Commit 91ed6833194091433c8066e3c605dbf3358770a2

Authored by liquanyu
1 parent 041df5004d

code update

Showing 2 changed files with 23 additions and 19 deletions

platform-biz-patient-service/src/main/java/com/lyms/platform/biz/JdbcUtil.java View file @ 91ed683
... ... @@ -366,9 +366,12 @@
366 366 public static void syncPatientData(String hospitalId,MongoTemplate mongoTemplate,int start,int end)
367 367 {
368 368  
369   - String sql = " SELECT * FROM ( SELECT A.*, ROWNUM RN FROM " +
370   - "(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" +
371   - " 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;
  369 +// String sql = " SELECT * FROM ( SELECT A.*, ROWNUM RN FROM " +
  370 +// "(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" +
  371 +// " 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;
  372 +
  373 + 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" +
  374 + " on mp.p_platpatientid=pp.p_id where mp.p_hospitalid = '" + hospitalId + "' order by mp.p_lastmenstrualperiod desc " ;
372 375 List<Map<String, Object>> list = getListDataBySql(sql);
373 376 System.out.println(list.size()+"---------------------------------");
374 377 System.out.println(sql);
... ... @@ -707,6 +710,7 @@
707 710 patients.setFileCode(getString(map.get("P_CLINICNO"))); //就诊卡号
708 711  
709 712 mongoTemplate.save(patients);
  713 + System.out.println(patients.getId()+"============");
710 714 syncChuZhen(person.getId(), patients.getId(), mongoTemplate);
711 715 syncFuzhen(person.getId(), patients.getId(), mongoTemplate);
712 716 } catch (Exception e)
platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/TestController.java View file @ 91ed683
... ... @@ -118,22 +118,22 @@
118 118 System.out.println("同步结束孕妇1>>>>>>>>>>>>>>>>>>>>>>>>>");
119 119 }
120 120 }).start();
121   - new Thread(new Runnable() {
122   - @Override
123   - public void run() {
124   - System.out.println("同步开始孕妇2>>>>>>>>>>>>>>>>>>>>>>>>>");
125   - JdbcUtil.syncDataPat2(hid, template);
126   - System.out.println("同步结束孕妇2>>>>>>>>>>>>>>>>>>>>>>>>>");
127   - }
128   - }).start();
129   - new Thread(new Runnable() {
130   - @Override
131   - public void run() {
132   - System.out.println("同步开始孕妇3>>>>>>>>>>>>>>>>>>>>>>>>>");
133   - JdbcUtil.syncDataPat3(hid, template);
134   - System.out.println("同步结束孕妇3>>>>>>>>>>>>>>>>>>>>>>>>>");
135   - }
136   - }).start();
  121 +// new Thread(new Runnable() {
  122 +// @Override
  123 +// public void run() {
  124 +// System.out.println("同步开始孕妇2>>>>>>>>>>>>>>>>>>>>>>>>>");
  125 +// JdbcUtil.syncDataPat2(hid, template);
  126 +// System.out.println("同步结束孕妇2>>>>>>>>>>>>>>>>>>>>>>>>>");
  127 +// }
  128 +// }).start();
  129 +// new Thread(new Runnable() {
  130 +// @Override
  131 +// public void run() {
  132 +// System.out.println("同步开始孕妇3>>>>>>>>>>>>>>>>>>>>>>>>>");
  133 +// JdbcUtil.syncDataPat3(hid, template);
  134 +// System.out.println("同步结束孕妇3>>>>>>>>>>>>>>>>>>>>>>>>>");
  135 +// }
  136 +// }).start();
137 137 return "starting...........";
138 138 }
139 139 }