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

- up

Browse Source
This commit is contained in:
gazebo
2019-01-23 14:06:33 +08:00
parent 148b64f659
commit 84d696fbe5
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
business/jxstore/cms/store.go
View File

@@ -721,7 +721,7 @@ func RefreshMissingDadaStores(ctx *jxcontext.Context, isAsync, isContinueWhenErr
if err != nil { if err != nil {
return "", err return "", err
} }
task := tasksch.NewParallelTask("RefreshMissingDadaStores", nil, ctx.GetUserName(), func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { task := tasksch.NewParallelTask("RefreshMissingDadaStores", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx.GetUserName(), func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
storeDetail := batchItemList[0].(*dao.StoreDetail2) storeDetail := batchItemList[0].(*dao.StoreDetail2)
_, err = api.DadaAPI.ShopDetail(utils.Int2Str(storeDetail.ID)) _, err = api.DadaAPI.ShopDetail(utils.Int2Str(storeDetail.ID))
if err != nil { if err != nil {
@@ -742,6 +742,7 @@ func RefreshMissingDadaStores(ctx *jxcontext.Context, isAsync, isContinueWhenErr
}, storeList) }, storeList)
ctx.SetTaskOrAddChild(task, nil) ctx.SetTaskOrAddChild(task, nil)
tasksch.ManageTask(task).Run() tasksch.ManageTask(task).Run()
hint = task.ID
if !isAsync { if !isAsync {
_, err = task.GetResult(0) _, err = task.GetResult(0)
} }