From 7bbf08d2a38d91bf4a1cf278c52ff7303e05fdaf Mon Sep 17 00:00:00 2001
From: linwe <872216996@qq.com>
Date: Sat, 11 Nov 2023 18:11:06 +0800
Subject: [PATCH] 标签报事+通知公告

---
 src/main/java/org/springblade/modules/doorplateAddress/service/impl/DoorplateAddressServiceImpl.java |  210 +++++++++++++++++++++++++++++++++++++++++-----------
 1 files changed, 164 insertions(+), 46 deletions(-)

diff --git a/src/main/java/org/springblade/modules/doorplateAddress/service/impl/DoorplateAddressServiceImpl.java b/src/main/java/org/springblade/modules/doorplateAddress/service/impl/DoorplateAddressServiceImpl.java
index f9b6dd3..dadb38f 100644
--- a/src/main/java/org/springblade/modules/doorplateAddress/service/impl/DoorplateAddressServiceImpl.java
+++ b/src/main/java/org/springblade/modules/doorplateAddress/service/impl/DoorplateAddressServiceImpl.java
@@ -16,24 +16,20 @@
  */
 package org.springblade.modules.doorplateAddress.service.impl;
 
-import com.baomidou.mybatisplus.core.conditions.Wrapper;
-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import org.apache.poi.hssf.record.DVALRecord;
-import org.jetbrains.annotations.NotNull;
+import liquibase.repackaged.org.apache.commons.lang3.StringUtils;
+import org.springblade.common.constant.DictConstant;
 import org.springblade.common.node.TreeNode;
-import org.springblade.core.mp.support.Condition;
 import org.springblade.core.secure.utils.AuthUtil;
-import org.springblade.core.tool.utils.StringUtil;
 import org.springblade.modules.doorplateAddress.entity.DoorplateAddressEntity;
 import org.springblade.modules.doorplateAddress.mapper.DoorplateAddressMapper;
 import org.springblade.modules.doorplateAddress.service.IDoorplateAddressService;
-import org.springblade.modules.doorplateAddress.vo.DoorplateAddressVOTree;
 import org.springblade.modules.doorplateAddress.vo.DoorplateAddressVO;
+import org.springblade.modules.doorplateAddress.vo.DoorplateAddressVOTree;
 import org.springblade.modules.doorplateAddress.vo.FuncNode;
 import org.springblade.modules.house.service.IHouseRentalService;
-import org.springblade.modules.house.service.IHouseholdLabelService;
 import org.springblade.modules.house.service.IHouseholdService;
 import org.springblade.modules.house.vo.HouseParam;
 import org.springblade.modules.house.vo.HouseRentalVO;
@@ -41,12 +37,8 @@
 import org.springblade.modules.place.service.IPlaceService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
-import com.baomidou.mybatisplus.core.metadata.IPage;
 
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 import java.util.stream.Collectors;
 
 /**
@@ -75,7 +67,7 @@
 
 	/**
 	 * 根据角色获取功能集合数据
-	 * @param type 1:查区域  2:查场所  3:查房屋
+	 * @param type 1:查社区  2:查房屋和场所(居民角色)
 	 * @param roleName
 	 * @return
 	 */
@@ -89,31 +81,83 @@
 				List<TreeNode> townList = baseMapper.getRegionListByGroupTwon();
 				// 查询社区
 				List<TreeNode> neiList = baseMapper.getRegionListByGroupNei();
-				TreeNode node = townList.get(0);
-				node.setHasChildren(true);
 				// 遍历
-				for (TreeNode treeNode : neiList) {
-					treeNode.setHasChildren(false);
-					node.getChildren().add(treeNode);
+				for (TreeNode treeNode : townList) {
+					// 遍历
+					for (TreeNode node : neiList) {
+						if (treeNode.getId().equals(node.getParentId())){
+							node.setHasChildren(false);
+							treeNode.getChildren().add(node);
+						}
+					}
 				}
 				// 查询区域数据,当前只有西市街道数据
 				return townList;
 			}
-			// 如果是场所负责人
-			if (type==2){
-				// 查询场所集合信息
-				list = placeService.selectPlaceNodeList(AuthUtil.getUserId());
-				// 返回
-				return list;
-			}
 			// 如果是居民
-			if (type==3){
-				// 查询房屋集合信息
-				list = householdService.selectHouseNodeList(AuthUtil.getUserId());
-				// 返回
-				return list;
+			if (type==2 || type==3){
+				return getInhabitantInfo(list);
 			}
 		}
+		return list;
+	}
+
+	/**
+	 * 获取居民角色对应的房屋,场所信息
+	 * @param list
+	 * @return
+	 */
+	private Object getInhabitantInfo(List<TreeNode> list) {
+		// 查询房屋集合信息
+		List<TreeNode> houseNodeList = householdService.selectHouseNodeList(AuthUtil.getUserId());
+		for (TreeNode treeNode : houseNodeList) {
+			// 判断房屋类型类型
+			if (DictConstant.SMALL_DOORPLATE.equals(treeNode.getDoorplateType())  ||
+				(DictConstant.centre_DOORPLATE.equals(treeNode.getDoorplateType()) &&
+					treeNode.getAddressLevel().equals(1))) {
+				treeNode.setAddressType(2);
+			} else {
+				treeNode.setAddressType(1);
+			}
+		}
+		// 查询场所集合信息
+		List<TreeNode> placeNodeList = placeService.selectPlaceNodeList(AuthUtil.getUserId());
+		for (TreeNode treeNode : placeNodeList) {
+			treeNode.setAddressType(2);
+//			if (DictConstant.SMALL_DOORPLATE.equals(treeNode.getDoorplateType()) ||
+//				(DictConstant.centre_DOORPLATE.equals(treeNode.getDoorplateType()) &&
+//					treeNode.getAddressLevel().equals(1))) {
+//				treeNode.setAddressType(2);
+//			} else {
+//				treeNode.setAddressType(3);
+//			}
+		}
+		if (houseNodeList.size() > 0 && placeNodeList.size() > 0) {
+			// 合并
+			TreeNode houseNode = new TreeNode();
+			houseNode.setName("房屋");
+			houseNode.setId("1");
+			houseNode.setHasChildren(true);
+			houseNode.setChildren(houseNodeList);
+
+			TreeNode placeNode = new TreeNode();
+			placeNode.setName("场所");
+			placeNode.setId("2");
+			placeNode.setHasChildren(true);
+			placeNode.setChildren(placeNodeList);
+
+			list.add(houseNode);
+			list.add(placeNode);
+			// 返回
+			return list;
+		}
+		if (houseNodeList.size()>0){
+			list = houseNodeList;
+		}
+		if (placeNodeList.size()>0){
+			list = placeNodeList;
+		}
+		// 返回
 		return list;
 	}
 
@@ -193,8 +237,10 @@
 			List<TreeNode> shopList = new ArrayList<>();
 			// 根据社区名称查询楼栋或者商铺的集合
 			List<TreeNode> list = baseMapper.getBuildingList(houseParam.getName(),houseParam.getCode());
+			// 排序  StringUtils.getDigits(X.getName()) 取出数字排序
+			List<TreeNode> sortList = list.stream().sorted(Comparator.comparing(X -> StringUtils.getDigits(X.getName()))).collect(Collectors.toList());
 			if (list.size()>0){
-				for (TreeNode treeNode : list) {
+				for (TreeNode treeNode : sortList) {
 					if (treeNode.getAddressType()==1){
 						aoiList.add(treeNode);
 					}
@@ -240,24 +286,84 @@
 		}
 		// 处理,先按单元分组,再按楼层分组
 		if (aoiNodes.size()>0){
-			Map<String, List<FuncNode>> listMap = aoiNodes.stream().collect(Collectors.groupingBy(FuncNode::getFloor));
-			List<FuncNode> funcNodeList  = new ArrayList<>();
-			listMap.forEach((s, temps) -> {
-				FuncNode funcNode = new FuncNode();
-				funcNode.setFloor(s);
-				funcNode.setChildren(temps);
-				funcNode.setAddressType(1);
-				funcNodeList.add(funcNode);
-			});
-			FuncNode funcNode = new FuncNode();
-			funcNode.setUnitName("一单元");
-			funcNode.setChildren(funcNodeList);
-			funcNode.setAddressType(1);
-			list.add(funcNode);
+			// 按单元分组
+			Map<String, List<FuncNode>> listMap = aoiNodes.stream().collect(Collectors.groupingBy(FuncNode::getUnitName));
+			// 单个单元
+			oneUnitHandle(list, listMap);
+			// 多个单元
+			moreUnitHandle(list, listMap);
 		}
 		list.addAll(shopNodes);
 		// 返回
 		return list;
+	}
+
+	/**
+	 * 单个单元处理
+	 * @param list
+	 * @param listMap
+	 */
+	private void oneUnitHandle(List<FuncNode> list, Map<String, List<FuncNode>> listMap) {
+		if (listMap.size()==1){
+			Set<String> keySet = listMap.keySet();
+			// 获取第一个key
+			String firstKey = null;
+			for (String key : keySet) {
+				firstKey = key;
+				break;
+			}
+			if (firstKey.equals("未知单元")){
+				// 取出数据按楼层分组
+				List<FuncNode> unitList = listMap.get(firstKey);
+				Map<String, List<FuncNode>> floorListMap = unitList.stream().collect(Collectors.groupingBy(FuncNode::getFloor));
+				List<FuncNode> funcNodeList  = new ArrayList<>();
+				floorListMap.forEach((s, temps) -> {
+					FuncNode funcNode = new FuncNode();
+					funcNode.setFloor(s);
+					funcNode.setChildren(temps);
+					funcNode.setAddressType(1);
+					funcNodeList.add(funcNode);
+				});
+				FuncNode funcNode = new FuncNode();
+				funcNode.setUnitName("一单元");
+				funcNode.setChildren(funcNodeList);
+				funcNode.setAddressType(1);
+				list.add(funcNode);
+			}
+		}
+	}
+
+	/**
+	 * 多单元处理
+	 * @param list
+	 * @param listMap
+	 */
+	private void moreUnitHandle(List<FuncNode> list, Map<String, List<FuncNode>> listMap) {
+		// 不止一个单元
+		if (listMap.size()>1){
+			List<FuncNode> tempList = new ArrayList<>();
+			// 遍历
+			listMap.forEach((s, temps) -> {
+				FuncNode funcNode = new FuncNode();
+				funcNode.setUnitName(s);
+				funcNode.setAddressType(1);
+				// 按楼层分组
+				Map<String, List<FuncNode>> floorListMap = temps.stream().collect(Collectors.groupingBy(FuncNode::getFloor));
+				List<FuncNode> floorNodeList  = new ArrayList<>();
+				floorListMap.forEach((floor, houseList) -> {
+					FuncNode floorNode = new FuncNode();
+					floorNode.setFloor(floor);
+					floorNode.setChildren(houseList);
+					floorNode.setAddressType(1);
+					floorNodeList.add(floorNode);
+				});
+				funcNode.setChildren(floorNodeList);
+				tempList.add(funcNode);
+			});
+			// 排序
+			List<FuncNode> sortList = tempList.stream().sorted(Comparator.comparing(X -> X.getUnitName())).collect(Collectors.toList());
+			list.addAll(sortList);
+		}
 	}
 
 	/**
@@ -316,4 +422,16 @@
 		// 返回
 		return doorplateAddress;
 	}
+
+	@Override
+	public Object getHouseType(String code) {
+		DoorplateAddressEntity doorplateAddressEntity = baseMapper.selectOne(Wrappers.<DoorplateAddressEntity>lambdaQuery().eq(DoorplateAddressEntity::getAddressCode, code));
+		// 判断房屋信息是否住宅
+		if (doorplateAddressEntity.getDoorplateType().equals(DictConstant.SMALL_DOORPLATE) ||
+			(doorplateAddressEntity.getDoorplateType().equals(DictConstant.centre_DOORPLATE) &&
+				doorplateAddressEntity.getAddressLevel().equals(1))) {
+			return 1;
+		}
+		return 0;
+	}
 }

--
Gitblit v1.9.3