Index: ssts-web/src/main/webapp/disinfectsystem/config/jmszxyy/spring/HIS.xml
===================================================================
diff -u -r29371 -r38602
--- ssts-web/src/main/webapp/disinfectsystem/config/jmszxyy/spring/HIS.xml	(.../HIS.xml)	(revision 29371)
+++ ssts-web/src/main/webapp/disinfectsystem/config/jmszxyy/spring/HIS.xml	(.../HIS.xml)	(revision 38602)
@@ -67,34 +67,10 @@
        </property>
     </bean>
    
-
-     <!-- 诊疗号 -->
-    <bean id="findPatientInfoByTreatmentNumDao" class="org.mybatis.spring.mapper.MapperFactoryBean">  
-       <property name="mapperInterface"  
-           value="com.forgon.disinfectsystem.datasynchronization.dao.FindPatientInfoByTreatmentNumDao" />  
-       <property name="sqlSessionFactory">
-            <bean class="org.mybatis.spring.SqlSessionFactoryBean">
-                <property name="dataSource" ref="hisDataSource" />
-                <property name="mapperLocations" value="file:///#{T(com.forgon.tools.Path).webROOT}/disinfectsystem/config/jmszxyy/interfaces/mybatis/FindPatientInfoByTreatmentNumMapper.xml" />
-                <property name="typeAliasesPackage" value="com.forgon.disinfectsystem.datasynchronization.model" />
-            </bean>
-       </property>
-    </bean>
+	<!-- 住院号接口 -->
+    <bean id="findPatientInfoByHospitalNumDao" class="com.forgon.disinfectsystem.mq.dao.jmszxyy.FindPatientInfoByHospitalNumDaoImpl"></bean>
     
+    <!-- 诊疗号接口 -->
+    <bean id="findPatientInfoByTreatmentNumDao" class="com.forgon.disinfectsystem.mq.dao.jmszxyy.FindPatientInfoByTreatmentNumDaoImpl"></bean>
     
-   
-    <bean id="findPatientInfoByHospitalNumDao" class="org.mybatis.spring.mapper.MapperFactoryBean">  
-       <property name="mapperInterface"  
-           value="com.forgon.disinfectsystem.datasynchronization.dao.FindPatientInfoByHospitalNumDao" />  
-       <property name="sqlSessionFactory">
-            <bean class="org.mybatis.spring.SqlSessionFactoryBean">
-                <property name="dataSource" ref="hisDataSource" />
-                <property name="mapperLocations" value="file:///#{T(com.forgon.tools.Path).webROOT}/disinfectsystem/config/jmszxyy/interfaces/mybatis/FindPatientInfoByHospitalNumMapper.xml" />
-                <property name="typeAliasesPackage" value="com.forgon.disinfectsystem.datasynchronization.model" />
-            </bean>
-       </property>
-    </bean>
-
-    
-    
 </beans>
\ No newline at end of file
Index: ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/mq/dao/jmszxyy/FindPatientInfoByTreatmentNumDaoImpl.java
===================================================================
diff -u
--- ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/mq/dao/jmszxyy/FindPatientInfoByTreatmentNumDaoImpl.java	(revision 0)
+++ ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/mq/dao/jmszxyy/FindPatientInfoByTreatmentNumDaoImpl.java	(revision 38602)
@@ -0,0 +1,177 @@
+package com.forgon.disinfectsystem.mq.dao.jmszxyy;
+
+import java.util.LinkedList;
+import java.util.List;
+
+import org.apache.commons.collections4.CollectionUtils;
+import org.apache.commons.lang.StringUtils;
+import org.apache.log4j.Logger;
+import org.dom4j.Document;
+import org.dom4j.DocumentHelper;
+import org.dom4j.Node;
+import org.dom4j.XPath;
+
+import com.forgon.disinfectsystem.datasynchronization.dao.FindPatientInfoByTreatmentNumDao;
+import com.forgon.disinfectsystem.datasynchronization.model.PatientInfoVO;
+import com.forgon.tools.date.DateTools;
+
+/**
+ * 查询 BS10085 诊疗卡信息JMSZXYY-105
+ */
+public class FindPatientInfoByTreatmentNumDaoImpl implements FindPatientInfoByTreatmentNumDao {
+	
+	private Logger logger = Logger.getLogger(this.getClass());
+	
+	@Override
+	public PatientInfoVO[] findPatientInfoByTreatmentNum(String treatmentNum) {
+		if(StringUtils.isBlank(treatmentNum)){
+			logger.debug("诊疗号为空！");
+			return null;
+		}
+		
+		List<PatientInfoVO> patientInfoVOList = null;
+		try {
+			//请求响应消费方:一次请求，一条响应    或者 推送发送方：一次推送，一条推送结果(EHSB平台提供的平台接入方法)
+			logger.debug(String.format("开始查询%s诊疗卡信息（诊疗卡信息接口）接口", MQHelper.treatmentNumFID));
+			//请求信息
+			String msgbody = buildTreatmentNumMsgbody(treatmentNum);
+			logger.debug(String.format("%s诊疗卡信息（诊疗卡信息接口）接口请求信息：%s", MQHelper.treatmentNumFID, msgbody));
+			//调用接口
+			String responce = MQHelper.composePutAndGetMsg(msgbody);
+			/*StringBuffer responceBuf = new StringBuffer();
+			responceBuf.append("<ESBEntry><MessageHeader><Fid>BS10085</Fid><OrderNo>BS10085S90001</OrderNo><SourceSysCode>S00</SourceSysCode><TargetSysCode>S90</TargetSysCode><HospCode>JMZX</HospCode><MsgDate>2024-07-09 16:18:47.630</MsgDate></MessageHeader>");
+			responceBuf.append("<RetInfo><RetCode>1</RetCode><RetCon>query success</RetCon></RetInfo><ResponseOption><currentPage>1</currentPage> <totalPage>1</totalPage></ResponseOption>");
+			responceBuf.append("<MsgInfo><Msg><![CDATA[<msg><body><row action='select'><PAT_INDEX_NO>-391259</PAT_INDEX_NO><TREAT_CARD_NO>20403920</TREAT_CARD_NO><EFFECTIVE_DATE>2023-07-17T18:38:42</EFFECTIVE_DATE><EXPIRATION_DATE/>");
+			responceBuf.append("<TREAT_CARD_NO_ALL>20403920</TREAT_CARD_NO_ALL><CARD_TYPE/><PAT_NAME>测试病人</PAT_NAME><PHYSI_SEX_CODE>1</PHYSI_SEX_CODE><PHYSI_SEX_NAME>男</PHYSI_SEX_NAME><DATE_BIRTH>1994-03-23</DATE_BIRTH><NATION_CODE>156</NATION_CODE>");
+			responceBuf.append("<NATION_NAME>中国</NATION_NAME><ETHNIC_CODE>01</ETHNIC_CODE><ETHNIC_NAME>汉族</ETHNIC_NAME><MARITAL_STATUS_CODE>U</MARITAL_STATUS_CODE><MARITAL_STATUS_NAME>未知</MARITAL_STATUS_NAME><OCCUPATION_CATEG_CODE>99</OCCUPATION_CATEG_CODE>");
+			responceBuf.append("<OCCUPATION_CATEG_NAME>不详或不便分类的其他劳动者</OCCUPATION_CATEG_NAME><PHONE_NO>19925503991</PHONE_NO><EMAIL/><CONTACT_ADDR>广东省江门市蓬江区白沙街道</CONTACT_ADDR><COMPANY/><ID_NUMBER>440701199403230323</ID_NUMBER>");
+			responceBuf.append("<INVALID_FLAG>N</INVALID_FLAG></row></body></msg>]]></Msg></MsgInfo></ESBEntry>");
+			String responce = responceBuf.toString();*/
+			
+			logger.debug(String.format("成功接收%s诊疗卡信息（诊疗卡信息接口）接口返回信息：%s", MQHelper.treatmentNumFID, responce));
+			//解析返回参数
+			patientInfoVOList = buildTreatmentPatientInfoVO(responce);
+			if(CollectionUtils.isEmpty(patientInfoVOList)){
+				logger.debug(String.format("不存在诊疗号为%s的%s诊疗卡信息", treatmentNum, MQHelper.treatmentNumFID));
+			}else{
+				PatientInfoVO[] array = new PatientInfoVO[patientInfoVOList.size()];
+				for(int i=0;i<patientInfoVOList.size();i++){
+					array[i] = patientInfoVOList.get(i);
+				}
+				return array;
+			}
+		} catch (Exception e) {
+			e.printStackTrace();
+			logger.debug(String.format("%s诊疗卡信息（诊疗卡信息接口）接口查询失败：%s" , MQHelper.treatmentNumFID, e.getMessage()));
+		}
+		
+		return null;
+	}
+
+	/**
+	 * 解析 BS10085 诊疗卡信息
+	 * @param responce
+	 * @return
+	 * @throws Exception 
+	 */
+	@SuppressWarnings("unchecked")
+	private List<PatientInfoVO> buildTreatmentPatientInfoVO(String responce) throws Exception {
+
+		if(StringUtils.isBlank(responce)){
+			throw new RuntimeException("接口返回的参数为空！");
+		}
+
+		// 开始解析
+		Document doc = DocumentHelper.parseText(responce);
+		// 查询结果返回状态
+		String RetCodeXpath = "/ESBEntry/RetInfo/RetCode";
+		String RetCode = MQHelper.processDataByXpath(doc, RetCodeXpath);
+		String RetConXpath = "/ESBEntry/RetInfo/RetCon";
+		String RetCon = MQHelper.processDataByXpath(doc, RetConXpath);
+		if (!MQHelper.RET_CODE_SUCCESS.equals(RetCode)) {
+			throw new RuntimeException("接口返回信息为" + RetCon);
+		}
+		// 解析住院病人信息并入库
+		String MsgXpath = "/ESBEntry/MsgInfo/Msg";	// 返回结果可能存在多条住院病人信息
+		XPath xpath = doc.createXPath(MsgXpath);
+		List<Node> nodeList2 = xpath.selectNodes(doc, xpath);
+		if (nodeList2 == null || nodeList2.size() == 0) {
+			throw new RuntimeException("查询返回的数据不包含/ESBEntry/MsgInfo/Msg节点！");
+		}
+		List<PatientInfoVO> patientInfoVOList = new LinkedList<PatientInfoVO>();
+		// 解析返回信息中所有住院病人信息
+		for (int i = 1; i <= nodeList2.size(); i++) {
+			String msgXpath = "/ESBEntry/MsgInfo/Msg[" + i + "]";
+			String patientInfo = MQHelper.processDataByXpath(doc, msgXpath); // 住院病人信息
+			if (StringUtils.isNotBlank(patientInfo)) {
+				Document document = DocumentHelper.parseText(patientInfo);
+				
+				String clinicNumberXpath = "/msg/body/row/TREAT_CARD_NO";
+				String patientNameXpath = "/msg/body/row/PAT_NAME";
+				String patientSexXpath = "/msg/body/row/PHYSI_SEX_NAME";
+				String patientIDCardXpath = "/msg/body/row/ID_NUMBER";
+				
+				String clinicNumber = MQHelper.processDataByXpath(document, clinicNumberXpath);
+				String patientName = MQHelper.processDataByXpath(document, patientNameXpath);
+				String patientSex = MQHelper.processDataByXpath(document, patientSexXpath);
+				String patientIDCard = MQHelper.processDataByXpath(document, patientIDCardXpath);
+
+				
+				PatientInfoVO vo = new PatientInfoVO();
+				vo.setClinicNumber(clinicNumber);
+				vo.setPatientName(patientName);
+				vo.setPatientSex(patientSex);
+				vo.setPatientIDCard(patientIDCard);
+
+				patientInfoVOList.add(vo);
+			}
+		}
+
+		if(CollectionUtils.isEmpty(patientInfoVOList)){
+			throw new RuntimeException("返回的诊疗好患者信息为空！");
+		}
+
+		return patientInfoVOList;
+	}
+
+	/**
+	 * 构建BS10085 诊疗卡信息接口请求信息
+	 * @param treatmentNum
+	 * @return
+	 */
+	private String buildTreatmentNumMsgbody(String treatmentNum) {
+		StringBuffer msgbody = new StringBuffer();
+		msgbody.append("<ESBEntry>");
+		msgbody.append("<AccessControl>");
+		msgbody.append("<SysFlag>1</SysFlag>");
+		msgbody.append("<UserName>" + MQHelper.userName + "</UserName>");
+		msgbody.append("<Password>" + MQHelper.password + "</Password>");
+		msgbody.append("<Fid>" + MQHelper.treatmentNumFID + "</Fid>");
+		msgbody.append("<OrderNo>" + MQHelper.treatmentNumOrderNo + "</OrderNo>");
+		msgbody.append("</AccessControl>");
+		msgbody.append("<MessageHeader>");
+		msgbody.append("<Fid>" + MQHelper.treatmentNumFID + "</Fid>");
+		msgbody.append("<OrderNo>" + MQHelper.treatmentNumOrderNo + "</OrderNo>");
+		msgbody.append("<SourceSysCode>S90</SourceSysCode>");
+		msgbody.append("<TargetSysCode>S00</TargetSysCode>");
+		msgbody.append("<HospCode>JMZX</HospCode>");
+		//2024-06-28 09:08:04
+		msgbody.append("<MsgDate>" + DateTools.getCurrentDayByFormat(DateTools.COMMON_DATE_HMS) + "</MsgDate>");
+		msgbody.append("</MessageHeader>");
+		msgbody.append("<RequestOption>");
+		msgbody.append("<triggerData>0</triggerData>");
+		msgbody.append("<dataAmount>500</dataAmount>");
+		msgbody.append("</RequestOption>");
+		msgbody.append("<MsgInfo flag=\"1\" >");
+		msgbody.append("<Msg></Msg>");
+		msgbody.append("<distinct value=\"0\"/>");
+		msgbody.append("<query item=\"TREAT_CARD_NO\" compy=\"=\" value=\"'" + treatmentNum + "'\" splice=\"AND\"/>");
+		msgbody.append("</MsgInfo>");
+		msgbody.append("<GroupInfo flag=\"0\">");
+		msgbody.append("<AS ID=\"\" linkField=\"\"/>");
+		msgbody.append("</GroupInfo>");
+		msgbody.append("</ESBEntry>");
+		return msgbody.toString();
+	}
+
+}
Index: ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/mq/dao/jmszxyy/MQHelper.java
===================================================================
diff -u
--- ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/mq/dao/jmszxyy/MQHelper.java	(revision 0)
+++ ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/mq/dao/jmszxyy/MQHelper.java	(revision 38602)
@@ -0,0 +1,93 @@
+package com.forgon.disinfectsystem.mq.dao.jmszxyy;
+
+import org.apache.commons.lang3.StringUtils;
+import org.dom4j.Document;
+import org.dom4j.Node;
+import org.dom4j.XPath;
+
+import com.ewell.sdk.business.EwellServiceTool;
+import com.ewell.sdk.domain.MessageEntity;
+import com.ewell.sdk.exception.SDKException;
+
+/**
+ * 百慧MQ信息队列服务的患者信息接口开发JMSZXYY-105
+ */
+public class MQHelper {
+	
+	public static final String queueManagerName = "QMGR.S90";
+	
+	public static final String RET_CODE_SUCCESS = "1";
+	
+	public static final String userName = "XDGY";
+	
+	public static final String password = "XDGY123456";
+	
+	/**
+	 * BS30005 手术申请单信息接口
+	 */
+	public static final String hospitalNumFID = "BS30005";
+	
+	public static final String hospitalNumOrderNo = "BS30005S90001";
+	
+	/**
+	 * BS10091 在院患者信息接口
+	 */
+	public static final String patientInfoFID = "BS10091";
+	
+	public static final String patientInfoOrderNo = "BS10091S90001";
+	
+	/**
+	 * BS10085诊疗卡信息的fid
+	 */
+	public static final String treatmentNumFID = "BS10085";
+	
+	public static final String treatmentNumOrderNo = "BS10085S90001";
+	
+	/**
+	 * 调用接口获取返回信息
+	 * @param msgbody
+	 * @return
+	 */
+	public static String composePutAndGetMsg(String msgbody) {
+		String responce = null;
+		EwellServiceTool ewellServiceTool = null;
+		try {
+			ewellServiceTool = new EwellServiceTool();
+			MessageEntity messageEntity = ewellServiceTool.composePutAndGetMsg(queueManagerName, null, 5000, msgbody);
+			if(messageEntity != null){
+				responce = messageEntity.getMsg();
+			}
+		} catch (Exception e) {
+			e.printStackTrace();
+			throw new RuntimeException(e.getMessage());
+		} finally {
+			if(ewellServiceTool != null){
+				try {
+					ewellServiceTool.disconnect();
+				} catch (SDKException e) {
+					e.printStackTrace();
+				}
+			}
+		}
+		return responce;
+	}
+	
+	/**
+	 * 根据document和Xpath表达式解析数据
+	 * @param document
+	 * @param nameSpaceURIMap
+	 * @param xpathExp
+	 * @return
+	 */
+	public static String processDataByXpath(Document document, String xpathExp) {
+		if ((StringUtils.isNotBlank(xpathExp)) && (document != null)) {
+			XPath xpath = document.createXPath(xpathExp);
+			Node node = xpath.selectSingleNode(document);
+			if (node != null) {
+				return node.getStringValue();
+			}
+		}
+		return null;
+	}
+
+}
Index: ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/mq/dao/jmszxyy/FindPatientInfoByHospitalNumDaoImpl.java
===================================================================
diff -u
--- ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/mq/dao/jmszxyy/FindPatientInfoByHospitalNumDaoImpl.java	(revision 0)
+++ ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/mq/dao/jmszxyy/FindPatientInfoByHospitalNumDaoImpl.java	(revision 38602)
@@ -0,0 +1,435 @@
+package com.forgon.disinfectsystem.mq.dao.jmszxyy;
+
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.Calendar;
+import java.util.Comparator;
+import java.util.Date;
+import java.util.LinkedList;
+import java.util.List;
+
+import org.apache.commons.collections4.CollectionUtils;
+import org.apache.commons.lang3.StringUtils;
+import org.apache.log4j.Logger;
+import org.dom4j.Document;
+import org.dom4j.DocumentHelper;
+import org.dom4j.Node;
+import org.dom4j.XPath;
+
+import com.forgon.disinfectsystem.datasynchronization.dao.FindPatientInfoByHospitalNumDao;
+import com.forgon.disinfectsystem.datasynchronization.model.PatientInfoVO;
+import com.forgon.tools.date.DateTools;
+
+/**
+ * 先查询 BS30005 手术申请单信息（手术患者信息接口）,查不到手术申请单信息再查询  BS10091 在院患者信息JMSZXYY-105
+ */
+public class FindPatientInfoByHospitalNumDaoImpl implements FindPatientInfoByHospitalNumDao {
+	
+	private Logger logger = Logger.getLogger(this.getClass());
+	
+	@Override
+	public PatientInfoVO[] findPatientInfoByHospitalNum(String hospitalNum) {
+		if (StringUtils.isBlank(hospitalNum)) {
+			logger.debug("住院号为空！");
+			return null;
+		}
+		List<PatientInfoVO> patientInfoVOList = null;
+		try {
+			//请求响应消费方:一次请求，一条响应    或者 推送发送方：一次推送，一条推送结果(EHSB平台提供的平台接入方法)
+			logger.debug(String.format("开始查询%s手术申请单信息(住院病人)接口", MQHelper.hospitalNumFID));
+			//请求信息
+			String msgbody = buildOperationApplyMsgbody(hospitalNum);
+			logger.debug(String.format("%s手术申请单信息(住院病人)接口请求信息：%s", MQHelper.hospitalNumFID, msgbody));
+			//调用接口
+			String responce = MQHelper.composePutAndGetMsg(msgbody);
+			/*StringBuffer responceBuf = new StringBuffer();
+			responceBuf.append("<ESBEntry><MessageHeader><Fid>BS30005</Fid><OrderNo>BS30005S90001</OrderNo><SourceSysCode>S00</SourceSysCode><TargetSysCode>S90</TargetSysCode><HospCode>JMZX</HospCode><MsgDate>2024-07-09 17:32:14.350</MsgDate></MessageHeader>");
+			responceBuf.append("<RetInfo><RetCode>1</RetCode><RetCon>query success</RetCon></RetInfo><ResponseOption><currentPage>1</currentPage><totalPage>1</totalPage></ResponseOption><MsgInfo>");
+			responceBuf.append("<Msg><![CDATA[<msg><body><row action='select'><OUTHOSP_INDEX_NO/><VISIT_CARD_NO>22286286</VISIT_CARD_NO><OUTHOSP_NO/><INHOSP_INDEX_NO>1000007</INHOSP_INDEX_NO><MR_NO>1000007</MR_NO><ANAMNESIS_NO>1000007</ANAMNESIS_NO><INHOSP_NUM>1</INHOSP_NUM><INHOSP_NO>2024-0449353-0</INHOSP_NO><PAT_INDEX_NO>-2251173</PAT_INDEX_NO><ELECTR_REQUISITION_NO>36055</ELECTR_REQUISITION_NO><ORDER_NO>4426946</ORDER_NO><ORDER_GROUP_NO/><SURGERY_APPLY_DATE>2024-06-23T08:00:00</SURGERY_APPLY_DATE><SURGERY_PROOF_DATE/><SURGERY_OPER_CODE>51.1104</SURGERY_OPER_CODE><SURGERY_OPER_NAME>腹腔镜下胆总管探查术</SURGERY_OPER_NAME><SURGERY_PAT_RESOURCE_CODE>1E+0</SURGERY_PAT_RESOURCE_CODE><SURGERY_PAT_RESOURCE_NAME>门诊</SURGERY_PAT_RESOURCE_NAME><SELECTIVE_SURGERY_FLAG>1E+0</SELECTIVE_SURGERY_FLAG><ISOLATE_FLAG/><VALUATION_FLAG/><REQUISITION_STATUS>NO_SCHEDULE</REQUISITION_STATUS><NOTE>1424</NOTE><SURGERY_LEVEL_CODE>3</SURGERY_LEVEL_CODE><SURGERY_LEVEL_NAME>三级手术</SURGERY_LEVEL_NAME><SURGERY_NUM/><APPLY_DR_INDEX_NO>5354</APPLY_DR_INDEX_NO><APPLY_DR_CODE>5354</APPLY_DR_CODE><APPLY_DR_NAME>测试医生</APPLY_DR_NAME><PROOF_DR_INDEX_NO>5354</PROOF_DR_INDEX_NO><PROOF_DR_CODE>5354</PROOF_DR_CODE><PROOF_DR_NAME>测试医生</PROOF_DR_NAME><APPLY_DEPT_INDEX_NO>ZYCS1</APPLY_DEPT_INDEX_NO><APPLY_DEPT_CODE>ZYCS1</APPLY_DEPT_CODE><APPLY_DEPT_NAME>住院测试科室</APPLY_DEPT_NAME><PRE_SURGERY_DIAG_CODE/><PRE_SURGERY_DIAG_NAME>创伤性膀胱破裂</PRE_SURGERY_DIAG_NAME><ID_NUMBER>44072219410718111X</ID_NUMBER><PAT_NAME>测试</PAT_NAME>");
+			responceBuf.append("<PHYSI_SEX_CODE>2</PHYSI_SEX_CODE><PHYSI_SEX_NAME>女</PHYSI_SEX_NAME><DATE_BIRTH>1989-01-01T00:00:00</DATE_BIRTH><ETHNIC_CODE>01</ETHNIC_CODE><ETHNIC_NAME>汉族</ETHNIC_NAME><MARITAL_STATUS_CODE>U</MARITAL_STATUS_CODE><MARITAL_STATUS_NAME>未知</MARITAL_STATUS_NAME><RECORD_DATE>2024-06-22T09:15:49</RECORD_DATE><UPDATE_DATE>2024-06-24T08:12:27</UPDATE_DATE><BED_NO>08</BED_NO><OPERATING_DEPT>麻醉中心</OPERATING_DEPT><RESERVE_DATE>2024-06-23T08:00:00</RESERVE_DATE><SURGERY_TYPE>手术</SURGERY_TYPE><SPECIAL_EQUIPMENT/><SURGERY_DEPT_CODE>30101</SURGERY_DEPT_CODE><SURGERY_ROOM_NO>手术间</SURGERY_ROOM_NO><SURGEON_CODE>5354</SURGEON_CODE><ANES_DR_CODE/><ANES_DR_INDEX_NO/><ANES_DR_NAME/><MEDICAL_INSTITUTION>江门市中心医院</MEDICAL_INSTITUTION><SUBOR_HOSPITAL_DISTRICT>01</SUBOR_HOSPITAL_DISTRICT><APPLY_BED_CODE>ZYCS01,08</APPLY_BED_CODE><APPLY_BED_NAME>08</APPLY_BED_NAME><EMPI_ID>-2251173</EMPI_ID><WOUND_HEALING_LEVEL_CODE/><WOUND_HEALING_LEVEL_NAME/><GROUP_NO_TABLE_NO>0</GROUP_NO_TABLE_NO><ANES_METHOD_CODE>10029</ANES_METHOD_CODE><ANES_METHOD_NAME>静脉麻醉</ANES_METHOD_NAME><SURGERY_PART_CODE>0001</SURGERY_PART_CODE><SURGERY_PART_NAME>双侧鼻孔</SURGERY_PART_NAME><SURGERY_STATUS/><NORMAL_SURGERY_FLAG>N</NORMAL_SURGERY_FLAG></row></body></msg>]]></Msg>");
+			responceBuf.append("<Msg><![CDATA[<msg><body><row action='select'><OUTHOSP_INDEX_NO/><VISIT_CARD_NO>22286286</VISIT_CARD_NO><OUTHOSP_NO/><INHOSP_INDEX_NO>1000007</INHOSP_INDEX_NO><MR_NO>1000007</MR_NO><ANAMNESIS_NO>1000007</ANAMNESIS_NO><INHOSP_NUM>1</INHOSP_NUM><INHOSP_NO>2024-0449353-0</INHOSP_NO><PAT_INDEX_NO>-2251173</PAT_INDEX_NO><ELECTR_REQUISITION_NO>36019</ELECTR_REQUISITION_NO><ORDER_NO>4410613</ORDER_NO><ORDER_GROUP_NO/><SURGERY_APPLY_DATE>2024-06-04T08:00:00</SURGERY_APPLY_DATE><SURGERY_PROOF_DATE/><SURGERY_OPER_CODE>53.1401</SURGERY_OPER_CODE><SURGERY_OPER_NAME>双侧腹股沟直疝无张力修补术</SURGERY_OPER_NAME><SURGERY_PAT_RESOURCE_CODE>1E+0</SURGERY_PAT_RESOURCE_CODE><SURGERY_PAT_RESOURCE_NAME>门诊</SURGERY_PAT_RESOURCE_NAME><SELECTIVE_SURGERY_FLAG>1E+0</SELECTIVE_SURGERY_FLAG><ISOLATE_FLAG/><VALUATION_FLAG/><REQUISITION_STATUS>NO_SCHEDULE</REQUISITION_STATUS><NOTE>打号机</NOTE><SURGERY_LEVEL_CODE>3</SURGERY_LEVEL_CODE><SURGERY_LEVEL_NAME>三级手术</SURGERY_LEVEL_NAME><SURGERY_NUM/><APPLY_DR_INDEX_NO>5354</APPLY_DR_INDEX_NO><APPLY_DR_CODE>5354</APPLY_DR_CODE><APPLY_DR_NAME>测试医生</APPLY_DR_NAME><PROOF_DR_INDEX_NO>5354</PROOF_DR_INDEX_NO><PROOF_DR_CODE>5354</PROOF_DR_CODE><PROOF_DR_NAME>测试医生</PROOF_DR_NAME><APPLY_DEPT_INDEX_NO>ZYCS1</APPLY_DEPT_INDEX_NO><APPLY_DEPT_CODE>ZYCS1</APPLY_DEPT_CODE><APPLY_DEPT_NAME>住院测试科室</APPLY_DEPT_NAME><PRE_SURGERY_DIAG_CODE/><PRE_SURGERY_DIAG_NAME>创伤性膀胱破裂</PRE_SURGERY_DIAG_NAME><ID_NUMBER>44072219410718111X</ID_NUMBER><PAT_NAME>测试</PAT_NAME>");
+			responceBuf.append("<PHYSI_SEX_CODE>2</PHYSI_SEX_CODE><PHYSI_SEX_NAME>女</PHYSI_SEX_NAME><DATE_BIRTH>1989-01-01T00:00:00</DATE_BIRTH><ETHNIC_CODE>01</ETHNIC_CODE><ETHNIC_NAME>汉族</ETHNIC_NAME><MARITAL_STATUS_CODE>U</MARITAL_STATUS_CODE><MARITAL_STATUS_NAME>未知</MARITAL_STATUS_NAME><RECORD_DATE>2024-06-03T08:24:08</RECORD_DATE><UPDATE_DATE>2024-06-03T10:54:50</UPDATE_DATE><BED_NO>08</BED_NO><OPERATING_DEPT>手术中心</OPERATING_DEPT><RESERVE_DATE>2024-06-04T08:00:00</RESERVE_DATE><SURGERY_TYPE>手术</SURGERY_TYPE><SPECIAL_EQUIPMENT/><SURGERY_DEPT_CODE>301</SURGERY_DEPT_CODE><SURGERY_ROOM_NO>手术间</SURGERY_ROOM_NO><SURGEON_CODE>5354</SURGEON_CODE><ANES_DR_CODE/><ANES_DR_INDEX_NO/><ANES_DR_NAME/><MEDICAL_INSTITUTION>江门市中心医院</MEDICAL_INSTITUTION><SUBOR_HOSPITAL_DISTRICT>01</SUBOR_HOSPITAL_DISTRICT><APPLY_BED_CODE>ZYCS01,08</APPLY_BED_CODE><APPLY_BED_NAME>08</APPLY_BED_NAME><EMPI_ID>-2251173</EMPI_ID><WOUND_HEALING_LEVEL_CODE/><WOUND_HEALING_LEVEL_NAME/><GROUP_NO_TABLE_NO>0</GROUP_NO_TABLE_NO><ANES_METHOD_CODE>10028</ANES_METHOD_CODE><ANES_METHOD_NAME>吸入麻醉</ANES_METHOD_NAME><SURGERY_PART_CODE>9999</SURGERY_PART_CODE><SURGERY_PART_NAME>其他</SURGERY_PART_NAME><SURGERY_STATUS/><NORMAL_SURGERY_FLAG>N</NORMAL_SURGERY_FLAG></row></body></msg>]]></Msg>");
+			responceBuf.append("<Msg><![CDATA[<msg><body><row action='select'><OUTHOSP_INDEX_NO/><VISIT_CARD_NO>22286286</VISIT_CARD_NO><OUTHOSP_NO/><INHOSP_INDEX_NO>1000007</INHOSP_INDEX_NO><MR_NO>1000007</MR_NO><ANAMNESIS_NO>1000007</ANAMNESIS_NO><INHOSP_NUM>1</INHOSP_NUM><INHOSP_NO>2024-0449353-0</INHOSP_NO><PAT_INDEX_NO>-2251173</PAT_INDEX_NO><ELECTR_REQUISITION_NO>36025</ELECTR_REQUISITION_NO><ORDER_NO>4413755</ORDER_NO><ORDER_GROUP_NO/><SURGERY_APPLY_DATE>2024-06-06T08:00:00</SURGERY_APPLY_DATE><SURGERY_PROOF_DATE/><SURGERY_OPER_CODE>53.2100x001</SURGERY_OPER_CODE><SURGERY_OPER_NAME>腹腔镜下单侧股疝无张力修补术</SURGERY_OPER_NAME><SURGERY_PAT_RESOURCE_CODE>1E+0</SURGERY_PAT_RESOURCE_CODE><SURGERY_PAT_RESOURCE_NAME>门诊</SURGERY_PAT_RESOURCE_NAME><SELECTIVE_SURGERY_FLAG>1E+0</SELECTIVE_SURGERY_FLAG><ISOLATE_FLAG/><VALUATION_FLAG/><REQUISITION_STATUS>NO_SCHEDULE</REQUISITION_STATUS><NOTE>是的是的</NOTE><SURGERY_LEVEL_CODE>2</SURGERY_LEVEL_CODE><SURGERY_LEVEL_NAME>二级手术</SURGERY_LEVEL_NAME><SURGERY_NUM/><APPLY_DR_INDEX_NO>5354</APPLY_DR_INDEX_NO><APPLY_DR_CODE>5354</APPLY_DR_CODE><APPLY_DR_NAME>测试医生</APPLY_DR_NAME><PROOF_DR_INDEX_NO>5354</PROOF_DR_INDEX_NO><PROOF_DR_CODE>5354</PROOF_DR_CODE><PROOF_DR_NAME>测试医生</PROOF_DR_NAME><APPLY_DEPT_INDEX_NO>ZYCS1</APPLY_DEPT_INDEX_NO><APPLY_DEPT_CODE>ZYCS1</APPLY_DEPT_CODE><APPLY_DEPT_NAME>住院测试科室</APPLY_DEPT_NAME><PRE_SURGERY_DIAG_CODE/><PRE_SURGERY_DIAG_NAME>创伤性膀胱破裂</PRE_SURGERY_DIAG_NAME><ID_NUMBER>44072219410718111X</ID_NUMBER><PAT_NAME>测试</PAT_NAME>");
+			responceBuf.append("<PHYSI_SEX_CODE>2</PHYSI_SEX_CODE><PHYSI_SEX_NAME>女</PHYSI_SEX_NAME><DATE_BIRTH>1989-01-01T00:00:00</DATE_BIRTH><ETHNIC_CODE>01</ETHNIC_CODE><ETHNIC_NAME>汉族</ETHNIC_NAME><MARITAL_STATUS_CODE>U</MARITAL_STATUS_CODE><MARITAL_STATUS_NAME>未知</MARITAL_STATUS_NAME><RECORD_DATE>2024-06-05T15:05:30</RECORD_DATE><UPDATE_DATE>2024-06-05T17:05:55</UPDATE_DATE><BED_NO>08</BED_NO><OPERATING_DEPT>手术中心</OPERATING_DEPT><RESERVE_DATE>2024-06-06T08:00:00</RESERVE_DATE><SURGERY_TYPE>手术</SURGERY_TYPE><SPECIAL_EQUIPMENT/><SURGERY_DEPT_CODE>301</SURGERY_DEPT_CODE><SURGERY_ROOM_NO>手术间</SURGERY_ROOM_NO><SURGEON_CODE>P23001</SURGEON_CODE><ANES_DR_CODE/><ANES_DR_INDEX_NO/><ANES_DR_NAME/><MEDICAL_INSTITUTION>江门市中心医院</MEDICAL_INSTITUTION><SUBOR_HOSPITAL_DISTRICT>01</SUBOR_HOSPITAL_DISTRICT><APPLY_BED_CODE>ZYCS01,08</APPLY_BED_CODE><APPLY_BED_NAME>08</APPLY_BED_NAME><EMPI_ID>-2251173</EMPI_ID><WOUND_HEALING_LEVEL_CODE/><WOUND_HEALING_LEVEL_NAME/><GROUP_NO_TABLE_NO>0</GROUP_NO_TABLE_NO><ANES_METHOD_CODE>10028</ANES_METHOD_CODE><ANES_METHOD_NAME>吸入麻醉</ANES_METHOD_NAME><SURGERY_PART_CODE>0001</SURGERY_PART_CODE><SURGERY_PART_NAME>双侧鼻孔</SURGERY_PART_NAME><SURGERY_STATUS/><NORMAL_SURGERY_FLAG>N</NORMAL_SURGERY_FLAG></row></body></msg>]]></Msg>");
+			responceBuf.append("<Msg><![CDATA[<msg><body><row action='select'><OUTHOSP_INDEX_NO/><VISIT_CARD_NO>22286286</VISIT_CARD_NO><OUTHOSP_NO/><INHOSP_INDEX_NO>1000007</INHOSP_INDEX_NO><MR_NO>1000007</MR_NO><ANAMNESIS_NO>1000007</ANAMNESIS_NO><INHOSP_NUM>1</INHOSP_NUM><INHOSP_NO>2024-0449353-0</INHOSP_NO><PAT_INDEX_NO>-2251173</PAT_INDEX_NO><ELECTR_REQUISITION_NO>36055</ELECTR_REQUISITION_NO><ORDER_NO>4426946</ORDER_NO><ORDER_GROUP_NO/><SURGERY_APPLY_DATE>2024-06-23T08:00:00</SURGERY_APPLY_DATE><SURGERY_PROOF_DATE/><SURGERY_OPER_CODE>53.2101</SURGERY_OPER_CODE><SURGERY_OPER_NAME>单侧股疝无张力修补术</SURGERY_OPER_NAME><SURGERY_PAT_RESOURCE_CODE>1E+0</SURGERY_PAT_RESOURCE_CODE><SURGERY_PAT_RESOURCE_NAME>门诊</SURGERY_PAT_RESOURCE_NAME><SELECTIVE_SURGERY_FLAG>1E+0</SELECTIVE_SURGERY_FLAG><ISOLATE_FLAG/><VALUATION_FLAG/><REQUISITION_STATUS>NO_SCHEDULE</REQUISITION_STATUS><NOTE>1424</NOTE><SURGERY_LEVEL_CODE>3</SURGERY_LEVEL_CODE><SURGERY_LEVEL_NAME>三级手术</SURGERY_LEVEL_NAME><SURGERY_NUM/><APPLY_DR_INDEX_NO>5354</APPLY_DR_INDEX_NO><APPLY_DR_CODE>5354</APPLY_DR_CODE><APPLY_DR_NAME>测试医生</APPLY_DR_NAME><PROOF_DR_INDEX_NO>5354</PROOF_DR_INDEX_NO><PROOF_DR_CODE>5354</PROOF_DR_CODE><PROOF_DR_NAME>测试医生</PROOF_DR_NAME><APPLY_DEPT_INDEX_NO>ZYCS1</APPLY_DEPT_INDEX_NO><APPLY_DEPT_CODE>ZYCS1</APPLY_DEPT_CODE><APPLY_DEPT_NAME>住院测试科室</APPLY_DEPT_NAME><PRE_SURGERY_DIAG_CODE/><PRE_SURGERY_DIAG_NAME>创伤性膀胱破裂</PRE_SURGERY_DIAG_NAME><ID_NUMBER>44072219410718111X</ID_NUMBER><PAT_NAME>测试</PAT_NAME>");
+			responceBuf.append("<PHYSI_SEX_CODE>2</PHYSI_SEX_CODE><PHYSI_SEX_NAME>女</PHYSI_SEX_NAME><DATE_BIRTH>1989-01-01T00:00:00</DATE_BIRTH><ETHNIC_CODE>01</ETHNIC_CODE><ETHNIC_NAME>汉族</ETHNIC_NAME><MARITAL_STATUS_CODE>U</MARITAL_STATUS_CODE><MARITAL_STATUS_NAME>未知</MARITAL_STATUS_NAME><RECORD_DATE>2024-06-22T09:15:49</RECORD_DATE><UPDATE_DATE>2024-06-24T08:12:27</UPDATE_DATE><BED_NO>08</BED_NO><OPERATING_DEPT>麻醉中心</OPERATING_DEPT><RESERVE_DATE>2024-06-23T08:00:00</RESERVE_DATE><SURGERY_TYPE>手术</SURGERY_TYPE><SPECIAL_EQUIPMENT/><SURGERY_DEPT_CODE>30101</SURGERY_DEPT_CODE><SURGERY_ROOM_NO>手术间</SURGERY_ROOM_NO><SURGEON_CODE>5354</SURGEON_CODE><ANES_DR_CODE/><ANES_DR_INDEX_NO/><ANES_DR_NAME/><MEDICAL_INSTITUTION>江门市中心医院</MEDICAL_INSTITUTION><SUBOR_HOSPITAL_DISTRICT>01</SUBOR_HOSPITAL_DISTRICT><APPLY_BED_CODE>ZYCS01,08</APPLY_BED_CODE><APPLY_BED_NAME>08</APPLY_BED_NAME><EMPI_ID>-2251173</EMPI_ID><WOUND_HEALING_LEVEL_CODE/><WOUND_HEALING_LEVEL_NAME/><GROUP_NO_TABLE_NO>0</GROUP_NO_TABLE_NO><ANES_METHOD_CODE>10029</ANES_METHOD_CODE><ANES_METHOD_NAME>静脉麻醉</ANES_METHOD_NAME><SURGERY_PART_CODE>0001</SURGERY_PART_CODE><SURGERY_PART_NAME>双侧鼻孔</SURGERY_PART_NAME><SURGERY_STATUS/><NORMAL_SURGERY_FLAG>N</NORMAL_SURGERY_FLAG></row></body></msg>]]></Msg>");
+			responceBuf.append("</MsgInfo></ESBEntry>");
+			String responce = responceBuf.toString();*/
+			logger.debug(String.format("成功接收%s手术申请单信息(住院病人)接口返回信息：%s", MQHelper.hospitalNumFID, responce));
+			//解析返回参数
+			patientInfoVOList = buildHospitalNumberPatientInfoVO(responce);
+			if(CollectionUtils.isEmpty(patientInfoVOList)){
+				logger.debug(String.format("不存在住院号为%s的%s手术申请单信息", hospitalNum, MQHelper.hospitalNumFID));
+			}else{
+				PatientInfoVO[] array = new PatientInfoVO[patientInfoVOList.size()];
+				for(int i=0;i<patientInfoVOList.size();i++){
+					array[i] = patientInfoVOList.get(i);
+				}
+				return array;
+			}
+		} catch (Exception e) {
+			e.printStackTrace();
+			logger.debug(String.format("%s手术申请单信息(住院病人)接口查询失败：%s" , MQHelper.hospitalNumFID, e.getMessage()));
+		}
+		
+		//查不到手术申请单信息再查询  BS10091 在院患者信息
+		if(CollectionUtils.isEmpty(patientInfoVOList)){
+			try {
+				//查询BS10091 在院患者信息
+				logger.debug(String.format("开始查询%s在院患者信息", MQHelper.patientInfoFID));
+				//BS10091 在院患者信息请求信息
+				String msgbody = buildPatientInfoMsgBody(hospitalNum);
+				logger.debug(String.format("%s在院患者信息请求信息：%s", MQHelper.patientInfoFID, msgbody));
+				//调用接口
+				String responce = MQHelper.composePutAndGetMsg(msgbody);
+				/*StringBuffer responceBuf = new StringBuffer();
+				responceBuf.append("<ESBEntry><MessageHeader><Fid>BS10091</Fid><OrderNo>BS10091S90001</OrderNo><SourceSysCode>S00</SourceSysCode><TargetSysCode>S90</TargetSysCode><HospCode>1000142</HospCode><MsgDate>2024-07-09 17:51:14.106</MsgDate></MessageHeader>");
+				responceBuf.append("<RetInfo><RetCode>1</RetCode><RetCon>query success</RetCon></RetInfo><ResponseOption><currentPage>1</currentPage><totalPage>1</totalPage></ResponseOption>");
+				responceBuf.append("<MsgInfo>");
+				responceBuf.append("<Msg><![CDATA[<msg><body><row action='select'><PAT_INDEX_NO>76560</PAT_INDEX_NO><ID_NUMBER>44072219410718111X</ID_NUMBER><PAT_NAME>雷柏森</PAT_NAME><PHYSI_SEX_CODE>1</PHYSI_SEX_CODE><PHYSI_SEX_NAME>男</PHYSI_SEX_NAME><DATE_BIRTH>1941-07-18</DATE_BIRTH><ETHNIC_CODE>01</ETHNIC_CODE><ETHNIC_NAME>汉族</ETHNIC_NAME><MARITAL_STATUS_CODE>2</MARITAL_STATUS_CODE><MARITAL_STATUS_NAME>已婚</MARITAL_STATUS_NAME><PINYIN_CODE/><WUBI_CODE/><CERTIFICATE_TYPE>居民身份证</CERTIFICATE_TYPE><CERTIFICATE_NO>44072219410718111X</CERTIFICATE_NO><NATION_CODE>156</NATION_CODE><NATION_NAME>中国</NATION_NAME><OCCUPATION_CATEG_CODE>70</OCCUPATION_CATEG_CODE><OCCUPATION_CATEG_NAME>无业人员</OCCUPATION_CATEG_NAME><EDUCATION_CODE/><EDUCATION_NAME/><BIRTH_ADDR>广东省江门市台山市大江镇@河木肿闸村23--1号</BIRTH_ADDR><HUKOU_ADDR>广东省江门市台山市大江镇@河木肿闸村23--1号</HUKOU_ADDR><NATIVE_ADDR>广东省江门市</NATIVE_ADDR><EMAIL/><COMPANY>无</COMPANY><ADDR_COMPANY>无</ADDR_COMPANY><COMPANY_PHONE_NO>13702278468</COMPANY_PHONE_NO><PHONE_NO>13702278468</PHONE_NO><CONTACT_ADDR>广东省江门市台山市大江镇@</CONTACT_ADDR><PHONE_NO_HOME>13702278468</PHONE_NO_HOME><CURR_ADDR>广东省江门市台山市大江镇@大江镇河木中闸村23-1号</CURR_ADDR>");
+				responceBuf.append("<CONTACT_RELATION_CODE>0</CONTACT_RELATION_CODE><CONTACT_RELATION_NAME>本人或户主</CONTACT_RELATION_NAME><COMPANY_CERTIFICATE_TYPE/><COMPANY_CERTIFICATE_NO/><CONTACT_NAME>雷柏森</CONTACT_NAME><CONTACT_PERSON_ADDR>广东省江门市台山市大江镇@</CONTACT_PERSON_ADDR><CONTACT_PHONE_NO>13702278468</CONTACT_PHONE_NO><INHOSP_INDEX_NO>1000142</INHOSP_INDEX_NO><MR_NO>1000142</MR_NO><ANAMNESIS_NO/><VISIT_CARD_NO>30016946</VISIT_CARD_NO><INHOSP_NUM>1</INHOSP_NUM><INHOSP_NO>2024-0651074-0</INHOSP_NO><MEDICARE_CARD_NO>30016946</MEDICARE_CARD_NO><MEDICARE_CATEG_CODE>141</MEDICARE_CATEG_CODE><MEDICARE_CATEG_NAME>国家江门城乡医保</MEDICARE_CATEG_NAME><PAT_TYPE_CODE>3</PAT_TYPE_CODE><PAT_TYPE_NAME>住院</PAT_TYPE_NAME><NURSING_LEVEL_CODE>2</NURSING_LEVEL_CODE><NURSING_LEVEL_NAME>Ⅱ级护理</NURSING_LEVEL_NAME><PAT_STATUS_CODE>3E+0</PAT_STATUS_CODE><PAT_STATUS_NAME>一般</PAT_STATUS_NAME><PRELIMINARY_DIAG_CODE>E11.900</PRELIMINARY_DIAG_CODE><PRELIMINARY_DIAG_NAME>2型糖尿病</PRELIMINARY_DIAG_NAME><ADMIT_DIAG_CODE>E11.900</ADMIT_DIAG_CODE><ADMIT_DIAG_NAME>2型糖尿病</ADMIT_DIAG_NAME><DISCHARGE_DIAG_CODE>E11.900</DISCHARGE_DIAG_CODE><DISCHARGE_DIAG_NAME>2型糖尿病</DISCHARGE_DIAG_NAME>");
+				responceBuf.append("<ADMIT_DATE>2024-06-28 15:19:25</ADMIT_DATE><ADMIT_SITUATION>3</ADMIT_SITUATION><ADMIT_WAY_CODE>3</ADMIT_WAY_CODE><ADMIT_WAY_NAME>其他医疗机构转入</ADMIT_WAY_NAME><PAT_CHIEF_DESCR/><BRIEF_DISEASE_SITUATION/><TREAT_PLAN/><ADMIT_MI_CODE>01</ADMIT_MI_CODE><ADMIT_MI_NAME>江门中心医院</ADMIT_MI_NAME><ADMIT_DEPT_INDEX_NO>210306</ADMIT_DEPT_INDEX_NO><ADMIT_DEPT_CODE>210306</ADMIT_DEPT_CODE><ADMIT_DEPT_NAME>内分泌科</ADMIT_DEPT_NAME><ADMIT_WARD_INDEX_NO>21030601</ADMIT_WARD_INDEX_NO><ADMIT_WARD_CODE>21030601</ADMIT_WARD_CODE><ADMIT_WARD_NAME>内分泌科病区</ADMIT_WARD_NAME><ADMIT_SICKROOM_INDEX_NO/><ADMIT_SICKROOM_CODE>病室</ADMIT_SICKROOM_CODE><ADMIT_SICKROOM_NAME/><ADMIT_BED_INDEX_NO>0628</ADMIT_BED_INDEX_NO><ADMIT_BED_CODE>0628</ADMIT_BED_CODE><ADMIT_BED_NAME>0628</ADMIT_BED_NAME><CURR_MI_CODE>01</CURR_MI_CODE><CURR_MI_NAME>江门中心医院</CURR_MI_NAME><CURR_DEPT_INDEX_NO>210418</CURR_DEPT_INDEX_NO><CURR_DEPT_CODE>210418</CURR_DEPT_CODE><CURR_DEPT_NAME>烧伤整形与创面修复科</CURR_DEPT_NAME><CURR_WARD_INDEX_NO>21041801</CURR_WARD_INDEX_NO><CURR_WARD_CODE>21041801</CURR_WARD_CODE><CURR_WARD_NAME>烧伤整形与创面修复科病区</CURR_WARD_NAME><CURR_SICKROOM_INDEX_NO/>");
+				responceBuf.append("<CURR_SICKROOM_CODE/><CURR_SICKROOM_NAME/><CURR_BED_INDEX_NO>17010</CURR_BED_INDEX_NO><CURR_BED_CODE>17010</CURR_BED_CODE><CURR_BED_NAME>17010</CURR_BED_NAME><DISCHARGE_MI_CODE>01</DISCHARGE_MI_CODE><DISCHARGE_MI_NAME>江门中心医院</DISCHARGE_MI_NAME><DISCHARGE_DEPT_INDEX_NO>210418</DISCHARGE_DEPT_INDEX_NO><DISCHARGE_DEPT_CODE>210418</DISCHARGE_DEPT_CODE><DISCHARGE_DEPT_NAME>烧伤整形与创面修复科</DISCHARGE_DEPT_NAME><DISCHARGE_WARD_INDEX_NO>21041801</DISCHARGE_WARD_INDEX_NO><DISCHARGE_WARD_CODE>21041801</DISCHARGE_WARD_CODE><DISCHARGE_WARD_NAME>烧伤整形与创面修复科病区</DISCHARGE_WARD_NAME><DISCHARGE_SICKROOM_INDEX_NO/><DISCHARGE_SICKROOM_CODE/><DISCHARGE_SICKROOM_NAME/><DISCHARGE_BED_INDEX_NO>17010</DISCHARGE_BED_INDEX_NO><DISCHARGE_BED_CODE>17010</DISCHARGE_BED_CODE><DISCHARGE_BED_NAME>17010</DISCHARGE_BED_NAME><DISCHARGE_DATE/><OUTCOME/><DISCHARGE_METHOD_CODE/><DISCHARGE_METHOD_NAME/><RECEPT_TREAT_DR_INDEX_NO>1177</RECEPT_TREAT_DR_INDEX_NO><RECEPT_TREAT_DR_CODE>1177</RECEPT_TREAT_DR_CODE><RECEPT_TREAT_DR_NAME>余文昊</RECEPT_TREAT_DR_NAME><ATTEND_DR_INDEX_NO>1177</ATTEND_DR_INDEX_NO><ATTEND_DR_CODE>1177</ATTEND_DR_CODE><ATTEND_DR_NAME>余文昊</ATTEND_DR_NAME>");
+				responceBuf.append("<CHIEF_DR_INDEX_NO/><CHIEF_DR_CODE/><CHIEF_DR_NAME/><BED_NURSE_INDEX_NO>212105</BED_NURSE_INDEX_NO><BED_NURSE_CODE>212105</BED_NURSE_CODE><BED_NURSE_NAME>林丽秋</BED_NURSE_NAME><BED_DR_INDEX_NO>1177</BED_DR_INDEX_NO><BED_DR_CODE>1177</BED_DR_CODE><BED_DR_NAME>余文昊</BED_DR_NAME><ASSISTANT_DR_INDEX_NO/><ASSISTANT_DR_CODE/><ASSISTANT_DR_NAME/><PAST_DISEASE_HISTORY_DESCR/><DISEASE_HISTORY/><SURGERY_HISTORY/><METACHYSIS_HISTORY/><INFECT_DISEASE_HISTORY/><RECORD_DATE>2024-06-28 15:03:32</RECORD_DATE><UPDATE_DATE>2024-07-08 11:45:32</UPDATE_DATE><AGE>82岁</AGE><PROS_PAY>1000.00</PROS_PAY><DIET_SITUATION/><ADMIT_WAY_CODE1>3</ADMIT_WAY_CODE1><DATETIME_SURGERY_FLAG/><AGE_MONTH/><ALLERGY_HISTORY/></row></body></msg>]]></Msg></MsgInfo></ESBEntry>");
+				String responce = responceBuf.toString();*/
+				logger.debug(String.format("成功接收%s在院患者信息：%s", MQHelper.patientInfoFID, responce));
+				//解析
+				patientInfoVOList = buildPatientInfoVO(responce);
+				if(CollectionUtils.isEmpty(patientInfoVOList)){
+					logger.debug(String.format("不存在住院号为%s的%s住院患者信息", hospitalNum, MQHelper.patientInfoFID));
+				}else{
+					PatientInfoVO[] array = new PatientInfoVO[patientInfoVOList.size()];
+					for(int i=0;i<patientInfoVOList.size();i++){
+						array[i] = patientInfoVOList.get(i);
+					}
+					return array;
+				}
+			} catch (Exception e) {
+				e.printStackTrace();
+				logger.debug(String.format("%s在院患者信息接口查询失败：%s" , MQHelper.patientInfoFID, e.getMessage()));
+			}
+		}
+		return null;
+	}
+	
+	/**
+	 * BS30005 手术申请单信息接口的请求信息
+	 * @param hospitalNum
+	 * @return
+	 */
+	private String buildOperationApplyMsgbody(String hospitalNum) {
+		StringBuffer msgbody = new StringBuffer();
+		msgbody.append("<ESBEntry>");
+		msgbody.append("<AccessControl>");
+		msgbody.append("<SysFlag>1</SysFlag>");
+		msgbody.append("<UserName>" + MQHelper.userName + "</UserName>");
+		msgbody.append("<Password>" + MQHelper.password + "</Password>");
+		msgbody.append("<Fid>" + MQHelper.hospitalNumFID + "</Fid>");
+		msgbody.append("<OrderNo>" + MQHelper.hospitalNumOrderNo + "</OrderNo>");
+		msgbody.append("</AccessControl>");
+		msgbody.append("<MessageHeader>");
+		msgbody.append("<Fid>" + MQHelper.hospitalNumFID + "</Fid>");
+		msgbody.append("<OrderNo>" + MQHelper.hospitalNumOrderNo + "</OrderNo>");
+		msgbody.append("<SourceSysCode>S90</SourceSysCode>");
+		msgbody.append("<TargetSysCode>S00</TargetSysCode>");
+		msgbody.append("<HospCode>JMZX</HospCode>");
+		//2024-06-28 09:08:04
+		msgbody.append("<MsgDate>" + DateTools.getCurrentDayByFormat(DateTools.COMMON_DATE_HMS) + "</MsgDate>");
+		msgbody.append("</MessageHeader>");
+		msgbody.append("<RequestOption>");
+		msgbody.append("<triggerData>0</triggerData>");
+		msgbody.append("<dataAmount>500</dataAmount>");
+		msgbody.append("</RequestOption>");
+		msgbody.append("<MsgInfo flag=\"1\" >");
+		msgbody.append("<Msg></Msg>");
+		msgbody.append("<distinct value=\"0\"/>");
+		msgbody.append("<query item=\"INHOSP_INDEX_NO\" compy=\"=\" value=\"'" + hospitalNum + "'\" splice=\"AND\"/>");
+		msgbody.append("</MsgInfo>");
+		msgbody.append("<GroupInfo flag=\"0\">");
+		msgbody.append("<AS ID=\"\" linkField=\"\"/>");
+		msgbody.append("</GroupInfo>");
+		msgbody.append("</ESBEntry>");
+		return msgbody.toString();
+	}
+
+	/**
+	 * BS10091 在院患者信息的请求参数
+	 * @param hospitalNum
+	 * @return
+	 */
+	private String buildPatientInfoMsgBody(String hospitalNum) {
+		StringBuffer msgbody = new StringBuffer();
+		msgbody.append("<ESBEntry>");
+		msgbody.append("<AccessControl>");
+		msgbody.append("<SysFlag>1</SysFlag>");
+		msgbody.append("<UserName>" + MQHelper.userName + "</UserName>");
+		msgbody.append("<Password>" + MQHelper.password + "</Password>");
+		msgbody.append("<Fid>" + MQHelper.patientInfoFID + "</Fid>");
+		msgbody.append("<OrderNo>" + MQHelper.patientInfoOrderNo + "</OrderNo>");
+		msgbody.append("</AccessControl>");
+		msgbody.append("<MessageHeader>");
+		msgbody.append("<Fid>" + MQHelper.patientInfoFID + "</Fid>");
+		msgbody.append("<OrderNo>" + MQHelper.patientInfoOrderNo + "</OrderNo>");
+		msgbody.append("<SourceSysCode>S90</SourceSysCode>");
+		msgbody.append("<TargetSysCode>S00</TargetSysCode>");
+		msgbody.append("<HospCode>JMZX</HospCode>");
+		//2024-06-28 09:08:04
+		msgbody.append("<MsgDate>" + DateTools.getCurrentDayByFormat(DateTools.COMMON_DATE_HMS) + "</MsgDate>");
+		msgbody.append("</MessageHeader>");
+		msgbody.append("<RequestOption>");
+		msgbody.append("<triggerData>0</triggerData>");
+		msgbody.append("<dataAmount>500</dataAmount>");
+		msgbody.append("</RequestOption>");
+		msgbody.append("<MsgInfo flag=\"1\" >");
+		msgbody.append("<Msg></Msg>");
+		msgbody.append("<distinct value=\"0\"/>");
+		msgbody.append("<query item=\"INHOSP_INDEX_NO\" compy=\"=\" value=\"'" + hospitalNum + "'\" splice=\"AND\"/>");
+		msgbody.append("</MsgInfo>");
+		msgbody.append("<GroupInfo flag=\"0\">");
+		msgbody.append("<AS ID=\"\" linkField=\"\"/>");
+		msgbody.append("</GroupInfo>");
+		msgbody.append("</ESBEntry>");
+		return msgbody.toString();
+	}
+
+	/**
+	 * 解析并返回BS10091 在院患者信息
+	 * @param responce
+	 * @return
+	 * @throws Exception 
+	 */
+	@SuppressWarnings("unchecked")
+	private List<PatientInfoVO> buildPatientInfoVO(String responce) throws Exception {
+
+		if(StringUtils.isBlank(responce)){
+			throw new RuntimeException("接口返回的参数为空！");
+		}
+
+		// 开始解析
+		Document doc = DocumentHelper.parseText(responce);
+		// 查询结果返回状态
+		String RetCodeXpath = "/ESBEntry/RetInfo/RetCode";
+		String RetCode = MQHelper.processDataByXpath(doc, RetCodeXpath);
+		String RetConXpath = "/ESBEntry/RetInfo/RetCon";
+		String RetCon = MQHelper.processDataByXpath(doc, RetConXpath);
+		if (!MQHelper.RET_CODE_SUCCESS.equals(RetCode)) {
+			throw new RuntimeException("接口返回信息为" + RetCon);
+		}
+		// 解析住院病人信息并入库
+		String MsgXpath = "/ESBEntry/MsgInfo/Msg";	// 返回结果可能存在多条住院病人信息
+		XPath xpath = doc.createXPath(MsgXpath);
+		List<Node> nodeList2 = xpath.selectNodes(doc, xpath);
+		if (nodeList2 == null || nodeList2.size() == 0) {
+			throw new RuntimeException("查询返回的数据不包含/ESBEntry/MsgInfo/Msg节点！");
+		}
+		List<PatientInfoVO> patientInfoVOList = new LinkedList<PatientInfoVO>();
+		// 解析返回信息中所有住院病人信息
+		for (int i = 1; i <= nodeList2.size(); i++) {
+			String msgXpath = "/ESBEntry/MsgInfo/Msg[" + i + "]";
+			String patientInfo = MQHelper.processDataByXpath(doc, msgXpath); // 住院病人信息
+			if (StringUtils.isNotBlank(patientInfo)) {
+				Document document = DocumentHelper.parseText(patientInfo);
+				// 解析住院病人信息并入库
+				String hospitalNumberXpath = "/msg/body/row/INHOSP_INDEX_NO";
+				String clinicNumberXpath = "/msg/body/row/VISIT_CARD_NO";
+				String patientNameXpath = "/msg/body/row/PAT_NAME";
+				String patientAgeXpath = "/msg/body/row/AGE";
+
+				String patientSexXpath = "/msg/body/row/PHYSI_SEX_NAME";
+				String patientAreaXpath = "/msg/body/row/ADMIT_WARD_NAME";
+				String ascriptionDepartmentXpath = "/msg/body/row/ADMIT_DEPT_NAME";
+				String roomNumberXpath = "/msg/body/row/ADMIT_SICKROOM_CODE";
+
+				String bedNumberXpath = "/msg/body/row/ADMIT_BED_CODE";
+				String patientIDCardXpath = "/msg/body/row/ID_NUMBER";
+
+				String hospitalNumber = MQHelper.processDataByXpath(document, hospitalNumberXpath);
+				String clinicNumber = MQHelper.processDataByXpath(document, clinicNumberXpath);
+				String patientName = MQHelper.processDataByXpath(document, patientNameXpath);
+				String patientAge = MQHelper.processDataByXpath(document, patientAgeXpath);
+
+				String patientSex = MQHelper.processDataByXpath(document, patientSexXpath);
+				String patientArea = MQHelper.processDataByXpath(document, patientAreaXpath);
+				String ascriptionDepartment = MQHelper.processDataByXpath(document, ascriptionDepartmentXpath);
+				String roomNumber = MQHelper.processDataByXpath(document, roomNumberXpath);
+
+				String bedNumber = MQHelper.processDataByXpath(document, bedNumberXpath);
+				String patientIDCard = MQHelper.processDataByXpath(document, patientIDCardXpath);
+
+				PatientInfoVO vo = new PatientInfoVO();
+				vo.setHospitalNumber(hospitalNumber);
+				vo.setClinicNumber(clinicNumber);
+				vo.setPatientName(patientName);
+				vo.setPatientAge(patientAge);
+				vo.setPatientSex(patientSex);
+				vo.setPatientArea(patientArea);
+				vo.setAscriptionDepartment(ascriptionDepartment);
+				vo.setRoomNumber(roomNumber);
+				vo.setBedNumber(bedNumber);
+				vo.setPatientIDCard(patientIDCard);
+
+				patientInfoVOList.add(vo);
+			}
+		}
+
+		if(CollectionUtils.isEmpty(patientInfoVOList)){
+			throw new RuntimeException("返回的住院患者信息为空！");
+		}
+
+		return patientInfoVOList;
+	}
+	
+	/**
+	 * 解析并返回BS30005手术申请单患者信息
+	 * @return
+	 * @throws Exception 
+	 */
+	@SuppressWarnings("unchecked")
+	private List<PatientInfoVO> buildHospitalNumberPatientInfoVO(String responce) throws Exception {
+
+		if(StringUtils.isBlank(responce)){
+			throw new RuntimeException("接口返回的参数为空！");
+		}
+
+		// 开始解析
+		Document doc = DocumentHelper.parseText(responce);
+		// 查询结果返回状态
+		String RetCodeXpath = "/ESBEntry/RetInfo/RetCode";
+		String RetCode = MQHelper.processDataByXpath(doc, RetCodeXpath);
+		String RetConXpath = "/ESBEntry/RetInfo/RetCon";
+		String RetCon = MQHelper.processDataByXpath(doc, RetConXpath);
+		if (!MQHelper.RET_CODE_SUCCESS.equals(RetCode)) {
+			throw new RuntimeException("接口返回信息为" + RetCon);
+		}
+		// 解析住院病人信息并入库
+		String MsgXpath = "/ESBEntry/MsgInfo/Msg";	// 返回结果可能存在多条住院病人信息
+		XPath xpath = doc.createXPath(MsgXpath);
+		List<Node> nodeList2 = xpath.selectNodes(doc, xpath);
+		if (nodeList2 == null || nodeList2.size() == 0) {
+			throw new RuntimeException("查询返回的数据不包含/ESBEntry/MsgInfo/Msg节点！");
+		}
+		List<PatientInfoVO> patientInfoVOList = new LinkedList<PatientInfoVO>();
+		// 解析返回信息中所有住院病人信息
+		for (int i = 1; i <= nodeList2.size(); i++) {
+			String msgXpath = "/ESBEntry/MsgInfo/Msg[" + i + "]";
+			String patientInfo = MQHelper.processDataByXpath(doc, msgXpath); // 住院病人信息
+			if (StringUtils.isNotBlank(patientInfo)) {
+				Document document = DocumentHelper.parseText(patientInfo);
+				// 解析住院病人信息并入库
+				String hospitalNumberXpath = "/msg/body/row/INHOSP_INDEX_NO";
+				String operationRoomXpath = "/msg/body/row/SURGERY_ROOM_NO";
+				String patientNameXpath = "/msg/body/row/PAT_NAME";
+				String patientBirthdayXpath = "/msg/body/row/DATE_BIRTH";
+
+				String patientSexXpath = "/msg/body/row/PHYSI_SEX_NAME";
+				String bedNumberXpath = "/msg/body/row/BED_NO";
+				String patientIDCardXpath = "/msg/body/row/ID_NUMBER";
+				String doctorNameXpath = "/msg/body/row/SURGEON_CODE";
+
+				String operationXpath = "/msg/body/row/SURGERY_OPER_NAME";
+				String operationScheduleIdXpath = "/msg/body/row/ELECTR_REQUISITION_NO";
+				String operationTimeXpath = "/msg/body/row/RESERVE_DATE";
+
+				String hospitalNumber = MQHelper.processDataByXpath(document, hospitalNumberXpath);
+				String opRoomId = MQHelper.processDataByXpath(document, operationRoomXpath);
+				String patientName = MQHelper.processDataByXpath(document, patientNameXpath);
+				String patientBirthday = MQHelper.processDataByXpath(document, patientBirthdayXpath);
+
+				String patientSex = MQHelper.processDataByXpath(document, patientSexXpath);
+				String bedNumber = MQHelper.processDataByXpath(document, bedNumberXpath);
+				String patientIDCard = MQHelper.processDataByXpath(document, patientIDCardXpath);
+				String doctorName = MQHelper.processDataByXpath(document, doctorNameXpath);
+
+				String operation = MQHelper.processDataByXpath(document, operationXpath);
+				String operationScheduleId = MQHelper.processDataByXpath(document, operationScheduleIdXpath);
+				String operationTime = MQHelper.processDataByXpath(document, operationTimeXpath);
+				if(StringUtils.isNotBlank(operationTime)){
+					operationTime= operationTime.replace("T", " ");
+				}
+
+				PatientInfoVO patientInfoVO = new PatientInfoVO();
+				patientInfoVO.setHospitalNumber(hospitalNumber);
+				patientInfoVO.setOpRoomId(opRoomId);
+				patientInfoVO.setPatientName(patientName);
+				patientInfoVO.setPatientAge(birthdayToAge(patientBirthday));
+
+				patientInfoVO.setPatientSex(patientSex);
+				patientInfoVO.setBedNumber(bedNumber);
+				patientInfoVO.setPatientIDCard(patientIDCard);
+				patientInfoVO.setDoctorName(doctorName);
+
+				patientInfoVO.setOperation(operation);
+				patientInfoVO.setOperationScheduleId(operationScheduleId);
+				patientInfoVO.setOperationTime(operationTime);
+
+				patientInfoVOList.add(patientInfoVO);
+			}
+		}
+
+		if(CollectionUtils.isEmpty(patientInfoVOList)){
+			throw new RuntimeException("返回的住院患者信息为空！");
+		}
+
+		// 根据记录手术时间排序，只取最新记录
+		patientInfoVOList.sort(new Comparator<PatientInfoVO>() {
+			@Override
+			public int compare(PatientInfoVO o1, PatientInfoVO o2) {
+				if (StringUtils.isBlank(o1.getOperationTime()) && StringUtils.isNotBlank(o2.getOperationTime())) {
+					return -1;
+				}
+				if (StringUtils.isBlank(o2.getOperationTime()) && StringUtils.isNotBlank(o1.getOperationTime())) {
+					return 1;
+				}
+				SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+				try {
+					Date date1 = sdf.parse(o1.getOperationTime());
+					Date date2 = sdf.parse(o2.getOperationTime());
+					return date2.compareTo(date1);
+				} catch (ParseException e) {
+					logger.debug(String.format("%s手术申请单信息(住院病人)排序出错(录入时间【RECORD_DATE】字段格式错误)！", MQHelper.hospitalNumFID));
+					e.printStackTrace();
+				}
+				return 0;
+			}
+		});
+		return patientInfoVOList;
+	}
+
+	/**
+	 * 患者年龄处理：
+	 * 根据患者出生日期(yyyy-MM-ddTHH:mm:ss)计算年龄（1989-01-01T00:00:00）
+	 * @param birthday(yyyy-MM-ddTHH:mm:ss)
+	 * @return age 
+	 */
+	private static String birthdayToAge(String birthday) {
+		if(StringUtils.isNotBlank(birthday)) {
+			if (StringUtils.isNotBlank(birthday)) {
+				birthday = birthday.replace("T", " ");
+			}
+			String[] arr = birthday.split("-");
+			Integer year = Integer.parseInt(arr[0]);
+			Integer month = Integer.parseInt(arr[1]);
+			Integer day = Integer.parseInt(arr[2].split(" ")[0]);
+			Calendar now = Calendar.getInstance();
+			Integer currentYear = now.get(Calendar.YEAR);
+			Integer currentMonth = now.get(Calendar.MONTH) + 1;
+			Integer currentDay = now.get(Calendar.DAY_OF_MONTH);
+			Integer age = currentYear - year;
+			if(currentMonth == month) {
+				if(currentDay < day) {
+					age -= 1;
+				}
+			} else if(currentMonth < month) {
+				age -= 1;
+			}
+			return age.toString();
+		}
+		return null;
+	}
+
+	@Override
+	public PatientInfoVO[] findPatientInfoByHospitalNumBeforeOperation(String hospitalNum) {
+		return this.findPatientInfoByHospitalNum(hospitalNum);
+	}
+
+}