using Microsoft.Extensions.DependencyInjection;
using System;
using System.Threading.Tasks;

namespace JMDbContext.DBContext
{
    public class DbContextFactory : IDbContextFactory
    {
        IServiceProvider _serviceProvider;

        public DbContextFactory(IServiceProvider serviceProvider)
        {
            _serviceProvider = serviceProvider;
        }

        public async Task DbContext(Func<JMDbContext, Task> func)
        {
            using (var scope = _serviceProvider.CreateScope())
            {
                using (var context = scope.ServiceProvider.GetRequiredService<JMDbContext>())
                {
                    await func(context);
                }
            }
        }
    }

    public interface IDbContextFactory
    {
        Task DbContext(Func<JMDbContext, Task> func);
    }
}

using System;
using System.Threading;
using Microsoft.AspNetCore.Hosting;
using JMDbContext.DBContext;
using Microsoft.Extensions.Logging;
using Microsoft.EntityFrameworkCore;
using Microsoft.EntityFrameworkCore.Infrastructure;

namespace JM.Metric
{
    public class MetricSQL
    {
        readonly IHostingEnvironment _env;
        readonly IDbContextFactory _context;
        readonly ILogger<MetricSQL> _logger;

        public MetricSQL(IHostingEnvironment env, IDbContextFactory context, ILogger<MetricSQL> logger)
        {
            _env = env;
            _logger = logger;
            _context = context;
            Host = System.Net.Dns.GetHostName();
        }


        private async void GetCount(object o)
        {

            _context.DbContext(async (context) =>
              {
                  try
                  {
                     
                     var conn = context.Database.GetDbConnection();  
                     var cmd = conn.CreateCommand();
                     cmd.CommandText = "select count(distinct s.phone ) from uInfo (nolock) ui inner join [dbo].Starts (nolock) s on ui.guid = s.guid where ui.Start= 1;";
                      conn.Open();
                      var res = (int)cmd.ExecuteScalar();
                            .....
                      return;
                  }
                  catch (Exception ex)
                  {
                      _logger.LogError($"Request: {error.ErrorTrace}. Error: {error.ErrorMessage}");
                  }
              });
        }
    }
}