From 16e188758b164ed959090dd5149d109b7a9adb92 Mon Sep 17 00:00:00 2001
From: schangxiang@126.com <schangxiang@126.com>
Date: 周四, 05 9月 2024 11:40:08 +0800
Subject: [PATCH] 10和40  上线逻辑回退

---
 DataCapture/iWare_SCADA_DataCapture/iWare_SCADA_BusinessLogical/DataCaptureHandlerV2/Special/DataCaptureHandler_OP7009.cs |   86 +++++++++++++++++++------------------------
 1 files changed, 38 insertions(+), 48 deletions(-)

diff --git a/DataCapture/iWare_SCADA_DataCapture/iWare_SCADA_BusinessLogical/DataCaptureHandlerV2/Special/DataCaptureHandler_OP7009.cs b/DataCapture/iWare_SCADA_DataCapture/iWare_SCADA_BusinessLogical/DataCaptureHandlerV2/Special/DataCaptureHandler_OP7009.cs
index cbfd2ca..e0d6bd9 100644
--- a/DataCapture/iWare_SCADA_DataCapture/iWare_SCADA_BusinessLogical/DataCaptureHandlerV2/Special/DataCaptureHandler_OP7009.cs
+++ b/DataCapture/iWare_SCADA_DataCapture/iWare_SCADA_BusinessLogical/DataCaptureHandlerV2/Special/DataCaptureHandler_OP7009.cs
@@ -62,19 +62,19 @@
                 }
                 while (true)
                 {
-                    ThreadStatusMonitor threadStatusMonitor = new ThreadStatusMonitor();
-                    threadStatusMonitor.Threadcode = DataCapturePointCode;
-                    threadStatusMonitor.Threadcname = DataCapturePointCname;
-                    threadStatusMonitor.Threadendtime = DateTime.Now;
-                    //threadStatusMonitor.Threadlastmodifytime = DateTime.Now;
-                    threadStatusMonitor.Threadstatue = 0;
-                    threadStatusMonitor.ThreadId = Thread.CurrentThread.ManagedThreadId.ToString();
+                    //ThreadStatusMonitor threadStatusMonitor = new ThreadStatusMonitor();
+                    //threadStatusMonitor.Threadcode = DataCapturePointCode;
+                    //threadStatusMonitor.Threadcname = DataCapturePointCname;
+                    //threadStatusMonitor.Threadendtime = DateTime.Now;
+                    ////threadStatusMonitor.Threadlastmodifytime = DateTime.Now;
+                    //threadStatusMonitor.Threadstatue = 0;
+                    //threadStatusMonitor.ThreadId = Thread.CurrentThread.ManagedThreadId.ToString();
                     try
                     {
                         //_dataCaptureConfig
                         if (plcService == null || !plcService.IsConnected)
                         {
-                            threadStatusMonitor.ErrorMsg = $" {RandomHelper.GenerateRandomCode(4)} {_dataCaptureConfig.WorkingProcedure} PLC杩炴帴宸叉柇寮�锛屾鍦ㄥ皾璇曟墦寮�!";
+                            // threadStatusMonitor.ErrorMsg = $" {RandomHelper.GenerateRandomCode(4)} {_dataCaptureConfig.WorkingProcedure} PLC杩炴帴宸叉柇寮�锛屾鍦ㄥ皾璇曟墦寮�!";
 
                             SystemValue.lbl_Alert_OP1002 = $" {RandomHelper.GenerateRandomCode(4)} {WorkingProcedure} PLC杩炴帴宸叉柇寮�锛屾鍦ㄥ皾璇曟墦寮�!";
                             SystemValue.PLCServiceReconnect(plcService);
@@ -85,20 +85,34 @@
                         }
                         else
                         {
-                            Log4NetHelper.WriteInfoLog(PLCManger.GetLogTypeForWorkingProcedure(WorkingProcedure), $" {DataCapturePointCode}宸ュ簭娴嬫爣璁拌鍙杮DateTime.Now} *****0***");
+
+                            //鑾峰彇OP70鏈粨鏉熺殑宸ヤ欢鍒楄〃
+                            var ooDateTime = Convert.ToDateTime("0001-01-01");
+                            var findTime = DateTime.Now.AddHours(-12);
+                            List<WorkPieceProcess> noFinishWorkPieceProcessList = null;
+                            using (DbModel db = new DbModel())
+                            {
+                                var dateTime = DateTime.Now;
+                                noFinishWorkPieceProcessList = db.WorkPieceProcess.Where(x => x.CreatedTime >= findTime
+                                  && x.WorkingProcedureCurrent == WorkingProcedure
+                                  && x.EndTime == ooDateTime).ToList();
+                            }
+                            if (noFinishWorkPieceProcessList?.Count <= 0)
+                            {
+                                continue;
+                            }
 
 
-                            Log4NetHelper.WriteInfoLog(PLCManger.GetLogTypeForWorkingProcedure(WorkingProcedure), $" {DataCapturePointCode}宸ュ簭娴嬫爣璁拌鍙杮DateTime.Now}***1****");
-
-                            threadStatusMonitor.Threadlastmodifytime = DateTime.Now;
+                            // threadStatusMonitor.Threadlastmodifytime = DateTime.Now;
                             WorkPieceLogMiddle wplog = new WorkPieceLogMiddle();
                             wplog.Id = Yitter.IdGenerator.YitIdHelper.NextId();
                             wplog.WorkingProcedure = WorkingProcedure;
                             wplog.EquipmentID = _dataCaptureConfig.EquipmentID;
                             wplog.Remarks = WorkingProcedure;
                             wplog.MonitoringPoint = DataCapturePointCode;
+                            //wplog.CreatedUserName = DataCapturePointCode;
+                            SystemBussinessHelper.SetWorkPieceLogMiddleForCreatedUserName(ref wplog, DataCapturePointCode, DataCapturePointCname);
                             wplog.CreatedTime = DateTimeHelper.GetDateTime();
-                            wplog.CreatedUserName = DataCapturePointCode;
                             wplog.UpdatedTime = DateTimeHelper.GetDateTime();
                             wplog.UpdatedUserName = Environment.MachineName + "鑷姩" + Thread.CurrentThread.ManagedThreadId.ToString();
                             wplog.OnlineTime = DateTimeHelper.GetDateTime();
@@ -114,9 +128,9 @@
                                     var set = wplog.GetType().GetProperty(col.DataCaptureColumnTabelName);
                                     if (set == null)
                                     {
-                                        Log4NetHelper.WriteErrorLog(PLCManger.GetLogTypeForWorkingProcedure(WorkingProcedure), $" {WorkingProcedure}宸ュ簭鐩戞帶璇荤爜鏍囪 璇诲彇宸ヤ欢鐮佸姩鎬佺敱浜庡瓧娈靛悕娌℃壘鍒帮紝璧嬪�笺�恵WorkingProcedure ?? "绌哄瓧绗︿覆"}銆戝け璐wplog.Id}");
+                                        Log4NetHelper.WriteErrorLog(LogType.OP7009, $" {WorkingProcedure}宸ュ簭鐩戞帶璇荤爜鏍囪 璇诲彇宸ヤ欢鐮佸姩鎬佺敱浜庡瓧娈靛悕娌℃壘鍒帮紝璧嬪�笺�恵WorkingProcedure ?? "绌哄瓧绗︿覆"}銆戝け璐wplog.Id}");
                                     }
-                                    Log4NetHelper.WriteInfoLog(PLCManger.GetLogTypeForWorkingProcedure(WorkingProcedure), $" {DataCapturePointCode}宸ュ簭娴嬫爣璁拌鍙杮DateTime.Now}***2****{col.DataCaptureColumnTabelName} 鍊� {valuecol.ToString() ?? ""}");
+                                    Log4NetHelper.WriteInfoLog(LogType.OP7009, $" {DataCapturePointCode}宸ュ簭娴嬫爣璁拌鍙杮DateTime.Now}***2****{col.DataCaptureColumnTabelName} 鍊� {valuecol.ToString() ?? ""}");
 
                                     if (col.DataCaptureColumnTabelName.Contains("Quality"))
                                     {//瀛楁鍚嶅寘鍚玅uality鏄涓烘槸璐ㄩ噺鏁版嵁锛岄兘鏄浆鎹㈡垚string
@@ -129,70 +143,46 @@
                                 }
                                 catch (Exception setex)
                                 {
-                                    Log4NetHelper.WriteErrorLog(PLCManger.GetLogTypeForWorkingProcedure(WorkingProcedure), $" {WorkingProcedure}宸ュ簭鐩戞帶璇荤爜鏍囪 璇诲彇宸ヤ欢鐮佸姩鎬佽祴鍊笺�恵WorkingProcedure ?? "绌哄瓧绗︿覆"}銆戝紓甯竰wplog.Id}", setex);
+                                    Log4NetHelper.WriteErrorLog(LogType.OP7009, $" {WorkingProcedure}宸ュ簭鐩戞帶璇荤爜鏍囪 璇诲彇宸ヤ欢鐮佸姩鎬佽祴鍊笺�恵WorkingProcedure ?? "绌哄瓧绗︿覆"}銆戝紓甯竰wplog.Id}", setex);
                                 }
                             }
 
-                            Log4NetHelper.WriteInfoLog(PLCManger.GetLogTypeForWorkingProcedure(WorkingProcedure), $" {DataCapturePointCode}宸ュ簭娴嬫爣璁拌鍙杮DateTime.Now}***3****");
-
                             if (string.IsNullOrEmpty(wplog.QualityOP70To1) && string.IsNullOrEmpty(wplog.QualityOP70To2) && string.IsNullOrEmpty(wplog.QualityOP70To3))
                             {
-                                Log4NetHelper.WriteInfoLog(PLCManger.GetLogTypeForWorkingProcedure(WorkingProcedure), $"璇诲彇 {DataCapturePointCode}璐ㄩ噺淇℃伅涓変釜鍊奸兘鏄┖鐨勶細");
+                                //Log4NetHelper.WriteInfoLog(LogType.OP7009, $"璇诲彇 {DataCapturePointCode}璐ㄩ噺淇℃伅涓変釜鍊奸兘鏄┖鐨勶細");
                                 continue;
                             }
 
-                            //鑾峰彇OP70鏈粨鏉熺殑宸ヤ欢鍒楄〃
-                            var ooDateTime = Convert.ToDateTime("0001-01-01");
-                            List<WorkPieceProcess> noFinishWorkPieceProcessList = null;
-                            using (DbModel db = new DbModel())
-                            {
-                                var dateTime = DateTime.Now;
-                                noFinishWorkPieceProcessList = db.WorkPieceProcess.Where(x => x.CreatedTime >= DateTime.Now.AddHours(-12)
-                                  && x.WorkingProcedureCurrent == WorkingProcedure
-                                  && x.EndTime == ooDateTime).ToList();
-                            }
+
                             if (noFinishWorkPieceProcessList?.Count > 0)
                             {
                                 foreach (var item in noFinishWorkPieceProcessList)
                                 {
                                     wplog.WorkPieceID = item.WorkPieceID;
-                                    WorkPieceInfoManager.QualityInfoCompleteForOP70(wplog, PLCManger.GetLogTypeForWorkingProcedure(WorkingProcedure));
-                                    threadStatusMonitor.Threadstatue = 1;
+                                    WorkPieceInfoManager.QualityInfoCompleteForOP70(wplog, LogType.OP7009);
+                                    // threadStatusMonitor.Threadstatue = 1;
                                 }
                             }
-                            else
-                            {
-                                Log4NetHelper.WriteInfoLog(PLCManger.GetLogTypeForWorkingProcedure(WorkingProcedure), $"璇诲彇 {DataCapturePointCode}璐ㄩ噺淇℃伅涓変釜鍊兼湁鍊硷紝浣嗘槸鑾峰彇OP70鏈粨鏉熺殑宸ヤ欢鍒楄〃涓虹┖锛�");
-                            }
                         }
-
-
                         SystemValue.lbl_Alert_OP1002 = $"abcdefg:{RandomHelper.GenerateRandomCode(4)}";
-                        if (!_dataCaptureConfig.DataCaptureFrequency.HasValue || _dataCaptureConfig.DataCaptureFrequency < 10)
-                        {
-                            Thread.Sleep(5000);
-                        }
-                        else
-                        {
-                            Thread.Sleep(_dataCaptureConfig.DataCaptureFrequency.Value);
-                        }
+                        Thread.Sleep(5000);
 
                     }
                     catch (Exception ex)
                     {
                         SystemValue.lbl_Alert_OP1002 = $" {RandomHelper.GenerateRandomCode(4)} 璇诲彇{DataCapturePointCode}璐ㄩ噺淇℃伅 鍑虹幇寮傚父锛岃鏌ョ湅鏃ュ織锛�";
-                        Log4NetHelper.WriteErrorLog(PLCManger.GetLogTypeForWorkingProcedure(WorkingProcedure), $"璇诲彇 {DataCapturePointCode}璐ㄩ噺淇℃伅鏃跺紓甯革細", ex);
+                        Log4NetHelper.WriteErrorLog(LogType.OP7009, $"璇诲彇 {DataCapturePointCode}璐ㄩ噺淇℃伅鏃跺紓甯革細", ex);
                     }
                     finally
                     {
-                        WorkPieceInfoManager.ThreadMonitor(threadStatusMonitor);
+                        //WorkPieceInfoManager.ThreadMonitor(threadStatusMonitor);
                     }
                 }
             }
             else
             {
                 SystemValue.lbl_Alert_OP1002 = $" {RandomHelper.GenerateRandomCode(4)} {DataCapturePointCode}璐ㄩ噺淇℃伅 涓嶅仛鏍¢獙锛岃纭閰嶇疆淇℃伅锛�";
-                Log4NetHelper.WriteInfoLog(PLCManger.GetLogTypeForWorkingProcedure(WorkingProcedure), $"{DataCapturePointCode}璐ㄩ噺淇℃伅 涓嶅仛鏍¢獙锛岃纭鏄惁閰嶇疆寮傚父");
+                Log4NetHelper.WriteInfoLog(LogType.OP7009, $"{DataCapturePointCode}璐ㄩ噺淇℃伅 涓嶅仛鏍¢獙锛岃纭鏄惁閰嶇疆寮傚父");
             }
         }
 

--
Gitblit v1.9.3