From 2a694d55f629395c4db12a31a3ebb2e881ce67a4 Mon Sep 17 00:00:00 2001
From: wucongxing8150 <815046773@qq.com>
Date: Thu, 18 Apr 2024 16:57:34 +0800
Subject: [PATCH] 12

---
 app/Amqp/Consumer/UserCouponExpiredDelayDirectConsumer.php | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/app/Amqp/Consumer/UserCouponExpiredDelayDirectConsumer.php b/app/Amqp/Consumer/UserCouponExpiredDelayDirectConsumer.php
index eebd6e9..f0a9341 100644
--- a/app/Amqp/Consumer/UserCouponExpiredDelayDirectConsumer.php
+++ b/app/Amqp/Consumer/UserCouponExpiredDelayDirectConsumer.php
@@ -42,6 +42,8 @@ class UserCouponExpiredDelayDirectConsumer extends ConsumerMessage
     {
         Log::getInstance("queue-UserCouponExpired")->info("开始：" . json_encode($data, JSON_UNESCAPED_UNICODE));
 
+        return Result::DROP;
+
         // 检测参数
         if (!isset($data['user_coupon_id'])){
             Log::getInstance("queue-UserCouponExpired")->error("入参错误");
@@ -80,14 +82,13 @@ class UserCouponExpiredDelayDirectConsumer extends ConsumerMessage
 
                 $queue_data = array();
                 $queue_data['user_coupon_id'] = $user_coupon['user_coupon_id'];
-
                 $message = new UserCouponExpiredDelayDirectProducer($queue_data);
                 $message->setDelayMs(1000 * $time);
                 $producer = $this->container->get(Producer::class);
                 $res = $producer->produce($message);
                 if (!$res) {
                     Log::getInstance("queue-UserCouponExpired")->error("未到过期时间，重新添加队列失败");
-                    return Result::DROP;
+                    return Result::REQUEUE;
                 }
 
                 return Result::DROP;