hehele/hyperf_service
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat : order

Browse Source
This commit is contained in:
ctexthuang
2025-03-04 16:26:14 +08:00
parent 8b67fccf64
commit 902ffa5f1f
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
app/Amqp/Consumer/OrderGoodStockConsumer.php
View File

@@ -16,6 +16,7 @@ use Hyperf\Amqp\Message\Type;
use Hyperf\Amqp\Result; use Hyperf\Amqp\Result;
use Hyperf\Amqp\Annotation\Consumer; use Hyperf\Amqp\Annotation\Consumer;
use Hyperf\Amqp\Message\ConsumerMessage; use Hyperf\Amqp\Message\ConsumerMessage;
use Hyperf\DbConnection\Db;
use Hyperf\Di\Annotation\Inject; use Hyperf\Di\Annotation\Inject;
use PhpAmqpLib\Message\AMQPMessage; use PhpAmqpLib\Message\AMQPMessage;
use Psr\Container\ContainerExceptionInterface; use Psr\Container\ContainerExceptionInterface;
@@ -112,7 +113,7 @@ class OrderGoodStockConsumer extends ConsumerMessage
return Result::ACK; return Result::ACK;
} }
if (!(new Sku)->update($this->updateArr)) { if (!(Db::table('sku')->update($this->updateArr))) {
$this->log->debug('OrderGoodStockConsumer:error:UpdateSkuDataFail:'.json_encode($this->updateArr)); $this->log->debug('OrderGoodStockConsumer:error:UpdateSkuDataFail:'.json_encode($this->updateArr));
return Result::ACK; return Result::ACK;
} }
@@ -133,7 +134,7 @@ class OrderGoodStockConsumer extends ConsumerMessage
$this->updateArr[] = [ $this->updateArr[] = [
'id' => $orderGood['sku_id'], 'id' => $orderGood['sku_id'],
'sales_num' => ($this->skuArr[$orderGood['sku_id']]['sales_num'] ?? 0) + $orderGood['quantity'], 'sales_num' => ($this->skuArr[$orderGood['sku_id']]['sales_num'] ?? 0) + $orderGood['quantity'],
'order_num' => ($this->skuArr[$orderGood['sku_id']]['order_num'] ?? 0) + 1, 'order_num' => ($this->skuArr[$orderGood['sku_id']]['order_num'] ?? 0) + $orderGood['quantity'],
'surplus_stock' => ($this->skuArr[$orderGood['sku_id']]['surplus_stock'] ?? 0) - $orderGood['quantity'], 'surplus_stock' => ($this->skuArr[$orderGood['sku_id']]['surplus_stock'] ?? 0) - $orderGood['quantity'],
]; ];
} }
@@ -152,7 +153,7 @@ class OrderGoodStockConsumer extends ConsumerMessage
$this->updateArr[] = [ $this->updateArr[] = [
'id' => $orderGood['sku_id'], 'id' => $orderGood['sku_id'],
'refund_num' => ($this->skuArr[$orderGood['sku_id']]['refund_num'] ?? 0) + $orderGood['quantity'], 'refund_num' => ($this->skuArr[$orderGood['sku_id']]['refund_num'] ?? 0) + $orderGood['quantity'],
'order_num' => ($this->skuArr[$orderGood['sku_id']]['order_num'] ?? 0) - 1, 'order_num' => ($this->skuArr[$orderGood['sku_id']]['order_num'] ?? 0) - $orderGood['quantity'],
'surplus_stock' => ($this->skuArr[$orderGood['sku_id']]['surplus_stock'] ?? 0) + $orderGood['quantity'], 'surplus_stock' => ($this->skuArr[$orderGood['sku_id']]['surplus_stock'] ?? 0) + $orderGood['quantity'],
]; ];
} }
@@ -167,7 +168,7 @@ class OrderGoodStockConsumer extends ConsumerMessage
$this->updateArr[] = [ $this->updateArr[] = [
'id' => $orderGood['sku_id'], 'id' => $orderGood['sku_id'],
'cancel_num' => ($this->skuArr[$orderGood['sku_id']]['cancel_num'] ?? 0) + $orderGood['quantity'], 'cancel_num' => ($this->skuArr[$orderGood['sku_id']]['cancel_num'] ?? 0) + $orderGood['quantity'],
'order_num' => ($this->skuArr[$orderGood['sku_id']]['order_num'] ?? 0) - 1, 'order_num' => ($this->skuArr[$orderGood['sku_id']]['order_num'] ?? 0) - $orderGood['quantity'],
'surplus_stock' => ($this->skuArr[$orderGood['sku_id']]['surplus_stock'] ?? 0) + $orderGood['quantity'], 'surplus_stock' => ($this->skuArr[$orderGood['sku_id']]['surplus_stock'] ?? 0) + $orderGood['quantity'],
]; ];
} }