MongoDB更新文档数组中符合时间条件且expiry最小的对象

问题根因 #

原有写法中使用的$数组定位符，只会匹配$elemMatch筛选到的第一个数组元素，不会自动按expiry排序取最小值，无法定位到符合要求的目标项。

实现方案 #

方案1：原子聚合更新（推荐，无并发风险） #

基于MongoDB 4.2+支持的聚合管道更新能力，单条语句原子完成筛选、定位、更新操作，不存在并发安全问题：

const now = Date.now()
await UserTransactions.updateOne(
  // 前置过滤：仅处理存在有效交易的文档，避免无效更新
  { 
    _id: given_id, 
    transactions: { $elemMatch:{ available_from:{ $lt: now }, expiry: { $gt: now }}}
  },
  [
    // 第一步：计算所有有效交易中expiry最小的元素所在索引
    {
      $set: {
        targetIndex: {
          $indexOfArray: [
            "$transactions.expiry",
            {
              $min: {
                $map: {
                  input: {
                    $filter: {
                      input: "$transactions",
                      cond: {
                        $and: [
                          { $lt: ["$$this.available_from", now] },
                          { $gt: ["$$this.expiry", now] }
                        ]
                      }
                    }
                  },
                  in: "$$this.expiry"
                }
              }
            }
          ]
        }
      }
    },
    // 第二步：遍历数组，仅对目标索引的元素扣减quantity
    {
      $set: {
        transactions: {
          $map: {
            input: "$transactions",
            in: {
              $cond: [
                { $eq: [{ $indexOfArray: ["$transactions", "$$this"] }, "$targetIndex"] },
                { $mergeObjects: ["$$this", { quantity: { $add: ["$$this.quantity", -1] } }] },
                "$$this"
              ]
            }
          }
        }
      }
    },
    // 第三步：清理临时计算字段
    { $unset: "targetIndex" }
  ]
)

方案2：先查后改（兼容低版本MongoDB） #

如果使用的MongoDB版本低于4.2，不支持聚合管道更新，可以分两步操作，逻辑更直观：

const now = Date.now()
// 1. 查询目标文档，筛选有效交易
const userDoc = await UserTransactions.findOne(
  { _id: given_id },
  { transactions: 1 }
)
if (!userDoc) throw new Error('对应用户记录不存在')

// 过滤出当前时间在有效期内的交易，按expiry升序取第一个（即expiry最小的项）
const validTxs = userDoc.transactions.filter(tx => tx.available_from < now && tx.expiry > now)
if (validTxs.length === 0) throw new Error('无可用有效交易')
const targetTx = validTxs.sort((a, b) => a.expiry - b.expiry)[0]

// 2. 通过arrayFilters精准定位目标子项更新
await UserTransactions.updateOne(
  { _id: given_id },
  { $inc: { "transactions.$[tx].quantity": -1 } },
  {
    arrayFilters: [{ "tx._id": targetTx._id }]
  }
)

注意：先查后改不属于原子操作，如果业务存在高并发扣减同一条用户记录的场景，必须搭配MongoDB事务使用，避免超扣问题。

内容的提问来源于stack exchange，提问作者heeya joshi