|
@@ -659,7 +659,7 @@ namespace Hotline.FlowEngine.Workflows
|
|
|
await _workflowRepository.UpdateAsync(workflow, cancellationToken);
|
|
|
|
|
|
await _publisher.PublishAsync(new PreviousNotify(workflow, newPrevStep, dto, isOrgToCenter),
|
|
|
- PublishStrategy.ParallelNoWait, cancellationToken);
|
|
|
+ PublishStrategy.ParallelWhenAll, cancellationToken);
|
|
|
|
|
|
return GetFlowDirection(currentStep.BusinessType, prevStep.BusinessType);
|
|
|
}
|
|
@@ -1051,7 +1051,7 @@ namespace Hotline.FlowEngine.Workflows
|
|
|
await _workflowRepository.UpdateAsync(workflow, cancellationToken);
|
|
|
|
|
|
await _publisher.PublishAsync(new RecallNotify(workflow, targetStep, dto, isOrgToCenter),
|
|
|
- PublishStrategy.ParallelNoWait, cancellationToken);
|
|
|
+ PublishStrategy.ParallelWhenAll, cancellationToken);
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
@@ -1122,7 +1122,7 @@ namespace Hotline.FlowEngine.Workflows
|
|
|
var dto = _mapper.Map<RecallDto>(targetStep);
|
|
|
dto.WorkflowId = workflow.Id;
|
|
|
await _publisher.PublishAsync(new RecallNotify(workflow, targetStep, dto, isOrgToCenter),
|
|
|
- PublishStrategy.ParallelNoWait, cancellationToken);
|
|
|
+ PublishStrategy.ParallelWhenAll, cancellationToken);
|
|
|
}
|
|
|
|
|
|
///// <summary>
|