1.调度人员信息与人事库同步，逻辑变更

王通
1 parent 104f1118
Showing 7 changed files with 108 additions and 12 deletions
src/main/java/com/bsth/handler/personnelUpdateHandler.java
src/main/java/com/bsth/thread/PersonnelUpdateThrad.java
src/main/java/com/bsth/wsdl/PJDataSerivce.java
src/main/resources/application-dev.properties
src/main/resources/application-prod.properties
src/main/resources/application.properties
src/main/resources/personnel-jdbc.properties
@@ -9,14 +9,20 @@ import com.bsth.util.DBUtils_Personnel;
 import com.bsth.util.XmlToJson;
 import com.bsth.wsdl.PJDataSerivce;
 import com.bsth.wsdl.PJDataSerivceSoap;
+import com.fasterxml.jackson.databind.ObjectMapper;
 import org.hibernate.collection.internal.PersistentBag;
 import org.joda.time.DateTime;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.BatchPreparedStatementSetter;
 import org.springframework.jdbc.core.BeanPropertyRowMapper;
 import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.jdbc.datasource.DataSourceTransactionManager;
 import org.springframework.stereotype.Component;
+import org.springframework.transaction.TransactionDefinition;
+import org.springframework.transaction.TransactionStatus;
+import org.springframework.transaction.support.DefaultTransactionDefinition;
 import javax.xml.namespace.QName;
 import java.net.URL;
@@ -47,6 +53,18 @@ public class personnelUpdateHandler {
 	private static final QName SERVICE_NAME = new QName("http://www.pd-transport.com/", "PJDataSerivce");
+	private static Map<String, String> gzname2code = new HashMap<>();
+	
+	static {
+		gzname2code.put("路线驾驶员","1");
+		gzname2code.put("团客车驾驶员","1");
+		gzname2code.put("交通车驾驶员","1");
+		gzname2code.put("调度员","2");
+		gzname2code.put("乘务员","3");
+		gzname2code.put("机务员/质检员","3");
+		gzname2code.put("其他服务人员","14");
+	}
+	
 	public void sync() {
 		URL wsdlURL = PJDataSerivce.WSDL_LOCATION;
@@ -80,7 +98,7 @@ public class personnelUpdateHandler {
 			// 把所有人员设为停用状态，然后在用金蝶人员数据匹配，匹配上的设为在职
 			conn = DBUtils_Personnel.getConnection();
 			// 服务器
-			ps = conn.prepareStatement("UPDATE control.bsth_c_personnel SET destroy = 1");
+			ps = conn.prepareStatement("UPDATE pd_control.bsth_c_personnel SET destroy = 1");
 			// 本地
 //			ps = conn.prepareStatement("UPDATE pd_control.bsth_c_personnel SET destroy = 1");
 			ps.executeUpdate();
@@ -200,4 +218,82 @@ public class personnelUpdateHandler {
             logger.error("", e);
         } 
 	}
+
+	public void sync(String s) {
+		final Map<String, String> unit2company = new HashMap<>(4);
+		unit2company.put("KD01.0110", "55-上南公司");
+		unit2company.put("KD01.0111", "22-金高公司");
+		unit2company.put("KD01.0112", "26-南汇公司");
+		unit2company.put("KD01.0113", "05-杨高公司");
+
+		PJDataSerivce ss = new PJDataSerivce(PJDataSerivce.WSDL_LOCATION, SERVICE_NAME);
+		PJDataSerivceSoap port = ss.getPJDataSerivceSoap12();
+		//编程式事务
+		DataSourceTransactionManager tran = new DataSourceTransactionManager(jdbcTemplate.getDataSource());
+		DefaultTransactionDefinition def = new DefaultTransactionDefinition();
+		def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);
+		TransactionStatus status = tran.getTransaction(def);
+		try {
+			logger.info("人事数据同步 开始");
+			List<Personnel> personnels = jdbcTemplate.query("select * from bsth_c_personnel", BeanPropertyRowMapper.newInstance(Personnel.class));
+			logger.info("personnel 原数据:" + new ObjectMapper().writeValueAsString(personnels));
+			// KD01.0110上南 KD01.0111金高 KD01.0112南汇 KD01.0113杨高
+			jdbcTemplate.execute("delete from bsth_c_employee");
+			for (int i = 0;i < 4;i++) {
+				final String unintCode = "KD01.011" + i;
+				String employeeXml = port.getEmployee(unintCode, "");
+				logger.info(unintCode + ":" + employeeXml);
+				JSONObject json = XmlToJson.xml2Json(employeeXml);
+				final JSONArray emps = (JSONArray)json.get("Emp");
+				jdbcTemplate.batchUpdate("insert into bsth_c_employee values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)", new BatchPreparedStatementSetter() {
+					@Override
+					public void setValues(PreparedStatement ps, int i) throws SQLException {
+						JSONObject emp = emps.getJSONObject(i);
+						String jobCode = emp.getString("Code"), company = unit2company.get(unintCode), positName = emp.getString("PositName");
+						String[] jobCodeSplit = jobCode.split("-"), companySplit = company.split("-");
+						ps.setString(1, jobCode);
+						ps.setString(2, companySplit[0] + "-" + jobCodeSplit[1]);
+						ps.setString(3, jobCodeSplit[1]);
+						ps.setString(4, emp.getString("EmployeeName"));
+						ps.setString(5, gzname2code.get(positName) == null ? "14" : gzname2code.get(positName));
+						ps.setString(6, companySplit[0]);
+						ps.setString(7, companySplit[1]);
+						ps.setString(8, emp.getString("IDCardID") == null ? "" : emp.getString("IDCardID"));
+						ps.setString(9, emp.getString("EnterDeptDate"));
+						ps.setString(10, emp.getString("EnterGroupDate"));
+						ps.setString(11, emp.getString("InpositionDate"));
+					}
+
+					@Override
+					public int getBatchSize() {
+						return emps.size();
+					}
+				});
+			}
+			// 根据工号关联更新姓名、公司、工种、身份证号
+			int rows = jdbcTemplate.update("update bsth_c_personnel a inner join bsth_c_employee b on a.job_code = b.job_code1 set a.personnel_name = b.employee_name,a.personnel_type = b.job_type,a.company = b.company_name,a.company_code = b.company_code,a.card = b.id_card where a.destroy = 0");
+			logger.info(String.format("根据工号关联更新姓名、公司、工种、身份证号,记录数%d",rows));
+			// 未匹配上工号的数据 用身份证号关联更新工号、姓名、公司、工种
+			rows = jdbcTemplate.update("update bsth_c_personnel a inner join bsth_c_employee b on a.card = b.id_card set a.job_code = b.job_code1,a.personnel_name = b.employee_name,a.personnel_type = b.job_type,a.company = b.company_name,a.company_code = b.company_code where a.destroy = 0 and a.job_code <> b.job_code1");
+			logger.info(String.format("根据身份证号关联更新工号、姓名、公司、工种,记录数%d",rows));
+			// 可能会出现数据异常情况 如一个是最新的工号无身份证号，一个是老的工号有身份证号，最后更新的结果会造成工号和身份证号重复
+			// 将更早创建的人员信息更新为停用
+			rows = jdbcTemplate.update("update bsth_c_personnel x INNER JOIN (select card,min(id) id from bsth_c_personnel a where destroy = 0 and LENGTH(a.card) > 1 GROUP BY card having count(*) > 1) y on x.id = y.id set destroy = 1");
+			logger.info(String.format("同一个人,将更早创建的人员停用,记录数%d",rows));
+			// 仍未匹配上的调度数据作为停用人员
+			rows = jdbcTemplate.update("update bsth_c_personnel a left join bsth_c_employee b on a.job_code = b.job_code1 set a.destroy = 1 where a.destroy = 0 and b.job_code1 is null");
+			logger.info(String.format("调度系统未匹配数据标记为停用,记录数%d",rows));
+			// 仍未匹配上的金蝶数据作为新人员
+			rows = jdbcTemplate.update("insert into bsth_c_personnel (job_code,personnel_name,personnel_type,company,company_code,job_codeori) select b.job_code1,b.employee_name,b.job_type,b.company_name,b.company_code,b.job_code2 from bsth_c_employee b left join bsth_c_personnel a on b.job_code1 = a.job_code where a.job_code is null");
+			logger.info(String.format("金蝶未匹配数据插入,记录数%d",rows));
+			// 赋值分公司编码1 不然无法查询
+			rows = jdbcTemplate.update("update bsth_c_personnel set branche_company_code = '1' where branche_company_code is null");
+			logger.info(String.format("分公司代码更新为1,记录数%d",rows));
+			logger.info("人事数据同步 结束");
+			tran.commit(status);
+		} catch (Exception e) {
+			tran.rollback(status);
+			logger.error("", e);
+		}
+	}
 }
@@ -23,7 +23,7 @@ public class PersonnelUpdateThrad extends Thread {
     @Override
     public void run() {
         try {
-            personnelUpdateHandler.sync();
+            personnelUpdateHandler.sync("");
         } catch (Exception e) {
             logger.error("", e);
         }
@@ -15,7 +15,7 @@ import java.net.URL;
  *
  */
 @WebServiceClient(name = "PJDataSerivce",
-                  wsdlLocation = "http://116.236.238.218:31/PJDataInterface/PJDataService.asmx?wsdl",
+                  wsdlLocation = "http://116.228.98.212:31/PJDataInterface/PJDataService.asmx?wsdl",
                   targetNamespace = "http://www.pd-transport.com/")
 public class PJDataSerivce extends Service {
@@ -27,11 +27,11 @@ public class PJDataSerivce extends Service {
     static {
         URL url = null;
         try {
-            url = new URL("http://116.236.238.218:31/PJDataInterface/PJDataService.asmx?wsdl");
+            url = new URL("http://116.228.98.212:31/PJDataInterface/PJDataService.asmx?wsdl");
         } catch (MalformedURLException e) {
             java.util.logging.Logger.getLogger(PJDataSerivce.class.getName())
                 .log(java.util.logging.Level.INFO,
-                     "Can not initialize the default wsdl from {0}", "http://116.236.238.218:31/PJDataInterface/PJDataService.asmx?wsdl");
+                     "Can not initialize the default wsdl from {0}", "http://116.228.98.212:31/PJDataInterface/PJDataService.asmx?wsdl");
         }
         WSDL_LOCATION = url;
     }
@@ -2,15 +2,15 @@ server.port=8776
 management.port= 9001
 management.address= 127.0.0.1
-spring.jpa.hibernate.ddl-auto= update
+spring.jpa.hibernate.ddl-auto= none
 spring.jpa.hibernate.naming_strategy= org.hibernate.cfg.ImprovedNamingStrategy
 #DATABASE
 spring.jpa.database= MYSQL
 spring.jpa.show-sql= true
 spring.datasource.driver-class-name= com.mysql.jdbc.Driver
-spring.datasource.url= jdbc:mysql://localhost:3306/pd_control?useUnicode=true&characterEncoding=utf-8&useSSL=false
+spring.datasource.url= jdbc:mysql://192.168.168.241/pd_control?rewriteBatchedStatements=true&useUnicode=true&characterEncoding=utf-8&useSSL=false
 spring.datasource.username= root
-spring.datasource.password=
+spring.datasource.password= root2jsp
 #DATASOURCE
 spring.datasource.max-active=100
 spring.datasource.max-idle=8
@@ -8,9 +8,9 @@ spring.jpa.hibernate.naming_strategy= org.hibernate.cfg.ImprovedNamingStrategy
 spring.jpa.database= MYSQL
 spring.jpa.show-sql= true
 spring.datasource.driver-class-name= com.mysql.jdbc.Driver
-spring.datasource.url= jdbc:mysql://10.10.150.24:3306/control?useUnicode=true&characterEncoding=utf-8&useSSL=false
+spring.datasource.url= jdbc:mysql://10.10.200.148/control?rewriteBatchedStatements=true&useUnicode=true&characterEncoding=utf-8&useSSL=false
 spring.datasource.username= root
-spring.datasource.password= root2jsp
+spring.datasource.password= root
 #DATASOURCE
 spring.datasource.max-active=100
 spring.datasource.max-idle=8
 spring.profiles: dev,prod
-spring.profiles.active: prod
+spring.profiles.active: dev
 spring.view.suffix=.html
 server.session-timeout=-1
@@ -4,6 +4,6 @@
 #ms.mysql.password=
 ms.mysql.driver= com.mysql.jdbc.Driver
-ms.mysql.url= jdbc:mysql://10.10.150.24:3306/personnel?useUnicode=true&characterEncoding=utf-8
+ms.mysql.url= jdbc:mysql://192.168.168.240:3306/personnel?useUnicode=true&characterEncoding=utf-8
 ms.mysql.username= root
 ms.mysql.password= root2jsp