Quellcode durchsuchen

[智价云] 数据清洗采集日期时间补充

tangyuanwang vor 1 Woche
Ursprung
Commit
7b8a579e25

+ 1 - 0
app/Jobs/Manager/Process/LowPriceGoodsDataJobs.php

@@ -165,6 +165,7 @@ class LowPriceGoodsDataJobs implements ShouldQueue
                 'first_responsible_person' => '',
                 'responsible_person' => '',
                 'source_responsible_person' => '',
+                'scrape_date' => $product_data['scrape_date'],
             ];
             //获取公司绑定责任人信息
             $company_data = $ViolationStoreModel->leftjoin('washconfig_company_category', 'washconfig_company_category.id', '=', 'washconfig_violation_store.category_id')

+ 1 - 0
app/Jobs/Manager/Process/ViolationProductDataJobs.php

@@ -160,6 +160,7 @@ class ViolationProductDataJobs implements ShouldQueue
                 'first_responsible_person' => '',
                 'responsible_person' => '',
                 'source_responsible_person' => '',
+                'scrape_date' => $product_data['scrape_date'],
             ];
             //获取公司绑定责任人信息
             $company_data = $ViolationStoreModel->leftjoin('washconfig_company_category', 'washconfig_company_category.id', '=', 'washconfig_violation_store.category_id')

+ 1 - 0
app/Jobs/Manager/Process/ViolationStoreDataJobs.php

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

+ 2 - 0
app/Models/Manager/Process/LowPriceGoods.php

@@ -76,6 +76,7 @@ class LowPriceGoods extends Model
             'source_responsible_person'    => $data['source_responsible_person'],
             'processing_status' => '1',
             'insert_time' => time(),
+            'scrape_date' => isset($data['scrape_date']) ? $data['scrape_date'] : '',
         ];
         $LowPriceGoods_id = $this->insertGetId($insert_data);
         return $LowPriceGoods_id;
@@ -132,6 +133,7 @@ class LowPriceGoods extends Model
                 'company_category_name' => $data['company_category_name'],
                 'processing_status' => '1',
                 'insert_time' => time(),
+                'scrape_date' => isset($data['scrape_date']) ? $data['scrape_date'] : '',
             ];
 
             $LowPriceGoods_id = $this->insertGetId($insert_data);

+ 2 - 0
app/Models/Manager/Process/ViolationProduct.php

@@ -73,6 +73,7 @@ class ViolationProduct extends Model
             'source_responsible_person'    => $data['source_responsible_person'],
             'processing_status' => '1',
             'insert_time' => time(),
+            'scrape_date' => isset($data['scrape_date']) ? $data['scrape_date'] : '',
         ];
         $ViolationProduct_id = $this->insertGetId($insert_data);
         return $ViolationProduct_id;
@@ -126,6 +127,7 @@ class ViolationProduct extends Model
                 'company_category_name' => $data['company_category_name'],
                 'processing_status' => '1',
                 'insert_time' => time(),
+                'scrape_date' => isset($data['scrape_date']) ? $data['scrape_date'] : '',
             ];
             $ViolationProduct_id = $this->insertGetId($insert_data);
             $first_responsible_persons = $data['first_responsible_person'] != '' ? explode(',', $data['first_responsible_person']) : [];

+ 2 - 0
app/Models/Manager/Process/ViolationStore.php

@@ -53,6 +53,7 @@ class ViolationStore extends Model
             'company_category_name' => $data['company_category_name'] ? $data['company_category_name'] : '',
             'processing_status' => '1',
             'insert_time' => time(),
+            'scrape_date' => isset($data['scrape_date']) ? $data['scrape_date'] : '',
         ];
         $ViolationStore_id = $this->insertGetId($insert_data);
         return $ViolationStore_id;
@@ -98,6 +99,7 @@ class ViolationStore extends Model
                 'company_category_name' => $data['company_category_name'] ? $data['company_category_name'] : '',
                 'processing_status' => '1',
                 'insert_time' => time(),
+                'scrape_date' => isset($data['scrape_date']) ? $data['scrape_date'] : '',
             ];
             $ViolationStore_id = $this->insertGetId($insert_data);
             $first_responsible_persons = $data['first_responsible_person'] != '' ? explode(',', $data['first_responsible_person']) : [];