短信指定楼栋发送

linwe

2024-08-09 8b7258c9427882bb1798f1502eaa35184c6e374e

 src/main/java/org/springblade/modules/grid/service/impl/GridRangeServiceImpl.java

@@ -16,14 +16,22 @@
 */
package org.springblade.modules.grid.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springblade.modules.grid.entity.GridEntity;
import org.springblade.modules.grid.entity.GridRangeEntity;
import org.springblade.modules.grid.service.IGridService;
import org.springblade.modules.grid.vo.GridRangeVO;
import org.springblade.modules.grid.mapper.GridRangeMapper;
import org.springblade.modules.grid.service.IGridRangeService;
import org.springblade.core.mp.base.BaseServiceImpl;
import org.springblade.modules.grid.vo.GridVO;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.baomidou.mybatisplus.core.metadata.IPage;
import org.springframework.transaction.annotation.Transactional;

import java.util.List;

/**
 * 网格范围表 服务实现类
@@ -34,10 +42,53 @@
@Service
public class GridRangeServiceImpl extends ServiceImpl<GridRangeMapper, GridRangeEntity> implements IGridRangeService {

   @Autowired
   private IGridService gridService;

   @Override
   public IPage<GridRangeVO> selectGridRangePage(IPage<GridRangeVO> page, GridRangeVO gridRange) {
      return page.setRecords(baseMapper.selectGridRangePage(page, gridRange));
   }

   /**
    * 网格范围表数据处理
    */
   @Override
   @Transactional(rollbackFor = Exception.class)
   public Object dataHandle() {
      // 查询test 数据表数据
      List<GridVO> list = baseMapper.getTestGridData();
      // 匹配
      for (GridVO gridVO : list) {
         QueryWrapper<GridEntity> wrapper = new QueryWrapper<>();
         wrapper.eq("grid_name",gridVO.getGridName())
            .eq("community_name",gridVO.getCommunityName())
            .eq("is_deleted",0);
         GridEntity one = gridService.getOne(wrapper);
         if (null!=one){
            // 查询是否已存在绑定关系，已有则不新增
            QueryWrapper<GridRangeEntity> queryWrapper = new QueryWrapper<>();
            queryWrapper.eq("grid_id",one.getId()).eq("house_code",gridVO.getPrincipal());
            GridRangeEntity gridRangeEntity = getOne(queryWrapper);
            if (null== gridRangeEntity) {
               GridRangeEntity rangeEntity = new GridRangeEntity();
               rangeEntity.setGridId(one.getId());
               rangeEntity.setHouseCode(gridVO.getPrincipal());
               // 新增
               save(rangeEntity);
            }
         }
      }
      return null;
   }

   /**
    * 根据房屋查询对应的小区
    * @param houseCode
    * @return
    */
   @Override
   public String getDistrictIdByHouseCode(String houseCode) {
      return baseMapper.getDistrictIdByHouseCode(houseCode);
   }
}