|
using 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 WIDESEA_Common.OtherEnum;
|
using WIDESEA_Common.TaskEnum;
|
using WIDESEA_Common.OrderEnum;
|
using WIDESEA_Common.StockEnum;
|
using WIDESEA_Common.CommonEnum;
|
using WIDESEA_Common.LocationEnum;
|
using MailKit.Search;
|
using WIDESEA_External.Model;
|
using WIDESEA_Core.CodeConfigEnum;
|
using Microsoft.AspNetCore.Mvc;
|
using WIDESEA_DTO.ERP;
|
using WIDESEA_Common.MaterielEnum;
|
using WIDESEA_Common.WareHouseEnum;
|
using WIDESEA_DTO.MES;
|
using WIDESEA_DTO.Outbound;
|
using Microsoft.IdentityModel.Tokens;
|
|
namespace WIDESEA_TaskInfoService
|
{
|
public partial class TaskService
|
{
|
/// <summary>
|
/// 选择库存生成出库任务
|
/// </summary>
|
/// <param name="id"></param>
|
/// <returns></returns>
|
public WebResponseContent Outbound(List<int> ids)
|
{
|
WebResponseContent content = new WebResponseContent();
|
try
|
{
|
//获取选定库存
|
List<Dt_StockInfo> stockInfos = _stockRepository.StockInfoRepository.Db.Queryable<Dt_StockInfo>().Where(x => ids.Contains(x.Id) && x.StockStatus == StockStatusEmun.入库完成.ObjToInt() && x.MaterielInvOrgId == MaterielInvOrgEnum.老厂.ObjToInt()).ToList();
|
if (stockInfos == null || stockInfos.Count != ids.Count)
|
{
|
return content.Error($"未找到库存");
|
}
|
//获取库存货位
|
List<Dt_LocationInfo> locationInfos = _basicRepository.LocationInfoRepository.QueryData(x =>x.WarehouseId == WarehouseEnum.LLDYL.ObjToInt() && stockInfos.Select(x=>x.LocationCode).Contains(x.LocationCode) && x.LocationStatus == LocationStatusEnum.InStock.ObjToInt() && (x.EnableStatus == EnableStatusEnum.OnlyOut.ObjToInt() || x.EnableStatus == EnableStatusEnum.Normal.ObjToInt()));
|
if (locationInfos == null || locationInfos.Count != stockInfos.Count)
|
{
|
return content.Error($"货位出库条件不满足");
|
}
|
//任务生成
|
List<Dt_Task> tasks = GetTasks(stockInfos, TaskTypeEnum.OldYLOutbound);
|
if (tasks == null || tasks.Count <= 0)
|
{
|
return content.Error($"生成任务失败");
|
}
|
stockInfos.ForEach(x =>
|
{
|
x.StockStatus = StockStatusEmun.出库锁定.ObjToInt();
|
});
|
_unitOfWorkManage.BeginTran();
|
//更新库存状态
|
_stockRepository.StockInfoRepository.UpdateData(stockInfos);
|
//更新货位状态
|
_basicRepository.LocationInfoRepository.UpdateLocationStatus(locationInfos, LocationStatusEnum.Lock);
|
//加入货位变动记录
|
_recordService.LocationStatusChangeRecordSetvice.AddLocationStatusChangeRecord(locationInfos, LocationStatusEnum.Lock, LocationChangeType.OutboundAssignLocation, taskNums: tasks.Select(x => x.TaskNum).ToList());
|
//新建任务
|
BaseDal.AddData(tasks);
|
_unitOfWorkManage.CommitTran();
|
PushTasksToWCS(tasks);
|
content.OK();
|
}
|
catch (Exception ex)
|
{
|
content.Error(ex.Message);
|
}
|
return content;
|
}
|
/// <summary>
|
/// 向WMS申请出库AGV终点
|
/// </summary>
|
/// <param name="taskNum">任务号</param>
|
/// <returns></returns>
|
public WebResponseContent AssignOutTargetAddress(int taskNum)
|
{
|
WebResponseContent content = new WebResponseContent();
|
try
|
{
|
Dt_Task task = BaseDal.QueryFirst(x => x.TaskNum == taskNum);
|
if (task == null)
|
{
|
return WebResponseContent.Instance.Error($"未找到该入库任务");
|
}
|
if (_agvStationInfoRepository.QueryFirst(x => x.AGVStationCode == task.TargetAddress) != null)
|
{
|
return WebResponseContent.Instance.OK(data: task.TargetAddress);
|
}
|
Dt_AGVStationInfo? aGVStationInfo = _agvStationInfoRepository.QueryData(x => x.StationArea == nameof(AGVStationAreaEnum.一楼月台码头) && x.IsOccupied == WhetherEnum.False.ObjToInt()).OrderByDescending(x => x.Depth).FirstOrDefault();
|
if (aGVStationInfo==null)
|
{
|
return content.Error("未找到可分配的出库站点");
|
}
|
aGVStationInfo.IsOccupied = WhetherEnum.True.ObjToInt();
|
_agvStationInfoRepository.UpdateData(aGVStationInfo);
|
content.OK("成功",data: aGVStationInfo.AGVStationCode);
|
}
|
catch (Exception ex)
|
{
|
content.Error(ex.Message);
|
}
|
return content;
|
}
|
/// <summary>
|
/// 出库任务完成
|
/// </summary>
|
public WebResponseContent OutboundTaskCompleted(Dt_Task task)
|
{
|
try
|
{
|
Dt_Warehouse warehouse = _basicRepository.WarehouseRepository.QueryFirst(x => x.WarehouseId == task.WarehouseId);
|
if (warehouse.WarehouseCode == WarehouseEnum.LLDCP.ToString() || warehouse.WarehouseCode == WarehouseEnum.LLDFL.ToString()) //成品完成
|
{
|
Dt_LocationInfo locationInfoStart = _basicService.LocationInfoService.Repository.QueryFirst(x => x.LocationCode == task.SourceAddress);
|
if (locationInfoStart == null)
|
{
|
return WebResponseContent.Instance.Error($"未找到对应的起点货位信息");
|
}
|
Dt_ProStockInfo proStockInfo = _stockRepository.ProStockInfoRepository.Db.Queryable<Dt_ProStockInfo>().Where(x => x.PalletCode == task.PalletCode).Includes(x=>x.proStockInfoDetails).First();
|
if (proStockInfo != null && proStockInfo.StockStatus==StockStatusEmun.出库锁定.ObjToInt())
|
{
|
task.TaskStatus = TaskStatusEnum.Finish.ObjToInt();
|
_unitOfWorkManage.BeginTran();
|
proStockInfo.StockStatus = StockStatusEmun.出库完成.ObjToInt();
|
_stockRepository.ProStockInfoRepository.DeleteAndMoveIntoHty(proStockInfo,App.User.UserId > 0 ? WIDESEA_Core.Enums.OperateTypeEnum.人工完成 : WIDESEA_Core.Enums.OperateTypeEnum.自动完成);
|
if (proStockInfo.proStockInfoDetails!=null && proStockInfo.proStockInfoDetails.Count>0)
|
{
|
_stockRepository.ProStockInfoDetailRepository.DeleteAndMoveIntoHty(proStockInfo.proStockInfoDetails, App.User.UserId > 0 ? WIDESEA_Core.Enums.OperateTypeEnum.人工完成 : WIDESEA_Core.Enums.OperateTypeEnum.自动完成);
|
}
|
_basicService.LocationInfoService.UpdateLocationStatus(locationInfoStart, proStockInfo.PalletType, LocationStatusEnum.Free, proStockInfo.WarehouseId);
|
BaseDal.DeleteAndMoveIntoHty(task, App.User.UserId > 0 ? WIDESEA_Core.Enums.OperateTypeEnum.人工完成 : WIDESEA_Core.Enums.OperateTypeEnum.自动完成);
|
_unitOfWorkManage.CommitTran();
|
}
|
else
|
{
|
return WebResponseContent.Instance.Error($"未找到对应库存信息");
|
}
|
}
|
else//原料库完成
|
{
|
Dt_LocationInfo locationInfoStart = _basicService.LocationInfoService.Repository.QueryFirst(x => x.LocationCode == task.SourceAddress);
|
if (locationInfoStart == null)
|
{
|
return WebResponseContent.Instance.Error($"未找到对应的起点货位信息");
|
}
|
Dt_StockInfo stockInfo = _stockRepository.StockInfoRepository.QueryFirst(x => x.PalletCode == task.PalletCode);
|
if (stockInfo != null && stockInfo.StockStatus == StockStatusEmun.出库锁定.ObjToInt())
|
{
|
task.TaskStatus = TaskStatusEnum.Finish.ObjToInt();
|
_unitOfWorkManage.BeginTran();
|
if (task.TaskType == TaskTypeEnum.OldYLOutbound.ObjToInt())
|
{
|
stockInfo.StockStatus = StockStatusEmun.出库完成.ObjToInt();
|
stockInfo.WarehouseId = WarehouseEnum.LLDOldCache.ObjToInt();
|
_stockRepository.StockInfoRepository.UpdateData(stockInfo);
|
}
|
else
|
{
|
stockInfo.StockStatus = StockStatusEmun.出库完成.ObjToInt();
|
_stockRepository.StockInfoRepository.DeleteAndMoveIntoHty(stockInfo, App.User.UserId > 0 ? WIDESEA_Core.Enums.OperateTypeEnum.人工完成 : WIDESEA_Core.Enums.OperateTypeEnum.自动完成);
|
}
|
_basicService.LocationInfoService.UpdateLocationStatus(locationInfoStart, stockInfo.PalletType, LocationStatusEnum.Free, stockInfo.WarehouseId);
|
BaseDal.DeleteAndMoveIntoHty(task, App.User.UserId > 0 ? WIDESEA_Core.Enums.OperateTypeEnum.人工完成 : WIDESEA_Core.Enums.OperateTypeEnum.自动完成);
|
_unitOfWorkManage.CommitTran();
|
}
|
else
|
{
|
return WebResponseContent.Instance.Error($"未找到对应库存信息");
|
}
|
}
|
return WebResponseContent.Instance.OK();
|
}
|
catch (Exception ex)
|
{
|
_unitOfWorkManage.RollbackTran();
|
return WebResponseContent.Instance.Error(ex.Message);
|
}
|
}
|
/// <summary>
|
/// 库存数据转出库任务(原料/半成品)
|
/// </summary>
|
/// <param name="stockInfos"></param>
|
/// <returns></returns>
|
public List<Dt_Task> GetTasks(List<Dt_StockInfo> stockInfos, TaskTypeEnum taskType)
|
{
|
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);
|
if (!tasks.Exists(x => x.PalletCode == stockInfo.PalletCode))
|
{
|
Dt_Task task = new()
|
{
|
CurrentAddress = stockInfo.LocationCode,
|
Grade = 0,
|
PalletCode = stockInfo.PalletCode,
|
NextAddress = "",
|
Roadway = locationInfo.RoadwayNo,
|
SourceAddress = stockInfo.LocationCode,
|
TargetAddress = "",
|
TaskStatus = TaskStatusEnum.New.ObjToInt(),
|
TaskType = taskType.ObjToInt(),
|
TaskNum = BaseDal.GetTaskNum(nameof(SequenceEnum.SeqTaskNum)),
|
PalletType = stockInfo.PalletType,
|
WarehouseId = stockInfo.WarehouseId,
|
MaterielCode = stockInfo.MaterielCode,
|
RfidCode = stockInfo.RfidCode,
|
Quantity = stockInfo.StockLength,
|
};
|
if (stockInfo.MaterielWide>0)
|
{
|
task.TaskLength = (int)stockInfo.MaterielWide;
|
}
|
tasks.Add(task);
|
}
|
}
|
}
|
return tasks;
|
}
|
/// <summary>
|
/// 库存数据转出库任务(辅料/成品)
|
/// </summary>
|
public List<Dt_Task> GetTasks(List<Dt_ProStockInfo> stockInfos, TaskTypeEnum taskType,List<Dt_LocationInfo> locationInfos)
|
{
|
List<Dt_Task> tasks = new List<Dt_Task>();
|
for (int i = 0; i < stockInfos.Count; i++)
|
{
|
Dt_ProStockInfo stockInfo = stockInfos[i];
|
|
if (stockInfo != null)
|
{
|
Dt_LocationInfo locationInfo = locationInfos.FirstOrDefault(x => x.LocationCode == stockInfo.LocationCode);
|
if (!tasks.Exists(x => x.PalletCode == stockInfo.PalletCode))
|
{
|
Dt_Task task = new()
|
{
|
CurrentAddress = stockInfo.LocationCode,
|
Grade = 0,
|
PalletCode = stockInfo.PalletCode,
|
NextAddress = "",
|
Roadway = locationInfo.RoadwayNo,
|
SourceAddress = stockInfo.LocationCode,
|
TargetAddress = "",
|
TaskStatus = TaskStatusEnum.New.ObjToInt(),
|
TaskType = taskType.ObjToInt(),
|
TaskNum = BaseDal.GetTaskNum(nameof(SequenceEnum.SeqTaskNum)),
|
PalletType = stockInfo.PalletType,
|
WarehouseId = stockInfo.WarehouseId,
|
Quantity = 0,
|
};
|
tasks.Add(task);
|
}
|
}
|
}
|
return tasks;
|
}
|
/// <summary>
|
/// 成品出库
|
/// </summary>
|
/// <returns></returns>
|
public WebResponseContent RequestCPWMSTaskOut(string materialCode,int Count, string targetId)
|
{
|
WebResponseContent content = new WebResponseContent();
|
try
|
{
|
List<Dt_AGVStationInfo> aGVStationInfos = _agvStationInfoRepository.QueryData(x=>x.StationArea == targetId && x.IsOccupied==WhetherEnum.False.ObjToInt());
|
int useCount=aGVStationInfos.Count;
|
if (targetId == nameof(AGVStationAreaEnum.一楼月台码头))
|
{
|
|
//获取所有月台出库任务
|
List<Dt_Task> _TasksOut = BaseDal.QueryData(x => x.TaskType == TaskTypeEnum.OutProduct.ObjToInt() && x.TargetAddress == nameof(AGVStationAreaEnum.一楼月台码头));
|
useCount -= _TasksOut.Count;
|
}
|
if (useCount < Count)
|
{
|
return content.Error($"可用缓存数不足");
|
}
|
//获取货位
|
List<Dt_LocationInfo> locationInfos = _basicRepository.LocationInfoRepository.QueryData(x => x.WarehouseId == WarehouseEnum.LLDCP.ObjToInt() && (x.EnableStatus == EnableStatusEnum.OnlyOut.ObjToInt() || x.EnableStatus == EnableStatusEnum.Normal.ObjToInt()) && x.LocationStatus == LocationStatusEnum.InStock.ObjToInt());
|
List<Dt_ProStockInfo> stockInfos = new List<Dt_ProStockInfo>();
|
if (materialCode=="1")
|
{
|
stockInfos = BaseDal.Db.Queryable<Dt_ProStockInfo>().Where(x => locationInfos.Select(x => x.LocationCode).Contains(x.LocationCode) && x.StockStatus == StockStatusEmun.入库完成.ObjToInt() && x.ProStockAttribute==ProStockAttributeEnum.空托.ObjToInt()).Take(Count).ToList();
|
}
|
else
|
{
|
stockInfos = BaseDal.Db.Queryable<Dt_ProStockInfo>().Where(x => locationInfos.Select(x => x.LocationCode).Contains(x.LocationCode) && x.StockStatus == StockStatusEmun.入库完成.ObjToInt()).Includes(x => x.proStockInfoDetails)
|
.Where(x => x.proStockInfoDetails
|
.Any(v =>
|
v.ProductCode == materialCode)
|
).Take(Count).ToList();
|
}
|
|
if (stockInfos.Count!=Count)
|
{
|
return content.Error($"库存{materialCode}数量不足");
|
}
|
List<Dt_LocationInfo> AssignLocations = new List<Dt_LocationInfo>();
|
foreach (var item in stockInfos)
|
{
|
Dt_LocationInfo? locationInfo = locationInfos.FirstOrDefault(x => x.LocationCode == item.LocationCode);
|
if (locationInfo != null)
|
{
|
AssignLocations.Add(locationInfo);
|
item.StockStatus = StockStatusEmun.出库锁定.ObjToInt();
|
}
|
}
|
TaskTypeEnum typeEnum = targetId switch
|
{
|
nameof(AGVStationAreaEnum.一楼月台码头) => TaskTypeEnum.OutProduct,
|
nameof(AGVStationAreaEnum.一楼无纺织布) => TaskTypeEnum.OutWFB,
|
nameof(AGVStationAreaEnum.一楼无纺淋膜) => TaskTypeEnum.OutWFBLM,
|
nameof(AGVStationAreaEnum.一楼纸张淋膜) => TaskTypeEnum.OutPaperLM,
|
nameof(AGVStationAreaEnum.一楼分切) => TaskTypeEnum.OutFenQie,
|
nameof(AGVStationAreaEnum.一楼模切) => TaskTypeEnum.OutMoQie,
|
nameof(AGVStationAreaEnum.一楼冲切) => TaskTypeEnum.OutChongQie,
|
nameof(AGVStationAreaEnum.二楼纸袋) => TaskTypeEnum.OutCarton,
|
_ => throw new Exception("未找到对应任务")
|
};
|
if (materialCode == "1" && typeEnum!= TaskTypeEnum.OutCarton)
|
{
|
typeEnum = TaskTypeEnum.OutEmpty;
|
}
|
List<Dt_Task> tasks = GetTasks(stockInfos, typeEnum, AssignLocations);
|
if (tasks == null || tasks.Count <= 0)
|
{
|
return content.Error($"生成任务失败");
|
}
|
//成品任务不直接分配终点
|
if (targetId != nameof(AGVStationAreaEnum.一楼月台码头))
|
{
|
for (int i = 0; i < tasks.Count; i++)
|
{
|
aGVStationInfos[i].IsOccupied = WhetherEnum.True.ObjToInt();
|
tasks[i].TargetAddress = aGVStationInfos[i].AGVStationCode;
|
}
|
}
|
else
|
{
|
for (int i = 0; i < tasks.Count; i++)
|
{
|
tasks[i].TargetAddress = nameof(AGVStationAreaEnum.一楼月台码头);
|
}
|
}
|
//判断是否有出库单信息
|
_unitOfWorkManage.BeginTran();
|
//更新库存状态
|
_stockRepository.ProStockInfoRepository.UpdateData(stockInfos);
|
_agvStationInfoRepository.UpdateData(aGVStationInfos);
|
//更新货位状态
|
_basicRepository.LocationInfoRepository.UpdateLocationStatus(AssignLocations, LocationStatusEnum.Lock);
|
//加入货位变动记录
|
_recordService.LocationStatusChangeRecordSetvice.AddLocationStatusChangeRecord(AssignLocations, LocationStatusEnum.Lock, LocationChangeType.OutboundAssignLocation, taskNums: tasks.Select(x => x.TaskNum).ToList());
|
//新建任务
|
BaseDal.AddData(tasks);
|
_unitOfWorkManage.CommitTran();
|
PushTasksToWCS(tasks);
|
content.OK();
|
}
|
catch (Exception ex)
|
{
|
content.Error(ex.Message);
|
}
|
return content;
|
}
|
|
/// <summary>
|
/// 原料出库任务
|
/// </summary>
|
/// <param name="materielCode">物料代码</param>
|
/// <param name="materielWide">物料幅宽</param>
|
/// <param name="Count">卷数</param>
|
/// <returns></returns>
|
public WebResponseContent RequestYLWMSTaskOut(YLWMSTaskOutDTO yLWMSTaskOutDTO)
|
{
|
WebResponseContent content = new WebResponseContent();
|
try
|
{
|
if (yLWMSTaskOutDTO==null)
|
{
|
return content.Error("请填入出库信息");
|
}
|
//获取货位
|
List<Dt_LocationInfo> locationInfos = _basicRepository.LocationInfoRepository.QueryData(x => x.WarehouseId == WarehouseEnum.LLDYL.ObjToInt() && (x.EnableStatus == EnableStatusEnum.OnlyOut.ObjToInt() || x.EnableStatus == EnableStatusEnum.Normal.ObjToInt()) && x.LocationStatus == LocationStatusEnum.InStock.ObjToInt());
|
//获取对应库存
|
List<Dt_StockInfo> stockInfos = _stockRepository.StockInfoRepository.QueryData(x => locationInfos.Select(x => x.LocationCode).Contains(x.LocationCode) && x.MaterielCode == yLWMSTaskOutDTO.MaterialCode && x.MaterielWide == yLWMSTaskOutDTO.Wide && x.StockStatus == StockStatusEmun.入库完成.ObjToInt() && x.MaterielInvOrgId == MaterielInvOrgEnum.新厂.ObjToInt()).OrderBy(x => x.CreateDate).Take(yLWMSTaskOutDTO.Count).ToList();
|
if (stockInfos.Count< yLWMSTaskOutDTO.Count)
|
{
|
return content.Error($"库存{yLWMSTaskOutDTO.MaterialCode}数量不足");
|
}
|
List<Dt_LocationInfo> AssignLocations =new List<Dt_LocationInfo>();
|
foreach (var item in stockInfos)
|
{
|
Dt_LocationInfo? locationInfo = locationInfos.FirstOrDefault(x=>x.LocationCode==item.LocationCode);
|
if (locationInfo!=null)
|
{
|
AssignLocations.Add(locationInfo);
|
item.StockStatus = StockStatusEmun.出库锁定.ObjToInt();
|
}
|
}
|
List<Dt_Task> tasks = GetTasks(stockInfos, TaskTypeEnum.PrintYLOutbound);
|
if (tasks == null || tasks.Count <= 0)
|
{
|
return content.Error($"生成任务失败");
|
}
|
if (!string.IsNullOrEmpty(yLWMSTaskOutDTO.Address))
|
{
|
tasks.ForEach(x =>
|
{
|
x.TargetAddress= yLWMSTaskOutDTO.Address;
|
});
|
}
|
else
|
{
|
return content.Error("地址信息不能为空");
|
}
|
//判断是否有出库单信息
|
_unitOfWorkManage.BeginTran();
|
//更新库存状态
|
_stockRepository.StockInfoRepository.UpdateData(stockInfos);
|
//更新货位状态
|
_basicRepository.LocationInfoRepository.UpdateLocationStatus(AssignLocations, LocationStatusEnum.Lock);
|
//加入货位变动记录
|
_recordService.LocationStatusChangeRecordSetvice.AddLocationStatusChangeRecord(AssignLocations, LocationStatusEnum.Lock, LocationChangeType.OutboundAssignLocation,taskNums:tasks.Select(x=>x.TaskNum).ToList());
|
//新建任务
|
BaseDal.AddData(tasks);
|
_unitOfWorkManage.CommitTran();
|
PushTasksToWCS(tasks);
|
content.OK();
|
}
|
catch (Exception ex)
|
{
|
content.Error(ex.Message);
|
}
|
return content;
|
}
|
/// <summary>
|
/// 创建原纸生产排程出库任务
|
/// </summary>
|
/// <param name="keys"></param>
|
/// <returns></returns>
|
public WebResponseContent CreateBSTOutboundTasks(int[] keys)
|
{
|
WebResponseContent content=new WebResponseContent();
|
try
|
{
|
List<Dt_Task> tasks = new List<Dt_Task>();
|
List<Dt_StockInfo> stockInfos = new List<Dt_StockInfo>();
|
List<Dt_OutBSTOrderDetail> outBSTOrderDetails = new List<Dt_OutBSTOrderDetail>();
|
List<Dt_OutStockLockInfo> outStockLockInfos = new List<Dt_OutStockLockInfo>();
|
List<Dt_LocationInfo> locationInfos = new List<Dt_LocationInfo>();
|
//生成任务、库存等信息
|
(List<Dt_Task>, List<Dt_StockInfo>?, List<Dt_OutBSTOrderDetail>?, List<Dt_OutStockLockInfo>?, List<Dt_LocationInfo>?) result = OutboundTaskDataHandle(keys);
|
if (result.Item2 != null && result.Item2.Count > 0)
|
{
|
stockInfos.AddRange(result.Item2);
|
}
|
if (result.Item3 != null && result.Item3.Count > 0)
|
{
|
outBSTOrderDetails.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);
|
}
|
//处理出库数据
|
return GenerateOutboundTaskDataUpdate(tasks, stockInfos, outBSTOrderDetails, outStockLockInfos, locationInfos);
|
}
|
catch (Exception ex)
|
{
|
_unitOfWorkManage.RollbackTran();
|
content.Error(ex.Message);
|
}
|
return content;
|
}
|
|
/// <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_OutBSTOrderDetail>?, List<Dt_OutStockLockInfo>?, List<Dt_LocationInfo>?) OutboundTaskDataHandle(int[] keys)
|
{
|
List<Dt_Task> tasks = new List<Dt_Task>();
|
List<Dt_OutBSTOrderDetail> outboundOrderDetails = _outBSTOrderDetailRepository.QueryData(x => keys.Contains(x.Id));
|
|
if (outboundOrderDetails == null || outboundOrderDetails.Count == 0)
|
{
|
throw new Exception("未找到出库单明细信息");
|
}
|
Dt_OutBSTOrderDetail? outBSTOrderDetail = outboundOrderDetails.FirstOrDefault(x => x.OutBSTOrderDetailStatus != OutOrderStatusEnum.未开始.ObjToInt());
|
if (outBSTOrderDetail!=null)
|
{
|
throw new Exception($"出库明细物料{outBSTOrderDetail.MaterialNo},出库中或已完成");
|
}
|
List<Dt_StockInfo>? stockInfos = null;
|
List<Dt_OutBSTOrderDetail>? orderDetails = null;
|
List<Dt_OutStockLockInfo>? outStockLockInfos = null;
|
List<Dt_LocationInfo>? locationInfos = null;
|
|
//分配库存
|
(List<Dt_StockInfo>, List<Dt_OutBSTOrderDetail>, List<Dt_OutStockLockInfo>, List<Dt_LocationInfo>) result = _outBSTOrderDetailService.AssignStockOutbound(outboundOrderDetails);
|
if (result.Item1 != null && result.Item1.Count > 0)
|
{
|
Dt_OutBSTOrder outBSTOrder = _outBSTOrderRepository.QueryFirst(x => x.Id == outboundOrderDetails.FirstOrDefault().OutBSTOrderId);
|
//获取任务
|
tasks = GetTasks(result.Item1, TaskTypeEnum.OldYLOutbound);
|
tasks.ForEach(x =>
|
{
|
x.OrderNo = outBSTOrder.BoardMpsNo;
|
});
|
result.Item2.ForEach(x =>
|
{
|
x.OutBSTOrderDetailStatus = OutOrderStatusEnum.出库中.ObjToInt();
|
});
|
result.Item3.ForEach(x =>
|
{
|
x.Status = OutLockStockStatusEnum.出库中.ObjToInt();
|
});
|
|
stockInfos = result.Item1;
|
orderDetails = result.Item2;
|
outStockLockInfos = result.Item3;
|
locationInfos = result.Item4;
|
}
|
else
|
{
|
throw new Exception("无库存");
|
}
|
|
return (tasks, stockInfos, orderDetails, outStockLockInfos, locationInfos);
|
}
|
|
/// <summary>
|
/// 生成出库任务后数据更新到数据库
|
/// </summary>
|
public WebResponseContent GenerateOutboundTaskDataUpdate(List<Dt_Task> tasks, List<Dt_StockInfo>? stockInfos = null, List<Dt_OutBSTOrderDetail>? outboundOrderDetails = null, List<Dt_OutStockLockInfo>? outStockLockInfos = null, List<Dt_LocationInfo>? locationInfos = null)
|
{
|
try
|
{
|
_unitOfWorkManage.BeginTran();
|
|
BaseDal.AddData(tasks);
|
if (stockInfos != null && stockInfos.Count > 0 && outboundOrderDetails != null && outboundOrderDetails.Count > 0 && outStockLockInfos != null && outStockLockInfos.Count > 0 && locationInfos != null && locationInfos.Count > 0)
|
{
|
stockInfos.ForEach(x =>
|
{
|
x.StockStatus = StockStatusEmun.出库锁定.ObjToInt();
|
});
|
outboundOrderDetails.ForEach(x =>
|
{
|
x.OutBSTOrderDetailStatus = OutOrderStatusEnum.出库中.ObjToInt();
|
});
|
Dt_OutBSTOrder outBSTOrder = _outBSTOrderRepository.QueryFirst(x => x.Id == outboundOrderDetails.FirstOrDefault().OutBSTOrderId);
|
if (outBSTOrder.OutBSTOrderStatus == OutOrderStatusEnum.未开始.ObjToInt())
|
{
|
outBSTOrder.OutBSTOrderStatus = OutOrderStatusEnum.出库中.ObjToInt();
|
_outBSTOrderRepository.UpdateData(outBSTOrder);
|
}
|
WebResponseContent content = _outBSTOrderDetailService.LockOutboundStockDataUpdate(stockInfos, outboundOrderDetails, outStockLockInfos, locationInfos, tasks: tasks);
|
if (!content.Status)
|
{
|
_unitOfWorkManage.RollbackTran();
|
return content;
|
}
|
}
|
_unitOfWorkManage.CommitTran();
|
PushTasksToWCS(tasks);
|
return WebResponseContent.Instance.OK();
|
}
|
catch (Exception ex)
|
{
|
_unitOfWorkManage.RollbackTran();
|
return WebResponseContent.Instance.Error(ex.Message);
|
}
|
|
}
|
/// <summary>
|
/// 创建原纸生管排程出库任务
|
/// </summary>
|
/// <param name="keys"></param>
|
/// <returns></returns>
|
public WebResponseContent CreateSGOutboundTasks(int[] keys)
|
{
|
WebResponseContent content = new WebResponseContent();
|
try
|
{
|
List<Dt_Task> tasks = new List<Dt_Task>();
|
List<Dt_StockInfo> stockInfos = new List<Dt_StockInfo>();
|
List<Dt_OutSGOrderDetail> outSGOrderDetails = new List<Dt_OutSGOrderDetail>();
|
List<Dt_OutStockLockInfo> outStockLockInfos = new List<Dt_OutStockLockInfo>();
|
List<Dt_LocationInfo> locationInfos = new List<Dt_LocationInfo>();
|
//生成任务、库存等信息
|
(List<Dt_Task>, List<Dt_StockInfo>?, List<Dt_OutSGOrderDetail>?, List<Dt_OutStockLockInfo>?, List<Dt_LocationInfo>?) result = OutSGTaskDataHandle(keys);
|
if (result.Item2 != null && result.Item2.Count > 0)
|
{
|
stockInfos.AddRange(result.Item2);
|
}
|
if (result.Item3 != null && result.Item3.Count > 0)
|
{
|
outSGOrderDetails.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);
|
}
|
//处理出库数据
|
return GenerateOutboundTaskDataUpdate(tasks, stockInfos, outSGOrderDetails, outStockLockInfos, locationInfos);
|
}
|
catch (Exception ex)
|
{
|
_unitOfWorkManage.RollbackTran();
|
content.Error(ex.Message);
|
}
|
return content;
|
}
|
/// <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_OutSGOrderDetail>?, List<Dt_OutStockLockInfo>?, List<Dt_LocationInfo>?) OutSGTaskDataHandle(int[] keys)
|
{
|
List<Dt_Task> tasks = new List<Dt_Task>();
|
List<Dt_OutSGOrderDetail> outSGOrderDetails = _outboundRepository.OutSGOrderDetailRepository.QueryData(x => keys.Contains(x.Id));
|
|
if (outSGOrderDetails == null || outSGOrderDetails.Count == 0)
|
{
|
throw new Exception("未找到出库单明细信息");
|
}
|
Dt_OutSGOrderDetail? outBSTOrderDetail = outSGOrderDetails.FirstOrDefault(x => x.OutSGOrderDetailStatus != OutOrderStatusEnum.未开始.ObjToInt());
|
if (outBSTOrderDetail != null)
|
{
|
throw new Exception($"出库明细{nameof(Dt_OutSGOrderDetail.BoardMpsDetailId)}{outBSTOrderDetail.BoardMpsDetailId}物料{outBSTOrderDetail.MaterialNo},出库中或已完成");
|
}
|
List<Dt_StockInfo>? stockInfos = null;
|
List<Dt_OutSGOrderDetail>? orderDetails = null;
|
List<Dt_OutStockLockInfo>? outStockLockInfos = null;
|
List<Dt_LocationInfo>? locationInfos = null;
|
|
//分配库存
|
(List<Dt_StockInfo>, List<Dt_OutSGOrderDetail>, List<Dt_OutStockLockInfo>, List<Dt_LocationInfo>) result = _outboundService.OutSGOrderDetailService.AssignStockOutbound(outSGOrderDetails);
|
if (result.Item1 != null && result.Item1.Count > 0)
|
{
|
//获取任务
|
tasks = GetTasks(result.Item1, TaskTypeEnum.OldYLOutbound);
|
|
result.Item2.ForEach(x =>
|
{
|
x.OutSGOrderDetailStatus = OutOrderStatusEnum.出库中.ObjToInt();
|
});
|
result.Item3.ForEach(x =>
|
{
|
x.Status = OutLockStockStatusEnum.出库中.ObjToInt();
|
});
|
|
stockInfos = result.Item1;
|
orderDetails = result.Item2;
|
outStockLockInfos = result.Item3;
|
locationInfos = result.Item4;
|
}
|
else
|
{
|
throw new Exception("无库存");
|
}
|
|
return (tasks, stockInfos, orderDetails, outStockLockInfos, locationInfos);
|
}
|
/// <summary>
|
/// 处理出库数据
|
/// </summary>
|
/// <returns></returns>
|
public WebResponseContent GenerateOutboundTaskDataUpdate(List<Dt_Task> tasks, List<Dt_StockInfo>? stockInfos = null, List<Dt_OutSGOrderDetail>? outboundOrderDetails = null, List<Dt_OutStockLockInfo>? outStockLockInfos = null, List<Dt_LocationInfo>? locationInfos = null)
|
{
|
try
|
{
|
_unitOfWorkManage.BeginTran();
|
|
if (outStockLockInfos != null && outStockLockInfos.Any())
|
{
|
tasks.ForEach(x =>
|
{
|
string orderNos = string.Join(",", outStockLockInfos.Where(x => x.PalletCode == x.PalletCode).Select(x => x.OrderNo).Distinct());
|
x.OrderNo = orderNos;
|
});
|
}
|
BaseDal.AddData(tasks);
|
if (stockInfos != null && stockInfos.Count > 0 && outboundOrderDetails != null && outboundOrderDetails.Count > 0 && outStockLockInfos != null && outStockLockInfos.Count > 0 && locationInfos != null && locationInfos.Count > 0)
|
{
|
stockInfos.ForEach(x =>
|
{
|
x.StockStatus = StockStatusEmun.出库锁定.ObjToInt();
|
});
|
outboundOrderDetails.ForEach(x =>
|
{
|
x.OutSGOrderDetailStatus = OutOrderStatusEnum.出库中.ObjToInt();
|
});
|
List<Dt_OutSGOrder> outSGOrders = _outboundRepository.OutSGOrderRepository.QueryData(x => outboundOrderDetails.Select(x=>x.OutSGOrderId).Distinct().Contains(x.Id));
|
if (outSGOrders.Count<=0)
|
{
|
throw new Exception("未找到单据信息");
|
}
|
outSGOrders.ForEach(x =>
|
{
|
x.OutSGOrderStatus = OutOrderStatusEnum.出库中.ObjToInt();
|
});
|
_outboundRepository.OutSGOrderRepository.UpdateData(outSGOrders);
|
WebResponseContent content = _outboundService.OutSGOrderDetailService.LockOutboundStockDataUpdate(stockInfos, outboundOrderDetails, outStockLockInfos, locationInfos, tasks: tasks);
|
if (!content.Status)
|
{
|
_unitOfWorkManage.RollbackTran();
|
return content;
|
}
|
}
|
_unitOfWorkManage.CommitTran();
|
PushTasksToWCS(tasks);
|
return WebResponseContent.Instance.OK();
|
}
|
catch (Exception ex)
|
{
|
_unitOfWorkManage.RollbackTran();
|
return WebResponseContent.Instance.Error(ex.Message);
|
}
|
|
}
|
List<string> GradeCodes = new List<string>
|
{
|
"001"
|
};
|
/// <summary>
|
/// 接收MES领料计划
|
/// </summary>
|
/// <returns></returns>
|
public WebResponseContent ReceiveOutBound(List<OutMESOrderDTO> outMESOrderDTOs)
|
{
|
WebResponseContent content = new WebResponseContent();
|
try
|
{
|
if (outMESOrderDTOs == null || outMESOrderDTOs.Count <= 0)
|
{
|
return content.Error("领料计划传入信息为空");
|
}
|
outMESOrderDTOs.Select(x => x.OutDetailId);
|
List<Dt_Warehouse> warehouses = _basicRepository.WarehouseRepository.QueryData();
|
OutMESOrderDTO? CheckGradeCode = outMESOrderDTOs.FirstOrDefault(x => !GradeCodes.Contains(x.GradeCode));
|
if (CheckGradeCode != null)
|
{
|
return content.Error($"领料计划库区{nameof(OutMESOrderDTO.GradeCode)}:{CheckGradeCode.GradeCode}不存在");
|
}
|
OutMESOrderDTO? CheckOutDetailId = outMESOrderDTOs.FirstOrDefault(x => x.OutDetailId <= 0);
|
if (CheckOutDetailId != null)
|
{
|
return content.Error($"领料计划{nameof(OutMESOrderDTO.OutDetailId)}:{CheckOutDetailId.ProductOrderNo}需要大于0");
|
}
|
OutMESOrderDTO? CheckReqQuantity = outMESOrderDTOs.FirstOrDefault(x => x.ReqQuantity <= 0);
|
if (CheckReqQuantity != null)
|
{
|
return content.Error($"领料计划{nameof(OutMESOrderDTO.ReqQuantity)}:{CheckReqQuantity.ProductOrderNo}需要大于0");
|
}
|
//获取所有物料信息
|
List<Dt_MaterielInfo> materielInfos = _basicRepository.MaterielInfoRepository.QueryData(x => x.MaterielInvOrgId == MaterielInvOrgEnum.新厂.ObjToInt());
|
//获取所有领料计划
|
List<Dt_OutMESOrder> outMESOrders = _outboundRepository.OutMESOrderRepository.QueryData();
|
|
OutMESOrderDTO? CheckMaterialCode = outMESOrderDTOs.FirstOrDefault(x => !materielInfos.Select(x => x.MaterielCode).Contains(x.MaterialCode));
|
if (CheckMaterialCode != null)
|
{
|
return content.Error($"物料编码{nameof(OutMESOrderDTO.MaterialCode)}:{CheckMaterialCode.MaterialCode}信息不存在");
|
}
|
Dt_OutMESOrder? OldoutMESOrder = outMESOrders.FirstOrDefault(x => outMESOrderDTOs.Select(x => x.OutDetailId).Contains(x.OutDetailId));
|
if (OldoutMESOrder != null)
|
{
|
return content.Error($"领料计划{nameof(OutMESOrderDTO.OutDetailId)}:{OldoutMESOrder.OutDetailId}信息已存在");
|
}
|
List<Dt_OutMESOrder> AddoutMESOrders = outMESOrderDTOs.Select(x => _mapper.Map<Dt_OutMESOrder>(x)).ToList();
|
foreach (var item in AddoutMESOrders)
|
{
|
Dt_MaterielInfo materielInfo = materielInfos.FirstOrDefault(x => x.MaterielCode == item.MaterialCode);
|
item.WarehouseId = materielInfo.WarehouseId;
|
}
|
|
|
_unitOfWorkManage.BeginTran();
|
|
_outboundRepository.OutMESOrderRepository.AddData(AddoutMESOrders);
|
|
List<Dt_Task> tasks = new List<Dt_Task>();
|
List<Dt_StockInfo>? stockInfos = null;
|
List<Dt_OutMESOrder>? Orders = null;
|
List<Dt_OutStockLockInfo>? outStockLockInfos = null;
|
List<Dt_LocationInfo>? locationInfos = null;
|
{
|
//分配库存
|
(List<Dt_StockInfo>, List<Dt_OutMESOrder>, List<Dt_OutStockLockInfo>, List<Dt_LocationInfo>) result = _outboundService.OutMESOrderService.AssignStockOutbound(AddoutMESOrders);
|
if (result.Item1 != null && result.Item1.Count > 0)
|
{
|
//创建任务
|
tasks = GetTasks(result.Item1, TaskTypeEnum.PrintYLOutbound);
|
result.Item2.ForEach(x =>
|
{
|
OutOrderStatusEnum.出库中.ObjToInt();
|
});
|
result.Item3.ForEach(x =>
|
{
|
x.Status = OutLockStockStatusEnum.出库中.ObjToInt();
|
});
|
|
stockInfos = result.Item1;
|
Orders = result.Item2;
|
outStockLockInfos = result.Item3;
|
locationInfos = result.Item4;
|
}
|
else
|
{
|
throw new Exception("无库存");
|
}
|
}
|
int id = BaseDal.AddData(tasks);
|
|
if (stockInfos != null && stockInfos.Count > 0 && outStockLockInfos != null && outStockLockInfos.Count > 0 && locationInfos != null && locationInfos.Count > 0)
|
{
|
WebResponseContent contentResponse = _outboundService.OutMESOrderService.LockOutboundStockDataUpdate(stockInfos, Orders, outStockLockInfos, locationInfos, tasks: tasks);
|
|
if (!contentResponse.Status)
|
{
|
_unitOfWorkManage.RollbackTran();
|
return content.Error(contentResponse.Message);
|
}
|
}
|
|
_unitOfWorkManage.CommitTran();
|
|
return content.OK("接收成功");
|
}
|
catch (Exception ex)
|
{
|
content.Error(ex.Message);
|
}
|
return content;
|
}
|
}
|
}
|
