liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

rollback

Browse Source
This commit is contained in:
苏尹岚
2020-11-05 10:51:54 +08:00
parent bad35a0e0c
commit 57da75ee0d
1 changed files with 4 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
business/jxstore/cms/job.go
View File

@@ -264,12 +264,6 @@ func AcceptJob(ctx *jxcontext.Context, jobID int) (errCode string, err error) {
jobOrder.Status = model.JobOrderStatusAccept jobOrder.Status = model.JobOrderStatusAccept
// } // }
dao.Begin(db) dao.Begin(db)
defer func() {
if r := recover(); r != nil {
dao.Rollback(db)
panic(r)
}
}()
dao.WrapAddIDCULEntity(jobOrder, ctx.GetUserName()) dao.WrapAddIDCULEntity(jobOrder, ctx.GetUserName())
if err = dao.CreateEntity(db, jobOrder); err != nil { if err = dao.CreateEntity(db, jobOrder); err != nil {
dao.Rollback(db) dao.Rollback(db)
@@ -279,6 +273,10 @@ func AcceptJob(ctx *jxcontext.Context, jobID int) (errCode string, err error) {
if _, err = dao.UpdateEntity(db, job, "SurplusCount"); err != nil { if _, err = dao.UpdateEntity(db, job, "SurplusCount"); err != nil {
dao.Rollback(db) dao.Rollback(db)
} }
if r := recover(); r != nil {
dao.Rollback(db)
panic(r)
}
dao.Commit(db) dao.Commit(db)
//任务限时完成 //任务限时完成
timer := checkLimitJobOrders(db, job, jobOrder, model.JobTimerTypeAccept) timer := checkLimitJobOrders(db, job, jobOrder, model.JobTimerTypeAccept)