From 9fbf932f63c86385fc42f35528ede2b4fd64f88e Mon Sep 17 00:00:00 2001
From: ctexthuang <ctexthuang@qq.com>
Date: Tue, 4 Mar 2025 16:31:45 +0800
Subject: [PATCH] feat : order

---
 app/Amqp/Consumer/OrderGoodStockConsumer.php | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

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());