[智价云] 清洗规则增加只清洗前一周数据

app/Jobs/Manager/Process/LowPriceGoodsDataJobs.php

@@ -19,6 +19,7 @@ use App\Models\Manager\Citys as CitysModel;
 use App\Models\Manager\Personnel\EmployeePlatform as EmployeePlatformModel;
 use App\Models\Manager\Personnel\EmployeeArea as EmployeeAreaModel;
 use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Carbon;
 
 /**
  * 数据清洗-低价挂网商品队列
@@ -90,6 +91,10 @@ class LowPriceGoodsDataJobs implements ShouldQueue
             $platform = explode(',', $platform);
             $ScrapeDataModel = $ScrapeDataModel->whereIn('platform_id', $platform);
         }
+        $last7DaysStart = Carbon::today()->subDays(6)->startOfDay()->getTimestamp(); // 7天前开始
+        $last7DaysEnd = Carbon::today()->endOfDay()->getTimestamp(); // 到今天结束
+        $where[] = ['insert_time', '>=', $last7DaysStart];
+        $where[] = ['insert_time', '<=', $last7DaysEnd];
         $where[] = ['product_name', 'like', '%' . $product_name . '%'];
         $where[] = ['product_specs', 'like', '%' . $product_specs . '%'];
         $where[] = ['one_box_price', '<', $suggested_price];

app/Jobs/Manager/Process/ViolationProductDataJobs.php

@@ -19,6 +19,7 @@ use App\Models\Manager\Citys as CitysModel;
 use App\Models\Manager\Personnel\EmployeePlatform as EmployeePlatformModel;
 use App\Models\Manager\Personnel\EmployeeArea as EmployeeAreaModel;
 use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Carbon;
 
 /**
  * 数据清洗-违规挂网商品数据队列
@@ -89,6 +90,10 @@ class ViolationProductDataJobs implements ShouldQueue
             $platform = explode(',', $platform);
             $ScrapeDataModel = $ScrapeDataModel->whereIn('platform_id', $platform);
         }
+        $last7DaysStart = Carbon::today()->subDays(6)->startOfDay()->getTimestamp(); // 7天前开始
+        $last7DaysEnd = Carbon::today()->endOfDay()->getTimestamp(); // 到今天结束
+        $where[] = ['insert_time', '>=', $last7DaysStart];
+        $where[] = ['insert_time', '<=', $last7DaysEnd];
         $where[] = ['product_name', 'like', '%' . $product_name . '%'];
         $where[] = ['product_specs', 'like', '%' . $product_specs . '%'];
         if ($company_scope == 2) {

app/Jobs/Manager/Process/ViolationStoreDataJobs.php

@@ -18,6 +18,7 @@ use App\Models\Manager\Citys as CitysModel;
 use App\Models\Manager\Personnel\EmployeePlatform as EmployeePlatformModel;
 use App\Models\Manager\Personnel\EmployeeArea as EmployeeAreaModel;
 use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Carbon;
 
 /**
  * 数据清洗-违规店铺清洗数据队列
@@ -81,11 +82,16 @@ class ViolationStoreDataJobs implements ShouldQueue
         $page = isset($message_data['page']) ? $message_data['page'] : 1;
         $company_id = isset($message_data['company_id']) ? $message_data['company_id'] : 0;//品牌方公司ID
 
+
+        $last7DaysStart = Carbon::today()->subDays(6)->startOfDay()->getTimestamp(); // 7天前开始
+        $last7DaysEnd = Carbon::today()->endOfDay()->getTimestamp(); // 到今天结束
+        $where_map[] = ['insert_time', '>=', $last7DaysStart];
+        $where_map[] = ['insert_time', '<=', $last7DaysEnd];
         if ($platform != '0') {
             $platform = explode(',', $platform);
-            $ScrapeDataModel = $ScrapeDataModel->where('qualification_number', $social_credit_code)->whereIn('platform_id', $platform);
+            $ScrapeDataModel = $ScrapeDataModel->where('qualification_number', $social_credit_code)->where($where_map)->whereIn('platform_id', $platform);
         } else {
-            $ScrapeDataModel = $ScrapeDataModel->where('qualification_number', $social_credit_code);
+            $ScrapeDataModel = $ScrapeDataModel->where('qualification_number', $social_credit_code)->where($where_map);
         }
         $product_data_info = $ScrapeDataModel->paginate($limit, ['*'], 'page', $page)->toarray();
         $product_datas = $product_data_info['data'];