using AutoMapper;
|
using Newtonsoft.Json;
|
using SqlSugar;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Reflection.Metadata;
|
using System.Text;
|
using System.Threading.Tasks;
|
using WIDESEA_Core;
|
using WIDESEA_Core.BaseRepository;
|
using WIDESEA_Core.BaseServices;
|
using WIDESEA_Core.Enums;
|
using WIDESEA_Core.Helper;
|
using WIDESEA_Core.Utilities;
|
using WIDESEA_DTO;
|
using WIDESEA_DTO.Inbound;
|
using WIDESEA_DTO.WCSInfo;
|
using WIDESEA_IBasicService;
|
using WIDESEA_IInboundRepository;
|
using WIDESEA_IInboundService;
|
using WIDESEA_IStockService;
|
using WIDESEA_ITaskInfoRepository;
|
using WIDESEA_Model.Models;
|
using WIDESEAWCS_DTO.WCSInfo;
|
|
namespace WIDESEA_InboundService
|
{
|
public partial class InboundOrderService : ServiceBase<Dt_InboundOrder, IInboundOrderRepository>, IInboundOrderService
|
{
|
|
/// <summary>
|
/// 根据入库单号获取入库单(含明细)
|
/// </summary>
|
/// <param name="inboundOrderNo"></param>
|
/// <returns></returns>
|
public Dt_InboundOrder GetInboundOrder(string inboundOrderNo)
|
{
|
return BaseDal.Db.Queryable<Dt_InboundOrder>().Includes(x => x.Details).First(x => x.OrderNo == inboundOrderNo);
|
}
|
public bool UpdateDataWithDetail(Dt_InboundOrder inboundOrder)
|
{
|
return Db.UpdateNav(inboundOrder).Include(x => x.Details).ExecuteCommand();
|
}
|
/// <summary>
|
/// 空托组盘入库
|
/// </summary>
|
/// <param name="materielGroupDTO"></param>
|
/// <returns></returns>
|
public WebResponseContent PdaAddEmptyStockInfo(string barcode)
|
{
|
try
|
{
|
#region 添加一个空托组盘信息及空托任务并下发给WCS
|
Dt_StockInfo stockInfo = _stockService.StockInfoService.Repository.GetStockInfo(barcode);
|
if (stockInfo != null) throw new Exception($"托盘号【{stockInfo.PalletCode}】已存在组盘信息");
|
Dt_Task task = _taskRepository.QueryFirst(x => x.PalletCode == barcode && x.TaskType == TaskTypeEnum.PalletInbound.ObjToInt());
|
if (task == null)
|
{
|
task = new Dt_Task()
|
{
|
CurrentAddress = "1001",
|
NextAddress = "SC01",
|
SourceAddress = "1001",
|
TargetAddress = "SC01",
|
Creater = "System",
|
PalletCode = barcode,
|
Roadway = "SC01",
|
OrderNo = DateTime.Now.ToString("yyMMdd"),
|
TaskNum = _taskRepository.GetTaskNum(nameof(SequenceEnum.SeqTaskNum)),
|
TaskState = InTaskStatusEnum.AGV_InFinish.ObjToInt(),
|
TaskType = TaskTypeEnum.PalletInbound.ObjToInt(),
|
CreateDate = DateTime.Now,
|
Dispatchertime = DateTime.Now,
|
};
|
Db.Ado.BeginTran();
|
WebResponseContent content = _stockService.StockInfoService.AddStockEmpty(barcode);
|
if (!content.Status) throw new Exception(content.Message);
|
_taskRepository.AddData(task);
|
List<WMSTaskDTO> wMSTaskDTOs = _mapper.Map<List<WMSTaskDTO>>(new List<Dt_Task> { task });
|
var ResultData = HttpHelper.PostAsync(WCSInterfaceAddress.ReceiveTask, wMSTaskDTOs.ToJson(), headers: new Dictionary<string, string>());
|
if (ResultData.Result == null) throw new Exception($"向WCS下发空托入库任务超时");
|
content = JsonConvert.DeserializeObject<WebResponseContent>(ResultData.Result);
|
if (content == null) throw new Exception($"下发空托入库任务WCS无响应");
|
if (!content.Status) throw new Exception(content.Message);
|
Db.Ado.CommitTran();
|
}
|
else
|
throw new Exception($"托盘号【{barcode}】已存在任务");
|
#endregion
|
return WebResponseContent.Instance.OK();
|
}
|
catch (Exception ex)
|
{
|
Db.Ado.RollbackTran();
|
return WebResponseContent.Instance.Error(ex.Message);
|
}
|
}
|
/// <summary>
|
/// PDA组盘
|
/// 单种物料组盘
|
/// </summary>
|
/// <param name="pdaMaterielGroupDTO"></param>
|
/// <returns></returns>
|
public WebResponseContent PdaAddStockInfo(PdaMaterielGroupDTO pdaMaterielGroupDTO)
|
{
|
WebResponseContent content = new WebResponseContent();
|
try
|
{
|
Dt_MaterielInfo materielInfo = _basicService.MaterielInfoService.GetMaterielInfo(pdaMaterielGroupDTO.MaterielCode);
|
|
Dt_InboundOrder inboundOrder = GetInboundOrder(pdaMaterielGroupDTO.OrderNo);
|
|
Dt_StockInfo? stockInfo = _stockService.StockInfoService.GetStockByPalletCode(pdaMaterielGroupDTO.PalletCode);
|
|
var result = CheckMaterielGroupParam(pdaMaterielGroupDTO, materielInfo, inboundOrder, stockInfo);
|
if (!result.Item1) return content = WebResponseContent.Instance.Error(result.Item2);
|
|
if (stockInfo == null)
|
{
|
stockInfo = new Dt_StockInfo();
|
stockInfo.Details = new List<Dt_StockInfoDetail>();
|
}
|
var stockInfoDetail = stockInfo.Details.Where(x => pdaMaterielGroupDTO.MaterielCode == x.MaterielCode && x.BatchNo == pdaMaterielGroupDTO.BatchNo).FirstOrDefault();
|
if (stockInfoDetail == null)
|
{
|
stockInfoDetail = new Dt_StockInfoDetail()
|
{
|
Status = StockStatusEmun.组盘暂存.ObjToInt(),
|
OrderNo = inboundOrder.OrderNo,
|
StockId = stockInfo.Id != 0 ? stockInfo.Id : 0,
|
MaterielName = materielInfo.MaterielName,
|
MaterielCode = materielInfo.MaterielCode,
|
BatchNo = pdaMaterielGroupDTO.BatchNo,
|
StockQuantity = pdaMaterielGroupDTO.ReceiptQuantity,
|
SerialNumber = $"{inboundOrder.OrderNo} | {materielInfo.MaterielCode} | {pdaMaterielGroupDTO.BatchNo} | {pdaMaterielGroupDTO.ReceiptQuantity}",
|
Creater = "System"
|
};
|
if (stockInfo.Id == 0)
|
{
|
stockInfo.PalletCode = pdaMaterielGroupDTO.PalletCode;
|
stockInfo.StockStatus = StockStatusEmun.组盘暂存.ObjToInt();
|
stockInfo.Creater = "System";
|
}
|
stockInfo.Details.Add(stockInfoDetail);
|
}
|
else
|
{
|
stockInfoDetail.StockQuantity += pdaMaterielGroupDTO.ReceiptQuantity;
|
stockInfoDetail.SerialNumber = $"{inboundOrder.OrderNo} | {materielInfo.MaterielCode} | {pdaMaterielGroupDTO.BatchNo} | {(int)stockInfoDetail.StockQuantity}";
|
}
|
|
|
Dt_InboundOrderDetail inboundOrderDetail = inboundOrder.Details.Where(x => materielInfo.MaterielCode == x.MaterielCode && x.BatchNo == pdaMaterielGroupDTO.BatchNo).FirstOrDefault();//订单详情
|
|
inboundOrderDetail.ReceiptQuantity++;
|
inboundOrderDetail.OrderDetailStatus = inboundOrderDetail.OverInQuantity == inboundOrderDetail.OrderQuantity ? OrderDetailStatusEnum.Over.ObjToInt() : OrderDetailStatusEnum.GroupAndInbound.ObjToInt();
|
|
if (inboundOrder.Details.FirstOrDefault(x => x.OrderDetailStatus != OrderDetailStatusEnum.Over.ObjToInt()) == null)
|
{
|
inboundOrder.OrderStatus = InboundStatusEnum.入库完成.ObjToInt();
|
}
|
else if (inboundOrder.OrderStatus == InboundStatusEnum.未开始.ObjToInt())
|
{
|
inboundOrder.OrderStatus = InboundStatusEnum.入库中.ObjToInt();
|
}
|
|
_unitOfWorkManage.BeginTran();
|
UpdateData(inboundOrder);
|
_inboundOrderDetailService.UpdateData(inboundOrderDetail);
|
_stockService.StockInfoService.AddMaterielGroup(stockInfo);
|
_unitOfWorkManage.CommitTran();
|
content.OK();
|
}
|
catch (Exception ex)
|
{
|
_unitOfWorkManage.RollbackTran();
|
content.Error(ex.Message);
|
}
|
return content;
|
}
|
|
/// <summary>
|
/// MES下发组盘
|
/// </summary>
|
/// <param name="materielGroupDTO"></param>
|
/// <returns></returns>
|
public WebResponseContent MaterielGroup(MaterielGroupDTO materielGroupDTO)
|
{
|
WebResponseContent content = new WebResponseContent();
|
try
|
{
|
List<MatSerialNumberDTO> matSerialNumberDTOs = CodeAnalysisHelper.CodeAnalysis<MatSerialNumberDTO>(AnalysisCode.InnerCode, materielGroupDTO.SerialNumbers);
|
(bool, string, object?) result2 = ModelValidate.ValidateModelData(matSerialNumberDTOs);
|
if (!result2.Item1) return content = WebResponseContent.Instance.Error(result2.Item2);
|
|
List<string> materielCodes = matSerialNumberDTOs.GroupBy(x => x.MaterielCode).Select(x => x.Key).ToList();
|
|
List<Dt_MaterielInfo> materielInfos = _basicService.MaterielInfoService.GetMaterielInfos(materielCodes);
|
|
Dt_InboundOrder inboundOrder = GetInboundOrder(materielGroupDTO.OrderNo);
|
|
|
Dt_StockInfo? stockInfo = _stockService.StockInfoService.GetStockByPalletCode(materielGroupDTO.PalletCode);
|
|
(bool, string, object?) result = CheckMaterielGroupParam(materielGroupDTO, matSerialNumberDTOs, materielInfos, materielCodes, inboundOrder, stockInfo);
|
if (!result.Item1) return content = WebResponseContent.Instance.Error(result.Item2);
|
|
if (stockInfo == null)
|
{
|
stockInfo = new Dt_StockInfo();
|
stockInfo.Details = new List<Dt_StockInfoDetail>();
|
}
|
|
List<Dt_StockInfoDetail> stockInfoDetails = _mapper.Map<List<Dt_StockInfoDetail>>(matSerialNumberDTOs);
|
stockInfoDetails.ForEach(x =>
|
{
|
x.Status = StockStatusEmun.组盘暂存.ObjToInt();
|
x.OrderNo = inboundOrder.OrderNo;
|
x.MaterielName = materielInfos.FirstOrDefault(v => v.MaterielCode == x.MaterielCode)?.MaterielName ?? "";
|
x.StockId = stockInfo.Id != 0 ? stockInfo.Id : 0;
|
});
|
if (stockInfo.Id == 0)
|
{
|
stockInfo.PalletCode = materielGroupDTO.PalletCode;
|
stockInfo.StockStatus = StockStatusEmun.组盘暂存.ObjToInt();
|
}
|
stockInfo.Details.AddRange(stockInfoDetails);
|
|
List<Dt_InboundOrderDetail> inboundOrderDetails = new List<Dt_InboundOrderDetail>();
|
for (int i = 0; i < materielCodes.Count; i++)
|
{
|
decimal stockQuantity = stockInfoDetails.Where(x => x.MaterielCode == materielCodes[i]).Sum(x => x.StockQuantity);
|
inboundOrderDetails.AddRange(_inboundOrderDetailService.UpdateReceiptQuantity(inboundOrder.Details.Where(x => x.MaterielCode == materielCodes[i]).ToList(), stockQuantity));
|
}
|
List<int> updateDetailIds = inboundOrderDetails.Select(x => x.Id).ToList();
|
if (inboundOrderDetails.FirstOrDefault(x => x.OrderDetailStatus != OrderDetailStatusEnum.Over.ObjToInt()) == null && inboundOrder.Details.FirstOrDefault(x => !updateDetailIds.Contains(x.Id) && x.OrderDetailStatus != OrderDetailStatusEnum.Over.ObjToInt()) == null)
|
{
|
inboundOrder.OrderStatus = InboundStatusEnum.入库完成.ObjToInt();
|
}
|
else if (inboundOrder.OrderStatus == InboundStatusEnum.未开始.ObjToInt())
|
{
|
inboundOrder.OrderStatus = InboundStatusEnum.入库中.ObjToInt();
|
}
|
|
content = MaterielGroupUpdateData(inboundOrder, inboundOrderDetails, stockInfo);
|
}
|
catch (Exception ex)
|
{
|
content = WebResponseContent.Instance.Error(ex.Message);
|
}
|
finally
|
{
|
|
}
|
return content;
|
}
|
|
/// <summary>
|
/// 组盘数据更新
|
/// </summary>
|
/// <param name="inboundOrder">入库单</param>
|
/// <param name="inboundOrderDetails">入库单明细</param>
|
/// <param name="stockInfo">组盘数据</param>
|
/// <returns></returns>
|
public WebResponseContent MaterielGroupUpdateData(Dt_InboundOrder inboundOrder, List<Dt_InboundOrderDetail> inboundOrderDetails, Dt_StockInfo stockInfo)
|
{
|
try
|
{
|
_unitOfWorkManage.BeginTran();
|
UpdateData(inboundOrder);
|
_inboundOrderDetailService.UpdateData(inboundOrderDetails);
|
_stockService.StockInfoService.AddMaterielGroup(stockInfo);
|
_unitOfWorkManage.CommitTran();
|
return WebResponseContent.Instance.OK();
|
}
|
catch (Exception ex)
|
{
|
_unitOfWorkManage.RollbackTran();
|
return WebResponseContent.Instance.Error(ex.Message);
|
}
|
}
|
/// <summary>
|
/// 验证PDA组盘数据
|
/// </summary>
|
/// <param name="materielGroupDTO"></param>
|
/// <param name="materielInfo"></param>
|
/// <param name="inboundOrder"></param>
|
/// <param name="stockInfo"></param>
|
/// <returns></returns>
|
public (bool, string, object?) CheckMaterielGroupParam(PdaMaterielGroupDTO materielGroupDTO, Dt_MaterielInfo materielInfo, Dt_InboundOrder inboundOrder, Dt_StockInfo? stockInfo)
|
{
|
if (_taskRepository.QueryFirst(x => x.PalletCode == materielGroupDTO.PalletCode) != null)
|
{
|
return (false, "该托盘号已有任务", materielGroupDTO);
|
}
|
if (stockInfo != null && !string.IsNullOrEmpty(stockInfo.LocationCode) && stockInfo.StockStatus != StockStatusEmun.组盘暂存.ObjToInt())
|
{
|
return (false, "已上架的托盘不能再次组盘", materielGroupDTO);
|
}
|
if (stockInfo != null)
|
{
|
return (false, "已组盘的托盘不能再次组盘", materielGroupDTO);
|
}
|
if (materielInfo == null)
|
{
|
return (false, "有物料信息未录入，请录入物料信息", materielGroupDTO);
|
}
|
if (inboundOrder == null)
|
{
|
return (false, "单据不存在", materielGroupDTO);
|
}
|
if (inboundOrder.Details == null || inboundOrder.Details.Count == 0)
|
{
|
return (false, "无单据明细信息", materielGroupDTO);
|
}
|
|
if (inboundOrder.OrderStatus != InboundStatusEnum.未开始.ObjToInt() && inboundOrder.OrderStatus != InboundStatusEnum.入库中.ObjToInt())
|
{
|
return (false, "该单据不可再组盘", materielGroupDTO);
|
}
|
|
Dt_InboundOrderDetail inboundOrderDetail = inboundOrder.Details.Where(x => materielInfo.MaterielCode == x.MaterielCode && x.BatchNo == materielGroupDTO.BatchNo).FirstOrDefault();
|
if (inboundOrderDetail == null)
|
{
|
return (false, "物料或批次号有误", materielGroupDTO);
|
}
|
if (inboundOrderDetail.OrderQuantity - inboundOrderDetail.ReceiptQuantity < 1)
|
{
|
//return (false, "有物料超出单据数量", materielGroupDTO);
|
return (false, "组盘超出单据数量", materielGroupDTO);
|
}
|
return (true, "成功", inboundOrderDetail);
|
}
|
|
/// <summary>
|
/// 验证组盘数据
|
/// </summary>
|
/// <param name="materielGroupDTO">物料组盘DTO</param>
|
/// <param name="matSerialNumberDTOs">扫码序列号</param>
|
/// <param name="materielInfos">物料信息</param>
|
/// <param name="materielCodes">物料编号</param>
|
/// <param name="inboundOrder">入库单据</param>
|
/// <param name="stockInfo">组盘信息</param>
|
/// <returns></returns>
|
public (bool, string, object?) CheckMaterielGroupParam(MaterielGroupDTO materielGroupDTO, List<MatSerialNumberDTO> matSerialNumberDTOs, List<Dt_MaterielInfo> materielInfos, List<string> materielCodes, Dt_InboundOrder inboundOrder, Dt_StockInfo stockInfo)
|
{
|
(bool, string, object?) result = ModelValidate.ValidateModelData(materielGroupDTO);
|
if (!result.Item1) return result;
|
|
if (_taskRepository.QueryFirst(x => x.PalletCode == materielGroupDTO.PalletCode) != null)
|
{
|
return (false, "该托盘号已有任务", materielGroupDTO);
|
}
|
|
if (stockInfo != null && !string.IsNullOrEmpty(stockInfo.LocationCode) && stockInfo.StockStatus != StockStatusEmun.组盘暂存.ObjToInt())
|
{
|
return (false, "已上架的托盘不能再次组盘", materielGroupDTO);
|
}
|
|
if (_stockService.StockInfoDetailService.ExistSerialNumbers(materielGroupDTO.SerialNumbers))
|
{
|
return (false, "有序列号在库存中已存在", materielGroupDTO);
|
}
|
|
if (materielInfos.Count != materielCodes.Count)
|
{
|
return (false, "有物料信息未录入，请录入物料信息", materielGroupDTO);
|
}
|
|
if (materielCodes.Count > 1 && materielInfos.FirstOrDefault(x => !x.IsMixMateriel) != null)
|
{
|
return (false, "有物料不可混料组盘", materielGroupDTO);
|
}
|
|
List<string> batchs = matSerialNumberDTOs.GroupBy(x => x.BatchNo).Select(x => x.Key).ToList();
|
if (batchs.Count > 1 && materielInfos.FirstOrDefault(x => !x.IsMixMateriel) != null)
|
{
|
return (false, "有物料不可混批组盘", materielGroupDTO);
|
}
|
|
if (inboundOrder == null)
|
{
|
return (false, "单据不存在", materielGroupDTO);
|
}
|
|
if (inboundOrder.Details == null || inboundOrder.Details.Count == 0)
|
{
|
return (false, "无单据明细信息", materielGroupDTO);
|
}
|
|
if (inboundOrder.OrderStatus != InboundStatusEnum.未开始.ObjToInt() && inboundOrder.OrderStatus != InboundStatusEnum.入库中.ObjToInt())
|
{
|
return (false, "该单据不可再组盘", materielGroupDTO);
|
}
|
|
List<Dt_InboundOrderDetail> inboundOrderDetails = inboundOrder.Details.Where(x => materielCodes.Contains(x.MaterielCode)).ToList();
|
|
if (inboundOrderDetails.GroupBy(x => x.MaterielCode).Count() != materielCodes.Count)
|
{
|
return (false, "有物料不在单据内", materielGroupDTO);
|
}
|
|
IGrouping<string, Dt_InboundOrderDetail>? temp = inboundOrder.Details.Where(x => materielCodes.Contains(x.MaterielCode)).GroupBy(x => x.MaterielCode).FirstOrDefault(x => x.Sum(v => v.OverInQuantity) >= x.Sum(v => v.OrderQuantity) || x.Sum(v => v.ReceiptQuantity) >= x.Sum(v => v.OrderQuantity));
|
if (temp != null)
|
{
|
return (false, "有物料超出单据数量", materielGroupDTO);
|
}
|
|
return (true, "成功", materielGroupDTO);
|
}
|
|
public WebResponseContent QueryOrderInfo(int pageNo, string orderNo)
|
{
|
if (string.IsNullOrEmpty(orderNo))
|
{
|
object obj = Repository.QueryPage(x => true, pageNo, 10, new Dictionary<string, OrderByType> { { nameof(Dt_InboundOrder.CreateDate), OrderByType.Desc } }).Rows.Select(x => new
|
{
|
x.OrderNo,
|
x.UpperOrderNo,
|
x.CreateDate,
|
x.Creater
|
});
|
return WebResponseContent.Instance.OK(data: obj);
|
}
|
else
|
{
|
object obj = Repository.QueryPage(x => x.OrderNo == orderNo, pageNo, 10, new Dictionary<string, OrderByType> { { nameof(Dt_InboundOrder.CreateDate), OrderByType.Desc } }).Rows.Select(x => new
|
{
|
x.OrderNo,
|
x.UpperOrderNo,
|
x.CreateDate,
|
x.Creater
|
});
|
return WebResponseContent.Instance.OK(data: obj);
|
}
|
}
|
}
|
}
|
