package cn.stylefeng.guns.sys.modular.rest.service;
|
|
import cn.hutool.core.collection.CollectionUtil;
|
import cn.stylefeng.guns.base.auth.context.LoginContextHolder;
|
import cn.stylefeng.guns.base.auth.model.LoginUser;
|
import cn.stylefeng.guns.base.oauth2.entity.OauthUserInfo;
|
import cn.stylefeng.guns.base.oauth2.service.OauthUserInfoService;
|
import cn.stylefeng.guns.base.pojo.node.MenuNode;
|
import cn.stylefeng.guns.base.pojo.page.LayuiPageFactory;
|
import cn.stylefeng.guns.sys.core.constant.Const;
|
import cn.stylefeng.guns.sys.core.constant.factory.ConstantFactory;
|
import cn.stylefeng.guns.sys.core.constant.state.ManagerStatus;
|
import cn.stylefeng.guns.sys.core.exception.enums.BizExceptionEnum;
|
import cn.stylefeng.guns.sys.core.util.SaltUtil;
|
import cn.stylefeng.guns.sys.modular.rest.entity.RestUser;
|
import cn.stylefeng.guns.sys.modular.rest.entity.RestUserPos;
|
import cn.stylefeng.guns.sys.modular.rest.factory.RestUserFactory;
|
import cn.stylefeng.guns.sys.modular.rest.mapper.RestUserMapper;
|
import cn.stylefeng.guns.sys.modular.system.model.UserDto;
|
import cn.stylefeng.roses.core.datascope.DataScope;
|
import cn.stylefeng.roses.core.util.SpringContextHolder;
|
import cn.stylefeng.roses.core.util.ToolUtil;
|
import cn.stylefeng.roses.kernel.model.exception.ServiceException;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
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.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* <p>
|
* 管理员表 服务实现类
|
* </p>
|
*
|
* @author stylefeng
|
* @since 2018-12-07
|
*/
|
@Service
|
public class RestUserService extends ServiceImpl<RestUserMapper, RestUser> {
|
|
@Resource
|
private RestMenuService restMenuService;
|
|
@Resource
|
private RestUserPosService restUserPosService;
|
|
/**
|
* 添加用戶
|
*
|
* @author fengshuonan
|
* @Date 2018/12/24 22:51
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
public void addUser(UserDto user) {
|
|
// 判断账号是否重复
|
RestUser theUser = this.getByAccount(user.getAccount());
|
if (theUser != null) {
|
throw new ServiceException(BizExceptionEnum.USER_ALREADY_REG);
|
}
|
|
// 完善账号信息
|
String salt = SaltUtil.getRandomSalt();
|
String password = SaltUtil.md5Encrypt(user.getPassword(), salt);
|
|
RestUser newUser = RestUserFactory.createRestUser(user, password, salt);
|
this.save(newUser);
|
|
//添加职位关联
|
addPosition(user.getPosition(), newUser.getUserId());
|
}
|
|
/**
|
* 修改用户
|
*
|
* @author fengshuonan
|
* @Date 2018/12/24 22:53
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
public void editUser(UserDto user) {
|
RestUser oldUser = this.getById(user.getUserId());
|
|
if (oldUser == null) {
|
throw new ServiceException(BizExceptionEnum.NO_THIS_USER);
|
}
|
|
if (LoginContextHolder.getContext().hasRole(Const.ADMIN_NAME)) {
|
this.updateById(RestUserFactory.editRestUser(user, oldUser));
|
} else {
|
this.assertAuth(user.getUserId());
|
LoginUser shiroUser = LoginContextHolder.getContext().getUser();
|
if (shiroUser.getId().equals(user.getUserId())) {
|
this.updateById(RestUserFactory.editRestUser(user, oldUser));
|
} else {
|
throw new ServiceException(BizExceptionEnum.NO_PERMITION);
|
}
|
}
|
|
//删除职位关联
|
restUserPosService.remove(new QueryWrapper<RestUserPos>().eq("user_id", user.getUserId()));
|
|
//添加职位关联
|
addPosition(user.getPosition(), user.getUserId());
|
}
|
|
/**
|
* 删除用户
|
*
|
* @author fengshuonan
|
* @Date 2018/12/24 22:54
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
public void deleteUser(Long userId) {
|
|
//不能删除超级管理员
|
if (userId.equals(Const.ADMIN_ID)) {
|
throw new ServiceException(BizExceptionEnum.CANT_DELETE_ADMIN);
|
}
|
|
//不是超级管理员校验权限
|
if (!LoginContextHolder.getContext().isAdmin()) {
|
this.assertAuth(userId);
|
}
|
this.setStatus(userId, ManagerStatus.DELETED.getCode());
|
|
//删除对应的oauth2绑定表
|
OauthUserInfoService oauthUserInfoService = null;
|
try {
|
oauthUserInfoService = SpringContextHolder.getBean(OauthUserInfoService.class);
|
oauthUserInfoService.remove(new QueryWrapper<OauthUserInfo>().eq("user_id", userId));
|
} catch (Exception e) {
|
//没有集成oauth2模块，不操作
|
}
|
|
//删除职位关联
|
restUserPosService.remove(new QueryWrapper<RestUserPos>().eq("user_id", userId));
|
}
|
|
/**
|
* 修改用户状态
|
*
|
* @author fengshuonan
|
* @Date 2018/12/24 22:45
|
*/
|
public int setStatus(Long userId, String status) {
|
return this.baseMapper.setStatus(userId, status);
|
}
|
|
/**
|
* 修改密码
|
*
|
* @author fengshuonan
|
* @Date 2018/12/24 22:45
|
*/
|
public void changePwd(String oldPassword, String newPassword) {
|
Long userId = LoginContextHolder.getContext().getUser().getId();
|
RestUser user = this.getById(userId);
|
|
String oldMd5 = SaltUtil.md5Encrypt(oldPassword, user.getSalt());
|
|
if (user.getPassword().equals(oldMd5)) {
|
String newMd5 = SaltUtil.md5Encrypt(newPassword, user.getSalt());
|
user.setPassword(newMd5);
|
this.updateById(user);
|
} else {
|
throw new ServiceException(BizExceptionEnum.OLD_PWD_NOT_RIGHT);
|
}
|
}
|
|
/**
|
* 根据条件查询用户列表
|
*
|
* @author fengshuonan
|
* @Date 2018/12/24 22:45
|
*/
|
public Page<Map<String, Object>> selectUsers(DataScope dataScope, String name, String beginTime, String endTime, Long deptId) {
|
Page page = LayuiPageFactory.defaultPage();
|
return this.baseMapper.selectUsers(page, dataScope, name, beginTime, endTime, deptId);
|
}
|
|
/**
|
* 设置用户的角色
|
*
|
* @author fengshuonan
|
* @Date 2018/12/24 22:45
|
*/
|
public int setRoles(Long userId, String roleIds) {
|
return this.baseMapper.setRoles(userId, roleIds);
|
}
|
|
/**
|
* 通过账号获取用户
|
*
|
* @author fengshuonan
|
* @Date 2018/12/24 22:46
|
*/
|
public RestUser getByAccount(String account) {
|
return this.baseMapper.getByAccount(account);
|
}
|
|
/**
|
* 获取用户菜单列表
|
*
|
* @author fengshuonan
|
* @Date 2018/12/24 22:46
|
*/
|
public List<Map<String, Object>> getUserMenuNodes(List<Long> roleList) {
|
if (roleList == null || roleList.size() == 0) {
|
return new ArrayList<>();
|
} else {
|
List<MenuNode> menus = restMenuService.getMenusByRoleIds(roleList);
|
|
//定义不同系统分类的菜单集合
|
ArrayList<Map<String, Object>> lists = new ArrayList<>();
|
|
//根据当前用户包含的系统类型，分类出不同的菜单
|
List<Map<String, Object>> systemTypes = LoginContextHolder.getContext().getUser().getSystemTypes();
|
for (Map<String, Object> systemType : systemTypes) {
|
|
//当前遍历系统分类code
|
String systemCode = (String) systemType.get("code");
|
|
//获取当前系统分类下菜单集合
|
ArrayList<MenuNode> originSystemTypeMenus = new ArrayList<>();
|
for (MenuNode menu : menus) {
|
if (menu.getSystemType().equals(systemCode)) {
|
originSystemTypeMenus.add(menu);
|
}
|
}
|
|
//拼接存放key为系统分类编码，value为该分类下菜单集合的map
|
HashMap<String, Object> map = new HashMap<>();
|
List<MenuNode> treeSystemTypeMenus = MenuNode.buildTitle(originSystemTypeMenus);
|
|
//渲染系统类型id
|
map.put("id", systemCode);
|
|
//系统类型的名称
|
map.put("name", ConstantFactory.me().getDictNameByCode(systemCode));
|
|
//各个系统地子菜单
|
map.put("subMenus", treeSystemTypeMenus);
|
|
lists.add(map);
|
}
|
|
return lists;
|
}
|
|
}
|
|
/**
|
* 判断当前登录的用户是否有操作这个用户的权限
|
*
|
* @author fengshuonan
|
* @Date 2018/12/24 22:44
|
*/
|
public void assertAuth(Long userId) {
|
if (LoginContextHolder.getContext().isAdmin()) {
|
return;
|
}
|
List<Long> deptDataScope = LoginContextHolder.getContext().getDeptDataScope();
|
RestUser user = this.getById(userId);
|
Long deptId = user.getDeptId();
|
if (deptDataScope.contains(deptId)) {
|
return;
|
} else {
|
throw new ServiceException(BizExceptionEnum.NO_PERMITION);
|
}
|
|
}
|
|
/**
|
* 刷新当前登录用户的信息
|
*
|
* @author fengshuonan
|
* @Date 2019/1/19 5:59 PM
|
*/
|
public void refreshCurrentUser() {
|
LoginUser user = LoginContextHolder.getContext().getUser();
|
Long id = user.getId();
|
RestUser currentUser = this.getById(id);
|
|
//TODO 刷新
|
// LoginUser shiroUser = userAuthService.shiroUser(currentUser);
|
// LoginUser lastUser = LoginContextHolder.getContext().getUser();
|
// BeanUtil.copyProperties(shiroUser, lCastUser);
|
}
|
|
/**
|
* 获取用户的基本信息
|
*
|
* @author fengshuonan
|
* @Date 2019-05-04 17:12
|
*/
|
public Map<String, Object> getUserInfo(Long userId) {
|
RestUser user = this.getById(userId);
|
Map<String, Object> map = RestUserFactory.removeUnSafeFieldsRest(user);
|
|
HashMap<String, Object> hashMap = CollectionUtil.newHashMap();
|
hashMap.putAll(map);
|
hashMap.put("roleName", ConstantFactory.me().getRoleName(user.getRoleId()));
|
hashMap.put("deptName", ConstantFactory.me().getDeptName(user.getDeptId()));
|
|
hashMap.put("positionIds", ConstantFactory.me().getPositionIds(userId));
|
hashMap.put("positionNames", ConstantFactory.me().getPositionName(userId));
|
|
return hashMap;
|
}
|
|
|
/**
|
* 添加职位关联
|
*
|
* @author fengshuonan
|
* @Date 2019-06-28 13:35
|
*/
|
private void addPosition(String positions, Long userId) {
|
if (ToolUtil.isNotEmpty(positions)) {
|
String[] position = positions.split(",");
|
for (String item : position) {
|
|
RestUserPos entity = new RestUserPos();
|
entity.setUserId(userId);
|
entity.setPosId(Long.valueOf(item));
|
|
restUserPosService.save(entity);
|
|
}
|
}
|
}
|
}
|
