Compare commits

...

5 Commits

1 changed files with 33 additions and 16 deletions

View File

@ -132,21 +132,38 @@ public class DeptServiceImpl implements DeptService {
reqVO.setParentId(DeptIdEnum.ROOT.getId()); reqVO.setParentId(DeptIdEnum.ROOT.getId());
} }
validateForCreateOrUpdate(reqVO.getId(), reqVO.getParentId(), reqVO.getName()); validateForCreateOrUpdate(reqVO.getId(), reqVO.getParentId(), reqVO.getName());
// 更新部门 // // 更新部门
DeptDO updateObj = DeptConvert.INSTANCE.convert(reqVO); // DeptDO updateObj = DeptConvert.INSTANCE.convert(reqVO);
if (DeptIdEnum.ROOT.getId().equals(updateObj.getParentId())) { // if (DeptIdEnum.ROOT.getId().equals(updateObj.getParentId())) {
updateObj.setParentOrganizationIds(updateObj.getId() + ""); // updateObj.setParentOrganizationIds(updateObj.getId() + "");
updateObj.setParentOrganizationName(updateObj.getName()); // updateObj.setParentOrganizationName(updateObj.getName());
} else { // } else {
DeptDO parent = deptMapper.selectById(reqVO.getParentId()); // DeptDO parent = deptMapper.selectById(reqVO.getParentId());
updateObj.setParentOrganizationIds(parent.getParentOrganizationIds() + "," + updateObj.getId()); // updateObj.setParentOrganizationIds(parent.getParentOrganizationIds() + "," + updateObj.getId());
updateObj.setParentOrganizationName(parent.getParentOrganizationName() + ">" + updateObj.getName()); // updateObj.setParentOrganizationName(parent.getParentOrganizationName() + ">" + updateObj.getName());
} // }
deptMapper.updateById(updateObj); DeptDO deptDO = deptMapper.selectById(reqVO.getId());
List<DeptDO> deptDOS = deptMapper.selectListDeep(Wrappers.<DeptDO>lambdaQuery().like(DeptDO::getParentOrganizationIds, reqVO.getId()));
deptDOS.forEach(x -> {
x.setParentOrganizationName(x.getParentOrganizationName().replace(deptDO.getName(), reqVO.getName()));
});
deptMapper.updateBatch(deptDOS,deptDOS.size());
// deptMapper.updateById(updateObj);
// 发送刷新消息 // 发送刷新消息
deptProducer.sendDeptRefreshMessage(); deptProducer.sendDeptRefreshMessage();
} }
public static void main(String[] args) {
String words = "创盈云>测试删除1";
System.out.println("原始字符串是'" + words + "'");
System.out.println("replace(\"r's\",\"is\")结果:" + words.replace("测试删除1", "测试删除"));
}
@Override @Override
public void deleteDept(Long id) { public void deleteDept(Long id) {
// 校验是否存在 // 校验是否存在
@ -322,7 +339,7 @@ public class DeptServiceImpl implements DeptService {
private static List<DeptDO> deptDOS4 = new ArrayList<>(); private static List<DeptDO> deptDOS4 = new ArrayList<>();
@Override @Override
public void batchImport(MultipartFile file){ public void batchImport(MultipartFile file) {
try { try {
List<BatchImportVO> deptList = ExcelUtils.read(file, BatchImportVO.class); List<BatchImportVO> deptList = ExcelUtils.read(file, BatchImportVO.class);
@ -341,7 +358,7 @@ public class DeptServiceImpl implements DeptService {
deptDO1.setCharacteristic(batchImportVO1.getCharacteristic()); deptDO1.setCharacteristic(batchImportVO1.getCharacteristic());
deptMapper.insert(deptDO1); deptMapper.insert(deptDO1);
deptDO1.setParentOrganizationIds(deptDO1.getId().toString()); deptDO1.setParentOrganizationIds(deptDO1.getId().toString());
deptMapper.update(deptDO1,Wrappers.<DeptDO>lambdaUpdate().eq(DeptDO::getId,deptDO1.getId())); deptMapper.update(deptDO1, Wrappers.<DeptDO>lambdaUpdate().eq(DeptDO::getId, deptDO1.getId()));
// 装入层级2 // 装入层级2
for (BatchImportVO batchImportVO : batchImportVOS2) { for (BatchImportVO batchImportVO : batchImportVOS2) {
DeptDO deptDO2 = new DeptDO(); DeptDO deptDO2 = new DeptDO();
@ -351,7 +368,7 @@ public class DeptServiceImpl implements DeptService {
deptDO2.setCharacteristic(batchImportVO.getCharacteristic()); deptDO2.setCharacteristic(batchImportVO.getCharacteristic());
deptMapper.insert(deptDO2); deptMapper.insert(deptDO2);
deptDO2.setParentOrganizationIds(deptDO1.getParentOrganizationIds() + ">" + deptDO2.getId()); deptDO2.setParentOrganizationIds(deptDO1.getParentOrganizationIds() + ">" + deptDO2.getId());
deptMapper.update(deptDO2,Wrappers.<DeptDO>lambdaUpdate().eq(DeptDO::getId,deptDO2.getId())); deptMapper.update(deptDO2, Wrappers.<DeptDO>lambdaUpdate().eq(DeptDO::getId, deptDO2.getId()));
deptDOS2.add(deptDO2); deptDOS2.add(deptDO2);
} }
// 装入层级3 // 装入层级3
@ -365,7 +382,7 @@ public class DeptServiceImpl implements DeptService {
deptDO3.setCharacteristic(batchImportVO.getCharacteristic()); deptDO3.setCharacteristic(batchImportVO.getCharacteristic());
deptMapper.insert(deptDO3); deptMapper.insert(deptDO3);
deptDO3.setParentOrganizationIds(deptDO.getParentOrganizationIds() + ">" + deptDO3.getId()); deptDO3.setParentOrganizationIds(deptDO.getParentOrganizationIds() + ">" + deptDO3.getId());
deptMapper.update(deptDO3,Wrappers.<DeptDO>lambdaUpdate().eq(DeptDO::getId,deptDO3.getId())); deptMapper.update(deptDO3, Wrappers.<DeptDO>lambdaUpdate().eq(DeptDO::getId, deptDO3.getId()));
deptDOS3.add(deptDO3); deptDOS3.add(deptDO3);
} }
// 装入层级4 // 装入层级4
@ -378,7 +395,7 @@ public class DeptServiceImpl implements DeptService {
deptDO4.setParentOrganizationName(deptDO.getParentOrganizationName() + ">" + batchImportVO.getDepName()); deptDO4.setParentOrganizationName(deptDO.getParentOrganizationName() + ">" + batchImportVO.getDepName());
deptMapper.insert(deptDO4); deptMapper.insert(deptDO4);
deptDO4.setParentOrganizationIds(deptDO.getParentOrganizationIds() + ">" + deptDO4.getId()); deptDO4.setParentOrganizationIds(deptDO.getParentOrganizationIds() + ">" + deptDO4.getId());
deptMapper.update(deptDO4,Wrappers.<DeptDO>lambdaUpdate().eq(DeptDO::getId,deptDO4.getId())); deptMapper.update(deptDO4, Wrappers.<DeptDO>lambdaUpdate().eq(DeptDO::getId, deptDO4.getId()));
deptDOS4.add(deptDO4); deptDOS4.add(deptDO4);
} }
} catch (IOException e) { } catch (IOException e) {