From c2d2f4eb78c54bdfdb6ffb0df5932751d538ed14 Mon Sep 17 00:00:00 2001
From: 杨张扬 <634643841@qq.com>
Date: 星期一, 14 七月 2025 17:35:02 +0800
Subject: [PATCH] 新增PDA搬送,线边空托到原材料上线口

---
 api/ApiHelper.cs |  310 +++++++++++++++++++++++++++++++++++++++++++--------
 1 files changed, 261 insertions(+), 49 deletions(-)

diff --git a/api/ApiHelper.cs b/api/ApiHelper.cs
index 20f8b26..b5da79d 100644
--- a/api/ApiHelper.cs
+++ b/api/ApiHelper.cs
@@ -123,10 +123,12 @@
         internal static SimpleResult PDAFullCheckIn(PDAFullCheckInfo model)
         {
             LogHelper.Info("瑙﹀彂API锛歅DA婊℃墭澶嶆鍒ゆ柇" + JsonConvert.SerializeObject(model), "API");
-            var db = new SqlHelper<object>().GetInstance();
+
             var result = new SimpleResult();//杩斿洖缁撴灉
             try
             {
+                var db = new SqlHelper<object>().GetInstance();
+
                 var locCnt = db.Queryable<TN_Loc_Container>().First(a => a.S_CNTR_CODE == model.rfId);
                 if (locCnt == null)
                 {
@@ -161,15 +163,21 @@
                     cG_Detail.N_ITEM_STATE = 0;
                     cG_Detail.S_ITEM_STATE = "鍚堟牸";
                     endLoc = db.Queryable<TN_Location>().
-                            Where(o => o.S_AREA_CODE == Settings.Areas[1] && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == "鏃� && o.C_ENABLE == "Y" && o.N_CURRENT_NUM == 0).
+                            Where(o => o.S_AREA_CODE == Settings.Areas[1] 
+                            && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == "鏃�
+                             && SqlFunc.Subqueryable<TN_Loc_Container>().Where(b => b.S_LOC_CODE == o.S_CODE).NotAny()
+                            && o.C_ENABLE == "Y" && o.N_CURRENT_NUM == 0).
                             OrderBy(o => o.T_MODIFY, OrderByType.Asc).First();//鏌ヨ鍚堥�鐨勭粓鐐硅揣浣�                 }
-                else if (model.cgState == 4)//鎶�湳鍚堟牸鍥炲簱
+                else if (model.cgState == 4)//鎶�湳鍒ゅ畾鍥炲簱
                 {
                     cG_Detail.N_ITEM_STATE = 4;
-                    cG_Detail.S_ITEM_STATE = "鎶�湳鍚堟牸";
+                    cG_Detail.S_ITEM_STATE = "鎶�湳鍒ゅ畾";
                     endLoc = db.Queryable<TN_Location>().
-                            Where(o => o.S_AREA_CODE == Settings.Areas[8] && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == "鏃� && o.C_ENABLE == "Y" && o.N_CURRENT_NUM == 0).
+                            Where(o => o.S_AREA_CODE == Settings.Areas[8] 
+                            && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == "鏃�
+                            && SqlFunc.Subqueryable<TN_Loc_Container>().Where(b => b.S_LOC_CODE == o.S_CODE).NotAny()
+                            && o.C_ENABLE == "Y" && o.N_CURRENT_NUM == 0).
                             OrderBy(o => o.T_MODIFY, OrderByType.Asc).First();//鏌ヨ鍚堥�鐨勭粓鐐硅揣浣�                 }
                 else if (model.cgState == 2)//涓嶅悎鏍煎洖鐐�@@ -177,7 +185,10 @@
                     cG_Detail.N_ITEM_STATE = 2;
                     cG_Detail.S_ITEM_STATE = "涓嶅悎鏍�;
                     endLoc = db.Queryable<TN_Location>().
-                            Where(o => o.S_AREA_CODE == Settings.Areas[8] && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == "鏃� && o.C_ENABLE == "Y" && o.N_CURRENT_NUM == 0).
+                            Where(o => o.S_AREA_CODE == Settings.Areas[8] 
+                            && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == "鏃�
+                            && SqlFunc.Subqueryable<TN_Loc_Container>().Where(b => b.S_LOC_CODE == o.S_CODE).NotAny()
+                            && o.C_ENABLE == "Y" && o.N_CURRENT_NUM == 0).
                             OrderBy(o => o.T_MODIFY, OrderByType.Asc).First();//鏌ヨ鍚堥�鐨勭粓鐐硅揣浣�                 }
                 else if (model.cgState == 5)//娣峰悎涔熷洖搴擄紝閫氳繃鐐瑰鐐瑰啀鍙戠嚎杈�@@ -185,7 +196,10 @@
                     cG_Detail.N_ITEM_STATE = 5;
                     cG_Detail.S_ITEM_STATE = "娣峰悎";
                     endLoc = db.Queryable<TN_Location>().
-                            Where(o => o.S_AREA_CODE == Settings.Areas[2] && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == "鏃� && o.C_ENABLE == "Y" && o.N_CURRENT_NUM == 0).
+                            Where(o => o.S_AREA_CODE == Settings.Areas[2] 
+                            && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == "鏃�
+                            && SqlFunc.Subqueryable<TN_Loc_Container>().Where(b => b.S_LOC_CODE == o.S_CODE).NotAny()
+                            && o.C_ENABLE == "Y" && o.N_CURRENT_NUM == 0).
                             OrderBy(o => o.T_MODIFY, OrderByType.Asc).First();//鏌ヨ鍚堥�鐨勭粓鐐硅揣浣�                 }
                 else if (model.cgState == 6)//涓�骇鏂欎簩绾ф枡鍥炲簱
@@ -193,7 +207,10 @@
                     cG_Detail.N_ITEM_STATE = 6;
                     cG_Detail.S_ITEM_STATE = "涓�骇鏂�;
                     endLoc = db.Queryable<TN_Location>().
-                            Where(o => o.S_AREA_CODE == Settings.Areas[2] && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == "鏃� && o.C_ENABLE == "Y" && o.N_CURRENT_NUM == 0).
+                            Where(o => o.S_AREA_CODE == Settings.Areas[2] 
+                            && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == "鏃�
+                            && SqlFunc.Subqueryable<TN_Loc_Container>().Where(b => b.S_LOC_CODE == o.S_CODE).NotAny()
+                            && o.C_ENABLE == "Y" && o.N_CURRENT_NUM == 0).
                             OrderBy(o => o.T_MODIFY, OrderByType.Asc).First();//鏌ヨ鍚堥�鐨勭粓鐐硅揣浣�                 }
                 else if (model.cgState == 7)//涓�骇鏂欎簩绾ф枡鍥炲簱
@@ -201,13 +218,16 @@
                     cG_Detail.N_ITEM_STATE = 7;
                     cG_Detail.S_ITEM_STATE = "浜岀骇鏂�;
                     endLoc = db.Queryable<TN_Location>().
-                            Where(o => o.S_AREA_CODE == Settings.Areas[2] && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == "鏃� && o.C_ENABLE == "Y" && o.N_CURRENT_NUM == 0).
+                            Where(o => o.S_AREA_CODE == Settings.Areas[2] 
+                            && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == "鏃�
+                            && SqlFunc.Subqueryable<TN_Loc_Container>().Where(b => b.S_LOC_CODE == o.S_CODE).NotAny()
+                            && o.C_ENABLE == "Y" && o.N_CURRENT_NUM == 0).
                             OrderBy(o => o.T_MODIFY, OrderByType.Asc).First();//鏌ヨ鍚堥�鐨勭粓鐐硅揣浣�                 }
                 else
                 {
                     result.resultCode = 6;
-                    result.resultMsg = $"鐗╂枡鐘舵�鍙兘涓�鍚堟牸1寰呮2涓嶅悎鏍硷紝涓嬬嚎鍗冲緟妫�紝3杩囨湡锛�鎶�湳鍚堟牸锛�娣峰悎锛�涓�骇鏂欍�7浜岀骇鏂欙紝濡傛灉涓哄叾浠栧�锛屽垯涓嶅鐞�;
+                    result.resultMsg = $"鐗╂枡鐘舵�鍙兘涓�鍚堟牸1寰呮2涓嶅悎鏍硷紝涓嬬嚎鍗冲緟妫�紝3杩囨湡锛�鎶�湳鍒ゅ畾锛�娣峰悎锛�涓�骇鏂欍�7浜岀骇鏂欙紝濡傛灉涓哄叾浠栧�锛屽垯涓嶅鐞�;
                     LogHelper.Info(result.resultMsg);
                     return result;
                 }
@@ -223,14 +243,20 @@
 
                 var typeName = (model.cgState == 0) ? "浜哄伐澶嶆鍥炲簱" : "浜哄伐澶嶆鍥炵倝";
 
-                //鍒涘缓浜哄伐鎷嗙洏鍑哄簱浠诲姟
+                //鍒涘缓浜哄伐澶嶆浠诲姟
                 if (WCSHelper.CreateTask(startLoc.S_CODE, endLoc.S_CODE, typeName, 3, locCnt.S_CNTR_CODE,out string taskNo,cG_Detail.S_SPE))//鍒涘缓鎼�浠诲姟锛岃捣鐐圭粓鐐瑰鍣�                 {
                     LocationHelper.LockLoc(startLoc.S_CODE, 2);//璧风偣鍑哄簱閿侊紝
                     LocationHelper.LockLoc(endLoc.S_CODE, 1);//缁堢偣鍏ュ簱閿�                     LogHelper.Info($"鐢熸垚{typeName}浠诲姟鎴愬姛锛屽鍣ㄥ彿{locCnt.S_CNTR_CODE}锛岃捣鐐箋startLoc.S_CODE}锛岀粓鐐箋endLoc.S_CODE}");
 
-                    db.Updateable<TN_CG_Detail>().UpdateColumns(it => new { it.S_ITEM_STATE, it.N_ITEM_STATE }).ExecuteCommand();
+                    if( db.Updateable<TN_CG_Detail>(cG_Detail).UpdateColumns(it => new { it.S_ITEM_STATE, it.N_ITEM_STATE }).ExecuteCommand() <= 0)
+                    {
+                        result.resultCode = 5;
+                        result.resultMsg = $"鏇存柊瀹瑰櫒{locCnt.S_CNTR_CODE}鐨勮揣鍝佹槑缁嗗け璐�;
+                        LogHelper.Info(result.resultMsg);
+                        return result;
+                    }
 
                     Task task99 = Task.Run(() =>
                     {
@@ -299,6 +325,179 @@
         }
 
         /// <summary>
+        /// 绾胯竟绌烘墭鍒板師鏉愭枡杈撻�绾�+        /// </summary>
+        /// <param name="model"></param>
+        /// <returns></returns>
+        internal static SimpleResult EmptyLineToLine(EmptyLineToLineInfo model)
+        {
+            LogHelper.Info("瑙﹀彂API锛氱嚎杈圭┖鎵樺埌鍘熸潗鏂欒緭閫佺嚎" + JsonConvert.SerializeObject(model), "API");
+            var result = new SimpleResult();//杩斿洖缁撴灉
+            try
+            {
+                var db = new SqlHelper<object>().GetInstance();
+
+                var startLoc = db.Queryable<TN_Location>().First(o => o.S_CODE == model.startLoc);
+                if (startLoc == null)
+                {
+                    result.resultCode = 1;
+                    result.resultMsg = $"鏁版嵁搴撲腑鏈壘鍒版璐т綅锛歿model.startLoc}";
+                    LogHelper.Info(result.resultMsg);
+                    return result;
+                }
+                if (startLoc.N_CURRENT_NUM == 1 || db.Queryable<TN_Loc_Container>().Any(a=>a.S_LOC_CODE==model.startLoc))
+                {
+                    result.resultCode = 2;
+                    result.resultMsg = $"姝よ揣浣嶏細{model.startLoc}锛屽凡缁戝畾鎵樼洏";
+                    LogHelper.Info(result.resultMsg);
+                    return result;
+                }
+                if (startLoc.N_LOCK_STATE != 0  || startLoc.S_LOCK_STATE != "鏃�)
+                {
+                    result.resultCode = 3;
+                    result.resultMsg = $"姝よ揣浣嶏細{model.startLoc}锛屽凡涓婇攣";
+                    LogHelper.Info(result.resultMsg);
+                    return result;
+                }
+                if (startLoc.C_ENABLE != "Y")
+                {
+                    result.resultCode = 4;
+                    result.resultMsg = $"姝よ揣浣嶏細{model.startLoc}锛屾湭鍚敤";
+                    LogHelper.Info(result.resultMsg);
+                    return result;
+                }
+                var startLocArea = Settings.Areas[13];
+                if (startLoc.S_AREA_CODE != startLocArea)
+                {
+                    result.resultCode = 5;
+                    result.resultMsg = $"姝よ揣浣嶏細{model.startLoc}锛屼笉灞炰簬绾胯竟绌烘墭鍖簕startLocArea}";
+                    LogHelper.Info(result.resultMsg);
+                    return result;
+                }
+
+
+                var endLocIndex = Settings.LineSorting;
+                var endLocLine = Settings.ProductionLines.FirstOrDefault(a => a.Sorting == endLocIndex);
+                if (endLocLine == null)
+                {
+                    result.resultCode = 6;
+                    result.resultMsg = $"閰嶇疆鏂囦欢涓湭鎵惧埌搴忓彿涓猴細{endLocIndex}鐨勫師鏉愭枡浜х嚎鐨勪俊鎭�;
+                    LogHelper.Info(result.resultMsg);
+                    return result;
+                }
+                var endLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == endLocLine.PointIn);
+                if (endLoc == null)
+                {
+                    result.resultCode = 7;
+                    result.resultMsg = $"鏁版嵁搴撲腑鏈壘鍒板師鏉愭枡浜х嚎绌烘墭涓婄嚎鍙o細{endLocLine.PointIn}";
+                    LogHelper.Info(result.resultMsg);
+                    return result;
+                }
+                var endLocArea = Settings.Areas[14];
+                if (endLoc.S_AREA_CODE != endLocArea)
+                {
+                    result.resultCode = 8;
+                    result.resultMsg = $"姝よ揣浣嶏細{endLoc.S_CODE}锛屼笉灞炰簬鍘熸潗鏂欎骇绾跨┖鎵樺尯{endLocArea}";
+                    LogHelper.Info(result.resultMsg);
+                    return result;
+                }
+                if (endLoc.N_CURRENT_NUM == 1 || db.Queryable<TN_Loc_Container>().Any(a => a.S_LOC_CODE == endLocLine.PointIn))
+                {
+                    result.resultCode = 9;
+                    result.resultMsg = $"姝よ揣浣嶏細{model.startLoc}锛屽凡缁戝畾鎵樼洏";
+                    LogHelper.Info(result.resultMsg);
+                    return result;
+                }
+                if (endLoc.N_LOCK_STATE != 0 || endLoc.S_LOCK_STATE != "鏃�)
+                {
+                    result.resultCode = 10;
+                    result.resultMsg = $"姝よ揣浣嶏細{model.startLoc}锛屽凡涓婇攣";
+                    LogHelper.Info(result.resultMsg);
+                    return result;
+                }
+                if (endLoc.C_ENABLE != "Y")
+                {
+                    result.resultCode = 11;
+                    result.resultMsg = $"姝よ揣浣嶏細{model.startLoc}锛屾湭鍚敤";
+                    LogHelper.Info(result.resultMsg);
+                    return result;
+                }
+                var Cnt = Guid.NewGuid().ToString("D");
+
+
+                using (var trans = db.Ado.UseTran())
+                {
+                    startLoc.N_CURRENT_NUM = 1;
+                    startLoc.N_LOCK_STATE = 2;
+                    startLoc.S_LOCK_STATE = "鍑哄簱閿�;
+
+                    endLoc.N_LOCK_STATE = 1;
+                    endLoc.S_LOCK_STATE = "鍏ュ簱閿�;
+
+                    var locCnt = new TN_Loc_Container()
+                    {
+                        S_LOC_CODE = startLoc.S_CODE,
+                        S_CNTR_CODE = Cnt,
+                    };
+
+                    var task = new TN_Task()
+                    {
+                        S_CODE = WCSHelper.GenerateTaskNo(),
+                        S_START_AREA = startLoc.S_AREA_CODE,
+                        S_END_AREA = endLoc.S_AREA_CODE,
+                        S_START_LOC = startLoc.S_CODE,
+                        S_END_LOC = endLoc.S_CODE,
+                        S_TYPE = "绾胯竟绌烘墭涓婄嚎",
+                        N_PRIORITY = 3,
+                        N_SCHEDULE_TYPE = 1,
+                        N_B_STATE = 0,
+                        S_B_STATE = "绛夊緟",
+                        S_CNTR_CODE = Cnt,
+                    };
+
+                    if (
+                        db.Updateable<TN_Location>(startLoc).UpdateColumns(it=>new {it.N_CURRENT_NUM,it.N_LOCK_STATE,it.S_LOCK_STATE }).ExecuteCommand() == 1 &&
+                        db.Updateable<TN_Location>(endLoc).UpdateColumns(it=>new {it.N_LOCK_STATE,it.S_LOCK_STATE }).ExecuteCommand() == 1 &&
+                        db.Insertable<TN_Loc_Container>(locCnt).ExecuteCommand() == 1 &&
+                        db.Insertable<TN_Task>(task).ExecuteCommand() == 1
+                        )
+                    {
+                        if (Settings.LineSorting < Settings.ProductionLines.Count - 1)
+                        {
+                            Settings.LineSorting++;
+                        }
+                        else
+                        {
+                            Settings.LineSorting = 0;
+                        }
+
+
+                        trans.CommitTran();
+                        result.resultCode = 0;
+                        result.resultMsg = $"鍒涘缓 绾胯竟绌烘墭涓婄嚎 浠诲姟鎴愬姛锛岃捣鐐癸細{startLoc.S_CODE}锛岀粓鐐癸細{endLoc.S_CODE}";
+                        LogHelper.Info(result.resultMsg);
+                        return result;
+                    }
+                    else
+                    {
+                        trans.RollbackTran();
+                        result.resultCode = 12;
+                        result.resultMsg = $"鍒涘缓 绾胯竟绌烘墭涓婄嚎 浠诲姟澶辫触锛岃捣鐐癸細{startLoc.S_CODE}锛岀粓鐐癸細{endLoc.S_CODE}";
+                        LogHelper.Info(result.resultMsg);
+                        return result;
+                    }
+                }
+            }
+            catch(Exception ex)
+            {
+                result.resultCode = -1;
+                result.resultMsg = $"PDA婊℃墭澶嶆鍒ゆ柇锛屽彂鐢熶簡寮傚父锛歿ex.Message}";
+                LogHelper.Info(result.resultMsg);
+                return result;
+            }
+        }
+
+        /// <summary>
         /// 浜哄伐娆″搧鍥炵倝
         /// </summary>
         /// <param name="model"></param>
@@ -306,11 +505,13 @@
         internal static SimpleResult PDAReturnReset(PDAReturnResetInfo model)
         {
             LogHelper.Info("瑙﹀彂API锛氫汉宸ユ鍝佸洖鐐� + JsonConvert.SerializeObject(model), "API");
-            var db = new SqlHelper<object>().GetInstance();
+         
             var result = new SimpleResult();//杩斿洖缁撴灉
 
             try
             {
+                var db = new SqlHelper<object>().GetInstance();
+
                 var startLoc  =  db.Queryable<TN_Location>().First(o => o.S_CODE == model.startLoc && o.N_CURRENT_NUM ==0 && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE=="鏃� && o.S_AREA_CODE == Settings.Areas[4]);
                 if (startLoc == null)
                 {
@@ -320,7 +521,13 @@
                     return result;
                 }
 
-                var endLoc = db.Queryable<TN_Location>().First(o =>o.S_AREA_CODE == Settings.Areas[11] && o.N_CURRENT_NUM == 0 && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == "鏃�);
+                var endLoc = db.Queryable<TN_Location>().
+                    Where(o =>o.S_AREA_CODE == Settings.Areas[11] 
+                    && o.N_CURRENT_NUM == 0 
+                    && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == "鏃�
+                    && SqlFunc.Subqueryable<TN_Loc_Container>().Where(b => b.S_LOC_CODE == o.S_CODE).NotAny()
+                    ).First();
+
                 if (endLoc == null)
                 {
                     result.resultCode = 2;
@@ -359,7 +566,7 @@
 
                 endLoc.N_LOCK_STATE = 1;
                 endLoc.S_LOCK_STATE = "鍏ュ簱閿�;
-                startLoc.T_MODIFY = System.DateTime.Now;
+                endLoc.T_MODIFY = System.DateTime.Now;
 
                 using (var tran = db.Ado.UseTran())
                 {
@@ -649,12 +856,14 @@
         /// </summary>
         internal static SimpleResult PDAFullInArea(PDAFullInAreaInfo model)
         {
-            var db = new SqlHelper<object>().GetInstance();
+
             var result = new SimpleResult();//杩斿洖缁撴灉
             LogHelper.Info("瑙﹀彂API锛歅DA婊℃墭涓嬬嚎鍏ュ簱" + JsonConvert.SerializeObject(model), "API");
             try
             {
-                if( model.RfId.Length < 16)
+                var db = new SqlHelper<object>().GetInstance();
+
+                if (model.RfId.Length < 16)
                 {
                     result.resultCode = 1;
                     result.resultMsg = $"杈撳叆鐨凴FID锛岄暱搴︿笉澶燂紝瑕佸ぇ浜�6浣�;
@@ -662,7 +871,7 @@
                     return result;
                 }
 
-                model.RfId = WMSHelper.ConvertHexToAscii(model.RfId);
+                model.RfId = WMSHelper.ConvertHexToAscii(model.RfId.Substring(0,16));
 
                 //璇ヤ骇绾跨殑婊℃墭涓嬬嚎浣嶇疆锛岃捣鐐�                 var startPoint = Settings.ProductionLines.FirstOrDefault(a => a.PointOut == model.StartLoc);
@@ -728,8 +937,12 @@
                                 };
 
                                 var endLoc = db.Queryable<TN_Location>().
-                                                      Where(c => c.S_AREA_CODE == Settings.Areas[1] && c.S_LOCK_STATE == "鏃� && c.N_LOCK_STATE == 0 && c.N_CURRENT_NUM == 0 && c.C_ENABLE == "Y").
-                                                      OrderBy(o => o.T_MODIFY, OrderByType.Asc).First();//鏌ヨ鍚堥�鐨勭粓鐐硅揣浣嶏紝鐩存帴鍒ゆ柇褰撳墠鏁伴噺涓�鍗冲彲
+                                                      Where(c => c.S_AREA_CODE == Settings.Areas[1] 
+                                                      && c.S_LOCK_STATE == "鏃� && c.N_LOCK_STATE == 0 
+                                                      && c.N_CURRENT_NUM == 0 && c.C_ENABLE == "Y"
+                                                      && SqlFunc.Subqueryable<TN_Loc_Container>().Where(b => b.S_LOC_CODE == c.S_CODE).NotAny()//涓嶈兘鏈夎揣
+                                                      ).
+                                                      OrderBy(o => o.N_LAYER, OrderByType.Asc).First();//鏌ヨ鍚堥�鐨勭粓鐐硅揣浣嶏紝1灞傚厛鍏ュ簱
 
                                 if (endLoc != null)
                                 {
@@ -937,10 +1150,11 @@
             LogHelper.Info("瑙﹀彂API锛氭弧鎵樺嚭搴撲笂绾� + JsonConvert.SerializeObject(model), "API");
 
             var result = new SimpleResult();
-            var db = new SqlHelper<object>().GetInstance();
+
             TN_Location endLoc = new TN_Location();
             try
             {
+                var db = new SqlHelper<object>().GetInstance();
                 if (model.EndLoc != string.Empty)//鎸囧畾缁堢偣璐т綅
                 {
                     endLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.EndLoc);
@@ -969,7 +1183,7 @@
                         return result;
                     }
 
-                    if (endLoc.N_CURRENT_NUM != 0)
+                    if (endLoc.N_CURRENT_NUM != 0 || db.Queryable<TN_Loc_Container>().Any(b => b.S_LOC_CODE == model.EndLoc))//涓嶈兘鏈夎揣
                     {
                         result.resultCode = 5;
                         result.resultMsg = $"璇ョ粓鐐硅揣浣峽model.EndLoc}宸叉弧";
@@ -987,13 +1201,13 @@
 
                 var waitTime = SpecHelper.GetWaitTime(model.Spe);
 
-                //浼樺厛鎶�湳鍚堟牸
+                //浼樺厛鎶�湳鍒ゅ畾
                 var startLoc = db.Queryable<TN_Location>().
                     LeftJoin<TN_Loc_Container>((o, i) => o.S_CODE == i.S_LOC_CODE).
                     LeftJoin<TN_CG_Detail>((o, i, s) => i.S_CNTR_CODE == s.S_CNTR_CODE).
                     Where((o, i, s) => o.N_CURRENT_NUM > 0 && o.S_AREA_CODE == Settings.Areas[1] && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == "鏃� && o.C_ENABLE == "Y"
                     && (s.S_ITEM_SPEC == model.Spe || s.S_SPE == model.Spe)//鎸囧畾瑙勬牸
-                    && s.N_ITEM_STATE == 4 && s.S_ITEM_STATE == "鎶�湳鍚堟牸"). //鎶�湳鍚堟牸
+                    && s.N_ITEM_STATE == 4 && s.S_ITEM_STATE == "鎶�湳鍒ゅ畾"). //鎶�湳鍒ゅ畾
                     First();//绛涢�鏈夊鍣ㄨ揣浣嶅叧绯昏〃淇℃伅锛岀瓫閫夋湁瀹瑰櫒璐у搧鏄庣粏琛ㄤ俊鎭� 
                 if (startLoc == null)//鍏舵鍚堟牸
@@ -1005,7 +1219,7 @@
                        Where((o, i, s) => o.N_CURRENT_NUM > 0 && o.S_AREA_CODE == Settings.Areas[1] && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == "鏃� && o.C_ENABLE == "Y"
                        && (s.S_ITEM_SPEC == model.Spe || s.S_SPE == model.Spe)//鎸囧畾瑙勬牸
                        && s.N_ITEM_STATE == 0 && s.S_ITEM_STATE == "鍚堟牸" //鍚堟牸鐨�-                       && s.T_MODIFY.AddMinutes(waitTime) <= System.DateTime.Now).//鏍规嵁瑙勬牸鐨勪笉鍚岄潤缃笉鍚屽垎閽熸墠鑳藉嚭搴�+                       && i.T_CREATE.AddMinutes(waitTime) <= System.DateTime.Now).//鏍规嵁瑙勬牸鐨勪笉鍚岄潤缃笉鍚屽垎閽熸墠鑳藉嚭搴�                        OrderBy((o, i, s) => s.T_CREATE, OrderByType.Asc).//鍏堣繘鍏堝嚭
                        First();//绛涢�鏈夊鍣ㄨ揣浣嶅叧绯昏〃淇℃伅锛岀瓫閫夋湁瀹瑰櫒璐у搧鏄庣粏琛ㄤ俊鎭�                 }
@@ -1058,11 +1272,6 @@
                         };
                         SpecHelper.InsertComponentDetail(target);
                     });
-
-                    Task task27 = Task.Run(() =>
-                    {
-                        SpecHelper.DeleteInventoryM(cgInfo.S_ID);
-                    });
                 }
                 else
                 {
@@ -1091,13 +1300,14 @@
         {
             LogHelper.Info("瑙﹀彂API锛氱┖鎵樹笅绾垮爢鍙� + JsonConvert.SerializeObject(model), "API");
 
-          
             var result = new SimpleResult();
-            var db = new SqlHelper<object>().GetInstance();
+
             TN_Location startLoc = new TN_Location();
 
             try
             {
+                var db = new SqlHelper<object>().GetInstance();
+
                 var startLocCntrRel = db.Queryable<TN_Loc_Container>().First(a => a.S_LOC_CODE == model.startLoc && a.S_CNTR_CODE == model.cntID);
                 if (startLocCntrRel != null)
                 {
@@ -1192,13 +1402,13 @@
             LogHelper.Info("瑙﹀彂API锛氫綑鏂欎笅绾垮叆搴� + JsonConvert.SerializeObject(model), "API");
 
             var result = new SimpleResult();
-            var db = new SqlHelper<object>().GetInstance();
+
             TN_Location startLoc_Old = new TN_Location();
             TN_Location startLoc_New = new TN_Location();
 
             try
             {
-
+                var db = new SqlHelper<object>().GetInstance();
                 var cG_Detail = db.Queryable<TN_CG_Detail>().First(a => a.S_CNTR_CODE == model.cntID);
                 if (cG_Detail == null)
                 {
@@ -1264,7 +1474,9 @@
 
                 //鏌ヨ绗﹀悎鐨勬湭閿佸畾宸插惎鐢ㄦ寚瀹氳揣鍖虹殑璐т綅锛岀粓鐐�                 var endLoc = db.Queryable<TN_Location>().
-                          First(o => o.S_AREA_CODE == Settings.Areas[9] && o.S_CODE == weightPoint && o.C_ENABLE == "Y");//鏌ヨ鍚堥�鐨勭粓鐐硅揣浣�+                          First(o => o.S_AREA_CODE == Settings.Areas[9]
+                          && SqlFunc.Subqueryable<TN_Loc_Container>().Where(b => b.S_LOC_CODE == o.S_CODE).NotAny()
+                          && o.S_CODE == weightPoint && o.C_ENABLE == "Y");//鏌ヨ鍚堥�鐨勭粓鐐硅揣浣� 
                 if (endLoc == null)
                 {
@@ -1469,10 +1681,12 @@
             LogHelper.Info("瑙﹀彂API锛氫汉宸ユ媶鐩樺叆搴� + JsonConvert.SerializeObject(model), "API");
 
             var result = new SimpleResult();
-            var db = new SqlHelper<object>().GetInstance();
+
             string cntLog = $"鏃х殑瀹瑰櫒鍙穥model.old_CntId}";
             try
             {
+                var db = new SqlHelper<object>().GetInstance();
+
                 if (model.new_IsOK == model.old_IsOK)
                 {
                     result.resultCode = 19;
@@ -1590,10 +1804,14 @@
                 }
 
                 var endLoc_Ok = db.Queryable<TN_Location>().
-                          First(o => o.S_AREA_CODE == Settings.Areas[9] && o.S_CODE == weightPoint);//鏌ヨ鍚堥�鐨勭粓鐐硅揣浣嶏紝鍘荤О閲�+                          First(o => o.S_AREA_CODE == Settings.Areas[9]
+                          && o.S_CODE == weightPoint);//鏌ヨ鍚堥�鐨勭粓鐐硅揣浣嶏紝鍘荤О閲� 
                 var endLoc_NG = db.Queryable<TN_Location>().
-                          First(o => o.S_AREA_CODE == Settings.Areas[8] && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == "鏃� && o.N_CURRENT_NUM == 0);//鏌ヨ鍚堥�鐨勭粓鐐硅揣浣�+                          Where(o => o.S_AREA_CODE == Settings.Areas[8] 
+                          && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == "鏃�
+                          && SqlFunc.Subqueryable<TN_Loc_Container>().Where(b => b.S_LOC_CODE == o.S_CODE).NotAny()//涓嶈兘鏈夎揣
+                          && o.N_CURRENT_NUM == 0).First();//鏌ヨ鍚堥�鐨勭粓鐐硅揣浣� 
                 if (endLoc_Ok == null)
                 {
@@ -1805,9 +2023,10 @@
             LogHelper.Info("瑙﹀彂API锛氫汉宸ュ垱寤虹偣鍒扮偣浠诲姟" + JsonConvert.SerializeObject(model), "API");
 
             var result = new SimpleResult();
-            var db = new SqlHelper<object>().GetInstance();
             try
             {
+                var db = new SqlHelper<object>().GetInstance();
+
                 var startLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.startLoc);
                 
                 if(!(startLoc != null  && startLoc.N_LOCK_STATE == 0 && startLoc.S_LOCK_STATE == "鏃�))
@@ -1820,10 +2039,10 @@
 
                 var endLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.endLoc);
 
-                if (!(endLoc != null && endLoc.N_CURRENT_NUM == 0 && endLoc.N_LOCK_STATE == 0 && endLoc.S_LOCK_STATE == "鏃�))
+                if (!(endLoc != null && endLoc.N_CURRENT_NUM == 0 && endLoc.N_LOCK_STATE == 0 && endLoc.S_LOCK_STATE == "鏃�) || db.Queryable<TN_Loc_Container>().Any(a=>a.S_LOC_CODE == endLoc.S_CODE))
                 {
                     result.resultCode = 2;
-                    result.resultMsg = $"缁堢偣浣嶇疆{model.endLoc}涓嶆弧瓒虫潯浠讹細endLoc != null && endLoc.N_CURRENT_NUM == 0 && endLoc.N_LOCK_STATE == 0 && endLoc.S_LOCK_STATE == 鏃�;
+                    result.resultMsg = $"缁堢偣浣嶇疆{model.endLoc}宸查攣浣忔垨宸叉弧";
                     LogHelper.Info(result.resultMsg);
                     return result;
                 }
@@ -1884,7 +2103,7 @@
                         var cginfo = db.Queryable<TN_CG_Detail>().First(a => a.S_CNTR_CODE == startLocCnt.S_CNTR_CODE);
                         Task task27 = Task.Run(() =>
                         {
-                            if (endLoc.S_AREA_CODE == Settings.Areas[2] && cginfo != null) //鎻掑叆WMS搴撳瓨鏄庣粏
+                            if (endLoc.S_AREA_CODE == Settings.Areas[1] && cginfo != null) //鎻掑叆WMS搴撳瓨鏄庣粏
                             {
                                 var target = new TN_InventoryM()
                                 {
@@ -1898,13 +2117,6 @@
                                     SHIFT = model.shift,
                                 };
                                 SpecHelper.InsertInventoryM(target);
-                            }
-                        });
-                        Task task26 = Task.Run(() =>
-                        {
-                            if (startLoc.S_AREA_CODE == Settings.Areas[2] && cginfo != null)
-                            {
-                                SpecHelper.DeleteInventoryM(cginfo.S_ID);
                             }
                         });
 

--
Gitblit v1.9.1