From 08eefab8f0b04018dc62928ec2191bcae9d3e7d0 Mon Sep 17 00:00:00 2001 From: huanghongfa <huanghongfa123456> Date: 星期五, 15 十月 2021 16:25:01 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/test' into test --- springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComMngPopulationServiceImpl.java | 150 +++++++++++++++++--------------------------------- 1 files changed, 51 insertions(+), 99 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 73d25e9..f95b8cf 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 @@ -9,6 +9,7 @@ import com.baomidou.mybatisplus.core.conditions.Wrapper; import com.baomidou.mybatisplus.core.conditions.segments.MergeSegments; +import com.panzhihua.common.utlis.*; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Bean; @@ -54,10 +55,6 @@ import com.panzhihua.common.model.vos.screen.ComActPopulationScreenVO; import com.panzhihua.common.model.vos.screen.ComMngPopulationAgeVO; import com.panzhihua.common.model.vos.user.*; -import com.panzhihua.common.utlis.AgeUtils; -import com.panzhihua.common.utlis.DateUtils; -import com.panzhihua.common.utlis.Snowflake; -import com.panzhihua.common.utlis.StringUtils; import com.panzhihua.service_community.dao.*; import com.panzhihua.service_community.model.dos.*; import com.panzhihua.service_community.service.*; @@ -472,25 +469,27 @@ break; case 2: comMngPopulationVO.setRoad(houseDO.getAlley()); - comMngPopulationVO.setDoorNo(houseDO.getHouseNum()); +// comMngPopulationVO.setDoorNo(houseDO.getHouseNum()); break; case 3: comMngPopulationVO.setRoad(houseDO.getAlley()); comMngPopulationVO.setDoorNo(houseDO.getHouseNum()); - comMngPopulationVO.setFloor(houseDO.getFloor()); +// comMngPopulationVO.setFloor(houseDO.getFloor()); break; case 4: comMngPopulationVO.setRoad(houseDO.getAlley()); comMngPopulationVO.setDoorNo(houseDO.getHouseNum()); comMngPopulationVO.setFloor(houseDO.getFloor()); - comMngPopulationVO.setUnitNo(houseDO.getUnitNo()); +// comMngPopulationVO.setUnitNo(houseDO.getUnitNo()); break; case 5: comMngPopulationVO.setRoad(houseDO.getAlley()); comMngPopulationVO.setDoorNo(houseDO.getHouseNum()); comMngPopulationVO.setFloor(houseDO.getFloor()); comMngPopulationVO.setUnitNo(houseDO.getUnitNo()); - comMngPopulationVO.setHouseNo(houseDO.getHouseNo()); + if(comMngPopulationVO.getLevelIsAll() == null){ + comMngPopulationVO.setHouseNo(houseDO.getHouseNo()); + } break; default: break; @@ -4885,15 +4884,6 @@ ComElderAuthElderliesDO comElderAuthElderliesDO = comElderAuthElderliesDAO.selectOne(new QueryWrapper<ComElderAuthElderliesDO>().lambda() .eq(ComElderAuthElderliesDO::getPopulationId, populationDO.getId()).eq(ComElderAuthElderliesDO::getCommunityId, communityId)); - // List<String> userTag = vo.getUserTagStr().stream().map(userTagStr -> - // userTagStr.split("\\(")[0]).collect(Collectors.toList()); - // //如果导入数据标签中有当前社区标签列表中不包含的标签,则删除 - // Iterator<String> iterator = userTag.iterator(); - // while (iterator.hasNext()) { - // String s = iterator.next(); - // if (!labelList.contains(s)) - // iterator.remove(); - // } String cardNoAES = populationDO.getCardNo(); try { cardNoAES = AESUtil.encrypt128(vo.getCardNo(), aesKey); @@ -4918,19 +4908,6 @@ comElderAuthElderliesDO.setPersonnelCategory(ComElderAuthElderliesDO.personnelCategory.above100); } } -// if (!comElderAuthElderliesDO.getIsAlive().equals(1) || !comElderAuthElderliesDO.getIsRegister().equals(1)) { -// if (vo.getIsRegister().equals(1) && vo.getIsAlive().equals(1)) { -// Date nowDate = new Date(); -// // 获取当前年 -// int year = DateUtils.getYear(nowDate); -// // 获取当前月 -// int month = DateUtils.getMonth(nowDate) + 1; -// ComEldersAuthStatisticsDO comEldersAuthStatisticsDO = comEldersAuthStatisticsMapper.selectOne(new QueryWrapper<ComEldersAuthStatisticsDO>() -// .lambda().eq(ComEldersAuthStatisticsDO::getCommunityId, communityId).eq(ComEldersAuthStatisticsDO::getYear, year).eq(ComEldersAuthStatisticsDO::getMonth, month)); -// comEldersAuthStatisticsDO.setSum(comEldersAuthStatisticsDO.getSum() + 1); -// comEldersAuthStatisticsMapper.updateById(comEldersAuthStatisticsDO); -// } -// } comElderAuthElderliesDAO.updateById(comElderAuthElderliesDO); } else { comElderAuthElderliesDO = new ComElderAuthElderliesDO(); @@ -4951,19 +4928,11 @@ comElderAuthElderliesDO.setPersonnelCategory(ComElderAuthElderliesDO.personnelCategory.above100); } } -// if (vo.getIsRegister().equals(1) && vo.getIsAlive().equals(1)) { -// Date nowDate = new Date(); -// // 获取当前年 -// int year = DateUtils.getYear(nowDate); -// // 获取当前月 -// int month = DateUtils.getMonth(nowDate) + 1; -// ComEldersAuthStatisticsDO comEldersAuthStatisticsDO = comEldersAuthStatisticsMapper.selectOne(new QueryWrapper<ComEldersAuthStatisticsDO>() -// .lambda().eq(ComEldersAuthStatisticsDO::getCommunityId, communityId).eq(ComEldersAuthStatisticsDO::getYear, year).eq(ComEldersAuthStatisticsDO::getMonth, month)); -// comEldersAuthStatisticsDO.setSum(comEldersAuthStatisticsDO.getSum() + 1); -// comEldersAuthStatisticsMapper.updateById(comEldersAuthStatisticsDO); -// } comElderAuthElderliesDAO.insert(comElderAuthElderliesDO); } + + //维护养老认证健在状态 + comPensionAuthPensionerDAO.editPensionIsAlive(populationDO.getId(),vo.getIsAlive()); return populationDO; } @@ -4974,15 +4943,6 @@ comPensionAuthPensionerDAO.selectOne(new QueryWrapper<ComPensionAuthPensionerDO>().lambda() .eq(ComPensionAuthPensionerDO::getPopulationId, populationDO.getId()) .eq(ComPensionAuthPensionerDO::getCommunityId, communityId)); - // List<String> userTag = vo.getUserTagStr().stream().map(userTagStr -> - // userTagStr.split("\\(")[0]).collect(Collectors.toList()); - // //如果导入数据标签中有当前社区标签列表中不包含的标签,则删除 - // Iterator<String> iterator = userTag.iterator(); - // while (iterator.hasNext()) { - // String s = iterator.next(); - // if (!labelList.contains(s)) - // iterator.remove(); - // } String cardNoAES = populationDO.getCardNo(); try { cardNoAES = AESUtil.encrypt128(vo.getCardNo(), aesKey); @@ -4997,23 +4957,6 @@ BeanUtils.copyProperties(vo, comPensionAuthPensionerDO); comPensionAuthPensionerDO.setIdCard(cardNoAES); comPensionAuthPensionerDO.setAddress(vo.getNowAddress()); -// if (!comPensionAuthPensionerDO.getIsAlive().equals(1) || !comPensionAuthPensionerDO.getIsRegister().equals(1)) { -// if (vo.getIsRegister().equals(1) && vo.getIsAlive().equals(1)) { -// Date nowDate = new Date(); -// // 获取当前年 -// int year = (DateUtils.getYear(nowDate)); -// ComPensionAuthStatisticsDO comPensionAuthStatisticsDO = comPensionAuthStatisticsDAO.selectOne(new QueryWrapper<ComPensionAuthStatisticsDO>() -// .lambda().eq(ComPensionAuthStatisticsDO::getCommunityId, communityId) -// .eq(ComPensionAuthStatisticsDO::getYear, year)); -// if(null == comPensionAuthStatisticsDO){ -// comPensionAuthStatisticsDO = comPensionAuthStatisticsDAO.selectOne(new QueryWrapper<ComPensionAuthStatisticsDO>() -// .lambda().eq(ComPensionAuthStatisticsDO::getCommunityId, communityId) -// .eq(ComPensionAuthStatisticsDO::getYear, year - 1)); -// } -// comPensionAuthStatisticsDO.setSum(comPensionAuthStatisticsDO.getSum() + 1); -// comPensionAuthStatisticsDAO.updateById(comPensionAuthStatisticsDO); -// } -// } comPensionAuthPensionerDAO.updateById(comPensionAuthPensionerDO); } else { comPensionAuthPensionerDO = new ComPensionAuthPensionerDO(); @@ -5025,17 +4968,9 @@ comPensionAuthPensionerDO.setIdCard(vo.getCardNo()); comPensionAuthPensionerDO.setAddress(vo.getNowAddress()); comPensionAuthPensionerDAO.insert(comPensionAuthPensionerDO); -// if (vo.getIsRegister().equals(1) && vo.getIsAlive().equals(1)) { -// Date nowDate = new Date(); -// // 获取当前年 -// int year = (DateUtils.getYear(nowDate)); -// ComPensionAuthStatisticsDO comPensionAuthStatisticsDO = comPensionAuthStatisticsDAO.selectOne(new QueryWrapper<ComPensionAuthStatisticsDO>() -// .lambda().eq(ComPensionAuthStatisticsDO::getCommunityId, communityId) -// .eq(ComPensionAuthStatisticsDO::getYear, year)); -// comPensionAuthStatisticsDO.setSum(comPensionAuthStatisticsDO.getSum() + 1); -// comPensionAuthStatisticsDAO.updateById(comPensionAuthStatisticsDO); -// } } + //维护高龄老人健在状态 + comElderAuthElderliesDAO.editEditIsAlive(populationDO.getId(),vo.getIsAlive()); return populationDO; } @@ -5601,16 +5536,6 @@ Long populationId = Snowflake.getId(); populationDO.setId(populationId); comElderAuthElderliesDO.setPopulationId(populationId); - // List<String> userTag = vo.getUserTagStr().stream().map(userTagStr -> - // userTagStr.split("\\(")[0]).collect(Collectors.toList()); - // - // //如果导入数据标签中有当前社区标签列表中不包含的标签,则删除 - // Iterator<String> iterator = userTag.iterator(); - // while (iterator.hasNext()) { - // String s = iterator.next(); - // if (!labelList.contains(s)) - // iterator.remove(); - // } populationDO.setVillageId(comMngVillageDO.getVillageId()); populationDO.setActId(comActDO.getCommunityId()); populationDO.setStreetId(comActDO.getStreetId()); @@ -5651,17 +5576,6 @@ comElderAuthElderliesDO.setPersonnelCategory(ComElderAuthElderliesDO.personnelCategory.above100); } } -// if (vo.getIsRegister().equals(1) && vo.getIsAlive().equals(1)) { -// Calendar calendar = Calendar.getInstance(); -// // 获取当前年 -// int year = calendar.get(Calendar.YEAR); -// // 获取当前月 -// int month = calendar.get(Calendar.MONTH) + 1; -// ComEldersAuthStatisticsDO comEldersAuthStatisticsDO = comEldersAuthStatisticsMapper.selectOne(new QueryWrapper<ComEldersAuthStatisticsDO>() -// .lambda().eq(ComEldersAuthStatisticsDO::getCommunityId, communityId).eq(ComEldersAuthStatisticsDO::getYear, year).eq(ComEldersAuthStatisticsDO::getMonth, month)); -// comEldersAuthStatisticsDO.setSum(comEldersAuthStatisticsDO.getSum() + 1); -// comEldersAuthStatisticsMapper.updateById(comEldersAuthStatisticsDO); -// } comElderAuthElderliesDAO.insert(comElderAuthElderliesDO); return populationDO; } @@ -6495,6 +6409,16 @@ populationDO.setStreetId(comActDO.getStreetId()); } + //修改人员标签 + List<ComMngPopulationCommunityTagsDO> communityTagsDOList = comMngPopulationCommunityTagsDAO + .selectList(new QueryWrapper<ComMngPopulationCommunityTagsDO>().lambda() + .eq(ComMngPopulationCommunityTagsDO::getCommunityId,communityId) + .eq(ComMngPopulationCommunityTagsDO::getPopulationId,vo.getId())); + communityTagsDOList.forEach(communityTags -> { + communityTags.setLabel(vo.getLabel()); + comMngPopulationCommunityTagsDAO.updateById(communityTags); + }); + // 查询当前用户所有房屋id List<Long> houseIds = comMngPopulationHouseUserDAO.getPopulationHouseIdByUserId(vo.getId()); // 清除用户房屋居住信息 @@ -6657,6 +6581,17 @@ public R specialInputUser(PageInputUserDTO pageInputUserDTO) { IPage<InputUserInfoVO> iPage = populationDAO.specialInputUser( new Page<>(pageInputUserDTO.getPageNum(), pageInputUserDTO.getPageSize()), pageInputUserDTO); + + iPage.getRecords().forEach(page -> { + if(page.getAreaName() == null || StringUtils.isEmpty(page.getAreaName())){ + StringBuilder sb = new StringBuilder(); + sb.append(page.getAlley()); + if(!page.getHouseNum().contains("号")){ + sb.append(page.getHouseNum() + "号"); + } + page.setAreaName(sb.toString()); + } + }); return R.ok(iPage); } @@ -6668,13 +6603,24 @@ * @return 删除结果 */ @Override - public R deleteSpecialInputUser(Long id) { + public R deleteSpecialInputUser(Long id,Long communityId) { // 查询特殊群体人员 ComMngPopulationDO populationDO = this.baseMapper.selectById(id); if (populationDO == null) { return R.fail("未查询到该记录"); } populationDO.setLabel(null); + + // 清理社区与人口关联信息的label信息 + List<ComMngPopulationCommunityTagsDO> communityTagsDOList = comMngPopulationCommunityTagsDAO.selectList(new QueryWrapper<ComMngPopulationCommunityTagsDO>() + .lambda().eq(ComMngPopulationCommunityTagsDO::getPopulationId,id).eq(ComMngPopulationCommunityTagsDO::getCommunityId,communityId)); + if(communityTagsDOList != null && communityTagsDOList.size() > 0){ + communityTagsDOList.forEach(communityTags -> { + communityTags.setLabel(null); + comMngPopulationCommunityTagsDAO.updateById(communityTags); + }); + } + if (this.baseMapper.updateById(populationDO) > 0) { return R.ok(); } else { @@ -7524,6 +7470,10 @@ if (StringUtils.isNotEmpty(detail.getMarriage())) { detail.setMarriage(PopulMarriageEnum.getCnDescByName(Integer.parseInt(detail.getMarriage()))); } + //查询该人口的标签 + List<ComMngPopulationCommunityTagsVo> communityTagsList = this.baseMapper.getCommunityTagList(populationId); + String label = LabelUtils.assembleLabel(communityTagsList); + detail.setLabel(label); } return R.ok(detail); } @@ -7604,6 +7554,8 @@ return R.fail("您选择的数据中存在被引用的,无法删除"); } this.baseMapper.deleteBatchIds(ids); + //删除人口并删除人口和社区关联关系 + this.baseMapper.deletePopulaitonRelation(ids); return R.ok("删除成功"); } -- Gitblit v1.7.1