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 46f3317..4c56493 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 @@ -43,10 +43,12 @@ public class JdbcUtil { private static Map datacontents = new HashMap<>(); private static Map basicConfigs = new HashMap<>(); + private static Integer orgId = 0; + private static BlockingQueue bq = new LinkedBlockingQueue(); - private static ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(15, 20, 1, TimeUnit.HOURS, new LinkedBlockingQueue()); + private static ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(10, 15, 1, TimeUnit.HOURS, new LinkedBlockingQueue()); private static class Chanle extends Thread { private MongoTemplate mongoTemplate; @@ -114,7 +116,8 @@ public class JdbcUtil { } } - public static void initData() { + public static void initData(Integer mysqlHid) { + orgId = mysqlHid; List> listEmp = getListDataBySql("select e.e_name,e.e_id from mommy_employee e"); for (Map map : listEmp) { employees.put(getString(map.get("E_ID")), getString(map.get("E_NAME"))); @@ -137,7 +140,7 @@ public class JdbcUtil { System.out.println("oracleHosps------" + oracleHosps.size()); - List> usersList = getMysqlListDataBySql("select id,name from users where org_id = 216 "); + List> usersList = getMysqlListDataBySql("select id,name from users where org_id = "+mysqlHid); for (Map map : usersList) { System.out.println(map); users.put(getString(map.get("name")), getString(map.get("id"))); @@ -176,7 +179,7 @@ public class JdbcUtil { public static String getOrgIdByName(String name) { - return "216"; + return String.valueOf(orgId); } public static String getEmpNameById(String id) { @@ -986,7 +989,7 @@ public class JdbcUtil { " INNER JOIN PLAT_DATACONTENT K ON J.ME_WORNINGID = K.DC_ID AND K.DC_ISVALID=1 AND K.DC_DATATYPEID='fb43fd5a-b153-4cb9-9180-c46f5612ba43' AND K.DC_NAME<>'其他' \n" + " --高危等级\n" + " INNER JOIN PLAT_DATACONTENT L ON K.DC_PARENTID=L.DC_ID AND L.DC_ISVALID=1\n" + - " INNER JOIN LYMS_BASICCONFIG LL ON K.DC_NAME=LL.NAME\n" + + " INNER JOIN LYMS_BASICCONFIG LL ON K.DC_NAME=LL.NAME AND LL.PARENTID IN ('49a36aea-c5b6-4162-87d2-9eb3c6ec00c2','eb146c03-b19f-4e28-b85f-fda574b2283b','315107bd-91fe-42a1-9237-752f3c046a40','e637b361-99cf-41eb-84f2-f0dab596e928','224b2329-cb82-4da3-a071-8527f8283aab') \n" + " -- UNION ALL \n" + " --其他高危评分\n" + " --SELECT M.ID,M.MO_CONTENT,M.MO_COLORNAME,M.MO_VALUES FROM MOMMY_OTHERWORNING M\n" + @@ -1119,12 +1122,12 @@ public class JdbcUtil { while (true) { List> list = getListDataBySql(" SELECT * FROM ( SELECT A.*, ROWNUM RN FROM " + " (select replace(m.PI_ID,'-','') as ID,m.* from MOMMY_PATIENTINFO m where m.pi_bookbuildinghospitalid='" + hospitalId + "') " + - " A WHERE ROWNUM < " + (num + 20) + " ) WHERE RN >= " + num + " "); + " A WHERE ROWNUM < " + (num + 50) + " ) WHERE RN >= " + num + " "); if (list == null || list.size() == 0) { break; } - num = num + 20; + num = num + 50; for (Map map : list) { try { PersonModel personModel = new PersonModel(); 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 228c77a..6bd5111 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 @@ -97,7 +97,7 @@ public class TestController { @RequestMapping(value = "/syncData", method = RequestMethod.GET) @ResponseBody - public String syncData(@RequestParam(required = true) final String hid) { + public String syncData(@RequestParam(required = true) final String oracleHid,@RequestParam(required = true) final Integer mysqlHid) { final MongoTemplate template = mongoTemplate; // new Thread(new Runnable() { // @Override @@ -107,11 +107,11 @@ public class TestController { // System.out.print("同步结束儿童>>>>>>>>>>>>>>>>>>>>>>>>>"); // } // }).start(); - JdbcUtil.initData(); + JdbcUtil.initData(mysqlHid); System.out.println("initData------"); System.out.println("同步开始孕妇1>>>>>>>>>>>>>>>>>>>>>>>>>"); - JdbcUtil.syncDataPat(hid, template); + JdbcUtil.syncDataPat(oracleHid, template); System.out.println("同步结束孕妇1>>>>>>>>>>>>>>>>>>>>>>>>>");