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 = "BindEntrance", Order = 100)]
|
[Route("api/[Controller]")]
|
public class BindEntranceService : 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 BindEntranceService(
|
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("getcontainer")]
|
[UnifyResult(typeof(BindEntranceOutput))]
|
public async Task<object> GetContainer([FromQuery] BindEntranceInput input)
|
{
|
var bindEntranceOutputModel = new BindEntranceOutput();
|
|
var wmsContainer = await _wmsContainerRep.FirstOrDefaultAsync(n => n.ContainerCode == input.ContainerCode && n.ContainerStatus != ContainerStatus.JINYONG);
|
if (wmsContainer == null)
|
{
|
var newWmsContainer = new WmsContainerDto();
|
newWmsContainer.ContainerCode = input.ContainerCode;
|
newWmsContainer.ContainerStatus = ContainerStatus.KOUXIAN;
|
newWmsContainer.ContainerType = ContainerType.SULIAO;
|
|
bindEntranceOutputModel.ContainerCode = input.ContainerCode;
|
bindEntranceOutputModel.WmsContainer = newWmsContainer;
|
|
if (wmsContainer != null)
|
{
|
var isWmsTask = await _wmsTaskRep.AnyAsync(p => p.ContainerCode == wmsContainer.ContainerCode && p.TaskStatus != TaskStatusEnum.WANCHENG);
|
if (isWmsTask) return XnRestfulResultProvider.RESTfulMesaage("周转箱号存在未完成任务!");
|
|
bindEntranceOutputModel.WmsContainer = wmsContainer.Adapt<WmsContainerDto>();
|
bindEntranceOutputModel.ContainerCode = wmsContainer.ContainerCode;
|
|
// 周转箱号组盘状态
|
if (wmsContainer.ContainerStatus == ContainerStatus.ZUPANG)
|
{
|
bindEntranceOutputModel.WmsMaterials = await _wmsMaterialContainerRep
|
.Where(p => p.ContainerCode == wmsContainer.ContainerCode && p.BindStatus == CommonStatus.ENABLE).ProjectToType<GetMaterialContainerOutput>().ToListAsync();
|
|
return XnRestfulResultProvider.RESTfulResult(bindEntranceOutputModel);
|
}
|
// 周转箱号库位状态
|
if (wmsContainer.ContainerStatus == ContainerStatus.KUWEI)
|
{
|
// 查询周转箱号与库位关系
|
var wmsContainerPlace = await _wmsContainerPlaceRep.FirstOrDefaultAsync(u => u.ContainerId == wmsContainer.Id && u.ContainerCode == wmsContainer.ContainerCode);
|
|
if (wmsContainerPlace != null) bindEntranceOutputModel.PlaceCode = wmsContainerPlace.PlaceCode;
|
|
return XnRestfulResultProvider.RESTfulResult(bindEntranceOutputModel);
|
}
|
}
|
}
|
return XnRestfulResultProvider.RESTfulResult(bindEntranceOutputModel);
|
}
|
|
/// <summary>
|
/// 扫码获取物料
|
/// </summary>
|
/// <returns></returns>
|
[HttpGet("GetMaterial")]
|
[UnifyResult(typeof(MaterialOutput))]
|
public async Task<object> GetMaterial([FromQuery] GetMaterialInput input)
|
{
|
var material = new MaterialOutput();
|
material.MaterialName = "胶合板";
|
material.MaterialNo = "JHB20110101";
|
material.MaterialId = 43214325321513;
|
material.MaterialBatch = "DIYIPICI001";
|
material.MaterialType = MaterialType.BAOZHUANGCAILIAO;
|
material.InspectionMethod = MaterialInspection.MIANJIAN;
|
material.MaterialSpec = "";
|
material.MaterialDensity = "";
|
material.MaterialUnit = "";
|
material.LesWorkshopSection = LesWorkshopSection.CNC;
|
return XnRestfulResultProvider.RESTfulResult(material);
|
|
}
|
|
|
/// <summary>
|
/// 组盘
|
/// </summary>
|
/// <returns></returns>
|
[HttpPost("AutoWare")]
|
public async Task AutoWare(WarehousingInput input)
|
{
|
// 根据托盘号查询托盘号信息是否已存在
|
var wmsContainer = await _wmsContainerRep.FirstOrDefaultAsync(u => u.ContainerCode == input.ContainerCode);
|
if (wmsContainer == null)
|
{
|
// 不存在则添加托盘号信息
|
wmsContainer = new WmsContainer
|
{
|
ContainerCode = input.ContainerCode,
|
ContainerType = ContainerType.SULIAO,
|
ContainerStatus = ContainerStatus.KOUXIAN,
|
AssetNo = "N/A",
|
ErpNo = "N/A"
|
};
|
await _wmsContainerRep.InsertNowAsync(wmsContainer);
|
}
|
// 查询是否任务已存在
|
var isExit = await _wmsTaskRep.AnyAsync(p => p.ContainerCode == wmsContainer.ContainerCode && p.TaskStatus != TaskStatusEnum.WANCHENG);
|
if (isExit) throw Oops.Oh("托盘号存在未完成任务中!");
|
|
// 查询已组盘信息
|
var wmsMaterialContainerList = await _wmsMaterialContainerRep
|
.Where(p => p.ContainerCode == wmsContainer.ContainerCode && p.BindStatus == CommonStatus.ENABLE).ToListAsync();
|
await _wmsMaterialContainerRep.DeleteAsync(wmsMaterialContainerList);
|
var orderNo = "N/A";
|
if (input.WmsMaterials.Count > 0)
|
{
|
wmsContainer.ContainerStatus = ContainerStatus.ZUPANG;
|
orderNo = YitIdHelper.NextId().ToString();
|
await _wmsContainerRep.UpdateAsync(wmsContainer);
|
}
|
// 创建新组盘记录
|
foreach (var item in input.WmsMaterials)
|
{
|
//创建组盘记录
|
var bindentranceModel = new WmsMaterialContainer();
|
bindentranceModel.ContainerId = wmsContainer.Id;
|
bindentranceModel.ContainerCode = wmsContainer.ContainerCode;
|
bindentranceModel.MaterialNo = item.MaterialNo;
|
bindentranceModel.MaterialId = 478183507525701;
|
bindentranceModel.MaterialBatch = item.MaterialBatch;
|
bindentranceModel.BindQuantity = 1;
|
bindentranceModel.BindStatus = CommonStatus.ENABLE;
|
bindentranceModel.OrderNo = orderNo;
|
bindentranceModel.MaterialName = item.MaterialName;
|
bindentranceModel.MaterialDensity = "N/A";
|
await _wmsMaterialContainerRep.InsertNowAsync(bindentranceModel);
|
}
|
}
|
|
|
|
/// <summary>
|
/// 自动入库
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost("automaticWarehousing")]
|
[UnitOfWork]
|
public async Task AutomaticWarehousing(WarehousingInput input)
|
{
|
// 查询混合料库区信息
|
var wmsArea = await _wmsAreaRep.FirstOrDefaultAsync(u => u.AreaName.Contains("绝缘立库"));
|
// 根据料箱号查询周转箱号信息是否已存在
|
var wmsContainer = await _wmsContainerRep.FirstOrDefaultAsync(u => u.ContainerCode == input.ContainerCode);
|
if (wmsContainer == null)
|
{
|
// 不存在则添加周转箱号信息
|
wmsContainer = new WmsContainer
|
{
|
ContainerCode = input.ContainerCode,
|
ContainerType = ContainerType.JINSHU,
|
ContainerStatus = ContainerStatus.KOUXIAN,
|
AssetNo = "N/A",
|
ErpNo = "N/A"
|
};
|
await _wmsContainerRep.InsertNowAsync(wmsContainer);
|
}
|
else
|
{
|
// 更新周转箱号状态为“库位”
|
wmsContainer.ContainerStatus = ContainerStatus.KOUXIAN;
|
await _wmsContainerRep.UpdateAsync(wmsContainer);
|
}
|
|
// 查询周转箱号是否已存在任务
|
var isWmsTask = await _wmsTaskRep.AnyAsync(p => p.ContainerCode == wmsContainer.ContainerCode && p.TaskStatus != TaskStatusEnum.WANCHENG);
|
if (isWmsTask) throw Oops.Oh("周转箱号存在未完成任务中!");
|
|
// 删除已组盘信息
|
var oldWmsMaterialContainerList = await _wmsMaterialContainerRep
|
.Where(p => p.ContainerCode == wmsContainer.ContainerCode && p.BindStatus == CommonStatus.ENABLE).ToListAsync();
|
|
foreach (var item in oldWmsMaterialContainerList)
|
{
|
await _wmsMaterialContainerRep.DeleteAsync(item);
|
}
|
|
// 组盘单据 默认空料箱单据
|
var source = ""; //定义入库来源
|
var orderNo = "N/A";
|
if (input.WmsMaterials.Count > 0)
|
{
|
wmsContainer.ContainerStatus = ContainerStatus.ZUPANG;
|
orderNo = YitIdHelper.NextId().ToString();
|
await _wmsContainerRep.UpdateAsync(wmsContainer);
|
source = "物料";
|
}
|
else
|
{
|
source = "空托";
|
}
|
// 查询物料Id
|
var wmsMaterial = await _wmsMaterialRep.FirstOrDefaultAsync(u => u.MaterialNo == "N/A" && u.MaterialName == "N/A" && u.MaterialBatch == "N/A");
|
|
// 创建新组盘记录
|
foreach (var item in input.WmsMaterials)
|
{
|
var wmsMaterialContainer = item.Adapt<WmsMaterialContainer>();
|
wmsMaterialContainer.OrderNo = orderNo;
|
wmsMaterialContainer.ContainerId = wmsContainer.Id;
|
wmsMaterialContainer.ContainerCode = wmsContainer.ContainerCode;
|
wmsMaterialContainer.MaterialId = wmsMaterial.Id;
|
wmsMaterialContainer.BindStatus = CommonStatus.ENABLE;
|
await _wmsMaterialContainerRep.InsertNowAsync(wmsMaterialContainer);
|
}
|
|
|
//if (input.Source == RuKuSourceEnum.KONGTUO)
|
//else if (input.Source == RuKuSourceEnum.WULIAO)
|
|
//创建巷道分配
|
var wmsPlace = await _wmsPlaceRep.Where(u => u.PlaceStatus == PlaceStatus.KONGXIAN).ToListAsync();
|
var one = wmsPlace.Where(s => s.Aisle==1).ToList().Count;
|
var two = wmsPlace.Where(s => s.Aisle == 2).ToList().Count;
|
var three = wmsPlace.Where(s => s.Aisle == 3).ToList().Count;
|
var Aisle = 0;
|
if (one >= two && one >= three)
|
{
|
Aisle = 1;
|
}
|
else if (two >= one && two >= three)
|
{
|
Aisle = 2;
|
}
|
else
|
{
|
Aisle = 3;
|
}
|
|
string taskNo = "RUKU"+ 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.RUKU,
|
TaskLevel = 1,
|
Aisle = Aisle,
|
TaskStatus = TaskStatusEnum.WEIZHIXING,
|
ContainerCode = wmsContainer.ContainerCode,
|
SourcePlace = "入库口",
|
ToPlace = "",
|
AreaName = wmsArea != null ? wmsArea.AreaName : "",
|
OrderNo = orderNo,
|
Description = source, //入库来源
|
TaskDodeviceStatus = TaskDodeviceStatusEnum.WZX,
|
IsRead = true
|
};
|
await _wmsTaskRep.InsertAsync(takmodel);
|
}
|
|
|
|
|
|
/// <summary>
|
/// 人工入库
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost("manualWarehousing")]
|
[UnitOfWork]
|
public async Task ManualWarehousing(WarehousingInput input)
|
{
|
// 查询混合料库区信息
|
var wmsArea = await _wmsAreaRep.FirstOrDefaultAsync(u => u.AreaName.Contains("绝缘立库"));
|
// 根据料箱号查询周转箱号信息是否已存在
|
var wmsContainer = await _wmsContainerRep.FirstOrDefaultAsync(u => u.ContainerCode == input.ContainerCode);
|
if (wmsContainer == null)
|
{
|
// 不存在则添加周转箱号信息
|
wmsContainer = new WmsContainer
|
{
|
ContainerCode = input.ContainerCode,
|
ContainerType = ContainerType.JINSHU,
|
ContainerStatus = ContainerStatus.KUWEI,
|
AssetNo = "N/A",
|
ErpNo = "N/A"
|
};
|
await _wmsContainerRep.InsertNowAsync(wmsContainer);
|
}
|
else
|
{
|
// 更新周转箱号状态为“库位”
|
wmsContainer.ContainerStatus = ContainerStatus.KUWEI;
|
await _wmsContainerRep.UpdateAsync(wmsContainer);
|
}
|
|
// 查询周转箱号是否已存在任务
|
var isWmsTask = await _wmsTaskRep.AnyAsync(p => p.ContainerCode == wmsContainer.ContainerCode && p.TaskStatus != TaskStatusEnum.WANCHENG);
|
if (isWmsTask) throw Oops.Oh("周转箱号存在未完成任务中!");
|
|
// 删除已组盘信息
|
var oldWmsMaterialContainerList = await _wmsMaterialContainerRep
|
.Where(p => p.ContainerCode == wmsContainer.ContainerCode && p.BindStatus == CommonStatus.ENABLE).ToListAsync();
|
|
foreach (var item in oldWmsMaterialContainerList)
|
{
|
await _wmsMaterialContainerRep.DeleteAsync(item);
|
}
|
|
// 查询库位信息 随机分配库位
|
var wmsPlace = new WmsPlace();
|
if (string.IsNullOrEmpty(input.PlaceCode))
|
wmsPlace = await _wmsPlaceRep.FirstOrDefaultAsync(u => u.AreaId == wmsArea.Id && u.Islock == YesOrNot.N && u.PlaceStatus == PlaceStatus.KONGXIAN);
|
else
|
wmsPlace = await _wmsPlaceRep.FirstOrDefaultAsync(u => u.AreaId == wmsArea.Id && u.PlaceCode == input.PlaceCode);
|
if (wmsPlace == null) throw Oops.Oh("库位不存在!");
|
if (wmsPlace.Islock == YesOrNot.Y) throw Oops.Oh("库位被锁定!");
|
if (wmsPlace.PlaceStatus != PlaceStatus.KONGXIAN) throw Oops.Oh("库位已存货!");
|
// 更新库位状态为“存货”
|
wmsPlace.PlaceStatus = PlaceStatus.CUNHUO;
|
|
// 组盘单据 默认空料箱单据
|
var orderNo = "N/A";
|
var source = ""; //定义入库来源
|
if (input.WmsMaterials.Count > 0)
|
{
|
orderNo = YitIdHelper.NextId().ToString();
|
source = "物料";
|
}
|
else
|
{
|
wmsPlace.EmptyContainer = YesOrNot.Y; //是否空托
|
source = "空托";
|
}
|
// 查询物料Id
|
var wmsMaterial = await _wmsMaterialRep.FirstOrDefaultAsync(u => u.MaterialNo == "N/A" && u.MaterialName == "N/A" && u.MaterialBatch == "N/A");
|
|
// 创建新组盘记录
|
foreach (var item in input.WmsMaterials)
|
{
|
var wmsMaterialContainer = item.Adapt<WmsMaterialContainer>();
|
wmsMaterialContainer.OrderNo = orderNo;
|
wmsMaterialContainer.ContainerId = wmsContainer.Id;
|
wmsMaterialContainer.ContainerCode = wmsContainer.ContainerCode;
|
wmsMaterialContainer.MaterialId = wmsMaterial.Id;
|
wmsMaterialContainer.BindStatus = CommonStatus.ENABLE;
|
|
await _wmsMaterialContainerRep.InsertNowAsync(wmsMaterialContainer);
|
}
|
|
string taskNo = "RUKU" + 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.SHOUDONG,
|
TaskType = TaskType.RUKU,
|
TaskLevel = 1,
|
Aisle = wmsPlace.Aisle,
|
TaskStatus = TaskStatusEnum.WANCHENG,
|
ContainerCode = wmsContainer.ContainerCode,
|
SourcePlace = "入库口",
|
ToPlace = wmsPlace.PlaceCode,
|
AreaName = wmsArea != null ? wmsArea.AreaName : "",
|
OrderNo = orderNo,
|
Description = source, //入库来源
|
TaskDodeviceStatus = TaskDodeviceStatusEnum.W,
|
UpdatedTime = DateTime.Now,
|
};
|
await _wmsTaskRep.InsertAsync(takmodel);
|
|
// 创建托盘号库位关系表
|
var wmsContainerPlaceModel = new WmsContainerPlace()
|
{
|
PlaceId = wmsPlace.Id,
|
PlaceCode = wmsPlace.PlaceCode,
|
ContainerId = wmsContainer.Id,
|
ContainerCode = wmsContainer.ContainerCode,
|
ContainerPlaceStatus = CommonStatus.ENABLE
|
};
|
await _wmsContainerPlaceRep.InsertAsync(wmsContainerPlaceModel);
|
|
// 更新库存
|
var wmsMaterialContainerList = await _wmsMaterialContainerRep.DetachedEntities
|
.Where(p => p.OrderNo == orderNo && p.BindStatus == CommonStatus.ENABLE).ProjectToType<WmsMaterialContainer>().ToListAsync();
|
|
foreach (var item in wmsMaterialContainerList)
|
{
|
var wmsMaterialStock = await _wmsMaterialStockRep.FirstOrDefaultAsync(p => p.ContainerCode == wmsContainer.ContainerCode
|
&& p.MaterialBatch == item.MaterialBatch );
|
if (wmsMaterialStock != null)
|
{
|
wmsMaterialStock.Source = RuKuSourceEnum.WULIAO;
|
wmsMaterialStock.AreaId = wmsPlace.AreaId;
|
wmsMaterialStock.PlaceCode = wmsPlace.PlaceCode;
|
wmsMaterialStock.StockNumber += item.BindQuantity;
|
await _wmsMaterialStockRep.UpdateAsync(wmsMaterialStock);
|
}
|
else
|
{
|
wmsMaterialStock = new WmsMaterialStock()
|
{
|
InspectionMethod = MaterialInspection.MIANJIAN,
|
UnitType = UnitType.ZHONGLIANG,
|
UnitNo = UnitNoType.T,
|
MaterialNo = item.MaterialNo,
|
MaterialType = MaterialType.CHENGPING,
|
MaterialName = item.MaterialName,
|
MaterialSpec = item.MaterialSpec,
|
MaterialBatch = item.MaterialBatch,
|
MaterialDensity = item.MaterialDensity,
|
StockNumber = 1,
|
PlaceCode = wmsPlace.PlaceCode,
|
ContainerId = wmsContainer.Id,
|
ContainerCode = wmsContainer.ContainerCode,
|
AreaId = wmsPlace.AreaId,
|
Source = RuKuSourceEnum.WULIAO
|
};
|
await _wmsMaterialStockRep.InsertAsync(wmsMaterialStock);
|
}
|
}
|
// 空料箱入库
|
if (orderNo == "N/A")
|
{
|
var wmsMaterialStock = new WmsMaterialStock()
|
{
|
InspectionMethod = MaterialInspection.MIANJIAN,
|
UnitType = UnitType.ZHONGLIANG,
|
UnitNo = UnitNoType.T,
|
MaterialNo = "N/A",
|
MaterialType = MaterialType.KONGTUO,
|
MaterialName = "N/A",
|
MaterialSpec = "N/A",
|
MaterialBatch = "N/A",
|
MaterialDensity = "N/A",
|
StockNumber = 0,
|
PlaceCode = wmsPlace.PlaceCode,
|
ContainerId = wmsContainer.Id,
|
ContainerCode = wmsContainer.ContainerCode,
|
AreaId = wmsPlace.AreaId,
|
Source = RuKuSourceEnum.KONGTUO
|
};
|
await _wmsMaterialStockRep.InsertAsync(wmsMaterialStock);
|
}
|
}
|
}
|
}
|
