This commit is contained in:
wucongxing 2023-04-14 14:38:13 +08:00
parent 882127a9bb
commit d6e6e9213e

View File

@ -129,10 +129,11 @@ class CouponService extends BaseService
// 添加用户优惠卷自动过期队列 // 添加用户优惠卷自动过期队列
// 添加自动完成队列 // 添加自动完成队列
$valid_end_time = $data['valid_end_time'];
$data = array(); $data = array();
$data['user_coupon_id'] = $user_coupon['user_coupon_id']; $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 = new UserCouponExpiredDelayDirectProducer($data);
$message->setDelayMs(1000 * $time); $message->setDelayMs(1000 * $time);
$producer = $this->container->get(Producer::class); $producer = $this->container->get(Producer::class);