| | |
| | | private String aesKey; |
| | | @Resource |
| | | private ComActEasyPhotoDAO comActEasyPhotoDAO; |
| | | @Resource |
| | | private ComMngBuildingDAO comMngBuildingDAO; |
| | | |
| | | /** |
| | | * 新增实有人口 |
| | |
| | | } |
| | | } |
| | | log.info("查询实有人口存在社区信息完成"); |
| | | |
| | | log.info("开始处理楼栋信息"); |
| | | List<ComMngBuildingDO> comMngBuildingDOList= comMngBuildingDAO.selectList(new QueryWrapper<ComMngBuildingDO>().lambda().eq(ComMngBuildingDO::getVillageId,comMngVillageDO.getVillageId()).eq(ComMngBuildingDO::getName,vo.getFloor())); |
| | | if(comMngBuildingDOList.isEmpty()){ |
| | | ComMngBuildingDO comMngBuildingDO=new ComMngBuildingDO(); |
| | | comMngBuildingDO.setId(Snowflake.getId()); |
| | | comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); |
| | | comMngBuildingDO.setName(vo.getFloor()); |
| | | comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); |
| | | comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); |
| | | comMngBuildingDAO.insert(comMngBuildingDO); |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | log.info("出现错误,错误原因:" + e.getMessage()); |
| | |
| | | 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)); |
| | |
| | | mistakes.add(mistake); |
| | | } |
| | | } |
| | | |
| | | log.info("查询实有人口存在社区信息完成"); |
| | | |
| | | log.info("开始处理楼栋信息"); |
| | | List<ComMngBuildingDO> comMngBuildingDOList= comMngBuildingDAO.selectList(new QueryWrapper<ComMngBuildingDO>().lambda().eq(ComMngBuildingDO::getVillageId,comMngVillageDO.getVillageId()).eq(ComMngBuildingDO::getName,vo.getFloor())); |
| | | if(comMngBuildingDOList.isEmpty()){ |
| | | ComMngBuildingDO comMngBuildingDO=new ComMngBuildingDO(); |
| | | comMngBuildingDO.setId(Snowflake.getId()); |
| | | comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); |
| | | comMngBuildingDO.setName(vo.getFloor()); |
| | | comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); |
| | | comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); |
| | | comMngBuildingDAO.insert(comMngBuildingDO); |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | log.info("出现错误,错误原因:" + e.getMessage()); |
| | |
| | | if (!houseList.isEmpty()) { |
| | | log.info("执行数据库导入房屋"); |
| | | comMngPopulationHouseDAO.insertAll(houseList); |
| | | log.info("执行数据库导入房屋完成"); |
| | | log.info("数据库导入房屋完成"); |
| | | } |
| | | if (!saveList.isEmpty()) { |
| | | log.info("执行数据库导入人口"); |
| | | this.baseMapper.insertAll(saveList); |
| | | log.info("执行数据库导入人口完成"); |
| | | log.info("数据库导入人口完成"); |
| | | } |
| | | if (!updateList.isEmpty()) { |
| | | log.info("执行数据库更新人口"); |
| | | this.baseMapper.updateAll(updateList); |
| | | this.updateBatchById(updateList); |
| | | // this.updateBatchById(updateList); |
| | | log.info("执行数据库更新人口完成"); |
| | | log.info("数据库更新人口完成"); |
| | | } |
| | | if (!houseUserList.isEmpty()) { |
| | | log.info("执行数据库导入人口房屋关系"); |
| | | comMngPopulationHouseUserService.saveBatch(houseUserList); |
| | | log.info("执行数据库导入人口房屋关系完成"); |
| | | log.info("数据库导入人口房屋关系完成"); |
| | | } |
| | | if (!savePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库导入人口社区关系"); |
| | |
| | | } |
| | | if (!updatePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库更新人口社区关系"); |
| | | comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); |
| | | comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); |
| | | log.info("数据库更新人口社区关系完成"); |
| | | } |
| | | log.info("执行数据库导入完成"); |
| | |
| | | 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)); |
| | |
| | | mistakes.add(mistake); |
| | | } |
| | | } |
| | | |
| | | log.info("查询实有人口存在社区信息完成"); |
| | | |
| | | log.info("开始处理楼栋信息"); |
| | | List<ComMngBuildingDO> comMngBuildingDOList= comMngBuildingDAO.selectList(new QueryWrapper<ComMngBuildingDO>().lambda().eq(ComMngBuildingDO::getVillageId,comMngVillageDO.getVillageId()).eq(ComMngBuildingDO::getName,vo.getFloor())); |
| | | if(comMngBuildingDOList.isEmpty()){ |
| | | ComMngBuildingDO comMngBuildingDO=new ComMngBuildingDO(); |
| | | comMngBuildingDO.setId(Snowflake.getId()); |
| | | comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); |
| | | comMngBuildingDO.setName(vo.getFloor()); |
| | | comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); |
| | | comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); |
| | | comMngBuildingDAO.insert(comMngBuildingDO); |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | log.info("出现错误,错误原因:" + e.getMessage()); |
| | |
| | | if (!houseList.isEmpty()) { |
| | | log.info("执行数据库导入房屋"); |
| | | comMngPopulationHouseDAO.insertAll(houseList); |
| | | log.info("执行数据库导入房屋完成"); |
| | | log.info("数据库导入房屋完成"); |
| | | } |
| | | if (!saveList.isEmpty()) { |
| | | log.info("执行数据库导入人口"); |
| | | this.baseMapper.insertAll(saveList); |
| | | log.info("执行数据库导入人口完成"); |
| | | log.info("数据库导入人口完成"); |
| | | } |
| | | if (!updateList.isEmpty()) { |
| | | log.info("执行数据库更新人口"); |
| | | this.baseMapper.updateAll(updateList); |
| | | this.updateBatchById(updateList); |
| | | // this.updateBatchById(updateList); |
| | | log.info("执行数据库更新人口完成"); |
| | | log.info("数据库更新人口完成"); |
| | | } |
| | | if (!houseUserList.isEmpty()) { |
| | | log.info("执行数据库导入人口房屋关系"); |
| | | comMngPopulationHouseUserService.saveBatch(houseUserList); |
| | | log.info("执行数据库导入人口房屋关系完成"); |
| | | log.info("数据库导入人口房屋关系完成"); |
| | | } |
| | | if (!savePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库导入人口社区关系"); |
| | |
| | | } |
| | | if (!updatePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库更新人口社区关系"); |
| | | comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); |
| | | comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); |
| | | log.info("数据库更新人口社区关系完成"); |
| | | } |
| | | log.info("执行数据库导入完成"); |
| | |
| | | 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)); |
| | |
| | | mistakes.add(mistake); |
| | | } |
| | | } |
| | | |
| | | log.info("查询实有人口存在社区信息完成"); |
| | | |
| | | log.info("开始处理楼栋信息"); |
| | | List<ComMngBuildingDO> comMngBuildingDOList= comMngBuildingDAO.selectList(new QueryWrapper<ComMngBuildingDO>().lambda().eq(ComMngBuildingDO::getVillageId,comMngVillageDO.getVillageId()).eq(ComMngBuildingDO::getName,vo.getFloor())); |
| | | if(comMngBuildingDOList.isEmpty()){ |
| | | ComMngBuildingDO comMngBuildingDO=new ComMngBuildingDO(); |
| | | comMngBuildingDO.setId(Snowflake.getId()); |
| | | comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); |
| | | comMngBuildingDO.setName(vo.getFloor()); |
| | | comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); |
| | | comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); |
| | | comMngBuildingDAO.insert(comMngBuildingDO); |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | log.info("出现错误,错误原因:" + e.getMessage()); |
| | |
| | | if (!houseList.isEmpty()) { |
| | | log.info("执行数据库导入房屋"); |
| | | comMngPopulationHouseDAO.insertAll(houseList); |
| | | log.info("执行数据库导入房屋完成"); |
| | | log.info("数据库导入房屋完成"); |
| | | } |
| | | if (!saveList.isEmpty()) { |
| | | log.info("执行数据库导入人口"); |
| | | this.baseMapper.insertAll(saveList); |
| | | log.info("执行数据库导入人口完成"); |
| | | log.info("数据库导入人口完成"); |
| | | } |
| | | if (!updateList.isEmpty()) { |
| | | log.info("执行数据库更新人口"); |
| | | this.baseMapper.updateAll(updateList); |
| | | this.updateBatchById(updateList); |
| | | // this.updateBatchById(updateList); |
| | | log.info("执行数据库更新人口完成"); |
| | | log.info("数据库更新人口完成"); |
| | | } |
| | | if (!houseUserList.isEmpty()) { |
| | | log.info("执行数据库导入人口房屋关系"); |
| | | comMngPopulationHouseUserService.saveBatch(houseUserList); |
| | | log.info("执行数据库导入人口房屋关系完成"); |
| | | log.info("数据库导入人口房屋关系完成"); |
| | | } |
| | | if (!savePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库导入人口社区关系"); |
| | |
| | | } |
| | | if (!updatePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库更新人口社区关系"); |
| | | comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); |
| | | comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); |
| | | log.info("数据库更新人口社区关系完成"); |
| | | } |
| | | log.info("执行数据库导入完成"); |
| | |
| | | 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)); |
| | |
| | | mistakes.add(mistake); |
| | | } |
| | | } |
| | | |
| | | log.info("查询实有人口存在社区信息完成"); |
| | | |
| | | log.info("开始处理楼栋信息"); |
| | | List<ComMngBuildingDO> comMngBuildingDOList= comMngBuildingDAO.selectList(new QueryWrapper<ComMngBuildingDO>().lambda().eq(ComMngBuildingDO::getVillageId,comMngVillageDO.getVillageId()).eq(ComMngBuildingDO::getName,vo.getFloor())); |
| | | if(comMngBuildingDOList.isEmpty()){ |
| | | ComMngBuildingDO comMngBuildingDO=new ComMngBuildingDO(); |
| | | comMngBuildingDO.setId(Snowflake.getId()); |
| | | comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); |
| | | comMngBuildingDO.setName(vo.getFloor()); |
| | | comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); |
| | | comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); |
| | | comMngBuildingDAO.insert(comMngBuildingDO); |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | log.info("出现错误,错误原因:" + e.getMessage()); |
| | |
| | | if (!houseList.isEmpty()) { |
| | | log.info("执行数据库导入房屋"); |
| | | comMngPopulationHouseDAO.insertAll(houseList); |
| | | log.info("执行数据库导入房屋完成"); |
| | | log.info("数据库导入房屋完成"); |
| | | } |
| | | if (!saveList.isEmpty()) { |
| | | log.info("执行数据库导入人口"); |
| | | this.baseMapper.insertAll(saveList); |
| | | log.info("执行数据库导入人口完成"); |
| | | log.info("数据库导入人口完成"); |
| | | } |
| | | if (!updateList.isEmpty()) { |
| | | log.info("执行数据库更新人口"); |
| | | this.baseMapper.updateAll(updateList); |
| | | this.updateBatchById(updateList); |
| | | // this.updateBatchById(updateList); |
| | | log.info("执行数据库更新人口完成"); |
| | | log.info("数据库更新人口完成"); |
| | | } |
| | | if (!houseUserList.isEmpty()) { |
| | | log.info("执行数据库导入人口房屋关系"); |
| | | comMngPopulationHouseUserService.saveBatch(houseUserList); |
| | | log.info("执行数据库导入人口房屋关系完成"); |
| | | log.info("数据库导入人口房屋关系完成"); |
| | | } |
| | | if (!savePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库导入人口社区关系"); |
| | |
| | | } |
| | | if (!updatePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库更新人口社区关系"); |
| | | comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); |
| | | comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); |
| | | log.info("数据库更新人口社区关系完成"); |
| | | } |
| | | log.info("执行数据库导入完成"); |
| | |
| | | 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)); |
| | |
| | | mistakes.add(mistake); |
| | | } |
| | | } |
| | | |
| | | log.info("查询实有人口存在社区信息完成"); |
| | | |
| | | log.info("开始处理楼栋信息"); |
| | | List<ComMngBuildingDO> comMngBuildingDOList= comMngBuildingDAO.selectList(new QueryWrapper<ComMngBuildingDO>().lambda().eq(ComMngBuildingDO::getVillageId,comMngVillageDO.getVillageId()).eq(ComMngBuildingDO::getName,vo.getFloor())); |
| | | if(comMngBuildingDOList.isEmpty()){ |
| | | ComMngBuildingDO comMngBuildingDO=new ComMngBuildingDO(); |
| | | comMngBuildingDO.setId(Snowflake.getId()); |
| | | comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); |
| | | comMngBuildingDO.setName(vo.getFloor()); |
| | | comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); |
| | | comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); |
| | | comMngBuildingDAO.insert(comMngBuildingDO); |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | log.info("出现错误,错误原因:" + e.getMessage()); |
| | |
| | | if (!houseList.isEmpty()) { |
| | | log.info("执行数据库导入房屋"); |
| | | comMngPopulationHouseDAO.insertAll(houseList); |
| | | log.info("执行数据库导入房屋完成"); |
| | | log.info("数据库导入房屋完成"); |
| | | } |
| | | if (!saveList.isEmpty()) { |
| | | log.info("执行数据库导入人口"); |
| | | this.baseMapper.insertAll(saveList); |
| | | log.info("执行数据库导入人口完成"); |
| | | log.info("数据库导入人口完成"); |
| | | } |
| | | if (!updateList.isEmpty()) { |
| | | log.info("执行数据库更新人口"); |
| | | this.baseMapper.updateAll(updateList); |
| | | this.updateBatchById(updateList); |
| | | // this.updateBatchById(updateList); |
| | | log.info("执行数据库更新人口完成"); |
| | | log.info("数据库更新人口完成"); |
| | | } |
| | | if (!houseUserList.isEmpty()) { |
| | | log.info("执行数据库导入人口房屋关系"); |
| | | comMngPopulationHouseUserService.saveBatch(houseUserList); |
| | | log.info("执行数据库导入人口房屋关系完成"); |
| | | log.info("数据库导入人口房屋关系完成"); |
| | | } |
| | | if (!savePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库导入人口社区关系"); |
| | |
| | | } |
| | | if (!updatePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库更新人口社区关系"); |
| | | comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); |
| | | comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); |
| | | log.info("数据库更新人口社区关系完成"); |
| | | } |
| | | log.info("执行数据库导入完成"); |
| | |
| | | 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)); |
| | |
| | | mistakes.add(mistake); |
| | | } |
| | | } |
| | | |
| | | log.info("查询实有人口存在社区信息完成"); |
| | | |
| | | log.info("开始处理楼栋信息"); |
| | | List<ComMngBuildingDO> comMngBuildingDOList= comMngBuildingDAO.selectList(new QueryWrapper<ComMngBuildingDO>().lambda().eq(ComMngBuildingDO::getVillageId,comMngVillageDO.getVillageId()).eq(ComMngBuildingDO::getName,vo.getFloor())); |
| | | if(comMngBuildingDOList.isEmpty()){ |
| | | ComMngBuildingDO comMngBuildingDO=new ComMngBuildingDO(); |
| | | comMngBuildingDO.setId(Snowflake.getId()); |
| | | comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); |
| | | comMngBuildingDO.setName(vo.getFloor()); |
| | | comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); |
| | | comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); |
| | | comMngBuildingDAO.insert(comMngBuildingDO); |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | log.info("出现错误,错误原因:" + e.getMessage()); |
| | |
| | | if (!houseList.isEmpty()) { |
| | | log.info("执行数据库导入房屋"); |
| | | comMngPopulationHouseDAO.insertAll(houseList); |
| | | log.info("执行数据库导入房屋完成"); |
| | | log.info("数据库导入房屋完成"); |
| | | } |
| | | if (!saveList.isEmpty()) { |
| | | log.info("执行数据库导入人口"); |
| | | this.baseMapper.insertAll(saveList); |
| | | log.info("执行数据库导入人口完成"); |
| | | log.info("数据库导入人口完成"); |
| | | } |
| | | if (!updateList.isEmpty()) { |
| | | log.info("执行数据库更新人口"); |
| | | this.baseMapper.updateAll(updateList); |
| | | this.updateBatchById(updateList); |
| | | // this.updateBatchById(updateList); |
| | | log.info("执行数据库更新人口完成"); |
| | | log.info("数据库更新人口完成"); |
| | | } |
| | | if (!houseUserList.isEmpty()) { |
| | | log.info("执行数据库导入人口房屋关系"); |
| | | comMngPopulationHouseUserService.saveBatch(houseUserList); |
| | | log.info("执行数据库导入人口房屋关系完成"); |
| | | log.info("数据库导入人口房屋关系完成"); |
| | | } |
| | | if (!savePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库导入人口社区关系"); |
| | |
| | | } |
| | | if (!updatePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库更新人口社区关系"); |
| | | comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); |
| | | comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); |
| | | log.info("数据库更新人口社区关系完成"); |
| | | } |
| | | log.info("执行数据库导入完成"); |
| | |
| | | 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)); |
| | |
| | | mistakes.add(mistake); |
| | | } |
| | | } |
| | | |
| | | log.info("查询实有人口存在社区信息完成"); |
| | | |
| | | log.info("开始处理楼栋信息"); |
| | | List<ComMngBuildingDO> comMngBuildingDOList= comMngBuildingDAO.selectList(new QueryWrapper<ComMngBuildingDO>().lambda().eq(ComMngBuildingDO::getVillageId,comMngVillageDO.getVillageId()).eq(ComMngBuildingDO::getName,vo.getFloor())); |
| | | if(comMngBuildingDOList.isEmpty()){ |
| | | ComMngBuildingDO comMngBuildingDO=new ComMngBuildingDO(); |
| | | comMngBuildingDO.setId(Snowflake.getId()); |
| | | comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); |
| | | comMngBuildingDO.setName(vo.getFloor()); |
| | | comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); |
| | | comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); |
| | | comMngBuildingDAO.insert(comMngBuildingDO); |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | log.info("出现错误,错误原因:" + e.getMessage()); |
| | |
| | | if (!houseList.isEmpty()) { |
| | | log.info("执行数据库导入房屋"); |
| | | comMngPopulationHouseDAO.insertAll(houseList); |
| | | log.info("执行数据库导入房屋完成"); |
| | | log.info("数据库导入房屋完成"); |
| | | } |
| | | if (!saveList.isEmpty()) { |
| | | log.info("执行数据库导入人口"); |
| | | this.baseMapper.insertAll(saveList); |
| | | log.info("执行数据库导入人口完成"); |
| | | log.info("数据库导入人口完成"); |
| | | } |
| | | if (!updateList.isEmpty()) { |
| | | log.info("执行数据库更新人口"); |
| | | this.baseMapper.updateAll(updateList); |
| | | this.updateBatchById(updateList); |
| | | // this.updateBatchById(updateList); |
| | | log.info("执行数据库更新人口完成"); |
| | | log.info("数据库更新人口完成"); |
| | | } |
| | | if (!houseUserList.isEmpty()) { |
| | | log.info("执行数据库导入人口房屋关系"); |
| | | comMngPopulationHouseUserService.saveBatch(houseUserList); |
| | | log.info("执行数据库导入人口房屋关系完成"); |
| | | log.info("数据库导入人口房屋关系完成"); |
| | | } |
| | | if (!savePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库导入人口社区关系"); |
| | |
| | | } |
| | | if (!updatePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库更新人口社区关系"); |
| | | comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); |
| | | comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); |
| | | log.info("数据库更新人口社区关系完成"); |
| | | } |
| | | log.info("执行数据库导入完成"); |
| | |
| | | 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)); |
| | |
| | | mistakes.add(mistake); |
| | | } |
| | | } |
| | | |
| | | log.info("查询实有人口存在社区信息完成"); |
| | | |
| | | log.info("开始处理楼栋信息"); |
| | | List<ComMngBuildingDO> comMngBuildingDOList= comMngBuildingDAO.selectList(new QueryWrapper<ComMngBuildingDO>().lambda().eq(ComMngBuildingDO::getVillageId,comMngVillageDO.getVillageId()).eq(ComMngBuildingDO::getName,vo.getFloor())); |
| | | if(comMngBuildingDOList.isEmpty()){ |
| | | ComMngBuildingDO comMngBuildingDO=new ComMngBuildingDO(); |
| | | comMngBuildingDO.setId(Snowflake.getId()); |
| | | comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); |
| | | comMngBuildingDO.setName(vo.getFloor()); |
| | | comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); |
| | | comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); |
| | | comMngBuildingDAO.insert(comMngBuildingDO); |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | log.info("出现错误,错误原因:" + e.getMessage()); |
| | |
| | | if (!houseList.isEmpty()) { |
| | | log.info("执行数据库导入房屋"); |
| | | comMngPopulationHouseDAO.insertAll(houseList); |
| | | log.info("执行数据库导入房屋完成"); |
| | | log.info("数据库导入房屋完成"); |
| | | } |
| | | if (!saveList.isEmpty()) { |
| | | log.info("执行数据库导入人口"); |
| | | this.baseMapper.insertAll(saveList); |
| | | log.info("执行数据库导入人口完成"); |
| | | log.info("数据库导入人口完成"); |
| | | } |
| | | if (!updateList.isEmpty()) { |
| | | log.info("执行数据库更新人口"); |
| | | this.baseMapper.updateAll(updateList); |
| | | this.updateBatchById(updateList); |
| | | // this.updateBatchById(updateList); |
| | | log.info("执行数据库更新人口完成"); |
| | | log.info("数据库更新人口完成"); |
| | | } |
| | | if (!houseUserList.isEmpty()) { |
| | | log.info("执行数据库导入人口房屋关系"); |
| | | comMngPopulationHouseUserService.saveBatch(houseUserList); |
| | | log.info("执行数据库导入人口房屋关系完成"); |
| | | log.info("数据库导入人口房屋关系完成"); |
| | | } |
| | | if (!savePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库导入人口社区关系"); |
| | |
| | | } |
| | | if (!updatePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库更新人口社区关系"); |
| | | comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); |
| | | comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); |
| | | log.info("数据库更新人口社区关系完成"); |
| | | } |
| | | log.info("执行数据库导入完成"); |
| | |
| | | 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)); |
| | |
| | | mistakes.add(mistake); |
| | | } |
| | | } |
| | | |
| | | log.info("查询实有人口存在社区信息完成"); |
| | | |
| | | log.info("开始处理楼栋信息"); |
| | | List<ComMngBuildingDO> comMngBuildingDOList= comMngBuildingDAO.selectList(new QueryWrapper<ComMngBuildingDO>().lambda().eq(ComMngBuildingDO::getVillageId,comMngVillageDO.getVillageId()).eq(ComMngBuildingDO::getName,vo.getFloor())); |
| | | if(comMngBuildingDOList.isEmpty()){ |
| | | ComMngBuildingDO comMngBuildingDO=new ComMngBuildingDO(); |
| | | comMngBuildingDO.setId(Snowflake.getId()); |
| | | comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); |
| | | comMngBuildingDO.setName(vo.getFloor()); |
| | | comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); |
| | | comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); |
| | | comMngBuildingDAO.insert(comMngBuildingDO); |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | log.info("出现错误,错误原因:" + e.getMessage()); |
| | |
| | | if (!houseList.isEmpty()) { |
| | | log.info("执行数据库导入房屋"); |
| | | comMngPopulationHouseDAO.insertAll(houseList); |
| | | log.info("执行数据库导入房屋完成"); |
| | | log.info("数据库导入房屋完成"); |
| | | } |
| | | if (!saveList.isEmpty()) { |
| | | log.info("执行数据库导入人口"); |
| | | this.baseMapper.insertAll(saveList); |
| | | log.info("执行数据库导入人口完成"); |
| | | log.info("数据库导入人口完成"); |
| | | } |
| | | if (!updateList.isEmpty()) { |
| | | log.info("执行数据库更新人口"); |
| | | this.baseMapper.updateAll(updateList); |
| | | this.updateBatchById(updateList); |
| | | // this.updateBatchById(updateList); |
| | | log.info("执行数据库更新人口完成"); |
| | | log.info("数据库更新人口完成"); |
| | | } |
| | | if (!houseUserList.isEmpty()) { |
| | | log.info("执行数据库导入人口房屋关系"); |
| | | comMngPopulationHouseUserService.saveBatch(houseUserList); |
| | | log.info("执行数据库导入人口房屋关系完成"); |
| | | log.info("数据库导入人口房屋关系完成"); |
| | | } |
| | | if (!savePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库导入人口社区关系"); |
| | |
| | | } |
| | | if (!updatePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库更新人口社区关系"); |
| | | comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); |
| | | comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); |
| | | log.info("数据库更新人口社区关系完成"); |
| | | } |
| | | log.info("执行数据库导入完成"); |
| | |
| | | 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)); |
| | |
| | | mistakes.add(mistake); |
| | | } |
| | | } |
| | | |
| | | log.info("查询实有人口存在社区信息完成"); |
| | | |
| | | log.info("开始处理楼栋信息"); |
| | | List<ComMngBuildingDO> comMngBuildingDOList= comMngBuildingDAO.selectList(new QueryWrapper<ComMngBuildingDO>().lambda().eq(ComMngBuildingDO::getVillageId,comMngVillageDO.getVillageId()).eq(ComMngBuildingDO::getName,vo.getFloor())); |
| | | if(comMngBuildingDOList.isEmpty()){ |
| | | ComMngBuildingDO comMngBuildingDO=new ComMngBuildingDO(); |
| | | comMngBuildingDO.setId(Snowflake.getId()); |
| | | comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); |
| | | comMngBuildingDO.setName(vo.getFloor()); |
| | | comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); |
| | | comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); |
| | | comMngBuildingDAO.insert(comMngBuildingDO); |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | log.info("出现错误,错误原因:" + e.getMessage()); |
| | |
| | | if (!houseList.isEmpty()) { |
| | | log.info("执行数据库导入房屋"); |
| | | comMngPopulationHouseDAO.insertAll(houseList); |
| | | log.info("执行数据库导入房屋完成"); |
| | | log.info("数据库导入房屋完成"); |
| | | } |
| | | if (!saveList.isEmpty()) { |
| | | log.info("执行数据库导入人口"); |
| | | this.baseMapper.insertAll(saveList); |
| | | log.info("执行数据库导入人口完成"); |
| | | log.info("数据库导入人口完成"); |
| | | } |
| | | if (!updateList.isEmpty()) { |
| | | log.info("执行数据库更新人口"); |
| | | this.baseMapper.updateAll(updateList); |
| | | this.updateBatchById(updateList); |
| | | // this.updateBatchById(updateList); |
| | | log.info("执行数据库更新人口完成"); |
| | | log.info("数据库更新人口完成"); |
| | | } |
| | | if (!houseUserList.isEmpty()) { |
| | | log.info("执行数据库导入人口房屋关系"); |
| | | comMngPopulationHouseUserService.saveBatch(houseUserList); |
| | | log.info("执行数据库导入人口房屋关系完成"); |
| | | log.info("数据库导入人口房屋关系完成"); |
| | | } |
| | | if (!savePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库导入人口社区关系"); |
| | |
| | | } |
| | | if (!updatePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库更新人口社区关系"); |
| | | comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); |
| | | comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); |
| | | log.info("数据库更新人口社区关系完成"); |
| | | } |
| | | log.info("执行数据库导入完成"); |
| | |
| | | iterator.remove(); |
| | | } |
| | | } |
| | | if(userTag != null && userTag.size() > 0){ |
| | | comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel() + "," + Joiner.on(",").join(userTag)); |
| | | if(StringUtils.isNotEmpty(comMngPopulationCommunityTagsDO.getLabel())){ |
| | | for(String tag:userTag){ |
| | | if(!comMngPopulationCommunityTagsDO.getLabel().contains(tag)){ |
| | | comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel()+","+tag); |
| | | } |
| | | } |
| | | } |
| | | else{ |
| | | comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); |
| | | } |
| | | comMngPopulationCommunityTagsDO.setUpdateBy(userId); |
| | | updatePopulationCommunityList.add(comMngPopulationCommunityTagsDO); |
| | |
| | | mistakes.add(mistake); |
| | | } |
| | | } |
| | | |
| | | log.info("查询实有人口存在社区信息完成"); |
| | | |
| | | log.info("开始处理楼栋信息"); |
| | | List<ComMngBuildingDO> comMngBuildingDOList= comMngBuildingDAO.selectList(new QueryWrapper<ComMngBuildingDO>().lambda().eq(ComMngBuildingDO::getVillageId,comMngVillageDO.getVillageId()).eq(ComMngBuildingDO::getName,vo.getFloor())); |
| | | if(comMngBuildingDOList.isEmpty()){ |
| | | ComMngBuildingDO comMngBuildingDO=new ComMngBuildingDO(); |
| | | comMngBuildingDO.setId(Snowflake.getId()); |
| | | comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); |
| | | comMngBuildingDO.setName(vo.getFloor()); |
| | | comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); |
| | | comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); |
| | | comMngBuildingDAO.insert(comMngBuildingDO); |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | log.info("出现错误,错误原因:" + e.getMessage()); |
| | |
| | | if (!houseList.isEmpty()) { |
| | | log.info("执行数据库导入房屋"); |
| | | comMngPopulationHouseDAO.insertAll(houseList); |
| | | log.info("执行数据库导入房屋完成"); |
| | | log.info("数据库导入房屋完成"); |
| | | } |
| | | if (!saveList.isEmpty()) { |
| | | log.info("执行数据库导入人口"); |
| | | this.baseMapper.insertAll(saveList); |
| | | log.info("执行数据库导入人口完成"); |
| | | log.info("数据库导入人口完成"); |
| | | } |
| | | if (!updateList.isEmpty()) { |
| | | log.info("执行数据库更新人口"); |
| | | this.baseMapper.updateAll(updateList); |
| | | this.updateBatchById(updateList); |
| | | // this.updateBatchById(updateList); |
| | | log.info("执行数据库更新人口完成"); |
| | | log.info("数据库更新人口完成"); |
| | | } |
| | | if (!houseUserList.isEmpty()) { |
| | | log.info("执行数据库导入人口房屋关系"); |
| | | comMngPopulationHouseUserService.saveBatch(houseUserList); |
| | | log.info("执行数据库导入人口房屋关系完成"); |
| | | log.info("数据库导入人口房屋关系完成"); |
| | | } |
| | | if (!savePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库导入人口社区关系"); |
| | |
| | | } |
| | | if (!updatePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库更新人口社区关系"); |
| | | comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); |
| | | comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); |
| | | log.info("数据库更新人口社区关系完成"); |
| | | } |
| | | log.info("执行数据库导入完成"); |
| | |
| | | iterator.remove(); |
| | | } |
| | | } |
| | | if(userTag != null && userTag.size() > 0){ |
| | | comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel() + "," + Joiner.on(",").join(userTag)); |
| | | if(StringUtils.isNotEmpty(comMngPopulationCommunityTagsDO.getLabel())){ |
| | | for(String tag:userTag){ |
| | | if(!comMngPopulationCommunityTagsDO.getLabel().contains(tag)){ |
| | | comMngPopulationCommunityTagsDO.setLabel(comMngPopulationCommunityTagsDO.getLabel()+","+tag); |
| | | } |
| | | } |
| | | } |
| | | else{ |
| | | comMngPopulationCommunityTagsDO.setLabel(Joiner.on(",").join(userTag)); |
| | | } |
| | | comMngPopulationCommunityTagsDO.setUpdateBy(userId); |
| | | updatePopulationCommunityList.add(comMngPopulationCommunityTagsDO); |
| | |
| | | mistakes.add(mistake); |
| | | } |
| | | } |
| | | |
| | | log.info("查询实有人口存在社区信息完成"); |
| | | |
| | | log.info("开始处理楼栋信息"); |
| | | List<ComMngBuildingDO> comMngBuildingDOList= comMngBuildingDAO.selectList(new QueryWrapper<ComMngBuildingDO>().lambda().eq(ComMngBuildingDO::getVillageId,comMngVillageDO.getVillageId()).eq(ComMngBuildingDO::getName,vo.getFloor())); |
| | | if(comMngBuildingDOList.isEmpty()){ |
| | | ComMngBuildingDO comMngBuildingDO=new ComMngBuildingDO(); |
| | | comMngBuildingDO.setId(Snowflake.getId()); |
| | | comMngBuildingDO.setVillageId(comMngVillageDO.getVillageId()); |
| | | comMngBuildingDO.setName(vo.getFloor()); |
| | | comMngBuildingDO.setActId(comMngVillageDO.getCommunityId()); |
| | | comMngBuildingDO.setStreetId(comMngVillageDO.getStreetId()); |
| | | comMngBuildingDAO.insert(comMngBuildingDO); |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | log.info("出现错误,错误原因:" + e.getMessage()); |
| | |
| | | if (!houseList.isEmpty()) { |
| | | log.info("执行数据库导入房屋"); |
| | | comMngPopulationHouseDAO.insertAll(houseList); |
| | | log.info("执行数据库导入房屋完成"); |
| | | log.info("数据库导入房屋完成"); |
| | | } |
| | | if (!saveList.isEmpty()) { |
| | | log.info("执行数据库导入人口"); |
| | | this.baseMapper.insertAll(saveList); |
| | | log.info("执行数据库导入人口完成"); |
| | | log.info("数据库导入人口完成"); |
| | | } |
| | | if (!updateList.isEmpty()) { |
| | | log.info("执行数据库更新人口"); |
| | | this.baseMapper.updateAll(updateList); |
| | | this.updateBatchById(updateList); |
| | | // this.updateBatchById(updateList); |
| | | log.info("执行数据库更新人口完成"); |
| | | log.info("数据库更新人口完成"); |
| | | } |
| | | if (!houseUserList.isEmpty()) { |
| | | log.info("执行数据库导入人口房屋关系"); |
| | | comMngPopulationHouseUserService.saveBatch(houseUserList); |
| | | log.info("执行数据库导入人口房屋关系完成"); |
| | | log.info("数据库导入人口房屋关系完成"); |
| | | } |
| | | if (!savePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库导入人口社区关系"); |
| | |
| | | } |
| | | if (!updatePopulationCommunityList.isEmpty()) { |
| | | log.info("执行数据库更新人口社区关系"); |
| | | comMngPopulationCommunityTagsDAO.updateAll(updatePopulationCommunityList); |
| | | comMngPopulationCommunityTagsService.updateBatchById(updatePopulationCommunityList); |
| | | log.info("数据库更新人口社区关系完成"); |
| | | } |
| | | log.info("执行数据库导入完成"); |
| | |
| | | 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); |
| | | }); |
| | | } |