From 0859eca81c7d64fbc91c49928f78b50d6271760d Mon Sep 17 00:00:00 2001
From: Rodney Chen <rodney.chen@hotmail.com>
Date: 星期五, 11 十月 2024 00:48:31 +0800
Subject: [PATCH] 优化了一些已知问题

---
 Tiger.Business.MES/Transaction/PackingNode.cs |   57 +++++++++++++++++++++++++++++++++++----------------------
 1 files changed, 35 insertions(+), 22 deletions(-)

diff --git a/Tiger.Business.MES/Transaction/PackingNode.cs b/Tiger.Business.MES/Transaction/PackingNode.cs
index 448f73b..c4cc211 100644
--- a/Tiger.Business.MES/Transaction/PackingNode.cs
+++ b/Tiger.Business.MES/Transaction/PackingNode.cs
@@ -62,7 +62,6 @@
                 //NodeSubmit锛氫骇鍝佽繃绔欙紝姝e父浜у搧杩囩珯閫昏緫
                 else
                 {
-                    NodeCmd = "NodeSubmit";
                     //宸ユ鍒楄〃涓虹┖鎴栬�呭伐搴忚妭鐐瑰伐姝ユ湁鏈畬鎴愭椂锛屼紭鍏堝畬鎴愬伐搴忚妭鐐瑰伐姝�
                     if (Steps.IsNullOrEmpty() || !IsFinishNodeSteps)
                     {
@@ -88,7 +87,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 +109,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)
@@ -126,8 +125,8 @@
 	                                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)
+	                                    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();
@@ -253,12 +252,23 @@
             var curNode = CurBatch.GetNode(PostCode);
             try
             {
+                //宸ュ簭鑺傜偣閫昏緫澧炲姞濡傛灉鏍瑰熀褰撳墠宀椾綅鎵句笉鍒板搴斿伐搴忕殑鏃跺�欒鎶ラ敊
+                if (curNode.IsNullOrEmpty())
+                {
+                    action.Data.ShortMsg = new("鏈煡宸ュ簭", ShortMessage.Types.Error);
+                    action.IsSuccessed = false;
+                    //action.LocaleMsg = new($"宀椾綅[{0}]鍦ㄥ伐鍗昜{1}]宸ヨ壓璺嚎涓壘涓嶅埌瀵瑰簲鐨勫伐搴忥紝璇锋鏌ュ伐鍗曞伐鑹鸿矾绾夸腑宸ュ簭涓庡矖浣嶇殑缁戝畾鍏崇郴鏄惁姝g‘");
+                    action.LocaleMsg = new("MES.Transaction.PackingNode.NodeSubmit.OperateNodeError", PostCode, CurBatch.WO.ORDER_NO);
+                    return action;
+                }
+                var curNodeSetting = CurBatch.GetNodeSetting(curNode);
+
                 //褰撳伐姝ュ垪琛ㄤ负绌猴紝鍒欐墽琛屽綋鍓嶅伐搴忕殑蹇呰閫昏緫褰撲綔绗竴涓伐搴忚妭鐐癸紝瀹屾垚鍚庢寜闇�姹傚垱寤哄悗缁殑宸ユ鍒楄〃
                 if (Steps.IsNullOrEmpty())
                 {
                     BeginAt = DateTime.Now;
                     //鍒ゆ柇宸ュ崟瀹炴椂鐘舵�佸垽鏂槸鍚﹀彲浠ョ敓浜�
-                    var woStatus = CurBatch.CheckCanProduce(curNode);
+                    var woStatus = CurBatch.CheckCanProduce(curNode, curNodeSetting);
                     if (!woStatus.IsSuccessed)
                     {
                         woStatus.Data.ShortMsg = new("宸ュ崟寮傚父", ShortMessage.Types.Error);
@@ -319,10 +329,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()
                             {
@@ -337,7 +350,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;
@@ -369,17 +382,17 @@
 		                    wipSN.PRD_CODE = curShiftPeriod.Period.PRD_CODE;
                         }
                         //濡傛灉鏄姇鍏ョ珯
-                        if (curNode.IS_INPUT == "Y")
+                        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;
                         }
                         //濡傛灉鏄骇鍑虹珯
-                        if (curNode.IS_OUTPUT == "Y")
+                        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;
@@ -449,7 +462,7 @@
                     var _wipSns = wipSNs.Clone();
                     var _wipHiss = CurWipSNHiss.Clone();
                     var _defect = CurDefects.Clone();
-                    var _curNode = curNode.Clone();
+                    var _curNodeSetting = curNodeSetting.Clone();
                     var _Batch = CurBatch.Batch.Clone();
 
                     //鍒濆鍖栧伐姝ュ垪琛�
@@ -474,13 +487,13 @@
                                 db.Storageable(_defect, UserCode).ExecuteCommand();
                             }
                             //濡傛灉鏄姇鍏ョ珯
-                            if (_curNode.IS_INPUT == "Y")
+                            if (_curNodeSetting.IS_INPUT == "Y")
                             {
                                 db.Updateable<BIZ_MES_WO>().SetColumns(q => q.INPUT_QTY == q.INPUT_QTY + _woSns.Count).Where(q => q.ORDER_NO == _Batch.ORDER_NO).ExecuteCommand();
                                 db.Updateable<BIZ_MES_WO_BATCH>().SetColumns(q => q.INPUT_QTY == q.INPUT_QTY + _woSns.Count).Where(q => q.BATCH_NO == _Batch.BATCH_NO).ExecuteCommand();
                             }
                             //濡傛灉鏄骇鍑虹珯
-                            if (_curNode.IS_OUTPUT == "Y")
+                            if (_curNodeSetting.IS_OUTPUT == "Y")
                             {
                                 db.Updateable<BIZ_MES_WO>().SetColumns(q => q.OUTPUT_QTY == q.OUTPUT_QTY + _woSns.Count).Where(q => q.ORDER_NO == _Batch.ORDER_NO).ExecuteCommand();
                                 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();
@@ -591,7 +604,7 @@
             //淇濆瓨鎴愬姛锛岃繑鍥炶繃绔欐秷鎭�
             CurOperInfo(locale).InputQty += CurWipSNs.Count;
             action.Data.OperInfo = SetOperNodeInfo(CurOperInfo(locale));
-            action.Data.ShortMsg = new("杩囩珯鎴愬姛", ShortMessage.Types.Success);
+            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>());
             
@@ -611,18 +624,15 @@
             try
             {
                 //PkgSubmit锛氭墜鍔ㄧ粨鏉熷寘瑁咃紝淇濆瓨鏆傚瓨鐨勫寘瑁呮暟鎹�
-                if (NodeCmd.IsNullOrEmpty("PkgSubmit") == "PkgSubmit")
+                if (NodeCmd.IsNullOrEmpty("PkgSubmit") == "PkgSubmit" || CurWipSNs.IsNullOrEmpty())
                 {
                     if (Context.ContainsKey("CurPackage"))
                     {
-                        var CurPkg = Context["CurPackage"] as WipPkg;
-                        int shipQty = input.Data.ToInt32();
-    
-                        NodeCmd = "PkgSubmit";
-
                         TempPkgAction = new PackingAction();
                         TempPkgAction.Init(this);
 
+                        var CurPkg = Context["CurPackage"] as WipPkg;
+                        int shipQty = input.Data.ToInt32();
                         int curQty = CurPkg.Item.TotalQty;
                         int ruleQty = TempPkgAction.PkgRule.GetTotalQty();
                         //鏈夊~鍑鸿揣鏁伴噺鍒欓獙璇佸綋鍓嶅寘瑁呮暟閲忓繀椤荤瓑浜庯紙鍑鸿揣鏁伴噺/鍖呰瑙勫垯鏁伴噺锛夌殑浣欐暟
@@ -633,6 +643,8 @@
                             action.LocaleMsg = new("MES.Transaction.PackingNode.NotMatchShipQty", shipQty, curQty, shipQty % ruleQty); 
                             return action;
                         }
+
+                        NodeCmd = "PkgSubmit";
                         action = TempPkgAction.Submit(null);
                     }
                     else
@@ -660,6 +672,7 @@
             catch (Exception ex)
             {
                 action.CatchExceptionWithLog(ex, $"鍖呰宸ュ簭锛氭墜鍔ㄧ粨鏉熷寘瑁呭紓甯�");
+                NodeCmd = null;
             }
             return action;
         }

--
Gitblit v1.9.3