From 77da618442dd496f856fe76e44bf0c2142e2ee2f Mon Sep 17 00:00:00 2001
From: Rosy-zhudan <donmicro@qq.com>
Date: Wed, 28 Aug 2019 18:32:16 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B5=8B=E8=AF=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 business/partner/purchase/ebai/store_sku2.go | 64 ++++++++++----------
 1 file changed, 32 insertions(+), 32 deletions(-)

diff --git a/business/partner/purchase/ebai/store_sku2.go b/business/partner/purchase/ebai/store_sku2.go
index 623525f4f..030db9813 100644
--- a/business/partner/purchase/ebai/store_sku2.go
+++ b/business/partner/purchase/ebai/store_sku2.go
@@ -312,41 +312,41 @@ func (p *PurchaseHandler) GetStoreSkusFullInfo(ctx *jxcontext.Context, parentTas
 	if err == nil {
 		skuNameList = append(skuNameList, vendorSkuList2Jx(page1.List)...)
 		if page1.Pages > 1 {
-			// pages := make([]int, page1.Pages-1)
-			// for i := 2; i <= page1.Pages; i++ {
-			// 	pages[i-2] = i
-			// }
-			// task := tasksch.NewParallelTask("ebai GetStoreSkusFullInfo", nil, ctx,
-			// 	func(t *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
-			// 		callParams := &ebaiapi.SkuListParams{
-			// 			PageSize: ebaiapi.MaxSkuListPageSize,
-			// 			Page:     batchItemList[0].(int),
-			// 		}
-			// 		pageSku, err2 := api.EbaiAPI.SkuList(utils.Int2Str(storeID), callParams)
-			// 		if err2 == nil {
-			// 			return pageSku.List, err2
-			// 		}
-			// 		return nil, err2
-			// 	}, pages)
-			// tasksch.HandleTask(task, parentTask, true).Run()
-			// result, err2 := task.GetResult(0)
-			// if err = err2; err == nil {
-			// 	for _, v := range result {
-			// 		skuNameList = append(skuNameList, vendorSku2Jx(v.(*ebaiapi.SkuInfo)))
-			// 	}
-			// }
-			for pageIndex := 2; pageIndex <= page1.Pages; pageIndex++ {
-				callParams := &ebaiapi.SkuListParams{
-					PageSize: ebaiapi.MaxSkuListPageSize,
-					Page:     pageIndex,
-				}
-				pageSku, err2 := api.EbaiAPI.SkuList(utils.Int2Str(storeID), callParams)
-				if err2 == nil {
-					for _, v := range pageSku.List {
-						skuNameList = append(skuNameList, vendorSku2Jx(v))
+			pages := make([]int, page1.Pages-1)
+			for i := 2; i <= page1.Pages; i++ {
+				pages[i-2] = i
+			}
+			task := tasksch.NewParallelTask("ebai GetStoreSkusFullInfo", nil, ctx,
+				func(t *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
+					callParams := &ebaiapi.SkuListParams{
+						PageSize: ebaiapi.MaxSkuListPageSize,
+						Page:     batchItemList[0].(int),
 					}
+					pageSku, err2 := api.EbaiAPI.SkuList(utils.Int2Str(storeID), callParams)
+					if err2 == nil {
+						return pageSku.List, err2
+					}
+					return nil, err2
+				}, pages)
+			tasksch.HandleTask(task, parentTask, false).Run()
+			result, err2 := task.GetResult(0)
+			if err = err2; err == nil {
+				for _, v := range result {
+					skuNameList = append(skuNameList, vendorSku2Jx(v.(*ebaiapi.SkuInfo)))
 				}
 			}
+			// for pageIndex := 2; pageIndex <= page1.Pages; pageIndex++ {
+			// 	callParams := &ebaiapi.SkuListParams{
+			// 		PageSize: ebaiapi.MaxSkuListPageSize,
+			// 		Page:     pageIndex,
+			// 	}
+			// 	pageSku, err2 := api.EbaiAPI.SkuList(utils.Int2Str(storeID), callParams)
+			// 	if err2 == nil {
+			// 		for _, v := range pageSku.List {
+			// 			skuNameList = append(skuNameList, vendorSku2Jx(v))
+			// 		}
+			// 	}
+			// }
 		}
 	}
 	return skuNameList, err