using System.Collections.Specialized;
using System.Net.Http;
using System.Net.Http.Json;
using Dpz.Core.Public.ViewModel.V4;
using Dpz.Core.Service.V4.Services;
using Dpz.Core.Web.Models;
using ZiggyCreatures.Caching.Fusion;

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

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

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

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

    public async Task<IList<string>> GetArticleTagsAsync()
    {
        return await articleService.GetAllTagsAsync();
    }

    public async Task<IList<VmArticleMini>> GetLatestArticlesAsync()
    {
        return await articleService.GetLatestAsync();
    }

    public async Task<IList<VmArticleMini>> GetRandomArticlesAsync()
    {
        return await articleService.GetRandomArticlesAsync();
    }

    public async Task<TodayNewsModel?> GetTodayNewsAsync()
    {
        var ipAddress = httpContextAccessor.HttpContext?.Request.GetIpAddress() ?? "";
        var todayNewsKey = $"home-news-{ipAddress}";
        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<VmArticleMini>> GetTopArticlesAsync()
    {
        var articleMinis = await articleService.GetTopArticlesAsync(-3);
        return articleMinis;
    }
}