refactor: AnalysisCompletedHandler 책임 분리

src/main/java/io/wisoft/prepair/prepair_api/interview/answer/controller/AnswerController.java

@@ -1,7 +1,7 @@
 package io.wisoft.prepair.prepair_api.interview.answer.controller;
 
-import io.wisoft.prepair.prepair_api.interview.answer.dto.AnswerRequest;
-import io.wisoft.prepair.prepair_api.interview.answer.dto.FeedbackResponse;
+import io.wisoft.prepair.prepair_api.interview.answer.dto.request.AnswerRequest;
+import io.wisoft.prepair.prepair_api.interview.answer.dto.response.FeedbackResponse;
 import io.wisoft.prepair.prepair_api.common.response.ApiResponse;
 import io.wisoft.prepair.prepair_api.interview.answer.service.AnswerService;
 import io.wisoft.prepair.prepair_api.interview.answer.service.VideoAnswerSseService;

src/main/java/io/wisoft/prepair/prepair_api/interview/answer/dto/AnswerSubmitResult.java → src/main/java/io/wisoft/prepair/prepair_api/interview/answer/dto/internal/AnswerSubmitResult.java

@@ -1,4 +1,4 @@
-package io.wisoft.prepair.prepair_api.interview.answer.dto;
+package io.wisoft.prepair.prepair_api.interview.answer.dto.internal;
 
 import io.wisoft.prepair.prepair_api.interview.answer.entity.InterviewFeedback;
 

src/main/java/io/wisoft/prepair/prepair_api/interview/answer/dto/CombinedFeedbackResult.java → src/main/java/io/wisoft/prepair/prepair_api/interview/answer/dto/internal/CombinedFeedbackResult.java

@@ -1,7 +1,7 @@
-package io.wisoft.prepair.prepair_api.interview.answer.dto;
+package io.wisoft.prepair.prepair_api.interview.answer.dto.internal;
 
 public record CombinedFeedbackResult(
         String combineFeedback,
         int score
 ) {
-}
+}

src/main/java/io/wisoft/prepair/prepair_api/interview/answer/dto/FeedbackDetail.java → src/main/java/io/wisoft/prepair/prepair_api/interview/answer/dto/internal/FeedbackDetail.java

@@ -1,4 +1,4 @@
-package io.wisoft.prepair.prepair_api.interview.answer.dto;
+package io.wisoft.prepair.prepair_api.interview.answer.dto.internal;
 
 public record FeedbackDetail(
         String good,

src/main/java/io/wisoft/prepair/prepair_api/interview/answer/dto/FeedbackResult.java → src/main/java/io/wisoft/prepair/prepair_api/interview/answer/dto/internal/FeedbackResult.java

@@ -1,4 +1,4 @@
-package io.wisoft.prepair.prepair_api.interview.answer.dto;
+package io.wisoft.prepair.prepair_api.interview.answer.dto.internal;
 
 public record FeedbackResult(
         String good,

src/main/java/io/wisoft/prepair/prepair_api/interview/answer/dto/internal/FinalFeedbackInput.java

@@ -0,0 +1,11 @@
+package io.wisoft.prepair.prepair_api.interview.answer.dto.internal;
+
+import java.util.UUID;
+
+public record FinalFeedbackInput(
+        UUID questionId,
+        String question,
+        String combinedFeedback,
+        int score
+) {
+}

src/main/java/io/wisoft/prepair/prepair_api/interview/answer/dto/internal/FinalFeedbackResult.java

@@ -0,0 +1,6 @@
+package io.wisoft.prepair.prepair_api.interview.answer.dto.internal;
+
+public record FinalFeedbackResult(
+        String finalFeedback
+) {
+}

src/main/java/io/wisoft/prepair/prepair_api/interview/answer/dto/AnswerRequest.java → src/main/java/io/wisoft/prepair/prepair_api/interview/answer/dto/request/AnswerRequest.java

@@ -1,4 +1,4 @@
-package io.wisoft.prepair.prepair_api.interview.answer.dto;
+package io.wisoft.prepair.prepair_api.interview.answer.dto.request;
 
 import jakarta.validation.constraints.NotBlank;
 

src/main/java/io/wisoft/prepair/prepair_api/interview/answer/dto/FeedbackResponse.java → src/main/java/io/wisoft/prepair/prepair_api/interview/answer/dto/response/FeedbackResponse.java

@@ -1,5 +1,6 @@
-package io.wisoft.prepair.prepair_api.interview.answer.dto;
+package io.wisoft.prepair.prepair_api.interview.answer.dto.response;
 
+import io.wisoft.prepair.prepair_api.interview.answer.dto.internal.FeedbackDetail;
 import io.wisoft.prepair.prepair_api.interview.answer.entity.InterviewFeedback;
 import io.wisoft.prepair.prepair_api.interview.answer.entity.FeedbackType;
 

src/main/java/io/wisoft/prepair/prepair_api/interview/answer/dto/FinalFeedbackResponse.java → src/main/java/io/wisoft/prepair/prepair_api/interview/answer/dto/response/FinalFeedbackResponse.java

@@ -1,4 +1,4 @@
-package io.wisoft.prepair.prepair_api.interview.answer.dto;
+package io.wisoft.prepair.prepair_api.interview.answer.dto.response;
 
 import java.util.List;
 import java.util.UUID;
@@ -18,4 +18,4 @@ public record QuestionFeedback(
             String videoFeedback
     ) {
     }
-}
+}

src/main/java/io/wisoft/prepair/prepair_api/interview/answer/event/AllAnalysisCompletedEvent.java → src/main/java/io/wisoft/prepair/prepair_api/interview/answer/event/AnalysisCompletedEvent.java

@@ -2,5 +2,5 @@
 
 import java.util.UUID;
 
-public record AllAnalysisCompletedEvent(UUID answerId, boolean hasFailed) {
+public record AnalysisCompletedEvent(UUID answerId, boolean hasFailed) {
 }

src/main/java/io/wisoft/prepair/prepair_api/interview/answer/event/AnalysisCompletedHandler.java

@@ -0,0 +1,37 @@
+package io.wisoft.prepair.prepair_api.interview.answer.event;
+
+import io.wisoft.prepair.prepair_api.interview.answer.service.AnalysisCompletionService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.event.EventListener;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Component;
+
+import java.util.UUID;
+
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class AnalysisCompletedHandler {
+
+    private final AnalysisCompletionService analysisCompletionService;
+
+    @Async("videoTaskExecutor")
+    @EventListener
+    public void handle(AnalysisCompletedEvent event) {
+        UUID answerId = event.answerId();
+
+        if (event.hasFailed()) {
+            log.error("[종합평가] 분석 실패로 종합평가 생략 - answerId: {}", answerId);
+            analysisCompletionService.failSession(answerId, "분석 중 오류가 발생했습니다.");
+            return;
+        }
+
+        try {
+            analysisCompletionService.processAnalysisCompletion(answerId);
+        } catch (Exception e) {
+            log.error("[종합평가] 실패 - answerId: {}, error: {}", answerId, e.getMessage(), e);
+            analysisCompletionService.failSession(answerId, "종합 평가 생성 중 오류가 발생했습니다.");
+        }
+    }
+}

src/main/java/io/wisoft/prepair/prepair_api/interview/answer/event/AnalysisCompletionTracker.java

@@ -54,7 +54,7 @@ private void finishAnalysis(UUID answerId, boolean failed) {
         int analysisCount = state.analysisCount.incrementAndGet();
         if (analysisCount == ANALYSIS_TASKS) {
             eventPublisher.publishEvent(
-                    new AllAnalysisCompletedEvent(answerId, state.analysisFailed.get())
+                    new AnalysisCompletedEvent(answerId, state.analysisFailed.get())
             );
         }
         finishTask(answerId);

src/main/java/io/wisoft/prepair/prepair_api/interview/answer/event/VideoAnswerProcessor.java

@@ -3,8 +3,8 @@
 import io.wisoft.prepair.prepair_api.common.exception.BusinessException;
 import io.wisoft.prepair.prepair_api.common.exception.ErrorCode;
 import io.wisoft.prepair.prepair_api.external.storage.S3FileStorage;
-import io.wisoft.prepair.prepair_api.interview.answer.dto.FeedbackDetail;
-import io.wisoft.prepair.prepair_api.interview.answer.dto.FeedbackResult;
+import io.wisoft.prepair.prepair_api.interview.answer.dto.internal.FeedbackDetail;
+import io.wisoft.prepair.prepair_api.interview.answer.dto.internal.FeedbackResult;
 import io.wisoft.prepair.prepair_api.interview.answer.entity.FeedbackType;
 import io.wisoft.prepair.prepair_api.interview.answer.service.AnswerPersistenceService;
 import io.wisoft.prepair.prepair_api.interview.answer.service.FeedbackGenerator;