在DDD与CQRS架构中如何用子实体列表初始化聚合根

我正在构建采用DDD（领域驱动设计）与CQRS（命令查询职责分离）架构的应用，其中Budget为聚合根，BudgetedTransaction为子实体，Budget维护着BudgetedTransaction的列表，数据库中两者是一对多关系。

我的Budget类代码如下：

public class Budget : Entity, IAggregateRoot
{
    private readonly List<BudgetedTransaction> _budgetedTransactions;

    private Budget() { } //ef core

    public Budget(List<BudgetedTransaction> budgetedTransactions)
    {
        _budgetedTransactions = budgetedTransactions;
    }
}

我希望采用读写仓库分离的CQRS模式，用Dapper处理读操作，EF（Entity Framework）处理写操作。但我困惑于如何为写操作检索并初始化Budget聚合根，比如在实现添加新交易功能时。以下是命令处理器中的Handle方法代码：

public async Task<Guid> Handle(AddBudgetedTransactionCommand command, CancellationToken cancellationToken)
{
    var budgetWithTransactionsDto = await _budgetRepositoryRead.GetBudgetById(command.AddBudgetedTransactionRequest.BudgetId);

    var transactions = budgetWithTransactionsDto.BudgetedTransactions.ToList();

    var budget = new Budget(?);

    var transaction = new BudgetedTransaction(command.AddBudgetedTransactionRequest.BudgetId,
    command.AddBudgetedTransactionRequest.BudgetingCategoryId,
    command.AddBudgetedTransactionRequest.TransactionType,        
    command.AddBudgetedTransactionRequest.TransactionOccurrences,
    command.AddBudgetedTransactionRequest.StartDate,
    command.AddBudgetedTransactionRequest.Amount);

    budget.AddBudgetedTransaction(transaction);

    await _budgetRepositoryWrite.UnitOfWork.SaveEntitiesAsync(cancellationToken);

    budget.AddDomainEvent(new BudgetedTransactionAdded(transaction));
 
    return transaction.Id;
}

Budget类新增的方法：

public void AddBudgetedTransaction(BudgetedTransaction transaction)
{
    _budgetedTransactions.Add(transaction);
}

我不清楚如何在不使用EF读操作的前提下，将DTO列表转换为实体列表来初始化Budget。我猜测Dapper仅适用于API返回数据的读操作，写仓库需兼顾读写（用EF）来读取实体修改，这种理解是否正确？有没有更优方案？

核心理解纠正 #

你的猜测不完全准确：Dapper并非只能用于API读操作，但写侧绝对不能用读侧的DTO来初始化聚合根——CQRS的读写分离是指查询和命令的职责分离，但写侧必须操作完整的、由EF跟踪的聚合根实体，原因有两点：

1. EF需要跟踪实体的状态变化，这是后续SaveChanges能正确更新数据的基础；如果用Dapper加载DTO再转成实体，EF会把它当成新实体插入，导致数据重复或错误。
2. 聚合根的完整性由领域模型保证，从DTO转换实体可能跳过领域规则校验，破坏DDD的封装性。

正确实现方式 #

1. 写侧仓储用EF加载完整聚合根
   命令处理器中直接通过写侧仓储（EF实现）加载Budget聚合根，而非读侧的Dapper DTO：

   public async Task<Guid> Handle(AddBudgetedTransactionCommand command, CancellationToken cancellationToken)
   {
       // 用写侧仓储加载聚合根，EF自动跟踪状态
       var budget = await _budgetRepositoryWrite.GetByIdAsync(command.AddBudgetedTransactionRequest.BudgetId, cancellationToken);
   
       var transaction = new BudgetedTransaction(
           command.AddBudgetedTransactionRequest.BudgetId,
           command.AddBudgetedTransactionRequest.BudgetingCategoryId,
           command.AddBudgetedTransactionRequest.TransactionType,        
           command.AddBudgetedTransactionRequest.TransactionOccurrences,
           command.AddBudgetedTransactionRequest.StartDate,
           command.AddBudgetedTransactionRequest.Amount);
   
       budget.AddBudgetedTransaction(transaction);
       // 领域事件应在状态变更后立即添加，保证原子性
       budget.AddDomainEvent(new BudgetedTransactionAdded(transaction));
   
       await _budgetRepositoryWrite.UnitOfWork.SaveEntitiesAsync(cancellationToken);
   
       return transaction.Id;
   }
   

   对应的写侧仓储EF实现：

   public class BudgetRepositoryWrite : IBudgetRepositoryWrite
   {
       private readonly AppDbContext _dbContext;
   
       public BudgetRepositoryWrite(AppDbContext dbContext)
       {
           _dbContext = dbContext;
       }
   
       public async Task<Budget> GetByIdAsync(Guid budgetId, CancellationToken cancellationToken)
       {
           // 加载聚合根时包含子实体，确保聚合完整
           return await _dbContext.Budgets
               .Include(b => b.BudgetedTransactions)
               .FirstOrDefaultAsync(b => b.Id == budgetId, cancellationToken);
       }
   
       // 其他写操作方法...
   }
   

2. 为什么不能用Dapper转实体？

   • 从DTO转换BudgetedTransaction实体时，无法保证实体构造符合领域规则（比如私有构造函数、必填参数校验等）。
   • EF无法识别手动创建的实体是数据库中已存在的记录，执行SaveChanges时会尝试插入新的Budget，而非更新现有数据。

3. 优化建议

   • 严格划分读写边界：读侧（Dapper）只负责查询DTO供API返回，写侧（EF）只负责操作聚合根、维护领域模型完整性。
   • 封装聚合根构造逻辑：可以给Budget添加静态工厂方法，新聚合根通过工厂方法创建，数据库加载的聚合根用EF的私有构造函数，避免外部直接操作子实体列表。
   • 领域事件与状态变更绑定：修改聚合根状态后立即添加领域事件，再执行保存，确保事件和状态变更的原子性。

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