- EnableHaveRestStores中正确处理isContinueWhenError

2019-06-10 08:47:58 +08:00
parent 4458a1e392
commit 7008be540a
1 changed files with 1 additions and 1 deletions
--- a/business/jxstore/cms/store.go
+++ b/business/jxstore/cms/store.go
@@ -533,7 +533,7 @@ func EnableHaveRestStores(ctx *jxcontext.Context, isAsync, isContinueWhenError b
 		return "0", nil
 	}

-	task := tasksch.NewParallelTask("EnableHaveRestStores", nil, ctx,
+	task := tasksch.NewParallelTask("EnableHaveRestStores", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx,
 		func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
 			store := batchItemList[0].(*StoreExt)
 			err = SetStoreStatus(ctx, store.ID, model.StoreStatusOpened)