using CMS.Plugin.HIAWms.Application.Contracts.Dtos.OutStockDto;
|
using CMS.Plugin.HIAWms.Application.Contracts.Services;
|
using CMS.Plugin.HIAWms.Domain.Shared.Enums;
|
using CMS.Plugin.HIAWms.Domain.WmsInOutStockOrder;
|
using CMS.Plugin.HIAWms.Domain.WmsMaterialStocks;
|
using CMS.Plugin.HIAWms.Domain.WmsTask;
|
using Microsoft.Extensions.DependencyInjection;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using Volo.Abp;
|
using Volo.Abp.Uow;
|
|
namespace CMS.Plugin.HIAWms.Application.Implements
|
{
|
/// <summary>
|
/// 出库服务
|
/// </summary>
|
public class WmsOutStockAppService : CMSPluginAppService, IWmsOutStockAppService
|
{
|
private readonly IWmsMaterialStockRepository _wmsMaterialStockRepository;
|
private readonly IWmsCommonAppService _wmsCommonAppService;
|
private readonly IWmsTaskRepository _wmsTaskRepository;
|
private readonly IWmsInOutStockOrderRepository _wmsInOutStockOrderRepository;
|
private readonly IServiceProvider _serviceProvider;
|
public WmsOutStockAppService(IWmsMaterialStockRepository wmsMaterialStockRepository,
|
IWmsCommonAppService wmsCommonAppService, IWmsTaskRepository wmsTaskRepository,
|
IWmsInOutStockOrderRepository wmsInOutStockOrderRepository, IServiceProvider serviceProvider
|
)
|
{
|
_wmsMaterialStockRepository = wmsMaterialStockRepository;
|
_wmsCommonAppService = wmsCommonAppService;
|
_wmsTaskRepository = wmsTaskRepository;
|
_wmsInOutStockOrderRepository = wmsInOutStockOrderRepository;
|
_serviceProvider = serviceProvider;
|
}
|
|
public async Task CallMaterialAsync(List<CallMaterialInput> input)
|
{
|
using var scope = _serviceProvider.CreateScope();
|
var unitOfWorkManager = scope.ServiceProvider.GetRequiredService<IUnitOfWorkManager>();
|
using var uow = unitOfWorkManager.Begin(requiresNew: true);
|
|
var distinctModels = input.Select(x => x.MaterialModel).Distinct().ToList();
|
if (distinctModels.Count > 1)
|
{
|
throw new UserFriendlyException("一次叫料只能针对同一型号的物料！");
|
}
|
foreach (var inputItem in input)
|
{
|
var order = await _wmsInOutStockOrderRepository.FindByNameAsync(inputItem.OrderNo);
|
if (order == null)
|
{
|
throw new UserFriendlyException("出库单据不存在");
|
}
|
if (inputItem.MaterialNumber <= 0)
|
{
|
throw new UserFriendlyException("叫料数量必须大于0");
|
}
|
if (order.MaterialNumber < inputItem.MaterialNumber)
|
{
|
throw new UserFriendlyException("叫料数量不能大于单据数量");
|
}
|
order.OrderStatus = OrderStatusEnum.Executing;
|
order.DistributeNumber = inputItem.MaterialNumber;
|
|
await _wmsInOutStockOrderRepository.UpdateAsync(order);
|
|
var stockresult = await _wmsCommonAppService.FindStockAsync(inputItem.MaterialModel, inputItem.MaterialNumber);
|
if (stockresult == null)
|
{
|
throw new UserFriendlyException("当前无库存");
|
}
|
var taskList = new List<WmsTask>();
|
foreach (var kvp in stockresult)
|
{
|
var stock = kvp.Key; // WmsPlace对象
|
var quantity = kvp.Value; // 分配数量
|
|
for (int i = 0; i < quantity; i++)
|
{
|
var task = new WmsTask
|
{
|
TaskNo = $"CK_{DateTime.Now:yyyyMMddHHmmss}_{Guid.NewGuid().ToString("N").Substring(0, 6)}",
|
ContainerNo = stock.ContainerNo,
|
SourcePlace = stock.PlaceNo,
|
ToPlace = "201",// place.PlaceNo,
|
TaskType = TaskTypeEnum.CHUKU,
|
SonTaskType = inputItem.OrderType == OrderTypeEnum.PRODUCTCALL ? SonTaskTypeEnum.ZDCHUKU : SonTaskTypeEnum.RGRUKU,
|
TaskStatus = WmsTaskStatus.WEIZHIXING,
|
TaskLevel = order.Priority,
|
Aisle = 1,
|
DodeviceId = 0,
|
TaskDodeviceStatus = TaskDodeviceStatus.SrmNoStart,
|
IsNextTask = (int)YesNoEnum.Y,
|
IsRead = true,
|
SourceOrderNo = inputItem.OrderNo,
|
MutableParam1 = inputItem.MaterialModel,
|
};
|
taskList.Add(task);
|
}
|
}
|
await _wmsTaskRepository.InsertManyAsync(taskList);
|
}
|
|
await uow.SaveChangesAsync();
|
await uow.CompleteAsync();
|
}
|
}
|
}
|
