MongoDB聚合入门求助：账户与日记账集合的会计核算实现

嘿，我来帮你一步步搞定MongoDB聚合在会计核算里的应用。基于你给出的accounts和journals集合结构，我整理了几个最常用的会计场景的聚合实现，每个都会详细拆解步骤，你跟着抄就行～

1. 查询带科目名称的完整日记账明细 #

这个需求是把日记账里的debit和credit对应的账户名称关联出来，方便查看每笔分录的具体科目。聚合管道如下：

db.journals.aggregate([
  // 关联借方科目名称
  {
    $lookup: {
      from: "accounts",
      localField: "debit",
      foreignField: "_id",
      as: "debit_account"
    }
  },
  // 关联贷方科目名称
  {
    $lookup: {
      from: "accounts",
      localField: "credit",
      foreignField: "_id",
      as: "credit_account"
    }
  },
  // 整理输出格式，把数组转成单个字段
  {
    $project: {
      _id: 1,
      debit_name: { $arrayElemAt: ["$debit_account.name", 0] },
      credit_name: { $arrayElemAt: ["$credit_account.name", 0] },
      amount: 1
    }
  }
])

步骤解释：

• 两次$lookup分别关联借方和贷方对应的accounts文档，结果会存在数组里（因为是一对一关联，数组只有一个元素）
• $project阶段用$arrayElemAt把数组里的唯一元素提取成单独的debit_name和credit_name字段，让结果更整洁易读

2. 计算所有科目的当前余额 #

会计里科目余额=借方累计发生额 - 贷方累计发生额（结果为正就是借方余额，负则为贷方余额）。这里需要先把每笔分录的金额分到借方和贷方科目，再汇总计算：

db.journals.aggregate([
  // 拆分红录：把每笔分录拆成借方和贷方两条记录，方便后续分组汇总
  {
    $facet: {
      debit_entries: [
        { $project: { account_id: "$debit", amount: "$amount" } }
      ],
      credit_entries: [
        { $project: { account_id: "$credit", amount: { $multiply: ["$amount", -1] } } }
      ]
    }
  },
  // 把借方和贷方记录合并成一个数组
  {
    $project: {
      all_entries: { $concatArrays: ["$debit_entries", "$credit_entries"] }
    }
  },
  // 展开合并后的数组
  { $unwind: "$all_entries" },
  // 按科目分组，汇总余额
  {
    $group: {
      _id: "$all_entries.account_id",
      balance: { $sum: "$all_entries.amount" }
    }
  },
  // 关联科目名称
  {
    $lookup: {
      from: "accounts",
      localField: "_id",
      foreignField: "_id",
      as: "account"
    }
  },
  // 整理最终输出格式
  {
    $project: {
      account_id: "$_id",
      account_name: { $arrayElemAt: ["$account.name", 0] },
      balance: 1,
      _id: 0
    }
  }
])

步骤解释：

• $facet用来并行处理借方和贷方记录：借方记录保留原金额，贷方记录把金额转成负数（因为贷方发生额会减少科目余额）
• $concatArrays把两类记录合并，$unwind展开成单条记录
• $group按科目ID汇总所有发生额，得到最终余额
• 最后用$lookup关联科目名称，再用$project整理成易读的格式

3. 生成试算平衡表（借方发生额、贷方发生额、余额） #

试算平衡表需要统计每个科目的借方累计发生额、贷方累计发生额，再计算余额，确保所有科目借方总和等于贷方总和：

db.journals.aggregate([
  // 用facet分别统计借方和贷方的发生额
  {
    $facet: {
      debit_totals: [
        {
          $group: {
            _id: "$debit",
            debit_amount: { $sum: "$amount" }
          }
        }
      ],
      credit_totals: [
        {
          $group: {
            _id: "$credit",
            credit_amount: { $sum: "$amount" }
          }
        }
      ]
    }
  },
  // 把两个统计结果合并
  {
    $project: {
      combined: { $concatArrays: ["$debit_totals", "$credit_totals"] }
    }
  },
  { $unwind: "$combined" },
  // 按科目ID分组，合并借方和贷方金额（没有的话用0填充）
  {
    $group: {
      _id: "$combined._id",
      total_debit: { $sum: { $ifNull: ["$combined.debit_amount", 0] } },
      total_credit: { $sum: { $ifNull: ["$combined.credit_amount", 0] } }
    }
  },
  // 计算余额
  {
    $project: {
      account_id: "$_id",
      total_debit: 1,
      total_credit: 1,
      balance: { $subtract: ["$total_debit", "$total_credit"] },
      _id: 0
    }
  },
  // 关联科目名称
  {
    $lookup: {
      from: "accounts",
      localField: "account_id",
      foreignField: "_id",
      as: "account"
    }
  },
  // 整理最终输出
  {
    $project: {
      account_name: { $arrayElemAt: ["$account.name", 0] },
      total_debit: 1,
      total_credit: 1,
      balance: 1,
      account_id: 1
    }
  },
  // 可选：添加总计行，验证试算平衡
  {
    $group: {
      _id: null,
      accounts: { $push: "$$ROOT" },
      total_debit_sum: { $sum: "$total_debit" },
      total_credit_sum: { $sum: "$total_credit" },
      total_balance_sum: { $sum: "$balance" }
    }
  },
  {
    $project: {
      accounts: 1,
      totals: {
        total_debit: "$total_debit_sum",
        total_credit: "$total_credit_sum",
        total_balance: "$total_balance_sum"
      },
      _id: 0
    }
  }
])

步骤解释：

• $facet分别统计每个科目的借方和贷方累计发生额
• 合并后按科目ID分组，用$ifNull处理没有借方或贷方发生额的科目（默认填充0）
• 计算余额后关联科目名称
• 最后用$group添加总计行，验证借方总和是否等于贷方总和（正常情况下total_balance应该为0）

如果你有其他特定的会计核算需求（比如按期间统计、往来账龄分析等），可以随时补充说明，我再帮你调整聚合管道～

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