using System; using System.Collections.Generic; using System.Linq; using System.Reflection; using System.Text; using System.Threading.Tasks; using WIDESEA_Core.Enums; using WIDESEA_Core; using WIDESEA_Model.Models; using WIDESEA_Core.Helper; using Microsoft.Extensions.Logging; using MailKit.Search; using System.Reflection.Metadata; using static WIDESEA_ITaskInfoService.ITaskService; namespace WIDESEA_TaskInfoService { public partial class TaskService { /// /// PDA申请入库--堆垛机立库入库 /// /// 起始地址 /// 任务类型--入空,入料 /// 托盘编号 /// 返回处理结果 public WebResponseContent GenerateInboundTask(string stationCode, int taskType, string palletCode) { string? name = Enum.GetName(typeof(TaskTypeEnum), taskType); MethodInfo? methodInfo = GetType().GetMethod(name + "Request"); if (methodInfo != null) { WebResponseContent? responseContent = (WebResponseContent?)methodInfo.Invoke(this, new object[] { stationCode, palletCode }); if (responseContent != null) { return responseContent; } } else { return WebResponseContent.Instance.Error("未找到该任务类型业务"); } return WebResponseContent.Instance.Error("错误"); } /// /// 空托盘入库 /// /// 起始地址 /// 托盘编号 /// 返回处理结果 public WebResponseContent PalletInboundRequest(string stationCode, string palletCode) { WebResponseContent content = new WebResponseContent(); try { (bool, string) result = CheckRequestInbound(stationCode, palletCode, false); if (!result.Item1) return content = WebResponseContent.Instance.Error(result.Item2); content = AssignLocUpdateData(stationCode, TaskTypeEnum.PalletInbound.ObjToInt(), palletCode, false); } catch (Exception ex) { content = WebResponseContent.Instance.Error(ex.Message); } return content; } /// /// 物料入库 /// /// 起始地址 /// 托盘编号 /// 返回处理结果 public WebResponseContent InboundRequest(string stationCode, string palletCode) { WebResponseContent content = new WebResponseContent(); try { Dt_StockInfo stockInfo = _stockService.StockInfoService.Repository.GetStockInfo(palletCode); (bool, string) result = CheckRequestInbound(stationCode, palletCode, true, stockInfo); if (!result.Item1) return content = WebResponseContent.Instance.Error(result.Item2); content = AssignLocUpdateData(stationCode, TaskTypeEnum.Inbound.ObjToInt(), palletCode, true, stockInfo); } catch (Exception ex) { content = WebResponseContent.Instance.Error(ex.Message); } return content; } /// /// 入库分配货位及处理数据 /// /// 起始地址 /// 任务类型 /// 托盘编号 /// 是否更新组盘信息--区分物料入库和空托入库 /// 组盘信息--可空 /// 订单号--可空 /// 返回处理结果 private WebResponseContent AssignLocUpdateData(string stationCode, int taskType, string palletCode, bool isUpdateStock = true, Dt_StockInfo? stockInfo = null, string orderNo = "") { WebResponseContent content = new WebResponseContent(); try { Dt_LocationInfo? locationInfo = _basicService.LocationInfoService.AssignLocation(stationCode, taskType); //Dt_LocationInfo dt_LocationInfo = null; if (locationInfo != null) { Dt_Task task = new() { CurrentAddress = stationCode, Grade = 0, PalletCode = palletCode, NextAddress = locationInfo.LocationCode, Roadway = locationInfo.RoadwayNo, SourceAddress = stationCode, TargetAddress = locationInfo.LocationCode, TaskStatus = InTaskStatusEnum.InNew.ObjToInt(), TaskType = taskType, }; BaseDal.AddData(task); int beforeStatus = locationInfo.LocationStatus; if (isUpdateStock) { locationInfo.LocationStatus = LocationStatusEnum.Lock.ObjToInt(); _basicService.LocationInfoService.UpdateLocationLock(locationInfo, task.TaskNum, StockChangeType.Inbound.ObjToInt(), false); if (stockInfo != null && stockInfo.Details != null && stockInfo.Details.Count > 0) { orderNo = stockInfo.Details.FirstOrDefault()?.OrderNo ?? ""; stockInfo.StockStatus = StockStatusEmun.入库确认.ObjToInt(); _stockService.StockInfoService.Repository.UpdateData(stockInfo); } else { return content = WebResponseContent.Instance.Error("未找到库存信息"); } } else { locationInfo.LocationStatus = LocationStatusEnum.PalletLock.ObjToInt(); _basicService.LocationInfoService.UpdateLocationLock(locationInfo, task.TaskNum, StockChangeType.Inbound.ObjToInt(), false); } _basicService.LocationInfoService.Repository.UpdateData(locationInfo); _recordService.LocationStatusChangeRecordSetvice.AddLocationStatusChangeRecord(locationInfo, beforeStatus, StockChangeType.Inbound.ObjToInt(), orderNo, task.TaskNum); return content = WebResponseContent.Instance.OK(); } return content = WebResponseContent.Instance.Error("未找到可分配货位"); } catch (Exception ex) { content = WebResponseContent.Instance.Error(ex.Message); } return content; } /// /// 验证数据 /// /// 起始地址 /// 托盘编号 /// 是否检查组盘信息--区分物料入库和空托入库 /// 组盘信息--可空 /// 返回处理结果 private (bool, string) CheckRequestInbound(string stationCode, string palletCode, bool isCheckStock = true, Dt_StockInfo? stockInfo = null) { if (BaseDal.QueryFirst(x => x.PalletCode == palletCode) != null) { return (false, "该托盘号已有任务"); } if (BaseDal.QueryFirst(x => (x.SourceAddress == stationCode || x.CurrentAddress == stationCode) && x.TaskStatus == InTaskStatusEnum.InNew.ObjToInt()) != null) { return (false, "当前入库站台已有一条新建任务"); } if (isCheckStock) { if (stockInfo == null) { return (false, "未找到组盘信息"); } if (stockInfo.StockStatus != StockStatusEmun.组盘暂存.ObjToInt()) { return (false, "该组盘状态不可入库"); } if (!string.IsNullOrEmpty(stockInfo.LocationCode)) { return (false, "该托盘已绑定货位"); } if (stockInfo.Details == null || stockInfo.Details.Count == 0) { return (false, "没有库存明细信息"); } } else { if (_stockService.StockInfoService.Repository.QueryFirst(x => x.PalletCode == palletCode) != null) { return (false, "该托盘已存在库内"); } } return (true, "成功"); } /// /// 根据托盘条码,生成入库信息 /// /// /// public WebResponseContent GenerateInventoryInformation(GenerateInv generate) { WebResponseContent content = new WebResponseContent(); try { Dt_Task task = BaseDal.QueryFirst(x => x.PalletCode == generate.PalletCode); if (task != null) { return content = WebResponseContent.Instance.Error($"已有该托盘的入库任务,托盘号:{task.PalletCode}"); } else { if ((generate.SourceAddress == "R01-003-041-011-01" || generate.SourceAddress == "R01-002-043-001-01" || generate.SourceAddress == "R02-003-027-011-01")) { Dt_StockInfo dt_StockInfo2 = _stockService.StockInfoService.Repository.QueryFirst(x => x.PalletCode == generate.PalletCode); if(dt_StockInfo2 == null) { Dt_StockInfo dt_Stock = new() { PalletCode = generate.PalletCode, IsFull = true, StockStatus = (int)StockStatusEmun.组盘暂存, Creater = "WMS", CreateDate = DateTime.Now, MaterialType = (int)InventoryMaterialType.空托, Materialweight = 0, Wlstatus = (int)InventoryMaterialStatus.空托, Mgeneratetime = DateTime.Now, }; _stockService.StockInfoService.Repository.AddData(dt_Stock); } } Dt_StockInfo dt_StockInfo = _stockService.StockInfoService.Repository.QueryFirst(x => x.PalletCode == generate.PalletCode && x.StockStatus== (int)StockStatusEmun.组盘暂存); if (dt_StockInfo != null) { Dt_LocationInfo newLocation; Dt_LocationInfo newSourceAddress; newSourceAddress = _basicService.LocationInfoService.GetLocationplatform(generate.SourceAddress); int Locationtype = 9; //默认为9 if(dt_StockInfo.MaterialType== (int)InventoryMaterialType.成品 || (generate.SourceAddress == "R01-003-041-001-01" && dt_StockInfo.MaterialType == (int)InventoryMaterialType.原材料)) { Locationtype = 11; }else if(dt_StockInfo.MaterialType == (int)InventoryMaterialType.原材料) { Locationtype = 10; } if (dt_StockInfo.MaterialType == (int)InventoryMaterialType.成品) { string[] targetCodes = dt_StockInfo.PalletCode.Split("*"); Dt_InboundOrder dt_Inbound = _inboundService.InbounOrderService.Repository.QueryFirst(x => x.OrderName == targetCodes[0]); if (dt_Inbound.Startingcolumn != 0 || dt_Inbound.Terminationcolumn != 0) { newLocation = _basicService.LocationInfoService.GetLocation2(newSourceAddress.RoadwayNo, Locationtype, dt_Inbound.Startingcolumn, dt_Inbound.Terminationcolumn); } else { newLocation = _basicService.LocationInfoService.GetLocation(newSourceAddress.RoadwayNo, Locationtype); } } else { newLocation = _basicService.LocationInfoService.GetLocation(newSourceAddress.RoadwayNo, Locationtype); } //string[] Pallet = PalletCode.Split("-"); if (newLocation != null && newSourceAddress != null) { //生成入库任务 Dt_Task dt_Task = new() { PalletCode = generate.PalletCode, TaskNum = BaseDal.GetTaskNum(nameof(SequenceEnum.SeqTaskNum)), Roadway = newLocation.RoadwayNo, TaskType = TaskTypeEnum.Inbound.ObjToInt(), TaskStatus = InTaskStatusEnum.InNew.ObjToInt(), SourceAddress = newSourceAddress.LocationCode, TargetAddress = newLocation.LocationCode, CurrentAddress = newSourceAddress.LocationCode, NextAddress = newLocation.LocationCode, Grade = 1, Creater = "WMS", Depth = newLocation.Depth, CreateDate = DateTime.Now, MaterialType= dt_StockInfo.MaterialType }; _unitOfWorkManage.BeginTran(); if (newLocation.LocationStatus == LocationStatusEnum.Free.ObjToInt()) { newLocation.LocationStatus = newSourceAddress.LocationType == (int)LocationTypeEnum.EmptyOut ? LocationStatusEnum.PalletLock.ObjToInt() : LocationStatusEnum.Lock.ObjToInt(); } BaseDal.AddData(dt_Task); _basicService.LocationInfoService.UpdateData(newLocation); _unitOfWorkManage.CommitTran(); return content = WebResponseContent.Instance.OK(data: dt_Task); } else { return content = WebResponseContent.Instance.Error($"未找到对应的起点:{generate.SourceAddress},或终点{newSourceAddress.RoadwayNo},信息"); } } else { //Queryinventory(generate.PalletCode); return content = WebResponseContent.Instance.Error($"组盘,请核对托盘号:{generate.PalletCode}"); } } } catch (Exception ex) { return content = WebResponseContent.Instance.Error($"生成入库任务出错,出错信息:{ex.Message}"); throw; } } /// /// 查询1巷道库存,是否运行进行入库 //带后续重新拼接 /// /// public WebResponseContent Queryinventory3(GenerateInv generate) { try { WebResponseContent content = new WebResponseContent(); string result = generate.PalletCode.Substring(0, 2); Dt_InboundOrder dt_Inbound = _inboundService.InbounOrderService.Repository.QueryFirst(x => x.UpperOrderNo == result); Dt_StockInfo dt_StockInfo = _stockService.StockInfoService.Repository.QueryFirst(x => x.PalletCode == generate.PalletCode); if (dt_Inbound != null) { if (dt_StockInfo == null) { Dt_StockInfo dt_Stock = new() { PalletCode = generate.PalletCode, IsFull = true, StockStatus = (int)StockStatusEmun.组盘暂存, Creater = "WMS", CreateDate = DateTime.Now, MaterialType = (int)InventoryMaterialType.原材料, Materialweight = 0, }; _unitOfWorkManage.BeginTran(); _stockService.StockInfoService.Repository.AddData(dt_Stock); string part2 = generate.PalletCode.Substring(2, 8); string part3 = generate.PalletCode.Split('#')[1]; Dt_StockInfo dt_StockInfo2= _stockService.StockInfoService.Repository.QueryFirst(x => x.PalletCode == generate.PalletCode); Dt_StockInfoDetail dt_StockInfoDetail = new() { StockId = dt_StockInfo2.Id, MaterielCode = result, //物料编号 MaterielName = dt_Inbound.OrderNo, //材质 OrderNo = generate.PalletCode, //单据(托盘条码) BatchNo = part2, //批次号 SerialNumber = part3, //序列号 StockQuantity = 1, //序列号 OutboundQuantity = 1, //序列号 Status = (int)StockStatusEmun.组盘暂存, Creater = "WMS", CreateDate = DateTime.Now, }; _stockService.StockInfoDetailService.AddData(dt_StockInfoDetail); _unitOfWorkManage.CommitTran(); return content = WebResponseContent.Instance.OK(); } else { return content = WebResponseContent.Instance.OK(); } } else { return content = WebResponseContent.Instance.Error("未找到该类型的解析"); } } catch (Exception ex) { throw; } } /// /// 解析库存 /// /// public WebResponseContent Queryinventory(GenerateInv generate) { WebResponseContent content = new WebResponseContent(); try { string[] targetCodes = generate.PalletCode.Split("*"); if (targetCodes.Length == 4) { Dt_InboundOrder dt_Inbound = _inboundService.InbounOrderService.Repository.QueryFirst(x => x.OrderName == targetCodes[0]); if(dt_Inbound != null) { Dt_StockInfo dt_StockInfo = _stockService.StockInfoService.Repository.QueryFirst(x => x.PalletCode == generate.PalletCode); if (dt_Inbound.OrderType == (int)InventoryMaterialType.原材料) //0为原材料编码 { List locationInfos = _basicService.LocationInfoService.Repository.QueryData(x => x.RoadwayNo == "2" && x.LocationStatus == (int)LocationStatusEnum.Free && x.Depth == 1 && x.EnableStatus == (int)EnableStatusEnum.Normal && x.LocationType == (int)LocationTypeEnum.MaterialsCube); if (dt_StockInfo == null) { Dt_StockInfo dt_Stock = new() { PalletCode = generate.PalletCode, IsFull = true, StockStatus = (int)StockStatusEmun.组盘暂存, Creater = "WMS", CreateDate = DateTime.Now, MaterialType = (int)InventoryMaterialType.原材料, Materialweight = decimal.Parse(targetCodes[3]), Wlstatus = (int)InventoryMaterialStatus.待检, Mgeneratetime=DateTime.Now, }; _unitOfWorkManage.BeginTran(); _stockService.StockInfoService.Repository.AddData(dt_Stock); Dt_StockInfo dt_StockInfo2 = _stockService.StockInfoService.Repository.QueryFirst(x => x.PalletCode == generate.PalletCode); string part2 = targetCodes[1].Substring(0, 2); //解析物料批次找详情 Dt_InboundOrder dt_Int = _inboundService.InbounOrderService.Repository.QueryFirst(x => x.UpperOrderNo == part2); Dt_StockInfoDetail dt_StockInfoDetail = new() { StockId = dt_StockInfo2.Id, MaterielCode = dt_Inbound.OrderName, //物料号 MaterielName = dt_Inbound.UpperOrderNo, //物料名称 OrderNo = dt_Inbound.OrderNo, //物料详情 BatchNo = targetCodes[1].ToString(), //物料批次 SerialNumber = targetCodes[2].ToString(), //包号 BatchNoName = dt_Int.OrderNo, StockQuantity = decimal.Parse(targetCodes[3].ToString()), //重量 OutboundQuantity = 1, //序列号 Status = (int)StockStatusEmun.组盘暂存, Creater = "WMS", CreateDate = DateTime.Now, }; _stockService.StockInfoDetailService.AddData(dt_StockInfoDetail); _unitOfWorkManage.CommitTran(); if (locationInfos.Count < 50) { return content = WebResponseContent.Instance.OK(data: 1); } else { return content = WebResponseContent.Instance.OK(data: 3); } } else { if (dt_StockInfo.StockStatus == (int)StockStatusEmun.组盘暂存) { if (locationInfos.Count < 50) { return content = WebResponseContent.Instance.OK(data: 1); } else { return content = WebResponseContent.Instance.OK(data: 3); } } else { return content = WebResponseContent.Instance.Error($"库存已有该条码,条码信息:{generate.PalletCode}"); } } } else if (dt_Inbound.OrderType == (int)InventoryMaterialType.成品) { if (dt_StockInfo == null) { Dt_StockInfo dt_Stock = new() { PalletCode = generate.PalletCode, IsFull = true, StockStatus = (int)StockStatusEmun.组盘暂存, Creater = "WMS", CreateDate = DateTime.Now, MaterialType = (int)InventoryMaterialType.成品, Materialweight = decimal.Parse(targetCodes[3]), Wlstatus = (int)InventoryMaterialStatus.待检, Mgeneratetime = DateTime.Now, }; _unitOfWorkManage.BeginTran(); _stockService.StockInfoService.Repository.AddData(dt_Stock); Dt_StockInfo dt_StockInfo2 = _stockService.StockInfoService.Repository.QueryFirst(x => x.PalletCode == generate.PalletCode); Dt_StockInfoDetail dt_StockInfoDetail = new() { StockId = dt_StockInfo2.Id, MaterielCode = dt_Inbound.OrderName, //物料号 MaterielName = dt_Inbound.UpperOrderNo, //物料名称 OrderNo = dt_Inbound.OrderNo, //物料详情 BatchNo = targetCodes[1].ToString(), //物料批次 BatchNoName = "", SerialNumber = targetCodes[2], //包号 StockQuantity = decimal.Parse(targetCodes[3]), //重量 OutboundQuantity = 1, //序列号 Status = (int)StockStatusEmun.组盘暂存, Creater = "WMS", CreateDate = DateTime.Now, }; _stockService.StockInfoDetailService.AddData(dt_StockInfoDetail); _unitOfWorkManage.CommitTran(); return content = WebResponseContent.Instance.OK(data: 1); } else { if (dt_StockInfo.StockStatus == (int)StockStatusEmun.组盘暂存) { return content = WebResponseContent.Instance.OK(data: 1); } else { return content = WebResponseContent.Instance.Error($"库存已有该条码,条码信息:{generate.PalletCode}"); } } } else { return content = WebResponseContent.Instance.Error($"未找到条码解析,条码信息:{generate.PalletCode}"); } } else { return content = WebResponseContent.Instance.Error($"未找到入库单,条码信息:{generate.PalletCode}"); } } else { return content = WebResponseContent.Instance.Error($"解析的托盘条码长度不足4,条码信息:{generate.PalletCode}"); } } catch (Exception ex) { return content=WebResponseContent.Instance.Error($"系统巷道入库接口解析错误:错误:{ex.Message}"); throw; } } public WebResponseContent Queryinventory2(GenerateInv generate) { try { WebResponseContent content = new WebResponseContent(); string result = generate.PalletCode.Substring(0, 2); if (result == "B-") { Dt_StockInfo dt_StockInfo = _stockService.StockInfoService.Repository.QueryFirst(x => x.PalletCode == generate.PalletCode); if (dt_StockInfo == null) { Dt_StockInfo dt_Stock = new() { PalletCode = generate.PalletCode, IsFull = true, StockStatus = (int)StockStatusEmun.组盘暂存, Creater = "WMS", CreateDate = DateTime.Now, MaterialType = (int)InventoryMaterialType.成品, Materialweight = 0, }; _unitOfWorkManage.BeginTran(); _stockService.StockInfoService.Repository.AddData(dt_Stock); //string part2 = generate.PalletCode.Substring(2, 8); //string part3 = generate.PalletCode.Split('#')[1]; Dt_StockInfo dt_StockInfo2 = _stockService.StockInfoService.Repository.QueryFirst(x => x.PalletCode == generate.PalletCode); Dt_StockInfoDetail dt_StockInfoDetail = new() { StockId = dt_StockInfo2.Id, MaterielCode = dt_StockInfo2.PalletCode, //物料编号 MaterielName = dt_StockInfo2.PalletCode, //材质 OrderNo = dt_StockInfo2.PalletCode, //单据(托盘条码) BatchNo = dt_StockInfo2.PalletCode, //批次号 SerialNumber = dt_StockInfo2.PalletCode, //序列号 StockQuantity = 1, //序列号 OutboundQuantity = 1, //序列号 Status = (int)StockStatusEmun.组盘暂存, Creater = "WMS", CreateDate = DateTime.Now, }; _stockService.StockInfoDetailService.AddData(dt_StockInfoDetail); _unitOfWorkManage.CommitTran(); return content = WebResponseContent.Instance.OK(data: 1); } else { if(dt_StockInfo.StockStatus== (int)StockStatusEmun.组盘暂存) { return content = WebResponseContent.Instance.OK(data:1); } else { return content = WebResponseContent.Instance.Error($"库存已有该条码,条码信息:{generate.PalletCode}"); } } } else { Dt_InboundOrder dt_Inbound = _inboundService.InbounOrderService.Repository.QueryFirst(x => x.UpperOrderNo == result); Dt_StockInfo dt_StockInfo = _stockService.StockInfoService.Repository.QueryFirst(x => x.PalletCode == generate.PalletCode); List locationinfoData = _basicService.LocationInfoService.Repository.QueryData(x => x.RoadwayNo == "2" && x.LocationStatus == LocationStatusEnum.Free.ObjToInt() && x.LocationType == (int)LocationTypeEnum.MaterialsCube); if (dt_Inbound != null) { if (dt_StockInfo == null) { Dt_StockInfo dt_Stock = new() { PalletCode = generate.PalletCode, IsFull = true, StockStatus = (int)StockStatusEmun.组盘暂存, Creater = "WMS", CreateDate = DateTime.Now, MaterialType = (int)InventoryMaterialType.原材料, Materialweight = 0, }; _unitOfWorkManage.BeginTran(); _stockService.StockInfoService.Repository.AddData(dt_Stock); string part2 = generate.PalletCode.Substring(2, 8); string part3 = generate.PalletCode.Split('#')[1]; Dt_StockInfo dt_StockInfo2 = _stockService.StockInfoService.Repository.QueryFirst(x => x.PalletCode == generate.PalletCode); Dt_StockInfoDetail dt_StockInfoDetail = new() { StockId = dt_StockInfo2.Id, MaterielCode = result, //物料编号 MaterielName = dt_Inbound.OrderNo, //材质 OrderNo = generate.PalletCode, //单据(托盘条码) BatchNo = part2, //批次号 SerialNumber = part3, //序列号 StockQuantity = 1, //序列号 OutboundQuantity = 1, //序列号 Status = (int)StockStatusEmun.组盘暂存, Creater = "WMS", CreateDate = DateTime.Now, }; _stockService.StockInfoDetailService.AddData(dt_StockInfoDetail); _unitOfWorkManage.CommitTran(); if (locationinfoData.Count > 40) { return content = WebResponseContent.Instance.OK(data: 3); } else { return content = WebResponseContent.Instance.OK(data: 1); } } else { if (dt_StockInfo.StockStatus == (int)StockStatusEmun.组盘暂存) { if (locationinfoData.Count > 40) { return content = WebResponseContent.Instance.OK(data: 3); } else { return content = WebResponseContent.Instance.OK(data: 1); } } else { return content = WebResponseContent.Instance.Error($"库存已有该条码,条码信息:{generate.PalletCode}"); } } } else { return content = WebResponseContent.Instance.Error("未找到该类型的解析"); } } } catch (Exception ex) { throw; } } public WebResponseContent PalletQueryinventory() { WebResponseContent content = new WebResponseContent(); List locationinfoData = _basicService.LocationInfoService.Repository.QueryData(x => x.RoadwayNo=="2" && x.LocationStatus == LocationStatusEnum.Free.ObjToInt() && x.LocationType == (int)LocationTypeEnum.EmptyCube && x.EnableStatus == (int)EnableStatusEnum.Normal); if (locationinfoData.Count < 20) { return content = WebResponseContent.Instance.OK(data: 1); } else { return content = WebResponseContent.Instance.OK(data: 3); } } } }