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

EunChanNam · 2023-12-27T17:05:19Z

📄 무엇을 개발했나요?

스케줄러 모듈 정의
예매대기 처리 스케줄러 구현

🍸 무엇을 집중적으로 리뷰해야할까요?

파일체인지가 많아요..! 그래서 한 파일에 대한 수정은 한커밋에서만 이루어지게 해놨습니다. 커밋 보시면서 리뷰하시면 편하실거에요!

…sByIdIn 쿼리 구현

…dateToActiveById 쿼리 구현

…teSeatToAvailable 메소드 구현

…ctivateWaitingBooking 구현

github-actions · 2023-12-27T17:07:08Z

🦞 Test Coverage Report

Overall Project	NaN% `NaN%`	🟢

There is no coverage information present for the Files changed

ssssujini99 · 2023-12-28T05:07:33Z

settings.gradle

스케줄러 모듈 설정 잘 추가하신 것 같아요! 👍🏻

ssssujini99 · 2023-12-28T05:09:05Z

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

@@ -52,6 +53,8 @@ public class WaitingBooking extends TimeBaseEntity {

 	private int seatCount;

+	private LocalDateTime expireAt;


expiredAt 은 어떤가요?! (근데 사실 너무 사소함 ㅎㅎ)

의미적으로 그게 더 맞는거같네요! 수정하겠습니다 ㅎㅎ

b84ab45
수정 했습니다~

ssssujini99 · 2023-12-28T05:10:28Z

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

@@ -108,4 +111,10 @@ public static WaitingBooking of(
 	) {
 		return new WaitingBooking(user, seatCount, seatIds);
 	}
+
+	public List<Long> getSelectedSeatIds() {


예약 대기 좌석에 해당하는 좌석 id값을 list로 반환하는 함수가 맞을까요?

네 맞습니다~ 👍

ssssujini99 · 2023-12-28T05:15:19Z

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

-	CANCELED("예매 취소");
+	CANCELED("예매 취소"),
+	// 취소된 좌석이 예매대기로 인해 6시간동안 예매대기를 한 사용자에 한해 예약이 가능한 상태
+	WAITING("예매 대기");


👍🏻👍🏻

ssssujini99 · 2023-12-28T05:37:08Z

core/src/test/java/dev/hooon/show/domain/repository/SeatRepositoryTest.java

+			SeatFixture.getSeat()
+		);
+		// 0번 Seat 만 Canceled 상태로 변경(취소 기능이 아직 구현되지 않아서 리플렉션 사용)
+		ReflectionTestUtils.setField(seats.get(0), "seatStatus", SeatStatus.CANCELED);


👍🏻👍🏻
저도 배워갑니다

리플랙션이 정말 사기적인 기술이긴한데.. 안좋은 측면도 있어서 남발하지만 않으면 좋은거같아요!

ssssujini99 · 2023-12-28T05:47:07Z

core/src/test/java/dev/hooon/show/domain/repository/SeatRepositoryTest.java

테스트 꼼꼼히 잘 작성하셨어요!! 굿굿

ssssujini99 · 2023-12-28T05:55:13Z

...in/java/dev/hooon/waitingbooking/infrastructure/adaptor/WaitingBookingRepositoryAdaptor.java

 	@Override
 	public List<WaitingBooking> findAll() {
 		return waitingBookingJpaRepository.findAll();
 	}

+	@Override
+	public List<WaitingBooking> findByStatusIsWaiting() {
+		return waitingBookingJpaRepository.findByStatusOrderByIdDesc(WaitingStatus.WAITING);


네이밍 굿굿 한번에 바로 파악했네요

ssssujini99 · 2023-12-28T05:55:49Z

...in/java/dev/hooon/waitingbooking/infrastructure/adaptor/WaitingBookingRepositoryAdaptor.java

+	}
+
+	@Override
+	public void updateToActiveById(Long id) {


updateStatusToActiveById 는 어떨까요?! (이것도 사소해~)

이 쿼리가 어댑터쪽 코드보면 상태변경도있는데 expireAt 도 6시간 뒤로 설정해주는 쿼리라서 이렇게 네이밍했어요!

ssssujini99 · 2023-12-28T05:58:21Z

...ain/java/dev/hooon/waitingbooking/infrastructure/repository/WaitingBookingJpaRepository.java


 public interface WaitingBookingJpaRepository extends JpaRepository<WaitingBooking, Long> {
+
+	@EntityGraph(attributePaths = {"user", "waitingBookingSeats"})


이거 fetch join으로 한번에 다 가져오는게 맞나용??

넵 맞아요 user 는 이메일 보낼때 사용될거같아서 넣었고 waitingBookingSeats 는 예약대기 처리하는 로직에서 사용돼서 같이 패칭했습니다

ssssujini99 · 2023-12-28T06:01:24Z

core/src/testFixtures/java/dev/hooon/common/fixture/WaitingBookingFixture.java

아주 좋습니다👍🏻👍🏻

ssssujini99 · 2023-12-28T06:05:24Z

core/src/main/java/dev/hooon/show/application/SeatService.java

+	// 좌석을 대기중 상태로 변경
+	@Transactional
+	public void updateSeatToWaiting(Collection<Long> targetIds) {
+		seatRepository.updateStatusByIdIn(targetIds, SeatStatus.WAITING);


이거 뒤에 In 은 무슨의미인가요?!

In 절을 통해 가져온다는 의미에요!

ssssujini99 · 2023-12-28T06:06:04Z

core/src/main/java/dev/hooon/show/application/SeatService.java

최소 단위 기능으로 메서드로 분리한거 굿굿

ssssujini99 · 2023-12-28T06:08:23Z

core/src/main/java/dev/hooon/waitingbooking/application/WaitingBookingService.java

+	// ID 에 해당하는 WaitingBooking ACTIVATION 상태로 변경하고 expireAt 6시간뒤로 설정
+	@Transactional
+	public void activateWaitingBooking(Long waitingBookingId) {
+		waitingBookingRepository.updateToActiveById(waitingBookingId);


이것도 updateStatusToActivateById 는 어떠신가요? ㅎㅎ (이거도 단순히 제안 ㅎㅎㅎ)

의미상으로 "예약대기를 활성화한다" 라는 의미를 담은 서비스로직이라고 생각해서 제 생각에는 나은거같다고 생각이 듭니다! 수진님이 강력히 원하시는건 아닌거같으니...ㅎㅎ 이대로 가볼게요 ㅎㅎ

ssssujini99 · 2023-12-28T06:12:41Z

core/src/main/java/dev/hooon/waitingbooking/application/facade/WaitingBookingFacade.java

+		int seatCount
+	) {
+		List<Long> matchSeatIds = new ArrayList<>();
+		for (Long selectedSeatId : selectedSeatIds) {


이부분 stream으로 처리는 어려운건가용??

그 바로 아랫줄에 사이즈가 seatCount 랑 같아지면 break 치는 부분이 있는데 stream forEach 에선 break 를 지원안해서 이렇게 구현했습니다~!

ssssujini99 · 2023-12-28T06:13:05Z

core/src/main/java/dev/hooon/waitingbooking/application/facade/WaitingBookingFacade.java


 	public WaitingRegisterResponse registerWaitingBooking(Long userId, WaitingRegisterRequest request) {
 		User user = userService.getUserById(userId);
 		WaitingBooking waitingBooking = waitingBookingService.createWaitingBooking(user, request);

 		return new WaitingRegisterResponse(waitingBooking.getId());
 	}
+
+	public void processWaitingBooking() {


주석으로 설명을 잘 해놓아서 어떤 흐름인지 이해가 잘 되네요 👍🏻👍🏻

ssssujini99 · 2023-12-28T06:14:56Z

scheduler/src/main/java/dev/hooon/common/config/SchedulerConfig.java

+	public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
+		ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
+
+		scheduler.setPoolSize(10);


이거 사이즈를 10으로 설정하신 이유가 있나요?

아 이건 특별한 이유 없습니다.
스레드 풀 사이즈 지정하는건 배포하면 거기에 맞춰서 설정해야될거같아서 일단 임의로 10 했습니다

ssssujini99 · 2023-12-28T06:15:11Z

scheduler/src/main/java/dev/hooon/common/config/SchedulerConfig.java

ssssujini99 · 2023-12-28T06:16:35Z

scheduler/src/main/java/dev/hooon/waitingbooking/scheduler/WaitingBookingScheduler.java

+
+	private final WaitingBookingFacade waitingBookingFacade;
+
+	@Scheduled(cron = "0 */10 * * * *")


이게 10분마다 스케줄러가 작동하는게 맞나요?

10분마다 돌아가게 설정한 부분입니다!
비즈니스적으로 몇분마다 돌릴지는 같이 상의해봐야겠네요 🤔

ssssujini99 · 2023-12-28T06:17:24Z

scheduler/src/main/java/dev/hooon/waitingbooking/scheduler/WaitingBookingScheduler.java

+@RequiredArgsConstructor
+public class WaitingBookingScheduler {
+
+	private final WaitingBookingFacade waitingBookingFacade;


👍🏻👍🏻 퍼사드 패턴을 잘 활용하시는 것 같아요
설계 너무 잘하셨네요

ssssujini99 · 2023-12-28T06:18:52Z

scheduler/src/test/java/dev/hooon/waitingbooking/scheduler/WaitingBookingSchedulerTest.java

+	@Autowired
+	private SeatRepository seatRepository;
+
+	private void assertSeatStatus(Long id, SeatStatus expected) {


와 이거 검증로직 길어지면 이렇게 빼니 훨씬 가독성 좋네요
저도 이거 이용해봐야겠어요 ㅎㅎ

ssssujini99 · 2023-12-28T06:19:23Z

scheduler/src/test/java/dev/hooon/waitingbooking/scheduler/WaitingBookingSchedulerTest.java

예약대기 스케줄러 통합테스트 잘 짜신듯!!! 🤩 고생많으셨어요

ssssujini99 · 2023-12-28T06:20:32Z

전체적으로 설계도 꼼꼼하게 잘 하셨고, 잘 구현하신 것 같아요
수고하셨습니다 !!!!

github-actions · 2023-12-28T09:54:22Z

🦞 Test Coverage Report

Overall Project	NaN% `NaN%`	🟢

There is no coverage information present for the Files changed

* chore : scheduler 모듈 설정 구성 * feat : 6시간 요구사항에 사용되는 expireAt 필드 추가 & getSelectedSeatIds 메소드 추가 * feat : User 엔티티에 테스트용 생성자 추가 * feat : SeatStatus 에 예매대기 상태 추가 * feat : SeatRepository - findById, findByStatusIsCanceled, updateStatusByIdIn 쿼리 구현 * feat : WaitingBookingRepository - findById, findByStatusIsWaiting, updateToActiveById 쿼리 구현 * feat : SeatFixture 데이터추가 * feat : WaitingBookingFixture 구현 * feat : SeatService 구현 & getCanceledSeatIds, updateSeatToWaiting, updateSeatToAvailable 메소드 구현 * feat : WaitingBookingService - getWaitingBookingsByStatusIsWaiting, activateWaitingBooking 구현 * feat : WaitingBookingFacade - 예약대기를 처리하는 processWaitingBooking 메소드 구현 * feat : 스케줄러 설정 및 스케줄러에 사용되는 스레드 설정 추가 * feat : 예약대기 스케줄러 구현 * refactor : expireAt 컬럼 expiredAt 으로 네이밍 변경

EunChanNam added 13 commits December 28, 2023 00:38

chore : scheduler 모듈 설정 구성

a384874

feat : 6시간 요구사항에 사용되는 expireAt 필드 추가 & getSelectedSeatIds 메소드 추가

b350dfa

feat : User 엔티티에 테스트용 생성자 추가

239049b

feat : SeatStatus 에 예매대기 상태 추가

6cff378

feat : SeatRepository - findById, findByStatusIsCanceled, updateStatu…

0b86696

…sByIdIn 쿼리 구현

feat : WaitingBookingRepository - findById, findByStatusIsWaiting, up…

7901712

…dateToActiveById 쿼리 구현

feat : SeatFixture 데이터추가

8921b03

feat : WaitingBookingFixture 구현

566ab5d

feat : SeatService 구현 & getCanceledSeatIds, updateSeatToWaiting, upda…

5aa39f2

…teSeatToAvailable 메소드 구현

feat : WaitingBookingService - getWaitingBookingsByStatusIsWaiting, a…

0924434

…ctivateWaitingBooking 구현

feat : WaitingBookingFacade - 예약대기를 처리하는 processWaitingBooking 메소드 구현

47d2ab0

feat : 스케줄러 설정 및 스케줄러에 사용되는 스레드 설정 추가

6c771ce

feat : 예약대기 스케줄러 구현

5d75bc6

EunChanNam added the ✏️ Feat 기능 개발 label Dec 27, 2023

EunChanNam added this to the 2차 스프린트 milestone Dec 27, 2023

EunChanNam requested review from ssssujini99 and ParkJuhan94 December 27, 2023 17:05

EunChanNam self-assigned this Dec 27, 2023

ssssujini99 reviewed Dec 28, 2023

View reviewed changes

core/src/testFixtures/java/dev/hooon/common/fixture/WaitingBookingFixture.java Outdated

Copy link

Contributor

ssssujini99 Dec 28, 2023

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

아주 좋습니다👍🏻👍🏻

ssssujini99 reviewed Dec 28, 2023

View reviewed changes

scheduler/src/main/java/dev/hooon/common/config/SchedulerConfig.java

Copy link

Contributor

ssssujini99 Dec 28, 2023

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

👍🏻

ssssujini99 reviewed Dec 28, 2023

View reviewed changes

ssssujini99 approved these changes Dec 28, 2023

View reviewed changes

refactor : expireAt 컬럼 expiredAt 으로 네이밍 변경

b84ab45

EunChanNam merged commit f056544 into dev Dec 28, 2023
2 checks passed

EunChanNam deleted the feat/#37 branch December 28, 2023 17:09

		@@ -52,6 +53,8 @@ public class WaitingBooking extends TimeBaseEntity {

		private int seatCount;

		private LocalDateTime expireAt;


		public interface WaitingBookingJpaRepository extends JpaRepository<WaitingBooking, Long> {

		@EntityGraph(attributePaths = {"user", "waitingBookingSeats"})


		private final WaitingBookingFacade waitingBookingFacade;

		@Scheduled(cron = "0 /10 * * *")

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

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

Conversation

EunChanNam commented Dec 27, 2023

📄 무엇을 개발했나요?

🍸 무엇을 집중적으로 리뷰해야할까요?

github-actions bot commented Dec 27, 2023

🦞 Test Coverage Report

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

ssssujini99 commented Dec 28, 2023 • edited Loading

github-actions bot commented Dec 28, 2023

🦞 Test Coverage Report

ssssujini99 commented Dec 28, 2023 •

edited

Loading