2

app/Amqp/Consumer/GrantUserCouponDelayDirectConsumer.php

@@ -5,21 +5,31 @@ declare(strict_types=1);
 namespace App\Amqp\Consumer;
 
 use App\Model\Coupon;
-use App\Model\OrderInquiry;
 use App\Services\CouponService;
 use App\Utils\Log;
+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\DbConnection\Db;
 use PhpAmqpLib\Message\AMQPMessage;
 
-/**
- * 延迟发放用户优惠卷
- */
-#[Consumer(exchange: 'amqp.direct', routingKey: 'GrantUserCoupon', queue: 'grant.user.coupon.queue', nums: 1)]
+#[Consumer(nums: 1)]
 class GrantUserCouponDelayDirectConsumer extends ConsumerMessage
 {
+    use ProducerDelayedMessageTrait;
+    use ConsumerDelayedMessageTrait;
+
+    protected string $exchange = 'amqp.delay.direct';
+
+    protected ?string $queue = 'grant.user.coupon.delay.queue';
+
+    protected string $type = Type::DIRECT; //Type::FANOUT;
+
+    protected string|array $routingKey = 'GrantUserCoupon';
+
     public function consumeMessage($data, AMQPMessage $message): string
     {
         Log::getInstance("queue-GrantUserCoupon")->info("开始执行 延迟发放用户优惠卷 队列：" . json_encode($data, JSON_UNESCAPED_UNICODE));

app/Amqp/Producer/GrantUserCouponDelayDirectProducer.php

@@ -9,9 +9,6 @@ use Hyperf\Amqp\Message\ProducerDelayedMessageTrait;
 use Hyperf\Amqp\Message\ProducerMessage;
 use Hyperf\Amqp\Message\Type;
 
-/**
- * 延迟发放用户优惠卷
- */
 #[Producer]
 class GrantUserCouponDelayDirectProducer extends ProducerMessage
 {