Index: ssts-web/src/main/webapp/disinfectsystem/config/bj309yy/spring/HIS.xml
===================================================================
diff -u -r36287 -r36473
--- ssts-web/src/main/webapp/disinfectsystem/config/bj309yy/spring/HIS.xml	(.../HIS.xml)	(revision 36287)
+++ ssts-web/src/main/webapp/disinfectsystem/config/bj309yy/spring/HIS.xml	(.../HIS.xml)	(revision 36473)
@@ -1,4 +1,4 @@
-<?xml version="1.0" encoding="UTF-8"?>
+<?xml version="1.0" encoding="UTF-8"?>
 <beans xmlns="http://www.springframework.org/schema/beans"
 	   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 	   xmlns:context="http://www.springframework.org/schema/context"
@@ -46,31 +46,11 @@
         <property name="password" value="p2ssword" />
     </bean>
 
-    <!-- 由MyBatis实现访问HIS数据的Dao接口-->
-    <bean id="syncOrgUnitAndUserDao" class="org.mybatis.spring.mapper.MapperFactoryBean">  
-       <property name="mapperInterface"  
-           value="com.forgon.disinfectsystem.datasynchronization.dao.SyncOrgUnitAndUserDao" />  
-       <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/bj309yy/interfaces/mybatis/SyncOrgUnitAndUserMapper.xml" />
-                <property name="typeAliasesPackage" value="com.forgon.disinfectsystem.datasynchronization.model" />
-            </bean>
-       </property>
-    </bean>
+    <!-- 科室人员及住院病人信息同步接口 -->
+	<bean id="syncOrgUnitAndUserDao" class="com.forgon.disinfectsystem.datasynchronization.dao.bj309yy.SyncOrgUnitAndUserDaoImpl"></bean>
+	
+	<bean id="findPatientInfoByHospitalNumDao" class="com.forgon.disinfectsystem.datasynchronization.dao.bj309yy.FindPatientInfoByHospitalNumDaoImpl"></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/bj309yy/interfaces/mybatis/FindPatientInfoByHospitalNumMapper.xml" />
-                <property name="typeAliasesPackage" value="com.forgon.disinfectsystem.datasynchronization.model" />
-            </bean>
-       </property>
-    </bean>
-    
     <bean id="findPatientInfoByTreatmentNumDao" class="org.mybatis.spring.mapper.MapperFactoryBean">
        <property name="mapperInterface"  
            value="com.forgon.disinfectsystem.datasynchronization.dao.FindPatientInfoByTreatmentNumDao" />  
Index: ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/datasynchronization/dao/bj309yy/SyncOrgUnitAndUserDaoImpl.java
===================================================================
diff -u
--- ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/datasynchronization/dao/bj309yy/SyncOrgUnitAndUserDaoImpl.java	(revision 0)
+++ ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/datasynchronization/dao/bj309yy/SyncOrgUnitAndUserDaoImpl.java	(revision 36473)
@@ -0,0 +1,195 @@
+package com.forgon.disinfectsystem.datasynchronization.dao.bj309yy;
+
+
+import java.util.ArrayList;
+import java.util.List;
+
+import net.sf.json.JSONObject;
+
+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.SyncOrgUnitAndUserDao;
+import com.forgon.disinfectsystem.datasynchronization.model.OrgUnitVo;
+import com.forgon.disinfectsystem.datasynchronization.model.UserVo;
+
+/**
+ * 查询科室与人员信息(北京309医院)
+ *
+ */
+public class SyncOrgUnitAndUserDaoImpl implements SyncOrgUnitAndUserDao {
+
+	Logger logger = Logger.getLogger(SyncOrgUnitAndUserDaoImpl.class);
+
+	@Override
+	public UserVo[] getAllUser() {
+		UserVo[] userVoArray = null;
+		List<UserVo> userVoList = new ArrayList<UserVo>();
+		try {
+			String inputXml = WebServiceClientHelper.buildInputStr(DatasyncConstant.ACTION_USER_INFO_QUERY, null, null);
+			logger.info("人员同步接口请求信息：" + inputXml);
+			String result = WebServiceClientHelper.axisInvokeWebservice(DatasyncConstant.WebserviceAddress, DatasyncConstant.targetNamespace, DatasyncConstant.soapAction, DatasyncConstant.method, DatasyncConstant.paramName, inputXml, "utf-8");
+			logger.info("人员同步接口返回信息：" + result);
+			//String result = "<RESPONSE><RET_INFO><RET_CODE>0</RET_CODE><RET_DESCRIPTION></RET_DESCRIPTION></RET_INFO><MSG><USER_LIST><USER><USER_ID></USER_ID><USER_CODE>C720</USER_CODE><ORGUNIT_CODE>20230720</ORGUNIT_CODE><USER_NAME>20230720</USER_NAME></USER></USER_LIST></MSG></RESPONSE>;"
+			int startIndex = result.indexOf("<RESPONSE>");
+			if(startIndex == -1){
+				return null;
+			}
+			int endIndex = result.indexOf("</RESPONSE>");
+			if(endIndex == -1 || endIndex < startIndex){
+				return null;
+			}
+			String xmlString = result.substring(startIndex + "<RESPONSE>".length(), endIndex);
+			xmlString = "<RESPONSE>" + xmlString + "</RESPONSE>";
+			Document document = DocumentHelper.parseText(xmlString);
+			// 查询结果
+			String resultCodeXpath = "/RESPONSE/RET_INFO/RET_CODE";
+			String resultCotentXpath = "/RESPONSE/RET_INFO/RET_DESCRIPTION";
+			String resultCode = WebServiceClientHelper.processDataByXpath(document, resultCodeXpath);
+			String resultCotent = WebServiceClientHelper.processDataByXpath(document, resultCotentXpath);
+			if(!StringUtils.equals(resultCode, DatasyncConstant.RET_CODE_SUCCESS)){
+				logger.info("用户信息查询失败：" + resultCotent);
+				return null;
+			}
+			String itemXpath = "/RESPONSE/MSG_INFO/MSG/USER_LIST/USER";	// 返回结果可能存在多条用户信息
+			XPath xpath = document.createXPath(itemXpath);
+			@SuppressWarnings("unchecked")
+			List<Node> nodeList = xpath.selectNodes(document, xpath);
+			if(CollectionUtils.isNotEmpty(nodeList)){
+				for (int i = 1; i <= nodeList.size(); i++) {
+					
+					String msgXpath = "/RESPONSE/MSG_INFO/MSG/USER_LIST/USER[" + i + "]";
+					// 工号
+					String codeXpath = msgXpath + "/USER_CODE";
+					// 姓名
+					String nameXpath = msgXpath + "/USER_NAME";
+					// 上级科室编码
+					String orgUnitCodeXpath = msgXpath + "/ORGUNIT_CODE";
+					
+					String code = WebServiceClientHelper.processDataByXpath(document, codeXpath);
+					String name = WebServiceClientHelper.processDataByXpath(document, nameXpath);
+					String orgUnitCoding = WebServiceClientHelper.processDataByXpath(document, orgUnitCodeXpath);
+					UserVo userVo = new UserVo();
+					userVo.setCoding(code);
+					userVo.setName(name);
+					userVo.setOrgUnitCoding(orgUnitCoding);
+					
+					//如果人员工号或名称为空,则忽略该条数据
+					if(StringUtils.isBlank(userVo.getName()) || StringUtils.isBlank(userVo.getCoding())){
+						continue;
+					}
+					userVoList.add(userVo);
+				}
+				userVoArray = new UserVo[userVoList.size()];
+				userVoList.toArray(userVoArray);
+			} else {
+				logger.info("未找到人员数据");
+			}
+		} catch (Exception e) {
+			e.printStackTrace();
+			logger.error("查询人员信息失败:" + e);
+		}
+		return userVoArray;
+	}
+
+	@Override
+	public OrgUnitVo[] getAllOrgUnit() {
+		OrgUnitVo[] orgUnitVoArray = null;
+		List<OrgUnitVo> orgUnitVoList = new ArrayList<OrgUnitVo>();
+		try {
+			String inputXml = WebServiceClientHelper.buildInputStr(DatasyncConstant.ACTION_ORGUNIT_INFO_QUERY, null, null);
+			logger.info("科室同步接口请求信息：" + inputXml);
+			String result = WebServiceClientHelper.axisInvokeWebservice(DatasyncConstant.WebserviceAddress, DatasyncConstant.targetNamespace, DatasyncConstant.soapAction, DatasyncConstant.method, DatasyncConstant.paramName, inputXml, "utf-8");
+			logger.info("科室同步接口返回信息：" + result);
+			//String result = " <return><![CDATA[<RESPONSE><RET_INFO><RET_CODE>0</RET_CODE><RET_DESCRIPTION></RET_DESCRIPTION></RET_INFO><MSG><ORGUNIT_LIST><ORGUNIT><ORGUNIT_ID></ORGUNIT_ID><ORGUNIT_CODE>20230720</ORGUNIT_CODE><PARENT_ORGUNIT_CODE>4009H</PARENT_ORGUNIT_CODE><ORGUNIT_NAME>20230720测试科室</ORGUNIT_NAME></ORGUNIT></ORGUNIT_LIST></MSG></RESPONSE>]]></return>;"
+			int startIndex = result.indexOf("<RESPONSE>");
+			if(startIndex == -1){
+				return null;
+			}
+			int endIndex = result.indexOf("</RESPONSE>");
+			if(endIndex == -1 || endIndex < startIndex){
+				return null;
+			}
+			String xmlString = result.substring(startIndex + "<RESPONSE>".length(), endIndex);
+			xmlString = "<RESPONSE>" + xmlString + "</RESPONSE>";
+			Document document = DocumentHelper.parseText(xmlString);
+			// 查询结果
+			String resultCodeXpath = "/RESPONSE/RET_INFO/RET_CODE";
+			String resultCotentXpath = "/RESPONSE/RET_INFO/RET_DESCRIPTION";
+			String resultCode = WebServiceClientHelper.processDataByXpath(document, resultCodeXpath);
+			String resultCotent = WebServiceClientHelper.processDataByXpath(document, resultCotentXpath);
+			if(!StringUtils.equals(resultCode, DatasyncConstant.RET_CODE_SUCCESS)){
+				logger.info("科室信息查询失败：" + resultCotent);
+				return null;
+			}
+			String itemXpath = "/RESPONSE/MSG_INFO/MSG/ORGUNIT_LIST/ORGUNIT";	// 返回结果可能存在多条科室信息
+			XPath xpath = document.createXPath(itemXpath);
+			@SuppressWarnings("unchecked")
+			List<Node> nodeList = xpath.selectNodes(document, xpath);
+			if(CollectionUtils.isNotEmpty(nodeList)){
+				for (int i = 1; i <= nodeList.size(); i++) {
+					
+					String msgXpath = itemXpath + "[" + i + "]";
+					// 科室编码
+					String codeXpath = msgXpath + "/ORGUNIT_CODE";
+					// 科室名称
+					String nameXpath = msgXpath + "/ORGUNIT_NAME";
+					// 上级科室编码
+					String parentCodingXpath = msgXpath + "/PARENT_ORGUNIT_CODE";
+					
+					String code = WebServiceClientHelper.processDataByXpath(document, codeXpath);
+					String name = WebServiceClientHelper.processDataByXpath(document, nameXpath);
+					String parentCoding = WebServiceClientHelper.processDataByXpath(document, parentCodingXpath);
+					OrgUnitVo orgUnitVo = new OrgUnitVo();
+					orgUnitVo.setCoding(code);
+					orgUnitVo.setName(name);
+					orgUnitVo.setParentCoding(parentCoding);
+					
+					//科室编码与上级科室编码相同时,默认其上级科室编码为空
+					if(StringUtils.equals(orgUnitVo.getCoding(), orgUnitVo.getParentCoding())){
+						orgUnitVo.setParentCoding(null);
+					}
+					//如果科室编码或名称为空,则忽略该条数据
+					if(StringUtils.isBlank(orgUnitVo.getCoding()) || StringUtils.isBlank(orgUnitVo.getName())){
+						continue;
+					}
+					orgUnitVoList.add(orgUnitVo);
+				}
+				orgUnitVoArray = new OrgUnitVo[orgUnitVoList.size()];
+				orgUnitVoList.toArray(orgUnitVoArray);
+			} else {
+				logger.info("未找到科室数据");
+			}
+		} catch (Exception e) {
+			e.printStackTrace();
+			logger.error("科室信息失败" + e);
+		}
+		return orgUnitVoArray;
+	}
+	
+	@Override
+	public OrgUnitVo[] paramToOrgUnitVos(String param) {
+		// TODO Auto-generated method stub
+		return null;
+	}
+
+	@Override
+	public UserVo[] paramToUserVos(String param) {
+		// TODO Auto-generated method stub
+		return null;
+	}
+
+	@Override
+	public JSONObject buttjoinResponse(Boolean success, String message,
+			String param) {
+		// TODO Auto-generated method stub
+		return null;
+	}
+	
+
+}
Index: ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/datasynchronization/dao/bj309yy/DatasyncConstant.java
===================================================================
diff -u
--- ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/datasynchronization/dao/bj309yy/DatasyncConstant.java	(revision 0)
+++ ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/datasynchronization/dao/bj309yy/DatasyncConstant.java	(revision 36473)
@@ -0,0 +1,62 @@
+package com.forgon.disinfectsystem.datasynchronization.dao.bj309yy;
+
+/**
+ * 北京309医院接口相关常量
+ *
+ */
+public class DatasyncConstant {
+
+	/**
+	 * 科室信息、人员信息、患者信息Web Service接口地址：http://172.25.0.82:9090/services/HisMessageServiceV1
+	 */
+	public final static String WebserviceAddress = "http://172.25.0.82:9090/services/HisMessageServiceV1";
+	
+	public final static String targetNamespace = "http://service.forgon.com/";
+	
+	public final static String soapAction = "HisMessageServiceV1";
+	
+	public final static String method = "HisMessageServiceV1";
+	
+	public final static String paramName = "message";
+
+    /**
+     * 科室查询的action
+     */
+    public static String ACTION_ORGUNIT_INFO_QUERY = "ORGUNIT_INFO_QUERY";
+
+    /**
+     * 人员查询的action
+     */
+    public static String ACTION_USER_INFO_QUERY = "USER_INFO_QUERY";
+
+    /**
+     * 患者信息查询的action
+     */
+    public static String ACTION_PATIENT_INFO_QUERY = "PATIENT_INFO_QUERY";
+
+    /**
+     * 根据住院号查询
+     */
+    public static String CODE_TYPE_HOSPITAL_NUMBER = "INHOSP_INDEX_NO";
+
+    /**
+     * 根据诊疗号查询
+     */
+    public static String CODE_TYPE_TREATMENT_NUMBER = "OUTHOSP_INDEX_NO";
+
+    /**
+     * 根据手术单号查询
+     */
+    public static String CODE_TYPE_OPRATION_SCHEDULEID = "SURGERY_APPLI_FORM_NO";
+
+    /**
+     * 调用成功的返回码
+     */
+    public static String RET_CODE_SUCCESS = "0";
+
+    /**
+     * 调用失败的返回码
+     */
+    public static String RET_CODE_FAIL = "1";
+	
+}
Index: ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/datasynchronization/dao/bj309yy/FindPatientInfoByHospitalNumDaoImpl.java
===================================================================
diff -u
--- ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/datasynchronization/dao/bj309yy/FindPatientInfoByHospitalNumDaoImpl.java	(revision 0)
+++ ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/datasynchronization/dao/bj309yy/FindPatientInfoByHospitalNumDaoImpl.java	(revision 36473)
@@ -0,0 +1,253 @@
+package com.forgon.disinfectsystem.datasynchronization.dao.bj309yy;
+
+import java.io.ByteArrayOutputStream;
+import java.io.PrintStream;
+import java.util.ArrayList;
+import java.util.Calendar;
+import java.util.Date;
+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;
+
+/**
+ * 根据住院号查询病人信息(北京309医院)
+ *
+ */
+public class FindPatientInfoByHospitalNumDaoImpl implements
+		FindPatientInfoByHospitalNumDao {
+	
+	Logger logger = Logger.getLogger(FindPatientInfoByHospitalNumDaoImpl.class);
+
+	@Override
+	public PatientInfoVO[] findPatientInfoByHospitalNum(String hospitalNum) {
+		try {
+			String inputXml = WebServiceClientHelper.buildInputStr(DatasyncConstant.ACTION_PATIENT_INFO_QUERY, DatasyncConstant.CODE_TYPE_HOSPITAL_NUMBER, hospitalNum);
+			logger.info("住院病人信息同步接口请求信息：" + inputXml);
+			String result = WebServiceClientHelper.axisInvokeWebservice(DatasyncConstant.WebserviceAddress, DatasyncConstant.targetNamespace, DatasyncConstant.soapAction, DatasyncConstant.method, DatasyncConstant.paramName, inputXml, "utf-8");
+			logger.info("病人信息同步接口返回信息：" + result);
+			/*String result = "<RESPONSE>"
+					+ "<RET_INFO>"
+					+ "<RET_CODE>0</RET_CODE>"
+					+ "<RET_DESCRIPTION></RET_DESCRIPTION>"
+					+ "</RET_INFO>"
+					+ "<MSG_INFO>"
+					+ "<MSG>"
+					+ "<SURGERY_LIST>"
+					+ "<SURGERY>"
+					+ "<INHOSP_INDEX_NO>0000000001</INHOSP_INDEX_NO>"
+					+ "<OUTHOSP_INDEX_NO></OUTHOSP_INDEX_NO>"
+					+ "<SURGERY_APPLI_FORM_NO>1</SURGERY_APPLI_FORM_NO>"
+					+ "<VISIT_ID>1</VISIT_ID>"
+					+ "<NAME>患者1</NAME>"
+					+ "<SEX>男</SEX>"
+					+ "<DATE_OF_BIRTH>1990-07-20 10:00:00</DATE_OF_BIRTH>"
+					+ "<OPERATION>手术名称</OPERATION>"
+					+ "<SCHEDULED_DATETIME>2023-07-25 17:48:00</SCHEDULED_DATETIME>"
+					+ "<OPERATING_ROOM_NO>001</OPERATING_ROOM_NO>"
+					+ "<SURGEON>医生</SURGEON>"
+					+ "<WASH_HAND_NURSE_CODE></WASH_HAND_NURSE_CODE>"
+					+ "<WASH_HAND_NURSE_NAME>GY护士1</WASH_HAND_NURSE_NAME>"
+					+ "<CIRCUIT_NURSE_CODE></CIRCUIT_NURSE_CODE>"
+					+ "<CIRCUIT_NURSE_NAME>洗手护士</CIRCUIT_NURSE_NAME>"
+					+ "<USE_DEPT_CODE>4009H</USE_DEPT_CODE>"
+					+ "<USE_DEPT_NAME></USE_DEPT_NAME>"
+					+ "</SURGERY>"
+					+ "<SURGERY>"
+					+ "<INHOSP_INDEX_NO>0000000001</INHOSP_INDEX_NO>"
+					+ "<OUTHOSP_INDEX_NO></OUTHOSP_INDEX_NO>"
+					+ "<SURGERY_APPLI_FORM_NO>1</SURGERY_APPLI_FORM_NO>"
+					+ "<VISIT_ID>1</VISIT_ID>"
+					+ "<NAME>患者1</NAME>"
+					+ "<SEX>男</SEX>"
+					+ "<DATE_OF_BIRTH>1990-07-20 10:00:00</DATE_OF_BIRTH>"
+					+ "<OPERATION>手术名称</OPERATION>"
+					+ "<SCHEDULED_DATETIME>2023-07-25 17:48:00</SCHEDULED_DATETIME>"
+					+ "<OPERATING_ROOM_NO>001</OPERATING_ROOM_NO>"
+					+ "<SURGEON>医生</SURGEON>"
+					+ "<WASH_HAND_NURSE_CODE></WASH_HAND_NURSE_CODE>"
+					+ "<WASH_HAND_NURSE_NAME>GY护士1</WASH_HAND_NURSE_NAME>"
+					+ "<CIRCUIT_NURSE_CODE></CIRCUIT_NURSE_CODE>"
+					+ "<CIRCUIT_NURSE_NAME>洗手护士</CIRCUIT_NURSE_NAME>"
+					+ "<USE_DEPT_CODE>4009H</USE_DEPT_CODE>"
+					+ "<USE_DEPT_NAME></USE_DEPT_NAME>"
+					+ "</SURGERY>"
+					+ "</SURGERY_LIST>"
+					+ "</MSG>"
+					+ "</MSG_INFO>"
+					+ "</RESPONSE>";
+			logger.info("病人信息同步接口返回信息：" + result);*/
+			int startIndex = result.indexOf("<RESPONSE>");
+			if(startIndex == -1){
+				logger.info("住院病人接口返回信息没有<RESPONSE>标签！");
+				return null;
+			}
+			int endIndex = result.indexOf("</RESPONSE>");
+			if(endIndex == -1 || endIndex < startIndex){
+				logger.info("住院病人接口返回信息没有</RESPONSE>标签");
+				return null;
+			}
+			String xmlString = result.substring(startIndex + "<RESPONSE>".length(), endIndex);
+			if(StringUtils.isBlank(xmlString)){
+				logger.info("住院病人接口返回信息为空！" + xmlString);
+				return null;
+			}
+			xmlString = "<RESPONSE>" + xmlString + "</RESPONSE>";
+			Document document = DocumentHelper.parseText(xmlString);
+			// 查询结果
+			String resultCodeXpath = "/RESPONSE/RET_INFO/RET_CODE";
+			String resultCotentXpath = "/RESPONSE/RET_INFO/RET_DESCRIPTION";
+			String resultCode = WebServiceClientHelper.processDataByXpath(document, resultCodeXpath);
+			String resultCotent = WebServiceClientHelper.processDataByXpath(document, resultCotentXpath);
+			if(!StringUtils.equals(resultCode, DatasyncConstant.RET_CODE_SUCCESS)){
+				logger.info("住院病人接口查询失败：" + resultCotent);
+				return null;
+			}
+			String itemXpath = "/RESPONSE/MSG_INFO/MSG/SURGERY_LIST/SURGERY";	// 返回结果可能存在多条住院病人信息
+			XPath xpath = document.createXPath(itemXpath);
+			@SuppressWarnings("unchecked")
+			List<Node> nodeList = xpath.selectNodes(document, xpath);
+			if(CollectionUtils.isNotEmpty(nodeList)){
+				List<PatientInfoVO> patientInfoVOList = new ArrayList<PatientInfoVO>();
+				for (int i = 1; i <= nodeList.size(); i++) {
+					String msgXpath = itemXpath + "[" + i + "]";
+					// 住院号
+					String hospitalNumberXpath = msgXpath + "/INHOSP_INDEX_NO";
+					// 流水号
+					String serialNumberXpath = msgXpath + "/VISIT_ID";
+					// 所属科室
+					String ascriptionDepartmentXpath = msgXpath + "/DEPT_STAYED";
+					// 手术时间
+					String operationTimeXpath = msgXpath + "/SCHEDULED_DATETIME";
+					// 手术间
+					String opRoomIdXpath = msgXpath + "/OPERATING_ROOM_NO";
+					// 医生姓名
+					String doctorNameXpath = msgXpath + "/SURGEON";
+					//巡回护士
+					String circuitNurseXpath = msgXpath + "/FIRST_OPERATION_NURSE";
+					//洗手护士
+					String washHandNurseXpath = msgXpath + "/FIRST_SUPPLY_NURSE";
+					// 手术单号
+					String operationScheduleIdXpath = msgXpath + "/SURGERY_APPLI_FORM_NO";
+					// 手术名称
+					String operationXpath = msgXpath + "/OPERATION";
+					// 病人姓名
+					String patientNameXpath = msgXpath + "/NAME";
+					// 病人年龄
+					String patientBirthDayXpath = msgXpath + "/DATE_OF_BIRTH";
+					// 病人性别
+					String patientSexXpath = msgXpath + "/SEX";
+					
+					String hospitalNumber = WebServiceClientHelper.processDataByXpath(document, hospitalNumberXpath);
+					String serialNumber = WebServiceClientHelper.processDataByXpath(document, serialNumberXpath);
+					String ascriptionDepartment = WebServiceClientHelper.processDataByXpath(document, ascriptionDepartmentXpath);
+					String operationTime = WebServiceClientHelper.processDataByXpath(document, operationTimeXpath);
+					String opRoomId = WebServiceClientHelper.processDataByXpath(document, opRoomIdXpath);
+					String doctorName = WebServiceClientHelper.processDataByXpath(document, doctorNameXpath);
+					String circuitNurse = WebServiceClientHelper.processDataByXpath(document, circuitNurseXpath);
+					String washHandNurse = WebServiceClientHelper.processDataByXpath(document, washHandNurseXpath);
+					String operationScheduleId =  WebServiceClientHelper.processDataByXpath(document, operationScheduleIdXpath);
+					String operation = WebServiceClientHelper.processDataByXpath(document, operationXpath);
+					String patientName = WebServiceClientHelper.processDataByXpath(document, patientNameXpath);
+					String patientSex = WebServiceClientHelper.processDataByXpath(document, patientSexXpath);
+					String patientAge = null;
+					String patientBirthDate = WebServiceClientHelper.processDataByXpath(document, patientBirthDayXpath);
+					Integer age = getAgeByDateTime(patientBirthDate);
+					if(age != null){
+						patientAge = age.intValue() + "";
+					}
+
+					PatientInfoVO patientInfoVO = new PatientInfoVO();
+					patientInfoVO.setHospitalNumber(hospitalNumber);
+					patientInfoVO.setSerialNumber(serialNumber);
+					patientInfoVO.setAscriptionDepartment(ascriptionDepartment);
+					patientInfoVO.setOperationTime(operationTime);
+					patientInfoVO.setOpRoomId(opRoomId);
+					patientInfoVO.setDoctorName(doctorName);
+					patientInfoVO.setCircuitNurse(circuitNurse);
+					patientInfoVO.setWashHandNurse(washHandNurse);
+					patientInfoVO.setOperationScheduleId(operationScheduleId);
+					patientInfoVO.setOperation(operation);
+					patientInfoVO.setPatientName(patientName);
+					patientInfoVO.setPatientAge(patientAge);
+					patientInfoVO.setPatientSex(patientSex);
+
+					patientInfoVOList.add(patientInfoVO);
+				}
+				if (CollectionUtils.isNotEmpty(patientInfoVOList)) {
+					// 只取最新录入的一条记录
+					PatientInfoVO patientInfoVO = patientInfoVOList.get(0);
+					logger.debug("完成住院病人信息解析，病人住院号为：" + patientInfoVO.getHospitalNumber());
+					PatientInfoVO[] patientInfoArray = new PatientInfoVO[patientInfoVOList.size()];
+					for(int i=0;i<patientInfoVOList.size();i++){
+						patientInfoArray[i] = patientInfoVOList.get(i);
+					}
+					return patientInfoArray;
+				}
+			}
+		} catch (Exception e) {
+			ByteArrayOutputStream baos = new ByteArrayOutputStream();		
+			e.printStackTrace(new PrintStream(baos));
+			String exception = baos.toString();
+			logger.error("根据病人住院号查询病人信息失败" + exception);
+			e.printStackTrace();
+		}
+		return null;
+	}
+
+	@Override
+	public PatientInfoVO[] findPatientInfoByHospitalNumBeforeOperation(
+			String hospitalNum) {
+		return findPatientInfoByHospitalNum(hospitalNum);
+	}
+	
+    /**
+     * 根据出生日期计算年龄
+     * @param birthDay
+     * @return
+     */
+    private Integer getAgeByDateTime(String patientBirthDate) {
+    	
+    	Date birthDay = null;
+    	try {
+    		birthDay = DateTools.coverStrToDate(patientBirthDate, DateTools.COMMON_DATE_HMS);
+		} catch (Exception e) {
+			e.printStackTrace();
+		}
+    	
+        Calendar cal = Calendar.getInstance();
+        if(birthDay == null || cal.before(birthDay)){
+            return null;
+        }
+        int yearNow = cal.get(Calendar.YEAR); //当前年份
+        int monthNow = cal.get(Calendar.MONTH); //当前月份
+        int dayOfMonthNow = cal.get(Calendar.DAY_OF_MONTH); //当前日期
+
+        cal.setTime(birthDay);
+        int yearBirth = cal.get(Calendar.YEAR);
+        int monthBirth = cal.get(Calendar.MONTH);
+        int dayOfMonthBirth = cal.get(Calendar.DAY_OF_MONTH);
+        int age = yearNow - yearBirth; //计算整岁数
+
+        if (monthNow <= monthBirth) {
+            if (monthNow == monthBirth) {
+                if (dayOfMonthNow < dayOfMonthBirth) {
+                    age--;//当前日期在生日之前，年龄减一
+                }
+            }else{
+                age--;//当前月份在生日之前，年龄减一
+            }
+        }
+        return age;
+    }
+	
+}
Index: ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/datasynchronization/dao/bj309yy/WebServiceClientHelper.java
===================================================================
diff -u
--- ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/datasynchronization/dao/bj309yy/WebServiceClientHelper.java	(revision 0)
+++ ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/datasynchronization/dao/bj309yy/WebServiceClientHelper.java	(revision 36473)
@@ -0,0 +1,126 @@
+package com.forgon.disinfectsystem.datasynchronization.dao.bj309yy;
+
+import javax.xml.namespace.QName;
+
+import org.apache.axis.client.Call;
+import org.apache.axis.client.Service;
+import org.apache.commons.lang.StringUtils;
+import org.apache.log4j.Logger;
+import org.dom4j.Document;
+import org.dom4j.Node;
+import org.dom4j.XPath;
+
+/**
+ * 北京309医院webservice帮助类
+ *
+ */
+public class WebServiceClientHelper {
+	
+	public static Logger logger = Logger.getLogger(WebServiceClientHelper.class);
+	
+	/**
+	 * 根据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;
+	}
+	
+	/**
+	 * 构建请求信息
+	 **/
+	public static String buildInputStr(String action, String codeType, String code){
+		StringBuffer inputSb = new StringBuffer();
+		if(StringUtils.equals(action, DatasyncConstant.ACTION_ORGUNIT_INFO_QUERY)){
+			inputSb.append("<REQUEST>");
+			inputSb.append("<ACTION>" + DatasyncConstant.ACTION_ORGUNIT_INFO_QUERY + "</ACTION>");
+			inputSb.append("<MSG>");
+			inputSb.append("<ORGUNIT_CODE>" + StringUtils.defaultString(code) + "</ORGUNIT_CODE>");
+			inputSb.append("</MSG>");
+			inputSb.append("</REQUEST>");
+		} else if(StringUtils.equals(action, DatasyncConstant.ACTION_USER_INFO_QUERY)){
+			inputSb.append("<REQUEST>");
+			inputSb.append("<ACTION>" + DatasyncConstant.ACTION_USER_INFO_QUERY + "</ACTION>");
+			inputSb.append("<MSG>");
+			inputSb.append("<ORGUNIT_CODE>" + StringUtils.defaultString(code) + "</ORGUNIT_CODE>");
+			inputSb.append("</MSG>");
+			inputSb.append("</REQUEST>");
+		} else if(StringUtils.equals(action, DatasyncConstant.ACTION_PATIENT_INFO_QUERY)){
+			if(StringUtils.equals(codeType, DatasyncConstant.CODE_TYPE_HOSPITAL_NUMBER)){
+				inputSb.append("<REQUEST>");
+				inputSb.append("<ACTION>" + DatasyncConstant.ACTION_PATIENT_INFO_QUERY + "</ACTION>");
+				inputSb.append("<MSG>");
+				inputSb.append("<CODE_TYPE>" + DatasyncConstant.CODE_TYPE_HOSPITAL_NUMBER + "</CODE_TYPE>");
+				inputSb.append("<CODE>" + StringUtils.defaultString(code) + "</CODE>");
+				inputSb.append("</MSG>");
+				inputSb.append("</REQUEST>");
+			} else if(StringUtils.equals(codeType, DatasyncConstant.CODE_TYPE_TREATMENT_NUMBER)){
+				inputSb.append("<REQUEST>");
+				inputSb.append("<ACTION>" + DatasyncConstant.ACTION_PATIENT_INFO_QUERY + "</ACTION>");
+				inputSb.append("<MSG>");
+				inputSb.append("<CODE_TYPE>" + DatasyncConstant.CODE_TYPE_TREATMENT_NUMBER + "</CODE_TYPE>");
+				inputSb.append("<CODE>" + StringUtils.defaultString(code) + "</CODE>");
+				inputSb.append("</MSG>");
+				inputSb.append("</REQUEST>");
+			} else if(StringUtils.equals(codeType, DatasyncConstant.CODE_TYPE_OPRATION_SCHEDULEID)){
+				inputSb.append("<REQUEST>");
+				inputSb.append("<ACTION>" + DatasyncConstant.ACTION_PATIENT_INFO_QUERY + "</ACTION>");
+				inputSb.append("<MSG>");
+				inputSb.append("<CODE_TYPE>" + DatasyncConstant.CODE_TYPE_OPRATION_SCHEDULEID + "</CODE_TYPE>");
+				inputSb.append("<CODE>" + StringUtils.defaultString(code) + "</CODE>");
+				inputSb.append("</MSG>");
+				inputSb.append("</REQUEST>");
+			} else{
+				throw new RuntimeException("无效的codeType值");
+			}
+		} else {
+			throw new RuntimeException("无效的action值");
+		}
+		return inputSb.toString();
+	}
+	
+    /**
+     * axis调用webservice
+     * @param endpoint 			<soap:address location="">
+     * @param targetNamespace 	命名空间，在WSDL中对应的标签是：targetNamespace 
+     * @param soapActionURI 	具体方法的调用URI，在WSDL中对应的标签是：<soap:operation soapAction="">
+     * @param method 			具体调用的方法名，在WSDL中对应的标签是： <operation name="">
+     * @param paramName			调用接口的参数的名字  <s:element name="queryDepts"> 
+     * @param input				参数值
+     * @param encodingStyle		字符集"utf-8"
+     * @return
+     * @throws Exception
+     */
+    public static String axisInvokeWebservice(String endpoint, String targetNamespace, String soapActionURI, String method,
+    		String paramName, String input, String encodingStyle) throws Exception {
+		//logger.info("input : " + input);
+		Service service = new Service();  
+		Call call = (Call) service.createCall(); 
+		//call.setTimeout(new Integer(20000));  //设置超时时间
+		call.setSOAPActionURI(soapActionURI);
+		call.setTargetEndpointAddress(new java.net.URL(endpoint));  //设置目标接口的地址
+		call.setEncodingStyle(encodingStyle);//设置传入服务端的字符集格式如utf-8等
+		call.setOperationName(new QName(targetNamespace, method));// 具体调用的方法名，可以由接口提供方告诉你，也可以自己从WSDL中找  
+		call.setUseSOAPAction(true); 
+		call.addParameter(paramName,  
+				org.apache.axis.encoding.XMLType.XSD_STRING,  
+				javax.xml.rpc.ParameterMode.IN);// 接口的参数  
+		call.setReturnClass(java.lang.String.class); //返回字符串类型
+		// 给方法传递参数，并且调用方法 ，如果无参，则new Obe 
+		String result = (String)call.invoke(new String[] {input});
+		// 打印返回值
+		//logger.info("result is " + result);  
+		return result;
+	}
+    
+}