55 lines
2.1 KiB
C#
55 lines
2.1 KiB
C#
|
using Elsa.Common.Entities;
|
||
|
|
using Elsa.Workflows.Runtime.Contracts;
|
||
|
|
using Elsa.Workflows.Runtime.Filters;
|
||
|
|
using Elsa.Workflows.Runtime.Models;
|
||
|
|
using Elsa.Workflows.Runtime.OrderDefinitions;
|
||
|
|
|
||
|
|
namespace Elsa.Workflows.Runtime.Services;
|
||
|
|
|
||
|
|
/// <inheritdoc />
|
||
|
|
public class ActivityExecutionService : IActivityExecutionService
|
||
|
|
{
|
||
|
|
private readonly IActivityExecutionStore _store;
|
||
|
|
|
||
|
|
/// <summary>
|
||
|
|
/// Initializes a new instance of the <see cref="ActivityExecutionService"/> class.
|
||
|
|
/// </summary>
|
||
|
|
public ActivityExecutionService(IActivityExecutionStore store)
|
||
|
|
{
|
||
|
|
_store = store;
|
||
|
|
}
|
||
|
|
|
||
|
|
/// <inheritdoc />
|
||
|
|
public async Task<IEnumerable<ActivityExecutionStats>> GetStatsAsync(string workflowInstanceId, IEnumerable<string> activityIds, CancellationToken cancellationToken = default)
|
||
|
|
{
|
||
|
|
var filter = new ActivityExecutionRecordFilter
|
||
|
|
{
|
||
|
|
WorkflowInstanceId = workflowInstanceId,
|
||
|
|
ActivityIds = activityIds.ToList()
|
||
|
|
};
|
||
|
|
var order = new ActivityExecutionRecordOrder<DateTimeOffset>(x => x.StartedAt, OrderDirection.Ascending);
|
||
|
|
var records = (await _store.FindManyAsync(filter, order, cancellationToken)).ToList();
|
||
|
|
var groupedRecords = records.GroupBy(x => x.ActivityId).ToList();
|
||
|
|
var stats = groupedRecords.Select(grouping => new ActivityExecutionStats
|
||
|
|
{
|
||
|
|
ActivityId = grouping.Key,
|
||
|
|
StartedCount = grouping.Count(),
|
||
|
|
CompletedCount = grouping.Count(x => x.CompletedAt != null),
|
||
|
|
UncompletedCount = grouping.Count(x => x.CompletedAt == null),
|
||
|
|
IsBlocked = grouping.Any(x => x.HasBookmarks)
|
||
|
|
}).ToList();
|
||
|
|
|
||
|
|
return stats;
|
||
|
|
}
|
||
|
|
|
||
|
|
/// <inheritdoc />
|
||
|
|
public async Task<ActivityExecutionStats> GetStatsAsync(string workflowInstanceId, string activityId, CancellationToken cancellationToken = default)
|
||
|
|
{
|
||
|
|
var stats = (await GetStatsAsync(workflowInstanceId, new[] { activityId }, cancellationToken)).FirstOrDefault();
|
||
|
|
|
||
|
|
return stats ?? new ActivityExecutionStats
|
||
|
|
{
|
||
|
|
ActivityId = activityId
|
||
|
|
};
|
||
|
|
}
|
||
|
|
}
|