Index: ssts-web/src/main/resources/spring/projects/dgszyy/HIS.xml
===================================================================
diff -u
--- ssts-web/src/main/resources/spring/projects/dgszyy/HIS.xml	(revision 0)
+++ ssts-web/src/main/resources/spring/projects/dgszyy/HIS.xml	(revision 15293)
@@ -0,0 +1,114 @@
+<?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"
+	   xmlns:aop="http://www.springframework.org/schema/aop"
+	   xmlns:tx="http://www.springframework.org/schema/tx"
+	   xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
+           http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.0.xsd
+           http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.0.xsd
+           http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd"
+	   default-autowire="byName" default-lazy-init="true">
+
+	<!-- his系统数据库相关注入 -->
+	
+	<context:component-scan base-package="com.forgon.disinfectsystem.datasynchronization.service.*" />
+	 
+    <bean id="dataSynchronizationManagerTarget"
+        class="com.forgon.disinfectsystem.datasynchronization.service.DataSynchronizationManagerImpl" >
+		<property name="config">
+            <bean class="com.forgon.tools.json.JsonObjectFromResourceFactoryBean">
+                <property name="resource" value="config/dgszyy/dataSyncConfig.json" />
+                <property name="charset" value="UTF-8" />
+            </bean>
+        </property>
+	</bean>
+    
+    <bean id="dataSynchronizationManager"
+        class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean">
+        <property name="transactionManager" ref="transactionManager" />
+        <property name="target">
+            <ref bean="dataSynchronizationManagerTarget" />
+        </property>
+        <property name="transactionAttributes">
+            <props>
+                <prop key="*">PROPAGATION_REQUIRED,-Exception</prop>
+            </props>
+        </property>
+    </bean>
+    
+    <bean id="dataSynchronizationTableManager"
+        class="com.forgon.disinfectsystem.datasynchronization.dwr.DataSynchronizationTableManager">
+    </bean>
+    
+    
+    <!-- 此处定义多个数据源。根据开发和生产环境需要，设置所用数据源的Bean id 为 hisDataSource -->
+    <bean id="hisDataSource"
+        class="com.mchange.v2.c3p0.ComboPooledDataSource"
+		destroy-method="close">
+        <property name="driverClass" value="com.microsoft.sqlserver.jdbc.SQLServerDriver" />  
+        <property name="jdbcUrl" value="jdbc:sqlserver://10.12.0.19:1433;databaseName=WINZYGL" />
+        <property name="user" value="tmzs" />  
+        <property name="password" value="tmzs" />
+        
+        <property name="minPoolSize">
+			<value>5</value>
+		</property>
+		<property name="maxPoolSize" value="30" />
+		<property name="initialPoolSize" value="10" />
+		<property name="maxIdleTime" value="60" />
+		<property name="acquireIncrement" value="5" />
+		<property name="maxStatements" value="0" />
+		<property name="idleConnectionTestPeriod" value="60" />
+		<property name="acquireRetryAttempts" value="30" />
+		<property name="breakAfterAcquireFailure" value="false" />
+		<property name="testConnectionOnCheckout" value="false" />
+    </bean>
+    
+    <bean id="hisJdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
+        <property name="dataSource" ref="hisDataSource"/>
+    </bean>
+    
+    <!-- 科室与人员的Dao接口-->
+    <bean id="syncOrgUnitAndUserDao" class="com.forgon.disinfectsystem.datasynchronization.dao.dgszyy.SyncOrgUnitAndUserDaoImpl"></bean>
+    
+	<!-- 使用记录的住院病人接口(按住院号),由MyBatis实现访问HIS数据的Dao接口 -->
+    <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="classpath*:config/dgszyy/mybatis/FindPatientInfoByHospitalNumMapper.xml" />
+                <property name="typeAliasesPackage" value="com.forgon.disinfectsystem.datasynchronization.model" />
+            </bean>
+       </property>
+    </bean>
+
+
+     <!-- 诊疗号 -->
+	 <bean id="hisDataSource2"
+        class="com.mchange.v2.c3p0.ComboPooledDataSource"
+		destroy-method="close">
+        <property name="driverClass" value="com.microsoft.sqlserver.jdbc.SQLServerDriver" />  
+        <property name="jdbcUrl" value="jdbc:sqlserver://10.12.0.19:1433;databaseName=WINMZGL" />
+        <property name="user" value="tmzs" />  
+        <property name="password" value="tmzs" />  
+    </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="hisDataSource2" />
+                <property name="mapperLocations" value="classpath*:config/dgszyy/mybatis/FindPatientInfoByTreatmentNumMapper.xml" />
+                <property name="typeAliasesPackage" value="com.forgon.disinfectsystem.datasynchronization.model" />
+            </bean>
+       </property>
+    </bean>
+    
+    
+    
+    
+</beans>
\ No newline at end of file
Index: ssts-web/src/main/resources/config/dgszyy/mybatis/SyncOrgUnitAndUserMapper.xml
===================================================================
diff -u
--- ssts-web/src/main/resources/config/dgszyy/mybatis/SyncOrgUnitAndUserMapper.xml	(revision 0)
+++ ssts-web/src/main/resources/config/dgszyy/mybatis/SyncOrgUnitAndUserMapper.xml	(revision 15293)
@@ -0,0 +1,28 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper
+  PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+  "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.forgon.disinfectsystem.datasynchronization.dao.SyncOrgUnitAndUserDao">
+  
+  <!-- 获取所有部门 -->
+  <select id="getAllOrgUnit" resultType="OrgUnitVo">
+  <![CDATA[
+	select  ksdm as coding,
+        	ksmc as name,
+	        '' as parentCoding
+	from Z_KSZD
+	]]>
+  </select>
+  
+  <!-- 获取所有用户 -->
+  <select id="getAllUser" resultType="UserVo">
+  <![CDATA[
+	select userid as coding,
+        	username as name,
+	        ksdm as orgUnitCoding
+	from Pubc_UserM 
+	where ksdm='30010102'
+	ORDER BY ksdm
+	]]>
+  </select>
+</mapper>
\ No newline at end of file
Index: ssts-web/src/main/resources/config/dgszyy/mybatis/FindPatientInfoByHospitalNumMapper.xml
===================================================================
diff -u
--- ssts-web/src/main/resources/config/dgszyy/mybatis/FindPatientInfoByHospitalNumMapper.xml	(revision 0)
+++ ssts-web/src/main/resources/config/dgszyy/mybatis/FindPatientInfoByHospitalNumMapper.xml	(revision 15293)
@@ -0,0 +1,22 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper
+  PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+  "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.forgon.disinfectsystem.datasynchronization.dao.FindPatientInfoByHospitalNumDao">
+  
+  <!-- 按住院号查找病人信息 -->
+  <select id="findPatientInfoByHospitalNum" resultType="PatientInfoVO">
+  <![CDATA[
+	select h.zyh as patientNumber,
+        	h.xm as patientName,
+	        h.nl as patientAge,
+	        h.xb as patientSex,
+	        '' as patientIDCard,
+	        h.syysxm as doctorName,
+	        h.jbzdmc as operation 
+	from rydj h
+	WHERE h.zyh = #{hospitalNum}
+	]]>
+  </select>
+  
+</mapper>
\ No newline at end of file
Index: ssts-web/src/main/resources/config/dgszyy/mybatis/FindPatientInfoByTreatmentNumMapper.xml
===================================================================
diff -u
--- ssts-web/src/main/resources/config/dgszyy/mybatis/FindPatientInfoByTreatmentNumMapper.xml	(revision 0)
+++ ssts-web/src/main/resources/config/dgszyy/mybatis/FindPatientInfoByTreatmentNumMapper.xml	(revision 15293)
@@ -0,0 +1,22 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper
+  PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+  "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.forgon.disinfectsystem.datasynchronization.dao.FindPatientInfoByTreatmentNumDao">
+  
+  <!-- 按门诊号查找病人信息 -->
+  <select id="findPatientInfoByTreatmentNum" resultType="PatientInfoVO">
+  <![CDATA[
+	SELECT h.ickh as patientNumber,
+        	h.brxm as patientName,
+	        h.nl as patientAge,
+	        h.xb as patientSex,
+	        '' as patientIDCard,
+	        h.ysxm as doctorName,
+	        '' as operation
+	FROM [WINMZGL].[dbo].ghao_gh h
+	WHERE h.ickh = #{treatmentNum}
+	]]>
+  </select>
+
+</mapper>
\ No newline at end of file
Index: ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/datasynchronization/dao/dgszyy/SyncOrgUnitAndUserDaoImpl.java
===================================================================
diff -u
--- ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/datasynchronization/dao/dgszyy/SyncOrgUnitAndUserDaoImpl.java	(revision 0)
+++ ssts-datasync-default-impl/src/main/java/com/forgon/disinfectsystem/datasynchronization/dao/dgszyy/SyncOrgUnitAndUserDaoImpl.java	(revision 15293)
@@ -0,0 +1,130 @@
+package com.forgon.disinfectsystem.datasynchronization.dao.dgszyy;
+
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.util.ArrayList;
+import java.util.List;
+
+import org.apache.commons.collections.CollectionUtils;
+import org.apache.commons.lang3.StringUtils;
+import org.apache.log4j.Logger;
+import org.springframework.dao.DataAccessException;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.jdbc.core.ResultSetExtractor;
+
+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.db.DatabaseUtil;
+
+/**
+ * 查询his系统科室与人员信息(南山附幼)
+ * @author shuyongfu
+ *
+ */
+public class SyncOrgUnitAndUserDaoImpl implements SyncOrgUnitAndUserDao {
+
+	Logger logger = Logger.getLogger(SyncOrgUnitAndUserDaoImpl.class);
+	
+	private JdbcTemplate hisJdbcTemplate;
+	
+	public void setHisJdbcTemplate(JdbcTemplate hisJdbcTemplate) {
+		this.hisJdbcTemplate = hisJdbcTemplate;
+	}
+
+	/**
+	 * 查询his系统人员信息
+	 * ##注意:ksdm即orgUnitCoding返回的是科室编码如果有多是用分号;拼接的
+	 */
+	@Override
+	public UserVo[] getAllUser() {
+		UserVo[] userVoArray = null;
+		ResultSet rs = null;
+		try{
+			List<UserVo> userVoList = hisJdbcTemplate.query("select userid as coding, username as name,ksdm as orgUnitCoding from Pubc_UserM where ksdm='30010102' ORDER BY ksdm",
+					new ResultSetExtractor<List<UserVo>>() {
+				public List<UserVo> extractData(ResultSet rs)
+						throws SQLException, DataAccessException {
+					List<UserVo> userVoList = new ArrayList<UserVo>();
+					UserVo userVo = null;
+					while (rs.next()) {
+						String coding = rs.getString("coding");
+						String name = rs.getString("name");
+						String orgUnitCoding = rs.getString("orgUnitCoding");
+						if(StringUtils.isNotBlank(orgUnitCoding) && orgUnitCoding.indexOf(";") != -1){
+							String[] orgUnitCodingArray = orgUnitCoding.split(";");
+							for(String orgUnitCodingTemp : orgUnitCodingArray){
+								userVo = new UserVo();
+								userVo.setCoding(coding);
+								userVo.setName(name);
+								userVo.setOrgUnitCoding(orgUnitCodingTemp);
+								userVoList.add(userVo);
+							}
+						}else{
+							userVo = new UserVo();
+							userVo.setCoding(coding);
+							userVo.setName(name);
+							userVo.setOrgUnitCoding(orgUnitCoding);
+							userVoList.add(userVo);
+						}
+					}
+					return userVoList;
+				}
+			});
+			if(CollectionUtils.isNotEmpty(userVoList)){
+				userVoArray = (UserVo[])userVoList.toArray();
+				if(CollectionUtils.isNotEmpty(userVoList)){
+					userVoArray = new UserVo[userVoList.size()];
+					userVoList.toArray(userVoArray);
+				}
+			}
+		}catch(Exception e){
+			logger.error("查询his人员信息失败:" + e);
+		}finally{
+			DatabaseUtil.closeResultSetAndStatement(rs);
+		}
+		
+		return userVoArray;
+	}
+
+	/**
+	 * 查询his系统科室信息
+	 */
+	@Override
+	public OrgUnitVo[] getAllOrgUnit() {
+		OrgUnitVo[] orgUnitVoArray = null;
+		ResultSet rs = null;
+		try{
+			List<OrgUnitVo> orgUnitVoList = hisJdbcTemplate.query("select ksdm as coding,ksmc as name,'' as parentCoding from Z_KSZD",
+					new ResultSetExtractor<List<OrgUnitVo>>() {
+				public List<OrgUnitVo> extractData(ResultSet rs)
+						throws SQLException, DataAccessException {
+					List<OrgUnitVo> orgUnitVoList = new ArrayList<OrgUnitVo>();
+					OrgUnitVo orgUnitVo = null;
+					while (rs.next()) {
+						orgUnitVo = new OrgUnitVo();
+						orgUnitVo.setCoding(rs.getString("coding"));
+						orgUnitVo.setName(rs.getString("name"));
+						orgUnitVo.setParentCoding(rs.getString("parentCoding"));
+						orgUnitVoList.add(orgUnitVo);
+					}
+					return orgUnitVoList;
+				}
+			});
+			if(CollectionUtils.isNotEmpty(orgUnitVoList)){
+				orgUnitVoArray = (OrgUnitVo[])orgUnitVoList.toArray();
+				if(CollectionUtils.isNotEmpty(orgUnitVoList)){
+					orgUnitVoArray = new OrgUnitVo[orgUnitVoList.size()];
+					orgUnitVoList.toArray(orgUnitVoArray);
+				}
+			}
+		}catch(Exception e){
+			logger.error("查询his科室信息失败" + e);
+		}finally{
+			DatabaseUtil.closeResultSetAndStatement(rs);
+		}
+		
+		return orgUnitVoArray;
+	}
+
+}