차량 요청 목록 조회api 추가, 역지오코딩으로 주소 추가 등등

jinsol24 · web-flow · commit 32dd7ecdfe65 · 2025-09-23T03:15:27.000+09:00
diff --git a/scripts/start.sh b/scripts/start.sh
@@ -25,6 +25,7 @@ export $(cat /home/ubuntu/apps/okagaka-server/.env | xargs)
 
 # DB, AWS, 기타 환경 변수 전달
 nohup java \
+  -Duser.timezone=Asia/Seoul \
   -DRDS_HOST=$RDS_HOST \
   -DRDS_PORT=$RDS_PORT \
   -DRDS_NAME=$RDS_NAME \
diff --git a/src/main/java/com/okagaka/OkaGaka/common/external/tmap/TmapGeocodingClient.java b/src/main/java/com/okagaka/OkaGaka/common/external/tmap/TmapGeocodingClient.java
@@ -55,4 +55,54 @@ public Coordinate getCoordinates(String cityDo, String guGun, String dong, Strin
 
         return new Coordinate(latitude, longitude);
     }
+
+    /**
+     * 좌표를 주소로 변환합니다. (역 지오코딩)
+     * 건물명(buildingName)을 우선적으로 반환하며, 없을 경우 '도로명 + 건물번호'를 반환합니다.
+     * @param longitude 경도
+     * @param latitude 위도
+     * @return 변환된 건물명 또는 도로명 주소
+     */
+    public String getAddress(double longitude, double latitude) {
+        String url = UriComponentsBuilder.fromHttpUrl("https://apis.openapi.sk.com/tmap/geo/reversegeocoding")
+                .queryParam("version", "1")
+                .queryParam("lat", latitude)
+                .queryParam("lon", longitude)
+                .queryParam("addressType", "A03") // A03: 도로명 주소
+                .encode()
+                .toUriString();
+
+        HttpHeaders headers = new HttpHeaders();
+        headers.set("Accept", "application/json");
+        headers.set("appKey", appKey);
+
+        HttpEntity<String> entity = new HttpEntity<>(headers);
+
+        ResponseEntity<JsonNode> response = restTemplate.exchange(url, HttpMethod.GET, entity, JsonNode.class);
+
+        JsonNode addressInfo = response.getBody().path("addressInfo");
+
+        if (addressInfo.isMissingNode()) {
+            throw new RuntimeException("주소 변환 실패: lat=" + latitude + ", lon=" + longitude);
+        }
+
+        // 1. buildingName을 우선적으로 가져옵니다.
+        String buildingName = addressInfo.path("buildingName").asText(null);
+
+        // 2. buildingName이 존재하고 비어있지 않다면, 해당 값을 바로 반환합니다.
+        if (buildingName != null && !buildingName.isEmpty()) {
+            return buildingName;
+        }
+
+        // 3. buildingName이 없는 경우, 대체 정보로 '도로명 + 건물번호'를 조합하여 반환합니다.
+        String roadName = addressInfo.path("roadName").asText("");
+        String buildingIndex = addressInfo.path("buildingIndex").asText("");
+        String fallbackAddress = (roadName + " " + buildingIndex).trim();
+
+        if (fallbackAddress.isEmpty()) {
+            throw new RuntimeException("파싱된 주소 정보가 없습니다: lat=" + latitude + ", lon=" + longitude);
+        }
+
+        return fallbackAddress;
+    }
 }
diff --git a/src/main/java/com/okagaka/OkaGaka/domain/aidecision/service/AsyncDecisionService.java b/src/main/java/com/okagaka/OkaGaka/domain/aidecision/service/AsyncDecisionService.java
@@ -374,17 +374,17 @@ private void performFinalAnalysisAndSaveDecision(CarRequest carRequest, LocalDat
             User user = carRequest.getUser();
             Vehicle vehicle = user.getFamilyGroup().getVehicle();
 
-            // 1. 대중교통 정보 조회 (API 제한으로 임시 비활성화)
-            System.out.println(">> [임시] 대중교통 API 호출을 건너뜁니다.");
-            TransitInfo transitInfo = null; // API 호출 대신 null을 할당
+//            // 1. 대중교통 정보 조회 (API 제한으로 임시 비활성화)
+//            System.out.println(">> [임시] 대중교통 API 호출을 건너뜁니다.");
+//            TransitInfo transitInfo = null; // API 호출 대신 null을 할당
 
-//            // 1. 대중교통 정보 조회
-//            TransitInfo transitInfo = transitService.getTransitInfo(
-//                    String.valueOf(carRequest.getRequesterLongitude()),
-//                    String.valueOf(carRequest.getRequesterLatitude()),
-//                    String.valueOf(carRequest.getDestinationLongitude()),
-//                    String.valueOf(carRequest.getDestinationLatitude())
-//            );
+            // 1. 대중교통 정보 조회
+            TransitInfo transitInfo = transitService.getTransitInfo(
+                    String.valueOf(carRequest.getRequesterLongitude()),
+                    String.valueOf(carRequest.getRequesterLatitude()),
+                    String.valueOf(carRequest.getDestinationLongitude()),
+                    String.valueOf(carRequest.getDestinationLatitude())
+            );
 
             if (transitInfo == null) {
                 System.out.println(">> 조회된 대중교통 경로가 없습니다.");
diff --git a/src/main/java/com/okagaka/OkaGaka/domain/carrequest/controller/CarRequestController.java b/src/main/java/com/okagaka/OkaGaka/domain/carrequest/controller/CarRequestController.java
@@ -4,6 +4,7 @@
 import com.okagaka.OkaGaka.common.security.CustomUserDetails;
 import com.okagaka.OkaGaka.domain.aidecision.dto.AiDecisionResponse;
 import com.okagaka.OkaGaka.domain.carrequest.dto.CarRequestDto;
+import com.okagaka.OkaGaka.domain.carrequest.dto.CarRequestListResponse;
 import com.okagaka.OkaGaka.domain.carrequest.dto.CarRequestResponse;
 import com.okagaka.OkaGaka.domain.carrequest.dto.ConfirmationRequest;
 import com.okagaka.OkaGaka.domain.carrequest.service.CarRequestService;
@@ -16,6 +17,8 @@
 import org.springframework.security.core.annotation.AuthenticationPrincipal;
 import org.springframework.web.bind.annotation.*;
 
+import java.util.List;
+
 @RestController
 @RequiredArgsConstructor
 @RequestMapping("/api/car-request")
@@ -58,4 +61,14 @@ public ResponseEntity<ApiResponse<Void>> confirmChoice(
         return ResponseEntity.ok(ApiResponse.success(null, "결정이 성공적으로 반영되었습니다."));
     }
 
+    @Operation(summary = "내 차량 요청 목록 조회", description = "로그인한 사용자의 모든 차량 요청 목록을 최신순으로 조회합니다.")
+    @GetMapping("/my-requests")
+    public ResponseEntity<ApiResponse<List<CarRequestListResponse>>> getMyCarRequests(
+            @AuthenticationPrincipal CustomUserDetails userDetails
+    ) {
+        Long userId = userDetails.getUserId();
+        List<CarRequestListResponse> response = carRequestService.getUserCarRequests(userId);
+        return ResponseEntity.ok(ApiResponse.success(response));
+    }
+
 }
diff --git a/src/main/java/com/okagaka/OkaGaka/domain/carrequest/dto/CarRequestDto.java b/src/main/java/com/okagaka/OkaGaka/domain/carrequest/dto/CarRequestDto.java
@@ -7,12 +7,6 @@
 @Setter
 public class CarRequestDto {
 
-    // 요청자 현재 위치
-//    private String requesterCityDo;
-//    private String requesterGuGun;
-//    private String requesterDong;
-//    private String requesterBunji;
-
     // 도착지
     private String destinationCityDo;
     private String destinationGuGun;
diff --git a/src/main/java/com/okagaka/OkaGaka/domain/carrequest/dto/CarRequestListResponse.java b/src/main/java/com/okagaka/OkaGaka/domain/carrequest/dto/CarRequestListResponse.java
@@ -0,0 +1,45 @@
+package com.okagaka.OkaGaka.domain.carrequest.dto;
+
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.okagaka.OkaGaka.domain.carrequest.entity.CarRequest;
+import lombok.Builder;
+import lombok.Getter;
+
+import java.time.LocalDateTime;
+
+@Getter
+@Builder
+@JsonInclude(JsonInclude.Include.NON_NULL)
+public class CarRequestListResponse {
+
+    private Long carRequestId;
+//    private double destinationLongitude;
+//    private double destinationLatitude;
+    private String destinationAddress;
+    private LocalDateTime requestTime; // 요청 시간
+    private CarRequest.CarRequestStatus status;
+
+    // CONFIRMED 상태일 때만 포함될 필드
+    private LocalDateTime estimatedPickupTime;
+    private LocalDateTime estimatedDestinationTime;
+
+    /**
+     * CarRequest 엔티티를 DTO로 변환하는 정적 팩토리 메서드
+     */
+//    public static CarRequestListResponse from(CarRequest carRequest) {
+//        CarRequestListResponseBuilder builder = CarRequestListResponse.builder()
+//                .carRequestId(carRequest.getId())
+//                .destinationLongitude(carRequest.getDestinationLongitude())
+//                .destinationLatitude(carRequest.getDestinationLatitude())
+//                .requestTime(carRequest.getCreatedAt()) // BaseTimeEntity의 생성 시간 활용
+//                .status(carRequest.getStatus());
+//
+//        // 상태가 CONFIRMED일 경우에만 예상 시간 정보를 추가
+//        if (carRequest.getStatus() == CarRequest.CarRequestStatus.CONFIRMED) {
+//            builder.estimatedPickupTime(carRequest.getEstimatedPickupTime())
+//                    .estimatedDestinationTime(carRequest.getEstimatedDestinationTime());
+//        }
+//
+//        return builder.build();
+//    }
+}
diff --git a/src/main/java/com/okagaka/OkaGaka/domain/carrequest/entity/CarRequest.java b/src/main/java/com/okagaka/OkaGaka/domain/carrequest/entity/CarRequest.java
@@ -67,7 +67,7 @@ public enum CarRequestStatus {
         ANALYSIS_COMPLETE,  // AI 분석 완료 (사용자 확인 대기)
         CONFIRMED,          // 사용자가 차량 이용을 최종 확정함
         REJECTED,           // 규칙 기반 또는 시스템 오류로 거절됨
-        CANCELLED   ,        // 사용자가 대중교통을 선택하거나 요청을 취소함
+        CANCELLED   ,       // 사용자가 대중교통을 선택하거나 요청을 취소함
         COMPLETED
     }
 
diff --git a/src/main/java/com/okagaka/OkaGaka/domain/carrequest/repository/CarRequestRepository.java b/src/main/java/com/okagaka/OkaGaka/domain/carrequest/repository/CarRequestRepository.java
@@ -37,4 +37,11 @@ public interface CarRequestRepository extends JpaRepository<CarRequest, Long> {
 
     // carpoolGroupId로 모든 관련 요청을 찾는 메서드
     List<CarRequest> findAllByCarpoolGroupId(Long carpoolGroupId);
+
+    /**
+     * 특정 사용자의 모든 차량 요청을 생성 시간(요청 시간)의 내림차순으로 조회합니다.
+     * @param userId 사용자 ID
+     * @return 정렬된 차량 요청 목록
+     */
+    List<CarRequest> findByUser_IdOrderByCreatedAtDesc(Long userId);
 }
diff --git a/src/main/java/com/okagaka/OkaGaka/domain/carrequest/service/CarRequestService.java b/src/main/java/com/okagaka/OkaGaka/domain/carrequest/service/CarRequestService.java
@@ -407,6 +407,41 @@ public void confirmUserChoice(Long carRequestId, Long userId, ConfirmationReques
             throw e;
         }
     }
+
+    /**
+     * 로그인한 사용자의 모든 차량 요청 목록을 조회합니다.
+     * @param userId 로그인한 사용자의 ID
+     * @return 차량 요청 DTO 리스트 (최신순으로 정렬됨)
+     */
+    @Transactional(readOnly = true)
+    public List<CarRequestListResponse> getUserCarRequests(Long userId) {
+        List<CarRequest> requests = carRequestRepository.findByUser_IdOrderByCreatedAtDesc(userId);
+
+        return requests.stream()
+                .map(carRequest -> {
+                    // ✨ 각 요청에 대해 역 지오코딩 호출
+                    String address = tmapGeocodingClient.getAddress(
+                            carRequest.getDestinationLongitude(),
+                            carRequest.getDestinationLatitude()
+                    );
+
+                    // DTO 빌더 생성
+                    CarRequestListResponse.CarRequestListResponseBuilder builder = CarRequestListResponse.builder()
+                            .carRequestId(carRequest.getId())
+                            .destinationAddress(address) // 변환된 주소 사용
+                            .requestTime(carRequest.getCreatedAt())
+                            .status(carRequest.getStatus());
+
+                    // CONFIRMED 상태일 때 시간 정보 추가
+                    if (carRequest.getStatus() == CarRequest.CarRequestStatus.CONFIRMED) {
+                        builder.estimatedPickupTime(carRequest.getEstimatedPickupTime())
+                                .estimatedDestinationTime(carRequest.getEstimatedDestinationTime());
+                    }
+
+                    return builder.build();
+                })
+                .collect(Collectors.toList());
+    }
 }
 
 //    /**
diff --git a/src/main/java/com/okagaka/OkaGaka/domain/location/service/LocationCacheService.java b/src/main/java/com/okagaka/OkaGaka/domain/location/service/LocationCacheService.java
@@ -55,7 +55,7 @@ public void saveVehicleLocation(Long groupId, Long vehicleId, VehicleLocationDTO
             String key = String.format(VEHICLE_LOCATION_KEY, groupId, vehicleId);
             String locationJson = objectMapper.writeValueAsString(dto);
             // 차량 정보는 더 자주 업데이트될 수 있으므로 TTL을 적절히 조절 (예: 10분)
-            redisTemplate.opsForValue().set(key, locationJson, 10, TimeUnit.MINUTES); // TTL 10분으로 설정
+            redisTemplate.opsForValue().set(key, locationJson, 40, TimeUnit.MINUTES); // TTL 40분으로 설정
         } catch (Exception e) {
             // 로깅
             System.err.println("Failed to save vehicle location to Redis: " + e.getMessage());
diff --git a/src/main/java/com/okagaka/OkaGaka/domain/reservation/dto/ReservationListResponse.java b/src/main/java/com/okagaka/OkaGaka/domain/reservation/dto/ReservationListResponse.java
@@ -13,19 +13,23 @@ public class ReservationListResponse {
 
     private Long reservationId;
     private String title;
+
+    private String departureAddress;
+    private String destinationAddress;
+
     private ReservationStatus status;
     private LocalDateTime departureDateTime;
     private LocalDateTime arrivalDateTime;
 
-    // Reservation 엔티티를 받아 ReservationListResponse 객체를 생성하는 정적 메서드
-    public static ReservationListResponse from(Reservation reservation) {
-        return ReservationListResponse.builder()
-                .reservationId(reservation.getId())
-                .title(reservation.getTitle())
-                .status(reservation.getStatus())
-                .departureDateTime(reservation.getDepartureDateTime())
-                .arrivalDateTime(reservation.getArrivalDateTime())
-                .build();
-    }
+//    // Reservation 엔티티를 받아 ReservationListResponse 객체를 생성하는 정적 메서드
+//    public static ReservationListResponse from(Reservation reservation) {
+//        return ReservationListResponse.builder()
+//                .reservationId(reservation.getId())
+//                .title(reservation.getTitle())
+//                .status(reservation.getStatus())
+//                .departureDateTime(reservation.getDepartureDateTime())
+//                .arrivalDateTime(reservation.getArrivalDateTime())
+//                .build();
+//    }
 
 }
diff --git a/src/main/java/com/okagaka/OkaGaka/domain/reservation/repository/ReservationRepository.java b/src/main/java/com/okagaka/OkaGaka/domain/reservation/repository/ReservationRepository.java
@@ -75,4 +75,6 @@ List<Reservation> findOverlappingReservationsForVehicle(
     // 특정 상태 리스트에 속하면서, 특정 시간보다 도착 시간이 이른 모든 예약을 조회하는 메소드
     List<Reservation> findAllByStatusInAndArrivalDateTimeBefore(List<ReservationStatus> statuses, LocalDateTime dateTime);
 
+    List<Reservation> findByUserIdOrderByDepartureDateTimeDesc(Long userId);
+
 }
diff --git a/src/main/java/com/okagaka/OkaGaka/domain/reservation/service/ReservationService.java b/src/main/java/com/okagaka/OkaGaka/domain/reservation/service/ReservationService.java
@@ -453,13 +453,38 @@ public List<CarpoolProposalResponse> getReceivedCarpoolProposals(Long userId) {
     /**
      * 로그인한 사용자의 모든 예약 목록을 조회합니다.
      * @param userId 로그인한 사용자의 ID
-     * @return 예약 목록 DTO 리스트
+     * @return 주소 정보가 포함된 예약 목록 DTO 리스트
      */
     public List<ReservationListResponse> getUserReservations(Long userId) {
-        // userId를 기준으로 Reservation 목록을 조회
-        return reservationRepository.findByUserId(userId)
-                .stream()
-                .map(ReservationListResponse::from) // Reservation 엔티티를 ReservationResponse DTO로 변환
+        // 1. DB에서 최신순으로 정렬된 예약 목록을 가져옵니다.
+        List<Reservation> reservations = reservationRepository.findByUserIdOrderByDepartureDateTimeDesc(userId);
+
+        // 2. Stream을 사용하여 각 Reservation 엔티티를 ReservationListResponse DTO로 변환합니다.
+        return reservations.stream()
+                .map(reservation -> {
+                    // 3. 출발지 좌표를 주소로 변환합니다.
+                    String departureAddr = tmapGeocodingClient.getAddress(
+                            reservation.getDepartureLongitude(),
+                            reservation.getDepartureLatitude()
+                    );
+
+                    // 4. 목적지 좌표를 주소로 변환합니다.
+                    String destinationAddr = tmapGeocodingClient.getAddress(
+                            reservation.getDestinationLongitude(),
+                            reservation.getDestinationLatitude()
+                    );
+
+                    // 5. 변환된 주소를 포함하여 DTO를 생성하고 반환합니다.
+                    return ReservationListResponse.builder()
+                            .reservationId(reservation.getId())
+                            .title(reservation.getTitle())
+                            .departureAddress(departureAddr) // 변환된 출발지 주소 설정
+                            .destinationAddress(destinationAddr) // 변환된 목적지 주소 설정
+                            .status(reservation.getStatus())
+                            .departureDateTime(reservation.getDepartureDateTime())
+                            .arrivalDateTime(reservation.getArrivalDateTime())
+                            .build();
+                })
                 .collect(Collectors.toList());
     }
 }
diff --git a/src/main/java/com/okagaka/OkaGaka/domain/vehicle/service/VehicleService.java b/src/main/java/com/okagaka/OkaGaka/domain/vehicle/service/VehicleService.java
@@ -40,6 +40,7 @@ public VehicleRegistrationResponse registerVehicleToGroup(Long userId, VehicleRe
 
         // 2. 해당 그룹에 이미 차량이 등록되었는지 확인 (1그룹 1차량 정책)
         if (familyGroup.getVehicle() != null) {
+            System.out.println(familyGroup.getVehicle());
             throw new CustomException(ErrorCode.VEHICLE_ALREADY_EXISTS_IN_GROUP);
         }
 

Original file line number	Diff line number	Diff line change
`@@ -67,7 +67,7 @@ public enum CarRequestStatus {`
`67`	`67`	`ANALYSIS_COMPLETE, // AI 분석 완료 (사용자 확인 대기)`
`68`	`68`	`CONFIRMED, // 사용자가 차량 이용을 최종 확정함`
`69`	`69`	`REJECTED, // 규칙 기반 또는 시스템 오류로 거절됨`
`70`		`- CANCELLED , // 사용자가 대중교통을 선택하거나 요청을 취소함`
	`70`	`+ CANCELLED , // 사용자가 대중교통을 선택하거나 요청을 취소함`
`71`	`71`	`COMPLETED`
`72`	`72`	`}`
`73`	`73`