cKey
5 years ago
committed by
GitHub
GitHub
63 changed files with 416 additions and 1210 deletions
@ -1,31 +0,0 @@ |
|||
using Microsoft.Extensions.DependencyInjection; |
|||
using System; |
|||
using System.Collections.Generic; |
|||
using Volo.Abp.Modularity; |
|||
using NRule = NRules.Fluent.Dsl.Rule; |
|||
|
|||
namespace LINGYUN.Abp.Rules.NRules |
|||
{ |
|||
[DependsOn( |
|||
typeof(AbpRulesModule) |
|||
)] |
|||
public class AbpNRulesModule : AbpModule |
|||
{ |
|||
private readonly AbpNRulesOptions options = new AbpNRulesOptions(); |
|||
public override void PreConfigureServices(ServiceConfigurationContext context) |
|||
{ |
|||
context.Services.AddObjectAccessor(options); |
|||
context.Services.OnRegistred(ctx => |
|||
{ |
|||
if (ctx.ImplementationType.IsAssignableTo(typeof(NRule))) |
|||
{ |
|||
options.Rules.AddIfNotContains(ctx.ImplementationType); |
|||
} |
|||
}); |
|||
} |
|||
public override void ConfigureServices(ServiceConfigurationContext context) |
|||
{ |
|||
context.Services.AddNRules(options); |
|||
} |
|||
} |
|||
} |
|||
@ -1,22 +0,0 @@ |
|||
<Project Sdk="Microsoft.NET.Sdk"> |
|||
|
|||
<Import Project="..\..\..\common.props" /> |
|||
|
|||
<PropertyGroup> |
|||
<TargetFramework>netstandard2.0</TargetFramework> |
|||
<RootNamespace /> |
|||
</PropertyGroup> |
|||
|
|||
<ItemGroup> |
|||
<PackageReference Include="NRules" Version="0.9.0" /> |
|||
</ItemGroup> |
|||
|
|||
<ItemGroup> |
|||
<ProjectReference Include="..\LINGYUN.Abp.Rules\LINGYUN.Abp.Rules.csproj" /> |
|||
</ItemGroup> |
|||
|
|||
<ItemGroup> |
|||
<Folder Include="LINGYUN\Abp\Rules\NRules\" /> |
|||
</ItemGroup> |
|||
|
|||
</Project> |
|||
@ -1,14 +0,0 @@ |
|||
using Volo.Abp.Collections; |
|||
using NRule = NRules.Fluent.Dsl.Rule; |
|||
|
|||
namespace LINGYUN.Abp.Rules |
|||
{ |
|||
public class AbpNRulesOptions |
|||
{ |
|||
public ITypeList<NRule> Rules { get; } |
|||
public AbpNRulesOptions() |
|||
{ |
|||
Rules = new TypeList<NRule>(); |
|||
} |
|||
} |
|||
} |
|||
@ -1,44 +0,0 @@ |
|||
using NRules.RuleModel; |
|||
using System; |
|||
using System.Collections.Generic; |
|||
|
|||
namespace LINGYUN.Abp.Rules |
|||
{ |
|||
public class AbpRuleRepository : INRulesRepository |
|||
{ |
|||
public void Add(IRuleSet ruleSet) |
|||
{ |
|||
throw new NotImplementedException(); |
|||
} |
|||
|
|||
public IEnumerable<IRuleSet> GetRuleSets() |
|||
{ |
|||
throw new NotImplementedException(); |
|||
} |
|||
|
|||
public void Remove(string ruleSetName) |
|||
{ |
|||
throw new NotImplementedException(); |
|||
} |
|||
|
|||
public void Remove(IRuleSet ruleSet) |
|||
{ |
|||
throw new NotImplementedException(); |
|||
} |
|||
|
|||
public IRuleSet GetRuleSet(string ruleSetName) |
|||
{ |
|||
return new RuleSet(ruleSetName); |
|||
} |
|||
|
|||
public IRuleSet GetRuleSet(RuleGroup group) |
|||
{ |
|||
throw new NotImplementedException(); |
|||
} |
|||
|
|||
public IEnumerable<IRuleSet> GetRuleSets(IEnumerable<RuleGroup> groups) |
|||
{ |
|||
throw new NotImplementedException(); |
|||
} |
|||
} |
|||
} |
|||
@ -1,20 +0,0 @@ |
|||
using Microsoft.Extensions.DependencyInjection; |
|||
using NRules.Extensibility; |
|||
using System; |
|||
|
|||
namespace LINGYUN.Abp.Rules |
|||
{ |
|||
public class DependencyResolver : IDependencyResolver |
|||
{ |
|||
protected IServiceProvider ServiceProvider { get; } |
|||
public DependencyResolver(IServiceProvider serviceProvider) |
|||
{ |
|||
ServiceProvider = serviceProvider; |
|||
} |
|||
|
|||
public virtual object Resolve(IResolutionContext context, Type serviceType) |
|||
{ |
|||
return ServiceProvider.GetRequiredService(serviceType); |
|||
} |
|||
} |
|||
} |
|||
@ -1,20 +0,0 @@ |
|||
using NRules.RuleModel; |
|||
using System.Collections.Generic; |
|||
|
|||
namespace LINGYUN.Abp.Rules |
|||
{ |
|||
public interface INRulesRepository : IRuleRepository |
|||
{ |
|||
void Add(IRuleSet ruleSet); |
|||
|
|||
void Remove(string ruleSetName); |
|||
|
|||
void Remove(IRuleSet ruleSet); |
|||
|
|||
IRuleSet GetRuleSet(string ruleSetName); |
|||
|
|||
IRuleSet GetRuleSet(RuleGroup group); |
|||
|
|||
IEnumerable<IRuleSet> GetRuleSets(IEnumerable<RuleGroup> groups); |
|||
} |
|||
} |
|||
@ -1,60 +0,0 @@ |
|||
using Microsoft.Extensions.DependencyInjection; |
|||
using NRules.RuleModel; |
|||
using NRules.RuleModel.Builders; |
|||
using System; |
|||
using System.Collections.Generic; |
|||
using System.Linq; |
|||
using System.Linq.Dynamic.Core; |
|||
using System.Linq.Expressions; |
|||
using System.Threading.Tasks; |
|||
using Volo.Abp.DependencyInjection; |
|||
|
|||
namespace LINGYUN.Abp.Rules |
|||
{ |
|||
[Dependency(ServiceLifetime.Transient, ReplaceServices = true)] |
|||
[ExposeServices(typeof(IEntityRuleContributor))] |
|||
public class NRulesEntityRuleContributor : IEntityRuleContributor |
|||
{ |
|||
protected INRulesRepository Repository { get; } |
|||
public Task ApplyAsync(EntityRuleContext context) |
|||
{ |
|||
var entityType = context.Entity.GetType(); |
|||
var entityRuleName = RuleNameAttribute.GetRuleName(entityType); |
|||
|
|||
|
|||
|
|||
IEnumerable<IRuleSet> groupRuleSets = new List<IRuleSet>(); |
|||
|
|||
groupRuleSets = Repository.GetRuleSets(context.Groups); |
|||
|
|||
var sessionFactory = Repository.Compile(context.Groups); |
|||
var session = sessionFactory.CreateSession(); |
|||
session.Insert(context.Entity); |
|||
|
|||
session.Fire(); |
|||
|
|||
foreach (var groupRuleSet in groupRuleSets) |
|||
{ |
|||
} |
|||
|
|||
foreach (var group in context.Groups) |
|||
{ |
|||
var groupRuleSet = new RuleSet(group.Name); |
|||
|
|||
Repository.GetRuleSet(group.Name); |
|||
|
|||
foreach (var rule in group.Rules) |
|||
{ |
|||
var builder = new RuleBuilder(); |
|||
builder.Name(rule.Name); |
|||
|
|||
PatternBuilder thisRulePattern = builder.LeftHandSide().Pattern(entityType, entityRuleName); |
|||
ParameterExpression thisRuleParameter = thisRulePattern.Declaration.ToParameterExpression(); |
|||
var ruleCondition = Expression.Lambda(DynamicExpressionParser.ParseLambda(typeof(bool), rule.Expression), thisRuleParameter); |
|||
thisRulePattern.Condition(ruleCondition); |
|||
} |
|||
} |
|||
throw new NotImplementedException(); |
|||
} |
|||
} |
|||
} |
|||
@ -1,24 +0,0 @@ |
|||
using Microsoft.Extensions.DependencyInjection; |
|||
using NRules.Fluent; |
|||
using System; |
|||
using System.Collections.Generic; |
|||
using Volo.Abp.DependencyInjection; |
|||
using NRule = NRules.Fluent.Dsl.Rule; |
|||
|
|||
namespace LINGYUN.Abp.Rules |
|||
{ |
|||
[Dependency(ServiceLifetime.Transient, ReplaceServices = true)] |
|||
[ExposeServices(typeof(IRuleActivator))] |
|||
public class RuleActivator : IRuleActivator |
|||
{ |
|||
protected IServiceProvider ServiceProvider { get; } |
|||
public RuleActivator(IServiceProvider serviceProvider) |
|||
{ |
|||
ServiceProvider = serviceProvider; |
|||
} |
|||
public virtual IEnumerable<NRule> Activate(Type type) |
|||
{ |
|||
return (IEnumerable<NRule>)ServiceProvider.GetServices(type); |
|||
} |
|||
} |
|||
} |
|||
@ -1,55 +0,0 @@ |
|||
using LINGYUN.Abp.Rules; |
|||
using NRules; |
|||
using NRules.Fluent; |
|||
using NRules.RuleModel; |
|||
using System; |
|||
|
|||
namespace Microsoft.Extensions.DependencyInjection |
|||
{ |
|||
public static class NRulesServiceCollectionExtensions |
|||
{ |
|||
public static IServiceCollection AddNRules(this IServiceCollection services, AbpNRulesOptions options) |
|||
{ |
|||
services.RegisterRepository(); |
|||
services.RegisterSessionFactory(); |
|||
services.RegisterSession(); |
|||
|
|||
return services; |
|||
} |
|||
|
|||
public static IServiceCollection RegisterRepository(this IServiceCollection services) |
|||
{ |
|||
services.AddSingleton<IRuleActivator, RuleActivator>(); |
|||
|
|||
services.AddSingleton<IRuleRepository, AbpRuleRepository>(); |
|||
services.AddSingleton<INRulesRepository, AbpRuleRepository>(); |
|||
|
|||
return services; |
|||
} |
|||
|
|||
public static IServiceCollection RegisterSessionFactory(this IServiceCollection services) |
|||
{ |
|||
services.RegisterSessionFactory((provider) => provider.GetRequiredService<IRuleRepository>().Compile()); |
|||
|
|||
return services; |
|||
} |
|||
|
|||
public static IServiceCollection RegisterSessionFactory(this IServiceCollection services, Func<IServiceProvider, ISessionFactory> compileFunc) |
|||
{ |
|||
services.AddSingleton<IRuleActivator, RuleActivator>(); |
|||
services.AddSingleton(compileFunc); |
|||
|
|||
return services; |
|||
} |
|||
|
|||
public static IServiceCollection RegisterSession(this IServiceCollection services) |
|||
{ |
|||
return services.RegisterSession((provider) => provider.GetRequiredService<ISessionFactory>().CreateSession()); |
|||
} |
|||
|
|||
public static IServiceCollection RegisterSession(this IServiceCollection services, Func<IServiceProvider, ISession> factoryFunc) |
|||
{ |
|||
return services.AddScoped(factoryFunc); |
|||
} |
|||
} |
|||
} |
|||
@ -1,15 +0,0 @@ |
|||
using NRules; |
|||
using System.Collections.Generic; |
|||
|
|||
namespace LINGYUN.Abp.Rules |
|||
{ |
|||
public static class RuleRepositoryExtensions |
|||
{ |
|||
public static ISessionFactory Compile(this INRulesRepository repository, IEnumerable<RuleGroup> groups) |
|||
{ |
|||
var compiler = new RuleCompiler(); |
|||
ISessionFactory factory = compiler.Compile(repository.GetRuleSets(groups)); |
|||
return factory; |
|||
} |
|||
} |
|||
} |
|||
@ -1,14 +0,0 @@ |
|||
<Project Sdk="Microsoft.NET.Sdk"> |
|||
|
|||
<Import Project="..\..\..\common.props" /> |
|||
|
|||
<PropertyGroup> |
|||
<TargetFramework>netstandard2.0</TargetFramework> |
|||
<RootNamespace /> |
|||
</PropertyGroup> |
|||
|
|||
<ItemGroup> |
|||
<PackageReference Include="Volo.Abp.Ddd.Domain" Version="4.3.0" /> |
|||
</ItemGroup> |
|||
|
|||
</Project> |
|||
@ -1,16 +0,0 @@ |
|||
using Microsoft.Extensions.DependencyInjection; |
|||
using Volo.Abp.Domain; |
|||
using Volo.Abp.Modularity; |
|||
|
|||
namespace LINGYUN.Abp.Rules |
|||
{ |
|||
[DependsOn( |
|||
typeof(AbpDddDomainModule))] |
|||
public class AbpRulesModule : AbpModule |
|||
{ |
|||
public override void PreConfigureServices(ServiceConfigurationContext context) |
|||
{ |
|||
context.Services.OnRegistred(EntityChangedRulesInterceptorRegistrar.RegisterIfNeeded); |
|||
} |
|||
} |
|||
} |
|||
@ -1,48 +0,0 @@ |
|||
using System; |
|||
using System.Linq; |
|||
using System.Threading.Tasks; |
|||
using Volo.Abp.DependencyInjection; |
|||
using Volo.Abp.Domain.Entities; |
|||
using Volo.Abp.DynamicProxy; |
|||
|
|||
namespace LINGYUN.Abp.Rules |
|||
{ |
|||
public class EntityChangedRulesInterceptor : AbpInterceptor, ITransientDependency |
|||
{ |
|||
protected IRuleFinder RuleFinder { get; } |
|||
protected IEntityRuleContributor EntityRuleContributor { get; } |
|||
|
|||
public EntityChangedRulesInterceptor( |
|||
IRuleFinder ruleFinder, |
|||
IEntityRuleContributor entityRuleContributor) |
|||
{ |
|||
RuleFinder = ruleFinder; |
|||
EntityRuleContributor = entityRuleContributor; |
|||
} |
|||
|
|||
public override async Task InterceptAsync(IAbpMethodInvocation invocation) |
|||
{ |
|||
var entityObj = invocation.Arguments.First(); |
|||
// TODO: 针对实体的变更执行一次定义的规则
|
|||
// IBasicRepository.InsertAsync || IBasicRepository.UpdateAsync || IBasicRepository.DeleteAsync
|
|||
if (entityObj != null && entityObj is IEntity entity) |
|||
{ |
|||
await ApplyEntityRuleAsync(entity); |
|||
} |
|||
|
|||
await invocation.ProceedAsync(); |
|||
} |
|||
|
|||
protected virtual async Task ApplyEntityRuleAsync(IEntity entity) |
|||
{ |
|||
Type entityType = ProxyHelper.GetUnProxiedType(entity); |
|||
// 加载规则列表
|
|||
var groups = await RuleFinder.GetRuleGroupsAsync(entityType); |
|||
if (groups.Any()) |
|||
{ |
|||
// 应用规则
|
|||
await EntityRuleContributor.ApplyAsync(new EntityRuleContext(groups, entity)); |
|||
} |
|||
} |
|||
} |
|||
} |
|||
@ -1,28 +0,0 @@ |
|||
using System; |
|||
using Volo.Abp.DependencyInjection; |
|||
using Volo.Abp.Domain.Repositories; |
|||
using Volo.Abp.DynamicProxy; |
|||
|
|||
namespace LINGYUN.Abp.Rules |
|||
{ |
|||
public static class EntityChangedRulesInterceptorRegistrar |
|||
{ |
|||
public static void RegisterIfNeeded(IOnServiceRegistredContext context) |
|||
{ |
|||
if (ShouldIntercept(context.ImplementationType)) |
|||
{ |
|||
context.Interceptors.TryAdd<EntityChangedRulesInterceptor>(); |
|||
} |
|||
} |
|||
|
|||
private static bool ShouldIntercept(Type type) |
|||
{ |
|||
// 拦截器的要求
|
|||
// 1、继承自IBasicRepository的仓储
|
|||
// 2、继承自INeedRule接口的实体
|
|||
return !DynamicProxyIgnoreTypes.Contains(type) && |
|||
type.IsAssignableTo(typeof(IBasicRepository<>)) && |
|||
type.GetGenericTypeDefinition().IsAssignableTo(typeof(INeedRule)); |
|||
} |
|||
} |
|||
} |
|||
@ -1,18 +0,0 @@ |
|||
using System.Collections.Generic; |
|||
using Volo.Abp.Domain.Entities; |
|||
|
|||
namespace LINGYUN.Abp.Rules |
|||
{ |
|||
public class EntityRuleContext |
|||
{ |
|||
public List<RuleGroup> Groups { get; } |
|||
public IEntity Entity { get; } |
|||
public EntityRuleContext( |
|||
List<RuleGroup> groups, |
|||
IEntity entity) |
|||
{ |
|||
Groups = groups; |
|||
Entity = entity; |
|||
} |
|||
} |
|||
} |
|||
@ -1,8 +0,0 @@ |
|||
namespace LINGYUN.Abp.Rules |
|||
{ |
|||
public enum ErrorType |
|||
{ |
|||
Warning = 0, |
|||
Error = 1 |
|||
} |
|||
} |
|||
@ -1,7 +0,0 @@ |
|||
namespace LINGYUN.Abp.Rules |
|||
{ |
|||
public enum ExpressionType |
|||
{ |
|||
LambdaExpression = 0 |
|||
} |
|||
} |
|||
@ -1,9 +0,0 @@ |
|||
using System.Threading.Tasks; |
|||
|
|||
namespace LINGYUN.Abp.Rules |
|||
{ |
|||
public interface IEntityRuleContributor |
|||
{ |
|||
Task ApplyAsync(EntityRuleContext context); |
|||
} |
|||
} |
|||
@ -1,6 +0,0 @@ |
|||
namespace LINGYUN.Abp.Rules |
|||
{ |
|||
public interface INeedRule |
|||
{ |
|||
} |
|||
} |
|||
@ -1,11 +0,0 @@ |
|||
using System; |
|||
using System.Collections.Generic; |
|||
using System.Threading.Tasks; |
|||
|
|||
namespace LINGYUN.Abp.Rules |
|||
{ |
|||
public interface IRuleFinder |
|||
{ |
|||
Task<List<RuleGroup>> GetRuleGroupsAsync(Type entityType); |
|||
} |
|||
} |
|||
@ -1,13 +0,0 @@ |
|||
using System.Threading.Tasks; |
|||
using Volo.Abp.DependencyInjection; |
|||
|
|||
namespace LINGYUN.Abp.Rules |
|||
{ |
|||
public class NullEntityRuleContributor : IEntityRuleContributor, ISingletonDependency |
|||
{ |
|||
public Task ApplyAsync(EntityRuleContext context) |
|||
{ |
|||
return Task.CompletedTask; |
|||
} |
|||
} |
|||
} |
|||
@ -1,15 +0,0 @@ |
|||
using System; |
|||
using System.Collections.Generic; |
|||
using System.Threading.Tasks; |
|||
using Volo.Abp.DependencyInjection; |
|||
|
|||
namespace LINGYUN.Abp.Rules |
|||
{ |
|||
public class NullRuleFinder : IRuleFinder, ISingletonDependency |
|||
{ |
|||
public Task<List<RuleGroup>> GetRuleGroupsAsync(Type entityType) |
|||
{ |
|||
return Task.FromResult(new List<RuleGroup>()); |
|||
} |
|||
} |
|||
} |
|||
@ -1,90 +0,0 @@ |
|||
using JetBrains.Annotations; |
|||
using System; |
|||
using System.Collections.Generic; |
|||
using Volo.Abp; |
|||
|
|||
namespace LINGYUN.Abp.Rules |
|||
{ |
|||
/// <summary>
|
|||
/// ref: https://github.com/microsoft/RulesEngine/blob/master/src/RulesEngine/RulesEngine/Models/Rule.cs
|
|||
/// </summary>
|
|||
public class Rule |
|||
{ |
|||
[NotNull] |
|||
public string Name { get; set; } |
|||
public string Operator { get; set; } |
|||
public string ErrorMessage { get; set; } |
|||
public DateTime CreationTime { get; set; } |
|||
public ErrorType ErrorType { get; set; } |
|||
public ExpressionType? ExpressionType { get; set; } |
|||
public List<Rule> Rules { get; set; } |
|||
public List<string> InjectRules { get; set; } |
|||
public List<RuleParam> Params { get; set; } |
|||
public string Expression { get; set; } |
|||
public string SuccessEvent { get; set; } |
|||
protected Rule() { } |
|||
public Rule( |
|||
[NotNull] string name, |
|||
string operation, |
|||
DateTime creationTime, |
|||
string expression = null, |
|||
string successEvent = null, |
|||
ErrorType errorType = ErrorType.Warning, |
|||
ExpressionType? expressionType = null) |
|||
{ |
|||
Check.NotNullOrWhiteSpace(name, nameof(name)); |
|||
|
|||
Name = name; |
|||
Operator = operation; |
|||
CreationTime = creationTime; |
|||
Expression = expression; |
|||
SuccessEvent = successEvent; |
|||
ErrorType = errorType; |
|||
ExpressionType = expressionType; |
|||
|
|||
Rules = new List<Rule>(); |
|||
Params = new List<RuleParam>(); |
|||
InjectRules = new List<string>(); |
|||
} |
|||
|
|||
public Rule CreateChildren(Rule rule) |
|||
{ |
|||
Rules.Add(rule); |
|||
|
|||
return this; |
|||
} |
|||
|
|||
public Rule WithParam(RuleParam param) |
|||
{ |
|||
Params.AddIfNotContains(param); |
|||
return this; |
|||
} |
|||
|
|||
public Rule InjectRule(string ruleName) |
|||
{ |
|||
InjectRules.AddIfNotContains(ruleName); |
|||
|
|||
return this; |
|||
} |
|||
|
|||
public override int GetHashCode() |
|||
{ |
|||
return Name.GetHashCode(); |
|||
} |
|||
|
|||
public override bool Equals(object obj) |
|||
{ |
|||
if (obj == null) |
|||
{ |
|||
return false; |
|||
} |
|||
|
|||
if (obj is Rule rule) |
|||
{ |
|||
return rule.Name.Equals(Name); |
|||
} |
|||
|
|||
return false; |
|||
} |
|||
} |
|||
} |
|||
@ -1,53 +0,0 @@ |
|||
using JetBrains.Annotations; |
|||
using System.Collections.Generic; |
|||
using Volo.Abp; |
|||
|
|||
namespace LINGYUN.Abp.Rules |
|||
{ |
|||
public class RuleGroup |
|||
{ |
|||
[NotNull] |
|||
public string Name { get; set; } |
|||
public List<string> InjectRules { get; set; } |
|||
public List<Rule> Rules { get; } |
|||
protected RuleGroup() { } |
|||
public RuleGroup( |
|||
[NotNull] string name) |
|||
{ |
|||
Check.NotNullOrWhiteSpace(name, nameof(name)); |
|||
|
|||
Name = name; |
|||
|
|||
Rules = new List<Rule>(); |
|||
InjectRules = new List<string>(); |
|||
} |
|||
|
|||
public RuleGroup WithInjectRule(string ruleName) |
|||
{ |
|||
InjectRules.AddIfNotContains(ruleName); |
|||
|
|||
return this; |
|||
} |
|||
|
|||
public RuleGroup WithInjectRule(IEnumerable<string> ruleNames) |
|||
{ |
|||
InjectRules.AddIfNotContains(ruleNames); |
|||
|
|||
return this; |
|||
} |
|||
|
|||
public RuleGroup WithRule(Rule rule) |
|||
{ |
|||
Rules.AddIfNotContains(rule); |
|||
|
|||
return this; |
|||
} |
|||
|
|||
public RuleGroup WithRule(IEnumerable<Rule> rules) |
|||
{ |
|||
Rules.AddIfNotContains(rules); |
|||
|
|||
return this; |
|||
} |
|||
} |
|||
} |
|||
@ -1,35 +0,0 @@ |
|||
using System; |
|||
using System.Reflection; |
|||
|
|||
namespace LINGYUN.Abp.Rules |
|||
{ |
|||
public class RuleNameAttribute : Attribute |
|||
{ |
|||
public string Name { get; } |
|||
public RuleNameAttribute(string name) |
|||
{ |
|||
Name = name; |
|||
} |
|||
|
|||
public virtual string GetRuleNameForType(Type ruleType) |
|||
{ |
|||
return Name; |
|||
} |
|||
|
|||
public static string GetRuleName<TEntity>() |
|||
{ |
|||
return GetRuleName(typeof(TEntity)); |
|||
} |
|||
|
|||
public static string GetRuleName(Type entityType) |
|||
{ |
|||
var ruleAttribute = entityType.GetSingleAttributeOrNull<RuleNameAttribute>(); |
|||
if (ruleAttribute != null) |
|||
{ |
|||
return ruleAttribute.GetRuleNameForType(entityType); |
|||
} |
|||
|
|||
return entityType.Name.RemovePostFix("Rule").ToKebabCase(); |
|||
} |
|||
} |
|||
} |
|||
@ -1,45 +0,0 @@ |
|||
using JetBrains.Annotations; |
|||
using Volo.Abp; |
|||
|
|||
namespace LINGYUN.Abp.Rules |
|||
{ |
|||
public class RuleParam |
|||
{ |
|||
[NotNull] |
|||
public string Name { get; set; } |
|||
|
|||
[NotNull] |
|||
public string Expression { get; set; } |
|||
|
|||
protected RuleParam() { } |
|||
public RuleParam( |
|||
[NotNull] string name, |
|||
[NotNull] string expression) |
|||
{ |
|||
Check.NotNullOrWhiteSpace(name, nameof(name)); |
|||
Check.NotNullOrWhiteSpace(expression, nameof(expression)); |
|||
|
|||
Name = name; |
|||
Expression = expression; |
|||
} |
|||
|
|||
public override int GetHashCode() |
|||
{ |
|||
return Name.GetHashCode(); |
|||
} |
|||
|
|||
public override bool Equals(object obj) |
|||
{ |
|||
if (obj == null) |
|||
{ |
|||
return false; |
|||
} |
|||
|
|||
if (obj is RuleParam param) |
|||
{ |
|||
return param.Name.Equals(Name); |
|||
} |
|||
return base.Equals(obj); |
|||
} |
|||
} |
|||
} |
|||
@ -1,7 +0,0 @@ |
|||
# LINGYUN.Abp.Rules |
|||
|
|||
规则引擎定义 |
|||
|
|||
## 配置使用 |
|||
|
|||
待完善 |
|||
@ -1,20 +0,0 @@ |
|||
<Project Sdk="Microsoft.NET.Sdk.Web"> |
|||
|
|||
<Import Project="..\..\..\common.props" /> |
|||
|
|||
<PropertyGroup> |
|||
<TargetFramework>net5.0</TargetFramework> |
|||
<AssetTargetFallback>$(AssetTargetFallback);portable-net45+win8+wp8+wpa81;</AssetTargetFallback> |
|||
<GenerateAssemblyConfigurationAttribute>false</GenerateAssemblyConfigurationAttribute> |
|||
<GenerateAssemblyCompanyAttribute>false</GenerateAssemblyCompanyAttribute> |
|||
<GenerateAssemblyProductAttribute>false</GenerateAssemblyProductAttribute> |
|||
<IsPackable>true</IsPackable> |
|||
<OutputType>Library</OutputType> |
|||
<RootNamespace /> |
|||
</PropertyGroup> |
|||
|
|||
<ItemGroup> |
|||
<ProjectReference Include="..\LINGYUN.Abp.Dapr.Actors.IdentityModel\LINGYUN.Abp.Dapr.Actors.IdentityModel.csproj" /> |
|||
</ItemGroup> |
|||
|
|||
</Project> |
|||
@ -1,6 +0,0 @@ |
|||
<?xml version="1.0" encoding="utf-8"?> |
|||
<Project ToolsVersion="Current" xmlns="http://schemas.microsoft.com/developer/msbuild/2003"> |
|||
<PropertyGroup> |
|||
<ActiveDebugProfile>IIS Express</ActiveDebugProfile> |
|||
</PropertyGroup> |
|||
</Project> |
|||
@ -1,10 +0,0 @@ |
|||
using Volo.Abp.Modularity; |
|||
|
|||
namespace LINGYUN.Abp.Dapr.Actors.IdentityModel.Web |
|||
{ |
|||
[DependsOn( |
|||
typeof(AbpDaprActorsIdentityModelModule))] |
|||
public class AbpDaprActorsIdentityModelWebModule : AbpModule |
|||
{ |
|||
} |
|||
} |
|||
@ -1,51 +0,0 @@ |
|||
using LINGYUN.Abp.Dapr.Actors.Authentication; |
|||
using Microsoft.AspNetCore.Authentication; |
|||
using Microsoft.AspNetCore.Http; |
|||
using System.Net.Http.Headers; |
|||
using System.Threading.Tasks; |
|||
using Volo.Abp.DependencyInjection; |
|||
using Volo.Abp.IdentityModel; |
|||
|
|||
namespace LINGYUN.Abp.Dapr.Actors.IdentityModel |
|||
{ |
|||
[Dependency(ReplaceServices = true)] |
|||
public class HttpContextIdentityModelDaprActorProxyAuthenticator : IdentityModelDaprActorProxyAuthenticator |
|||
{ |
|||
public IHttpContextAccessor HttpContextAccessor { get; set; } |
|||
|
|||
public HttpContextIdentityModelDaprActorProxyAuthenticator( |
|||
IIdentityModelAuthenticationService identityModelAuthenticationService) |
|||
: base(identityModelAuthenticationService) |
|||
{ |
|||
} |
|||
|
|||
public override async Task AuthenticateAsync(DaprActorProxyAuthenticateContext context) |
|||
{ |
|||
if (context.RemoteService.GetUseCurrentAccessToken() != false) |
|||
{ |
|||
var accessToken = await GetAccessTokenFromHttpContextOrNullAsync(); |
|||
if (accessToken != null) |
|||
{ |
|||
context.Handler.PreConfigure(request => |
|||
{ |
|||
request.Headers.Authorization = new AuthenticationHeaderValue("Bearer", accessToken); |
|||
}); |
|||
return; |
|||
} |
|||
} |
|||
|
|||
await base.AuthenticateAsync(context); |
|||
} |
|||
|
|||
protected virtual async Task<string> GetAccessTokenFromHttpContextOrNullAsync() |
|||
{ |
|||
var httpContext = HttpContextAccessor?.HttpContext; |
|||
if (httpContext == null) |
|||
{ |
|||
return null; |
|||
} |
|||
|
|||
return await httpContext.GetTokenAsync("access_token"); |
|||
} |
|||
} |
|||
} |
|||
@ -1,27 +0,0 @@ |
|||
{ |
|||
"iisSettings": { |
|||
"windowsAuthentication": false, |
|||
"anonymousAuthentication": true, |
|||
"iisExpress": { |
|||
"applicationUrl": "http://localhost:25348/", |
|||
"sslPort": 44377 |
|||
} |
|||
}, |
|||
"profiles": { |
|||
"IIS Express": { |
|||
"commandName": "IISExpress", |
|||
"launchBrowser": true, |
|||
"environmentVariables": { |
|||
"ASPNETCORE_ENVIRONMENT": "Development" |
|||
} |
|||
}, |
|||
"LINGYUN.Abp.Dapr.Actors.IdentityModel.Web": { |
|||
"commandName": "Project", |
|||
"launchBrowser": true, |
|||
"environmentVariables": { |
|||
"ASPNETCORE_ENVIRONMENT": "Development" |
|||
}, |
|||
"applicationUrl": "https://localhost:5001;http://localhost:5000" |
|||
} |
|||
} |
|||
} |
|||
@ -1,19 +0,0 @@ |
|||
# LINGYUN.Abp.Dapr.Actors.IdentityModel.Web |
|||
|
|||
Dapr.Actors内部使用Http进行服务间调用,此模块用于获取应用当前状态中的身份令牌并传递到远程Actor服务 |
|||
|
|||
## 配置使用 |
|||
|
|||
模块按需引用 |
|||
|
|||
```csharp |
|||
[DependsOn(typeof(AbpDaprActorsIdentityModelWebModule))] |
|||
public class YouProjectModule : AbpModule |
|||
{ |
|||
// other |
|||
} |
|||
``` |
|||
## 配置项说明 |
|||
|
|||
|
|||
## 其他 |
|||
@ -1,18 +0,0 @@ |
|||
<Project Sdk="Microsoft.NET.Sdk"> |
|||
|
|||
<Import Project="..\..\..\common.props" /> |
|||
|
|||
<PropertyGroup> |
|||
<TargetFramework>net5.0</TargetFramework> |
|||
<RootNamespace /> |
|||
</PropertyGroup> |
|||
|
|||
<ItemGroup> |
|||
<PackageReference Include="Volo.Abp.IdentityModel" Version="4.3.0" /> |
|||
</ItemGroup> |
|||
|
|||
<ItemGroup> |
|||
<ProjectReference Include="..\LINGYUN.Abp.Dapr.Actors\LINGYUN.Abp.Dapr.Actors.csproj" /> |
|||
</ItemGroup> |
|||
|
|||
</Project> |
|||
@ -1,54 +0,0 @@ |
|||
using JetBrains.Annotations; |
|||
using System.Collections.Generic; |
|||
using Volo.Abp; |
|||
|
|||
namespace LINGYUN.Abp.Dapr.Actors |
|||
{ |
|||
public static class DaprActorConfigurationExtensions |
|||
{ |
|||
public const string IdentityClientName = "IdentityClient"; |
|||
public const string UseCurrentAccessTokenName = "UseCurrentAccessToken"; |
|||
|
|||
[CanBeNull] |
|||
public static string GetIdentityClient([NotNull] this DaprActorConfiguration configuration) |
|||
{ |
|||
Check.NotNullOrEmpty(configuration, nameof(configuration)); |
|||
|
|||
return configuration.GetOrDefault(IdentityClientName); |
|||
} |
|||
|
|||
public static DaprActorConfiguration SetIdentityClient([NotNull] this DaprActorConfiguration configuration, [CanBeNull] string value) |
|||
{ |
|||
configuration[IdentityClientName] = value; |
|||
return configuration; |
|||
} |
|||
|
|||
[CanBeNull] |
|||
public static bool? GetUseCurrentAccessToken([NotNull] this DaprActorConfiguration configuration) |
|||
{ |
|||
Check.NotNullOrEmpty(configuration, nameof(configuration)); |
|||
|
|||
var value = configuration.GetOrDefault(UseCurrentAccessTokenName); |
|||
if (value == null) |
|||
{ |
|||
return null; |
|||
} |
|||
|
|||
return bool.Parse(value); |
|||
} |
|||
|
|||
public static DaprActorConfiguration SetUseCurrentAccessToken([NotNull] this DaprActorConfiguration configuration, [CanBeNull] bool? value) |
|||
{ |
|||
if (value == null) |
|||
{ |
|||
configuration.Remove(UseCurrentAccessTokenName); |
|||
} |
|||
else |
|||
{ |
|||
configuration[UseCurrentAccessTokenName] = value.Value.ToString().ToLowerInvariant(); |
|||
} |
|||
|
|||
return configuration; |
|||
} |
|||
} |
|||
} |
|||
@ -1,13 +0,0 @@ |
|||
using Volo.Abp.IdentityModel; |
|||
using Volo.Abp.Modularity; |
|||
|
|||
namespace LINGYUN.Abp.Dapr.Actors.IdentityModel |
|||
{ |
|||
[DependsOn( |
|||
typeof(AbpDaprActorsModule), |
|||
typeof(AbpIdentityModelModule) |
|||
)] |
|||
public class AbpDaprActorsIdentityModelModule : AbpModule |
|||
{ |
|||
} |
|||
} |
|||
@ -1,66 +0,0 @@ |
|||
using LINGYUN.Abp.Dapr.Actors.Authentication; |
|||
using LINGYUN.Abp.Dapr.Actors.DynamicProxying; |
|||
using Microsoft.Extensions.Logging; |
|||
using Microsoft.Extensions.Logging.Abstractions; |
|||
using System; |
|||
using System.Collections.Generic; |
|||
using System.Net.Http.Headers; |
|||
using System.Threading.Tasks; |
|||
using Volo.Abp.DependencyInjection; |
|||
using Volo.Abp.IdentityModel; |
|||
|
|||
namespace LINGYUN.Abp.Dapr.Actors.IdentityModel |
|||
{ |
|||
[Dependency(ReplaceServices = true)] |
|||
public class IdentityModelDaprActorProxyAuthenticator : IDaprActorProxyAuthenticator, ITransientDependency |
|||
{ |
|||
protected AbpIdentityClientOptions ClientOptions { get; } |
|||
protected IIdentityModelAuthenticationService IdentityModelAuthenticationService { get; } |
|||
|
|||
public ILogger<IdentityModelDaprActorProxyAuthenticator> Logger { get; set; } |
|||
|
|||
public IdentityModelDaprActorProxyAuthenticator( |
|||
IIdentityModelAuthenticationService identityModelAuthenticationService) |
|||
{ |
|||
IdentityModelAuthenticationService = identityModelAuthenticationService; |
|||
Logger = NullLogger<IdentityModelDaprActorProxyAuthenticator>.Instance; |
|||
} |
|||
|
|||
public virtual async Task AuthenticateAsync(DaprActorProxyAuthenticateContext context) |
|||
{ |
|||
var identityClientName = context.RemoteService.GetIdentityClient(); |
|||
var configuration = GetClientConfiguration(identityClientName); |
|||
if (configuration == null) |
|||
{ |
|||
Logger.LogWarning($"Could not find {nameof(IdentityClientConfiguration)} for {identityClientName}. Either define a configuration for {identityClientName} or set a default configuration."); |
|||
return; |
|||
} |
|||
var accessToken = await IdentityModelAuthenticationService.GetAccessTokenAsync(configuration); |
|||
if (accessToken == null) |
|||
{ |
|||
return; |
|||
} |
|||
|
|||
SetAccessToken(context.Handler, accessToken); |
|||
} |
|||
|
|||
protected virtual void SetAccessToken(DaprHttpClientHandler handler, string accessToken) |
|||
{ |
|||
handler.PreConfigure(request => |
|||
{ |
|||
request.Headers.Authorization = new AuthenticationHeaderValue("Bearer", accessToken); |
|||
}); |
|||
} |
|||
|
|||
private IdentityClientConfiguration GetClientConfiguration(string identityClientName = null) |
|||
{ |
|||
if (identityClientName.IsNullOrEmpty()) |
|||
{ |
|||
return ClientOptions.IdentityClients.Default; |
|||
} |
|||
|
|||
return ClientOptions.IdentityClients.GetOrDefault(identityClientName) ?? |
|||
ClientOptions.IdentityClients.Default; |
|||
} |
|||
} |
|||
} |
|||
@ -1,19 +0,0 @@ |
|||
# LINGYUN.Abp.Dapr.Actors.IdentityModel |
|||
|
|||
Dapr.Actors内部使用Http进行服务间调用,此模块用于传递服务间调用令牌 |
|||
|
|||
## 配置使用 |
|||
|
|||
模块按需引用 |
|||
|
|||
```csharp |
|||
[DependsOn(typeof(AbpDaprActorsIdentityModelModule))] |
|||
public class YouProjectModule : AbpModule |
|||
{ |
|||
// other |
|||
} |
|||
``` |
|||
## 配置项说明 |
|||
|
|||
|
|||
## 其他 |
|||
@ -0,0 +1,27 @@ |
|||
using JetBrains.Annotations; |
|||
using System.Collections.Generic; |
|||
|
|||
namespace LINGYUN.Abp.Rules.RulesEngine |
|||
{ |
|||
public class AbpRulesEngineResolveOptions |
|||
{ |
|||
/// <summary>
|
|||
/// 合并规则
|
|||
/// 如果为 true,在上一个提供者解析规则之后继续执行下一个提供者
|
|||
/// 如果为 false,在上一个提供者解析规则之后立即执行规则
|
|||
/// 默认：false
|
|||
/// </summary>
|
|||
public bool MergingRuels { get; set; } |
|||
/// <summary>
|
|||
/// 规则解析提供者
|
|||
/// </summary>
|
|||
[NotNull] |
|||
public List<IWorkflowRulesResolveContributor> WorkflowRulesResolvers { get; } |
|||
|
|||
public AbpRulesEngineResolveOptions() |
|||
{ |
|||
MergingRuels = false; |
|||
WorkflowRulesResolvers = new List<IWorkflowRulesResolveContributor>(); |
|||
} |
|||
} |
|||
} |
|||
@ -0,0 +1,10 @@ |
|||
namespace LINGYUN.Abp.Rules.RulesEngine.FileProviders.Physical |
|||
{ |
|||
public class AbpRulesEnginePthsicalFileResolveOptions |
|||
{ |
|||
/// <summary>
|
|||
/// 本地文件路径
|
|||
/// </summary>
|
|||
public string PhysicalPath { get; set; } |
|||
} |
|||
} |
|||
@ -1,42 +0,0 @@ |
|||
using Microsoft.Extensions.Caching.Memory; |
|||
using Microsoft.Extensions.FileProviders; |
|||
using Microsoft.Extensions.Options; |
|||
using System; |
|||
using System.IO; |
|||
using Volo.Abp.DependencyInjection; |
|||
using Volo.Abp.Json; |
|||
|
|||
namespace LINGYUN.Abp.Rules.RulesEngine.FileProviders.Physical |
|||
{ |
|||
public class PhysicalFileWorkflowRulesContributor : FileProviderWorkflowRulesContributor, ISingletonDependency |
|||
{ |
|||
private readonly RuleIdGenerator _ruleIdGenerator; |
|||
private readonly AbpRulesEngineOptions _options; |
|||
public PhysicalFileWorkflowRulesContributor( |
|||
IMemoryCache ruleCache, |
|||
RuleIdGenerator ruleIdGenerator, |
|||
IJsonSerializer jsonSerializer, |
|||
IOptions<AbpRulesEngineOptions> options) |
|||
: base(ruleCache, jsonSerializer) |
|||
{ |
|||
_ruleIdGenerator = ruleIdGenerator; |
|||
|
|||
_options = options.Value; |
|||
} |
|||
|
|||
protected override IFileProvider BuildFileProvider() |
|||
{ |
|||
// 未指定路径不启用
|
|||
if (!_options.PhysicalPath.IsNullOrWhiteSpace() && |
|||
Directory.Exists(_options.PhysicalPath)) |
|||
{ |
|||
return new PhysicalFileProvider(_options.PhysicalPath); |
|||
} |
|||
return null; |
|||
} |
|||
|
|||
protected override int GetRuleId<T>() => _ruleIdGenerator.CreateRuleId(typeof(T), _options.IgnoreMultiTenancy); |
|||
|
|||
protected override string GetRuleName<T>() => $"{_ruleIdGenerator.CreateRuleName(typeof(T), _options.IgnoreMultiTenancy)}.json"; |
|||
} |
|||
} |
|||
@ -0,0 +1,44 @@ |
|||
using Microsoft.Extensions.DependencyInjection; |
|||
using Microsoft.Extensions.FileProviders; |
|||
using Microsoft.Extensions.Options; |
|||
using System; |
|||
using System.IO; |
|||
using Volo.Abp.DependencyInjection; |
|||
|
|||
namespace LINGYUN.Abp.Rules.RulesEngine.FileProviders.Physical |
|||
{ |
|||
public class PhysicalFileWorkflowRulesResolveContributor : FileProviderWorkflowRulesResolveContributor, ISingletonDependency |
|||
{ |
|||
public override string Name => "PhysicalFile"; |
|||
|
|||
private RuleIdGenerator _ruleIdGenerator; |
|||
private AbpRulesEngineOptions _rulesEngineOptions; |
|||
private AbpRulesEnginePthsicalFileResolveOptions _fileResolveOptions; |
|||
|
|||
public PhysicalFileWorkflowRulesResolveContributor() |
|||
{ |
|||
} |
|||
|
|||
protected override void Initialize(IServiceProvider serviceProvider) |
|||
{ |
|||
_ruleIdGenerator = serviceProvider.GetRequiredService<RuleIdGenerator>(); |
|||
_rulesEngineOptions = serviceProvider.GetRequiredService<IOptions<AbpRulesEngineOptions>>().Value; |
|||
_fileResolveOptions = serviceProvider.GetRequiredService<IOptions<AbpRulesEnginePthsicalFileResolveOptions>>().Value; |
|||
} |
|||
|
|||
protected override IFileProvider BuildFileProvider(RulesInitializationContext context) |
|||
{ |
|||
// 未指定路径不启用
|
|||
if (!_fileResolveOptions.PhysicalPath.IsNullOrWhiteSpace() && |
|||
Directory.Exists(_fileResolveOptions.PhysicalPath)) |
|||
{ |
|||
return new PhysicalFileProvider(_fileResolveOptions.PhysicalPath); |
|||
} |
|||
return null; |
|||
} |
|||
|
|||
protected override int GetRuleId(Type type) => _ruleIdGenerator.CreateRuleId(type, _rulesEngineOptions.IgnoreMultiTenancy); |
|||
|
|||
protected override string GetRuleName(Type type) => $"{_ruleIdGenerator.CreateRuleName(type, _rulesEngineOptions.IgnoreMultiTenancy)}.json"; |
|||
} |
|||
} |
|||
@ -1,15 +0,0 @@ |
|||
using RulesEngine.Models; |
|||
using System.Threading; |
|||
using System.Threading.Tasks; |
|||
|
|||
namespace LINGYUN.Abp.Rules.RulesEngine |
|||
{ |
|||
public interface IWorkflowRulesContributor |
|||
{ |
|||
void Initialize(); |
|||
|
|||
Task<WorkflowRules[]> LoadAsync<T>(CancellationToken cancellationToken = default); |
|||
|
|||
void Shutdown(); |
|||
} |
|||
} |
|||
@ -0,0 +1,19 @@ |
|||
using JetBrains.Annotations; |
|||
using RulesEngine.Models; |
|||
using System; |
|||
using System.Collections.Generic; |
|||
using Volo.Abp.DependencyInjection; |
|||
|
|||
namespace LINGYUN.Abp.Rules.RulesEngine |
|||
{ |
|||
public interface IWorkflowRulesResolveContext : IServiceProviderAccessor |
|||
{ |
|||
[CanBeNull] |
|||
IEnumerable<WorkflowRules> WorkflowRules { get; set; } |
|||
|
|||
[NotNull] |
|||
Type Type { get; } |
|||
|
|||
bool Handled { get; set; } |
|||
} |
|||
} |
|||
@ -0,0 +1,15 @@ |
|||
using System.Threading.Tasks; |
|||
|
|||
namespace LINGYUN.Abp.Rules.RulesEngine |
|||
{ |
|||
public interface IWorkflowRulesResolveContributor |
|||
{ |
|||
string Name { get; } |
|||
|
|||
Task ResolveAsync(IWorkflowRulesResolveContext context); |
|||
|
|||
void Initialize(RulesInitializationContext context); |
|||
|
|||
void Shutdown(); |
|||
} |
|||
} |
|||
@ -0,0 +1,16 @@ |
|||
using JetBrains.Annotations; |
|||
using System; |
|||
using System.Threading.Tasks; |
|||
|
|||
namespace LINGYUN.Abp.Rules.RulesEngine |
|||
{ |
|||
public interface IWorkflowRulesResolver |
|||
{ |
|||
void Initialize(RulesInitializationContext context); |
|||
|
|||
[NotNull] |
|||
Task<WorkflowRulesResolveResult> ResolveWorkflowRulesAsync(Type type); |
|||
|
|||
void Shutdown(); |
|||
} |
|||
} |
|||
@ -1,25 +0,0 @@ |
|||
using RulesEngine.Models; |
|||
using System.Threading; |
|||
using System.Threading.Tasks; |
|||
using Volo.Abp.DependencyInjection; |
|||
|
|||
namespace LINGYUN.Abp.Rules.RulesEngine |
|||
{ |
|||
public class NullWorkflowRulesContributor : IWorkflowRulesContributor, ISingletonDependency |
|||
{ |
|||
public void Initialize() |
|||
{ |
|||
|
|||
} |
|||
|
|||
public Task<WorkflowRules[]> LoadAsync<T>(CancellationToken cancellationToken = default) |
|||
{ |
|||
return Task.FromResult(new WorkflowRules[0]); |
|||
} |
|||
|
|||
public void Shutdown() |
|||
{ |
|||
|
|||
} |
|||
} |
|||
} |
|||
@ -0,0 +1,16 @@ |
|||
using RulesEngine.Models; |
|||
using System; |
|||
using System.Collections.Generic; |
|||
using System.Threading; |
|||
using System.Threading.Tasks; |
|||
|
|||
namespace LINGYUN.Abp.Rules.RulesEngine.Persistent |
|||
{ |
|||
/// <summary>
|
|||
/// 实现此接口以用于从其他持久化存储中获取规则
|
|||
/// </summary>
|
|||
public interface IWorkflowRuleStore |
|||
{ |
|||
Task<IEnumerable<WorkflowRules>> GetRulesAsync(Type inputType, CancellationToken cancellationToken = default); |
|||
} |
|||
} |
|||
@ -0,0 +1,19 @@ |
|||
using RulesEngine.Models; |
|||
using System; |
|||
using System.Collections.Generic; |
|||
using System.Threading; |
|||
using System.Threading.Tasks; |
|||
using Volo.Abp.DependencyInjection; |
|||
|
|||
namespace LINGYUN.Abp.Rules.RulesEngine.Persistent |
|||
{ |
|||
[Dependency(TryRegister = true)] |
|||
public class NullWorkflowRuleStore : IWorkflowRuleStore, ISingletonDependency |
|||
{ |
|||
public Task<IEnumerable<WorkflowRules>> GetRulesAsync(Type inputType, CancellationToken cancellationToken = default) |
|||
{ |
|||
IEnumerable<WorkflowRules> rules = new WorkflowRules[0]; |
|||
return Task.FromResult(rules); |
|||
} |
|||
} |
|||
} |
|||
@ -0,0 +1,31 @@ |
|||
using Microsoft.Extensions.DependencyInjection; |
|||
using System.Threading.Tasks; |
|||
using Volo.Abp.DependencyInjection; |
|||
|
|||
namespace LINGYUN.Abp.Rules.RulesEngine.Persistent |
|||
{ |
|||
public class PersistentWorkflowRulesResolveContributor : WorkflowRulesResolveContributorBase, ITransientDependency |
|||
{ |
|||
private IWorkflowRuleStore _store; |
|||
public override string Name => "Persistent"; |
|||
|
|||
protected IWorkflowRuleStore Store => _store; |
|||
|
|||
public PersistentWorkflowRulesResolveContributor() |
|||
{ |
|||
} |
|||
|
|||
public override void Initialize(RulesInitializationContext context) |
|||
{ |
|||
_store = context.ServiceProvider.GetRequiredService<IWorkflowRuleStore>(); |
|||
} |
|||
|
|||
public override async Task ResolveAsync(IWorkflowRulesResolveContext context) |
|||
{ |
|||
var rules = await Store.GetRulesAsync(context.Type); |
|||
|
|||
context.Handled = true; |
|||
context.WorkflowRules = rules; |
|||
} |
|||
} |
|||
} |
|||
@ -0,0 +1,30 @@ |
|||
using JetBrains.Annotations; |
|||
using RulesEngine.Models; |
|||
using System; |
|||
using System.Collections.Generic; |
|||
using System.Linq; |
|||
using Volo.Abp; |
|||
|
|||
namespace LINGYUN.Abp.Rules.RulesEngine |
|||
{ |
|||
public class WorkflowRulesResolveContext : IWorkflowRulesResolveContext |
|||
{ |
|||
public Type Type { get; } |
|||
public IServiceProvider ServiceProvider { get; } |
|||
public IEnumerable<WorkflowRules> WorkflowRules { get; set; } |
|||
public bool Handled { get; set; } |
|||
|
|||
public bool HasResolved() |
|||
{ |
|||
return Handled && WorkflowRules?.Any() == true; |
|||
} |
|||
|
|||
public WorkflowRulesResolveContext( |
|||
[NotNull] Type type, |
|||
IServiceProvider serviceProvider) |
|||
{ |
|||
Type = Check.NotNull(type, nameof(type)); |
|||
ServiceProvider = serviceProvider; |
|||
} |
|||
} |
|||
} |
|||
@ -0,0 +1,18 @@ |
|||
using System.Threading.Tasks; |
|||
|
|||
namespace LINGYUN.Abp.Rules.RulesEngine |
|||
{ |
|||
public abstract class WorkflowRulesResolveContributorBase : IWorkflowRulesResolveContributor |
|||
{ |
|||
public abstract string Name { get; } |
|||
|
|||
public virtual void Initialize(RulesInitializationContext context) |
|||
{ |
|||
} |
|||
public abstract Task ResolveAsync(IWorkflowRulesResolveContext context); |
|||
|
|||
public virtual void Shutdown() |
|||
{ |
|||
} |
|||
} |
|||
} |
|||
@ -0,0 +1,18 @@ |
|||
using RulesEngine.Models; |
|||
using System.Collections.Generic; |
|||
|
|||
namespace LINGYUN.Abp.Rules.RulesEngine |
|||
{ |
|||
public class WorkflowRulesResolveResult |
|||
{ |
|||
public List<WorkflowRules> WorkflowRules { get; set; } |
|||
|
|||
public List<string> AppliedResolvers { get; } |
|||
|
|||
public WorkflowRulesResolveResult() |
|||
{ |
|||
AppliedResolvers = new List<string>(); |
|||
WorkflowRules = new List<WorkflowRules>(); |
|||
} |
|||
} |
|||
} |
|||
@ -0,0 +1,67 @@ |
|||
using Microsoft.Extensions.DependencyInjection; |
|||
using Microsoft.Extensions.Options; |
|||
using System; |
|||
using System.Threading.Tasks; |
|||
using Volo.Abp.DependencyInjection; |
|||
|
|||
namespace LINGYUN.Abp.Rules.RulesEngine |
|||
{ |
|||
public class WorkflowRulesResolver : IWorkflowRulesResolver, ITransientDependency |
|||
{ |
|||
private readonly IServiceProvider _serviceProvider; |
|||
private readonly AbpRulesEngineResolveOptions _options; |
|||
|
|||
public WorkflowRulesResolver( |
|||
IServiceProvider serviceProvider, |
|||
IOptions<AbpRulesEngineResolveOptions> options) |
|||
{ |
|||
_options = options.Value; |
|||
_serviceProvider = serviceProvider; |
|||
} |
|||
|
|||
public virtual void Initialize(RulesInitializationContext context) |
|||
{ |
|||
foreach (var workflowRulesResolver in _options.WorkflowRulesResolvers) |
|||
{ |
|||
workflowRulesResolver.Initialize(context); |
|||
} |
|||
} |
|||
|
|||
public virtual async Task<WorkflowRulesResolveResult> ResolveWorkflowRulesAsync(Type type) |
|||
{ |
|||
var result = new WorkflowRulesResolveResult(); |
|||
|
|||
using (var serviceScope = _serviceProvider.CreateScope()) |
|||
{ |
|||
var context = new WorkflowRulesResolveContext(type, serviceScope.ServiceProvider); |
|||
|
|||
foreach (var workflowRulesResolver in _options.WorkflowRulesResolvers) |
|||
{ |
|||
await workflowRulesResolver.ResolveAsync(context); |
|||
|
|||
result.AppliedResolvers.Add(workflowRulesResolver.Name); |
|||
|
|||
if (context.HasResolved()) |
|||
{ |
|||
result.WorkflowRules.AddRange(context.WorkflowRules); |
|||
|
|||
if (!_options.MergingRuels) |
|||
{ |
|||
break; |
|||
} |
|||
} |
|||
} |
|||
} |
|||
|
|||
return result; |
|||
} |
|||
|
|||
public virtual void Shutdown() |
|||
{ |
|||
foreach (var workflowRulesResolver in _options.WorkflowRulesResolvers) |
|||
{ |
|||
workflowRulesResolver.Shutdown(); |
|||
} |
|||
} |
|||
} |
|||
} |
|||
Loading…
Reference in new issue