MassTransit关联Saga中导航属性失效问题求助

我正在开发一个通用批处理组件，参考了Chris Pattersons的Batch示例。目前遇到问题：BatchState和BatchJobState的导航属性无法正常工作——在BatchStateMachine中处理BatchJobDone事件时，需要判断该任务是否为最后一个BatchJob，但BatchJobState的Batch属性始终为null，BatchState的Jobs属性始终显示Count = 0。

实体定义 #

public class BatchState : SagaStateMachineInstance
{
    // 其他属性...
    
    // 导航属性
    public List<BatchJobState> Jobs { get; set; } = new List<BatchJobState>();
    public Guid CorrelationId { get; set; }
}

public class BatchJobState : SagaStateMachineInstance
{
    // 其他属性...

    // 导航属性
    public BatchState Batch { get; set; }
    public Guid CorrelationId { get; set; }
    // 需要添加外键字段
    public Guid BatchId { get; set; }
}

现有实体配置代码 #

class BatchStateEntityConfiguration : IEntityTypeConfiguration<BatchState>
{
    public void Configure(EntityTypeBuilder<BatchState> builder)
    {
        builder.HasKey(c => c.CorrelationId);

        builder.Property(c => c.CorrelationId)
            .ValueGeneratedNever()
            .HasColumnName("BatchId");

        builder.Property(c => c.CurrentState).IsRequired();

        builder.Property(c => c.Action)
            .HasConversion(new EnumToStringConverter<BatchAction>());

        builder.Property(c => c.UnprocessedOrderIds)
            .HasConversion(new JsonValueConverter<Stack<Guid>>())
            .Metadata.SetValueComparer(new JsonValueComparer<Stack<Guid>>());

        builder.Property(c => c.ProcessingOrderIds)
            .HasConversion(new JsonValueConverter<Dictionary<Guid, Guid>>())
            .Metadata.SetValueComparer(new JsonValueComparer<Dictionary<Guid, Guid>>());
    }
}

class JobStateEntityConfiguration : IEntityTypeConfiguration<BatchJobState>
{
    public void Configure(EntityTypeBuilder<BatchJobState> builder)
    {
        builder.HasKey(c => c.CorrelationId);

        builder.Property(c => c.CorrelationId)
            .ValueGeneratedNever()
            .HasColumnName("BatchJobId");

        builder.Property(c => c.CurrentState).IsRequired();

        builder.Property(c => c.Action)
            .HasConversion(new EnumToStringConverter<BatchAction>());
    }
}

问题原因及解决方法 #

导航属性失效的核心原因是EF Core未配置实体间的关联关系，且缺少必要的外键字段：

1. 添加外键字段：在BatchJobState中新增BatchId字段，用于关联对应的BatchState（对应BatchState的CorrelationId，数据库列名为BatchId）。

2. 配置EF Core关联关系：

   • 在BatchStateEntityConfiguration中添加一对多关系配置：

     builder.HasMany(b => b.Jobs)
            .WithOne(j => j.Batch)
            .HasForeignKey(j => j.BatchId)
            .OnDelete(DeleteBehavior.Cascade); // 根据业务需求设置删除行为
     

   • 在JobStateEntityConfiguration中添加多对一关系配置：

     builder.Property(j => j.BatchId)
            .IsRequired(); // 若BatchJob必须属于某个Batch，设置为必填
     
     builder.HasOne(j => j.Batch)
            .WithMany(b => b.Jobs)
            .HasForeignKey(j => j.BatchId);
     

3. 确保Saga实例保存时设置外键：创建BatchJobState实例时，必须将BatchId赋值为对应BatchState的CorrelationId，这样EF Core才能正确关联两个实体，导航属性才会被填充。

完成以上修改后，EF Core就能正确识别实体间的关联关系，导航属性Batch和Jobs就能正常加载数据。

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