cq_anquan
/
safety-eval-service
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

PaperBasicInfo

dev-tmp1
luotaiqian 2026-08-21 15:58:40 +08:00
parent ff1e0ae8fd
commit b4043e8238
2 changed files with 105 additions and 78 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

161
safety-eval-app/src/main/java/org/qinan/safetyeval/app/support/OrgPersonnelExcelImporter.java
View File

@ -56,7 +56,7 @@ import java.util.stream.Collectors;
* <p>
* 模板包含两个 sheet：sheet1「专职人员基础信息」、sheet2「专职人员能力信息」，
* 解析后按 身份证号（为空时按姓名） 将能力信息关联到基础信息行；
* 再批量校验部门/岗位名称并回填ID -> 校验账号重复并收集异常 -> 逐行落库。
* 再批量校验部门/岗位名称并回填ID（部门或部门下岗位不存在时自动新增） -> 校验账号重复并收集异常 -> 逐行落库。
* </p>
*
* @author safety-eval
@ -769,12 +769,12 @@ public class OrgPersonnelExcelImporter {
}
/**
* 批量校验部门层级是否在当前机构下存在且层级关系正确。
* 批量校验部门层级是否在当前机构下存在且层级关系正确，不存在的部门自动新增。
* <p>
* 三级部门 -> 二级部门 -> 一级部门 逐级校验 parentId：
* <ul>
* <li>名称在机构下不存在的部门视为异常；</li>
* <li>任一相邻层级的 parentId 关系不匹配视为异常；</li>
* <li>名称在机构下不存在（或上级部门下不存在同名子部门）-> 自动新增该部门；</li>
* <li>一级部门名称在机构下重复 -> 视为异常（无法确定挂载位置）；</li>
* <li>全部校验通过后，取最底层（最深一级）不为空的部门 ID 作为 deptId 回填。</li>
* </ul>
*/
@ -796,31 +796,53 @@ public class OrgPersonnelExcelImporter {
Map<String, List<OrgDepartmentEntity>> nameMapList =
orgDepartmentList.stream().collect(Collectors.groupingBy(OrgDepartmentEntity::getDeptName));
for (OrgPersonnelImportRow row : rows) {
Pair<Boolean, OrgDepartmentEntity> l1 = getL1(errors, row, nameMapList);
Pair<Boolean, OrgDepartmentEntity> l1 = getL1(errors, row, nameMapList, orgId);
if (!l1.getKey()) {
continue;
}
OrgDepartmentEntity l1Dept = l1.getValue();
Pair<Boolean, OrgDepartmentEntity> l2 = getL2(errors, row, nameMapList, l1Dept);
Pair<Boolean, OrgDepartmentEntity> l2 = getL2(row, nameMapList, l1Dept, orgId);
if (!l2.getKey() || l2.getValue() == null) {
continue;
}
getL3(errors, row, nameMapList, l2.getValue());
getL3(row, nameMapList, l2.getValue(), orgId);
}
}
/**
* 新增部门并注册到名称索引（nameMapList），保证同一文件中同层级同名部门仅创建一次。
*
* @param errors errors
* @param row row
* @param nameMapList nameMapList
* @param l2Dept l2Dept
* @return Pair<Boolean, OrgDepartmentEntity> key 是否通过 true 通过 false 不通
* ；value （key =true ,value=null 说明没有二级部门）
* @param orgId 机构ID
* @param parentId 上级部门ID（一级部门传 0）
* @param deptName 部门名称
* @param nameMapList 部门名称索引（key: 部门名称）
* @return 新增后的部门实体（含生成的ID）
*/
private Pair<Boolean, OrgDepartmentEntity> getL3(List<OrgPersonnelImportErrorCO> errors, OrgPersonnelImportRow row
, Map<String, List<OrgDepartmentEntity>> nameMapList, OrgDepartmentEntity l2Dept) {
private OrgDepartmentEntity createDept(Long orgId, Long parentId, String deptName,
Map<String, List<OrgDepartmentEntity>> nameMapList) {
OrgDepartmentEntity entity = new OrgDepartmentEntity();
entity.setOrgId(orgId);
entity.setParentId(parentId);
entity.setDeptName(deptName);
OrgDepartmentEntity saved = orgDepartmentGateway.save(entity);
nameMapList.computeIfAbsent(deptName, k -> new ArrayList<>()).add(saved);
LOGGER.info("人员导入自动新增部门, orgId={}, parentId={}, deptName={}, deptId={}"
, orgId, parentId, deptName, saved.getId());
return saved;
}
/**
* 三级部门校验并回填：为空跳过；二级部门下不存在同名三级部门时自动新增。
*
* @param row 当前行
* @param nameMapList 部门名称索引（key: 部门名称）
* @param l2Dept 二级部门实体
* @param orgId 机构ID
* @return Pair<Boolean, OrgDepartmentEntity> key 是否通过；value 三级部门实体（无三级部门时为 null）
*/
private Pair<Boolean, OrgDepartmentEntity> getL3(OrgPersonnelImportRow row
, Map<String, List<OrgDepartmentEntity>> nameMapList, OrgDepartmentEntity l2Dept, Long orgId) {
String l3 = row.getBasic().getDeptNameLevel3();
if (StrUtil.isBlank(l3)) {
return Pair.of(true, null);
@ -828,14 +850,7 @@ public class OrgPersonnelExcelImporter {
// l3 部门查询
List<OrgDepartmentEntity> departmentEntities = nameMapList.get(l3);
if (CollectionUtils.isEmpty(departmentEntities)) {
errors.add(new OrgPersonnelImportErrorCO(row.getBasic().getRowIndex(), row.getBasic().getAccount(), row.getBasic().getUserName(),
ErrorCode.ORG_PERSONNEL_IMPORT_DEPT_L3_NOT_EXIST.getMessage()));
row.setValidateFail(true);
return Pair.of(false, null);
}
// 三级部门
if (!CollectionUtils.isEmpty(departmentEntities)) {
for (OrgDepartmentEntity departmentEntity : departmentEntities) {
if (departmentEntity.getDeptName().equals(l3)
&& departmentEntity.getParentId().compareTo(l2Dept.getId()) == 0) {
@ -843,25 +858,25 @@ public class OrgPersonnelExcelImporter {
return Pair.of(true, departmentEntity);
}
}
}
errors.add(new OrgPersonnelImportErrorCO(row.getBasic().getRowIndex(), row.getBasic().getAccount(), row.getBasic().getUserName(),
l2Dept.getDeptName() + "下"
+ ErrorCode.ORG_PERSONNEL_IMPORT_DEPT_L3_NOT_EXIST.getMessage()));
row.setValidateFail(true);
return Pair.of(false, null);
// 二级部门下不存在该三级部门 -> 自动新增
OrgDepartmentEntity created = createDept(orgId, l2Dept.getId(), l3, nameMapList);
row.setDeptId(created.getId());
return Pair.of(true, created);
}
/**
* 二级部门校验并回填：为空跳过；一级部门下不存在同名二级部门时自动新增。
*
* @param errors errors
* @param row row
* @param nameMapList nameMapList
* @param l1Dept l1Dept
* @return Pair<Boolean, OrgDepartmentEntity> key 是否通过 true 通过 false 不通
* ；value （key =true ,value=null 说明没有二级部门）
* @param row 当前行
* @param nameMapList 部门名称索引（key: 部门名称）
* @param l1Dept 一级部门实体
* @param orgId 机构ID
* @return Pair<Boolean, OrgDepartmentEntity> key 是否通过；value 二级部门实体（无二级部门时为 null）
*/
private Pair<Boolean, OrgDepartmentEntity> getL2(List<OrgPersonnelImportErrorCO> errors
, OrgPersonnelImportRow row, Map<String, List<OrgDepartmentEntity>> nameMapList, OrgDepartmentEntity l1Dept) {
private Pair<Boolean, OrgDepartmentEntity> getL2(OrgPersonnelImportRow row
, Map<String, List<OrgDepartmentEntity>> nameMapList, OrgDepartmentEntity l1Dept, Long orgId) {
String l2 = row.getBasic().getDeptNameLevel2();
if (StrUtil.isBlank(l2)) {
return Pair.of(true, null);
@ -869,14 +884,7 @@ public class OrgPersonnelExcelImporter {
// l2 部门查询
List<OrgDepartmentEntity> departmentEntities = nameMapList.get(l2);
if (CollectionUtils.isEmpty(departmentEntities)) {
errors.add(new OrgPersonnelImportErrorCO(row.getBasic().getRowIndex(), row.getBasic().getAccount(), row.getBasic().getUserName(),
ErrorCode.ORG_PERSONNEL_IMPORT_DEPT_L2_NOT_EXIST.getMessage()));
row.setValidateFail(true);
return Pair.of(false, null);
}
// 二级部门
if (!CollectionUtils.isEmpty(departmentEntities)) {
for (OrgDepartmentEntity departmentEntity : departmentEntities) {
if (departmentEntity.getDeptName().equals(l2)
&& departmentEntity.getParentId().compareTo(l1Dept.getId()) == 0) {
@ -884,22 +892,26 @@ public class OrgPersonnelExcelImporter {
return Pair.of(true, departmentEntity);
}
}
}
errors.add(new OrgPersonnelImportErrorCO(row.getBasic().getRowIndex(), row.getBasic().getAccount(), row.getBasic().getUserName(),
l1Dept.getDeptName() + "下" + ErrorCode.ORG_PERSONNEL_IMPORT_DEPT_L2_NOT_EXIST.getMessage()));
row.setValidateFail(true);
return Pair.of(false, null);
// 一级部门下不存在该二级部门 -> 自动新增
OrgDepartmentEntity created = createDept(orgId, l1Dept.getId(), l2, nameMapList);
row.setDeptId(created.getId());
return Pair.of(true, created);
}
/**
* 一级部门校验并回填：为空记录异常；机构下不存在同名部门时自动新增（parentId=0 为根）；
* 同名部门重复时记录异常（无法确定挂载位置）。
*
* @param errors errors
* @param row row
* @param nameMapList nameMapList
* @return Pair<Boolean, String> key 是否通过 true 通过 false 不通
* @param errors 异常收集列表
* @param row 当前行
* @param nameMapList 部门名称索引（key: 部门名称）
* @param orgId 机构ID
* @return Pair<Boolean, OrgDepartmentEntity> key 是否通过；value 一级部门实体
*/
private static Pair<Boolean, OrgDepartmentEntity> getL1(List<OrgPersonnelImportErrorCO> errors, OrgPersonnelImportRow row
, Map<String, List<OrgDepartmentEntity>> nameMapList) {
private Pair<Boolean, OrgDepartmentEntity> getL1(List<OrgPersonnelImportErrorCO> errors, OrgPersonnelImportRow row
, Map<String, List<OrgDepartmentEntity>> nameMapList, Long orgId) {
String l1 = row.getBasic().getDeptNameLevel1();
if (StrUtil.isBlank(l1)) {
errors.add(new OrgPersonnelImportErrorCO(row.getBasic().getRowIndex(), row.getBasic().getAccount(), row.getBasic().getUserName(),
@ -911,10 +923,10 @@ public class OrgPersonnelExcelImporter {
// l1 部门查询
List<OrgDepartmentEntity> departmentEntities = nameMapList.get(l1);
if (CollectionUtils.isEmpty(departmentEntities)) {
errors.add(new OrgPersonnelImportErrorCO(row.getBasic().getRowIndex(), row.getBasic().getAccount(), row.getBasic().getUserName(),
ErrorCode.ORG_PERSONNEL_IMPORT_DEPT_L1_NOT_EXIST.getMessage()));
row.setValidateFail(true);
return Pair.of(false, null);
// 机构下不存在该一级部门 -> 自动新增（根节点 parentId=0）
OrgDepartmentEntity created = createDept(orgId, 0L, l1, nameMapList);
row.setDeptId(created.getId());
return Pair.of(true, created);
}
// 一级部门重复
@ -935,8 +947,8 @@ public class OrgPersonnelExcelImporter {
}
/**
* 批量校验岗位名称在所属部门下是否存在（dept_id + org_id），校验通过的同时回填 postId；
* 岗位名称为空或部门下岗位不存在的行，记录异常并标记 validateFail。
* 批量校验岗位名称在所属部门下是否存在（dept_id + org_id）并回填 postId；
* 岗位名称为空的行记录异常并标记 validateFail；部门下岗位不存在时自动新增岗位。
*/
private void validateAndFillPosition(List<OrgPersonnelImportRow> rows, Long orgId, List<OrgPersonnelImportErrorCO> errors) {
Set<Long> deptIds = new HashSet<>();
@ -960,7 +972,7 @@ public class OrgPersonnelExcelImporter {
}
}
// 逐行校验：岗位名称为空或部门下岗位不存在 -> 记录异常并标记；校验通过则回填岗位ID
// 逐行校验：岗位名称为空 -> 记录异常并标记；部门下岗位不存在 -> 自动新增；校验通过则回填岗位ID
for (OrgPersonnelImportRow row : rows) {
String posName = trim(row.getBasic().getPositionName());
if (!StringUtils.hasText(posName)) {
@ -973,16 +985,33 @@ public class OrgPersonnelExcelImporter {
String key = row.getDeptId() + "|" + posName;
OrgPositionEntity pos = positionMap.get(key);
if (pos == null) {
errors.add(new OrgPersonnelImportErrorCO(row.getBasic().getRowIndex(), row.getBasic().getAccount(), row.getBasic().getUserName(),
ErrorCode.ORG_PERSONNEL_IMPORT_POSITION_NOT_FOUND.getMessage()
+ "：" + posName + "（部门:" + row.getDeptDisplayName() + "）"));
row.setValidateFail(true);
continue;
// 部门下岗位不存在 -> 自动新增并放入缓存（同文件同部门同岗位仅创建一次）
pos = createPosition(orgId, row.getDeptId(), posName);
positionMap.put(key, pos);
}
row.setPostId(pos.getId());
}
}
/**
* 新增部门下的岗位。
*
* @param orgId 机构ID
* @param deptId 部门ID
* @param positionName 岗位名称
* @return 新增后的岗位实体（含生成的ID）
*/
private OrgPositionEntity createPosition(Long orgId, Long deptId, String positionName) {
OrgPositionEntity entity = new OrgPositionEntity();
entity.setOrgId(orgId);
entity.setDeptId(deptId);
entity.setPositionName(positionName);
OrgPositionEntity saved = orgPositionGateway.save(entity);
LOGGER.info("人员导入自动新增岗位, orgId={}, deptId={}, positionName={}, postId={}"
, orgId, deptId, positionName, saved.getId());
return saved;
}
/**
* 批量校验 所学专业（major）与 系列/专业（seriesMajor）名称在基础学科专业对照表中是否存在
* （basic_discipline_major.professional_name），两个字段名称合并为一次 in 查询；

2
safety-eval-domain/src/main/java/org/qinan/safetyeval/domain/exception/ErrorCode.java
View File

@ -42,8 +42,6 @@ public enum ErrorCode {
ORG_PERSONNEL_IMPORT_DEPT_NOT_EXIST("01-05-013", "请填写部门名称"),
ORG_PERSONNEL_IMPORT_DEPT_L1_NOT_EXIST("01-05-014", "一级部门名称不存在"),
ORG_PERSONNEL_IMPORT_DEPT_L1_REPEAT("01-05-015", "一级部门名称查询到多个，请在部门目录去核验"),
ORG_PERSONNEL_IMPORT_DEPT_L2_NOT_EXIST("01-05-016", "二级部门名称不存在"),
ORG_PERSONNEL_IMPORT_DEPT_L3_NOT_EXIST("01-05-017", "三级部门名称不存在"),
// ---- 人员证书 ----
ORG_PERSONNEL_CERT_NOT_FOUND("01-06-001", "人员证书不存在"),