|
|
@ -151,58 +151,92 @@ public class StatsGroupServiceImpl implements StatsGroupService { |
|
|
BeanUtils.copyProperties(timeDim,agencyResult); |
|
|
BeanUtils.copyProperties(timeDim,agencyResult); |
|
|
//机关下的所有网格（包括直属网格）
|
|
|
//机关下的所有网格（包括直属网格）
|
|
|
List<String> allGrid = this.getAllGrid(agencyId,customerId); |
|
|
List<String> allGrid = this.getAllGrid(agencyId,customerId); |
|
|
String pidByAgencyId = dimAgencyService.getPidByAgencyId(agencyId); |
|
|
if (allGrid.size() != NumConstant.ZERO) { |
|
|
agencyResult.setPid(StringUtils.isBlank(pidByAgencyId)?"0":pidByAgencyId); |
|
|
String pidByAgencyId = dimAgencyService.getPidByAgencyId(agencyId); |
|
|
// 1. 机关下有多少网格
|
|
|
agencyResult.setPid(StringUtils.isBlank(pidByAgencyId) ? "0" : pidByAgencyId); |
|
|
List<GridIdListByCustomerResultDTO> customerGridIdList = customerGridService.getCustomerGridIdList(customerId, dateId); |
|
|
// 1. 机关下有多少网格
|
|
|
AtomicReference<Integer> gridSize = new AtomicReference<>(0); |
|
|
List<GridIdListByCustomerResultDTO> customerGridIdList = customerGridService.getCustomerGridIdList(customerId, dateId); |
|
|
if (customerGridIdList.size() != NumConstant.ZERO){ |
|
|
AtomicReference<Integer> gridSize = new AtomicReference<>(0); |
|
|
customerGridIdList.forEach(gridId -> { |
|
|
if (customerGridIdList.size() != NumConstant.ZERO) { |
|
|
allGrid.forEach(allAgencyGrid -> { |
|
|
customerGridIdList.forEach(gridId -> { |
|
|
if (gridId.getGridId().equals(allAgencyGrid)){ |
|
|
allGrid.forEach(allAgencyGrid -> { |
|
|
gridSize.updateAndGet(v -> v + NumConstant.ONE); |
|
|
if (gridId.getGridId().equals(allAgencyGrid)) { |
|
|
|
|
|
gridSize.updateAndGet(v -> v + NumConstant.ONE); |
|
|
|
|
|
} |
|
|
|
|
|
}); |
|
|
|
|
|
}); |
|
|
|
|
|
agencyResult.setGridTotal(gridSize.get()); |
|
|
|
|
|
} else { |
|
|
|
|
|
agencyResult.setGridTotal(NumConstant.ZERO); |
|
|
|
|
|
} |
|
|
|
|
|
// 2. 机关下有多少小组，只算 state = ‘approved’
|
|
|
|
|
|
List<AgencyGroupTotalCountResultDTO> approvedResult = new ArrayList<>(); |
|
|
|
|
|
List<AgencyGroupTotalCountResultDTO> agencyGroupTotalCount = groupDataService.getAgencyGroupTotalCount(customerId, dateId); |
|
|
|
|
|
allGrid.forEach(grid -> { |
|
|
|
|
|
agencyGroupTotalCount.forEach(groupTotal -> { |
|
|
|
|
|
if (grid.equals(groupTotal.getGridId())) { |
|
|
|
|
|
approvedResult.add(groupTotal); |
|
|
} |
|
|
} |
|
|
}); |
|
|
}); |
|
|
}); |
|
|
}); |
|
|
agencyResult.setGridTotal(gridSize.get()); |
|
|
Integer groupCount = approvedResult.stream().collect(Collectors.summingInt(AgencyGroupTotalCountResultDTO::getGridGroupCount)); |
|
|
}else { |
|
|
agencyResult.setGroupTotalCount(groupCount); |
|
|
agencyResult.setGridTotal(NumConstant.ZERO); |
|
|
// 3. 机关下所有组内人数和（不需要去重） 人员状态 != "removed"
|
|
|
} |
|
|
List<AgencyGridGroupPeopleTotalResultDTO> peopleTotal = new ArrayList<>(); |
|
|
// 2. 机关下有多少小组，只算 state = ‘approved’
|
|
|
List<AgencyGridGroupPeopleTotalResultDTO> agencyGridGroupPeopleTotal = groupDataService.selectAgencyGridGroupPeopleTotal(customerId, dateId); |
|
|
List<AgencyGroupTotalCountResultDTO> agencyGroupTotalCount = groupDataService.getAgencyGroupTotalCount(allGrid,dateId); |
|
|
allGrid.forEach(grid -> { |
|
|
Integer groupCount = agencyGroupTotalCount.stream().collect(Collectors.summingInt(AgencyGroupTotalCountResultDTO::getGridGroupCount)); |
|
|
agencyGridGroupPeopleTotal.forEach(people -> { |
|
|
agencyResult.setGroupTotalCount(groupCount); |
|
|
if (grid.equals(people.getGridId())) { |
|
|
// 3. 机关下所有组内人数和（不需要去重） 人员状态 != "removed"
|
|
|
peopleTotal.add(people); |
|
|
List<AgencyGridGroupPeopleTotalResultDTO> agencyGridGroupPeopleTotal = groupDataService.selectAgencyGridGroupPeopleTotal(allGrid,dateId); |
|
|
} |
|
|
Integer groupPeopleCount = agencyGridGroupPeopleTotal.stream().collect(Collectors.summingInt(AgencyGridGroupPeopleTotalResultDTO::getGridGroupPeopleTotal)); |
|
|
}); |
|
|
agencyResult.setGroupMemberTotalCount(groupPeopleCount); |
|
|
}); |
|
|
// 4. 机关下小组平均人数
|
|
|
Integer groupPeopleCount = peopleTotal.stream().collect(Collectors.summingInt(AgencyGridGroupPeopleTotalResultDTO::getGridGroupPeopleTotal)); |
|
|
agencyResult.setGroupMemberAvgCount( |
|
|
agencyResult.setGroupMemberTotalCount(groupPeopleCount); |
|
|
agencyResult.getGroupTotalCount() == NumConstant.ZERO ? NumConstant.ZERO : |
|
|
// 4. 机关下小组平均人数
|
|
|
agencyResult.getGroupMemberTotalCount()/agencyResult.getGroupTotalCount()); |
|
|
agencyResult.setGroupMemberAvgCount( |
|
|
// 5. 机关下小组人数中位数 小组最大(小)成员数、最多(少)成员小组ID
|
|
|
agencyResult.getGroupTotalCount() == NumConstant.ZERO ? NumConstant.ZERO : |
|
|
List<AgencyGridGroupPeopleResultDTO> agencyGridGroupPeople = groupDataService.selectAgencyEveryGroupPeopleCount(allGrid,dateId); |
|
|
agencyResult.getGroupMemberTotalCount() / agencyResult.getGroupTotalCount()); |
|
|
List<AgencyGridGroupPeopleResultDTO> sorted = agencyGridGroupPeople.stream().sorted(Comparator.comparing(AgencyGridGroupPeopleResultDTO::getGroupCount).reversed()).collect(Collectors.toList()); |
|
|
// 5. 机关下小组人数中位数 小组最大(小)成员数、最多(少)成员小组ID
|
|
|
Integer groupPeopleMedian; |
|
|
List<AgencyGridGroupPeopleResultDTO> groupPeople = new ArrayList<>(); |
|
|
if (sorted.size() == NumConstant.ONE){ |
|
|
List<AgencyGridGroupPeopleResultDTO> agencyGridGroupPeople = groupDataService.selectAgencyEveryGroupPeopleCount(customerId, dateId); |
|
|
agencyResult.setGroupMemberMaxCount(sorted.get(NumConstant.ZERO).getGroupCount()); |
|
|
allGrid.forEach(grid -> { |
|
|
agencyResult.setMaxMemberGroupId(sorted.get(NumConstant.ZERO).getGroupId()); |
|
|
agencyGridGroupPeople.forEach(group -> { |
|
|
agencyResult.setGroupMemberMinCount(sorted.get(NumConstant.ZERO).getGroupCount()); |
|
|
if (grid.equals(group.getGridId())) { |
|
|
agencyResult.setMinMemberGroupId(sorted.get(NumConstant.ZERO).getGroupId()); |
|
|
groupPeople.add(group); |
|
|
}else if (sorted.size() >= NumConstant.TWO){ |
|
|
} |
|
|
groupPeopleMedian = sorted.size() % NumConstant.TWO == NumConstant.ZERO ? |
|
|
}); |
|
|
(sorted.get(sorted.size() / NumConstant.TWO - NumConstant.ONE).getGroupCount() + sorted.get(sorted.size() / 2).getGroupCount()) / 2 : |
|
|
}); |
|
|
sorted.get(sorted.size() / NumConstant.TWO).getGroupCount(); |
|
|
List<AgencyGridGroupPeopleResultDTO> sorted = groupPeople.stream().sorted(Comparator.comparing(AgencyGridGroupPeopleResultDTO::getGroupCount).reversed()).collect(Collectors.toList()); |
|
|
agencyResult.setGroupMedian(groupPeopleMedian); |
|
|
Integer groupPeopleMedian; |
|
|
agencyResult.setGroupMemberMaxCount(sorted.get(NumConstant.ZERO).getGroupCount()); |
|
|
if (sorted.size() == NumConstant.ONE) { |
|
|
agencyResult.setMaxMemberGroupId(sorted.get(NumConstant.ZERO).getGroupId()); |
|
|
agencyResult.setGroupMemberMaxCount(sorted.get(NumConstant.ZERO).getGroupCount()); |
|
|
agencyResult.setGroupMemberMinCount(sorted.get(sorted.size() - NumConstant.ONE).getGroupCount()); |
|
|
agencyResult.setMaxMemberGroupId(sorted.get(NumConstant.ZERO).getGroupId()); |
|
|
agencyResult.setMinMemberGroupId(sorted.get(sorted.size() - NumConstant.ONE).getGroupId()); |
|
|
agencyResult.setGroupMemberMinCount(sorted.get(NumConstant.ZERO).getGroupCount()); |
|
|
|
|
|
agencyResult.setMinMemberGroupId(sorted.get(NumConstant.ZERO).getGroupId()); |
|
|
|
|
|
} else if (sorted.size() >= NumConstant.TWO) { |
|
|
|
|
|
groupPeopleMedian = sorted.size() % NumConstant.TWO == NumConstant.ZERO ? |
|
|
|
|
|
(sorted.get(sorted.size() / NumConstant.TWO - NumConstant.ONE).getGroupCount() + sorted.get(sorted.size() / 2).getGroupCount()) / 2 : |
|
|
|
|
|
sorted.get(sorted.size() / NumConstant.TWO).getGroupCount(); |
|
|
|
|
|
agencyResult.setGroupMedian(groupPeopleMedian); |
|
|
|
|
|
agencyResult.setGroupMemberMaxCount(sorted.get(NumConstant.ZERO).getGroupCount()); |
|
|
|
|
|
agencyResult.setMaxMemberGroupId(sorted.get(NumConstant.ZERO).getGroupId()); |
|
|
|
|
|
agencyResult.setGroupMemberMinCount(sorted.get(sorted.size() - NumConstant.ONE).getGroupCount()); |
|
|
|
|
|
agencyResult.setMinMemberGroupId(sorted.get(sorted.size() - NumConstant.ONE).getGroupId()); |
|
|
|
|
|
} |
|
|
|
|
|
// 6. 机关下小组增量
|
|
|
|
|
|
List<AgencyGroupIncrResultDTO> groupIncr = new ArrayList<>(); |
|
|
|
|
|
List<AgencyGroupIncrResultDTO> agencyGroupIncr = groupDataService.selectAgencyGroupIncr(customerId, dateId); |
|
|
|
|
|
allGrid.forEach(grid -> { |
|
|
|
|
|
agencyGroupIncr.forEach(incr -> { |
|
|
|
|
|
if (grid.equals(incr.getGridId())) { |
|
|
|
|
|
groupIncr.add(incr); |
|
|
|
|
|
} |
|
|
|
|
|
}); |
|
|
|
|
|
}); |
|
|
|
|
|
Integer groupIncrCount = groupIncr.stream().collect(Collectors.summingInt(AgencyGroupIncrResultDTO::getGroupIncr)); |
|
|
|
|
|
agencyResult.setGroupIncr(groupIncrCount); |
|
|
} |
|
|
} |
|
|
// 6. 机关下小组增量
|
|
|
|
|
|
List<AgencyGroupIncrResultDTO> agencyGroupIncr = groupDataService.selectAgencyGroupIncr(allGrid, dateId); |
|
|
|
|
|
Integer groupIncr = agencyGroupIncr.stream().collect(Collectors.summingInt(AgencyGroupIncrResultDTO::getGroupIncr)); |
|
|
|
|
|
agencyResult.setGroupIncr(groupIncr); |
|
|
|
|
|
result.add(agencyResult); |
|
|
result.add(agencyResult); |
|
|
}); |
|
|
}); |
|
|
return result; |
|
|
return result; |
|
|
|
jianjun
5 years ago