From 468831b650a8a8b43d2e4ad85a3b89fa388ec5af Mon Sep 17 00:00:00 2001 From: liquanyu Date: Wed, 27 Sep 2017 16:18:36 +0800 Subject: [PATCH] update code --- .../java/com/lyms/platform/permission/service/LisService.java | 3 ++- .../com/lyms/platform/permission/service/impl/LisServiceImpl.java | 7 +------ .../com/lyms/platform/operate/web/controller/LisController.java | 8 +++++++- 3 files changed, 10 insertions(+), 8 deletions(-) diff --git a/platform-biz-service/src/main/java/com/lyms/platform/permission/service/LisService.java b/platform-biz-service/src/main/java/com/lyms/platform/permission/service/LisService.java index 9885b81..8e91748 100644 --- a/platform-biz-service/src/main/java/com/lyms/platform/permission/service/LisService.java +++ b/platform-biz-service/src/main/java/com/lyms/platform/permission/service/LisService.java @@ -5,12 +5,13 @@ import com.lyms.platform.common.result.BaseResponse; import com.lyms.platform.permission.model.LisReportItemModel; import com.lyms.platform.permission.model.LisReportModel; import com.lyms.platform.permission.model.LisReportQuery; +import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; import java.util.List; public interface LisService { - BaseResponse saveLisData(List models); + BaseResponse saveLisData(List models,ThreadPoolTaskExecutor commonThreadPool); List queryLisDataByModel(LisReportQuery model); diff --git a/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/LisServiceImpl.java b/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/LisServiceImpl.java index 0d8e8b4..5bb19b7 100644 --- a/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/LisServiceImpl.java +++ b/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/LisServiceImpl.java @@ -27,15 +27,10 @@ import java.util.concurrent.Future; public class LisServiceImpl implements LisService { @Autowired - @Qualifier("commonThreadPool") - private ThreadPoolTaskExecutor commonThreadPool; - - - @Autowired private MasterLisMapper masterLisMapper; @Override - public BaseResponse saveLisData(final List lisList) { + public BaseResponse saveLisData(final List lisList,ThreadPoolTaskExecutor commonThreadPool) { try { System.out.println("saveLis data size = "+ lisList.size()); if (CollectionUtils.isNotEmpty(lisList)) diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/LisController.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/LisController.java index 4eae5f1..4649458 100644 --- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/LisController.java +++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/LisController.java @@ -18,6 +18,8 @@ import org.apache.commons.collections.CollectionUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Qualifier; +import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.*; @@ -34,6 +36,10 @@ import java.util.Map; public class LisController extends BaseController { @Autowired + @Qualifier("commonThreadPool") + private ThreadPoolTaskExecutor commonThreadPool; + + @Autowired private LisService lisService; @Autowired private LisFacade lisFacade; @@ -94,7 +100,7 @@ public class LisController extends BaseController { } } } - return lisService.saveLisData(list); + return lisService.saveLisData(list,commonThreadPool); } -- 1.8.3.1