diff --git a/app/Amqp/Consumer/OrderGoodStockConsumer.php b/app/Amqp/Consumer/OrderGoodStockConsumer.php
index 3ef846f..78667e9 100644
--- a/app/Amqp/Consumer/OrderGoodStockConsumer.php
+++ b/app/Amqp/Consumer/OrderGoodStockConsumer.php
@@ -113,11 +113,14 @@ class OrderGoodStockConsumer extends ConsumerMessage
                 return Result::ACK;
             }
 
-            if (!(Db::table('sku')->update($this->updateArr))) {
+            $res = Db::table('sku')->upsert($this->updateArr,['id']);
+            if (!$res) {
                 $this->log->debug('OrderGoodStockConsumer:error:UpdateSkuDataFail:'.json_encode($this->updateArr));
                 return Result::ACK;
             }
 
+            $this->log->Debug('OrderGoodStockConsumer:'.json_encode($this->updateArr).':'.json_encode($res));
+
             return Result::ACK;
         } catch (Exception $e) {
             $this->log->error($e->getMessage());