diff --git a/adaptor/PCM-CORE/rpc/internal/logic/cronlogic.go b/adaptor/PCM-CORE/rpc/internal/logic/cronlogic.go index 89ce4a9b..c7e8bef6 100644 --- a/adaptor/PCM-CORE/rpc/internal/logic/cronlogic.go +++ b/adaptor/PCM-CORE/rpc/internal/logic/cronlogic.go @@ -12,7 +12,7 @@ func InitCron(svc *svc.ServiceContext) { svc.Cron.Start() svc.Cron.AddFunc("*/5 * * * * ?", func() { var tasks []model.Task - svc.DbEngin.Find(&tasks) + svc.DbEngin.Not("status = ?", "Completed").Find(&tasks) for _, task := range tasks { var allStatus string tx := svc.DbEngin.Raw("SELECT CONCAT_WS(',',GROUP_CONCAT(DISTINCT h.status) ,GROUP_CONCAT(DISTINCT a.status) ,GROUP_CONCAT(DISTINCT c.status))as status from task t left join hpc h on t.id = h.task_id left join cloud c on t.id = c.task_id left join ai a on t.id = a.task_id where t.id = ?", task.Id).Scan(&allStatus)