using System;
using System.Text.Json;
using KH.WMS.Core.DependencyInjection.ServiceLifetimes;
using KH.WMS.Core.Logging.LogEnums;
using Microsoft.AspNetCore.Http;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Logging;
using SerilogLogContext = Serilog.Context.LogContext;

namespace KH.WMS.Core.Logging.Serilog;

/// <summary>
/// 日志服务实现（自动识别模块）
/// </summary>
[RegisteredService(Lifetime = ServiceLifetime.Scoped)]
public class LoggerService : ILoggerService
{
    private readonly ILogger<LoggerService> _logger;
    private readonly IHttpContextAccessor? _httpContextAccessor;

    public LoggerService(ILogger<LoggerService> logger, IHttpContextAccessor? httpContextAccessor = null)
    {
        _logger = logger;
        _httpContextAccessor = httpContextAccessor;
    }

    public void LogVerbose(string message, params object?[] args)
    {
        var module = LogModuleDetector.DetectModule();
        WriteLog(LogLevel.Trace, message, module, null, args);
    }

    public void LogDebug(string message, params object?[] args)
    {
        var module = LogModuleDetector.DetectModule();
        WriteLog(LogLevel.Debug, message, module, null, args);
    }

    public void LogInfo(string message, params object?[] args)
    {
        var module = LogModuleDetector.DetectModule();
        WriteLog(LogLevel.Information, message, module, null, args);
    }

    public void LogWarning(string message, params object?[] args)
    {
        var module = LogModuleDetector.DetectModule();
        WriteLog(LogLevel.Warning, message, module, null, args);
    }

    public void LogError(string message, params object?[] args)
    {
        var module = LogModuleDetector.DetectModule();
        WriteLog(LogLevel.Error, message, module, null, args);
    }

    public void LogError(Exception exception, string message, params object?[] args)
    {
        var module = LogModuleDetector.DetectModule();
        var context = CreateLogContext(LogLevel.Error, module);
        context.Type = LogType.Exception;

        using (PushFileName(null))
        {
            if (args != null && args.Length > 0)
            {
                var messageTemplate = $"[{GetModuleCode(module)}] {message}";
                _logger.LogError(exception, messageTemplate, args);
            }
            else
            {
                _logger.LogError(exception, "[{ModuleCode}] {Message}", GetModuleCode(module), message);
            }
        }
    }

    public void LogFatal(string message, params object?[] args)
    {
        var module = LogModuleDetector.DetectModule();
        WriteLog(LogLevel.Critical, message, module, null, args);
    }

    public void LogFatal(Exception exception, string message, params object?[] args)
    {
        var module = LogModuleDetector.DetectModule();
        var context = CreateLogContext(LogLevel.Critical, module);
        context.Type = LogType.Exception;

        using (PushFileName(null))
        {
            if (args != null && args.Length > 0)
            {
                var messageTemplate = $"[{GetModuleCode(module)}] {message}";
                _logger.LogCritical(exception, messageTemplate, args);
            }
            else
            {
                _logger.LogCritical(exception, "[{ModuleCode}] {Message}", GetModuleCode(module), message);
            }
        }
    }

    public void LogOperation(string operation, string? userName = null, long? userId = null, object? data = null)
    {
        var module = LogModuleDetector.DetectModule();
        var context = CreateLogContext(LogLevel.Information, module);
        context.Type = LogType.Operation;
        context.Operation = operation;
        context.UserName = userName ?? context.UserName;
        context.UserId = userId ?? context.UserId;

        var dataJson = data != null ? JsonSerializer.Serialize(data) : null;

        using (PushFileName(null))
        {
            _logger.LogInformation("[{ModuleCode}] [OPERATION] {Operation} by {UserName} (UserId:{UserId}) {Data}",
                GetModuleCode(module), operation, context.UserName, context.UserId, dataJson ?? "");
        }
    }

    public void LogBusiness(string businessType, string message, object? data = null)
    {
        var module = LogModuleDetector.DetectModule();
        var context = CreateLogContext(LogLevel.Information, module);
        context.Type = LogType.Business;
        context.Operation = businessType;

        var dataJson = data != null ? JsonSerializer.Serialize(data) : null;

        using (PushFileName(null))
        {
            _logger.LogInformation("[{ModuleCode}] [BUSINESS:{Type}] {Message} {Data}",
                GetModuleCode(module), businessType, message, dataJson ?? "");
        }
    }

    public void LogPerformance(string operation, long elapsedMs, object? data = null)
    {
        var module = LogModuleDetector.DetectModule();
        var context = CreateLogContext(LogLevel.Information, module);
        context.Type = LogType.Performance;
        context.Operation = operation;
        context.Data["ElapsedMs"] = elapsedMs;
        context.Data["ElapsedSeconds"] = elapsedMs / 1000.0;

        if (elapsedMs > 3000)
        {
            context.Level = LogLevelType.Warning;
        }

        var dataJson = data != null ? JsonSerializer.Serialize(data) : null;
        var logLevel = elapsedMs > 3000 ? LogLevel.Warning : LogLevel.Information;

        using (PushFileName(null))
        {
            _logger.Log(logLevel, "[{ModuleCode}] [PERFORMANCE] {Operation} 耗时 {Elapsed}ms {Data}",
                GetModuleCode(module), operation, elapsedMs, dataJson ?? "");
        }
    }

    public void Log(LogContext context, string message, params object?[] args)
    {
        var logLevel = ConvertLogLevel(context.Level);
        var messageFormat = $"[{GetModuleCode(context.Module)}] [LogType:{context.Type}] {message}";

        var state = new Dictionary<string, object?>
        {
            ["UserId"] = context.UserId,
            ["UserName"] = context.UserName,
            ["TenantId"] = context.TenantId,
            ["RequestId"] = context.RequestId,
            ["Operation"] = context.Operation
        };

        using (_logger.BeginScope(state))
        {
            _logger.Log(logLevel, messageFormat, args);
        }
    }

    // ==================== 私有方法 ====================

    private void WriteLog(LogLevel level, string message, LogModule module, string? fileName, object?[] args)
    {
        using (PushFileName(fileName))
        {
            if (args != null && args.Length > 0)
            {
                var messageTemplate = $"[{GetModuleCode(module)}] {message}";
                _logger.Log(level, messageTemplate, args);
            }
            else
            {
                _logger.Log(level, $"[{GetModuleCode(module)}] {message}");
            }
        }
    }

    private IDisposable? PushFileName(string? fileName)
    {
        if (string.IsNullOrEmpty(fileName))
        {
            return null;
        }

        return SerilogLogContext.PushProperty("FileName", fileName);
    }

    private LogContext CreateLogContext(LogLevel level, LogModule module)
    {
        var context = new LogContext
        {
            Level = ConvertToLogLevelType(level),
            Module = module
        };

        if (_httpContextAccessor?.HttpContext != null)
        {
            var httpContext = _httpContextAccessor.HttpContext;
            var user = httpContext.User;

            var userIdClaim = user?.FindFirst(System.Security.Claims.ClaimTypes.NameIdentifier)?.Value;
            if (long.TryParse(userIdClaim, out var userId))
            {
                context.UserId = userId;
            }

            context.UserName = user?.FindFirst(System.Security.Claims.ClaimTypes.Name)?.Value;

            var tenantIdClaim = user?.FindFirst("TenantId")?.Value;
            if (long.TryParse(tenantIdClaim, out var tenantId))
            {
                context.TenantId = tenantId;
            }

            context.RequestId = httpContext.TraceIdentifier;
            context.CorrelationId = httpContext.Request.Headers["X-Correlation-ID"].FirstOrDefault();
            context.ClientIp = httpContext.Connection.RemoteIpAddress?.ToString();
        }

        return context;
    }

    private LogLevel ConvertLogLevel(LogLevelType level)
    {
        return level switch
        {
            LogLevelType.Verbose => LogLevel.Trace,
            LogLevelType.Debug => LogLevel.Debug,
            LogLevelType.Information => LogLevel.Information,
            LogLevelType.Warning => LogLevel.Warning,
            LogLevelType.Error => LogLevel.Error,
            LogLevelType.Fatal => LogLevel.Critical,
            LogLevelType.None => LogLevel.None,
            _ => LogLevel.Information
        };
    }

    private LogLevelType ConvertToLogLevelType(LogLevel level)
    {
        return level switch
        {
            Microsoft.Extensions.Logging.LogLevel.Trace => LogLevelType.Verbose,
            Microsoft.Extensions.Logging.LogLevel.Debug => LogLevelType.Debug,
            Microsoft.Extensions.Logging.LogLevel.Information => LogLevelType.Information,
            Microsoft.Extensions.Logging.LogLevel.Warning => LogLevelType.Warning,
            Microsoft.Extensions.Logging.LogLevel.Error => LogLevelType.Error,
            Microsoft.Extensions.Logging.LogLevel.Critical => LogLevelType.Fatal,
            Microsoft.Extensions.Logging.LogLevel.None => LogLevelType.None,
            _ => LogLevelType.Information
        };
    }

    private string GetModuleCode(LogModule module)
    {
        return ((int)module).ToString() + " " + module;
    }

    private string GetModuleName(LogModule module)
    {
        return module.ToString();
    }
}