using Admin.NET.Core.Service;
|
using Admin.NET.Application.Entity;
|
using Microsoft.AspNetCore.Http;
|
using System.Data;
|
using System.Web;
|
using System.Text;
|
using Furion.DatabaseAccessor;
|
using Admin.NET.Application.CommonHelper;
|
using AngleSharp.Dom;
|
using DocumentFormat.OpenXml.Office2013.Word;
|
using NPOI.SS.Formula.Functions;
|
using Admin.NET.Core;
|
|
namespace Admin.NET.Application;
|
/// <summary>
|
/// 实时库存服务
|
/// </summary>
|
[ApiDescriptionSettings(ApplicationConst.WmsStockQuanGroupName, Order = 100)]
|
public class WmsStockQuanService : IDynamicApiController, ITransient
|
{
|
private readonly SqlSugarRepository<WmsBaseBusinessType> _wmsBaseBusinessTypeRep;
|
private readonly UserManager _userManager;
|
private readonly SqlSugarRepository<WmsStockQuan> _rep;
|
private readonly SqlSugarRepository<WmsStockQuanZero> _wmsStockQuanZeroRep;
|
private readonly SqlSugarRepository<WmsStockQuanOut> _wmsStockQuanOutRep;
|
private readonly SqlSugarRepository<v_wms_stock_quan> _v_wms_stock_quanRep;
|
private readonly SqlSugarRepository<WmsBasePlace> _repWmsPlace;
|
private readonly SqlSugarRepository<WmsBaseContainer> _repWmsContainer;
|
private readonly SqlSugarRepository<v_wms_stock_quan_for_use> _v_wms_stock_quan_for_useRep;
|
private readonly SqlSugarRepository<WmsRecordTrans> _wmsRecordTransRep;
|
private readonly SqlSugarRepository<WmsLogAction> _wmsLogActionRep;
|
private readonly SqlSugarRepository<WmsBasePlace> _wmsPlaceRep;
|
public WmsStockQuanService(
|
SqlSugarRepository<WmsStockQuanOut> wmsStockQuanOutRep,
|
SqlSugarRepository<WmsStockQuanZero> wmsStockQuanZeroRep,
|
SqlSugarRepository<WmsBaseBusinessType> wmsBaseBusinessTypeRep,
|
UserManager userManager,
|
SqlSugarRepository<WmsStockQuan> rep
|
|
|
, SqlSugarRepository<v_wms_stock_quan_for_use> v_wms_stock_quan_for_useRep
|
, SqlSugarRepository<v_wms_stock_quan> v_wms_stock_quanRep,
|
SqlSugarRepository<WmsBasePlace> repWmsPlace
|
, SqlSugarRepository<WmsBaseContainer> repWmsContainer,
|
SqlSugarRepository<WmsRecordTrans> wmsRecordTransRep,
|
SqlSugarRepository<WmsLogAction> wmsLogActionRep,
|
SqlSugarRepository<WmsBasePlace> wmsPlaceRep)
|
|
{
|
_wmsStockQuanOutRep = wmsStockQuanOutRep;
|
_wmsStockQuanZeroRep = wmsStockQuanZeroRep;
|
_wmsBaseBusinessTypeRep = wmsBaseBusinessTypeRep;
|
_userManager = userManager;
|
_rep = rep;
|
_v_wms_stock_quanRep = v_wms_stock_quanRep;
|
_v_wms_stock_quan_for_useRep = v_wms_stock_quan_for_useRep;
|
_repWmsPlace = repWmsPlace;
|
_repWmsContainer = repWmsContainer;
|
_wmsRecordTransRep = wmsRecordTransRep;
|
|
_wmsLogActionRep = wmsLogActionRep;
|
_wmsPlaceRep = wmsPlaceRep;
|
}
|
|
/// <summary>
|
/// 分页查询实时库存
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[ApiDescriptionSettings(Name = "Page")]
|
[Description("WmsStockQuan/Page")]
|
public async Task<SqlSugarPagedList<WmsStockQuanOutput>> Page(WmsStockQuanInput input)
|
{
|
var query = CommonPageFilter(input);
|
return await query.OrderBuilder(input, "", "Id").ToPagedListAsync(input.Page, input.PageSize);
|
}
|
|
|
|
/// <summary>
|
/// 分页查询可用库存-细分到跟踪码
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[ApiDescriptionSettings(Name = "GetStockQuanPageForUse")]
|
[Description("WmsStockQuan/GetStockQuanPageForUse")]
|
public async Task<SqlSugarPagedList<v_wms_stock_quan_for_use>> Page(WmsMaterialInput input)
|
{
|
var query = _v_wms_stock_quan_for_useRep.AsQueryable()
|
.WhereIF(!string.IsNullOrWhiteSpace(input.MaterialName), u => u.MaterialName.Contains(input.MaterialName.Trim()))
|
.WhereIF(!string.IsNullOrWhiteSpace(input.SnCode), u => u.SNCode.Contains(input.SnCode.Trim()))
|
.WhereIF(!string.IsNullOrWhiteSpace(input.MaterialCode), u => u.MaterialCode == input.MaterialCode)
|
.WhereIF(!string.IsNullOrWhiteSpace(input.Batch), u => u.Batch.Contains(input.Batch.Trim()))
|
.WhereIF(!string.IsNullOrWhiteSpace(input.ErpCode), u => u.ErpCode.Contains(input.ErpCode.Trim()))
|
.Where(p => p.ContainerIsDisabled == false)
|
.Where(p => p.PlaceStatus == PlaceStatusEnum.正常)
|
.Select<v_wms_stock_quan_for_use>();
|
return await query.OrderBuilder(input).ToPagedListAsync(input.Page, input.PageSize);
|
}
|
|
|
|
/// <summary>
|
/// 分页查询实时库存
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[ApiDescriptionSettings(Name = "PageView")]
|
[Description("WmsStockQuan/PageView")]
|
[AllowAnonymous]
|
public async Task<SqlSugarPagedList<v_wms_stock_quan>> PageView(WmsStockQuanInput input)
|
{
|
var query = CommonPageViewFilter(input);
|
return await query.OrderBuilder(input, "", string.IsNullOrWhiteSpace(input.Field) ? "RecordInsertTime" : input.Field).OrderBuilder(input, "", "MaterialCode").OrderBuilder(input, "", "RelationNo").ToPagedListAsync(input.Page, input.PageSize);
|
}
|
|
/// <summary>
|
/// 分页查询abc分类实时库存
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[ApiDescriptionSettings(Name = "AbcClassPageView")]
|
[Description("WmsStockQuan/AbcClassPageView")]
|
[AllowAnonymous]
|
public async Task<SqlSugarPagedList<WmsStockQuanAbcClassOutput>> AbcClassPageView(WmsStockQuanAbcClassInput input)
|
{
|
DateTime? start = null;
|
DateTime? end = null;
|
|
if (input.RecordInsertTimeRange != null && input.RecordInsertTimeRange.Count > 0)
|
{
|
DateTime stDateInput = input.RecordInsertTimeRange[0].Value;
|
start = new DateTime(stDateInput.Year, stDateInput.Month, stDateInput.Day, 00, 00, 00);
|
if (input.RecordInsertTimeRange.Count > 1 && input.RecordInsertTimeRange[1].HasValue)
|
{
|
DateTime edDateInput = input.RecordInsertTimeRange[1].Value;
|
end = new DateTime(edDateInput.Year, edDateInput.Month, edDateInput.Day, 23, 59, 59);
|
}
|
}
|
|
var query = _rep.AsQueryable()
|
.LeftJoin<WmsBaseMaterial>((u, wm) => u.MaterialCode == wm.MaterialCode)
|
.WhereIF(input.ABCClass.HasValue, (u, wm) => wm.ABCClass == input.ABCClass)
|
.WhereIF(!string.IsNullOrWhiteSpace(input.MaterialCode), (u, wm) => u.MaterialCode.Contains(input.MaterialCode.Trim()))
|
.WhereIF(start.HasValue, (u, wm) => u.RecordInsertTime > start)
|
.WhereIF(end.HasValue, (u, wm) => u.RecordInsertTime < end)
|
.GroupBy((u, wm) => new { wm.ABCClassName, u.MaterialCode, u.MaterialName, u.MaterialUnit })
|
.Select((u, wm) => new WmsStockQuanAbcClassOutput
|
{
|
MaterialName = u.MaterialName,
|
MaterialCode = u.MaterialCode,
|
MaterialUnit = u.MaterialUnit,
|
AbcClassName = wm.ABCClassName,
|
Quantity = SqlFunc.AggregateSumNoNull(u.Quantity)
|
})
|
.OrderByDescending(u => SqlFunc.AggregateSumNoNull(u.Quantity));
|
return await query.ToPagedListAsync(input.Page, input.PageSize);
|
}
|
|
|
/// <summary>
|
/// 不分页查询实时库存
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpGet]
|
[ApiDescriptionSettings(Name = "List")]
|
[Description("WmsStockQuan/List")]
|
public async Task<List<WmsStockQuanOutput>> List([FromQuery] WmsStockQuanInput input)
|
{
|
var query = CommonPageFilter(input);
|
return await query.OrderBuilder(input, "", "Id").Select<WmsStockQuanOutput>().ToListAsync();
|
}
|
|
/// <summary>
|
/// 增加实时库存
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[ApiDescriptionSettings(Name = "Add")]
|
[Description("WmsStockQuan/Add")]
|
public async Task<long> Add(AddWmsStockQuanInput input)
|
{
|
var entity = input.Adapt<WmsStockQuan>();
|
|
//重复性验证
|
await CheckExist(entity);
|
|
await _rep.InsertAsync(entity);
|
return entity.Id;
|
}
|
|
/// <summary>
|
/// 删除实时库存
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[ApiDescriptionSettings(Name = "Delete")]
|
[Description("WmsStockQuan/Delete")]
|
public async Task Delete(DeleteWmsStockQuanInput input)
|
{
|
var entity = await _rep.GetFirstAsync(u => u.Id == input.Id) ?? throw Oops.Oh(ErrorCodeEnum.D1002);
|
//await _rep.FakeDeleteAsync(entity); //假删除
|
await _rep.DeleteAsync(entity); //真删除
|
}
|
|
/// <summary>
|
/// 更新实时库存
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[ApiDescriptionSettings(Name = "Update")]
|
[Description("WmsStockQuan/Update")]
|
public async Task Update(UpdateWmsStockQuanInput input)
|
{
|
var entity = input.Adapt<WmsStockQuan>();
|
|
//重复性验证
|
await CheckExist(entity, true);
|
|
await _rep.AsUpdateable(entity).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
|
}
|
|
/// <summary>
|
/// 获取实时库存
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpGet]
|
[ApiDescriptionSettings(Name = "Detail")]
|
[Description("WmsStockQuan/Detail")]
|
public async Task<WmsStockQuan> Detail([FromQuery] QueryByIdWmsStockQuanInput input)
|
{
|
return await _rep.GetFirstAsync(u => u.Id == input.Id);
|
}
|
|
|
/// <summary>
|
/// 冻结
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[ApiDescriptionSettings(Name = "Frozen")]
|
[Description("WmsStockQuan/Frozen")]
|
[UnitOfWork]
|
public async Task Frozen([FromBody] FrozeningInput input)
|
{
|
int mark = 0;
|
List<WmsRecordTrans> addWmsRecordTransList = new List<WmsRecordTrans>();
|
List<WmsLogAction> addWmsLogActionList = new List<WmsLogAction>();
|
|
|
#region 事务入参
|
//update by liuwq 20240720 查询库存视图
|
var allStockQuanViewList = await _v_wms_stock_quanRep.GetListAsync(f => f.SNCode.Equals(input.SNCode) || input.WmsStockIdList.Contains(f.Id));
|
|
BusinessTypeEnum businessTypeEnum = BusinessTypeEnum.冻结;
|
// 获取业务类型 update by liuwq 2024 07 30
|
var wmsBaseBusinessType = BusinessTypeHelper.GetBusinessTypeInfoFromDB((int)businessTypeEnum, _wmsBaseBusinessTypeRep);
|
string recordTransRemarks = string.Empty;
|
|
|
//获取库位相信
|
var placeCodeList = allStockQuanViewList.Select(s => s.PlaceCode).Distinct().ToList();
|
var allPlaeList = await _wmsPlaceRep.GetListAsync(u => placeCodeList.Contains(u.PlaceCode) && u.IsDelete == false);
|
|
#endregion
|
|
|
//声明库存表参数
|
var StockUpdateList = new List<WmsStockQuan>();
|
|
if (input == null) throw Oops.Oh("未传入需要冻结信息");
|
if (!string.IsNullOrEmpty(input.SNCode) && input.WmsStockIdList == null)
|
{
|
var StockModel = await _rep.AsQueryable().FirstAsync(p => p.SNCode == input.SNCode && p.StockStatus == StockStatusEnum.已上架);
|
if (StockModel == null) throw Oops.Oh("库存未找到或者未上架");
|
if (StockModel.StockStatus == StockStatusEnum.已冻结) throw Oops.Oh("该物料已冻结！");
|
|
|
StockQuanHelper.UpdateStockStatus(StockModel, StockStatusEnum.已冻结, input.Reason, _userManager.RealName);
|
|
|
|
#region 添加事务、操作日志
|
|
|
#region 创建事务日志入参
|
|
|
//获取源库存信息
|
var sourceStockView = StockQuanHelper.GetVMmsStockQuan(allStockQuanViewList, StockModel.SNCode);
|
|
//update by liuwq 20240730
|
//获取目标库位
|
//冻结库存没有变更库位，目标库位还是源库位
|
var toPlace = BaseInfoHelper.GetPlace(sourceStockView.PlaceCode, allPlaeList);
|
|
// 其他参数对象
|
TransferOtherDetail transferOtherDetail = new TransferOtherDetail()
|
{
|
RelationNo = "",
|
RelationNoLineNumber = "",
|
Remarks = recordTransRemarks,
|
|
};
|
#endregion
|
|
//新增事务记录
|
//仅变更冻结状态
|
addWmsRecordTransList.Add(LogRecordHelper.CreateWmsRecordTrans(wmsBaseBusinessType, sourceStockView, StockModel, toPlace, transferOtherDetail));
|
//新增操作日志
|
WmsLogAction wareActionLog = LogActionHelper.CreateWmsLogAction(StockModel.Id, recordTransRemarks, $"跟踪码{StockModel.SNCode}");
|
addWmsLogActionList.Add(wareActionLog);
|
#endregion
|
await _wmsLogActionRep.InsertRangeAsync(addWmsLogActionList);
|
await _wmsRecordTransRep.InsertRangeAsync(addWmsRecordTransList);
|
await _rep.UpdateAsync(StockModel);
|
mark++;
|
}
|
else if (input.WmsStockIdList != null)
|
{
|
foreach (var item in input.WmsStockIdList)
|
{
|
var StockModel = await _rep.AsQueryable().FirstAsync(p => p.Id == item && p.StockStatus == StockStatusEnum.已上架);
|
if (StockModel == null) throw Oops.Oh("库存未找到或者未上架");
|
if (StockModel.StockStatus == StockStatusEnum.已冻结) throw Oops.Oh("该物料已冻结！");
|
|
if (StockModel != null && StockModel.StockStatus == StockStatusEnum.已上架)
|
{
|
StockQuanHelper.UpdateStockStatus(StockModel, StockStatusEnum.已冻结,input.Reason, _userManager.RealName);
|
StockUpdateList.Add(StockModel);
|
|
#region 添加事务、操作日志
|
|
|
#region 创建事务日志入参
|
|
|
//获取源库存信息
|
var sourceStockView = StockQuanHelper.GetVMmsStockQuan(allStockQuanViewList, StockModel.SNCode);
|
|
//update by liuwq 20240730
|
//获取目标库位
|
//冻结库存没有变更库位，目标库位还是源库位
|
var toPlace = BaseInfoHelper.GetPlace(sourceStockView.PlaceCode, allPlaeList);
|
|
// 其他参数对象
|
TransferOtherDetail transferOtherDetail = new TransferOtherDetail()
|
{
|
RelationNo = "",
|
RelationNoLineNumber = "",
|
Remarks = recordTransRemarks,
|
|
};
|
#endregion
|
|
|
//新增事务记录
|
//仅变更冻结状态
|
addWmsRecordTransList.Add(LogRecordHelper.CreateWmsRecordTrans(wmsBaseBusinessType, sourceStockView, StockModel, toPlace, transferOtherDetail));
|
|
//新增操作日志
|
WmsLogAction wareActionLog = LogActionHelper.CreateWmsLogAction(StockModel.Id, recordTransRemarks, $"跟踪码{StockModel.SNCode}");
|
addWmsLogActionList.Add(wareActionLog);
|
#endregion
|
|
}
|
}
|
|
await _wmsLogActionRep.InsertRangeAsync(addWmsLogActionList);
|
await _wmsRecordTransRep.InsertRangeAsync(addWmsRecordTransList);
|
await _rep.UpdateRangeAsync(StockUpdateList);
|
}
|
|
else if (!string.IsNullOrEmpty(input.PlaceCode))
|
{
|
var PlaceModel = await _repWmsPlace.AsQueryable().FirstAsync(p => p.PlaceCode == input.PlaceCode && p.PlaceStatus == PlaceStatusEnum.正常);
|
if (PlaceModel == null) throw Oops.Oh("该库位状态异常或者不存在");
|
if (PlaceModel.PlaceStatus == PlaceStatusEnum.封存) throw Oops.Oh("该库位已冻结！");
|
PlaceModel.PlaceStatus = PlaceStatusEnum.封存;
|
await _repWmsPlace.UpdateAsync(PlaceModel);
|
mark++;
|
}
|
else if (!string.IsNullOrEmpty(input.ContainerCode))
|
{
|
var ContainerModel = await _repWmsContainer.AsQueryable().FirstAsync(p => p.ContainerCode == input.ContainerCode && p.IsDisabled == false);
|
if (ContainerModel == null)
|
{
|
throw Oops.Oh("该容器不需要冻结！");
|
}
|
|
if (ContainerModel.IsDisabled == true) throw Oops.Oh("该容器已冻结！");
|
ContainerModel.IsDisabled = true;
|
await _repWmsContainer.UpdateAsync(ContainerModel);
|
mark++;
|
}
|
if (mark != 1 && mark != 0) throw Oops.Oh("不能同时传入多个冻结信息");
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
/// <summary>
|
/// 解冻
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[ApiDescriptionSettings(Name = "Unfreezeing")]
|
[Description("WmsStockQuan/Unfreezeing")]
|
[UnitOfWork]
|
public async Task Unfreezeing([FromBody] FrozeningInput input)
|
{
|
|
//update by liuwq 20240720 查询库存视图
|
#region 事务入参
|
List<WmsRecordTrans> addWmsRecordTransList = new List<WmsRecordTrans>();
|
List<WmsLogAction> addWmsLogActionList = new List<WmsLogAction>();
|
var allStockQuanViewList = await _v_wms_stock_quanRep.GetListAsync(f => f.SNCode.Equals(input.SNCode) || input.WmsStockIdList.Contains(f.Id));
|
BusinessTypeEnum businessTypeEnum = BusinessTypeEnum.解冻;
|
// 获取业务类型 update by liuwq 2024 07 30
|
var wmsBaseBusinessType = BusinessTypeHelper.GetBusinessTypeInfoFromDB((int)businessTypeEnum, _wmsBaseBusinessTypeRep);
|
string recordTransRemarks = string.Empty;
|
|
|
//获取库位相信
|
var placeCodeList = allStockQuanViewList.Select(s => s.PlaceCode).Distinct().ToList();
|
var allPlaeList = await _wmsPlaceRep.GetListAsync(u => placeCodeList.Contains(u.PlaceCode) && u.IsDelete == false);
|
|
#endregion
|
|
int mark = 0;
|
|
//声明库存表参数
|
var StockUpdateList = new List<WmsStockQuan>();
|
if (input == null) throw Oops.Oh("未传入需要冻结信息");
|
if (input.WmsStockIdList != null)
|
{
|
foreach (var item in input.WmsStockIdList)
|
{
|
var StockModel = await _rep.AsQueryable().FirstAsync(p => p.Id == item);
|
//if (StockModel.OperReason.Contains("盘点冻结")) throw Oops.Oh("此物料" + StockModel.SNCode + "为盘点冻结无法解冻");
|
if (StockModel.StockStatus != StockStatusEnum.已冻结) throw Oops.Oh($"该物料库存状态是{StockModel.StockStatusName}！");
|
|
|
|
if (StockModel.OldStockStatus == null)
|
{
|
throw Oops.Oh("该物料变更前库存状态为空，无法解冻！");
|
}
|
|
|
if (StockModel != null && (StockModel.StockStatus == StockStatusEnum.已冻结))
|
{
|
//解冻库存
|
StockQuanHelper.UpdateStockStatus(StockModel, (StockStatusEnum)StockModel.OldStockStatus,input.Reason, _userManager.RealName);
|
StockUpdateList.Add(StockModel);
|
|
|
#region 添加事务、操作日志
|
|
|
|
#region 创建事务日志入参
|
|
|
//获取源库存信息
|
var sourceStockView = StockQuanHelper.GetVMmsStockQuan(allStockQuanViewList, StockModel.SNCode);
|
|
//update by liuwq 20240730
|
//获取目标库位
|
//解冻库存没有变更库位，目标库位还是源库位
|
var toPlace = BaseInfoHelper.GetPlace(sourceStockView.PlaceCode, allPlaeList);
|
|
// 其他参数对象
|
TransferOtherDetail transferOtherDetail = new TransferOtherDetail()
|
{
|
RelationNo = "",
|
RelationNoLineNumber = "",
|
Remarks = recordTransRemarks,
|
|
};
|
#endregion
|
|
|
//新增事务记录
|
//仅变更冻结状态
|
addWmsRecordTransList.Add(LogRecordHelper.CreateWmsRecordTrans(wmsBaseBusinessType, sourceStockView, StockModel, toPlace, transferOtherDetail));
|
|
//新增操作日志
|
WmsLogAction wareActionLog = LogActionHelper.CreateWmsLogAction(StockModel.Id, recordTransRemarks, $"跟踪码{StockModel.SNCode}");
|
addWmsLogActionList.Add(wareActionLog);
|
#endregion
|
|
}
|
}
|
await _wmsLogActionRep.InsertRangeAsync(addWmsLogActionList);
|
await _wmsRecordTransRep.InsertRangeAsync(addWmsRecordTransList);
|
await _rep.UpdateRangeAsync(StockUpdateList);
|
}
|
else if (!string.IsNullOrEmpty(input.SNCode) && input.WmsStockIdList == null)
|
{
|
var StockModel = await _rep.AsQueryable().FirstAsync(p => p.SNCode == input.SNCode);
|
if (StockModel == null) throw Oops.Oh("库存未找到或者未冻结");
|
if (StockModel.StockStatus != StockStatusEnum.已冻结) throw Oops.Oh($"该物料库存状态是{StockModel.StockStatusName}！");
|
|
|
//解冻库存
|
StockQuanHelper.UpdateStockStatus(StockModel, (StockStatusEnum)StockModel.OldStockStatus, input.Reason, _userManager.RealName);
|
|
#region 添加事务、操作日志
|
|
#region 创建事务日志入参
|
//获取源库存信息
|
var sourceStockView = StockQuanHelper.GetVMmsStockQuan(allStockQuanViewList, StockModel.SNCode);
|
|
//update by liuwq 20240730
|
//获取目标库位
|
//冻结库存没有变更库位，目标库位还是源库位
|
var toPlace = BaseInfoHelper.GetPlace(sourceStockView.PlaceCode, allPlaeList);
|
|
// 其他参数对象
|
TransferOtherDetail transferOtherDetail = new TransferOtherDetail()
|
{
|
RelationNo = "",
|
RelationNoLineNumber = "",
|
Remarks = recordTransRemarks,
|
|
};
|
#endregion
|
|
//新增事务记录
|
//仅变更冻结状态
|
addWmsRecordTransList.Add(LogRecordHelper.CreateWmsRecordTrans(wmsBaseBusinessType, sourceStockView, StockModel, toPlace, transferOtherDetail));
|
|
//新增操作日志
|
WmsLogAction wareActionLog = LogActionHelper.CreateWmsLogAction(StockModel.Id, recordTransRemarks, $"跟踪码{StockModel.SNCode}");
|
addWmsLogActionList.Add(wareActionLog);
|
#endregion
|
await _wmsLogActionRep.InsertRangeAsync(addWmsLogActionList);
|
await _wmsRecordTransRep.InsertRangeAsync(addWmsRecordTransList);
|
await _rep.UpdateAsync(StockModel);
|
mark++;
|
}
|
else if (!string.IsNullOrEmpty(input.PlaceCode))
|
{
|
var PlaceModel = await _repWmsPlace.AsQueryable().FirstAsync(p => p.PlaceCode == input.PlaceCode && p.PlaceStatus == PlaceStatusEnum.封存);
|
if (PlaceModel.PlaceStatus == PlaceStatusEnum.正常) throw Oops.Oh("该库位已解冻");
|
|
if (PlaceModel == null) throw Oops.Oh("该库位状态异常或者不存在");
|
PlaceModel.PlaceStatus = PlaceStatusEnum.正常;
|
await _repWmsPlace.UpdateAsync(PlaceModel);
|
mark++;
|
}
|
else if (!string.IsNullOrEmpty(input.ContainerCode))
|
{
|
var ContainerModel = await _repWmsContainer.AsQueryable().FirstAsync(p => p.ContainerCode == input.ContainerCode && p.IsDisabled == true);
|
if (ContainerModel == null) throw Oops.Oh("该容器不需要解冻！");
|
if (ContainerModel.IsDisabled == false) throw Oops.Oh("该容器已解冻");
|
ContainerModel.IsDisabled = false;
|
await _repWmsContainer.UpdateAsync(ContainerModel);
|
mark++;
|
}
|
if (mark != 1 && mark != 0) throw Oops.Oh("不能同时传入多个冻结信息");
|
}
|
|
/// <summary>
|
/// 寻找库存（包扣已经删除的）
|
/// </summary>
|
/// <param name="snCode"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[ApiDescriptionSettings(Name = "GetStockBySnCodeIncludeDelete")]
|
[Description("WmsStockQuan/GetStockBySnCodeIncludeDelete")]
|
public async Task<WmsStockQuan> GetStockBySnCodeIncludeDelete([FromBody] string snCode)
|
{
|
var stock = await _rep.GetFirstAsync(a => a.SNCode == snCode);
|
if (stock != null)
|
{
|
return stock;
|
}
|
else
|
{
|
var zeroStock = await _wmsStockQuanZeroRep.GetFirstAsync(a => a.SNCode == snCode);
|
if (zeroStock != null)
|
{
|
return zeroStock.Adapt<WmsStockQuan>();
|
}
|
else
|
{
|
var outStock = await _wmsStockQuanOutRep.GetFirstAsync(a => a.SNCode == snCode);
|
if (outStock != null)
|
{
|
return outStock.Adapt<WmsStockQuan>();
|
}
|
}
|
}
|
return null;
|
}
|
|
|
/////// <summary>
|
/////// 创建事务记录入参方法
|
/////// </summary>
|
/////// <param name="allStockQuanView"></param>
|
/////// <param name="moveType"></param>
|
/////// <param name="businessTypeEnum"></param>
|
/////// <param name="StockModel"></param>
|
/////// <param name="recordTransRemarks"></param>
|
/////// <returns></returns>
|
////private static WmsRecordTrans CreateRecordTransInfo(List<v_wms_stock_quan> allStockQuanView, MoveTypeEnum moveType, BusinessTypeEnum businessTypeEnum, WmsStockQuan StockModel, string recordTransRemarks)
|
////{
|
//// //创建事务的入参
|
//// var currentStockQuanView = allStockQuanView.FirstOrDefault(f => f.SNCode.Equals(StockModel.SNCode));
|
//// if (currentStockQuanView == null)
|
//// {
|
//// throw Oops.Oh($"{businessTypeEnum.GetDescription()}跟踪码{StockModel.SNCode}没有获取到库存信息");
|
//// }
|
|
//// TransferOtherDetail transferOtherDetail = new TransferOtherDetail()
|
//// {
|
//// RelationNo = StockModel.RelationNo,
|
//// RelationNoLineNumber = string.Empty,
|
//// Remarks = recordTransRemarks,
|
|
//// };
|
//// //源信息
|
//// TransferStockDetail sourceStockDetail = new TransferStockDetail()
|
//// {
|
//// Quantity = currentStockQuanView.Quantity,//源库存数
|
//// StockStatus = currentStockQuanView.StockStatus,//源库存状态
|
//// StockQcStatus = currentStockQuanView.QCStatus,//源质量状态
|
//// LockStatus= currentStockQuanView.LockStatus,//源冻结状态
|
//// };
|
//// //目标信息
|
//// TransferStockDetail targetStockDetail = new TransferStockDetail()
|
//// {
|
//// Quantity = StockModel.Quantity,//目标库存数
|
//// StockStatus = StockModel.StockStatus,//目标库存状态
|
//// StockQcStatus = StockModel.QCStatus,//目标质量状态
|
|
//// LockStatus = StockModel.LockStatus,//目标冻结状态
|
//// };
|
//// WmsRecordTrans addWmsRecordTrans = LogRecordHelper.CreateWmsRecordTrans
|
//// (
|
//// moveType, (int)businessTypeEnum,_wmsBaseBusinessTypeRep, currentStockQuanView, null,
|
//// sourceStockDetail, targetStockDetail, transferOtherDetail
|
//// );
|
//// return addWmsRecordTrans;
|
////}
|
|
public static string GetNextSuffix(string baseNumber, List<string> documents)
|
{
|
List<int> suffixes = new List<int>();
|
|
foreach (string document in documents)
|
{
|
if (document.StartsWith(baseNumber + "-"))
|
{
|
// Extract the suffix part after "-"
|
string suffixString = document.Substring(baseNumber.Length + 1);
|
int suffix;
|
if (int.TryParse(suffixString, out suffix))
|
{
|
suffixes.Add(suffix);
|
}
|
}
|
}
|
|
// Find the maximum suffix
|
int maxSuffix = suffixes.Count > 0 ? suffixes.Max() : 0;
|
|
// Return the next available suffix (max + 1)
|
return baseNumber + (maxSuffix + 1).ToString();
|
}
|
|
|
#region 私有方法
|
|
/// <summary>
|
/// 公共查询实时库存条件
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
private ISugarQueryable<WmsStockQuanOutput> CommonPageFilter(WmsStockQuanInput input)
|
{
|
var query = _rep.AsQueryable()
|
.WhereIF(!string.IsNullOrWhiteSpace(input.SearchKey), u =>
|
u.ContainerCode.Contains(input.SearchKey.Trim())
|
|| u.MaterialCode.Contains(input.SearchKey.Trim())
|
|| u.SupplierBatch.Contains(input.SearchKey.Trim())
|
|| u.Batch.Contains(input.SearchKey.Trim())
|
|| u.CreateUserName.Contains(input.SearchKey.Trim())
|
|| u.UpdateUserName.Contains(input.SearchKey.Trim())
|
|| u.SupplierCode.Contains(input.SearchKey.Trim())
|
|| u.SupplierName.Contains(input.SearchKey.Trim())
|
|| u.MaterialName.Contains(input.SearchKey.Trim())
|
|| u.SN_1d.Contains(input.SearchKey.Trim())
|
|| u.SN_2d.Contains(input.SearchKey.Trim())
|
|| u.SNCode.Contains(input.SearchKey.Trim())
|
|| u.ErpOrderNo.Contains(input.SearchKey.Trim())
|
|| u.ErpCode.Contains(input.SearchKey.Trim())
|
|| u.ErpVoucher.Contains(input.SearchKey.Trim())
|
)
|
.WhereIF(input.ContainerId > 0, u => u.ContainerId == input.ContainerId)
|
.WhereIF(!string.IsNullOrWhiteSpace(input.ContainerCode), u => u.ContainerCode.Contains(input.ContainerCode.Trim()))
|
.WhereIF(!string.IsNullOrWhiteSpace(input.MaterialCode), u => u.MaterialCode.Contains(input.MaterialCode.Trim()))
|
.WhereIF(!string.IsNullOrWhiteSpace(input.SupplierBatch), u => u.SupplierBatch.Contains(input.SupplierBatch.Trim()))
|
.WhereIF(!string.IsNullOrWhiteSpace(input.Batch), u => u.Batch.Contains(input.Batch.Trim()))
|
.WhereIF(!string.IsNullOrWhiteSpace(input.SupplierCode), u => u.SupplierCode.Contains(input.SupplierCode.Trim()))
|
.WhereIF(!string.IsNullOrWhiteSpace(input.SupplierName), u => u.SupplierName.Contains(input.SupplierName.Trim()))
|
.WhereIF(!string.IsNullOrWhiteSpace(input.MaterialName), u => u.MaterialName.Contains(input.MaterialName.Trim()))
|
.WhereIF(input.StockStatus.HasValue, u => u.StockStatus == input.StockStatus)
|
.WhereIF(!string.IsNullOrWhiteSpace(input.SN_1d), u => u.SN_1d.Contains(input.SN_1d.Trim()))
|
.WhereIF(!string.IsNullOrWhiteSpace(input.SN_2d), u => u.SN_2d.Contains(input.SN_2d.Trim()))
|
.WhereIF(!string.IsNullOrWhiteSpace(input.SNCode), u => u.SNCode.Contains(input.SNCode.Trim()))
|
.WhereIF(!string.IsNullOrWhiteSpace(input.ErpOrderNo), u => u.ErpOrderNo.Contains(input.ErpOrderNo.Trim()))
|
.WhereIF(!string.IsNullOrWhiteSpace(input.ErpCode), u => u.ErpCode.Contains(input.ErpCode.Trim()))
|
.WhereIF(input.QCStatus.HasValue, u => u.QCStatus == input.QCStatus)
|
.WhereIF(!string.IsNullOrWhiteSpace(input.ErpVoucher), u => u.ErpVoucher.Contains(input.ErpVoucher.Trim()))
|
.Select<WmsStockQuanOutput>();
|
if (input.RecordInsertTimeRange != null && input.RecordInsertTimeRange.Count > 0)
|
{
|
DateTime? start = input.RecordInsertTimeRange[0].Value.AddDays(-1);
|
query = query.WhereIF(start.HasValue, u => u.RecordInsertTime > start);
|
if (input.RecordInsertTimeRange.Count > 1 && input.RecordInsertTimeRange[1].HasValue)
|
{
|
var end = input.RecordInsertTimeRange[1].Value.AddDays(1);
|
query = query.Where(u => u.RecordInsertTime < end);
|
}
|
}
|
if (input.ActionTimeRange != null && input.ActionTimeRange.Count > 0)
|
{
|
DateTime? start = input.ActionTimeRange[0].Value.AddDays(-1);
|
query = query.WhereIF(start.HasValue, u => u.ActionTime > start);
|
if (input.ActionTimeRange.Count > 1 && input.ActionTimeRange[1].HasValue)
|
{
|
var end = input.ActionTimeRange[1].Value.AddDays(1);
|
query = query.Where(u => u.ActionTime < end);
|
}
|
}
|
return query;
|
}
|
|
|
private ISugarQueryable<v_wms_stock_quan> CommonPageViewFilter(WmsStockQuanInput input)
|
{
|
var query = _v_wms_stock_quanRep.AsQueryable()
|
.WhereIF(!string.IsNullOrWhiteSpace(input.SearchKey), u =>
|
u.ContainerCode.Contains(input.SearchKey.Trim())
|
|| u.MaterialCode.Contains(input.SearchKey.Trim())
|
|| u.SupplierBatch.Contains(input.SearchKey.Trim())
|
|| u.Batch.Contains(input.SearchKey.Trim())
|
|| u.CreateUserName.Contains(input.SearchKey.Trim())
|
|| u.UpdateUserName.Contains(input.SearchKey.Trim())
|
|| u.SupplierCode.Contains(input.SearchKey.Trim())
|
|| u.SupplierName.Contains(input.SearchKey.Trim())
|
|| u.MaterialName.Contains(input.SearchKey.Trim())
|
|| u.SN_1d.Contains(input.SearchKey.Trim())
|
|| u.SN_2d.Contains(input.SearchKey.Trim())
|
|| u.SNCode.Contains(input.SearchKey.Trim())
|
|| u.ErpOrderNo.Contains(input.SearchKey.Trim())
|
|| u.ErpCode.Contains(input.SearchKey.Trim())
|
|| u.ErpVoucher.Contains(input.SearchKey.Trim())
|
|| u.ActionRemark.Contains(input.SearchKey.Trim())
|
)
|
.WhereIF(!string.IsNullOrWhiteSpace(input.ContainerCode), u => u.ContainerCode.Contains(input.ContainerCode.Trim()))
|
.WhereIF(!string.IsNullOrWhiteSpace(input.MaterialCode), u => u.MaterialCode.Contains(input.MaterialCode.Trim()))
|
.WhereIF(!string.IsNullOrWhiteSpace(input.SupplierBatch), u => u.SupplierBatch.Contains(input.SupplierBatch.Trim()))
|
.WhereIF(!string.IsNullOrWhiteSpace(input.Batch), u => u.Batch.Contains(input.Batch.Trim()))
|
.WhereIF(!string.IsNullOrWhiteSpace(input.PlaceName), u => u.PlaceName == input.PlaceName)
|
.WhereIF(!string.IsNullOrWhiteSpace(input.AreaName), u => u.AreaName == input.AreaName)
|
|
|
.WhereIF(!string.IsNullOrWhiteSpace(input.SupplierCode), u => u.SupplierCode.Contains(input.SupplierCode.Trim()))
|
.WhereIF(!string.IsNullOrWhiteSpace(input.SupplierName), u => u.SupplierName.Contains(input.SupplierName.Trim()))
|
.WhereIF(!string.IsNullOrWhiteSpace(input.MaterialName), u => u.MaterialName.Contains(input.MaterialName.Trim()))
|
.WhereIF(input.StockStatus.HasValue, u => u.StockStatus == input.StockStatus)
|
.WhereIF(input.LockStatus.HasValue, u => u.LockStatus == input.LockStatus)
|
.WhereIF(!string.IsNullOrWhiteSpace(input.OperReason), u => u.OperReason.Contains(input.OperReason.Trim()))
|
.WhereIF(!string.IsNullOrWhiteSpace(input.OperUser), u => u.OperUser.Contains(input.OperUser.Trim()))
|
|
.WhereIF(!string.IsNullOrWhiteSpace(input.SN_1d), u => u.SN_1d.Contains(input.SN_1d.Trim()))
|
.WhereIF(!string.IsNullOrWhiteSpace(input.SN_2d), u => u.SN_2d.Contains(input.SN_2d.Trim()))
|
.WhereIF(!string.IsNullOrWhiteSpace(input.SNCode), u => u.SNCode.Contains(input.SNCode.Trim()))
|
.WhereIF(!string.IsNullOrWhiteSpace(input.SNCodeForPda), u => u.SNCode == input.SNCodeForPda) //ly0720 pda物料拆分合并 需要精准跟踪码
|
.WhereIF(!string.IsNullOrWhiteSpace(input.ErpOrderNo), u => u.ErpOrderNo.Contains(input.ErpOrderNo.Trim()))
|
.WhereIF(!string.IsNullOrWhiteSpace(input.ErpCode), u => u.ErpCode.Contains(input.ErpCode.Trim()))
|
.WhereIF(input.QCStatus.HasValue, u => u.QCStatus == input.QCStatus)
|
.WhereIF(input.UsableFlag.HasValue, u => u.UsableFlag == input.UsableFlag)
|
.WhereIF(!string.IsNullOrWhiteSpace(input.ErpVoucher), u => u.ErpVoucher.Contains(input.ErpVoucher.Trim()))
|
.Select<v_wms_stock_quan>();
|
if (input.RecordInsertTimeRange != null && input.RecordInsertTimeRange.Count > 0)
|
{
|
DateTime? start = input.RecordInsertTimeRange[0].Value.AddDays(-1);
|
query = query.WhereIF(start.HasValue, u => u.RecordInsertTime > start);
|
if (input.RecordInsertTimeRange.Count > 1 && input.RecordInsertTimeRange[1].HasValue)
|
{
|
var end = input.RecordInsertTimeRange[1].Value.AddDays(1);
|
query = query.Where(u => u.RecordInsertTime < end);
|
}
|
}
|
if (input.ActionTimeRange != null && input.ActionTimeRange.Count > 0)
|
{
|
DateTime? start = input.ActionTimeRange[0].Value.AddDays(-1);
|
query = query.WhereIF(start.HasValue, u => u.ActionTime > start);
|
if (input.ActionTimeRange.Count > 1 && input.ActionTimeRange[1].HasValue)
|
{
|
var end = input.ActionTimeRange[1].Value.AddDays(1);
|
query = query.Where(u => u.ActionTime < end);
|
}
|
}
|
if (!string.IsNullOrWhiteSpace(input.PageFlage))
|
{
|
query.Where(n => SqlFunc.Subqueryable<WmsBaseMaterial>()
|
.WhereIF(input.ABCClass.HasValue, wm => wm.MaterialCode == n.MaterialCode && wm.ABCClass == input.ABCClass).Any());
|
}
|
return query;
|
}
|
|
/// <summary>
|
/// 重复性验证
|
/// </summary>
|
/// <param name="input">验证对象</param>
|
/// <param name="isEdit">是否是编辑</param>
|
/// <returns></returns>
|
private async Task CheckExist(WmsStockQuan input, bool isEdit = false)
|
{
|
|
|
|
//没有配置组合校验，不需要验重
|
|
|
//没有配置单独校验，不需要验重
|
}
|
|
/// <summary>
|
/// 根据组合校验和单独校验验证数据是否已存在-导入时验证
|
/// </summary>
|
/// <param name="inputs"></param>
|
/// <returns></returns>
|
private async Task CheckExisitForImport(List<WmsStockQuan> inputs)
|
{
|
if (inputs?.Count <= 0)
|
{
|
throw Oops.Oh($"导入数据不能为空");
|
}
|
//根据组合校验验证表格中中是否已存在相同数据
|
|
|
|
|
|
|
|
|
//根据单独校验验证表格中中是否已存在相同数据
|
|
|
|
}
|
#endregion
|
|
}
|
