|
@@ -2,7 +2,6 @@ package com.usky.system.service.impl;
|
|
|
|
|
|
|
|
|
|
import com.ruoyi.common.datascope.annotation.DataScope;
|
|
import com.ruoyi.common.datascope.annotation.DataScope;
|
|
-import com.usky.common.core.constants.Constants;
|
|
|
|
import com.usky.common.security.utils.SecurityUtils;
|
|
import com.usky.common.security.utils.SecurityUtils;
|
|
import com.usky.common.core.bean.CommonPage;
|
|
import com.usky.common.core.bean.CommonPage;
|
|
import com.usky.common.core.exception.BusinessException;
|
|
import com.usky.common.core.exception.BusinessException;
|
|
@@ -15,17 +14,16 @@ import com.usky.system.mapper.*;
|
|
import com.usky.system.model.LoginUser;
|
|
import com.usky.system.model.LoginUser;
|
|
import com.usky.system.service.ISysConfigService;
|
|
import com.usky.system.service.ISysConfigService;
|
|
import com.usky.system.service.ISysUserService;
|
|
import com.usky.system.service.ISysUserService;
|
|
|
|
+import com.usky.system.service.vo.UserPostVo;
|
|
import org.slf4j.Logger;
|
|
import org.slf4j.Logger;
|
|
import org.slf4j.LoggerFactory;
|
|
import org.slf4j.LoggerFactory;
|
|
import org.springframework.beans.BeanUtils;
|
|
import org.springframework.beans.BeanUtils;
|
|
|
|
+import org.springframework.beans.BeansException;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
|
|
|
-import java.util.ArrayList;
|
|
|
|
-import java.util.List;
|
|
|
|
-import java.util.Objects;
|
|
|
|
-import java.util.Set;
|
|
|
|
|
|
+import java.util.*;
|
|
import java.util.stream.Collectors;
|
|
import java.util.stream.Collectors;
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -87,6 +85,37 @@ public class SysUserServiceImpl extends AbstractCrudService<SysUserMapper, SysUs
|
|
return userMapper.selectUserList(user);
|
|
return userMapper.selectUserList(user);
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ /**
|
|
|
|
+ * 用户列表-新
|
|
|
|
+ *
|
|
|
|
+ * @param user 用户信息
|
|
|
|
+ * @return 用户信息集合信息
|
|
|
|
+ */
|
|
|
|
+ @Override
|
|
|
|
+ public List<com.usky.system.service.vo.SysUserVO> dUserList(SysUser user) {
|
|
|
|
+ user.setTenantId(SecurityUtils.getTenantId());
|
|
|
|
+ user.setUserType("00");
|
|
|
|
+ List<com.usky.system.service.vo.SysUserVO> sysUserVOS = new ArrayList<>();
|
|
|
|
+ List<SysUser> sysUsers = userMapper.selectUserList(user);
|
|
|
|
+ List<Long> userIds = new ArrayList<>();
|
|
|
|
+ if (!sysUsers.isEmpty()) {
|
|
|
|
+ for (SysUser sysUser : sysUsers) {
|
|
|
|
+ com.usky.system.service.vo.SysUserVO sysUserVO = new com.usky.system.service.vo.SysUserVO();
|
|
|
|
+ try {
|
|
|
|
+ BeanUtils.copyProperties(sysUser, sysUserVO);
|
|
|
|
+ } catch (BeansException e) {
|
|
|
|
+ throw new BusinessException("dUserList方法,获取用户列表信息异常" + e);
|
|
|
|
+ }
|
|
|
|
+ userIds.add(sysUser.getUserId());
|
|
|
|
+ sysUserVOS.add(sysUserVO);
|
|
|
|
+ }
|
|
|
|
+ Map<Long, String> userIdToPostMap = userPostMapper.getUserPost(userIds).stream()
|
|
|
|
+ .collect(Collectors.toMap(UserPostVo::getUserId, UserPostVo::getPostName));
|
|
|
|
+ sysUserVOS.forEach(sysUserVO -> sysUserVO.setPost(userIdToPostMap.get(sysUserVO.getUserId())));
|
|
|
|
+ }
|
|
|
|
+ return sysUserVOS;
|
|
|
|
+ }
|
|
|
|
+
|
|
/**
|
|
/**
|
|
* 根据条件分页查询已分配用户角色列表
|
|
* 根据条件分页查询已分配用户角色列表
|
|
*
|
|
*
|
|
@@ -219,7 +248,7 @@ public class SysUserServiceImpl extends AbstractCrudService<SysUserMapper, SysUs
|
|
}
|
|
}
|
|
|
|
|
|
@Override
|
|
@Override
|
|
- public String checkPhoneUnique1(String phone, Integer tenantId){
|
|
|
|
|
|
+ public String checkPhoneUnique1(String phone, Integer tenantId) {
|
|
int count = userMapper.checkPhoneUnique1(phone, tenantId);
|
|
int count = userMapper.checkPhoneUnique1(phone, tenantId);
|
|
if (count > 0) {
|
|
if (count > 0) {
|
|
return UserConstants.NOT_UNIQUE;
|
|
return UserConstants.NOT_UNIQUE;
|
|
@@ -478,16 +507,16 @@ public class SysUserServiceImpl extends AbstractCrudService<SysUserMapper, SysUs
|
|
|
|
|
|
@Override
|
|
@Override
|
|
@Transactional
|
|
@Transactional
|
|
- public int deleteUserByPwd(Long userId,String password) {
|
|
|
|
|
|
+ public int deleteUserByPwd(Long userId, String password) {
|
|
checkUserAllowed(new SysUser(userId));
|
|
checkUserAllowed(new SysUser(userId));
|
|
SysUser user = this.selectUserById(userId);
|
|
SysUser user = this.selectUserById(userId);
|
|
- if (user.getPassword().equals(password)){
|
|
|
|
|
|
+ if (user.getPassword().equals(password)) {
|
|
// 删除用户与角色关联
|
|
// 删除用户与角色关联
|
|
userRoleMapper.deleteUserRoleByUserId(userId);
|
|
userRoleMapper.deleteUserRoleByUserId(userId);
|
|
// 删除用户与岗位表
|
|
// 删除用户与岗位表
|
|
userPostMapper.deleteUserPostByUserId(userId);
|
|
userPostMapper.deleteUserPostByUserId(userId);
|
|
return userMapper.deleteUserById(userId);
|
|
return userMapper.deleteUserById(userId);
|
|
- }else {
|
|
|
|
|
|
+ } else {
|
|
throw new BusinessException("密码错误");
|
|
throw new BusinessException("密码错误");
|
|
}
|
|
}
|
|
}
|
|
}
|
|
@@ -531,26 +560,26 @@ public class SysUserServiceImpl extends AbstractCrudService<SysUserMapper, SysUs
|
|
|
|
|
|
@Override
|
|
@Override
|
|
public SysUser getAppUserInfo(String username, Integer tenantId, String phone) {
|
|
public SysUser getAppUserInfo(String username, Integer tenantId, String phone) {
|
|
- SysUser sysUser = new SysUser();
|
|
|
|
- if (!StringUtils.isBlank(username)) {
|
|
|
|
- sysUser = userMapper.selectUserData(username, tenantId);
|
|
|
|
- } else if (!StringUtils.isBlank(phone)) {
|
|
|
|
- sysUser = userMapper.selectUserDataOne(tenantId,phone);
|
|
|
|
- }
|
|
|
|
- if(Objects.isNull(sysUser)){
|
|
|
|
- sysUser = userMapper.selectUserDataOne(tenantId,username);
|
|
|
|
- if (Objects.isNull(sysUser)){
|
|
|
|
- throw new BusinessException("用户信息未注册");
|
|
|
|
- }
|
|
|
|
- }
|
|
|
|
- List<SysRole> sysRoles = roleMapper.selectRolePermissionByUserId(sysUser.getUserId());
|
|
|
|
- List<SysRoleVO> collect = sysRoles.stream().map(sysRole -> {
|
|
|
|
- SysRoleVO sysRoleVO = new SysRoleVO();
|
|
|
|
- BeanUtils.copyProperties(sysRole, sysRoleVO);
|
|
|
|
- return sysRoleVO;
|
|
|
|
- }).collect(Collectors.toList());
|
|
|
|
- sysUser.setRoles(collect);
|
|
|
|
- return sysUser;
|
|
|
|
|
|
+ SysUser sysUser = new SysUser();
|
|
|
|
+ if (!StringUtils.isBlank(username)) {
|
|
|
|
+ sysUser = userMapper.selectUserData(username, tenantId);
|
|
|
|
+ } else if (!StringUtils.isBlank(phone)) {
|
|
|
|
+ sysUser = userMapper.selectUserDataOne(tenantId, phone);
|
|
|
|
+ }
|
|
|
|
+ if (Objects.isNull(sysUser)) {
|
|
|
|
+ sysUser = userMapper.selectUserDataOne(tenantId, username);
|
|
|
|
+ if (Objects.isNull(sysUser)) {
|
|
|
|
+ throw new BusinessException("用户信息未注册");
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ List<SysRole> sysRoles = roleMapper.selectRolePermissionByUserId(sysUser.getUserId());
|
|
|
|
+ List<SysRoleVO> collect = sysRoles.stream().map(sysRole -> {
|
|
|
|
+ SysRoleVO sysRoleVO = new SysRoleVO();
|
|
|
|
+ BeanUtils.copyProperties(sysRole, sysRoleVO);
|
|
|
|
+ return sysRoleVO;
|
|
|
|
+ }).collect(Collectors.toList());
|
|
|
|
+ sysUser.setRoles(collect);
|
|
|
|
+ return sysUser;
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|