[feat] #50 회원가입 시 임베딩된 이미지도 저장

[feat] #50 회원가입 시 임베딩된 이미지도 저장

Author: jinsol24

build.gradle

@@ -46,6 +46,7 @@ dependencies {
 	implementation 'org.springframework.boot:spring-boot-starter-data-redis'
 	implementation 'org.springframework.boot:spring-boot-starter-websocket'
 
+	implementation 'org.springframework.boot:spring-boot-starter-webflux'
 
 	implementation 'io.jsonwebtoken:jjwt-api:0.11.5'
 	runtimeOnly 'io.jsonwebtoken:jjwt-impl:0.11.5'
@@ -62,6 +63,7 @@ dependencies {
 	testImplementation 'org.springframework.boot:spring-boot-starter-test'
 	testRuntimeOnly 'org.junit.platform:junit-platform-launcher'
 
+
 }
 
 tasks.named('test') {

src/main/java/com/okagaka/OkaGaka/OkaGakaApplication.java

@@ -2,7 +2,9 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.scheduling.annotation.EnableAsync;
 
+@EnableAsync
 @SpringBootApplication
 public class OkaGakaApplication {
 

src/main/java/com/okagaka/OkaGaka/common/config/WebClientConfig.java

@@ -0,0 +1,13 @@
+package com.okagaka.OkaGaka.common.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.web.reactive.function.client.WebClient;
+
+@Configuration
+public class WebClientConfig {
+    @Bean
+    public WebClient.Builder webClientBuilder() {
+        return WebClient.builder();
+    }
+}

src/main/java/com/okagaka/OkaGaka/common/external/embedding/EmbeddingApiClient.java

@@ -0,0 +1,52 @@
+package com.okagaka.OkaGaka.common.external.embedding;
+
+import com.okagaka.OkaGaka.domain.signup.dto.EmbeddingRequestDto;
+import com.okagaka.OkaGaka.domain.signup.dto.EmbeddingResponseDto;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.http.HttpStatusCode;
+import org.springframework.http.MediaType;
+import org.springframework.stereotype.Component;
+import org.springframework.web.reactive.function.client.WebClient;
+import reactor.core.publisher.Mono;
+
+@Component
+public class EmbeddingApiClient {
+
+    private final WebClient webClient;
+
+    private static final Logger log = LoggerFactory.getLogger(EmbeddingApiClient.class);
+
+    // WebClient.Builder를 주입받아 API 서버의 기본 정보를 설정합니다.
+    public EmbeddingApiClient(WebClient.Builder webClientBuilder) {
+        this.webClient = webClientBuilder
+                .baseUrl("http://13.124.128.236:8000")
+                .build();
+    }
+
+    /**
+     * 얼굴 이미지 정보로부터 Embedding 정보를 요청하는 메소드
+     * @param requestDto API 요청에 필요한 데이터 (userId, image 리스트)
+     * @return API 응답을 파싱한 DTO 객체
+     */
+    public EmbeddingResponseDto getEmbeddings(EmbeddingRequestDto requestDto) {
+        return webClient.post() // POST 요청
+                .uri("/v1/embeddings") // 기본 URL 뒤에 붙는 상세 경로
+                .contentType(MediaType.APPLICATION_JSON) // 요청 본문의 타입은 JSON
+                .bodyValue(requestDto) // 요청 본문에 실어보낼 객체
+                .retrieve() // 응답을 받아옴
+                .onStatus(HttpStatusCode::isError, response ->
+                        // 응답 본문을 문자열로 읽어옵니다.
+                        response.bodyToMono(String.class)
+                                .flatMap(errorBody -> {
+                                    // 실제 에러 로그를 자세히 출력합니다.
+                                    log.error("Embedding API 호출 실패. Status: {}, Body: {}", response.statusCode(), errorBody);
+                                    // 예외를 발생시켜 트랜잭션 롤백 등을 유도합니다.
+                                    return Mono.error(new RuntimeException("Embedding API 호출 실패: " + errorBody));
+                                })
+                )
+                .bodyToMono(EmbeddingResponseDto.class) // 응답 본문을 EmbeddingResponseDto 객체로 변환
+                .block(); // 비동기 스트림(Mono)의 처리가 끝날 때까지 기다린 후 최종 결과를 반환 (동기 방식 처리)
+    }
+
+}

src/main/java/com/okagaka/OkaGaka/domain/carrequest/controller/CarRequestController.java

@@ -0,0 +1,36 @@
+//package com.okagaka.OkaGaka.domain.carrequest.controller;
+//
+//import com.okagaka.OkaGaka.common.response.ApiResponse;
+//import com.okagaka.OkaGaka.common.security.CustomUserDetails;
+//import com.okagaka.OkaGaka.domain.carrequest.dto.CarRequestDto;
+//import com.okagaka.OkaGaka.domain.carrequest.service.CarRequestService;
+//import io.swagger.v3.oas.annotations.Operation;
+//import io.swagger.v3.oas.annotations.tags.Tag;
+//import lombok.RequiredArgsConstructor;
+//import org.springframework.http.ResponseEntity;
+//import org.springframework.security.core.annotation.AuthenticationPrincipal;
+//import org.springframework.web.bind.annotation.PostMapping;
+//import org.springframework.web.bind.annotation.RequestBody;
+//import org.springframework.web.bind.annotation.RequestMapping;
+//import org.springframework.web.bind.annotation.RestController;
+//
+//@RestController
+//@RequiredArgsConstructor
+//@RequestMapping("/api/car-request")
+//@Tag(name = "Car Request API", description = "차량 이용 요청 및 AI 추천 API")
+//public class CarRequestController {
+//    private final CarRequestService carRequestService;
+//
+//    @Operation(summary = "차량 이용 요청", description = "요청을 등록하고 AI의 추천 및 승인 절차를 시작합니다.")
+//    @PostMapping
+//    public ResponseEntity<ApiResponse<CarRequestResponseDto>> createCarReqeust(
+//            @RequestBody CarRequestDto requestDto,
+//            @AuthenticationPrincipal CustomUserDetails userDetails
+//    ) {
+//        Long userId = userDetails.getUserId();
+//        CarRequestResponseDto response = carRequestService.createAndProcessCarRequest(userId, requestDto);
+//        return ResponseEntity.accepted().body(ApiResponse.success(response)); // 202 Accepted 응답(요청은 받았지만 실제 처리는 비동기적으로 처리)
+//    }
+//
+//
+//}

src/main/java/com/okagaka/OkaGaka/domain/carrequest/dto/CarRequestDto.java

@@ -0,0 +1,14 @@
+package com.okagaka.OkaGaka.domain.carrequest.dto;
+
+public record CarRequestDto(
+        String departureCityDo,
+        String departureGuGun,
+        String departureDong,
+        String departureBunji,
+
+        // 도착지
+        String destinationCityDo,
+        String destinationGuGun,
+        String destinationDong,
+        String destinationBunji
+) { }

src/main/java/com/okagaka/OkaGaka/domain/carrequest/service/CarRequestService.java

@@ -0,0 +1,22 @@
+//package com.okagaka.OkaGaka.domain.carrequest.service;
+//
+//import com.okagaka.OkaGaka.domain.carrequest.dto.CarRequestDto;
+//import com.okagaka.OkaGaka.domain.carrequest.repository.CarRequestRepository;
+//import com.okagaka.OkaGaka.domain.user.repository.UserRepository;
+//import lombok.RequiredArgsConstructor;
+//import org.springframework.stereotype.Service;
+//import org.springframework.transaction.annotation.Transactional;
+//
+//@Service
+//@RequiredArgsConstructor
+//public class CarRequestService {
+//
+//    private final CarRequestRepository carRequestRepository;
+//    private final UserRepository userRepository;
+//    private final AsyncDecisionService asyncDecisionService;
+//
+//    @Transactional
+//    public CarRequestResponseDto createAndProcessCarRequest(Long userId, CarRequestDto requestDto) {
+//
+//    }
+//}

src/main/java/com/okagaka/OkaGaka/domain/reservation/entity/Reservation.java

@@ -86,7 +86,7 @@ public class Reservation extends BaseTimeEntity {
 
     private int travelTimeSec; // 경로 소요 시간(초 단위)
 
-    private int recalculatedTravelTimeSec; // 카풀 시 재계산한 시간
+//    private int recalculatedTravelTimeSec; // 카풀 시 재계산한 시간
 
 //    private Boolean isRecurring;
 //

src/main/java/com/okagaka/OkaGaka/domain/signup/dto/EmbeddingData.java

@@ -0,0 +1,13 @@
+package com.okagaka.OkaGaka.domain.signup.dto;
+
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+import java.util.List;
+
+@Getter
+@NoArgsConstructor
+public class EmbeddingData {
+    private Long userId;
+    private List<EmbeddingItem> items;
+}

src/main/java/com/okagaka/OkaGaka/domain/signup/dto/EmbeddingItem.java

@@ -0,0 +1,11 @@
+package com.okagaka.OkaGaka.domain.signup.dto;
+
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Getter
+@NoArgsConstructor
+public class EmbeddingItem {
+    private Long id; // UserFaceImage의 ID
+    private String embeddingUrl;
+}