如何为实现ITenantScoped接口的实体动态注册EF Core查询过滤器？

问题分析 #

你的代码报错是因为HasQueryFilter要求传入的表达式必须是对应实体具体类型的Expression<Func<TEntity, bool>>，而非接口ITenantScoped的表达式。EF Core无法直接将接口类型的表达式应用到具体实体上，必须做表达式树的类型转换。

解决方案 #

通过构建动态表达式树，将针对ITenantScoped的过滤器表达式转换为对应实体类型的表达式。以下是完整可运行的实现：

1. 编写表达式转换工具方法

这个方法负责将接口类型的表达式，转换为指定实体类型的表达式：

private static Expression<Func<TEntity, bool>> ConvertFilterExpression<TEntity>(Expression<Func<ITenantScoped, bool>> baseFilter)
    where TEntity : class, ITenantScoped
{
    // 创建实体类型的参数表达式
    var parameter = Expression.Parameter(typeof(TEntity), "e");
    // 将原表达式的参数替换为实体类型的参数
    var body = Expression.Invoke(baseFilter, parameter);
    // 构建新的表达式
    return Expression.Lambda<Func<TEntity, bool>>(body, parameter);
}

2. 修改OnModelCreating方法

遍历所有实现ITenantScoped的实体，动态转换并注册过滤器：

protected override void OnModelCreating(ModelBuilder modelBuilder)
{
    // 只处理实现了ITenantScoped的实体（排除抽象类）
    var tenantScopedEntities = modelBuilder.Model.GetEntityTypes()
        .Where(t => typeof(ITenantScoped).IsAssignableFrom(t.ClrType) && !t.ClrType.IsAbstract);

    // 定义基础过滤器（针对接口）
    Expression<Func<ITenantScoped, bool>> baseFilter = 
        e => contextAccessor.Get<ITenantContext>().CanAccessTenant(e.TenantId);

    foreach (var entityType in tenantScopedEntities)
    {
        // 通过反射调用泛型版的转换方法
        var convertMethod = typeof(YourDbContext)
            .GetMethod(nameof(ConvertFilterExpression), BindingFlags.NonPublic | BindingFlags.Static)
            .MakeGenericMethod(entityType.ClrType);
        
        var entityFilter = convertMethod.Invoke(null, new object[] { baseFilter }) as LambdaExpression;

        // 注册查询过滤器
        modelBuilder.Entity(entityType.ClrType).HasQueryFilter(entityFilter);
    }
}

关键说明 #

• 表达式转换逻辑：通过Expression.Invoke将原接口参数替换为实体类型参数，生成符合要求的表达式树，EF Core能正确解析这个表达式并转换为SQL（或在内存中执行权限校验）。
• 保留AsyncLocal调用：contextAccessor.Get<ITenantContext>()仍在Lambda表达式内部，确保每次查询执行时都会获取当前上下文的租户信息，不会提前固化值。
• 权限校验触发：如果CanAccessTenant方法在无权限时抛出异常，EF Core在执行查询、加载实体时会触发这个校验，直接抛出异常阻断访问。

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