namespace Dpz.Core.Service.RepositoryServiceImpl;

public class VideoService(IRepository<Video> repository, IMapper mapper, IFusionCache fusionCache)
    : IVideoService
{
    public async Task<List<VmVideo>> GetVideosAsync()
    {
        var list = await repository.SearchFor(x => true).ToListAsync();
        return list == null || list.Count == 0 ? [] : mapper.Map<List<VmVideo>>(list);
    }

    public async Task SaveInformationAsync(VmVideo video)
    {
        if (video == null || string.IsNullOrEmpty(video.Id))
        {
            throw new ArgumentNullException(
                nameof(video),
                "argument video or video.id is null or empty"
            );
        }

        var inVideo = mapper.Map<Video>(video);

        var filter = Builders<Video>.Filter.Eq(x => x.Id, inVideo.Id);
        var find = await repository.Collection.FindAsync(filter);
        var entity = await find.FirstOrDefaultAsync();
        if (entity == null)
        {
            inVideo.CommentCount = 0;
            inVideo.DanmakuCount = 0;
            inVideo.PlayCount = 0;
            await repository.InsertAsync(inVideo);
            return;
        }

        var update = Builders<Video>
            .Update.Set(x => x.Name, inVideo.Name)
            .Set(x => x.Description, inVideo.Description)
            .Set(x => x.Tags, inVideo.Tags)
            .Set(x => x.Title, inVideo.Title)
            .Set(x => x.SubTitle, inVideo.SubTitle)
            .Set(x => x.VideoTitle, inVideo.VideoTitle);

        await repository.UpdateAsync(x => x.Id == inVideo.Id, update);
    }

    public async Task<VmVideo?> GetVideoAsync(string id)
    {
        var entity = await repository.SearchFor(x => x.Id == id).FirstOrDefaultAsync();
        if (entity == null)
        {
            return null;
        }

        return mapper.Map<VmVideo>(entity);
    }

    public async Task AddPlayAsync(string id)
    {
        var update = Builders<Video>.Update.Inc(x => x.PlayCount, 1);
        await repository.UpdateAsync(x => x.Id == id, update);
    }

    /// <summary>
    /// 更新视频评论数（仅由消息队列使用）
    /// </summary>
    public async Task UpdateCommentCountAsync(
        string videoId,
        int count,
        CancellationToken cancellationToken = default
    )
    {
        // 视频使用字符串ID，直接更新
        var update = Builders<Video>.Update.Set(x => x.CommentCount, count);
        await repository.UpdateAsync(x => x.Id == videoId, update, cancellationToken);
    }

    public async Task UpdateDanmakuCountAsync(
        string videoId,
        int count,
        CancellationToken cancellationToken = default
    )
    {
        // 更新数据库
        var update = Builders<Video>.Update.Set(x => x.DanmakuCount, count);
        await repository.UpdateAsync(x => x.Id == videoId, update, cancellationToken);

        // 更新单个视频缓存
        var singleVideoKey = $"{CacheKey.VideoListKey}:{videoId}";
        var cachedVideo = await fusionCache.TryGetAsync<VmVideo>(
            singleVideoKey,
            token: cancellationToken
        );
        if (cachedVideo.HasValue)
        {
            cachedVideo.Value.DanmakuCount = count;
            await fusionCache.SetAsync(
                singleVideoKey,
                cachedVideo.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 == videoId);
            if (video != null)
            {
                video.DanmakuCount = count;
                await fusionCache.SetAsync(
                    CacheKey.VideoListKey,
                    listCache.Value,
                    TimeSpan.FromDays(1),
                    [CacheKey.VideoListKey],
                    token: cancellationToken
                );
            }
        }
    }
}