Просмотр исходного кода

[智价云] 清洗频率调整为5分钟清洗一次

tangyuanwang 3 часов назад
Родитель
Сommit
965c92a1a9

+ 4 - 6
app/Jobs/Manager/Process/LowPriceGoodsDataJobs.php

@@ -97,12 +97,10 @@ class LowPriceGoodsDataJobs implements ShouldQueue
             $ScrapeDataModel = $ScrapeDataModel->whereIn('platform_id', $platform);
         }
         $ScrapeDataModel = $ScrapeDataModel->where([['min_price', '>=', '0.01'], ['number', '>=', '1']]);
-
-        // $yesterdayStart = Carbon::today()->subDays(6)->startOfDay()->getTimestamp(); // 最近7天开始时间 00:00:00
-        $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
-        $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
-        $yesterdayStart = date('Y-m-d', $yesterdayStart);
-        $yesterdayEnd = date('Y-m-d', $yesterdayEnd);
+        $start_time = time() - 60 * 5; // 开始时间 5分钟之前
+        $end_time = time();//结束时间
+        $yesterdayStart = date('Y-m-d', $start_time);
+        $yesterdayEnd = date('Y-m-d', $end_time);
         $where[] = ['scrape_date', '>=', $yesterdayStart];
         $where[] = ['scrape_date', '<=', $yesterdayEnd];
         $where[] = ['product_name', 'like', '%' . $product_name . '%'];

+ 4 - 5
app/Jobs/Manager/Process/ViolationCompanyDataJobs.php

@@ -85,11 +85,10 @@ class ViolationCompanyDataJobs implements ShouldQueue
         $item_totle_page = $message_data['item_totle_page']; //清洗店铺总页数
         $item_now_page = $message_data['item_now_page']; //清洗店铺当前页
 
-        // $yesterdayStart = Carbon::today()->subDays(6)->startOfDay()->getTimestamp(); // 最近7天开始时间 00:00:00
-        $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
-        $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
-        $yesterdayStart = date('Y-m-d', $yesterdayStart);
-        $yesterdayEnd = date('Y-m-d', $yesterdayEnd);
+        $start_time = time() - 60 * 5; // 开始时间 5分钟之前
+        $end_time = time();//结束时间
+        $yesterdayStart = date('Y-m-d', $start_time);
+        $yesterdayEnd = date('Y-m-d', $end_time);
         $where_map[] = ['scrape_date', '>=', $yesterdayStart];
         $where_map[] = ['scrape_date', '<=', $yesterdayEnd];
 

+ 4 - 5
app/Jobs/Manager/Process/ViolationProductDataJobs.php

@@ -95,11 +95,10 @@ class ViolationProductDataJobs implements ShouldQueue
             $platform = explode(',', $platform);
             $ScrapeDataModel = $ScrapeDataModel->whereIn('platform_id', $platform);
         }
-        // $yesterdayStart = Carbon::today()->subDays(6)->startOfDay()->getTimestamp(); // 最近7天开始时间 00:00:00
-        $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
-        $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
-        $yesterdayStart = date('Y-m-d', $yesterdayStart);
-        $yesterdayEnd = date('Y-m-d', $yesterdayEnd);
+        $start_time = time() - 60 * 5; // 开始时间 5分钟之前
+        $end_time = time();//结束时间
+        $yesterdayStart = date('Y-m-d', $start_time);
+        $yesterdayEnd = date('Y-m-d', $end_time);
         $where[] = ['scrape_date', '>=', $yesterdayStart];
         $where[] = ['scrape_date', '<=', $yesterdayEnd];
         $where[] = ['product_name', 'like', '%' . $product_name . '%'];

+ 4 - 5
app/Jobs/Manager/Process/ViolationStoreDataJobs.php

@@ -80,11 +80,10 @@ class ViolationStoreDataJobs implements ShouldQueue
         $item_totle_page = $message_data['item_totle_page']; //清洗店铺总页数
         $item_now_page = $message_data['item_now_page']; //清洗店铺当前页
 
-        // $yesterdayStart = Carbon::today()->subDays(6)->startOfDay()->getTimestamp(); // 最近7天开始时间 00:00:00
-        $yesterdayStart = Carbon::yesterday()->startOfDay()->getTimestamp(); // 昨天开始时间 00:00:00
-        $yesterdayEnd = Carbon::yesterday()->endOfDay()->getTimestamp(); // 昨天结束时间 23:59:59
-        $yesterdayStart = date('Y-m-d', $yesterdayStart);
-        $yesterdayEnd = date('Y-m-d', $yesterdayEnd);
+        $start_time = time() - 60 * 5; // 开始时间 5分钟之前
+        $end_time = time();//结束时间
+        $yesterdayStart = date('Y-m-d', $start_time);
+        $yesterdayEnd = date('Y-m-d', $end_time);
         $where_map[] = ['scrape_date', '>=', $yesterdayStart];
         $where_map[] = ['scrape_date', '<=', $yesterdayEnd];