From 8f7a023d89230530fffb280dffb6df16c3b3ecdd Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com>
Date: Fri, 6 Mar 2020 17:03:55 +0800
Subject: [PATCH] =?UTF-8?q?=E7=94=9F=E6=88=90=E9=97=A8=E5=BA=97=E5=95=86?=
 =?UTF-8?q?=E5=93=81=E5=A4=87=E4=BB=BD=E8=A1=A8=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 business/jxstore/cms/store_sku.go | 18 +++++++++++-------
 1 file changed, 11 insertions(+), 7 deletions(-)

diff --git a/business/jxstore/cms/store_sku.go b/business/jxstore/cms/store_sku.go
index 0e8db150c..789a4705c 100644
--- a/business/jxstore/cms/store_sku.go
+++ b/business/jxstore/cms/store_sku.go
@@ -3859,12 +3859,14 @@ func BackUpStoreSkuBind(ctx *jxcontext.Context, isAsync, isContinueWhenError boo
 	}
 	dao.DeleteEntity(db, storeSkuBindHis, "SnapShotAt")
 	dao.DeleteEntity(db, storeSkuBindHis2, "SnapShotAt")
+	storeList, err := dao.GetStoreList(db, nil, nil, nil, nil, "")
 	sql := `SELECT * FROM store_sku_bind WHERE deleted_at = ?`
 	sqlParams := []interface{}{utils.DefaultTimeValue}
 	err = dao.GetRows(db, &storeSkuBinds, sql, sqlParams)
 	task := tasksch.NewParallelTask("RefreshOrdersPriceInfo", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx,
 		func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
-			v := batchItemList[0].(*model.StoreSkuBind)
+			store := batchItemList[0].(*model.Store)
+			storeSku, err := dao.GetStoresSkusInfo(db, []int{store.ID}, nil)
 			dao.Begin(db)
 			defer func() {
 				if r := recover(); r != nil {
@@ -3872,14 +3874,16 @@ func BackUpStoreSkuBind(ctx *jxcontext.Context, isAsync, isContinueWhenError boo
 					panic(r)
 				}
 			}()
-			storeSkuBindHis := &model.StoreSkuBindHistory{}
-			storeSkuBindHis.StoreSkuBind = *v
-			storeSkuBindHis.StoreSkuBindID = v.ID
-			storeSkuBindHis.SnapshotAt = snapshotAt
-			dao.CreateEntity(db, storeSkuBindHis)
+			for _, v := range storeSku {
+				storeSkuBindHis := &model.StoreSkuBindHistory{}
+				storeSkuBindHis.StoreSkuBind = *v
+				storeSkuBindHis.StoreSkuBindID = v.ID
+				storeSkuBindHis.SnapshotAt = snapshotAt
+				dao.CreateEntity(db, storeSkuBindHis)
+			}
 			dao.Commit(db)
 			return retVal, err
-		}, storeSkuBinds)
+		}, storeList)
 	tasksch.HandleTask(task, nil, true).Run()
 	if isAsync {
 		hint = task.GetID()