From a18b6286678e90a00c3ac20c8e937d40104d2ef9 Mon Sep 17 00:00:00 2001 From: Rodney Chen <rodney.chen@hotmail.com> Date: 星期六, 12 十月 2024 21:45:26 +0800 Subject: [PATCH] 工序结束返回包装信息 --- Tiger.Business.MES/Transaction/PackingNode.cs | 112 +++++++++++++++++++++++++++++++------------------------ 1 files changed, 63 insertions(+), 49 deletions(-) diff --git a/Tiger.Business.MES/Transaction/PackingNode.cs b/Tiger.Business.MES/Transaction/PackingNode.cs index d107e59..c51b140 100644 --- a/Tiger.Business.MES/Transaction/PackingNode.cs +++ b/Tiger.Business.MES/Transaction/PackingNode.cs @@ -48,6 +48,16 @@ var action = new ApiAction<SubmitOutput>(new SubmitOutput()); try { + if (input.Qty.ToInt32() <= 0) + { + action.Data.ShortMsg = new("璇疯緭鍏ュ寘瑁呮暟閲�", ShortMessage.Types.Error); + action.Data.OperInfo = new(); + action.Data.Data = "QtyError"; + action.IsSuccessed = false; + action.LocaleMsg = new($"鍖呰鏁伴噺[{input.Qty}]涓嶆纭紝璇烽噸鏂拌緭鍏ユ暟閲忓悗缁х画鍖呰鎿嶄綔"); + //action.LocaleMsg = new("MES.Transaction.PackingNode.Submit.QtyError", input.Qty); + return action; + } //PkgSubmit锛氭墜鍔ㄧ粨鏉熷寘瑁咃紝鎵嬪姩淇濆瓨鏆傚瓨鐨勫寘瑁呮暟鎹� if (NodeCmd == "PkgSubmit") { @@ -62,7 +72,6 @@ //NodeSubmit锛氫骇鍝佽繃绔欙紝姝e父浜у搧杩囩珯閫昏緫 else { - NodeCmd = "NodeSubmit"; //宸ユ鍒楄〃涓虹┖鎴栬�呭伐搴忚妭鐐瑰伐姝ユ湁鏈畬鎴愭椂锛屼紭鍏堝畬鎴愬伐搴忚妭鐐瑰伐姝� if (Steps.IsNullOrEmpty() || !IsFinishNodeSteps) { @@ -88,7 +97,7 @@ //褰撳墠宀椾綅鍦ㄥ綋鍓嶅伐鍗曚笉鏄绔欙紝鍒欐煡鎵炬潯鐮佸凡缁戝畾鐨勫伐鍗曞綋浣滃綋鍓嶅伐鍗� else { - var wosns = Biz.Db.Queryable<BIZ_MES_WO_BATCH, BIZ_MES_WO_SN>((q, s) => new JoinQueryInfos(JoinType.Inner, q.ORDER_NO == s.WORK_ORDER)) + var wosns = Biz.Db.Queryable<BIZ_MES_WO_BATCH, BIZ_MES_WO_SN>((q, s) => new JoinQueryInfos(JoinType.Inner, q.ORDER_NO == s.WORK_ORDER && q.BATCH_NO == s.BATCH_NO)) .ByAuth(input.AuthOption).Where((q, s) => s.STATUS < BIZ_MES_WO_SN.STATUSs.Finished.GetValue()) .Where((q, s) => s.SN == input.SN || s.FLOW_SN == input.SN || s.TRAY_SN == input.SN).Select((q, s) => new { Batch = q, SN = s }).ToList(); @@ -110,7 +119,7 @@ action.Data.OperInfo = new(); action.IsSuccessed = false; //action.LocaleMsg = new($"姝e湪鍖呰宸ュ崟鎵规[{0}]鐨勪骇鍝侊紝璇峰厛瀹屾垚褰撳墠鍖呰鍚庡啀鎵弿鍏朵粬鎵规[{1}]鐨勪骇鍝乕{2}]"); - action.LocaleMsg = new("MES.Transaction.PackingNode.Submit.BatchError", (Context["CurPackage"] as WipPkg).WorkBatch, wosns.First().Batch.BATCH_NO, CurSN); + action.LocaleMsg = new("MES.Transaction.PackingNode.Submit.BatchError", (Context["CurPackage"] as WipPkg).WorkBatch, wosns.First().Batch.BATCH_NO, input.SN); return action; } if (wosns.First().Batch.ACT_LINE != CurLine.LINE_CODE) @@ -120,22 +129,22 @@ action.IsSuccessed = false; //action.LocaleMsg = new($"鏉$爜[{0}]宸插湪浜х嚎[{1}]鎶曞叆鐢熶骇锛岃鍦ㄦ纭矖浣嶆壂鎻�"); action.LocaleMsg = new("MES.Transaction.PackingNode.Submit.NotCorrectLine", input.SN, wosns.First().Batch.ACT_LINE); - } + } else { - if (CurBatch?.Batch?.ORDER_NO != wosns.First().Batch.ORDER_NO) - { - //鏉$爜宸茬粦瀹氱殑宸ュ崟涓嶇瓑浜庡綋鍓嶅伐鍗曞垯閲嶆柊閫夋嫨宸ュ崟 - var result = await SelectOrder(new() { AuthOption = input.AuthOption, OrderNo = wosns.First().Batch.ORDER_NO }); - if (!result.IsSuccessed) - { + if (CurBatch?.Batch?.ORDER_NO != wosns.First().Batch.ORDER_NO) + { + //鏉$爜宸茬粦瀹氱殑宸ュ崟涓嶇瓑浜庡綋鍓嶅伐鍗曞垯閲嶆柊閫夋嫨宸ュ崟 + var result = await SelectOrder(new() { AuthOption = input.AuthOption, OrderNo = wosns.First().Batch.ORDER_NO }, wosns.First().Batch.BATCH_NO); + if (!result.IsSuccessed) + { action.Data.ShortMsg = new("宸ュ崟寮傚父", ShortMessage.Types.Error); action.Data.OperInfo = new(); action.IsSuccessed = result.IsSuccessed; - action.LocaleMsg = result.LocaleMsg; - return action; - } - } + action.LocaleMsg = result.LocaleMsg; + return action; + } + } //鏇存柊CurBatch CurBatch?.Update(); //鏉$爜杩囩珯 @@ -226,9 +235,9 @@ action.Data.ShortMsg = new("閲嶇疆鎵弿", ShortMessage.Types.Error); action.Data.OperInfo = CurOperInfo(input.Locale); ResetNode(); - action.IsSuccessed = false; - //action.LocaleMsg = new($"宀椾綅[{CurPosition.POST_CODE}]宸ユ鎵ц寮傚父锛岃閲嶆柊鎵弿浜у搧鏉$爜", CurPosition.POST_CODE); - action.LocaleMsg = new("MES.Transaction.PackingNode.Submit.WorkStepException", CurPosition.POST_CODE); + action.IsSuccessed = false; + //action.LocaleMsg = new($"宀椾綅[{CurPosition.POST_CODE}]宸ユ鎵ц寮傚父锛岃閲嶆柊鎵弿浜у搧鏉$爜", CurPosition.POST_CODE); + action.LocaleMsg = new("MES.Transaction.PackingNode.Submit.WorkStepException", CurPosition.POST_CODE); } } } @@ -251,7 +260,6 @@ public ApiAction<SubmitOutput> NodeSubmit(ApiAction<SubmitOutput> action, SubmitInput input) { var curNode = CurBatch.GetNode(PostCode); - var curNodeSetting = CurBatch.GetNodeSetting(curNode); try { //宸ュ簭鑺傜偣閫昏緫澧炲姞濡傛灉鏍瑰熀褰撳墠宀椾綅鎵句笉鍒板搴斿伐搴忕殑鏃跺�欒鎶ラ敊 @@ -263,6 +271,8 @@ action.LocaleMsg = new("MES.Transaction.PackingNode.NodeSubmit.OperateNodeError", PostCode, CurBatch.WO.ORDER_NO); return action; } + var curNodeSetting = CurBatch.GetNodeSetting(curNode); + //褰撳伐姝ュ垪琛ㄤ负绌猴紝鍒欐墽琛屽綋鍓嶅伐搴忕殑蹇呰閫昏緫褰撲綔绗竴涓伐搴忚妭鐐癸紝瀹屾垚鍚庢寜闇�姹傚垱寤哄悗缁殑宸ユ鍒楄〃 if (Steps.IsNullOrEmpty()) { @@ -329,10 +339,13 @@ return canGotoNext; } + //璁剧疆褰撳墠鎸囦护涓烘甯镐骇鍝佽繃绔� + NodeCmd = "NodeSubmit"; + //缁戝畾鏉$爜鍒板伐鍗� foreach (var wipSN in wipSNs) { - if (!CurBatch.WoSNs.Any(q => q.SN == wipSN.SN)) + if (!CurBatch.WoSNs.Any(q => q.WIP_ID == wipSN.ID)) { CurBatch.WoSNs.Add(new() { @@ -347,7 +360,7 @@ } //鏇存柊宸ュ崟鏉$爜鏄庣粏淇℃伅 - var woSNs = CurBatch.WoSNs.Where(q => wipSNs.Any(w => q.SN == w.SN)).ToList(); + var woSNs = CurBatch.WoSNs.Where(q => wipSNs.Any(w => q.WIP_ID == w.ID)).ToList(); foreach (var woSN in woSNs) { woSN.AUTH_ORG = CurBatch.WO.AUTH_ORG; @@ -362,26 +375,26 @@ wipSN.AUTH_PROD = CurLine.LINE_CODE; wipSN.STATUS = MES_WIP_DATA.STATUSs.OK.GetValue();//wipSN.STATUS > 0 ? MES_WIP_DATA.STATUSs.OK.GetValue() : wipSN.STATUS; wipSN.ROT_CODE = CurBatch.WO.ROUTE_CODE; - wipSN.NODE_ID = curNode.ID; - wipSN.NODE_NAME = curNode.NODE_NAME; - wipSN.FTY_CODE = CurFactory.FTY_CODE; - wipSN.WS_CODE = CurWorkshop.WS_CODE; - wipSN.LINE_CODE = CurLine.LINE_CODE; - wipSN.POST_CODE = CurPosition.POST_CODE; - wipSN.OPER_CODE = curNode.OPER_CODE; - wipSN.SEGMENT = curNode.SEGMENT; - wipSN.OPERATION_TIME = DateTime.Now; + wipSN.NODE_ID = curNode.ID; + wipSN.NODE_NAME = curNode.NODE_NAME; + wipSN.FTY_CODE = CurFactory.FTY_CODE; + wipSN.WS_CODE = CurWorkshop.WS_CODE; + wipSN.LINE_CODE = CurLine.LINE_CODE; + wipSN.POST_CODE = CurPosition.POST_CODE; + wipSN.OPER_CODE = curNode.OPER_CODE; + wipSN.SEGMENT = curNode.SEGMENT; + wipSN.OPERATION_TIME = DateTime.Now; var curShiftPeriod = GetShiftPeriodForNow(); if (!curShiftPeriod.IsNullOrEmpty()) { - wipSN.SFTS_CODE = curShiftPeriod.ShiftSys.SFTS_CODE; - wipSN.SFT_CODE = curShiftPeriod.Shift.SFT_CODE; - wipSN.PRD_CODE = curShiftPeriod.Period.PRD_CODE; + wipSN.SFTS_CODE = curShiftPeriod.ShiftSys.SFTS_CODE; + wipSN.SFT_CODE = curShiftPeriod.Shift.SFT_CODE; + wipSN.PRD_CODE = curShiftPeriod.Period.PRD_CODE; } //濡傛灉鏄姇鍏ョ珯 if (curNodeSetting.IS_INPUT == "Y") { - var woSN = woSNs.First(q => q.SN == wipSN.SN); + var woSN = woSNs.First(q => q.WIP_ID == wipSN.ID); woSN.STATUS = BIZ_MES_WO_SN.STATUSs.Inputed.GetValue(); wipSN.STATUS = MES_WIP_DATA.STATUSs.Input.GetValue(); wipSN.INLINE_DATE = DateTime.Now; @@ -389,7 +402,7 @@ //濡傛灉鏄骇鍑虹珯 if (curNodeSetting.IS_OUTPUT == "Y") { - var woSN = woSNs.First(q => q.SN == wipSN.SN); + var woSN = woSNs.First(q => q.WIP_ID == wipSN.ID); woSN.STATUS = BIZ_MES_WO_SN.STATUSs.Finished.GetValue(); wipSN.STATUS = MES_WIP_DATA.STATUSs.Finished.GetValue(); wipSN.OUTLINE_DATE = DateTime.Now; @@ -464,20 +477,20 @@ //鍒濆鍖栧伐姝ュ垪琛� Steps.Clear(); - var curStep = new WorkStep(IWorkStep.NodeTypes.Node, this) + var curStep = new WorkStep(IWorkStep.NodeTypes.Node, this) { Name = "鎵弿浜у搧", Sequence = Steps.Count + 1, - Node = curNode, + Node = curNode, OperSetting = CurBatch.NodeSets.FirstOrDefault(q => q.NODE_ID == curNode.ID), DBSubmitAction = () => - { + { //浣跨敤缁熶竴鐨勪簨鍔B瀵硅薄 var db = GetCommitDB(); //鏁版嵁淇濆瓨閫昏緫 - db.Storageable(_woSns, UserCode).ExecuteCommand(); - db.Storageable(_wipSns, UserCode).ExecuteCommand(); - db.Storageable(_wipHiss, UserCode).ExecuteCommand(); + db.Storageable(_woSns, UserCode).ExecuteCommand(); + db.Storageable(_wipSns, UserCode).ExecuteCommand(); + db.Storageable(_wipHiss, UserCode).ExecuteCommand(); //濡傛灉鏈変笉鑹垯淇濆瓨 if (_defect.Any()) { @@ -496,8 +509,8 @@ db.Updateable<BIZ_MES_WO_BATCH>().SetColumns(q => q.OUTPUT_QTY == q.OUTPUT_QTY + _woSns.Count).Where(q => q.BATCH_NO == _Batch.BATCH_NO).ExecuteCommand(); } } - }; - Steps.Add(curStep); + }; + Steps.Add(curStep); //鏈夐渶瑕佺敤鎴锋彁浜や俊鎭垯娣诲姞宸ュ簭鑺傜偣鐨勫叾浠栧伐姝� @@ -517,7 +530,7 @@ curStep.IsFinished = true; curStep.Status = StepStatus.Finished; CurStep = curStep; - } + } else if (!IsFinishNodeSteps) { var curStep = Steps.Where(q => q.NodeType == IWorkStep.NodeTypes.Node && !q.IsFinished).OrderBy(q => q.Sequence).First(); @@ -600,14 +613,15 @@ //淇濆瓨鎴愬姛锛岃繑鍥炶繃绔欐秷鎭� CurOperInfo(locale).InputQty += CurWipSNs.Count; + action.Data.Data = new PackingActionOutput() { PkgInfo = Context["CurPackage"] as WipPkg }; action.Data.OperInfo = SetOperNodeInfo(CurOperInfo(locale)); 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>()}]"); - action.LocaleMsg = new("MES.Transaction.CollectNode.ScanSn.PassSuccess", CurWipSNs.First().WORK_ORDER, CurSN, CurWipSNs.First().POST_CODE, CurWipSNs.First().NODE_NAME,CurWipSNs.First().STATUS.GetEnumDesc<MES_WIP_DATA.STATUSs>()); - + action.LocaleMsg = new("MES.Transaction.CollectNode.ScanSn.PassSuccess", CurWipSNs.First().WORK_ORDER, CurSN, CurWipSNs.First().POST_CODE, CurWipSNs.First().NODE_NAME, CurWipSNs.First().STATUS.GetEnumDesc<MES_WIP_DATA.STATUSs>()); + //閲嶇疆宸ュ簭 ResetNode(); - + return action; } @@ -621,7 +635,7 @@ try { //PkgSubmit锛氭墜鍔ㄧ粨鏉熷寘瑁咃紝淇濆瓨鏆傚瓨鐨勫寘瑁呮暟鎹� - if (NodeCmd.IsNullOrEmpty("PkgSubmit") == "PkgSubmit") + if (NodeCmd.IsNullOrEmpty("PkgSubmit") == "PkgSubmit" || CurWipSNs.IsNullOrEmpty()) { if (Context.ContainsKey("CurPackage")) { @@ -633,11 +647,11 @@ int curQty = CurPkg.Item.TotalQty; int ruleQty = TempPkgAction.PkgRule.GetTotalQty(); //鏈夊~鍑鸿揣鏁伴噺鍒欓獙璇佸綋鍓嶅寘瑁呮暟閲忓繀椤荤瓑浜庯紙鍑鸿揣鏁伴噺/鍖呰瑙勫垯鏁伴噺锛夌殑浣欐暟 - if (shipQty > 0 && curQty != shipQty % ruleQty) + if (shipQty > 0 && curQty != shipQty % ruleQty) { action.IsSuccessed = false; //action.LocaleMsg = new($"鍑鸿揣鏁伴噺璁惧畾涓篬{0}]锛岀洰鍓嶅寘瑁呬簡[{1}]锛屽寘瑁呭熬鏁扮殑鏁伴噺蹇呴渶鏄痆{2}]锛岃瑁呭鏁伴噺鍚庡啀缁撴潫鍖呰"); - action.LocaleMsg = new("MES.Transaction.PackingNode.NotMatchShipQty", shipQty, curQty, shipQty % ruleQty); + action.LocaleMsg = new("MES.Transaction.PackingNode.NotMatchShipQty", shipQty, curQty, shipQty % ruleQty); return action; } -- Gitblit v1.9.3