using AutoMapper;
|
using MailKit.Search;
|
using SqlSugar;
|
using System;
|
using System.Collections.Generic;
|
using System.Data;
|
using System.Globalization;
|
using System.Linq;
|
using System.Reflection.Metadata;
|
using System.Text;
|
using System.Threading.Tasks;
|
using WIDESEA_BasicRepository;
|
using WIDESEA_Common;
|
using WIDESEA_Common.OrderEnum;
|
using WIDESEA_Core;
|
using WIDESEA_Core.BaseRepository;
|
using WIDESEA_Core.BaseServices;
|
using WIDESEA_Core.CodeConfigEnum;
|
using WIDESEA_Core.Enums;
|
using WIDESEA_Core.Helper;
|
using WIDESEA_Core.Utilities;
|
using WIDESEA_DTO;
|
using WIDESEA_DTO.Basic;
|
using WIDESEA_DTO.Inbound;
|
using WIDESEA_DTO.Outbound;
|
using WIDESEA_IBasicRepository;
|
using WIDESEA_IBasicService;
|
using WIDESEA_IInboundRepository;
|
using WIDESEA_IInboundService;
|
using WIDESEA_InboundRepository;
|
using WIDESEA_IStockRepository;
|
using WIDESEA_IStockService;
|
using WIDESEA_ITaskInfoRepository;
|
using WIDESEA_Model.Models;
|
|
namespace WIDESEA_InboundService
|
{
|
public partial class InboundOrderService : ServiceBase<Dt_InboundOrder, IInboundOrderRepository>, IInboundOrderService
|
{
|
private readonly IMapper _mapper;
|
private readonly IUnitOfWorkManage _unitOfWorkManage;
|
private readonly ITaskRepository _taskRepository;
|
private readonly IInboundRepository _inboundRepository;
|
private readonly IBasicRepository _basicRepository;
|
private IBasicService _basicService;
|
private IStockService _stockService;
|
private IInboundOrderDetailService _inboundOrderDetailService;
|
private IInboundOrder_HtyService _inboundOrderHtyService;
|
private IInboundOrderDetail_HtyService _inboundOrderDetail_HtyService;
|
private IWarehouseService _warehouseService;
|
private readonly IStockRepository _stockRepository;
|
private IPalletTypeInfoRepository _palletTypeInfoRepository;
|
|
public IInboundOrderRepository Repository => BaseDal;
|
|
public InboundOrderService(IInboundOrderRepository BaseDal, IMapper mapper, IBasicService basicService, IBasicRepository basicRepository, IInboundRepository inboundRepository, IUnitOfWorkManage unitOfWorkManage, ITaskRepository taskRepository, IStockService stockService, IInboundOrderDetailService inboundOrderDetailService, IInboundOrder_HtyService inboundOrderHtyService, IInboundOrderDetail_HtyService inboundOrderDetail_HtyService, IWarehouseService warehouseService, IStockRepository stockRepository, IPalletTypeInfoRepository palletTypeInfoRepository) : base(BaseDal)
|
{
|
_mapper = mapper;
|
_unitOfWorkManage = unitOfWorkManage;
|
_taskRepository = taskRepository;
|
_stockService = stockService;
|
_inboundRepository = inboundRepository;
|
_basicRepository = basicRepository;
|
_inboundOrderDetailService = inboundOrderDetailService;
|
_inboundOrderHtyService = inboundOrderHtyService;
|
_inboundOrderDetail_HtyService = inboundOrderDetail_HtyService;
|
_basicService = basicService;
|
_warehouseService = warehouseService;
|
_stockRepository = stockRepository;
|
_palletTypeInfoRepository = palletTypeInfoRepository;
|
}
|
|
/// <summary>
|
/// 组盘
|
/// </summary>
|
/// <param name="materielGroupDTO"></param>
|
/// <returns></returns>
|
public WebResponseContent MaterielGroup(SaveModel saveModel)
|
{
|
WebResponseContent content = new WebResponseContent();
|
try
|
{
|
|
var orderNo = saveModel.MainData["orderNo"].ToString();
|
var palletCode = saveModel.MainData["palletCode"].ToString();
|
var warehouseId = saveModel.MainData["warehouseId"].ObjToInt();
|
var Initiallife = saveModel.MainData["initiallife"].ObjToInt();
|
var serNums = saveModel.DelKeys.Select(x => x.ToString()).ToList();
|
Dt_Warehouse warehouse = _warehouseService.Repository.QueryFirst(x => x.WarehouseId == warehouseId);
|
if (warehouse == null)
|
{
|
return WebResponseContent.Instance.Error($"未找到该仓库信息");
|
}
|
|
Dt_InboundOrder inboundOrder = BaseDal.Db.Queryable<Dt_InboundOrder>().Where(x => x.OrderNo == orderNo && x.WarehouseId == warehouse.WarehouseId).Includes(x => x.Details).First();
|
if (inboundOrder == null)
|
{
|
return WebResponseContent.Instance.Error($"未找到入库单信息");
|
}
|
if (inboundOrder.Details == null || inboundOrder.Details.Count <= 0)
|
{
|
return WebResponseContent.Instance.Error($"未找到入库单明细信息");
|
}
|
List<MatSerNumAnalysisModel> models = CodeAnalysisHelper.CodeAnalysis<MatSerNumAnalysisModel>(AnalysisCodeEnum.MatSerNumAnalysis, serNums);
|
//验证判断时间格式
|
WebResponseContent IsValidContent = IsValidMCDates(models);
|
if (!IsValidContent.Status)
|
{
|
return content.Error(IsValidContent.Message);
|
}
|
|
string materielCode = models.FirstOrDefault()?.MaterielCode ?? "";
|
Dt_MaterielInfo materielInfo = _basicRepository.MaterielInfoRepository.QueryFirst(x => x.MaterielCode == materielCode);
|
if (materielInfo == null)
|
{
|
return WebResponseContent.Instance.Error($"未找到该物料的信息");
|
}
|
|
List<Dt_InboundOrderDetail> inboundOrderDetails = inboundOrder.Details.Where(x => x.MaterielCode == materielCode && x.BatchNo == (models.FirstOrDefault()?.LotNo ?? "")).ToList();
|
|
if (inboundOrderDetails == null || inboundOrderDetails.Count <= 0)
|
{
|
return WebResponseContent.Instance.Error($"未在入库单明细中找到该物料信息");
|
}
|
var inboundOrderDet = inboundOrderDetails.FirstOrDefault();
|
//Dt_StockInfo? stockInfo = _stockService.StockInfoService.GetStockByPalletCode(palletCode);
|
|
decimal beforeQuantity = 0;
|
|
Dt_StockInfo stockInfo = _stockRepository.StockInfoRepository.Db.Queryable<Dt_StockInfo>().Where(x => x.PalletCode == palletCode).Includes(x => x.Details).First();
|
if (stockInfo == null)
|
{
|
stockInfo = new Dt_StockInfo()
|
{
|
BatchNo = inboundOrderDet.BatchNo,
|
PalletCode = palletCode,
|
PalletType = GetPalletType(warehouse, palletCode),//GetPalletType(warehouse, palletCode)
|
IsFull = true,
|
StockStatus = (int)StockStatusEmun.组盘暂存,
|
Creater = "WMS",
|
CreateDate = DateTime.Now,
|
MaterialType = (int)InventoryMaterialType.成品,
|
Materialweight = 0,
|
Wlstatus = (int)InventoryMaterialStatus.合格,
|
Mgeneratetime = DateTime.Now,
|
WarehouseId = warehouse.WarehouseId,
|
Details = new List<Dt_StockInfoDetail>()
|
};
|
}
|
else
|
{
|
if (stockInfo.StockStatus != StockStatusEmun.组盘暂存.ObjToInt())
|
{
|
return WebResponseContent.Instance.Error($"托盘号重复");
|
}
|
beforeQuantity = stockInfo.Details.Sum(x => x.StockQuantity);
|
}
|
|
if (warehouse.WarehouseCode == WarehouseEnum.SC01_BC.ToString())
|
{
|
stockInfo.Remark = Initiallife.ToString();
|
string batchNo = models.FirstOrDefault()?.LotNo ?? "";
|
//Dt_StockInfoDetail existDetail = _stockRepository.StockInfoDetailRepository.QueryFirst(x => x.BatchNo == batchNo);
|
//if (existDetail != null)
|
//{
|
// return WebResponseContent.Instance.Error($"{batchNo}测试架已存在");
|
//}
|
if (models.Count >= 2)
|
{
|
return WebResponseContent.Instance.Error($"组盘明细不唯一");
|
}
|
//if (palletCode.Substring(0, 1) == "6")
|
//{
|
// stockInfo.PalletType = PalletTypeEnum.MediumPallet.ObjToInt();
|
//}
|
//else
|
//{
|
// stockInfo.PalletType = PalletTypeEnum.LargestPallet.ObjToInt();
|
//}
|
}
|
else if (warehouse.WarehouseCode == WarehouseEnum.SC01_BC.ToString())
|
{
|
if (models.Count >= 2)
|
{
|
return WebResponseContent.Instance.Error($"组盘明细不唯一");
|
}
|
}
|
|
List<Dt_StockInfoDetail> stockInfoDetails = new List<Dt_StockInfoDetail>();
|
foreach (var model in models)
|
{
|
Dt_InboundOrderDetail? notGroupDetail = inboundOrderDetails.Where(x => x.OrderDetailStatus <= OrderDetailStatusEnum.Inbounding.ObjToInt() && x.MaterielCode == model.MaterielCode && x.BatchNo == model.LotNo && x.OrderQuantity > x.ReceiptQuantity).FirstOrDefault();
|
|
if (notGroupDetail == null)
|
{
|
return WebResponseContent.Instance.Error($"该物料在该入库单中已全部组盘完成");
|
}
|
Dt_StockInfoDetail stockInfoDetail = new Dt_StockInfoDetail()
|
{
|
MaterielCode = inboundOrderDet.MaterielCode,
|
MaterielName = inboundOrderDet.MaterielName,
|
OrderNo = inboundOrder.OrderNo,
|
BatchNo = inboundOrderDet.BatchNo,
|
LinId = inboundOrderDet.LinId,
|
StockQuantity = model.Quantity,
|
Status = (int)StockStatusEmun.组盘暂存,
|
Creater = "WMS",
|
CreateDate = DateTime.Now,
|
Id = inboundOrderDet.LinId.ObjToInt(),
|
};
|
|
if (stockInfo.Id > 0)
|
{
|
stockInfoDetail.StockId = stockInfo.Id;
|
}
|
stockInfo.Details.Add(stockInfoDetail);
|
|
stockInfoDetails.Add(stockInfoDetail);
|
|
decimal decimalReceiptQuantity = Convert.ToDecimal(notGroupDetail.ReceiptQuantity);
|
decimal decimalModelQuantity = Convert.ToDecimal(model.Quantity);
|
decimal decimalOrderQuantity = Convert.ToDecimal(notGroupDetail.OrderQuantity);
|
decimalReceiptQuantity += decimalModelQuantity;
|
// 检查是否超出订单数量
|
if (decimalReceiptQuantity > decimalOrderQuantity)
|
{
|
return WebResponseContent.Instance.Error($"组盘数量溢出{decimalReceiptQuantity - decimalOrderQuantity}");
|
}
|
// 转回float类型存储，但比较和计算都使用decimal完成
|
notGroupDetail.ReceiptQuantity = Convert.ToDecimal(decimalReceiptQuantity);
|
if (notGroupDetail.OrderDetailStatus == OrderDetailStatusEnum.New.ObjToInt())
|
{
|
notGroupDetail.OrderDetailStatus = OrderDetailStatusEnum.GroupAndInbound.ObjToInt();
|
}
|
}
|
|
decimal totalQuantity = stockInfo.Details.Sum(x => x.StockQuantity);
|
|
inboundOrder.OrderStatus = InOrderStatusEnum.入库中.ObjToInt();
|
|
_unitOfWorkManage.BeginTran();
|
if (stockInfo.Id == 0)
|
{
|
_stockRepository.StockInfoRepository.Db.InsertNav(stockInfo).Include(x => x.Details).ExecuteCommand();
|
}
|
else
|
{
|
_stockRepository.StockInfoRepository.Db.UpdateNav(stockInfo).Include(x => x.Details, new UpdateNavOptions() { OneToManyInsertOrUpdate = true }).ExecuteCommand();
|
}
|
_inboundRepository.InboundOrderDetailRepository.UpdateData(inboundOrderDetails);
|
_inboundRepository.InboundOrderRepository.UpdateData(inboundOrder);
|
_unitOfWorkManage.CommitTran();
|
content.OK();
|
}
|
catch (Exception ex)
|
{
|
content = WebResponseContent.Instance.Error(ex.Message);
|
}
|
finally
|
{
|
|
}
|
return content;
|
}
|
public int GetPalletType(Dt_Warehouse warehouse, string palletCode)
|
{
|
|
if (warehouse.WarehouseCode == WarehouseEnum.SC01_BC.ObjToString())
|
{
|
Dt_PalletTypeInfo palletTypeInfo = _palletTypeInfoRepository.QueryFirst(x => x.CodeStartStr == palletCode.Substring(0, 3));
|
if (palletTypeInfo == null)
|
{
|
throw new Exception($"托盘号错误");
|
}
|
return palletTypeInfo.PalletType;
|
}
|
//else if (warehouse.WarehouseCode == WarehouseEnum.HA152.ObjToString())
|
//{
|
// Dt_PalletTypeInfo palletTypeInfo = _palletTypeInfoRepository.QueryFirst(x => x.CodeStartStr == palletCode.Substring(0, 2));
|
// if (palletTypeInfo == null)
|
// {
|
// throw new Exception($"托盘号错误");
|
// }
|
// return palletTypeInfo.PalletType;
|
//}
|
//else if (warehouse.WarehouseCode == WarehouseEnum.HA57.ObjToString())
|
//{
|
// Dt_PalletTypeInfo palletTypeInfo = _palletTypeInfoRepository.QueryFirst(x => x.CodeStartStr == palletCode.Substring(0, 3));
|
// if (palletTypeInfo == null)
|
// {
|
// throw new Exception($"托盘号错误");
|
// }
|
// return palletTypeInfo.PalletType;
|
//}
|
//else if (warehouse.WarehouseCode == WarehouseEnum.HA58.ObjToString())
|
//{
|
// Dt_PalletTypeInfo palletTypeInfo = _palletTypeInfoRepository.QueryFirst(x => x.CodeStartStr == palletCode.Substring(0, 2));
|
// if (palletTypeInfo == null)
|
// {
|
// throw new Exception($"托盘号错误");
|
// }
|
// return palletTypeInfo.PalletType;
|
//}
|
return -1;
|
}
|
/// <summary>
|
/// 判断正确时间格式
|
/// </summary>
|
public WebResponseContent IsValidMCDates(List<MatSerNumAnalysisModel> analysisModels)
|
{
|
string[] effDates = analysisModels.Select(x => x.EffectiveDate).Distinct().ToArray();
|
string[] ProDates = analysisModels.Select(x => x.ProductionDate).Distinct().ToArray();
|
foreach (string effDate in effDates)
|
{
|
string format = "yyyy-MM-dd"; // 目标格式
|
DateTime parsedDate;
|
// 解析并验证格式
|
bool isValid = DateTime.TryParseExact(
|
effDate,
|
format,
|
CultureInfo.InvariantCulture,
|
DateTimeStyles.None,
|
out parsedDate
|
);
|
|
if (!isValid)
|
{
|
return WebResponseContent.Instance.Error("格式无效或日期不合法");
|
}
|
}
|
foreach (string ProDate in ProDates)
|
{
|
string format = "yyyy-MM-dd"; // 目标格式
|
DateTime parsedDate;
|
// 解析并验证格式
|
bool isValid = DateTime.TryParseExact(
|
ProDate,
|
format,
|
CultureInfo.InvariantCulture,
|
DateTimeStyles.None,
|
out parsedDate
|
);
|
|
if (!isValid)
|
{
|
return WebResponseContent.Instance.Error("格式无效或日期不合法");
|
}
|
}
|
return WebResponseContent.Instance.OK();
|
}
|
|
public WebResponseContent GetInboundOrders(SaveModel saveModel)
|
{
|
WebResponseContent content = new WebResponseContent();
|
try
|
{
|
int pageNo = saveModel.MainData["pageNo"].ObjToInt();
|
string? orderNo = saveModel.MainData["orderNo"].ToString();
|
int warehouseId = saveModel.MainData["warehouseId"].ObjToInt();
|
List<Dt_InboundOrder> dt_ReceiveOrders = new List<Dt_InboundOrder>();
|
if (string.IsNullOrEmpty(orderNo))
|
{
|
dt_ReceiveOrders = Db.Queryable<Dt_InboundOrder>().Where(x => x.OrderStatus < InboundStatusEnum.入库完成.ObjToInt() && x.WarehouseId == warehouseId).Includes(x => x.Details).OrderByDescending(x => x.CreateDate).ToPageList(pageNo, 10);
|
}
|
else
|
{
|
dt_ReceiveOrders = Db.Queryable<Dt_InboundOrder>().Where(x => (x.OrderNo.Contains(orderNo)) && x.OrderStatus < InboundStatusEnum.入库完成.ObjToInt() && x.WarehouseId == warehouseId).Includes(x => x.Details).OrderByDescending(x => x.CreateDate).ToPageList(pageNo, 10);
|
}
|
|
content.OK(data: dt_ReceiveOrders);
|
}
|
catch (Exception ex)
|
{
|
content.Error(ex.Message);
|
}
|
return content;
|
}
|
|
/// <summary>
|
/// 验证单据添加DTO对象
|
/// </summary>
|
/// <param name="inboundOrderAddDTO">单据添加DTO</param>
|
/// <returns></returns>
|
//private (bool, string, object?) CheckInboundOrderAddData(InboundOrderAddDTO inboundOrderAddDTO)
|
//{
|
// (bool, string, object?) result1 = ModelValidate.ValidateModelData(inboundOrderAddDTO);
|
// if (!result1.Item1) return result1;
|
|
// (bool, string, object?) result2 = ModelValidate.ValidateModelData(inboundOrderAddDTO.Details);
|
// if (!result2.Item1) return result2;
|
|
// IEnumerable<int> inOrderTypes = Enum.GetValues<OrderTypeEmun>().Cast<int>();
|
// if (!inOrderTypes.Contains(inboundOrderAddDTO.OrderType))
|
// {
|
// return (false, "未找到该单据类型", inboundOrderAddDTO);
|
// }
|
|
// List<string> materielCodes = inboundOrderAddDTO.Details.Select(x => x.MaterielCode).ToList();
|
// if (!_basicService.MaterielInfoService.ExsitMateriels(materielCodes))
|
// {
|
// return (false, "有物料信息未录入，请录入物料信息", inboundOrderAddDTO);
|
// }
|
// Dt_Warehouse warehouse = _basicRepository.WarehouseRepository.QueryFirst(x => x.WarehouseCode == inboundOrderAddDTO.OutWareHouse);
|
// if (warehouse == null)
|
// {
|
// return (false, "未找到仓库信息", inboundOrderAddDTO);
|
// }
|
// if (BaseDal.QueryFirst(x => x.OrderName == inboundOrderAddDTO.orderName && !string.IsNullOrEmpty(x.OrderName)) != null)
|
// {
|
// return (false, "单据已存在", inboundOrderAddDTO);
|
// }
|
// return (true, "成功", inboundOrderAddDTO);
|
//}
|
|
|
}
|
}
|
