From ebf95825152c927607df95c340d4a57580964091 Mon Sep 17 00:00:00 2001
From: cKey <35512826+colinin@users.noreply.github.com>
Date: Fri, 3 Dec 2021 17:49:03 +0800
Subject: [PATCH 1/2] feat(workflow): integrate WorkflowCore to support
workflow
---
...GYUN.Abp.WorkflowCore.Elasticsearch.csproj | 12 +
.../Elasticsearch/AbpElasticsearchIndexer.cs | 140 +++++++
.../AbpWorkflowCoreElasticsearchModule.cs | 24 ++
.../AbpWorkflowCoreElasticsearchOptions.cs | 14 +
.../Models/WorkflowSearchModel.cs | 120 ++++++
...YUN.Abp.WorkflowCore.LifeCycleEvent.csproj | 16 +
.../AbpEventBusLifeCycleEventHub.cs | 51 +++
.../AbpWorkflowCoreLifeCycleEventModule.cs | 24 ++
.../LifeCycleEvent/LifeCycleEventHandler.cs | 45 +++
...ore.Persistence.EntityFrameworkCore.csproj | 16 +
...orePersistenceEntityFrameworkCoreModule.cs | 23 ++
.../EfCoreWorkflowEventRepository.cs | 14 +
...CoreWorkflowEventSubscriptionRepository.cs | 15 +
.../EfCoreWorkflowExecutionErrorRepository.cs | 14 +
.../EfCoreWorkflowRepository.cs | 40 ++
...fCoreWorkflowScheduledCommandRepository.cs | 14 +
.../EntityFrameworkCore/IWorkflowDbContext.cs | 18 +
.../EntityFrameworkCore/WorkflowDbContext.cs | 29 ++
...WorkflowDbContextModelBuilderExtensions.cs | 103 +++++
...INGYUN.Abp.WorkflowCore.Persistence.csproj | 16 +
.../Definitions/WorkflowDefinition.cs | 47 +++
.../WorkflowDefinitionConditionCondition.cs | 30 ++
.../WorkflowDefinitionConditionNode.cs | 37 ++
.../WorkflowDefinitionExtensions.cs | 10 +
.../Definitions/WorkflowDefinitionFormData.cs | 52 +++
.../Definitions/WorkflowDefinitionNode.cs | 47 +++
.../Definitions/WorkflowDefinitionStepBody.cs | 28 ++
.../AbpWorkflowCorePersistenceModule.cs | 9 +
.../AbpWorkflowPersistenceProvider.cs | 354 ++++++++++++++++++
.../Persistence/IWorkflowEventRepository.cs | 9 +
.../IWorkflowEventSubscriptionRepository.cs | 9 +
.../IWorkflowExecutionErrorRepository.cs | 8 +
.../Persistence/IWorkflowRepository.cs | 21 ++
.../IWorkflowScheduledCommandRepository.cs | 8 +
.../Abp/WorkflowCore/Persistence/Workflow.cs | 101 +++++
.../Persistence/WorkflowDbProperties.cs | 9 +
.../WorkflowCore/Persistence/WorkflowEvent.cs | 47 +++
.../Persistence/WorkflowEventSubscription.cs | 73 ++++
.../Persistence/WorkflowExecutionError.cs | 34 ++
.../Persistence/WorkflowExecutionPointer.cs | 162 ++++++++
.../Persistence/WorkflowExtensionAttribute.cs | 31 ++
.../Persistence/WorkflowExtensions.cs | 113 ++++++
.../Persistence/WorkflowScheduledCommand.cs | 29 ++
.../WorkflowCore/Models/WorkflowExtensions.cs | 138 +++++++
.../LINGYUN.Abp.WorkflowCore.RabbitMQ.csproj | 16 +
.../AbpRabbitMQWorkflowCoreOptions.cs | 15 +
.../RabbitMQ/AbpRabbitMqQueueProvider.cs | 135 +++++++
.../RabbitMQ/AbpWorkflowCoreRabbitMQModule.cs | 24 ++
.../RabbitMQ/IQueueNameNormalizer.cs | 9 +
.../RabbitMQ/QueueNameNormalizer.cs | 23 ++
.../RabbitMQ/WorkflowQueueConfiguration.cs | 21 ++
.../LINGYUN.Abp.WorkflowCore.csproj | 14 +
.../AbpWorkflowCoreConventionalRegistrar.cs | 11 +
.../Abp/WorkflowCore/AbpWorkflowCoreModule.cs | 58 +++
.../WorkflowCore/AbpWorkflowCoreOptions.cs | 10 +
.../Abp/WorkflowCore/IWorkflowEnabled.cs | 6 +
.../Abp/WorkflowCore/IWorkflowManager.cs | 10 +
.../LINGYUN/Abp/WorkflowCore/NullStepBody.cs | 14 +
.../LINGYUN/Abp/WorkflowCore/WorkflowBase.cs | 14 +
.../WorkflowConditionCondition.cs | 9 +
.../Abp/WorkflowCore/WorkflowConditionNode.cs | 15 +
.../Abp/WorkflowCore/WorkflowDefinition.cs | 17 +
.../Abp/WorkflowCore/WorkflowFormData.cs | 24 ++
.../Abp/WorkflowCore/WorkflowManager.cs | 105 ++++++
.../LINGYUN/Abp/WorkflowCore/WorkflowNode.cs | 20 +
.../LINGYUN/Abp/WorkflowCore/WorkflowParam.cs | 10 +
.../WorkflowCore/WorkflowParamDictionary.cs | 8 +
.../Abp/WorkflowCore/WorkflowParamInput.cs | 8 +
.../Abp/WorkflowCore/WorkflowStepBody.cs | 17 +
.../System/ObjectSerializerExtensions.cs | 19 +
.../System/UtcDateTimeExtensions.cs | 19 +
.../LINGYUN.Abp.WorkflowCore.Tests.csproj | 17 +
.../WorkflowCore/AbpWorkflowCoreTestBase.cs | 8 +
.../WorkflowCore/AbpWorkflowCoreTestModule.cs | 11 +
74 files changed, 2841 insertions(+)
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Elasticsearch/LINGYUN.Abp.WorkflowCore.Elasticsearch.csproj
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Elasticsearch/LINGYUN/Abp/WorkflowCore/Elasticsearch/AbpElasticsearchIndexer.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Elasticsearch/LINGYUN/Abp/WorkflowCore/Elasticsearch/AbpWorkflowCoreElasticsearchModule.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Elasticsearch/LINGYUN/Abp/WorkflowCore/Elasticsearch/AbpWorkflowCoreElasticsearchOptions.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Elasticsearch/LINGYUN/Abp/WorkflowCore/Elasticsearch/Models/WorkflowSearchModel.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.LifeCycleEvent/LINGYUN.Abp.WorkflowCore.LifeCycleEvent.csproj
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.LifeCycleEvent/LINGYUN/Abp/WorkflowCore/LifeCycleEvent/AbpEventBusLifeCycleEventHub.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.LifeCycleEvent/LINGYUN/Abp/WorkflowCore/LifeCycleEvent/AbpWorkflowCoreLifeCycleEventModule.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.LifeCycleEvent/LINGYUN/Abp/WorkflowCore/LifeCycleEvent/LifeCycleEventHandler.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore.csproj
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/AbpWorkflowCorePersistenceEntityFrameworkCoreModule.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/EfCoreWorkflowEventRepository.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/EfCoreWorkflowEventSubscriptionRepository.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/EfCoreWorkflowExecutionErrorRepository.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/EfCoreWorkflowRepository.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/EfCoreWorkflowScheduledCommandRepository.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/IWorkflowDbContext.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/WorkflowDbContext.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/WorkflowDbContextModelBuilderExtensions.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN.Abp.WorkflowCore.Persistence.csproj
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Definitions/WorkflowDefinition.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Definitions/WorkflowDefinitionConditionCondition.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Definitions/WorkflowDefinitionConditionNode.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Definitions/WorkflowDefinitionExtensions.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Definitions/WorkflowDefinitionFormData.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Definitions/WorkflowDefinitionNode.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Definitions/WorkflowDefinitionStepBody.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/AbpWorkflowCorePersistenceModule.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/AbpWorkflowPersistenceProvider.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/IWorkflowEventRepository.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/IWorkflowEventSubscriptionRepository.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/IWorkflowExecutionErrorRepository.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/IWorkflowRepository.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/IWorkflowScheduledCommandRepository.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/Workflow.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/WorkflowDbProperties.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/WorkflowEvent.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/WorkflowEventSubscription.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/WorkflowExecutionError.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/WorkflowExecutionPointer.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/WorkflowExtensionAttribute.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/WorkflowExtensions.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/WorkflowScheduledCommand.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/WorkflowCore/Models/WorkflowExtensions.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.RabbitMQ/LINGYUN.Abp.WorkflowCore.RabbitMQ.csproj
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.RabbitMQ/LINGYUN/Abp/WorkflowCore/RabbitMQ/AbpRabbitMQWorkflowCoreOptions.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.RabbitMQ/LINGYUN/Abp/WorkflowCore/RabbitMQ/AbpRabbitMqQueueProvider.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.RabbitMQ/LINGYUN/Abp/WorkflowCore/RabbitMQ/AbpWorkflowCoreRabbitMQModule.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.RabbitMQ/LINGYUN/Abp/WorkflowCore/RabbitMQ/IQueueNameNormalizer.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.RabbitMQ/LINGYUN/Abp/WorkflowCore/RabbitMQ/QueueNameNormalizer.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.RabbitMQ/LINGYUN/Abp/WorkflowCore/RabbitMQ/WorkflowQueueConfiguration.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN.Abp.WorkflowCore.csproj
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/AbpWorkflowCoreConventionalRegistrar.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/AbpWorkflowCoreModule.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/AbpWorkflowCoreOptions.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/IWorkflowEnabled.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/IWorkflowManager.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/NullStepBody.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/WorkflowBase.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/WorkflowConditionCondition.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/WorkflowConditionNode.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/WorkflowDefinition.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/WorkflowFormData.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/WorkflowManager.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/WorkflowNode.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/WorkflowParam.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/WorkflowParamDictionary.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/WorkflowParamInput.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/WorkflowStepBody.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/System/ObjectSerializerExtensions.cs
create mode 100644 aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/System/UtcDateTimeExtensions.cs
create mode 100644 aspnet-core/tests/LINGYUN.Abp.WorkflowCore.Tests/LINGYUN.Abp.WorkflowCore.Tests.csproj
create mode 100644 aspnet-core/tests/LINGYUN.Abp.WorkflowCore.Tests/LINGYUN/Abp/WorkflowCore/AbpWorkflowCoreTestBase.cs
create mode 100644 aspnet-core/tests/LINGYUN.Abp.WorkflowCore.Tests/LINGYUN/Abp/WorkflowCore/AbpWorkflowCoreTestModule.cs
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Elasticsearch/LINGYUN.Abp.WorkflowCore.Elasticsearch.csproj b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Elasticsearch/LINGYUN.Abp.WorkflowCore.Elasticsearch.csproj
new file mode 100644
index 000000000..21aa9a59f
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Elasticsearch/LINGYUN.Abp.WorkflowCore.Elasticsearch.csproj
@@ -0,0 +1,12 @@
+
+
+
+ netstandard2.0
+
+
+
+
+
+
+
+
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Elasticsearch/LINGYUN/Abp/WorkflowCore/Elasticsearch/AbpElasticsearchIndexer.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Elasticsearch/LINGYUN/Abp/WorkflowCore/Elasticsearch/AbpElasticsearchIndexer.cs
new file mode 100644
index 000000000..81122060e
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Elasticsearch/LINGYUN/Abp/WorkflowCore/Elasticsearch/AbpElasticsearchIndexer.cs
@@ -0,0 +1,140 @@
+using LINGYUN.Abp.Elasticsearch;
+using LINGYUN.Abp.WorkflowCore.Elasticsearch.Models;
+using Microsoft.Extensions.Logging;
+using Microsoft.Extensions.Options;
+using Nest;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Linq.Expressions;
+using System.Threading.Tasks;
+using WorkflowCore.Interface;
+using WorkflowCore.Models;
+using WorkflowCore.Models.Search;
+
+namespace LINGYUN.Abp.WorkflowCore.Elasticsearch
+{
+ public class AbpElasticsearchIndexer : ISearchIndex
+ {
+ private IElasticClient _client;
+
+ private readonly IElasticsearchClientFactory _elasticsearchClientFactory;
+ private readonly AbpWorkflowCoreElasticsearchOptions _options;
+ private readonly ILogger _logger;
+
+ public AbpElasticsearchIndexer(
+ ILogger logger,
+ IOptions options,
+ IElasticsearchClientFactory elasticsearchClientFactory)
+ {
+ _logger = logger;
+ _options = options.Value;
+ _elasticsearchClientFactory = elasticsearchClientFactory;
+ }
+
+ public async Task IndexWorkflow(WorkflowInstance workflow)
+ {
+ if (_client == null)
+ throw new InvalidOperationException("Not started");
+
+ var denormModel = WorkflowSearchModel.FromWorkflowInstance(workflow);
+
+ var result = await _client.IndexAsync(
+ denormModel,
+ idx => idx.Index(_options.IndexFormat));
+
+ if (!result.ApiCall.Success)
+ {
+ _logger.LogError(default(EventId), result.ApiCall.OriginalException, $"Failed to index workflow {workflow.Id}");
+ throw new ApplicationException($"Failed to index workflow {workflow.Id}", result.ApiCall.OriginalException);
+ }
+ }
+
+ public async Task> Search(string terms, int skip, int take, params SearchFilter[] filters)
+ {
+ if (_client == null)
+ throw new InvalidOperationException("Not started");
+
+ var result = await _client.SearchAsync(s => s
+ .Index(_options.IndexFormat)
+ .Skip(skip)
+ .Take(take)
+ .MinScore(!string.IsNullOrEmpty(terms) ? 0.1 : 0)
+ .Query(query => query
+ .Bool(b => b
+ .Filter(BuildFilterQuery(filters))
+ .Should(
+ should => should.Match(t => t.Field(f => f.Reference).Query(terms).Boost(1.2)),
+ should => should.Match(t => t.Field(f => f.DataTokens).Query(terms).Boost(1.1)),
+ should => should.Match(t => t.Field(f => f.WorkflowDefinitionId).Query(terms).Boost(0.9)),
+ should => should.Match(t => t.Field(f => f.Status).Query(terms).Boost(0.9)),
+ should => should.Match(t => t.Field(f => f.Description).Query(terms))
+ )
+ )
+ )
+ );
+
+ return new Page
+ {
+ Total = result.Total,
+ Data = result.Hits.Select(x => x.Source).Select(x => x.ToSearchResult()).ToList()
+ };
+ }
+
+ public async Task Start()
+ {
+ _client = _elasticsearchClientFactory.Create();
+ var nodeInfo = await _client.Nodes.InfoAsync();
+ if (nodeInfo.Nodes.Values.Any(x => Convert.ToUInt32(x.Version.Split('.')[0]) < 6))
+ throw new NotSupportedException("Elasticsearch verison 6 or greater is required");
+
+ var exists = await _client.Indices.ExistsAsync(_options.IndexFormat);
+ if (!exists.Exists)
+ {
+ await _client.Indices.CreateAsync(_options.IndexFormat);
+ }
+ }
+
+ public Task Stop()
+ {
+ return Task.CompletedTask;
+ }
+
+ private List, QueryContainer>> BuildFilterQuery(SearchFilter[] filters)
+ {
+ var result = new List, QueryContainer>>();
+
+ foreach (var filter in filters)
+ {
+ var field = new Field(filter.Property);
+ if (filter.IsData)
+ {
+ Expression> dataExpr = x => x.Data[filter.DataType.FullName];
+ var fieldExpr = Expression.Convert(filter.Property, typeof(Func));
+ field = new Field(Expression.Lambda(Expression.Invoke(fieldExpr, dataExpr), Expression.Parameter(typeof(WorkflowSearchModel))));
+ }
+
+ switch (filter)
+ {
+ case ScalarFilter f:
+ result.Add(x => x.Match(t => t.Field(field).Query(Convert.ToString(f.Value))));
+ break;
+ case DateRangeFilter f:
+ if (f.BeforeValue.HasValue)
+ result.Add(x => x.DateRange(t => t.Field(field).LessThan(f.BeforeValue)));
+ if (f.AfterValue.HasValue)
+ result.Add(x => x.DateRange(t => t.Field(field).GreaterThan(f.AfterValue)));
+ break;
+ case NumericRangeFilter f:
+ if (f.LessValue.HasValue)
+ result.Add(x => x.Range(t => t.Field(field).LessThan(f.LessValue)));
+ if (f.GreaterValue.HasValue)
+ result.Add(x => x.Range(t => t.Field(field).GreaterThan(f.GreaterValue)));
+ break;
+ }
+ }
+
+ return result;
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Elasticsearch/LINGYUN/Abp/WorkflowCore/Elasticsearch/AbpWorkflowCoreElasticsearchModule.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Elasticsearch/LINGYUN/Abp/WorkflowCore/Elasticsearch/AbpWorkflowCoreElasticsearchModule.cs
new file mode 100644
index 000000000..0470be14a
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Elasticsearch/LINGYUN/Abp/WorkflowCore/Elasticsearch/AbpWorkflowCoreElasticsearchModule.cs
@@ -0,0 +1,24 @@
+using LINGYUN.Abp.Elasticsearch;
+using Microsoft.Extensions.DependencyInjection;
+using Volo.Abp.Modularity;
+using WorkflowCore.Interface;
+using WorkflowCore.Models;
+
+namespace LINGYUN.Abp.WorkflowCore.Elasticsearch
+{
+ [DependsOn(typeof(AbpWorkflowCoreModule))]
+ [DependsOn(typeof(AbpElasticsearchModule))]
+ public class AbpWorkflowCoreElasticsearchModule : AbpModule
+ {
+ public override void PreConfigureServices(ServiceConfigurationContext context)
+ {
+ context.Services.AddSingleton();
+ context.Services.AddSingleton();
+
+ PreConfigure(options =>
+ {
+ options.UseSearchIndex(provider => provider.GetRequiredService());
+ });
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Elasticsearch/LINGYUN/Abp/WorkflowCore/Elasticsearch/AbpWorkflowCoreElasticsearchOptions.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Elasticsearch/LINGYUN/Abp/WorkflowCore/Elasticsearch/AbpWorkflowCoreElasticsearchOptions.cs
new file mode 100644
index 000000000..414be43b8
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Elasticsearch/LINGYUN/Abp/WorkflowCore/Elasticsearch/AbpWorkflowCoreElasticsearchOptions.cs
@@ -0,0 +1,14 @@
+namespace LINGYUN.Abp.WorkflowCore.Elasticsearch
+{
+ public class AbpWorkflowCoreElasticsearchOptions
+ {
+ ///
+ /// Default value: "workflows".
+ ///
+ public string IndexFormat { get; set; }
+ public AbpWorkflowCoreElasticsearchOptions()
+ {
+ IndexFormat = "workflows";
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Elasticsearch/LINGYUN/Abp/WorkflowCore/Elasticsearch/Models/WorkflowSearchModel.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Elasticsearch/LINGYUN/Abp/WorkflowCore/Elasticsearch/Models/WorkflowSearchModel.cs
new file mode 100644
index 000000000..ec000ce50
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Elasticsearch/LINGYUN/Abp/WorkflowCore/Elasticsearch/Models/WorkflowSearchModel.cs
@@ -0,0 +1,120 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using WorkflowCore.Interface;
+using WorkflowCore.Models;
+using WorkflowCore.Models.Search;
+
+namespace LINGYUN.Abp.WorkflowCore.Elasticsearch.Models
+{
+ public class WorkflowSearchModel
+ {
+ public string Id { get; set; }
+
+ public string WorkflowDefinitionId { get; set; }
+
+ public int Version { get; set; }
+
+ public string Description { get; set; }
+
+ public string Reference { get; set; }
+
+ public DateTime? NextExecutionUtc { get; set; }
+
+ public string Status { get; set; }
+
+ public Dictionary Data { get; set; } = new Dictionary();
+
+ public IEnumerable DataTokens { get; set; }
+
+ public DateTime CreateTime { get; set; }
+
+ public DateTime? CompleteTime { get; set; }
+
+ public ICollection WaitingSteps { get; set; } = new HashSet();
+
+ public ICollection SleepingSteps { get; set; } = new HashSet();
+
+ public ICollection FailedSteps { get; set; } = new HashSet();
+
+ public WorkflowSearchResult ToSearchResult()
+ {
+ var result = new WorkflowSearchResult
+ {
+ Id = Id,
+ CompleteTime = CompleteTime,
+ CreateTime = CreateTime,
+ Description = Description,
+ NextExecutionUtc = NextExecutionUtc,
+ Reference = Reference,
+ Status = (WorkflowStatus)Enum.Parse(typeof(WorkflowStatus), Status, true),
+ Version = Version,
+ WorkflowDefinitionId = WorkflowDefinitionId,
+ FailedSteps = FailedSteps,
+ SleepingSteps = SleepingSteps,
+ WaitingSteps = WaitingSteps
+ };
+
+ if (Data.Count > 0)
+ result.Data = Data.First().Value;
+
+ return result;
+ }
+
+ public static WorkflowSearchModel FromWorkflowInstance(WorkflowInstance workflow)
+ {
+ var result = new WorkflowSearchModel();
+
+ result.Id = workflow.Id;
+ result.WorkflowDefinitionId = workflow.WorkflowDefinitionId;
+ result.Description = workflow.Description;
+ result.Reference = workflow.Reference;
+
+ if (workflow.Data != null)
+ result.Data.Add(workflow.Data.GetType().FullName, workflow.Data);
+
+ result.CompleteTime = workflow.CompleteTime;
+ result.CreateTime = workflow.CreateTime;
+ result.Version = workflow.Version;
+ result.Status = workflow.Status.ToString();
+
+ if (workflow.NextExecution.HasValue)
+ result.NextExecutionUtc = new DateTime(workflow.NextExecution.Value);
+
+ if (workflow.Data is ISearchable)
+ result.DataTokens = (workflow.Data as ISearchable).GetSearchTokens();
+
+ foreach (var ep in workflow.ExecutionPointers)
+ {
+ if (ep.Status == PointerStatus.Sleeping)
+ {
+ result.SleepingSteps.Add(new StepInfo
+ {
+ StepId = ep.StepId,
+ Name = ep.StepName
+ });
+ }
+
+ if (ep.Status == PointerStatus.WaitingForEvent)
+ {
+ result.WaitingSteps.Add(new StepInfo
+ {
+ StepId = ep.StepId,
+ Name = ep.StepName
+ });
+ }
+
+ if (ep.Status == PointerStatus.Failed)
+ {
+ result.FailedSteps.Add(new StepInfo
+ {
+ StepId = ep.StepId,
+ Name = ep.StepName
+ });
+ }
+ }
+
+ return result;
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.LifeCycleEvent/LINGYUN.Abp.WorkflowCore.LifeCycleEvent.csproj b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.LifeCycleEvent/LINGYUN.Abp.WorkflowCore.LifeCycleEvent.csproj
new file mode 100644
index 000000000..0131c6f7e
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.LifeCycleEvent/LINGYUN.Abp.WorkflowCore.LifeCycleEvent.csproj
@@ -0,0 +1,16 @@
+
+
+
+ netstandard2.0
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.LifeCycleEvent/LINGYUN/Abp/WorkflowCore/LifeCycleEvent/AbpEventBusLifeCycleEventHub.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.LifeCycleEvent/LINGYUN/Abp/WorkflowCore/LifeCycleEvent/AbpEventBusLifeCycleEventHub.cs
new file mode 100644
index 000000000..080ce5e75
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.LifeCycleEvent/LINGYUN/Abp/WorkflowCore/LifeCycleEvent/AbpEventBusLifeCycleEventHub.cs
@@ -0,0 +1,51 @@
+using Microsoft.Extensions.Logging;
+using System;
+using System.Threading.Tasks;
+using Volo.Abp.EventBus.Distributed;
+using WorkflowCore.Interface;
+using EventData = WorkflowCore.Models.LifeCycleEvents.LifeCycleEvent;
+
+namespace LINGYUN.Abp.WorkflowCore.LifeCycleEvent
+{
+ public class AbpEventBusLifeCycleEventHub : ILifeCycleEventHub
+ {
+ private IDisposable _subscriber;
+
+ private readonly IDistributedEventBus _eventBus;
+ private readonly ILoggerFactory _loggerFactory;
+
+ public AbpEventBusLifeCycleEventHub(
+ ILoggerFactory loggerFactory,
+ IDistributedEventBus distributedEventBus)
+ {
+ _loggerFactory = loggerFactory;
+ _eventBus = distributedEventBus;
+ }
+
+ public async Task PublishNotification(EventData evt)
+ {
+ await _eventBus.PublishAsync(evt);
+ }
+
+ public Task Start()
+ {
+ _subscriber = _eventBus.Subscribe(new LifeCycleEventHandler(
+ _loggerFactory.CreateLogger()));
+
+ return Task.CompletedTask;
+ }
+
+ public Task Stop()
+ {
+ // TODO
+ _subscriber?.Dispose();
+
+ return Task.CompletedTask;
+ }
+
+ public void Subscribe(Action action)
+ {
+ LifeCycleEventHandler.Subscribers.Add(action);
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.LifeCycleEvent/LINGYUN/Abp/WorkflowCore/LifeCycleEvent/AbpWorkflowCoreLifeCycleEventModule.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.LifeCycleEvent/LINGYUN/Abp/WorkflowCore/LifeCycleEvent/AbpWorkflowCoreLifeCycleEventModule.cs
new file mode 100644
index 000000000..1f15011dc
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.LifeCycleEvent/LINGYUN/Abp/WorkflowCore/LifeCycleEvent/AbpWorkflowCoreLifeCycleEventModule.cs
@@ -0,0 +1,24 @@
+using Microsoft.Extensions.DependencyInjection;
+using Volo.Abp.EventBus;
+using Volo.Abp.Modularity;
+using WorkflowCore.Interface;
+using WorkflowCore.Models;
+
+namespace LINGYUN.Abp.WorkflowCore.LifeCycleEvent
+{
+ [DependsOn(typeof(AbpEventBusModule))]
+ [DependsOn(typeof(AbpWorkflowCoreModule))]
+ public class AbpWorkflowCoreLifeCycleEventModule : AbpModule
+ {
+ public override void PreConfigureServices(ServiceConfigurationContext context)
+ {
+ context.Services.AddSingleton();
+ context.Services.AddSingleton();
+
+ PreConfigure(options =>
+ {
+ options.UseEventHub(provider => provider.GetRequiredService());
+ });
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.LifeCycleEvent/LINGYUN/Abp/WorkflowCore/LifeCycleEvent/LifeCycleEventHandler.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.LifeCycleEvent/LINGYUN/Abp/WorkflowCore/LifeCycleEvent/LifeCycleEventHandler.cs
new file mode 100644
index 000000000..dbffbd847
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.LifeCycleEvent/LINGYUN/Abp/WorkflowCore/LifeCycleEvent/LifeCycleEventHandler.cs
@@ -0,0 +1,45 @@
+using Microsoft.Extensions.Logging;
+using System;
+using System.Collections.Generic;
+using System.Threading.Tasks;
+using Volo.Abp.EventBus.Distributed;
+using EventData = WorkflowCore.Models.LifeCycleEvents.LifeCycleEvent;
+
+namespace LINGYUN.Abp.WorkflowCore.LifeCycleEvent
+{
+ public class LifeCycleEventHandler : IDistributedEventHandler
+ {
+ private readonly ILogger _logger;
+
+ internal static readonly ICollection> Subscribers = new HashSet>();
+
+ public LifeCycleEventHandler(
+ ILogger logger)
+ {
+ _logger = logger;
+ }
+
+ public Task HandleEventAsync(EventData eventData)
+ {
+ NotifySubscribers(eventData);
+
+ return Task.CompletedTask;
+ }
+
+ private void NotifySubscribers(EventData evt)
+ {
+ foreach (var subscriber in Subscribers)
+ {
+ try
+ {
+ subscriber(evt);
+ }
+ catch (Exception ex)
+ {
+ _logger.LogWarning(
+ default, ex, $"Error on event subscriber: {ex.Message}");
+ }
+ }
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore.csproj b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore.csproj
new file mode 100644
index 000000000..d6bccfbda
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore.csproj
@@ -0,0 +1,16 @@
+
+
+
+ netstandard2.1
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/AbpWorkflowCorePersistenceEntityFrameworkCoreModule.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/AbpWorkflowCorePersistenceEntityFrameworkCoreModule.cs
new file mode 100644
index 000000000..73a2adb87
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/AbpWorkflowCorePersistenceEntityFrameworkCoreModule.cs
@@ -0,0 +1,23 @@
+using Microsoft.Extensions.DependencyInjection;
+using Volo.Abp.EntityFrameworkCore;
+using Volo.Abp.Modularity;
+
+namespace LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore
+{
+ [DependsOn(typeof(AbpWorkflowCorePersistenceModule))]
+ [DependsOn(typeof(AbpEntityFrameworkCoreModule))]
+ public class AbpWorkflowCorePersistenceEntityFrameworkCoreModule : AbpModule
+ {
+ public override void ConfigureServices(ServiceConfigurationContext context)
+ {
+ context.Services.AddAbpDbContext(options =>
+ {
+ options.AddRepository();
+ options.AddRepository();
+ options.AddRepository();
+ options.AddRepository();
+ options.AddRepository();
+ });
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/EfCoreWorkflowEventRepository.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/EfCoreWorkflowEventRepository.cs
new file mode 100644
index 000000000..48a8035d5
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/EfCoreWorkflowEventRepository.cs
@@ -0,0 +1,14 @@
+using System;
+using Volo.Abp.Domain.Repositories.EntityFrameworkCore;
+using Volo.Abp.EntityFrameworkCore;
+
+namespace LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore
+{
+ public class EfCoreWorkflowEventRepository : EfCoreRepository, IWorkflowEventRepository
+ {
+ public EfCoreWorkflowEventRepository(IDbContextProvider dbContextProvider)
+ : base(dbContextProvider)
+ {
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/EfCoreWorkflowEventSubscriptionRepository.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/EfCoreWorkflowEventSubscriptionRepository.cs
new file mode 100644
index 000000000..406a6f258
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/EfCoreWorkflowEventSubscriptionRepository.cs
@@ -0,0 +1,15 @@
+using LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore;
+using System;
+using Volo.Abp.Domain.Repositories.EntityFrameworkCore;
+using Volo.Abp.EntityFrameworkCore;
+
+namespace LINGYUN.Abp.WorkflowCore.Persistence
+{
+ public class EfCoreWorkflowEventSubscriptionRepository : EfCoreRepository, IWorkflowEventSubscriptionRepository
+ {
+ public EfCoreWorkflowEventSubscriptionRepository(IDbContextProvider dbContextProvider)
+ : base(dbContextProvider)
+ {
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/EfCoreWorkflowExecutionErrorRepository.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/EfCoreWorkflowExecutionErrorRepository.cs
new file mode 100644
index 000000000..84787e017
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/EfCoreWorkflowExecutionErrorRepository.cs
@@ -0,0 +1,14 @@
+using LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore;
+using Volo.Abp.Domain.Repositories.EntityFrameworkCore;
+using Volo.Abp.EntityFrameworkCore;
+
+namespace LINGYUN.Abp.WorkflowCore.Persistence
+{
+ public class EfCoreWorkflowExecutionErrorRepository : EfCoreRepository, IWorkflowExecutionErrorRepository
+ {
+ public EfCoreWorkflowExecutionErrorRepository(IDbContextProvider dbContextProvider)
+ : base(dbContextProvider)
+ {
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/EfCoreWorkflowRepository.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/EfCoreWorkflowRepository.cs
new file mode 100644
index 000000000..9385fdbdb
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/EfCoreWorkflowRepository.cs
@@ -0,0 +1,40 @@
+using LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading;
+using System.Threading.Tasks;
+using Volo.Abp.Domain.Repositories.EntityFrameworkCore;
+using Volo.Abp.EntityFrameworkCore;
+using WorkflowCore.Models;
+
+namespace LINGYUN.Abp.WorkflowCore.Persistence
+{
+ public class EfCoreWorkflowRepository : EfCoreRepository, IWorkflowRepository
+ {
+ public EfCoreWorkflowRepository(IDbContextProvider dbContextProvider)
+ : base(dbContextProvider)
+ {
+ }
+
+ public virtual async Task> GetListAsync(
+ WorkflowStatus? status,
+ string type,
+ DateTime? createdFrom,
+ DateTime? createdTo,
+ int skip,
+ int take,
+ CancellationToken cancellationToken = default)
+ {
+ return await (await GetDbSetAsync())
+ .Include(x => x.ExecutionPointers)
+ .WhereIf(status.HasValue, x => x.Status == status.Value)
+ .WhereIf(!type.IsNullOrWhiteSpace(), x => x.WorkflowDefinitionId.Equals(type))
+ .WhereIf(createdFrom.HasValue, x => x.CreationTime >= createdFrom.Value)
+ .WhereIf(createdTo.HasValue, x => x.CreationTime <= createdTo.Value)
+ .PageBy(skip, take)
+ .ToListAsync();
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/EfCoreWorkflowScheduledCommandRepository.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/EfCoreWorkflowScheduledCommandRepository.cs
new file mode 100644
index 000000000..e6f7cb8e7
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/EfCoreWorkflowScheduledCommandRepository.cs
@@ -0,0 +1,14 @@
+using LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore;
+using Volo.Abp.Domain.Repositories.EntityFrameworkCore;
+using Volo.Abp.EntityFrameworkCore;
+
+namespace LINGYUN.Abp.WorkflowCore.Persistence
+{
+ public class EfCoreWorkflowScheduledCommandRepository : EfCoreRepository, IWorkflowScheduledCommandRepository
+ {
+ public EfCoreWorkflowScheduledCommandRepository(IDbContextProvider dbContextProvider)
+ : base(dbContextProvider)
+ {
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/IWorkflowDbContext.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/IWorkflowDbContext.cs
new file mode 100644
index 000000000..19257a4a8
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/IWorkflowDbContext.cs
@@ -0,0 +1,18 @@
+using Microsoft.EntityFrameworkCore;
+using Volo.Abp.Data;
+using Volo.Abp.EntityFrameworkCore;
+
+namespace LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore
+{
+ [ConnectionStringName(WorkflowDbProperties.ConnectionStringName)]
+ public interface IWorkflowDbContext : IEfCoreDbContext
+ {
+ DbSet Workflows { get; set; }
+ DbSet WorkflowEvents { get; set; }
+ DbSet WorkflowEventSubscriptions { get; set; }
+ DbSet WorkflowExecutionErrors { get; set; }
+ DbSet WorkflowExecutionPointers { get; set; }
+ DbSet WorkflowExtensionAttributes { get; set; }
+ DbSet WorkflowScheduledCommands { get; set; }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/WorkflowDbContext.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/WorkflowDbContext.cs
new file mode 100644
index 000000000..cc883bed4
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/WorkflowDbContext.cs
@@ -0,0 +1,29 @@
+using Microsoft.EntityFrameworkCore;
+using Volo.Abp.Data;
+using Volo.Abp.EntityFrameworkCore;
+
+namespace LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore
+{
+ [ConnectionStringName(WorkflowDbProperties.ConnectionStringName)]
+ public class WorkflowDbContext : AbpDbContext, IWorkflowDbContext
+ {
+ public virtual DbSet Workflows { get; set; }
+ public virtual DbSet WorkflowEvents { get; set; }
+ public virtual DbSet WorkflowEventSubscriptions { get; set; }
+ public virtual DbSet WorkflowExecutionErrors { get; set; }
+ public virtual DbSet WorkflowExecutionPointers { get; set; }
+ public virtual DbSet WorkflowExtensionAttributes { get; set; }
+ public virtual DbSet WorkflowScheduledCommands { get; set; }
+
+ public WorkflowDbContext(DbContextOptions options) : base(options)
+ {
+ }
+
+ protected override void OnModelCreating(ModelBuilder modelBuilder)
+ {
+ base.OnModelCreating(modelBuilder);
+
+ modelBuilder.ConfigureWorkflow();
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/WorkflowDbContextModelBuilderExtensions.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/WorkflowDbContextModelBuilderExtensions.cs
new file mode 100644
index 000000000..fb6a2bb94
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore/LINGYUN/Abp/WorkflowCore/Persistence/EntityFrameworkCore/WorkflowDbContextModelBuilderExtensions.cs
@@ -0,0 +1,103 @@
+using JetBrains.Annotations;
+using Microsoft.EntityFrameworkCore;
+using Volo.Abp;
+using Volo.Abp.EntityFrameworkCore.Modeling;
+
+namespace LINGYUN.Abp.WorkflowCore.Persistence.EntityFrameworkCore
+{
+ public static class WorkflowDbContextModelBuilderExtensions
+ {
+ public static void ConfigureWorkflow([NotNull] this ModelBuilder builder)
+ {
+ Check.NotNull(builder, nameof(builder));
+
+ builder.Entity(b =>
+ {
+ b.ToTable(WorkflowDbProperties.TablePrefix + "Workflow");
+
+ b.Property(p => p.WorkflowDefinitionId).HasMaxLength(200);
+ b.Property(p => p.Description).HasMaxLength(500);
+ b.Property(p => p.Reference).HasMaxLength(200);
+
+ b.ConfigureByConvention();
+
+ b.HasIndex(p => p.NextExecution);
+ });
+
+ builder.Entity(b =>
+ {
+ b.ToTable(WorkflowDbProperties.TablePrefix + "ExecutionPointer");
+
+ b.Property(p => p.Id).HasMaxLength(50);
+ b.Property(p => p.EventName).HasMaxLength(200);
+ b.Property(p => p.EventKey).HasMaxLength(200);
+ b.Property(p => p.StepName).HasMaxLength(100);
+ b.Property(p => p.PredecessorId).HasMaxLength(100);
+
+ b.ConfigureByConvention();
+ });
+
+ builder.Entity(b =>
+ {
+ b.ToTable(WorkflowDbProperties.TablePrefix + "ExtensionAttribute");
+
+ b.Property(p => p.Key).HasMaxLength(100);
+ b.Property(p => p.ExecutionPointerId).HasMaxLength(50);
+
+ b.ConfigureByConvention();
+ });
+
+ builder.Entity(b =>
+ {
+ b.ToTable(WorkflowDbProperties.TablePrefix + "Event");
+
+ b.Property(p => p.EventName).HasMaxLength(200);
+ b.Property(p => p.EventKey).HasMaxLength(200);
+
+ b.ConfigureByConvention();
+
+ b.HasIndex(x => new { x.EventName, x.EventKey });
+ b.HasIndex(x => x.CreationTime);
+ b.HasIndex(x => x.IsProcessed);
+ });
+
+ builder.Entity(b =>
+ {
+ b.ToTable(WorkflowDbProperties.TablePrefix + "Subscription");
+
+ b.Property(p => p.ExecutionPointerId).HasMaxLength(50);
+ b.Property(p => p.EventName).HasMaxLength(200);
+ b.Property(p => p.EventKey).HasMaxLength(200);
+ b.Property(p => p.ExternalToken).HasMaxLength(200);
+ b.Property(p => p.ExternalWorkerId).HasMaxLength(200);
+
+ b.ConfigureByConvention();
+
+ b.HasIndex(x => x.EventName);
+ b.HasIndex(x => x.EventKey);
+ });
+
+ builder.Entity(b =>
+ {
+ b.ToTable(WorkflowDbProperties.TablePrefix + "ExecutionError");
+
+ b.Property(p => p.ExecutionPointerId).HasMaxLength(50);
+
+ b.ConfigureByConvention();
+ });
+
+ builder.Entity(b =>
+ {
+ b.ToTable(WorkflowDbProperties.TablePrefix + "ScheduledCommand");
+
+ b.Property(p => p.CommandName).HasMaxLength(200);
+ b.Property(p => p.Data).HasMaxLength(500);
+
+ b.ConfigureByConvention();
+
+ b.HasIndex(x => x.ExecuteTime);
+ b.HasIndex(x => new { x.CommandName, x.Data }).IsUnique();
+ });
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN.Abp.WorkflowCore.Persistence.csproj b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN.Abp.WorkflowCore.Persistence.csproj
new file mode 100644
index 000000000..a48c88143
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN.Abp.WorkflowCore.Persistence.csproj
@@ -0,0 +1,16 @@
+
+
+
+ netstandard2.0
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Definitions/WorkflowDefinition.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Definitions/WorkflowDefinition.cs
new file mode 100644
index 000000000..73162e027
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Definitions/WorkflowDefinition.cs
@@ -0,0 +1,47 @@
+using System;
+using System.Collections.Generic;
+using System.Collections.ObjectModel;
+using Volo.Abp.Domain.Entities.Auditing;
+using Volo.Abp.MultiTenancy;
+
+namespace LINGYUN.Abp.WorkflowCore.Definitions
+{
+ public class WorkflowDefinition : FullAuditedAggregateRoot, IMultiTenant
+ {
+ public virtual Guid? TenantId { get; protected set; }
+ public string Title { get; protected set; }
+ public int Version { get; protected set; }
+ public string Description { get; protected set; }
+ public string Icon { get; protected set; }
+ public string Color { get; protected set; }
+ public string Group { get; protected set; }
+ public ICollection Nodes { get; protected set; }
+ public ICollection Inputs { get; protected set; }
+ protected WorkflowDefinition()
+ {
+ Nodes = new Collection();
+ Inputs = new Collection();
+ }
+ public WorkflowDefinition(
+ Guid id,
+ string title,
+ int version,
+ string group,
+ string icon,
+ string color,
+ string description = null,
+ Guid? tenantId = null) : base(id)
+ {
+ Title = title;
+ Version = version;
+ Group = group;
+ Icon = icon;
+ Color = color;
+ Description = description;
+ TenantId = tenantId;
+
+ Nodes = new Collection();
+ Inputs = new Collection();
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Definitions/WorkflowDefinitionConditionCondition.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Definitions/WorkflowDefinitionConditionCondition.cs
new file mode 100644
index 000000000..4c26893be
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Definitions/WorkflowDefinitionConditionCondition.cs
@@ -0,0 +1,30 @@
+using System;
+using Volo.Abp.Domain.Entities;
+using Volo.Abp.MultiTenancy;
+
+namespace LINGYUN.Abp.WorkflowCore.Definitions
+{
+ public class WorkflowDefinitionConditionCondition : Entity, IMultiTenant
+ {
+ public virtual Guid? TenantId { get; protected set; }
+ public virtual Guid ParentId { get; protected set; }
+ public virtual WorkflowDefinitionConditionNode ConditionNode { get; protected set; }
+ public virtual string Field { get; set; }
+ public virtual string Operator { get; set; }
+ public virtual string Value { get; set; }
+ protected WorkflowDefinitionConditionCondition() { }
+ public WorkflowDefinitionConditionCondition(
+ Guid parentId,
+ string field,
+ string opt,
+ string value,
+ Guid? tenantId = null)
+ {
+ ParentId = parentId;
+ Field = field;
+ Operator = opt;
+ Value = value;
+ TenantId = tenantId;
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Definitions/WorkflowDefinitionConditionNode.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Definitions/WorkflowDefinitionConditionNode.cs
new file mode 100644
index 000000000..d8b8fbef9
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Definitions/WorkflowDefinitionConditionNode.cs
@@ -0,0 +1,37 @@
+using System;
+using System.Collections.Generic;
+using System.Collections.ObjectModel;
+using Volo.Abp.Domain.Entities;
+using Volo.Abp.MultiTenancy;
+
+namespace LINGYUN.Abp.WorkflowCore.Definitions
+{
+ public class WorkflowDefinitionConditionNode : Entity, IMultiTenant
+ {
+ public virtual Guid? TenantId { get; protected set; }
+ public virtual Guid ParentId { get; protected set; }
+ public virtual WorkflowDefinitionNode Node { get; protected set; }
+ public virtual string Label { get; protected set; }
+ public virtual string NodeId { get; protected set; }
+ public virtual ICollection Conditions { get; protected set; }
+
+ protected WorkflowDefinitionConditionNode()
+ {
+ Conditions = new Collection();
+ }
+
+ public WorkflowDefinitionConditionNode(
+ Guid parentId,
+ string label,
+ string nodeId,
+ Guid? tenantId = null)
+ {
+ ParentId = parentId;
+ Label = label;
+ NodeId = nodeId;
+ TenantId = tenantId;
+
+ Conditions = new Collection();
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Definitions/WorkflowDefinitionExtensions.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Definitions/WorkflowDefinitionExtensions.cs
new file mode 100644
index 000000000..f89e02aab
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Definitions/WorkflowDefinitionExtensions.cs
@@ -0,0 +1,10 @@
+using System;
+using System.Collections.Generic;
+using System.Text;
+
+namespace LINGYUN.Abp.WorkflowCore.Definitions
+{
+ public class WorkflowDefinitionExtensions
+ {
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Definitions/WorkflowDefinitionFormData.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Definitions/WorkflowDefinitionFormData.cs
new file mode 100644
index 000000000..ca7b98650
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Definitions/WorkflowDefinitionFormData.cs
@@ -0,0 +1,52 @@
+using System;
+using Volo.Abp.Data;
+using Volo.Abp.Domain.Entities;
+using Volo.Abp.MultiTenancy;
+
+namespace LINGYUN.Abp.WorkflowCore.Definitions
+{
+ public class WorkflowDefinitionFormData : Entity, IMultiTenant
+ {
+ public virtual Guid? TenantId { get; protected set; }
+ public virtual Guid WorkflowId { get; protected set; }
+ public virtual WorkflowDefinition Workflow { get; protected set; }
+ public virtual string Name { get; protected set; }
+ public virtual string Label { get; protected set; }
+ public virtual string Type { get; protected set; }
+ public virtual string Value { get; protected set; }
+ public virtual ExtraPropertyDictionary Styles { get; protected set; }
+ public virtual int? MaxLength { get; protected set; }
+ public virtual int? MinLength { get; protected set; }
+ public virtual ExtraPropertyDictionary Items { get; protected set; }
+ public virtual ExtraPropertyDictionary Rules { get; protected set; }
+ protected WorkflowDefinitionFormData()
+ {
+ Styles = new ExtraPropertyDictionary();
+ Items = new ExtraPropertyDictionary();
+ Rules = new ExtraPropertyDictionary();
+ }
+ public WorkflowDefinitionFormData(
+ Guid workflowId,
+ string name,
+ string label,
+ string type,
+ string value,
+ int? minLength = null,
+ int? maxLength = null,
+ Guid? tenantId = null)
+ {
+ WorkflowId = workflowId;
+ Name = name;
+ Label = label;
+ Type = type;
+ Value = value;
+ MinLength = minLength;
+ MaxLength = maxLength;
+ TenantId = tenantId;
+
+ Styles = new ExtraPropertyDictionary();
+ Items = new ExtraPropertyDictionary();
+ Rules = new ExtraPropertyDictionary();
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Definitions/WorkflowDefinitionNode.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Definitions/WorkflowDefinitionNode.cs
new file mode 100644
index 000000000..fb93a2789
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Definitions/WorkflowDefinitionNode.cs
@@ -0,0 +1,47 @@
+using System;
+using System.Collections.Generic;
+using System.Collections.ObjectModel;
+using Volo.Abp.Domain.Entities;
+using Volo.Abp.MultiTenancy;
+
+namespace LINGYUN.Abp.WorkflowCore.Definitions
+{
+ public class WorkflowDefinitionNode : Entity, IMultiTenant
+ {
+ public virtual Guid? TenantId { get; protected set; }
+ public virtual Guid WorkflowId { get; protected set; }
+ public virtual WorkflowDefinition Workflow { get; protected set; }
+ public virtual string Key { get; protected set; }
+ public virtual string Title { get; protected set; }
+ public virtual string Position { get; protected set; }
+ public virtual string Type { get; protected set; }
+ public virtual WorkflowDefinitionStepBody StepBody { get; protected set; }
+ public virtual string ParentNodes { get; protected set; }
+ public virtual ICollection NextNodes { get; protected set; }
+ protected WorkflowDefinitionNode()
+ {
+ NextNodes = new Collection();
+ }
+ public WorkflowDefinitionNode(
+ Guid workflowId,
+ string key,
+ string title,
+ int[] position,
+ string type,
+ WorkflowDefinitionStepBody stepBody,
+ string[] parentNodes,
+ Guid? tenantId = null)
+ {
+ WorkflowId = workflowId;
+ Key = key;
+ Title = title;
+ Position = position.JoinAsString(";");
+ Type = type;
+ StepBody = stepBody;
+ ParentNodes = parentNodes.JoinAsString(";");
+ TenantId = tenantId;
+
+ NextNodes = new Collection();
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Definitions/WorkflowDefinitionStepBody.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Definitions/WorkflowDefinitionStepBody.cs
new file mode 100644
index 000000000..e4aa96165
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Definitions/WorkflowDefinitionStepBody.cs
@@ -0,0 +1,28 @@
+using System;
+using Volo.Abp.Data;
+using Volo.Abp.Domain.Entities;
+using Volo.Abp.MultiTenancy;
+
+namespace LINGYUN.Abp.WorkflowCore.Definitions
+{
+ public class WorkflowDefinitionStepBody : Entity, IMultiTenant, IHasExtraProperties
+ {
+ public virtual Guid? TenantId { get; protected set; }
+ public virtual string Name { get; protected set; }
+ public ExtraPropertyDictionary ExtraProperties { get; protected set; }
+ protected WorkflowDefinitionStepBody()
+ {
+ ExtraProperties = new ExtraPropertyDictionary();
+ this.SetDefaultsForExtraProperties();
+ }
+ public WorkflowDefinitionStepBody(
+ Guid id,
+ string name) : base(id)
+ {
+ Name = name;
+
+ ExtraProperties = new ExtraPropertyDictionary();
+ this.SetDefaultsForExtraProperties();
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/AbpWorkflowCorePersistenceModule.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/AbpWorkflowCorePersistenceModule.cs
new file mode 100644
index 000000000..ac147ddb6
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/AbpWorkflowCorePersistenceModule.cs
@@ -0,0 +1,9 @@
+using Volo.Abp.Modularity;
+
+namespace LINGYUN.Abp.WorkflowCore.Persistence
+{
+ [DependsOn(typeof(AbpWorkflowCoreModule))]
+ public class AbpWorkflowCorePersistenceModule : AbpModule
+ {
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/AbpWorkflowPersistenceProvider.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/AbpWorkflowPersistenceProvider.cs
new file mode 100644
index 000000000..51fdfd226
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/AbpWorkflowPersistenceProvider.cs
@@ -0,0 +1,354 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading;
+using System.Threading.Tasks;
+using Volo.Abp.DependencyInjection;
+using Volo.Abp.Guids;
+using Volo.Abp.Linq;
+using Volo.Abp.MultiTenancy;
+using Volo.Abp.Uow;
+using WorkflowCore.Interface;
+using WorkflowCore.Models;
+
+namespace LINGYUN.Abp.WorkflowCore.Persistence
+{
+ public class AbpWorkflowPersistenceProvider : IPersistenceProvider, IUnitOfWorkEnabled, ITransientDependency
+ {
+ private readonly ICurrentTenant _currentTenant;
+ private readonly IGuidGenerator _guidGenerator;
+ private readonly IWorkflowRepository _workflowRepository;
+ private readonly IWorkflowEventRepository _workflowEventRepository;
+ private readonly IWorkflowExecutionErrorRepository _executionErrorRepository;
+ private readonly IWorkflowEventSubscriptionRepository _subscriptionRepository;
+ private readonly IWorkflowScheduledCommandRepository _scheduledCommandRepository;
+
+ private readonly IAsyncQueryableExecuter _asyncQueryableExecuter;
+
+ public bool SupportsScheduledCommands => true;
+
+ public AbpWorkflowPersistenceProvider(
+ ICurrentTenant currentTenant,
+ IGuidGenerator guidGenerator,
+ IAsyncQueryableExecuter asyncQueryableExecuter,
+ IWorkflowRepository workflowRepository,
+ IWorkflowEventRepository workflowEventRepository,
+ IWorkflowExecutionErrorRepository executionErrorRepository,
+ IWorkflowEventSubscriptionRepository subscriptionRepository,
+ IWorkflowScheduledCommandRepository scheduledCommandRepository)
+ {
+ _currentTenant = currentTenant;
+ _guidGenerator = guidGenerator;
+ _asyncQueryableExecuter = asyncQueryableExecuter;
+
+ _workflowRepository = workflowRepository;
+ _workflowEventRepository = workflowEventRepository;
+ _executionErrorRepository = executionErrorRepository;
+ _subscriptionRepository = subscriptionRepository;
+ _scheduledCommandRepository = scheduledCommandRepository;
+ }
+
+ public virtual async Task ClearSubscriptionToken(
+ string eventSubscriptionId,
+ string token,
+ CancellationToken cancellationToken = default)
+ {
+ var uid = Guid.Parse(eventSubscriptionId);
+ var existingEntity = await _subscriptionRepository.GetAsync(uid, cancellationToken: cancellationToken);
+
+ if (existingEntity.ExternalToken != token)
+ throw new InvalidOperationException();
+
+ existingEntity.SetSubscriptionToken(null, null, null);
+
+ await _subscriptionRepository.UpdateAsync(existingEntity, cancellationToken: cancellationToken);
+ }
+
+ public virtual async Task CreateEvent(
+ Event newEvent,
+ CancellationToken cancellationToken = default)
+ {
+ var we = newEvent.ToWorkflowEvent(_guidGenerator, _currentTenant);
+
+ await _workflowEventRepository.InsertAsync(we, cancellationToken: cancellationToken);
+
+ newEvent.Id = we.Id.ToString();
+
+ return newEvent.Id;
+ }
+
+ public virtual async Task CreateEventSubscription(
+ EventSubscription subscription,
+ CancellationToken cancellationToken = default)
+ {
+ var wes = subscription.ToWorkflowEventSubscription(_guidGenerator, _currentTenant);
+
+ await _subscriptionRepository.InsertAsync(wes, cancellationToken: cancellationToken);
+
+ subscription.Id = wes.Id.ToString();
+
+ return subscription.Id;
+ }
+
+ public virtual async Task CreateNewWorkflow(
+ WorkflowInstance workflow,
+ CancellationToken cancellationToken = default)
+ {
+ var wf = workflow.ToWorkflow(_guidGenerator, _currentTenant);
+
+ await _workflowRepository.InsertAsync(wf, cancellationToken: cancellationToken);
+
+ workflow.Id = wf.Id.ToString();
+
+ return workflow.Id;
+ }
+
+ [UnitOfWork(IsDisabled = true)]
+ public void EnsureStoreExists()
+ {
+ // TODO:
+ }
+
+ public virtual async Task GetEvent(string id, CancellationToken cancellationToken = default)
+ {
+ var eventId = Guid.Parse(id);
+
+ var workflowEvent = await _workflowEventRepository.GetAsync(eventId, cancellationToken: cancellationToken);
+
+ return workflowEvent.ToEvent();
+ }
+
+ public virtual async Task> GetEvents(
+ string eventName,
+ string eventKey,
+ DateTime asOf,
+ CancellationToken cancellationToken = default)
+ {
+ var queryable = await _workflowEventRepository.GetQueryableAsync();
+ var workflowEventIds = await _asyncQueryableExecuter.ToListAsync(
+ queryable.Where(x => x.EventName == eventName && x.EventKey == eventKey)
+ .Where(x => x.CreationTime >= asOf)
+ .Select(x => x.Id),
+ cancellationToken);
+
+ return workflowEventIds.Select(e => e.ToString());
+ }
+
+ public virtual async Task GetFirstOpenSubscription(
+ string eventName,
+ string eventKey,
+ DateTime asOf,
+ CancellationToken cancellationToken = default)
+ {
+ var queryable = await _subscriptionRepository.GetQueryableAsync();
+ var workflowEventSubscription = await _asyncQueryableExecuter.FirstOrDefaultAsync(
+ queryable.Where(x => x.EventName == eventName && x.EventKey == eventKey && x.SubscribeAsOf <= asOf && x.ExternalToken == null),
+ cancellationToken);
+
+ return workflowEventSubscription?.ToEventSubscription();
+ }
+
+ public virtual async Task> GetRunnableEvents(
+ DateTime asAt,
+ CancellationToken cancellationToken = default)
+ {
+ var workflowEvents = await _workflowEventRepository.GetQueryableAsync();
+
+ var now = asAt.ToUniversalTime();
+
+ var workflowEventIdList = await _asyncQueryableExecuter.ToListAsync(
+ workflowEvents.Where(x => !x.IsProcessed)
+ .Where(x => x.CreationTime <= now)
+ .Select(x => x.Id),
+ cancellationToken);
+
+ return workflowEventIdList.Select(e => e.ToString());
+ }
+
+ public virtual async Task> GetRunnableInstances(
+ DateTime asAt,
+ CancellationToken cancellationToken = default)
+ {
+ var now = asAt.ToUniversalTime().Ticks;
+
+ var workflows = await _workflowRepository.GetQueryableAsync();
+ var workflowIdList = await _asyncQueryableExecuter.ToListAsync(
+ workflows.Where(x => x.NextExecution.HasValue && (x.NextExecution <= now) && (x.Status == WorkflowStatus.Runnable))
+ .Select(x => x.Id),
+ cancellationToken);
+
+ return workflowIdList.Select(e => e.ToString());
+ }
+
+ public virtual async Task GetSubscription(
+ string eventSubscriptionId,
+ CancellationToken cancellationToken = default)
+ {
+ var subscriptionId = Guid.Parse(eventSubscriptionId);
+ var subscription = await _subscriptionRepository.FindAsync(subscriptionId, cancellationToken: cancellationToken);
+
+ return subscription?.ToEventSubscription();
+ }
+
+ public virtual async Task> GetSubscriptions(
+ string eventName,
+ string eventKey,
+ DateTime asOf,
+ CancellationToken cancellationToken = default)
+ {
+ var now = asOf.ToUniversalTime();
+ var subscriptions = await _subscriptionRepository.GetQueryableAsync();
+ var eventSubscriptions = await _asyncQueryableExecuter.ToListAsync(
+ subscriptions.Where(x => x.EventName == eventName && x.EventKey == eventKey && x.SubscribeAsOf <= now),
+ cancellationToken);
+
+ return eventSubscriptions.Select(x => x.ToEventSubscription());
+ }
+
+ public virtual async Task GetWorkflowInstance(
+ string Id,
+ CancellationToken cancellationToken = default)
+ {
+ var workflowId = Guid.Parse(Id);
+ var workflow = await _workflowRepository.FindAsync(
+ workflowId,
+ includeDetails: true,
+ cancellationToken: cancellationToken);
+
+ return workflow?.ToWorkflowInstance();
+ }
+
+ public virtual async Task> GetWorkflowInstances(
+ WorkflowStatus? status,
+ string type,
+ DateTime? createdFrom,
+ DateTime? createdTo,
+ int skip,
+ int take)
+ {
+ var workflows = await _workflowRepository.GetListAsync(status, type, createdFrom, createdTo, skip, take);
+
+ return workflows.Select(x => x.ToWorkflowInstance());
+ }
+
+ public virtual async Task> GetWorkflowInstances(
+ IEnumerable ids,
+ CancellationToken cancellationToken = default)
+ {
+ var workflowIds = ids.Select(id => Guid.Parse(id));
+
+ var queryable = await _workflowRepository.GetQueryableAsync();
+ var workflows = await _asyncQueryableExecuter.ToListAsync(
+ queryable.Where(x => workflowIds.Contains(x.Id)),
+ cancellationToken);
+
+ return workflows.Select(x => x.ToWorkflowInstance());
+ }
+
+ public virtual async Task MarkEventProcessed(string id, CancellationToken cancellationToken = default)
+ {
+ var eventId = Guid.Parse(id);
+ var workflowEvent = await _workflowEventRepository.GetAsync(eventId, cancellationToken: cancellationToken);
+
+ workflowEvent.IsProcessed = true;
+
+ await _workflowEventRepository.UpdateAsync(workflowEvent, cancellationToken: cancellationToken);
+ }
+
+ public virtual async Task MarkEventUnprocessed(string id, CancellationToken cancellationToken = default)
+ {
+ var eventId = Guid.Parse(id);
+ var workflowEvent = await _workflowEventRepository.GetAsync(eventId, cancellationToken: cancellationToken);
+
+ workflowEvent.IsProcessed = false;
+
+ await _workflowEventRepository.UpdateAsync(workflowEvent, cancellationToken: cancellationToken);
+ }
+
+ public virtual async Task PersistErrors(IEnumerable errors, CancellationToken cancellationToken = default)
+ {
+ if (errors.Any())
+ {
+ var workflowExecutionErrors = errors.Select(x => x.ToWorkflowExecutionError(_currentTenant));
+
+ await _executionErrorRepository.InsertManyAsync(workflowExecutionErrors, cancellationToken: cancellationToken);
+ }
+ }
+
+ public virtual async Task PersistWorkflow(WorkflowInstance workflow, CancellationToken cancellationToken = default)
+ {
+ if (!Guid.TryParse(workflow.Id, out Guid workflowId))
+ {
+ workflowId = _guidGenerator.Create();
+ }
+
+ var wf = await _workflowRepository.FindAsync(workflowId, includeDetails: true, cancellationToken: cancellationToken);
+ if (wf == null)
+ {
+ wf = workflow.ToWorkflow(_guidGenerator, _currentTenant);
+
+ await _workflowRepository.InsertAsync(wf, cancellationToken: cancellationToken);
+ }
+ else
+ {
+ wf.Update(workflow, _guidGenerator, _currentTenant);
+
+ await _workflowRepository.UpdateAsync(wf, cancellationToken: cancellationToken);
+ }
+ }
+
+ public virtual async Task ProcessCommands(
+ DateTimeOffset asOf,
+ Func action,
+ CancellationToken cancellationToken = default)
+ {
+ var quertable = await _scheduledCommandRepository.GetQueryableAsync();
+ var commands = await _asyncQueryableExecuter.ToListAsync(
+ quertable.Where(x => x.ExecuteTime < asOf.UtcDateTime.Ticks),
+ cancellationToken);
+
+ foreach (var command in commands)
+ {
+ await action(command.ToScheduledCommand());
+ }
+
+ await _scheduledCommandRepository.DeleteManyAsync(commands, cancellationToken: cancellationToken);
+ }
+
+ public virtual async Task ScheduleCommand(ScheduledCommand command)
+ {
+ var workflowCommand = command.ToWorkflowScheduledCommand(_currentTenant);
+
+ await _scheduledCommandRepository.InsertAsync(workflowCommand);
+ }
+
+ public virtual async Task SetSubscriptionToken(
+ string eventSubscriptionId,
+ string token,
+ string workerId,
+ DateTime expiry,
+ CancellationToken cancellationToken = default)
+ {
+ var uid = Guid.Parse(eventSubscriptionId);
+
+ var existingEntity = await _subscriptionRepository.GetAsync(uid, cancellationToken: cancellationToken);
+
+ existingEntity.SetSubscriptionToken(token, workerId, expiry);
+
+ await _subscriptionRepository.UpdateAsync(existingEntity, cancellationToken: cancellationToken);
+
+ return true;
+ }
+
+ public virtual async Task TerminateSubscription(
+ string eventSubscriptionId,
+ CancellationToken cancellationToken = default)
+ {
+ var uid = Guid.Parse(eventSubscriptionId);
+
+ var existingEntity = await _subscriptionRepository.GetAsync(uid, cancellationToken: cancellationToken);
+
+ await _subscriptionRepository.DeleteAsync(existingEntity, cancellationToken: cancellationToken);
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/IWorkflowEventRepository.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/IWorkflowEventRepository.cs
new file mode 100644
index 000000000..1e89d0689
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/IWorkflowEventRepository.cs
@@ -0,0 +1,9 @@
+using System;
+using Volo.Abp.Domain.Repositories;
+
+namespace LINGYUN.Abp.WorkflowCore.Persistence
+{
+ public interface IWorkflowEventRepository : IRepository
+ {
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/IWorkflowEventSubscriptionRepository.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/IWorkflowEventSubscriptionRepository.cs
new file mode 100644
index 000000000..f363422b8
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/IWorkflowEventSubscriptionRepository.cs
@@ -0,0 +1,9 @@
+using System;
+using Volo.Abp.Domain.Repositories;
+
+namespace LINGYUN.Abp.WorkflowCore.Persistence
+{
+ public interface IWorkflowEventSubscriptionRepository : IRepository
+ {
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/IWorkflowExecutionErrorRepository.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/IWorkflowExecutionErrorRepository.cs
new file mode 100644
index 000000000..65da21372
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/IWorkflowExecutionErrorRepository.cs
@@ -0,0 +1,8 @@
+using Volo.Abp.Domain.Repositories;
+
+namespace LINGYUN.Abp.WorkflowCore.Persistence
+{
+ public interface IWorkflowExecutionErrorRepository : IRepository
+ {
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/IWorkflowRepository.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/IWorkflowRepository.cs
new file mode 100644
index 000000000..f3a5acbfa
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/IWorkflowRepository.cs
@@ -0,0 +1,21 @@
+using System;
+using System.Collections.Generic;
+using System.Threading;
+using System.Threading.Tasks;
+using Volo.Abp.Domain.Repositories;
+using WorkflowCore.Models;
+
+namespace LINGYUN.Abp.WorkflowCore.Persistence
+{
+ public interface IWorkflowRepository : IRepository
+ {
+ Task> GetListAsync(
+ WorkflowStatus? status,
+ string type,
+ DateTime? createdFrom,
+ DateTime? createdTo,
+ int skip,
+ int take,
+ CancellationToken cancellationToken = default);
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/IWorkflowScheduledCommandRepository.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/IWorkflowScheduledCommandRepository.cs
new file mode 100644
index 000000000..411d8d8eb
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/IWorkflowScheduledCommandRepository.cs
@@ -0,0 +1,8 @@
+using Volo.Abp.Domain.Repositories;
+
+namespace LINGYUN.Abp.WorkflowCore.Persistence
+{
+ public interface IWorkflowScheduledCommandRepository : IRepository
+ {
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/Workflow.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/Workflow.cs
new file mode 100644
index 000000000..9e9fbacd4
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/Workflow.cs
@@ -0,0 +1,101 @@
+using Newtonsoft.Json;
+using System;
+using System.Collections.Generic;
+using System.Collections.ObjectModel;
+using System.Linq;
+using Volo.Abp.Domain.Entities.Auditing;
+using Volo.Abp.Guids;
+using Volo.Abp.MultiTenancy;
+using WorkflowCore.Models;
+
+namespace LINGYUN.Abp.WorkflowCore.Persistence
+{
+ public class Workflow : AuditedAggregateRoot, IMultiTenant
+ {
+ public virtual Guid? TenantId { get; protected set; }
+ public virtual string WorkflowDefinitionId { get; protected set; }
+ public virtual int Version { get; protected set; }
+ public virtual string Description { get; protected set; }
+ public virtual string Reference { get; protected set; }
+ public virtual long? NextExecution { get; protected set; }
+ public virtual WorkflowStatus Status { get; protected set; }
+ public virtual string Data { get; protected set; }
+ public virtual DateTime? CompleteTime { get; protected set; }
+ public virtual ICollection ExecutionPointers { get; protected set; }
+
+ protected Workflow()
+ {
+ ExecutionPointers = new Collection();
+ }
+
+ public Workflow(
+ Guid id,
+ DateTime creationTime,
+ string defintionId,
+ string data,
+ int version,
+ string description,
+ string reference,
+ long? nextExecution = null,
+ WorkflowStatus status = WorkflowStatus.Terminated,
+ DateTime? completeTime = null,
+ Guid? tenantId = null) : base(id)
+ {
+ Data = data;
+ CreationTime = creationTime;
+ WorkflowDefinitionId = defintionId;
+ Version = version;
+ Description = description;
+ Reference = reference;
+ NextExecution = nextExecution;
+ Status = status;
+ CompleteTime = completeTime;
+ TenantId = tenantId;
+
+ ExecutionPointers = new Collection();
+ }
+
+ public void AddPointer(WorkflowExecutionPointer pointer)
+ {
+ ExecutionPointers.Add(pointer);
+ }
+
+ public WorkflowExecutionPointer FindPointer(Guid id)
+ {
+ return ExecutionPointers.FirstOrDefault(point => point.Id.Equals(id));
+ }
+
+ public void Update(
+ WorkflowInstance instance,
+ IGuidGenerator guidGenerator,
+ ICurrentTenant currentTenant)
+ {
+ Data = JsonConvert.SerializeObject(instance.Data);
+ CreationTime = instance.CreateTime;
+ WorkflowDefinitionId = instance.WorkflowDefinitionId;
+ Version = instance.Version;
+ Description = instance.Description;
+ Reference = instance.Reference;
+ NextExecution = instance.NextExecution;
+ Status = instance.Status;
+ CompleteTime = instance.CompleteTime;
+
+ foreach (var pointer in instance.ExecutionPointers)
+ {
+ if (!Guid.TryParse(pointer.Id, out Guid pointerId))
+ {
+ pointerId = guidGenerator.Create();
+ }
+
+ var currentPointer = FindPointer(pointerId);
+ if (currentPointer != null)
+ {
+ currentPointer.Update(pointer);
+ continue;
+ }
+
+ AddPointer(pointer.ToWorkflowExecutionPointer(this, guidGenerator, currentTenant));
+ }
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/WorkflowDbProperties.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/WorkflowDbProperties.cs
new file mode 100644
index 000000000..a35d7de88
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/WorkflowDbProperties.cs
@@ -0,0 +1,9 @@
+namespace LINGYUN.Abp.WorkflowCore.Persistence
+{
+ public static class WorkflowDbProperties
+ {
+ public const string ConnectionStringName = "WorkflowCore";
+
+ public static string TablePrefix = "WF_";
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/WorkflowEvent.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/WorkflowEvent.cs
new file mode 100644
index 000000000..fc79d69e5
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/WorkflowEvent.cs
@@ -0,0 +1,47 @@
+using System;
+using Volo.Abp.Auditing;
+using Volo.Abp.Domain.Entities;
+using Volo.Abp.MultiTenancy;
+
+namespace LINGYUN.Abp.WorkflowCore.Persistence
+{
+ public class WorkflowEvent : Entity, IMultiTenant, IHasCreationTime
+ {
+ public virtual Guid? TenantId { get; protected set; }
+ ///
+ /// 名称
+ ///
+ public virtual string EventName { get; protected set; }
+ ///
+ /// Key
+ ///
+ public virtual string EventKey { get; protected set; }
+ ///
+ /// 数据
+ ///
+ public virtual string EventData { get; protected set; }
+ ///
+ /// 是否已处理
+ ///
+ public virtual bool IsProcessed { get; set; }
+ ///
+ /// 建立时间
+ ///
+ public virtual DateTime CreationTime { get; protected set; }
+ protected WorkflowEvent() { }
+ public WorkflowEvent(
+ Guid id,
+ string name,
+ string key,
+ string data,
+ DateTime creationTime,
+ Guid? tenantId = null) : base(id)
+ {
+ EventName = name;
+ EventKey = key;
+ EventData = data;
+ CreationTime = creationTime;
+ TenantId = tenantId;
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/WorkflowEventSubscription.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/WorkflowEventSubscription.cs
new file mode 100644
index 000000000..5d5d050ce
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/WorkflowEventSubscription.cs
@@ -0,0 +1,73 @@
+using System;
+using Volo.Abp.Domain.Entities;
+using Volo.Abp.MultiTenancy;
+
+namespace LINGYUN.Abp.WorkflowCore.Persistence
+{
+ public class WorkflowEventSubscription : Entity, IMultiTenant
+ {
+ public virtual Guid? TenantId { get; protected set; }
+
+ public virtual Guid WorkflowId { get; protected set; }
+
+ public virtual int StepId { get; protected set; }
+
+ public virtual Guid ExecutionPointerId { get; protected set; }
+
+ public virtual string EventName { get; protected set; }
+
+ public virtual string EventKey { get; protected set; }
+
+ public virtual DateTime SubscribeAsOf { get; protected set; }
+
+ public virtual string SubscriptionData { get; protected set; }
+
+ public virtual string ExternalToken { get; protected set; }
+
+ public virtual string ExternalWorkerId { get; protected set; }
+
+ public virtual DateTime? ExternalTokenExpiry { get; protected set; }
+
+ protected WorkflowEventSubscription()
+ {
+ }
+
+ public WorkflowEventSubscription(
+ Guid id,
+ Guid workflowId,
+ int stepId,
+ Guid pointerId,
+ string eventName,
+ string eventKey,
+ DateTime subscribeAsOf,
+ string subscriptionData,
+ string externalToken,
+ string externalWorkerId,
+ DateTime? externalTokenExpiry = null,
+ Guid? tenantId = null) : base(id)
+ {
+ WorkflowId = workflowId;
+ StepId = stepId;
+ ExecutionPointerId = pointerId;
+ EventName = eventName;
+ EventKey = eventKey;
+ SubscribeAsOf = subscribeAsOf;
+ SubscriptionData = subscriptionData;
+ ExternalToken = externalToken;
+ ExternalWorkerId = externalWorkerId;
+ ExternalTokenExpiry = externalTokenExpiry;
+
+ TenantId = tenantId;
+ }
+
+ public void SetSubscriptionToken(
+ string token,
+ string workerId,
+ DateTime? expiry)
+ {
+ ExternalToken = token;
+ ExternalWorkerId = workerId;
+ ExternalTokenExpiry = expiry;
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/WorkflowExecutionError.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/WorkflowExecutionError.cs
new file mode 100644
index 000000000..24a4433e6
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/WorkflowExecutionError.cs
@@ -0,0 +1,34 @@
+using System;
+using Volo.Abp.Domain.Entities;
+using Volo.Abp.MultiTenancy;
+
+namespace LINGYUN.Abp.WorkflowCore.Persistence
+{
+ public class WorkflowExecutionError : Entity, IMultiTenant
+ {
+ public virtual Guid? TenantId { get; protected set; }
+
+ public virtual Guid WorkflowId { get; protected set; }
+
+ public virtual Guid ExecutionPointerId { get; set; }
+
+ public virtual DateTime ErrorTime { get; set; }
+
+ public virtual string Message { get; set; }
+
+ protected WorkflowExecutionError() { }
+ public WorkflowExecutionError(
+ Guid workflowId,
+ Guid executionPointerId,
+ DateTime errorTime,
+ string message,
+ Guid? tenantId = null)
+ {
+ WorkflowId = workflowId;
+ ExecutionPointerId = executionPointerId;
+ ErrorTime = errorTime;
+ Message = message;
+ TenantId = tenantId;
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/WorkflowExecutionPointer.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/WorkflowExecutionPointer.cs
new file mode 100644
index 000000000..6fb62299f
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/WorkflowExecutionPointer.cs
@@ -0,0 +1,162 @@
+using Newtonsoft.Json;
+using System;
+using System.Collections.Generic;
+using System.Collections.ObjectModel;
+using System.Linq;
+using Volo.Abp.Data;
+using Volo.Abp.Domain.Entities;
+using Volo.Abp.MultiTenancy;
+using WorkflowCore.Models;
+
+namespace LINGYUN.Abp.WorkflowCore.Persistence
+{
+ public class WorkflowExecutionPointer : Entity, IMultiTenant
+ {
+ public virtual Guid? TenantId { get; protected set; }
+
+ public virtual Guid WorkflowId { get; protected set; }
+
+ public virtual Workflow Workflow { get; protected set; }
+
+ public virtual int StepId { get; protected set; }
+
+ public virtual bool Active { get; protected set; }
+
+ public virtual DateTime? SleepUntil { get; protected set; }
+
+ public virtual string PersistenceData { get; protected set; }
+
+ public virtual DateTime? StartTime { get; protected set; }
+
+ public virtual DateTime? EndTime { get; protected set; }
+
+ public virtual string EventName { get; protected set; }
+
+ public virtual string EventKey { get; protected set; }
+
+ public virtual bool EventPublished { get; protected set; }
+
+ public virtual string EventData { get; protected set; }
+
+ public virtual string StepName { get; protected set; }
+
+ public virtual int RetryCount { get; protected set; }
+
+ public virtual string Children { get; protected set; }
+
+ public virtual string ContextItem { get; protected set; }
+
+ public virtual string PredecessorId { get; protected set; }
+
+ public virtual string Outcome { get; protected set; }
+
+ public virtual PointerStatus Status { get; protected set; }
+
+ public virtual string Scope { get; protected set; }
+
+ public virtual ICollection ExtensionAttributes { get; protected set; }
+
+ protected WorkflowExecutionPointer()
+ {
+ ExtensionAttributes = new Collection();
+ }
+
+ public WorkflowExecutionPointer(
+ Guid id,
+ Guid workflowId,
+ int stepId,
+ string stepName,
+ bool active,
+ string persistenceData,
+ string eventName,
+ string eventKey,
+ bool eventPublished,
+ string eventData,
+ int retryCount,
+ string children,
+ string contextItem,
+ string predecessorId,
+ string outcome,
+ string scope,
+ PointerStatus status = PointerStatus.Legacy,
+ DateTime? sleepUntil = null,
+ DateTime? startTime = null,
+ DateTime? endTime = null,
+ Guid? tenantId = null) : base(id)
+ {
+ WorkflowId = workflowId;
+ StepId = stepId;
+ StepName = stepName;
+ Active = active;
+ PersistenceData = persistenceData;
+ EventName = eventName;
+ EventKey = eventKey;
+ EventPublished = eventPublished;
+ EventData = eventData;
+ RetryCount = retryCount;
+ Children = children;
+ ContextItem = contextItem;
+ PredecessorId = predecessorId;
+ Outcome = outcome;
+ Scope = scope;
+ Status = status;
+ SleepUntil = sleepUntil;
+ StartTime = startTime;
+ EndTime = endTime;
+
+ TenantId = tenantId;
+
+ ExtensionAttributes = new Collection();
+ }
+
+ public void Update(ExecutionPointer pointer)
+ {
+ StepId = pointer.StepId;
+ StepName = pointer.StepName;
+ Active = pointer.Active;
+ PersistenceData = JsonConvert.SerializeObject(pointer.PersistenceData);
+ EventName = pointer.EventName;
+ EventKey = pointer.EventKey;
+ EventPublished = pointer.EventPublished;
+ EventData = JsonConvert.SerializeObject(pointer.EventData);
+ RetryCount = pointer.RetryCount;
+ Children = pointer.Children.JoinAsString(";");
+ ContextItem = JsonConvert.SerializeObject(pointer.ContextItem);
+ PredecessorId = pointer.PredecessorId;
+ Outcome = JsonConvert.SerializeObject(pointer.Outcome);
+ Scope = pointer.Scope.JoinAsString(";");
+ Status = pointer.Status;
+ SleepUntil = pointer.SleepUntil;
+ StartTime = pointer.StartTime;
+ EndTime = pointer.EndTime;
+
+ foreach (var attribute in pointer.ExtensionAttributes)
+ {
+ var findAttr = FindAttribute(attribute.Key);
+ if (findAttr == null)
+ {
+ findAttr = new WorkflowExtensionAttribute(Id, attribute.Key, attribute.Value.SerializeObject());
+
+ }
+ else
+ {
+ findAttr.Key = attribute.Key;
+ findAttr.Value = attribute.Value.SerializeObject();
+ }
+ }
+ }
+
+ public WorkflowExtensionAttribute AddAttribute(string key, string value)
+ {
+ var attr = new WorkflowExtensionAttribute(Id, key, value);
+ ExtensionAttributes.Add(attr);
+
+ return attr;
+ }
+
+ public WorkflowExtensionAttribute FindAttribute(string key)
+ {
+ return ExtensionAttributes.FirstOrDefault(x => x.Key.Equals(key));
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/WorkflowExtensionAttribute.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/WorkflowExtensionAttribute.cs
new file mode 100644
index 000000000..f332c675e
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/WorkflowExtensionAttribute.cs
@@ -0,0 +1,31 @@
+using System;
+using Volo.Abp.Domain.Entities;
+using Volo.Abp.MultiTenancy;
+
+namespace LINGYUN.Abp.WorkflowCore.Persistence
+{
+ public class WorkflowExtensionAttribute : Entity, IMultiTenant
+ {
+ public virtual Guid? TenantId { get; protected set; }
+
+ public virtual Guid ExecutionPointerId { get; set; }
+
+ public virtual WorkflowExecutionPointer ExecutionPointer { get; set; }
+
+ public virtual string Key { get; set; }
+
+ public virtual string Value { get; set; }
+
+ protected WorkflowExtensionAttribute() { }
+
+ public WorkflowExtensionAttribute(
+ Guid pointerId,
+ string key,
+ string value)
+ {
+ ExecutionPointerId = pointerId;
+ Key = key;
+ Value = value;
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/WorkflowExtensions.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/WorkflowExtensions.cs
new file mode 100644
index 000000000..389016411
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/WorkflowExtensions.cs
@@ -0,0 +1,113 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using WorkflowCore.Models;
+
+namespace LINGYUN.Abp.WorkflowCore.Persistence
+{
+ public static class WorkflowExtensions
+ {
+ public static Event ToEvent(this WorkflowEvent workflowEvent)
+ {
+ return new Event
+ {
+ Id = workflowEvent.Id.ToString(),
+ EventName = workflowEvent.EventName,
+ EventKey = workflowEvent.EventKey,
+ EventTime = workflowEvent.CreationTime.ToUtcDateTime(),
+ IsProcessed = workflowEvent.IsProcessed,
+ EventData = workflowEvent.EventData.DeserializeObject()
+ };
+ }
+
+ public static EventSubscription ToEventSubscription(this WorkflowEventSubscription workflowEventSubscription)
+ {
+ return new EventSubscription
+ {
+ Id = workflowEventSubscription.Id.ToString(),
+ StepId = workflowEventSubscription.StepId,
+ SubscribeAsOf = workflowEventSubscription.SubscribeAsOf.ToUtcDateTime(),
+ SubscriptionData = workflowEventSubscription.SubscriptionData.DeserializeObject(),
+ EventKey = workflowEventSubscription.EventKey,
+ EventName = workflowEventSubscription.EventName,
+ ExecutionPointerId = workflowEventSubscription.ExecutionPointerId.ToString(),
+ ExternalWorkerId = workflowEventSubscription.ExternalWorkerId,
+ ExternalToken = workflowEventSubscription.ExternalToken,
+ ExternalTokenExpiry = workflowEventSubscription.ExternalTokenExpiry.ToNullableUtcDateTime(),
+ WorkflowId = workflowEventSubscription.WorkflowId.ToString()
+ };
+ }
+
+ public static WorkflowInstance ToWorkflowInstance(this Workflow workflow)
+ {
+ return new WorkflowInstance
+ {
+ Id = workflow.Id.ToString(),
+ WorkflowDefinitionId = workflow.WorkflowDefinitionId,
+ CompleteTime = workflow.CompleteTime.ToNullableUtcDateTime(),
+ CreateTime = workflow.CreationTime.ToUtcDateTime(),
+ Data = workflow.Data.SerializeObject(),
+ Status = workflow.Status,
+ Description = workflow.Description,
+ NextExecution = workflow.NextExecution,
+ Reference = workflow.Reference,
+ Version = workflow.Version,
+ ExecutionPointers = new ExecutionPointerCollection(
+ workflow.ExecutionPointers
+ .Select(pointer => pointer.ToExecutionPointer())
+ .ToList())
+ };
+ }
+
+ public static ExecutionPointer ToExecutionPointer(this WorkflowExecutionPointer pointer)
+ {
+ return new ExecutionPointer
+ {
+ Id = pointer.Id.ToString(),
+ EventData = pointer.EventData.DeserializeObject(),
+ EventKey = pointer.StepName,
+ EventName = pointer.EventName,
+ EventPublished = pointer.EventPublished,
+ ExtensionAttributes = pointer.ExtensionAttributes.ToExtensionAttributes(),
+ Active = pointer.Active,
+ Children = pointer.Children.Split(';').ToList(),
+ ContextItem = pointer.ContextItem.DeserializeObject(),
+ Scope = pointer.Scope.Split(';').ToList(),
+ Outcome = pointer.Outcome.DeserializeObject(),
+ PersistenceData = pointer.PersistenceData.DeserializeObject(),
+ PredecessorId = pointer.PredecessorId,
+ RetryCount = pointer.RetryCount,
+ Status = pointer.Status,
+ StepId = pointer.StepId,
+ StepName = pointer.StepName,
+ EndTime = pointer.EndTime.ToNullableUtcDateTime(),
+ StartTime = pointer.StartTime.ToNullableUtcDateTime(),
+ SleepUntil = pointer.SleepUntil.ToNullableUtcDateTime(),
+ };
+ }
+
+ public static ScheduledCommand ToScheduledCommand(
+ this WorkflowScheduledCommand command)
+ {
+ return new ScheduledCommand
+ {
+ CommandName = command.CommandName,
+ Data = command.Data,
+ ExecuteTime = command.ExecuteTime
+ };
+ }
+
+ public static Dictionary ToExtensionAttributes(
+ this ICollection attributes)
+ {
+ var attrDic = new Dictionary();
+
+ foreach (var attr in attributes)
+ {
+ attrDic.Add(attr.Key, attr.Value.DeserializeObject());
+ }
+
+ return attrDic;
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/WorkflowScheduledCommand.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/WorkflowScheduledCommand.cs
new file mode 100644
index 000000000..0753b3c7f
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/LINGYUN/Abp/WorkflowCore/Persistence/WorkflowScheduledCommand.cs
@@ -0,0 +1,29 @@
+using System;
+using Volo.Abp.Domain.Entities;
+using Volo.Abp.MultiTenancy;
+
+namespace LINGYUN.Abp.WorkflowCore.Persistence
+{
+ public class WorkflowScheduledCommand : Entity, IMultiTenant
+ {
+ public virtual Guid? TenantId { get; protected set; }
+
+ public virtual string CommandName { get; set; }
+
+ public virtual string Data { get; set; }
+
+ public virtual long ExecuteTime { get; set; }
+ protected WorkflowScheduledCommand() { }
+ public WorkflowScheduledCommand(
+ string commandName,
+ string data,
+ long executeTime,
+ Guid? tenantId = null)
+ {
+ CommandName = commandName;
+ Data = data;
+ ExecuteTime = executeTime;
+ TenantId = tenantId;
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/WorkflowCore/Models/WorkflowExtensions.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/WorkflowCore/Models/WorkflowExtensions.cs
new file mode 100644
index 000000000..e5359fbd7
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.Persistence/WorkflowCore/Models/WorkflowExtensions.cs
@@ -0,0 +1,138 @@
+using LINGYUN.Abp.WorkflowCore.Persistence;
+using System;
+using System.Collections.Generic;
+using Volo.Abp.Guids;
+using Volo.Abp.MultiTenancy;
+
+namespace WorkflowCore.Models
+{
+ public static class WorkflowExtensions
+ {
+ public static Workflow ToWorkflow(
+ this WorkflowInstance instance,
+ IGuidGenerator generator,
+ ICurrentTenant currentTenant)
+ {
+ var workflow = new Workflow(
+ generator.Create(),
+ instance.CreateTime,
+ instance.WorkflowDefinitionId,
+ instance.Data.SerializeObject(),
+ instance.Version,
+ instance.Description,
+ instance.Reference,
+ instance.NextExecution,
+ instance.Status,
+ instance.CompleteTime,
+ currentTenant.Id);
+
+ foreach (var pointer in instance.ExecutionPointers)
+ {
+ pointer.ToWorkflowExecutionPointer(workflow, generator, currentTenant);
+ }
+
+ return workflow;
+ }
+
+ public static WorkflowExecutionPointer ToWorkflowExecutionPointer(
+ this ExecutionPointer executionPointer,
+ Workflow workflow,
+ IGuidGenerator generator,
+ ICurrentTenant currentTenant)
+ {
+ var pointer = new WorkflowExecutionPointer(
+ generator.Create(),
+ workflow.Id,
+ executionPointer.StepId,
+ executionPointer.StepName,
+ executionPointer.Active,
+ executionPointer.PersistenceData.SerializeObject(),
+ executionPointer.EventName,
+ executionPointer.EventKey,
+ executionPointer.EventPublished,
+ executionPointer.EventData.SerializeObject(),
+ executionPointer.RetryCount,
+ executionPointer.Children.JoinAsString(";"),
+ executionPointer.ContextItem.SerializeObject(),
+ executionPointer.PredecessorId,
+ executionPointer.Outcome.SerializeObject(),
+ executionPointer.Scope.JoinAsString(";"),
+ executionPointer.Status,
+ executionPointer.SleepUntil,
+ executionPointer.StartTime,
+ executionPointer.EndTime,
+ currentTenant.Id);
+
+ foreach (var attribute in executionPointer.ExtensionAttributes)
+ {
+ pointer.AddAttribute(attribute.Key, attribute.Value.SerializeObject());
+ }
+
+ executionPointer.Id = pointer.Id.ToString();
+
+ return pointer;
+ }
+
+ public static WorkflowEvent ToWorkflowEvent(
+ this Event @event,
+ IGuidGenerator generator,
+ ICurrentTenant currentTenant)
+ {
+ var we = new WorkflowEvent(
+ generator.Create(),
+ @event.EventName,
+ @event.EventKey,
+ @event.EventData.SerializeObject(),
+ @event.EventTime,
+ currentTenant.Id)
+ {
+ IsProcessed = @event.IsProcessed
+ };
+
+ return we;
+ }
+
+ public static WorkflowEventSubscription ToWorkflowEventSubscription(
+ this EventSubscription subscription,
+ IGuidGenerator generator,
+ ICurrentTenant currentTenant)
+ {
+ return new WorkflowEventSubscription(
+ generator.Create(),
+ Guid.Parse(subscription.WorkflowId),
+ subscription.StepId,
+ Guid.Parse(subscription.ExecutionPointerId),
+ subscription.EventName,
+ subscription.EventKey,
+ subscription.SubscribeAsOf,
+ subscription.SubscriptionData.SerializeObject(),
+ subscription.ExternalToken,
+ subscription.ExternalWorkerId,
+ subscription.ExternalTokenExpiry,
+ currentTenant.Id);
+ }
+
+ public static WorkflowExecutionError ToWorkflowExecutionError(
+ this ExecutionError executionError,
+ ICurrentTenant currentTenant)
+ {
+ return new WorkflowExecutionError(
+ Guid.Parse(executionError.WorkflowId),
+ Guid.Parse(executionError.ExecutionPointerId),
+ executionError.ErrorTime,
+ executionError.Message,
+ currentTenant.Id);
+ }
+
+ public static WorkflowScheduledCommand ToWorkflowScheduledCommand(
+ this ScheduledCommand command,
+ ICurrentTenant currentTenant)
+ {
+ return new WorkflowScheduledCommand(
+ command.CommandName,
+ command.Data,
+ command.ExecuteTime,
+ currentTenant.Id);
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.RabbitMQ/LINGYUN.Abp.WorkflowCore.RabbitMQ.csproj b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.RabbitMQ/LINGYUN.Abp.WorkflowCore.RabbitMQ.csproj
new file mode 100644
index 000000000..a32c88430
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.RabbitMQ/LINGYUN.Abp.WorkflowCore.RabbitMQ.csproj
@@ -0,0 +1,16 @@
+
+
+
+ netstandard2.0
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.RabbitMQ/LINGYUN/Abp/WorkflowCore/RabbitMQ/AbpRabbitMQWorkflowCoreOptions.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.RabbitMQ/LINGYUN/Abp/WorkflowCore/RabbitMQ/AbpRabbitMQWorkflowCoreOptions.cs
new file mode 100644
index 000000000..30883e94b
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.RabbitMQ/LINGYUN/Abp/WorkflowCore/RabbitMQ/AbpRabbitMQWorkflowCoreOptions.cs
@@ -0,0 +1,15 @@
+namespace LINGYUN.Abp.WorkflowCore.RabbitMQ
+{
+ public class AbpRabbitMQWorkflowCoreOptions
+ {
+ ///
+ /// Default value: "AbpWorkflows.".
+ ///
+ public string DefaultQueueNamePrefix { get; set; }
+
+ public AbpRabbitMQWorkflowCoreOptions()
+ {
+ DefaultQueueNamePrefix = "AbpWorkflows.";
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.RabbitMQ/LINGYUN/Abp/WorkflowCore/RabbitMQ/AbpRabbitMqQueueProvider.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.RabbitMQ/LINGYUN/Abp/WorkflowCore/RabbitMQ/AbpRabbitMqQueueProvider.cs
new file mode 100644
index 000000000..6267420e3
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.RabbitMQ/LINGYUN/Abp/WorkflowCore/RabbitMQ/AbpRabbitMqQueueProvider.cs
@@ -0,0 +1,135 @@
+using Microsoft.Extensions.Options;
+using RabbitMQ.Client;
+using System.Text;
+using System.Threading;
+using System.Threading.Tasks;
+using Volo.Abp;
+using Volo.Abp.RabbitMQ;
+using Volo.Abp.Threading;
+using WorkflowCore.Interface;
+
+namespace LINGYUN.Abp.WorkflowCore.RabbitMQ
+{
+ public class AbpRabbitMqQueueProvider : IQueueProvider
+ {
+ private string ChannelPrefix = "WorkflowQueue.";
+ protected bool IsDiposed { get; private set; }
+ protected SemaphoreSlim SyncObj = new SemaphoreSlim(1, 1);
+
+ protected IChannelAccessor ChannelAccessor { get; private set; }
+
+ protected IChannelPool ChannelPool { get; }
+ protected IQueueNameNormalizer QueueNameNormalizer { get; }
+ protected AbpRabbitMQWorkflowCoreOptions RabbitMQWorkflowCoreOptions { get; }
+ protected WorkflowQueueConfiguration QueueConfiguration { get; }
+
+ public bool IsDequeueBlocking => false;
+
+ public AbpRabbitMqQueueProvider(
+ IChannelPool channelPool,
+ IQueueNameNormalizer queueNameNormalizer,
+ IOptions options)
+ {
+ ChannelPool = channelPool;
+ QueueNameNormalizer = queueNameNormalizer;
+ RabbitMQWorkflowCoreOptions = options.Value;
+
+ QueueConfiguration = GetOrCreateWorkflowQueueConfiguration();
+ }
+
+ protected virtual WorkflowQueueConfiguration GetOrCreateWorkflowQueueConfiguration()
+ {
+ return new WorkflowQueueConfiguration(
+ RabbitMQWorkflowCoreOptions.DefaultQueueNamePrefix + "Workflow-Core",
+ durable: true,
+ exclusive: false,
+ autoDelete: false);
+ }
+
+ public async Task DequeueWork(QueueType queue, CancellationToken cancellationToken)
+ {
+ using (await SyncObj.LockAsync(cancellationToken))
+ {
+ ChannelAccessor.Channel.BasicQos(prefetchSize: 0, prefetchCount: 1, global: false);
+
+ var msg = ChannelAccessor.Channel.BasicGet(QueueNameNormalizer.NormalizeKey(queue), false);
+ if (msg != null)
+ {
+ var data = Encoding.UTF8.GetString(msg.Body.ToArray());
+ ChannelAccessor.Channel.BasicAck(msg.DeliveryTag, false);
+ return data;
+ }
+ return null;
+ }
+ }
+
+ public async Task QueueWork(string id, QueueType queue)
+ {
+ using (await SyncObj.LockAsync())
+ {
+ var body = Encoding.UTF8.GetBytes(id);
+
+ ChannelAccessor.Channel.BasicPublish(
+ exchange: "",
+ routingKey: QueueNameNormalizer.NormalizeKey(queue),
+ basicProperties: null,
+ body: body
+ );
+ }
+ }
+
+ public async Task Start()
+ {
+ CheckDisposed();
+
+ using (await SyncObj.LockAsync())
+ {
+ await EnsureInitializedAsync();
+ }
+ }
+
+ public Task Stop()
+ {
+ Dispose();
+
+ return Task.CompletedTask;
+ }
+
+
+ public void Dispose()
+ {
+ if (IsDiposed)
+ {
+ return;
+ }
+
+ IsDiposed = true;
+
+ ChannelAccessor?.Dispose();
+ }
+
+
+ protected virtual Task EnsureInitializedAsync()
+ {
+ if (ChannelAccessor != null)
+ {
+ return Task.CompletedTask;
+ }
+
+ ChannelAccessor = ChannelPool.Acquire(
+ ChannelPrefix + QueueConfiguration.QueueName,
+ QueueConfiguration.ConnectionName
+ );
+
+ return Task.CompletedTask;
+ }
+
+ protected void CheckDisposed()
+ {
+ if (IsDiposed)
+ {
+ throw new AbpException("This object is disposed!");
+ }
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.RabbitMQ/LINGYUN/Abp/WorkflowCore/RabbitMQ/AbpWorkflowCoreRabbitMQModule.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.RabbitMQ/LINGYUN/Abp/WorkflowCore/RabbitMQ/AbpWorkflowCoreRabbitMQModule.cs
new file mode 100644
index 000000000..148869d6e
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.RabbitMQ/LINGYUN/Abp/WorkflowCore/RabbitMQ/AbpWorkflowCoreRabbitMQModule.cs
@@ -0,0 +1,24 @@
+using Microsoft.Extensions.DependencyInjection;
+using Volo.Abp.Modularity;
+using Volo.Abp.RabbitMQ;
+using WorkflowCore.Interface;
+using WorkflowCore.Models;
+
+namespace LINGYUN.Abp.WorkflowCore.RabbitMQ
+{
+ [DependsOn(typeof(AbpRabbitMqModule))]
+ [DependsOn(typeof(AbpWorkflowCoreModule))]
+ public class AbpWorkflowCoreRabbitMQModule : AbpModule
+ {
+ public override void PreConfigureServices(ServiceConfigurationContext context)
+ {
+ context.Services.AddSingleton();
+ context.Services.AddSingleton();
+
+ PreConfigure(options =>
+ {
+ options.UseQueueProvider(provider => provider.GetRequiredService());
+ });
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.RabbitMQ/LINGYUN/Abp/WorkflowCore/RabbitMQ/IQueueNameNormalizer.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.RabbitMQ/LINGYUN/Abp/WorkflowCore/RabbitMQ/IQueueNameNormalizer.cs
new file mode 100644
index 000000000..1ccf5f015
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.RabbitMQ/LINGYUN/Abp/WorkflowCore/RabbitMQ/IQueueNameNormalizer.cs
@@ -0,0 +1,9 @@
+using WorkflowCore.Interface;
+
+namespace LINGYUN.Abp.WorkflowCore.RabbitMQ
+{
+ public interface IQueueNameNormalizer
+ {
+ string NormalizeKey(QueueType queue);
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.RabbitMQ/LINGYUN/Abp/WorkflowCore/RabbitMQ/QueueNameNormalizer.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.RabbitMQ/LINGYUN/Abp/WorkflowCore/RabbitMQ/QueueNameNormalizer.cs
new file mode 100644
index 000000000..94e229e18
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.RabbitMQ/LINGYUN/Abp/WorkflowCore/RabbitMQ/QueueNameNormalizer.cs
@@ -0,0 +1,23 @@
+using Volo.Abp.DependencyInjection;
+using WorkflowCore.Interface;
+
+namespace LINGYUN.Abp.WorkflowCore.RabbitMQ
+{
+ public class QueueNameNormalizer : IQueueNameNormalizer, ISingletonDependency
+ {
+ public string NormalizeKey(QueueType queue)
+ {
+ switch (queue)
+ {
+ case QueueType.Workflow:
+ return "wfc.workflow_queue";
+ case QueueType.Event:
+ return "wfc.event_queue";
+ case QueueType.Index:
+ return "wfc.index_queue";
+ default:
+ return null;
+ }
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.RabbitMQ/LINGYUN/Abp/WorkflowCore/RabbitMQ/WorkflowQueueConfiguration.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.RabbitMQ/LINGYUN/Abp/WorkflowCore/RabbitMQ/WorkflowQueueConfiguration.cs
new file mode 100644
index 000000000..0865616fc
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore.RabbitMQ/LINGYUN/Abp/WorkflowCore/RabbitMQ/WorkflowQueueConfiguration.cs
@@ -0,0 +1,21 @@
+using Volo.Abp.RabbitMQ;
+
+namespace LINGYUN.Abp.WorkflowCore.RabbitMQ
+{
+ public class WorkflowQueueConfiguration : QueueDeclareConfiguration
+ {
+ public string ConnectionName { get; set; }
+
+ public WorkflowQueueConfiguration(
+ string queueName,
+ string connectionName = null,
+ bool durable = true,
+ bool exclusive = false,
+ bool autoDelete = false,
+ string deadLetterQueueName = null)
+ : base(queueName, durable, exclusive, autoDelete, deadLetterQueueName)
+ {
+ ConnectionName = connectionName;
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN.Abp.WorkflowCore.csproj b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN.Abp.WorkflowCore.csproj
new file mode 100644
index 000000000..70ea8acbc
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN.Abp.WorkflowCore.csproj
@@ -0,0 +1,14 @@
+
+
+
+ netstandard2.0
+ 8.0
+
+
+
+
+
+
+
+
+
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/AbpWorkflowCoreConventionalRegistrar.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/AbpWorkflowCoreConventionalRegistrar.cs
new file mode 100644
index 000000000..decbbae34
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/AbpWorkflowCoreConventionalRegistrar.cs
@@ -0,0 +1,11 @@
+using System;
+using System.Collections.Generic;
+using System.Text;
+using Volo.Abp.DependencyInjection;
+
+namespace LINGYUN.Abp.WorkflowCore
+{
+ public class AbpWorkflowCoreConventionalRegistrar : DefaultConventionalRegistrar
+ {
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/AbpWorkflowCoreModule.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/AbpWorkflowCoreModule.cs
new file mode 100644
index 000000000..72f746261
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/AbpWorkflowCoreModule.cs
@@ -0,0 +1,58 @@
+using Microsoft.Extensions.DependencyInjection;
+using System;
+using System.Collections.Generic;
+using Volo.Abp.Modularity;
+using WorkflowCore.Interface;
+
+namespace LINGYUN.Abp.WorkflowCore
+{
+ public class AbpWorkflowCoreModule : AbpModule
+ {
+ private readonly static IList _definitionWorkflows = new List();
+
+ public override void PreConfigureServices(ServiceConfigurationContext context)
+ {
+ AutoAddDefinitionWorkflows(context.Services);
+ }
+
+ public override void ConfigureServices(ServiceConfigurationContext context)
+ {
+ context.Services.AddWorkflow(options =>
+ {
+ context.Services.ExecutePreConfiguredActions(options);
+ });
+ context.Services.AddWorkflowDSL();
+ }
+
+ public override void OnApplicationInitialization(Volo.Abp.ApplicationInitializationContext context)
+ {
+ var workflowRegistry = context.ServiceProvider.GetRequiredService();
+
+ foreach (var definitionWorkflow in _definitionWorkflows)
+ {
+ var workflow = context.ServiceProvider.GetRequiredService(definitionWorkflow);
+ workflowRegistry.RegisterWorkflow(workflow as IWorkflow);
+ }
+
+ var workflowHost = context.ServiceProvider.GetRequiredService();
+ workflowHost.Start();
+ }
+
+ public override void OnApplicationShutdown(Volo.Abp.ApplicationShutdownContext context)
+ {
+ var workflowHost = context.ServiceProvider.GetRequiredService();
+ workflowHost.Stop();
+ }
+
+ private static void AutoAddDefinitionWorkflows(IServiceCollection services)
+ {
+ services.OnRegistred(context =>
+ {
+ if (typeof(WorkflowBase).IsAssignableFrom(context.ImplementationType))
+ {
+ _definitionWorkflows.Add(context.ImplementationType);
+ }
+ });
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/AbpWorkflowCoreOptions.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/AbpWorkflowCoreOptions.cs
new file mode 100644
index 000000000..eea4fe0cf
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/AbpWorkflowCoreOptions.cs
@@ -0,0 +1,10 @@
+using Volo.Abp.Collections;
+using WorkflowCore.Interface;
+
+namespace LINGYUN.Abp.WorkflowCore
+{
+ public class AbpWorkflowCoreOptions
+ {
+ public ITypeList DefinitionProviders { get; }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/IWorkflowEnabled.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/IWorkflowEnabled.cs
new file mode 100644
index 000000000..077befb5b
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/IWorkflowEnabled.cs
@@ -0,0 +1,6 @@
+namespace LINGYUN.Abp.WorkflowCore
+{
+ public interface IWorkflowEnabled
+ {
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/IWorkflowManager.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/IWorkflowManager.cs
new file mode 100644
index 000000000..6f0b5b2ff
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/IWorkflowManager.cs
@@ -0,0 +1,10 @@
+using System;
+using System.Collections.Generic;
+using System.Text;
+
+namespace LINGYUN.Abp.WorkflowCore
+{
+ public interface IWorkflowManager
+ {
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/NullStepBody.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/NullStepBody.cs
new file mode 100644
index 000000000..6561894df
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/NullStepBody.cs
@@ -0,0 +1,14 @@
+using Volo.Abp.DependencyInjection;
+using WorkflowCore.Interface;
+using WorkflowCore.Models;
+
+namespace LINGYUN.Abp.WorkflowCore
+{
+ public class NullStepBody : StepBody, ITransientDependency
+ {
+ public override ExecutionResult Run(IStepExecutionContext context)
+ {
+ return ExecutionResult.Next();
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/WorkflowBase.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/WorkflowBase.cs
new file mode 100644
index 000000000..4b694e01a
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/WorkflowBase.cs
@@ -0,0 +1,14 @@
+using WorkflowCore.Interface;
+using Volo.Abp.DependencyInjection;
+
+namespace LINGYUN.Abp.WorkflowCore
+{
+ public abstract class WorkflowBase : IWorkflow, ISingletonDependency
+ {
+ public abstract string Id { get; }
+
+ public abstract int Version { get; }
+
+ public abstract void Build(IWorkflowBuilder builder);
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/WorkflowConditionCondition.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/WorkflowConditionCondition.cs
new file mode 100644
index 000000000..bcfb674dc
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/WorkflowConditionCondition.cs
@@ -0,0 +1,9 @@
+namespace LINGYUN.Abp.WorkflowCore
+{
+ public class WorkflowConditionCondition
+ {
+ public string Field { get; set; }
+ public string Operator { get; set; }
+ public object Value { get; set; }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/WorkflowConditionNode.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/WorkflowConditionNode.cs
new file mode 100644
index 000000000..5a78cf224
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/WorkflowConditionNode.cs
@@ -0,0 +1,15 @@
+using System.Collections.Generic;
+
+namespace LINGYUN.Abp.WorkflowCore
+{
+ public class WorkflowConditionNode
+ {
+ public string Label { get; set; }
+ public string NodeId { get; set; }
+ public IEnumerable Conditions { get; set; }
+ public WorkflowConditionNode()
+ {
+ Conditions = new List();
+ }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/WorkflowDefinition.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/WorkflowDefinition.cs
new file mode 100644
index 000000000..c62501d2e
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/WorkflowDefinition.cs
@@ -0,0 +1,17 @@
+using System.Collections.Generic;
+
+namespace LINGYUN.Abp.WorkflowCore
+{
+ public class WorkflowDefinition
+ {
+ public string Id { get; set; }
+ public string Title { get; set; }
+ public int Version { get; set; }
+ public string Description { get; set; }
+ public string Icon { get; set; }
+ public string Color { get; set; }
+ public string Group { get; set; }
+ public ICollection Nodes { get; set; }
+ public ICollection Inputs { get; set; }
+ }
+}
diff --git a/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/WorkflowFormData.cs b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/WorkflowFormData.cs
new file mode 100644
index 000000000..7de0584ec
--- /dev/null
+++ b/aspnet-core/modules/workflow/LINGYUN.Abp.WorkflowCore/LINGYUN/Abp/WorkflowCore/WorkflowFormData.cs
@@ -0,0 +1,24 @@
+using System.Collections.Generic;
+
+namespace LINGYUN.Abp.WorkflowCore
+{
+ public class WorkflowFormData
+ {
+ public string Id { get; set; }
+ public string Name { get; set; }
+ public string Label { get; set; }
+ public string Type { get; set; }
+ public object Value { get; set; }
+ public IEnumerable