From e69865a1a3739740201bac8782b721da35d49923 Mon Sep 17 00:00:00 2001
From: patrick.xu <patrick.xu@broconcentric.com>
Date: 星期一, 25 一月 2021 18:45:28 +0800
Subject: [PATCH] 1. gocator添加重试和清理缓存操作 2. gts板卡调整监听频率 3. 记录产品数据使用filsstream避免程序崩溃影响

---
 src/Bro.Device.Gocator/GocatorDriver.cs |  172 ++++++++++++++++++++++++++++++++++++++++++++++-----------
 1 files changed, 138 insertions(+), 34 deletions(-)

diff --git a/src/Bro.Device.Gocator/GocatorDriver.cs b/src/Bro.Device.Gocator/GocatorDriver.cs
index a45de96..52c32df 100644
--- a/src/Bro.Device.Gocator/GocatorDriver.cs
+++ b/src/Bro.Device.Gocator/GocatorDriver.cs
@@ -13,6 +13,7 @@
 using System.Drawing;
 using System.IO;
 using System.Linq;
+using System.Runtime.CompilerServices;
 using System.Runtime.InteropServices;
 using System.Text;
 using System.Threading;
@@ -139,10 +140,12 @@
                                 //imgSet.HImage.GenImage1("int4", (int)width, zoomHeight, zoomPtr);
                                 imgSet.HImage.GenImage1(IIConfig.ByteNums == GocatorDataByteNums.Byte2 ? "uint2" : "int4", (int)width, zoomHeight, zoomPtr);
 
-                                imgSet.HImage_2 = imgSet.HImage.Clone();
+                                //imgSet.HImage_2 = imgSet.HImage.Clone();
                                 //imgSet.HImage_2.GenImage1("uint2", (int)width, zoomHeight, zoomPtr);
                                 //imgSet.HImage_2.GenImage1("int4", (int)width, zoomHeight, zoomPtr);
-                                //imgSet.HImage_2.GenImage1(IIConfig.ByteNums == GocatorDataByteNums.Byte2 ? "uint2" : "int4", (int)width, zoomHeight, zoomPtr);
+
+                                imgSet.HImage_2 = new HImage();
+                                imgSet.HImage_2.GenImage1(IIConfig.ByteNums == GocatorDataByteNums.Byte2 ? "uint2" : "int4", (int)width, zoomHeight, zoomPtr);
 
                                 LaserScanParam para = new LaserScanParam()
                                 {
@@ -216,25 +219,47 @@
             }
         }
 
+        [MethodImpl(MethodImplOptions.Synchronized)]
         public override IImageSet Snapshot(IOperationConfig config)
         {
+            GocatorOperationConfig opConfig = config as GocatorOperationConfig;
             if (!IIConfig.IsAsyncMode)
             {
-                if (config is GocatorOperationConfig opConfig)
+                if (opConfig.IsOpenConnection)
                 {
-                    if (opConfig.IsOpenConnection)
+                    while (sensor.State != GoState.Ready)
                     {
-                        system.Start();
-                    }
-                    else
-                    {
-                        system.Stop();
+                        Thread.Sleep(10);
                     }
 
-                    if (!opConfig.IsSnapshotAction)
+                    do
                     {
-                        return null;
-                    }
+                        try
+                        {
+                            sensor.Start();
+                            LogAsync(DateTime.Now, $"浼犳劅鍣ㄧ姸鎬侊細{sensor.State.ToString()}", "");
+                            if (sensor.State != GoState.Running)
+                            {
+                                Thread.Sleep(100);
+                            }
+                            else
+                            {
+                                break;
+                            }
+                        }
+                        catch (Exception ex)
+                        {
+                            LogAsync(DateTime.Now, $"寮�鍚紓甯革細{ex.GetExceptionMessage()}", "");
+                            Thread.Sleep(100);
+                        }
+                    } while (true);
+
+                    LogAsync(DateTime.Now, $"浼犳劅鍣ㄥ惎鍔ㄦ垚鍔�", "");
+                }
+
+                if (!opConfig.IsSnapshotAction)
+                {
+                    return null;
                 }
             }
 
@@ -258,24 +283,81 @@
             }
             else
             {
-                try
+                if (!opConfig.IsSnapshotAction)
                 {
-                    dataSet = system.ReceiveData(IIConfig.SnapshotTimeout);
-                }
-                catch (Exception ex)
-                {
-                    LogAsync(DateTime.Now, $"{Name}鑾峰彇鍥惧儚寮傚父", ex.GetExceptionMessage());
                     return null;
+                }
+
+                int reTryTime = 3;
+                do
+                {
+                    try
+                    {
+                        dataSet = system.ReceiveData(IIConfig.SnapshotTimeout);
+                        reTryTime = 0;
+                    }
+                    catch (Exception ex)
+                    {
+                        reTryTime--;
+                        LogAsync(DateTime.Now, $"{Name}鑾峰彇鍥惧儚寮傚父", ex.GetExceptionMessage());
+
+                        if (reTryTime <= 0)
+                        {
+                            imgSet.HImage = null;
+                            dataSet = null;
+                            system.ClearData();
+                        }
+                    }
+                } while (reTryTime > 0);
+            }
+
+            if (!IIConfig.IsAsyncMode)
+            {
+                if (!opConfig.IsOpenConnection)
+                {
+                    while (sensor.State == GoState.Busy)
+                    {
+                        Thread.Sleep(100);
+                    }
+
+                    do
+                    {
+                        try
+                        {
+                            sensor.Stop();
+
+                            LogAsync(DateTime.Now, $"浼犳劅鍣ㄧ姸鎬侊細{sensor.State.ToString()}", "");
+                            if (sensor.State != GoState.Ready)
+                            {
+                                Thread.Sleep(100);
+                            }
+                            else
+                            {
+                                break;
+                            }
+                        }
+                        catch (Exception ex)
+                        {
+                            LogAsync(DateTime.Now, $"鍏抽棴寮傚父锛歿ex.GetExceptionMessage()}", "");
+                            Thread.Sleep(100);
+                        }
+                    } while (true);
+
+                    sensor.Flush();
+                    LogAsync(DateTime.Now, $"浼犳劅鍣ㄥ叧闂垚鍔�", "");
                 }
             }
 
-            HandleGoData(dataSet, imgSet);
-
-            dataSet.Dispose();
-
-            if (imgSet.HImage == null)
+            if (dataSet != null)
             {
-                LogAsync(DateTime.Now, $"{Name}鏈兘鑾峰彇HImage鍥惧儚", "");
+                HandleGoData(dataSet, imgSet);
+
+                dataSet.Dispose();
+
+                if (imgSet.HImage == null)
+                {
+                    LogAsync(DateTime.Now, $"{Name}鏈兘鑾峰彇HImage鍥惧儚", "");
+                }
             }
 
             return imgSet;
@@ -376,8 +458,22 @@
         {
             base.Start();
 
-            if (IIConfig.IsAsyncMode)
+            if (sensor.State != GoState.Ready)
+            {
                 system.Start();
+            }
+
+            if (IIConfig.IsAsyncMode)
+            {
+                sensor.Start();
+            }
+            else
+            {
+                //if (sensor.State == GoState.Ready)
+                {
+                    sensor.Stop();
+                }
+            }
         }
 
         protected override void Stop()
@@ -535,21 +631,29 @@
             });
         }
 
-        public override void ClearImageSet(IImageSet set)
-        {
-            if (set.IsOriginSaved && set.IsFitSaved && set.IsAddtionalSaved)
-            {
-                (set as GoImageSet).HImage_2?.Dispose();
-                (set as GoImageSet).HImage_2 = null;
-            }
+        //public override void ClearImageSet(IImageSet set)
+        //{
+        //    if (set.IsOriginSaved && set.IsFitSaved && set.IsAddtionalSaved)
+        //    {
+        //        (set as GoImageSet).HImage_2?.Dispose();
+        //        (set as GoImageSet).HImage_2 = null;
+        //    }
 
-            base.ClearImageSet(set);
-        }
+        //    base.ClearImageSet(set);
+        //}
         #endregion
     }
 
     public class GoImageSet : ImageSet
     {
         public HImage HImage_2 { get; set; }
+
+        public override void Dispose()
+        {
+            base.Dispose();
+
+            HImage_2?.Dispose();
+            HImage_2 = null;
+        }
     }
 }

--
Gitblit v1.8.0