/* * Copyright (c) 2018-2028, Chill Zhuang All rights reserved. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions are met: * * Redistributions of source code must retain the above copyright notice, * this list of conditions and the following disclaimer. * Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the following disclaimer in the * documentation and/or other materials provided with the distribution. * Neither the name of the dreamlu.net developer nor the names of its * contributors may be used to endorse or promote products derived from * this software without specific prior written permission. * Author: Chill 庄骞 (smallchill@163.com) */ 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; /** * 网格范围表 服务实现类 * * @author BladeX * @since 2023-10-28 */ @Service public class GridRangeServiceImpl extends ServiceImpl implements IGridRangeService { @Autowired private IGridService gridService; @Override public IPage selectGridRangePage(IPage page, GridRangeVO gridRange) { return page.setRecords(baseMapper.selectGridRangePage(page, gridRange)); } /** * 网格范围表数据处理 */ @Override @Transactional(rollbackFor = Exception.class) public Object dataHandle() { // 查询test 数据表数据 List list = baseMapper.getTestGridData(); // 匹配 for (GridVO gridVO : list) { QueryWrapper 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 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; } }