//using PasteApeart;
//using PasteApeart.Application.Contracts;
//using PasteApeart.Handler;
//using ExampleApeart.Application.Contracts;
//using ExampleApeart.Handler;
//using Serilog;

//namespace ExampleApeart
//{
//    /// <summary>
//    /// 事件模型的扩展
//    /// </summary>
//    public static class AbsEventModelExtensions
//    {

//        ///// <summary>
//        ///// 启动 任务排重标记，修改MutexVal
//        ///// </summary>
//        ///// <param name="info"></param>
//        ///// <param name="appCache"></param>
//        ///// <param name="id"></param>
//        ///// <param name="expireSecond"></param>
//        ///// <returns></returns>
//        //public static async Task ToStartTaskMutexAsync(this AbsEventModel info, IAppCache appCache, object id = null, int expireSecond = 300)
//        //{
//        //    if (string.IsNullOrEmpty(info.MutexKey))
//        //    {
//        //        info.MutexKey = $"mutex:{info.GetType().Name}:{(id?.ToString() ?? "0")}";
//        //    }
//        //    else
//        //    {
//        //        info.MutexKey = info.MutexKey.Replace(":id", $":{(id?.ToString() ?? "0")}");
//        //    }
//        //    info.MutexVal = Guid.NewGuid().ToString("N");
//        //    await appCache.SetAsync(info.MutexKey, info.MutexVal, expireSecond);
//        //}

//        ///// <summary>
//        ///// 判断是否有同样的任务，如果有则返回false表示不能启动
//        ///// </summary>
//        ///// <param name="info"></param>
//        ///// <param name="appCache"></param>
//        ///// <param name="id"></param>
//        ///// <param name="expireSecond"></param>
//        ///// <returns>是否可以启动 false表示正在执行中</returns>
//        //public static async Task<bool> ToAutoStartTaskMutexAsync(this AbsEventModel info, IAppCache appCache, object id = null, int expireSecond = 300)
//        //{
//        //    if (string.IsNullOrEmpty(info.MutexKey))
//        //    {
//        //        info.MutexKey = $"mutex:{info.GetType().Name}:{(id?.ToString() ?? "0")}";
//        //    }
//        //    else
//        //    {
//        //        info.MutexKey = info.MutexKey.Replace(":id", $":{(id?.ToString() ?? "0")}");
//        //    }
//        //    if (!await appCache.ExistsAsync(info.MutexKey))
//        //    {
//        //        info.MutexVal = Guid.NewGuid().ToString("N");
//        //        await appCache.SetAsync(info.MutexKey, info.MutexVal, expireSecond);
//        //        return true;
//        //    }
//        //    else
//        //    {
//        //        return false;
//        //    }
//        //}

//        ///// <summary>
//        ///// 检查任务是否被重置 返回true表示可以执行 返回false表示不能执行
//        ///// </summary>
//        ///// <param name="info"></param>
//        ///// <param name="appCache"></param>
//        ///// <returns>true:可以执行，匹配 false:任务被重置，不能执行</returns>
//        //public static async Task<bool> ToMatchTaskMutexAsync(this AbsEventModel info, IAppCache appCache)
//        //{
//        //    if (!string.IsNullOrEmpty(info.MutexKey))
//        //    {
//        //        var readVal = await appCache.GetAsync(info.MutexKey);
//        //        if (string.IsNullOrEmpty(readVal))
//        //        {
//        //            return true;
//        //        }
//        //        if (readVal != info.MutexVal)
//        //        {
//        //            Log.Logger.Warning($"任务互斥 Model:{info.GetType().Name} Key:{info.MutexKey} Val:{info.MutexVal} != Read:{readVal}");
//        //            return false;
//        //        }
//        //    }
//        //    return true;
//        //}

//        ///// <summary>
//        ///// 删除标记
//        ///// </summary>
//        ///// <param name="info"></param>
//        ///// <param name="appCache"></param>
//        ///// <returns></returns>
//        //public static async Task ToCleanTaskMutexAsync(this AbsEventModel info, IAppCache appCache)
//        //{
//        //    if (!string.IsNullOrEmpty(info.MutexKey))
//        //    {
//        //        await appCache.DeleteAsync(info.MutexKey);
//        //    }
//        //}

//        ///// <summary>
//        ///// 任务是否标记 注意要使用这个的时候，任务结束的时候需要调用 ToCleanTaskMutexAsync
//        ///// 需要之前有对MutexKey进行赋值 也就是ToAutoStartTaskMutexAsync/ToStartTaskMutexAsync
//        ///// </summary>
//        ///// <param name="info"></param>
//        ///// <param name="appCache"></param>
//        ///// <returns>true 任务在进行 false:没有任务 或者任务已经结束</returns>
//        //public static async Task<bool> ToExistsTaskMutexAsync(this AbsEventModel info, IAppCache appCache)
//        //{
//        //    if (!string.IsNullOrEmpty(info.MutexKey))
//        //    {
//        //        return await appCache.ExistsAsync(info.MutexKey);
//        //    }
//        //    return false;
//        //}

//        ///// <summary>
//        ///// 设置下一次执行时间 并压入到队列
//        ///// </summary>
//        ///// <param name="input"></param>
//        ///// <returns></returns>
//        //public static async Task<bool> ToAutoExpireAndSendAsync(this AbsEventModel input, ChannelHelper _channelHelper)
//        //{
//        //    input.RetryTime++;
//        //    if (input.MaxRetryTime <= 0)
//        //    {
//        //        return false;
//        //    }
//        //    if (input.RetryTime > input.MaxRetryTime)
//        //    {
//        //        return false;
//        //    }
//        //    //计算下一次时间 默认基于5秒的倍率延迟
//        //    var baseRate = 5;
//        //    if (!string.IsNullOrEmpty(input.RetryModel))
//        //    {
//        //        //基于业务自定义模型
//        //    }
//        //    input.ExpireSecond = baseRate * input.RetryTime;
//        //    //可以设定最大时间等
//        //    await _channelHelper.WriteAutoQueueAsync(input);
//        //    return true;
//        //}



//    }
//}