From e3868d4d61ded0e76fc8fe3fdacdd9e6d9113cf1 Mon Sep 17 00:00:00 2001
From: alielie <alielie@git.com>
Date: 星期一, 13 十月 2025 08:50:15 +0800
Subject: [PATCH] 优化HMI;

---
 Plugin.TsExecution/TsExecution.xaml.cs |  795 ++++++++++++++++++++++++++++++++++++++++++--------------
 1 files changed, 594 insertions(+), 201 deletions(-)

diff --git a/Plugin.TsExecution/TsExecution.xaml.cs b/Plugin.TsExecution/TsExecution.xaml.cs
index 528df03..11614c4 100644
--- a/Plugin.TsExecution/TsExecution.xaml.cs
+++ b/Plugin.TsExecution/TsExecution.xaml.cs
@@ -1,15 +1,19 @@
 锘縰sing HMI.Base;
 using HMI.Core;
+using HMI.Core.Api;
 using HMI.Core.Entity;
 using HMI.Core.Manager;
 using HMI.Core.Util;
+using HMI.MQUtil;
 using HMI.UI;
+using HMI.UI.Controls;
 using HMI.UI.Util;
 using HMI.Util;
 using log4net;
 using NationalInstruments.TestStand.Interop.API;
 using NationalInstruments.TestStand.Interop.UI.Ax;
 using Panuon.WPF.UI;
+using Plugin.TsSupport;
 using ScottPlot;
 using ScottPlot.Plottables;
 using System;
@@ -18,12 +22,11 @@
 using System.ComponentModel;
 using System.IO;
 using System.Linq;
-using System.Reflection;
 using System.Timers;
 using System.Windows;
 using System.Windows.Controls;
 using System.Windows.Forms.DataVisualization.Charting;
-using System.Xml.Linq;
+using System.Windows.Media;
 
 namespace Plugin.TsExecution
 {
@@ -92,6 +95,8 @@
 
         private ProductData selectedProduct;
 
+        private MSMQHelper mSMQHelper = new MSMQHelper("HMI_Alarm");
+
         public ProductData SelectedProduct
         {
             get { return selectedProduct; }
@@ -121,6 +126,7 @@
 
         private Pie pie;
         private string CountIniPath;
+        private bool IsOptRequirePassword;
 
         private bool alarmVisiable;
         public bool AlarmVisiable
@@ -138,9 +144,12 @@
             get => _enableMes;
             set
             {
-                if (WriteConfig("EnableMes", value))
+                if (RequirePassword() == true)
                 {
-                    Set(ref _enableMes, value);
+                    if (WriteConfig("EnableMes", value))
+                    {
+                        Set(ref _enableMes, value);
+                    }
                 }
             }
         }
@@ -164,9 +173,12 @@
             get => _enableDebugMode;
             set
             {
-                if (WriteConfig("EnableDebugMode", value))
+                if (RequirePassword() == true)
                 {
-                    Set(ref _enableDebugMode, value);
+                    if (WriteConfig("EnableDebugMode", value))
+                    {
+                        Set(ref _enableDebugMode, value);
+                    }
                 }
             }
         }
@@ -177,9 +189,12 @@
             get => _enableNGPause;
             set
             {
-                if (WriteConfig("EnableNGPause", value))
+                if (RequirePassword() == true)
                 {
-                    Set(ref _enableNGPause, value);
+                    if (WriteConfig("EnableNGPause", value))
+                    {
+                        Set(ref _enableNGPause, value);
+                    }
                 }
             }
         }
@@ -212,6 +227,48 @@
             }
         }
 
+        private bool autoExecuteSeq;
+        public bool AutoExecuteSeq
+        {
+            get => autoExecuteSeq;
+            set
+            {
+                Set(ref autoExecuteSeq, value);
+            }
+        }
+
+        private string currentWorkorder;
+        public string CurrentWorkorder
+        {
+            get => currentWorkorder;
+            set
+            {
+                if (WriteIni("UI_CurrentWorkorder", value))
+                {
+                    Set(ref currentWorkorder, value);
+                }
+            }
+        }
+
+        private bool _DisableScanner;
+        public bool DisableScanner
+        {
+            get => _DisableScanner;
+            set
+            {
+                if (WriteConfig("DisableScanner", value))
+                {
+                    Set(ref _DisableScanner, value);
+                }
+            }
+        }
+
+        private string tsModelPath;
+        private string dataLogPath;
+        private SqliteHelper sqliteHelper;
+
+        private MQConnector mqConnector;
+
         public TsExecution()
         {
             DataContext = this;
@@ -222,11 +279,51 @@
             //鍒濆鍖朤estStand寮曟搸
             this.InitTestStandEngine();
         }
-
         public override void SetBaseFolder(string folder)
         {
             CountIniPath = Path.Combine(folder, "Count.ini");
             base.SetBaseFolder(folder);
+        }
+
+        private void CheckSqlHelper()
+        {
+            string today = DateTime.Now.ToString("yyyyMMdd");
+            string dbPath = Path.Combine(dataLogPath, $"Data_{today}.db");
+            if (!File.Exists(dbPath))
+            {
+                SqliteHelper.CreateDatabase(dbPath);
+            }
+            if (sqliteHelper == null || sqliteHelper.DataBaseFile != dbPath)
+            {
+                sqliteHelper?.Dispose();
+                sqliteHelper = new SqliteHelper(dbPath);
+                sqliteHelper.ExecuteSql(@"CREATE TABLE IF NOT EXISTS serialData (
+                    id INTEGER PRIMARY KEY AUTOINCREMENT,
+                    sn TEXT NOT NULL,
+                    model TEXT,
+                    station TEXT NOT NULL,
+                    step TEXT NOT NULL,
+                    position TEXT,
+                    limitDown TEXT,
+                    limitUp TEXT,
+                    unit TEXT,
+                    offset TEXT,
+                    value TEXT,
+                    status TEXT,
+                    finalStatus TEXT,
+                    consumeTime TEXT, 
+                    totalConsumeTime TEXT, 
+                    time DATETIME NOT NULL);");
+                sqliteHelper.ExecuteSql(@"CREATE TABLE IF NOT EXISTS testResult (
+                    id INTEGER PRIMARY KEY AUTOINCREMENT,
+                    sn TEXT NOT NULL,
+                    model TEXT,
+                    station TEXT NOT NULL,
+                    position TEXT,
+                    status TEXT,
+                    result TEXT NOT NULL, 
+                    time DATETIME NOT NULL);");
+            }
         }
 
         public override void InitFinish()
@@ -234,7 +331,51 @@
             this.ReadCount(out int pass, out int fail);
             this.DisplayCount(pass, fail);
             InitProducts();
+            ReadConfig();
+            CheckSqlHelper();
             base.InitFinish();
+        }
+
+        private void InitMQ()
+        {
+            mqConnector = new MQConnector("UI");
+            mqConnector.BeginReceive(HandleMQUI);
+        }
+
+        void HandleMQUI(string msg)
+        {
+            string[] arr = msg.Split('|');
+            int eventCode = int.Parse(arr[0]);
+            int index = int.Parse(arr[1]);
+            string strData = arr[2];
+            Dispatcher.BeginInvoke(new Action(() =>
+            {
+                HandleUIMessage(eventCode, index, strData);
+            }));
+        }
+
+        void createChildInNewThread(int index, string configFile, int probeWarn)
+        {
+            HostVisual hostVisual = new HostVisual();
+
+            UIElement content = new VisualHost(hostVisual);
+
+            System.Threading.Thread thread = new System.Threading.Thread(new System.Threading.ThreadStart(() =>
+            {
+                VisualTarget visualTarget = new VisualTarget(hostVisual);
+
+                var control = new SingleControl(index, configFile, probeWarn);
+                control.Arrange(new Rect(new Point(), content.RenderSize));
+
+                visualTarget.RootVisual = control;
+                tsSockets.Add(control);
+                System.Windows.Threading.Dispatcher.Run();
+            }));
+            //panel.Children.Add(content);
+
+            thread.SetApartmentState(System.Threading.ApartmentState.STA);
+            thread.IsBackground = true;
+            thread.Start();
         }
 
         /// <summary>
@@ -244,7 +385,7 @@
         {
             pieChart.Plot.Axes.Frameless();
             pieChart.Plot.HideGrid();
-            pieChart.Plot.DataBackground.Color = Colors.Transparent;
+            pieChart.Plot.DataBackground.Color = ScottPlot.Colors.Transparent;
 
             var legend = pieChart.Plot.ShowLegend(Alignment.UpperRight);
             legend.Alignment = Alignment.UpperRight;
@@ -254,15 +395,25 @@
             pieChart.Plot.Font.Automatic();
 
             List<PieSlice> slices = new List<PieSlice> {
-    new PieSlice() { Value = 5, FillColor = Colors.Green,
+    new PieSlice() { Value = 5, FillColor = ScottPlot.Colors.Green,
         LabelFontSize = (float)WidthSizeConverter.CountFontSize(20,300,300),
         Label = "Pass",LegendText="Pass" },
-    new PieSlice() { Value = 2, FillColor = Colors.Red,
+    new PieSlice() { Value = 2, FillColor = ScottPlot.Colors.Red,
         LabelFontSize = (float)WidthSizeConverter.CountFontSize(20,300,300),
         Label = "Fail",LegendText="Fail" } };
 
 
             pie = pieChart.Plot.Add.Pie(slices);
+        }
+
+        private bool? RequirePassword()
+        {
+            if (!IsOptRequirePassword) return true;
+            var win = new RequirePasswordWindow
+            {
+                Owner = Window.GetWindow(this)
+            };
+            return win.ShowDialog();
         }
 
         private void InitProducts()
@@ -316,15 +467,40 @@
         /// </summary>
         private void InitTsEngine()
         {
-            AxApplicationMgr = new AxApplicationMgr();
+            AxApplicationMgr = TestAppManager.GetAxApplicationMgr();
+            AxApplicationMgr.EndExecution += AxApplicationMgr_EndExecution;
             AxApplicationMgr.ExitApplication += new EventHandler(this.AxApplicationMgr_ExitApplication);
             AxApplicationMgr.UIMessageEvent +=
                 new _ApplicationMgrEvents_UIMessageEventEventHandler(this.AxApplicationMgr_UIMessageEvent);
             AxApplicationMgr.ExecutionClosed +=
                 new _ApplicationMgrEvents_ExecutionClosedEventHandler(this.AxApplicationMgr_ExecutionClosed);
+
             ((System.ComponentModel.ISupportInitialize)(AxApplicationMgr)).BeginInit();
             host.Child = AxApplicationMgr;
             ((System.ComponentModel.ISupportInitialize)(AxApplicationMgr)).EndInit();
+        }
+
+        private void AxApplicationMgr_EndExecution(object sender, _ApplicationMgrEvents_EndExecutionEvent e)
+        {
+            log.Info("AxApplicationMgr_EndExecution");
+            if (ReleaseSequenceFile())
+            {
+                log.Info("Release SeqFile Success!");
+            }
+            else
+            {
+                log.Warn("Release SeqFile Fail!");
+            }
+        }
+
+        /// <summary>
+        /// 杩涚▼缁撴潫浜嬩欢
+        /// </summary>
+        /// <param name="sender"></param>
+        /// <param name="e"></param>
+        private void AxApplicationMgr_ExecutionClosed(object sender, _ApplicationMgrEvents_ExecutionClosedEvent e)
+        {
+            //ReleaseSequenceFile();
         }
 
         private void PluginControl_Loaded(object sender, RoutedEventArgs e)
@@ -345,10 +521,9 @@
                             {
                                 log.Warn("Get Login User Failed.", ex);
                             }
-                            ReadConfig();
                         });
                         isLoadOK = true;
-                        StartSequence();
+                        if (AutoExecuteSeq) StartSequence();
                     }
                     catch (Exception ex)
                     {
@@ -371,25 +546,6 @@
                     {
                         if (isLoadOK) Loaded -= PluginControl_Loaded;
                     });
-
-                    //Dispatcher.Invoke(() =>
-                    //{
-                    //    try
-                    //    {
-                    //        ReadConfig();
-                    //        //杩炴帴OPChandle
-                    //        //this.OpcHandle.Connect2("127.0.0.1", 6543, 18081, out string ErrMsg, null);
-                    //        isLoadOK = true;
-                    //        //鍚姩娴嬭瘯杩涚▼
-                    //        StartSequence();
-                    //    }
-                    //    catch (Exception ex)
-                    //    {
-                    //        log.Error("TsExecution Loaded Failed.", ex);
-                    //        MsgBoxHelper.Error(this, $"{LangUtil.Get("Ts.UserControlLoadFailed")}: {ex.Message}");
-                    //    }
-
-                    //});
                 }
                 ).Info(LangUtil.Get("App.UsercontrolIsLoading"));
         }
@@ -417,6 +573,8 @@
                 SingleControl control = new SingleControl(i, CountIniPath, ProbeWarn);
                 panel.Children.Add(control);
                 tsSockets.Add(control);
+
+                //createChildInNewThread(i, CountIniPath, ProbeWarn);
             }
             if (tsSockets.Count == 1)
             {
@@ -440,7 +598,7 @@
                 this.AxApplicationMgr.IsEditor = true;
                 this.AxApplicationMgr.LoginOnStart = false;
                 this.AxApplicationMgr.Start();
-                this.modeSeq = this.engine.GetSequenceFileEx(@"C:\Program Files\National Instruments\TestStand 2020\Components\Models\TestStandModels\ParallelModel.seq");
+                //this.modeSeq = this.engine.GetSequenceFileEx(@"C:\Program Files\National Instruments\TestStand 2020\Components\Models\TestStandModels\ParallelModel.seq");
             }
             catch (Exception ex)
             {
@@ -469,28 +627,104 @@
         private void ReadConfig()
         {
             ParameterData value;
+
+
+            bool flag = false;
             try
             {
-                value = ParameterManager.GetCommonParameterByName("EnableMes");
-                _enableMes = bool.Parse(value.Value);
-                Set("EnableMes");
+                value = ParameterManager.GetCommonParameterByName("DefaultEnableMes");
+                if (value != null)
+                {
+                    flag = bool.Parse(value.Value);
+                }
             }
             catch
             {
-                _enableMes = false;
-                Set("EnableMes");
+                flag = false;
             }
+
+            if (flag)
+            {
+                EnableMes = true;
+            }
+            else
+            {
+                try
+                {
+                    value = ParameterManager.GetCommonParameterByName("EnableMes");
+                    if (value == null)
+                    {
+                        CbEnableMes.Visibility = Visibility.Collapsed;
+                    }
+                    else
+                    {
+                        _enableMes = bool.Parse(value.Value);
+                        Set("EnableMes");
+                    }
+                }
+                catch
+                {
+                    _enableMes = false;
+                    Set("EnableMes");
+                }
+            }
+
 
             try
             {
                 value = ParameterManager.GetCommonParameterByName("EnableNGPause");
-                _enableNGPause = bool.Parse(value.Value);
-                Set("EnableNGPause");
+                if (value == null)
+                {
+                    CbEnableNGPause.Visibility = Visibility.Collapsed;
+                }
+                else
+                {
+                    _enableNGPause = bool.Parse(value.Value);
+                    Set("EnableNGPause");
+                }
             }
             catch
             {
                 _enableNGPause = false;
                 Set("EnableNGPause");
+            }
+
+            try
+            {
+                value = ParameterManager.GetCommonParameterByName("EnableDebugMode");
+                if (value == null)
+                {
+                    CbEnableDebugMode.Visibility = Visibility.Collapsed;
+                }
+                else
+                {
+                    _enableDebugMode = bool.Parse(value.Value);
+                    Set("EnableDebugMode");
+                }
+            }
+            catch
+            {
+                _enableDebugMode = false;
+                Set("EnableDebugMode");
+            }
+
+            try
+            {
+                value = ParameterManager.GetCommonParameterByName("DisableScanner");
+                if (value == null)
+                {
+                    CbDisableScanner.Visibility = Visibility.Collapsed;
+                }
+                else
+                {
+                    _DisableScanner = bool.Parse(value.Value);
+                    Set("DisableScanner");
+                }
+            }
+            catch
+            {
+                _DisableScanner = false;
+                Set("DisableScanner");
             }
 
             try
@@ -505,22 +739,18 @@
                 Set("EnableCanLog");
             }
 
-            try
-            {
-                value = ParameterManager.GetCommonParameterByName("EnableDebugMode");
-                _enableDebugMode = bool.Parse(value.Value);
-                Set("EnableDebugMode");
-            }
-            catch
-            {
-                _enableDebugMode = false;
-                Set("EnableDebugMode");
-            }
 
             try
             {
                 value = ParameterManager.GetCommonParameterByName("EnableSimpleMode");
-                EnableSimpleMode = bool.Parse(value.Value);
+                if (value == null)
+                {
+                    CbEnableSimpleMode.Visibility = Visibility.Collapsed;
+                }
+                else
+                {
+                    EnableSimpleMode = bool.Parse(value.Value);
+                }
             }
             catch
             {
@@ -530,11 +760,28 @@
             try
             {
                 value = ParameterManager.GetCommonParameterByName("UI_ShowInfoDock");
-                UI_ShowInfoDock = bool.Parse(value.Value);
+                if (value == null)
+                {
+                    CbUI_ShowInfoDock.Visibility = Visibility.Collapsed;
+                }
+                else
+                {
+                    UI_ShowInfoDock = bool.Parse(value.Value);
+                }
             }
             catch
             {
                 UI_ShowInfoDock = false;
+            }
+
+            try
+            {
+                value = ParameterManager.GetCommonParameterByName("AutoExecuteSeq");
+                AutoExecuteSeq = bool.Parse(value.Value);
+            }
+            catch
+            {
+                AutoExecuteSeq = true;
             }
 
             try
@@ -551,6 +798,68 @@
             {
                 csvDir = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "TestReport");
             }
+
+            try
+            {
+
+                value = ParameterManager.GetCommonParameterByName("IsOptRequirePassword");
+                IsOptRequirePassword = bool.Parse(value.Value);
+            }
+            catch
+            {
+                IsOptRequirePassword = false;
+            }
+
+            try
+            {
+
+                value = ParameterManager.GetCommonParameterByName("UI_CurrentWorkorder");
+                currentWorkorder = value.Value;
+                Set("CurrentWorkorder");
+            }
+            catch
+            {
+                currentWorkorder = string.Empty;
+                Set("CurrentWorkorder");
+            }
+
+            try
+            {
+
+                value = ParameterManager.GetCommonParameterByName("TS_ShowTitleWorkorder");
+                var boo = bool.Parse(value.Value);
+                if (boo)
+                {
+                    workorderPanel.Visibility = Visibility.Visible;
+                }
+            }
+            catch
+            {
+            }
+
+            try
+            {
+
+                value = ParameterManager.GetCommonParameterByName("TS_DataLogPath");
+                dataLogPath = value.Value;
+            }
+            catch
+            {
+                dataLogPath = Path.Combine(PathHelper.ConfigFolder, "DataBoard");
+            }
+
+            try
+            {
+
+                value = ParameterManager.GetCommonParameterByName("TsModelPath");
+                tsModelPath = value.Value;
+            }
+            catch
+            {
+                //@"C:\Program Files\National Instruments\TestStand 2020\Components\Models\TestStandModels\ParallelModel.seq"
+                tsModelPath = @"C:\Users\Public\Documents\National Instruments\TestStand 2020 (64-bit)\Components\Models\ParallelModel.seq";
+            }
+
 
             //Convert.ToBoolean(IniFileHelper.ReadIniData("Config", "EnableMes", "true", CountIniPath));
             //EnableCanLog = Convert.ToBoolean(IniFileHelper.ReadIniData("Config", "EnableCanLog", "true", CountIniPath));
@@ -579,6 +888,27 @@
                     {
                         ts?.SequenceFileContext?.StationGlobals.SetValBoolean($"SystemSetting.{name}", 1, value);
                     }
+                    return true;
+                }
+                else
+                {
+                    throw new Exception(errMsg);
+                }
+            }
+            catch (Exception ex)
+            {
+                MsgBoxHelper2.Error(ex.Message);
+                return false;
+            }
+        }
+
+        private bool WriteIni(string name, object value)
+        {
+            //IniFileHelper.WriteIniData("Config", name, value.ToString(), CountIniPath);
+            try
+            {
+                if (ParameterManager.UpdateCommonParameter(name, value, out string errMsg))
+                {
                     return true;
                 }
                 else
@@ -664,12 +994,8 @@
             {
                 engine?.Globals.SetValString("StationState.ProductModel", 1, SelectedProduct?.Name);
                 engine?.CommitGlobalsToDisk(promptOnSaveConflicts: false);
-                this.modeSeq = this.engine.GetSequenceFileEx(@"C:\Program Files\National Instruments\TestStand 2020\Components\Models\TestStandModels\ParallelModel.seq");
-                this.testSeq = this.engine.GetSequenceFileEx(this.testSeqFile, 0, TypeConflictHandlerTypes.ConflictHandler_UseGlobalType);
-
-                //var sb = testSeq.GetSequenceByName("MainSequence");
-                //sb.
-
+                this.modeSeq = this.engine.GetSequenceFileEx(tsModelPath);
+                this.testSeq = this.engine.GetSequenceFileEx(this.testSeqFile, 2, TypeConflictHandlerTypes.ConflictHandler_UseGlobalType);
                 this.execution = this.engine.NewExecution(this.testSeq, "Test UUTs", this.modeSeq, false, 0, null, null, null);
                 IsTesting = true;
             }
@@ -708,10 +1034,6 @@
                                 win.Close();
                             });
                         }
-                        //Dispatcher.Invoke(() =>
-                        //{
-
-                        //});
                     }
                     ).Info(LangUtil.Get("App.SequenceIsStopping"));
         }
@@ -738,7 +1060,9 @@
                     }
                 }
                 if (this.execution == null) return true;
-                return this.execution.WaitForEndEx(2000, true, null, null);
+
+                bool res = this.execution.WaitForEndEx(2000, true, null, null);
+                return res;
             }
             catch (Exception ex)
             {
@@ -800,30 +1124,6 @@
             //this.Close();
         }
 
-        /// <summary>
-        /// 杩涚▼缁撴潫浜嬩欢
-        /// </summary>
-        /// <param name="sender"></param>
-        /// <param name="e"></param>
-        private void AxApplicationMgr_ExecutionClosed(object sender, _ApplicationMgrEvents_ExecutionClosedEvent e)
-        {
-            try
-            {
-                if (this.testSeq == null)
-                    return;
-                this.engine.ReleaseSequenceFileEx(this.testSeq, 0);
-                this.engine.ReleaseSequenceFileEx(this.modeSeq, 0);
-                this.engine.UnloadAllModules();
-                this.testSeq = null;
-                this.modeSeq = null;
-            }
-            catch (Exception ex)
-            {
-                log.Error("ReleaseSequenceFileEx Failed.", ex);
-                MsgBoxHelper.Error(Window.GetWindow(this), $"{LangUtil.Get("Ts.ReleaseSequenceFileFail")}: {ex.Message}");
-            }
-        }
-
         public void UpdatePositionStatus(int index, string status)
         {
             this.tsSockets[index].UpdateStatus(status);
@@ -847,18 +1147,152 @@
                 TestItems[4], TestItems[5], TestItems[6]);
         }
 
-        public void SetPositionBarcode(int index, string barcode)
+        public void SetPositionBarcode(int index, string strData)
         {
-            this.tsSockets[index].Barcode = barcode;
+            if (strData.Contains(";"))
+            {
+                var strs = strData.Split(';');
+                this.tsSockets[index].Barcode = strs[0];
+                this.tsSockets[index].Model = strs[1];
+            }
+            else
+            {
+                this.tsSockets[index].Barcode = strData;
+            }
         }
 
-        public void SavePositionCSV(int index)
+        public void SavePositionCSV(int index, string csvPath)
         {
-            var time = DateTime.Now;
-            string status = this.tsSockets[index].Status == "Passed" ? "PASS" : "FAIL";
-            string csvPath = Path.Combine(csvDir, SelectedProduct?.Name ?? "鏈煡浜у搧", time.ToString("yyyyMMdd"), status,
-                $"{this.tsSockets[index].Barcode}-{time.ToString("HHmmss")}.csv");
+            //var time = DateTime.Now;
+            //string status = this.tsSockets[index].Status == "Passed" ? "PASS" : "FAIL";
+            //string csvPath = Path.Combine(csvDir, SelectedProduct?.Name ?? "鏈煡浜у搧", time.ToString("yyyyMMdd"), status,
+            //    $"{this.tsSockets[index].Barcode}-{time.ToString("HHmmss")}.csv");
             this.tsSockets[index].WriteToCSV(csvPath);
+        }
+
+        public void SavePositionDB(int index, string status)
+        {
+            CheckSqlHelper();
+            var socket = this.tsSockets[index];
+            var time = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
+            string snr = socket.Barcode;
+
+            List<string> sqls = new List<string>();
+            foreach (var data in socket.Datasource)
+            {
+                sqls.Add($@"INSERT INTO serialData (sn,model,station,step,limitDown,limitUp,unit,value,status,finalStatus,consumeTime,totalConsumeTime,time) VALUES
+('{snr}','{socket.Model}','','{data.Name}','{data.LimitDown}','{data.LimitUp}','{data.Unit}','{data.Value}','{data.Result}','{socket.Status}','{data.ConsumeTime}','{socket.ElapseTime}','{time}')");
+            }
+            sqls.Add($@"INSERT INTO testResult (sn,model,station,result,time,position,status) VALUES 
+('{snr}','{socket.Model}','','{socket.Status}','{time}','{index}','{status}')");
+            sqliteHelper.ExecuteBatchSql(sqls);
+        }
+
+        private void HandleUIMessage(int eventCode, int index, string strData)
+        {
+            switch (eventCode)
+            {
+                case 10002://鏇存柊娴嬭瘯鐘舵��
+                    string status = strData;
+                    UpdatePositionStatus(index, status);
+                    break;
+
+                case 10003://鍙戦�佹祴璇曟暟鎹�
+                    AddTestData(index, strData);
+                    break;
+
+                case 10004://鍙戦�佹祴璇曡繃绋嬩俊鎭�
+                    this.tsSockets[index].CurrentStep = strData;
+                    break;
+
+                case 10005://鍒濆鍖栨祴璇曟暟鎹紝娓呯┖娴嬭瘯鏁版嵁
+                    this.tsSockets[index].IniTestData();
+                    break;
+
+                case 10006://鍙戦�佷骇鍝佹潯鐮�
+                    SetPositionBarcode(index, strData);
+                    break;
+
+                case 10007://寮�濮嬫祴璇曡鏃�
+                    tsSockets[index].ElapseTime = "Start Timing";
+                    BtnStopSeq.IsEnabled = false;
+                    break;
+
+                case 10008://鍋滄娴嬭瘯璁℃椂
+                    tsSockets[index].ElapseTime = "Stop Timing";
+                    BtnStopSeq.IsEnabled = true;
+                    break;
+
+                case 10009:
+                    // 
+                    break;
+
+                case 10010:
+
+                    //PropertyObj.SetValBoolean("Locals.MD5_Used", 0, true);
+                    //PropertyObj.SetValVariant("FileGlobals.MD5_Value", 0, MD5_DATA);
+                    //PropertyObj.SetValVariant("StationGlobals.MD5", 0, MD5_DATA);
+                    break;
+
+                case 10011:
+                    // write model
+
+                    break;
+
+                case 10012:
+                    // read model
+
+                    break;
+
+                case 10013:
+                    // read continue
+
+
+                    break;
+
+                case 10014:
+
+                    break;
+
+                case 10015:
+
+                    break;
+                case 10016://鏄剧ず3D鎷兼帴鍥剧墖
+
+                    break;
+                case 10017://鏇存柊娴嬭瘯璁℃椂锛岄拡瀵归儴鍒嗚鏃舵湁PLC瀹屾垚鐨勯」鐩�
+                    this.tsSockets[index].ElapseTime = strData;
+                    break;
+                case (int)UIMessageCodes.UIMsg_EndExecution://鎵ц缁撴潫
+                    IsTesting = false;
+                    //this.ReleaseSequenceFile();
+                    break;
+                case 10030://鏄剧ず娴嬭瘯杩涘害
+                    int ProcessVal = Convert.ToInt32(strData);
+                    this.tsSockets[index].SetTestProcess(ProcessVal);
+                    break;
+                case 10031://瀵煎嚭CSV
+                    string[] datas = strData.Split(';');
+                    SavePositionCSV(index, datas[0]);
+                    SavePositionDB(index, datas[1]);
+                    break;
+                case 10032://鎸変笅鏍囨殏鍋滄祴璇�
+                    this.tsSockets[index].ShowPausePanel();
+                    break;
+                case 10033:
+                    ShowAlarm(strData);
+                    break;
+                case 10099:
+                    break;
+                default:
+                    break;
+            }
+        }
+
+        private void ShowAlarm(string info)
+        {
+            AlarmShowHelper.ShowAlarm(info);
+            mSMQHelper.Send("Alarm", $"ATE娴嬭瘯 {info}");
         }
 
         /// <summary>
@@ -870,113 +1304,24 @@
         {
             try
             {
-                int EventCase = Convert.ToInt32(e.uiMsg.Event);
-                int Index = Convert.ToInt16(e.uiMsg.NumericData);//SocketIndex
+                int eventCode = Convert.ToInt32(e.uiMsg.Event);
+                int index = Convert.ToInt16(e.uiMsg.NumericData);//SocketIndex
                 string strData = e.uiMsg.StringData;
 
                 try
                 {
-                    log.Info($"Event: {EventCase}, NumericData: {Index}, StringData: {strData}");
+                    log.Info($"Event: {eventCode}, NumericData: {index}, StringData: {strData}");
                 }
                 catch
                 {
 
                 }
-
-                switch (EventCase)
+                if (eventCode == 10001)
                 {
-                    case 10001://浼犻�扴ocketContext
-                        tsSockets[Index].SequenceFileContext = (SequenceContext)e.uiMsg.ActiveXData;
-                        break;
-
-                    case 10002://鏇存柊娴嬭瘯鐘舵��
-                        string status = e.uiMsg.StringData;
-                        UpdatePositionStatus(Index, status);
-                        break;
-
-                    case 10003://鍙戦�佹祴璇曟暟鎹�
-                        AddTestData(Index, e.uiMsg.StringData);
-                        break;
-
-                    case 10004://鍙戦�佹祴璇曡繃绋嬩俊鎭�
-                        this.tsSockets[Index].CurrentStep = e.uiMsg.StringData;
-                        break;
-
-                    case 10005://鍒濆鍖栨祴璇曟暟鎹紝娓呯┖娴嬭瘯鏁版嵁
-                        this.tsSockets[Index].IniTestData();
-                        break;
-
-                    case 10006://鍙戦�佷骇鍝佹潯鐮�
-                        SetPositionBarcode(Index, e.uiMsg.StringData);
-                        break;
-
-                    case 10007://寮�濮嬫祴璇曡鏃�
-                        tsSockets[Index].ElapseTime = "Start Timing";
-                        BtnStopSeq.IsEnabled = false;
-                        break;
-
-                    case 10008://鍋滄娴嬭瘯璁℃椂
-                        tsSockets[Index].ElapseTime = "Stop Timing";
-                        BtnStopSeq.IsEnabled = true;
-                        break;
-
-                    case 10009:
-                        // 
-                        break;
-
-                    case 10010:
-
-                        //PropertyObj.SetValBoolean("Locals.MD5_Used", 0, true);
-                        //PropertyObj.SetValVariant("FileGlobals.MD5_Value", 0, MD5_DATA);
-                        //PropertyObj.SetValVariant("StationGlobals.MD5", 0, MD5_DATA);
-                        break;
-
-                    case 10011:
-                        // write model
-
-                        break;
-
-                    case 10012:
-                        // read model
-
-                        break;
-
-                    case 10013:
-                        // read continue
-
-
-                        break;
-
-                    case 10014:
-
-                        break;
-
-                    case 10015:
-
-                        break;
-                    case 10016://鏄剧ず3D鎷兼帴鍥剧墖
-
-                        break;
-                    case 10017://鏇存柊娴嬭瘯璁℃椂锛岄拡瀵归儴鍒嗚鏃舵湁PLC瀹屾垚鐨勯」鐩�
-                        this.tsSockets[Index].ElapseTime = e.uiMsg.StringData;
-                        break;
-                    case (int)UIMessageCodes.UIMsg_EndExecution://鎵ц缁撴潫
-                        IsTesting = false;
-                        // this.ReleaseSequenceFile();
-                        break;
-                    case 10030://鏄剧ず娴嬭瘯杩涘害
-                        int ProcessVal = Convert.ToInt32(e.uiMsg.StringData);
-                        this.tsSockets[Index].SetTestProcess(ProcessVal);
-                        break;
-                    case 10031://瀵煎嚭CSV
-                        SavePositionCSV(Index);
-                        break;
-                    case 10032://鎸変笅鏍囨殏鍋滄祴璇�
-                        this.tsSockets[Index].ShowPausePanel();
-                        break;
-                    default:
-                        break;
+                    tsSockets[index].SequenceFileContext = (SequenceContext)e.uiMsg.ActiveXData;
+                    return;
                 }
+                HandleUIMessage(eventCode, index, strData);
             }
             catch (Exception ex)
             {
@@ -1006,7 +1351,10 @@
             string name = product.Name;
             List<ParameterData> parameters = ProductManager.GetParametersByProductName(name);
             testSeqFile = parameters.FirstOrDefault(p => p.Name == "TestSequence")?.Value?.ToString();
-            StartSequence();
+            if (AutoExecuteSeq)
+            {
+                StartSequence();
+            }
         }
 
         private void ClearNum()
@@ -1029,13 +1377,6 @@
             try
             {
                 StopSequence();
-                // this.engine?.TerminateAll();
-                // this.engine?.ReleaseSequenceFileEx(this.testSeq, 0);
-                // this.engine?.ReleaseSequenceFileEx(this.modeSeq, 0);
-                // this.engine?.UnloadAllModules();
-                // this.engine?.ShutDown(true);
-                //this.testSeq = null;
-                //this.modeSeq = null;
                 base.OnClose(sender, e);
             }
             catch (Exception ex)
@@ -1044,6 +1385,58 @@
             }
         }
 
+        public override void DoClose(object sender, EventArgs e)
+        {
+            base.DoClose(sender, e);
+        }
+
+        /// <summary>
+        /// 閲婃斁鎵�鏈夌殑搴忓垪鏂囦欢
+        /// </summary>
+        private bool ReleaseSequenceFile()
+        {
+            try
+            {
+                lock (this)
+                {
+                    //execution.Abort();
+                    int count = 10;
+                    while (count > 0)
+                    {
+                        try
+                        {
+                            if (this.testSeq == null)
+                                return true;
+
+                            if (this.engine.ReleaseSequenceFileEx(this.testSeq, 4))
+                            {
+                                this.testSeq = null;
+                            }
+                            if (this.engine.ReleaseSequenceFileEx(this.modeSeq, 4))
+                            {
+                                this.modeSeq = null;
+                            }
+                            this.engine.UnloadAllModules();
+                            return this.testSeq == null && this.modeSeq == null;
+                        }
+                        catch (Exception ex)
+                        {
+                            log.Warn($"ReleaseSequenceFile In {count} Times Fail.", ex);
+                            count--;
+                            System.Threading.Thread.Sleep(1000);
+                        }
+                    }
+                    log.Warn($"ReleaseSequenceFile Failed.");
+                    return false;
+                }
+            }
+            catch (Exception ex)
+            {
+                log.Warn("ReleaseSequenceFile Error.", ex);
+                return false;
+            }
+        }
+
         private void PluginControl_SizeChanged(object sender, SizeChangedEventArgs e)
         {
 

--
Gitblit v1.9.1