namespace WIDESEA_StorageOutOrderServices;
|
|
public class Dt_OutOrderService : ServiceBase<Dt_OutOrder, IDt_OutOrderRepository>, IDt_OutOrderService
|
{
|
private readonly LogFactory LogFactory = new LogFactory();
|
private readonly IUnitOfWorkManage _unitOfWorkManage;
|
private readonly IDt_OutOrderProductionService _outOrderProductionService;
|
private readonly IDt_OutOrderProductionDetailService _outOrderProductionDetailService;
|
private readonly IDt_OutOrderDtailService _outOrderDtailService;
|
private readonly IDt_OutOrderTransferRepository _OutOrderTransferRepository;
|
private readonly IDt_OutOrderTransferDetailRepository _OutOrderTransferDetailRepository;
|
private readonly IDt_MaterielInfoRepository _materielInfoRepository;
|
private readonly IStockInfoRepository _stockInfoRepository;
|
private readonly IDt_OutOrderAndStockRepository _outOrderAndStockRepository;
|
private readonly IDt_TaskRepository _taskRepository;
|
|
public Dt_OutOrderService(IDt_OutOrderRepository BaseDal,
|
IUnitOfWorkManage unitOfWorkManage,
|
IDt_OutOrderProductionService outOrderProductionService,
|
IDt_OutOrderProductionDetailService outOrderProductionDetailService,
|
IDt_OutOrderDtailService outOrderDtailService,
|
IDt_OutOrderTransferDetailRepository outOrderTransferDetailRepository,
|
IDt_OutOrderTransferRepository outOrderTransferRepository,
|
IDt_MaterielInfoRepository materielInfoRepository,
|
IStockInfoRepository stockInfoRepository,
|
IDt_OutOrderAndStockRepository outOrderAndStockRepository,
|
IDt_TaskRepository taskRepository) : base(BaseDal)
|
{
|
_unitOfWorkManage = unitOfWorkManage;
|
_outOrderProductionService = outOrderProductionService;
|
_outOrderProductionDetailService = outOrderProductionDetailService;
|
_outOrderDtailService = outOrderDtailService;
|
_OutOrderTransferDetailRepository = outOrderTransferDetailRepository;
|
_OutOrderTransferRepository = outOrderTransferRepository;
|
_materielInfoRepository = materielInfoRepository;
|
_stockInfoRepository = stockInfoRepository;
|
_outOrderAndStockRepository = outOrderAndStockRepository;
|
_taskRepository = taskRepository;
|
}
|
|
/// <summary>
|
/// 添加生产出库单
|
/// </summary>
|
/// <param name="model">出库数据</param>
|
/// <returns>成功或失败</returns>
|
public WebResponseContent AddOutOrderProduction(SaveModel model)
|
{
|
WebResponseContent content = new WebResponseContent();
|
try
|
{
|
LogFactory.GetLog("添加生产出库单").InfoFormat(true, "请求", JsonConvert.SerializeObject(model));
|
// 1. 构建生产出库单对象
|
var production = CreateProductionOrder(model.MainData);
|
LogFactory.GetLog("添加生产出库单").InfoFormat(true, "构建生产出库单对象", JsonConvert.SerializeObject(production));
|
|
// 2. 构建生产出库单明细列表
|
var productionDetails = CreateProductionDetails(model.DetailData);
|
LogFactory.GetLog("添加生产出库单").InfoFormat(true, "构建生产出库单明细对象", JsonConvert.SerializeObject(productionDetails));
|
|
// 3. 构建系统出库单对象
|
var order = CreateSystemOrder(production);
|
LogFactory.GetLog("添加生产出库单").InfoFormat(true, "构建系统出库单对象", JsonConvert.SerializeObject(order));
|
|
// 4. 构建系统出库单明细列表
|
var orderDetails = CreateSystemOrderDetails(productionDetails);
|
LogFactory.GetLog("添加生产出库单").InfoFormat(true, "构建系统出库单明细对象", JsonConvert.SerializeObject(orderDetails));
|
|
// 开启事务
|
_unitOfWorkManage.BeginTran();
|
|
// 5. 添加生产出库单并获取主键ID
|
var productionId = _outOrderProductionService.AddOrderProduction(production);
|
LogFactory.GetLog("添加生产出库单").InfoFormat(true, "添加生产出库单并获取主键ID", productionId);
|
|
// 6. 生产出库单明细绑定主表ID
|
productionDetails.ForEach(item => { item.ProductionOutOrderId = productionId; });
|
LogFactory.GetLog("添加生产出库单").InfoFormat(true, "生产出库单明细绑定主表ID", productionId);
|
|
// 7. 添加生产出库单明细
|
var detailAddResult = _outOrderProductionDetailService.AddData(productionDetails);
|
LogFactory.GetLog("添加生产出库单").InfoFormat(true, "添加生产出库单明细", detailAddResult.Status);
|
|
// 8. 系统出库单绑定生产出库单ID
|
order.UpperOutOrderId = productionId;
|
LogFactory.GetLog("添加生产出库单").InfoFormat(true, "系统出库单绑定生产出库单ID", productionId);
|
|
// 9. 添加系统出库单并获取主键ID
|
var orderId = BaseDal.AddData(order);
|
LogFactory.GetLog("添加生产出库单").InfoFormat(true, "添加系统出库单并获取主键ID", orderId);
|
|
// 10 . 系统出库单明细绑定主表ID
|
orderDetails.ForEach(item => { item.OutOrderId = orderId; });
|
LogFactory.GetLog("添加生产出库单").InfoFormat(true, "系统出库单明细绑定主表ID", orderId);
|
|
// 11. 添加系统出库单明细并返回结果
|
content = _outOrderDtailService.AddData(orderDetails);
|
LogFactory.GetLog("添加生产出库单").InfoFormat(true, "添加系统出库单明细并返回结果", content.Status);
|
|
if (content.Status && productionId > 0 && detailAddResult.Status && orderId > 0)
|
{
|
LogFactory.GetLog("添加生产出库单").InfoFormat(true, "所有操作执行完成提交事务", "无参数");
|
_unitOfWorkManage.CommitTran(); // 提交事务
|
}
|
else
|
{
|
LogFactory.GetLog("添加生产出库单").InfoFormat(true, "添加数据库失败,请检查数据是否正确", $"系统出库单明细:{content.Status},添加系统出库单:{orderId > 0},生产出库单:{productionId > 0},生产出库单明细:{detailAddResult.Status}");
|
throw new Exception("出库单添加失败" + $"系统出库单明细:{content.Status},添加系统出库单:{orderId > 0},生产出库单:{productionId > 0},生产出库单明细:{detailAddResult.Status}");
|
}
|
|
return content;
|
}
|
catch (Exception ex)
|
{
|
_unitOfWorkManage.RollbackTran(); // 回滚事务
|
LogFactory.GetLog("添加生产出库单").InfoFormat(true, $"系统异常，异常信息：{ex.Message}", "无参数");
|
return content.Error(ex.Message);
|
}
|
finally
|
{
|
LogFactory.GetLog("添加生产出库单").InfoFormat(true, "响应", JsonConvert.SerializeObject(content));
|
}
|
}
|
|
/// <summary>
|
/// 添加调拨出库单
|
/// </summary>
|
/// <param name="model">出库数据</param>
|
/// <returns>成功或失败</returns>
|
public WebResponseContent AddOutOrderTransfer(SaveModel model)
|
{
|
WebResponseContent content = new WebResponseContent();
|
try
|
{
|
// 1. 构建调拨出库单对象
|
var transfer = CreateTransferOrder(model.MainData);
|
LogFactory.GetLog("添加调拨出库单").InfoFormat(true, "构建调拨出库单对象", JsonConvert.SerializeObject(transfer));
|
|
// 2. 构建调拨出库单明细列表
|
var transferDetail = CreateTransferDetails(model.DetailData);
|
LogFactory.GetLog("添加调拨出库单").InfoFormat(true, "构建调拨出库单明细对象", JsonConvert.SerializeObject(transferDetail));
|
|
// 3. 构建系统出库单对象
|
var order = CreateSystemOrder(transfer);
|
LogFactory.GetLog("添加调拨出库单").InfoFormat(true, "构建系统出库单对象", JsonConvert.SerializeObject(order));
|
|
// 4. 构建系统出库单明细列表
|
var orderDetails = CreateSystemOrderDetails(transferDetail);
|
LogFactory.GetLog("添加调拨出库单").InfoFormat(true, "构建系统出库单明细对象", JsonConvert.SerializeObject(orderDetails));
|
|
// 添加事务
|
_unitOfWorkManage.BeginTran();
|
|
// 5. 添加调拨出库单并获取主键ID
|
var transferId = _OutOrderTransferRepository.AddData(transfer);
|
LogFactory.GetLog("添加调拨出库单").InfoFormat(true, "添加调拨出库单并获取主键ID", transferId);
|
|
// 6. 调拨出库单明细绑定主表ID
|
transferDetail.ForEach(item => { item.TransferOutOrderId = transferId; });
|
LogFactory.GetLog("添加调拨出库单").InfoFormat(true, "调拨出库单明细绑定主表ID", transferId);
|
|
// 7. 添加生产出库单明细
|
var detailAddResult = _OutOrderTransferDetailRepository.AddData(transferDetail);
|
LogFactory.GetLog("添加调拨出库单").InfoFormat(true, "添加生产出库单明细", detailAddResult);
|
|
// 8. 系统出库单绑定调拨出库单ID
|
order.UpperOutOrderId = transferId;
|
LogFactory.GetLog("添加调拨出库单").InfoFormat(true, "系统出库单绑定调拨出库单ID", transferId);
|
|
// 9. 添加系统出库单并获取主键ID
|
var orderId = BaseDal.AddData(order);
|
LogFactory.GetLog("添加调拨出库单").InfoFormat(true, "添加系统出库单并获取主键ID", orderId);
|
|
// 10 . 系统出库单明细绑定主表ID
|
orderDetails.ForEach(item => { item.OutOrderId = orderId; });
|
LogFactory.GetLog("添加调拨出库单").InfoFormat(true, "系统出库单明细绑定主表ID", orderId);
|
|
// 11. 添加系统出库单明细并返回结果
|
content = _outOrderDtailService.AddData(orderDetails);
|
LogFactory.GetLog("添加调拨出库单").InfoFormat(true, "添加系统出库单明细并返回结果", content.Status);
|
|
if (content.Status && transferId > 0 && detailAddResult > 0 && orderId > 0)
|
{
|
LogFactory.GetLog("添加调拨出库单").InfoFormat(true, "所有操作执行完成提交事务", "无参数");
|
_unitOfWorkManage.CommitTran(); // 提交事务
|
}
|
else
|
{
|
LogFactory.GetLog("添加调拨出库单").InfoFormat(true, "添加数据库失败,请检查数据是否正确", $"系统出库单明细:{content.Status},添加系统出库单:{orderId > 0},生产出库单:{transferId > 0},生产出库单明细:{detailAddResult > 0}");
|
throw new Exception("添加调拨出库单");
|
}
|
return content;
|
}
|
catch (Exception ex)
|
{
|
_unitOfWorkManage.RollbackTran(); // 回滚事务
|
LogFactory.GetLog("添加调拨出库单").InfoFormat(true, $"系统异常，异常信息：{ex.Message}", "无参数");
|
return content.Error(ex.Message);
|
}
|
}
|
|
/// <summary>
|
/// 根据出库单号查询出库订单
|
/// </summary>
|
/// <param name="orderNumber">出库单号</param>
|
/// <returns>出库订单</returns>
|
public WebResponseContent GetOutOrderByNumber(string orderNumber)
|
{
|
WebResponseContent content = new WebResponseContent();
|
var order = Db.Queryable<Dt_OutOrder>()
|
.Includes(x => x.OrderDetailList)
|
.Where(x => x.OrderNumber == orderNumber).First();
|
if (order == null)
|
content.Error($"订单编号{orderNumber}查询为空");
|
else
|
content.OK("查询成功", order);
|
return content;
|
}
|
|
/// <summary>
|
/// 根据订单分配出库库存
|
/// </summary>
|
/// <param name="orderNo">订单编号</param>
|
/// <returns></returns>
|
public async Task<WebResponseContent> GetOutboundStockAsync(string orderNo)
|
{
|
WebResponseContent content = new WebResponseContent();
|
try
|
{
|
// 获取订单
|
var order = await BaseDal.GetOutOrderByNumberAsync(orderNo);
|
LogFactory.GetLog("出库分配并创建任务").InfoFormat(true, "根据订单编号获取订单数据", JsonConvert.SerializeObject(order));
|
|
// 检查订单是否获取成功
|
if (order == null)
|
{
|
return content.Error("获取订单失败");
|
}
|
|
// 获取订单中的第一个物料编号
|
var materielInfo = await _materielInfoRepository.QueryFirstAsync(x => x.MaterielID == order.OrderDetailList.MaterialId);
|
LogFactory.GetLog("出库分配并创建任务").InfoFormat(true, "获取订单物料编号", JsonConvert.SerializeObject(materielInfo));
|
|
#region 先入先出
|
|
// 获取该物料所有可出库库存
|
var filteredStocks = await _stockInfoRepository.QueryDataAsync(x => true);
|
filteredStocks.OrderBy(x => x.CreateDate).ToList();
|
LogFactory.GetLog("出库分配并创建任务").InfoFormat(true, "获取该物料所有可出库库存", JsonConvert.SerializeObject(filteredStocks));
|
|
#endregion 先入先出
|
|
#region 查找靠近出库口库存
|
|
// 默认列越大越靠近出库口
|
filteredStocks = filteredStocks.OrderByDescending(x => x.LocationInfo.Column).OrderBy(x => x.CreateDate).ToList();
|
|
#endregion 查找靠近出库口库存
|
|
#region 一深位优先查找，再查找同列二深位
|
|
filteredStocks = PickStocks(filteredStocks);
|
|
#endregion 一深位优先查找，再查找同列二深位
|
|
// 创建任务列表
|
var (tasks, updateOrder, stock) = CreateTasks(order, filteredStocks);
|
LogFactory.GetLog("出库分配并创建任务").InfoFormat(true, "创建任务列表，修改订单分配数量，获取出库分配库存",
|
$"任务列表:{JsonConvert.SerializeObject(tasks)},订单列表：{JsonConvert.SerializeObject(updateOrder)},已分配库存：{JsonConvert.SerializeObject(stock)}");
|
|
// 更新库存状态
|
var stockList = UpdateStocks(stock);
|
LogFactory.GetLog("出库分配并创建任务").InfoFormat(true, "更新库存状态", JsonConvert.SerializeObject(stockList));
|
|
// 创建订单库存列表
|
List<Dt_OutOrderAndStock>? orderStocks = CreateOrderStock(stock, updateOrder);
|
LogFactory.GetLog("出库分配并创建任务").InfoFormat(true, "创建订单库存列表", JsonConvert.SerializeObject(orderStocks));
|
|
// 开始事务
|
_unitOfWorkManage.BeginTran();
|
|
// 更新库存
|
var isStockUpdated = _stockInfoRepository.UpdateData(stockList);
|
LogFactory.GetLog("出库分配并创建任务").InfoFormat(true, "事务更新库存", isStockUpdated);
|
|
// 更新订单
|
var isOrderUpdated = await BaseDal.OutOrderUpdatedAsync(updateOrder);
|
LogFactory.GetLog("出库分配并创建任务").InfoFormat(true, "事务更新订单", isOrderUpdated);
|
|
//添加订单库存
|
var isOrderStockCread = await _outOrderAndStockRepository.AddDataAsync(orderStocks) > 0;
|
LogFactory.GetLog("出库分配并创建任务").InfoFormat(true, "事务添加订单库存", isOrderStockCread);
|
|
// 创建任务
|
var isTaskCreated = await _taskRepository.Create(tasks);
|
LogFactory.GetLog("出库分配并创建任务").InfoFormat(true, "事务创建任务", isTaskCreated);
|
|
// 提交或回滚事务
|
if (isStockUpdated && isTaskCreated && isOrderUpdated && isOrderStockCread)
|
{
|
LogFactory.GetLog("出库分配并创建任务").InfoFormat(true, "数据处理完成，提交事务", "无参数");
|
_unitOfWorkManage.CommitTran();
|
}
|
else
|
{
|
LogFactory.GetLog("出库分配并创建任务").InfoFormat(true, "添加数据库失败,请检查数据是否正确,数据回滚", $"更新库存:{isStockUpdated},更新订单:{isOrderUpdated},添加订单库存:{isOrderStockCread},创建任务:{isTaskCreated}");
|
_unitOfWorkManage.RollbackTran();
|
throw new Exception("添加数据库失败,请检查数据是否正确,数据回滚");
|
}
|
|
return content.OK(data: orderStocks);
|
}
|
catch (Exception ex)
|
{
|
_unitOfWorkManage.RollbackTran();
|
LogFactory.GetLog("出库分配并创建任务").InfoFormat(true, $"系统异常，异常信息：{ex.Message}", "无参数");
|
return content.Error(ex.Message);
|
}
|
}
|
|
/// <summary>
|
/// 修改出库订单（导航修改）
|
/// </summary>
|
/// <param name="outOrder"></param>
|
/// <returns>是否成功</returns>
|
public async Task<bool> OutOrderUpdatedAsync(Dt_OutOrder outOrder)
|
{
|
return await BaseDal.OutOrderUpdatedAsync(outOrder);
|
}
|
|
#region 内部调用
|
|
/// <summary>
|
/// 一深位优先查找
|
/// </summary>
|
/// <param name="filteredStocks">可出库库存</param>
|
/// <returns>排序好的出库库存</returns>
|
public List<DtStockInfo> PickStocks(List<DtStockInfo> filteredStocks)
|
{
|
var oneDepthList = filteredStocks.Where(x => x.LocationInfo.Depth == 1).ToList();
|
var twoDepthList = filteredStocks.Where(x => x.LocationInfo.Depth == 2).ToList();
|
|
var results = new List<DtStockInfo>();
|
foreach (var oneDepth in oneDepthList)
|
{
|
// 将 Line 字符串转换为整数
|
int oneDepthLine = oneDepth.LocationInfo.Row;
|
|
// 计算相对行
|
int relativeLine = oneDepthLine % 2 == 1 ? oneDepthLine + 1 : oneDepthLine - 1;
|
|
// 查找最接近的二深位记录
|
var closestTwoDepth = twoDepthList
|
.Where(t => t.LocationInfo.Row == relativeLine)
|
.Where(x => x.LocationInfo.Column == oneDepth.LocationInfo.Column)
|
.Where(x => x.LocationInfo.Layer == oneDepth.LocationInfo.Layer)
|
.FirstOrDefault();
|
|
// 如果找到了最接近的二深位记录，将其与一深位一起添加到结果列表
|
if (closestTwoDepth != null)
|
{
|
results.Add(oneDepth);
|
results.Add(closestTwoDepth);
|
}
|
else
|
{
|
// 如果没有找到最接近的二深位记录，将一深位添加到结果列表
|
results.Add(oneDepth);
|
}
|
}
|
return results;
|
}
|
|
#endregion 内部调用
|
|
#region 私有方法
|
|
#region 生产出库单
|
|
/// <summary>
|
/// 根据主数据构建生产出库单对象。
|
/// </summary>
|
private Dt_OutOrderProduction CreateProductionOrder(Dictionary<string, object> mainData)
|
{
|
return new Dt_OutOrderProduction
|
{
|
OrderNumber = mainData.GetValueOrDefault("OrderNumber")?.ToString(),
|
WarehouseId = mainData.GetValueOrDefault("WarehouseId")?.ObjToInt() ?? 0,
|
Status = (int)OutOrderTypeEnum.Issue,
|
Remarks = mainData.GetValueOrDefault("Remarks")?.ToString(),
|
Creater = mainData.GetValueOrDefault("Creater")?.ToString(),
|
CreateDate = mainData.GetValueOrDefault("CreateDate")?.ObjToDate() ?? DateTime.Now,
|
OrderDate = mainData.GetValueOrDefault("OrderDate")?.ObjToDate() ?? DateTime.Now,
|
};
|
}
|
|
/// <summary>
|
/// 根据明细数据和生产出库单ID构建生产出库单明细列表。
|
/// </summary>
|
private List<Dt_OutOrderProductionDetail> CreateProductionDetails(List<Dictionary<string, object>> detailData)
|
{
|
var details = new List<Dt_OutOrderProductionDetail>();
|
foreach (var item in detailData)
|
{
|
var detail = new Dt_OutOrderProductionDetail
|
{
|
MaterialId = item.GetValueOrDefault("MaterialId")?.ObjToInt() ?? 0,
|
Quantity = item.GetValueOrDefault("Quantity")?.ObjToInt() ?? 0,
|
Remarks = item.GetValueOrDefault("Remarks")?.ToString(),
|
CreateDate = item.GetValueOrDefault("CreateDate")?.ObjToDate() ?? DateTime.Now,
|
Creater = item.GetValueOrDefault("Creater")?.ToString(),
|
BatchNumber = item.GetValueOrDefault("BatchNumber")?.ToString(),
|
};
|
details.Add(detail);
|
}
|
return details;
|
}
|
|
/// <summary>
|
/// 根据生产出库单对象和生产出库单ID构建系统出库单对象。
|
/// </summary>
|
private Dt_OutOrder CreateSystemOrder(Dt_OutOrderProduction production)
|
{
|
return new Dt_OutOrder
|
{
|
Status = production.Status,
|
CreateDate = DateTime.Now,
|
Creater = production.Creater,
|
OrderDate = DateTime.Now,
|
OrderNumber = production.OrderNumber,
|
Remarks = production.Remarks,
|
WarehouseId = production.WarehouseId,
|
};
|
}
|
|
/// <summary>
|
/// 根据生产出库单明细列表和系统出库单ID构建系统出库单明细列表。
|
/// </summary>
|
private List<Dt_OutOrderDetail> CreateSystemOrderDetails(List<Dt_OutOrderProductionDetail> productionDetails)
|
{
|
var orderDetails = new List<Dt_OutOrderDetail>();
|
foreach (var item in productionDetails)
|
{
|
var detail = new Dt_OutOrderDetail
|
{
|
AllocatedQuantity = 0,
|
BatchNumber = item.BatchNumber,
|
CompletedQuantity = 0,
|
CreateDate = item.CreateDate,
|
Creater = item.Creater,
|
MaterialId = item.MaterialId,
|
OutboundQuantity = item.Quantity,
|
Remarks = item.Remarks,
|
MaterialName = item.Remarks // 物料名称
|
};
|
orderDetails.Add(detail);
|
}
|
return orderDetails;
|
}
|
|
#endregion 生产出库单
|
|
#region 调拨出库单
|
|
/// <summary>
|
/// 根据主数据构建调拨出库单对象。
|
/// </summary>
|
private Dt_OutOrderTransfer CreateTransferOrder(Dictionary<string, object> mainData)
|
{
|
return new Dt_OutOrderTransfer
|
{
|
OrderNumber = mainData.GetValueOrDefault("OrderNumber")?.ToString(),
|
SourceWarehouseId = mainData.GetValueOrDefault("SourceWarehouseId")?.ObjToInt() ?? 0,
|
DestinationWarehouseId = mainData.GetValueOrDefault("WarehouseId")?.ObjToInt() ?? 0,
|
Status = (int)OutOrderTypeEnum.Allocate,
|
Remarks = mainData.GetValueOrDefault("Remarks")?.ToString(),
|
Creater = mainData.GetValueOrDefault("Creater")?.ToString(),
|
CreateDate = mainData.GetValueOrDefault("CreateDate")?.ObjToDate() ?? DateTime.Now,
|
OrderDate = mainData.GetValueOrDefault("OrderDate")?.ObjToDate() ?? DateTime.Now,
|
};
|
}
|
|
/// <summary>
|
/// 根据明细数据和调拨出库单ID构建调拨出库单明细列表。
|
/// </summary>
|
private List<Dt_OutOrderTransferDetail> CreateTransferDetails(List<Dictionary<string, object>> detailData)
|
{
|
var details = new List<Dt_OutOrderTransferDetail>();
|
foreach (var item in detailData)
|
{
|
var detail = new Dt_OutOrderTransferDetail
|
{
|
MaterialId = item.GetValueOrDefault("MaterialId")?.ObjToInt() ?? 0,
|
Quantity = item.GetValueOrDefault("Quantity")?.ObjToInt() ?? 0,
|
Remarks = item.GetValueOrDefault("Remarks")?.ToString(),
|
CreateDate = item.GetValueOrDefault("CreateDate")?.ObjToDate() ?? DateTime.Now,
|
Creater = item.GetValueOrDefault("Creater")?.ToString(),
|
BatchNumber = item.GetValueOrDefault("BatchNumber")?.ToString(),
|
};
|
details.Add(detail);
|
}
|
return details;
|
}
|
|
/// <summary>
|
/// 根据生产出库单对象和生产出库单ID构建系统出库单对象。
|
/// </summary>
|
private Dt_OutOrder CreateSystemOrder(Dt_OutOrderTransfer transfer)
|
{
|
return new Dt_OutOrder
|
{
|
Status = transfer.Status,
|
CreateDate = DateTime.Now,
|
Creater = transfer.Creater,
|
OrderDate = DateTime.Now,
|
OrderNumber = transfer.OrderNumber,
|
Remarks = transfer.Remarks,
|
WarehouseId = transfer.SourceWarehouseId,
|
};
|
}
|
|
/// <summary>
|
/// 根据生产出库单明细列表和系统出库单ID构建系统出库单明细列表。
|
/// </summary>
|
private List<Dt_OutOrderDetail> CreateSystemOrderDetails(List<Dt_OutOrderTransferDetail> transferDetails)
|
{
|
var orderDetails = new List<Dt_OutOrderDetail>();
|
foreach (var item in transferDetails)
|
{
|
var detail = new Dt_OutOrderDetail
|
{
|
AllocatedQuantity = 0,
|
BatchNumber = item.BatchNumber,
|
CompletedQuantity = 0,
|
CreateDate = item.CreateDate,
|
Creater = item.Creater,
|
MaterialId = item.MaterialId,
|
OutboundQuantity = item.Quantity,
|
Remarks = item.Remarks,
|
MaterialName = item.Remarks // 物料名称
|
};
|
orderDetails.Add(detail);
|
}
|
return orderDetails;
|
}
|
|
#endregion 调拨出库单
|
|
#region 出库分配
|
|
/// <summary>
|
/// 创建任务列表
|
/// </summary>
|
/// <param name="order">订单对象</param>
|
/// <param name="filteredStocks">筛选后的库存列表</param>
|
/// <returns>【任务列表,更新分配数量订单,创建任务的库存】</returns>
|
private (List<Dt_Task>, Dt_OutOrder, List<DtStockInfo>) CreateTasks(Dt_OutOrder order, List<DtStockInfo> filteredStocks)
|
{
|
var tasks = new List<Dt_Task>();
|
var stocks = new List<DtStockInfo>();
|
|
foreach (var stock in filteredStocks)
|
{
|
// 如果已分配数量达到出库数量，停止分配
|
if (order.OrderDetailList.AllocatedQuantity >= order.OrderDetailList.OutboundQuantity)
|
break;
|
|
// 如果托盘任务已存在，跳过
|
if (_taskRepository.QueryFirst(x => x.PalletCode == stock.PalletCode) != null)
|
continue;
|
|
// 创建任务
|
tasks.Add(new Dt_Task
|
{
|
CreateDate = DateTime.Now, // 创建时间
|
Creater = App.User.UserName, // 创建人
|
CurrentAddress = stock.LocationCode, //当前位置
|
Dispatchertime = DateTime.Now, //调度时间（任务下发时间）
|
Grade = 1, // 等级
|
MaterialNo = stock.StockInfoDetails[0].MaterielCode, // 物料号
|
NextAddress = stock.LocationCode, // 下一位置
|
PalletCode = stock.PalletCode, //托盘号
|
Remark = stock.Remark, //备注
|
Roadway = stock.LocationInfo.RoadwayNo, //巷道
|
SourceAddress = stock.LocationCode, //来源位置
|
TargetAddress = order.OrderDetailList.Remarks, //目标地址
|
TaskNum = _taskRepository.GetTaskNo().Result, //任务号
|
TaskState = (int)TaskOutStatusEnum.OutNew, //任务状态
|
TaskType = (int)TaskTypeEnum.Outbound, //任务类型
|
});
|
|
// 更新已分配数量
|
order.OrderDetailList.AllocatedQuantity += stock.StockInfoDetails.Sum(x => x.StockQuantity);
|
stocks.Add(stock);
|
}
|
|
return (tasks, order, stocks);
|
}
|
|
/// <summary>
|
/// 更新库存状态
|
/// </summary>
|
/// <param name="filteredStocks">筛选后的库存列表</param>
|
/// <returns>更新后的库存列表</returns>
|
private List<DtStockInfo> UpdateStocks(List<DtStockInfo> filteredStocks)
|
{
|
var updatedStocks = new List<DtStockInfo>();
|
|
foreach (var stock in filteredStocks)
|
{
|
// 更新库存状态
|
stock.LocationInfo.LocationStatus = (int)LocationEnum.Lock;
|
stock.StockInfoDetails.ForEach(x =>
|
{
|
x.Status = (int)StockStateEmun.出库锁定;
|
});
|
updatedStocks.Add(stock);
|
}
|
|
return updatedStocks;
|
}
|
|
/// <summary>
|
/// 创建订单库存列表
|
/// </summary>
|
/// <param name="stock">筛选后的库存列表</param>
|
/// <param name="order">订单对象</param>
|
/// <returns>订单库存列表</returns>
|
private List<Dt_OutOrderAndStock> CreateOrderStock(List<DtStockInfo> stock, Dt_OutOrder order)
|
{
|
var orderStocks = new List<Dt_OutOrderAndStock>();
|
foreach (var item in stock)
|
{
|
orderStocks.Add(new Dt_OutOrderAndStock()
|
{
|
AllocatedQuantity = order.OrderDetailList.AllocatedQuantity,
|
MaterialNo = item.StockInfoDetails[0].MaterielCode,
|
MaterialName = order.OrderDetailList.MaterialName,
|
OrderNumber = order.OrderNumber,
|
OutboundQuantity = order.OrderDetailList.OutboundQuantity,
|
PalletCode = item.PalletCode,
|
PalletQuantity = item.StockInfoDetails.Sum(x => x.StockQuantity),
|
State = item.StockInfoDetails[0].Status,
|
BatchNumber = order.OrderDetailList.BatchNumber,
|
CompletedQuantity = order.OrderDetailList.CompletedQuantity,
|
Creater = App.User.UserName,
|
CreateDate = DateTime.Now,
|
GroupId = item.Id,
|
LocationCode = item.LocationInfo.LocationCode,
|
OutOrderId = order.Id,
|
});
|
}
|
|
return orderStocks;
|
}
|
|
#endregion 出库分配
|
|
#endregion 私有方法
|
}
|
