using FlexJobApi.Core.Entities.Common;
using Furion;
using Furion.DatabaseAccessor;
using Furion.DistributedIDGenerator;
using Furion.Schedule;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.AspNetCore.Mvc.Controllers;
using Microsoft.AspNetCore.Mvc.Filters;
using Microsoft.Extensions.DependencyInjection;
using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.IO;
using System.Linq;
using System.Security.Claims;
using System.Text;
using System.Threading.Tasks;

namespace FlexJobApi.Core
{
    public class ResourceActionFilter : IAsyncActionFilter
    {
        public async Task OnActionExecutionAsync(ActionExecutingContext context, ActionExecutionDelegate next)
        {
            var stopwatch = Stopwatch.StartNew();

            StringWriter consoleWriter = new();
            TextWriter originalConsoleOut = Console.Out;

            try
            {
                Console.SetOut(consoleWriter);

                var serviceScopeFactory = App.GetService<IServiceScopeFactory>();
                var serviceScope = serviceScopeFactory.CreateScope();
                var rep = serviceScope.ServiceProvider.GetRequiredService<IRepository<ResourceLog, LogDbContextLocator>>();
                var logier = JwtUtils.GetCurrentLogier();

                var resourceLog = new ResourceLog();
                resourceLog.CreatedTime = DateTimeOffset.Now;
                resourceLog.Id = IDGen.NextID();
                resourceLog.TraceId = App.GetTraceId();
                resourceLog.Method = EnumUtils.GetEnum<EnumResourceMethod>(context.HttpContext.Request.Method);
                resourceLog.Domain = $"{context.HttpContext.Request.Scheme}://{context.HttpContext.Request.Host}";
                resourceLog.Path = context.HttpContext.Request.Path;
                resourceLog.ClientIpAddress = context.HttpContext.GetRemoteIpAddressToIPv4();
                resourceLog.CreatedUserId = logier?.Id;
                resourceLog.CreatedEnterpriseId = logier?.EnterpriseId;
                resourceLog.Request = context.ActionArguments?.ToJson();
                resourceLog.RequestHeaders = context.HttpContext.Request.Headers.ToJson();

                Console.SetOut(originalConsoleOut);
                await rep.InsertNowAsync(resourceLog);
                Console.SetOut(consoleWriter);

                //============== 这里是执行方法之后获取数据 ====================
                var actionContext = await next();
                Console.SetOut(originalConsoleOut);

                resourceLog.UpdatedTime = DateTimeOffset.Now;
                if (actionContext.Result is JsonResult jsonResult)
                {
                    resourceLog.Response = jsonResult.Value.ToJson();
                }
                resourceLog.ResponseHeaders = context.HttpContext.Response.Headers.ToJson();
                resourceLog.IsSuccess = actionContext.Exception == null;
                resourceLog.ConsoleLogs = consoleWriter.ToString();

                stopwatch.Stop();
                resourceLog.ElapsedMilliseconds = stopwatch.ElapsedMilliseconds;

                await rep.UpdateNowAsync(resourceLog);
            }
            finally
            {
                Console.SetOut(originalConsoleOut); // 恢复 Console 原始输出流
                consoleWriter.Dispose(); // 释放流资源
            }
        }
    }
}