using Newtonsoft.Json; using ScottPlot.Plottables; using SunlightCentralizedControlManagement_SCCM_.View; using SunlightCentralizedControlManagement_SCCM_.ViewModel; using SunlightCentralizedControlManagement_SCCM_.WindowsView; using System; using System.Collections.Generic; using System.Data; using System.Linq; using System.Security.Cryptography; using System.Text; using System.Text.RegularExpressions; using System.Threading; using System.Threading.Tasks; using System.Windows; using TouchSocket.Core; using TouchSocket.SerialPorts; using TouchSocket.Sockets; using static OpenTK.Graphics.OpenGL.GL; using static SkiaSharp.HarfBuzz.SKShaper; using static SunlightCentralizedControlManagement_SCCM_.UserClass.SqliteHelper; using static SunlightCentralizedControlManagement_SCCM_.ViewModel.MainWindowViewModel; using static System.Net.Mime.MediaTypeNames; namespace SunlightCentralizedControlManagement_SCCM_.UserClass { public class AsyncSerialPortClient { public static string ClipBetween(string source, char startChar, char endChar, bool includeBounds = false) { if (string.IsNullOrEmpty(source)) return string.Empty; int startIndex = source.IndexOf(startChar); if (startIndex == -1) return string.Empty; int endIndex = source.IndexOf(endChar, startIndex + 1); if (endIndex == -1) return string.Empty; if (includeBounds) { return source.Substring(startIndex, endIndex - startIndex + 1); } else { int contentStart = startIndex + 1; int contentLength = endIndex - startIndex - 1; return contentLength > 0 ? source.Substring(contentStart, contentLength) : string.Empty; } } public static string PortCOM1 { get; set; } public static string PortCOM2 { get; set; } public static string PortCOM3 { get; set; } public static string PortCOM4 { get; set; } public static async Task PortClient(SerialPortClient portclient, string com, int BAUD) { //var client = new SerialPortClient(); portclient.Connecting = (client, e) => { return EasyTask.CompletedTask; };//即将连接到端口 portclient.Connected = (client, e) => { return EasyTask.CompletedTask; };//成功连接到端口 portclient.Closing = (client, e) => { return EasyTask.CompletedTask; };//即将从端口断开连接。此处仅主动断开才有效。 portclient.Closed = (client, e) => { return EasyTask.CompletedTask; };//从端口断开连接，当连接不成功时不会触发。 portclient.Received = (client, e) => { _responseEvent.Set(); string[] sArray = Regex.Split(e.ByteBlock.Span.ToString(Encoding.UTF8), @"\n", RegexOptions.IgnoreCase); for (int i = 0; i < sArray.Length; i++) { if (sArray[i].Length>5) { string SYSAPI = sArray[i].Substring(0, 5); string Station = ClipBetween(sArray[i], '[', ']'); string DAT = sArray[i].Substring(sArray[i].IndexOf("]") + 1); if (SYSAPI == "SC800") { try { Dictionary _new = new Dictionary();//缓存函数 _new = JsonConvert.DeserializeObject>(DAT);//反序列化 lock (MainWindowViewModel.Machines.Rows.SyncRoot) { DataRow drEmployee = MainWindowViewModel.Machines.Select("Station='" + Station + "' AND Serial = 'PORT1'").First(); drEmployee.BeginEdit(); drEmployee["State"] = "802"; drEmployee.EndEdit(); drEmployee.AcceptChanges(); } } catch (Exception ex) { LogGing.ERRDATA(ex); MainWindowViewModel.ERR_c++; } } else if (SYSAPI == "SC810") { try { Dictionary _dat; _dat = SerializeConvert.JsonDeserializeFromString>(DAT); MainWindowViewModel.SQLiteHelpers.Update("WorkOrder", new Dictionary { { "State", 111 } }, "WorkOrder ='" + _dat.GetValue("WorkOrder") + "' AND ReDye ='" + _dat.GetValue("ReDye") + "'", null); } catch (Exception ex) { LogGing.LogGingDATA("[ERR='" + ex + "']=Exception"); MainWindowViewModel.ERR_c++; } }//回复的工单记录状态后就位111 else if (SYSAPI == "SC811") { try { Dictionary _dat; _dat = SerializeConvert.JsonDeserializeFromString>(DAT); MainWindowViewModel.SQLiteHelpers.Update("WorkorderSteps", new Dictionary { { "Mode", 1 } }, "WorkOrder ='" + _dat.GetValue("Order") + "' AND ReDye ='" + _dat.GetValue("ReDye") + "' AND Step ='" + _dat.GetValue("Step") + "'", null); int x = MainWindowViewModel.SQLiteHelpers.ExecuteDataSet("select * from WorkorderSteps where WorkOrder='"+ _dat.GetValue("Order") + "' AND ReDye ='" + _dat.GetValue("ReDye") + "' AND Mode <> '1'", null).Tables[0].Rows.Count; if (x == 0) { MainWindowViewModel.SQLiteHelpers.Update("WorkOrder", new Dictionary { { "State", 113 } }, "WorkOrder ='" + _dat.GetValue("Order") + "' AND ReDye ='" + _dat.GetValue("ReDye") + "'", null); } } catch (Exception ex) { LogGing.LogGingDATA("[ERR='" + ex + "']=Exception"); MainWindowViewModel.ERR_c++; } }//回复的工单明细状态后就位113 else if (SYSAPI == "SC812") { try { Dictionary _dat; _dat = SerializeConvert.JsonDeserializeFromString>(DAT); MainWindowViewModel.SQLiteHelpers.Update("WorkOrder", new Dictionary { { "State", 101 } }, "WorkOrder ='" + _dat.GetValue("WorkOrder") + "' AND ReDye ='" + _dat.GetValue("ReDye") + "'", null); } catch (Exception ex) { LogGing.LogGingDATA("[ERR='" + ex + "']=Exception"); MainWindowViewModel.ERR_c++; } }//回复的工单设置状态后就位101 else if (SYSAPI == "SC827") { try { Dictionary _dat; _dat = SerializeConvert.JsonDeserializeFromString>(DAT); DataTable dataTable = MainWindowViewModel.SQLiteHelpers.ExecuteDataSet("select * from Dyelot where WorkOrder='" + _dat.GetValue("WorkOrder") + "' AND ReDye ='" + _dat.GetValue("ReDye") + "' AND Step = '"+ _dat.GetValue("Step") + "'", null).Tables[0]; foreach (DataRow sourceRow in dataTable.Rows) { lock (MainWindowViewModel.Dyelot_CALL.Rows.SyncRoot) { // 创建新行（基于目标表结构） DataRow newRow = MainWindowViewModel.Dyelot_CALL.NewRow(); // 复制源表中存在的列数据 foreach (DataColumn column in dataTable.Columns) { if (MainWindowViewModel.Dyelot_CALL.Columns.Contains(column.ColumnName)) { newRow[column.ColumnName] = sourceRow[column.ColumnName]; } } MainWindowViewModel.Dyelot_CALL.Rows.Add(newRow); Dictionary Product_ = new Dictionary();//缓存函数 Product_.Add("State", 202); Product_.Add("Dyelot", newRow.Field("Dyelot")); Product_.Add("Step", newRow.Field("Step")); newRow.BeginEdit(); newRow["State"] = 202; newRow.EndEdit(); MainWindowViewModel.SQLiteHelpers.InsertData("DyelotHistory", MainWindowViewModel.SQLiteHelpers.ToDictionary(newRow));// 执行插入 int index = MainWindowViewModel.SQLiteHelpers.ExecuteDataSet("select * from Machines where Serial='PORT1' AND Station ='" + Station + "' ", null).Tables[0].Rows[0].Field("ID"); string dat_ = "SC828[" + Station + "]" + Product_.ToJsonString(); bool exists = stringQueueSerial_1.Any(item => item.ID == index && item.DAT == dat_); if (!exists) { stringQueueSerial_1.Enqueue(new QueueSerial { ID = index, DAT = dat_ }); } } } } catch (Exception ex) { LogGing.LogGingDATA("[ERR='" + ex + "']=Exception"); MainWindowViewModel.ERR_c++; } }//获取呼叫领料单 else if (SYSAPI == "SC822") { try { DataTable dataTable = JsonConvert.DeserializeObject(DAT).Copy();//反序列化 System.Windows.Application.Current.Dispatcher.Invoke(() => { UserWorkOrder userWorkOrder = new UserWorkOrder(); userWorkOrder.WorkOrderTable = dataTable; userWorkOrder.Show(); }); } catch (Exception) { System.Windows.Application.Current.Dispatcher.Invoke(() => { UserInf userInf = new UserInf(); userInf.Inf_DAT = "没有等待中的工艺"; userInf.Show(); userInf.Activate(); }); // LogGing.LogGingDATA("[ERR='" + ex + "']=Exception"); MainWindowViewModel.ERR_c++; } }//可用工单 else if (SYSAPI == "SC830") { try { Dictionary _new = new Dictionary();//缓存函数 _new = JsonConvert.DeserializeObject>(DAT);//反序列化 string mac; lock (MainWindowViewModel.Machines.Rows.SyncRoot) { DataRow drEmployee = MainWindowViewModel.Machines.Select("Station='" + Station + "' AND Serial = 'PORT1'").First(); mac = drEmployee["Name"].ToString(); drEmployee.BeginEdit(); drEmployee["ERR"] = _new.GetValue("ERR"); drEmployee["LOCK"] = _new.GetValue("LOCK"); drEmployee["Message"] = _new.GetValue("Status"); drEmployee["WorkOrder"] = _new.GetValue("WorkNumder"); drEmployee["Temperature"] = _new.GetValue("MTT"); drEmployee["WaterLevel"] = _new.GetValue("MTL"); drEmployee["Process"] = _new.GetValue("Process"); drEmployee["Step"] = _new.GetValue("Step"); drEmployee["UserButton"] = _new.GetValue("UserButton"); if (_new.GetValue("UserInfoStart").ToString() != "900") { drEmployee["UserInfoStart"] = _new.GetValue("UserInfoStart"); } drEmployee["UserInfo"] = _new.GetValue("UserInfo"); drEmployee["WORK_RUN"] = _new.GetValue("WORK_RUN"); drEmployee["RUN_STEPID"] = _new.GetValue("RUN_STEPID"); drEmployee["CALL"] = _new.GetValue("CALL"); drEmployee.EndEdit(); drEmployee.AcceptChanges(); } if (_new.GetValue("Status").ToString() != "----------") { Dictionary Chart_new = new Dictionary();//缓存函数 Chart_new.Add("WorkOrder", _new.GetValue("WorkNumder")); Chart_new.Add("Machine", mac); Chart_new.Add("Time", _new.GetValue("Time")); Chart_new.Add("MST", _new.GetValue("MST")); Chart_new.Add("MTT", _new.GetValue("MTT")); Chart_new.Add("MTL", _new.GetValue("MTL")); Chart_new.Add("MTH", _new.GetValue("MTH")); Chart_new.Add("MUT", _new.GetValue("MUT")); Chart_new.Add("STTA", _new.GetValue("STTA")); Chart_new.Add("STLA", _new.GetValue("STLA")); Chart_new.Add("STTB", _new.GetValue("STTB")); Chart_new.Add("STLB", _new.GetValue("STLB")); Chart_new.Add("STTC", _new.GetValue("STTC")); Chart_new.Add("STLC", _new.GetValue("STLC")); MainWindowViewModel.SQLiteChartAdress.InsertData("Chart", Chart_new);// 执行插入 } } catch (Exception ex) { LogGing.LogGingDATA("[ERR='" + ex + "']=Exception"); MainWindowViewModel.ERR_c++; } }//当前信息 else if (SYSAPI == "SC831") { try { Dictionary _dat; _dat = SerializeConvert.JsonDeserializeFromString>(DAT); MainWindowViewModel.dt_TP = MainWindowViewModel.SQLiteHelpers.ExecuteDataSet("select * WorkorderSteps Dyelot where WorkOrder='" + _dat.GetValue("WorkOrder") + "' AND ReDye ='" + _dat.GetValue("ReDye") + "'", null).Tables[0]; } catch (Exception ex) { LogGing.LogGingDATA("[ERR='" + ex + "']=Exception"); MainWindowViewModel.ERR_c++; } }//当前步骤信息 else if (SYSAPI == "SC832") { try { MainWindowViewModel.MachineLOG = DAT; } catch (Exception ex) { LogGing.LogGingDATA("[ERR='" + ex + "']=Exception"); MainWindowViewModel.ERR_c++; } }//当前细节信息 else if (SYSAPI == "SC833") { try { Dictionary _dat; _dat = SerializeConvert.JsonDeserializeFromString>(DAT); MonitorView.Product_DAT = MainWindowViewModel.SQLiteHelpers.ExecuteDataSet("select * from Dyelot where WorkOrder='" + _dat.GetValue("WorkOrder") + "' AND ReDye ='" + _dat.GetValue("ReDye") + "'", null).Tables[0]; MonitorView.Product_bool = true; } catch (Exception ex) { LogGing.LogGingDATA("[ERR='" + ex + "']=Exception"); MainWindowViewModel.ERR_c++; } }//当前领料单信息 else if (SYSAPI == "SC851") { try { Dictionary _dat; _dat = SerializeConvert.JsonDeserializeFromString>(DAT); string[] DO = _dat.GetValue("DO").ToString().Split(','); string[] DQ = _dat.GetValue("DQ").ToString().Split(','); DataTable dataTable = new DataTable(); dataTable.Columns.Add("ID", Type.GetType("System.String")); dataTable.Columns.Add("type", Type.GetType("System.String")); dataTable.Columns.Add("DIO", Type.GetType("System.Bool")); dataTable.Columns.Add("PLC", Type.GetType("System.String")); for (int DOi = 0; DOi < DO.Length; DOi++) { DataRow newRow = dataTable.NewRow(); newRow["ID"] = DOi+2001; newRow["type"] = "DO"; newRow["DIO"] = DO[DOi]; newRow["PLC"] = DOi + 2001; dataTable.Rows.Add(newRow); } for (int DQi = 0; DQi < DO.Length; DQi++) { DataRow newRow = dataTable.NewRow(); newRow["ID"] = DQi + 3001; newRow["type"] = "DQ"; newRow["DIO"] = DQ[DQi]; newRow["PLC"] = DQi + 3001; dataTable.Rows.Add(newRow); } MainWindowViewModel.dt_d = dataTable; } catch (Exception ex) { LogGing.LogGingDATA("[ERR='" + ex + "']=Exception"); MainWindowViewModel.ERR_c++; } }//数字开关表 else if (SYSAPI == "SC852") { try { Dictionary _dat; _dat = SerializeConvert.JsonDeserializeFromString>(DAT); string[] AI = _dat.GetValue("DO").ToString().Split(','); string[] AO = _dat.GetValue("DQ").ToString().Split(','); DataTable dataTable = new DataTable(); dataTable.Columns.Add("ID", Type.GetType("System.String")); dataTable.Columns.Add("type", Type.GetType("System.String")); dataTable.Columns.Add("AIO", Type.GetType("System.Int")); dataTable.Columns.Add("PLC", Type.GetType("System.String")); for (int AIi = 0; AIi < AI.Length; AIi++) { DataRow newRow = dataTable.NewRow(); newRow["ID"] = AIi + 4001; newRow["type"] = "DO"; newRow["AIO"] = AI[AIi]; newRow["PLC"] = AIi + 4001; dataTable.Rows.Add(newRow); } for (int AOi = 0; AOi < AO.Length; AOi++) { DataRow newRow = dataTable.NewRow(); newRow["ID"] = AOi + 5001; newRow["type"] = "DQ"; newRow["AIO"] = AO[AOi]; newRow["PLC"] = AOi + 5001; dataTable.Rows.Add(newRow); } MainWindowViewModel.dt_a = dataTable; } catch (Exception ex) { LogGing.LogGingDATA("[ERR='" + ex + "']=Exception"); MainWindowViewModel.ERR_c++; } }//寄存器表 else if (SYSAPI == "SC853") { try { Dictionary _dat; _dat = SerializeConvert.JsonDeserializeFromString>(DAT); string[] M = _dat.GetValue("M").ToString().Split(','); DataTable dataTable = new DataTable(); dataTable.Columns.Add("ID", Type.GetType("System.String")); dataTable.Columns.Add("type", Type.GetType("System.String")); dataTable.Columns.Add("Value", Type.GetType("System.Double")); dataTable.Columns.Add("PLC", Type.GetType("System.String")); for (int Mi = 0; Mi < M.Length; Mi++) { DataRow newRow = dataTable.NewRow(); newRow["ID"] = Mi + 1001; newRow["type"] = "M"; newRow["Value"] = M[Mi]; newRow["PLC"] = Mi + 1001; dataTable.Rows.Add(newRow); } } catch (Exception ex) { LogGing.LogGingDATA("[ERR='" + ex + "']=Exception"); MainWindowViewModel.ERR_c++; } }//缓存表 else if (SYSAPI == "SC854") { try { } catch (Exception ex) { LogGing.LogGingDATA("[ERR='" + ex + "']=Exception"); MainWindowViewModel.ERR_c++; } }//程序设置表 else if (SYSAPI == "SC855") { try { } catch (Exception ex) { LogGing.LogGingDATA("[ERR='" + ex + "']=Exception"); MainWindowViewModel.ERR_c++; } }//系统设置表 else if (SYSAPI == "SC859") { try { } catch (Exception ex) { LogGing.LogGingDATA("[ERR='" + ex + "']=Exception"); MainWindowViewModel.ERR_c++; } }//信息 else if (SYSAPI == "SC910") { try { MainWindowViewModel.SQLiteHelpers.Update("WorkOrder", new Dictionary { { "State", 109 } }, "WorkOrder ='" + DAT + "'", null); } catch (Exception ex) { LogGing.LogGingDATA("[ERR='" + ex + "']=Exception"); MainWindowViewModel.ERR_c++; } }//发布失败 else if (SYSAPI == "SC911") { try { MainWindowViewModel.SQLiteHelpers.Update("WorkOrder", new Dictionary { { "State", 119 } }, "WorkOrder ='" + DAT + "'", null); } catch (Exception ex) { LogGing.LogGingDATA("[ERR='" + ex + "']=Exception"); MainWindowViewModel.ERR_c++; } }//细节错误 else if (SYSAPI == "SC921") { try { } catch (Exception ex) { LogGing.LogGingDATA("[ERR='" + ex + "']=Exception"); MainWindowViewModel.ERR_c++; } }//错误 else if (SYSAPI == "SC980") { MessageBox.Show(DAT, "SCCM", MessageBoxButton.OK, MessageBoxImage.Question); } } } return EasyTask.CompletedTask; ; }; await portclient.SetupAsync(new TouchSocketConfig() .SetMaxBufferSize(1024 * 1024 * 10) .SetSerialPortOption(new SerialPortOption() { BaudRate = BAUD,//波特率 DataBits = 8,//数据位 Parity = System.IO.Ports.Parity.None,//校验位 PortName = com,//COM StopBits = System.IO.Ports.StopBits.One,//停止位 }) .SetSerialDataHandlingAdapter(() => new PeriodPackageAdapter() { CacheTimeout = TimeSpan.FromMilliseconds(100) }) .ConfigurePlugins(a => { //a.Add(); } )); try { await portclient.ConnectAsync(); } catch (Exception ex) { LogGing.ERRDATA(ex); } } public static async Task PortClient2(SerialPortClient portclient, string com, int BAUD) { //var client = new SerialPortClient(); portclient.Connecting = (client, e) => { return EasyTask.CompletedTask; };//即将连接到端口 portclient.Connected = (client, e) => { return EasyTask.CompletedTask; };//成功连接到端口 portclient.Closing = (client, e) => { return EasyTask.CompletedTask; };//即将从端口断开连接。此处仅主动断开才有效。 portclient.Closed = (client, e) => { return EasyTask.CompletedTask; };//从端口断开连接，当连接不成功时不会触发。 portclient.Received = (client, e) => { _responseEvent2.Set(); string[] sArray = Regex.Split(e.ByteBlock.Span.ToString(Encoding.UTF8), @"\n", RegexOptions.IgnoreCase); return EasyTask.CompletedTask; ; }; await portclient.SetupAsync(new TouchSocketConfig() .SetSerialPortOption(new SerialPortOption() { BaudRate = BAUD,//波特率 DataBits = 8,//数据位 Parity = System.IO.Ports.Parity.None,//校验位 PortName = com,//COM StopBits = System.IO.Ports.StopBits.One,//停止位 }) .SetSerialDataHandlingAdapter(() => new PeriodPackageAdapter() { CacheTimeout = TimeSpan.FromMilliseconds(100) }) .ConfigurePlugins(a => { //a.Add(); })); try { await portclient.ConnectAsync(); } catch (Exception ex) { LogGing.ERRDATA(ex); } } public static async Task PortClient3(SerialPortClient portclient, string com, int BAUD) { //var client = new SerialPortClient(); portclient.Connecting = (client, e) => { return EasyTask.CompletedTask; };//即将连接到端口 portclient.Connected = (client, e) => { return EasyTask.CompletedTask; };//成功连接到端口 portclient.Closing = (client, e) => { return EasyTask.CompletedTask; };//即将从端口断开连接。此处仅主动断开才有效。 portclient.Closed = (client, e) => { return EasyTask.CompletedTask; };//从端口断开连接，当连接不成功时不会触发。 portclient.Received = (client, e) => { _responseEvent3.Set(); string[] sArray = Regex.Split(e.ByteBlock.Span.ToString(Encoding.UTF8), @"\n", RegexOptions.IgnoreCase); return EasyTask.CompletedTask; ; }; await portclient.SetupAsync(new TouchSocketConfig() .SetSerialPortOption(new SerialPortOption() { BaudRate = BAUD,//波特率 DataBits = 8,//数据位 Parity = System.IO.Ports.Parity.None,//校验位 PortName = com,//COM StopBits = System.IO.Ports.StopBits.One,//停止位 }) .SetSerialDataHandlingAdapter(() => new PeriodPackageAdapter() { CacheTimeout = TimeSpan.FromMilliseconds(100) }) .ConfigurePlugins(a => { //a.Add(); })); try { await portclient.ConnectAsync(); } catch (Exception ex) { LogGing.ERRDATA(ex); } } public static async Task PortClient4(SerialPortClient portclient, string com, int BAUD) { //var client = new SerialPortClient(); portclient.Connecting = (client, e) => { return EasyTask.CompletedTask; };//即将连接到端口 portclient.Connected = (client, e) => { return EasyTask.CompletedTask; };//成功连接到端口 portclient.Closing = (client, e) => { return EasyTask.CompletedTask; };//即将从端口断开连接。此处仅主动断开才有效。 portclient.Closed = (client, e) => { return EasyTask.CompletedTask; };//从端口断开连接，当连接不成功时不会触发。 portclient.Received = (client, e) => { _responseEvent4.Set(); string[] sArray = Regex.Split(e.ByteBlock.Span.ToString(Encoding.UTF8), @"\n", RegexOptions.IgnoreCase); return EasyTask.CompletedTask; ; }; await portclient.SetupAsync(new TouchSocketConfig() .SetSerialPortOption(new SerialPortOption() { BaudRate = BAUD,//波特率 DataBits = 8,//数据位 Parity = System.IO.Ports.Parity.None,//校验位 PortName = com,//COM StopBits = System.IO.Ports.StopBits.One,//停止位 }) .SetSerialDataHandlingAdapter(() => new PeriodPackageAdapter() { CacheTimeout = TimeSpan.FromMilliseconds(100) }) .ConfigurePlugins(a => { //a.Add(); })); try { await portclient.ConnectAsync(); } catch (Exception ex) { LogGing.ERRDATA(ex); } } public static readonly ManualResetEventSlim _responseEvent = new ManualResetEventSlim(false); public static readonly ManualResetEventSlim _responseEvent2 = new ManualResetEventSlim(false); public static readonly ManualResetEventSlim _responseEvent3 = new ManualResetEventSlim(false); public static readonly ManualResetEventSlim _responseEvent4 = new ManualResetEventSlim(false); /// /// 发送指令并等待响应，超时时间为500ms /// /// 要发送的指令字节数组 /// 从机的响应数据，超时则为null public static void SendCommandAndWait(SerialPortClient serialPortClients, string command) { try { var t = CRCcheck16.ToCRC16(command); _responseEvent.Reset(); serialPortClients.Send(command); // 发送指令 // 等待500毫秒或直到收到响应 _responseEvent.Wait(TimeSpan.FromMilliseconds(1000)); // 重置事件状态 _responseEvent.Set(); //清楚了解状态 string Station = ClipBetween(command, '[', ']'); lock (MainWindowViewModel.Machines.Rows.SyncRoot) { DataRow drEmployee = MainWindowViewModel.Machines.Select("Station='" + Station + "' AND Serial = 'PORT1'").First(); if (drEmployee.Field("State") != 800) { drEmployee.BeginEdit(); drEmployee["State"] = "800"; drEmployee["WorkOrder"] = "------"; drEmployee["Dyelot"] = ""; drEmployee["Temperature"] = 0.0; drEmployee["WaterLevel"] = 0.0; drEmployee["Process"] = ""; drEmployee["Step"] = ""; drEmployee["Message"] = ""; drEmployee["SYSKEY"] = ""; drEmployee["WORK_RUN"] = "-1"; drEmployee["ERR"] = false; drEmployee.EndEdit(); drEmployee.AcceptChanges(); } } } catch (Exception) { } } public static void SendCommandAndWait2(SerialPortClient serialPortClients, string command) { try { _responseEvent2.Reset(); serialPortClients.Send(command); // 发送指令 // 等待500毫秒或直到收到响应 _responseEvent2.Wait(TimeSpan.FromMilliseconds(1000)); // 重置事件状态 _responseEvent2.Set(); } catch (Exception) { } } public static void SendCommandAndWait3(SerialPortClient serialPortClients, string command) { try { _responseEvent3.Reset(); serialPortClients.Send(command); // 发送指令 // 等待500毫秒或直到收到响应 _responseEvent3.Wait(TimeSpan.FromMilliseconds(1000)); // 重置事件状态 _responseEvent3.Set(); } catch (Exception) { } } public static void SendCommandAndWait4(SerialPortClient serialPortClients, string command) { try { _responseEvent4.Reset(); serialPortClients.Send(command); // 发送指令 // 等待500毫秒或直到收到响应 _responseEvent4.Wait(TimeSpan.FromMilliseconds(1000)); // 重置事件状态 _responseEvent4.Set(); } catch (Exception) { } } } }