[智价云] 分块更新

app/Console/Commands/DailyTask.php

@@ -46,7 +46,7 @@ class DailyTask extends Command
             $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' => '10000', 'start_time' => $start_time, 'end_time' => $end_time];
+                $message_data = ['company_id' => $company['id'], 'page' => '1', 'limit' => '1000', 'start_time' => $start_time, 'end_time' => $end_time];
                 //执行低价挂网商品数据清洗任务
                 ScrapeDataProductJobs::dispatch($message_data);
             }

app/Jobs/Manager/Process/ScrapeDataProductJobs.php

@@ -142,7 +142,7 @@ class ScrapeDataProductJobs implements ShouldQueue
         $index_number = 0;
         foreach ($cache_product_datas as $key => $product_data) {
             $index_number = $key + 1;
-            $message_data = ['company_id' => $company_id, 'page' => '1', 'limit' => '10000', 'product_data' => $product_data, 'index_number' => $index_number, 'data_totle' => $data_totle];
+            $message_data = ['company_id' => $company_id, 'page' => '1', 'limit' => '1000', 'product_data' => $product_data, 'index_number' => $index_number, 'data_totle' => $data_totle];
             LowPriceGoodsJobs::dispatch($message_data);
             // LowPriceGoodsJobs::dispatchSync($message_data);
             ViolationProductJobs::dispatch($message_data);