From f454d6e5379960b3592bc5dad3c0c60f72966dc3 Mon Sep 17 00:00:00 2001
From: tangxiaobao <303826152@qq.com>
Date: 星期二, 20 七月 2021 11:23:30 +0800
Subject: [PATCH] 社区后台基础数据库bug修改

---
 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComMngPopulationServiceImpl.java |   51 +++++++++++++++++++++++++++++++++++++++------------
 1 files changed, 39 insertions(+), 12 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComMngPopulationServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComMngPopulationServiceImpl.java
index 2f71757..3d34adf 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComMngPopulationServiceImpl.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComMngPopulationServiceImpl.java
@@ -11,6 +11,7 @@
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.google.common.base.Joiner;
 import com.google.common.collect.Lists;
+import com.panzhihua.common.constants.Constants;
 import com.panzhihua.common.enums.*;
 import com.panzhihua.common.exceptions.ServiceException;
 import com.panzhihua.common.model.dtos.community.*;
@@ -180,10 +181,18 @@
 //        if (!comMngFamilyInfoVOS.isEmpty()) {
 //            comMngPopulationVO.setComMngFamilyInfoVOS(comMngFamilyInfoVOS);
 //        }
+        //查询户主关系信息
+        List<ComHouseMemberVo> comMngFamilyInfoVOS = populationDAO.listHouseMermberByPopuId(comMngPopulationDO.getId());
+        if (!comMngFamilyInfoVOS.isEmpty()) {
+            for (ComHouseMemberVo comHouseMemberVo : comMngFamilyInfoVOS){
+                comHouseMemberVo.setAge(AgeUtils.getAgeFromBirthTimes(comHouseMemberVo.getBirthDay()));
+            }
+            comMngPopulationVO.setComMngFamilyInfoVOS(comMngFamilyInfoVOS);
+        }
         //设置户主关系
-        ComMngPopulationHouseUserDO comMngPopulationHouseUserDO = comMngPopulationHouseUserDAO.selectOne((new QueryWrapper<ComMngPopulationHouseUserDO>().lambda().eq(ComMngPopulationHouseUserDO::getPopulId, populationId)));
-        if (comMngPopulationHouseUserDO != null) {
-            comMngPopulationVO.setRelation(comMngPopulationHouseUserDO.getRelation());
+        List<ComMngPopulationHouseUserDO> comMngPopulationHouseUserDOS = comMngPopulationHouseUserDAO.selectList((new QueryWrapper<ComMngPopulationHouseUserDO>().lambda().eq(ComMngPopulationHouseUserDO::getPopulId, populationId)));
+        if (!comMngPopulationHouseUserDOS.isEmpty()) {
+            comMngPopulationVO.setRelation(comMngPopulationHouseUserDOS.get(comMngPopulationHouseUserDOS.size() - 1).getRelation());
         }
         //设置年龄
         if (StringUtils.isNotEmpty(comMngPopulationVO.getBirthday())) {
@@ -276,14 +285,14 @@
         }
 
         if (StringUtils.isNotEmpty(comMngPopulationVO.getAgeStart())) {
-            String ageStartTime = DateUtils.getDateFormatString(DateUtils.yearAddNum(new Date(), -(Integer.parseInt(comMngPopulationVO.getAgeStart()) + 1)), "yyyy-MM-dd");
+            String ageStartTime = DateUtils.getDateFormatString(DateUtils.yearAddNum(new Date(), -(Integer.parseInt(comMngPopulationVO.getAgeStart()))), "yyyy-MM-dd");
             if (StringUtils.isNotEmpty(ageStartTime)) {
                 comMngPopulationVO.setAgeStartTime(ageStartTime);
             }
         }
 
         if (StringUtils.isNotEmpty(comMngPopulationVO.getAgeEnd())) {
-            String ageEndTime = DateUtils.getDateFormatString(DateUtils.yearAddNum(new Date(), -(Integer.parseInt(comMngPopulationVO.getAgeEnd()) + 1)), "yyyy-MM-dd");
+            String ageEndTime = DateUtils.getDateFormatString(DateUtils.yearAddNum(new Date(), -(Integer.parseInt(comMngPopulationVO.getAgeEnd()))), "yyyy-MM-dd");
             if (StringUtils.isNotEmpty(ageEndTime)) {
                 comMngPopulationVO.setAgeEndTime(ageEndTime);
             }
@@ -407,7 +416,7 @@
             if (populationDO == null) {
                 //不存在实有人口,则新增
                 populationDO = savePopulationDO(vo, comActDO, comMngVillageDO);
-                ComMngPopulationHouseUserDO comMngPopulationHouseUserDO = savePopulationHouseUser(vo, populationDO, populationHouseDO);
+//                ComMngPopulationHouseUserDO comMngPopulationHouseUserDO = savePopulationHouseUser(vo, populationDO, populationHouseDO);
             } else {
                 //如果存在人口信息,且是自用房,则更新人口默认的房屋信息
                 if (vo.getIsRent() != null && vo.getIsRent().equals(PopulHouseUseEnum.SELF.getCode())) {
@@ -466,6 +475,19 @@
         BeanUtils.copyProperties(vo, populationDO);
         populationDO.setId(Snowflake.getId());
         List<String> userTag = vo.getUserTagStr().stream().map(userTagStr -> userTagStr.split("\\(")[0]).collect(Collectors.toList());
+        //查询当前社区标签列表
+        List<String> list = new ArrayList<>();
+        List<ComMngUserTagDO> comMngUserTagDOS = comMngUserTagDAO.selectList(new QueryWrapper<ComMngUserTagDO>().eq("sys_flag", 1).or().eq("community_id", comActDO.getCommunityId()));
+        if (!ObjectUtils.isEmpty(comMngUserTagDOS)) {
+            list = comMngUserTagDOS.stream().map(comMngUserTagDO -> comMngUserTagDO.getTagName()).collect(Collectors.toList());
+        }
+        //如果导入数据标签中有当前社区标签列表中不包含的标签,则删除
+        Iterator<String> iterator = userTag.iterator();
+        while (iterator.hasNext()) {
+            String s = iterator.next();
+            if (!list.contains(s))
+                iterator.remove();
+        }
         populationDO.setVillageId(comMngVillageDO.getVillageId());
         populationDO.setActId(comActDO.getCommunityId());
         populationDO.setStreetId(comActDO.getStreetId());
@@ -770,13 +792,18 @@
             }
         }
 
-        //查询当前用户所有戶主关系
-        List<Integer> relations = comMngPopulationHouseUserDAO.getPopulationRelationByUserId(vo.getId());
-        if (!relations.isEmpty()) {
-            ComMngPopulationHouseUserDO comMngPopulationHouseUserDO = comMngPopulationHouseUserDAO.selectOne(new QueryWrapper<ComMngPopulationHouseUserDO>().lambda()
-                    .eq(ComMngPopulationHouseUserDO::getPopulId, vo.getId()));
-            comMngPopulationHouseUserDO.setRelation(relations.get(relations.size() - 1));
+        ComMngPopulationHouseUserDO comMngPopulationHouseUserDO = comMngPopulationHouseUserDAO.selectOne(new QueryWrapper<ComMngPopulationHouseUserDO>().lambda()
+                .eq(ComMngPopulationHouseUserDO::getPopulId, vo.getId()));
+        if (comMngPopulationHouseUserDO != null) {
+            comMngPopulationHouseUserDO.setRelation(vo.getRelation());
             comMngPopulationHouseUserDAO.updateById(comMngPopulationHouseUserDO);
+        }else {
+            comMngPopulationHouseUserDO = new ComMngPopulationHouseUserDO();
+            comMngPopulationHouseUserDO.setId(Snowflake.getId());
+            comMngPopulationHouseUserDO.setPopulId(vo.getId());
+            comMngPopulationHouseUserDO.setRelation(vo.getRelation());
+            comMngPopulationHouseUserDO.setCreateAt(new Date());
+            comMngPopulationHouseUserDAO.insert(comMngPopulationHouseUserDO);
         }
         if (populationDAO.updateById(populationDO) > 0) {
             return R.ok();

--
Gitblit v1.7.1