[智价云] 清洗优化调整

app/Jobs/Manager/Process/LowPriceGoodsDataJobs.php

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

app/Jobs/Manager/Process/LowPriceGoodsJobs.php

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

app/Jobs/Manager/Process/ViolationCompanyDataJobs.php

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

app/Jobs/Manager/Process/ViolationCompanyJobs.php

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

app/Jobs/Manager/Process/ViolationProductDataJobs.php

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

app/Jobs/Manager/Process/ViolationProductJobs.php

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

app/Jobs/Manager/Process/ViolationStoreDataJobs.php

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

app/Jobs/Manager/Process/ViolationStoreJobs.php

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