能否扩展IEntityHistoryStore实现ABP按实体分表存储变更记录？

当然可以实现！你的直觉其实有点偏差——ABP的IEntityHistoryStore正是为了让开发者自定义实体变更的持久化逻辑而设计的，默认的实现只是把所有记录塞进同一张表，我们完全可以重写它来实现每个实体单独存储变更日志的需求。下面结合你给出的Task实体例子，一步步说明实现方案：

1. 定义实体对应的日志表实体 #

首先为Task创建专属的日志实体，对应你想要的zzLog.Tasks_Task表结构：

using System;
using System.ComponentModel.DataAnnotations.Schema;

[Table("Tasks_Task", Schema = "zzLog")]
public class TaskHistory
{
    // 日志主键自增
    public int lgId { get; set; }
    // 关联原Task实体的ID
    public int TaskId { get; set; }
    // Task的描述字段（若需记录所有字段，可添加其他对应属性）
    public string Description { get; set; }
    // 变更类型：1=创建，2=更新，3=删除
    public int lgAction { get; set; }
    // 变更时间
    public DateTime lgTime { get; set; }
}

然后在你的DbContext中添加这个日志实体的DbSet：

public class YourDbContext : AbpDbContext
{
    // 原Task实体的DbSet
    public DbSet<Task> Tasks { get; set; }
    // Task的日志DbSet
    public DbSet<TaskHistory> TaskHistories { get; set; }

    // 其他DbSet和构造函数逻辑...
}

2. 自定义IEntityHistoryStore实现 #

接下来我们重写IEntityHistoryStore的核心逻辑，将不同实体的变更记录写入对应的日志表：

using Abp.EntityHistory;
using Abp.Runtime.Session;
using Microsoft.EntityFrameworkCore;
using System;
using System.Linq;
using System.Threading.Tasks;

public class CustomEntityHistoryStore : AbpServiceBase, IEntityHistoryStore
{
    private readonly YourDbContext _dbContext;
    private readonly IAbpSession _abpSession;

    public CustomEntityHistoryStore(YourDbContext dbContext, IAbpSession abpSession)
    {
        _dbContext = dbContext;
        _abpSession = abpSession;
    }

    // 核心方法：处理实体变更并分发到对应日志表
    public async Task SaveAsync(EntityChangeSet entityChangeSet)
    {
        foreach (var entityChange in entityChangeSet.EntityChanges)
        {
            // 根据实体类型匹配对应的日志处理逻辑
            switch (entityChange.EntityTypeFullName)
            {
                case var fullName when fullName == typeof(Task).FullName:
                    await SaveTaskHistoryAsync(entityChange, entityChangeSet.CreationTime);
                    break;
                // 其他实体可在此添加分支，比如User、Order等
                // case var fullName when fullName == typeof(User).FullName:
                //     await SaveUserHistoryAsync(entityChange, entityChangeSet.CreationTime);
                //     break;
            }
        }

        await _dbContext.SaveChangesAsync();
    }

    // 处理Task实体的变更日志写入
    private async Task SaveTaskHistoryAsync(EntityChange entityChange, DateTime changeTime)
    {
        var task = entityChange.EntityEntry.Entity as Task;
        if (task == null) return;

        // 将ABP的变更类型映射到自定义的lgAction值
        var lgAction = entityChange.ChangeType switch
        {
            EntityChangeType.Created => 1,
            EntityChangeType.Updated => 2,
            EntityChangeType.Deleted => 3,
            _ => throw new ArgumentOutOfRangeException(nameof(entityChange.ChangeType))
        };

        // 获取下一个自增的lgId（也可使用数据库自增列简化逻辑）
        var maxLgId = await _dbContext.TaskHistories.MaxAsync(h => (int?)h.lgId) ?? 0;

        var taskHistory = new TaskHistory
        {
            lgId = maxLgId + 1,
            TaskId = task.Id,
            Description = task.Description,
            lgAction = lgAction,
            lgTime = changeTime
        };

        await _dbContext.TaskHistories.AddAsync(taskHistory);
    }

    // 以下为接口的其他方法，按需实现查询/删除逻辑
    public Task<List<EntityChangeSet>> GetEntityChangeSetsAsync(EntityHistoryQueryInput input)
    {
        // 若需查询变更日志，可根据input条件（如实体类型、时间范围）从对应表读取数据并封装返回
        return Task.FromResult(new List<EntityChangeSet>());
    }

    public Task<List<EntityChange>> GetEntityChangesAsync(long entityChangeSetId)
    {
        return Task.FromResult(new List<EntityChange>());
    }

    public Task<List<EntityPropertyChange>> GetEntityPropertyChangesAsync(long entityChangeId)
    {
        return Task.FromResult(new List<EntityPropertyChange>());
    }

    public Task DeleteAsync(EntityChangeSet entityChangeSet)
    {
        // 按需实现日志删除逻辑
        return Task.CompletedTask;
    }
}

3. 替换ABP默认的实现 #

最后在你的ABP模块的PreInitialize方法中，替换默认的IEntityHistoryStore为我们自定义的实现：

[DependsOn(typeof(AbpEntityHistoryModule))]
public class YourModule : AbpModule
{
    public override void PreInitialize()
    {
        // 替换实体历史存储实现
        Configuration.ReplaceService<IEntityHistoryStore, CustomEntityHistoryStore>(DependencyLifeStyle.Transient);
        
        // 确保启用实体历史追踪（若尚未开启）
        Configuration.EntityHistory.IsEnabled = true;
        // 可指定需要追踪的实体，比如仅追踪Task
        Configuration.EntityHistory.Selectors.Add(
            new NamedTypeSelector("TaskEntities", type => type == typeof(Task))
        );
    }

    // 其他模块初始化逻辑...
}

额外注意事项 #

• 表结构迁移：写完实体后，记得通过EF Core的迁移工具生成并执行数据库脚本，创建zzLog.Tasks_Task表。
• 批量优化：如果实体变更量很大，可以考虑批量插入日志记录，提升性能。
• 通用逻辑复用：若有大量实体需要分表追踪，可使用泛型或反射简化重复代码，比如创建通用日志实体基类，通过动态创建实例避免每个实体写单独的Save方法。
• 变更细节记录：若需记录具体哪些字段发生变更（而非整个实体的当前值），可解析entityChange.PropertyChanges集合，记录每个属性的旧值和新值。

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