Merge pull request #63 from VentionCapstone/feat/131_booking-status-u…

…pdater-cron

feat: booking end checker cron

package.json

@@ -42,6 +42,7 @@
     "@nestjs/mapped-types": "*",
     "@nestjs/passport": "^10.0.3",
     "@nestjs/platform-express": "^10.2.10",
+    "@nestjs/schedule": "^4.0.0",
     "@nestjs/swagger": "^7.1.16",
     "@nestjs/terminus": "^10.2.0",
     "@prisma/client": "^5.6.0",

src/app.module.ts

@@ -1,5 +1,6 @@
 import { Logger, Module } from '@nestjs/common';
 import { ConfigModule } from '@nestjs/config';
+import { ScheduleModule } from '@nestjs/schedule';
 import { AcceptLanguageResolver, I18nModule, QueryResolver } from 'nestjs-i18n';
 import * as path from 'path';
 import { AccommodationModule } from './accommodation/accommodation.module';
@@ -35,6 +36,7 @@ import { WishlistModule } from './wishlist/wishlist.module';
         AcceptLanguageResolver,
       ],
     }),
+    ScheduleModule.forRoot(),
     AuthModule,
     UserModule,
     AmenitiesModule,

src/booking/booking.service.ts

@@ -1,10 +1,12 @@
 import { BadRequestException, HttpException, Injectable, NotFoundException } from '@nestjs/common';
+import { Cron, CronExpression } from '@nestjs/schedule';
 import { Status } from '@prisma/client';
 import * as dayjs from 'dayjs';
 import { Dayjs } from 'dayjs';
 import * as isSameOrBefore from 'dayjs/plugin/isSameOrBefore';
 import * as utc from 'dayjs/plugin/utc';
 import { PaginationDto } from 'src/accommodation/dto/pagination.dto';
+import { STANDARD_CHECKOUT_HOUR } from 'src/common/constants/booking';
 import { DEFAULT_DATE_FORMAT } from 'src/common/constants/date';
 import { AuthUser } from 'src/common/types/AuthUser.type';
 import ErrorsTypes from 'src/errors/errors.enum';
@@ -266,4 +268,65 @@ export class BookingService {
   private getTimeInZone(date: Date, offset: number) {
     return dayjs(date).utcOffset(-offset).add(offset, 'minutes');
   }
+
+  @Cron(CronExpression.EVERY_HOUR)
+  async checkBookingEnd() {
+    const serverUtcOffset = dayjs().utcOffset();
+    const tomorrow = dayjs()
+      .add(1, 'day')
+      .startOf('day')
+      .add(serverUtcOffset, 'minutes')
+      .toISOString();
+
+    const bookings = await this.prismaService.booking.findMany({
+      select: {
+        id: true,
+        endDate: true,
+        accommodation: {
+          select: {
+            timezoneOffset: true,
+          },
+        },
+      },
+      where: {
+        status: Status.ACTIVE,
+        endDate: {
+          lte: tomorrow,
+        },
+      },
+    });
+
+    const completedBookingsIds = [];
+    const now = dayjs();
+
+    for (const booking of bookings) {
+      const {
+        id,
+        endDate,
+        accommodation: { timezoneOffset },
+      } = booking;
+
+      const bookingEnd = this.getTimeInZone(endDate, timezoneOffset).add(
+        STANDARD_CHECKOUT_HOUR,
+        'hours'
+      );
+
+      if (bookingEnd.isBefore(now)) {
+        completedBookingsIds.push(id);
+      }
+    }
+
+    if (completedBookingsIds.length > 0) {
+      await this.prismaService.booking.updateMany({
+        where: {
+          id: {
+            in: completedBookingsIds,
+          },
+        },
+        data: {
+          status: Status.COMPLETED,
+        },
+      });
+    }
+  }
 }

src/common/constants/booking.ts

@@ -0,0 +1 @@
+export const STANDARD_CHECKOUT_HOUR = 11;