From eb0ad83719de660e5c4f7676aea4710625b6bd51 Mon Sep 17 00:00:00 2001
From: Rodney Chen <rodney.chen@hotmail.com>
Date: 星期四, 19 十二月 2024 21:55:43 +0800
Subject: [PATCH] WMS增加标准上下架功能事务

---
 Tiger.Business.MES/WorkAction/YadaAssembly.cs |   35 ++++++++++++++++++++++++++++-------
 1 files changed, 28 insertions(+), 7 deletions(-)

diff --git a/Tiger.Business.MES/WorkAction/YadaAssembly.cs b/Tiger.Business.MES/WorkAction/YadaAssembly.cs
index 506c8d8..40b91d8 100644
--- a/Tiger.Business.MES/WorkAction/YadaAssembly.cs
+++ b/Tiger.Business.MES/WorkAction/YadaAssembly.cs
@@ -9,6 +9,7 @@
 using Tiger.IBusiness.MES.WorkAction;
 using Tiger.Model;
 using Tiger.Model.Entitys.MES.Position;
+using Tiger.Model.MES.Yada;
 
 namespace Tiger.Business.MES.WorkAction
 {
@@ -16,6 +17,7 @@
     {
         #region Propertys & Variables
         #region 鍥哄畾鍐欐硶锛屽伐搴忎腑鐨勫繀瑕佷俊鎭�
+        public DbClient MainDB { get; set; }
         public bool IsFinished { get; set; } = false;
         public IWorkStep CurStep { get; set; }
         public IPosition CurPosition { get; set; }
@@ -24,6 +26,7 @@
         #endregion
         public List<BAS_PROD_BOM> Boms { get; set; } = new();
         public AssemblyInfo CurAssembly { get; set; } = new();
+        public List<mes_MOPickList> MoPickList { get; set; }
         #endregion Propertys & Variables
 
         #region Functions
@@ -34,6 +37,7 @@
         public void Init(IWorkStep curStep, IPosition position, MES_WO_NODE_ACT nodeAct, MES_WO_ACTION setting)
         {
             #region 鍥哄畾鍐欐硶锛岀粰榛樿鍙橀噺璧嬪��
+            MainDB = position.MainDB;
             CurStep = curStep;
             CurPosition = position;
             NodeAct = nodeAct;
@@ -41,7 +45,7 @@
             #endregion
 
             //鑾峰彇浜у搧BOM
-            Boms = Biz.Db.Queryable<BAS_PROD_BOM>().Where(q => q.PROD_CODE == CurPosition.WorkBatch.WO.ITEM_CODE).ToList();
+            Boms = MainDB.Queryable<BAS_PROD_BOM>().Where(q => q.PROD_CODE == CurPosition.WorkBatch.WO.ITEM_CODE).ToList();
             //鑾峰彇涓婃枡鐗╂枡
             var assyList = new List<AssemblySetting>();
             try
@@ -57,7 +61,7 @@
                 }
             }
             var codes = assyList.Select(q => q.ITEM_CODE).ToList();
-            var items = Biz.Db.Queryable<BAS_ITEM>().Where(q => codes.Contains(q.ITEM_CODE) && q.AUTH_ORG == CurPosition.WorkBatch.WO.AUTH_ORG).ToList();
+            var items = MainDB.Queryable<BAS_ITEM>().Where(q => codes.Contains(q.ITEM_CODE) && q.AUTH_ORG == CurPosition.WorkBatch.WO.AUTH_ORG).ToList();
             //鑾峰彇涓婃枡鐗╂枡鐨勬浛浠f枡
             foreach (var assy in assyList)
             {
@@ -74,7 +78,7 @@
 	                if (!bom.IsNullOrEmpty())
 	                {
 		                var subs = bom.SUB_CODE.Split(new string[] { "," }, StringSplitOptions.RemoveEmptyEntries);
-		                var surItems = Biz.Db.Queryable<BAS_ITEM>().Where(q => subs.Contains(q.ITEM_CODE) && q.AUTH_ORG == CurPosition.WorkBatch.WO.AUTH_ORG).ToList();
+		                var surItems = MainDB.Queryable<BAS_ITEM>().Where(q => subs.Contains(q.ITEM_CODE) && q.AUTH_ORG == CurPosition.WorkBatch.WO.AUTH_ORG).ToList();
                         foreach (var sub in surItems)
                         {
                             if (!item.SubItems.Any(q => q.ITEM_CODE == sub.ITEM_CODE))
@@ -86,6 +90,11 @@
 	                CurAssembly.Items.Add(item);
                 }
             }
+            //鑾峰彇宸ュ崟澶囨枡淇℃伅
+            MoPickList = Biz.DataSource["YadaU9C"].Client.Queryable<mes_MOPickList>().Where(q => q.MoDocNo == CurPosition.WorkBatch.WO.ORDER_NO).ToList();
+
+            CurStep.Message = Biz.L("鎵弿涓婃枡鐗╂枡");
+            CurStep.Status = StepStatus.Normal;
         }
 
         /// <summary>
@@ -153,9 +162,9 @@
                     //鏍规嵁鏉$爜瑙勫垯楠岃瘉涓婃枡鏄惁姝g‘
                     if (!item.RuleCode.IsNullOrEmpty())
                     {
-                        if (!Biz.CodeRule[item.RuleCode].IsNullOrEmpty())
+                        if (!Cache.CodeRule[item.RuleCode].IsNullOrEmpty())
                         {
-                            var result = Biz.CodeRule[item.RuleCode].Verify(input.SN);
+                            var result = Cache.CodeRule[item.RuleCode].Verify(input.SN);
                             if (!result.IsSuccessed)
                             {
                                 isOK = false;
@@ -181,9 +190,9 @@
                         {
                             if (!subItem.RULE_CODE.IsNullOrEmpty())
                             {
-                                if (!Biz.CodeRule[subItem.RULE_CODE].IsNullOrEmpty())
+                                if (!Cache.CodeRule[subItem.RULE_CODE].IsNullOrEmpty())
                                 {
-                                    var result = Biz.CodeRule[item.RuleCode].Verify(input.SN);
+                                    var result = Cache.CodeRule[item.RuleCode].Verify(input.SN);
                                     //鍙鏈変竴涓浛浠f枡閫氳繃楠岃瘉鍒欏彲浠ヤ笂鏂�
                                     if (result.IsSuccessed)
                                     {
@@ -195,6 +204,17 @@
                             }
                         }
                     }
+                    //濡傛灉褰撳墠鐗╂枡瀛樺湪澶囨枡琛ㄤ腑瀛樺湪鎺ㄨ崘鎵规锛屽垯涓婃枡鐗╂枡蹇呴』灞炰簬鍏舵帹鑽愭壒娆$殑鐗╂枡
+                    //var suggest = MoPickList.Where(q => q.Code == item.ItemInfo.ITEM_CODE && !q.SuggestedBatch.IsNullOrEmpty()).Select(q => q.SuggestedBatch).ToList();
+                    //if (isOK && suggest.Any())
+                    //{
+                    //    isOK = false;
+                    //    //鍦ㄦ帹鑽愭壒娆℃墍灞炲伐鍗曠殑鏉$爜涓瓨鍦�
+                    //    if (MainDB.Queryable<BIZ_MES_WO_SN>().Any(q => suggest.Contains(q.WORK_ORDER) && (q.SN == input.SN || q.FLOW_SN == input.SN || q.TRAY_SN == input.SN)))
+                    //    {
+                    //        isOK = true;
+                    //    }
+                    //}
                     //楠岃瘉閫氳繃鍒欎繚瀛樹笂鏂欎俊鎭�
                     if (isOK)
                     {
@@ -349,6 +369,7 @@
                     ACT_SN = wipSn.SN,
                     ACT_VALUE_1 = CurAssembly.ToJson(),
                     ACT_RESULT = "Y",
+                    ELAPSED_TIME = CurStep.GetElapsedTime().TotalMilliseconds.ToInt64(),
                     TRACE_INFO = $"浠ヤ笅鐗╂枡涓婃枡瀹屾垚锛歿string.Join(",", CurAssembly.Items.Select(q => $"{q.ItemInfo.ITEM_NAME}({q.ItemInfo.ITEM_CODE})"))}",
                 };
                 wipActs.Add(wipAct);

--
Gitblit v1.9.3