diff --git a/app/common/repositories/store/product/ProductRepository.php b/app/common/repositories/store/product/ProductRepository.php
index 6d128a61..f6760e36 100644
--- a/app/common/repositories/store/product/ProductRepository.php
+++ b/app/common/repositories/store/product/ProductRepository.php
@@ -1556,8 +1556,16 @@ class ProductRepository extends BaseRepository
             throw new ValidateException('商品正在参与预售活动');
         if ($status == 1 && $product['product_type'] == 3)
             throw new ValidateException('商品正在参与助力活动');
-        $this->dao->update($id,[$field => $status]);
-        app()->make(SpuRepository::class)->changeStatus($id,$product->product_type);
+        Db::startTrans();
+        if ($this->dao->update($id, [$field => $status]) === false) {
+            Db::rollback();
+            throw new ValidateException('商品更新出错');
+        }
+        if (app()->make(SpuRepository::class)->changeStatus($id, $product->product_type) === false) {
+            Db::rollback();
+            throw new ValidateException('商品spu更新出错');
+        }
+        Db::commit();
     }
 
     public function batchSwitchShow($id, $status, $field, $merId = 0)
diff --git a/app/common/repositories/store/product/SpuRepository.php b/app/common/repositories/store/product/SpuRepository.php
index 361edf81..80723650 100644
--- a/app/common/repositories/store/product/SpuRepository.php
+++ b/app/common/repositories/store/product/SpuRepository.php
@@ -318,8 +318,10 @@ class SpuRepository extends BaseRepository
                 Queue(SendSmsJob::class, ['tempId' => 'PRODUCT_INCREASE', 'id' => $id]);
             }
             if (in_array($productType, [0, 98])) Queue::push(SyncProductTopJob::class,[]);
+            return true;
         } catch (\Exception $exception) {
             Log::info($exception->getMessage());
+            return false;
         }
     }