Merge branch 'master' of http://192.168.0.12:13000/sc/SunlightCentralizedControlManagement

DATA/SCCM.ini

@@ -0,0 +1,24 @@
+[SYS]
+Language=zh-CN
+DyelotsDispenser=True
+COMP1=COM7
+COMP2=COM8
+COMP3=COM9
+COMP4=COM10
+BAUD1 = 57600
+BAUD2= 57600
+BAUD3 =57600
+BAUD4 =57600
+[SQL_SERVER]
+SQL1=www.scserverddns.top\EXPRESS ,21344
+SQL2=BatchDyeingCentral
+SQL3=SQL SERVER
+SQL4=sa
+SQL5=SC971216@server
+[SN]
+SN3=5BEE2D9CF3E1A8DD
+SN2=BED2E58B6EBB4BD4
+SN1=5BEE2D9CF3E1A8DD
+[VOICE]
+V1=-2
+V2=100

Login.xaml.cs

@@ -1,4 +1,5 @@
-using SunlightCentralizedControlManagement_SCCM_.ViewModel;
+using SunlightCentralizedControlManagement_SCCM_.UserClass;
+using SunlightCentralizedControlManagement_SCCM_.ViewModel;
 using System;
 using System.Data;
 using System.Data.SqlClient;
@@ -82,9 +83,10 @@ namespace SunlightCentralizedControlManagement_SCCM_
                     }
                 }
             }
-            catch (Exception)
+            catch (Exception ex)
             {
-                System.Windows.MessageBox.Show(Properties.Resources.NPERR, "SCCM", MessageBoxButton.OK, MessageBoxImage.Error);
+                LogGing.ERRDATA(ex);
+                System.Windows.MessageBox.Show("Unable to start. Check the log for details.", "SCCM", MessageBoxButton.OK, MessageBoxImage.Error);
             }
         }
 

MainWindow.xaml.cs

@@ -32,7 +32,9 @@ namespace SunlightCentralizedControlManagement_SCCM_
     {
         public static string user_;
         public static DataTable InfData = new DataTable();
+     //   public static string[] Inf_string ;
         public UserInformation userInformation;
+       // public UserInf userInf;
 
         public MainWindow()
         {
@@ -74,6 +76,22 @@ namespace SunlightCentralizedControlManagement_SCCM_
                 if (userInformation.WindowState == WindowState.Minimized) userInformation.WindowState = WindowState.Normal;
             }
         }
+   /*     private void UserInfTable(string dat)//触发行改变事件
+        {
+            userInf.Inf_DAT = dat;
+            if (userInf == null || !userInf.IsLoaded)//窗口不存在及创建
+            {
+                userInf = new UserInf();
+                userInf.Topmost = true;
+                userInf.Show();
+                userInf.Activate();
+            }
+            else
+            {//窗口纯在及置顶
+                userInf.Activate();
+                if (userInf.WindowState == WindowState.Minimized) userInf.WindowState = WindowState.Normal;
+            }
+        }*/
 
         private void ButtonPopUpLogout_Click(object sender, RoutedEventArgs e)
         {

Properties/Resources.Designer.cs

@@ -19,7 +19,7 @@ namespace SunlightCentralizedControlManagement_SCCM_.Properties {
     // 类通过类似于 ResGen 或 Visual Studio 的工具自动生成的。
     // 若要添加或移除成员，请编辑 .ResX 文件，然后重新运行 ResGen
     // (以 /str 作为命令选项)，或重新生成 VS 项目。
-    [global::System.CodeDom.Compiler.GeneratedCodeAttribute("System.Resources.Tools.StronglyTypedResourceBuilder", "17.0.0.0")]
+    [global::System.CodeDom.Compiler.GeneratedCodeAttribute("System.Resources.Tools.StronglyTypedResourceBuilder", "18.0.0.0")]
     [global::System.Diagnostics.DebuggerNonUserCodeAttribute()]
     [global::System.Runtime.CompilerServices.CompilerGeneratedAttribute()]
     public class Resources {
@@ -1284,6 +1284,15 @@ namespace SunlightCentralizedControlManagement_SCCM_.Properties {
             }
         }
         
+        /// <summary>
+        ///   查找类似 Machines 的本地化字符串。
+        /// </summary>
+        public static string Machines {
+            get {
+                return ResourceManager.GetString("Machines", resourceCulture);
+            }
+        }
+        
         /// <summary>
         ///   查找类似 Malfunction 的本地化字符串。
         /// </summary>
@@ -2004,6 +2013,15 @@ namespace SunlightCentralizedControlManagement_SCCM_.Properties {
             }
         }
         
+        /// <summary>
+        ///   查找类似 ProgramName 的本地化字符串。
+        /// </summary>
+        public static string ProgramName {
+            get {
+                return ResourceManager.GetString("ProgramName", resourceCulture);
+            }
+        }
+        
         /// <summary>
         ///   查找类似 ProportionalValves 的本地化字符串。
         /// </summary>
@@ -2400,6 +2418,15 @@ namespace SunlightCentralizedControlManagement_SCCM_.Properties {
             }
         }
         
+        /// <summary>
+        ///   查找类似 Start 的本地化字符串。
+        /// </summary>
+        public static string Start {
+            get {
+                return ResourceManager.GetString("Start", resourceCulture);
+            }
+        }
+        
         /// <summary>
         ///   查找类似 StartDate 的本地化字符串。
         /// </summary>

Properties/Resources.en-US.resx

@@ -1083,4 +1083,13 @@
   <data name="Swing" xml:space="preserve">
     <value>Swing</value>
   </data>
+  <data name="Start" xml:space="preserve">
+    <value>Start</value>
+  </data>
+  <data name="ProgramName" xml:space="preserve">
+    <value>Program Name</value>
+  </data>
+  <data name="Machines" xml:space="preserve">
+    <value>Machines</value>
+  </data>
 </root>

Properties/Resources.resx

@@ -1083,4 +1083,13 @@
   <data name="Swing" xml:space="preserve">
     <value>Swing</value>
   </data>
+  <data name="Start" xml:space="preserve">
+    <value>Start</value>
+  </data>
+  <data name="ProgramName" xml:space="preserve">
+    <value>ProgramName</value>
+  </data>
+  <data name="Machines" xml:space="preserve">
+    <value>Machines</value>
+  </data>
 </root>

Properties/Resources.zh-CN.resx

@@ -1083,4 +1083,13 @@
   <data name="Swing" xml:space="preserve">
     <value>摆布</value>
   </data>
+  <data name="Start" xml:space="preserve">
+    <value>开始</value>
+  </data>
+  <data name="ProgramName" xml:space="preserve">
+    <value>工艺名</value>
+  </data>
+  <data name="Machines" xml:space="preserve">
+    <value>机台</value>
+  </data>
 </root>

Properties/Resources.zh-TW.resx

@@ -1080,11 +1080,16 @@
   <data name="_Auto" xml:space="preserve">
     <value>手/自動</value>
   </data>
-  <assembly alias="System.Windows.Forms" name="System.Windows.Forms, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089" />
-  <data name="Swing" type="System.Resources.ResXNullRef, System.Windows.Forms">
-    <value />
-  </data>
   <data name="Swing" xml:space="preserve">
     <value>擺佈</value>
   </data>
+  <data name="Start" xml:space="preserve">
+    <value>開始</value>
+  </data>
+  <data name="ProgramName" xml:space="preserve">
+    <value>工藝名</value>
+  </data>
+  <data name="Machines" xml:space="preserve">
+    <value>機器</value>
+  </data>
 </root>

SunlightCentralizedControlManagement_SCCM_.csproj

@@ -77,6 +77,9 @@
     <Prefer32Bit>true</Prefer32Bit>
   </PropertyGroup>
   <ItemGroup>
+    <Reference Include="SkiaSharp">
+      <HintPath>bin\Debug\SkiaSharp.dll</HintPath>
+    </Reference>
     <Reference Include="System" />
     <Reference Include="System.Data" />
     <Reference Include="System.Drawing" />
@@ -132,6 +135,7 @@
     <Compile Include="UserClass\CSV.cs" />
     <Compile Include="UserClass\DataGridHelper.cs" />
     <Compile Include="UserClass\DataTableForToObservableCollection.cs" />
+    <Compile Include="UserClass\DataTableManager .cs" />
     <Compile Include="UserClass\get_local_ip_address.cs" />
     <Compile Include="UserClass\HardwareSN.cs" />
     <Compile Include="UserClass\IniFile.cs" />
@@ -150,6 +154,12 @@
     <Compile Include="UserControls\DispenseMacInfo.xaml.cs">
       <DependentUpon>DispenseMacInfo.xaml</DependentUpon>
     </Compile>
+    <Compile Include="WindowsView\UserWorkOrder.xaml.cs">
+      <DependentUpon>UserWorkOrder.xaml</DependentUpon>
+    </Compile>
+    <Compile Include="WindowsView\UserInf.xaml.cs">
+      <DependentUpon>UserInf.xaml</DependentUpon>
+    </Compile>
     <Compile Include="WindowsView\UserInformation.xaml.cs">
       <DependentUpon>UserInformation.xaml</DependentUpon>
     </Compile>
@@ -289,6 +299,14 @@
       <Generator>MSBuild:Compile</Generator>
       <SubType>Designer</SubType>
     </Page>
+    <Page Include="WindowsView\UserWorkOrder.xaml">
+      <Generator>MSBuild:Compile</Generator>
+      <SubType>Designer</SubType>
+    </Page>
+    <Page Include="WindowsView\UserInf.xaml">
+      <Generator>MSBuild:Compile</Generator>
+      <SubType>Designer</SubType>
+    </Page>
     <Page Include="WindowsView\UserInformation.xaml">
       <SubType>Designer</SubType>
       <Generator>MSBuild:Compile</Generator>
@@ -525,6 +543,11 @@
     <Content Include="Fonts\font-awesome-4.7.0\css\font-awesome.css" />
     <Content Include="Fonts\font-awesome-4.7.0\css\font-awesome.min.css" />
     <Content Include="Fonts\font-awesome-4.7.0\fonts\fontawesome-webfont.svg" />
+    <Resource Include="lmage\IconParkExtend.png" />
+    <Resource Include="lmage\IconParkExtendR.png" />
+    <Resource Include="lmage\IconParkExtendY.png" />
+    <Resource Include="lmage\IconParkInfo.png" />
+    <Resource Include="lmage\IconParkUsbOne.png" />
     <Resource Include="lmage\00.png" />
     <Resource Include="lmage\1000-1.png" />
     <Resource Include="lmage\1000-2.png" />

UserClass/AsyncSerialPortClient.cs

@@ -6,6 +6,7 @@ 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;
@@ -59,30 +60,33 @@ namespace SunlightCentralizedControlManagement_SCCM_.UserClass
             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)
+                    if (sArray[i].Length > 5)
                     {
-                        return EasyTask.CompletedTask; ;
                         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<string, object> _new = new Dictionary<string, object>();//缓存函数                  
                                 _new = JsonConvert.DeserializeObject<Dictionary<string, object>>(DAT);//反序列化
-                                DataRow drEmployee = MainWindowViewModel.Machines.Select("Station='" +
-                                    Station + "' AND Serial = 'PORT1'").First();
-                                drEmployee.BeginEdit();
-                                drEmployee["State"] = "802";
-                                drEmployee.EndEdit();
-                                drEmployee.AcceptChanges();
+                                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)
                             {
@@ -93,32 +97,50 @@ namespace SunlightCentralizedControlManagement_SCCM_.UserClass
                         {
                             try
                             {
+                                DAT = DAT.Substring(DAT.IndexOf("]") + 1);
+                                Dictionary<string, object> _dat;
+                                _dat = SerializeConvert.JsonDeserializeFromString<Dictionary<string, object>>(DAT);
                                 MainWindowViewModel.SQLiteHelpers.Update("WorkOrder", new Dictionary<string, object> { { "State", 111 } },
-                                    "WorkOrder ='" + DAT + "'", null);
+                                    "WorkOrder ='" + _dat.GetValue("Work") + "' AND ReDye ='" + _dat.GetValue("ReDye") + "'", null);
                             }
                             catch (Exception ex)
                             {
                                 LogGing.LogGingDATA("[ERR='" + ex + "']=Exception"); MainWindowViewModel.ERR_c++;
                             }
-                        }
+                        }//回复的工单记录状态后就位111
                         else if (SYSAPI == "SC811")
                         {
                             try
                             {
-                                MainWindowViewModel.SQLiteHelpers.Update("WorkOrder", new Dictionary<string, object> { { "State", 113 } },
-                                    "WorkOrder ='" + DAT + "'", null);
+                                DAT = DAT.Substring(DAT.IndexOf("]") + 1);
+                                Dictionary<string, object> _dat;
+                                _dat = SerializeConvert.JsonDeserializeFromString<Dictionary<string, object>>(DAT);
+                                MainWindowViewModel.SQLiteHelpers.Update("WorkorderSteps", new Dictionary<string, object> { { "Mode", 1 } },
+                                    "WorkOrder ='" + _dat.GetValue("Work") + "' AND ReDye ='" + _dat.GetValue("ReDye") + "' AND Step ='" +
+                                    _dat.GetValue("Step") + "'", null);
+
+                                int x = MainWindowViewModel.SQLiteHelpers.ExecuteDataSet("select * from WorkorderSteps where WorkOrder='" +
+                                     _dat.GetValue("Work") + "' AND ReDye ='" + _dat.GetValue("ReDye") + "' AND Mode <> '1'", null).Tables[0].Rows.Count;
+                                if (x == 0)
+                                {
+                                    MainWindowViewModel.SQLiteHelpers.Update("WorkOrder", new Dictionary<string, object> { { "State", 113 } },
+                                          "WorkOrder ='" + _dat.GetValue("Work") + "' AND ReDye ='" + _dat.GetValue("ReDye") + "'", null);
+                                }
                             }
                             catch (Exception ex) { LogGing.LogGingDATA("[ERR='" + ex + "']=Exception"); MainWindowViewModel.ERR_c++; }
-                        }
+                        }//回复的工单明细状态后就位113
                         else if (SYSAPI == "SC812")
                         {
                             try
                             {
+                                DAT = DAT.Substring(DAT.IndexOf("]") + 1);
+                                Dictionary<string, object> _dat;
+                                _dat = SerializeConvert.JsonDeserializeFromString<Dictionary<string, object>>(DAT);
                                 MainWindowViewModel.SQLiteHelpers.Update("WorkOrder", new Dictionary<string, object> { { "State", 101 } },
-                                    "WorkOrder ='" + DAT + "'", null);
+                                          "WorkOrder ='" + _dat.GetValue("Work") + "' AND ReDye ='" + _dat.GetValue("ReDye") + "'", null);
                             }
                             catch (Exception ex) { LogGing.LogGingDATA("[ERR='" + ex + "']=Exception"); MainWindowViewModel.ERR_c++; }
-                        }
+                        }//回复的工单设置状态后就位101
                         else if (SYSAPI == "SC827")
                         {
                             try
@@ -132,33 +154,37 @@ namespace SunlightCentralizedControlManagement_SCCM_.UserClass
                             {
                                 Dictionary<string, object> _new = new Dictionary<string, object>();//缓存函数                  
                                 _new = JsonConvert.DeserializeObject<Dictionary<string, object>>(DAT);//反序列化
-                                DataRow drEmployee = MainWindowViewModel.Machines.Select("Station='" +
-                                    Station + "' AND Serial = 'PORT1'").First();
-                                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();
+                                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("Work");
+                                    drEmployee["Temperature"] = _new.GetValue("MTT");
+                                    drEmployee["WaterLevel"] = _new.GetValue("MTL");
+                                    drEmployee["Process"] = _new.GetValue("Process");
+                                    drEmployee["Step"] = _new.GetValue("Step");
+                                    drEmployee["UserButton"] = _new.GetValue("UserB");
+                                    if (_new.GetValue("InfoS").ToString() != "900")
+                                    { drEmployee["UserInfoStart"] = _new.GetValue("InfoS"); }
+                                    drEmployee["UserInfo"] = _new.GetValue("Info");
+                                    drEmployee["WORK_RUN"] = _new.GetValue("RUN");
+                                    drEmployee["RUN_STEPID"] = _new.GetValue("STEPID");
+                                    drEmployee["CALL"] = _new.GetValue("CALL");
+                                    drEmployee.EndEdit();
+                                    drEmployee.AcceptChanges();
+                                }
 
                                 if (_new.GetValue("Status").ToString() != "----------")
                                 {
                                     Dictionary<string, object> Chart_new = new Dictionary<string, object>();//缓存函数                                               
-                                    Chart_new.Add("WorkOrder", _new.GetValue("WorkNumder"));
-                                    Chart_new.Add("Machine", _new.GetValue("Machine"));
-                                    Chart_new.Add("Time", _new.GetValue("Time"));
+                                    Chart_new.Add("WorkOrder", _new.GetValue("Work"));
+                                    //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"));
@@ -174,7 +200,10 @@ namespace SunlightCentralizedControlManagement_SCCM_.UserClass
                                     MainWindowViewModel.SQLiteChartAdress.InsertData("Chart", Chart_new);// 执行插入     
                                 }
                             }
-                            catch (Exception ex) { LogGing.LogGingDATA("[ERR='" + ex + "']=Exception"); MainWindowViewModel.ERR_c++; }
+                            catch (Exception ex)
+                            {
+                                LogGing.LogGingDATA("[ERR='" + ex + "']=Exception"); MainWindowViewModel.ERR_c++;
+                            }
                         }//当前信息
                         else if (SYSAPI == "SC831")
                         {
@@ -378,8 +407,6 @@ namespace SunlightCentralizedControlManagement_SCCM_.UserClass
                 string[] sArray = Regex.Split(e.ByteBlock.Span.ToString(Encoding.UTF8),
                     @"\n", RegexOptions.IgnoreCase);
 
-
-
                 return EasyTask.CompletedTask; ;
             };
             await portclient.SetupAsync(new TouchSocketConfig()
@@ -391,7 +418,7 @@ namespace SunlightCentralizedControlManagement_SCCM_.UserClass
                      PortName = com,//COM
                      StopBits = System.IO.Ports.StopBits.One,//停止位
                  })
-                 .SetSerialDataHandlingAdapter(() => new PeriodPackageAdapter() { CacheTimeout = TimeSpan.FromMilliseconds(100) })
+                 .SetSerialDataHandlingAdapter(() => new PeriodPackageAdapter() { CacheTimeout = TimeSpan.FromMilliseconds(500) })
                  .ConfigurePlugins(a =>
                  {
                      //a.Add<MyPlugin>();
@@ -416,13 +443,39 @@ namespace SunlightCentralizedControlManagement_SCCM_.UserClass
         {
             try
             {
-              var t=  CRCcheck16.ToCRC16(command);
+                var t = CRCcheck16.ToCRC16(command);
                 _responseEvent.Reset();
                 serialPortClients.Send(command); // 发送指令
-                                                 // 等待500毫秒或直到收到响应
-                _responseEvent.Wait(TimeSpan.FromMilliseconds(1000));
-                // 重置事件状态       
-                _responseEvent.Set();
+
+                // 等待500毫秒或直到收到响应
+                if (!_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<int>("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) { }
         }

UserClass/AsyncTcpClient.cs

@@ -6,6 +6,7 @@ using ScottPlot.Colormaps;
 using SkiaSharp;
 using SunlightCentralizedControlManagement_SCCM_.View;
 using SunlightCentralizedControlManagement_SCCM_.ViewModel;
+using SunlightCentralizedControlManagement_SCCM_.WindowsView;
 using System;
 using System.Collections;
 using System.Collections.Generic;
@@ -22,10 +23,11 @@ using System.Text;
 using System.Threading;
 using System.Threading.Tasks;
 using System.Windows;
+using System.Windows.Documents;
 using System.Xml.Linq;
 using TouchSocket.Core;
-using TouchSocket.Sockets;
 using TouchSocket.SerialPorts;
+using TouchSocket.Sockets;
 using static SunlightCentralizedControlManagement_SCCM_.UserClass.SqliteHelper;
 using static SunlightCentralizedControlManagement_SCCM_.View.MachinesView;
 using static System.Windows.Forms.AxHost;
@@ -47,12 +49,14 @@ namespace SunlightCentralizedControlManagement_SCCM_.UserClass
             {
                 try
                 {
-                    DataRow drEmployee = MainWindowViewModel.Machines.Select("IP='" + client.IP + "'").First();
-                    drEmployee.BeginEdit();
-                    drEmployee["State"] = "801";
-                    drEmployee.EndEdit();
-                    drEmployee.AcceptChanges();
-
+                    lock (MainWindowViewModel.Machines.Rows.SyncRoot)
+                    {
+                        DataRow drEmployee = MainWindowViewModel.Machines.Select("IP='" + client.IP + "'").First();
+                        drEmployee.BeginEdit();
+                        drEmployee["State"] = "801";
+                        drEmployee.EndEdit();
+                        drEmployee.AcceptChanges();
+                    }
                     LogGing.LogGingDATA("[IP='" + client.IP + "' AND port='" + client.Port + "']=Link_OK");
                 }
                 catch (Exception ex)
@@ -66,21 +70,24 @@ namespace SunlightCentralizedControlManagement_SCCM_.UserClass
             {
                 try
                 {
-                    DataRow drEmployee = MainWindowViewModel.Machines.Select("IP='" + client.IP + "'").First();
-                    drEmployee.BeginEdit();
-                    drEmployee["State"] = "800";
-                    drEmployee["WorkOrder"] = "------";
-                    drEmployee["Dyelot"] = "";
-                    drEmployee["Temperature"] = 0.0;
-                    drEmployee["WaterLevel"] = "----";
-                    drEmployee["Process"] = "";
-                    drEmployee["Step"] = "";
-                    drEmployee["Message"] = "";
-                    drEmployee["SYSKEY"] = "";
-                    drEmployee["WORK_RUN"] = "-1";
-                    drEmployee["ERR"] = false;
-                    drEmployee.EndEdit();
-                    drEmployee.AcceptChanges();
+                    lock (MainWindowViewModel.Machines.Rows.SyncRoot)
+                    {
+                        DataRow drEmployee = MainWindowViewModel.Machines.Select("IP='" + client.IP + "'").First();
+                        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();
+                    }
                     LogGing.LogGingDATA("[IP='" + client.IP + "' AND port='" + client.Port + "']=Link_STOP");
                 }
                 catch (Exception ex)
@@ -93,21 +100,24 @@ namespace SunlightCentralizedControlManagement_SCCM_.UserClass
             {
                 try
                 {
-                    DataRow drEmployee = MainWindowViewModel.Machines.Select("IP='" + client.IP + "'").First();
-                    drEmployee.BeginEdit();
-                    drEmployee["State"] = "800";
-                    drEmployee["WorkOrder"] = "------";
-                    drEmployee["Dyelot"] = "";
-                    drEmployee["Temperature"] = 0.0;
-                    drEmployee["WaterLevel"] = "----";
-                    drEmployee["Process"] = "";
-                    drEmployee["Step"] = "";
-                    drEmployee["Message"] = "";
-                    drEmployee["SYSKEY"] = "";
-                    drEmployee["WORK_RUN"] = "-1";
-                    drEmployee["ERR"] = false;
-                    drEmployee.EndEdit();
-                    drEmployee.AcceptChanges();
+                    lock (MainWindowViewModel.Machines.Rows.SyncRoot)
+                    {
+                        DataRow drEmployee = MainWindowViewModel.Machines.Select("IP='" + client.IP + "'").First();
+                        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();
+                    }
                     LogGing.LogGingDATA("[IP='" + client.IP + "' AND port='" + client.Port + "']=Link_INTERRUPT");
                 }
                 catch (Exception ex)
@@ -128,14 +138,17 @@ namespace SunlightCentralizedControlManagement_SCCM_.UserClass
                         DAT = DAT.Substring(DAT.IndexOf("]") + 1);
                         Dictionary<string, object> Chart_new = new Dictionary<string, object>();//缓存函数                  
                         Chart_new = JsonConvert.DeserializeObject<Dictionary<string, object>>(DAT);//反序列化
-                        DataRow drEmployee = MainWindowViewModel.Machines.Select("IP='" + client.IP + "'").First();
-                        drEmployee.BeginEdit();
-                        drEmployee["SYSKEY"] = Chart_new.GetValue("SYSKEY").ToString();
-                        //  drEmployee["NAME"] = Chart_new.GetValue("MACHINE").ToString();
-                        drEmployee["Groups"] = Chart_new.GetValue("GROUP").ToString();
-                        drEmployee["State"] = "802";
-                        drEmployee.EndEdit();
-                        drEmployee.AcceptChanges();
+                        lock (MainWindowViewModel.Machines.Rows.SyncRoot)
+                        {
+                            DataRow drEmployee = MainWindowViewModel.Machines.Select("IP='" + client.IP + "'").First();
+                            drEmployee.BeginEdit();
+                            drEmployee["SYSKEY"] = Chart_new.GetValue("SYSKEY").ToString();
+                            //  drEmployee["NAME"] = Chart_new.GetValue("MACHINE").ToString();
+                            drEmployee["Groups"] = Chart_new.GetValue("GROUP").ToString();
+                            drEmployee["State"] = "802";
+                            drEmployee.EndEdit();
+                            drEmployee.AcceptChanges();
+                        }
                     }
                     catch (Exception ex)
                     {
@@ -146,9 +159,14 @@ namespace SunlightCentralizedControlManagement_SCCM_.UserClass
                 {
                     try
                     {
-                        DAT = DAT.Substring(DAT.IndexOf("]") + 1);                                              
+                        DAT = DAT.Substring(DAT.IndexOf("]") + 1);
+
                         MainWindowViewModel.SQLiteHelpers.Update("WorkOrder", new Dictionary<string, object> { { "State", 111 } },
                             "WorkOrder ='" + DAT + "'", null);
+                   //     Dictionary<string, object> _dat;
+                //        _dat = SerializeConvert.JsonDeserializeFromString<Dictionary<string, object>>(DAT);
+                //        MainWindowViewModel.SQLiteHelpers.Update("WorkOrder", new Dictionary<string, object> { { "State", 111 } },
+                //            "WorkOrder ='" + _dat.GetValue("WorkOrder") + "' AND ReDye ='" + _dat.GetValue("ReDye") + "'", null);
                     }
                     catch (Exception ex)
                     {
@@ -160,8 +178,13 @@ namespace SunlightCentralizedControlManagement_SCCM_.UserClass
                     try
                     {
                         DAT = DAT.Substring(DAT.IndexOf("]") + 1);
-                        MainWindowViewModel.SQLiteHelpers.Update("WorkOrder", new Dictionary<string, object> { { "State", 113 } },
+
+                        MainWindowViewModel.SQLiteHelpers.Update("WorkOrder", new Dictionary<string, object> { { "State", 111 } },
                             "WorkOrder ='" + DAT + "'", null);
+               //         Dictionary<string, object> _dat;
+              //          _dat = SerializeConvert.JsonDeserializeFromString<Dictionary<string, object>>(DAT);
+             //           MainWindowViewModel.SQLiteHelpers.Update("WorkOrder", new Dictionary<string, object> { { "State", 113 } },
+             //               "WorkOrder ='" + _dat.GetValue("WorkOrder") + "' AND ReDye ='"+ _dat.GetValue("ReDye") + "'", null);
                     }
                     catch (Exception ex) { LogGing.LogGingDATA("[ERR='" + ex + "']=Exception"); MainWindowViewModel.ERR_c++; }
                 }
@@ -175,6 +198,33 @@ namespace SunlightCentralizedControlManagement_SCCM_.UserClass
                     }
                     catch (Exception ex) { LogGing.LogGingDATA("[ERR='" + ex + "']=Exception"); MainWindowViewModel.ERR_c++; }
                 }
+                else if (SYSAPI == "SC822")
+                {
+                    try
+                    {
+                        DAT = DAT.Substring(DAT.IndexOf("]") + 1);
+                        DataTable dataTable = JsonConvert.DeserializeObject<DataTable>(DAT).Copy();//反序列化
+                        Application.Current.Dispatcher.Invoke(() =>
+                        {
+                            UserWorkOrder userWorkOrder = new UserWorkOrder();
+                            userWorkOrder.WorkOrderTable = dataTable;
+                            userWorkOrder.Show();
+                        });
+                    }
+                    catch (Exception)
+                    {
+                        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 == "SC827")
                 {
                     try
@@ -184,38 +234,41 @@ namespace SunlightCentralizedControlManagement_SCCM_.UserClass
 
                         foreach (DataRow sourceRow in dataTable.Rows)
                         {
-                            // 创建新行（基于目标表结构）
-                            DataRow newRow = MainWindowViewModel.Dyelot_CALL.NewRow();
-                            // 复制源表中存在的列数据
-                            foreach (DataColumn column in dataTable.Columns)
+                            lock (MainWindowViewModel.Dyelot_CALL.Rows.SyncRoot)
                             {
-                                if (MainWindowViewModel.Dyelot_CALL.Columns.Contains(column.ColumnName))
+                                // 创建新行（基于目标表结构）
+                                DataRow newRow = MainWindowViewModel.Dyelot_CALL.NewRow();
+                                // 复制源表中存在的列数据
+                                foreach (DataColumn column in dataTable.Columns)
                                 {
-                                    newRow[column.ColumnName] = sourceRow[column.ColumnName];
+                                    if (MainWindowViewModel.Dyelot_CALL.Columns.Contains(column.ColumnName))
+                                    {
+                                        newRow[column.ColumnName] = sourceRow[column.ColumnName];
+                                    }
                                 }
+                                MainWindowViewModel.Dyelot_CALL.Rows.Add(newRow);
+
+                                Dictionary<string, object> Product_ = new Dictionary<string, object>();//缓存函数
+                                Product_.Add("State", 202);
+                                Product_.Add("Dyelot", newRow.Field<string>("Dyelot"));
+                                Product_.Add("Step", newRow.Field<int>("Step"));
+                                Product_.Add("ProductCode", newRow.Field<string>("ProductCode"));
+                                Product_.Add("Amount", newRow.Field<object>("Amount"));
+                                Product_.Add("DispenseEndTime", newRow.Field<object>("DispenseEndTime"));
+
+                                newRow.BeginEdit();
+                                newRow["State"] = 202;
+                                newRow.EndEdit();
+
+                                MainWindowViewModel.SQLiteHelpers.InsertData("DyelotHistory", MainWindowViewModel.SQLiteHelpers.ToDictionary(newRow));// 执行插入                                                       
+                                MainWindowViewModel.stringQueue.Enqueue(new MainWindowViewModel.QueueString
+                                {
+                                    ID = Convert.ToInt16(MainWindowViewModel.Selet_Machines(MainWindowViewModel.Machines,
+                                    "ID", "Name='" + newRow.Field<string>("Machine") + "'")),
+                                    DAT = "SC828" + MainWindowViewModel.Selet_Machines(MainWindowViewModel.Machines,
+                                    "SYSKEY", "Name='" + newRow.Field<string>("Machine") + "'") + Product_.ToJsonString()
+                                });
                             }
-                            MainWindowViewModel.Dyelot_CALL.Rows.Add(newRow);
-
-                            Dictionary<string, object> Product_ = new Dictionary<string, object>();//缓存函数
-                            Product_.Add("State", 202);
-                            Product_.Add("Dyelot", newRow.Field<string>("Dyelot"));
-                            Product_.Add("Step", newRow.Field<int>("Step"));
-                            Product_.Add("ProductCode", newRow.Field<string>("ProductCode"));
-                            Product_.Add("Amount", newRow.Field<object>("Amount"));
-                            Product_.Add("DispenseEndTime", newRow.Field<object>("DispenseEndTime"));
-
-                            newRow.BeginEdit();
-                            newRow["State"] = 202;
-                            newRow.EndEdit();
-
-                            MainWindowViewModel.SQLiteHelpers.InsertData("DyelotHistory", MainWindowViewModel.SQLiteHelpers.ToDictionary(newRow));// 执行插入                                                       
-                            MainWindowViewModel.stringQueue.Enqueue(new MainWindowViewModel.QueueString
-                            {
-                                ID = Convert.ToInt16(MainWindowViewModel.Selet_Machines(MainWindowViewModel.Machines,
-                                "ID", "Name='" + newRow.Field<string>("Machine") + "'")),
-                                DAT = "SC828" + MainWindowViewModel.Selet_Machines(MainWindowViewModel.Machines,
-                                "SYSKEY", "Name='" + newRow.Field<string>("Machine") + "'") + Product_.ToJsonString()
-                            });
                         }
                     }
                    catch (Exception ex) { LogGing.LogGingDATA("[ERR='" + ex + "']=Exception"); MainWindowViewModel.ERR_c++; }
@@ -227,31 +280,36 @@ namespace SunlightCentralizedControlManagement_SCCM_.UserClass
                         DAT = DAT.Substring(DAT.IndexOf("]") + 1);
                         Dictionary<string, object> _new = new Dictionary<string, object>();//缓存函数                  
                         _new = JsonConvert.DeserializeObject<Dictionary<string, object>>(DAT);//反序列化
-                        DataRow drEmployee = MainWindowViewModel.Machines.Select("IP='" + client.IP + "'").First();
-                        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();
-
+                        string mac;
+                        // 首先确保 DataTable 使用线程安全的访问方式
+                        lock (MainWindowViewModel.Machines.Rows.SyncRoot)
+                        {
+                            DataRow drEmployee = MainWindowViewModel.Machines.Select("IP='" + client.IP + "'").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<string, object> Chart_new = new Dictionary<string, object>();//缓存函数                                               
                             Chart_new.Add("WorkOrder", _new.GetValue("WorkNumder"));
-                            Chart_new.Add("Machine", drEmployee["Name"]);
+                            Chart_new.Add("Machine", mac);
                             Chart_new.Add("Time", DateTime.Now.ToString("yyyy/MM/dd  HH:mm:ss"));
                             Chart_new.Add("MST", _new.GetValue("MST"));
                             Chart_new.Add("MTT", _new.GetValue("MTT"));
@@ -279,7 +337,7 @@ namespace SunlightCentralizedControlManagement_SCCM_.UserClass
                         MainWindowViewModel.dt_TP = JsonConvert.DeserializeObject<DataTable>(DAT);//反序列化
                     }
                     catch (Exception ex) { LogGing.LogGingDATA("[ERR='" + ex + "']=Exception"); MainWindowViewModel.ERR_c++; }
-                }
+                }//步骤信息
                 else if (SYSAPI == "SC832")
                 {
                     try
@@ -351,7 +409,7 @@ namespace SunlightCentralizedControlManagement_SCCM_.UserClass
                         MachinesView.LOG_dataTable = JsonConvert.DeserializeObject<DataTable>(DAT);//反序列化
                     }
                     catch (Exception ex) { LogGing.LogGingDATA("[ERR='" + ex + "']=Exception"); MainWindowViewModel.ERR_c++; }
-                }
+                }//信息
                 else if (SYSAPI == "SC910")
                 {
                     try
@@ -372,6 +430,14 @@ namespace SunlightCentralizedControlManagement_SCCM_.UserClass
                     }
                     catch (Exception ex) { LogGing.LogGingDATA("[ERR='" + ex + "']=Exception"); MainWindowViewModel.ERR_c++; }
                 }//细节错误
+                else if (SYSAPI == "SC921")
+                {
+                    try
+                    {
+                        DAT = DAT.Substring(DAT.IndexOf("]") + 1);                        
+                    }
+                    catch (Exception ex) { LogGing.LogGingDATA("[ERR='" + ex + "']=Exception"); MainWindowViewModel.ERR_c++; }
+                }//错误
                 else if (SYSAPI == "SC980")
                 {
                     DAT = DAT.Substring(DAT.IndexOf("]") + 1);

UserClass/DataTableManager .cs

@@ -0,0 +1,360 @@
+using System;
+using System.Collections.Generic;
+using System.Data;
+using System.Linq;
+using System.Text;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace SunlightCentralizedControlManagement_SCCM_.UserClass
+{
+    /// <summary>
+    /// 线程安全的 DataTable 管理器
+    /// 提供对 DataTable 的安全并发访问
+    /// </summary>
+    public class DataTableManager : IDisposable
+    {
+        private DataTable _dataTable;
+        private readonly ReaderWriterLockSlim _lock = new ReaderWriterLockSlim();
+        private bool _disposed = false;
+
+        #region 构造函数
+        public DataTableManager()
+        {
+            _dataTable = new DataTable();
+        }
+
+        public DataTableManager(DataTable dataTable)
+        {
+            _dataTable = dataTable ?? throw new ArgumentNullException(nameof(dataTable));
+        }
+
+        public DataTableManager(string tableName)
+        {
+            _dataTable = new DataTable(tableName);
+        }
+        #endregion
+
+        #region 基本操作
+        /// <summary>
+        /// 安全地添加列
+        /// </summary>
+        public void AddColumn(string columnName, Type dataType)
+        {
+            ExecuteWriteOperation(table =>
+            {
+                table.Columns.Add(columnName, dataType);
+            });
+        }
+
+        /// <summary>
+        /// 安全地添加行
+        /// </summary>
+        public void AddRow(params object[] values)
+        {
+            ExecuteWriteOperation(table =>
+            {
+                DataRow newRow = table.NewRow();
+                for (int i = 0; i < Math.Min(values.Length, table.Columns.Count); i++)
+                {
+                    newRow[i] = values[i] ?? DBNull.Value;
+                }
+                table.Rows.Add(newRow);
+            });
+        }
+
+        /// <summary>
+        /// 安全地更新单元格值
+        /// </summary>
+        public bool UpdateCell(int rowIndex, string columnName, object value)
+        {
+            return ExecuteWriteOperation(table =>
+            {
+                if (IsValidRowIndex(table, rowIndex) && table.Columns.Contains(columnName))
+                {
+                    table.Rows[rowIndex][columnName] = value ?? DBNull.Value;
+                    return true;
+                }
+                return false;
+            });
+        }
+
+        /// <summary>
+        /// 安全地删除行
+        /// </summary>
+        public bool DeleteRow(int rowIndex)
+        {
+            return ExecuteWriteOperation(table =>
+            {
+                if (IsValidRowIndex(table, rowIndex))
+                {
+                    table.Rows[rowIndex].Delete();
+                    return true;
+                }
+                return false;
+            });
+        }
+        #endregion
+
+        #region 查询操作
+        /// <summary>
+        /// 安全地获取行
+        /// </summary>
+        public DataRow GetRow(int rowIndex)
+        {
+            return ExecuteReadOperation(table =>
+            {
+                return IsValidRowIndex(table, rowIndex) ? table.Rows[rowIndex] : null;
+            });
+        }
+
+        /// <summary>
+        /// 安全地查找行（使用筛选条件）
+        /// </summary>
+        public DataRow[] FindRows(string filterExpression)
+        {
+            return ExecuteReadOperation(table =>
+            {
+                try
+                {
+                    return string.IsNullOrEmpty(filterExpression)
+                        ? table.Select()
+                        : table.Select(filterExpression);
+                }
+                catch (EvaluateException)
+                {
+                    return new DataRow[0];
+                }
+            });
+        }
+
+        /// <summary>
+        /// 安全地获取行数
+        /// </summary>
+        public int GetRowCount()
+        {
+            return ExecuteReadOperation(table => table.Rows.Count);
+        }
+
+        /// <summary>
+        /// 安全地检查行是否存在
+        /// </summary>
+        public bool RowExists(int rowIndex)
+        {
+            return ExecuteReadOperation(table => IsValidRowIndex(table, rowIndex));
+        }
+        #endregion
+
+        #region 批量操作
+        /// <summary>
+        /// 安全地批量添加行
+        /// </summary>
+        public void BulkAddRows(IEnumerable<object[]> rowsData)
+        {
+            ExecuteWriteOperation(table =>
+            {
+                foreach (var rowData in rowsData)
+                {
+                    DataRow newRow = table.NewRow();
+                    for (int i = 0; i < Math.Min(rowData.Length, table.Columns.Count); i++)
+                    {
+                        newRow[i] = rowData[i] ?? DBNull.Value;
+                    }
+                    table.Rows.Add(newRow);
+                }
+            });
+        }
+
+        /// <summary>
+        /// 安全地清空所有数据
+        /// </summary>
+        public void Clear()
+        {
+            ExecuteWriteOperation(table =>
+            {
+                table.Clear();
+            });
+        }
+        #endregion
+
+        #region 数据导出
+        /// <summary>
+        /// 获取数据快照（线程安全的副本）
+        /// </summary>
+        public DataTable GetSnapshot()
+        {
+            return ExecuteReadOperation(table =>
+            {
+                return table.Copy(); // 创建数据的独立副本
+            });
+        }
+
+        /// <summary>
+        /// 获取只读视图
+        /// </summary>
+        public DataView GetReadOnlyView()
+        {
+            return ExecuteReadOperation(table =>
+            {
+                return new DataView(table) { AllowEdit = false };
+            });
+        }
+
+        /// <summary>
+        /// 导出到新 DataTable（包含结构）
+        /// </summary>
+        public DataTable ExportToDataTable()
+        {
+            return ExecuteReadOperation(table =>
+            {
+                DataTable exported = table.Clone();
+                exported.Merge(table, false, MissingSchemaAction.Add);
+                return exported;
+            });
+        }
+        #endregion
+
+        #region 锁操作核心
+        /// <summary>
+        /// 执行读取操作（共享锁）
+        /// </summary>
+        private T ExecuteReadOperation<T>(Func<DataTable, T> operation)
+        {
+            _lock.EnterReadLock();
+            try
+            {
+                return operation(_dataTable);
+            }
+            finally
+            {
+                _lock.ExitReadLock();
+            }
+        }
+
+        /// <summary>
+        /// 执行写入操作（独占锁）
+        /// </summary>
+        private void ExecuteWriteOperation(Action<DataTable> operation)
+        {
+            _lock.EnterWriteLock();
+            try
+            {
+                operation(_dataTable);
+                _dataTable.AcceptChanges();
+            }
+            finally
+            {
+                _lock.ExitWriteLock();
+            }
+        }
+
+        private T ExecuteWriteOperation<T>(Func<DataTable, T> operation)
+        {
+            _lock.EnterWriteLock();
+            try
+            {
+                var result = operation(_dataTable);
+                _dataTable.AcceptChanges();
+                return result;
+            }
+            finally
+            {
+                _lock.ExitWriteLock();
+            }
+        }
+
+        private bool IsValidRowIndex(DataTable table, int rowIndex)
+        {
+            return rowIndex >= 0 && rowIndex < table.Rows.Count;
+        }
+        #endregion
+
+        #region 高级功能
+        /// <summary>
+        /// 带超时的安全操作
+        /// </summary>
+        public bool TryUpdateCell(int rowIndex, string columnName, object value, int timeoutMs = 5000)
+        {
+            if (_lock.TryEnterWriteLock(timeoutMs))
+            {
+                try
+                {
+                    if (IsValidRowIndex(_dataTable, rowIndex) && _dataTable.Columns.Contains(columnName))
+                    {
+                        _dataTable.Rows[rowIndex][columnName] = value ?? DBNull.Value;
+                        _dataTable.AcceptChanges();
+                        return true;
+                    }
+                    return false;
+                }
+                finally
+                {
+                    _lock.ExitWriteLock();
+                }
+            }
+            return false;
+        }
+
+        /// <summary>
+        /// 执行事务性操作
+        /// </summary>
+        public void ExecuteTransaction(Action<DataTable> transaction)
+        {
+            _lock.EnterWriteLock();
+            try
+            {
+                // 开始事务
+                _dataTable.BeginLoadData();
+
+                try
+                {
+                    transaction(_dataTable);
+                    _dataTable.AcceptChanges();
+                }
+                catch
+                {
+                    _dataTable.RejectChanges();
+                    throw;
+                }
+                finally
+                {
+                    _dataTable.EndLoadData();
+                }
+            }
+            finally
+            {
+                _lock.ExitWriteLock();
+            }
+        }
+        #endregion
+
+        #region 属性和清理
+        public string TableName
+        {
+            get => ExecuteReadOperation(table => table.TableName);
+            set => ExecuteWriteOperation(table => table.TableName = value);
+        }
+
+        public DataColumnCollection Columns
+        {
+            get => ExecuteReadOperation(table => table.Columns);
+        }
+
+        public void Dispose()
+        {
+            if (!_disposed)
+            {
+                _lock?.Dispose();
+                _dataTable?.Dispose();
+                _disposed = true;
+            }
+            GC.SuppressFinalize(this);
+        }
+
+        ~DataTableManager()
+        {
+            Dispose();
+        }
+        #endregion
+    }
+}

View/MachinesSet.xaml.cs

@@ -75,96 +75,103 @@ namespace SunlightCentralizedControlManagement_SCCM_.View
             if (!string.IsNullOrEmpty(comboBoxMachine.Text))
             {
                 Dictionary<string, object> Machines_DAT = new Dictionary<string, object>();//缓存函数
-                  if (MainWindowViewModel.SQLiteHelpers.ExecuteDataSet("select * from Machines where name ='" + comboBoxMachine.Text + "'", null).Tables[0].Rows.Count == 0)
-                {                  
-                    DataRow dat_=  MainWindowViewModel.Machines.NewRow();
-                    dat_.BeginEdit();
-                    dat_["Name"] = comboBoxMachine.Text;
-                    dat_["Groups"] = TextMachineGroup.Text;
-                    dat_["IP"] = IP.Text;
-                    dat_["PORT"] = PORT.Text;
-                    dat_["Serial"] = comboBoxCOM0.Text;
-                    dat_["Type"] = comboBoxtype.Text;
-                    dat_["Model"] = comboBoxtype.Text;
-                    dat_["Station"] = Station.Text; 
-                    dat_["ID"] = 999;
-                    dat_["ERR"] = false;
-                    dat_["AUTO"] = false;
-                    dat_["CALL"] = false;
-                    dat_["LOCK"] = false;
-                    dat_["State"] = 800;
-                    dat_["Temperature"] = 0;
-                    dat_["WaterLevel"] = 0;
-                    dat_["WORK_RUN"] = -1;
-                    dat_["UserInfoStart"] = 900;
-                    if (comboBoxtype.Text.Contains( link_model))
+                if (MainWindowViewModel.SQLiteHelpers.ExecuteDataSet("select * from Machines where name ='" + comboBoxMachine.Text + "'", null).Tables[0].Rows.Count == 0)
+                {
+                    lock (MainWindowViewModel.Machines.Rows.SyncRoot)
                     {
-                        dat_["Desktop"] = true;
-                        dat_["Type"] = true;
-                    }
-                    else
-                    {
-                        dat_["Desktop"] = false;
-                        dat_["Type"] = false;
-                    }                        
-                    dat_.EndEdit();
-                    MainWindowViewModel.Machines.Rows.Add(dat_);
-                    DatSteps(MainWindowViewModel.Machines);
-                    MainWindowViewModel.SQLiteHelpers.Delete("Machines", null, null);// 
-                    for (int x = 0; x < MainWindowViewModel.Machines.Rows.Count; x++)
-                    {
-                        Machines_DAT.Add("ID", MainWindowViewModel.Machines.Rows[x]["ID"]);
-                        Machines_DAT.Add("Name", MainWindowViewModel.Machines.Rows[x]["Name"]);
-                        Machines_DAT.Add("IP", MainWindowViewModel.Machines.Rows[x]["IP"]);
-                        Machines_DAT.Add("PORT", MainWindowViewModel.Machines.Rows[x]["PORT"]);
-                        Machines_DAT.Add("Serial", MainWindowViewModel.Machines.Rows[x]["Serial"]);
-                        Machines_DAT.Add("Station", MainWindowViewModel.Machines.Rows[x]["Station"]);
-                        Machines_DAT.Add("Groups", MainWindowViewModel.Machines.Rows[x]["Groups"]);
-                        Machines_DAT.Add("Desktop", MainWindowViewModel.Machines.Rows[x]["Desktop"]);
-                        Machines_DAT.Add("Dispense", MainWindowViewModel.Machines.Rows[x]["Dispense"]);
-                        Machines_DAT.Add("Type", MainWindowViewModel.Machines.Rows[x]["Type"]);
-                        Machines_DAT.Add("Model", MainWindowViewModel.Machines.Rows[x]["Model"]);
-                        MainWindowViewModel.SQLiteHelpers.InsertData("Machines", Machines_DAT);//行插入                                                                             
-                        Machines_DAT.Clear();
+                        DataRow dat_ = MainWindowViewModel.Machines.NewRow();
+                        dat_.BeginEdit();
+                        dat_["Name"] = comboBoxMachine.Text;
+                        dat_["Groups"] = TextMachineGroup.Text;
+                        dat_["IP"] = IP.Text;
+                        dat_["PORT"] = PORT.Text;
+                        dat_["Serial"] = comboBoxCOM0.Text;
+                        dat_["Model"] = comboBoxtype.Text;
+                        dat_["Station"] = Station.Text;
+                        dat_["ID"] = 999;
+                        dat_["ERR"] = false;
+                        dat_["AUTO"] = false;
+                        dat_["CALL"] = false;
+                        dat_["LOCK"] = false;
+                        dat_["State"] = 800;
+                        dat_["Temperature"] = 0;
+                        dat_["WaterLevel"] = 0;
+                        dat_["WORK_RUN"] = -1;
+                        dat_["UserInfoStart"] = 900;
+                        if (comboBoxtype.Text.Contains(link_model))
+                        {
+                            dat_["Desktop"] = true;
+                            dat_["Type"] = true;
+                        }
+                        else
+                        {
+                            dat_["Desktop"] = false;
+                            dat_["Type"] = false;
+                        }
+                        dat_.EndEdit();
+                        MainWindowViewModel.Machines.Rows.Add(dat_);
+                        DatSteps(MainWindowViewModel.Machines);
+                        MainWindowViewModel.SQLiteHelpers.Delete("Machines", null, null);// 
+                        for (int x = 0; x < MainWindowViewModel.Machines.Rows.Count; x++)
+                        {
+                            Machines_DAT.Add("ID", MainWindowViewModel.Machines.Rows[x]["ID"]);
+                            Machines_DAT.Add("Name", MainWindowViewModel.Machines.Rows[x]["Name"]);
+                            Machines_DAT.Add("IP", MainWindowViewModel.Machines.Rows[x]["IP"]);
+                            Machines_DAT.Add("PORT", MainWindowViewModel.Machines.Rows[x]["PORT"]);
+                            Machines_DAT.Add("Serial", MainWindowViewModel.Machines.Rows[x]["Serial"]);
+                            Machines_DAT.Add("Station", MainWindowViewModel.Machines.Rows[x]["Station"]);
+                            Machines_DAT.Add("Groups", MainWindowViewModel.Machines.Rows[x]["Groups"]);
+                            Machines_DAT.Add("Desktop", MainWindowViewModel.Machines.Rows[x]["Desktop"]);
+                            Machines_DAT.Add("Dispense", MainWindowViewModel.Machines.Rows[x]["Dispense"]);
+                            Machines_DAT.Add("Type", MainWindowViewModel.Machines.Rows[x]["Type"]);
+                            Machines_DAT.Add("Model", MainWindowViewModel.Machines.Rows[x]["Model"]);
+                            MainWindowViewModel.SQLiteHelpers.InsertData("Machines", Machines_DAT);//行插入                                                                             
+                            Machines_DAT.Clear();
+                        }
                     }
                 }
                 else
                 {
-                    DataRow dr = MainWindowViewModel.Machines.Rows[ID_];
-                    dr.BeginEdit();
-                    dr["Name"] = comboBoxMachine.Text;
-                    dr["Groups"] = TextMachineGroup.Text;
-                    dr["IP"] = IP.Text;
-                    dr["PORT"] = PORT.Text;
-                    dr["Serial"] = comboBoxCOM0.Text;
-                    dr["Model"] = comboBoxtype.Text;
-                    dr["Station"] = Station.Text;
-                    if (comboBoxtype.Text.Contains(link_model))
-                    { dr["Desktop"] = true; 
-                        dr["Type"] = true; }
-                    else
+                    lock (MainWindowViewModel.Machines.Rows.SyncRoot)
                     {
-                        dr["Desktop"] = false; 
-                        dr["Type"] = false;
-                    }
-                    dr.EndEdit();
-                    MainWindowViewModel.SQLiteHelpers.Delete("Machines", null, null);// 
-                    for (int x = 0; x < MainWindowViewModel.Machines.Rows.Count; x++)
-                    {
-                        Machines_DAT.Add("ID", MainWindowViewModel.Machines.Rows[x]["ID"]);
-                        Machines_DAT.Add("Name", MainWindowViewModel.Machines.Rows[x]["Name"]);
-                        Machines_DAT.Add("IP", MainWindowViewModel.Machines.Rows[x]["IP"]);
-                        Machines_DAT.Add("PORT", MainWindowViewModel.Machines.Rows[x]["PORT"]);
-                        Machines_DAT.Add("Serial", MainWindowViewModel.Machines.Rows[x]["Serial"]);
-                        Machines_DAT.Add("Station", MainWindowViewModel.Machines.Rows[x]["Station"]);
-                        Machines_DAT.Add("Groups", MainWindowViewModel.Machines.Rows[x]["Groups"]);
-                        Machines_DAT.Add("Desktop", MainWindowViewModel.Machines.Rows[x]["Desktop"]);
-                        Machines_DAT.Add("Dispense", MainWindowViewModel.Machines.Rows[x]["Dispense"]);
-                        Machines_DAT.Add("Type", MainWindowViewModel.Machines.Rows[x]["Type"]);
-                        Machines_DAT.Add("Model", MainWindowViewModel.Machines.Rows[x]["Model"]);
-                        Machines_DAT.Add("LOCK", "FALSE");
-                        MainWindowViewModel.SQLiteHelpers.InsertData("Machines", Machines_DAT);//行插入                                                                             
-                        Machines_DAT.Clear();
+                        DataRow dr = MainWindowViewModel.Machines.Rows[ID_];
+                        dr.BeginEdit();
+                        dr["Name"] = comboBoxMachine.Text;
+                        dr["Groups"] = TextMachineGroup.Text;
+                        dr["IP"] = IP.Text;
+                        dr["PORT"] = PORT.Text;
+                        dr["Serial"] = comboBoxCOM0.Text;
+                        dr["Model"] = comboBoxtype.Text;
+                        dr["Station"] = Station.Text;
+                        if (comboBoxtype.Text.Contains(link_model))
+                        {
+                            dr["Desktop"] = true;
+                            dr["Type"] = true;
+                        }
+                        else
+                        {
+                            dr["Desktop"] = false;
+                            dr["Type"] = false;
+                        }
+                        dr.EndEdit();
+                        MainWindowViewModel.SQLiteHelpers.Delete("Machines", null, null);// 
+                        for (int x = 0; x < MainWindowViewModel.Machines.Rows.Count; x++)
+                        {
+                            Machines_DAT.Add("ID", MainWindowViewModel.Machines.Rows[x]["ID"]);
+                            Machines_DAT.Add("Name", MainWindowViewModel.Machines.Rows[x]["Name"]);
+                            Machines_DAT.Add("IP", MainWindowViewModel.Machines.Rows[x]["IP"]);
+                            Machines_DAT.Add("PORT", MainWindowViewModel.Machines.Rows[x]["PORT"]);
+                            Machines_DAT.Add("Serial", MainWindowViewModel.Machines.Rows[x]["Serial"]);
+                            Machines_DAT.Add("Station", MainWindowViewModel.Machines.Rows[x]["Station"]);
+                            Machines_DAT.Add("Groups", MainWindowViewModel.Machines.Rows[x]["Groups"]);
+                            Machines_DAT.Add("Desktop", MainWindowViewModel.Machines.Rows[x]["Desktop"]);
+                            Machines_DAT.Add("Dispense", MainWindowViewModel.Machines.Rows[x]["Dispense"]);
+                            Machines_DAT.Add("Type", MainWindowViewModel.Machines.Rows[x]["Type"]);
+                            Machines_DAT.Add("Model", MainWindowViewModel.Machines.Rows[x]["Model"]);
+                            Machines_DAT.Add("LOCK", "FALSE");
+                            MainWindowViewModel.SQLiteHelpers.InsertData("Machines", Machines_DAT);//行插入                                                                             
+                            Machines_DAT.Clear();
+                        }
                     }
                 }
                 Griddata.ItemsSource = MainWindowViewModel.Machines.DefaultView;
@@ -188,9 +195,11 @@ namespace SunlightCentralizedControlManagement_SCCM_.View
                 MessageBoxResult vr = System.Windows.MessageBox.Show(Properties.Resources.Delete + comboBoxMachine.Text, "SCCM", MessageBoxButton.OKCancel, MessageBoxImage.Question);
                 if (vr == MessageBoxResult.OK) // 如果是确定，就执行下面代码
                 {
-                    MainWindowViewModel.Machines.Rows.RemoveAt(ID_ - 1);
-                    DatSteps(MainWindowViewModel.Machines);
-                                        
+                    lock (MainWindowViewModel.Machines.Rows.SyncRoot)
+                    {
+                        MainWindowViewModel.Machines.Rows.RemoveAt(ID_ - 1);
+                        DatSteps(MainWindowViewModel.Machines);
+                    }                 
                     Dictionary<string, object> Machines_DAT = new Dictionary<string, object>();//缓存函数
 
                     MainWindowViewModel.SQLiteHelpers.Delete("Machines", null, null);// 

View/MonitorView.xaml

@@ -20,6 +20,8 @@
         <ContextMenu x:Key="PersoncontextMenu">
             <MenuItem Header="{x:Static lang:Resources._lock}" Click="MenuItem_LOCK_XML"/>
             <MenuItem Header="{x:Static lang:Resources._Auto}" Click="MenuItem_AUTO_XML"/>
+            <MenuItem Header="{x:Static lang:Resources.Stop}" Click="MenuItem_Stop_XML"/>
+            <MenuItem Header="{x:Static lang:Resources.Start}" Click="MenuItem_Start_XML"/>
         </ContextMenu>
         <ContextMenu x:Key="PersoncontextMenuStep">
             <MenuItem Header="{x:Static lang:Resources.edit}" Click="MenuItem_edit"/>

View/MonitorView.xaml.cs

@@ -1,5 +1,5 @@
 using LiveChartsCore.Geo;
- using SkiaSharp;
+using SkiaSharp;
 using SunlightCentralizedControlManagement_SCCM_.UserClass;
 using SunlightCentralizedControlManagement_SCCM_.ViewModel;
 using SunlightCentralizedControlManagement_SCCM_.WindowsView;
@@ -28,6 +28,8 @@ using System.Xml.Linq;
 using TouchSocket.Core;
 using TouchSocket.Sockets;
 using VncSharpWpf;
+using static SunlightCentralizedControlManagement_SCCM_.UserClass.SqliteHelper;
+using static SunlightCentralizedControlManagement_SCCM_.ViewModel.MainWindowViewModel;
 using static SunlightCentralizedControlManagement_SCCM_.WindowsView.ViewStep;
 using static System.Net.WebRequestMethods;
 using static System.Windows.Forms.VisualStyles.VisualStyleElement.Rebar;
@@ -120,7 +122,7 @@ namespace SunlightCentralizedControlManagement_SCCM_.View
             }
             else
             {
-                MessageBox.Show(Properties.Resources.TMNR, "800", MessageBoxButton.OK, MessageBoxImage.Information); //
+            //    MessageBox.Show(Properties.Resources.TMNR, "800", MessageBoxButton.OK, MessageBoxImage.Information); //
             }
         }
 
@@ -140,6 +142,267 @@ namespace SunlightCentralizedControlManagement_SCCM_.View
             }
         }
 
+        private void MenuItem_LOCK_XML(object sender, RoutedEventArgs e)
+        {
+            if (!string.IsNullOrEmpty(machine))
+            {
+                lock (MainWindowViewModel.Machines.Rows.SyncRoot)
+                {
+                    bool mode = MainWindowViewModel.Machines.Select("NAME='" + machine + "'").First().Field<bool>("LOCK");
+
+                    Dictionary<string, object> dat_ = new Dictionary<string, object>();
+                    dat_.Clear();
+
+                    if (!mode)
+                    {
+                        dat_.Add("NAME", "LOCK");
+                        dat_.Add("VALUE", "True");
+                        MainWindowViewModel.Updata_Machines(MainWindowViewModel.Machines, "LOCK", "Name='" + machine + "'", "True");
+                    }
+                    else
+                    {
+                        dat_.Add("NAME", "LOCK");
+                        dat_.Add("VALUE", "False");
+                        MainWindowViewModel.Updata_Machines(MainWindowViewModel.Machines, "LOCK", "Name='" + machine + "'", "False");
+                    }
+
+                    DataRow drEmployee = MainWindowViewModel.Machines.Select("NAME='" + machine + "'").First();
+                    int index = Convert.ToInt16(drEmployee.Field<object>("ID"));
+
+                    if (drEmployee.Field<bool>("Type"))
+                    {//网络
+                        MainWindowViewModel.stringQueue.Enqueue(new MainWindowViewModel.QueueString
+                        {
+                            ID = index,
+                            DAT = "SC829" + drEmployee.Field<string>("SYSKEY") + dat_.ToJsonString()
+                        });
+                    }
+                    else
+                    {//串口
+                        if (drEmployee.Field<string>("Serial") == "PORT1")
+                        {
+                            stringQueueSerial_1.Enqueue(new QueueSerial
+                            {
+                                ID = index,
+                                DAT = "SC829" + MainWindowViewModel.Selet_Machines(MainWindowViewModel.Machines, "SYSKEY", "ID='" + index + "'") + dat_.ToJsonString()
+                            });
+                        }
+                        else if (drEmployee.Field<string>("Serial") == "PORT2")
+                        {
+                            stringQueueSerial_2.Enqueue(new QueueSerial
+                            {
+                                ID = index,
+                                DAT = "SC829" + drEmployee.Field<string>("Station") + dat_.ToJsonString()
+                            });
+                        }
+                        else if (drEmployee.Field<string>("Serial") == "PORT3")
+                        {
+                            stringQueueSerial_3.Enqueue(new QueueSerial
+                            {
+                                ID = index,
+                                DAT = "SC829" + drEmployee.Field<string>("Station") + dat_.ToJsonString()
+                            });
+                        }
+                        else if (drEmployee.Field<string>("Serial") == "PORT4")
+                        {
+                            stringQueueSerial_4.Enqueue(new QueueSerial
+                            {
+                                ID = index,
+                                DAT = "SC829" + drEmployee.Field<string>("Station") + dat_.ToJsonString()
+                            });
+                        }
+                    }
+                    if (!mode)
+                    {
+                        MessageBox.Show(machine + Properties.Resources.user_lock, "800", MessageBoxButton.OK, MessageBoxImage.Information);
+                    }
+                    else
+                    {
+                        MessageBox.Show(machine + Properties.Resources.user_unlock, "800", MessageBoxButton.OK, MessageBoxImage.Information);
+                    }
+                }
+            }
+        }//锁定
+        private void MenuItem_AUTO_XML(object sender, RoutedEventArgs e)
+        {
+            if (!string.IsNullOrEmpty(machine))
+            {
+                lock (MainWindowViewModel.Machines.Rows.SyncRoot)
+                {
+                    bool mode = MainWindowViewModel.Machines.Select("NAME='" + machine + "'").First().Field<bool>("AUTO");
+
+                    Dictionary<string, object> dat_ = new Dictionary<string, object>();
+                    dat_.Clear();
+
+                    if (!mode)
+                    {
+                        dat_.Add("NAME", "AUTO");
+                        dat_.Add("VALUE", "True");
+                        MainWindowViewModel.Updata_Machines(MainWindowViewModel.Machines, "AUTO", "Name='" + machine + "'", "True");
+                    }
+                    else
+                    {
+                        dat_.Add("NAME", "AUTO");
+                        dat_.Add("VALUE", "FALSE");
+                        MainWindowViewModel.Updata_Machines(MainWindowViewModel.Machines, "AUTO", "Name='" + machine + "'", "False");
+                    }
+
+                    DataRow drEmployee = MainWindowViewModel.Machines.Select("NAME='" + machine + "'").First();
+                    int index = Convert.ToInt16(drEmployee.Field<object>("ID"));
+                    if (drEmployee.Field<bool>("Type"))
+                    {//网络
+                        MainWindowViewModel.stringQueue.Enqueue(new MainWindowViewModel.QueueString
+                        {
+                            ID = index,
+                            DAT = "SC829" + drEmployee.Field<string>("SYSKEY") + dat_.ToJsonString()
+                        });
+                    }
+                    else
+                    {//串口
+                        if (drEmployee.Field<string>("Serial") == "PORT1")
+                        {
+                            stringQueueSerial_1.Enqueue(new QueueSerial
+                            {
+                                ID = index,
+                                DAT = "SC829" + drEmployee.Field<string>("Station") + dat_.ToJsonString()
+                            });
+                        }
+                        else if (drEmployee.Field<string>("Serial") == "PORT2")
+                        {
+                            stringQueueSerial_2.Enqueue(new QueueSerial
+                            {
+                                ID = index,
+                                DAT = "SC829" + drEmployee.Field<string>("Station") + dat_.ToJsonString()
+                            });
+                        }
+                        else if (drEmployee.Field<string>("Serial") == "PORT3")
+                        {
+                            stringQueueSerial_3.Enqueue(new QueueSerial
+                            {
+                                ID = index,
+                                DAT = "SC829" + drEmployee.Field<string>("Station") + dat_.ToJsonString()
+                            });
+                        }
+                        else if (drEmployee.Field<string>("Serial") == "PORT4")
+                        {
+                            stringQueueSerial_4.Enqueue(new QueueSerial
+                            {
+                                ID = index,
+                                DAT = "SC829" + drEmployee.Field<string>("Station") + dat_.ToJsonString()
+                            });
+                        }
+                    }
+                }
+            }
+        }//手自动
+        private void MenuItem_Stop_XML(object sender, RoutedEventArgs e)
+        {
+            if (!string.IsNullOrEmpty(machine))
+            {
+                Dictionary<string, object> dat_821 = new Dictionary<string, object>();
+                dat_821.Clear();
+                dat_821.Add("INSTRUCTION", "STOP");
+                lock (MainWindowViewModel.Machines.Rows.SyncRoot)
+                {
+                    DataRow drEmployee = MainWindowViewModel.Machines.Select("NAME='" + machine + "'").First();
+                    int index = Convert.ToInt16(drEmployee.Field<object>("ID"));
+                    if (drEmployee.Field<bool>("Type"))
+                    {//网络
+                        MainWindowViewModel.stringQueue.Enqueue(new MainWindowViewModel.QueueString
+                        {
+                            ID = index,
+                            DAT = "SC821" + drEmployee.Field<string>("SYSKEY") + dat_821.ToJsonString()
+                        });
+                    }
+                    else
+                    {//串口
+                        if (drEmployee.Field<string>("Serial") == "PORT1")
+                        {
+                            stringQueueSerial_1.Enqueue(new QueueSerial
+                            {
+                                ID = index,
+                                DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                            });
+                        }
+                        else if (drEmployee.Field<string>("Serial") == "PORT2")
+                        {
+                            stringQueueSerial_2.Enqueue(new QueueSerial
+                            {
+                                ID = index,
+                                DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                            });
+                        }
+                        else if (drEmployee.Field<string>("Serial") == "PORT3")
+                        {
+                            stringQueueSerial_3.Enqueue(new QueueSerial
+                            {
+                                ID = index,
+                                DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                            });
+                        }
+                        else if (drEmployee.Field<string>("Serial") == "PORT4")
+                        {
+                            stringQueueSerial_4.Enqueue(new QueueSerial
+                            {
+                                ID = index,
+                                DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                            });
+                        }
+                    }
+                }
+            }
+        }//停止
+        private void MenuItem_Start_XML(object sender, RoutedEventArgs e)
+        {
+            if (!string.IsNullOrEmpty(machine))
+            {
+                DataRow drEmployee = MainWindowViewModel.Machines.Select("NAME='" + machine + "'").First();
+                int index = Convert.ToInt16(drEmployee.Field<object>("ID"));
+                if (drEmployee.Field<bool>("Type"))
+                {//网络
+                    MainWindowViewModel.stringQueue.Enqueue(new MainWindowViewModel.QueueString
+                    {
+                        ID = index,
+                        DAT = "SC822" + drEmployee.Field<string>("SYSKEY")
+                    });
+                }
+                else
+                {//串口
+                    if (drEmployee.Field<string>("Serial") == "PORT1")
+                    {
+                        stringQueueSerial_1.Enqueue(new QueueSerial
+                        {
+                            ID = index,
+                            DAT = "SC822" + drEmployee.Field<string>("Station") 
+                        });
+                    }
+                    else if (drEmployee.Field<string>("Serial") == "PORT2")
+                    {
+                        stringQueueSerial_2.Enqueue(new QueueSerial
+                        {
+                            ID = index,
+                            DAT = "SC822" + drEmployee.Field<string>("Station")
+                        });
+                    }
+                    else if (drEmployee.Field<string>("Serial") == "PORT3")
+                    {
+                        stringQueueSerial_3.Enqueue(new QueueSerial
+                        {
+                            ID = index,
+                            DAT = "SC822" + drEmployee.Field<string>("Station")
+                        });
+                    }
+                    else if (drEmployee.Field<string>("Serial") == "PORT4")
+                    {
+                        stringQueueSerial_4.Enqueue(new QueueSerial
+                        {
+                            ID = index,
+                            DAT = "SC822" + drEmployee.Field<string>("Station")
+                        });
+                    }
+                }
+            }
+        }//开始
         private void ListViewItem_DyeingMachine(object sender, MouseButtonEventArgs e)
         {
             if (rdp.IsConnected)rdp.Disconnect();                
@@ -211,12 +474,49 @@ namespace SunlightCentralizedControlManagement_SCCM_.View
             }
 
             int index = Convert.ToInt16(drEmployee.Field<object>("ID"));
-            MainWindowViewModel.stringQueue.Enqueue(new MainWindowViewModel.QueueString
-            {
-                ID = index,
-                DAT = "SC833" + MainWindowViewModel.Selet_Machines(MainWindowViewModel.Machines, "SYSKEY", "ID='" + index + "'")
-            });
-
+            if (drEmployee.Field<bool>("Type"))
+            {//网络
+                MainWindowViewModel.stringQueue.Enqueue(new MainWindowViewModel.QueueString
+                {
+                    ID = index,
+                    DAT = "SC833" + drEmployee.Field<string>("SYSKEY")
+                });
+            }
+            else
+            {//串口
+                if (drEmployee.Field<string>("Serial") == "PORT1")
+                {
+                    stringQueueSerial_1.Enqueue(new QueueSerial
+                    {
+                        ID = index,
+                        DAT = "SC833" + drEmployee.Field<string>("Station")
+                    });
+                }
+                else if (drEmployee.Field<string>("Serial") == "PORT2")
+                {
+                    stringQueueSerial_2.Enqueue(new QueueSerial
+                    {
+                        ID = index,
+                        DAT = "SC833" + drEmployee.Field<string>("Station")
+                    });
+                }
+                else if (drEmployee.Field<string>("Serial") == "PORT3")
+                {
+                    stringQueueSerial_3.Enqueue(new QueueSerial
+                    {
+                        ID = index,
+                        DAT = "SC833" + drEmployee.Field<string>("Station")
+                    });
+                }
+                else if (drEmployee.Field<string>("Serial") == "PORT4")
+                {
+                    stringQueueSerial_4.Enqueue(new QueueSerial
+                    {
+                        ID = index,
+                        DAT = "SC833" + drEmployee.Field<string>("Station")
+                    });
+                }
+            }
             machines_info = 2;
             log.Visibility = Visibility.Collapsed;
             rdp.Visibility = Visibility.Collapsed;
@@ -225,68 +525,6 @@ namespace SunlightCentralizedControlManagement_SCCM_.View
             dyelotView.DyelotDatatable(Product_DAT);
             Picture.Content = dyelotView;
         }//单据
-        private void MenuItem_LOCK_XML(object sender, RoutedEventArgs e)
-        {
-            bool mode = MainWindowViewModel.Machines.Select("NAME='" + machine + "'").First().Field<bool>("LOCK");
-
-            Dictionary<string, object> dat_ = new Dictionary<string, object>();
-            dat_.Clear();
-
-            if (!mode)
-            {
-                dat_.Add("NAME", "LOCK");
-                dat_.Add("VALUE", "True");
-                MainWindowViewModel.Updata_Machines(MainWindowViewModel.Machines, "LOCK", "Name='" + machine + "'", "True");                    
-            }
-            else
-            {
-                dat_.Add("NAME", "LOCK");
-                dat_.Add("VALUE", "False");
-                MainWindowViewModel.Updata_Machines(MainWindowViewModel.Machines, "LOCK", "Name='" + machine + "'", "False");
-            }
-
-            DataRow drEmployee = MainWindowViewModel.Machines.Select("NAME='" + machine + "'").First();
-            int index = Convert.ToInt16(drEmployee.Field<object>("ID"));
-            MainWindowViewModel.stringQueue.Enqueue(new MainWindowViewModel.QueueString
-            {
-                ID = index,
-                DAT = "SC829" + MainWindowViewModel.Selet_Machines(MainWindowViewModel.Machines, "SYSKEY", "ID='" + index + "'") + dat_.ToJsonString()
-            });
-
-            if (!mode) { MessageBox.Show(machine + Properties.Resources.user_lock, "800", MessageBoxButton.OK, MessageBoxImage.Information);
-            } else {
-                MessageBox.Show(machine + Properties.Resources.user_unlock, "800", MessageBoxButton.OK, MessageBoxImage.Information);
-            }
-        }//锁定
-        private void MenuItem_AUTO_XML(object sender, RoutedEventArgs e)
-        {
-            bool mode = MainWindowViewModel.Machines.Select("NAME='" + machine + "'").First().Field<bool>("AUTO");
-
-            Dictionary<string, object> dat_ = new Dictionary<string, object>();
-            dat_.Clear();
-
-            if (!mode)
-            {
-                dat_.Add("NAME", "AUTO");
-                dat_.Add("VALUE", "True");
-                MainWindowViewModel.Updata_Machines(MainWindowViewModel.Machines, "AUTO", "Name='" + machine + "'", "True");
-            }
-            else
-            {
-                dat_.Add("NAME", "AUTO");
-                dat_.Add("VALUE", "FALSE");
-                MainWindowViewModel.Updata_Machines(MainWindowViewModel.Machines, "AUTO", "Name='" + machine + "'", "False");
-            }
-
-            DataRow drEmployee = MainWindowViewModel.Machines.Select("NAME='" + machine + "'").First();
-            int index = Convert.ToInt16(drEmployee.Field<object>("ID"));
-            MainWindowViewModel.stringQueue.Enqueue(new MainWindowViewModel.QueueString
-            {
-                ID = index,
-                DAT = "SC829" + MainWindowViewModel.Selet_Machines(MainWindowViewModel.Machines, "SYSKEY", "ID='" + index + "'") + dat_.ToJsonString()
-            });
-          
-        }//手自动
         private void ListViewItem_Curve(object sender, MouseButtonEventArgs e)
         {
             if (rdp.IsConnected) rdp.Disconnect();
@@ -296,7 +534,6 @@ namespace SunlightCentralizedControlManagement_SCCM_.View
             Picture.Content = new View.CurveDiagram(false, machine, DateTime.Now.AddHours(-8).ToString("yyyy/MM/dd  HH:mm:ss"), DateTime.Now.ToString("yyyy/MM/dd  HH:mm:ss"), workOrder);
             machines_info = 3;
         }//曲线
-
         private void ListViewItem_Resume(object sender, MouseButtonEventArgs e)
         {
             IsInteractive = false;
@@ -307,11 +544,49 @@ namespace SunlightCentralizedControlManagement_SCCM_.View
                 dat_821.Add("INSTRUCTION", "CONTINUE");
                 DataRow drEmployee = MainWindowViewModel.Machines.Select("NAME='" + machine + "'").First();
                 int index = Convert.ToInt16(drEmployee.Field<object>("ID"));
-                MainWindowViewModel.stringQueue.Enqueue(new MainWindowViewModel.QueueString 
-                { 
-                    ID = index, 
-                    DAT = "SC821" + MainWindowViewModel.Selet_Machines(MainWindowViewModel.Machines, "SYSKEY", "ID='" + index + "'") + dat_821.ToJsonString() 
-                });
+                if (drEmployee.Field<bool>("Type"))
+                {//网络
+                    MainWindowViewModel.stringQueue.Enqueue(new MainWindowViewModel.QueueString
+                    {
+                        ID = index,
+                        DAT = "SC821" + drEmployee.Field<string>("SYSKEY") + dat_821.ToJsonString()
+                    });
+                }
+                else
+                {//串口
+                    if (drEmployee.Field<string>("Serial") == "PORT1")
+                    {
+                        stringQueueSerial_1.Enqueue(new QueueSerial
+                        {
+                            ID = index,
+                            DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                        });
+                    }
+                    else if (drEmployee.Field<string>("Serial") == "PORT2")
+                    {
+                        stringQueueSerial_2.Enqueue(new QueueSerial
+                        {
+                            ID = index,
+                            DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                        });
+                    }
+                    else if (drEmployee.Field<string>("Serial") == "PORT3")
+                    {
+                        stringQueueSerial_3.Enqueue(new QueueSerial
+                        {
+                            ID = index,
+                            DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                        });
+                    }
+                    else if (drEmployee.Field<string>("Serial") == "PORT4")
+                    {
+                        stringQueueSerial_4.Enqueue(new QueueSerial
+                        {
+                            ID = index,
+                            DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                        });
+                    }
+                }
             }
             Insert.IsHitTestVisible = false;
             edit.IsHitTestVisible = false;
@@ -330,11 +605,49 @@ namespace SunlightCentralizedControlManagement_SCCM_.View
                 dat_821.Add("INSTRUCTION", "PAUSE");
                 DataRow drEmployee = MainWindowViewModel.Machines.Select("NAME='" + machine + "'").First();
                 int index = Convert.ToInt16(drEmployee.Field<object>("ID"));
-                MainWindowViewModel.stringQueue.Enqueue(new MainWindowViewModel.QueueString 
-                {
-                    ID = index, 
-                    DAT = "SC821" + MainWindowViewModel.Selet_Machines(MainWindowViewModel.Machines, "SYSKEY", "ID='" + index + "'") + dat_821.ToJsonString() 
-                });
+                if (drEmployee.Field<bool>("Type"))
+                {//网络
+                    MainWindowViewModel.stringQueue.Enqueue(new MainWindowViewModel.QueueString
+                    {
+                        ID = index,
+                        DAT = "SC821" + drEmployee.Field<string>("SYSKEY") + dat_821.ToJsonString()
+                    });
+                }
+                else
+                {//串口
+                    if (drEmployee.Field<string>("Serial") == "PORT1")
+                    {
+                        stringQueueSerial_1.Enqueue(new QueueSerial
+                        {
+                            ID = index,
+                            DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                        });
+                    }
+                    else if (drEmployee.Field<string>("Serial") == "PORT2")
+                    {
+                        stringQueueSerial_2.Enqueue(new QueueSerial
+                        {
+                            ID = index,
+                            DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                        });
+                    }
+                    else if (drEmployee.Field<string>("Serial") == "PORT3")
+                    {
+                        stringQueueSerial_3.Enqueue(new QueueSerial
+                        {
+                            ID = index,
+                            DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                        });
+                    }
+                    else if (drEmployee.Field<string>("Serial") == "PORT4")
+                    {
+                        stringQueueSerial_4.Enqueue(new QueueSerial
+                        {
+                            ID = index,
+                            DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                        });
+                    }
+                }
             }
             Insert.IsHitTestVisible = true;
             edit.IsHitTestVisible = true;
@@ -354,11 +667,49 @@ namespace SunlightCentralizedControlManagement_SCCM_.View
                 dat_821.Add("INSTRUCTION", "STOP");
                 DataRow drEmployee = MainWindowViewModel.Machines.Select("NAME='" + machine + "'").First();
                 int index = Convert.ToInt16(drEmployee.Field<object>("ID"));
-                MainWindowViewModel.stringQueue.Enqueue(new MainWindowViewModel.QueueString 
-                { 
-                    ID = index, 
-                    DAT = "SC821" + MainWindowViewModel.Selet_Machines(MainWindowViewModel.Machines, "SYSKEY", "ID='" + index + "'") + dat_821.ToJsonString()
-                });
+                if (drEmployee.Field<bool>("Type"))
+                {//网络
+                    MainWindowViewModel.stringQueue.Enqueue(new MainWindowViewModel.QueueString
+                    {
+                        ID = index,
+                        DAT = "SC821" + drEmployee.Field<string>("SYSKEY") + dat_821.ToJsonString()
+                    });
+                }
+                else
+                {//串口
+                    if (drEmployee.Field<string>("Serial") == "PORT1")
+                    {
+                        stringQueueSerial_1.Enqueue(new QueueSerial
+                        {
+                            ID = index,
+                            DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                        });
+                    }
+                    else if (drEmployee.Field<string>("Serial") == "PORT2")
+                    {
+                        stringQueueSerial_2.Enqueue(new QueueSerial
+                        {
+                            ID = index,
+                            DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                        });
+                    }
+                    else if (drEmployee.Field<string>("Serial") == "PORT3")
+                    {
+                        stringQueueSerial_3.Enqueue(new QueueSerial
+                        {
+                            ID = index,
+                            DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                        });
+                    }
+                    else if (drEmployee.Field<string>("Serial") == "PORT4")
+                    {
+                        stringQueueSerial_4.Enqueue(new QueueSerial
+                        {
+                            ID = index,
+                            DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                        });
+                    }
+                }
             }
         }//停止
         private void ListViewItem_edit(object sender, MouseButtonEventArgs e)
@@ -416,11 +767,49 @@ namespace SunlightCentralizedControlManagement_SCCM_.View
 
             DataRow drEmployee = MainWindowViewModel.Machines.Select("NAME='" + machine + "'").First();
             int index = Convert.ToInt16(drEmployee.Field<object>("ID"));
-            MainWindowViewModel.stringQueue.Enqueue(new MainWindowViewModel.QueueString 
-            {
-                ID = index, 
-                DAT = "SC821" + MainWindowViewModel.Selet_Machines(MainWindowViewModel.Machines, "SYSKEY", "ID='" + index + "'") + dat_821.ToJsonString() 
-            });
+            if (drEmployee.Field<bool>("Type"))
+            {//网络
+                MainWindowViewModel.stringQueue.Enqueue(new MainWindowViewModel.QueueString
+                {
+                    ID = index,
+                    DAT = "SC821" + drEmployee.Field<string>("SYSKEY") + dat_821.ToJsonString()
+                });
+            }
+            else
+            {//串口
+                if (drEmployee.Field<string>("Serial") == "PORT1")
+                {
+                    stringQueueSerial_1.Enqueue(new QueueSerial
+                    {
+                        ID = index,
+                        DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                    });
+                }
+                else if (drEmployee.Field<string>("Serial") == "PORT2")
+                {
+                    stringQueueSerial_2.Enqueue(new QueueSerial
+                    {
+                        ID = index,
+                        DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                    });
+                }
+                else if (drEmployee.Field<string>("Serial") == "PORT3")
+                {
+                    stringQueueSerial_3.Enqueue(new QueueSerial
+                    {
+                        ID = index,
+                        DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                    });
+                }
+                else if (drEmployee.Field<string>("Serial") == "PORT4")
+                {
+                    stringQueueSerial_4.Enqueue(new QueueSerial
+                    {
+                        ID = index,
+                        DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                    });
+                }
+            }
             TechnologicalProcess_bool = true;
         }
         private void ListViewItem_Jump(object sender, MouseButtonEventArgs e)
@@ -444,11 +833,49 @@ namespace SunlightCentralizedControlManagement_SCCM_.View
 
             DataRow drEmployee = MainWindowViewModel.Machines.Select("NAME='" + machine + "'").First();
             int index = Convert.ToInt16(drEmployee.Field<object>("ID"));
-            MainWindowViewModel.stringQueue.Enqueue(new MainWindowViewModel.QueueString
-            {
-                ID = index,
-                DAT = "SC821" + MainWindowViewModel.Selet_Machines(MainWindowViewModel.Machines, "SYSKEY", "ID='" + index + "'") + dat_821.ToJsonString()
-            });
+            if (drEmployee.Field<bool>("Type"))
+            {//网络
+                MainWindowViewModel.stringQueue.Enqueue(new MainWindowViewModel.QueueString
+                {
+                    ID = index,
+                    DAT = "SC821" + drEmployee.Field<string>("SYSKEY") + dat_821.ToJsonString()
+                });
+            }
+            else
+            {//串口
+                if (drEmployee.Field<string>("Serial") == "PORT1")
+                {
+                    stringQueueSerial_1.Enqueue(new QueueSerial
+                    {
+                        ID = index,
+                        DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                    });
+                }
+                else if (drEmployee.Field<string>("Serial") == "PORT2")
+                {
+                    stringQueueSerial_2.Enqueue(new QueueSerial
+                    {
+                        ID = index,
+                        DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                    });
+                }
+                else if (drEmployee.Field<string>("Serial") == "PORT3")
+                {
+                    stringQueueSerial_3.Enqueue(new QueueSerial
+                    {
+                        ID = index,
+                        DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                    });
+                }
+                else if (drEmployee.Field<string>("Serial") == "PORT4")
+                {
+                    stringQueueSerial_4.Enqueue(new QueueSerial
+                    {
+                        ID = index,
+                        DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                    });
+                }
+            }
 
             TechnologicalProcess_bool = true;
         }//跳步
@@ -507,11 +934,49 @@ namespace SunlightCentralizedControlManagement_SCCM_.View
 
             DataRow drEmployee = MainWindowViewModel.Machines.Select("NAME='" + machine + "'").First();
             int index = Convert.ToInt16(drEmployee.Field<object>("ID"));
-            MainWindowViewModel.stringQueue.Enqueue(new MainWindowViewModel.QueueString 
-            { 
-                ID = index, 
-                DAT = "SC821" + MainWindowViewModel.Selet_Machines(MainWindowViewModel.Machines, "SYSKEY", "ID='" + index + "'") + dat_821.ToJsonString() 
-            });
+            if (drEmployee.Field<bool>("Type"))
+            {//网络
+                MainWindowViewModel.stringQueue.Enqueue(new MainWindowViewModel.QueueString
+                {
+                    ID = index,
+                    DAT = "SC821" + drEmployee.Field<string>("SYSKEY") + dat_821.ToJsonString()
+                });
+            }
+            else
+            {//串口
+                if (drEmployee.Field<string>("Serial") == "PORT1")
+                {
+                    stringQueueSerial_1.Enqueue(new QueueSerial
+                    {
+                        ID = index,
+                        DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                    });
+                }
+                else if (drEmployee.Field<string>("Serial") == "PORT2")
+                {
+                    stringQueueSerial_2.Enqueue(new QueueSerial
+                    {
+                        ID = index,
+                        DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                    });
+                }
+                else if (drEmployee.Field<string>("Serial") == "PORT3")
+                {
+                    stringQueueSerial_3.Enqueue(new QueueSerial
+                    {
+                        ID = index,
+                        DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                    });
+                }
+                else if (drEmployee.Field<string>("Serial") == "PORT4")
+                {
+                    stringQueueSerial_4.Enqueue(new QueueSerial
+                    {
+                        ID = index,
+                        DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                    });
+                }
+            }
 
         }
         private void ListViewItem_Delete(object sender, MouseButtonEventArgs e)
@@ -524,11 +989,49 @@ namespace SunlightCentralizedControlManagement_SCCM_.View
                 dat_821.Add("ID", ID);
                 DataRow drEmployee = MainWindowViewModel.Machines.Select("NAME='" + machine + "'").First();
                 int index = Convert.ToInt16(drEmployee.Field<object>("ID"));
-                MainWindowViewModel.stringQueue.Enqueue(new MainWindowViewModel.QueueString 
-                { 
-                    ID = index, 
-                    DAT = "SC821" + MainWindowViewModel.Selet_Machines(MainWindowViewModel.Machines, "SYSKEY", "ID='" + index + "'") + dat_821.ToJsonString() 
-                });
+                if (drEmployee.Field<bool>("Type"))
+                {//网络
+                    MainWindowViewModel.stringQueue.Enqueue(new MainWindowViewModel.QueueString
+                    {
+                        ID = index,
+                        DAT = "SC821" + drEmployee.Field<string>("SYSKEY") + dat_821.ToJsonString()
+                    });
+                }
+                else
+                {//串口
+                    if (drEmployee.Field<string>("Serial") == "PORT1")
+                    {
+                        stringQueueSerial_1.Enqueue(new QueueSerial
+                        {
+                            ID = index,
+                            DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                        });
+                    }
+                    else if (drEmployee.Field<string>("Serial") == "PORT2")
+                    {
+                        stringQueueSerial_2.Enqueue(new QueueSerial
+                        {
+                            ID = index,
+                            DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                        });
+                    }
+                    else if (drEmployee.Field<string>("Serial") == "PORT3")
+                    {
+                        stringQueueSerial_3.Enqueue(new QueueSerial
+                        {
+                            ID = index,
+                            DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                        });
+                    }
+                    else if (drEmployee.Field<string>("Serial") == "PORT4")
+                    {
+                        stringQueueSerial_4.Enqueue(new QueueSerial
+                        {
+                            ID = index,
+                            DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                        });
+                    }
+                }
 
                 MainWindowViewModel.dt_TP.Select("Step="+ID).First().Delete();
                 MainWindowViewModel.dt_TP.AcceptChanges();
@@ -571,6 +1074,7 @@ namespace SunlightCentralizedControlManagement_SCCM_.View
             }
         }
         private void MenuItem_Delete(object sender, RoutedEventArgs e)//右键删除
+  
         {
             int rownum = Gridstep.SelectedIndex;//获取鼠标选中行并定义变量
             if (rownum != -1)//判断鼠标定位是否有效
@@ -584,11 +1088,49 @@ namespace SunlightCentralizedControlManagement_SCCM_.View
                     dat_821.Add("ID", ID);
                     DataRow drEmployee = MainWindowViewModel.Machines.Select("NAME='" + machine + "'").First();
                     int index = Convert.ToInt16(drEmployee.Field<object>("ID"));
-                    MainWindowViewModel.stringQueue.Enqueue(new MainWindowViewModel.QueueString
-                    {
-                        ID = index,
-                        DAT = "SC821" + MainWindowViewModel.Selet_Machines(MainWindowViewModel.Machines, "SYSKEY", "ID='" + index + "'") + dat_821.ToJsonString()
-                    });
+                    if (drEmployee.Field<bool>("Type"))
+                    {//网络
+                        MainWindowViewModel.stringQueue.Enqueue(new MainWindowViewModel.QueueString
+                        {
+                            ID = index,
+                            DAT = "SC821" + drEmployee.Field<string>("SYSKEY") + dat_821.ToJsonString()
+                        });
+                    }
+                    else
+                    {//串口
+                        if (drEmployee.Field<string>("Serial") == "PORT1")
+                        {
+                            stringQueueSerial_1.Enqueue(new QueueSerial
+                            {
+                                ID = index,
+                                DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                            });
+                        }
+                        else if (drEmployee.Field<string>("Serial") == "PORT2")
+                        {
+                            stringQueueSerial_2.Enqueue(new QueueSerial
+                            {
+                                ID = index,
+                                DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                            });
+                        }
+                        else if (drEmployee.Field<string>("Serial") == "PORT3")
+                        {
+                            stringQueueSerial_3.Enqueue(new QueueSerial
+                            {
+                                ID = index,
+                                DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                            });
+                        }
+                        else if (drEmployee.Field<string>("Serial") == "PORT4")
+                        {
+                            stringQueueSerial_4.Enqueue(new QueueSerial
+                            {
+                                ID = index,
+                                DAT = "SC821" + drEmployee.Field<string>("Station") + dat_821.ToJsonString()
+                            });
+                        }
+                    }
 
                     MainWindowViewModel.dt_TP.Select("Step=" + ID).First().Delete();
                     MainWindowViewModel.dt_TP.AcceptChanges();
@@ -641,7 +1183,7 @@ namespace SunlightCentralizedControlManagement_SCCM_.View
                             MainWindowViewModel.stringQueue.Enqueue(new MainWindowViewModel.QueueString
                             {
                                 ID = index,
-                                DAT = "SC832" + MainWindowViewModel.Selet_Machines(MainWindowViewModel.Machines, "SYSKEY", "ID='" + index + "'")
+                                DAT = "SC832" + drEmployee.Field<string>("SYSKEY")
                             });
                         }//信息
                         else if (machines_info == 1)
@@ -659,7 +1201,7 @@ namespace SunlightCentralizedControlManagement_SCCM_.View
                         MainWindowViewModel.stringQueue.Enqueue(new MainWindowViewModel.QueueString
                         {
                             ID = index,
-                            DAT = "SC831" + MainWindowViewModel.Selet_Machines(MainWindowViewModel.Machines, "SYSKEY", "ID='" + index + "'")
+                            DAT = "SC831" + drEmployee.Field<string>("SYSKEY")
                         });
                     }
                     else

View/ProgramstepsView .xaml.cs

@@ -1,4 +1,6 @@
-using SunlightCentralizedControlManagement_SCCM_.UserClass;
+
+
+using SunlightCentralizedControlManagement_SCCM_.UserClass;
 using SunlightCentralizedControlManagement_SCCM_.ViewModel;
 using SunlightCentralizedControlManagement_SCCM_.WindowsView;
 using System;

WindowsView/UserInf.xaml

@@ -0,0 +1,23 @@
+<Window x:Class="SunlightCentralizedControlManagement_SCCM_.WindowsView.UserInf"
+        xmlns="http://schemas.microsoft.com/winfx/2006/xaml/presentation"
+        xmlns:x="http://schemas.microsoft.com/winfx/2006/xaml"
+        xmlns:d="http://schemas.microsoft.com/expression/blend/2008"
+        xmlns:mc="http://schemas.openxmlformats.org/markup-compatibility/2006"
+        xmlns:local="clr-namespace:SunlightCentralizedControlManagement_SCCM_.WindowsView"
+        xmlns:lang="clr-namespace:SunlightCentralizedControlManagement_SCCM_.Properties" 
+        WindowStartupLocation="CenterScreen"
+        Loaded ="Window_Loaded"
+        ResizeMode="NoResize"
+        mc:Ignorable="d"
+        Title="SUNLIGHT 800" Height="400" Width="800">
+    <Grid>
+        <Grid Margin="0,0,0,100">
+            <TextBox x:Name="INF_DATA" Margin="140,20,20,20" TextWrapping="Wrap" FontSize="30" IsReadOnly="True" BorderBrush="#FF673AB7" BorderThickness="2,2,2,2" Cursor="Hand" />       
+            <Image Height="100" Width="100" FlowDirection="LeftToRight" HorizontalAlignment="Left" Margin="20,0,0,0" Source="/Lmage/IconParkInfo.png" VerticalAlignment="Center"/>
+        </Grid>
+        <Button Content="{x:Static lang:Resources.YES}" HorizontalAlignment="Left" Height="45" Margin="50,70,20,20" 
+                VerticalAlignment="Bottom" Width="100" Click="YES_Click" HorizontalContentAlignment="Center"/>
+        <Button Content="{x:Static lang:Resources.NO}" HorizontalAlignment="Right" Height="45" Margin="50,70,20,20" 
+                VerticalAlignment="Bottom" Width="100" Click="YES_Click"/>
+    </Grid>
+</Window>

WindowsView/UserInf.xaml.cs

@@ -0,0 +1,47 @@
+using SunlightCentralizedControlManagement_SCCM_.ViewModel;
+using System;
+using System.Collections.Generic;
+using System.Data;
+using System.Drawing;
+using System.Linq;
+using System.Net;
+using System.Text;
+using System.Threading.Tasks;
+using System.Windows;
+using System.Windows.Controls;
+using System.Windows.Data;
+using System.Windows.Documents;
+using System.Windows.Input;
+using System.Windows.Markup;
+using System.Windows.Media;
+using System.Windows.Media.Animation;
+using System.Windows.Media.Imaging;
+using System.Windows.Shapes;
+using System.Windows.Threading;
+using System.Xml.Linq;
+using static SunlightCentralizedControlManagement_SCCM_.UserClass.SqliteHelper;
+
+namespace SunlightCentralizedControlManagement_SCCM_.WindowsView
+{
+    /// <summary>
+    /// ViewProgram.xaml 的交互逻辑
+    /// </summary>
+    public partial class UserInf : Window
+    {
+        public string Inf_DAT;//信息
+        public UserInf()
+        {
+            InitializeComponent();           
+        }
+        private void Window_Loaded(object sender, RoutedEventArgs e)
+        {
+            INF_DATA.Text = Inf_DAT;
+        }
+
+        private void YES_Click(object sender, RoutedEventArgs e)//确认
+        {
+            this.Close(); //关闭窗口
+        }
+
+    }
+}

WindowsView/UserWorkOrder.xaml

@@ -0,0 +1,93 @@
+<Window x:Class="SunlightCentralizedControlManagement_SCCM_.WindowsView.UserWorkOrder"
+        xmlns="http://schemas.microsoft.com/winfx/2006/xaml/presentation"
+        xmlns:x="http://schemas.microsoft.com/winfx/2006/xaml"
+        xmlns:d="http://schemas.microsoft.com/expression/blend/2008"
+        xmlns:mc="http://schemas.openxmlformats.org/markup-compatibility/2006"
+        xmlns:local="clr-namespace:SunlightCentralizedControlManagement_SCCM_.WindowsView"
+        xmlns:lang="clr-namespace:SunlightCentralizedControlManagement_SCCM_.Properties" 
+        WindowStartupLocation="CenterScreen"
+        Loaded ="Window_Loaded"
+        ResizeMode="NoResize"
+        mc:Ignorable="d"
+        Title="SUNLIGHT 800" Height="400" Width="800">
+    <Grid>
+        <DataGrid Grid.Row="0" Grid.Column="0" x:Name="WorkOrder" AlternationCount="2" IsReadOnly="True" 
+                 SelectedCellsChanged="WorkOrder_SelectedCellsChanged" EnableRowVirtualization="True"  EnableColumnVirtualization="True"
+              VirtualizingPanel.IsVirtualizing="True" VirtualizingPanel.VirtualizationMode="Recycling" AutoGenerateColumns="False" MinColumnWidth="30"                          
+              Background="White" GridLinesVisibility="All" ColumnHeaderHeight="40" HorizontalContentAlignment="Right" 
+              CanUserReorderColumns="False" CanUserSortColumns="False" CanUserResizeRows="False" CanUserResizeColumns="True"   
+              CanUserDeleteRows="False" SelectionMode="Single" FontSize="15" Focusable="True" Margin="0,0,0,132" >
+            <DataGrid.RowStyle >
+                <Style TargetType="{x:Type DataGridRow}">
+                    <Setter Property="Height" Value="30" />
+                    <Setter Property="FontSize" Value="25" />
+                    <Setter Property="VerticalAlignment" Value="Center"/>
+                    <Style.Triggers>
+                        <Trigger Property="ItemsControl.AlternationIndex" Value="0">
+                            <Setter Property="Background" Value="#FFFFFFFF" />
+                        </Trigger>
+                        <Trigger Property="ItemsControl.AlternationIndex" Value="1">
+                            <Setter Property="Background" Value="#FFF0F0F0" />
+                        </Trigger>
+                        <Trigger Property="IsMouseOver" Value="False"/>
+                        <DataTrigger Binding="{Binding lock}" Value="True">
+                            <Setter Property="Background" Value="Red"/>
+                        </DataTrigger>
+                        <DataTrigger Binding="{Binding State}" Value="309">
+                            <Setter Property="Background" Value="Red"/>
+                        </DataTrigger>
+                        <DataTrigger Binding="{Binding State}" Value="308">
+                            <Setter Property="Background" Value="Yellow"/>
+                        </DataTrigger>
+                        <DataTrigger Binding="{Binding State}" Value="800">
+                            <Setter Property="IsHitTestVisible" Value="False"/>
+                        </DataTrigger>
+                    </Style.Triggers>
+                </Style>
+            </DataGrid.RowStyle>
+            <DataGrid.CellStyle>
+                <Style TargetType="DataGridCell">
+                    <Setter Property="BorderThickness" Value="0"/>
+                    <Setter Property="MinWidth" Value="20"/>
+                    <Setter Property="VerticalAlignment" Value="Center"/>
+                    <Style.Triggers>
+                        <Trigger Property="IsSelected" Value="True">
+                            <Setter Property="Background" Value="#FFC0C0C0"/>
+                            <Setter Property="BorderBrush" Value="#FFC0C0C0"/>
+                            <Setter Property="Foreground" Value="Black"/>
+                        </Trigger>
+                    </Style.Triggers>
+                </Style>
+            </DataGrid.CellStyle>
+            <DataGrid.Resources>
+                <Style x:Key="CellStyle" TargetType="{x:Type DataGridCell}">
+                    <Setter Property="Focusable" Value="False"/>
+                    <Setter Property="Background" Value="#FFFFFFFF"/>
+                    <Setter Property="BorderBrush" Value="#FFFFFFFF"/>
+                    <Setter Property="Foreground" Value="#000000"/>
+                </Style>
+            </DataGrid.Resources>
+            <DataGrid.Columns>
+                <!--列信息绑定-->
+                <DataGridTextColumn Header="{x:Static lang:Resources.WorkOrder}" Binding="{Binding WorkOrder}" Width="200" IsReadOnly="True"/>
+                <DataGridTextColumn Header="{x:Static lang:Resources.ProgramName}" Binding="{Binding ProgramName}" Width="200" IsReadOnly="True"/>
+                <DataGridTextColumn Header="{x:Static lang:Resources.StartTime}" Binding="{Binding StartTime}" Width="250" IsReadOnly="True"/>
+                <DataGridTextColumn Header="{x:Static lang:Resources.Machines}" Binding="{Binding Machines}" Width="100" IsReadOnly="True"/>
+                <DataGridTextColumn Header="{x:Static lang:Resources.ColorNumber}" Binding="{Binding ColorNumber}" Width="200" IsReadOnly="True"/>
+                <DataGridTextColumn Header="{x:Static lang:Resources.Client}" Binding="{Binding Client}" Width="200" IsReadOnly="True"/>
+                <DataGridTextColumn Header="{x:Static lang:Resources.ClothWeight}" Binding="{Binding ClothWeight}" Width="200" IsReadOnly="True"/>
+                <DataGridTextColumn Header="{x:Static lang:Resources.ClothSpecies}" Binding="{Binding ClothSpecies}" Width="200" IsReadOnly="True"/>
+                <DataGridTextColumn Header="{x:Static lang:Resources.BathRatio}" Binding="{Binding BathRatio}" Width="200" IsReadOnly="True"/>
+                <DataGridTextColumn Header="{x:Static lang:Resources.Total}" Binding="{Binding Total}" Width="200" IsReadOnly="True"/>
+                <DataGridTextColumn Header="{x:Static lang:Resources.USER}" Binding="{Binding USER}" Width="150" IsReadOnly="True"/>
+                <DataGridTextColumn Header="{x:Static lang:Resources.ColorName}" Binding="{Binding ColorName}" Width="200" IsReadOnly="True"/>
+            </DataGrid.Columns>
+        </DataGrid>
+        <Image Height="100" Width="100" FlowDirection="LeftToRight" HorizontalAlignment="Left" Margin="20,0,0,20" Source="/Lmage/IconParkInfo.png" VerticalAlignment="Bottom"/>
+
+        <Button Content="{x:Static lang:Resources.Start}" HorizontalAlignment="Right" Height="45" Margin="50,70,200,20" IsEnabled="False" x:Name="Start"
+                VerticalAlignment="Bottom" Width="100" Click="Start_Click" HorizontalContentAlignment="Center"/>
+        <Button Content="{x:Static lang:Resources.Quit}" HorizontalAlignment="Right" Height="45" Margin="50,70,20,20" 
+                VerticalAlignment="Bottom" Width="100" Click="Quit_Click" HorizontalContentAlignment="Center"/>
+    </Grid>
+</Window>

WindowsView/UserWorkOrder.xaml.cs

@@ -0,0 +1,139 @@
+using ScottPlot.TickGenerators.TimeUnits;
+using SunlightCentralizedControlManagement_SCCM_.ViewModel;
+using System;
+using System.Collections.Generic;
+using System.Data;
+using System.Drawing;
+using System.Linq;
+using System.Net;
+using System.Text;
+using System.Threading.Tasks;
+using System.Windows;
+using System.Windows.Controls;
+using System.Windows.Data;
+using System.Windows.Documents;
+using System.Windows.Forms;
+using System.Windows.Input;
+using System.Windows.Markup;
+using System.Windows.Media;
+using System.Windows.Media.Animation;
+using System.Windows.Media.Imaging;
+using System.Windows.Shapes;
+using System.Windows.Threading;
+using System.Xml.Linq;
+using TouchSocket.Core;
+using static SunlightCentralizedControlManagement_SCCM_.UserClass.SqliteHelper;
+using static SunlightCentralizedControlManagement_SCCM_.ViewModel.MainWindowViewModel;
+
+namespace SunlightCentralizedControlManagement_SCCM_.WindowsView
+{
+    /// <summary>
+    /// ViewProgram.xaml 的交互逻辑
+    /// </summary>
+    public partial class UserWorkOrder : Window
+    {
+
+        public DataTable WorkOrderTable = new DataTable();//信息
+        private string WorkOrder_=null;
+        private string machine_ = null;
+        public UserWorkOrder()
+        {
+            InitializeComponent();           
+        }
+        private void Window_Loaded(object sender, RoutedEventArgs e)
+        {
+            WorkOrder.ItemsSource = WorkOrderTable.DefaultView;
+        }
+
+        private void Start_Click(object sender, RoutedEventArgs e)//确认
+        {
+            Dictionary<string, object> dat_821 = new Dictionary<string, object>();
+            dat_821.Clear();
+            dat_821.Add("INSTRUCTION", "START");
+            dat_821.Add("WorkOrder", WorkOrder_);
+            DataRow drEmployee = MainWindowViewModel.Machines.Select("NAME='" + machine_ + "'").First();
+            int index = Convert.ToInt16(drEmployee.Field<object>("ID"));
+            string dat = "SC821" + MainWindowViewModel.Selet_Machines(MainWindowViewModel.Machines, "SYSKEY", "ID='" + index + "'") + dat_821.ToJsonString();
+
+            lock (MainWindowViewModel.Machines.Rows.SyncRoot)
+            {
+                if (drEmployee.Field<bool>("Type"))
+                {//网络
+                    MainWindowViewModel.stringQueue.Enqueue(new MainWindowViewModel.QueueString
+                    {
+                        ID = index,
+                        DAT = dat
+                    });
+                }
+                else 
+                {//串口
+                    if (drEmployee.Field<string>("Serial") == "PORT1")
+                    {
+                        bool exists = stringQueueSerial_1.Any(item => item.ID == index && item.DAT == dat);
+                        if (!exists)
+                        {
+                            stringQueueSerial_1.Enqueue(new QueueSerial
+                            {
+                                ID = index,
+                                DAT = dat
+                            });
+                        }
+                    }
+                    else if (drEmployee.Field<string>("Serial") == "PORT2")
+                    {
+                        bool exists = stringQueueSerial_2.Any(item => item.ID == index && item.DAT == dat);
+                        if (!exists)
+                        {
+                            stringQueueSerial_2.Enqueue(new QueueSerial
+                            {
+                                ID = index,
+                                DAT = dat
+                            });
+                        }
+                    }
+                    else if (drEmployee.Field<string>("Serial") == "PORT3")
+                    {
+                        bool exists = stringQueueSerial_3.Any(item => item.ID == index && item.DAT == dat);
+                        if (!exists)
+                        {
+                            stringQueueSerial_3.Enqueue(new QueueSerial
+                            {
+                                ID = index,
+                                DAT = dat
+                            });
+                        }
+                    }
+                    else if (drEmployee.Field<string>("Serial") == "PORT4")
+                    {
+                        bool exists = stringQueueSerial_4.Any(item => item.ID == index && item.DAT == dat);
+                        if (!exists)
+                        {
+                            stringQueueSerial_4.Enqueue(new QueueSerial
+                            {
+                                ID = index,
+                                DAT = dat
+                            });
+                        }
+                    }
+                }
+            }
+
+            this.Close(); 
+        }
+        private void Quit_Click(object sender, RoutedEventArgs e)//退出
+        {
+            this.Close(); //关闭窗口
+        }
+        private void WorkOrder_SelectedCellsChanged(object sender, SelectedCellsChangedEventArgs e)
+        {
+            int rownum = WorkOrder.SelectedIndex;//获取鼠标选中行并定义变量
+            if (rownum != -1)//判断鼠标定位是否有效
+            {
+                WorkOrder_ = (WorkOrder.Columns[0].GetCellContent(WorkOrder.Items[rownum]) as TextBlock).Text;//定位第0列，
+                machine_ = (WorkOrder.Columns[3].GetCellContent(WorkOrder.Items[rownum]) as TextBlock).Text;//定位第0列，
+
+                Start.IsEnabled = true;
+            }
+        }
+    }
+}