using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Configuration;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Web;
 

namespace WMS.BZSqlSugar
{
    public class SqlSugarHelper
    {
        static List<ConnectionConfig> ConnectionConfigs= new List<ConnectionConfig>();
        static SqlSugarHelper()
        {
            
            var lists= Util.ConfigHelper.GetConnectionConfigs().Connections;
            foreach (var connection in lists)
            {
                ConnectionConfigs.Add(new ConnectionConfig
                {
                    ConnectionString = connection.ConnectionString,
                    DbType = (DbType)connection.DataBaseType,
                    InitKeyType = (InitKeyType)connection.InitKey,
                    IsAutoCloseConnection = connection.IsAutoCloseConn,
                    ConfigId = connection.ConfigId
                });
            }
            //string jsonfile = HttpContext.Current.Server.MapPath($"\\XmlSet\\jsconfig.json");
            //StreamReader file = File.OpenText(jsonfile);
            //JsonTextReader reader = new JsonTextReader(file);
            //var obj = JToken.ReadFrom(reader).ToString();
            //var jo = (JObject)JsonConvert.DeserializeObject(obj);
            //ConnectionConfigs = JsonConvert.DeserializeObject<List<ConnectionConfig>>(((JProperty)jo.First).Value.ToString());
        }
        //用单例模式
        public static SqlSugarScope Db = new SqlSugarScope(ConnectionConfigs,
      db =>
      {
          db.GetConnectionScope("hj").Aop.OnLogExecuting = (sql, pars) =>
          {
              Console.WriteLine(db.GetConnectionScope("hj").Ado.Connection.ConnectionString + "\r\n " + sql);
              Console.WriteLine();
              Console.WriteLine();
          };
          db.GetConnectionScope("usercenter").Aop.OnLogExecuting = (sql, pars) =>
          {
              Console.WriteLine(db.GetConnectionScope("usercenter").Ado.Connection.ConnectionString + "\r\n " + sql);
              Console.WriteLine();
              Console.WriteLine();
          };
          db.GetConnectionScope("pt").Aop.OnLogExecuting = (sql, pars) =>
          {
              Console.WriteLine(db.GetConnectionScope("pt").Ado.Connection.ConnectionString + "\r\n " + sql);
              Console.WriteLine();
              Console.WriteLine();
          };

          db.GetConnectionScope("fj").Aop.OnLogExecuting = (sql, pars) =>
          {
              Console.WriteLine(db.GetConnectionScope("fj").Ado.Connection.ConnectionString + "\r\n " + sql);
              Console.WriteLine();
              Console.WriteLine();
          };
          db.GetConnectionScope("sx").Aop.OnLogExecuting = (sql, pars) =>
          {
              Console.WriteLine(db.GetConnectionScope("sx").Ado.Connection.ConnectionString + "\r\n " + sql);
              Console.WriteLine();
              Console.WriteLine();
          };
          db.GetConnectionScope("cp").Aop.OnLogExecuting = (sql, pars) =>
          {
              Console.WriteLine(db.GetConnectionScope("cp").Ado.Connection.ConnectionString + "\r\n " + sql);
              Console.WriteLine();
              Console.WriteLine();
          };
      });
    }
}