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