package com.thhy.usercore.modules.sys.login.service.impl;
|
|
import com.thhy.general.utils.DeepCopyUtils;
|
import com.thhy.general.utils.password.PasswdUtils;
|
import com.thhy.general.utils.UUIDUtils;
|
import com.thhy.general.common.BasicStatus;
|
import com.thhy.general.config.BasicContext;
|
import com.thhy.general.config.GlobalConfig;
|
import com.thhy.general.exception.BasicException;
|
import com.thhy.usercore.modules.sys.login.entity.LoginVO;
|
import com.thhy.general.common.entity.SysUserDto;
|
import com.thhy.usercore.modules.sys.login.entity.MpLoginVo;
|
import com.thhy.usercore.modules.sys.login.entity.MpMenuListVo;
|
import com.thhy.usercore.modules.sys.login.entity.MpMenuVo;
|
import com.thhy.usercore.modules.sys.login.service.LoginService;
|
import com.thhy.usercore.modules.sys.mpmenu.mapper.MpMenuMapper;
|
import com.thhy.usercore.modules.sys.sysmenu.entity.MenuDto;
|
import com.thhy.usercore.modules.sys.sysmenu.entity.MenuTreeVo;
|
import com.thhy.usercore.modules.sys.sysmenu.service.ISysMenusService;
|
import com.thhy.general.config.SysUserInfo;
|
import com.thhy.usercore.modules.sys.sysusers.entity.SysUsers;
|
import com.thhy.usercore.modules.sys.sysusers.mapper.SysUsersMapper;
|
import org.redisson.api.RBucket;
|
import org.redisson.api.RedissonClient;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.util.StringUtils;
|
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.concurrent.TimeUnit;
|
|
/**
|
* @Author: zhang_xiao_bo
|
* @Date: 2022/3/22 14:31
|
* @description:
|
*/
|
@Service
|
public class LoginServiceImpl implements LoginService {
|
|
@Autowired
|
private SysUsersMapper sysUsersMapper;
|
|
@Autowired
|
private MpMenuMapper menuMapper;
|
|
@Autowired
|
private ISysMenusService sysMenusService;
|
|
@Autowired
|
private RedissonClient redissonClient;
|
|
@Autowired
|
private GlobalConfig globalConfig;
|
|
/**
|
* 登陆
|
* @param sysUserDto
|
* @return
|
*/
|
@Override
|
public LoginVO login(SysUserDto sysUserDto) {
|
//根据用户名获取用户信息
|
SysUsers sysUser = sysUsersMapper.queryByUsername(sysUserDto.getUsername());
|
if(sysUser==null){
|
throw new BasicException(BasicStatus.LOGIN_FAILD); //用户名不存在导致登录失败
|
}
|
//判断登陆状态,强制下线
|
/*RKeys keys = redissonClient.getKeys();
|
Iterable<String> iterable = keys.getKeysByPattern(globalConfig.getKeyPrefix()+":usertoken:"+"*"+sysUser.getUserId());
|
iterable.forEach(s -> {
|
RBucket<SysUserInfo> rBucket = redissonClient.getBucket(s);
|
SysUserInfo userInfo = rBucket.get();
|
if(sysUser.getUserId().equals(userInfo.getUserId())){
|
rBucket.delete();
|
}
|
});*/
|
//解析并校验密码
|
boolean result = PasswdUtils.validatePassword(sysUserDto.getPassword(),sysUser.getPassword());
|
if(!result){
|
throw new BasicException(BasicStatus.USER_NOT_EXIST);
|
}
|
if(sysUser.getSubAdmin()==1){
|
HashMap<String,Object> map = sysUsersMapper.queryCompanyByComAdmin(sysUser.getUserId());
|
sysUser.setCompanyId(map.get("companyId").toString());
|
sysUser.setCompanyName(map.get("companyName").toString());
|
}
|
if(sysUser.getIsPlat()==1){
|
HashMap<String,Object> map = sysUsersMapper.queryCompanyByUser(sysUser.getUserId());
|
sysUser.setCompanyId(map.get("companyId").toString());
|
sysUser.setCompanyName(map.get("companyName").toString());
|
}
|
SysUserInfo sysUserInfo = new SysUserInfo();
|
DeepCopyUtils.copy(sysUser,sysUserInfo); //这里不需要密码
|
|
//用户可访问url
|
//List<String> enableUrls = sysUsersMapper.queryUserUrls(sysUserInfo.getUserId());
|
|
//用户可用按钮
|
String enableButtons = sysUsersMapper.queryUserButtons(sysUserInfo.getUserId());
|
|
//sysUserInfo.setEnableUrls(enableUrls);
|
|
sysUserInfo.setEnableButtons(StringUtils.isEmpty(enableButtons)?"":enableButtons);
|
|
String token = UUIDUtils.create()+sysUserInfo.getUserId();
|
redissonClient.getBucket(globalConfig.getKeyPrefix()+":usertoken:"+ token).trySet(sysUserInfo,365, TimeUnit.DAYS);
|
//用户菜单权限
|
List<MenuTreeVo> menuTreeVoList = sysMenusService.findTree(new MenuDto(sysUserInfo.getUserId(),"0"));
|
if(menuTreeVoList.size()<1){
|
throw new BasicException(BasicStatus.NO_ENABLE_MENU);
|
}
|
BasicContext.setToken(token);
|
return new LoginVO(token,sysUserInfo,menuTreeVoList);
|
}
|
|
@Override
|
public MpLoginVo mpLogin(SysUserDto sysUserDto) {
|
SysUsers sysUser = sysUsersMapper.queryByUsernameIsPlat(sysUserDto.getUsername());
|
if(sysUser==null){
|
throw new BasicException(BasicStatus.LOGIN_FAILD); //用户名不存在导致登录失败
|
}
|
//解析并校验密码
|
boolean result = PasswdUtils.validatePassword(sysUserDto.getPassword(),sysUser.getPassword());
|
if(!result){
|
throw new BasicException(BasicStatus.USER_NOT_EXIST);
|
}
|
List<MpMenuVo> mpMenuVoList = new ArrayList<>();
|
if(sysUser.getUserType()==1){
|
mpMenuVoList = menuMapper.queryMenuTagByUserId(sysUser.getUserId());
|
mpMenuVoList.forEach(mm->{
|
List<MpMenuListVo> menuList = menuMapper.queryMenuByTagAndUser(sysUser.getUserId(),mm.getTagId());
|
mm.setMenuList(menuList);
|
});
|
}else{
|
mpMenuVoList = menuMapper.queryMPMenuLW(sysUser.getUserId());
|
}
|
/*if(mpMenuVoList.size()<1){
|
throw new BasicException(BasicStatus.NO_ENABLE_MENU);
|
}*/
|
|
|
HashMap<String,Object> map = sysUsersMapper.queryCompanyByPosition(sysUser.getUserId());
|
sysUser.setCompanyId(map.get("companyId").toString());
|
sysUser.setCompanyName(map.get("companyName").toString());
|
SysUserInfo sysUserInfo = new SysUserInfo();
|
DeepCopyUtils.copy(sysUser,sysUserInfo); //这里不需要密码
|
|
|
String token = UUIDUtils.create()+sysUserInfo.getUserId();
|
redissonClient.getBucket(globalConfig.getKeyPrefix()+":usertoken:"+ token).trySet(sysUserInfo,1000, TimeUnit.MINUTES);
|
|
BasicContext.setToken(token);
|
|
return new MpLoginVo(token,sysUserInfo,mpMenuVoList);
|
}
|
|
@Override
|
public void logout(String token) {
|
try {
|
RBucket rBucket = redissonClient.getBucket(globalConfig.getKeyPrefix()+":usertoken:"+token);
|
if(rBucket.get()!=null){
|
rBucket.getAndDelete();
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
throw new BasicException(BasicStatus.OPERATOR_FAILD);
|
}
|
}
|
}
|
