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.UI.Config/MenuForms/FrmStatistic.cs |   97 +++++++++++++++++++++++++++++++++++++++---------
 1 files changed, 79 insertions(+), 18 deletions(-)

diff --git a/src/Bro.UI.Config/MenuForms/FrmStatistic.cs b/src/Bro.UI.Config/MenuForms/FrmStatistic.cs
index 30b5409..d587aca 100644
--- a/src/Bro.UI.Config/MenuForms/FrmStatistic.cs
+++ b/src/Bro.UI.Config/MenuForms/FrmStatistic.cs
@@ -5,7 +5,9 @@
 using System;
 using System.Configuration;
 using System.IO;
+using System.Runtime.CompilerServices;
 using System.Threading.Tasks;
+using System.Windows.Forms;
 using WeifenLuo.WinFormsUI.Docking;
 using static Bro.Common.Helper.EnumHelper;
 
@@ -403,10 +405,10 @@
                 CurrentState = RunState.Stop;
             }
 
-            if (state == EnumHelper.DeviceState.DSClose)
-            {
-                SaveNumRecord();
-            }
+            //if (state == EnumHelper.DeviceState.DSClose)
+            //{
+            //    SaveNumRecord();
+            //}
         }
 
         private void CheckIdle(object state)
@@ -436,7 +438,7 @@
 
             Task.Run(() =>
             {
-                SaveNumRecord();
+                SaveNumRecord(Qty_OK, Qty_NG);
             });
         }
 
@@ -505,22 +507,52 @@
             AvailableTime = AvailableTime.Add(new TimeSpan(0, 0, 1));
         }
 
-        private void OnClearQty()
-        {
-            Qty_OK = Qty_NG = 0;
-        }
+        //private void OnClearQty()
+        //{
+        //    Qty_OK = Qty_NG = 0;
+        //}
 
         string numRecordFile = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "Statistic.json");
         static object numLock = new object();
-        private void SaveNumRecord()
+
+        [MethodImpl(MethodImplOptions.Synchronized)]
+        private void SaveNumRecord(int okNum, int ngNum)
         {
             lock (numLock)
             {
-                using (StreamWriter writer = new StreamWriter(numRecordFile, false, System.Text.Encoding.UTF8))
+                try
                 {
-                    string dataStr = JsonConvert.SerializeObject(new { Qty_OK, Qty_NG });
-                    writer.Write(dataStr);
-                    writer.Flush();
+                    //using (StreamWriter writer = new StreamWriter(numRecordFile, false, System.Text.Encoding.UTF8))
+                    //{
+                    //    if (okNum % 5 == 0)
+                    //    {
+                    //        Application.Exit();
+                    //        throw new AccessViolationException();
+                    //    }
+                    //    string dataStr = JsonConvert.SerializeObject(new StatisticModel() { Qty_OK = okNum, Qty_NG = ngNum });
+                    //    if (!string.IsNullOrWhiteSpace(dataStr))
+                    //    {
+                    //        writer.Write(dataStr);
+                    //        writer.Flush();
+                    //    }
+                    //}
+
+                    using (FileStream fs = new FileStream(numRecordFile, FileMode.OpenOrCreate, FileAccess.Write))
+                    {
+                        fs.Seek(0, SeekOrigin.Begin);
+
+                        string dataStr = JsonConvert.SerializeObject(new StatisticModel() { Qty_OK = okNum, Qty_NG = ngNum });
+
+                        byte[] dataBuf = System.Text.Encoding.UTF8.GetBytes(dataStr);
+                        fs.Write(dataBuf, 0, dataBuf.Length);
+                        fs.SetLength(dataBuf.Length);
+                        fs.Flush();
+                        fs.Close();
+                    }
+                }
+                catch (Exception ex)
+                {
+                    LogAsync(DateTime.Now, $"淇濆瓨缁熻鏁版嵁寮傚父锛寋ex.GetExceptionMessage()}");
                 }
             }
         }
@@ -535,21 +567,50 @@
                     {
                         string dataStr = reader.ReadToEnd();
 
-                        JObject data = JsonConvert.DeserializeObject<JObject>(dataStr);
+                        //JObject data = JsonConvert.DeserializeObject<JObject>(dataStr);
 
-                        if (data != null)
+                        //if (data != null)
+                        //{
+                        //    Qty_OK = data.Value<int>("Qty_OK");
+                        //    Qty_NG = data.Value<int>("Qty_NG");
+                        //}
+
+                        StatisticModel model = JsonConvert.DeserializeObject<StatisticModel>(dataStr);
+                        if (model != null)
                         {
-                            Qty_OK = data.Value<int>("Qty_OK");
-                            Qty_NG = data.Value<int>("Qty_NG");
+                            Qty_OK = model.Qty_OK;
+                            Qty_NG = model.Qty_NG;
+                        }
+                        else
+                        {
+                            //LogAsync(DateTime.Now, $"杞藉叆缁熻鏁版嵁閿欒", "");
+                            MessageBox.Show($"杞藉叆缁熻鏁版嵁閿欒");
                         }
                     }
                 }
+            }
+            else
+            {
+                //LogAsync(DateTime.Now, $"缁熻鏁版嵁鏂囦欢涓嶅瓨鍦�", "");
+                MessageBox.Show($"缁熻鏁版嵁鏂囦欢涓嶅瓨鍦�");
             }
         }
 
         private void btnClearStatistic_Click(object sender, EventArgs e)
         {
+            //Qty_OK = Qty_NG = 0;
+        }
+
+        private void tsmiClearQty_Click(object sender, EventArgs e)
+        {
             Qty_OK = Qty_NG = 0;
         }
     }
+
+    public class StatisticModel
+    {
+        public int Qty_OK { get; set; }
+
+        public int Qty_NG { get; set; }
+    }
 }

--
Gitblit v1.8.0