From 951c9a4e80495429338b9c495addda1ebae9703b Mon Sep 17 00:00:00 2001
From: Administrator <Administrator@DESKTOP-5BIMHQ3>
Date: 星期四, 21 三月 2024 16:56:06 +0800
Subject: [PATCH] agv转运功能修改

---
 Wms/WMS.BLL/BllPdaServer/PdaCrServer.cs |  253 ++++++++++++++++++++++++++++---------------------
 1 files changed, 144 insertions(+), 109 deletions(-)

diff --git a/Wms/WMS.BLL/BllPdaServer/PdaCrServer.cs b/Wms/WMS.BLL/BllPdaServer/PdaCrServer.cs
index e802b7c..8e3fd47 100644
--- a/Wms/WMS.BLL/BllPdaServer/PdaCrServer.cs
+++ b/Wms/WMS.BLL/BllPdaServer/PdaCrServer.cs
@@ -773,33 +773,41 @@
         {
             try
             {
-                var models = Db.Queryable<DataStockDetail>().First(w => w.IsDel == "0" && w.PalletNo == palletNo);
-                if (models == null)
-                {
-                    throw new Exception("鎵樼洏搴撳瓨淇℃伅涓嶅瓨鍦�,璇锋鏌�!");
-                }
-                if (string.IsNullOrEmpty(models.LocatNo))
-                {
-                    throw new Exception("鎵樼洏鍌ㄤ綅淇℃伅涓嶅瓨鍦�,璇锋鏌�!");
-                }
-                if (models.WareHouseNo != "W02")
-                {
-                    throw new Exception("璇ユ墭鐩樻湭鍦ㄥ钩搴撳唴,璇锋鏌�!");
-                }
-                var storageLocat = Db.Queryable<SysStorageLocat>().First(w => w.IsDel == "0" && w.LocatNo == models.LocatNo);
-                if (storageLocat == null)
-                {
-                    throw new Exception("鍌ㄤ綅淇℃伅涓嶅瓨鍦�,璇锋鏌�!");
-                }
                 var storageArea = new List<SysStorageArea>();
-                if (storageLocat.AreaNo.Contains("B0"))
+                if (string.IsNullOrEmpty(palletNo))
                 {
-                    storageArea = Db.Queryable<SysStorageArea>().Where(w => w.AreaNo.Contains("B0")).ToList();
+                    storageArea = Db.Queryable<SysStorageArea>().Where(w => w.IsDel == "0" && w.Status == "0" && w.WareHouseNo == "W02").OrderBy(o=>o.AreaNo).ToList();
                 }
                 else
                 {
-                    storageArea = Db.Queryable<SysStorageArea>().Where(w => w.AreaNo.Contains("B1")).ToList();
-                }
+                    var models = Db.Queryable<DataStockDetail>().First(w => w.IsDel == "0" && w.PalletNo == palletNo);
+                    if (models == null)
+                    {
+                        throw new Exception("鎵樼洏搴撳瓨淇℃伅涓嶅瓨鍦�,璇锋鏌�!");
+                    }
+                    if (string.IsNullOrEmpty(models.LocatNo))
+                    {
+                        throw new Exception("鎵樼洏鍌ㄤ綅淇℃伅涓嶅瓨鍦�,璇锋鏌�!");
+                    }
+                    if (models.WareHouseNo != "W02")
+                    {
+                        throw new Exception("璇ユ墭鐩樻湭鍦ㄥ钩搴撳唴,璇锋鏌�!");
+                    }
+                    var storageLocat = Db.Queryable<SysStorageLocat>().First(w => w.IsDel == "0" && w.LocatNo == models.LocatNo);
+                    if (storageLocat == null)
+                    {
+                        throw new Exception("鍌ㄤ綅淇℃伅涓嶅瓨鍦�,璇锋鏌�!");
+                    }
+                   
+                    if (storageLocat.AreaNo.Contains("B0"))
+                    {
+                        storageArea = Db.Queryable<SysStorageArea>().Where(w => w.IsDel == "0" && w.Status == "0" && w.AreaNo.Contains("B0") && w.WareHouseNo == "W02").OrderBy(o => o.AreaNo).ToList();
+                    }
+                    else
+                    {
+                        storageArea = Db.Queryable<SysStorageArea>().Where(w => w.IsDel == "0" && w.Status == "0" && w.AreaNo.Contains("B1") && w.WareHouseNo == "W02").OrderBy(o => o.AreaNo).ToList();
+                    }
+                }                
                 return storageArea;
             }
             catch (Exception ex)
@@ -867,7 +875,7 @@
         }
 
         /// <summary>
-        /// agv杞繍鍛煎彨灏忚溅-寮�鍙戞湭瀹屾垚寰呯‘璁�
+        /// agv杞繍鍛煎彨灏忚溅
         /// </summary>
         /// <param name="palletNo"></param>
         /// <param name="areaNo"></param>
@@ -1004,7 +1012,7 @@
             }
         }
         /// <summary>
-        /// agv杞繍鍛煎彨灏忚溅鍙栬揣-寮�鍙戞湭瀹屾垚寰呯‘璁�
+        /// agv杞繍鍛煎彨灏忚溅鍙栬揣
         /// </summary>
         /// <param name="soNo"></param>
         /// <param name="palletNo"></param>
@@ -1016,112 +1024,139 @@
             {
                 throw new Exception("璇烽�夋嫨鍑哄簱鍗曟嵁锛�");
             }
-            if (string.IsNullOrEmpty(palletNo))
-            {
-                throw new Exception("璇锋壂鎻忔墭鐩樻潯鐮侊紒");
-            }
             if (string.IsNullOrEmpty(areaNo))
             {
                 throw new Exception("璇烽�夋嫨鐩爣鍖哄煙锛�");
             }
             try
             {
-                var log = Db.Queryable<LogTask>().First(w => w.IsDel == "0" && w.PalletNo == palletNo && (w.Status == "0" || w.Status == "1"));
-                if (log != null)
-                {
-                    throw new Exception("璇ユ墭鐩樺凡鏈夊皬杞︾瓑寰呮墽琛屾垨姝e湪鎵ц鐨勪换鍔�!");
-                }
-
+                //寮�鍚簨鍔�
+                Db.BeginTran();
+                //鍑哄簱鍗曚俊鎭�
                 var notice = Db.Queryable<BllExportNotice>().First(w => w.IsDel == "0" && w.SONo == soNo);
                 if (notice == null)
                 {
                     throw new Exception("鍑哄簱鍗曟嵁淇℃伅涓嶅瓨鍦�,璇锋鏌�!");
                 }
-                var allot = Db.Queryable<BllExportAllot>().First(w => w.IsDel == "0" && w.SONo == soNo && w.PalletNo == palletNo);
-                if (allot == null)
-                {
-                    throw new Exception("璇ユ墭鐩樺嚭搴撳垎閰嶄俊鎭笉瀛樺湪,璇锋鏌�!");
-                }
-                var stockDetail = Db.Queryable<DataStockDetail>().First(w => w.IsDel == "0" && w.PalletNo == palletNo);
-                if (stockDetail == null)
-                {
-                    throw new Exception("鎵樼洏涓婄墿鏂欏簱瀛樹俊鎭笉瀛樺湪,璇锋鏌�!");
-                }
-                var stock = Db.Queryable<DataStock>().First(w => w.IsDel == "0" && w.SkuNo == stockDetail.SkuNo && w.LotNo == stockDetail.LotNo);
-                if (stock == null)
-                {
-                    throw new Exception("鎵樼洏涓婄墿鏂欏簱瀛樹俊鎭笉瀛樺湪,璇锋鏌�!");
-                }
-                if (string.IsNullOrEmpty(stockDetail.LocatNo))
-                {
-                    throw new Exception("鎵樼洏鍌ㄤ綅淇℃伅涓嶅瓨鍦�,璇锋鏌�!");
-                }
-                if (stockDetail.WareHouseNo != "W02")
-                {
-                    throw new Exception("璇ユ墭鐩樻湭鍦ㄥ钩搴撳唴,璇锋鏌�!");
-                }
-                var storageLocat = Db.Queryable<SysStorageLocat>().First(w => w.IsDel == "0" && w.LocatNo == stockDetail.LocatNo);
-                if (storageLocat == null)
-                {
-                    throw new Exception("鍌ㄤ綅淇℃伅涓嶅瓨鍦�,璇锋鏌�!");
-                }
+                //鐩爣鍖哄煙淇℃伅
                 var storageArea = Db.Queryable<SysStorageArea>().First(w => w.IsDel == "0" && w.AreaNo == areaNo);
                 if (storageArea == null)
                 {
                     throw new Exception("鎵�閫夊尯鍩熶俊鎭笉瀛樺湪,璇锋鏌�!");
                 }
-                string EndLocat = string.Empty;//鐩爣浣嶇疆
-                EndLocat= GetLocat(areaNo, stockDetail.SkuNo, stockDetail.LotNo,palletNo);
-                //鐩爣鍌ㄤ綅淇℃伅
-                var storageLocatEnd = Db.Queryable<SysStorageLocat>().First(w => w.IsDel == "0" && w.LocatNo == EndLocat && w.Flag == "0" && w.Status == "0");
-                if (storageLocatEnd == null)
+                List<DataStockDetail> stockDetailList = new List<DataStockDetail>();//闇�瑕佺殑鎵樼洏鏄庣粏
+                if (!string.IsNullOrEmpty(palletNo))//鍗曟墭鐩樺彨璐�
                 {
-                    throw new Exception("鐩爣鍌ㄤ綅淇℃伅涓嶅瓨鍦�,璇锋鏌�!");
+                    stockDetailList = Db.Queryable<DataStockDetail>().Where(w => w.IsDel == "0" && w.PalletNo == palletNo).ToList();
                 }
-                //寮�鍚簨鍔�
-                Db.BeginTran();
-
-                //娣诲姞鍑哄簱浠诲姟
-                var taskNo = new Common().GetMaxNo("TK");
-                var exTask = new LogTask
+                else//鏁翠釜鍑哄簱鍗曞彨璐�
                 {
-                    TaskNo = taskNo,
-                    Sender = "WMS",
-                    Receiver = "AGV",
-                    IsSuccess = 0, //鏄惁涓嬪彂鎴愬姛 0澶辫触 1鎴愬姛
-                    Msg= string.Format("杞繍浠诲姟锛歿0}=>>{1}", stockDetail.LocatNo, EndLocat),
-                    StartLocat = stockDetail.LocatNo,//璧峰浣嶇疆
-                    EndLocat = EndLocat,//鐩爣浣嶇疆
-                    PalletNo = palletNo,//鎵樼洏鐮�
-                    IsSend = 1,//鏄惁鍙啀娆′笅鍙�
-                    IsCancel = 1,//鏄惁鍙彇娑�
-                    IsFinish = 1,//鏄惁鍙畬鎴�
-                    Type = "2",//浠诲姟绫诲瀷 0 鍏ュ簱浠诲姟 1 鍑哄簱浠诲姟  2 绉诲簱浠诲姟
-                    Status = "0",//浠诲姟鐘舵��0锛氱瓑寰呮墽琛�1姝e湪鎵ц2鎵ц瀹屾垚
-                    OrderType = "3",//0 鍏ュ簱鍗� 1 鍑哄簱鍗�  2 鐩樼偣鍗�  3 绉诲簱鍗�
+                    string sqlStr = $"select * from DataStockDetail where PalletNo in (select PalletNo from BllExportAllot where IsDel='0' and SONo='{soNo}')";
+                    stockDetailList = Db.Ado.SqlQuery<DataStockDetail>(sqlStr).ToList();
+                }
+                if (stockDetailList.Count<=0)
+                {
+                    throw new Exception("鎵樼洏鏄庣粏涓嶅瓨鍦�,璇锋鏌�!");
+                }
 
-                    CreateTime = DateTime.Now
-                };
-                Db.Insertable(exTask).ExecuteCommand();
+                var log = Db.Queryable<LogTask>().Where(w => w.IsDel == "0" && (w.Status == "0" || w.Status == "1"));//浠诲姟琛�
+                var storageLocat = Db.Queryable<SysStorageLocat>().Where(w => w.IsDel == "0");//鍌ㄤ綅琛�
+                var stock = Db.Queryable<DataStock>().Where(w => w.IsDel == "0");//搴撳瓨鎬昏〃
+                string EndLocat = string.Empty;//鐩爣浣嶇疆
+                string hasLocatNoList = string.Empty;//宸插垎閰嶇殑鍌ㄤ綅
+                foreach (var item in stockDetailList)
+                {
+                    //浠诲姟淇℃伅
+                    var logInfo = log.First(w =>w.PalletNo == item.PalletNo);
+                    if (logInfo != null)
+                    {
+                        throw new Exception($"鎵樼洏鍙凤細{item.PalletNo}宸叉湁灏忚溅绛夊緟鎵ц鎴栨鍦ㄦ墽琛岀殑浠诲姟!");
+                    }
+                    if (string.IsNullOrEmpty(item.LocatNo))
+                    {
+                        throw new Exception($"鎵樼洏鍙凤細{item.PalletNo}鐨勫偍浣嶄俊鎭笉瀛樺湪,璇锋鏌�!");
+                    }
+                    if (item.WareHouseNo != "W02")
+                    {
+                        throw new Exception($"鎵樼洏鍙凤細{item.PalletNo}鏈湪骞冲簱鍐�,璇锋鏌�!");
+                    }
+                    //璧峰鍌ㄤ綅淇℃伅
+                    var storageLocatBegin = storageLocat.First(w => w.LocatNo == item.LocatNo);
+                    if (storageLocat == null)
+                    {
+                        throw new Exception($"鎵樼洏鍙凤細{item.PalletNo}鎵�鍦ㄧ殑鍌ㄤ綅淇℃伅涓嶅瓨鍦�,璇锋鏌�!");
+                    }
+                    //鑾峰彇鐩爣鍌ㄤ綅
+                    EndLocat = GetLocat(areaNo, item.SkuNo, item.LotNo, palletNo);
+                    if (string.IsNullOrEmpty(EndLocat))
+                    {
+                        throw new Exception("鍒嗛厤鐩爣鍌ㄤ綅澶辫触,璇锋鏌�!");
+                    }
+                    if (string.IsNullOrEmpty(hasLocatNoList))
+                    {
+                        hasLocatNoList = EndLocat;
+                    }
+                    else
+                    {
+                        hasLocatNoList = hasLocatNoList + "," + EndLocat;
+                    }
+                    //鐩爣鍌ㄤ綅淇℃伅
+                    var storageLocatEnd = storageLocat.First(w => w.LocatNo == EndLocat && w.Flag == "0" && w.Status == "0");
+                    if (storageLocatEnd == null)
+                    {
+                        throw new Exception("鐩爣鍌ㄤ綅淇℃伅涓嶅瓨鍦�,璇锋鏌�!");
+                    }
 
-                //淇敼搴撳瓨鏄庣粏淇℃伅
-                stockDetail.Status = "4";//绉诲簱閿佸畾
-                stockDetail.LockQty = stockDetail.Qty;//閿佸畾搴撳瓨鏁伴噺
-                Db.Updateable(stockDetail).ExecuteCommand();
-                //淇敼搴撳瓨淇℃伅
-                stock.LockQty += (decimal)stockDetail.Qty;
-                Db.Updateable(stock).ExecuteCommand();
+                    //娣诲姞鍑哄簱浠诲姟
+                    var taskNo = new Common().GetMaxNo("TK");
+                    var exTask = new LogTask
+                    {
+                        TaskNo = taskNo,
+                        Sender = "WMS",
+                        Receiver = "AGV",
+                        IsSuccess = 0, //鏄惁涓嬪彂鎴愬姛 0澶辫触 1鎴愬姛
+                        Msg = string.Format("杞繍浠诲姟锛歿0}=>>{1}", item.LocatNo, EndLocat),
+                        StartLocat = item.LocatNo,//璧峰浣嶇疆
+                        EndLocat = EndLocat,//鐩爣浣嶇疆
+                        PalletNo = palletNo,//鎵樼洏鐮�
+                        IsSend = 1,//鏄惁鍙啀娆′笅鍙�
+                        IsCancel = 1,//鏄惁鍙彇娑�
+                        IsFinish = 1,//鏄惁鍙畬鎴�
+                        Type = "2",//浠诲姟绫诲瀷 0 鍏ュ簱浠诲姟 1 鍑哄簱浠诲姟  2 绉诲簱浠诲姟
+                        Status = "0",//浠诲姟鐘舵��0锛氱瓑寰呮墽琛�1姝e湪鎵ц2鎵ц瀹屾垚
+                        OrderType = "3",//0 鍏ュ簱鍗� 1 鍑哄簱鍗�  2 鐩樼偣鍗�  3 绉诲簱鍗�
 
-                //淇敼鍌ㄤ綅鍦板潃鐘舵��
-                storageLocat.Status = "5";//0锛氱┖鍌ㄤ綅 1锛氭湁鐗╁搧 2锛氬叆搴撲腑 3锛氬嚭搴撲腑 4锛氱Щ鍏ヤ腑 5锛氱Щ鍑轰腑 
-                Db.Updateable(storageLocat).ExecuteCommand();
+                        CreateTime = DateTime.Now
+                    };
+                    Db.Insertable(exTask).ExecuteCommand();
 
-                //淇敼鐩爣鍌ㄤ綅鍦板潃鐘舵��
-                storageLocatEnd.Status = "4";//0锛氱┖鍌ㄤ綅 1锛氭湁鐗╁搧 2锛氬叆搴撲腑 3锛氬嚭搴撲腑 4锛氱Щ鍏ヤ腑 5锛氱Щ鍑轰腑 
-                Db.Updateable(storageLocatEnd).ExecuteCommand();
+                    //淇敼搴撳瓨鏄庣粏淇℃伅
+                    item.Status = "4";//绉诲簱閿佸畾
+                    item.LockQty = item.Qty;//閿佸畾搴撳瓨鏁伴噺
+                    Db.Updateable(item).ExecuteCommand();
 
-                //娣诲姞鎿嶄綔鏃ュ織璁板綍
-                var k = new OperationCrServer().AddLogOperationCr("PDA妯″潡", "AGV杞繍", palletNo, "绉诲簱", $"PDA鍛煎彨灏忚溅瀵规墭鐩樺彿锛歿palletNo}鍙戣捣杞繍", userId);
+                    //淇敼璧峰鍌ㄤ綅鍦板潃鐘舵��
+                    storageLocatBegin.Status = "5";//0锛氱┖鍌ㄤ綅 1锛氭湁鐗╁搧 2锛氬叆搴撲腑 3锛氬嚭搴撲腑 4锛氱Щ鍏ヤ腑 5锛氱Щ鍑轰腑 
+                    Db.Updateable(storageLocatBegin).ExecuteCommand();
+                    //淇敼鐩爣鍌ㄤ綅鍦板潃鐘舵��
+                    storageLocatEnd.Status = "4";//0锛氱┖鍌ㄤ綅 1锛氭湁鐗╁搧 2锛氬叆搴撲腑 3锛氬嚭搴撲腑 4锛氱Щ鍏ヤ腑 5锛氱Щ鍑轰腑 
+                    Db.Updateable(storageLocatEnd).ExecuteCommand();
+
+                    var stockInfo = stock.First(w => w.SkuNo == item.SkuNo && w.LotNo == item.LotNo);
+                    //淇敼搴撳瓨淇℃伅
+                    stockInfo.LockQty += (decimal)item.Qty;//閿佸畾鏁伴噺
+                    Db.Updateable(stockInfo).ExecuteCommand();
+                }
+                if (string.IsNullOrEmpty(palletNo))
+                {
+                    //娣诲姞鎿嶄綔鏃ュ織璁板綍
+                    var k = new OperationCrServer().AddLogOperationCr("PDA妯″潡", "AGV杞繍", palletNo, "绉诲簱", $"PDA鍛煎彨灏忚溅瀵瑰嚭搴撳崟锛歿soNo}涓嬫墍鏈夋墭鐩樺彂璧疯浆杩�", userId);
+                }
+                else
+                {
+                    //娣诲姞鎿嶄綔鏃ュ織璁板綍
+                    var k = new OperationCrServer().AddLogOperationCr("PDA妯″潡", "AGV杞繍", palletNo, "绉诲簱", $"PDA鍛煎彨灏忚溅瀵规墭鐩樺彿锛歿palletNo}鍙戣捣杞繍", userId);
+                }
                 //鎻愪氦浜嬪姟
                 Db.CommitTran();
 
@@ -1142,7 +1177,7 @@
         /// <param name="skuNo"></param>
         /// <param name="lotNo"></param>
         /// <returns></returns>
-        private string GetLocat(string areaNo,string skuNo,string lotNo,string palletNo)
+        private string GetLocat(string areaNo,string skuNo,string lotNo,string palletNo,string hasLocatNoList="")
         {
             try
             {
@@ -1156,7 +1191,7 @@
                 {
                     var locatInfo = storageLocatList.Where(w => w.LocatNo == item).First();
 
-                    var locatInfo2 = storageLocatList.Where(w => w.IsDel == "0" && w.Status == "0" && w.Flag == "0" && w.LocatNo != locatInfo.LocatNo && w.Row == locatInfo.Row)
+                    var locatInfo2 = storageLocatList.Where(w => w.IsDel == "0" && w.Status == "0" && w.Flag == "0" && w.LocatNo != locatInfo.LocatNo && w.Row == locatInfo.Row && !hasLocatNoList.Contains(w.LocatNo))
                         .OrderByDescending(o => o.Column).First();
                     if (locatInfo2 != null)
                     {
@@ -1165,7 +1200,7 @@
                 }
                 if (string.IsNullOrEmpty(endLocat))
                 {
-                    var locatInfo3 = storageLocatList.Where(w => w.IsDel == "0" && w.Flag == "0" && w.Status == "0")
+                    var locatInfo3 = storageLocatList.Where(w => w.IsDel == "0" && w.Flag == "0" && w.Status == "0" && !hasLocatNoList.Contains(w.LocatNo))
                                 .OrderByDescending(m => m.Layer).OrderByDescending(m=>m.Column).OrderByDescending(m=> m.Row).First();
 
                     if (locatInfo3 != null)

--
Gitblit v1.8.0