Node.js 里定时任务和后台任务怎么做？

请求 → 校验参数 → 写库 → 投递任务 → 立即返回"处理中"（或任务 ID）
                              │
                         任务队列（Redis）
                              │
                worker 进程取出任务执行 → 失败按策略重试 → 结果写库 / 通知用户

import { Queue, Worker } from 'bullmq'
import { Redis } from 'ioredis' // 较新版本的 BullMQ 不再自带 ioredis，要单独安装

// Worker 使用的连接必须设置 maxRetriesPerRequest: null
const connection = new Redis(process.env.REDIS_URL ?? 'redis://127.0.0.1:6379', {
  maxRetriesPerRequest: null,
})

// ---- 生产者：接口里只负责投递 ----
const emailQueue = new Queue('email', { connection })

export async function onOrderPaid(orderId: string) {
  await emailQueue.add('order-paid', { orderId }, {
    jobId: `order-paid-${orderId}`,                // 同一个订单不会重复投递
    attempts: 5,                                   // 最多执行 5 次
    backoff: { type: 'exponential', delay: 1000 }, // 失败后按指数退避重试
    removeOnComplete: 1000,                        // 只保留最近 1000 个已完成的任务
    removeOnFail: 5000,
  })
}

// 定时任务：每个实例启动时都调用也没关系，同一个 ID 只有一个调度器
await emailQueue.upsertJobScheduler(
  'daily-report',
  { pattern: '0 3 * * *', tz: 'Asia/Shanghai' },
  { name: 'daily-report', data: {} },
)

// ---- 消费者：通常单独部署成 worker 进程 ----
const worker = new Worker('email', async (job) => {
  if (job.name === 'daily-report') return generateReport()
  await sendOrderEmail(job.data.orderId) // 抛出异常即视为失败，按 attempts 重试
}, { connection, concurrency: 5 })

worker.on('failed', (job, err) => {
  console.error(`任务 ${job?.id} 第 ${job?.attemptsMade} 次失败：${err.message}`)
})

// 优雅退出：等正在执行的任务完成再断开
process.on('SIGTERM', async () => {
  await worker.close()
  await connection.quit()
  process.exit(0)
})

declare function sendOrderEmail(orderId: string): Promise<void>
declare function generateReport(): Promise<void>