1.更新分公司信息

王通
1 parent 4a34ada4
Showing 1 changed file with 26 additions and 6 deletions
src/main/java/com/bsth/handler/personnelUpdateHandler.java
@@ -225,6 +225,23 @@ public class personnelUpdateHandler {
 		unit2company.put("KD01.0111", "22-金高公司");
 		unit2company.put("KD01.0112", "26-南汇公司");
 		unit2company.put("KD01.0113", "05-杨高公司");
+		final Map<String, String> unit2bcompany = new HashMap<>();
+		unit2bcompany.put("杨高分公司", "5-杨高分公司");
+		unit2bcompany.put("周浦分公司", "6-周浦分公司");
+		unit2bcompany.put("川沙分公司", "1-川沙分公司");
+		unit2bcompany.put("金桥分公司", "2-金桥分公司");
+		unit2bcompany.put("上南六分", "3-上南六分公司");
+		unit2bcompany.put("上南三分", "2-上南三分公司");
+		unit2bcompany.put("上南一分", "4-上南一分公司");
+		unit2bcompany.put("上南二分", "1-上南二分公司");
+		unit2bcompany.put("金高二分", "2-二分公司");
+		unit2bcompany.put("金高四分", "1-四分公司");
+		unit2bcompany.put("金高三分", "3-三分公司");
+		unit2bcompany.put("金高一分", "5-一分公司");
+		unit2bcompany.put("南汇一分", "1-南汇一分");
+		unit2bcompany.put("南汇二分", "2-南汇二分");
+		unit2bcompany.put("南汇三分", "3-南汇三分");
+		unit2bcompany.put("南汇六分", "6-南汇六分");
 		PJDataSerivce ss = new PJDataSerivce(PJDataSerivce.WSDL_LOCATION, SERVICE_NAME);
 		PJDataSerivceSoap port = ss.getPJDataSerivceSoap12();
@@ -245,12 +262,13 @@ public class personnelUpdateHandler {
 				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() {
+				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("-");
+						String jobCode = emp.getString("Code"), company = unit2company.get(unintCode), positName = emp.getString("PositName"), bcompany = unit2bcompany.get(emp.getString("HRMS_USERFIELD_45"));
+						String[] jobCodeSplit = jobCode.split("-"), companySplit = company.split("-"), bcompanySplit = bcompany == null ? null : bcompany.split("-");
+
 						ps.setString(1, jobCode);
 						ps.setString(2, companySplit[0] + "-" + jobCodeSplit[1]);
 						ps.setString(3, jobCodeSplit[1]);
@@ -262,6 +280,8 @@ public class personnelUpdateHandler {
 						ps.setString(9, emp.getString("EnterDeptDate"));
 						ps.setString(10, emp.getString("EnterGroupDate"));
 						ps.setString(11, emp.getString("InpositionDate"));
+						ps.setString(12, bcompanySplit == null ? null : bcompanySplit[0]);
+						ps.setString(13, bcompanySplit == null ? null : bcompanySplit[1]);
 					}
 					@Override
@@ -271,10 +291,10 @@ public class personnelUpdateHandler {
 				});
 			}
 			// 根据工号关联更新姓名、公司、工种、身份证号
-			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");
+			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,a.branche_company_code = b.branche_company_code,a.branche_company = b.branche_company 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");
+			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,a.branche_company_code = b.branche_company_code,a.branche_company = b.branche_company where a.destroy = 0 and a.job_code <> b.job_code1");
 			logger.info(String.format("根据身份证号关联更新工号、姓名、公司、工种,记录数%d",rows));
 			// 可能会出现数据异常情况 如一个是最新的工号无身份证号，一个是老的工号有身份证号，最后更新的结果会造成工号和身份证号重复
 			// 将更早创建的人员信息更新为停用
@@ -284,7 +304,7 @@ public class personnelUpdateHandler {
 			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");
+			rows = jdbcTemplate.update("insert into bsth_c_personnel (job_code,personnel_name,personnel_type,company,company_code,job_codeori,branche_company_code,branche_company) select b.job_code1,b.employee_name,b.job_type,b.company_name,b.company_code,b.job_code2,b.branche_company_code,b.branche_company 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");