using Admin.NET.Core.Service;
using Admin.NET.Application.Entity;
using Microsoft.AspNetCore.Http;
namespace Admin.NET.Application;
///
/// 替代品管理服务
///
[ApiDescriptionSettings(ApplicationConst.WmsBaseGroupName, Order = 100)]
public class WmsSubstituteGoodService : IDynamicApiController, ITransient
{
private readonly SqlSugarRepository _rep;
public WmsSubstituteGoodService(SqlSugarRepository rep)
{
_rep = rep;
}
///
/// 分页查询替代品管理
///
///
///
[HttpPost]
[ApiDescriptionSettings(Name = "Page")]
public async Task> Page(WmsSubstituteGoodInput input)
{
var query = _rep.AsQueryable()
.WhereIF(!string.IsNullOrWhiteSpace(input.SearchKey), u =>
u.MaterialCode.Contains(input.SearchKey.Trim())
|| u.MaterialName.Contains(input.SearchKey.Trim())
|| u.SubstituteMaterialCode.Contains(input.SearchKey.Trim())
|| u.SubstituteMaterialName.Contains(input.SearchKey.Trim())
)
.WhereIF(input.IsDisabled != null, u => u.IsDisabled == input.IsDisabled)
.WhereIF(!string.IsNullOrWhiteSpace(input.MaterialCode), u => u.MaterialCode.Contains(input.MaterialCode.Trim()))
.WhereIF(!string.IsNullOrWhiteSpace(input.MaterialName), u => u.MaterialName.Contains(input.MaterialName.Trim()))
.WhereIF(!string.IsNullOrWhiteSpace(input.SubstituteMaterialCode), u => u.SubstituteMaterialCode.Contains(input.SubstituteMaterialCode.Trim()))
.WhereIF(!string.IsNullOrWhiteSpace(input.SubstituteMaterialName), u => u.SubstituteMaterialName.Contains(input.SubstituteMaterialName.Trim()))
.Select();
return await query.OrderBuilder(input).ToPagedListAsync(input.Page, input.PageSize);
}
///
/// 增加替代品管理
///
///
///
[HttpPost]
[ApiDescriptionSettings(Name = "Add")]
public async Task Add(AddWmsSubstituteGoodInput input)
{
var entity = input.Adapt();
//验重
await CheckExisit(entity);
await _rep.InsertAsync(entity);
return entity.Id;
}
///
/// 删除替代品管理
///
///
///
[HttpPost]
[ApiDescriptionSettings(Name = "Delete")]
public async Task Delete(DeleteWmsSubstituteGoodInput input)
{
var entity = await _rep.GetFirstAsync(u => u.Id == input.Id) ?? throw Oops.Oh(ErrorCodeEnum.D1002);
//await _rep.FakeDeleteAsync(entity); //假删除
await _rep.DeleteAsync(entity); //真删除
}
///
/// 更新替代品管理
///
///
///
[HttpPost]
[ApiDescriptionSettings(Name = "Update")]
public async Task Update(UpdateWmsSubstituteGoodInput input)
{
var entity = input.Adapt();
//验重
await CheckExisit(entity,true);
await _rep.AsUpdateable(entity).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
}
///
/// 获取替代品管理
///
///
///
[HttpGet]
[ApiDescriptionSettings(Name = "Detail")]
public async Task Detail([FromQuery] QueryByIdWmsSubstituteGoodInput input)
{
return await _rep.GetFirstAsync(u => u.Id == input.Id);
}
///
/// 获取替代品管理列表
///
///
///
[HttpGet]
[ApiDescriptionSettings(Name = "List")]
public async Task> List([FromQuery] WmsSubstituteGoodInput input)
{
return await _rep.AsQueryable().Select().ToListAsync();
}
#region 私有方法
///
/// 根据联合主键验证数据是否已存在-数据库
///
///
///
///
private async Task CheckExisit(WmsBaseSubstituteGood input, bool isEdit = false)
{
//输出数据已存在错误
ErrorCodeItemMetadataAttribute metadata = ErrorCodeEnum.D1006.GetErrorCodeItemMetadata();
WmsBaseSubstituteGood _existItem = null
;
if (!isEdit)//新增
{
_existItem = await _rep.GetFirstAsync(u => u.MaterialCode.Equals(input.MaterialCode)&&u.SubstituteMaterialCode.Equals(input.SubstituteMaterialCode));
if (_existItem != null) throw Oops.Oh($"物料编号[{input.MaterialCode}]替代品物料编号[{input.SubstituteMaterialCode}]{metadata.ErrorMessage}");
}
else//编辑
{
//当前编辑数据以外是否存在重复
_existItem = await _rep.GetFirstAsync(u => u.Id != input.Id && u.MaterialCode.Equals(input.MaterialCode) && u.SubstituteMaterialCode.Equals(input.SubstituteMaterialCode));
if (_existItem != null) throw Oops.Oh($"编号[{input.MaterialCode}]{metadata.ErrorMessage}");
}
}
#endregion
}