修改优惠卷过期计算
This commit is contained in:
parent
955b24a205
commit
43152742d5
@ -42,7 +42,6 @@ class UserCouponExpiredDelayDirectConsumer extends ConsumerMessage
|
|||||||
{
|
{
|
||||||
Log::getInstance("queue-UserCouponExpired")->info("开始:" . json_encode($data, JSON_UNESCAPED_UNICODE));
|
Log::getInstance("queue-UserCouponExpired")->info("开始:" . json_encode($data, JSON_UNESCAPED_UNICODE));
|
||||||
|
|
||||||
return Result::DROP;
|
|
||||||
// 检测参数
|
// 检测参数
|
||||||
if (!isset($data['user_coupon_id'])){
|
if (!isset($data['user_coupon_id'])){
|
||||||
Log::getInstance("queue-UserCouponExpired")->error("入参错误");
|
Log::getInstance("queue-UserCouponExpired")->error("入参错误");
|
||||||
@ -78,6 +77,11 @@ class UserCouponExpiredDelayDirectConsumer extends ConsumerMessage
|
|||||||
// 先删除-重新添加队列
|
// 先删除-重新添加队列
|
||||||
if ($valid_end_time > time()){
|
if ($valid_end_time > time()){
|
||||||
$time = $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 = array();
|
||||||
$queue_data['user_coupon_id'] = $user_coupon['user_coupon_id'];
|
$queue_data['user_coupon_id'] = $user_coupon['user_coupon_id'];
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user