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