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 ac72f3e..fe1395e 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 @@ -37,10 +37,7 @@ public class JdbcUtil { private static List> datacontents = new ArrayList<>(); private static List> basicConfigs = new ArrayList<>(); - static - { - initData(); - } + public static void initData() { @@ -53,6 +50,8 @@ public class JdbcUtil { employees.add(emap); } + System.out.println("employees------"+employees.size()); + List> datacontentsList = getListDataBySql("select dc_name,dc_id from plat_datacontent "); for(Map map : datacontentsList) @@ -62,6 +61,8 @@ public class JdbcUtil { data.put("name",getString(map.get("DC_NAME"))); datacontents.add(data); } + + System.out.println("datacontents------"+datacontents.size()); List> orcleHospsList = getListDataBySql("select h_name,h_id from plat_hospital h"); for(Map map : orcleHospsList) { @@ -71,6 +72,7 @@ public class JdbcUtil { oracleHosps.add(data); } + System.out.println("oracleHosps------"+oracleHosps.size()); List> usersList = getMysqlListDataBySql("select id,name from users"); for(Map map : usersList) @@ -80,7 +82,7 @@ public class JdbcUtil { data.put("name",getString(map.get("NAME"))); users.add(data); } - + System.out.println("users------"+users.size()); List> mysqlHospsList = getMysqlListDataBySql("select id,name from organization"); for(Map map : mysqlHospsList) @@ -90,7 +92,9 @@ public class JdbcUtil { data.put("name",getString(map.get("NAME"))); mysqlHosps.add(data); } - List> oracleBasicList = getListDataBySql("select id,name.parentId from lyms_basicconfig "); + + System.out.println("mysqlHosps------"+mysqlHosps.size()); + List> oracleBasicList = getListDataBySql("select id,name,parentId from lyms_basicconfig "); for(Map map : oracleBasicList) { Map data = new HashMap<>(); @@ -100,6 +104,8 @@ public class JdbcUtil { basicConfigs.add(data); } + System.out.println("basicConfigs------"+basicConfigs.size()); + } @@ -1631,36 +1637,36 @@ public class JdbcUtil { } - public void syncDataPat1(String hid,MongoTemplate mongoTemplate) + public static void syncDataPat1(String hid,MongoTemplate mongoTemplate) { try { syncPatientData(hid, mongoTemplate,1,3000); } catch (Exception e) { - ExceptionUtils.catchException(e,"孕妇同步出错。。。。。。。。。。。。。。"); + ExceptionUtils.catchException(e,"孕妇同步出错1。。。。。。。。。。。。。。"); } } - public void syncDataPat2(String hid,MongoTemplate mongoTemplate) + public static void syncDataPat2(String hid,MongoTemplate mongoTemplate) { try { syncPatientData(hid,mongoTemplate,30001,8000); } catch (Exception e) { - ExceptionUtils.catchException(e,"孕妇同步出错。。。。。。。。。。。。。。"); + ExceptionUtils.catchException(e,"孕妇同步出错2。。。。。。。。。。。。。。"); } } - public void syncDataPat3(String hid,MongoTemplate mongoTemplate) + public static void syncDataPat3(String hid,MongoTemplate mongoTemplate) { try { syncPatientData(hid,mongoTemplate,8001,100000000); } catch (Exception e) { - ExceptionUtils.catchException(e,"孕妇同步出错。。。。。。。。。。。。。。"); + ExceptionUtils.catchException(e,"孕妇同步出错3。。。。。。。。。。。。。。"); } } 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 08ba50a..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 @@ -1,6 +1,6 @@ package com.lyms.platform.operate.web.controller; -import com.lyms.platform.operate.web.utils.JdbcUtil; +import com.lyms.platform.biz.JdbcUtil; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.mongodb.core.MongoTemplate; import org.springframework.stereotype.Controller; @@ -107,12 +107,14 @@ public class TestController { // System.out.print("同步结束儿童>>>>>>>>>>>>>>>>>>>>>>>>>"); // } // }).start(); + JdbcUtil.initData(); + System.out.println("initData------"); new Thread(new Runnable() { @Override public void run() { System.out.print("同步开始孕妇1>>>>>>>>>>>>>>>>>>>>>>>>>"); - new com.lyms.platform.biz.JdbcUtil().syncDataPat1(hid, template); + JdbcUtil.syncDataPat1(hid, template); System.out.print("同步结束孕妇1>>>>>>>>>>>>>>>>>>>>>>>>>"); } }).start(); @@ -120,7 +122,7 @@ public class TestController { @Override public void run() { System.out.print("同步开始孕妇2>>>>>>>>>>>>>>>>>>>>>>>>>"); - new com.lyms.platform.biz.JdbcUtil().syncDataPat2(hid, template); + JdbcUtil.syncDataPat2(hid, template); System.out.print("同步结束孕妇2>>>>>>>>>>>>>>>>>>>>>>>>>"); } }).start(); @@ -128,7 +130,7 @@ public class TestController { @Override public void run() { System.out.print("同步开始孕妇3>>>>>>>>>>>>>>>>>>>>>>>>>"); - new com.lyms.platform.biz.JdbcUtil().syncDataPat3(hid, template); + JdbcUtil.syncDataPat3(hid, template); System.out.print("同步结束孕妇3>>>>>>>>>>>>>>>>>>>>>>>>>"); } }).start();