From 2464e1d803e1a015bd933d9078872aad1b7b3be0 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com> Date: Tue, 19 Jan 2021 09:35:34 +0800 Subject: [PATCH] aa --- business/jxstore/cms/job.go | 19 +++++++++++++++++-- 1 file changed, 17 insertions(+), 2 deletions(-) diff --git a/business/jxstore/cms/job.go b/business/jxstore/cms/job.go index eb95281f6..3d2bbd14c 100644 --- a/business/jxstore/cms/job.go +++ b/business/jxstore/cms/job.go @@ -828,11 +828,26 @@ func AuditJob(ctx *jxcontext.Context, jobOrderID, status int, comment, vendorWay } } } 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) 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) }