feat: place Order

app/Amqp/Consumer/CancelOrderConsumer.php

@@ -0,0 +1,86 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Amqp\Consumer;
+
+use App\Constants\Common\OrderCode;
+use App\Lib\Log;
+use App\Model\Order;
+use Hyperf\Amqp\Message\ConsumerDelayedMessageTrait;
+use Hyperf\Amqp\Message\ProducerDelayedMessageTrait;
+use Hyperf\Amqp\Message\Type;
+use Hyperf\Amqp\Result;
+use Hyperf\Amqp\Annotation\Consumer;
+use Hyperf\Amqp\Message\ConsumerMessage;
+use Hyperf\Di\Annotation\Inject;
+use PhpAmqpLib\Message\AMQPMessage;
+
+#[Consumer(exchange: 'OrderCancel', routingKey: 'OrderCancel', queue: 'OrderCancel.delay', name: "CancelOrderConsumer", nums: 1)]
+class CancelOrderConsumer extends ConsumerMessage
+{
+    use ProducerDelayedMessageTrait,ConsumerDelayedMessageTrait;
+
+    /**
+     * @var Type|string 消息类型
+     */
+    protected Type|string $type = Type::DIRECT;
+
+    /**
+     * @var Log $log
+     */
+    #[Inject]
+    protected Log $log;
+
+    /**
+     * @var Order
+     */
+    #[Inject]
+    protected Order $orderModel;
+
+    /**
+     * @var int
+     */
+    private int $orderId;
+
+    /**
+     * @var int
+     */
+    private int $orderType;
+
+
+    public function consumeMessage($data, AMQPMessage $message): Result
+    {
+        if (!$data['order_id'] || !$data['type']) {
+            $this->log->error('CancelOrderConsumer:error:NoData:'.json_encode($data));
+            return Result::ACK;
+        }
+
+        $this->orderId = (int)$data['order_id'];
+        $this->orderType = (int)$data['type'];
+
+        $orderInfo = match ($this->orderType) {
+            OrderCode::ORDER_TYPE_GOOD => $this->orderModel->getInfoById($this->orderId),
+            default => null,
+        };
+
+        if (empty($orderInfo)) {
+            $this->log->debug('CancelOrderConsumer:error:NoOrderData:'.json_encode($data));
+            return Result::ACK;
+        }
+
+        if ($orderInfo->status != OrderCode::WAIT_PAY) {
+            $this->log->debug('CancelOrderConsumer:error:orderStatusError:'.json_encode($orderInfo->toArray()));
+            return Result::ACK;
+        }
+
+        $orderInfo->status = OrderCode::CANCEL;
+        if (!$orderInfo->save()) {
+            $this->log->debug('CancelOrderConsumer:error:orderStatusSaveError:'.json_encode($orderInfo->toArray()));
+            return Result::ACK;
+        }
+
+
+        return Result::ACK;
+    }
+}

app/Amqp/Consumer/OrderGoodStockConsumer.php

@@ -0,0 +1,26 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Amqp\Consumer;
+
+use Hyperf\Amqp\Message\Type;
+use Hyperf\Amqp\Result;
+use Hyperf\Amqp\Annotation\Consumer;
+use Hyperf\Amqp\Message\ConsumerMessage;
+use PhpAmqpLib\Message\AMQPMessage;
+
+#[Consumer(exchange: 'OrderGoodStock', routingKey: 'OrderGoodStock', queue: 'OrderGoodStock.change', name: "OrderGoodStockConsumer", nums: 1)]
+class OrderGoodStockConsumer extends ConsumerMessage
+{
+
+    /**
+     * @var Type|string 消息类型
+     */
+    protected Type|string $type = Type::DIRECT;
+
+    public function consumeMessage($data, AMQPMessage $message): Result
+    {
+        return Result::ACK;
+    }
+}

app/Amqp/Consumer/RefundOrderConsumer.php

@@ -0,0 +1,26 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Amqp\Consumer;
+
+use Hyperf\Amqp\Message\Type;
+use Hyperf\Amqp\Result;
+use Hyperf\Amqp\Annotation\Consumer;
+use Hyperf\Amqp\Message\ConsumerMessage;
+use PhpAmqpLib\Message\AMQPMessage;
+
+#[Consumer(exchange: 'RefundOrder', routingKey: 'RefundOrder', queue: 'RefundOrder.direct', name: "RefundOrderConsumer", nums: 1)]
+class RefundOrderConsumer extends ConsumerMessage
+{
+
+    /**
+     * @var Type|string 消息类型
+     */
+    protected Type|string $type = Type::DIRECT;
+
+    public function consumeMessage($data, AMQPMessage $message): Result
+    {
+        return Result::ACK;
+    }
+}