chenlin/migu_admin_server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1、优化定时任务；

Browse Source
This commit is contained in:
chenlin 2025-04-01 10:48:34 +08:00
parent 9b23df12bd
commit c818eef08e
1 changed files with 49 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

68
cmd/api/server.go
View File

@ -100,33 +100,63 @@ func run() error {
fmt.Println("err:", err)
}
} else {
today := time.Now().Day() // 获取当前日期的天数
// 统一每天定时任务
err := s.Every(1).Day().At("01:30").Do(func() {
if time.Now().Day() == 1 {
// 每月1号的逻辑
fmt.Println("****每月1号 检测未退订 任务延迟到03:30执行****")
} else {
// 其他日期的逻辑
fmt.Println("执行普通每日任务：检测 未退订")
models.CheckAllOrderState()
}
})
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("02:30").Do(func() {
if time.Now().Day() == 1 {
// 每月1号的逻辑
fmt.Println("****每月1号 检测已退订 任务延迟到04:30执行****")
} else {
// 其他日期的逻辑
fmt.Println("执行普通每日任务：检测 已退订")
models.CheckCancelOrderState()
}
})
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("03:30").Do(func() {
if time.Now().Day() == 1 {
fmt.Println("****执行每月1号 未退订检测****")
models.CheckAllOrderState()
}
})
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("04:30").Do(func() {
if time.Now().Day() == 1 {
fmt.Println("****执行每月1号 已退订检测 01****")
models.CheckCancelOrderState()
}
})
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)
err = s.Every(1).Day().At("05:30").Do(func() {
if time.Now().Day() == 1 {
fmt.Println("****执行每月1号 已退订检测 02****")
models.CheckCancelOrderState()
}
})
if err != nil {
fmt.Println("err:", err)
}
}