一、代码
@PostMapping("/import")@Operation(summary = "导入用户")@Parameters({@Parameter(name = "file", description = "Excel 文件", required = true),@Parameter(name = "updateSupport", description = "是否支持更新,默认为 false", example = "true")})@PreAuthorize("@ss.hasPermission('system:user:import')")public CommonResult<UserImportRespVO> importExcel(@RequestParam("file") MultipartFile file,@RequestParam(value = "updateSupport", required = false, defaultValue = "false") Boolean updateSupport) throws Exception {List<UserImportExcelVO> list = ExcelUtils.read(file, UserImportExcelVO.class);return success(userService.importUserList(list, updateSupport));}
@Override@Transactional(rollbackFor = Exception.class) // 添加事务,异常则回滚所有导入public UserImportRespVO importUserList(List<UserImportExcelVO> importUsers, boolean isUpdateSupport) {// 1.1 参数校验if (CollUtil.isEmpty(importUsers)) {throw exception(USER_IMPORT_LIST_IS_EMPTY);}// 1.2 初始化密码不能为空String initPassword = configApi.getConfigValueByKey(USER_INIT_PASSWORD_KEY).getCheckedData();if (StrUtil.isEmpty(initPassword)) {throw exception(USER_IMPORT_INIT_PASSWORD);}// 2. 遍历,逐个创建 or 更新UserImportRespVO respVO = UserImportRespVO.builder().createUsernames(new ArrayList<>()).updateUsernames(new ArrayList<>()).failureUsernames(new LinkedHashMap<>()).build();importUsers.forEach(importUser -> {// 2.1.1 校验字段是否符合要求try {ValidationUtils.validate(BeanUtils.toBean(importUser, UserSaveReqVO.class).setPassword(initPassword));} catch (ConstraintViolationException ex){respVO.getFailureUsernames().put(importUser.getUsername(), ex.getMessage());return;}// 2.1.2 校验,判断是否有不符合的原因try {validateUserForCreateOrUpdate(null, null, importUser.getMobile(), importUser.getEmail(),importUser.getDeptId(), null);} catch (ServiceException ex) {respVO.getFailureUsernames().put(importUser.getUsername(), ex.getMessage());return;}// 2.2.1 判断如果不存在,在进行插入AdminUserDO existUser = userMapper.selectByUsername(importUser.getUsername());if (existUser == null) {userMapper.insert(BeanUtils.toBean(importUser, AdminUserDO.class).setPassword(encodePassword(initPassword)).setPostIds(new HashSet<>())); // 设置默认密码及空岗位编号数组respVO.getCreateUsernames().add(importUser.getUsername());return;}// 2.2.2 如果存在,判断是否允许更新if (!isUpdateSupport) {respVO.getFailureUsernames().put(importUser.getUsername(), USER_USERNAME_EXISTS.getMsg());return;}AdminUserDO updateUser = BeanUtils.toBean(importUser, AdminUserDO.class);updateUser.setId(existUser.getId());userMapper.updateById(updateUser);respVO.getUpdateUsernames().add(importUser.getUsername());});return respVO;}
二、密码判断
✅ 1.
configApi.getConfigValueByKey(...)
这是调用 配置中心 API(
configApi
)的方法,去根据配置项的 key 获取对应的值。
USER_INIT_PASSWORD_KEY
是常量,通常定义为字符串"sys.user.init-password"
(或者类似的 key)。意思是:去配置系统里找“用户初始密码”的配置。
✅ 2.
.getCheckedData()
这是对配置结果的 封装处理,用于确保该配置值是存在并有效的。
如果配置项未设置或值为空,它可能会抛出异常(提示配置缺失),避免后面使用 null 值。
所以这是一个 带校验的安全获取配置值方式。
三、校验数据 (加注解)
当执行 validate(userSaveReqVO)
时,如果 username
是空,或者 email
格式不对,或者 password
长度不合适,都会被检测出来,然后抛出异常。
字段名 | 校验规则 | 说明 |
---|---|---|
username | @NotBlank 、@Pattern 、@Size(4~30) | 用户账号不能为空,且只能是字母数字,长度4~30 |
nickname | @Size(max=30) | 用户昵称最长30个字符 |
email | @Email 、@Size(max=50) | 必须是合法邮箱,最长50字符 |
mobile | @Mobile (自定义手机校验注解) | 手机号格式校验 |
password | @Length(4~16) + @AssertTrue(isPasswordValid) | 新增用户时密码不能为空且长度4~16 |