From b183905d45e279eca8a845f532fc2d2edd540edb Mon Sep 17 00:00:00 2001
From: kazelee <1847801760@qq.com>
Date: 星期四, 10 七月 2025 17:27:42 +0800
Subject: [PATCH] 重构盘点单表结构,修复部分盘点逻辑

---
 HH.WCS.Mobox3.AnGang.csproj  |    7 
 models/TN_Count_Diff.cs      |   21 +
 models/TN_AG_Count_Order.cs  |   25 ++
 models/TN_Count_CG_Detail.cs |   22 +
 core/Monitor.cs              |  132 +++++++++++
 util/Settings.cs             |    4 
 models/TN_Count_Plan.cs      |   41 +++
 api/ApiHelper.cs             |  327 +++++++++++++++++++++++++++
 models/TN_Count_Order.cs     |   27 ++
 models/TN_AG_Count_Plan.cs   |   16 +
 api/ApiModel.cs              |    3 
 api/MoboxController.cs       |   66 +++++
 models/TN_AG_Count_Diff.cs   |   15 +
 13 files changed, 704 insertions(+), 2 deletions(-)

diff --git a/HH.WCS.Mobox3.AnGang.csproj b/HH.WCS.Mobox3.AnGang.csproj
index 3cf0433..0b624af 100644
--- a/HH.WCS.Mobox3.AnGang.csproj
+++ b/HH.WCS.Mobox3.AnGang.csproj
@@ -267,6 +267,13 @@
     <Compile Include="App_Start\SwaggerControllerDescProvider.cs" />
     <Compile Include="device\SnapDevice.cs" />
     <Compile Include="device\SnapManager.cs" />
+    <Compile Include="models\TN_AG_Count_Diff.cs" />
+    <Compile Include="models\TN_AG_Count_Order.cs" />
+    <Compile Include="models\TN_AG_Count_Plan.cs" />
+    <Compile Include="models\TN_Count_CG_Detail.cs" />
+    <Compile Include="models\TN_Count_Diff.cs" />
+    <Compile Include="models\TN_Count_Order.cs" />
+    <Compile Include="models\TN_Count_Plan.cs" />
     <Compile Include="models\TN_Inbound_DataRecord.cs" />
     <Compile Include="models\TN_Outbound_DataRecord.cs" />
     <Compile Include="core\WMSCore.cs" />
diff --git a/api/ApiHelper.cs b/api/ApiHelper.cs
index 285284f..10aca34 100644
--- a/api/ApiHelper.cs
+++ b/api/ApiHelper.cs
@@ -358,7 +358,7 @@
                                 $"鎻掑叆瀹瑰櫒璐у搧鏄庣粏琛ㄥけ璐ワ細瀹瑰櫒{cgDetail.S_CNTR_CODE}锛岀墿鏂檣cgDetail.S_ITEM_CODE}");
                         }
                     }
-
+                    
                     if (db.Updateable<TN_Location>(startLoc).UpdateColumns(it => new {
                         it.N_LOCK_STATE,
                         it.S_LOCK_STATE,
@@ -1097,5 +1097,330 @@
                 return BuildErpResult(1, $"鍙戠敓浜嗗紓甯革細{ex.Message}");
             }
         }
+
+        // 鐩樼偣鍔熻兘锛堟柊锛�+
+
+
+        // 澶囩敤锛氱洏鐐圭浉鍏冲姛鑳斤紙鎭㈠锛�-----------------------------
+
+        /// <summary>
+        /// 鐩樼偣鐞嗚揣鍑哄簱(WMS)
+        /// </summary>
+        /// <param name="model"></param>
+        /// <returns></returns>
+        internal static SimpleResult CheckOutbound(CheckOutboundInfo model) {
+            var taskName = TaskName.鐩樼偣鐞嗚揣鍑哄簱;
+            var db = new SqlHelper<object>().GetInstance();
+
+            try {
+                // 璧风偣浣嶇疆锛氬彇鏀捐揣鍖猴紙鏈夎揣鐗┿�娌℃湁閿併�宸插惎鐢級
+                var startLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.startLoc && a.N_CURRENT_NUM == 1 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y" && Settings.Areas[AreaIndex.H璐ф灦鍖篯.Contains(a.S_AREA_CODE));
+                if (startLoc == null) {
+                    return BuildSimpleResult(2, $"璧风偣浣嶇疆 {model.startLoc} 涓嶇鍚堝嚭搴撴潯浠�);
+                }
+
+                var locCntrRel = db.Queryable<TN_Loc_Container>().First(a => a.S_LOC_CODE == model.startLoc);
+                if (locCntrRel == null) {
+                    return BuildSimpleResult(3, $"璧风偣浣嶇疆 {model.startLoc} 娌℃湁缁戝畾瀹瑰櫒锛屾棤鍙洖搴撶殑鐗╂枡");
+                }
+
+                // 缁堢偣浣嶇疆锛氳揣鏋讹紙娌℃湁璐х墿锛屾病鏈夐攣锛�+                var endLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.endLoc && a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y");
+                if (endLoc == null) {
+                    return BuildSimpleResult(4, $"缁堢偣浣嶇疆 {model.endLoc} 涓嶅叿澶囨斁璐ф潯浠�);
+                }
+
+                var cntID = locCntrRel.S_CNTR_CODE;
+                var task = WCSHelper.BuildTask(startLoc, endLoc, cntID, taskName);
+                LocationHelper.LockLoc(ref startLoc, 2); // 璧风偣鍑哄簱閿�+                LocationHelper.LockLoc(ref endLoc, 1); // 缁堢偣鍏ュ簱閿�+
+                using (var tran = db.Ado.UseTran()) {
+                    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) {
+                        tran.RollbackTran();
+                        return BuildSimpleResult(500,
+                            $"鐢熸垚 {taskName} 澶辫触锛屽鍣ㄥ彿 {cntID} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣浣�{endLoc.S_CODE}");
+                    }
+
+                    if (db.Updateable<TN_Location>(endLoc).UpdateColumns(it => new {
+                        it.N_LOCK_STATE,
+                        it.S_LOCK_STATE,
+                        it.S_LOCK_OP,
+                        it.T_MODIFY
+                    }).ExecuteCommand() <= 0) {
+                        tran.RollbackTran();
+                        return BuildSimpleResult(500,
+                            $"鐢熸垚 {taskName} 澶辫触锛屽鍣ㄥ彿 {cntID} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣鏋�{endLoc.S_CODE}");
+                    }
+
+                    if (db.Insertable<TN_Task>(task).ExecuteCommand() <= 0) {
+                        tran.RollbackTran();
+                        return BuildSimpleResult(500,
+                            $"鐢熸垚 {taskName} 澶辫触锛屽鍣ㄥ彿 {cntID} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣鏋�{endLoc.S_CODE}");
+                    }
+
+                    tran.CommitTran();
+                    return BuildSimpleResult(0,
+                        $"鐢熸垚 {taskName} 鎴愬姛锛屽鍣ㄥ彿 {cntID} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣鏋�{endLoc.S_CODE}");
+                }
+            }
+            catch (Exception ex) {
+                return BuildSimpleResult(1, $"鍙戠敓浜嗗紓甯革細{ex.Message}");
+            }
+        }
+
+        /// <summary>
+        /// 鐩樼偣鐞嗚揣鍥炲簱(WMS)
+        /// </summary>
+        /// <param name="model"></param>
+        /// <returns></returns>
+        internal static SimpleResult CheckInbound(CheckInboundInfo model) {
+            var taskName = TaskName.鐩樼偣鐞嗚揣鍥炲簱;
+            var db = new SqlHelper<object>().GetInstance();
+
+            try {
+                // 璧风偣浣嶇疆锛氬彇鏀捐揣鍖猴紙鏈夎揣鐗┿�娌℃湁閿併�宸插惎鐢級
+                var startLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.startLoc && a.N_CURRENT_NUM == 1 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y" && Settings.Areas[AreaIndex.X鍗歌揣鍖篯.Contains(a.S_AREA_CODE));
+                if (startLoc == null) {
+                    return BuildSimpleResult(2, $"璧风偣浣嶇疆 {model.startLoc} 涓嶇鍚堝洖搴撴潯浠�);
+                }
+
+                var locCntrRel = db.Queryable<TN_Loc_Container>().First(a => a.S_LOC_CODE == model.startLoc);
+                if (locCntrRel == null) {
+                    return BuildSimpleResult(3, $"璧风偣浣嶇疆 {model.startLoc} 娌℃湁缁戝畾瀹瑰櫒锛屾棤鍙洖搴撶殑鐗╂枡");
+                }
+
+                // 缁堢偣浣嶇疆锛氳揣鏋讹紙娌℃湁璐х墿锛屾病鏈夐攣锛�+                var endLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.endLoc && a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y" && Settings.Areas[AreaIndex.H璐ф灦鍖篯.Contains(a.S_AREA_CODE));
+                if (endLoc == null) {
+                    return BuildSimpleResult(4, $"缁堢偣浣嶇疆 {model.endLoc} 涓嶅叿澶囨斁璐ф潯浠�);
+                }
+
+                var cntID = locCntrRel.S_CNTR_CODE;
+                var task = WCSHelper.BuildTask(startLoc, endLoc, cntID, taskName);
+                LocationHelper.LockLoc(ref startLoc, 2); // 璧风偣鍑哄簱閿�+                LocationHelper.LockLoc(ref endLoc, 1); // 缁堢偣鍏ュ簱閿�+
+                using (var tran = db.Ado.UseTran()) {
+                    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) {
+                        tran.RollbackTran();
+                        return BuildSimpleResult(500,
+                            $"鐢熸垚 {taskName} 澶辫触锛屽鍣ㄥ彿 {cntID} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣浣�{endLoc.S_CODE}");
+                    }
+
+                    if (db.Updateable<TN_Location>(endLoc).UpdateColumns(it => new {
+                        it.N_LOCK_STATE,
+                        it.S_LOCK_STATE,
+                        it.S_LOCK_OP,
+                        it.T_MODIFY
+                    }).ExecuteCommand() <= 0) {
+                        tran.RollbackTran();
+                        return BuildSimpleResult(500,
+                            $"鐢熸垚 {taskName} 澶辫触锛屽鍣ㄥ彿 {cntID} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣鏋�{endLoc.S_CODE}");
+                    }
+
+                    if (db.Insertable<TN_Task>(task).ExecuteCommand() <= 0) {
+                        tran.RollbackTran();
+                        return BuildSimpleResult(500,
+                            $"鐢熸垚 {taskName} 澶辫触锛屽鍣ㄥ彿 {cntID} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣鏋�{endLoc.S_CODE}");
+                    }
+
+                    tran.CommitTran();
+                    return BuildSimpleResult(0,
+                        $"鐢熸垚 {taskName} 鎴愬姛锛屽鍣ㄥ彿 {cntID} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣鏋�{endLoc.S_CODE}");
+                }
+            }
+            catch (Exception ex) {
+                return BuildSimpleResult(1, $"鍙戠敓浜嗗紓甯革細{ex.Message}");
+            }
+        }
+
+        //public static SimpleResult CreateCountPlan(CreateCountPlanInfo model) {
+        //    var db = new SqlHelper<object>().GetInstance();
+        //    try {
+
+        //        var countPlan = new TN_Count_Plan() {
+        //            S_CP_NO = GenerateNo("鐩樼偣璁″垝", "PDJH"), // CP =銆婸DJH
+        //            S_TYPE = model.countType,
+        //        };
+
+        //        if (model.countType == "璐т綅") {
+        //            countPlan.S_LOC_CODE = model.targetId;
+        //        }
+        //        else if (model.countType == "鐗╂枡") {
+        //            countPlan.S_ITEM_CODE = model.targetId;
+        //        }
+        //        else {
+        //            return BuildSimpleResult(2, $"鍒涘缓鐩樼偣璁″垝澶辫触锛氫笉鍚堟硶鐨勭洏鐐圭被鍨�'{model.countType}'");
+        //        }
+
+        //        if (db.Insertable<TN_Count_Plan>(countPlan).ExecuteCommand() <= 0) {
+        //            return BuildSimpleResult(2, "鍒涘缓鐩樼偣璁″垝澶辫触");
+        //        }
+
+        //        return BuildSimpleResult(0, "鍒涘缓鐩樼偣璁″垝鎴愬姛");
+
+        //    }
+        //    catch (Exception ex) {
+
+        //        return BuildSimpleResult(1, ex.Message);
+        //    }
+        //}
+
+        //public static SimpleResult CreateCountOrder(CreateCountOrderInfo model) {
+        //    var db = new SqlHelper<object>().GetInstance();
+        //    var info = "";
+        //    try {
+        //        var countPlan = db.Queryable<TN_Count_Plan>()
+        //            .Where(a => a.S_CP_NO == model.planId).First();
+
+        //        if (countPlan == null) {
+        //            return BuildSimpleResult(2, $"鐩樼偣璁″垝鍗曞彿 '{model.planId}' 涓嶅瓨鍦�);
+        //        }
+
+        //        var countOrder = new TN_Count_Order() {
+        //            S_CP_NO = model.planId,
+        //            S_COUNT_NO = GenerateNo("鐩樼偣鍗�, "PDD"), // CN =銆婸DD
+        //        };
+
+        //        var countDetailList = new List<TN_Count_CG_Detail>();
+        //        if (countPlan.S_TYPE == "璐т綅") {
+        //            var cgDetail = db.Queryable<TN_Location, TN_Loc_Container, TN_CG_Detail>
+        //                ((l, c, d) => l.S_CODE == c.S_LOC_CODE && c.S_CNTR_CODE == d.S_CNTR_CODE)
+        //                .Where(l => l.S_CODE == countPlan.S_LOC_CODE)
+        //                .Select((l, c, d) => d).First();
+
+        //            if (cgDetail == null) {
+        //                return BuildSimpleResult(3, $"鏈壘鍒版寚瀹氳揣浣峽countPlan.S_LOC_CODE}涓婄殑鐗╂枡");
+        //            }
+
+        //            var countDetail = new TN_Count_CG_Detail {
+        //                S_COUNT_NO = countOrder.S_COUNT_NO,
+        //                S_CNTR_CODE = cgDetail.S_CNTR_CODE,
+        //                S_ITEM_CODE = cgDetail.S_ITEM_CODE,
+        //            };
+
+        //            countDetailList.Add(countDetail);
+        //        }
+        //        else if (countPlan.S_TYPE == "鐗╂枡") {
+        //            var cgDetail = db.Queryable<TN_CG_Detail>()
+        //                .Where(d => d.S_ITEM_CODE == countPlan.S_ITEM_CODE).First(); // ToList -> First
+
+        //            if (cgDetail == null) {
+        //                return BuildSimpleResult(3, $"鏈壘鍒版寚瀹氱殑鐗╂枡{countPlan.S_ITEM_CODE}");
+        //            }
+
+        //            //foreach (var cgDetail in cgDetailList) {
+        //            //    var countDetail = new TN_Count_CG_Detail {
+        //            //        S_COUNT_NO = countOrder.S_COUNT_NO,
+        //            //        S_CNTR_CODE = cgDetail.S_CNTR_CODE,
+        //            //        S_ITEM_CODE = cgDetail.S_ITEM_CODE,
+        //            //    };
+
+        //            //    countDetailList.Add(countDetail);
+        //            //}
+
+        //            var countDetail = new TN_Count_CG_Detail {
+        //                S_COUNT_NO = countOrder.S_COUNT_NO,
+        //                S_CNTR_CODE = cgDetail.S_CNTR_CODE,
+        //                S_ITEM_CODE = cgDetail.S_ITEM_CODE,
+        //            };
+
+        //            countDetailList.Add(countDetail);
+        //        }
+        //        else {
+        //            return BuildSimpleResult(3, $"璁″垝鍗�{model.planId}'鐨勭被鍨媨countPlan.S_TYPE}涓嶅悎娉�);
+        //        }
+
+        //        using (var tran = db.Ado.UseTran()) {
+        //            if (db.Insertable<TN_Count_Order>(countOrder).ExecuteCommand() <= 0) {
+        //                tran.RollbackTran();
+        //                info = "鍒涘缓鐩樼偣鍗曞け璐�;
+        //                return BuildSimpleResult(2, info);
+        //            }
+
+        //            if (db.Insertable<TN_Count_CG_Detail>(countDetailList).ExecuteCommand() <= 0) {
+        //                tran.RollbackTran();
+        //                info = "鍒涘缓鐩樼偣鍗曟槑缁嗗け璐�;
+        //                return BuildSimpleResult(3, info);
+        //            }
+
+        //            tran.CommitTran();
+        //        }
+
+        //        return BuildSimpleResult(0, "鍒涘缓鐩樼偣鍗曟垚鍔�);
+        //    }
+        //    catch (Exception ex) {
+
+        //        return BuildSimpleResult(1, $"鍙戠敓浜嗗紓甯革細{ex.Message}");
+        //    }
+        //}
+
+        public static SimpleResult CountProduct(CountProductInfo model) {
+            var db = new SqlHelper<object>().GetInstance();
+            try {
+                //var cgDetail = db.Queryable<TN_CG_Detail>()
+                //    .Where(d => d.S_CNTR_CODE == model.cntrCode).First();
+
+                //if (cgDetail == null) {
+                //    return BuildSimpleResult(2, $"鎵句笉鍒板鍣ㄥ彿'{model.cntrCode}'瀵瑰簲鐨勭墿鏂�);
+                //}
+
+                var locCntrRel = db.Queryable<TN_Loc_Container>()
+                    //.LeftJoin<TN_CG_Detail>((c, d) => c.S_CNTR_CODE == d.S_CNTR_CODE)
+                    .Where(c => c.S_LOC_CODE == model.locCode).First();
+                if (locCntrRel == null) {
+                    return BuildSimpleResult(2, $"褰撳墠璐т綅{model.locCode}娌℃湁瀹瑰櫒锛�);
+                }
+
+                var cgDetail = db.Queryable<TN_CG_Detail>()
+                    .Where(d => d.S_CNTR_CODE == locCntrRel.S_CNTR_CODE).First();
+                if (cgDetail == null) {
+                    return BuildSimpleResult(3, $"褰撳墠璐т綅{model.locCode}涓婄殑瀹瑰櫒{locCntrRel.S_CNTR_CODE}娌℃湁鐗╁搧锛�);
+                }
+
+                //var countDiff = new TN_Count_Diff {
+                //    S_CNTR_CODE = cgDetail.S_CNTR_CODE,
+                //    F_QTY = cgDetail.F_QTY,
+                //    F_ACTUAL_QTY = model.qty
+                //};
+
+                var countDiff = db.Queryable<TN_AG_Count_Diff>().Where(d => d.S_CNTR_CODE == locCntrRel.S_CNTR_CODE).First();
+                if (countDiff == null) {
+                    return BuildSimpleResult(4, $"褰撳墠鐗╂枡鎵�湪瀹瑰櫒{locCntrRel.S_CNTR_CODE}鐗╂枡淇℃伅娌℃湁鐢熸垚瀵瑰簲鐨勭洏鐐瑰樊寮傝〃锛�);
+                }
+
+                countDiff.F_QTY = cgDetail.F_QTY;
+                countDiff.F_ACTUAL_QTY = model.qty;
+                //countDiff.S_ITEM_CODE = cgDetail.S_ITEM_CODE;
+
+                //if (db.Insertable<TN_Count_Diff>(countDiff).ExecuteCommand() <= 0) {
+                //    return BuildSimpleResult(3, $"鎻掑叆鐩樼偣宸紓琛ㄥけ璐�);
+                //}
+
+                if (db.Updateable<TN_AG_Count_Diff>(countDiff).ExecuteCommand() <= 0) {
+                    return BuildSimpleResult(5, $"鎻掑叆鐩樼偣宸紓琛ㄥけ璐�);
+                }
+
+                return BuildSimpleResult(0, "鐩樼偣宸紓瀹屾垚");
+
+            }
+            catch (Exception ex) {
+                return BuildSimpleResult(1, $"鍙戠敓浜嗗紓甯革細{ex.Message}");
+            }
+        }
+
+
     }
 }
diff --git a/api/ApiModel.cs b/api/ApiModel.cs
index b4d438b..c6eb912 100644
--- a/api/ApiModel.cs
+++ b/api/ApiModel.cs
@@ -228,7 +228,8 @@
         }
 
         public class CountProductInfo {
-            public string cntrCode { get; set; }
+            //public string cntrCode { get; set; }
+            public string locCode { get; set; }
             public float qty { get; set; }
         }
 
diff --git a/api/MoboxController.cs b/api/MoboxController.cs
index 51d084f..0ab6099 100644
--- a/api/MoboxController.cs
+++ b/api/MoboxController.cs
@@ -84,5 +84,71 @@
             LogHelper.Info("瑙﹀彂API锛氬彇娑堜换鍔� + JsonConvert.SerializeObject(model), "API");
             return ApiHelper.CancelTask(model);
         }
+
+        // 鐩樼偣鍔熻兘锛堟柊锛�+
+
+
+        // 澶囩敤锛氱洏鐐圭浉鍏冲姛鑳斤紙鎭㈠锛�-----------------------------------
+
+        ///// <summary>
+        ///// 鍒涘缓鐩樼偣璁″垝鍗�WMS)
+        ///// </summary>
+        ///// <param name="model"></param>
+        ///// <returns></returns>
+        //[HttpPost]
+        //[Route("CreateCountPlan")]
+        //public SimpleResult CreateCountPlan(CreateCountPlanInfo model) {
+        //    LogHelper.Info("瑙﹀彂API锛氬垱寤虹洏鐐硅鍒掑崟(WMS)" + JsonConvert.SerializeObject(model), "API");
+        //    return ApiHelper.CreateCountPlan(model);
+        //}
+
+        ///// <summary>
+        ///// 鍒涘缓鐩樼偣鍗�PDA)
+        ///// </summary>
+        ///// <param name="model"></param>
+        ///// <returns></returns>
+        //[HttpPost]
+        //[Route("CreateCountOrder")]
+        //public SimpleResult CreateCountOrder(CreateCountOrderInfo model) {
+        //    LogHelper.Info("瑙﹀彂API锛氬垱寤虹洏鐐瑰崟(PDA)" + JsonConvert.SerializeObject(model), "API");
+        //    return ApiHelper.CreateCountOrder(model);
+        //}
+
+        /// <summary>
+        /// 鐩樼偣鐞嗚揣(PDA)
+        /// </summary>
+        /// <param name="model"></param>
+        /// <returns></returns>
+        [HttpPost]
+        [Route("CountProduct")]
+        public SimpleResult CountProduct(CountProductInfo model) {
+            LogHelper.Info("瑙﹀彂API锛氱洏鐐圭悊璐�PDA)" + JsonConvert.SerializeObject(model), "API");
+            return ApiHelper.CountProduct(model);
+        }
+
+        /// <summary>
+        /// 鐩樼偣鐞嗚揣鍑哄簱(WMS)
+        /// </summary>
+        /// <param name="model"></param>
+        /// <returns></returns>
+        [HttpPost]
+        [Route("CheckOutbound")]
+        public SimpleResult CheckOutbound(CheckOutboundInfo model) {
+            LogHelper.Info("瑙﹀彂API锛氱洏鐐圭悊璐у嚭搴�WMS)" + JsonConvert.SerializeObject(model), "API");
+            return ApiHelper.CheckOutbound(model);
+        }
+
+        /// <summary>
+        /// 鐩樼偣鐞嗚揣鍥炲簱(WMS)
+        /// </summary>
+        /// <param name="model"></param>
+        /// <returns></returns>
+        [HttpPost]
+        [Route("CheckInbound")]
+        public SimpleResult CheckInbound(CheckInboundInfo model) {
+            LogHelper.Info("瑙﹀彂API锛氱洏鐐圭悊璐у洖搴�WMS)" + JsonConvert.SerializeObject(model), "API");
+            return ApiHelper.CheckInbound(model);
+        }
     }
 }
diff --git a/core/Monitor.cs b/core/Monitor.cs
index 3f81d23..ec11518 100644
--- a/core/Monitor.cs
+++ b/core/Monitor.cs
@@ -146,6 +146,138 @@
                 LogHelper.Info($"鍙戠敓浜嗗紓甯革細{ex.Message}");
             }
         }
+
+        // 鐩樼偣鍔熻兘锛堟柊锛�----------------------------------------
+
+
+
+        // 澶囩敤锛氱洏鐐圭浉鍏冲姛鑳斤紙鎭㈠锛�-----------------------------------
+
+        //public static void CheckCountOrder() {
+        //    var taskName = TaskName.鐩樼偣鐞嗚揣鍑哄簱;
+        //    var db = new SqlHelper<object>().GetInstance();
+        //    var info = "";
+
+        //    try {
+        //        var orderList = db.Queryable<TN_Count_Order>()
+        //            .Where(c => c.N_B_STATE == 1)
+        //            .OrderBy(c => c.T_CREATE, SqlSugar.OrderByType.Asc)
+        //            .ToList();
+
+        //        if (orderList.Count == 0) {
+        //            LogHelper.Info($"杞--{taskName}--鏆傛棤寰呮墽琛岀殑{taskName}鍗�);
+        //            return;
+        //        }
+
+        //        var detailList = new List<TN_Count_CG_Detail>();
+        //        foreach (var order in orderList) {
+        //            var doingCount = db.Queryable<TN_Count_CG_Detail>()
+        //                .Count(d => d.S_COUNT_NO == order.S_COUNT_NO && d.N_B_STATE >= 2); // 鎵ц涓�+        //            var allCount = db.Queryable<TN_Count_CG_Detail>()
+        //                .Count(d => d.S_COUNT_NO == order.S_COUNT_NO);
+        //            LogHelper.Info($"杞--{taskName}--缁熻{taskName}鍗�{order.S_COUNT_NO}'浠诲姟宸蹭笅鍙戯細{doingCount}/{allCount}");
+
+        //            if (doingCount == allCount) {
+        //                order.N_B_STATE = 2; // 鎵�湁浠诲姟閮藉凡鎵ц
+        //                db.Updateable<TN_Count_Order>(order).UpdateColumns(it => new { it.N_B_STATE }).ExecuteCommand();
+        //                continue;
+        //            }
+
+        //            var countCgDetailList = db.Queryable<TN_Count_CG_Detail>()
+        //                .Where(a => a.S_COUNT_NO == order.S_COUNT_NO && a.N_B_STATE == 1) // 宸蹭笅鍙�+        //                .ToList();
+
+        //            if (countCgDetailList.Count == 0) {
+        //                LogHelper.Info($"杞--{taskName}--{taskName}鍗曟槑缁嗙姸鎬佸紓甯�);
+        //                continue;
+        //            }
+
+        //            detailList.AddRange(countCgDetailList);
+        //        }
+
+        //        if (detailList.Count == 0) {
+        //            return;
+        //        }
+
+        //        foreach (var detail in detailList) {
+        //            var startLoc = db.Queryable<TN_Location>()
+        //                .LeftJoin<TN_Loc_Container>((l, c) => l.S_CODE == c.S_LOC_CODE)
+        //                .Where((l, c) => c.S_CNTR_CODE == detail.S_CNTR_CODE)
+        //                .First();
+
+        //            if (startLoc == null) {
+        //                LogHelper.Info($"杞--{taskName}锛氭病鏈夋壘鍒板悎閫傜殑璧风偣璐т綅锛�);
+        //                continue;
+        //            }
+
+        //            var endLoc = db.Queryable<TN_Location>()
+        //                .Where(a => Settings.Areas[0].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).First();
+
+        //            if (endLoc == null) {
+        //                LogHelper.Info($"杞--{taskName}锛氭病鏈夋壘鍒板悎閫傜殑缁堢偣璐т綅锛佸崟鍙蜂负 '{detail.S_COUNT_NO}'");
+        //                continue;
+        //            }
+
+        //            detail.N_B_STATE = 2;
+
+        //            var cntId = detail.S_CNTR_CODE;
+        //            var task = WCSHelper.BuildTask(startLoc, endLoc, cntId, taskName);
+
+        //            LocationHelper.LockLoc(ref startLoc, 2); // 璧风偣鍑哄簱閿�+        //            LocationHelper.LockLoc(ref endLoc, 1); // 缁堢偣鍏ュ簱閿�+
+        //            using (var tran = db.Ado.UseTran()) {
+        //                if (db.Updateable<TN_Count_CG_Detail>(detail).UpdateColumns(it => it.N_B_STATE).ExecuteCommand() <= 0) {
+        //                    tran.RollbackTran();
+        //                    LogHelper.Info($"杞--{taskName}--淇敼鏄庣粏琛ㄧ姸鎬佷负瀹屾垚澶辫触锛�);
+        //                }
+
+        //                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) {
+        //                    tran.RollbackTran();
+        //                    info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛屽鍣ㄥ彿{cntId}锛岃捣鐐箋startLoc.S_CODE}锛岀粓鐐硅揣浣峽endLoc.S_CODE}";
+        //                    LogHelper.Info(info);
+        //                    continue;
+        //                }
+
+        //                if (db.Updateable<TN_Location>(endLoc).UpdateColumns(it => new {
+        //                    it.N_LOCK_STATE,
+        //                    it.S_LOCK_STATE,
+        //                    it.S_LOCK_OP,
+        //                    it.T_MODIFY
+        //                }).ExecuteCommand() <= 0) {
+
+        //                    tran.RollbackTran();
+        //                    info = $"鐢熸垚'{taskName}'澶辫触锛屽鍣ㄥ彿 {cntId} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣浣�{endLoc.S_CODE}";
+        //                    LogHelper.Info(info);
+        //                    continue;
+        //                }
+
+        //                if (db.Insertable<TN_Task>(task).ExecuteCommand() <= 0) {
+        //                    tran.RollbackTran();
+        //                    info = $"鐢熸垚 {taskName} 澶辫触锛屽鍣ㄥ彿 {cntId} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣浣�{endLoc.S_CODE}";
+        //                    LogHelper.Info(info);
+        //                    continue;
+        //                }
+
+        //                tran.CommitTran();
+        //                info = $"鐢熸垚 {taskName} 鎴愬姛锛屽鍣ㄥ彿 {cntId} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣浣�{endLoc.S_CODE}";
+        //                LogHelper.Info(info);
+        //                //continue;
+        //            }
+        //        }
+        //    }
+        //    catch (Exception ex) {
+        //        info = $"鍙戠敓浜嗗紓甯革細{ex.Message}";
+        //        LogHelper.Info(info);
+        //    }
+        //}
     }
 
 }
diff --git a/models/TN_AG_Count_Diff.cs b/models/TN_AG_Count_Diff.cs
new file mode 100644
index 0000000..c964b45
--- /dev/null
+++ b/models/TN_AG_Count_Diff.cs
@@ -0,0 +1,15 @@
+锘縰sing System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace HH.WCS.Mobox3.AnGang.models {
+    public class TN_AG_Count_Diff {
+        public string S_COUNT_NO { get; set; }
+        public string S_CNTR_CODE { get; set; }
+        public float F_QTY { get; set; } = 0f;
+        public float F_ACTUAL_QTY { get; set; } = 0f;
+        public string S_ITEM_CODE { get; set; }
+    }
+}
diff --git a/models/TN_AG_Count_Order.cs b/models/TN_AG_Count_Order.cs
new file mode 100644
index 0000000..06b3ee4
--- /dev/null
+++ b/models/TN_AG_Count_Order.cs
@@ -0,0 +1,25 @@
+锘縰sing System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+using SqlSugar;
+
+namespace HH.WCS.Mobox3.AnGang.models {
+    [SugarTable("TN_AG_Count_Order")]
+    public class TN_AG_Count_Order {
+        public string S_COUNT_NO { get; set; }
+        public string S_CP_NO { get; set; }
+
+        //public string S_LOC_CODE { get; set; }
+        public string S_CNTR_CODE { get; set; }
+
+        public string S_ITEM_CODE { get; set; }
+
+        /// <summary>
+        /// 0 寰呯洏鐐癸紱1 鐩樼偣鎵ц涓紱2 鐩樼偣瀹屾垚寰呭洖搴擄紱3 鍥炲簱瀹屾垚锛堝彧鏈夊洖搴撳畬鎴愭椂鍙互鎵ц涓嬩竴涓换鍔★級
+        /// </summary>
+        public int N_B_STATE { get; set; }
+    }
+}
diff --git a/models/TN_AG_Count_Plan.cs b/models/TN_AG_Count_Plan.cs
new file mode 100644
index 0000000..4ac7a7e
--- /dev/null
+++ b/models/TN_AG_Count_Plan.cs
@@ -0,0 +1,16 @@
+锘縰sing System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+using SqlSugar;
+
+namespace HH.WCS.Mobox3.AnGang.models {
+    [SugarTable("TN_AG_Count_Plan")]
+    public class TN_AG_Count_Plan {
+        public string S_CP_NO { get; set; }
+
+        public int N_B_STATE { get; set; }
+    }
+}
diff --git a/models/TN_Count_CG_Detail.cs b/models/TN_Count_CG_Detail.cs
new file mode 100644
index 0000000..ce584a7
--- /dev/null
+++ b/models/TN_Count_CG_Detail.cs
@@ -0,0 +1,22 @@
+锘縰sing System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+using SqlSugar;
+
+namespace HH.WCS.Mobox3.AnGang.models {
+    /// <summary>
+    /// 銆愭棫銆戠洏鐐瑰崟鏄庣粏琛�+    /// </summary>
+    [SugarTable("TN_Count_CG_Detail")]
+    public class TN_Count_CG_Detail : BaseModel {
+        public string S_COUNT_NO { get; set; }
+        public string S_ITEM_CODE { get; set; }
+        public string S_CNTR_CODE { get; set; }
+
+        public int N_B_STATE { get; set; }
+
+    }
+}
diff --git a/models/TN_Count_Diff.cs b/models/TN_Count_Diff.cs
new file mode 100644
index 0000000..f2fb221
--- /dev/null
+++ b/models/TN_Count_Diff.cs
@@ -0,0 +1,21 @@
+锘縰sing System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+using SqlSugar;
+
+namespace HH.WCS.Mobox3.AnGang.models {
+    /// <summary>
+    /// 銆愭棫銆戠洏鐐瑰樊寮傝〃
+    /// </summary>
+    [SugarTable("TN_Count_Diff")]
+    public class TN_Count_Diff : BaseModel {
+        public string S_COUNT_NO { get; set; }
+        public string S_CNTR_CODE { get; set; }
+        public float F_QTY { get; set; }
+        public float F_ACTUAL_QTY { get; set; }
+        public string S_ITEM_CODE { get; set; }
+    }
+}
diff --git a/models/TN_Count_Order.cs b/models/TN_Count_Order.cs
new file mode 100644
index 0000000..6b7e5a0
--- /dev/null
+++ b/models/TN_Count_Order.cs
@@ -0,0 +1,27 @@
+锘縰sing System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+using SqlSugar;
+
+namespace HH.WCS.Mobox3.AnGang.models {
+    /// <summary>
+    /// 銆愭棫銆戠洏鐐瑰崟琛�+    /// </summary>
+    [SugarTable("TN_Count_Order")]
+    public class TN_Count_Order : BaseModel {
+        public string S_CP_NO { get; set; }
+
+        /// <summary>
+        /// 鐩樼偣鍗曞彿
+        /// </summary>
+        public string S_COUNT_NO { get; set; }
+
+        /// <summary>
+        /// 涓氬姟鐘舵�锛�绛夊緟鎵ц 1宸叉墽琛屽緟鐢熸垚浠诲姟 2浠诲姟鎵ц涓�3浠诲姟瀹屾垚
+        /// </summary>
+        public int N_B_STATE { get; set; }
+    }
+}
diff --git a/models/TN_Count_Plan.cs b/models/TN_Count_Plan.cs
new file mode 100644
index 0000000..910faa5
--- /dev/null
+++ b/models/TN_Count_Plan.cs
@@ -0,0 +1,41 @@
+锘縰sing System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+using SqlSugar;
+
+namespace HH.WCS.Mobox3.AnGang.models {
+    /// <summary>
+    /// 銆愭棫銆戠洏鐐硅鍒掕〃
+    /// </summary>
+    [SugarTable("TN_Count_Plan")]
+    public class TN_Count_Plan : BaseModel {
+        /// <summary>
+        /// 鐩樼偣璁″垝鍙�+        /// </summary>
+        public string S_CP_NO { get; set; }
+
+        /// <summary>
+        /// 鐩樼偣绫诲瀷锛氳揣鐗╃洏鐐�璐т綅鐩樼偣
+        /// </summary>
+        public string S_TYPE { get; set; }
+
+        /// <summary>
+        /// 鐩樼偣鐘舵�锛� 鈥�鏈墽琛�1 鈥�鍚姩涓�2 鈥�鎵ц涓�3 鈥�瀹屾垚 4 鈥�鍑洪敊
+        /// </summary>
+        public int N_B_STATE { get; set; } = 0;
+
+        ///// <summary>
+        ///// 璁″垝鐩樼偣鐗╂枡鏁伴噺
+        ///// </summary>
+        //public int N_PLAN_TOTAL { get; set; }
+
+        // ------
+
+        public string S_LOC_CODE { get; set; } = "";
+
+        public string S_ITEM_CODE { get; set; } = "";
+    }
+}
diff --git a/util/Settings.cs b/util/Settings.cs
index 796fe32..4585a8a 100644
--- a/util/Settings.cs
+++ b/util/Settings.cs
@@ -110,6 +110,10 @@
         public const string 浜у搧鍏ュ簱 = "浜у搧鍏ュ簱";
         public const string 浜у搧閮ㄥ垎鍑哄簱 = "浜у搧閮ㄥ垎鍑哄簱";
         public const string 浜у搧閮ㄥ垎鍥炲簱 = "浜у搧閮ㄥ垎鍥炲簱";
+
+        // 澶囩敤锛氱洏鐐圭悊璐у嚭搴擄紙鎭㈠锛�+        public const string 鐩樼偣鐞嗚揣鍑哄簱 = "鐩樼偣鐞嗚揣鍑哄簱";
+        public const string 鐩樼偣鐞嗚揣鍥炲簱 = "鐩樼偣鐞嗚揣鍥炲簱";
     }
 
     public class AreaIndex {

--
Gitblit v1.9.1