From b3362ed634780027ff5e726c7eb15c0ca7c5d795 Mon Sep 17 00:00:00 2001
From: zhongrj <646384940@qq.com>
Date: Tue, 30 Jan 2024 09:47:22 +0800
Subject: [PATCH] 社区民警处理

---
 src/main/java/org/springblade/modules/system/service/impl/DeptServiceImpl.java |   61 ++++++++++++++++++++++++++----
 1 files changed, 53 insertions(+), 8 deletions(-)

diff --git a/src/main/java/org/springblade/modules/system/service/impl/DeptServiceImpl.java b/src/main/java/org/springblade/modules/system/service/impl/DeptServiceImpl.java
index 379fdf6..cd269ee 100644
--- a/src/main/java/org/springblade/modules/system/service/impl/DeptServiceImpl.java
+++ b/src/main/java/org/springblade/modules/system/service/impl/DeptServiceImpl.java
@@ -29,12 +29,16 @@
 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;
@@ -312,24 +316,65 @@
 	@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;

--
Gitblit v1.9.3