package com.doumee.service.system.impl; import com.baomidou.mybatisplus.core.conditions.Wrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.doumee.biz.system.SystemDictDataBiz; import com.doumee.core.model.PageData; import com.doumee.core.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.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.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; 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; @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) { Wrapper wrapper = new QueryWrapper<>(systemUser); return systemUserMapper.selectList(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 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 pageWrap) { MPJLambdaWrapper queryWrapper = new MPJLambdaWrapper<>(); Utils.MP.blankToNull(pageWrap); queryWrapper.selectAll(SystemUser.class); queryWrapper.eq(SystemUser::getDeleted, Constants.ZERO); queryWrapper.and(StringUtils.isNotBlank(pageWrap.getUsername()),ms->ms.like(SystemUser::getUsername,pageWrap.getUsername()) .or().like(SystemUser::getMobile,pageWrap.getUsername()) .or().like(SystemUser::getRealname,pageWrap.getUsername()) ); queryWrapper.orderByDesc(SystemUser::getCreateTime); List result = systemUserJoinMapper.selectJoinList( SystemUser.class, queryWrapper); 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.orderByDesc(SystemUser::getCreateTime); List result = systemUserJoinMapper.selectJoinList( SystemUser.class, queryWrapper); return result; } }