feat: 新增设备运行时长明细查询接口

@@ -157,4 +157,24 @@ public class HealthController {
             @RequestParam String date) {
         return energySearchService.queryEnergyDetailByDate(dtuSn, date);
     }
+
+    /**
+     * 根据dtuSn查询指定设备的运行时长明细
+     * type=1(时): 传startDate，获取指定日期的运行时长明细
+     * type=2(天): 传startDate和endDate，按日统计
+     * type=3(月): 查本年年初到现在，按月统计
+     *
+     * @param dtuSn    设备序列号
+     * @param type     类型：1-时，2-天，3-月
+     * @param startDate 开始日期 yyyy-MM-dd (type=1,2必填)
+     * @param endDate   结束日期 yyyy-MM-dd (type=2必填)
+     */
+    @GetMapping("/energy/runtimeDetail")
+    public Map<String, Object> energyRuntimeDetail(
+            @RequestParam String dtuSn,
+            @RequestParam(defaultValue = "1") String type,
+            @RequestParam(required = false) String startDate,
+            @RequestParam(required = false) String endDate) {
+        return energySearchService.queryEnergyRuntimeDetail(dtuSn, type, startDate, endDate);
+    }
 }

@@ -13,6 +13,7 @@ import jakarta.annotation.Resource;
 
 import java.math.BigDecimal;
 import java.math.RoundingMode;
+import java.text.SimpleDateFormat;
 import java.util.*;
 
 @Slf4j
@@ -235,6 +236,209 @@ public class EnergySearchService {
     }
 
     /**
+     * 根据dtuSn查询指定设备的运行时长明细
+     * 核心数据为设备时用电量(eq_kwh)，其中包含每个状态的运行时长，需要统计
+     * type=1(时): 传startDate，获取指定日期的时用电量明细+各状态时长统计
+     * type=2(天): 传startDate和endDate，按日统计
+     * type=3(月): 查本年年初到现在，按月统计
+     *
+     * @param dtuSn    设备序列号
+     * @param type     类型：1-时，2-天，3-月
+     * @param startDate 开始日期 yyyy-MM-dd (type=1,2必填)
+     * @param endDate   结束日期 yyyy-MM-dd (type=2必填)
+     */
+    public Map<String, Object> queryEnergyRuntimeDetail(String dtuSn, String type,
+                                                        String startDate, String endDate) {
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+        List<String> dateList = new ArrayList<>();
+
+        // 根据type构建日期列表
+        if ("1".equals(type)) {
+            dateList.add(startDate);
+        } else if ("2".equals(type)) {
+            try {
+                Date start = sdf.parse(startDate);
+                Date end = sdf.parse(endDate);
+                Calendar cur = Calendar.getInstance();
+                cur.setTime(start);
+                while (!cur.getTime().after(end)) {
+                    dateList.add(sdf.format(cur.getTime()));
+                    cur.add(Calendar.DAY_OF_MONTH, 1);
+                }
+            } catch (Exception e) {
+                return Map.of("code", 400, "msg", "日期格式错误");
+            }
+        } else if ("3".equals(type)) {
+            Calendar now = Calendar.getInstance();
+            int year = now.get(Calendar.YEAR);
+            Calendar startCal = Calendar.getInstance();
+            startCal.set(year, Calendar.JANUARY, 1);
+            while (!startCal.getTime().after(now.getTime())) {
+                dateList.add(sdf.format(startCal.getTime()));
+                startCal.add(Calendar.DAY_OF_MONTH, 1);
+            }
+        }
+
+        // 统计汇总数据
+        long totalDurationAll = 0;
+        BigDecimal totalKwhAll = BigDecimal.ZERO;
+        Map<Integer, Long> statusDurationAllMap = initStatusMap();
+
+        // type=1: 直接返回每日明细; type=2/3: 按日期聚合后返回
+        List<Map<String, Object>> detailList = new ArrayList<>();
+        // type=3 按月聚合用
+        Map<String, Map<String, Object>> monthAggMap = "3".equals(type) ? new LinkedHashMap<>() : null;
+
+        for (String dateStr : dateList) {
+            // 从eq_kwh表查询时用电量数据
+            Object kwhRawData = Collections.emptyList();
+            BigDecimal dayKwh = BigDecimal.ZERO;
+            long dayTotalDuration = 0;
+            Map<Integer, Long> dayStatusDuration = initStatusMap();
+
+            try {
+                String kwhSql = "SELECT description FROM " + eqKwhTableName
+                        + " WHERE corp_code = ? AND dtuSn = ? AND use_date = ?";
+                Map<String, Object> kwhRow = jdbcTemplate.queryForMap(kwhSql, energyCorpCode, dtuSn, dateStr + " 00:00:00");
+                if (kwhRow != null && kwhRow.get("description") != null) {
+                    String desc = String.valueOf(kwhRow.get("description"));
+                    JSONArray dataArray = JSON.parseArray(desc);
+
+                    for (int i = 0; i < dataArray.size(); i++) {
+                        JSONObject item = dataArray.getJSONObject(i);
+                        Double value = item.getDouble("value");
+                        if (value != null) dayKwh = dayKwh.add(BigDecimal.valueOf(value));
+
+                        // 从字段 0/1/2/3 统计各状态运行时长 + 格式化新字段
+                        for (int statusKey = 0; statusKey <= 3; statusKey++) {
+                            Long dur = item.getLong(String.valueOf(statusKey));
+                            item.put(statusKey + "Formatted", formatDuration(dur != null ? dur : 0L));
+                            if (dur != null && dur > 0) {
+                                dayTotalDuration += dur;
+                                totalDurationAll += dur;
+                                dayStatusDuration.merge(statusKey, dur, Long::sum);
+                                statusDurationAllMap.merge(statusKey, dur, Long::sum);
+                            }
+                        }
+                    }
+                    kwhRawData = dataArray;
+                }
+            } catch (Exception ignored) {}
+            totalKwhAll = totalKwhAll.add(dayKwh);
+
+            String periodKey = "3".equals(type) ? dateStr.substring(0, 7) : dateStr;
+
+            if ("1".equals(type)) {
+                // type=1(时): 返回原始kwhList + 当日统计
+                Map<String, Object> entry = new LinkedHashMap<>();
+                entry.put("date", periodKey);
+                entry.put("kwhList", kwhRawData);
+                entry.put("totalKwh", dayKwh.setScale(2, RoundingMode.HALF_UP));
+                entry.put("totalDurationFormatted", formatDuration(dayTotalDuration));
+                entry.put("totalDurationSeconds", dayTotalDuration);
+                entry.put("statusStats", buildStatusStats(dayStatusDuration, dayTotalDuration));
+                detailList.add(entry);
+            } else if ("2".equals(type)) {
+                // type=2(天): 返回每日汇总统计，不含kwhList
+                Map<String, Object> entry = new LinkedHashMap<>();
+                entry.put("date", periodKey);
+                entry.put("totalKwh", dayKwh.setScale(2, RoundingMode.HALF_UP));
+                entry.put("totalDurationFormatted", formatDuration(dayTotalDuration));
+                entry.put("totalDurationSeconds", dayTotalDuration);
+                entry.put("statusStats", buildStatusStats(dayStatusDuration, dayTotalDuration));
+                detailList.add(entry);
+            } else if ("3".equals(type)) {
+                // type=3(月): 按月聚合
+                monthAggMap.computeIfAbsent(periodKey, k -> {
+                    Map<String, Object> m = new LinkedHashMap<>();
+                    m.put("date", k);
+                    m.put("totalKwh", BigDecimal.ZERO);
+                    m.put("totalDurationSeconds", 0L);
+                    m.put("statusDurationMap", initStatusMap());
+                    return m;
+                });
+                Map<String, Object> monthEntry = monthAggMap.get(periodKey);
+                monthEntry.put("totalKwh", ((BigDecimal) monthEntry.get("totalKwh")).add(dayKwh));
+                monthEntry.put("totalDurationSeconds", (Long) monthEntry.get("totalDurationSeconds") + dayTotalDuration);
+                @SuppressWarnings("unchecked")
+                Map<Integer, Long> mStatusMap = (Map<Integer, Long>) monthEntry.get("statusDurationMap");
+                for (int sk = 0; sk <= 3; sk++) {
+                    if (dayStatusDuration.get(sk) > 0) {
+                        mStatusMap.merge(sk, dayStatusDuration.get(sk), Long::sum);
+                    }
+                }
+            }
+        }
+
+        // type=3 构建月度聚合结果
+        if ("3".equals(type) && monthAggMap != null) {
+            for (Map.Entry<String, Map<String, Object>> me : monthAggMap.entrySet()) {
+                Map<String, Object> m = me.getValue();
+                long mDur = (Long) m.get("totalDurationSeconds");
+                @SuppressWarnings("unchecked")
+                Map<Integer, Long> mStatusMap = (Map<Integer, Long>) m.get("statusDurationMap");
+
+                Map<String, Object> entry = new LinkedHashMap<>();
+                entry.put("date", m.get("date"));
+                entry.put("totalKwh", ((BigDecimal) m.get("totalKwh")).setScale(2, RoundingMode.HALF_UP));
+                entry.put("totalDurationFormatted", formatDuration(mDur));
+                entry.put("totalDurationSeconds", mDur);
+                entry.put("statusStats", buildStatusStats(mStatusMap, mDur));
+                detailList.add(entry);
+            }
+        }
+
+        List<Map<String, Object>> allStatusStats = buildStatusStats(statusDurationAllMap, totalDurationAll);
+
+        return Map.of(
+                "code", 200,
+                "msg", "请求成功",
+                "dtuSn", dtuSn,
+                "type", type,
+                "detailList", detailList,
+                "summary", Map.of(
+                        "totalDurationFormatted", formatDuration(totalDurationAll),
+                        "totalDurationSeconds", totalDurationAll,
+                        "totalKwh", totalKwhAll.setScale(2, RoundingMode.HALF_UP),
+                        "statusStats", allStatusStats
+                )
+        );
+    }
+
+    private static Map<Integer, Long> initStatusMap() {
+        Map<Integer, Long> map = new LinkedHashMap<>();
+        map.put(0, 0L);
+        map.put(1, 0L);
+        map.put(2, 0L);
+        map.put(3, 0L);
+        return map;
+    }
+
+    private static List<Map<String, Object>> buildStatusStats(Map<Integer, Long> statusMap, long totalDur) {
+        List<Map<String, Object>> list = new ArrayList<>();
+        for (Map.Entry<Integer, Long> entry : statusMap.entrySet()) {
+            long dur = entry.getValue();
+            double percent = totalDur > 0 ? BigDecimal.valueOf(dur * 100.0 / totalDur)
+                    .setScale(2, RoundingMode.HALF_UP).doubleValue() : 0.0;
+            Map<String, Object> stat = new LinkedHashMap<>();
+            stat.put("status", entry.getKey());
+            stat.put("durationSeconds", dur);
+            stat.put("durationFormatted", formatDuration(dur));
+            stat.put("percent", percent);
+            list.add(stat);
+        }
+        return list;
+    }
+
+    private static Object itemToMap(JSONArray dataArray) {
+        List<Object> list = new ArrayList<>();
+        for (int i = 0; i < dataArray.size(); i++) {
+            list.add(dataArray.getJSONObject(i));
+        }
+        return list;
+    }
+
+    /**
      * 格式化时长为 xx时xx分xx秒 格式
      * 时不为0则展示xx时xx分xx秒
      * 时和分都为0则只展示xx秒