using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using WIDESEA_Core;
|
using WIDESEA_Core.Enums;
|
using WIDESEA_Core.Helper;
|
using WIDESEA_Model.Models;
|
|
namespace WIDESEA_TaskInfoService
|
{
|
public partial class TaskService
|
{
|
public WebResponseContent WMSGenerateNewOutboundTask(int[] keys)
|
{
|
try
|
{
|
List<Dt_Task> tasks = new List<Dt_Task>();
|
List<Dt_LocationInfo> locationInfos = new List<Dt_LocationInfo>();
|
List<Dt_OutStockLockInfo> outStockLockInfos = new List<Dt_OutStockLockInfo>();
|
|
List<Dt_NewOutboundOrderDetail> outboundOrderDetails = _outboundService.NewOutboundOrderDetailService.Repository.QueryData(x => keys.Contains(x.Id));
|
if (outboundOrderDetails == null || outboundOrderDetails.Count == 0)
|
{
|
throw new Exception("未找到出库单明细信息");
|
}
|
if (outboundOrderDetails.FirstOrDefault(x => x.OrderDetailStatus > OrderDetailStatusEnum.New.ObjToInt() && x.OrderDetailStatus != OrderDetailStatusEnum.AssignOverPartial.ObjToInt()) != null)
|
{
|
throw new Exception("所选出库单明细存在出库中或已完成");
|
}
|
var lpngroup = outboundOrderDetails.GroupBy(x => x.LPNNo);
|
|
|
List<Dt_NewOutboundOrderDetail> newOutboundOrderDetails = new List<Dt_NewOutboundOrderDetail>();
|
List<Dt_StockInfo> stockInfos = new List<Dt_StockInfo>();
|
|
foreach (var lpngroups in lpngroup)
|
{
|
string lpn = lpngroups.Key;
|
List<Dt_NewOutboundOrderDetail> detailsForThisLPN = _outboundService.NewOutboundOrderDetailService.Repository.QueryData(x => x.LPNNo == lpn && x.OrderDetailStatus == OrderDetailStatusEnum.New.ObjToInt());
|
if (detailsForThisLPN.Count == 0) continue;
|
newOutboundOrderDetails.AddRange(detailsForThisLPN);
|
Dt_StockInfo? stockInfo = _stockService.StockInfoService.Repository.QueryFirst(x => x.PalletCode == lpn);
|
if (stockInfo == null)
|
{
|
throw new Exception($"未找到库存信息，托盘号{lpn}");
|
}
|
stockInfos.Add(stockInfo);
|
|
}
|
|
if (stockInfos == null || stockInfos.Count == 0)
|
{
|
throw new Exception("未找到库存信息");
|
}
|
List<int> orderId = newOutboundOrderDetails.Select(x => x.OrderId).Distinct().ToList();
|
List<Dt_NewOutboundOrder> outboundOrders = _outboundService.NewOutboundOrderService.Repository.QueryData(x => orderId.Contains(x.Id));
|
var Newtasks = GetTasks(stockInfos, TaskTypeEnum.OutProduct);
|
List<Dt_StockInfoDetail> stockInfoDetails = _stockService.StockInfoDetailService.Repository.QueryData(x => stockInfos.Select(x => x.Id).Contains(x.StockId));
|
List<string> palletcodelpn = new List<string>();
|
foreach (var item in newOutboundOrderDetails)
|
{
|
Dt_StockInfo? stockInfo = stockInfos.FirstOrDefault(x => x.PalletCode == item.LPNNo);
|
if (stockInfo == null) continue;
|
Dt_StockInfoDetail? stockInfoDetail = stockInfoDetails.FirstOrDefault(x => x.StockId == stockInfo.Id && x.BatchNo == item.BatchNo);
|
if (stockInfoDetail == null) continue;
|
stockInfoDetail.OutboundQuantity += item.OrderQuantity;
|
item.LockQuantity += item.OrderQuantity;
|
item.OrderDetailStatus = OrderDetailStatusEnum.Outbound.ObjToInt();
|
var outboundOrder = outboundOrders.FirstOrDefault(x => x.Id == item.OrderId);
|
Dt_OutStockLockInfo outStockLockInfo = _outboundService.OutboundStockLockInfoService.GetOutStockLockInfo(outboundOrder, item, stockInfo, stockInfoDetail, item.OrderQuantity);
|
outStockLockInfo.Status = OutStockStatus.出库中.ObjToInt();
|
item.OrderDetailStatus = OrderDetailStatusEnum.Outbound.ObjToInt();
|
outboundOrder.OrderStatus = OutboundStatusEnum.出库中.ObjToInt();
|
stockInfo.StockStatus = StockStatusEmun.出库锁定.ObjToInt();
|
var task = Newtasks.FirstOrDefault(x => x.PalletCode == item.LPNNo);
|
if (task != null && !palletcodelpn.Contains(item.LPNNo))
|
{
|
if (outboundOrder.OrderType == 1)
|
{
|
task.TaskType = TaskTypeEnum.OutProduct.ObjToInt();
|
}
|
else if (outboundOrder.OrderType == 2)
|
{
|
task.TaskType = TaskTypeEnum.OutAllocate.ObjToInt();
|
}
|
task.OrderNo = outboundOrder.OrderNo;
|
tasks.Add(task);
|
palletcodelpn.Add(task.PalletCode);
|
}
|
outStockLockInfo.TaskNum = task.TaskNum;
|
outStockLockInfos.Add(outStockLockInfo);
|
}
|
locationInfos.AddRange(_basicService.LocationInfoService.Repository.GetLocationInfos(stockInfos.Select(x => x.LocationCode).ToList()));
|
|
_unitOfWorkManage.BeginTran();
|
|
BaseDal.AddData(tasks);
|
_stockService.StockInfoService.Repository.UpdateData(stockInfos);
|
_stockService.StockInfoDetailService.Repository.UpdateData(stockInfoDetails);
|
_outboundService.NewOutboundOrderDetailService.Repository.UpdateData(newOutboundOrderDetails);
|
_outboundService.NewOutboundOrderService.Repository.UpdateData(outboundOrders);
|
_outboundService.OutboundStockLockInfoService.Repository.AddData(outStockLockInfos);
|
_recordService.LocationStatusChangeRecordSetvice.AddLocationStatusChangeRecord(locationInfos, LocationStatusEnum.Lock.ObjToInt(), StockChangeType.Outbound.ObjToInt(), "", tasks?.Select(x => x.TaskNum).ToList());
|
_basicService.LocationInfoService.Repository.UpdateLocationStatus(locationInfos, LocationStatusEnum.Lock);
|
|
_unitOfWorkManage.CommitTran();
|
//将任务推送到WCS
|
return PushTasksWCS(tasks);
|
}
|
catch (Exception ex)
|
{
|
_unitOfWorkManage.RollbackTran();
|
return WebResponseContent.Instance.Error(ex.Message);
|
}
|
}
|
|
//合托出库
|
public WebResponseContent WMSGenerateSTOutboundTask(int[] keys)
|
{
|
try
|
{
|
List<Dt_Task> tasks = new List<Dt_Task>();
|
List<Dt_LocationInfo> locationInfos = new List<Dt_LocationInfo>();
|
List<Dt_OutStockLockInfo> outStockLockInfos = new List<Dt_OutStockLockInfo>();
|
|
List<Dt_StockInfo> stockInfos = _stockService.StockInfoService.Repository.QueryData(x => keys.Contains(x.Id) && x.StockStatus == StockStatusEmun.入库完成.ObjToInt());
|
if (stockInfos == null || stockInfos.Count == 0)
|
{
|
throw new Exception("未找到库存信息,或库存状态不为入库完成");
|
}
|
|
var Newtasks = GetTasks(stockInfos, TaskTypeEnum.OutSyncretism);
|
List<Dt_StockInfoDetail> stockInfoDetails = _stockService.StockInfoDetailService.Repository.QueryData(x => stockInfos.Select(x => x.Id).Contains(x.StockId));
|
foreach (var item in stockInfos)
|
{
|
Dt_StockInfo? stockInfo = stockInfos.FirstOrDefault(x => x.PalletCode == item.PalletCode);
|
if (stockInfo == null) continue;
|
|
stockInfo.StockStatus = StockStatusEmun.出库锁定.ObjToInt();
|
var task = Newtasks.FirstOrDefault(x => x.PalletCode == item.PalletCode);
|
tasks.Add(task);
|
}
|
locationInfos.AddRange(_basicService.LocationInfoService.Repository.GetLocationInfos(stockInfos.Select(x => x.LocationCode).ToList()));
|
|
_unitOfWorkManage.BeginTran();
|
|
BaseDal.AddData(tasks);
|
_stockService.StockInfoService.Repository.UpdateData(stockInfos);
|
_stockService.StockInfoDetailService.Repository.UpdateData(stockInfoDetails);
|
_recordService.LocationStatusChangeRecordSetvice.AddLocationStatusChangeRecord(locationInfos, LocationStatusEnum.Lock.ObjToInt(), StockChangeType.Outbound.ObjToInt(), "", tasks?.Select(x => x.TaskNum).ToList());
|
_basicService.LocationInfoService.Repository.UpdateLocationStatus(locationInfos, LocationStatusEnum.Lock);
|
|
_unitOfWorkManage.CommitTran();
|
//将任务推送到WCS
|
return PushTasksWCS(tasks);
|
}
|
catch (Exception ex)
|
{
|
_unitOfWorkManage.RollbackTran();
|
return WebResponseContent.Instance.Error(ex.Message);
|
}
|
}
|
}
|
}
|
