From cd1fbba20aec4274b5abe6612d3704dde1374877 Mon Sep 17 00:00:00 2001
From: yangfei <yangfei@lymsh.com>
Date: Wed, 29 Nov 2017 00:14:01 +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

---
 .../java/com/lyms/platform/operate/web/controller/TestController.java | 3 ++-
 .../lyms/platform/operate/web/worker/BuildSerToPatientSerWorker.java  | 4 ++--
 2 files changed, 4 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 e9e07ee..8984789 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
@@ -155,7 +155,7 @@ public class TestController {
         System.out.println("一共需要处理数据量："+patientCount);
 
         //预计开启10个线程处理，计算每个线程需要处理的数据量
-        int batchSize = patientCount/10;
+        int batchSize = patientCount/5;
         int end = 0;
         List<Future> listFuture = new ArrayList<>();
         for (int i = 0; i < patientCount; i += batchSize) {
@@ -163,6 +163,7 @@ public class TestController {
             if (end > patientCount) {
                 end = patientCount+1;
             }
+            System.out.println("线程处理数据量："+i+"--至--"+end);
              listFuture.add(commonThreadPool.submit(new BuildSerToPatientSerWorker(i, end,patientsService,patientServiceService,isSkip,isZjzx,batchSize,patientCount)));
         }
 
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 614fe86..e341180 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
@@ -39,8 +39,8 @@ public class BuildSerToPatientSerWorker implements Callable {
         this.patientServiceService = patientServiceService;
         this.isSkip = isSkip;
         this.isZjzx = isZjzx;
-        if (batchSize >= 100) {
-            this.batchSize = 100;
+        if (batchSize >= 1000) {
+            this.batchSize = 1000;
         } else {
             this.batchSize = batchSize;
         }
-- 
1.8.3.1