using FlexJobApi.Core;
|
using Furion.DatabaseAccessor;
|
using Mapster;
|
using MediatR;
|
using Microsoft.EntityFrameworkCore;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace FlexJobApi.Application
|
{
|
/// <summary>
|
/// 数据字典查询处理器
|
/// </summary>
|
public class DictionaryDatasQueryHandler(
|
IRepository<DictionaryData> rep
|
) : IRequestHandler<GetDictionaryDatasQuery, PagedListQueryResult<GetDictionaryDatasQueryResultItem>>
|
{
|
private readonly IRepository<DictionaryData> rep = rep;
|
|
/// <summary>
|
/// 获取数据字典分页列表数据
|
/// </summary>
|
/// <param name="request"></param>
|
/// <param name="cancellationToken"></param>
|
/// <returns></returns>
|
public Task<PagedListQueryResult<GetDictionaryDatasQueryResultItem>> Handle(GetDictionaryDatasQuery request, CancellationToken cancellationToken)
|
{
|
return request.PageModel.ToPagedListAsync<DictionaryData, GetDictionaryDatasQueryResultItem>(
|
q =>
|
{
|
q = q.OrderBy(it => it.Sort).ThenBy(it => it.CreatedTime);
|
if (request.CategoryId.HasValue)
|
{
|
q = q.Where(it => it.CategoryId == request.CategoryId);
|
}
|
if (request.Keywords.IsNotNull())
|
{
|
q = q.Where(it =>
|
it.Code.Contains(request.Keywords)
|
|| it.Content.Contains(request.Keywords)
|
|| it.Field1.Contains(request.Keywords)
|
|| it.Field2.Contains(request.Keywords)
|
|| it.Field3.Contains(request.Keywords)
|
|| it.Field4.Contains(request.Keywords)
|
|| it.Field5.Contains(request.Keywords));
|
}
|
return q;
|
}, cancellationToken: cancellationToken);
|
}
|
}
|
}
|