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 DictionaryCategoriesQueryHandler(
|
IRepository<DictionaryCategory> rep
|
) : IRequestHandler<GetDictionaryCategoriesQuery, PagedListQueryResult<GetDictionaryCategoriesQueryResultItem>>,
|
IRequestHandler<GetDictionaryCategorySelectQuery, List<SelectQueryResultItem<Guid>>>
|
{
|
private readonly IRepository<DictionaryCategory> rep = rep;
|
|
/// <summary>
|
/// 查询数据字典类别分页列表数据
|
/// </summary>
|
/// <param name="request"></param>
|
/// <param name="cancellationToken"></param>
|
/// <returns></returns>
|
public Task<PagedListQueryResult<GetDictionaryCategoriesQueryResultItem>> Handle(GetDictionaryCategoriesQuery request, CancellationToken cancellationToken)
|
{
|
return request.PageModel.ToPagedListAsync<DictionaryCategory, GetDictionaryCategoriesQueryResultItem>(
|
q =>
|
{
|
q = q.OrderBy(it => it.Sort).ThenBy(it => it.CreatedTime);
|
if (request.Keywords.IsNotNull())
|
{
|
q = q.Where(it =>
|
it.Code.Contains(request.Keywords) ||
|
it.Name.Contains(request.Keywords) ||
|
it.Remark.Contains(request.Keywords));
|
}
|
return q;
|
}, cancellationToken: cancellationToken);
|
}
|
|
/// <summary>
|
/// 查询数据字典类别选择器数据
|
/// </summary>
|
/// <param name="request"></param>
|
/// <param name="cancellationToken"></param>
|
/// <returns></returns>
|
public Task<List<SelectQueryResultItem<Guid>>> Handle(GetDictionaryCategorySelectQuery request, CancellationToken cancellationToken)
|
{
|
var items = rep.AsQueryable().AsNoTracking()
|
.Select(it => new SelectQueryResultItem<Guid>
|
{
|
Value = it.Id,
|
Label = it.Name,
|
Data = new
|
{
|
it.Id,
|
it.Name,
|
it.Remark,
|
it.FieldNames
|
}
|
})
|
.ToListAsync(cancellationToken);
|
return items;
|
}
|
}
|
}
|