海沧医保接口

business/base-service/src/main/java/com/yihu/jw/hospital/prescription/service/PrescriptionService.java

@@ -368,26 +368,24 @@ public class PrescriptionService extends BaseJpaService<WlyyPrescriptionDO, Pres
        if (StringUtils.isBlank(patNo)) {
            return null;
        }
        BasePatientDO patientDO = basePatientDao.findById(patient);
        logger.info("findOutpatientList patNo " + patNo);
        List<WlyyOutpatientVO> wlyyOutpatientVOList  =  entranceService.BS30025(patNo, null, startTime, endTime, demoFlag,ksdm);
        /*if (StringUtils.isNoneBlank(ksdm)){
            if (!ksdm.equalsIgnoreCase("1500010")){
                List<WlyyOutpatientVO> wlyyOutpatientVOList1  =  entranceService.BS30025(patNo, null, startTime, endTime, demoFlag,"1500010");
                if (wlyyOutpatientVOList!=null&&wlyyOutpatientVOList.size()!=0){
                    if(wlyyOutpatientVOList1!=null&&wlyyOutpatientVOList1.size()!=0){
                        for (WlyyOutpatientVO wlyyOutpatientVO:wlyyOutpatientVOList1){
                            logger.info("==="+wlyyOutpatientVO);
                            if (wlyyOutpatientVO!=null){
                                wlyyOutpatientVOList.add(wlyyOutpatientVO);
                            }
                        }
        List<WlyyOutpatientVO> wlyyOutpatientVOList1  =  entranceService.BS10016(patientDO.getIdcard(), null, startTime, endTime, demoFlag,"1500010");
        if (wlyyOutpatientVOList!=null&&wlyyOutpatientVOList.size()!=0){
            if(wlyyOutpatientVOList1!=null&&wlyyOutpatientVOList1.size()!=0){
                for (WlyyOutpatientVO wlyyOutpatientVO:wlyyOutpatientVOList1){
                    logger.info("==="+wlyyOutpatientVO);
                    if (wlyyOutpatientVO!=null){
                        wlyyOutpatientVOList.add(wlyyOutpatientVO);
                    }
                }else {
                    wlyyOutpatientVOList = new ArrayList<>();
                    wlyyOutpatientVOList = wlyyOutpatientVOList1;
                }
            }
        }*/
        }else {
            wlyyOutpatientVOList = new ArrayList<>();
            wlyyOutpatientVOList = wlyyOutpatientVOList1;
        }
        return wlyyOutpatientVOList;
    }

business/base-service/src/main/java/com/yihu/jw/hospital/prescription/service/entrance/EntranceService.java

@@ -309,6 +309,7 @@ public class EntranceService {
        //剔除非激活的卡
        JSONArray res = ConvertUtil.convertListEnvelopByString(resp);
        logger.info("res==="+res.toString());
        if (res != null && res.size() > 0) {
            Iterator it = res.iterator();
            if (it.hasNext()) {
@@ -789,10 +790,10 @@ public class EntranceService {
     * @return
     * @throws Exception
     */
    public List<WlyyOutpatientVO> BS10016(String PAT_NO, String conNo, String startTime, String endTime, boolean demoFlag ,String ksdm) throws Exception {
    public List<WlyyOutpatientVO> BS10016(String idcard, String conNo, String startTime, String endTime, boolean demoFlag ,String ksdm) throws Exception {
        System.out.println("ksdm="+ksdm);
        String fid = "BS10016";
        logger.info("EntranceService " + fid + " PAT_NO :" + PAT_NO + " conNo:" + conNo + " startTime:" + startTime + " endTime:" + endTime);
        logger.info("EntranceService " + fid + " PAT_NO :" + idcard + " conNo:" + conNo + " startTime:" + startTime + " endTime:" + endTime);
        String resp = "";
        String orgCode = "350211A1002";
@@ -807,9 +808,9 @@ public class EntranceService {
            sbs.append("<MessageHeader><Fid>" + fid + "</Fid><MsgDate>" + DateUtil.dateToStr(new Date(), DateUtil.YYYY_MM_DD_HH_MM_SS) + "</MsgDate><SourceSysCode>" + sourceSysCode + "</SourceSysCode><TargetSysCode>" + targetSysCode + "</TargetSysCode></MessageHeader>");
            //查询信息拼接
            sbs.append("<MsgInfo><onceFlag>1</onceFlag><startNum>1</startNum><endNum>50000</endNum><Msg>");
            if (StringUtils.isNotBlank(PAT_NO)) {
            if (StringUtils.isNotBlank(idcard)) {
                /*sbs.append("<query compy=\"=\" item=\"PAT_NO\" splice=\"and\" value=\"'" + PAT_NO + "'\"/>");*/
                sbs.append(" and Pat_Admit_ID = '"+PAT_NO+"' ");
                sbs.append(" and Id_Num = '"+idcard+"' ");
            }
            if (StringUtils.isNotBlank(startTime)) {
                /*sbs.append("<query compy=\"&gt;=\" item=\"CON_DATE\" splice=\"and\" value=\"'" + startTime + "'\"/>");*/
@@ -833,7 +834,8 @@ public class EntranceService {
            logger.info("resp===" + resp);
            resp = MqSdkUtil.xml2jsonArrayRootRow(resp);
        }
        JSONArray jsonArray = ConvertUtil.convertListEnvelopInRow(resp);
        logger.info("resp===="+resp);
        JSONArray jsonArray = ConvertUtil.convertListEnvelopInBodyAndRow(resp);
        if (null == jsonArray) {
            return null;        }
        List<WlyyOutpatientVO> wlyyOutpatientVOS = new ArrayList<>();
@@ -847,21 +849,12 @@ public class EntranceService {
                wlyyOutpatientVO.setHospitalName(orgName);
                wlyyOutpatientVO.setWinNo("6");
                wlyyOutpatientVO.setAdmNo(null == jsonObjectMgsInfo.get("Admit_Num") ? "" : jsonObjectMgsInfo.get("Admit_Num") + "");
                wlyyOutpatientVO.setRegisterNo(null == jsonObjectMgsInfo.get("REGISTER_SN") ? "" : jsonObjectMgsInfo.get("REGISTER_SN") + "");
                wlyyOutpatientVO.setDept(null == jsonObjectMgsInfo.get("ADM_SPEC") ? "" : jsonObjectMgsInfo.get("ADM_SPEC") + "");
                wlyyOutpatientVO.setDeptName(null == jsonObjectMgsInfo.get("ADM_SPEC_NAME") ? "" : jsonObjectMgsInfo.get("ADM_SPEC_NAME") + "");
                String patNo = null != jsonObjectMgsInfo.get("PAT_NO") ? jsonObjectMgsInfo.get("PAT_NO").toString() : "";
                String patientName = null != jsonObjectMgsInfo.get("PAT_NAME") ? jsonObjectMgsInfo.get("PAT_NAME").toString() : "";
                PatientMappingDO patientMappingDo = new PatientMappingDO();
                if (StringUtils.isNotBlank(patNo)) {
                    patientMappingDo = patientMappingDao.findByMappingCodeAndSource(patNo.trim(), "1");
                    patNo = null == patientMappingDo ? null : patientMappingDo.getPatient();
                    patientName = null == patientMappingDo ? null : patientMappingDo.getPatientName();
                }
                wlyyOutpatientVO.setPatient(patNo);
                wlyyOutpatientVO.setDept(null == jsonObjectMgsInfo.get("Discharge_Dept_Code") ? "" : jsonObjectMgsInfo.get("Discharge_Dept_Code") + "");
               /* wlyyOutpatientVO.setDeptName(null == jsonObjectMgsInfo.get("ADM_SPEC_NAME") ? "" : jsonObjectMgsInfo.get("ADM_SPEC_NAME") + "");*/
                String patientName = null != jsonObjectMgsInfo.get("Pat_Name") ? jsonObjectMgsInfo.get("Pat_Name").toString() : "";
                wlyyOutpatientVO.setPatientName(patientName);
                wlyyOutpatientVO.setConNo(null == jsonObjectMgsInfo.get("CON_NO") ? "" : jsonObjectMgsInfo.get("CON_NO") + "");
                String doctor = null == jsonObjectMgsInfo.get("CON_DOC") ? "" : jsonObjectMgsInfo.get("CON_DOC") + "";
                String doctor = null == jsonObjectMgsInfo.get("Admit_Dr_Code") ? "" : jsonObjectMgsInfo.get("Admit_Dr_Code") + "";
                //转化医生
                String mappingCode = doctor.trim();
@@ -873,50 +866,25 @@ public class EntranceService {
                    }
                }
                wlyyOutpatientVO.setDoctor(doctorCode);
                wlyyOutpatientVO.setDoctorName(null == jsonObjectMgsInfo.get("CON_DOC_NAME") ? "" : jsonObjectMgsInfo.get("CON_DOC_NAME") + "");
                wlyyOutpatientVO.setDoctorName(null == jsonObjectMgsInfo.get("Admit_Dr_Name") ? "" : jsonObjectMgsInfo.get("Admit_Dr_Name") + "");
//                wlyyOutpatientVO.setIdcard(null == jsonObjectMgsInfo.get("social_no") ? "" : jsonObjectMgsInfo.get("social_no") + "");
                wlyyOutpatientVO.setMjz(null == jsonObjectMgsInfo.get("MJZ") ? "" : jsonObjectMgsInfo.get("MJZ") + "");
                /*wlyyOutpatientVO.setMjz(null == jsonObjectMgsInfo.get("MJZ") ? "" : jsonObjectMgsInfo.get("MJZ") + "");*/
                //主诊断 毒蛇咬伤&T63.001
                String[] icdName = jsonObjectMgsInfo.get("icd_name").toString().split("&");
                String[] diagTwo = jsonObjectMgsInfo.get("diag_two").toString().split("&");
                String[] diagThree = jsonObjectMgsInfo.get("diag_three").toString().split("&");
                String[] diagFour = jsonObjectMgsInfo.get("diag_four").toString().split("&");
                String[] diagFive = jsonObjectMgsInfo.get("diag_five").toString().split("&");
                String icdcodes = "";
               /* String icdcodes = "";
                String icdNames = "";
                if (icdName.length > 1) {
                    icdcodes += icdName[1];
                    icdNames += icdName[0];
                }
                if (diagTwo.length > 1) {
                    icdcodes += "," + diagTwo[1];
                    icdNames += "," + diagTwo[0];
                }
                if (diagThree.length > 1) {
                    icdcodes += "," + diagThree[1];
                    icdNames += "," + diagThree[0];
                }
                if (diagFour.length > 1) {
                    icdcodes += "," + diagFour[1];
                    icdNames += "," + diagFour[0];
                }
                if (diagFive.length > 1) {
                    icdcodes += "," + diagFive[1];
                    icdNames += "," + diagFive[0];
                }
                }*/
//                String icds = null == jsonObjectMgsInfo.get("icd_name") ? "" : jsonObjectMgsInfo.get("icd_name") + "";
//                String[] icdcodeAndName = icds.split("&");
//                wlyyOutpatientVO.setIcd10(icdcodeAndName.length > 1 ? icdcodeAndName[1].toString() : "");
//                wlyyOutpatientVO.setIcd10Name(icdcodeAndName.length > 0 ? icdcodeAndName[0].toString() : "");
                wlyyOutpatientVO.setIcd10(icdcodes);
                wlyyOutpatientVO.setIcd10Name(icdNames);
                wlyyOutpatientVO.setIcd10(jsonObjectMgsInfo.get("Admit_Diag_Code").toString());
                wlyyOutpatientVO.setIcd10Name(jsonObjectMgsInfo.get("Admit_Diag_Name").toString());
                String admDate = null == jsonObjectMgsInfo.get("ADM_DAT") ? "" : jsonObjectMgsInfo.get("ADM_DAT") + "";
                String conDate = null == jsonObjectMgsInfo.get("CON_DATE") ? "" : jsonObjectMgsInfo.get("CON_DATE") + "";
                String admDate = null == jsonObjectMgsInfo.get("Discharge_Date") ? "" : jsonObjectMgsInfo.get("Discharge_Date") + "";
                String conDate = null == jsonObjectMgsInfo.get("Discharge_Date") ? "" : jsonObjectMgsInfo.get("Discharge_Date") + "";
                wlyyOutpatientVO.setAdmDate(DateUtil.strToDate(admDate, DateUtil.YYYY_MM_DD_HH_MM_SS_));
                wlyyOutpatientVO.setConDate(DateUtil.strToDate(conDate, DateUtil.YYYY_MM_DD_HH_MM_SS_));
                wlyyOutpatientVOS.add(wlyyOutpatientVO);

business/base-service/src/main/java/com/yihu/jw/hospital/prescription/service/entrance/util/ConvertUtil.java

@@ -152,6 +152,42 @@ public class ConvertUtil {
        }
    }
    /**
     * 返回对象数组数据解析
     * @param obj
     * @return
     * @throws Exception
     */
    public static  JSONArray convertListEnvelopInBodyAndRow(String obj)throws Exception{
        JSONObject jsonObject=JSONObject.fromObject(obj);
        JSONArray jsonArray=new JSONArray();
        if(null!=jsonObject&&"1".equals(jsonObject.get("code").toString())){
            JSONArray jsonObjectMgsInfo=(JSONArray)jsonObject.get("MsgInfo");
            if(null!=jsonObjectMgsInfo){
                for (Object object : jsonObjectMgsInfo) {
                    JSONObject jsonObjectBody=(JSONObject)object;
                    Object objectBody=jsonObjectBody.get("body");
                    if(objectBody instanceof JSONArray){
                        net.sf.json.JSONArray jsonArrayBody = (net.sf.json.JSONArray) jsonObjectBody.get("body");
                        for (Object objectBodySub : jsonArrayBody) {
                            jsonArray.add(objectBodySub);
                        }
                    }else {
                        Object rowObj = jsonObjectBody.getJSONObject("body").getJSONObject("row");
                        jsonArray.add(rowObj) ;
                    }
                }
                return jsonArray;
            }else {
                return null;
            }
        }else {
            return  null;
        }
    }
    /**
     * 返回对象数组数据解析
     * @param obj

business/base-service/src/mqConfig/esbmq-config.xml

@@ -23,6 +23,8 @@
				<BS16017_1>EwellQ.S60.BS16017.GET</BS16017_1>
				<BS30025_0>EwellQ.S60.BS30025.PUT</BS30025_0>
				<BS30025_1>EwellQ.S60.BS30025.GET</BS30025_1>
				<BS10016_0>EwellQ.S60.BS10016.PUT</BS10016_0>
				<BS10016_1>EwellQ.S60.BS10016.GET</BS10016_1>
				<MS30001_0>EwellQ.S60.MS30001.PUT</MS30001_0>
				<MS30001_1>EwellQ.S60.MS30001.GET</MS30001_1>
				<BS10110_0>EwellQ.S60.BS10110.PUT</BS10110_0>

business/base-service/src/mqConfig/mqdata/BS15018.json

@@ -8,7 +8,8 @@
		"CARD_TYPE": "2",
		"CARD_TYPE_NAME": "社保卡",
		"social_no": "350211198411053024",
			"name":"白海灵"
			"name":"白海灵",
			"phone_no":null
		},
	{
		"PAT_NO": "P5616242-0",
@@ -18,7 +19,8 @@
		"CARD_TYPE": "2",
		"CARD_TYPE_NAME": "社保卡",
		"social_no": "350211198411053024",
		"name":"白海灵"
		"name":"白海灵",
		"phone_no":null
	},
	{
		"PAT_NO": "P5616242-1",
@@ -28,6 +30,7 @@
		"CARD_TYPE": "2",
		"CARD_TYPE_NAME": "社保卡",
		"social_no": "230203195211271426",
		"name":"王金妮"
		"name":"王金妮",
		"phone_no":null
	}]
}

svr/svr-internet-hospital-entrance/src/main/java/com/yihu/jw/entrance/controller/MqSdkController.java

@@ -101,6 +101,20 @@ public class MqSdkController extends EnvelopRestEndpoint {
        return success(obj);
    }
    @GetMapping(value = "/BS10016")
    @ApiOperation(value = " 查询某个时间段的患者出院就诊记录 V1.00")
    public ListEnvelop BS10016(@ApiParam(name = "patNo", value = "身份证")
                               @RequestParam(value = "patNo", required = false) String patNo,
                               @ApiParam(name = "conNo", value = "就诊次数")
                               @RequestParam(value = "conNo", required = false) String conNo,
                               @ApiParam(name = "startTime", value = "开始时间")
                               @RequestParam(value = "startTime", required = false) String startTime,
                               @ApiParam(name = "endTime", value = "结束时间")
                               @RequestParam(value = "endTime", required = false) String endTime) throws Exception {
        List<WlyyOutpatientVO> obj = entranceService.BS10016(patNo,conNo, startTime, endTime, demoFlag,null);
        return success(obj);
    }
    @GetMapping(value = "/MS30001")
    @ApiOperation(value = "医院药品字典 V1.00--弃用")
    public ListEnvelop MS30001(@ApiParam(name = "DRUG_CODE", value = "字典编码")

svr/svr-internet-hospital/src/main/resources/application.yml

@@ -206,7 +206,7 @@ fastDFS:
fast-dfs:
  tracker-server: 172.26.0.110:22122 #服务器地址
wechat:
  id: xm_mlwyy_wx  # base库中,wx_wechat 的id字段
  id: xm_zsyy_wx  # base库中,wx_wechat 的id字段
  flag: false #演示环境  true走Mysql数据库  false走Oracle
  url: http://172.16.100.37:8090/hospitalPortal-sms/sms/sendMessage
# 短信验证码发送的客户端标识,居民端