package com.doumee.service.system.impl; import com.baomidou.mybatisplus.core.conditions.Wrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.doumee.biz.system.SystemDictDataBiz; import com.doumee.dao.business.model.Member; import com.doumee.service.business.third.model.PageData; import com.doumee.service.business.third.model.PageWrap; import com.doumee.core.utils.Constants; import com.doumee.core.utils.Utils; import com.doumee.dao.business.model.Company; 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.SystemUser; import com.doumee.dao.system.vo.SystemDepartmentListVO; import com.doumee.dao.system.vo.SystemUserListVO; import com.doumee.dao.system.vo.UserResponse; 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 org.apache.commons.lang3.StringUtils; 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.List; import java.util.Objects; /** * 系统用户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; @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) { QueryWrapper wrapper = new QueryWrapper(systemUser); return systemUserMapper.selectOne(wrapper.lambda().last("limit 1")); } @Override public List findList(SystemUser systemUser) { MPJLambdaWrapper wrapper = new MPJLambdaWrapper<>(); wrapper.selectAll(SystemUser.class ) .selectAs(Company::getName,SystemUser::getCompanyName) .eq(SystemUser::getDeleted,Constants.ZERO) .leftJoin(Company.class,Company::getId,SystemUser::getCompanyId) .eq( systemUser.getCompanyId() !=null,SystemUser::getCompanyId,systemUser.getCompanyId()) .eq( systemUser.getCompanyType() !=null,Company::getType,systemUser.getCompanyType()) .like(StringUtils.isNotBlank(systemUser.getRealname()),SystemUser::getRealname,systemUser.getRealname()) .like(StringUtils.isNotBlank(systemUser.getMobile()),SystemUser::getMobile,systemUser.getMobile()) .like(StringUtils.isNotBlank(systemUser.getUsername()),SystemUser::getUsername,systemUser.getUsername()) .like(StringUtils.isNotBlank(systemUser.getCompanyName()),Company::getName,systemUser.getCompanyName()) .orderByAsc( Company::getPinyin ) .orderByAsc(SystemUser::getPinyin) ; return systemUserMapper.selectJoinList(SystemUser.class,wrapper); } @Override public List getUserList(Integer bookingsId) { return systemUserMapper.getUserList(new QueryWrapper() .exists(" select 1 from meeting_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 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); }*/ //查询特殊的42人配置 if(Objects.nonNull(pageWrap.getModel()) && Constants.equalsInteger(pageWrap.getModel().getQuerySpecial(),Constants.ONE)){ String companySpecialId = systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.SPECIAL_COMPANY_ID).getCode(); if(StringUtils.isNotBlank(companySpecialId)){ pageWrap.getModel().setCompanySpecialId(companySpecialId); } } // 执行查询 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 PageData findDriverPage(PageWrap pageWrap) { IPage page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); QueryWrapper queryWrapper = new QueryWrapper<>(); Utils.MP.blankToNull(pageWrap.getModel()); queryWrapper.lambda() .like(StringUtils.isNotBlank(pageWrap.getModel().getRealname()),SystemUser::getRealname,pageWrap.getModel().getRealname()) .like(StringUtils.isNotBlank(pageWrap.getModel().getMobile()),SystemUser::getMobile,pageWrap.getModel().getMobile()) .like(StringUtils.isNotBlank(pageWrap.getModel().getUsername()),SystemUser::getUsername,pageWrap.getModel().getUsername()) .eq( pageWrap.getModel().getType()!=null,SystemUser::getType,pageWrap.getModel().getType()) .eq (SystemUser::getDeleted,Constants.ZERO); return PageData.from(systemUserMapper.selectPage(page, queryWrapper)); } @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 List findAllList(SystemUser systemUser) { //查询特殊的42人配置 if( Constants.equalsInteger(systemUser.getQuerySpecial(),Constants.ONE)){ String companySpecialId = systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.SPECIAL_COMPANY_ID).getCode(); if(StringUtils.isNotBlank(companySpecialId)){ systemUser.setCompanySpecialId(companySpecialId); } } MPJLambdaWrapper wrapper = new MPJLambdaWrapper<>(); wrapper.selectAll(SystemUser.class ) .selectAs(Company::getCompanyNamePath,SystemUser::getCompanyName) .selectAs(Member::getFaceImg,SystemUser::getFaceImg) .eq(SystemUser::getDeleted,Constants.ZERO) .leftJoin(Company.class,Company::getId,SystemUser::getCompanyId) .leftJoin(Member.class,Member::getId,SystemUser::getMemberId) .and(StringUtils.isNotBlank(systemUser.getUsername()),ms->ms.like(SystemUser::getUsername,systemUser.getUsername()) .or().like(SystemUser::getMobile,systemUser.getUsername()) .or().like(SystemUser::getRealname,systemUser.getUsername())) .and(StringUtils.isNotBlank(systemUser.getQueryParam()),ms->ms.like(SystemUser::getUsername,systemUser.getUsername()) .or().like(SystemUser::getMobile,systemUser.getQueryParam()) .or().like(Company::getName,systemUser.getQueryParam()) .or().like(SystemUser::getRealname,systemUser.getQueryParam())) .eq( systemUser.getCompanyId() !=null,SystemUser::getCompanyId,systemUser.getCompanyId()) .eq( systemUser.getCompanyType() !=null,Company::getType,systemUser.getCompanyType()) .eq( systemUser.getWorkStatus() !=null,Member::getWorkStatus,systemUser.getWorkStatus()) .like(StringUtils.isNotBlank(systemUser.getRealname()),SystemUser::getRealname,systemUser.getRealname()) .like(StringUtils.isNotBlank(systemUser.getMobile()),SystemUser::getMobile,systemUser.getMobile()) .like(StringUtils.isNotBlank(systemUser.getUsername()),SystemUser::getUsername,systemUser.getUsername()) .like(StringUtils.isNotBlank(systemUser.getCompanyName()),Company::getName,systemUser.getCompanyName()) .apply(StringUtils.isNotBlank(systemUser.getCompanySpecialId())," find_in_set('"+systemUser.getCompanySpecialId()+"',REPLACE(t1.company_path,'/',','))") .orderByAsc( Company::getPinyin ) .orderByAsc(SystemUser::getPinyin) ; List result = systemUserJoinMapper.selectJoinList( SystemUser.class, wrapper); if(result!=null){ String prefixUrl = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_RESOURCE_PATH).getCode() + systemDictDataBiz.queryByCode(Constants.FTP,Constants.MEMBER_IMG).getCode(); for (SystemUser memberInfoDTO:result) { //拼接前缀 if (StringUtils.isNotBlank(memberInfoDTO.getFaceImg())) { memberInfoDTO.setFaceImg(prefixUrl + memberInfoDTO.getFaceImg()); } } } return result; } @Override public List findInternalList() { MPJLambdaWrapper queryWrapper = new MPJLambdaWrapper<>(); queryWrapper.selectAll(SystemUser.class); queryWrapper.eq(SystemUser::getDeleted, Constants.ZERO); queryWrapper.leftJoin(Company.class,Company::getId,SystemUser::getCompanyId); queryWrapper.eq(Company::getType,Constants.ONE); queryWrapper.orderByAsc(SystemUser::getPinyin); List result = systemUserJoinMapper.selectJoinList( SystemUser.class, queryWrapper); return result; } }