组织画像-标准执行

airport-check/src/main/java/com/sundot/airport/check/service/impl/CheckLargeScreenServiceImpl.java

@@ -1479,6 +1479,55 @@ public class CheckLargeScreenServiceImpl implements ICheckLargeScreenService {
                 Integer integer = rankMap.get(targetId);
                 result.setStationRanking(integer);
             }
+        } else if (ObjUtil.isNotNull(brigadeId)) {
+            // 大队级
+            Long finalbrigadeId = brigadeId;
+            target = all.stream().filter(item -> ObjUtil.equals(item.getCheckedBrigadeId(), finalbrigadeId)).collect(Collectors.toList());
+            if (CollUtil.isEmpty(target)) {
+                return null;
+            }
+            // 本站排名处理
+            List<CheckLargeScreenCorrectionPortraitSqlDto> stationList = all;
+            Map<Long, Long> brigadeIdCountMap = stationList.stream().collect(Collectors.groupingBy(CheckLargeScreenCorrectionPortraitSqlDto::getCheckedBrigadeId, Collectors.counting()));
+            Map<Long, Long> tempMap = new HashMap<>();
+            List<SysDept> deptList = sysDeptService.selectDeptInfoAll(new SysDept());
+            deptList = deptList.stream().filter(item -> StrUtil.equals(DeptType.BRIGADE.getCode(), item.getDeptType())).collect(Collectors.toList());
+            if (CollUtil.isNotEmpty(deptList)) {
+                List<Long> brigadeIdList = deptList.stream().map(SysDept::getDeptId).distinct().collect(Collectors.toList());
+                brigadeIdList.forEach(item -> {
+                    tempMap.put(item, brigadeIdCountMap.getOrDefault(item, 0L));
+                });
+                result.setStationTotal(brigadeIdList.size());
+                // 1. 按值升序排序
+                List<Map.Entry<Long, Long>> sortedEntries = tempMap.entrySet()
+                        .stream()
+                        .sorted(Map.Entry.comparingByValue())
+                        .collect(Collectors.toList());
+                // 2. 计算排名（考虑并列情况）
+                Map<Long, Integer> rankMap = new HashMap<>();
+                int currentRank = 1;
+                Long prevValue = null;
+                int sameValueCount = 1; // 记录相同值的用户数
+                for (int i = 0; i < sortedEntries.size(); i++) {
+                    Map.Entry<Long, Long> entry = sortedEntries.get(i);
+                    Long currentValue = entry.getValue();
+                    if (prevValue != null && !currentValue.equals(prevValue)) {
+                        // 如果当前值与前一个值不同，更新排名
+                        currentRank += sameValueCount;
+                        sameValueCount = 1;
+                    } else if (prevValue != null) {
+                        // 如果当前值与前一个值相同，排名不变，但增加相同值的计数
+                        sameValueCount++;
+                    }
+                    // 存储用户ID和排名
+                    rankMap.put(entry.getKey(), currentRank);
+                    prevValue = currentValue;
+                }
+                // 3. 查询指定排名
+                Long targetId = brigadeId;
+                Integer integer = rankMap.get(targetId);
+                result.setStationRanking(integer);
+            }
         } else {
             // 站级
             target = all;