diff --git a/app/Services/CouponService.php b/app/Services/CouponService.php index 7e83d48..f43d36a 100644 --- a/app/Services/CouponService.php +++ b/app/Services/CouponService.php @@ -129,10 +129,11 @@ class CouponService extends BaseService // 添加用户优惠卷自动过期队列 // 添加自动完成队列 + $valid_end_time = $data['valid_end_time']; $data = array(); $data['user_coupon_id'] = $user_coupon['user_coupon_id']; - $time = $data['valid_end_time'] - time(); + $time = $valid_end_time - time(); $message = new UserCouponExpiredDelayDirectProducer($data); $message->setDelayMs(1000 * $time); $producer = $this->container->get(Producer::class);