From bdfb1bfaf5dc5d7318c632fcc6fdf3ffacbd075f Mon Sep 17 00:00:00 2001
From: lin <sbla5888@163.com>
Date: Mon, 15 Apr 2024 17:21:29 +0800
Subject: [PATCH] 社区管理员查询轮播图+报事报修查询优化

---
 src/main/java/org/springblade/modules/house/service/impl/HouseServiceImpl.java |  219 +++++++++++++++++++++++++++++++++++++++++-------------
 1 files changed, 166 insertions(+), 53 deletions(-)

diff --git a/src/main/java/org/springblade/modules/house/service/impl/HouseServiceImpl.java b/src/main/java/org/springblade/modules/house/service/impl/HouseServiceImpl.java
index 5de078b..ed8394d 100644
--- a/src/main/java/org/springblade/modules/house/service/impl/HouseServiceImpl.java
+++ b/src/main/java/org/springblade/modules/house/service/impl/HouseServiceImpl.java
@@ -17,6 +17,7 @@
 package org.springblade.modules.house.service.impl;
 
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@@ -49,6 +50,8 @@
 import org.springblade.modules.label.entity.LabelEntity;
 import org.springblade.modules.label.service.ILabelService;
 import org.springblade.modules.label.vo.LabelVO;
+import org.springblade.modules.place.excel.PlaceExcel;
+import org.springblade.modules.place.vo.PlaceVO;
 import org.springblade.modules.police.entity.PoliceAffairsGridEntity;
 import org.springblade.modules.police.service.IPoliceAffairsGridService;
 import org.springblade.modules.system.entity.Region;
@@ -214,7 +217,7 @@
 		if (null != houseParam.getRoleName() && !houseParam.getRoleName().equals("")) {
 			if (houseParam.getRoleName().equals("网格员")) {
 				// 查询对应的房屋地址code
-				stringList = gridService.getAddressCodeListByUserId(AuthUtil.getUserId());
+				stringList = gridService.getAddressCodeListByUserId(AuthUtil.getUserId(),null);
 			}
 		}
 		return stringList;
@@ -285,8 +288,27 @@
 				houseEntity.setHouseCode(IdUtils.getIdBy36());
 				houseEntity.setSource(2);
 			}
+			// 网格处理
+			importGridHandle(houseAndHoldExcel,houseEntity);
 			// 新增
 			save(houseEntity);
+		}else {
+			// 更新
+			one.setHouseName(houseAndHoldExcel.getHouseName());
+			one.setAddress(houseAndHoldExcel.getHouseName());
+			one.setDistrictName(houseAndHoldExcel.getDistrictName());
+			one.setUnit(houseAndHoldExcel.getUnit());
+			if (!Strings.isBlank(houseAndHoldExcel.getFloor())) {
+				one.setFloor(houseAndHoldExcel.getFloor());
+			}
+			one.setRoom(houseAndHoldExcel.getRoom());
+			one.setBuilding(houseAndHoldExcel.getBuilding());
+			one.setArea(houseAndHoldExcel.getArea());
+			one.setPropertyPrice(houseAndHoldExcel.getPropertyPrice());
+			// 网格处理
+			importGridHandle(houseAndHoldExcel,one);
+			// 更新
+			updateById(one);
 		}
 	}
 
@@ -301,7 +323,7 @@
 		QueryWrapper<HouseholdEntity> wrapper = new QueryWrapper<>();
 		wrapper.eq("house_code", houseAndHoldExcel.getHouseCode())
 			.eq("is_deleted", 0)
-			.eq("id_card", houseAndHoldExcel.getIdCard())
+			.eq("phone_number", houseAndHoldExcel.getPhoneNumber())
 			.eq("name", houseAndHoldExcel.getName());
 		HouseholdEntity one = householdService.getOne(wrapper);
 		// 不存在则插入,存在则不操作
@@ -420,27 +442,7 @@
 			// 新增
 			boolean save = householdService.save(householdEntity);
 			if (save) {
-				String labelId = houseAndHoldExcel.getLabelId();
-				if (StringUtils.isBlank(labelId)) {
-					return;
-				}
-				String[] split = labelId.split(",");
-				IUserHouseLabelService bean = SpringUtils.getBean(IUserHouseLabelService.class);
-				ILabelService bean1 = SpringUtils.getBean(ILabelService.class);
-				for (String s : split) {
-					LabelEntity one1 = bean1.getOne(Wrappers.<LabelEntity>lambdaQuery().eq(LabelEntity::getLabelName, s));
-					if (one1 != null) {
-						UserHouseLabelEntity userHouseLabelEntity = new UserHouseLabelEntity();
-						userHouseLabelEntity.setLabelId(BigDecimal.valueOf(one1.getId()).longValue());
-						userHouseLabelEntity.setHouseholdId(householdEntity.getId());
-						// 设置默认的绿色
-						userHouseLabelEntity.setColor("green");
-						userHouseLabelEntity.setLableType(1);
-						userHouseLabelEntity.setLabelName(s);
-						userHouseLabelEntity.setHouseCode(houseAndHoldExcel.getHouseCode());
-						bean.save(userHouseLabelEntity);
-					}
-				}
+				householdLabelHandle(houseAndHoldExcel, householdEntity);
 			}
 		} else {
 			// 更新
@@ -550,27 +552,107 @@
 			// 新增
 			boolean update = householdService.updateById(one);
 			if (update) {
-				String labelId = houseAndHoldExcel.getLabelId();
-				if (StringUtils.isBlank(labelId)) {
-					return;
+				// 住户标签处理
+				householdLabelHandle(houseAndHoldExcel,one);
+			}
+		}
+	}
+
+
+	/**
+	 * 导入是网格数据绑定处理
+	 * @param houseAndHoldExcel
+	 * @param houseEntity
+	 */
+	public void importGridHandle(HouseAndHoldExcel houseAndHoldExcel, HouseEntity houseEntity) {
+		if (!Strings.isBlank(houseAndHoldExcel.getCommunityName()) &&
+			!Strings.isBlank(houseAndHoldExcel.getGridName())){
+			// 查询对应的网格信息
+			GridEntity gridEntity = gridService.getGridInfoByParam(houseAndHoldExcel.getCommunityName(),houseAndHoldExcel.getGridName());
+			if (null!=gridEntity){
+				// 设置场所范围
+				houseEntity.setGridId(gridEntity.getId());
+				houseEntity.setGridCode(gridEntity.getGridCode());
+				// 更新网格范围绑定
+				GridRangeEntity gridRangeEntity = new GridRangeEntity();
+				gridRangeEntity.setGridId(gridEntity.getId());
+				gridRangeEntity.setGridCode(gridEntity.getGridCode());
+				gridRangeEntity.setHouseCode(houseEntity.getHouseCode());
+				UpdateWrapper<GridRangeEntity> updateWrapper = new UpdateWrapper<>();
+				updateWrapper.eq("house_code",houseEntity.getHouseCode());
+				gridRangeService.update(gridRangeEntity,updateWrapper);
+			}
+		}
+	}
+
+	/**
+	 * 住户标签处理
+	 * @param houseAndHoldExcel
+	 * @param householdEntity
+	 */
+	public void householdLabelHandle(HouseAndHoldExcel houseAndHoldExcel, HouseholdEntity householdEntity) {
+		String labelId = houseAndHoldExcel.getLabelId();
+		if (!StringUtils.isBlank(labelId)) {
+			String[] split = labelId.split(",");
+			IUserHouseLabelService bean = SpringUtils.getBean(IUserHouseLabelService.class);
+			ILabelService bean1 = SpringUtils.getBean(ILabelService.class);
+			for (String s : split) {
+				LabelEntity one1 = bean1.getOne(Wrappers.<LabelEntity>lambdaQuery().eq(LabelEntity::getLabelName, s));
+				if (one1 != null) {
+					UserHouseLabelEntity userHouseLabelEntity = new UserHouseLabelEntity();
+					userHouseLabelEntity.setLabelId(BigDecimal.valueOf(one1.getId()).longValue());
+					userHouseLabelEntity.setHouseholdId(householdEntity.getId());
+					// 设置默认的绿色
+					userHouseLabelEntity.setColor("green");
+					userHouseLabelEntity.setLableType(1);
+					userHouseLabelEntity.setLabelName(s);
+					userHouseLabelEntity.setHouseCode(houseAndHoldExcel.getHouseCode());
+					bean.save(userHouseLabelEntity);
 				}
-				String[] split = labelId.split(",");
-				IUserHouseLabelService bean = SpringUtils.getBean(IUserHouseLabelService.class);
-				ILabelService bean1 = SpringUtils.getBean(ILabelService.class);
-				for (String s : split) {
-					LabelEntity one1 = bean1.getOne(Wrappers.<LabelEntity>lambdaQuery().eq(LabelEntity::getLabelName, s));
-					if (one1 != null) {
-						UserHouseLabelEntity userHouseLabelEntity = new UserHouseLabelEntity();
-						userHouseLabelEntity.setLabelId(BigDecimal.valueOf(one1.getId()).longValue());
-						userHouseLabelEntity.setHouseholdId(one.getId());
-						userHouseLabelEntity.setLableType(1);
-						userHouseLabelEntity.setLabelName(s);
-						// 设置默认的绿色
-						userHouseLabelEntity.setColor("green");
-						userHouseLabelEntity.setHouseCode(houseAndHoldExcel.getHouseCode());
-						bean.save(userHouseLabelEntity);
-					}
+			}
+		}
+	}
+
+	/**
+	 * 住户业主信息处理,将业主人员插入到用户表
+	 *
+	 * @return
+	 */
+	public void userHandle(HouseholdEntity householdEntity) {
+		if (!Strings.isBlank(householdEntity.getPhoneNumber())) {
+			// 根据手机号查询对应账号和手机号的用户信息
+			List<User> userList = userService.getUserListByPhoneOrAccount(householdEntity.getPhoneNumber());
+			if (userList.size() > 0) {
+				User user = userList.get(0);
+				householdEntity.setAssociatedUserId(user.getId());
+				// 更新
+				householdService.updateById(householdEntity);
+				// 判断用户是否包含了居民角色,不包含则需更新
+				if (!user.getRoleId().contains("1717429059648606209")) {
+					user.setRoleId(user.getRoleId() + ",1717429059648606209");
+					//更新
+					userService.updateById(user);
 				}
+			} else {
+				// 插入用户信息
+				//如果用户不存在,则新增一个用户
+				User newUser = new User();
+				newUser.setAccount(householdEntity.getPhoneNumber());
+				newUser.setPhone(householdEntity.getPhoneNumber());
+				newUser.setName(householdEntity.getName());
+				newUser.setRealName(householdEntity.getName());
+				// 社区群众部门
+				newUser.setDeptId("1727979636479037441");
+				// 目前暂定居民角色,
+				newUser.setRoleId("1717429059648606209");
+				//默认密码为 123456
+				newUser.setPassword("123456");
+				// 用户新增
+				boolean submit = userService.submit(newUser);
+				// 更新绑定用户信息
+				householdEntity.setAssociatedUserId(newUser.getId());
+				// 更新
+				householdService.updateById(householdEntity);
 			}
 		}
 	}
@@ -628,13 +710,13 @@
 	 *
 	 * @param householdEntity
 	 */
+	@Transactional(rollbackFor = Exception.class)
 	public void saveOrUpdateUser(HouseholdEntity householdEntity) {
 		if (null != householdEntity.getPhoneNumber() && !householdEntity.getPhoneNumber().equals("")) {
 			//根据手机号查询库里的数据
-			User userParams = new User();
-			userParams.setPhone(householdEntity.getPhoneNumber());
-			User user = userService.getOne(Condition.getQueryWrapper(userParams));
-			if (null != user) {
+			List<User> list = userService.getUserListByPhoneOrAccount(householdEntity.getPhoneNumber());
+			if (list.size()>0) {
+				User user = list.get(0);
 				//如果用户存在,则该用户id绑定住户
 				householdEntity.setAssociatedUserId(user.getId());
 				// 判断用户是否包含了居民角色,不包含则需更新
@@ -704,18 +786,19 @@
 
 	@Override
 	public List<Map<String, Object>> labelStatistics(HouseVO house) {
-		List<String> regionChildCodesList = SysCache.getRegionChildCodesByDeptId(AuthUtil.getDeptId());
-		Integer isAdministrator = AuthUtil.isAdministrator() == true ? 1 : 2;
-		return baseMapper.labelStatistics(house, regionChildCodesList, isAdministrator);
+		CommonParamSet commonParamSet = new CommonParamSet<>().invoke(HouseVO.class, house);
+		return baseMapper.labelStatistics(house, commonParamSet.getRegionChildCodesList(), commonParamSet.getIsAdministrator());
 	}
 
 	@Override
 	public List<Map<String, Object>> labelCommunityStatistics(HouseVO house) {
-		List<String> regionChildCodesList = SysCache.getRegionChildCodesByDeptId(AuthUtil.getDeptId());
-		Integer isAdministrator = AuthUtil.isAdministrator() == true ? 1 : 2;
-		List<Map<String, Object>> list = baseMapper.labelCommunityStatistics(house, regionChildCodesList);
+		CommonParamSet commonParamSet = new CommonParamSet<>().invoke(HouseVO.class, house);
+		List<Map<String, Object>> list = baseMapper.labelCommunityStatistics(house, commonParamSet.getRegionChildCodesList());
 		for (Map<String, Object> map : list) {
-			List<LabelVO> code = baseMapper.getlabelCount(house, regionChildCodesList, isAdministrator, map.get("code").toString());
+			List<LabelVO> code = baseMapper.getlabelCount(house,
+				commonParamSet.getRegionChildCodesList(),
+				commonParamSet.getIsAdministrator(),
+				map.get("code").toString());
 			map.put("child",code);
 		}
 		return list;
@@ -781,4 +864,34 @@
 		// 返回
 		return list;
 	}
+
+	/**
+	 * 查询对应的社区编号
+	 * @param id
+	 * @return
+	 */
+	@Override
+	public String getCommunityCode(Long id) {
+		return baseMapper.getCommunityCode(id);
+	}
+
+	/**
+	 * 查询所有房屋总数
+	 * @return
+	 */
+	@Override
+	public int getAllListTotal() {
+		return baseMapper.getAllListTotal();
+	}
+
+	/**
+	 * 查询所有的房屋
+	 * @param i
+	 * @param size
+	 * @return
+	 */
+	@Override
+	public List<HouseVO> getAllList(int i, int size) {
+		return baseMapper.getAllList(i,size);
+	}
 }

--
Gitblit v1.9.3