diff --git a/business/jxstore/cms/job.go b/business/jxstore/cms/job.go index c0d2c736e..1e0475ab3 100644 --- a/business/jxstore/cms/job.go +++ b/business/jxstore/cms/job.go @@ -661,11 +661,16 @@ func RefreshJobStatus(ctx *jxcontext.Context) (err error) { return err } //3、任务状态被取消 - job.Status = model.JobStatusOverdue - // job.DeletedAt = time.Now() - if _, err = dao.UpdateEntity(db, job, "Status"); err != nil { - dao.Rollback(db) - return err + job2 := &model.Job{} + job2.ID = job.ID + dao.GetEntity(db, job2) + if job2 != nil { + job2.Status = model.JobStatusOverdue + // job.DeletedAt = time.Now() + if _, err = dao.UpdateEntity(db, job2, "Status"); err != nil { + dao.Rollback(db) + return err + } } dao.Commit(db) }