Kotlin中Firestore查询结果复用及订单地毯总费用计算写入方法

两种实现方案可选，按需使用：

方案1：前端/后端主动计算（适合手动触发场景） #

直接调用Firestore原生聚合查询计算总和，无需拉取所有地毯文档，性能更高：

// 以Web SDK v9为例
import { getFirestore, collection, getAggregateFromServer, sum, doc, updateDoc } from "firebase/firestore";
const db = getFirestore();

// 替换为你要计算的订单ID
const targetOrderId = "your_order_id";
// 构造对应订单下的carpets子集合引用
const carpetsCollectionRef = collection(db, "orders", targetOrderId, "carpets");

// 聚合查询直接计算cost字段总和
const aggregateSnapshot = await getAggregateFromServer(carpetsCollectionRef, {
  totalCarpetCost: sum("cost")
});
const totalCost = aggregateSnapshot.data().totalCarpetCost || 0;

// 将总和写入订单文档的指定字段（示例为totalCost字段，可自行替换）
const orderDocRef = doc(db, "orders", targetOrderId);
await updateDoc(orderDocRef, { totalCost: totalCost });

方案2：云函数自动更新（推荐生产环境使用） #

通过云函数监听carpets子集合的增删改操作，自动同步总费用到订单文档，避免前端篡改数据：

// 以Node.js云函数为例
const functions = require("firebase-functions");
const admin = require("firebase-admin");
admin.initializeApp();
const db = admin.firestore();

exports.syncOrderTotalCost = functions.firestore
  .document("orders/{orderId}/carpets/{carpetId}")
  .onWrite(async (change, context) => {
    const orderId = context.params.orderId;
    const carpetsCol = db.collection("orders").doc(orderId).collection("carpets");
    // 聚合计算总费用
    const aggResult = await carpetsCol.aggregate({
      total: admin.firestore.AggregateField.sum("cost")
    }).get();
    const total = aggResult.data().total || 0;
    // 更新订单文档
    await db.collection("orders").doc(orderId).update({ totalCost: total });
    return null;
  });

Firestore所有读写操作均为异步Promise结构，通用逻辑为按异步顺序执行操作即可，核心步骤如下：

• 执行首次查询，拿到查询结果快照
• 从快照中提取后续操作需要的参数（文档ID、字段值、文档引用等）
• 用提取到的参数构造后续查询/写入的请求
• 执行后续操作，多操作场景可搭配批量写入或事务保证一致性

示例：先查询所有地址为上海市的订单，再给这些订单统一加上15元上门费：

import { getFirestore, collection, query, where, getDocs, writeBatch } from "firebase/firestore";
const db = getFirestore();

// 第一步：首次查询筛选目标订单
const orderQuery = query(collection(db, "orders"), where("address.city", "==", "上海市"));
const orderSnapshot = await getDocs(orderQuery);

// 第二步：用首次查询结果构造批量更新操作
const batch = writeBatch(db);
orderSnapshot.forEach(docSnap => {
  // 从快照中直接取文档引用，构造更新请求
  batch.update(docSnap.ref, {
    totalCost: docSnap.data().totalCost + 15,
    note: "已增加上海市上门费"
  });
});

// 第三步：执行批量写入
await batch.commit();

注意事项 #

• 超过1条写入操作优先用writeBatch批量处理，最多支持500条操作，可大幅提升性能
• 并发修改多、需要保证数据一致性的场景，用transaction事务处理
• 敏感数据的计算和写入尽量放在服务端/云函数执行，不要依赖前端计算结果

内容的提问来源于stack exchange，提问作者Надир Парилаев