using Admin.NET.Core.Service; using Admin.NET.Application.Const; using Admin.NET.Application.Entity; using Microsoft.AspNetCore.Http; using Nest; namespace Admin.NET.Application; /// /// 出库单服务 /// [ApiDescriptionSettings(ApplicationConst.GroupName, Order = 100)] public class OutboundService : IDynamicApiController, ITransient { private readonly SqlSugarRepository _rep; private readonly OutboundDetailService _outboundDetailService; private readonly PrintCodeDetailService _codeDetailService; public OutboundService(SqlSugarRepository rep, OutboundDetailService outboundDetailService, PrintCodeDetailService codeDetailService) { _rep = rep; _outboundDetailService = outboundDetailService; _codeDetailService = codeDetailService; } /// /// 分页查询出库单 /// /// /// [HttpPost] [ApiDescriptionSettings(Name = "Page")] public async Task> Page(OutboundInput input) { var query = _rep.AsQueryable().Where(a => !a.IsDelete) .WhereIF(!string.IsNullOrWhiteSpace(input.SearchKey), u => u.CodeNum.Contains(input.SearchKey.Trim()) || u.SourceCodeNum.Contains(input.SearchKey.Trim()) || u.BusinessType.Contains(input.SearchKey.Trim()) || u.Consignee.Contains(input.SearchKey.Trim()) ) .WhereIF(!string.IsNullOrWhiteSpace(input.CodeNum), u => u.CodeNum.Contains(input.CodeNum.Trim())) .WhereIF(!string.IsNullOrWhiteSpace(input.SourceCodeNum), u => u.SourceCodeNum.Contains(input.SourceCodeNum.Trim())) .WhereIF(input.State>0, u => u.State == input.State) .WhereIF(!string.IsNullOrWhiteSpace(input.BusinessType), u => u.BusinessType.Contains(input.BusinessType.Trim())) .WhereIF(!string.IsNullOrWhiteSpace(input.Consignee), u => u.Consignee.Contains(input.Consignee.Trim())) .WhereIF(input.ExaminerId>0, u => u.ExaminerId == input.ExaminerId) .Select(); return await query.OrderBuilder(input).ToPagedListAsync(input.Page, input.PageSize); } /// /// 增加出库单 /// /// /// [HttpPost] [ApiDescriptionSettings(Name = "Add")] public async Task Add(AddOutboundInput input) { var entity = input.Adapt(); await _rep.InsertAsync(entity); return entity.Id; } /// /// 删除出库单 /// /// /// [HttpPost] [ApiDescriptionSettings(Name = "Delete")] public async Task Delete(DeleteOutboundInput 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(UpdateOutboundInput input) { var entity = input.Adapt(); await _rep.AsUpdateable(entity).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync(); } /// /// 获取出库单 /// /// /// [HttpGet] [ApiDescriptionSettings(Name = "Detail")] public async Task Detail([FromQuery] QueryByIdOutboundInput input) { return await _rep.GetFirstAsync(u => u.Id == input.Id); } /// /// 获取出库单列表 /// /// /// [HttpGet] [ApiDescriptionSettings(Name = "List")] public async Task> List() { return await _rep.AsQueryable().Where(a => !a.IsDelete).Select().ToListAsync(); } /// /// 获取出库单 /// /// /// [HttpGet] [ApiDescriptionSettings(Name = "GetOutboundDetail")] public async Task> GetOutboundDetail([FromQuery] QueryByIdOutboundInput input) { var outbound = await _outboundDetailService.GetByOutboundId(input.Id); if (string.IsNullOrEmpty(outbound.CodeTableIds)) { throw Oops.Oh(ErrorCodeEnum.xg1002); } var result = new List(); var details = await _codeDetailService.List(); if (details == null || details.Count < 1) { return result; } var ids = outbound.CodeTableIds.Split(',').Select(a => Convert.ToInt64(a)).ToList(); //var printDetails = details.FindAll(a => ids.Contains(a.Id)); //if (printDetails.Count < 1) //{ // return result; //} var father = details.FindAll(a => ids.Contains(a.Id)); foreach (var item in father) { var treeData1 = item.Adapt(); var list1 = details.FindAll(a => a.FatherId == item.Id); if (list1.Count > 0) { treeData1.Children = new List(); treeData1.HasChildren = false; foreach (var dt in list1) { var list2 = details.FindAll(a => a.FatherId == dt.Id); var treeData2 = dt.Adapt(); if (list2.Count > 0) { treeData2.Children = new List(); treeData2.HasChildren = false; foreach (var dt3 in list2) { var list3 = details.FindAll(a => a.FatherId == dt3.Id); var treeData3 = dt3.Adapt(); if (list3.Count > 0) { treeData3.Children = new List(); treeData3.HasChildren = false; foreach (var dt4 in list3) { var treeData4 = dt4.Adapt(); treeData3.Children.Add(treeData4); } } treeData2.Children.Add(treeData3); } } treeData1.Children.Add(treeData2); } } result.Add(treeData1); } return result; } }