package com.doumee.service.system.impl;
|
|
import cn.binarywang.wx.miniapp.bean.WxMaJscode2SessionResult;
|
import cn.binarywang.wx.miniapp.bean.WxMaPhoneNumberInfo;
|
import com.baomidou.mybatisplus.core.conditions.Wrapper;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.doumee.biz.system.SystemDictDataBiz;
|
import com.doumee.config.Jwt.JwtPayLoad;
|
import com.doumee.config.Jwt.JwtTokenUtil;
|
import com.doumee.core.constants.ResponseStatus;
|
import com.doumee.core.exception.BusinessException;
|
import com.doumee.core.model.PageData;
|
import com.doumee.core.model.PageWrap;
|
import com.doumee.core.utils.CodeVerifyUtils;
|
import com.doumee.core.utils.Constants;
|
import com.doumee.core.utils.DateUtil;
|
import com.doumee.core.utils.Utils;
|
import com.doumee.core.wx.WxMiniConfig;
|
import com.doumee.dao.business.BookingsMapper;
|
import com.doumee.dao.business.model.Bookings;
|
import com.doumee.dao.system.SystemUserJoinMapper;
|
import com.doumee.dao.system.SystemUserMapper;
|
import com.doumee.dao.system.dto.QuerySystemUserDTO;
|
import com.doumee.dao.system.model.SystemDepartment;
|
import com.doumee.dao.system.model.SystemUser;
|
import com.doumee.dao.system.vo.SystemDepartmentListVO;
|
import com.doumee.dao.system.vo.SystemUserListVO;
|
import com.doumee.dao.web.request.UserEditRequest;
|
import com.doumee.dao.web.request.UserPageRequest;
|
import com.doumee.dao.web.request.WxPhoneRequest;
|
import com.doumee.dao.web.response.AccountResponse;
|
import com.doumee.dao.web.response.UserResponse;
|
import com.doumee.dao.web.response.VisitorLoginResponse;
|
import com.doumee.service.aware.DepartmentDataPermissionAware;
|
import com.doumee.service.system.SystemDepartmentService;
|
import com.doumee.service.system.SystemPositionService;
|
import com.doumee.service.system.SystemRoleService;
|
import com.doumee.service.system.SystemUserService;
|
import com.github.pagehelper.PageHelper;
|
import com.github.pagehelper.PageInfo;
|
import com.github.yulichang.wrapper.MPJLambdaWrapper;
|
import me.chanjar.weixin.common.error.WxErrorException;
|
import org.apache.commons.lang3.StringUtils;
|
import org.apache.shiro.SecurityUtils;
|
import org.apache.shiro.authc.AuthenticationException;
|
import org.apache.shiro.authc.UsernamePasswordToken;
|
import org.apache.shiro.subject.Subject;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.util.CollectionUtils;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Objects;
|
import java.util.stream.Collectors;
|
|
/**
|
* 系统用户Service实现
|
* @author Eva.Caesar Liu
|
* @date 2023/03/21 14:49
|
*/
|
@Service
|
public class SystemUserServiceImpl implements SystemUserService {
|
|
@Autowired
|
private SystemDictDataBiz systemDictDataBiz;
|
|
@Autowired
|
private SystemUserMapper systemUserMapper;
|
|
@Autowired
|
private SystemUserJoinMapper systemUserJoinMapper;
|
|
@Autowired
|
private SystemRoleService systemRoleService;
|
|
@Autowired
|
private SystemDepartmentService systemDepartmentService;
|
|
@Autowired
|
private SystemPositionService systemPositionService;
|
|
@Autowired
|
private DepartmentDataPermissionAware departmentDataPermissionAware;
|
|
@Autowired
|
private BookingsMapper bookingsMapper;
|
|
@Override
|
public Integer create(SystemUser systemUser) {
|
systemUserMapper.insert(systemUser);
|
return systemUser.getId();
|
}
|
|
@Override
|
public void deleteById(Integer id) {
|
SystemUser systemUser = new SystemUser();
|
systemUser.setId(id);
|
systemUser.setDeleted(Boolean.TRUE);
|
this.updateById(systemUser);
|
}
|
|
@Override
|
@Transactional
|
public void deleteByIdInBatch(List<Integer> ids) {
|
if (CollectionUtils.isEmpty(ids)) return;
|
for (Integer id : ids) {
|
this.deleteById(id);
|
}
|
}
|
|
@Override
|
public void updateById(SystemUser systemUser) {
|
systemUserMapper.updateById(systemUser);
|
}
|
|
@Override
|
@Transactional
|
public void updateByIdInBatch(List<SystemUser> systemUsers) {
|
if (CollectionUtils.isEmpty(systemUsers)) return;
|
for (SystemUser systemUser: systemUsers) {
|
this.updateById(systemUser);
|
}
|
}
|
|
@Override
|
public SystemUser findById(Integer id) {
|
MPJLambdaWrapper<SystemUser> queryWrapper = new MPJLambdaWrapper<>();
|
queryWrapper.selectAll(SystemUser.class);
|
queryWrapper.eq(SystemUser::getId,id );
|
queryWrapper.orderByDesc(SystemUser::getCreateTime);
|
SystemUser result = systemUserJoinMapper.selectJoinOne( SystemUser.class, queryWrapper);
|
return result;
|
}
|
|
@Override
|
public SystemUser findOne(SystemUser systemUser) {
|
Wrapper<SystemUser> wrapper = new QueryWrapper<>(systemUser);
|
return systemUserMapper.selectOne(wrapper);
|
}
|
|
@Override
|
public List<SystemUser> findList(SystemUser systemUser) {
|
Wrapper<SystemUser> wrapper = new QueryWrapper<>(systemUser);
|
return systemUserMapper.selectList(wrapper);
|
}
|
|
@Override
|
public PageData<SystemUserListVO> findPage(PageWrap<QuerySystemUserDTO> pageWrap) {
|
// 根部门条件处理（需查询根部门下所有部门的用户）
|
if (pageWrap.getModel().getRootDeptId() != null) {
|
pageWrap.getModel().setDepartmentIds(getDeptIds(pageWrap.getModel().getRootDeptId()));
|
} else {
|
List<SystemDepartment> list = systemDepartmentService.findList(new QueryWrapper<>());
|
List<Integer> collect = list.stream().map(s -> s.getId()).collect(Collectors.toList());
|
pageWrap.getModel().setDepartmentIds(collect);
|
}
|
// 执行查询
|
PageHelper.startPage(pageWrap.getPage(), pageWrap.getCapacity());
|
List<SystemUserListVO> userList = systemUserMapper.selectManageList(pageWrap.getModel(), pageWrap.getOrderByClause());
|
for (SystemUserListVO user : userList) {
|
// 查询用户角色列表
|
user.setRoles(systemRoleService.findByUserId(user.getId()));
|
// 查询用户岗位列表
|
// user.setPositions(systemPositionService.findByUserId(user.getId()));
|
}
|
return PageData.from(new PageInfo<>(userList));
|
}
|
|
@Override
|
public long count(SystemUser systemUser) {
|
Wrapper<SystemUser> wrapper = new QueryWrapper<>(systemUser);
|
return systemUserMapper.selectCount(wrapper);
|
}
|
|
|
/**
|
* 获取用户权限内允许查询的部门ID
|
*/
|
private List<Integer> getDeptIds(Integer rootDeptId) {
|
List<Integer> departmentIds = systemDepartmentService.findChildren(rootDeptId);
|
departmentIds.add(rootDeptId);
|
return departmentIds;
|
}
|
|
/**
|
* 获取用户权限内允许查询的部门ID
|
*/
|
private List<Integer> getAllowedDeptIds(Integer rootDeptId) {
|
List<SystemDepartmentListVO> allowedDepartments = departmentDataPermissionAware.execute();
|
List<Integer> allowedDeptIds = new ArrayList<>();
|
for (SystemDepartmentListVO listVO : allowedDepartments) {
|
injectIds(allowedDeptIds, listVO);
|
}
|
// 没有允许的部门
|
if (allowedDeptIds.size() == 0) {
|
allowedDeptIds.add(-1);
|
return allowedDeptIds;
|
}
|
if (rootDeptId == null) {
|
return allowedDeptIds;
|
}
|
List<Integer> departmentIds = systemDepartmentService.findChildren(rootDeptId);
|
departmentIds.add(rootDeptId);
|
departmentIds.removeIf(deptId -> !allowedDeptIds.contains(deptId));
|
return departmentIds;
|
}
|
|
/**
|
* 递归注入用户权限内的部门ID
|
*/
|
private void injectIds (List<Integer> pool, SystemDepartmentListVO listVO) {
|
pool.add(listVO.getId());
|
if (CollectionUtils.isEmpty(listVO.getChildren())) {
|
return;
|
}
|
for (SystemDepartmentListVO child : listVO.getChildren()) {
|
injectIds(pool, child);
|
}
|
}
|
|
|
@Override
|
public PageData<SystemUser> findAllList(PageWrap<SystemUser> pageWrap) {
|
|
IPage<SystemUser> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
|
MPJLambdaWrapper<SystemUser> queryWrapper = new MPJLambdaWrapper<>();
|
Utils.MP.blankToNull(pageWrap.getModel());
|
queryWrapper.selectAll(SystemUser.class);
|
queryWrapper.eq(SystemUser::getDeleted, Constants.ZERO);
|
queryWrapper.and(StringUtils.isNotBlank(pageWrap.getModel().getUsername()),ms->ms.like(SystemUser::getUsername,pageWrap.getModel().getUsername())
|
.or().like(SystemUser::getMobile,pageWrap.getModel().getUsername())
|
.or().like(SystemUser::getRealname,pageWrap.getModel().getUsername())
|
);
|
queryWrapper.orderByDesc(SystemUser::getCreateTime);
|
|
|
|
IPage<SystemUser> result = systemUserJoinMapper.selectJoinPage(page, SystemUser.class, queryWrapper);
|
|
return PageData.from(result);
|
}
|
|
|
|
/****************************************移动端接口开始********************************************************************/
|
|
|
/**
|
* 小程序 普通登录
|
* @param account
|
* @param password
|
* @return
|
*/
|
@Override
|
public AccountResponse ordinaryLogin(String account, String password){
|
AccountResponse accountResponse = new AccountResponse();
|
SystemUser systemUser = systemUserMapper.selectOne(new QueryWrapper<SystemUser>()
|
.eq("USERNAME",account)
|
.eq("DELETED",Constants.ZERO)
|
.eq("status",Constants.ZERO)
|
);
|
if(Objects.isNull(systemUser)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到账户信息");
|
}
|
// 校验用户名和密码
|
Subject subject = SecurityUtils.getSubject();
|
UsernamePasswordToken token = new UsernamePasswordToken(account, password);
|
try {
|
subject.login(token);
|
} catch (AuthenticationException e) {
|
throw new BusinessException(ResponseStatus.ACCOUNT_INCORRECT);
|
}
|
|
UserResponse userResponse =this.getUserInfo(systemUser.getId());
|
String path = systemDictDataBiz.queryByCode(Constants.SYSTEM, Constants.FILE_DIR).getCode() + systemDictDataBiz.queryByCode(Constants.OSS, Constants.PROJECTS).getCode();
|
userResponse.setPrefixUrl(path);
|
JwtPayLoad payLoad = new JwtPayLoad(systemUser.getId());
|
accountResponse.setToken(JwtTokenUtil.generateToken(payLoad));
|
accountResponse.setUserResponse(userResponse);
|
return accountResponse;
|
}
|
|
|
/**
|
* 拉取微信授权
|
* @param code
|
* @param userId
|
*/
|
@Override
|
public void wxEmpower(String code,Integer userId){
|
SystemUser systemUser = systemUserMapper.selectById(userId);
|
if(Objects.isNull(systemUser)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未查询到账户信息");
|
}
|
try {
|
//获取微信敏感数据
|
WxMaJscode2SessionResult session = WxMiniConfig.wxMaService.getUserService().getSessionInfo(code);
|
String openId = session.getOpenid();
|
if (com.baomidou.mybatisplus.core.toolkit.StringUtils.isBlank(openId)) {
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"获取openid失败！请联系管理员");
|
}
|
systemUser.setOpenid(openId);
|
systemUserMapper.updateById(systemUser);
|
systemUserMapper.update(null,
|
new UpdateWrapper<SystemUser>()
|
.set("openId",null)
|
.eq("openId",openId)
|
.ne("id",systemUser.getId()));
|
} catch (WxErrorException e) {
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"微信登录异常！请联系管理员");
|
}
|
}
|
|
|
/**
|
* 查询参会人员分页
|
* @param pageWrap
|
* @return
|
*/
|
@Override
|
public IPage<UserResponse> getUserPage(PageWrap<UserPageRequest> pageWrap) {
|
IPage<UserResponse> page = systemUserMapper.getUserPage(pageWrap.toPage(),new QueryWrapper<UserResponse>()
|
.and(StringUtils.isNotBlank(pageWrap.getModel().getKeyword()), i -> i.like("c.realName", pageWrap.getModel().getKeyword())
|
.or().like("e.name", pageWrap.getModel().getKeyword())
|
)
|
.eq("c.DELETED",0)
|
.eq("c.status",0)
|
.orderByAsc("c.id")
|
);
|
String path = systemDictDataBiz.queryByCode(Constants.SYSTEM, Constants.FILE_DIR).getCode() + systemDictDataBiz.queryByCode(Constants.OSS, Constants.PROJECTS).getCode();
|
//查询是否处于会议中
|
page.getRecords().forEach(j->{
|
j.setPrefixUrl(path);
|
if(bookingsMapper.selectCount(new QueryWrapper<Bookings>()
|
.exists(" select 1 from user_rel u where u.OBJ_ID = bookings.id and u.USER_ID = '"+j.getId()+"' and u.OBJ_TYPE = 1 ")
|
.and(i -> i.between("START_TIME", pageWrap.getModel().getStartTime()+":00",pageWrap.getModel().getEndTime()+":00")
|
.or().between("END_TIME", pageWrap.getModel().getStartTime()+":00",pageWrap.getModel().getEndTime()+":00")
|
)
|
)>Constants.ZERO){
|
j.setStatus(Constants.ONE);
|
}else{
|
j.setStatus(Constants.ZERO);
|
}
|
});
|
return page;
|
}
|
|
@Override
|
public List<UserResponse> getUserList(Integer bookingsId) {
|
return systemUserMapper.getUserList(new QueryWrapper<UserResponse>()
|
.exists(" select 1 from user_rel u where u.USER_ID = c.id and u.ISDELETED = 0 and u.OBJ_ID = "+bookingsId+" and u.OBJ_TYPE = 1 ")
|
);
|
}
|
|
@Override
|
public UserResponse getUserInfo(Integer id) {
|
UserResponse userResponse = systemUserMapper.getUserInfo(id);
|
if(!Objects.isNull(userResponse)){
|
String path = systemDictDataBiz.queryByCode(Constants.SYSTEM, Constants.FILE_DIR).getCode() + systemDictDataBiz.queryByCode(Constants.OSS, Constants.PROJECTS).getCode();
|
userResponse.setPrefixUrl(path);
|
}
|
return userResponse;
|
}
|
|
|
@Override
|
public void editUserInfo(UserEditRequest userEditRequest) {
|
SystemUser systemUser = new SystemUser();
|
BeanUtils.copyProperties(userEditRequest,systemUser);
|
if(StringUtils.isNotBlank(userEditRequest.getBirthday())){
|
systemUser.setBirthday(DateUtil.StringToDate(userEditRequest.getBirthday(),"yyyy-MM-dd"));
|
}
|
systemUser.setUpdateUser(userEditRequest.getEditor());
|
systemUser.setUpdateTime(new Date());
|
systemUserMapper.updateById(systemUser);
|
}
|
|
|
/**
|
* 访客登录授权
|
* @param code
|
* @return
|
*/
|
@Override
|
public VisitorLoginResponse visitorLogin(String code){
|
try {
|
//获取微信敏感数据
|
WxMaJscode2SessionResult session = WxMiniConfig.wxMaService.getUserService().getSessionInfo(code);
|
String openId = session.getOpenid();
|
if (com.baomidou.mybatisplus.core.toolkit.StringUtils.isBlank(openId)) {
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"获取openid失败！请联系管理员");
|
}
|
SystemUser systemUser = systemUserMapper.selectOne(new QueryWrapper<SystemUser>().eq("OPENID",openId)
|
.eq("TYPE",Constants.ZERO).eq("DELETED",Constants.ZERO)
|
.eq("status",Constants.ZERO)
|
);
|
if(Objects.isNull(systemUser)){
|
systemUser = systemUserMapper.selectOne(new QueryWrapper<SystemUser>().eq("OPENID",openId)
|
.eq("TYPE",Constants.ONE)
|
.eq("DELETED",Constants.ZERO)
|
.eq("status",Constants.ZERO)
|
);
|
}
|
VisitorLoginResponse visitorLoginResponse = new VisitorLoginResponse();
|
if(Objects.isNull(systemUser)){
|
visitorLoginResponse.setCode(500);
|
visitorLoginResponse.setOpenId(openId);
|
visitorLoginResponse.setSessionKey(session.getSessionKey());
|
return visitorLoginResponse;
|
}
|
JwtPayLoad payLoad = new JwtPayLoad(systemUser.getId());
|
visitorLoginResponse.setCode(200);
|
visitorLoginResponse.setSystemUser(systemUser);
|
visitorLoginResponse.setToken(JwtTokenUtil.generateToken(payLoad));
|
return visitorLoginResponse;
|
} catch (WxErrorException e) {
|
e.printStackTrace();
|
}
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"微信登录异常！请联系管理员");
|
}
|
|
|
|
@Override
|
public VisitorLoginResponse wxPhone(WxPhoneRequest wxPhoneRequest){
|
try {
|
WxMaPhoneNumberInfo userPhoneInfo = WxMiniConfig.wxMaService.getUserService().getPhoneNoInfo(
|
wxPhoneRequest.getSessionKey(), wxPhoneRequest.getEncryptedData(), wxPhoneRequest.getIv());
|
//获取手机号
|
String phone= userPhoneInfo.getPurePhoneNumber();
|
if(Objects.isNull(phone)){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"未获取到手机号");
|
}
|
SystemUser systemUser = systemUserMapper.selectOne(new QueryWrapper<SystemUser>().eq("OPENID",wxPhoneRequest.getOpenId())
|
.eq("TYPE",Constants.ONE)
|
.eq("DELETED",Constants.ZERO)
|
.eq("status",Constants.ZERO)
|
);
|
if(Objects.isNull(systemUser)){
|
systemUser = new SystemUser();
|
systemUser.setUsername("访客："+CodeVerifyUtils.createVerificationCode(4));
|
systemUser.setRealname(systemUser.getUsername());
|
systemUser.setMobile(phone);
|
//TODO
|
systemUser.setAvatar("");
|
systemUser.setFixed(false);
|
systemUser.setCreateTime(new Date());
|
systemUser.setType(Constants.ONE);
|
systemUser.setOpenid(wxPhoneRequest.getOpenId());
|
systemUser.setStatus(Constants.ZERO);
|
systemUserMapper.insert(systemUser);
|
}
|
VisitorLoginResponse visitorLoginResponse = new VisitorLoginResponse();
|
JwtPayLoad payLoad = new JwtPayLoad(systemUser.getId());
|
visitorLoginResponse.setCode(200);
|
visitorLoginResponse.setSystemUser(systemUser);
|
visitorLoginResponse.setToken(JwtTokenUtil.generateToken(payLoad));
|
return visitorLoginResponse;
|
} catch (Exception e) {
|
e.printStackTrace();
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"更新手机号失败");
|
}
|
}
|
|
}
|
