liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

aa

Browse Source
This commit is contained in:
苏尹岚
2021-03-01 15:51:44 +08:00
parent b4141f448e
commit c55e09e208
1 changed files with 5 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
business/jxstore/tempop/tempop.go
View File

@@ -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