Mongoose店铺利润存储与查询的Schema设计选型咨询

我需要在店铺仪表盘展示日/周/月/年度总利润，希望每个店铺的统计数据存储在单个文档的数组中，避免同一店铺因不同日期生成多份文档。目前在两种方案间纠结：

• 方案1：采用独立的利润集合：考虑到场景是读密集且需频繁更新，同时涉及多店铺访问，但每次支付成功后，需要先后在profits和invoices两个集合中完成更新与计算。
• 方案2：基于现有invoiceModel做聚合查询：所有统计数据都在发票集合里，只需通过聚合操作获取，但这样发票集合既要存储支付/发票数据，又要承担统计查询的职责，且聚合操作开销大，尤其是批量查询所有店铺数据时。

我最关注性能问题，请问哪种方案更优？如果推荐第一种方案，有没有Schema设计建议？

附当前invoiceModel代码：

import { Schema, model } from "mongoose";

const invoiceSchema = new Schema({
    purchaseId: {
        type:Number,
        required: [true, "the purchaseId field is required"],
        unique: true,
        default: crypto.randomUUID(), 
    },
    buyer: {
        type: Schema.Types.ObjectId,
        ref: "User",
        required: [true, "the buyer field is required"]
    },
    products:[{
        type: Schema.Types.ObjectId,
        ref: "Product",
        required: [true, "the products field is required"]
    }],
    total: {
        type: Number,
        required: [true, "the total field is required"]
    },
    paymentMethod: {},
    purchasedAt: {
        type: Date, // 原代码笔误：应为Date而非Data
        default: Date.now(),
        required: [true, "the purchasedAt field is required"]
    },
    status: {
        type: String,
        required: [true, "the field is required"],
        enum: ["successful", "cancelled"] 
    },
    notes: {
        type: String,
        trim: true,
    }

});

invoiceSchema.index({user: 1}); // 注意：Schema中未定义user字段，推测应为buyer

const Invoice = model("Invoice", invoiceSchema);

export default Invoice;

优先选择方案1：独立利润集合，核心原因如下：

1. 读性能碾压聚合查询：仪表盘属于高频读场景，直接读取预计算的利润数据，响应速度比每次全量聚合发票数据快数倍，数据量达到万级以上时，聚合延迟会非常明显。
2. 避免职责过载：发票集合专注存储交易原始数据，利润集合专注存储统计结果，符合单一职责原则，后续维护、扩展更清晰。
3. 多店铺批量查询更高效：若需同时展示多个店铺统计数据，直接从利润集合批量查询比逐个店铺执行聚合的效率高得多。

利润集合Schema设计建议 #

针对“每个店铺一个文档，统计数据按周期存数组”的需求，设计如下：

import { Schema, model } from "mongoose";

// 周期统计子文档Schema
const periodProfitSchema = new Schema({
    periodType: {
        type: String,
        enum: ["day", "week", "month", "year"],
        required: true
    },
    periodKey: {
        type: String,
        required: true, // 格式示例：day用"2024-05-20"，week用"2024-W21"，month用"2024-05"，year用"2024"
        index: true
    },
    totalProfit: {
        type: Number,
        default: 0,
        required: true
    },
    updatedAt: {
        type: Date,
        default: Date.now
    }
});

const profitSchema = new Schema({
    shopId: {
        type: Schema.Types.ObjectId,
        ref: "Shop",
        required: true,
        unique: true // 确保每个店铺仅对应一个文档
    },
    profitStats: [periodProfitSchema],
    createdAt: {
        type: Date,
        default: Date.now
    }
});

// 建立复合索引，加速按店铺+周期类型+周期Key的精准查询
profitSchema.index({ shopId: 1, "profitStats.periodType": 1, "profitStats.periodKey": 1 });

const Profit = model("Profit", profitSchema);

export default Profit;

支付成功后的更新逻辑 #

生成发票后，需原子性更新利润集合（利用MongoDB的findOneAndUpdate或bulkWrite配合数组操作符），示例流程：

1. 根据交易数据计算单笔利润（比如invoice.total减去商品成本，按业务逻辑调整）
2. 针对日/周/月/年四个周期，生成对应的periodKey
3. 用$inc更新对应周期的利润值，用$setOnInsert处理店铺首次统计的情况

示例代码片段：

// 假设已获取当前店铺ID、单笔利润、交易日期
const shopId = "xxx";
const profitAmount = invoice.total - calculateProductCost(invoice.products);
const purchasedDate = new Date(invoice.purchasedAt);

// 生成各周期的唯一标识key
const periodKeys = {
    day: purchasedDate.toISOString().split('T')[0],
    week: `${purchasedDate.getFullYear()}-W${Math.ceil((purchasedDate.getDate() + purchasedDate.getDay()) / 7)}`,
    month: `${purchasedDate.getFullYear()}-${String(purchasedDate.getMonth() + 1).padStart(2, '0')}`,
    year: `${purchasedDate.getFullYear()}`
};

// 构建批量更新操作：先尝试更新已有周期，不存在则插入
const updateOps = Object.entries(periodKeys).map(([type, key]) => ({
    updateOne: {
        filter: { shopId, "profitStats.periodType": type, "profitStats.periodKey": key },
        update: {
            $inc: { "profitStats.$.totalProfit": profitAmount },
            $set: { "profitStats.$.updatedAt": new Date() }
        },
        upsert: false
    }
})).concat([{
    updateOne: {
        filter: { shopId },
        update: {
            $push: {
                profitStats: Object.entries(periodKeys).map(([type, key]) => ({
                    periodType: type,
                    periodKey: key,
                    totalProfit: profitAmount,
                    updatedAt: new Date()
                }))
            }
        },
        upsert: true // 店铺文档不存在则创建
    }
}]);

// 执行批量更新
await Profit.bulkWrite(updateOps);

额外优化点 #

• 事务保障：若MongoDB版本支持事务（副本集/分片集群），将发票插入与利润更新放在同一事务中，避免数据不一致。
• 错误重试：支付回调时若利润更新失败，添加重试机制（比如基于队列的重试），确保统计数据准确。
• 发票集合补全：原发票Schema缺少shopId字段，需补充并建立索引，方便后续补统计数据时的高效查询。

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