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)); }