using Dpz.Core.MessageQueue.Abstractions;
using Dpz.Core.MessageQueue.Models;
using Dpz.Core.Public.ViewModel.Messages;
using Dpz.Core.Service.RepositoryService;

namespace Dpz.Core.Web.Jobs.MessageHandlers;

/// <summary>
/// 增加弹幕计数消息处理器
/// 更新视频的弹幕数量并刷新缓存
/// </summary>
public class AddDanmakuCountHandler(
    IVideoService videoService,
    IBarrageService barrageService,
    ILogger<AddDanmakuCountHandler> logger
) : IMessageHandler<AddDanmakuCountMessage>
{
    public async Task<MessageHandlerResult> HandleAsync(
        AddDanmakuCountMessage message,
        CancellationToken cancellationToken
    )
    {
        try
        {
            // 获取最新弹幕数量
            var count = await barrageService.GetGroupBarrageCountAsync(message.DanmakuGroup);

            // 更新数据库和缓存
            await videoService.UpdateDanmakuCountAsync(
                message.DanmakuGroup,
                count,
                cancellationToken
            );

            logger.LogInformation(
                "弹幕计数更新成功: DanmakuGroup={DanmakuGroup}, Count={Count}",
                message.DanmakuGroup,
                count
            );

            return MessageHandlerResult.Ok();
        }
        catch (Exception ex)
        {
            logger.LogError(
                ex,
                "弹幕计数更新失败: DanmakuGroup={DanmakuGroup}",
                message.DanmakuGroup
            );
            return MessageHandlerResult.Fail($"弹幕计数更新失败: {ex.Message}");
        }
    }
}