feat : 예매대기 처리 스케줄러 구현

core/src/main/java/dev/hooon/waitingbooking/domain/repository/WaitingBookingRepository.java

@@ -1,12 +1,20 @@
 package dev.hooon.waitingbooking.domain.repository;
 
 import java.util.List;
+import java.util.Optional;
 
 import dev.hooon.waitingbooking.domain.entity.WaitingBooking;
 
 public interface WaitingBookingRepository {
 
 	void save(WaitingBooking waitingBooking);
 
+	Optional<WaitingBooking> findById(Long id);
+
 	List<WaitingBooking> findAll();
+
+	// WaitingStatus 가 WAITING 인 데이터를 최신순으로 조회하는 쿼리
+	List<WaitingBooking> findByStatusIsWaiting();
+
+	void updateToActiveById(Long id);
 }

core/src/main/java/dev/hooon/waitingbooking/infrastructure/adaptor/WaitingBookingRepositoryAdaptor.java

@@ -1,10 +1,13 @@
 package dev.hooon.waitingbooking.infrastructure.adaptor;
 
+import java.time.LocalDateTime;
 import java.util.List;
+import java.util.Optional;
 
 import org.springframework.stereotype.Repository;
 
 import dev.hooon.waitingbooking.domain.entity.WaitingBooking;
+import dev.hooon.waitingbooking.domain.entity.WaitingStatus;
 import dev.hooon.waitingbooking.domain.repository.WaitingBookingRepository;
 import dev.hooon.waitingbooking.infrastructure.repository.WaitingBookingJpaRepository;
 import lombok.RequiredArgsConstructor;
@@ -20,9 +23,27 @@ public void save(WaitingBooking waitingBooking) {
 		waitingBookingJpaRepository.save(waitingBooking);
 	}
 
+	@Override
+	public Optional<WaitingBooking> findById(Long id) {
+		return waitingBookingJpaRepository.findById(id);
+	}
+
 	@Override
 	public List<WaitingBooking> findAll() {
 		return waitingBookingJpaRepository.findAll();
 	}
 
+	@Override
+	public List<WaitingBooking> findByStatusIsWaiting() {
+		return waitingBookingJpaRepository.findByStatusOrderByIdDesc(WaitingStatus.WAITING);
+	}
+
+	@Override
+	public void updateToActiveById(Long id) {
+		waitingBookingJpaRepository.updateStatusAndExpireAt(
+			id,
+			WaitingStatus.ACTIVATION,
+			LocalDateTime.now().plusHours(6)
+		);
+	}
 }

core/src/main/java/dev/hooon/waitingbooking/infrastructure/repository/WaitingBookingJpaRepository.java

@@ -1,8 +1,26 @@
 package dev.hooon.waitingbooking.infrastructure.repository;
 
+import java.time.LocalDateTime;
+import java.util.List;
+
+import org.springframework.data.jpa.repository.EntityGraph;
 import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Modifying;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
 
 import dev.hooon.waitingbooking.domain.entity.WaitingBooking;
+import dev.hooon.waitingbooking.domain.entity.WaitingStatus;
 
 public interface WaitingBookingJpaRepository extends JpaRepository<WaitingBooking, Long> {
+
+	@EntityGraph(attributePaths = {"user", "waitingBookingSeats"})
+	List<WaitingBooking> findByStatusOrderByIdDesc(WaitingStatus status);
+
+	@Modifying
+	@Query("update WaitingBooking w SET w.status = :status, w.expireAt = :expireAt where w.id = :id")
+	void updateStatusAndExpireAt(
+		@Param("id") Long id,
+		@Param("status") WaitingStatus status,
+		@Param("expireAt") LocalDateTime expireAt);
 }

core/src/test/java/dev/hooon/waitingbooking/domain/repository/WaitingBookingRepositoryTest.java

@@ -0,0 +1,79 @@
+package dev.hooon.waitingbooking.domain.repository;
+
+import static org.assertj.core.api.Assertions.*;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+import org.junit.jupiter.api.DisplayName;
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.test.util.ReflectionTestUtils;
+
+import dev.hooon.common.fixture.WaitingBookingFixture;
+import dev.hooon.common.support.DataJpaTestSupport;
+import dev.hooon.user.domain.entity.User;
+import dev.hooon.user.domain.entity.UserRole;
+import dev.hooon.user.domain.repository.UserRepository;
+import dev.hooon.waitingbooking.domain.entity.WaitingBooking;
+import dev.hooon.waitingbooking.domain.entity.WaitingStatus;
+import jakarta.persistence.EntityManager;
+import jakarta.persistence.PersistenceContext;
+
+@DisplayName("[WaitingBookingRepository 테스트]")
+class WaitingBookingRepositoryTest extends DataJpaTestSupport {
+
+	@Autowired
+	private WaitingBookingRepository waitingBookingRepository;
+	@Autowired
+	private UserRepository userRepository;
+	@PersistenceContext
+	private EntityManager entityManager;
+
+	private final User user = new User("hello123@naver.com", "name", UserRole.BUYER);
+
+	@Test
+	@DisplayName("[WAITING 상태인 데이터를 최신순으로 조회한다]")
+	void findByStatusIsWaitingTest() {
+		//given
+		userRepository.save(user);
+
+		List<WaitingBooking> waitingBookings = List.of(
+			WaitingBookingFixture.getWaitingBooking(user),
+			WaitingBookingFixture.getWaitingBooking(user),
+			WaitingBookingFixture.getWaitingBooking(user)
+		);
+		// 0번 데이터만 상태를 ACTIVATION 으로 변경
+		ReflectionTestUtils.setField(waitingBookings.get(0), "status", WaitingStatus.ACTIVATION);
+
+		waitingBookings.forEach(waitingBooking -> waitingBookingRepository.save(waitingBooking));
+
+		//when
+		List<WaitingBooking> result = waitingBookingRepository.findByStatusIsWaiting();
+
+		//then
+		assertThat(result)
+			.hasSize(2)
+			.containsExactly(waitingBookings.get(2), waitingBookings.get(1));
+	}
+
+	@Test
+	@DisplayName("[id 에 해당하는 데이터의 status 를 ACTIVATION 으로 변경하고 expireAt 을 6시간뒤로 설정한다]")
+	void updateToActiveByIdTest() {
+		//given
+		userRepository.save(user);
+
+		WaitingBooking waitingBooking = WaitingBookingFixture.getWaitingBooking(user);
+		waitingBookingRepository.save(waitingBooking);
+
+		//when
+		waitingBookingRepository.updateToActiveById(waitingBooking.getId());
+		entityManager.flush();
+		entityManager.clear();
+
+		//then
+		WaitingBooking actual = waitingBookingRepository.findById(waitingBooking.getId()).orElseThrow();
+		assertThat(actual.getStatus()).isEqualTo(WaitingStatus.ACTIVATION);
+		assertThat(actual.getExpireAt()).isEqualToIgnoringSeconds(LocalDateTime.now().plusHours(6));
+	}
+}