diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go
index cf3d40476..b14e969e8 100644
--- a/business/jxstore/tempop/tempop.go
+++ b/business/jxstore/tempop/tempop.go
@@ -1877,8 +1877,8 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
 		utils.DefaultTimeValue, "2", model.VendorIDJDShop,
 	}
 	dao.GetRows(db, &storeMaps, sql, sqlParams)
-	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) {
+	task := tasksch.NewParallelTask("uuuuu", tasksch.NewParallelConfig().SetParallelCount(5).SetIsContinueWhenError(true), ctx,
+		func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
 			v := batchItemList[0].(*model.StoreMap)
 			err = api.JdShop2API.CreateGisFence(utils.Str2Int(v.VendorStoreID), "2")
 			if err != nil {
@@ -1895,13 +1895,14 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
 					}
 				}
 			}
-			return retVal, successCount, err
+			return retVal, err
 		}, storeMaps)
-	tasksch.HandleTask(task, nil, false).Run()
+	tasksch.HandleTask(task, nil, true).Run()
 	result, err := task.GetResult(0)
 	for _, v := range result {
 		stores = append(stores, v.(int))
 	}
+	fmt.Println("resultstores55", stores)
 	return err
 }