a
This commit is contained in:
@@ -1129,11 +1129,17 @@ func RefreshJobSpan(ctx *jxcontext.Context) (err error) {
|
||||
job.ID = jobSpan.JobID
|
||||
if err = dao.GetEntity(db, job); err == nil {
|
||||
if jobSpan.SpanType == model.JobSpanTop {
|
||||
|
||||
job.TopSeq = 0
|
||||
job.JobSpanTop = 0
|
||||
dao.UpdateEntity(db, job, "TopSeq", "JobSpanTop")
|
||||
} else {
|
||||
|
||||
job.RecmdSeq = 0
|
||||
job.JobSpanRecmd = 0
|
||||
dao.UpdateEntity(db, job, "RecmdSeq", "JobSpanRecmd")
|
||||
}
|
||||
}
|
||||
jobSpan.DeletedAt = time.Now()
|
||||
dao.UpdateEntity(db, jobSpan, "DeletedAt")
|
||||
}
|
||||
return retVal, err
|
||||
}, jobSpans)
|
||||
|
||||
Reference in New Issue
Block a user