This commit is contained in:
苏尹岚
2020-11-05 16:20:12 +08:00
parent 40fd3e6d2c
commit 49ac45a94a

View File

@@ -546,8 +546,11 @@ func RefreshJobStatus(ctx *jxcontext.Context) (err error) {
}
for _, job := range jobs {
if time.Now().Sub(*job.FinishedAt) >= 0 {
job.Status = model.JobStatusOverdue
dao.UpdateEntity(db, job, "Status")
job2 := &model.Job{}
job2.ID = job.ID
dao.GetEntity(db, job2)
job2.Status = model.JobStatusOverdue
dao.UpdateEntity(db, job2, "Status")
}
}
globals.SugarLogger.Debugf("RefreshJobStatus end...")