CQRS + ES - 在哪里查询业务逻辑所需的数据？

Question

我正在使用 CQRS + ES，但我遇到了一个无法找到解决方案的建模问题。
您可以跳过以下内容并回答标题中的通用问题：您将在哪里查询业务逻辑所需的数据？
抱歉，原来这是一个复杂的问题，我的想法现在很扭曲！！！
问题出在：
我的用户是团队成员。这是多对多的关系。每个用户都有每个团队的可用性状态。
团队收到票，每张票都有一定的负载系数，应该根据他们的可用性和总负载分配给团队的一名成员。
第一个问题，我需要查询团队中可用的用户列表，并选择负载最少的用户，因为他有资格分配。（请注意，这是其中一种情况，它可能是运行不同的查询）
第二个问题，票的负载因子可能会改变，所以我在计算时必须考虑到这一点每个用户的总负载。请注意，虽然工单可以属于 1 个团队，但分配应基于用户的总负载，而不是每个团队的负载。
目前，此有界上下文接收到 TicketReceivedEvent，我应该触发工作流将该票分配给用户。
可能的解决方案：

1. 最简单的方法是将事件排队并顺序发送命令 AssignTicketToUser 并让服务查询用户 ID 的读取模型，获取用户和 user.assignTicket(Ticket)。一旦收到 TicketAssignedEvent，就发送下一个分配命令。但是从命令处理程序中查询读取模型似乎是一个危险信号！并且很麻烦地排队购买所有这些门票！
2. 为每个用户分配一个流程经理，并将其可用性/团队和分配给该用户的工单。在这种情况下，我们将查询替换为“进程管理器查找”查询，命令处理程序将调用 Ticket.AssignTo(User)。缺点是我认为太多业务逻辑泄漏到域模型之外，特别是我们从用户聚合中提取所有信息/模型以使其可用于查询

我倾向于使用第一个解决方案，它似乎更易于维护、修改/扩展和在代码中定位，但也许我缺少一些东西。

Answer 1

始终（嗯，99.99% 的情况）在业务/域层，即在 CQRS 的“命令”部分。这意味着您的存储库应该具有用于​​特定查询的方法，并且您的持久性模型应该足够“可查询”以达到此目的。这意味着在决定如何实现持久性之前，您必须更多地了解您的域的用例。

使用文档数据库（mongodb、raven db 或 postgres）可能会使工作更轻松。如果您坚持使用 rdbms 或键值存储，请创建查询表，即写入模型的读取模型，充当索引:)（这假设您正在序列化对象）。如果您要存储与每种实体类型的特定表架构相关的内容（巨大的开销，您的生活会变得复杂），那么信息很容易自动查询。

Answer 2

为什么不能查询所涉及的聚合？

我冒昧地重写了目标：

将团队票分配给总负载最低的用户。

这里有一个Ticket，它应该能够计算标准负载因子，一个Team，它知道它的用户，还有一个User，它知道它的总负载并可以接受新票：

更新：如果将存储库传递给聚合不合适，可以将其包装在服务中，在本例中为定位器。这样做可以更轻松地强制一次只更新一个聚合。

public void AssignTicketToUser(int teamId, int ticketId)
{
    var ticket = repository.Get<Ticket>(ticketId);
    var team = repository.Get<Team>(teamId);
    var users = new UserLocator(repository);
    var tickets = new TicketLocator(repository);
    var user = team.GetUserWithLowestLoad(users, tickets);

    user.AssignTicket(ticket);

    repository.Save(user);
}

我们的想法是 User 是我们更新的唯一聚合。

Team 会知道它的用户：

public User GetGetUserWithLowestLoad(ILocateUsers users, ILocateTickets tickets)
{
    User lowest = null;

    foreach(var id in userIds)
    {
        var user = users.GetById(id);
        if(user.IsLoadedLowerThan(lowest, tickets))
        {
            lowest = user;
        }
    }
    return lowest;
}

更新：由于工单可能会随时间改变负载，User 需要计算其当前负载。

public bool IsLoadedLowerThan(User other, ILocateTickets tickets)
{
    var load = CalculateLoad(tickets);
    var otherLoad = other.CalculateLoad(tickets);

    return load < otherLoad;
}

public int CalculateLoad(ILocateTickets tickets)
{
    return assignedTicketIds
        .Select(id => tickets.GetById(id))
        .Sum(ticket.CalculateLoad());
}

User 然后接受票证：

public void AssignTicket(Ticket ticket)
{
    if(ticketIds.Contains(ticket.Id)) return;

    Publish(new TicketAssignedToUser
        {
            UserId = id,
            Ticket = new TicketLoad
                {
                    Id = ticket.Id,
                    Load = ticket.CalculateLoad() 
                }
        });
}

public void When(TicketAssignedToUser e)
{
    ticketIds.Add(e.Ticket.Id);
    totalLoad += e.Ticket.Load;
}

我会使用流程管理器/传奇来更新任何其他聚合。

Answer 3

您可以在应用服务中查询您需要的数据。这似乎与您的第一个解决方案相似。

通常，您会交叉引用您的聚合，所以我不太确定第一个问题来自哪里。每个用户都应该有一个它所属的团队列表，每个组都有一个用户列表。您可以使用所需的任何属性来补充此数据，例如可用性。因此，当您阅读聚合时，您可以直接获得数据。当然，你会有很多数据重复，但这很常见。

在事件溯源模型中，域存储库永远无法提供任何查询能力。 Yves Reynhout 的 AggregateSource 是一个很好的参考，这里是 IRepository interface。您可以很容易地看到这个界面中没有任何“查询”方法。

还有一个类似的问题Domain queries in CQRS