using Furion;
using Furion.DatabaseAccessor;
using Furion.DistributedIDGenerator;
using Furion.Logging;
using Microsoft.AspNetCore.Http;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Logging;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace FlexJobApi.Core
{
    public class DatabaseLoggingWriter : IDatabaseLoggingWriter, IDisposable
    {
        private readonly IServiceScope serviceScope;
        private readonly IRepository<ConsoleLog, LogDbContextLocator> rep;

        public DatabaseLoggingWriter(IServiceScopeFactory scopeFactory)
        {
            serviceScope = scopeFactory.CreateScope();
            rep = serviceScope.ServiceProvider.GetRequiredService<IRepository<ConsoleLog, LogDbContextLocator>>();
        }

        public async Task WriteAsync(LogMessage logMsg, bool flush)
        {
            await rep.InsertNowAsync(new ConsoleLog
            {
                Id = IDGen.NextID(),
                Access = EnumConsoleLogAccess.Back,
                Content = logMsg.Message,
                Level = logMsg.LogLevel == LogLevel.Trace
                    ? EnumLogLevel.Trace
                    : logMsg.LogLevel == LogLevel.Debug
                    ? EnumLogLevel.Debug
                    : logMsg.LogLevel == LogLevel.Information
                    ? EnumLogLevel.Information
                    : logMsg.LogLevel == LogLevel.Warning
                    ? EnumLogLevel.Warning
                    : logMsg.LogLevel == LogLevel.Error
                    ? EnumLogLevel.Error
                    : logMsg.LogLevel == LogLevel.Critical
                    ? EnumLogLevel.Critical
                    : EnumLogLevel.Information,
                ClientIpAddress = App.HttpContext?.GetRemoteIpAddressToIPv4(),
                TraceId = logMsg.TraceId,
                CreatedTime = logMsg.LogDateTime,
                CreatedUserInfoId = JwtUtils.GetCurrentLogier()?.UserInfoId,
            });
        }

        /// <summary>
        /// 释放服务作用域
        /// </summary>
        public void Dispose()
        {
            serviceScope.Dispose();
        }
    }
}