From a768a893ebff7a7a3c9b371778e94dbaa346b02a Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com>
Date: Mon, 8 Feb 2021 14:36:35 +0800
Subject: [PATCH] aa

---
 business/jxstore/tempop/tempop.go | 29 +++++++++++++++--------------
 1 file changed, 15 insertions(+), 14 deletions(-)

diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go
index 14aca52b1..a23a200a1 100644
--- a/business/jxstore/tempop/tempop.go
+++ b/business/jxstore/tempop/tempop.go
@@ -1852,21 +1852,22 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
 		}
 	}
 	// fmt.Println(utils.Format4Output(idLists, false))
-	task := tasksch.NewParallelTask("uuuuu", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
-		func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
-			storeMap := batchItemList[0].(*model.StoreMap)
-			for _, v := range idLists {
-				if v != nil {
-					err = api.JdAPI.DelVipPrice(utils.Int2Str(storeMap.StoreID), v, "suyl")
-					if strings.Contains(err.Error(), "没有会员价") {
-						err = nil
-					}
-				}
+	for _, v := range idLists {
+		if v != nil {
+			err = api.JdAPI.DelVipPrice(utils.Int2Str(storeMaps[0].StoreID), v, "suyl")
+			if strings.Contains(err.Error(), "没有会员价") {
+				err = nil
 			}
-			return retVal, err
-		}, storeMaps)
-	tasksch.HandleTask(task, nil, true).Run()
-	_, err = task.GetResult(0)
+		}
+	}
+	// task := tasksch.NewParallelTask("uuuuu", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
+	// 	func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
+	// 		storeMap := batchItemList[0].(*model.StoreMap)
+
+	// 		return retVal, err
+	// 	}, storeMaps)
+	// tasksch.HandleTask(task, nil, true).Run()
+	// _, err = task.GetResult(0)
 	return err
 }