刷新京东门店等级

business/jxstore/cms/store.go

@@ -2585,6 +2585,15 @@ func RefreshJdLevel(ctx *jxcontext.Context) (err error) {
 	db := dao.GetDB()
 	storeMapList, err := dao.GetStoresMapList(db, []int{model.VendorIDJD}, nil, model.StoreStatusOpened, -1, "")
 	if len(storeMapList) > 0 {
+		dao.Begin(db)
+		defer func() {
+			if r := recover(); r != nil || err != nil {
+				dao.Rollback(db)
+				if r != nil {
+					panic(r)
+				}
+			}
+		}()
 		task := tasksch.NewParallelTask("更新京东门店等级", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
 			func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
 				v := batchItemList[0].(*model.StoreMap)
@@ -2606,21 +2615,12 @@ func RefreshJdLevel(ctx *jxcontext.Context) (err error) {
 					}
 				}
 				v.JdStoreLevel = level
-				dao.Begin(db)
-				defer func() {
-					if r := recover(); r != nil || err != nil {
-						dao.Rollback(db)
-						if r != nil {
-							panic(r)
-						}
-					}
-				}()
 				_, err = dao.UpdateEntity(db, v, "JdStoreLevel")
-				dao.Commit(db)
 				return retVal, err
 			}, storeMapList)
 		tasksch.HandleTask(task, nil, true).Run()
 		_, err = task.GetResult(0)
+		dao.Commit(db)
 	}
 	return err
 }