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 fe1395e..fe7f435 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 @@ -379,6 +379,7 @@ public class JdbcUtil { num=num+20; for (Map map : list) { try { + System.out.println(num+"---------------------------------"); Patients patients = new Patients(); PersonModel person = new PersonModel(); int type = 1; @@ -387,7 +388,7 @@ public class JdbcUtil { if (StringUtils.isNotEmpty(getString(map.get("P_ID")))) { chanList = getListDataBySql("select * from MOMMY_PREGDELIVERYRECORD p where p.pdr_patientid = '" + getString(map.get("p_id")) + "' order by p.PDR_CHILDBIRTHDAY desc "); } - if (weeks >= 42 || CollectionUtils.isNotEmpty(chanList)) { + if (weeks != null && weeks >= 42 || CollectionUtils.isNotEmpty(chanList)) { Date fmDate = null; if (CollectionUtils.isNotEmpty(chanList)) { fmDate = getDate(chanList.get(0).get("PDR_CHILDBIRTHDAY")); @@ -1640,7 +1641,7 @@ public class JdbcUtil { public static void syncDataPat1(String hid,MongoTemplate mongoTemplate) { try { - syncPatientData(hid, mongoTemplate,1,3000); + syncPatientData(hid, mongoTemplate,1,30000); } 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 9ba65f1..81ebced 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.print("同步结束孕妇1>>>>>>>>>>>>>>>>>>>>>>>>>"); } }).start(); - new Thread(new Runnable() { - @Override - public void run() { - System.out.print("同步开始孕妇2>>>>>>>>>>>>>>>>>>>>>>>>>"); - JdbcUtil.syncDataPat2(hid, template); - 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("同步开始孕妇2>>>>>>>>>>>>>>>>>>>>>>>>>"); +// JdbcUtil.syncDataPat2(hid, template); +// 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(); return "starting..........."; } }