From 99d001bbf2a0371373e15c97d3c6c7dcf45e97e3 Mon Sep 17 00:00:00 2001
From: kazelee <1847801760@qq.com>
Date: 星期五, 13 六月 2025 15:44:22 +0800
Subject: [PATCH] 修复空托上线与满托下线联调的逻辑错误

---
 .vs/HH.WCS.Mobox3.DSZSH/FileContentIndex/72b74e1b-3ce7-462f-a4d7-ab0ffca83287.vsidx |    0 
 api/DebugController.cs                                                              |  134 ++++++++++++++------------
 .vs/HH.WCS.Mobox3.DSZSH/FileContentIndex/d49484c3-00c1-4b7d-9deb-0d030288ff5a.vsidx |    0 
 core/Monitor.cs                                                                     |  133 ++++++++++++++-----------
 /dev/null                                                                           |    0 
 .vs/HH.WCS.Mobox3.DSZSH/FileContentIndex/f0bbbb2f-3b58-4dfe-8ac7-534413626ac1.vsidx |    0 
 api/ApiHelper.cs                                                                    |   10 +
 7 files changed, 154 insertions(+), 123 deletions(-)

diff --git a/.vs/HH.WCS.Mobox3.DSZSH/FileContentIndex/16cec1d3-204a-4803-a3d3-25bcd983bea9.vsidx b/.vs/HH.WCS.Mobox3.DSZSH/FileContentIndex/16cec1d3-204a-4803-a3d3-25bcd983bea9.vsidx
deleted file mode 100644
index 72200f6..0000000
--- a/.vs/HH.WCS.Mobox3.DSZSH/FileContentIndex/16cec1d3-204a-4803-a3d3-25bcd983bea9.vsidx
+++ /dev/null
Binary files differ
diff --git a/.vs/HH.WCS.Mobox3.DSZSH/FileContentIndex/1912c2ce-d2a9-4b1c-82fe-620c78efc36f.vsidx b/.vs/HH.WCS.Mobox3.DSZSH/FileContentIndex/1912c2ce-d2a9-4b1c-82fe-620c78efc36f.vsidx
deleted file mode 100644
index 0725a14..0000000
--- a/.vs/HH.WCS.Mobox3.DSZSH/FileContentIndex/1912c2ce-d2a9-4b1c-82fe-620c78efc36f.vsidx
+++ /dev/null
Binary files differ
diff --git a/.vs/HH.WCS.Mobox3.DSZSH/FileContentIndex/43738d2c-dc76-49d4-9704-65742496dac9.vsidx b/.vs/HH.WCS.Mobox3.DSZSH/FileContentIndex/43738d2c-dc76-49d4-9704-65742496dac9.vsidx
deleted file mode 100644
index d2cb725..0000000
--- a/.vs/HH.WCS.Mobox3.DSZSH/FileContentIndex/43738d2c-dc76-49d4-9704-65742496dac9.vsidx
+++ /dev/null
Binary files differ
diff --git a/.vs/HH.WCS.Mobox3.DSZSH/FileContentIndex/72b74e1b-3ce7-462f-a4d7-ab0ffca83287.vsidx b/.vs/HH.WCS.Mobox3.DSZSH/FileContentIndex/72b74e1b-3ce7-462f-a4d7-ab0ffca83287.vsidx
new file mode 100644
index 0000000..3bb3ce4
--- /dev/null
+++ b/.vs/HH.WCS.Mobox3.DSZSH/FileContentIndex/72b74e1b-3ce7-462f-a4d7-ab0ffca83287.vsidx
Binary files differ
diff --git a/.vs/HH.WCS.Mobox3.DSZSH/FileContentIndex/af8508f5-ad22-43b1-b70b-0efaa94c3359.vsidx b/.vs/HH.WCS.Mobox3.DSZSH/FileContentIndex/d49484c3-00c1-4b7d-9deb-0d030288ff5a.vsidx
similarity index 75%
rename from .vs/HH.WCS.Mobox3.DSZSH/FileContentIndex/af8508f5-ad22-43b1-b70b-0efaa94c3359.vsidx
rename to .vs/HH.WCS.Mobox3.DSZSH/FileContentIndex/d49484c3-00c1-4b7d-9deb-0d030288ff5a.vsidx
index b7b8a2a..5b54bf1 100644
--- a/.vs/HH.WCS.Mobox3.DSZSH/FileContentIndex/af8508f5-ad22-43b1-b70b-0efaa94c3359.vsidx
+++ b/.vs/HH.WCS.Mobox3.DSZSH/FileContentIndex/d49484c3-00c1-4b7d-9deb-0d030288ff5a.vsidx
Binary files differ
diff --git a/.vs/HH.WCS.Mobox3.DSZSH/FileContentIndex/f0bbbb2f-3b58-4dfe-8ac7-534413626ac1.vsidx b/.vs/HH.WCS.Mobox3.DSZSH/FileContentIndex/f0bbbb2f-3b58-4dfe-8ac7-534413626ac1.vsidx
new file mode 100644
index 0000000..ac77e73
--- /dev/null
+++ b/.vs/HH.WCS.Mobox3.DSZSH/FileContentIndex/f0bbbb2f-3b58-4dfe-8ac7-534413626ac1.vsidx
Binary files differ
diff --git a/api/ApiHelper.cs b/api/ApiHelper.cs
index fabea4d..d851211 100644
--- a/api/ApiHelper.cs
+++ b/api/ApiHelper.cs
@@ -218,6 +218,8 @@
                     S_CNTR_TYPE = cntrType, // 绌烘墭鍏ュ簱
                 };
 
+                startLoc.N_CURRENT_NUM = 1; // 缁戝畾鍚�+
                 var endLoc = db.Queryable<TN_Location>()
                     .Where(l => Settings.AreaMap[endAreaName].Contains(l.S_AREA_CODE))
                     .Where(l => l.N_LOCK_STATE == 0 && l.S_LOCK_STATE == "鏃� && l.C_ENABLE == "Y")
@@ -275,7 +277,8 @@
                         it.N_LOCK_STATE,
                         it.S_LOCK_STATE,
                         it.S_LOCK_OP,
-                        it.T_MODIFY
+                        it.T_MODIFY,
+                        it.N_CURRENT_NUM
                     }).ExecuteCommand() <= 0) {
                         tran.RollbackTran();
                         info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂拌捣鐐硅揣浣�{startLoc.S_CODE}'閿佺姸鎬佸け璐�;
@@ -386,6 +389,8 @@
                     S_CNTR_TYPE = cntrType,
                 };
 
+                startLoc.N_CURRENT_NUM = 1; // 缁戝畾鍚�+
                 var endLoc = db.Queryable<TN_Location>()
                     .Where(l => Settings.AreaMap[endAreaName].Contains(l.S_AREA_CODE))
                     .Where(l => l.N_LOCK_STATE == 0 && l.S_LOCK_STATE == "鏃� && l.C_ENABLE == "Y")
@@ -445,7 +450,8 @@
                         it.N_LOCK_STATE,
                         it.S_LOCK_STATE,
                         it.S_LOCK_OP,
-                        it.T_MODIFY
+                        it.T_MODIFY,
+                        it.N_CURRENT_NUM
                     }).ExecuteCommand() <= 0) {
                         tran.RollbackTran();
                         info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂拌捣鐐硅揣浣�{startLoc.S_CODE}'閿佺姸鎬佸け璐�;
diff --git a/api/DebugController.cs b/api/DebugController.cs
index b723b09..836c7d7 100644
--- a/api/DebugController.cs
+++ b/api/DebugController.cs
@@ -200,47 +200,48 @@
             const string taskName = TaskName.T鎵樼洏_婊℃墭涓嬬嚎鍏ュ簱;
             const string startAreaName = AreaName.B鍖呰鍖�
             const string endAreaName = AreaName.M婊℃墭璐ф灦鍖�
+            const string cntrType = "鎵樼洏";
 
             try {
-                var itemCode = model.ItemCode;
-                var batchNo = model.BatchNo;
+                //var itemCode = model.ItemCode;
+                //var batchNo = model.BatchNo;
                 var cntrCode = model.CntrCode;
                 var startLocCode = model.StartLoc;
 
-                var cgDetail = new TN_CG_Detail {
-                    S_ITEM_CODE = itemCode,
-                    S_BATCH_NO = batchNo,
-                    S_CNTR_CODE = cntrCode,
-                };
+                //var cgDetail = new TN_CG_Detail {
+                //    S_ITEM_CODE = itemCode,
+                //    S_BATCH_NO = batchNo,
+                //    S_CNTR_CODE = cntrCode,
+                //};
 
-                var needInsertContainer = false;
-                var needUpdateContainer = false;
+                //var needInsertContainer = false;
+                //var needUpdateContainer = false;
                 // 鏌ュ鍣ㄤ俊鎭〃鏄惁宸茬粡鏈夎繖涓鍣�-                var cntr = db.Queryable<TN_Container>()
-                    .Where(c => c.S_CODE == cntrCode).First();
+                //var cntr = db.Queryable<TN_Container>()
+                //    .Where(c => c.S_CODE == cntrCode).First();
                 // 濡傛灉鎵句笉鍒拌瀹瑰櫒锛岄渶瑕佹坊鍔狅紝骞朵笖灏嗗鍣ㄦ潵婧愯缃负浠诲姟鍚嶇О
-                if (cntr == null) {
-                    needInsertContainer = true;
-                    LogHelper.Info($"杞锛歿taskName}锛氬鍣細{cntrCode}锛屽湪瀹瑰櫒琛ㄤ腑娌℃湁鐧昏锛岀櫥璁板苟璁剧疆瀹瑰櫒鏉ユ簮涓猴細{taskName}");
+                //if (cntr == null) {
+                //    needInsertContainer = true;
+                //    LogHelper.Info($"杞锛歿taskName}锛氬鍣細{cntrCode}锛屽湪瀹瑰櫒琛ㄤ腑娌℃湁鐧昏锛岀櫥璁板苟璁剧疆瀹瑰櫒鏉ユ簮涓猴細{taskName}");
 
-                    cntr = new TN_Container {
-                        S_CODE = cntrCode,
-                        S_TYPE = "鎵樼洏",
-                        S_SPEC = itemCode,
-                        S_SOURCE = taskName,
-                    };
-                }
-                else {
-                    // 濡傛灉鎵惧埌璇ュ鍣紝浣嗗鍣ㄧ墿鏂欑被鍨嬩笌涓嬬嚎鐗╂枡涓嶇锛岃褰曞苟鐩存帴瑕嗙洊锛堝緟瀹氾級
-                    if (!string.IsNullOrEmpty(cntr.S_SPEC) && cntr.S_SPEC != itemCode) {
-                        needUpdateContainer = true;
-                        LogHelper.Info($"杞锛歿taskName}锛氬鍣ㄨ〃涓鍣▄cntrCode}瀵瑰簲鐨勭墿鏂欎俊鎭細{cntr.S_SPEC}锛� +
-                            $"涓庢墍闇�鐨勭墿鏂欎俊鎭瘂itemCode}涓嶇锛岀洿鎺ヨ鐩栫粨鏋�);
+                //    cntr = new TN_Container {
+                //        S_CODE = cntrCode,
+                //        S_TYPE = "鎵樼洏",
+                //        S_SPEC = itemCode,
+                //        S_SOURCE = taskName,
+                //    };
+                //}
+                //else {
+                //    // 濡傛灉鎵惧埌璇ュ鍣紝浣嗗鍣ㄧ墿鏂欑被鍨嬩笌涓嬬嚎鐗╂枡涓嶇锛岃褰曞苟鐩存帴瑕嗙洊锛堝緟瀹氾級
+                //    if (!string.IsNullOrEmpty(cntr.S_SPEC) && cntr.S_SPEC != itemCode) {
+                //        needUpdateContainer = true;
+                //        LogHelper.Info($"杞锛歿taskName}锛氬鍣ㄨ〃涓鍣▄cntrCode}瀵瑰簲鐨勭墿鏂欎俊鎭細{cntr.S_SPEC}锛� +
+                //            $"涓庢墍闇�鐨勭墿鏂欎俊鎭瘂itemCode}涓嶇锛岀洿鎺ヨ鐩栫粨鏋�);
 
-                        cntr.S_SPEC = itemCode;
-                        cntr.S_SOURCE = taskName;
-                    }
-                }
+                //        cntr.S_SPEC = itemCode;
+                //        cntr.S_SOURCE = taskName;
+                //    }
+                //}
 
                 var startLoc = db.Queryable<TN_Location>()
                     .Where(l => l.S_CODE == startLocCode)
@@ -255,12 +256,17 @@
                     return info;
                 }
 
+                var locCntrRelOld = db.Queryable<TN_Loc_Container>()
+                    .Where(c => c.S_CNTR_CODE == cntrCode).First();
+
                 // 缁戝畾璐т綅鍜屽鍣ㄥ彿
                 var locCntrRel = new TN_Loc_Container {
                     S_LOC_CODE = startLocCode,
-                    S_CNTR_CODE = cgDetail.S_CNTR_CODE,
-                    S_CNTR_TYPE = "鎵樼洏",
+                    S_CNTR_CODE = cntrCode,
+                    S_CNTR_TYPE = cntrType,
                 };
+
+                startLoc.N_CURRENT_NUM = 1; // 缁戝畾鍚� 
                 var endLoc = db.Queryable<TN_Location>()
                     .Where(a => Settings.AreaMap[endAreaName].Contains(a.S_AREA_CODE))
@@ -282,29 +288,38 @@
                 LocationHelper.LockEndLoc(ref endLoc); // 缁堢偣鍏ュ簱閿� 
                 using (var tran = db.Ado.UseTran()) {
-                    if (db.Insertable<TN_CG_Detail>(cgDetail).ExecuteCommand() <= 0) {
-                        tran.RollbackTran();
-                        info = $"鎻掑叆瀹瑰櫒璐у搧淇℃伅琛ㄥけ璐ワ細鐗╂枡缂栫爜{cgDetail.S_ITEM_CODE}锛屽鍣ㄧ紪鐮亄cgDetail.S_CNTR_CODE}";
-                        LogHelper.Info(info);
-                        return info;
+                    if (locCntrRelOld != null) {
+                        if (db.Deleteable<TN_Loc_Container>(locCntrRelOld).ExecuteCommand() <= 0 &&
+                            db.Updateable<TN_Location>().SetColumns(l => l.N_CURRENT_NUM == 0).Where(l => l.S_CODE == locCntrRelOld.S_LOC_CODE).ExecuteCommand() <= 0) {
+                            tran.RollbackTran();
+                            info = $"鍒犻櫎鏃ц揣浣嶅鍣ㄥ叧绯昏〃澶辫触锛氳揣浣嶇紪鐮亄locCntrRelOld.S_LOC_CODE}锛屽鍣ㄧ紪鐮亄locCntrRelOld.S_CNTR_CODE}";
+                            LogHelper.Info(info);
+                            return info;
+                        }
                     }
+                    //if (db.Insertable<TN_CG_Detail>(cgDetail).ExecuteCommand() <= 0) {
+                    //    tran.RollbackTran();
+                    //    info = $"鎻掑叆瀹瑰櫒璐у搧淇℃伅琛ㄥけ璐ワ細鐗╂枡缂栫爜{cgDetail.S_ITEM_CODE}锛屽鍣ㄧ紪鐮亄cgDetail.S_CNTR_CODE}";
+                    //    LogHelper.Info(info);
+                    //    return info;
+                    //}
 
-                    if (needInsertContainer) {
-                        if (db.Insertable<TN_Container>(cntr).ExecuteCommand() <= 0) {
-                            info = $"鎻掑叆瀹瑰櫒琛ㄥけ璐ワ細" + JsonConvert.SerializeObject(cntr);
-                            tran.RollbackTran();
-                            LogHelper.Info(info);
-                            return info;
-                        }
-                    }
-                    else if (needUpdateContainer) {
-                        if (db.Updateable<TN_Container>(cntr).ExecuteCommand() <= 0) {
-                            info = $"鏇存柊瀹瑰櫒琛ㄥけ璐ワ細" + JsonConvert.SerializeObject(cntr);
-                            tran.RollbackTran();
-                            LogHelper.Info(info);
-                            return info;
-                        }
-                    }
+                    //if (needInsertContainer) {
+                    //    if (db.Insertable<TN_Container>(cntr).ExecuteCommand() <= 0) {
+                    //        info = $"鎻掑叆瀹瑰櫒琛ㄥけ璐ワ細" + JsonConvert.SerializeObject(cntr);
+                    //        tran.RollbackTran();
+                    //        LogHelper.Info(info);
+                    //        return info;
+                    //    }
+                    //}
+                    //else if (needUpdateContainer) {
+                    //    if (db.Updateable<TN_Container>(cntr).ExecuteCommand() <= 0) {
+                    //        info = $"鏇存柊瀹瑰櫒琛ㄥけ璐ワ細" + JsonConvert.SerializeObject(cntr);
+                    //        tran.RollbackTran();
+                    //        LogHelper.Info(info);
+                    //        return info;
+                    //    }
+                    //}
 
                     if (db.Insertable<TN_Loc_Container>(locCntrRel).ExecuteCommand() <= 0) {
                         tran.RollbackTran();
@@ -313,12 +328,7 @@
                         return info;
                     }
 
-                    if (db.Updateable<TN_Location>(startLoc).UpdateColumns(it => new {
-                        it.N_LOCK_STATE,
-                        it.S_LOCK_STATE,
-                        it.S_LOCK_OP,
-                        it.T_MODIFY
-                    }).ExecuteCommand() <= 0) {
+                    if (db.Updateable<TN_Location>(startLoc).UpdateColumns(it => new { it.N_LOCK_STATE, it.S_LOCK_STATE, it.S_LOCK_OP, it.T_MODIFY, it.N_CURRENT_NUM }).ExecuteCommand() <= 0) {
                         tran.RollbackTran();
                         info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂拌捣鐐硅揣浣峽startLoc.S_CODE}閿佺姸鎬佸け璐�;
                         LogHelper.Info(info);
@@ -360,11 +370,11 @@
 
     public class AddInboundTaskInfo {
         /// <summary>
-        /// 鐗╂枡缂栫爜
+        /// 鐗╂枡缂栫爜锛堟殏鏃舵病鐢級
         /// </summary>
         public string ItemCode { get; set; }
         /// <summary>
-        /// 鎵规鍙�+        /// 鎵规鍙凤紙鏆傛椂娌$敤锛�         /// </summary>
         public string BatchNo { get; set; }
         /// <summary>
diff --git a/core/Monitor.cs b/core/Monitor.cs
index 5c83eba..23f9962 100644
--- a/core/Monitor.cs
+++ b/core/Monitor.cs
@@ -25,6 +25,8 @@
             var info = "";
 
             const string taskName = TaskName.T鎵樼洏_婊℃墭涓嬬嚎鍏ュ簱;
+            const string startAreaName = AreaName.B鍖呰鍖�
+            const string endAreaName = AreaName.M婊℃墭璐ф灦鍖�
             const string cntrType = "鎵樼洏";
 
             try {
@@ -56,78 +58,82 @@
 
                     LogHelper.Info(JsonConvert.SerializeObject(data));
 
-                    var itemCode = data.item_code;
-                    var batchNo = data.batch_no;
+                    //var itemCode = data.item_code;
+                    //var batchNo = data.batch_no;
                     var cntrCode = data.cntr_code;
 
                     var startLocCode = prod.OffLoc[0]; // 鐢ㄤ簬娴嬭瘯
                     //var startLocCode = "CX01"; // 鐢ㄤ簬娴嬭瘯
 
-                    var cgDetail = new TN_CG_Detail {
-                        S_ITEM_CODE = itemCode,
-                        S_BATCH_NO = batchNo,
-                        S_CNTR_CODE = cntrCode,
-                    };
+                    //var cgDetail = new TN_CG_Detail { // 绌烘墭涓婄嚎鏃跺氨缁戝畾濂戒簡
+                    //    S_ITEM_CODE = itemCode,
+                    //    S_BATCH_NO = batchNo,
+                    //    S_CNTR_CODE = cntrCode,
+                    //};
 
-                    var needInsertContainer = false;
-                    var needUpdateContainer = false;
+                    //var needInsertContainer = false;
+                    //var needUpdateContainer = false;
 
                     // TEMP 鑷姩瑙﹀彂鐨勬墭鐩樹笅绾挎殏鏃朵笉鑰冭檻鍒ゆ柇锛岄粯璁ゆ病鏈夋椂鍐欏叆
                     // 鏌ュ鍣ㄤ俊鎭〃鏄惁宸茬粡鏈夎繖涓鍣�-                    var cntr = db.Queryable<TN_Container>()
-                        .Where(c => c.S_CODE == cntrCode).First();
+                    //var cntr = db.Queryable<TN_Container>()
+                    //    .Where(c => c.S_CODE == cntrCode).First();
                     // 濡傛灉鎵句笉鍒拌瀹瑰櫒锛岄渶瑕佹坊鍔狅紝骞朵笖灏嗗鍣ㄦ潵婧愯缃负浠诲姟鍚嶇О
-                    if (cntr == null) {
-                        needInsertContainer = true;
-                        LogHelper.Info($"杞锛歿taskName}锛氬鍣細{cntrCode}锛屽湪瀹瑰櫒琛ㄤ腑娌℃湁鐧昏锛岀櫥璁板苟璁剧疆瀹瑰櫒鏉ユ簮涓猴細{taskName}");
+                    //if (cntr == null) {
+                    //    needInsertContainer = true;
+                    //    LogHelper.Info($"杞锛歿taskName}锛氬鍣細{cntrCode}锛屽湪瀹瑰櫒琛ㄤ腑娌℃湁鐧昏锛岀櫥璁板苟璁剧疆瀹瑰櫒鏉ユ簮涓猴細{taskName}");
 
-                        cntr = new TN_Container {
-                            S_CODE = cntrCode,
-                            S_TYPE = cntrType,
-                            S_SPEC = itemCode,
-                        };
-                    }
-                    else {
-                        // 濡傛灉鎵惧埌璇ュ鍣紝浣嗗鍣ㄧ墿鏂欑被鍨嬩笌涓嬬嚎鐗╂枡涓嶇锛岃褰曞苟鐩存帴瑕嗙洊锛堝緟瀹氾級
-                        if (!string.IsNullOrEmpty(cntr.S_SPEC) && cntr.S_SPEC != itemCode) {
-                            needUpdateContainer = true;
-                            LogHelper.Info($"杞锛歿taskName}锛氬鍣ㄨ〃涓鍣▄cntrCode}瀵瑰簲鐨勭墿鏂欎俊鎭細{cntr.S_SPEC}锛� +
-                                $"涓庢墍闇�鐨勭墿鏂欎俊鎭瘂itemCode}涓嶇锛岀洿鎺ヨ鐩栫粨鏋�);
+                    //    cntr = new TN_Container {
+                    //        S_CODE = cntrCode,
+                    //        S_TYPE = cntrType,
+                    //        S_SPEC = itemCode,
+                    //    };
+                    //}
+                    //else {
+                    //    濡傛灉鎵惧埌璇ュ鍣紝浣嗗鍣ㄧ墿鏂欑被鍨嬩笌涓嬬嚎鐗╂枡涓嶇锛岃褰曞苟鐩存帴瑕嗙洊锛堝緟瀹氾級
+                    //    if (!string.IsNullOrEmpty(cntr.S_SPEC) && cntr.S_SPEC != itemCode) {
+                    //        needUpdateContainer = true;
+                    //        LogHelper.Info($"杞锛歿taskName}锛氬鍣ㄨ〃涓鍣▄cntrCode}瀵瑰簲鐨勭墿鏂欎俊鎭細{cntr.S_SPEC}锛� +
+                    //            $"涓庢墍闇�鐨勭墿鏂欎俊鎭瘂itemCode}涓嶇锛岀洿鎺ヨ鐩栫粨鏋�);
 
-                            cntr.S_SPEC = itemCode;
-                        }
-                    }
+                    //        cntr.S_SPEC = itemCode;
+                    //    }
+                    //}
 
                     var startLoc = db.Queryable<TN_Location>()
-                        .Where(l => l.S_CODE == startLocCode) // 鎸囧畾锛氳捣鐐硅揣浣嶅彿
-                        .Where(l => l.N_LOCK_STATE == 0 && l.S_LOCK_STATE == "鏃� && l.C_ENABLE == "Y") // 绛涢�锛氭湭涓婇攣
-                        .Where(l => l.N_CURRENT_NUM == 0)
-                        .First();
+                    .Where(l => l.S_CODE == startLocCode)
+                    .Where(l => Settings.AreaMap[startAreaName].Contains(l.S_AREA_CODE))
+                    .Where(l => l.N_LOCK_STATE == 0 && l.S_LOCK_STATE == "鏃� && l.C_ENABLE == "Y")
+                    //.Where(l => l.N_CURRENT_NUM == 0) // 缁戝畾鍓�+                    .First();
 
                     if (startLoc == null) {
-                        info = $"璧风偣浣嶇疆 '{startLocCode}' 涓嶅瓨鍦ㄦ垨涓嶅叿澶囧彇璐ц姹�;
+                        info = $"鍦�{startAreaName}'涓病鏈夋壘鍒拌捣鐐硅揣浣�{startLocCode}'锛屾垨涓嶆弧瓒宠姹傦細鏈笂閿併�褰撳墠瀹瑰櫒鏁伴噺=0";
                         LogHelper.Info(info);
-                        continue;
                     }
+
+                    var locCntrRelOld = db.Queryable<TN_Loc_Container>()
+                        .Where(c => c.S_CNTR_CODE == cntrCode).First();
 
                     // 缁戝畾璐т綅鍜屽鍣ㄥ彿
                     var locCntrRel = new TN_Loc_Container {
                         S_LOC_CODE = startLocCode,
-                        S_CNTR_CODE = cgDetail.S_CNTR_CODE,
+                        S_CNTR_CODE = cntrCode,
                         S_CNTR_TYPE = cntrType,
                     };
 
+                    startLoc.N_CURRENT_NUM = 1; // 缁戝畾鍚�+
                     var endLoc = db.Queryable<TN_Location>()
-                        .Where(a => Settings.AreaMap[AreaName.K绌烘墭瀛樻斁鍖篯.Contains(a.S_AREA_CODE))
+                        .Where(a => Settings.AreaMap[endAreaName].Contains(a.S_AREA_CODE))
                         .Where(a => a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y") // 绛涢�锛氭湭涓婇攣
                         .Where(a => a.N_CURRENT_NUM == 0) // 绛涢�锛氱┖璐т綅
                         .OrderBy(l => l.N_LAYER)
                         .First();
 
                     if (endLoc == null) {
-                        info = "绌烘墭鍏ュ簱鏆傛椂娌℃湁鍚堥�鐨勮揣浣嶅彲浠ュ叆搴�;
+                        info = $"鍦ㄧ粓鐐硅揣鍖�{endAreaName}'涓紝娌℃湁鎵惧埌鍚堥�鐨勩�缁堢偣璐т綅銆戯紝闇�婊¤冻瑕佹眰锛氭湭涓婇攣銆佸綋鍓嶅鍣ㄦ暟閲�0";
                         LogHelper.Info(info);
-                        continue;
                     }
 
                     var cntId = locCntrRel.S_CNTR_CODE;
@@ -136,34 +142,43 @@
                     LocationHelper.LockStartLoc(ref startLoc); // 璧风偣鍑哄簱閿�                     LocationHelper.LockEndLoc(ref endLoc); // 缁堢偣鍏ュ簱閿� 
-                    cntr.S_SOURCE = task.S_CODE;
-                    cntr.T_MODIFY = DateTime.Now;
+                    //cntr.S_SOURCE = task.S_CODE;
+                    //cntr.T_MODIFY = DateTime.Now;
 
                     using (var tran = db.Ado.UseTran()) {
-                        if (needInsertContainer) {
-                            if (db.Insertable<TN_Container>(cntr).ExecuteCommand() <= 0) {
-                                info = $"鎻掑叆瀹瑰櫒琛ㄥけ璐ワ細" + JsonConvert.SerializeObject(cntr);
+                        if (locCntrRelOld != null) {
+                            if (db.Deleteable<TN_Loc_Container>(locCntrRelOld).ExecuteCommand() <= 0 &&
+                                db.Updateable<TN_Location>().SetColumns(l => l.N_CURRENT_NUM == 0).Where(l => l.S_CODE == locCntrRelOld.S_LOC_CODE).ExecuteCommand() <= 0) {
                                 tran.RollbackTran();
+                                info = $"鍒犻櫎鏃ц揣浣嶅鍣ㄥ叧绯昏〃澶辫触锛氳揣浣嶇紪鐮亄locCntrRelOld.S_LOC_CODE}锛屽鍣ㄧ紪鐮亄locCntrRelOld.S_CNTR_CODE}";
                                 LogHelper.Info(info);
                                 continue;
                             }
                         }
-                        else if (needUpdateContainer) {
-                            if (db.Updateable<TN_Container>(cntr)
-                                .UpdateColumns(c => new { c.S_SPEC, c.S_SOURCE, c.T_MODIFY }).ExecuteCommand() <= 0) {
-                                info = $"鏇存柊瀹瑰櫒琛ㄥけ璐ワ細" + JsonConvert.SerializeObject(cntr);
-                                tran.RollbackTran();
-                                LogHelper.Info(info);
-                                continue;
-                            }
-                        }
+                        //if (needInsertContainer) {
+                        //    if (db.Insertable<TN_Container>(cntr).ExecuteCommand() <= 0) {
+                        //        info = $"鎻掑叆瀹瑰櫒琛ㄥけ璐ワ細" + JsonConvert.SerializeObject(cntr);
+                        //        tran.RollbackTran();
+                        //        LogHelper.Info(info);
+                        //        continue;
+                        //    }
+                        //}
+                        //else if (needUpdateContainer) {
+                        //    if (db.Updateable<TN_Container>(cntr)
+                        //        .UpdateColumns(c => new { c.S_SPEC, c.S_SOURCE, c.T_MODIFY }).ExecuteCommand() <= 0) {
+                        //        info = $"鏇存柊瀹瑰櫒琛ㄥけ璐ワ細" + JsonConvert.SerializeObject(cntr);
+                        //        tran.RollbackTran();
+                        //        LogHelper.Info(info);
+                        //        continue;
+                        //    }
+                        //}
 
-                        if (db.Insertable<TN_CG_Detail>(cgDetail).ExecuteCommand() <= 0) {
-                            tran.RollbackTran();
-                            info = $"鎻掑叆瀹瑰櫒璐у搧淇℃伅琛ㄥけ璐ワ細鐗╂枡缂栫爜{cgDetail.S_ITEM_CODE}锛屽鍣ㄧ紪鐮亄cgDetail.S_CNTR_CODE}";
-                            LogHelper.Info(info);
-                            continue;
-                        }
+                        //if (db.Insertable<TN_CG_Detail>(cgDetail).ExecuteCommand() <= 0) {
+                        //    tran.RollbackTran();
+                        //    info = $"鎻掑叆瀹瑰櫒璐у搧淇℃伅琛ㄥけ璐ワ細鐗╂枡缂栫爜{cgDetail.S_ITEM_CODE}锛屽鍣ㄧ紪鐮亄cgDetail.S_CNTR_CODE}";
+                        //    LogHelper.Info(info);
+                        //    continue;
+                        //}
 
                         if (db.Insertable<TN_Loc_Container>(locCntrRel).ExecuteCommand() <= 0) {
                             tran.RollbackTran();

--
Gitblit v1.9.1