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-17 14:31:03 +08:00
parent c4e876ea2f
commit ada4d6e023
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
business/jxstore/report/report.go
View File

@@ -444,7 +444,7 @@ func RefreshStoreManageState(ctx *jxcontext.Context) {
dao.DeleteEntity(db, storeManage, "StoreID", "VendorID") dao.DeleteEntity(db, storeManage, "StoreID", "VendorID")
return retVal, err return retVal, err
}, deleteList) }, deleteList)
tasksch.HandleTask(task3, task, true).Run() tasksch.HandleTask(task3, nil, true).Run()
task3.GetResult(0) task3.GetResult(0)
case 1: case 1:
task3 := tasksch.NewParallelTask("createList", tasksch.NewParallelConfig().SetParallelCount(50).SetIsContinueWhenError(true), ctx, task3 := tasksch.NewParallelTask("createList", tasksch.NewParallelConfig().SetParallelCount(50).SetIsContinueWhenError(true), ctx,
@@ -458,7 +458,7 @@ func RefreshStoreManageState(ctx *jxcontext.Context) {
dao.UpdateEntity(db, storeManage) dao.UpdateEntity(db, storeManage)
return retVal, err return retVal, err
}, createList) }, createList)
tasksch.HandleTask(task3, task, true).Run() tasksch.HandleTask(task3, nil, true).Run()
task3.GetResult(0) task3.GetResult(0)
case 2: case 2:
task3 := tasksch.NewParallelTask("updateList", tasksch.NewParallelConfig().SetParallelCount(50).SetIsContinueWhenError(true), ctx, task3 := tasksch.NewParallelTask("updateList", tasksch.NewParallelConfig().SetParallelCount(50).SetIsContinueWhenError(true), ctx,
@@ -472,12 +472,12 @@ func RefreshStoreManageState(ctx *jxcontext.Context) {
dao.CreateEntity(db, storeManage) dao.CreateEntity(db, storeManage)
return retVal, err return retVal, err
}, updateList) }, updateList)
tasksch.HandleTask(task3, task, true).Run() tasksch.HandleTask(task3, nil, true).Run()
task3.GetResult(0) task3.GetResult(0)
} }
return retVal, err return retVal, err
}, []int{0, 1, 2}) }, []int{0, 1, 2})
tasksch.HandleTask(task2, task, true).Run() tasksch.HandleTask(task2, nil, true).Run()
task2.GetResult(0) task2.GetResult(0)
return retVal, err return retVal, err
}, vendorIDs) }, vendorIDs)