Kaynağa Gözat

[智价云] 队列优化

tangyuanwang 21 saat önce
ebeveyn
işleme
621f1cece8

+ 1 - 1
app/Jobs/Manager/Process/LowPriceGoodsDataJobs.php

@@ -534,7 +534,7 @@ class LowPriceGoodsDataJobs implements ShouldQueue
         //继续执行下一页
         $message_data['page'] = $page + 1;
         $message_data['limit'] = $limit;
-        $this->dispatch($message_data);
+        LowPriceGoodsDataJobs::dispatch($message_data)->delay(now()->addSeconds(1));
     }
 
 

+ 1 - 1
app/Jobs/Manager/Process/LowPriceGoodsJobs.php

@@ -106,7 +106,7 @@ class LowPriceGoodsJobs implements ShouldQueue
                 'page' => $page + 1,
                 'executeLog_id' => $executeLog_id,
             ];
-            $this->dispatchSync($now_message_data);
+            LowPriceGoodsJobs::dispatch($now_message_data)->delay(now()->addSeconds(1));
         } catch (\Exception $e) {
             Log::info('job_error', '数据清洗-低价挂网商品配置队列失败', ['data' => $this->message_data, 'error' => $e->getMessage()]);
         }