Commit aa7dbe38a842586eaf822934bf73aef3e1168982

Authored by liquanyu
1 parent e5a6075a34

code update

Showing 1 changed file with 9 additions and 5 deletions

platform-biz-patient-service/src/main/java/com/lyms/platform/biz/JdbcUtil.java View file @ aa7dbe3
... ... @@ -46,7 +46,7 @@
46 46  
47 47 private static BlockingQueue<SimplePatient> bq = new LinkedBlockingQueue();
48 48  
49   - private static ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(10, 15, 1, TimeUnit.HOURS, new LinkedBlockingQueue<Runnable>());
  49 + private static ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(15, 20, 1, TimeUnit.HOURS, new LinkedBlockingQueue<Runnable>());
50 50  
51 51 private static class Chanle extends Thread {
52 52 private MongoTemplate mongoTemplate;
... ... @@ -742,6 +742,7 @@
742 742  
743 743 private static void syncChuZhen(String pid, String parentId, MongoTemplate mongoTemplate) {
744 744 // List<Map<String,Object>> list = getListDataBySql(" SELECT * FROM MOMMY_FIRSTEXAMINE f where replace(f.FE_TRIAGEORDERNO,'-','') = '" + parentId + "'");
  745 + long startTimes = System.currentTimeMillis();
745 746 List<Map<String, Object>> list = getListDataBySql(" SELECT F.*,\n" +
746 747 " '[\"'||REPLACE(TT.HIGH_RISK_ID,',','\",\"')||'\"]' AS RISKFACTOR,\n" +
747 748 " TT.HIGH_RISK_VALUE AS RISKSCORE\n" +
748 749  
... ... @@ -767,12 +768,14 @@
767 768 " GROUP BY T.ME_EXAMINID \n" +
768 769 " )TT ON F.FE_ID=TT.ME_EXAMINID\n" +
769 770 "where replace(f.FE_TRIAGEORDERNO,'-','') = '" + parentId + "'\n");
  771 + long endTimes = System.currentTimeMillis();
  772 + System.out.println("fuzhenTimes===========" + (endTimes-startTimes));
770 773 for (Map<String, Object> map : list) {
771 774 AntExChuModel chuModel = new AntExChuModel();
772 775  
773 776 chuModel.setParentId(parentId);
774 777 chuModel.setPid(pid);
775   - chuModel.setId(getString(map.get("FE_ID")));
  778 + chuModel.setId(getString(map.get("FE_ID")).replace("-",""));
776 779  
777 780 chuModel.setDueDate(getDate(map.get("FE_EXPECTEDDATECONFINEMENT")));
778 781 chuModel.setLastMenses(getDate(map.get("FE_LASTMENSTRUALPERIOD")));
779 782  
780 783  
... ... @@ -991,14 +994,15 @@
991 994 " GROUP BY T.ME_EXAMINID \n" +
992 995 " )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 ";
993 996  
994   -
  997 + long startTimes = System.currentTimeMillis();
995 998 List<Map<String, Object>> list = getListDataBySql(sql);
996   -
  999 + long endTimes = System.currentTimeMillis();
  1000 + System.out.println("chzhenTimes==========="+(endTimes-startTimes));
997 1001 for (Map<String, Object> map : list) {
998 1002 AntenatalExaminationModel antxModel = new AntenatalExaminationModel();
999 1003 antxModel.setPid(pid);
1000 1004 antxModel.setParentId(parentId);
1001   - antxModel.setId(getString(map.get("ID")));
  1005 + antxModel.setId(getString(map.get("ID")).replace("-",""));
1002 1006  
1003 1007 antxModel.setCurrentDueDate(getString(map.get("CURRENTDUEDATE")));
1004 1008 antxModel.setWeight(getDouble(map.get("WEIGHT")));