using Newtonsoft.Json.Linq; using Serein.Library; using Serein.Library.Utils; using Serein.Script.Node; using System.ComponentModel.Design; using System.Reflection; using System.Reflection.Metadata.Ecma335; using System.Runtime.CompilerServices; using System.Xml.Linq; namespace Serein.Script { /// /// 脚本解释器,负责解析和执行 Serein 脚本 /// public class SereinScriptInterpreter { /// /// 挂载的函数 /// private static Dictionary _functionTable = new Dictionary(); private static Dictionary _functionInfoTable = new Dictionary(); public static Dictionary FunctionInfoTable { get { return _functionInfoTable; } } /// /// 挂载的函数调用的对象(用于函数需要实例才能调用的场景) /// private Dictionary> _callFuncOfGetObjects = new Dictionary>(); /// /// 定义的类型 /// private Dictionary _classDefinition = new Dictionary(); /// /// 类型分析器 /// private SereinScriptTypeAnalysis typeAnalysis; /// /// 挂载静态函数 /// /// /// public static void AddStaticFunction(string functionName, MethodInfo methodInfo) { _functionTable[functionName] = new DelegateDetails(methodInfo); _functionInfoTable[functionName] = methodInfo; } /// /// 挂载函数 /// /// 函数名称 /// 方法信息 public void AddFunction(string functionName, MethodInfo methodInfo, Func? callObj = null) { //if (!_functionTable.ContainsKey(functionName)) //{ // _functionTable[functionName] = new DelegateDetails(methodInfo); //} if(!methodInfo.IsStatic && callObj is null) { SereinEnv.WriteLine(InfoType.WARN, "函数挂载失败:试图挂载非静态的函数,但没有传入相应的获取实例的方法。"); return; } if(!methodInfo.IsStatic && callObj is not null && !_callFuncOfGetObjects.ContainsKey(functionName)) { // 静态函数不需要 _callFuncOfGetObjects.Add(functionName, callObj); } if (!_functionTable.ContainsKey(functionName)) { _functionTable[functionName] = new DelegateDetails(methodInfo); } //_functionTable[functionName] = new DelegateDetails(methodInfo); } /// /// 挂载类型 /// /// 函数名称 /// 方法信息 public void AddClassType(Type type , string typeName = "") { if (string.IsNullOrEmpty(typeName)) { typeName = type.Name; } if (!_classDefinition.ContainsKey(typeName)) { _classDefinition[typeName] = type; } } /// /// 设置类型分析器 /// /// public void SetTypeAnalysis(SereinScriptTypeAnalysis typeAnalysis) { this.typeAnalysis = typeAnalysis; } /// /// 入口节点 /// /// /// private async Task ExecutionProgramNodeAsync(IScriptInvokeContext context,ProgramNode programNode) { // 加载变量 ASTNode statement = null; try { // 遍历 ProgramNode 中的所有语句并执行它们 for (int index = 0; index < programNode.Statements.Count; index++) { statement = programNode.Statements[index]; // 直接退出 if (statement is ReturnNode returnNode) // 遇到 Return 语句 提前退出 { return await EvaluateAsync(context, statement); } else { var result = await InterpretAsync(context, statement); if (context.IsNeedReturn) { return result; } } } return null; } catch (Exception ex ) { if(statement is not null) { SereinEnv.WriteLine(InfoType.ERROR, $"脚本异常发生在[行{statement.Row}]:{ex.Message}{Environment.NewLine}\t{statement.Code}"); } throw; } } /// /// 类型定义 /// /// /// private void ExecutionClassTypeDefinitionNode(ClassTypeDefinitionNode classTypeDefinitionNode) { if (_classDefinition.ContainsKey(classTypeDefinitionNode.ClassName) && !classTypeDefinitionNode.IsOverlay) { //SereinEnv.WriteLine(InfoType.WARN, $"异常信息 : 类型重复定义,代码在第{classTypeDefinitionNode.Row}行: {classTypeDefinitionNode.Code.Trim()}"); return; } //var isOverlay = true; // classTypeDefinitionNode.IsOverlay; var type = DynamicObjectHelper.CreateTypeWithProperties(classTypeDefinitionNode.Fields, classTypeDefinitionNode.ClassName); // 覆盖 //classTypeDefinitionNode.IsOverlay = false; // 已经加载过,则不再覆盖 _classDefinition[classTypeDefinitionNode.ClassName] = type; // 定义对象 } /// /// IF...ELSE... 语句块 /// /// /// /// private async Task ExecutionIfNodeAsync(IScriptInvokeContext context, IfNode ifNode) { var result = await EvaluateAsync(context, ifNode.Condition) ?? throw new SereinSciptException(ifNode, $"条件语句返回了 null"); if (result is not bool condition) { throw new SereinSciptException(ifNode, "条件语句返回值不为 bool 类型"); } var branchNodes = condition ? ifNode.TrueBranch : ifNode.FalseBranch; if(branchNodes is null || branchNodes.Count < 1) { return null; } else { foreach (var branchNode in branchNodes) { if (branchNode is ReturnNode) // 遇到 Return 语句 提前退出 { var reulst = await EvaluateAsync(context, branchNode); context.IsNeedReturn = true; return reulst; } else { await InterpretAsync(context, branchNode); } } return null; } } /// /// WHILE(){...} 语句块 /// /// /// /// private async Task ExectutionWhileNodeAsync(IScriptInvokeContext context, WhileNode whileNode) { while (true) { if (context.IsReturn) // 停止流程 { throw new SereinSciptException(whileNode, $"while循环已由外部主动停止"); } var result = await EvaluateAsync(context, whileNode.Condition) ?? throw new SereinSciptException(whileNode, $"条件语句返回了 null"); if (result is not bool condition) { throw new SereinSciptException(whileNode, $"条件语句返回值不为 bool 类型(当前返回值类型为 {result.GetType()})"); } if (!condition) { break; } foreach(var branchNode in whileNode.Body) { if (branchNode is ReturnNode) // 遇到 Return 语句 提前退出 { var reulst = await EvaluateAsync(context, branchNode); context.IsNeedReturn = true; return reulst; } else { await InterpretAsync(context, branchNode); } //await InterpretAsync(context, node); } } return null; } /// /// 操作节点 /// /// /// private async Task ExecutionAssignmentNodeAsync(IScriptInvokeContext context, AssignmentNode assignmentNode) { if(assignmentNode.Target is IdentifierNode identifierNode) { var value = await EvaluateAsync(context, assignmentNode.Value); if (value is not null) { context.SetVarValue(identifierNode.Name, value); } } else { } /*var targetObject = await EvaluateAsync(context, assignmentNode.TargetNode); var value = await EvaluateAsync(context, assignmentNode.Value); if(value is not null) { context.SetVarValue(targetObject, value); }*/ } private async Task InterpretFunctionCallAsync(IScriptInvokeContext context, FunctionCallNode functionCallNode) { if (functionCallNode.FunctionName.Equals("GetFlowContext", StringComparison.OrdinalIgnoreCase)) { return context.FlowContext; } // 评估函数参数 var arguments = new object?[functionCallNode.Arguments.Count]; for (int i = 0; i < functionCallNode.Arguments.Count; i++) { ASTNode? arg = functionCallNode.Arguments[i]; arguments[i] = await EvaluateAsync(context, arg); // 评估每个参数 } var funcName = functionCallNode.FunctionName; object? instance = null; // 静态方法不需要传入实例,所以可以传入null // 查找并执行对应的函数 if (_functionTable.TryGetValue(funcName, out DelegateDetails? function)) { if (!function.EmitMethodInfo.IsStatic) { if(_callFuncOfGetObjects.TryGetValue(funcName, out var action)) { instance = action.Invoke();// 非静态的方法需要获取相应的实例 if (instance is null) { throw new SereinSciptException(functionCallNode, $"函数 {funcName} 尝试获取实例时返回了 null "); } } else { throw new SereinSciptException(functionCallNode, $"挂载函数 {funcName} 时需要同时给定获取实例的 Func"); } } var result = await function.InvokeAsync(instance,arguments); return result; } else { throw new Exception($"Unknown function: {functionCallNode.FunctionName}"); } } /// /// 解释操作 /// /// /// /// /// public async Task InterpretAsync(IScriptInvokeContext context, ASTNode node) { if(node == null) { return null; } switch (node) { case ProgramNode programNode: // AST树入口 var scritResult = await ExecutionProgramNodeAsync(context, programNode); return scritResult; // 遍历 ProgramNode 中的所有语句并执行它们 case ClassTypeDefinitionNode classTypeDefinitionNode: // 定义类型 ExecutionClassTypeDefinitionNode(classTypeDefinitionNode); break; case AssignmentNode assignment: // 出现在 = 右侧的表达式 await ExecutionAssignmentNodeAsync(context, assignment); break; case ObjectMemberExpressionNode objectMemberExpressionNode: break; case MemberAssignmentNode memberAssignmentNode: // 设置对象属性 await SetMemberValue(context, memberAssignmentNode); break; case MemberFunctionCallNode memberFunctionCallNode: // 对象方法调用 return await CallMemberFunction(context, memberFunctionCallNode); case IfNode ifNode: // 执行 if...else... 语句块 return await ExecutionIfNodeAsync(context, ifNode); break; case WhileNode whileNode: // 循环语句块 return await ExectutionWhileNodeAsync(context, whileNode); break; case FunctionCallNode functionCallNode: // 方法调用节点 return await InterpretFunctionCallAsync(context, functionCallNode); case ReturnNode returnNode: return await EvaluateAsync(context, returnNode); default: throw new SereinSciptException(node, "解释器 InterpretAsync() 未实现节点行为"); } return null; } /// /// 评估 /// /// /// /// /// private async Task EvaluateAsync(IScriptInvokeContext context, ASTNode node) { if(node == null) { return null; } switch (node) { case NullNode nullNode: return null; case BooleanNode booleanNode: return booleanNode.Value; // 返回数值 case NumberIntNode numberNode: return numberNode.Value; // 返回 int 整型数 case NumberLongNode numberNode: return numberNode.Value; // 返回 long 整型数 case NumberFloatNode numberNode: return numberNode.Value; // 返回 float 浮点型 case NumberDoubleNode numberNode: return numberNode.Value; // 返回 double 浮点型 case StringNode stringNode: return stringNode.Value; // 返回字符串值 case CharNode charNode: return charNode.Value; // 返回Char case IdentifierNode identifierNode: return context.GetVarValue(identifierNode.Name); //throw new SereinSciptException(identifierNode, "尝试使用值为null的变量"); //throw new SereinSciptException(identifierNode, "尝试使用未声明的变量"); case BinaryOperationNode binOpNode: // 递归计算二元操作 var left = await EvaluateAsync(context, binOpNode.Left); //if (left == null ) throw new SereinSciptException(binOpNode.Left, $"左值尝试使用 null"); var right = await EvaluateAsync(context, binOpNode.Right); //if (right == null) throw new SereinSciptException(binOpNode.Right, "右值尝试使用计算 null"); return EvaluateBinaryOperation(left, binOpNode.Operator, right); case ObjectInstantiationNode objectInstantiationNode: // 对象实例化 if (_classDefinition.TryGetValue(objectInstantiationNode.TypeName,out var type )) { object?[] args = new object[objectInstantiationNode.Arguments.Count]; for (int i = 0; i < objectInstantiationNode.Arguments.Count; i++) { var argNode = objectInstantiationNode.Arguments[i]; args[i] = await EvaluateAsync(context, argNode); } var obj = Activator.CreateInstance(type,args: args);// 创建对象 if (obj == null) { throw new SereinSciptException(objectInstantiationNode, $"类型创建失败\"{objectInstantiationNode.TypeName}\""); } return obj; } else { throw new SereinSciptException(objectInstantiationNode, $"使用了未定义的类型\"{objectInstantiationNode.TypeName}\""); } case FunctionCallNode callNode: // 调用方法 return await InterpretFunctionCallAsync(context, callNode); // 调用方法返回函数的返回值 case MemberFunctionCallNode memberFunctionCallNode: // 对象方法调用 return await CallMemberFunction(context, memberFunctionCallNode); case MemberAccessNode memberAccessNode: // 对象成员访问 return await GetMemberValue(context, memberAccessNode); case CollectionIndexNode collectionIndexNode: return await GetCollectionValue(context, collectionIndexNode); case ReturnNode returnNode: // 返回内容 return await EvaluateAsync(context, returnNode.Value); // 直接返回响应的内容 case ObjectMemberExpressionNode objectMemberExpressionNode: // 对象链式表达式 return await EvaluateAsync(context, objectMemberExpressionNode.Value); default: throw new SereinSciptException(node, $"解释器 EvaluateAsync() 未实现{node}节点行为"); } } private object EvaluateBinaryOperation(object left, string op, object right) { return BinaryOperationEvaluator.EvaluateValue(left, op, right); // 根据运算符执行不同的运算 switch (op) { case "+": if (left is string || right is string) { return left?.ToString() + right?.ToString(); // 字符串拼接 } else if (left is int leftInt && right is int rightInt) { return leftInt + rightInt; // 整数加法 } else if (left is long leftLong && right is long rightLong) { return leftLong + rightLong; // 整数加法 } else if (left is double leftDouble && right is double rightDouble) { return leftDouble + rightDouble; // 整数加法 } else { dynamic leftValue = Convert.ToDouble(left); dynamic rightValue = Convert.ToDouble(right); return leftValue + rightValue; } throw new Exception("Invalid types for + operator"); case "-": return (int)left - (int)right; case "*": return (int)left * (int)right; case "/": return (int)left / (int)right; case ">": return (int)left > (int)right; case "<": return (int)left < (int)right; case "==": return Equals(left, right); case "!=": return !Equals(left, right); default: throw new NotImplementedException("未定义的操作符: " + op); } } /// /// 设置对象成员 /// /// /// /// public async Task SetMemberValue(IScriptInvokeContext context, MemberAssignmentNode memberAssignmentNode) { var target = await EvaluateAsync(context, memberAssignmentNode.Object); var value = await EvaluateAsync(context, memberAssignmentNode.Value); // 设置值 var lastMember = memberAssignmentNode.MemberName; var lastProperty = target?.GetType().GetProperty(lastMember); if (lastProperty is null) { var lastField = target?.GetType().GetRuntimeField(lastMember); if (lastField is null) { throw new SereinSciptException(memberAssignmentNode, $"对象没有成员\"{memberAssignmentNode.MemberName}\""); } else { var convertedValue = Convert.ChangeType(value, lastField.FieldType); lastField.SetValue(target, convertedValue); } } else { if(value is null) { lastProperty.SetValue(target, null); return; } var valueTtpe = value.GetType(); if (lastProperty.PropertyType.IsAssignableFrom(valueTtpe)) { lastProperty.SetValue(target, value); } else if (lastProperty.PropertyType.FullName == valueTtpe.FullName) { lastProperty.SetValue(target, value); } else { throw new SereinSciptException(memberAssignmentNode, $"对象成员赋值时类型异常:\"{memberAssignmentNode.MemberName}\""); } //var convertedValue = Convert.ChangeType(value, ); } } /// /// 获取对象成员 /// /// /// /// public async Task GetMemberValue(IScriptInvokeContext context, MemberAccessNode memberAccessNode) { var target = await EvaluateAsync(context, memberAccessNode.Object); var lastMember = memberAccessNode.MemberName; var lastProperty = target?.GetType().GetProperty(lastMember); if (lastProperty is null) { var lastField = target?.GetType().GetRuntimeField(lastMember); if (lastField is null) { throw new SereinSciptException(memberAccessNode, $"对象没有成员\"{memberAccessNode.MemberName}\""); } else { return lastField.GetValue(target); } } else { return lastProperty.GetValue(target); } } /// /// 获取集合中的成员 /// /// /// /// public async Task GetCollectionValue(IScriptInvokeContext context, CollectionIndexNode collectionIndexNode) { var target = await EvaluateAsync(context, collectionIndexNode.Collection); // 获取对象 if (target is null) { throw new ArgumentNullException($"解析{collectionIndexNode}节点时,TargetValue返回空。"); } // 解析数组/集合名与索引部分 var targetType = target.GetType(); // 目标对象的类型 #region 处理键值对 if (targetType.IsGenericType && targetType.GetGenericTypeDefinition() == typeof(Dictionary<,>)) { // 目标是键值对 var method = targetType.GetMethod("get_Item", BindingFlags.Public | BindingFlags.Instance); if (method is not null) { var key = await EvaluateAsync(context, collectionIndexNode.Index); // 获取索引值; var result = method.Invoke(target, new object[] { key }); return result; } } #endregion #region 处理集合对象 else { var indexValue = await EvaluateAsync(context, collectionIndexNode.Index); // 获取索引值 object? result; if (indexValue is int index) { // 获取数组或集合对象 // 访问数组或集合中的指定索引 if (target is Array array) { if (index < 0 || index >= array.Length) { throw new ArgumentException($"解析{collectionIndexNode}节点时,数组下标越界。"); } result = array.GetValue(index); return result; } else if (target is IList list) { if (index < 0 || index >= list.Count) { throw new ArgumentException($"解析{collectionIndexNode}节点时,数组下标越界。"); } result = list[index]; return result; } else if (target is string chars) { return chars[index]; } else { throw new ArgumentException($"解析{collectionIndexNode}节点时,左值并非有效集合。"); } } } #endregion throw new ArgumentException($"解析{collectionIndexNode}节点时,左值并非有效集合。"); } /// /// 缓存method委托 /// private Dictionary MethodToDelegateCaches { get; } = new Dictionary(); public async Task CallMemberFunction(IScriptInvokeContext context, MemberFunctionCallNode memberFunctionCallNode) { var target = await EvaluateAsync(context, memberFunctionCallNode.Object); var lastMember = memberFunctionCallNode.FunctionName; if(lastMember == "ToUpper") { } MethodInfo? methodInfo = null; if (memberFunctionCallNode.Arguments.Count == 0) { // 查询无参方法 methodInfo = target?.GetType().GetMethod(lastMember, []) ?? throw new SereinSciptException(memberFunctionCallNode, $"对象没有方法\"{memberFunctionCallNode.FunctionName}\""); } else { // 获取参数列表的类型 methodInfo = target?.GetType().GetMethod(lastMember) ?? throw new SereinSciptException(memberFunctionCallNode, $"对象没有方法\"{memberFunctionCallNode.FunctionName}\""); } /*Type[] paramTypes = new { }*/ if (!MethodToDelegateCaches.TryGetValue(methodInfo.MetadataToken, out DelegateDetails? delegateDetails)) { delegateDetails = new DelegateDetails(methodInfo); MethodToDelegateCaches[methodInfo.MetadataToken] = delegateDetails; } if(memberFunctionCallNode.Arguments.Count == 0) { var reuslt = await delegateDetails.InvokeAsync(target, []); return reuslt; } else { var arguments = new object?[memberFunctionCallNode.Arguments.Count]; for (int i = 0; i < memberFunctionCallNode.Arguments.Count; i++) { ASTNode? arg = memberFunctionCallNode.Arguments[i]; arguments[i] = await EvaluateAsync(context, arg); // 评估每个参数 } var reuslt = await delegateDetails.InvokeAsync(target, arguments); return reuslt; } } } }