Commit 54783d3075815948324b751f9785b0bbd06dff25
1 parent
cbf30219bb
Exists in
master
and in
1 other branch
code update
Showing 1 changed file with 179 additions and 134 deletions
platform-job-index/src/main/java/com/lyms/platform/job/index/service/SyncDataService.java
View file @
54783d3
... | ... | @@ -32,6 +32,7 @@ |
32 | 32 | |
33 | 33 | private static BlockingQueue<SimplePatient> patientsQueue = new LinkedBlockingQueue(); |
34 | 34 | |
35 | + | |
35 | 36 | @Autowired |
36 | 37 | private MongoTemplate mongoTemplate; |
37 | 38 | |
38 | 39 | |
... | ... | @@ -348,7 +349,47 @@ |
348 | 349 | } |
349 | 350 | |
350 | 351 | |
352 | +// private void initChuzhenDatas() | |
353 | +// { | |
354 | +// | |
355 | +// long startTimes = System.currentTimeMillis(); | |
356 | +// List<Map<String, Object>> list = JDBCUtil.getOracleListDataBySql(" SELECT F.*,\n" + | |
357 | +// " '[\"'||REPLACE(TT.HIGH_RISK_ID,',','\",\"')||'\"]' AS RISKFACTOR,\n" + | |
358 | +// " TT.HIGH_RISK_VALUE AS RISKSCORE\n" + | |
359 | +// "FROM MOMMY_FIRSTEXAMINE f \n" + | |
360 | +// "--高危数据\n" + | |
361 | +// "LEFT JOIN \n" + | |
362 | +// " (\n" + | |
363 | +// " SELECT T.ME_EXAMINID,WMSYS.WM_CONCAT(T.HIGH_RISK_FACTOR) AS HIGH_RISK_FACTOR,WMSYS.WM_CONCAT(DISTINCT T.HIGH_RISK_GRADE) AS HIGH_RISK_GRADE,SUM(T.HIGH_RISK_VALUE) AS HIGH_RISK_VALUE,WMSYS.WM_CONCAT(T.HIGH_RISK_ID) AS HIGH_RISK_ID\n" + | |
364 | +// " FROM \n" + | |
365 | +// " (SELECT J.ME_EXAMINID,K.DC_NAME AS HIGH_RISK_FACTOR,L.DC_NAME AS HIGH_RISK_GRADE,TO_NUMBER(K.DC_NO) AS HIGH_RISK_VALUE,LL.ID AS HIGH_RISK_ID\n" + | |
366 | +// " FROM \n" + | |
367 | +// " --高危风险关系表\n" + | |
368 | +// " MOMMY_EXAMINWARNING J\n" + | |
369 | +// " --高危内容\n" + | |
370 | +// " 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" + | |
371 | +// " --高危等级\n" + | |
372 | +// " INNER JOIN PLAT_DATACONTENT L ON K.DC_PARENTID=L.DC_ID AND L.DC_ISVALID=1 \n" + | |
373 | +// " 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" + | |
374 | +// " -- UNION ALL \n" + | |
375 | +// " --其他高危评分\n" + | |
376 | +// " --SELECT M.ID,M.MO_CONTENT,M.MO_COLORNAME,M.MO_VALUES FROM MOMMY_OTHERWORNING M\n" + | |
377 | +// " )T\n" + | |
378 | +// " GROUP BY T.ME_EXAMINID \n" + | |
379 | +// " )TT ON F.FE_ID=TT.ME_EXAMINID\n" + | |
380 | +// "where replace(f.FE_TRIAGEORDERNO,'-','') \n"); | |
381 | +// long endTimes = System.currentTimeMillis(); | |
382 | +// System.out.println("chuzhentimes===========" + (endTimes - startTimes)); | |
383 | +// | |
384 | +// for(Map<String, Object> map : list) | |
385 | +// { | |
386 | +// chuzhenDatas.put(DataUtil.getString(map.get("FE_ID")).replace("-", ""), map); | |
387 | +// } | |
388 | +// list = null; | |
389 | +// | |
390 | +// } | |
351 | 391 | |
392 | + | |
352 | 393 | public void syncPatientData(String oracleHid,Integer mysqlHid) { |
353 | 394 | |
354 | 395 | //初始化数据 |
... | ... | @@ -754,31 +795,34 @@ |
754 | 795 | |
755 | 796 | private void syncChuZhen(String pid, String parentId, MongoTemplate mongoTemplate) { |
756 | 797 | long startTimes = System.currentTimeMillis(); |
757 | - List<Map<String, Object>> list = JDBCUtil.getOracleListDataBySql(" SELECT F.*,\n" + | |
758 | - " '[\"'||REPLACE(TT.HIGH_RISK_ID,',','\",\"')||'\"]' AS RISKFACTOR,\n" + | |
759 | - " TT.HIGH_RISK_VALUE AS RISKSCORE\n" + | |
760 | - "FROM MOMMY_FIRSTEXAMINE f \n" + | |
761 | - "--高危数据\n" + | |
762 | - "LEFT JOIN \n" + | |
763 | - " (\n" + | |
764 | - " SELECT T.ME_EXAMINID,WMSYS.WM_CONCAT(T.HIGH_RISK_FACTOR) AS HIGH_RISK_FACTOR,WMSYS.WM_CONCAT(DISTINCT T.HIGH_RISK_GRADE) AS HIGH_RISK_GRADE,SUM(T.HIGH_RISK_VALUE) AS HIGH_RISK_VALUE,WMSYS.WM_CONCAT(T.HIGH_RISK_ID) AS HIGH_RISK_ID\n" + | |
765 | - " FROM \n" + | |
766 | - " (SELECT J.ME_EXAMINID,K.DC_NAME AS HIGH_RISK_FACTOR,L.DC_NAME AS HIGH_RISK_GRADE,TO_NUMBER(K.DC_NO) AS HIGH_RISK_VALUE,LL.ID AS HIGH_RISK_ID\n" + | |
767 | - " FROM \n" + | |
768 | - " --高危风险关系表\n" + | |
769 | - " MOMMY_EXAMINWARNING J\n" + | |
770 | - " --高危内容\n" + | |
771 | - " 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" + | |
772 | - " --高危等级\n" + | |
773 | - " INNER JOIN PLAT_DATACONTENT L ON K.DC_PARENTID=L.DC_ID AND L.DC_ISVALID=1 \n" + | |
774 | - " 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" + | |
775 | - " -- UNION ALL \n" + | |
776 | - " --其他高危评分\n" + | |
777 | - " --SELECT M.ID,M.MO_CONTENT,M.MO_COLORNAME,M.MO_VALUES FROM MOMMY_OTHERWORNING M\n" + | |
778 | - " )T\n" + | |
779 | - " GROUP BY T.ME_EXAMINID \n" + | |
780 | - " )TT ON F.FE_ID=TT.ME_EXAMINID\n" + | |
781 | - "where replace(f.FE_TRIAGEORDERNO,'-','') = '" + parentId + "'\n"); | |
798 | +// List<Map<String, Object>> list = JDBCUtil.getOracleListDataBySql(" SELECT F.*,\n" + | |
799 | +// " '[\"'||REPLACE(TT.HIGH_RISK_ID,',','\",\"')||'\"]' AS RISKFACTOR,\n" + | |
800 | +// " TT.HIGH_RISK_VALUE AS RISKSCORE\n" + | |
801 | +// "FROM MOMMY_FIRSTEXAMINE f \n" + | |
802 | +// "--高危数据\n" + | |
803 | +// "LEFT JOIN \n" + | |
804 | +// " (\n" + | |
805 | +// " SELECT T.ME_EXAMINID,WMSYS.WM_CONCAT(T.HIGH_RISK_FACTOR) AS HIGH_RISK_FACTOR,WMSYS.WM_CONCAT(DISTINCT T.HIGH_RISK_GRADE) AS HIGH_RISK_GRADE,SUM(T.HIGH_RISK_VALUE) AS HIGH_RISK_VALUE,WMSYS.WM_CONCAT(T.HIGH_RISK_ID) AS HIGH_RISK_ID\n" + | |
806 | +// " FROM \n" + | |
807 | +// " (SELECT J.ME_EXAMINID,K.DC_NAME AS HIGH_RISK_FACTOR,L.DC_NAME AS HIGH_RISK_GRADE,TO_NUMBER(K.DC_NO) AS HIGH_RISK_VALUE,LL.ID AS HIGH_RISK_ID\n" + | |
808 | +// " FROM \n" + | |
809 | +// " --高危风险关系表\n" + | |
810 | +// " MOMMY_EXAMINWARNING J\n" + | |
811 | +// " --高危内容\n" + | |
812 | +// " 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" + | |
813 | +// " --高危等级\n" + | |
814 | +// " INNER JOIN PLAT_DATACONTENT L ON K.DC_PARENTID=L.DC_ID AND L.DC_ISVALID=1 \n" + | |
815 | +// " 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" + | |
816 | +// " -- UNION ALL \n" + | |
817 | +// " --其他高危评分\n" + | |
818 | +// " --SELECT M.ID,M.MO_CONTENT,M.MO_COLORNAME,M.MO_VALUES FROM MOMMY_OTHERWORNING M\n" + | |
819 | +// " )T\n" + | |
820 | +// " GROUP BY T.ME_EXAMINID \n" + | |
821 | +// " )TT ON F.FE_ID=TT.ME_EXAMINID\n" + | |
822 | +// "where replace(f.FE_TRIAGEORDERNO,'-','') = '" + parentId + "'\n"); | |
823 | + | |
824 | + List<Map<String, Object>> list = JDBCUtil.getOracleListDataBySql("select * from TMP_QHD_CZ cz where replace(cz.fe_triageorderno,'-','') = "+parentId+"'"); | |
825 | + | |
782 | 826 | long endTimes = System.currentTimeMillis(); |
783 | 827 | System.out.println("chuzhentimes===========" + (endTimes-startTimes)); |
784 | 828 | for (Map<String, Object> map : list) { |
785 | 829 | |
... | ... | @@ -888,115 +932,116 @@ |
888 | 932 | |
889 | 933 | |
890 | 934 | private void syncFuzhen(String pid, String parentId, MongoTemplate mongoTemplate) { |
891 | - String sql = "SELECT * FROM ( SELECT A.*, ROWNUM RN FROM ( SELECT A.ER_ID AS ID,\n" + | |
892 | - " '' AS PID,\n" + | |
893 | - " B.P_NO AS PARENTID,\n" + | |
894 | - " (CASE WHEN ABS(MOD((FLOOR(A.ER_CHECKDATE - B.P_LASTMENSTRUALPERIOD)+1),7))=0 \n" + | |
895 | - " THEN '孕'||TO_CHAR(ABS(FLOOR((A.ER_CHECKDATE - B.P_LASTMENSTRUALPERIOD+1)/7)))||'周'\n" + | |
896 | - " ELSE '孕'||TO_CHAR(ABS(FLOOR((A.ER_CHECKDATE - B.P_LASTMENSTRUALPERIOD+1)/7)))||'周+'||TO_CHAR(ABS(MOD((FLOOR(A.ER_CHECKDATE - B.P_LASTMENSTRUALPERIOD)+1),7)))||'天'\n" + | |
897 | - " END) AS CURRENTDUEDATE,\n" + | |
898 | - " A.ER_CHIEF AS CHIEFCOMPLAINT,\n" + | |
899 | - " A.ER_WEIGHT AS WEIGHT,\n" + | |
900 | - " '{\"ssy\":'||A.ER_BBLOODPRESSURE||',\"szy\":'||A.ER_HBLOODPRESSURE||'}' AS BP,\n" + | |
901 | - " A.ER_UTERUSHEIGHT AS GONGGAO,\n" + | |
902 | - " A.ER_CIRCUMFERENCE AS ABDOMINALCIRCUMFERENCE,\n" + | |
903 | - " DECODE(A.ER_WATEREDEMA,'-',1,'++',2,'+++',3,'++++',4) AS EDEMA,\n" + | |
904 | - " (CASE WHEN A.ER_ISSECOND=1 THEN 2 WHEN A.ER_ISTHIRD=1 THEN 3 ELSE 1 END) AS TIRENUMBER, \n" + | |
905 | - " (CASE WHEN A.ER_ISTHIRD=1\n" + | |
906 | - " --A.ER_FETALPOSITION_THD IS NOT NULL AND A.ER_FETALPOSITION_SEC IS NOT NULL AND A.ER_FETALPOSITION IS NOT NULL\n" + | |
907 | - " THEN '[{\"heartRate\":\"'||A.ER_HEARTRATE||'\",\"fetalPosition\":\"'||\n" + | |
908 | - " TO_CHAR(DECODE(A.ER_FETALPOSITION,'3777',1,'3778',2,'3779',3,'3780',4,'3781',5,'3782',6,'3783',7,'3784',8,'3785',9,'3786',10,'3787',11,'3788',12,'3789',13,'3790',14,'3791',15,'3792',16,'3793',17,'3794',18,'3795',19,'3796',20,'3797',21,'3798',22,'3799',23))||\n" + | |
909 | - " '\",\"fetalPresentation\":\"'||\n" + | |
910 | - " TO_CHAR(DECODE(A.ER_FETALPRESENTATION,'3772',1,'3773',2,'3774',3,'3775',4))||\n" + | |
911 | - " '\",\"join\":\"'||\n" + | |
912 | - " TO_CHAR(DECODE(A.ER_LINK,'37598072-1cdf-4548-97c3-3dfef08593f7',1,'e9490e8d-5b59-489a-e9ee-25e05dc08d69',2,'e9490e8d-5b59-e89a-89ee-25e05dc08d69',3))||\n" + | |
913 | - " '\"},{\"heartRate\":\"'||\n" + | |
914 | - " A.ER_HEARTRATE||'\",\"fetalPosition\":\"'||\n" + | |
915 | - " TO_CHAR(DECODE(A.ER_FETALPOSITION_SEC,'3777',1,'3778',2,'3779',3,'3780',4,'3781',5,'3782',6,'3783',7,'3784',8,'3785',9,'3786',10,'3787',11,'3788',12,'3789',13,'3790',14,'3791',15,'3792',16,'3793',17,'3794',18,'3795',19,'3796',20,'3797',21,'3798',22,'3799',23))||\n" + | |
916 | - " '\",\"fetalPresentation\":\"'||\n" + | |
917 | - " TO_CHAR(DECODE(A.ER_FETALPRESENTATION_SEC,'3772',1,'3773',2,'3774',3,'3775',4))||\n" + | |
918 | - " '\",\"join\":\"'||\n" + | |
919 | - " TO_CHAR(DECODE(A.ER_LINK_SEC,'37598072-1cdf-4548-97c3-3dfef08593f7',1,'e9490e8d-5b59-489a-e9ee-25e05dc08d69',2,'e9490e8d-5b59-e89a-89ee-25e05dc08d69',3))||\n" + | |
920 | - " '\"},{\"heartRate\":\"'||A.ER_HEARTRATE||'\",\"fetalPosition\":\"'||\n" + | |
921 | - " TO_CHAR(DECODE(A.ER_FETALPOSITION_THD,'3777',1,'3778',2,'3779',3,'3780',4,'3781',5,'3782',6,'3783',7,'3784',8,'3785',9,'3786',10,'3787',11,'3788',12,'3789',13,'3790',14,'3791',15,'3792',16,'3793',17,'3794',18,'3795',19,'3796',20,'3797',21,'3798',22,'3799',23))||\n" + | |
922 | - " '\",\"fetalPresentation\":\"'||\n" + | |
923 | - " TO_CHAR(DECODE(A.ER_FETALPRESENTATION_THD,'3772',1,'3773',2,'3774',3,'3775',4))||\n" + | |
924 | - " '\",\"join\":\"'||\n" + | |
925 | - " TO_CHAR(DECODE(A.ER_LINK_THD,'37598072-1cdf-4548-97c3-3dfef08593f7',1,'e9490e8d-5b59-489a-e9ee-25e05dc08d69',2,'e9490e8d-5b59-e89a-89ee-25e05dc08d69',3))||\n" + | |
926 | - " '\"}]'\n" + | |
927 | - " WHEN A.ER_ISSECOND=1\n" + | |
928 | - " THEN '[{\"heartRate\":\"'||A.ER_HEARTRATE||'\",\"fetalPosition\":\"'||\n" + | |
929 | - " TO_CHAR(DECODE(A.ER_FETALPOSITION,'3777',1,'3778',2,'3779',3,'3780',4,'3781',5,'3782',6,'3783',7,'3784',8,'3785',9,'3786',10,'3787',11,'3788',12,'3789',13,'3790',14,'3791',15,'3792',16,'3793',17,'3794',18,'3795',19,'3796',20,'3797',21,'3798',22,'3799',23))||\n" + | |
930 | - " '\",\"fetalPresentation\":\"'||\n" + | |
931 | - " TO_CHAR(DECODE(A.ER_FETALPRESENTATION,'3772',1,'3773',2,'3774',3,'3775',4))||\n" + | |
932 | - " '\",\"join\":\"'||\n" + | |
933 | - " TO_CHAR(DECODE(A.ER_LINK,'37598072-1cdf-4548-97c3-3dfef08593f7',1,'e9490e8d-5b59-489a-e9ee-25e05dc08d69',2,'e9490e8d-5b59-e89a-89ee-25e05dc08d69',3))||\n" + | |
934 | - " '\"},{\"heartRate\":\"'||\n" + | |
935 | - " A.ER_HEARTRATE||'\",\"fetalPosition\":\"'||\n" + | |
936 | - " TO_CHAR(DECODE(A.ER_FETALPOSITION_SEC,'3777',1,'3778',2,'3779',3,'3780',4,'3781',5,'3782',6,'3783',7,'3784',8,'3785',9,'3786',10,'3787',11,'3788',12,'3789',13,'3790',14,'3791',15,'3792',16,'3793',17,'3794',18,'3795',19,'3796',20,'3797',21,'3798',22,'3799',23))||\n" + | |
937 | - " '\",\"fetalPresentation\":\"'||\n" + | |
938 | - " TO_CHAR(DECODE(A.ER_FETALPRESENTATION_SEC,'3772',1,'3773',2,'3774',3,'3775',4))||\n" + | |
939 | - " '\",\"join\":\"'||\n" + | |
940 | - " TO_CHAR(DECODE(A.ER_LINK_SEC,'37598072-1cdf-4548-97c3-3dfef08593f7',1,'e9490e8d-5b59-489a-e9ee-25e05dc08d69',2,'e9490e8d-5b59-e89a-89ee-25e05dc08d69',3))||\n" + | |
941 | - " '\"}]'\n" + | |
942 | - " ELSE '[{\"heartRate\":\"'||A.ER_HEARTRATE||'\",\"fetalPosition\":\"'||\n" + | |
943 | - " TO_CHAR(DECODE(A.ER_FETALPOSITION,'3777',1,'3778',2,'3779',3,'3780',4,'3781',5,'3782',6,'3783',7,'3784',8,'3785',9,'3786',10,'3787',11,'3788',12,'3789',13,'3790',14,'3791',15,'3792',16,'3793',17,'3794',18,'3795',19,'3796',20,'3797',21,'3798',22,'3799',23))||\n" + | |
944 | - " '\",\"fetalPresentation\":\"'||\n" + | |
945 | - " TO_CHAR(DECODE(A.ER_FETALPRESENTATION,'3772',1,'3773',2,'3774',3,'3775',4))||\n" + | |
946 | - " '\",\"join\":\"'||\n" + | |
947 | - " TO_CHAR(DECODE(A.ER_LINK,'37598072-1cdf-4548-97c3-3dfef08593f7',1,'e9490e8d-5b59-489a-e9ee-25e05dc08d69',2,'e9490e8d-5b59-e89a-89ee-25e05dc08d69',3))||\n" + | |
948 | - " '\"}]'\n" + | |
949 | - " END) AS TIREDATA,\n" + | |
950 | - " A.ER_WHITEBLOOD AS HEMOGLOBIN,\n" + | |
951 | - " A.ER_URINARYPROTEIN AS URINEPROTEIN,\n" + | |
952 | - " A.ER_B AS BCHAO,\n" + | |
953 | - " A.ER_BLOODGLUCOSESCREENING AS BLOODSUGAR,\n" + | |
954 | - " '[\"'||REPLACE(TT.HIGH_RISK_ID,',','\",\"')||'\"]' AS RISKFACTOR,\n" + | |
955 | - " TT.HIGH_RISK_VALUE AS RISKSCORE,\n" + | |
956 | - " A.ER_CLASSIFICATION AS TYPE,\n" + | |
957 | - " A.ER_DEAL AS TREATMENTOPINION,\n" + | |
958 | - " A.ER_CHECKDATE AS CHECKDATE,\n" + | |
959 | - " A.ER_NEXTDATE AS NEXTCHECKTIME,\n" + | |
960 | - " A.ER_CREATETIME AS CREATED,\n" + | |
961 | - " A.ER_OPERTIME AS MODIFIED,\n" + | |
962 | - " H.E_HOSPITALID AS HOSPITALID,\n" + | |
963 | - " ABS(FLOOR((A.ER_CHECKDATE - B.P_LASTMENSTRUALPERIOD+1)/7)) AS CDUEWEEK,\n" + | |
964 | - " B.P_ISVALID AS YN,\n" + | |
965 | - " H.E_NAME AS CHECKDOCTOR\n" + | |
966 | - " \n" + | |
967 | - "FROM \n" + | |
968 | - " MOMMY_EXAMINERESULT A --初诊表\n" + | |
969 | - "----孕产婴用户表\n" + | |
970 | - "INNER JOIN MOMMY_PATIENT B ON A.ER_TRIAGEORDERNO=B.P_NO AND B.P_ISVALID=1\n" + | |
971 | - "--平台用户表 \n" + | |
972 | - "INNER JOIN PLAT_PATIENT C ON B.P_PLATPATIENTID=C.P_ID AND C.P_ISVALID=1\n" + | |
973 | - "--医生表\n" + | |
974 | - "INNER JOIN MOMMY_EMPLOYEE H ON H.E_ISVALID=1 AND A.ER_CREATOR=H.E_ID\n" + | |
975 | - "--医院表\n" + | |
976 | - "INNER JOIN PLAT_HOSPITAL F ON F.H_ID=H.E_HOSPITALID AND F.H_ISVALID=1 \n" + | |
977 | - "--诊断表\n" + | |
978 | - "--INNER JOIN MOMMY_EXAMINEDIAGNOSIS N ON N.ED_TRIAGEORDERNO=A.ER_ID AND N.ED_IDENTIFYING=0\n" + | |
979 | - "--高危数据\n" + | |
980 | - "LEFT JOIN \n" + | |
981 | - " (\n" + | |
982 | - " SELECT T.ME_EXAMINID,WMSYS.WM_CONCAT(T.HIGH_RISK_FACTOR) AS HIGH_RISK_FACTOR,WMSYS.WM_CONCAT(DISTINCT T.HIGH_RISK_GRADE) AS HIGH_RISK_GRADE,SUM(T.HIGH_RISK_VALUE) AS HIGH_RISK_VALUE,WMSYS.WM_CONCAT(T.HIGH_RISK_ID) AS HIGH_RISK_ID\n" + | |
983 | - " FROM \n" + | |
984 | - " (SELECT J.ME_EXAMINID,K.DC_NAME AS HIGH_RISK_FACTOR,L.DC_NAME AS HIGH_RISK_GRADE,TO_NUMBER(K.DC_NO) AS HIGH_RISK_VALUE,LL.ID AS HIGH_RISK_ID\n" + | |
985 | - " FROM \n" + | |
986 | - " --高危风险关系表\n" + | |
987 | - " MOMMY_EXAMINWARNING J\n" + | |
988 | - " --高危内容\n" + | |
989 | - " 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" + | |
990 | - " --高危等级\n" + | |
991 | - " INNER JOIN PLAT_DATACONTENT L ON K.DC_PARENTID=L.DC_ID AND L.DC_ISVALID=1\n" + | |
992 | - " 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" + | |
993 | - " -- UNION ALL \n" + | |
994 | - " --其他高危评分\n" + | |
995 | - " --SELECT M.ID,M.MO_CONTENT,M.MO_COLORNAME,M.MO_VALUES FROM MOMMY_OTHERWORNING M\n" + | |
996 | - " )T\n" + | |
997 | - " GROUP BY T.ME_EXAMINID \n" + | |
998 | - " )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 "; | |
935 | +// String sql = "SELECT * FROM ( SELECT A.*, ROWNUM RN FROM ( SELECT A.ER_ID AS ID,\n" + | |
936 | +// " '' AS PID,\n" + | |
937 | +// " B.P_NO AS PARENTID,\n" + | |
938 | +// " (CASE WHEN ABS(MOD((FLOOR(A.ER_CHECKDATE - B.P_LASTMENSTRUALPERIOD)+1),7))=0 \n" + | |
939 | +// " THEN '孕'||TO_CHAR(ABS(FLOOR((A.ER_CHECKDATE - B.P_LASTMENSTRUALPERIOD+1)/7)))||'周'\n" + | |
940 | +// " ELSE '孕'||TO_CHAR(ABS(FLOOR((A.ER_CHECKDATE - B.P_LASTMENSTRUALPERIOD+1)/7)))||'周+'||TO_CHAR(ABS(MOD((FLOOR(A.ER_CHECKDATE - B.P_LASTMENSTRUALPERIOD)+1),7)))||'天'\n" + | |
941 | +// " END) AS CURRENTDUEDATE,\n" + | |
942 | +// " A.ER_CHIEF AS CHIEFCOMPLAINT,\n" + | |
943 | +// " A.ER_WEIGHT AS WEIGHT,\n" + | |
944 | +// " '{\"ssy\":'||A.ER_BBLOODPRESSURE||',\"szy\":'||A.ER_HBLOODPRESSURE||'}' AS BP,\n" + | |
945 | +// " A.ER_UTERUSHEIGHT AS GONGGAO,\n" + | |
946 | +// " A.ER_CIRCUMFERENCE AS ABDOMINALCIRCUMFERENCE,\n" + | |
947 | +// " DECODE(A.ER_WATEREDEMA,'-',1,'++',2,'+++',3,'++++',4) AS EDEMA,\n" + | |
948 | +// " (CASE WHEN A.ER_ISSECOND=1 THEN 2 WHEN A.ER_ISTHIRD=1 THEN 3 ELSE 1 END) AS TIRENUMBER, \n" + | |
949 | +// " (CASE WHEN A.ER_ISTHIRD=1\n" + | |
950 | +// " --A.ER_FETALPOSITION_THD IS NOT NULL AND A.ER_FETALPOSITION_SEC IS NOT NULL AND A.ER_FETALPOSITION IS NOT NULL\n" + | |
951 | +// " THEN '[{\"heartRate\":\"'||A.ER_HEARTRATE||'\",\"fetalPosition\":\"'||\n" + | |
952 | +// " TO_CHAR(DECODE(A.ER_FETALPOSITION,'3777',1,'3778',2,'3779',3,'3780',4,'3781',5,'3782',6,'3783',7,'3784',8,'3785',9,'3786',10,'3787',11,'3788',12,'3789',13,'3790',14,'3791',15,'3792',16,'3793',17,'3794',18,'3795',19,'3796',20,'3797',21,'3798',22,'3799',23))||\n" + | |
953 | +// " '\",\"fetalPresentation\":\"'||\n" + | |
954 | +// " TO_CHAR(DECODE(A.ER_FETALPRESENTATION,'3772',1,'3773',2,'3774',3,'3775',4))||\n" + | |
955 | +// " '\",\"join\":\"'||\n" + | |
956 | +// " TO_CHAR(DECODE(A.ER_LINK,'37598072-1cdf-4548-97c3-3dfef08593f7',1,'e9490e8d-5b59-489a-e9ee-25e05dc08d69',2,'e9490e8d-5b59-e89a-89ee-25e05dc08d69',3))||\n" + | |
957 | +// " '\"},{\"heartRate\":\"'||\n" + | |
958 | +// " A.ER_HEARTRATE||'\",\"fetalPosition\":\"'||\n" + | |
959 | +// " TO_CHAR(DECODE(A.ER_FETALPOSITION_SEC,'3777',1,'3778',2,'3779',3,'3780',4,'3781',5,'3782',6,'3783',7,'3784',8,'3785',9,'3786',10,'3787',11,'3788',12,'3789',13,'3790',14,'3791',15,'3792',16,'3793',17,'3794',18,'3795',19,'3796',20,'3797',21,'3798',22,'3799',23))||\n" + | |
960 | +// " '\",\"fetalPresentation\":\"'||\n" + | |
961 | +// " TO_CHAR(DECODE(A.ER_FETALPRESENTATION_SEC,'3772',1,'3773',2,'3774',3,'3775',4))||\n" + | |
962 | +// " '\",\"join\":\"'||\n" + | |
963 | +// " TO_CHAR(DECODE(A.ER_LINK_SEC,'37598072-1cdf-4548-97c3-3dfef08593f7',1,'e9490e8d-5b59-489a-e9ee-25e05dc08d69',2,'e9490e8d-5b59-e89a-89ee-25e05dc08d69',3))||\n" + | |
964 | +// " '\"},{\"heartRate\":\"'||A.ER_HEARTRATE||'\",\"fetalPosition\":\"'||\n" + | |
965 | +// " TO_CHAR(DECODE(A.ER_FETALPOSITION_THD,'3777',1,'3778',2,'3779',3,'3780',4,'3781',5,'3782',6,'3783',7,'3784',8,'3785',9,'3786',10,'3787',11,'3788',12,'3789',13,'3790',14,'3791',15,'3792',16,'3793',17,'3794',18,'3795',19,'3796',20,'3797',21,'3798',22,'3799',23))||\n" + | |
966 | +// " '\",\"fetalPresentation\":\"'||\n" + | |
967 | +// " TO_CHAR(DECODE(A.ER_FETALPRESENTATION_THD,'3772',1,'3773',2,'3774',3,'3775',4))||\n" + | |
968 | +// " '\",\"join\":\"'||\n" + | |
969 | +// " TO_CHAR(DECODE(A.ER_LINK_THD,'37598072-1cdf-4548-97c3-3dfef08593f7',1,'e9490e8d-5b59-489a-e9ee-25e05dc08d69',2,'e9490e8d-5b59-e89a-89ee-25e05dc08d69',3))||\n" + | |
970 | +// " '\"}]'\n" + | |
971 | +// " WHEN A.ER_ISSECOND=1\n" + | |
972 | +// " THEN '[{\"heartRate\":\"'||A.ER_HEARTRATE||'\",\"fetalPosition\":\"'||\n" + | |
973 | +// " TO_CHAR(DECODE(A.ER_FETALPOSITION,'3777',1,'3778',2,'3779',3,'3780',4,'3781',5,'3782',6,'3783',7,'3784',8,'3785',9,'3786',10,'3787',11,'3788',12,'3789',13,'3790',14,'3791',15,'3792',16,'3793',17,'3794',18,'3795',19,'3796',20,'3797',21,'3798',22,'3799',23))||\n" + | |
974 | +// " '\",\"fetalPresentation\":\"'||\n" + | |
975 | +// " TO_CHAR(DECODE(A.ER_FETALPRESENTATION,'3772',1,'3773',2,'3774',3,'3775',4))||\n" + | |
976 | +// " '\",\"join\":\"'||\n" + | |
977 | +// " TO_CHAR(DECODE(A.ER_LINK,'37598072-1cdf-4548-97c3-3dfef08593f7',1,'e9490e8d-5b59-489a-e9ee-25e05dc08d69',2,'e9490e8d-5b59-e89a-89ee-25e05dc08d69',3))||\n" + | |
978 | +// " '\"},{\"heartRate\":\"'||\n" + | |
979 | +// " A.ER_HEARTRATE||'\",\"fetalPosition\":\"'||\n" + | |
980 | +// " TO_CHAR(DECODE(A.ER_FETALPOSITION_SEC,'3777',1,'3778',2,'3779',3,'3780',4,'3781',5,'3782',6,'3783',7,'3784',8,'3785',9,'3786',10,'3787',11,'3788',12,'3789',13,'3790',14,'3791',15,'3792',16,'3793',17,'3794',18,'3795',19,'3796',20,'3797',21,'3798',22,'3799',23))||\n" + | |
981 | +// " '\",\"fetalPresentation\":\"'||\n" + | |
982 | +// " TO_CHAR(DECODE(A.ER_FETALPRESENTATION_SEC,'3772',1,'3773',2,'3774',3,'3775',4))||\n" + | |
983 | +// " '\",\"join\":\"'||\n" + | |
984 | +// " TO_CHAR(DECODE(A.ER_LINK_SEC,'37598072-1cdf-4548-97c3-3dfef08593f7',1,'e9490e8d-5b59-489a-e9ee-25e05dc08d69',2,'e9490e8d-5b59-e89a-89ee-25e05dc08d69',3))||\n" + | |
985 | +// " '\"}]'\n" + | |
986 | +// " ELSE '[{\"heartRate\":\"'||A.ER_HEARTRATE||'\",\"fetalPosition\":\"'||\n" + | |
987 | +// " TO_CHAR(DECODE(A.ER_FETALPOSITION,'3777',1,'3778',2,'3779',3,'3780',4,'3781',5,'3782',6,'3783',7,'3784',8,'3785',9,'3786',10,'3787',11,'3788',12,'3789',13,'3790',14,'3791',15,'3792',16,'3793',17,'3794',18,'3795',19,'3796',20,'3797',21,'3798',22,'3799',23))||\n" + | |
988 | +// " '\",\"fetalPresentation\":\"'||\n" + | |
989 | +// " TO_CHAR(DECODE(A.ER_FETALPRESENTATION,'3772',1,'3773',2,'3774',3,'3775',4))||\n" + | |
990 | +// " '\",\"join\":\"'||\n" + | |
991 | +// " TO_CHAR(DECODE(A.ER_LINK,'37598072-1cdf-4548-97c3-3dfef08593f7',1,'e9490e8d-5b59-489a-e9ee-25e05dc08d69',2,'e9490e8d-5b59-e89a-89ee-25e05dc08d69',3))||\n" + | |
992 | +// " '\"}]'\n" + | |
993 | +// " END) AS TIREDATA,\n" + | |
994 | +// " A.ER_WHITEBLOOD AS HEMOGLOBIN,\n" + | |
995 | +// " A.ER_URINARYPROTEIN AS URINEPROTEIN,\n" + | |
996 | +// " A.ER_B AS BCHAO,\n" + | |
997 | +// " A.ER_BLOODGLUCOSESCREENING AS BLOODSUGAR,\n" + | |
998 | +// " '[\"'||REPLACE(TT.HIGH_RISK_ID,',','\",\"')||'\"]' AS RISKFACTOR,\n" + | |
999 | +// " TT.HIGH_RISK_VALUE AS RISKSCORE,\n" + | |
1000 | +// " A.ER_CLASSIFICATION AS TYPE,\n" + | |
1001 | +// " A.ER_DEAL AS TREATMENTOPINION,\n" + | |
1002 | +// " A.ER_CHECKDATE AS CHECKDATE,\n" + | |
1003 | +// " A.ER_NEXTDATE AS NEXTCHECKTIME,\n" + | |
1004 | +// " A.ER_CREATETIME AS CREATED,\n" + | |
1005 | +// " A.ER_OPERTIME AS MODIFIED,\n" + | |
1006 | +// " H.E_HOSPITALID AS HOSPITALID,\n" + | |
1007 | +// " ABS(FLOOR((A.ER_CHECKDATE - B.P_LASTMENSTRUALPERIOD+1)/7)) AS CDUEWEEK,\n" + | |
1008 | +// " B.P_ISVALID AS YN,\n" + | |
1009 | +// " H.E_NAME AS CHECKDOCTOR\n" + | |
1010 | +// " \n" + | |
1011 | +// "FROM \n" + | |
1012 | +// " MOMMY_EXAMINERESULT A --初诊表\n" + | |
1013 | +// "----孕产婴用户表\n" + | |
1014 | +// "INNER JOIN MOMMY_PATIENT B ON A.ER_TRIAGEORDERNO=B.P_NO AND B.P_ISVALID=1 and replace(B.P_NO,'-','') = '" + parentId + "'\n" + | |
1015 | +// "--平台用户表 \n" + | |
1016 | +// "INNER JOIN PLAT_PATIENT C ON B.P_PLATPATIENTID=C.P_ID AND C.P_ISVALID=1\n" + | |
1017 | +// "--医生表\n" + | |
1018 | +// "INNER JOIN MOMMY_EMPLOYEE H ON H.E_ISVALID=1 AND A.ER_CREATOR=H.E_ID\n" + | |
1019 | +// "--医院表\n" + | |
1020 | +// "INNER JOIN PLAT_HOSPITAL F ON F.H_ID=H.E_HOSPITALID AND F.H_ISVALID=1 \n" + | |
1021 | +// "--诊断表\n" + | |
1022 | +// "--INNER JOIN MOMMY_EXAMINEDIAGNOSIS N ON N.ED_TRIAGEORDERNO=A.ER_ID AND N.ED_IDENTIFYING=0\n" + | |
1023 | +// "--高危数据\n" + | |
1024 | +// "LEFT JOIN \n" + | |
1025 | +// " (\n" + | |
1026 | +// " SELECT T.ME_EXAMINID,WMSYS.WM_CONCAT(T.HIGH_RISK_FACTOR) AS HIGH_RISK_FACTOR,WMSYS.WM_CONCAT(DISTINCT T.HIGH_RISK_GRADE) AS HIGH_RISK_GRADE,SUM(T.HIGH_RISK_VALUE) AS HIGH_RISK_VALUE,WMSYS.WM_CONCAT(T.HIGH_RISK_ID) AS HIGH_RISK_ID\n" + | |
1027 | +// " FROM \n" + | |
1028 | +// " (SELECT J.ME_EXAMINID,K.DC_NAME AS HIGH_RISK_FACTOR,L.DC_NAME AS HIGH_RISK_GRADE,TO_NUMBER(K.DC_NO) AS HIGH_RISK_VALUE,LL.ID AS HIGH_RISK_ID\n" + | |
1029 | +// " FROM \n" + | |
1030 | +// " --高危风险关系表\n" + | |
1031 | +// " MOMMY_EXAMINWARNING J\n" + | |
1032 | +// " --高危内容\n" + | |
1033 | +// " 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" + | |
1034 | +// " --高危等级\n" + | |
1035 | +// " INNER JOIN PLAT_DATACONTENT L ON K.DC_PARENTID=L.DC_ID AND L.DC_ISVALID=1\n" + | |
1036 | +// " 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" + | |
1037 | +// " -- UNION ALL \n" + | |
1038 | +// " --其他高危评分\n" + | |
1039 | +// " --SELECT M.ID,M.MO_CONTENT,M.MO_COLORNAME,M.MO_VALUES FROM MOMMY_OTHERWORNING M\n" + | |
1040 | +// " )T\n" + | |
1041 | +// " GROUP BY T.ME_EXAMINID \n" + | |
1042 | +// " )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 "; | |
999 | 1043 | |
1044 | + String sql = "select * from TMP_QHD_FZ where replace(parentid,'-','') = '"+parentId+"'"; | |
1000 | 1045 | long startTimes = System.currentTimeMillis(); |
1001 | 1046 | List<Map<String, Object>> list = JDBCUtil.getOracleListDataBySql(sql); |
1002 | 1047 | long endTimes = System.currentTimeMillis(); |