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 a5f13d9..46f3317 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 @@ -46,7 +46,7 @@ public class JdbcUtil { private static BlockingQueue bq = new LinkedBlockingQueue(); - private static ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(10, 15, 1, TimeUnit.HOURS, new LinkedBlockingQueue()); + private static ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(15, 20, 1, TimeUnit.HOURS, new LinkedBlockingQueue()); private static class Chanle extends Thread { private MongoTemplate mongoTemplate; @@ -742,6 +742,7 @@ public class JdbcUtil { private static void syncChuZhen(String pid, String parentId, MongoTemplate mongoTemplate) { // List> list = getListDataBySql(" SELECT * FROM MOMMY_FIRSTEXAMINE f where replace(f.FE_TRIAGEORDERNO,'-','') = '" + parentId + "'"); + long startTimes = System.currentTimeMillis(); List> list = getListDataBySql(" SELECT F.*,\n" + " '[\"'||REPLACE(TT.HIGH_RISK_ID,',','\",\"')||'\"]' AS RISKFACTOR,\n" + " TT.HIGH_RISK_VALUE AS RISKSCORE\n" + @@ -767,12 +768,14 @@ public class JdbcUtil { " GROUP BY T.ME_EXAMINID \n" + " )TT ON F.FE_ID=TT.ME_EXAMINID\n" + "where replace(f.FE_TRIAGEORDERNO,'-','') = '" + parentId + "'\n"); + long endTimes = System.currentTimeMillis(); + System.out.println("fuzhenTimes===========" + (endTimes-startTimes)); for (Map map : list) { AntExChuModel chuModel = new AntExChuModel(); chuModel.setParentId(parentId); chuModel.setPid(pid); - chuModel.setId(getString(map.get("FE_ID"))); + chuModel.setId(getString(map.get("FE_ID")).replace("-","")); chuModel.setDueDate(getDate(map.get("FE_EXPECTEDDATECONFINEMENT"))); chuModel.setLastMenses(getDate(map.get("FE_LASTMENSTRUALPERIOD"))); @@ -991,14 +994,15 @@ public class JdbcUtil { " GROUP BY T.ME_EXAMINID \n" + " )TT ON A.ER_ID=TT.ME_EXAMINID where replace(p_no,'-','') = '" + parentId + "' ORDER BY B.P_NO,A.ER_CHECKDATE ASC ) A WHERE ROWNUM <= 10 ) WHERE RN >= 0 "; - + long startTimes = System.currentTimeMillis(); List> list = getListDataBySql(sql); - + long endTimes = System.currentTimeMillis(); + System.out.println("chzhenTimes==========="+(endTimes-startTimes)); for (Map map : list) { AntenatalExaminationModel antxModel = new AntenatalExaminationModel(); antxModel.setPid(pid); antxModel.setParentId(parentId); - antxModel.setId(getString(map.get("ID"))); + antxModel.setId(getString(map.get("ID")).replace("-","")); antxModel.setCurrentDueDate(getString(map.get("CURRENTDUEDATE"))); antxModel.setWeight(getDouble(map.get("WEIGHT")));