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 class StockInfoService : ServiceBase, IStockInfoService { private readonly IMapper _mapper; private readonly IStockQuantityChangeRecordService _stockQuantityChangeRecordService; private readonly IStockInfoDetailRepository _stockInfoDetailRepository; private readonly IWarehouseRepository _warehouseRepository; private readonly IRoadwayInfoRepository _roadwayInfoRepository; private readonly IAreaInfoRepository _areaInfoRepository; private readonly ILocationInfoRepository _locationInfoRepository; public IStockInfoRepository Repository => BaseDal; public StockInfoService(IStockInfoRepository BaseDal, IMapper mapper, IStockQuantityChangeRecordService stockQuantityChangeRecordService, IStockInfoDetailRepository stockInfoDetailRepository, IWarehouseRepository warehouseRepository, IRoadwayInfoRepository roadwayInfoRepository, IAreaInfoRepository areaInfoRepository, ILocationInfoRepository locationInfoRepository) : base(BaseDal) { _mapper = mapper; _stockQuantityChangeRecordService = stockQuantityChangeRecordService; _stockInfoDetailRepository = stockInfoDetailRepository; _warehouseRepository = warehouseRepository; _roadwayInfoRepository = roadwayInfoRepository; _areaInfoRepository = areaInfoRepository; _locationInfoRepository = locationInfoRepository; } public Dt_StockInfo? GetStockByPalletCode(string palletCode) { Dt_StockInfo stockInfo = BaseDal.QueryFirst(x => x.PalletCode == palletCode); if (stockInfo != null) { stockInfo.Details = _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(_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); stockInfo.Details = details; _stockQuantityChangeRecordService.AddStockChangeRecord(stockInfo, stockInfo.Details, beforeQuantity, stockInfo.Details.Sum(x => x.StockQuantity) + beforeQuantity, StockChangeType.MaterielGroup); } public List GetUseableStocks(string materielCode) { List roadways = _roadwayInfoRepository.CanOutRoadwayNos; List warehouseIds = _warehouseRepository.EnableWarehouseIds; List areaIds = _areaInfoRepository.GetEnableAreaIds(warehouseIds); List locationCodes = _locationInfoRepository.GetCanOutLocationCodes(roadways, areaIds); return BaseDal.GetStockInfos(materielCode, locationCodes); } public List GetStockSelectViews(string materielCode) { List roadways = _roadwayInfoRepository.CanOutRoadwayNos; List warehouseIds = _warehouseRepository.EnableWarehouseIds; List areaIds = _areaInfoRepository.GetEnableAreaIds(warehouseIds); List locationCodes = _locationInfoRepository.GetCanOutLocationCodes(roadways, areaIds); return 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.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(); } public List GetOutboundStocks(List stockInfos, string materielCode, decimal needQuantity, out decimal residueQuantity) { List outStocks = new List(); 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; return outStocks; } } }