52 lines
2.0 KiB
C#
52 lines
2.0 KiB
C#
using e_suite.API.Common;
|
|
using e_suite.API.Common.repository;
|
|
using e_suite.Database.Audit;
|
|
using e_suite.Database.Core.Extensions;
|
|
using e_suite.Database.Core.Tables.Activity;
|
|
using e_suite.Messaging.Common;
|
|
using eSuite.Core.Miscellaneous;
|
|
using Microsoft.EntityFrameworkCore;
|
|
|
|
namespace e_suite.Modules.RunningActivityManager;
|
|
|
|
public class ActivityManager : IActivityManager
|
|
{
|
|
private readonly IActivityMessageSender _activityMessageSender;
|
|
private readonly IActivityRepository _activityRepository;
|
|
private readonly IWorkflowTemplateRepository _workflowTemplateRepository;
|
|
|
|
public ActivityManager(IActivityMessageSender activityMessageSender, IActivityRepository activityRepository, IWorkflowTemplateRepository workflowTemplateRepository)
|
|
{
|
|
_activityMessageSender = activityMessageSender;
|
|
_activityRepository = activityRepository;
|
|
_workflowTemplateRepository = workflowTemplateRepository;
|
|
}
|
|
|
|
public async Task CreateActivity(
|
|
AuditUserDetails auditUserDetails,
|
|
CreateActivity template,
|
|
CancellationToken cancellationToken
|
|
)
|
|
{
|
|
GeneralIdRef? progressActivityRef = null;
|
|
await _activityRepository.TransactionAsync(async () =>
|
|
{
|
|
var workflowTemplate = _workflowTemplateRepository.GetWorkflows().Include( x => x.Versions).FindByGeneralIdRef(template.WorkflowTemplateId);
|
|
var workflowTemplateVersion = workflowTemplate!.Versions.OrderByDescending(x => x.Version).First();
|
|
|
|
Activity activity = new Activity
|
|
{
|
|
Guid = Guid.NewGuid(),
|
|
Name = template.ActivityName,
|
|
WorkflowVersion = workflowTemplateVersion,
|
|
};
|
|
|
|
await _activityRepository.CreateActivityInstanceAsync(auditUserDetails, activity, cancellationToken);
|
|
|
|
progressActivityRef = activity.ToGeneralIdRef();
|
|
});
|
|
|
|
if (progressActivityRef != null)
|
|
_activityMessageSender.ProgressActivity(progressActivityRef);
|
|
}
|
|
} |