From a5ec83b8f60e444bf59ead24ec1bb570b9bfce16 Mon Sep 17 00:00:00 2001
From: mkm <727897186@qq.com>
Date: Fri, 19 May 2023 21:12:34 +0800
Subject: [PATCH 1/9] =?UTF-8?q?=E5=95=86=E5=93=81=E5=AF=BC=E5=85=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../api/store/product/StoreMicro.php          | 37 ++++++++++++++++++-
 route/api.php                                 |  1 +
 2 files changed, 36 insertions(+), 2 deletions(-)

diff --git a/app/controller/api/store/product/StoreMicro.php b/app/controller/api/store/product/StoreMicro.php
index 4b68b53b..34e63c46 100644
--- a/app/controller/api/store/product/StoreMicro.php
+++ b/app/controller/api/store/product/StoreMicro.php
@@ -1,6 +1,6 @@
 <?php
 namespace app\controller\api\store\product;
-use think\exception\ValidateException;
+use app\common\repositories\store\product\ProductRepository;
 use think\facade\Db;
 use crmeb\basic\BaseController;
 
@@ -28,6 +28,7 @@ class StoreMicro extends BaseController
         return app('json')->success($store_product);
     }
 
+    //商品详情
     public function ProductDetails($id){
         $find=Db::name('store_product')->where('product_id',$id)
             ->withAttr('attr_value',function ($value,$data){
@@ -35,8 +36,40 @@ class StoreMicro extends BaseController
             })
             ->find();
         return app('json')->success(['list'=>$find]);
+    }
 
-
+    //提交导入商品id
+    public function ProductImport(){
+        $product_id = $this->request->param('id', 0);
+        $user = $this->request->userInfo();
+        $mer_id =Db::name('store_service')->where('uid',$user['uid'])->where('status',1)->value('mer_id');
+        if ($mer_id==0) return app('json')->fail('商户id不能为空');
+        $find=Db::name('store_product')->where('product_id',$product_id)->find();
+        if($find){
+            $find['attrValue']=Db::name('store_product_attr_value')->where('product_id',$find['product_id'])->field('image,price,cost,ot_price,svip_price,stock,bar_code,weight,volume')->select();
+            $find['content']=Db::name('store_product_content')->where('product_id',$find['product_id'])->value('content');
+            $find['is_show']=0;
+            $find['mer_id']=$mer_id;
+            $find['temp_id']="";
+            $find['give_coupon_ids']=[];
+            $find['params']=[];
+            $find['extend']=[];
+            $find['param_temp_id']=[];
+            $find['mer_labels']=[];
+            $find['attr']=[];
+            $find['delivery_way']=[ 0 => "2"];
+            $find["guarantee_template_id"] = "";
+            $find['product_type']=0;
+            $find['mer_cate_id']=[0 => 0];
+            unset($find['product_id'],$find['create_time']);
+        }
+        $make = app()->make(ProductRepository::class);
+        $a=$make->create($find,0);
+        if($a){
+            return app('json')->success(['data'=>$a,'msg'=>'导入成功']);
+        }else{
+            return app('json')->fail('导入失败');
+        }
     }
 
     public function eadtProduct(){
diff --git a/route/api.php b/route/api.php
index 44fce8a7..e71be2c7 100644
--- a/route/api.php
+++ b/route/api.php
@@ -28,6 +28,7 @@ Route::group('api/', function () {
             Route::get('seach_bar_code', '/seach_bar_code');
             Route::get('product_details', '/ProductDetails');
             Route::post('eadt_product', '/eadtProduct');
+            Route::post('product_import', '/ProductImport');
         })->prefix('api.store.product.StoreMicro');
 
         Route::group('v2', function () {

From 52690a7a82266c56b1bd11b5c49d4f5e8937fd53 Mon Sep 17 00:00:00 2001
From: mkm <727897186@qq.com>
Date: Fri, 19 May 2023 21:35:30 +0800
Subject: [PATCH 2/9] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E9=94=99=E8=AF=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/controller/api/store/product/StoreMicro.php | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/app/controller/api/store/product/StoreMicro.php b/app/controller/api/store/product/StoreMicro.php
index 34e63c46..8a61bb8b 100644
--- a/app/controller/api/store/product/StoreMicro.php
+++ b/app/controller/api/store/product/StoreMicro.php
@@ -46,9 +46,13 @@ class StoreMicro extends BaseController
         if ($mer_id==0) return app('json')->fail('商户id不能为空');
         $find=Db::name('store_product')->where('product_id',$product_id)->find();
         if($find){
+            if($find['product_type']!=0){
+                return app('json')->fail('该商品不是普通商品');
+            }
             $find['attrValue']=Db::name('store_product_attr_value')->where('product_id',$find['product_id'])->field('image,price,cost,ot_price,svip_price,stock,bar_code,weight,volume')->select();
             $find['content']=Db::name('store_product_content')->where('product_id',$find['product_id'])->value('content');
             $find['is_show']=0;
+            $find['mer_status']=1;
             $find['mer_id']=$mer_id;
             $find['temp_id']="";
             $find['give_coupon_ids']=[];
@@ -61,6 +65,9 @@ class StoreMicro extends BaseController
             $find["guarantee_template_id"] = "";
             $find['product_type']=0;
             $find['mer_cate_id']=[0 => 0];
+            $find['is_used']=1;
+            $find['status']=1;
+            $find['mer_status']=1;
             unset($find['product_id'],$find['create_time']);
         }
         $make = app()->make(ProductRepository::class);

From b25a86d05610f2d67ad3d96e245ab97745165d39 Mon Sep 17 00:00:00 2001
From: luofei <604446095@qq.com>
Date: Sat, 20 May 2023 14:26:26 +0800
Subject: [PATCH 3/9] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E8=87=AA=E5=8A=A8?=
 =?UTF-8?q?=E6=89=A3=E9=99=A4=E4=BF=9D=E8=AF=81=E9=87=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../system/merchant/FinancialRecordDao.php    |  7 ++++
 .../store/order/StoreOrderRepository.php      | 39 +++++++++++++++++++
 2 files changed, 46 insertions(+)

diff --git a/app/common/dao/system/merchant/FinancialRecordDao.php b/app/common/dao/system/merchant/FinancialRecordDao.php
index 6d2b1323..44d2d7c9 100644
--- a/app/common/dao/system/merchant/FinancialRecordDao.php
+++ b/app/common/dao/system/merchant/FinancialRecordDao.php
@@ -20,6 +20,13 @@ use app\common\model\system\merchant\FinancialRecord;
 class FinancialRecordDao extends BaseDao
 {
 
+    const Outlay = 0; //支出
+    const Income = 1; //收入
+
+    const TypeMerchant = 0; //商户
+    const TypeCommon = 1; //公共
+    const TypePlatform = 2; //平台
+
     protected function getModel(): string
     {
         return FinancialRecord::class;
diff --git a/app/common/repositories/store/order/StoreOrderRepository.php b/app/common/repositories/store/order/StoreOrderRepository.php
index 602e8c20..118555c3 100644
--- a/app/common/repositories/store/order/StoreOrderRepository.php
+++ b/app/common/repositories/store/order/StoreOrderRepository.php
@@ -12,8 +12,10 @@
 namespace app\common\repositories\store\order;
 
 use app\common\dao\store\order\StoreOrderDao;
+use app\common\dao\system\merchant\FinancialRecordDao;
 use app\common\model\store\order\StoreGroupOrder;
 use app\common\model\store\order\StoreOrder;
+use app\common\model\system\merchant\Merchant;
 use app\common\model\user\User;
 use app\common\repositories\BaseRepository;
 use app\common\repositories\delivery\DeliveryOrderRepository;
@@ -374,6 +376,10 @@ class StoreOrderRepository extends BaseRepository
                         $_payPrice = bcadd($_payPrice, $order->platform_coupon_price, 2);
                     }
 
+                    if ($_payPrice > 0) {
+                        $this->autoMargin($_payPrice, $order, $finance, $financeSn, $i);
+                    }
+
                     if (!$is_combine) {
                         app()->make(MerchantRepository::class)->addLockMoney($order->mer_id, 'order', $order->order_id, $_payPrice);
                     }
@@ -450,6 +456,39 @@ class StoreOrderRepository extends BaseRepository
 
     }
 
+    /**
+     * 自动扣除保证金
+     * @param $income
+     * @param $order
+     * @param $finance
+     * @param $financeSn
+     * @param $index
+     * @return void
+     */
+    public function autoMargin(&$income, $order, &$finance, $financeSn, $index = 0)
+    {
+        $merchant = Merchant::find($order->mer_id);
+        //商户保证金未完全缴纳且设置了自动扣除比例
+        if ($merchant['margin'] > $merchant['paid_margin'] && $merchant['auto_margin_rate'] > 0 && $merchant['auto_margin_rate'] <= 100) {
+            $margin = bcmul($income, $merchant['auto_margin_rate'] / 100, 2);
+            $margin = min(bcsub($merchant['margin'], $merchant['paid_margin'], 2), $margin);
+            $income = max(bcsub($income, $margin, 2), 0);
+            $finance[] = [
+                'order_id' => $order->order_id,
+                'order_sn' => $order->order_sn,
+                'user_info' => $order->user->nickname,
+                'user_id' => $order->uid,
+                'financial_type' => 'auto_margin',
+                'financial_pm' => FinancialRecordDao::Outlay,
+                'type' => FinancialRecordDao::TypePlatform,
+                'number' => $margin,
+                'mer_id' => $order->mer_id,
+                'financial_record_sn' => $financeSn . $index
+            ];
+            $merchant->save(['paid_margin' => bcadd($merchant['paid_margin'], $margin, 2)]);
+        }
+    }
+
     /**
      *  自动打印
      * @Author:Qinii

From 705c1ac4189cca3947515a4177d978f57ef103d1 Mon Sep 17 00:00:00 2001
From: luofei <604446095@qq.com>
Date: Sat, 20 May 2023 14:46:19 +0800
Subject: [PATCH 4/9] =?UTF-8?q?=E6=9A=82=E6=97=B6=E6=B3=A8=E9=87=8A?=
 =?UTF-8?q?=E8=AE=A2=E5=8D=95=E6=94=AF=E4=BB=98=E6=88=90=E5=8A=9F=E4=BA=8B?=
 =?UTF-8?q?=E4=BB=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/event.php | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/app/event.php b/app/event.php
index edafe1d9..06e044fe 100644
--- a/app/event.php
+++ b/app/event.php
@@ -63,7 +63,7 @@ return [
         'pay_success_presell' => [\crmeb\listens\pay\PresellPaySuccessListen::class],
         'pay_success_meal' => [\crmeb\listens\pay\MealSuccessListen::class],
         'community_address'=>[\app\listener\CommunityAddress::class],
-        'order.paySuccess'=>[\app\listener\OrderPaySuccess::class],
+//        'order.paySuccess'=>[\app\listener\OrderPaySuccess::class],
         'product.create'=>[\app\listener\ProductCreate::class],
     ],
 

From be53659118d313890ffe0eeff59654f0ac9ebeaa Mon Sep 17 00:00:00 2001
From: luofei <604446095@qq.com>
Date: Sat, 20 May 2023 14:57:21 +0800
Subject: [PATCH 5/9] =?UTF-8?q?=E8=B5=84=E9=87=91=E6=B5=81=E6=B0=B4?=
 =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E4=BF=9D=E8=AF=81=E9=87=91=E7=B1=BB=E5=9E=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/controller/admin/system/merchant/FinancialRecord.php | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/app/controller/admin/system/merchant/FinancialRecord.php b/app/controller/admin/system/merchant/FinancialRecord.php
index 06778659..c8222cac 100644
--- a/app/controller/admin/system/merchant/FinancialRecord.php
+++ b/app/controller/admin/system/merchant/FinancialRecord.php
@@ -37,9 +37,9 @@ class FinancialRecord extends BaseController
         $merId = $this->request->merId();
         if ($merId) {
             $where['mer_id'] = $merId;
-            $where['financial_type'] = ['order', 'mer_accoubts', 'brokerage_one', 'brokerage_two', 'refund_brokerage_one', 'refund_brokerage_two', 'refund_order','order_platform_coupon','order_svip_coupon'];
+            $where['financial_type'] = ['order', 'mer_accoubts', 'brokerage_one', 'brokerage_two', 'refund_brokerage_one', 'refund_brokerage_two', 'refund_order','order_platform_coupon','order_svip_coupon' ,'auto_margin'];
         } else {
-            $where['financial_type'] = ['order', 'sys_accoubts', 'brokerage_one', 'brokerage_two', 'refund_brokerage_one', 'refund_brokerage_two', 'refund_order','order_platform_coupon','order_svip_coupon'];
+            $where['financial_type'] = ['order', 'sys_accoubts', 'brokerage_one', 'brokerage_two', 'refund_brokerage_one', 'refund_brokerage_two', 'refund_order','order_platform_coupon','order_svip_coupon', 'auto_margin'];
         }
         return app('json')->success($this->repository->getList($where, $page, $limit));
     }

From f4b8f0716009c8f1c4183e1421fa27c2470fe9f2 Mon Sep 17 00:00:00 2001
From: mkm <727897186@qq.com>
Date: Sat, 20 May 2023 16:29:11 +0800
Subject: [PATCH 6/9] =?UTF-8?q?=E5=AF=BC=E5=85=A5=E5=95=86=E5=93=81?=
 =?UTF-8?q?=E7=9A=84=E8=AF=A6=E6=83=85?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/common/dao/store/product/SpuDao.php          |  3 +++
 .../repositories/store/product/SpuRepository.php | 10 ++++++++--
 app/controller/api/store/product/StoreSpu.php    |  2 +-
 app/listener/ProductCreate.php                   | 16 ++++++++++++++++
 4 files changed, 28 insertions(+), 3 deletions(-)

diff --git a/app/common/dao/store/product/SpuDao.php b/app/common/dao/store/product/SpuDao.php
index 8a437bf3..b85b3e6d 100644
--- a/app/common/dao/store/product/SpuDao.php
+++ b/app/common/dao/store/product/SpuDao.php
@@ -52,6 +52,9 @@ class SpuDao extends  BaseDao
         $query->when(isset($where['is_del']) && $where['is_del'] !== '',function($query)use($where){
                 $query->where('P.is_del',$where['is_del']);
             })
+            ->when(isset($where['product_id']) && $where['product_id'] !== '',function($query)use($where){
+                $query->where('P.product_id','in',$where['product_id']);
+            })
             ->when(isset($where['mer_id']) && $where['mer_id'] !== '',function($query)use($where){
                 $query->where('P.mer_id',$where['mer_id']);
             })
diff --git a/app/common/repositories/store/product/SpuRepository.php b/app/common/repositories/store/product/SpuRepository.php
index 83951b66..a46ef148 100644
--- a/app/common/repositories/store/product/SpuRepository.php
+++ b/app/common/repositories/store/product/SpuRepository.php
@@ -161,9 +161,15 @@ class SpuRepository extends BaseRepository
     {
         $where['spu_status'] = 1;
         $where['mer_status'] = 1;
+        $RedisCacheService = app()->make(RedisCacheService::class);
+        $exists=$RedisCacheService->exists('CloudMerchanSpu'.$where['mer_id']);
+        if ($exists){
+            $Spu_arr=$RedisCacheService->SRANDMEMBER('CloudMerchanSpu'.$where['mer_id'], 10);
+            $where['product_id'] =$Spu_arr;
+        }
         $query = $this->dao->search($where);
 
-        $count = $query->count();
+        $count = 0;
 //        $Sql=$query->page($page, $limit)->setOption('field', [])->field($this->productFiled)->fetchSql(true);
         $query->with([
             'merchant' => function ($query) {
@@ -171,7 +177,7 @@ class SpuRepository extends BaseRepository
             },
             'issetCoupon',
         ]);
-        $list = $query->page($page, $limit)->setOption('field', [])->field($this->productFiled)->orderRaw('rand()')->select();
+        $list = $query->setOption('field', [])->field($this->productFiled)->orderRaw('rand()')->select();
         $append = ['stop_time','svip_price','show_svip_info','is_svip_price'];
 
         $list->append($append);
diff --git a/app/controller/api/store/product/StoreSpu.php b/app/controller/api/store/product/StoreSpu.php
index 31a2dc67..f7ab95ce 100644
--- a/app/controller/api/store/product/StoreSpu.php
+++ b/app/controller/api/store/product/StoreSpu.php
@@ -102,7 +102,7 @@ class StoreSpu extends BaseController
         ]);
         if ($where['action']) unset($where['product_type']);
         $category_id=Db::name('merchant')->where('mer_id',$id)->value('category_id');
-        $mer_id=Db::name('merchant')->where('category_id',$category_id)->where('type_id',11)->value('mer_id');
+        $mer_id=Db::name('merchant')->where('mer_state',1)->where('status',1)->where('category_id',$category_id)->where('type_id',11)->value('mer_id');
         if (!$mer_id){
             return app('json')->success(['count'=>0,'list'=>[]]);
 
diff --git a/app/listener/ProductCreate.php b/app/listener/ProductCreate.php
index 0057054a..fa580678 100644
--- a/app/listener/ProductCreate.php
+++ b/app/listener/ProductCreate.php
@@ -3,6 +3,7 @@ declare (strict_types=1);
 
 namespace app\listener;
 
+use crmeb\services\RedisCacheService;
 use think\facade\Db;
 use think\facade\Log;
 
@@ -12,6 +13,9 @@ class ProductCreate
     public function handle($event)
     {
         $merchant=Db::name('merchant')->where('mer_id',$event['product']['mer_id'])->find();
+        if ($merchant['type_id']==11){
+            $this->CloudMerchanSpu($merchant,$event);
+        }
         if ($merchant['type_id']==13 ||$merchant['type_id']==11){
             return false;
         }
@@ -58,6 +62,18 @@ class ProductCreate
         return false;
     }
 
+    public function CloudMerchanSpu($data,$event){
+        $RedisCacheService = app()->make(RedisCacheService::class);
+        $exists=$RedisCacheService->exists('CloudMerchanSpu'.$data['mer_id']);
+        if ($exists){
+            $RedisCacheService->SADD ('CloudMerchanSpu'.$data['mer_id'], $event['product']['product_id']);
+        }else{
+            $Spu_arr=Db::name('store_spu')->where('mer_id',$data['mer_id'])->where('status',1)->column('product_id');
+            foreach ($Spu_arr as $k=>$v){
+                $RedisCacheService->SADD ('CloudMerchanSpu'.$data['mer_id'], $v);
+            }
+        }
+    }
     public function AddProduct($mer_id,$product_find,$event){
         $datas=[
             'mer_id'=>$mer_id,

From 5be0c7ce07db874335838670022a0e7c0017ee1d Mon Sep 17 00:00:00 2001
From: mkm <727897186@qq.com>
Date: Sat, 20 May 2023 18:22:04 +0800
Subject: [PATCH 7/9] =?UTF-8?q?=E5=AF=BC=E5=85=A5=E5=95=86=E5=93=81?=
 =?UTF-8?q?=E7=9A=84=E8=AF=A6=E6=83=85?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/listener/ProductCreate.php | 35 +++++++++++++++++-----------------
 1 file changed, 18 insertions(+), 17 deletions(-)

diff --git a/app/listener/ProductCreate.php b/app/listener/ProductCreate.php
index fa580678..e9229199 100644
--- a/app/listener/ProductCreate.php
+++ b/app/listener/ProductCreate.php
@@ -12,7 +12,7 @@ class ProductCreate
 
     public function handle($event)
     {
-        $merchant=Db::name('merchant')->where('mer_id',$event['product']['mer_id'])->find();
+        $merchant=Db::name('merchant')->where('status',1)->where('mer_state',1)->where('mer_id',$event['product']['mer_id'])->find();
         if ($merchant['type_id']==11){
             $this->CloudMerchanSpu($merchant,$event);
         }
@@ -20,9 +20,8 @@ class ProductCreate
             return false;
         }
         $product_find=Db::name('store_product')->where('product_id',$event['product']['product_id'])->where('mer_id',$event['product']['mer_id'])->find();
-
         //市级云仓
-        $cityMerchantId = Db::name('merchant')->where('category_id',$merchant['category_id'])->where('type_id',13)->value('mer_id');
+        $cityMerchantId = Db::name('merchant')->where('status',1)->where('mer_state',1)->where('category_id',$merchant['category_id'])->where('type_id',13)->value('mer_id');
         if ($cityMerchantId) {
             $is_product=0;
             if ($product_find['bar_code']!='' &&in_array($product_find['product_type'],[0,98]) &&$product_find['spec_type']==0){
@@ -42,24 +41,26 @@ class ProductCreate
         }
         //镇街云仓
         $is_product=0;
-        if ($merchant['type_id']==11){
-            $townMerchantId = Db::name('merchant')->where('category_id',$merchant['category_id'])->where('type_id',11)->value('mer_id');
-            if ($product_find['bar_code']!='' &&in_array($product_find['product_type'],[0,98]) &&$product_find['spec_type']==0){
-                $find=Db::name('store_product')->where('bar_code',$product_find['bar_code'])->where('mer_id',$townMerchantId)->find();
-                if (!$find){
-                    $is_product=1;
+        if ($merchant['type_id']==10){
+            $townMerchantId = Db::name('merchant')->where('status',1)->where('mer_state',1)->where('category_id',$merchant['category_id'])->where('type_id',11)->value('mer_id');
+            if ($townMerchantId){
+                if ($product_find['bar_code']!='' &&in_array($product_find['product_type'],[0,98]) &&$product_find['spec_type']==0){
+                    $find=Db::name('store_product')->where('bar_code',$product_find['bar_code'])->where('mer_id',$townMerchantId)->find();
+                    if (!$find){
+                        $is_product=1;
+                    }
+                }else{
+                    $find=Db::name('store_product')->where('store_name',$product_find['store_name'])->where('mer_id',$townMerchantId)->find();
+                    if (!$find){
+                        $is_product=1;
+                    }
                 }
-            }else{
-                $find=Db::name('store_product')->where('store_name',$product_find['store_name'])->where('mer_id',$townMerchantId)->find();
-                if (!$find){
-                    $is_product=1;
+                if ($is_product==1){
+                    $this->AddProduct($townMerchantId,$product_find,$event);
                 }
             }
-            if ($is_product==1){
-                $this->AddProduct($townMerchantId,$product_find,$event);
-            }
+
         }
-        return false;
     }
 
     public function CloudMerchanSpu($data,$event){

From bbf53a6a1f607c89c6aa7515debc43c8d15b3917 Mon Sep 17 00:00:00 2001
From: mkm <727897186@qq.com>
Date: Mon, 22 May 2023 09:54:06 +0800
Subject: [PATCH 8/9] =?UTF-8?q?=E4=BF=AE=E6=94=B9redis=E6=95=B0=E6=8D=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../repositories/store/product/ProductRepository.php | 12 +++++++++++-
 1 file changed, 11 insertions(+), 1 deletion(-)

diff --git a/app/common/repositories/store/product/ProductRepository.php b/app/common/repositories/store/product/ProductRepository.php
index 8824dc7a..7f52b967 100644
--- a/app/common/repositories/store/product/ProductRepository.php
+++ b/app/common/repositories/store/product/ProductRepository.php
@@ -1563,9 +1563,19 @@ class ProductRepository extends BaseRepository
             Db::rollback();
             throw new ValidateException('商品更新出错');
         }
-        if (app()->make(SpuRepository::class)->changeStatus($id, $product->product_type) === false) {
+       $changeStatus= app()->make(SpuRepository::class)->changeStatus($id, $product->product_type);
+        if ($changeStatus=== false) {
             Db::rollback();
             throw new ValidateException('商品spu更新出错');
+        }else{
+            if ($product->product_type==0){
+                $RedisCacheService = app()->make(RedisCacheService::class);
+                if ($status==1){
+                    $RedisCacheService->SADD ('CloudMerchanSpu'.$product['mer_id'], $product['product_id']);
+                }else{
+                    $RedisCacheService->SREM ('CloudMerchanSpu'.$product['mer_id'], $product['product_id']);
+                }
+            }
         }
         Db::commit();
     }

From 8e1532f17d5d3058c93411db0c29a6b35f04362c Mon Sep 17 00:00:00 2001
From: mkm <727897186@qq.com>
Date: Mon, 22 May 2023 10:10:03 +0800
Subject: [PATCH 9/9] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E9=9A=8F=E6=9C=BA?=
 =?UTF-8?q?=E9=94=99=E8=AF=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/common/repositories/store/product/SpuRepository.php | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/app/common/repositories/store/product/SpuRepository.php b/app/common/repositories/store/product/SpuRepository.php
index a46ef148..3ce2c637 100644
--- a/app/common/repositories/store/product/SpuRepository.php
+++ b/app/common/repositories/store/product/SpuRepository.php
@@ -177,7 +177,7 @@ class SpuRepository extends BaseRepository
             },
             'issetCoupon',
         ]);
-        $list = $query->setOption('field', [])->field($this->productFiled)->orderRaw('rand()')->select();
+        $list = $query->setOption('field', [])->field($this->productFiled)->select();
         $append = ['stop_time','svip_price','show_svip_info','is_svip_price'];
 
         $list->append($append);