[feat] #50 reservationStatus 업데이트 및 예약 목록 조회 api

Author: jinsol24

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(">> 조회된 대중교통 경로가 없습니다.");

src/main/java/com/okagaka/OkaGaka/domain/reservation/controller/ReservationController.java

@@ -3,6 +3,7 @@
 import com.okagaka.OkaGaka.common.response.ApiResponse;
 import com.okagaka.OkaGaka.common.security.CustomUserDetails;
 import com.okagaka.OkaGaka.domain.reservation.dto.CarpoolProposalResponse;
+import com.okagaka.OkaGaka.domain.reservation.dto.ReservationListResponse;
 import com.okagaka.OkaGaka.domain.reservation.service.ReservationService;
 import com.okagaka.OkaGaka.domain.reservation.dto.ReservationResponse;
 import com.okagaka.OkaGaka.domain.reservation.dto.ReservationRequest;
@@ -82,5 +83,18 @@ public ResponseEntity<ApiResponse<List<CarpoolProposalResponse>>> getReceivedCar
         return ResponseEntity.ok(ApiResponse.success(proposals));
     }
 
+    /**
+     * 로그인한 사용자의 예약 목록 조회
+     */
+    @Operation(summary = "내 예약 목록 조회", description = "로그인한 사용자의 모든 예약 정보를 최신순으로 반환합니다.")
+    @GetMapping
+    public ResponseEntity<ApiResponse<List<ReservationListResponse>>> getUserReservations(
+            @AuthenticationPrincipal CustomUserDetails userDetails
+    ) {
+        Long userId = userDetails.getUserId();
+        List<ReservationListResponse> reservations = reservationService.getUserReservations(userId);
+        return ResponseEntity.ok(ApiResponse.success(reservations));
+    }
+
 
 }

src/main/java/com/okagaka/OkaGaka/domain/reservation/dto/ReservationListResponse.java

@@ -0,0 +1,31 @@
+package com.okagaka.OkaGaka.domain.reservation.dto;
+
+import com.okagaka.OkaGaka.domain.reservation.entity.Reservation;
+import com.okagaka.OkaGaka.domain.reservation.enums.ReservationStatus;
+import lombok.Builder;
+import lombok.Getter;
+
+import java.time.LocalDateTime;
+
+@Getter
+@Builder
+public class ReservationListResponse {
+
+    private Long reservationId;
+    private String title;
+    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();
+    }
+
+}

src/main/java/com/okagaka/OkaGaka/domain/reservation/enums/ReservationStatus.java

@@ -14,6 +14,6 @@ public enum ReservationStatus {
     CARPOOL,
 //    REJECTED,
     CANCELLED,
-//    COMPLETED,
+    COMPLETED,
 //    COMPLICT
 }

src/main/java/com/okagaka/OkaGaka/domain/reservation/repository/ReservationRepository.java

@@ -18,6 +18,7 @@ public interface ReservationRepository extends JpaRepository<Reservation, Long>{
     // 특정 사용자 ID로 예약 목록 조회
     List<Reservation> findByUserId(Long userId);
 
+
     // 특정 사용자와 예약 상태로 예약 목록 조회
     List<Reservation> findByUserIdAndStatus(Long userId, ReservationStatus status);
 
@@ -71,4 +72,7 @@ List<Reservation> findOverlappingReservationsForVehicle(
             @Param("endDateTime") LocalDateTime endDateTime
     );
 
+    // 특정 상태 리스트에 속하면서, 특정 시간보다 도착 시간이 이른 모든 예약을 조회하는 메소드
+    List<Reservation> findAllByStatusInAndArrivalDateTimeBefore(List<ReservationStatus> statuses, LocalDateTime dateTime);
+
 }

src/main/java/com/okagaka/OkaGaka/domain/reservation/service/ReservationScheduler.java

@@ -0,0 +1,55 @@
+package com.okagaka.OkaGaka.domain.reservation.service;
+
+
+import com.okagaka.OkaGaka.domain.reservation.entity.Reservation;
+import com.okagaka.OkaGaka.domain.reservation.enums.ReservationStatus;
+import com.okagaka.OkaGaka.domain.reservation.repository.ReservationRepository;
+import lombok.RequiredArgsConstructor;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+
+@Component
+@RequiredArgsConstructor
+public class ReservationScheduler {
+
+    private final ReservationRepository reservationRepository;
+
+    // 예상 도착 시간보다 10분 늦는 경우까지 여유를 둡니다.
+    private static final int GRACE_PERIOD_MINUTES = 10;
+
+    /**
+     * 5분마다 한 번씩 실행되며, 완료된 예약 상태를 업데이트합니다.
+     */
+    @Scheduled(fixedRate = 300000) // 5분 = 300,000 밀리초
+    @Transactional
+    public void updateCompletedReservations() {
+        System.out.println(">> [Scheduler] 완료된 예약 상태 업데이트 시작...");
+
+        // 현재 시간에서 유예 기간을 뺀 시점을 기준으로 완료된 예약을 조회합니다.
+        LocalDateTime checkTime = LocalDateTime.now().minusMinutes(GRACE_PERIOD_MINUTES);
+
+        // 1. 'CONFIRMED' 또는 'CARPOOL' 상태이며, 도착 시간이 지난 모든 예약을 조회합니다.
+        List<Reservation> completedReservations = reservationRepository.findAllByStatusInAndArrivalDateTimeBefore(
+                List.of(ReservationStatus.CONFIRMED, ReservationStatus.CARPOOL),
+                checkTime
+        );
+
+        if (completedReservations.isEmpty()) {
+            System.out.println(">> [Scheduler] 완료된 예약이 없습니다.");
+            return;
+        }
+
+        // 2. 조회된 예약들의 상태를 'COMPLETED'로 변경합니다.
+        System.out.printf(">> [Scheduler] %d개의 완료된 예약을 업데이트합니다.%n", completedReservations.size());
+        for (Reservation reservation : completedReservations) {
+            reservation.setStatus(ReservationStatus.COMPLETED);
+        }
+
+        // @Transactional에 의해 메소드가 종료되면 변경 사항이 DB에 자동으로 저장됩니다.
+    }
+}

src/main/java/com/okagaka/OkaGaka/domain/reservation/service/ReservationService.java

@@ -1,6 +1,7 @@
 package com.okagaka.OkaGaka.domain.reservation.service;
 
 import com.okagaka.OkaGaka.domain.reservation.dto.CarpoolProposalResponse;
+import com.okagaka.OkaGaka.domain.reservation.dto.ReservationListResponse;
 import com.okagaka.OkaGaka.domain.reservation.enums.ProposalStatus;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
@@ -448,4 +449,17 @@ public List<CarpoolProposalResponse> getReceivedCarpoolProposals(Long userId) {
                 })
                 .collect(Collectors.toList());
     }
+
+    /**
+     * 로그인한 사용자의 모든 예약 목록을 조회합니다.
+     * @param userId 로그인한 사용자의 ID
+     * @return 예약 목록 DTO 리스트
+     */
+    public List<ReservationListResponse> getUserReservations(Long userId) {
+        // userId를 기준으로 Reservation 목록을 조회
+        return reservationRepository.findByUserId(userId)
+                .stream()
+                .map(ReservationListResponse::from) // Reservation 엔티티를 ReservationResponse DTO로 변환
+                .collect(Collectors.toList());
+    }
 }