weseek__growi/packages/app/src/server/service/questionnaire-cron.ts

import axios from '~/utils/axios';

import Crowi from '../crowi';
import { QuestionnaireOrderDocument } from '../models/questionnaire/questionnaire-order';

const nodeCron = require('node-cron');

const getRandomInt = (min: number, max: number): number => {
  const minInt = Math.ceil(min);
  const maxInt = Math.floor(max);
  return Math.floor(Math.random() * (maxInt - minInt) + minInt);
};

const sleep = msec => new Promise(resolve => setTimeout(resolve, msec));

class QuestionnaireCronService {

  growiQuestionnaireUri: string;

  cronSchedule: string;

  maxHoursUntilRequest: number;

  constructor(crowi: Crowi) {
    this.growiQuestionnaireUri = crowi.configManager?.getConfig('crowi', 'app:growiQuestionnaireUri');
    this.cronSchedule = crowi.configManager?.getConfig('crowi', 'app:questionnaireCronSchedule');
    this.maxHoursUntilRequest = crowi.configManager?.getConfig('crowi', 'app:questionnaireCronMaxHoursUntilRequest');
  }

  setUpCron(): void {
    const maxSecondsUntilRequest = this.maxHoursUntilRequest * 60 * 60;
    this.questionnaireOrderGetCron(this.cronSchedule, maxSecondsUntilRequest);
  }

  questionnaireOrderGetCron(cronSchedule: string, maxSecondsUntilRequest: number): void {
    nodeCron.schedule(cronSchedule, async() => {
      const secToSleep = getRandomInt(0, maxSecondsUntilRequest);

      await sleep(secToSleep * 1000);

      try {
        const response = await axios.get(`${this.growiQuestionnaireUri}/questionnaire-order/index`);
        const questionnaireOrders: QuestionnaireOrderDocument[] = response.data.questionnaireOrders;
        console.log(response.data);
        console.log(questionnaireOrders);
      }
      catch (e) {
        console.log(e);
      }

    }).start();
  }

}

export default QuestionnaireCronService;