using AutoMapper; using Microsoft.Extensions.Logging; using Newtonsoft.Json; using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Text.Json; using System.Threading.Tasks; using WMS.Web.Core.Dto.Inventory; using WMS.Web.Core.Help; using WMS.Web.Core.Internal.Results; using WMS.Web.Domain.Entitys; using WMS.Web.Domain.Infrastructure; using WMS.Web.Domain.IService; using WMS.Web.Domain.Values; namespace WMS.Web.Domain.Services { /// /// 即时库存-服务 /// public class BoxInventoryService : IBoxInventoryService { private readonly IMapper _mapper; private readonly IBoxRepositories _boxRepositories; private readonly IInventoryDetailsService _inventoryDetailsService; private readonly IInventoryInOutDetailsService _inventoryInOutDetailsService; private readonly ISerialNumbersRepositories _serialNumbersRepositories; private readonly IBoxInventoryRepositories _boxInventoryRepositories; private readonly ILogger _logger; private readonly IBoxService _boxService; public BoxInventoryService(IMapper mapper, IBoxRepositories boxRepositories, ILogger logger, IInventoryDetailsService inventoryDetailsService, IBoxService boxService, IInventoryInOutDetailsService inventoryInOutDetailsService, ISerialNumbersRepositories serialNumbersRepositories, IBoxInventoryRepositories boxInventoryRepositories) { _mapper = mapper; _logger = logger; _boxService = boxService; _boxRepositories = boxRepositories; _inventoryDetailsService = inventoryDetailsService; _serialNumbersRepositories = serialNumbersRepositories; _boxInventoryRepositories = boxInventoryRepositories; _inventoryInOutDetailsService = inventoryInOutDetailsService; } /// /// 改箱-箱库存的变更 /// /// /// /// public async Task GenerateChangeBox(List dtoDatas, bool isTransaction) { _logger.LogInformation("改箱-箱库存变更：" + JsonConvert.SerializeObject(dtoDatas)); //1.判断来源数据是否存在 if (dtoDatas == null || dtoDatas.Count == 0) { _logger.LogInformation("改箱-箱库存变更：失败->" + ResultCodes.InventoryNoSourceError.Item2 + "，参数->" + JsonConvert.SerializeObject(dtoDatas)); return Result.ReFailure(ResultCodes.InventoryNoSourceError); } //2.原来箱库存集合 var boxIds = dtoDatas.Where(x => x.SrcBoxId != 0).GroupBy(x => x.SrcBoxId).Select(x => x.Key).ToList(); var sourceBoxInventorys = await _boxInventoryRepositories.GetList(boxIds); //2.1目标箱库存集合 var targetBoxIds = dtoDatas.GroupBy(x => x.DestBoxId).Select(x => x.Key).ToList(); var targetBoxInventorys = await _boxInventoryRepositories.GetList(targetBoxIds); //2.2组合要生成的dto var generateDtos = dtoDatas.GroupBy(x => new { x.SrcBoxId, x.DestBoxId, x.DestStockCode, x.DestSubStockCode, x.DestBoxOrgCode }).Select(x => new BoxInventoryChangeGenerateDto() { BoxId = x.Key.SrcBoxId, TargetBoxId = x.Key.DestBoxId, StockCode = x.Key.DestStockCode, SubStockCode = x.Key.DestSubStockCode, TargetBoxOrgCode = x.Key.DestBoxOrgCode }).ToList(); //3.遍历：组装明细 generateDtos.ForEach(x => { foreach (var item in dtoDatas) { //3.1原箱和目标箱是当前的 if (item.SrcBoxId == x.BoxId && item.DestBoxId == x.TargetBoxId) { //3.2组装明细 var det = new BoxInventoryDetailsChangeGenerateDto(); det.MaterialNumber = item.MaterialNumber; det.Qty = item.Qty; det.SerialNumbers = item.SerialNumbers; x.Details.Add(det); } } }); //4.开始处理 var result = await this.ExeChangeBox(generateDtos, sourceBoxInventorys, targetBoxInventorys, isTransaction); if (!result.IsSuccess) { _logger.LogInformation("改箱-箱库存变更：失败->" + result.Message + "，参数->" + JsonConvert.SerializeObject(dtoDatas)); return result; } //5.物料收发明细dtos var InventoryInOutDetailsGenerateDtoList = new List(); //5.1遍历 foreach (var item in dtoDatas) { //5.2组装：原箱物料收发明细;有箱库存就需要创建物料收发明细； var sour = sourceBoxInventorys.Where(x => x.BoxId == item.SrcBoxId).FirstOrDefault(); if (sour != null) { var inventoryInOutDet = _inventoryInOutDetailsService.GenerateDto( item.SrcBoxId, item.MaterialNumber, sour.OrgCode, sour.StockCode, sour.SubStockCode, OrderType.ChangeBox, item.BillNo, item.Qty, InventoryInOutType.Out); InventoryInOutDetailsGenerateDtoList.Add(inventoryInOutDet); } //5.3组装：目标箱物料收发明细；有箱库存就需要创建物料收发明细； var tagBox = targetBoxInventorys.Where(x => x.BoxId == item.DestBoxId).FirstOrDefault(); if (tagBox != null) { var inventoryInOutDet = _inventoryInOutDetailsService.GenerateDto( item.DestBoxId, item.MaterialNumber, item.DestBoxOrgCode, item.DestStockCode, item.DestSubStockCode, OrderType.ChangeBox, item.BillNo, item.Qty, InventoryInOutType.In); InventoryInOutDetailsGenerateDtoList.Add(inventoryInOutDet); } } //5.提交物料收发明细：新增 if (InventoryInOutDetailsGenerateDtoList.Count != 0) { var inout_result = await _inventoryInOutDetailsService.GenerateInOrOutDetails(InventoryInOutDetailsGenerateDtoList, isTransaction); if (!inout_result.IsSuccess) { _logger.LogInformation("改箱-箱库存变更：失败->" + inout_result.Message + "，参数->" + JsonConvert.SerializeObject(dtoDatas)); return inout_result; } } _logger.LogInformation("改箱-箱库存变更：成功" + JsonConvert.SerializeObject(dtoDatas)); return Result.ReSuccess(); } /// /// 移箱-箱库存的变更 /// /// /// /// public async Task GenerateMoveBox(List dtoDatas, bool isTransaction) { _logger.LogInformation("移箱-箱库存变更：" + JsonConvert.SerializeObject(dtoDatas)); //1.判断来源数据是否存在 if (dtoDatas == null || dtoDatas.Count == 0) { _logger.LogInformation("移箱-箱库存变更：失败->" + ResultCodes.InventoryNoSourceError.Item2 + "，参数->" + JsonConvert.SerializeObject(dtoDatas)); return Result.ReFailure(ResultCodes.InventoryNoSourceError); } //物料收发明细dtos var InventoryInOutDetailsGenerateDtoList = new List(); //2.箱库存集合 var boxIds = dtoDatas.GroupBy(x => x.BoxId).Select(x => x.Key).ToList(); var boxInventorys = await _boxInventoryRepositories.GetList(boxIds); //2.2组合要生成的dto var generateDtoList = new List(); foreach (var item in dtoDatas) { //2.2.1箱库存dto-组装 var generateDto = new BoxInventoryMoveGenerateDto(); generateDto.BoxId = item.BoxId; generateDto.OrgCode = item.OrgCode; generateDto.StockCode = item.StockCode; generateDto.SubStockCode = item.Type == MoveBoxType.Up ? item.DestSubStockCode : item.SrcSubStockCode; generateDto.InventoryInOutType = item.Type == MoveBoxType.Down ? (int)InventoryInOutType.Out : (int)InventoryInOutType.In; //2.2.2箱库存dto-组装明细 foreach (var detItem in item.Details) { var genDetDto = new BoxInventoryMoveDetailsGenerateDto(); genDetDto.MaterialNumber = detItem.MaterialNumber; genDetDto.Qty = detItem.Qty; genDetDto.SerialNumbers = detItem.SerialNumbers; generateDto.Details.Add(genDetDto); } generateDtoList.Add(generateDto); //2.2.2物料收发明dto-组装 var SubStockCode = item.Type == MoveBoxType.Up ? item.DestSubStockCode : item.SrcSubStockCode; InventoryInOutType InOutType = item.Type == MoveBoxType.Down ? InventoryInOutType.Out : InventoryInOutType.In; var ishave = boxInventorys.Where(x => x.BoxId == item.BoxId).Any(); //上架-箱是不存在库存的情况下，生成物料收发明细 //或者 //下架-箱库存是存在的情况下，生成物料收发明细 if ((!ishave && item.Type == MoveBoxType.Up) || (ishave && item.Type == MoveBoxType.Down)) { foreach (var boxDet in item.Details) { var inventoryInOutDet = _inventoryInOutDetailsService.GenerateDto( item.BoxId, boxDet.MaterialNumber, item.OrgCode, item.StockCode, SubStockCode, OrderType.MoveBox, item.BillNo, boxDet.Qty, InOutType); InventoryInOutDetailsGenerateDtoList.Add(inventoryInOutDet); } } } //4.开始处理 var result = await this.ExeMoveBox(generateDtoList, boxInventorys, isTransaction); if (!result.IsSuccess) { _logger.LogInformation("移箱-箱库存变更：失败->" + result.Message + "，参数->" + JsonConvert.SerializeObject(dtoDatas)); return result; } //5.提交物料收发明细：新增 if (InventoryInOutDetailsGenerateDtoList.Count != 0) { var inout_result = await _inventoryInOutDetailsService.GenerateInOrOutDetails(InventoryInOutDetailsGenerateDtoList, isTransaction); if (!inout_result.IsSuccess) { _logger.LogInformation("移箱-箱库存变更：失败->" + inout_result.Message + "，参数->" + JsonConvert.SerializeObject(dtoDatas)); return inout_result; } } _logger.LogInformation("移箱-箱库存变更：成功，参数->" + JsonConvert.SerializeObject(dtoDatas)); return Result.ReSuccess(); } /// /// 入库回退上下架-箱库存的变更 /// /// /// /// public async Task GenerateBackBox(BackRecord dtoData, bool isTransaction) { _logger.LogInformation("入库回退上下架-箱库存的变更：" + JsonConvert.SerializeObject(dtoData)); //1.判断来源数据是否存在 if (dtoData == null) { _logger.LogInformation("入库回退上下架-箱库存的变更：失败->" + ResultCodes.InventoryNoSourceError.Item2 + "，参数->" + JsonConvert.SerializeObject(dtoData)); return Result.ReFailure(ResultCodes.InventoryNoSourceError); } //物料收发明细dtos var InventoryInOutDetailsGenerateDtoList = new List(); //2.1组织：头部 var generateDtoList = dtoData.Details.GroupBy(x => new { x.BoxId }) .Select(x => new BoxInventoryBackGenerateDto() { BoxId = x.Key.BoxId, OrgCode = dtoData.OrgCode, StockCode = dtoData.StockCode, SubStockCode = dtoData.SubStockCode, InventoryInOutType = dtoData.Type == BackRecordType.OutstockOn ? (int)InventoryInOutType.In : (int)InventoryInOutType.Out }).ToList(); //3.遍历：组装明细 generateDtoList.ForEach(x => { foreach (var detItem in dtoData.Details) { //3.1箱是当前的 if (detItem.BoxId == x.BoxId) { //3.2组装明细 var det = new BoxInventoryBackDetailsGenerateDto(); det.MaterialNumber = detItem.MaterialNumber; det.Qty = detItem.Qty; det.SerialNumbers = detItem.SerialNumbers; x.Details.Add(det); } } }); //4.提交处理 var result = await this.ExeBackBox(generateDtoList, isTransaction); if (!result.IsSuccess) { _logger.LogInformation("入库回退上下架-箱库存的变更：失败->" + result.Message + "，参数->" + JsonConvert.SerializeObject(dtoData)); return result; } //5.组装物料收发明细dto foreach (var item in dtoData.Details) { var inventoryInOutDet = _inventoryInOutDetailsService.GenerateDto( item.BoxId, item.MaterialNumber, dtoData.OrgCode, dtoData.StockCode, dtoData.SubStockCode, OrderType.Back, dtoData.BillNo, item.Qty, (dtoData.Type == BackRecordType.InstockOff ? InventoryInOutType.Out : InventoryInOutType.In)); InventoryInOutDetailsGenerateDtoList.Add(inventoryInOutDet); } //5.提交物料收发明细：新增 if (InventoryInOutDetailsGenerateDtoList.Count != 0) { var inout_result = await _inventoryInOutDetailsService.GenerateInOrOutDetails(InventoryInOutDetailsGenerateDtoList, isTransaction); if (!inout_result.IsSuccess) { _logger.LogInformation("入库回退上下架-箱库存的变更：失败->" + inout_result.Message + "，参数->" + JsonConvert.SerializeObject(dtoData)); return inout_result; } } _logger.LogInformation("入库回退上下架-箱库存的变更：成功，参数->" + JsonConvert.SerializeObject(dtoData)); return Result.ReSuccess(); } /// /// 盘点单-箱库存的变更 /// /// /// /// public async Task GenerateTakeBox(List dtoDatas, List serNubBoxDto,bool isUpdateSubStock, bool isTransaction) { _logger.LogInformation("盘点单-箱库存的变更：" + JsonConvert.SerializeObject(dtoDatas)); //1.判断来源数据是否存在 if (dtoDatas == null || dtoDatas.Count == 0) { _logger.LogInformation("盘点单-箱库存的变更：失败->" + ResultCodes.InventoryNoSourceError.Item2 + "，参数->" + JsonConvert.SerializeObject(dtoDatas)); return Result.ReFailure(ResultCodes.InventoryNoSourceError); } //物料收发明细dtos var InventoryInOutDetailsGenerateDtoList = new List(); var dtoDetails_in = dtoDatas.Where(x => x.ResultType == TakeStockType.Profit).SelectMany(x => x.Details).ToList(); //2.组装：入库数据 var generateDtoList_in = dtoDetails_in.GroupBy(x => new { x.BoxId, x.OrgCode, x.StockCode, x.SubStockCode }).Select(x => new BoxInventoryTakeGenerateDto() { BoxId = x.Key.BoxId, OrgCode = x.Key.OrgCode, StockCode = x.Key.StockCode, SubStockCode = x.Key.SubStockCode, InventoryInOutType = (int)InventoryInOutType.In }).ToList(); //2.1.遍历：组装明细 generateDtoList_in.ForEach(x => { foreach (var detItem in dtoDetails_in) { //3.1箱是当前的 if (detItem.BoxId == x.BoxId) { //3.2组装明细 var det = new BoxInventoryTakeDetailsGenerateDto(); det.MaterialNumber = detItem.MaterialNumber; det.Qty = detItem.FinalQty; det.SerialNumbers = detItem.SerialNumbers; x.Details.Add(det); } } }); //3.组装：出库数据 var dtoDetails_out = dtoDatas.Where(x => x.ResultType == TakeStockType.Loss).SelectMany(x => x.Details).ToList(); var generateDtoList_out = dtoDetails_out.GroupBy(x => new { x.BoxId, x.OrgCode, x.StockCode, x.SubStockCode }).Select(x => new BoxInventoryTakeGenerateDto() { BoxId = x.Key.BoxId, OrgCode = x.Key.OrgCode, StockCode = x.Key.StockCode, SubStockCode = x.Key.SubStockCode, InventoryInOutType = (int)InventoryInOutType.Out }).ToList(); //3.1遍历：组装明细 generateDtoList_out.ForEach(x => { foreach (var detItem in dtoDetails_out) { //3.1箱是当前的 if (detItem.BoxId == x.BoxId) { //3.2组装明细 var det = new BoxInventoryTakeDetailsGenerateDto(); det.MaterialNumber = detItem.MaterialNumber; det.Qty = detItem.FinalQty; det.SerialNumbers = detItem.SerialNumbers; x.Details.Add(det); } } }); if (isUpdateSubStock) { //更改了仓位 分两次调 先调出库 再调入库 var result = await this.ExeTakeBox(generateDtoList_out, serNubBoxDto, isTransaction); if (!result.IsSuccess) { _logger.LogInformation("盘点单-箱库存的变更(出)：失败->" + result.Message + "，参数->" + JsonConvert.SerializeObject(dtoDatas)); return result; } result = await this.ExeTakeBox(generateDtoList_in, serNubBoxDto, isTransaction); if (!result.IsSuccess) { _logger.LogInformation("盘点单-箱库存的变更(入)：失败->" + result.Message + "，参数->" + JsonConvert.SerializeObject(dtoDatas)); return result; } } else { //整合一起 var generateDtoList = new List(); generateDtoList.AddRange(generateDtoList_in); generateDtoList.AddRange(generateDtoList_out); //提交处理 var result = await this.ExeTakeBox(generateDtoList, serNubBoxDto, isTransaction); if (!result.IsSuccess) { _logger.LogInformation("盘点单-箱库存的变更：失败->" + result.Message + "，参数->" + JsonConvert.SerializeObject(dtoDatas)); return result; } } //5.组装物料收发明细 foreach (var item in dtoDatas.SelectMany(x => x.Details).ToList()) { var entity = dtoDatas.Where(x => x.Id == item.Fid).FirstOrDefault(); if (entity != null) { var inventoryInOutDet = _inventoryInOutDetailsService.GenerateDto( item.BoxId, item.MaterialNumber, item.OrgCode, item.StockCode, item.SubStockCode, OrderType.Take, entity.BillNo, item.FinalQty, (entity.ResultType == TakeStockType.Loss ? InventoryInOutType.Out : InventoryInOutType.In)); InventoryInOutDetailsGenerateDtoList.Add(inventoryInOutDet); } } //5.提交物料收发明细：新增 if (InventoryInOutDetailsGenerateDtoList.Count != 0) { var inout_result = await _inventoryInOutDetailsService.GenerateInOrOutDetails(InventoryInOutDetailsGenerateDtoList, isTransaction); if (!inout_result.IsSuccess) { _logger.LogInformation("盘点单-箱库存的变更：失败->" + inout_result.Message + "，参数->" + JsonConvert.SerializeObject(dtoDatas)); return inout_result; } } _logger.LogInformation("盘点单-箱库存的变更：成功，参数->" + JsonConvert.SerializeObject(dtoDatas)); return Result.ReSuccess(); } /// /// 入库单-箱库存的变更 /// /// /// /// public async Task GenerateInStockBox(InStock dtoData, bool isTransaction) { _logger.LogInformation("入库单-箱库存的变更：" + JsonConvert.SerializeObject(dtoData)); //1.判断来源数据是否存在 if (dtoData == null) { _logger.LogInformation("入库单-箱库存的变更：失败->" + ResultCodes.InventoryNoSourceError.Item2 + "，参数->" + JsonConvert.SerializeObject(dtoData)); return Result.ReFailure(ResultCodes.InventoryNoSourceError); } //物料收发明细dtos var InventoryInOutDetailsGenerateDtoList = new List(); //2.组装-按箱和按产品入库 var generateDtoList = dtoData.Details.GroupBy(x => new { x.BoxId }) .Select(x => new BoxInventoryGenerateDto() { BoxId = x.Key.BoxId, OrgCode = dtoData.OrgCode, StockCode = dtoData.StockCode, SubStockCode = dtoData.SubStockCode, InventoryInOutMethod = (int)dtoData.Method, InventoryInOutType = (int)InventoryInOutType.In }).ToList(); //2.1.遍历：组装明细 generateDtoList.ForEach(x => { foreach (var detItem in dtoData.Details) { //2.1箱是当前的 if (detItem.BoxId == x.BoxId) { //2.2组装明细 var det = new BoxInventoryGenerateDetailsDto(); det.MaterialNumber = detItem.MaterialNumber; det.Qty = detItem.Qty; det.SerialNumbers = detItem.SerialNumbers; x.Details.Add(det); } } }); //提交处理 var result = await this.ExeInStockBox(generateDtoList, isTransaction); if (!result.IsSuccess) { _logger.LogInformation("入库单-箱库存的变更：失败->" + result.Message + "，参数->" + JsonConvert.SerializeObject(dtoData)); return result; } //5.组装物料收发明细dto foreach (var item in dtoData.Details) { var inventoryInOutDet = _inventoryInOutDetailsService.GenerateDto( item.BoxId, item.MaterialNumber, dtoData.OrgCode, dtoData.StockCode, dtoData.SubStockCode, InStockTypeConvert(dtoData.Type), item.SourceBillNo, item.Qty, InventoryInOutType.In); InventoryInOutDetailsGenerateDtoList.Add(inventoryInOutDet); } //5.提交物料收发明细：新增 if (InventoryInOutDetailsGenerateDtoList.Count != 0) { var inout_result = await _inventoryInOutDetailsService.GenerateInOrOutDetails(InventoryInOutDetailsGenerateDtoList, isTransaction); if (!inout_result.IsSuccess) { _logger.LogInformation("入库单-箱库存的变更：失败->" + inout_result.Message + "，参数->" + JsonConvert.SerializeObject(dtoData)); return inout_result; } } _logger.LogInformation("入库单-箱库存的变更：成功，参数->" + JsonConvert.SerializeObject(dtoData)); return Result.ReSuccess(); } /// /// 出库单-箱库存变更 /// /// /// /// public async Task GenerateOutStockBox(OutStock dtoData, bool isTransaction) { _logger.LogInformation("出库单-箱库存的变更：" + JsonConvert.SerializeObject(dtoData)); //1.判断来源数据是否存在 if (dtoData == null) { _logger.LogInformation("出库单-箱库存的变更：失败->" + ResultCodes.InventoryNoSourceError.Item2 + "，参数->" + JsonConvert.SerializeObject(dtoData)); return Result.ReFailure(ResultCodes.InventoryNoSourceError); } //物料收发明细dtos var InventoryInOutDetailsGenerateDtoList = new List(); //找出所有的箱库存 var boxIds = dtoData.Details.SelectMany(x => x.BoxsDetails).GroupBy(x => x.BoxId).Select(x => x.Key).ToList(); var boxInventorys = await _boxInventoryRepositories.GetList(boxIds); //判断箱库存是否存在 foreach (var bid in boxIds) { var isHaveBoxInvetory = boxInventorys.Where(x => x.BoxId == bid).Any(); if (!isHaveBoxInvetory) { _logger.LogInformation("出库单-箱库存的变更：失败->" + ResultCodes.BoxInventoryNoDataError.Item2 + "，参数->" + JsonConvert.SerializeObject(dtoData)); return Result.ReFailure(ResultCodes.BoxInventoryNoDataError); } } //2.组装 var generateDtoList = dtoData.Details.SelectMany(x => x.BoxsDetails).GroupBy(x => new { x.BoxId }) .Select(x => new BoxInventoryGenerateDto() { BoxId = x.Key.BoxId, InventoryInOutMethod = (int)dtoData.Method, InventoryInOutType = (int)InventoryInOutType.Out }).ToList(); //3.组装明细 generateDtoList.ForEach(x => { //从箱库存找到：组织、仓库、仓位、进行赋值； var current_box_invetory = boxInventorys.Where(t => t.BoxId == x.BoxId).FirstOrDefault(); if (current_box_invetory != null && current_box_invetory.BoxId == x.BoxId) { x.OrgCode = current_box_invetory.OrgCode; x.StockCode = current_box_invetory.StockCode; x.SubStockCode = current_box_invetory.SubStockCode; } ////3.1先通过中间层的明细的箱明细找到中间层明细的IDS //var current_materialDetails_ids = dtoData.Details.SelectMany(t => t.BoxsDetails).Where(t => t.BoxId == x.BoxId).GroupBy(t => t.DetailId).Select(t => t.Key).ToList(); ////3.2再通过找到的IDS获取中间层的明细 //var current_materialDetails = dtoData.Details.Where(t => current_materialDetails_ids.Contains(t.Id)).ToList(); ////3.3遍历-组装箱库存要的dto明细 //if (current_materialDetails != null && current_materialDetails.Count != 0) foreach (var detItem in dtoData.Details.SelectMany(x => x.BoxsDetails).ToList()) { if (x.BoxId == detItem.BoxId) { var current_det = dtoData.Details.Where(x => x.Id == detItem.DetailId).FirstOrDefault(); //2.2组装明细 var det = new BoxInventoryGenerateDetailsDto(); det.MaterialNumber = current_det == null ? "" : current_det.MaterialNumber; det.Qty = detItem.Qty; det.SerialNumbers = detItem.SerialNumbers; // det.TwoSerialNumbers = detItem.TwoSerialNumbers; x.Details.Add(det); } } }); //是否要改箱的信息：直接调拨出库单，过来的出库就不要去改箱了 var isChangeBoxInfo = true; if (dtoData != null && (dtoData.Type == OutStockType.Stkdirecttransfers || dtoData.Type == OutStockType.StktransferInst)) isChangeBoxInfo = false; //提交处理 var result = await this.ExeOutStockBox(generateDtoList, boxInventorys, isChangeBoxInfo, isTransaction); if (!result.IsSuccess) { _logger.LogInformation("出库单-箱库存的变更：失败->" + result.Message + "，参数->" + JsonConvert.SerializeObject(dtoData)); return result; } //5.组装物料收发明细dto //3.1明细的IDS var current_materialDetails_ids = dtoData.Details.SelectMany(t => t.BoxsDetails).GroupBy(t => t.DetailId).Select(t => t.Key).ToList(); //3.2再通过找到的IDS获取中间层的明细 var current_materialDetails = dtoData.Details.Where(t => current_materialDetails_ids.Contains(t.Id)).ToList(); foreach (var item in dtoData.Details.SelectMany(x => x.BoxsDetails).ToList()) { //找到当前box对应的物料明细 var currentDet = current_materialDetails.Where(x => x.Id == item.DetailId).FirstOrDefault(); var inventoryInOutDet = _inventoryInOutDetailsService.GenerateDto( item.BoxId, currentDet.MaterialNumber, dtoData.OrgCode, dtoData.StockCode, item.SubStockCode, OutStockTypeConvert(dtoData.Type), dtoData.BillNo, item.Qty, InventoryInOutType.Out); InventoryInOutDetailsGenerateDtoList.Add(inventoryInOutDet); } //5.提交物料收发明细：新增 if (InventoryInOutDetailsGenerateDtoList.Count != 0) { var inout_result = await _inventoryInOutDetailsService.GenerateInOrOutDetails(InventoryInOutDetailsGenerateDtoList, isTransaction); if (!inout_result.IsSuccess) { _logger.LogInformation("出库单-箱库存的变更：失败->" + inout_result.Message + "，参数->" + JsonConvert.SerializeObject(dtoData)); return inout_result; } } _logger.LogInformation("出库单-箱库存的变更：成功，参数->" + JsonConvert.SerializeObject(dtoData)); var lastBoxInventList = await _boxInventoryRepositories.GetList(boxIds); _logger.LogInformation("出库单-箱库存的变更：成功，处理后的箱是否存在的箱->" + JsonConvert.SerializeObject(lastBoxInventList)); return Result.ReSuccess(); } /// /// 改箱-箱库存的变更 /// /// /// /// /// /// private async Task ExeChangeBox(List dtoDatas, List sourceBoxInventorys, List targetBoxInventorys, bool isTransaction) { //1.判断来源数据是否存在 if (dtoDatas == null || dtoDatas.Count == 0) return Result.ReFailure(ResultCodes.InventoryNoSourceError); //这个实体给改箱的服务进行处理 var changeBox_inventoryList = new List(); var delete_ids = new List(); var delete_entitys = new List(); var update_entitys = new List(); var add_entitys = new List(); var InventoryDetailsGenerateDto = new List(); foreach (var dto in dtoDatas) { #region 原箱库存-库存处理 //2.1找到要改变的源箱数据://备注（原箱号不一定存在于库存的情况和存在库存的情况）存在：直接变更库存值，不存在不做操作 var sour = sourceBoxInventorys.Where(x => x.BoxId == dto.BoxId).FirstOrDefault(); if (sour != null) { //2.2箱库存 var sour_update_entity = sour; sour_update_entity.Details = sour.Details; foreach (var dtoItem in dto.Details) { //2.2.1箱库存：找到原来的箱库存对应要改变的物料:这个一定是存在的，不存在就有问题 var sour_ChangeDetail = sour_update_entity.Details.Where(x => x.MaterialNumber == dtoItem.MaterialNumber).FirstOrDefault(); if (sour_ChangeDetail == null) return Result.ReFailure(ResultCodes.BoxInventoryNoDataError); //2.2.1箱库存：箱物料的库存数量不足；小于要拿出来的数量 if (sour_ChangeDetail.Qty < dtoItem.Qty) return Result.ReFailure(ResultCodes.BoxInventoryNoInventoryError); //2.2.1箱库存：减库存 sour_ChangeDetail.Qty = sour_ChangeDetail.Qty - dtoItem.Qty; //2.2.1箱库存：再移除要改箱的序列号；最后就是原箱库存的新序列号 sour_ChangeDetail.SerialNumbers.RemoveAll(x => dtoItem.SerialNumbers.Contains(x)); //2.2.2组装即时库存dto var inventoryDet = new InventoryDetailsGenerateDto(); inventoryDet.MaterialNumber = dtoItem.MaterialNumber; inventoryDet.OrgCode = sour_update_entity.OrgCode; inventoryDet.StockCode = sour_update_entity.StockCode; inventoryDet.SubStockCode = sour_update_entity.SubStockCode; inventoryDet.Qty = dtoItem.Qty; inventoryDet.InventoryInOutType = (int)InventoryInOutType.Out; //2.2.2即时库存：修改箱库存的集合 InventoryDetailsGenerateDto.Add(inventoryDet); } //4.1判断要修改的箱库存对象：是否所有的物料库存的数量都为0，“是”则删除该箱库存,"否"则修改； var isAllNoInventory = sour_update_entity.Details.All(x => x.Qty == 0); if (isAllNoInventory) { //给改箱服务用：按箱的话，就要把明细里的数量修改为0 changeBox_inventoryList.Add(GenerateBoxInventory(sour_update_entity.Clone())); delete_ids.Add(sour_update_entity.Id); delete_entitys.Add(sour_update_entity); } else { //4.2添加要更新的箱库存实体 update_entitys.Add(sour_update_entity); //给改箱服务用 changeBox_inventoryList.Add(sour_update_entity.Clone()); } } #endregion #region 目标箱库存-库存处理 //2.2找到要改变的目标箱数据：备注（目标箱号不一定存在于库存的情况和存在库存的情况）存在：直接变更库存值，不存在不做操作 var tagBox = targetBoxInventorys.Where(x => x.BoxId == dto.TargetBoxId).FirstOrDefault(); if (tagBox != null) { var subStockCode = tagBox.SubStockCode; var stockCode = tagBox.StockCode; var orgCode = tagBox.OrgCode; var tag_update_entity = tagBox; //2.2.1这里为了重新上架，改变仓库和仓位的需求 if (!string.IsNullOrEmpty(dto.StockCode) && !string.IsNullOrEmpty(dto.SubStockCode)) { //2.2.3.在变更目标箱的-仓库-仓位-组织 tag_update_entity.StockCode = dto.StockCode; tag_update_entity.SubStockCode = dto.SubStockCode; tag_update_entity.OrgCode = dto.TargetBoxOrgCode; } tag_update_entity.Details = tagBox.Details; //2.2.2仓位和原来的目标箱的仓位不一致的情况下-》》把目标箱原来仓位的物料进行-即时库存的变更-（减库存） if (subStockCode != tag_update_entity.SubStockCode) { foreach (var item in tag_update_entity.Details) { //2.2.2组装即时库存dto var inventoryDet = new InventoryDetailsGenerateDto(); inventoryDet.MaterialNumber = item.MaterialNumber; inventoryDet.OrgCode = orgCode; inventoryDet.StockCode = stockCode; inventoryDet.SubStockCode = subStockCode; inventoryDet.Qty = item.Qty; inventoryDet.InventoryInOutType = (int)InventoryInOutType.Out; //2.2.2即时库存：修改箱库存的集合 InventoryDetailsGenerateDto.Add(inventoryDet); //2.2.2组装即时库存dto var inventoryDet_i = new InventoryDetailsGenerateDto(); inventoryDet_i.MaterialNumber = item.MaterialNumber; inventoryDet_i.OrgCode = tag_update_entity.OrgCode; inventoryDet_i.StockCode = tag_update_entity.StockCode; inventoryDet_i.SubStockCode = tag_update_entity.SubStockCode; inventoryDet_i.Qty = item.Qty; inventoryDet_i.InventoryInOutType = (int)InventoryInOutType.In; //2.2.2即时库存：修改箱库存的集合 InventoryDetailsGenerateDto.Add(inventoryDet_i); } } //2.2.1遍历改变的明细 foreach (var item in dto.Details) { //2.2.2找到目标箱对应要改变的物料 var tagChangeDetail = tag_update_entity.Details.Where(x => x.MaterialNumber == item.MaterialNumber).FirstOrDefault(); if (tagChangeDetail != null) { tagChangeDetail.Qty = tagChangeDetail.Qty + item.Qty; tagChangeDetail.SerialNumbers.AddRange(item.SerialNumbers); }//2.3.没有对应的箱物料，就新增明细 else { var newTagChangeDetail = new BoxInventoryDetails(); newTagChangeDetail.MaterialNumber = item.MaterialNumber; newTagChangeDetail.Qty = item.Qty; newTagChangeDetail.SerialNumbers = item.SerialNumbers; tag_update_entity.Details.Add(newTagChangeDetail); } //2.2.2组装即时库存dto var inventoryDet = new InventoryDetailsGenerateDto(); inventoryDet.MaterialNumber = item.MaterialNumber; inventoryDet.OrgCode = tag_update_entity.OrgCode; inventoryDet.StockCode = tag_update_entity.StockCode; inventoryDet.SubStockCode = tag_update_entity.SubStockCode; inventoryDet.Qty = item.Qty; inventoryDet.InventoryInOutType = (int)InventoryInOutType.In; //2.2.2即时库存：修改箱库存的集合 InventoryDetailsGenerateDto.Add(inventoryDet); } //2.4箱库存：要修改的集合 update_entitys.Add(tag_update_entity); //给改箱服务用 changeBox_inventoryList.Add(tag_update_entity.Clone()); } #endregion } //改箱 var changeBox_result = await _boxService.BoxInventorySync(changeBox_inventoryList, isTransaction,"0"); if (!changeBox_result.IsSuccess) return changeBox_result; var isSuccess = true; //4.数据库更新操作:更新和添加 if (add_entitys.Count != 0) { _logger.LogInformation("改箱-箱库存的添加：->" + JsonConvert.SerializeObject(add_entitys)); isSuccess = await _boxInventoryRepositories.AddRange(add_entitys, isTransaction); if (!isSuccess) return Result.ReFailure(ResultCodes.DateWriteError); } if (update_entitys.Count != 0) { _logger.LogInformation("改箱-箱库存的修改：->" + JsonConvert.SerializeObject(update_entitys)); isSuccess = await _boxInventoryRepositories.UpdateRange(update_entitys, isTransaction); if (!isSuccess) return Result.ReFailure(ResultCodes.DateWriteError); } if (delete_ids.Count != 0) { _logger.LogInformation("改箱-箱库存的删除：->" + JsonConvert.SerializeObject(delete_entitys)); isSuccess = await _boxInventoryRepositories.DeleteRange(delete_ids, isTransaction); if (!isSuccess) return Result.ReFailure(ResultCodes.DateWriteError); } //5.即时库存：变更 //5.1先合并相同的数据 var invDetGenDtos_in = InventoryDetailsGenerateDto.Where(x => x.InventoryInOutType == (int)InventoryInOutType.In).GroupBy(x => new { x.OrgCode, x.MaterialNumber, x.StockCode, x.SubStockCode }).Select(x => new InventoryDetailsGenerateDto() { OrgCode = x.Key.OrgCode, StockCode = x.Key.StockCode, MaterialNumber = x.Key.MaterialNumber, SubStockCode = x.Key.SubStockCode, InventoryInOutType = (int)InventoryInOutType.In, Qty = x.Sum(t => t.Qty) }).ToList(); var invDetGenDtos_out = InventoryDetailsGenerateDto.Where(x => x.InventoryInOutType == (int)InventoryInOutType.Out).GroupBy(x => new { x.OrgCode, x.MaterialNumber, x.StockCode, x.SubStockCode }).Select(x => new InventoryDetailsGenerateDto() { OrgCode = x.Key.OrgCode, StockCode = x.Key.StockCode, MaterialNumber = x.Key.MaterialNumber, SubStockCode = x.Key.SubStockCode, InventoryInOutType = (int)InventoryInOutType.Out, Qty = x.Sum(t => t.Qty) }).ToList(); var invDetGenDtos = new List(); invDetGenDtos.AddRange(invDetGenDtos_in); invDetGenDtos.AddRange(invDetGenDtos_out); if (invDetGenDtos.Count != 0) { var InventoryDetailsGenerate_result = await _inventoryDetailsService.GenerateInventoryDetails(invDetGenDtos, isTransaction,"0"); if (!InventoryDetailsGenerate_result.IsSuccess) return InventoryDetailsGenerate_result; } return Result.ReSuccess(); } /// /// 移箱-箱库存的变更 /// /// /// /// /// /// private async Task ExeMoveBox(List dtoDatas, List boxInventorys, bool isTransaction) { //1.判断来源数据是否存在 if (dtoDatas == null || dtoDatas.Count == 0) return Result.ReFailure(ResultCodes.InventoryNoSourceError); ////这个实体给改箱的服务进行处理 //var changeBox_inventoryList = new List(); var delete_entitys = new List(); var add_entitys = new List(); var InventoryDetailsGenerateDto = new List(); _logger.LogInformation("移箱-箱库存变更2：" + JsonConvert.SerializeObject(dtoDatas)); //3.遍历：dto foreach (var dto in dtoDatas) { //上架 if (dto.InventoryInOutType == (int)InventoryInOutType.In) { //3.1上架的时候：箱一定是不存在于箱库存当中的，有则返回提示“已有箱库存，不需要再扫上架” var ishave = boxInventorys.Where(x => x.BoxId == dto.BoxId).Any(); if (ishave) return Result.ReFailure(ResultCodes.BoxInventoryHaveInventoryError); //3.2组装要新增的箱库存信息：箱和明细 var addEntity = _mapper.Map(dto); addEntity.Details = _mapper.Map>(dto.Details); //3.4箱库存：要新增的集合 add_entitys.Add(addEntity); ////给改箱服务用--整箱移动就不要处理了 //changeBox_inventoryList.Add(addEntity.Clone()); //4.1即时库存：组装入库 foreach (var item in dto.Details) { //3.2.2组装即时库存dto var inventoryDet = new InventoryDetailsGenerateDto(); inventoryDet.MaterialNumber = item.MaterialNumber; inventoryDet.OrgCode = dto.OrgCode; inventoryDet.StockCode = dto.StockCode; inventoryDet.SubStockCode = dto.SubStockCode; inventoryDet.Qty = item.Qty; inventoryDet.InventoryInOutType = (int)InventoryInOutType.In; //3.2.2即时库存：修改箱库存的集合 InventoryDetailsGenerateDto.Add(inventoryDet); } } //下架 else { //3.1下架的时候：箱一定是存在于箱库存当中的，没有则返回提示“箱不存在于库存，请扫其它箱” var ishave = boxInventorys.Where(x => x.BoxId == dto.BoxId).Any(); if (!ishave) return Result.ReFailure(ResultCodes.BoxInventoryNoDataError); //3.2整箱移货下架-直接删除当前箱子所在的库存 var box_inventory = boxInventorys.Where(x => x.BoxId == dto.BoxId).FirstOrDefault(); delete_entitys.Add(box_inventory); //给改箱服务用：按箱的话，就要把明细里的数量修改为0--整箱移动就不要处理了 //changeBox_inventoryList.Add(GenerateBoxInventory(box_inventory.Clone())); //4.1即时库存：组装出库 foreach (var item in box_inventory.Details) { //3.2.2组装即时库存dto var inventoryDet = new InventoryDetailsGenerateDto(); inventoryDet.MaterialNumber = item.MaterialNumber; inventoryDet.OrgCode = dto.OrgCode; inventoryDet.StockCode = dto.StockCode; inventoryDet.SubStockCode = dto.SubStockCode; inventoryDet.Qty = item.Qty; inventoryDet.InventoryInOutType = (int)InventoryInOutType.Out; //3.2.2即时库存：修改箱库存的集合 InventoryDetailsGenerateDto.Add(inventoryDet); } } } ////改箱 //var changeBox_result = await _boxService.BoxInventorySync(changeBox_inventoryList, isTransaction); //if (!changeBox_result.IsSuccess) // return changeBox_result; var isSuccess = true; //4.数据库操作处理 if (add_entitys.Count != 0) { _logger.LogInformation("移箱-箱库存的添加：->" + JsonConvert.SerializeObject(add_entitys)); isSuccess = await _boxInventoryRepositories.AddRange(add_entitys, isTransaction); if (!isSuccess) return Result.ReFailure(ResultCodes.DateWriteError); } if (delete_entitys.Count != 0) { _logger.LogInformation("移箱-箱库存的删除：->" + JsonConvert.SerializeObject(delete_entitys)); var delete_ids = delete_entitys.Select(x => x.Id).ToList(); isSuccess = await _boxInventoryRepositories.DeleteRange(delete_ids, isTransaction); if (!isSuccess) return Result.ReFailure(ResultCodes.DateWriteError); } //5.即时库存：处理 //5.1先合并相同的数据 var invDetGenDtos_in = InventoryDetailsGenerateDto.Where(x => x.InventoryInOutType == (int)InventoryInOutType.In).GroupBy(x => new { x.OrgCode, x.MaterialNumber, x.StockCode, x.SubStockCode }).Select(x => new InventoryDetailsGenerateDto() { OrgCode = x.Key.OrgCode, StockCode = x.Key.StockCode, MaterialNumber = x.Key.MaterialNumber, SubStockCode = x.Key.SubStockCode, InventoryInOutType = (int)InventoryInOutType.In, Qty = x.Sum(t => t.Qty) }).ToList(); var invDetGenDtos_out = InventoryDetailsGenerateDto.Where(x => x.InventoryInOutType == (int)InventoryInOutType.Out).GroupBy(x => new { x.OrgCode, x.MaterialNumber, x.StockCode, x.SubStockCode }).Select(x => new InventoryDetailsGenerateDto() { OrgCode = x.Key.OrgCode, StockCode = x.Key.StockCode, MaterialNumber = x.Key.MaterialNumber, SubStockCode = x.Key.SubStockCode, InventoryInOutType = (int)InventoryInOutType.Out, Qty = x.Sum(t => t.Qty) }).ToList(); var invDetGenDtos = new List(); invDetGenDtos.AddRange(invDetGenDtos_in); invDetGenDtos.AddRange(invDetGenDtos_out); if (invDetGenDtos.Count != 0) { var InventoryDetailsGenerate_result = await _inventoryDetailsService.GenerateInventoryDetails(invDetGenDtos, isTransaction, "0"); if (!InventoryDetailsGenerate_result.IsSuccess) return InventoryDetailsGenerate_result; } return Result.ReSuccess(); } /// /// 入库回退上下架-箱库存的变更 /// /// /// /// private async Task ExeBackBox(List dtoDatas, bool isTransaction) { //1.判断来源数据是否存在 if (dtoDatas == null || dtoDatas.Count == 0) return Result.ReFailure(ResultCodes.InventoryNoSourceError); //这个实体给改箱的服务进行处理 var changeBox_inventoryList = new List(); var delete_ids = new List(); var delete_entitys = new List(); var update_entitys = new List(); var add_entitys = new List(); var InventoryDetailsGenerateDto = new List(); //2.获取“箱库存集合” var boxIds = dtoDatas.GroupBy(x => x.BoxId).Select(x => x.Key).ToList(); var boxInventorys = await _boxInventoryRepositories.GetList(boxIds); //box的序列号 var serialNumbers = await _serialNumbersRepositories.GetEntityListByBoxIds(dtoDatas.GroupBy(x => x.BoxId).Select(x => x.Key).ToList()); //3.遍历：dto foreach (var dto in dtoDatas) { //上架 if (dto.InventoryInOutType == (int)InventoryInOutType.In) { _logger.LogInformation("出入库回退：上架->序列号：" + JsonConvert.SerializeObject(dto.Details.SelectMany(x => x.SerialNumbers).ToList())); //3.1上架的时候：箱库存可能存在，也可能不存在的两种情况 var boxInventory = boxInventorys.Where(x => x.BoxId == dto.BoxId).FirstOrDefault(); if (boxInventory == null) { //3.2组装要新增的箱库存信息：箱和明细和序列号 var addEntity = _mapper.Map(dto); addEntity.Details = _mapper.Map>(dto.Details); #region 序列号处理 /////按箱的-弃用了 //if (dto.InventoryInOutMethod == (int)InventoryInOutMethod.Box) //{ // //当前箱的序列号 // var current_box_serNums = serialNumbers.Where(t => t.BoxId == dto.BoxId).ToList(); // //赋值序列号 // addEntity.Details.ForEach(x => // { // var current_box_mat_serNums = current_box_serNums.Where(m => m.MaterialId == x.MaterialId).Select(t => t.SerialNumber).ToList(); // x.SerialNumbers.AddRange(current_box_mat_serNums); // }); //} //赋值序列号 addEntity.Details.ForEach(x => { var current_box_mat_serNums = dto.Details.Where(m => m.MaterialNumber == x.MaterialNumber).FirstOrDefault(); if (current_box_mat_serNums != null && current_box_mat_serNums.MaterialNumber == x.MaterialNumber) x.SerialNumbers.AddRange(current_box_mat_serNums.SerialNumbers); }); #endregion add_entitys.Add(addEntity); //给改箱服务用 changeBox_inventoryList.Add(addEntity.Clone()); } else { _logger.LogInformation("出入库回退：上架->序列号：" + JsonConvert.SerializeObject(dto.Details.SelectMany(x => x.SerialNumbers).ToList())); var update_entity = boxInventory; update_entity.OrgCode = dto.OrgCode; update_entity.StockCode = dto.StockCode; update_entity.SubStockCode = dto.SubStockCode; update_entity.Details = boxInventory.Details; //3.3遍历dto明细 foreach (var dtoItem in dto.Details) { //找到原来的箱库存对应要改变的物料:这个一定是存在的，不存在就有问题 var updateDetail = update_entity.Details.Where(x => x.MaterialNumber == dtoItem.MaterialNumber).FirstOrDefault(); if (updateDetail == null) { var det = _mapper.Map(dtoItem); update_entity.Details.Add(det); } else { updateDetail.Qty = updateDetail.Qty + dtoItem.Qty; } } #region 序列号处理 /////按箱的-弃用了 //if (dto.InventoryInOutMethod == (int)InventoryInOutMethod.Box) //{ // //当前箱的序列号 // var current_box_serNums = serialNumbers.Where(t => t.BoxId == dto.BoxId).ToList(); // //赋值序列号 // update_entity.Details.ForEach(x => // { // var current_box_mat_serNums = current_box_serNums.Where(m => m.MaterialId == x.MaterialId).Select(t => t.SerialNumber).ToList(); // x.SerialNumbers.AddRange(current_box_mat_serNums); // }); //} //赋值序列号 update_entity.Details.ForEach(x => { var current_box_mat_serNums = dto.Details.Where(m => m.MaterialNumber == x.MaterialNumber).FirstOrDefault(); if (current_box_mat_serNums != null && current_box_mat_serNums.MaterialNumber == x.MaterialNumber) { foreach (var serialitem in current_box_mat_serNums.SerialNumbers) { var isHaveSerial = x.SerialNumbers.Where(sn => sn == serialitem).Any(); if (!isHaveSerial) x.SerialNumbers.Add(serialitem); } // x.SerialNumbers.AddRange(current_box_mat_serNums.SerialNumbers); } }); #endregion update_entitys.Add(update_entity); //给改箱服务用 changeBox_inventoryList.Add(update_entity.Clone()); } //4.1即时库存：组装入库 foreach (var item in dto.Details) { //3.2.2组装即时库存dto var inventoryDet = new InventoryDetailsGenerateDto(); inventoryDet.MaterialNumber = item.MaterialNumber; inventoryDet.OrgCode = dto.OrgCode; inventoryDet.StockCode = dto.StockCode; inventoryDet.SubStockCode = dto.SubStockCode; inventoryDet.Qty = item.Qty; inventoryDet.InventoryInOutType = (int)InventoryInOutType.In; //3.2.2即时库存：修改箱库存的集合 InventoryDetailsGenerateDto.Add(inventoryDet); } } //下架 else { //3.1下架的时候：箱一定是存在于箱库存当中的，没有则返回提示“箱不存在于库存，请扫其它箱” var boxInventory = boxInventorys.Where(x => x.BoxId == dto.BoxId).FirstOrDefault(); if (boxInventory == null) return Result.ReFailure(ResultCodes.BoxInventoryNoDataError); //3.2创建更新对象 var update_entity = boxInventory; update_entity.Details = boxInventory.Details; //3.3遍历dto明细 foreach (var dtoItem in dto.Details) { //找到原来的箱库存对应要改变的物料:这个一定是存在的，不存在就有问题 var updateDetail = update_entity.Details.Where(x => x.MaterialNumber == dtoItem.MaterialNumber).FirstOrDefault(); if (updateDetail == null) return Result.ReFailure(ResultCodes.BoxInventoryNoDataError); //箱物料的库存数量不足；小于要拿出来的数量 if (updateDetail.Qty < dtoItem.Qty) return Result.ReFailure(ResultCodes.BoxInventoryNoInventoryError); updateDetail.Qty = updateDetail.Qty - dtoItem.Qty; //再移除要改箱的序列号；最后就是原箱库存的新序列号 updateDetail.SerialNumbers.RemoveAll(x => dtoItem.SerialNumbers.Contains(x)); //4.1即时库存：组装出库 //3.2.2组装即时库存dto var inventoryDet = new InventoryDetailsGenerateDto(); inventoryDet.MaterialNumber = dtoItem.MaterialNumber; inventoryDet.OrgCode = dto.OrgCode; inventoryDet.StockCode = dto.StockCode; inventoryDet.SubStockCode = dto.SubStockCode; inventoryDet.Qty = dtoItem.Qty; inventoryDet.InventoryInOutType = (int)InventoryInOutType.Out; //3.2.2即时库存：修改箱库存的集合 InventoryDetailsGenerateDto.Add(inventoryDet); } //4.1判断要修改的箱库存对象：是否所有的物料库存的数量都为0，“是”则删除该箱库存,"否"则修改； var isAllNoInventory = update_entity.Details.All(x => x.Qty == 0); if (isAllNoInventory) { //给改箱服务用：按箱的话，就要把明细里的数量修改为0;备注：当数量为0后就不要改箱了 //changeBox_inventoryList.Add(GenerateBoxInventory(update_entity.Clone())); delete_ids.Add(update_entity.Id); delete_entitys.Add(update_entity); } else { //4.2添加要更新的箱库存实体 update_entitys.Add(update_entity); //给改箱服务用 changeBox_inventoryList.Add(update_entity.Clone()); } } } //改箱 var changeBox_result = await _boxService.BoxInventorySync(changeBox_inventoryList, isTransaction,"1"); if (!changeBox_result.IsSuccess) return changeBox_result; var isSuccess = true; //4.数据库更新操作:更新和添加 if (add_entitys.Count != 0) { _logger.LogInformation("出入库回退上下架-箱库存的添加：->" + JsonConvert.SerializeObject(add_entitys)); isSuccess = await _boxInventoryRepositories.AddRange(add_entitys, isTransaction); if (!isSuccess) return Result.ReFailure(ResultCodes.DateWriteError); } if (update_entitys.Count != 0) { _logger.LogInformation("出入库回退上下架-箱库存的修改：->" + JsonConvert.SerializeObject(update_entitys)); isSuccess = await _boxInventoryRepositories.UpdateRange(update_entitys, isTransaction); if (!isSuccess) return Result.ReFailure(ResultCodes.DateWriteError); } if (delete_ids.Count != 0) { _logger.LogInformation("出入库回退上下架-箱库存的删除：->" + JsonConvert.SerializeObject(delete_entitys)); isSuccess = await _boxInventoryRepositories.DeleteRange(delete_ids, isTransaction); if (!isSuccess) return Result.ReFailure(ResultCodes.DateWriteError); } //5.即时库存：处理 //5.1先合并相同的数据 var invDetGenDtos_in = InventoryDetailsGenerateDto.Where(x => x.InventoryInOutType == (int)InventoryInOutType.In).GroupBy(x => new { x.OrgCode, x.MaterialNumber, x.StockCode, x.SubStockCode }).Select(x => new InventoryDetailsGenerateDto() { OrgCode = x.Key.OrgCode, StockCode = x.Key.StockCode, MaterialNumber = x.Key.MaterialNumber, SubStockCode = x.Key.SubStockCode, InventoryInOutType = (int)InventoryInOutType.In, Qty = x.Sum(t => t.Qty) }).ToList(); var invDetGenDtos_out = InventoryDetailsGenerateDto.Where(x => x.InventoryInOutType == (int)InventoryInOutType.Out).GroupBy(x => new { x.OrgCode, x.MaterialNumber, x.StockCode, x.SubStockCode }).Select(x => new InventoryDetailsGenerateDto() { OrgCode = x.Key.OrgCode, StockCode = x.Key.StockCode, MaterialNumber = x.Key.MaterialNumber, SubStockCode = x.Key.SubStockCode, InventoryInOutType = (int)InventoryInOutType.Out, Qty = x.Sum(t => t.Qty) }).ToList(); var invDetGenDtos = new List(); invDetGenDtos.AddRange(invDetGenDtos_in); invDetGenDtos.AddRange(invDetGenDtos_out); if (invDetGenDtos.Count != 0) { var InventoryDetailsGenerate_result = await _inventoryDetailsService.GenerateInventoryDetails(invDetGenDtos, isTransaction, "0"); if (!InventoryDetailsGenerate_result.IsSuccess) return InventoryDetailsGenerate_result; } return Result.ReSuccess(); } /// /// 盘点单-箱库存的变更 /// /// /// /// private async Task ExeTakeBox(List dtoDatas, List serNubBoxDto, bool isTransaction) { //1.判断来源数据是否存在 if (dtoDatas == null || dtoDatas.Count == 0) return Result.ReFailure(ResultCodes.InventoryNoSourceError); //这个实体给改箱的服务进行处理 var changeBox_inventoryList = new List(); var delete_ids = new List(); var delete_entitys = new List(); var update_entitys = new List(); var InventoryDetailsGenerateDto = new List(); //2.获取“箱库存集合” var boxIds = dtoDatas.GroupBy(x => x.BoxId).Select(x => x.Key).ToList(); var boxInventorys = await _boxInventoryRepositories.GetList(boxIds); //3.遍历：dto foreach (var dto in dtoDatas) { //入库 if (dto.InventoryInOutType == (int)InventoryInOutType.In) { //3.1入库的时候：盘点-箱一定是存在于库存 var boxInvent = boxInventorys.Where(x => x.BoxId == dto.BoxId).FirstOrDefault(); //if (boxInvent == null) // return Result.ReFailure(ResultCodes.BoxInventoryHaveInventoryError); //v1.0.6版本 如果没有箱库存就添加 if (boxInvent == null) { BoxInventory box_add = new BoxInventory() { BoxId = dto.BoxId, OrgCode = dto.OrgCode, StockCode = dto.StockCode, SubStockCode = dto.SubStockCode }; boxInvent = await _boxInventoryRepositories.Add(box_add, isTransaction); if (boxInvent == null) return Result.ReFailure(ResultCodes.DateWriteError); boxInventorys.Add(boxInvent); } //3.2组装要新增的箱库存信息：箱和明细和序列号 var updateEntity = boxInvent; updateEntity.Details = boxInvent.Details; //3.3序列号重新给值：已有的物料 updateEntity.Details.ForEach(x => { foreach (var detItem in dto.Details) { if (x.MaterialNumber == detItem.MaterialNumber) { x.Qty = x.Qty + detItem.Qty; x.SerialNumbers = detItem.SerialNumbers; } } }); //3.4明细添加新的物料 foreach (var detItem in dto.Details) { var IsHave_upEnDet = updateEntity.Details.Where(x => x.MaterialNumber == detItem.MaterialNumber).Any(); if (!IsHave_upEnDet) { var newDet = _mapper.Map(detItem); updateEntity.Details.Add(newDet); } //3.2.2组装即时库存dto var inventoryDet = new InventoryDetailsGenerateDto(); inventoryDet.MaterialNumber = detItem.MaterialNumber; inventoryDet.OrgCode = dto.OrgCode; inventoryDet.StockCode = dto.StockCode; inventoryDet.SubStockCode = dto.SubStockCode; inventoryDet.Qty = detItem.Qty; inventoryDet.InventoryInOutType = (int)InventoryInOutType.In; //3.2.2即时库存：修改箱库存的集合 InventoryDetailsGenerateDto.Add(inventoryDet); } //3.5要处理的修改集合 update_entitys.Add(updateEntity); //给改箱服务用 changeBox_inventoryList.Add(updateEntity.Clone()); } //出库 else { //3.1出库的时候：盘点-箱库存是存在 var boxInventory = boxInventorys.Where(x => x.BoxId == dto.BoxId).FirstOrDefault(); if (boxInventory == null) return Result.ReFailure(ResultCodes.BoxInventoryNoDataError); //3.2创建更新对象 var update_entity = boxInventory; update_entity.Details = boxInventory.Details; //3.3序列号重新给值：已有的物料 update_entity.Details.ForEach(x => { foreach (var detItem in dto.Details) { if (x.MaterialNumber == detItem.MaterialNumber) { x.Qty = x.Qty - detItem.Qty; x.SerialNumbers = detItem.SerialNumbers; } } }); //3.4明细添加新的物料 foreach (var detItem in dto.Details) { //3.2.2组装即时库存dto var inventoryDet = new InventoryDetailsGenerateDto(); inventoryDet.MaterialNumber = detItem.MaterialNumber; inventoryDet.OrgCode = dto.OrgCode; inventoryDet.StockCode = dto.StockCode; inventoryDet.SubStockCode = dto.SubStockCode; inventoryDet.Qty = detItem.Qty; inventoryDet.InventoryInOutType = (int)InventoryInOutType.Out; //3.2.2即时库存：修改箱库存的集合 InventoryDetailsGenerateDto.Add(inventoryDet); } //4.1判断要修改的箱库存对象：是否所有的物料库存的数量都为0，“是”则删除该箱库存,"否"则修改； var isAllNoInventory = update_entity.Details.All(x => x.Qty == 0); if (isAllNoInventory) { //给改箱服务用：按箱的话，就要把明细里的数量修改为0 changeBox_inventoryList.Add(GenerateBoxInventory(update_entity.Clone())); delete_ids.Add(update_entity.Id); delete_entitys.Add(update_entity); } else { //4.2添加要更新的箱库存实体 update_entitys.Add(update_entity); //给改箱服务用 changeBox_inventoryList.Add(update_entity.Clone()); } } } //改箱 var changeBox_result = await _boxService.BoxInventorySync(changeBox_inventoryList, isTransaction, "0"); if (!changeBox_result.IsSuccess) return changeBox_result; var isSuccess = true; //4.数据库更新操作:更新和添加 if (update_entitys.Count != 0) { _logger.LogInformation("盘点单-步骤1箱库存的修改：->" + JsonConvert.SerializeObject(update_entitys)); isSuccess = await _boxInventoryRepositories.UpdateRange(update_entitys, isTransaction); if (!isSuccess) return Result.ReFailure(ResultCodes.DateWriteError); } if (delete_ids.Count != 0) { _logger.LogInformation("盘点单-步骤1箱库存的删除：->" + JsonConvert.SerializeObject(delete_entitys)); isSuccess = await _boxInventoryRepositories.DeleteRange(delete_ids, isTransaction); if (!isSuccess) return Result.ReFailure(ResultCodes.DateWriteError); } //盘点单-箱库存的变更：第二步骤，为了不是当前扫的所在箱里的序列号；如果是其它箱需要减箱库存 var result = await this.ExeTaskBox(serNubBoxDto, isTransaction); if (!result.IsSuccess) return result; //5.即时库存：处理 //5.1先合并相同的数据 var invDetGenDtos_in = InventoryDetailsGenerateDto.Where(x => x.InventoryInOutType == (int)InventoryInOutType.In).GroupBy(x => new { x.OrgCode, x.MaterialNumber, x.StockCode, x.SubStockCode }).Select(x => new InventoryDetailsGenerateDto() { OrgCode = x.Key.OrgCode, StockCode = x.Key.StockCode, MaterialNumber = x.Key.MaterialNumber, SubStockCode = x.Key.SubStockCode, InventoryInOutType = (int)InventoryInOutType.In, Qty = x.Sum(t => t.Qty) }).ToList(); var invDetGenDtos_out = InventoryDetailsGenerateDto.Where(x => x.InventoryInOutType == (int)InventoryInOutType.Out).GroupBy(x => new { x.OrgCode, x.MaterialNumber, x.StockCode, x.SubStockCode }).Select(x => new InventoryDetailsGenerateDto() { OrgCode = x.Key.OrgCode, StockCode = x.Key.StockCode, MaterialNumber = x.Key.MaterialNumber, SubStockCode = x.Key.SubStockCode, InventoryInOutType = (int)InventoryInOutType.Out, Qty = x.Sum(t => t.Qty) }).ToList(); var invDetGenDtos = new List(); invDetGenDtos.AddRange(invDetGenDtos_in); invDetGenDtos.AddRange(invDetGenDtos_out); if (invDetGenDtos.Count != 0) { var InventoryDetailsGenerate_result = await _inventoryDetailsService.GenerateInventoryDetails(invDetGenDtos, isTransaction, "0"); if (!InventoryDetailsGenerate_result.IsSuccess) return InventoryDetailsGenerate_result; } return Result.ReSuccess(); } /// /// 盘点单-箱库存的变更：第二步骤，为了不是当前扫的所在箱里的序列号；如果是其它箱的需要减箱库存 /// /// /// /// private async Task ExeTaskBox(List out_SerialNumbers, bool isTransaction) { var boxIds = out_SerialNumbers.GroupBy(x => x.BoxId).Select(x => x.Key).ToList(); var boxInventorys = await _boxInventoryRepositories.GetList(boxIds); //这个实体给改箱的服务进行处理 var changeBox_inventoryList = new List(); var delete_ids1 = new List(); var delete_entity = new List(); var update_entitys1 = new List(); var InventoryDetailsGenerateDto1 = new List(); foreach (var item in boxInventorys) { item.Details.ForEach(x => { var current_sers_info = out_SerialNumbers.Where(o => o.BoxId == item.BoxId && o.MaterialNumber == x.MaterialNumber).ToList(); var current_sers_infoCount = out_SerialNumbers.Where(o => o.BoxId == item.BoxId && o.MaterialNumber == x.MaterialNumber && o.isNotCount!="1").ToList(); if (current_sers_info != null && current_sers_info.Count != 0) { //if (isNoCount == "1") //{ //} //else //{ x.Qty = x.Qty - current_sers_infoCount.Count; //} var crrent_sers = current_sers_info.Select(t => t.SerialNumber).ToList(); x.SerialNumbers.RemoveAll(r => crrent_sers.Contains(r)); //3.2.2组装即时库存dto var inventoryDet = new InventoryDetailsGenerateDto(); inventoryDet.MaterialNumber = x.MaterialNumber; inventoryDet.OrgCode = item.OrgCode; inventoryDet.StockCode = item.StockCode; inventoryDet.SubStockCode = item.SubStockCode; //inventoryDet.Qty = current_sers_info.Count; inventoryDet.Qty = current_sers_infoCount.Count; inventoryDet.InventoryInOutType = (int)InventoryInOutType.Out; //3.2.2即时库存：修改的集合 InventoryDetailsGenerateDto1.Add(inventoryDet); } }); //4.1判断要修改的箱库存对象：是否所有的物料库存的数量都为0，“是”则删除该箱库存,"否"则修改； var isAllNoInventory = item.Details.All(x => x.Qty == 0); if (isAllNoInventory) { //给改箱服务用：按箱的话，就要把明细里的数量修改为0 changeBox_inventoryList.Add(GenerateBoxInventory(item.Clone())); delete_ids1.Add(item.Id); delete_entity.Add(item); } else { //4.2添加要更新的箱库存实体 update_entitys1.Add(item); //给改箱服务用 changeBox_inventoryList.Add(item.Clone()); } } //改箱 var changeBox_result = await _boxService.BoxInventorySync(changeBox_inventoryList, isTransaction, "0"); if (!changeBox_result.IsSuccess) return changeBox_result; var isSuccess = true; //4.数据库更新操作:更新和添加 if (update_entitys1.Count != 0) { _logger.LogInformation("盘点单-箱库存的修改：->" + JsonConvert.SerializeObject(update_entitys1)); isSuccess = await _boxInventoryRepositories.UpdateRange(update_entitys1, isTransaction); if (!isSuccess) return Result.ReFailure(ResultCodes.DateWriteError); } if (delete_ids1.Count != 0) { _logger.LogInformation("盘点单-箱库存的删除：->" + JsonConvert.SerializeObject(delete_entity)); isSuccess = await _boxInventoryRepositories.DeleteRange(delete_ids1, isTransaction); if (!isSuccess) return Result.ReFailure(ResultCodes.DateWriteError); } if (InventoryDetailsGenerateDto1.Count != 0) { var InventoryDetailsGenerate_result = await _inventoryDetailsService.GenerateInventoryDetails(InventoryDetailsGenerateDto1, isTransaction, "1"); if (!InventoryDetailsGenerate_result.IsSuccess) return InventoryDetailsGenerate_result; } return Result.ReSuccess(); } /// /// 入库单-箱库存变更 /// /// /// /// private async Task ExeInStockBox(List dtoDatas, bool isTransaction) { //1.判断来源数据是否存在 if (dtoDatas == null || dtoDatas.Count == 0) return Result.ReFailure(ResultCodes.InventoryNoSourceError); //这个实体给改箱的服务进行处理 var changeBox_inventoryList = new List(); var update_entitys = new List(); var add_entitys = new List(); var InventoryDetailsGenerateDto = new List(); //1.1通过箱IDS获取箱库存 var boxIds = dtoDatas.Select(x => x.BoxId).ToList(); var boxInventorys = await _boxInventoryRepositories.GetList(boxIds); //2.遍历：dto foreach (var dto in dtoDatas) { //按箱上架入库 if (dto.InventoryInOutMethod == (int)InventoryInOutMethod.Box) { //3.1上架的时候：箱一定是不存在于箱库存当中的，有则返回提示“已有箱库存，不需要再扫上架” var isHave = boxInventorys.Where(x => x.BoxId == dto.BoxId).Any(); if (isHave) return Result.ReFailure(ResultCodes.BoxInventoryHaveInventoryError); //3.2组装要新增的箱库存信息：箱和明细和序列号 var addEntity = _mapper.Map(dto); //3.3要合并下相同的物料 var dtoDets_merge = dto.Details.GroupBy(d => new { d.MaterialNumber }).Select(d => new BoxInventoryGenerateDetailsDto { MaterialNumber = d.Key.MaterialNumber, Qty = d.Sum(t => t.Qty), SerialNumbers = d.SelectMany(t => t.SerialNumbers).ToList() }).ToList(); //3.4明细映射：用合并过的dto数据 addEntity.Details = _mapper.Map>(dtoDets_merge); add_entitys.Add(addEntity); //给改箱服务用 changeBox_inventoryList.Add(addEntity.Clone()); //4.组装即时库存 foreach (var detItem in dto.Details) { //4.1组装即时库存dto var inventoryDet = new InventoryDetailsGenerateDto(); inventoryDet.MaterialNumber = detItem.MaterialNumber; inventoryDet.OrgCode = dto.OrgCode; inventoryDet.StockCode = dto.StockCode; inventoryDet.SubStockCode = dto.SubStockCode; inventoryDet.Qty = detItem.Qty; inventoryDet.InventoryInOutType = (int)InventoryInOutType.In; //4.2即时库存：修改箱库存的集合 InventoryDetailsGenerateDto.Add(inventoryDet); } } //按产品上架入库 else { //按产品上架：箱只能是一个；箱可能存在库存（修改），也可能不存在库存（新增） var boxInventory = boxInventorys.Where(x => x.BoxId == dto.BoxId).FirstOrDefault(); if (boxInventory == null) { //3.2组装要新增的箱库存信息：箱和明细和序列号 var addEntity = _mapper.Map(dto); //3.3要合并下相同的物料 var dtoDets_merge = dto.Details.GroupBy(d => new { d.MaterialNumber }).Select(d => new BoxInventoryGenerateDetailsDto { MaterialNumber = d.Key.MaterialNumber, Qty = d.Sum(t => t.Qty), SerialNumbers = d.SelectMany(t => t.SerialNumbers).ToList() }).ToList(); //3.4明细映射：用合并过的dto数据 addEntity.Details = _mapper.Map>(dtoDets_merge); add_entitys.Add(addEntity); //给改箱服务用 changeBox_inventoryList.Add(addEntity.Clone()); //3.3.遍历：dto明细；组装即时库存数据 foreach (var dtoItem in dto.Details) { //4.1组装即时库存dto var inventoryDet = new InventoryDetailsGenerateDto(); inventoryDet.MaterialNumber = dtoItem.MaterialNumber; inventoryDet.OrgCode = dto.OrgCode; inventoryDet.StockCode = dto.StockCode; inventoryDet.SubStockCode = dto.SubStockCode; inventoryDet.Qty = dtoItem.Qty; inventoryDet.InventoryInOutType = (int)InventoryInOutType.In; //4.2即时库存：修改箱库存的集合 InventoryDetailsGenerateDto.Add(inventoryDet); } } else { //3.3创建更新对象 var update_entity = boxInventory; update_entity.Details = boxInventory.Details; foreach (var dtoItem in dto.Details) { //明细对应的物料：存在就修改，不存在即新增 var update_entity_det = new BoxInventoryDetails(); var updateDetail = update_entity.Details.Where(x => x.MaterialNumber == dtoItem.MaterialNumber).FirstOrDefault(); if (updateDetail == null) { update_entity_det.Qty = dtoItem.Qty; update_entity_det.MaterialNumber = dtoItem.MaterialNumber; update_entity_det.SerialNumbers = dtoItem.SerialNumbers; update_entity.Details.Add(update_entity_det); } else { updateDetail.Qty = updateDetail.Qty + dtoItem.Qty; updateDetail.SerialNumbers.AddRange(dtoItem.SerialNumbers); } //4.1组装即时库存dto var inventoryDet = new InventoryDetailsGenerateDto(); inventoryDet.MaterialNumber = dtoItem.MaterialNumber; inventoryDet.OrgCode = dto.OrgCode; inventoryDet.StockCode = dto.StockCode; inventoryDet.SubStockCode = dto.SubStockCode; inventoryDet.Qty = dtoItem.Qty; inventoryDet.InventoryInOutType = (int)InventoryInOutType.In; //4.2即时库存：修改箱库存的集合 InventoryDetailsGenerateDto.Add(inventoryDet); } update_entitys.Add(update_entity); //给改箱服务用 changeBox_inventoryList.Add(update_entity.Clone()); } } } //改箱 var changeBox_result = await _boxService.BoxInventorySync(changeBox_inventoryList, isTransaction, "0"); if (!changeBox_result.IsSuccess) return changeBox_result; var isSuccess = true; //4.数据库更新操作:更新和添加 if (add_entitys.Count != 0) { _logger.LogInformation("入库单-箱库存的添加：->" + JsonConvert.SerializeObject(add_entitys)); isSuccess = await _boxInventoryRepositories.AddRange(add_entitys, isTransaction); if (!isSuccess) return Result.ReFailure(ResultCodes.DateWriteError); } if (update_entitys.Count != 0) { _logger.LogInformation("入库单-箱库存的修改：->" + JsonConvert.SerializeObject(update_entitys)); isSuccess = await _boxInventoryRepositories.UpdateRange(update_entitys, isTransaction); if (!isSuccess) return Result.ReFailure(ResultCodes.DateWriteError); } //5.即时库存：处理 //5.1先合并相同的数据 var invDetGenDtos_in = InventoryDetailsGenerateDto.Where(x => x.InventoryInOutType == (int)InventoryInOutType.In).GroupBy(x => new { x.OrgCode, x.MaterialNumber, x.StockCode, x.SubStockCode }).Select(x => new InventoryDetailsGenerateDto() { OrgCode = x.Key.OrgCode, StockCode = x.Key.StockCode, MaterialNumber = x.Key.MaterialNumber, SubStockCode = x.Key.SubStockCode, InventoryInOutType = (int)InventoryInOutType.In, Qty = x.Sum(t => t.Qty) }).ToList(); var invDetGenDtos_out = InventoryDetailsGenerateDto.Where(x => x.InventoryInOutType == (int)InventoryInOutType.Out).GroupBy(x => new { x.OrgCode, x.MaterialNumber, x.StockCode, x.SubStockCode }).Select(x => new InventoryDetailsGenerateDto() { OrgCode = x.Key.OrgCode, StockCode = x.Key.StockCode, MaterialNumber = x.Key.MaterialNumber, SubStockCode = x.Key.SubStockCode, InventoryInOutType = (int)InventoryInOutType.Out, Qty = x.Sum(t => t.Qty) }).ToList(); var invDetGenDtos = new List(); invDetGenDtos.AddRange(invDetGenDtos_in); invDetGenDtos.AddRange(invDetGenDtos_out); _logger.LogInformation($"入库对应即时库存:{JsonConvert.SerializeObject(invDetGenDtos)} 操作时间:{DateTime.Now.ToString()}"); if (invDetGenDtos.Count != 0) { var InventoryDetailsGenerate_result = await _inventoryDetailsService.GenerateInventoryDetails(invDetGenDtos, isTransaction, "0"); if (!InventoryDetailsGenerate_result.IsSuccess) return InventoryDetailsGenerate_result; } return Result.ReSuccess(); } /// /// 出库单-箱库存变更 /// /// /// /// /// private async Task ExeOutStockBox(List dtoDatas, List boxInventorys, bool isChangeBoxInfo, bool isTransaction) { //1.判断来源数据是否存在 if (dtoDatas == null || dtoDatas.Count == 0) return Result.ReFailure(ResultCodes.InventoryNoSourceError); //这个实体给改箱的服务进行处理 var changeBox_inventoryList = new List(); var delete_entitys = new List(); var delete_ids = new List(); var update_entitys = new List(); var InventoryDetailsGenerateDto = new List(); //2.遍历 foreach (var dto in dtoDatas) { //3.1出库的时候：箱一定是存在于箱库存当中的，没有则返回提示“箱库存数据不存在，请稍候再试！” // 获取箱库存 var boxInventory = boxInventorys.Where(x => x.BoxId == dto.BoxId).FirstOrDefault(); if (boxInventory == null) return Result.ReFailure(ResultCodes.BoxInventoryNoDataError); //按箱：出库 if (dto.InventoryInOutMethod == (int)InventoryInOutMethod.Box) { //直接添加要删除的箱 delete_ids.Add(boxInventory.Id); delete_entitys.Add(boxInventory); //给改箱服务用：按箱的话，就要把明细里的数量修改为0 if (isChangeBoxInfo) changeBox_inventoryList.Add(GenerateBoxInventory(boxInventory.Clone())); //4.组装即时库存 foreach (var detItem in dto.Details) { //4.1组装即时库存dto var inventoryDet = new InventoryDetailsGenerateDto(); inventoryDet.MaterialNumber = detItem.MaterialNumber; inventoryDet.OrgCode = dto.OrgCode; inventoryDet.StockCode = dto.StockCode; inventoryDet.SubStockCode = dto.SubStockCode; inventoryDet.Qty = detItem.Qty; inventoryDet.InventoryInOutType = (int)InventoryInOutType.Out; //4.2即时库存：修改箱库存的集合 InventoryDetailsGenerateDto.Add(inventoryDet); } } //按产品：出库 else { //3.3创建更新对象 var update_entity = boxInventory; update_entity.Details = boxInventory.Details; //3.2.遍历：dto明细 foreach (var dtoItem in dto.Details) { //3.3.找到当前明细物料：没有则返回失败；提示：“该箱物料库存不存在” var update_entityDetail = update_entity.Details.Where(x => x.MaterialNumber == dtoItem.MaterialNumber).FirstOrDefault(); if (update_entityDetail == null) return Result.ReFailure(ResultCodes.BoxInventoryMaterialNoDataError); //3.4判断库存数量是否不足 if (update_entityDetail.Qty < dtoItem.Qty) return Result.ReFailure(ResultCodes.BoxInventoryNoInventoryError); //3.5物料库存数量变更：减库存 update_entityDetail.Qty = update_entityDetail.Qty - dtoItem.Qty; //3.6移除要出库的序列号 update_entityDetail.SerialNumbers.RemoveAll(x => dtoItem.SerialNumbers.Contains(x)); //4.1组装即时库存dto var inventoryDet = new InventoryDetailsGenerateDto(); inventoryDet.MaterialNumber = dtoItem.MaterialNumber; inventoryDet.OrgCode = dto.OrgCode; inventoryDet.StockCode = dto.StockCode; inventoryDet.SubStockCode = dto.SubStockCode; inventoryDet.Qty = dtoItem.Qty; inventoryDet.InventoryInOutType = (int)InventoryInOutType.Out; //4.2即时库存：修改箱库存的集合 InventoryDetailsGenerateDto.Add(inventoryDet); } //4.1判断要修改的箱库存对象：是否所有的物料库存的数量都为0，“是”则删除该箱库存,"否"则修改； var isAllNoInventory = update_entity.Details.All(x => x.Qty == 0); if (isAllNoInventory) { //给改箱服务用：按箱的话，就要把明细里的数量修改为0 if (isChangeBoxInfo) changeBox_inventoryList.Add(GenerateBoxInventory(update_entity.Clone())); delete_ids.Add(update_entity.Id); delete_entitys.Add(update_entity); } else { //4.2添加要更新的箱库存实体 update_entitys.Add(update_entity); //给改箱服务用 changeBox_inventoryList.Add(update_entity.Clone()); } } } //改箱 var changeBox_result = await _boxService.BoxInventorySync(changeBox_inventoryList, isTransaction, "0"); if (!changeBox_result.IsSuccess) return changeBox_result; //4.数据库更新操作:更新和删除 var isSuccess = true; if (delete_ids.Count != 0) { _logger.LogInformation("出库单-箱库存的删除：开始->" + JsonConvert.SerializeObject(delete_entitys)); isSuccess = await _boxInventoryRepositories.DeleteRange(delete_ids, isTransaction); if (!isSuccess) return Result.ReFailure(ResultCodes.DateWriteError); _logger.LogInformation("出库单-箱库存的删除：结束成功->" + JsonConvert.SerializeObject(delete_entitys)); } if (update_entitys.Count != 0) { _logger.LogInformation("出库单-箱库存的修改：开始->" + JsonConvert.SerializeObject(update_entitys)); isSuccess = await _boxInventoryRepositories.UpdateRange(update_entitys, isTransaction); if (!isSuccess) return Result.ReFailure(ResultCodes.DateWriteError); _logger.LogInformation("出库单-箱库存的修改：结束成功->" + JsonConvert.SerializeObject(update_entitys)); } //5.即时库存：变更处理 var invDetGenDtos = InventoryDetailsGenerateDto.Where(x => x.InventoryInOutType == (int)InventoryInOutType.Out).GroupBy(x => new { x.OrgCode, x.MaterialNumber, x.StockCode, x.SubStockCode }).Select(x => new InventoryDetailsGenerateDto() { OrgCode = x.Key.OrgCode, StockCode = x.Key.StockCode, MaterialNumber = x.Key.MaterialNumber, SubStockCode = x.Key.SubStockCode, InventoryInOutType = (int)InventoryInOutType.Out, Qty = x.Sum(t => t.Qty) }).ToList(); if (invDetGenDtos.Count != 0) { var inventoryDetails_result = await _inventoryDetailsService.GenerateInventoryDetails(invDetGenDtos, isTransaction, "0"); if (!inventoryDetails_result.IsSuccess) return inventoryDetails_result; } return Result.ReSuccess(); } /// /// 出库类型转换为单据类型 /// /// /// private OrderType OutStockTypeConvert(OutStockType type) { switch (type) { case OutStockType.Sal: return OrderType.Sal_Out; case OutStockType.Assembled: return OrderType.Assembled_Out; case OutStockType.Miscellaneous: return OrderType.Miscellaneous_Out; case OutStockType.Stkdirecttransfers: return OrderType.Stkdirecttransfers_Out; case OutStockType.StktransferInst: return OrderType.StktransferInst_Out; default: return OrderType.StktransferInst_Out; } } /// /// 入库类型转换为单据类型 /// /// /// private OrderType InStockTypeConvert(InstockType type) { switch (type) { case InstockType.Purchase: return OrderType.Purchase_In; case InstockType.Assembled: return OrderType.Assembled_In; case InstockType.Miscellaneous: return OrderType.Miscellaneous_In; case InstockType.Stkdirecttransfers: return OrderType.Stkdirecttransfers_In; case InstockType.StktransferInst: return OrderType.StktransferInst_In; default: return OrderType.StktransferInst_In; } } private BoxInventory GenerateBoxInventory(BoxInventory boxInventory) { // 使用 LINQ 将box里的明细全部设置为0 boxInventory.Details.Select(detail => { detail.Qty = 0; return detail; }).ToList(); return boxInventory; } /// /// 处理箱库存变更：出入库 /// /// /// /// public async Task HandlBoxInventory(List dtoDatas, bool isTransaction) { //1.判断来源数据是否存在 if (dtoDatas == null || dtoDatas.Count == 0) return Result.ReFailure(ResultCodes.InventoryNoSourceError); var delete_ids = new List(); var update_entitys = new List(); var add_entitys = new List(); var InventoryDetailsGenerateDto = new List(); //1.1通过箱IDS获取箱库存 var boxIds = dtoDatas.Select(x => x.BoxId).ToList(); var boxInventorys = await _boxInventoryRepositories.GetList(boxIds); //2.遍历：dto foreach (var dto in dtoDatas) { //出库 if (dto.InventoryInOutType == (int)InventoryInOutType.Out) { //生成出库对象：删除和修改 var outStockInventoryResult = this.GenerateOutStockBox(dto, boxInventorys, delete_ids, update_entitys); if (!outStockInventoryResult.IsSuccess) return outStockInventoryResult; } //入库 else { //生成入库对象：新增和修改 var inStockInventoryResult = this.GenerateInStockBox(dto, boxInventorys, add_entitys, update_entitys); if (!inStockInventoryResult.IsSuccess) return inStockInventoryResult; } //组装：即时库存明细处理对象 var invDtos = this.GenerateInventoryDetails(dto); InventoryDetailsGenerateDto.AddRange(invDtos); } //4.数据库更新操作:更新和删除和添加 var isSuccess = true; if (delete_ids.Count != 0) { isSuccess = await _boxInventoryRepositories.DeleteRange(delete_ids, isTransaction); if (!isSuccess) return Result.ReFailure(ResultCodes.DateWriteError); } if (add_entitys.Count != 0) { isSuccess = await _boxInventoryRepositories.AddRange(add_entitys, isTransaction); if (!isSuccess) return Result.ReFailure(ResultCodes.DateWriteError); } if (update_entitys.Count != 0) { isSuccess = await _boxInventoryRepositories.UpdateRange(update_entitys, isTransaction); if (!isSuccess) return Result.ReFailure(ResultCodes.DateWriteError); } //5.即时库存：变更处理 if (InventoryDetailsGenerateDto.Count != 0) { var inventoryDetails_result = await _inventoryDetailsService.GenerateInventoryDetails(InventoryDetailsGenerateDto, isTransaction, "0"); if (!inventoryDetails_result.IsSuccess) return inventoryDetails_result; } return Result.ReSuccess(); } /// /// 生成出库对象：删除和修改 /// /// /// /// /// /// private Result GenerateOutStockBox(BoxInventoryGenerateDto dto, List boxInventorys, List delete_ids, List update_entitys) { //3.1出库的时候：箱一定是存在于箱库存当中的，没有则返回提示“箱库存数据不存在，请稍候再试！” // 获取箱库存 var boxInventory = boxInventorys.Where(x => x.BoxId == dto.BoxId).FirstOrDefault(); if (boxInventory == null) return Result.ReFailure(ResultCodes.BoxInventoryNoDataError); //按箱：出库 if (dto.InventoryInOutMethod == (int)InventoryInOutMethod.Box) { //直接添加要删除的箱 delete_ids.Add(boxInventory.Id); } //按产品：出库 else { //3.3创建更新对象 var update_entity = boxInventory; update_entity.Details = boxInventory.Details; //3.2.遍历：dto明细 foreach (var dtoItem in dto.Details) { //3.3.找到当前明细物料：没有则返回失败；提示：“该箱物料库存不存在” var update_entityDetail = update_entity.Details.Where(x => x.MaterialNumber == dtoItem.MaterialNumber).FirstOrDefault(); if (update_entityDetail == null) return Result.ReFailure(ResultCodes.BoxInventoryMaterialNoDataError); //3.4判断库存数量是否不足 if (update_entityDetail.Qty < dtoItem.Qty) return Result.ReFailure(ResultCodes.BoxInventoryNoInventoryError); //3.5物料库存数量变更：减库存 update_entityDetail.Qty = update_entityDetail.Qty - dtoItem.Qty; //3.6移除要出库的序列号 update_entityDetail.SerialNumbers.RemoveAll(x => dtoItem.SerialNumbers.Contains(x)); } //4.1判断要修改的箱库存对象：是否所有的物料库存的数量都为0，“是”则删除该箱库存,"否"则修改； var isAllNoInventory = update_entity.Details.All(x => x.Qty == 0); if (isAllNoInventory) delete_ids.Add(update_entity.Id); else //4.2添加要更新的箱库存实体 update_entitys.Add(update_entity); } return Result.ReSuccess(); } /// /// 生成入库对象：新增和修改 /// /// /// /// /// /// private Result GenerateInStockBox(BoxInventoryGenerateDto dto, List boxInventorys, List add_entitys, List update_entitys) { //按箱上架入库 if (dto.InventoryInOutMethod == (int)InventoryInOutMethod.Box) { //3.1上架的时候：箱一定是不存在于箱库存当中的，有则返回提示“已有箱库存，不需要再扫上架” var isHave = boxInventorys.Where(x => x.BoxId == dto.BoxId).Any(); if (isHave) return Result.ReFailure(ResultCodes.BoxInventoryHaveInventoryError); //3.2组装要新增的箱库存信息：箱和明细和序列号 var addEntity = _mapper.Map(dto); addEntity.Details = _mapper.Map>(dto.Details); add_entitys.Add(addEntity); } //按产品上架入库 else { //按产品上架：箱只能是一个；箱可能存在库存（修改），也可能不存在库存（新增） var boxInventory = boxInventorys.Where(x => x.BoxId == dto.BoxId).FirstOrDefault(); if (boxInventory == null) { //3.2组装要新增的箱库存信息：箱和明细和序列号 var addEntity = _mapper.Map(dto); addEntity.Details = _mapper.Map>(dto.Details); add_entitys.Add(addEntity); } else { //3.3创建更新对象 var update_entity = boxInventory; update_entity.Details = boxInventory.Details; foreach (var dtoItem in dto.Details) { //明细对应的物料：存在就修改，不存在即新增 var update_entity_det = new BoxInventoryDetails(); var updateDetail = update_entity.Details.Where(x => x.MaterialNumber == dtoItem.MaterialNumber).FirstOrDefault(); if (updateDetail == null) { update_entity_det.Qty = dtoItem.Qty; update_entity_det.MaterialNumber = dtoItem.MaterialNumber; update_entity_det.SerialNumbers = dtoItem.SerialNumbers; update_entity.Details.Add(update_entity_det); } else { updateDetail.Qty = updateDetail.Qty + dtoItem.Qty; updateDetail.SerialNumbers.AddRange(dtoItem.SerialNumbers); } } update_entitys.Add(update_entity); } } return Result.ReSuccess(); } /// /// 生成即时库存对象：新增和修改 /// /// /// private List GenerateInventoryDetails(BoxInventoryGenerateDto dto) { var invDtos = new List(); foreach (var dtoDet in dto.Details) { var invDto = new InventoryDetailsGenerateDto(); invDto.OrgCode = dto.OrgCode; invDto.InventoryInOutType = dto.InventoryInOutType; invDto.StockCode = dto.StockCode; invDto.SubStockCode = dto.SubStockCode; invDto.MaterialNumber = dtoDet.MaterialNumber; invDto.Qty = dtoDet.Qty; invDtos.Add(invDto); } return invDtos; } } }