From f147cfa91feec613eb304c78fecafdf43286034a Mon Sep 17 00:00:00 2001
From: Administrator <Administrator@DESKTOP-5BIMHQ3>
Date: 星期六, 30 三月 2024 11:12:24 +0800
Subject: [PATCH] Merge branch 'wxw'

---
 Wms/WMS.BLL/BllCheckServer/StockCheckServer.cs |  173 +++++++++++++++++++++++++++++++++++++++++++++++++++++++--
 1 files changed, 166 insertions(+), 7 deletions(-)

diff --git a/Wms/WMS.BLL/BllCheckServer/StockCheckServer.cs b/Wms/WMS.BLL/BllCheckServer/StockCheckServer.cs
index d65b27e..3e4ae44 100644
--- a/Wms/WMS.BLL/BllCheckServer/StockCheckServer.cs
+++ b/Wms/WMS.BLL/BllCheckServer/StockCheckServer.cs
@@ -200,7 +200,7 @@
                     LotNo = m.LotNo,
                     LotText = m.LotText,
                     SupplierLot = m.SupplierLot,
-                    Qty = (int)m.Qty,
+                    Qty = (decimal)m.Qty,
 
                     PalletNo = m.PalletNo
                 }).ToList();
@@ -641,7 +641,7 @@
                                     BoxNo2 = l.BoxNo2,
                                     BoxNo3 = l.BoxNo3,
                                     PalletNo = l.PalletNo,
-                                    Qty = (int)l.RealQty,
+                                    Qty = (decimal)l.RealQty,
                                     FullQty = stockBoxInfo.FullQty,//婊$鏁伴噺
                                     Status = "2",
                                     SkuNo = l.SkuNo,
@@ -658,12 +658,12 @@
                                 };
                                 Db.Insertable<DataBoxInfo>(databox).ExecuteCommand();
                                 //搴撳瓨鏄庣粏澧炲姞鏁伴噺
-                                stockDetailInfo.Qty += (int)l.RealQty;
+                                stockDetailInfo.Qty += l.RealQty;
                             }
                             else
                             {
                                 //搴撳瓨鏄庣粏澧炲姞鏁伴噺
-                                stockDetailInfo.Qty = (int)l.RealQty;
+                                stockDetailInfo.Qty = l.RealQty;
                             }
                             stockDetailInfo.Status = "0";
 
@@ -676,11 +676,11 @@
                             }
                             if (sku.Type != "4")
                             {
-                                de.Qty += (int)l.RealQty;
+                                de.Qty += (decimal)l.RealQty;
                             }
                             else
                             {
-                                de.Qty += (int)(l.RealQty - l.Qty);
+                                de.Qty += (decimal)(l.RealQty - l.Qty);
                             }
 
                             Db.Updateable(de).ExecuteCommand();
@@ -1294,6 +1294,97 @@
             }
         }
 
+        //AGV绉诲簱瀹屾垚
+        public void MoveSuccess(string taskNo, int userId)
+        {
+            try
+            {
+                //褰撳墠浠诲姟淇℃伅
+                var task = Db.Queryable<LogTask>().First(m => m.TaskNo == taskNo && m.IsDel == "0");
+                if (task == null)
+                {
+                    throw new Exception($"鏈煡璇㈠埌浠诲姟鍙蜂负锛氣�榹taskNo}鈥欑殑浠诲姟淇℃伅");
+                }
+                if (task.Status == "2")
+                {
+                    throw new Exception("褰撳墠浠诲姟宸插畬鎴�");
+                }
+                Db.BeginTran();
+                //搴撳瓨涓綋鍓嶆墭鐩樼殑淇℃伅
+                var stockDetail = Db.Queryable<DataStockDetail>().Where(m => m.PalletNo == task.PalletNo).ToList();
+                var locateNo = stockDetail.Select(m => m.LocatNo).Distinct().FirstOrDefault();
+               
+                //褰撳墠浠诲姟涓殑鍌ㄤ綅淇℃伅
+                var locate = Db.Queryable<SysStorageLocat>().First(m => m.LocatNo == locateNo);
+
+                //鏇存敼浠诲姟
+                task.Status = "2";//浠诲姟鐘舵��
+                task.IsSend = 0;
+                task.IsCancel = 0;
+                task.IsFinish = 0;
+                task.FinishDate = DateTime.Now;//瀹屾垚鏃堕棿
+                Db.Updateable(task).ExecuteCommand();
+                // 鏇存敼褰撳墠浠诲姟涓殑鍌ㄤ綅鐘舵�侊紙鏀逛负0绌哄偍浣嶏級
+                locate.Status = "0"; 
+                Db.Updateable(locate).ExecuteCommand();
+
+                //鐩爣鍌ㄤ綅淇℃伅
+                var endLocate = Db.Queryable<SysStorageLocat>().First(m => m.LocatNo == task.EndLocat);
+                if (endLocate != null)
+                {
+                    if (endLocate.Status != "0")
+                    {
+                        throw new Exception("鐩爣鍌ㄤ綅鐘舵�侀潪绌哄偍浣�");
+                    }
+                }
+                //鏇存敼搴撳瓨鏄庣粏
+                foreach (var item in stockDetail)
+                {
+                    item.Status = "0";//寰呭垎閰�
+                    item.LockQty = 0;//閿佸畾鏁伴噺鏀逛负0
+                    if (endLocate != null)//鏈夌洰鏍囧偍浣嶈鏄庣Щ鍒板叾浠栧尯鍩熷偍浣�
+                    {
+                        item.LocatNo = endLocate.LocatNo;//鍌ㄤ綅鏇存敼
+                        item.WareHouseNo = endLocate.WareHouseNo;//鎵�灞炰粨搴撴洿鏀�
+                        item.RoadwayNo = endLocate.RoadwayNo;//鎵�灞炲贩閬撴洿鏀�
+                        item.AreaNo = endLocate.AreaNo;//鎵�灞炲尯鍩熸洿鏀�
+                    }
+                    else//娌℃湁鐩爣鍌ㄤ綅璇存槑绉诲埌鍏ュ簱鍙�
+                    {
+                        item.LocatNo = "";//鍌ㄤ綅鏇存敼锛堟敼涓虹┖锛�
+                        item.WareHouseNo = "";//鎵�灞炰粨搴撴洿鏀癸紙鏀逛负绌猴級
+                        item.RoadwayNo = "";//鎵�灞炲贩閬撴洿鏀癸紙鏀逛负绌猴級
+                        item.AreaNo = "";//鎵�灞炲尯鍩熸洿鏀癸紙鏀逛负绌猴級
+                    }                   
+                    Db.Updateable(item).ExecuteCommand();
+
+                    //鏇存敼搴撳瓨鎬昏〃
+                    var stock = Db.Queryable<DataStock>().First(w => w.IsDel == "0" && w.SkuNo == item.SkuNo && w.LotNo == item.LotNo);
+                    stock.LockQty -= (decimal)item.Qty;
+                    Db.Updateable(stock).ExecuteCommand();
+                }
+                if (endLocate != null)
+                {
+                    //鏇存敼鐩爣鍌ㄤ綅鐘舵��
+                    endLocate.Status = "1";//鏈夌墿鍝�
+                    Db.Updateable(endLocate).ExecuteCommand();
+                }
+
+                if (userId != 0)
+                {
+                    //娣诲姞鎿嶄綔鏃ュ織璁板綍
+                    var k = new OperationCrServer().AddLogOperationCr("搴撳唴浣滀笟", "搴撳唴鏃ュ織", taskNo, "瀹屾垚", $"鐐瑰嚮瀹屾垚鎸夐挳銆佸畬鎴愪换鍔″彿涓猴細{taskNo}鐨勪换鍔�", userId);
+                }
+                Db.CommitTran();
+
+            }
+            catch (Exception ex)
+            {
+                Db.RollbackTran();
+                throw new Exception("瀹屾垚鍙嶉澶辫触锛�" + ex.Message);
+            }
+        }
+
         //閲嶆柊涓嬪彂鐩樼偣鍑哄簱浠诲姟
         public OutCommandDto AgainSendCheckTask(string taskNo, int userId, string url)
         {
@@ -1417,7 +1508,7 @@
                     checkLog.IsDel = "1";
                     Db.Updateable(checkLog).ExecuteCommand();
                     //淇敼鍌ㄤ綅淇℃伅
-                    var locat = Db.Queryable<SysStorageLocat>().First(a => a.IsDel == "0" && a.WareHouseNo == "W01" && a.LocatNo == task.StartLocat);
+                    var locat = Db.Queryable<SysStorageLocat>().First(a => a.IsDel == "0" && a.WareHouseNo == "W02" && a.LocatNo == task.StartLocat);
                     if (locat == null)
                     {
                         throw new Exception("鏈煡璇㈠埌鍌ㄤ綅淇℃伅锛岃鏍稿疄锛�");
@@ -1441,6 +1532,74 @@
             }
         }
 
+        //鍙栨秷AGV绉诲簱浠诲姟
+        public void CancelMoveTask(string taskNo, int userId)
+        {
+            try
+            {
+                Db.BeginTran();
+
+                var task = Db.Queryable<LogTask>().First(m => m.TaskNo == taskNo && m.IsDel == "0");
+                if (task == null)
+                {
+                    throw new Exception("鏈煡璇㈠埌浠诲姟淇℃伅");
+                }
+                //淇敼浠诲姟 
+                task.IsSuccess = 0;
+                task.IsSend = 0;
+                task.IsCancel = 0;
+                task.IsFinish = 0;
+                task.Status = "4";
+                task.CancelDate = DateTime.Now;
+                Db.Updateable(task).ExecuteCommand();
+
+                //淇敼璧峰鍌ㄤ綅淇℃伅
+                var locat = Db.Queryable<SysStorageLocat>().First(a => a.IsDel == "0" && a.WareHouseNo == "W02" && a.LocatNo == task.StartLocat);
+                if (locat == null)
+                {
+                    throw new Exception("鏈煡璇㈠埌鍌ㄤ綅淇℃伅锛岃鏍稿疄锛�");
+                }
+                locat.Status = "1"; //鏈夌墿鍝�
+                Db.Updateable(locat).ExecuteCommand();
+
+                //淇敼鐩爣鍌ㄤ綅淇℃伅
+                var locatEnd = Db.Queryable<SysStorageLocat>().First(a => a.IsDel == "0" && a.WareHouseNo == "W02" && a.LocatNo == task.EndLocat);
+                if (locatEnd != null)
+                {
+                    locatEnd.Status = "0"; //绌哄偍浣�
+                    Db.Updateable(locatEnd).ExecuteCommand();
+                }                
+
+                //淇敼搴撳瓨鏄庣粏
+                var stockDetail = Db.Queryable<DataStockDetail>().First(w => w.IsDel == "0" && w.PalletNo == task.PalletNo);
+                if (stockDetail == null)
+                {
+                    throw new Exception("鎵樼洏涓婄墿鏂欏簱瀛樻槑缁嗕俊鎭笉瀛樺湪,璇锋鏌�!");
+                }
+                stockDetail.Status = "0";//寰呭垎閰�
+                stockDetail.LockQty = 0;//閿佸畾鏁伴噺
+                Db.Updateable(stockDetail).ExecuteCommand();
+
+                //淇敼搴撳瓨
+                var stock = Db.Queryable<DataStock>().First(w => w.IsDel == "0" && w.SkuNo == stockDetail.SkuNo && w.LotNo == stockDetail.LotNo);
+                if (stock == null)
+                {
+                    throw new Exception("鎵樼洏涓婄墿鏂欏簱瀛樹俊鎭笉瀛樺湪,璇锋鏌�!");
+                }
+                stock.LockQty -= (decimal)stockDetail.Qty;
+                Db.Updateable(stock).ExecuteCommand();
+
+                //娣诲姞鎿嶄綔鏃ュ織璁板綍
+                var k = new OperationCrServer().AddLogOperationCr("搴撳唴浣滀笟", "搴撳唴鏃ュ織", taskNo, "鍙栨秷", $"鐐瑰嚮鍙栨秷鎸夐挳銆佸彇娑堜簡浠诲姟鍙蜂负锛歿taskNo}鐨勪换鍔�", userId);
+                Db.CommitTran();
+            }
+            catch (Exception e)
+            {
+                Db.RollbackTran();
+                throw new Exception(e.Message);
+            }
+        }
+
         #region 涓婃父绯荤粺鎺ュ彛
 
         //鐩樼偣缁撴灉杩斿洖erp

--
Gitblit v1.8.0