From bb24236869454656f797f75f2c4be2492516cdd6 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com>
Date: Wed, 17 Mar 2021 14:41:27 +0800
Subject: [PATCH] aa

---
 business/jxstore/report/report.go | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/business/jxstore/report/report.go b/business/jxstore/report/report.go
index 2828f8ae7..073b4c7a2 100644
--- a/business/jxstore/report/report.go
+++ b/business/jxstore/report/report.go
@@ -429,7 +429,7 @@ func RefreshStoreManageState(ctx *jxcontext.Context) {
 					createList = append(createList, v)
 				}
 			}
-			task2 := tasksch.NewParallelTask("deleteList", tasksch.NewParallelConfig().SetParallelCount(50).SetIsContinueWhenError(true), ctx,
+			task2 := tasksch.NewParallelTask("deleteList", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
 				func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
 					storeID := batchItemList[0].(int)
 					storeManage := &model.StoreManageState{
@@ -441,7 +441,7 @@ func RefreshStoreManageState(ctx *jxcontext.Context) {
 				}, deleteList)
 			tasksch.HandleTask(task2, task, true).Run()
 			task2.GetResult(0)
-			task3 := tasksch.NewParallelTask("createList", tasksch.NewParallelConfig().SetParallelCount(50).SetIsContinueWhenError(true), ctx,
+			task3 := tasksch.NewParallelTask("createList", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
 				func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
 					storeMap := batchItemList[0].(*model.StoreMap)
 					if storeMap.VendorOrgCode == "" || storeMap.VendorStoreID == "" {
@@ -454,7 +454,7 @@ func RefreshStoreManageState(ctx *jxcontext.Context) {
 				}, createList)
 			tasksch.HandleTask(task3, task, true).Run()
 			task3.GetResult(0)
-			task4 := tasksch.NewParallelTask("updateList", tasksch.NewParallelConfig().SetParallelCount(50).SetIsContinueWhenError(true), ctx,
+			task4 := tasksch.NewParallelTask("updateList", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
 				func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
 					storeMap := batchItemList[0].(*model.StoreMap)
 					if storeMap.VendorOrgCode == "" || storeMap.VendorStoreID == "" {