diff --git a/src/modules/crontask/crontask.go b/src/modules/crontask/crontask.go index 50de7700..5d544d25 100644 --- a/src/modules/crontask/crontask.go +++ b/src/modules/crontask/crontask.go @@ -3,7 +3,7 @@ package crontask import ( "ems.agt/src/framework/cron" "ems.agt/src/framework/logger" - "ems.agt/src/modules/crontask/tasks" + "ems.agt/src/modules/crontask/delExpiredNeBackup" "github.com/gin-gonic/gin" ) @@ -19,5 +19,6 @@ func Setup(router *gin.Engine) { // InitCronQueue 初始定时任务队列 func InitCronQueue() { - cron.CreateQueue("tasks", tasks.NewProcessor) + // delete expired NE backup file + cron.CreateQueue("delExpiredNeBackup", delExpiredNeBackup.NewProcessor) } diff --git a/src/modules/crontask/tasks/tasks.go b/src/modules/crontask/delExpiredNeBackup/delExpiredNeBackup.go similarity index 96% rename from src/modules/crontask/tasks/tasks.go rename to src/modules/crontask/delExpiredNeBackup/delExpiredNeBackup.go index 21f3b716..b7893533 100644 --- a/src/modules/crontask/tasks/tasks.go +++ b/src/modules/crontask/delExpiredNeBackup/delExpiredNeBackup.go @@ -1,4 +1,4 @@ -package tasks +package delExpiredNeBackup import ( "ems.agt/lib/dborm" @@ -57,7 +57,7 @@ func (s *BarProcessor) Execute(data any) (any, error) { // 返回结果,用于记录执行结果 return map[string]any{ - "err": err.Error(), + "msg": "sucesse", "affected": affected, }, nil }