在前面的文章里使用.NET 6開發(fā)TodoList應用之領域實體創(chuàng)建原理和思路，我們留了一個坑還沒有填上，就是在數據庫保存的時候，CreateUser和ModifiedUser我們當時填的都是Anonymous，完成認證的功能后，現(xiàn)在我們需要實現(xiàn)在保存數據庫的時候填入當前登陸進行操作的用戶名。

目標

實現(xiàn)當前登陸用戶信息獲取。

原理和思路

原理很簡單，在認證時拿到的Token里，payload中是包含登陸User的部分信息的，作為演示，我們需要想辦法獲取到用戶名信息，并在保存數據時填入相應字段。為了獲取Token中包含的用戶信息，需要用到HttpContextAccessor對象。很顯然，需要一個新的接口和實現(xiàn)。

實現(xiàn)

創(chuàng)建當前用戶獲取接口

在Application/Common/Interfaces中添加一個新的接口：

ICurrentUserService.cs

namespace TodoList.Application.Common.Interfaces;

public interface ICurrentUserService
{
    string? UserName { get; }
}

這里我們取的是UserName，是因為在返回的Token中包含UserName的信息，如果需要使用UserId或其他信息，需要在GetClaims中添加：

// 演示了返回用戶名和Role兩個claims
var claims = new List<Claim>
{
    // Claims中包含UserName信息
    new(ClaimTypes.Name, User!.UserName),
    new(JwtRegisteredClaimNames.Iss, _jwtConfiguration.ValidIssuer ?? "TodoListApi"),
    new(JwtRegisteredClaimNames.Aud, _jwtConfiguration.ValidAudience ?? "http://localhost:5050")
};

實現(xiàn)接口功能

在Api/Services中添加類實現(xiàn)接口：

CurrentUserService.cs

using System.Security.Claims;
using TodoList.Application.Common.Interfaces;

namespace TodoList.Api.Services;

public class CurrentUserService : ICurrentUserService
{
    private readonly IHttpContextAccessor _httpContextAccessor;

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

    // 通過注入的IHttpContextAccessor獲取`HttpContext.User(ClaimsPrinciple)`中對應的Claims信息
    public string? UserName  => _httpContextAccessor.HttpContext?.User.FindFirstValue(ClaimTypes.Name);
}

并在Program中添加依賴注入：

Program.cs

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

使用功能

接下來我們去修改DbContext，需要先在構造函數中注入：

TodoListDbContext.cs

private readonly ICurrentUserService _currentUserService;
public TodoListDbContext(
    DbContextOptions<TodoListDbContext> options,
    IDomainEventService domainEventService,
    ICurrentUserService currentUserService) : base(options)
{
    _domainEventService = domainEventService;
    _currentUserService = currentUserService;
}

在SaveChangesAsync方法中修改：

public override async Task<int> SaveChangesAsync(CancellationToken cancellationToken = new())
{
    foreach (var entry in ChangeTracker.Entries<AuditableEntity>())
    {
        switch (entry.State)
        {
            case EntityState.Added:
                entry.Entity.CreatedBy = _currentUserService.UserName;
                entry.Entity.Created = DateTime.UtcNow;
                break;
            case EntityState.Modified:
                entry.Entity.LastModifiedBy = _currentUserService.UserName;
                entry.Entity.LastModified = DateTime.UtcNow;
                break;
        }
    }
// 省略其他...
}