[智价云] 优先级清洗更新

app/Console/Commands/DailyTask.php

@@ -43,16 +43,23 @@ class DailyTask extends Command
         try {
             Log::info('每日数据清洗任务执行中 - ' . now());
             $CompanyModel = new CompanyModel();
-            $company_list = $CompanyModel->select(['id', 'status'])->where('status', 0)->orderByDesc('cleaning_priority')->get()->toarray();
-            foreach ($company_list as $company) {
-                $message_data = ['company_id' => $company['id'], 'page' => '1', 'limit' => '50'];
-                //执行低价挂网商品数据清洗任务
-                LowPriceGoodsJobs::dispatch($message_data);
-                //执行违规商品数据清洗任务
-                ViolationProductJobs::dispatch($message_data);
-                //执行违规门店数据清洗任务
-                ViolationStoreJobs::dispatch($message_data);
-            }
+            // $company_list = $CompanyModel->select(['id', 'status'])->where('status', 0)->orderByDesc('cleaning_priority')->get()->toarray();
+            // foreach ($company_list as $company) {
+            //     $message_data = ['company_id' => $company['id'], 'page' => '1', 'limit' => '50'];
+            //     //执行低价挂网商品数据清洗任务
+            //     LowPriceGoodsJobs::dispatch($message_data);
+            //     //执行违规商品数据清洗任务
+            //     ViolationProductJobs::dispatch($message_data);
+            //     //执行违规门店数据清洗任务
+            //     ViolationStoreJobs::dispatch($message_data);
+            // }
+            $message_data = ['page' => '1', 'limit' => '50'];
+            //执行低价挂网商品数据清洗任务
+            LowPriceGoodsJobs::dispatch($message_data);
+            //执行违规商品数据清洗任务
+            ViolationProductJobs::dispatch($message_data);
+            //执行违规门店数据清洗任务
+            ViolationStoreJobs::dispatch($message_data);
             // 示例：记录日志
             $this->info('每日任务执行完成！');
             return Command::SUCCESS;