From 8a83e6f21af0a764950e45b2565a370fff74daa5 Mon Sep 17 00:00:00 2001
From: chengsc <11752@DESKTOP-DS49RCP>
Date: 星期四, 08 五月 2025 16:47:45 +0800
Subject: [PATCH] Merge branch 'csc'

---
 Wms/WMS.BLL/HttpServer.cs |  424 ++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 423 insertions(+), 1 deletions(-)

diff --git a/Wms/WMS.BLL/HttpServer.cs b/Wms/WMS.BLL/HttpServer.cs
index 210df4f..1fee251 100644
--- a/Wms/WMS.BLL/HttpServer.cs
+++ b/Wms/WMS.BLL/HttpServer.cs
@@ -1,8 +1,14 @@
-锘縰sing SqlSugar;
+锘縰sing Model.InterFaceModel;
+using SqlSugar;
 using System;
 using System.Collections.Generic;
+using System.Linq;
 using System.Text;
+using WMS.BLL.Logic;
 using WMS.BLL.LogServer;
+using WMS.DAL;
+using WMS.Entity.BllAsnEntity;
+using WMS.Entity.BllSoEntity;
 using WMS.Entity.Context;
 using WMS.Entity.DataEntity;
 using WMS.Entity.LogEntity;
@@ -16,6 +22,338 @@
         private static readonly SqlSugarScope Db = DataContext.Db;
         public HttpServer() { }
 
+        /// <summary>
+        /// 鐢宠鍌ㄤ綅  锛堢珛浣撳簱锛�
+        /// </summary>
+        /// <param name="palletNo"></param>
+        /// <param name="houseNo"></param>
+        /// <param name="roadwayNo"></param>
+        /// <returns></returns>
+        /// <exception cref="Exception"></exception>
+        public OutCommandDto RequestLocation(string palletNo, string houseNo)
+        {
+            try
+            {
+                //楠岃瘉鎵樼洏鏉$爜鏄惁涓虹┖
+                if (string.IsNullOrEmpty(palletNo))
+                {
+                    throw new Exception("璇疯緭鍏ヨ鐢宠鐨勬墭鐩樻潯鐮�");
+                }
+                //楠岃瘉鎵�灞炰粨搴撴槸鍚︿负绌�
+                if (string.IsNullOrEmpty(houseNo))
+                {
+                    throw new Exception("璇烽�夋嫨鎵�灞炰粨搴�");
+                }
+                //楠岃瘉鏄惁涓哄钩搴撳叆搴�
+                var houseType = Db.Queryable<SysWareHouse>().First(a => a.WareHouseNo == houseNo);//鑾峰彇浠撳簱绫诲瀷
+                //楠岃瘉鏄惁涓虹珛浣撳簱鍏ュ簱
+                if (houseType.Type != "1")
+                {
+                    throw new Exception("浠撳簱绫诲瀷閿欒锛岃閫夋嫨绔嬩綋搴撲粨搴�");
+                }
+
+                OutCommandDto comDto;//杩斿洖wcs鐨勫叆搴撳懡浠�
+
+                var stock = Db.Queryable<SysPallets>().First(a => a.PalletNo == palletNo);//鎵樼洏淇℃伅
+
+                //鍒ゆ柇鎵樼洏鏉$爜鏄惁鏈夋晥
+                if (stock == null)
+                    throw new Exception("鎵樼洏鏉$爜涓嶅彈WMS绠$悊锛屼笉鍙叆搴擄紒");
+
+                #region 
+                var upShelfOld = Db.Queryable<BllPalletUpShelf>().First(m => m.IsDel == "0" && m.PalletNo == palletNo && (m.Status == "0" || m.Status == "1"));
+                
+                var skuList = Db.Queryable<SysMaterials>().Where(m => m.IsDel == "0").ToList();
+                //鐗╂枡绫诲埆淇℃伅
+                var skuCategoryList = Db.Queryable<SysMaterialCategory>().Where(m => m.IsDel == "0").ToList();
+
+                var skuNo = ""; //鍏ュ簱鐗╂枡 
+                var starLocate = ""; // 璧峰鍌ㄤ綅
+                var stockDetail = Db.Queryable<DataStockDetail>().Where(m => m.PalletNo == palletNo).ToList();
+                //楠岃瘉鐗╂枡鏄惁鏈夋垚鍝�
+                foreach (var item in stockDetail)
+                {
+                    var skuItem = skuList.First(m => m.SkuNo == item.SkuNo);
+                    if (skuItem.Type == "2")
+                    {
+                        throw new Exception("鎴愬搧鐗╂枡璇峰叆鎴愬搧搴�");
+                    }
+                }
+                if (upShelfOld != null) //鏌ヨ鍒板叆搴撲俊鎭�
+                {
+                    var beingTask = Db.Queryable<LogTask>().First(m => m.IsDel == "0" && m.TaskNo == upShelfOld.TaskNo);
+                    if (beingTask == null)
+                    {
+                        throw new Exception("璇ユ墭鐩樻鍦ㄥ叆搴擄紝浣嗘湭鏌ヨ鍒颁换鍔′俊鎭�");
+                    }
+                    if (!string.IsNullOrWhiteSpace(beingTask.EndLocat))
+                    {
+                        comDto = new OutCommandDto()
+                        {
+                            PalletNo = palletNo,//鎵樼洏鍙�
+                            StartRoadway = beingTask.StartRoadway, // 璧峰宸烽亾
+                            StartLocate = beingTask.StartLocat, // 璧峰浣嶇疆
+                            EndLocate = beingTask.EndLocat, // 鐩爣浣嶇疆
+                            EndRoadway = beingTask.EndRoadway,                           //  鐩爣宸烽亾
+                            TaskNo = beingTask.TaskNo, // 浠诲姟鍙�
+                            TaskType = "0",// 浠诲姟绫诲瀷 (鍑哄簱)
+                            OutMode = "",  //鐩爣鍦板潃
+                            Order = 1
+                        };
+                        if (beingTask.IsSuccess == 0)
+                        {
+                            beingTask.IsSuccess = 1;
+                        }
+                        beingTask.Status = "1";
+                        Db.Updateable(beingTask).ExecuteCommand();
+                        if (upShelfOld.Status == "0")
+                        {
+                            upShelfOld.Status = "1";
+                            Db.Updateable(upShelfOld).ExecuteCommand();
+                        }
+                        return comDto;
+                    }
+                    else
+                    {
+                        throw new Exception("鏌ヨ鍒颁换鍔′絾鐩殑鍌ㄤ綅涓虹┖");
+                    }
+                }
+                else //鐢宠鍏ュ簱
+                {
+                    if (stockDetail.Count == 0)
+                    {
+                        throw new Exception($"{palletNo}鎵樼洏鏉$爜涓嶅叿鏈夌鐮佷俊鎭紝涓嶅彲鍏ュ簱锛�");
+                    }
+                    if (stockDetail.Count(m => !string.IsNullOrWhiteSpace(m.LocatNo)) == 0)
+                    {
+                        throw new Exception("褰撳墠鎵樼洏娌℃湁鍦ㄥ钩搴撳偍浣嶄笂锛岃鏍稿疄");
+                    }
+                    starLocate = stockDetail.First().LocatNo;
+
+                    var pingAreaStr = Db.Queryable<SysStorageArea>().Where(m => m.IsDel == "0" && m.WareHouseNo == "W04" && m.AreaNo != "B06" && m.AreaNo != "B07").Select(m => m.AreaNo).ToList();
+                    var pingLocateInfo = Db.Queryable<SysStorageLocat>().First(m => m.LocatNo == starLocate && pingAreaStr.Contains(m.AreaNo) && m.IsDel == "0");
+                    if (pingLocateInfo == null)
+                    {
+                        throw new Exception("褰撳墠鎵樼洏鎵�鍦ㄧ殑鍌ㄤ綅娌℃湁鍦ㄧ郴缁熶腑鎵惧埌淇℃伅");
+                    }
+                    if (pingLocateInfo.Status != "1")
+                    {
+                        throw new Exception("褰撳墠鎵樼洏鎵�鍦ㄧ殑鍌ㄤ綅鐘舵�侀敊璇紝涓嶆槸绌哄偍浣�");
+                    }
+                    skuNo = stockDetail.First().SkuNo;
+
+                    var beingTask = Db.Queryable<LogTask>().First(m => m.IsDel == "0"
+                    && (m.Status == "0" || m.Status == "1") && m.PalletNo == palletNo && m.Type == "0");
+                    if (beingTask != null)
+                    {
+                        if (!string.IsNullOrWhiteSpace(beingTask.EndLocat))
+                        {
+                            comDto = new OutCommandDto()
+                            {
+                                PalletNo = palletNo,//鎵樼洏鍙�
+                                StartRoadway = beingTask.StartRoadway, // 璧峰宸烽亾
+                                StartLocate = beingTask.StartLocat, // 璧峰浣嶇疆
+                                EndLocate = beingTask.EndLocat, // 鐩爣浣嶇疆
+                                EndRoadway = beingTask.EndRoadway,                           //  鐩爣宸烽亾
+                                TaskNo = beingTask.TaskNo, // 浠诲姟鍙�
+                                TaskType = "0",// 浠诲姟绫诲瀷 (鍑哄簱)
+                                OutMode = "",  //鐩爣鍦板潃
+                                Order = 1,
+                                Type = PLCTypeEnum.AGV
+                            };
+                            if (beingTask.IsSuccess == 0)
+                            {
+                                beingTask.IsSuccess = 1;
+                               
+                            }
+                            beingTask.Status = "1";
+                            Db.Updateable(beingTask).ExecuteCommand();
+                            return comDto;
+                        }
+                        else
+                        {
+                            throw new Exception("鏌ヨ鍒颁换鍔′絾鐩殑鍌ㄤ綅涓虹┖");
+                        }
+                    }
+
+                    //鑾峰彇瀵瑰簲鍥炲簱瑙勫垯
+                    var function = Db.Queryable<SysFunSetting>().First(a => a.IsDel == "0" && a.FunSetName == "鎵樼洏鍥炲簱楠岃瘉" && a.IsEnable == "NO");
+                    #region 鎵樼洏鍥炲簱瑙勫垯
+
+                    if (function != null)
+                    {
+                        //鎷h揣瀹屾垚鍚庡厑璁告墭鐩樺洖搴�
+                        if (function.SetValue == "CompletePick")
+                        {
+                            var allot = Db.Queryable<BllExportAllot>().First(a => a.IsDel == "0" && a.LotNo == stockDetail[0].LotNo && a.PalletNo == palletNo && a.SkuNo == stockDetail[0].SkuNo);
+
+                            //楠岃瘉鎷h揣鏄庣粏鏄惁瀛樺湪
+                            if (allot != null)
+                            {
+                                //楠岃瘉褰撳墠鎵樼洏鎷h揣淇℃伅鏄惁宸插畬鎴�
+                                if (allot.Status != "5")
+                                {
+                                    throw new Exception("褰撳墠鎵樼洏鎷h揣淇℃伅鏈畬鎴愶紝璇峰畬鎴愬悗鍥炲簱锛�");
+                                }
+                            }
+                        }
+                    }
+                    #endregion
+                }
+
+                var allotLocate = new AllotLocation();
+
+                #region 鐢宠鍌ㄤ綅
+
+                SysStorageLocat locate;
+                                var sku = skuList.FirstOrDefault(m => m.SkuNo == skuNo);
+                if (sku == null)
+                {
+                    throw new Exception("鐗╂枡淇℃伅涓湭鏌ヨ鍒板叆搴撳崟鏄庣粏鍖呭惈鐨勭墿鏂欎俊鎭紝涓嶅彲鍏ュ簱");
+                }
+                //鍒ゆ柇鐗╂枡鏄惁鍚湁绫诲埆淇℃伅
+                if (string.IsNullOrWhiteSpace(sku.CategoryNo))
+                {
+                    throw new Exception($"鐗╂枡锛歿sku.SkuNo}鏈煡璇㈠埌绫诲埆淇℃伅");
+                }
+
+                var skuCategory = skuCategoryList.FirstOrDefault(m => m.CategoryNo == sku.CategoryNo);
+                if (skuCategory == null)
+                {
+                    throw new Exception($"鏈湪绫诲埆淇℃伅涓煡璇㈠埌鐗╂枡锛歿sku.SkuNo}鍖呭惈鐨勭被鍒�");
+                }
+
+                var areaStr = skuCategory.AreaNo.Split(",");
+                var areaList = new List<string>();
+                foreach (var item in areaStr)
+                {
+                    areaList.Add(item);
+                }
+
+                locate = allotLocate.GetSuiTableLocate(houseNo, areaList, "");
+                
+
+                #endregion
+
+                Db.BeginTran();
+                try
+                {
+
+                    
+                    //娣诲姞宸烽亾浣跨敤璁板綍
+                    var log = new SysRoadwayUseLog
+                    {
+                        RoadwayNo = locate.RoadwayNo,
+                        WareHouseNo = houseNo,
+                        Row = 0,
+                        Column = 0,
+                        Layer = 0,
+                    };
+                    Db.Insertable(log).ExecuteCommand();
+                    var taskNo = new Common().GetMaxNo("TK");
+                    var exTask = new LogTask    //鍏ュ簱浠诲姟
+                    {
+                        TaskNo = taskNo,
+                        Sender = "WMS",
+                        Receiver = "WCS",
+                        IsSuccess = 1, //鏄惁涓嬪彂鎴愬姛 0澶辫触 1鎴愬姛
+                        SendDate = DateTime.Now,  //鍙戦�佹椂闂�
+                        BackDate = DateTime.Now,  //杩斿洖鏃堕棿
+                        StartRoadway = "",            // 璧峰宸烽亾
+                        StartLocat = starLocate,//璧峰浣嶇疆
+                        EndLocat = locate.LocatNo,//鐩爣浣嶇疆
+                        EndRoadway = locate.RoadwayNo,  // 鐩爣宸烽亾
+                        PalletNo = palletNo,//鎵樼洏鐮�
+                        IsSend = 1,//鏄惁鍙啀娆′笅鍙�
+                        IsCancel = 1,//鏄惁鍙彇娑�
+                        IsFinish = 1,//鏄惁鍙畬鎴�
+                        Type = "0",//浠诲姟绫诲瀷 0 鍏ュ簱浠诲姟 1 鍑哄簱浠诲姟  2 绉诲簱浠诲姟
+                        Status = "1",//浠诲姟鐘舵��0锛氱瓑寰呮墽琛�1姝e湪鎵ц2鎵ц瀹屾垚
+                        OrderType = "0",//0 鍏ュ簱鍗� 1 鍑哄簱鍗�  2 鐩樼偣鍗�  3 绉诲簱鍗�
+                        Msg = "鍏ュ簱鍙e埌=>>" + locate.LocatNo + "鐨勫叆搴撲换鍔�", //鍏抽敭淇℃伅
+
+                    };
+                    Db.Insertable(exTask).ExecuteCommand();
+                    var asnNo = "";
+                    // 娣诲姞鎵樼洏缁戝畾琛ㄦ墭鐩樺叆搴撲换鍔″彿 liudl
+                    foreach (DataStockDetail stockModel in stockDetail)
+                    {
+                        var bindModel = Db.Queryable<BllPalletBind>().First(m => m.IsDel == "0" && m.Status == "2"
+                        && m.PalletNo == stockModel.PalletNo && m.ASNNo == stockModel.ASNNo && m.ASNDetailNo == stockModel.ASNDetailNo);
+                        if (bindModel != null && string.IsNullOrWhiteSpace(bindModel.TaskNo))
+                        {
+                            bindModel.TaskNo = taskNo;
+                            bindModel.WareHouseNo = locate.WareHouseNo;
+                            bindModel.RoadwayNo = locate.RoadwayNo;
+                            bindModel.LocatNo = locate.LocatNo;
+                            Db.Updateable(bindModel).ExecuteCommand();
+                            asnNo = stockModel.ASNNo;
+                        }
+                    }
+                    foreach (DataStockDetail stockModel in stockDetail)
+                    {
+                        //娣诲姞鎵樼洏涓婃灦璁板綍
+                        var upShelf = new BllPalletUpShelf()
+                        {
+                            TaskNo = exTask.TaskNo,
+                            TraceNo = asnNo,
+                            PalletNo = palletNo,
+                            SkuNo = stockModel.SkuNo,
+                            SkuName = stockModel.SkuName,
+                            LotNo = stockModel.LotNo,
+                            Status = "1",
+
+                            WareHouseNo = houseNo,
+                            RoadwayNo = locate.RoadwayNo,
+                            AreaNo = locate.AreaNo,
+                            LocatNo = locate.LocatNo,
+
+                            CreateUser = 0,
+                        };
+                        Db.Insertable(upShelf).ExecuteCommand();
+                    }
+                     
+                    
+                    locate.Status = "2";
+                    Db.Updateable(locate).ExecuteCommand();
+                     
+                    Db.CommitTran();
+                    comDto = new OutCommandDto()
+                    {
+                        PalletNo = palletNo,//鎵樼洏鍙�
+                        StartRoadway = "",
+                        StartLocate = starLocate, // 璧峰浣嶇疆
+                        EndLocate = locate.LocatNo, // 鐩爣浣嶇疆 
+                        EndRoadway = locate.RoadwayNo,   // 鐩爣宸烽亾
+                        TaskNo = taskNo, // 浠诲姟鍙�
+                        TaskType = "0",// 浠诲姟绫诲瀷 (鍑哄簱)
+                        OutMode = "",  //鐩爣鍦板潃
+                        Order = 1,
+                        Type = PLCTypeEnum.AGV
+                    };
+
+                }
+                catch (Exception ex)
+                {
+                    Db.RollbackTran();
+                    throw new Exception(ex.Message);
+                }
+                #endregion
+
+
+                return comDto;
+            }
+            catch (Exception e)
+            {
+                throw new Exception(e.Message);
+            }
+        }
+
+        /// <summary>
+        /// agv璧板嚭鍌ㄤ綅淇敼鍌ㄤ綅淇℃伅锛屼粎闄愬钩搴撳偍浣�
+        /// </summary>
+        /// <param name="taskNo"></param>
+        /// <param name="userId"></param>
         public void UpLocateByAgvOut(string taskNo, int userId)
         {
             try
@@ -55,5 +393,89 @@
                 throw new Exception(e.Message);
             }
         }
+
+        /// <summary>
+        /// 鍏ュ簱浠诲姟瀹屾垚JC34
+        /// </summary>
+        /// <param name="taskNo"></param>
+        /// <param name="userId"></param>
+        /// <exception cref="Exception"></exception>
+        public void ArrivalSuccess2(string taskNo, int userId)
+        {
+            try
+            {
+                //姝e父鍏ュ簱 
+                var task = Db.Queryable<LogTask>().First(m => m.IsDel == "0" && m.TaskNo == taskNo);
+                if (task == null)
+                {
+                    throw new Exception("鏈煡璇㈠埌浠诲姟淇℃伅");
+                }
+                if (task.Status == "2")
+                {
+                    throw new Exception("褰撳墠浠诲姟宸插畬鎴�");
+                }
+
+                var stockDetail = Db.Queryable<DataStockDetail>().Where(m => m.PalletNo == task.PalletNo).ToList();
+                var upShelf = Db.Queryable<BllPalletUpShelf>().First(m => m.TaskNo == taskNo);
+                if (upShelf == null)
+                {
+                    throw new Exception("娌℃湁鎵惧埌鎵樼洏涓婃灦淇℃伅");
+                }
+                //褰撳墠浠诲姟涓殑鍌ㄤ綅淇℃伅
+                var locate = Db.Queryable<SysStorageLocat>().First(m => m.LocatNo == task.EndLocat);
+                if (locate == null)
+                {
+                    throw new Exception($"鏈煡璇㈠埌浠诲姟涓殑鍌ㄤ綅淇℃伅");
+                }
+                Db.BeginTran();
+
+                task.Status = "2";//浠诲姟鐘舵��
+                task.IsSend = 0;
+                task.IsCancel = 0;
+                task.IsFinish = 0;
+                task.FinishDate = DateTime.Now;//瀹屾垚鏃堕棿
+                Db.Updateable(task).ExecuteCommand();
+                if (userId != 0)
+                {
+                    //娣诲姞鎿嶄綔鏃ュ織璁板綍
+                    var k = new OperationASNServer().AddLogOperationAsn("鍏ュ簱浣滀笟", "鍏ュ簱鏃ュ織", taskNo, "瀹屾垚", $"鐐瑰嚮瀹屾垚鎸夐挳銆佸畬鎴愪换鍔″彿涓猴細{taskNo}鐨勪换鍔�", userId);
+                }
+
+                //鍒ゆ柇鏄惁鏄洖娴佸叆搴撳畬鎴�
+                if (stockDetail.Any())
+                {
+                    throw new Exception("娌℃湁鏌ヨ鍒板簱瀛樹俊鎭�");
+                }
+
+                foreach (var item in stockDetail)
+                {
+                    item.WareHouseNo = locate.WareHouseNo;
+                    item.RoadwayNo = locate.RoadwayNo;
+                    item.AreaNo = locate.AreaNo;
+                    item.LocatNo = locate.LocatNo;
+                    item.UpdateTime = DateTime.Now;
+                    if (userId != 0)
+                    {
+                        item.UpdateUser = userId;
+                    }
+                }
+                upShelf.Status = "2";
+                Db.Updateable(upShelf).ExecuteCommand();
+
+                locate.Status = "1";
+                Db.Updateable(locate).ExecuteCommand();
+                Db.Updateable(stockDetail).ExecuteCommand();
+                Db.CommitTran();
+
+            }
+            catch (Exception e)
+            {
+                throw new Exception(e.Message);
+            }
+        }
+
+
+
+
     }
 }

--
Gitblit v1.8.0