From 71e9cbaffd858f09318aae2f1cf7c3784da0ea29 Mon Sep 17 00:00:00 2001
From: suyl <770236076@qq.com>
Date: Fri, 24 Apr 2020 01:06:42 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BA=AC=E4=B8=9C=E6=81=A2=E5=A4=8Did?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 business/jxstore/cms/sku.go | 31 +++++++++----------------------
 1 file changed, 9 insertions(+), 22 deletions(-)

diff --git a/business/jxstore/cms/sku.go b/business/jxstore/cms/sku.go
index 41cbf3da9..f559bddf0 100644
--- a/business/jxstore/cms/sku.go
+++ b/business/jxstore/cms/sku.go
@@ -2199,32 +2199,19 @@ func writeToExcel(excelTitle []string, dataList interface{}, ctx *jxcontext.Cont
 
 func RefreshJdDepot(ctx *jxcontext.Context) (err error) {
 	var (
-		pageSize               = 20
-		searchResults          []*jdapi.SearchDeleteWareResult
-		searchResultsInterface []interface{}
-		db                     = dao.GetDB()
-		pageList               []int
+		pageSize      = 20
+		searchResults []*jdapi.SearchDeleteWareResult
+		db            = dao.GetDB()
+		pageList      []int
 		// skuIDs                 []int
 	)
 	for i := 186; i < 367; i++ {
-		pageList = append(pageList, i)
-	}
-	task := tasksch.NewParallelTask("RefreshOrdersPriceInfo", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
-		func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
-			page := batchItemList[0].(int)
-			searchDeleteWareResults, err := api.JdAPI.SearchDeleteWare("2020-04-22", "2020-04-23", page, pageSize)
-			if err == nil && len(searchDeleteWareResults) > 0 {
-				for _, v := range searchDeleteWareResults {
-					retVal = []*jdapi.SearchDeleteWareResult{v}
-				}
-			}
-			return retVal, err
-		}, pageList)
-	tasksch.HandleTask(task, nil, true).Run()
-	searchResultsInterface, err = task.GetResult(0)
-	for _, v := range searchResultsInterface {
-		searchResults = append(searchResults, v.(*jdapi.SearchDeleteWareResult))
+		searchDeleteWareResults, err := api.JdAPI.SearchDeleteWare("2020-04-22", "2020-04-23", page, pageSize)
+		if err == nil && len(searchDeleteWareResults) > 0 {
+			searchResults = append(searchResults, searchDeleteWareResults...)
+		}
 	}
+
 	for _, v := range searchResults {
 		param := &jdapi.OpSkuParam{
 			TraceID:     ctx.GetTrackInfo(),