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 }