modify: change cron time

Author: sideseal

Diff for: src/rotation/rotations.service.ts

@@ -35,9 +35,9 @@ import { FindAllRotationDto } from './dto/find-all-rotation.dto';
 
 function getRotationCronTime() {
   if (process.env.NODE_ENV === 'production') {
-    return '59 23 * * 5';
+    return '42 4 27 * *';
   }
-  return '0 0 * * 5';
+  return '0 0 27 * *';
 }
 
 @Injectable()
@@ -101,24 +101,53 @@ export class RotationsService {
   }
 
   /*
-   * 매일 0시 0분마다, 현재 날짜가 이번 달 4째주 월요일/금요일인지 확인하여, 집현전 슬랙 채널에 메세지를 보내는 cron job
+   * 매월 23일, 집현전 슬랙 채널에 메세지를 보내는 cron job
    */
-  @Cron('0 0 * * *', {
-    name: 'sendMessageRotationDeadline',
+  @Cron('42 15 23 * *', {
+    name: 'sendMessageRotationDeadlineFirst',
     timeZone: 'Asia/Seoul',
   })
-  async sendMessageRotationDeadline(): Promise<void> {
-    let message: string;
-    const today = new Date().getDate();
-    if (today === getFourthMondayOfMonth()) {
-      message =
-        '[알림] 로테이션 신청 기간이 시작되었습니다. 이번 주 금요일까지 신청해주세요!\n[신청하러 가기]: https://together.42jip.net/';
-    } else if (today === getFourthFridayOfMonth()) {
-      message =
-        '[알림] 로테이션 신청 기간이 내일 마감됩니다. 오늘까지 신청해주세요!\n[신청하러 가기]: https://together.42jip.net/';
-    } else {
-      return;
-    }
+  async sendMessageRotationDeadlineFirst(): Promise<void> {
+    const message =
+      '[알림] 4일 후 로테이션 신청이 마감됩니다.\n[신청하러 가기]: https://together.42jip.net/';
+
+    await this.slackService.postMessage(
+      Message({
+        text: message,
+        channel: this.configService.get('slack.jiphyeonjeonChannel'),
+      }).buildToObject(),
+    );
+  }
+
+  /*
+   * 매월 26일, 집현전 슬랙 채널에 메세지를 보내는 cron job
+   */
+  @Cron('42 15 26 * *', {
+    name: 'sendMessageRotationDeadlineFirst',
+    timeZone: 'Asia/Seoul',
+  })
+  async sendMessageRotationDeadlineLast(): Promise<void> {
+    const message =
+      '[알림] 로테이션 신청 기간이 내일 마감됩니다. 오늘까지 신청해주세요!\n[신청하러 가기]: https://together.42jip.net/';
+
+    await this.slackService.postMessage(
+      Message({
+        text: message,
+        channel: this.configService.get('slack.jiphyeonjeonChannel'),
+      }).buildToObject(),
+    );
+  }
+
+  /*
+   * 매월 27일 사서 로테이션 설정이 완료된 후, 집현전 슬랙 채널에 메세지를 보내는 cron job
+   */
+  @Cron('42 15 27 * *', {
+    name: 'sendMessageRotationDeadlineFirst',
+    timeZone: 'Asia/Seoul',
+  })
+  async sendMessageRotationFinished(): Promise<void> {
+    const message =
+      '[알림] 다음 달 로테이션이 확정되었습니다! 친바 사이트에서 확인해주세요!\n[확인하러 가기]: https://together.42jip.net/';
 
     await this.slackService.postMessage(
       Message({
@@ -159,101 +188,102 @@ export class RotationsService {
    * 매주 금요일을 체크하여, 만약 4주차 금요일인 경우,
    * 23시 59분에 로테이션을 돌린다.
    * 다음 달 로테이션 참석자를 바탕으로 로테이션 결과 반환
+   * [update 20240202] - 매월 4주차 금요일이 아닌, 매월 27일 새벽에 로테이션을 돌린다.
    */
   @Cron(`${getRotationCronTime()}`, {
     name: 'setRotation',
     timeZone: 'Asia/Seoul',
   })
   async setRotation(): Promise<void> {
-    if (getFourthWeekdaysOfMonth().indexOf(getTodayDay()) > 0) {
-      this.logger.log('Setting rotation...');
+    // if (getFourthWeekdaysOfMonth().indexOf(getTodayDay()) > 0) {
+    this.logger.log('Setting rotation...');
 
-      const { year, month } = getNextYearAndMonth();
-      const attendeeArray: Partial<RotationAttendeeEntity>[] = await this.getAllRegistration();
-      const monthArrayInfo: DayObject[][] = await this.getInitMonthArray(year, month);
+    const { year, month } = getNextYearAndMonth();
+    const attendeeArray: Partial<RotationAttendeeEntity>[] = await this.getAllRegistration();
+    const monthArrayInfo: DayObject[][] = await this.getInitMonthArray(year, month);
 
-      if (!attendeeArray || attendeeArray.length === 0) {
-        this.logger.warn('No attendees participated in the rotation');
-        return;
-      }
+    if (!attendeeArray || attendeeArray.length === 0) {
+      this.logger.warn('No attendees participated in the rotation');
+      return;
+    }
 
-      const rotationAttendeeInfo: RotationAttendeeInfo[] = attendeeArray.map((attendee) => {
-        const parsedAttendLimit: number[] = Array.isArray(attendee.attendLimit)
-          ? JSON.parse(JSON.stringify(attendee.attendLimit))
-          : [];
-        return {
-          userId: attendee.userId,
-          year: attendee.year,
-          month: attendee.month,
-          attendLimit: parsedAttendLimit,
-          attended: 0,
-        };
-      });
+    const rotationAttendeeInfo: RotationAttendeeInfo[] = attendeeArray.map((attendee) => {
+      const parsedAttendLimit: number[] = Array.isArray(attendee.attendLimit)
+        ? JSON.parse(JSON.stringify(attendee.attendLimit))
+        : [];
+      return {
+        userId: attendee.userId,
+        year: attendee.year,
+        month: attendee.month,
+        attendLimit: parsedAttendLimit,
+        attended: 0,
+      };
+    });
 
-      // 만약 year & month에 해당하는 로테이션 정보가 이미 존재한다면,
-      // 해당 로테이션 정보를 삭제하고 다시 생성한다.
-      const hasInfo = await this.rotationRepository.find({
+    // 만약 year & month에 해당하는 로테이션 정보가 이미 존재한다면,
+    // 해당 로테이션 정보를 삭제하고 다시 생성한다.
+    const hasInfo = await this.rotationRepository.find({
+      where: {
+        year: year,
+        month: month,
+      },
+    });
+
+    if (hasInfo.length > 0) {
+      this.logger.log('Rotation info already exists. Deleting...');
+      await this.rotationRepository.softRemove(hasInfo);
+    }
+
+    const rotationResultArray: DayObject[] = createRotation(rotationAttendeeInfo, monthArrayInfo);
+
+    for (const item of rotationResultArray) {
+      const [userId1, userId2] = item.arr;
+
+      const attendeeOneExist = await this.rotationRepository.findOne({
         where: {
+          userId: userId1,
           year: year,
           month: month,
+          day: item.day,
         },
       });
 
-      if (hasInfo.length > 0) {
-        this.logger.log('Rotation info already exists. Deleting...');
-        await this.rotationRepository.softRemove(hasInfo);
-      }
-
-      const rotationResultArray: DayObject[] = createRotation(rotationAttendeeInfo, monthArrayInfo);
+      if (!attendeeOneExist) {
+        const rotation1 = new RotationEntity();
+        rotation1.userId = userId1;
+        rotation1.updateUserId = userId1;
+        rotation1.year = year;
+        rotation1.month = month;
+        rotation1.day = item.day;
 
-      for (const item of rotationResultArray) {
-        const [userId1, userId2] = item.arr;
-
-        const attendeeOneExist = await this.rotationRepository.findOne({
-          where: {
-            userId: userId1,
-            year: year,
-            month: month,
-            day: item.day,
-          },
-        });
-
-        if (!attendeeOneExist) {
-          const rotation1 = new RotationEntity();
-          rotation1.userId = userId1;
-          rotation1.updateUserId = userId1;
-          rotation1.year = year;
-          rotation1.month = month;
-          rotation1.day = item.day;
-
-          await this.rotationRepository.save(rotation1);
-        }
+        await this.rotationRepository.save(rotation1);
+      }
 
-        const attendeeTwoExist = await this.rotationRepository.findOne({
-          where: {
-            userId: userId2,
-            year: year,
-            month: month,
-            day: item.day,
-          },
-        });
+      const attendeeTwoExist = await this.rotationRepository.findOne({
+        where: {
+          userId: userId2,
+          year: year,
+          month: month,
+          day: item.day,
+        },
+      });
 
-        if (!attendeeTwoExist) {
-          const rotation2 = new RotationEntity();
-          rotation2.userId = userId2;
-          rotation2.updateUserId = userId2;
-          rotation2.year = year;
-          rotation2.month = month;
-          rotation2.day = item.day;
+      if (!attendeeTwoExist) {
+        const rotation2 = new RotationEntity();
+        rotation2.userId = userId2;
+        rotation2.updateUserId = userId2;
+        rotation2.year = year;
+        rotation2.month = month;
+        rotation2.day = item.day;
 
-          await this.rotationRepository.save(rotation2);
-        }
+        await this.rotationRepository.save(rotation2);
       }
-
-      this.logger.log('Successfully set rotation!');
-    } else {
-      // skipped...
     }
+
+    this.logger.log('Successfully set rotation!');
+    // } else {
+    //   // skipped...
+    // }
   }
 
   /*