mirror of
https://gitee.com/langsisi_admin/serein-flow
synced 2026-03-03 00:00:49 +08:00
789 lines
34 KiB
C#
789 lines
34 KiB
C#
using Newtonsoft.Json;
|
||
using Newtonsoft.Json.Linq;
|
||
using Serein.Library.Api;
|
||
using Serein.Library.Utils;
|
||
using Serein.Library.Utils.SereinExpression;
|
||
using System;
|
||
using System.Collections;
|
||
using System.Collections.Generic;
|
||
using System.ComponentModel.Design;
|
||
using System.Linq;
|
||
using System.Linq.Expressions;
|
||
using System.Net.Http.Headers;
|
||
using System.Reflection;
|
||
using System.Runtime.CompilerServices;
|
||
using System.Text;
|
||
using System.Threading;
|
||
using System.Threading.Tasks;
|
||
using System.Xml.Linq;
|
||
using static Serein.Library.Utils.ChannelFlowInterrupt;
|
||
|
||
namespace Serein.Library
|
||
{
|
||
|
||
|
||
|
||
/// <summary>
|
||
/// 节点基类（数据）：条件控件，动作控件，条件区域，动作区域
|
||
/// </summary>
|
||
public abstract partial class NodeModelBase : IDynamicFlowNode
|
||
{
|
||
#region 导出/导入项目文件节点信息
|
||
|
||
/// <summary>
|
||
/// 获取节点参数
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
public abstract ParameterData[] GetParameterdatas();
|
||
|
||
/// <summary>
|
||
/// 导出为节点信息
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
public virtual NodeInfo ToInfo()
|
||
{
|
||
// if (MethodDetails == null) return null;
|
||
|
||
var trueNodes = SuccessorNodes[ConnectionInvokeType.IsSucceed].Select(item => item.Guid); // 真分支
|
||
var falseNodes = SuccessorNodes[ConnectionInvokeType.IsFail].Select(item => item.Guid);// 假分支
|
||
var errorNodes = SuccessorNodes[ConnectionInvokeType.IsError].Select(item => item.Guid);// 异常分支
|
||
var upstreamNodes = SuccessorNodes[ConnectionInvokeType.Upstream].Select(item => item.Guid);// 上游分支
|
||
|
||
// 生成参数列表
|
||
ParameterData[] parameterData = GetParameterdatas();
|
||
|
||
return new NodeInfo
|
||
{
|
||
Guid = Guid,
|
||
AssemblyName = MethodDetails.AssemblyName,
|
||
MethodName = MethodDetails?.MethodName,
|
||
Label = MethodDetails?.MethodAnotherName,
|
||
Type = this.GetType().ToString(),
|
||
TrueNodes = trueNodes.ToArray(),
|
||
FalseNodes = falseNodes.ToArray(),
|
||
UpstreamNodes = upstreamNodes.ToArray(),
|
||
ParameterData = parameterData.ToArray(),
|
||
ErrorNodes = errorNodes.ToArray(),
|
||
Position = Position,
|
||
};
|
||
}
|
||
|
||
/// <summary>
|
||
/// 从节点信息加载节点
|
||
/// </summary>
|
||
/// <param name="nodeInfo"></param>
|
||
/// <returns></returns>
|
||
public virtual NodeModelBase LoadInfo(NodeInfo nodeInfo)
|
||
{
|
||
this.Guid = nodeInfo.Guid;
|
||
|
||
if (nodeInfo.Position is null)
|
||
{
|
||
nodeInfo.Position = new PositionOfUI(0, 0);
|
||
}
|
||
this.Position = nodeInfo.Position;// 加载位置信息
|
||
if (this.MethodDetails != null)
|
||
{
|
||
if(this.MethodDetails.ParameterDetailss is null)
|
||
{
|
||
this.MethodDetails.ParameterDetailss = new ParameterDetails[nodeInfo.ParameterData.Length];
|
||
this.MethodDetails.ParameterDetailss = nodeInfo.ParameterData.Select((pd,index) =>
|
||
{
|
||
return new ParameterDetails()
|
||
{
|
||
Index = index,
|
||
NodeModel = this,
|
||
DataType = typeof(object),
|
||
ExplicitType = typeof(object),
|
||
Name = string.Empty,
|
||
ExplicitTypeName = "Value",
|
||
IsExplicitData = pd.State,
|
||
DataValue = pd.Value,
|
||
ArgDataSourceType = EnumHelper.ConvertEnum<ConnectionArgSourceType>(pd.SourceType),
|
||
ArgDataSourceNodeGuid = pd.SourceNodeGuid,
|
||
};
|
||
}).ToArray();
|
||
}
|
||
else
|
||
{
|
||
var md = this.MethodDetails; // 当前节点的方法说明
|
||
var pds = md.ParameterDetailss; // 当前节点的入参描述数组
|
||
if (nodeInfo.ParameterData.Length > pds.Length && md.HasParamsArg)
|
||
{
|
||
// 保存的参数信息项数量大于方法本身的方法入参数量（可能存在可变入参）
|
||
var length = nodeInfo.ParameterData.Length - pds.Length; // 需要扩容的长度
|
||
this.MethodDetails.ParameterDetailss = ArrayHelper.Expansion(pds, length); // 扩容入参描述数组
|
||
pds = this.MethodDetails.ParameterDetailss;
|
||
var startParmsPd = pds[md.ParamsArgIndex]; // 获取可变入参参数描述
|
||
for(int i = md.ParamsArgIndex + 1; i <= md.ParamsArgIndex + length; i++)
|
||
{
|
||
pds[i] = startParmsPd.CloneOfModel(this);
|
||
pds[i].Index = pds[i-1].Index + 1;
|
||
pds[i].IsParams = true;
|
||
}
|
||
}
|
||
for (int i = 0; i < nodeInfo.ParameterData.Length; i++)
|
||
{
|
||
if(i >= pds.Length)
|
||
{
|
||
Env.WriteLine(InfoType.ERROR, $"保存的参数数量大于方法此时的入参参数数量：[{nodeInfo.Guid}][{nodeInfo.MethodName}]");
|
||
|
||
break;
|
||
}
|
||
var pd = pds[i];
|
||
ParameterData pdInfo = nodeInfo.ParameterData[i];
|
||
pd.IsExplicitData = pdInfo.State;
|
||
pd.DataValue = pdInfo.Value;
|
||
pd.ArgDataSourceType = EnumHelper.ConvertEnum<ConnectionArgSourceType>(pdInfo.SourceType);
|
||
pd.ArgDataSourceNodeGuid = pdInfo.SourceNodeGuid;
|
||
|
||
}
|
||
}
|
||
|
||
|
||
|
||
|
||
}
|
||
return this;
|
||
}
|
||
#endregion
|
||
|
||
#region 程序集更新，更新节点方法描述、以及所有入参描述的类型
|
||
|
||
#endregion
|
||
|
||
#region 调试中断
|
||
|
||
/// <summary>
|
||
/// 不再中断
|
||
/// </summary>
|
||
public void CancelInterrupt()
|
||
{
|
||
this.DebugSetting.IsInterrupt = false;
|
||
DebugSetting.CancelInterruptCallback?.Invoke();
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 节点方法的执行
|
||
|
||
/// <summary>
|
||
/// 是否应该退出执行
|
||
/// </summary>
|
||
/// <param name="context"></param>
|
||
/// <param name="flowCts"></param>
|
||
/// <returns></returns>
|
||
public static bool IsBradk(IDynamicContext context, CancellationTokenSource flowCts)
|
||
{
|
||
// 上下文不再执行
|
||
if (context.RunState == RunState.Completion)
|
||
{
|
||
return true;
|
||
}
|
||
|
||
// 不存在全局触发器时，流程运行状态被设置为完成，退出执行，用于打断无限循环分支。
|
||
if (flowCts is null && context.Env.FlowState == RunState.Completion)
|
||
{
|
||
return true;
|
||
}
|
||
// 如果存在全局触发器，且触发器的执行任务已经被取消时，退出执行。
|
||
if (flowCts != null)
|
||
{
|
||
if (flowCts.IsCancellationRequested)
|
||
return true;
|
||
}
|
||
return false;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 开始执行
|
||
/// </summary>
|
||
/// <param name="context"></param>
|
||
/// <returns></returns>
|
||
public async Task StartFlowAsync(IDynamicContext context)
|
||
{
|
||
Stack<NodeModelBase> stack = new Stack<NodeModelBase>();
|
||
HashSet<NodeModelBase> processedNodes = new HashSet<NodeModelBase>(); // 用于记录已处理上游节点的节点
|
||
stack.Push(this);
|
||
var flowCts = context.Env.IOC.Get<CancellationTokenSource>(NodeStaticConfig.FlipFlopCtsName);
|
||
bool hasFlipflow = flowCts != null;
|
||
while (stack.Count > 0) // 循环中直到栈为空才会退出循环
|
||
{
|
||
#if DEBUG
|
||
await Task.Delay(1);
|
||
#endif
|
||
|
||
#region 执行相关
|
||
|
||
// 从栈中弹出一个节点作为当前节点进行处理
|
||
var currentNode = stack.Pop();
|
||
#if false
|
||
// 筛选出上游分支
|
||
var upstreamNodes = currentNode.SuccessorNodes[ConnectionInvokeType.Upstream].ToArray();
|
||
for (int index = 0; index < upstreamNodes.Length; index++)
|
||
{
|
||
NodeModelBase upstreamNode = upstreamNodes[index];
|
||
if (!(upstreamNode is null) && upstreamNode.DebugSetting.IsEnable)
|
||
{
|
||
if (upstreamNode.DebugSetting.IsInterrupt) // 执行触发前
|
||
{
|
||
var cancelType = await upstreamNode.DebugSetting.GetInterruptTask();
|
||
await Console.Out.WriteLineAsync($"[{upstreamNode.MethodDetails?.MethodName}]中断已{cancelType}，开始执行后继分支");
|
||
}
|
||
context.SetPreviousNode(upstreamNode, currentNode);
|
||
await upstreamNode.StartFlowAsync(context); // 执行流程节点的上游分支
|
||
if (context.NextOrientation == ConnectionInvokeType.IsError)
|
||
{
|
||
// 如果上游分支执行失败，不再继续执行
|
||
// 使上游节点（仅上游节点本身，不包含上游节点的后继节点）
|
||
// 具备通过抛出异常中断流程的能力
|
||
break;
|
||
}
|
||
}
|
||
}
|
||
#endif
|
||
// 上游分支执行完成，才执行当前节点
|
||
if (IsBradk(context, flowCts)) break; // 退出执行
|
||
context.NextOrientation = ConnectionInvokeType.None; // 重置上下文状态
|
||
|
||
object newFlowData;
|
||
try
|
||
{
|
||
|
||
if (IsBradk(context, flowCts)) break; // 退出执行
|
||
newFlowData = await currentNode.ExecutingAsync(context);
|
||
if (IsBradk(context, flowCts)) break; // 退出执行
|
||
if (context.NextOrientation == ConnectionInvokeType.None) // 没有手动设置时，进行自动设置
|
||
{
|
||
context.NextOrientation = ConnectionInvokeType.IsSucceed;
|
||
}
|
||
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
newFlowData = null;
|
||
context.Env.WriteLine(InfoType.ERROR, $"节点[{currentNode.Guid}]异常：" + ex);
|
||
context.NextOrientation = ConnectionInvokeType.IsError;
|
||
context.ExceptionOfRuning = ex;
|
||
}
|
||
|
||
|
||
await RefreshFlowDataAndExpInterrupt(context, currentNode, newFlowData); // 执行当前节点后刷新数据
|
||
#endregion
|
||
|
||
#region 执行完成
|
||
|
||
// 首先将指定类别后继分支的所有节点逆序推入栈中
|
||
var nextNodes = currentNode.SuccessorNodes[context.NextOrientation];
|
||
for (int index = nextNodes.Count - 1; index >= 0; index--)
|
||
{
|
||
// 筛选出启用的节点的节点
|
||
if (nextNodes[index].DebugSetting.IsEnable)
|
||
{
|
||
context.SetPreviousNode(nextNodes[index], currentNode);
|
||
stack.Push(nextNodes[index]);
|
||
}
|
||
}
|
||
// 然后将指上游分支的所有节点逆序推入栈中
|
||
var upstreamNodes = currentNode.SuccessorNodes[ConnectionInvokeType.Upstream];
|
||
for (int index = upstreamNodes.Count - 1; index >= 0; index--)
|
||
{
|
||
// 筛选出启用的节点的节点
|
||
if (upstreamNodes[index].DebugSetting.IsEnable)
|
||
{
|
||
context.SetPreviousNode(upstreamNodes[index], currentNode);
|
||
stack.Push(upstreamNodes[index]);
|
||
}
|
||
}
|
||
#endregion
|
||
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 执行节点对应的方法
|
||
/// </summary>
|
||
/// <param name="context">流程上下文</param>
|
||
/// <returns>节点传回数据对象</returns>
|
||
public virtual async Task<object> ExecutingAsync(IDynamicContext context)
|
||
{
|
||
#region 调试中断
|
||
|
||
if (DebugSetting.IsInterrupt) // 执行触发检查是否需要中断
|
||
{
|
||
var cancelType = await this.DebugSetting.GetInterruptTask(); // 等待中断结束
|
||
await Console.Out.WriteLineAsync($"[{this.MethodDetails?.MethodName}]中断已{cancelType}，开始执行后继分支");
|
||
}
|
||
|
||
#endregion
|
||
|
||
MethodDetails md = MethodDetails;
|
||
if (md is null)
|
||
{
|
||
throw new Exception($"节点{this.Guid}不存在方法信息，请检查是否需要重写节点的ExecutingAsync");
|
||
}
|
||
if (!context.Env.TryGetDelegateDetails(md.AssemblyName, md.MethodName, out var dd)) // 流程运行到某个节点
|
||
{
|
||
throw new Exception($"节点{this.Guid}不存在对应委托");
|
||
}
|
||
if (md.ActingInstance is null)
|
||
{
|
||
md.ActingInstance = context.Env.IOC.Get(md.ActingInstanceType);
|
||
}
|
||
|
||
object[] args = await GetParametersAsync(context, this, md);
|
||
var result = await dd.InvokeAsync(md.ActingInstance, args);
|
||
return result;
|
||
|
||
}
|
||
|
||
/// <summary>
|
||
/// 获取对应的参数数组
|
||
/// </summary>
|
||
public static async Task<object[]> GetParametersAsync(IDynamicContext context,
|
||
NodeModelBase nodeModel,
|
||
MethodDetails md)
|
||
{
|
||
// 用正确的大小初始化参数数组
|
||
if (md.ParameterDetailss.Length == 0)
|
||
{
|
||
return null;// md.ActingInstance
|
||
}
|
||
|
||
object[] parameters;
|
||
Array paramsArgs = null; // 初始化可选参数
|
||
int paramsArgIndex = 0; // 可选参数下标，与 object[] paramsArgs 一起使用
|
||
|
||
if (md.ParamsArgIndex >= 0)
|
||
{
|
||
// 存在可变入参参数
|
||
var paramsArgType = md.ParameterDetailss[md.ParamsArgIndex].DataType; // 获取可变参数的参数类型
|
||
// 可变参数数组长度 = 方法参数个数 - （ 可选入参下标 + 1 ）
|
||
int paramsLength = md.ParameterDetailss.Length - md.ParamsArgIndex;
|
||
paramsArgs = Array.CreateInstance(paramsArgType, paramsLength);// 可变参数
|
||
parameters = new object[md.ParamsArgIndex+1]; // 调用方法的入参数组
|
||
parameters[md.ParamsArgIndex] = paramsArgs; // 如果存在可选参数，入参参数最后一项则为可变参数
|
||
}
|
||
else
|
||
{
|
||
// 不存在可选参数
|
||
parameters = new object[md.ParameterDetailss.Length]; // 调用方法的入参数组
|
||
}
|
||
|
||
bool hasParams = false;
|
||
for (int i = 0; i < md.ParameterDetailss.Length; i++)
|
||
{
|
||
var pd = md.ParameterDetailss[i]; // 方法入参描述
|
||
var argDataType = pd.DataType;
|
||
|
||
// 入参参数下标循环到可选参数时，开始写入到可选参数数组
|
||
if (paramsArgs != null && i >= md.ParamsArgIndex)
|
||
{
|
||
// 控制参数赋值方向：
|
||
// true => paramsArgs
|
||
// false => parameters
|
||
hasParams = true;
|
||
}
|
||
|
||
#region 获取基础的上下文数据
|
||
if (argDataType == typeof(IFlowEnvironment)) // 获取流程上下文
|
||
{
|
||
parameters[i] = nodeModel.Env;
|
||
continue;
|
||
}
|
||
if (argDataType == typeof(IDynamicContext)) // 获取流程上下文
|
||
{
|
||
parameters[i] = context;
|
||
continue;
|
||
}
|
||
#endregion
|
||
|
||
#region 确定[预入参]数据
|
||
object inputParameter; // 存放解析的临时参数
|
||
if (pd.IsExplicitData && !pd.DataValue.StartsWith("@", StringComparison.OrdinalIgnoreCase)) // 判断是否使用显示的输入参数
|
||
{
|
||
// 使用输入的固定值
|
||
inputParameter = pd.DataValue;
|
||
}
|
||
else
|
||
{
|
||
#region （默认的）从运行时上游节点获取其返回值
|
||
if (pd.ArgDataSourceType == ConnectionArgSourceType.GetPreviousNodeData)
|
||
{
|
||
var previousNode = context.GetPreviousNode(nodeModel);
|
||
if (previousNode is null)
|
||
{
|
||
inputParameter = null;
|
||
}
|
||
else
|
||
{
|
||
inputParameter = context.GetFlowData(previousNode.Guid); // 当前传递的数据
|
||
|
||
}
|
||
}
|
||
#endregion
|
||
#region 从指定节点获取其返回值
|
||
else if (pd.ArgDataSourceType == ConnectionArgSourceType.GetOtherNodeData)
|
||
{
|
||
// 获取指定节点的数据
|
||
// 如果指定节点没有被执行，会返回null
|
||
// 如果执行过，会获取上一次执行结果作为预入参数据
|
||
inputParameter = context.GetFlowData(pd.ArgDataSourceNodeGuid);
|
||
}
|
||
#endregion
|
||
#region 立刻执行指定节点，然后获取返回值
|
||
else if (pd.ArgDataSourceType == ConnectionArgSourceType.GetOtherNodeDataOfInvoke)
|
||
{
|
||
// 立刻调用对应节点获取数据。
|
||
var result = await context.Env.InvokeNodeAsync(context, pd.ArgDataSourceNodeGuid);
|
||
inputParameter = result;
|
||
}
|
||
#endregion
|
||
#region 意料之外的参数
|
||
else
|
||
{
|
||
throw new Exception("节点执行方法获取入参参数时，ConnectionArgSourceType枚举是意外的枚举值");
|
||
}
|
||
#endregion
|
||
}
|
||
|
||
|
||
|
||
#region 处理 @Get / @DTC 表达式 （Data type conversion） / @Data (全局数据)
|
||
if (pd.IsExplicitData)
|
||
{
|
||
|
||
// @Get 表达式 （从上一节点获取对象）
|
||
if (pd.DataValue.StartsWith("@get", StringComparison.OrdinalIgnoreCase))
|
||
{
|
||
inputParameter = SerinExpressionEvaluator.Evaluate(pd.DataValue, inputParameter, out _);
|
||
}
|
||
|
||
// @DTC 表达式 （Data type conversion）
|
||
if (pd.DataValue.StartsWith("@dtc", StringComparison.OrdinalIgnoreCase))
|
||
{
|
||
inputParameter = SerinExpressionEvaluator.Evaluate(pd.DataValue, inputParameter, out _);
|
||
}
|
||
|
||
// @Data 表达式 （获取全局数据）
|
||
if (pd.DataValue.StartsWith("@data", StringComparison.OrdinalIgnoreCase))
|
||
{
|
||
inputParameter = SerinExpressionEvaluator.Evaluate(pd.DataValue, inputParameter, out _);
|
||
}
|
||
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 对于非值类型的null检查
|
||
if (!argDataType.IsValueType && inputParameter is null)
|
||
{
|
||
parameters[i] = null;
|
||
throw new Exception($"[arg{pd.Index}][{pd.Name}][{argDataType}]参数不能为null");
|
||
continue;
|
||
}
|
||
#endregion
|
||
|
||
#endregion
|
||
|
||
#region 入参存在取值转换器，调用对应的转换器获取入参数据，如果获取成功（不为null）会跳过循环
|
||
if (pd.ExplicitType.IsEnum && !(pd.Convertor is null))
|
||
{
|
||
//var resultEnum = Enum.ToObject(ed.ExplicitType, ed.DataValue);
|
||
var resultEnum = Enum.Parse(pd.ExplicitType, pd.DataValue);
|
||
var value = pd.Convertor(resultEnum);
|
||
if (value is null)
|
||
{
|
||
throw new InvalidOperationException("转换器调用失败");
|
||
|
||
}
|
||
else
|
||
{
|
||
if (hasParams)
|
||
{
|
||
paramsArgs.SetValue(value, paramsArgIndex++);
|
||
// 处理可选参数
|
||
//paramsArgs[paramsArgIndex++] = value;
|
||
}
|
||
else
|
||
{
|
||
parameters[i] = value;
|
||
}
|
||
continue;
|
||
}
|
||
}
|
||
#endregion
|
||
|
||
#region 入参存在基于BinValue的类型转换器，获取枚举转换器中记录的类型，如果获取成功（不为null）会跳过循环
|
||
// 入参存在基于BinValue的类型转换器，获取枚举转换器中记录的类型
|
||
if (pd.ExplicitType.IsEnum && argDataType != pd.ExplicitType)
|
||
{
|
||
var resultEnum = Enum.Parse(pd.ExplicitType, pd.DataValue);
|
||
// 获取绑定的类型
|
||
var type = EnumHelper.GetBoundValue(pd.ExplicitType, resultEnum, attr => attr.Value);
|
||
if (type is Type enumBindType && !(enumBindType is null))
|
||
{
|
||
var value = nodeModel.Env.IOC.Instantiate(enumBindType);
|
||
if (value is null)
|
||
{
|
||
|
||
}
|
||
else
|
||
{
|
||
if (hasParams)
|
||
{
|
||
// 处理可选参数
|
||
paramsArgs.SetValue(value, paramsArgIndex++);
|
||
//paramsArgs[paramsArgIndex++] = value;
|
||
}
|
||
else
|
||
{
|
||
parameters[i] = value;
|
||
}
|
||
continue;
|
||
}
|
||
}
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 对入参数据尝试进行转换
|
||
object tmpVaue = null; // 临时存放数据，最后才判断是否放置可选参数数组
|
||
var inputParameterType = inputParameter.GetType();
|
||
if (inputParameterType == argDataType)
|
||
{
|
||
tmpVaue = inputParameter; // 类型一致无需转换，直接装入入参数组
|
||
}
|
||
else if (argDataType.IsValueType)
|
||
{
|
||
// 值类型
|
||
var valueStr = inputParameter?.ToString();
|
||
tmpVaue = valueStr.ToValueData(argDataType); // 类型不一致，尝试进行转换，如果转换失败返回类型对应的默认值
|
||
}
|
||
else
|
||
{
|
||
// 引用类型
|
||
if (argDataType == typeof(string)) // 转为字符串
|
||
{
|
||
var valueStr = inputParameter?.ToString();
|
||
tmpVaue = valueStr;
|
||
}
|
||
else if(argDataType.IsSubclassOf(inputParameterType)) // 入参类型 是 预入参数据类型 的 子类/实现类
|
||
{
|
||
// 方法入参中，父类不能隐式转为子类，这里需要进行强制转换
|
||
tmpVaue = ObjectConvertHelper.ConvertParentToChild(inputParameter, argDataType);
|
||
}
|
||
else if(argDataType.IsAssignableFrom(inputParameterType)) // 入参类型 是 预入参数据类型 的 父类/接口
|
||
{
|
||
tmpVaue = inputParameter;
|
||
}
|
||
// 集合类型
|
||
//else if(inputParameter is IEnumerable collection)
|
||
//{
|
||
// var enumerableMethods = typeof(Enumerable).GetMethods(); // 获取所有的 Enumerable 扩展方法
|
||
// MethodInfo conversionMethod;
|
||
// if (argDataType.IsArray) // 转为数组
|
||
// {
|
||
// parameters[i] = inputParameter;
|
||
// conversionMethod = enumerableMethods.FirstOrDefault(m => m.Name == "ToArray" && m.IsGenericMethodDefinition);
|
||
// }
|
||
// else if (argDataType.GetGenericTypeDefinition() == typeof(List<>)) // 转为集合
|
||
// {
|
||
// conversionMethod = enumerableMethods.FirstOrDefault(m => m.Name == "ToList" && m.IsGenericMethodDefinition);
|
||
// }
|
||
// else
|
||
// {
|
||
// throw new InvalidOperationException("输入对象不是集合或目标类型不支持（目前仅支持Array、List的自动转换）");
|
||
// }
|
||
// var genericMethod = conversionMethod.MakeGenericMethod(argDataType);
|
||
// var result = genericMethod.Invoke(null, new object[] { collection });
|
||
// parameters[i] = result;
|
||
//}
|
||
|
||
|
||
|
||
}
|
||
|
||
|
||
if (hasParams)
|
||
{
|
||
// 处理可选参数
|
||
paramsArgs.SetValue(tmpVaue, paramsArgIndex++);
|
||
//paramsArgs[paramsArgIndex++] = tmpVaue;
|
||
}
|
||
else
|
||
{
|
||
parameters[i] = tmpVaue;
|
||
}
|
||
#endregion
|
||
|
||
|
||
}
|
||
|
||
|
||
return parameters;
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 更新节点数据，并检查监视表达式是否生效
|
||
/// </summary>
|
||
/// <param name="context">上下文</param>
|
||
/// <param name="nodeModel">节点Moel</param>
|
||
/// <param name="newData">新的数据</param>
|
||
/// <returns></returns>
|
||
public static async Task RefreshFlowDataAndExpInterrupt(IDynamicContext context, NodeModelBase nodeModel, object newData = null)
|
||
{
|
||
string guid = nodeModel.Guid;
|
||
context.AddOrUpdate(guid, newData); // 上下文中更新数据
|
||
if (newData is null)
|
||
{
|
||
}
|
||
else
|
||
{
|
||
await MonitorObjExpInterrupt(context, nodeModel, newData, 0); // 首先监视对象
|
||
await MonitorObjExpInterrupt(context, nodeModel, newData, 1); // 然后监视节点
|
||
//nodeModel.FlowData = newData; // 替换数据
|
||
}
|
||
}
|
||
|
||
private static async Task MonitorObjExpInterrupt(IDynamicContext context, NodeModelBase nodeModel, object data, int monitorType)
|
||
{
|
||
MonitorObjectEventArgs.ObjSourceType sourceType;
|
||
string key;
|
||
if (monitorType == 0)
|
||
{
|
||
key = data?.GetType()?.FullName;
|
||
sourceType = MonitorObjectEventArgs.ObjSourceType.IOCObj;
|
||
}
|
||
else
|
||
{
|
||
key = nodeModel.Guid;
|
||
sourceType = MonitorObjectEventArgs.ObjSourceType.IOCObj;
|
||
}
|
||
if (string.IsNullOrEmpty(key))
|
||
{
|
||
return;
|
||
}
|
||
(var isMonitor, var exps) = await context.Env.CheckObjMonitorStateAsync(key);
|
||
if (isMonitor) // 如果新的数据处于查看状态，通知UI进行更新？交给运行环境判断？
|
||
{
|
||
context.Env.MonitorObjectNotification(nodeModel.Guid, data, sourceType); // 对象处于监视状态，通知UI更新数据显示
|
||
if (exps.Length > 0)
|
||
{
|
||
// 表达式环境下判断是否需要执行中断
|
||
bool isExpInterrupt = false;
|
||
string exp = "";
|
||
// 判断执行监视表达式，直到为 true 时退出
|
||
for (int i = 0; i < exps.Length && !isExpInterrupt; i++)
|
||
{
|
||
exp = exps[i];
|
||
if (string.IsNullOrEmpty(exp)) continue;
|
||
// isExpInterrupt = SereinConditionParser.To(data, exp);
|
||
}
|
||
|
||
if (isExpInterrupt) // 触发中断
|
||
{
|
||
nodeModel.DebugSetting.IsInterrupt = true;
|
||
if (await context.Env.SetNodeInterruptAsync(nodeModel.Guid,true))
|
||
{
|
||
context.Env.TriggerInterrupt(nodeModel.Guid, exp, InterruptTriggerEventArgs.InterruptTriggerType.Exp);
|
||
var cancelType = await nodeModel.DebugSetting.GetInterruptTask();
|
||
await Console.Out.WriteLineAsync($"[{data}]中断已{cancelType}，开始执行后继分支");
|
||
nodeModel.DebugSetting.IsInterrupt = false;
|
||
}
|
||
}
|
||
}
|
||
|
||
}
|
||
}
|
||
|
||
///// <summary>
|
||
///// 释放对象
|
||
///// </summary>
|
||
//public void ReleaseFlowData()
|
||
//{
|
||
// if (typeof(IDisposable).IsAssignableFrom(FlowData?.GetType()) && FlowData is IDisposable disposable)
|
||
// {
|
||
// disposable?.Dispose();
|
||
// }
|
||
// this.FlowData = null;
|
||
//}
|
||
|
||
///// <summary>
|
||
///// 获取节点数据
|
||
///// </summary>
|
||
///// <returns></returns>
|
||
//public object GetFlowData()
|
||
//{
|
||
// return this.FlowData;
|
||
//}
|
||
#endregion
|
||
|
||
}
|
||
|
||
|
||
#if false
|
||
public static class NodeModelExtension
|
||
{
|
||
/// <summary>
|
||
/// 程序集更新，更新节点方法描述、以及所有入参描述的类型
|
||
/// </summary>
|
||
/// <param name="nodeModel">节点Model</param>
|
||
/// <param name="newMd">新的方法描述</param>
|
||
public static void UploadMethod(this NodeModelBase nodeModel, MethodDetails newMd)
|
||
{
|
||
var thisMd = nodeModel.MethodDetails;
|
||
|
||
thisMd.ActingInstanceType = newMd.ActingInstanceType; // 更新方法需要的类型
|
||
|
||
var thisPds = thisMd.ParameterDetailss;
|
||
var newPds = newMd.ParameterDetailss;
|
||
// 当前存在可变参数，且新的方法也存在可变参数，需要把可变参数的数目与值传递过去
|
||
if (thisMd.HasParamsArg && newMd.HasParamsArg)
|
||
{
|
||
int paramsLength = thisPds.Length - thisMd.ParamsArgIndex - 1; // 确定扩容长度
|
||
newMd.ParameterDetailss = ArrayHelper.Expansion(newPds, paramsLength);// 为新方法的入参参数描述进行扩容
|
||
newPds = newMd.ParameterDetailss;
|
||
int index = newMd.ParamsArgIndex; // 记录
|
||
var templatePd = newPds[newMd.ParamsArgIndex]; // 新的入参模板
|
||
for (int i = thisMd.ParamsArgIndex; i < thisPds.Length; i++)
|
||
{
|
||
ParameterDetails thisPd = thisPds[i];
|
||
var newPd = templatePd.CloneOfModel(nodeModel); // 复制参数描述
|
||
newPd.Index = i + 1; // 更新索引
|
||
newPd.IsParams = true;
|
||
newPd.DataValue = thisPd.DataValue; // 保留参数值
|
||
newPd.ArgDataSourceNodeGuid = thisPd.ArgDataSourceNodeGuid; // 保留参数来源信息
|
||
newPd.ArgDataSourceType = thisPd.ArgDataSourceType; // 保留参数来源信息
|
||
newPd.IsParams = thisPd.IsParams; // 保留显式参数设置
|
||
newPds[index++] = newPd;
|
||
}
|
||
}
|
||
|
||
|
||
var thidPdLength = thisMd.HasParamsArg ? thisMd.ParamsArgIndex : thisPds.Length;
|
||
// 遍历当前的参数描述（不包含可变参数），找到匹配项，复制必要的数据进行保留
|
||
for (int i = 0; i < thisPds.Length; i++)
|
||
{
|
||
ParameterDetails thisPd = thisPds[i];
|
||
var newPd = newPds.FirstOrDefault(t_newPd => !t_newPd.IsParams // 不为可变参数
|
||
&& t_newPd.Name.Equals(thisPd.Name, StringComparison.OrdinalIgnoreCase) // 存在相同名称
|
||
&& t_newPd.DataType.Name.Equals(thisPd.DataType.Name) // 存在相同入参类型名称（以类型作为区分）
|
||
);
|
||
if (newPd != null) // 如果匹配上了
|
||
{
|
||
newPd.DataValue = thisPd.DataValue; // 保留参数值
|
||
newPd.ArgDataSourceNodeGuid = thisPd.ArgDataSourceNodeGuid; // 保留参数来源信息
|
||
newPd.ArgDataSourceType = thisPd.ArgDataSourceType; // 保留参数来源信息
|
||
newPd.IsParams = thisPd.IsParams; // 保留显式参数设置
|
||
}
|
||
}
|
||
thisMd.ReturnType = newMd.ReturnType;
|
||
nodeModel.MethodDetails = newMd;
|
||
|
||
}
|
||
}
|
||
#endif
|
||
}
|
