[智价云] 队列优化更新

app/Jobs/Manager/Process/ViolationCompanyDataJobs.php

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

app/Jobs/Manager/Process/ViolationCompanyJobs.php

@@ -90,7 +90,7 @@ class ViolationCompanyJobs implements ShouldQueue
                 'page' => $page + 1,
                 'executeLog_id' => $executeLog_id,
             ];
-            ViolationCompanyJobs::dispatch($now_message_data);
+            ViolationCompanyJobs::dispatch($now_message_data)->delay(now()->addSeconds(1));
         } catch (\Exception $e) {
             Log::info('job_error', '数据清洗-违规挂网公司队列失败', ['data' => $this->message_data, 'error' => $e->getMessage()]);
         }

app/Jobs/Manager/Process/ViolationProductDataJobs.php

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

app/Jobs/Manager/Process/ViolationProductJobs.php

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

app/Jobs/Manager/Process/ViolationStoreDataJobs.php

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

app/Jobs/Manager/Process/ViolationStoreJobs.php

@@ -87,7 +87,7 @@ class ViolationStoreJobs implements ShouldQueue
                 'page' => $page + 1,
                 'executeLog_id' => $executeLog_id,
             ];
-            ViolationStoreJobs::dispatch($now_message_data);
+            ViolationStoreJobs::dispatch($now_message_data)->delay(now()->addSeconds(1));
         } catch (\Exception $e) {
             Log::info('job_error', '数据清洗-违规挂网店铺队列失败', ['data' => $this->message_data, 'error' => $e->getMessage()]);
         }