新增amqp队列，新增订单创建

app/Amqp/Consumer/CancelUnpayOrdersDelayDirectConsumer.php

@@ -0,0 +1,37 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Amqp\Consumer;
+
+use Hyperf\Amqp\Message\ConsumerDelayedMessageTrait;
+use Hyperf\Amqp\Message\ProducerDelayedMessageTrait;
+use Hyperf\Amqp\Result;
+use Hyperf\Amqp\Annotation\Consumer;
+use Hyperf\Amqp\Message\ConsumerMessage;
+use PhpAmqpLib\Message\AMQPMessage;
+use Hyperf\Amqp\Message\Type;
+
+/**
+ * 取消未支付订单消费者-延迟队列
+ */
+#[Consumer(nums: 1)]
+class CancelUnpayOrdersDelayDirectConsumer extends ConsumerMessage
+{
+    use ProducerDelayedMessageTrait;
+    use ConsumerDelayedMessageTrait;
+
+    protected string $exchange = 'amqp.delay.direct';
+
+    protected ?string $queue = 'cancel.unpay.orders.delay.queue';
+
+    protected string $type = Type::DIRECT; //Type::FANOUT;
+
+    protected string|array $routingKey = '';
+
+    public function consumeMessage($data, AMQPMessage $message): string
+    {
+        dump($data);
+        return Result::ACK;
+    }
+}