From 8b7258c9427882bb1798f1502eaa35184c6e374e Mon Sep 17 00:00:00 2001
From: linwe <872216996@qq.com>
Date: Fri, 09 Aug 2024 14:29:18 +0800
Subject: [PATCH] 短信指定楼栋发送
---
src/main/java/org/springblade/modules/grid/service/impl/GridRangeServiceImpl.java | 51 +++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 51 insertions(+), 0 deletions(-)
diff --git a/src/main/java/org/springblade/modules/grid/service/impl/GridRangeServiceImpl.java b/src/main/java/org/springblade/modules/grid/service/impl/GridRangeServiceImpl.java
index e0bdfed..681caf4 100644
--- a/src/main/java/org/springblade/modules/grid/service/impl/GridRangeServiceImpl.java
+++ b/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);
+ }
}
--
Gitblit v1.9.3