From e8734db76fbbb3149ba663beff3b4f7451012b03 Mon Sep 17 00:00:00 2001
From: schangxiang@126.com <schangxiang@126.com>
Date: 周二, 03 12月 2024 13:28:34 +0800
Subject: [PATCH] 11

---
 CC/iWareCC_ASRS/FormCC.cs |  177 +++++++++++++++++++++++++++++-----------------------------
 1 files changed, 88 insertions(+), 89 deletions(-)

diff --git a/CC/iWareCC_ASRS/FormCC.cs b/CC/iWareCC_ASRS/FormCC.cs
index 286fe2c..d8b0b67 100644
--- a/CC/iWareCC_ASRS/FormCC.cs
+++ b/CC/iWareCC_ASRS/FormCC.cs
@@ -5,6 +5,8 @@
 using iWareCC.SrmService;
 using iWareCC.StationService;
 using iWareCC.ThreadService;
+using iWareCC.ThreadService._03_BZ12_鏈哄櫒浜虹爜鍖呭伐浣峗;
+using iWareCC.ThreadService._04_BZ21_鎼繍鏁村灈鏈哄櫒浜篲;
 using iWareCC.WCF;
 using iWareCommon.Common.Globle;
 using iWareCommon.Utils;
@@ -12,6 +14,7 @@
 using iWareModel.Entity.AGV;
 using iWareSql.DataAccess;
 using iWareSql.DBModel;
+using iWareSql.WmsDBModel;
 using Newtonsoft.Json;
 using System;
 using System.Collections.Generic;
@@ -25,11 +28,23 @@
 using System.Windows.Forms;
 using XiGang.Core.Model;
 using XiGang.Core.Model.ViewModels;
+using static iWareCC.ThreadService._04_BZ21_鎼繍鏁村灈鏈哄櫒浜篲.DataProcess_BZ21;
 
 namespace iWareCC
 {
     public partial class FormCC : Form
     {
+
+        /// <summary>
+        /// 鍏ㄥ眬鈥旀槸鍚﹀彲浠ヨ繍琛屾墽琛屽嚭搴撴ā寮�
+        /// </summary>
+        public static bool IsAllowRunOutMode = false;
+
+        /// <summary>
+        /// 褰撳墠涓嬪彂鍑哄簱浠诲姟鐨勫寘鍙�
+        /// </summary>
+        public static string currHandlerPackageCodeForIssueOutboundTask = "";
+
         /// <summary>
         /// 1鍙峰爢鍨涙満鍏ュ簱鍙f壂鐮佸己鍒堕獙璇侀�氳繃
         /// </summary>
@@ -187,13 +202,14 @@
             //鍫嗗灈鏈篣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 鏈嶅姟绾跨▼鍚姩
@@ -206,32 +222,38 @@
             // 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(DataProcess_RobotBuffer_AutoQiTaoOutbound.Handler).Start();
 
             new Thread(DataProcess_RobotBuffer_FinishTaskForOutbound.Handler).Start();
 
-            //鑷姩缁勭洏浠诲姟
+
             new Thread(DataProcess_RobotBuffer_FinishTask.Handler).Start();
 
             new Thread(DataProcess_BZ01.Handler).Start();
 
-            //閲嶆柊鑾峰彇鍙戝姩鏈轰俊鎭�
+
             new Thread(DataProcess_269.Handler).Start();
 
-            //1014搴撲綅杞繍鍒�1020绾跨▼
+
             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_FinishTask.Handler).Start();
             new Thread(DeleteData).Start();
 
-            new Thread(LineInSacnResult.HandlerLineInSacnResult).Start();
+            //new Thread(PrintHandler.Handler).Start();
 
 
 
@@ -300,7 +322,7 @@
             }
             else
             {//姝e紡妯″紡 
-                rgvServiceClient = new RgvServiceClient();
+                stationServiceClient = new StationServiceClient();
             }
 
             this.lbl_IsSimulationPLC.BackColor = IsSimulationPLC ? Color.Red : Color.Green;
@@ -308,10 +330,6 @@
             //姝ゅ蹇�熷惎鍔� 璋冭瘯妯″紡锛岀敤浜庡紑鍙戠敤
             //btn_Start_Click(null, null);
         }
-
-
-
-        #region 鍫嗗灈鏈虹嚎绋嬪拰UI澶勭悊
 
         /// <summary>
         /// 璁剧疆1/2鍙峰爢鍨涙満鐨勫墠绔樉绀�
@@ -326,7 +344,7 @@
 
                     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_Srm4Release.Text = showNowTime + SystemWarningMsg._lbl_Alert_Srm4Release;
@@ -337,22 +355,22 @@
                     this.lbl_Alert_Srm4ReleaseFinish.Text = showNowTime + SystemWarningMsg._lbl_Alert_Srm4ReleaseFinish;
 
                     this.lbl_Alert_RgvRelease.Text = showNowTime + SystemWarningMsg._lbl_Alert_RgvRelease;
-                    this.lbl_Alert_RgvReleaseFinish.Text = showNowTime + SystemWarningMsg._lbl_Alert_RgvReleaseFinish;
+                    this.lbl_Alert_RgvReleaseFinish.Text = showNowTime + SystemWarningMsg._lbl_Alert_DataProcess_RobotBuffer_ModeChange;
                     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_DataProcess_BZ12_IssueTask.Text = showNowTime + SystemWarningMsg._lbl_Alert_DataProcess_BZ12_IssueTask;
 
                     this.lbl_Alert_DataProcess_RobotBuffer_FinishTask.Text = showNowTime + SystemWarningMsg._lbl_Alert_DataProcess_RobotBuffer_FinishTask;
 
                     this.lbl_MainTaskDecompose.Text = showNowTime + SystemWarningMsg._lbl_Alert_MainTaskDecompose;
 
-                    this.lbl_MainTaskDecompose_ZPRK.Text = showNowTime + SystemWarningMsg._lbl_Alert_MainTaskDecompose_ZPRK;
+                    this.lbl_DataProcess_RobotBuffer_ModeChange.Text = showNowTime + SystemWarningMsg._lbl_Alert_MainTaskDecompose_ZPRK;
 
                     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_DataProcess_BZ39.Text = showNowTime + SystemWarningMsg._lbl_alert_DataProcess_BZ39;
 
@@ -360,7 +378,7 @@
 
                     this.lbl_alert_DataProcess_269.Text = showNowTime + SystemWarningMsg._lbl_alert_DataProcess_269;
 
-                    this.lbl_Alert_Place1014ClearStoreTask.Text = showNowTime + SystemWarningMsg._lbl_Alert_Place1014To1020TaskTask;
+                    this.lbl_Alert_DataProcess_RobotBuffer_IssueOutboundTask.Text = showNowTime + SystemWarningMsg._lbl_Alert_DataProcess_RobotBuffer_IssueOutboundTask;
 
 
                     this.lbl_Alter_OutTaskRetryToMes.Text = showNowTime + SystemWarningMsg._lbl_Alert_OutTaskRetryToMes;
@@ -371,11 +389,14 @@
                 }
                 catch (Exception ex)
                 {
-                    Log4NetHelper.WriteErrorLog(iWareCommon.Utils.LogType.SrmTheadService, "鏂规硶SrmRead_Label鍑虹幇寮傚父锛�" + ex.Message, ex);
                     continue;
                 }
             }
         }
+
+        #region 鍫嗗灈鏈虹嚎绋嬪拰UI澶勭悊
+
+
 
         /// <summary>
         /// 鑾峰彇鍫嗗灈鏈虹殑瀹炴椂淇℃伅
@@ -400,18 +421,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;
                 }
             };
@@ -452,7 +473,7 @@
             };
             realTimeList.Add(obj);
 
-            DeviceSrmRealTimeHandler.Update(realTimeList, iWareCommon.Utils.LogType.SrmTheadService);
+            DeviceSrmRealTimeHandler.Update(realTimeList, iWareCommon.Utils.LogType.DataProcess_BZ39_IssueInboundTask);
 
         }
 
@@ -960,53 +981,6 @@
 
         #endregion
 
-        #region AGV
-
-
-        /// <summary>
-        /// 鑾峰彇AGV杞﹁締鍒楄〃
-        /// </summary>
-        public void GetAgvVehicles()
-        {
-            while (true)
-            {
-                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杞﹁締淇℃伅鎴愬姛";
-                    }
-                }
-                catch (Exception ex)
-                {
-                    Log4NetHelper.WriteErrorLog(iWareCommon.Utils.LogType.CCWCFService, "鑾峰彇AGV杞﹁締鍒楄〃 鍑虹幇寮傚父:" + ex.Message, ex);
-                    this.lbl_Alert_Agv.Text = "鑾峰彇AGV杞﹁締淇℃伅寮傚父锛�" + ex.Message;
-                }
-                finally
-                {
-                    Thread.Sleep(5000);//5绉掍竴娆� 
-                }
-            }
-        }
-        #endregion
 
         #region 鍏朵粬绾跨▼
 
@@ -1211,7 +1185,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() + "鎬ュ仠鎸囦护鎴愬姛");
@@ -1514,7 +1488,7 @@
                 this.lbl_ModelText.Text = title + currentCheckModelText;
                 SetAllCheckBoxChecked(true);
                 //灏嗙壒娈婄殑鍙栨秷
-                this.ckHandlerIssuingTask.Checked = false;
+                this.ck_DataProcess_BZ12_IssueTask.Checked = false;
                 this.ckMainTaskDecompose.Checked = false;
 
                 this.gBoxThread.Enabled = true;
@@ -1551,7 +1525,7 @@
         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浠诲姟涓嬪彂
@@ -1572,22 +1546,22 @@
             DoCommonCheckedChanged(ref SystemValue.isAllowRuning_RgvThreadService_Finish, ckBRgvFinishedHandle);
             DoCommonCheckedChanged(ref SystemValue.isAllowRuning_RgvThreadService_Finish_BuChang, ckBRgvFinishedHandle_BuChang);
 
-            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_HandlerIssuingTask, ckHandlerIssuingTask);
+            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_HandlerIssuingTask, ck_DataProcess_BZ12_IssueTask);
 
             DoCommonCheckedChanged(ref SystemValue.isAllowRuning_DataProcess_RobotBuffer_FinishTask, ck_DataProcess_RobotBuffer_FinishTask);
 
             DoCommonCheckedChanged(ref SystemValue.isAllowRuning_MainTaskDecompose, ckMainTaskDecompose);
 
-            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_MainTaskDecompose_ZPRK, ckMainTaskDecompose_ZPRK);
+            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_DataProcess_RobotBuffer_ModeChange, ck_DataProcess_RobotBuffer_ModeChange);
+
+            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_EmptySalverTransfer, ckEmptySalverTransfer);
+            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_DataProcess_RobotBuffer_AutoQiTaoOutbound, ckDataProcess_RobotBuffer_AutoQiTaoOutbound);
 
             DoCommonCheckedChanged(ref SystemValue.isAllowRuning_DataProcess_BZ39, ck_DataProcess_BZ39);
 
@@ -1595,7 +1569,7 @@
 
             DoCommonCheckedChanged(ref SystemValue.isAllowRuning_DataProcess_269, ck_DataProcess_269);
 
-            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_Place1014To1020Task, ckPlace1014ClearStoreTask);
+            DoCommonCheckedChanged(ref SystemValue.isAllowRuning_DataProcess_RobotBuffer_IssueOutboundTask, ck_DataProcess_RobotBuffer_IssueOutboundTask);
 
             DoCommonCheckedChanged(ref SystemValue.isAllowRuning_OutTaskRetryToMes, checkBox_OutTaskRetryToMes);
         }
@@ -1715,7 +1689,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)
@@ -1774,7 +1748,7 @@
         /// <returns></returns>
         private bool CommonStopService()
         {
-            using (DbModel edm = new DbModel())
+            using (WmsDBModel edm = new WmsDBModel())
             {
                 var ccSystem = BasicDataSetHandler.GetCCSystem(edm);
                 if (ccSystem == null)
@@ -1790,7 +1764,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)
@@ -1872,6 +1846,9 @@
                         this.btn_Start.BackColor = default_btn_Start_Color;//杩樺師棰滆壊
                     }
                 }
+
+                this.lbl_RobotMode.Text = "缂撳瓨宀涙満鍣ㄤ汉妯″紡:" + (IsAllowRunOutMode ? "鍑哄簱妯″紡" : "鍏ュ簱妯″紡");
+                this.lbl_currHandlerPackageCodeForIssueOutboundTask.Text = "褰撳墠涓嬪彂鍑哄簱浠诲姟鐨勫寘鍙�:" + currHandlerPackageCodeForIssueOutboundTask;
             }
         }
 
@@ -3571,5 +3548,27 @@
                 "杞崲鍚�:" + "\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("宸插鐞�");
+            }
+        }
     }
 }

--
Gitblit v1.9.3