MongoDB文档删除异常：定时器为负未及时删除问题求助

问题根源 #

你当前的代码逻辑存在两个核心问题：

• 每次仅通过findOne()获取单个文档，但用updateMany()给所有文档的timer减1000，导致只有这个被查询到的文档会被检查是否到期，其他文档的timer会持续被减到负数，直到这个文档处理完成后才会轮到它们；
• 到期处理逻辑完全绑定在单个文档的查询结果上，没有主动遍历所有已到期的文档。

修复方案 #

把定时任务拆成两个独立步骤，实现批量更新+批量处理到期文档：

1. 先给所有未到期（timer > 0）的文档批量减1000，避免已经到期的文档timer继续变成负数；
2. 查询所有timer ≤ 0的文档，逐个处理到期逻辑（编辑消息、抽取获奖者）并删除。

完整修复代码 #

// 每秒执行的定时任务
setInterval(async () => {
  // 第一步：给所有未到期的文档批量减少1000毫秒
  await giveaway.updateMany(
    { timer: { $gt: 0 } }, // 只更新还在计时中的文档
    { $inc: { timer: -1000 } }
  );

  // 第二步：查询所有已到期的文档
  const expiredGiveaways = await giveaway.find({ timer: { $lte: 0 } });

  // 逐个处理到期的抽奖
  for (const schema of expiredGiveaways) {
    try {
      // 抽取获奖者逻辑
      const random = [...schema.userEntries].sort(() => 0.5 - Math.random());
      const shuffle = random.slice(0, schema.giveawayOptions.winners);
      const newShuffle = shuffle.map(id => `<@${id}>`);

      // 更新Discord消息
      const channel = client.channels.cache.get(schema.ChannelID);
      if (channel) {
        const msg = await channel.messages.fetch(schema.MessageID);
        await msg.edit({
          embeds: [
            new Discord.EmbedBuilder()
              .setAuthor({
                name: schema.giveawayOptions.prize,
                iconURL: "https://cdn.discordapp.com/attachments/1030899776423723171/1071213376644075640/MainGift.png"
              })
              .setDescription(
                `**•** This giveaway event has **ended!**\n\n${
                  schema.userEntries.length >= 1
                    ? `Winners **•** ${newShuffle.join(", ")}`
                    : "**•** No participators!"
                }`
              )
              .setColor(client.mainColor)
          ],
          components: []
        });
      }

      // 删除已处理的文档
      await giveaway.findByIdAndDelete(schema._id);
    } catch (error) {
      console.error(`处理抽奖失败：${error}`);
      // 可选：处理出错时记录日志，避免单个失败阻塞所有任务
    }
  }
}, 1 * 1000);

关键优化点 #

• 用find({ timer: { $lte: 0 } })替代单个文档查询，确保所有到期的文档都会被及时处理；
• 更新timer时添加timer: { $gt: 0 }条件，防止已到期的文档timer继续减少变成负数；
• 用循环逐个处理到期文档，每个文档的处理逻辑独立，不会互相阻塞；
• 添加异常捕获，避免单个抽奖处理失败导致整个定时任务崩溃。

内容的提问来源于stack exchange，提问作者Sprint's Utilities