rollback

business/jxstore/cms/job.go

@@ -264,20 +264,22 @@ func AcceptJob(ctx *jxcontext.Context, jobID int) (errCode string, err error) {
 	jobOrder.Status = model.JobOrderStatusAccept
 	// }
 	dao.Begin(db)
+	defer func() {
+		if r := recover(); r != nil {
+			dao.Rollback(db)
+			panic(r)
+		}
+	}()
 	dao.WrapAddIDCULEntity(jobOrder, ctx.GetUserName())
 	if err = dao.CreateEntity(db, jobOrder); err != nil {
-		fmt.Println("qweqweqeqweeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee")
 		dao.Rollback(db)
+		return
 	}
 	//用户接受任务，任务剩余次数-1
 	job.SurplusCount -= 1
 	if _, err = dao.UpdateEntity(db, job, "SurplusCount"); err != nil {
 		dao.Rollback(db)
-	}
+		return
-	if r := recover(); r != nil {
-		fmt.Println("qweqweqeqweqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqq")
-		dao.Rollback(db)
-		panic(r)
 	}
 	dao.Commit(db)
 	//任务限时完成