From cc9ac79e45a38984df17a5c7ba9202da7b5f0fcb Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com>
Date: Fri, 16 Oct 2020 15:07:29 +0800
Subject: [PATCH] audit job

---
 business/jxstore/cms/job.go | 16 +++++++++++++++-
 1 file changed, 15 insertions(+), 1 deletion(-)

diff --git a/business/jxstore/cms/job.go b/business/jxstore/cms/job.go
index 40e6df83c..8e3f30a4d 100644
--- a/business/jxstore/cms/job.go
+++ b/business/jxstore/cms/job.go
@@ -315,6 +315,20 @@ func checkLimitJobOrders(db *dao.DaoDB, job *model.Job, jobOrder *model.JobOrder
 	})
 }
 
+func checkLimitAuditJobOrders(db *dao.DaoDB, job *model.Job, jobOrder *model.JobOrder) {
+	utils.AfterFuncWithRecover(time.Hour*time.Duration(job.AuditLimitAt), func() {
+		utils.CallFuncAsync(func() {
+			globals.SugarLogger.Debugf("checkLimitAuditJobOrders jobID: %v, jobOrderID: %v", job.ID, jobOrder.JobOrderID)
+			if jobOrder.Status == model.JobOrderStatusWaitAudit {
+				err := AuditJob(jxcontext.AdminCtx, int(jobOrder.JobOrderID), model.JobOrderStatusAuditPass, "超时系统通过")
+				if err != nil {
+					globals.SugarLogger.Debugf("checkLimitAuditJobOrders err: %v jobID: %v, jobOrderID: %v", err, job.ID, jobOrder.JobOrderID)
+				}
+			}
+		})
+	})
+}
+
 func SubmitJob(ctx *jxcontext.Context, jobOrder *model.JobOrder) (err error) {
 	var (
 		db = dao.GetDB()
@@ -343,7 +357,7 @@ func SubmitJob(ctx *jxcontext.Context, jobOrder *model.JobOrder) (err error) {
 	jobOrder2.Status = model.JobOrderStatusWaitAudit
 	if _, err = dao.UpdateEntity(db, jobOrder2, "Img", "Content", "SubmitAuditAt", "Status"); err == nil {
 		//审核定时
-
+		checkLimitAuditJobOrders(db, job, jobOrder2)
 	}
 	return err
 }