| | |
|---|
| | | public WorkStep CurStep { get; set; } |
|---|
| | | public List<WorkStep> NextSteps { get; set; } = new(); |
|---|
| | | public bool IsFinishNodeSteps => !Steps.Any(q => q.NodeType == IWorkStep.NodeTypes.Node && !q.IsFinished); |
|---|
| | | public bool IsFinishAllSteps => !Steps.Any() || !Steps.Any(q => !q.IsFinished); |
|---|
| | | public bool IsFinishAllSteps => Steps.Any() && !Steps.Any(q => !q.IsFinished); |
|---|
| | | //public int CurStep => Steps.Where(q => !q.IsFinished).OrderBy(q => q.Sequence).FirstOrDefault()?.Sequence ?? 0; |
|---|
| | | private DbClient CommitDB; |
|---|
| | | /// <summary> |
|---|
| | |
|---|
| | | CurStep = step; |
|---|
| | | //更新后续可执行的工步列表 |
|---|
| | | NextSteps = GetNextSteps(CurStep); |
|---|
| | | //返回结果到客户端 |
|---|
| | | result = canBegin; |
|---|
| | | result.Data.SetValue(CurBatch, CurStep, CurStep?.ID, IsFinishAllSteps); |
|---|
| | | |
|---|
| | | //如果当前执行工步尝试执行后就已经完成，不需要后续交互，且，则继续开始下一工步 |
|---|
| | | if (CurStep.IsFinished && NextSteps.Any()) |
|---|
| | | { |
|---|
| | | result = BeginNextActionStep(input); |
|---|
| | | } |
|---|
| | | else |
|---|
| | | { |
|---|
| | | //返回结果到客户端 |
|---|
| | | result = canBegin; |
|---|
| | | result.Data.SetValue(CurBatch, CurStep, CurStep?.ID, IsFinishAllSteps); |
|---|
| | | } |
|---|
| | | return result; |
|---|
| | | } |
|---|
| | | //工序被重置 |
|---|
| | | else if(Steps.IsNullOrEmpty()) |
|---|
| | | { |
|---|
| | | return canBegin; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | //没有可以直接开始的后续工步，根据后续工步返回ApiAction |
|---|
