diff --git a/app/Console/Commands/Swoole.php b/app/Console/Commands/Swoole.php
index 9e97435..ecc9494 100644
--- a/app/Console/Commands/Swoole.php
+++ b/app/Console/Commands/Swoole.php
@@ -48,7 +48,7 @@ class Swoole extends Command
             $endTime = DateTimeUtils::getMicroTime();
             $beginTime = $endTime - 1000;
             foreach ($shops as $shop) {
-                BusinessFactory::init()->make($shop->plat_id)->setShop($shop)->downloadOrdersAndSave($beginTime, $endTime, 1, '', 'increment');
+                BusinessFactory::init()->make($shop->plat_id)->setShop($shop)->downloadOrdersAndSave($beginTime, $endTime, 'increment', 1);
             }
         });
         Event::wait();
diff --git a/app/Console/Commands/Test.php b/app/Console/Commands/Test.php
index dde17fa..619eb6b 100644
--- a/app/Console/Commands/Test.php
+++ b/app/Console/Commands/Test.php
@@ -53,9 +53,9 @@ class Test extends Command
 //        $business->incrQuantity(1);
 
         // 订单下载
-        $beginTime =  DateTimeUtils::getMicroTime('2022-08-08');
-        $endTime = DateTimeUtils::getMicroTime('2022-08-09');
-        $business->downloadOrdersAndSave($beginTime, $endTime);
+//        $beginTime =  DateTimeUtils::getMicroTime('2022-08-08');
+//        $endTime = DateTimeUtils::getMicroTime('2022-08-09');
+//        $business->downloadOrdersAndSave($beginTime, $endTime);
 
         $this->info('执行测试成功');
     }
diff --git a/app/Http/Controllers/Shop/ShopsController.php b/app/Http/Controllers/Shop/ShopsController.php
index ee8c0bf..872a4d9 100644
--- a/app/Http/Controllers/Shop/ShopsController.php
+++ b/app/Http/Controllers/Shop/ShopsController.php
@@ -94,7 +94,7 @@ class ShopsController extends Controller
             $business->bindGoods($request->get('data'));
         }
         if ('orders' === $request->get('type')) {
-            $business->saveOrders();
+            $business->saveOrders($request->get('data'));
         }
     }
 }
diff --git a/app/Listeners/UpdateBusinessGoodsStock.php b/app/Listeners/UpdateBusinessGoodsStock.php
index 2d6bfaa..8f99cbf 100644
--- a/app/Listeners/UpdateBusinessGoodsStock.php
+++ b/app/Listeners/UpdateBusinessGoodsStock.php
@@ -2,25 +2,29 @@
 
 namespace App\Listeners;
 
+use App\Models\GoodsSku;
+use App\Models\Log;
 use App\Models\Shop;
+use App\Services\Business\BusinessFactory;
 use Illuminate\Auth\Events\Registered;
 use Illuminate\Contracts\Queue\ShouldQueue;
 use Illuminate\Queue\InteractsWithQueue;
+use App\Models\BusinessOrderItem;
 
 class UpdateBusinessGoodsStock implements ShouldQueue
 {
-    protected $shopId;
-    protected $updateOrders;
+    protected $num;
+    protected $businessOrderItem;
 
     /**
      * Create the event listener.
      *
      * @return void
      */
-    public function __construct($shopId, $updateOrders)
+    public function __construct(BusinessOrderItem $item, $num)
     {
-        $this->shopId = $shopId;
-        $this->updateOrders = $updateOrders;
+        $this->businessOrderItem = $item;
+        $this->num = $num;
     }
 
     /**
@@ -31,8 +35,29 @@ class UpdateBusinessGoodsStock implements ShouldQueue
      */
     public function handle(Registered $event)
     {
-        if (empty($this->updateOrders)) {
-            return;
+        $shops = Shop::query()->where('id', '<>', $this->businessOrderItem->shop_id)->where('status', 1)->get(['id', 'plat_id']);
+        [$goodsCode, $skuCode] = explode('_', $this->businessOrderItem->external_sku_id);
+        $goodsSku = GoodsSku::query()->where('sku_code', $skuCode)
+            ->with(['goods' => function ($query) use ($goodsCode) {
+                $query->where('goods_code', $goodsCode);
+            }])
+            ->first();
+        if ($goodsSku) {
+            $goodsSku->stock += $this->num;
+            $goodsSku->save();
+            foreach ($shops as $shop) {
+                BusinessFactory::init()->make($shop['plat_id'])->setShopId($shop['id'])->incrQuantity($this->businessOrderItem, $this->num, true, $goodsSku);
+            }
+        } else {
+            $log = new Log();
+            $log->module = 'goods';
+            $log->action = 'PATCH';
+            $log->target_type = 'goods_sku';
+            $log->target_id = $goodsSku->id;
+            $log->target_field = 'stock';
+            $log->user_id = $this->businessOrderItem->shop_id;
+            $log->message = ($this->businessOrderItem->external_sku_id ?: '商品') . '未找到';
+            $log->save();
         }
     }
 }
diff --git a/app/Services/Business/BusinessClient.php b/app/Services/Business/BusinessClient.php
index 12dc06c..be66a2a 100644
--- a/app/Services/Business/BusinessClient.php
+++ b/app/Services/Business/BusinessClient.php
@@ -2,6 +2,10 @@
 
 namespace App\Services\Business;
 
+use App\Listeners\UpdateBusinessGoodsStock;
+use App\Models\BusinessGoodsSku;
+use App\Models\BusinessOrder;
+use App\Models\GoodsSku;
 use App\Models\Log;
 use App\Models\Shop;
 use GuzzleHttp\Client;
@@ -21,11 +25,60 @@ abstract class BusinessClient
 
     abstract public function bindGoods($goods);
 
-    abstract public function incrQuantity($skuId);
+    abstract public function incrQuantity(BusinessGoodsSku $businessGoodsSku, $num, $incremental, GoodsSku $goodsSku);
 
-    abstract public function downloadOrdersAndSave($beginTime, $endTime, $page = 1, $activityNo = '', $downloadType = 'default');
+    abstract public function downloadOrdersAndSave($beginTime, $endTime, $downloadType = 'default', $page = 1);
 
-    abstract public function saveOrders($orders);
+    public function saveOrders($orders)
+    {
+        $shopId = $this->getShop()->id;
+        foreach ($orders as $order) {
+            unset($order['custom_item_list'], $order['logistics_list'], $order['gift_order_list']);
+            $order['shop_id'] = $shopId;
+            $orderRecord = BusinessOrder::query()->where('shop_id', $shopId)->where('order_sn', $order['order_sn'])->first();
+            if (empty($orderRecord)) {
+                $orderRecord->create($order);
+            } else {
+                $orderRecord->update($order);
+            }
+            foreach ($order['sub_order_list'] as $item) {
+                $item['shop_id'] = $shopId;
+                $orderItem = BusinessOrder::query()->where('shop_id', $shopId)
+                    ->where('business_order_id', $orderRecord->id)
+                    ->where('goods_id', $item['goods_id'])
+                    ->where('sku_id', $item['sku_id'])
+                    ->first();
+                $num = 0;
+                if (empty($orderItem)) {
+                    if ($item['cancel_status']) {
+                        if ($num = $item['goods_number'] - $item['already_cancel_number']) {
+                            // 扣库存 $reduceNum
+                            $num = 0 - $num;
+                        }
+                    } else {
+                        // 扣库存
+                        $num = 0 - $item['goods_number'];
+                    }
+                    $orderItem->create($item);
+                } else {
+                    if ($item['cancel_status'] !== $orderItem->cancel_status) {
+                        if ($item['cancel_status']) {
+                            // 加库存
+                            $num = $item['already_cancel_number'];
+                        } else {
+                            // 扣库存
+                            $num = 0 - $item['goods_number'];
+                        }
+                    }
+                    $orderItem->update($item);
+                }
+                // 增量更新库存
+                if ($num) {
+                    event(new UpdateBusinessGoodsStock($orderItem, $num));
+                }
+            }
+        }
+    }
 
     public function authCallback($code, $shopId)
     {
@@ -81,31 +134,29 @@ abstract class BusinessClient
 
     public function formDataPostRequest($url, $params)
     {
+        $method = 'POST';
         $headers = [
             'headers' => ['Content-type' => 'application/x-www-form-urlencoded;charset=UTF-8'],
             'form_params' => $params
         ];
-        $res = (new Client())->request('POST', $url, $headers);
+        $res = (new Client())->request($method, $url, $headers);
         $size = $res->getBody()->getSize();
         $res = json_decode($res->getBody()->getContents(), true);
         if ('pdd.ktt.increment.order.query' === $params['type']) {
-            $log = Log::query()->where('user_id', $this->shop->id)->where('target_field', $params['type'])->first();
+            $log = Log::query()->where('user_id', $this->getShop()->id)->where('target_field', $params['type'])->first();
         } else {
             $log = new Log();
         }
         $log->module = 'plat';
-        $log->action = 'POST';
-        $log->target_type = $this->shop->plat_id;
+        $log->action = $method;
+        $log->target_type = $this->getShop()->plat_id;
         $log->target_id = $this->getSkuId();
         $log->target_field = $params['type'];
-        $log->user_id = $this->shop->id;
+        $log->user_id = $this->getShop()->id;
         if ($size < 64000) {
             $log->message = json_encode($res, 256);
         }
         $log->save();
-        if (isset($res['error_response'])) {
-            throw new \Exception($res['error_response']['error_msg'], $res['error_response']['error_code']);
-        }
 
         return $res;
     }
diff --git a/app/Services/Business/KuaiTuanTuan/KuaiTuanTuan.php b/app/Services/Business/KuaiTuanTuan/KuaiTuanTuan.php
index b299df8..7f2bcf1 100644
--- a/app/Services/Business/KuaiTuanTuan/KuaiTuanTuan.php
+++ b/app/Services/Business/KuaiTuanTuan/KuaiTuanTuan.php
@@ -55,14 +55,9 @@ class KuaiTuanTuan extends BusinessClient
         Goods::bindGoods($goods, $this->shop->id);
     }
 
-    public function incrQuantity($skuId)
+    public function incrQuantity($businessGoodsSku, $num, $incremental, GoodsSku $goodsSku)
     {
-        $goodsSku = GoodsSku::query()
-            ->with(['goods:id,goods_code'])
-            ->find($skuId);
-        $code = $goodsSku->goods->goods_code . '_' . $goodsSku->sku_code;
-        $business = BusinessGoodsSku::query()->where('shop_id', $this->shop->id)->where('external_sku_id', $code)->first(['goods_id', 'sku_id']);
-        [$type, $appendParams] = Goods::incrQuantity($business->goods_id, $goodsSku->stock, $business->sku_id);
+        [$type, $appendParams] = Goods::incrQuantity($businessGoodsSku->goods_id, $num, $businessGoodsSku->sku_id, $incremental ? 1 : 2);
         $this->doRequest($type, $appendParams);
     }
 
@@ -72,11 +67,10 @@ class KuaiTuanTuan extends BusinessClient
      * @param $beginTime
      * @param $endTime
      * @param int $page
-     * @param string $activityNo
      * @param string $downloadType
-     * @return mixed
+     * @return void
      */
-    public function downloadOrdersAndSave($beginTime, $endTime, $page = 1, $activityNo = '', $downloadType = 'default')
+    public function downloadOrdersAndSave($beginTime, $endTime, $downloadType = 'default', $page = 1)
     {
         if ('increment' === $downloadType) {
             [$type, $appendParams] = Order::downloadIncrementOrders($beginTime, $endTime, $page);
@@ -93,11 +87,6 @@ class KuaiTuanTuan extends BusinessClient
         }
     }
 
-    public function saveOrders($orders)
-    {
-        Order::saveOrders($orders, $this->shop->id);
-    }
-
     protected function getAccessTokenWithCode()
     {
         $type = 'pdd.pop.auth.token.create';
@@ -134,14 +123,6 @@ class KuaiTuanTuan extends BusinessClient
         return $this->formDataPostRequest($url, $publicParams);
     }
 
-
-    public function getAuthUrl($shopId, $platId)
-    {
-        $state = $shopId . '_' . $platId;
-
-        return "https://oauth.pinduoduo.com/authorize/ktt?client_id={$this->clientId}&redirect_uri={$this->redirectUri}&state={$state}";
-    }
-
     public function downloadGoods($skuId)
     {
         $goodsSku = GoodsSku::query()
@@ -154,4 +135,11 @@ class KuaiTuanTuan extends BusinessClient
         $goods = $res['response']['result'];
         $this->bindGoods([$goods]);
     }
+
+    public function getAuthUrl($shopId, $platId)
+    {
+        $state = $shopId . '_' . $platId;
+
+        return "https://oauth.pinduoduo.com/authorize/ktt?client_id={$this->clientId}&redirect_uri={$this->redirectUri}&state={$state}";
+    }
 }
diff --git a/app/Services/Business/KuaiTuanTuan/Order.php b/app/Services/Business/KuaiTuanTuan/Order.php
index d9d74f9..6fcdbc5 100644
--- a/app/Services/Business/KuaiTuanTuan/Order.php
+++ b/app/Services/Business/KuaiTuanTuan/Order.php
@@ -2,10 +2,6 @@
 
 namespace App\Services\Business\KuaiTuanTuan;
 
-use App\Listeners\UpdateBusinessGoodsStock;
-use App\Models\BusinessOrder;
-use App\Models\BusinessOrderItem;
-
 class Order
 {
     /**
@@ -21,8 +17,8 @@ class Order
             'page_size' => 100, // 数量, 必填, 1～100
             // 非必填
 //            'activity_no' => $activityNo, // 团号
-            'after_sales_status' => 0, // 售后状态, 可选 0-未发起售后 1-退款中 2-退款成功 3-待处理 4-拒绝退款 6-待(顾客)退货 7-待(团长)确认退货 8-(顾客)撤销 9-(系统)关闭
-            'cancel_status' => 0,  // 取消状态, 可选 0-未取消 1-已取消
+//            'after_sales_status' => 0, // 售后状态, 可选 0-未发起售后 1-退款中 2-退款成功 3-待处理 4-拒绝退款 6-待(顾客)退货 7-待(团长)确认退货 8-(顾客)撤销 9-(系统)关闭
+//            'cancel_status' => 0,  // 取消状态, 可选 0-未取消 1-已取消
 //            'shipping_status' => '', // 发货状态 0-未发货 1-已发货 2-部分发货 3-已收货
 //            'verification_status' => '', // 	核销状态, 可选 0-未核销 1-已核销 2-部分核销
         ];
@@ -43,34 +39,13 @@ class Order
             'page_size' => 100, // 数量
             // 非必填
 //            'activity_no' => $activityNo, // 团号
-            'after_sales_status' => 0, // 售后状态, 可选 0-未发起售后 1-退款中 2-退款成功 3-待处理 4-拒绝退款 6-待(顾客)退货 7-待(团长)确认退货 8-(顾客)撤销 9-(系统)关闭
-            'cancel_status' => 0,  // 取消状态, 可选 0-未取消 1-已取消
+//            'after_sales_status' => 0, // 售后状态, 可选 0-未发起售后 1-退款中 2-退款成功 3-待处理 4-拒绝退款 6-待(顾客)退货 7-待(团长)确认退货 8-(顾客)撤销 9-(系统)关闭
+//            'cancel_status' => 0,  // 取消状态, 可选 0-未取消 1-已取消
 //            'shipping_status' => '', // 发货状态 0-未发货 1-已发货 2-部分发货 3-已收货
 //            'verification_status' => '', // 	核销状态, 可选 0-未核销 1-已核销 2-部分核销
         ];
 
         return [$type, $appendParams];
     }
-
-    // 下载订单事件之后去统计 然后更新库存
-    public static function saveOrders(array $orders, $shopId)
-    {
-        $updateOrders = [];
-        foreach ($orders as $order) {
-            unset($order['custom_item_list'], $order['logistics_list'], $order['gift_order_list']);
-            $orderRecord = BusinessOrder::updateOrCreate(
-                ['shop_id' => $shopId, 'order_sn' => $order['order_sn']],
-                $order
-            );
-            $updateOrders[] = $order['order_sn'];
-            foreach ($order['sub_order_list'] as $item) {
-                BusinessOrderItem::updateOrCreate(
-                    ['shop_id' => $shopId, 'business_order_id' => $orderRecord->id, 'goods_id' => $item['goods_id'], 'sku_id' => $item['sku_id']],
-                    $item
-                );
-            }
-        }
-        event(new UpdateBusinessGoodsStock($shopId, $updateOrders));
-    }
 }
 
diff --git a/app/Services/Business/MiaoXuan/MiaoXuan.php b/app/Services/Business/MiaoXuan/MiaoXuan.php
index 7abbdff..7840e27 100644
--- a/app/Services/Business/MiaoXuan/MiaoXuan.php
+++ b/app/Services/Business/MiaoXuan/MiaoXuan.php
@@ -24,24 +24,17 @@ class MiaoXuan extends BusinessClient
         Goods::bindGoods($goods, $this->shop->id);
     }
 
-    public function incrQuantity($skuId)
+    public function incrQuantity($businessGoodsSku, $num, $incremental, GoodsSku $goodsSku)
     {
-        $goodsSku = GoodsSku::query()->find($skuId);
-        $business = BusinessGoodsSku::query()->where('shop_id', $this->shop->id)->where('self_sku_id', $skuId)->first(['goods_id', 'sku_id', 'external_sku_id'])->toArray();
-        $appendParams = Goods::incrQuantity($this->shop->id, $goodsSku->stock, $business);
+        $appendParams = Goods::incrQuantity($this->shop->id, $goodsSku->stock, $businessGoodsSku);
         $url = 'http://shop.chutang66.com/miaoxuan/stock';
         $this->formDataPostRequest($url, $appendParams);
     }
 
-    public function downloadOrdersAndSave($beginTime, $endTime, $page = 1, $activityNo = '', $downloadType = 'default')
+    public function downloadOrdersAndSave($beginTime, $endTime, $downloadType = 'default', $page = 1)
     {
     }
 
-    public function saveOrders($orders)
-    {
-        Order::saveOrders($orders, $this->shop->id);
-    }
-
     public function downloadGoods($skuId)
     {
         // TODO: Implement downloadGoods() method.
diff --git a/app/Services/Business/MiaoXuan/Order.php b/app/Services/Business/MiaoXuan/Order.php
index 89c6e73..43c0e9e 100644
--- a/app/Services/Business/MiaoXuan/Order.php
+++ b/app/Services/Business/MiaoXuan/Order.php
@@ -2,29 +2,7 @@
 
 namespace App\Services\Business\MiaoXuan;
 
-use App\Listeners\UpdateBusinessGoodsStock;
-use App\Models\BusinessOrder;
-
 class Order
 {
-    // 下载订单事件之后去统计 然后更新库存
-    public static function saveOrders(array $orders, $shopId)
-    {
-        $updateOrders = [];
-        foreach ($orders as $order) {
-            $orderRecord = BusinessOrder::updateOrCreate(
-                ['shop_id' => $shopId, 'order_sn' => $order['order_sn']],
-                $order
-            );
-            $updateOrders[] = $order['order_sn'];
-            foreach ($order['sub_order_list'] as $item) {
-                $orderRecord = BusinessOrder::updateOrCreate(
-                    ['shop_id' => $shopId, 'business_order_id' => $orderRecord->id, 'goods_id' => $item['goods_id'], 'sku_id' => $item['sku_id']],
-                    $item
-                );
-            }
-        }
-        event(new UpdateBusinessGoodsStock($shopId, $updateOrders));
-    }
 }