using Dpz.Core.MessageQueue.Abstractions;
using Dpz.Core.MessageQueue.Models;
using Dpz.Core.Public.ViewModel.Messages;
using Dpz.Core.Web.Jobs.Services;

namespace Dpz.Core.Web.Jobs.MessageHandlers;

/// <summary>
/// 发送管理员邮件通知处理器
/// </summary>
public class SendMasterEmailHandler(
    EmailSenderHelper emailSenderHelper,
    ILogger<SendMasterEmailHandler> logger
) : IMessageHandler<SendMasterEmailMessage>
{
    public async Task<MessageHandlerResult> HandleAsync(
        SendMasterEmailMessage message,
        CancellationToken cancellationToken
    )
    {
        try
        {
            if (!emailSenderHelper.IsServiceEnabled)
            {
                logger.LogWarning("邮件服务未启用，跳过发送");
                return MessageHandlerResult.Ok();
            }

            await emailSenderHelper.SendMasterNotificationAsync(
                message.NickName,
                message.Email,
                message.CommentText,
                message.SendTime,
                cancellationToken
            );

            logger.LogInformation(
                "管理员邮件通知发送成功: NickName={NickName}, Email={Email}",
                message.NickName,
                message.Email
            );

            return MessageHandlerResult.Ok();
        }
        catch (Exception ex)
        {
            logger.LogError(
                ex,
                "管理员邮件通知发送失败: NickName={NickName}, Email={Email}",
                message.NickName,
                message.Email
            );
            return MessageHandlerResult.Fail($"管理员邮件通知发送失败: {ex.Message}");
        }
    }
}