预警页面-红线指标预警

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

@@ -3,6 +3,7 @@ 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.LedgerWarningDetailItemReduceVO;
 import com.sundot.airport.ledger.domain.vo.LedgerWarningDetailVO;
 import com.sundot.airport.ledger.domain.vo.LedgerWarningVO;
 import com.sundot.airport.ledger.service.ILedgerWarningService;
@@ -12,6 +13,8 @@ import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.util.List;
+
 /**
  * 预警页面控制器
  */
@@ -40,4 +43,13 @@ public class LedgerWarningController extends BaseController {
         return AjaxResult.success(result);
     }
 
+    /**
+     * 红线指标预警
+     */
+    @PostMapping("/ledgerReduceDetail")
+    public AjaxResult ledgerReduceDetail(@RequestBody LedgerCommonQueryReqVO queryReq) {
+        List<LedgerWarningDetailItemReduceVO> result = ledgerWarningService.ledgerReduceDetail(queryReq);
+        return AjaxResult.success(result);
+    }
+
 }

airport-common/src/main/java/com/sundot/airport/common/utils/DateMonthUtils.java

@@ -0,0 +1,43 @@
+package com.sundot.airport.common.utils;
+
+import java.time.LocalDate;
+import java.time.ZoneId;
+import java.util.Date;
+
+public class DateMonthUtils {
+
+    /**
+     * 根据开始日期和结束日期计算相隔月数
+     * 规则：每 30 天 = 1 个月，超出部分四舍五入
+     *
+     * @param startDate 开始日期
+     * @param endDate   结束日期
+     * @return 相隔月数（Integer）
+     */
+    public static Integer calculateMonths(Date startDate, Date endDate) {
+        if (startDate == null || endDate == null) {
+            return null;
+        }
+
+        // Date → LocalDate
+        LocalDate start = startDate.toInstant()
+                .atZone(ZoneId.systemDefault())
+                .toLocalDate();
+        LocalDate end = endDate.toInstant()
+                .atZone(ZoneId.systemDefault())
+                .toLocalDate();
+
+        // 防止开始时间晚于结束时间
+        if (start.isAfter(end)) {
+            LocalDate temp = start;
+            start = end;
+            end = temp;
+        }
+
+        // 计算天数差
+        long days = java.time.temporal.ChronoUnit.DAYS.between(start, end);
+
+        // 每 30 天为 1 个月，四舍五入
+        return (int) Math.round((double) days / 30.0);
+    }
+}

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

@@ -0,0 +1,77 @@
+package com.sundot.airport.ledger.domain.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+
+/**
+ * 预警信息详情配分事项录入明细
+ */
+@Data
+public class LedgerWarningDetailItemReduceVO implements Serializable {
+    /**
+     * 员工ID
+     */
+    private Long userId;
+    /**
+     * 员工账号
+     */
+    private String userName;
+    /**
+     * 员工昵称
+     */
+    private String nickName;
+    /**
+     * 所属部门ID
+     */
+    private Long deptId;
+    /**
+     * 所属部门名称
+     */
+    private String deptName;
+    /**
+     * 维度ID
+     */
+    private Long dimensionId;
+    /**
+     * 维度名称
+     */
+    private String dimensionName;
+    /**
+     * 二级指标ID
+     */
+    private Long level2Id;
+    /**
+     * 二级指标名称
+     */
+    private String level2Name;
+    /**
+     * 分值合计
+     */
+    private BigDecimal totalScore;
+    /**
+     * 发生次数
+     */
+    private Integer occurrenceCount;
+    /**
+     * 月份数
+     */
+    private Integer monthCount;
+    /**
+     * 平均次数
+     */
+    private BigDecimal averageCount;
+    /**
+     * 预警等级
+     */
+    private String warningLevel;
+    /**
+     * 状态标签
+     */
+    private String statusLabel;
+    /**
+     * 核心风险
+     */
+    private String coreRisks;
+}

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

@@ -4,6 +4,7 @@ import lombok.Data;
 
 import java.io.Serializable;
 import java.math.BigDecimal;
+import java.util.List;
 
 /**
  * 预警信息详情明细
@@ -46,4 +47,8 @@ public class LedgerWarningDetailItemVO implements Serializable {
      * 核心风险/优秀事迹
      */
     private String coreRisksOrOutstandingAchievements;
+    /**
+     * 预警信息详情配分事项录入明细列表
+     */
+    private List<LedgerWarningDetailItemReduceVO> ledgerWarningDetailItemDetailList;
 }

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

@@ -1,9 +1,12 @@
 package com.sundot.airport.ledger.service;
 
 import com.sundot.airport.common.dto.LedgerCommonQueryReqVO;
+import com.sundot.airport.ledger.domain.vo.LedgerWarningDetailItemReduceVO;
 import com.sundot.airport.ledger.domain.vo.LedgerWarningDetailVO;
 import com.sundot.airport.ledger.domain.vo.LedgerWarningVO;
 
+import java.util.List;
+
 /**
  * 预警页面服务
  */
@@ -19,4 +22,9 @@ public interface ILedgerWarningService {
      */
     LedgerWarningDetailVO ledgerDetail(LedgerCommonQueryReqVO queryReq);
 
+    /**
+     * 红线指标预警
+     */
+    List<LedgerWarningDetailItemReduceVO> ledgerReduceDetail(LedgerCommonQueryReqVO queryReq);
+
 }

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

@@ -11,11 +11,13 @@ 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.DateMonthUtils;
 import com.sundot.airport.common.utils.DeptUtils;
 import com.sundot.airport.common.utils.SecurityUtils;
 import com.sundot.airport.common.utils.StreamSortUtils;
 import com.sundot.airport.ledger.domain.ScoreEvent;
 import com.sundot.airport.ledger.domain.ScoreIndicator;
+import com.sundot.airport.ledger.domain.vo.LedgerWarningDetailItemReduceVO;
 import com.sundot.airport.ledger.domain.vo.LedgerWarningDetailItemVO;
 import com.sundot.airport.ledger.domain.vo.LedgerWarningDetailVO;
 import com.sundot.airport.ledger.domain.vo.LedgerWarningVO;
@@ -266,4 +268,114 @@ public class LedgerWarningServiceImpl implements ILedgerWarningService {
         return null;
     }
 
+    /**
+     * 红线指标预警
+     */
+    @Override
+    public List<LedgerWarningDetailItemReduceVO> ledgerReduceDetail(LedgerCommonQueryReqVO queryReq) {
+        List<String> scoreIndicatorNameList = Arrays.asList("员工规范化操作", "后台实时质控拦截", "不安全事件", "安保测试未通过");
+        Map<String, String> unitMap = new HashMap<>();
+        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());
+
+        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)));
+        }
+        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<LedgerWarningDetailItemReduceVO> resultList = new ArrayList<>();
+        userIdList.forEach(userId -> {
+            SysUser sysUser = sysUserMap.get(userId);
+//            // 由于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, List<ScoreEvent>> userScoreEventListMap = userScoreEventList.stream().collect(Collectors.groupingBy(item -> item.getLevel2Id() + "_" + item.getLevel2Name()));
+                userScoreEventListMap.forEach((level2IdName, eventList) -> {
+                    LedgerWarningDetailItemReduceVO ledgerWarningDetailItemReduce = new LedgerWarningDetailItemReduceVO();
+                    ledgerWarningDetailItemReduce.setUserId(sysUser.getUserId());
+                    ledgerWarningDetailItemReduce.setUserName(sysUser.getUserName());
+                    ledgerWarningDetailItemReduce.setNickName(sysUser.getNickName());
+                    ledgerWarningDetailItemReduce.setDeptId(sysUser.getDeptId());
+                    SysDept dept = deptMap.get(findUserBrigade(sysUser.getDeptId(), brigadeSubDeptsMap));
+                    if (ObjUtil.isNotNull(dept)) {
+                        ledgerWarningDetailItemReduce.setDeptName(dept.getDeptName());
+                    }
+                    ledgerWarningDetailItemReduce.setDimensionId(eventList.get(0).getDimensionId());
+                    ledgerWarningDetailItemReduce.setDimensionName(eventList.get(0).getDimensionName());
+                    ledgerWarningDetailItemReduce.setLevel2Id(Long.valueOf(level2IdName.split("_")[0]));
+                    ledgerWarningDetailItemReduce.setLevel2Name(level2IdName.split("_")[1]);
+                    ledgerWarningDetailItemReduce.setTotalScore(eventList.stream().map(ScoreEvent::getTotalScore).reduce(BigDecimal.ZERO, BigDecimal::add));
+                    ledgerWarningDetailItemReduce.setOccurrenceCount(eventList.size());
+                    ledgerWarningDetailItemReduce.setMonthCount(DateMonthUtils.calculateMonths(queryReq.getStartDate(), queryReq.getEndDate()));
+                    ledgerWarningDetailItemReduce.setAverageCount(ObjUtil.isNull(ledgerWarningDetailItemReduce.getMonthCount()) ? BigDecimal.ZERO : BigDecimal.valueOf(ledgerWarningDetailItemReduce.getOccurrenceCount()).divide(BigDecimal.valueOf(ledgerWarningDetailItemReduce.getMonthCount()), 1, RoundingMode.HALF_UP));
+                    if (ledgerWarningDetailItemReduce.getAverageCount().compareTo(BigDecimal.valueOf(3)) >= 0) {
+                        ledgerWarningDetailItemReduce.setWarningLevel(LedgerAlertLevelEnum.RED_ALERT.getCode());
+                        ledgerWarningDetailItemReduce.setStatusLabel(LedgerStatusLabelEnum.EMERGENCY_INTERVENTION.getCode());
+                    } else {
+                        ledgerWarningDetailItemReduce.setWarningLevel(LedgerAlertLevelEnum.NORMAL_RANGE.getCode());
+                        ledgerWarningDetailItemReduce.setStatusLabel(LedgerStatusLabelEnum.REGULAR_COACHING.getCode());
+                    }
+                    ledgerWarningDetailItemReduce.setCoreRisks(ledgerWarningDetailItemReduce.getLevel2Name() + ledgerWarningDetailItemReduce.getOccurrenceCount() + unitMap.get(ledgerWarningDetailItemReduce.getLevel2Name()));
+                    resultList.add(ledgerWarningDetailItemReduce);
+                });
+            }
+        });
+
+        // 排序
+        if (ObjUtil.isNull(queryReq.getSorts())) {
+            Map<String, String> sorts = new LinkedHashMap<>();
+            sorts.put("userId", "asc");
+            sorts.put("dimensionId", "asc");
+            queryReq.setSorts(sorts);
+        }
+        List<LedgerWarningDetailItemReduceVO> result = StreamSortUtils.sort(resultList, queryReq.getSorts());
+        return result;
+    }
+
 }

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

@@ -174,7 +174,8 @@
         dimension_name dimensionName,
         level2_id level2Id,
         level2_name level2Name,
-        event_time eventTime
+        event_time eventTime,
+        total_score totalScore
         from score_event
         where 1 = 1
         and org = '4'