在Node.js和MongoDB中实现文档过期通知机制

const mongoose = require('mongoose');

const documentSchema = new mongoose.Schema({
  userId: { type: mongoose.Schema.Types.ObjectId, ref: 'User', required: true },
  documentName: { type: String, required: true },
  uploadDate: { type: Date, default: Date.now },
  expirationTime: { type: Date, required: true }, // 关键字段：过期时间
  expired: { type: Boolean, default: false },    // 关键字段：是否已过期并处理
  // 其他文档相关字段
  // ...
});

const Document = mongoose.model('Document', documentSchema);
module.exports = Document;

npm install node-cron mongoose

const cron = require('node-cron');
const Document = require('./path/to/your/documentModel'); // 引入你的MongoDB模型
// 假设你已经配置了Mongoose连接

/**
 * 检查并处理过期文档的函数
 */
const checkExpiredDocuments = async () => {
  try {
    const currentDate = new Date(); // 获取当前时间

    // 查找所有过期时间早于当前时间且尚未被标记为“已过期”的文档
    const expiredDocs = await Document.find({
      expirationTime: { $lt: currentDate },
      expired: false,
    });

    if (expiredDocs.length > 0) {
      console.log(`检测到 ${expiredDocs.length} 个过期文档，正在处理...`);

      // 遍历并处理每个过期文档
      for (const doc of expiredDocs) {
        // 1. 发送通知（例如，邮件通知用户）
        await notifyUserOfExpiration(doc);
        console.log(`已通知用户文档 "${doc.documentName}" (ID: ${doc._id}) 过期。`);

        // 2. 将文档标记为已过期，避免重复通知
        doc.expired = true;
        await doc.save();
        console.log(`文档 "${doc.documentName}" (ID: ${doc._id}) 已标记为过期。`);
      }
    } else {
      console.log('未检测到新的过期文档。');
    }

  } catch (error) {
    console.error('检查过期文档时发生错误:', error);
  }
};

/**
 * 占位函数：模拟发送用户过期通知
 * 在实际应用中，这里会集成邮件服务（如Nodemailer）、短信服务等
 * @param {Object} document - 过期的文档对象
 */
const notifyUserOfExpiration = async (document) => {
  // 实际的通知逻辑，例如：
  // const user = await User.findById(document.userId);
  // if (user && user.email) {
  //   await sendEmail(user.email, '您的文档已过期', `尊敬的用户，您的文档"${document.documentName}"已于${document.expirationTime.toLocaleString()}过期。`);
  // }
  return new Promise(resolve => setTimeout(resolve, 500)); // 模拟异步操作
};

// 导出函数，以便在主应用中调度
module.exports = {
  checkExpiredDocuments,
  notifyUserOfExpiration
};

const mongoose = require('mongoose');
const cron = require('node-cron');
const { checkExpiredDocuments } = require('./path/to/your/cronJobs'); // 引入你的定时任务函数

// MongoDB 连接配置
mongoose.connect('mongodb://localhost:27017/your_database', {
  useNewUrlParser: true,
  useUnifiedTopology: true,
})
.then(() => console.log('MongoDB 连接成功'))
.catch(err => console.error('MongoDB 连接失败:', err));

// 调度任务：每小时的第0分钟执行一次
// cron.schedule('0 * * * *', checkExpiredDocuments);
// 示例：每分钟执行一次，方便测试
cron.schedule('* * * * *', () => {
  console.log('正在执行过期文档检查任务...');
  checkExpiredDocuments();
});

console.log('定时任务已启动，等待执行...');

// 启动你的Node.js服务器（如果适用）
// app.listen(3000, () => console.log('Server running on port 3000'));