EF Core如何简化子类数据加载，避免重复代码与多服务依赖？

核心思路 #

放弃为每个Cell子类单独创建IService<T>，转而基于基类Cell实现通用服务，结合Ardalis.Specification的多态查询能力，一次性处理所有子类的加载逻辑，彻底消除控制器冗余代码。

1. 定义通用Cell服务接口与实现 #

创建针对基类Cell的通用服务，封装所有子类的查询、CRUD操作：

public interface ICellService
{
    Task<IEnumerable<Cell>> GetAllCellsAsync(CancellationToken cancellationToken = default);
    Task<Cell?> GetCellByIdAsync(Guid id, CancellationToken cancellationToken = default);
    Task<IEnumerable<Cell>> GetCellsByTypeAsync(CellType cellType, CancellationToken cancellationToken = default);
    Task<IEnumerable<ImageCell>> GetImageCellsWithAssetsAsync(CancellationToken cancellationToken = default);
    Task<IEnumerable<TextCell>> GetTextCellsWithContentAsync(CancellationToken cancellationToken = default);
}

public class CellService : ICellService
{
    private readonly IRepository<Cell> _cellRepository;

    public CellService(IRepository<Cell> cellRepository)
    {
        _cellRepository = cellRepository;
    }

    public async Task<IEnumerable<Cell>> GetAllCellsAsync(CancellationToken cancellationToken = default)
    {
        return await _cellRepository.ListAsync(new Specification<Cell>(), cancellationToken);
    }

    public async Task<Cell?> GetCellByIdAsync(Guid id, CancellationToken cancellationToken = default)
    {
        // 按需加载子类专属导航属性
        var spec = new Specification<Cell>(c => c.Id == id)
            .Include(c => c is ImageCell img ? img.ImageAsset : null)
            .Include(c => c is TextCell txt ? txt.RichTextContent : null);
        
        return await _cellRepository.FirstOrDefaultAsync(spec, cancellationToken);
    }

    public async Task<IEnumerable<Cell>> GetCellsByTypeAsync(CellType cellType, CancellationToken cancellationToken = default)
    {
        var spec = new Specification<Cell>(c => c.CellType == cellType);
        return await _cellRepository.ListAsync(spec, cancellationToken);
    }

    public async Task<IEnumerable<ImageCell>> GetImageCellsWithAssetsAsync(CancellationToken cancellationToken = default)
    {
        // 用OfType筛选ImageCell并加载关联资源
        var spec = new Specification<Cell>()
            .OfType<ImageCell>()
            .Include(img => img.ImageAsset)
            .Where(img => img.ImageAsset != null);
        
        var cells = await _cellRepository.ListAsync(spec, cancellationToken);
        return cells.OfType<ImageCell>();
    }

    public async Task<IEnumerable<TextCell>> GetTextCellsWithContentAsync(CancellationToken cancellationToken = default)
    {
        var spec = new Specification<Cell>()
            .OfType<TextCell>()
            .Include(txt => txt.RichTextContent);
        
        var cells = await _cellRepository.ListAsync(spec, cancellationToken);
        return cells.OfType<TextCell>();
    }
}

2. 利用Ardalis.Specification处理子类专属查询 #

如果需要更复杂的子类查询，可以单独定义Specification类，保持代码整洁：

// ImageCell专属查询规格
public class ActiveImageCellsSpec : Specification<ImageCell>
{
    public ActiveImageCellsSpec()
    {
        Query.Include(img => img.ImageAsset)
             .Where(img => img.IsActive && img.ImageAsset.FileSize < 1024 * 1024);
    }
}

// 在服务中使用这个规格
public async Task<IEnumerable<ImageCell>> GetActiveSmallImageCellsAsync(CancellationToken cancellationToken = default)
{
    var spec = new ActiveImageCellsSpec();
    return await _cellRepository.ListAsync(spec, cancellationToken);
}

3. 控制器简化：只依赖通用服务 #

控制器不再需要注入多个子类服务，仅通过ICellService处理所有请求：

[ApiController]
[Route("api/cells")]
public class CellsController : ControllerBase
{
    private readonly ICellService _cellService;

    public CellsController(ICellService cellService)
    {
        _cellService = cellService;
    }

    [HttpGet]
    public async Task<IActionResult> GetAllCells(CancellationToken cancellationToken)
    {
        var cells = await _cellService.GetAllCellsAsync(cancellationToken);
        return Ok(cells);
    }

    [HttpGet("{id:guid}")]
    public async Task<IActionResult> GetCellById(Guid id, CancellationToken cancellationToken)
    {
        var cell = await _cellService.GetCellByIdAsync(id, cancellationToken);
        return cell == null ? NotFound() : Ok(cell);
    }

    [HttpGet("type/{cellType}")]
    public async Task<IActionResult> GetCellsByType(CellType cellType, CancellationToken cancellationToken)
    {
        var cells = await _cellService.GetCellsByTypeAsync(cellType, cancellationToken);
        return Ok(cells);
    }

    [HttpGet("image-cells/active-small")]
    public async Task<IActionResult> GetActiveSmallImageCells(CancellationToken cancellationToken)
    {
        var cells = await _cellService.GetActiveSmallImageCellsAsync(cancellationToken);
        return Ok(cells);
    }
}

4. 服务注册（Program.cs/Startup.cs） #

只需注册基类仓库和通用服务，EF Core的鉴别器映射会自动处理子类的存储逻辑：

// 注册Ardalis.Specification仓库
builder.Services.AddScoped<IRepository<Cell>, Repository<Cell>>();
// 注册通用Cell服务
builder.Services.AddScoped<ICellService, CellService>();

关键优势 #

• 彻底消除子类服务的重复代码，所有Cell相关逻辑集中在一个服务中
• 借助Ardalis.Specification的OfType<T>和筛选能力，轻松实现子类专属查询
• EF Core鉴别器自动处理多态数据的存储与查询，无需额外编写SQL或查询逻辑

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