漏检统计大屏-模块三

airport-admin/src/main/java/com/sundot/airport/web/controller/blocked/BlockedMissCheckStatisticsScreenController.java

@@ -0,0 +1,46 @@
+package com.sundot.airport.web.controller.blocked;
+
+import com.sundot.airport.blocked.service.IBlockedMissCheckStatisticsScreenService;
+import com.sundot.airport.common.core.controller.BaseController;
+import com.sundot.airport.common.core.domain.AjaxResult;
+import com.sundot.airport.common.core.domain.BlockedMissCheckStatisticsQueryParamDto;
+import com.sundot.airport.common.dto.BaseCommonDto;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+/**
+ * 漏检统计大屏Controller
+ *
+ * @author wangxx
+ * @date 2026-04-13
+ */
+@RestController
+@RequestMapping("/blocked/missReview/screen")
+public class BlockedMissCheckStatisticsScreenController extends BaseController {
+
+    @Autowired
+    private IBlockedMissCheckStatisticsScreenService blockedMissCheckStatisticsScreenService;
+
+    /**
+     * 月考成绩统计
+     */
+    @GetMapping("/monthlyAssessment")
+    public AjaxResult monthlyAssessment(BlockedMissCheckStatisticsQueryParamDto dto) {
+        List<BaseCommonDto> list = blockedMissCheckStatisticsScreenService.monthlyAssessment(dto);
+        return success(list);
+    }
+
+    /**
+     * 本月自测有无漏检统计
+     */
+    @GetMapping("/selfTestHasMissCheck")
+    public AjaxResult selfTestHasMissCheck(BlockedMissCheckStatisticsQueryParamDto dto) {
+        List<BaseCommonDto> list = blockedMissCheckStatisticsScreenService.selfTestHasMissCheck(dto);
+        return success(list);
+    }
+
+}

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

@@ -0,0 +1,32 @@
+package com.sundot.airport.blocked.service;
+
+import com.sundot.airport.common.core.domain.BlockedMissCheckStatisticsQueryParamDto;
+import com.sundot.airport.common.dto.BaseCommonDto;
+
+import java.util.List;
+
+/**
+ * 漏检统计大屏Service接口
+ *
+ * @author wangxx
+ * @date 2026-04-13
+ */
+public interface IBlockedMissCheckStatisticsScreenService {
+
+    /**
+     * 月考成绩统计
+     *
+     * @param dto 漏检统计查询参数
+     * @return 月考成绩统计
+     */
+    public List<BaseCommonDto> monthlyAssessment(BlockedMissCheckStatisticsQueryParamDto dto);
+
+    /**
+     * 本月自测有无漏检统计
+     *
+     * @param dto 漏检统计查询参数
+     * @return 本月自测有无漏检统计
+     */
+    public List<BaseCommonDto> selfTestHasMissCheck(BlockedMissCheckStatisticsQueryParamDto dto);
+
+}

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

@@ -0,0 +1,89 @@
+package com.sundot.airport.blocked.service.impl;
+
+import com.sundot.airport.blocked.domain.BlockedMissCheckStatistics;
+import com.sundot.airport.blocked.mapper.BlockedMissCheckStatisticsMapper;
+import com.sundot.airport.blocked.service.IBlockedMissCheckStatisticsScreenService;
+import com.sundot.airport.common.core.domain.BlockedMissCheckStatisticsQueryParamDto;
+import com.sundot.airport.common.core.domain.entity.SysDictData;
+import com.sundot.airport.common.dto.BaseCommonDto;
+import com.sundot.airport.system.service.ISysDictDataService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.math.BigDecimal;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+/**
+ * 漏检统计大屏Service业务层处理
+ *
+ * @author wangxx
+ * @date 2026-04-13
+ */
+@Service
+public class BlockedMissCheckStatisticsScreenServiceImpl implements IBlockedMissCheckStatisticsScreenService {
+
+    @Autowired
+    private BlockedMissCheckStatisticsMapper blockedMissCheckStatisticsMapper;
+    @Autowired
+    private ISysDictDataService sysDictDataService;
+
+    /**
+     * 月考成绩统计
+     *
+     * @param dto 漏检统计查询参数
+     * @return 月考成绩统计
+     */
+    @Override
+    public List<BaseCommonDto> monthlyAssessment(BlockedMissCheckStatisticsQueryParamDto dto) {
+        List<BaseCommonDto> result = new ArrayList<>();
+        SysDictData dictData = new SysDictData();
+        dictData.setDictType("blocked_monthly_exam_result");
+        List<SysDictData> sysDictDataList = sysDictDataService.selectDictDataList(dictData);
+        BlockedMissCheckStatistics query = new BlockedMissCheckStatistics();
+        query.setReviewDate(dto.getSpecifiedDate());
+        query.setBrigadeId(dto.getBrigadeId());
+        query.setBrigadeName(dto.getBrigadeName());
+        List<BlockedMissCheckStatistics> blockedMissCheckStatisticsList = blockedMissCheckStatisticsMapper.selectBlockedMissCheckStatisticsList(query);
+        Map<String, Long> monthlyAssessmentMap = blockedMissCheckStatisticsList.stream()
+                .filter(blockedMissCheckStatistics -> blockedMissCheckStatistics.getMonthlyAssessment() != null)
+                .collect(Collectors.groupingBy(BlockedMissCheckStatistics::getMonthlyAssessment, Collectors.counting()));
+        sysDictDataList.forEach(sysDictData -> {
+            BaseCommonDto item = new BaseCommonDto();
+            item.setCode(sysDictData.getDictValue());
+            item.setName(sysDictData.getDictLabel());
+            item.setTotal(BigDecimal.valueOf(monthlyAssessmentMap.getOrDefault(sysDictData.getDictValue(), 0L)));
+            result.add(item);
+        });
+        return result;
+    }
+
+    /**
+     * 本月自测有无漏检统计
+     *
+     * @param dto 漏检统计查询参数
+     * @return 本月自测有无漏检统计
+     */
+    @Override
+    public List<BaseCommonDto> selfTestHasMissCheck(BlockedMissCheckStatisticsQueryParamDto dto) {
+        List<BaseCommonDto> result = new ArrayList<>();
+        BlockedMissCheckStatistics query = new BlockedMissCheckStatistics();
+        query.setReviewDate(dto.getSpecifiedDate());
+        query.setBrigadeId(dto.getBrigadeId());
+        query.setBrigadeName(dto.getBrigadeName());
+        List<BlockedMissCheckStatistics> blockedMissCheckStatisticsList = blockedMissCheckStatisticsMapper.selectBlockedMissCheckStatisticsList(query);
+        Map<Integer, Long> selfTestHasMissCheckMap = blockedMissCheckStatisticsList.stream()
+                .filter(blockedMissCheckStatistics -> blockedMissCheckStatistics.getSelfTestHasMissCheck() != null)
+                .collect(Collectors.groupingBy(BlockedMissCheckStatistics::getSelfTestHasMissCheck, Collectors.counting()));
+        selfTestHasMissCheckMap.forEach((key, value) -> {
+            BaseCommonDto item = new BaseCommonDto();
+            item.setName(String.valueOf(key));
+            item.setTotal(BigDecimal.valueOf(value));
+            result.add(item);
+        });
+        return result;
+    }
+
+}

airport-common/src/main/java/com/sundot/airport/common/core/domain/BlockedMissCheckStatisticsQueryParamDto.java

@@ -0,0 +1,23 @@
+package com.sundot.airport.common.core.domain;
+
+import lombok.Data;
+
+/**
+ * 漏检统计查询参数
+ *
+ * @author ruoyi
+ */
+@Data
+public class BlockedMissCheckStatisticsQueryParamDto extends BaseScreenQueryParamDto {
+
+    /**
+     * 大队ID
+     */
+    private Long brigadeId;
+
+    /**
+     * 大队名称
+     */
+    private String brigadeName;
+
+}