VberAdmin_V4/SourceCode/Zero/VberYue.Zero/Workflows/VbWorkflowPersistenceProvider.cs

using Abp;
using Abp.Domain.Repositories;
using Abp.Domain.Uow;
using Abp.Linq;

using VberZero.Authorization;
using VberZero.Session;
using VberZero.Workflow;
using VberZero.Workflow.DesignInfo;
using VberZero.Workflow.Persistence;

using WorkflowCore.Models;

namespace VberZero.Workflows;

public class VbWorkflowPersistenceProvider : VberPersistenceProvider
{
    public VbWorkflowPersistenceProvider(IRepository<WorkflowEventInfo, string> eventRepository, IRepository<WorkflowExecutionPointerInfo, string> executionPointerRepository, IRepository<WorkflowInfo, string> workflowRepository, IRepository<WorkflowSubscriptionInfo, string> eventSubscriptionRepository, IGuidGenerator guidGenerator, IAsyncQueryableExecuter asyncQueryableExecuter, IRepository<WorkflowExecutionErrorInfo, string> executionErrorRepository, IRepository<WorkflowDefinitionInfo, string> workflowDefinitionRepository) : base(eventRepository, executionPointerRepository, workflowRepository, eventSubscriptionRepository, guidGenerator, asyncQueryableExecuter, executionErrorRepository, workflowDefinitionRepository)
    {
    }

    public new IVzSession AbpSession { get; set; }

    [UnitOfWork]
    public override async Task<string> CreateNewWorkflow(WorkflowInstance workflow, CancellationToken cancellationToken = new())
    {
        var entity = GenerateWorkflow(workflow);
        if (AbpSession.UserId.HasValue)
        {
            var name = AbpSession.GetClaimValue(VzClaimTypes.RealName);
            entity.CreateUserIdentityName = name;
        }
        await _workflowRepository.InsertAsync(entity);
        await CurrentUnitOfWork.SaveChangesAsync();
        return workflow.Id;
    }
}