From c7ebdea204373bd29d595ddfa4eafbb4cce6b354 Mon Sep 17 00:00:00 2001 From: liquanyu Date: Mon, 10 Oct 2016 18:02:04 +0800 Subject: [PATCH] code update --- .../main/java/com/lyms/platform/biz/JdbcUtil.java | 70 +++++++++++++++------- platform-resource/resources/config-test.properties | 2 +- 2 files changed, 51 insertions(+), 21 deletions(-) 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 76bd140..3ca59d6 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 @@ -596,8 +596,9 @@ public class JdbcUtil { " '{\"ssy\":'||A.ER_BBLOODPRESSURE||',\"szy\":'||A.ER_HBLOODPRESSURE||'}' AS BP,\n" + " A.ER_UTERUSHEIGHT AS GONGGAO,\n" + " A.ER_CIRCUMFERENCE AS ABDOMINALCIRCUMFERENCE,\n" + - " DECODE(A.ER_WATEREDEMA,'-',1,'++',2,'+++',3,'++++',4) AS EDEMA, \n" + - " (CASE WHEN 1=1\n" + + " DECODE(A.ER_WATEREDEMA,'-',1,'++',2,'+++',3,'++++',4) AS EDEMA,\n" + + " (CASE WHEN A.ER_ISSECOND=1 THEN 2 WHEN A.ER_ISTHIRD=1 THEN 3 ELSE 1 END) AS TIRENUMBER, \n" + + " (CASE WHEN A.ER_ISTHIRD=1\n" + " --A.ER_FETALPOSITION_THD IS NOT NULL AND A.ER_FETALPOSITION_SEC IS NOT NULL AND A.ER_FETALPOSITION IS NOT NULL\n" + " THEN '[{\"heartRate\":\"'||A.ER_HEARTRATE||'\",\"fetalPosition\":\"'||\n" + " 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" + @@ -619,12 +620,35 @@ public class JdbcUtil { " '\",\"join\":\"'||\n" + " 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" + " '\"}]'\n" + + " WHEN A.ER_ISSECOND=1\n" + + " THEN '[{\"heartRate\":\"'||A.ER_HEARTRATE||'\",\"fetalPosition\":\"'||\n" + + " 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" + + " '\",\"fetalPresentation\":\"'||\n" + + " TO_CHAR(DECODE(A.ER_FETALPRESENTATION,'3772',1,'3773',2,'3774',3,'3775',4))||\n" + + " '\",\"join\":\"'||\n" + + " 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" + + " '\"},{\"heartRate\":\"'||\n" + + " A.ER_HEARTRATE||'\",\"fetalPosition\":\"'||\n" + + " 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" + + " '\",\"fetalPresentation\":\"'||\n" + + " TO_CHAR(DECODE(A.ER_FETALPRESENTATION_SEC,'3772',1,'3773',2,'3774',3,'3775',4))||\n" + + " '\",\"join\":\"'||\n" + + " 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" + + " '\"}]'\n" + + " ELSE '[{\"heartRate\":\"'||A.ER_HEARTRATE||'\",\"fetalPosition\":\"'||\n" + + " 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" + + " '\",\"fetalPresentation\":\"'||\n" + + " TO_CHAR(DECODE(A.ER_FETALPRESENTATION,'3772',1,'3773',2,'3774',3,'3775',4))||\n" + + " '\",\"join\":\"'||\n" + + " 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" + + " '\"}]'\n" + " END) AS TIREDATA,\n" + " A.ER_WHITEBLOOD AS HEMOGLOBIN,\n" + " A.ER_URINARYPROTEIN AS URINEPROTEIN,\n" + " A.ER_B AS BCHAO,\n" + " A.ER_BLOODGLUCOSESCREENING AS BLOODSUGAR,\n" + " '[\"'||REPLACE(TT.HIGH_RISK_ID,',','\",\"')||'\"]' AS RISKFACTOR,\n" + + " TT.HIGH_RISK_VALUE AS RISKSCORE,\n" + " A.ER_CLASSIFICATION AS TYPE,\n" + " A.ER_DEAL AS TREATMENTOPINION,\n" + " A.ER_CHECKDATE AS CHECKDATE,\n" + @@ -633,7 +657,8 @@ public class JdbcUtil { " A.ER_OPERTIME AS MODIFIED,\n" + " H.E_HOSPITALID AS HOSPITALID,\n" + " ABS(FLOOR((A.ER_CHECKDATE - B.P_LASTMENSTRUALPERIOD+1)/7)) AS CDUEWEEK,\n" + - " B.P_ISVALID AS YN\n" + + " B.P_ISVALID AS YN,\n" + + " H.E_NAME AS CHECKDOCTOR\n" + " \n" + "FROM \n" + " MOMMY_EXAMINERESULT A --初诊表\n" + @@ -645,6 +670,8 @@ public class JdbcUtil { "INNER JOIN MOMMY_EMPLOYEE H ON H.E_ISVALID=1 AND A.ER_CREATOR=H.E_ID\n" + "--医院表\n" + "INNER JOIN PLAT_HOSPITAL F ON F.H_ID=H.E_HOSPITALID AND F.H_ISVALID=1 \n" + + "--诊断表\n" + + "--INNER JOIN MOMMY_EXAMINEDIAGNOSIS N ON N.ED_TRIAGEORDERNO=A.ER_ID AND N.ED_IDENTIFYING=0\n" + "--高危数据\n" + "LEFT JOIN \n" + " (\n" + @@ -669,8 +696,6 @@ public class JdbcUtil { List> list = getListDataBySql(sql); - - for(Map map : list) { AntenatalExaminationModel antxModel = new AntenatalExaminationModel(); @@ -684,24 +709,30 @@ public class JdbcUtil { antxModel.setGongGao(getString(map.get("GONGGAO"))); antxModel.setAbdominalCircumference(getString(map.get("ABDOMINALCIRCUMFERENCE"))); antxModel.setEdema(getString(map.get("EDEMA"))); - antxModel.setTireNumber(getString(map.get(""))); + antxModel.setTireNumber(getString(map.get("TIRENUMBER"))); - antxModel.setTireData(JsonUtil.toList(getString(map.get("TIREDATA")),Placenta.class)); + antxModel.setTireData(JsonUtil.toList(getString(map.get("TIREDATA")), Placenta.class)); antxModel.setHemoglobin(getString(map.get("HEMOGLOBIN"))); antxModel.setUrineProtein(getString(map.get("URINEPROTEIN"))); antxModel.setbChao(getString(map.get("BCHAO"))); antxModel.setBloodSugar(getString(map.get("BLOODSUGAR"))); antxModel.setRiskFactor(getString(map.get("RISKFACTOR"))); - antxModel.setRiskScore(getString(map.get(""))); + antxModel.setRiskScore(getString(map.get("RISKSCORE"))); antxModel.setOtherRisk(getString(map.get(""))); antxModel.setDiagnosis(getString(map.get(""))); - antxModel.setType(getString(map.get("TYPE"))); + antxModel.setType(getString(map.get(""))); antxModel.setTypeYc(getString(map.get(""))); antxModel.setTreatmentOpinion(getString(map.get("TREATMENTOPINION"))); antxModel.setGuide(getString(map.get(""))); - antxModel.setCheckDoctor(getString(map.get(""))); + String checkDoctorName = getString(map.get("CHECKDOCTOR")); + if (checkDoctorName != null && !"".equals(checkDoctorName)) + { + String id = getString(getMysqlSingleObjBySql("select id from users where name = '" + checkDoctorName + "'")); + antxModel.setCheckDoctor(id); + } + antxModel.setCheckDate(getDate(map.get("CHECKDATE"))); antxModel.setNextCheckTime(getDate(map.get("NEXTCHECKTIME"))); antxModel.setYn(getInteger(map.get("YN"))); @@ -718,7 +749,7 @@ public class JdbcUtil { } public static void syncBabyData() { - List> list = getListDataBySql(" SELECT * FROM ( SELECT A.*, ROWNUM RN FROM (select replace(m.PI_ID,'-','') as ID,m.* from MOMMY_PATIENTINFO m) A WHERE ROWNUM <= 10 ) WHERE RN >= 0 "); + List> list = getListDataBySql(" SELECT * FROM ( SELECT A.*, ROWNUM RN FROM (select replace(m.PI_ID,'-','') as ID,m.* from MOMMY_PATIENTINFO m) A WHERE ROWNUM <= 100 ) WHERE RN >= 0 "); MongoTemplate mongoTemplate = getMongoTemplate(); @@ -778,8 +809,8 @@ public class JdbcUtil { model.setMproTypeId(id); } - model.setMcertNo(getString(map.get(""))); - model.setMcertTypeId(getString(map.get(""))); + model.setMcertNo(getString(map.get("PI_MOTHERPHONE"))); + model.setMcertTypeId("57e0a21c0cf209b410a82cda"); String mLevelId = getString(map.get("PI_MMCULTURE")); if (mLevelId != null && !"".equals(mLevelId)) { @@ -898,9 +929,7 @@ public class JdbcUtil { public static void syncBabyCheck(String parentId,MongoTemplate mongoTemplate) { - - - String sql = " select * from MOMMY_PATIENTINFO MP left join MOMMY_CHILDEXAMINRECORD MC ON MP.PI_ID = MC.CER_PATIENTID WHERE MP.Pi_Id= '"+parentId+"'"; + String sql = " select * from MOMMY_CHILDEXAMINRECORD MC left join MOMMY_PATIENTINFO MP ON MP.PI_ID = MC.CER_PATIENTID WHERE replace(MP.Pi_Id,'-','')= '"+parentId+"'"; List> list = getListDataBySql(sql); for (Map map : list) @@ -994,17 +1023,18 @@ public class JdbcUtil { String[] arrs = result.split("|"); for (String str : arrs) { + String[] temps = str.split("："); if (str.startsWith("头")) { - checkModel.setBilirubinHead(str.split("：")[1]); + checkModel.setBilirubinHead(temps.length == 2 ? temps[1] : ""); } else if (str.startsWith("胸")) { - checkModel.setBilirubinChest(str.split("：")[1]); + checkModel.setBilirubinChest(temps.length == 2 ? temps[1] : ""); } else if (str.startsWith("腹")) { - checkModel.setBilirubinBelly(str.split("：")[1]); + checkModel.setBilirubinBelly(temps.length == 2 ? temps[1] : ""); } } } @@ -1039,7 +1069,7 @@ public class JdbcUtil { } } - checkModel.setBregma(result); + checkModel.setBregma(JsonUtil.obj2JsonString(bregma)); } else if ("出牙数".equals(itemName)) { diff --git a/platform-resource/resources/config-test.properties b/platform-resource/resources/config-test.properties index 0b6e1a0..b6f4909 100644 --- a/platform-resource/resources/config-test.properties +++ b/platform-resource/resources/config-test.properties @@ -1,6 +1,6 @@ mongo.db.host=127.0.0.1 mongo.db.port=10001 -mongo.db.dbname=platform +mongo.db.dbname=sync-platform-data mongo.db.username=platform mongo.db.password=platform123 -- 1.8.3.1