using Admin.NET.Application.Common.FindEmptyLocationFactory;
|
using Admin.NET.Application.Common;
|
using Furion;
|
using Furion.DatabaseAccessor;
|
using Furion.DatabaseAccessor.Extensions;
|
using Furion.DependencyInjection;
|
using Furion.DynamicApiController;
|
using Furion.FriendlyException;
|
using iWare.Wms.Core;
|
using iWare.Wms.Core.Enum;
|
using Mapster;
|
using Microsoft.AspNetCore.Authorization;
|
using Microsoft.AspNetCore.Mvc;
|
using Microsoft.EntityFrameworkCore;
|
using System.Linq.Dynamic.Core;
|
|
namespace iWare.Wms.Application
|
{
|
/// <summary>
|
/// 出库管理
|
/// </summary>
|
[ApiDescriptionSettings("仓库作业", Name = "IExWarehouse", Order = 100)]
|
[Route("api/[Controller]")]
|
[DisableOpLog]
|
public class ExWarehouseService : IExWarehouseService, IDynamicApiController, ITransient
|
{
|
private readonly IRepository<WmsContainer, MasterDbContextLocator> _wmsContainerRep;
|
private readonly IRepository<WmsMaterial, MasterDbContextLocator> _wmsMaterialRep;
|
private readonly IRepository<WmsMaterialContainer, MasterDbContextLocator> _wmsMaterialContainerRep;
|
private readonly IRepository<WmsArea, MasterDbContextLocator> _wmsAreaRep;
|
private readonly IRepository<WmsPlace, MasterDbContextLocator> _wmsPlaceRep;
|
private readonly IRepository<WmsTask, MasterDbContextLocator> _wmsTaskRep;
|
private readonly IRepository<WmsMaterialStock, MasterDbContextLocator> _wmsMaterialStockRep;
|
private readonly IRepository<WareContainerVsMaterial, MasterDbContextLocator> _wmsContainerPlaceRep;
|
private readonly IRepository<SysUser, MasterDbContextLocator> _sysUser;
|
private readonly IRepository<WareSite, MasterDbContextLocator> _wareSite;
|
private readonly IRepository<WmsPart, MasterDbContextLocator> _wmsPart;
|
private readonly IRepository<v_ware_inventory_by_container, MasterDbContextLocator> _v_ware_inventory_by_container;
|
private readonly IRepository<WareTask, MasterDbContextLocator> _wareTask;
|
private readonly IRepository<WmsContainerType, MasterDbContextLocator> _wmsContainerType;
|
private readonly IRepository<v_empty_location, MasterDbContextLocator> _v_empty_location;
|
private readonly IRepository<WareLocationVsContainer, MasterDbContextLocator> _wareLocationVsContainer;
|
private readonly IRepository<v_empty_location, MasterDbContextLocator> _v_EmptyLocationRep;
|
|
public ExWarehouseService(
|
IRepository<WmsContainer, MasterDbContextLocator> wmsContainerRep,
|
IRepository<WmsMaterial, MasterDbContextLocator> wmsMaterialRep,
|
IRepository<WmsMaterialContainer, MasterDbContextLocator> wmsMaterialContainerRep,
|
IRepository<WmsArea, MasterDbContextLocator> wmsAreaRep,
|
IRepository<WmsPlace, MasterDbContextLocator> wmsPlaceRep,
|
IRepository<WmsTask, MasterDbContextLocator> wmsTaskRep,
|
IRepository<WmsMaterialStock, MasterDbContextLocator> wmsMaterialStockRep,
|
IRepository<WareContainerVsMaterial, MasterDbContextLocator> wmsContainerPlaceRep,
|
IRepository<SysUser, MasterDbContextLocator> sysUser,
|
IRepository<WareSite, MasterDbContextLocator> wareSite,
|
IRepository<WmsPart, MasterDbContextLocator> wmsPart,
|
IRepository<v_ware_inventory_by_container, MasterDbContextLocator> v_ware_inventory_by_container,
|
IRepository<WareTask, MasterDbContextLocator> wareTask,
|
IRepository<WmsContainerType, MasterDbContextLocator> wmsContainerType,
|
IRepository<v_empty_location, MasterDbContextLocator> v_empty_location,
|
IRepository<WareLocationVsContainer, MasterDbContextLocator> wareLocationVsContainer,
|
IRepository<v_empty_location, MasterDbContextLocator> v_EmptyLocationRep
|
)
|
{
|
_wmsContainerRep = wmsContainerRep;
|
_wmsMaterialRep = wmsMaterialRep;
|
_wmsMaterialContainerRep = wmsMaterialContainerRep;
|
_wmsAreaRep = wmsAreaRep;
|
_wmsPlaceRep = wmsPlaceRep;
|
_wmsTaskRep = wmsTaskRep;
|
_wmsMaterialStockRep = wmsMaterialStockRep;
|
_wmsContainerPlaceRep = wmsContainerPlaceRep;
|
_sysUser = sysUser;
|
_wareSite = wareSite;
|
_wmsPart = wmsPart;
|
_v_ware_inventory_by_container = v_ware_inventory_by_container;
|
_wareTask = wareTask;
|
_wmsContainerType = wmsContainerType;
|
_v_empty_location = v_empty_location;
|
_wareLocationVsContainer = wareLocationVsContainer;
|
_v_EmptyLocationRep = v_EmptyLocationRep;
|
}
|
|
/// <summary>
|
/// 分页查询库存表
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpGet("page")]
|
public async Task<PageResult<WmsMaterialStockOutput>> Page([FromQuery] WmsMaterialStockSearch input)
|
{
|
//var wmsMaterialStocks = await _wmsMaterialStockRep.DetachedEntities
|
// .Where(!string.IsNullOrEmpty(input.Materialno), u => EF.Functions.Like(u.MaterialNo, $"%{input.Materialno.Trim()}%"))
|
// .Where(input.Materialtype != null, u => u.MaterialType == input.Materialtype)
|
// .Where(!string.IsNullOrEmpty(input.Materialbatch), u => EF.Functions.Like(u.MaterialBatch, $"%{input.Materialbatch.Trim()}%"))
|
// .Where(!string.IsNullOrEmpty(input.Materialname), u => EF.Functions.Like(u.MaterialName, $"%{input.Materialname.Trim()}%"))
|
// .Where(!string.IsNullOrEmpty(input.Materialspec), u => EF.Functions.Like(u.MaterialSpec, $"%{input.Materialspec.Trim()}%"))
|
// .Where(input.Inspectionmethod != null, u => u.InspectionMethod == input.Inspectionmethod)
|
// .Where(input.Unittype != null, u => u.UnitType == input.Unittype)
|
// .Where(input.Unitno != null, u => u.UnitNo == input.Unitno)
|
// .Where(u => u.StockNumber != 0)
|
// .Where(!string.IsNullOrEmpty(input.Placecode), u =0> u.PlaceCode == input.Placecode)
|
// .Where(!string.IsNullOrEmpty(input.Containercode), u => u.ContainerCode == input.Containercode)
|
// .OrderBy(PageInputOrder.OrderBuilder(input))
|
// .ProjectToType<WmsMaterialStockOutput>()
|
// .ToADPagedListAsync(input.PageNo, input.PageSize);
|
//获取登录用户
|
var contextUser = App.User;
|
var userName = contextUser.Claims.Single(x => x.Type == "Account").Value;
|
//获取登录用户所属线别
|
var lineType = await _sysUser.DetachedEntities.Where(u => u.Account == userName).Select(u => u.LineType).FirstOrDefaultAsync();
|
|
var lvms = await _v_ware_inventory_by_container.DetachedEntities
|
.Where(!string.IsNullOrEmpty(input.Materialno), u => u.WareMaterialCode.Contains(input.Materialno))
|
.Where(!string.IsNullOrEmpty(input.Materialname), u => u.WareMaterialName.Contains(input.Materialname))
|
.Where(!string.IsNullOrEmpty(input.Placecode), u => u.WareLocationCode == input.Placecode)
|
.Where(!string.IsNullOrEmpty(input.Containercode), u => u.WareContainerCode == input.Containercode)
|
.Where(!string.IsNullOrEmpty(input.PartCode), u => u.PartCode == input.PartCode)
|
.Where(!string.IsNullOrEmpty(input.PCPartCode), u => u.PartCode.Contains(input.PCPartCode))
|
.Where(lineType != null && lineType != LineTypeEnum.通用,u => u.LineType == lineType)
|
.OrderBy(PageInputOrder.OrderBuilder(input))
|
.ProjectToType<WmsMaterialStockOutput>()
|
.ToADPagedListAsync(input.PageNo, input.PageSize);
|
return lvms;
|
}
|
|
/// <summary>
|
/// 手动出库
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost("ManualWare")]
|
public async Task ManualWare(ExManualWarehouseInput input)
|
{
|
if (string.IsNullOrEmpty(input.ToPlace))
|
{
|
throw Oops.Oh("目标站台不能为空");
|
}
|
if (string.IsNullOrEmpty(input.Containercode))
|
{
|
throw Oops.Oh("小车编号不能为空");
|
}
|
if (string.IsNullOrEmpty(input.Placecode))
|
{
|
throw Oops.Oh("库位编号不能为空");
|
}
|
//找库存
|
var balance = await _v_ware_inventory_by_container.DetachedEntities.Where(u => u.WareLocationCode == input.Placecode && u.WareContainerCode == input.Containercode && u.IsLocked == false).OrderBy(u => u.DeepcellNo).FirstOrDefaultAsync();
|
if (balance == null)
|
{
|
throw Oops.Oh($"根据小车{input.Containercode}和库位{input.Placecode}没有找到可用库存");
|
}
|
if (balance.StockStatus != StockStatusEnum.在库)
|
{
|
throw Oops.Oh($"零件{input.Containercode}对应的端拾器{input.Placecode}没有可用库存");
|
}
|
|
if (string.IsNullOrEmpty(input.ToPlace))
|
{
|
throw Oops.Oh("目的地不能为空");
|
}
|
var line = (LineTypeEnum)Enum.Parse(typeof(LineTypeEnum), input.ToPlace);
|
var site = await _wareSite.DetachedEntities.Where(u => u.LineType == line).FirstOrDefaultAsync();
|
if (site == null)
|
{
|
throw Oops.Oh("生产线没有配置站台");
|
}
|
|
// 创建任务
|
var tasknew = new WareTask
|
{
|
//OrderNo = input.OrderNo,
|
TaskNo = Yitter.IdGenerator.YitIdHelper.NextId().ToString(),
|
//TaskName = wcsTask.TaskName,
|
//TaskCategory = wcsTask.TaskType,
|
TaskCategory = TaskCategoryEnum.出库任务,
|
TaskDescribe = "",
|
TaskPriority = 99,
|
//TaskState = 0,
|
TaskState = (int)TaskStateEnum.未执行,
|
//TaskType = wcsTask.TaskType,
|
FromLocationCode = balance.WareLocationCode,
|
ToLocationCode = site.Code,
|
ContainerCode = balance.WareContainerCode,
|
Lane = balance.Lane,
|
ContainerType = 0,
|
PartCode = input.PartCode,
|
BeginTime = DateTimeOffset.Now,
|
};
|
|
var cvms = await _wmsContainerPlaceRep.Where(u => u.WareContainerCode == balance.WareContainerCode).ToListAsync();
|
foreach (var item in cvms)
|
{
|
item.StockStatus = StockStatusEnum.出库中;
|
item.IsLocked = true;
|
}
|
|
using (var tran = await _wareTask.Database.BeginTransactionAsync())
|
{
|
try
|
{
|
if (tasknew != null)
|
{
|
await _wareTask.InsertAsync(tasknew);
|
}
|
if (cvms != null && cvms.Count > 0)
|
{
|
await _wmsContainerPlaceRep.UpdateAsync(cvms);
|
}
|
await tran.CommitAsync();
|
}
|
catch
|
{
|
await tran.RollbackAsync();
|
}
|
}
|
}
|
|
|
/// <summary>
|
/// 自动出库
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost("AutoWare")]
|
[AllowAnonymous]
|
public async Task AutoWare(ExAutoWarehouseInput input)
|
{
|
LineTypeEnum? lineType = null;
|
if (input.LineType == null)
|
{
|
var contextUser = App.User;
|
var userName = contextUser.Claims.Single(x => x.Type == "Account").Value;
|
//获取登录用户所属线别
|
lineType = await _sysUser.DetachedEntities.Where(u => u.Account == userName).Select(u => u.LineType).FirstOrDefaultAsync();
|
}
|
else
|
{
|
lineType = input.LineType;
|
}
|
|
////获取登录用户
|
|
//通过线别获取终点站台
|
if (lineType == null)
|
{
|
throw Oops.Oh("该登录用户没有配置线别");
|
}
|
|
|
//通过零件号查找端拾器信息
|
var part = await _wmsPart.DetachedEntities.Where(u => u.PartCode == input.PartNo && u.LineType == lineType).FirstOrDefaultAsync();
|
if (part == null && input.LineType == null)
|
{
|
throw Oops.Oh("生产线没有该零件信息");
|
}
|
|
LineTypeEnum? line = null;
|
if (input.LineType != null)
|
{
|
line = (LineTypeEnum)Enum.Parse(typeof(LineTypeEnum), Convert.ToString(input.LineType));
|
if (line != LineTypeEnum.A线 && line != LineTypeEnum.B线 && line != LineTypeEnum.C线)
|
{
|
throw Oops.Oh("请输入正确的线别");
|
}
|
}
|
|
var site = await _wareSite.Where(u => u.LineType == (line != null ? line : lineType)).FirstOrDefaultAsync();
|
if (site == null)
|
{
|
throw Oops.Oh($"线别{part.LineType}没有配置站台信息");
|
}
|
|
//找库存
|
var balance = await _v_ware_inventory_by_container.DetachedEntities.Where(u => u.PartCode == input.PartNo && u.WareMaterialCode == part.MaterialCode && u.IsLocked == false).OrderBy(u => u.DeepcellNo).FirstOrDefaultAsync();
|
if (balance == null)
|
{
|
throw Oops.Oh($"零件{input.PartNo}对应的端拾器没有可用库存");
|
}
|
if (balance.StockStatus != StockStatusEnum.在库)
|
{
|
throw Oops.Oh($"零件{input.PartNo}对应的端拾器没有可用库存");
|
}
|
|
// 创建任务
|
var tasknew = new WareTask
|
{
|
//OrderNo = input.OrderNo,
|
TaskNo = Yitter.IdGenerator.YitIdHelper.NextId().ToString(),
|
//TaskName = wcsTask.TaskName,
|
//TaskCategory = wcsTask.TaskType,
|
TaskCategory = TaskCategoryEnum.出库任务,
|
TaskDescribe = "",
|
TaskPriority = 99,
|
//TaskState = 0,
|
TaskState = (int)TaskStateEnum.未执行,
|
//TaskType = wcsTask.TaskType,
|
FromLocationCode = balance.WareLocationCode,
|
ToLocationCode = site.Code,
|
ContainerCode = balance.WareContainerCode,
|
Lane = balance.Lane,
|
ContainerType = 0,
|
PartCode = input.PartNo,
|
BeginTime = DateTimeOffset.Now,
|
};
|
|
var cvms = await _wmsContainerPlaceRep.Where(u => u.WareContainerCode == balance.WareContainerCode).ToListAsync();
|
foreach (var item in cvms)
|
{
|
item.StockStatus = StockStatusEnum.出库中;
|
item.IsLocked = true;
|
}
|
|
using (var tran = await _wareTask.Database.BeginTransactionAsync())
|
{
|
try
|
{
|
if (tasknew != null)
|
{
|
await _wareTask.InsertAsync(tasknew);
|
}
|
if (cvms != null && cvms.Count > 0)
|
{
|
await _wmsContainerPlaceRep.UpdateAsync(cvms);
|
}
|
await tran.CommitAsync();
|
}
|
catch
|
{
|
await tran.RollbackAsync();
|
}
|
}
|
}
|
|
/// <summary>
|
/// 入库
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost("AutoInWare")]
|
[AllowAnonymous]
|
public async Task AutoInWare(ExAutoWarehouseInput input)
|
{
|
if (string.IsNullOrEmpty(input.RealLocationCode))
|
{
|
//throw Oops.Oh("目标库位不能为空");
|
//如果库位是空的，重新找一下库位
|
FindEmptyLocationServiceHandle handle = null;
|
handle = FindEmptyLocationServiceFactory.GetHandle(MeterialType.物料, _v_EmptyLocationRep,
|
_wmsPlaceRep,
|
_wareTask,
|
_wmsContainerPlaceRep,
|
_wmsContainerRep,
|
_wmsContainerType,
|
_v_ware_inventory_by_container,
|
input.RealLocationCode,
|
"");
|
var emtpyLocation = handle.MainFindEmptyLocation();
|
if (emtpyLocation == null)
|
{
|
throw Oops.Oh("目前没有空库位存放!");
|
}
|
input.RealLocationCode = emtpyLocation.PlaceCode;
|
}
|
else
|
{
|
var place = await _wmsPlaceRep.DetachedEntities.Where(u => u.PlaceCode == input.RealLocationCode).FirstOrDefaultAsync();
|
if (place == null)
|
{
|
throw Oops.Oh("目标库位不能是" + input.RealLocationCode);
|
}
|
|
var lvc = await _wareLocationVsContainer.DetachedEntities.Where(u => u.WareLocationCode == input.RealLocationCode).FirstOrDefaultAsync();
|
if (lvc != null)//目标有货
|
{
|
if (lvc.IsEmptyContainer == true)
|
{
|
throw Oops.Oh("配置的目标库位需要移库，请稍等");
|
}
|
else
|
{
|
throw Oops.Oh("目标库位有货，请处理");
|
}
|
}
|
|
input.RealLocationCode = place.PlaceCode;
|
}
|
|
////获取登录用户
|
//var contextUser = App.User;
|
//var userName = contextUser.Claims.Single(x => x.Type == "Account").Value;
|
////获取登录用户所属线别
|
//var lineType = await _sysUser.DetachedEntities.Where(u => u.Account == userName).Select(u => u.LineType).FirstOrDefaultAsync();
|
|
////通过线别获取终点站台
|
//if (lineType == null)
|
//{
|
// throw Oops.Oh("该登录用户没有配置线别");
|
//}
|
var vi = await _v_ware_inventory_by_container.DetachedEntities.Where(u => u.PartCode == input.PartCode && u.WareContainerCode == input.Containercode).FirstOrDefaultAsync();
|
if (vi == null)
|
{
|
throw Oops.Oh("没有查询到对应的信息");
|
}
|
if (vi.StockStatus == StockStatusEnum.在库)
|
{
|
throw Oops.Oh("对应端拾器已经在库");
|
}
|
|
//通过零件号查找端拾器信息
|
var part = await _wmsPart.DetachedEntities.Where(u => u.PartCode == vi.PartCode).FirstOrDefaultAsync();
|
if (part == null && input.LineType == null)
|
{
|
throw Oops.Oh("零件没有配置对应的端拾器信息");
|
}
|
|
LineTypeEnum? line = null;
|
if (input.ToPlace != null)
|
{
|
line = (LineTypeEnum)Enum.Parse(typeof(LineTypeEnum), Convert.ToString(input.ToPlace));
|
if (line != LineTypeEnum.A线 && line != LineTypeEnum.B线 && line != LineTypeEnum.C线)
|
{
|
throw Oops.Oh("请输入正确的线别");
|
}
|
}
|
|
var site = await _wareSite.Where(u => u.LineType == (line != null ? line : part.LineType)).FirstOrDefaultAsync();
|
if (site == null)
|
{
|
throw Oops.Oh($"线别{part.LineType}没有配置站台信息");
|
}
|
|
//找库存
|
//var balance = await _v_ware_inventory_by_container.DetachedEntities.Where(u => u.PartCode == input.PartNo && u.IsLocked == false).OrderBy(u => u.DeepcellNo).FirstOrDefaultAsync();
|
//if (balance == null)
|
//{
|
// throw Oops.Oh($"零件{input.PartNo}对应的端拾器没有可用库存");
|
//}
|
//if (balance.StockStatus != StockStatusEnum.在库)
|
//{
|
// throw Oops.Oh($"零件{input.PartNo}对应的端拾器没有可用库存");
|
//}
|
|
// 创建任务
|
var tasknew = new WareTask
|
{
|
//OrderNo = input.OrderNo,
|
TaskNo = Yitter.IdGenerator.YitIdHelper.NextId().ToString(),
|
//TaskName = wcsTask.TaskName,
|
//TaskCategory = wcsTask.TaskType,
|
TaskCategory = TaskCategoryEnum.入库任务,
|
TaskDescribe = "",
|
TaskPriority = 99,
|
//TaskState = 0,
|
TaskState = (int)TaskStateEnum.未执行,
|
//TaskType = wcsTask.TaskType,
|
FromLocationCode = site.Code,
|
ToLocationCode = input.RealLocationCode,
|
ContainerCode = vi.WareContainerCode,
|
Lane = vi.Lane,
|
ContainerType = 0,
|
PartCode = vi.PartCode,
|
BeginTime = DateTimeOffset.Now,
|
};
|
|
var cvms = await _wmsContainerPlaceRep.Where(u => u.WareContainerCode == vi.WareContainerCode).ToListAsync();
|
foreach (var item in cvms)
|
{
|
item.StockStatus = StockStatusEnum.出库中;
|
item.IsLocked = true;
|
}
|
|
using (var tran = await _wareTask.Database.BeginTransactionAsync())
|
{
|
try
|
{
|
if (tasknew != null)
|
{
|
await _wareTask.InsertAsync(tasknew);
|
}
|
if (cvms != null && cvms.Count > 0)
|
{
|
await _wmsContainerPlaceRep.UpdateAsync(cvms);
|
}
|
await tran.CommitAsync();
|
}
|
catch
|
{
|
await tran.RollbackAsync();
|
}
|
}
|
}
|
|
/// <summary>
|
/// 获取移库空库位
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpGet("GetRemoveLocation")]
|
public async Task<dynamic> GetRemoveLocation([FromQuery] ExManualWarehouseInput input)
|
{
|
var container = await _wmsContainerRep.DetachedEntities.Where(u => u.ContainerCode == input.Containercode).FirstOrDefaultAsync();
|
if (container == null)
|
{
|
throw Oops.Oh("查询小车为空");
|
}
|
|
var containerType = await _wmsContainerType.DetachedEntities.Where(u => u.WareContainerTypeCode == container.ContainerTypeCode).FirstOrDefaultAsync();
|
if (containerType == null)
|
{
|
throw Oops.Oh("查询小车类型失败");
|
}
|
|
var location = await _v_empty_location.DetachedEntities.Where(u => u.WareLocationTypeCode == containerType.LocationType)
|
.Select(u => new { code = u.PlaceCode }).ToListAsync();
|
return location;
|
}
|
|
/// <summary>
|
/// 手动移库任务
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost("MoveWare")]
|
public async Task MoveWare(ExManualWarehouseInput input)
|
{
|
if (string.IsNullOrEmpty(input.ToPlace))
|
{
|
throw Oops.Oh("目标站台不能为空");
|
}
|
if (string.IsNullOrEmpty(input.Containercode))
|
{
|
throw Oops.Oh("小车编号不能为空");
|
}
|
if (string.IsNullOrEmpty(input.Placecode))
|
{
|
throw Oops.Oh("库位编号不能为空");
|
}
|
|
var container = await _wmsContainerRep.Where(u => u.ContainerCode == input.Containercode).FirstOrDefaultAsync();
|
if (container == null)
|
{
|
throw Oops.Oh("查询小车为空");
|
}
|
|
var containerType = await _wmsContainerType.DetachedEntities.Where(u => u.WareContainerTypeCode == container.ContainerTypeCode).FirstOrDefaultAsync();
|
if (containerType == null)
|
{
|
throw Oops.Oh("查询小车类型失败");
|
}
|
|
var cvm = await _v_ware_inventory_by_container.DetachedEntities.Where(u => u.WareContainerCode == input.Containercode).FirstOrDefaultAsync();
|
|
if (cvm == null)
|
{
|
throw Oops.Oh("库存查询错误");
|
}
|
if (cvm.StockStatus != StockStatusEnum.在库)
|
{
|
throw Oops.Oh("库存不是在库");
|
}
|
|
var location = await _wmsPlaceRep.DetachedEntities.Where(u => u.PlaceCode == input.Placecode).FirstOrDefaultAsync();
|
|
if (location == null)
|
{
|
throw Oops.Oh("源库位查询错误");
|
}
|
|
if (location.WareLocationTypeCode != containerType.LocationType)
|
{
|
throw Oops.Oh("库位校验错误，选定的库位不是小车的可入库位");
|
}
|
if (location.DeepcellNo == (int)DeepcellNoEnum.远伸)
|
{
|
//选择库存远伸要判断一下近伸有没有货
|
var nearLocation = await _wmsPlaceRep.DetachedEntities.Where(u => u.UnionCode == location.UnionCode && u.DeepcellNo == (int)DeepcellNoEnum.近伸).FirstOrDefaultAsync();
|
if (nearLocation == null)
|
{
|
throw Oops.Oh("近伸库位查询错误");
|
}
|
|
var lvc = await _wareLocationVsContainer.DetachedEntities.Where(u => u.WareLocationCode == nearLocation.PlaceCode).FirstOrDefaultAsync();
|
if (lvc != null)
|
{
|
throw Oops.Oh("不能进行移库，因为选择的库存近伸有货");
|
}
|
}
|
|
var toLocation = await _v_empty_location.DetachedEntities.Where(u => u.PlaceCode == input.ToPlace).FirstOrDefaultAsync();
|
|
if (toLocation == null)
|
{
|
throw Oops.Oh("目标库位查询错误");
|
}
|
if (toLocation.DeepcellNo == DeepcellNoEnum.远伸)
|
{
|
//选择库存远伸要判断一下近伸有没有货
|
var nearLocation = await _v_empty_location.DetachedEntities.Where(u => u.UnionCode == toLocation.UnionCode && u.DeepcellNo == (int)DeepcellNoEnum.近伸).FirstOrDefaultAsync();
|
if (nearLocation == null)
|
{
|
throw Oops.Oh("近伸库位查询错误");
|
}
|
|
//var lvc = await _wareLocationVsContainer.DetachedEntities.Where(u => u.WareLocationCode == nearLocation.PlaceCode).FirstOrDefaultAsync();
|
//if (lvc != null)
|
//{
|
// throw Oops.Oh("不能进行移库，因为选择的目标库位近伸有货");
|
//}
|
toLocation = nearLocation;
|
}
|
|
//小车绑定库位更换
|
container.RealLocationCode = toLocation.PlaceCode;
|
|
// 创建任务
|
var tasknew = new WareTask
|
{
|
//OrderNo = input.OrderNo,
|
TaskNo = Yitter.IdGenerator.YitIdHelper.NextId().ToString(),
|
//TaskName = wcsTask.TaskName,
|
//TaskCategory = wcsTask.TaskType,
|
TaskCategory = TaskCategoryEnum.移库任务,
|
TaskDescribe = "",
|
TaskPriority = 99,
|
//TaskState = 0,
|
TaskState = (int)TaskStateEnum.未执行,
|
//TaskType = wcsTask.TaskType,
|
FromLocationCode = input.Placecode,
|
ToLocationCode = toLocation.PlaceCode,
|
ContainerCode = input.Containercode,
|
Lane = location.Line,
|
ContainerType = 0,
|
PartCode = input.PartCode,
|
BeginTime = DateTimeOffset.Now,
|
};
|
|
var cvms = await _wmsContainerPlaceRep.Where(u => u.WareContainerCode == input.Containercode).ToListAsync();
|
foreach (var item in cvms)
|
{
|
item.StockStatus = StockStatusEnum.移库中;
|
item.IsLocked = true;
|
}
|
|
using (var tran = await _wareTask.Database.BeginTransactionAsync())
|
{
|
try
|
{
|
if (tasknew != null)
|
{
|
await _wareTask.InsertAsync(tasknew);
|
}
|
if (cvms != null && cvms.Count > 0)
|
{
|
await _wmsContainerPlaceRep.UpdateAsync(cvms);
|
}
|
await _wmsContainerRep.UpdateAsync(container);
|
await tran.CommitAsync();
|
}
|
catch
|
{
|
await tran.RollbackAsync();
|
}
|
}
|
}
|
}
|
}
|
