using Admin.NET.Core.Service; using Admin.NET.Application.Entity; using Microsoft.AspNetCore.Http; using System.Data; using System.Web; using System.Text; namespace Admin.NET.Application; /// /// 库存信息服务 /// [ApiDescriptionSettings(ApplicationConst.WmsStockQuanGroupName, Order = 100)] public class WmsStockQuanService : IDynamicApiController, ITransient { private readonly SqlSugarRepository _rep; public WmsStockQuanService(SqlSugarRepository rep) { _rep = rep; } /// /// 分页查询库存信息 /// /// /// [HttpPost] [ApiDescriptionSettings(Name = "Page")] [Description("WmsStockQuan/Page")] public async Task> Page(WmsStockQuanInput input) { var query = CommonPageFilter(input); return await query.OrderBuilder(input, "", "Id").ToPagedListAsync(input.Page, input.PageSize); } /// /// 不分页查询库存信息 /// /// /// [HttpGet] [ApiDescriptionSettings(Name = "List")] [Description("WmsStockQuan/List")] public async Task> List([FromQuery] WmsStockQuanInput input) { var query = CommonPageFilter(input); return await query.OrderBuilder(input, "", "Id").Select().ToListAsync(); } /// /// 增加库存信息 /// /// /// [HttpPost] [ApiDescriptionSettings(Name = "Add")] [Description("WmsStockQuan/Add")] public async Task Add(AddWmsStockQuanInput input) { var entity = input.Adapt(); //重复性验证 await CheckExist(entity); await _rep.InsertAsync(entity); return entity.Id; } /// /// 删除库存信息 /// /// /// [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); //真删除 } /// /// 更新库存信息 /// /// /// [HttpPost] [ApiDescriptionSettings(Name = "Update")] [Description("WmsStockQuan/Update")] public async Task Update(UpdateWmsStockQuanInput input) { var entity = input.Adapt(); //重复性验证 await CheckExist(entity,true); await _rep.AsUpdateable(entity).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync(); } /// /// 获取库存信息 /// /// /// [HttpGet] [ApiDescriptionSettings(Name = "Detail")] [Description("WmsStockQuan/Detail")] public async Task Detail([FromQuery] QueryByIdWmsStockQuanInput input) { return await _rep.GetFirstAsync(u => u.Id == input.Id); } #region 私有方法 /// /// 公共查询库存信息条件 /// /// /// private ISugarQueryable CommonPageFilter(WmsStockQuanInput input) { var query = _rep.AsQueryable() .WhereIF(!string.IsNullOrWhiteSpace(input.SearchKey), u => u.PlaceCode.Contains(input.SearchKey.Trim()) || u.Upi.Contains(input.SearchKey.Trim()) || u.DetailName.Contains(input.SearchKey.Trim()) || u.PlanNo.Contains(input.SearchKey.Trim()) || u.OrderId.Contains(input.SearchKey.Trim()) || u.PackageCode.Contains(input.SearchKey.Trim()) || u.StockStatusName.Contains(input.SearchKey.Trim()) || u.OperReason.Contains(input.SearchKey.Trim()) || u.OperUser.Contains(input.SearchKey.Trim()) || u.LockReason.Contains(input.SearchKey.Trim()) || u.LockUser.Contains(input.SearchKey.Trim()) || u.Remarks.Contains(input.SearchKey.Trim()) || u.CreateUserName.Contains(input.SearchKey.Trim()) || u.UpdateUserName.Contains(input.SearchKey.Trim()) ) .WhereIF(!string.IsNullOrWhiteSpace(input.PlaceCode), u => u.PlaceCode.Contains(input.PlaceCode.Trim())) .WhereIF(!string.IsNullOrWhiteSpace(input.Upi), u => u.Upi.Contains(input.Upi.Trim())) .WhereIF(!string.IsNullOrWhiteSpace(input.DetailName), u => u.DetailName.Contains(input.DetailName.Trim())) .WhereIF(!string.IsNullOrWhiteSpace(input.PlanNo), u => u.PlanNo.Contains(input.PlanNo.Trim())) .WhereIF(!string.IsNullOrWhiteSpace(input.OrderId), u => u.OrderId.Contains(input.OrderId.Trim())) .WhereIF(!string.IsNullOrWhiteSpace(input.PackageCode), u => u.PackageCode.Contains(input.PackageCode.Trim())) .WhereIF(input.StockStatus.HasValue, u => u.StockStatus == input.StockStatus) .WhereIF(!string.IsNullOrWhiteSpace(input.StockStatusName), u => u.StockStatusName.Contains(input.StockStatusName.Trim())) .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(input.LockStatus.HasValue, u => u.LockStatus == input.LockStatus) .WhereIF(!string.IsNullOrWhiteSpace(input.LockReason), u => u.LockReason.Contains(input.LockReason.Trim())) .WhereIF(!string.IsNullOrWhiteSpace(input.LockUser), u => u.LockUser.Contains(input.LockUser.Trim())) .WhereIF(!string.IsNullOrWhiteSpace(input.Remarks), u => u.Remarks.Contains(input.Remarks.Trim())) .Select(); if(input.InTimeRange != null && input.InTimeRange.Count >0) { DateTime? start= input.InTimeRange[0].Value; query = query.WhereIF(start.HasValue, u => u.InTime >= start); if (input.InTimeRange.Count >1 && input.InTimeRange[1].HasValue) { var end = input.InTimeRange[1].Value; query = query.Where(u => u.InTime <= end); } } if(input.OperTimeRange != null && input.OperTimeRange.Count >0) { DateTime? start= input.OperTimeRange[0].Value.AddDays(-1); query = query.WhereIF(start.HasValue, u => u.OperTime > start); if (input.OperTimeRange.Count >1 && input.OperTimeRange[1].HasValue) { var end = input.OperTimeRange[1].Value.AddDays(1); query = query.Where(u => u.OperTime < end); } } if(input.LockTimeRange != null && input.LockTimeRange.Count >0) { DateTime? start= input.LockTimeRange[0].Value.AddDays(-1); query = query.WhereIF(start.HasValue, u => u.LockTime > start); if (input.LockTimeRange.Count >1 && input.LockTimeRange[1].HasValue) { var end = input.LockTimeRange[1].Value.AddDays(1); query = query.Where(u => u.LockTime < end); } } return query; } /// /// 重复性验证 /// /// 验证对象 /// 是否是编辑 /// private async Task CheckExist( WmsStockQuan input,bool isEdit=false) { //没有配置组合校验,不需要验重 //没有配置单独校验,不需要验重 } /// /// 根据组合校验和单独校验验证数据是否已存在-导入时验证 /// /// /// private async Task CheckExisitForImport(List inputs) { if (inputs?.Count <= 0) { throw Oops.Oh($"导入数据不能为空"); } //根据组合校验验证表格中中是否已存在相同数据 //根据单独校验验证表格中中是否已存在相同数据 } #endregion }