From 91b3014f920903721af7590ce1049d91b20bfd96 Mon Sep 17 00:00:00 2001
From: 杨张扬 <634643841@qq.com>
Date: 星期三, 11 六月 2025 17:25:22 +0800
Subject: [PATCH] 临时取消容器ID的解析

---
 api/ApiHelper.cs |  248 ++++++++++++++++++++++++++++++++----------------
 1 files changed, 164 insertions(+), 84 deletions(-)

diff --git a/api/ApiHelper.cs b/api/ApiHelper.cs
index e8a32c6..d05b32b 100644
--- a/api/ApiHelper.cs
+++ b/api/ApiHelper.cs
@@ -161,7 +161,10 @@
                     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)//鎶�湳鍚堟牸鍥炲簱
@@ -169,7 +172,10 @@
                     cG_Detail.N_ITEM_STATE = 4;
                     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 +183,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,13 +194,38 @@
                     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)//涓�骇鏂欎簩绾ф枡鍥炲簱
+                {
+                    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 == "鏃�
+                            && 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)//涓�骇鏂欎簩绾ф枡鍥炲簱
+                {
+                    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 == "鏃�
+                            && 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 = $"鐗╂枡鐘舵�鍙兘涓�銆�銆�銆�锛屽鏋滀负鍏朵粬鍊硷紝鍒欎笉澶勭悊锛�鍚堟牸锛�涓嶅悎鏍硷紝4鎶�湳鍚堟牸锛�娣峰悎";
+                    result.resultMsg = $"鐗╂枡鐘舵�鍙兘涓�鍚堟牸1寰呮2涓嶅悎鏍硷紝涓嬬嚎鍗冲緟妫�紝3杩囨湡锛�鎶�湳鍚堟牸锛�娣峰悎锛�涓�骇鏂欍�7浜岀骇鏂欙紝濡傛灉涓哄叾浠栧�锛屽垯涓嶅鐞�;
                     LogHelper.Info(result.resultMsg);
                     return result;
                 }
@@ -304,7 +338,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;
@@ -343,7 +383,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())
                 {
@@ -638,15 +678,15 @@
             LogHelper.Info("瑙﹀彂API锛歅DA婊℃墭涓嬬嚎鍏ュ簱" + JsonConvert.SerializeObject(model), "API");
             try
             {
-                if( model.RfId.Length < 16)
-                {
-                    result.resultCode = 1;
-                    result.resultMsg = $"杈撳叆鐨凴FID锛岄暱搴︿笉澶燂紝瑕佸ぇ浜�6浣�;
-                    LogHelper.Info(result.resultMsg);
-                    return result;
-                }
+                //if( model.RfId.Length < 16)
+                //{
+                //    result.resultCode = 1;
+                //    result.resultMsg = $"杈撳叆鐨凴FID锛岄暱搴︿笉澶燂紝瑕佸ぇ浜�6浣�;
+                //    LogHelper.Info(result.resultMsg);
+                //    return result;
+                //}
 
-                model.RfId = WMSHelper.ConvertHexToAscii(model.RfId);
+                //model.RfId = WMSHelper.ConvertHexToAscii(model.RfId);
 
                 //璇ヤ骇绾跨殑婊℃墭涓嬬嚎浣嶇疆锛岃捣鐐�                 var startPoint = Settings.ProductionLines.FirstOrDefault(a => a.PointOut == model.StartLoc);
@@ -712,7 +752,11 @@
                                 };
 
                                 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").
+                                                      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.T_MODIFY, OrderByType.Asc).First();//鏌ヨ鍚堥�鐨勭粓鐐硅揣浣嶏紝鐩存帴鍒ゆ柇褰撳墠鏁伴噺涓�鍗冲彲
 
                                 if (endLoc != null)
@@ -953,7 +997,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}宸叉弧";
@@ -1248,7 +1292,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)
                 {
@@ -1460,7 +1506,7 @@
                 if (model.new_IsOK == model.old_IsOK)
                 {
                     result.resultCode = 19;
-                    result.resultMsg = $"浜哄伐鎷嗙洏鍏ュ簱锛岀墿鏂欓渶瑕佷竴涓悎鏍间竴涓笉鍚堟牸";
+                    result.resultMsg = $"浜哄伐鎷嗙洏鍏ュ簱锛岀墿鏂欓渶瑕佷竴涓緟妫�竴涓笉鍚堟牸";
                     LogHelper.Info(result.resultMsg);
                     return result;
                 }
@@ -1503,7 +1549,6 @@
 
                 var startLoc_New = db.Queryable<TN_Location>().
                     First(b => b.S_CODE == model.new_StartLoc && b.N_CURRENT_NUM == 0 && b.S_AREA_CODE == Settings.Areas[5] && b.N_LOCK_STATE == 0 && b.S_LOCK_STATE == "鏃�);
-
 
                 if (startLoc_New == null)
                 {
@@ -1575,15 +1620,19 @@
                 }
 
                 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)
                 {
                     result.resultCode = 10;
-                    result.resultMsg = $"鍚堟牸鐨勭墿鏂欐湭鎵惧埌鍚堥�鐨勭О閲嶇粓鐐硅揣浣峽weightPoint}";
+                    result.resultMsg = $"寰呮鐨勭墿鏂欐湭鎵惧埌鍚堥�鐨勭О閲嶇粓鐐硅揣浣峽weightPoint}";
                     LogHelper.Info(result.resultMsg);
                     return result;
                 }
@@ -1591,7 +1640,7 @@
                 if (endLoc_NG == null)
                 {
                     result.resultCode = 16;
-                    result.resultMsg = $"涓嶅悎鏍肩殑鐗╂枡鏈壘鍒板悎閫傜殑鍥炵倝鍖虹粓鐐硅揣浣峽Settings.Areas[8]}";
+                    result.resultMsg = $"涓嶅悎鏍肩殑鐗╂枡鏈壘鍒板悎閫傜殑鎷嗙洏涓嶅悎鏍煎尯缁堢偣璐т綅{Settings.Areas[8]}";
                     LogHelper.Info(result.resultMsg);
                     return result;
                 }
@@ -1609,7 +1658,7 @@
                     fromArea = startLoc_New.S_AREA_CODE,
                     to = (model.new_IsOK == 2) ? endLoc_NG.S_CODE : endLoc_Ok.S_CODE,
                     toArea = (model.new_IsOK == 2) ? endLoc_NG.S_AREA_CODE : endLoc_Ok.S_AREA_CODE,
-                    taskType = (model.new_IsOK == 2) ? "浜哄伐鎷嗙洏鍥炵倝" : "浜哄伐鎷嗙洏鍥炲簱",
+                    taskType = (model.new_IsOK == 2) ? "浜哄伐鎷嗙洏鍥炰笉鍚堟牸鍖� : "浜哄伐鎷嗙洏鍥炲簱",
                     pri = 3,
                     cntrInfo = model.new_CntIds,
                     spec = cG_new_Detail_Ins.S_SPE,
@@ -1624,7 +1673,7 @@
                     fromArea = startLoc_Old.S_AREA_CODE,
                     to = (model.old_IsOK == 2) ? endLoc_NG.S_CODE : endLoc_Ok.S_CODE,
                     toArea = (model.old_IsOK == 2) ? endLoc_NG.S_AREA_CODE : endLoc_Ok.S_AREA_CODE,
-                    taskType = (model.old_IsOK == 2) ? "浜哄伐鎷嗙洏鍥炵倝" : "浜哄伐鎷嗙洏鍥炲簱",
+                    taskType = (model.old_IsOK == 2) ? "浜哄伐鎷嗙洏鍥炰笉鍚堟牸鍖� : "浜哄伐鎷嗙洏鍥炲簱",
                     pri = 3,
                     cntrInfo = model.old_CntId,
                     spec = cG_old_Detail.S_SPE,
@@ -1795,88 +1844,119 @@
             {
                 var startLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.startLoc);
                 
-                if(!(startLoc != null && startLoc.N_CURRENT_NUM > 0 && startLoc.N_LOCK_STATE == 0 && startLoc.S_LOCK_STATE == "鏃�))
+                if(!(startLoc != null  && startLoc.N_LOCK_STATE == 0 && startLoc.S_LOCK_STATE == "鏃�))
                 {
                     result.resultCode = 1;
-                    result.resultMsg = $"璧峰浣嶇疆{model.startLoc}涓嶆弧瓒虫潯浠讹細startLoc != null && startLoc.N_CURRENT_NUM > 0 && startLoc.N_LOCK_STATE == 0 && startLoc.S_LOCK_STATE == 鏃�;
+                    result.resultMsg = $"璧峰浣嶇疆{model.startLoc}涓嶆弧瓒虫潯浠讹細startLoc != null && startLoc.N_LOCK_STATE == 0 && startLoc.S_LOCK_STATE == 鏃�;
                     LogHelper.Info(result.resultMsg);
                     return result;
                 }
 
                 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;
                 }
-
                 var startLocCnt = db.Queryable<TN_Loc_Container>().First(a => a.S_LOC_CODE == model.startLoc);
                 
-                if (startLocCnt == null)
+                var tn_Task = new TN_Task()
                 {
-                    startLocCnt = new TN_Loc_Container()
-                    {
-                        S_LOC_CODE = model.startLoc,
-                        S_CNTR_CODE = Guid.NewGuid().ToString("D"),
-                    };
-                    db.Insertable<TN_Loc_Container>(startLocCnt).ExecuteCommand();
-                }
+                    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 = model.priority,
+                    N_SCHEDULE_TYPE = 1,
+                    N_B_STATE = 0
+                };
+                startLoc.N_LOCK_STATE  = 2;
+                startLoc.S_LOCK_STATE = "鍑哄簱閿�;
+                startLoc.N_CURRENT_NUM = 1;
 
-                //鍒涘缓鐐瑰鐐逛换鍔�-                if (WCSHelper.CreateTask(startLoc.S_CODE, endLoc.S_CODE, "鐐瑰鐐�, 3, startLocCnt.S_CNTR_CODE))//鍒涘缓鎼�浠诲姟锛岃捣鐐圭粓鐐瑰鍣�+                endLoc.N_LOCK_STATE = 1;
+                endLoc.S_LOCK_STATE = "鍏ュ簱閿�;
+
+
+                using (var tran = db.Ado.UseTran())
                 {
-                    LocationHelper.LockLoc(startLoc.S_CODE, 2);//璧风偣鍑哄簱閿侊紝
-                    LocationHelper.LockLoc(endLoc.S_CODE, 1);//缁堢偣鍏ュ簱閿�-                    LogHelper.Info($"鐢熸垚鐐瑰鐐逛换鍔℃垚鍔燂紝瀹瑰櫒鍙穥startLocCnt.S_CNTR_CODE}锛岃捣鐐箋startLoc.S_CODE}锛岀粓鐐箋endLoc.S_CODE}");
-
-                    Task task1 = Task.Run(() =>
+                    if (startLocCnt == null)
                     {
-                        WMSHelper.InsertOpInfo(model.staff, "鐐瑰鐐�, startLocCnt.S_CNTR_CODE);
-                    });
-
-                    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)
+                        startLocCnt = new TN_Loc_Container()
                         {
-                            var target = new TN_InventoryM()
+                            S_LOC_CODE = model.startLoc,
+                            S_CNTR_CODE = Guid.NewGuid().ToString("D"),
+                        };
+                        if (db.Insertable<TN_Loc_Container>(startLocCnt).ExecuteCommand() <= 0)
+                        {
+                            tran.RollbackTran();
+                            result.resultCode = 3;
+                            result.resultMsg = $"鎻掑叆TN_Loc_Container琛ㄥけ璐ワ紝璐т綅锛歿model.startLoc}";
+                            LogHelper.Info(result.resultMsg);
+                            return result;
+                        }
+                    }
+                    
+                    tn_Task.S_CNTR_CODE = startLocCnt.S_CNTR_CODE;
+
+                    if (db.Insertable<TN_Task>(tn_Task).ExecuteCommand() > 0 &&
+                        db.Updateable<TN_Location>(startLoc).ExecuteCommand() > 0 &&
+                        db.Updateable<TN_Location>(endLoc).ExecuteCommand() > 0
+                        ){
+                        LogHelper.Info($"鐢熸垚鐐瑰鐐逛换鍔℃垚鍔燂紝瀹瑰櫒鍙穥startLocCnt.S_CNTR_CODE}锛岃捣鐐箋startLoc.S_CODE}锛岀粓鐐箋endLoc.S_CODE}");
+
+                        Task task1 = Task.Run(() =>
+                        {
+                            WMSHelper.InsertOpInfo(model.staff, "鐐瑰鐐�, startLocCnt.S_CNTR_CODE);
+                        });
+
+                        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搴撳瓨鏄庣粏
                             {
-                                S_ID = cginfo.S_ID,
-                                RFID = cginfo.S_CNTR_CODE,
-                                SPEC = cginfo.S_SPE,
-                                WEIGHT = cginfo.F_QTY,
-                                ITEMSTATE = cginfo.S_ITEM_STATE,
-                                ITEMCODE = cginfo.S_ITEM_CODE,
-                                LOGINNAME = model.staff,
-                                SHIFT = model.shift,
-                            };
-                            SpecHelper.InsertInventoryM(target);
-                        }
-                    });
-                    Task task26 = Task.Run(() =>
-                    {
-                        if (startLoc.S_AREA_CODE == Settings.Areas[2] && cginfo != null)
+                                var target = new TN_InventoryM()
+                                {
+                                    S_ID = cginfo.S_ID,
+                                    RFID = cginfo.S_CNTR_CODE,
+                                    SPEC = cginfo.S_SPE,
+                                    WEIGHT = cginfo.F_QTY,
+                                    ITEMSTATE = cginfo.S_ITEM_STATE,
+                                    ITEMCODE = cginfo.S_ITEM_CODE,
+                                    LOGINNAME = model.staff,
+                                    SHIFT = model.shift,
+                                };
+                                SpecHelper.InsertInventoryM(target);
+                            }
+                        });
+                        Task task26 = Task.Run(() =>
                         {
-                            SpecHelper.DeleteInventoryM(cginfo.S_ID);
-                        }
-                    });
+                            if (startLoc.S_AREA_CODE == Settings.Areas[2] && cginfo != null)
+                            {
+                                SpecHelper.DeleteInventoryM(cginfo.S_ID);
+                            }
+                        });
 
-                    result.resultCode = 0;
-                    result.resultMsg =  "鎴愬姛";
-                    LogHelper.Info($"鐢熸垚鐐瑰鐐瑰け璐ワ紝瀹瑰櫒鍙穥 startLocCnt.S_CNTR_CODE}锛岃捣鐐箋startLoc.S_CODE}锛岀粓鐐箋endLoc.S_CODE}");
-                    return result;
+                        tran.CommitTran();
+                        result.resultCode = 0;
+                        result.resultMsg = "鎴愬姛";
+                        LogHelper.Info($"鐢熸垚鐐瑰鐐瑰け璐ワ紝瀹瑰櫒鍙穥 startLocCnt.S_CNTR_CODE}锛岃捣鐐箋startLoc.S_CODE}锛岀粓鐐箋endLoc.S_CODE}");
+                        return result;
+                    }
+                    else
+                    {
+                        tran.RollbackTran();
+                        result.resultCode = 9;
+                        result.resultMsg = $"鐢熸垚鐐瑰鐐瑰け璐ワ紝瀹瑰櫒鍙穥 startLocCnt.S_CNTR_CODE}锛岃捣鐐箋startLoc.S_CODE}锛岀粓鐐箋endLoc.S_CODE}";
+                        LogHelper.Info(result.resultMsg);
+                        return result;
+                    }
                 }
-                else
-                {
-                    result.resultCode = 9;
-                    result.resultMsg = $"鐢熸垚鐐瑰鐐瑰け璐ワ紝瀹瑰櫒鍙穥 startLocCnt.S_CNTR_CODE}锛岃捣鐐箋startLoc.S_CODE}锛岀粓鐐箋endLoc.S_CODE}";
-                    LogHelper.Info(result.resultMsg);
-                    return result;
-                }
-
             }
             catch (Exception ex)
             {

--
Gitblit v1.9.1