| | |
| | | import org.springblade.core.tool.node.ForestNodeMerger; |
| | | import org.springblade.core.tool.utils.BeanUtil; |
| | | import org.springblade.core.tool.utils.Func; |
| | | import org.springblade.core.tool.utils.SpringUtil; |
| | | import org.springblade.core.tool.utils.StringPool; |
| | | import org.springblade.modules.community.entity.CommunityEntity; |
| | | import org.springblade.modules.community.service.ICommunityService; |
| | | import org.springblade.modules.grid.entity.GridEntity; |
| | | import org.springblade.modules.grid.service.IGridService; |
| | | import org.springblade.modules.property.entity.PropertyCompanyEntity; |
| | | import org.springblade.modules.property.service.IPropertyCompanyService; |
| | | import org.springblade.modules.system.entity.Dept; |
| | | import org.springblade.modules.system.entity.Region; |
| | | import org.springblade.modules.system.mapper.DeptMapper; |
| | | import org.springblade.modules.system.service.IDeptService; |
| | | import org.springblade.modules.system.service.IRegionService; |
| | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public Object dataHandle() { |
| | | // 查询未绑定的网格 |
| | | List<TreeStringNode> list = regionService.getTree(null); |
| | | // 查询所有的社区 |
| | | QueryWrapper<Region> queryWrapper = new QueryWrapper<>(); |
| | | queryWrapper.eq("district_code","361102").eq("region_level",5); |
| | | List<Region> list = regionService.list(queryWrapper); |
| | | // 遍历 |
| | | for (TreeStringNode treeStringNode : list) { |
| | | for (Region region : list) { |
| | | // 查询是否已创建 |
| | | QueryWrapper<Dept> wrapper = new QueryWrapper<>(); |
| | | wrapper.eq("is_deleted", 0).eq("dept_name", treeStringNode.getName()); |
| | | wrapper.eq("is_deleted", 0).eq("dept_name", region.getName()); |
| | | Dept one = getOne(wrapper); |
| | | if (null == one) { |
| | | // 新增 |
| | | Dept dept = new Dept(); |
| | | dept.setParentId(1733066387113734145L); |
| | | dept.setFullName(treeStringNode.getName()); |
| | | dept.setDeptName(treeStringNode.getName()); |
| | | dept.setFullName(region.getName()); |
| | | dept.setDeptName(region.getName()); |
| | | dept.setDeptCategory(1); |
| | | dept.setTenantId("000000"); |
| | | // 查询上级id |
| | | QueryWrapper<Dept> deptQueryWrapper = new QueryWrapper<>(); |
| | | deptQueryWrapper.eq("is_deleted", 0).eq("dept_name", region.getTownName()); |
| | | Dept parentDept = getOne(deptQueryWrapper); |
| | | if (null!=parentDept){ |
| | | dept.setParentId(parentDept.getId()); |
| | | dept.setAncestors(parentDept.getAncestors() + "," + parentDept.getId()); |
| | | } |
| | | dept.setRegionCode(region.getCode()); |
| | | // 新增 |
| | | save(dept); |
| | | saveOrUpdate(dept); |
| | | // 插入社区表数据 |
| | | } |
| | | } |
| | | return null; |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 数据处理(社区绑定)--处理机构 |
| | | */ |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public Object dataHandleCommunity() { |
| | | // 查询所有的社区 |
| | | QueryWrapper<Region> queryWrapper = new QueryWrapper<>(); |
| | | queryWrapper.eq("district_code","361102").eq("region_level",5); |
| | | List<Region> list = regionService.list(queryWrapper); |
| | | // 遍历 |
| | | for (Region region : list) { |
| | | // 查询是否已创建 |
| | | QueryWrapper<CommunityEntity> wrapper = new QueryWrapper<>(); |
| | | wrapper.eq("is_deleted", 0).eq("name", region.getName()); |
| | | CommunityEntity one = SpringUtil.getBean(ICommunityService.class).getOne(wrapper); |
| | | if (null == one) { |
| | | // 新增 |
| | | CommunityEntity communityEntity = new CommunityEntity(); |
| | | communityEntity.setStreetCode(region.getTownCode()); |
| | | communityEntity.setName(region.getName()); |
| | | communityEntity.setCode(region.getCode()); |
| | | // 新增 |
| | | SpringUtil.getBean(ICommunityService.class).save(communityEntity); |
| | | } |
| | | } |
| | | return null; |