From f4ce2bcaa377c5fe869c0e8f0e1640cee3f8a400 Mon Sep 17 00:00:00 2001 From: Rodney Chen <rodney.chen@hotmail.com> Date: 星期一, 04 十一月 2024 14:47:50 +0800 Subject: [PATCH] 增加在线产品异常下线功能 --- Tiger.Business.MES/Transaction/TestNode.cs | 89 ++++++++++++++++++++++++++++++++++++++++---- 1 files changed, 80 insertions(+), 9 deletions(-) diff --git a/Tiger.Business.MES/Transaction/TestNode.cs b/Tiger.Business.MES/Transaction/TestNode.cs index dbe6279..d334a8d 100644 --- a/Tiger.Business.MES/Transaction/TestNode.cs +++ b/Tiger.Business.MES/Transaction/TestNode.cs @@ -1,13 +1,6 @@ 锘縰sing Rhea.Common; -using Tiger.IBusiness; using SqlSugar; -using System; -using System.Collections.Generic; -using System.Linq; -using System.Linq.Expressions; -using System.Text; -using System.Threading; -using System.Threading.Tasks; +using Tiger.IBusiness; using Tiger.Model; using Tiger.Model.Entitys.MES.Position; @@ -269,6 +262,7 @@ HOLD_FLAG = "N", REWORK_FLAG = CurBatch.WO.ORDER_TYPE == BIZ_MES_WO.ORDER_TYPEs.Rework.GetValue() ? "Y" : "N", FINISHED_FLAG = "N", + UNBIND_FLAG = "N", INV_FLAG = "N", DFT_FLAG = "N", DFT_COUNT = 0, @@ -413,8 +407,16 @@ LOCK_BATCH = wipSN.LOCK_BATCH, WIP_ID = wipSN.ID, }; + wipSN.Defects.Add(defect); CurDefects.Add(defect); } + } + + //浜у搧琚垽鏂笉鑹悗涓嬬嚎锛屽苟浠庡伐鍗曚腑绉婚櫎姝e湪鐢熶骇鐨勬潯鐮� + if (CurDefects.Any() && curNodeSetting.IF_DFT_OFFLINE == "Y") + { + woStatus.Data.ShortMsg = new("浜у搧涓嬬嚎", ShortMessage.Types.Error); + return OfflineIfDefect(action, wipSNs, input.Locale); } //宸ュ崟寮�宸� @@ -622,7 +624,7 @@ SaveStepsCommitActionToDB(endAction); //淇濆瓨鎴愬姛锛岃繑鍥炶繃绔欐秷鎭� - CurOperInfo(locale).InputQty += CurWipSNs.Count; + operInfo.InputQty += CurWipSNs.Count; action.Data.OperInfo = operInfo; action.Data.ShortMsg = new(CurWipSNs.Any(q => q.DFT_FLAG == "Y") ? "涓嶈壇杩囩珯" : "鑹搧杩囩珯", ShortMessage.Types.Success); //action.LocaleMsg = new($"宸ュ崟[{CurWipSN.WORK_ORDER}]鐨勬潯鐮乕{CurWipSN.SN}]鍦ㄥ矖浣峓{CurWipSN.POST_CODE}]宸ュ簭[{CurWipSN.NODE_NAME}]杩囩珯鎴愬姛锛岀姸鎬乕{CurWipSN.STATUS.GetEnumDesc<MES_WIP_DATA.STATUSs>()}]"); @@ -640,6 +642,75 @@ } /// <summary> + /// 浜у搧琚垽鏂笉鑹悗涓嬬嚎 + /// </summary> + /// <param name="action"></param> + /// <returns></returns> + public ApiAction<SubmitOutput> OfflineIfDefect(ApiAction<SubmitOutput> action, List<MES_WIP_DATA> wipSNs, string locale) + { + var operInfo = SetOperNodeInfo(CurOperInfo(locale)); + operInfo.CurNode = wipSNs.FirstOrDefault()?.NODE_NAME; + operInfo.NextNode = "涓嬬嚎閫�搴�"; + + //鏇存柊宸ュ崟鏉$爜鏄庣粏淇℃伅 + var woSNs = CurBatch.WoSNs.Where(q => wipSNs.Any(w => q.WIP_ID == w.ID)).ToList(); + foreach (var woSN in woSNs) + { + woSN.STATUS = BIZ_MES_WO_SN.STATUSs.Offline.GetValue(); + } + + //鏉$爜涓嬬嚎 + foreach (var wipSN in wipSNs) + { + wipSN.STATUS = MES_WIP_DATA.STATUSs.Offline.GetValue(); + wipSN.UNBIND_FLAG = "Y"; + } + + var wipHiss = new List<MES_WIP_HIS>(); + foreach (var wipSN in wipSNs) + { + var his = new MES_WIP_HIS(wipSN, $"宸ュ崟[{wipSN.WORK_ORDER}]鏉$爜[{wipSN.SN}]鍦ㄥ矖浣峓{wipSN.POST_CODE}]宸ュ簭[{wipSN.NODE_NAME}]鍥犱笉鑹痆{wipSN.Defects.FirstOrDefault()?.DFT_NAME}]涓嬬嚎锛圱ransId锛� {TransID} 锛�"); + wipSN.History.Add(his); + wipHiss.Add(his); + } + + //鍒涘缓鍙橀噺鍏嬮殕瀵硅薄鐢ㄤ簬浼犲叆DBSubmitAction涓繚瀛樺綋鍓嶉渶瑕佹殏瀛樼殑鏁版嵁鍊� + var _woSns = woSNs.Clone(); + var _wipSns = wipSNs.Clone(); + var _wipHiss = wipHiss.Clone(); + var _defect = CurDefects.Clone(); + //浣跨敤缁熶竴鐨勪簨鍔B瀵硅薄 + var db = GetCommitDB(); + //淇濆瓨鏁版嵁搴� + var dbTran = db.UseTran(() => + { + //鏁版嵁淇濆瓨閫昏緫 + db.Storageable(_woSns, UserCode).ExecuteCommand(); + db.Storageable(_wipSns, UserCode).ExecuteCommand(); + db.Storageable(_wipHiss, UserCode).ExecuteCommand(); + db.Storageable(_defect, UserCode).ExecuteCommand(); + }); + if (!dbTran.IsSuccess) + { + //鎶涘嚭寮傚父 + throw dbTran.ErrorException; + } + + //浠庡伐鍗曚腑绉婚櫎姝e湪鐢熶骇鐨勬潯鐮� + CurBatch.RemoveWipSn(wipSNs, UserCode); + + //淇濆瓨鎴愬姛锛岃繑鍥炶繃绔欐秷鎭� + action.Data.OperInfo = operInfo; + action.Data.ShortMsg = new("涓嬬嚎閫�搴�", ShortMessage.Types.Warning); + //action.LocaleMsg = new($"宸ュ崟[0]鐨勬潯鐮乕1]鍦ㄥ矖浣峓2]宸ュ簭[3]鍥犱笉鑹痆4]涓嬬嚎锛岀姸鎬乕5]"); + action.LocaleMsg = new("MES.Transaction.TestNode.OfflineIfDefect", wipSNs.First().WORK_ORDER, CurSN, wipSNs.First().POST_CODE, wipSNs.First().NODE_NAME, wipSNs.First().Defects.FirstOrDefault()?.DFT_NAME, wipSNs.First().STATUS.GetEnumDesc<MES_WIP_DATA.STATUSs>()); + + //閲嶇疆宸ュ簭 + ResetNode(); + return action; + } + + /// <summary> /// 娴嬭瘯宸ュ簭锛氳幏鍙栧伐搴忎笉鑹唬鐮� /// </summary> /// <returns></returns> -- Gitblit v1.9.3