Node.js与MongoDB：构建高效的文档过期通知系统

{
  "_id": ObjectId("65c8a4b0e7a1d2f3g4h5i6j7"),
  "userId": "user123",              // 文档所属用户ID
  "documentName": "用户服务协议",     // 文档名称
  "uploadDate": ISODate("2023-01-15T10:00:00Z"), // 文档上传日期
  "expirationTime": ISODate("2024-01-15T10:00:00Z"), // 文档的过期时间，使用ISODate类型
  "expired": false,                // 标记文档是否已过期，默认为false
  "notificationSent": false,       // 可选：标记是否已发送过期通知，默认为false
  "metaData": {
    "type": "agreement",
    "version": "1.0"
  }
}

npm install node-cron

// server.js 或您的主应用文件

const cron = require('node-cron');
const mongoose = require('mongoose'); // 假设您使用Mongoose连接MongoDB
const Document = require('./models/Document'); // 替换为您的Mongoose模型路径

// 确保MongoDB连接已建立
// mongoose.connect('mongodb://localhost:27017/your_database', { useNewUrlParser: true, useUnifiedTopology: true })
//   .then(() => console.log('MongoDB connected'))
//   .catch(err => console.error('MongoDB connection error:', err));

/**
 * 异步函数：检查并标记过期文档，然后触发通知
 */
const checkAndNotifyExpiredDocuments = async () => {
  try {
    const currentDate = new Date(); // 获取当前UTC时间

    // 步骤1: 查找所有过期时间早于当前日期，且尚未被标记为已过期的文档
    // 并将它们标记为 expired: true
    const updateResult = await Document.updateMany(
      {
        expirationTime: { $lt: currentDate }, // 过期时间早于当前时间
        expired: false                      // 尚未被标记为过期
      },
      {
        $set: {
          expired: true // 标记为已过期
        }
      }
    );

    console.log(`[${currentDate.toISOString()}] 发现并标记了 ${updateResult.modifiedCount} 个过期文档。`);

    // 步骤2: 查询所有已标记为过期但尚未发送通知的文档，并进行通知
    // 这一步是为了确保通知逻辑与过期标记逻辑分离，更灵活
    const documentsToNotify = await Document.find({
      expired: true,
      notificationSent: false
    }).lean(); // 使用.lean()获取纯JavaScript对象，提高性能

    if (documentsToNotify.length > 0) {
      console.log(`[${currentDate.toISOString()}] 准备发送 ${documentsToNotify.length} 份过期通知。`);
      for (const doc of documentsToNotify) {
        // TODO: 在此处调用您的通知函数
        // 例如：await sendEmailNotification(doc.userId, doc.documentName, doc.expirationTime);
        console.log(`通知用户 ${doc.userId}：文档 "${doc.documentName}" 已于 ${doc.expirationTime.toISOString()} 过期。`);

        // 标记通知已发送，防止重复发送
        await Document.updateOne(
          { _id: doc._id },
          { $set: { notificationSent: true } }
        );
      }
      console.log(`[${currentDate.toISOString()}] 已完成过期文档通知发送。`);
    }

  } catch (error) {
    console.error(`[${new Date().toISOString()}] 检查过期文档时发生错误:`, error);
  }
};

// 调度任务：每小时的第0分钟执行一次 (例如，00:00, 01:00, 02:00 等)
// 您可以根据业务需求调整调度频率。
// 例如：
// '*/5 * * * *'  - 每5分钟执行一次
// '0 0 * * *'    - 每天午夜执行一次
cron.schedule('0 * * * *', checkAndNotifyExpiredDocuments, {
  scheduled: true,
  timezone: "Asia/Shanghai" // 根据您的服务器时区调整，或确保所有时间都按UTC处理
});

console.log('Node.js应用已启动，过期文档检查任务已调度。');

// 示例Mongoose模型 (models/Document.js)
// const mongoose = require('mongoose');
// const documentSchema = new mongoose.Schema({
//   userId: { type: String, required: true },
//   documentName: { type: String, required: true },
//   uploadDate: { type: Date, default: Date.now },
//   expirationTime: { type: Date, required: true },
//   expired: { type: Boolean, default: false },
//   notificationSent: { type: Boolean, default: false }
// });
// module.exports = mongoose.model('Document', documentSchema);