npm install node-schedule @types/node-schedule

import * as schedule from 'node-schedule';
import { Job } from 'node-schedule';

interface TaskConfig {
  name: string;
  schedule: string | Date;
  task: () => Promise<void> | void;
  enabled?: boolean;
}

class TaskScheduler {
  private jobs: Map<string, Job> = new Map();

  /**
   * Lập lịch một tác vụ với cú pháp giống cron hoặc ngày cụ thể
   * @param config Cấu hình tác vụ
   * @returns Instance Job
   */
  scheduleTask(config: TaskConfig): Job | null {
    if (!config.enabled && config.enabled !== undefined) {
      console.log(`Tác vụ ${config.name} đã bị vô hiệu, bỏ qua...`);
      return null;
    }

    try {
      const job = schedule.scheduleJob(config.name, config.schedule, async () => {
        console.log(`[${new Date().toISOString()}] Thực hiện tác vụ: ${config.name}`);
        try {
          await config.task();
          console.log(`[${new Date().toISOString()}] Tác vụ đã hoàn thành: ${config.name}`);
        } catch (error) {
          console.error(`[${new Date().toISOString()}] Tác vụ thất bại: ${config.name}`, error);
        }
      });

      if (job) {
        this.jobs.set(config.name, job);
        console.log(`Tác vụ đã được lập lịch: ${config.name} - Lần chạy tiếp theo: ${job.nextInvocation()}`);
      }

      return job;
    } catch (error) {
      console.error(`Lập lịch tác vụ thất bại: ${config.name}`, error);
      return null;
    }
  }

  /**
   * Lập lịch nhiều tác vụ cùng một lúc
   * @param configs Mảng cấu hình tác vụ
   */
  scheduleTasks(configs: TaskConfig[]): void {
    configs.forEach(config => this.scheduleTask(config));
  }

  /**
   * Hủy một tác vụ cụ thể
   * @param taskName Tên tác vụ cần hủy
   */
  cancelTask(taskName: string): boolean {
    const job = this.jobs.get(taskName);
    if (job) {
      job.cancel();
      this.jobs.delete(taskName);
      console.log(`Tác vụ đã bị hủy: ${taskName}`);
      return true;
    }
    console.warn(`Không tìm thấy tác vụ: ${taskName}`);
    return false;
  }

  /**
   * Hủy tất cả các tác vụ đã lập lịch
   */
  cancelAllTasks(): void {
    this.jobs.forEach((job, name) => {
      job.cancel();
      console.log(`Tác vụ đã bị hủy: ${name}`);
    });
    this.jobs.clear();
  }

  /**
   * Lấy thông tin về tất cả các tác vụ đã lập lịch
   */
  getTasksInfo(): Array<{name: string, nextRun: Date | null}> {
    const tasksInfo: Array<{name: string, nextRun: Date | null}> = [];

    this.jobs.forEach((job, name) => {
      tasksInfo.push({
        name,
        nextRun: job.nextInvocation()
      });
    });

    return tasksInfo;
  }

  /**
   * Lập lịch lại một tác vụ đã tồn tại
   * @param taskName Tên tác vụ cần lập lịch lại
   * @param newSchedule Lịch trình mới (cron hoặc ngày)
   */
  rescheduleTask(taskName: string, newSchedule: string | Date): boolean {
    const job = this.jobs.get(taskName);
    if (job) {
      const success = job.reschedule(newSchedule);
      if (success) {
        console.log(`Tác vụ đã được lập lịch lại: ${taskName} - Lần chạy tiếp theo: ${job.nextInvocation()}`);
      }
      return success;
    }
    console.warn(`Không tìm thấy tác vụ: ${taskName}`);
    return false;
  }

  /**
   * Tắt máy một cách an toàn - hủy tất cả các tác vụ
   */
  shutdown(): void {
    console.log('Đang tắt trình lập lịch...');
    this.cancelAllTasks();
    schedule.gracefulShutdown();
  }
}

* * * * * *
┬ ┬ ┬ ┬ ┬ ┬
│ │ │ │ │ │
│ │ │ │ │ └ ngày trong tuần (0 - 7) (0 hoặc 7 là Chủ nhật)
│ │ │ │ └───── tháng (1 - 12)
│ │ │ └────────── ngày trong tháng (1 - 31)
│ │ └─────────────── giờ (0 - 23)
│ └──────────────────── phút (0 - 59)
└───────────────────────── giây (0 - 59, tùy chọn)

// Khởi tạo trình lập lịch
const scheduler = new TaskScheduler();

// Các tác vụ ví dụ
const exampleTasks: TaskConfig[] = [
  {
    name: 'daily-report',
    schedule: '0 9 * * *', // Mỗi ngày lúc 9:00 sáng
    task: async () => {
      console.log('Đang tạo báo cáo hàng ngày...');
      await new Promise(resolve => setTimeout(resolve, 1000));
      console.log('Báo cáo hàng ngày đã được tạo thành công');
    },
    enabled: true
  },
  {
    name: 'database-cleanup',
    schedule: '0 2 * * 0', // Mỗi Chủ nhật lúc 2:00 sáng
    task: async () => {
      console.log('Đang bắt đầu dọn dẹp cơ sở dữ liệu...');
      await new Promise(resolve => setTimeout(resolve, 2000));
      console.log('Dọn dẹp cơ sở dữ liệu đã hoàn tất');
    },
    enabled: true
  },
];

// Lập lịch tất cả các tác vụ
scheduler.scheduleTasks(exampleTasks);

// Hiển thị thông tin các tác vụ đã lập lịch
console.log('\n=== Các tác vụ đã lập lịch ===');
const tasksInfo = scheduler.getTasksInfo();
tasksInfo.forEach(task => {
  console.log(`${task.name}: Lần chạy tiếp theo lúc ${task.nextRun}`);
});

// Tắt máy an toàn khi quá trình kết thúc
process.on('SIGINT', () => {
  console.log('\nNhận tín hiệu SIGINT, đang tắt máy an toàn...');
  scheduler.shutdown();
  process.exit(0);
});