feat: 최근 28일 내 동정 요청 해결 시간 통계 추가 (#231)

Author: soonduck-dreams

src/main/java/org/devkor/apu/saerok_server/domain/stat/application/StatAggregationService.java

@@ -38,6 +38,7 @@ public void aggregateFor(LocalDate date, Set<StatMetric> metrics) {
                 case BIRD_ID_PENDING_COUNT -> aggregatePendingCount(date);
                 case BIRD_ID_RESOLVED_COUNT -> aggregateResolvedDaily(date);
                 case BIRD_ID_RESOLUTION_STATS -> aggregateResolutionStatsCumulative(date);
+                case BIRD_ID_RESOLUTION_STATS_28D -> aggregateResolutionStatsRecent28d(date);
 
                 case USER_COMPLETED_TOTAL -> aggregateUserCompletedTotal(date);
                 case USER_SIGNUP_DAILY -> aggregateUserSignupDaily(date);
@@ -109,6 +110,7 @@ private void aggregateResolvedDaily(LocalDate date) {
 
     /* Metric calculators (멀티값 → payload.{min/max/avg/stddev}_hours) */
 
+    /** 누적: 해당 날짜까지 전체 ADOPT 해결 시간 통계 */
     private void aggregateResolutionStatsCumulative(LocalDate date) {
         var end = endExclusive(date);
         Object[] row = histRepo.resolutionStatsCumulativeSecondsAsOf(end); // [min,max,avg,stddev] in seconds
@@ -130,6 +132,29 @@ private void aggregateResolutionStatsCumulative(LocalDate date) {
         dailyRepo.upsertPayload(StatMetric.BIRD_ID_RESOLUTION_STATS, date, p);
     }
 
+    /** 최근 28일: [end-28d, end) ADOPT 해결 시간 통계 */
+    private void aggregateResolutionStatsRecent28d(LocalDate date) {
+        var end = endExclusive(date);
+        var start = end.minusDays(28);
+        Object[] row = histRepo.resolutionStatsWindowSeconds(start, end); // [min,max,avg,stddev] in seconds
+
+        // 최근 28일 내 ADOPT 해결이 하나도 없으면 저장 생략
+        if (row == null || row[0] == null || row[1] == null || row[2] == null || row[3] == null) return;
+
+        double minH = ((Number) row[0]).doubleValue() / 3600.0;
+        double maxH = ((Number) row[1]).doubleValue() / 3600.0;
+        double avgH = ((Number) row[2]).doubleValue() / 3600.0;
+        double stdH = ((Number) row[3]).doubleValue() / 3600.0;
+
+        Map<String, Object> p = new HashMap<>();
+        p.put("min_hours",    minH);
+        p.put("max_hours",    maxH);
+        p.put("avg_hours",    avgH);
+        p.put("stddev_hours", stdH);
+
+        dailyRepo.upsertPayload(StatMetric.BIRD_ID_RESOLUTION_STATS_28D, date, p);
+    }
+
     /** 누적 가입자 수: COMPLETED 이고, day 끝 시점 기준으로 삭제되지 않은 사용자 */
     private void aggregateUserCompletedTotal(LocalDate date) {
         var end = endExclusive(date);

src/main/java/org/devkor/apu/saerok_server/domain/stat/application/StatBatchScheduler.java

@@ -34,7 +34,7 @@ public void runDailyAggregation() {
                 StatMetric.COLLECTION_PRIVATE_RATIO,
                 StatMetric.BIRD_ID_PENDING_COUNT,
                 StatMetric.BIRD_ID_RESOLVED_COUNT,
-                StatMetric.BIRD_ID_RESOLUTION_STATS,
+                StatMetric.BIRD_ID_RESOLUTION_STATS_28D,
 
                 StatMetric.USER_COMPLETED_TOTAL,
                 StatMetric.USER_SIGNUP_DAILY,

src/main/java/org/devkor/apu/saerok_server/domain/stat/application/StatQueryService.java

@@ -24,7 +24,7 @@ public StatSeriesResponse getSeries(List<StatMetric> metrics) {
         for (StatMetric m : metrics) {
             List<DailyStat> rows = dailyRepo.findSeriesByMetric(m);
 
-            if (m == StatMetric.BIRD_ID_RESOLUTION_STATS) {
+            if (m == StatMetric.BIRD_ID_RESOLUTION_STATS || m == StatMetric.BIRD_ID_RESOLUTION_STATS_28D) {
                 var minSeries = new StatSeriesResponse.ComponentSeries(
                         "min_hours",
                         rows.stream().map(s ->

src/main/java/org/devkor/apu/saerok_server/domain/stat/core/entity/StatMetric.java

@@ -5,7 +5,8 @@ public enum StatMetric {
     COLLECTION_PRIVATE_RATIO,        // 비공개 새록 비율 0..1 (스냅샷, 단일값)
     BIRD_ID_PENDING_COUNT,           // 진행 중 동정 요청 수 (스냅샷, 단일값)
     BIRD_ID_RESOLVED_COUNT,          // 누적 동정 요청 해결 수 (스냅샷, 단일값) — 동정 제안 채택(ADOPT)으로만 증가
-    BIRD_ID_RESOLUTION_STATS,        // 동정 요청 해결 시간 통계(누적): min/max/avg/stddev (멀티값) — 채택(ADOPT)으로만 집계
+    BIRD_ID_RESOLUTION_STATS,        // 동정 요청 해결 시간 통계(누적): min/max/avg/stddev (멀티값) — 채택(ADOPT)만 집계
+    BIRD_ID_RESOLUTION_STATS_28D,    // 동정 요청 해결 시간 통계(최근 28일): min/max/avg/stddev (멀티값) — 채택(ADOPT)만 집계
 
     USER_COMPLETED_TOTAL,            // 누적 가입자 수(스냅샷) — COMPLETED && 삭제되지 않음
     USER_SIGNUP_DAILY,               // 일일 가입자 수 — signup_completed_at 기준

src/main/java/org/devkor/apu/saerok_server/domain/stat/core/repository/BirdIdRequestHistoryRepository.java

@@ -85,6 +85,26 @@ public Object[] resolutionStatsCumulativeSecondsAsOf(OffsetDateTime endExclusive
         return row;
     }
 
+    /** 윈도우(구간) 해결 시간 통계 — 단위: "초" (ADOPT만) */
+    public Object[] resolutionStatsWindowSeconds(OffsetDateTime startInclusive, OffsetDateTime endExclusive) {
+        Object[] row = (Object[]) em.createNativeQuery("""
+        SELECT
+          MIN(resolution_seconds) AS min_s,
+          MAX(resolution_seconds) AS max_s,
+          AVG(resolution_seconds) AS avg_s,
+          STDDEV_POP(resolution_seconds) AS stddev_s
+        FROM bird_id_request_history
+        WHERE resolved_at IS NOT NULL
+          AND resolution_kind = 'ADOPT'
+          AND resolved_at >= ?1
+          AND resolved_at < ?2
+        """)
+                .setParameter(1, startInclusive)
+                .setParameter(2, endExclusive)
+                .getSingleResult();
+        return row;
+    }
+
     public long countResolvedOnDate(OffsetDateTime startInclusive, OffsetDateTime endExclusive) {
         return em.createQuery("""
                 SELECT COUNT(h) FROM BirdIdRequestHistory h
@@ -98,5 +118,4 @@ SELECT COUNT(h) FROM BirdIdRequestHistory h
                 .setParameter("end", endExclusive)
                 .getSingleResult();
     }
-
 }