feat: 新增智能灯统计稼动率查询接口

@@ -82,4 +82,18 @@ public class HealthController {
             @RequestParam(defaultValue = "20") Integer pageSize) {
         return deviceSearchService.queryOeeTimeline(startDate, endDate, pageNo, pageSize);
     }
+
+    /**
+     * 智能灯统计稼动率查询（仪表盘）
+     * 支持日/周/月查询，返回总时长、稼动率、当前机台状态、异常排行榜、每设备状态时长
+     *
+     * @param startDate 开始日期 yyyy-MM-dd (day模式必填)
+     * @param endDate   结束日期 yyyy-MM-dd (day模式必填)
+     */
+    @GetMapping("/device/lampStatistics")
+    public Map<String, Object> lampStatistics(
+            @RequestParam(required = false) String startDate,
+            @RequestParam(required = false) String endDate) {
+        return deviceSearchService.queryLampStatistics(startDate, endDate);
+    }
 }

@@ -928,4 +928,197 @@ public class DeviceSearchService {
                 )
         );
     }
+
+    // ==================== 智能灯统计稼动率查询（仪表盘） ====================
+
+    /**
+     * 智能灯统计稼动率综合查询（仪表盘数据）
+     * 返回：总时长、稼动率、当前机台运行状态、异常排行榜、每设备状态时长
+     *
+     * @param startDate 开始日期 yyyy-MM-dd
+     * @param endDate   结束日期 yyyy-MM-dd
+     */
+    public Map<String, Object> queryLampStatistics(String startDate, String endDate) {
+        log.info("========== [智能灯统计查询] startDate={}, endDate={} ==========", startDate, endDate);
+
+        // 1. 根据前端传入的起止日期构建日期范围
+        List<String> dateList = buildDayList(startDate, endDate);
+        if (dateList.isEmpty()) {
+            return buildEmptyLampStats();
+        }
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+        String todayStr = sdf.format(new Date());
+        boolean includeToday = dateList.contains(todayStr);
+        log.info("日期范围共 {} 天, 包含今日({}): {}", dateList.size(), todayStr, includeToday);
+
+        // 2. 获取所有设备及名称
+        Map<String, String> deviceNameMap = queryAllDtuSnWithName();
+        List<String> allDtuSns = new ArrayList<>(deviceNameMap.keySet());
+        if (allDtuSns.isEmpty()) {
+            return buildEmptyLampStats();
+        }
+
+        // 3. 批量从OEE表查询数据
+        List<OeeRecord> allRecords = queryOeeBatch(allDtuSns, dateList, includeToday ? todayStr : null);
+
+        // 4. 补充今天的实时数据
+        if (includeToday) {
+            supplementTodayData(allDtuSns, todayStr, allRecords);
+        }
+
+        // 5. 按 dtuSn 分组
+        Map<String, List<OeeRecord>> deviceMap = new LinkedHashMap<>();
+        for (OeeRecord r : allRecords) {
+            deviceMap.computeIfAbsent(r.dtuSn, k -> new ArrayList<>()).add(r);
+        }
+        for (String sn : allDtuSns) {
+            if (!deviceMap.containsKey(sn)) {
+                deviceMap.put(sn, new ArrayList<>());
+            }
+        }
+
+        // 6. 计算各项统计数据
+        return buildLampStatisticsResult(allDtuSns, deviceMap, deviceNameMap, dateList);
+    }
+
+    /** 构建空结果 */
+    private Map<String, Object> buildEmptyLampStats() {
+        return Map.of(
+                "totalDuration", Map.of(
+                        "off", Map.of("duration", "0时0分0秒", "seconds", 0),
+                        "red", Map.of("duration", "0时0分0秒", "seconds", 0),
+                        "yellow", Map.of("duration", "0时0分0秒", "seconds", 0),
+                        "green", Map.of("duration", "0时0分0秒", "seconds", 0),
+                        "blue", Map.of("duration", "0时0分0秒", "seconds", 0)
+                ),
+                "availabilityRate", "0.00%",
+                "currentStatus", Map.of(
+                        "off", 0, "red", 0, "yellow", 0, "green", 0, "blue", 0
+                ),
+                "abnormalRanking", List.of(),
+                "deviceList", List.of()
+        );
+    }
+
+    /** 构建智能灯统计结果 */
+    private Map<String, Object> buildLampStatisticsResult(List<String> allDtuSns,
+                                                           Map<String, List<OeeRecord>> deviceMap,
+                                                           Map<String, String> deviceNameMap,
+                                                           List<String> dateList) {
+        // ---- ① 总时长：汇总所有设备各状态时长 ----
+        long totalOff = 0, totalRed = 0, totalYellow = 0, totalGreen = 0, totalBlue = 0;
+
+        // ---- ② 设备维度统计：用于异常排名和每设备详情 ----
+        List<Map<String, Object>> deviceStatList = new ArrayList<>();
+
+        for (String dtuSn : allDtuSns) {
+            List<OeeRecord> dayRecords = deviceMap.getOrDefault(dtuSn, Collections.emptyList());
+
+            long devOff = 0, devRed = 0, devYellow = 0, devGreen = 0, devBlue = 0;
+            long devTotalDur = 0, devGreenDur = 0;
+
+            for (OeeRecord rec : dayRecords) {
+                if (rec.lampData != null) {
+                    for (int i = 0; i < rec.lampData.size(); i++) {
+                        JSONObject lamp = rec.lampData.getJSONObject(i);
+                        if (lamp == null) continue;
+                        int state = lamp.getIntValue("lampState");
+                        long dur = lamp.getLongValue("duration");
+                        switch (state) {
+                            case 0 -> devOff += dur;
+                            case 1 -> devRed += dur;
+                            case 2 -> devYellow += dur;
+                            case 3 -> { devGreen += dur; devGreenDur += dur; }
+                            case 4 -> devBlue += dur;
+                        }
+                        devTotalDur += dur;
+                    }
+                }
+            }
+
+            // 稼动率 = 绿 / (红 + 黄 + 绿) * 100%
+            long devRygDur = devRed + devYellow + devGreen;
+            double rate = (devRygDur > 0) ? Math.round(devGreenDur * 10000.0 / devRygDur) / 100.0 : 0.0;
+            long abnormalDur = devRed + devYellow; // 异常时长 = 红+黄
+
+            Map<String, Object> devStat = new LinkedHashMap<>();
+            devStat.put("dtuSn", dtuSn);
+            devStat.put("deviceName", deviceNameMap.getOrDefault(dtuSn, ""));
+            devStat.put("offDuration", formatDuration(devOff));
+            devStat.put("offSeconds", devOff);
+            devStat.put("redDuration", formatDuration(devRed));
+            devStat.put("redSeconds", devRed);
+            devStat.put("yellowDuration", formatDuration(devYellow));
+            devStat.put("yellowSeconds", devYellow);
+            devStat.put("greenDuration", formatDuration(devGreen));
+            devStat.put("greenSeconds", devGreen);
+            devStat.put("blueDuration", formatDuration(devBlue));
+            devStat.put("blueSeconds", devBlue);
+            devStat.put("availabilityRatio", String.format("%.2f%%", rate));
+            devStat.put("rygTotalDuration", formatDuration(devRygDur)); // 红+黄+绿 总时长
+            devStat.put("abnormalDuration", abnormalDur); // 用于排序
+
+            deviceStatList.add(devStat);
+
+            // 累加到全局总计
+            totalOff += devOff;
+            totalRed += devRed;
+            totalYellow += devYellow;
+            totalGreen += devGreen;
+            totalBlue += devBlue;
+        }
+
+        // ---- ③ 稼动率 = 绿 / (红 + 黄 + 绿) ----
+        long totalRygDur = totalRed + totalYellow + totalGreen;
+        double overallRate = (totalRygDur > 0) ? Math.round(totalGreen * 10000.0 / totalRygDur) / 100.0 : 0.0;
+
+        // ---- ④ 当前机台运行状态（从设备表实时查） ----
+        Map<String, Integer> currentStatus = queryCurrentDeviceStatus();
+
+        // ---- ⑤ 异常排行榜（按红+黄时长降序） ----
+        deviceStatList.sort((a, b) -> Long.compare(
+                ((Number) b.get("abnormalDuration")).longValue(),
+                ((Number) a.get("abnormalDuration")).longValue()
+        ));
+        // 排序后移除辅助字段
+        for (Map<String, Object> d : deviceStatList) {
+            d.remove("abnormalDuration");
+        }
+
+        return Map.of(
+                "totalDuration", Map.of(
+                        "off", Map.of("duration", formatDuration(totalOff), "seconds", totalOff),
+                        "red", Map.of("duration", formatDuration(totalRed), "seconds", totalRed),
+                        "yellow", Map.of("duration", formatDuration(totalYellow), "seconds", totalYellow),
+                        "green", Map.of("duration", formatDuration(totalGreen), "seconds", totalGreen),
+                        "blue", Map.of("duration", formatDuration(totalBlue), "seconds", totalBlue)
+                ),
+                "availabilityRate", String.format("%.2f%%", overallRate),
+                "rygTotalDuration", formatDuration(totalRygDur), // 红黄绿总时长
+                "currentStatus", currentStatus,
+                "abnormalRanking", deviceStatList,
+                "deviceList", deviceStatList
+        );
+    }
+
+    /** 查询当前设备的运行状态分布（从设备表） */
+    private Map<String, Integer> queryCurrentDeviceStatus() {
+        String sql = "SELECT lampState, COUNT(*) as cnt FROM " + deviceTableName +
+                " WHERE corp_code = ? GROUP BY lampState";
+        List<Map<String, Object>> rows = jdbcTemplate.queryForList(sql, deviceCorpCode);
+
+        int off = 0, red = 0, yellow = 0, green = 0, blue = 0;
+        for (Map<String, Object> row : rows) {
+            String state = String.valueOf(row.get("lampState"));
+            int cnt = ((Number) row.get("cnt")).intValue();
+            switch (state) {
+                case "0" -> off = cnt;
+                case "1" -> red = cnt;
+                case "2" -> yellow = cnt;
+                case "3" -> green = cnt;
+                case "4" -> blue = cnt;
+            }
+        }
+        return Map.of("off", off, "red", red, "yellow", yellow, "green", green, "blue", blue);
+    }
 }