using System.Collections.Specialized;
using System.Net.Http;
using System.Net.Http.Json;
using Dpz.Core.Public.ViewModel.Response;
using Dpz.Core.Shard.Service;

namespace Dpz.Core.Web.Library.Api.Service;

public class HomeCacheService(
    IArticleService articleService,
    IPictureRecordService pictureRecordService,
    IHttpContextAccessor httpContextAccessor,
    IHttpClientFactory httpClientFactory,
    IFusionCache fusionCache,
    IVideoShardService videoShardService,
    ILogger<HomeCacheService> logger
) : IHomeCacheService
{
    /// <summary>
    /// 过期时间
    /// </summary>
    private readonly TimeSpan _expired = TimeSpan.FromDays(1);

    private async Task<IList<PictureRecordResponse>> GetBannersAsync()
    {
        var banner = await pictureRecordService.GetBannerAsync();
        return banner.ToList();
    }

    public async Task<HomeContainerModel> GetCacheDataAsync()
    {
        var model = await fusionCache.GetOrSetAsync<HomeContainerModel>(
            CacheKey.HomeContainerKey,
            async (_, cancellationToken) =>
            {
                var m = new HomeContainerModel
                {
                    Blogs = await GetTopArticlesAsync(),
                    LikeArticle = await GetRandomArticlesAsync(cancellationToken),
                    News = await GetLatestArticlesAsync(cancellationToken),
                    Pictures = await GetBannersAsync(),
                    Tags = await GetArticleTagsAsync(cancellationToken),
                };
                return m;
            },
            options => options.SetDuration(_expired)
        );

        var video = await GetRandomVideoAsync();
        model.Video = video;
        return model;
    }

    private async Task<VmVideo?> GetRandomVideoAsync()
    {
        var videos = await videoShardService.GetVideosAsync();
        if (videos.Count == 0)
        {
            return null;
        }

        return videos.OrderBy(_ => Guid.NewGuid()).First();
    }

    public async Task<List<string>> GetArticleTagsAsync(
        CancellationToken cancellationToken = default
    )
    {
        return await articleService.GetAllTagsAsync(cancellationToken);
    }

    public async Task<List<ArticleMiniResponse>> GetLatestArticlesAsync(
        CancellationToken cancellationToken = default
    )
    {
        return await articleService.GetLatestAsync(cancellationToken: cancellationToken);
    }

    public async Task<List<ArticleMiniResponse>> GetRandomArticlesAsync(
        CancellationToken cancellationToken = default
    )
    {
        return await articleService.GetRandomArticlesAsync(cancellationToken: cancellationToken);
    }

    public async Task<TodayNewsModel?> GetTodayNewsAsync()
    {
        var ipAddress = httpContextAccessor.HttpContext?.Request.GetIpAddress() ?? "";
        var todayNewsKey = $"home:news:{ipAddress.Replace(":", "-")}";
        return await fusionCache.GetOrSetAsync<TodayNewsModel?>(
            todayNewsKey,
            async (_, cancellationToke) =>
            {
                var httpClient = httpClientFactory.CreateClient("edge");

                try
                {
                    var parameters = new NameValueCollection { { "ip", ipAddress } };
                    var request = new HttpRequestMessage(
                        HttpMethod.Get,
                        "https://news.topurl.cn/api?" + parameters.ToQueryString()
                    );
                    var response = await httpClient.SendAsync(request, cancellationToke);
                    if (!response.IsSuccessStatusCode)
                    {
                        logger.LogWarning(
                            "get today news fail,status code:{Code}",
                            response.StatusCode
                        );
                        return null;
                    }
                    var data = await response.Content.ReadFromJsonAsync<NewsResponse>(
                        cancellationToken: cancellationToke
                    );
                    return data?.Data;
                }
                catch (Exception ex)
                {
                    logger.LogError(ex, "get today news fail");
                    return null;
                }
            },
            options => options.SetDuration(TimeSpan.FromHours(5))
        );
    }

    private async Task<List<ArticleMiniResponse>> GetTopArticlesAsync()
    {
        var articleMinis = await articleService.GetTopArticlesAsync(-3, 10);
        return articleMinis;
    }
}