From fb342d813b6967bbea3c9ba6c33a34497692ec17 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, 1 Mar 2021 15:27:45 +0800
Subject: [PATCH] aa

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

diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go
index b2f67dea0..cf3d40476 100644
--- a/business/jxstore/tempop/tempop.go
+++ b/business/jxstore/tempop/tempop.go
@@ -1877,24 +1877,31 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
 		utils.DefaultTimeValue, "2", model.VendorIDJDShop,
 	}
 	dao.GetRows(db, &storeMaps, sql, sqlParams)
-	for _, v := range storeMaps {
-		err = api.JdShop2API.CreateGisFence(utils.Str2Int(v.VendorStoreID), "2")
-		if err != nil {
-			api.JdShop2API.CreateGisFence(utils.Str2Int(err.Error()), "2")
-			err2 := api.JdShop2API.CreateGisFence(utils.Str2Int(v.VendorStoreID), "2")
-			if err2 != nil {
-				api.JdShop2API.CreateGisFence(utils.Str2Int(err.Error()), "1")
-				err3 := api.JdShop2API.CreateGisFence(utils.Str2Int(v.VendorStoreID), "2")
-				if err3 != nil {
-					err4 := api.JdShop2API.CreateGisFence(utils.Str2Int(v.VendorStoreID), "1")
-					if err4 != nil {
-						stores = append(stores, v.StoreID)
+	task := tasksch.NewParallelTask2("yuuuuu", tasksch.NewParallelConfig().SetParallelCount(5).SetIsContinueWhenError(true), ctx,
+		func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, successCount int, err error) {
+			v := batchItemList[0].(*model.StoreMap)
+			err = api.JdShop2API.CreateGisFence(utils.Str2Int(v.VendorStoreID), "2")
+			if err != nil {
+				api.JdShop2API.CreateGisFence(utils.Str2Int(err.Error()), "2")
+				err2 := api.JdShop2API.CreateGisFence(utils.Str2Int(v.VendorStoreID), "2")
+				if err2 != nil {
+					api.JdShop2API.CreateGisFence(utils.Str2Int(err2.Error()), "1")
+					err3 := api.JdShop2API.CreateGisFence(utils.Str2Int(v.VendorStoreID), "2")
+					if err3 != nil {
+						err4 := api.JdShop2API.CreateGisFence(utils.Str2Int(v.VendorStoreID), "1")
+						if err4 != nil {
+							retVal = []int{v.StoreID}
+						}
 					}
 				}
 			}
-		}
+			return retVal, successCount, err
+		}, storeMaps)
+	tasksch.HandleTask(task, nil, false).Run()
+	result, err := task.GetResult(0)
+	for _, v := range result {
+		stores = append(stores, v.(int))
 	}
-	fmt.Println("resultstore3", stores)
 	return err
 }