From 84d696fbe55c382e5fa463616005a9d202056fca Mon Sep 17 00:00:00 2001 From: gazebo Date: Wed, 23 Jan 2019 14:06:33 +0800 Subject: [PATCH] - up --- business/jxstore/cms/store.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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) }