| | |
| | | package org.dromara.system.service.impl; |
| | | |
| | | import cn.hutool.core.collection.CollUtil; |
| | | import cn.hutool.core.convert.Convert; |
| | | import cn.hutool.core.util.ArrayUtil; |
| | | import cn.hutool.core.util.ObjectUtil; |
| | | import com.baomidou.mybatisplus.core.conditions.Wrapper; |
| | |
| | | import org.dromara.common.core.exception.ServiceException; |
| | | import org.dromara.common.core.service.UserService; |
| | | import org.dromara.common.core.utils.MapstructUtils; |
| | | import org.dromara.common.core.utils.SpringUtils; |
| | | import org.dromara.common.core.utils.StreamUtils; |
| | | import org.dromara.common.core.utils.StringUtils; |
| | | import org.dromara.common.mybatis.core.page.PageQuery; |
| | |
| | | import org.dromara.system.domain.SysUserPost; |
| | | import org.dromara.system.domain.SysUserRole; |
| | | import org.dromara.system.domain.bo.SysUserBo; |
| | | import org.dromara.system.domain.vo.SysPostVo; |
| | | import org.dromara.system.domain.vo.SysRoleVo; |
| | | import org.dromara.system.domain.vo.SysUserVo; |
| | | import org.dromara.system.domain.vo.*; |
| | | import org.dromara.system.mapper.*; |
| | | import org.dromara.system.service.ISysUserService; |
| | | import org.springframework.cache.annotation.Cacheable; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | |
| | | import java.util.ArrayList; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | |
| | |
| | | * @return 用户信息集合信息 |
| | | */ |
| | | @Override |
| | | public List<SysUserVo> selectUserList(SysUserBo user) { |
| | | return baseMapper.selectUserList(this.buildQueryWrapper(user)); |
| | | public List<SysUserExportVo> selectUserExportList(SysUserBo user) { |
| | | return baseMapper.selectUserExportList(this.buildQueryWrapper(user)); |
| | | } |
| | | |
| | | private Wrapper<SysUser> buildQueryWrapper(SysUserBo user) { |
| | |
| | | List<Long> ids = StreamUtils.toList(deptList, SysDept::getDeptId); |
| | | ids.add(user.getDeptId()); |
| | | w.in("u.dept_id", ids); |
| | | }); |
| | | }).orderByAsc("u.user_id"); |
| | | return wrapper; |
| | | } |
| | | |
| | |
| | | .eq(ObjectUtil.isNotNull(user.getRoleId()), "r.role_id", user.getRoleId()) |
| | | .like(StringUtils.isNotBlank(user.getUserName()), "u.user_name", user.getUserName()) |
| | | .eq(StringUtils.isNotBlank(user.getStatus()), "u.status", user.getStatus()) |
| | | .like(StringUtils.isNotBlank(user.getPhonenumber()), "u.phonenumber", user.getPhonenumber()); |
| | | .like(StringUtils.isNotBlank(user.getPhonenumber()), "u.phonenumber", user.getPhonenumber()) |
| | | .orderByAsc("u.user_id"); |
| | | Page<SysUserVo> page = baseMapper.selectAllocatedList(pageQuery.build(), wrapper); |
| | | return TableDataInfo.build(page); |
| | | } |
| | |
| | | .and(w -> w.ne("r.role_id", user.getRoleId()).or().isNull("r.role_id")) |
| | | .notIn(CollUtil.isNotEmpty(userIds), "u.user_id", userIds) |
| | | .like(StringUtils.isNotBlank(user.getUserName()), "u.user_name", user.getUserName()) |
| | | .like(StringUtils.isNotBlank(user.getPhonenumber()), "u.phonenumber", user.getPhonenumber()); |
| | | .like(StringUtils.isNotBlank(user.getPhonenumber()), "u.phonenumber", user.getPhonenumber()) |
| | | .orderByAsc("u.user_id"); |
| | | Page<SysUserVo> page = baseMapper.selectUnallocatedList(pageQuery.build(), wrapper); |
| | | return TableDataInfo.build(page); |
| | | } |
| | |
| | | */ |
| | | @Override |
| | | public SysUserVo selectUserByUserName(String userName) { |
| | | return baseMapper.selectUserByUserName(userName); |
| | | return baseMapper.selectVoOne(new LambdaQueryWrapper<SysUser>().eq(SysUser::getUserName, userName)); |
| | | } |
| | | |
| | | /** |
| | |
| | | */ |
| | | @Override |
| | | public SysUserVo selectUserByPhonenumber(String phonenumber) { |
| | | return baseMapper.selectUserByPhonenumber(phonenumber); |
| | | return baseMapper.selectVoOne(new LambdaQueryWrapper<SysUser>().eq(SysUser::getPhonenumber, phonenumber)); |
| | | } |
| | | |
| | | /** |
| | |
| | | */ |
| | | @Override |
| | | public SysUserVo selectUserById(Long userId) { |
| | | return baseMapper.selectUserById(userId); |
| | | SysUserVo user = baseMapper.selectVoById(userId); |
| | | if (ObjectUtil.isNull(user)) { |
| | | return user; |
| | | } |
| | | user.setRoles(roleMapper.selectRolesByUserId(user.getUserId())); |
| | | return user; |
| | | } |
| | | |
| | | /** |
| | | * 通过用户ID串查询用户 |
| | | * |
| | | * @param userIds 用户ID串 |
| | | * @param deptId 部门id |
| | | * @return 用户列表信息 |
| | | */ |
| | | @Override |
| | | public List<SysUserVo> selectUserByIds(List<Long> userIds, Long deptId) { |
| | | return baseMapper.selectUserList(new LambdaQueryWrapper<SysUser>() |
| | | .select(SysUser::getUserId, SysUser::getUserName, SysUser::getNickName) |
| | | .eq(SysUser::getStatus, UserConstants.USER_NORMAL) |
| | | .eq(ObjectUtil.isNotNull(deptId), SysUser::getDeptId, deptId) |
| | | .in(CollUtil.isNotEmpty(userIds), SysUser::getUserId, userIds)); |
| | | } |
| | | |
| | | /** |
| | | * 查询用户所属角色组 |
| | | * |
| | | * @param userName 用户名 |
| | | * @param userId 用户ID |
| | | * @return 结果 |
| | | */ |
| | | @Override |
| | | public String selectUserRoleGroup(String userName) { |
| | | List<SysRoleVo> list = roleMapper.selectRolesByUserName(userName); |
| | | public String selectUserRoleGroup(Long userId) { |
| | | List<SysRoleVo> list = roleMapper.selectRolesByUserId(userId); |
| | | if (CollUtil.isEmpty(list)) { |
| | | return StringUtils.EMPTY; |
| | | } |
| | |
| | | /** |
| | | * 查询用户所属岗位组 |
| | | * |
| | | * @param userName 用户名 |
| | | * @param userId 用户ID |
| | | * @return 结果 |
| | | */ |
| | | @Override |
| | | public String selectUserPostGroup(String userName) { |
| | | List<SysPostVo> list = postMapper.selectPostsByUserName(userName); |
| | | public String selectUserPostGroup(Long userId) { |
| | | List<SysPostVo> list = postMapper.selectPostsByUserId(userId); |
| | | if (CollUtil.isEmpty(list)) { |
| | | return StringUtils.EMPTY; |
| | | } |
| | |
| | | if (LoginHelper.isSuperAdmin()) { |
| | | return; |
| | | } |
| | | if (ObjectUtil.isNull(baseMapper.selectUserById(userId))) { |
| | | if (baseMapper.countUserById(userId) == 0) { |
| | | throw new ServiceException("没有权限访问用户数据!"); |
| | | } |
| | | } |
| | |
| | | */ |
| | | @Override |
| | | public boolean registerUser(SysUserBo user, String tenantId) { |
| | | user.setCreateBy(user.getUserId()); |
| | | user.setUpdateBy(user.getUserId()); |
| | | user.setCreateBy(0L); |
| | | user.setUpdateBy(0L); |
| | | SysUser sysUser = MapstructUtils.convert(user, SysUser.class); |
| | | sysUser.setTenantId(tenantId); |
| | | return baseMapper.insert(sysUser) > 0; |
| | |
| | | return flag; |
| | | } |
| | | |
| | | /** |
| | | * 通过部门id查询当前部门所有用户 |
| | | * |
| | | * @param deptId 部门ID |
| | | * @return 用户信息集合信息 |
| | | */ |
| | | @Override |
| | | public List<SysUserVo> selectUserListByDept(Long deptId) { |
| | | LambdaQueryWrapper<SysUser> lqw = Wrappers.lambdaQuery(); |
| | | lqw.eq(SysUser::getDeptId, deptId); |
| | | lqw.orderByAsc(SysUser::getUserId); |
| | | return baseMapper.selectVoList(lqw); |
| | | } |
| | | |
| | | /** |
| | | * 通过用户ID查询用户账户 |
| | | * |
| | | * @param userId 用户ID |
| | | * @return 用户账户 |
| | | */ |
| | | @Cacheable(cacheNames = CacheNames.SYS_USER_NAME, key = "#userId") |
| | | @Override |
| | | public String selectUserNameById(Long userId) { |
| | |
| | | .select(SysUser::getUserName).eq(SysUser::getUserId, userId)); |
| | | return ObjectUtil.isNull(sysUser) ? null : sysUser.getUserName(); |
| | | } |
| | | |
| | | /** |
| | | * 通过用户ID查询用户账户 |
| | | * |
| | | * @param userId 用户ID |
| | | * @return 用户账户 |
| | | */ |
| | | @Override |
| | | @Cacheable(cacheNames = CacheNames.SYS_NICKNAME, key = "#userId") |
| | | public String selectNicknameById(Long userId) { |
| | | SysUser sysUser = baseMapper.selectOne(new LambdaQueryWrapper<SysUser>() |
| | | .select(SysUser::getNickName).eq(SysUser::getUserId, userId)); |
| | | return ObjectUtil.isNull(sysUser) ? null : sysUser.getNickName(); |
| | | } |
| | | |
| | | /** |
| | | * 通过用户ID查询用户账户 |
| | | * |
| | | * @param userIds 用户ID 多个用逗号隔开 |
| | | * @return 用户账户 |
| | | */ |
| | | @Override |
| | | public String selectNicknameByIds(String userIds) { |
| | | List<String> list = new ArrayList<>(); |
| | | for (Long id : StringUtils.splitTo(userIds, Convert::toLong)) { |
| | | String nickname = SpringUtils.getAopProxy(this).selectNicknameById(id); |
| | | if (StringUtils.isNotBlank(nickname)) { |
| | | list.add(nickname); |
| | | } |
| | | } |
| | | return String.join(StringUtils.SEPARATOR, list); |
| | | } |
| | | |
| | | /** |
| | | * 通过用户ID查询用户手机号 |
| | | * |
| | | * @param userId 用户id |
| | | * @return 用户手机号 |
| | | */ |
| | | @Override |
| | | public String selectPhonenumberById(Long userId) { |
| | | SysUser sysUser = baseMapper.selectOne(new LambdaQueryWrapper<SysUser>() |
| | | .select(SysUser::getPhonenumber).eq(SysUser::getUserId, userId)); |
| | | return ObjectUtil.isNull(sysUser) ? null : sysUser.getPhonenumber(); |
| | | } |
| | | |
| | | /** |
| | | * 通过用户ID查询用户邮箱 |
| | | * |
| | | * @param userId 用户id |
| | | * @return 用户邮箱 |
| | | */ |
| | | @Override |
| | | public String selectEmailById(Long userId) { |
| | | SysUser sysUser = baseMapper.selectOne(new LambdaQueryWrapper<SysUser>() |
| | | .select(SysUser::getEmail).eq(SysUser::getUserId, userId)); |
| | | return ObjectUtil.isNull(sysUser) ? null : sysUser.getEmail(); |
| | | } |
| | | |
| | | } |