18923810322/WMS-Api
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

导出接口

Browse Source
This commit is contained in:
tongfei
2023-11-15 15:02:19 +08:00
parent 9840fb93fb
commit 2cbc496e1f
17 changed files with 327 additions and 64 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
src/WMS.Web.Repositories/BoxInventoryRepositories.cs
View File

@@ -19,7 +19,7 @@ namespace WMS.Web.Repositories
/// <summary>
/// 箱库存-仓储
/// </summary>
public class BoxInventoryRepositories: IBoxInventoryRepositories
public class BoxInventoryRepositories: IAllFielRepositories<BoxInventoryQueryRequest>, IBoxInventoryRepositories
{
private readonly IMapper _mapper;
private readonly IServiceProvider _serviceProvider;
@@ -52,12 +52,12 @@ namespace WMS.Web.Repositories
/// </summary>
/// <param name="dto"></param>
/// <returns></returns>
public async Task<ResultPagedList<BoxInventoryQueryResponse>> GetPagedList(BoxInventoryQueryRequest dto)
public async Task<(List<BoxInventoryQueryResponse> list, int total)> GetPagedList(BoxInventoryQueryRequest dto)
{
//1.获取物料集合和组织集合
var materials_result = await _erpService.BillQueryForMaterial();
if (!materials_result.IsSuccess)
return ResultPagedList<BoxInventoryQueryResponse>.ReFailure(materials_result);
return (new List<BoxInventoryQueryResponse>(), 0);
var materials = materials_result.Data.ToList();
//物料集合；模糊查询后的物料集合
@@ -80,10 +80,7 @@ namespace WMS.Web.Repositories
if (dto.SubStockId.HasValue)
query = query.Where(w => w.order.SubStockId == dto.SubStockId.Value);
var response = new ResultPagedList<BoxInventoryQueryResponse>();
int total = await query.CountAsync();
response.TotalCount = total;
var list = await query.Select(s => new BoxInventoryQueryResponse()
{
Id = s.order.Id,
@@ -96,9 +93,7 @@ namespace WMS.Web.Repositories
SubStock = _singleDataService.GetSingleData(SingleAction.SubStocks, _loginRepositories.CompanyId, s.order.SubStockId),
Qty = s.detail.Qty,
}).OrderByDescending(x => x.Id).Skip((dto.PageNo - 1) * dto.PageSize).Take(dto.PageSize).ToListAsync();
response.Data = list;
return response;
return (list,total);
}
/// <summary>
@@ -236,5 +231,16 @@ namespace WMS.Web.Repositories
}
return true;
}
/// <summary>
/// 导出
/// </summary>
/// <param name="dto"></param>
/// <param name="companyId"></param>
/// <returns></returns>
public async Task<(object obj, int total)> GetListField(BoxInventoryQueryRequest dto, int companyId)
{
return await GetPagedList(dto);
}
}
}

8
src/WMS.Web.Repositories/DependencyInjection/AppBuilderExtensions.cs
View File

@@ -2,7 +2,9 @@
using System;
using System.Collections.Generic;
using System.Text;
using WMS.Web.Core.Dto;
using WMS.Web.Core.Dto.ChangeBoxRecord;
using WMS.Web.Core.Dto.Inventory;
using WMS.Web.Core.Dto.MoveBoxRecord;
using WMS.Web.Core.Dto.OutStock;
using WMS.Web.Core.Dto.OutStockTask;
@@ -48,6 +50,12 @@ namespace Microsoft.Extensions.DependencyInjection
services.AddTransient<IAllFielRepositories<OutStockQueryRequest>, OutStockRepositories>();
services.AddTransient<IAllFielRepositories<MoveBoxRecordQueryRequest>, MoveBoxRecordRepositories>();
services.AddTransient<IAllFielRepositories<ChangeBoxRecordQueryRequest>, ChangeBoxRecordRepositories>();
services.AddTransient<IAllFielRepositories<InStockQueryRequest>, InStockRepositories>();
services.AddTransient<IAllFielRepositories<InStockTaskQueryRequest>, InStockTaskRepositories>();
services.AddTransient<IAllFielRepositories<InventoryDetailsQueryRequest>, InventoryDetailsRepositories>();
services.AddTransient<IAllFielRepositories<InventoryInOutDetailsQueryRequest>, InventoryInOutDetailsRepositories>();
services.AddTransient<IAllFielRepositories<BoxInventoryQueryRequest>, BoxInventoryRepositories>();
#endregion

28
src/WMS.Web.Repositories/InStockRepositories.cs
View File

@@ -20,7 +20,7 @@ namespace WMS.Web.Repositories
/// <summary>
/// wms入库单-仓储
/// </summary>
public class InStockRepositories: IInStockRepositories
public class InStockRepositories: IAllFielRepositories<InStockQueryRequest>, IInStockRepositories
{
private readonly IMapper _mapper;
private readonly IServiceProvider _serviceProvider;
@@ -53,24 +53,24 @@ namespace WMS.Web.Repositories
/// </summary>
/// <param name="dto"></param>
/// <returns></returns>
public async Task<ResultPagedList<InStockQueryResponse>> GetPagedList(InStockQueryRequest dto)
public async Task<(List<InStockQueryResponse> list, int total)> GetPagedList(InStockQueryRequest dto)
{
//1.获取物料集合和组织集合和供应商的集合
var materials_result = await _erpService.BillQueryForMaterial();
if (!materials_result.IsSuccess)
return ResultPagedList<InStockQueryResponse>.ReFailure(materials_result);
return (new List<InStockQueryResponse>(), 0);
var materials = materials_result.Data.ToList();
//组织集合
var orgs_result = await _erpService.BillQueryForOrg();
if (!orgs_result.IsSuccess)
return ResultPagedList<InStockQueryResponse>.ReFailure(orgs_result);
return (new List<InStockQueryResponse>(), 0);
var orgs = orgs_result.Data.ToList();
//供应商集合
var suppliers_result = await _erpService.BillQueryForSupplier();
if (!suppliers_result.IsSuccess)
return ResultPagedList<InStockQueryResponse>.ReFailure(suppliers_result);
return (new List<InStockQueryResponse>(), 0);
var suppliers = suppliers_result.Data.ToList();
//物料集合；模糊查询后的物料集合
@@ -109,10 +109,8 @@ namespace WMS.Web.Repositories
if (dto.CreateEndDate != null)
query = query.Where(w => w.order.CreateTime <= dto.CreateEndDate.Value);
var response = new ResultPagedList<InStockQueryResponse>();
int total = await query.CountAsync();
response.TotalCount = total;
var list = await query.Select(s => new InStockQueryResponse()
{
Id=s.order.Id,
@@ -132,8 +130,7 @@ namespace WMS.Web.Repositories
SuccessSync=s.order.SuccessSync
}).OrderByDescending(x => x.Id).Skip((dto.PageNo - 1) * dto.PageSize).Take(dto.PageSize).ToListAsync();
response.Data = list;
return response;
return (list, total);
}
/// <summary>
@@ -170,5 +167,16 @@ namespace WMS.Web.Repositories
}
}
/// <summary>
/// 导出
/// </summary>
/// <param name="dto"></param>
/// <param name="companyId"></param>
/// <returns></returns>
public async Task<(object obj, int total)> GetListField(InStockQueryRequest dto, int companyId)
{
return await GetPagedList(dto);
}
}
}

32
src/WMS.Web.Repositories/InStockTaskRepositories.cs
View File

@@ -25,7 +25,7 @@ namespace WMS.Web.Repositories
/// <summary>
/// 入库任务表-仓储
/// </summary>
public class InStockTaskRepositories : IInStockTaskRepositories
public class InStockTaskRepositories : IAllFielRepositories<InStockTaskQueryRequest>, IInStockTaskRepositories
{
private readonly IMapper _mapper;
private readonly IServiceProvider _serviceProvider;
@@ -58,23 +58,23 @@ namespace WMS.Web.Repositories
/// </summary>
/// <param name="dto"></param>
/// <returns></returns>
public async Task<ResultPagedList<InStockTaskQueryResponse>> GetPagedList(InStockTaskQueryRequest dto)
public async Task<(List<InStockTaskQueryResponse> list, int total)> GetPagedList(InStockTaskQueryRequest dto)
{
//1.获取物料集合和组织集合
var materials_result = await _erpService.BillQueryForMaterial();
if (!materials_result.IsSuccess)
return ResultPagedList<InStockTaskQueryResponse>.ReFailure(materials_result);
return (new List<InStockTaskQueryResponse>(), 0);
var materials = materials_result.Data.ToList();
//组织集合
var orgs_result = await _erpService.BillQueryForOrg();
if (!orgs_result.IsSuccess)
return ResultPagedList<InStockTaskQueryResponse>.ReFailure(orgs_result);
return (new List<InStockTaskQueryResponse>(), 0);
var orgs = orgs_result.Data.ToList();
//供应商集合
var suppliers_result = await _erpService.BillQueryForSupplier();
if (!suppliers_result.IsSuccess)
return ResultPagedList<InStockTaskQueryResponse>.ReFailure(suppliers_result);
return (new List<InStockTaskQueryResponse>(), 0);
var suppliers = suppliers_result.Data.ToList();
//物料集合；模糊查询后的物料集合
@@ -117,10 +117,8 @@ namespace WMS.Web.Repositories
if (dto.CreateEndDate != null)
query = query.Where(w => w.order.ShelfTime <= dto.CreateEndDate.Value);
var response = new ResultPagedList<InStockTaskQueryResponse>();
int total = await query.CountAsync();
response.TotalCount = total;
int total = await query.CountAsync();
var list =await query.Select(s => new InStockTaskQueryResponse()
{
Id = s.order.Id,
@@ -145,9 +143,8 @@ namespace WMS.Web.Repositories
ShelfTime = s.order.ShelfTime.HasValue ? s.order.ShelfTime.Value.ToString("yyyy-MM-dd HH:mm:ss") : "",
CreateTime = s.order.CreateTime.ToString("yyyy-MM-dd HH:mm:ss"),
}).OrderByDescending(x => x.Id).Skip((dto.PageNo - 1) * dto.PageSize).Take(dto.PageSize).ToListAsync();
response.Data = list;
return response;
return (list,total);
}
/// <summary>
@@ -498,5 +495,16 @@ namespace WMS.Web.Repositories
return null;
}
}
/// <summary>
/// 导出
/// </summary>
/// <param name="dto"></param>
/// <param name="companyId"></param>
/// <returns></returns>
public async Task<(object obj, int total)> GetListField(InStockTaskQueryRequest dto, int companyId)
{
return await GetPagedList(dto);
}
}
}

25
src/WMS.Web.Repositories/InventoryDetailsRepositories.cs
View File

@@ -19,7 +19,7 @@ namespace WMS.Web.Repositories
/// <summary>
/// 库存相关-仓储
/// </summary>
public class InventoryDetailsRepositories: IInventoryDetailsRepositories
public class InventoryDetailsRepositories: IAllFielRepositories<InventoryDetailsQueryRequest>, IInventoryDetailsRepositories
{
private readonly IMapper _mapper;
private readonly IServiceProvider _serviceProvider;
@@ -51,12 +51,12 @@ namespace WMS.Web.Repositories
/// </summary>
/// <param name="dto"></param>
/// <returns></returns>
public async Task<ResultPagedList<InventoryDetailsQueryResponse>> GetPagedList(InventoryDetailsQueryRequest dto)
public async Task<(List<InventoryDetailsQueryResponse> list,int total)> GetPagedList(InventoryDetailsQueryRequest dto)
{
//1.获取物料集合和组织集合
var materials_result = await _erpService.BillQueryForMaterial();
if (!materials_result.IsSuccess)
return ResultPagedList<InventoryDetailsQueryResponse>.ReFailure(materials_result);
return (new List<InventoryDetailsQueryResponse>(), 0);
var materials = materials_result.Data.ToList();
//物料集合；模糊查询后的物料集合
@@ -80,9 +80,8 @@ namespace WMS.Web.Repositories
if (dto.Qty.HasValue)
query = query.Where(w => w.Qty == dto.Qty);
var response = new ResultPagedList<InventoryDetailsQueryResponse>();
int total = await query.CountAsync();
response.TotalCount = total;
int total = await query.CountAsync();
var list = await query.Select(s => new InventoryDetailsQueryResponse()
{
@@ -96,8 +95,7 @@ namespace WMS.Web.Repositories
Unit = _erpBasicDataExtendService.GetMaterialUnitName(materials, s.MaterialId),
}).OrderByDescending(x => x.Id).Skip((dto.PageNo - 1) * dto.PageSize).Take(dto.PageSize).ToListAsync();
response.Data = list;
return response;
return (list,total);
}
/// <summary>
@@ -159,5 +157,16 @@ namespace WMS.Web.Repositories
return true;
}
}
/// <summary>
/// 导出
/// </summary>
/// <param name="dto"></param>
/// <param name="companyId"></param>
/// <returns></returns>
public async Task<(object obj, int total)> GetListField(InventoryDetailsQueryRequest dto, int companyId)
{
return await GetPagedList(dto);
}
}
}

24
src/WMS.Web.Repositories/InventoryInOutDetailsRepositories.cs
View File

@@ -20,7 +20,7 @@ namespace WMS.Web.Repositories
/// <summary>
/// 物料收发明细-仓储
/// </summary>
public class InventoryInOutDetailsRepositories: IInventoryInOutDetailsRepositories
public class InventoryInOutDetailsRepositories : IAllFielRepositories<InventoryInOutDetailsQueryRequest>, IInventoryInOutDetailsRepositories
{
private readonly IMapper _mapper;
private readonly IServiceProvider _serviceProvider;
@@ -52,12 +52,12 @@ namespace WMS.Web.Repositories
/// </summary>
/// <param name="dto"></param>
/// <returns></returns>
public async Task<ResultPagedList<InventoryInOutDetailsQueryResponse>> GetPagedList(InventoryInOutDetailsQueryRequest dto)
public async Task<(List<InventoryInOutDetailsQueryResponse> list, int total)> GetPagedList(InventoryInOutDetailsQueryRequest dto)
{
//1.获取物料集合和组织集合
var materials_result = await _erpService.BillQueryForMaterial();
if (!materials_result.IsSuccess)
return ResultPagedList<InventoryInOutDetailsQueryResponse>.ReFailure(materials_result);
return (new List<InventoryInOutDetailsQueryResponse>(), 0);
var materials = materials_result.Data.ToList();
//物料集合；模糊查询后的物料集合
@@ -85,10 +85,8 @@ namespace WMS.Web.Repositories
if (dto.CreateEndDate != null)
query = query.Where(w => w.CreateTime <= dto.CreateEndDate.Value);
var response = new ResultPagedList<InventoryInOutDetailsQueryResponse>();
int total = await query.CountAsync();
response.TotalCount = total;
var list = await query.Select(s => new InventoryInOutDetailsQueryResponse()
{
Id = s.Id,
@@ -104,8 +102,7 @@ namespace WMS.Web.Repositories
CreateTime = s.CreateTime
}).OrderByDescending(x => x.Id).Skip((dto.PageNo - 1) * dto.PageSize).Take(dto.PageSize).ToListAsync();
response.Data = list;
return response;
return (list,total);
}
/// <summary>
@@ -137,5 +134,16 @@ namespace WMS.Web.Repositories
return false;
}
}
/// <summary>
/// 导出
/// </summary>
/// <param name="dto"></param>
/// <param name="companyId"></param>
/// <returns></returns>
public async Task<(object obj, int total)> GetListField(InventoryInOutDetailsQueryRequest dto, int companyId)
{
return await GetPagedList(dto);
}
}
}