From 88604ff346c6dc6caf07612aa99a688d3f0428c1 Mon Sep 17 00:00:00 2001
From: wxw <Administrator@DESKTOP-5BIMHQ3>
Date: 星期五, 07 三月 2025 09:37:25 +0800
Subject: [PATCH] 修改问题

---
 Wms/WMS.BLL/BllTransServer/RcsServer.cs |  241 ++++++++++++++++++++++++++++++++++++++++++++---
 1 files changed, 224 insertions(+), 17 deletions(-)

diff --git a/Wms/WMS.BLL/BllTransServer/RcsServer.cs b/Wms/WMS.BLL/BllTransServer/RcsServer.cs
index d6f6333..f771a83 100644
--- a/Wms/WMS.BLL/BllTransServer/RcsServer.cs
+++ b/Wms/WMS.BLL/BllTransServer/RcsServer.cs
@@ -65,7 +65,11 @@
 
                 //寮�濮嬩簨鍔�
                 Db.BeginTran();
-                
+                //鍒ゆ柇鍙枡璁惧鏄惁鏄疉鍖虹殑娣锋枡璁惧03锛岃璁惧鏄帴鏂欐贩鏂欎竴浣撴満锛孉GV鍙《搴旇鍙噣妗舵帴鏂�
+                if (houseNo=="M03" && model.Location == "125" && model.Type=="1")
+                {
+                    model.Type = "0";
+                }
                 switch (model.Type)
                 {
                     case "0"://鎺ユ枡璁惧鍙噣妗�
@@ -79,12 +83,28 @@
                             //鏌ユ壘鍒拌杞﹂棿鍑�妗跺尯
                             List<string> areaNoList = Db.Queryable<SysStorageArea>().Where(w => w.IsDel == "0" && w.Status == "0" && w.Type == "0" && w.WareHouseNo == houseNo).Select(s => s.AreaNo).ToList();
                             //鏌ユ壘鍑�妗�
-                            pallet = stockDetail.Where(w => w.WareHouseNo == houseNo && w.PalletStatus == "0" && w.Status == "0"
-                            && areaNoList.Contains(w.AreaNo)).OrderByDescending(o => o.CreateTime).First();
+                            if (houseNo == "M03")//澶у崟浣撹溅闂村噣妗舵槸缁戝畾鎺ユ枡璁惧鐨�
+                            {
+                                pallet = stockDetail.Where(w => w.WareHouseNo == houseNo && w.PalletStatus == "0" && w.Status == "0"
+                            && areaNoList.Contains(w.AreaNo) && w.UDF1 == deviceInfo.DeviceCode).OrderBy(o => o.UpdateTime).First();
+                            }
+                            else
+                            {
+                                pallet = stockDetail.Where(w => w.WareHouseNo == houseNo && w.PalletStatus == "0" && w.Status == "0"
+                            && areaNoList.Contains(w.AreaNo)).OrderBy(o => o.UpdateTime).First();
+                            }
+                            
                             if (pallet == null)
                             {
                                 throw new Exception("鏆傛棤鍑�妗跺彲鍒嗛厤");
                             }
+                            //鍒嗛厤妗跺悗鍒ゆ柇璇ユ《澶栦晶鍌ㄤ綅鏄惁闇�瑕佺Щ搴�
+                            bool yikuResult = YikuTask(pallet.PalletNo, url);
+                            if (!yikuResult)
+                            {
+                                throw new Exception("绉诲簱澶辫触");
+                            }
+
                             pallet.Status = "2";//鍒嗛厤鐘舵�� 0:寰呭垎閰嶏紝1锛氶儴鍒嗗垎閰� 锛� 2:宸插垎閰�
                                                 //鏇存柊妗跺簱瀛樻槑缁�
                             Db.Updateable(pallet).ExecuteCommand();
@@ -109,11 +129,18 @@
                             List<string> areaNoList2 = Db.Queryable<SysStorageArea>().Where(w => w.IsDel == "0" && w.Status == "0" && w.Type == "1" && w.WareHouseNo == houseNo).Select(s => s.AreaNo).ToList();
                             //鏌ユ壘搴撳瓨涓槸鍚︽湁鍙敤鐨勬鎵规鐨勬贩鏂欐《
                             pallet = stockDetail.Where(w => w.WareHouseNo == houseNo && w.PalletStatus == "1" && w.Status == "0" && w.LotNo == model.LotNo
-                            && areaNoList2.Contains(w.AreaNo)).OrderByDescending(o => o.CompleteTime).First();
+                            && areaNoList2.Contains(w.AreaNo)).OrderBy(o => o.UpdateTime).First();
                             if (pallet == null)
                             {
                                 throw new Exception("鏆傛棤娣锋枡妗跺彲鍒嗛厤");
                             }
+                            //鍒嗛厤妗跺悗鍒ゆ柇璇ユ《澶栦晶鍌ㄤ綅鏄惁闇�瑕佺Щ搴�
+                            bool yikuResult = YikuTask(pallet.PalletNo, url);
+                            if (!yikuResult)
+                            {
+                                throw new Exception("绉诲簱澶辫触");
+                            }
+
                             pallet.Status = "2";//鍒嗛厤鐘舵�� 0:寰呭垎閰嶏紝1锛氶儴鍒嗗垎閰� 锛� 2:宸插垎閰�
                                                 //鏇存柊妗跺簱瀛樻槑缁�
                             Db.Updateable(pallet).ExecuteCommand();
@@ -143,7 +170,7 @@
                                 throw new Exception("鎵规鍙蜂负绌猴紒");
                             }
                             //鏌ユ壘鏄惁鏈夋鎵规鍑哄簱鍗曟槑缁�
-                            var soNoticeDetail = Db.Queryable<BllExportNoticeDetail>().Where(w => w.IsDel == "0" && w.LotNo == model.LotNo).OrderBy(o => o.CreateTime).First();
+                            /*var soNoticeDetail = Db.Queryable<BllExportNoticeDetail>().Where(w => w.IsDel == "0" && w.LotNo == model.LotNo).OrderBy(o => o.CreateTime).First();
                             if (soNoticeDetail == null)
                             {
                                 throw new Exception("璇ユ壒娆℃病鏈夊搴旂殑鍑哄簱鍗曟槑缁�");
@@ -158,17 +185,24 @@
                             soNotice.Status = "3";//姝e湪鎵ц
                             soNotice.UpdateTime = DateTime.Now;
                             //鏇存柊鍑哄簱鍗�
-                            Db.Updateable(soNotice).ExecuteCommand();
+                            Db.Updateable(soNotice).ExecuteCommand();*/
 
                             //鏌ユ壘鍒拌杞﹂棿鍗婃垚鍝佸尯
                             List<string> areaNoList3 = Db.Queryable<SysStorageArea>().Where(w => w.IsDel == "0" && w.Status == "0" && w.Type == "2" && w.WareHouseNo == houseNo).Select(s => s.AreaNo).ToList();
                             //鏌ユ壘搴撳瓨涓槸鍚︽湁姝ゆ壒娆$殑鍚堟牸涓嬫枡妗�
                             pallet = stockDetail.Where(w => w.WareHouseNo == houseNo && w.PalletStatus == "2" && w.Status == "0" && w.LotNo == model.LotNo && w.InspectStatus == "1"
-                            && areaNoList3.Contains(w.AreaNo)).OrderByDescending(o => o.CompleteTime).First();
+                            && areaNoList3.Contains(w.AreaNo)).OrderBy(o => o.UpdateTime).First();
                             if (pallet == null)
                             {
                                 throw new Exception("鏆傛棤涓嬫枡妗跺彲鍒嗛厤");
                             }
+                            //鍒嗛厤妗跺悗鍒ゆ柇璇ユ《澶栦晶鍌ㄤ綅鏄惁闇�瑕佺Щ搴�
+                            bool yikuResult = YikuTask(pallet.PalletNo, url);
+                            if (!yikuResult)
+                            {
+                                throw new Exception("绉诲簱澶辫触");
+                            }
+
                             pallet.Status = "2";//鍒嗛厤鐘舵�� 0:寰呭垎閰嶏紝1锛氶儴鍒嗗垎閰� 锛� 2:宸插垎閰�
                                                 //鏇存柊妗跺簱瀛樻槑缁�
                             Db.Updateable(pallet).ExecuteCommand();
@@ -186,8 +220,23 @@
                             }
                             //鏌ユ壘鍒拌杞﹂棿鑴忔《鍖�
                             List<string> areaNoList4 = Db.Queryable<SysStorageArea>().Where(w => w.IsDel == "0" && w.Status == "0" && w.Type == "3" && w.WareHouseNo == houseNo).Select(s => s.AreaNo).ToList();
-                            List<DataStockDetail> palletList = stockDetail.Where(w => w.WareHouseNo == houseNo && w.PalletStatus == "3" && w.Status == "0"
-                            && areaNoList4.Contains(w.AreaNo)).OrderByDescending(o => o.CompleteTime).ToList();
+
+                            List<DataStockDetail> palletList = new List<DataStockDetail>();
+                            if (houseNo == "M01")
+                            {
+                                palletList = Db.Queryable<DataStockDetail>()
+                                     .LeftJoin<SysStorageLocat>((d, l) => d.LocatNo == l.LocatNo)
+                                    .Where(d => d.WareHouseNo == houseNo && d.PalletStatus == "3" && d.Status == "0" && areaNoList4.Contains(d.AreaNo))
+                                    .OrderBy((d, l) => l.Row)
+                                    .OrderBy((d, l) => l.Column)
+                                    .ToList();
+                            }
+                            else
+                            {
+                                palletList = stockDetail.Where(w => w.WareHouseNo == houseNo && w.PalletStatus == "3" && w.Status == "0"
+                                && areaNoList4.Contains(w.AreaNo)).OrderBy(o => o.UpdateTime).ToList();
+                            }
+                            
                             if (palletList.Count <= 0)
                             {
                                 throw new Exception("鏆傛棤鑴忔《鍙垎閰�");
@@ -230,7 +279,7 @@
                                 #endregion
 
                                 item.Status = "2";//鍒嗛厤鐘舵�� 0:寰呭垎閰嶏紝1锛氶儴鍒嗗垎閰� 锛� 2:宸插垎閰�
-                                                  //鏇存柊妗跺簱瀛樻槑缁�
+                                //鏇存柊妗跺簱瀛樻槑缁�
                                 Db.Updateable(item).ExecuteCommand();
                                 //璧峰鍌ㄤ綅鍦板潃淇℃伅
                                 var startLoction2 = Db.Queryable<SysStorageLocat>().First(w => w.IsDel == "0" && w.LocatNo == item.LocatNo);
@@ -259,6 +308,7 @@
                                     Status = "0",//浠诲姟鐘舵��0锛氱瓑寰呮墽琛�1姝e湪鎵ц2鎵ц瀹屾垚
                                     NoticeDetailNo = int.Parse(noticeNo),
                                     Msg = taskMsg, //鍏抽敭淇℃伅
+                                    LotNo = item.LotNo//鎵规鍙�
                                 };
                                 //缁勭粐涓嬪彂灏忚溅浠诲姟淇℃伅
                                 var task2 = new TaskDetial
@@ -332,6 +382,7 @@
                     Status = "0",//浠诲姟鐘舵��0锛氱瓑寰呮墽琛�1姝e湪鎵ц2鎵ц瀹屾垚
                     NoticeDetailNo = int.Parse(noticeNo),
                     Msg = taskMsg, //鍏抽敭淇℃伅
+                    LotNo = pallet.LotNo//鎵规鍙�
                 };
 
                 //缁勭粐涓嬪彂灏忚溅浠诲姟淇℃伅
@@ -519,7 +570,7 @@
                                 throw new Exception("鎵规鍙蜂负绌猴紒");
                             }
                             //鏍¢獙姝ゆ壒娆℃槸鍚︽湁鍏ュ簱鍗�
-                            var noticeDetail = Db.Queryable<BllArrivalNoticeDetail>().Where(w => w.IsDel == "0" && w.Status == "0" && w.LotNo == model.LotNo).OrderByDescending(o => o.CreateTime).First();
+                            /*var noticeDetail = Db.Queryable<BllArrivalNoticeDetail>().Where(w => w.IsDel == "0" && w.Status == "0" && w.LotNo == model.LotNo).OrderByDescending(o => o.CreateTime).First();
                             if (noticeDetail == null)
                             {
                                 throw new Exception("璇ユ壒娆℃病鏈夊搴旂殑鍏ュ簱鍗曟槑缁�");
@@ -533,7 +584,7 @@
                             }
                             notice.Status = "1";//姝e湪鎵ц
                             //鏇存柊鍏ュ簱鍗曠姸鎬�
-                            Db.Updateable(notice).ExecuteCommand();
+                            Db.Updateable(notice).ExecuteCommand();*/
 
                             //鏌ユ壘鍒拌杞﹂棿鍗婃垚鍝佸尯
                             loction = GetLocatModel(houseNo, "2");
@@ -612,6 +663,7 @@
                     Status = "0",//浠诲姟鐘舵��0锛氱瓑寰呮墽琛�1姝e湪鎵ц2鎵ц瀹屾垚
                     NoticeDetailNo = int.Parse(noticeno),
                     Msg = taskMsg, //鍏抽敭淇℃伅
+                    LotNo = palletInfo.LotNo//鎵规鍙�
                 };
                 var task = new TaskDetial
                 {
@@ -672,10 +724,10 @@
                 //鏌ユ壘鍌ㄤ綅
                 var loctionModel = Db.Queryable<SysStorageLocat>().Where(w => w.IsDel == "0" && w.Status == "0" && w.Flag == "0" && w.WareHouseNo == houseNo && areaNoList.Contains(w.AreaNo))
                     .OrderBy(o => o.Row).OrderByDescending(o => o.Column).First();
-                if (loctionModel == null)
-                {
-                    throw new Exception("璇ヨ溅闂村噣妗跺尯鏆傛棤绌轰綑鍌ㄤ綅");
-                }
+                //if (loctionModel == null)
+                //{
+                //    throw new Exception("璇ヨ溅闂村噣妗跺尯鏆傛棤绌轰綑鍌ㄤ綅");
+                //}
                 return loctionModel;
             }
             catch (Exception ex)
@@ -1142,7 +1194,7 @@
         /// </summary>
         /// <param name="req"></param>
         /// <returns></returns>
-        public bool CreateTaskForAgv(TaskDetial taskDetial, string url)
+        public bool CreateTaskForAgv(TaskDetial taskDetial, string url,string priority=null)
         {
             bool result = false;
 
@@ -1192,6 +1244,7 @@
             agvTask.positionCodePath = pahtList;//灏忚溅璺緞
             agvTask.podCode = "";
             agvTask.userCallCode = "";//taskDetial.Endport;//鐩爣浣嶇疆
+            agvTask.priority = priority;//浼樺厛绾�
             //鍒ゆ柇瀹瑰櫒绫诲瀷
             if (taskDetial.WareHouseNo == "M04")//鍠峰共杞﹂棿
             {
@@ -1241,5 +1294,159 @@
             return result;
             #endregion
         }
+
+        /// <summary>
+        /// 鍒嗛厤妗跺悗鍒ゆ柇璇ユ《澶栦晶鍌ㄤ綅鏄惁闇�瑕佺Щ搴�
+        /// </summary>
+        /// <param name="palletNo"></param>
+        /// <param name="url"></param>
+        /// <returns></returns>
+        /// <exception cref="Exception"></exception>
+        private bool YikuTask(string palletNo,string url)
+        {
+            try
+            {
+                //鍒嗛厤妗剁殑搴撳瓨淇℃伅
+                var palletInfo = Db.Queryable<DataStockDetail>().First(w => w.IsDel == "0" && w.PalletNo == palletNo);
+                if (palletInfo == null)
+                {
+                    throw new Exception("鏈煡璇㈠埌鍒嗛厤妗剁殑搴撳瓨淇℃伅");
+                }
+                //鍒ゆ柇鍒嗛厤鐨勬《鏈夋病鏈夋鍦ㄦ墽琛岀殑浠诲姟锛堢Щ搴撲腑锛�
+                var taskIng= Db.Queryable<LogTask>().First(w => w.IsDel == "0" && (w.Status == "0" || w.Status == "1") && w.PalletNo == palletNo);
+                if (taskIng != null)
+                {
+                    throw new Exception("鍒嗛厤鐨勬《鏈夋鍦ㄦ墽琛岀殑浠诲姟锛岃绋嶅悗鍐嶈瘯");
+                }
+                //鍒嗛厤妗剁殑鍌ㄤ綅淇℃伅
+                var locatInfo = Db.Queryable<SysStorageLocat>().First(w => w.IsDel == "0" && w.LocatNo == palletInfo.LocatNo);
+                if (locatInfo == null)
+                {
+                    throw new Exception("鏈煡璇㈠埌鍒嗛厤妗舵墍鍦ㄧ殑鍌ㄤ綅淇℃伅");
+                }
+                
+                //鍒ゆ柇璇ュ偍浣嶆槸鍚︽槸鍐呬晶鍌ㄤ綅
+                if (!string.IsNullOrEmpty(locatInfo.AisleOne))
+                {
+                    //鍒ゆ柇澶栦晶鍌ㄤ綅鏄惁鏈夋《
+                    var palletInfoYi = Db.Queryable<DataStockDetail>().First(w => w.IsDel == "0" && w.LocatNo == locatInfo.AisleOne);
+                    if (palletInfoYi != null)
+                    {
+                        //鍒ゆ柇瑕佺Щ搴撶殑妗舵槸鍚﹁鍒嗛厤
+                        if (palletInfoYi.Status != "0")
+                        {
+                            throw new Exception("瑕佺Щ搴撶殑妗跺凡琚垎閰嶏紝璇风◢鍚庡啀璇�");
+                        }
+                        //鍒ゆ柇瑕佺Щ搴撶殑妗舵槸鍚︽湁姝e湪鎵ц鐨勪换鍔�
+                        var taskInfo = Db.Queryable<LogTask>().First(w => w.IsDel == "0" && (w.Status == "0" || w.Status == "1") && w.PalletNo == palletInfoYi.PalletNo);
+                        if (taskInfo != null)
+                        {
+                            throw new Exception("瑕佺Щ搴撶殑妗舵湁姝e湪鎵ц鐨勪换鍔★紝璇风◢鍚庡啀璇�");
+                        }
+                        #region#缁欒绉诲簱鐨勬《鍒嗛厤鏂板偍浣�
+                        var locatInfoNew = new SysStorageLocat();
+                        //浼樺厛鍒嗛厤鍐呬晶鍌ㄤ綅
+                        var locatListNei = Db.Queryable<SysStorageLocat>().Where(w => w.IsDel == "0" && w.Status == "0" && !string.IsNullOrEmpty(w.AisleOne) && w.WareHouseNo == palletInfoYi.WareHouseNo && w.AreaNo == palletInfoYi.AreaNo).ToList();
+                        foreach (var item in locatListNei)
+                        {
+                            //鍒ゆ柇璇ュ唴渚у偍浣嶇殑澶栦晶鍌ㄤ綅鏄惁鏈夋《
+                            var detailWai = Db.Queryable<DataStockDetail>().First(w => w.IsDel == "0" && w.LocatNo == item.AisleOne);
+                            if (detailWai != null)
+                            {
+                                continue;
+                            }
+                            locatInfoNew = item;
+                            break;
+                        }
+                        if (locatInfoNew == null)
+                        {
+                            //娌℃湁鍐呬晶鍌ㄤ綅锛屽啀鏌ユ壘澶栦晶鍌ㄤ綅
+                            var locatListWai = Db.Queryable<SysStorageLocat>().Where(w => w.IsDel == "0" && w.Status == "0" && string.IsNullOrEmpty(w.AisleOne) && w.WareHouseNo == palletInfoYi.WareHouseNo && w.AreaNo == palletInfoYi.AreaNo).OrderBy(o => o.Row).ToList();
+                            foreach (var item in locatListWai)
+                            {
+                                //鍒ゆ柇璇ュ偍浣嶇殑鍐呬晶鍌ㄤ綅鏄惁鏈夋鍦ㄦ墽琛岀殑浠诲姟
+                                var locatItemNei = Db.Queryable<SysStorageLocat>().First(w => w.IsDel == "0" && w.AisleOne == item.LocatNo);
+                                if (locatItemNei != null && locatItemNei.Status != "0")
+                                {
+                                    continue;
+                                }
+                                locatInfoNew = item;
+                                break;
+                            }
+                        }
+                        if (locatInfoNew == null)
+                        {
+                            throw new Exception("娌℃湁绌轰綑鐨勭┖鍌ㄤ綅杩涜绉诲簱");
+                        }
+                        #endregion
+
+                        //缁欎笅杞︿笅鍙戠Щ搴撲换鍔�
+                        var taskNo = new Common().GetMaxNo("TK");//浠诲姟鍙�
+                        //浠诲姟淇℃伅
+                        var logTaskEntry = new LogTask
+                        {
+                            TaskNo = taskNo,
+                            Sender = "WMS",
+                            Receiver = "RCS",
+                            //IsSuccess = 1, //鏄惁涓嬪彂鎴愬姛 0澶辫触 1鎴愬姛
+                            SendDate = DateTime.Now,  //鍙戦�佹椂闂�
+                            //BackDate = DateTime.Now,  //杩斿洖鏃堕棿
+                            StartLocat = palletInfoYi.LocatNo,//璧峰浣嶇疆
+                            EndLocat = locatInfoNew.LocatNo,//鐩爣浣嶇疆
+                            PalletNo = palletInfoYi.PalletNo,//鎵樼洏鐮�
+                            IsSend = 1,//鏄惁鍙啀娆′笅鍙�
+                            IsCancel = 1,//鏄惁鍙彇娑�
+                            IsFinish = 1,//鏄惁鍙畬鎴�
+                            Type = "1",//浠诲姟绫诲瀷 0 鍏ュ簱浠诲姟 1 鍑哄簱浠诲姟  2 绉诲簱浠诲姟
+                            OrderType = "3",//鍗曟嵁绫诲瀷 0 鍏ュ簱 1 鍑哄簱 3绉诲簱
+                            Status = "0",//浠诲姟鐘舵��0锛氱瓑寰呮墽琛�1姝e湪鎵ц2鎵ц瀹屾垚
+                            NoticeDetailNo = 0,
+                            Msg = $"灏嗘《{palletInfoYi.PalletNo}浠巤palletInfoYi.LocatNo}绉诲埌{locatInfoNew.LocatNo}", //鍏抽敭淇℃伅
+                            LotNo = ""//鎵规鍙�
+                        };
+
+                        //缁勭粐涓嬪彂灏忚溅浠诲姟淇℃伅
+                        var task = new TaskDetial
+                        {
+                            Taskno = taskNo,//浠诲姟鍙�
+                            Startport = palletInfoYi.LocatNo,//璧峰浣嶇疆
+                            Endport = locatInfoNew.LocatNo,//endLoction.LocatNo,//鐩爣浣嶇疆
+                            Pallno = palletInfoYi.PalletNo,//妗跺彿
+                            Crtype = "1",//鍙《
+                            WareHouseNo = palletInfoYi.WareHouseNo//杞﹂棿缂栫爜
+                        };
+                        //缁欎笅杞︿笅鍙戜换鍔�
+                        logTaskEntry.SendDate = DateTime.Now;//鍙戦�佹椂闂�
+                        var agvResult = CreateTaskForAgv(task, url, "70");
+                        if (agvResult)//鎴愬姛
+                        {
+                            //璇锋眰鎴愬姛淇敼浠诲姟琛ㄧ浉搴斿瓧娈电姸鎬�
+                            logTaskEntry.IsSuccess = 1;
+                            logTaskEntry.IsSend = 0;
+                            //logTaskEntry.IsCancel = 0;
+                            logTaskEntry.BackDate = DateTime.Now;
+                            logTaskEntry.Status = "1";//姝e湪鎵ц
+                            Db.Insertable(logTaskEntry).ExecuteCommand();
+
+
+                            locatInfo.Status = "5";//绉诲嚭涓�
+                            Db.Updateable(locatInfo).ExecuteCommand();
+
+                            locatInfoNew.Status = "4";//绉诲叆涓�
+                            Db.Updateable(locatInfoNew).ExecuteCommand();
+                        }
+                        else//澶辫触
+                        {
+                            throw new Exception($"缁欏皬杞︿笅鍙戠Щ搴撲换鍔″け璐ワ紝妗跺彿锛歿palletInfoYi.PalletNo}");
+                        }
+                    }
+                }
+                return true;
+            }
+            catch (Exception e)
+            {
+                throw new Exception(e.Message);
+            }
+        }
     }
 }

--
Gitblit v1.8.0