[智价云] 采集队列日志更新

app/Jobs/Manager/CollectData/JdTmao/JdTmaoProductDataJobs.php

@@ -159,14 +159,12 @@ class JdTmaoProductDataJobs implements ShouldQueue
                 JdTmaoProductJobs::dispatch($message_data);
             }
         } catch (\Exception $e) {
-            print_r($e->getMessage());
-            exit;
             Log::info('job_error', '采集数据-医药城数据处理队列失败', ['data' => $this->message_data, 'error' => $e->getMessage()]);
         }
     }
 
     public function failed(\Throwable $exception)
     {
-        Log::info('job_error', '采集数据-医药城数据处理队列完全失败', ['data' => $this->message_data, 'error' => $exception]);
+        Log::info('job_error', '采集数据-京东天猫数据处理队列完全失败', ['data' => $this->message_data, 'error' => $exception]);
     }
 }

app/Jobs/Manager/CollectData/JdTmao/JdTmaoProductJobs.php

@@ -88,8 +88,12 @@ class JdTmaoProductJobs implements ShouldQueue
 
             Log::info('job_info', '采集数据-京东天猫数据同步队列日志', ['data' => ['page' => $page, 'limit' => $limit, 'totle' => $total]]);
         } catch (\Exception $e) {
-            print_r($e->getMessage());exit;
             Log::info('job_error', '采集数据-京东天猫数据同步队列失败', ['error' => $e->getMessage()]);
         }
     }
+
+    public function failed(\Throwable $exception)
+    {
+        Log::info('job_error', '采集数据-京东天猫数据处理队列完全失败', ['data' => $this->message_data, 'error' => $exception]);
+    }
 }

app/Jobs/Manager/CollectData/JdTmao/JdTmaoStoreJobs.php

@@ -51,6 +51,8 @@ class JdTmaoStoreJobs implements ShouldQueue
                 $item['queue_total'] =  $this->message_data['queue_total'];
                 JdTmaoProductDataJobs::dispatch($item);
                 // JdTmaoProductDataJobs::dispatchSync($item);
+                unset($item);
+                gc_collect_cycles();
             }
         } catch (\Exception $e) {
             Log::info('job_error', '采集数据-药师帮店铺数据同步队列失败', ['error' => $e->getMessage()]);

app/Jobs/Manager/CollectData/Ysbang/YsbangProductJobs.php

@@ -80,4 +80,9 @@ class YsbangProductJobs implements ShouldQueue
             Log::info('job_error', '采集数据-药师帮数据同步队列失败', ['error' => $e->getMessage()]);
         }
     }
+
+    public function failed(\Throwable $exception)
+    {
+        Log::info('job_error', '采集数据-药师帮产品数据同步队列完全失败', ['data' => $this->message_data, 'error' => $exception]);
+    }
 }

app/Jobs/Manager/CollectData/Ysbang/YsbangStoreJobs.php

@@ -50,6 +50,8 @@ class YsbangStoreJobs implements ShouldQueue
                 $item['queue_total'] =  $this->message_data['queue_total'];
                 YsbangProductDataJobs::dispatch($item);
                 // YsbangProductDataJobs::dispatchSync($item);
+                unset($item);
+                gc_collect_cycles();
             }
         } catch (\Exception $e) {
             Log::info('job_error', '采集数据-药师帮店铺数据同步队列失败', ['error' => $e->getMessage()]);

app/Jobs/Manager/CollectData/Yycheng/YychengProductJobs.php

@@ -82,4 +82,9 @@ class YychengProductJobs implements ShouldQueue
             Log::info('job_error', '采集数据-医药城数据同步队列失败', ['error' => $e->getMessage()]);
         }
     }
+
+    public function failed(\Throwable $exception)
+    {
+        Log::info('job_error', '采集数据-医药城数据处理队列完全失败', ['data' => $this->message_data, 'error' => $exception]);
+    }
 }

app/Jobs/Manager/CollectData/Yycheng/YychengStoreJobs.php

@@ -51,6 +51,8 @@ class YychengStoreJobs implements ShouldQueue
                 $item['queue_total'] =  $this->message_data['queue_total'];
                 YychengProductDataJobs::dispatch($item);
                 // YychengProductDataJobs::dispatchSync($item);
+                unset($item);
+                gc_collect_cycles();
             }
         } catch (\Exception $e) {
             Log::info('job_error', '采集数据-药师帮店铺数据同步队列失败', ['error' => $e->getMessage()]);