你在谈论访问以及访问期间发生的事情,所以它似乎是一个重要的领域概念.
我想你也会有一个DayCareCenter,所有关心的孩子都在这里注册.

所以我会选择这个聚合根：

> DayCareCenter
>孩子
>参观

顺便说一句：我看到另一个不变量：
“孩子不能同时在多个日托中心”

“多次点击’登录’按钮”

如果每个命令都有一个唯一的id,它是为每次有意的尝试生成的 – 不是每次点击都产生的(无意的),你可以缓冲最后n个收到的命令id并忽略重复.

或者您的消息传递基础设施(服务总线)可以为您处理.

创建访问

由于您使用多个聚合,因此必须查询一些(可靠,一致)存储以查明是否满足不变量.
(或者如果很少发生冲突并且手动“取消”无效访问是合理的,那么最终一致的读取模型也会起作用……)

由于儿童只能进行一次当前访问,因此儿童只会存储关于上次开始访问的一些信息(事件).

每当开始新的访问时,都会查询任何先前访问的“真实来源”(写模型)并检查访问是否结束.

(另一个选择是访问只能通过Child聚合结束,再次存储一个“结束” – 在Child中的事件,但这对我来说感觉不太好……但这只是个人观点)

查询(验证)部分可以通过特殊服务完成,或者只是将存储库传递给方法并直接在那里查询 – 这次我使用第二个选项.

这是一些C#-ish脑编译的伪代码来表达我认为你可以处理它的方式：

public class DayCareCenterId
{
    public string Value { get; set; }
}
public class DayCareCenter
{
    public DayCareCenter(DayCareCenterId id,string name)
    {
        RaiseEvent(new DayCareCenterCreated(id,name));
    }
    private void Apply(DayCareCenterCreated @event)
    {
        //...
    }
}
 
public class VisitId
{
    public string Value { get; set; }
}
public class Visit
{
    public Visit(VisitId id,ChildId childId,DateTime start)
    {
        RaiseEvent(new VisitCreated(id,childId,start));
    }
    private void Apply(VisitCreated @event)
    {
        //...
    }
 
    public void EndVisit()
    {
        RaiseEvent(new VisitEnded(id));
    }
    private void Apply(VisitEnded @event)
    {
        //...
    }
}
 
public class ChildId
{
    public string Value { get; set; }
}
public class Child
{
    VisitId lastVisitId = null;
 
    public Child(ChildId id,string name)
    {
        RaiseEvent(new ChildCreated(id,name));
    }
    private void Apply(ChildCreated @event)
    {
        //...
    }
 
    public Visit VisitsDayCareCenter(DayCareCenterId centerId,IEventStore eventStore)
    {
        // check if child is stille visiting somewhere
        if (lastVisitId != null)
        {
            // query write-side (is more reliable than eventual consistent read-model)
            // ...but if you like pass in the read-model-repository for querying
            if (eventStore.OpenEventStream(lastVisitId.Value)
                .Events()
                .Any(x => x is VisitEnded) == false)
                throw new BusinessException("There is already an ongoning visit!");
        }
 
        // no pending visit
        var visitId = VisitId.Generate();
        var visit = new Visit(visitId,this.id,DateTime.UtcNow);
 
        RaiseEvent(ChildVisitedDayCenter(id,centerId,visitId));
 
        return visit;
    }
    private void Apply(ChildVisitedDayCenter @event)
    {
        lastVisitId = @event.VisitId;
    }
}
 
public class CommandHandler : Handles<ChildVisitsDayCareCenter>
{
    // http://csharptest.net/1279/introducing-the-lurchtable-as-a-c-version-of-linkedhashmap/
    private static readonly LurchTable<string,int> lastKnownCommandIds = new LurchTable<string,bool>(LurchTableOrder.Access,1024);
 
    public CommandHandler(IWriteSideRepository writeSideRepository,IEventStore eventStore)
    {
        this.writeSideRepository = writeSideRepository;
        this.eventStore = eventStore;
    }
 
    public void Handle(ChildVisitsDayCareCenter command)
    {
        #region example command douplicates detection
 
        if (lastKnownCommandIds.ContainsKey(command.CommandId))
            return; // already handled
        lastKnownCommandIds[command.CommandId] = true;
 
        #endregion
 
        // OK,now actual logic
 
        Child child = writeSideRepository.GetByAggregateId<Child>(command.AggregateId);
 
        // ... validate day-care-center-id ...
        // query write-side or read-side for that
 
        // create a visit via the factory-method
        var visit = child.VisitsDayCareCenter(command.DayCareCenterId,eventStore);
        writeSideRepository.Save(visit);
        writeSideRepository.Save(child);
    }
}

备注：

> RaiseEvent(…)立即在场景后面调用Apply(…)
> writeSideRepository.Save(…)实际上保存了事件
> LurchTable用作固定大小的MRU命令列表
>如果您感兴趣,可以为它提供服务,而不是传递整个事件存储

免责声明：我不是知名专家.这就是我接近它的方式.在这个答案中可能会损害一些模式.