Commit 91c67a50fb287d663d3b2bd26cfde42de2ff6059
1 parent
1fd155a076
Exists in
master
and in
8 other branches
code update
Showing 2 changed files with 19 additions and 18 deletions
platform-biz-patient-service/src/main/java/com/lyms/platform/biz/JdbcUtil.java
View file @
91c67a5
| ... | ... | @@ -379,6 +379,7 @@ |
| 379 | 379 | num=num+20; |
| 380 | 380 | for (Map<String, Object> map : list) { |
| 381 | 381 | try { |
| 382 | + System.out.println(num+"---------------------------------"); | |
| 382 | 383 | Patients patients = new Patients(); |
| 383 | 384 | PersonModel person = new PersonModel(); |
| 384 | 385 | int type = 1; |
| ... | ... | @@ -387,7 +388,7 @@ |
| 387 | 388 | if (StringUtils.isNotEmpty(getString(map.get("P_ID")))) { |
| 388 | 389 | chanList = getListDataBySql("select * from MOMMY_PREGDELIVERYRECORD p where p.pdr_patientid = '" + getString(map.get("p_id")) + "' order by p.PDR_CHILDBIRTHDAY desc "); |
| 389 | 390 | } |
| 390 | - if (weeks >= 42 || CollectionUtils.isNotEmpty(chanList)) { | |
| 391 | + if (weeks != null && weeks >= 42 || CollectionUtils.isNotEmpty(chanList)) { | |
| 391 | 392 | Date fmDate = null; |
| 392 | 393 | if (CollectionUtils.isNotEmpty(chanList)) { |
| 393 | 394 | fmDate = getDate(chanList.get(0).get("PDR_CHILDBIRTHDAY")); |
| ... | ... | @@ -1640,7 +1641,7 @@ |
| 1640 | 1641 | public static void syncDataPat1(String hid,MongoTemplate mongoTemplate) |
| 1641 | 1642 | { |
| 1642 | 1643 | try { |
| 1643 | - syncPatientData(hid, mongoTemplate,1,3000); | |
| 1644 | + syncPatientData(hid, mongoTemplate,1,30000); | |
| 1644 | 1645 | } |
| 1645 | 1646 | catch (Exception e) |
| 1646 | 1647 | { |
platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/TestController.java
View file @
91c67a5
| ... | ... | @@ -118,22 +118,22 @@ |
| 118 | 118 | System.out.print("同步结束孕妇1>>>>>>>>>>>>>>>>>>>>>>>>>"); |
| 119 | 119 | } |
| 120 | 120 | }).start(); |
| 121 | - new Thread(new Runnable() { | |
| 122 | - @Override | |
| 123 | - public void run() { | |
| 124 | - System.out.print("同步开始孕妇2>>>>>>>>>>>>>>>>>>>>>>>>>"); | |
| 125 | - JdbcUtil.syncDataPat2(hid, template); | |
| 126 | - System.out.print("同步结束孕妇2>>>>>>>>>>>>>>>>>>>>>>>>>"); | |
| 127 | - } | |
| 128 | - }).start(); | |
| 129 | - new Thread(new Runnable() { | |
| 130 | - @Override | |
| 131 | - public void run() { | |
| 132 | - System.out.print("同步开始孕妇3>>>>>>>>>>>>>>>>>>>>>>>>>"); | |
| 133 | - JdbcUtil.syncDataPat3(hid, template); | |
| 134 | - System.out.print("同步结束孕妇3>>>>>>>>>>>>>>>>>>>>>>>>>"); | |
| 135 | - } | |
| 136 | - }).start(); | |
| 121 | +// new Thread(new Runnable() { | |
| 122 | +// @Override | |
| 123 | +// public void run() { | |
| 124 | +// System.out.print("同步开始孕妇2>>>>>>>>>>>>>>>>>>>>>>>>>"); | |
| 125 | +// JdbcUtil.syncDataPat2(hid, template); | |
| 126 | +// System.out.print("同步结束孕妇2>>>>>>>>>>>>>>>>>>>>>>>>>"); | |
| 127 | +// } | |
| 128 | +// }).start(); | |
| 129 | +// new Thread(new Runnable() { | |
| 130 | +// @Override | |
| 131 | +// public void run() { | |
| 132 | +// System.out.print("同步开始孕妇3>>>>>>>>>>>>>>>>>>>>>>>>>"); | |
| 133 | +// JdbcUtil.syncDataPat3(hid, template); | |
| 134 | +// System.out.print("同步结束孕妇3>>>>>>>>>>>>>>>>>>>>>>>>>"); | |
| 135 | +// } | |
| 136 | +// }).start(); | |
| 137 | 137 | return "starting..........."; |
| 138 | 138 | } |
| 139 | 139 | } |