From bfe7b653a9d376b31699ef5eef34a8817546f84c Mon Sep 17 00:00:00 2001 From: 101captain <237651143@qq.com> Date: 星期五, 27 五月 2022 17:20:47 +0800 Subject: [PATCH] bug修改 --- springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComMngPopulationServiceImpl.java | 226 +++++++++++++++++++++++++++++++++++--------------------- 1 files changed, 140 insertions(+), 86 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 01b6c44..df919f7 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 @@ -1246,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)); @@ -1285,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("执行数据库导入人口社区关系"); @@ -1310,7 +1314,7 @@ } if (!updatePopulationCommunityList.isEmpty()) { log.info("执行数据库更新人口社区关系"); - comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); + comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); log.info("数据库更新人口社区关系完成"); } log.info("执行数据库导入完成"); @@ -1570,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)); @@ -1609,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("执行数据库导入人口社区关系"); @@ -1634,7 +1642,7 @@ } if (!updatePopulationCommunityList.isEmpty()) { log.info("执行数据库更新人口社区关系"); - comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); + comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); log.info("数据库更新人口社区关系完成"); } log.info("执行数据库导入完成"); @@ -1894,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)); @@ -1933,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("执行数据库导入人口社区关系"); @@ -1958,7 +1970,7 @@ } if (!updatePopulationCommunityList.isEmpty()) { log.info("执行数据库更新人口社区关系"); - comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); + comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); log.info("数据库更新人口社区关系完成"); } log.info("执行数据库导入完成"); @@ -2218,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)); @@ -2257,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("执行数据库导入人口社区关系"); @@ -2282,7 +2298,7 @@ } if (!updatePopulationCommunityList.isEmpty()) { log.info("执行数据库更新人口社区关系"); - comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); + comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); log.info("数据库更新人口社区关系完成"); } log.info("执行数据库导入完成"); @@ -2543,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)); @@ -2583,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("执行数据库导入人口社区关系"); @@ -2608,7 +2628,7 @@ } if (!updatePopulationCommunityList.isEmpty()) { log.info("执行数据库更新人口社区关系"); - comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); + comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); log.info("数据库更新人口社区关系完成"); } log.info("执行数据库导入完成"); @@ -2867,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)); @@ -2906,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("执行数据库导入人口社区关系"); @@ -2931,7 +2955,7 @@ } if (!updatePopulationCommunityList.isEmpty()) { log.info("执行数据库更新人口社区关系"); - comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); + comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); log.info("数据库更新人口社区关系完成"); } log.info("执行数据库导入完成"); @@ -3190,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)); @@ -3229,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("执行数据库导入人口社区关系"); @@ -3254,7 +3282,7 @@ } if (!updatePopulationCommunityList.isEmpty()) { log.info("执行数据库更新人口社区关系"); - comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); + comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); log.info("数据库更新人口社区关系完成"); } log.info("执行数据库导入完成"); @@ -3513,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)); @@ -3552,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("执行数据库导入人口社区关系"); @@ -3577,7 +3609,7 @@ } if (!updatePopulationCommunityList.isEmpty()) { log.info("执行数据库更新人口社区关系"); - comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); + comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); log.info("数据库更新人口社区关系完成"); } log.info("执行数据库导入完成"); @@ -3836,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)); @@ -3875,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("执行数据库导入人口社区关系"); @@ -3900,7 +3936,7 @@ } if (!updatePopulationCommunityList.isEmpty()) { log.info("执行数据库更新人口社区关系"); - comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); + comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); log.info("数据库更新人口社区关系完成"); } log.info("执行数据库导入完成"); @@ -4164,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)); @@ -4203,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("执行数据库导入人口社区关系"); @@ -4228,7 +4268,7 @@ } if (!updatePopulationCommunityList.isEmpty()) { log.info("执行数据库更新人口社区关系"); - comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); + comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); log.info("数据库更新人口社区关系完成"); } log.info("执行数据库导入完成"); @@ -4488,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); @@ -4525,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("执行数据库导入人口社区关系"); @@ -4550,7 +4597,7 @@ } if (!updatePopulationCommunityList.isEmpty()) { log.info("执行数据库更新人口社区关系"); - comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); + comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); log.info("数据库更新人口社区关系完成"); } log.info("执行数据库导入完成"); @@ -4809,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); @@ -4846,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("执行数据库导入人口社区关系"); @@ -4871,7 +4925,7 @@ } if (!updatePopulationCommunityList.isEmpty()) { log.info("执行数据库更新人口社区关系"); - comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); + comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); log.info("数据库更新人口社区关系完成"); } log.info("执行数据库导入完成"); -- Gitblit v1.7.1