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