xuxy
/
jucailin_eb_product
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

优化

This commit is contained in:
Administrator 2025-05-20 16:44:38 +08:00
parent 91e10d9387
commit bd7ec4537e
1 changed files with 294 additions and 246 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

540
jcl-hrmorganization/secondev-jcl-hrmorganization/src/main/java/com/weaver/seconddev/jcl/organization/esb/SyncRzglPersonInfo.java
View File

@ -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<String, Object> map){
boolean flag = false;
public void insertFormdata(Map<String, Object> 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<String, Object> rs = databaseUtils.execute("LOGIC", "weaver-ebuilder-form-service", sql);
List<Map<String, Object>> 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<String, Object> map){
boolean flag = false;
public void insertPhysical(Map<String, Object> 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<String, Object> rs = databaseUtils.execute("LOGIC", "weaver-ebuilder-form-service", sql);
List<Map<String, Object>> 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<Map<String, Object>> gzllInfo = getYgxxDetailInfo(gzsql);
Set<String> listOfgzllColumns = getTableColumnsOfTableName("uf_jcl_emp_gzll");
log.error("getYgxxDetailInfo.gzllInfo:{}", gzllInfo);
log.error("getYgxxDetailInfo.listOfgzllColumns:{}", listOfgzllColumns);
for (Map<String, Object> map : gzllInfo) {
Map<String, Object> 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<String> listOfgzllColumns = getTableColumnsOfTableName("uf_jcl_emp_gzll");
log.error("getYgxxDetailInfo.listOfgzllColumns:{}", listOfgzllColumns);
for (Map<String, Object> map : gzllInfo) {
Map<String, Object> 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<Map<String, Object>> jyjlInfo = getYgxxDetailInfo(jysql);
Set<String> listOfjyjlColumns = getTableColumnsOfTableName("uf_jcl_emp_jyjl");
log.error("getYgxxDetailInfo.jyjlInfo:{}", jyjlInfo);
log.error("getYgxxDetailInfo.listOfjyjlColumns:{}", listOfjyjlColumns);
for (Map<String, Object> map : jyjlInfo) {
Map<String, Object> 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<String> listOfjyjlColumns = getTableColumnsOfTableName("uf_jcl_emp_jyjl");
log.error("getYgxxDetailInfo.listOfjyjlColumns:{}", listOfjyjlColumns);
for (Map<String, Object> map : jyjlInfo) {
Map<String, Object> 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<Map<String, Object>> jtxxInfo = getYgxxDetailInfo(jtxxsql);
Set<String> listOfjtxxColumns = getTableColumnsOfTableName("uf_jcl_emp_jtxx");
log.error("getYgxxDetailInfo.jtxxInfo:{}", jtxxInfo);
for (Map<String, Object> map : jtxxInfo) {
Map<String, Object> 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<String> listOfjtxxColumns = getTableColumnsOfTableName("uf_jcl_emp_jtxx");
log.error("getYgxxDetailInfo.listOfjtxxColumns:{}", listOfjtxxColumns);
for (Map<String, Object> map : jtxxInfo) {
Map<String, Object> 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<Map<String, Object>> bzInfo = getYgxxDetailInfo(bzsql);
Set<String> listOfbzColumns = getTableColumnsOfTableName("uf_jcl_emp_bzyjl");
log.error("getYgxxDetailInfo.bzInfo:{}", bzInfo);
log.error("getYgxxDetailInfo.listOfbzColumns:{}", listOfbzColumns);
for (Map<String, Object> map : bzInfo) {
Map<String, Object> 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<String> listOfbzColumns = getTableColumnsOfTableName("uf_jcl_emp_bzyjl");
log.error("getYgxxDetailInfo.listOfbzColumns:{}", listOfbzColumns);
for (Map<String, Object> map : bzInfo) {
Map<String, Object> 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<Map<String, Object>> pxInfo = getYgxxDetailInfo(pxsql);
Set<String> listOfpxColumns = getTableColumnsOfTableName("uf_jcl_emp_pxjl");
log.error("getYgxxDetailInfo.pxInfo:{}", pxInfo);
log.error("getYgxxDetailInfo.listOfpxColumns:{}", listOfpxColumns);
for (Map<String, Object> map : pxInfo) {
Map<String, Object> 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<String> listOfpxColumns = getTableColumnsOfTableName("uf_jcl_emp_pxjl");
log.error("getYgxxDetailInfo.listOfpxColumns:{}", listOfpxColumns);
for (Map<String, Object> map : pxInfo) {
Map<String, Object> 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<Map<String, Object>> yyInfo = getYgxxDetailInfo(yysql);
Set<String> listOfyyColumns = getTableColumnsOfTableName("uf_jcl_emp_yynl");
log.error("getYgxxDetailInfo.yyInfo:{}", yyInfo);
log.error("getYgxxDetailInfo.listOfyyColumns:{}", listOfyyColumns);
for (Map<String, Object> map : yyInfo) {
Map<String, Object> 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<String> listOfyyColumns = getTableColumnsOfTableName("uf_jcl_emp_yynl");
log.error("getYgxxDetailInfo.listOfyyColumns:{}", listOfyyColumns);
for (Map<String, Object> map : yyInfo) {
Map<String, Object> 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<Map<String, Object>> qwInfo = getYgxxDetailInfo(qwsql);
Set<String> listOfqwColumns = getTableColumnsOfTableName("uf_jcl_emp_qwjgzgrz");
log.error("getYgxxDetailInfo.qwInfo:{}", qwInfo);
log.error("getYgxxDetailInfo.listOfqwColumns:{}", listOfqwColumns);
for (Map<String, Object> map : qwInfo) {
Map<String, Object> 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<String> listOfqwColumns = getTableColumnsOfTableName("uf_jcl_emp_qwjgzgrz");
log.error("getYgxxDetailInfo.listOfqwColumns:{}", listOfqwColumns);
for (Map<String, Object> map : qwInfo) {
Map<String, Object> 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<Map<String, Object>> gzllInfo = getYgxxDetailInfo(gzsql);
Set<String> listOfgzllColumns = getTableColumnsOfTableName("uf_jcl_emp_gzll");
log.error("updateAllXxbgDetailInfo.gzllInfo:{}", gzllInfo);
log.error("updateAllXxbgDetailInfo.listOfgzllColumns:{}", listOfgzllColumns);
for (Map<String, Object> map : gzllInfo) {
Map<String, Object> 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<String> listOfgzllColumns = getTableColumnsOfTableName("uf_jcl_emp_gzll");
log.error("updateAllXxbgDetailInfo.listOfgzllColumns:{}", listOfgzllColumns);
for (Map<String, Object> map : gzllInfo) {
Map<String, Object> 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<Map<String, Object>> jyjlInfo = getYgxxDetailInfo(jysql);
Set<String> listOfjyjlColumns = getTableColumnsOfTableName("uf_jcl_emp_jyjl");
log.error("getYgxxDetailInfo.jyjlInfo0172:{}", jyjlInfo);
log.error("getYgxxDetailInfo.listOfjyjlColumns:{}", listOfjyjlColumns);
for (Map<String, Object> map : jyjlInfo) {
Map<String, Object> 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<String> listOfjyjlColumns = getTableColumnsOfTableName("uf_jcl_emp_jyjl");
log.error("getYgxxDetailInfo.listOfjyjlColumns:{}", listOfjyjlColumns);
for (Map<String, Object> map : jyjlInfo) {
Map<String, Object> 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<Map<String, Object>> jtxxInfo = getYgxxDetailInfo(jtxxsql);
Set<String> listOfjtxxColumns = getTableColumnsOfTableName("uf_jcl_emp_jtxx");
log.error("getYgxxDetailInfo.jtxxInfo:{}", jtxxInfo);
for (Map<String, Object> map : jtxxInfo) {
Map<String, Object> 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<String> listOfjtxxColumns = getTableColumnsOfTableName("uf_jcl_emp_jtxx");
log.error("getYgxxDetailInfo.listOfjtxxColumns:{}", listOfjtxxColumns);
for (Map<String, Object> map : jtxxInfo) {
Map<String, Object> 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<Map<String, Object>> bzInfo = getYgxxDetailInfo(bzsql);
Set<String> listOfbzColumns = getTableColumnsOfTableName("uf_jcl_emp_bzyjl");
log.error("getYgxxDetailInfo.bzInfo:{}", bzInfo);
log.error("getYgxxDetailInfo.listOfbzColumns:{}", listOfbzColumns);
for (Map<String, Object> map : bzInfo) {
Map<String, Object> 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<String> listOfbzColumns = getTableColumnsOfTableName("uf_jcl_emp_bzyjl");
log.error("getYgxxDetailInfo.listOfbzColumns:{}", listOfbzColumns);
for (Map<String, Object> map : bzInfo) {
Map<String, Object> 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<Map<String, Object>> pxInfo = getYgxxDetailInfo(pxsql);
Set<String> listOfpxColumns = getTableColumnsOfTableName("uf_jcl_emp_pxjl");
log.error("getYgxxDetailInfo.pxInfo:{}", pxInfo);
log.error("getYgxxDetailInfo.listOfpxColumns:{}", listOfpxColumns);
for (Map<String, Object> map : pxInfo) {
Map<String, Object> 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<String> listOfpxColumns = getTableColumnsOfTableName("uf_jcl_emp_pxjl");
log.error("getYgxxDetailInfo.listOfpxColumns:{}", listOfpxColumns);
for (Map<String, Object> map : pxInfo) {
Map<String, Object> 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<Map<String, Object>> yyInfo = getYgxxDetailInfo(yysql);
Set<String> listOfyyColumns = getTableColumnsOfTableName("uf_jcl_emp_yynl");
log.error("getYgxxDetailInfo.yyInfo:{}", yyInfo);
log.error("getYgxxDetailInfo.listOfyyColumns:{}", listOfyyColumns);
for (Map<String, Object> map : yyInfo) {
Map<String, Object> 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<String> listOfyyColumns = getTableColumnsOfTableName("uf_jcl_emp_yynl");
log.error("getYgxxDetailInfo.listOfyyColumns:{}", listOfyyColumns);
for (Map<String, Object> map : yyInfo) {
Map<String, Object> 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<Map<String, Object>> qwInfo = getYgxxDetailInfo(qwsql);
Set<String> listOfqwColumns = getTableColumnsOfTableName("uf_jcl_emp_qwjgzgrz");
log.error("getYgxxDetailInfo.qwInfo:{}", qwInfo);
log.error("getYgxxDetailInfo.listOfqwColumns:{}", listOfqwColumns);
for (Map<String, Object> map : qwInfo) {
Map<String, Object> 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<String> listOfqwColumns = getTableColumnsOfTableName("uf_jcl_emp_qwjgzgrz");
log.error("getYgxxDetailInfo.listOfqwColumns:{}", listOfqwColumns);
for (Map<String, Object> map : qwInfo) {
Map<String, Object> 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<String, Object> map, String key) {
@ -873,7 +921,7 @@ public class SyncRzglPersonInfo implements EsbServerlessRpcRemoteInterface {
log.error("getTableColumnsOfTableName222.sql:{}", sql);
Map<String, Object> rs = databaseUtils.execute("LOGIC", "weaver-ebuilder-form-service", sql);
List<Map<String, Object>> recordList = databaseUtils.getDataSourceList(rs);
log.error("getTableColumnsOfTableName.recordList:{}", recordList);
//log.error("getTableColumnsOfTableName.recordList:{}", recordList);
return extractFieldNames(recordList);
}