Commit c7ebdea204373bd29d595ddfa4eafbb4cce6b354

Authored by liquanyu
1 parent acefa89672

code update

Showing 2 changed files with 51 additions and 21 deletions

platform-biz-patient-service/src/main/java/com/lyms/platform/biz/JdbcUtil.java View file @ c7ebdea
... ... @@ -596,8 +596,9 @@
596 596 " '{\"ssy\":'||A.ER_BBLOODPRESSURE||',\"szy\":'||A.ER_HBLOODPRESSURE||'}' AS BP,\n" +
597 597 " A.ER_UTERUSHEIGHT AS GONGGAO,\n" +
598 598 " A.ER_CIRCUMFERENCE AS ABDOMINALCIRCUMFERENCE,\n" +
599   - " DECODE(A.ER_WATEREDEMA,'-',1,'++',2,'+++',3,'++++',4) AS EDEMA, \n" +
600   - " (CASE WHEN 1=1\n" +
  599 + " DECODE(A.ER_WATEREDEMA,'-',1,'++',2,'+++',3,'++++',4) AS EDEMA,\n" +
  600 + " (CASE WHEN A.ER_ISSECOND=1 THEN 2 WHEN A.ER_ISTHIRD=1 THEN 3 ELSE 1 END) AS TIRENUMBER, \n" +
  601 + " (CASE WHEN A.ER_ISTHIRD=1\n" +
601 602 " --A.ER_FETALPOSITION_THD IS NOT NULL AND A.ER_FETALPOSITION_SEC IS NOT NULL AND A.ER_FETALPOSITION IS NOT NULL\n" +
602 603 " THEN '[{\"heartRate\":\"'||A.ER_HEARTRATE||'\",\"fetalPosition\":\"'||\n" +
603 604 " 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" +
604 605  
... ... @@ -619,12 +620,35 @@
619 620 " '\",\"join\":\"'||\n" +
620 621 " 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" +
621 622 " '\"}]'\n" +
  623 + " WHEN A.ER_ISSECOND=1\n" +
  624 + " THEN '[{\"heartRate\":\"'||A.ER_HEARTRATE||'\",\"fetalPosition\":\"'||\n" +
  625 + " 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" +
  626 + " '\",\"fetalPresentation\":\"'||\n" +
  627 + " TO_CHAR(DECODE(A.ER_FETALPRESENTATION,'3772',1,'3773',2,'3774',3,'3775',4))||\n" +
  628 + " '\",\"join\":\"'||\n" +
  629 + " 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" +
  630 + " '\"},{\"heartRate\":\"'||\n" +
  631 + " A.ER_HEARTRATE||'\",\"fetalPosition\":\"'||\n" +
  632 + " 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" +
  633 + " '\",\"fetalPresentation\":\"'||\n" +
  634 + " TO_CHAR(DECODE(A.ER_FETALPRESENTATION_SEC,'3772',1,'3773',2,'3774',3,'3775',4))||\n" +
  635 + " '\",\"join\":\"'||\n" +
  636 + " 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" +
  637 + " '\"}]'\n" +
  638 + " ELSE '[{\"heartRate\":\"'||A.ER_HEARTRATE||'\",\"fetalPosition\":\"'||\n" +
  639 + " 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" +
  640 + " '\",\"fetalPresentation\":\"'||\n" +
  641 + " TO_CHAR(DECODE(A.ER_FETALPRESENTATION,'3772',1,'3773',2,'3774',3,'3775',4))||\n" +
  642 + " '\",\"join\":\"'||\n" +
  643 + " 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" +
  644 + " '\"}]'\n" +
622 645 " END) AS TIREDATA,\n" +
623 646 " A.ER_WHITEBLOOD AS HEMOGLOBIN,\n" +
624 647 " A.ER_URINARYPROTEIN AS URINEPROTEIN,\n" +
625 648 " A.ER_B AS BCHAO,\n" +
626 649 " A.ER_BLOODGLUCOSESCREENING AS BLOODSUGAR,\n" +
627 650 " '[\"'||REPLACE(TT.HIGH_RISK_ID,',','\",\"')||'\"]' AS RISKFACTOR,\n" +
  651 + " TT.HIGH_RISK_VALUE AS RISKSCORE,\n" +
628 652 " A.ER_CLASSIFICATION AS TYPE,\n" +
629 653 " A.ER_DEAL AS TREATMENTOPINION,\n" +
630 654 " A.ER_CHECKDATE AS CHECKDATE,\n" +
... ... @@ -633,7 +657,8 @@
633 657 " A.ER_OPERTIME AS MODIFIED,\n" +
634 658 " H.E_HOSPITALID AS HOSPITALID,\n" +
635 659 " ABS(FLOOR((A.ER_CHECKDATE - B.P_LASTMENSTRUALPERIOD+1)/7)) AS CDUEWEEK,\n" +
636   - " B.P_ISVALID AS YN\n" +
  660 + " B.P_ISVALID AS YN,\n" +
  661 + " H.E_NAME AS CHECKDOCTOR\n" +
637 662 " \n" +
638 663 "FROM \n" +
639 664 " MOMMY_EXAMINERESULT A --初诊表\n" +
... ... @@ -645,6 +670,8 @@
645 670 "INNER JOIN MOMMY_EMPLOYEE H ON H.E_ISVALID=1 AND A.ER_CREATOR=H.E_ID\n" +
646 671 "--医院表\n" +
647 672 "INNER JOIN PLAT_HOSPITAL F ON F.H_ID=H.E_HOSPITALID AND F.H_ISVALID=1 \n" +
  673 + "--诊断表\n" +
  674 + "--INNER JOIN MOMMY_EXAMINEDIAGNOSIS N ON N.ED_TRIAGEORDERNO=A.ER_ID AND N.ED_IDENTIFYING=0\n" +
648 675 "--高危数据\n" +
649 676 "LEFT JOIN \n" +
650 677 " (\n" +
... ... @@ -669,8 +696,6 @@
669 696  
670 697 List<Map<String, Object>> list = getListDataBySql(sql);
671 698  
672   -
673   -
674 699 for(Map<String,Object> map : list)
675 700 {
676 701 AntenatalExaminationModel antxModel = new AntenatalExaminationModel();
677 702  
678 703  
679 704  
680 705  
... ... @@ -684,24 +709,30 @@
684 709 antxModel.setGongGao(getString(map.get("GONGGAO")));
685 710 antxModel.setAbdominalCircumference(getString(map.get("ABDOMINALCIRCUMFERENCE")));
686 711 antxModel.setEdema(getString(map.get("EDEMA")));
687   - antxModel.setTireNumber(getString(map.get("")));
  712 + antxModel.setTireNumber(getString(map.get("TIRENUMBER")));
688 713  
689   - antxModel.setTireData(JsonUtil.toList(getString(map.get("TIREDATA")),Placenta.class));
  714 + antxModel.setTireData(JsonUtil.toList(getString(map.get("TIREDATA")), Placenta.class));
690 715  
691 716 antxModel.setHemoglobin(getString(map.get("HEMOGLOBIN")));
692 717 antxModel.setUrineProtein(getString(map.get("URINEPROTEIN")));
693 718 antxModel.setbChao(getString(map.get("BCHAO")));
694 719 antxModel.setBloodSugar(getString(map.get("BLOODSUGAR")));
695 720 antxModel.setRiskFactor(getString(map.get("RISKFACTOR")));
696   - antxModel.setRiskScore(getString(map.get("")));
  721 + antxModel.setRiskScore(getString(map.get("RISKSCORE")));
697 722 antxModel.setOtherRisk(getString(map.get("")));
698 723 antxModel.setDiagnosis(getString(map.get("")));
699   - antxModel.setType(getString(map.get("TYPE")));
  724 + antxModel.setType(getString(map.get("")));
700 725 antxModel.setTypeYc(getString(map.get("")));
701 726 antxModel.setTreatmentOpinion(getString(map.get("TREATMENTOPINION")));
702 727 antxModel.setGuide(getString(map.get("")));
703 728  
704   - antxModel.setCheckDoctor(getString(map.get("")));
  729 + String checkDoctorName = getString(map.get("CHECKDOCTOR"));
  730 + if (checkDoctorName != null && !"".equals(checkDoctorName))
  731 + {
  732 + String id = getString(getMysqlSingleObjBySql("select id from users where name = '" + checkDoctorName + "'"));
  733 + antxModel.setCheckDoctor(id);
  734 + }
  735 +
705 736 antxModel.setCheckDate(getDate(map.get("CHECKDATE")));
706 737 antxModel.setNextCheckTime(getDate(map.get("NEXTCHECKTIME")));
707 738 antxModel.setYn(getInteger(map.get("YN")));
... ... @@ -718,7 +749,7 @@
718 749 }
719 750  
720 751 public static void syncBabyData() {
721   - List<Map<String, Object>> 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 ");
  752 + List<Map<String, Object>> 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 ");
722 753  
723 754  
724 755 MongoTemplate mongoTemplate = getMongoTemplate();
... ... @@ -778,8 +809,8 @@
778 809 model.setMproTypeId(id);
779 810 }
780 811  
781   - model.setMcertNo(getString(map.get("")));
782   - model.setMcertTypeId(getString(map.get("")));
  812 + model.setMcertNo(getString(map.get("PI_MOTHERPHONE")));
  813 + model.setMcertTypeId("57e0a21c0cf209b410a82cda");
783 814  
784 815 String mLevelId = getString(map.get("PI_MMCULTURE"));
785 816 if (mLevelId != null && !"".equals(mLevelId)) {
786 817  
... ... @@ -898,10 +929,8 @@
898 929  
899 930 public static void syncBabyCheck(String parentId,MongoTemplate mongoTemplate)
900 931 {
  932 + 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+"'";
901 933  
902   -
903   - String sql = " select * from MOMMY_PATIENTINFO MP left join MOMMY_CHILDEXAMINRECORD MC ON MP.PI_ID = MC.CER_PATIENTID WHERE MP.Pi_Id= '"+parentId+"'";
904   -
905 934 List<Map<String, Object>> list = getListDataBySql(sql);
906 935 for (Map<String, Object> map : list)
907 936 {
908 937  
909 938  
910 939  
... ... @@ -994,17 +1023,18 @@
994 1023 String[] arrs = result.split("|");
995 1024 for (String str : arrs)
996 1025 {
  1026 + String[] temps = str.split(":");
997 1027 if (str.startsWith("头"))
998 1028 {
999   - checkModel.setBilirubinHead(str.split(":")[1]);
  1029 + checkModel.setBilirubinHead(temps.length == 2 ? temps[1] : "");
1000 1030 }
1001 1031 else if (str.startsWith("胸"))
1002 1032 {
1003   - checkModel.setBilirubinChest(str.split(":")[1]);
  1033 + checkModel.setBilirubinChest(temps.length == 2 ? temps[1] : "");
1004 1034 }
1005 1035 else if (str.startsWith("腹"))
1006 1036 {
1007   - checkModel.setBilirubinBelly(str.split(":")[1]);
  1037 + checkModel.setBilirubinBelly(temps.length == 2 ? temps[1] : "");
1008 1038 }
1009 1039 }
1010 1040 }
... ... @@ -1039,7 +1069,7 @@
1039 1069  
1040 1070 }
1041 1071 }
1042   - checkModel.setBregma(result);
  1072 + checkModel.setBregma(JsonUtil.obj2JsonString(bregma));
1043 1073 }
1044 1074 else if ("出牙数".equals(itemName))
1045 1075 {
platform-resource/resources/config-test.properties View file @ c7ebdea
1 1 mongo.db.host=127.0.0.1
2 2 mongo.db.port=10001
3   -mongo.db.dbname=platform
  3 +mongo.db.dbname=sync-platform-data
4 4  
5 5 mongo.db.username=platform
6 6 mongo.db.password=platform123