From d5305df3e30ab17f91b63c38221d98b6260a2829 Mon Sep 17 00:00:00 2001 From: jiangjiazhi Date: Sun, 9 Oct 2016 17:33:02 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=96=B0=E7=94=B5=E5=AD=90?= =?UTF-8?q?=E7=97=85=E5=8E=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/lyms/platform/job/index/restore/data/SyncDataWork.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/platform-job-index/src/main/java/com/lyms/platform/job/index/restore/data/SyncDataWork.java b/platform-job-index/src/main/java/com/lyms/platform/job/index/restore/data/SyncDataWork.java index 772b6db..d37aae7 100644 --- a/platform-job-index/src/main/java/com/lyms/platform/job/index/restore/data/SyncDataWork.java +++ b/platform-job-index/src/main/java/com/lyms/platform/job/index/restore/data/SyncDataWork.java @@ -60,7 +60,7 @@ public class SyncDataWork { /** * 工作线程池 */ - private ThreadPoolExecutor workExecutor = new ThreadPoolExecutor(5, 10, 1, TimeUnit.HOURS, new LinkedBlockingQueue(5000)); + private ThreadPoolExecutor workExecutor = new ThreadPoolExecutor(8, 10, 1, TimeUnit.HOURS, new LinkedBlockingQueue(5000)); @Autowired private AntenatalExaminationService antenatalExaminationService; @@ -288,8 +288,6 @@ public class SyncDataWork { PatientsQuery patientsQuery1 = new PatientsQuery(); patientsQuery1.setYn(YnEnums.YES.getId()); patientsQuery1.setHospitalId(hospitalId); - patientsQuery1.setNeed("1"); - patientsQuery1.setLimit(500); if(-1!=lastSyncTime){ patientsQuery1.setGteModified(new Date(lastSyncTime)); } -- 1.8.3.1