部门画像--站画像--团队画像统计

airport-admin/src/main/java/com/sundot/airport/web/controller/score/DeptPortraitController.java

@@ -6,6 +6,7 @@ import com.sundot.airport.ledger.dto.DeptMemberDistributionDTO;
 import com.sundot.airport.ledger.dto.DeptMemberDTO;
 import com.sundot.airport.ledger.dto.DeptPortraitQueryDTO;
 import com.sundot.airport.ledger.dto.GroupPortraitDTO;
+import com.sundot.airport.ledger.dto.StationTeamStatsDTO;
 import com.sundot.airport.ledger.service.IDeptPortraitService;
 import com.sundot.airport.ledger.service.IGroupPortraitService;
 import io.swagger.annotations.Api;
@@ -177,4 +178,40 @@ public class DeptPortraitController extends BaseController {
             return error("获取组织画像失败：" + e.getMessage());
         }
     }
+
+    /**
+     * 获取站级别下所有部门的团队画像统计
+     * <p>
+     * 展示站下各部门的：
+     * 部门名称、员工数量、党员数量、平均年龄、平均工龄、
+     * 职业资格证书等级、平均升级年龄、综合得分
+     * </p>
+     *
+     * @param query 查询参数对象
+     * @return 站下各部门的团队画像统计列表
+     */
+    @ApiOperation("获取站级别下所有部门的团队画像统计")
+    @PostMapping("/station-team-stats")
+    public AjaxResult getStationTeamStats(@RequestBody DeptPortraitQueryDTO query) {
+        try {
+            // 参数校验
+            if (query == null || query.getDeptId() == null) {
+                return error("部门ID不能为空");
+            }
+
+            // 如果没有传日期范围,则默认为91天
+            if (query.getStartDate() == null || query.getEndDate() == null) {
+                java.time.LocalDate today = java.time.LocalDate.now();
+                query.setEndDate(today.toString());
+                query.setStartDate(today.minusDays(91).toString());
+            }
+
+            List<StationTeamStatsDTO> stats = deptPortraitService.getStationTeamStats(query);
+
+            return success(stats);
+        } catch (Exception e) {
+            logger.error("获取站团队画像统计失败", e);
+            return error("获取站团队画像统计失败：" + e.getMessage());
+        }
+    }
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/dto/StationTeamStatsDTO.java

@@ -0,0 +1,65 @@
+package com.sundot.airport.ledger.dto;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+
+/**
+ * <b>功能名：</b>StationTeamStatsDTO<br>
+ * <b>说明：</b> 站级别团队画像统计DTO（展示站下各部门的团队成员统计信息）<br>
+ * <b>著作权：</b> Copyright (C) 2025 SUNDOT CORPORATION<br>
+ *
+ * @author Claude
+ */
+@Data
+public class StationTeamStatsDTO implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 部门ID
+     */
+    private Long deptId;
+
+    /**
+     * 部门名称
+     */
+    private String deptName;
+
+    /**
+     * 员工数量
+     */
+    private Integer employeeCount;
+
+    /**
+     * 党员数量
+     */
+    private Integer partyMemberCount;
+
+    /**
+     * 平均年龄
+     */
+    private Double avgAge;
+
+    /**
+     * 平均工龄
+     */
+    private Double avgWorkYears;
+
+    /**
+     * 平均开机年限
+     */
+    private Double avgXrayOperatorYears;
+
+    /**
+     * 职业资格证书等级
+     */
+    private String qualificationLevel;
+
+
+    /**
+     * 综合得分
+     */
+    private BigDecimal totalScore;
+}

airport-ledger/src/main/java/com/sundot/airport/ledger/service/IDeptPortraitService.java

@@ -3,6 +3,7 @@ package com.sundot.airport.ledger.service;
 import com.sundot.airport.ledger.dto.DeptMemberDistributionDTO;
 import com.sundot.airport.ledger.dto.DeptMemberDTO;
 import com.sundot.airport.ledger.dto.DeptPortraitQueryDTO;
+import com.sundot.airport.ledger.dto.StationTeamStatsDTO;
 
 import java.util.List;
 
@@ -54,4 +55,17 @@ public interface IDeptPortraitService {
      * @return 成员职位情况分布数据
      */
     DeptMemberDistributionDTO getPositionDistribution(DeptPortraitQueryDTO query);
+
+    /**
+     * 获取站级别下所有部门的团队画像统计
+     * <p>
+     * 查询指定站(STATION)下所有部门(BRIGADE)的团队成员统计信息，包括：
+     * 部门名称、员工数量、党员数量、平均年龄、平均工龄、
+     * 职业资格证书等级、平均升级年龄、综合得分
+     * </p>
+     *
+     * @param query 查询参数对象(deptId=站ID, startDate, endDate)
+     * @return 站下各部门的团队画像统计列表
+     */
+    List<StationTeamStatsDTO> getStationTeamStats(DeptPortraitQueryDTO query);
 }

airport-ledger/src/main/java/com/sundot/airport/ledger/service/impl/DeptPortraitServiceImpl.java

@@ -2,16 +2,22 @@ package com.sundot.airport.ledger.service.impl;
 
 import com.sundot.airport.common.core.domain.entity.SysRole;
 import com.sundot.airport.common.core.domain.entity.SysUser;
+import com.sundot.airport.common.core.domain.entity.SysDept;
+import com.sundot.airport.common.enums.DeptTypeEnum;
 import com.sundot.airport.ledger.domain.ScoreDimension;
 import com.sundot.airport.ledger.domain.ScoreEvent;
 import com.sundot.airport.ledger.dto.DeptMemberDistributionDTO;
 import com.sundot.airport.ledger.dto.DeptMemberDTO;
 import com.sundot.airport.ledger.dto.DeptPortraitQueryDTO;
+import com.sundot.airport.ledger.dto.StationTeamStatsDTO;
 import com.sundot.airport.ledger.mapper.ScoreDimensionMapper;
 import com.sundot.airport.ledger.mapper.ScoreEventMapper;
+import com.sundot.airport.ledger.dto.GroupPortraitDTO;
 import com.sundot.airport.ledger.service.IDeptPortraitService;
+import com.sundot.airport.ledger.service.IGroupPortraitService;
 import com.sundot.airport.system.domain.BasePosition;
 import com.sundot.airport.system.mapper.BasePositionMapper;
+import com.sundot.airport.system.mapper.SysDeptMapper;
 import com.sundot.airport.system.mapper.SysRoleMapper;
 import com.sundot.airport.system.mapper.SysUserMapper;
 import org.slf4j.Logger;
@@ -44,6 +50,9 @@ public class DeptPortraitServiceImpl implements IDeptPortraitService {
     private SysUserMapper sysUserMapper;
 
     @Autowired
+    private SysDeptMapper sysDeptMapper;
+
+    @Autowired
     private SysRoleMapper sysRoleMapper;
 
     @Autowired
@@ -55,6 +64,9 @@ public class DeptPortraitServiceImpl implements IDeptPortraitService {
     @Autowired
     private BasePositionMapper basePositionMapper;
 
+    @Autowired
+    private IGroupPortraitService groupPortraitService;
+
     @Override
     public List<DeptMemberDTO> getDeptMembers(DeptPortraitQueryDTO query) {
         // 递归查询所有下级部门的用户
@@ -359,6 +371,132 @@ public class DeptPortraitServiceImpl implements IDeptPortraitService {
         return total.setScale(1, RoundingMode.HALF_UP);
     }
 
+    @Override
+    public List<StationTeamStatsDTO> getStationTeamStats(DeptPortraitQueryDTO query) {
+        // 1. 验证是站级别
+        SysDept station = sysDeptMapper.selectDeptById(query.getDeptId());
+        if (station == null || !"STATION".equals(station.getDeptType())) {
+            throw new RuntimeException("请选择站级别部门");
+        }
+
+        // 2. 查询站下所有部门(BRIGADE)
+        SysDept deptQuery = new SysDept();
+        deptQuery.setParentId(query.getDeptId());
+        deptQuery.setDeptType(DeptTypeEnum.BRIGADE.getCode());
+        deptQuery.setStatus("0");
+        List<SysDept> brigades = sysDeptMapper.selectDeptList(deptQuery);
+
+        if (brigades == null || brigades.isEmpty()) {
+            return Collections.emptyList();
+        }
+
+        // 3. 为每个部门计算统计信息
+        List<StationTeamStatsDTO> result = new ArrayList<>();
+        for (SysDept brigade : brigades) {
+            StationTeamStatsDTO stats = calculateDeptStats(brigade, query.getStartDate(), query.getEndDate());
+            if (stats != null) {
+                result.add(stats);
+            }
+        }
+
+        return result;
+    }
+
+    /**
+     * 计算单个部门的团队画像统计信息
+     */
+    private StationTeamStatsDTO calculateDeptStats(SysDept dept, String startDate, String endDate) {
+        // 查询部门所有成员
+        SysUser userQuery = new SysUser();
+        userQuery.setDeptId(dept.getDeptId());
+        userQuery.setStatus("0");
+        List<SysUser> members = sysUserMapper.selectUserList(userQuery);
+
+        if (members == null || members.isEmpty()) {
+            return null;
+        }
+
+        StationTeamStatsDTO stats = new StationTeamStatsDTO();
+        stats.setDeptId(dept.getDeptId());
+        stats.setDeptName(dept.getDeptName());
+        stats.setEmployeeCount(members.size());
+
+        // 计算各项统计
+        int partyCount = 0;
+        int totalAge = 0;
+        int totalWorkYears = 0;
+        int totalXrayOperatorYears = 0;
+        int validAgeCount = 0;
+        int validWorkYearsCount = 0;
+        int validXrayOperatorYearsCount = 0;
+        Map<String, Integer> qualLevelCount = new HashMap<>();
+        
+        for (SysUser user : members) {
+            // 党员数量(中共党员 + 中共预备党员)
+            String politicalStatus = decodePoliticalStatus(user.getPoliticalStatus());
+            if ("中共党员".equals(politicalStatus) || "中共预备党员".equals(politicalStatus)) {
+                partyCount++;
+            }
+        
+            // 年龄
+            Integer age = calculateAgeFromIdCard(user.getCardNumber());
+            if (age != null && age > 0) {
+                totalAge += age;
+                validAgeCount++;
+            }
+        
+            // 工龄(从入职时间计算)
+            if (user.getEntryDate() != null) {
+                Integer workYears = calculateYears(user.getEntryDate());
+                if (workYears != null) {
+                    totalWorkYears += workYears;
+                    validWorkYearsCount++;
+                }
+            }
+        
+            // 开机年限(从开机时间计算)
+            if (user.getXrayOperatorStarttime() != null) {
+                Integer xrayYears = calculateYears(user.getXrayOperatorStarttime());
+                if (xrayYears != null) {
+                    totalXrayOperatorYears += xrayYears;
+                    validXrayOperatorYearsCount++;
+                }
+            }
+        
+            // 职业资格等级
+            if (user.getQualificationLevel() != null && !user.getQualificationLevel().isEmpty()) {
+                String level = decodeQualificationLevel(user.getQualificationLevel());
+                qualLevelCount.merge(level, 1, Integer::sum);
+            }
+        }
+
+        stats.setPartyMemberCount(partyCount);
+        stats.setAvgAge(validAgeCount > 0 ? Math.round((double) totalAge / validAgeCount * 10) / 10.0 : 0);
+        stats.setAvgWorkYears(validWorkYearsCount > 0 ? Math.round((double) totalWorkYears / validWorkYearsCount * 10) / 10.0 : 0);
+        stats.setAvgXrayOperatorYears(validXrayOperatorYearsCount > 0 ? Math.round((double) totalXrayOperatorYears / validXrayOperatorYearsCount * 10) / 10.0 : 0);
+
+        // 职业资格证书等级（总个数）
+        int totalQualificationCount = qualLevelCount.values().stream()
+                .mapToInt(Integer::intValue)
+                .sum();
+        stats.setQualificationLevel(String.valueOf(totalQualificationCount));
+
+        // 计算综合得分（使用维度得分一览的总分逻辑）
+        try {
+            DeptPortraitQueryDTO portraitQuery = new DeptPortraitQueryDTO();
+            portraitQuery.setDeptId(dept.getDeptId());
+            portraitQuery.setStartDate(startDate);
+            portraitQuery.setEndDate(endDate);
+            GroupPortraitDTO portrait = groupPortraitService.getGroupPortrait(portraitQuery);
+            stats.setTotalScore(portrait.getTotalScore() != null ? portrait.getTotalScore() : BigDecimal.ZERO);
+        } catch (Exception e) {
+            log.warn("计算部门[{}]综合得分失败: {}", dept.getDeptName(), e.getMessage());
+            stats.setTotalScore(BigDecimal.ZERO);
+        }
+
+        return stats;
+    }
+
     private Integer calculateAgeFromIdCard(String idCard) {
         if (idCard == null || idCard.length() < 14) {
             return null;
@@ -405,4 +543,4 @@ public class DeptPortraitServiceImpl implements IDeptPortraitService {
             default: return v;
         }
     }
-}
+}