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:32:01 +08:00
parent fb342d813b
commit b4141f448e
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

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