|
|
@@ -32,244 +32,7 @@ namespace YSAI.TestConsole
|
|
|
static void Main(string[] args)
|
|
|
{
|
|
|
|
|
|
- //创建一个采集配置
|
|
|
- List<AddressManage> addressManages = new List<AddressManage>();
|
|
|
-
|
|
|
- AddressManage addressManage = new AddressManage();
|
|
|
- addressManage.DType = Core.@enum.DaqType.OpcDa;
|
|
|
- addressManage.SN = "OPCDA采集";
|
|
|
- addressManage.InstanceParam = new OpcDaClientData.Basics() { SN = "OPCDA采集", ServiceName = "Knight.OPC.Server.Demo", ApiVerType = OpcDaClientData.ApiVerType.COM_DA_20 };
|
|
|
- addressManage.AddressArray = new List<AddressDetails>()
|
|
|
- {
|
|
|
- new AddressDetails()
|
|
|
- {
|
|
|
- AddressName = "a.a.a",
|
|
|
- AddressDataType = Core.@enum.DataType.Bool,
|
|
|
- AddressDescribe = "一个动态的布尔类型",
|
|
|
- AddressAnotherName = "test",
|
|
|
- AddressPropertyName = "aaa",
|
|
|
- AddressType = Core.@enum.AddressType.Reality
|
|
|
- },
|
|
|
- new AddressDetails()
|
|
|
- {
|
|
|
- AddressName = "a.a.h",
|
|
|
- AddressDataType = Core.@enum.DataType.String,
|
|
|
- AddressDescribe = "一个动态的字符串类型",
|
|
|
- AddressAnotherName = "test",
|
|
|
- AddressPropertyName = "aah",
|
|
|
- AddressType = Core.@enum.AddressType.Reality,
|
|
|
- AddressParseParam = new AddressParse()
|
|
|
- {
|
|
|
- ParseType = Core.@enum.ParseType.ScriptAnalysis,
|
|
|
- Script = new Core.script.ScriptData.Basics()
|
|
|
- {
|
|
|
- ScriptCode = @"function Convert(value)
|
|
|
- {
|
|
|
- return '这是脚本测试,传入的参数是:' + value;
|
|
|
- }",
|
|
|
- ScriptFunction = "Convert",
|
|
|
- ScriptType = Core.script.ScriptData.ScriptType.JavaScript
|
|
|
- }
|
|
|
- }
|
|
|
- },
|
|
|
- new AddressDetails()
|
|
|
- {
|
|
|
- AddressName = "a.a.g",
|
|
|
- AddressDataType = Core.@enum.DataType.Double,
|
|
|
- AddressDescribe = "一个动态的浮点类型",
|
|
|
- AddressAnotherName = "test",
|
|
|
- AddressPropertyName = "aag",
|
|
|
- AddressType = Core.@enum.AddressType.Reality,
|
|
|
- AddressParseParam = new AddressParse()
|
|
|
- {
|
|
|
- ParseType = Core.@enum.ParseType.ScriptAnalysis,
|
|
|
- Script = new Core.script.ScriptData.Basics()
|
|
|
- {
|
|
|
- ScriptCode = @"function Convert(value)
|
|
|
- {
|
|
|
- return value*1000;
|
|
|
- }",
|
|
|
- ScriptFunction = "Convert",
|
|
|
- ScriptType = Core.script.ScriptData.ScriptType.JavaScript
|
|
|
- }
|
|
|
- }
|
|
|
- },
|
|
|
- new AddressDetails()
|
|
|
- {
|
|
|
- AddressName = "OPCDA_VirtualAddress",
|
|
|
- AddressDataType = Core.@enum.DataType.String,
|
|
|
- AddressDescribe = "虚拟地址",
|
|
|
- AddressAnotherName = "test",
|
|
|
- AddressPropertyName = "OPCDA_VirtualAddress",
|
|
|
- AddressType = Core.@enum.AddressType.Virtual
|
|
|
- },
|
|
|
- new AddressDetails()
|
|
|
- {
|
|
|
- AddressName = "OPCDA_VirtualDynamicAddress",
|
|
|
- AddressDataType = Core.@enum.DataType.String,
|
|
|
- AddressDescribe = "虚拟动态地址",
|
|
|
- AddressAnotherName = "test",
|
|
|
- AddressPropertyName = "OPCDA_VirtualDynamicAddress",
|
|
|
- AddressType = Core.@enum.AddressType.VirtualDynamic
|
|
|
- }
|
|
|
- };
|
|
|
-
|
|
|
- addressManages.Add(addressManage);
|
|
|
-
|
|
|
- addressManage = new AddressManage();
|
|
|
- addressManage.DType = Core.@enum.DaqType.OpcUa;
|
|
|
- addressManage.SN = "OPCUA采集";
|
|
|
- addressManage.InstanceParam = new OpcUaClientData.Basics() { SN = "OPCUA采集", Name = "TEST", Password = "ysai", UserName = "ysai", ServerUrl = "opc.tcp://192.168.2.38:8866/Opc.Ua.Service", SamplingInterval = 100 };
|
|
|
- addressManage.AddressArray = new List<AddressDetails>()
|
|
|
- {
|
|
|
- new AddressDetails()
|
|
|
- {
|
|
|
- AddressName = "ns=2;s=Boolean_Dynamic",
|
|
|
- AddressDataType = Core.@enum.DataType.Bool,
|
|
|
- AddressDescribe = "一个动态的布尔类型",
|
|
|
- AddressAnotherName = "test",
|
|
|
- AddressPropertyName = "Boolean_Dynamic",
|
|
|
- AddressType = Core.@enum.AddressType.Reality
|
|
|
- },
|
|
|
- new AddressDetails()
|
|
|
- {
|
|
|
- AddressName = "ns=2;s=String_Dynamic",
|
|
|
- AddressDataType = Core.@enum.DataType.String,
|
|
|
- AddressDescribe = "一个动态的字符串类型",
|
|
|
- AddressAnotherName = "test",
|
|
|
- AddressPropertyName = "String_Dynamic",
|
|
|
- AddressType = Core.@enum.AddressType.Reality,
|
|
|
- AddressParseParam = new AddressParse()
|
|
|
- {
|
|
|
- ParseType = Core.@enum.ParseType.ScriptAnalysis,
|
|
|
- Script = new Core.script.ScriptData.Basics()
|
|
|
- {
|
|
|
- ScriptCode = @"function Convert(value)
|
|
|
- {
|
|
|
- return '这是脚本测试,传入的参数是:' + value;
|
|
|
- }",
|
|
|
- ScriptFunction = "Convert",
|
|
|
- ScriptType = Core.script.ScriptData.ScriptType.JavaScript
|
|
|
- }
|
|
|
- }
|
|
|
- },
|
|
|
- new AddressDetails()
|
|
|
- {
|
|
|
- AddressName = "ns=2;s=Double_Dynamic",
|
|
|
- AddressDataType = Core.@enum.DataType.Double,
|
|
|
- AddressDescribe = "一个动态的浮点类型",
|
|
|
- AddressAnotherName = "test",
|
|
|
- AddressPropertyName = "Double_Dynamic",
|
|
|
- AddressType = Core.@enum.AddressType.Reality,
|
|
|
- AddressParseParam = new AddressParse()
|
|
|
- {
|
|
|
- ParseType = Core.@enum.ParseType.ScriptAnalysis,
|
|
|
- Script = new Core.script.ScriptData.Basics()
|
|
|
- {
|
|
|
- ScriptCode = @"function Convert(value)
|
|
|
- {
|
|
|
- return value*1000;
|
|
|
- }",
|
|
|
- ScriptFunction = "Convert",
|
|
|
- ScriptType = Core.script.ScriptData.ScriptType.JavaScript
|
|
|
- }
|
|
|
- }
|
|
|
- },
|
|
|
- new AddressDetails()
|
|
|
- {
|
|
|
- AddressName = "OPCUA_VirtualAddress",
|
|
|
- AddressDataType = Core.@enum.DataType.String,
|
|
|
- AddressDescribe = "虚拟地址",
|
|
|
- AddressAnotherName = "test",
|
|
|
- AddressPropertyName = "OPCUA_VirtualAddress",
|
|
|
- AddressType = Core.@enum.AddressType.Virtual
|
|
|
- },
|
|
|
- new AddressDetails()
|
|
|
- {
|
|
|
- AddressName = "OPCUA_VirtualDynamicAddress",
|
|
|
- AddressDataType = Core.@enum.DataType.String,
|
|
|
- AddressDescribe = "虚拟动态地址",
|
|
|
- AddressAnotherName = "test",
|
|
|
- AddressPropertyName = "OPCUA_VirtualDynamicAddress",
|
|
|
- AddressType = Core.@enum.AddressType.VirtualDynamic
|
|
|
- }
|
|
|
- };
|
|
|
-
|
|
|
- addressManages.Add(addressManage);
|
|
|
-
|
|
|
- //生成文件
|
|
|
- FileTool.StringToFile("config//DaqConfig.json", JsonTool.JsonEntityToString(addressManages).JsonFormatting());
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
- //转发配置
|
|
|
- RelayData.Basics basics = new RelayData.Basics();
|
|
|
- basics.RabbitMQDataArray = new List<RabbitMQData.Basics>();
|
|
|
- basics.KafkaProducerDataArray = new List<KafkaProducerData.Basics>();
|
|
|
- basics.MqttClientDataArray = new List<MqttClientData.Basics>();
|
|
|
- basics.MqttClientDataArray.Add(new MqttClientData.Basics() { QualityOfServiceLevel = 0, ServerIPAddress = "127.0.0.1", ServerPort = 8881, ServerLoginID = "ysai", ServerLoginPassword = "ysai", SN = "mqtt转发一号" });
|
|
|
- basics.MqttClientDataArray.Add(new MqttClientData.Basics() { QualityOfServiceLevel = 0, ServerIPAddress = "127.0.0.1", ServerPort = 8882, ServerLoginID = "ysai", ServerLoginPassword = "ysai", SN = "mqtt转发二号" });
|
|
|
- basics.MqttClientDataArray.Add(new MqttClientData.Basics() { QualityOfServiceLevel = 0, ServerIPAddress = "127.0.0.1", ServerPort = 8883, ServerLoginID = "ysai", ServerLoginPassword = "ysai", SN = "mqtt转发三号" });
|
|
|
- basics.MqttClientDataArray.Add(new MqttClientData.Basics() { QualityOfServiceLevel = 0, ServerIPAddress = "127.0.0.1", ServerPort = 8884, ServerLoginID = "ysai", ServerLoginPassword = "ysai", SN = "mqtt转发四号" });
|
|
|
-
|
|
|
- RelayOperate relayOperate = new RelayOperate();
|
|
|
-
|
|
|
- relayOperate.OnEvent += RelayOperate_OnEvent;
|
|
|
-
|
|
|
- FileTool.StringToFile(RelayOperate.ConfigFile, basics.ToJson().JsonFormatting());
|
|
|
-
|
|
|
- //创建配置
|
|
|
- Basics basics2 = new Basics()
|
|
|
- {
|
|
|
- DllDatas = new List<Basics.DllData>()
|
|
|
- {
|
|
|
- new Basics.DllData()
|
|
|
- {
|
|
|
- DllPath="YSAI.Relay.dll",
|
|
|
- IsAbsolutePath=false,
|
|
|
- NamespaceDatas=new List<Basics.DllData.NamespaceData>()
|
|
|
- {
|
|
|
- new Basics.DllData.NamespaceData()
|
|
|
- {
|
|
|
- Namespace="YSAI.Relay",
|
|
|
- ClassDatas=new List<Basics.DllData.NamespaceData.ClassData>()
|
|
|
- {
|
|
|
- new Basics.DllData.NamespaceData.ClassData()
|
|
|
- {
|
|
|
- ClassName="RelayOperate",
|
|
|
- ConstructorParam=null,
|
|
|
- SN="YSAI.Relay.RelayOperate[Instance]",
|
|
|
- MethodDatas=new List<Basics.DllData.NamespaceData.ClassData.MethodData>()
|
|
|
- {
|
|
|
- new Basics.DllData.NamespaceData.ClassData.MethodData()
|
|
|
- {
|
|
|
- MethodName="Produce",
|
|
|
- SN="[Produce]"
|
|
|
- },
|
|
|
- new Basics.DllData.NamespaceData.ClassData.MethodData()
|
|
|
- {
|
|
|
- MethodName="Dispose",
|
|
|
- SN="[Dispose]"
|
|
|
- }
|
|
|
- },
|
|
|
- EventDatas=new List<ClassData.EventData>()
|
|
|
- {
|
|
|
- new ClassData.EventData()
|
|
|
- {
|
|
|
- EventName="OnEvent",
|
|
|
- SN="[OnEvent]"
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- };
|
|
|
-
|
|
|
-
|
|
|
- FileTool.StringToFile(ReflectionOperate.ConfigFile, basics2.ToJson().JsonFormatting());
|
|
|
+
|
|
|
|
|
|
Console.WriteLine();
|
|
|
|
|
|
@@ -279,9 +42,6 @@ namespace YSAI.TestConsole
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- private static void RelayOperate_OnEvent(object? sender, object e)
|
|
|
- {
|
|
|
- throw new NotImplementedException();
|
|
|
- }
|
|
|
+
|
|
|
}
|
|
|
}
|