♻️ Refactor - AI API 1번 요청을 병렬 요청으로 리팩토링한다

♻️ Refactor - AI API 1번 요청을 병렬 요청으로 리팩토링한다

Author: oOccasio

src/main/java/sopt/comfit/report/controller/AIReportController.java

@@ -5,7 +5,6 @@
 import lombok.RequiredArgsConstructor;
 import org.springframework.data.domain.PageRequest;
 import org.springframework.data.domain.Pageable;
-import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.*;
 import reactor.core.publisher.Mono;
 import sopt.comfit.company.dto.response.GetReportCompanyResponseDto;
@@ -16,57 +15,64 @@
 import sopt.comfit.report.dto.request.MatchExperienceRequestDto;
 import sopt.comfit.report.dto.response.AIReportResponseDto;
 import sopt.comfit.report.dto.response.GetReportSummaryResponseDto;
-import sopt.comfit.report.service.AIReportService;
+import sopt.comfit.report.service.AIReportFacade;
 
 @RestController
 @RequiredArgsConstructor
 @RequestMapping("/api/v1/ai-reports")
 public class AIReportController implements AIReportSwagger {
 
-    private final AIReportService aiReportService;
-
-    @Override
-    public AIReportResponseDto matchExperience(@LoginUser Long userId,
-                                               @Valid @RequestBody MatchExperienceRequestDto requestDto){
-        return aiReportService.matchExperience(MatchExperienceCommandDto.of(userId, requestDto));
-    }
+    private final AIReportFacade aiReportFacade;
 
     @Override
     public PageDto<GetReportSummaryResponseDto> getReportList(@LoginUser Long userId,
                                                               @RequestParam(defaultValue = "1") int page,
                                                               @RequestParam(required = false) String keyword){
         Pageable pageable = PageRequest.of(Math.max(page - 1, 0), 4);
-        return aiReportService.getReportList(userId, pageable, keyword);
+        return aiReportFacade.getReportList(userId, pageable, keyword);
     }
 
     @Override
     public AIReportResponseDto getReport(@LoginUser Long userId,
                                          @PathVariable Long reportId){
-        return aiReportService.getReport(userId, reportId);
+        return aiReportFacade.getReport(userId, reportId);
     }
 
     @Override
     public GetReportExperienceResponseDto getReportExperience(@LoginUser Long userId){
 
-        return aiReportService.getReportExperience(userId);
+        return aiReportFacade.getReportExperience(userId);
     }
 
     @Override
     public GetReportCompanyResponseDto getReportCompany(@PathVariable Long companyId){
-        return aiReportService.getReportCompany(companyId);
+        return aiReportFacade.getReportCompany(companyId);
+    }
+
+    @Override
+    public AIReportResponseDto matchExperience(@LoginUser Long userId,
+                                               @Valid @RequestBody MatchExperienceRequestDto requestDto){
+        return aiReportFacade.matchExperience(MatchExperienceCommandDto.of(userId, requestDto));
     }
 
     @PostMapping("/match/async")
     @SecurityRequirement(name = "JWT")
     public Mono<AIReportResponseDto> matchAsync(@LoginUser Long userid ,
                                                 @RequestBody MatchExperienceRequestDto request) {
-        return aiReportService.matchExperienceAsync(MatchExperienceCommandDto.of(userid, request));
+        return aiReportFacade.matchExperienceAsync(MatchExperienceCommandDto.of(userid, request));
     }
 
     @PostMapping("/match/async/webclient")
     @SecurityRequirement(name = "JWT")
     public AIReportResponseDto matchAsyncWebClient(@LoginUser Long userid ,
                                                 @RequestBody MatchExperienceRequestDto request) {
-        return aiReportService.matchExperienceWebclient(MatchExperienceCommandDto.of(userid, request));
+        return aiReportFacade.matchExperienceWebclient(MatchExperienceCommandDto.of(userid, request));
+    }
+
+    @PostMapping("/match/async/parallel")
+    @SecurityRequirement(name = "JWT")
+    public Mono<AIReportResponseDto> matchExperienceWebfluxParallel(@LoginUser Long userId,
+                                                                    @RequestBody MatchExperienceRequestDto requestDto){
+        return aiReportFacade.matchExperienceParallel(MatchExperienceCommandDto.of(userId, requestDto));
     }
 }

src/main/java/sopt/comfit/report/domain/AIReport.java

@@ -90,7 +90,4 @@ public static AIReport create(
                 .company(company)
                 .build();
     }
-
-
-
 }

src/main/java/sopt/comfit/report/exception/AIReportErrorCode.java

@@ -17,7 +17,8 @@ public enum AIReportErrorCode implements ErrorCode {
     AI_AUTH_FAILED(HttpStatus.INTERNAL_SERVER_ERROR, "AI_500_002", "AI 서비스 인증 실패"),
     AI_RATE_LIMITED(HttpStatus.TOO_MANY_REQUESTS, "AI_429_001", "AI 요청 한도 초과"),
     AI_SERVER_ERROR(HttpStatus.BAD_GATEWAY, "AI_502_002", "AI 서버 오류"),
-
+    AI_CALL_FAILED(HttpStatus.INTERNAL_SERVER_ERROR, "AI_500_003", "AI 병렬 호출 실패"),
+    AI_RESPONSE_REQUIRED_FIELD_OMIT(HttpStatus.INTERNAL_SERVER_ERROR, "AI_500_004", "AI 응답이 필수 응답값을 누락했습니다.")
     ;
     private final HttpStatus status;
     private final String prefix;

src/main/java/sopt/comfit/report/infra/dto/PreparedDataDto.java

@@ -0,0 +1,21 @@
+package sopt.comfit.report.infra.dto;
+
+import sopt.comfit.company.domain.Company;
+import sopt.comfit.company.domain.CompanyIssue;
+import sopt.comfit.experience.domain.Experience;
+
+import java.util.List;
+
+public record PreparedDataDto(
+        Company company,
+        Experience experience,
+        String jobDescription,
+        List<CompanyIssue> issues
+) {
+    public static PreparedDataDto of(Company company,
+                                     Experience experience,
+                                     String jobDescription,
+                                     List<CompanyIssue> issues) {
+        return new PreparedDataDto(company, experience, jobDescription, issues);
+    }
+}