[智价云] 增加采集时间清洗

app/Jobs/Manager/Process/LowPriceGoodsDataJobs.php

@@ -203,6 +203,7 @@ class LowPriceGoodsDataJobs implements ShouldQueue
                 'responsible_person' => '',
                 'source_responsible_person' => '',
                 'scrape_date' => $product_data['scrape_date'],
+                'collection_time' => strtotime($product_data['insert_time']),
                 'shipment_province_id' => $product_data['shipment_province_id'],
                 'shipment_province_name' => $product_data['shipment_province_name'],
                 'shipment_city_id' => $product_data['shipment_city_id'],

app/Jobs/Manager/Process/ViolationProductDataJobs.php

@@ -194,6 +194,7 @@ class ViolationProductDataJobs implements ShouldQueue
                 'responsible_person' => '',
                 'source_responsible_person' => '',
                 'scrape_date' => $product_data['scrape_date'],
+                'collection_time' => strtotime($product_data['insert_time']),
                 'shipment_province_id' => $product_data['shipment_province_id'],
                 'shipment_province_name' => $product_data['shipment_province_name'],
                 'shipment_city_id' => $product_data['shipment_city_id'],

app/Jobs/Manager/Process/ViolationStoreDataJobs.php

@@ -166,6 +166,7 @@ class ViolationStoreDataJobs implements ShouldQueue
                 'responsible_person' => '',
                 'source_responsible_person' => '',
                 'scrape_date' => $product_data['scrape_date'],
+                'collection_time' => strtotime($product_data['insert_time']),
             ];
             //获取公司绑定责任人信息
             $company_data = $ViolationStoreModel->where('social_credit_code', $product_data['qualification_number'])

app/Models/Manager/Process/LowPriceGoods.php

@@ -92,6 +92,7 @@ class LowPriceGoods extends Model
             'processing_status' => '1',
             'insert_time' => time(),
             'scrape_date' => isset($data['scrape_date']) ? $data['scrape_date'] : '',
+            'collection_time' => isset($data['collection_time']) ? $data['collection_time'] : '',
             'shipment_province_id' => isset($data['shipment_province_id']) ? $data['shipment_province_id'] : '0', // 发货省份id
             'shipment_province_name' => isset($data['shipment_province_name']) ? $data['shipment_province_name'] : '', // 发货省份
             'shipment_city_id' => isset($data['shipment_city_id']) ? $data['shipment_city_id'] : '0', // 发货城市id
@@ -156,6 +157,7 @@ class LowPriceGoods extends Model
                 'processing_status' => '1',
                 'insert_time' => time(),
                 'scrape_date' => isset($data['scrape_date']) ? $data['scrape_date'] : '',
+                'collection_time' => isset($data['collection_time']) ? $data['collection_time'] : '',
                 'shipment_province_id' => isset($data['shipment_province_id']) ? $data['shipment_province_id'] : '0', // 发货省份id
                 'shipment_province_name' => isset($data['shipment_province_name']) ? $data['shipment_province_name'] : '', // 发货省份
                 'shipment_city_id' => isset($data['shipment_city_id']) ? $data['shipment_city_id'] : '0', // 发货城市id

app/Models/Manager/Process/ViolationProduct.php

@@ -88,6 +88,7 @@ class ViolationProduct extends Model
             'processing_status' => '1',
             'insert_time' => time(),
             'scrape_date' => isset($data['scrape_date']) ? $data['scrape_date'] : '',
+            'collection_time' => isset($data['collection_time']) ? $data['collection_time'] : '',
             'shipment_province_id' => isset($data['shipment_province_id']) ? $data['shipment_province_id'] : '0', // 发货省份id
             'shipment_province_name' => isset($data['shipment_province_name']) ? $data['shipment_province_name'] : '', // 发货省份
             'shipment_city_id' => isset($data['shipment_city_id']) ? $data['shipment_city_id'] : '0', // 发货城市id
@@ -149,6 +150,7 @@ class ViolationProduct extends Model
                 'processing_status' => '1',
                 'insert_time' => time(),
                 'scrape_date' => isset($data['scrape_date']) ? $data['scrape_date'] : '',
+                'collection_time' => isset($data['collection_time']) ? $data['collection_time'] : '',
                 'shipment_province_id' => isset($data['shipment_province_id']) ? $data['shipment_province_id'] : '0', // 发货省份id
                 'shipment_province_name' => isset($data['shipment_province_name']) ? $data['shipment_province_name'] : '', // 发货省份
                 'shipment_city_id' => isset($data['shipment_city_id']) ? $data['shipment_city_id'] : '0', // 发货城市id

app/Models/Manager/Process/ViolationStore.php

@@ -38,6 +38,7 @@ class ViolationStore extends Model
     public function addViolationStore_content($data)
     {
         $insert_data = [
+            'company_id' => $data['company_id'],
             'source_id' => $data['source_id'],
             'first_responsible_person' => $data['first_responsible_person'] ? ',' . $data['first_responsible_person'] . ',' : '',
             'responsible_person' => $data['responsible_person'] ? ',' . $data['responsible_person'] . ',' : '',
@@ -56,6 +57,7 @@ class ViolationStore extends Model
             'processing_status' => '1',
             'insert_time' => time(),
             'scrape_date' => isset($data['scrape_date']) ? $data['scrape_date'] : '',
+            'collection_time' => isset($data['collection_time']) ? $data['collection_time'] : '',
         ];
         $ViolationStore_id = $this->insertGetId($insert_data);
         return $ViolationStore_id;
@@ -102,6 +104,7 @@ class ViolationStore extends Model
                 'processing_status' => '1',
                 'insert_time' => time(),
                 'scrape_date' => isset($data['scrape_date']) ? $data['scrape_date'] : '',
+                'collection_time' => isset($data['collection_time']) ? $data['collection_time'] : '',
             ];
             $ViolationStore_id = $this->insertGetId($insert_data);
             $first_responsible_persons = $data['first_responsible_person'] != '' ? explode(',', $data['first_responsible_person']) : [];