[智价云] 累计挂网回填脚本更新

app/Jobs/Manager/CollectData/Backfill/LowPriceOnlineStatisticsjobs.php

@@ -11,6 +11,7 @@ use Illuminate\Queue\SerializesModels;
 use App\Models\Manager\Process\LowPriceGoods as LowPriceGoodsModel;
 use Illuminate\Support\Facades\DB;
 use App\Facades\Servers\Logs\Log;
+use Illuminate\Support\Carbon;
 
 
 /**
@@ -46,13 +47,16 @@ class LowPriceOnlineStatisticsjobs implements ShouldQueue
     public function handle()
     {
         $LowPriceGoodsModel = new LowPriceGoodsModel();
+        $start_time = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
         $company_id = $this->message_data['company_id'];
         $map_one = [];
         $map_one[] = ['process_lowprice_product.company_id', '=', $company_id];
         $map_one[] = ['process_lowprice_product.online_posting_count', '>', 0];
+        $map_one[] = ['process_lowprice_product.insert_time', '>=', $start_time];
         $map_two = [];
         $map_two[] = ['process_lowprice_product.company_id', '=', $company_id];
         $map_two[] = ['process_lowprice_product.continuous_listing_count', '>', 0];
+        $map_two[] = ['process_lowprice_product.insert_time', '>=', $start_time];
         $page = isset($this->message_data['page']) ? $this->message_data['page'] : 1;
         $limit = isset($this->message_data['limit']) ? $this->message_data['limit'] : 10;
         DB::beginTransaction();

app/Jobs/Manager/CollectData/Backfill/ViolationProductOnlineStatisticsjobs.php

@@ -11,6 +11,7 @@ use Illuminate\Queue\SerializesModels;
 use App\Models\Manager\Process\ViolationProduct as ViolationProductModel;
 use Illuminate\Support\Facades\DB;
 use App\Facades\Servers\Logs\Log;
+use Illuminate\Support\Carbon;
 
 
 /**
@@ -46,20 +47,23 @@ class ViolationProductOnlineStatisticsjobs implements ShouldQueue
     public function handle()
     {
         $ViolationProductModel = new ViolationProductModel();
+        $start_time = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
         $company_id = $this->message_data['company_id'];
         $map_one = [];
         $map_one[] = ['process_violation_product.company_id', '=', $company_id];
         $map_one[] = ['process_violation_product.online_posting_count', '>', 0];
+        $map_one[] = ['process_violation_product.insert_time', '>=', $start_time];
         $map_two = [];
         $map_two[] = ['process_violation_product.company_id', '=', $company_id];
         $map_two[] = ['process_violation_product.continuous_listing_count', '>', 0];
+        $map_two[] = ['process_violation_product.insert_time', '>=', $start_time];
         $page = isset($this->message_data['page']) ? $this->message_data['page'] : 1;
         $limit = isset($this->message_data['limit']) ? $this->message_data['limit'] : 10;
         DB::beginTransaction();
         try {
-            $filed =['process_violation_product.*','scrape_data.collect_config_info'];
+            $filed = ['process_violation_product.*', 'scrape_data.collect_config_info'];
             $result = $ViolationProductModel->leftJoin('scrape_data', 'process_violation_product.source_id', '=', 'scrape_data.id')
-            ->Orwhere($map_one)->Orwhere($map_two)->orderBy('process_violation_product.scrape_date', 'asc')->paginate($limit,$filed, 'page', $page)->toarray();
+                ->Orwhere($map_one)->Orwhere($map_two)->orderBy('process_violation_product.scrape_date', 'asc')->paginate($limit, $filed, 'page', $page)->toarray();
             $select_product_datas = $result['data'];
             $last_page = $result['last_page'];
             if (empty($select_product_datas)) {
@@ -74,11 +78,11 @@ class ViolationProductOnlineStatisticsjobs implements ShouldQueue
                 foreach ($result['data'] as $key => $product_data) {
                     $update_data = [];
                     $select_data = $ViolationProductModel->handleCountData($product_data);
-                    if(isset($select_data['online_posting_count']) && $select_data['online_posting_count'] > 1){
-                       $update_data['online_posting_count'] = $select_data['online_posting_count']; //累计挂网次数
+                    if (isset($select_data['online_posting_count']) && $select_data['online_posting_count'] > 1) {
+                        $update_data['online_posting_count'] = $select_data['online_posting_count']; //累计挂网次数
                     }
-                    if(isset($select_data['continuous_listing_count']) && $select_data['continuous_listing_count'] > 1){
-                        $update_data['continuous_listing_count'] = $select_data['continuous_listing_count'];//连续挂网次数
+                    if (isset($select_data['continuous_listing_count']) && $select_data['continuous_listing_count'] > 1) {
+                        $update_data['continuous_listing_count'] = $select_data['continuous_listing_count']; //连续挂网次数
                     }
                     if (!empty($update_data) && count($update_data) > 0) {
                         $ViolationProductModel->where('id', $product_data['id'])->update($update_data);