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.Stock; 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, 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; } public void AddMaterielGroup(Dt_StockInfo stockInfo) { decimal beforeQuantity = 0; List details = new List(); if (stockInfo.Id == 0) { BaseDal.Db.InsertNav(stockInfo).Include(x => x.Details).ExecuteCommand(); //stockQuantityChangeRecords = _mapper.Map>(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>(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 GetUseableStocks(string materielCode) { List roadways = _basicRepository.RoadwayInfoRepository.CanOutRoadwayNos; List warehouseIds = _basicRepository.WarehouseRepository.EnableWarehouseIds; List areaIds = _basicRepository.AreaInfoRepository.GetEnableAreaIds(warehouseIds); List locationCodes = _basicRepository.LocationInfoRepository.GetCanOutLocationCodes(roadways, areaIds); return BaseDal.GetStockInfos(materielCode, locationCodes); } /// /// 获取指定物料库存信息 /// /// /// public List GetStockSelectViews(string materielCode) { List roadways = _basicRepository.RoadwayInfoRepository.CanOutRoadwayNos; List warehouseIds = _basicRepository.WarehouseRepository.EnableWarehouseIds; List areaIds = _basicRepository.AreaInfoRepository.GetEnableAreaIds(warehouseIds); List locationCodes = _basicRepository.LocationInfoRepository.GetCanOutLocationCodes(roadways, areaIds); #region 按物料数量查询 //var StockSelectViewDTOs = BaseDal.QueryTabs((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 //}, a => locationCodes.Contains(a.LocationCode), b => b.StockQuantity > b.OutboundQuantity && b.Status == StockStatusEmun.已入库.ObjToInt() && b.MaterielCode == materielCode, x => true).GroupBy(x => x.PalletCode).Select(x => new StockSelectViewDTO //{ // LocationCode = x.FirstOrDefault()?.LocationCode ?? "", // MaterielCode = x.FirstOrDefault()?.MaterielCode ?? "", // MaterielName = x.FirstOrDefault()?.MaterielName ?? "", // PalletCode = x.Key, // UseableQuantity = x.Sum(x => x.UseableQuantity) //}).ToList(); #endregion #region 按批号和托盘数量查询 //StockSelectViewDTOs = BaseDal.QueryTabs((a, b) => a.Id == b.StockId, (a, b) => new StockSelectViewDTO //{ // LocationCode = a.LocationCode, // MaterielCode = b.MaterielCode, // MaterielName = b.MaterielName, // PalletCode = a.PalletCode, // BatchNo = b.BatchNo, // UseableQuantity = 1 //}, a => locationCodes.Contains(a.LocationCode), b => b.StockQuantity > b.OutboundQuantity && b.Status == StockStatusEmun.已入库.ObjToInt() && b.MaterielCode == materielCode, x => true).GroupBy(x => x.PalletCode).Select(x => new StockSelectViewDTO //{ // LocationCode = x.FirstOrDefault()?.LocationCode ?? "", // MaterielCode = x.FirstOrDefault()?.MaterielCode ?? "", // MaterielName = x.FirstOrDefault()?.MaterielName ?? "", // BatchNo = x.FirstOrDefault()?.BatchNo ?? "", // PalletCode = x.Key, // UseableQuantity = x.Sum(x => x.UseableQuantity) //}).ToList(); #endregion #region 查询物料库存按批号分组 var StockSelectViewDTOs = BaseDal.QueryTabs((a, b) => a.Id == b.StockId, (a, b) => new StockSelectViewDTO { MaterielCode = b.MaterielCode, MaterielName = b.MaterielName, BatchNo = b.BatchNo, }, a => locationCodes.Contains(a.LocationCode), b => b.StockQuantity > b.OutboundQuantity && b.Status == StockStatusEmun.已入库.ObjToInt() && b.MaterielCode == materielCode, x => true).GroupBy(x => x.BatchNo).Select(x => new StockSelectViewDTO { MaterielCode = x.FirstOrDefault()?.MaterielCode ?? "", MaterielName = x.FirstOrDefault()?.MaterielName ?? "", BatchNo = x.Key, UseableQuantity = x.Count() }).ToList(); #endregion return StockSelectViewDTOs; } /// /// 计算库存 /// /// /// /// /// /// public List GetOutboundStocks(List stockInfos, string materielCode, decimal needQuantity, out decimal residueQuantity) { List outStocks = new List(); #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; } } }