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-21 17:46:04 +08:00
parent f693f0cc3a
commit ff6d5da87a
2 changed files with 44 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -89,7 +89,7 @@ public class SyncRzglPersonInfo implements EsbServerlessRpcRemoteInterface {
/**
* 员工信息明细表数据同步处理
*/
syncAllYgxxDetailInfo(sjid);
syncAllYgxxDetailInfo(sjid,ryid);
/**
* 写入表单引擎数据大表
@ -118,6 +118,13 @@ public class SyncRzglPersonInfo implements EsbServerlessRpcRemoteInterface {
map.remove("eb_workflow_id");
map.remove("current_step");
map.remove("name");
map.remove("rzzt_obj");
map.remove("rzzt");
map.remove("rzsqlc_obj");
map.remove("rzsqlc");
map.remove("sec_level");
if(!map.isEmpty()){
//更新前先处理一下时间
cleanUpTime(map);
@ -436,7 +443,7 @@ public class SyncRzglPersonInfo implements EsbServerlessRpcRemoteInterface {
* 数据同步处理明细表
* @return
*/
public void syncAllYgxxDetailInfo(String ygxxid){
public void syncAllYgxxDetailInfo(String ygxxid,String id){
log.error("syncAllYgxxDetailInfo.ygxxid:{}", ygxxid);
/**
* 工作履历表
@ -461,6 +468,9 @@ public class SyncRzglPersonInfo implements EsbServerlessRpcRemoteInterface {
//插入组织工作履历表
cleanUpTime(gzllInfo_new);
gzllInfo_new.remove("hiredate");
String detail_id = createPrimarykey();
gzllInfo_new.put("id",detail_id);
gzllInfo_new.put("form_data_id",id);
insert("uf_jcl_emp_gzll",gzllInfo_new);
}
}
@ -488,6 +498,9 @@ public class SyncRzglPersonInfo implements EsbServerlessRpcRemoteInterface {
//插入教育经历表
cleanUpTime(jyjlInfo_new);
jyjlInfo_new.remove("hiredate");
String detail_id = createPrimarykey();
jyjlInfo_new.put("id",detail_id);
jyjlInfo_new.put("form_data_id",id);
insert("uf_jcl_emp_jyjl",jyjlInfo_new);
}
}
@ -515,6 +528,9 @@ public class SyncRzglPersonInfo implements EsbServerlessRpcRemoteInterface {
//插入家庭信息表
cleanUpTime(jtxxInfo_new);
jtxxInfo_new.remove("hiredate");
String detail_id = createPrimarykey();
jtxxInfo_new.put("id",detail_id);
jtxxInfo_new.put("form_data_id",id);
insert("uf_jcl_emp_jtxx",jtxxInfo_new);
}
}
@ -541,6 +557,9 @@ public class SyncRzglPersonInfo implements EsbServerlessRpcRemoteInterface {
}
cleanUpTime(bzInfo_new);
bzInfo_new.remove("hiredate");
String detail_id = createPrimarykey();
bzInfo_new.put("id",detail_id);
bzInfo_new.put("form_data_id",id);
//插入家庭信息表
insert("uf_jcl_emp_bzyjl",bzInfo_new);
}
@ -569,6 +588,9 @@ public class SyncRzglPersonInfo implements EsbServerlessRpcRemoteInterface {
//插入培训表
cleanUpTime(pxInfo_new);
pxInfo_new.remove("hiredate");
String detail_id = createPrimarykey();
pxInfo_new.put("id",detail_id);
pxInfo_new.put("form_data_id",id);
insert("uf_jcl_emp_pxjl",pxInfo_new);
}
}
@ -596,6 +618,9 @@ public class SyncRzglPersonInfo implements EsbServerlessRpcRemoteInterface {
//插入培训表
cleanUpTime(yyInfo_new);
yyInfo_new.remove("hiredate");
String detail_id = createPrimarykey();
yyInfo_new.put("id",detail_id);
yyInfo_new.put("form_data_id",id);
insert("uf_jcl_emp_yynl",yyInfo_new);
}
}
@ -623,6 +648,9 @@ public class SyncRzglPersonInfo implements EsbServerlessRpcRemoteInterface {
//插入权威机构表
cleanUpTime(qwInfo_new);
qwInfo_new.remove("hiredate");
String detail_id = createPrimarykey();
qwInfo_new.put("id",detail_id);
qwInfo_new.put("form_data_id",id);
insert("uf_jcl_emp_qwjgzgrz",qwInfo_new);
}
}
@ -657,7 +685,7 @@ public class SyncRzglPersonInfo implements EsbServerlessRpcRemoteInterface {
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();
@ -692,7 +720,7 @@ public class SyncRzglPersonInfo implements EsbServerlessRpcRemoteInterface {
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();
@ -727,7 +755,7 @@ public class SyncRzglPersonInfo implements EsbServerlessRpcRemoteInterface {
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();
@ -762,7 +790,7 @@ public class SyncRzglPersonInfo implements EsbServerlessRpcRemoteInterface {
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();
@ -797,7 +825,7 @@ public class SyncRzglPersonInfo implements EsbServerlessRpcRemoteInterface {
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();
@ -832,7 +860,7 @@ public class SyncRzglPersonInfo implements EsbServerlessRpcRemoteInterface {
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();
@ -867,7 +895,7 @@ public class SyncRzglPersonInfo implements EsbServerlessRpcRemoteInterface {
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();

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

@ -360,7 +360,7 @@ public class SyncXxbgPersonInfo implements EsbServerlessRpcRemoteInterface {
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();
@ -392,7 +392,7 @@ public class SyncXxbgPersonInfo implements EsbServerlessRpcRemoteInterface {
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();
@ -423,7 +423,7 @@ public class SyncXxbgPersonInfo implements EsbServerlessRpcRemoteInterface {
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();
@ -455,7 +455,7 @@ public class SyncXxbgPersonInfo implements EsbServerlessRpcRemoteInterface {
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();
@ -487,7 +487,7 @@ public class SyncXxbgPersonInfo implements EsbServerlessRpcRemoteInterface {
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();
@ -519,7 +519,7 @@ public class SyncXxbgPersonInfo implements EsbServerlessRpcRemoteInterface {
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();
@ -551,7 +551,7 @@ public class SyncXxbgPersonInfo implements EsbServerlessRpcRemoteInterface {
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();