diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go index b14e969e8..bf291f42a 100644 --- a/business/jxstore/tempop/tempop.go +++ b/business/jxstore/tempop/tempop.go @@ -1877,30 +1877,11 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) { utils.DefaultTimeValue, "2", model.VendorIDJDShop, } dao.GetRows(db, &storeMaps, sql, sqlParams) - 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 { - 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, err - }, storeMaps) - tasksch.HandleTask(task, nil, true).Run() - result, err := task.GetResult(0) - for _, v := range result { - stores = append(stores, v.(int)) + for _, v := range storeMaps { + err = api.JdShop2API.CreateGisFence(utils.Str2Int(v.VendorStoreID), "1") + if err != nil { + stores = append(stores, v.StoreID) + } } fmt.Println("resultstores55", stores) return err