using Admin.NET.Application.CommonHelper;
|
using Admin.NET.Application.Entity;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace Admin.NET.Application;
|
|
/// <summary>
|
/// 下架服务
|
/// </summary>
|
[ApiDescriptionSettings(ApplicationConst.WmsOperationsGroupName, Order = 100)]
|
public class WmsUnshelveService : IDynamicApiController, ITransient
|
{
|
private readonly SqlSugarRepository<WmsBasePlace> _wmsPlaceRep;
|
private readonly SqlSugarRepository<WmsBaseContainer> _wmsContainerRep;
|
private readonly SqlSugarRepository<WmsContainerPlace> _wmsContainerPlaceRep;
|
private readonly SqlSugarRepository<WmsStockQuan> _wmsStockQuanRep;
|
private readonly SqlSugarRepository<WmsTask> _wmsTaskRep;
|
private readonly SqlSugarRepository<WmsBaseContainerType> _wmsContainerTypeRep;
|
private readonly SqlSugarRepository<WmsBaseContainerPackaging> _wmsContainerPackagingRep;
|
private readonly SqlSugarRepository<v_wms_stock_quan> _v_wms_stock_quanRep;
|
private readonly SqlSugarRepository<WmsOrderMovement> _wmsOrderMovementRep;
|
private readonly SqlSugarRepository<WmsOrderMovementDetails> _wmsOrderMovementDetailsRep;
|
private readonly SqlSugarRepository<WmsConfigSerialSN> _repSNRep;
|
private readonly SqlSugarRepository<WmsConfigNoRule> _WmsNoCreateRuleRep;
|
private readonly SqlSugarRepository<WmsLogAction> _wmsLogActionRep;
|
private readonly SqlSugarRepository<WmsRecordTrans> _wmsRecordTransRep;
|
private readonly SqlSugarRepository<WmsBaseBusinessType> _wmsBaseBusinessTypeRep;
|
private readonly SqlSugarRepository<WmsBaseArea> _WmsAreaRep;
|
/// <summary>
|
/// 构造函数
|
/// </summary>
|
public WmsUnshelveService(SqlSugarRepository<WmsBasePlace> wmsPlaceRep,
|
SqlSugarRepository<WmsBaseContainer> wmsContainerRep,
|
SqlSugarRepository<WmsContainerPlace> wmsContainerPlaceRep,
|
SqlSugarRepository<WmsStockQuan> wmsStockQuanRep,
|
SqlSugarRepository<WmsTask> wmsTaskRep,
|
SqlSugarRepository<WmsBaseContainerType> wmsContainerTypeRep,
|
SqlSugarRepository<WmsBaseContainerPackaging> wmsContainerPackagingRep,
|
SqlSugarRepository<v_wms_stock_quan> v_wms_stock_quanRep,
|
SqlSugarRepository<WmsOrderMovement> wmsOrderMovementRep,
|
SqlSugarRepository<WmsOrderMovementDetails> wmsOrderMovementDetailsRep,
|
SqlSugarRepository<WmsConfigSerialSN> repSNRep,
|
SqlSugarRepository<WmsConfigNoRule> wmsNoCreateRuleRep,
|
SqlSugarRepository<WmsLogAction> wmsLogActionRep,
|
SqlSugarRepository<WmsRecordTrans> wmsRecordTransRep,
|
SqlSugarRepository<WmsBaseBusinessType> wmsBaseBusinessTypeRep,
|
SqlSugarRepository<WmsBaseArea> wmsAreaRep)
|
{
|
this._wmsPlaceRep = wmsPlaceRep;
|
this._wmsContainerRep = wmsContainerRep;
|
this._wmsContainerPlaceRep = wmsContainerPlaceRep;
|
this._wmsStockQuanRep = wmsStockQuanRep;
|
this._wmsTaskRep = wmsTaskRep;
|
this._wmsContainerTypeRep= wmsContainerTypeRep;
|
this._wmsContainerPackagingRep= wmsContainerPackagingRep;
|
this._v_wms_stock_quanRep = v_wms_stock_quanRep;
|
this._wmsOrderMovementRep= wmsOrderMovementRep;
|
this._wmsOrderMovementDetailsRep=wmsOrderMovementDetailsRep;
|
this._repSNRep= repSNRep;
|
this._WmsNoCreateRuleRep = wmsNoCreateRuleRep;
|
this._wmsLogActionRep = wmsLogActionRep;
|
this._wmsRecordTransRep = wmsRecordTransRep;
|
this._wmsBaseBusinessTypeRep = wmsBaseBusinessTypeRep;
|
this._WmsAreaRep = wmsAreaRep;
|
}
|
|
/// <summary>
|
/// PDA容器下架判断目标库位是否异常
|
/// </summary>
|
/// <returns></returns>
|
[HttpPost]
|
[ApiDescriptionSettings(Name = "GetPlaceInfo", Description = "PDA容器下架判断目标库位是否异常")]
|
[Description("/Unshelve/GetPlaceInfo")]
|
public async Task GetPlaceInfo(GetPlaceInfoInput input)
|
{
|
var wmsPlace = await _wmsPlaceRep.GetFirstAsync(o => o.PlaceCode == input.PlaceCode && o.IsDelete==false);
|
if(wmsPlace==null) throw Oops.Oh($"该地标/库位不存在，请检查库位基础数据！");
|
if (wmsPlace.PlaceStatus == PlaceStatusEnum.锁定)
|
{
|
var wmsTask = await _wmsTaskRep.GetFirstAsync(o => o.SourcePlaceCode == wmsPlace.PlaceCode&&o.TaskStatus== TaskStatusEnum.已下发);
|
throw Oops.Oh($"该库位被任务号{wmsTask.TaskNo}锁定，不可使用！");
|
}
|
if(wmsPlace.PlaceStatus== PlaceStatusEnum.封存) throw Oops.Oh($"该库位已冻结，不可使用！如需解冻，请先解冻该库位！");
|
}
|
|
/// <summary>
|
/// PDA下架查询-获取物料编号对应的容器类型
|
/// </summary>
|
/// <returns></returns>
|
[HttpGet]
|
[ApiDescriptionSettings(Name = "GetMaterialCodeByInfo", Description = "PDA容器下架查询-获取物料编号对应的容器类型")]
|
[Description("/Unshelve/GetMaterialCodeByInfo")]
|
public async Task<GetContainerTypeOutPut> GetMaterialCodeByInfo([FromQuery] GetMaterialCodeByInfoInput input)
|
{
|
if(string.IsNullOrEmpty(input.MaterialCode)) throw Oops.Oh($"物料编号不能为空！！");
|
var wmsMaterial = await _wmsContainerPackagingRep.AsQueryable().
|
WhereIF(!string.IsNullOrEmpty(input.MaterialCode), o => o.MaterialCode.Contains(input.MaterialCode.Trim())).FirstAsync();
|
if (wmsMaterial == null) throw Oops.Oh($"该物料编号{input.MaterialCode}在系统中没有关联容器类型，请先添加容器类型！");
|
var wmsContainerType = new GetContainerTypeOutPut()
|
{
|
ContainerTypeCode = wmsMaterial.ContainerTypeCode,
|
ContainerTypeName = wmsMaterial.ContainerTypeName,
|
};
|
return wmsContainerType;
|
}
|
|
/// <summary>
|
/// 容器下架执行
|
/// </summary>
|
/// <returns></returns>
|
[HttpPost]
|
[ApiDescriptionSettings(Name = "ContainerUnshelveExecute", Description = "PDA容器下架确认-创建下架单、调度任务")]
|
[Description("/Unshelve/ContainerUnshelveExecute")]
|
public async Task ContainerUnshelveExecute(WmsUnshelveInput input)
|
{
|
//ly-0813 添加来源库区
|
//var AreaCodeItem = await _WmsAreaRep.GetFirstAsync(w => w.AreaCode == input.AreaCode && w.IsDelete == false);
|
//if (AreaCodeItem==null)
|
//{
|
// throw Oops.Oh($"来源库区{input.AreaCode}不存在！");
|
//}
|
|
//获取库存中已上架的容器类型集合按时间排序 排除目标库位是自己的
|
var contaierList = await _v_wms_stock_quanRep.AsQueryable()
|
.Where(o => o.PlaceCode != input.PlaceCode && o.ContainerTypeCode == input.ContainerTypeCode && o.MaterialTypeCode=="RQ" && o.IsDelete == false && o.StockStatus==StockStatusEnum.已上架)
|
.OrderBy(o=>o.CreateTime).ToListAsync();
|
//判断当前容器类型是否有库存
|
if (contaierList.Count<=0) throw Oops.Oh($"当前容器类型{input.ContainerTypeCode}没有库存,请先上架该类型的容器！");
|
//查询第一个容器号的容器组盘集合 不能自己呼叫自己
|
var contaierInfoList = contaierList
|
.Where(u => u.ContainerCode == contaierList[0].ContainerCode && u.ContainerCode != input.PlaceCode)
|
.ToList();
|
//if (contaierInfoList.Count <= 0)
|
//{
|
// throw Oops.Oh($"来源库区{input.AreaCode}没有找到已上架的容器！");
|
//}
|
|
//源库位
|
string sourcePlaceCode = contaierInfoList[0].PlaceCode;
|
string sourcePlaceName = contaierInfoList[0].PlaceName;
|
|
//if (contaierInfoList[0].PlaceCode == input.PlaceCode)
|
//{
|
// throw Oops.Oh($"来源库位{contaierInfoList[0].PlaceCode}和目标库位{input.PlaceCode}相同！");
|
//}
|
|
//新增事务记录
|
List<WmsRecordTrans> addWmsRecordTransList = new List<WmsRecordTrans>();
|
//新增操作履历
|
List<WmsLogAction> addWmsLogActionList = new List<WmsLogAction>();
|
//新增下架单明细
|
List<WmsOrderMovementDetails> addWmsOrderMovementDetailsList = new List<WmsOrderMovementDetails>();
|
|
//获取目标库位信息
|
WmsBasePlace toPlace = null;
|
if (!string.IsNullOrWhiteSpace(input.PlaceCode))
|
{
|
toPlace = await _wmsPlaceRep.GetFirstAsync(w => w.PlaceCode == input.PlaceCode && w.IsDelete == false);
|
if (toPlace == null)
|
{
|
throw Oops.Oh($"目标库位{input.PlaceCode}不存在！");
|
}
|
if (toPlace.IsDisabled == true)
|
{
|
throw Oops.Oh($"目标库位{input.PlaceCode}已禁用！");
|
}
|
if (toPlace.IsVirtually == true)
|
{
|
throw Oops.Oh($"目标库位{input.PlaceCode}是虚拟库位！");
|
}
|
//库位属性 正常和禁出的可以组盘上架
|
if (toPlace.PlaceStatus != PlaceStatusEnum.正常 && toPlace.PlaceStatus != PlaceStatusEnum.禁出)
|
{
|
throw Oops.Oh($"目标库位{input.PlaceCode}库位属性是{toPlace.PlaceStatus.GetDescription()}！");
|
}
|
}
|
else
|
{
|
//用户必须指定一个 库位。
|
throw Oops.Oh($"目标库位不能为空！");
|
}
|
BusinessTypeEnum businessTypeEnum = BusinessTypeEnum.容器下架;
|
// 获取业务类型 update by liuwq 2024 07 30
|
var wmsBaseBusinessType = BusinessTypeHelper.GetBusinessTypeInfoFromDB((int)businessTypeEnum, _wmsBaseBusinessTypeRep);
|
|
int lineNumber = 0;//移动单明细行号
|
var hearId = Yitter.IdGenerator.YitIdHelper.NextId();//上架单ID
|
//3.循环库存信息-创建上架单明细
|
foreach (var vstockQuan in contaierInfoList)
|
{
|
var wmsContainerItem = await _wmsContainerRep.GetFirstAsync(w => w.ContainerCode == vstockQuan.SNCode &&w.IsDelete == false);
|
if (wmsContainerItem == null) throw Oops.Oh($"容器{vstockQuan.SNCode}不存在！");
|
if (wmsContainerItem.IsDisabled == true) throw Oops.Oh($"容器{vstockQuan.SNCode}已禁用！");
|
if (wmsContainerItem.IsVirtually == true) throw Oops.Oh($"容器{vstockQuan.SNCode}是虚拟容器！");
|
var stockQuan = await _wmsStockQuanRep.GetFirstAsync(w => w.Id==vstockQuan.Id);
|
if(stockQuan==null) throw Oops.Oh($"容器{vstockQuan.SNCode}不存在！");
|
|
if (string.IsNullOrWhiteSpace(vstockQuan.ContainerCode))
|
{
|
throw Oops.Oh($"库存{vstockQuan.SNCode}容器号不能为空！");
|
}
|
lineNumber++;
|
#region 创建下架单明细
|
//3.根据容器的库存创建下架单明细
|
var wmsOrderMovementDetails = new WmsOrderMovementDetails()
|
{
|
MovementId = hearId,
|
LineNumber = OrderHelper.AutoCompleEBELP(lineNumber.ToString(), 4),//lineNumber.ToString(),
|
SNCode = vstockQuan.SNCode,
|
SupplierCode = vstockQuan.SupplierCode,
|
SupplierName = vstockQuan.SupplierName,
|
Batch = vstockQuan.Batch,
|
ErpOrderNo = vstockQuan.ErpOrderNo,
|
ErpCode = vstockQuan.ErpCode,
|
Unit = vstockQuan.MaterialUnit,
|
SupplierBatch = vstockQuan.SupplierBatch,
|
OrderStatus = OrderStatusEnum.新建,
|
OrderStatusName = OrderStatusEnum.新建.GetDescription(),
|
//ToAreaCode = input.ToAreaCode,
|
//ToPlaceCode = input.ToPlaceCode,
|
ContainerCode = vstockQuan.ContainerCode,
|
ContainerName = vstockQuan.ContainerName,
|
SourceWarehouseCode = vstockQuan.WarehouseCode,
|
SourceWarehouseName = vstockQuan.WarehouseName,
|
SourceAreaCode = vstockQuan.AreaCode,
|
SourceAreaName = vstockQuan.AreaName,
|
SourcePlaceCode = vstockQuan.PlaceCode,
|
SourcePlaceName = vstockQuan.PlaceName,
|
ToPlaceCode = toPlace.PlaceCode,
|
ToPlaceName = toPlace.PlaceName,
|
ToAreaCode = toPlace.AreaCode,
|
ToAreaName = toPlace.AreaName,
|
MaterialCode = vstockQuan.MaterialCode,
|
MaterialName = vstockQuan.MaterialName,
|
Quantity = vstockQuan.Quantity,
|
ActionRemark = "PDA下架架创建下架单",
|
ActionTime = DateTime.Now
|
};
|
addWmsOrderMovementDetailsList.Add(wmsOrderMovementDetails);
|
#endregion
|
#region 转移库存操作日志
|
string recordTransRemarks = string.Empty;
|
|
|
|
//新增操作日志
|
WmsLogAction wareActionLog = LogActionHelper.CreateWmsLogAction(vstockQuan.Id, businessTypeEnum.GetDescription(), recordTransRemarks);
|
addWmsLogActionList.Add(wareActionLog);
|
#endregion
|
}
|
|
// 获取当前时间
|
DateTime currentTime = DateTime.Now;
|
// 格式化为年月日字符串
|
string formattedDate = currentTime.ToString("yyyyMMdd");
|
//按照单号规则生成单号 - 查找最新的创建的一条单据记录
|
var newestOrder = await _wmsOrderMovementRep.AsQueryable().Where(p => p.OrderType == OrderTypeEnum.下架单).Where(p => p.OrderNo.Contains(formattedDate)).OrderBy(it => it.CreateTime, OrderByType.Desc)
|
.FirstAsync();
|
|
|
//按照单号规则生成单号-ly
|
var OrderNoSjd = await SerialUtilOrder.GetSerialOrder(OrderTypeEnum.下架单, _WmsNoCreateRuleRep, _repSNRep, (int)businessTypeEnum, newestOrder == null ? null : newestOrder.OrderNo);
|
if (OrderNoSjd == null || OrderNoSjd == "")
|
{
|
var OrderNoSjdRQ = await SerialUtilOrder.GetSerialOrder(OrderTypeEnum.下架单, _WmsNoCreateRuleRep, _repSNRep, (int)businessTypeEnum, newestOrder == null ? null : newestOrder.OrderNo);
|
if (OrderNoSjdRQ != null || OrderNoSjdRQ != "")
|
{
|
OrderNoSjd = OrderNoSjdRQ;
|
}
|
else
|
{
|
OrderNoSjd = Yitter.IdGenerator.YitIdHelper.NextId().ToString();
|
}
|
}
|
|
var businessTypeInfo = BusinessTypeHelper.GetBusinessTypeInfoFromDB((int)businessTypeEnum, _wmsBaseBusinessTypeRep);
|
|
//4 创建下架单
|
var addWmsOrderMovement = new WmsOrderMovement()
|
{
|
Id = hearId,
|
OrderNo = OrderNoSjd, //按照单号规则生成单号-ly
|
OrderType = OrderTypeEnum.下架单,
|
OrderTypeName = OrderTypeEnum.下架单.GetDescription(),
|
BusinessType = (int)businessTypeEnum,
|
BusinessTypeName = businessTypeEnum.GetDescription(),
|
OrderStatus = OrderStatusEnum.新建,
|
OrderStatusName = OrderStatusEnum.新建.GetDescription(),
|
OrderSocure = SourceByEnum.系统
|
};
|
BusinessTypeEnum wmsTaskBusinessTypeEnum = BusinessTypeEnum.容器下架;
|
//5.创建调度任务
|
var wmsTask = new WmsTask()
|
{
|
MoveType = businessTypeInfo.MoveType,
|
MoveTypeName = businessTypeInfo.MoveTypeName,
|
BusinessType = businessTypeInfo.BusinessTypeValue,
|
BusinessTypeName = businessTypeInfo.BusinessTypeName,
|
ContainerCode = contaierList.FirstOrDefault().ContainerCode,
|
IsFlagFinish = false,
|
OrderNo = addWmsOrderMovement.OrderNo,
|
TaskDescribe = "PDA容器下架",
|
TaskStatus = TaskStatusEnum.新建,
|
TaskStatusName = TaskStatusEnum.新建.GetDescription(),
|
TaskNo = Yitter.IdGenerator.YitIdHelper.NextId().ToString(),
|
TaskPriority = 0,
|
TaskName = wmsTaskBusinessTypeEnum.GetDescription(),
|
ToAreaCode = toPlace.AreaCode,
|
SourcePlaceCode = sourcePlaceCode,
|
ToPlaceCode = input.PlaceCode
|
};
|
|
var _tenant = _wmsOrderMovementRep.AsTenant();
|
try
|
{
|
await _tenant.BeginTranAsync();
|
#region 事务内执行操作
|
|
//新增操作日志
|
await _wmsLogActionRep.InsertRangeAsync(addWmsLogActionList);
|
|
if (addWmsOrderMovementDetailsList?.Count > 0)
|
{
|
//新增下架单
|
await _wmsOrderMovementRep.InsertAsync(addWmsOrderMovement);
|
await _wmsOrderMovementDetailsRep.InsertRangeAsync(addWmsOrderMovementDetailsList);
|
|
|
//新增任务调度
|
await _wmsTaskRep.InsertAsync(wmsTask);
|
}
|
else
|
{
|
throw Oops.Oh($"下架单明细为空！");
|
}
|
#endregion
|
await _tenant.CommitTranAsync();
|
}
|
catch
|
{
|
await _tenant.RollbackTranAsync();
|
throw;
|
}
|
}
|
|
}
|
