From 43152742d5a991d201a6bfd0ca03bca5edc446ed Mon Sep 17 00:00:00 2001
From: wucongxing8150 <815046773@qq.com>
Date: Wed, 24 Apr 2024 13:14:52 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E4=BC=98=E6=83=A0=E5=8D=B7?=
 =?UTF-8?q?=E8=BF=87=E6=9C=9F=E8=AE=A1=E7=AE=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/Amqp/Consumer/UserCouponExpiredDelayDirectConsumer.php | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/app/Amqp/Consumer/UserCouponExpiredDelayDirectConsumer.php b/app/Amqp/Consumer/UserCouponExpiredDelayDirectConsumer.php
index 5de7b84..67c0e06 100644
--- a/app/Amqp/Consumer/UserCouponExpiredDelayDirectConsumer.php
+++ b/app/Amqp/Consumer/UserCouponExpiredDelayDirectConsumer.php
@@ -42,7 +42,6 @@ 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("入参错误");
@@ -78,6 +77,11 @@ class UserCouponExpiredDelayDirectConsumer extends ConsumerMessage
             // 先删除-重新添加队列
             if ($valid_end_time > time()){
                 $time = $valid_end_time - time();
+                Log::getInstance("queue-UserCouponExpired")->info($time);
+
+                if ($time < 60 * 60 * 24){
+                    $time = 60 * 60 * 24;
+                }
 
                 $queue_data = array();
                 $queue_data['user_coupon_id'] = $user_coupon['user_coupon_id'];