diff --git a/app/Amqp/Consumer/OrderGoodStockConsumer.php b/app/Amqp/Consumer/OrderGoodStockConsumer.php index 24e6b47..678fd56 100644 --- a/app/Amqp/Consumer/OrderGoodStockConsumer.php +++ b/app/Amqp/Consumer/OrderGoodStockConsumer.php @@ -83,6 +83,7 @@ class OrderGoodStockConsumer extends ConsumerMessage $this->skuArr = []; $this->orderGoodArr = $this->orderGoodModel->getGoodIdsByOrderId($orderId); + $this->log->debug('OrderGoodStockConsumer:'.json_encode($this->orderGoodArr)); if (empty($this->orderGoodArr)) { $this->log->debug('OrderGoodStockConsumer:error:NoOrderGoodData:'.json_encode($orderId)); return Result::ACK; diff --git a/app/Model/OrderGood.php b/app/Model/OrderGood.php index a48b198..3dd770c 100644 --- a/app/Model/OrderGood.php +++ b/app/Model/OrderGood.php @@ -50,6 +50,6 @@ class OrderGood extends Model */ public function getGoodIdsByOrderId(int $orderId): array { - return $this->where('order_id', $orderId)->select('sku_id')->selectRaw('SUM(`quantity`) as `quantity`')->get()->toArray(); + return $this->where('order_id', $orderId)->select('sku_id')->selectRaw('SUM(`quantity`) as `quantity`')->groupBy('sku_id')->get()->toArray(); } }