Index: ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/datasynchronization/dao/szsdsrmyy/SyncOrgUnitAndUserDaoImpl.java
===================================================================
diff -u
--- ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/datasynchronization/dao/szsdsrmyy/SyncOrgUnitAndUserDaoImpl.java	(revision 0)
+++ ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/datasynchronization/dao/szsdsrmyy/SyncOrgUnitAndUserDaoImpl.java	(revision 27832)
@@ -0,0 +1,200 @@
+package com.forgon.disinfectsystem.datasynchronization.dao.szsdsrmyy;
+
+
+import java.util.ArrayList;
+import java.util.List;
+
+import net.sf.json.JSON;
+import net.sf.json.JSONArray;
+import net.sf.json.JSONObject;
+import net.sf.json.xml.XMLSerializer;
+
+import org.apache.commons.lang.StringUtils;
+import org.apache.log4j.Logger;
+
+import com.forgon.disinfectsystem.common.CssdUtils;
+import com.forgon.disinfectsystem.datasynchronization.dao.SyncOrgUnitAndUserDao;
+import com.forgon.disinfectsystem.datasynchronization.model.OrgUnitVo;
+import com.forgon.disinfectsystem.datasynchronization.model.UserVo;
+import com.forgon.tools.Constants;
+
+/**
+ * 查询his系统科室与人员信息(深圳市第三人民医院)
+ * @author ZhouPeiMian
+ * @since 2020-04-17
+ *
+ */
+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.buildInputString(DatasyncConstant.MethodName_User);
+			logger.info("his人员同步接口请求信息：" + inputXml);
+			//String result = CssdUtils.callWebService(DatasyncConstant.WebserviceAddress, inputXml, Constants.CHARSET_UTF8);
+			String result = WebServiceClientHelper.doPostSoap1_2(DatasyncConstant.WebserviceAddress, inputXml, DatasyncConstant.MethodName_User);
+			logger.info("his人员同步接口返回信息：" + result);
+			/*String result = 
+			"<soap:Envelope xmlns:soap=\"http://schemas.xmlsoap.org/soap/envelope/\">"
+			+ "<soap:Body>"
+			+ "<ns2:HIPMessageServerResponse xmlns:ns2=\"urn:hl7-org:v3\">"
+			+ "<return><![CDATA[<DataSource><EmployeeInfo_Response><his_dept_code>3041</his_dept_code><emp_ext3>null</emp_ext3><his_emp_type>D</his_emp_type><emp_ext1>null</emp_ext1><dept_code>3041</dept_code><emp_name>吴其恺</emp_name><wubi_code>KAN</wubi_code><curt_dept_code>肝病一科</curt_dept_code><salary_id>null</salary_id><education>null</education><emp_status>null</emp_status><spell_code>WQK</spell_code><comp_code>45575559-X</comp_code><if_attendance>null</if_attendance><emp_type>D</emp_type><emp_idno>440301196410283472</emp_idno><sex_code>1</sex_code><bank_code>null</bank_code><title_type>5</title_type><email>null</email><emp_code>000016</emp_code><phone>13902973973</phone><birthday>1964-10-28</birthday><valid_state>1</valid_state><duty_type>26</duty_type><entry_date>2020-04-17</entry_date><emp_ext2>null</emp_ext2><attendance_type>null</attendance_type><messageId>GUID</messageId><businessTime>2020-04-16T00:00:00</businessTime><responseId>4028999a708eb056017185d8727b00d4</responseId><resultMark>OK</resultMark><resultMsg>找到数据</resultMsg></EmployeeInfo_Response><EmployeeInfo_Response><his_dept_code>2013</his_dept_code><emp_ext3>null</emp_ext3><his_emp_type>D</his_emp_type><emp_ext1>null</emp_ext1><dept_code>2013</dept_code><emp_name>林敏</emp_name><wubi_code>ST</wubi_code><curt_dept_code>体检科门诊</curt_dept_code><salary_id>null</salary_id><education>null</education><emp_status>null</emp_status><spell_code>LM</spell_code><comp_code>45575559-X</comp_code><if_attendance>null</if_attendance><emp_type>D</emp_type><emp_idno>null</emp_idno><sex_code>2</sex_code><bank_code>null</bank_code><title_type>7</title_type><email>null</email><emp_code>002406</emp_code><phone>null</phone><birthday>2012-06-07</birthday><valid_state>0</valid_state><duty_type>26</duty_type><entry_date>2020-04-17</entry_date><emp_ext2>null</emp_ext2><attendance_type>null</attendance_type><messageId>GUID</messageId><businessTime>2020-04-16T00:00:00</businessTime><responseId>4028999a708eb056017185d8727b00d4</responseId><resultMark>OK</resultMark><resultMsg>找到数据</resultMsg></EmployeeInfo_Response></DataSource>]]></return>"
+			+ "</ns2:HIPMessageServerResponse>"
+			+ "</soap:Body>"
+			+ "</soap:Envelope>";*/
+			int startIndex = result.indexOf("<DataSource>");
+			if(startIndex == -1){
+				return null;
+			}
+			int endIndex = result.indexOf("</DataSource>");
+			if(endIndex == -1 || endIndex < startIndex){
+				return null;
+			}
+			String xmlString = result.substring(startIndex + "<DataSource>".length(), endIndex);
+			XMLSerializer xmlSerializer = new XMLSerializer();
+			xmlString = "<DataSource>" + xmlString + "<xml>xml</xml>" + "</DataSource>";
+			JSON json = xmlSerializer.read(xmlString);
+			JSONObject userVoInfos = (JSONObject)json;
+			if(userVoInfos != null){
+				JSONArray userVoInfoArr = new JSONArray();
+				Object userObj = userVoInfos.opt("EmployeeInfo_Response");
+				if(userObj instanceof JSONArray){
+					userVoInfoArr = (JSONArray) userObj;
+				} else if (userObj instanceof JSONObject) {
+					userVoInfoArr.add((JSONObject)userObj);
+				}
+				if(userVoInfoArr.size() > 0){
+					for (Object object : userVoInfoArr) {
+						JSONObject userJSON = (JSONObject) object;
+						String resultMark = userJSON.optString("resultMark", "");
+						if(!StringUtils.equals(resultMark, DatasyncConstant.RESULT_MARK)){
+							continue;
+						}
+						Object coding = userJSON.opt("emp_code");
+						Object name = userJSON.opt("emp_name");
+						Object orgUnitCoding = userJSON.opt("dept_code");
+						UserVo userVo = new UserVo();
+						userVo.setCoding(coding instanceof String ? (String)coding : "");
+						userVo.setName(name instanceof String ? (String)name : "");
+						userVo.setOrgUnitCoding(orgUnitCoding instanceof String ? (String)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("查询his人员信息失败:" + e);
+		}
+		return userVoArray;
+	}
+
+	@Override
+	public OrgUnitVo[] getAllOrgUnit() {
+		OrgUnitVo[] orgUnitVoArray = null;
+		List<OrgUnitVo> orgUnitVoList = new ArrayList<OrgUnitVo>();
+		try {
+			String inputXml = WebServiceClientHelper.buildInputString(DatasyncConstant.MethodName_Department);
+			logger.info("his科室同步接口请求信息：" + inputXml);
+			String result = WebServiceClientHelper.doPostSoap1_2(DatasyncConstant.WebserviceAddress, inputXml, DatasyncConstant.MethodName_Department);
+			logger.info("his科室同步接口返回信息：" + result);
+			/*String result = 
+			"<soap:Envelope xmlns:soap=\"http://schemas.xmlsoap.org/soap/envelope/\">"
+			+ "<soap:Body>"
+			+ "<ns2:HIPMessageServerResponse xmlns:ns2=\"urn:hl7-org:v3\">"
+			+ "<return><![CDATA[<DataSource><DeptInfo_Response><branch_code>null</branch_code><is_register>1</is_register><dept_ext1>null</dept_ext1><his_dept_type>C</his_dept_type><is_stock>null</is_stock><dept_name>心血管专科门诊</dept_name><is_budg>null</is_budg><dept_code>0134</dept_code><his_dept_code>0134</his_dept_code><is_account>1</is_account><dept_ext3>null</dept_ext3><eng_name>[门诊二楼]</eng_name><dept_ext2>null</dept_ext2><wubi_code>NTTFTUY</wubi_code><is_special>0</is_special><spell_code>XXGZKMZ</spell_code><dept_addr>null</dept_addr><is_outer>null</is_outer><simple_name>心血管专科门诊</simple_name><dept_level>null</dept_level><super_code>01</super_code><valid_state>1</valid_state><is_func>null</is_func><is_last>null</is_last><dept_type>C</dept_type><comp_code>45575559-X</comp_code><messageId>GUID</messageId><businessTime>2020-04-16T00:00:00</businessTime><responseId>4028999a6b01e362016c283fe7b418b4</responseId><resultMark>OK</resultMark><resultMsg>找到数据</resultMsg></DeptInfo_Response><DeptInfo_Response><branch_code>null</branch_code><is_register>0</is_register><dept_ext1>null</dept_ext1><his_dept_type>N</his_dept_type><is_stock>null</is_stock><dept_name>皮肤科分诊台</dept_name><is_budg>null</is_budg><dept_code>2027</dept_code><his_dept_code>2027</his_dept_code><is_account>0</is_account><dept_ext3>null</dept_ext3><eng_name>192.168.16.181</eng_name><dept_ext2>null</dept_ext2><wubi_code>HETWYC</wubi_code><is_special>0</is_special><spell_code>PFKFZT</spell_code><dept_addr>null</dept_addr><is_outer>null</is_outer><simple_name>皮肤科分诊台</simple_name><dept_level>null</dept_level><super_code>null</super_code><valid_state>1</valid_state><is_func>null</is_func><is_last>null</is_last><dept_type>N</dept_type><comp_code>45575559-X</comp_code><messageId>GUID</messageId><businessTime>2020-04-16T00:00:00</businessTime><responseId>4028999a6b01e362016c283fe7b418b4</responseId><resultMark>OK</resultMark><resultMsg>找到数据</resultMsg></DeptInfo_Response></DataSource>]]></return>"
+			+ "</ns2:HIPMessageServerResponse>"
+			+ "</soap:Body>"
+			+ "</soap:Envelope>";*/
+			int startIndex = result.indexOf("<DataSource>");
+			if(startIndex == -1){
+				return null;
+			}
+			int endIndex = result.indexOf("</DataSource>");
+			if(endIndex == -1 || endIndex < startIndex){
+				return null;
+			}
+			String xmlString = result.substring(startIndex + "<DataSource>".length(), endIndex);
+			XMLSerializer xmlSerializer = new XMLSerializer();
+			xmlString = "<DataSource>" + xmlString + "<xml>xml</xml>" + "</DataSource>";
+			JSON json = xmlSerializer.read(xmlString);
+			JSONObject orgUnitVoInfos = (JSONObject)json;
+			if(orgUnitVoInfos != null){
+				JSONArray deptInfoArr = new JSONArray();
+				Object deptObj = orgUnitVoInfos.opt("DeptInfo_Response");
+				if(deptObj instanceof JSONArray){
+					deptInfoArr = (JSONArray) deptObj;
+				} else if (deptObj instanceof JSONObject) {
+					deptInfoArr.add((JSONObject)deptObj);
+				}
+				if(deptInfoArr.size() > 0){
+					for (Object object : deptInfoArr) {
+						JSONObject orgUnitInfo = (JSONObject) object;
+						String resultMark = orgUnitInfo.optString("resultMark", "");
+						if(!StringUtils.equals(resultMark, DatasyncConstant.RESULT_MARK)){
+							continue;
+						}
+						Object coding = orgUnitInfo.opt("dept_code");
+						Object name = orgUnitInfo.opt("dept_name");
+						Object orgUnitCoding = orgUnitInfo.opt("super_code");
+						OrgUnitVo orgVo = new OrgUnitVo();
+						orgVo.setCoding(coding instanceof String ? (String)coding : "");
+						orgVo.setName(name instanceof String ? (String)name : "");
+						orgVo.setParentCoding(orgUnitCoding instanceof String ? (String)orgUnitCoding : "");
+						//科室编码与上级科室编码相同时,默认其上级科室编码为空
+						if(StringUtils.equals(orgVo.getCoding(), orgVo.getParentCoding())){
+							orgVo.setParentCoding(null);
+						}
+						//如果科室编码或名称为空,则忽略该条数据
+						if(StringUtils.isBlank(orgVo.getCoding()) || StringUtils.isBlank(orgVo.getName())){
+							continue;
+						}
+						orgUnitVoList.add(orgVo);
+					}
+					orgUnitVoArray = new OrgUnitVo[orgUnitVoList.size()];
+					orgUnitVoList.toArray(orgUnitVoArray);
+				} else {
+					throw new RuntimeException("未找到科室数据...");
+				}
+			} else {
+				throw new RuntimeException("未找到科室数据...");
+			}
+		} catch (Exception e) {
+			e.printStackTrace();
+			logger.error("查询his科室信息失败" + 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/szsdsrmyy/DatasyncConstant.java
===================================================================
diff -u
--- ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/datasynchronization/dao/szsdsrmyy/DatasyncConstant.java	(revision 0)
+++ ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/datasynchronization/dao/szsdsrmyy/DatasyncConstant.java	(revision 27832)
@@ -0,0 +1,51 @@
+package com.forgon.disinfectsystem.datasynchronization.dao.szsdsrmyy;
+
+/**
+ * 深圳市第三人民医院接口相关常量
+ * @author ZhouPeiMian
+ * @since 2020-04-17
+ *
+ */
+public class DatasyncConstant {
+
+	/**
+	 * Webservice地址
+	 */
+	public final static String WebserviceAddress = "http://192.168.25.25:8001/HIP/webService/hl7/HL7Delegate1_1?wsdl";
+
+	/**
+	 * 按诊疗号查询病人信息的接口方法名
+	 */
+	public final static String MethodName_ClinicNumber = "OutpatientInfoForCSSD";
+	
+	/**
+	 * 按住院号查询病人信息的接口方法名
+	 */
+	public final static String MethodName_HospitalNumber = "InpatientInfoForCSSD";
+
+	/**
+	 * 科室信息的接口方法名(作为输入参数)
+	 */
+	public final static String MethodName_Department = "queryDeptInfo";
+	
+	/**
+	 * 人员信息的接口方法名(作为输入参数)
+	 */
+	public final static String MethodName_User = "queryEmployeeInfo";
+	
+	/**
+	 * 病人信息查询成功标识
+	 */
+	public final static String SUCCESS_STATUS = "AA";
+	
+	/**
+	 * 病人信息查询失败标识
+	 */
+	public final static String FAIL_STATUS = "AE";
+	
+	/**
+	 * 科室人员返回状态：OK
+	 */
+	public final static String RESULT_MARK = "OK";
+
+}
Index: ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/datasynchronization/dao/szsdsrmyy/FindPatientInfoByHospitalNumDaoImpl.java
===================================================================
diff -u
--- ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/datasynchronization/dao/szsdsrmyy/FindPatientInfoByHospitalNumDaoImpl.java	(revision 0)
+++ ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/datasynchronization/dao/szsdsrmyy/FindPatientInfoByHospitalNumDaoImpl.java	(revision 27832)
@@ -0,0 +1,120 @@
+package com.forgon.disinfectsystem.datasynchronization.dao.szsdsrmyy;
+
+import net.sf.json.JSON;
+import net.sf.json.JSONArray;
+import net.sf.json.JSONObject;
+import net.sf.json.xml.XMLSerializer;
+
+import org.apache.commons.lang.StringUtils;
+import org.apache.log4j.Logger;
+
+import com.forgon.disinfectsystem.common.CssdUtils;
+import com.forgon.disinfectsystem.datasynchronization.dao.FindPatientInfoByHospitalNumDao;
+import com.forgon.disinfectsystem.datasynchronization.dao.szsdsrmyy.DatasyncConstant;
+import com.forgon.disinfectsystem.datasynchronization.model.PatientInfoVO;
+import com.forgon.tools.Constants;
+
+/**
+ * 根据住院号查询病人信息(深圳市第三人民医院)
+ * @author ZhouPeiMian
+ * @since 2020-04-17
+ *
+ */
+public class FindPatientInfoByHospitalNumDaoImpl implements
+		FindPatientInfoByHospitalNumDao {
+	
+	Logger logger = Logger.getLogger(FindPatientInfoByHospitalNumDaoImpl.class);
+
+	@Override
+	public PatientInfoVO[] findPatientInfoByHospitalNum(String hospitalNum) {
+		try {
+			String inputXml = WebServiceClientHelper.buildInputString(DatasyncConstant.MethodName_HospitalNumber, hospitalNum);
+			logger.info("住院号病人同步接口请求信息：" + inputXml);
+			String result = WebServiceClientHelper.doPostSoap1_2(DatasyncConstant.WebserviceAddress, inputXml, DatasyncConstant.MethodName_HospitalNumber);
+			//String result = "<soap:Envelope xmlns:soap='http://schemas.xmlsoap.org/soap/envelope/'><soap:Body><ns2:HIPMessageServerResponse xmlns:ns2='urn:hl7-org:v3'><return><![CDATA[<DataSource><OnReceiveResult><response><return><hospitalNumber>0000225139</hospitalNumber><searialNumber>ZY010000225139</searialNumber><patientName>周彦光</patientName><patientAge>30岁</patientAge><patientSex>男</patientSex><patientIDCard>430481198912185017</patientIDCard><doctorName>陶红光</doctorName><operation>颈淋巴结清扫术</operation><operationTime>2020/4/16 10:00:00</operationTime><patientArea>胃肠外科护士站</patientArea><roomNumber>胃肠外科</roomNumber><bedNumber>520235</bedNumber><remark></remark><washHandNurse>0</washHandNurse><circuitNurse>0</circuitNurse></return><Status>AA</Status><Message></Message></response></OnReceiveResult></DataSource>]]></return></ns2:HIPMessageServerResponse></soap:Body></soap:Envelope>";
+			logger.info("住院号病人同步接口返回信息：" + result);
+			int startIndex = result.indexOf("<OnReceiveResult>");
+			if(startIndex == -1){
+				return null;
+			}
+			int endIndex = result.indexOf("</OnReceiveResult>");
+			if(endIndex == -1 || endIndex < startIndex){
+				return null;
+			}
+			String xmlString = result.substring(startIndex + "<OnReceiveResult>".length(), endIndex);
+			XMLSerializer xmlSerializer = new XMLSerializer();
+			JSON json = xmlSerializer.read(xmlString);
+			JSONObject patientInfos = (JSONObject)json;
+			if(patientInfos != null){
+				if(patientInfos != null){
+					String status = patientInfos.optString("Status");
+					if(StringUtils.equals(DatasyncConstant.FAIL_STATUS, status)){
+						logger.info("根据住院号查询病人信息失败：Status = " + status + "; Message = " + patientInfos.optString("Message"));
+						return null;
+					}
+					JSONArray patientInfoArr = new JSONArray();
+					Object returnObj = patientInfos.opt("return");
+					if(returnObj instanceof JSONArray){
+						patientInfoArr = (JSONArray) returnObj;
+					} else if (returnObj instanceof JSONObject){
+						patientInfoArr.add((JSONObject)returnObj);
+					}
+					if(patientInfoArr.size() > 0){
+						int i = 0;
+						PatientInfoVO[] patientInfoVOArray = new PatientInfoVO[patientInfoArr.size()];
+						for (Object object : patientInfoArr) {
+							JSONObject patientInfo = (JSONObject) object;
+							Object tNumber = patientInfo.opt("hospitalNumber");
+							Object patientName = patientInfo.opt("patientName");
+							Object patientAge = patientInfo.opt("patientAge");
+							Object patientSex = patientInfo.opt("patientSex");
+							Object patientIDCard = patientInfo.opt("patientIDCard");
+							Object doctorName = patientInfo.opt("doctorName");
+							Object operation = patientInfo.opt("operation");
+							Object opRoomId = patientInfo.opt("opRoomId");
+							Object operationTime = patientInfo.opt("operationTime");//
+							Object patientArea = patientInfo.opt("patientArea");
+							Object bedNumber = patientInfo.opt("bedNumber");
+							Object roomNumber = patientInfo.opt("roomNumber");
+							Object remark = patientInfo.opt("remark");
+							
+							Object washHandNurse = patientInfo.opt("washHandNurse");
+							Object circuitNurse = patientInfo.opt("circuitNurse");
+							
+							PatientInfoVO vo = new PatientInfoVO();
+							vo.setPatientNumber(tNumber instanceof String ? (String)tNumber : "");
+							vo.setPatientName(patientName instanceof String ? (String)patientName : "");
+							vo.setPatientAge(patientAge instanceof String ? (String)patientAge : "");
+							vo.setPatientSex(patientSex instanceof String ? (String)patientSex : "");
+							vo.setPatientIDCard(patientIDCard instanceof String ? (String)patientIDCard : "");
+							vo.setDoctorName(doctorName instanceof String ? (String)doctorName : "");
+							vo.setOperation(operation instanceof String ? (String)operation : "");
+							vo.setOpRoomId(opRoomId instanceof String ? (String)opRoomId : "");
+							vo.setOperationTime(operationTime instanceof String ? (String)operationTime : "");
+							vo.setPatientArea(patientArea instanceof String ? (String)patientArea : "");
+							vo.setBedNumber(bedNumber instanceof String ? (String)bedNumber : "");
+							vo.setRoomNumber(roomNumber instanceof String ? (String)roomNumber : "");
+							vo.setRemark(remark instanceof String ? (String)remark : "");
+							
+							vo.setWashHandNurse(washHandNurse instanceof String ? (String)washHandNurse : "");
+							vo.setCircuitNurse(circuitNurse instanceof String ? (String)circuitNurse : "");
+							patientInfoVOArray[i++] = vo;
+						}
+						return patientInfoVOArray;
+					}
+				}
+			}
+		} catch (Exception e) {
+			logger.error("根据住院号查询病人信息失败" + e);
+			e.printStackTrace();
+		}
+		return null;
+	}
+
+	@Override
+	public PatientInfoVO[] findPatientInfoByHospitalNumBeforeOperation(
+			String clinicNumber) {
+		return null;
+	}
+
+}
Index: ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/datasynchronization/dao/szsdsrmyy/WebServiceClientHelper.java
===================================================================
diff -u
--- ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/datasynchronization/dao/szsdsrmyy/WebServiceClientHelper.java	(revision 0)
+++ ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/datasynchronization/dao/szsdsrmyy/WebServiceClientHelper.java	(revision 27832)
@@ -0,0 +1,200 @@
+package com.forgon.disinfectsystem.datasynchronization.dao.szsdsrmyy;
+
+
+import java.nio.charset.Charset;
+import java.util.UUID;
+
+import org.apache.commons.lang.StringUtils;
+import org.apache.http.HttpEntity;
+import org.apache.http.client.config.RequestConfig;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.entity.StringEntity;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClientBuilder;
+import org.apache.http.util.EntityUtils;
+import org.apache.log4j.Logger;
+
+import com.forgon.tools.date.DateTools;
+
+/**
+ * 深圳市第三人民医院webservice帮助类
+ * @author ZhouPeiMian
+ * @since 2020-04-17
+ *
+ */
+public class WebServiceClientHelper {
+	
+	public static Logger logger = Logger.getLogger(WebServiceClientHelper.class);
+	
+	/**
+	 * 构造接口输入参数
+	 * @param transIdName
+	 * @param arg
+	 * @return
+	 */
+	public static String buildInputString(String methodName , String... arg){
+		String inputXml = "";
+		if(StringUtils.equals(methodName, DatasyncConstant.MethodName_Department)
+				|| StringUtils.equals(methodName, DatasyncConstant.MethodName_User)){
+			StringBuffer inputXmlSB = new StringBuffer();
+			inputXmlSB.append("<soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:urn=\"urn:hl7-org:v3\">");
+			inputXmlSB.append("<soapenv:Header/>");
+			inputXmlSB.append("<soapenv:Body>");
+			inputXmlSB.append("<urn:HIPMessageServer>");
+			// action
+			inputXmlSB.append("<action>" + methodName + "</action>");
+			// message
+			inputXmlSB.append("<message><![CDATA[");
+			inputXmlSB.append("<PRPA_IN000001UV03>");
+			inputXmlSB.append("<id root=\"2.999.1.96\" extension=\"" + UUID.randomUUID().toString() + "\"/>");
+			inputXmlSB.append("<creationTime value=\"" + DateTools.getCurrentDayByFormat("yyyyMMddHHmmssSSS") + "\" />");
+			inputXmlSB.append("<interactionId root=\"2.16.840.1.113883.1.6\" extension=\"PRPA_IN000001UV03\" />");
+			// receiver
+			inputXmlSB.append("<receiver typeCode=\"RCV\">");
+			inputXmlSB.append("<telecom value=\"\" />");
+			inputXmlSB.append("<device classCode=\"DEV\" determinerCode=\"INSTANCE\">");
+			inputXmlSB.append("<id root=\"2.999.1.97\" extension=\"MDM\" /><telecom value=\"设备编号\" />");
+			inputXmlSB.append("<softwareName code=\"MDM\" displayName=\"主数据管理系统\" codeSystem=\"2.999.2.3.2.84\" codeSystemName=\"医院信息平台系统域代码表\" />");
+			inputXmlSB.append("</device></receiver>");
+			// sender
+			inputXmlSB.append("<sender typeCode=\"SND\"><telecom value=\"\" />");
+			inputXmlSB.append("<device classCode=\"DEV\" determinerCode=\"INSTANCE\">");
+			inputXmlSB.append("<id root=\"2.999.1.98\" extension=\"QT-SPD\" />");
+			inputXmlSB.append("<telecom value=\"" + methodName + "\" />");
+			inputXmlSB.append("<softwareName code=\"QT-SPD\" displayName=\"供应链管理系统\" codeSystem=\"2.999.2.3.2.84\" codeSystemName=\"医院信息平台系统域代码表\" />");
+			inputXmlSB.append("</device></sender>");
+			// controlActProcess
+			if(StringUtils.equals(methodName, DatasyncConstant.MethodName_Department)){
+				inputXmlSB.append("<controlActProcess classCode=\"CACT\" moodCode=\"APT\">");
+				inputXmlSB.append("<subject typeCode=\"SUBJ\">");
+				inputXmlSB.append("<request><query_DeptInfo_Request>");
+				inputXmlSB.append("<DeptInfo_Request>");
+				inputXmlSB.append("<messageId>" + UUID.randomUUID().toString() + "</messageId>");
+				inputXmlSB.append("<businessTime>" + DateTools.getCurrentDayByFormat("yyyy-MM-dd'T'HH:mm:ss") + "</businessTime>");
+				inputXmlSB.append("</DeptInfo_Request>");
+				inputXmlSB.append("</query_DeptInfo_Request></request>");
+				inputXmlSB.append("</subject>");
+				inputXmlSB.append("</controlActProcess>");
+			} else {
+				inputXmlSB.append("<controlActProcess classCode=\"CACT\" moodCode=\"APT\">");
+				inputXmlSB.append("<subject typeCode=\"SUBJ\">");
+				inputXmlSB.append("<request><query_EmployeeInfo_Request>");
+				inputXmlSB.append("<EmployeeInfo_Request>");
+				inputXmlSB.append("<messageId>" + UUID.randomUUID().toString() + "</messageId>");
+				inputXmlSB.append("<businessTime>" + DateTools.getCurrentDayByFormat("yyyy-MM-dd'T'HH:mm:ss") + "</businessTime>");
+				inputXmlSB.append("</EmployeeInfo_Request>");
+				inputXmlSB.append("</query_EmployeeInfo_Request></request>");
+				inputXmlSB.append("</subject>");
+				inputXmlSB.append("</controlActProcess>");
+			}
+			inputXmlSB.append("</PRPA_IN000001UV03>");
+			inputXmlSB.append("]]></message>");
+			
+			inputXmlSB.append("</urn:HIPMessageServer> ");
+			inputXmlSB.append("</soapenv:Body>");
+			inputXmlSB.append("</soapenv:Envelope>");
+			inputXml = inputXmlSB.toString();
+		} else if (StringUtils.equals(methodName, DatasyncConstant.MethodName_ClinicNumber)
+				|| StringUtils.equals(methodName, DatasyncConstant.MethodName_HospitalNumber)) {
+			StringBuffer inputXmlSB = new StringBuffer();
+			inputXmlSB.append("<soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:urn=\"urn:hl7-org:v3\">");
+			inputXmlSB.append("<soapenv:Header/>");
+			inputXmlSB.append("<soapenv:Body>");
+			inputXmlSB.append("<urn:HIPMessageServer>");
+			// action
+			inputXmlSB.append("<action>" + methodName + "</action>");
+			// message
+			inputXmlSB.append("<message><![CDATA[");
+			inputXmlSB.append("<PRPA_IN000001UV03>");
+			inputXmlSB.append("<id root=\"2.999.1.96\" extension=\"" + UUID.randomUUID().toString() + "\"/>");
+			inputXmlSB.append("<creationTime value=\"" + DateTools.getCurrentDayByFormat("yyyyMMddHHmmssSSS") + "\" />");
+			inputXmlSB.append("<interactionId root=\"2.16.840.1.113883.1.6\" extension=\"PRPA_IN000001UV03\" />");
+			// receiver
+			inputXmlSB.append("<receiver typeCode=\"RCV\">");
+			inputXmlSB.append("<telecom value=\"\" />");
+			inputXmlSB.append("<device classCode=\"DEV\" determinerCode=\"INSTANCE\">");
+			inputXmlSB.append("<id root=\"2.999.1.97\" extension=\"HIP-HSB\" /><telecom value=\"设备编号\" />");
+			inputXmlSB.append("<softwareName code=\"HIP-HSB\" displayName=\"医疗服务总线\" codeSystem=\"2.999.2.3.2.84\" codeSystemName=\"医院信息平台系统域代码表\" />");
+			inputXmlSB.append("</device></receiver>");
+			// sender
+			inputXmlSB.append("<sender typeCode=\"SND\"><telecom value=\"\" />");
+			inputXmlSB.append("<device classCode=\"DEV\" determinerCode=\"INSTANCE\">");
+			inputXmlSB.append("<id root=\"2.999.1.98\" extension=\"QT-XDGY\" />");
+			inputXmlSB.append("<telecom value=\"" + methodName + "\" />");
+			inputXmlSB.append("<softwareName code=\"QT-XDGY\" displayName=\"消毒供应系统\" codeSystem=\"2.999.2.3.2.84\" codeSystemName=\"医院信息平台系统域代码表\" />");
+			inputXmlSB.append("</device></sender>");
+			// controlActProcess
+			if(StringUtils.equals(methodName, DatasyncConstant.MethodName_ClinicNumber)){
+				inputXmlSB.append("<controlActProcess classCode=\"CACT\" moodCode=\"APT\">");
+				inputXmlSB.append("<subject typeCode=\"SUBJ\">");
+				inputXmlSB.append("<request><OutpatientInfoForCSSD>");
+				inputXmlSB.append("<clinicNumber>" + arg[0] + "</clinicNumber>");
+				inputXmlSB.append("</OutpatientInfoForCSSD></request>");
+				inputXmlSB.append("</subject>");
+				inputXmlSB.append("</controlActProcess>");
+			} else {
+				inputXmlSB.append("<controlActProcess classCode=\"CACT\" moodCode=\"APT\">");
+				inputXmlSB.append("<subject typeCode=\"SUBJ\">");
+				inputXmlSB.append("<request><InpatientInfoForCSSD>");
+				inputXmlSB.append("<hospitalNumber>" + arg[0] + "</hospitalNumber>");
+				inputXmlSB.append("</InpatientInfoForCSSD></request>");
+				inputXmlSB.append("</subject>");
+				inputXmlSB.append("</controlActProcess>");
+			}
+			
+			inputXmlSB.append("</PRPA_IN000001UV03>");
+			inputXmlSB.append("]]></message>");
+
+			inputXmlSB.append("</urn:HIPMessageServer> ");
+			inputXmlSB.append("</soapenv:Body>");
+			inputXmlSB.append("</soapenv:Envelope>");
+			inputXml = inputXmlSB.toString();
+		} else {
+			throw new RuntimeException("不存在此方法:" + methodName);
+		}
+		return inputXml;
+	}
+	
+	/**
+     * 使用SOAP1.2发送消息
+     *
+     * @param postUrl
+     * @param soapXml
+     * @param soapAction
+     * @return
+     */
+    public static String doPostSoap1_2(String postUrl, String soapXml, String soapAction) {
+        String retStr = "";
+        // 创建HttpClientBuilder
+        HttpClientBuilder httpClientBuilder = HttpClientBuilder.create();
+        // HttpClient
+        CloseableHttpClient closeableHttpClient = httpClientBuilder.build();
+        HttpPost httpPost = new HttpPost(postUrl);
+        // 设置请求和传输超时时间
+        RequestConfig requestConfig = RequestConfig.custom()
+                .setSocketTimeout(3000000)
+                .setConnectTimeout(3000000).build();
+        httpPost.setConfig(requestConfig);
+        try {
+            httpPost.setHeader("Content-Type", "application/soap+xml;charset=UTF-8;action=\"HIPMessageServer\"");
+            httpPost.setHeader("action", soapAction);
+            StringEntity data = new StringEntity(soapXml,Charset.forName("UTF-8"));
+            httpPost.setEntity(data);
+            CloseableHttpResponse response = closeableHttpClient.execute(httpPost);
+            HttpEntity httpEntity = response.getEntity();
+            if (httpEntity != null) {
+                // 打印响应内容
+                retStr = EntityUtils.toString(httpEntity, "UTF-8");
+                retStr = retStr.replaceAll("&lt;", "<");
+                retStr = retStr.replaceAll("&gt;", ">");
+            }
+            // 释放资源
+            closeableHttpClient.close();
+        } catch (Exception e) {
+            logger.info("exception in doPostSoap1_2：" + e);
+        }
+        return retStr;
+    }
+	
+}
Index: ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/datasynchronization/dao/szsdsrmyy/FindPatientInfoByTreatmentNumDaoImpl.java
===================================================================
diff -u
--- ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/datasynchronization/dao/szsdsrmyy/FindPatientInfoByTreatmentNumDaoImpl.java	(revision 0)
+++ ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/datasynchronization/dao/szsdsrmyy/FindPatientInfoByTreatmentNumDaoImpl.java	(revision 27832)
@@ -0,0 +1,108 @@
+package com.forgon.disinfectsystem.datasynchronization.dao.szsdsrmyy;
+
+import net.sf.json.JSON;
+import net.sf.json.JSONArray;
+import net.sf.json.JSONObject;
+import net.sf.json.xml.XMLSerializer;
+
+import org.apache.commons.lang.StringUtils;
+import org.apache.log4j.Logger;
+
+import com.forgon.disinfectsystem.common.CssdUtils;
+import com.forgon.disinfectsystem.datasynchronization.dao.FindPatientInfoByTreatmentNumDao;
+import com.forgon.disinfectsystem.datasynchronization.model.PatientInfoVO;
+import com.forgon.tools.Constants;
+
+/**
+ * 根据诊疗号查询病人信息(深圳市第三人民医院)
+ * @author ZhouPeiMian
+ * @since 2020-04-17
+ *
+ */
+public class FindPatientInfoByTreatmentNumDaoImpl implements
+		FindPatientInfoByTreatmentNumDao {
+
+	Logger logger = Logger.getLogger(FindPatientInfoByTreatmentNumDaoImpl.class);
+
+	@Override
+	public PatientInfoVO[] findPatientInfoByTreatmentNum(String clinicNumber) {
+		try {
+			String inputXml = WebServiceClientHelper.buildInputString(DatasyncConstant.MethodName_ClinicNumber, clinicNumber);
+			logger.info("诊疗号病人同步接口请求信息：" + inputXml);
+			//String result = CssdUtils.callWebService(DatasyncConstant.WebserviceAddress, inputXml, Constants.CHARSET_UTF8);
+			String result = WebServiceClientHelper.doPostSoap1_2(DatasyncConstant.WebserviceAddress, inputXml, DatasyncConstant.MethodName_ClinicNumber);
+			//String result = "<soap:Envelope xmlns:soap='http://schemas.xmlsoap.org/soap/envelope/'><soap:Body><ns2:HIPMessageServerResponse xmlns:ns2='urn:hl7-org:v3'><return><![CDATA[<DataSource><OnReceiveResult><response><return><clinicNumber>0000225139</clinicNumber><searialNumber>ZY010000225139</searialNumber><patientName>周彦光</patientName><patientAge>30岁</patientAge><patientSex>男</patientSex><patientIDCard>430481198912185017</patientIDCard><doctorName>陶红光</doctorName><operation>颈淋巴结清扫术</operation><operationTime>2020/4/16 10:00:00</operationTime><patientArea>胃肠外科护士站</patientArea><roomNumber>胃肠外科</roomNumber><bedNumber>520235</bedNumber><remark></remark><washHandNurse>0</washHandNurse><circuitNurse>0</circuitNurse></return><return><clinicNumber>0000225139</clinicNumber><searialNumber>ZY010000225139</searialNumber><patientName>周彦光</patientName><patientAge>30岁</patientAge><patientSex>男</patientSex><patientIDCard>430481198912185017</patientIDCard><doctorName>陶红光</doctorName><operation>颈淋巴结清扫术</operation><operationTime>2020/4/16 10:00:00</operationTime><patientArea>胃肠外科护士站</patientArea><roomNumber>胃肠外科</roomNumber><bedNumber>520235</bedNumber><remark></remark><washHandNurse>0</washHandNurse><circuitNurse>0</circuitNurse></return><Status>AA</Status><Message></Message></response></OnReceiveResult></DataSource>]]></return></ns2:HIPMessageServerResponse></soap:Body></soap:Envelope>";
+			logger.info("诊疗号病人同步接口返回信息：" + result);
+			int startIndex = result.indexOf("<OnReceiveResult>");
+			if(startIndex == -1){
+				return null;
+			}
+			int endIndex = result.indexOf("</OnReceiveResult>");
+			if(endIndex == -1 || endIndex < startIndex){
+				return null;
+			}
+			String xmlString = result.substring(startIndex + "<OnReceiveResult>".length(), endIndex);
+			XMLSerializer xmlSerializer = new XMLSerializer();
+			JSON json = xmlSerializer.read(xmlString);
+			JSONObject patientInfos = (JSONObject)json;
+			if(patientInfos != null){
+				if(patientInfos != null){
+					String status = patientInfos.optString("Status");
+					if(StringUtils.equals(DatasyncConstant.FAIL_STATUS, status)){
+						logger.info("根据诊疗号查询病人信息失败：Status = " + status + "; Message = " + patientInfos.optString("Message"));
+						return null;
+					}
+					JSONArray patientInfoArr = new JSONArray();
+					Object returnObj = patientInfos.opt("return");
+					if(returnObj instanceof JSONArray){
+						patientInfoArr = (JSONArray) returnObj;
+					} else if (returnObj instanceof JSONObject){
+						patientInfoArr.add((JSONObject)returnObj);
+					}
+					if(patientInfoArr.size() > 0){
+						int i = 0;
+						PatientInfoVO[] patientInfoVOArray = new PatientInfoVO[patientInfoArr.size()];
+						for (Object object : patientInfoArr) {
+							JSONObject patientInfo = (JSONObject) object;
+							Object tNumber = patientInfo.opt("clinicNumber");
+							Object patientName = patientInfo.opt("patientName");
+							Object patientAge = patientInfo.opt("patientAge");
+							Object patientSex = patientInfo.opt("patientSex");
+							Object patientIDCard = patientInfo.opt("patientIDCard");
+							Object doctorName = patientInfo.opt("doctorName");
+							Object operation = patientInfo.opt("operation");
+							Object operationTime = patientInfo.opt("operationTime");
+							Object patientArea = patientInfo.opt("patientArea");
+							Object bedNumber = patientInfo.opt("bedNumber");
+							Object roomNumber = patientInfo.opt("roomNumber");
+							Object remark = patientInfo.opt("remark");
+							
+							PatientInfoVO vo = new PatientInfoVO();
+							vo.setPatientNumber(tNumber instanceof String ? (String)tNumber : "");
+							vo.setClinicNumber(vo.getPatientNumber());
+							vo.setPatientName(patientName instanceof String ? (String)patientName : "");
+							vo.setPatientAge(patientAge instanceof String ? (String)patientAge : "");
+							vo.setPatientIDCard(patientIDCard instanceof String ? (String)patientIDCard : "");
+							vo.setDoctorName(doctorName instanceof String ? (String)doctorName : "");
+							vo.setOperation(operation instanceof String ? (String)operation : "");
+							vo.setOperationTime(operationTime instanceof String ? (String)operationTime : "");
+							vo.setPatientArea(patientArea instanceof String ? (String)patientArea : "");
+							vo.setBedNumber(bedNumber instanceof String ? (String)bedNumber : "");
+							vo.setRoomNumber(roomNumber instanceof String ? (String)roomNumber : "");
+							vo.setRemark(remark instanceof String ? (String)remark : "");
+							vo.setPatientSex(patientSex instanceof String ? (String)patientSex : "");
+							
+							patientInfoVOArray[i++] = vo;
+						}
+						return patientInfoVOArray;
+					}
+				}
+			}
+		} catch (Exception e) {
+			logger.error("根据诊疗号查询病人信息失败" + e);
+			e.printStackTrace();
+		}
+		return null;
+	}
+	
+}
Index: ssts-web/src/main/resources/spring/projects/szsdsrmyy/HIS.xml
===================================================================
diff -u -r26449 -r27832
--- ssts-web/src/main/resources/spring/projects/szsdsrmyy/HIS.xml	(.../HIS.xml)	(revision 26449)
+++ ssts-web/src/main/resources/spring/projects/szsdsrmyy/HIS.xml	(.../HIS.xml)	(revision 27832)
@@ -48,7 +48,7 @@
     </bean>
     --> 
     <!-- 由MyBatis实现访问HIS数据的Dao接口-->
-    <bean id="syncOrgUnitAndUserDao" class="org.mybatis.spring.mapper.MapperFactoryBean">  
+    <!-- <bean id="syncOrgUnitAndUserDao" class="org.mybatis.spring.mapper.MapperFactoryBean">  
        <property name="mapperInterface"  
            value="com.forgon.disinfectsystem.datasynchronization.dao.SyncOrgUnitAndUserDao" />  
        <property name="sqlSessionFactory"> 
@@ -58,9 +58,9 @@
                 <property name="typeAliasesPackage" value="com.forgon.disinfectsystem.datasynchronization.model" />
             </bean>
        </property>
-    </bean>
+    </bean> -->
     
-    <bean id="findPatientInfoByHospitalNumDao" class="org.mybatis.spring.mapper.MapperFactoryBean">  
+    <!-- <bean id="findPatientInfoByHospitalNumDao" class="org.mybatis.spring.mapper.MapperFactoryBean">  
        <property name="mapperInterface"  
            value="com.forgon.disinfectsystem.datasynchronization.dao.FindPatientInfoByHospitalNumDao" />  
        <property name="sqlSessionFactory">
@@ -70,9 +70,9 @@
                 <property name="typeAliasesPackage" value="com.forgon.disinfectsystem.datasynchronization.model" />
             </bean>
        </property>
-    </bean>
+    </bean> -->
     
-    <bean id="findPatientInfoByTreatmentNumDao" class="org.mybatis.spring.mapper.MapperFactoryBean">
+    <!-- <bean id="findPatientInfoByTreatmentNumDao" class="org.mybatis.spring.mapper.MapperFactoryBean">
        <property name="mapperInterface"  
            value="com.forgon.disinfectsystem.datasynchronization.dao.FindPatientInfoByTreatmentNumDao" />  
         <property name="sqlSessionFactory">
@@ -82,7 +82,7 @@
                 <property name="typeAliasesPackage" value="com.forgon.disinfectsystem.datasynchronization.model" />
             </bean>
        </property>
-    </bean>
+    </bean> -->
   
   
     <!-- his数据源 -->
@@ -116,4 +116,12 @@
             </bean>
        </property>
     </bean>  
+    
+    <!-- 科室人员及住院病人信息同步接口 -->
+	<bean id="syncOrgUnitAndUserDao" class="com.forgon.disinfectsystem.datasynchronization.dao.szsdsrmyy.SyncOrgUnitAndUserDaoImpl"></bean>
+	
+	<bean id="findPatientInfoByHospitalNumDao" class="com.forgon.disinfectsystem.datasynchronization.dao.szsdsrmyy.FindPatientInfoByHospitalNumDaoImpl"></bean>
+    
+    <bean id="findPatientInfoByTreatmentNumDao" class="com.forgon.disinfectsystem.datasynchronization.dao.szsdsrmyy.FindPatientInfoByTreatmentNumDaoImpl"></bean>
+    
 </beans>
\ No newline at end of file