1、退订查询改为查询最近3天的退订数据;

2、推迟每月1号的定时任务检测时间,退订查询2次;
This commit is contained in:
chenlin 2025-03-31 15:04:00 +08:00
parent 71cb0c34e5
commit 9b23df12bd
2 changed files with 29 additions and 10 deletions

View File

@ -1277,11 +1277,11 @@ func CheckCancelOrderState() {
// 查询订单列表已退订的用户
var orderList []MgOrder
// 获取当前时间前2个小时
twoDaysAgo := time.Now().Add(-48 * time.Hour)
// 获取当前时间前72个小时
threeDaysAgo := time.Now().Add(-72 * time.Hour)
err := database.Db.Where("state = 2").
Where("unsubscribe_time >= ?", twoDaysAgo).
Where("unsubscribe_time >= ?", threeDaysAgo).
Where("product_id = ?", ProductID).
Order("created_at desc").
Find(&orderList).Error

View File

@ -100,14 +100,33 @@ func run() error {
fmt.Println("err:", err)
}
} else {
err := s.Every(1).Day().At("01:30").Do(models.CheckAllOrderState)
if err != nil {
fmt.Println("err:", err)
}
today := time.Now().Day() // 获取当前日期的天数
err = s.Every(1).Day().At("02:30").Do(models.CheckCancelOrderState)
if err != nil {
fmt.Println("err:", err)
if today == 1 { // 每个月1号
err := s.Every(1).Day().At("03:30").Do(models.CheckAllOrderState)
if err != nil {
fmt.Println("err:", err)
}
err = s.Every(1).Day().At("04:30").Do(models.CheckCancelOrderState)
if err != nil {
fmt.Println("err:", err)
}
err = s.Every(1).Day().At("05:30").Do(models.CheckCancelOrderState)
if err != nil {
fmt.Println("err:", err)
}
} else { // 其他日期
err := s.Every(1).Day().At("01:30").Do(models.CheckAllOrderState)
if err != nil {
fmt.Println("err:", err)
}
err = s.Every(1).Day().At("02:30").Do(models.CheckCancelOrderState)
if err != nil {
fmt.Println("err:", err)
}
}
}