|
|
|
@ -53,10 +53,7 @@ import org.springframework.util.CollectionUtils; |
|
|
|
import javax.annotation.Resource; |
|
|
|
import javax.servlet.http.HttpServletResponse; |
|
|
|
import java.io.InputStream; |
|
|
|
import java.util.ArrayList; |
|
|
|
import java.util.HashMap; |
|
|
|
import java.util.List; |
|
|
|
import java.util.Map; |
|
|
|
import java.util.*; |
|
|
|
import java.util.concurrent.ExecutorService; |
|
|
|
import java.util.stream.Collectors; |
|
|
|
|
|
|
|
@ -320,57 +317,175 @@ public class BuildingServiceImpl implements BuildingService { |
|
|
|
* @return 逐级展开，用户点击树节点去查询 |
|
|
|
*/ |
|
|
|
@Override |
|
|
|
public List<BuildingTreeLevelDTO> treeInit(HouseManageTreeFormDTO formDTO) { |
|
|
|
List<CustomerAgencyEntity> customerAgencyList=new ArrayList<>(); |
|
|
|
// 1.获取所在组织及下级组织
|
|
|
|
CustomerAgencyEntity customerAgency = customerAgencyDao.selectById(formDTO.getStaffAgencyId()); |
|
|
|
customerAgencyList.add(customerAgency); |
|
|
|
// 2、查询直属下级组织
|
|
|
|
List<CustomerAgencyEntity> subAgencyList = icBuildingDao.selectAgencyChildrenList(formDTO.getCustomerId(), null, formDTO.getStaffAgencyId()); |
|
|
|
if (!CollectionUtils.isEmpty(customerAgencyList)) { |
|
|
|
customerAgencyList.addAll(subAgencyList); |
|
|
|
public BuildingTreeLevelDTO treeInit(HouseManageTreeFormDTO formDTO) { |
|
|
|
CustomerStaffInfoCacheResult staffInfoCacheResult=CustomerStaffRedis.getStaffInfo(formDTO.getCustomerId(),formDTO.getStaffId()); |
|
|
|
BuildingTreeLevelDTO resultDto = customerAgencyDao.selectAgencyTree(staffInfoCacheResult.getAgencyId()); |
|
|
|
if (null != resultDto) { |
|
|
|
int showNum = customerAgencyDao.selectTotalNext(staffInfoCacheResult.getAgencyId()); |
|
|
|
resultDto.setShowNum(String.valueOf(showNum)); |
|
|
|
resultDto.setShowName(String.format("%s(%s)", resultDto.getLabel(), showNum)); |
|
|
|
List<BuildingTreeLevelDTO> children = customerAgencyDao.selectNextOrg(staffInfoCacheResult.getAgencyId()); |
|
|
|
for (BuildingTreeLevelDTO dto : children) { |
|
|
|
if ("agency".equals(dto.getOrgType())) { |
|
|
|
dto.setShowNum(String.valueOf(customerAgencyDao.selectTotalNext(dto.getId()))); |
|
|
|
dto.setShowName(String.format("%s(%s)", dto.getLabel(), dto.getShowNum())); |
|
|
|
} else if ("grid".equals(dto.getOrgType())) { |
|
|
|
LambdaQueryWrapper<IcNeighborHoodEntity> queryWrapper = new QueryWrapper<IcNeighborHoodEntity>().lambda() |
|
|
|
.eq(IcNeighborHoodEntity::getGridId, dto.getId()); |
|
|
|
dto.setShowNum(String.valueOf(icNeighborHoodDao.selectCount(queryWrapper))); |
|
|
|
dto.setShowName(String.format("%s(%s)", dto.getLabel(), dto.getShowNum())); |
|
|
|
} |
|
|
|
} |
|
|
|
resultDto.setChildren(children); |
|
|
|
} |
|
|
|
return resultDto; |
|
|
|
} |
|
|
|
|
|
|
|
List<BuildingTreeLevelDTO> resultList = customerAgencyList.stream().map(item -> { |
|
|
|
BuildingTreeLevelDTO buildingTreeLevelDTO = new BuildingTreeLevelDTO(); |
|
|
|
buildingTreeLevelDTO.setId(item.getId()); |
|
|
|
buildingTreeLevelDTO.setPId(item.getPid()); |
|
|
|
buildingTreeLevelDTO.setLabel(item.getOrganizationName()); |
|
|
|
buildingTreeLevelDTO.setLevel(item.getLevel()); |
|
|
|
buildingTreeLevelDTO.setLongitude(item.getLongitude()); |
|
|
|
buildingTreeLevelDTO.setLatitude(item.getLatitude()); |
|
|
|
buildingTreeLevelDTO.setChildren(new ArrayList<>()); |
|
|
|
// 当前组织有几个下级组织
|
|
|
|
buildingTreeLevelDTO.setShowNum(StrConstant.EPMETY_STR); |
|
|
|
return buildingTreeLevelDTO; |
|
|
|
}).collect(Collectors.toList()); |
|
|
|
/** |
|
|
|
* 房屋信息左侧树 |
|
|
|
* 点击树上节点，查询下一级列表 |
|
|
|
* |
|
|
|
* @param formDTO |
|
|
|
* @return |
|
|
|
*/ |
|
|
|
@Override |
|
|
|
public List<BuildingTreeLevelDTO> nextTreeNode(HouseManageTreeFormDTO formDTO) { |
|
|
|
/** |
|
|
|
* level:::: |
|
|
|
* 省级:province |
|
|
|
* 市级: city |
|
|
|
* 区县级: district, |
|
|
|
* 乡（镇、街道）级:street, |
|
|
|
* 社区级：community， |
|
|
|
* 网格：grid |
|
|
|
* 小区：neighborHood |
|
|
|
* 楼栋：building |
|
|
|
*/ |
|
|
|
List<BuildingTreeLevelDTO> resultList = new ArrayList<>(); |
|
|
|
if ("province".equals(formDTO.getLevel()) |
|
|
|
|| "city".equals(formDTO.getLevel()) |
|
|
|
|| "district".equals(formDTO.getLevel()) |
|
|
|
|| "street".equals(formDTO.getLevel())) { |
|
|
|
List<BuildingTreeLevelDTO> list = customerAgencyDao.selectNextOrg(formDTO.getId()); |
|
|
|
for (BuildingTreeLevelDTO dto : list) { |
|
|
|
if ("agency".equals(dto.getOrgType())) { |
|
|
|
dto.setShowNum(String.valueOf(customerAgencyDao.selectTotalNext(dto.getId()))); |
|
|
|
dto.setShowName(String.format("%s(%s)", dto.getLabel(), dto.getShowNum())); |
|
|
|
} else if ("grid".equals(dto.getOrgType())) { |
|
|
|
LambdaQueryWrapper<IcNeighborHoodEntity> queryWrapper = new QueryWrapper<IcNeighborHoodEntity>().lambda() |
|
|
|
.eq(IcNeighborHoodEntity::getGridId, dto.getId()); |
|
|
|
dto.setShowNum(String.valueOf(icNeighborHoodDao.selectCount(queryWrapper))); |
|
|
|
dto.setShowName(String.format("%s(%s)", dto.getLabel(), dto.getShowNum())); |
|
|
|
} |
|
|
|
} |
|
|
|
resultList.addAll(list); |
|
|
|
} else if ("community".equals(formDTO.getLevel())) { |
|
|
|
// 网格列表，需要计算网格下小区数量
|
|
|
|
resultList.addAll(getGridTreeNode(formDTO.getId())); |
|
|
|
} else if ("grid".equals(formDTO.getLevel())) { |
|
|
|
// 小区列表，需要计算小区下楼栋数量
|
|
|
|
resultList.addAll(getNeighborHoodTreeNode(formDTO.getId())); |
|
|
|
} else if ("neighborHood".equals(formDTO.getLevel())) { |
|
|
|
// 楼栋列表，需要计算楼栋下 实有房屋数/楼栋总户数
|
|
|
|
resultList.addAll(getBuildTreeNode(formDTO.getId())); |
|
|
|
} else if ("building".equals(formDTO.getLevel())) { |
|
|
|
// 直接返回
|
|
|
|
return resultList; |
|
|
|
} |
|
|
|
return resultList; |
|
|
|
} |
|
|
|
|
|
|
|
// 3.获取组织下的网格
|
|
|
|
private List<BuildingTreeLevelDTO> getGridTreeNode(String agencyId) { |
|
|
|
List<BuildingTreeLevelDTO> list = new ArrayList<>(); |
|
|
|
LambdaQueryWrapper<CustomerGridEntity> gridWrapper = new LambdaQueryWrapper<>(); |
|
|
|
gridWrapper.eq(CustomerGridEntity::getPid, formDTO.getStaffAgencyId()); |
|
|
|
gridWrapper.eq(CustomerGridEntity::getPid, agencyId); |
|
|
|
gridWrapper.last("ORDER BY sort,CAST(GRID_NAME AS SIGNED),CONVERT(GRID_NAME using gbk)"); |
|
|
|
List<CustomerGridEntity> customerGridList = customerGridDao.selectList(gridWrapper); |
|
|
|
customerGridList.forEach(gridEntity -> { |
|
|
|
BuildingTreeLevelDTO resultDto = new BuildingTreeLevelDTO(); |
|
|
|
resultDto.setId(gridEntity.getId()); |
|
|
|
resultDto.setLabel(gridEntity.getGridName()); |
|
|
|
resultDto.setLevel("grid"); |
|
|
|
resultDto.setPId(gridEntity.getPid()); |
|
|
|
resultDto.setLongitude(gridEntity.getLongitude()); |
|
|
|
resultDto.setLatitude(gridEntity.getLatitude()); |
|
|
|
resultDto.setChildren(new ArrayList<>()); |
|
|
|
// 当前网格下有几个小区
|
|
|
|
LambdaQueryWrapper<IcNeighborHoodEntity> neighborhoodWrapper = new QueryWrapper<IcNeighborHoodEntity>().lambda() |
|
|
|
.eq(IcNeighborHoodEntity::getGridId, resultDto.getId()); |
|
|
|
resultDto.setShowNum(String.valueOf(icNeighborHoodDao.selectCount(neighborhoodWrapper))); |
|
|
|
resultDto.setShowName(String.format("%s(%s)", resultDto.getLabel(), resultDto.getShowNum())); |
|
|
|
list.add(resultDto); |
|
|
|
}); |
|
|
|
return list; |
|
|
|
} |
|
|
|
|
|
|
|
if (CollectionUtils.isEmpty(customerGridList)) { |
|
|
|
return covertToTree(customerAgency, resultList); |
|
|
|
} |
|
|
|
private List<BuildingTreeLevelDTO> getNeighborHoodTreeNode(String gridId) { |
|
|
|
List<BuildingTreeLevelDTO> list = new ArrayList<>(); |
|
|
|
// 当前网格下有几个小区
|
|
|
|
LambdaQueryWrapper<IcNeighborHoodEntity> neighborhoodWrapper = new QueryWrapper<IcNeighborHoodEntity>().lambda() |
|
|
|
.eq(IcNeighborHoodEntity::getGridId, gridId) |
|
|
|
.last("ORDER BY CAST(NEIGHBOR_HOOD_NAME AS SIGNED),CONVERT(NEIGHBOR_HOOD_NAME using gbk)"); |
|
|
|
; |
|
|
|
List<IcNeighborHoodEntity> neighborHoodEntityList = icNeighborHoodDao.selectList(neighborhoodWrapper); |
|
|
|
neighborHoodEntityList.forEach(item -> { |
|
|
|
BuildingTreeLevelDTO neighborHood = new BuildingTreeLevelDTO(); |
|
|
|
neighborHood.setId(item.getId()); |
|
|
|
neighborHood.setPId(item.getGridId()); |
|
|
|
neighborHood.setLabel(item.getNeighborHoodName()); |
|
|
|
neighborHood.setLevel("neighborHood"); |
|
|
|
neighborHood.setLongitude(item.getLongitude()); |
|
|
|
neighborHood.setLatitude(item.getLatitude()); |
|
|
|
neighborHood.setChildren(new ArrayList<>()); |
|
|
|
// 当前小区下，有几栋楼
|
|
|
|
LambdaQueryWrapper<IcBuildingEntity> buildingQueryWrapper = new QueryWrapper<IcBuildingEntity>().lambda() |
|
|
|
.eq(IcBuildingEntity::getNeighborHoodId, neighborHood.getId()); |
|
|
|
neighborHood.setShowNum(String.valueOf(icBuildingDao.selectCount(buildingQueryWrapper))); |
|
|
|
neighborHood.setShowNum(String.format("%s(%s)", neighborHood.getLabel(), neighborHood.getShowNum())); |
|
|
|
list.add(neighborHood); |
|
|
|
}); |
|
|
|
return list; |
|
|
|
} |
|
|
|
|
|
|
|
List<BuildingTreeLevelDTO> gridList = customerGridList.stream().map(item -> { |
|
|
|
BuildingTreeLevelDTO buildingTreeLevelDTO = new BuildingTreeLevelDTO(); |
|
|
|
buildingTreeLevelDTO.setId(item.getId()); |
|
|
|
buildingTreeLevelDTO.setLabel(item.getGridName()); |
|
|
|
buildingTreeLevelDTO.setLevel("grid"); |
|
|
|
buildingTreeLevelDTO.setPId(item.getPid()); |
|
|
|
buildingTreeLevelDTO.setLongitude(item.getLongitude()); |
|
|
|
buildingTreeLevelDTO.setLatitude(item.getLatitude()); |
|
|
|
buildingTreeLevelDTO.setChildren(new ArrayList<>()); |
|
|
|
// 当前网格下有几个小区
|
|
|
|
buildingTreeLevelDTO.setShowNum(StrConstant.EPMETY_STR); |
|
|
|
return buildingTreeLevelDTO; |
|
|
|
}).collect(Collectors.toList()); |
|
|
|
private List<BuildingTreeLevelDTO> getBuildTreeNode(String neighborHoodId) { |
|
|
|
List<BuildingTreeLevelDTO> list = new ArrayList<>(); |
|
|
|
LambdaQueryWrapper<IcBuildingEntity> buildingQueryWrapper = new QueryWrapper<IcBuildingEntity>().lambda() |
|
|
|
.in(IcBuildingEntity::getNeighborHoodId, neighborHoodId) |
|
|
|
.last("ORDER BY SORT, CAST(BUILDING_NAME AS SIGNED),CONVERT(BUILDING_NAME USING gbk)"); |
|
|
|
List<IcBuildingEntity> icBuildingList = icBuildingDao.selectList(buildingQueryWrapper); |
|
|
|
|
|
|
|
// 获取楼里已经有多少个房屋
|
|
|
|
LambdaQueryWrapper<IcHouseEntity> icHouseEntityWrapper = new QueryWrapper<IcHouseEntity>().lambda() |
|
|
|
.eq(IcHouseEntity::getNeighborHoodId, neighborHoodId) |
|
|
|
.select(IcHouseEntity::getId) |
|
|
|
.select(IcHouseEntity::getBuildingId); |
|
|
|
List<IcHouseEntity> buildingHouseCount = icHouseDao.selectList(icHouseEntityWrapper); |
|
|
|
Map<String, Long> buildingHouseCountMap = buildingHouseCount.stream().collect(Collectors.groupingBy(IcHouseEntity::getBuildingId, Collectors.counting())); |
|
|
|
|
|
|
|
resultList.addAll(gridList); |
|
|
|
return covertToTree(customerAgency, resultList); |
|
|
|
icBuildingList.forEach(item -> { |
|
|
|
BuildingTreeLevelDTO building = new BuildingTreeLevelDTO(); |
|
|
|
building.setId(item.getId()); |
|
|
|
building.setPId(item.getNeighborHoodId()); |
|
|
|
building.setLabel(item.getBuildingName()); |
|
|
|
building.setLevel("building"); |
|
|
|
building.setLongitude(item.getLongitude()); |
|
|
|
building.setLatitude(item.getLatitude()); |
|
|
|
building.setChildren(new ArrayList<>()); |
|
|
|
// 当前楼栋共有多少户，有多少户有人住
|
|
|
|
building.setShowNum(StrConstant.EPMETY_STR); |
|
|
|
// 楼栋总户数
|
|
|
|
Integer total = null == item.getTotalHouseNum() ? NumConstant.ZERO : item.getTotalHouseNum(); |
|
|
|
// 实际已录入的总房屋数
|
|
|
|
int count = buildingHouseCountMap.getOrDefault(item.getId(), NumConstant.ZERO_L).intValue(); |
|
|
|
if (NumConstant.ZERO == total) { |
|
|
|
building.setShowNum(String.format("%s/%s", count, count)); |
|
|
|
} else { |
|
|
|
building.setShowNum(String.format("%s/%s", count, total)); |
|
|
|
} |
|
|
|
building.setShowName(String.format("%s(%s)", building.getLabel(), building.getShowNum())); |
|
|
|
list.add(building); |
|
|
|
}); |
|
|
|
return list; |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
|
yinzuomei
3 years ago