From 5aabbbdf2a710da02f59a2a3bb6030c1bb4d866a Mon Sep 17 00:00:00 2001 From: zhangwei <894646498@qq.com> Date: Tue, 7 Nov 2023 16:13:18 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=9A=E6=97=B6=E4=BF=AE=E6=94=B9=E4=BB=BB?= =?UTF-8?q?=E5=8A=A1=E7=8A=B6=E6=80=81=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Former-commit-id: 6d994295482df4fb123a3260c90cb2927ba6c0bb --- rpc/internal/cron/cronlogic.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/rpc/internal/cron/cronlogic.go b/rpc/internal/cron/cronlogic.go index fc0679f1..dc628a18 100644 --- a/rpc/internal/cron/cronlogic.go +++ b/rpc/internal/cron/cronlogic.go @@ -14,7 +14,7 @@ func InitCron(svc *svc.ServiceContext) { svc.Cron.AddFunc("*/5 * * * * ?", func() { var tasks []models.Task - svc.DbEngin.Not("status not in ?", []string{constants.Deleted, constants.Succeeded, constants.Completed, constants.Failed}).Find(&tasks) + svc.DbEngin.Where("status not in ?", []string{constants.Deleted, constants.Succeeded, constants.Completed, constants.Failed}).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)