预警页面

airport-admin/src/main/java/com/sundot/airport/web/controller/ledger/LedgerWarningController.java

@@ -0,0 +1,43 @@
+package com.sundot.airport.web.controller.ledger;
+
+import com.sundot.airport.common.core.controller.BaseController;
+import com.sundot.airport.common.core.domain.AjaxResult;
+import com.sundot.airport.common.dto.LedgerCommonQueryReqVO;
+import com.sundot.airport.ledger.domain.vo.LedgerWarningDetailVO;
+import com.sundot.airport.ledger.domain.vo.LedgerWarningVO;
+import com.sundot.airport.ledger.service.ILedgerWarningService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * 预警页面控制器
+ */
+@RestController
+@RequestMapping("/ledger/warning")
+public class LedgerWarningController extends BaseController {
+
+    @Autowired
+    private ILedgerWarningService ledgerWarningService;
+
+    /**
+     * 台账数据
+     */
+    @PostMapping("/ledger")
+    public AjaxResult ledger(@RequestBody LedgerCommonQueryReqVO queryReq) {
+        LedgerWarningVO result = ledgerWarningService.ledger(queryReq);
+        return AjaxResult.success(result);
+    }
+
+    /**
+     * 员工综合评估预警看板
+     */
+    @PostMapping("/ledgerDetail")
+    public AjaxResult ledgerDetail(@RequestBody LedgerCommonQueryReqVO queryReq) {
+        LedgerWarningDetailVO result = ledgerWarningService.ledgerDetail(queryReq);
+        return AjaxResult.success(result);
+    }
+
+}

airport-common/src/main/java/com/sundot/airport/common/enums/LedgerAlertLevelEnum.java

@@ -0,0 +1,29 @@
+package com.sundot.airport.common.enums;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+/**
+ * 预警等级枚举
+ */
+@Getter
+@AllArgsConstructor
+public enum LedgerAlertLevelEnum {
+
+    RED_ALERT("1", "红色预警"),
+    EXCELLENT_BENCHMARK("2", "优秀标杆"),
+    NORMAL_RANGE("3", "正常范围");
+
+    private final String code;
+    private final String desc;
+
+    public static LedgerAlertLevelEnum getByCode(String code) {
+        for (LedgerAlertLevelEnum itemEnum : values()) {
+            if (itemEnum.getCode().equals(code)) {
+                return itemEnum;
+            }
+        }
+        return null;
+    }
+
+}

airport-common/src/main/java/com/sundot/airport/common/enums/LedgerStatusLabelEnum.java

@@ -0,0 +1,29 @@
+package com.sundot.airport.common.enums;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+/**
+ * 状态标签枚举
+ */
+@Getter
+@AllArgsConstructor
+public enum LedgerStatusLabelEnum {
+
+    EMERGENCY_INTERVENTION("1", "紧急干预"),
+    COMMENDATION_AND_MOTIVATION("2", "表彰激励"),
+    REGULAR_COACHING("3", "常规辅导");
+
+    private final String code;
+    private final String desc;
+
+    public static LedgerStatusLabelEnum getByCode(String code) {
+        for (LedgerStatusLabelEnum itemEnum : values()) {
+            if (itemEnum.getCode().equals(code)) {
+                return itemEnum;
+            }
+        }
+        return null;
+    }
+
+}

airport-ledger/src/main/java/com/sundot/airport/ledger/domain/vo/LedgerWarningDetailItemVO.java

@@ -0,0 +1,49 @@
+package com.sundot.airport.ledger.domain.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+
+/**
+ * 预警信息详情明细
+ */
+@Data
+public class LedgerWarningDetailItemVO implements Serializable {
+    /**
+     * 员工ID
+     */
+    private Long userId;
+    /**
+     * 员工账号
+     */
+    private String userName;
+    /**
+     * 员工昵称
+     */
+    private String nickName;
+    /**
+     * 所属部门ID
+     */
+    private Long deptId;
+    /**
+     * 所属部门名称
+     */
+    private String deptName;
+    /**
+     * 综合评估得分
+     */
+    private BigDecimal overallScore;
+    /**
+     * 预警等级
+     */
+    private String warningLevel;
+    /**
+     * 状态标签
+     */
+    private String statusLabel;
+    /**
+     * 核心风险/优秀事迹
+     */
+    private String coreRisksOrOutstandingAchievements;
+}

airport-ledger/src/main/java/com/sundot/airport/ledger/domain/vo/LedgerWarningDetailVO.java

@@ -0,0 +1,31 @@
+package com.sundot.airport.ledger.domain.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.util.List;
+
+/**
+ * 预警信息详情
+ */
+@Data
+public class LedgerWarningDetailVO implements Serializable {
+    /**
+     * 红色预警人数
+     */
+    private Integer redAlertNum;
+    /**
+     * 优秀标杆人数
+     */
+    private Integer excellentBenchmarkNum;
+    /**
+     * 全员平均综合得分
+     */
+    private BigDecimal averageComprehensiveScore;
+    /**
+     * 预警信息详情明细列表
+     */
+    private List<LedgerWarningDetailItemVO> ledgerWarningDetailItemList;
+
+}

airport-ledger/src/main/java/com/sundot/airport/ledger/domain/vo/LedgerWarningVO.java

@@ -0,0 +1,48 @@
+package com.sundot.airport.ledger.domain.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 预警信息
+ */
+@Data
+public class LedgerWarningVO implements Serializable {
+    /**
+     * 部门监察问题
+     */
+    private Integer ledgerSupervisionProblem;
+    /**
+     * 实时质控拦截
+     */
+    private Integer ledgerRealtimeInterception;
+    /**
+     * 不安全事件
+     */
+    private Integer ledgerUnsafeEvent;
+    /**
+     * 安保测试记录
+     */
+    private Integer ledgerSecurityTest;
+    /**
+     * 旅客服务投诉
+     */
+    private Integer ledgerComplaint;
+    /**
+     * 服务巡查
+     */
+    private Integer ledgerServicePatrol;
+    /**
+     * 航站楼
+     */
+    private Integer ledgerTerminalBonus;
+    /**
+     * 小额奖励
+     */
+    private Integer ledgerRewardApproval;
+    /**
+     * 考试成绩
+     */
+    private Integer ledgerExamScore;
+}

airport-ledger/src/main/java/com/sundot/airport/ledger/mapper/LedgerWarningMapper.java

@@ -0,0 +1,65 @@
+package com.sundot.airport.ledger.mapper;
+
+import com.sundot.airport.common.dto.LedgerCommonQueryReqVO;
+import com.sundot.airport.ledger.domain.ScoreEvent;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * 预警页面Mapper接口
+ */
+public interface LedgerWarningMapper {
+
+    /**
+     * 部门监察问题
+     */
+    Integer selectLedgerSupervisionProblem(LedgerCommonQueryReqVO query);
+
+    /**
+     * 实时质控拦截
+     */
+    Integer selectLedgerRealtimeInterception(LedgerCommonQueryReqVO query);
+
+    /**
+     * 不安全事件
+     */
+    Integer selectLedgerUnsafeEvent(LedgerCommonQueryReqVO query);
+
+    /**
+     * 安保测试记录
+     */
+    Integer selectLedgerSecurityTest(LedgerCommonQueryReqVO query);
+
+    /**
+     * 旅客服务投诉
+     */
+    Integer selectLedgerComplaint(LedgerCommonQueryReqVO query);
+
+    /**
+     * 服务巡查
+     */
+    Integer selectLedgerServicePatrol(LedgerCommonQueryReqVO query);
+
+    /**
+     * 航站楼
+     */
+    Integer selectLedgerTerminalBonus(LedgerCommonQueryReqVO query);
+
+    /**
+     * 小额奖励
+     */
+    Integer selectLedgerRewardApproval(LedgerCommonQueryReqVO query);
+
+    /**
+     * 考试成绩
+     */
+    Integer selectLedgerExamScore(LedgerCommonQueryReqVO query);
+
+    /**
+     * 配分事项列表
+     */
+    List<ScoreEvent> selectScoreEventList(@Param("startDate") Date startDate, @Param("endDate") Date endDate, @Param("scoreIndicatorIdList") List<Long> scoreIndicatorIdList, @Param("userIdList") List<Long> userIdList);
+
+}

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

@@ -0,0 +1,22 @@
+package com.sundot.airport.ledger.service;
+
+import com.sundot.airport.common.dto.LedgerCommonQueryReqVO;
+import com.sundot.airport.ledger.domain.vo.LedgerWarningDetailVO;
+import com.sundot.airport.ledger.domain.vo.LedgerWarningVO;
+
+/**
+ * 预警页面服务
+ */
+public interface ILedgerWarningService {
+
+    /**
+     * 台账数据
+     */
+    LedgerWarningVO ledger(LedgerCommonQueryReqVO queryReq);
+
+    /**
+     * 员工综合评估预警看板
+     */
+    LedgerWarningDetailVO ledgerDetail(LedgerCommonQueryReqVO queryReq);
+
+}

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

@@ -0,0 +1,260 @@
+package com.sundot.airport.ledger.service.impl;
+
+import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.date.DateUtil;
+import cn.hutool.core.util.ObjUtil;
+import cn.hutool.core.util.StrUtil;
+import com.sundot.airport.common.core.domain.entity.SysDept;
+import com.sundot.airport.common.core.domain.entity.SysUser;
+import com.sundot.airport.common.dto.LedgerCommonQueryReqVO;
+import com.sundot.airport.common.enums.DeptTypeEnum;
+import com.sundot.airport.common.enums.LedgerAlertLevelEnum;
+import com.sundot.airport.common.enums.LedgerStatusLabelEnum;
+import com.sundot.airport.common.enums.ScoreLevelEnum;
+import com.sundot.airport.common.utils.DeptUtils;
+import com.sundot.airport.common.utils.SecurityUtils;
+import com.sundot.airport.ledger.domain.ScoreEvent;
+import com.sundot.airport.ledger.domain.ScoreIndicator;
+import com.sundot.airport.ledger.domain.vo.LedgerWarningDetailItemVO;
+import com.sundot.airport.ledger.domain.vo.LedgerWarningDetailVO;
+import com.sundot.airport.ledger.domain.vo.LedgerWarningVO;
+import com.sundot.airport.ledger.mapper.LedgerWarningMapper;
+import com.sundot.airport.ledger.service.IEmployeePortraitService;
+import com.sundot.airport.ledger.service.ILedgerWarningService;
+import com.sundot.airport.ledger.service.IScoreIndicatorService;
+import com.sundot.airport.system.service.ISysDeptService;
+import com.sundot.airport.system.service.ISysUserService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.math.BigDecimal;
+import java.math.RoundingMode;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.stream.Collectors;
+
+/**
+ * 预警页面服务
+ */
+@Service
+public class LedgerWarningServiceImpl implements ILedgerWarningService {
+
+    @Autowired
+    private LedgerWarningMapper ledgerWarningMapper;
+
+    @Autowired
+    private IEmployeePortraitService employeePortraitService;
+
+    @Autowired
+    private IScoreIndicatorService scoreIndicatorService;
+
+    @Autowired
+    private ISysDeptService sysDeptService;
+
+    @Autowired
+    private ISysUserService sysUserService;
+
+    /**
+     * 台账数据
+     */
+    @Override
+    public LedgerWarningVO ledger(LedgerCommonQueryReqVO queryReq) {
+        LedgerWarningVO result = new LedgerWarningVO();
+        result.setLedgerSupervisionProblem(ledgerWarningMapper.selectLedgerSupervisionProblem(queryReq));
+        result.setLedgerRealtimeInterception(ledgerWarningMapper.selectLedgerRealtimeInterception(queryReq));
+        result.setLedgerUnsafeEvent(ledgerWarningMapper.selectLedgerUnsafeEvent(queryReq));
+        result.setLedgerSecurityTest(ledgerWarningMapper.selectLedgerSecurityTest(queryReq));
+        result.setLedgerComplaint(ledgerWarningMapper.selectLedgerComplaint(queryReq));
+        result.setLedgerServicePatrol(ledgerWarningMapper.selectLedgerServicePatrol(queryReq));
+        result.setLedgerTerminalBonus(ledgerWarningMapper.selectLedgerTerminalBonus(queryReq));
+        result.setLedgerRewardApproval(ledgerWarningMapper.selectLedgerRewardApproval(queryReq));
+        result.setLedgerExamScore(ledgerWarningMapper.selectLedgerExamScore(queryReq));
+        return result;
+    }
+
+    /**
+     * 台账数据
+     */
+    @Override
+    public LedgerWarningDetailVO ledgerDetail(LedgerCommonQueryReqVO queryReq) {
+        List<String> scoreIndicatorNameList = Arrays.asList("员工规范化操作", "后台实时质控拦截", "不安全事件", "安保测试未通过", "旅客服务投诉", "服务监察", "典型服务案例", "典型案例查获", "考试成绩");
+        Map<String, String> unitMap = new HashMap<>();
+        unitMap.put("员工规范化操作", "项");
+        unitMap.put("后台实时质控拦截", "次");
+        unitMap.put("不安全事件", "起");
+        unitMap.put("安保测试未通过", "项");
+        unitMap.put("旅客服务投诉", "件");
+        unitMap.put("服务监察", "项");
+        unitMap.put("典型服务案例", "次");
+        unitMap.put("典型案例查获", "次");
+        unitMap.put("考试成绩", "次");
+
+        Long topSiteId = DeptUtils.getTopSiteId(sysDeptService.selectDeptById(SecurityUtils.getDeptId()));
+        // 获取所有部门信息
+        Map<Long, SysDept> deptMap = getDeptMap();
+        // 构建大队到其所有子部门ID的映射
+        Map<Long, Set<Long>> brigadeSubDeptsMap = buildBrigadeSubDeptsMap(getDeptMap());
+
+        LedgerWarningDetailVO result = new LedgerWarningDetailVO();
+        ScoreIndicator scoreIndicatorQuery = new ScoreIndicator();
+        scoreIndicatorQuery.setStatus("0");
+        scoreIndicatorQuery.setOrg(ScoreLevelEnum.PERSON.getCode());
+        scoreIndicatorQuery.setLevel(2);
+        List<ScoreIndicator> scoreIndicatorList = scoreIndicatorService.selectList(scoreIndicatorQuery);
+        scoreIndicatorList = scoreIndicatorList.stream().filter(scoreIndicator -> scoreIndicatorNameList.contains(scoreIndicator.getName())).collect(Collectors.toList());
+        List<Long> scoreIndicatorIdList = scoreIndicatorList.stream().map(ScoreIndicator::getId).collect(Collectors.toList());
+        List<Long> userIdList = new ArrayList<>();
+        List<String> userNameList = new ArrayList<>();
+        Map<Long, SysUser> sysUserMap = new HashMap<>();
+        if (ObjUtil.isNotNull(queryReq.getUserId())) {
+            userIdList.add(queryReq.getUserId());
+            SysUser sysUser = sysUserService.selectUserById(queryReq.getUserId());
+            userNameList.add(sysUser.getNickName());
+            sysUserMap.put(queryReq.getUserId(), sysUser);
+        } else {
+            Long targetDeptId = ObjUtil.isNotNull(queryReq.getGroupId()) ? queryReq.getGroupId()
+                    : ObjUtil.isNotNull(queryReq.getTeamId()) ? queryReq.getTeamId()
+                    : ObjUtil.isNotNull(queryReq.getDeptId()) ? queryReq.getDeptId()
+                    : topSiteId;
+            List<SysUser> sysUserList = sysUserService.selectUserByDeptId(targetDeptId);
+            userIdList.addAll(sysUserList.stream().map(SysUser::getUserId).collect(Collectors.toList()));
+            userNameList.addAll(sysUserList.stream().map(SysUser::getNickName).collect(Collectors.toList()));
+            sysUserMap.putAll(sysUserList.stream().collect(Collectors.toMap(SysUser::getUserId, user -> user)));
+        }
+        Map<String, BigDecimal> overallScoreMap = employeePortraitService.getPortraitTotalScore(userNameList, DateUtil.formatDate(queryReq.getStartDate()), DateUtil.formatDate(queryReq.getEndDate()));
+        List<ScoreEvent> scoreEventList = ledgerWarningMapper.selectScoreEventList(queryReq.getStartDate(), queryReq.getEndDate(), scoreIndicatorIdList, userIdList);
+//        // 由于person_name存在多用户时person_id为空,因此不能根据person_id进行分组处理数据
+//        Map<Long, List<ScoreEvent>> scoreEventMap = scoreEventList.stream().collect(Collectors.groupingBy(ScoreEvent::getPersonId));
+        List<LedgerWarningDetailItemVO> ledgerWarningDetailItemList = new ArrayList<>();
+        userIdList.forEach(userId -> {
+            LedgerWarningDetailItemVO ledgerWarningDetailItem = new LedgerWarningDetailItemVO();
+            SysUser sysUser = sysUserMap.get(userId);
+            ledgerWarningDetailItem.setUserId(sysUser.getUserId());
+            ledgerWarningDetailItem.setUserName(sysUser.getUserName());
+            ledgerWarningDetailItem.setNickName(sysUser.getNickName());
+            ledgerWarningDetailItem.setDeptId(sysUser.getDeptId());
+            SysDept dept = deptMap.get(findUserBrigade(sysUser.getDeptId(), brigadeSubDeptsMap));
+            if (ObjUtil.isNotNull(dept)) {
+                ledgerWarningDetailItem.setDeptName(dept.getDeptName());
+            }
+            BigDecimal overallScore = overallScoreMap.get(sysUser.getNickName());
+            ledgerWarningDetailItem.setOverallScore(overallScore);
+            if (ledgerWarningDetailItem.getOverallScore().compareTo(BigDecimal.valueOf(75)) < 0) {
+                ledgerWarningDetailItem.setWarningLevel(LedgerAlertLevelEnum.RED_ALERT.getCode());
+                ledgerWarningDetailItem.setStatusLabel(LedgerStatusLabelEnum.EMERGENCY_INTERVENTION.getCode());
+            } else if (ledgerWarningDetailItem.getOverallScore().compareTo(BigDecimal.valueOf(90)) >= 0) {
+                ledgerWarningDetailItem.setWarningLevel(LedgerAlertLevelEnum.EXCELLENT_BENCHMARK.getCode());
+                ledgerWarningDetailItem.setStatusLabel(LedgerStatusLabelEnum.COMMENDATION_AND_MOTIVATION.getCode());
+            } else {
+                ledgerWarningDetailItem.setWarningLevel(LedgerAlertLevelEnum.NORMAL_RANGE.getCode());
+                ledgerWarningDetailItem.setStatusLabel(LedgerStatusLabelEnum.REGULAR_COACHING.getCode());
+            }
+//            // 由于person_name存在多用户时person_id为空,因此不能根据person_id进行分组处理数据
+//            List<ScoreEvent> userScoreEventList = scoreEventMap.get(userId);
+            List<ScoreEvent> userScoreEventList = scoreEventList.stream()
+                    .filter(scoreEvent -> {
+                        if (ObjUtil.isNull(scoreEvent.getDimensionId()) || StrUtil.isEmpty(scoreEvent.getPersonName())) {
+                            return false;
+                        }
+                        boolean matched = false;
+                        for (String n : scoreEvent.getPersonName().split("[,，]")) {
+                            if (sysUser.getNickName().equals(n.trim())) {
+                                matched = true;
+                                break;
+                            }
+                        }
+                        return matched;
+                    })
+                    .collect(Collectors.toList());
+            if (CollUtil.isNotEmpty(userScoreEventList)) {
+                Map<String, Integer> userScoreEventCountMap = userScoreEventList.stream().collect(Collectors.groupingBy(ScoreEvent::getLevel2Name, Collectors.summingInt(e -> 1)));
+                String coreRisksOrOutstandingAchievements = userScoreEventCountMap.entrySet().stream()
+                        .map(entry -> entry.getKey() + entry.getValue() + unitMap.get(entry.getKey()))
+                        .collect(Collectors.joining(","));
+                ledgerWarningDetailItem.setCoreRisksOrOutstandingAchievements(coreRisksOrOutstandingAchievements);
+            }
+            ledgerWarningDetailItemList.add(ledgerWarningDetailItem);
+        });
+        List<LedgerWarningDetailItemVO> redAlertList = ledgerWarningDetailItemList.stream().filter(item -> StrUtil.equals(LedgerAlertLevelEnum.RED_ALERT.getCode(), item.getWarningLevel())).collect(Collectors.toList());
+        List<LedgerWarningDetailItemVO> excellentBenchmarkList = ledgerWarningDetailItemList.stream().filter(item -> StrUtil.equals(LedgerAlertLevelEnum.EXCELLENT_BENCHMARK.getCode(), item.getWarningLevel())).collect(Collectors.toList());
+        result.setRedAlertNum(redAlertList.size());
+        result.setExcellentBenchmarkNum(excellentBenchmarkList.size());
+        BigDecimal sum = ledgerWarningDetailItemList.stream().map(LedgerWarningDetailItemVO::getOverallScore).reduce(BigDecimal.ZERO, BigDecimal::add);
+        BigDecimal averageComprehensiveScore = CollUtil.isEmpty(ledgerWarningDetailItemList) ? BigDecimal.ZERO : sum.divide(BigDecimal.valueOf(ledgerWarningDetailItemList.size()), 2, RoundingMode.HALF_UP);
+        result.setAverageComprehensiveScore(averageComprehensiveScore);
+        result.setLedgerWarningDetailItemList(ledgerWarningDetailItemList);
+        return result;
+    }
+
+    /**
+     * 获取部门映射表
+     */
+    private Map<Long, SysDept> getDeptMap() {
+        List<SysDept> allDepts = sysDeptService.selectDeptInfoAll(new SysDept());
+        return allDepts.stream()
+                .collect(Collectors.toMap(SysDept::getDeptId, dept -> dept, (v1, v2) -> v1));
+    }
+
+    /**
+     * 构建大队到其所有子部门ID的映射
+     * 用于按大队级别统计，包括大队及其下属所有部门
+     *
+     * @param deptMap 部门映射表
+     * @return 大队ID到其所有子部门ID集合的映射
+     */
+    private Map<Long, Set<Long>> buildBrigadeSubDeptsMap(Map<Long, SysDept> deptMap) {
+        // 获取所有大队部门
+        List<SysDept> allBrigades = deptMap.values().stream()
+                .filter(dept -> DeptTypeEnum.BRIGADE.getCode().equals(dept.getDeptType()))
+                .collect(Collectors.toList());
+        // 构建大队到其所有子部门ID的映射
+        Map<Long, Set<Long>> brigadeSubDeptsMap = new HashMap<>();
+        for (SysDept brigade : allBrigades) {
+            Set<Long> subDeptIds = getAllSubDeptIds(brigade.getDeptId(), deptMap);
+            brigadeSubDeptsMap.put(brigade.getDeptId(), subDeptIds);
+        }
+        return brigadeSubDeptsMap;
+    }
+
+    /**
+     * 获取指定部门及其所有子部门的ID集合
+     *
+     * @param deptId 部门ID
+     * @param deptMap 部门映射表
+     * @return 包含当前部门及所有子部门的ID集合
+     */
+    private Set<Long> getAllSubDeptIds(Long deptId, Map<Long, SysDept> deptMap) {
+        Set<Long> result = new HashSet<>();
+        // 包含当前部门
+        result.add(deptId);
+        for (SysDept dept : deptMap.values()) {
+            if (dept.getParentId() != null && dept.getParentId().equals(deptId)) {
+                // 递归获取子部门的子部门
+                result.addAll(getAllSubDeptIds(dept.getDeptId(), deptMap));
+            }
+        }
+        return result;
+    }
+
+    /**
+     * 查找用户所属的大队ID
+     *
+     * @param userDeptId 用户所在部门ID
+     * @param brigadeSubDeptsMap 大队到其所有子部门ID的映射
+     * @return 所属大队ID，如果未找到则返回null
+     */
+    private Long findUserBrigade(Long userDeptId, Map<Long, Set<Long>> brigadeSubDeptsMap) {
+        for (Map.Entry<Long, Set<Long>> entry : brigadeSubDeptsMap.entrySet()) {
+            if (entry.getValue().contains(userDeptId)) {
+                return entry.getKey();
+            }
+        }
+        return null;
+    }
+
+}

airport-ledger/src/main/resources/mapper/ledger/LedgerWarningMapper.xml

@@ -0,0 +1,202 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.sundot.airport.ledger.mapper.LedgerWarningMapper">
+
+    <select id="selectLedgerSupervisionProblem"
+            parameterType="com.sundot.airport.common.dto.LedgerCommonQueryReqVO"
+            resultType="java.lang.Integer">
+        select count(1)
+        from ledger_supervision_problem
+        where 1 = 1
+        <if test="deptId != null">and dept_id = #{deptId}</if>
+        <if test="teamId != null">and team_id = #{teamId}</if>
+        <if test="groupId != null">and group_id = #{groupId}</if>
+        <if test="userId != null">and inspected_id = #{userId}</if>
+        <if test="startDate != null">
+            and record_date >= #{startDate}
+        </if>
+        <if test="endDate != null">
+            and record_date <![CDATA[ < ]]> date_add(#{endDate} , interval 1 day)
+        </if>
+    </select>
+
+    <select id="selectLedgerRealtimeInterception"
+            parameterType="com.sundot.airport.common.dto.LedgerCommonQueryReqVO"
+            resultType="java.lang.Integer">
+        select count(1)
+        from ledger_realtime_interception
+        where 1 = 1
+        <if test="deptId != null">and dept_id = #{deptId}</if>
+        <if test="teamId != null">and team_id = #{teamId}</if>
+        <if test="groupId != null">and group_id = #{groupId}</if>
+        <if test="userId != null">and inspected_id = #{userId}</if>
+        <if test="startDate != null">
+            and record_date >= #{startDate}
+        </if>
+        <if test="endDate != null">
+            and record_date <![CDATA[ < ]]> date_add(#{endDate} , interval 1 day)
+        </if>
+    </select>
+
+    <select id="selectLedgerUnsafeEvent"
+            parameterType="com.sundot.airport.common.dto.LedgerCommonQueryReqVO"
+            resultType="java.lang.Integer">
+        select count(1)
+        from ledger_unsafe_event
+        where 1 = 1
+        <if test="deptId != null">and dept_id = #{deptId}</if>
+        <if test="teamId != null">and team_id = #{teamId}</if>
+        <if test="groupId != null">and group_id = #{groupId}</if>
+        <if test="userId != null">and responsible_id = #{userId}</if>
+        <if test="startDate != null">
+            and record_date >= #{startDate}
+        </if>
+        <if test="endDate != null">
+            and record_date <![CDATA[ < ]]> date_add(#{endDate} , interval 1 day)
+        </if>
+    </select>
+
+    <select id="selectLedgerSecurityTest"
+            parameterType="com.sundot.airport.common.dto.LedgerCommonQueryReqVO"
+            resultType="java.lang.Integer">
+        select count(1)
+        from ledger_security_test
+        where 1 = 1
+        <if test="deptId != null">and dept_id = #{deptId}</if>
+        <if test="teamId != null">and team_id = #{teamId}</if>
+        <if test="groupId != null">and group_id = #{groupId}</if>
+        <if test="userId != null">and tested_id = #{userId}</if>
+        <if test="startDate != null">
+            and record_date >= #{startDate}
+        </if>
+        <if test="endDate != null">
+            and record_date <![CDATA[ < ]]> date_add(#{endDate} , interval 1 day)
+        </if>
+    </select>
+
+    <select id="selectLedgerComplaint"
+            parameterType="com.sundot.airport.common.dto.LedgerCommonQueryReqVO"
+            resultType="java.lang.Integer">
+        select count(1)
+        from ledger_complaint
+        where 1 = 1
+        <if test="deptId != null">and dept_id = #{deptId}</if>
+        <if test="teamId != null">and team_id = #{teamId}</if>
+        <if test="groupId != null">and group_id = #{groupId}</if>
+        <if test="userId != null">and responsible_id = #{userId}</if>
+        <if test="startDate != null">
+            and record_date >= #{startDate}
+        </if>
+        <if test="endDate != null">
+            and record_date <![CDATA[ < ]]> date_add(#{endDate} , interval 1 day)
+        </if>
+    </select>
+
+    <select id="selectLedgerServicePatrol"
+            parameterType="com.sundot.airport.common.dto.LedgerCommonQueryReqVO"
+            resultType="java.lang.Integer">
+        select count(1)
+        from ledger_service_patrol
+        where 1 = 1
+        <if test="deptId != null">and dept_id = #{deptId}</if>
+        <if test="teamId != null">and team_id = #{teamId}</if>
+        <if test="groupId != null">and group_id = #{groupId}</if>
+        <if test="userId != null">and inspected_id = #{userId}</if>
+        <if test="startDate != null">
+            and record_date >= #{startDate}
+        </if>
+        <if test="endDate != null">
+            and record_date <![CDATA[ < ]]> date_add(#{endDate} , interval 1 day)
+        </if>
+    </select>
+
+    <select id="selectLedgerTerminalBonus"
+            parameterType="com.sundot.airport.common.dto.LedgerCommonQueryReqVO"
+            resultType="java.lang.Integer">
+        select count(1)
+        from ledger_terminal_bonus
+        where 1 = 1
+        <if test="deptId != null">and dept_id = #{deptId}</if>
+        <if test="teamId != null">and team_id = #{teamId}</if>
+        <if test="groupId != null">and group_id = #{groupId}</if>
+        <if test="userId != null">and person_id = #{userId}</if>
+        <if test="startDate != null">
+            and approve_date >= #{startDate}
+        </if>
+        <if test="endDate != null">
+            and approve_date <![CDATA[ < ]]> date_add(#{endDate} , interval 1 day)
+        </if>
+    </select>
+
+    <select id="selectLedgerRewardApproval"
+            parameterType="com.sundot.airport.common.dto.LedgerCommonQueryReqVO"
+            resultType="java.lang.Integer">
+        select count(1)
+        from ledger_reward_approval
+        where 1 = 1
+        <if test="deptId != null">and dept_id = #{deptId}</if>
+        <if test="teamId != null">and team_id = #{teamId}</if>
+        <if test="groupId != null">and group_id = #{groupId}</if>
+        <if test="userId != null">and person_id = #{userId}</if>
+        <if test="startDate != null">
+            and approve_date >= #{startDate}
+        </if>
+        <if test="endDate != null">
+            and approve_date <![CDATA[ < ]]> date_add(#{endDate} , interval 1 day)
+        </if>
+    </select>
+
+    <select id="selectLedgerExamScore"
+            parameterType="com.sundot.airport.common.dto.LedgerCommonQueryReqVO"
+            resultType="java.lang.Integer">
+        select count(1)
+        from ledger_exam_score
+        where 1 = 1
+        <if test="deptId != null">and dept_id = #{deptId}</if>
+        <if test="teamId != null">and team_id = #{teamId}</if>
+        <if test="groupId != null">and group_id = #{groupId}</if>
+        <if test="userId != null">and person_id = #{userId}</if>
+        <if test="startDate != null">
+            and exam_date >= #{startDate}
+        </if>
+        <if test="endDate != null">
+            and exam_date <![CDATA[ < ]]> date_add(#{endDate} , interval 1 day)
+        </if>
+    </select>
+
+    <select id="selectScoreEventList"
+            resultType="com.sundot.airport.ledger.domain.ScoreEvent">
+        select person_id personId,
+        person_name personName,
+        dept_id deptId,
+        dept_name deptName,
+        dimension_id dimensionId,
+        dimension_name dimensionName,
+        level2_id level2Id,
+        level2_name level2Name,
+        event_time eventTime
+        from score_event
+        where 1 = 1
+        and org = '4'
+        <if test="startDate != null">
+            and event_time >= #{startDate}
+        </if>
+        <if test="endDate != null">
+            and event_time <![CDATA[ < ]]> date_add(#{endDate} , interval 1 day)
+        </if>
+        <if test="scoreIndicatorIdList != null and scoreIndicatorIdList.size() > 0">
+            and level2_id in
+            <foreach collection="scoreIndicatorIdList" item="item" open="(" separator="," close=")">
+                #{item}
+            </foreach>
+        </if>
+        <!--        由于person_name存在多用户时person_id为空,因此不能根据person_id进行查询-->
+        <!--        <if test="userIdList != null and userIdList.size() > 0">-->
+        <!--            and person_id in-->
+        <!--            <foreach collection="userIdList" item="item" open="(" separator="," close=")">-->
+        <!--                #{item}-->
+        <!--            </foreach>-->
+        <!--        </if>-->
+    </select>
+
+</mapper>