package com.monkeylessey.sys.service.impl; import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.monkeylessey.sys.domain.entity.SysOrg; import com.monkeylessey.sys.domain.form.SysOrgForm; import com.monkeylessey.sys.domain.query.SysOrgQuery; import com.monkeylessey.sys.domain.tree.SysOrgTree; import com.monkeylessey.sys.domain.vo.SysMenuVO; import com.monkeylessey.sys.domain.vo.SysOrgVO; import com.monkeylessey.sys.mapper.SysOrgMapper; import com.monkeylessey.response.Result; import com.monkeylessey.sys.service.SysOrgService; import com.monkeylessey.utils.TreeUtil; import lombok.RequiredArgsConstructor; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.BeanUtils; import org.springframework.stereotype.Service; import org.springframework.util.Assert; import java.util.Comparator; import java.util.List; import java.util.Objects; import java.util.stream.Collectors; /** * 服务实现类 * * @author 向培 * @since 2023-11-25 */ @Service @RequiredArgsConstructor public class SysOrgServiceImpl extends ServiceImpl implements SysOrgService { private final SysOrgMapper sysOrgMapper; /** * 添加 * @param form * @return */ @Override public Result add(SysOrgForm form) { SysOrg entity = SysOrgForm.getEntityByForm(form, null); if(baseMapper.insert(entity) > 0) { return Result.ok("添加成功"); } return Result.error("添加失败"); } /** * 修改 * @param form * @return */ @Override public Result update(SysOrgForm form) { SysOrg entity = baseMapper.selectById(form.getId()); // 为空抛IllegalArgumentException,做全局异常处理 Assert.notNull(entity, "修改组织不存在"); // 不能将自己作为自己的上级组织 if (Objects.equals(form.getId(), form.getParentId())) { return Result.error("不能将自己作为自己的上级组织"); } BeanUtils.copyProperties(form, entity); if (baseMapper.updateById(entity) > 0) { return Result.ok("修改成功"); } return Result.error("修改失败"); } /** * 批量删除 * @param ids * @return */ @Override public Result remove(List ids) { if(baseMapper.deleteBatchIds(ids) > 0) { return Result.ok("删除成功"); } return Result.error("删除失败"); } /** * id删除 * @param id * @return */ @Override public Result removeById(String id) { if(baseMapper.deleteById(id) > 0) { return Result.ok("删除成功"); } return Result.error("删除失败"); } /** * 分页查询 * @param query * @return */ @Override public Result page(SysOrgQuery query) { List orgList = new LambdaQueryChainWrapper<>(baseMapper) .like(StringUtils.isNotBlank(query.getOrgName()), SysOrg::getOrgName, query.getOrgName()) .orderByAsc(SysOrg::getOrderNum) .list(); List vos = orgList.stream().map(org -> { SysOrgTree vo = SysOrgTree.getVoByEntity(org, null); if (StringUtils.isNotBlank(query.getId()) && vo.getId().equals(query.getId())) { vo.setDisabled(Boolean.TRUE); } return vo; }).collect(Collectors.toList()); List tree = TreeUtil.buildTree(vos); tree.sort(Comparator.comparing(SysOrgTree::getOrderNum)); return Result.ok().data(tree).total(tree.size()); } /** * 根据id查找 * @param id * @return */ @Override public Result detail(String id) { SysOrg entity = baseMapper.selectById(id); Assert.notNull(entity, "记录不存在"); SysOrgVO vo = SysOrgVO.getVoByEntity(entity, null); if (! "0".equals(entity.getParentId())) { SysOrg parent = new LambdaQueryChainWrapper<>(baseMapper) .eq(SysOrg::getId, entity.getParentId()) .select(SysOrg::getOrgName) .one(); vo.setParentName(parent.getOrgName()); } else { vo.setParentName("最高组织"); } return Result.ok().data(vo); } /** * 列表 * @return */ @Override public Result all() { List entities = baseMapper.selectList(null); List vos = entities.stream() .map( entity -> SysOrgVO.getVoByEntity(entity, null) ) .collect(Collectors.toList()); return Result.ok().data(vos); } }