|
|
@@ -10,6 +10,7 @@ using Hotline.Share.Enums.FlowEngine;
|
|
|
using MapsterMapper;
|
|
|
using MediatR;
|
|
|
using Microsoft.Extensions.Logging;
|
|
|
+using System.Diagnostics;
|
|
|
using System.Threading;
|
|
|
using XF.Domain.Authentications;
|
|
|
using XF.Domain.Dependency;
|
|
|
@@ -110,7 +111,6 @@ namespace Hotline.FlowEngine.Workflows
|
|
|
};
|
|
|
_mapper.Map(workflow.WorkflowDefinition, startStep);
|
|
|
workflow.Steps.Add(startStep);
|
|
|
- //await _workflowStepRepository.AddAsync(startStep, cancellationToken);
|
|
|
|
|
|
//firststep
|
|
|
var firstStep = new WorkflowStep
|
|
|
@@ -123,27 +123,26 @@ namespace Hotline.FlowEngine.Workflows
|
|
|
};
|
|
|
_mapper.Map(workflow.WorkflowDefinition, firstStep);
|
|
|
workflow.Steps.Add(firstStep);
|
|
|
- //await _workflowStepRepository.AddAsync(firstStep, cancellationToken);
|
|
|
+
|
|
|
await _workflowStepRepository.AddRangeAsync(workflow.Steps, cancellationToken);
|
|
|
|
|
|
//starttrace
|
|
|
var startTrace = _mapper.Map<WorkflowTrace>(startStep);
|
|
|
startTrace.StepId = startStep.Id;
|
|
|
startTrace.Status = EWorkflowTraceStatus.Normal;
|
|
|
+ _mapper.Map(dto, startTrace);
|
|
|
workflow.Traces.Add(startTrace);
|
|
|
- //await _workflowTraceRepository.AddAsync(startTrace, cancellationToken);
|
|
|
|
|
|
//firsttrace
|
|
|
var firstTrace = _mapper.Map<WorkflowTrace>(firstStep);
|
|
|
firstTrace.StepId = firstStep.Id;
|
|
|
firstTrace.Status = EWorkflowTraceStatus.Normal;
|
|
|
workflow.Traces.Add(firstTrace);
|
|
|
- //await _workflowTraceRepository.AddAsync(firstTrace, cancellationToken);
|
|
|
+
|
|
|
await _workflowTraceRepository.AddRangeAsync(workflow.Traces, cancellationToken);
|
|
|
|
|
|
//办理开始节点
|
|
|
var counterSignType = GetCounterSignType(firstStep.BusinessType);
|
|
|
-
|
|
|
await HandleStepAsync(startStep, workflow, dto, counterSignType, cancellationToken);
|
|
|
await _workflowStepRepository.UpdateAsync(startStep, cancellationToken);
|
|
|
|
xf