aa

controllers/act.go

@@ -282,27 +282,16 @@ func (c *ActController) UpdateActStoreSkuBind() {
 				err = fmt.Errorf("actStoreSkuAddList与actStoreSkuDeleteList不能都为空")
 			} else {
 				db := dao.GetDB()
-				txDB, _ := dao.Begin(db)
-				func() {
-					defer func() {
-						if r := recover(); r != nil {
-							dao.Rollback(db, txDB)
-						}
-					}()
-					if len(actStoreSkuAddList) > 0 {
-						if err = act.AddActStoreSkuBind(params.Ctx, db, params.ActID, actStoreSkuAddList); err != nil {
-							dao.Rollback(db, txDB)
-							return
-						}
+				if len(actStoreSkuAddList) > 0 {
+					if err = act.AddActStoreSkuBind(params.Ctx, db, params.ActID, actStoreSkuAddList); err != nil {
+						return
 					}
-					if len(actStoreSkuDeleteList) > 0 {
-						if _, err = act.DeleteActStoreSkuBind(params.Ctx, db, params.ActID, actStoreSkuDeleteList); err != nil {
-							dao.Rollback(db, txDB)
-							return
-						}
+				}
+				if len(actStoreSkuDeleteList) > 0 {
+					if _, err = act.DeleteActStoreSkuBind(params.Ctx, db, params.ActID, actStoreSkuDeleteList); err != nil {
+						return
 					}
-					dao.Commit(db, txDB)
-				}()
+				}
 				if err == nil {
 					retVal, err = act.SyncAct(params.Ctx, nil, params.ActID, nil, params.IsAsync)
 				}