namespace Dpz.Core.Service.Mediator.Features.Video.Commands;

/// <summary>
/// 已过时：请使用 AddDanmakuCountHandler 和 RabbitMQ 消息队列替代。
/// 原 MediatR 同步处理模式已迁移到异步消息队列，提供更好的性能和可靠性。
/// </summary>
[Obsolete(
    "请使用 Web.Jobs 项目中的 AddDanmakuCountHandler 替代。MediatR 同步处理已迁移到 RabbitMQ 异步消息队列。",
    false
)]
public class AddDanmakuCountEvent(
    IRepository<global::Dpz.Core.Public.Entity.Video> repository,
    IRepository<Barrage> barrageRepository,
    IFusionCache fusionCache
) : IRequestHandler<AddDanmakuCountRequest>
{
    /// <summary>
    /// 回填视频弹幕计数并同步更新相关缓存。
    /// </summary>
    public async ValueTask<Unit> Handle(
        AddDanmakuCountRequest request,
        CancellationToken cancellationToken
    )
    {
        var count = await barrageRepository
            .SearchFor(x => x.Group == request.DanmakuGroup)
            .CountAsync(cancellationToken);
        var update = Builders<global::Dpz.Core.Public.Entity.Video>.Update.Set(
            x => x.DanmakuCount,
            count
        );
        await repository.UpdateAsync(x => x.Id == request.DanmakuGroup, update, cancellationToken);

        var key = $"{CacheKey.VideoListKey}:{request.DanmakuGroup}";
        var cacheValue = await fusionCache.TryGetAsync<VmVideo>(key, token: cancellationToken);
        if (cacheValue.HasValue)
        {
            cacheValue.Value.DanmakuCount = count;
            await fusionCache.SetAsync(
                key,
                cacheValue.Value,
                TimeSpan.FromDays(1),
                [CacheKey.VideoListKey],
                token: cancellationToken
            );
        }

        var listCache = await fusionCache.TryGetAsync<List<VmVideo>>(
            CacheKey.VideoListKey,
            token: cancellationToken
        );
        if (listCache.HasValue)
        {
            var video = listCache.Value.FirstOrDefault(x => x.Id == request.DanmakuGroup);
            if (video != null)
            {
                video.DanmakuCount = count;
                await fusionCache.SetAsync(
                    CacheKey.VideoListKey,
                    listCache.Value,
                    TimeSpan.FromDays(1),
                    [CacheKey.VideoListKey],
                    token: cancellationToken
                );
            }
        }

        return Unit.Value;
    }
}