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