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

core/src/main/java/dev/hooon/show/domain/entity/seat/SeatStatus.java

@@ -9,7 +9,9 @@ public enum SeatStatus {
 
 	AVAILABLE("예매 가능"),
 	BOOKED("예매 완료"),
-	CANCELED("예매 취소");
+	CANCELED("예매 취소"),
+	// 취소된 좌석이 예매대기로 인해 6시간동안 예매대기를 한 사용자에 한해 예약이 가능한 상태
+	WAITING("예매 대기");
 
 	private final String description;
 }

core/src/main/java/dev/hooon/user/domain/entity/User.java

@@ -19,18 +19,25 @@
 @NoArgsConstructor
 public class User extends TimeBaseEntity {
 
-    @Id
-    @GeneratedValue(strategy = IDENTITY)
-    @Column(name = "user_id")
-    private Long id;
+	@Id
+	@GeneratedValue(strategy = IDENTITY)
+	@Column(name = "user_id")
+	private Long id;
 
-    @Column(name = "user_email", nullable = false, unique = true)
-    private String email;
+	@Column(name = "user_email", nullable = false, unique = true)
+	private String email;
 
-    @Column(name = "user_name", nullable = false)
-    private String name;
+	@Column(name = "user_name", nullable = false)
+	private String name;
 
-    @Enumerated(STRING)
-    @Column(name = "user_role", nullable = false)
-    private UserRole userRole;
+	@Enumerated(STRING)
+	@Column(name = "user_role", nullable = false)
+	private UserRole userRole;
+
+	// 테스트용 AllArgsConstructor
+	public User(String email, String name, UserRole userRole) {
+		this.email = email;
+		this.name = name;
+		this.userRole = userRole;
+	}
 }

core/src/main/java/dev/hooon/user/domain/repository/UserRepository.java

@@ -6,5 +6,7 @@
 
 public interface UserRepository {
 
+	User save(User user);
+
 	Optional<User> findById(Long id);
 }

core/src/main/java/dev/hooon/user/infrastructure/adaptor/UserRepositoryAdaptor.java

@@ -15,6 +15,11 @@ public class UserRepositoryAdaptor implements UserRepository {
 
 	private final UserJpaRepository userJpaRepository;
 
+	@Override
+	public User save(User user) {
+		return userJpaRepository.save(user);
+	}
+
 	@Override
 	public Optional<User> findById(Long id) {
 		return userJpaRepository.findById(id);

core/src/main/java/dev/hooon/waitingbooking/domain/entity/WaitingBooking.java

@@ -7,6 +7,7 @@
 import static jakarta.persistence.FetchType.*;
 import static jakarta.persistence.GenerationType.*;
 
+import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.List;
 
@@ -52,6 +53,8 @@ public class WaitingBooking extends TimeBaseEntity {
 
 	private int seatCount;
 
+	private LocalDateTime expireAt;
+
 	@OneToMany(mappedBy = "waitingBooking", cascade = {REMOVE, PERSIST})
 	List<WaitingBookingSeat> waitingBookingSeats = new ArrayList<>();
 
@@ -108,4 +111,10 @@ public static WaitingBooking of(
 	) {
 		return new WaitingBooking(user, seatCount, seatIds);
 	}
+
+	public List<Long> getSelectedSeatIds() {
+		return waitingBookingSeats.stream()
+			.map(WaitingBookingSeat::getSeatId)
+			.toList();
+	}
 }

core/src/test/java/dev/hooon/waitingbooking/domain/entity/WaitingBookingTest.java

@@ -95,4 +95,24 @@ void ofTest_4() {
 			.isInstanceOf(ValidationException.class)
 			.hasMessageContaining(WaitingBookingErrorCode.INVALID_SELECTED_SEAT_COUNT.getMessage());
 	}
+
+	@Test
+	@DisplayName("[선택한 좌석의 ID List 를 응답한다]")
+	void getSelectedSeatIdsTest() {
+		//given
+		List<Long> selectedSeatIds = List.of(1L, 2L, 3L, 4L, 5L);
+		WaitingBooking waitingBooking = WaitingBooking.of(
+			new User(),
+			3,
+			selectedSeatIds
+		);
+
+		//when
+		List<Long> result = waitingBooking.getSelectedSeatIds();
+
+		//then
+		assertThat(result)
+			.hasSameSizeAs(selectedSeatIds)
+			.containsAll(selectedSeatIds);
+	}
 }

scheduler/build.gradle

@@ -0,0 +1,4 @@
+dependencies {
+    implementation project(':core')
+    testImplementation(testFixtures(project(':core')))
+}

scheduler/src/main/java/dev/hooon/SchedulerApplication.java

@@ -0,0 +1,12 @@
+package dev.hooon;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class SchedulerApplication {
+
+	public static void main(String[] args) {
+		SpringApplication.run(SchedulerApplication.class, args);
+	}
+}

scheduler/src/main/resources/application.yml

@@ -0,0 +1,13 @@
+spring:
+  jpa:
+    show-sql: true
+    hibernate:
+      ddl-auto: create
+    properties:
+      hibernate:
+        dialect: org.hibernate.dialect.PostgreSQLDialect
+        format_sql: true
+
+logging:
+  level:
+    org.hibernate.sql: info

settings.gradle

@@ -2,3 +2,5 @@ rootProject.name = 'interpark'
 
 include 'api'
 include 'core'
+include 'scheduler'
+