基于Spring Boot 2的Roses开源项目Guns核心支撑层设计源码

package cn.stylefeng.roses.kernel.sys.modular.user.service.impl; import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.util.ObjectUtil; import cn.hutool.extra.spring.SpringUtil; import cn.stylefeng.roses.kernel.auth.api.TenantCodeGetApi; import cn.stylefeng.roses.kernel.auth.api.context.LoginContext; import cn.stylefeng.roses.kernel.auth.api.password.PasswordStoredEncryptApi; import cn.stylefeng.roses.kernel.auth.api.pojo.login.LoginUser; import cn.stylefeng.roses.kernel.auth.api.pojo.password.SaltedEncryptResult; import cn.stylefeng.roses.kernel.cache.api.CacheOperatorApi; import cn.stylefeng.roses.kernel.db.api.factory.PageFactory; import cn.stylefeng.roses.kernel.db.api.factory.PageResultFactory; import cn.stylefeng.roses.kernel.db.api.pojo.entity.BaseEntity; import cn.stylefeng.roses.kernel.db.api.pojo.page.PageResult; import cn.stylefeng.roses.kernel.db.mp.tenant.holder.TenantIdHolder; import cn.stylefeng.roses.kernel.db.mp.tenant.holder.TenantSwitchHolder; import cn.stylefeng.roses.kernel.dsctn.api.context.DataSourceContext; import cn.stylefeng.roses.kernel.file.api.FileInfoApi; import cn.stylefeng.roses.kernel.file.api.constants.FileConstants; import cn.stylefeng.roses.kernel.log.api.util.BusinessLogUtil; import cn.stylefeng.roses.kernel.rule.enums.DbTypeEnum; import cn.stylefeng.roses.kernel.rule.enums.YesOrNotEnum; import cn.stylefeng.roses.kernel.rule.exception.base.ServiceException; import cn.stylefeng.roses.kernel.rule.pojo.dict.SimpleDict; import cn.stylefeng.roses.kernel.rule.util.SortUtils; import cn.stylefeng.roses.kernel.sys.api.SecurityConfigService; import cn.stylefeng.roses.kernel.sys.api.callback.RemoveUserCallbackApi; import cn.stylefeng.roses.kernel.sys.api.constants.SysConstants; import cn.stylefeng.roses.kernel.sys.api.enums.user.UserStatusEnum; import cn.stylefeng.roses.kernel.sys.api.expander.SysConfigExpander; import cn.stylefeng.roses.kernel.sys.api.pojo.user.*; import cn.stylefeng.roses.kernel.sys.modular.user.entity.SysUser; import cn.stylefeng.roses.kernel.sys.modular.user.enums.SysUserExceptionEnum; import cn.stylefeng.roses.kernel.sys.modular.user.factory.SysUserCreateFactory; import cn.stylefeng.roses.kernel.sys.modular.user.factory.UserDataScopeFactory; import cn.stylefeng.roses.kernel.sys.modular.user.mapper.SysUserMapper; import cn.stylefeng.roses.kernel.sys.modular.user.pojo.request.SysUserRequest; import cn.stylefeng.roses.kernel.sys.modular.user.pojo.response.PersonalInfo; import cn.stylefeng.roses.kernel.sys.modular.user.pojo.response.SysUserCertificateResponse; import cn.stylefeng.roses.kernel.sys.modular.user.service.SysUserCertificateService; import cn.stylefeng.roses.kernel.sys.modular.user.service.SysUserOrgService; import cn.stylefeng.roses.kernel.sys.modular.user.service.SysUserRoleService; import cn.stylefeng.roses.kernel.sys.modular.user.service.SysUserService; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import java.util.*; import java.util.stream.Collectors; /** * 系统用户业务实现层 * * @author fengshuonan * @date 2023/06/10 21:26 */ @Service public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> implements SysUserService { @Resource private PasswordStoredEncryptApi passwordStoredEncryptApi; @Resource private SysUserOrgService sysUserOrgService; @Resource private SysUserRoleService sysUserRoleService; @Resource private FileInfoApi fileInfoApi; @Resource private TenantCodeGetApi tenantCodeGetApi; @Resource(name = "loginErrorCountCacheApi") private CacheOperatorApi<Integer> loginErrorCountCacheApi; @Resource private SecurityConfigService securityConfigService; @Resource private SysUserCertificateService sysUserCertificateService; @Override @Transactional(rollbackFor = Exception.class) public void add(SysUserRequest sysUserRequest) { SysUser sysUser = new SysUser(); BeanUtil.copyProperties(sysUserRequest, sysUser); // 校验密码是否符合规则 String password = sysUserRequest.getPassword().trim(); securityConfigService.validatePasswordSecurityRule(false, password); // 将密码加密存储到库中 SaltedEncryptResult saltedEncryptResult = passwordStoredEncryptApi.encryptWithSalt(password); sysUser.setPassword(saltedEncryptResult.getEncryptPassword()); sysUser.setPasswordSalt(saltedEncryptResult.getPasswordSalt()); // 设置用户默认头像 sysUser.setAvatar(FileConstants.DEFAULT_AVATAR_FILE_ID); this.save(sysUser); // 记录一个密码修改记录 securityConfigService.recordPasswordEditLog(sysUser.getUserId(), saltedEncryptResult.getEncryptPassword(), saltedEncryptResult.getPasswordSalt()); // 更新用户的任职信息 sysUserOrgService.updateUserOrg(sysUser.getUserId(), sysUserRequest.getUserOrgList()); // 添加用户一个默认角色 sysUserRoleService.bindUserDefaultRole(sysUser.getUserId()); // 增加用户证书的信息 sysUserCertificateService.updateUserCertificate(sysUser.getUserId(), sysUserRequest.getUserCertificateList()); // 记录日志 BusinessLogUtil.setLogTitle("新增用户，用户账号：" + sysUser.getAccount()); BusinessLogUtil.addContent("新增用户账号信息：", sysUser.getAccount()); BusinessLogUtil.addContent("用户详细信息如下：\n", sysUser); } @Override @Transactional(rollbackFor = Exception.class) public void del(SysUserRequest sysUserRequest) { SysUser sysUser = this.querySysUser(sysUserRequest); // 不能删除超级管理员 if (YesOrNotEnum.Y.getCode().equals(sysUser.getSuperAdminFlag())) { throw new ServiceException(SysUserExceptionEnum.USER_CAN_NOT_DELETE_ADMIN); } // 删除用户的业务操作 this.baseRemoveUser(CollectionUtil.set(false, sysUser.getUserId())); // 记录日志 BusinessLogUtil.setLogTitle("删除用户，用户账号：" + sysUser.getAccount()); BusinessLogUtil.addContent("新增用户账号信息：", sysUser.getAccount()); BusinessLogUtil.addContent("用户详细信息：\n", sysUser); } @Override public void batchDel(SysUserRequest sysUserRequest) { // 判断被删除用户是否有管理员 Set<Long> userIdList = sysUserRequest.getUserIdList(); LambdaQueryWrapper<SysUser> sysUserLambdaQueryWrapper = new LambdaQueryWrapper<>(); sysUserLambdaQueryWrapper.in(SysUser::getUserId, userIdList); sysUserLambdaQueryWrapper.eq(SysUser::getSuperAdminFlag, YesOrNotEnum.Y.getCode()); long adminCount = this.count(sysUserLambdaQueryWrapper); if (adminCount > 0) { throw new ServiceException(SysUserExceptionEnum.USER_CAN_NOT_DELETE_ADMIN); } // 删除用户的业务操作 this.baseRemoveUser(userIdList); // 记录日志 BusinessLogUtil.setLogTitle("批量删除用户"); BusinessLogUtil.addContent("用户id集合为：\n", userIdList); } @Override public void edit(SysUserRequest sysUserRequest) { SysUser sysUser = this.querySysUser(sysUserRequest); BusinessLogUtil.setLogTitle("更新用户信息，用户账号：" + sysUser.getAccount()); BusinessLogUtil.addContent("原始用户信息如下：\n", sysUser); // 不能修改admin账号的超级管理员标识和账号 if (SysConstants.ADMIN_US