Skip to content

Commit

Permalink
优化 情景解析
Browse files Browse the repository at this point in the history
  • Loading branch information
@MakesYT
MakesYT committed Oct 8, 2023
1 parent be4371c commit d7bbb63
Showing 1 changed file with 63 additions and 62 deletions.
125 changes: 63 additions & 62 deletions Core/SDKs/CustomScenario/CustomScenario.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -184,71 +184,60 @@ private void ParsePointItem(PointItem nowPointItem, bool onlyForward, bool notRe
Log.Debug($"解析节点:{nowPointItem.Title}");
var valid = true;
List<Task> sourceDataTask = new();
try

foreach (var connectorItem in nowPointItem.Input)
{
foreach (var connectorItem in nowPointItem.Input)
if (!connectorItem.IsConnected)
{
try
if (connectorItem.Type.FullName != "PluginCore.NodeConnectorClass")
{
if (!connectorItem.IsConnected)
{
if (connectorItem.Type.FullName != "PluginCore.NodeConnectorClass")
{
//当前节点有一个输入参数不存在,验证失败
if (!connectorItem.IsSelf)
{
valid = false;
break;
}
}
else
{
connectorItem.IsNotUsed = true;
}
}
else if (connectorItem.Type.FullName == "PluginCore.NodeConnectorClass")
//当前节点有一个输入参数不存在,验证失败
if (!connectorItem.IsSelf)
{
connectorItem.IsNotUsed = false;
valid = false;
break;
}
}
catch (Exception e)
else
{
Log.Debug(e);
connectorItem.IsNotUsed = true;
}
}
else if (connectorItem.Type.FullName == "PluginCore.NodeConnectorClass")
{
connectorItem.IsNotUsed = false;
}

//这是连接当前节点的节点
var connectionItem = connections.Where((e) => e.Target == connectorItem).ToList();

foreach (var sourceSource in connectionItem.Select(item => item.Source.Source))
//这是连接当前节点的节点
var connectionItem = connections.Where((e) => e.Target == connectorItem).ToList();

foreach (var sourceSource in connectionItem.Select(item => item.Source.Source))
{
lock (_tasks)
{
lock (_tasks)
if (_tasks.TryGetValue(sourceSource, out var task1))
{
if (_tasks.TryGetValue(sourceSource, out var task1))
if (task1 is not null)
{
if (task1 is not null)
{
sourceDataTask.Add(task1);
}
sourceDataTask.Add(task1);
}
else
}
else
{
var task = new Task(() =>
{
var task = new Task(() =>
{
ParsePointItem(sourceSource, true, notRealTime);
});
task.Start();
// Log.Debug(sourceSource.Title);
_tasks.Add(sourceSource, task);
sourceDataTask.Add(task);
}
ParsePointItem(sourceSource, true, notRealTime);
});
task.Start();
// Log.Debug(sourceSource.Title);
_tasks.Add(sourceSource, task);
sourceDataTask.Add(task);
}
}
}
}
catch (Exception e)
{
Log.Error(e);
} //源数据全部生成
//源数据全部生成

Task.WaitAll(sourceDataTask.ToArray());
//这是连接当前节点的节点
Expand Down Expand Up @@ -309,8 +298,20 @@ private void ParsePointItem(PointItem nowPointItem, bool onlyForward, bool notRe
}
case "相等":
{
nowPointItem.Output[0].InputObject = nowPointItem.Input[1].InputObject
.Equals(nowPointItem.Input[2].InputObject);
if (nowPointItem.Input[1].InputObject is null)
{
nowPointItem.Output[0].InputObject = false;
}
else if (nowPointItem.Input[2].InputObject is null)
{
nowPointItem.Output[0].InputObject = false;
}
else
{
nowPointItem.Output[0].InputObject =
nowPointItem.Input[1].InputObject!.Equals(nowPointItem.Input[2].InputObject);
}

var nextNode = connections.Where((e) => e.Source == nowPointItem.Output[0])
.ToList();
foreach (var item in nextNode)
Expand All @@ -329,15 +330,14 @@ private void ParsePointItem(PointItem nowPointItem, bool onlyForward, bool notRe
}

var userInputData = userInputConnector.InputObject;
if (nowPointItem.MerthodName == "System.Int32")
if (userInputData is null or "")
{
userInputData = int.Parse(userInputData.ToString());
throw new NullReferenceException();
}

if (userInputData is null or "")
if (nowPointItem.MerthodName == "System.Int32")
{
//这是用户自输入控件没有数据直接抛出异常
throw new NullReferenceException();
userInputData = int.Parse(userInputData.ToString()!);
}

nowPointItem.Output[0].InputObject = userInputData;
Expand All @@ -360,6 +360,9 @@ private void ParsePointItem(PointItem nowPointItem, bool onlyForward, bool notRe
var index = 1;
foreach (var parameterInfo in methodInfo.GetParameters())
{
var inputObject = nowPointItem.Input[index].InputObject ??
throw new NullReferenceException("nowPointItem.Input[index].InputObject");

if (parameterInfo.ParameterType.GetCustomAttribute(typeof(AutoUnbox)) is not null)
{
var autoUnboxIndex = nowPointItem.Input[index].AutoUnboxIndex;
Expand All @@ -368,25 +371,23 @@ private void ParsePointItem(PointItem nowPointItem, bool onlyForward, bool notRe
while (nowPointItem.Input.Count >= index &&
nowPointItem.Input[index].AutoUnboxIndex == autoUnboxIndex)
{
parameterList.Add(nowPointItem.Input[index].InputObject);
parameterTypesList.Add(nowPointItem.Input[index].InputObject.GetType());
parameterList.Add(inputObject);
parameterTypesList.Add(inputObject.GetType());
index++;
}

var instance = parameterInfo.ParameterType.GetConstructor(parameterTypesList.ToArray())
var instance = parameterInfo.ParameterType.GetConstructor(parameterTypesList.ToArray())!
.Invoke(parameterList.ToArray());
list.Add(instance);
continue;
}
else
{
list.Add(nowPointItem.Input[index].InputObject);
}

list.Add(inputObject);

index++;
}

var invoke = methodInfo.Invoke(plugin.ServiceProvider.GetService(methodInfo.DeclaringType),
var invoke = methodInfo.Invoke(plugin.ServiceProvider!.GetService(methodInfo.DeclaringType!),
list.ToArray());

if (methodInfo.ReturnParameter.ParameterType.GetCustomAttribute(typeof(AutoUnbox)) is not null)
Expand Down Expand Up @@ -442,7 +443,7 @@ private void ParsePointItem(PointItem nowPointItem, bool onlyForward, bool notRe
var thisToNextConnections = connections.Where((e) => e.Source == outputConnector).ToList();
foreach (var nextPointItem in thisToNextConnections
.Select(thisToNextConnection => thisToNextConnection.Target.Source)
.Where(nextPointItem => !outputConnector.IsNotUsed))
.Where(_ => !outputConnector.IsNotUsed))
{
lock (_tasks)
{
Expand Down

0 comments on commit d7bbb63

Please sign in to comment.