This commit is contained in:
苏尹岚
2021-01-19 09:35:34 +08:00
parent 7ef72424bb
commit 2464e1d803

View File

@@ -828,11 +828,26 @@ func AuditJob(ctx *jxcontext.Context, jobOrderID, status int, comment, vendorWay
} }
} }
} else { } else {
job.SurplusCount += 1 //审核不通过的话,要重新变成待上传,再重新开个定时器
if _, err = dao.UpdateEntity(db, job, "SurplusCount"); err != nil { jobOrder.Status = model.JobOrderStatusAccept
if _, err = dao.UpdateEntity(db, jobOrder, "Status"); err != nil {
dao.Rollback(db) dao.Rollback(db)
return return
} }
//之前的定时表删了?
jobTimer := &model.JobTimer{
JobID: job.ID,
JobOrderID: jobOrder.JobOrderID,
}
if _, err = dao.DeleteEntity(db, jobTimer, "JobID", "JobOrderID"); err != nil {
dao.Rollback(db)
return
}
//任务限时完成
timer := checkLimitJobOrders(db, job, jobOrder, model.JobTimerTypeAccept)
JobTimers.s.Lock()
JobTimers.JobTimerMap[jobOrder.JobOrderID] = timer
JobTimers.s.Unlock()
} }
event.SendSysMessageSimple(content2.String(), jobOrder.UserID) event.SendSysMessageSimple(content2.String(), jobOrder.UserID)
} }