From f5b7b03044680a00e5896f9497b912f8ee7078a1 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com>
Date: Tue, 17 Dec 2019 08:57:51 +0800
Subject: [PATCH] =?UTF-8?q?=E5=88=B7=E6=96=B0=E4=BA=AC=E4=B8=9C=E9=97=A8?=
 =?UTF-8?q?=E5=BA=97=E7=AD=89=E7=BA=A7?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 business/jxstore/cms/store.go | 20 ++++++++++----------
 1 file changed, 10 insertions(+), 10 deletions(-)

diff --git a/business/jxstore/cms/store.go b/business/jxstore/cms/store.go
index f4952c33a..7b124a2e6 100644
--- a/business/jxstore/cms/store.go
+++ b/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
 }