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-10 14:01:04 +08:00
parent 050cd4db15
commit 88ff46c0ee
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -434,7 +434,6 @@ func GetStoreManageState(ctx *jxcontext.Context, storeIDs []int, vendorID int, f
storeIDs = storeIDs2 storeIDs = storeIDs2
} }
} }
fmt.Println("storeIDs111111111111111111111111111", storeIDs)
task := tasksch.NewParallelTask("GetStoreManageState", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx, task := tasksch.NewParallelTask("GetStoreManageState", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
v := batchItemList[0].(int) v := batchItemList[0].(int)
@@ -514,7 +513,7 @@ func GetStoreManageState(ctx *jxcontext.Context, storeIDs []int, vendorID int, f
return retVal, err return retVal, err
}, storeIDs) }, storeIDs)
tasksch.HandleTask(task, nil, true).Run() tasksch.HandleTask(task, nil, true).Run()
result, err := task.GetResult(0) result, _ := task.GetResult(0)
for _, v := range result { for _, v := range result {
getStoreManageStateResult = append(getStoreManageStateResult, v.(*GetStoreManageStateResult)) getStoreManageStateResult = append(getStoreManageStateResult, v.(*GetStoreManageStateResult))
} }