LowPriceGoodsDataJobs.php 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367
  1. <?php
  2. namespace App\Jobs\Manager\Process;
  3. use Illuminate\Bus\Queueable;
  4. use Illuminate\Contracts\Queue\ShouldBeUnique;
  5. use Illuminate\Contracts\Queue\ShouldQueue;
  6. use Illuminate\Foundation\Bus\Dispatchable;
  7. use Illuminate\Queue\InteractsWithQueue;
  8. use Illuminate\Queue\SerializesModels;
  9. use App\Facades\Servers\Logs\Log;
  10. use App\Models\Manager\Process\LowPriceGoods as LowPriceGoodsModel;
  11. use App\Models\Manager\Personnel\Employee as EmployeeModel;
  12. use App\Models\Api\Process\ExecuteLog as ExecuteLogModel;
  13. use App\Models\Manager\Process\ScrapeData as ScrapeDataModel;
  14. use App\Models\Manager\WashConfig\ViolationStore as ViolationStoreModel;
  15. use App\Models\Manager\WashConfig\ViolationCompanyMember as ViolationCompanyMemberModel;
  16. use App\Models\Manager\Citys as CitysModel;
  17. use App\Models\Manager\Personnel\EmployeePlatform as EmployeePlatformModel;
  18. use App\Models\Manager\Personnel\EmployeeArea as EmployeeAreaModel;
  19. use Illuminate\Support\Facades\DB;
  20. use Illuminate\Support\Carbon;
  21. /**
  22. * 数据清洗-低价挂网商品队列
  23. * @author 唐远望
  24. * @version 1.0
  25. * @date 2025-12-10
  26. */
  27. class LowPriceGoodsDataJobs implements ShouldQueue
  28. {
  29. use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
  30. protected $message_data;
  31. /**
  32. * Create a new job instance.
  33. *
  34. * @return void
  35. */
  36. public function __construct(array $message_data)
  37. {
  38. $this->message_data = $message_data;
  39. }
  40. /**
  41. * Execute the job.
  42. *
  43. * @return void
  44. */
  45. public function handle()
  46. {
  47. try {
  48. $this->getLowPriceGoodsData($this->message_data);
  49. } catch (\Exception $e) {
  50. Log::info('job_error', '数据清洗-低价挂网商品队列失败', ['data' => $this->message_data, 'error' => $e->getMessage()]);
  51. }
  52. }
  53. /**
  54. * 采集商品数据清洗
  55. * @author 唐远望
  56. * @version 1.0
  57. * @date 2025-12-10
  58. */
  59. public function getLowPriceGoodsData($message_data)
  60. {
  61. $CitysModel = new CitysModel();
  62. $EmployeeModel = new EmployeeModel();
  63. $LowPriceGoodsModel = new LowPriceGoodsModel();
  64. $ScrapeDataModel = new ScrapeDataModel();
  65. $ViolationStoreModel = new ViolationStoreModel();
  66. $ViolationCompanyMemberModel = new ViolationCompanyMemberModel();
  67. $EmployeePlatformModel = new EmployeePlatformModel();
  68. $EmployeeAreaModel = new EmployeeAreaModel();
  69. $platform = $message_data['platform']; //多个平台配置
  70. $product_name = $message_data['product_name']; //商品名称
  71. $product_specs = $message_data['product_specs']; //商品规格
  72. $suggested_price = $message_data['suggested_price']; //监控价格格
  73. $store_scope = $message_data['store_scope']; //店铺范围1=全部店铺2=指定店铺
  74. $company_scope = $message_data['company_scope']; //公司范围1=全部公司2=指定公司
  75. $social_credit_code = $message_data['social_credit_code']; //社会信用代码
  76. $executeLog_id = $message_data['executeLog_id'];
  77. $category_name = $message_data['category_name']; //产品分类名称
  78. $specify_responsible_person = $message_data['specify_responsible_person']; //指派责任人 0=开启 1=关闭
  79. $limit = isset($message_data['limit']) ? $message_data['limit'] : 50;
  80. $page = isset($message_data['page']) ? $message_data['page'] : 1;
  81. $company_id = isset($message_data['company_id']) ? $message_data['company_id'] : 0; //品牌方公司ID
  82. $product_brand = $message_data['product_brand']; //商品品牌名称
  83. $product_keywords = $message_data['product_keyword']; //关键字
  84. $where = [];
  85. if ($platform != '0') {
  86. $platform = explode(',', $platform);
  87. $ScrapeDataModel = $ScrapeDataModel->whereIn('platform_id', $platform);
  88. }
  89. $last7DaysStart = Carbon::today()->subDays(6)->startOfDay()->getTimestamp(); // 7天前开始
  90. $last7DaysEnd = Carbon::today()->endOfDay()->getTimestamp(); // 到今天结束
  91. $where[] = ['insert_time', '>=', $last7DaysStart];
  92. $where[] = ['insert_time', '<=', $last7DaysEnd];
  93. $where[] = ['product_name', 'like', '%' . $product_name . '%'];
  94. $where[] = ['product_specs', 'like', '%' . $product_specs . '%'];
  95. $where[] = ['one_box_price', '<', $suggested_price];
  96. if ($product_brand) $where[] = ['product_name', 'like', '%' . $product_brand . '%'];
  97. if (!empty($product_keyword)) {
  98. foreach ($product_keywords as $key => $keywords) {
  99. if (trim($keywords) == '') continue;
  100. $where[] = ['product_name', 'like', '%' . $keywords . '%'];
  101. }
  102. }
  103. if ($company_scope == 2 && $social_credit_code != '') {
  104. $ScrapeDataModel->whereIn('qualification_number', $social_credit_code);
  105. }
  106. $product_data_info = $ScrapeDataModel->where($where)->paginate($limit, ['*'], 'page', $page)->toarray();
  107. $product_datas = $product_data_info['data'];
  108. if (empty($product_datas)) {
  109. if ($executeLog_id) {
  110. (new ExecuteLogModel())->where('id', $executeLog_id)->update(['status' => 0, 'update_time' => time()]);
  111. }
  112. return true;
  113. }
  114. foreach ($product_datas as $product_data) {
  115. $province_name = $product_data['province_name'];
  116. $city_name = $product_data['city_name'];
  117. //特殊地区1级移除市
  118. if ($province_name && in_array($province_name, ['北京市', '天津市', '上海市', '重庆市'])) {
  119. //移除市这个字符
  120. $province_name = trim(str_replace('市', '', $province_name));
  121. } else if ($province_name && in_array($province_name, ['北京', '天津', '上海', '重庆'])) {
  122. } else if ($province_name && in_array($province_name, ['内蒙古', '广西', '西藏', '新疆', '宁夏'])) {
  123. switch ($province_name) {
  124. case '内蒙古':
  125. $province_name = '内蒙古自治区';
  126. break;
  127. case '广西':
  128. $province_name = '广西壮族自治区';
  129. break;
  130. case '西藏':
  131. $province_name = '西藏自治区';
  132. break;
  133. case '新疆':
  134. $province_name = '新疆维吾尔自治区';
  135. break;
  136. case '宁夏':
  137. $province_name = '宁夏回族自治区';
  138. break;
  139. }
  140. } else if ($province_name && in_array($province_name, ['内蒙古自治区', '广西壮族自治区', '西藏自治区', '新疆维吾尔自治区', '宁夏回族自治区'])) {
  141. } else if (strpos($province_name, '省') === false) {
  142. //是否存在市省,如果不存在则补全
  143. if (strpos($province_name, '省') === false) {
  144. $province_name = $province_name . '省';
  145. }
  146. }
  147. if ($city_name != '') {
  148. $city_name = $CitysModel->where([['id', '=', $product_data['city_id']], ['level', '=', '2']])->value('name');
  149. }
  150. $insert_product_data = [
  151. 'company_id' => $company_id,
  152. 'source_id' => $product_data['id'],
  153. 'platform' => $product_data['platform_id'],
  154. 'company_name' => $product_data['company_name'],
  155. 'social_credit_code' => $product_data['qualification_number'],
  156. 'product_name' => $product_name,
  157. 'product_specs' => $product_specs,
  158. 'inventory' => $product_data['inventory'] ? $product_data['inventory'] : '',
  159. 'sales' => $product_data['sales'] ? $product_data['sales'] : '',
  160. 'snapshot_url' => $product_data['snapshot_url'] ? $product_data['snapshot_url'] : '',
  161. 'suggested_price' => $suggested_price,
  162. 'online_posting_price' => $product_data['one_box_price'],
  163. 'online_posting_count' => $product_data['online_posting_count'],
  164. 'continuous_listing_count' => $product_data['continuous_listing_count'],
  165. 'link_url' => $product_data['link_url'],
  166. 'store_name' => $product_data['store_name'],
  167. 'province_id' => $product_data['province_id'],
  168. 'province_name' => $province_name,
  169. 'city_id' => $product_data['city_id'],
  170. 'city_name' => $city_name,
  171. 'area_info' => $product_data['area_info'],
  172. 'category_name' => $category_name,
  173. 'company_category_name' => '',
  174. 'first_responsible_person' => '',
  175. 'responsible_person' => '',
  176. 'source_responsible_person' => '',
  177. 'scrape_date' => $product_data['scrape_date'],
  178. 'shipment_province_id' => $product_data['shipment_province_id'],
  179. 'shipment_province_name' => $product_data['shipment_province_name'],
  180. 'shipment_city_id' => $product_data['shipment_city_id'],
  181. 'shipment_city_name' => $product_data['shipment_city_name'],
  182. ];
  183. //获取公司绑定责任人信息
  184. $company_data = $ViolationStoreModel->leftjoin('washconfig_company_category', 'washconfig_company_category.id', '=', 'washconfig_violation_store.category_id')
  185. ->where('washconfig_violation_store.social_credit_code', $product_data['qualification_number'])
  186. ->where('washconfig_violation_store.company_id', $company_id)
  187. ->select(['washconfig_violation_store.id', 'washconfig_company_category.name as category_name'])->first();
  188. $employee_id_list = [];
  189. if ($company_data) {
  190. $employee_id_list = $ViolationCompanyMemberModel->where('company_logid', $company_data->id)->pluck('employee_id')->toarray();
  191. $insert_product_data['company_category_name'] = $company_data->category_name ? $company_data->category_name : '';
  192. }
  193. //获取指定人员信息
  194. if ($specify_responsible_person == 0) {
  195. $where_query1 = [];
  196. $where_query2 = [];
  197. $where_query3 = [];
  198. //查询指定公司第一责任人
  199. if (!empty($employee_id_list)) {
  200. $where_query1[] = ['company_id', '=', $company_id];
  201. $where_query1[] = ['id', 'in', $employee_id_list];
  202. $where_query1[] = ['status', '=', 0];
  203. $where_query1[] = ['duty_type', '=', 1]; //责任类型1=第一责任人,2=责任人
  204. }
  205. //查询地区配置的第一责任人
  206. $employee_id_area = $EmployeeAreaModel->where('city_id', $product_data['city_id'])->pluck('employee_id')->toarray();
  207. if (!empty($employee_id_area)) {
  208. $where_query2[] = ['company_id', '=', $company_id];
  209. $where_query2[] = ['id', 'in', $employee_id_area];
  210. $where_query2[] = ['status', '=', 0];
  211. $where_query2[] = ['duty_type', '=', 1]; //责任类型1=第一责任人,2=责任人
  212. }
  213. //查询平台配置的第一责任人
  214. $employee_id_platform = $EmployeePlatformModel->where('platform_id', $product_data['platform_id'])->pluck('employee_id')->toarray();
  215. if (!empty($employee_id_platform)) {
  216. $where_query3[] = ['company_id', '=', $company_id];
  217. $where_query3[] = ['id', 'in', $employee_id_platform];
  218. $where_query3[] = ['status', '=', 0];
  219. $where_query3[] = ['duty_type', '=', 1]; //责任类型1=第一责任人,2=责任人
  220. }
  221. //并行查询第一责任人
  222. $EmployeeModel = $EmployeeModel->where(function ($q) use ($employee_id_list, $company_id) {
  223. if (!empty($employee_id_list)) {
  224. $q->where('company_id', $company_id)
  225. ->orWhereIn('id', $employee_id_list)
  226. ->where('status', 0)
  227. ->where('duty_type', 1);
  228. }
  229. })->orWhere(function ($q) use ($employee_id_area, $company_id) {
  230. if (!empty($employee_id_area)) {
  231. $q->where('company_id', $company_id)
  232. ->whereIn('id', $employee_id_area)
  233. ->where('status', 0)
  234. ->where('duty_type', 1);
  235. }
  236. })->orWhere(function ($q) use ($employee_id_platform, $company_id) {
  237. if (!empty($employee_id_platform)) {
  238. $q->where('company_id', $company_id)
  239. ->whereIn('id', $employee_id_platform)
  240. ->where('status', 0)
  241. ->where('duty_type', 1);
  242. }
  243. });
  244. $first_responsible_person = $EmployeeModel->pluck('id')->implode(',');
  245. //当以上规则匹配不到责任人时,则去查询发货地区信息关联责任人
  246. if (trim($first_responsible_person) == '' && trim($product_data['shipment_city_id']) != '') {
  247. $employee_id_area = $EmployeeAreaModel->where('city_id', $product_data['city_id'])->pluck('employee_id')->toarray();
  248. if (!empty($employee_id_area)) {
  249. $where_city[] = ['company_id', '=', $company_id];
  250. $where_city[] = ['id', 'in', $employee_id_area];
  251. $where_city[] = ['status', '=', 0];
  252. $where_city[] = ['duty_type', '=', 1]; //责任类型1=第一责任人,2=责任人
  253. $EmployeeModel = new EmployeeModel();
  254. $first_responsible_person = $EmployeeModel->where($where_city)->pluck('id')->implode(',');
  255. }
  256. }
  257. //调试记录查询条件
  258. $insert_product_data['first_responsible_person'] = $first_responsible_person;
  259. //查询责任人
  260. $where_query1 = [];
  261. $where_query2 = [];
  262. $where_query3 = [];
  263. //查询指定公司责任人
  264. if (!empty($employee_id_list)) {
  265. $where_query1[] = ['company_id', '=', $company_id];
  266. $where_query1[] = ['id', 'in', $employee_id_list];
  267. $where_query1[] = ['status', '=', 0];
  268. $where_query1[] = ['duty_type', '=', 2]; //责任类型1=第一责任人,2=责任人
  269. }
  270. //查询地区配置的员工
  271. $employee_id_area = $EmployeeAreaModel->where('city_id', $product_data['city_id'])->pluck('employee_id')->toarray();
  272. if (!empty($employee_id_area)) {
  273. $where_query2[] = ['company_id', '=', $company_id];
  274. $where_query2[] = ['id', 'in', $employee_id_area];
  275. $where_query2[] = ['status', '=', 0];
  276. $where_query2[] = ['duty_type', '=', 2]; //责任类型1=第一责任人,2=责任人
  277. }
  278. //查询平台配置的员工
  279. $employee_id_platform = $EmployeePlatformModel->where('platform_id', $product_data['platform_id'])->pluck('employee_id')->toarray();
  280. if (!empty($employee_id_platform)) {
  281. $where_query3[] = ['company_id', '=', $company_id];
  282. $where_query3[] = ['id', 'in', $employee_id_platform];
  283. $where_query3[] = ['status', '=', 0];
  284. $where_query3[] = ['duty_type', '=', 2]; //责任类型1=第一责任人,2=责任人
  285. }
  286. //并行查询责任人
  287. $EmployeeModel = new EmployeeModel();
  288. $EmployeeModel = $EmployeeModel->where(function ($q) use ($employee_id_list, $company_id) {
  289. if (!empty($employee_id_list)) {
  290. $q->where('company_id', $company_id)
  291. ->orWhereIn('id', $employee_id_list)
  292. ->where('status', 0)
  293. ->where('duty_type', 2); //责任类型1=第一责任人,2=责任人
  294. }
  295. })->orWhere(function ($q) use ($employee_id_area, $company_id) {
  296. if (!empty($employee_id_area)) {
  297. $q->where('company_id', $company_id)
  298. ->whereIn('id', $employee_id_area)
  299. ->where('status', 0)
  300. ->where('duty_type', 2); //责任类型1=第一责任人,2=责任人
  301. }
  302. })->orWhere(function ($q) use ($employee_id_platform, $company_id) {
  303. if (!empty($employee_id_platform)) {
  304. $q->where('company_id', $company_id)
  305. ->whereIn('id', $employee_id_platform)
  306. ->where('status', 0)
  307. ->where('duty_type', 2); //责任类型1=第一责任人,2=责任人
  308. }
  309. });
  310. $responsible_person = $EmployeeModel->pluck('id')->implode(',');
  311. //当以上规则匹配不到责任人时,则去查询发货地区信息关联责任人
  312. if (trim($responsible_person) == '' && trim($product_data['shipment_city_id']) != '') {
  313. $employee_id_area = $EmployeeAreaModel->where('city_id', $product_data['city_id'])->pluck('employee_id')->toarray();
  314. if (!empty($employee_id_area)) {
  315. $where_city[] = ['company_id', '=', $company_id];
  316. $where_city[] = ['id', 'in', $employee_id_area];
  317. $where_city[] = ['status', '=', 0];
  318. $where_city[] = ['duty_type', '=', 2]; //责任类型1=第一责任人,2=责任人
  319. $EmployeeModel = new EmployeeModel();
  320. $responsible_person = $EmployeeModel->where($where_city)->pluck('id')->implode(',');
  321. }
  322. }
  323. $insert_product_data['responsible_person'] = $responsible_person;
  324. //溯源责任人
  325. $source_responsible_person = '';
  326. if ($first_responsible_person && $responsible_person) {
  327. //转换成数组,合并后在去重
  328. $first_responsible_person = explode(',', $first_responsible_person);
  329. $responsible_person = explode(',', $responsible_person);
  330. $source_responsible_person = array_unique(array_merge($first_responsible_person, $responsible_person));
  331. $source_responsible_person = ',' . implode(',', $source_responsible_person) . ',';
  332. } else if ($first_responsible_person) {
  333. $source_responsible_person = $first_responsible_person;
  334. } else if ($responsible_person) {
  335. $source_responsible_person = $responsible_person;
  336. }
  337. $insert_product_data['source_responsible_person'] = $source_responsible_person;
  338. }
  339. //插入数据
  340. $LowPriceGoodsModel->addLowPriceGoods($insert_product_data);
  341. }
  342. //继续执行下一页
  343. $message_data['page'] = $page + 1;
  344. $message_data['limit'] = $limit;
  345. $this->dispatch($message_data);
  346. }
  347. public function failed(\Throwable $exception)
  348. {
  349. Log::info('job_error', '数据清洗-低价挂网商品队列完全失败', ['data' => $this->message_data, 'error' => $exception]);
  350. }
  351. }