From 02f18587bd8860b305e2c688e20465be166bb48c Mon Sep 17 00:00:00 2001 From: huanghongfa <huanghongfa123456> Date: 星期四, 22 七月 2021 15:14:03 +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 | 1661 +++++++++++++++++++++++++++++++++++++++++++++++++++------- 1 files changed, 1,439 insertions(+), 222 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 68dcaf2..f0db4da 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 @@ -1,48 +1,71 @@ package com.panzhihua.service_community.service.impl; +import cn.hutool.core.util.IdcardUtil; 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.conditions.update.UpdateWrapper; +import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.google.common.base.Joiner; import com.google.common.collect.Lists; -import com.panzhihua.common.enums.PopulIsOksEnum; +import com.panzhihua.common.constants.Constants; +import com.panzhihua.common.enums.*; import com.panzhihua.common.exceptions.ServiceException; -import com.panzhihua.common.model.dtos.community.ComMngPopulationDTO; -import com.panzhihua.common.model.dtos.community.ComMngPopulationTagDTO; +import com.panzhihua.common.model.dtos.community.*; +import com.panzhihua.common.model.dtos.community.bigscreen.BigScreenEventDTO; +import com.panzhihua.common.model.dtos.community.bigscreen.BigScreenEventDetailDTO; +import com.panzhihua.common.model.dtos.grid.PageComMngPopulationDTO; +import com.panzhihua.common.model.dtos.grid.PagePopulationListDTO; +import com.panzhihua.common.model.dtos.grid.admin.ComMngPopulationExportDTO; +import com.panzhihua.common.model.dtos.grid.admin.ComMngPopulationListDTO; +import com.panzhihua.common.model.dtos.grid.admin.ComMngPopulationSubordinateDTO; +import com.panzhihua.common.model.dtos.grid.admin.PageComMngVillagePopulationDTO; import com.panzhihua.common.model.dtos.user.PageInputUserDTO; -import com.panzhihua.common.model.helper.AESUtil; -import com.panzhihua.common.model.dtos.community.PageComActDTO; 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.event.EventTransferRecordVO; +import com.panzhihua.common.model.vos.community.screen.index.*; +import com.panzhihua.common.model.vos.grid.*; +import com.panzhihua.common.model.vos.grid.admin.ComMngPopulationListVO; +import com.panzhihua.common.model.vos.grid.admin.ComMngPopulationVillageVO; +import com.panzhihua.common.model.vos.grid.admin.ComMngSubordinateVO; +import com.panzhihua.common.model.vos.grid.admin.excel.ComMngPopulationExportExcelVO; +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.*; +import com.panzhihua.common.model.vos.user.ComMngUserTagVO; import com.panzhihua.common.utlis.AgeUtils; -import com.panzhihua.common.utlis.PayUtil; +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.ComMngPopulationHouseUserService; import com.panzhihua.service_community.service.ComMngPopulationService; +import com.panzhihua.service_community.service.ComMngVillageService; +import com.panzhihua.service_community.service.EventResourceService; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Value; -import org.springframework.beans.factory.annotation.Value; -import org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; +import org.springframework.util.CollectionUtils; import org.springframework.util.ObjectUtils; -import com.panzhihua.common.utlis.StringUtils; import javax.annotation.Resource; -import javax.crypto.BadPaddingException; -import javax.crypto.IllegalBlockSizeException; -import javax.crypto.NoSuchPaddingException; -import java.io.UnsupportedEncodingException; -import java.security.InvalidKeyException; -import java.security.NoSuchAlgorithmException; -import java.util.ArrayList; -import java.util.Date; -import java.util.List; +import java.math.BigDecimal; +import java.text.SimpleDateFormat; +import java.util.*; import java.util.stream.Collectors; /** @@ -64,8 +87,19 @@ private ComMngCarDAO comMngCarDAO; @Resource private ComMngPopulationHouseUserDAO comMngPopulationHouseUserDAO; + @Resource + private ComMngPopulationDAO comMngPopulationDAO; + @Resource + private ComMngPopulationHouseUserService comMngPopulationHouseUserService; + @Resource + private EventResourceService eventResourceService; + @Resource + private BigScreenDAO bigScreenDAO; + @Resource + private ComMngUserTagDAO comMngUserTagDAO; @Value("${domain.aesKey:}") private String aesKey; + /** @@ -136,23 +170,44 @@ if (ObjectUtils.isEmpty(comMngPopulationDO)) { return R.fail("用户信息不存在"); } +// if(StringUtils.isNotEmpty(comMngPopulationDO.getBirthday())){//计算年龄 +// comMngPopulationDO.setAge(AgeUtils.getAgeFromBirthTimes(comMngPopulationDO.getBirthday())); +// } + ComMngPopulationVO comMngPopulationVO = new ComMngPopulationVO(); BeanUtils.copyProperties(comMngPopulationDO, comMngPopulationVO); //查询户主关系信息 - List<ComHouseMemberVo> comMngFamilyInfoVOS = populationDAO.listHouseMermberByUserId(comMngPopulationDO.getHouseId(),comMngPopulationDO.getId()); +// List<ComHouseMemberVo> comMngFamilyInfoVOS = populationDAO.listHouseMermberByUserId(comMngPopulationDO.getHouseId(),comMngPopulationDO.getId()); +// 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); + } + //设置户主关系 + 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())) { + comMngPopulationVO.setAge(AgeUtils.getAgeFromBirthTimes(comMngPopulationVO.getBirthday())); } //查询当前用户电子档信息 - if(!StringUtils.isEmpty(comMngPopulationDO.getCardNo())){ + if (!StringUtils.isEmpty(comMngPopulationDO.getCardNo())) { UserElectronicFileVO electronicFileVO = populationDAO.getSysUserElectronicFile(comMngPopulationDO.getCardNo()); - if(electronicFileVO != null){ + if (electronicFileVO != null) { comMngPopulationVO.setUserElectronicFileVO(electronicFileVO); //查询家庭成员信息 List<ComMngFamilyInfoVO> familyInfoVOList = populationDAO.listFamilyByUserId(electronicFileVO.getUserId()); - if(!familyInfoVOList.isEmpty()){ + if (!familyInfoVOList.isEmpty()) { comMngPopulationVO.setFamilyInfoVOList(familyInfoVOList); } } @@ -160,13 +215,16 @@ //查询当前用户房屋信息 List<ComMngHouseVo> houseList = comMngPopulationHouseDAO.getPopulHouseListByPopulId(populationId); - if(!houseList.isEmpty()){ + if (!houseList.isEmpty()) { + houseList.forEach(house -> { + + }); comMngPopulationVO.setHouseList(houseList); } //查询当前实有人口车辆信息 List<ComMngPopulationCarVO> carList = comMngCarDAO.getPopulationCarListByIdCard(comMngPopulationDO.getCardNo()); - if(!carList.isEmpty()){ + if (!carList.isEmpty()) { comMngPopulationVO.setCarList(carList); } return R.ok(comMngPopulationVO); @@ -184,14 +242,79 @@ 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); + + if (comMngPopulationVO.getHouseId() != null) { + ComMngPopulationHouseDO houseDO = comMngPopulationHouseDAO.selectById(comMngPopulationVO.getHouseId()); + if (houseDO != null) { + switch (comMngPopulationVO.getLevel()) { + case 1: + comMngPopulationVO.setRoad(houseDO.getAlley()); + break; + case 2: + comMngPopulationVO.setRoad(houseDO.getAlley()); + comMngPopulationVO.setDoorNo(houseDO.getHouseNum()); + break; + case 3: + comMngPopulationVO.setRoad(houseDO.getAlley()); + comMngPopulationVO.setDoorNo(houseDO.getHouseNum()); + comMngPopulationVO.setFloor(houseDO.getFloor()); + break; + case 4: + comMngPopulationVO.setRoad(houseDO.getAlley()); + comMngPopulationVO.setDoorNo(houseDO.getHouseNum()); + comMngPopulationVO.setFloor(houseDO.getFloor()); + 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()); + break; + default: + break; + } + } + } + + if (StringUtils.isNotEmpty(comMngPopulationVO.getAgeStart())) { + 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()))), "yyyy-MM-dd"); + if (StringUtils.isNotEmpty(ageEndTime)) { + comMngPopulationVO.setAgeEndTime(ageEndTime); + } + } + if (comMngPopulationVO.getAgeStartTime() !=null && !"".equals(comMngPopulationVO.getAgeStartTime()) && comMngPopulationVO.getAgeEndTime() !=null && !"".equals(comMngPopulationVO.getAgeEndTime())){ + if (comMngPopulationVO.getAgeStartTime().equals(comMngPopulationVO.getAgeEndTime())) { + Date endAge = DateUtils.stringToDate(comMngPopulationVO.getAgeEndTime(),new SimpleDateFormat("yyyy-MM-dd")); + String ageStartTime = DateUtils.getDateFormatString(DateUtils.yearAddNum(endAge, -1),"yyyy-MM-dd"); + if (StringUtils.isNotEmpty(ageStartTime)) { + comMngPopulationVO.setAgeStartTimeEnd(ageStartTime); + } + } + } IPage<ComMngPopulationVO> iPage = populationDAO.pagePopulation(page, comMngPopulationVO); + if (!iPage.getRecords().isEmpty()) { + iPage.getRecords().forEach(populDO -> { + if (StringUtils.isNotEmpty(populDO.getBirthday())) { + populDO.setAge(AgeUtils.getAgeFromBirthTimes(populDO.getBirthday())); + } + }); + } return R.ok(iPage); } @@ -231,161 +354,98 @@ @Override @Transactional(rollbackFor = Exception.class) - public R listSavePopulation(List<ComMngPopulationServeExcelVO> list, Long communityId) throws Exception{ + public R listSavePopulation(List<ComMngPopulationServeExcelVO> list, Long communityId) throws Exception { List<ComMngPopulationImportErrorVO> populationImportErrorVOList = new ArrayList<>(); //查询该社区 ComActDO comActDO = comActDAO.selectById(communityId); //查询该社区的省市区地址 - AreaAddressVO areaAddressVO = populationDAO.getAreaAddress(comActDO.getProvinceCode(),comActDO.getCityCode(),comActDO.getAreaCode()); + AreaAddressVO areaAddressVO = populationDAO.getAreaAddress(comActDO.getProvinceCode(), comActDO.getCityCode(), comActDO.getAreaCode()); //查询社区上街道信息 - String street = ""; - if(comActDO.getStreetId() != null){ + String streetName = ""; + if (comActDO.getStreetId() != null) { ComStreetDO streetDO = comStreetDAO.selectById(comActDO.getStreetId()); - if(streetDO != null){ - street = streetDO.getName(); + if (streetDO != null) { + streetName = streetDO.getName(); } } - int index = 2; + StringBuilder areaPath = new StringBuilder(); + areaPath.append(areaAddressVO.getProvince()).append(">").append(areaAddressVO.getCity()).append(">").append(areaAddressVO.getDistrict()).append(">"); //处理实有人口信息 - List<ComMngPopulationDO> savePopulList = new ArrayList<>(); 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 (vo.getDoorNo().contains("号")) { + vo.setDoorNo(vo.getDoorNo().replace("号","")); + } + if(vo.getFloor().contains("栋")){ + vo.setFloor(vo.getFloor().replace("栋","")); + } + if(vo.getUnitNo().contains("单元")){ + vo.setUnitNo(vo.getUnitNo().replace("单元","")); + } + if(vo.getHouseNo().contains("号")){ + vo.setHouseNo(vo.getHouseNo().replace("号","")); + } + //查询小区街路巷是否存在 + 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("查无:" + vo.getRoad() + vo.getDoorNo() + "小区/房租地址,请先新建地址"); - importErrorVO.setErrorPosition("第" + index + "行,第7、8列"); + importErrorVO.setErrorMsg("街路巷或小区号不存在"); + importErrorVO.setErrorPosition("街路巷:" + vo.getRoad() + ",小区号:" + vo.getDoorNo()); populationImportErrorVOList.add(importErrorVO); - index++; +// index++; continue; } - address = areaAddressVO.getProvince() + areaAddressVO.getCity() - + areaAddressVO.getDistrict() + street + comMngVillageDO.getAlley() + comMngVillageDO.getHouseNum() + "号" - + vo.getFloor() + vo.getUnitNo() + vo.getHouseNo(); - vo.setAddress(address); + StringBuilder address = new StringBuilder(); + address.append(areaAddressVO.getProvince()).append(areaAddressVO.getCity()).append(areaAddressVO.getDistrict()) + .append(streetName).append(comMngVillageDO.getAlley()).append(vo.getDoorNo()).append("号").append(vo.getFloor()).append("栋") + .append(vo.getUnitNo()).append("单元").append(vo.getHouseNo()).append("号"); + vo.setAddress(address.toString()); + + //todo 后期优化改为批量 //先判断房屋是否存在 ComMngPopulationHouseDO populationHouseDO = comMngPopulationHouseDAO.selectOne(new QueryWrapper<ComMngPopulationHouseDO>().lambda() - .eq(ComMngPopulationHouseDO::getCommunityId,communityId).eq(ComMngPopulationHouseDO::getAlley,vo.getRoad()).eq(ComMngPopulationHouseDO::getHouseNum,vo.getDoorNo()) - .eq(ComMngPopulationHouseDO::getFloor,vo.getFloor()).eq(ComMngPopulationHouseDO::getUnitNo,vo.getUnitNo()) - .eq(ComMngPopulationHouseDO::getHouseNo,vo.getHouseNo())); - if(populationHouseDO == null){ - //查询该房屋未建立,执行建立房屋信息 - populationHouseDO = new ComMngPopulationHouseDO(); - populationHouseDO.setAlley(vo.getRoad()); - populationHouseDO.setHouseNum(vo.getDoorNo()); - populationHouseDO.setCommunityId(communityId); - populationHouseDO.setFloor(vo.getFloor()); - populationHouseDO.setUnitNo(vo.getUnitNo()); - populationHouseDO.setHouseNo(vo.getHouseNo()); - populationHouseDO.setAddress(address); - if(StringUtils.isEmpty(vo.getName()) && StringUtils.isEmpty(vo.getCardNo())){ - populationHouseDO.setIsEmpty(PopulIsOksEnum.YES.getCode()); - } - if(vo.getHouseStatus() != null){ - populationHouseDO.setStatus(vo.getHouseStatus()); - } - if(vo.getHousePurpose() != null){ - populationHouseDO.setPurpose(vo.getHousePurpose()); - } - if(vo.getControlStatus() != null){ - populationHouseDO.setControlStatus(vo.getControlStatus()); - } - comMngPopulationHouseDAO.insert(populationHouseDO); + .eq(ComMngPopulationHouseDO::getCommunityId, communityId).eq(ComMngPopulationHouseDO::getVillageId, comMngVillageDO.getVillageId()) + .eq(ComMngPopulationHouseDO::getFloor, vo.getFloor()).eq(ComMngPopulationHouseDO::getUnitNo, vo.getUnitNo()) + .eq(ComMngPopulationHouseDO::getHouseNo, vo.getHouseNo())); + if (populationHouseDO == null) { + //房屋信息不存在建立房屋信息 + populationHouseDO = savePopulationHouse(vo, comMngVillageDO, communityId, areaPath, comActDO.getName()); + vo.setHouseId(populationHouseDO.getId()); } - if(StringUtils.isEmpty(vo.getName()) && StringUtils.isEmpty(vo.getCardNo())){ + if (StringUtils.isEmpty(vo.getName()) && StringUtils.isEmpty(vo.getCardNo())) { //空户处理完房屋信息,直接返回 continue; } - + String cardNoAES = AESUtil.encrypt128(vo.getCardNo(), aesKey); //判断实有人口是否已存在 ComMngPopulationDO populationDO = this.baseMapper.selectOne(new QueryWrapper<ComMngPopulationDO>().lambda() - .eq(ComMngPopulationDO::getCardNo,AESUtil.encrypt128(vo.getCardNo(), aesKey)).eq(ComMngPopulationDO::getName,vo.getName())); - if(populationDO == null){ - if(savePopulList.size() > 0){ - String name = vo.getName(); - String cardNo = AESUtil.encrypt128(vo.getCardNo(), aesKey); - if(savePopulList.stream().anyMatch(populDo -> name.equals(populDo.getName()) && cardNo.equals(populDo.getCardNo()))){ - //实有人口已存在,判断录入的这个房屋信息是否是用户的居住地 - for (ComMngPopulationDO savePopul:savePopulList) { - if(savePopul.getName().equals(name) && savePopul.getCardNo().equals(cardNo)){ - if(vo.getIsResidence() != null && vo.getIsResidence().equals(PopulIsOksEnum.YES.getCode())) { - savePopul.setRoad(vo.getRoad()); - savePopul.setDoorNo(vo.getDoorNo()); - savePopul.setFloor(vo.getFloor()); - savePopul.setUnitNo(vo.getUnitNo()); - savePopul.setHouseNo(vo.getHouseNo()); - savePopul.setHouseAddress(vo.getAddress()); - savePopul.setHouseId(populationHouseDO.getId()); - savePopul.setCardNo(cardNo); - savePopul.setPhone(AESUtil.encrypt128(savePopul.getPhone(), aesKey)); - this.baseMapper.updateById(savePopul); - } - populationDO = savePopul; - break; - } - } - }else{ - //不存在实有人口则新增 - populationDO = new ComMngPopulationDO(); - BeanUtils.copyProperties(vo,populationDO); - List<String> userTag = vo.getUserTagStr().stream().map(userTagStr -> userTagStr.split("\\(")[0]).collect(Collectors.toList()); - populationDO.setVillageId(comMngVillageDO.getVillageId()); - populationDO.setActId(comActDO.getCommunityId()); - populationDO.setStreetId(comActDO.getStreetId()); - populationDO.setLabel(Joiner.on(",").join(userTag)); - populationDO.setVillageName(comMngVillageDO.getGroupAt()); - populationDO.setHouseAddress(address); - populationDO.setHouseId(populationHouseDO.getId()); - this.baseMapper.insert(populationDO); - savePopulList.add(populationDO); - index++; - } - }else { - //不存在实有人口则新增 - populationDO = new ComMngPopulationDO(); - BeanUtils.copyProperties(vo,populationDO); - List<String> userTag = vo.getUserTagStr().stream().map(userTagStr -> userTagStr.split("\\(")[0]).collect(Collectors.toList()); - populationDO.setVillageId(comMngVillageDO.getVillageId()); - populationDO.setActId(comActDO.getCommunityId()); - populationDO.setStreetId(comActDO.getStreetId()); - populationDO.setLabel(Joiner.on(",").join(userTag)); - populationDO.setVillageName(comMngVillageDO.getGroupAt()); - populationDO.setHouseAddress(address); - populationDO.setHouseId(populationHouseDO.getId()); - this.baseMapper.insert(populationDO); - savePopulList.add(populationDO); - index++; - } - }else { - //实有人口已存在,判断录入的这个房屋信息是否是用户的居住地 - if(vo.getIsResidence() != null && vo.getIsResidence().equals(PopulIsOksEnum.YES.getCode())){ - populationDO.setRoad(vo.getRoad()); - populationDO.setDoorNo(vo.getDoorNo()); - populationDO.setFloor(vo.getFloor()); - populationDO.setUnitNo(vo.getUnitNo()); - populationDO.setHouseNo(vo.getHouseNo()); - populationDO.setHouseAddress(address); - populationDO.setCardNo(AESUtil.encrypt128(populationDO.getCardNo(), aesKey)); - populationDO.setPhone(AESUtil.encrypt128(populationDO.getPhone(), aesKey)); - populationDO.setHouseId(populationHouseDO.getId()); - this.baseMapper.updateById(populationDO); - } + .eq(ComMngPopulationDO::getCardNo, cardNoAES)); + if (populationDO == null) { + //不存在实有人口,则新增 + populationDO = savePopulationDO(vo, comActDO, comMngVillageDO); +// ComMngPopulationHouseUserDO comMngPopulationHouseUserDO = savePopulationHouseUser(vo, populationDO, populationHouseDO); + } else { + //如果存在人口信息,且是自用房,则更新人口默认的房屋信息 +// if (vo.getIsRent() != null && vo.getIsRent().equals(PopulHouseUseEnum.SELF.getCode())) { +// populationDO = updatePopulationDO(vo, populationDO); +// } + populationDO = updatePopulationDO(vo, populationDO); } - //处理实有房屋居住信息 - if(populationDO != null){ + //处理实有人口房屋居住信息 + if (populationDO != null) { ComMngPopulationHouseUserDO populationHouseUserDO = comMngPopulationHouseUserDAO.selectOne(new QueryWrapper<ComMngPopulationHouseUserDO>() - .lambda().eq(ComMngPopulationHouseUserDO::getHouseId,populationHouseDO.getId()) - .eq(ComMngPopulationHouseUserDO::getPopulId,populationDO.getId())); - if(populationHouseUserDO == null){ + .lambda().eq(ComMngPopulationHouseUserDO::getHouseId, populationHouseDO.getId()) + .eq(ComMngPopulationHouseUserDO::getPopulId, populationDO.getId())); + if (populationHouseUserDO == null) { populationHouseUserDO = new ComMngPopulationHouseUserDO(); + populationHouseUserDO.setId(Snowflake.getId()); populationHouseUserDO.setHouseId(populationHouseDO.getId()); populationHouseUserDO.setPopulId(populationDO.getId()); - populationHouseUserDO.setRelation(populationDO.getRelation()); + populationHouseUserDO.setRelation(vo.getRelation()); + populationHouseUserDO.setRelationId(vo.getIsRent()); comMngPopulationHouseUserDAO.insert(populationHouseUserDO); } } @@ -397,17 +457,127 @@ } this.saveBatch(populationDOList);*/ - if(!populationImportErrorVOList.isEmpty()){ + if (!populationImportErrorVOList.isEmpty()) { return R.fail(JSON.toJSONString(populationImportErrorVOList)); } return R.ok(); } + private ComMngPopulationDO updatePopulationDO(ComMngPopulationServeExcelVO vo, ComMngPopulationDO populationDO) throws Exception { + UpdateWrapper<ComMngPopulationDO> updateWrapper = new UpdateWrapper<>(); + updateWrapper.eq("id",populationDO.getId()); + ComMngPopulationDO update = new ComMngPopulationDO(); +// update.setRoad(vo.getRoad()); +// update.setDoorNo(vo.getDoorNo()); +// update.setFloor(vo.getFloor()); +// update.setUnitNo(vo.getUnitNo()); +// update.setHouseNo(vo.getHouseNo()); +// update.setHouseId(vo.getHouseId()); +// if (StringUtils.isNotEmpty(populationDO.getPhone())) { +// update.setPhone(populationDO.getPhone()); +// } + BeanUtils.copyProperties(vo, update); + this.baseMapper.update(update,updateWrapper); + return populationDO; + } + + private ComMngPopulationDO savePopulationDO(ComMngPopulationServeExcelVO vo, ComActDO comActDO, ComMngVillageDO comMngVillageDO) { + ComMngPopulationDO populationDO = new ComMngPopulationDO(); + 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()); + populationDO.setLabel(Joiner.on(",").join(userTag)); + populationDO.setVillageName(comMngVillageDO.getGroupAt()); + populationDO.setCardNoStr(vo.getCardNo()); + populationDO.setUpdateAt(new Date()); + //新增的时候默认绑定房屋id +// if ((vo.getIsRent() != null && vo.getIsRent().equals(PopulHouseUseEnum.SELF.getCode())) || +// (vo.getIsResidence() != null && vo.getIsResidence().intValue() == 1)) { +// populationDO.setHouseId(vo.getHouseId()); +// }else{ +// populationDO.setHouseId(null); +// } + + this.baseMapper.insert(populationDO); + return populationDO; + } + + private ComMngPopulationHouseDO savePopulationHouse(ComMngPopulationServeExcelVO vo, ComMngVillageDO comMngVillageDO, Long communityId,StringBuilder areaPath, String actName) { + //查询该房屋未建立,执行建立房屋信息 + ComMngPopulationHouseDO populationHouseDO = new ComMngPopulationHouseDO(); + populationHouseDO.setId(Snowflake.getId()); + populationHouseDO.setStreetId(comMngVillageDO.getStreetId()); + populationHouseDO.setVillageId(comMngVillageDO.getVillageId()); + populationHouseDO.setAlley(vo.getRoad()); + populationHouseDO.setHouseNum(vo.getDoorNo()); + populationHouseDO.setStatus(vo.getIsRent()); + populationHouseDO.setCommunityId(communityId); + populationHouseDO.setFloor(vo.getFloor()); + populationHouseDO.setUnitNo(vo.getUnitNo()); + populationHouseDO.setHouseNo(vo.getHouseNo()); + populationHouseDO.setCode(vo.getHouseNo()); + populationHouseDO.setAddress(vo.getAddress()); + populationHouseDO.setUpdateAt(new Date()); + populationHouseDO.setConstructPurpose(vo.getBuildPurpose()); + StringBuilder housePath = new StringBuilder(); + housePath.append(populationHouseDO.getAlley()).append(">").append(actName).append(">").append(comMngVillageDO.getName()).append(">").append(vo.getAddress()); + populationHouseDO.setPath(areaPath.toString() + housePath.toString()); + try { + populationHouseDO.setConstructArea(new BigDecimal(vo.getBuildArea())); + } catch (Exception e) { + } + + if (StringUtils.isEmpty(vo.getName()) && StringUtils.isEmpty(vo.getCardNo())) { + populationHouseDO.setIsEmpty(PopulIsOksEnum.YES.getCode()); + } + if (vo.getHouseStatus() != null) { + populationHouseDO.setStatus(vo.getHouseStatus()); + } + if (vo.getHousePurpose() != null) { + populationHouseDO.setPurpose(vo.getHousePurpose()); + } + if (vo.getControlStatus() != null) { + populationHouseDO.setControlStatus(vo.getControlStatus()); + } + comMngPopulationHouseDAO.insert(populationHouseDO); + return populationHouseDO; + } + + private ComMngPopulationHouseUserDO savePopulationHouseUser(ComMngPopulationServeExcelVO vo, ComMngPopulationDO comMngPopulationDO, ComMngPopulationHouseDO comMngPopulationHouseDO) { + //查询该房屋未建立,执行建立房屋信息 + ComMngPopulationHouseUserDO populationHouseUserDO = new ComMngPopulationHouseUserDO(); + populationHouseUserDO.setId(Snowflake.getId()); + populationHouseUserDO.setPopulId(comMngPopulationDO.getId()); + populationHouseUserDO.setHouseId(comMngPopulationHouseDO.getId()); + populationHouseUserDO.setRelationId(comMngPopulationHouseDO.getStatus()); + populationHouseUserDO.setRelation(vo.getRelation()); + populationHouseUserDO.setCreateAt(new Date()); + comMngPopulationHouseUserDAO.insert(populationHouseUserDO); + return populationHouseUserDO; + } + /** * 确认导入实有人口(有则更新,无则新建) - * @param list 用户信息 - * @param communityId 社区id - * @return 导入结果 + * + * @param list 用户信息 + * @param communityId 社区id + * @return 导入结果 */ @Override public R listSavePopulationConfirm(List<ComMngPopulationServeExcelVO> list, Long communityId) { @@ -422,7 +592,7 @@ list.forEach(vo -> { ComMngPopulationDO comMngPopulationDO = new ComMngPopulationDO(); //查询街路巷是否存在 - ComMngVillageDO comMngVillageDO = comActVillageDAO.selectOne(new QueryWrapper<ComMngVillageDO>().eq("alley",vo.getRoad()).eq("house_num",vo.getDoorNo()).eq("community_id",communityId)); + ComMngVillageDO comMngVillageDO = comActVillageDAO.selectOne(new QueryWrapper<ComMngVillageDO>().eq("alley", vo.getRoad()).eq("house_num", vo.getDoorNo()).eq("community_id", communityId)); // ComMngVillageDO comMngVillageDO = villageDOList.stream().filter(village -> village.getAlley().equals(vo.getRoad()) && village.getHouseNum().equals(Integer.valueOf(vo.getDoorNo()))).findFirst().orElse(null); BeanUtils.copyProperties(vo, comMngPopulationDO); if (comMngVillageDO == null) { @@ -437,7 +607,7 @@ populationDOList.add(comMngPopulationDO); }); - if(!populationDOList.isEmpty()){ + if (!populationDOList.isEmpty()) { //循环遍历待导入人员信息,如果数据库存在则更新,如果不存在则新建 populationDOList.forEach(population -> { try { @@ -447,14 +617,14 @@ //查询这个用户是否存在 ComMngPopulationDO comMngPopulationDO = this.populationDAO.selectOne(new QueryWrapper<ComMngPopulationDO>().lambda() .eq(ComMngPopulationDO::getCardNo, population.getCardNo())); - if(comMngPopulationDO != null){ + if (comMngPopulationDO != null) { population.setId(comMngPopulationDO.getId()); - BeanUtils.copyProperties(population,comMngPopulationDO); + BeanUtils.copyProperties(population, comMngPopulationDO); this.populationDAO.updateById(population); - }else{ + } else { this.populationDAO.insert(population); } - }catch (Exception e){ + } catch (Exception e) { log.error("导入实有人口失败"); } }); @@ -474,6 +644,7 @@ /** * 根据id修改实有人口标签 + * * @param populationTagDTO 请求参数 * @return 修改结果 */ @@ -483,10 +654,10 @@ if (comMngPopulationDO == null) { return R.fail("未查询到人口记录"); } - BeanUtils.copyProperties(populationTagDTO,comMngPopulationDO); + BeanUtils.copyProperties(populationTagDTO, comMngPopulationDO); int nub = populationDAO.updateById(comMngPopulationDO); - if(nub < 1){ + if (nub < 1) { return R.fail(); } return R.ok(); @@ -494,11 +665,19 @@ /** * 批量删除实有人口 + * * @param Ids * @return */ @Override + @Transactional(rollbackFor = Exception.class) public R deletePopulations(List<Long> Ids) { + if (!Ids.isEmpty()) { + Ids.forEach(id -> { + //清除用户房屋居住信息 + comMngPopulationHouseUserDAO.deletePopulationHouseByUserId(id); + }); + } int delete = populationDAO.deleteBatchIds(Ids); if (delete > 0) { return R.ok(); @@ -508,17 +687,18 @@ /** * 根据社区id查询所有实有人口 - * @param communityId 社区id - * @return 查询结果 + * + * @param communityId 社区id + * @return 查询结果 */ @Override public R getPopulationListByCommunityId(Long communityId) { - List<ComMngPopulationDO> list = populationDAO.selectList(new QueryWrapper<ComMngPopulationDO>().eq("act_id",communityId)); + List<ComMngPopulationDO> list = populationDAO.selectList(new QueryWrapper<ComMngPopulationDO>().eq("act_id", communityId)); List<ComMngPopulationVO> resultList = new ArrayList<>(); - if(list.size() > 0){ + if (list.size() > 0) { list.forEach(populationDO -> { - ComMngPopulationVO populationVO=new ComMngPopulationVO(); - BeanUtils.copyProperties(populationDO,populationVO); + ComMngPopulationVO populationVO = new ComMngPopulationVO(); + BeanUtils.copyProperties(populationDO, populationVO); resultList.add(populationVO); }); } @@ -527,17 +707,18 @@ /** * 根据id集合查询实有人口 - * @param Ids 实有人口id集合 - * @return 查询结果 + * + * @param Ids 实有人口id集合 + * @return 查询结果 */ @Override public R getPopulationLists(List<Long> Ids) { List<ComMngPopulationDO> list = populationDAO.selectBatchIds(Ids); List<ComMngPopulationVO> resultList = new ArrayList<>(); - if(list.size() > 0){ + if (list.size() > 0) { list.forEach(populationDO -> { ComMngPopulationVO populationVO = new ComMngPopulationVO(); - BeanUtils.copyProperties(populationDO,populationVO); + BeanUtils.copyProperties(populationDO, populationVO); resultList.add(populationVO); }); } @@ -545,95 +726,217 @@ } @Override - public R editPopulation(EditComMngPopulationVO vo, Long communityId) { - ComActDO comActDO = comActDAO.selectById(communityId); + public R getPopulationListByVillageId(Long villageId) { + List<ComMngPopulationDO> list = populationDAO.selectList(new QueryWrapper<ComMngPopulationDO>().eq("village_id", villageId)); + List<ComMngPopulationVO> resultList = new ArrayList<>(); + if (list.size() > 0) { + list.forEach(populationDO -> { + ComMngPopulationVO populationVO = new ComMngPopulationVO(); + BeanUtils.copyProperties(populationDO, populationVO); + resultList.add(populationVO); + }); + } + return R.ok(resultList); + } + + @Override + public R editPopulation(ComMngPopulationEditDTO vo, Long communityId) throws Exception { ComMngPopulationDO populationDO = populationDAO.selectById(vo.getId()); - if(populationDO==null){ + if (populationDO == null) { return R.fail(); } - String cardNo = populationDO.getCardNo(); - BeanUtils.copyProperties(vo,populationDO); - try { - //TODO 修改拦截器时候需要维护加密操作 - if(!cardNo.equals(vo.getCardNo())){//判断是否修改身份证号码 - //判断要修改的身份证号码是否已存在 - ComMngPopulationDO cardNoDO = populationDAO.selectOne(new QueryWrapper<ComMngPopulationDO>() - .lambda().eq(ComMngPopulationDO::getCardNo,vo.getCardNo())); - if(cardNoDO != null){ - return R.fail("您输入的身份证已存在,请重新输入"); - } - populationDO.setCardNo(AESUtil.encrypt128(vo.getCardNo(), aesKey)); - }else{ - populationDO.setCardNo(AESUtil.encrypt128(cardNo, aesKey)); - } - populationDO.setPhone(AESUtil.encrypt128(vo.getPhone(), aesKey)); - } catch (Exception e) { - e.printStackTrace(); - return R.fail(); + BeanUtils.copyProperties(vo, populationDO); + if (StringUtils.isEmpty(vo.getLabel())) { + populationDO.setLabel(null); + } + if (StringUtils.isEmpty(vo.getRemark())) { + populationDO.setRemark(null); + } + populationDO.setCardNo(null); + populationDO.setPhone(AESUtil.encrypt128(vo.getPhone(), aesKey)); + + ComActDO comActDO = comActDAO.selectById(communityId); + if (comActDO != null) { + populationDO.setActId(comActDO.getCommunityId()); + populationDO.setStreetId(comActDO.getStreetId()); } - ComMngVillageDO comMngVillageDO = comActVillageDAO.selectOne(new QueryWrapper<ComMngVillageDO>().eq("alley",vo.getRoad()).eq("house_num",vo.getDoorNo()).eq("community_id",communityId)); - if (comMngVillageDO == null) { - return R.fail("街道巷:" + vo.getRoad() + vo.getDoorNo() + "不存在!"); -// throw new ServiceException("街道巷:" + vo.getRoad() + "不存在!"); + //查询当前用户所有房屋id + List<Long> houseIds = comMngPopulationHouseUserDAO.getPopulationHouseIdByUserId(vo.getId()); + //清除用户房屋居住信息 + comMngPopulationHouseUserDAO.deletePopulationHouseByUserId(vo.getId()); + if (!houseIds.isEmpty()) { + houseIds.forEach(houseId -> { + //查询当前房屋下是否有人口信息,如果没有则将房屋设置为空户 + List<Long> oldHouseIds = comMngPopulationHouseUserDAO.getPopulationHouseIdByhHosueId(houseId); + if (oldHouseIds.isEmpty()) { + //修改房屋信息为空户 + comMngPopulationHouseDAO.updateHouseByIsEmpty(houseId, 1); + } + }); } - populationDO.setVillageId(comMngVillageDO.getVillageId()); - populationDO.setActId(comActDO.getCommunityId()); - populationDO.setStreetId(comActDO.getStreetId()); - if(!StringUtils.isEmpty(comMngVillageDO.getGroupAt())){ - populationDO.setVillageName(comMngVillageDO.getGroupAt()); + + + //更新用户的房屋信息 + Long houseId = null; + List<ComMngPopulationHouseUserDO> populationHouseUserDOList = new ArrayList<>(); + if (!vo.getHouseEditDTOList().isEmpty()) { + for (ComMngPopulationHouseEditDTO houseEditDto : vo.getHouseEditDTOList()) { + ComMngPopulationHouseUserDO populationHouseUserDO = new ComMngPopulationHouseUserDO(); + populationHouseUserDO.setId(Snowflake.getId()); + populationHouseUserDO.setPopulId(populationDO.getId()); + populationHouseUserDO.setHouseId(houseEditDto.getId()); + if (houseEditDto.getIsResidence().equals(ComMngPopulationHouseEditDTO.isResidence.yes)) { + houseId = houseEditDto.getId();//居住地 + } + populationHouseUserDOList.add(populationHouseUserDO); + + //修改房屋信息不为空户 + comMngPopulationHouseDAO.updateHouseByIsEmpty(houseEditDto.getId(), 2); + } } - populationDO.setUpdateAt(new Date()); -// this.updateById(populationDO); - if(populationDAO.updateById(populationDO) > 0){ + comMngPopulationHouseUserService.saveBatch(populationHouseUserDOList); + + if (houseId != null) {//居住地更新 + ComMngPopulationHouseDO houseDO = comMngPopulationHouseDAO.selectById(houseId); + if (houseDO != null) { + populationDO.setRoad(houseDO.getAlley()); + populationDO.setDoorNo(houseDO.getHouseNum()); + populationDO.setFloor(houseDO.getFloor()); + populationDO.setUnitNo(houseDO.getUnitNo()); + populationDO.setHouseNo(houseDO.getHouseNo()); + ComMngVillageDO comMngVillageDO = comActVillageDAO.selectOne(new QueryWrapper<ComMngVillageDO>().lambda() + .eq(ComMngVillageDO::getAlley, houseDO.getAlley()).eq(ComMngVillageDO::getHouseNum, houseDO.getHouseNum()) + .eq(ComMngVillageDO::getCommunityId, communityId)); + if (comMngVillageDO != null) { + populationDO.setVillageId(comMngVillageDO.getVillageId()); + if (!StringUtils.isEmpty(comMngVillageDO.getGroupAt())) { + populationDO.setVillageName(comMngVillageDO.getGroupAt()); + } + } + } + } + + 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(); - }else{ + } else { return R.fail("修改失败"); } } @Override - public R specialInputUser(PageInputUserDTO pageInputUserDTO){ + public R specialInputUser(PageInputUserDTO pageInputUserDTO) { IPage<InputUserInfoVO> iPage = populationDAO.specialInputUser(new Page<>(pageInputUserDTO.getPageNum() - ,pageInputUserDTO.getPageSize()), pageInputUserDTO); + , pageInputUserDTO.getPageSize()), pageInputUserDTO); return R.ok(iPage); } /** * 删除特殊群体人员 - * @param id 特殊群体id - * @return 删除结果 + * + * @param id 特殊群体id + * @return 删除结果 */ @Override - public R deleteSpecialInputUser(Long id){ + public R deleteSpecialInputUser(Long id) { //查询特殊群体人员 ComMngPopulationDO populationDO = this.baseMapper.selectById(id); - if(populationDO == null){ + if (populationDO == null) { return R.fail("未查询到该记录"); } populationDO.setLabel(null); - if(this.baseMapper.updateById(populationDO) > 0){ + if (this.baseMapper.updateById(populationDO) > 0) { return R.ok(); - }else{ + } else { return R.fail(); } } + @Override + public R specialInputUserTags(PageInputUserDTO comMngUserTagDTO) { + IPage<ComMngTagVO> iPage = populationDAO.specialInputUserTags(new Page<>(comMngUserTagDTO.getPageNum() + , comMngUserTagDTO.getPageSize()), comMngUserTagDTO); + return R.ok(iPage); + } + + @Override + public R saveSpecialInputUserTags(ComMngTagVO comMngTagVO) { + if (null != comMngTagVO.getId() && comMngTagVO.getId() != 0) { + //修改 + ComMngUserTagDO comMngUserTagDO = comMngUserTagDAO.selectById(comMngTagVO.getId()); + if (null == comMngUserTagDO) { + return R.fail("该标签不存在"); + } + ComMngUserTagDO checkCreditCode = comMngUserTagDAO.selectOne(new QueryWrapper<ComMngUserTagDO>().lambda().eq(ComMngUserTagDO::getTagName, comMngTagVO.getTagName())); + if (null != checkCreditCode && comMngUserTagDO.getId() != checkCreditCode.getId()) { + return R.fail("该标签已存在,标签名称重复"); + } + + BeanUtils.copyProperties(comMngTagVO, comMngUserTagDO); + int update = comMngUserTagDAO.updateById(comMngUserTagDO); + if (update > 0) { + return R.ok(); + } + } else { + //新增 + Integer count = comMngUserTagDAO.selectCount(new QueryWrapper<ComMngUserTagDO>().lambda().eq(ComMngUserTagDO::getTagName, comMngTagVO.getTagName())); + if (count > 0) { + return R.fail("该标签已存在,标签名称重复"); + } + ComMngUserTagDO comMngUserTagDO = new ComMngUserTagDO(); + BeanUtils.copyProperties(comMngTagVO, comMngUserTagDO); + int insert = comMngUserTagDAO.insert(comMngUserTagDO); + if (insert > 0) { + return R.ok(); + } + } + + return R.fail("添加失败"); + } + + @Override + public R deleteSpecialInputUserTags(Long id) { + //查询特殊群体人员 + ComMngUserTagDO comMngUserTagDO = comMngUserTagDAO.selectById(id); + if (comMngUserTagDO == null) { + return R.fail("该标签不存在"); + } + int delete = comMngUserTagDAO.deleteById(id); + if (delete > 0) { + return R.ok(); + } + return R.fail("删除失败"); + } + /** * 查询实有人口电子档信息 - * @param populationId 实有人口id - * @return 实有人口电子档信息 + * + * @param populationId 实有人口id + * @return 实有人口电子档信息 */ @Override - public R electronicArchivesPopulation(Long populationId){ + public R electronicArchivesPopulation(Long populationId) { ComMngPopulationDO comMngPopulationDO = populationDAO.selectById(populationId); if (ObjectUtils.isEmpty(comMngPopulationDO)) { return R.fail("用户信息不存在"); } //查询当前用户电子档信息 - if(!StringUtils.isEmpty(comMngPopulationDO.getCardNo())){ + if (!StringUtils.isEmpty(comMngPopulationDO.getCardNo())) { UserElectronicFileVO electronicFileVO = populationDAO.getSysUserElectronicFile(comMngPopulationDO.getCardNo()); - if(electronicFileVO != null){ + if (electronicFileVO != null) { return R.ok(electronicFileVO); } } @@ -643,10 +946,924 @@ @Override public R editUserElectronicFile(UserElectronicFileVO userElectronicFileVO) { UserElectronicFileVO electronicFileVO = populationDAO.getSysUserById(userElectronicFileVO.getUserId()); - if(electronicFileVO==null){ + if (electronicFileVO == null) { return R.fail("id有误!"); } - populationDAO.updateSysUserElectronicFile(userElectronicFileVO); + populationDAO.updateSysUserElectronicFile(userElectronicFileVO); return R.ok(); } -} + + /** + * 实有人口统计 + * + * @param communityId 社区id + * @return 统计结果 + */ + @Override + public R getPopulationTotalByAdmin(Long communityId) { + return R.ok(this.baseMapper.getPopulationTotalByAdmin(communityId)); + } + + @Override + public R editTagPopulationByCardNo(ComMngPopulationTagCardNoDTO comMngPopulationTagCardNoDTO) { + ComMngPopulationDO comMngPopulationDO = getPopulationByCardNo(comMngPopulationTagCardNoDTO.getCardNo()); + if (comMngPopulationDO == null) { + return R.fail("未查询到人口记录"); + } + ComMngPopulationDO comMngPopulation = new ComMngPopulationDO(); + if (comMngPopulationDO.getLabel() != null) { + if (!comMngPopulationDO.getLabel().contains(comMngPopulationTagCardNoDTO.getLabel())) { + comMngPopulation.setLabel(comMngPopulationTagCardNoDTO.getLabel().concat(",").concat(comMngPopulationDO.getLabel())); + } + } else { + comMngPopulation.setLabel(comMngPopulationTagCardNoDTO.getLabel()); + } + comMngPopulation.setCardNo(null); + comMngPopulation.setId(comMngPopulationDO.getId()); + int nub = populationDAO.updateById(comMngPopulation); + if (nub < 1) { + return R.fail(); + } + return R.ok(); + } + + @Override + public ComMngPopulationDO getPopulationByCardNo(String cardNo) { + try { + String aesCardNo = AESUtil.encrypt128(cardNo, aesKey); + return baseMapper.selectOne( + new QueryWrapper<ComMngPopulationDO>() + .eq("card_no", aesCardNo) + ); + } catch (Exception e) { + log.error("根据身份证查询业务-加密证件信息出错:{}", e.getCause()); + } + 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 screenEventDTO 请求参数 + * @return 统计结果 + */ + @Override + public R getScreenEvent(BigScreenEventDTO screenEventDTO) { + + Long communityId = screenEventDTO.getCommunityId(); + //创建统计返回参数 + EventStatisticsVO statisticsVO = new EventStatisticsVO(); + + //查询页面左边数据 + EventLeftStatisticsVO leftStatisticsVO = new EventLeftStatisticsVO(); + //查询左上数据 + EventLeftTopStatisticsVO leftTopStatisticsVO = this.baseMapper.getEventScreenLeftTop(screenEventDTO); + //查询时间频发月份 + List<Integer> monthList = this.baseMapper.getFrequentlyEventMonth(communityId); + leftTopStatisticsVO.setOftenMonth(monthList); + leftStatisticsVO.setLeftTopStatisticsVO(leftTopStatisticsVO); + //查询左下数据 + EventLeftDownStatisticsVO leftDownStatisticsVO = this.baseMapper.getEventScreenLeftDown(screenEventDTO); + 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(screenEventDTO); + 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); + if(communityId.equals(2L)){ + populationTotalVO.setSpecialTotal(36); + } + 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(); + ComMngPopulationTotalVO vo = populationDAO.getPopulationTotalByAdmin(communityId); + 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()); + + //查询特殊人群统计 + 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); + + //统计性别 + Map<String, Long> sexMap = populationDAO.countBySex(communityId); + comActPopulationScreenVO.setWoman(sexMap.get("woman") == null ? 0L : sexMap.get("woman")); + comActPopulationScreenVO.setManNum(sexMap.get("man") == null ? 0L : sexMap.get("man")); + int manPoint = (int) (((double) comActPopulationScreenVO.getManNum() / (double) comActPopulationScreenVO.getTotalNum()) * 100); + comActPopulationScreenVO.setManPoint(manPoint); + comActPopulationScreenVO.setWomanPoint(100 - manPoint); + + //统计年龄结构 + setAgeGroup(comActPopulationScreenVO, communityId); + //统计学历 + setCultureGroup(comActPopulationScreenVO, communityId); + + //查询网格数据 + List<EventGridStatisticsVO> gridStatisticsList = this.baseMapper.getEventScreenGridData(communityId); + comActPopulationScreenVO.setGridStatisticsList(gridStatisticsList); + + //查询小区列表 + List<CivilVillageStatisticsVO> villageStatisticsList = this.baseMapper.getCivilScreenVillageList(communityId); + comActPopulationScreenVO.setVillageStatisticsList(villageStatisticsList); + + return R.ok(comActPopulationScreenVO); + } + + + private void setCultureGroup(ComActPopulationScreenVO comActPopulationScreenVO, Long communityId) { + Map<String, Long> cultureMap = populationDAO.countByCulture(communityId); + List<ComActPopulationCultureVO> cultureGroup = new ArrayList<>(); + ComActPopulationCultureVO xx = new ComActPopulationCultureVO(); + xx.setLevel(PopulCultureLevelEnum.XX.getName()); + xx.setNum(cultureMap.get("xx")); + cultureGroup.add(xx); + + ComActPopulationCultureVO cz = new ComActPopulationCultureVO(); + cz.setLevel(PopulCultureLevelEnum.CZ.getName()); + cz.setNum(cultureMap.get("cz")); + cultureGroup.add(cz); + + ComActPopulationCultureVO gz = new ComActPopulationCultureVO(); + gz.setLevel(PopulCultureLevelEnum.GZ.getName()); + gz.setNum(cultureMap.get("gz")); + cultureGroup.add(gz); + + ComActPopulationCultureVO zz = new ComActPopulationCultureVO(); + zz.setLevel(PopulCultureLevelEnum.ZZ.getName()); + zz.setNum(cultureMap.get("zz")); + cultureGroup.add(zz); + + ComActPopulationCultureVO dz = new ComActPopulationCultureVO(); + dz.setLevel(PopulCultureLevelEnum.DZ.getName()); + dz.setNum(cultureMap.get("dz")); + cultureGroup.add(dz); + + ComActPopulationCultureVO bk = new ComActPopulationCultureVO(); + bk.setLevel(PopulCultureLevelEnum.BK.getName()); + bk.setNum(cultureMap.get("bk")); + cultureGroup.add(bk); + + ComActPopulationCultureVO ss = new ComActPopulationCultureVO(); + ss.setLevel(PopulCultureLevelEnum.SS.getName()); + ss.setNum(cultureMap.get("ss")); + cultureGroup.add(ss); + + ComActPopulationCultureVO bs = new ComActPopulationCultureVO(); + bs.setLevel(PopulCultureLevelEnum.BS.getName()); + bs.setNum(cultureMap.get("bs")); + cultureGroup.add(bs); + + ComActPopulationCultureVO qt = new ComActPopulationCultureVO(); + qt.setLevel(PopulCultureLevelEnum.QT.getName()); + qt.setNum(cultureMap.get("qt")); + cultureGroup.add(qt); + + comActPopulationScreenVO.setCultureGroup(cultureGroup); + } + + private void setAgeGroup(ComActPopulationScreenVO comActPopulationScreenVO, Long communityId) { + Map<String, Long> ageMap = populationDAO.countByAge(communityId); + List<ComMngPopulationAgeVO> ageList = new ArrayList<>(); + ComMngPopulationAgeVO ageVO16 = new ComMngPopulationAgeVO(); + ageVO16.setGroup("0-16岁"); + ageVO16.setNum(ageMap.get("age16")); + ageList.add(ageVO16); + ComMngPopulationAgeVO ageVO25 = new ComMngPopulationAgeVO(); + ageVO25.setGroup("16-25岁"); + ageVO25.setNum(ageMap.get("age25")); + ageList.add(ageVO25); + + ComMngPopulationAgeVO ageVO35 = new ComMngPopulationAgeVO(); + ageVO35.setGroup("25-35岁"); + ageVO35.setNum(ageMap.get("age35")); + ageList.add(ageVO35); + ComMngPopulationAgeVO ageVO45 = new ComMngPopulationAgeVO(); + ageVO45.setGroup("35-45岁"); + ageVO45.setNum(ageMap.get("age45")); + ageList.add(ageVO45); + ComMngPopulationAgeVO ageVO55 = new ComMngPopulationAgeVO(); + ageVO55.setGroup("45-55岁"); + ageVO55.setNum(ageMap.get("age55")); + ageList.add(ageVO55); + ComMngPopulationAgeVO ageVO55over = new ComMngPopulationAgeVO(); + ageVO55over.setGroup("55岁以上"); + ageVO55over.setNum(ageMap.get("age55over")); + ageList.add(ageVO55over); + comActPopulationScreenVO.setAgeGroup(ageList); + } + + /** + * 获取社区网格 + * + * @param communityId 社区id + * @return 网格数据 + */ + @Override + public R getScreenGirds(Long communityId) { + return R.ok(this.baseMapper.getEventScreenGridData(communityId)); + } + + /** + * 事件大屏查询事件详情 + * + * @param eventDetailDTO 请求参数 + * @return 事件详情 + */ + @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); + } + + /** + * 获取人口数据信息 + * + * @param populationListDTO 请求参数 + * @return 人口数据 + */ + @Override + public R pagePopulationListApp(PagePopulationListDTO populationListDTO){ + IPage<PopulationListVO> pagePopulationList = this.baseMapper.pagePopulationListApp(new Page(populationListDTO.getPageNum(),populationListDTO.getPageSize()),populationListDTO); + if(!pagePopulationList.getRecords().isEmpty()){ + pagePopulationList.getRecords().forEach(population -> { + population.setAge(IdcardUtil.getAgeByIdCard(population.getCardNo())); + }); + } + return R.ok(pagePopulationList); + } + + /** + * 根据人口id获取人口详情 + * + * @param populationId 人口id + * @return 人口详情 + */ + @Override + public R getPopulationDetailApp(Long populationId){ + PopulationDetailVO detail = this.baseMapper.getPopulationDetailApp(populationId); + if(detail != null){ + detail.setAge(IdcardUtil.getAgeByIdCard(detail.getCardNo())); + if(StringUtils.isNotEmpty(detail.getCultureLevel())){ + detail.setCultureLevel(PopulCultureLevelEnum.getCnDescByName(Integer.parseInt(detail.getCultureLevel()))); + } + if(StringUtils.isNotEmpty(detail.getMarriage())){ + detail.setMarriage(PopulMarriageEnum.getCnDescByName(Integer.parseInt(detail.getMarriage()))); + } + } + return R.ok(detail); + } + + /** + * 修复人口加密问题 + * + * @return 修复结果 + */ + @Override + @Transactional(rollbackFor = Exception.class) + public R getPopulationRepairByApp(){ + List<ComMngPopulationDO> populationDOList = this.baseMapper.selectList(new QueryWrapper<ComMngPopulationDO>()); + if(!populationDOList.isEmpty()){ + populationDOList.forEach(population -> { + try { + population.setCardNo(AESUtil.encrypt128(population.getCardNoStr(),aesKey)); + }catch (Exception e){ + + } + this.baseMapper.updateById(population); + }); + } + return R.ok(); + } + + /** + * 综治后台-居民列表 + * @param populationListDTO 请求参数 + * @return 居民列表 + */ + @Override + public R getGridPopulationAdminList(ComMngPopulationListDTO populationListDTO){ + IPage<ComMngPopulationListVO> populationListIPage = this.baseMapper.getGridPopulationAdminList(new Page(populationListDTO.getPageNum(),populationListDTO.getPageSize()),populationListDTO); + if(!populationListIPage.getRecords().isEmpty()){ + populationListIPage.getRecords().forEach(population -> { + try { + Integer age = IdcardUtil.getAgeByIdCard(population.getCardNo()); + population.setAge(age); + }catch (Exception e){ + log.error("当前人口身份证获取年龄失败,实有人口id:" + population.getId()); + } + //查询此用户在当前房屋是否是户主 + Integer relation = this.baseMapper.getPopulationRelationByHouseId(population.getHouseId(),population.getId()); + if(relation == null || relation != 1){ + population.setIsRelation(2); + }else{ + population.setIsRelation(1); + } + }); + } + return R.ok(populationListIPage); + } + + /** + * 综治后台-删除居民 + * @param ids 居民id集合 + * @return 删除结果 + */ + @Override + public R delGridPopulationAdmin(List<Long> ids){ + Integer count = this.baseMapper.getPopulationVisitingCount(ids); + if(count > 0){ + return R.ok("您选择的数据中存在被引用的,无法删除"); + } + this.baseMapper.deleteBatchIds(ids); + return R.ok(); + } + + @Override + public R binding() { + QueryWrapper<ComMngPopulationDO> query = new QueryWrapper<>(); + query.isNull("house_id"); + List<ComMngPopulationDO> list = baseMapper.selectList(query); + list.forEach(e->{ + QueryWrapper<ComMngPopulationHouseDO> houseQuery = new QueryWrapper<>(); + houseQuery.lambda().eq(ComMngPopulationHouseDO::getCommunityId,e.getActId()) + .eq(ComMngPopulationHouseDO::getAlley,e.getRoad()) + .eq(ComMngPopulationHouseDO::getFloor,e.getFloor()) + .eq(ComMngPopulationHouseDO::getUnitNo,e.getUnitNo()) + .eq(ComMngPopulationHouseDO::getHouseNo,e.getHouseNo()); + List<ComMngPopulationHouseDO> houseList = comMngPopulationHouseDAO.selectList(houseQuery); + if(!CollectionUtils.isEmpty(houseList)){ + UpdateWrapper<ComMngPopulationDO> updateWrapper = new UpdateWrapper(); + updateWrapper.eq("id",e.getId()); + ComMngPopulationDO populationDO = new ComMngPopulationDO(); + populationDO.setHouseId(houseList.get(0).getId()); + baseMapper.update(populationDO,updateWrapper); + } + }); + return R.ok(); + } + + /** + * 查询平台人口列表 + * @param populationDTO 请求参数 + * @return 人口列表 + */ + @Override + public R getBuildingHousePopulationList(PageComMngPopulationDTO populationDTO){ + + IPage<EventSpecialPopulationVO> populationVOIPage = this.baseMapper.getBuildingHousePopulationList(new Page(populationDTO.getPageNum(),populationDTO.getPageSize()),populationDTO); + if(!populationVOIPage.getRecords().isEmpty()){ + populationVOIPage.getRecords().forEach(population -> { + try { + Integer age = IdcardUtil.getAgeByIdCard(population.getIdCard()); + population.setAge(age); + }catch (Exception e){ + log.error("人员身份证转换年龄失败,人员id:" + population.getId()); + } + }); + } + return R.ok(populationVOIPage); + } + + /** + * 综治后台-居民标签栏统计 + * @return 居民统计 + */ + @Override + public R getGridPopulationStatistics(Long communityId){ + return R.ok(this.baseMapper.getGridPopulationStatistics(communityId)); + } + + /** + * 综治后台-居民导出查询居民数据 + * @param populationExportDTO 请求参数 + * @return 导出结果 + */ + @Override + public R getGridPopulationExport(ComMngPopulationExportDTO populationExportDTO){ + //结果集 + List<ComMngPopulationExportExcelVO> resultPopulationList = new ArrayList<>(); + //查询人口信息 + List<ComMngPopulationListVO> populationListVOList = this.baseMapper.getGridPopulationAdminLists(populationExportDTO); + if(!populationListVOList.isEmpty()){ + populationListVOList.forEach(population -> { + ComMngPopulationExportExcelVO populationExportExcelVO = new ComMngPopulationExportExcelVO(); + BeanUtils.copyProperties(population,populationExportExcelVO); + if(population.getSex() != null){ + populationExportExcelVO.setSex(PopulSexEnum.getCnDescByName(population.getSex())); + } + if(population.getPoliticalOutlook() != null){ + populationExportExcelVO.setPoliticalOutlook(PopulPoliticalOutlookEnum.getCnDescByName(population.getPoliticalOutlook())); + } + if(population.getIsHouse() != null){ + if(!population.getIsHouse().equals(0L)){ + populationExportExcelVO.setIsHouse("是"); + }else{ + populationExportExcelVO.setIsHouse("否"); + } + } + if(population.getEventStatus() != null){ + populationExportExcelVO.setEventStatus(EventStatusEnum.getCnDescByName(population.getEventStatus())); + } + try { + Integer age = IdcardUtil.getAgeByIdCard(population.getCardNo()); + populationExportExcelVO.setAge(age); + }catch (Exception e){ + log.error("当前人口身份证获取年龄失败,实有人口id:" + population.getId()); + } + resultPopulationList.add(populationExportExcelVO); + }); + } + return R.ok(resultPopulationList); + } + + /** + * 综治后台-居民管理小区列表 + * @param name 小区名字 + * @return 小区列表 + */ + @Override + public R relationVillage(String name){ + List<ComMngPopulationVillageVO> populationVillageList = new ArrayList<>(); + QueryWrapper<ComMngVillageDO> villageQuery = new QueryWrapper<>(); + if(StringUtils.isNotEmpty(name)){ + villageQuery.lambda().like(ComMngVillageDO::getName,name); + } + + List<ComMngVillageDO> villageList = comActVillageDAO.selectList(villageQuery); + if(!villageList.isEmpty()){ + villageList.forEach(village -> { + ComMngPopulationVillageVO populationVillageVO = new ComMngPopulationVillageVO(); + BeanUtils.copyProperties(village,populationVillageVO); + populationVillageList.add(populationVillageVO); + }); + } + return R.ok(populationVillageList); + } + + @Override + public R getVillagePopulationAdmin(PageComMngVillagePopulationDTO villagePopulationDTO){ + return R.ok(this.baseMapper.getVillagePopulationAdmin(new Page(villagePopulationDTO.getPageNum(),villagePopulationDTO.getPageSize()),villagePopulationDTO)); + } + +} \ No newline at end of file -- Gitblit v1.7.1