using Furion.DatabaseAccessor;
|
using Furion.DependencyInjection;
|
using Furion.DynamicApiController;
|
using Furion.FriendlyException;
|
using Mapster;
|
using Microsoft.AspNetCore.Mvc;
|
using Microsoft.EntityFrameworkCore;
|
using Yitter.IdGenerator;
|
using Admin.NET.Core;
|
|
namespace Admin.NET.Application
|
{
|
/// <summary>
|
/// 出库管理服务
|
/// </summary>
|
[ApiDescriptionSettings("自己的业务", Name = "ExWarehouse", Order = 100)]
|
[Route("api/[Controller]")]
|
public class ExWarehouseService : IDynamicApiController, ITransient
|
{
|
private readonly IRepository<WmsArea, MasterDbContextLocator> _wmsAreaRep;
|
private readonly IRepository<WmsPlace, MasterDbContextLocator> _wmsPlaceRep;
|
private readonly IRepository<WmsTask, MasterDbContextLocator> _wmsTaskRep;
|
private readonly IRepository<WmsContainer, MasterDbContextLocator> _wmsContainerRep;
|
private readonly IRepository<WmsContainerPlace, MasterDbContextLocator> _wmsContainerPlaceRep;
|
private readonly IRepository<WmsMaterial, MasterDbContextLocator> _wmsMaterialRep;
|
private readonly IRepository<WmsMaterialStock, MasterDbContextLocator> _wmsMaterialStockRep;
|
private readonly IRepository<WmsMaterialContainer, MasterDbContextLocator> _wmsMaterialContainerRep;
|
|
/// <summary>
|
/// 构造函数
|
/// </summary>
|
public ExWarehouseService(
|
IRepository<WmsArea, MasterDbContextLocator> wmsAreaRep,
|
IRepository<WmsPlace, MasterDbContextLocator> wmsPlaceRep,
|
IRepository<WmsTask, MasterDbContextLocator> wmsTaskRep,
|
IRepository<WmsContainer, MasterDbContextLocator> wmsContainerRep,
|
IRepository<WmsContainerPlace, MasterDbContextLocator> wmsContainerPlaceRep,
|
IRepository<WmsMaterial, MasterDbContextLocator> wmsMaterialRep,
|
IRepository<WmsMaterialStock, MasterDbContextLocator> wmsMaterialStockRep,
|
IRepository<WmsMaterialContainer, MasterDbContextLocator> wmsMaterialContainerRep
|
)
|
{
|
this._wmsAreaRep = wmsAreaRep;
|
this._wmsPlaceRep = wmsPlaceRep;
|
this._wmsTaskRep = wmsTaskRep;
|
this._wmsContainerRep = wmsContainerRep;
|
this._wmsContainerPlaceRep = wmsContainerPlaceRep;
|
this._wmsMaterialRep = wmsMaterialRep;
|
this._wmsMaterialStockRep = wmsMaterialStockRep;
|
this._wmsMaterialContainerRep = wmsMaterialContainerRep;
|
}
|
|
|
|
|
/// <summary>
|
/// 分页查询物料出库管理信息
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpGet("page")]
|
public async Task<PageResult<ExWareHouseOutput>> Page([FromQuery] ExWarehouseSearch input)
|
{
|
var wmsMaterialStocks = await _wmsMaterialStockRep.DetachedEntities
|
.Where (!string.IsNullOrEmpty(input.MaterialName), u => EF.Functions.Like(u.MaterialName, $"%{input.MaterialName.Trim()}%"))
|
.ProjectToType<ExWareHouseOutput>()
|
.ToListAsync();
|
return wmsMaterialStocks.ToADPagedList(input.PageNo, input.PageSize);
|
}
|
|
/// <summary>
|
/// 自动出库
|
/// </summary>
|
/// <param name="inputs"></param>
|
/// <returns></returns>
|
[HttpPost("AutoExWarehouse")]
|
[UnitOfWork]
|
public async Task AutoExWarehouse(List<ExWarehouseInput> inputs)
|
{
|
// 根据托盘号、库位编号去重
|
var containerCodeDistinct = inputs.Select(u => new { u.ContainerCode, u.PlaceCode }).Distinct().ToList();
|
if (containerCodeDistinct.Count <= 0) throw Oops.Oh("暂无库存出库");
|
|
// 查询库区名称
|
var wmsArea = await _wmsAreaRep.FirstOrDefaultAsync(u => u.AreaName.Contains("绝缘立库"));
|
if (wmsArea != null) throw Oops.Oh("库区不存在");
|
|
foreach (var item in containerCodeDistinct)
|
{
|
var wmsMaterialContainerList = new List<WmsMaterialContainer>();
|
// 判断任务
|
var wmsTask = await _wmsTaskRep.FirstOrDefaultAsync(p => p.ContainerCode == item.ContainerCode && p.TaskStatus != TaskStatusEnum.WANCHENG);
|
if (wmsTask != null) throw Oops.Oh("周转箱号存在未完成的任务!");
|
|
// 检查周转箱号信息
|
var wmsContainer = await _wmsContainerRep.FirstOrDefaultAsync(n => n.ContainerCode == item.ContainerCode);
|
if (wmsContainer == null) throw Oops.Oh("库存中没有该：" + wmsContainer.ContainerCode + "托盘!");
|
|
// 检查库位信息
|
var wmsPlace = await _wmsPlaceRep.FirstOrDefaultAsync(p => p.PlaceCode == item.PlaceCode);
|
if (wmsPlace == null) throw Oops.Oh("库位不存在!");
|
if (wmsPlace.Islock == YesOrNot.Y) throw Oops.Oh("库位被锁定!");
|
|
// 更新状态为“待出”
|
wmsPlace.PlaceStatus = PlaceStatus.DAICHU;
|
await _wmsPlaceRep.UpdateAsync(wmsPlace);
|
|
// 检查库存
|
var wmsMaterialStockList = inputs.Where(u => u.ContainerCode == wmsContainer.ContainerCode && u.PlaceCode == wmsPlace.PlaceCode).ToList();
|
if (wmsMaterialStockList.Count <= 0) throw Oops.Oh("库存数据异常!");
|
|
// 检查库位与周转箱号关系
|
var wmsContainerPlace = await _wmsContainerPlaceRep.FirstOrDefaultAsync(p => p.ContainerCode == wmsContainer.ContainerCode && p.ContainerId == wmsContainer.Id
|
&& p.PlaceCode == wmsPlace.PlaceCode && p.PlaceId == wmsPlace.Id && p.ContainerPlaceStatus == CommonStatus.ENABLE);
|
if (wmsContainerPlace == null) throw Oops.Oh("托盘号与库位关系不存在!");
|
|
// 不是空料箱才会有组盘关系
|
if (wmsPlace.EmptyContainer == YesOrNot.N)
|
{
|
// 检查物料与周转箱号关系
|
wmsMaterialContainerList = await _wmsMaterialContainerRep.Where(p => p.ContainerCode == wmsContainer.ContainerCode && p.BindStatus == CommonStatus.ENABLE).ToListAsync();
|
if (wmsMaterialContainerList.Count <= 0) throw Oops.Oh("周转箱号与物料关系不存在!");
|
}
|
else
|
{
|
// 更新空料箱库存
|
var wmsMaterialStock = await _wmsMaterialStockRep.FirstOrDefaultAsync(u => u.ContainerCode == wmsContainer.ContainerCode);
|
if (wmsMaterialStock.Source == RuKuSourceEnum.KONGTUO)
|
{
|
wmsMaterialStock.PlaceCode = "N/A";
|
await _wmsMaterialStockRep.UpdateAsync(wmsMaterialStock);
|
}
|
}
|
if (wmsTask == null)
|
{
|
string taskNo = "CHUKU" + DateTime.Today.ToString("yyyyMMdd");
|
var wmsTaskModel = await _wmsTaskRep.DetachedEntities.FirstOrDefaultAsync(u => EF.Functions.Like(u.TaskNo, $"%{taskNo}%"));
|
if (wmsTaskModel == null)
|
{
|
taskNo = taskNo + "0001";
|
}
|
else
|
{
|
//获取流水号最大的数据
|
var maxSerialNumber = await _wmsTaskRep.MaxAsync(t => t.TaskNo);
|
taskNo = Comm.GenerateNewInvoiceNumber(maxSerialNumber, 1);
|
}
|
|
// 新增任务
|
var takmodel = new WmsTask()
|
{
|
TaskNo = taskNo,//YitIdHelper.NextId().ToString(),
|
TaskModel = TaskModel.QUANZIDONG,
|
TaskType = TaskType.CHUKU,
|
TaskLevel = 1,
|
TaskStatus = TaskStatusEnum.WEIZHIXING,
|
ContainerCode = wmsContainer.ContainerCode,
|
SourcePlace = wmsPlace.PlaceCode,
|
Aisle = wmsPlace.Aisle,
|
ToPlace = "出库口",
|
AreaName = wmsArea.AreaName,
|
Description = wmsPlace.EmptyContainer == YesOrNot.Y ? "空托" : "物料",
|
OrderNo = wmsMaterialContainerList.Count <= 0 ? "N/A" : wmsMaterialContainerList.FirstOrDefault().OrderNo,
|
TaskDodeviceStatus = TaskDodeviceStatusEnum.W,
|
IsRead = true
|
};
|
await _wmsTaskRep.InsertAsync(takmodel);
|
}
|
}
|
}
|
|
/// <summary>
|
/// 人工出库
|
/// </summary>
|
/// <param name="inputs"></param>
|
/// <returns></returns>
|
[HttpPost("manualExWarehouse")]
|
[UnitOfWork]
|
public async Task ManualExWarehouse(List<ExWarehouseInput> inputs)
|
{
|
// 根据托盘号、库位编号去重
|
var containerCodeDistinct = inputs.Select(u => new { u.ContainerCode, u.PlaceCode }).Distinct().ToList();
|
if (containerCodeDistinct.Count <= 0) throw Oops.Oh("暂无库存出库");
|
|
// 查询库区名称
|
var wmsArea = await _wmsAreaRep.FirstOrDefaultAsync(u => u.AreaName.Contains("绝缘立库"));
|
if (wmsArea != null) throw Oops.Oh("库区不存在");
|
|
foreach (var item in containerCodeDistinct)
|
{
|
var wmsMaterialContainerList = new List<WmsMaterialContainer>();
|
// 判断任务
|
var wmsTask = await _wmsTaskRep.FirstOrDefaultAsync(p => p.ContainerCode == item.ContainerCode && p.TaskStatus != TaskStatusEnum.WANCHENG);
|
if (wmsTask != null) throw Oops.Oh("托盘号存在未完成的任务!");
|
|
// 检查托盘号信息
|
var wmsContainer = await _wmsContainerRep.FirstOrDefaultAsync(n => n.ContainerCode == item.ContainerCode);
|
if (wmsContainer == null) throw Oops.Oh("周转箱号不存在!");
|
|
// 检查库位信息
|
var wmsPlace = await _wmsPlaceRep.FirstOrDefaultAsync(p => p.PlaceCode == item.PlaceCode);
|
if (wmsPlace == null) throw Oops.Oh("库位不存在!");
|
if (wmsPlace.Islock == YesOrNot.Y) throw Oops.Oh("库位被锁定!");
|
|
// 检查库存
|
var wmsMaterialStockList = inputs.Where(u => u.ContainerCode == wmsContainer.ContainerCode && u.PlaceCode == wmsPlace.PlaceCode).ToList();
|
if (wmsMaterialStockList.Count <= 0) throw Oops.Oh("库存数据异常!");
|
|
// 检查库位与托盘号关系
|
var wmsContainerPlace = await _wmsContainerPlaceRep.FirstOrDefaultAsync(p => p.ContainerCode == wmsContainer.ContainerCode && p.ContainerId == wmsContainer.Id
|
&& p.PlaceCode == wmsPlace.PlaceCode && p.PlaceId == wmsPlace.Id && p.ContainerPlaceStatus == CommonStatus.ENABLE);
|
if (wmsContainerPlace == null) throw Oops.Oh("托盘号与库位关系不存在!");
|
|
|
// 不是空托才会有组盘关系
|
if (wmsPlace.EmptyContainer == YesOrNot.N)
|
{
|
// 检查物料与空托号关系
|
wmsMaterialContainerList = await _wmsMaterialContainerRep.Where(p => p.ContainerCode == wmsContainer.ContainerCode && p.BindStatus == CommonStatus.ENABLE).ToListAsync();
|
if (wmsMaterialContainerList.Count <= 0) throw Oops.Oh("托盘号与物料关系不存在!");
|
}
|
else
|
{
|
// 更新空料箱库存
|
var wmsMaterialStock = await _wmsMaterialStockRep.FirstOrDefaultAsync(u => u.ContainerCode == wmsContainer.ContainerCode);
|
if (wmsMaterialStock.Source == RuKuSourceEnum.KONGTUO)
|
{
|
await _wmsMaterialStockRep.DeleteAsync(wmsMaterialStock);
|
}
|
}
|
|
if (wmsTask == null)
|
{
|
//构建出库物料和周转箱号关系
|
var orderNo = "N/A";
|
if (wmsMaterialContainerList.Count > 0) orderNo = YitIdHelper.NextId().ToString();
|
|
foreach (var wmsMaterialContaine in wmsMaterialContainerList)
|
{
|
//更新状态为”删除“
|
wmsMaterialContaine.BindStatus = CommonStatus.DELETED;
|
await _wmsMaterialContainerRep.UpdateNowAsync(wmsMaterialContaine);
|
|
//新增组盘绑定记录 正常
|
var addWmsMaterialContainer = wmsMaterialContaine;
|
addWmsMaterialContainer.Id = YitIdHelper.NextId();
|
addWmsMaterialContainer.OrderNo = orderNo;
|
addWmsMaterialContainer.BindStatus = CommonStatus.ENABLE;
|
await _wmsMaterialContainerRep.InsertNowAsync(addWmsMaterialContainer);
|
// 这里没有分拣操作直接更新库存信息
|
var wmsMaterialStock = await _wmsMaterialStockRep.FirstOrDefaultAsync(u => u.ContainerCode == wmsMaterialContaine.ContainerCode);
|
wmsMaterialStock.PlaceCode = "N/A";
|
wmsMaterialStock.StockNumber -= wmsMaterialContaine.BindQuantity;
|
await _wmsMaterialStockRep.UpdateAsync(wmsMaterialStock);
|
}
|
|
string taskNo = "CHUKU" + DateTime.Today.ToString("yyyyMMdd");
|
var wmsTaskModel = await _wmsTaskRep.DetachedEntities.FirstOrDefaultAsync(u => EF.Functions.Like(u.TaskNo, $"%{taskNo}%"));
|
if (wmsTaskModel == null)
|
{
|
taskNo = taskNo + "0001";
|
}
|
else
|
{
|
//获取流水号最大的数据
|
var maxSerialNumber = await _wmsTaskRep.MaxAsync(t => t.TaskNo);
|
taskNo = Comm.GenerateNewInvoiceNumber(maxSerialNumber, 1);
|
}
|
// 新增任务
|
var addWmsTask = new WmsTask()
|
{
|
TaskNo = taskNo,//YitIdHelper.NextId().ToString(),
|
TaskModel = TaskModel.SHOUDONG,
|
TaskType = TaskType.CHUKU,
|
TaskLevel = 1,
|
TaskStatus = TaskStatusEnum.WANCHENG,
|
ContainerCode = wmsContainer.ContainerCode,
|
SourcePlace = wmsPlace.PlaceCode,
|
Aisle = wmsPlace.Aisle,
|
ToPlace = "出库口",
|
AreaName = wmsArea.AreaName,
|
Description = wmsPlace.EmptyContainer == YesOrNot.Y ? "空托" : "物料",
|
OrderNo = orderNo,
|
TaskDodeviceStatus=TaskDodeviceStatusEnum.W,
|
UpdatedTime = DateTime.Now,
|
};
|
await _wmsTaskRep.InsertAsync(addWmsTask);
|
|
// 更新库位与周转箱号关系表状态为“删除”
|
wmsContainerPlace.ContainerPlaceStatus = CommonStatus.DELETED;
|
await _wmsContainerPlaceRep.UpdateAsync(wmsContainerPlace);
|
|
// 更新库位为“空闲”
|
wmsPlace.PlaceStatus = PlaceStatus.KONGXIAN;
|
wmsPlace.Islock = YesOrNot.N;
|
wmsPlace.EmptyContainer = YesOrNot.N;
|
await _wmsPlaceRep.UpdateAsync(wmsPlace);
|
|
// 更新周转箱号状态为“空闲”
|
wmsContainer.ContainerStatus = ContainerStatus.KOUXIAN;
|
await _wmsContainerRep.UpdateAsync(wmsContainer);
|
}
|
}
|
}
|
|
|
/// <summary>
|
/// 呼叫空托
|
/// </summary>
|
/// <returns></returns>
|
[HttpPost("callairflare")]
|
[UnitOfWork]
|
public async Task CallAirflare(CallAirflareInput input)
|
{
|
//获取库位中存货是空托的库位
|
var wmsPlace = await _wmsPlaceRep.Where(u => u.PlaceStatus == PlaceStatus.CUNHUO && u.EmptyContainer== YesOrNot.Y).ToListAsync();
|
if (wmsPlace.Count > 0)
|
{
|
|
}
|
}
|
}
|
}
|
