feat: AI 요약 및 영상 타임라인 기능 추가 (#53)

* feat: VideoTimeline 도메인 모델 추가 및 VideoAnalysisResult/Task에 summary, timeline 필드 추가 (#52)

* feat: VideoTimelinePersistencePort 추가 및 기존 포트에 summary, timelines 반영 (#52)

* feat: video_timeline 엔티티, Querydsl 레포지토리 및 어댑터 추가 (#52)

* feat: 영상 분석 결과 저장 및 조회 시 summary, timeline 처리 추가 (#52)

* refactor: Gemini 프롬프트 토큰 최적화 및 summary, timeline 추출 추가 (#52)

* feat: 영상 조회 응답에 summary, timelines(timestamp, timestampUrl) 반환 추가 (#52)

* test: 영상 타임라인 및 AI 요약 기능 테스트 보강

* feat: VideoAnalysisTask, VideoTimeline 캐싱 데코레이터 적용 (#52)

* refactor: ktlintformat (#52)

* test: 타임라인 두 번째 항목 description 검증 추가 (#52)

Author: toychip

linktrip-application/src/main/kotlin/com/linktrip/application/domain/video/VideoAnalysisResult.kt

@@ -4,11 +4,13 @@ data class VideoAnalysisResult(
     val valid: Boolean,
     val destination: String?,
     val title: String?,
+    val summary: String?,
     val estimatedMinCost: Long?,
     val estimatedMaxCost: Long?,
     val costBasis: CostBasis?,
     val hashtags: List<String>,
     val days: List<DaySchedule>,
+    val timeline: List<TimelineItem>,
 ) {
     data class DaySchedule(
         val day: Int,
@@ -22,4 +24,9 @@ data class VideoAnalysisResult(
         val description: String?,
         val tips: String?,
     )
+
+    data class TimelineItem(
+        val timestampSeconds: Int,
+        val description: String,
+    )
 }

linktrip-application/src/main/kotlin/com/linktrip/application/domain/video/VideoAnalysisResultSaver.kt

@@ -3,29 +3,35 @@ package com.linktrip.application.domain.video
 import com.linktrip.application.port.output.persistence.HashtagPersistencePort
 import com.linktrip.application.port.output.persistence.TravelItineraryItemPersistencePort
 import com.linktrip.application.port.output.persistence.VideoAnalysisTaskPersistencePort
+import com.linktrip.application.port.output.persistence.VideoTimelinePersistencePort
 import org.springframework.stereotype.Component
 import org.springframework.transaction.annotation.Transactional
 
 @Component
 class VideoAnalysisResultSaver(
     private val travelItineraryItemPersistencePort: TravelItineraryItemPersistencePort,
     private val videoAnalysisTaskPersistencePort: VideoAnalysisTaskPersistencePort,
+    private val videoTimelinePersistencePort: VideoTimelinePersistencePort,
     private val hashtagPersistencePort: HashtagPersistencePort,
 ) {
     @Transactional
     fun save(
         videoAnalysisTaskId: String,
         itineraryItems: List<TravelItineraryItem>,
+        summary: String? = null,
         estimatedMinCost: Long? = null,
         estimatedMaxCost: Long? = null,
         costBasis: CostBasis? = null,
         hashtags: List<String> = emptyList(),
+        timelines: List<VideoTimeline> = emptyList(),
     ) {
         travelItineraryItemPersistencePort.saveAll(itineraryItems)
+        videoTimelinePersistencePort.saveAll(timelines)
         videoAnalysisTaskPersistencePort.updateValidAndStatus(
             videoAnalysisTaskId,
             valid = true,
             VideoAnalysisTaskStatus.COMPLETED,
+            summary = summary,
             estimatedMinCost = estimatedMinCost,
             estimatedMaxCost = estimatedMaxCost,
             costBasis = costBasis,

linktrip-application/src/main/kotlin/com/linktrip/application/domain/video/VideoAnalysisTask.kt

@@ -10,6 +10,7 @@ data class VideoAnalysisTask(
     val youtubeUrl: String,
     val valid: Boolean,
     val status: VideoAnalysisTaskStatus,
+    val summary: String? = null,
     val estimatedMinCost: Long? = null,
     val estimatedMaxCost: Long? = null,
     val costBasis: CostBasis? = null,

linktrip-application/src/main/kotlin/com/linktrip/application/domain/video/VideoAnalyzeEventListener.kt

@@ -48,13 +48,16 @@ class VideoAnalyzeEventListener(
             destination = result.destination
             title = result.title
             val itineraryItems = toItineraryItems(event.videoAnalysisTaskId, result)
+            val timelines = toTimelines(event.videoAnalysisTaskId, result)
             videoAnalysisResultSaver.save(
                 event.videoAnalysisTaskId,
                 itineraryItems,
+                summary = result.summary,
                 estimatedMinCost = result.estimatedMinCost,
                 estimatedMaxCost = result.estimatedMaxCost,
                 costBasis = result.costBasis,
                 hashtags = result.hashtags,
+                timelines = timelines,
             )
 
             val analyzeElapsed = System.currentTimeMillis() - startTime
@@ -127,4 +130,16 @@ class VideoAnalyzeEventListener(
                 TravelItineraryItem.from(videoAnalysisTaskId, daySchedule, item)
             }
         }
+
+    private fun toTimelines(
+        videoAnalysisTaskId: String,
+        result: VideoAnalysisResult,
+    ): List<VideoTimeline> =
+        result.timeline.map { timelineItem ->
+            VideoTimeline.create(
+                videoAnalysisTaskId = videoAnalysisTaskId,
+                timestampSeconds = timelineItem.timestampSeconds,
+                description = timelineItem.description,
+            )
+        }
 }

linktrip-application/src/main/kotlin/com/linktrip/application/domain/video/VideoScheduleService.kt

@@ -4,6 +4,7 @@ import com.linktrip.application.port.input.VideoScheduleResult
 import com.linktrip.application.port.input.VideoScheduleUseCase
 import com.linktrip.application.port.output.persistence.TravelItineraryItemPersistencePort
 import com.linktrip.application.port.output.persistence.VideoAnalysisTaskPersistencePort
+import com.linktrip.application.port.output.persistence.VideoTimelinePersistencePort
 import com.linktrip.common.exception.ExceptionCode
 import com.linktrip.common.exception.LinktripException
 import org.springframework.stereotype.Service
@@ -14,14 +15,16 @@ import org.springframework.transaction.annotation.Transactional
 class VideoScheduleService(
     private val videoAnalysisTaskPersistencePort: VideoAnalysisTaskPersistencePort,
     private val travelItineraryItemPersistencePort: TravelItineraryItemPersistencePort,
+    private val videoTimelinePersistencePort: VideoTimelinePersistencePort,
 ) : VideoScheduleUseCase {
     override fun getVideoSchedule(videoAnalysisTaskId: String): VideoScheduleResult {
         val videoAnalysisTask =
             videoAnalysisTaskPersistencePort.findById(videoAnalysisTaskId)
                 ?: throw LinktripException(ExceptionCode.NOT_FOUND_VIDEO_ANALYSIS_TASK)
 
         val items = travelItineraryItemPersistencePort.findByVideoAnalysisTaskIdWithPlace(videoAnalysisTaskId)
+        val timelines = videoTimelinePersistencePort.findByVideoAnalysisTaskId(videoAnalysisTaskId)
 
-        return VideoScheduleResult(videoAnalysisTask, items)
+        return VideoScheduleResult(videoAnalysisTask, items, timelines)
     }
 }

linktrip-application/src/main/kotlin/com/linktrip/application/domain/video/VideoTimeline.kt

@@ -0,0 +1,27 @@
+package com.linktrip.application.domain.video
+
+import com.linktrip.application.domain.common.IdGenerator
+import java.time.LocalDateTime
+
+data class VideoTimeline(
+    val id: String,
+    val videoAnalysisTaskId: String,
+    val timestampSeconds: Int,
+    val description: String,
+    val createdAt: LocalDateTime = LocalDateTime.now(),
+    val updatedAt: LocalDateTime = LocalDateTime.now(),
+) {
+    companion object {
+        fun create(
+            videoAnalysisTaskId: String,
+            timestampSeconds: Int,
+            description: String,
+        ): VideoTimeline =
+            VideoTimeline(
+                id = IdGenerator.generate(),
+                videoAnalysisTaskId = videoAnalysisTaskId,
+                timestampSeconds = timestampSeconds,
+                description = description,
+            )
+    }
+}

linktrip-application/src/main/kotlin/com/linktrip/application/port/input/VideoScheduleUseCase.kt

@@ -2,6 +2,7 @@ package com.linktrip.application.port.input
 
 import com.linktrip.application.domain.video.TravelItineraryItem
 import com.linktrip.application.domain.video.VideoAnalysisTask
+import com.linktrip.application.domain.video.VideoTimeline
 
 interface VideoScheduleUseCase {
     fun getVideoSchedule(videoAnalysisTaskId: String): VideoScheduleResult
@@ -10,4 +11,5 @@ interface VideoScheduleUseCase {
 data class VideoScheduleResult(
     val videoAnalysisTask: VideoAnalysisTask,
     val items: List<TravelItineraryItem>,
+    val timelines: List<VideoTimeline>,
 )

linktrip-application/src/main/kotlin/com/linktrip/application/port/output/persistence/VideoAnalysisTaskPersistencePort.kt

@@ -20,6 +20,7 @@ interface VideoAnalysisTaskPersistencePort {
         id: String,
         valid: Boolean,
         status: VideoAnalysisTaskStatus,
+        summary: String? = null,
         estimatedMinCost: Long? = null,
         estimatedMaxCost: Long? = null,
         costBasis: CostBasis? = null,

linktrip-application/src/main/kotlin/com/linktrip/application/port/output/persistence/VideoTimelinePersistencePort.kt

@@ -0,0 +1,9 @@
+package com.linktrip.application.port.output.persistence
+
+import com.linktrip.application.domain.video.VideoTimeline
+
+interface VideoTimelinePersistencePort {
+    fun saveAll(timelines: List<VideoTimeline>)
+
+    fun findByVideoAnalysisTaskId(videoAnalysisTaskId: String): List<VideoTimeline>
+}

linktrip-application/src/test/kotlin/com/linktrip/application/domain/video/VideoAnalysisResultSaverTest.kt

@@ -3,11 +3,14 @@ package com.linktrip.application.domain.video
 import com.linktrip.application.port.output.persistence.HashtagPersistencePort
 import com.linktrip.application.port.output.persistence.TravelItineraryItemPersistencePort
 import com.linktrip.application.port.output.persistence.VideoAnalysisTaskPersistencePort
+import com.linktrip.application.port.output.persistence.VideoTimelinePersistencePort
 import org.junit.jupiter.api.Test
 import org.junit.jupiter.api.extension.ExtendWith
 import org.mockito.InjectMocks
 import org.mockito.Mock
 import org.mockito.junit.jupiter.MockitoExtension
+import org.mockito.kotlin.anyOrNull
+import org.mockito.kotlin.eq
 import org.mockito.kotlin.verify
 
 @ExtendWith(MockitoExtension::class)
@@ -18,6 +21,9 @@ class VideoAnalysisResultSaverTest {
     @Mock
     lateinit var videoAnalysisTaskPersistencePort: VideoAnalysisTaskPersistencePort
 
+    @Mock
+    lateinit var videoTimelinePersistencePort: VideoTimelinePersistencePort
+
     @Mock
     lateinit var hashtagPersistencePort: HashtagPersistencePort
 
@@ -31,7 +37,7 @@ class VideoAnalysisResultSaverTest {
             listOf(
                 TravelItineraryItem(
                     id = "item-1",
-                    videoAnalysisTaskId = "summary-1",
+                    videoAnalysisTaskId = "task-1",
                     day = 1,
                     itemOrder = 1,
                     category = Category.EAT,
@@ -42,14 +48,43 @@ class VideoAnalysisResultSaverTest {
             )
 
         // when - 분석 결과를 저장한다
-        saver.save("summary-1", items)
+        saver.save("task-1", items)
 
         // then - 일정 항목이 저장되고, VideoAnalysisTask가 COMPLETED로 변경된다
         verify(travelItineraryItemPersistencePort).saveAll(items)
         verify(videoAnalysisTaskPersistencePort).updateValidAndStatus(
-            "summary-1",
-            valid = true,
-            VideoAnalysisTaskStatus.COMPLETED,
+            eq("task-1"),
+            eq(true),
+            eq(VideoAnalysisTaskStatus.COMPLETED),
+            anyOrNull(),
+            anyOrNull(),
+            anyOrNull(),
+            anyOrNull(),
         )
     }
+
+    @Test
+    fun `타임라인이 있는 분석 결과를 저장하면_타임라인도 DB에 함께 저장된다`() {
+        // given - 타임라인이 포함된 저장 요청
+        val timelines =
+            listOf(
+                VideoTimeline.create("task-1", 0, "인트로"),
+                VideoTimeline.create("task-1", 135, "시부야 스크램블 교차로"),
+            )
+
+        // when - 타임라인과 함께 저장한다
+        saver.save("task-1", emptyList(), timelines = timelines)
+
+        // then - 타임라인이 DB에 저장된다
+        verify(videoTimelinePersistencePort).saveAll(timelines)
+    }
+
+    @Test
+    fun `타임라인이 없는 분석 결과를 저장하면_빈 리스트로 타임라인 저장이 호출된다`() {
+        // when - 타임라인 없이 저장한다
+        saver.save("task-1", emptyList())
+
+        // then - 빈 리스트로 타임라인 저장이 호출된다
+        verify(videoTimelinePersistencePort).saveAll(emptyList())
+    }
 }