| | |
| | | package com.panzhihua.service_community.service.impl; |
| | | |
| | | import com.alibaba.fastjson.JSON; |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import com.baomidou.mybatisplus.core.metadata.IPage; |
| | | import com.baomidou.mybatisplus.extension.plugins.pagination.Page; |
| | |
| | | import com.panzhihua.common.enums.PopulIsOksEnum; |
| | | import com.panzhihua.common.exceptions.ServiceException; |
| | | import com.panzhihua.common.model.dtos.community.*; |
| | | import com.panzhihua.common.model.dtos.community.bigscreen.BigScreenEventDetailDTO; |
| | | import com.panzhihua.common.model.dtos.user.PageInputUserDTO; |
| | | import com.panzhihua.common.model.helper.AESUtil; |
| | | import com.panzhihua.common.model.vos.R; |
| | | import com.panzhihua.common.model.vos.area.AreaAddressVO; |
| | | import com.panzhihua.common.model.vos.community.*; |
| | | import com.panzhihua.common.model.vos.community.bigscreen.BigScreenStatisticPartyBuild; |
| | | import com.panzhihua.common.model.vos.community.screen.civil.CivilPopulationStatisticsVO; |
| | | import com.panzhihua.common.model.vos.community.screen.civil.CivilStatisticsVO; |
| | | import com.panzhihua.common.model.vos.community.screen.civil.CivilVillageStatisticsVO; |
| | | import com.panzhihua.common.model.vos.community.screen.event.*; |
| | | import com.panzhihua.common.model.vos.community.screen.index.*; |
| | | import com.panzhihua.common.model.vos.grid.EventGridDataVO; |
| | | import com.panzhihua.common.model.vos.grid.EventResourceVO; |
| | | import com.panzhihua.common.model.vos.screen.ComActPopulationCultureVO; |
| | | import com.panzhihua.common.model.vos.screen.ComActPopulationScreenVO; |
| | | import com.panzhihua.common.model.vos.screen.ComMngPopulationAgeVO; |
| | | import com.panzhihua.common.model.vos.user.ComMngFamilyInfoVO; |
| | | import com.panzhihua.common.model.vos.user.ComMngHouseVo; |
| | | import com.panzhihua.common.model.vos.user.InputUserInfoVO; |
| | | import com.panzhihua.common.model.vos.user.UserElectronicFileVO; |
| | | 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.service_community.model.dos.*; |
| | | import com.panzhihua.service_community.service.ComMngPopulationHouseUserService; |
| | | import com.panzhihua.service_community.service.ComMngPopulationService; |
| | | import com.panzhihua.service_community.service.EventResourceService; |
| | | import org.springframework.beans.BeanUtils; |
| | | import org.springframework.beans.factory.annotation.Value; |
| | | import org.springframework.stereotype.Service; |
| | |
| | | @Resource |
| | | private ComMngPopulationHouseUserDAO comMngPopulationHouseUserDAO; |
| | | @Resource |
| | | private ComMngPopulationDAO comMngPopulationDAO; |
| | | @Resource |
| | | private ComMngPopulationHouseUserService comMngPopulationHouseUserService; |
| | | @Resource |
| | | private EventResourceService eventResourceService; |
| | | @Resource |
| | | private BigScreenDAO bigScreenDAO; |
| | | @Value("${domain.aesKey:}") |
| | | private String aesKey; |
| | | |
| | |
| | | Long pageNum = comMngPopulationVO.getPageNum(); |
| | | Long pageSize = comMngPopulationVO.getPageSize(); |
| | | if (null == pageNum || 0 == pageNum) { |
| | | pageNum = 1l; |
| | | pageNum = 1L; |
| | | } |
| | | if (null == pageSize || 0 == pageSize) { |
| | | pageSize = 10l; |
| | | pageSize = 10L; |
| | | } |
| | | page.setSize(pageSize); |
| | | page.setCurrent(pageNum); |
| | |
| | | //处理实有人口信息 |
| | | for (ComMngPopulationServeExcelVO vo : list) { |
| | | String address = ""; |
| | | //查询小区街路巷是否存在 |
| | | //查询街路巷是否存在 |
| | | ComMngVillageDO comMngVillageDO = comActVillageDAO.selectOne(new QueryWrapper<ComMngVillageDO>().eq("alley", vo.getRoad()).eq("house_num", vo.getDoorNo()).eq("community_id", communityId)); |
| | | if (comMngVillageDO == null) { |
| | | ComMngPopulationImportErrorVO importErrorVO = new ComMngPopulationImportErrorVO(); |
| | | importErrorVO.setErrorMsg("街路巷或小区号不存在"); |
| | | importErrorVO.setErrorPosition("街路巷:" + vo.getRoad() + ",小区号:" + vo.getDoorNo()); |
| | | populationImportErrorVOList.add(importErrorVO); |
| | | // index++; |
| | | continue; |
| | | } |
| | | |
| | |
| | | comMngVillageDO.setHouseNum(comMngVillageDO.getHouseNum() + "号"); |
| | | } |
| | | |
| | | //小区详细地址 |
| | | address = areaAddressVO.getProvince() + areaAddressVO.getCity() |
| | | + areaAddressVO.getDistrict() + streetName + comMngVillageDO.getAlley() + comMngVillageDO.getHouseNum() |
| | | + vo.getFloor() + vo.getUnitNo() + vo.getHouseNo(); |
| | |
| | | return null; |
| | | } |
| | | |
| | | /** |
| | | * 首页大屏统计接口 |
| | | * |
| | | * @param communityId 社区id |
| | | * @return 统计结果 |
| | | */ |
| | | @Override |
| | | public R getScreenIndex(Long communityId) { |
| | | //创建统计返回参数 |
| | | IndexStatisticsVO statisticsVO = new IndexStatisticsVO(); |
| | | |
| | | //查询基础数据模块 |
| | | IndexBasicsStatisticsVO basicsStatisticsVO = comMngPopulationDAO.getScreenIndexByBasics(communityId); |
| | | statisticsVO.setBasicsStatistics(basicsStatisticsVO); |
| | | |
| | | //查询实有人口统计模块 |
| | | IndexPopulationStatisticsVO populationStatisticsVO = new IndexPopulationStatisticsVO(); |
| | | //查询实有人口性别统计 |
| | | List<IndexPopulationSexStatisticsVO> sexPopulationList = comMngPopulationDAO.getScreenIndexByPopulationSex(communityId); |
| | | populationStatisticsVO.setSexPopulationList(sexPopulationList); |
| | | //查询实有人口年龄统计 |
| | | List<IndexPopulationAgeStatisticsVO> agePopulationList = statisticsAge(communityId); |
| | | populationStatisticsVO.setAgePopulationList(agePopulationList); |
| | | statisticsVO.setPopulationStatisticsVO(populationStatisticsVO); |
| | | |
| | | //查询实有人口实时治理信息 |
| | | List<IndexEventListStatisticsVO> eventListStatisticsList = comMngPopulationDAO.getScreenIndexByEventList(communityId); |
| | | statisticsVO.setEventListStatisticsList(eventListStatisticsList); |
| | | |
| | | //查询社区治理动态信息 |
| | | IndexDynamicStatisticsVO dynamicStatisticsVO = comMngPopulationDAO.getScreenIndexByDynamic(communityId); |
| | | dynamicStatisticsVO.setCultureActivityTotal(dynamicStatisticsVO.getPbTotal() + dynamicStatisticsVO.getActTotal()); |
| | | statisticsVO.setDynamicStatisticsVO(dynamicStatisticsVO); |
| | | |
| | | //查询网格化治理 |
| | | IndexEventGridStatisticsVO eventGridStatisticsVO = new IndexEventGridStatisticsVO(); |
| | | List<IndexGridStatisticsVO> gridStatisticsList = new ArrayList<>(); |
| | | //查询网格化事件数据 |
| | | IndexGridEventStatisticsVO gridEventStatistics = comMngPopulationDAO.getGridEventStatisticsList(communityId); |
| | | eventGridStatisticsVO.setGridEventStatisticsList(gridEventStatistics); |
| | | //查询网格数据 |
| | | List<EventGridDataVO> gridDataList = comMngPopulationDAO.getGridDataListByCommunityId(communityId); |
| | | if (!gridDataList.isEmpty()) { |
| | | gridDataList.forEach(gridData -> { |
| | | if (gridData != null) { |
| | | IndexGridStatisticsVO gridStatisticsVO = new IndexGridStatisticsVO(); |
| | | gridStatisticsVO.setEventData(gridData.getGridName()); |
| | | //根据网格id查询网格事件列表 |
| | | IndexGridEventStatisticsVO gridEventList = comMngPopulationDAO.getGridEventByGirdId(gridData.getId()); |
| | | gridStatisticsVO.setGridEventStatisticsList(gridEventList); |
| | | gridStatisticsList.add(gridStatisticsVO); |
| | | } |
| | | }); |
| | | } |
| | | eventGridStatisticsVO.setGridStatisticsList(gridStatisticsList); |
| | | statisticsVO.setEventGridStatisticsVO(eventGridStatisticsVO); |
| | | |
| | | //查询党建数据 |
| | | BigScreenStatisticPartyBuild statisticPartyBuild = bigScreenDAO.partybuild(communityId); |
| | | statisticsVO.setStatisticPartyBuild(statisticPartyBuild); |
| | | |
| | | //查询特殊人群统计 |
| | | List<IndexSpecialStatisticsVO> specialStatisticsVOList = new ArrayList<>(); |
| | | |
| | | //查询特殊人群标签列表 |
| | | List<ComMngUserTagVO> userTagList = comMngPopulationDAO.getUserTagListByCommunityId(communityId); |
| | | IndexSpecialStatisticsVO otherSpecialVO = new IndexSpecialStatisticsVO(); |
| | | otherSpecialVO.setTitle("其他"); |
| | | otherSpecialVO.setSum(0); |
| | | if (!userTagList.isEmpty()) { |
| | | userTagList.forEach(userTag -> { |
| | | if (userTag != null) { |
| | | if (userTag.getSysFlag().equals(0)) { |
| | | Integer count = comMngPopulationDAO.getSpecialStatisticsByLabel(userTag.getTagName()); |
| | | otherSpecialVO.setSum(otherSpecialVO.getSum() + count); |
| | | } else { |
| | | if (StringUtils.isNotEmpty(userTag.getTagName())) { |
| | | if (userTag.getTagName().equals("特扶家庭")) { |
| | | IndexSpecialStatisticsVO specialStatisticsVO = new IndexSpecialStatisticsVO(); |
| | | specialStatisticsVO.setTitle(userTag.getTagName()); |
| | | specialStatisticsVO.setSum(22); |
| | | specialStatisticsVOList.add(specialStatisticsVO); |
| | | } else if (userTag.getTagName().equals("低保户")) { |
| | | IndexSpecialStatisticsVO specialStatisticsVO = new IndexSpecialStatisticsVO(); |
| | | specialStatisticsVO.setTitle(userTag.getTagName()); |
| | | specialStatisticsVO.setSum(94); |
| | | specialStatisticsVOList.add(specialStatisticsVO); |
| | | } else if (userTag.getTagName().equals("低收入人群")) { |
| | | IndexSpecialStatisticsVO specialStatisticsVO = new IndexSpecialStatisticsVO(); |
| | | specialStatisticsVO.setTitle(userTag.getTagName()); |
| | | specialStatisticsVO.setSum(2); |
| | | specialStatisticsVOList.add(specialStatisticsVO); |
| | | } else if (userTag.getTagName().equals("退役军人")) { |
| | | IndexSpecialStatisticsVO specialStatisticsVO = new IndexSpecialStatisticsVO(); |
| | | specialStatisticsVO.setTitle(userTag.getTagName()); |
| | | specialStatisticsVO.setSum(264); |
| | | specialStatisticsVOList.add(specialStatisticsVO); |
| | | }else if(userTag.getTagName().equals("高龄老人")){ |
| | | IndexSpecialStatisticsVO specialStatisticsVO = new IndexSpecialStatisticsVO(); |
| | | specialStatisticsVO.setTitle(userTag.getTagName()); |
| | | specialStatisticsVO.setSum(comMngPopulationDAO.getStatisticsCount(communityId)); |
| | | specialStatisticsVOList.add(specialStatisticsVO); |
| | | }else{ |
| | | IndexSpecialStatisticsVO specialStatisticsVO = new IndexSpecialStatisticsVO(); |
| | | specialStatisticsVO.setTitle(userTag.getTagName()); |
| | | Integer count = comMngPopulationDAO.getSpecialStatisticsByLabel(userTag.getTagName()); |
| | | specialStatisticsVO.setSum(count); |
| | | specialStatisticsVOList.add(specialStatisticsVO); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | }); |
| | | } |
| | | specialStatisticsVOList.add(otherSpecialVO); |
| | | statisticsVO.setSpecialStatisticsVOList(specialStatisticsVOList); |
| | | return R.ok(statisticsVO); |
| | | } |
| | | |
| | | private List<IndexPopulationAgeStatisticsVO> statisticsAge(Long communityId) { |
| | | Map<String, Long> ageMap = populationDAO.indexCountByAge(communityId); |
| | | List<IndexPopulationAgeStatisticsVO> agePopulationList = new ArrayList<>(); |
| | | IndexPopulationAgeStatisticsVO ageStatisticsVO1 = new IndexPopulationAgeStatisticsVO(); |
| | | IndexPopulationAgeStatisticsVO ageStatisticsVO2 = new IndexPopulationAgeStatisticsVO(); |
| | | IndexPopulationAgeStatisticsVO ageStatisticsVO3 = new IndexPopulationAgeStatisticsVO(); |
| | | IndexPopulationAgeStatisticsVO ageStatisticsVO4 = new IndexPopulationAgeStatisticsVO(); |
| | | IndexPopulationAgeStatisticsVO ageStatisticsVO5 = new IndexPopulationAgeStatisticsVO(); |
| | | IndexPopulationAgeStatisticsVO ageStatisticsVO6 = new IndexPopulationAgeStatisticsVO(); |
| | | ageStatisticsVO1.setType(1); |
| | | ageStatisticsVO2.setType(2); |
| | | ageStatisticsVO3.setType(3); |
| | | ageStatisticsVO4.setType(4); |
| | | ageStatisticsVO5.setType(5); |
| | | ageStatisticsVO6.setType(6); |
| | | |
| | | if (ageMap.isEmpty()) { |
| | | ageStatisticsVO1.setSum(0); |
| | | ageStatisticsVO2.setSum(0); |
| | | ageStatisticsVO3.setSum(0); |
| | | ageStatisticsVO4.setSum(0); |
| | | ageStatisticsVO5.setSum(0); |
| | | ageStatisticsVO6.setSum(0); |
| | | } else { |
| | | ageStatisticsVO1.setSum(ageMap.get("age16").intValue()); |
| | | ageStatisticsVO2.setSum(ageMap.get("age27").intValue()); |
| | | ageStatisticsVO3.setSum(ageMap.get("age35").intValue()); |
| | | ageStatisticsVO4.setSum(ageMap.get("age45").intValue()); |
| | | ageStatisticsVO5.setSum(ageMap.get("age55").intValue()); |
| | | ageStatisticsVO6.setSum(ageMap.get("age55over").intValue()); |
| | | } |
| | | |
| | | agePopulationList.add(ageStatisticsVO1); |
| | | agePopulationList.add(ageStatisticsVO2); |
| | | agePopulationList.add(ageStatisticsVO3); |
| | | agePopulationList.add(ageStatisticsVO4); |
| | | agePopulationList.add(ageStatisticsVO5); |
| | | agePopulationList.add(ageStatisticsVO6); |
| | | return agePopulationList; |
| | | } |
| | | |
| | | /** |
| | | * 事件大屏统计接口 |
| | | * |
| | | * @param communityId 社区id |
| | | * @return 统计结果 |
| | | */ |
| | | @Override |
| | | public R getScreenEvent(Long communityId) { |
| | | //创建统计返回参数 |
| | | EventStatisticsVO statisticsVO = new EventStatisticsVO(); |
| | | |
| | | //查询页面左边数据 |
| | | EventLeftStatisticsVO leftStatisticsVO = new EventLeftStatisticsVO(); |
| | | //查询左上数据 |
| | | EventLeftTopStatisticsVO leftTopStatisticsVO = this.baseMapper.getEventScreenLeftTop(communityId); |
| | | //查询时间频发月份 |
| | | List<Integer> monthList = this.baseMapper.getFrequentlyEventMonth(communityId); |
| | | leftTopStatisticsVO.setOftenMonth(monthList); |
| | | leftStatisticsVO.setLeftTopStatisticsVO(leftTopStatisticsVO); |
| | | //查询左下数据 |
| | | EventLeftDownStatisticsVO leftDownStatisticsVO = this.baseMapper.getEventScreenLeftDown(communityId); |
| | | leftStatisticsVO.setLeftDownStatisticsVO(leftDownStatisticsVO); |
| | | statisticsVO.setLeftStatisticsVO(leftStatisticsVO); |
| | | |
| | | //查询事件播报模块数据 |
| | | EventNewStatisticsVO newStatisticsVO = this.baseMapper.getEventScreenRightTop(communityId); |
| | | if (newStatisticsVO != null) { |
| | | //查询事件资源文件 |
| | | List<EventResourceDO> eventResourceDOList = |
| | | eventResourceService.getBaseMapper().selectList(new LambdaQueryWrapper<EventResourceDO>() |
| | | .eq(EventResourceDO::getClassification, 1) |
| | | .eq(EventResourceDO::getRefId, newStatisticsVO.getId()) |
| | | ); |
| | | List<EventResourceVO> picList = new ArrayList<>(); |
| | | List<EventResourceVO> audioList = new ArrayList<>(); |
| | | List<EventResourceVO> videoList = new ArrayList<>(); |
| | | eventResourceDOList.forEach(eventResourceDO -> { |
| | | switch (eventResourceDO.getType()) { |
| | | case 1: |
| | | EventResourceVO picEventResourceVO = new EventResourceVO(); |
| | | BeanUtils.copyProperties(eventResourceDO, picEventResourceVO); |
| | | picList.add(picEventResourceVO); |
| | | break; |
| | | case 2: |
| | | EventResourceVO audioResourceVO = new EventResourceVO(); |
| | | BeanUtils.copyProperties(eventResourceDO, audioResourceVO); |
| | | audioList.add(audioResourceVO); |
| | | break; |
| | | case 3: |
| | | EventResourceVO videoResourceVO = new EventResourceVO(); |
| | | BeanUtils.copyProperties(eventResourceDO, videoResourceVO); |
| | | videoList.add(videoResourceVO); |
| | | break; |
| | | } |
| | | }); |
| | | newStatisticsVO.setAudios(audioList); |
| | | newStatisticsVO.setPics(picList); |
| | | newStatisticsVO.setVideos(videoList); |
| | | |
| | | //查询事件流转记录 |
| | | List<EventTransferRecordVO> transferRecordList = this.baseMapper.getEventScreenEventTransList(newStatisticsVO.getId()); |
| | | newStatisticsVO.setTransferRecordList(transferRecordList); |
| | | } |
| | | statisticsVO.setNewStatisticsVO(newStatisticsVO); |
| | | |
| | | //查询网格数据 |
| | | List<EventGridStatisticsVO> gridStatisticsList = this.baseMapper.getEventScreenGridData(communityId); |
| | | statisticsVO.setGridStatisticsList(gridStatisticsList); |
| | | |
| | | //查询社区事件列表 |
| | | List<EventGridIncidentStatisticsVO> gridIncidentList = this.baseMapper.getEventScreenEventList(communityId); |
| | | statisticsVO.setGridIncidentList(gridIncidentList); |
| | | |
| | | //查询小区列表 |
| | | List<CivilVillageStatisticsVO> villageStatisticsList = this.baseMapper.getCivilScreenVillageList(communityId); |
| | | if(!villageStatisticsList.isEmpty()){ |
| | | villageStatisticsList.forEach(village -> { |
| | | CivilVillageStatisticsVO villageStatisticsVO = this.baseMapper.getCivilScreenVillageStatistics(village.getVillageId()); |
| | | if(villageStatisticsVO != null){ |
| | | BeanUtils.copyProperties(villageStatisticsVO,village); |
| | | } |
| | | }); |
| | | } |
| | | statisticsVO.setVillageStatisticsList(villageStatisticsList); |
| | | |
| | | //查询统计人口数据 |
| | | ComMngPopulationTotalVO populationTotalVO = populationDAO.getPopulationTotalByAdmin(communityId); |
| | | statisticsVO.setPopulationTotalVO(populationTotalVO); |
| | | |
| | | return R.ok(statisticsVO); |
| | | } |
| | | |
| | | /** |
| | | * 民生大屏统计接口 |
| | | * |
| | | * @param communityId 社区id |
| | | * @return 统计结果 |
| | | */ |
| | | @Override |
| | | public R getScreenCivil(Long communityId) { |
| | | //创建统计返回参数 |
| | | CivilStatisticsVO civilStatisticsVO = new CivilStatisticsVO(); |
| | | |
| | | //查询特殊人群统计 |
| | | List<IndexSpecialStatisticsVO> specialStatisticsVOList = new ArrayList<>(); |
| | | |
| | | //查询特殊人群标签列表 |
| | | List<ComMngUserTagVO> userTagList = comMngPopulationDAO.getUserTagListByCommunityId(communityId); |
| | | IndexSpecialStatisticsVO otherSpecialVO = new IndexSpecialStatisticsVO(); |
| | | otherSpecialVO.setTitle("其他"); |
| | | otherSpecialVO.setSum(0); |
| | | if (!userTagList.isEmpty()) { |
| | | userTagList.forEach(userTag -> { |
| | | if (userTag != null) { |
| | | if (userTag.getSysFlag().equals(0)) { |
| | | Integer count = comMngPopulationDAO.getSpecialStatisticsByLabel(userTag.getTagName()); |
| | | otherSpecialVO.setSum(otherSpecialVO.getSum() + count); |
| | | } else { |
| | | if (StringUtils.isNotEmpty(userTag.getTagName())) { |
| | | if (userTag.getTagName().equals("特扶家庭")) { |
| | | IndexSpecialStatisticsVO specialStatisticsVO = new IndexSpecialStatisticsVO(); |
| | | specialStatisticsVO.setTitle(userTag.getTagName()); |
| | | specialStatisticsVO.setSum(22); |
| | | specialStatisticsVOList.add(specialStatisticsVO); |
| | | } else if (userTag.getTagName().equals("低保户")) { |
| | | IndexSpecialStatisticsVO specialStatisticsVO = new IndexSpecialStatisticsVO(); |
| | | specialStatisticsVO.setTitle(userTag.getTagName()); |
| | | specialStatisticsVO.setSum(94); |
| | | specialStatisticsVOList.add(specialStatisticsVO); |
| | | } else if (userTag.getTagName().equals("低收入人群")) { |
| | | IndexSpecialStatisticsVO specialStatisticsVO = new IndexSpecialStatisticsVO(); |
| | | specialStatisticsVO.setTitle(userTag.getTagName()); |
| | | specialStatisticsVO.setSum(2); |
| | | specialStatisticsVOList.add(specialStatisticsVO); |
| | | } else if (userTag.getTagName().equals("退役军人")) { |
| | | IndexSpecialStatisticsVO specialStatisticsVO = new IndexSpecialStatisticsVO(); |
| | | specialStatisticsVO.setTitle(userTag.getTagName()); |
| | | specialStatisticsVO.setSum(264); |
| | | specialStatisticsVOList.add(specialStatisticsVO); |
| | | }else if(userTag.getTagName().equals("高龄老人")){ |
| | | IndexSpecialStatisticsVO specialStatisticsVO = new IndexSpecialStatisticsVO(); |
| | | specialStatisticsVO.setTitle(userTag.getTagName()); |
| | | specialStatisticsVO.setSum(comMngPopulationDAO.getStatisticsCount(communityId)); |
| | | specialStatisticsVOList.add(specialStatisticsVO); |
| | | }else{ |
| | | IndexSpecialStatisticsVO specialStatisticsVO = new IndexSpecialStatisticsVO(); |
| | | specialStatisticsVO.setTitle(userTag.getTagName()); |
| | | Integer count = comMngPopulationDAO.getSpecialStatisticsByLabel(userTag.getTagName()); |
| | | specialStatisticsVO.setSum(count); |
| | | specialStatisticsVOList.add(specialStatisticsVO); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | }); |
| | | } |
| | | //计算特殊人群总数 |
| | | specialStatisticsVOList.add(otherSpecialVO); |
| | | Integer specialNum = 0; |
| | | if (!specialStatisticsVOList.isEmpty()) { |
| | | for (IndexSpecialStatisticsVO special : specialStatisticsVOList) { |
| | | specialNum += special.getSum(); |
| | | } |
| | | } |
| | | civilStatisticsVO.setSpecialNum(specialNum); |
| | | civilStatisticsVO.setSpecialStatisticsList(specialStatisticsVOList); |
| | | |
| | | //计算环比上月增长率 |
| | | BigDecimal rate = BigDecimal.ZERO; |
| | | CivilPopulationStatisticsVO populationStatisticsVO = this.baseMapper.getCivilScreenPopulation(communityId, DateUtils.getFirstDayOfMonth()); |
| | | if (populationStatisticsVO != null) { |
| | | if (populationStatisticsVO.getToMonthSpecialTotal().equals(0)) { |
| | | rate = BigDecimal.valueOf(100); |
| | | } else { |
| | | rate = BigDecimal.valueOf(populationStatisticsVO.getSpecialTotal() - populationStatisticsVO.getToMonthSpecialTotal()).divide(BigDecimal.valueOf(populationStatisticsVO.getToMonthSpecialTotal()), 3, BigDecimal.ROUND_HALF_UP).multiply(BigDecimal.valueOf(100)); |
| | | } |
| | | } |
| | | civilStatisticsVO.setRate(rate); |
| | | |
| | | //查询网格数据 |
| | | List<EventGridStatisticsVO> gridStatisticsList = this.baseMapper.getEventScreenGridData(communityId); |
| | | civilStatisticsVO.setGridStatisticsList(gridStatisticsList); |
| | | |
| | | //查询小区列表 |
| | | List<CivilVillageStatisticsVO> villageStatisticsList = this.baseMapper.getCivilScreenVillageList(communityId); |
| | | civilStatisticsVO.setVillageStatisticsList(villageStatisticsList); |
| | | |
| | | return R.ok(civilStatisticsVO); |
| | | } |
| | | |
| | | @Override |
| | | public R screenStatistic(Long communityId) { |
| | | ComActPopulationScreenVO comActPopulationScreenVO = new ComActPopulationScreenVO(); |
| | |
| | | comActPopulationScreenVO.setTotalNum(vo.getPopulationTotal() == null ? 0 : vo.getPopulationTotal()); |
| | | comActPopulationScreenVO.setLocalNum(vo.getLocalTotal() == null ? 0 : vo.getLocalTotal().longValue()); |
| | | comActPopulationScreenVO.setOutNum(vo.getOutTotal() == null ? 0 : vo.getOutTotal().longValue()); |
| | | comActPopulationScreenVO.setSpecialNum(vo.getSpecialTotal() == null ? 0 : vo.getSpecialTotal().longValue()); |
| | | |
| | | //查询特殊人群统计 |
| | | List<IndexSpecialStatisticsVO> specialStatisticsVOList = new ArrayList<>(); |
| | | |
| | | //查询特殊人群标签列表 |
| | | List<ComMngUserTagVO> userTagList = comMngPopulationDAO.getUserTagListByCommunityId(communityId); |
| | | IndexSpecialStatisticsVO otherSpecialVO = new IndexSpecialStatisticsVO(); |
| | | otherSpecialVO.setTitle("其他"); |
| | | otherSpecialVO.setSum(0); |
| | | if(!userTagList.isEmpty()){ |
| | | userTagList.forEach(userTag -> { |
| | | if(userTag != null){ |
| | | if(userTag.getSysFlag().equals(0)){ |
| | | Integer count = comMngPopulationDAO.getSpecialStatisticsByLabel(userTag.getTagName()); |
| | | otherSpecialVO.setSum(otherSpecialVO.getSum() + count); |
| | | }else{ |
| | | if(StringUtils.isNotEmpty(userTag.getTagName())){ |
| | | if(userTag.getTagName().equals("特扶家庭")){ |
| | | IndexSpecialStatisticsVO specialStatisticsVO = new IndexSpecialStatisticsVO(); |
| | | specialStatisticsVO.setTitle(userTag.getTagName()); |
| | | specialStatisticsVO.setSum(22); |
| | | specialStatisticsVOList.add(specialStatisticsVO); |
| | | }else if(userTag.getTagName().equals("低保户")){ |
| | | IndexSpecialStatisticsVO specialStatisticsVO = new IndexSpecialStatisticsVO(); |
| | | specialStatisticsVO.setTitle(userTag.getTagName()); |
| | | specialStatisticsVO.setSum(94); |
| | | specialStatisticsVOList.add(specialStatisticsVO); |
| | | }else if(userTag.getTagName().equals("低收入人群")){ |
| | | IndexSpecialStatisticsVO specialStatisticsVO = new IndexSpecialStatisticsVO(); |
| | | specialStatisticsVO.setTitle(userTag.getTagName()); |
| | | specialStatisticsVO.setSum(2); |
| | | specialStatisticsVOList.add(specialStatisticsVO); |
| | | }else if(userTag.getTagName().equals("退役军人")){ |
| | | IndexSpecialStatisticsVO specialStatisticsVO = new IndexSpecialStatisticsVO(); |
| | | specialStatisticsVO.setTitle(userTag.getTagName()); |
| | | specialStatisticsVO.setSum(264); |
| | | specialStatisticsVOList.add(specialStatisticsVO); |
| | | }else if(userTag.getTagName().equals("高龄老人")){ |
| | | IndexSpecialStatisticsVO specialStatisticsVO = new IndexSpecialStatisticsVO(); |
| | | specialStatisticsVO.setTitle(userTag.getTagName()); |
| | | specialStatisticsVO.setSum(comMngPopulationDAO.getStatisticsCount(communityId)); |
| | | specialStatisticsVOList.add(specialStatisticsVO); |
| | | }else{ |
| | | IndexSpecialStatisticsVO specialStatisticsVO = new IndexSpecialStatisticsVO(); |
| | | specialStatisticsVO.setTitle(userTag.getTagName()); |
| | | Integer count = comMngPopulationDAO.getSpecialStatisticsByLabel(userTag.getTagName()); |
| | | specialStatisticsVO.setSum(count); |
| | | specialStatisticsVOList.add(specialStatisticsVO); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | }); |
| | | } |
| | | //计算特殊人群总数 |
| | | specialStatisticsVOList.add(otherSpecialVO); |
| | | Integer specialNum = 0; |
| | | if(!specialStatisticsVOList.isEmpty()){ |
| | | for (IndexSpecialStatisticsVO special:specialStatisticsVOList) { |
| | | specialNum += special.getSum(); |
| | | } |
| | | } |
| | | comActPopulationScreenVO.setSpecialNum(specialNum.longValue()); |
| | | //统计已使用社区通人数 |
| | | Long count = populationDAO.countUsedCommunityPopulation(communityId); |
| | | comActPopulationScreenVO.setUsedCommunityNum(count == null ? 0 : count); |
| | |
| | | comActPopulationScreenVO.setAgeGroup(ageList); |
| | | } |
| | | |
| | | } |
| | | @Override |
| | | public R getScreenGirds(Long communityId) { |
| | | return R.ok(this.baseMapper.getEventScreenGridData(communityId)); |
| | | } |
| | | |
| | | @Override |
| | | public R getScreenEventDetail(BigScreenEventDetailDTO eventDetailDTO) { |
| | | EventNewStatisticsVO statisticsVO = new EventNewStatisticsVO(); |
| | | if (eventDetailDTO.getType().equals(7)) {//随手拍详情 |
| | | statisticsVO = this.baseMapper.getEventScreenSSPDateil(eventDetailDTO.getEventId()); |
| | | if (statisticsVO != null && StringUtils.isNotEmpty(statisticsVO.getPhotoPathList())) { |
| | | statisticsVO.setDangerLevel("0"); |
| | | statisticsVO.setMajor(false); |
| | | statisticsVO.setUrgent(false); |
| | | if (statisticsVO.getEventDealStatus().equals(2)) { |
| | | statisticsVO.setEventDealStatus(4); |
| | | } |
| | | List<EventResourceVO> picList = new ArrayList<>(); |
| | | String[] pics = statisticsVO.getPhotoPathList().split(","); |
| | | if (pics.length > 0) { |
| | | for (int i = 0; i < pics.length; i++) { |
| | | EventResourceVO resourceVO = new EventResourceVO(); |
| | | resourceVO.setType(1); |
| | | resourceVO.setUrl(pics[i]); |
| | | picList.add(resourceVO); |
| | | } |
| | | } |
| | | statisticsVO.setPics(picList); |
| | | } |
| | | } else {//事件详情 |
| | | statisticsVO = this.baseMapper.getEventScreenEventDetail(eventDetailDTO.getEventId()); |
| | | if (statisticsVO != null) { |
| | | //查询事件资源文件 |
| | | List<EventResourceDO> eventResourceDOList = |
| | | eventResourceService.getBaseMapper().selectList(new LambdaQueryWrapper<EventResourceDO>() |
| | | .eq(EventResourceDO::getClassification, 1) |
| | | .eq(EventResourceDO::getRefId, statisticsVO.getId()) |
| | | ); |
| | | List<EventResourceVO> picList = new ArrayList<>(); |
| | | List<EventResourceVO> audioList = new ArrayList<>(); |
| | | List<EventResourceVO> videoList = new ArrayList<>(); |
| | | eventResourceDOList.forEach(eventResourceDO -> { |
| | | switch (eventResourceDO.getType()) { |
| | | case 1: |
| | | EventResourceVO picEventResourceVO = new EventResourceVO(); |
| | | BeanUtils.copyProperties(eventResourceDO, picEventResourceVO); |
| | | picList.add(picEventResourceVO); |
| | | break; |
| | | case 2: |
| | | EventResourceVO audioResourceVO = new EventResourceVO(); |
| | | BeanUtils.copyProperties(eventResourceDO, audioResourceVO); |
| | | audioList.add(audioResourceVO); |
| | | break; |
| | | case 3: |
| | | EventResourceVO videoResourceVO = new EventResourceVO(); |
| | | BeanUtils.copyProperties(eventResourceDO, videoResourceVO); |
| | | videoList.add(videoResourceVO); |
| | | break; |
| | | } |
| | | }); |
| | | statisticsVO.setAudios(audioList); |
| | | statisticsVO.setPics(picList); |
| | | statisticsVO.setVideos(videoList); |
| | | |
| | | //查询事件流转记录 |
| | | List<EventTransferRecordVO> transferRecordList = this.baseMapper.getEventScreenEventTransList(eventDetailDTO.getEventId()); |
| | | if(!transferRecordList.isEmpty()){ |
| | | transferRecordList.forEach(transfer -> { |
| | | if(transfer.getFromType().equals(EventTransferRecordVO.fromType.wgy)){ |
| | | //查询上级网格信息 |
| | | EventTransferRecordDetailVO transferRecordDetailVO = this.baseMapper.getEventScreenEventTransDetail(transfer.getEventId()); |
| | | transfer.setSuperiorRelationship(transferRecordDetailVO.getStreetName() + "-" |
| | | + transferRecordDetailVO.getCommunityName() + "-" + transferRecordDetailVO.getGridName()); |
| | | }else if(transfer.getFromType().equals(EventTransferRecordVO.fromType.sq)){ |
| | | //查询上级社区信息 |
| | | EventTransferRecordDetailVO transferRecordDetailVO = this.baseMapper.getEventScreenEventTransDetailByCommunityId(transfer.getFromId()); |
| | | transfer.setSuperiorRelationship(transferRecordDetailVO.getStreetName() + "-" |
| | | + transferRecordDetailVO.getCommunityName()); |
| | | } |
| | | }); |
| | | } |
| | | statisticsVO.setTransferRecordList(transferRecordList); |
| | | } |
| | | } |
| | | return R.ok(statisticsVO); |
| | | } |
| | | |
| | | |
| | | } |