This commit is contained in:
苏尹岚
2020-12-17 09:31:41 +08:00
parent e150bf5f59
commit 5f96b68e5e

View File

@@ -661,12 +661,17 @@ func RefreshJobStatus(ctx *jxcontext.Context) (err error) {
return err return err
} }
//3、任务状态被取消 //3、任务状态被取消
job.Status = model.JobStatusOverdue job2 := &model.Job{}
job2.ID = job.ID
dao.GetEntity(db, job2)
if job2 != nil {
job2.Status = model.JobStatusOverdue
// job.DeletedAt = time.Now() // job.DeletedAt = time.Now()
if _, err = dao.UpdateEntity(db, job, "Status"); err != nil { if _, err = dao.UpdateEntity(db, job2, "Status"); err != nil {
dao.Rollback(db) dao.Rollback(db)
return err return err
} }
}
dao.Commit(db) dao.Commit(db)
} }
} }