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 fae528c..45645ff 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 @@ -366,9 +366,12 @@ public class JdbcUtil { public static void syncPatientData(String hospitalId,MongoTemplate mongoTemplate,int start,int end) { - String sql = " 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 + "' order by mp.p_lastmenstrualperiod desc ) A WHERE ROWNUM <= "+end+" ) WHERE RN >= "+start; +// String sql = " 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 + "' order by mp.p_lastmenstrualperiod desc ) A WHERE ROWNUM <= "+end+" ) WHERE RN >= "+start; + + String sql = "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 + "' order by mp.p_lastmenstrualperiod desc " ; List> list = getListDataBySql(sql); System.out.println(list.size()+"---------------------------------"); System.out.println(sql); @@ -707,6 +710,7 @@ public class JdbcUtil { patients.setFileCode(getString(map.get("P_CLINICNO"))); //就诊卡号 mongoTemplate.save(patients); + System.out.println(patients.getId()+"============"); syncChuZhen(person.getId(), patients.getId(), mongoTemplate); syncFuzhen(person.getId(), patients.getId(), mongoTemplate); } 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 557ffea..3fd82d1 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 @@ -118,22 +118,22 @@ public class TestController { System.out.println("同步结束孕妇1>>>>>>>>>>>>>>>>>>>>>>>>>"); } }).start(); - new Thread(new Runnable() { - @Override - public void run() { - System.out.println("同步开始孕妇2>>>>>>>>>>>>>>>>>>>>>>>>>"); - JdbcUtil.syncDataPat2(hid, template); - System.out.println("同步结束孕妇2>>>>>>>>>>>>>>>>>>>>>>>>>"); - } - }).start(); - new Thread(new Runnable() { - @Override - public void run() { - System.out.println("同步开始孕妇3>>>>>>>>>>>>>>>>>>>>>>>>>"); - JdbcUtil.syncDataPat3(hid, template); - System.out.println("同步结束孕妇3>>>>>>>>>>>>>>>>>>>>>>>>>"); - } - }).start(); +// new Thread(new Runnable() { +// @Override +// public void run() { +// System.out.println("同步开始孕妇2>>>>>>>>>>>>>>>>>>>>>>>>>"); +// JdbcUtil.syncDataPat2(hid, template); +// System.out.println("同步结束孕妇2>>>>>>>>>>>>>>>>>>>>>>>>>"); +// } +// }).start(); +// new Thread(new Runnable() { +// @Override +// public void run() { +// System.out.println("同步开始孕妇3>>>>>>>>>>>>>>>>>>>>>>>>>"); +// JdbcUtil.syncDataPat3(hid, template); +// System.out.println("同步结束孕妇3>>>>>>>>>>>>>>>>>>>>>>>>>"); +// } +// }).start(); return "starting..........."; } }