From 0bfe24ddf438636aeef8c1e6989d5c8c28b0bb1a Mon Sep 17 00:00:00 2001 From: Huangxiaoqiang-03 <1247017146@qq.com> Date: 星期四, 31 十月 2024 16:56:13 +0800 Subject: [PATCH] 1 --- 代码管理/WMS/WIDESEA_WMSServer/WIDESEA_TaskInfoService/PartialTaskService_Outbound.cs | 389 +++++++++++++++++++++++++++++++++++++++++++++++++++++- 1 files changed, 377 insertions(+), 12 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" index 924d427..2022f55 100644 --- "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" @@ -8,11 +8,20 @@ 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; 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>(); @@ -22,8 +31,8 @@ if (stockInfo != null) { - Dt_LocationInfo locationInfo = _locationInfoService.Repository.QueryFirst(x => x.LocationCode == stockInfo.LocationCode); - Dt_RoadwayInfo roadwayInfo = _roadwayInfoRepository.QueryFirst(x => x.RoadwayNo == locationInfo.RoadwayNo); + 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() @@ -35,9 +44,10 @@ Roadway = locationInfo.RoadwayNo, SourceAddress = stockInfo.LocationCode, TargetAddress = roadwayInfo.OutStationCode, - TaskStatus = InTaskStatusEnum.InNew.ObjToInt(), + TaskStatus = OutTaskStatusEnum.OutNew.ObjToInt(), TaskType = TaskTypeEnum.Outbound.ObjToInt(), - TaskNum = BaseDal.GetTaskNum("SeqTaskNum") + Depth = locationInfo.Depth, + TaskNum = BaseDal.GetTaskNum(nameof(SequenceEnum.SeqTaskNum)) }; tasks.Add(task); } @@ -46,10 +56,17 @@ 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 = _outboundOrderDetailService.Repository.QueryFirst(x => x.Id == orderDetailId); + Dt_OutboundOrderDetail outboundOrderDetail = _outboundService.OutboundOrderDetailService.Repository.QueryFirst(x => x.Id == orderDetailId); if (outboundOrderDetail == null) { @@ -66,7 +83,7 @@ List<Dt_LocationInfo>? locationInfos = null; if (outboundOrderDetail.OrderDetailStatus == OrderDetailStatusEnum.New.ObjToInt()) { - (List<Dt_StockInfo>, Dt_OutboundOrderDetail, List<Dt_OutStockLockInfo>, List<Dt_LocationInfo>) result = _outboundOrderDetailService.AssignStockOutbound(outboundOrderDetail, stockSelectViews); + (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); @@ -88,10 +105,10 @@ } else { - List<Dt_OutStockLockInfo> stockLockInfos = _outStockLockInfoService.GetByOrderDetailId(outboundOrderDetail.OrderId); + List<Dt_OutStockLockInfo> stockLockInfos = _outboundService.OutboundStockLockInfoService.GetByOrderDetailId(outboundOrderDetail.OrderId); if (stockLockInfos != null && stockLockInfos.Count > 0) { - List<Dt_StockInfo> stocks = _stockInfoService.Repository.GetStockInfosByPalletCodes(stockLockInfos.Select(x => x.PalletCode).Distinct().ToList()); + List<Dt_StockInfo> stocks = _stockService.StockInfoService.Repository.GetStockInfosByPalletCodes(stockLockInfos.Select(x => x.PalletCode).Distinct().ToList()); tasks = GetTasks(stocks); } } @@ -99,6 +116,12 @@ 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 @@ -115,16 +138,36 @@ } } + /// <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) { try { + WebResponseContent content=new WebResponseContent(); _unitOfWorkManage.BeginTran(); - - BaseDal.AddData(tasks); + //鍒ゆ柇绉诲簱 + content=RelocationTasks(tasks.OrderBy(x=>x.Depth).ToList()); + if (content.Status) + { + _unitOfWorkManage.CommitTran(); + } + else + { + _unitOfWorkManage.RollbackTran(); + return content; + } + //BaseDal.AddData(tasks); if (stockInfos != null && outboundOrderDetails != null && outStockLockInfos != null && locationInfos != null) { - WebResponseContent content = _outboundOrderDetailService.LockOutboundStockDataUpdate(stockInfos, outboundOrderDetails, outStockLockInfos, locationInfos, tasks: tasks); + content = _outboundService.OutboundOrderDetailService.LockOutboundStockDataUpdate(stockInfos, outboundOrderDetails, outStockLockInfos, locationInfos, tasks: tasks); if (content.Status) { @@ -143,7 +186,7 @@ x.OrderDetailStatus = OrderDetailStatusEnum.Outbound.ObjToInt(); }); - _outboundOrderDetailService.Repository.UpdateData(outboundOrderDetails); + _outboundService.OutboundOrderDetailService.Repository.UpdateData(outboundOrderDetails); } _unitOfWorkManage.CommitTran(); return WebResponseContent.Instance.OK(); @@ -155,7 +198,208 @@ } } + public WebResponseContent RelocationTasks(List<Dt_Task> task) + { + WebResponseContent content = new WebResponseContent(); + try + { + _unitOfWorkManage.BeginTran(); + 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); + if (location != null) + { + //(Dt_LocationInfo?, int?) result = _basicService.LocationInfoService.isDepth(location); + (Dt_LocationInfo?, int?) result = isDepth(location); + if (result.Item1 != null && result.Item2 != LocationStatusEnum.Lock.ObjToInt() && result.Item2 != LocationStatusEnum.PalletLock.ObjToInt() && result.Item2 != LocationStatusEnum.Free.ObjToInt()) + { + int sum = 0; + for (int j = 0; j < task.Count; j++) + { + if (result.Item1.LocationCode == task[j].SourceAddress) + { + sum++; + } + } + if (sum == 0) + { + return content = RelocationTask(task[i]); + } + else + { + BaseDal.AddData(task[i]); + _basicService.LocationInfoService.UpdateLocationLock(location, task[i].TaskNum, StockChangeType.Outbound.ObjToInt(), true); + } + } + else if (result.Item1 == null && result.Item2 == LocationStatusEnum.Free.ObjToInt()) + { + BaseDal.AddData(task[i]); + location.LocationStatus = LocationStatusEnum.Lock.ObjToInt(); + _basicService.LocationInfoService.UpdateData(location); + content = WebResponseContent.Instance.OK(); + } + else if (result.Item1 != null && result.Item2 == LocationStatusEnum.Free.ObjToInt()) + { + BaseDal.AddData(task[i]); + location.LocationStatus = LocationStatusEnum.Lock.ObjToInt(); + _basicService.LocationInfoService.UpdateData(location); + _basicService.LocationInfoService.UpdateLocationLock(location, task[i].TaskNum, StockChangeType.Outbound.ObjToInt(), false); + content = WebResponseContent.Instance.OK(); + } + else if (result.Item1 != null && (result.Item2 == LocationStatusEnum.Lock.ObjToInt() || result.Item2 == LocationStatusEnum.PalletLock.ObjToInt())) + { + Dt_Task TaskInfo = BaseDal.QueryFirst(x => x.SourceAddress == result.Item1.LocationCode); + if (TaskInfo == null) + { + return content = WebResponseContent.Instance.Error("璐т綅琚攣瀹氫笉鍙嚭搴�"); + } + else + { + BaseDal.AddData(task[i]); + location.LocationStatus = LocationStatusEnum.Lock.ObjToInt(); + _basicService.LocationInfoService.UpdateData(location); + content = WebResponseContent.Instance.OK(); + } + } + } + else + { + return content = WebResponseContent.Instance.Error("浠诲姟寮傚父"); + } + } + } + else + { + return content = WebResponseContent.Instance.Error("娌℃湁搴撳瓨鐢熸垚浠诲姟"); + } + _unitOfWorkManage.CommitTran(); + return content; + } + catch (Exception ex) + { + _unitOfWorkManage.RollbackTran(); + return content = WebResponseContent.Instance.Error(ex.Message); + } + } + /// <summary> + /// 绉诲簱浠诲姟 + /// </summary> + /// <param name="task"></param> + /// <returns></returns> + public WebResponseContent RelocationTask(Dt_Task task) + { + WebResponseContent content = new WebResponseContent(); + try + { + Dt_LocationInfo locationInfo = _basicService.LocationInfoService.Repository.QueryFirst(x => x.LocationCode == task.SourceAddress && x.RoadwayNo == task.Roadway); + if (locationInfo != null) + { + int beforeStatus = locationInfo.LocationStatus; + //(Dt_LocationInfo?,int?) Result = _basicService.LocationInfoService.isDepth(locationInfo); + (Dt_LocationInfo?,int?) Result = isDepth(locationInfo); + if (Result.Item1 != null&& Result.Item2== LocationStatusEnum.InStock.ObjToInt()) + { + Dt_StockInfo stockInfo = _stockService.StockInfoService.Repository.QueryFirst(x => x.LocationCode == Result.Item1.LocationCode); + Dt_StockInfoDetail stockInfoDetail = _stockService.StockInfoDetailService.Repository.QueryFirst(x => x.StockId==stockInfo.Id); + if (stockInfo != null&& stockInfoDetail != null) + { + (Dt_Task ?, Dt_LocationInfo ?) result= AddRelocationTask(Result.Item1, stockInfo, task); + if (result.Item1!=null&&result.Item2!=null) + { + _basicService.LocationInfoService.RelocationLock(Result.Item1, result.Item2, result.Item1.TaskNum); + locationInfo.LocationStatus = LocationStatusEnum.Lock.ObjToInt(); + _basicService.LocationInfoService.UpdateData(locationInfo); + _recordService.LocationStatusChangeRecordSetvice.AddLocationStatusChangeRecord(locationInfo, beforeStatus, StockChangeType.Relocation.ObjToInt(), "", task.TaskNum); + return content = WebResponseContent.Instance.OK(); + } + else + { + return content = WebResponseContent.Instance.Error("绉诲簱浠诲姟鐢熸垚澶辫触"); + } + } + else + { + return content = WebResponseContent.Instance.Error("鏈壘鍒板簱瀛樹俊鎭�"); + } + } + else if(Result.Item1 != null && Result.Item2 == LocationStatusEnum.Pallet.ObjToInt()) + { + Dt_StockInfo stockInfo = _stockService.StockInfoService.Repository.QueryFirst(x => x.LocationCode == Result.Item1.LocationCode); + if (stockInfo != null) + { + (Dt_Task?, Dt_LocationInfo?) result = AddRelocationTask(Result.Item1, stockInfo, task); + if (result.Item1 != null && result.Item2 != null) + { + _basicService.LocationInfoService.RelocationLock(Result.Item1, result.Item2, result.Item1.TaskNum); + locationInfo.LocationStatus = LocationStatusEnum.PalletLock.ObjToInt(); + _basicService.LocationInfoService.UpdateData(locationInfo); + _recordService.LocationStatusChangeRecordSetvice.AddLocationStatusChangeRecord(locationInfo, beforeStatus, StockChangeType.Relocation.ObjToInt(), "", task.TaskNum); + return content = WebResponseContent.Instance.OK(); + } + else + { + return content = WebResponseContent.Instance.Error("绉诲簱浠诲姟鐢熸垚澶辫触"); + } + } + else + { + return content = WebResponseContent.Instance.Error("鏈壘鍒板簱瀛樹俊鎭�"); + } + } + else + { + return content = WebResponseContent.Instance.Error("寮傚父"); + } + } + else + { + return content = WebResponseContent.Instance.Error("浠诲姟淇℃伅寮傚父"); + } + } + catch (Exception ex) + { + return content = WebResponseContent.Instance.Error(ex.Message); + } + finally + { + + } + + + } + public (Dt_Task?,Dt_LocationInfo?) AddRelocationTask(Dt_LocationInfo location,Dt_StockInfo stockInfo,Dt_Task task) + { + 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(), + TaskNum = BaseDal.GetTaskNum(nameof(SequenceEnum.SeqTaskNum)) + }; + BaseDal.AddData(tasks); + BaseDal.AddData(task); + stockInfo.StockStatus = StockStatusEmun.绉诲簱閿佸畾.ObjToInt(); + _stockService.StockInfoService.UpdateData(stockInfo); + } + return (task, locationInfos); + } + /// <summary> + /// 鐢熸垚鍑哄簱浠诲姟 + /// </summary> + /// <param name="keys"></param> + /// <returns></returns> public WebResponseContent GenerateOutboundTask(int[] keys) { try @@ -168,6 +412,7 @@ 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) { @@ -189,6 +434,8 @@ { tasks.AddRange(result.Item1); } + + } WebResponseContent content = GenerateOutboundTaskDataUpdate(tasks, stockInfos, outboundOrderDetails, outStockLockInfos, locationInfos); @@ -200,5 +447,123 @@ 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("鏈壘鍒扮粓鐐瑰贩閬撲俊鎭�"); + } + Dt_Task task = new Dt_Task() + { + CurrentAddress = stockInfo.LocationCode, + Grade = 0, + 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(); + BaseDal.AddData(task); + _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); + } + } + + public (Dt_LocationInfo?, int?) isDepth(Dt_LocationInfo locationInfo) + { + if (locationInfo.Depth == 2) + { + if (locationInfo.Row == 1 || locationInfo.Row == 5) + { + Dt_LocationInfo dt_LocationInfo = _basicService.LocationInfoService.Repository.QueryFirst(x => x.Row == locationInfo.Row + 1 && x.Layer == locationInfo.Layer && x.Column == locationInfo.Column && x.RoadwayNo == locationInfo.RoadwayNo); + + if (dt_LocationInfo != null && dt_LocationInfo.LocationStatus == LocationStatusEnum.InStock.ObjToInt()) + { + return (dt_LocationInfo, LocationStatusEnum.InStock.ObjToInt()); + } + if (dt_LocationInfo != null && dt_LocationInfo.LocationStatus == LocationStatusEnum.Free.ObjToInt()) + { + return (dt_LocationInfo, LocationStatusEnum.Free.ObjToInt()); + } + if (dt_LocationInfo != null && dt_LocationInfo.LocationStatus == LocationStatusEnum.Lock.ObjToInt()) + { + return (dt_LocationInfo, LocationStatusEnum.Lock.ObjToInt()); + } + if (dt_LocationInfo != null && dt_LocationInfo.LocationStatus == LocationStatusEnum.PalletLock.ObjToInt()) + { + return (dt_LocationInfo, LocationStatusEnum.PalletLock.ObjToInt()); + } + if (dt_LocationInfo != null && dt_LocationInfo.LocationStatus == LocationStatusEnum.Pallet.ObjToInt()) + { + return (dt_LocationInfo, LocationStatusEnum.Pallet.ObjToInt()); + } + } + else if (locationInfo.Row == 4 || locationInfo.Row == 8) + { + Dt_LocationInfo dt_LocationInfo = _basicService.LocationInfoService.Repository.QueryFirst(x => x.Row == locationInfo.Row + 1 && x.Layer == locationInfo.Layer && x.Column == locationInfo.Column && x.RoadwayNo == locationInfo.RoadwayNo); + + if (dt_LocationInfo != null && dt_LocationInfo.LocationStatus == LocationStatusEnum.InStock.ObjToInt()) + { + return (dt_LocationInfo, LocationStatusEnum.InStock.ObjToInt()); + } + if (dt_LocationInfo != null && dt_LocationInfo.LocationStatus == LocationStatusEnum.Free.ObjToInt()) + { + return (dt_LocationInfo, LocationStatusEnum.Free.ObjToInt()); + } + if (dt_LocationInfo != null && dt_LocationInfo.LocationStatus == LocationStatusEnum.Lock.ObjToInt()) + { + return (dt_LocationInfo, LocationStatusEnum.Lock.ObjToInt()); + } + if (dt_LocationInfo != null && dt_LocationInfo.LocationStatus == LocationStatusEnum.PalletLock.ObjToInt()) + { + return (dt_LocationInfo, LocationStatusEnum.PalletLock.ObjToInt()); + } + if (dt_LocationInfo != null && dt_LocationInfo.LocationStatus == LocationStatusEnum.Pallet.ObjToInt()) + { + return (dt_LocationInfo, LocationStatusEnum.Pallet.ObjToInt()); + } + } + } + return (null, LocationStatusEnum.Free.ObjToInt()); + } } } -- Gitblit v1.9.3