From bd7ec4537efc68086ed1fbccdbe471afc80d6fe2 Mon Sep 17 00:00:00 2001 From: Administrator <704728292@qq.com> Date: Tue, 20 May 2025 16:44:38 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../organization/esb/SyncRzglPersonInfo.java | 540 ++++++++++-------- 1 file changed, 294 insertions(+), 246 deletions(-) diff --git a/jcl-hrmorganization/secondev-jcl-hrmorganization/src/main/java/com/weaver/seconddev/jcl/organization/esb/SyncRzglPersonInfo.java b/jcl-hrmorganization/secondev-jcl-hrmorganization/src/main/java/com/weaver/seconddev/jcl/organization/esb/SyncRzglPersonInfo.java index c685ffa..3b143ac 100644 --- a/jcl-hrmorganization/secondev-jcl-hrmorganization/src/main/java/com/weaver/seconddev/jcl/organization/esb/SyncRzglPersonInfo.java +++ b/jcl-hrmorganization/secondev-jcl-hrmorganization/src/main/java/com/weaver/seconddev/jcl/organization/esb/SyncRzglPersonInfo.java @@ -65,9 +65,23 @@ public class SyncRzglPersonInfo implements EsbServerlessRpcRemoteInterface { if(!map.isEmpty()){ //更新前先处理一下时间 cleanUpTime(map); + /** + * 清除申请表字段 + */ + map.remove("id"); + map.remove("rzzt_obj"); + map.remove("rzzt"); + map.remove("rzsqlc_obj"); + map.remove("rzsqlc"); + map.remove("sec_level"); + log.error("SyncRzglPersonInfo88888.map:{}", map); + //跟换id值，然后主键冲突 + ryid = createPrimarykey(); + log.error("SyncRzglPersonInfo88888.primarykey:{}", ryid); + map.put("id",ryid); code = insert("uf_jcl_employee_information",map); log.error("SyncRzglPersonInfo.code:{}", code); - ryid = String.valueOf(map.get("id")); + //ryid = String.valueOf(map.get("id")); /** * 员工信息明细表数据同步处理 */ @@ -128,39 +142,29 @@ public class SyncRzglPersonInfo implements EsbServerlessRpcRemoteInterface { * 写入表单引擎数据大表 * @return */ - public boolean insertFormdata(Map map){ - boolean flag = false; + public void insertFormdata(Map map){ String sql="insert into formdata(id, form_id, layout_id, data_status, tenant_key, operator, create_time, update_time, " + " module, client, is_delete, creator, delete_type)" + - " values('" + map.get("id") + "','1109797752477335562','1113505082434510856','submit','" + map.get("tenantKey") + "','" + map.get("updater") + "','" + map.get("create_time") + "'," + - " '" + map.get("update_time") + "','ebuilderform','pc','" + map.get("delete_type") + "','" + map.get("creator") + "','" + map.get("delete_type") + "',)"; + " values('" + map.get("id") + "','1109797752477335562','1113505082434510856','submit','" + map.get("tenant_key") + "','" + map.get("updater") + "','" + map.get("create_time") + "'," + + " '" + map.get("update_time") + "','ebuilderform','pc','" + map.get("delete_type") + "','" + map.get("creator") + "','" + map.get("delete_type") + "')"; log.error("insertFormdata.sql:{}", sql); Map rs = databaseUtils.execute("LOGIC", "weaver-ebuilder-form-service", sql); List> recordList = databaseUtils.getDataSourceList(rs); log.error("insertFormdata.recordList:{}", recordList); - if(Integer.parseInt(String.valueOf(recordList.get(0).get("code")))==200){ - flag = true; - } - return flag; } /** * 写入EB表单数据大表 * @return */ - public boolean insertPhysical(Map map){ - boolean flag = false; + public void insertPhysical(Map map){ String sql="insert into ebdf_physical_data(id, tenant_key, obj_id, name, form_data_id, form_table_id, is_flow, data_status, creator, create_time)" + - " values('" + map.get("id") + "','" + map.get("tenantKey") + "','1109797752477335559','" + map.get("name") + "','" + map.get("id") + "'," + + " values('" + map.get("id") + "','" + map.get("tenant_key") + "','1109797752477335559','" + map.get("name") + "','" + map.get("id") + "'," + " '" + map.get("id") + "','" + map.get("is_flow") + "','" + map.get("data_status") + "','" + map.get("creator") + "','" + map.get("create_time") + "')"; log.error("insertPhysical.sql:{}", sql); Map rs = databaseUtils.execute("LOGIC", "weaver-ebuilder-form-service", sql); List> recordList = databaseUtils.getDataSourceList(rs); log.error("insertPhysical.recordList:{}", recordList); - if(Integer.parseInt(String.valueOf(recordList.get(0).get("code")))==200){ - flag = true; - } - return flag; } @@ -435,168 +439,190 @@ public class SyncRzglPersonInfo implements EsbServerlessRpcRemoteInterface { * */ String gzsql = "select * from uf_jcl_employ4944 where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0"; List> gzllInfo = getYgxxDetailInfo(gzsql); - Set listOfgzllColumns = getTableColumnsOfTableName("uf_jcl_emp_gzll"); log.error("getYgxxDetailInfo.gzllInfo:{}", gzllInfo); - log.error("getYgxxDetailInfo.listOfgzllColumns:{}", listOfgzllColumns); - for (Map map : gzllInfo) { - Map gzllInfo_new = new HashMap<>(); - for (String key : listOfgzllColumns) { - if (containsKeyIgnoreCase(map,key)) { - if("delete_type".equalsIgnoreCase(key)||"IS_DELETE".equalsIgnoreCase(key)){ - gzllInfo_new.put(key,"0"); - }else{ - gzllInfo_new.put(key,getIgnoreCase(map, key)); + if(CollectionUtils.isNotEmpty(gzllInfo)){ + Set listOfgzllColumns = getTableColumnsOfTableName("uf_jcl_emp_gzll"); + log.error("getYgxxDetailInfo.listOfgzllColumns:{}", listOfgzllColumns); + for (Map map : gzllInfo) { + Map gzllInfo_new = new HashMap<>(); + for (String key : listOfgzllColumns) { + if (containsKeyIgnoreCase(map,key)) { + if("delete_type".equalsIgnoreCase(key)||"IS_DELETE".equalsIgnoreCase(key)){ + gzllInfo_new.put(key,"0"); + }else{ + gzllInfo_new.put(key,getIgnoreCase(map, key)); + } } } + //插入组织工作履历表 + cleanUpTime(gzllInfo_new); + gzllInfo_new.remove("hiredate"); + insert("uf_jcl_emp_gzll",gzllInfo_new); } - //插入组织工作履历表 - cleanUpTime(gzllInfo_new); - gzllInfo_new.remove("hiredate"); - insert("uf_jcl_emp_gzll",gzllInfo_new); } + /** * 教育经历表 * */ String jysql = "select * from uf_jcl_employ4991 where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0"; List> jyjlInfo = getYgxxDetailInfo(jysql); - Set listOfjyjlColumns = getTableColumnsOfTableName("uf_jcl_emp_jyjl"); log.error("getYgxxDetailInfo.jyjlInfo:{}", jyjlInfo); - log.error("getYgxxDetailInfo.listOfjyjlColumns:{}", listOfjyjlColumns); - for (Map map : jyjlInfo) { - Map jyjlInfo_new = new HashMap<>(); - for (String key : listOfjyjlColumns) { - if (containsKeyIgnoreCase(map,key)) { - if("delete_type".equalsIgnoreCase(key)||"IS_DELETE".equalsIgnoreCase(key)){ - jyjlInfo_new.put(key,"0"); - }else{ - jyjlInfo_new.put(key,getIgnoreCase(map, key)); + if(CollectionUtils.isNotEmpty(jyjlInfo)){ + Set listOfjyjlColumns = getTableColumnsOfTableName("uf_jcl_emp_jyjl"); + log.error("getYgxxDetailInfo.listOfjyjlColumns:{}", listOfjyjlColumns); + for (Map map : jyjlInfo) { + Map jyjlInfo_new = new HashMap<>(); + for (String key : listOfjyjlColumns) { + if (containsKeyIgnoreCase(map,key)) { + if("delete_type".equalsIgnoreCase(key)||"IS_DELETE".equalsIgnoreCase(key)){ + jyjlInfo_new.put(key,"0"); + }else{ + jyjlInfo_new.put(key,getIgnoreCase(map, key)); + } } } + //插入教育经历表 + cleanUpTime(jyjlInfo_new); + jyjlInfo_new.remove("hiredate"); + insert("uf_jcl_emp_jyjl",jyjlInfo_new); } - //插入教育经历表 - cleanUpTime(jyjlInfo_new); - jyjlInfo_new.remove("hiredate"); - insert("uf_jcl_emp_jyjl",jyjlInfo_new); } + /** * 家庭信息表 * */ String jtxxsql = "select * from uf_jcl_employ5051 where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0"; List> jtxxInfo = getYgxxDetailInfo(jtxxsql); - Set listOfjtxxColumns = getTableColumnsOfTableName("uf_jcl_emp_jtxx"); log.error("getYgxxDetailInfo.jtxxInfo:{}", jtxxInfo); - for (Map map : jtxxInfo) { - Map jtxxInfo_new = new HashMap<>(); - for (String key : listOfjtxxColumns) { - if (containsKeyIgnoreCase(map,key)) { - if("delete_type".equalsIgnoreCase(key)||"IS_DELETE".equalsIgnoreCase(key)){ - jtxxInfo_new.put(key,"0"); - }else{ - jtxxInfo_new.put(key,getIgnoreCase(map, key)); + if(CollectionUtils.isNotEmpty(jtxxInfo)){ + Set listOfjtxxColumns = getTableColumnsOfTableName("uf_jcl_emp_jtxx"); + log.error("getYgxxDetailInfo.listOfjtxxColumns:{}", listOfjtxxColumns); + for (Map map : jtxxInfo) { + Map jtxxInfo_new = new HashMap<>(); + for (String key : listOfjtxxColumns) { + if (containsKeyIgnoreCase(map,key)) { + if("delete_type".equalsIgnoreCase(key)||"IS_DELETE".equalsIgnoreCase(key)){ + jtxxInfo_new.put(key,"0"); + }else{ + jtxxInfo_new.put(key,getIgnoreCase(map, key)); + } } } + //插入家庭信息表 + cleanUpTime(jtxxInfo_new); + jtxxInfo_new.remove("hiredate"); + insert("uf_jcl_emp_jtxx",jtxxInfo_new); } - //插入家庭信息表 - cleanUpTime(jtxxInfo_new); - jtxxInfo_new.remove("hiredate"); - insert("uf_jcl_emp_jtxx",jtxxInfo_new); } + /** * 表彰与奖励 * */ String bzsql = "select * from uf_jcl_employ5105 where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0"; List> bzInfo = getYgxxDetailInfo(bzsql); - Set listOfbzColumns = getTableColumnsOfTableName("uf_jcl_emp_bzyjl"); log.error("getYgxxDetailInfo.bzInfo:{}", bzInfo); - log.error("getYgxxDetailInfo.listOfbzColumns:{}", listOfbzColumns); - for (Map map : bzInfo) { - Map bzInfo_new = new HashMap<>(); - for (String key : listOfbzColumns) { - if (containsKeyIgnoreCase(map,key)) { - if("delete_type".equalsIgnoreCase(key)||"IS_DELETE".equalsIgnoreCase(key)){ - bzInfo_new.put(key,"0"); - }else{ - bzInfo_new.put(key,getIgnoreCase(map, key)); + if(CollectionUtils.isNotEmpty(bzInfo)){ + Set listOfbzColumns = getTableColumnsOfTableName("uf_jcl_emp_bzyjl"); + log.error("getYgxxDetailInfo.listOfbzColumns:{}", listOfbzColumns); + for (Map map : bzInfo) { + Map bzInfo_new = new HashMap<>(); + for (String key : listOfbzColumns) { + if (containsKeyIgnoreCase(map,key)) { + if("delete_type".equalsIgnoreCase(key)||"IS_DELETE".equalsIgnoreCase(key)){ + bzInfo_new.put(key,"0"); + }else{ + bzInfo_new.put(key,getIgnoreCase(map, key)); + } } } + cleanUpTime(bzInfo_new); + bzInfo_new.remove("hiredate"); + //插入家庭信息表 + insert("uf_jcl_emp_bzyjl",bzInfo_new); } - cleanUpTime(bzInfo_new); - bzInfo_new.remove("hiredate"); - //插入家庭信息表 - insert("uf_jcl_emp_bzyjl",bzInfo_new); } + /** * 培训经历 * */ String pxsql = "select * from uf_jcl_employ5165 where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0"; List> pxInfo = getYgxxDetailInfo(pxsql); - Set listOfpxColumns = getTableColumnsOfTableName("uf_jcl_emp_pxjl"); log.error("getYgxxDetailInfo.pxInfo:{}", pxInfo); - log.error("getYgxxDetailInfo.listOfpxColumns:{}", listOfpxColumns); - for (Map map : pxInfo) { - Map pxInfo_new = new HashMap<>(); - for (String key : listOfpxColumns) { - if (containsKeyIgnoreCase(map,key)) { - if("delete_type".equalsIgnoreCase(key)||"IS_DELETE".equalsIgnoreCase(key)){ - pxInfo_new.put(key,"0"); - }else{ - pxInfo_new.put(key,getIgnoreCase(map, key)); + if(CollectionUtils.isNotEmpty(pxInfo)){ + Set listOfpxColumns = getTableColumnsOfTableName("uf_jcl_emp_pxjl"); + log.error("getYgxxDetailInfo.listOfpxColumns:{}", listOfpxColumns); + for (Map map : pxInfo) { + Map pxInfo_new = new HashMap<>(); + for (String key : listOfpxColumns) { + if (containsKeyIgnoreCase(map,key)) { + if("delete_type".equalsIgnoreCase(key)||"IS_DELETE".equalsIgnoreCase(key)){ + pxInfo_new.put(key,"0"); + }else{ + pxInfo_new.put(key,getIgnoreCase(map, key)); + } } } + //插入培训表 + cleanUpTime(pxInfo_new); + pxInfo_new.remove("hiredate"); + insert("uf_jcl_emp_pxjl",pxInfo_new); } - //插入培训表 - cleanUpTime(pxInfo_new); - pxInfo_new.remove("hiredate"); - insert("uf_jcl_emp_pxjl",pxInfo_new); } + /** * 语言能力 * */ String yysql = "select * from uf_jcl_employ5218 where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0"; List> yyInfo = getYgxxDetailInfo(yysql); - Set listOfyyColumns = getTableColumnsOfTableName("uf_jcl_emp_yynl"); log.error("getYgxxDetailInfo.yyInfo:{}", yyInfo); - log.error("getYgxxDetailInfo.listOfyyColumns:{}", listOfyyColumns); - for (Map map : yyInfo) { - Map yyInfo_new = new HashMap<>(); - for (String key : listOfyyColumns) { - if (containsKeyIgnoreCase(map,key)) { - if("delete_type".equalsIgnoreCase(key)||"IS_DELETE".equalsIgnoreCase(key)){ - yyInfo_new.put(key,"0"); - }else{ - yyInfo_new.put(key,getIgnoreCase(map, key)); + if(CollectionUtils.isNotEmpty(yyInfo)){ + Set listOfyyColumns = getTableColumnsOfTableName("uf_jcl_emp_yynl"); + log.error("getYgxxDetailInfo.listOfyyColumns:{}", listOfyyColumns); + for (Map map : yyInfo) { + Map yyInfo_new = new HashMap<>(); + for (String key : listOfyyColumns) { + if (containsKeyIgnoreCase(map,key)) { + if("delete_type".equalsIgnoreCase(key)||"IS_DELETE".equalsIgnoreCase(key)){ + yyInfo_new.put(key,"0"); + }else{ + yyInfo_new.put(key,getIgnoreCase(map, key)); + } } } + //插入培训表 + cleanUpTime(yyInfo_new); + yyInfo_new.remove("hiredate"); + insert("uf_jcl_emp_yynl",yyInfo_new); } - //插入培训表 - cleanUpTime(yyInfo_new); - yyInfo_new.remove("hiredate"); - insert("uf_jcl_emp_yynl",yyInfo_new); } + /** * 权威机构资格 * */ String qwsql = "select * from uf_jcl_employ5265 where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0"; List> qwInfo = getYgxxDetailInfo(qwsql); - Set listOfqwColumns = getTableColumnsOfTableName("uf_jcl_emp_qwjgzgrz"); log.error("getYgxxDetailInfo.qwInfo:{}", qwInfo); - log.error("getYgxxDetailInfo.listOfqwColumns:{}", listOfqwColumns); - for (Map map : qwInfo) { - Map qwInfo_new = new HashMap<>(); - for (String key : listOfqwColumns) { - if (containsKeyIgnoreCase(map,key)) { - if("delete_type".equalsIgnoreCase(key)||"IS_DELETE".equalsIgnoreCase(key)){ - qwInfo_new.put(key,"0"); - }else{ - qwInfo_new.put(key,getIgnoreCase(map, key)); + if(CollectionUtils.isNotEmpty(qwInfo)){ + Set listOfqwColumns = getTableColumnsOfTableName("uf_jcl_emp_qwjgzgrz"); + log.error("getYgxxDetailInfo.listOfqwColumns:{}", listOfqwColumns); + for (Map map : qwInfo) { + Map qwInfo_new = new HashMap<>(); + for (String key : listOfqwColumns) { + if (containsKeyIgnoreCase(map,key)) { + if("delete_type".equalsIgnoreCase(key)||"IS_DELETE".equalsIgnoreCase(key)){ + qwInfo_new.put(key,"0"); + }else{ + qwInfo_new.put(key,getIgnoreCase(map, key)); + } } } + //插入权威机构表 + cleanUpTime(qwInfo_new); + qwInfo_new.remove("hiredate"); + insert("uf_jcl_emp_qwjgzgrz",qwInfo_new); } - //插入权威机构表 - cleanUpTime(qwInfo_new); - qwInfo_new.remove("hiredate"); - insert("uf_jcl_emp_qwjgzgrz",qwInfo_new); } + } /** @@ -613,30 +639,33 @@ public class SyncRzglPersonInfo implements EsbServerlessRpcRemoteInterface { * */ String gzsql = "select * from uf_jcl_employ4944 where FORM_DATA_ID = '" + lcid + "' and delete_type=0"; List> gzllInfo = getYgxxDetailInfo(gzsql); - Set listOfgzllColumns = getTableColumnsOfTableName("uf_jcl_emp_gzll"); log.error("updateAllXxbgDetailInfo.gzllInfo:{}", gzllInfo); - log.error("updateAllXxbgDetailInfo.listOfgzllColumns:{}", listOfgzllColumns); - for (Map map : gzllInfo) { - Map gzllInfo_new = new HashMap<>(); - for (String key : listOfgzllColumns) { - if (containsKeyIgnoreCase(map,key)) { - if("delete_type".equalsIgnoreCase(key)||"IS_DELETE".equalsIgnoreCase(key)){ - gzllInfo_new.put(key,"0"); - }else{ - gzllInfo_new.put(key,getIgnoreCase(map, key)); + if(CollectionUtils.isNotEmpty(gzllInfo)){ + Set listOfgzllColumns = getTableColumnsOfTableName("uf_jcl_emp_gzll"); + log.error("updateAllXxbgDetailInfo.listOfgzllColumns:{}", listOfgzllColumns); + for (Map map : gzllInfo) { + Map gzllInfo_new = new HashMap<>(); + for (String key : listOfgzllColumns) { + if (containsKeyIgnoreCase(map,key)) { + if("delete_type".equalsIgnoreCase(key)||"IS_DELETE".equalsIgnoreCase(key)){ + gzllInfo_new.put(key,"0"); + }else{ + gzllInfo_new.put(key,getIgnoreCase(map, key)); + } } + gzllInfo_new.put("FORM_DATA_ID",ygxxid); } - gzllInfo_new.put("FORM_DATA_ID",ygxxid); + //跟换id值，然后主键冲突 + String primarykey = createPrimarykey(); + log.error("getYgxxDetailInfo.primarykey:{}", primarykey); + gzllInfo_new.put("id",primarykey); + //插入组织工作履历表 + cleanUpTime(gzllInfo_new); + gzllInfo_new.remove("hiredate"); + insert("uf_jcl_emp_gzll",gzllInfo_new); } - //跟换id值，然后主键冲突 - String primarykey = createPrimarykey(); - log.error("getYgxxDetailInfo.primarykey:{}", primarykey); - gzllInfo_new.put("id",primarykey); - //插入组织工作履历表 - cleanUpTime(gzllInfo_new); - gzllInfo_new.remove("hiredate"); - insert("uf_jcl_emp_gzll",gzllInfo_new); } + /** * 教育经历表 * */ @@ -645,30 +674,33 @@ public class SyncRzglPersonInfo implements EsbServerlessRpcRemoteInterface { deleteDetailData(sql); String jysql = "select * from uf_jcl_employ4991 where FORM_DATA_ID = '" + lcid + "' and delete_type=0"; List> jyjlInfo = getYgxxDetailInfo(jysql); - Set listOfjyjlColumns = getTableColumnsOfTableName("uf_jcl_emp_jyjl"); log.error("getYgxxDetailInfo.jyjlInfo0172:{}", jyjlInfo); - log.error("getYgxxDetailInfo.listOfjyjlColumns:{}", listOfjyjlColumns); - for (Map map : jyjlInfo) { - Map jyjlInfo_new = new HashMap<>(); - for (String key : listOfjyjlColumns) { - if (containsKeyIgnoreCase(map,key)) { - if("delete_type".equalsIgnoreCase(key)||"IS_DELETE".equalsIgnoreCase(key)){ - jyjlInfo_new.put(key,"0"); - }else{ - jyjlInfo_new.put(key,getIgnoreCase(map, key)); + if(CollectionUtils.isNotEmpty(jyjlInfo)){ + Set listOfjyjlColumns = getTableColumnsOfTableName("uf_jcl_emp_jyjl"); + log.error("getYgxxDetailInfo.listOfjyjlColumns:{}", listOfjyjlColumns); + for (Map map : jyjlInfo) { + Map jyjlInfo_new = new HashMap<>(); + for (String key : listOfjyjlColumns) { + if (containsKeyIgnoreCase(map,key)) { + if("delete_type".equalsIgnoreCase(key)||"IS_DELETE".equalsIgnoreCase(key)){ + jyjlInfo_new.put(key,"0"); + }else{ + jyjlInfo_new.put(key,getIgnoreCase(map, key)); + } } + jyjlInfo_new.put("FORM_DATA_ID",ygxxid); } - jyjlInfo_new.put("FORM_DATA_ID",ygxxid); + //跟换id值，然后主键冲突 + String primarykey = createPrimarykey(); + log.error("getYgxxDetailInfo.primarykey:{}", primarykey); + jyjlInfo_new.put("id",primarykey); + //插入教育经历表 + cleanUpTime(jyjlInfo_new); + jyjlInfo_new.remove("hiredate"); + insert("uf_jcl_emp_jyjl",jyjlInfo_new); } - //跟换id值，然后主键冲突 - String primarykey = createPrimarykey(); - log.error("getYgxxDetailInfo.primarykey:{}", primarykey); - jyjlInfo_new.put("id",primarykey); - //插入教育经历表 - cleanUpTime(jyjlInfo_new); - jyjlInfo_new.remove("hiredate"); - insert("uf_jcl_emp_jyjl",jyjlInfo_new); } + /** * 家庭信息表 * */ @@ -677,29 +709,33 @@ public class SyncRzglPersonInfo implements EsbServerlessRpcRemoteInterface { deleteDetailData(sql); String jtxxsql = "select * from uf_jcl_employ5051 where FORM_DATA_ID = '" + lcid + "' and delete_type=0"; List> jtxxInfo = getYgxxDetailInfo(jtxxsql); - Set listOfjtxxColumns = getTableColumnsOfTableName("uf_jcl_emp_jtxx"); log.error("getYgxxDetailInfo.jtxxInfo:{}", jtxxInfo); - for (Map map : jtxxInfo) { - Map jtxxInfo_new = new HashMap<>(); - for (String key : listOfjtxxColumns) { - if (containsKeyIgnoreCase(map,key)) { - if("delete_type".equalsIgnoreCase(key)||"IS_DELETE".equalsIgnoreCase(key)){ - jtxxInfo_new.put(key,"0"); - }else{ - jtxxInfo_new.put(key,getIgnoreCase(map, key)); + if(CollectionUtils.isNotEmpty(jtxxInfo)){ + Set listOfjtxxColumns = getTableColumnsOfTableName("uf_jcl_emp_jtxx"); + log.error("getYgxxDetailInfo.listOfjtxxColumns:{}", listOfjtxxColumns); + for (Map map : jtxxInfo) { + Map jtxxInfo_new = new HashMap<>(); + for (String key : listOfjtxxColumns) { + if (containsKeyIgnoreCase(map,key)) { + if("delete_type".equalsIgnoreCase(key)||"IS_DELETE".equalsIgnoreCase(key)){ + jtxxInfo_new.put(key,"0"); + }else{ + jtxxInfo_new.put(key,getIgnoreCase(map, key)); + } } + jtxxInfo_new.put("FORM_DATA_ID",ygxxid); } - jtxxInfo_new.put("FORM_DATA_ID",ygxxid); + //跟换id值，然后主键冲突 + String primarykey = createPrimarykey(); + log.error("getYgxxDetailInfo.primarykey:{}", primarykey); + jtxxInfo_new.put("id",primarykey); + //插入家庭信息表 + cleanUpTime(jtxxInfo_new); + jtxxInfo_new.remove("hiredate"); + insert("uf_jcl_emp_jtxx",jtxxInfo_new); } - //跟换id值，然后主键冲突 - String primarykey = createPrimarykey(); - log.error("getYgxxDetailInfo.primarykey:{}", primarykey); - jtxxInfo_new.put("id",primarykey); - //插入家庭信息表 - cleanUpTime(jtxxInfo_new); - jtxxInfo_new.remove("hiredate"); - insert("uf_jcl_emp_jtxx",jtxxInfo_new); } + /** * 表彰与奖励 * */ @@ -708,30 +744,33 @@ public class SyncRzglPersonInfo implements EsbServerlessRpcRemoteInterface { deleteDetailData(sql); String bzsql = "select * from uf_jcl_employ5105 where FORM_DATA_ID = '" + lcid + "' and delete_type=0"; List> bzInfo = getYgxxDetailInfo(bzsql); - Set listOfbzColumns = getTableColumnsOfTableName("uf_jcl_emp_bzyjl"); log.error("getYgxxDetailInfo.bzInfo:{}", bzInfo); - log.error("getYgxxDetailInfo.listOfbzColumns:{}", listOfbzColumns); - for (Map map : bzInfo) { - Map bzInfo_new = new HashMap<>(); - for (String key : listOfbzColumns) { - if (containsKeyIgnoreCase(map,key)) { - if("delete_type".equalsIgnoreCase(key)||"IS_DELETE".equalsIgnoreCase(key)){ - bzInfo_new.put(key,"0"); - }else{ - bzInfo_new.put(key,getIgnoreCase(map, key)); + if(CollectionUtils.isNotEmpty(bzInfo)){ + Set listOfbzColumns = getTableColumnsOfTableName("uf_jcl_emp_bzyjl"); + log.error("getYgxxDetailInfo.listOfbzColumns:{}", listOfbzColumns); + for (Map map : bzInfo) { + Map bzInfo_new = new HashMap<>(); + for (String key : listOfbzColumns) { + if (containsKeyIgnoreCase(map,key)) { + if("delete_type".equalsIgnoreCase(key)||"IS_DELETE".equalsIgnoreCase(key)){ + bzInfo_new.put(key,"0"); + }else{ + bzInfo_new.put(key,getIgnoreCase(map, key)); + } } + bzInfo_new.put("FORM_DATA_ID",ygxxid); } - bzInfo_new.put("FORM_DATA_ID",ygxxid); + //跟换id值，然后主键冲突 + String primarykey = createPrimarykey(); + log.error("getYgxxDetailInfo.primarykey:{}", primarykey); + bzInfo_new.put("id",primarykey); + //插入家庭信息表 + cleanUpTime(bzInfo_new); + bzInfo_new.remove("hiredate"); + insert("uf_jcl_emp_bzyjl",bzInfo_new); } - //跟换id值，然后主键冲突 - String primarykey = createPrimarykey(); - log.error("getYgxxDetailInfo.primarykey:{}", primarykey); - bzInfo_new.put("id",primarykey); - //插入家庭信息表 - cleanUpTime(bzInfo_new); - bzInfo_new.remove("hiredate"); - insert("uf_jcl_emp_bzyjl",bzInfo_new); } + /** * 培训经历 * */ @@ -740,30 +779,33 @@ public class SyncRzglPersonInfo implements EsbServerlessRpcRemoteInterface { deleteDetailData(sql); String pxsql = "select * from uf_jcl_employ5165 where FORM_DATA_ID = '" + lcid + "' and delete_type=0"; List> pxInfo = getYgxxDetailInfo(pxsql); - Set listOfpxColumns = getTableColumnsOfTableName("uf_jcl_emp_pxjl"); log.error("getYgxxDetailInfo.pxInfo:{}", pxInfo); - log.error("getYgxxDetailInfo.listOfpxColumns:{}", listOfpxColumns); - for (Map map : pxInfo) { - Map pxInfo_new = new HashMap<>(); - for (String key : listOfpxColumns) { - if (containsKeyIgnoreCase(map,key)) { - if("delete_type".equalsIgnoreCase(key)||"IS_DELETE".equalsIgnoreCase(key)){ - pxInfo_new.put(key,"0"); - }else{ - pxInfo_new.put(key,getIgnoreCase(map, key)); + if(CollectionUtils.isNotEmpty(pxInfo)){ + Set listOfpxColumns = getTableColumnsOfTableName("uf_jcl_emp_pxjl"); + log.error("getYgxxDetailInfo.listOfpxColumns:{}", listOfpxColumns); + for (Map map : pxInfo) { + Map pxInfo_new = new HashMap<>(); + for (String key : listOfpxColumns) { + if (containsKeyIgnoreCase(map,key)) { + if("delete_type".equalsIgnoreCase(key)||"IS_DELETE".equalsIgnoreCase(key)){ + pxInfo_new.put(key,"0"); + }else{ + pxInfo_new.put(key,getIgnoreCase(map, key)); + } } + pxInfo_new.put("FORM_DATA_ID",ygxxid); } - pxInfo_new.put("FORM_DATA_ID",ygxxid); + //跟换id值，然后主键冲突 + String primarykey = createPrimarykey(); + log.error("getYgxxDetailInfo.primarykey:{}", primarykey); + pxInfo_new.put("id",primarykey); + //插入培训表 + cleanUpTime(pxInfo_new); + pxInfo_new.remove("hiredate"); + insert("uf_jcl_emp_pxjl",pxInfo_new); } - //跟换id值，然后主键冲突 - String primarykey = createPrimarykey(); - log.error("getYgxxDetailInfo.primarykey:{}", primarykey); - pxInfo_new.put("id",primarykey); - //插入培训表 - cleanUpTime(pxInfo_new); - pxInfo_new.remove("hiredate"); - insert("uf_jcl_emp_pxjl",pxInfo_new); } + /** * 语言能力 * */ @@ -772,30 +814,33 @@ public class SyncRzglPersonInfo implements EsbServerlessRpcRemoteInterface { deleteDetailData(sql); String yysql = "select * from uf_jcl_employ5218 where FORM_DATA_ID = '" + lcid + "' and delete_type=0"; List> yyInfo = getYgxxDetailInfo(yysql); - Set listOfyyColumns = getTableColumnsOfTableName("uf_jcl_emp_yynl"); log.error("getYgxxDetailInfo.yyInfo:{}", yyInfo); - log.error("getYgxxDetailInfo.listOfyyColumns:{}", listOfyyColumns); - for (Map map : yyInfo) { - Map yyInfo_new = new HashMap<>(); - for (String key : listOfyyColumns) { - if (containsKeyIgnoreCase(map,key)) { - if("delete_type".equalsIgnoreCase(key)||"IS_DELETE".equalsIgnoreCase(key)){ - yyInfo_new.put(key,"0"); - }else{ - yyInfo_new.put(key,getIgnoreCase(map, key)); + if(CollectionUtils.isNotEmpty(yyInfo)){ + Set listOfyyColumns = getTableColumnsOfTableName("uf_jcl_emp_yynl"); + log.error("getYgxxDetailInfo.listOfyyColumns:{}", listOfyyColumns); + for (Map map : yyInfo) { + Map yyInfo_new = new HashMap<>(); + for (String key : listOfyyColumns) { + if (containsKeyIgnoreCase(map,key)) { + if("delete_type".equalsIgnoreCase(key)||"IS_DELETE".equalsIgnoreCase(key)){ + yyInfo_new.put(key,"0"); + }else{ + yyInfo_new.put(key,getIgnoreCase(map, key)); + } } + yyInfo_new.put("FORM_DATA_ID",ygxxid); } - yyInfo_new.put("FORM_DATA_ID",ygxxid); + //跟换id值，然后主键冲突 + String primarykey = createPrimarykey(); + log.error("getYgxxDetailInfo.primarykey:{}", primarykey); + yyInfo_new.put("id",primarykey); + //插入培训表 + cleanUpTime(yyInfo_new); + yyInfo_new.remove("hiredate"); + insert("uf_jcl_emp_yynl",yyInfo_new); } - //跟换id值，然后主键冲突 - String primarykey = createPrimarykey(); - log.error("getYgxxDetailInfo.primarykey:{}", primarykey); - yyInfo_new.put("id",primarykey); - //插入培训表 - cleanUpTime(yyInfo_new); - yyInfo_new.remove("hiredate"); - insert("uf_jcl_emp_yynl",yyInfo_new); } + /** * 权威机构资格 * */ @@ -804,30 +849,33 @@ public class SyncRzglPersonInfo implements EsbServerlessRpcRemoteInterface { deleteDetailData(sql); String qwsql = "select * from uf_jcl_employ5265 where FORM_DATA_ID = '" + lcid + "' and delete_type=0"; List> qwInfo = getYgxxDetailInfo(qwsql); - Set listOfqwColumns = getTableColumnsOfTableName("uf_jcl_emp_qwjgzgrz"); log.error("getYgxxDetailInfo.qwInfo:{}", qwInfo); - log.error("getYgxxDetailInfo.listOfqwColumns:{}", listOfqwColumns); - for (Map map : qwInfo) { - Map qwInfo_new = new HashMap<>(); - for (String key : listOfqwColumns) { - if (containsKeyIgnoreCase(map,key)) { - if("delete_type".equalsIgnoreCase(key)||"IS_DELETE".equalsIgnoreCase(key)){ - qwInfo_new.put(key,"0"); - }else{ - qwInfo_new.put(key,getIgnoreCase(map, key)); + if(CollectionUtils.isNotEmpty(qwInfo)){ + Set listOfqwColumns = getTableColumnsOfTableName("uf_jcl_emp_qwjgzgrz"); + log.error("getYgxxDetailInfo.listOfqwColumns:{}", listOfqwColumns); + for (Map map : qwInfo) { + Map qwInfo_new = new HashMap<>(); + for (String key : listOfqwColumns) { + if (containsKeyIgnoreCase(map,key)) { + if("delete_type".equalsIgnoreCase(key)||"IS_DELETE".equalsIgnoreCase(key)){ + qwInfo_new.put(key,"0"); + }else{ + qwInfo_new.put(key,getIgnoreCase(map, key)); + } } + qwInfo_new.put("FORM_DATA_ID",ygxxid); } - qwInfo_new.put("FORM_DATA_ID",ygxxid); + //跟换id值，然后主键冲突 + String primarykey = createPrimarykey(); + log.error("getYgxxDetailInfo.primarykey:{}", primarykey); + qwInfo_new.put("id",primarykey); + //插入权威机构表 + cleanUpTime(qwInfo_new); + qwInfo_new.remove("hiredate"); + insert("uf_jcl_emp_qwjgzgrz",qwInfo_new); } - //跟换id值，然后主键冲突 - String primarykey = createPrimarykey(); - log.error("getYgxxDetailInfo.primarykey:{}", primarykey); - qwInfo_new.put("id",primarykey); - //插入权威机构表 - cleanUpTime(qwInfo_new); - qwInfo_new.remove("hiredate"); - insert("uf_jcl_emp_qwjgzgrz",qwInfo_new); } + } public static boolean containsKeyIgnoreCase(Map map, String key) { @@ -873,7 +921,7 @@ public class SyncRzglPersonInfo implements EsbServerlessRpcRemoteInterface { log.error("getTableColumnsOfTableName222.sql:{}", sql); Map rs = databaseUtils.execute("LOGIC", "weaver-ebuilder-form-service", sql); List> recordList = databaseUtils.getDataSourceList(rs); - log.error("getTableColumnsOfTableName.recordList:{}", recordList); + //log.error("getTableColumnsOfTableName.recordList:{}", recordList); return extractFieldNames(recordList); }