查堵大屏--大队

airport-blocked/src/main/java/com/sundot/airport/blocked/dto/BlockedItemLocationDistributionDTO.java

@@ -8,10 +8,10 @@ import java.io.Serializable;
 import java.math.BigDecimal;
 
 /**
- * 查堵物品位置分布统计DTO(用于扇形图)
+ * 查堵物品位置分布统计DTO
  * 
  * @author wangxx
- * @date 2026-04-15
+ * @date 2026-04-16
  */
 @Data
 @ApiModel("查堵物品位置分布统计")

airport-blocked/src/main/java/com/sundot/airport/blocked/mapper/BlockedDashboardMapper.java

@@ -5,20 +5,27 @@ import com.sundot.airport.blocked.dto.BlockedBrigadeCertificateDistributionDTO;
 import com.sundot.airport.blocked.dto.BlockedBrigadeRateStatsDTO;
 import com.sundot.airport.blocked.dto.BlockedBrigadeStatsDTO;
 import com.sundot.airport.blocked.dto.BlockedCertificateDistributionDTO;
+import com.sundot.airport.blocked.dto.BlockedCertificateLevelDistributionDTO;
 import com.sundot.airport.blocked.dto.BlockedDailyBrigadeLuggageStatsDTO;
 import com.sundot.airport.blocked.dto.BlockedDailyBrigadeRateStatsDTO;
 import com.sundot.airport.blocked.dto.BlockedDailyBrigadeStatsDTO;
+import com.sundot.airport.blocked.dto.BlockedDailyBrigadeTerminalLuggageStatsDTO;
+import com.sundot.airport.blocked.dto.BlockedDailyBrigadeTerminalRateStatsDTO;
+import com.sundot.airport.blocked.dto.BlockedDailyBrigadeTerminalStatsDTO;
 import com.sundot.airport.blocked.dto.BlockedDailyLuggageStatsDTO;
 import com.sundot.airport.blocked.dto.BlockedDailyRateStatsDTO;
 import com.sundot.airport.blocked.dto.BlockedDailyStatsDTO;
 import com.sundot.airport.blocked.dto.BlockedDashboardQueryDTO;
 import com.sundot.airport.blocked.dto.BlockedDifficultyDistributionDTO;
 import com.sundot.airport.blocked.dto.BlockedDiscriminationDistributionDTO;
+import com.sundot.airport.blocked.dto.BlockedGenderDistributionDTO;
 import com.sundot.airport.blocked.dto.BlockedItemDistributionDTO;
 import com.sundot.airport.blocked.dto.BlockedItemLocationDistributionDTO;
 import com.sundot.airport.blocked.dto.BlockedMissCheckReasonDistributionDTO;
 import com.sundot.airport.blocked.dto.BlockedOperatingYearsDistributionDTO;
 import com.sundot.airport.blocked.dto.BlockedRankingDTO;
+import com.sundot.airport.blocked.dto.BlockedTerminalStatsDTO;
+import com.sundot.airport.blocked.dto.BlockedTimePeriodLuggageStatsDTO;
 import com.sundot.airport.blocked.dto.BlockedTimePeriodStatsDTO;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
@@ -249,4 +256,139 @@ public interface BlockedDashboardMapper {
      * @return 大队证书分布统计列表
      */
     List<BlockedBrigadeCertificateDistributionDTO> selectBrigadeCertificateDistribution(BlockedDashboardQueryDTO queryDTO);
+
+    /**
+     * 查询两楼每日查堵走势(按大队)
+     * 
+     * @param queryDTO 查询参数
+     * @return 两楼每日查堵走势统计列表
+     */
+    List<BlockedDailyBrigadeTerminalStatsDTO> selectDailyBrigadeTerminalStats(BlockedDashboardQueryDTO queryDTO);
+
+    /**
+     * 查询两楼每日过检图像数(按大队)
+     * 
+     * @param queryDTO 查询参数
+     * @return 两楼每日过检图像数统计列表
+     */
+    List<BlockedDailyBrigadeTerminalLuggageStatsDTO> selectDailyBrigadeTerminalLuggageStats(BlockedDashboardQueryDTO queryDTO);
+
+    /**
+     * 查询两楼查堵数（包含行检，按大队）
+     * 数据来源：漏检统计表
+     * 先查大队数量，再查T1、T2数量
+     * 
+     * @param queryDTO 查询参数
+     * @return 两楼查堵数统计
+     */
+    BlockedTerminalStatsDTO selectTerminalBlockedStats(BlockedDashboardQueryDTO queryDTO);
+
+    /**
+     * 查询查堵时间段过检行李数(按大队)
+     * 数据源：每日各时间段过检行李数
+     * 维度(横轴)：时间段
+     * 统计值(左坐标轴)：过检行李数平均值
+     * 统计值(右坐标轴)：时段查堵件数平均值
+     * 
+     * @param queryDTO 查询参数
+     * @return 时间段过检行李数统计列表
+     */
+    List<BlockedTimePeriodLuggageStatsDTO> selectTimePeriodLuggageStats(BlockedDashboardQueryDTO queryDTO);
+
+    /**
+     * 查询两楼每日查堵万分率(按大队)
+     * 数据源：各大队每日过检行李查堵数据收集表
+     * 按时间统计T2旅检万分率、T1旅检万分率、T1行检万分率、T2行检万分率
+     * 
+     * @param queryDTO 查询参数
+     * @return 两楼每日查堵万分率统计列表
+     */
+    List<BlockedDailyBrigadeTerminalRateStatsDTO> selectDailyBrigadeTerminalRateStats(BlockedDashboardQueryDTO queryDTO);
+
+    /**
+     * 查询查堵-主管分管次数分布(用于饼图)
+     * 
+     * @param queryDTO 查询参数
+     * @return 主管分管次数分布统计列表
+     */
+    List<BlockedRankingDTO> selectSupervisorDistribution(BlockedDashboardQueryDTO queryDTO);
+
+    /**
+     * 查询查堵-主管排行榜(大队维度,前10名)
+     * 数据源：漏检统计表
+     * 数据筛选：分管主管不为空
+     * 排行字段：分管主管
+     * 排行依据：统计记录总数
+     * 显示行数：显示前10行
+     * 
+     * @param queryDTO 查询参数
+     * @return 主管排行榜列表（前10名）
+     */
+    List<BlockedRankingDTO> selectBrigadeSupervisorRanking(BlockedDashboardQueryDTO queryDTO);
+
+    /**
+     * 查询查堵-班组排行榜(大队维度,前10名)
+     * 数据源：漏检统计表
+     * 数据筛选：分管班组长不为空
+     * 排行字段：分管班组长
+     * 排行依据：统计记录总数
+     * 显示行数：显示前10行
+     * 
+     * @param queryDTO 查询参数
+     * @return 班组排行榜列表（前10名）
+     */
+    List<BlockedRankingDTO> selectBrigadeTeamLeaderRanking(BlockedDashboardQueryDTO queryDTO);
+
+    /**
+     * 查询查堵-人员排行榜(大队维度,前10名)
+     * 数据源：漏检统计表
+     * 数据筛选：被回查人不为空
+     * 排行字段：被回查人
+     * 排行依据：统计记录总数
+     * 显示行数：显示前10行
+     * 
+     * @param queryDTO 查询参数
+     * @return 人员排行榜列表（前10名）
+     */
+    List<BlockedRankingDTO> selectBrigadeReviewedUserRanking(BlockedDashboardQueryDTO queryDTO);
+
+    /**
+     * 查询查堵男女比例(按大队)
+     * 数据源：漏检统计表
+     * 统计性别分布
+     * 
+     * @param queryDTO 查询参数
+     * @return 男女比例统计列表
+     */
+    List<BlockedGenderDistributionDTO> selectGenderDistribution(BlockedDashboardQueryDTO queryDTO);
+
+    /**
+     * 查询查堵人员证书级别分布(按大队)
+     * 数据源：漏检统计表
+     * 统计证书级别分布
+     * 
+     * @param queryDTO 查询参数
+     * @return 证书级别分布统计列表
+     */
+    List<BlockedCertificateLevelDistributionDTO> selectCertificateLevelDistribution(BlockedDashboardQueryDTO queryDTO);
+
+    /**
+     * 查询证书级别人员基数(分大队统计)
+     * 数据源：用户表(sys_user) + 部门表(sys_dept)
+     * 统计大队人员里面的人员证书级别构成
+     * 
+     * @param queryDTO 查询参数（大队ID必填）
+     * @return 证书级别人员基数统计列表
+     */
+    List<BlockedCertificateLevelDistributionDTO> selectBrigadePersonnelCertificateBase(BlockedDashboardQueryDTO queryDTO);
+
+    /**
+     * 查询查堵人员开机年限分布(用于饼图)
+     * 数据源：漏检统计表
+     * 统计字段：开机年限
+     * 
+     * @param queryDTO 查询参数
+     * @return 开机年限分布统计列表
+     */
+    List<BlockedOperatingYearsDistributionDTO> selectOperatingYearsDistribution(BlockedDashboardQueryDTO queryDTO);
 }

airport-blocked/src/main/java/com/sundot/airport/blocked/service/IBlockedDashboardService.java

@@ -5,9 +5,13 @@ import com.sundot.airport.blocked.dto.BlockedBrigadeCertificateDistributionDTO;
 import com.sundot.airport.blocked.dto.BlockedBrigadeRateStatsDTO;
 import com.sundot.airport.blocked.dto.BlockedBrigadeStatsDTO;
 import com.sundot.airport.blocked.dto.BlockedCertificateDistributionDTO;
+import com.sundot.airport.blocked.dto.BlockedCertificateLevelDistributionDTO;
 import com.sundot.airport.blocked.dto.BlockedDailyBrigadeLuggageStatsDTO;
 import com.sundot.airport.blocked.dto.BlockedDailyBrigadeRateStatsDTO;
 import com.sundot.airport.blocked.dto.BlockedDailyBrigadeStatsDTO;
+import com.sundot.airport.blocked.dto.BlockedDailyBrigadeTerminalLuggageStatsDTO;
+import com.sundot.airport.blocked.dto.BlockedDailyBrigadeTerminalRateStatsDTO;
+import com.sundot.airport.blocked.dto.BlockedDailyBrigadeTerminalStatsDTO;
 import com.sundot.airport.blocked.dto.BlockedDailyLuggageStatsDTO;
 import com.sundot.airport.blocked.dto.BlockedDailyRateStatsDTO;
 import com.sundot.airport.blocked.dto.BlockedDailyStatsDTO;
@@ -15,12 +19,15 @@ import com.sundot.airport.blocked.dto.BlockedDashboardQueryDTO;
 import com.sundot.airport.blocked.dto.BlockedDashboardResultDTO;
 import com.sundot.airport.blocked.dto.BlockedDifficultyDistributionDTO;
 import com.sundot.airport.blocked.dto.BlockedDiscriminationDistributionDTO;
+import com.sundot.airport.blocked.dto.BlockedGenderDistributionDTO;
 import com.sundot.airport.blocked.dto.BlockedItemDistributionDTO;
 import com.sundot.airport.blocked.dto.BlockedItemLocationDistributionDTO;
 import com.sundot.airport.blocked.dto.BlockedMissCheckReasonDistributionDTO;
 import com.sundot.airport.blocked.dto.BlockedOperatingYearsDistributionDTO;
 import com.sundot.airport.blocked.dto.BlockedRankingDTO;
 import com.sundot.airport.blocked.dto.BlockedRateResultDTO;
+import com.sundot.airport.blocked.dto.BlockedTerminalStatsDTO;
+import com.sundot.airport.blocked.dto.BlockedTimePeriodLuggageStatsDTO;
 import com.sundot.airport.blocked.dto.BlockedTimePeriodStatsDTO;
 
 import java.util.List;
@@ -240,4 +247,147 @@ public interface IBlockedDashboardService {
      * @return 大队证书分布统计列表
      */
     List<BlockedBrigadeCertificateDistributionDTO> getBrigadeCertificateDistribution(BlockedDashboardQueryDTO queryDTO);
+
+    /**
+     * 查询两楼每日查堵走势(按大队)
+     * 数据来源：各大队每日过检行李查堵数据收集表
+     * 先查出来是哪个安检大队的，然后按日期统计以下四个字段：
+     * T1旅检查堵件数、T2旅检查堵件数、T1行检查堵件数、T2行检查堵件数
+     * 
+     * @param queryDTO 查询参数
+     * @return 两楼每日查堵走势统计列表
+     */
+    List<BlockedDailyBrigadeTerminalStatsDTO> getDailyBrigadeTerminalStats(BlockedDashboardQueryDTO queryDTO);
+
+    /**
+     * 查询两楼每日过检图像数(按大队)
+     * 数据来源：各大队每日过检行李查堵数据收集表
+     * 先查出来是哪个安检大队的，然后按日期统计以下四个字段：
+     * T2旅检过检行李数、T1旅检过检行李数、T1行检过检行李数、T2行检过检行李数
+     * 
+     * @param queryDTO 查询参数
+     * @return 两楼每日过检图像数统计列表
+     */
+    List<BlockedDailyBrigadeTerminalLuggageStatsDTO> getDailyBrigadeTerminalLuggageStats(BlockedDashboardQueryDTO queryDTO);
+
+    /**
+     * 查询两楼查堵数（包含行检，按大队）
+     * 数据来源：漏检统计表
+     * 先查大队数量，再查T1、T2数量
+     * 
+     * @param queryDTO 查询参数
+     * @return 两楼查堵数统计
+     */
+    BlockedTerminalStatsDTO getTerminalBlockedStats(BlockedDashboardQueryDTO queryDTO);
+
+    /**
+     * 查询查堵时间段过检行李数(按大队)
+     * 数据源：每日各时间段过检行李数
+     * 维度(横轴)：时间段
+     * 统计值(左坐标轴)：过检行李数平均值
+     * 统计值(右坐标轴)：时段查堵件数平均值
+     * 
+     * @param queryDTO 查询参数
+     * @return 时间段过检行李数统计列表
+     */
+    List<BlockedTimePeriodLuggageStatsDTO> getTimePeriodLuggageStats(BlockedDashboardQueryDTO queryDTO);
+
+    /**
+     * 查询两楼每日查堵万分率(按大队)
+     * 数据源：各大队每日过检行李查堵数据收集表
+     * 按时间统计T2旅检万分率、T1旅检万分率、T1行检万分率、T2行检万分率
+     * 
+     * @param queryDTO 查询参数
+     * @return 两楼每日查堵万分率统计列表
+     */
+    List<BlockedDailyBrigadeTerminalRateStatsDTO> getDailyBrigadeTerminalRateStats(BlockedDashboardQueryDTO queryDTO);
+
+    /**
+     * 查询查堵-主管分管次数分布(用于饼图)
+     * 数据源：漏检统计表
+     * 统计字段：分管主管
+     * 
+     * @param queryDTO 查询参数
+     * @return 主管分管次数分布统计列表
+     */
+    List<BlockedRankingDTO> getSupervisorDistribution(BlockedDashboardQueryDTO queryDTO);
+
+    /**
+     * 查询查堵-主管排行榜(大队维度,前10名)
+     * 数据源：漏检统计表
+     * 数据筛选：分管主管不为空
+     * 排行字段：分管主管
+     * 排行依据：统计记录总数
+     * 显示行数：显示前10行
+     * 
+     * @param queryDTO 查询参数
+     * @return 主管排行榜列表（前10名）
+     */
+    List<BlockedRankingDTO> getBrigadeSupervisorRanking(BlockedDashboardQueryDTO queryDTO);
+
+    /**
+     * 查询查堵-班组排行榜(大队维度,前10名)
+     * 数据源：漏检统计表
+     * 数据筛选：分管班组长不为空
+     * 排行字段：分管班组长
+     * 排行依据：统计记录总数
+     * 显示行数：显示前10行
+     * 
+     * @param queryDTO 查询参数
+     * @return 班组排行榜列表（前10名）
+     */
+    List<BlockedRankingDTO> getBrigadeTeamLeaderRanking(BlockedDashboardQueryDTO queryDTO);
+
+    /**
+     * 查询查堵-人员排行榜(大队维度,前10名)
+     * 数据源：漏检统计表
+     * 数据筛选：被回查人不为空
+     * 排行字段：被回查人
+     * 排行依据：统计记录总数
+     * 显示行数：显示前10行
+     * 
+     * @param queryDTO 查询参数
+     * @return 人员排行榜列表（前10名）
+     */
+    List<BlockedRankingDTO> getBrigadeReviewedUserRanking(BlockedDashboardQueryDTO queryDTO);
+
+    /**
+     * 查询查堵男女比例(按大队)
+     * 数据源：漏检统计表
+     * 统计性别分布
+     * 
+     * @param queryDTO 查询参数
+     * @return 男女比例统计列表
+     */
+    List<BlockedGenderDistributionDTO> getGenderDistribution(BlockedDashboardQueryDTO queryDTO);
+
+    /**
+     * 查询查堵人员证书级别分布(按大队)
+     * 数据源：漏检统计表
+     * 统计证书级别分布
+     * 
+     * @param queryDTO 查询参数
+     * @return 证书级别分布统计列表
+     */
+    List<BlockedCertificateLevelDistributionDTO> getCertificateLevelDistribution(BlockedDashboardQueryDTO queryDTO);
+
+    /**
+     * 查询证书级别人员基数(分大队统计)
+     * 数据源：用户表(sys_user) + 部门表(sys_dept)
+     * 统计大队人员里面的人员证书级别构成
+     * 
+     * @param queryDTO 查询参数（大队ID必填）
+     * @return 证书级别人员基数统计列表
+     */
+    List<BlockedCertificateLevelDistributionDTO> getBrigadePersonnelCertificateBase(BlockedDashboardQueryDTO queryDTO);
+
+    /**
+     * 查询查堵人员开机年限分布(用于饼图)
+     * 数据源：漏检统计表
+     * 统计字段：开机年限
+     * 
+     * @param queryDTO 查询参数
+     * @return 开机年限分布统计列表
+     */
+    List<BlockedOperatingYearsDistributionDTO> getOperatingYearsDistribution(BlockedDashboardQueryDTO queryDTO);
 }

airport-blocked/src/main/java/com/sundot/airport/blocked/service/impl/BlockedDashboardServiceImpl.java

@@ -6,9 +6,13 @@ import com.sundot.airport.blocked.dto.BlockedBrigadeCertificateDistributionDTO;
 import com.sundot.airport.blocked.dto.BlockedBrigadeRateStatsDTO;
 import com.sundot.airport.blocked.dto.BlockedBrigadeStatsDTO;
 import com.sundot.airport.blocked.dto.BlockedCertificateDistributionDTO;
+import com.sundot.airport.blocked.dto.BlockedCertificateLevelDistributionDTO;
 import com.sundot.airport.blocked.dto.BlockedDailyBrigadeLuggageStatsDTO;
 import com.sundot.airport.blocked.dto.BlockedDailyBrigadeRateStatsDTO;
 import com.sundot.airport.blocked.dto.BlockedDailyBrigadeStatsDTO;
+import com.sundot.airport.blocked.dto.BlockedDailyBrigadeTerminalLuggageStatsDTO;
+import com.sundot.airport.blocked.dto.BlockedDailyBrigadeTerminalRateStatsDTO;
+import com.sundot.airport.blocked.dto.BlockedDailyBrigadeTerminalStatsDTO;
 import com.sundot.airport.blocked.dto.BlockedDailyLuggageStatsDTO;
 import com.sundot.airport.blocked.dto.BlockedDailyRateStatsDTO;
 import com.sundot.airport.blocked.dto.BlockedDailyStatsDTO;
@@ -16,12 +20,15 @@ import com.sundot.airport.blocked.dto.BlockedDashboardQueryDTO;
 import com.sundot.airport.blocked.dto.BlockedDashboardResultDTO;
 import com.sundot.airport.blocked.dto.BlockedDifficultyDistributionDTO;
 import com.sundot.airport.blocked.dto.BlockedDiscriminationDistributionDTO;
+import com.sundot.airport.blocked.dto.BlockedGenderDistributionDTO;
 import com.sundot.airport.blocked.dto.BlockedItemDistributionDTO;
 import com.sundot.airport.blocked.dto.BlockedItemLocationDistributionDTO;
 import com.sundot.airport.blocked.dto.BlockedMissCheckReasonDistributionDTO;
 import com.sundot.airport.blocked.dto.BlockedOperatingYearsDistributionDTO;
 import com.sundot.airport.blocked.dto.BlockedRankingDTO;
 import com.sundot.airport.blocked.dto.BlockedRateResultDTO;
+import com.sundot.airport.blocked.dto.BlockedTerminalStatsDTO;
+import com.sundot.airport.blocked.dto.BlockedTimePeriodLuggageStatsDTO;
 import com.sundot.airport.blocked.dto.BlockedTimePeriodStatsDTO;
 import com.sundot.airport.blocked.mapper.BlockedDashboardMapper;
 import com.sundot.airport.blocked.service.IBlockedDashboardService;
@@ -372,6 +379,14 @@ public class BlockedDashboardServiceImpl implements IBlockedDashboardService {
     @Override
     public List<BlockedCertificateDistributionDTO> getCertificateDistribution(BlockedDashboardQueryDTO queryDTO) {
         List<BlockedCertificateDistributionDTO> resultList = blockedDashboardMapper.selectCertificateDistribution(queryDTO);
+        if (resultList != null && !resultList.isEmpty()) {
+            // 转换证书级别为中文
+            resultList.forEach(item -> {
+                if (item.getCertificateLevel() != null) {
+                    item.setCertificateLevel(convertCertificateLevel(item.getCertificateLevel()));
+                }
+            });
+        }
         return resultList != null ? resultList : Collections.emptyList();
     }
 
@@ -386,4 +401,233 @@ public class BlockedDashboardServiceImpl implements IBlockedDashboardService {
         List<BlockedBrigadeCertificateDistributionDTO> resultList = blockedDashboardMapper.selectBrigadeCertificateDistribution(queryDTO);
         return resultList != null ? resultList : Collections.emptyList();
     }
+
+    /**
+     * 查询两楼每日查堵走势(按大队)
+     * 数据来源：各大队每日过检行李查堵数据收集表
+     * 先查出来是哪个安检大队的，然后按日期统计以下四个字段：
+     * T1旅检查堵件数、T2旅检查堵件数、T1行检查堵件数、T2行检查堵件数
+     * 
+     * @param queryDTO 查询参数
+     * @return 两楼每日查堵走势统计列表
+     */
+    @Override
+    public List<BlockedDailyBrigadeTerminalStatsDTO> getDailyBrigadeTerminalStats(BlockedDashboardQueryDTO queryDTO) {
+        List<BlockedDailyBrigadeTerminalStatsDTO> resultList = blockedDashboardMapper.selectDailyBrigadeTerminalStats(queryDTO);
+        return resultList != null ? resultList : Collections.emptyList();
+    }
+
+    /**
+     * 查询两楼每日过检图像数(按大队)
+     * 数据来源：各大队每日过检行李查堵数据收集表
+     * 先查出来是哪个安检大队的，然后按日期统计以下四个字段：
+     * T2旅检过检行李数、T1旅检过检行李数、T1行检过检行李数、T2行检过检行李数
+     * 
+     * @param queryDTO 查询参数
+     * @return 两楼每日过检图像数统计列表
+     */
+    @Override
+    public List<BlockedDailyBrigadeTerminalLuggageStatsDTO> getDailyBrigadeTerminalLuggageStats(BlockedDashboardQueryDTO queryDTO) {
+        List<BlockedDailyBrigadeTerminalLuggageStatsDTO> resultList = blockedDashboardMapper.selectDailyBrigadeTerminalLuggageStats(queryDTO);
+        return resultList != null ? resultList : Collections.emptyList();
+    }
+
+    /**
+     * 查询两楼查堵数（包含行检，按大队）
+     * 数据来源：漏检统计表
+     * 先查大队数量，再查T1、T2数量
+     * 
+     * @param queryDTO 查询参数
+     * @return 两楼查堵数统计
+     */
+    @Override
+    public BlockedTerminalStatsDTO getTerminalBlockedStats(BlockedDashboardQueryDTO queryDTO) {
+        return blockedDashboardMapper.selectTerminalBlockedStats(queryDTO);
+    }
+
+    /**
+     * 查询查堵时间段过检行李数(按大队)
+     * 数据源：每日各时间段过检行李数
+     * 维度(横轴)：时间段
+     * 统计值(左坐标轴)：过检行李数平均值
+     * 统计值(右坐标轴)：时段查堵件数平均值
+     * 
+     * @param queryDTO 查询参数
+     * @return 时间段过检行李数统计列表
+     */
+    @Override
+    public List<BlockedTimePeriodLuggageStatsDTO> getTimePeriodLuggageStats(BlockedDashboardQueryDTO queryDTO) {
+        List<BlockedTimePeriodLuggageStatsDTO> resultList = blockedDashboardMapper.selectTimePeriodLuggageStats(queryDTO);
+        return resultList != null ? resultList : Collections.emptyList();
+    }
+
+    /**
+     * 查询两楼每日查堵万分率(按大队)
+     * 数据源：各大队每日过检行李查堵数据收集表
+     * 按时间统计T2旅检万分率、T1旅检万分率、T1行检万分率、T2行检万分率
+     * 
+     * @param queryDTO 查询参数
+     * @return 两楼每日查堵万分率统计列表
+     */
+    @Override
+    public List<BlockedDailyBrigadeTerminalRateStatsDTO> getDailyBrigadeTerminalRateStats(BlockedDashboardQueryDTO queryDTO) {
+        List<BlockedDailyBrigadeTerminalRateStatsDTO> resultList = blockedDashboardMapper.selectDailyBrigadeTerminalRateStats(queryDTO);
+        return resultList != null ? resultList : Collections.emptyList();
+    }
+
+    /**
+     * 查询查堵-主管排行榜(大队维度,前10名)
+     * 数据源：漏检统计表
+     * 数据筛选：分管主管不为空
+     * 排行字段：分管主管
+     * 排行依据：统计记录总数
+     * 显示行数：显示前10行
+     * 
+     * @param queryDTO 查询参数
+     * @return 主管排行榜列表（前10名）
+     */
+    @Override
+    public List<BlockedRankingDTO> getBrigadeSupervisorRanking(BlockedDashboardQueryDTO queryDTO) {
+        List<BlockedRankingDTO> resultList = blockedDashboardMapper.selectBrigadeSupervisorRanking(queryDTO);
+        return resultList != null ? resultList : Collections.emptyList();
+    }
+
+    /**
+     * 查询查堵-班组排行榜(大队维度,前10名)
+     * 数据源：漏检统计表
+     * 数据筛选：分管班组长不为空
+     * 排行字段：分管班组长
+     * 排行依据：统计记录总数
+     * 显示行数：显示前10行
+     * 
+     * @param queryDTO 查询参数
+     * @return 班组排行榜列表（前10名）
+     */
+    @Override
+    public List<BlockedRankingDTO> getBrigadeTeamLeaderRanking(BlockedDashboardQueryDTO queryDTO) {
+        List<BlockedRankingDTO> resultList = blockedDashboardMapper.selectBrigadeTeamLeaderRanking(queryDTO);
+        return resultList != null ? resultList : Collections.emptyList();
+    }
+
+    /**
+     * 查询查堵-人员排行榜(大队维度,前10名)
+     * 数据源：漏检统计表
+     * 数据筛选：被回查人不为空
+     * 排行字段：被回查人
+     * 排行依据：统计记录总数
+     * 显示行数：显示前10行
+     * 
+     * @param queryDTO 查询参数
+     * @return 人员排行榜列表（前10名）
+     */
+    @Override
+    public List<BlockedRankingDTO> getBrigadeReviewedUserRanking(BlockedDashboardQueryDTO queryDTO) {
+        List<BlockedRankingDTO> resultList = blockedDashboardMapper.selectBrigadeReviewedUserRanking(queryDTO);
+        return resultList != null ? resultList : Collections.emptyList();
+    }
+
+    /**
+     * 查询查堵男女比例(按大队)
+     * 数据源：漏检统计表
+     * 统计性别分布
+     * 
+     * @param queryDTO 查询参数
+     * @return 男女比例统计列表
+     */
+    @Override
+    public List<BlockedGenderDistributionDTO> getGenderDistribution(BlockedDashboardQueryDTO queryDTO) {
+        List<BlockedGenderDistributionDTO> resultList = blockedDashboardMapper.selectGenderDistribution(queryDTO);
+        return resultList != null ? resultList : Collections.emptyList();
+    }
+
+    /**
+     * 查询查堵人员证书级别分布(按大队)
+     * 数据源：漏检统计表
+     * 统计证书级别分布
+     * 
+     * @param queryDTO 查询参数
+     * @return 证书级别分布统计列表
+     */
+    @Override
+    public List<BlockedCertificateLevelDistributionDTO> getCertificateLevelDistribution(BlockedDashboardQueryDTO queryDTO) {
+        List<BlockedCertificateLevelDistributionDTO> resultList = blockedDashboardMapper.selectCertificateLevelDistribution(queryDTO);
+        return resultList != null ? resultList : Collections.emptyList();
+    }
+
+    /**
+     * 查询证书级别人员基数(分大队统计)
+     * 数据源：用户表(sys_user) + 部门表(sys_dept)
+     * 统计大队人员里面的人员证书级别构成
+     * 
+     * @param queryDTO 查询参数（大队ID必填）
+     * @return 证书级别人员基数统计列表
+     */
+    @Override
+    public List<BlockedCertificateLevelDistributionDTO> getBrigadePersonnelCertificateBase(BlockedDashboardQueryDTO queryDTO) {
+        List<BlockedCertificateLevelDistributionDTO> resultList = blockedDashboardMapper.selectBrigadePersonnelCertificateBase(queryDTO);
+        if (resultList != null && !resultList.isEmpty()) {
+            // 转换证书级别为中文
+            resultList.forEach(item -> {
+                if (item.getCertificateLevel() != null) {
+                    item.setCertificateLevel(convertCertificateLevel(item.getCertificateLevel()));
+                }
+            });
+        }
+        return resultList != null ? resultList : Collections.emptyList();
+    }
+
+    /**
+     * 查询查堵-主管分管次数分布(用于饼图)
+     * 数据源：漏检统计表
+     * 统计字段：分管主管
+     * 
+     * @param queryDTO 查询参数
+     * @return 主管分管次数分布统计列表
+     */
+    @Override
+    public List<BlockedRankingDTO> getSupervisorDistribution(BlockedDashboardQueryDTO queryDTO) {
+        List<BlockedRankingDTO> resultList = blockedDashboardMapper.selectSupervisorDistribution(queryDTO);
+        return resultList != null ? resultList : Collections.emptyList();
+    }
+
+    /**
+     * 查询查堵人员开机年限分布(用于饼图)
+     * 数据源：漏检统计表
+     * 统计字段：开机年限
+     * 
+     * @param queryDTO 查询参数
+     * @return 开机年限分布统计列表
+     */
+    @Override
+    public List<BlockedOperatingYearsDistributionDTO> getOperatingYearsDistribution(BlockedDashboardQueryDTO queryDTO) {
+        List<BlockedOperatingYearsDistributionDTO> resultList = blockedDashboardMapper.selectOperatingYearsDistribution(queryDTO);
+        return resultList != null ? resultList : Collections.emptyList();
+    }
+
+    /**
+     * 转换证书级别代码为中文
+     * LEVEL_FIVE -> 初级
+     * LEVEL_FOUR -> 中级
+     * LEVEL_ONE/LEVEL_TWO/LEVEL_THREE -> 高级
+     * 
+     * @param levelCode 级别代码
+     * @return 中文级别名称
+     */
+    private String convertCertificateLevel(String levelCode) {
+        if (levelCode == null) {
+            return "";
+        }
+        switch (levelCode) {
+            case "LEVEL_FIVE":
+                return "初级";
+            case "LEVEL_FOUR":
+                return "中级";
+            case "LEVEL_ONE":
+            case "LEVEL_TWO":
+            case "LEVEL_THREE":
+                return "高级";
+            default:
+                return levelCode;
+        }
+    }
 }

airport-blocked/src/main/resources/mapper/blocked/BlockedDashboardMapper.xml

@@ -474,6 +474,9 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
             AND review_date >= #{startTime}
             AND review_date <= #{endTime}
         </if>
+        <if test="brigadeId != null">
+            AND brigade_id = #{brigadeId}
+        </if>
         GROUP BY difficulty_level
         ORDER BY count DESC
     </select>
@@ -530,4 +533,274 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         ORDER BY totalCount DESC
     </select>
 
+    <!-- 查询两楼每日查堵走势(按大队) -->
+    <select id="selectDailyBrigadeTerminalStats" resultType="com.sundot.airport.blocked.dto.BlockedDailyBrigadeTerminalStatsDTO">
+        SELECT 
+            stat_date as statDate,
+            COALESCE(SUM(t1_travel_blocked_count), 0) as t1TravelBlockedCount,
+            COALESCE(SUM(t2_travel_blocked_count), 0) as t2TravelBlockedCount,
+            COALESCE(SUM(t1_walk_blocked_count), 0) as t1WalkBlockedCount,
+            COALESCE(SUM(t2_walk_blocked_count), 0) as t2WalkBlockedCount
+        FROM blocked_luggage_statistics_daily
+        WHERE del_flag = '0'
+        <if test="brigadeId != null">
+            AND brigade_id = #{brigadeId}
+        </if>
+        <if test="startTime != null and endTime != null">
+            AND stat_date &gt;= #{startTime}
+            AND stat_date &lt;= #{endTime}
+        </if>
+        GROUP BY stat_date
+        ORDER BY stat_date ASC
+    </select>
+
+    <!-- 查询两楼每日过检图像数(按大队) -->
+    <select id="selectDailyBrigadeTerminalLuggageStats" resultType="com.sundot.airport.blocked.dto.BlockedDailyBrigadeTerminalLuggageStatsDTO">
+        SELECT 
+            stat_date as statDate,
+            COALESCE(SUM(t1_travel_luggage_count), 0) as t1TravelBagCount,
+            COALESCE(SUM(t2_travel_luggage_count), 0) as t2TravelBagCount,
+            COALESCE(SUM(t1_walk_luggage_count), 0) as t1WalkBagCount,
+            COALESCE(SUM(t2_walk_luggage_count), 0) as t2WalkBagCount
+        FROM blocked_luggage_statistics_daily
+        WHERE del_flag = '0'
+        <if test="brigadeId != null">
+            AND brigade_id = #{brigadeId}
+        </if>
+        <if test="startTime != null and endTime != null">
+            AND stat_date &gt;= #{startTime}
+            AND stat_date &lt;= #{endTime}
+        </if>
+        GROUP BY stat_date
+        ORDER BY stat_date ASC
+    </select>
+
+    <!-- 查询两楼查堵数（包含行检，按大队） -->
+    <select id="selectTerminalBlockedStats" resultType="com.sundot.airport.blocked.dto.BlockedTerminalStatsDTO">
+        SELECT 
+            COUNT(1) as totalBlockedCount,
+            COALESCE(SUM(CASE WHEN terminal_id = 1 THEN 1 ELSE 0 END), 0) as t1BlockedCount,
+            COALESCE(SUM(CASE WHEN terminal_id = 2 THEN 1 ELSE 0 END), 0) as t2BlockedCount
+        FROM blocked_miss_check_statistics
+        WHERE del_flag = '0'
+        <if test="brigadeId != null">
+            AND brigade_id = #{brigadeId}
+        </if>
+        <if test="startTime != null and endTime != null">
+            AND review_date &gt;= #{startTime}
+            AND review_date &lt;= #{endTime}
+        </if>
+    </select>
+
+    <!-- 查询查堵时间段过检行李数(按大队) -->
+    <select id="selectTimePeriodLuggageStats" resultType="com.sundot.airport.blocked.dto.BlockedTimePeriodLuggageStatsDTO">
+        SELECT 
+            time_period as timePeriod,
+            ROUND(AVG(total_luggage_count), 2) as avgLuggageCount,
+            ROUND(AVG(total_blocked_count), 2) as avgBlockedCount
+        FROM blocked_luggage_piece_daily
+        WHERE del_flag = '0'
+        <if test="brigadeId != null">
+            AND brigade_id = #{brigadeId}
+        </if>
+        <if test="startTime != null and endTime != null">
+            AND stat_date &gt;= #{startTime}
+            AND stat_date &lt;= #{endTime}
+        </if>
+        GROUP BY time_period
+        ORDER BY time_period ASC
+    </select>
+
+    <!-- 查询两楼每日查堵万分率(按大队) -->
+    <select id="selectDailyBrigadeTerminalRateStats" resultType="com.sundot.airport.blocked.dto.BlockedDailyBrigadeTerminalRateStatsDTO">
+        SELECT 
+            stat_date as statDate,
+            COALESCE(AVG(t1_travel_block_rate), 0) as t1TravelBlockRate,
+            COALESCE(AVG(t2_travel_block_rate), 0) as t2TravelBlockRate,
+            COALESCE(AVG(t1_walk_block_rate), 0) as t1WalkBlockRate,
+            COALESCE(AVG(t2_walk_block_rate), 0) as t2WalkBlockRate
+        FROM blocked_luggage_statistics_daily
+        WHERE del_flag = '0'
+        <if test="brigadeId != null">
+            AND brigade_id = #{brigadeId}
+        </if>
+        <if test="startTime != null and endTime != null">
+            AND stat_date &gt;= #{startTime}
+            AND stat_date &lt;= #{endTime}
+        </if>
+        GROUP BY stat_date
+        ORDER BY stat_date ASC
+    </select>
+
+    <!-- 查询查堵-主管排行榜(大队维度,前10名) -->
+    <select id="selectBrigadeSupervisorRanking" resultType="com.sundot.airport.blocked.dto.BlockedRankingDTO">
+        SELECT 
+            supervisor_name as name,
+            supervisor_id as id,
+            COUNT(1) as totalCount
+        FROM blocked_miss_check_statistics
+        WHERE del_flag = '0'
+        AND supervisor_name IS NOT NULL
+        AND supervisor_name != ''
+        <if test="brigadeId != null">
+            AND brigade_id = #{brigadeId}
+        </if>
+        <if test="startTime != null and endTime != null">
+            AND review_date &gt;= #{startTime}
+            AND review_date &lt;= #{endTime}
+        </if>
+        GROUP BY supervisor_id, supervisor_name
+        ORDER BY totalCount DESC
+        LIMIT 10
+    </select>
+
+    <!-- 查询查堵-班组排行榜(大队维度,前10名) -->
+    <select id="selectBrigadeTeamLeaderRanking" resultType="com.sundot.airport.blocked.dto.BlockedRankingDTO">
+        SELECT 
+            team_leader_name as name,
+            team_leader_id as id,
+            COUNT(1) as totalCount
+        FROM blocked_miss_check_statistics
+        WHERE del_flag = '0'
+        AND team_leader_name IS NOT NULL
+        AND team_leader_name != ''
+        <if test="brigadeId != null">
+            AND brigade_id = #{brigadeId}
+        </if>
+        <if test="startTime != null and endTime != null">
+            AND review_date &gt;= #{startTime}
+            AND review_date &lt;= #{endTime}
+        </if>
+        GROUP BY team_leader_id, team_leader_name
+        ORDER BY totalCount DESC
+        LIMIT 10
+    </select>
+
+    <!-- 查询查堵-人员排行榜(大队维度,前10名) -->
+    <select id="selectBrigadeReviewedUserRanking" resultType="com.sundot.airport.blocked.dto.BlockedRankingDTO">
+        SELECT 
+            reviewed_user_name as name,
+            reviewed_user_id as id,
+            COUNT(1) as totalCount
+        FROM blocked_miss_check_statistics
+        WHERE del_flag = '0'
+        AND reviewed_user_name IS NOT NULL
+        AND reviewed_user_name != ''
+        <if test="brigadeId != null">
+            AND brigade_id = #{brigadeId}
+        </if>
+        <if test="startTime != null and endTime != null">
+            AND review_date &gt;= #{startTime}
+            AND review_date &lt;= #{endTime}
+        </if>
+        GROUP BY reviewed_user_id, reviewed_user_name
+        ORDER BY totalCount DESC
+        LIMIT 10
+    </select>
+
+    <!-- 查询查堵男女比例(按大队) -->
+    <select id="selectGenderDistribution" resultType="com.sundot.airport.blocked.dto.BlockedGenderDistributionDTO">
+        SELECT 
+            gender as gender,
+            COUNT(1) as count,
+            ROUND(COUNT(1) * 100.0 / SUM(COUNT(1)) OVER(), 2) as percentage
+        FROM blocked_miss_check_statistics
+        WHERE del_flag = '0'
+        AND gender IS NOT NULL
+        AND gender != ''
+        <if test="brigadeId != null">
+            AND brigade_id = #{brigadeId}
+        </if>
+        <if test="startTime != null and endTime != null">
+            AND review_date &gt;= #{startTime}
+            AND review_date &lt;= #{endTime}
+        </if>
+        GROUP BY gender
+        ORDER BY count DESC
+    </select>
+
+    <!-- 查询查堵人员证书级别分布(按大队) -->
+    <select id="selectCertificateLevelDistribution" resultType="com.sundot.airport.blocked.dto.BlockedCertificateLevelDistributionDTO">
+        SELECT 
+            certificate_level as certificateLevel,
+            COUNT(1) as count,
+            ROUND(COUNT(1) * 100.0 / SUM(COUNT(1)) OVER(), 2) as percentage
+        FROM blocked_miss_check_statistics
+        WHERE del_flag = '0'
+        AND certificate_level IS NOT NULL
+        AND certificate_level != ''
+        <if test="brigadeId != null">
+            AND brigade_id = #{brigadeId}
+        </if>
+        <if test="startTime != null and endTime != null">
+            AND review_date &gt;= #{startTime}
+            AND review_date &lt;= #{endTime}
+        </if>
+        GROUP BY certificate_level
+        ORDER BY count DESC
+    </select>
+
+    <!-- 查询证书级别人员基数(分大队统计) -->
+    <select id="selectBrigadePersonnelCertificateBase" resultType="com.sundot.airport.blocked.dto.BlockedCertificateLevelDistributionDTO">
+        SELECT 
+            u.qualification_level as certificateLevel,
+            COUNT(DISTINCT u.user_id) as count,
+            ROUND(COUNT(DISTINCT u.user_id) * 100.0 / SUM(COUNT(DISTINCT u.user_id)) OVER(), 2) as percentage
+        FROM sys_user u
+        INNER JOIN sys_dept d ON u.dept_id = d.dept_id
+        WHERE u.del_flag = '0'
+        AND u.status = '0'
+        AND u.qualification_level IS NOT NULL
+        AND u.qualification_level != ''
+        AND d.dept_type = 'BRIGADE'
+        <if test="brigadeId != null">
+            AND d.dept_id = #{brigadeId}
+        </if>
+        GROUP BY u.qualification_level
+        ORDER BY count DESC
+    </select>
+
+    <!-- 查询查堵-主管分管次数分布(用于饼图) -->
+    <select id="selectSupervisorDistribution" resultType="com.sundot.airport.blocked.dto.BlockedRankingDTO">
+        SELECT 
+            supervisor_name as name,
+            supervisor_id as id,
+            COUNT(1) as totalCount,
+            ROUND(COUNT(1) * 100.0 / SUM(COUNT(1)) OVER(), 2) as percentage
+        FROM blocked_miss_check_statistics
+        WHERE del_flag = '0'
+        AND supervisor_name IS NOT NULL
+        AND supervisor_name != ''
+        <if test="brigadeId != null">
+            AND brigade_id = #{brigadeId}
+        </if>
+        <if test="startTime != null and endTime != null">
+            AND review_date &gt;= #{startTime}
+            AND review_date &lt;= #{endTime}
+        </if>
+        GROUP BY supervisor_id, supervisor_name
+        ORDER BY totalCount DESC
+    </select>
+
+    <!-- 查询查堵人员开机年限分布(用于饼图) -->
+    <select id="selectOperatingYearsDistribution" resultType="com.sundot.airport.blocked.dto.BlockedOperatingYearsDistributionDTO">
+        SELECT 
+            machine_operating_years as operatingYears,
+            COUNT(1) as count,
+            ROUND(COUNT(1) * 100.0 / SUM(COUNT(1)) OVER(), 2) as percentage
+        FROM blocked_miss_check_statistics
+        WHERE del_flag = '0'
+        AND machine_operating_years IS NOT NULL
+        AND machine_operating_years != ''
+        <if test="brigadeId != null">
+            AND brigade_id = #{brigadeId}
+        </if>
+        <if test="startTime != null and endTime != null">
+            AND review_date &gt;= #{startTime}
+            AND review_date &lt;= #{endTime}
+        </if>
+        GROUP BY machine_operating_years
+        ORDER BY count DESC
+    </select>
+
 </mapper>