using log4net;
using Microsoft.AspNetCore.SignalR;
using Quartz;
using Quartz.Impl;
using Quartz.Impl.Triggers;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Net.Http;
using System.Threading.Tasks;
using VueWebCoreApi.Extensions;
using VueWebCoreApi.SignalR;
using VueWebCoreApi.Tools;
using static VueWebCoreApi.Quartz.HttpManager;

namespace VueWebCoreApi.Quartz
{
    /// <summary>
    /// 定时任务执行类：Quartz到时间后，自动运行这个类的Execute方法
    /// 作用：发送HTTP请求、记录任务日志、推送执行结果
    /// </summary>
    public class HttpResultfulJob : IJob
    {
        // 日志记录工具（log4net）
        private readonly ILog _log = LogManager.GetLogger(Startup.repository.Name, typeof(ChatHub));
        // SignalR 实时推送工具（给前端推送消息）
        private readonly IHubContext<ChatHub, IChatClient> _hubContext;
        // HttpClient 工厂：用于发送 HTTP 请求
        private readonly IHttpClientFactory _httpClientFactory;
        // 数据库仓储：用于记录任务运行日志、更新最后执行时间
        private readonly QuartzRepository _quartzRepo;

        /// <summary>
        /// 构造函数：依赖注入（自动赋值所有需要的服务）
        /// </summary>
        public HttpResultfulJob(IServiceProvider serviceProvider,
                                IHttpClientFactory httpClientFactory,
                                IHubContext<ChatHub, IChatClient> hubContext,
                                QuartzRepository quartzRepo)
        {
            _httpClientFactory = httpClientFactory;
            _hubContext = hubContext;
            _quartzRepo = quartzRepo;
        }

        /// <summary>
        /// 【核心方法】
        /// Quartz 调度器根据 Cron 表达式，到时间后**自动调用**这个方法
        /// 作用：执行具体的任务逻辑（发送HTTP请求）
        /// </summary>
        public async Task Execute(IJobExecutionContext context)
        {
            // 记录任务开始执行时间
            var beginTime = DateTime.Now;
            // 从 Quartz 上下文获取当前要执行的任务配置（名称、分组、URL、Cron等）
            var taskOptions = context.GetTaskOptions();
            // 存储 HTTP 请求返回的结果信息
            string httpMessage = string.Empty;
            HttpResult result = new HttpResult();

            // ==========================================
            // 第一步：校验任务是否存在
            // ==========================================
            if (taskOptions == null)
            {
                // 如果任务为空，记录错误日志到数据库
                var trigger = context.Trigger;
                await _quartzRepo.AddJobRunLogAsync(trigger.Key.Name, trigger.Key.Group, beginTime, DateTime.Now, "未找到作业或可能被移除", taskOptions.MessagePush, taskOptions.PushUserCode);
                return;
            }
            // 系统日志输出：任务开始执行
            _log.Info($"作业[{taskOptions.TaskName}]开始:{beginTime:yyyy-MM-dd HH:mm:ss}");

            // ==========================================
            // 第二步：校验任务是否配置了请求地址
            // ==========================================
            if (string.IsNullOrEmpty(taskOptions.ApiUrl) || taskOptions.ApiUrl == "/")
            {
                // 未配置API地址，记录日志
                await _quartzRepo.AddJobRunLogAsync(taskOptions.TaskName, taskOptions.GroupName, beginTime, DateTime.Now, "未配置URL", taskOptions.MessagePush, taskOptions.PushUserCode);
                return;
            }
            // ==========================================
            // 第三步：发送 HTTP 请求（核心业务）
            // ==========================================
            try
            {
                // 存储请求头（身份验证信息）
                var headers = new Dictionary<string, string>();
                // 如果配置了 AuthKey 和 AuthValue，添加到请求头
                if (!string.IsNullOrEmpty(taskOptions.AuthKey) && !string.IsNullOrEmpty(taskOptions.AuthValue))
                {
                    headers.Add(taskOptions.AuthKey.Trim(), taskOptions.AuthValue.Trim());
                }
                // 判断请求方式：GET 或 POST（默认POST）
                var method = taskOptions.RequestType?.ToLower() == "get" ? HttpMethod.Get : HttpMethod.Post;
                // 调用工具类，发送 HTTP 请求，并获取返回结果
                result = await _httpClientFactory.HttpSendAsync(method, taskOptions.ApiUrl, taskOptions.RequestParameters, headers);
            }
            catch (Exception ex)
            {
                // 如果请求异常（网络错误、接口报错），记录异常信息
                result.ErrorMsg = ex.Message;
                _log.Error($"作业[{taskOptions.TaskName}]执行异常:{ex.Message}", ex);
            }

            try
            {
                // 1. 把本次执行记录写入 SQL Server 数据库（任务运行日志表）
                await _quartzRepo.AddJobRunLogAsync(taskOptions.TaskName, taskOptions.GroupName, beginTime, DateTime.Now,result.StatusCode==200?result.Content.ToString():result.ErrorMsg, taskOptions.MessagePush, taskOptions.PushUserCode);
                // 2. 更新任务表中的【最后执行时间】
                await _quartzRepo.UpdateTaskLastRunTimeAsync(taskOptions.TaskName, taskOptions.GroupName, beginTime);

                // ==========================================
                // 以下是 SignalR 实时推送（给前端页面发消息）
                // ==========================================
                //判断请求是否成功
                if (result.IsSuccess)
                {
                    //写入任务子表
                }
                if (taskOptions.MessagePush == "N"||taskOptions.PushUserCode==null) //是否需要推送
                {
                    _log.Info($"作业[{taskOptions.TaskName}]无需要推送的用户，跳过SignalR推送");
                    return;
                }
                //步骤2：提取用户编码（去重 + 空值过滤）
                var departmentIDs = taskOptions.PushUserCode.Split(',').ToList();

                if (departmentIDs.Count == 0)
                {
                    _log.Info($"作业[{taskOptions.TaskName}]查询到的用户编码为空，跳过SignalR推送");
                    return;
                }
                // 步骤3：获取在线用户的连接ID（使用线程安全方法）
                var targetConnIds = UserIdsStore.GetConnectionIdsByUserCodes(departmentIDs);
                if (targetConnIds.Count == 0)
                {
                    _log.Info($"作业[{taskOptions.TaskName}]目标用户均不在线，跳过SignalR推送");
                    return;
                }
                // 步骤4：构造推送消息（标准化格式）
                var logContent = $"【{taskOptions.TaskName}】执行结果：{beginTime:yyyy-MM-dd HH:mm:ss} 至 {DateTime.Now:yyyy-MM-dd HH:mm:ss} | 结果：{(string.IsNullOrEmpty(httpMessage) ? "执行成功" : httpMessage)}";
                // 步骤5：批量推送（增加超时+异常捕获）
                _log.Info($"作业[{taskOptions.TaskName}]开始向[{targetConnIds.Count}]个在线连接推送消息：{logContent}");
                // 设置推送超时时间（避免长时间阻塞）
                var pushTask = _hubContext.Clients.Clients(targetConnIds).SendCustomUserMessage(logContent);
                if (await Task.WhenAny(pushTask, Task.Delay(5000)) == pushTask)
                {
                    await pushTask; // 推送成功
                    _log.Info($"作业[{taskOptions.TaskName}]SignalR推送完成，目标连接数：{targetConnIds.Count}");
                }
                else
                {
                    _log.Warn($"作业[{taskOptions.TaskName}]SignalR推送超时（5秒），目标连接数：{targetConnIds.Count}");
                }
            }
            catch (Exception ex)
            {
                // 记录日志写入或推送失败的异常
                _log.Error($"作业[{taskOptions.TaskName}]日志写入/SignalR推送异常:{ex.Message}", ex);
            }
            // 系统日志输出：任务执行结束
            _log.Info($"作业[{taskOptions.TaskName}]结束:{DateTime.Now:yyyy-MM-dd HH:mm:ss} 结果:{result.ErrorMsg}");
        }
    }
}