| 
						
						
							
								
							
						
						
					 | 
				
				 | 
				
					@ -2916,26 +2916,30 @@ public class ProjectServiceImpl extends BaseServiceImpl<ProjectDao, ProjectEntit | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
							ProjectDistributionAnalysisRightResultDTO result = new ProjectDistributionAnalysisRightResultDTO(); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
							List<ProjectDistributionAnalysisRightDTO> orgList = new ArrayList<>(); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
							Result<List<SonOrgResultDTO>> sonOrgList = govOrgOpenFeignClient.getSonAgencyId(formDTO.getOrgId(), agencyInfo.getLevel()); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
							if (!sonOrgList.success() || CollectionUtils.isEmpty(sonOrgList.getData())){ | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
								throw new EpmetException(String.format("查询组织{%s}的下级组织失败或为空...",formDTO.getOrgId())); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
							if (!sonOrgList.success()){ | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
								throw new EpmetException(String.format("查询组织{%s}的下级组织失败...",formDTO.getOrgId())); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
							} | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
							if (CollectionUtils.isEmpty(sonOrgList.getData())){ | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
								return result; | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
							} | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
							List<SonOrgResultDTO> orgIds = sonOrgList.getData(); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
							for (SonOrgResultDTO o : orgIds) { | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
								ProjectDistributionAnalysisRightDTO dto = new ProjectDistributionAnalysisRightDTO(); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
								dto.setOrgId(o.getOrgId()); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
								orgList.add(dto); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
							} | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
							List<ProjectDistributionAnalysisRightDTO> dtos; | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
							if (!agencyInfo.getLevel().equals(ProjectConstant.ORG_LEVEL_COMMUNITY)){ | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
								orgList = baseDao.selectProjectCountByOrg(orgIds, formDTO.getStartDate(),formDTO.getEndDate()); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
								dtos = baseDao.selectProjectCountByOrg(orgIds.stream().map(m -> m.getOrgId()).collect(Collectors.toList()), formDTO.getStartDate(), formDTO.getEndDate()); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
							}else { | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
								for (SonOrgResultDTO o : orgIds) { | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
									ProjectDistributionAnalysisRightDTO dto = new ProjectDistributionAnalysisRightDTO(); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
									dto.setOrgId(o.getOrgId()); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
									orgList.add(dto); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
								} | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
								Result<List<ProjectDistributionAnalysisRightDTO>> projectCountByGrid = govIssueOpenFeignClient.getProjectCountByGrid(formDTO); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
								if (!projectCountByGrid.success()){ | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
									throw new EpmetException("查询网格项目数失败..."); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
								} | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
								if (CollectionUtils.isNotEmpty(projectCountByGrid.getData())){ | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
									orgList.stream().forEach(o -> projectCountByGrid.getData().stream().filter(p -> p.getOrgId().equals(o.getOrgId())).forEach(p -> o.setCount(p.getCount()))); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
					
 | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
								} | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
								dtos = projectCountByGrid.getData(); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
							} | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
							if (CollectionUtils.isNotEmpty(dtos)){ | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
								orgList.stream().forEach(o -> dtos.stream().filter(p -> p.getOrgId().equals(o.getOrgId())).forEach(p -> o.setCount(p.getCount()))); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
							} | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
							if (CollectionUtils.isEmpty(orgList)){ | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
								return result; | 
				
			
			
		
	
	
		
			
				
					| 
						
							
								
							
						
						
						
					 | 
				
				 | 
				
					
  |