EF Core 5中StockDetail无Product导航属性时如何获取Product表Rate写入

核心思路 #

因为要求StockDetail实体不能添加Product相关的导航属性，所以无法通过EF Core的导航属性自动关联查询取值，我们可以通过重写DbContext的SaveChanges/SaveChangesAsync方法，在数据提交到数据库前拦截新增的StockDetail实体，批量查询对应Product的Rate字段完成自动赋值，该方案对业务代码侵入性极低，完全符合需求约束。

具体实现步骤 #

1. 重写DbContext的保存方法 #

在你项目的自定义DbContext类中添加如下代码，逻辑会自动拦截所有新增的StockDetail数据，批量查询Product的Rate完成赋值：

public class YourDbContext : DbContext
{
    // 你的原有DbSet定义
    public DbSet<Product> Products { get; set; }
    public DbSet<StockHeader> StockHeaders { get; set; }
    public DbSet<StockDetail> StockDetails { get; set; }

    // 重写同步保存方法
    public override int SaveChanges()
    {
        PopulateStockDetailRate();
        return base.SaveChanges();
    }

    // 重写异步保存方法
    public override Task<int> SaveChangesAsync(CancellationToken cancellationToken = default)
    {
        PopulateStockDetailRate();
        return base.SaveChangesAsync(cancellationToken);
    }

    // 自动填充Rate的核心逻辑
    private void PopulateStockDetailRate()
    {
        // 提取所有状态为新增的StockDetail实体
        var addedDetails = ChangeTracker.Entries<StockDetail>()
            .Where(entry => entry.State == EntityState.Added)
            .ToList();

        if (!addedDetails.Any()) return;

        // 提取所有需要查询的ProductId去重，避免N+1查询
        var productIds = addedDetails.Select(d => d.Entity.ProductId).Distinct().ToList();

        // 批量查询Product的Id和Rate，存入字典
        var productRateMap = Set<Product>()
            .Where(p => productIds.Contains(p.Id))
            .ToDictionary(p => p.Id, p => p.Rate);

        // 遍历给每个新增的StockDetail赋值Rate
        foreach (var detailEntry in addedDetails)
        {
            if (productRateMap.TryGetValue(detailEntry.Entity.ProductId, out var rate))
            {
                detailEntry.Entity.Rate = rate;
            }
            else
            {
                // 可根据业务需求抛出异常或者设置默认值
                throw new InvalidOperationException($"传入的ProductId:{detailEntry.Entity.ProductId}不存在，无法获取商品单价");
            }
        }
    }

    // 你的原有其他DbContext逻辑，比如OnConfiguring、OnModelCreating等
}

2. 确认实体定义符合约束 #

你的StockDetail实体不需要做任何修改，不需要添加Product相关的引用属性，保持原有定义即可：

public class StockDetail
{
    public int Id { get; set; }
    public int HdrId { get; set; }
    public int ProductId { get; set; }
    public decimal Rate { get; set; }
    // 不需要添加public Product Product { get; set; }，完全符合需求约束
}

3. 接口调用验证 #

你在HttpPost新增StockDetail的接口中，只需要传入HdrId、ProductId字段即可，不需要手动给Rate赋值，调用SaveChanges的时候会自动完成Rate字段的填充，不需要修改原有业务接口的代码。

可选优化方案 #

如果你需要和DbContext解耦，也可以使用EF Core的SaveChangesInterceptor拦截器实现，把Rate填充的逻辑放到单独的拦截器类中注册即可，核心逻辑和上面的PopulateStockDetailRate方法完全一致。

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