From b41d28ff300a6f4afe598ed63377fd6db47876c2 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com>
Date: Thu, 12 Nov 2020 15:16:55 +0800
Subject: [PATCH] beta

---
 business/jxstore/tempop/tempop.go | 60 ++++++++++++++-----------------
 1 file changed, 26 insertions(+), 34 deletions(-)

diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go
index 41d85f2bd..8f908c6d0 100644
--- a/business/jxstore/tempop/tempop.go
+++ b/business/jxstore/tempop/tempop.go
@@ -1823,46 +1823,38 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
 					}
 				}
 			case 1:
-
+				if len(statusList1) > 0 {
+					for k, v := range statusList1 {
+						_, err = putils.FreeBatchStoreSkuInfo("更新门店商品状态", func(task tasksch.ITask, batchedStoreSkuList []*partner.StoreSkuInfo) (result interface{}, successCount int, err error) {
+							handler.UpdateStoreSkusStatus(ctx, vendorOrgCode, 0, k, batchedStoreSkuList, batchedStoreSkuList[0].Status)
+							return nil, 1, err
+						}, ctx, task, v, 50, true)
+					}
+				}
+			case 2:
+				if len(statusList2) > 0 {
+					for k, v := range statusList1 {
+						_, err = putils.FreeBatchStoreSkuInfo("更新门店商品状态2", func(task tasksch.ITask, batchedStoreSkuList []*partner.StoreSkuInfo) (result interface{}, successCount int, err error) {
+							handler.UpdateStoreSkusStatus(ctx, vendorOrgCode, 0, k, batchedStoreSkuList, batchedStoreSkuList[0].Status)
+							return nil, 1, err
+						}, ctx, task, v, 50, true)
+					}
+				}
+			case 3:
+				if len(stockList) > 0 {
+					for k, v := range stockList {
+						_, err = putils.FreeBatchStoreSkuInfo("更新门店商品库存", func(task tasksch.ITask, batchedStoreSkuList []*partner.StoreSkuInfo) (result interface{}, successCount int, err error) {
+							handler.UpdateStoreSkusStock(ctx, vendorOrgCode, 0, k, batchedStoreSkuList)
+							return nil, 1, err
+						}, ctx, task, v, 50, true)
+					}
+				}
 			}
 			return retVal, err
 		}, []int{0, 1, 2, 3})
 	tasksch.HandleTask(task, nil, true).Run()
 	_, err = task.GetResult(0)
 	return err
-
-	// if len(priceList) > 0 {
-	// 	for k, v := range priceList {
-	// 		if len(v) > 50 {
-	// 			for i := 0; i < len(v)/50+1; i++ {
-	// 				j := i
-	// 				if i == len(v)/50+1 {
-	// 					handler.UpdateStoreSkusPrice(ctx, vendorOrgCode, 0, k, v[j:len(v)])
-	// 				} else {
-	// 					handler.UpdateStoreSkusPrice(ctx, vendorOrgCode, 0, k, v[j:50*(j+1)])
-	// 				}
-	// 				j += 50
-	// 			}
-	// 		}
-	// 	}
-	// }
-	if len(statusList1) > 0 {
-		// for k, v := range statusList1 {
-		// 	handler.UpdateStoreSkusStatus(ctx, vendorOrgCode, 0, k, v, v[0].Status)
-		// }
-	}
-	if len(statusList2) > 0 {
-
-		// for k, v := range statusList2 {
-		// 	handler.UpdateStoreSkusStatus(ctx, vendorOrgCode, 0, k, v, v[0].Status)
-		// }
-	}
-	if len(stockList) > 0 {
-		// for k, v := range stockList {
-		// 	handler.UpdateStoreSkusStock(ctx, vendorOrgCode, 0, k, v)
-		// }
-	}
-	return err
 }
 
 func storeSkuFullList2BareFilter(storeSkuFull []*partner.SkuNameInfo) (bareStoreSkuList []*partner.StoreSkuInfo) {