package com.doumee.service.system.impl; import cn.binarywang.wx.miniapp.bean.WxMaJscode2SessionResult; import cn.binarywang.wx.miniapp.bean.WxMaPhoneNumberInfo; import com.alibaba.fastjson.JSONObject; 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.annotation.excel.ExcelImporter; import com.doumee.core.constants.ResponseStatus; import com.doumee.core.exception.BusinessException; import com.doumee.core.oss.FileModel; 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.SystemDepartmentMapper; import com.doumee.dao.system.SystemUserJoinMapper; import com.doumee.dao.web.request.MeetingPageRequest; 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.MeetingListResponse; import com.doumee.dao.web.response.UserResponse; import com.doumee.dao.web.response.VisitorLoginResponse; import com.doumee.service.business.BookingsService; import com.doumee.service.business.impl.BookingsServiceImpl; import com.doumee.dao.system.dto.ImportSystemUserDTO; import com.doumee.dao.system.model.SystemDepartment; import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageInfo; import com.doumee.core.model.PageData; import com.doumee.core.model.PageWrap; import com.doumee.dao.system.SystemUserMapper; import com.doumee.dao.system.dto.QuerySystemUserDTO; import com.doumee.dao.system.model.SystemUser; import com.doumee.dao.system.vo.SystemUserListVO; 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.doumee.dao.system.vo.SystemDepartmentListVO; import com.doumee.service.aware.DepartmentDataPermissionAware; import com.baomidou.mybatisplus.core.conditions.Wrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.github.yulichang.wrapper.MPJLambdaWrapper; import me.chanjar.weixin.common.error.WxErrorException; import okhttp3.OkHttpClient; import okhttp3.Request; import okhttp3.Response; import org.apache.commons.lang3.StringUtils; import org.apache.poi.openxml4j.exceptions.InvalidFormatException; 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.checkerframework.checker.units.qual.A; 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 org.springframework.web.multipart.MultipartFile; import java.io.ByteArrayInputStream; import java.io.IOException; import java.io.InputStream; import java.util.*; 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 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 systemUsers) { if (CollectionUtils.isEmpty(systemUsers)) return; for (SystemUser systemUser: systemUsers) { this.updateById(systemUser); } } @Override public SystemUser findById(Integer id) { MPJLambdaWrapper 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 wrapper = new QueryWrapper<>(systemUser); return systemUserMapper.selectOne(wrapper); } @Override public List findList(SystemUser systemUser) { Wrapper wrapper = new QueryWrapper<>(systemUser); return systemUserMapper.selectList(wrapper); } @Override public PageData findPage(PageWrap pageWrap) { // 根部门条件处理（需查询根部门下所有部门的用户） if (pageWrap.getModel().getRootDeptId() != null) { pageWrap.getModel().setDepartmentIds(getDeptIds(pageWrap.getModel().getRootDeptId())); } else { List list = systemDepartmentService.findList(new QueryWrapper<>()); List collect = list.stream().map(s -> s.getId()).collect(Collectors.toList()); pageWrap.getModel().setDepartmentIds(collect); } // 执行查询 PageHelper.startPage(pageWrap.getPage(), pageWrap.getCapacity()); List 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 wrapper = new QueryWrapper<>(systemUser); return systemUserMapper.selectCount(wrapper); } /** * 获取用户权限内允许查询的部门ID */ private List getDeptIds(Integer rootDeptId) { List departmentIds = systemDepartmentService.findChildren(rootDeptId); departmentIds.add(rootDeptId); return departmentIds; } /** * 获取用户权限内允许查询的部门ID */ private List getAllowedDeptIds(Integer rootDeptId) { List allowedDepartments = departmentDataPermissionAware.execute(); List 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 departmentIds = systemDepartmentService.findChildren(rootDeptId); departmentIds.add(rootDeptId); departmentIds.removeIf(deptId -> !allowedDeptIds.contains(deptId)); return departmentIds; } /** * 递归注入用户权限内的部门ID */ private void injectIds (List pool, SystemDepartmentListVO listVO) { pool.add(listVO.getId()); if (CollectionUtils.isEmpty(listVO.getChildren())) { return; } for (SystemDepartmentListVO child : listVO.getChildren()) { injectIds(pool, child); } } @Override public PageData findAllList(PageWrap pageWrap) { IPage page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); MPJLambdaWrapper 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 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() .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() .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 getUserPage(PageWrap pageWrap) { IPage page = systemUserMapper.getUserPage(pageWrap.toPage(),new QueryWrapper() .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() .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 getUserList(Integer bookingsId) { return systemUserMapper.getUserList(new QueryWrapper() .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().eq("OPENID",openId) .eq("TYPE",Constants.ZERO).eq("DELETED",Constants.ZERO) .eq("status",Constants.ZERO) ); if(Objects.isNull(systemUser)){ systemUser = systemUserMapper.selectOne(new QueryWrapper().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().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(),"更新手机号失败"); } } }