|
|
@@ -1,4 +1,42 @@
|
|
|
-//using YSAI.Core.communication.net.ws.client;
|
|
|
+using System.Text;
|
|
|
+using YSAI.Core.communication.serial;
|
|
|
+using YSAI.Core.data;
|
|
|
+using YSAI.Unility;
|
|
|
+
|
|
|
+SerialOperate serialOperate = SerialOperate.Instance(new SerialData.Basics
|
|
|
+{
|
|
|
+ BaudRate = 9600,
|
|
|
+ DataBit = 8,
|
|
|
+ ParityBit = System.IO.Ports.Parity.None,
|
|
|
+ PortName = "COM2",
|
|
|
+ StopBit = System.IO.Ports.StopBits.One
|
|
|
+});
|
|
|
+
|
|
|
+byte[] bytes = new byte[] { };
|
|
|
+
|
|
|
+OperateResult operateResult = serialOperate.On();
|
|
|
+if (operateResult.State)
|
|
|
+{
|
|
|
+ Console.WriteLine(operateResult.ToJson().JsonFormatting());
|
|
|
+ serialOperate.OnEvent += SerialOperate_OnEvent;
|
|
|
+}
|
|
|
+while (true)
|
|
|
+{
|
|
|
+ Console.ReadLine();
|
|
|
+ Console.WriteLine(Encoding.Default.GetString(bytes));
|
|
|
+ bytes = new byte[] { };
|
|
|
+}
|
|
|
+
|
|
|
+void SerialOperate_OnEvent(object? sender, EventResult e)
|
|
|
+{
|
|
|
+ byte[] array = (byte[])e.RData;
|
|
|
+ Console.WriteLine(ByteTool.HexToStr(array).ToUpper());
|
|
|
+ bytes = ByteTool.CombineBytes(bytes, 0, bytes.Length, array, 0, array.Length);
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+//using YSAI.Core.communication.net.ws.client;
|
|
|
//using YSAI.Core.communication.net.ws.service;
|
|
|
//using YSAI.Unility;
|
|
|
|
|
|
@@ -788,121 +826,121 @@
|
|
|
// public string Description { get; set; }
|
|
|
//}
|
|
|
|
|
|
-using System.Collections.Concurrent;
|
|
|
-using YSAI.Core.data;
|
|
|
-using YSAI.Log;
|
|
|
-using YSAI.Opc.ua.client;
|
|
|
-using YSAI.Unility;
|
|
|
+//using System.Collections.Concurrent;
|
|
|
+//using YSAI.Core.data;
|
|
|
+//using YSAI.Log;
|
|
|
+//using YSAI.Opc.ua.client;
|
|
|
+//using YSAI.Unility;
|
|
|
|
|
|
-/// <summary>
|
|
|
-/// 读取Csv,返回行集合
|
|
|
-/// </summary>
|
|
|
-/// <param name="path"></param>
|
|
|
-/// <param name="hasTitle"></param>
|
|
|
-/// <returns></returns>
|
|
|
-List<string> ReadCsv(string path, bool hasTitle)
|
|
|
-{
|
|
|
- if (!File.Exists(path))
|
|
|
- return new List<string>();
|
|
|
-
|
|
|
- var lines = File.ReadAllLines(path).ToList();
|
|
|
- if (hasTitle)
|
|
|
- {
|
|
|
- lines.RemoveAt(0);
|
|
|
- }
|
|
|
- return lines;
|
|
|
-}
|
|
|
+///// <summary>
|
|
|
+///// 读取Csv,返回行集合
|
|
|
+///// </summary>
|
|
|
+///// <param name="path"></param>
|
|
|
+///// <param name="hasTitle"></param>
|
|
|
+///// <returns></returns>
|
|
|
+//List<string> ReadCsv(string path, bool hasTitle)
|
|
|
+//{
|
|
|
+// if (!File.Exists(path))
|
|
|
+// return new List<string>();
|
|
|
|
|
|
-//Address address = JsonTool.StringToJsonEntity<Address>(FileTool.FileToString("C:\\Users\\Shun\\Desktop\\[6032]Node_Address 202310120854271486.json"));
|
|
|
+// var lines = File.ReadAllLines(path).ToList();
|
|
|
+// if (hasTitle)
|
|
|
+// {
|
|
|
+// lines.RemoveAt(0);
|
|
|
+// }
|
|
|
+// return lines;
|
|
|
+//}
|
|
|
|
|
|
-Address address = new Address();
|
|
|
-address.SN = Guid.NewGuid().ToString();
|
|
|
-address.CreationTime = DateTime.Now;
|
|
|
-address.AddressArray = new List<AddressDetails>();
|
|
|
-List<string> strings = ReadCsv("C:\\Users\\Shun\\Desktop\\6022.csv", true);
|
|
|
-foreach (var item in strings)
|
|
|
-{
|
|
|
- string[] str = item.Split(",");
|
|
|
- string addressD = str[0].Replace("\"", "");
|
|
|
- address.AddressArray.Add(new AddressDetails()
|
|
|
- {
|
|
|
- AddressName = $"ns=2;s=6022.6022.{addressD}",
|
|
|
- SN = Guid.NewGuid().ToString()
|
|
|
- });
|
|
|
-}
|
|
|
+////Address address = JsonTool.StringToJsonEntity<Address>(FileTool.FileToString("C:\\Users\\Shun\\Desktop\\[6032]Node_Address 202310120854271486.json"));
|
|
|
|
|
|
-//address.AddressArray.Add(new AddressDetails()
|
|
|
+//Address address = new Address();
|
|
|
+//address.SN = Guid.NewGuid().ToString();
|
|
|
+//address.CreationTime = DateTime.Now;
|
|
|
+//address.AddressArray = new List<AddressDetails>();
|
|
|
+//List<string> strings = ReadCsv("C:\\Users\\Shun\\Desktop\\6022.csv", true);
|
|
|
+//foreach (var item in strings)
|
|
|
//{
|
|
|
-// AddressName = $"ns=2;s=6022.6022.LAP5_DP2113_AUTO",
|
|
|
-// SN = Guid.NewGuid().ToString()
|
|
|
-//});
|
|
|
+// string[] str = item.Split(",");
|
|
|
+// string addressD = str[0].Replace("\"", "");
|
|
|
+// address.AddressArray.Add(new AddressDetails()
|
|
|
+// {
|
|
|
+// AddressName = $"ns=2;s=6022.6022.{addressD}",
|
|
|
+// SN = Guid.NewGuid().ToString()
|
|
|
+// });
|
|
|
+//}
|
|
|
|
|
|
-//address.AddressArray.Add(new AddressDetails()
|
|
|
+////address.AddressArray.Add(new AddressDetails()
|
|
|
+////{
|
|
|
+//// AddressName = $"ns=2;s=6022.6022.LAP5_DP2113_AUTO",
|
|
|
+//// SN = Guid.NewGuid().ToString()
|
|
|
+////});
|
|
|
+
|
|
|
+////address.AddressArray.Add(new AddressDetails()
|
|
|
+////{
|
|
|
+//// AddressName = $"ns=2;s=6022.6022.LAP5_DP2112_STATE_RUN",
|
|
|
+//// SN = Guid.NewGuid().ToString()
|
|
|
+////});
|
|
|
+
|
|
|
+//OpcUaClientOperate opcUaClientOperate = OpcUaClientOperate.Instance(new OpcUaClientData.Basics
|
|
|
//{
|
|
|
-// AddressName = $"ns=2;s=6022.6022.LAP5_DP2112_STATE_RUN",
|
|
|
-// SN = Guid.NewGuid().ToString()
|
|
|
+// ServerUrl = "opc.tcp://192.168.2.220:49320",
|
|
|
+// CustomName = "YSAI 性能测试",
|
|
|
+// TaskNumber = 10,
|
|
|
+// TaskHandleInterval = 1,
|
|
|
+// SubscribeSingleGroupMaxCount = 1000,
|
|
|
//});
|
|
|
+//Console.WriteLine(opcUaClientOperate.On().ToJson().JsonFormatting());
|
|
|
+//opcUaClientOperate.OnEvent += OpcUaClientOperate_OnEvent;
|
|
|
|
|
|
-OpcUaClientOperate opcUaClientOperate = OpcUaClientOperate.Instance(new OpcUaClientData.Basics
|
|
|
-{
|
|
|
- ServerUrl = "opc.tcp://192.168.2.220:49320",
|
|
|
- CustomName = "YSAI 性能测试",
|
|
|
- TaskNumber = 10,
|
|
|
- TaskHandleInterval = 1,
|
|
|
- SubscribeSingleGroupMaxCount = 1000,
|
|
|
-});
|
|
|
-Console.WriteLine(opcUaClientOperate.On().ToJson().JsonFormatting());
|
|
|
-opcUaClientOperate.OnEvent += OpcUaClientOperate_OnEvent;
|
|
|
+//while (true)
|
|
|
+//{
|
|
|
+// Console.ReadLine();
|
|
|
|
|
|
-while (true)
|
|
|
-{
|
|
|
- Console.ReadLine();
|
|
|
+// OperateResult operateResult = opcUaClientOperate.Subscribe(address);
|
|
|
+// Console.WriteLine(operateResult.ToJson().JsonFormatting());
|
|
|
+// Console.ReadLine();
|
|
|
+// operateResult = opcUaClientOperate.UnSubscribe(address);
|
|
|
+// Console.WriteLine(operateResult.ToJson().JsonFormatting());
|
|
|
+// Console.ReadLine();
|
|
|
+// address = new Address();
|
|
|
+// address.SN = Guid.NewGuid().ToString();
|
|
|
+// address.CreationTime = DateTime.Now;
|
|
|
+// address.AddressArray = new List<AddressDetails>();
|
|
|
+// address.AddressArray.Add(new AddressDetails()
|
|
|
+// {
|
|
|
+// AddressName = $"6666",
|
|
|
+// SN = Guid.NewGuid().ToString()
|
|
|
+// });
|
|
|
+// operateResult = opcUaClientOperate.Subscribe(address);
|
|
|
+// Console.WriteLine(operateResult.ToJson().JsonFormatting());
|
|
|
|
|
|
- OperateResult operateResult = opcUaClientOperate.Subscribe(address);
|
|
|
- Console.WriteLine(operateResult.ToJson().JsonFormatting());
|
|
|
- Console.ReadLine();
|
|
|
- operateResult = opcUaClientOperate.UnSubscribe(address);
|
|
|
- Console.WriteLine(operateResult.ToJson().JsonFormatting());
|
|
|
- Console.ReadLine();
|
|
|
- address = new Address();
|
|
|
- address.SN = Guid.NewGuid().ToString();
|
|
|
- address.CreationTime = DateTime.Now;
|
|
|
- address.AddressArray = new List<AddressDetails>();
|
|
|
- address.AddressArray.Add(new AddressDetails()
|
|
|
- {
|
|
|
- AddressName = $"6666",
|
|
|
- SN = Guid.NewGuid().ToString()
|
|
|
- });
|
|
|
- operateResult = opcUaClientOperate.Subscribe(address);
|
|
|
- Console.WriteLine(operateResult.ToJson().JsonFormatting());
|
|
|
+//}
|
|
|
|
|
|
-}
|
|
|
+//void OpcUaClientOperate_OnEvent(object? sender, EventResult e)
|
|
|
+//{
|
|
|
+// switch (e.RType)
|
|
|
+// {
|
|
|
+// case YSAI.Core.@enum.ResultType.KeyValue:
|
|
|
|
|
|
-void OpcUaClientOperate_OnEvent(object? sender, EventResult e)
|
|
|
-{
|
|
|
- switch (e.RType)
|
|
|
- {
|
|
|
- case YSAI.Core.@enum.ResultType.KeyValue:
|
|
|
-
|
|
|
- ConcurrentDictionary<string, AddressValue> pairs = e.GetRData<ConcurrentDictionary<string, AddressValue>>();
|
|
|
- foreach (var item in pairs)
|
|
|
- {
|
|
|
- if (item.Value.AddressName.Equals("ns=2;s=6022.6022.LAP5_DP2112_STATE_RUN") || item.Value.AddressName.Equals("ns=2;s=6022.6022.LAP5_DP2113_AUTO"))
|
|
|
- {
|
|
|
- String str = String.Format("{0,-100}{1,-100}", item.Key, item.Value.Value);
|
|
|
- LogHelper.Verbose(str);
|
|
|
- }
|
|
|
-
|
|
|
- //String str = String.Format("{0,-100}{1,-100}", item.Key, item.Value.Value);
|
|
|
- //LogHelper.Verbose(str);
|
|
|
- }
|
|
|
- break;
|
|
|
-
|
|
|
- default:
|
|
|
- //Console.WriteLine(e.Message);
|
|
|
- break;
|
|
|
- }
|
|
|
-}
|
|
|
+// ConcurrentDictionary<string, AddressValue> pairs = e.GetRData<ConcurrentDictionary<string, AddressValue>>();
|
|
|
+// foreach (var item in pairs)
|
|
|
+// {
|
|
|
+// if (item.Value.AddressName.Equals("ns=2;s=6022.6022.LAP5_DP2112_STATE_RUN") || item.Value.AddressName.Equals("ns=2;s=6022.6022.LAP5_DP2113_AUTO"))
|
|
|
+// {
|
|
|
+// String str = String.Format("{0,-100}{1,-100}", item.Key, item.Value.Value);
|
|
|
+// LogHelper.Verbose(str);
|
|
|
+// }
|
|
|
+
|
|
|
+// //String str = String.Format("{0,-100}{1,-100}", item.Key, item.Value.Value);
|
|
|
+// //LogHelper.Verbose(str);
|
|
|
+// }
|
|
|
+// break;
|
|
|
+
|
|
|
+// default:
|
|
|
+// //Console.WriteLine(e.Message);
|
|
|
+// break;
|
|
|
+// }
|
|
|
+//}
|
|
|
|
|
|
//using Opc.Ua;
|
|
|
//using YSAI.Core.data;
|