From 916f5413ed22c67759511646cb7afca94adc5573 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, 21 Jul 2020 15:30:33 +0800
Subject: [PATCH] =?UTF-8?q?=E5=88=B7=E9=97=A8=E5=BA=97=E5=BA=93=E5=AD=98?=
 =?UTF-8?q?=E8=BF=98=E6=98=AF=E5=BE=AA=E7=8E=AF=E6=8A=8A?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 business/jxstore/cms/sync.go | 72 ++++++++++++++++++------------------
 1 file changed, 36 insertions(+), 36 deletions(-)

diff --git a/business/jxstore/cms/sync.go b/business/jxstore/cms/sync.go
index b2d1586c7..87a1c5381 100644
--- a/business/jxstore/cms/sync.go
+++ b/business/jxstore/cms/sync.go
@@ -1116,45 +1116,45 @@ func (v *VendorSync) SyncJdsStoresSkus(ctx *jxcontext.Context, storeIDs []int, i
 }
 
 func syncJdsStoreStock(ctx *jxcontext.Context, db *dao.DaoDB, parentTask tasksch.ITask, storeSkus []*model.StoreSkuBind, storeMap *model.StoreMap, isAsync, isContinueWhenError bool) (err error) {
-	// for _, storeSku := range storeSkus {
-	// 	stock := 0
-	// 	if storeSku.Status == model.StoreSkuBindStatusNormal {
-	// 		stock = 9999
-	// 	}
-	// 	storeSku2, _ := dao.GetStoresSkusInfo(db, []int{storeMap.StoreID}, []int{storeSku.SkuID})
-	// 	if storeSku.JdsID != 0 {
-	// 		if len(storeSku2) > 0 {
-	// 			if storeSku.Status != storeSku2[0].Status && storeMap.VendorStoreID != "" {
-	// 				err = api.JdShopAPI.UpdateSkuSiteStock(storeSku.JdsID, stock, utils.Str2Int(storeMap.VendorStoreID))
-	// 			}
-	// 		} else {
-	// 			err = api.JdShopAPI.UpdateSkuSiteStock(storeSku.JdsID, 0, utils.Str2Int(storeMap.VendorStoreID))
-	// 		}
-	// 	}
-	// }
-	task := tasksch.NewParallelTask("syncJdsStoreStock", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx,
-		func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
-			storeSku := batchItemList[0].(*model.StoreSkuBind)
-			stock := 0
-			storeSku2, _ := dao.GetStoresSkusInfo(db, []int{storeMap.StoreID}, []int{storeSku.SkuID})
-			if storeSku.JdsID != 0 {
-				if len(storeSku2) > 0 {
-					if storeSku2[0].Status == model.StoreSkuBindStatusNormal {
-						stock = 9999
-					}
-					if storeMap.VendorStoreID != "" {
-						err = api.JdShopAPI.UpdateSkuSiteStock(storeSku.JdsID, stock, utils.Str2Int(storeMap.VendorStoreID))
-					}
-				} else {
-					err = api.JdShopAPI.UpdateSkuSiteStock(storeSku.JdsID, 0, utils.Str2Int(storeMap.VendorStoreID))
+	for _, storeSku := range storeSkus {
+		stock := 0
+		if storeSku.Status == model.StoreSkuBindStatusNormal {
+			stock = 9999
+		}
+		storeSku2, _ := dao.GetStoresSkusInfo(db, []int{storeMap.StoreID}, []int{storeSku.SkuID})
+		if storeSku.JdsID != 0 {
+			if len(storeSku2) > 0 {
+				if storeSku.Status != storeSku2[0].Status && storeMap.VendorStoreID != "" {
+					err = api.JdShopAPI.UpdateSkuSiteStock(storeSku.JdsID, stock, utils.Str2Int(storeMap.VendorStoreID))
 				}
+			} else {
+				err = api.JdShopAPI.UpdateSkuSiteStock(storeSku.JdsID, 0, utils.Str2Int(storeMap.VendorStoreID))
 			}
-			return retVal, err
-		}, storeSkus)
-	tasksch.HandleTask(task, parentTask, true).Run()
-	if !isAsync {
-		_, err = task.GetResult(0)
+		}
 	}
+	// task := tasksch.NewParallelTask("syncJdsStoreStock", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx,
+	// 	func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
+	// 		storeSku := batchItemList[0].(*model.StoreSkuBind)
+	// 		stock := 0
+	// 		storeSku2, _ := dao.GetStoresSkusInfo(db, []int{storeMap.StoreID}, []int{storeSku.SkuID})
+	// 		if storeSku.JdsID != 0 {
+	// 			if len(storeSku2) > 0 {
+	// 				if storeSku2[0].Status == model.StoreSkuBindStatusNormal {
+	// 					stock = 9999
+	// 				}
+	// 				if storeMap.VendorStoreID != "" {
+	// 					err = api.JdShopAPI.UpdateSkuSiteStock(storeSku.JdsID, stock, utils.Str2Int(storeMap.VendorStoreID))
+	// 				}
+	// 			} else {
+	// 				err = api.JdShopAPI.UpdateSkuSiteStock(storeSku.JdsID, 0, utils.Str2Int(storeMap.VendorStoreID))
+	// 			}
+	// 		}
+	// 		return retVal, err
+	// 	}, storeSkus)
+	// tasksch.HandleTask(task, parentTask, true).Run()
+	// if !isAsync {
+	// 	_, err = task.GetResult(0)
+	// }
 	return err
 }