using FreeRedis;
using Microsoft.Extensions.Caching.Distributed;
using Volo.Abp.Caching;
using Volo.Abp.Domain.Services;
using Volo.Abp.Settings;
using Volo.Abp.Threading;
using Yi.Framework.DigitalCollectibles.Domain.Dtos;
using Yi.Framework.DigitalCollectibles.Domain.Entities;
using Yi.Framework.DigitalCollectibles.Domain.Shared.Consts;
using Yi.Framework.DigitalCollectibles.Domain.Shared.Enums;
using Yi.Framework.SettingManagement.Domain;
using Yi.Framework.SqlSugarCore.Abstractions;

namespace Yi.Framework.DigitalCollectibles.Domain.Managers;

/// <summary>
/// 矿池领域服务
/// 处理矿池相关业务，例如挖矿等
/// </summary>
public class MiningPoolManager : DomainService
{
    private readonly ISqlSugarRepository<CollectiblesAggregateRoot> _collectiblesRepository;
    private readonly ISqlSugarRepository<OnHookAggregateRoot> _onHookRepository;
    private readonly ISettingProvider _settingProvider;
    private readonly IDistributedCache<MiningPoolContent?> _miningPoolCache;
    private readonly IDistributedCache<UserMiningLimitCacheDto?> _userMiningLimitCache;
    private readonly ISqlSugarRepository<CollectiblesUserStoreAggregateRoot> _userStoreRepository;
    private IRedisClient RedisClient => LazyServiceProvider.LazyGetRequiredService<IRedisClient>();

    public MiningPoolManager(ISettingProvider settingProvider, IDistributedCache<MiningPoolContent> miningPoolCache,
        ISqlSugarRepository<CollectiblesAggregateRoot> collectiblesRepository,
        ISqlSugarRepository<OnHookAggregateRoot> onHookRepository,
        ISqlSugarRepository<CollectiblesUserStoreAggregateRoot> userStoreRepository,
        IDistributedCache<UserMiningLimitCacheDto> userMiningLimitCache)
    {
        _settingProvider = settingProvider;
        this._miningPoolCache = miningPoolCache;
        _collectiblesRepository = collectiblesRepository;
        _onHookRepository = onHookRepository;
        _userStoreRepository = userStoreRepository;
        _userMiningLimitCache = userMiningLimitCache;
    }

    /// <summary>
    /// 每次挖矿概率，每天根据特定算法计算
    /// </summary>
    private decimal CurrentMiningProbability => AsyncHelper.RunSync(async () =>
    {
        return await ComputeMiningProbabilityAsync();
    });

    public async Task<MiningPoolContent> GetMiningPoolContentAsync()
    {
        var pool = await _miningPoolCache.GetAsync(MiningCacheConst.MiningPoolContent);
        return pool;
    }


    /// <summary>
    /// 校验挖矿限制
    /// </summary>
    /// <param name="userId"></param>
    private async Task VerifyMiningLimitAsync(Guid userId)
    {
        //每天最大次数限制
        var miningMaxLimit = int.Parse(await _settingProvider.GetOrNullAsync("MiningMaxLimit"));
        //每次间隔
        var miningMinIntervalSeconds = int.Parse(await _settingProvider.GetOrNullAsync("MiningMinIntervalSeconds"));

        var currentNumber = 1;

        //根据用户进行上锁
        if (await RedisClient.SetNxAsync($"UserMiningLimitLock:{userId}", true,
                TimeSpan.FromSeconds(miningMinIntervalSeconds)))
        {
            var userLimit = await _userMiningLimitCache.GetAsync($"{MiningCacheConst.UserMiningLimit}:{userId}");

            if (userLimit is not null)
            {
                //符合条件，成功挖矿
                if (userLimit.Number < miningMaxLimit)
                {
                    currentNumber = userLimit.Number + 1;
                }
                else
                {
                    throw new UserFriendlyException($"失败，你已达当轮矿池最大限制，给其他人留点吧");
                }
            }

            //没有缓存过，必定成功，直接走
            await _userMiningLimitCache.SetAsync($"{MiningCacheConst.UserMiningLimit}:{userId}",
                new UserMiningLimitCacheDto
                {
                    Number = currentNumber,
                    LastMiningTime = DateTime.Now,
                },
                new DistributedCacheEntryOptions()
                {
                    //虽然新增的是一天，但是每次刷新是早上10点，矿池刷新时，还需要清除限制
                    AbsoluteExpirationRelativeToNow = TimeSpan.FromDays(1)
                });
        }

        //已上过锁，并且没有到限制时间，必定失败
        //不符合条件，直接走
        throw new UserFriendlyException($"失败，你都挖的冒烟了，请稍后再挖");
    }

    /// <summary>
    /// 用户进行一次挖矿
    /// </summary>
    /// <returns></returns>
    public async Task<MiningPoolResult> MiningAsync(Guid userId)
    {
        //检验限制
        await VerifyMiningLimitAsync(userId);

        var result = new MiningPoolResult();
        //从矿池中开挖,判断矿池是否还有矿
        //根据挖矿概率，进行挖掘
        //挖到了放到用户仓库即可

        //如果概率是挖到了矿，再从矿物中随机选择一个稀有度，再在当前稀有度中的矿物列表，随机选择一个具体的矿物
        var pool = await GetMiningPoolContentAsync();
        if (pool.TotalNumber == 0)
        {
            throw new UserFriendlyException($"失败，矿池已经被掏空了，请等矿池刷新后再来");
        }

        // 生成一个 0 到 1 之间的随机数
        double randomValue = new Random().NextDouble();
        //如果随机的概率在当前概率内，成功
        if (randomValue.To<decimal>() < CurrentMiningProbability)
        {
            //成功后在藏品中根据稀有度概率必定获取一个
            var probabilityArray = RarityEnumExtensions.GetProbabilityArray();
            var index = GetRandomIndex(probabilityArray);
            var rarityType = (RarityEnum)Enum.GetValues(typeof(RarityEnum)).GetValue(index)!;
            var collectiblesList =
                await _collectiblesRepository._DbQueryable.Where(x => x.Rarity == rarityType).ToListAsync();
            int randomIndex = new Random().Next(collectiblesList.Count);
            var currentCollectibles = collectiblesList[randomIndex];

            result.Collectibles = currentCollectibles;

            //使用结果新增给对应的用户
            await _userStoreRepository.InsertAsync(new CollectiblesUserStoreAggregateRoot
            {
                UserId = userId,
                CollectiblesId = result.Collectibles.Id,
                IsRead = false
            });


            return result;
        }

        throw new UserFriendlyException($"恭喜！空空如也，挖了个寂寞");
    }

    /// <summary>
    /// 挂机挖矿
    /// </summary>
    public async Task OnHookMiningAsync()
    {
        //获取当前激活的挂机挖矿
        var currentOnHook = await _onHookRepository._DbQueryable.Where(x => x.IsActive == true)
            .Where(x => x.EndTime <= DateTime.Now).ToListAsync();

        //根据用户对挂机卡hash关系
        var userOnHookDic = currentOnHook.GroupBy(x => x.UserId).ToDictionary(x => x.Key, y => y.First());
        foreach (var onHookItem in userOnHookDic)
        {
            await MiningAsync(onHookItem.Value.UserId);
        }
    }

    private int GetRandomIndex(decimal[] probabilities)
    {
        // 生成0到1之间的随机数
        Random random = new Random();
        decimal randomValue = random.NextDouble().To<decimal>();

        decimal cumulativeProbability = 0.0m;

        for (int i = 0; i < probabilities.Length; i++)
        {
            cumulativeProbability += probabilities[i];

            // 判断随机数是否小于当前的累积概率
            if (randomValue < cumulativeProbability)
            {
                return i; // 返回中标的索引
            }
        }

        //剩余情况都是普通
        return 0;
    }

    /// <summary>
    /// 计算当前挖矿概率
    /// </summary>
    /// <returns></returns>
    public async Task<decimal> ComputeMiningProbabilityAsync()
    {
        //当前的挖矿期望：当天的所有藏品能被刚好挖完

        //保底概率：最大不能高过一个值，百分之10
        //手动挖矿：1天可挖10次，每次至少间隔6秒
        //自动挖矿：1天可以挖24次  每次间隔60分钟（需要使用自动挖矿卡）
        //可影响因素：剩余手动挖矿次数+剩余自动挖矿次数

        //简单模式，1/15
        var miningMaxLimit = decimal.Parse(await _settingProvider.GetOrNullAsync("MiningMinProbability"));
        return miningMaxLimit;
    }

    /// <summary>
    /// 刷新矿池
    /// </summary>
    /// <returns></returns>
    public async Task RefreshMiningPoolAsync()
    {
        //获取当前最大的限制
        var maximumPoolLimit = int.Parse(await _settingProvider.GetOrNullAsync("MaxPoolLimit"));

        DateTime startTime = DateTime.Today.AddHours(10);
        DateTime endTime = startTime.AddDays(1);
        var probabilityValues = RarityEnumExtensions.GetProbabilityArray();
        var result = GenerateDistribution(maximumPoolLimit, probabilityValues);

        //根据配置，将不同比例的矿，塞入矿池,
        //矿池，交给redis
        await _miningPoolCache.SetAsync(MiningCacheConst.MiningPoolContent, new MiningPoolContent(startTime, endTime)
        {
            I0_OrdinaryNumber = result[0],
            I1_SeniorNumber = result[1],
            I2_RareNumber = result[2],
            I3_GemNumber = result[3],
            I4_LegendNumber = result[4]
        }, new DistributedCacheEntryOptions
        {
            AbsoluteExpiration = endTime
        });
    }

    /// <summary>
    /// 刷新用户挖矿限制
    /// </summary>
    public async Task RefreshMiningUserLimitAsync()
    {
        await RedisClient.DelAsync($"{MiningCacheConst.UserMiningLimit}*");
    }

    /// <summary>
    /// 根据概率生成给对应稀有度藏品
    /// </summary>
    /// <param name="totalCount"></param>
    /// <param name="probabilities"></param>
    /// <returns></returns>
    /// <exception cref="ArgumentException"></exception>
    private int[] GenerateDistribution(int totalCount, decimal[] probabilities)
    {
        int[] counts = new int[probabilities.Length];
        decimal totalProbability = 0;

        // 计算概率总和，确保为 1
        foreach (var prob in probabilities)
        {
            totalProbability += prob;
        }

        // 检查概率之和是否为 1
        if (totalProbability < 0.99m || totalProbability > 1.01m)
        {
            throw new ArgumentException("概率总和必须接近1");
        }

        // 生成分布
        for (int i = 0; i < probabilities.Length; i++)
        {
            counts[i] = (int)(totalCount * probabilities[i]);
        }

        // 处理可能因精度问题导致的总数不足
        int sum = 0;
        foreach (var count in counts)
        {
            sum += count;
        }

        int difference = totalCount - sum;

        // 将差值分配给概率最大的一项
        if (difference > 0)
        {
            int maxIndex = Array.IndexOf(counts, Math.Max(counts[0], counts[1]));
            counts[maxIndex] += difference;
        }

        return counts;
    }
}