From c020f31a67fc5aa5644511bddff075f7ecc85234 Mon Sep 17 00:00:00 2001 From: qinchulong <qinchulong@hnkhzn.com> Date: 星期二, 27 五月 2025 15:35:27 +0800 Subject: [PATCH] Merge branch 'master' of http://115.159.85.185:8098/r/HuaYiZhongHeng/ZhongHeLiTiKu --- 代码管理/WMS/WIDESEA_WMSServer/WIDESEA_TaskInfoService/PartialTaskService_Outbound.cs | 526 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 526 insertions(+), 0 deletions(-) diff --git "a/\344\273\243\347\240\201\347\256\241\347\220\206/WMS/WIDESEA_WMSServer/WIDESEA_TaskInfoService/PartialTaskService_Outbound.cs" "b/\344\273\243\347\240\201\347\256\241\347\220\206/WMS/WIDESEA_WMSServer/WIDESEA_TaskInfoService/PartialTaskService_Outbound.cs" new file mode 100644 index 0000000..33d19d7 --- /dev/null +++ "b/\344\273\243\347\240\201\347\256\241\347\220\206/WMS/WIDESEA_WMSServer/WIDESEA_TaskInfoService/PartialTaskService_Outbound.cs" @@ -0,0 +1,526 @@ +锘縰sing System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; +using WIDESEA_Core.Enums; +using WIDESEA_Core; +using WIDESEA_DTO.Stock; +using WIDESEA_Model.Models; +using WIDESEA_Core.Helper; +using Microsoft.AspNetCore.Http; +using System.Reflection.Metadata; +using OfficeOpenXml.FormulaParsing.Excel.Functions.RefAndLookup; +using SkiaSharp; +using System.Collections; +using Newtonsoft.Json; +using WIDESEA_Core.Log; + +namespace WIDESEA_TaskInfoService +{ + public partial class TaskService + { + + /// <summary> + /// 搴撳瓨鏁版嵁杞嚭搴撲换鍔� + /// </summary> + /// <param name="stockInfos"></param> + /// <returns></returns> + public List<Dt_Task> GetTasks(List<Dt_StockInfo> stockInfos) + { + List<Dt_Task> tasks = new List<Dt_Task>(); + for (int i = 0; i < stockInfos.Count; i++) + { + Dt_StockInfo stockInfo = stockInfos[i]; + + if (stockInfo != null) + { + Dt_LocationInfo locationInfo = _basicService.LocationInfoService.Repository.QueryFirst(x => x.LocationCode == stockInfo.LocationCode); + Dt_RoadwayInfo roadwayInfo = _basicService.RoadwayInfoService.Repository.QueryFirst(x => x.RoadwayNo == locationInfo.RoadwayNo); + if (roadwayInfo != null) + { + Dt_Task task = new() + { + CurrentAddress = stockInfo.LocationCode, + Grade = 3, + PalletCode = stockInfo.PalletCode, + NextAddress = roadwayInfo.OutStationCode, + Roadway = locationInfo.RoadwayNo, + SourceAddress = stockInfo.LocationCode, + TargetAddress = roadwayInfo.OutStationCode, + TaskStatus = OutTaskStatusEnum.OutNew.ObjToInt(), + TaskType = TaskTypeEnum.Outbound.ObjToInt(), + Depth = locationInfo.Depth, + TaskNum = BaseDal.GetTaskNum(nameof(SequenceEnum.SeqTaskNum)) + }; + tasks.Add(task); + } + } + } + return tasks; + } + + /// <summary> + /// 鍑哄簱浠诲姟鏁版嵁澶勭悊 + /// </summary> + /// <param name="orderDetailId"></param> + /// <param name="stockSelectViews"></param> + /// <returns></returns> + /// <exception cref="Exception"></exception> + public (List<Dt_Task>, List<Dt_StockInfo>?, List<Dt_OutboundOrderDetail>?, List<Dt_OutStockLockInfo>?, List<Dt_LocationInfo>?) OutboundTaskDataHandle(int orderDetailId, List<StockSelectViewDTO> stockSelectViews) + { + List<Dt_Task> tasks = new List<Dt_Task>(); + Dt_OutboundOrderDetail outboundOrderDetail = _outboundService.OutboundOrderDetailService.Repository.QueryFirst(x => x.Id == orderDetailId); + + if (outboundOrderDetail == null) + { + throw new Exception("鏈壘鍒板嚭搴撳崟鏄庣粏淇℃伅!"); + } + + if (stockSelectViews.Sum(x => x.UseableQuantity) > outboundOrderDetail.OrderQuantity - outboundOrderDetail.LockQuantity) + { + throw new Exception("閫夋嫨鏁伴噺瓒呭嚭鍗曟嵁鏁伴噺!"); + } + List<Dt_StockInfo>? stockInfos = null; + Dt_OutboundOrderDetail? orderDetail = null; + List<Dt_OutStockLockInfo>? outStockLockInfos = null; + List<Dt_LocationInfo>? locationInfos = null; + if (outboundOrderDetail.OrderDetailStatus == OrderDetailStatusEnum.New.ObjToInt()) + { + (List<Dt_StockInfo>, Dt_OutboundOrderDetail, List<Dt_OutStockLockInfo>, List<Dt_LocationInfo>) result = _outboundService.OutboundOrderDetailService.AssignStockOutbound(outboundOrderDetail, stockSelectViews); + if (result.Item1 != null && result.Item1.Count > 0) + { + tasks = GetTasks(result.Item1); + result.Item2.OrderDetailStatus = OrderDetailStatusEnum.Outbound.ObjToInt(); + result.Item3.ForEach(x => + { + x.Status = OutStockStatus.鍑哄簱涓�.ObjToInt(); + }); + + stockInfos = result.Item1; + orderDetail = result.Item2; + outStockLockInfos = result.Item3; + locationInfos = result.Item4; + } + else + { + throw new Exception("鏃犲簱瀛�!"); + } + } + else + { + List<Dt_OutStockLockInfo> stockLockInfos = _outboundService.OutboundStockLockInfoService.GetByOrderDetailId(outboundOrderDetail.OrderId); + if (stockLockInfos != null && stockLockInfos.Count > 0) + { + List<Dt_StockInfo> stocks = _stockService.StockInfoService.Repository.GetStockInfosByPalletCodes(stockLockInfos.Select(x => x.PalletCode).Distinct().ToList()); + tasks = GetTasks(stocks); + } + } + + return (tasks, stockInfos, orderDetail == null ? null : new List<Dt_OutboundOrderDetail> { orderDetail }, outStockLockInfos, locationInfos); + } + + /// <summary> + /// 鐢熸垚鍑哄簱浠诲姟 + /// </summary> + /// <param name="orderDetailId"></param> + /// <param name="stockSelectViews"></param> + /// <returns></returns> + public WebResponseContent GenerateOutboundTask(int orderDetailId, List<StockSelectViewDTO> stockSelectViews) + { + try + { + (List<Dt_Task>, List<Dt_StockInfo>?, List<Dt_OutboundOrderDetail>?, List<Dt_OutStockLockInfo>?, List<Dt_LocationInfo>?) result = OutboundTaskDataHandle(orderDetailId, stockSelectViews); + + WebResponseContent content = GenerateOutboundTaskDataUpdate(result.Item1, result.Item2, result.Item3, result.Item4, result.Item5); + + return content; + } + catch (Exception ex) + { + return WebResponseContent.Instance.Error($"{ex.Message}"); + } + } + + /// <summary> + /// 鐢熸垚鍑哄簱浠诲姟鍚庢暟鎹洿鏂板埌鏁版嵁搴� + /// </summary> + /// <param name="tasks"></param> + /// <param name="stockInfos"></param> + /// <param name="outboundOrderDetails"></param> + /// <param name="outStockLockInfos"></param> + /// <param name="locationInfos"></param> + /// <returns></returns> + public WebResponseContent GenerateOutboundTaskDataUpdate(List<Dt_Task> tasks, List<Dt_StockInfo>? stockInfos = null, List<Dt_OutboundOrderDetail>? outboundOrderDetails = null, List<Dt_OutStockLockInfo>? outStockLockInfos = null, List<Dt_LocationInfo>? locationInfos = null) + { + WebResponseContent content = new WebResponseContent(); + try + { + _unitOfWorkManage.BeginTran(); + (List<Dt_Task>?, List<Dt_Task>?) result=RelocationTasks(tasks.OrderBy(x=>x.Depth).ToList()); + if (result.Item1 != null && result.Item1.Count >0) + { + AddData(result.Item1); + var response = HttpHelper.Post<WebResponseContent>(url + "ReceiveTask/", result.Item1, "鍑哄簱浠诲姟涓嬪彂"); + if (!response.Status) + { + _unitOfWorkManage.RollbackTran(); + return content = WebResponseContent.Instance.Error($"{response.Message}"); + } + } + if(result.Item2 != null&&result.Item2.Count>0) + { + for (int i = 0; i < result.Item2.Count; i++) + { + Dt_LocationInfo location = _basicService.LocationInfoService.Repository.QueryFirst(x => x.LocationCode == result.Item2[i].SourceAddress && x.RoadwayNo == result.Item2[i].Roadway); + if (location.Depth == 2) + { + _basicService.LocationInfoService.UpdateLocationLock(location, result.Item2[i].TaskNum, StockChangeType.Outbound.ObjToInt(), false); + } + } + AddData(result.Item2); + var response = HttpHelper.Post<WebResponseContent>(url + "ReceiveTask/", result.Item2, "鍑哄簱浠诲姟涓嬪彂"); + if (!response.Status) + { + _unitOfWorkManage.RollbackTran(); + return content = WebResponseContent.Instance.Error($"{response.Message}"); + } + } + + + if (stockInfos != null && outboundOrderDetails != null && outStockLockInfos != null && locationInfos != null) + { + content = _outboundService.OutboundOrderDetailService.LockOutboundStockDataUpdate(stockInfos, outboundOrderDetails, outStockLockInfos, locationInfos, tasks: tasks); + + if (content.Status) + { + _unitOfWorkManage.CommitTran(); + } + else + { + _unitOfWorkManage.RollbackTran(); + } + } + else if (outboundOrderDetails != null && outboundOrderDetails.Count > 0) + { + outboundOrderDetails.ForEach(x => + { + x.OrderDetailStatus = OrderDetailStatusEnum.Outbound.ObjToInt(); + }); + + _outboundService.OutboundOrderDetailService.Repository.UpdateData(outboundOrderDetails); + } + if (outboundOrderDetails != null&&outboundOrderDetails.Count()>0) + { + for (int i = 0; i < outboundOrderDetails.Count(); i++) + { + _outboundService.OutboundOrderDetailService.Repository.DeleteAndMoveIntoHty(outboundOrderDetails[i], App.User.UserId == 0 ? OperateType.鑷姩瀹屾垚 : OperateType.浜哄伐瀹屾垚); + Dt_OutboundOrder outboundOrder = _outboundService.OutboundOrderService.Repository.QueryFirst(x => x.Id == outboundOrderDetails[i].OrderId); + List<Dt_OutboundOrderDetail> outboundOrderDetail = _outboundService.OutboundOrderDetailService.Repository.QueryData(x => x.OrderId == outboundOrder.Id&&x.OrderDetailStatus==OrderDetailStatusEnum.New.ObjToInt()).ToList(); + if (outboundOrderDetail.Count <= 0) + { + outboundOrder.OrderStatus = OutboundStatusEnum.鍑哄簱瀹屾垚.ObjToInt(); + _outboundService.OutboundOrderService.Repository.DeleteAndMoveIntoHty(outboundOrder, App.User.UserId == 0 ? OperateType.鑷姩瀹屾垚 : OperateType.浜哄伐瀹屾垚); + } + else + { + outboundOrder.OrderStatus = OutboundStatusEnum.鍑哄簱涓�.ObjToInt(); + _outboundService.OutboundOrderService.Repository.UpdateData(outboundOrder); + } + } + + } + + _unitOfWorkManage.CommitTran(); + return WebResponseContent.Instance.OK(); + } + catch (Exception ex) + { + _unitOfWorkManage.RollbackTran(); + return WebResponseContent.Instance.Error(ex.Message); + } + finally + { + WriteLog.GetLog("鍑哄簱浠诲姟涓嬪彂").Write(JsonConvert.SerializeObject(content), "鍑哄簱浠诲姟涓嬪彂"); + } + + } + public (List<Dt_Task>?, List<Dt_Task>?) RelocationTasks(List<Dt_Task> task) + { + WebResponseContent content = new WebResponseContent(); + try + { + List<Dt_Task> tasks = new List<Dt_Task>(); + List<Dt_Task> relocationList=new List<Dt_Task>(); + if (task.Count > 0) + { + for (int i = 0; i < task.Count; i++) + { + Dt_LocationInfo location = _basicService.LocationInfoService.Repository.QueryFirst(x => x.LocationCode == task[i].SourceAddress && x.RoadwayNo == task[i].Roadway); + int befoStatus=location.LocationStatus.ObjToInt(); + if (location != null) + { + Dt_LocationInfo result = _basicService.LocationInfoService.isDepth(location); + if (result != null && result.LocationStatus != LocationStatusEnum.Lock.ObjToInt() && result.LocationStatus != LocationStatusEnum.PalletLock.ObjToInt() && result.LocationStatus != LocationStatusEnum.Free.ObjToInt()) + { + int sum = 0; + for (int j = 0; j < task.Count; j++) + { + if (result.LocationCode == task[j].SourceAddress) + { + sum++; + } + } + if (sum == 0) + { + Dt_Task relocariontask = RelocationTask(result); + task[i].Grade=2; + relocationList.Add(relocariontask); + relocationList.Add(task[i]); + } + else + { + tasks.Add(task[i]); + content = WebResponseContent.Instance.OK(); + } + } + else if (result == null) + { + tasks.Add(task[i]); + content = WebResponseContent.Instance.OK(); + } + else if (result != null && result.LocationStatus == LocationStatusEnum.Free.ObjToInt()) + { + tasks.Add(task[i]); + content = WebResponseContent.Instance.OK(); + } + else if (result != null && (result.LocationStatus == LocationStatusEnum.Lock.ObjToInt() || result.LocationStatus == LocationStatusEnum.PalletLock.ObjToInt())) + { + Dt_Task TaskInfo = BaseDal.QueryFirst(x => x.SourceAddress == result.LocationCode); + if (TaskInfo == null) + { + content = WebResponseContent.Instance.Error("璐т綅琚攣瀹氫笉鍙嚭搴�"); + break; + } + else + { + tasks.Add(task[i]); + content = WebResponseContent.Instance.OK(); + } + } + } + else + { + content = WebResponseContent.Instance.Error("浠诲姟寮傚父"); + break; + } + } + return (relocationList,tasks); + } + else + { + throw new Exception($"鐢熸垚绉诲簱浠诲姟澶辫触"); + } + } + catch (Exception ex) + { + return (null, null); + } + } + /// <summary> + /// 绉诲簱浠诲姟 + /// </summary> + /// <param name="task"></param> + /// <returns></returns> + public Dt_Task RelocationTask(Dt_LocationInfo location) + { + WebResponseContent content = new WebResponseContent(); + try + { + Dt_StockInfo stockInfo = _stockService.StockInfoService.Repository.QueryFirst(x => x.LocationCode == location.LocationCode); + if (stockInfo != null) + { + Dt_LocationInfo? locationInfos = _basicService.LocationInfoService.AssignLocation(location.RoadwayNo); + if (locationInfos != null) + { + Dt_Task tasks = new() + { + CurrentAddress = location.LocationCode, + Grade = 0, + PalletCode = stockInfo.PalletCode, + NextAddress = locationInfos.LocationCode, + Roadway = location.RoadwayNo, + SourceAddress = location.LocationCode, + TargetAddress = locationInfos.LocationCode, + TaskStatus = InTaskStatusEnum.RelocationNew.ObjToInt(), + TaskType = TaskTypeEnum.Relocation.ObjToInt(), + Depth= location.Depth, + TaskNum = BaseDal.GetTaskNum(nameof(SequenceEnum.SeqTaskNum)) + }; + _basicService.LocationInfoService.RelocationLock(location, locationInfos, tasks.TaskNum); + stockInfo.StockStatus= StockStatusEmun.绉诲簱閿佸畾.ObjToInt(); + _stockService.StockInfoService.Repository.UpdateData(stockInfo); + return tasks; + } + else + { + throw new Exception($"鐢熸垚绉诲簱浠诲姟澶辫触"); + } + } + else + { + throw new Exception("鏈壘鍒板簱瀛樹俊鎭�"); + } + } + catch (Exception ex) + { + throw new Exception($"鐢熸垚绉诲簱浠诲姟澶辫触"); ; + } + } + /// <summary> + /// 鐢熸垚鍑哄簱浠诲姟 + /// </summary> + /// <param name="keys"></param> + /// <returns></returns> + public WebResponseContent GenerateOutboundTask(int[] keys) + { + try + { + List<Dt_Task> tasks = new List<Dt_Task>(); + List<StockSelectViewDTO> stockSelectViews = new List<StockSelectViewDTO>(); + List<Dt_StockInfo> stockInfos = new List<Dt_StockInfo>(); + List<Dt_OutboundOrderDetail> outboundOrderDetails = new List<Dt_OutboundOrderDetail>(); + List<Dt_OutStockLockInfo> outStockLockInfos = new List<Dt_OutStockLockInfo>(); + List<Dt_LocationInfo> locationInfos = new List<Dt_LocationInfo>(); + foreach (int key in keys) + { + + (List<Dt_Task>, List<Dt_StockInfo>?, List<Dt_OutboundOrderDetail>?, List<Dt_OutStockLockInfo>?, List<Dt_LocationInfo>?) result = OutboundTaskDataHandle(key, stockSelectViews); + if (result.Item2 != null && result.Item2.Count > 0) + { + stockInfos.AddRange(result.Item2); + } + if (result.Item3 != null && result.Item3.Count > 0) + { + outboundOrderDetails.AddRange(result.Item3); + } + if (result.Item4 != null && result.Item4.Count > 0) + { + outStockLockInfos.AddRange(result.Item4); + } + if (result.Item5 != null && result.Item5.Count > 0) + { + locationInfos.AddRange(result.Item5); + } + if (result.Item1 != null && result.Item1.Count > 0) + { + tasks.AddRange(result.Item1); + } + + + } + + WebResponseContent content = GenerateOutboundTaskDataUpdate(tasks, stockInfos, outboundOrderDetails, outStockLockInfos, locationInfos); + return content; + } + catch (Exception ex) + { + _unitOfWorkManage.RollbackTran(); + return WebResponseContent.Instance.Error(ex.Message); + } + } + + /// <summary> + /// 绌烘墭鐩樺嚭搴撲换鍔� + /// </summary> + /// <param name="inTask"></param> + /// <returns></returns> + public WebResponseContent PalletOutboundTask(string roadwayNo, string endStation) + { + try + { + Dt_StockInfo stockInfo = _stockService.StockInfoService.Repository.GetPalletStockInfo(roadwayNo); + if (stockInfo == null) + { + return WebResponseContent.Instance.Error("鏈壘鍒扮┖鎵樼洏搴撳瓨"); + } + Dt_LocationInfo locationInfo = _basicService.LocationInfoService.Repository.QueryFirst(x => x.LocationCode == stockInfo.LocationCode && x.RoadwayNo == roadwayNo); + if (locationInfo == null) + { + return WebResponseContent.Instance.Error("鏈壘鍒扮┖鎵樼洏搴撳瓨瀵瑰簲鐨勮揣浣嶄俊鎭�"); + } + Dt_RoadwayInfo roadwayInfo = _basicService.RoadwayInfoService.Repository.QueryFirst(x => x.InStationCode == endStation && x.RoadwayNo == roadwayNo); + if (roadwayInfo == null) + { + return WebResponseContent.Instance.Error("鏈壘鍒扮粓鐐瑰贩閬撲俊鎭�"); + } + List<Dt_Task> tasks = new List<Dt_Task>(); + Dt_Task task = new Dt_Task() + { + CurrentAddress = stockInfo.LocationCode, + Grade = 1, + NextAddress = endStation, + PalletCode = stockInfo.PalletCode, + Roadway = roadwayNo, + SourceAddress = stockInfo.LocationCode, + TargetAddress = endStation, + TaskStatus = OutTaskStatusEnum.OutNew.ObjToInt(), + TaskType = TaskTypeEnum.PalletOutbound.ObjToInt(), + Depth = locationInfo.Depth, + TaskNum = BaseDal.GetTaskNum(nameof(SequenceEnum.SeqTaskNum)) + }; + int beforeStatus = locationInfo.LocationStatus; + _unitOfWorkManage.BeginTran(); + stockInfo.StockStatus = StockStatusEmun.鍑哄簱閿佸畾.ObjToInt(); + locationInfo.LocationStatus = LocationStatusEnum.Lock.ObjToInt(); + tasks.Add(task); + (List<Dt_Task>?, List<Dt_Task>?) result = RelocationTasks(tasks.OrderBy(x => x.Depth).ToList()); + if (result.Item1 != null && result.Item1.Count > 0) + { + for (int i = 0; i < result.Item1.Count; i++) + { + result.Item1[i].Grade = 1; + } + AddData(result.Item1); + var response = HttpHelper.Post<WebResponseContent>(url + "ReceiveTask/", result.Item1, "鍏ュ簱浠诲姟涓嬪彂"); + if (!response.Status) + { + _unitOfWorkManage.RollbackTran(); + return WebResponseContent.Instance.Error($"{response.Message}"); + } + } + if (result.Item2 != null && result.Item2.Count > 0) + { + for (int i = 0; i < result.Item2.Count; i++) + { + Dt_LocationInfo location = _basicService.LocationInfoService.Repository.QueryFirst(x => x.LocationCode == result.Item2[i].SourceAddress && x.RoadwayNo == result.Item2[i].Roadway); + if (location.Depth == 2) + { + _basicService.LocationInfoService.UpdateLocationLock(location, result.Item2[i].TaskNum, StockChangeType.Outbound.ObjToInt(), false); + } + result.Item2[i].Grade = 1; + } + AddData(result.Item2); + var response = HttpHelper.Post<WebResponseContent>(url + "ReceiveTask/", result.Item2, "鍑哄簱浠诲姟涓嬪彂"); + if (!response.Status) + { + _unitOfWorkManage.RollbackTran(); + return WebResponseContent.Instance.Error($"{response.Message}"); + } + } + _stockService.StockInfoService.UpdateData(stockInfo); + + _basicService.LocationInfoService.UpdateData(locationInfo); + + _basicService.LocationInfoService.UpdateLocationLock(locationInfo, task.TaskNum, StockChangeType.Outbound.ObjToInt(), false); + _recordService.LocationStatusChangeRecordSetvice.AddLocationStatusChangeRecord(locationInfo, beforeStatus, StockChangeType.Outbound.ObjToInt(), "", task.TaskNum); + _unitOfWorkManage.CommitTran(); + return WebResponseContent.Instance.OK(); + } + catch (Exception ex) + { + return WebResponseContent.Instance.Error(ex.Message); + } + } + } +} -- Gitblit v1.9.3