| | |
| | | import com.baomidou.mybatisplus.extension.plugins.pagination.Page; |
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
| | | import com.sinata.common.constant.CacheConstants; |
| | | import com.sinata.common.core.domain.entity.SysUser; |
| | | import com.sinata.common.entity.PageDTO; |
| | | import com.sinata.common.exception.ServiceException; |
| | | import com.sinata.common.utils.BeanUtils; |
| | | import com.sinata.common.utils.CollUtils; |
| | | import com.sinata.common.utils.SecurityUtils; |
| | | import com.sinata.common.utils.StringUtils; |
| | | import com.sinata.system.domain.MwApplication; |
| | | import com.sinata.system.domain.SysDepartment; |
| | | import com.sinata.system.domain.SysDepartmentInfo; |
| | | import com.sinata.system.domain.SysUserDepartment; |
| | | import com.sinata.system.domain.dto.DisposalUnitDTO; |
| | | import com.sinata.system.domain.dto.MedicalInstitutionDTO; |
| | | import com.sinata.system.domain.dto.RegulatoryUnitDTO; |
| | |
| | | import com.sinata.system.domain.vo.SysDepartmentVO; |
| | | import com.sinata.system.enums.DepartmentEnum; |
| | | import com.sinata.system.mapper.SysDepartmentMapper; |
| | | import com.sinata.system.service.ISysUserService; |
| | | import com.sinata.system.service.SysDepartmentInfoService; |
| | | import com.sinata.system.service.SysDepartmentService; |
| | | import com.sinata.system.service.SysUserDepartmentService; |
| | | import lombok.RequiredArgsConstructor; |
| | | import org.jetbrains.annotations.NotNull; |
| | | import org.springframework.context.annotation.Lazy; |
| | | import org.springframework.data.redis.core.RedisTemplate; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | |
| | | * @since 2024-12-02 |
| | | */ |
| | | @Service |
| | | @RequiredArgsConstructor |
| | | @RequiredArgsConstructor(onConstructor_ = {@Lazy}) |
| | | public class SysDepartmentServiceImpl extends ServiceImpl<SysDepartmentMapper, SysDepartment> implements SysDepartmentService { |
| | | private final SysUserDepartmentService sysUserDepartmentService; |
| | | private final RedisTemplate<Object, Object> redisTemplate; |
| | | private final SysDepartmentInfoService sysDepartmentInfoService; |
| | | private final ISysUserService sysUserService; |
| | | /** |
| | | * 获取区域树 |
| | | * @return |
| | |
| | | childrenMap = getChildrenDepartmentByOrgType(myDepartment, null); |
| | | } |
| | | SysDepartmentVO sysDepartmentVO = fillChildrenTreeModel(myDepartment, childrenMap); |
| | | switch (type) { |
| | | case 2: |
| | | case 3: |
| | | case 4: |
| | | filterEmptyChildren(sysDepartmentVO.getChildren()); |
| | | break; |
| | | } |
| | | root.add(sysDepartmentVO); |
| | | return root; |
| | | } |
| | | |
| | | /** |
| | | * 移除子节点为空的区域 |
| | | * |
| | | * @param departments |
| | | */ |
| | | private void filterEmptyChildren(List<SysDepartmentVO> departments) { |
| | | if (departments == null) { |
| | | return; |
| | | } |
| | | |
| | | Iterator<SysDepartmentVO> iterator = departments.iterator(); |
| | | while (iterator.hasNext()) { |
| | | SysDepartmentVO department = iterator.next(); |
| | | |
| | | // 递归过滤子节点 |
| | | filterEmptyChildren(department.getChildren()); |
| | | |
| | | // 如果 orgType == 1 且 children 为空,则移除当前节点 |
| | | if (department.getOrgType() == 1 && department.getChildren().isEmpty()) { |
| | | iterator.remove(); |
| | | } |
| | | } |
| | | } |
| | | |
| | | /** |
| | |
| | | public List<SysDepartmentVO> getRegionTree(String keyword) { |
| | | List<SysDepartmentVO> root = new ArrayList<>(); |
| | | SysDepartment currentDepartment = getMyDepartment(); |
| | | if (Objects.isNull(currentDepartment)) { |
| | | return root; |
| | | } |
| | | if (!currentDepartment.getOrgType().equals(DepartmentEnum.REGION.getCode())) { |
| | | return root; |
| | | } |
| | | Map<Long, List<SysDepartment>> childrenMap = getChildrenDepartmentByOrgType(currentDepartment, Collections.singletonList(DepartmentEnum.REGION.getCode())); |
| | | SysDepartmentVO sysDepartmentVO = fillChildrenTreeModel(currentDepartment, childrenMap); |
| | | root.add(sysDepartmentVO); |
| | | if (StringUtils.isNotBlank(keyword)) { |
| | | treeMatch(root, keyword); |
| | | } |
| | | return root; |
| | | } |
| | | @Override |
| | | public List<SysDepartmentVO> getRegionTree1(String keyword) { |
| | | SysUser sysUser = SecurityUtils.getLoginUser().getUser(); |
| | | |
| | | List<SysDepartmentVO> root = new ArrayList<>(); |
| | | SysDepartment sysDepartment = this.baseMapper.selectById(sysUser.getDepartmentId()); |
| | | SysDepartment currentDepartment = this.baseMapper.selectById(sysDepartment.getParentId()); |
| | | if (Objects.isNull(currentDepartment)) { |
| | | return root; |
| | | } |
| | | if (!currentDepartment.getOrgType().equals(DepartmentEnum.REGION.getCode())) { |
| | | return root; |
| | | } |
| | | Map<Long, List<SysDepartment>> childrenMap = getChildrenDepartmentByOrgType(currentDepartment, Collections.singletonList(DepartmentEnum.REGION.getCode())); |
| | | SysDepartmentVO sysDepartmentVO = fillChildrenTreeModel(currentDepartment, childrenMap); |
| | | root.add(sysDepartmentVO); |
| | | if (StringUtils.isNotBlank(keyword)) { |
| | | treeMatch(root, keyword); |
| | | } |
| | | return root; |
| | | } |
| | | public List<SysDepartmentVO> getRegionTree2(String keyword) { |
| | | |
| | | List<SysDepartmentVO> root = new ArrayList<>(); |
| | | SysDepartment currentDepartment = this.baseMapper.selectById(-1); |
| | | if (Objects.isNull(currentDepartment)) { |
| | | return root; |
| | | } |
| | |
| | | SysDepartment department = BeanUtils.copyBean(dto, SysDepartment.class); |
| | | //获取部门树编码 |
| | | department.setOrgType(DepartmentEnum.REGION.getCode()); |
| | | department.setTreeCode(getTreeCode(dto.getParentId())); |
| | | department.setTreeCode(generateTreeCode(dto.getParentId())); |
| | | department.setOrgCode(getOrgCode(dto.getParentId(), DepartmentEnum.REGION.getCode())); |
| | | save(department); |
| | | } |
| | |
| | | SysDepartment sysDepartment = getById(dto.getId()); |
| | | if (!dto.getParentId().equals(sysDepartment.getParentId())) { |
| | | //获取部门树编码 |
| | | department.setTreeCode(getTreeCode(dto.getParentId())); |
| | | department.setTreeCode(generateTreeCode(dto.getParentId())); |
| | | } |
| | | updateById(department); |
| | | } |
| | |
| | | * @return |
| | | */ |
| | | @Override |
| | | public String getTreeCode(Long parentId) { |
| | | public String generateTreeCode(Long parentId) { |
| | | |
| | | String treeId; |
| | | String preTreeCode = ""; |
| | |
| | | .orderByDesc(SysDepartment::getCreateTime) |
| | | .list(); |
| | | List<Long> departmentIds = sysDepartmentList.stream().map(SysDepartment::getId).collect(Collectors.toList()); |
| | | Long count = sysUserDepartmentService.lambdaQuery().in(SysUserDepartment::getDepartmentId, departmentIds).count(); |
| | | Long count = sysUserService.lambdaQuery().in(SysUser::getDepartmentId, departmentIds).count(); |
| | | if (count > 0) { |
| | | throw new ServiceException("该区域已存在用户,无法删除"); |
| | | throw new ServiceException("该区域已关联用户,无法删除"); |
| | | } |
| | | removeById(id); |
| | | } |
| | |
| | | */ |
| | | @Override |
| | | public PageDTO<MedicalInstitutionVO> pageMedicalList(DepartmentQuery query) { |
| | | String treeCode = ""; |
| | | String treeCode; |
| | | if (Objects.isNull(query.getDepartmentId())) { |
| | | SysDepartment myDepartment = getMyDepartment(); |
| | | if (Objects.nonNull(myDepartment)) { |
| | | treeCode = myDepartment.getTreeCode(); |
| | | SysDepartment department = getMyDepartment(); |
| | | treeCode = department.getTreeCode(); |
| | | } else { |
| | | SysDepartment department = getById(query.getDepartmentId()); |
| | | //如果是处置单位,则获取父级部门 |
| | | if (department.getOrgType().equals(DepartmentEnum.DISPOSAL_UNIT.getCode())) { |
| | | department = getDepartmentByParentId(department.getParentId()); |
| | | } |
| | | treeCode = department.getTreeCode(); |
| | | } |
| | | Page<MedicalInstitutionVO> page = baseMapper.pageMedicalList(new Page<>(query.getPageCurr(), query.getPageSize()), query.getDepartmentId(), query.getDepartmentName(), query.getContactPerson(), query.getContactPhone(), treeCode); |
| | | if (StringUtils.isBlank(treeCode)) { |
| | | return PageDTO.empty(0L, 0L); |
| | | } |
| | | Page<MedicalInstitutionVO> page = baseMapper.pageMedicalList(new Page<>(query.getPageCurr(), query.getPageSize()), query.getDepartmentName(), query.getContactPerson(), query.getContactPhone(), treeCode); |
| | | return PageDTO.of(page); |
| | | } |
| | | |
| | |
| | | throw new ServiceException("医疗机构已存在"); |
| | | } |
| | | SysDepartment department = BeanUtils.copyBean(dto, SysDepartment.class); |
| | | department.setTreeCode(getTreeCode(parent.getId())); |
| | | department.setTreeCode(generateTreeCode(parent.getId())); |
| | | department.setOrgCode(getOrgCode(parent.getId(), DepartmentEnum.MEDICAL_INSTITUTION.getCode())); |
| | | department.setOrgType(DepartmentEnum.MEDICAL_INSTITUTION.getCode()); |
| | | //查询父级完整区域 |
| | |
| | | sysDepartmentInfoService.save(sysDepartmentInfo); |
| | | } |
| | | |
| | | /** |
| | | * 根据父级区域id查询处置单位列表 |
| | | * |
| | | * @param id |
| | | * @return |
| | | */ |
| | | @Override |
| | | public List<DisposalUnitVO> getDisposalUnitListByParentId(Long id) { |
| | | List<DisposalUnitVO> disposalUnitList = null; |
| | |
| | | } |
| | | |
| | | /** |
| | | * 获取完成区域 |
| | | * 获取完整区域 |
| | | * |
| | | * @param department |
| | | * @return |
| | | */ |
| | | private String getRegionName(SysDepartment department) { |
| | | @Override |
| | | public String getRegionName(SysDepartment department) { |
| | | String region = department.getDepartmentName(); |
| | | SysDepartment sysDepartment = this.lambdaQuery().eq(SysDepartment::getId, department.getParentId()).ne(SysDepartment::getId, -1).one(); |
| | | if (Objects.nonNull(sysDepartment)) { |
| | |
| | | } |
| | | SysDepartment department = BeanUtils.copyBean(dto, SysDepartment.class); |
| | | if (!department.getParentId().equals(sysDepartment.getParentId())) { |
| | | department.setTreeCode(getTreeCode(parent.getId())); |
| | | department.setTreeCode(generateTreeCode(parent.getId())); |
| | | //查询父级完整区域 |
| | | String region = getRegionName(parent); |
| | | department.setRegion(region); |
| | |
| | | */ |
| | | @Override |
| | | public void deleteMedical(Long id) { |
| | | Long count = sysUserDepartmentService.lambdaQuery().eq(SysUserDepartment::getDepartmentId, id).count(); |
| | | Long count = sysUserService.lambdaQuery().eq(SysUser::getDepartmentId, id).count(); |
| | | if (count > 0) { |
| | | throw new ServiceException("该医疗机构已存在用户,无法删除"); |
| | | throw new ServiceException("该医疗机构已关联用户,无法删除"); |
| | | } |
| | | removeById(id); |
| | | } |
| | |
| | | */ |
| | | @Override |
| | | public PageDTO<DisposalUnitVO> pageDisposalUnitList(DepartmentQuery query) { |
| | | String treeCode = ""; |
| | | if (Objects.isNull(query.getDepartmentId())) { |
| | | SysDepartment myDepartment = getMyDepartment(); |
| | | if (Objects.nonNull(myDepartment)) { |
| | | treeCode = myDepartment.getTreeCode(); |
| | | } |
| | | String treeCode = getTreeCodeByDepartmentId(query.getDepartmentId()); |
| | | if (StringUtils.isBlank(treeCode)) { |
| | | return PageDTO.empty(0L, 0L); |
| | | } |
| | | Page<DisposalUnitVO> page = baseMapper.pageRegulatoryUnitList(new Page<>(query.getPageCurr(), query.getPageSize()), query.getDepartmentId(), query.getDepartmentName(), query.getContactPerson(), query.getContactPhone(), treeCode); |
| | | return PageDTO.of(page); |
| | |
| | | throw new ServiceException("处置单位已存在"); |
| | | } |
| | | SysDepartment department = BeanUtils.copyBean(dto, SysDepartment.class); |
| | | department.setTreeCode(getTreeCode(parent.getId())); |
| | | department.setTreeCode(generateTreeCode(parent.getId())); |
| | | department.setOrgCode(getOrgCode(parent.getId(), DepartmentEnum.DISPOSAL_UNIT.getCode())); |
| | | department.setOrgType(DepartmentEnum.DISPOSAL_UNIT.getCode()); |
| | | //查询父级完整区域 |
| | |
| | | SysDepartment department = BeanUtils.copyBean(dto, SysDepartment.class); |
| | | |
| | | if (!department.getParentId().equals(sysDepartment.getParentId())) { |
| | | department.setTreeCode(getTreeCode(parent.getId())); |
| | | department.setTreeCode(generateTreeCode(parent.getId())); |
| | | //查询父级完整区域 |
| | | String region = getRegionName(parent); |
| | | department.setRegion(region); |
| | |
| | | |
| | | @Override |
| | | public void deleteDisposalUnit(Long id) { |
| | | Long count = sysUserDepartmentService.lambdaQuery().eq(SysUserDepartment::getDepartmentId, id).count(); |
| | | Long count = sysUserService.lambdaQuery().eq(SysUser::getDepartmentId, id).count(); |
| | | if (count > 0) { |
| | | throw new ServiceException("该处置单位构已存在用户,无法删除"); |
| | | throw new ServiceException("该处置单位构已关联用户,无法删除"); |
| | | } |
| | | removeById(id); |
| | | } |
| | |
| | | */ |
| | | @Override |
| | | public PageDTO<RegulatoryUnitVO> pageRegulatoryUnitList(DepartmentQuery query) { |
| | | String treeCode = ""; |
| | | if (Objects.isNull(query.getDepartmentId())) { |
| | | SysDepartment myDepartment = getMyDepartment(); |
| | | if (Objects.nonNull(myDepartment)) { |
| | | treeCode = myDepartment.getTreeCode(); |
| | | } |
| | | String treeCode = getTreeCodeByDepartmentId(query.getDepartmentId()); |
| | | if (StringUtils.isBlank(treeCode)) { |
| | | return PageDTO.empty(0L, 0L); |
| | | } |
| | | Page<SysDepartment> page = this.lambdaQuery().eq(Objects.nonNull(query.getDepartmentId()), SysDepartment::getParentId, query.getDepartmentId()) |
| | | .likeRight(StringUtils.isNotBlank(treeCode), SysDepartment::getTreeCode, treeCode) |
| | | .like(StringUtils.isNotEmpty(query.getDepartmentName()), SysDepartment::getDepartmentName, query.getDepartmentName()) |
| | | .like(StringUtils.isNotBlank(query.getContactPerson()), SysDepartment::getContactPerson, query.getContactPerson()) |
| | | .like(StringUtils.isNotBlank(query.getContactPhone()), SysDepartment::getContactPhone, query.getContactPhone()) |
| | | .eq(SysDepartment::getOrgType, DepartmentEnum.REGULATORY_UNIT.getCode()) |
| | | .page(new Page<>(query.getPageCurr(), query.getPageSize())); |
| | | return PageDTO.of(page, RegulatoryUnitVO.class); |
| | | } |
| | |
| | | throw new ServiceException("监管单位已存在"); |
| | | } |
| | | SysDepartment department = BeanUtils.copyBean(dto, SysDepartment.class); |
| | | department.setTreeCode(getTreeCode(parent.getId())); |
| | | department.setTreeCode(generateTreeCode(parent.getId())); |
| | | department.setOrgCode(getOrgCode(parent.getId(), DepartmentEnum.REGULATORY_UNIT.getCode())); |
| | | department.setOrgType(DepartmentEnum.REGULATORY_UNIT.getCode()); |
| | | //查询父级完整区域 |
| | |
| | | SysDepartment department = BeanUtils.copyBean(dto, SysDepartment.class); |
| | | |
| | | if (!department.getParentId().equals(sysDepartment.getParentId())) { |
| | | department.setTreeCode(getTreeCode(parent.getId())); |
| | | department.setTreeCode(generateTreeCode(parent.getId())); |
| | | //查询父级完整区域 |
| | | String region = getRegionName(parent); |
| | | department.setRegion(region); |
| | |
| | | */ |
| | | @Override |
| | | public void deleteRegulatoryUnit(Long id) { |
| | | Long count = sysUserDepartmentService.lambdaQuery().eq(SysUserDepartment::getDepartmentId, id).count(); |
| | | Long count = sysUserService.lambdaQuery().eq(SysUser::getDepartmentId, id).count(); |
| | | if (count > 0) { |
| | | throw new ServiceException("该监管单位构已存在用户,无法删除"); |
| | | throw new ServiceException("该监管单位构已关联用户,无法删除"); |
| | | } |
| | | removeById(id); |
| | | } |
| | | |
| | | /** |
| | | * 根据部门id获取树编码,如果为空则获取当前登录用户所在区域树编码 |
| | | * |
| | | * @param departmentId |
| | | * @return |
| | | */ |
| | | @Override |
| | | public String getTreeCodeByDepartmentId(Long departmentId) { |
| | | SysDepartment department; |
| | | if (Objects.isNull(departmentId)) { |
| | | department = getMyDepartment(); |
| | | } else { |
| | | department = getById(departmentId); |
| | | } |
| | | if (Objects.nonNull(department)) { |
| | | return department.getTreeCode(); |
| | | } |
| | | return null; |
| | | } |
| | | |
| | | /** |
| | | * 路线关联医院列表 |
| | | * |
| | | * @param id |
| | | * @return |
| | | */ |
| | | @Override |
| | | public List<MedicalInstitutionVO> getHospitalListByRouteId(Long id) { |
| | | return baseMapper.getHospitalListByRouteId(id); |
| | | } |
| | | |
| | | /** |
| | | * 创建机构 |
| | | * |
| | | * @param mwApplication |
| | | */ |
| | | @Override |
| | | public void createDepartment(MwApplication mwApplication) { |
| | | SysDepartment parent = this.getById(mwApplication.getDepartmentId()); |
| | | if (Objects.isNull(parent)) { |
| | | throw new ServiceException("找不到对应父级组织"); |
| | | } |
| | | SysDepartment department = new SysDepartment(); |
| | | department.setParentId(mwApplication.getDepartmentId()); |
| | | department.setDepartmentName(mwApplication.getUnitName()); |
| | | department.setContactPerson(mwApplication.getConcat()); |
| | | department.setContactPhone(mwApplication.getPhone()); |
| | | department.setOrgType(mwApplication.getUnitType().equals(1) ? DepartmentEnum.MEDICAL_INSTITUTION.getCode() : DepartmentEnum.DISPOSAL_UNIT.getCode()); |
| | | department.setRegion(mwApplication.getRegion()); |
| | | department.setRelation(mwApplication.getRelation()); |
| | | department.setTreeCode(generateTreeCode(parent.getId())); |
| | | department.setOrgCode(getOrgCode(parent.getId(), department.getOrgType())); |
| | | save(department); |
| | | } |
| | | } |