diff --git a/business/jxstore/cms/store.go b/business/jxstore/cms/store.go index 42c599e92..4ffe0244c 100644 --- a/business/jxstore/cms/store.go +++ b/business/jxstore/cms/store.go @@ -721,7 +721,7 @@ func RefreshMissingDadaStores(ctx *jxcontext.Context, isAsync, isContinueWhenErr if err != nil { 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) _, err = api.DadaAPI.ShopDetail(utils.Int2Str(storeDetail.ID)) if err != nil { @@ -742,6 +742,7 @@ func RefreshMissingDadaStores(ctx *jxcontext.Context, isAsync, isContinueWhenErr }, storeList) ctx.SetTaskOrAddChild(task, nil) tasksch.ManageTask(task).Run() + hint = task.ID if !isAsync { _, err = task.GetResult(0) }