From 1c7cb41e75dece1ec91039625fcc434776df3821 Mon Sep 17 00:00:00 2001
From: 杨张扬 <634643841@qq.com>
Date: 星期二, 01 七月 2025 17:33:22 +0800
Subject: [PATCH] 满托入库按照第一层先入

---
 core/Monitor.cs |   59 ++++++++++++++++++++++++++++++++++++++++++++---------------
 1 files changed, 44 insertions(+), 15 deletions(-)

diff --git a/core/Monitor.cs b/core/Monitor.cs
index 8ffc3c5..f79b8a9 100644
--- a/core/Monitor.cs
+++ b/core/Monitor.cs
@@ -137,7 +137,7 @@
                                                                            && c.N_LOCK_STATE == 0 && c.N_CURRENT_NUM == 0
                                                                            && SqlFunc.Subqueryable<TN_Loc_Container>().Where(b => b.S_LOC_CODE == c.S_CODE).NotAny()//涓嶈兘鏈夎揣
                                                                            && c.C_ENABLE == "Y").
-                                                                           OrderBy(o => o.T_MODIFY, OrderByType.Asc).First();//鏌ヨ鍚堥�鐨勭粓鐐硅揣浣嶏紝鐩存帴鍒ゆ柇褰撳墠鏁伴噺涓�鍗冲彲
+                                                                           OrderBy(o => o.N_LAYER, OrderByType.Asc).First();//鏌ヨ鍚堥�鐨勭粓鐐硅揣浣嶏紝鐩存帴鍒ゆ柇褰撳墠鏁伴噺涓�鍗冲彲
 
                                                 if (endLoc != null)
                                                 {
@@ -370,7 +370,9 @@
                     return;
                 }
 
-                var endLoc = db.Queryable<TN_Location>().First(a => a.S_AREA_CODE == Settings.Areas[1]
+                var endLoc = db.Queryable<TN_Location>()
+                     .OrderBy(a => a.N_LAYER, OrderByType.Asc)
+                    .First(a => a.S_AREA_CODE == Settings.Areas[1]
                 && a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃�
                 && SqlFunc.Subqueryable<TN_Loc_Container>().Where(b => b.S_LOC_CODE == a.S_CODE).NotAny()//涓嶈兘鏈夎揣
                 );
@@ -483,7 +485,8 @@
                     var endLoc_2 = db.Queryable<TN_Location>()
                      .Where(o => o.S_AREA_CODE == Settings.Areas[2]
                       && SqlFunc.Subqueryable<TN_Loc_Container>().Where(b => b.S_LOC_CODE == o.S_CODE).NotAny()//涓嶈兘鏈夎揣
-                     && o.N_CURRENT_NUM == 0 && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == "鏃�).First();
+                     && o.N_CURRENT_NUM == 0 && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == "鏃�)
+                     .First();
 
                     if (endLoc_2 != null)
                     {
@@ -597,9 +600,13 @@
                     db.Updateable<TN_EquipProDetail>(targetEPD).UpdateColumns(it => new { it.ITEMSTATE }).ExecuteCommand();
 
                     var cginfo = db.Queryable<TN_CG_Detail>().First(a => a.S_ID == targetEPD.S_ID);
-                    cginfo.S_ITEM_STATE = "杩囨湡";
-                    cginfo.N_ITEM_STATE = 3;
-                    db.Updateable<TN_CG_Detail>(cginfo).UpdateColumns(it => new { it.S_ITEM_STATE, it.N_ITEM_STATE }).ExecuteCommand();
+
+                    if (cginfo != null)
+                    {
+                        cginfo.S_ITEM_STATE = "杩囨湡";
+                        cginfo.N_ITEM_STATE = 3;
+                        db.Updateable<TN_CG_Detail>(cginfo).UpdateColumns(it => new { it.S_ITEM_STATE, it.N_ITEM_STATE }).ExecuteCommand();
+                    }
                 }
 
                 // 鍚屾 TN_InventoryM 涓�TN_CG_Detail
@@ -626,21 +633,28 @@
                     db.Updateable<TN_InventoryM>(targetInM).UpdateColumns(it => new { it.ITEMSTATE }).ExecuteCommand();
 
                     var cginfo = db.Queryable<TN_CG_Detail>().First(a => a.S_ID == targetInM.S_ID);
-                    cginfo.S_ITEM_STATE = "杩囨湡";
-                    cginfo.N_ITEM_STATE = 3;
-                    db.Updateable<TN_CG_Detail>(cginfo).UpdateColumns(it => new { it.S_ITEM_STATE, it.N_ITEM_STATE }).ExecuteCommand();
+
+                    if (cginfo != null)
+                    {
+                        cginfo.S_ITEM_STATE = "杩囨湡";
+                        cginfo.N_ITEM_STATE = 3;
+                        db.Updateable<TN_CG_Detail>(cginfo).UpdateColumns(it => new { it.S_ITEM_STATE, it.N_ITEM_STATE }).ExecuteCommand();
+                    }
                 }
 
-                targetInM = db.Queryable<TN_InventoryM>().LeftJoin<TN_CG_Detail>((o, i) => o.S_ID == i.S_ID).
+               var targetInMList = db.Queryable<TN_InventoryM>().LeftJoin<TN_CG_Detail>((o, i) => o.S_ID == i.S_ID).
                  Where((o, i) => System.DateTime.Now < o.EXPIRATION
                    && ((i.S_ITEM_STATE == "寰呮" && i.N_ITEM_STATE == 1)
                    || (i.S_ITEM_STATE == "鍚堟牸" && i.N_ITEM_STATE == 0))
-                 ).First();
+                 ).ToList();
 
-                if (targetInM != null)//妫�祴鍑哄揩杩囨湡鐨勮揣鍝�+                if (targetInMList.Count > 0)//妫�祴鍑哄揩杩囨湡鐨勮揣鍝�                 {
-                    targetInM.EXPIRATION_DAY = SpecHelper.CalculateDaysDifference(System.DateTime.Now,targetInM.EXPIRATION).ToString();
-                    db.Updateable<TN_InventoryM>(targetInM).UpdateColumns(it => new { it.EXPIRATION_DAY }).ExecuteCommand();
+                    foreach (var item in targetInMList)
+                    {
+                        item.EXPIRATION_DAY = SpecHelper.CalculateDaysDifference(System.DateTime.Now, item.EXPIRATION).ToString();
+                    }
+                    db.Updateable<TN_InventoryM>(targetInMList).UpdateColumns(it => new { it.EXPIRATION_DAY }).ExecuteCommand();
                 }
 
                 targetInM = db.Queryable<TN_InventoryM>().First(a => Convert.ToInt32(a.EXPIRATION_DAY) > 0 && a.ITEMSTATE == "杩囨湡");
@@ -808,7 +822,22 @@
             }
             catch (Exception ex)
             {
-                LogHelper.Error($"鍙戠敓浜嗗紓甯革紝鍚屾TN_EquipProDetail寮傚父锛寋ex.Message}", ex);
+                // 鑾峰彇鏈�唴灞傚紓甯革紙閫氬父鏄疄闄呭紩鍙戦棶棰樼殑寮傚父锛�+                Exception innerEx = ex;
+                while (innerEx.InnerException != null)
+                {
+                    innerEx = innerEx.InnerException;
+                }
+
+                // 鑾峰彇鍫嗘爤甯т俊鎭�+                var stackTrace = new System.Diagnostics.StackTrace(innerEx, true);
+                var stackFrame = stackTrace.GetFrame(0); // 鑾峰彇鏈�《灞傜殑鍫嗘爤甯�+
+                // 鑾峰彇鏂囦欢鍚嶅拰琛屽彿
+                string fileName = stackFrame.GetFileName();
+                int lineNumber = stackFrame.GetFileLineNumber();
+
+                LogHelper.Error($"鍙戠敓浜嗗紓甯革紝鍚屾TN_EquipProDetail寮傚父锛屾枃浠�{fileName}, 琛屽彿:{lineNumber}, 閿欒:{ex.Message}\r\n{ex.StackTrace}", ex);
             }
         }
 

--
Gitblit v1.9.1