72 lines
1.7 KiB
Go
72 lines
1.7 KiB
Go
package crontab
|
|
|
|
import (
|
|
"fmt"
|
|
"hepa-calc-api/api/dao"
|
|
"hepa-calc-api/api/model"
|
|
"hepa-calc-api/extend/rabbitMq"
|
|
"hepa-calc-api/utils"
|
|
"time"
|
|
)
|
|
|
|
// UserCouponExpire 用户优惠卷过期
|
|
func UserCouponExpire() {
|
|
// 获取今日过期优惠卷
|
|
userCoupons := getUserExecCoupon()
|
|
if len(userCoupons) == 0 {
|
|
return
|
|
}
|
|
|
|
for _, userCoupon := range userCoupons {
|
|
// 计算过期时间
|
|
validEndTime := time.Time(*userCoupon.ValidEndTime)
|
|
|
|
delay := validEndTime.Sub(time.Now())
|
|
if delay < 5*time.Second {
|
|
delay = 5 * time.Second
|
|
}
|
|
|
|
// 添加处理优惠卷过期队列
|
|
data := make(map[string]interface{})
|
|
data["user_coupon_id"] = fmt.Sprintf("%d", userCoupon.UserCouponId)
|
|
|
|
p := rabbitMq.PublishS{
|
|
QueueName: "user.coupon.expired.delay.queue",
|
|
ExchangeName: "amqp.delay.direct",
|
|
RoutingKey: "UserCouponExpired",
|
|
Message: data,
|
|
Delay: delay,
|
|
}
|
|
err := p.PublishWithDelay()
|
|
if err != nil {
|
|
utils.LogJsonErr("添加处理用户优惠卷过期队列失败:", err.Error())
|
|
return
|
|
}
|
|
}
|
|
}
|
|
|
|
// 获取今日过期优惠卷
|
|
func getUserExecCoupon() (coupon []*model.UserCoupon) {
|
|
now := time.Now()
|
|
|
|
// 今天开始时间
|
|
year, month, day := now.Date()
|
|
location := now.Location()
|
|
startTime := time.Date(year, month, day, 00, 00, 00, 0, location).Format("2006-01-02 15:04:05")
|
|
|
|
// 今天结束时间
|
|
endTime := time.Date(year, month, day, 23, 59, 59, 0, location).Format("2006-01-02 15:04:05")
|
|
|
|
maps := make(map[string]interface{})
|
|
maps["user_coupon_status"] = 0
|
|
|
|
userCouponDao := dao.UserCouponDao{}
|
|
userCoupons, err := userCouponDao.GetUserCouponListByValidTime(maps, startTime, endTime)
|
|
if err != nil {
|
|
utils.LogJsonErr("系统优惠卷过期:", err.Error())
|
|
return nil
|
|
}
|
|
|
|
return userCoupons
|
|
}
|