Galosys.Foundation.RulesEngine.EntityFrameworkCore 26.5.20.1

Galosys.Foundation.RulesEngine.EntityFrameworkCore

规则引擎数据库存储模块，提供 DatabaseRuleProvider<TEntity> 从数据库加载规则定义，EF 上下文由业务应用决定。

依赖: Galosys.Foundation.RulesEngine（必选）

快速开始

1. 定义实体

业务层定义规则实体，实现 IRuleEntity 约定接口：

using Galosys.Foundation.Core;
using Microsoft.Extensions.Rules;

public class RuleDefinitionEntity : FullEntity<long>, IRuleEntity
{
    public string Code { get; set; } = "";
    public string Name { get; set; } = "";
    public string RuleSet { get; set; } = "";
    public string Condition { get; set; } = "";
    public string? Output { get; set; }
    public int Priority { get; set; }
    public bool Enabled { get; set; } = true;

    // 扩展字段（不映射到 IRuleEntity，需自定义 Provider 映射）
    public string? GroupCode { get; set; }
    public RuleStatus Status { get; set; } = RuleStatus.Active;
    public DateTimeOffset? EffectiveAt { get; set; }
    public DateTimeOffset? ExpireAt { get; set; }
}

2. 表结构

CREATE TABLE rule_definition (
    id              BIGINT PRIMARY KEY,
    code            VARCHAR(100) NOT NULL,
    name            VARCHAR(200) NOT NULL,
    rule_set        VARCHAR(100) NOT NULL,
    condition       TEXT NOT NULL,
    output          TEXT NULL,
    priority        INT DEFAULT 0,
    enabled         BOOLEAN DEFAULT true,
    group_code      VARCHAR(100) NULL,
    status          INT DEFAULT 3,
    effective_at    TIMESTAMP NULL,
    expire_at       TIMESTAMP NULL,
    -- FullEntity 审计字段 ...
    UNIQUE (tenant_id, code)
);

3. 注册服务

// Program.cs
services.AddRuleEngine(configuration);
services.AddDatabaseRuleProvider<RuleDefinitionEntity>();

DatabaseRuleProvider<TEntity> 通过 IRepository<TEntity, long>（Core 层接口）访问数据，自动注入到 IRuleProvider。

4. 初始化规则数据

INSERT INTO rule_definition (id, code, name, rule_set, condition, output, priority, enabled) VALUES
(1, 'vip-discount', 'VIP折扣', 'discount',
 'input.VipLevel >= 2 && input.OrderAmount >= 500',
 'new { Type = "Percentage", Value = 10m }',
 100, true);

自定义映射

默认映射只包含 IRuleEntity 的 7 个字段。若有扩展字段（GroupCode/Status/EffectiveAt 等），继承 DatabaseRuleProvider<TEntity> 覆盖 MapToDefinition：

public class MyRuleProvider : DatabaseRuleProvider<RuleDefinitionEntity>
{
    public MyRuleProvider(
        IRepository<RuleDefinitionEntity, long> repository,
        IMemoryCache cache,
        TimeSpan? cacheDuration = null)
        : base(repository, cache, cacheDuration) { }

    protected override RuleDefinition MapToDefinition(RuleDefinitionEntity entity)
    {
        var def = base.MapToDefinition(entity);
        def.GroupCode = entity.GroupCode;
        def.Status = entity.Status;
        def.EffectiveAt = entity.EffectiveAt;
        def.ExpireAt = entity.ExpireAt;
        return def;
    }
}

注册自定义 Provider：

services.TryAddSingleton<IRuleProvider>(sp =>
{
    var repo = sp.GetRequiredService<IRepository<RuleDefinitionEntity, long>>();
    var cache = sp.GetRequiredService<IMemoryCache>();
    return new MyRuleProvider(repo, cache, TimeSpan.FromMinutes(10));
});

缓存

• 默认 30 分钟滑动过期
• 可通过 AddDatabaseRuleProvider<TEntity>(TimeSpan.FromMinutes(10)) 自定义

与 JSON 配置组合

JSON 定义基础规则 + DB 定义业务规则：

services.AddRuleEngine(configuration);                    // ConfigurationRuleProvider (JSON)
services.AddDatabaseRuleProvider<RuleDefinitionEntity>(); // DatabaseRuleProvider (DB)

业务场景

IRuleEntity 约定接口

public interface IRuleEntity
{
    string Code { get; }
    string Name { get; }
    string RuleSet { get; }
    string Condition { get; }
    string? Output { get; }
    int Priority { get; }
    bool Enabled { get; }
}