ak/zn-cloud
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

优化用户导入功能，支持批量岗位关联

Browse Source 
优化了用户导入服务，新增了在创建或更新用户时批量设置岗位关联的能力。现在会在用户导入时，将用户岗位信息批量插入到`user_post`关联表中，提升了效率并减少了数据库操作的次数。
This commit is contained in:
furongxin 2024-09-21 12:48:47 +08:00
parent 5117cf4115
commit 3c21758abb
1 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/user/AdminUserServiceImpl.java
View File

@ -593,6 +593,8 @@ public class AdminUserServiceImpl implements AdminUserService {
throw exception(USER_IMPORT_LIST_IS_EMPTY); throw exception(USER_IMPORT_LIST_IS_EMPTY);
} }
UserImportRespVO respVO = UserImportRespVO.builder().createUsernames(new ArrayList<>()).updateUsernames(new ArrayList<>()).failureUsernames(new LinkedHashMap<>()).build(); UserImportRespVO respVO = UserImportRespVO.builder().createUsernames(new ArrayList<>()).updateUsernames(new ArrayList<>()).failureUsernames(new LinkedHashMap<>()).build();
List<UserPostDO> userPostDOS = new ArrayList<>();
importUsers.forEach(importUser -> { importUsers.forEach(importUser -> {
//校验，判断是否有不符合的原因 //校验，判断是否有不符合的原因
try { try {
@ -635,6 +637,10 @@ public class AdminUserServiceImpl implements AdminUserService {
if (existUser == null) { if (existUser == null) {
userMapper.insert(updateUser.setPassword(encodePassword(userInitPassword))); // 设置默认密码 userMapper.insert(updateUser.setPassword(encodePassword(userInitPassword))); // 设置默认密码
// 设置 user_post关联表
userPostDOS.addAll(convertList(updateUser.getPostIds(),
postId -> new UserPostDO().setUserId(updateUser.getId()).setPostId(postId)));
respVO.getCreateUsernames().add(importUser.getNickname()); respVO.getCreateUsernames().add(importUser.getNickname());
return; return;
} }
@ -648,8 +654,15 @@ public class AdminUserServiceImpl implements AdminUserService {
updateUser.setId(existUser.getId()); updateUser.setId(existUser.getId());
userMapper.updateById(updateUser); userMapper.updateById(updateUser);
// 更新用户岗位关联表
updateUserPost(new UserSaveReqVO().setId(existUser.getId()), new AdminUserDO().setPostIds(updateUser.getPostIds()));
respVO.getUpdateUsernames().add(importUser.getNickname()); respVO.getUpdateUsernames().add(importUser.getNickname());
}); });
// 插入user_post
if (CollectionUtil.isNotEmpty(userPostDOS)) {
userPostMapper.insertBatch(userPostDOS);
}
return respVO; return respVO;
} }