| | |
| | | |
| | | import com.baomidou.mybatisplus.core.conditions.Wrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.segments.MergeSegments; |
| | | import com.panzhihua.common.model.vos.community.bigscreen.WestScreenStatics; |
| | | import com.panzhihua.common.model.vos.community.screen.civil.*; |
| | | import com.panzhihua.common.model.vos.community.bigscreen.*; |
| | | import com.panzhihua.common.utlis.*; |
| | | import com.panzhihua.service_community.util.WxDataUtil; |
| | | import org.springframework.beans.BeanUtils; |
| | | import org.springframework.beans.factory.annotation.Value; |
| | | import org.springframework.context.annotation.Bean; |
| | |
| | | import com.panzhihua.common.model.helper.AESUtil; |
| | | import com.panzhihua.common.model.vos.R; |
| | | 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; |
| | |
| | | private ComActReserveMapper comActReserveMapper; |
| | | @Value("${domain.aesKey:}") |
| | | private String aesKey; |
| | | @Resource |
| | | private ComActEasyPhotoDAO comActEasyPhotoDAO; |
| | | @Resource |
| | | private ComMngBuildingDAO comMngBuildingDAO; |
| | | |
| | | /** |
| | | * 新增实有人口 |
| | |
| | | |
| | | ComMngPopulationVO comMngPopulationVO = new ComMngPopulationVO(); |
| | | BeanUtils.copyProperties(comMngPopulationDO, comMngPopulationVO); |
| | | |
| | | comMngPopulationVO.setCultureLevelName(PopulCultureLevelEnum.getCnDescByName(comMngPopulationVO.getCultureLevel())); |
| | | // 查询户主关系信息 |
| | | // List<ComHouseMemberVo> comMngFamilyInfoVOS = |
| | | // populationDAO.listHouseMermberByUserId(comMngPopulationDO.getHouseId(),comMngPopulationDO.getId()); |
| | |
| | | if (!comMngPopulationHouseUserDOS.isEmpty()) { |
| | | comMngPopulationVO |
| | | .setRelation(comMngPopulationHouseUserDOS.get(comMngPopulationHouseUserDOS.size() - 1).getRelation()); |
| | | comMngPopulationVO.setRelationName(PopulRelationEnum.getCnDescByName(comMngPopulationVO.getRelation())); |
| | | } |
| | | // 设置年龄 |
| | | if (StringUtils.isNotEmpty(comMngPopulationVO.getBirthday())) { |
| | |
| | | } |
| | | } |
| | | |
| | | if(comMngPopulationVO.getType()!=null){ |
| | | switch (comMngPopulationVO.getType()){ |
| | | case 1 : comMngPopulationVO.setAgeStart("80"); |
| | | comMngPopulationVO.setAgeEnd("89"); |
| | | break; |
| | | case 2 : comMngPopulationVO.setAgeStart("90"); |
| | | comMngPopulationVO.setAgeEnd("99"); |
| | | break; |
| | | case 3 : comMngPopulationVO.setAgeStart("100"); |
| | | break; |
| | | } |
| | | } |
| | | |
| | | if (StringUtils.isNotEmpty(comMngPopulationVO.getAgeStart())) { |
| | | String ageStartTime = DateUtils.getDateFormatString( |
| | | DateUtils.yearAddNum(new Date(), -(Integer.parseInt(comMngPopulationVO.getAgeStart()))), "yyyy-MM-dd"); |
| | |
| | | populDO.setPoliticalOutlookName( |
| | | PopulPoliticalOutlookEnum.getCnDescByName(populDO.getPoliticalOutlook())); |
| | | populDO.setMarriageName(PopulMarriageEnum.getCnDescByName(populDO.getMarriage())); |
| | | if(populDO.getAge()>=80&&populDO.getAge()<=89){ |
| | | populDO.setType(1); |
| | | } |
| | | if(populDO.getAge()>=90&&populDO.getAge()<=99){ |
| | | populDO.setType(2); |
| | | } |
| | | if(populDO.getAge()>=100){ |
| | | populDO.setType(3); |
| | | } |
| | | } |
| | | }); |
| | | } |
| | | return R.ok(iPage); |
| | | } |
| | | |
| | | @Override |
| | | public R exportOld(ComMngPopulationDTO comMngPopulationVO) { |
| | | 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); |
| | | } |
| | | } else { |
| | | 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.setAgeEndTimeEnd(ageStartTime); |
| | | } |
| | | } |
| | | } |
| | | List<ComMngPopulationVO> comMngPopulationVOS=this.comMngPopulationDAO.exportOld(comMngPopulationVO); |
| | | if(!comMngPopulationVOS.isEmpty()){ |
| | | comMngPopulationVOS.forEach(populDO -> { |
| | | if (StringUtils.isNotEmpty(populDO.getBirthday())) { |
| | | populDO.setAge(AgeUtils.getAgeFromBirthTimes(populDO.getBirthday())); |
| | | populDO.setRelationName(PopulRelationEnum.getCnDescByName(populDO.getRelation())); |
| | | populDO.setCultureLevelName(PopulCultureLevelEnum.getCnDescByName(populDO.getCultureLevel())); |
| | | populDO.setPoliticalOutlookName( |
| | | PopulPoliticalOutlookEnum.getCnDescByName(populDO.getPoliticalOutlook())); |
| | | populDO.setMarriageName(PopulMarriageEnum.getCnDescByName(populDO.getMarriage())); |
| | | if(populDO.getAge()>=80&&populDO.getAge()<=89){ |
| | | populDO.setType(1); |
| | | } |
| | | if(populDO.getAge()>=90&&populDO.getAge()<=99){ |
| | | populDO.setType(2); |
| | | } |
| | | if(populDO.getAge()>=100){ |
| | | populDO.setType(3); |
| | | } |
| | | } |
| | | }); |
| | | } |
| | | return R.ok(comMngPopulationVOS); |
| | | } |
| | | |
| | | /** |
| | |
| | | Integer nub = 1; |
| | | |
| | | // 查询所有人口数据放入HashMap中 |
| | | List<ComMngPopulationDO> populationList = this.baseMapper.selectList(null); |
| | | List<ComMngPopulationDO> populationList = this.baseMapper.selectList(new QueryWrapper<ComMngPopulationDO>().lambda().eq(ComMngPopulationDO::getActId,communityId)); |
| | | HashMap<String, Object> populationMap = new HashMap<>(); |
| | | populationList.forEach(population -> { |
| | | String key = population.getCardNo(); |
| | | populationMap.put(key, population); |
| | | }); |
| | | // 查询所有房屋信息放入到HashMap中 |
| | | List<ComMngPopulationHouseDO> houseLists = comMngPopulationHouseDAO.selectList(null); |
| | | List<ComMngPopulationHouseDO> houseLists = comMngPopulationHouseDAO.selectList(new QueryWrapper<ComMngPopulationHouseDO>().lambda().eq(ComMngPopulationHouseDO::getCommunityId,communityId)); |
| | | HashMap<String, Object> houseMap = new HashMap<>(); |
| | | houseLists.forEach(house -> { |
| | | String key = house.getCommunityId() + house.getVillageId() + house.getFloor() + house.getUnitNo() |
| | |
| | | houseMap.put(key, house); |
| | | }); |
| | | |
| | | List<ComMngVillageDO> villageList = comActVillageDAO.selectList(null); |
| | | List<ComMngVillageDO> villageList = comActVillageDAO.selectList(new QueryWrapper<ComMngVillageDO>().lambda().eq(ComMngVillageDO::getCommunityId,communityId)); |
| | | HashMap<String, Object> villageMap = new HashMap<>(); |
| | | villageList.forEach(village -> { |
| | | String key = village.getCommunityId() + village.getAlley() + village.getHouseNum(); |
| | | villageMap.put(key, village); |
| | | }); |
| | | |
| | | List<ComMngPopulationHouseUserDO> houseUserLists = comMngPopulationHouseUserDAO.selectList(null); |
| | | List<ComMngPopulationHouseUserDO> houseUserLists = comMngPopulationHouseUserDAO.selectListIndex(communityId); |
| | | HashMap<String, Object> houseUserMap = new HashMap<>(); |
| | | houseUserLists.forEach(houseUser -> { |
| | | String key = houseUser.getPopulId() + houseUser.getHouseId() + ""; |
| | |
| | | }); |
| | | |
| | | List<ComMngPopulationCommunityTagsDO> populationCommunityLists = |
| | | comMngPopulationCommunityTagsDAO.selectList(null); |
| | | comMngPopulationCommunityTagsDAO.selectList(new QueryWrapper<ComMngPopulationCommunityTagsDO>().lambda().eq(ComMngPopulationCommunityTagsDO::getCommunityId,communityId)); |
| | | HashMap<String, Object> populationCommunityMap = new HashMap<>(); |
| | | populationCommunityLists.forEach(populationCommunity -> { |
| | | String key = populationCommunity.getPopulationId() + populationCommunity.getCommunityId() + ""; |
| | |
| | | log.info("查询小区街路巷是否存在完成"); |
| | | |
| | | log.info("开始查询房屋是否存在"); |
| | | // 先判断房屋是否存在 |
| | | ComMngPopulationHouseDO populationHouseDO = null; |
| | | String houseKey = |
| | | communityId + comMngVillageDO.getVillageId() + vo.getFloor() + vo.getUnitNo() + vo.getHouseNo(); |
| | | if (isOnly(houseKey, houseMap)) { |
| | | if (!houseList.isEmpty()) { |
| | | for (ComMngPopulationHouseDO house : houseList) { |
| | | if (house.getVillageId().equals(comMngVillageDO.getVillageId()) |
| | | && house.getCommunityId().equals(communityId) && house.getFloor().equals(vo.getFloor()) |
| | | && house.getUnitNo().equals(vo.getUnitNo()) |
| | | && house.getHouseNo().equals(vo.getHouseNo())) { |
| | | populationHouseDO = house; |
| | | break; |
| | | // 先判断房屋是否存在 |
| | | if(StringUtils.isNotEmpty(vo.getFloor())&&StringUtils.isNotEmpty(vo.getHouseNo())&&StringUtils.isNotEmpty(vo.getUnitNo())){ |
| | | String houseKey = |
| | | communityId + comMngVillageDO.getVillageId() + vo.getFloor() + vo.getUnitNo() + vo.getHouseNo(); |
| | | if (isOnly(houseKey, houseMap)) { |
| | | if (!houseList.isEmpty()) { |
| | | for (ComMngPopulationHouseDO house : houseList) { |
| | | if (house.getVillageId().equals(comMngVillageDO.getVillageId()) |
| | | && house.getCommunityId().equals(communityId) && house.getFloor().equals(vo.getFloor()) |
| | | && house.getUnitNo().equals(vo.getUnitNo()) |
| | | && house.getHouseNo().equals(vo.getHouseNo())) { |
| | | populationHouseDO = house; |
| | | break; |
| | | } |
| | | } |
| | | } |
| | | if (populationHouseDO == null) { |
| | | // 房屋信息不存在建立房屋信息 |
| | | populationHouseDO = |
| | | savePopulationHouse(vo, comMngVillageDO, communityId, areaPath, populationActVO.getName()); |
| | | houseList.add(populationHouseDO); |
| | | } |
| | | } else { |
| | | populationHouseDO = (ComMngPopulationHouseDO)houseMap.get(houseKey); |
| | | } |
| | | if (populationHouseDO == null) { |
| | | // 房屋信息不存在建立房屋信息 |
| | | populationHouseDO = |
| | | savePopulationHouse(vo, comMngVillageDO, communityId, areaPath, populationActVO.getName()); |
| | | houseList.add(populationHouseDO); |
| | | } |
| | | } else { |
| | | populationHouseDO = (ComMngPopulationHouseDO)houseMap.get(houseKey); |
| | | vo.setHouseId(populationHouseDO.getId()); |
| | | log.info("查询房屋是否存在完成"); |
| | | }else { |
| | | ComMngPopulationMistakeExcelVO mistake = new ComMngPopulationMistakeExcelVO(); |
| | | BeanUtils.copyProperties(vo, mistake); |
| | | setMistake(mistake, vo); |
| | | mistake.setMistake("房屋数据填报不完整" ); |
| | | mistakes.add(mistake); |
| | | log.info("房屋数据填报不完整"); |
| | | continue; |
| | | } |
| | | vo.setHouseId(populationHouseDO.getId()); |
| | | log.info("查询房屋是否存在完成"); |
| | | |
| | | |
| | | |
| | | if (StringUtils.isEmpty(vo.getName()) && StringUtils.isEmpty(vo.getCardNo())) { |
| | | // 空户处理完房屋信息,直接返回 |
| | | continue; |
| | | } |
| | | String cardNoAES = AESUtil.encrypt128(vo.getCardNo(), aesKey); |
| | | //String cardNoAES = AESUtil.encrypt128(vo.getCardNo(), aesKey); |
| | | // 判断实有人口是否已存在 |
| | | log.info("开始查询实有人口是否已存在"); |
| | | ComMngPopulationDO populationDO = null; |
| | |
| | | // 不存在实有人口,则新增 |
| | | populationDO = savePopulationDO(vo, populationActVO, comMngVillageDO, userId); |
| | | saveList.add(populationDO); |
| | | populationMap.put(populationDO.getCardNo(),populationDO); |
| | | populationMap.put(populationKey,populationDO); |
| | | } |
| | | log.info("查询实有人口是否已存在完成"); |
| | | |
| | |
| | | } |
| | | cpopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); |
| | | cpopulationCommunityTagsDO.setCreateBy(userId); |
| | | populationCommunityMap.put(populationCommunityKey,cpopulationCommunityTagsDO); |
| | | savePopulationCommunityList.add(cpopulationCommunityTagsDO); |
| | | }else { |
| | | // 实有人口存在于当前社区,则更新 |
| | |
| | | iterator.remove(); |
| | | } |
| | | comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); |
| | | |
| | | comMngPopulationCommunityTagsDO.setUpdateBy(userId); |
| | | updatePopulationCommunityList.add(comMngPopulationCommunityTagsDO); |
| | | |
| | |
| | | } |
| | | } |
| | | log.info("查询实有人口存在社区信息完成"); |
| | | |
| | | log.info("开始处理楼栋信息"); |
| | | List<ComMngBuildingDO> comMngBuildingDOList= comMngBuildingDAO.selectList(new QueryWrapper<ComMngBuildingDO>().lambda().eq(ComMngBuildingDO::getVillageId,comMngVillageDO.getVillageId()).eq(ComMngBuildingDO::getName,vo.getFloor())); |
| | | if(comMngBuildingDOList.isEmpty()){ |
| | | ComMngBuildingDO comMngBuildingDO=new ComMngBuildingDO(); |
| | | comMngBuildingDO.setId(Snowflake.getId()); |
| | | comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); |
| | | comMngBuildingDO.setName(vo.getFloor()); |
| | | comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); |
| | | comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); |
| | | comMngBuildingDAO.insert(comMngBuildingDO); |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | log.info("出现错误,错误原因:" + e.getMessage()); |
| | |
| | | } |
| | | if (!updateList.isEmpty()) { |
| | | log.info("执行数据库更新人口"); |
| | | this.baseMapper.updateAll(updateList); |
| | | this.updateBatchById(updateList); |
| | | // this.updateBatchById(updateList); |
| | | log.info("数据库更新人口完成"); |
| | | } |
| | |
| | | } |
| | | if (!updatePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库更新人口社区关系"); |
| | | comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); |
| | | comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); |
| | | log.info("数据库更新人口社区关系完成"); |
| | | } |
| | | log.info("执行数据库导入完成"); |
| | |
| | | Integer nub = 1; |
| | | |
| | | // 查询所有人口数据放入HashMap中 |
| | | List<ComMngPopulationDO> populationList = this.baseMapper.selectList(null); |
| | | List<ComMngPopulationDO> populationList = this.baseMapper.selectList(new QueryWrapper<ComMngPopulationDO>().lambda().eq(ComMngPopulationDO::getActId,communityId)); |
| | | HashMap<String, Object> populationMap = new HashMap<>(); |
| | | populationList.forEach(population -> { |
| | | String key = population.getCardNo(); |
| | | populationMap.put(key, population); |
| | | }); |
| | | // 查询所有房屋信息放入到HashMap中 |
| | | List<ComMngPopulationHouseDO> houseLists = comMngPopulationHouseDAO.selectList(null); |
| | | List<ComMngPopulationHouseDO> houseLists = comMngPopulationHouseDAO.selectList(new QueryWrapper<ComMngPopulationHouseDO>().lambda().eq(ComMngPopulationHouseDO::getCommunityId,communityId)); |
| | | HashMap<String, Object> houseMap = new HashMap<>(); |
| | | houseLists.forEach(house -> { |
| | | String key = house.getCommunityId() + house.getVillageId() + house.getFloor() + house.getUnitNo() |
| | |
| | | houseMap.put(key, house); |
| | | }); |
| | | |
| | | List<ComMngVillageDO> villageList = comActVillageDAO.selectList(null); |
| | | List<ComMngVillageDO> villageList = comActVillageDAO.selectList(new QueryWrapper<ComMngVillageDO>().lambda().eq(ComMngVillageDO::getCommunityId,communityId)); |
| | | HashMap<String, Object> villageMap = new HashMap<>(); |
| | | villageList.forEach(village -> { |
| | | String key = village.getCommunityId() + village.getAlley() + village.getHouseNum(); |
| | | villageMap.put(key, village); |
| | | }); |
| | | |
| | | List<ComMngPopulationHouseUserDO> houseUserLists = comMngPopulationHouseUserDAO.selectList(null); |
| | | List<ComMngPopulationHouseUserDO> houseUserLists = comMngPopulationHouseUserDAO.selectListIndex(communityId); |
| | | HashMap<String, Object> houseUserMap = new HashMap<>(); |
| | | houseUserLists.forEach(houseUser -> { |
| | | String key = houseUser.getPopulId() + houseUser.getHouseId() + ""; |
| | |
| | | }); |
| | | |
| | | List<ComMngPopulationCommunityTagsDO> populationCommunityLists = |
| | | comMngPopulationCommunityTagsDAO.selectList(null); |
| | | comMngPopulationCommunityTagsDAO.selectList(new QueryWrapper<ComMngPopulationCommunityTagsDO>().lambda().eq(ComMngPopulationCommunityTagsDO::getCommunityId,communityId)); |
| | | HashMap<String, Object> populationCommunityMap = new HashMap<>(); |
| | | populationCommunityLists.forEach(populationCommunity -> { |
| | | String key = populationCommunity.getPopulationId() + populationCommunity.getCommunityId() + ""; |
| | |
| | | log.info("开始查询小区街路巷是否存在完成"); |
| | | |
| | | log.info("开始查询房屋是否存在"); |
| | | // 先判断房屋是否存在 |
| | | ComMngPopulationHouseDO populationHouseDO = null; |
| | | String houseKey = |
| | | communityId + comMngVillageDO.getVillageId() + vo.getFloor() + vo.getUnitNo() + vo.getHouseNo(); |
| | | if (isOnly(houseKey, houseMap)) { |
| | | if (!houseList.isEmpty()) { |
| | | for (ComMngPopulationHouseDO house : houseList) { |
| | | if (house.getVillageId().equals(comMngVillageDO.getVillageId()) |
| | | && house.getCommunityId().equals(communityId) && house.getFloor().equals(vo.getFloor()) |
| | | && house.getUnitNo().equals(vo.getUnitNo()) |
| | | && house.getHouseNo().equals(vo.getHouseNo())) { |
| | | populationHouseDO = house; |
| | | break; |
| | | // 先判断房屋是否存在 |
| | | if(StringUtils.isNotEmpty(vo.getFloor())&&StringUtils.isNotEmpty(vo.getHouseNo())&&StringUtils.isNotEmpty(vo.getUnitNo())){ |
| | | String houseKey = |
| | | communityId + comMngVillageDO.getVillageId() + vo.getFloor() + vo.getUnitNo() + vo.getHouseNo(); |
| | | if (isOnly(houseKey, houseMap)) { |
| | | if (!houseList.isEmpty()) { |
| | | for (ComMngPopulationHouseDO house : houseList) { |
| | | if (house.getVillageId().equals(comMngVillageDO.getVillageId()) |
| | | && house.getCommunityId().equals(communityId) && house.getFloor().equals(vo.getFloor()) |
| | | && house.getUnitNo().equals(vo.getUnitNo()) |
| | | && house.getHouseNo().equals(vo.getHouseNo())) { |
| | | populationHouseDO = house; |
| | | break; |
| | | } |
| | | } |
| | | } |
| | | if (populationHouseDO == null) { |
| | | // 房屋信息不存在建立房屋信息 |
| | | populationHouseDO = |
| | | saveDrugPopulationHouse(vo, comMngVillageDO, communityId, areaPath, populationActVO.getName()); |
| | | houseList.add(populationHouseDO); |
| | | } |
| | | } else { |
| | | populationHouseDO = (ComMngPopulationHouseDO)houseMap.get(houseKey); |
| | | } |
| | | if (populationHouseDO == null) { |
| | | // 房屋信息不存在建立房屋信息 |
| | | populationHouseDO = saveDrugPopulationHouse(vo, comMngVillageDO, communityId, areaPath, |
| | | populationActVO.getName()); |
| | | houseList.add(populationHouseDO); |
| | | } |
| | | } else { |
| | | populationHouseDO = (ComMngPopulationHouseDO)houseMap.get(houseKey); |
| | | vo.setHouseId(populationHouseDO.getId()); |
| | | log.info("查询房屋是否存在完成"); |
| | | }else { |
| | | ComMngPopulationDrugMistakeExcelVO mistake = new ComMngPopulationDrugMistakeExcelVO(); |
| | | BeanUtils.copyProperties(vo, mistake); |
| | | setDrugMistake(mistake, vo); |
| | | mistake.setMistake("房屋数据填报不完整" ); |
| | | mistakes.add(mistake); |
| | | log.info("房屋数据填报不完整"); |
| | | continue; |
| | | } |
| | | vo.setHouseId(populationHouseDO.getId()); |
| | | log.info("开始查询房屋是否存在完成"); |
| | | |
| | | |
| | | if (StringUtils.isEmpty(vo.getName()) && StringUtils.isEmpty(vo.getCardNo())) { |
| | | // 空户处理完房屋信息,直接返回 |
| | | continue; |
| | | } |
| | | String cardNoAES = AESUtil.encrypt128(vo.getCardNo(), aesKey); |
| | | // 判断实有人口是否已存在 |
| | | log.info("开始查询实有人口是否已存在"); |
| | | ComMngPopulationDO populationDO = null; |
| | |
| | | if (!labelList.contains(s)) |
| | | iterator.remove(); |
| | | } |
| | | comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); |
| | | if(StringUtils.isNotEmpty(comMngPopulationCommunityTagsDO.getLabel())){ |
| | | for(String tag:userTag){ |
| | | if(!comMngPopulationCommunityTagsDO.getLabel().contains(tag)){ |
| | | comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel()+","+tag); |
| | | } |
| | | } |
| | | } |
| | | else{ |
| | | comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); |
| | | } |
| | | comMngPopulationCommunityTagsDO.setUpdateBy(userId); |
| | | updatePopulationCommunityList.add(comMngPopulationCommunityTagsDO); |
| | | |
| | |
| | | mistakes.add(mistake); |
| | | } |
| | | } |
| | | |
| | | log.info("查询实有人口存在社区信息完成"); |
| | | |
| | | log.info("开始处理楼栋信息"); |
| | | List<ComMngBuildingDO> comMngBuildingDOList= comMngBuildingDAO.selectList(new QueryWrapper<ComMngBuildingDO>().lambda().eq(ComMngBuildingDO::getVillageId,comMngVillageDO.getVillageId()).eq(ComMngBuildingDO::getName,vo.getFloor())); |
| | | if(comMngBuildingDOList.isEmpty()){ |
| | | ComMngBuildingDO comMngBuildingDO=new ComMngBuildingDO(); |
| | | comMngBuildingDO.setId(Snowflake.getId()); |
| | | comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); |
| | | comMngBuildingDO.setName(vo.getFloor()); |
| | | comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); |
| | | comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); |
| | | comMngBuildingDAO.insert(comMngBuildingDO); |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | log.info("出现错误,错误原因:" + e.getMessage()); |
| | |
| | | if (!houseList.isEmpty()) { |
| | | log.info("执行数据库导入房屋"); |
| | | comMngPopulationHouseDAO.insertAll(houseList); |
| | | log.info("执行数据库导入房屋完成"); |
| | | log.info("数据库导入房屋完成"); |
| | | } |
| | | if (!saveList.isEmpty()) { |
| | | log.info("执行数据库导入人口"); |
| | | this.baseMapper.insertAll(saveList); |
| | | log.info("执行数据库导入人口完成"); |
| | | log.info("数据库导入人口完成"); |
| | | } |
| | | if (!updateList.isEmpty()) { |
| | | log.info("执行数据库更新人口"); |
| | | this.baseMapper.updateAll(updateList); |
| | | this.updateBatchById(updateList); |
| | | // this.updateBatchById(updateList); |
| | | log.info("执行数据库更新人口完成"); |
| | | log.info("数据库更新人口完成"); |
| | | } |
| | | if (!houseUserList.isEmpty()) { |
| | | log.info("执行数据库导入人口房屋关系"); |
| | | comMngPopulationHouseUserService.saveBatch(houseUserList); |
| | | log.info("执行数据库导入人口房屋关系完成"); |
| | | log.info("数据库导入人口房屋关系完成"); |
| | | } |
| | | if (!savePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库导入人口社区关系"); |
| | |
| | | } |
| | | if (!updatePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库更新人口社区关系"); |
| | | comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); |
| | | comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); |
| | | log.info("数据库更新人口社区关系完成"); |
| | | } |
| | | log.info("执行数据库导入完成"); |
| | |
| | | Integer nub = 1; |
| | | |
| | | // 查询所有人口数据放入HashMap中 |
| | | List<ComMngPopulationDO> populationList = this.baseMapper.selectList(null); |
| | | List<ComMngPopulationDO> populationList = this.baseMapper.selectList(new QueryWrapper<ComMngPopulationDO>().lambda().eq(ComMngPopulationDO::getActId,communityId)); |
| | | HashMap<String, Object> populationMap = new HashMap<>(); |
| | | populationList.forEach(population -> { |
| | | String key = population.getCardNo(); |
| | | populationMap.put(key, population); |
| | | }); |
| | | // 查询所有房屋信息放入到HashMap中 |
| | | List<ComMngPopulationHouseDO> houseLists = comMngPopulationHouseDAO.selectList(null); |
| | | List<ComMngPopulationHouseDO> houseLists = comMngPopulationHouseDAO.selectList(new QueryWrapper<ComMngPopulationHouseDO>().lambda().eq(ComMngPopulationHouseDO::getCommunityId,communityId)); |
| | | HashMap<String, Object> houseMap = new HashMap<>(); |
| | | houseLists.forEach(house -> { |
| | | String key = house.getCommunityId() + house.getVillageId() + house.getFloor() + house.getUnitNo() |
| | |
| | | houseMap.put(key, house); |
| | | }); |
| | | |
| | | List<ComMngVillageDO> villageList = comActVillageDAO.selectList(null); |
| | | List<ComMngVillageDO> villageList = comActVillageDAO.selectList(new QueryWrapper<ComMngVillageDO>().lambda().eq(ComMngVillageDO::getCommunityId,communityId)); |
| | | HashMap<String, Object> villageMap = new HashMap<>(); |
| | | villageList.forEach(village -> { |
| | | String key = village.getCommunityId() + village.getAlley() + village.getHouseNum(); |
| | | villageMap.put(key, village); |
| | | }); |
| | | |
| | | List<ComMngPopulationHouseUserDO> houseUserLists = comMngPopulationHouseUserDAO.selectList(null); |
| | | List<ComMngPopulationHouseUserDO> houseUserLists = comMngPopulationHouseUserDAO.selectListIndex(communityId); |
| | | HashMap<String, Object> houseUserMap = new HashMap<>(); |
| | | houseUserLists.forEach(houseUser -> { |
| | | String key = houseUser.getPopulId() + houseUser.getHouseId() + ""; |
| | |
| | | }); |
| | | |
| | | List<ComMngPopulationCommunityTagsDO> populationCommunityLists = |
| | | comMngPopulationCommunityTagsDAO.selectList(null); |
| | | comMngPopulationCommunityTagsDAO.selectList(new QueryWrapper<ComMngPopulationCommunityTagsDO>().lambda().eq(ComMngPopulationCommunityTagsDO::getCommunityId,communityId)); |
| | | HashMap<String, Object> populationCommunityMap = new HashMap<>(); |
| | | populationCommunityLists.forEach(populationCommunity -> { |
| | | String key = populationCommunity.getPopulationId() + populationCommunity.getCommunityId() + ""; |
| | |
| | | log.info("开始查询小区街路巷是否存在完成"); |
| | | |
| | | log.info("开始查询房屋是否存在"); |
| | | // 先判断房屋是否存在 |
| | | ComMngPopulationHouseDO populationHouseDO = null; |
| | | String houseKey = |
| | | communityId + comMngVillageDO.getVillageId() + vo.getFloor() + vo.getUnitNo() + vo.getHouseNo(); |
| | | if (isOnly(houseKey, houseMap)) { |
| | | if (!houseList.isEmpty()) { |
| | | for (ComMngPopulationHouseDO house : houseList) { |
| | | if (house.getVillageId().equals(comMngVillageDO.getVillageId()) |
| | | && house.getCommunityId().equals(communityId) && house.getFloor().equals(vo.getFloor()) |
| | | && house.getUnitNo().equals(vo.getUnitNo()) |
| | | && house.getHouseNo().equals(vo.getHouseNo())) { |
| | | populationHouseDO = house; |
| | | break; |
| | | // 先判断房屋是否存在 |
| | | if(StringUtils.isNotEmpty(vo.getFloor())&&StringUtils.isNotEmpty(vo.getHouseNo())&&StringUtils.isNotEmpty(vo.getUnitNo())){ |
| | | String houseKey = |
| | | communityId + comMngVillageDO.getVillageId() + vo.getFloor() + vo.getUnitNo() + vo.getHouseNo(); |
| | | if (isOnly(houseKey, houseMap)) { |
| | | if (!houseList.isEmpty()) { |
| | | for (ComMngPopulationHouseDO house : houseList) { |
| | | if (house.getVillageId().equals(comMngVillageDO.getVillageId()) |
| | | && house.getCommunityId().equals(communityId) && house.getFloor().equals(vo.getFloor()) |
| | | && house.getUnitNo().equals(vo.getUnitNo()) |
| | | && house.getHouseNo().equals(vo.getHouseNo())) { |
| | | populationHouseDO = house; |
| | | break; |
| | | } |
| | | } |
| | | } |
| | | if (populationHouseDO == null) { |
| | | // 房屋信息不存在建立房屋信息 |
| | | populationHouseDO = |
| | | saveCorrectPopulationHouse(vo, comMngVillageDO, communityId, areaPath, populationActVO.getName()); |
| | | houseList.add(populationHouseDO); |
| | | } |
| | | } else { |
| | | populationHouseDO = (ComMngPopulationHouseDO)houseMap.get(houseKey); |
| | | } |
| | | if (populationHouseDO == null) { |
| | | // 房屋信息不存在建立房屋信息 |
| | | populationHouseDO = saveCorrectPopulationHouse(vo, comMngVillageDO, communityId, areaPath, |
| | | populationActVO.getName()); |
| | | houseList.add(populationHouseDO); |
| | | } |
| | | } else { |
| | | populationHouseDO = (ComMngPopulationHouseDO)houseMap.get(houseKey); |
| | | vo.setHouseId(populationHouseDO.getId()); |
| | | log.info("查询房屋是否存在完成"); |
| | | }else { |
| | | ComMngPopulationCorrectMistakeExcelVO mistake = new ComMngPopulationCorrectMistakeExcelVO(); |
| | | BeanUtils.copyProperties(vo, mistake); |
| | | setCorrectMistake(mistake, vo); |
| | | mistake.setMistake("房屋数据填报不完整" ); |
| | | mistakes.add(mistake); |
| | | log.info("房屋数据填报不完整"); |
| | | continue; |
| | | } |
| | | vo.setHouseId(populationHouseDO.getId()); |
| | | log.info("开始查询房屋是否存在完成"); |
| | | |
| | | |
| | | if (StringUtils.isEmpty(vo.getName()) && StringUtils.isEmpty(vo.getCardNo())) { |
| | | // 空户处理完房屋信息,直接返回 |
| | | continue; |
| | | } |
| | | String cardNoAES = AESUtil.encrypt128(vo.getCardNo(), aesKey); |
| | | // 判断实有人口是否已存在 |
| | | log.info("开始查询实有人口是否已存在"); |
| | | ComMngPopulationDO populationDO = null; |
| | |
| | | if (!labelList.contains(s)) |
| | | iterator.remove(); |
| | | } |
| | | comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); |
| | | if(StringUtils.isNotEmpty(comMngPopulationCommunityTagsDO.getLabel())){ |
| | | for(String tag:userTag){ |
| | | if(!comMngPopulationCommunityTagsDO.getLabel().contains(tag)){ |
| | | comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel()+","+tag); |
| | | } |
| | | } |
| | | } |
| | | else{ |
| | | comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); |
| | | } |
| | | comMngPopulationCommunityTagsDO.setUpdateBy(userId); |
| | | updatePopulationCommunityList.add(comMngPopulationCommunityTagsDO); |
| | | |
| | |
| | | mistakes.add(mistake); |
| | | } |
| | | } |
| | | |
| | | log.info("查询实有人口存在社区信息完成"); |
| | | |
| | | log.info("开始处理楼栋信息"); |
| | | List<ComMngBuildingDO> comMngBuildingDOList= comMngBuildingDAO.selectList(new QueryWrapper<ComMngBuildingDO>().lambda().eq(ComMngBuildingDO::getVillageId,comMngVillageDO.getVillageId()).eq(ComMngBuildingDO::getName,vo.getFloor())); |
| | | if(comMngBuildingDOList.isEmpty()){ |
| | | ComMngBuildingDO comMngBuildingDO=new ComMngBuildingDO(); |
| | | comMngBuildingDO.setId(Snowflake.getId()); |
| | | comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); |
| | | comMngBuildingDO.setName(vo.getFloor()); |
| | | comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); |
| | | comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); |
| | | comMngBuildingDAO.insert(comMngBuildingDO); |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | log.info("出现错误,错误原因:" + e.getMessage()); |
| | |
| | | if (!houseList.isEmpty()) { |
| | | log.info("执行数据库导入房屋"); |
| | | comMngPopulationHouseDAO.insertAll(houseList); |
| | | log.info("执行数据库导入房屋完成"); |
| | | log.info("数据库导入房屋完成"); |
| | | } |
| | | if (!saveList.isEmpty()) { |
| | | log.info("执行数据库导入人口"); |
| | | this.baseMapper.insertAll(saveList); |
| | | log.info("执行数据库导入人口完成"); |
| | | log.info("数据库导入人口完成"); |
| | | } |
| | | if (!updateList.isEmpty()) { |
| | | log.info("执行数据库更新人口"); |
| | | this.baseMapper.updateAll(updateList); |
| | | this.updateBatchById(updateList); |
| | | // this.updateBatchById(updateList); |
| | | log.info("执行数据库更新人口完成"); |
| | | log.info("数据库更新人口完成"); |
| | | } |
| | | if (!houseUserList.isEmpty()) { |
| | | log.info("执行数据库导入人口房屋关系"); |
| | | comMngPopulationHouseUserService.saveBatch(houseUserList); |
| | | log.info("执行数据库导入人口房屋关系完成"); |
| | | log.info("数据库导入人口房屋关系完成"); |
| | | } |
| | | if (!savePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库导入人口社区关系"); |
| | |
| | | } |
| | | if (!updatePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库更新人口社区关系"); |
| | | comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); |
| | | comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); |
| | | log.info("数据库更新人口社区关系完成"); |
| | | } |
| | | log.info("执行数据库导入完成"); |
| | |
| | | Integer nub = 1; |
| | | |
| | | // 查询所有人口数据放入HashMap中 |
| | | List<ComMngPopulationDO> populationList = this.baseMapper.selectList(null); |
| | | List<ComMngPopulationDO> populationList = this.baseMapper.selectList(new QueryWrapper<ComMngPopulationDO>().lambda().eq(ComMngPopulationDO::getActId,communityId)); |
| | | HashMap<String, Object> populationMap = new HashMap<>(); |
| | | populationList.forEach(population -> { |
| | | String key = population.getCardNo(); |
| | | populationMap.put(key, population); |
| | | }); |
| | | // 查询所有房屋信息放入到HashMap中 |
| | | List<ComMngPopulationHouseDO> houseLists = comMngPopulationHouseDAO.selectList(null); |
| | | List<ComMngPopulationHouseDO> houseLists = comMngPopulationHouseDAO.selectList(new QueryWrapper<ComMngPopulationHouseDO>().lambda().eq(ComMngPopulationHouseDO::getCommunityId,communityId)); |
| | | HashMap<String, Object> houseMap = new HashMap<>(); |
| | | houseLists.forEach(house -> { |
| | | String key = house.getCommunityId() + house.getVillageId() + house.getFloor() + house.getUnitNo() |
| | |
| | | houseMap.put(key, house); |
| | | }); |
| | | |
| | | List<ComMngVillageDO> villageList = comActVillageDAO.selectList(null); |
| | | List<ComMngVillageDO> villageList = comActVillageDAO.selectList(new QueryWrapper<ComMngVillageDO>().lambda().eq(ComMngVillageDO::getCommunityId,communityId)); |
| | | HashMap<String, Object> villageMap = new HashMap<>(); |
| | | villageList.forEach(village -> { |
| | | String key = village.getCommunityId() + village.getAlley() + village.getHouseNum(); |
| | | villageMap.put(key, village); |
| | | }); |
| | | |
| | | List<ComMngPopulationHouseUserDO> houseUserLists = comMngPopulationHouseUserDAO.selectList(null); |
| | | List<ComMngPopulationHouseUserDO> houseUserLists = comMngPopulationHouseUserDAO.selectListIndex(communityId); |
| | | HashMap<String, Object> houseUserMap = new HashMap<>(); |
| | | houseUserLists.forEach(houseUser -> { |
| | | String key = houseUser.getPopulId() + houseUser.getHouseId() + ""; |
| | |
| | | }); |
| | | |
| | | List<ComMngPopulationCommunityTagsDO> populationCommunityLists = |
| | | comMngPopulationCommunityTagsDAO.selectList(null); |
| | | comMngPopulationCommunityTagsDAO.selectList(new QueryWrapper<ComMngPopulationCommunityTagsDO>().lambda().eq(ComMngPopulationCommunityTagsDO::getCommunityId,communityId)); |
| | | HashMap<String, Object> populationCommunityMap = new HashMap<>(); |
| | | populationCommunityLists.forEach(populationCommunity -> { |
| | | String key = populationCommunity.getPopulationId() + populationCommunity.getCommunityId() + ""; |
| | |
| | | log.info("开始查询小区街路巷是否存在完成"); |
| | | |
| | | log.info("开始查询房屋是否存在"); |
| | | // 先判断房屋是否存在 |
| | | ComMngPopulationHouseDO populationHouseDO = null; |
| | | String houseKey = |
| | | communityId + comMngVillageDO.getVillageId() + vo.getFloor() + vo.getUnitNo() + vo.getHouseNo(); |
| | | if (isOnly(houseKey, houseMap)) { |
| | | if (!houseList.isEmpty()) { |
| | | for (ComMngPopulationHouseDO house : houseList) { |
| | | if (house.getVillageId().equals(comMngVillageDO.getVillageId()) |
| | | && house.getCommunityId().equals(communityId) && house.getFloor().equals(vo.getFloor()) |
| | | && house.getUnitNo().equals(vo.getUnitNo()) |
| | | && house.getHouseNo().equals(vo.getHouseNo())) { |
| | | populationHouseDO = house; |
| | | break; |
| | | // 先判断房屋是否存在 |
| | | if(StringUtils.isNotEmpty(vo.getFloor())&&StringUtils.isNotEmpty(vo.getHouseNo())&&StringUtils.isNotEmpty(vo.getUnitNo())){ |
| | | String houseKey = |
| | | communityId + comMngVillageDO.getVillageId() + vo.getFloor() + vo.getUnitNo() + vo.getHouseNo(); |
| | | if (isOnly(houseKey, houseMap)) { |
| | | if (!houseList.isEmpty()) { |
| | | for (ComMngPopulationHouseDO house : houseList) { |
| | | if (house.getVillageId().equals(comMngVillageDO.getVillageId()) |
| | | && house.getCommunityId().equals(communityId) && house.getFloor().equals(vo.getFloor()) |
| | | && house.getUnitNo().equals(vo.getUnitNo()) |
| | | && house.getHouseNo().equals(vo.getHouseNo())) { |
| | | populationHouseDO = house; |
| | | break; |
| | | } |
| | | } |
| | | } |
| | | if (populationHouseDO == null) { |
| | | // 房屋信息不存在建立房屋信息 |
| | | populationHouseDO = |
| | | saveMajorPopulationHouse(vo, comMngVillageDO, communityId, areaPath, populationActVO.getName()); |
| | | houseList.add(populationHouseDO); |
| | | } |
| | | } else { |
| | | populationHouseDO = (ComMngPopulationHouseDO)houseMap.get(houseKey); |
| | | } |
| | | if (populationHouseDO == null) { |
| | | // 房屋信息不存在建立房屋信息 |
| | | populationHouseDO = saveMajorPopulationHouse(vo, comMngVillageDO, communityId, areaPath, |
| | | populationActVO.getName()); |
| | | houseList.add(populationHouseDO); |
| | | } |
| | | } else { |
| | | populationHouseDO = (ComMngPopulationHouseDO)houseMap.get(houseKey); |
| | | vo.setHouseId(populationHouseDO.getId()); |
| | | log.info("查询房屋是否存在完成"); |
| | | }else { |
| | | ComMngPopulationMajorMistakeExcelVO mistake = new ComMngPopulationMajorMistakeExcelVO(); |
| | | BeanUtils.copyProperties(vo, mistake); |
| | | setMajorMistake(mistake, vo); |
| | | mistake.setMistake("房屋数据填报不完整" ); |
| | | mistakes.add(mistake); |
| | | log.info("房屋数据填报不完整"); |
| | | continue; |
| | | } |
| | | vo.setHouseId(populationHouseDO.getId()); |
| | | log.info("开始查询房屋是否存在完成"); |
| | | |
| | | |
| | | if (StringUtils.isEmpty(vo.getName()) && StringUtils.isEmpty(vo.getCardNo())) { |
| | | // 空户处理完房屋信息,直接返回 |
| | | continue; |
| | | } |
| | | String cardNoAES = AESUtil.encrypt128(vo.getCardNo(), aesKey); |
| | | // 判断实有人口是否已存在 |
| | | log.info("开始查询实有人口是否已存在"); |
| | | ComMngPopulationDO populationDO = null; |
| | |
| | | if (!labelList.contains(s)) |
| | | iterator.remove(); |
| | | } |
| | | comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); |
| | | if(StringUtils.isNotEmpty(comMngPopulationCommunityTagsDO.getLabel())){ |
| | | for(String tag:userTag){ |
| | | if(!comMngPopulationCommunityTagsDO.getLabel().contains(tag)){ |
| | | comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel()+","+tag); |
| | | } |
| | | } |
| | | } |
| | | else{ |
| | | comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); |
| | | } |
| | | comMngPopulationCommunityTagsDO.setUpdateBy(userId); |
| | | updatePopulationCommunityList.add(comMngPopulationCommunityTagsDO); |
| | | |
| | |
| | | mistakes.add(mistake); |
| | | } |
| | | } |
| | | |
| | | log.info("查询实有人口存在社区信息完成"); |
| | | |
| | | log.info("开始处理楼栋信息"); |
| | | List<ComMngBuildingDO> comMngBuildingDOList= comMngBuildingDAO.selectList(new QueryWrapper<ComMngBuildingDO>().lambda().eq(ComMngBuildingDO::getVillageId,comMngVillageDO.getVillageId()).eq(ComMngBuildingDO::getName,vo.getFloor())); |
| | | if(comMngBuildingDOList.isEmpty()){ |
| | | ComMngBuildingDO comMngBuildingDO=new ComMngBuildingDO(); |
| | | comMngBuildingDO.setId(Snowflake.getId()); |
| | | comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); |
| | | comMngBuildingDO.setName(vo.getFloor()); |
| | | comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); |
| | | comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); |
| | | comMngBuildingDAO.insert(comMngBuildingDO); |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | log.info("出现错误,错误原因:" + e.getMessage()); |
| | |
| | | if (!houseList.isEmpty()) { |
| | | log.info("执行数据库导入房屋"); |
| | | comMngPopulationHouseDAO.insertAll(houseList); |
| | | log.info("执行数据库导入房屋完成"); |
| | | log.info("数据库导入房屋完成"); |
| | | } |
| | | if (!saveList.isEmpty()) { |
| | | log.info("执行数据库导入人口"); |
| | | this.baseMapper.insertAll(saveList); |
| | | log.info("执行数据库导入人口完成"); |
| | | log.info("数据库导入人口完成"); |
| | | } |
| | | if (!updateList.isEmpty()) { |
| | | log.info("执行数据库更新人口"); |
| | | this.baseMapper.updateAll(updateList); |
| | | this.updateBatchById(updateList); |
| | | // this.updateBatchById(updateList); |
| | | log.info("执行数据库更新人口完成"); |
| | | log.info("数据库更新人口完成"); |
| | | } |
| | | if (!houseUserList.isEmpty()) { |
| | | log.info("执行数据库导入人口房屋关系"); |
| | | comMngPopulationHouseUserService.saveBatch(houseUserList); |
| | | log.info("执行数据库导入人口房屋关系完成"); |
| | | log.info("数据库导入人口房屋关系完成"); |
| | | } |
| | | if (!savePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库导入人口社区关系"); |
| | |
| | | } |
| | | if (!updatePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库更新人口社区关系"); |
| | | comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); |
| | | comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); |
| | | log.info("数据库更新人口社区关系完成"); |
| | | } |
| | | log.info("执行数据库导入完成"); |
| | |
| | | Integer nub = 1; |
| | | |
| | | // 查询所有人口数据放入HashMap中 |
| | | List<ComMngPopulationDO> populationList = this.baseMapper.selectList(null); |
| | | List<ComMngPopulationDO> populationList = this.baseMapper.selectList(new QueryWrapper<ComMngPopulationDO>().lambda().eq(ComMngPopulationDO::getActId,communityId)); |
| | | HashMap<String, Object> populationMap = new HashMap<>(); |
| | | populationList.forEach(population -> { |
| | | String key = population.getCardNo(); |
| | | populationMap.put(key, population); |
| | | }); |
| | | // 查询所有房屋信息放入到HashMap中 |
| | | List<ComMngPopulationHouseDO> houseLists = comMngPopulationHouseDAO.selectList(null); |
| | | List<ComMngPopulationHouseDO> houseLists = comMngPopulationHouseDAO.selectList(new QueryWrapper<ComMngPopulationHouseDO>().lambda().eq(ComMngPopulationHouseDO::getCommunityId,communityId)); |
| | | HashMap<String, Object> houseMap = new HashMap<>(); |
| | | houseLists.forEach(house -> { |
| | | String key = house.getCommunityId() + house.getVillageId() + house.getFloor() + house.getUnitNo() |
| | |
| | | houseMap.put(key, house); |
| | | }); |
| | | |
| | | List<ComMngVillageDO> villageList = comActVillageDAO.selectList(null); |
| | | List<ComMngVillageDO> villageList = comActVillageDAO.selectList(new QueryWrapper<ComMngVillageDO>().lambda().eq(ComMngVillageDO::getCommunityId,communityId)); |
| | | HashMap<String, Object> villageMap = new HashMap<>(); |
| | | villageList.forEach(village -> { |
| | | String key = village.getCommunityId() + village.getAlley() + village.getHouseNum(); |
| | | villageMap.put(key, village); |
| | | }); |
| | | |
| | | List<ComMngPopulationHouseUserDO> houseUserLists = comMngPopulationHouseUserDAO.selectList(null); |
| | | List<ComMngPopulationHouseUserDO> houseUserLists = comMngPopulationHouseUserDAO.selectListIndex(communityId); |
| | | HashMap<String, Object> houseUserMap = new HashMap<>(); |
| | | houseUserLists.forEach(houseUser -> { |
| | | String key = houseUser.getPopulId() + houseUser.getHouseId() + ""; |
| | |
| | | }); |
| | | |
| | | List<ComMngPopulationCommunityTagsDO> populationCommunityLists = |
| | | comMngPopulationCommunityTagsDAO.selectList(null); |
| | | comMngPopulationCommunityTagsDAO.selectList(new QueryWrapper<ComMngPopulationCommunityTagsDO>().lambda().eq(ComMngPopulationCommunityTagsDO::getCommunityId,communityId)); |
| | | HashMap<String, Object> populationCommunityMap = new HashMap<>(); |
| | | populationCommunityLists.forEach(populationCommunity -> { |
| | | String key = populationCommunity.getPopulationId() + populationCommunity.getCommunityId() + ""; |
| | |
| | | log.info("开始查询小区街路巷是否存在完成"); |
| | | |
| | | log.info("开始查询房屋是否存在"); |
| | | // 先判断房屋是否存在 |
| | | ComMngPopulationHouseDO populationHouseDO = null; |
| | | String houseKey = |
| | | communityId + comMngVillageDO.getVillageId() + vo.getFloor() + vo.getUnitNo() + vo.getHouseNo(); |
| | | if (isOnly(houseKey, houseMap)) { |
| | | if (!houseList.isEmpty()) { |
| | | for (ComMngPopulationHouseDO house : houseList) { |
| | | if (house.getVillageId().equals(comMngVillageDO.getVillageId()) |
| | | && house.getCommunityId().equals(communityId) && house.getFloor().equals(vo.getFloor()) |
| | | && house.getUnitNo().equals(vo.getUnitNo()) |
| | | && house.getHouseNo().equals(vo.getHouseNo())) { |
| | | populationHouseDO = house; |
| | | break; |
| | | // 先判断房屋是否存在 |
| | | if(StringUtils.isNotEmpty(vo.getFloor())&&StringUtils.isNotEmpty(vo.getHouseNo())&&StringUtils.isNotEmpty(vo.getUnitNo())){ |
| | | String houseKey = |
| | | communityId + comMngVillageDO.getVillageId() + vo.getFloor() + vo.getUnitNo() + vo.getHouseNo(); |
| | | if (isOnly(houseKey, houseMap)) { |
| | | if (!houseList.isEmpty()) { |
| | | for (ComMngPopulationHouseDO house : houseList) { |
| | | if (house.getVillageId().equals(comMngVillageDO.getVillageId()) |
| | | && house.getCommunityId().equals(communityId) && house.getFloor().equals(vo.getFloor()) |
| | | && house.getUnitNo().equals(vo.getUnitNo()) |
| | | && house.getHouseNo().equals(vo.getHouseNo())) { |
| | | populationHouseDO = house; |
| | | break; |
| | | } |
| | | } |
| | | } |
| | | if (populationHouseDO == null) { |
| | | // 房屋信息不存在建立房屋信息 |
| | | populationHouseDO = |
| | | saveCultPopulationHouse(vo, comMngVillageDO, communityId, areaPath, populationActVO.getName()); |
| | | houseList.add(populationHouseDO); |
| | | } |
| | | } else { |
| | | populationHouseDO = (ComMngPopulationHouseDO)houseMap.get(houseKey); |
| | | } |
| | | if (populationHouseDO == null) { |
| | | // 房屋信息不存在建立房屋信息 |
| | | populationHouseDO = saveCultPopulationHouse(vo, comMngVillageDO, communityId, areaPath, |
| | | populationActVO.getName()); |
| | | houseList.add(populationHouseDO); |
| | | } |
| | | } else { |
| | | populationHouseDO = (ComMngPopulationHouseDO)houseMap.get(houseKey); |
| | | vo.setHouseId(populationHouseDO.getId()); |
| | | log.info("查询房屋是否存在完成"); |
| | | }else { |
| | | ComMngPopulationCultMistakeExcelVO mistake = new ComMngPopulationCultMistakeExcelVO(); |
| | | BeanUtils.copyProperties(vo, mistake); |
| | | setCultMistake(mistake, vo); |
| | | mistake.setMistake("房屋数据填报不完整" ); |
| | | mistakes.add(mistake); |
| | | log.info("房屋数据填报不完整"); |
| | | continue; |
| | | } |
| | | vo.setHouseId(populationHouseDO.getId()); |
| | | log.info("开始查询房屋是否存在完成"); |
| | | |
| | | |
| | | if (StringUtils.isEmpty(vo.getName()) && StringUtils.isEmpty(vo.getCardNo())) { |
| | | // 空户处理完房屋信息,直接返回 |
| | | continue; |
| | | } |
| | | String cardNoAES = AESUtil.encrypt128(vo.getCardNo(), aesKey); |
| | | // 判断实有人口是否已存在 |
| | | log.info("开始查询实有人口是否已存在"); |
| | | ComMngPopulationDO populationDO = null; |
| | |
| | | if (!labelList.contains(s)) |
| | | iterator.remove(); |
| | | } |
| | | comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); |
| | | if(StringUtils.isNotEmpty(comMngPopulationCommunityTagsDO.getLabel())){ |
| | | for(String tag:userTag){ |
| | | if(!comMngPopulationCommunityTagsDO.getLabel().contains(tag)){ |
| | | comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel()+","+tag); |
| | | } |
| | | } |
| | | } |
| | | else{ |
| | | comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); |
| | | } |
| | | comMngPopulationCommunityTagsDO.setUpdateBy(userId); |
| | | updatePopulationCommunityList.add(comMngPopulationCommunityTagsDO); |
| | | |
| | |
| | | mistakes.add(mistake); |
| | | } |
| | | } |
| | | |
| | | log.info("查询实有人口存在社区信息完成"); |
| | | |
| | | log.info("开始处理楼栋信息"); |
| | | List<ComMngBuildingDO> comMngBuildingDOList= comMngBuildingDAO.selectList(new QueryWrapper<ComMngBuildingDO>().lambda().eq(ComMngBuildingDO::getVillageId,comMngVillageDO.getVillageId()).eq(ComMngBuildingDO::getName,vo.getFloor())); |
| | | if(comMngBuildingDOList.isEmpty()){ |
| | | ComMngBuildingDO comMngBuildingDO=new ComMngBuildingDO(); |
| | | comMngBuildingDO.setId(Snowflake.getId()); |
| | | comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); |
| | | comMngBuildingDO.setName(vo.getFloor()); |
| | | comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); |
| | | comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); |
| | | comMngBuildingDAO.insert(comMngBuildingDO); |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | log.info("出现错误,错误原因:" + e.getMessage()); |
| | |
| | | if (!houseList.isEmpty()) { |
| | | log.info("执行数据库导入房屋"); |
| | | comMngPopulationHouseDAO.insertAll(houseList); |
| | | log.info("执行数据库导入房屋完成"); |
| | | log.info("数据库导入房屋完成"); |
| | | } |
| | | if (!saveList.isEmpty()) { |
| | | log.info("执行数据库导入人口"); |
| | | this.baseMapper.insertAll(saveList); |
| | | log.info("执行数据库导入人口完成"); |
| | | log.info("数据库导入人口完成"); |
| | | } |
| | | if (!updateList.isEmpty()) { |
| | | log.info("执行数据库更新人口"); |
| | | this.baseMapper.updateAll(updateList); |
| | | this.updateBatchById(updateList); |
| | | // this.updateBatchById(updateList); |
| | | log.info("执行数据库更新人口完成"); |
| | | log.info("数据库更新人口完成"); |
| | | } |
| | | if (!houseUserList.isEmpty()) { |
| | | log.info("执行数据库导入人口房屋关系"); |
| | | comMngPopulationHouseUserService.saveBatch(houseUserList); |
| | | log.info("执行数据库导入人口房屋关系完成"); |
| | | log.info("数据库导入人口房屋关系完成"); |
| | | } |
| | | if (!savePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库导入人口社区关系"); |
| | |
| | | } |
| | | if (!updatePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库更新人口社区关系"); |
| | | comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); |
| | | comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); |
| | | log.info("数据库更新人口社区关系完成"); |
| | | } |
| | | log.info("执行数据库导入完成"); |
| | |
| | | Integer nub = 1; |
| | | |
| | | // 查询所有人口数据放入HashMap中 |
| | | List<ComMngPopulationDO> populationList = this.baseMapper.selectList(null); |
| | | List<ComMngPopulationDO> populationList = this.baseMapper.selectList(new QueryWrapper<ComMngPopulationDO>().lambda().eq(ComMngPopulationDO::getActId,communityId)); |
| | | HashMap<String, Object> populationMap = new HashMap<>(); |
| | | populationList.forEach(population -> { |
| | | String key = population.getCardNo(); |
| | | populationMap.put(key, population); |
| | | }); |
| | | // 查询所有房屋信息放入到HashMap中 |
| | | List<ComMngPopulationHouseDO> houseLists = comMngPopulationHouseDAO.selectList(null); |
| | | List<ComMngPopulationHouseDO> houseLists = comMngPopulationHouseDAO.selectList(new QueryWrapper<ComMngPopulationHouseDO>().lambda().eq(ComMngPopulationHouseDO::getCommunityId,communityId)); |
| | | HashMap<String, Object> houseMap = new HashMap<>(); |
| | | houseLists.forEach(house -> { |
| | | String key = house.getCommunityId() + house.getVillageId() + house.getFloor() + house.getUnitNo() |
| | |
| | | houseMap.put(key, house); |
| | | }); |
| | | |
| | | List<ComMngVillageDO> villageList = comActVillageDAO.selectList(null); |
| | | List<ComMngVillageDO> villageList = comActVillageDAO.selectList(new QueryWrapper<ComMngVillageDO>().lambda().eq(ComMngVillageDO::getCommunityId,communityId)); |
| | | HashMap<String, Object> villageMap = new HashMap<>(); |
| | | villageList.forEach(village -> { |
| | | String key = village.getCommunityId() + village.getAlley() + village.getHouseNum(); |
| | | villageMap.put(key, village); |
| | | }); |
| | | |
| | | List<ComMngPopulationHouseUserDO> houseUserLists = comMngPopulationHouseUserDAO.selectList(null); |
| | | List<ComMngPopulationHouseUserDO> houseUserLists = comMngPopulationHouseUserDAO.selectListIndex(communityId); |
| | | HashMap<String, Object> houseUserMap = new HashMap<>(); |
| | | houseUserLists.forEach(houseUser -> { |
| | | String key = houseUser.getPopulId() + houseUser.getHouseId() + ""; |
| | |
| | | }); |
| | | |
| | | List<ComMngPopulationCommunityTagsDO> populationCommunityLists = |
| | | comMngPopulationCommunityTagsDAO.selectList(null); |
| | | comMngPopulationCommunityTagsDAO.selectList(new QueryWrapper<ComMngPopulationCommunityTagsDO>().lambda().eq(ComMngPopulationCommunityTagsDO::getCommunityId,communityId)); |
| | | HashMap<String, Object> populationCommunityMap = new HashMap<>(); |
| | | populationCommunityLists.forEach(populationCommunity -> { |
| | | String key = populationCommunity.getPopulationId() + populationCommunity.getCommunityId() + ""; |
| | |
| | | log.info("开始查询小区街路巷是否存在完成"); |
| | | |
| | | log.info("开始查询房屋是否存在"); |
| | | // 先判断房屋是否存在 |
| | | ComMngPopulationHouseDO populationHouseDO = null; |
| | | String houseKey = |
| | | communityId + comMngVillageDO.getVillageId() + vo.getFloor() + vo.getUnitNo() + vo.getHouseNo(); |
| | | if (isOnly(houseKey, houseMap)) { |
| | | if (!houseList.isEmpty()) { |
| | | for (ComMngPopulationHouseDO house : houseList) { |
| | | if (house.getVillageId().equals(comMngVillageDO.getVillageId()) |
| | | && house.getCommunityId().equals(communityId) && house.getFloor().equals(vo.getFloor()) |
| | | && house.getUnitNo().equals(vo.getUnitNo()) |
| | | && house.getHouseNo().equals(vo.getHouseNo())) { |
| | | populationHouseDO = house; |
| | | break; |
| | | // 先判断房屋是否存在 |
| | | if(StringUtils.isNotEmpty(vo.getFloor())&&StringUtils.isNotEmpty(vo.getHouseNo())&&StringUtils.isNotEmpty(vo.getUnitNo())){ |
| | | String houseKey = |
| | | communityId + comMngVillageDO.getVillageId() + vo.getFloor() + vo.getUnitNo() + vo.getHouseNo(); |
| | | if (isOnly(houseKey, houseMap)) { |
| | | if (!houseList.isEmpty()) { |
| | | for (ComMngPopulationHouseDO house : houseList) { |
| | | if (house.getVillageId().equals(comMngVillageDO.getVillageId()) |
| | | && house.getCommunityId().equals(communityId) && house.getFloor().equals(vo.getFloor()) |
| | | && house.getUnitNo().equals(vo.getUnitNo()) |
| | | && house.getHouseNo().equals(vo.getHouseNo())) { |
| | | populationHouseDO = house; |
| | | break; |
| | | } |
| | | } |
| | | } |
| | | if (populationHouseDO == null) { |
| | | // 房屋信息不存在建立房屋信息 |
| | | populationHouseDO = |
| | | saveRehabilitationPopulationHouse(vo, comMngVillageDO, communityId, areaPath, populationActVO.getName()); |
| | | houseList.add(populationHouseDO); |
| | | } |
| | | } else { |
| | | populationHouseDO = (ComMngPopulationHouseDO)houseMap.get(houseKey); |
| | | } |
| | | if (populationHouseDO == null) { |
| | | // 房屋信息不存在建立房屋信息 |
| | | populationHouseDO = saveRehabilitationPopulationHouse(vo, comMngVillageDO, communityId, |
| | | areaPath, populationActVO.getName()); |
| | | houseList.add(populationHouseDO); |
| | | } |
| | | } else { |
| | | populationHouseDO = (ComMngPopulationHouseDO)houseMap.get(houseKey); |
| | | vo.setHouseId(populationHouseDO.getId()); |
| | | log.info("查询房屋是否存在完成"); |
| | | }else { |
| | | ComMngPopulationRehabilitationMistakeExcelVO mistake = new ComMngPopulationRehabilitationMistakeExcelVO(); |
| | | BeanUtils.copyProperties(vo, mistake); |
| | | setRehabilitationMistake(mistake, vo); |
| | | mistake.setMistake("房屋数据填报不完整" ); |
| | | mistakes.add(mistake); |
| | | log.info("房屋数据填报不完整"); |
| | | continue; |
| | | } |
| | | vo.setHouseId(populationHouseDO.getId()); |
| | | log.info("开始查询房屋是否存在完成"); |
| | | |
| | | if (StringUtils.isEmpty(vo.getName()) && StringUtils.isEmpty(vo.getCardNo())) { |
| | | // 空户处理完房屋信息,直接返回 |
| | | continue; |
| | | } |
| | | String cardNoAES = AESUtil.encrypt128(vo.getCardNo(), aesKey); |
| | | // 判断实有人口是否已存在 |
| | | log.info("开始查询实有人口是否已存在"); |
| | | ComMngPopulationDO populationDO = null; |
| | |
| | | if (!labelList.contains(s)) |
| | | iterator.remove(); |
| | | } |
| | | comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); |
| | | if(StringUtils.isNotEmpty(comMngPopulationCommunityTagsDO.getLabel())){ |
| | | for(String tag:userTag){ |
| | | if(!comMngPopulationCommunityTagsDO.getLabel().contains(tag)){ |
| | | comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel()+","+tag); |
| | | } |
| | | } |
| | | } |
| | | else{ |
| | | comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); |
| | | } |
| | | comMngPopulationCommunityTagsDO.setUpdateBy(userId); |
| | | updatePopulationCommunityList.add(comMngPopulationCommunityTagsDO); |
| | | |
| | |
| | | mistakes.add(mistake); |
| | | } |
| | | } |
| | | |
| | | log.info("查询实有人口存在社区信息完成"); |
| | | |
| | | log.info("开始处理楼栋信息"); |
| | | List<ComMngBuildingDO> comMngBuildingDOList= comMngBuildingDAO.selectList(new QueryWrapper<ComMngBuildingDO>().lambda().eq(ComMngBuildingDO::getVillageId,comMngVillageDO.getVillageId()).eq(ComMngBuildingDO::getName,vo.getFloor())); |
| | | if(comMngBuildingDOList.isEmpty()){ |
| | | ComMngBuildingDO comMngBuildingDO=new ComMngBuildingDO(); |
| | | comMngBuildingDO.setId(Snowflake.getId()); |
| | | comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); |
| | | comMngBuildingDO.setName(vo.getFloor()); |
| | | comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); |
| | | comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); |
| | | comMngBuildingDAO.insert(comMngBuildingDO); |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | log.info("出现错误,错误原因:" + e.getMessage()); |
| | |
| | | if (!houseList.isEmpty()) { |
| | | log.info("执行数据库导入房屋"); |
| | | comMngPopulationHouseDAO.insertAll(houseList); |
| | | log.info("执行数据库导入房屋完成"); |
| | | log.info("数据库导入房屋完成"); |
| | | } |
| | | if (!saveList.isEmpty()) { |
| | | log.info("执行数据库导入人口"); |
| | | this.baseMapper.insertAll(saveList); |
| | | log.info("执行数据库导入人口完成"); |
| | | log.info("数据库导入人口完成"); |
| | | } |
| | | if (!updateList.isEmpty()) { |
| | | log.info("执行数据库更新人口"); |
| | | this.baseMapper.updateAll(updateList); |
| | | this.updateBatchById(updateList); |
| | | // this.updateBatchById(updateList); |
| | | log.info("执行数据库更新人口完成"); |
| | | log.info("数据库更新人口完成"); |
| | | } |
| | | if (!houseUserList.isEmpty()) { |
| | | log.info("执行数据库导入人口房屋关系"); |
| | | comMngPopulationHouseUserService.saveBatch(houseUserList); |
| | | log.info("执行数据库导入人口房屋关系完成"); |
| | | log.info("数据库导入人口房屋关系完成"); |
| | | } |
| | | if (!savePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库导入人口社区关系"); |
| | |
| | | } |
| | | if (!updatePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库更新人口社区关系"); |
| | | comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); |
| | | comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); |
| | | log.info("数据库更新人口社区关系完成"); |
| | | } |
| | | log.info("执行数据库导入完成"); |
| | |
| | | Integer nub = 1; |
| | | |
| | | // 查询所有人口数据放入HashMap中 |
| | | List<ComMngPopulationDO> populationList = this.baseMapper.selectList(null); |
| | | List<ComMngPopulationDO> populationList = this.baseMapper.selectList(new QueryWrapper<ComMngPopulationDO>().lambda().eq(ComMngPopulationDO::getActId,communityId)); |
| | | HashMap<String, Object> populationMap = new HashMap<>(); |
| | | populationList.forEach(population -> { |
| | | String key = population.getCardNo(); |
| | | populationMap.put(key, population); |
| | | }); |
| | | // 查询所有房屋信息放入到HashMap中 |
| | | List<ComMngPopulationHouseDO> houseLists = comMngPopulationHouseDAO.selectList(null); |
| | | List<ComMngPopulationHouseDO> houseLists = comMngPopulationHouseDAO.selectList(new QueryWrapper<ComMngPopulationHouseDO>().lambda().eq(ComMngPopulationHouseDO::getCommunityId,communityId)); |
| | | HashMap<String, Object> houseMap = new HashMap<>(); |
| | | houseLists.forEach(house -> { |
| | | String key = house.getCommunityId() + house.getVillageId() + house.getFloor() + house.getUnitNo() |
| | |
| | | houseMap.put(key, house); |
| | | }); |
| | | |
| | | List<ComMngVillageDO> villageList = comActVillageDAO.selectList(null); |
| | | List<ComMngVillageDO> villageList = comActVillageDAO.selectList(new QueryWrapper<ComMngVillageDO>().lambda().eq(ComMngVillageDO::getCommunityId,communityId)); |
| | | HashMap<String, Object> villageMap = new HashMap<>(); |
| | | villageList.forEach(village -> { |
| | | String key = village.getCommunityId() + village.getAlley() + village.getHouseNum(); |
| | | villageMap.put(key, village); |
| | | }); |
| | | |
| | | List<ComMngPopulationHouseUserDO> houseUserLists = comMngPopulationHouseUserDAO.selectList(null); |
| | | List<ComMngPopulationHouseUserDO> houseUserLists = comMngPopulationHouseUserDAO.selectListIndex(communityId); |
| | | HashMap<String, Object> houseUserMap = new HashMap<>(); |
| | | houseUserLists.forEach(houseUser -> { |
| | | String key = houseUser.getPopulId() + houseUser.getHouseId() + ""; |
| | |
| | | }); |
| | | |
| | | List<ComMngPopulationCommunityTagsDO> populationCommunityLists = |
| | | comMngPopulationCommunityTagsDAO.selectList(null); |
| | | comMngPopulationCommunityTagsDAO.selectList(new QueryWrapper<ComMngPopulationCommunityTagsDO>().lambda().eq(ComMngPopulationCommunityTagsDO::getCommunityId,communityId)); |
| | | HashMap<String, Object> populationCommunityMap = new HashMap<>(); |
| | | populationCommunityLists.forEach(populationCommunity -> { |
| | | String key = populationCommunity.getPopulationId() + populationCommunity.getCommunityId() + ""; |
| | |
| | | log.info("开始查询小区街路巷是否存在完成"); |
| | | |
| | | log.info("开始查询房屋是否存在"); |
| | | // 先判断房屋是否存在 |
| | | ComMngPopulationHouseDO populationHouseDO = null; |
| | | String houseKey = |
| | | communityId + comMngVillageDO.getVillageId() + vo.getFloor() + vo.getUnitNo() + vo.getHouseNo(); |
| | | if (isOnly(houseKey, houseMap)) { |
| | | if (!houseList.isEmpty()) { |
| | | for (ComMngPopulationHouseDO house : houseList) { |
| | | if (house.getVillageId().equals(comMngVillageDO.getVillageId()) |
| | | && house.getCommunityId().equals(communityId) && house.getFloor().equals(vo.getFloor()) |
| | | && house.getUnitNo().equals(vo.getUnitNo()) |
| | | && house.getHouseNo().equals(vo.getHouseNo())) { |
| | | populationHouseDO = house; |
| | | break; |
| | | // 先判断房屋是否存在 |
| | | if(StringUtils.isNotEmpty(vo.getFloor())&&StringUtils.isNotEmpty(vo.getHouseNo())&&StringUtils.isNotEmpty(vo.getUnitNo())){ |
| | | String houseKey = |
| | | communityId + comMngVillageDO.getVillageId() + vo.getFloor() + vo.getUnitNo() + vo.getHouseNo(); |
| | | if (isOnly(houseKey, houseMap)) { |
| | | if (!houseList.isEmpty()) { |
| | | for (ComMngPopulationHouseDO house : houseList) { |
| | | if (house.getVillageId().equals(comMngVillageDO.getVillageId()) |
| | | && house.getCommunityId().equals(communityId) && house.getFloor().equals(vo.getFloor()) |
| | | && house.getUnitNo().equals(vo.getUnitNo()) |
| | | && house.getHouseNo().equals(vo.getHouseNo())) { |
| | | populationHouseDO = house; |
| | | break; |
| | | } |
| | | } |
| | | } |
| | | if (populationHouseDO == null) { |
| | | // 房屋信息不存在建立房屋信息 |
| | | populationHouseDO = |
| | | saveKeyPopulationHouse(vo, comMngVillageDO, communityId, areaPath, populationActVO.getName()); |
| | | houseList.add(populationHouseDO); |
| | | } |
| | | } else { |
| | | populationHouseDO = (ComMngPopulationHouseDO)houseMap.get(houseKey); |
| | | } |
| | | if (populationHouseDO == null) { |
| | | // 房屋信息不存在建立房屋信息 |
| | | populationHouseDO = saveKeyPopulationHouse(vo, comMngVillageDO, communityId, areaPath, |
| | | populationActVO.getName()); |
| | | houseList.add(populationHouseDO); |
| | | } |
| | | } else { |
| | | populationHouseDO = (ComMngPopulationHouseDO)houseMap.get(houseKey); |
| | | vo.setHouseId(populationHouseDO.getId()); |
| | | log.info("查询房屋是否存在完成"); |
| | | }else { |
| | | ComMngPopulationKeyMistakeExcelVO mistake = new ComMngPopulationKeyMistakeExcelVO(); |
| | | BeanUtils.copyProperties(vo, mistake); |
| | | setKeyMistake(mistake, vo); |
| | | mistake.setMistake("房屋数据填报不完整" ); |
| | | mistakes.add(mistake); |
| | | log.info("房屋数据填报不完整"); |
| | | continue; |
| | | } |
| | | vo.setHouseId(populationHouseDO.getId()); |
| | | log.info("开始查询房屋是否存在完成"); |
| | | |
| | | if (StringUtils.isEmpty(vo.getName()) && StringUtils.isEmpty(vo.getCardNo())) { |
| | | // 空户处理完房屋信息,直接返回 |
| | | continue; |
| | | } |
| | | String cardNoAES = AESUtil.encrypt128(vo.getCardNo(), aesKey); |
| | | // 判断实有人口是否已存在 |
| | | log.info("开始查询实有人口是否已存在"); |
| | | ComMngPopulationDO populationDO = null; |
| | |
| | | if (!labelList.contains(s)) |
| | | iterator.remove(); |
| | | } |
| | | comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); |
| | | if(StringUtils.isNotEmpty(comMngPopulationCommunityTagsDO.getLabel())){ |
| | | for(String tag:userTag){ |
| | | if(!comMngPopulationCommunityTagsDO.getLabel().contains(tag)){ |
| | | comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel()+","+tag); |
| | | } |
| | | } |
| | | } |
| | | else{ |
| | | comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); |
| | | } |
| | | comMngPopulationCommunityTagsDO.setUpdateBy(userId); |
| | | updatePopulationCommunityList.add(comMngPopulationCommunityTagsDO); |
| | | |
| | |
| | | mistakes.add(mistake); |
| | | } |
| | | } |
| | | |
| | | log.info("查询实有人口存在社区信息完成"); |
| | | |
| | | log.info("开始处理楼栋信息"); |
| | | List<ComMngBuildingDO> comMngBuildingDOList= comMngBuildingDAO.selectList(new QueryWrapper<ComMngBuildingDO>().lambda().eq(ComMngBuildingDO::getVillageId,comMngVillageDO.getVillageId()).eq(ComMngBuildingDO::getName,vo.getFloor())); |
| | | if(comMngBuildingDOList.isEmpty()){ |
| | | ComMngBuildingDO comMngBuildingDO=new ComMngBuildingDO(); |
| | | comMngBuildingDO.setId(Snowflake.getId()); |
| | | comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); |
| | | comMngBuildingDO.setName(vo.getFloor()); |
| | | comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); |
| | | comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); |
| | | comMngBuildingDAO.insert(comMngBuildingDO); |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | log.info("出现错误,错误原因:" + e.getMessage()); |
| | |
| | | if (!houseList.isEmpty()) { |
| | | log.info("执行数据库导入房屋"); |
| | | comMngPopulationHouseDAO.insertAll(houseList); |
| | | log.info("执行数据库导入房屋完成"); |
| | | log.info("数据库导入房屋完成"); |
| | | } |
| | | if (!saveList.isEmpty()) { |
| | | log.info("执行数据库导入人口"); |
| | | this.baseMapper.insertAll(saveList); |
| | | log.info("执行数据库导入人口完成"); |
| | | log.info("数据库导入人口完成"); |
| | | } |
| | | if (!updateList.isEmpty()) { |
| | | log.info("执行数据库更新人口"); |
| | | this.baseMapper.updateAll(updateList); |
| | | this.updateBatchById(updateList); |
| | | // this.updateBatchById(updateList); |
| | | log.info("执行数据库更新人口完成"); |
| | | log.info("数据库更新人口完成"); |
| | | } |
| | | if (!houseUserList.isEmpty()) { |
| | | log.info("执行数据库导入人口房屋关系"); |
| | | comMngPopulationHouseUserService.saveBatch(houseUserList); |
| | | log.info("执行数据库导入人口房屋关系完成"); |
| | | log.info("数据库导入人口房屋关系完成"); |
| | | } |
| | | if (!savePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库导入人口社区关系"); |
| | |
| | | } |
| | | if (!updatePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库更新人口社区关系"); |
| | | comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); |
| | | comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); |
| | | log.info("数据库更新人口社区关系完成"); |
| | | } |
| | | log.info("执行数据库导入完成"); |
| | |
| | | Integer nub = 1; |
| | | |
| | | // 查询所有人口数据放入HashMap中 |
| | | List<ComMngPopulationDO> populationList = this.baseMapper.selectList(null); |
| | | List<ComMngPopulationDO> populationList = this.baseMapper.selectList(new QueryWrapper<ComMngPopulationDO>().lambda().eq(ComMngPopulationDO::getActId,communityId)); |
| | | HashMap<String, Object> populationMap = new HashMap<>(); |
| | | populationList.forEach(population -> { |
| | | String key = population.getCardNo(); |
| | | populationMap.put(key, population); |
| | | }); |
| | | // 查询所有房屋信息放入到HashMap中 |
| | | List<ComMngPopulationHouseDO> houseLists = comMngPopulationHouseDAO.selectList(null); |
| | | List<ComMngPopulationHouseDO> houseLists = comMngPopulationHouseDAO.selectList(new QueryWrapper<ComMngPopulationHouseDO>().lambda().eq(ComMngPopulationHouseDO::getCommunityId,communityId)); |
| | | HashMap<String, Object> houseMap = new HashMap<>(); |
| | | houseLists.forEach(house -> { |
| | | String key = house.getCommunityId() + house.getVillageId() + house.getFloor() + house.getUnitNo() |
| | |
| | | houseMap.put(key, house); |
| | | }); |
| | | |
| | | List<ComMngVillageDO> villageList = comActVillageDAO.selectList(null); |
| | | List<ComMngVillageDO> villageList = comActVillageDAO.selectList(new QueryWrapper<ComMngVillageDO>().lambda().eq(ComMngVillageDO::getCommunityId,communityId)); |
| | | HashMap<String, Object> villageMap = new HashMap<>(); |
| | | villageList.forEach(village -> { |
| | | String key = village.getCommunityId() + village.getAlley() + village.getHouseNum(); |
| | | villageMap.put(key, village); |
| | | }); |
| | | |
| | | List<ComMngPopulationHouseUserDO> houseUserLists = comMngPopulationHouseUserDAO.selectList(null); |
| | | List<ComMngPopulationHouseUserDO> houseUserLists = comMngPopulationHouseUserDAO.selectListIndex(communityId); |
| | | HashMap<String, Object> houseUserMap = new HashMap<>(); |
| | | houseUserLists.forEach(houseUser -> { |
| | | String key = houseUser.getPopulId() + houseUser.getHouseId() + ""; |
| | |
| | | }); |
| | | |
| | | List<ComMngPopulationCommunityTagsDO> populationCommunityLists = |
| | | comMngPopulationCommunityTagsDAO.selectList(null); |
| | | comMngPopulationCommunityTagsDAO.selectList(new QueryWrapper<ComMngPopulationCommunityTagsDO>().lambda().eq(ComMngPopulationCommunityTagsDO::getCommunityId,communityId)); |
| | | HashMap<String, Object> populationCommunityMap = new HashMap<>(); |
| | | populationCommunityLists.forEach(populationCommunity -> { |
| | | String key = populationCommunity.getPopulationId() + populationCommunity.getCommunityId() + ""; |
| | |
| | | log.info("开始查询小区街路巷是否存在完成"); |
| | | |
| | | log.info("开始查询房屋是否存在"); |
| | | // 先判断房屋是否存在 |
| | | ComMngPopulationHouseDO populationHouseDO = null; |
| | | String houseKey = |
| | | communityId + comMngVillageDO.getVillageId() + vo.getFloor() + vo.getUnitNo() + vo.getHouseNo(); |
| | | if (isOnly(houseKey, houseMap)) { |
| | | if (!houseList.isEmpty()) { |
| | | for (ComMngPopulationHouseDO house : houseList) { |
| | | if (house.getVillageId().equals(comMngVillageDO.getVillageId()) |
| | | && house.getCommunityId().equals(communityId) && house.getFloor().equals(vo.getFloor()) |
| | | && house.getUnitNo().equals(vo.getUnitNo()) |
| | | && house.getHouseNo().equals(vo.getHouseNo())) { |
| | | populationHouseDO = house; |
| | | break; |
| | | // 先判断房屋是否存在 |
| | | if(StringUtils.isNotEmpty(vo.getFloor())&&StringUtils.isNotEmpty(vo.getHouseNo())&&StringUtils.isNotEmpty(vo.getUnitNo())){ |
| | | String houseKey = |
| | | communityId + comMngVillageDO.getVillageId() + vo.getFloor() + vo.getUnitNo() + vo.getHouseNo(); |
| | | if (isOnly(houseKey, houseMap)) { |
| | | if (!houseList.isEmpty()) { |
| | | for (ComMngPopulationHouseDO house : houseList) { |
| | | if (house.getVillageId().equals(comMngVillageDO.getVillageId()) |
| | | && house.getCommunityId().equals(communityId) && house.getFloor().equals(vo.getFloor()) |
| | | && house.getUnitNo().equals(vo.getUnitNo()) |
| | | && house.getHouseNo().equals(vo.getHouseNo())) { |
| | | populationHouseDO = house; |
| | | break; |
| | | } |
| | | } |
| | | } |
| | | if (populationHouseDO == null) { |
| | | // 房屋信息不存在建立房屋信息 |
| | | populationHouseDO = |
| | | saveSentencePopulationHouse(vo, comMngVillageDO, communityId, areaPath, populationActVO.getName()); |
| | | houseList.add(populationHouseDO); |
| | | } |
| | | } else { |
| | | populationHouseDO = (ComMngPopulationHouseDO)houseMap.get(houseKey); |
| | | } |
| | | if (populationHouseDO == null) { |
| | | // 房屋信息不存在建立房屋信息 |
| | | populationHouseDO = saveSentencePopulationHouse(vo, comMngVillageDO, communityId, areaPath, |
| | | populationActVO.getName()); |
| | | houseList.add(populationHouseDO); |
| | | } |
| | | } else { |
| | | populationHouseDO = (ComMngPopulationHouseDO)houseMap.get(houseKey); |
| | | vo.setHouseId(populationHouseDO.getId()); |
| | | log.info("查询房屋是否存在完成"); |
| | | }else { |
| | | ComMngPopulationSentenceMistakeExcelVO mistake = new ComMngPopulationSentenceMistakeExcelVO(); |
| | | BeanUtils.copyProperties(vo, mistake); |
| | | setSentenceMistake(mistake, vo); |
| | | mistake.setMistake("房屋数据填报不完整" ); |
| | | mistakes.add(mistake); |
| | | log.info("房屋数据填报不完整"); |
| | | continue; |
| | | } |
| | | vo.setHouseId(populationHouseDO.getId()); |
| | | log.info("开始查询房屋是否存在完成"); |
| | | |
| | | if (StringUtils.isEmpty(vo.getName()) && StringUtils.isEmpty(vo.getCardNo())) { |
| | | // 空户处理完房屋信息,直接返回 |
| | | continue; |
| | | } |
| | | String cardNoAES = AESUtil.encrypt128(vo.getCardNo(), aesKey); |
| | | // 判断实有人口是否已存在 |
| | | log.info("开始查询实有人口是否已存在"); |
| | | ComMngPopulationDO populationDO = null; |
| | |
| | | if (!labelList.contains(s)) |
| | | iterator.remove(); |
| | | } |
| | | comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); |
| | | if(StringUtils.isNotEmpty(comMngPopulationCommunityTagsDO.getLabel())){ |
| | | for(String tag:userTag){ |
| | | if(!comMngPopulationCommunityTagsDO.getLabel().contains(tag)){ |
| | | comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel()+","+tag); |
| | | } |
| | | } |
| | | } |
| | | else{ |
| | | comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); |
| | | } |
| | | comMngPopulationCommunityTagsDO.setUpdateBy(userId); |
| | | updatePopulationCommunityList.add(comMngPopulationCommunityTagsDO); |
| | | |
| | |
| | | mistakes.add(mistake); |
| | | } |
| | | } |
| | | |
| | | log.info("查询实有人口存在社区信息完成"); |
| | | |
| | | log.info("开始处理楼栋信息"); |
| | | List<ComMngBuildingDO> comMngBuildingDOList= comMngBuildingDAO.selectList(new QueryWrapper<ComMngBuildingDO>().lambda().eq(ComMngBuildingDO::getVillageId,comMngVillageDO.getVillageId()).eq(ComMngBuildingDO::getName,vo.getFloor())); |
| | | if(comMngBuildingDOList.isEmpty()){ |
| | | ComMngBuildingDO comMngBuildingDO=new ComMngBuildingDO(); |
| | | comMngBuildingDO.setId(Snowflake.getId()); |
| | | comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); |
| | | comMngBuildingDO.setName(vo.getFloor()); |
| | | comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); |
| | | comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); |
| | | comMngBuildingDAO.insert(comMngBuildingDO); |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | log.info("出现错误,错误原因:" + e.getMessage()); |
| | |
| | | if (!houseList.isEmpty()) { |
| | | log.info("执行数据库导入房屋"); |
| | | comMngPopulationHouseDAO.insertAll(houseList); |
| | | log.info("执行数据库导入房屋完成"); |
| | | log.info("数据库导入房屋完成"); |
| | | } |
| | | if (!saveList.isEmpty()) { |
| | | log.info("执行数据库导入人口"); |
| | | this.baseMapper.insertAll(saveList); |
| | | log.info("执行数据库导入人口完成"); |
| | | log.info("数据库导入人口完成"); |
| | | } |
| | | if (!updateList.isEmpty()) { |
| | | log.info("执行数据库更新人口"); |
| | | this.baseMapper.updateAll(updateList); |
| | | this.updateBatchById(updateList); |
| | | // this.updateBatchById(updateList); |
| | | log.info("执行数据库更新人口完成"); |
| | | log.info("数据库更新人口完成"); |
| | | } |
| | | if (!houseUserList.isEmpty()) { |
| | | log.info("执行数据库导入人口房屋关系"); |
| | | comMngPopulationHouseUserService.saveBatch(houseUserList); |
| | | log.info("执行数据库导入人口房屋关系完成"); |
| | | log.info("数据库导入人口房屋关系完成"); |
| | | } |
| | | if (!savePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库导入人口社区关系"); |
| | |
| | | } |
| | | if (!updatePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库更新人口社区关系"); |
| | | comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); |
| | | comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); |
| | | log.info("数据库更新人口社区关系完成"); |
| | | } |
| | | log.info("执行数据库导入完成"); |
| | |
| | | Integer nub = 1; |
| | | |
| | | // 查询所有人口数据放入HashMap中 |
| | | List<ComMngPopulationDO> populationList = this.baseMapper.selectList(null); |
| | | List<ComMngPopulationDO> populationList = this.baseMapper.selectList(new QueryWrapper<ComMngPopulationDO>().lambda().eq(ComMngPopulationDO::getActId,communityId)); |
| | | HashMap<String, Object> populationMap = new HashMap<>(); |
| | | populationList.forEach(population -> { |
| | | String key = population.getCardNo(); |
| | | populationMap.put(key, population); |
| | | }); |
| | | // 查询所有房屋信息放入到HashMap中 |
| | | List<ComMngPopulationHouseDO> houseLists = comMngPopulationHouseDAO.selectList(null); |
| | | List<ComMngPopulationHouseDO> houseLists = comMngPopulationHouseDAO.selectList(new QueryWrapper<ComMngPopulationHouseDO>().lambda().eq(ComMngPopulationHouseDO::getCommunityId,communityId)); |
| | | HashMap<String, Object> houseMap = new HashMap<>(); |
| | | houseLists.forEach(house -> { |
| | | String key = house.getCommunityId() + house.getVillageId() + house.getFloor() + house.getUnitNo() |
| | |
| | | houseMap.put(key, house); |
| | | }); |
| | | |
| | | List<ComMngVillageDO> villageList = comActVillageDAO.selectList(null); |
| | | List<ComMngVillageDO> villageList = comActVillageDAO.selectList(new QueryWrapper<ComMngVillageDO>().lambda().eq(ComMngVillageDO::getCommunityId,communityId)); |
| | | HashMap<String, Object> villageMap = new HashMap<>(); |
| | | villageList.forEach(village -> { |
| | | String key = village.getCommunityId() + village.getAlley() + village.getHouseNum(); |
| | | villageMap.put(key, village); |
| | | }); |
| | | |
| | | List<ComMngPopulationHouseUserDO> houseUserLists = comMngPopulationHouseUserDAO.selectList(null); |
| | | List<ComMngPopulationHouseUserDO> houseUserLists = comMngPopulationHouseUserDAO.selectListIndex(communityId); |
| | | HashMap<String, Object> houseUserMap = new HashMap<>(); |
| | | houseUserLists.forEach(houseUser -> { |
| | | String key = houseUser.getPopulId() + houseUser.getHouseId() + ""; |
| | |
| | | }); |
| | | |
| | | List<ComMngPopulationCommunityTagsDO> populationCommunityLists = |
| | | comMngPopulationCommunityTagsDAO.selectList(null); |
| | | comMngPopulationCommunityTagsDAO.selectList(new QueryWrapper<ComMngPopulationCommunityTagsDO>().lambda().eq(ComMngPopulationCommunityTagsDO::getCommunityId,communityId)); |
| | | HashMap<String, Object> populationCommunityMap = new HashMap<>(); |
| | | populationCommunityLists.forEach(populationCommunity -> { |
| | | String key = populationCommunity.getPopulationId() + populationCommunity.getCommunityId() + ""; |
| | |
| | | log.info("开始查询小区街路巷是否存在完成"); |
| | | |
| | | log.info("开始查询房屋是否存在"); |
| | | // 先判断房屋是否存在 |
| | | ComMngPopulationHouseDO populationHouseDO = null; |
| | | String houseKey = |
| | | communityId + comMngVillageDO.getVillageId() + vo.getFloor() + vo.getUnitNo() + vo.getHouseNo(); |
| | | if (isOnly(houseKey, houseMap)) { |
| | | if (!houseList.isEmpty()) { |
| | | for (ComMngPopulationHouseDO house : houseList) { |
| | | if (house.getVillageId().equals(comMngVillageDO.getVillageId()) |
| | | && house.getCommunityId().equals(communityId) && house.getFloor().equals(vo.getFloor()) |
| | | && house.getUnitNo().equals(vo.getUnitNo()) |
| | | && house.getHouseNo().equals(vo.getHouseNo())) { |
| | | populationHouseDO = house; |
| | | break; |
| | | // 先判断房屋是否存在 |
| | | if(StringUtils.isNotEmpty(vo.getFloor())&&StringUtils.isNotEmpty(vo.getHouseNo())&&StringUtils.isNotEmpty(vo.getUnitNo())){ |
| | | String houseKey = |
| | | communityId + comMngVillageDO.getVillageId() + vo.getFloor() + vo.getUnitNo() + vo.getHouseNo(); |
| | | if (isOnly(houseKey, houseMap)) { |
| | | if (!houseList.isEmpty()) { |
| | | for (ComMngPopulationHouseDO house : houseList) { |
| | | if (house.getVillageId().equals(comMngVillageDO.getVillageId()) |
| | | && house.getCommunityId().equals(communityId) && house.getFloor().equals(vo.getFloor()) |
| | | && house.getUnitNo().equals(vo.getUnitNo()) |
| | | && house.getHouseNo().equals(vo.getHouseNo())) { |
| | | populationHouseDO = house; |
| | | break; |
| | | } |
| | | } |
| | | } |
| | | if (populationHouseDO == null) { |
| | | // 房屋信息不存在建立房屋信息 |
| | | populationHouseDO = |
| | | saveVeteransPopulationHouse(vo, comMngVillageDO, communityId, areaPath, populationActVO.getName()); |
| | | houseList.add(populationHouseDO); |
| | | } |
| | | } else { |
| | | populationHouseDO = (ComMngPopulationHouseDO)houseMap.get(houseKey); |
| | | } |
| | | if (populationHouseDO == null) { |
| | | // 房屋信息不存在建立房屋信息 |
| | | populationHouseDO = saveVeteransPopulationHouse(vo, comMngVillageDO, communityId, areaPath, |
| | | populationActVO.getName()); |
| | | houseList.add(populationHouseDO); |
| | | } |
| | | } else { |
| | | populationHouseDO = (ComMngPopulationHouseDO)houseMap.get(houseKey); |
| | | vo.setHouseId(populationHouseDO.getId()); |
| | | log.info("查询房屋是否存在完成"); |
| | | }else { |
| | | ComMngPopulationVeteransMistakeExcelVO mistake = new ComMngPopulationVeteransMistakeExcelVO(); |
| | | BeanUtils.copyProperties(vo, mistake); |
| | | setVeteransMistake(mistake, vo); |
| | | mistake.setMistake("房屋数据填报不完整" ); |
| | | mistakes.add(mistake); |
| | | log.info("房屋数据填报不完整"); |
| | | continue; |
| | | } |
| | | vo.setHouseId(populationHouseDO.getId()); |
| | | log.info("开始查询房屋是否存在完成"); |
| | | |
| | | if (StringUtils.isEmpty(vo.getName()) && StringUtils.isEmpty(vo.getCardNo())) { |
| | | // 空户处理完房屋信息,直接返回 |
| | | continue; |
| | | } |
| | | String cardNoAES = AESUtil.encrypt128(vo.getCardNo(), aesKey); |
| | | // 判断实有人口是否已存在 |
| | | log.info("开始查询实有人口是否已存在"); |
| | | ComMngPopulationDO populationDO = null; |
| | |
| | | if (!labelList.contains(s)) |
| | | iterator.remove(); |
| | | } |
| | | comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); |
| | | if(StringUtils.isNotEmpty(comMngPopulationCommunityTagsDO.getLabel())){ |
| | | for(String tag:userTag){ |
| | | if(!comMngPopulationCommunityTagsDO.getLabel().contains(tag)){ |
| | | comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel()+","+tag); |
| | | } |
| | | } |
| | | } |
| | | else{ |
| | | comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); |
| | | } |
| | | comMngPopulationCommunityTagsDO.setUpdateBy(userId); |
| | | updatePopulationCommunityList.add(comMngPopulationCommunityTagsDO); |
| | | |
| | |
| | | mistakes.add(mistake); |
| | | } |
| | | } |
| | | |
| | | log.info("查询实有人口存在社区信息完成"); |
| | | |
| | | log.info("开始处理楼栋信息"); |
| | | List<ComMngBuildingDO> comMngBuildingDOList= comMngBuildingDAO.selectList(new QueryWrapper<ComMngBuildingDO>().lambda().eq(ComMngBuildingDO::getVillageId,comMngVillageDO.getVillageId()).eq(ComMngBuildingDO::getName,vo.getFloor())); |
| | | if(comMngBuildingDOList.isEmpty()){ |
| | | ComMngBuildingDO comMngBuildingDO=new ComMngBuildingDO(); |
| | | comMngBuildingDO.setId(Snowflake.getId()); |
| | | comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); |
| | | comMngBuildingDO.setName(vo.getFloor()); |
| | | comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); |
| | | comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); |
| | | comMngBuildingDAO.insert(comMngBuildingDO); |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | log.info("出现错误,错误原因:" + e.getMessage()); |
| | |
| | | if (!houseList.isEmpty()) { |
| | | log.info("执行数据库导入房屋"); |
| | | comMngPopulationHouseDAO.insertAll(houseList); |
| | | log.info("执行数据库导入房屋完成"); |
| | | log.info("数据库导入房屋完成"); |
| | | } |
| | | if (!saveList.isEmpty()) { |
| | | log.info("执行数据库导入人口"); |
| | | this.baseMapper.insertAll(saveList); |
| | | log.info("执行数据库导入人口完成"); |
| | | log.info("数据库导入人口完成"); |
| | | } |
| | | if (!updateList.isEmpty()) { |
| | | log.info("执行数据库更新人口"); |
| | | this.baseMapper.updateAll(updateList); |
| | | this.updateBatchById(updateList); |
| | | // this.updateBatchById(updateList); |
| | | log.info("执行数据库更新人口完成"); |
| | | log.info("数据库更新人口完成"); |
| | | } |
| | | if (!houseUserList.isEmpty()) { |
| | | log.info("执行数据库导入人口房屋关系"); |
| | | comMngPopulationHouseUserService.saveBatch(houseUserList); |
| | | log.info("执行数据库导入人口房屋关系完成"); |
| | | log.info("数据库导入人口房屋关系完成"); |
| | | } |
| | | if (!savePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库导入人口社区关系"); |
| | |
| | | } |
| | | if (!updatePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库更新人口社区关系"); |
| | | comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); |
| | | comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); |
| | | log.info("数据库更新人口社区关系完成"); |
| | | } |
| | | log.info("执行数据库导入完成"); |
| | |
| | | Integer nub = 1; |
| | | |
| | | // 查询所有人口数据放入HashMap中 |
| | | List<ComMngPopulationDO> populationList = this.baseMapper.selectList(null); |
| | | List<ComMngPopulationDO> populationList = this.baseMapper.selectList(new QueryWrapper<ComMngPopulationDO>().lambda().eq(ComMngPopulationDO::getActId,communityId)); |
| | | HashMap<String, Object> populationMap = new HashMap<>(); |
| | | populationList.forEach(population -> { |
| | | String key = population.getCardNo(); |
| | | populationMap.put(key, population); |
| | | }); |
| | | // 查询所有房屋信息放入到HashMap中 |
| | | List<ComMngPopulationHouseDO> houseLists = comMngPopulationHouseDAO.selectList(null); |
| | | List<ComMngPopulationHouseDO> houseLists = comMngPopulationHouseDAO.selectList(new QueryWrapper<ComMngPopulationHouseDO>().lambda().eq(ComMngPopulationHouseDO::getCommunityId,communityId)); |
| | | HashMap<String, Object> houseMap = new HashMap<>(); |
| | | houseLists.forEach(house -> { |
| | | String key = house.getCommunityId() + house.getVillageId() + house.getFloor() + house.getUnitNo() |
| | |
| | | houseMap.put(key, house); |
| | | }); |
| | | |
| | | List<ComMngVillageDO> villageList = comActVillageDAO.selectList(null); |
| | | List<ComMngVillageDO> villageList = comActVillageDAO.selectList(new QueryWrapper<ComMngVillageDO>().lambda().eq(ComMngVillageDO::getCommunityId,communityId)); |
| | | HashMap<String, Object> villageMap = new HashMap<>(); |
| | | villageList.forEach(village -> { |
| | | String key = village.getCommunityId() + village.getAlley() + village.getHouseNum(); |
| | | villageMap.put(key, village); |
| | | }); |
| | | |
| | | List<ComMngPopulationHouseUserDO> houseUserLists = comMngPopulationHouseUserDAO.selectList(null); |
| | | List<ComMngPopulationHouseUserDO> houseUserLists = comMngPopulationHouseUserDAO.selectListIndex(communityId); |
| | | HashMap<String, Object> houseUserMap = new HashMap<>(); |
| | | houseUserLists.forEach(houseUser -> { |
| | | String key = houseUser.getPopulId() + houseUser.getHouseId() + ""; |
| | |
| | | }); |
| | | |
| | | List<ComMngPopulationCommunityTagsDO> populationCommunityLists = |
| | | comMngPopulationCommunityTagsDAO.selectList(null); |
| | | comMngPopulationCommunityTagsDAO.selectList(new QueryWrapper<ComMngPopulationCommunityTagsDO>().lambda().eq(ComMngPopulationCommunityTagsDO::getCommunityId,communityId)); |
| | | HashMap<String, Object> populationCommunityMap = new HashMap<>(); |
| | | populationCommunityLists.forEach(populationCommunity -> { |
| | | String key = populationCommunity.getPopulationId() + populationCommunity.getCommunityId() + ""; |
| | |
| | | log.info("开始查询小区街路巷是否存在完成"); |
| | | |
| | | log.info("开始查询房屋是否存在"); |
| | | // 先判断房屋是否存在 |
| | | ComMngPopulationHouseDO populationHouseDO = null; |
| | | String houseKey = |
| | | communityId + comMngVillageDO.getVillageId() + vo.getFloor() + vo.getUnitNo() + vo.getHouseNo(); |
| | | if (isOnly(houseKey, houseMap)) { |
| | | if (!houseList.isEmpty()) { |
| | | for (ComMngPopulationHouseDO house : houseList) { |
| | | if (house.getVillageId().equals(comMngVillageDO.getVillageId()) |
| | | && house.getCommunityId().equals(communityId) && house.getFloor().equals(vo.getFloor()) |
| | | && house.getUnitNo().equals(vo.getUnitNo()) |
| | | && house.getHouseNo().equals(vo.getHouseNo())) { |
| | | populationHouseDO = house; |
| | | break; |
| | | // 先判断房屋是否存在 |
| | | if(StringUtils.isNotEmpty(vo.getFloor())&&StringUtils.isNotEmpty(vo.getHouseNo())&&StringUtils.isNotEmpty(vo.getUnitNo())){ |
| | | String houseKey = |
| | | communityId + comMngVillageDO.getVillageId() + vo.getFloor() + vo.getUnitNo() + vo.getHouseNo(); |
| | | if (isOnly(houseKey, houseMap)) { |
| | | if (!houseList.isEmpty()) { |
| | | for (ComMngPopulationHouseDO house : houseList) { |
| | | if (house.getVillageId().equals(comMngVillageDO.getVillageId()) |
| | | && house.getCommunityId().equals(communityId) && house.getFloor().equals(vo.getFloor()) |
| | | && house.getUnitNo().equals(vo.getUnitNo()) |
| | | && house.getHouseNo().equals(vo.getHouseNo())) { |
| | | populationHouseDO = house; |
| | | break; |
| | | } |
| | | } |
| | | } |
| | | if (populationHouseDO == null) { |
| | | // 房屋信息不存在建立房屋信息 |
| | | populationHouseDO = |
| | | saveDisabilityPopulationHouse(vo, comMngVillageDO, communityId, areaPath, populationActVO.getName()); |
| | | houseList.add(populationHouseDO); |
| | | } |
| | | } else { |
| | | populationHouseDO = (ComMngPopulationHouseDO)houseMap.get(houseKey); |
| | | } |
| | | if (populationHouseDO == null) { |
| | | // 房屋信息不存在建立房屋信息 |
| | | populationHouseDO = saveDisabilityPopulationHouse(vo, comMngVillageDO, communityId, areaPath, |
| | | populationActVO.getName()); |
| | | houseList.add(populationHouseDO); |
| | | } |
| | | } else { |
| | | populationHouseDO = (ComMngPopulationHouseDO)houseMap.get(houseKey); |
| | | vo.setHouseId(populationHouseDO.getId()); |
| | | log.info("查询房屋是否存在完成"); |
| | | }else { |
| | | ComMngPopulationDisabilityMistakeExcelVO mistake = new ComMngPopulationDisabilityMistakeExcelVO(); |
| | | BeanUtils.copyProperties(vo, mistake); |
| | | setDisabilityMistake(mistake, vo); |
| | | mistake.setMistake("房屋数据填报不完整" ); |
| | | mistakes.add(mistake); |
| | | log.info("房屋数据填报不完整"); |
| | | continue; |
| | | } |
| | | vo.setHouseId(populationHouseDO.getId()); |
| | | log.info("开始查询房屋是否存在完成"); |
| | | |
| | | if (StringUtils.isEmpty(vo.getName()) && StringUtils.isEmpty(vo.getCardNo())) { |
| | | // 空户处理完房屋信息,直接返回 |
| | | continue; |
| | | } |
| | | String cardNoAES = AESUtil.encrypt128(vo.getCardNo(), aesKey); |
| | | // 判断实有人口是否已存在 |
| | | log.info("开始查询实有人口是否已存在"); |
| | | ComMngPopulationDO populationDO = null; |
| | |
| | | if (!labelList.contains(s)) |
| | | iterator.remove(); |
| | | } |
| | | comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); |
| | | if(StringUtils.isNotEmpty(comMngPopulationCommunityTagsDO.getLabel())){ |
| | | for(String tag:userTag){ |
| | | if(!comMngPopulationCommunityTagsDO.getLabel().contains(tag)){ |
| | | comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel()+","+tag); |
| | | } |
| | | } |
| | | } |
| | | else{ |
| | | comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); |
| | | } |
| | | comMngPopulationCommunityTagsDO.setUpdateBy(userId); |
| | | updatePopulationCommunityList.add(comMngPopulationCommunityTagsDO); |
| | | |
| | |
| | | mistakes.add(mistake); |
| | | } |
| | | } |
| | | |
| | | log.info("查询实有人口存在社区信息完成"); |
| | | |
| | | log.info("开始处理楼栋信息"); |
| | | List<ComMngBuildingDO> comMngBuildingDOList= comMngBuildingDAO.selectList(new QueryWrapper<ComMngBuildingDO>().lambda().eq(ComMngBuildingDO::getVillageId,comMngVillageDO.getVillageId()).eq(ComMngBuildingDO::getName,vo.getFloor())); |
| | | if(comMngBuildingDOList.isEmpty()){ |
| | | ComMngBuildingDO comMngBuildingDO=new ComMngBuildingDO(); |
| | | comMngBuildingDO.setId(Snowflake.getId()); |
| | | comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); |
| | | comMngBuildingDO.setName(vo.getFloor()); |
| | | comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); |
| | | comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); |
| | | comMngBuildingDAO.insert(comMngBuildingDO); |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | log.info("出现错误,错误原因:" + e.getMessage()); |
| | |
| | | if (!houseList.isEmpty()) { |
| | | log.info("执行数据库导入房屋"); |
| | | comMngPopulationHouseDAO.insertAll(houseList); |
| | | log.info("执行数据库导入房屋完成"); |
| | | log.info("数据库导入房屋完成"); |
| | | } |
| | | if (!saveList.isEmpty()) { |
| | | log.info("执行数据库导入人口"); |
| | | this.baseMapper.insertAll(saveList); |
| | | log.info("执行数据库导入人口完成"); |
| | | log.info("数据库导入人口完成"); |
| | | } |
| | | if (!updateList.isEmpty()) { |
| | | log.info("执行数据库更新人口"); |
| | | this.baseMapper.updateAll(updateList); |
| | | this.updateBatchById(updateList); |
| | | // this.updateBatchById(updateList); |
| | | log.info("执行数据库更新人口完成"); |
| | | log.info("数据库更新人口完成"); |
| | | } |
| | | if (!houseUserList.isEmpty()) { |
| | | log.info("执行数据库导入人口房屋关系"); |
| | | comMngPopulationHouseUserService.saveBatch(houseUserList); |
| | | log.info("执行数据库导入人口房屋关系完成"); |
| | | log.info("数据库导入人口房屋关系完成"); |
| | | } |
| | | if (!savePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库导入人口社区关系"); |
| | |
| | | } |
| | | if (!updatePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库更新人口社区关系"); |
| | | comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); |
| | | comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); |
| | | log.info("数据库更新人口社区关系完成"); |
| | | } |
| | | log.info("执行数据库导入完成"); |
| | |
| | | Integer nub = 1; |
| | | |
| | | // 查询所有人口数据放入HashMap中 |
| | | List<ComMngPopulationDO> populationList = this.baseMapper.selectList(null); |
| | | List<ComMngPopulationDO> populationList = this.baseMapper.selectList(new QueryWrapper<ComMngPopulationDO>().lambda().eq(ComMngPopulationDO::getActId,communityId)); |
| | | HashMap<String, Object> populationMap = new HashMap<>(); |
| | | populationList.forEach(population -> { |
| | | String key = population.getCardNo(); |
| | | populationMap.put(key, population); |
| | | }); |
| | | // 查询所有房屋信息放入到HashMap中 |
| | | List<ComMngPopulationHouseDO> houseLists = comMngPopulationHouseDAO.selectList(null); |
| | | List<ComMngPopulationHouseDO> houseLists = comMngPopulationHouseDAO.selectList(new QueryWrapper<ComMngPopulationHouseDO>().lambda().eq(ComMngPopulationHouseDO::getCommunityId,communityId)); |
| | | HashMap<String, Object> houseMap = new HashMap<>(); |
| | | houseLists.forEach(house -> { |
| | | String key = house.getCommunityId() + house.getVillageId() + house.getFloor() + house.getUnitNo() |
| | |
| | | houseMap.put(key, house); |
| | | }); |
| | | |
| | | List<ComMngVillageDO> villageList = comActVillageDAO.selectList(null); |
| | | List<ComMngVillageDO> villageList = comActVillageDAO.selectList(new QueryWrapper<ComMngVillageDO>().lambda().eq(ComMngVillageDO::getCommunityId,communityId)); |
| | | HashMap<String, Object> villageMap = new HashMap<>(); |
| | | villageList.forEach(village -> { |
| | | String key = village.getCommunityId() + village.getAlley() + village.getHouseNum(); |
| | | villageMap.put(key, village); |
| | | }); |
| | | |
| | | List<ComMngPopulationHouseUserDO> houseUserLists = comMngPopulationHouseUserDAO.selectList(null); |
| | | List<ComMngPopulationHouseUserDO> houseUserLists = comMngPopulationHouseUserDAO.selectListIndex(communityId); |
| | | HashMap<String, Object> houseUserMap = new HashMap<>(); |
| | | houseUserLists.forEach(houseUser -> { |
| | | String key = houseUser.getPopulId() + houseUser.getHouseId() + ""; |
| | |
| | | }); |
| | | |
| | | List<ComMngPopulationCommunityTagsDO> populationCommunityLists = |
| | | comMngPopulationCommunityTagsDAO.selectList(null); |
| | | comMngPopulationCommunityTagsDAO.selectList(new QueryWrapper<ComMngPopulationCommunityTagsDO>().lambda().eq(ComMngPopulationCommunityTagsDO::getCommunityId,communityId)); |
| | | HashMap<String, Object> populationCommunityMap = new HashMap<>(); |
| | | populationCommunityLists.forEach(populationCommunity -> { |
| | | String key = populationCommunity.getPopulationId() + populationCommunity.getCommunityId() + ""; |
| | |
| | | log.info("开始查询小区街路巷是否存在完成"); |
| | | |
| | | log.info("开始查询房屋是否存在"); |
| | | // 先判断房屋是否存在 |
| | | ComMngPopulationHouseDO populationHouseDO = null; |
| | | String houseKey = |
| | | communityId + comMngVillageDO.getVillageId() + vo.getFloor() + vo.getUnitNo() + vo.getHouseNo(); |
| | | if (isOnly(houseKey, houseMap)) { |
| | | if (!houseList.isEmpty()) { |
| | | for (ComMngPopulationHouseDO house : houseList) { |
| | | if (house.getVillageId().equals(comMngVillageDO.getVillageId()) |
| | | && house.getCommunityId().equals(communityId) && house.getFloor().equals(vo.getFloor()) |
| | | && house.getUnitNo().equals(vo.getUnitNo()) |
| | | && house.getHouseNo().equals(vo.getHouseNo())) { |
| | | populationHouseDO = house; |
| | | break; |
| | | // 先判断房屋是否存在 |
| | | if(StringUtils.isNotEmpty(vo.getFloor())&&StringUtils.isNotEmpty(vo.getHouseNo())&&StringUtils.isNotEmpty(vo.getUnitNo())){ |
| | | String houseKey = |
| | | communityId + comMngVillageDO.getVillageId() + vo.getFloor() + vo.getUnitNo() + vo.getHouseNo(); |
| | | if (isOnly(houseKey, houseMap)) { |
| | | if (!houseList.isEmpty()) { |
| | | for (ComMngPopulationHouseDO house : houseList) { |
| | | if (house.getVillageId().equals(comMngVillageDO.getVillageId()) |
| | | && house.getCommunityId().equals(communityId) && house.getFloor().equals(vo.getFloor()) |
| | | && house.getUnitNo().equals(vo.getUnitNo()) |
| | | && house.getHouseNo().equals(vo.getHouseNo())) { |
| | | populationHouseDO = house; |
| | | break; |
| | | } |
| | | } |
| | | } |
| | | if (populationHouseDO == null) { |
| | | // 房屋信息不存在建立房屋信息 |
| | | populationHouseDO = |
| | | saveLowSecurityPopulationHouse(vo, comMngVillageDO, communityId, areaPath, populationActVO.getName()); |
| | | houseList.add(populationHouseDO); |
| | | } |
| | | } else { |
| | | populationHouseDO = (ComMngPopulationHouseDO)houseMap.get(houseKey); |
| | | } |
| | | if (populationHouseDO == null) { |
| | | // 房屋信息不存在建立房屋信息 |
| | | populationHouseDO = saveLowSecurityPopulationHouse(vo, comMngVillageDO, communityId, areaPath, |
| | | populationActVO.getName()); |
| | | houseList.add(populationHouseDO); |
| | | } |
| | | } else { |
| | | populationHouseDO = (ComMngPopulationHouseDO)houseMap.get(houseKey); |
| | | vo.setHouseId(populationHouseDO.getId()); |
| | | log.info("查询房屋是否存在完成"); |
| | | }else { |
| | | ComMngPopulationLowSecurityMistakeExcelVO mistake = new ComMngPopulationLowSecurityMistakeExcelVO(); |
| | | BeanUtils.copyProperties(vo, mistake); |
| | | setLowSecurityMistake(mistake, vo); |
| | | mistake.setMistake("房屋数据填报不完整" ); |
| | | mistakes.add(mistake); |
| | | log.info("房屋数据填报不完整"); |
| | | continue; |
| | | } |
| | | vo.setHouseId(populationHouseDO.getId()); |
| | | log.info("开始查询房屋是否存在完成"); |
| | | |
| | | if (StringUtils.isEmpty(vo.getName()) && StringUtils.isEmpty(vo.getCardNo())) { |
| | | // 空户处理完房屋信息,直接返回 |
| | | continue; |
| | | } |
| | | String cardNoAES = AESUtil.encrypt128(vo.getCardNo(), aesKey); |
| | | // 判断实有人口是否已存在 |
| | | log.info("开始查询实有人口是否已存在"); |
| | | ComMngPopulationDO populationDO = null; |
| | |
| | | if (!labelList.contains(s)) |
| | | iterator.remove(); |
| | | } |
| | | comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); |
| | | if(StringUtils.isNotEmpty(comMngPopulationCommunityTagsDO.getLabel())){ |
| | | for(String tag:userTag){ |
| | | if(!comMngPopulationCommunityTagsDO.getLabel().contains(tag)){ |
| | | comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel()+","+tag); |
| | | } |
| | | } |
| | | } |
| | | else{ |
| | | comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); |
| | | } |
| | | comMngPopulationCommunityTagsDO.setUpdateBy(userId); |
| | | updatePopulationCommunityList.add(comMngPopulationCommunityTagsDO); |
| | | |
| | |
| | | mistakes.add(mistake); |
| | | } |
| | | } |
| | | |
| | | log.info("查询实有人口存在社区信息完成"); |
| | | |
| | | log.info("开始处理楼栋信息"); |
| | | List<ComMngBuildingDO> comMngBuildingDOList= comMngBuildingDAO.selectList(new QueryWrapper<ComMngBuildingDO>().lambda().eq(ComMngBuildingDO::getVillageId,comMngVillageDO.getVillageId()).eq(ComMngBuildingDO::getName,vo.getFloor())); |
| | | if(comMngBuildingDOList.isEmpty()){ |
| | | ComMngBuildingDO comMngBuildingDO=new ComMngBuildingDO(); |
| | | comMngBuildingDO.setId(Snowflake.getId()); |
| | | comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); |
| | | comMngBuildingDO.setName(vo.getFloor()); |
| | | comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); |
| | | comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); |
| | | comMngBuildingDAO.insert(comMngBuildingDO); |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | log.info("出现错误,错误原因:" + e.getMessage()); |
| | |
| | | if (!houseList.isEmpty()) { |
| | | log.info("执行数据库导入房屋"); |
| | | comMngPopulationHouseDAO.insertAll(houseList); |
| | | log.info("执行数据库导入房屋完成"); |
| | | log.info("数据库导入房屋完成"); |
| | | } |
| | | if (!saveList.isEmpty()) { |
| | | log.info("执行数据库导入人口"); |
| | | this.baseMapper.insertAll(saveList); |
| | | log.info("执行数据库导入人口完成"); |
| | | log.info("数据库导入人口完成"); |
| | | } |
| | | if (!updateList.isEmpty()) { |
| | | log.info("执行数据库更新人口"); |
| | | this.baseMapper.updateAll(updateList); |
| | | this.updateBatchById(updateList); |
| | | // this.updateBatchById(updateList); |
| | | log.info("执行数据库更新人口完成"); |
| | | log.info("数据库更新人口完成"); |
| | | } |
| | | if (!houseUserList.isEmpty()) { |
| | | log.info("执行数据库导入人口房屋关系"); |
| | | comMngPopulationHouseUserService.saveBatch(houseUserList); |
| | | log.info("执行数据库导入人口房屋关系完成"); |
| | | log.info("数据库导入人口房屋关系完成"); |
| | | } |
| | | if (!savePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库导入人口社区关系"); |
| | |
| | | } |
| | | if (!updatePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库更新人口社区关系"); |
| | | comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); |
| | | comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); |
| | | log.info("数据库更新人口社区关系完成"); |
| | | } |
| | | log.info("执行数据库导入完成"); |
| | |
| | | villageMap.put(key, village); |
| | | }); |
| | | |
| | | List<ComMngPopulationHouseUserDO> houseUserLists = comMngPopulationHouseUserDAO.selectList(null); |
| | | List<ComMngPopulationHouseUserDO> houseUserLists = comMngPopulationHouseUserDAO.selectListIndex(communityId); |
| | | HashMap<String, Object> houseUserMap = new HashMap<>(); |
| | | houseUserLists.forEach(houseUser -> { |
| | | String key = houseUser.getPopulId() + houseUser.getHouseId() + ""; |
| | |
| | | log.info("开始查询小区街路巷是否存在完成"); |
| | | |
| | | log.info("开始查询房屋是否存在"); |
| | | // 先判断房屋是否存在 |
| | | ComMngPopulationHouseDO populationHouseDO = null; |
| | | String houseKey = |
| | | communityId + comMngVillageDO.getVillageId() + vo.getFloor() + vo.getUnitNo() + vo.getHouseNo(); |
| | | if (isOnly(houseKey, houseMap)) { |
| | | if (!houseList.isEmpty()) { |
| | | for (ComMngPopulationHouseDO house : houseList) { |
| | | if (house.getVillageId().equals(comMngVillageDO.getVillageId()) |
| | | && house.getCommunityId().equals(communityId) && house.getFloor().equals(vo.getFloor()) |
| | | && house.getUnitNo().equals(vo.getUnitNo()) |
| | | && house.getHouseNo().equals(vo.getHouseNo())) { |
| | | populationHouseDO = house; |
| | | break; |
| | | // 先判断房屋是否存在 |
| | | if(StringUtils.isNotEmpty(vo.getFloor())&&StringUtils.isNotEmpty(vo.getHouseNo())&&StringUtils.isNotEmpty(vo.getUnitNo())){ |
| | | String houseKey = |
| | | communityId + comMngVillageDO.getVillageId() + vo.getFloor() + vo.getUnitNo() + vo.getHouseNo(); |
| | | if (isOnly(houseKey, houseMap)) { |
| | | if (!houseList.isEmpty()) { |
| | | for (ComMngPopulationHouseDO house : houseList) { |
| | | if (house.getVillageId().equals(comMngVillageDO.getVillageId()) |
| | | && house.getCommunityId().equals(communityId) && house.getFloor().equals(vo.getFloor()) |
| | | && house.getUnitNo().equals(vo.getUnitNo()) |
| | | && house.getHouseNo().equals(vo.getHouseNo())) { |
| | | populationHouseDO = house; |
| | | break; |
| | | } |
| | | } |
| | | } |
| | | if (populationHouseDO == null) { |
| | | // 房屋信息不存在建立房屋信息 |
| | | populationHouseDO = |
| | | saveElderPopulationHouse(vo, comMngVillageDO, communityId, areaPath, populationActVO.getName()); |
| | | houseList.add(populationHouseDO); |
| | | } |
| | | } else { |
| | | populationHouseDO = (ComMngPopulationHouseDO)houseMap.get(houseKey); |
| | | } |
| | | if (populationHouseDO == null) { |
| | | // 房屋信息不存在建立房屋信息 |
| | | populationHouseDO = saveElderPopulationHouse(vo, comMngVillageDO, communityId, areaPath, |
| | | populationActVO.getName()); |
| | | houseList.add(populationHouseDO); |
| | | } |
| | | } else { |
| | | populationHouseDO = (ComMngPopulationHouseDO)houseMap.get(houseKey); |
| | | vo.setHouseId(populationHouseDO.getId()); |
| | | log.info("查询房屋是否存在完成"); |
| | | }else { |
| | | ComMngPopulationElderMistakeExcelVO mistake = new ComMngPopulationElderMistakeExcelVO(); |
| | | BeanUtils.copyProperties(vo, mistake); |
| | | setElderMistake(mistake, vo); |
| | | mistake.setMistake("房屋数据填报不完整" ); |
| | | mistakes.add(mistake); |
| | | log.info("房屋数据填报不完整"); |
| | | continue; |
| | | } |
| | | vo.setHouseId(populationHouseDO.getId()); |
| | | log.info("开始查询房屋是否存在完成"); |
| | | |
| | | if (StringUtils.isEmpty(vo.getName()) && StringUtils.isEmpty(vo.getCardNo())) { |
| | | // 空户处理完房屋信息,直接返回 |
| | | continue; |
| | | } |
| | | String cardNoAES = AESUtil.encrypt128(vo.getCardNo(), aesKey); |
| | | // 判断实有人口是否已存在 |
| | | log.info("开始查询实有人口是否已存在"); |
| | | ComMngPopulationDO populationDO = null; |
| | |
| | | iterator.remove(); |
| | | } |
| | | } |
| | | if(userTag != null && userTag.size() > 0){ |
| | | comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel() + "," + Joiner.on(",").join(userTag)); |
| | | if(StringUtils.isNotEmpty(comMngPopulationCommunityTagsDO.getLabel())){ |
| | | for(String tag:userTag){ |
| | | if(!comMngPopulationCommunityTagsDO.getLabel().contains(tag)){ |
| | | comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel()+","+tag); |
| | | } |
| | | } |
| | | } |
| | | else{ |
| | | comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); |
| | | } |
| | | comMngPopulationCommunityTagsDO.setUpdateBy(userId); |
| | | updatePopulationCommunityList.add(comMngPopulationCommunityTagsDO); |
| | |
| | | mistakes.add(mistake); |
| | | } |
| | | } |
| | | |
| | | log.info("查询实有人口存在社区信息完成"); |
| | | |
| | | log.info("开始处理楼栋信息"); |
| | | List<ComMngBuildingDO> comMngBuildingDOList= comMngBuildingDAO.selectList(new QueryWrapper<ComMngBuildingDO>().lambda().eq(ComMngBuildingDO::getVillageId,comMngVillageDO.getVillageId()).eq(ComMngBuildingDO::getName,vo.getFloor())); |
| | | if(comMngBuildingDOList.isEmpty()){ |
| | | ComMngBuildingDO comMngBuildingDO=new ComMngBuildingDO(); |
| | | comMngBuildingDO.setId(Snowflake.getId()); |
| | | comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); |
| | | comMngBuildingDO.setName(vo.getFloor()); |
| | | comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); |
| | | comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); |
| | | comMngBuildingDAO.insert(comMngBuildingDO); |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | log.info("出现错误,错误原因:" + e.getMessage()); |
| | |
| | | if (!houseList.isEmpty()) { |
| | | log.info("执行数据库导入房屋"); |
| | | comMngPopulationHouseDAO.insertAll(houseList); |
| | | log.info("执行数据库导入房屋完成"); |
| | | log.info("数据库导入房屋完成"); |
| | | } |
| | | if (!saveList.isEmpty()) { |
| | | log.info("执行数据库导入人口"); |
| | | this.baseMapper.insertAll(saveList); |
| | | log.info("执行数据库导入人口完成"); |
| | | log.info("数据库导入人口完成"); |
| | | } |
| | | if (!updateList.isEmpty()) { |
| | | log.info("执行数据库更新人口"); |
| | | this.baseMapper.updateAll(updateList); |
| | | this.updateBatchById(updateList); |
| | | // this.updateBatchById(updateList); |
| | | log.info("执行数据库更新人口完成"); |
| | | log.info("数据库更新人口完成"); |
| | | } |
| | | if (!houseUserList.isEmpty()) { |
| | | log.info("执行数据库导入人口房屋关系"); |
| | | comMngPopulationHouseUserService.saveBatch(houseUserList); |
| | | log.info("执行数据库导入人口房屋关系完成"); |
| | | log.info("数据库导入人口房屋关系完成"); |
| | | } |
| | | if (!savePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库导入人口社区关系"); |
| | |
| | | } |
| | | if (!updatePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库更新人口社区关系"); |
| | | comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); |
| | | comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); |
| | | log.info("数据库更新人口社区关系完成"); |
| | | } |
| | | log.info("执行数据库导入完成"); |
| | |
| | | villageMap.put(key, village); |
| | | }); |
| | | |
| | | List<ComMngPopulationHouseUserDO> houseUserLists = comMngPopulationHouseUserDAO.selectList(null); |
| | | List<ComMngPopulationHouseUserDO> houseUserLists = comMngPopulationHouseUserDAO.selectListIndex(communityId); |
| | | HashMap<String, Object> houseUserMap = new HashMap<>(); |
| | | houseUserLists.forEach(houseUser -> { |
| | | String key = houseUser.getPopulId() + houseUser.getHouseId() + ""; |
| | |
| | | log.info("开始查询小区街路巷是否存在完成"); |
| | | |
| | | log.info("开始查询房屋是否存在"); |
| | | // 先判断房屋是否存在 |
| | | ComMngPopulationHouseDO populationHouseDO = null; |
| | | String houseKey = |
| | | communityId + comMngVillageDO.getVillageId() + vo.getFloor() + vo.getUnitNo() + vo.getHouseNo(); |
| | | if (isOnly(houseKey, houseMap)) { |
| | | if (!houseList.isEmpty()) { |
| | | for (ComMngPopulationHouseDO house : houseList) { |
| | | if (house.getVillageId().equals(comMngVillageDO.getVillageId()) |
| | | && house.getCommunityId().equals(communityId) && house.getFloor().equals(vo.getFloor()) |
| | | && house.getUnitNo().equals(vo.getUnitNo()) |
| | | && house.getHouseNo().equals(vo.getHouseNo())) { |
| | | populationHouseDO = house; |
| | | break; |
| | | // 先判断房屋是否存在 |
| | | if(StringUtils.isNotEmpty(vo.getFloor())&&StringUtils.isNotEmpty(vo.getHouseNo())&&StringUtils.isNotEmpty(vo.getUnitNo())){ |
| | | String houseKey = |
| | | communityId + comMngVillageDO.getVillageId() + vo.getFloor() + vo.getUnitNo() + vo.getHouseNo(); |
| | | if (isOnly(houseKey, houseMap)) { |
| | | if (!houseList.isEmpty()) { |
| | | for (ComMngPopulationHouseDO house : houseList) { |
| | | if (house.getVillageId().equals(comMngVillageDO.getVillageId()) |
| | | && house.getCommunityId().equals(communityId) && house.getFloor().equals(vo.getFloor()) |
| | | && house.getUnitNo().equals(vo.getUnitNo()) |
| | | && house.getHouseNo().equals(vo.getHouseNo())) { |
| | | populationHouseDO = house; |
| | | break; |
| | | } |
| | | } |
| | | } |
| | | if (populationHouseDO == null) { |
| | | // 房屋信息不存在建立房屋信息 |
| | | populationHouseDO = |
| | | savePensionPopulationHouse(vo, comMngVillageDO, communityId, areaPath, populationActVO.getName()); |
| | | houseList.add(populationHouseDO); |
| | | } |
| | | } else { |
| | | populationHouseDO = (ComMngPopulationHouseDO)houseMap.get(houseKey); |
| | | } |
| | | if (populationHouseDO == null) { |
| | | // 房屋信息不存在建立房屋信息 |
| | | populationHouseDO = savePensionPopulationHouse(vo, comMngVillageDO, communityId, areaPath, |
| | | populationActVO.getName()); |
| | | houseList.add(populationHouseDO); |
| | | } |
| | | } else { |
| | | populationHouseDO = (ComMngPopulationHouseDO)houseMap.get(houseKey); |
| | | vo.setHouseId(populationHouseDO.getId()); |
| | | log.info("查询房屋是否存在完成"); |
| | | }else { |
| | | ComMngPopulationPensionMistakeExcelVO mistake = new ComMngPopulationPensionMistakeExcelVO(); |
| | | BeanUtils.copyProperties(vo, mistake); |
| | | setPensionMistake(mistake, vo); |
| | | mistake.setMistake("房屋数据填报不完整" ); |
| | | mistakes.add(mistake); |
| | | log.info("房屋数据填报不完整"); |
| | | continue; |
| | | } |
| | | vo.setHouseId(populationHouseDO.getId()); |
| | | log.info("开始查询房屋是否存在完成"); |
| | | |
| | | if (StringUtils.isEmpty(vo.getName()) && StringUtils.isEmpty(vo.getCardNo())) { |
| | | // 空户处理完房屋信息,直接返回 |
| | | continue; |
| | | } |
| | | String cardNoAES = AESUtil.encrypt128(vo.getCardNo(), aesKey); |
| | | // 判断实有人口是否已存在 |
| | | log.info("开始查询实有人口是否已存在"); |
| | | ComMngPopulationDO populationDO = null; |
| | |
| | | iterator.remove(); |
| | | } |
| | | } |
| | | if(userTag != null && userTag.size() > 0){ |
| | | comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel() + "," + Joiner.on(",").join(userTag)); |
| | | if(StringUtils.isNotEmpty(comMngPopulationCommunityTagsDO.getLabel())){ |
| | | for(String tag:userTag){ |
| | | if(!comMngPopulationCommunityTagsDO.getLabel().contains(tag)){ |
| | | comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel()+","+tag); |
| | | } |
| | | } |
| | | } |
| | | else{ |
| | | comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); |
| | | } |
| | | comMngPopulationCommunityTagsDO.setUpdateBy(userId); |
| | | updatePopulationCommunityList.add(comMngPopulationCommunityTagsDO); |
| | |
| | | mistakes.add(mistake); |
| | | } |
| | | } |
| | | |
| | | log.info("查询实有人口存在社区信息完成"); |
| | | |
| | | log.info("开始处理楼栋信息"); |
| | | List<ComMngBuildingDO> comMngBuildingDOList= comMngBuildingDAO.selectList(new QueryWrapper<ComMngBuildingDO>().lambda().eq(ComMngBuildingDO::getVillageId,comMngVillageDO.getVillageId()).eq(ComMngBuildingDO::getName,vo.getFloor())); |
| | | if(comMngBuildingDOList.isEmpty()){ |
| | | ComMngBuildingDO comMngBuildingDO=new ComMngBuildingDO(); |
| | | comMngBuildingDO.setId(Snowflake.getId()); |
| | | comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); |
| | | comMngBuildingDO.setName(vo.getFloor()); |
| | | comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); |
| | | comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); |
| | | comMngBuildingDAO.insert(comMngBuildingDO); |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | log.info("出现错误,错误原因:" + e.getMessage()); |
| | |
| | | if (!houseList.isEmpty()) { |
| | | log.info("执行数据库导入房屋"); |
| | | comMngPopulationHouseDAO.insertAll(houseList); |
| | | log.info("执行数据库导入房屋完成"); |
| | | log.info("数据库导入房屋完成"); |
| | | } |
| | | if (!saveList.isEmpty()) { |
| | | log.info("执行数据库导入人口"); |
| | | this.baseMapper.insertAll(saveList); |
| | | log.info("执行数据库导入人口完成"); |
| | | log.info("数据库导入人口完成"); |
| | | } |
| | | if (!updateList.isEmpty()) { |
| | | log.info("执行数据库更新人口"); |
| | | this.baseMapper.updateAll(updateList); |
| | | this.updateBatchById(updateList); |
| | | // this.updateBatchById(updateList); |
| | | log.info("执行数据库更新人口完成"); |
| | | log.info("数据库更新人口完成"); |
| | | } |
| | | if (!houseUserList.isEmpty()) { |
| | | log.info("执行数据库导入人口房屋关系"); |
| | | comMngPopulationHouseUserService.saveBatch(houseUserList); |
| | | log.info("执行数据库导入人口房屋关系完成"); |
| | | log.info("数据库导入人口房屋关系完成"); |
| | | } |
| | | if (!savePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库导入人口社区关系"); |
| | |
| | | } |
| | | if (!updatePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库更新人口社区关系"); |
| | | comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); |
| | | comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); |
| | | log.info("数据库更新人口社区关系完成"); |
| | | } |
| | | log.info("执行数据库导入完成"); |
| | |
| | | private ComMngPopulationDO updatePopulationDO(ComMngPopulationServeExcelVO vo, ComMngPopulationDO populationDO, |
| | | Long communityId, Long userId) { |
| | | BeanUtils.copyProperties(vo, populationDO); |
| | | Integer personType = vo.getPersonType(); |
| | | if (nonNull(personType)) { |
| | | populationDO.setPersonType(personType.toString()); |
| | | } |
| | | // List<String> userTag = vo.getUserTagStr().stream().map(userTagStr -> |
| | | // userTagStr.split("\\(")[0]).collect(Collectors.toList()); |
| | | // //如果导入数据标签中有当前社区标签列表中不包含的标签,则删除 |
| | |
| | | ComMngVillageDO comMngVillageDO, Long userId) { |
| | | ComMngPopulationDO populationDO = new ComMngPopulationDO(); |
| | | BeanUtils.copyProperties(vo, populationDO); |
| | | Integer personType = vo.getPersonType(); |
| | | if (nonNull(personType)) { |
| | | populationDO.setPersonType(personType.toString()); |
| | | } |
| | | populationDO.setId(Snowflake.getId()); |
| | | // List<String> userTag = vo.getUserTagStr().stream().map(userTagStr -> |
| | | // userTagStr.split("\\(")[0]).collect(Collectors.toList()); |
| | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public R deletePopulations(List<Long> ids, Long communityId) { |
| | | comMngPopulationCommunityTagsDAO.deletePopulationRelation(ids,communityId); |
| | | for(Long id:ids){ |
| | | comMngPopulationCommunityTagsDAO.delete(new QueryWrapper<ComMngPopulationCommunityTagsDO>().lambda().eq(ComMngPopulationCommunityTagsDO::getPopulationId,id)); |
| | | comMngPopulationDAO.deleteById(id); |
| | | comMngPopulationHouseUserDAO.delete(new QueryWrapper<ComMngPopulationHouseUserDO>().lambda().eq(ComMngPopulationHouseUserDO::getPopulId,id)); |
| | | } |
| | | return R.ok(); |
| | | } |
| | | |
| | |
| | | list.forEach(populationDO -> { |
| | | ComMngPopulationVO populationVO = new ComMngPopulationVO(); |
| | | BeanUtils.copyProperties(populationDO, populationVO); |
| | | ComMngPopulationCommunityTagsDO comMngPopulationCommunityTagsDO=comMngPopulationCommunityTagsDAO.selectOne(new QueryWrapper<ComMngPopulationCommunityTagsDO>().lambda().eq(ComMngPopulationCommunityTagsDO::getPopulationId,populationDO.getId())); |
| | | if(comMngPopulationCommunityTagsDO!=null){ |
| | | populationVO.setLabel(comMngPopulationCommunityTagsDO.getLabel()); |
| | | } |
| | | resultList.add(populationVO); |
| | | }); |
| | | } |
| | |
| | | IndexPopulationAgeStatisticsVO ageStatisticsVO4 = new IndexPopulationAgeStatisticsVO(); |
| | | IndexPopulationAgeStatisticsVO ageStatisticsVO5 = new IndexPopulationAgeStatisticsVO(); |
| | | IndexPopulationAgeStatisticsVO ageStatisticsVO6 = new IndexPopulationAgeStatisticsVO(); |
| | | IndexPopulationAgeStatisticsVO ageStatisticsVO7 = new IndexPopulationAgeStatisticsVO(); |
| | | IndexPopulationAgeStatisticsVO ageStatisticsVO8 = new IndexPopulationAgeStatisticsVO(); |
| | | ageStatisticsVO1.setType(1); |
| | | ageStatisticsVO2.setType(2); |
| | | ageStatisticsVO3.setType(3); |
| | | ageStatisticsVO4.setType(4); |
| | | ageStatisticsVO5.setType(5); |
| | | ageStatisticsVO6.setType(6); |
| | | |
| | | ageStatisticsVO7.setType(7); |
| | | ageStatisticsVO8.setType(8); |
| | | if (ageMap.isEmpty()) { |
| | | ageStatisticsVO1.setSum(0); |
| | | ageStatisticsVO2.setSum(0); |
| | |
| | | ageStatisticsVO4.setSum(0); |
| | | ageStatisticsVO5.setSum(0); |
| | | ageStatisticsVO6.setSum(0); |
| | | ageStatisticsVO7.setSum(0); |
| | | ageStatisticsVO8.setSum(0); |
| | | } else { |
| | | int count=ageMap.get("age16").intValue()+ageMap.get("age27").intValue()+ageMap.get("age35").intValue() |
| | | +ageMap.get("age45").intValue()+ageMap.get("age55").intValue()+ageMap.get("age55over").intValue(); |
| | | +ageMap.get("age45").intValue()+ageMap.get("age55").intValue()+ageMap.get("age55over").intValue()+ageMap.get("age65").intValue()+ageMap.get("age75").intValue(); |
| | | ageStatisticsVO1.setSum(ageMap.get("age16").intValue()); |
| | | ageStatisticsVO1.setPercent(ageMap.get("age16").intValue()*100/count); |
| | | ageStatisticsVO2.setSum(ageMap.get("age27").intValue()); |
| | | ageStatisticsVO2.setPercent(ageMap.get("age27").intValue()*100/count); |
| | | ageStatisticsVO3.setSum(ageMap.get("age35").intValue()); |
| | | ageStatisticsVO3.setPercent(ageMap.get("age35").intValue()*100/count); |
| | | ageStatisticsVO4.setSum(ageMap.get("age45").intValue()); |
| | | ageStatisticsVO4.setPercent(ageMap.get("age45").intValue()*100/count); |
| | | ageStatisticsVO5.setSum(ageMap.get("age55").intValue()); |
| | | ageStatisticsVO5.setPercent(ageMap.get("age55").intValue()*100/count); |
| | | ageStatisticsVO6.setSum(ageMap.get("age55over").intValue()); |
| | | ageStatisticsVO6.setPercent(ageMap.get("age55over").intValue()*100/count); |
| | | if(count == 0){ |
| | | ageStatisticsVO1.setSum(0); |
| | | ageStatisticsVO2.setSum(0); |
| | | ageStatisticsVO3.setSum(0); |
| | | ageStatisticsVO4.setSum(0); |
| | | ageStatisticsVO5.setSum(0); |
| | | ageStatisticsVO6.setSum(0); |
| | | ageStatisticsVO7.setSum(0); |
| | | ageStatisticsVO8.setSum(0); |
| | | ageStatisticsVO1.setPercent(BigDecimal.ZERO); |
| | | ageStatisticsVO2.setPercent(BigDecimal.ZERO); |
| | | ageStatisticsVO3.setPercent(BigDecimal.ZERO); |
| | | ageStatisticsVO4.setPercent(BigDecimal.ZERO); |
| | | ageStatisticsVO5.setPercent(BigDecimal.ZERO); |
| | | ageStatisticsVO6.setPercent(BigDecimal.ZERO); |
| | | ageStatisticsVO7.setPercent(BigDecimal.ZERO); |
| | | ageStatisticsVO8.setPercent(BigDecimal.ZERO); |
| | | }else { |
| | | BigDecimal rate = BigDecimal.valueOf(ageMap.get("age16").intValue() * 100d).divide(BigDecimal.valueOf(count), 2, BigDecimal.ROUND_HALF_UP); |
| | | ageStatisticsVO1.setPercent(rate); |
| | | ageStatisticsVO2.setSum(ageMap.get("age27").intValue()); |
| | | rate = BigDecimal.valueOf(ageMap.get("age27").intValue() * 100d).divide(BigDecimal.valueOf(count), 2, BigDecimal.ROUND_HALF_UP); |
| | | ageStatisticsVO2.setPercent(rate); |
| | | ageStatisticsVO3.setSum(ageMap.get("age35").intValue()); |
| | | rate = BigDecimal.valueOf(ageMap.get("age35").intValue() * 100d).divide(BigDecimal.valueOf(count), 2, BigDecimal.ROUND_HALF_UP); |
| | | ageStatisticsVO3.setPercent(rate); |
| | | ageStatisticsVO4.setSum(ageMap.get("age45").intValue()); |
| | | rate = BigDecimal.valueOf(ageMap.get("age45").intValue() * 100d).divide(BigDecimal.valueOf(count), 2, BigDecimal.ROUND_HALF_UP); |
| | | ageStatisticsVO4.setPercent(rate); |
| | | ageStatisticsVO5.setSum(ageMap.get("age55").intValue()); |
| | | rate = BigDecimal.valueOf(ageMap.get("age55").intValue() * 100d).divide(BigDecimal.valueOf(count), 2, BigDecimal.ROUND_HALF_UP); |
| | | ageStatisticsVO5.setPercent(rate); |
| | | ageStatisticsVO6.setSum(ageMap.get("age55over").intValue()); |
| | | rate = BigDecimal.valueOf(ageMap.get("age55over").intValue() * 100d).divide(BigDecimal.valueOf(count), 2, BigDecimal.ROUND_HALF_UP); |
| | | ageStatisticsVO6.setPercent(rate); |
| | | ageStatisticsVO7.setSum(ageMap.get("age65").intValue()); |
| | | rate = BigDecimal.valueOf(ageMap.get("age65").intValue() * 100d).divide(BigDecimal.valueOf(count), 2, BigDecimal.ROUND_HALF_UP); |
| | | ageStatisticsVO7.setPercent(rate); |
| | | ageStatisticsVO8.setSum(ageMap.get("age75").intValue()); |
| | | rate = BigDecimal.valueOf(ageMap.get("age75").intValue() * 100d).divide(BigDecimal.valueOf(count), 2, BigDecimal.ROUND_HALF_UP); |
| | | ageStatisticsVO8.setPercent(rate); |
| | | } |
| | | } |
| | | |
| | | agePopulationList.add(ageStatisticsVO1); |
| | |
| | | agePopulationList.add(ageStatisticsVO4); |
| | | agePopulationList.add(ageStatisticsVO5); |
| | | agePopulationList.add(ageStatisticsVO6); |
| | | agePopulationList.add(ageStatisticsVO7); |
| | | agePopulationList.add(ageStatisticsVO8); |
| | | return agePopulationList; |
| | | } |
| | | |
| | |
| | | // 查询特殊人群统计 |
| | | List<IndexSpecialStatisticsVO> specialStatisticsVOList = new ArrayList<>(); |
| | | |
| | | // 查询特殊人群标签列表 |
| | | //查询特殊人群标签列表 |
| | | List<ComMngUserTagVO> userTagList = comMngPopulationDAO.getUserTagListByCommunityId(communityId); |
| | | IndexSpecialStatisticsVO otherSpecialVO = new IndexSpecialStatisticsVO(); |
| | | otherSpecialVO.setTitle("其他"); |
| | |
| | | |
| | | // 查询小区列表 |
| | | List<CivilVillageStatisticsVO> villageStatisticsList = this.baseMapper.getCivilScreenVillageList(communityId); |
| | | // villageStatisticsList.forEach(civilVillageStatisticsVO -> { |
| | | // civilVillageStatisticsVO.setUserSum(comMngPopulationDAO.selectCount(new QueryWrapper<ComMngPopulationDO>().lambda().eq(ComMngPopulationDO::getVillageId,civilVillageStatisticsVO.getVillageId()))); |
| | | // List<IndexSpecialStatisticsVO> specialStatisticsVOS = new ArrayList<>(); |
| | | // IndexSpecialStatisticsVO otherSpecial = new IndexSpecialStatisticsVO(); |
| | | // otherSpecial.setTitle("其他"); |
| | | // otherSpecial.setSum(0); |
| | | // // 查询特殊人群标签列表 |
| | | // List<ComMngUserTagVO> userTagVOS = comMngPopulationDAO.getUserTagListByCommunityId(communityId); |
| | | // |
| | | // userTagVOS.forEach(comMngUserTagVO -> { |
| | | // Integer count=comMngPopulationDAO.selectCountByVillageId(civilVillageStatisticsVO.getVillageId(),comMngUserTagVO.getTagName()); |
| | | // IndexSpecialStatisticsVO indexSpecialStatisticsVO=new IndexSpecialStatisticsVO(); |
| | | // indexSpecialStatisticsVO.setTitle(comMngUserTagVO.getTagName()); |
| | | // indexSpecialStatisticsVO.setSum(count); |
| | | // otherSpecial.setSum(otherSpecial.getSum()+count); |
| | | // specialStatisticsVOS.add(indexSpecialStatisticsVO); |
| | | // }); |
| | | // otherSpecial.setSum(civilVillageStatisticsVO.getUserSum()-otherSpecial.getSum()); |
| | | // specialStatisticsVOS.add(otherSpecial); |
| | | // civilVillageStatisticsVO.setSpecialStatisticsList(specialStatisticsVOS); |
| | | // }); |
| | | civilStatisticsVO.setVillageStatisticsList(villageStatisticsList); |
| | | |
| | | //查询党建引领数据 |
| | | CivilPartyStatisticsVO civilParty = this.baseMapper.getCivilParty(communityId); |
| | | if(civilParty != null){ |
| | | civilStatisticsVO.setCivilPartyStatisticsVO(civilParty); |
| | | } |
| | | //查询社区治理数据 |
| | | CivilGovernmentStatisticsVO civilGovernment = this.baseMapper.getCivilGovernment(communityId); |
| | | if(civilGovernment != null){ |
| | | civilStatisticsVO.setCivilGovernmentStatisticsVO(civilGovernment); |
| | | } |
| | | //查询网格管理数据 |
| | | CivilGridStatisticsVO civilGrid = this.baseMapper.getCivilGrid(communityId); |
| | | if(civilGrid != null){ |
| | | civilStatisticsVO.setCivilGridStatisticsVO(civilGrid); |
| | | } |
| | | //查询便民服务数据 |
| | | CivilConvenienceStatisticsVO civilConvenience = this.baseMapper.getCivilConvenience(communityId); |
| | | if(civilConvenience != null){ |
| | | civilStatisticsVO.setCivilConvenienceStatisticsVO(civilConvenience); |
| | | } |
| | | return R.ok(civilStatisticsVO); |
| | | } |
| | | |
| | |
| | | public R getScreenEventDetail(BigScreenEventDetailDTO eventDetailDTO) { |
| | | EventNewStatisticsVO statisticsVO = new EventNewStatisticsVO(); |
| | | Integer eventType = eventDetailDTO.getEventType(); |
| | | if (eventDetailDTO.getType().equals(7) || (nonNull(eventType) && eventType.equals(2))) {// 随手拍详情 |
| | | statisticsVO = this.baseMapper.getEventScreenSSPDateil(eventDetailDTO.getEventId()); |
| | | boolean isNewReq = nonNull(eventType) && eventType.equals(2); |
| | | if (eventDetailDTO.getType().equals(7) || isNewReq) {// 随手拍详情 |
| | | if (isNewReq) { |
| | | statisticsVO = this.baseMapper.getEventScreenSSPDateilNew(eventDetailDTO.getEventId()); |
| | | } else { |
| | | statisticsVO = this.baseMapper.getEventScreenSSPDateil(eventDetailDTO.getEventId()); |
| | | } |
| | | if (statisticsVO != null && StringUtils.isNotEmpty(statisticsVO.getPhotoPathList())) { |
| | | statisticsVO.setDangerLevel("0"); |
| | | statisticsVO.setMajor(false); |
| | |
| | | |
| | | /** |
| | | * 综治后台-居民列表 |
| | | * |
| | | * |
| | | * @param populationListDTO |
| | | * 请求参数 |
| | | * @return 居民列表 |
| | |
| | | |
| | | /** |
| | | * 综治后台-删除居民 |
| | | * |
| | | * |
| | | * @param ids |
| | | * 居民id集合 |
| | | * @return 删除结果 |
| | |
| | | |
| | | /** |
| | | * 查询平台人口列表 |
| | | * |
| | | * |
| | | * @param populationDTO |
| | | * 请求参数 |
| | | * @return 人口列表 |
| | |
| | | |
| | | /** |
| | | * 综治后台-居民标签栏统计 |
| | | * |
| | | * |
| | | * @return 居民统计 |
| | | */ |
| | | @Override |
| | |
| | | |
| | | /** |
| | | * 综治后台-居民导出查询居民数据 |
| | | * |
| | | * |
| | | * @param populationExportDTO |
| | | * 请求参数 |
| | | * @return 导出结果 |
| | |
| | | |
| | | /** |
| | | * 综治后台-居民管理小区列表 |
| | | * |
| | | * |
| | | * @param name |
| | | * 小区名字 |
| | | * @return 小区列表 |
| | |
| | | } |
| | | |
| | | @Override |
| | | public R westScreenStatics() { |
| | | WestScreenStatics westScreenStatics=this.comMngPopulationDAO.westScreenStatics(); |
| | | WxDataUtil wxDataUtil=new WxDataUtil(); |
| | | westScreenStatics.setDayUser(wxDataUtil.getDayUser()); |
| | | westScreenStatics.setCountUser(wxDataUtil.getMonthUser()); |
| | | return R.ok(westScreenStatics); |
| | | } |
| | | |
| | | @Override |
| | | public R getComprehensivePopulationStatics(Long streetId){ |
| | | EventPopulationStatisticsVO statisticsVo = new EventPopulationStatisticsVO(); |
| | | //查询人口数据 |
| | | List<EventPopulationBasicsStatisticsVO> basicsList = comMngPopulationDAO.getBasicsList(streetId); |
| | | if(basicsList != null){ |
| | | for (EventPopulationBasicsStatisticsVO basics : basicsList) { |
| | | statisticsVo.setPopulationNum(statisticsVo.getPopulationNum() + basics.getPopulationNum()); |
| | | statisticsVo.setVillageNum(statisticsVo.getVillageNum() + basics.getVillageNum()); |
| | | statisticsVo.setHouseNum(statisticsVo.getHouseNum() + basics.getHouseNum()); |
| | | } |
| | | statisticsVo.setBasicsList(basicsList); |
| | | } |
| | | //查询特殊人群数据 |
| | | EventPopulationSpecialStatisticsVO populationSpecial = comMngPopulationDAO.getPopulationSpecial(streetId); |
| | | if(populationSpecial != null){ |
| | | populationSpecial.setOtherTotal(populationSpecial.getZjTotal() + populationSpecial.getSfTotal() |
| | | + populationSpecial.getXsTotal() + populationSpecial.getXjTotal() |
| | | + populationSpecial.getJzTotal() + populationSpecial.getXdTotal()); |
| | | populationSpecial.setLnTotal(comMngPopulationDAO.getPopulationAge(streetId,60)); |
| | | populationSpecial.setGlTotal(comMngPopulationDAO.getPopulationAge(streetId,80)); |
| | | statisticsVo.setSpecialStatisticsVo(populationSpecial); |
| | | } |
| | | return R.ok(statisticsVo); |
| | | } |
| | | |
| | | @Override |
| | | public R getComprehensiveStreetList(){ |
| | | return R.ok(comMngPopulationDAO.getComprehensiveStreetList()); |
| | | } |
| | | |
| | | @Override |
| | | public R indexInfo(Long communityId) { |
| | | IndexInfo indexInfo=new IndexInfo(); |
| | | //基础数据 |
| | |
| | | IndexSpecialStatisticsVO otherSpecialVO = new IndexSpecialStatisticsVO(); |
| | | otherSpecialVO.setTitle("其他"); |
| | | otherSpecialVO.setSum(0); |
| | | int countAll=comMngPopulationDAO.getSpecialStatistics(communityId); |
| | | IndexSpecialStatisticsVO otherSpecialVO1 = new IndexSpecialStatisticsVO(); |
| | | otherSpecialVO1.setTitle("普通居民"); |
| | | otherSpecialVO1.setSum(0); |
| | | int countNormal=comMngPopulationDAO.getSpecialStatistics(communityId); |
| | | int countElder=comMngPopulationDAO.getStatisticsCount(communityId); |
| | | int countAll=countElder+countNormal; |
| | | if (!userTagList.isEmpty()) { |
| | | userTagList.forEach(userTag -> { |
| | | if (userTag != null) { |
| | | if (userTag.getSysFlag().equals(0)) { |
| | | Integer count = comMngPopulationDAO.getSpecialStatisticsByLabel(userTag.getTagName(),communityId); |
| | | otherSpecialVO.setSum(otherSpecialVO.getSum() + count); |
| | | otherSpecialVO.setPercent(otherSpecialVO.getSum()*100/countAll); |
| | | } 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(),communityId); |
| | | specialStatisticsVO.setSum(count); |
| | | specialStatisticsVOList.add(specialStatisticsVO); |
| | | } |
| | | if(userTag.getTagName().equals("高龄老人")||userTag.getTagName().equals("残疾人")||userTag.getTagName().equals("低保户")||userTag.getTagName().equals("退役军人")||userTag.getTagName().equals("养老金人员")||userTag.getTagName().equals("低收入人群")){ |
| | | IndexSpecialStatisticsVO specialStatisticsVO = new IndexSpecialStatisticsVO(); |
| | | specialStatisticsVO.setTitle(userTag.getTagName()); |
| | | Integer count =0; |
| | | if (userTag.getTagName().equals("高龄老人")) { |
| | | count=countElder; |
| | | } |
| | | else { |
| | | count= comMngPopulationDAO.getSpecialStatisticsByLabel(userTag.getTagName(),communityId); |
| | | } |
| | | specialStatisticsVO.setSum(count); |
| | | if(countAll == 0){ |
| | | specialStatisticsVO.setPercent(BigDecimal.ZERO); |
| | | }else{ |
| | | specialStatisticsVO.setPercent(BigDecimal.valueOf(specialStatisticsVO.getSum()*100d/countAll).setScale(2,BigDecimal.ROUND_HALF_UP)); |
| | | } |
| | | otherSpecialVO1.setSum(otherSpecialVO1.getSum()+count); |
| | | specialStatisticsVOList.add(specialStatisticsVO); |
| | | } |
| | | else{ |
| | | Integer count = comMngPopulationDAO.getSpecialStatisticsByLabel(userTag.getTagName(),communityId); |
| | | otherSpecialVO.setSum(otherSpecialVO.getSum()+count); |
| | | otherSpecialVO1.setSum(otherSpecialVO1.getSum()+count); |
| | | } |
| | | } |
| | | }); |
| | | } |
| | | if(countAll == 0){ |
| | | otherSpecialVO.setPercent(BigDecimal.ZERO); |
| | | otherSpecialVO1.setPercent(BigDecimal.ZERO); |
| | | }else{ |
| | | otherSpecialVO.setPercent(BigDecimal.valueOf(otherSpecialVO.getSum()*100d/countAll).setScale(2,BigDecimal.ROUND_HALF_UP)); |
| | | otherSpecialVO1.setPercent(BigDecimal.valueOf(otherSpecialVO1.getSum()*100d/countAll).setScale(2,BigDecimal.ROUND_HALF_UP)); |
| | | } |
| | | specialStatisticsVOList.add(otherSpecialVO); |
| | | otherSpecialVO1.setSum(countAll-otherSpecialVO1.getSum()); |
| | | |
| | | specialStatisticsVOList.add(otherSpecialVO1); |
| | | indexInfo.setSpecialStatisticsVOList(specialStatisticsVOList); |
| | | // 查询网格化治理 |
| | | IndexEventGridStatisticsVO eventGridStatisticsVO = new IndexEventGridStatisticsVO(); |
| | |
| | | // 查询网格化事件数据 |
| | | IndexGridEventStatisticsVO gridEventStatistics = comMngPopulationDAO.getGridEventStatisticsList(communityId); |
| | | int count=gridEventStatistics.getEventGGTotal()+gridEventStatistics.getEventBWDTotal()+gridEventStatistics.getEventMDTotal()+gridEventStatistics.getEventTFTotal()+gridEventStatistics.getEventTSTotal()+gridEventStatistics.getEventZATotal(); |
| | | gridEventStatistics.setGgPercent(gridEventStatistics.getEventGGTotal()*100/count); |
| | | gridEventStatistics.setBwdPercent(gridEventStatistics.getEventBWDTotal()*100/count); |
| | | gridEventStatistics.setMdPercent(gridEventStatistics.getEventMDTotal()*100/count); |
| | | gridEventStatistics.setTfPercent(gridEventStatistics.getEventTFTotal()*100/count); |
| | | gridEventStatistics.setTsPercent(gridEventStatistics.getEventTSTotal()*100/count); |
| | | gridEventStatistics.setZaPercent(gridEventStatistics.getEventZATotal()*100/count); |
| | | if(count!=0){ |
| | | gridEventStatistics.setGgPercent(BigDecimal.valueOf(gridEventStatistics.getEventGGTotal()*100d/count).setScale(2,BigDecimal.ROUND_HALF_UP)); |
| | | gridEventStatistics.setBwdPercent(BigDecimal.valueOf(gridEventStatistics.getEventBWDTotal()*100d/count).setScale(2,BigDecimal.ROUND_HALF_UP)); |
| | | gridEventStatistics.setMdPercent(BigDecimal.valueOf(gridEventStatistics.getEventMDTotal()*100d/count).setScale(2,BigDecimal.ROUND_HALF_UP)); |
| | | gridEventStatistics.setTfPercent(BigDecimal.valueOf(gridEventStatistics.getEventTFTotal()*100d/count).setScale(2,BigDecimal.ROUND_HALF_UP)); |
| | | gridEventStatistics.setTsPercent(BigDecimal.valueOf(gridEventStatistics.getEventTSTotal()*100d/count).setScale(2,BigDecimal.ROUND_HALF_UP)); |
| | | gridEventStatistics.setZaPercent(BigDecimal.valueOf(gridEventStatistics.getEventZATotal()*100d/count).setScale(2,BigDecimal.ROUND_HALF_UP)); |
| | | }else{ |
| | | gridEventStatistics.setGgPercent(BigDecimal.valueOf(0)); |
| | | gridEventStatistics.setBwdPercent(BigDecimal.valueOf(0)); |
| | | gridEventStatistics.setMdPercent(BigDecimal.valueOf(0)); |
| | | gridEventStatistics.setTfPercent(BigDecimal.valueOf(0)); |
| | | gridEventStatistics.setTsPercent(BigDecimal.valueOf(0)); |
| | | gridEventStatistics.setZaPercent(BigDecimal.valueOf(0)); |
| | | } |
| | | |
| | | eventGridStatisticsVO.setGridEventStatisticsList(gridEventStatistics); |
| | | // 查询网格数据 |
| | | List<EventGridDataVO> gridDataList = comMngPopulationDAO.getGridDataListByCommunityId(communityId); |
| | |
| | | IndexBackReserve indexBackReserve=new IndexBackReserve(); |
| | | indexBackReserve.setCount(comActReserveMapper.indexBackReserve(communityId)); |
| | | indexBackReserve.setIndexReserveSubList(comActReserveMapper.indexBackReserveSub(communityId)); |
| | | indexBackReserve.getIndexReserveSubList().forEach(indexReserveSub -> { |
| | | if(indexReserveSub.getAllCount()!=0){ |
| | | indexReserveSub.setPercent(BigDecimal.valueOf(indexReserveSub.getNum()*100d/indexReserveSub.getAllCount()).setScale(2,BigDecimal.ROUND_HALF_UP)); |
| | | } |
| | | else { |
| | | indexReserveSub.setPercent(BigDecimal.valueOf(0d)); |
| | | } |
| | | }); |
| | | IndexHomeQuarantine indexHomeQuarantine=new IndexHomeQuarantine(); |
| | | indexHomeQuarantine.setCount(comActReserveMapper.indexHomeQuarantine(communityId)); |
| | | indexHomeQuarantine.setIndexReserveSubList(comActReserveMapper.IndexHomeQuarantineSub(communityId)); |
| | | indexHomeQuarantine.getIndexReserveSubList().forEach(indexReserveSub -> { |
| | | if(indexReserveSub.getAllCount()!=0){ |
| | | indexReserveSub.setPercent(BigDecimal.valueOf(indexReserveSub.getNum()*100d/indexReserveSub.getAllCount()).setScale(2,BigDecimal.ROUND_HALF_UP)); |
| | | } |
| | | else { |
| | | indexReserveSub.setPercent(BigDecimal.valueOf(0d)); |
| | | } |
| | | }); |
| | | indexReserve.setIndexBackReserve(indexBackReserve); |
| | | indexReserve.setIndexHomeQuarantine(indexHomeQuarantine); |
| | | indexInfo.setIndexReserve(indexReserve); |
| | | |
| | | BigscreenGridsGovernanceStatisticsVO bigscreenGridsGovernanceStatisticsVO=comActEasyPhotoDAO.selectBigscreenGridsGovern(communityId); |
| | | indexInfo.setBigScreenGridStaticsReturn(setData(bigscreenGridsGovernanceStatisticsVO)); |
| | | |
| | | return R.ok(indexInfo); |
| | | } |
| | | |
| | | /** |
| | | * 历史数据人员类型填充 |
| | | * @param list |
| | | * @param communityId |
| | | * @param userId |
| | | * @return |
| | | */ |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public R filledPopulationPersonType(List<ComMngPopulationServeExcelVO> list, Long communityId, Long userId) { |
| | | // 需要修改的人口集合 |
| | | List<ComMngPopulationDO> updateList = new ArrayList<>(); |
| | | log.info("开始处理导入数据"); |
| | | List<ComMngPopulationMistakeExcelVO> mistakes = new ArrayList<>(); |
| | | try { |
| | | // 查询所有人口数据放入HashMap中 |
| | | List<ComMngPopulationDO> populationList = this.baseMapper.selectList(null); |
| | | HashMap<String, Object> populationMap = new HashMap<>(); |
| | | populationList.forEach(population -> { |
| | | String key = population.getCardNo(); |
| | | populationMap.put(key, population); |
| | | }); |
| | | for (ComMngPopulationServeExcelVO vo : list) { |
| | | // 判断实有人口是否已存在 |
| | | log.info("开始查询实有人口是否已存在"); |
| | | ComMngPopulationDO populationDO = null; |
| | | String populationKey = vo.getCardNo(); |
| | | if (!isOnly(populationKey, populationMap)) { |
| | | // 存在实有人口信息,则更新人员类型 |
| | | populationDO = (ComMngPopulationDO)populationMap.get(populationKey); |
| | | Integer personType = vo.getPersonType(); |
| | | if (nonNull(personType)) { |
| | | populationDO.setPersonType(personType.toString()); |
| | | } |
| | | updateList.add(populationDO); |
| | | } else { |
| | | // 不存在实有人口,返回 |
| | | ComMngPopulationMistakeExcelVO mistake = new ComMngPopulationMistakeExcelVO(); |
| | | BeanUtils.copyProperties(vo, mistake); |
| | | setMistake(mistake, vo); |
| | | mistake.setMistake("人口信息不存在,请下载实有人口模板导入"); |
| | | mistakes.add(mistake); |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | log.info("出现错误,错误原因:" + e.getMessage()); |
| | | } |
| | | if (!updateList.isEmpty()) { |
| | | log.info("执行数据库更新人口"); |
| | | this.baseMapper.updateAll(updateList); |
| | | log.info("数据库更新人口完成"); |
| | | } |
| | | if (!mistakes.isEmpty()) { |
| | | log.info("返回错误数据"); |
| | | return R.fail(mistakes); |
| | | } |
| | | return R.ok(mistakes); |
| | | } |
| | | |
| | | private void setMistake(ComMngPopulationMistakeExcelVO mvo, ComMngPopulationServeExcelVO vo) { |
| | |
| | | |
| | | /** |
| | | * 判重方法 |
| | | * |
| | | * |
| | | * @param key |
| | | * 主键 |
| | | * @param hashMap |
| | |
| | | return ObjectUtils.isEmpty(hashMap.get(key)); |
| | | } |
| | | |
| | | } |
| | | |
| | | private BigScreenGridStaticsReturn setData(BigscreenGridsGovernanceStatisticsVO bigscreenGridsGovernanceStatisticsVO){ |
| | | List<BigScreenGridStaticsReturn> bigScreenGridStaticsReturnList=new ArrayList<>(); |
| | | BigScreenGridStaticsReturn bigScreenGridStaticsReturn=new BigScreenGridStaticsReturn(); |
| | | bigScreenGridStaticsReturn.setCount(bigscreenGridsGovernanceStatisticsVO.getEventTotal()+bigscreenGridsGovernanceStatisticsVO.getOtherTotal()+bigscreenGridsGovernanceStatisticsVO.getSafety()); |
| | | BigScreenGridStaticsReturn bigScreenGridStaticsReturn1=new BigScreenGridStaticsReturn(); |
| | | bigScreenGridStaticsReturn1.setTitle("突发事件报告"); |
| | | bigScreenGridStaticsReturn1.setNum(bigscreenGridsGovernanceStatisticsVO.getEventTFTotal()); |
| | | if(bigScreenGridStaticsReturn.getCount()>0) { |
| | | bigScreenGridStaticsReturn1.setPercent(BigDecimal.valueOf(bigscreenGridsGovernanceStatisticsVO.getEventTFTotal() * 100d / bigScreenGridStaticsReturn.getCount()).setScale(2, BigDecimal.ROUND_HALF_UP)); |
| | | } |
| | | else { |
| | | bigScreenGridStaticsReturn1.setPercent(BigDecimal.valueOf(0).setScale(2, BigDecimal.ROUND_HALF_UP)); |
| | | } |
| | | bigScreenGridStaticsReturnList.add(bigScreenGridStaticsReturn1); |
| | | BigScreenGridStaticsReturn bigScreenGridStaticsReturn2=new BigScreenGridStaticsReturn(); |
| | | bigScreenGridStaticsReturn2.setTitle("特殊人群服务"); |
| | | bigScreenGridStaticsReturn2.setNum(bigscreenGridsGovernanceStatisticsVO.getEventTSTotal()); |
| | | if(bigScreenGridStaticsReturn.getCount()>0) { |
| | | bigScreenGridStaticsReturn2.setPercent(BigDecimal.valueOf(bigscreenGridsGovernanceStatisticsVO.getEventTSTotal()*100d/bigScreenGridStaticsReturn.getCount()).setScale(2,BigDecimal.ROUND_HALF_UP)); |
| | | } |
| | | else { |
| | | bigScreenGridStaticsReturn2.setPercent(BigDecimal.valueOf(0).setScale(2, BigDecimal.ROUND_HALF_UP)); |
| | | } |
| | | bigScreenGridStaticsReturnList.add(bigScreenGridStaticsReturn2); |
| | | BigScreenGridStaticsReturn bigScreenGridStaticsReturn3=new BigScreenGridStaticsReturn(); |
| | | bigScreenGridStaticsReturn3.setTitle("治安防控"); |
| | | bigScreenGridStaticsReturn3.setNum(bigscreenGridsGovernanceStatisticsVO.getEventZATotal()); |
| | | if(bigScreenGridStaticsReturn.getCount()>0) { |
| | | bigScreenGridStaticsReturn3.setPercent(BigDecimal.valueOf(bigscreenGridsGovernanceStatisticsVO.getEventZATotal()*100d/bigScreenGridStaticsReturn.getCount()).setScale(2,BigDecimal.ROUND_HALF_UP)); |
| | | } |
| | | else { |
| | | bigScreenGridStaticsReturn3.setPercent(BigDecimal.valueOf(0).setScale(2, BigDecimal.ROUND_HALF_UP)); |
| | | } |
| | | bigScreenGridStaticsReturnList.add(bigScreenGridStaticsReturn3); |
| | | BigScreenGridStaticsReturn bigScreenGridStaticsReturn4=new BigScreenGridStaticsReturn(); |
| | | bigScreenGridStaticsReturn4.setTitle("民生服务"); |
| | | bigScreenGridStaticsReturn4.setNum(bigscreenGridsGovernanceStatisticsVO.getEventMSTotal()); |
| | | if(bigScreenGridStaticsReturn.getCount()>0) { |
| | | bigScreenGridStaticsReturn4.setPercent(BigDecimal.valueOf(bigscreenGridsGovernanceStatisticsVO.getEventMSTotal()*100d/bigScreenGridStaticsReturn.getCount()).setScale(2,BigDecimal.ROUND_HALF_UP)); |
| | | } |
| | | else { |
| | | bigScreenGridStaticsReturn4.setPercent(BigDecimal.valueOf(0).setScale(2, BigDecimal.ROUND_HALF_UP)); |
| | | } |
| | | bigScreenGridStaticsReturnList.add(bigScreenGridStaticsReturn4); |
| | | BigScreenGridStaticsReturn bigScreenGridStaticsReturn5=new BigScreenGridStaticsReturn(); |
| | | bigScreenGridStaticsReturn5.setTitle("矛盾劝解"); |
| | | bigScreenGridStaticsReturn5.setNum(bigscreenGridsGovernanceStatisticsVO.getEventMDTotal()); |
| | | if(bigScreenGridStaticsReturn.getCount()>0) { |
| | | bigScreenGridStaticsReturn5.setPercent(BigDecimal.valueOf(bigscreenGridsGovernanceStatisticsVO.getEventMDTotal()*100d/bigScreenGridStaticsReturn.getCount()).setScale(2,BigDecimal.ROUND_HALF_UP)); |
| | | } |
| | | else { |
| | | bigScreenGridStaticsReturn5.setPercent(BigDecimal.valueOf(0).setScale(2, BigDecimal.ROUND_HALF_UP)); |
| | | } |
| | | bigScreenGridStaticsReturnList.add(bigScreenGridStaticsReturn5); |
| | | BigScreenGridStaticsReturn bigScreenGridStaticsReturn6=new BigScreenGridStaticsReturn(); |
| | | bigScreenGridStaticsReturn6.setTitle("防灾减灾"); |
| | | bigScreenGridStaticsReturn6.setNum(bigscreenGridsGovernanceStatisticsVO.getEventFJTotal()); |
| | | if(bigScreenGridStaticsReturn.getCount()>0) { |
| | | bigScreenGridStaticsReturn6.setPercent(BigDecimal.valueOf(bigscreenGridsGovernanceStatisticsVO.getEventFJTotal()*100d/bigScreenGridStaticsReturn.getCount()).setScale(2,BigDecimal.ROUND_HALF_UP)); |
| | | } |
| | | else { |
| | | bigScreenGridStaticsReturn6.setPercent(BigDecimal.valueOf(0).setScale(2, BigDecimal.ROUND_HALF_UP)); |
| | | } |
| | | bigScreenGridStaticsReturnList.add(bigScreenGridStaticsReturn6); |
| | | BigScreenGridStaticsReturn bigScreenGridStaticsReturn7=new BigScreenGridStaticsReturn(); |
| | | bigScreenGridStaticsReturn7.setTitle("政策法规宣传"); |
| | | bigScreenGridStaticsReturn7.setNum(bigscreenGridsGovernanceStatisticsVO.getEventFGTotal()); |
| | | if(bigScreenGridStaticsReturn.getCount()>0) { |
| | | bigScreenGridStaticsReturn7.setPercent(BigDecimal.valueOf(bigscreenGridsGovernanceStatisticsVO.getEventFGTotal()*100d/bigScreenGridStaticsReturn.getCount()).setScale(2,BigDecimal.ROUND_HALF_UP)); |
| | | } |
| | | else { |
| | | bigScreenGridStaticsReturn7.setPercent(BigDecimal.valueOf(0).setScale(2, BigDecimal.ROUND_HALF_UP)); |
| | | } |
| | | bigScreenGridStaticsReturnList.add(bigScreenGridStaticsReturn7); |
| | | BigScreenGridStaticsReturn bigScreenGridStaticsReturn8=new BigScreenGridStaticsReturn(); |
| | | bigScreenGridStaticsReturn8.setTitle("安全巡查"); |
| | | bigScreenGridStaticsReturn8.setNum(bigscreenGridsGovernanceStatisticsVO.getSafety()); |
| | | if(bigScreenGridStaticsReturn.getCount()>0) { |
| | | bigScreenGridStaticsReturn8.setPercent(BigDecimal.valueOf(bigscreenGridsGovernanceStatisticsVO.getSafety()*100d/bigScreenGridStaticsReturn.getCount()).setScale(2,BigDecimal.ROUND_HALF_UP)); |
| | | } |
| | | else { |
| | | bigScreenGridStaticsReturn8.setPercent(BigDecimal.valueOf(0).setScale(2, BigDecimal.ROUND_HALF_UP)); |
| | | } |
| | | bigScreenGridStaticsReturnList.add(bigScreenGridStaticsReturn8); |
| | | BigScreenGridStaticsReturn bigScreenGridStaticsReturn9=new BigScreenGridStaticsReturn(); |
| | | bigScreenGridStaticsReturn9.setTitle("其他"); |
| | | bigScreenGridStaticsReturn9.setNum(bigscreenGridsGovernanceStatisticsVO.getOtherTotal()); |
| | | if(bigScreenGridStaticsReturn.getCount()>0) { |
| | | bigScreenGridStaticsReturn9.setPercent(BigDecimal.valueOf(bigscreenGridsGovernanceStatisticsVO.getOtherTotal()*100d/bigScreenGridStaticsReturn.getCount()).setScale(2,BigDecimal.ROUND_HALF_UP)); |
| | | } |
| | | else { |
| | | bigScreenGridStaticsReturn9.setPercent(BigDecimal.valueOf(0).setScale(2, BigDecimal.ROUND_HALF_UP)); |
| | | } |
| | | bigScreenGridStaticsReturnList.add(bigScreenGridStaticsReturn9); |
| | | bigScreenGridStaticsReturn.setBigScreenGridStaticsReturnList(bigScreenGridStaticsReturnList); |
| | | return bigScreenGridStaticsReturn; |
| | | } |
| | | |
| | | } |