package com.ycl.platform.service.impl; import com.ycl.platform.base.BaseSelect; import com.ycl.platform.domain.entity.Region; import com.ycl.platform.domain.entity.YwUnit; import com.ycl.platform.domain.vo.RegionCascaderVO; import com.ycl.platform.mapper.RegionMapper; import com.ycl.platform.service.RegionService; import com.ycl.system.Result; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ycl.platform.domain.form.RegionForm; import com.ycl.platform.domain.vo.RegionVO; import com.ycl.platform.domain.query.RegionQuery; import java.util.Date; import java.util.List; import com.ycl.utils.DateUtils; import enumeration.general.RegionLevelEnum; import com.baomidou.mybatisplus.core.metadata.IPage; import com.ycl.system.page.PageUtil; import org.springframework.stereotype.Service; import org.springframework.security.core.context.SecurityContextHolder; import org.springframework.beans.BeanUtils; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.Assert; import java.util.ArrayList; import java.util.Objects; import java.util.stream.Collectors; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper; import lombok.RequiredArgsConstructor; import org.springframework.util.StringUtils; /** * 地域 服务实现类 * * @author xp * @since 2024-03-12 */ @Service @RequiredArgsConstructor public class RegionServiceImpl extends ServiceImpl implements RegionService { private final RegionMapper regionMapper; /** * 添加 * @param form * @return */ @Override public Result add(RegionForm form) { Region entity = RegionForm.getEntityByForm(form, null); entity.setRegionLevel(RegionLevelEnum.STREET); Date now = new Date(); entity.setCreateTime(now); entity.setUpdateTime(now); if(baseMapper.insert(entity) > 0) { return Result.ok("添加成功"); } return Result.error("添加失败"); } /** * 修改 * @param form * @return */ @Override public Result update(RegionForm form) { Region entity = baseMapper.selectById(form.getId()); // 为空抛IllegalArgumentException,做全局异常处理 Assert.notNull(entity, "记录不存在"); BeanUtils.copyProperties(form, entity); Date now = new Date(); entity.setUpdateTime(now); 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(RegionQuery query) { IPage page = new LambdaQueryChainWrapper<>(baseMapper) .like(StringUtils.hasText(query.getFullName()), Region::getFullName, query.getFullName()) .like(StringUtils.hasText(query.getSimpleName()), Region::getSimpleName, query.getSimpleName()) .eq(Objects.nonNull(query.getParentId()), Region::getParentId, query.getParentId()) .eq(StringUtils.hasText(query.getRegionLevel()), Region::getRegionLevel, query.getRegionLevel()) .between(Objects.nonNull(query.getStart()) && Objects.nonNull(query.getEnd()), Region::getCreateTime, DateUtils.getDayStart(query.getStart()), DateUtils.getDayEnd(query.getEnd())) .orderByDesc(Region::getCreateTime) .page(PageUtil.getPage(query, Region.class)); List vos = page.getRecords().stream() .map( entity -> RegionVO.getVoByEntity(entity, null) ) .collect(Collectors.toList()); return Result.ok().data(vos).total(page.getTotal()); } /** * 根据id查找 * @param id * @return */ @Override public Result detail(String id) { Region entity = baseMapper.selectById(id); Assert.notNull(entity, "记录不存在"); RegionVO vo = RegionVO.getVoByEntity(entity, null); return Result.ok().data(vo); } /** * 列表 * @return */ @Override public Result all() { List entities = baseMapper.selectList(null); List vos = entities.stream() .map( entity -> RegionVO.getVoByEntity(entity, null) ) .collect(Collectors.toList()); return Result.ok().data(vos); } @Override public Result counties() { List entityList = new LambdaQueryChainWrapper<>(baseMapper) .eq(Region::getRegionLevel, RegionLevelEnum.COUNTY) .orderByDesc(Region::getCreateTime) .list(); List vos = entityList.stream().map(entity -> { BaseSelect vo = new BaseSelect(); vo.setId(entity.getId()); vo.setValue(entity.getFullName()); return vo; }).collect(Collectors.toList()); return Result.ok().data(vos); } @Override public Result cascader() { List regionList = new LambdaQueryChainWrapper<>(baseMapper) .ne(Region::getRegionLevel, RegionLevelEnum.CITY) .list(); List vos = regionList.stream().map(entity -> { RegionCascaderVO vo = new RegionCascaderVO(); vo.setValue(entity.getId()); vo.setLabel(entity.getSimpleName()); vo.setRegionLevel(entity.getRegionLevel()); vo.setParentId(entity.getParentId()); return vo; }).collect(Collectors.toList()); List removeList = new ArrayList<>(12); for (RegionCascaderVO region : vos) { if (region.getRegionLevel() == RegionLevelEnum.COUNTY) { List childList = new ArrayList<>(12); for (RegionCascaderVO region1 : vos) { if (region1.getParentId() == region.getValue()) { childList.add(region1); removeList.add(region1); } } region.setChildren(childList); } } vos.removeAll(removeList); return Result.ok().data(vos); } }