feat: 유저 가입 경로 및 디바이스 플랫폼 통계 조회 기능 추가 (#296)

Author: pizzazoa

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

@@ -13,6 +13,7 @@
 import java.time.*;
 import java.util.EnumSet;
 import java.util.HashMap;
+import java.util.List;
 import java.util.Map;
 import java.util.Set;
 
@@ -45,6 +46,9 @@ public void aggregateFor(LocalDate date, Set<StatMetric> metrics) {
                 case USER_DAU -> aggregateUserDau(date);
                 case USER_WAU -> aggregateUserWau(date);
                 case USER_MAU -> aggregateUserMau(date);
+
+                case USER_SIGNUP_SOURCE_TOTAL -> aggregateUserSignupSourceTotal(date);
+                case USER_DEVICE_PLATFORM_TOTAL -> aggregateUserDevicePlatformTotal(date);
             }
         }
     }
@@ -220,6 +224,47 @@ SELECT COUNT(DISTINCT user_id) FROM user_activity_ping
         dailyRepo.upsertValue(StatMetric.USER_MAU, date, n.longValue());
     }
 
+    /** 누적 가입 경로별 가입자 수 (스냅샷): signupCompletedAt < end, signupSource IS NOT NULL */
+    private void aggregateUserSignupSourceTotal(LocalDate date) {
+        var end = endExclusive(date);
+
+        @SuppressWarnings("unchecked")
+        List<Object[]> rows = em.createQuery("""
+                SELECT u.signupSource, COUNT(u) FROM User u
+                WHERE u.signupCompletedAt < :end
+                  AND u.signupSource IS NOT NULL
+                GROUP BY u.signupSource
+                """)
+                .setParameter("end", end)
+                .getResultList();
+
+        Map<String, Object> payload = new HashMap<>();
+        for (Object[] row : rows) {
+            payload.put(row[0].toString(), ((Number) row[1]).longValue());
+        }
+        dailyRepo.upsertPayload(StatMetric.USER_SIGNUP_SOURCE_TOTAL, date, payload);
+    }
+
+    /** 누적 플랫폼별 유니크 유저 수 (스냅샷): UserDevice.createdAt < end */
+    private void aggregateUserDevicePlatformTotal(LocalDate date) {
+        var end = endExclusive(date);
+
+        @SuppressWarnings("unchecked")
+        List<Object[]> rows = em.createQuery("""
+                SELECT ud.platform, COUNT(DISTINCT ud.user.id) FROM UserDevice ud
+                WHERE ud.createdAt < :end
+                GROUP BY ud.platform
+                """)
+                .setParameter("end", end)
+                .getResultList();
+
+        Map<String, Object> payload = new HashMap<>();
+        for (Object[] row : rows) {
+            payload.put(row[0].toString(), ((Number) row[1]).longValue());
+        }
+        dailyRepo.upsertPayload(StatMetric.USER_DEVICE_PLATFORM_TOTAL, date, payload);
+    }
+
     /* Helpers */
 
     private OffsetDateTime endExclusive(LocalDate date) {

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

@@ -41,7 +41,10 @@ public void runDailyAggregation() {
                 StatMetric.USER_WITHDRAWAL_DAILY,
                 StatMetric.USER_DAU,
                 StatMetric.USER_WAU,
-                StatMetric.USER_MAU
+                StatMetric.USER_MAU,
+
+                StatMetric.USER_SIGNUP_SOURCE_TOTAL,
+                StatMetric.USER_DEVICE_PLATFORM_TOTAL
         )) {
             var last = dailyRepo.findLastDateOf(metric).orElse(null);
             LocalDate from = (last == null) ? yesterday : last.plusDays(1);

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

@@ -9,6 +9,9 @@
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
+import org.devkor.apu.saerok_server.domain.notification.core.entity.DevicePlatform;
+import org.devkor.apu.saerok_server.domain.user.core.entity.SignupSourceType;
+
 import java.time.LocalDate;
 import java.time.format.DateTimeParseException;
 import java.util.*;
@@ -51,6 +54,25 @@ public StatSeriesResponse getSeries(List<StatMetric> metrics, String period) {
                 );
 
                 out.add(StatSeriesResponse.multi(m.name(), List.of(minSeries, maxSeries, avgSeries, stdSeries)));
+
+            } else if (m == StatMetric.USER_SIGNUP_SOURCE_TOTAL) {
+                List<StatSeriesResponse.ComponentSeries> components = Arrays.stream(SignupSourceType.values())
+                        .map(src -> new StatSeriesResponse.ComponentSeries(
+                                src.name(),
+                                rows.stream().map(s ->
+                                        new StatSeriesResponse.Point(s.getDate(), numberOrNull(s.getPayload().get(src.name())))).toList()
+                        )).toList();
+                out.add(StatSeriesResponse.multi(m.name(), components));
+
+            } else if (m == StatMetric.USER_DEVICE_PLATFORM_TOTAL) {
+                List<StatSeriesResponse.ComponentSeries> components = Arrays.stream(DevicePlatform.values())
+                        .map(p -> new StatSeriesResponse.ComponentSeries(
+                                p.name(),
+                                rows.stream().map(s ->
+                                        new StatSeriesResponse.Point(s.getDate(), numberOrNull(s.getPayload().get(p.name())))).toList()
+                        )).toList();
+                out.add(StatSeriesResponse.multi(m.name(), components));
+
             } else {
                 List<StatSeriesResponse.Point> points = rows.stream()
                         .map(s -> new StatSeriesResponse.Point(s.getDate(), numberOrNull(s.getPayload().get("value"))))

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

@@ -12,5 +12,8 @@ public enum StatMetric {
     USER_WITHDRAWAL_DAILY,           // 일일 탈퇴자 수 — deleted_at 기준
     USER_DAU,                        // 일일 활성 사용자 수 — user_activity_ping DISTINCT(user_id)
     USER_WAU,                        // 주간 활성 사용자 수(마지막 7일 rolling)
-    USER_MAU                         // 월간 활성 사용자 수(마지막 30일 rolling)
+    USER_MAU,                        // 월간 활성 사용자 수(마지막 30일 rolling)
+
+    USER_SIGNUP_SOURCE_TOTAL,        // 누적 가입 경로별 가입자 수 (스냅샷, 멀티값) — signupCompletedAt 기준
+    USER_DEVICE_PLATFORM_TOTAL       // 누적 플랫폼별 유니크 유저 수 (스냅샷, 멀티값) — UserDevice.createdAt 기준
 }