From 566e7986291e73051d30ee252b0ebf852b1577a7 Mon Sep 17 00:00:00 2001
From: zhongrj <646384940@qq.com>
Date: Tue, 02 Apr 2024 14:25:51 +0800
Subject: [PATCH] 娱乐场所标签新增180200

---
 src/main/java/org/springblade/modules/house/service/impl/HouseholdServiceImpl.java |   55 ++++++++++++++++++++++++++++++++++++++++++++++++++-----
 1 files changed, 50 insertions(+), 5 deletions(-)

diff --git a/src/main/java/org/springblade/modules/house/service/impl/HouseholdServiceImpl.java b/src/main/java/org/springblade/modules/house/service/impl/HouseholdServiceImpl.java
index d7a3510..da26bcf 100644
--- a/src/main/java/org/springblade/modules/house/service/impl/HouseholdServiceImpl.java
+++ b/src/main/java/org/springblade/modules/house/service/impl/HouseholdServiceImpl.java
@@ -16,15 +16,19 @@
  */
 package org.springblade.modules.house.service.impl;
 
+import com.alibaba.fastjson.JSON;
 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 liquibase.repackaged.org.apache.commons.lang3.StringUtils;
 import org.apache.logging.log4j.util.Strings;
+import org.springblade.common.constant.CommonConstant;
 import org.springblade.common.node.TreeIntegerNode;
 import org.springblade.common.node.TreeStringNode;
 import org.springblade.common.param.CommonParamSet;
 import org.springblade.common.utils.NodeTreeUtil;
+import org.springblade.common.utils.SpringUtils;
 import org.springblade.core.mp.support.Condition;
 import org.springblade.core.secure.utils.AuthUtil;
 import org.springblade.core.tool.utils.BeanUtil;
@@ -38,6 +42,9 @@
 import org.springblade.modules.house.vo.HouseholdLabelVO;
 import org.springblade.modules.house.vo.HouseholdOtherVO;
 import org.springblade.modules.house.vo.HouseholdVO;
+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.entity.PlaceEntity;
 import org.springblade.modules.place.service.IPlaceService;
 import org.springblade.modules.system.entity.DictBiz;
@@ -81,12 +88,36 @@
 
 //		List<String> regionChildCodesList = SysCache.getRegionChildCodesByDeptId(AuthUtil.getDeptId());
 //		Integer isAdministrator = AuthUtil.isAdministrator()==true?1:2;
-
+		// 重点人员与关注人员
+		if (Objects.nonNull(household.getLabelType())) {
+			extracted(household);
+		}
 		List<HouseholdVO> householdVOS = baseMapper.selectHouseholdPage(page, household, commonParamSet.getIsAdministrator(),
 			commonParamSet.getRegionChildCodesList(), commonParamSet.getGridCodeList());
 		stopWatch.stop();
 //		System.out.println("selectHouseholdPage:" + stopWatch.getTotalTimeMillis());
 		return page.setRecords(householdVOS);
+	}
+
+	/**
+	 * 重点人员与关注人员
+	 * @param household
+	 */
+	private void extracted(HouseholdVO household) {
+		ILabelService iLabelService = SpringUtils.getBean(ILabelService.class);
+		if (CommonConstant.NUMBER_ONE.equals(household.getLabelType())) {
+			List<LabelEntity> list = iLabelService.list(Wrappers.<LabelEntity>lambdaQuery().eq(LabelEntity::getParentId, 103));
+			List<Integer> collect = list.stream().map(item ->
+				item.getId()
+			).collect(Collectors.toList());
+			household.setLabelIdList(collect);
+		} else if (CommonConstant.NUMBER_TWO.equals(household.getLabelType())) {
+			List<LabelEntity> list = iLabelService.list(Wrappers.<LabelEntity>lambdaQuery().eq(LabelEntity::getParentId, 1032));
+			List<Integer> collect = list.stream().map(item ->
+				item.getId()
+			).collect(Collectors.toList());
+			household.setLabelIdList(collect);
+		}
 	}
 
 	/**
@@ -297,13 +328,13 @@
 	 * @return
 	 */
 	@Override
-	public Integer statistics(Long userId, String neiCode,Integer confirmFlag) {
+	public Integer statistics(Long userId, String neiCode, Integer confirmFlag) {
 		HouseholdVO householdVO = new HouseholdVO();
 		householdVO.setConfirmFlag(confirmFlag);
-		householdVO.setNeiCode(neiCode);
+		householdVO.setCommunityCode(neiCode);
 		CommonParamSet commonParamSet = new CommonParamSet().invoke(HouseholdVO.class, householdVO);
 
-		return baseMapper.statistics(householdVO,commonParamSet.getIsAdministrator(),
+		return baseMapper.statistics(householdVO, commonParamSet.getIsAdministrator(),
 			commonParamSet.getRegionChildCodesList(), commonParamSet.getGridCodeList());
 	}
 
@@ -424,7 +455,7 @@
 		for (Long id : idList) {
 			HouseholdEntity householdEntity = getById(id);
 			// 如果是业主
-			if (householdEntity.getRelationship() == 1) {
+			if (null!= householdEntity.getRelationship() && householdEntity.getRelationship() == 1) {
 				// 查询对应的用户
 				User user = userService.getById(householdEntity.getAssociatedUserId());
 				// 判断是否还绑定其他的房屋,如果有,则不操作用户
@@ -551,4 +582,18 @@
 			node.setChildren(null);
 		}
 	}
+
+	/**
+	 * 通过小区id查询用户
+	 * @param householdVO
+	 * @param page
+	 * @return
+	 */
+	@Override
+	public IPage<HouseholdVO> getUserInfoByDistrictIds(HouseholdVO householdVO, IPage<HouseholdVO> page) {
+		List<String> list = JSON.parseArray(householdVO.getDistrictIds()).toJavaList(String.class);
+		List<HouseholdVO> userInfoByDistrictIds = baseMapper.getUserInfoByDistrictIds(list, householdVO, page);
+		return page.setRecords(userInfoByDistrictIds);
+	}
+
 }

--
Gitblit v1.9.3