feat: 트래킹 세션 종료 시 HikingRecord 자동 생성

Author: JangInho

src/main/java/com/semosan/api/domain/tracking/dto/response/TrackingSessionResponse.java

@@ -1,10 +1,12 @@
 package com.semosan.api.domain.tracking.dto.response;
 
+import com.fasterxml.jackson.annotation.JsonInclude;
 import com.semosan.api.domain.tracking.entity.TrackingSession;
 import com.semosan.api.domain.tracking.enums.TrackingSessionStatus;
 
 import java.time.LocalDateTime;
 
+@JsonInclude(JsonInclude.Include.NON_NULL)
 public record TrackingSessionResponse(
         Long sessionId,
         Long userId,
@@ -17,10 +19,16 @@ public record TrackingSessionResponse(
         LocalDateTime startedAt,
         LocalDateTime endedAt,
         LocalDateTime pausedAt,
-        Integer pausedSecondsTotal
+        Integer pausedSecondsTotal,
+        /** complete 시에만 채워짐 — 변환된 HikingRecord 의 ID. 다른 경로에선 null 직렬화에서 제외. */
+        Long hikingRecordId
 ) {
 
     public static TrackingSessionResponse from(TrackingSession session) {
+        return from(session, null);
+    }
+
+    public static TrackingSessionResponse from(TrackingSession session, Long hikingRecordId) {
         return new TrackingSessionResponse(
                 session.getId(),
                 session.getUser().getId(),
@@ -33,7 +41,8 @@ public static TrackingSessionResponse from(TrackingSession session) {
                 session.getStartedAt(),
                 session.getEndedAt(),
                 session.getPausedAt(),
-                session.getPausedSecondsTotal()
+                session.getPausedSecondsTotal(),
+                hikingRecordId
         );
     }
 }

src/main/java/com/semosan/api/domain/tracking/service/TrackingSessionService.java

@@ -2,6 +2,10 @@
 
 import com.semosan.api.common.exception.GeneralException;
 import com.semosan.api.common.status.ErrorStatus;
+import com.semosan.api.domain.hiking.entity.HikingMember;
+import com.semosan.api.domain.hiking.entity.HikingRecord;
+import com.semosan.api.domain.hiking.repository.HikingMemberRepository;
+import com.semosan.api.domain.hiking.repository.HikingRecordRepository;
 import com.semosan.api.domain.mountain.entity.Course;
 import com.semosan.api.domain.mountain.entity.Mountain;
 import com.semosan.api.domain.mountain.repository.CourseRepository;
@@ -33,6 +37,9 @@ public class TrackingSessionService {
     private final MountainRepository mountainRepository;
     private final CourseRepository courseRepository;
     private final UserReader userReader;
+    private final TrackingSessionStatsService statsService;
+    private final HikingRecordRepository hikingRecordRepository;
+    private final HikingMemberRepository hikingMemberRepository;
 
     @Transactional
     public TrackingSessionResponse create(Long userId, CreateTrackingSessionRequest request) {
@@ -75,14 +82,31 @@ public TrackingSessionResponse resume(Long userId, Long sessionId) {
     }
 
     /**
-     * 정상 종료. 본 메서드는 상태/시각만 마감하고, 실제 HikingRecord 변환은 #20 에서 추가될 예정.
-     * TODO(#20): 종료 시 Redis Stream 의 GPS 점들을 모아 통계 계산 + HikingRecord/HikingMember 생성.
+     * 정상 종료. 세션 상태를 COMPLETED 로 마감하고, Redis Hash 의 실시간 통계를 스냅샷 떠
+     * HikingRecord + HikingMember 로 영구 변환한다.
+     *  - 통계는 GPS Consumer 가 메시지 수신 즉시 갱신해두므로 종료 시점의 스냅샷이 최신값.
+     *  - 동행자 기능 미구현이므로 본인 1명만 HikingMember 로 등록.
+     *  - cliveImageUrl / photoReportImageUrl 은 #46 사진 흐름에서 채워질 예정 (현재 null).
      */
     @Transactional
     public TrackingSessionResponse complete(Long userId, Long sessionId) {
         TrackingSession session = findOwnedSession(userId, sessionId);
         session.complete();
-        return TrackingSessionResponse.from(session);
+
+        TrackingSessionStatsService.Stats stats = statsService.getStats(sessionId);
+        HikingRecord record = HikingRecord.fromTrackingSession(
+                session,
+                stats.distanceMeters(),
+                stats.maxAltitudeMeters(),
+                stats.ascentMeters(),
+                stats.descentMeters()
+        );
+        HikingRecord savedRecord = hikingRecordRepository.save(record);
+
+        HikingMember member = HikingMember.create(savedRecord, session.getUser());
+        hikingMemberRepository.save(member);
+
+        return TrackingSessionResponse.from(session, savedRecord.getId());
     }
 
     @Transactional

src/main/java/com/semosan/api/domain/tracking/service/TrackingSessionStatsService.java

@@ -38,6 +38,7 @@ public class TrackingSessionStatsService {
     private static final String F_DISTANCE_TOTAL = "distance_total";
     private static final String F_ASCENT_TOTAL = "ascent_total";
     private static final String F_DESCENT_TOTAL = "descent_total";
+    private static final String F_MAX_ALTITUDE = "max_altitude";
     private static final String F_POINT_COUNT = "point_count";
 
     private final StringRedisTemplate redisTemplate;
@@ -50,6 +51,7 @@ public void recordPoint(Long sessionId, double lat, double lng, Double altitude,
         double distanceTotal = parseDouble(prev.get(F_DISTANCE_TOTAL));
         double ascentTotal = parseDouble(prev.get(F_ASCENT_TOTAL));
         double descentTotal = parseDouble(prev.get(F_DESCENT_TOTAL));
+        Double maxAltitude = parseNullableDouble(prev.get(F_MAX_ALTITUDE));
         long pointCount = parseLong(prev.get(F_POINT_COUNT));
 
         Double prevLat = parseNullableDouble(prev.get(F_LAST_LAT));
@@ -66,6 +68,9 @@ public void recordPoint(Long sessionId, double lat, double lng, Double altitude,
                 descentTotal += -delta;
             }
         }
+        if (altitude != null && (maxAltitude == null || altitude > maxAltitude)) {
+            maxAltitude = altitude;
+        }
         pointCount += 1;
 
         Map<String, String> next = new HashMap<>();
@@ -78,6 +83,9 @@ public void recordPoint(Long sessionId, double lat, double lng, Double altitude,
         next.put(F_DISTANCE_TOTAL, String.valueOf(distanceTotal));
         next.put(F_ASCENT_TOTAL, String.valueOf(ascentTotal));
         next.put(F_DESCENT_TOTAL, String.valueOf(descentTotal));
+        if (maxAltitude != null) {
+            next.put(F_MAX_ALTITUDE, String.valueOf(maxAltitude));
+        }
         next.put(F_POINT_COUNT, String.valueOf(pointCount));
 
         hash.putAll(key, next);
@@ -88,6 +96,35 @@ public static String statsKey(Long sessionId) {
         return KEY_PREFIX + sessionId + STATS_SUFFIX;
     }
 
+    /**
+     * 세션 종료 시 통계 스냅샷 조회 — HikingRecord 생성에 사용된다.
+     * 점이 한 번도 들어오지 않았으면 모든 필드 0/null.
+     */
+    public Stats getStats(Long sessionId) {
+        Map<String, String> entries = redisTemplate.opsForHash().entries(statsKey(sessionId))
+                .entrySet().stream()
+                .collect(java.util.stream.Collectors.toMap(
+                        e -> String.valueOf(e.getKey()),
+                        e -> String.valueOf(e.getValue())
+                ));
+        return new Stats(
+                parseDouble(entries.get(F_DISTANCE_TOTAL)),
+                parseDouble(entries.get(F_ASCENT_TOTAL)),
+                parseDouble(entries.get(F_DESCENT_TOTAL)),
+                parseNullableDouble(entries.get(F_MAX_ALTITUDE)),
+                parseLong(entries.get(F_POINT_COUNT))
+        );
+    }
+
+    public record Stats(
+            double distanceMeters,
+            double ascentMeters,
+            double descentMeters,
+            Double maxAltitudeMeters,
+            long pointCount
+    ) {
+    }
+
     /** Haversine 거리(m). */
     static double haversineMeters(double lat1, double lng1, double lat2, double lng2) {
         double dLat = Math.toRadians(lat2 - lat1);