[智价云] 重复清洗检查更新

app/Models/Manager/Process/LowPriceGoods.php

@@ -122,6 +122,9 @@ class LowPriceGoods extends Model
     public function addLowPriceGoods($data, $is_import = false)
     {
         if ($is_import == false) {
+            //检查是否重复清洗
+            $source_data_log = $this->where('source_id', $data['source_id'])->count();
+            if(!empty($source_data_log) && $source_data_log > 0) return true;
             //去重规则：品牌方公司ID+店铺公司名称+店铺名称+品牌名称+商品名称+规格+盒数(针对采集)
             $source_where[] = ['company_id', '=', $data['company_id']]; //品牌方公司ID
             $source_where[] = ['platform', '=', $data['platform']]; //平台

app/Models/Manager/Process/ViolationProduct.php

@@ -116,6 +116,9 @@ class ViolationProduct extends Model
     public function addViolationProduct($data, $is_import = false)
     {
         if ($is_import == false) {
+            //检查是否重复清洗
+            $source_data_log = $this->where('source_id', $data['source_id'])->count();
+            if(!empty($source_data_log) && $source_data_log > 0) return true;
             //去重规则：品牌方公司ID+店铺公司名称+店铺名称+品牌名称+商品名称+规格+盒数(针对采集)
             $source_where[] = ['company_id', '=', $data['company_id']]; //品牌方公司ID
             $source_where[] = ['platform', '=', $data['platform']]; //平台

app/Models/Manager/Process/ViolationStore.php

@@ -79,6 +79,9 @@ class ViolationStore extends Model
      */
     public function addViolationStore($data)
     {
+        //检查是否重复清洗
+        $source_data_log = $this->where('source_id', $data['source_id'])->count();
+        if (!empty($source_data_log) && $source_data_log > 0) return true;
         $source_where[] = ['company_id', '=', $data['company_id']];
         $source_where[] = ['store_name', '=', $data['store_name']];
         $source_where[] = ['social_credit_code', '=', $data['social_credit_code']];
@@ -88,7 +91,7 @@ class ViolationStore extends Model
         }
         DB::beginTransaction();
         try {
-           
+
             $insert_data = [
                 'company_id' => $data['company_id'],
                 'source_id' => $data['source_id'],