From c818eef08ea0f70613455bf407af0d05c536fc8c Mon Sep 17 00:00:00 2001 From: chenlin Date: Tue, 1 Apr 2025 10:48:34 +0800 Subject: [PATCH] =?UTF-8?q?1=E3=80=81=E4=BC=98=E5=8C=96=E5=AE=9A=E6=97=B6?= =?UTF-8?q?=E4=BB=BB=E5=8A=A1=EF=BC=9B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- cmd/api/server.go | 68 ++++++++++++++++++++++++++++++++++------------- 1 file changed, 49 insertions(+), 19 deletions(-) diff --git a/cmd/api/server.go b/cmd/api/server.go index c241c90..6a08b86 100644 --- a/cmd/api/server.go +++ b/cmd/api/server.go @@ -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) } }