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