2

2024-04-18 17:07:29 +08:00
parent 2a694d55f6
commit 95cf4e47d5
2 changed files with 4 additions and 3 deletions
@@ -133,12 +133,15 @@ class CouponService extends BaseService
            }

            // 添加优惠卷过期队列
-            $valid_end_time = strtotime($user_coupon['valid_start_time']);
+            $valid_end_time = strtotime($user_coupon['valid_end_time']);

            $data = array();
            $data['user_coupon_id'] = $user_coupon['user_coupon_id'];

            $time = $valid_end_time - time();
+            if ($time < 0){
+                return false;
+            }
            $message = new UserCouponExpiredDelayDirectProducer($data);
            $message->setDelayMs(1000 * $time);
            $producer = $this->container->get(Producer::class);