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:27:45 +08:00
parent 96dfa7ad5a
commit fb342d813b
1 changed files with 21 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1877,24 +1877,31 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
utils.DefaultTimeValue, "2", model.VendorIDJDShop, utils.DefaultTimeValue, "2", model.VendorIDJDShop,
} }
dao.GetRows(db, &storeMaps, sql, sqlParams) dao.GetRows(db, &storeMaps, sql, sqlParams)
for _, v := range storeMaps { task := tasksch.NewParallelTask2("yuuuuu", tasksch.NewParallelConfig().SetParallelCount(5).SetIsContinueWhenError(true), ctx,
err = api.JdShop2API.CreateGisFence(utils.Str2Int(v.VendorStoreID), "2") func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, successCount int, err error) {
if err != nil { v := batchItemList[0].(*model.StoreMap)
api.JdShop2API.CreateGisFence(utils.Str2Int(err.Error()), "2") err = api.JdShop2API.CreateGisFence(utils.Str2Int(v.VendorStoreID), "2")
err2 := api.JdShop2API.CreateGisFence(utils.Str2Int(v.VendorStoreID), "2") if err != nil {
if err2 != nil { api.JdShop2API.CreateGisFence(utils.Str2Int(err.Error()), "2")
api.JdShop2API.CreateGisFence(utils.Str2Int(err.Error()), "1") err2 := api.JdShop2API.CreateGisFence(utils.Str2Int(v.VendorStoreID), "2")
err3 := api.JdShop2API.CreateGisFence(utils.Str2Int(v.VendorStoreID), "2") if err2 != nil {
if err3 != nil { api.JdShop2API.CreateGisFence(utils.Str2Int(err2.Error()), "1")
err4 := api.JdShop2API.CreateGisFence(utils.Str2Int(v.VendorStoreID), "1") err3 := api.JdShop2API.CreateGisFence(utils.Str2Int(v.VendorStoreID), "2")
if err4 != nil { if err3 != nil {
stores = append(stores, v.StoreID) 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 return err
} }