zengzy / hhrcs_service · Files

using MassTransit;
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 GetNetActionPropertysQueryHandler : IConsumer<GetNetActionPropertysQuery>
{
    private readonly ILogger<GetNetActionPropertysQueryHandler> _logger;
    private readonly INetActionPropertysRepository _repository;
    private readonly IMapper _mapper;

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

    public async Task Consume(ConsumeContext<GetNetActionPropertysQuery> context)
    {
        var query = context.Message;
        try
        {
            var data = await _repository.GetByIdAsync(query.NetActionId, context.CancellationToken);

            if (data == null)
            {
                await context.RespondAsync(ApiResponse<NetActionPropertysDto>.Failed("未找到该网络动作属性"));
                return;
            }

            var dto = _mapper.Map<NetActionPropertysDto>(data);
            await context.RespondAsync(ApiResponse<NetActionPropertysDto>.Successful(dto));
        }
        catch (Exception ex)
        {
            await context.RespondAsync(ApiResponse<NetActionPropertysDto>.Failed(ex.Message));
        }
    }
}