77 lines
2.2 KiB
C#
77 lines
2.2 KiB
C#
using Microsoft.EntityFrameworkCore;
|
||
using Persistence.Database.Model;
|
||
using Persistence.Models;
|
||
using Persistence.Models.Requests;
|
||
|
||
namespace Persistence.Repository;
|
||
|
||
/// <summary>
|
||
/// класс с набором методов, необходимых для фильтрации записей
|
||
/// </summary>
|
||
public static class QueryBuilders
|
||
{
|
||
public static void Apply<TEntity>(this IQueryable<TEntity> query, SectionPartRequest request)
|
||
where TEntity : class, IWithSectionPart
|
||
{
|
||
if (request.IdSection.HasValue)
|
||
{
|
||
query = query.Where(e => e.IdSection == request.IdSection);
|
||
}
|
||
if (request.DepthStart.HasValue)
|
||
{
|
||
query = query.Where(e => e.DepthStart >= request.DepthStart);
|
||
}
|
||
if (request.DepthEnd.HasValue)
|
||
{
|
||
query = query.Where(e => e.DepthEnd <= request.DepthEnd);
|
||
}
|
||
}
|
||
|
||
public static void Apply<TEntity>(this IQueryable<TEntity> query,DateTimeOffset momentUtc)
|
||
where TEntity : class, IChangeLog
|
||
{
|
||
momentUtc = momentUtc.ToUniversalTime();
|
||
|
||
query = query
|
||
.Where(e => e.Creation <= momentUtc)
|
||
.Where(e => e.Obsolete == null || e.Obsolete >= momentUtc);
|
||
}
|
||
|
||
|
||
public static async Task<PaginationContainer<TDto>> ApplyPagination<TEntity, TDto>(
|
||
this IQueryable<TEntity> query,
|
||
PaginationRequest request,
|
||
Func<TEntity, TDto> Convert,
|
||
CancellationToken token)
|
||
where TEntity : class, IWithSectionPart
|
||
where TDto : class
|
||
{
|
||
if (String.IsNullOrEmpty(request.SortSettings))
|
||
{
|
||
query = query
|
||
.OrderBy(e => e.IdSection)
|
||
.ThenBy(e => e.DepthStart)
|
||
.ThenBy(e => e.DepthEnd);
|
||
}
|
||
else
|
||
{
|
||
query = query.SortBy(request.SortSettings);
|
||
}
|
||
|
||
var entities = await query
|
||
.Skip(request.Skip)
|
||
.Take(request.Take)
|
||
.ToArrayAsync(token);
|
||
|
||
var result = new PaginationContainer<TDto>
|
||
{
|
||
Skip = request.Skip,
|
||
Take = request.Take,
|
||
Items = entities.Select(Convert),
|
||
Count = await query.CountAsync(token)
|
||
};
|
||
|
||
return result;
|
||
}
|
||
}
|