From 70d2a5d0f9c6951b2d4cac954041ed73582ff7eb Mon Sep 17 00:00:00 2001 From: liujie <1793218484@qq.com> Date: 星期一, 09 六月 2025 11:54:00 +0800 Subject: [PATCH] 6.9新增登录失败冻结逻辑 --- springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComMngPopulationServiceImpl.java | 407 ++++++++++++++++++++++++++++++++++------------------------ 1 files changed, 239 insertions(+), 168 deletions(-) diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComMngPopulationServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComMngPopulationServiceImpl.java index da7ec1e..80c12a7 100644 --- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComMngPopulationServiceImpl.java +++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComMngPopulationServiceImpl.java @@ -721,14 +721,14 @@ 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() @@ -736,14 +736,14 @@ 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() + ""; @@ -751,7 +751,7 @@ }); 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() + ""; @@ -944,10 +944,11 @@ 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(comMngBuildingDO.getStreetId()); + comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); comMngBuildingDAO.insert(comMngBuildingDO); } } @@ -1041,14 +1042,14 @@ 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() @@ -1056,14 +1057,14 @@ 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() + ""; @@ -1071,7 +1072,7 @@ }); 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() + ""; @@ -1245,7 +1246,11 @@ iterator.remove(); } if(StringUtils.isNotEmpty(comMngPopulationCommunityTagsDO.getLabel())){ - comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel()+","+Joiner.on(",").join(userTag)); + for(String tag:userTag){ + if(!comMngPopulationCommunityTagsDO.getLabel().contains(tag)){ + comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel()+","+tag); + } + } } else{ comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); @@ -1266,11 +1271,12 @@ 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 comMngBuildingDO=new ComMngBuildingDO(); + comMngBuildingDO.setId(Snowflake.getId()); comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); comMngBuildingDO.setName(vo.getFloor()); comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); - comMngBuildingDO.setStreetId(comMngBuildingDO.getStreetId()); + comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); comMngBuildingDAO.insert(comMngBuildingDO); } } @@ -1283,23 +1289,23 @@ 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("执行数据库导入人口社区关系"); @@ -1308,7 +1314,7 @@ } if (!updatePopulationCommunityList.isEmpty()) { log.info("执行数据库更新人口社区关系"); - comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); + comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); log.info("数据库更新人口社区关系完成"); } log.info("执行数据库导入完成"); @@ -1364,14 +1370,14 @@ 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() @@ -1379,14 +1385,14 @@ 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() + ""; @@ -1394,7 +1400,7 @@ }); 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() + ""; @@ -1568,7 +1574,11 @@ iterator.remove(); } if(StringUtils.isNotEmpty(comMngPopulationCommunityTagsDO.getLabel())){ - comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel()+","+Joiner.on(",").join(userTag)); + for(String tag:userTag){ + if(!comMngPopulationCommunityTagsDO.getLabel().contains(tag)){ + comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel()+","+tag); + } + } } else{ comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); @@ -1589,11 +1599,12 @@ 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 comMngBuildingDO=new ComMngBuildingDO(); + comMngBuildingDO.setId(Snowflake.getId()); comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); comMngBuildingDO.setName(vo.getFloor()); comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); - comMngBuildingDO.setStreetId(comMngBuildingDO.getStreetId()); + comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); comMngBuildingDAO.insert(comMngBuildingDO); } } @@ -1606,23 +1617,23 @@ 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("执行数据库导入人口社区关系"); @@ -1631,7 +1642,7 @@ } if (!updatePopulationCommunityList.isEmpty()) { log.info("执行数据库更新人口社区关系"); - comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); + comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); log.info("数据库更新人口社区关系完成"); } log.info("执行数据库导入完成"); @@ -1687,14 +1698,14 @@ 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() @@ -1702,14 +1713,14 @@ 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() + ""; @@ -1717,7 +1728,7 @@ }); 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() + ""; @@ -1891,7 +1902,11 @@ iterator.remove(); } if(StringUtils.isNotEmpty(comMngPopulationCommunityTagsDO.getLabel())){ - comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel()+","+Joiner.on(",").join(userTag)); + for(String tag:userTag){ + if(!comMngPopulationCommunityTagsDO.getLabel().contains(tag)){ + comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel()+","+tag); + } + } } else{ comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); @@ -1912,11 +1927,12 @@ 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 comMngBuildingDO=new ComMngBuildingDO(); + comMngBuildingDO.setId(Snowflake.getId()); comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); comMngBuildingDO.setName(vo.getFloor()); comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); - comMngBuildingDO.setStreetId(comMngBuildingDO.getStreetId()); + comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); comMngBuildingDAO.insert(comMngBuildingDO); } } @@ -1929,23 +1945,23 @@ 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("执行数据库导入人口社区关系"); @@ -1954,7 +1970,7 @@ } if (!updatePopulationCommunityList.isEmpty()) { log.info("执行数据库更新人口社区关系"); - comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); + comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); log.info("数据库更新人口社区关系完成"); } log.info("执行数据库导入完成"); @@ -2010,14 +2026,14 @@ 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() @@ -2025,14 +2041,14 @@ 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() + ""; @@ -2040,7 +2056,7 @@ }); 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() + ""; @@ -2214,7 +2230,11 @@ iterator.remove(); } if(StringUtils.isNotEmpty(comMngPopulationCommunityTagsDO.getLabel())){ - comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel()+","+Joiner.on(",").join(userTag)); + for(String tag:userTag){ + if(!comMngPopulationCommunityTagsDO.getLabel().contains(tag)){ + comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel()+","+tag); + } + } } else{ comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); @@ -2235,11 +2255,12 @@ 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 comMngBuildingDO=new ComMngBuildingDO(); + comMngBuildingDO.setId(Snowflake.getId()); comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); comMngBuildingDO.setName(vo.getFloor()); comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); - comMngBuildingDO.setStreetId(comMngBuildingDO.getStreetId()); + comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); comMngBuildingDAO.insert(comMngBuildingDO); } } @@ -2252,23 +2273,23 @@ 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("执行数据库导入人口社区关系"); @@ -2277,7 +2298,7 @@ } if (!updatePopulationCommunityList.isEmpty()) { log.info("执行数据库更新人口社区关系"); - comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); + comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); log.info("数据库更新人口社区关系完成"); } log.info("执行数据库导入完成"); @@ -2334,14 +2355,14 @@ 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() @@ -2349,14 +2370,14 @@ 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() + ""; @@ -2364,7 +2385,7 @@ }); 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() + ""; @@ -2538,7 +2559,11 @@ iterator.remove(); } if(StringUtils.isNotEmpty(comMngPopulationCommunityTagsDO.getLabel())){ - comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel()+","+Joiner.on(",").join(userTag)); + for(String tag:userTag){ + if(!comMngPopulationCommunityTagsDO.getLabel().contains(tag)){ + comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel()+","+tag); + } + } } else{ comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); @@ -2560,11 +2585,12 @@ 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 comMngBuildingDO=new ComMngBuildingDO(); + comMngBuildingDO.setId(Snowflake.getId()); comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); comMngBuildingDO.setName(vo.getFloor()); comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); - comMngBuildingDO.setStreetId(comMngBuildingDO.getStreetId()); + comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); comMngBuildingDAO.insert(comMngBuildingDO); } } @@ -2577,23 +2603,23 @@ 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("执行数据库导入人口社区关系"); @@ -2602,7 +2628,7 @@ } if (!updatePopulationCommunityList.isEmpty()) { log.info("执行数据库更新人口社区关系"); - comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); + comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); log.info("数据库更新人口社区关系完成"); } log.info("执行数据库导入完成"); @@ -2658,14 +2684,14 @@ 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() @@ -2673,14 +2699,14 @@ 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() + ""; @@ -2688,7 +2714,7 @@ }); 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() + ""; @@ -2861,7 +2887,11 @@ iterator.remove(); } if(StringUtils.isNotEmpty(comMngPopulationCommunityTagsDO.getLabel())){ - comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel()+","+Joiner.on(",").join(userTag)); + for(String tag:userTag){ + if(!comMngPopulationCommunityTagsDO.getLabel().contains(tag)){ + comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel()+","+tag); + } + } } else{ comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); @@ -2882,11 +2912,12 @@ 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 comMngBuildingDO=new ComMngBuildingDO(); + comMngBuildingDO.setId(Snowflake.getId()); comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); comMngBuildingDO.setName(vo.getFloor()); comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); - comMngBuildingDO.setStreetId(comMngBuildingDO.getStreetId()); + comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); comMngBuildingDAO.insert(comMngBuildingDO); } } @@ -2899,23 +2930,23 @@ 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("执行数据库导入人口社区关系"); @@ -2924,7 +2955,7 @@ } if (!updatePopulationCommunityList.isEmpty()) { log.info("执行数据库更新人口社区关系"); - comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); + comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); log.info("数据库更新人口社区关系完成"); } log.info("执行数据库导入完成"); @@ -2980,14 +3011,14 @@ 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() @@ -2995,14 +3026,14 @@ 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() + ""; @@ -3010,7 +3041,7 @@ }); 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() + ""; @@ -3183,7 +3214,11 @@ iterator.remove(); } if(StringUtils.isNotEmpty(comMngPopulationCommunityTagsDO.getLabel())){ - comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel()+","+Joiner.on(",").join(userTag)); + for(String tag:userTag){ + if(!comMngPopulationCommunityTagsDO.getLabel().contains(tag)){ + comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel()+","+tag); + } + } } else{ comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); @@ -3204,11 +3239,12 @@ 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 comMngBuildingDO=new ComMngBuildingDO(); + comMngBuildingDO.setId(Snowflake.getId()); comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); comMngBuildingDO.setName(vo.getFloor()); comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); - comMngBuildingDO.setStreetId(comMngBuildingDO.getStreetId()); + comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); comMngBuildingDAO.insert(comMngBuildingDO); } } @@ -3221,23 +3257,23 @@ 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("执行数据库导入人口社区关系"); @@ -3246,7 +3282,7 @@ } if (!updatePopulationCommunityList.isEmpty()) { log.info("执行数据库更新人口社区关系"); - comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); + comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); log.info("数据库更新人口社区关系完成"); } log.info("执行数据库导入完成"); @@ -3302,14 +3338,14 @@ 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() @@ -3317,14 +3353,14 @@ 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() + ""; @@ -3332,7 +3368,7 @@ }); 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() + ""; @@ -3505,7 +3541,11 @@ iterator.remove(); } if(StringUtils.isNotEmpty(comMngPopulationCommunityTagsDO.getLabel())){ - comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel()+","+Joiner.on(",").join(userTag)); + for(String tag:userTag){ + if(!comMngPopulationCommunityTagsDO.getLabel().contains(tag)){ + comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel()+","+tag); + } + } } else{ comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); @@ -3526,11 +3566,12 @@ 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 comMngBuildingDO=new ComMngBuildingDO(); + comMngBuildingDO.setId(Snowflake.getId()); comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); comMngBuildingDO.setName(vo.getFloor()); comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); - comMngBuildingDO.setStreetId(comMngBuildingDO.getStreetId()); + comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); comMngBuildingDAO.insert(comMngBuildingDO); } } @@ -3543,23 +3584,23 @@ 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("执行数据库导入人口社区关系"); @@ -3568,7 +3609,7 @@ } if (!updatePopulationCommunityList.isEmpty()) { log.info("执行数据库更新人口社区关系"); - comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); + comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); log.info("数据库更新人口社区关系完成"); } log.info("执行数据库导入完成"); @@ -3624,14 +3665,14 @@ 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() @@ -3639,14 +3680,14 @@ 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() + ""; @@ -3654,7 +3695,7 @@ }); 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() + ""; @@ -3827,7 +3868,11 @@ iterator.remove(); } if(StringUtils.isNotEmpty(comMngPopulationCommunityTagsDO.getLabel())){ - comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel()+","+Joiner.on(",").join(userTag)); + for(String tag:userTag){ + if(!comMngPopulationCommunityTagsDO.getLabel().contains(tag)){ + comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel()+","+tag); + } + } } else{ comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); @@ -3848,11 +3893,12 @@ 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 comMngBuildingDO=new ComMngBuildingDO(); + comMngBuildingDO.setId(Snowflake.getId()); comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); comMngBuildingDO.setName(vo.getFloor()); comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); - comMngBuildingDO.setStreetId(comMngBuildingDO.getStreetId()); + comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); comMngBuildingDAO.insert(comMngBuildingDO); } } @@ -3865,23 +3911,23 @@ 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("执行数据库导入人口社区关系"); @@ -3890,7 +3936,7 @@ } if (!updatePopulationCommunityList.isEmpty()) { log.info("执行数据库更新人口社区关系"); - comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); + comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); log.info("数据库更新人口社区关系完成"); } log.info("执行数据库导入完成"); @@ -3951,14 +3997,14 @@ 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() @@ -3966,14 +4012,14 @@ 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() + ""; @@ -3981,7 +4027,7 @@ }); 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() + ""; @@ -4154,7 +4200,11 @@ iterator.remove(); } if(StringUtils.isNotEmpty(comMngPopulationCommunityTagsDO.getLabel())){ - comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel()+","+Joiner.on(",").join(userTag)); + for(String tag:userTag){ + if(!comMngPopulationCommunityTagsDO.getLabel().contains(tag)){ + comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel()+","+tag); + } + } } else{ comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); @@ -4175,11 +4225,12 @@ 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 comMngBuildingDO=new ComMngBuildingDO(); + comMngBuildingDO.setId(Snowflake.getId()); comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); comMngBuildingDO.setName(vo.getFloor()); comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); - comMngBuildingDO.setStreetId(comMngBuildingDO.getStreetId()); + comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); comMngBuildingDAO.insert(comMngBuildingDO); } } @@ -4192,23 +4243,23 @@ 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("执行数据库导入人口社区关系"); @@ -4217,7 +4268,7 @@ } if (!updatePopulationCommunityList.isEmpty()) { log.info("执行数据库更新人口社区关系"); - comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); + comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); log.info("数据库更新人口社区关系完成"); } log.info("执行数据库导入完成"); @@ -4295,7 +4346,7 @@ 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() + ""; @@ -4477,8 +4528,15 @@ 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); @@ -4496,11 +4554,12 @@ 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 comMngBuildingDO=new ComMngBuildingDO(); + comMngBuildingDO.setId(Snowflake.getId()); comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); comMngBuildingDO.setName(vo.getFloor()); comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); - comMngBuildingDO.setStreetId(comMngBuildingDO.getStreetId()); + comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); comMngBuildingDAO.insert(comMngBuildingDO); } } @@ -4513,23 +4572,23 @@ 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("执行数据库导入人口社区关系"); @@ -4538,7 +4597,7 @@ } if (!updatePopulationCommunityList.isEmpty()) { log.info("执行数据库更新人口社区关系"); - comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); + comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); log.info("数据库更新人口社区关系完成"); } log.info("执行数据库导入完成"); @@ -4615,7 +4674,7 @@ 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() + ""; @@ -4797,8 +4856,15 @@ 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); @@ -4816,11 +4882,12 @@ 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 comMngBuildingDO=new ComMngBuildingDO(); + comMngBuildingDO.setId(Snowflake.getId()); comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); comMngBuildingDO.setName(vo.getFloor()); comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); - comMngBuildingDO.setStreetId(comMngBuildingDO.getStreetId()); + comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); comMngBuildingDAO.insert(comMngBuildingDO); } } @@ -4833,23 +4900,23 @@ 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("执行数据库导入人口社区关系"); @@ -4858,7 +4925,7 @@ } if (!updatePopulationCommunityList.isEmpty()) { log.info("执行数据库更新人口社区关系"); - comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); + comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); log.info("数据库更新人口社区关系完成"); } log.info("执行数据库导入完成"); @@ -6811,6 +6878,10 @@ 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); }); } -- Gitblit v1.7.1