From 508b247535200df49fea203a2d9d5213be129533 Mon Sep 17 00:00:00 2001 From: yangfei Date: Wed, 29 Nov 2017 04:08:46 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9C=8D=E5=8A=A1=E5=90=8C=E6=AD=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/lyms/platform/operate/web/controller/TestController.java | 2 +- .../platform/operate/web/worker/BuildSerToPatientSerWorker.java | 9 +++++++-- 2 files changed, 8 insertions(+), 3 deletions(-) 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); -- 1.8.3.1