package com.gkhy.fourierSpecialGasMonitor.domain.account.service.impl;
|
|
import cn.hutool.core.util.ObjectUtil;
|
import com.gkhy.fourierSpecialGasMonitor.commons.enums.ResultCode;
|
import com.gkhy.fourierSpecialGasMonitor.commons.exception.BusinessException;
|
import com.gkhy.fourierSpecialGasMonitor.domain.account.converter.SysDeparmentConverter;
|
import com.gkhy.fourierSpecialGasMonitor.domain.account.entity.SysDepartment;
|
import com.gkhy.fourierSpecialGasMonitor.domain.account.model.bo.SysDepartmentBO;
|
import com.gkhy.fourierSpecialGasMonitor.domain.account.model.dto.SysDepartmentDomainDTO;
|
import com.gkhy.fourierSpecialGasMonitor.domain.account.repository.jpa.SysDeparmentRepository;
|
import com.gkhy.fourierSpecialGasMonitor.domain.account.service.SysDepartmentDomainService;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.util.CollectionUtils;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
/**
|
* @email 1603559716@qq.com
|
* @author: zf
|
* @date: 2023/3/7
|
* @time: 17:18
|
*/
|
@Service
|
public class SysDepartmentDomainServiceImpl implements SysDepartmentDomainService {
|
|
@Autowired
|
private SysDeparmentRepository repository;
|
|
@Autowired
|
private SysDeparmentConverter converter;
|
|
@Override
|
public SysDepartmentDomainDTO save(SysDepartmentBO sysDepartmentBO,Long currentUserId) {
|
if (ObjectUtil.isEmpty(sysDepartmentBO.getDepName())) {
|
throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR.getCode(),"请填写部门名称");
|
}
|
byte depLevel = 0;
|
if(ObjectUtil.isEmpty(sysDepartmentBO.getParentId())){
|
depLevel = 1;
|
}
|
if (!ObjectUtil.isEmpty(sysDepartmentBO.getParentId())) {
|
//验证父级部门
|
SysDepartment parentDep = repository.findByIdAndDeleteStatus(sysDepartmentBO.getParentId());
|
if(ObjectUtil.isEmpty(parentDep)){
|
throw new BusinessException(this.getClass(), ResultCode.BUSINESS_ERROR_DATA_NOT_EXISIST.getCode(),"父级部门不存在！");
|
}
|
depLevel = (byte)(parentDep.getLevel()+1);
|
}
|
|
//复制
|
SysDepartment sysDepartment = new SysDepartment();
|
BeanUtils.copyProperties(sysDepartmentBO,sysDepartment);
|
sysDepartment.setDeleteStatus((byte)0);
|
sysDepartment.setLevel(depLevel);
|
sysDepartment.setCreateByUserId(currentUserId);
|
sysDepartment.setUpdateByUserId(currentUserId);
|
SysDepartmentDomainDTO sysDepartmentDomainDTO = converter.sysDepDomainDTOConverter(repository.save(sysDepartment));
|
|
return sysDepartmentDomainDTO;
|
}
|
|
@Override
|
public SysDepartmentDomainDTO update(SysDepartmentBO sysDepartmentBO,Long currentUserId) {
|
if (ObjectUtil.isEmpty(sysDepartmentBO.getId())) {
|
throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR.getCode(),"主键不可为空！");
|
}
|
if (ObjectUtil.isEmpty(sysDepartmentBO.getDepName())) {
|
throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR.getCode(),"请填写部门名称");
|
}
|
SysDepartment sysDepartment = repository.findByIdAndDeleteStatus(sysDepartmentBO.getId());
|
if(sysDepartment == null){
|
throw new BusinessException(this.getClass(), ResultCode.BUSINESS_ERROR_DATA_NOT_EXISIST.getCode(),"该部门不存在，不可修改！");
|
}
|
|
//复制
|
sysDepartment.setDepName(sysDepartmentBO.getDepName());
|
sysDepartment.setUpdateByUserId(currentUserId);
|
sysDepartment.setInfo(sysDepartmentBO.getInfo());
|
SysDepartmentDomainDTO sysDepartmentDomainDTO = converter.sysDepDomainDTOConverter(repository.save(sysDepartment));
|
return sysDepartmentDomainDTO;
|
}
|
|
@Override
|
public SysDepartmentDomainDTO delete(Long id, Long currentUserId) {
|
SysDepartment sysDepartment = repository.findByIdAndDeleteStatus(id);
|
if(sysDepartment == null){
|
throw new BusinessException(this.getClass(), ResultCode.BUSINESS_ERROR_DATA_NOT_EXISIST.getCode(),"该部门不存在，不可修改！");
|
}
|
//验证该部门下子部门
|
if (!checkDepChildren(id)) {
|
throw new BusinessException(this.getClass(), ResultCode.BUSINESS_ERROR_NOT_ALLOWED.getCode(),"该部门存在子部门，请先删除子部门！");
|
}
|
sysDepartment.setDeleteStatus((byte)1);
|
SysDepartmentDomainDTO sysDepartmentDomainDTO = converter.sysDepDomainDTOConverter(repository.save(sysDepartment));
|
return sysDepartmentDomainDTO;
|
}
|
@Override
|
public SysDepartmentDomainDTO findById(Long id){
|
if(ObjectUtil.isEmpty(id)){
|
throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR.getCode(),"主键不可为空！");
|
}
|
SysDepartment sysDepartment = repository.findByIdAndDeleteStatus(id);
|
SysDepartmentDomainDTO sysDepartmentDomainDTO = converter.sysDepDomainDTOConverter(sysDepartment);
|
return sysDepartmentDomainDTO;
|
}
|
|
|
@Override
|
public List<SysDepartmentDomainDTO> list() {
|
List<SysDepartment> list = repository.findByDeleteStatus();
|
List<SysDepartment> parentList = list.stream().filter(item -> item.getParentId() == null).collect(Collectors.toList());
|
List<SysDepartment> childList = list.stream().filter(item -> item.getParentId() != null).collect(Collectors.toList());
|
List<SysDepartmentDomainDTO> departmentDomainDTOList = new ArrayList<>();
|
if(parentList.size() > 0){
|
for(SysDepartment sysDepartment : parentList){
|
SysDepartmentDomainDTO sysDepartmentDomainDTO = converter.sysDepDomainDTOConverter(sysDepartment);
|
sysDepartmentDomainDTO.setChildren(recursion(sysDepartmentDomainDTO.getId(), childList));
|
departmentDomainDTOList.add(sysDepartmentDomainDTO);
|
}
|
}
|
return departmentDomainDTOList;
|
}
|
private List<SysDepartmentDomainDTO> recursion(Long parentId,List<SysDepartment> list){
|
List<SysDepartment> childList = list.stream().filter(item -> item.getParentId().equals(parentId)).collect(Collectors.toList());
|
List<SysDepartmentDomainDTO> departmentDomainDTOList = new ArrayList<>();
|
if(childList.size() > 0){
|
for(SysDepartment sysDepartment : childList){
|
SysDepartmentDomainDTO sysDepartmentDomainDTO = converter.sysDepDomainDTOConverter(sysDepartment);
|
sysDepartmentDomainDTO.setChildren(recursion(sysDepartmentDomainDTO.getId(), list));
|
departmentDomainDTOList.add(sysDepartmentDomainDTO);
|
}
|
}
|
return departmentDomainDTOList;
|
}
|
|
|
|
//验证部门
|
private boolean checkDep(Long id){
|
if(ObjectUtil.isEmpty(id)){
|
return false;
|
}
|
SysDepartment dep = repository.findByIdAndDeleteStatus(id);
|
if(ObjectUtil.isEmpty(dep)){
|
return false;
|
}
|
return true;
|
}
|
//验证部门是否存在子部门
|
private boolean checkDepChildren(Long parentId){
|
if (ObjectUtil.isEmpty(parentId)) {
|
return false;
|
}
|
List<SysDepartment> list = repository.findByParentIdAndDeleteStatus(parentId);
|
if(!CollectionUtils.isEmpty(list)){
|
return false;
|
}
|
return true;
|
}
|
|
|
}
|
