using AutoMapper;
|
using OfficeOpenXml.FormulaParsing.Excel.Functions.RefAndLookup;
|
using SqlSugar;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using WIDESEA_Core;
|
using WIDESEA_Core.BaseServices;
|
using WIDESEA_Core.Enums;
|
using WIDESEA_Core.Helper;
|
using WIDESEA_DTO.Inbound;
|
using WIDESEA_DTO.Stock;
|
using WIDESEA_DTO.WCSInfo;
|
using WIDESEA_IBasicRepository;
|
using WIDESEA_IRecordRepository;
|
using WIDESEA_IRecordService;
|
using WIDESEA_IStockRepository;
|
using WIDESEA_IStockService;
|
using WIDESEA_Model.Models;
|
|
namespace WIDESEA_StockService
|
{
|
public partial class StockInfoService : ServiceBase<Dt_StockInfo, IStockInfoRepository>, IStockInfoService
|
{
|
public Dt_StockInfo? GetStockByPalletCode(string palletCode)
|
{
|
Dt_StockInfo stockInfo = BaseDal.QueryFirst(x => x.PalletCode == palletCode);
|
if (stockInfo != null)
|
{
|
stockInfo.Details = _stockRepository.StockInfoDetailRepository.QueryData(x => x.StockId == stockInfo.Id);
|
}
|
return stockInfo;
|
}
|
/// <summary>
|
/// 添加组盘/库存信息
|
/// </summary>
|
/// <returns></returns>
|
public WebResponseContent AddStockInfo(ref Dt_StockInfo stockInfo, ref Dt_InboundOrder inboundOrder, ProductionlineDTO productionlineDTO)
|
{
|
WebResponseContent content = new WebResponseContent().OK();
|
try
|
{
|
var materielCode = productionlineDTO.traytype.ToString();
|
var inboundOrderDetail = inboundOrder.Details.FirstOrDefault(x => x.BatchNo == productionlineDTO.batchNo);
|
materielCode = inboundOrderDetail.MaterielCode;
|
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();
|
}
|
var materielInfo = _basicRepository.MaterielInfoRepository.QueryFirst(x => x.MaterielCode == materielCode);
|
if (materielInfo == null) throw new Exception($"未找到物料信息,物料编码【{materielCode}】");
|
Dt_StockInfoDetail stockInfoDetail = new Dt_StockInfoDetail()
|
{
|
Status = StockStatusEmun.组盘暂存.ObjToInt(),
|
OrderNo = inboundOrder?.OrderNo,
|
StockId = stockInfo.Id != 0 ? stockInfo.Id : 0,
|
MaterielName = materielInfo.MaterielName,
|
MaterielCode = materielInfo.MaterielCode,
|
BatchNo = inboundOrderDetail.BatchNo,
|
StockQuantity = 1,// productionlineDTO.QtySum,
|
SerialNumber = "",
|
//SerialNumber = $"{inboundOrder.OrderNo} | {materielInfo.MaterielCode} | {pdaMaterielGroupDTO.BatchNo} | {pdaMaterielGroupDTO.ReceiptQuantity}",
|
Creater = "System"
|
};
|
if (stockInfo.Id == 0)
|
{
|
stockInfo.PalletCode = productionlineDTO.Barcode;
|
stockInfo.StockStatus = StockStatusEmun.组盘暂存.ObjToInt();
|
stockInfo.Creater = "System";
|
stockInfo.Remark = productionlineDTO.productQty;
|
}
|
stockInfo.Details.Add(stockInfoDetail);
|
|
}
|
catch (Exception ex)
|
{
|
content.Error(ex.Message);
|
}
|
return content;
|
}
|
|
public void AddMaterielGroup(Dt_StockInfo stockInfo)
|
{
|
decimal beforeQuantity = 0;
|
List<Dt_StockInfoDetail> details = new List<Dt_StockInfoDetail>();
|
if (stockInfo.Id == 0)
|
{
|
BaseDal.Db.InsertNav(stockInfo).Include(x => x.Details).ExecuteCommand();
|
//stockQuantityChangeRecords = _mapper.Map<List<Dt_StockQuantityChangeRecord>>(stockInfo.Details);
|
//stockQuantityChangeRecords.ForEach(x =>
|
//{
|
// x.PalleCode = stockInfo.PalletCode;
|
// x.BeforeQuantity = 0;
|
// x.ChangeQuantity = x.AfterQuantity - x.BeforeQuantity;
|
// x.ChangeType = StockChangeType.MaterielGroup.ObjToInt();
|
//});
|
details = stockInfo.Details;
|
}
|
else
|
{
|
beforeQuantity = stockInfo.Details.Where(x => x.Id != 0).Sum(x => x.StockQuantity);
|
|
for (int i = 0; i < stockInfo.Details.Count; i++)
|
{
|
if (stockInfo.Details[i].Id == 0)
|
{
|
details.Add(_stockRepository.StockInfoDetailRepository.Db.Insertable(stockInfo.Details[i]).ExecuteReturnEntity());
|
}
|
|
}
|
|
//stockQuantityChangeRecords = _mapper.Map<List<Dt_StockQuantityChangeRecord>>(stockInfo.Details);
|
//int index = 0;
|
//stockQuantityChangeRecords.ForEach(x =>
|
//{
|
// x.PalleCode = stockInfo.PalletCode;
|
// x.BeforeQuantity = 0;
|
// x.ChangeQuantity = x.AfterQuantity - x.BeforeQuantity;
|
// x.ChangeType = StockChangeType.MaterielGroup.ObjToInt();
|
// x.StockDetailId =
|
// index++;
|
//});
|
}
|
//_stockQuantityChangeRecordRepository.AddData(stockQuantityChangeRecords);
|
if (details.Count > 0)
|
{
|
stockInfo.Details = details;
|
_recordService.StockQuantityChangeRecordService.AddStockChangeRecord(stockInfo, stockInfo.Details, beforeQuantity, stockInfo.Details.Sum(x => x.StockQuantity) + beforeQuantity, StockChangeType.MaterielGroup);
|
}
|
else
|
{
|
details = stockInfo.Details;
|
_stockRepository.StockInfoDetailRepository.UpdateData(details);
|
}
|
}
|
|
public List<Dt_StockInfo> GetUseableStocks(string materielCode)
|
{
|
List<string> roadways = _basicRepository.RoadwayInfoRepository.CanOutRoadwayNos;
|
|
List<int> warehouseIds = _basicRepository.WarehouseRepository.EnableWarehouseIds;
|
|
List<int> areaIds = _basicRepository.AreaInfoRepository.GetEnableAreaIds(warehouseIds);
|
|
List<string> locationCodes = _basicRepository.LocationInfoRepository.GetCanOutLocationCodes(roadways, areaIds);
|
|
return BaseDal.GetStockInfos(materielCode, locationCodes);
|
}
|
/// <summary>
|
/// 获取指定物料库存信息
|
/// </summary>
|
/// <param name="materielCode"></param>
|
/// <returns></returns>
|
public List<StockSelectViewDTO> GetStockSelectViews(string materielCode)
|
{
|
try
|
{
|
//Dt_MaterielInfo materielInfo = _basicRepository.MaterielInfoRepository.QueryFirst(x => x.MaterielCode == materielCode);
|
//if (materielInfo == null) throw new Exception($"未找到物料信息");
|
return BaseDal.QueryTabs<Dt_StockInfo, Dt_StockInfoDetail, StockSelectViewDTO>((a, b) => a.Id == b.StockId, (a, b) => new StockSelectViewDTO
|
{
|
LocationCode = a.LocationCode,
|
MaterielCode = b.MaterielCode,
|
MaterielName = b.MaterielName,
|
PalletCode = a.PalletCode,
|
//UseableQuantity = b.StockQuantity - b.OutboundQuantity
|
UseableQuantity = b.StockQuantity,
|
BatchNo = b.BatchNo,
|
}, a => a.StockStatus == StockStatusEmun.已入库.ObjToInt(), b => b.Status == StockStatusEmun.已入库.ObjToInt() && b.MaterielCode == materielCode, x => true).GroupBy(x => x.LocationCode).Select(x => new StockSelectViewDTO
|
{
|
LocationCode = x.FirstOrDefault()?.LocationCode ?? "",
|
MaterielCode = x.FirstOrDefault()?.MaterielCode ?? "",
|
MaterielName = x.FirstOrDefault()?.MaterielName ?? "",
|
PalletCode = string.Join(",", x.Select(x => x.PalletCode).ToList()),
|
//UseableQuantity = x.Sum(x => x.UseableQuantity)
|
UseableQuantity = x.Sum(x => x.UseableQuantity),
|
BatchNo = x.FirstOrDefault()?.BatchNo ?? ""
|
}).ToList();
|
}
|
catch (Exception ex)
|
{
|
return null;
|
}
|
}
|
/// <summary>
|
/// 计算库存
|
/// </summary>
|
/// <param name="stockInfos"></param>
|
/// <param name="materielCode"></param>
|
/// <param name="needQuantity"></param>
|
/// <param name="residueQuantity"></param>
|
/// <returns></returns>
|
public List<Dt_StockInfo> GetOutboundStocks(List<Dt_StockInfo> stockInfos, string materielCode, decimal needQuantity, out decimal residueQuantity)
|
{
|
List<Dt_StockInfo> outStocks = new List<Dt_StockInfo>();
|
#region
|
if (stockInfos.Count >= needQuantity)//库存够
|
{
|
foreach (var item in stockInfos.OrderBy(x => x.InDate).ToList().GroupBy(x => x.LocationCode))
|
{
|
if (item.Count() <= needQuantity && needQuantity > 0)
|
{
|
outStocks.AddRange(item);
|
needQuantity -= item.Count();
|
}
|
else if (needQuantity > 0)
|
{
|
outStocks.Add(item.OrderByDescending(x => x.InDate).First());
|
needQuantity -= 1;
|
}
|
}
|
|
}
|
else
|
{
|
outStocks = stockInfos;
|
needQuantity -= stockInfos.Count();
|
}
|
residueQuantity = needQuantity;
|
#endregion
|
|
#region 按库存上托盘数量计算
|
//decimal stockTotalQuantity = stockInfos.Select(x => x.Details.Sum(v => v.StockQuantity - v.OutboundQuantity)).Sum(x => x);
|
//stockInfos = stockInfos.OrderBy(x => x.Id).ToList();
|
//if (stockTotalQuantity >= needQuantity)//库存够
|
//{
|
// int index = 0;
|
// while (needQuantity > 0)
|
// {
|
// Dt_StockInfo stockInfo = stockInfos[index];
|
// decimal useableStockQuantity = stockInfo.Details.Where(x => x.MaterielCode == materielCode).Sum(x => x.StockQuantity - x.OutboundQuantity);
|
// if (useableStockQuantity < needQuantity)
|
// {
|
// stockInfo.Details.ForEach(x => x.OutboundQuantity = x.StockQuantity);
|
// needQuantity -= useableStockQuantity;
|
// }
|
// else
|
// {
|
// stockInfo.Details.ForEach(x =>
|
// {
|
// if (x.StockQuantity > x.OutboundQuantity && x.MaterielCode == materielCode)
|
// {
|
// if (x.StockQuantity - x.OutboundQuantity >= needQuantity)
|
// {
|
// x.OutboundQuantity += needQuantity;
|
// needQuantity = 0;
|
// }
|
// else
|
// {
|
// needQuantity -= (x.StockQuantity - x.OutboundQuantity);
|
// x.OutboundQuantity = x.StockQuantity;
|
// }
|
// }
|
// });
|
// }
|
// outStocks.Add(stockInfo);
|
// index++;
|
// }
|
//}
|
//else
|
//{
|
// for (int i = 0; i < stockInfos.Count; i++)
|
// {
|
// Dt_StockInfo stockInfo = stockInfos[i];
|
// decimal useableStockQuantity = stockInfo.Details.Where(x => x.MaterielCode == materielCode).Sum(x => x.StockQuantity - x.OutboundQuantity);
|
// if (useableStockQuantity < needQuantity)
|
// {
|
// stockInfo.Details.ForEach(x => x.OutboundQuantity = x.StockQuantity);
|
// needQuantity -= useableStockQuantity;
|
// }
|
// else
|
// {
|
// stockInfo.Details.ForEach(x =>
|
// {
|
// if (x.StockQuantity > x.OutboundQuantity && x.MaterielCode == materielCode)
|
// {
|
// if (x.StockQuantity - x.OutboundQuantity >= needQuantity)
|
// {
|
// x.OutboundQuantity += needQuantity;
|
// needQuantity = 0;
|
// }
|
// else
|
// {
|
// needQuantity -= (x.StockQuantity - x.OutboundQuantity);
|
// x.OutboundQuantity = x.StockQuantity;
|
// }
|
// }
|
// });
|
// }
|
// outStocks.Add(stockInfo);
|
// }
|
//}
|
//residueQuantity = needQuantity;
|
#endregion
|
|
return outStocks;
|
}
|
}
|
}
|
