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'];