云数据库MongoDB秒杀

// 假设有一个商品文档如下：
{
  "_id": ObjectId("..."),
  "name": "秒杀商品",
  "stock": 100,
  "version": 1
}

// 秒杀逻辑
async function seckill(productId) {
  const session = db.getMongo().startSession();
  try {
    session.startTransaction();
    const product = await db.products.findOne({ _id: productId }, { session });
    
    if (product.stock > 0) {
      // 检查版本号
      const result = await db.products.updateOne(
        { _id: productId, version: product.version },
        { $inc: { stock: -1 }, $set: { version: product.version + 1 } },
        { session }
      );
      
      if (result.modifiedCount === 1) {
        // 更新成功，处理订单逻辑
        console.log("秒杀成功！");
      } else {
        console.log("秒杀失败，商品已被抢光或版本不一致。");
      }
    } else {
      console.log("秒杀失败，商品已售罄。");
    }
    await session.commitTransaction();
  } catch (error) {
    await session.abortTransaction();
    console.error("秒杀过程中发生错误：", error);
  } finally {
    session.endSession();
  }
}