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

SQL优化

This commit is contained in:
Administrator 2025-05-08 17:51:56 +08:00
parent 5ccde64424
commit 1bd6de8fd8
3 changed files with 100 additions and 185 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -127,10 +127,7 @@ public class SyncAllOrgPersonInfo implements EsbServerlessRpcRemoteInterface {
cleanUpTime(employee_info);
//employee_info
//1.查询employee表字段
List<Map<String, Object>> employeeColumns = getTableColumnsOfTableName("employee");
List<String> listOfEmployee = employeeColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfEmployee = getTableColumnsOfTableName("employee");
// 遍历并移除(不包含则移除掉)
Map<String, Object> employee_new = new HashMap<>();
for (String key : listOfEmployee) {
@ -177,10 +174,7 @@ public class SyncAllOrgPersonInfo implements EsbServerlessRpcRemoteInterface {
code2 = update(tableName,employeeCustomize_new,"FORM_DATA_ID",formdata);
}
//3查询个人信息表
List<Map<String, Object>> userInfoColumns = getTableColumnsOfTableName("hr_userinfo");
List<String> listOfUserInfoColumns = userInfoColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfUserInfoColumns = getTableColumnsOfTableName("hr_userinfo");
// 遍历并移除(不包含则移除掉)
Map<String, Object> userInfo_new = new HashMap<>();
for (String key : listOfUserInfoColumns) {
@ -285,10 +279,7 @@ public class SyncAllOrgPersonInfo implements EsbServerlessRpcRemoteInterface {
* */
String gzsql = "select * from uf_jcl_emp_gzll where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0";
List<Map<String, Object>> gzllInfo = getYgxxDetailInfo(gzsql);
List<Map<String, Object>> gzllColumns = getTableColumnsOfTableName("hr_employment_record");
List<String> listOfgzllColumns = gzllColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfgzllColumns = getTableColumnsOfTableName("hr_employment_record");
log.error("updateAllYgxxDetailInfo.gzllInfo:{}", gzllInfo);
log.error("updateAllYgxxDetailInfo.listOfgzllColumns:{}", listOfgzllColumns);
for (Map<String, Object> map : gzllInfo) {
@ -311,10 +302,7 @@ public class SyncAllOrgPersonInfo implements EsbServerlessRpcRemoteInterface {
* */
String jysql = "select * from uf_jcl_emp_jyjl where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0";
List<Map<String, Object>> jyjlInfo = getYgxxDetailInfo(jysql);
List<Map<String, Object>> jyjlColumns = getTableColumnsOfTableName("hr_education");
List<String> listOfjyjlColumns = jyjlColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfjyjlColumns = getTableColumnsOfTableName("hr_education");
log.error("updateAllYgxxDetailInfo.jyjlInfo:{}", jyjlInfo);
log.error("updateAllYgxxDetailInfo.listOfjyjlColumns:{}", listOfjyjlColumns);
for (Map<String, Object> map : jyjlInfo) {
@ -337,12 +325,9 @@ public class SyncAllOrgPersonInfo implements EsbServerlessRpcRemoteInterface {
* */
String jtxxsql = "select * from uf_jcl_emp_jtxx where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0";
List<Map<String, Object>> jtxxInfo = getYgxxDetailInfo(jtxxsql);
List<Map<String, Object>> jtxxColumns = getTableColumnsOfTableName("hr_family");
List<String> listOfjtxxColumns = jtxxColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfjtxxColumns = getTableColumnsOfTableName("hr_family");
log.error("updateAllYgxxDetailInfo.jtxxInfo:{}", jtxxInfo);
log.error("updateAllYgxxDetailInfo.jtxxColumns:{}", jtxxColumns);
log.error("updateAllYgxxDetailInfo.listOfjtxxColumns:{}", listOfjtxxColumns);
for (Map<String, Object> map : jtxxInfo) {
Map<String, Object> jtxxInfo_new = new HashMap<>();
for (String key : listOfjtxxColumns) {
@ -363,10 +348,7 @@ public class SyncAllOrgPersonInfo implements EsbServerlessRpcRemoteInterface {
* */
String bzsql = "select * from uf_jcl_emp_bzyjl where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0";
List<Map<String, Object>> bzInfo = getYgxxDetailInfo(bzsql);
List<Map<String, Object>> bzColumns = getTableColumnsOfTableName("hr_rewards_before");
List<String> listOfbzColumns = bzColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfbzColumns = getTableColumnsOfTableName("hr_rewards_before");
log.error("updateAllYgxxDetailInfo.bzInfo:{}", bzInfo);
log.error("updateAllYgxxDetailInfo.listOfbzColumns:{}", listOfbzColumns);
for (Map<String, Object> map : bzInfo) {
@ -389,10 +371,7 @@ public class SyncAllOrgPersonInfo implements EsbServerlessRpcRemoteInterface {
* */
String pxsql = "select * from uf_jcl_emp_pxjl where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0";
List<Map<String, Object>> pxInfo = getYgxxDetailInfo(pxsql);
List<Map<String, Object>> pxColumns = getTableColumnsOfTableName("hr_train");
List<String> listOfpxColumns = pxColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfpxColumns = getTableColumnsOfTableName("hr_train");
log.error("updateAllYgxxDetailInfo.pxInfo:{}", pxInfo);
log.error("updateAllYgxxDetailInfo.listOfpxColumns:{}", listOfpxColumns);
for (Map<String, Object> map : pxInfo) {
@ -415,10 +394,7 @@ public class SyncAllOrgPersonInfo implements EsbServerlessRpcRemoteInterface {
* */
String yysql = "select * from uf_jcl_emp_yynl where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0";
List<Map<String, Object>> yyInfo = getYgxxDetailInfo(yysql);
List<Map<String, Object>> yyColumns = getTableColumnsOfTableName("hr_language");
List<String> listOfyyColumns = yyColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfyyColumns = getTableColumnsOfTableName("hr_language");
log.error("updateAllYgxxDetailInfo.yyInfo:{}", yyInfo);
log.error("updateAllYgxxDetailInfo.listOfyyColumns:{}", listOfyyColumns);
for (Map<String, Object> map : yyInfo) {
@ -441,10 +417,7 @@ public class SyncAllOrgPersonInfo implements EsbServerlessRpcRemoteInterface {
* */
String qwsql = "select * from uf_jcl_emp_qwjgzgrz where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0";
List<Map<String, Object>> qwInfo = getYgxxDetailInfo(qwsql);
List<Map<String, Object>> qwColumns = getTableColumnsOfTableName("hr_certification");
List<String> listOfqwColumns = qwColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfqwColumns = getTableColumnsOfTableName("hr_certification");
log.error("updateAllYgxxDetailInfo.qwInfo:{}", qwInfo);
log.error("updateAllYgxxDetailInfo.listOfqwColumns:{}", listOfqwColumns);
for (Map<String, Object> map : qwInfo) {
@ -624,13 +597,29 @@ public class SyncAllOrgPersonInfo implements EsbServerlessRpcRemoteInterface {
return form_data;
}
public List<Map<String, Object>> getTableColumnsOfTableName(String tableName) {
String sql = "SELECT column_name FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_NAME = '" + tableName + "' ";
log.error("getTableColumnsOfTableName111.sql:{}", sql);
// public List<Map<String, Object>> getTableColumnsOfTableName(String tableName) {
// String sql = "SELECT column_name FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_NAME = '" + tableName + "' ";
// log.error("getTableColumnsOfTableName111.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);
// return recordList;
// }
public Set<String> getTableColumnsOfTableName(String tableName) {
String sql = "SELECT * FROM " + tableName;
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);
return recordList;
return extractFieldNames(recordList);
}
public Set<String> extractFieldNames(List<Map<String, Object>> recordList) {
// 使用 Stream API 提取所有字段名
return recordList.stream()
.flatMap(record -> record.keySet().stream())
.collect(Collectors.toSet());
}
public static String getIgnoreCase(Map<String, Object> map, String key) {

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

@ -135,10 +135,7 @@ public class SyncAllYgxxInfoOfOrg implements EsbServerlessRpcRemoteInterface {
log.error("SyncAllYgxxInfoOfOrg.userCustomize_infos:{}", userCustomize_infos);
//1.查询uf_jcl_employee_information表字段
List<Map<String, Object>> employeeColumns = getTableColumnsOfTableName("uf_jcl_employee_information");
List<String> listOfEmployee = employeeColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfEmployee = getTableColumnsOfTableName("uf_jcl_employee_information");
/**
* 映射表数据
*/
@ -379,10 +376,7 @@ public class SyncAllYgxxInfoOfOrg implements EsbServerlessRpcRemoteInterface {
* */
String gzsql = "select * from hr_employment_record where user_id = '" + zzid + "' and delete_type=0";
List<Map<String, Object>> gzllInfo = getYgxxDetailInfo(gzsql);
List<Map<String, Object>> gzllColumns = getTableColumnsOfTableName("uf_jcl_emp_gzll");
List<String> listOfgzllColumns = gzllColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfgzllColumns = getTableColumnsOfTableName("uf_jcl_emp_gzll");
log.error("updateAllYgxxDetailInfo.gzllInfo:{}", gzllInfo);
log.error("updateAllYgxxDetailInfo.listOfgzllColumns:{}", listOfgzllColumns);
for (Map<String, Object> map : gzllInfo) {
@ -405,10 +399,7 @@ public class SyncAllYgxxInfoOfOrg implements EsbServerlessRpcRemoteInterface {
* */
String jysql = "select * from hr_education where employee_id = '" + zzid + "' and delete_type=0";
List<Map<String, Object>> jyjlInfo = getYgxxDetailInfo(jysql);
List<Map<String, Object>> jyjlColumns = getTableColumnsOfTableName("uf_jcl_emp_jyjl");
List<String> listOfjyjlColumns = jyjlColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfjyjlColumns = getTableColumnsOfTableName("uf_jcl_emp_jyjl");
log.error("updateAllYgxxDetailInfo.jyjlInfo:{}", jyjlInfo);
log.error("updateAllYgxxDetailInfo.listOfjyjlColumns:{}", listOfjyjlColumns);
for (Map<String, Object> map : jyjlInfo) {
@ -431,12 +422,9 @@ public class SyncAllYgxxInfoOfOrg implements EsbServerlessRpcRemoteInterface {
* */
String jtxxsql = "select * from hr_family where employee_id = '" + zzid + "' and delete_type=0";
List<Map<String, Object>> jtxxInfo = getYgxxDetailInfo(jtxxsql);
List<Map<String, Object>> jtxxColumns = getTableColumnsOfTableName("uf_jcl_emp_jtxx");
List<String> listOfjtxxColumns = jtxxColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfjtxxColumns = getTableColumnsOfTableName("uf_jcl_emp_jtxx");
log.error("updateAllYgxxDetailInfo.jtxxInfo:{}", jtxxInfo);
log.error("updateAllYgxxDetailInfo.jtxxColumns:{}", jtxxColumns);
log.error("updateAllYgxxDetailInfo.listOfjtxxColumns:{}", listOfjtxxColumns);
for (Map<String, Object> map : jtxxInfo) {
Map<String, Object> jtxxInfo_new = new HashMap<>();
for (String key : listOfjtxxColumns) {
@ -457,10 +445,7 @@ public class SyncAllYgxxInfoOfOrg implements EsbServerlessRpcRemoteInterface {
* */
String bzsql = "select * from hr_rewards_before where employeeid = '" + zzid + "' and delete_type=0";
List<Map<String, Object>> bzInfo = getYgxxDetailInfo(bzsql);
List<Map<String, Object>> bzColumns = getTableColumnsOfTableName("uf_jcl_emp_bzyjl");
List<String> listOfbzColumns = bzColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfbzColumns = getTableColumnsOfTableName("uf_jcl_emp_bzyjl");
log.error("updateAllYgxxDetailInfo.bzInfo:{}", bzInfo);
log.error("updateAllYgxxDetailInfo.listOfbzColumns:{}", listOfbzColumns);
for (Map<String, Object> map : bzInfo) {
@ -483,10 +468,7 @@ public class SyncAllYgxxInfoOfOrg implements EsbServerlessRpcRemoteInterface {
* */
String pxsql = "select * from hr_train where employee_id = '" + zzid + "' and delete_type=0";
List<Map<String, Object>> pxInfo = getYgxxDetailInfo(pxsql);
List<Map<String, Object>> pxColumns = getTableColumnsOfTableName("uf_jcl_emp_pxjl");
List<String> listOfpxColumns = pxColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfpxColumns = getTableColumnsOfTableName("uf_jcl_emp_pxjl");
log.error("updateAllYgxxDetailInfo.pxInfo:{}", pxInfo);
log.error("updateAllYgxxDetailInfo.listOfpxColumns:{}", listOfpxColumns);
for (Map<String, Object> map : pxInfo) {
@ -509,10 +491,7 @@ public class SyncAllYgxxInfoOfOrg implements EsbServerlessRpcRemoteInterface {
* */
String yysql = "select * from hr_language where employee_id = '" + zzid + "' and delete_type=0";
List<Map<String, Object>> yyInfo = getYgxxDetailInfo(yysql);
List<Map<String, Object>> yyColumns = getTableColumnsOfTableName("uf_jcl_emp_yynl");
List<String> listOfyyColumns = yyColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfyyColumns = getTableColumnsOfTableName("uf_jcl_emp_yynl");
log.error("updateAllYgxxDetailInfo.yyInfo:{}", yyInfo);
log.error("updateAllYgxxDetailInfo.listOfyyColumns:{}", listOfyyColumns);
for (Map<String, Object> map : yyInfo) {
@ -535,10 +514,7 @@ public class SyncAllYgxxInfoOfOrg implements EsbServerlessRpcRemoteInterface {
* */
String qwsql = "select * from hr_certification where employee_id = '" + zzid + "' and delete_type=0";
List<Map<String, Object>> qwInfo = getYgxxDetailInfo(qwsql);
List<Map<String, Object>> qwColumns = getTableColumnsOfTableName("uf_jcl_emp_qwjgzgrz");
List<String> listOfqwColumns = qwColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfqwColumns = getTableColumnsOfTableName("uf_jcl_emp_qwjgzgrz");
log.error("updateAllYgxxDetailInfo.qwInfo:{}", qwInfo);
log.error("updateAllYgxxDetailInfo.listOfqwColumns:{}", listOfqwColumns);
for (Map<String, Object> map : qwInfo) {
@ -718,13 +694,29 @@ public class SyncAllYgxxInfoOfOrg implements EsbServerlessRpcRemoteInterface {
return form_data;
}
public List<Map<String, Object>> getTableColumnsOfTableName(String tableName) {
String sql = "SELECT column_name FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_NAME = '" + tableName + "' ";
log.error("getTableColumnsOfTableName111.sql:{}", sql);
// public List<Map<String, Object>> getTableColumnsOfTableName(String tableName) {
// String sql = "SELECT column_name FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_NAME = '" + tableName + "' ";
// log.error("getTableColumnsOfTableName111.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);
// return recordList;
// }
public Set<String> getTableColumnsOfTableName(String tableName) {
String sql = "SELECT * FROM " + tableName;
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);
return recordList;
return extractFieldNames(recordList);
}
public Set<String> extractFieldNames(List<Map<String, Object>> recordList) {
// 使用 Stream API 提取所有字段名
return recordList.stream()
.flatMap(record -> record.keySet().stream())
.collect(Collectors.toSet());
}
public static String getIgnoreCase(Map<String, Object> map, String key) {

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

@ -131,10 +131,11 @@ public class SyncOrganizationPersonInfo implements EsbServerlessRpcRemoteInterfa
if(StringUtils.isBlank(glzzyg)){
//新增员工
//1.查询employee表字段
List<Map<String, Object>> employeeColumns = getTableColumnsOfTableName("employee");
List<String> listOfEmployee = employeeColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
//List<Map<String, Object>> employeeColumns = getTableColumnsOfTableName("employee");
Set<String> listOfEmployee = getTableColumnsOfTableName("employee");
// List<String> listOfEmployee = employeeColumns.stream()
// .map(map -> map.get("column_name").toString())
// .collect(Collectors.toList());
log.error("SyncOrganizationPersonInfo.listOfEmployee:{}", listOfEmployee);
// 遍历并移除(不包含则移除掉)
Map<String, Object> employee_new = new HashMap<>();
@ -188,10 +189,7 @@ public class SyncOrganizationPersonInfo implements EsbServerlessRpcRemoteInterfa
log.error("SyncOrganizationPersonInfo.employeeCustomize_new:{}", employeeCustomize_new);
code2 = insert(tableName,employeeCustomize_new);
//3查询个人信息表
List<Map<String, Object>> userInfoColumns = getTableColumnsOfTableName("hr_userinfo");
List<String> listOfUserInfoColumns = userInfoColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfUserInfoColumns = getTableColumnsOfTableName("hr_userinfo");
// 遍历并移除(不包含则移除掉)
Map<String, Object> userInfo_new = new HashMap<>();
log.error("SyncOrganizationPersonInfo.listOfUserInfoColumns:{}", listOfUserInfoColumns);
@ -267,10 +265,7 @@ public class SyncOrganizationPersonInfo implements EsbServerlessRpcRemoteInterfa
cleanUpTime(employee_info);
//employee_info
//1.查询employee表字段
List<Map<String, Object>> employeeColumns = getTableColumnsOfTableName("employee");
List<String> listOfEmployee = employeeColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfEmployee = getTableColumnsOfTableName("employee");
// 遍历并移除(不包含则移除掉)
Map<String, Object> employee_new = new HashMap<>();
for (String key : listOfEmployee) {
@ -315,10 +310,7 @@ public class SyncOrganizationPersonInfo implements EsbServerlessRpcRemoteInterfa
code2 = update(tableName,employeeCustomize_new,"FORM_DATA_ID",formdata);
}
//3查询个人信息表
List<Map<String, Object>> userInfoColumns = getTableColumnsOfTableName("hr_userinfo");
List<String> listOfUserInfoColumns = userInfoColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfUserInfoColumns = getTableColumnsOfTableName("hr_userinfo");
// 遍历并移除(不包含则移除掉)
Map<String, Object> userInfo_new = new HashMap<>();
for (String key : listOfUserInfoColumns) {
@ -389,10 +381,7 @@ public class SyncOrganizationPersonInfo implements EsbServerlessRpcRemoteInterfa
* */
String gzsql = "select * from uf_jcl_emp_gzll where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0";
List<Map<String, Object>> gzllInfo = getYgxxDetailInfo(gzsql);
List<Map<String, Object>> gzllColumns = getTableColumnsOfTableName("hr_employment_record");
List<String> listOfgzllColumns = gzllColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfgzllColumns = getTableColumnsOfTableName("hr_employment_record");
log.error("getYgxxDetailInfo.gzllInfo:{}", gzllInfo);
log.error("getYgxxDetailInfo.listOfgzllColumns:{}", listOfgzllColumns);
for (Map<String, Object> map : gzllInfo) {
@ -416,10 +405,7 @@ public class SyncOrganizationPersonInfo implements EsbServerlessRpcRemoteInterfa
* */
String jysql = "select * from uf_jcl_emp_jyjl where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0";
List<Map<String, Object>> jyjlInfo = getYgxxDetailInfo(jysql);
List<Map<String, Object>> jyjlColumns = getTableColumnsOfTableName("hr_education");
List<String> listOfjyjlColumns = jyjlColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfjyjlColumns = getTableColumnsOfTableName("hr_education");
log.error("getYgxxDetailInfo.jyjlInfo:{}", jyjlInfo);
log.error("getYgxxDetailInfo.listOfjyjlColumns:{}", listOfjyjlColumns);
for (Map<String, Object> map : jyjlInfo) {
@ -443,12 +429,8 @@ public class SyncOrganizationPersonInfo implements EsbServerlessRpcRemoteInterfa
* */
String jtxxsql = "select * from uf_jcl_emp_jtxx where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0";
List<Map<String, Object>> jtxxInfo = getYgxxDetailInfo(jtxxsql);
List<Map<String, Object>> jtxxColumns = getTableColumnsOfTableName("hr_family");
List<String> listOfjtxxColumns = jtxxColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfjtxxColumns = getTableColumnsOfTableName("hr_family");
log.error("getYgxxDetailInfo.jtxxInfo:{}", jtxxInfo);
log.error("getYgxxDetailInfo.jtxxColumns:{}", jtxxColumns);
for (Map<String, Object> map : jtxxInfo) {
Map<String, Object> jtxxInfo_new = new HashMap<>();
for (String key : listOfjtxxColumns) {
@ -470,10 +452,7 @@ public class SyncOrganizationPersonInfo implements EsbServerlessRpcRemoteInterfa
* */
String bzsql = "select * from uf_jcl_emp_bzyjl where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0";
List<Map<String, Object>> bzInfo = getYgxxDetailInfo(bzsql);
List<Map<String, Object>> bzColumns = getTableColumnsOfTableName("hr_rewards_before");
List<String> listOfbzColumns = bzColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfbzColumns = getTableColumnsOfTableName("hr_rewards_before");
log.error("getYgxxDetailInfo.bzInfo:{}", bzInfo);
log.error("getYgxxDetailInfo.listOfbzColumns:{}", listOfbzColumns);
for (Map<String, Object> map : bzInfo) {
@ -497,10 +476,7 @@ public class SyncOrganizationPersonInfo implements EsbServerlessRpcRemoteInterfa
* */
String pxsql = "select * from uf_jcl_emp_pxjl where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0";
List<Map<String, Object>> pxInfo = getYgxxDetailInfo(pxsql);
List<Map<String, Object>> pxColumns = getTableColumnsOfTableName("hr_train");
List<String> listOfpxColumns = pxColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfpxColumns = getTableColumnsOfTableName("hr_train");
log.error("getYgxxDetailInfo.pxInfo:{}", pxInfo);
log.error("getYgxxDetailInfo.listOfpxColumns:{}", listOfpxColumns);
for (Map<String, Object> map : pxInfo) {
@ -524,10 +500,7 @@ public class SyncOrganizationPersonInfo implements EsbServerlessRpcRemoteInterfa
* */
String yysql = "select * from uf_jcl_emp_yynl where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0";
List<Map<String, Object>> yyInfo = getYgxxDetailInfo(yysql);
List<Map<String, Object>> yyColumns = getTableColumnsOfTableName("hr_language");
List<String> listOfyyColumns = yyColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfyyColumns = getTableColumnsOfTableName("hr_language");
log.error("getYgxxDetailInfo.yyInfo:{}", yyInfo);
log.error("getYgxxDetailInfo.listOfyyColumns:{}", listOfyyColumns);
for (Map<String, Object> map : yyInfo) {
@ -551,10 +524,7 @@ public class SyncOrganizationPersonInfo implements EsbServerlessRpcRemoteInterfa
* */
String qwsql = "select * from uf_jcl_emp_qwjgzgrz where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0";
List<Map<String, Object>> qwInfo = getYgxxDetailInfo(qwsql);
List<Map<String, Object>> qwColumns = getTableColumnsOfTableName("hr_certification");
List<String> listOfqwColumns = qwColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfqwColumns = getTableColumnsOfTableName("hr_certification");
log.error("getYgxxDetailInfo.qwInfo:{}", qwInfo);
log.error("getYgxxDetailInfo.listOfqwColumns:{}", listOfqwColumns);
for (Map<String, Object> map : qwInfo) {
@ -590,10 +560,7 @@ public class SyncOrganizationPersonInfo implements EsbServerlessRpcRemoteInterfa
* */
String gzsql = "select * from uf_jcl_emp_gzll where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0";
List<Map<String, Object>> gzllInfo = getYgxxDetailInfo(gzsql);
List<Map<String, Object>> gzllColumns = getTableColumnsOfTableName("hr_employment_record");
List<String> listOfgzllColumns = gzllColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfgzllColumns = getTableColumnsOfTableName("hr_employment_record");
log.error("getYgxxDetailInfo.gzllInfo:{}", gzllInfo);
log.error("getYgxxDetailInfo.listOfgzllColumns:{}", listOfgzllColumns);
for (Map<String, Object> map : gzllInfo) {
@ -624,10 +591,7 @@ public class SyncOrganizationPersonInfo implements EsbServerlessRpcRemoteInterfa
deleteDetailData(sql);
String jysql = "select * from uf_jcl_emp_jyjl where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0";
List<Map<String, Object>> jyjlInfo = getYgxxDetailInfo(jysql);
List<Map<String, Object>> jyjlColumns = getTableColumnsOfTableName("hr_education");
List<String> listOfjyjlColumns = jyjlColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfjyjlColumns = getTableColumnsOfTableName("hr_education");
log.error("getYgxxDetailInfo.jyjlInfo0172:{}", jyjlInfo);
log.error("getYgxxDetailInfo.listOfjyjlColumns:{}", listOfjyjlColumns);
for (Map<String, Object> map : jyjlInfo) {
@ -658,12 +622,8 @@ public class SyncOrganizationPersonInfo implements EsbServerlessRpcRemoteInterfa
deleteDetailData(sql);
String jtxxsql = "select * from uf_jcl_emp_jtxx where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0";
List<Map<String, Object>> jtxxInfo = getYgxxDetailInfo(jtxxsql);
List<Map<String, Object>> jtxxColumns = getTableColumnsOfTableName("hr_family");
List<String> listOfjtxxColumns = jtxxColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfjtxxColumns = getTableColumnsOfTableName("hr_family");
log.error("getYgxxDetailInfo.jtxxInfo:{}", jtxxInfo);
log.error("getYgxxDetailInfo.jtxxColumns:{}", jtxxColumns);
for (Map<String, Object> map : jtxxInfo) {
Map<String, Object> jtxxInfo_new = new HashMap<>();
for (String key : listOfjtxxColumns) {
@ -692,10 +652,7 @@ public class SyncOrganizationPersonInfo implements EsbServerlessRpcRemoteInterfa
deleteDetailData(sql);
String bzsql = "select * from uf_jcl_emp_bzyjl where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0";
List<Map<String, Object>> bzInfo = getYgxxDetailInfo(bzsql);
List<Map<String, Object>> bzColumns = getTableColumnsOfTableName("hr_rewards_before");
List<String> listOfbzColumns = bzColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfbzColumns = getTableColumnsOfTableName("hr_rewards_before");
log.error("getYgxxDetailInfo.bzInfo:{}", bzInfo);
log.error("getYgxxDetailInfo.listOfbzColumns:{}", listOfbzColumns);
for (Map<String, Object> map : bzInfo) {
@ -726,10 +683,7 @@ public class SyncOrganizationPersonInfo implements EsbServerlessRpcRemoteInterfa
deleteDetailData(sql);
String pxsql = "select * from uf_jcl_emp_pxjl where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0";
List<Map<String, Object>> pxInfo = getYgxxDetailInfo(pxsql);
List<Map<String, Object>> pxColumns = getTableColumnsOfTableName("hr_train");
List<String> listOfpxColumns = pxColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfpxColumns = getTableColumnsOfTableName("hr_train");
log.error("getYgxxDetailInfo.pxInfo:{}", pxInfo);
log.error("getYgxxDetailInfo.listOfpxColumns:{}", listOfpxColumns);
for (Map<String, Object> map : pxInfo) {
@ -760,10 +714,7 @@ public class SyncOrganizationPersonInfo implements EsbServerlessRpcRemoteInterfa
deleteDetailData(sql);
String yysql = "select * from uf_jcl_emp_yynl where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0";
List<Map<String, Object>> yyInfo = getYgxxDetailInfo(yysql);
List<Map<String, Object>> yyColumns = getTableColumnsOfTableName("hr_language");
List<String> listOfyyColumns = yyColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfyyColumns = getTableColumnsOfTableName("hr_language");
log.error("getYgxxDetailInfo.yyInfo:{}", yyInfo);
log.error("getYgxxDetailInfo.listOfyyColumns:{}", listOfyyColumns);
for (Map<String, Object> map : yyInfo) {
@ -794,10 +745,7 @@ public class SyncOrganizationPersonInfo implements EsbServerlessRpcRemoteInterfa
deleteDetailData(sql);
String qwsql = "select * from uf_jcl_emp_qwjgzgrz where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0";
List<Map<String, Object>> qwInfo = getYgxxDetailInfo(qwsql);
List<Map<String, Object>> qwColumns = getTableColumnsOfTableName("hr_certification");
List<String> listOfqwColumns = qwColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfqwColumns = getTableColumnsOfTableName("hr_certification");
log.error("getYgxxDetailInfo.qwInfo:{}", qwInfo);
log.error("getYgxxDetailInfo.listOfqwColumns:{}", listOfqwColumns);
for (Map<String, Object> map : qwInfo) {
@ -849,10 +797,7 @@ public class SyncOrganizationPersonInfo implements EsbServerlessRpcRemoteInterfa
//deleteDetailData(sql);
String gzsql = "select * from uf_jcl_emp_gzll where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0";
List<Map<String, Object>> gzllInfo = getYgxxDetailInfo(gzsql);
List<Map<String, Object>> gzllColumns = getTableColumnsOfTableName("hr_employment_record");
List<String> listOfgzllColumns = gzllColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfgzllColumns = getTableColumnsOfTableName("hr_employment_record");
log.error("updateAllYgxxDetailInfo.gzllInfo:{}", gzllInfo);
log.error("updateAllYgxxDetailInfo.listOfgzllColumns:{}", listOfgzllColumns);
for (Map<String, Object> map : gzllInfo) {
@ -875,10 +820,7 @@ public class SyncOrganizationPersonInfo implements EsbServerlessRpcRemoteInterfa
* */
String jysql = "select * from uf_jcl_emp_jyjl where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0";
List<Map<String, Object>> jyjlInfo = getYgxxDetailInfo(jysql);
List<Map<String, Object>> jyjlColumns = getTableColumnsOfTableName("hr_education");
List<String> listOfjyjlColumns = jyjlColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfjyjlColumns = getTableColumnsOfTableName("hr_education");
log.error("updateAllYgxxDetailInfo.jyjlInfo:{}", jyjlInfo);
log.error("updateAllYgxxDetailInfo.listOfjyjlColumns:{}", listOfjyjlColumns);
for (Map<String, Object> map : jyjlInfo) {
@ -901,12 +843,8 @@ public class SyncOrganizationPersonInfo implements EsbServerlessRpcRemoteInterfa
* */
String jtxxsql = "select * from uf_jcl_emp_jtxx where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0";
List<Map<String, Object>> jtxxInfo = getYgxxDetailInfo(jtxxsql);
List<Map<String, Object>> jtxxColumns = getTableColumnsOfTableName("hr_family");
List<String> listOfjtxxColumns = jtxxColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfjtxxColumns = getTableColumnsOfTableName("hr_family");
log.error("updateAllYgxxDetailInfo.jtxxInfo:{}", jtxxInfo);
log.error("updateAllYgxxDetailInfo.jtxxColumns:{}", jtxxColumns);
for (Map<String, Object> map : jtxxInfo) {
Map<String, Object> jtxxInfo_new = new HashMap<>();
for (String key : listOfjtxxColumns) {
@ -927,10 +865,7 @@ public class SyncOrganizationPersonInfo implements EsbServerlessRpcRemoteInterfa
* */
String bzsql = "select * from uf_jcl_emp_bzyjl where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0";
List<Map<String, Object>> bzInfo = getYgxxDetailInfo(bzsql);
List<Map<String, Object>> bzColumns = getTableColumnsOfTableName("hr_rewards_before");
List<String> listOfbzColumns = bzColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfbzColumns = getTableColumnsOfTableName("hr_rewards_before");
log.error("updateAllYgxxDetailInfo.bzInfo:{}", bzInfo);
log.error("updateAllYgxxDetailInfo.listOfbzColumns:{}", listOfbzColumns);
for (Map<String, Object> map : bzInfo) {
@ -953,10 +888,7 @@ public class SyncOrganizationPersonInfo implements EsbServerlessRpcRemoteInterfa
* */
String pxsql = "select * from uf_jcl_emp_pxjl where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0";
List<Map<String, Object>> pxInfo = getYgxxDetailInfo(pxsql);
List<Map<String, Object>> pxColumns = getTableColumnsOfTableName("hr_train");
List<String> listOfpxColumns = pxColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfpxColumns = getTableColumnsOfTableName("hr_train");
log.error("updateAllYgxxDetailInfo.pxInfo:{}", pxInfo);
log.error("updateAllYgxxDetailInfo.listOfpxColumns:{}", listOfpxColumns);
for (Map<String, Object> map : pxInfo) {
@ -979,10 +911,7 @@ public class SyncOrganizationPersonInfo implements EsbServerlessRpcRemoteInterfa
* */
String yysql = "select * from uf_jcl_emp_yynl where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0";
List<Map<String, Object>> yyInfo = getYgxxDetailInfo(yysql);
List<Map<String, Object>> yyColumns = getTableColumnsOfTableName("hr_language");
List<String> listOfyyColumns = yyColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfyyColumns = getTableColumnsOfTableName("hr_language");
log.error("updateAllYgxxDetailInfo.yyInfo:{}", yyInfo);
log.error("updateAllYgxxDetailInfo.listOfyyColumns:{}", listOfyyColumns);
for (Map<String, Object> map : yyInfo) {
@ -1005,10 +934,7 @@ public class SyncOrganizationPersonInfo implements EsbServerlessRpcRemoteInterfa
* */
String qwsql = "select * from uf_jcl_emp_qwjgzgrz where FORM_DATA_ID = '" + ygxxid + "' and delete_type=0";
List<Map<String, Object>> qwInfo = getYgxxDetailInfo(qwsql);
List<Map<String, Object>> qwColumns = getTableColumnsOfTableName("hr_certification");
List<String> listOfqwColumns = qwColumns.stream()
.map(map -> map.get("column_name").toString())
.collect(Collectors.toList());
Set<String> listOfqwColumns = getTableColumnsOfTableName("hr_certification");
log.error("updateAllYgxxDetailInfo.qwInfo:{}", qwInfo);
log.error("updateAllYgxxDetailInfo.listOfqwColumns:{}", listOfqwColumns);
for (Map<String, Object> map : qwInfo) {
@ -1235,15 +1161,23 @@ public class SyncOrganizationPersonInfo implements EsbServerlessRpcRemoteInterfa
return form_data;
}
public List<Map<String, Object>> getTableColumnsOfTableName(String tableName) {
public Set<String> getTableColumnsOfTableName(String tableName) {
//Oracle：SELECT COLUMN_NAME FROM ALL_TAB_COLUMNS WHERE TABLE_NAME ='" + tableName + "' ";
//databaseUtils.getDataSourceList()
String sql = "SELECT column_name FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_NAME = '" + tableName + "' ";
log.error("getTableColumnsOfTableName111.sql:{}", sql);
//String sql = "SELECT column_name FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_NAME = '" + tableName + "' ";
String sql = "SELECT * FROM " + tableName;
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);
return recordList;
return extractFieldNames(recordList);
}
public Set<String> extractFieldNames(List<Map<String, Object>> recordList) {
// 使用 Stream API 提取所有字段名
return recordList.stream()
.flatMap(record -> record.keySet().stream())
.collect(Collectors.toSet());
}
public static String getIgnoreCase(Map<String, Object> map, String key) {