zengzy / hhrcs_service · Files

using MassTransit;
using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Logging;
using Rcs.Application.Common;
using Rcs.Application.DTOs;
using Rcs.Application.MessageBus.Commands;
using Rcs.Domain.Repositories;
using AutoMapper;

namespace Rcs.Infrastructure.MessageBus.Handlers.Commands;

/// <summary>
/// 获取网络动作属性列表查询处理器
/// @author zzy
/// </summary>
public class GetNetActionPropertysListQueryHandler : IConsumer<GetNetActionPropertysListQuery>
{
    private readonly ILogger<GetNetActionPropertysListQueryHandler> _logger;
    private readonly INetActionPropertysRepository _repository;
    private readonly IMapper _mapper;

    public GetNetActionPropertysListQueryHandler(
        ILogger<GetNetActionPropertysListQueryHandler> logger,
        INetActionPropertysRepository repository,
        IMapper mapper)
    {
        _logger = logger;
        _repository = repository;
        _mapper = mapper;
    }

    public async Task Consume(ConsumeContext<GetNetActionPropertysListQuery> context)
    {
        var query = context.Message;

        var queryable = _repository.GetQueryable();

        // 应用筛选条件
        if (!string.IsNullOrWhiteSpace(query.ActionName))
        {
            queryable = queryable.Where(x => x.ActionName.Contains(query.ActionName));
        }

        if (query.IsActive.HasValue)
        {
            queryable = queryable.Where(x => x.IsActive == query.IsActive.Value);
        }

        if (!string.IsNullOrWhiteSpace(query.RequestMethod))
        {
            queryable = queryable.Where(x => x.RequestMethod == query.RequestMethod);
        }

        // 应用通用筛选器
        if (!string.IsNullOrWhiteSpace(query.FilterModel))
        {
            queryable = FilterHelper.ApplyFilters(queryable, query.FilterModel);
        }

        var totalCount = await queryable.CountAsync(context.CancellationToken);

        var data = await queryable
            .OrderBy(x => x.CreatedAt)
            .Skip((query.PageNumber - 1) * query.PageSize)
            .Take(query.PageSize)
            .ToListAsync(context.CancellationToken);

        var dtos = _mapper.Map<List<NetActionPropertysListItemDto>>(data);
        await context.RespondAsync(PagedResponse<NetActionPropertysListItemDto>.Successful(
            dtos, query.PageNumber, query.PageSize, totalCount));
    }
}