From 761aaf597639c55c6f36b03f3a89ba2d49a1d3f4 Mon Sep 17 00:00:00 2001
From: schangxiang@126.com <schangxiang@126.com>
Date: 周二, 03 12月 2024 19:24:03 +0800
Subject: [PATCH] 增加是否允许切纸

---
 CC/iWareCC_ASRS/FormCC.cs |  441 +++++++++++++++++++++++++++++++++++++++---------------
 1 files changed, 314 insertions(+), 127 deletions(-)

diff --git a/CC/iWareCC_ASRS/FormCC.cs b/CC/iWareCC_ASRS/FormCC.cs
index 115e906..0e8a877 100644
--- a/CC/iWareCC_ASRS/FormCC.cs
+++ b/CC/iWareCC_ASRS/FormCC.cs
@@ -1,39 +1,51 @@
-锘縰sing iWareCC.BLL;
+锘縰sing Admin.NET.Application;
 using iWareCC.Common.Helper;
 using iWareCC.DeviceThreadFactory;
 using iWareCC.Forms;
 using iWareCC.RgvService;
 using iWareCC.SrmService;
+using iWareCC.StationService;
+using iWareCC.ThreadService;
+using iWareCC.ThreadService._03_BZ12_鏈哄櫒浜虹爜鍖呭伐浣峗;
+using iWareCC.ThreadService._04_BZ21_鎼繍鏁村灈鏈哄櫒浜篲;
 using iWareCC.WCF;
-using iWareCommon;
 using iWareCommon.Common.Globle;
 using iWareCommon.Utils;
 using iWareModel;
 using iWareModel.Entity.AGV;
 using iWareSql.DataAccess;
 using iWareSql.DBModel;
-using iWareSql.Orm;
+using iWareSql.WmsDBModel;
 using Newtonsoft.Json;
 using System;
 using System.Collections.Generic;
-using System.ComponentModel;
 using System.Data;
 using System.Drawing;
 using System.Linq;
 using System.Linq.Expressions;
 using System.Net;
 using System.ServiceModel;
-using System.Text;
 using System.Threading;
-using System.Threading.Tasks;
 using System.Windows.Forms;
 using XiGang.Core.Model;
 using XiGang.Core.Model.ViewModels;
+
 
 namespace iWareCC
 {
     public partial class FormCC : Form
     {
+
+        /// <summary>
+        /// 鍏ㄥ眬鈥旀槸鍚﹀彲浠ヨ繍琛屾墽琛屽嚭搴撴ā寮�
+        /// </summary>
+        public static bool IsAllowRunOutMode = false;
+
+        /// <summary>
+        /// 褰撳墠涓嬪彂鍑哄簱浠诲姟鐨勫寘鍙�
+        /// </summary>
+        public static string currHandlerPackageCodeForIssueOutboundTask = "";
+
         /// <summary>
         /// 1鍙峰爢鍨涙満鍏ュ簱鍙f壂鐮佸己鍒堕獙璇侀�氳繃
         /// </summary>
@@ -121,6 +133,9 @@
 
         public static RgvView rgvView;//Rgv瀹炰綋绫�
         public static RgvService.RgvServiceClient rgvServiceClient = null;
+
+        public static StationView stationView;//绔欑偣瀹炰綋绫�
+        public static StationServiceClient stationServiceClient = null;
         public FormCC()
         {
             InitializeComponent();
@@ -182,70 +197,79 @@
             tskGetRgv1Info = new Thread(GetRgvInfo);
             tskGetRgv1Info.Start();
 
+            var tskGetStationInfo = new Thread(GetStationInfo);
+            tskGetStationInfo.Start();
+
             //鍫嗗灈鏈篣I璧嬪��
             SetSrmUI();
+
+            tskSetSrmLable = new Thread(SrmRead_Label);
+            tskSetSrmLable.Start();
 
             #endregion
 
             #region 璁剧疆鏄剧ずUI
-            tskSetSrmLable = new Thread(SrmRead_Label);
-            tskSetSrmLable.Start();
-            tskSetRgvLable = new Thread(SetRgvLable);
-            tskSetRgvLable.Start();
+
+
             #endregion
 
             #region 鏈嶅姟绾跨▼鍚姩
 
             //鍫嗗灈鏈轰换鍔℃湇鍔$嚎绋嬪惎鍔�
-            var srmService = DeviceThreadServiceFactory.GetHandle(EDeviceType.鍫嗗灈鏈�);
-            srmService.StartService();
+            //var srmService = DeviceThreadServiceFactory.GetHandle(EDeviceType.鍫嗗灈鏈�);
+            //  srmService.StartService();
             //RGV浠诲姟鏈嶅姟绾跨▼鍚姩
-            var rgvService = DeviceThreadServiceFactory.GetHandle(EDeviceType.RGV);
-            rgvService.StartService();
+            //var rgvService = DeviceThreadServiceFactory.GetHandle(EDeviceType.RGV);
+            // rgvService.StartService();
 
 
-            //澶勭悊銆愪笅鍙戜腑銆戠殑鍑哄簱璁″垝浠诲姟
-            new Thread(OutPlanTaskDecompose.HandlerIssuingTask).Start();
 
-            //浠诲姟鍒嗚В绾跨▼-鍑哄簱
-            new Thread(MainTaskDecompose.HandlerMainTaskDecompose).Start();
+            new Thread(DataProcess_RobotBuffer_ModeChange.Handler).Start();
 
-            //浠诲姟鍒嗚В绾跨▼-缁勭洏鍏ュ簱
-            new Thread(MainTaskDecompose_ZPRK.HandlerMainTaskDecompose_ZPRK).Start();
+            new Thread(DataProcess_RobotBuffer_IssueOutboundTask.Handler).Start();
 
-            //绌烘墭鐩樿浆杩愪换鍔�
-            new Thread(EmptySalverTransferTask.Handler).Start();
 
-            //鑷姩缁勭洏浠诲姟
-            new Thread(AutoSalverMaterialBindTask.Handler).Start();
+            new Thread(DataProcess_RobotBuffer_AutoQiTaoOutbound.Handler).Start();
 
-            //鑷姩缁勭洏涓嬪彂浠诲姟
-            new Thread(AutoIssueInStoreTask.Handler).Start();
+            new Thread(DataProcess_RobotBuffer_FinishTaskForOutbound.Handler).Start();
 
-            //閲嶆柊鑾峰彇鍙戝姩鏈轰俊鎭�
-            new Thread(AutoUpdateEngineInfoTask.Handler).Start();
 
-            //1014搴撲綅杞繍鍒�1020绾跨▼
-            new Thread(Place1014To1020Task.Handler).Start();
+            new Thread(DataProcess_RobotBuffer_FinishTask.Handler).Start();
 
-            ////1009搴撲綅澧炲姞搴撳瓨绾跨▼
-            //new Thread(Place1009AddStoreTask.Handler).Start();
+            new Thread(DataProcess_BZ01.Handler).Start();
 
+
+            new Thread(DataProcess_269.Handler).Start();
+
+
+            new Thread(DataProcess_BZ39.Handler).Start();
+            new Thread(DataProcess_BZ39_IssueInboundTask.Handler).Start();
+            new Thread(DataProcess_BZ12.Hander).Start();
+            new Thread(DataProcess_BZ12_IssueTask.Handler).Start();
+
+
+            new Thread(DataProcess_BZ12_FinishTask.Handler).Start();
+
+            new Thread(DataProcess_BZ21.Hander).Start();
+            new Thread(DataProcess_BZ21_IssueTask.Handler).Start();
+
+            new Thread(DataProcess_BZ21_FinishTask.Handler).Start();
             new Thread(DeleteData).Start();
 
-            new Thread(LineInSacnResult.HandlerLineInSacnResult).Start();
+            new Thread(PushPackageCodeToMes.Handler).Start();
+            new Thread(PushPaperCutToMes.Handler).Start();
 
 
 
             //*/
             #endregion
 
-            new Thread(GetAgvVehicles).Start();//AGV杞﹁締淇℃伅
+            // new Thread(GetAgvVehicles).Start();//AGV杞﹁締淇℃伅
 
-            new Thread(OutTaskRetryToMes.Handler).Start();
+            // new Thread(OutTaskRetryToMes.Handler).Start();
 
             //鏆傛椂涓嶅惎鐢ㄨ櫄鎷熷嚭鍏ュ簱鍔熻兘
-            new Thread(VirtualTaskNoOutPlanTaskHandler.Handler).Start();
+            // new Thread(VirtualTaskNoOutPlanTaskHandler.Handler).Start();
         }
         private void FormCC_Load(object sender, EventArgs e)
         {
@@ -302,7 +326,7 @@
             }
             else
             {//姝e紡妯″紡 
-                rgvServiceClient = new RgvServiceClient();
+                stationServiceClient = new StationServiceClient();
             }
 
             this.lbl_IsSimulationPLC.BackColor = IsSimulationPLC ? Color.Red : Color.Green;
@@ -310,10 +334,6 @@
             //姝ゅ蹇�熷惎鍔� 璋冭瘯妯″紡锛岀敤浜庡紑鍙戠敤
             //btn_Start_Click(null, null);
         }
-
-
-
-        #region 鍫嗗灈鏈虹嚎绋嬪拰UI澶勭悊
 
         /// <summary>
         /// 璁剧疆1/2鍙峰爢鍨涙満鐨勫墠绔樉绀�
@@ -328,44 +348,43 @@
 
                     var showNowTime = "(" + DateTimeHelper.ConvertToStringForOnlyShowTime(DateTime.Now) + ")";
                     //璁剧疆鍫嗗灈鏈轰换鍔′笅鍙戝拰浠诲姟纭绾跨▼娑堟伅
-                    this.lbl_Alter_Srm1Release.Text = showNowTime + SystemWarningMsg._lbl_Alert_Srm1Release;
+                    this.lbl_Alert_DataProcess_BZ39_IssueInboundTask.Text = showNowTime + SystemWarningMsg._lbl_Alert_DataProcess_BZ39_IssueInboundTask;
                     this.lbl_Alert_Srm2Release.Text = showNowTime + SystemWarningMsg._lbl_Alert_Srm2Release;
-                    this.lbl_Alert_Srm3Release.Text = showNowTime + SystemWarningMsg._lbl_Alert_Srm3Release;
+                    this.lbl_Alert_DataProcess_BZ12.Text = showNowTime + SystemWarningMsg._lbl_alert_DataProcess_BZ12;
                     this.lbl_Alert_Srm4Release.Text = showNowTime + SystemWarningMsg._lbl_Alert_Srm4Release;
                     //璁剧疆鍫嗗灈鏈轰换鍔′笅鍙戝拰浠诲姟瀹屾垚纭绾跨▼娑堟伅
                     this.lbl_Alter_Srm1ReleaseFinish.Text = showNowTime + SystemWarningMsg._lbl_Alert_Srm1ReleaseFinish;
-                    this.lbl_Alert_Srm2ReleaseFinish.Text = showNowTime + SystemWarningMsg._lbl_Alert_Srm2ReleaseFinish;
-                    this.lbl_Alert_Srm3ReleaseFinish.Text = showNowTime + SystemWarningMsg._lbl_Alert_Srm3ReleaseFinish;
-                    this.lbl_Alert_Srm4ReleaseFinish.Text = showNowTime + SystemWarningMsg._lbl_Alert_Srm4ReleaseFinish;
+                    this.lbl_Alert_DataProcess_BZ12_FinishTask.Text = showNowTime + SystemWarningMsg._lbl_Alert_DataProcess_BZ12_FinishTask;
+                    this.lbl_Alert_DataProcess_BZ21_FinishTask.Text = showNowTime + SystemWarningMsg._lbl_Alert_DataProcess_BZ21_FinishTask;
 
-                    this.lbl_Alert_RgvRelease.Text = showNowTime + SystemWarningMsg._lbl_Alert_RgvRelease;
-                    this.lbl_Alert_RgvReleaseFinish.Text = showNowTime + SystemWarningMsg._lbl_Alert_RgvReleaseFinish;
-                    this.lbl_Alert_RgvReleaseFinish_BuChang.Text = showNowTime + SystemWarningMsg._lbl_Alert_RgvReleaseFinish_BuChang;
 
-                    this.lbl_Alert_HandlerIssuingTask.Text = showNowTime + SystemWarningMsg._lbl_Alert_HandlerIssuingTask;
 
-                    this.lbl_Alert_VirtualTaskNoOutPlanTaskHandler.Text = showNowTime + SystemWarningMsg._lbl_Alert_VirtualTaskNoOutPlanTaskHandler;
+                    this.lbl_Alert_PushPaperCutToMes.Text = showNowTime + SystemWarningMsg._lbl_Alert_PushPaperCutToMes;
+                    this.lbl_Alert_PushPackageCodeToMes.Text = showNowTime + SystemWarningMsg._lbl_Alert_PushPackageCodeToMes;
 
-                    this.lbl_MainTaskDecompose.Text = showNowTime + SystemWarningMsg._lbl_Alert_MainTaskDecompose;
+                    this.lbl_Alert_DataProcess_BZ12_IssueTask.Text = showNowTime + SystemWarningMsg._lbl_Alert_DataProcess_BZ12_IssueTask;
 
-                    this.lbl_MainTaskDecompose_ZPRK.Text = showNowTime + SystemWarningMsg._lbl_Alert_MainTaskDecompose_ZPRK;
+                    this.lbl_Alert_DataProcess_RobotBuffer_FinishTask.Text = showNowTime + SystemWarningMsg._lbl_Alert_DataProcess_RobotBuffer_FinishTask;
 
-                    this.lbl_Alert_LineInScan.Text = showNowTime + SystemWarningMsg._lbl_Alert_LineInScan;
+                    this.lbl_DataProcess_BZ21_IssueTask.Text = showNowTime + SystemWarningMsg._lbl_Alert_DataProcess_BZ21_IssueTask;
+
+                    this.lbl_DataProcess_RobotBuffer_ModeChange.Text = showNowTime + SystemWarningMsg._lbl_Alert_DataProcess_RobotBuffer_ModeChange;
+
+                    this.lbl_Alert_DataProcess_RobotBuffer_FinishTaskForOutbound.Text = showNowTime + SystemWarningMsg._lbl_Alert_DataProcess_RobotBuffer_FinishTaskForOutbound;
 
                     this.lbl_Alert_DeleteData.Text = showNowTime + SystemWarningMsg._lbl_Alert_DeleteData;
 
-                    this.lbl_Alert_EmptySalverTransfer.Text = showNowTime + SystemWarningMsg._lbl_Alert_EmptySalverTransfer;
+                    this.lbl_Alert_DataProcess_RobotBuffer_AutoQiTaoOutbound.Text = showNowTime + SystemWarningMsg._lbl_Alert_DataProcess_RobotBuffer_AutoQiTaoOutbound;
 
-                    this.lbl_alert_AutoSalverMaterialBindTask.Text = showNowTime + SystemWarningMsg._lbl_alert_AutoSalverMaterialBindTask;
+                    this.lbl_Alter_DataProcess_BZ21.Text = showNowTime + SystemWarningMsg._lbl_Alert_DataProcess_BZ21;
 
-                    this.lbl_alert_AutoIssueInStoreTask.Text = showNowTime + SystemWarningMsg._lbl_alert_AutoIssueInStoreTask;
+                    this.lbl_alert_DataProcess_BZ39.Text = showNowTime + SystemWarningMsg._lbl_alert_DataProcess_BZ39;
 
-                    this.lbl_alert_AutoUpdateEngineInfoTask.Text = showNowTime + SystemWarningMsg._lbl_alert_AutoUpdateEngineInfoTask;
+                    this.lbl_alert_DataProcess_BZ01.Text = showNowTime + SystemWarningMsg._lbl_alert_DataProcess_BZ01;
 
-                    this.lbl_Alert_Place1014ClearStoreTask.Text = showNowTime + SystemWarningMsg._lbl_Alert_Place1014To1020TaskTask;
+                    this.lbl_alert_DataProcess_269.Text = showNowTime + SystemWarningMsg._lbl_alert_DataProcess_269;
 
-
-                    this.lbl_Alter_OutTaskRetryToMes.Text = showNowTime + SystemWarningMsg._lbl_Alert_OutTaskRetryToMes;
+                    this.lbl_Alert_DataProcess_RobotBuffer_IssueOutboundTask.Text = showNowTime + SystemWarningMsg._lbl_Alert_DataProcess_RobotBuffer_IssueOutboundTask;
 
 
 
@@ -373,11 +392,14 @@
                 }
                 catch (Exception ex)
                 {
-                    Log4NetHelper.WriteErrorLog(iWareCommon.Utils.LogType.SrmTheadService, "鏂规硶SrmRead_Label鍑虹幇寮傚父锛�" + ex.Message, ex);
                     continue;
                 }
             }
         }
+
+        #region 鍫嗗灈鏈虹嚎绋嬪拰UI澶勭悊
+
+
 
         /// <summary>
         /// 鑾峰彇鍫嗗灈鏈虹殑瀹炴椂淇℃伅
@@ -402,18 +424,18 @@
                             {
                                 for (int i = 0; i < waringList.Count; i++)
                                 {
-                                    DeviceWarningHandler.SaveWarning(device, iWareCommon.Utils.LogType.SrmTheadService,
+                                    DeviceWarningHandler.SaveWarning(device, iWareCommon.Utils.LogType.DataProcess_BZ39_IssueInboundTask,
                                         waringList[i].Code, waringList[i].Address, waringList[i].Context);//鏂板鎶ヨ
                                     warningAddressList.Add(waringList[i].Address);
                                 }
                             }
                         }
-                        DeviceWarningHandler.AutoCloseWarning(device, iWareCommon.Utils.LogType.SrmTheadService, warningAddressList);//鑷姩鍏抽棴鎶ヨ
+                        DeviceWarningHandler.AutoCloseWarning(device, iWareCommon.Utils.LogType.DataProcess_BZ39_IssueInboundTask, warningAddressList);//鑷姩鍏抽棴鎶ヨ
                     }
                 }
                 catch (Exception ex)
                 {
-                    Log4NetHelper.WriteErrorLog(iWareCommon.Utils.LogType.SrmTheadService, "鑾峰彇" + device.ToString() + "鐨勫疄鏃朵俊鎭紓甯�:" + ex.Message, ex);
+                    Log4NetHelper.WriteErrorLog(iWareCommon.Utils.LogType.DataProcess_BZ39_IssueInboundTask, "鑾峰彇" + device.ToString() + "鐨勫疄鏃朵俊鎭紓甯�:" + ex.Message, ex);
                     continue;
                 }
             };
@@ -454,7 +476,7 @@
             };
             realTimeList.Add(obj);
 
-            DeviceSrmRealTimeHandler.Update(realTimeList, iWareCommon.Utils.LogType.SrmTheadService);
+            DeviceSrmRealTimeHandler.Update(realTimeList, iWareCommon.Utils.LogType.DataProcess_BZ39_IssueInboundTask);
 
         }
 
@@ -727,7 +749,7 @@
                         {
                             for (int i = 0; i < waringList.Count; i++)
                             {
-                                DeviceWarningHandler.SaveWarning(EDevice.RGV, iWareCommon.Utils.LogType.RgvThreadService,
+                                DeviceWarningHandler.SaveWarning(EDevice.RGV, iWareCommon.Utils.LogType.StationThreadService,
                                     waringList[i].Codek__BackingField, waringList[i].Addressk__BackingField, waringList[i].Contextk__BackingField);//鏂板鎶ヨ
                                 warningAddressList.Add(waringList[i].Addressk__BackingField);
                             }
@@ -737,12 +759,12 @@
                     {
                         tb_Rgv_Alter.Text = "";
                     }
-                    DeviceWarningHandler.AutoCloseWarning(EDevice.RGV, iWareCommon.Utils.LogType.RgvThreadService, warningAddressList);//鑷姩鍏抽棴鎶ヨ
+                    DeviceWarningHandler.AutoCloseWarning(EDevice.RGV, iWareCommon.Utils.LogType.StationThreadService, warningAddressList);//鑷姩鍏抽棴鎶ヨ
                 }
                 catch (Exception ex)
                 {
                     rgvView = null;
-                    Log4NetHelper.WriteErrorLog(iWareCommon.Utils.LogType.RgvThreadService, "鑾峰彇RGV淇℃伅鍑虹幇寮傚父:" + ex.Message, ex);
+                    Log4NetHelper.WriteErrorLog(iWareCommon.Utils.LogType.StationThreadService, "鑾峰彇RGV淇℃伅鍑虹幇寮傚父:" + ex.Message, ex);
                     continue;
                 }
             }
@@ -801,60 +823,167 @@
                 };
                 realTimeList.Add(obj);
             }
-            DeviceRgvRealTimeHandler.Update(realTimeList, iWareCommon.Utils.LogType.RgvThreadService);
+            DeviceRgvRealTimeHandler.Update(realTimeList, iWareCommon.Utils.LogType.StationThreadService);
 
         }
 
 
         #endregion
 
-        #region AGV
-
+        #region 绔欑偣绾跨▼鍜孶I澶勭悊
 
         /// <summary>
-        /// 鑾峰彇AGV杞﹁締鍒楄〃
+        /// 璁剧疆绔欑偣鐨刄I鏄剧ず
         /// </summary>
-        public void GetAgvVehicles()
+        /// <param name="obj"></param>
+        private void SetStationLable(object obj)
         {
             while (true)
             {
+                Thread.Sleep(cycleDelay_Device);
                 try
                 {
-                    if (SystemValue.isAllowRuning_Agv && SystemValue.isStartedModel)
-                    {
-                        AGVRetModel list = AgvRequestHelper.GetVehicles();
-                        AgvHandler.SaveAgvData(list);
 
-                        List<String> warningAddressList = new List<string>();
-                        if (list.alarms != null && list.alarms.errors != null && list.alarms.errors.Count > 0)
-                        {
-                            var waringList = list.alarms.errors;
-                            if (waringList != null && waringList.Count > 0)
-                            {
-                                for (int i = 0; i < waringList.Count; i++)
-                                {
-                                    DeviceWarningHandler.SaveWarning(EDevice.AGV, iWareCommon.Utils.LogType.AGVTheadService,
-                                        waringList[i].code, waringList[i].code, waringList[i].desc);//鏂板鎶ヨ
-                                    warningAddressList.Add(waringList[i].code);
-                                }
-                            }
-                        }
-                        DeviceWarningHandler.AutoCloseWarning(EDevice.AGV, iWareCommon.Utils.LogType.AGVTheadService, warningAddressList);//鑷姩鍏抽棴鎶ヨ
-                        this.lbl_Alert_Agv.Text = "鑾峰彇AGV杞﹁締淇℃伅鎴愬姛";
-                    }
+                    //lbRgv_Y.Text = "褰撳墠琛岃蛋浣嶇疆: " + rgv.R_RgvPosition;
+                    //lbRgv_X.Text = "褰撳墠鍖哄煙浣嶇疆: " + rgv.R_RgvPosition;
+                    //ERgvState _ERgvState = (ERgvState)Enum.Parse(typeof(ERgvState), rgv.R_State.ToString());
+                    //lbRgvWorkState.Text = "宸ヤ綔鐘舵��: " + _ERgvState.ToString();
+                    //lbRgvTaskId.Text = "浠诲姟鍙�: " + rgv.R_TaskNo;
+                    //lbRgvIsAuto.Text = "宸ヤ綔妯″紡: " + (rgv.ModeName);
+                    //lbRgvAlert.Text = rgv.R_AlarmCode.ToString();
+                    //if (rgv.R_Alarm == false)
+                    //{
+                    //    //妫�娴嬫槸鍚︽湁蹇冭烦
+                    //    using (var rgvService = new RgvService.RgvServiceClient())
+                    //    {
+                    //        //妫�娴嬫槸鍚︽湁蹇冭烦
+                    //        var isRgvHandShare = RgvBLL.IsRgvHandShare(rgvService);
+                    //        if (!isRgvHandShare)
+                    //        {
+                    //            lbRgvAlert.Text = "RGV娌℃湁蹇冭烦";
+                    //        }
+                    //    }
+                    //}
+                    //else
+                    //{
+                    //    lbRgvAlert.Text = rgv.R_AlarmCode.ToString();
+                    //}
+
+                    //// ERgvEvent _ERgvEvent = (ERgvEvent)Enum.Parse(typeof(ERgvEvent), rgv.r_ev.ToString());
+                    ////lbRgvEvent.Text = "浜�  浠讹細" + _ERgvEvent.ToString();
+                    //lbRgvTaskFinish.Text = "浠诲姟瀹屾垚锛�" + rgv.R_TaskFinish;
+
                 }
-                catch (Exception ex)
+                catch (Exception)
                 {
-                    Log4NetHelper.WriteErrorLog(iWareCommon.Utils.LogType.CCWCFService, "鑾峰彇AGV杞﹁締鍒楄〃 鍑虹幇寮傚父:" + ex.Message, ex);
-                    this.lbl_Alert_Agv.Text = "鑾峰彇AGV杞﹁締淇℃伅寮傚父锛�" + ex.Message;
-                }
-                finally
-                {
-                    Thread.Sleep(5000);//5绉掍竴娆� 
+                    continue;
                 }
             }
         }
+
+        /// <summary>
+        /// 鑾峰彇Station淇℃伅
+        /// </summary>
+        /// <param name="obj"></param>
+        private void GetStationInfo(object obj)
+        {
+            while (true)
+            {
+                Thread.Sleep(1000);//1绉掗挓璇诲彇涓�娆�
+                try
+                {
+                    if (stationServiceClient == null)
+                    {
+                        continue;
+                    }
+                    stationView = stationServiceClient.GetStationInfo((int)EDevice.Station);
+
+
+                    _CommmonShowAgvStation();
+
+
+                    ////鏄剧ずRGV浠诲姟瀹屾垚鍜屽畬鎴愮‘璁や俊鍙�
+                    //this.lbl_R_RGV_Finish.Text = "RGV浠诲姟瀹屾垚:" + rgvView.R_RGV_Finish;
+                    //this.lbl_W_RGV_FinishACK.Text = "RGV浠诲姟瀹屾垚纭:" + rgvView.W_RGV_FinishACK;
+
+                    //this.lbl_RgvCoordinate.Text = "RGV瀹炴椂鍧愭爣:" + rgvView.R_RGV_Coordinate;
+
+                    /*
+                    //瑙f瀽RGV瀵硅薄
+                    foreach (var item in rgvView.R_RgvForReadCommList)
+                    {
+                        var control = ControlHelper.GetControlInstance(this.tPTransAsrs, "btn_" + item.StationCode);
+                        if (item.R_AlarmCode > 0)
+                        {//鏈夋姤璀�
+                            if (control != null)
+                            {
+                                var btn = control as Button;
+                                btn.BackColor = Color.Red;
+                            }
+                        }
+                        else
+                        {
+                            if (control != null)
+                            {
+                                var btn = control as Button;
+                                if (item.StationCode == ((int)EDevice.RGV1040).ToString())
+                                {
+                                    btn.BackColor = Color.Gold;
+                                }
+                                else if (item.StationCode == ((int)EDevice.鎷嗙洏鏈�1020).ToString())
+                                {
+                                    btn.BackColor = Color.DodgerBlue;
+                                }
+                                else if (item.StationCode == ((int)EDevice.鎻愬崌鏈�1030).ToString())
+                                {
+                                    btn.BackColor = Color.SteelBlue;
+                                }
+                                else
+                                {
+                                    btn.BackColor = Color.SeaGreen;
+                                }
+                            }
+                        }
+                    }
+
+                    //鏄剧ずRGV鎶ヨ淇℃伅
+                    List<String> warningAddressList = new List<string>();
+                    if (rgvView.R_Rgv_WarningDBList != null && rgvView.R_Rgv_WarningDBList.Length > 0)
+                    {
+                        tb_Rgv_Alter.Text = String.Join(",", rgvView.R_Rgv_WarningDBList.Select(x => x.Contextk__BackingField).ToArray());
+                        //淇濆瓨鎶ヨ
+                        var waringList = rgvView.R_Rgv_WarningDBList.ToList();
+                        if (waringList != null && waringList.Count > 0)
+                        {
+                            for (int i = 0; i < waringList.Count; i++)
+                            {
+                                DeviceWarningHandler.SaveWarning(EDevice.RGV, iWareCommon.Utils.LogType.RgvThreadService,
+                                    waringList[i].Codek__BackingField, waringList[i].Addressk__BackingField, waringList[i].Contextk__BackingField);//鏂板鎶ヨ
+                                warningAddressList.Add(waringList[i].Addressk__BackingField);
+                            }
+                        }
+                    }
+                    else
+                    {
+                        tb_Rgv_Alter.Text = "";
+                    }
+                    DeviceWarningHandler.AutoCloseWarning(EDevice.RGV, iWareCommon.Utils.LogType.RgvThreadService, warningAddressList);//鑷姩鍏抽棴鎶ヨ
+
+                    //*/
+                }
+                catch (Exception ex)
+                {
+                    rgvView = null;
+                    Log4NetHelper.WriteErrorLog(iWareCommon.Utils.LogType.StationThreadService, "鑾峰彇绔欑偣淇℃伅鍑虹幇寮傚父:" + ex.Message, ex);
+                    continue;
+                }
+            }
+        }
+
+
+
         #endregion
+
 
         #region 鍏朵粬绾跨▼
 
@@ -1059,7 +1188,7 @@
                 using (var opcClinet = new SrmService.SrmServiceClient())
                 {
                     var result = opcClinet.SendEStop((int)_EDevice);
-                    Log4NetHelper.WriteInfoLog(iWareCommon.Utils.LogType.SrmTheadService, "瀛楃涓诧細" + JsonConvert.SerializeObject(result));
+                    Log4NetHelper.WriteInfoLog(iWareCommon.Utils.LogType.DataProcess_BZ39_IssueInboundTask, "瀛楃涓诧細" + JsonConvert.SerializeObject(result));
                     if (result.result)
                     {
                         WZ.Useful.Commons.MessageUtil.ShowTips("鍙戦��" + _EDevice.ToString() + "鎬ュ仠鎸囦护鎴愬姛");
@@ -1362,8 +1491,8 @@
                 this.lbl_ModelText.Text = title + currentCheckModelText;
                 SetAllCheckBoxChecked(true);
                 //灏嗙壒娈婄殑鍙栨秷
-                this.ckHandlerIssuingTask.Checked = false;
-                this.ckMainTaskDecompose.Checked = false;
+                this.ck_DataProcess_BZ12_IssueTask.Checked = false;
+                this.ck_DataProcess_BZ21_IssueTask.Checked = false;
 
                 this.gBoxThread.Enabled = true;
             }
@@ -1399,16 +1528,16 @@
         private void CommonCheckedChanged(object sender, EventArgs e)
         {
             //鍫嗗灈鏈�1浠诲姟涓嬪彂
-            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_SrmTaskThreadService_1, ckBSrm1Release);
+            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_SrmTaskThreadService_1, ckB_DataProcess_BZ39_IssueInboundTask);
             DoCommonCheckedChanged(ref SystemValue.isAllowRuning_SrmTaskThreadService_1_Finish, ckBSrm1FinishedHandle);
 
             //鍫嗗灈鏈�2浠诲姟涓嬪彂
             DoCommonCheckedChanged(ref SystemValue.isAllowRuning_SrmTaskThreadService_2, ckBSrm2Release);
-            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_SrmTaskThreadService_2_Finish, ckBSrm2FinishedHandle);
+            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_SrmTaskThreadService_2_Finish, ckBDataProcess_BZ12_FinishTask);
 
             //鍫嗗灈鏈�3浠诲姟涓嬪彂
-            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_SrmTaskThreadService_3, ckBSrm3Release);
-            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_SrmTaskThreadService_3_Finish, ckBSrm3FinishedHandle);
+            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_SrmTaskThreadService_3, ckBDataProcess_BZ12);
+            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_SrmTaskThreadService_3_Finish, ckBDataProcess_BZ21_FinishTask);
 
             //鍫嗗灈鏈�4浠诲姟涓嬪彂
             DoCommonCheckedChanged(ref SystemValue.isAllowRuning_SrmTaskThreadService_4, ckBSrm4Release);
@@ -1417,35 +1546,35 @@
 
             //RGV浠诲姟涓嬪彂
             DoCommonCheckedChanged(ref SystemValue.isAllowRuning_RgvThreadService, ckBRgvRelease);
-            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_RgvThreadService_Finish, ckBRgvFinishedHandle);
-            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_RgvThreadService_Finish_BuChang, ckBRgvFinishedHandle_BuChang);
+            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_RgvThreadService_Finish, ckB_PushPaperCutToMes);
+            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_RgvThreadService_Finish_BuChang, ck_PushPackageCodeToMes);
 
-            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_HandlerIssuingTask, ckHandlerIssuingTask);
+            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_HandlerIssuingTask, ck_DataProcess_BZ12_IssueTask);
 
-            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_VirtualTaskNoOutPlanTaskHandler, ck_VirtualTaskNoOutPlanTaskHandler);
+            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_DataProcess_RobotBuffer_FinishTask, ck_DataProcess_RobotBuffer_FinishTask);
 
-            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_MainTaskDecompose, ckMainTaskDecompose);
+            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_MainTaskDecompose, ck_DataProcess_BZ21_IssueTask);
 
-            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_MainTaskDecompose_ZPRK, ckMainTaskDecompose_ZPRK);
+            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_DataProcess_RobotBuffer_ModeChange, ck_DataProcess_RobotBuffer_ModeChange);
 
-            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_LineInScan, checkBox_LineInScan);
+            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_DataProcess_ValidateQiTao, ck_DataProcess_ValidateQiTao);
+
+            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_DataProcess_RobotBuffer_FinishTaskForOutbound, checkBox_DataProcess_RobotBuffer_FinishTaskForOutbound);
 
 
             DoCommonCheckedChanged(ref SystemValue.isAllowRuning_DeleteData, ckDeleteData);
 
-            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_Agv, ckAgv);
+            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_DataProcess_RobotBuffer_AutoQiTaoOutbound, ckDataProcess_RobotBuffer_AutoQiTaoOutbound);
 
-            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_EmptySalverTransfer, ckEmptySalverTransfer);
+            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_DataProcess_BZ39, ck_DataProcess_BZ39);
 
-            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_AutoSalverMaterialBindTask, ck_AutoSalverMaterialBindTask);
+            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_DataProcess_BZ01, ck_AutoIssueInStoreTask);
 
-            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_AutoIssueInStoreTask, ck_AutoIssueInStoreTask);
+            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_DataProcess_269, ck_DataProcess_269);
 
-            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_AutoUpdateEngineInfoTask, ck_AutoUpdateEngineInfoTask);
+            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_DataProcess_RobotBuffer_IssueOutboundTask, ck_DataProcess_RobotBuffer_IssueOutboundTask);
 
-            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_Place1014To1020Task, ckPlace1014ClearStoreTask);
-
-            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_OutTaskRetryToMes, checkBox_OutTaskRetryToMes);
+            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_OutTaskRetryToMes, checkBox_DataProcess_BZ21);
         }
 
         private void DoCommonCheckedChanged(ref bool isAllowValue, CheckBox cb)
@@ -1563,7 +1692,7 @@
             DialogResult dr = MessageBox.Show("纭畾瑕佸惎鍔ㄣ��" + currentCheckModelText + "銆戞ā寮忓悧?", "鍚姩妯″紡", messButton);
             if (dr == DialogResult.OK)//濡傛灉鐐瑰嚮鈥滅‘瀹氣�濇寜閽�
             {
-                using (DbModel edm = new DbModel())
+                using (WmsDBModel edm = new WmsDBModel())
                 {
                     var ccSystem = BasicDataSetHandler.GetCCSystem(edm);
                     if (ccSystem == null)
@@ -1622,7 +1751,7 @@
         /// <returns></returns>
         private bool CommonStopService()
         {
-            using (DbModel edm = new DbModel())
+            using (WmsDBModel edm = new WmsDBModel())
             {
                 var ccSystem = BasicDataSetHandler.GetCCSystem(edm);
                 if (ccSystem == null)
@@ -1638,7 +1767,7 @@
                     ccSystem.Machine = string.Empty;
                     ccSystem.LastMachine = Dns.GetHostName();
                     ccSystem.LastUnLineTime = DateTime.Now;
-                    ccSystem.ModifyTime = DateTime.Now;
+                    ccSystem.UpdateTime = DateTime.Now;
 
                     int i = edm.SaveChanges();
                     if (i <= 0)
@@ -1720,6 +1849,9 @@
                         this.btn_Start.BackColor = default_btn_Start_Color;//杩樺師棰滆壊
                     }
                 }
+
+                this.lbl_RobotMode.Text = "缂撳瓨宀涙満鍣ㄤ汉妯″紡:" + (IsAllowRunOutMode ? "鍑哄簱妯″紡" : "鍏ュ簱妯″紡");
+                this.lbl_currHandlerPackageCodeForIssueOutboundTask.Text = "褰撳墠涓嬪彂鍑哄簱浠诲姟鐨勫寘鍙�:" + currHandlerPackageCodeForIssueOutboundTask;
             }
         }
 
@@ -3419,5 +3551,60 @@
                 "杞崲鍚�:" + "\r\n" +
                 JsonConvert.SerializeObject(retModel);
         }
+
+        private void lbl_Alert_Place1014ClearStoreTask_Click(object sender, EventArgs e)
+        {
+
+        }
+
+        private void button24_Click(object sender, EventArgs e)
+        {
+            //寮哄埗璇ュ寘鍙峰嚭搴�
+            var packageCode = this.tb_PackageCode.Text.Trim();
+
+            var alertMsg = "";
+            DataProcess_RobotBuffer_ForceOutbound.Handler(packageCode, ref alertMsg);
+            if (!string.IsNullOrEmpty(alertMsg))
+            {
+                MessageBox.Show("閿欒:" + alertMsg);
+            }
+            else
+            {
+                MessageBox.Show("宸插鐞�");
+            }
+        }
+
+        private void button25_Click(object sender, EventArgs e)
+        {
+            var packageCode = this.tb_PackageCode.Text.Trim();
+
+            var alertMsg = "";
+            using (WmsDBModel db = new WmsDBModel())
+            {
+                var upiList = db.mes_batchOrderUPI_new.Where(x => x.PackageCode == packageCode).ToList();
+                foreach (var item in upiList)
+                {
+                    item.AreaCode = (int)AreaCodeEnum.鏃犲尯鍩�;
+                    item.UpiStatus = (int)UpiStatusEnum.鍒濆;
+                }
+
+                var pList = db.mes_package_gather.Where(x => x.PackageCode == packageCode).ToList();
+                foreach (var item in pList)
+                {
+                    item.AreaCode = (int)AreaCodeEnum.鏃犲尯鍩�;
+                    item.UpiStatus = (int)UpiStatusEnum.鍒濆;
+                }
+
+                db.SaveChanges();
+            }
+            if (!string.IsNullOrEmpty(alertMsg))
+            {
+                MessageBox.Show("閿欒:" + alertMsg);
+            }
+            else
+            {
+                MessageBox.Show("宸插鐞�");
+            }
+        }
     }
 }

--
Gitblit v1.9.3