From e6b8b1eeaaae4593133c7693d33e7ee31d2e7f09 Mon Sep 17 00:00:00 2001 From: liquanyu Date: Wed, 12 Oct 2016 18:04:16 +0800 Subject: [PATCH] code update --- .../main/java/com/lyms/platform/biz/JdbcUtil.java | 20 ++++++-------------- .../operate/web/controller/TestController.java | 16 ++++++++-------- 2 files changed, 14 insertions(+), 22 deletions(-) diff --git a/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/JdbcUtil.java b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/JdbcUtil.java index a90b0ec..a477210 100644 --- a/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/JdbcUtil.java +++ b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/JdbcUtil.java @@ -367,19 +367,13 @@ public class JdbcUtil { { int num = start; - - while (true) { List> list = getListDataBySql(" SELECT * FROM ( SELECT A.*, ROWNUM RN FROM " + "(select replace(mp.P_NO,'-','') as PID,mp.*,p_birthday,p_name,floor((trunc(sysdate) - trunc(mp.P_LASTMENSTRUALPERIOD)+1) /7) as weeks from MOMMY_PATIENT mp left join Plat_Patient pp" + - " on mp.p_platpatientid=pp.p_id where mp.p_hospitalid = '" + hospitalId + "' and rownum < "+total+" order by mp.p_lastmenstrualperiod desc ) A WHERE ROWNUM < "+(num+100)+" ) WHERE RN >= "+num+" "); - if (list == null || list.size() == 0) - { - break; - } - num=num+100; + " on mp.p_platpatientid=pp.p_id where mp.p_hospitalid = '" + hospitalId + "' order by mp.p_lastmenstrualperiod desc ) A WHERE ROWNUM < "+total+" ) WHERE RN >= "+num+" "); + System.out.println(list.size()+"---------------------------------"); for (Map map : list) { try { - System.out.println(num+"---------------------------------"); + Patients patients = new Patients(); PersonModel person = new PersonModel(); int type = 1; @@ -720,8 +714,6 @@ public class JdbcUtil { continue; } } - - } } private static void syncChuZhen(String pid,String parentId, MongoTemplate mongoTemplate) @@ -1645,7 +1637,7 @@ public class JdbcUtil { public static void syncDataPat1(String hid,MongoTemplate mongoTemplate) { try { - syncPatientData(hid, mongoTemplate,1,5000); + syncPatientData(hid, mongoTemplate,1,3000); } catch (Exception e) { @@ -1656,7 +1648,7 @@ public class JdbcUtil { public static void syncDataPat2(String hid,MongoTemplate mongoTemplate) { try { - syncPatientData(hid,mongoTemplate,50001,100000); + syncPatientData(hid,mongoTemplate,30001,8000); } catch (Exception e) { @@ -1667,7 +1659,7 @@ public class JdbcUtil { public static void syncDataPat3(String hid,MongoTemplate mongoTemplate) { try { - syncPatientData(hid,mongoTemplate,8001,100000000); + syncPatientData(hid,mongoTemplate,8001,100000); } catch (Exception e) { 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 b93444b..9ba65f1 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 @@ -126,14 +126,14 @@ public class TestController { System.out.print("同步结束孕妇2>>>>>>>>>>>>>>>>>>>>>>>>>"); } }).start(); -// new Thread(new Runnable() { -// @Override -// public void run() { -// System.out.print("同步开始孕妇3>>>>>>>>>>>>>>>>>>>>>>>>>"); -// JdbcUtil.syncDataPat3(hid, template); -// System.out.print("同步结束孕妇3>>>>>>>>>>>>>>>>>>>>>>>>>"); -// } -// }).start(); + new Thread(new Runnable() { + @Override + public void run() { + System.out.print("同步开始孕妇3>>>>>>>>>>>>>>>>>>>>>>>>>"); + JdbcUtil.syncDataPat3(hid, template); + System.out.print("同步结束孕妇3>>>>>>>>>>>>>>>>>>>>>>>>>"); + } + }).start(); return "starting..........."; } } -- 1.8.3.1