ASP.NET Core Web应用如何向DbContext传参实现基于登录用户的全局数据过滤

EF Core的全局查询过滤器支持引用DbContext的实例成员，每次查询时会自动读取当前DbContext实例的对应值，配合ASP.NET Core的Scoped生命周期服务，就能实现基于当前登录用户的动态过滤，具体实现步骤如下：

第一步：注册HTTP上下文访问服务 #

首先需要在Program.cs中注册IHttpContextAccessor，用于获取当前请求的登录用户信息：

builder.Services.AddHttpContextAccessor();

第二步：改造DbContext实现动态过滤 #

方案1：直接注入IHttpContextAccessor到DbContext #

修改你的DbContext类，新增实例字段存储当前用户的分支ID，构造函数中完成赋值，在全局过滤器中直接引用该字段即可：

public class YourDbContext : DbContext
{
    // 存储当前登录用户的分支ID，每个请求的DbContext实例对应唯一值
    private readonly int? _currentUserBranchId;

    // 构造函数注入IHttpContextAccessor
    public YourDbContext(DbContextOptions<YourDbContext> options, IHttpContextAccessor httpContextAccessor)
        : base(options)
    {
        var httpContext = httpContextAccessor.HttpContext;
        // 仅已登录用户才赋值分支ID
        if (httpContext?.User.Identity?.IsAuthenticated == true)
        {
            // 以下两种取值方式二选一：
            // 方式1：登录时已将BranchID存入用户Claims，直接读取（性能最优，无需额外查库）
            var branchIdClaim = httpContext.User.Claims.FirstOrDefault(c => c.Type == "BranchId");
            if (int.TryParse(branchIdClaim?.Value, out var branchId))
            {
                _currentUserBranchId = branchId;
            }

            // 方式2：根据用户名查用户表获取对应的分支ID
            // var userName = httpContext.User.Identity.Name;
            // _currentUserBranchId = 你的用户服务.GetBranchIdByUserName(userName);
        }
    }

    protected override void OnModelCreating(ModelBuilder modelBuilder)
    {
        // 全局过滤器直接引用实例字段即可，EF会在每次查询时动态取值
        modelBuilder.Entity<Branch>().HasQueryFilter(b => b.BranchID == _currentUserBranchId);
        // 其他关联BranchID的表也可以同步加过滤规则
        // modelBuilder.Entity<Order>().HasQueryFilter(o => o.BranchID == _currentUserBranchId);
    }

    // 你的DbSet定义
    public DbSet<Branch> Branches { get; set; }
}

方案2：封装用户服务（分层更清晰） #

如果不想把HTTP相关逻辑耦合到DbContext中，可以单独封装当前用户服务：

1. 定义服务接口与实现

public interface ICurrentUserService
{
    int? GetCurrentBranchId();
}

public class CurrentUserService : ICurrentUserService
{
    private readonly IHttpContextAccessor _httpContextAccessor;
    // 可注入你的用户仓储等依赖

    public CurrentUserService(IHttpContextAccessor httpContextAccessor)
    {
        _httpContextAccessor = httpContextAccessor;
    }

    public int? GetCurrentBranchId()
    {
        var user = _httpContextAccessor.HttpContext?.User;
        if (user?.Identity?.IsAuthenticated != true) return null;
        // 这里写获取用户分支ID的逻辑，比如从Claims取或者查库
        var branchIdClaim = user.Claims.FirstOrDefault(c => c.Type == "BranchId");
        return int.TryParse(branchIdClaim?.Value, out var bid) ? bid : null;
    }
}

2. 在Program.cs注册服务

builder.Services.AddScoped<ICurrentUserService, CurrentUserService>();

3. DbContext注入该服务即可

public YourDbContext(DbContextOptions<YourDbContext> options, ICurrentUserService currentUserService)
    : base(options)
{
    _currentUserBranchId = currentUserService.GetCurrentBranchId();
}

补充说明 #

• 未登录场景下_currentUserBranchId为null，此时过滤条件会匹配BranchID为null的记录，你可以根据业务需求调整默认值，比如未登录时抛出权限异常，或者允许查看全部数据。
• 如果管理员需要绕过过滤查看全部分支数据，查询时调用IgnoreQueryFilters()即可：

var allBranches = dbContext.Branches.IgnoreQueryFilters().ToList();

内容的提问来源于stack exchange，提问作者Colin-G-Davidson