Merge pull request #253 from boostcampwm-2024/feat/#233-admin-init-opened-event

관리자 기능: 오픈된 이벤트 상태 초기화

Author: kyu4583

back/src/domains/booking/controller/booking.controller.ts

@@ -195,4 +195,16 @@ export class BookingController {
   async reloadOpenTarget() {
     await this.openBookingService.scheduleUpcomingReservations();
   }
+
+  @Post('init/:eventId')
+  @UseGuards(SessionAuthGuard(USER_STATUS.ADMIN))
+  @ApiOperation({
+    summary: 'ADMIN: 예약 초기화',
+    description: '특정 이벤트의 예약 상태를 초기화한다.',
+  })
+  @ApiOkResponse({ description: '예약 초기화 완료' })
+  @ApiUnauthorizedResponse({ description: '인증 실패' })
+  async initReservation(@Param('eventId') eventId: number) {
+    await this.openBookingService.initReservation(eventId);
+  }
 }

back/src/domains/booking/service/in-booking.service.ts

@@ -5,6 +5,7 @@ import Redis from 'ioredis';
 
 import { AuthService } from '../../../auth/service/auth.service';
 import { UserService } from '../../user/service/user.service';
+import { IN_BOOKING_DEFAULT_MAX_SIZE } from '../const/inBookingDefaultMaxSize.const';
 
 type InBookingSession = {
   sid: string;
@@ -26,7 +27,11 @@ export class InBookingService {
   }
 
   async getInBookingSessionsDefaultMaxSize() {
-    return parseInt(await this.redis.get('in-booking:default-max-size'));
+    const defaultMaxSizeData = await this.redis.get('in-booking:default-max-size');
+    if (defaultMaxSizeData) {
+      return parseInt(defaultMaxSizeData);
+    }
+    return IN_BOOKING_DEFAULT_MAX_SIZE;
   }
 
   async setInBookingSessionsDefaultMaxSize(size: number) {

back/src/domains/booking/service/open-booking.service.ts

@@ -41,6 +41,11 @@ export class OpenBookingService implements OnApplicationBootstrap {
     await this.scheduleUpcomingReservations();
   }
 
+  async initReservation(eventId: number) {
+    await this.closeReservationAnyway(eventId);
+    await this.openReservationById(eventId);
+  }
+
   @Cron(ONE_MINUTE_BEFORE_THE_HOUR)
   async scheduleUpcomingReservations() {
     const comingEvents = await this.eventRepository.selectUpcomingEvents();
@@ -51,7 +56,9 @@ export class OpenBookingService implements OnApplicationBootstrap {
   private async scheduleUpcomingReservationsToOpen(comingEvents: Event[]) {
     const now = new Date();
     const openedEventIds = new Set(await this.getOpenedEventIds());
-    const eventToOpen = comingEvents.filter((event) => event.reservationOpenDate <= now);
+    const eventToOpen = comingEvents.filter(
+      (event) => !openedEventIds.has(event.id) && event.reservationOpenDate <= now,
+    );
     const eventsToScheduleOpen = comingEvents.filter(
       (event) => !openedEventIds.has(event.id) && event.reservationOpenDate > now,
     );
@@ -154,6 +161,14 @@ export class OpenBookingService implements OnApplicationBootstrap {
     await this.redis.set(`open-booking:${eventId}:opened`, 'true');
   }
 
+  async closeReservationAnyway(eventId: number) {
+    await this.unlinkOpenedEvent(eventId);
+    await this.clearWaitingService(eventId);
+    await this.clearEnteringService(eventId);
+    await this.seatsUpdateService.clearSeatsSubscription(eventId);
+    await this.clearInBookingService(eventId);
+  }
+
   async closeReservation(eventId: number) {
     await this.validateClosingEvent(eventId);
     await this.unlinkOpenedEvent(eventId);