diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/TestController.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/TestController.java index 8984789..4a4c6d3 100644 --- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/TestController.java +++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/TestController.java @@ -154,7 +154,7 @@ public class TestController { int patientCount = patientsService.queryPatientCount(patientsQuery); System.out.println("一共需要处理数据量:"+patientCount); - //预计开启10个线程处理,计算每个线程需要处理的数据量 + //预计开启5个线程处理,计算每个线程需要处理的数据量 int batchSize = patientCount/5; int end = 0; List listFuture = new ArrayList<>(); diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/worker/BuildSerToPatientSerWorker.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/worker/BuildSerToPatientSerWorker.java index 7d51469..8b28d46 100644 --- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/worker/BuildSerToPatientSerWorker.java +++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/worker/BuildSerToPatientSerWorker.java @@ -55,9 +55,14 @@ public class BuildSerToPatientSerWorker implements Callable { public Object call() { try { for (int i = startIndex; i < endIndex; i += batchSize) { - System.out.println("总数据量:"+allCount+",正在处理第:" + i+"--到--"+(i+batchSize)); PatientsQuery patientsQuery = new PatientsQuery(); - patientsQuery.setLimit(batchSize); + if(i+batchSize>endIndex){ + patientsQuery.setLimit(endIndex-i); + }else{ + patientsQuery.setLimit(batchSize); + } + System.out.println("总数据量:"+allCount+",正在处理第:" + i+"--到--"+(i+batchSize)+",limit:"+patientsQuery.getLimit()); + patientsQuery.setPage((i + batchSize) / batchSize); //排查本院隐藏建档 patientsQuery.setExtEnable(false);