#region

using System;
using System.Collections.Generic;
using CSFramework.DB;
using CSFrameworkV5.Common;
using CSFrameworkV5.Core;
using CSFrameworkV5.Core.DataSetLib;
using CSFrameworkV5.Models;

#endregion

namespace CSFrameworkV5.DataAccess
{
    /*****************************************************************************

    重要记录：
    1. LoadSystemDatabase(IWriteSQLConfigValue config),根据配置文件加载系统数据库连接
    2. LoadDatabase(string DBIDs)，获取当前用户的账套信息，实例化DataSetConfigList对象。
    3. GetDatabase(string DBID),获取数据库连接对象IDatabase.

    *****************************************************************************/

    /// <summary>
    ///     数据库提供者（DAL层应用）
    /// </summary>
    public static class DatabaseProvider
    {
        private static IDataSetData _DataSetConfigList;

        //账套连接字符串列表
        private static Dictionary<string, string> _ConnectionString =
            new Dictionary<string, string>();

        //活动数据库列表<string:DBID账套编号,IDatabase:数据库实例>
        private static Dictionary<string, IDatabase> _ActivedDBs =
            new Dictionary<string, IDatabase>();

        /// <summary>
        ///     静态构造器
        /// </summary>
        static DatabaseProvider()
        {
        }

        /// <summary>
        ///     账套列表
        /// </summary>
        public static IDataSetData DataSetConfigList
        {
            get => _DataSetConfigList;
            set
            {
                _DataSetConfigList = value;

                //实例化每个账套的数据库对象
                foreach (var item in _DataSetConfigList.DataSets)
                    AddDatabase(item);
            }
        }

        /// <summary>
        ///     是否IP直连模式(LAN,WAN)
        ///     若是WCF连接，此值必须设置为False
        /// </summary>
        public static bool IsAdoDirect { get; set; }

        /// <summary>
        ///     直连模式支持两种IP连接方式，外网IP和局域网IP, true:局域网IP, false:外网IP
        ///     若是WCF连接，此值必须设置为False
        /// </summary>
        public static bool IsLocalConnection { get; set; }

        /// <summary>
        ///     系统数据库
        /// </summary>
        public static IDatabase SystemDatabase { get; private set; }

        /// <summary>
        ///     系统数据库类型
        /// </summary>
        public static DatabaseType SystemDatabaseType { get; set; }

        public static void AddDatabase(DataSetConfigItem item)
        {
            if (item == null) return;

            if (!_ActivedDBs.ContainsKey(item.DataSetID))
            {
                string conn;
                var db = DatabaseFactory.CreateDatabase(item.DatabaseType, "");

                if (IsLocalConnection)
                    conn = db.BuildConnectionString(item.LocalServerIP,
                        item.LocalServerPort, item.DBName,
                        item.DBUserName, item.DBUserPassword);
                else
                    conn = db.BuildConnectionString(item.RemoteServerIP,
                        item.RemoteServerPort, item.DBName,
                        item.DBUserName, item.DBUserPassword);

                db.ConnectionString = conn;

                _ActivedDBs[item.DataSetID] = db; //数据库实例缓存表                  
                _ConnectionString[item.DataSetID] = conn; //连接字符串缓存表     
            }
        }

        /// <summary>
        ///     获取数据库实例
        /// </summary>
        /// <param name="DBID">账套编号</param>
        /// <returns></returns>
        public static IDatabase GetDatabase(string DBID)
        {
            if (string.IsNullOrEmpty(DBID)) return null;

            if (!_ConnectionString.ContainsKey(DBID)) return null;

            if (!_ActivedDBs.ContainsKey(DBID))
            {
                var databaseType =
                    DataSetConfigList.GetConfig(DBID).DatabaseType;
                var db = DatabaseFactory.CreateDatabase(databaseType,
                    _ConnectionString[DBID]); //OK
                _ActivedDBs.Add(DBID, db);
            }

            return _ActivedDBs[DBID];
        }

        /// <summary>
        ///     获取数据库实例
        /// </summary>
        /// <param name="DBName">数据库名称</param>
        /// <returns></returns>
        public static IDatabase GetDatabaseByDbName(string DBName)
        {
            if (DBName == Globals.DEF_SYSTEM_DBName) return SystemDatabase;

            var item = DataSetConfigList.DataSets.Find(
                delegate(DataSetConfigItem p)
                {
                    return p.DBName.ToLower() == DBName.ToLower();
                });
            if (item == null) throw new Exception($"数据库名称：{DBName}没有对应的账套！");

            return GetDatabase(item.DataSetID);
        }

        /// <summary>
        ///     加载账套数据库，(用户登录成功后 --> 则加载当前用户拥有权限的账套)
        /// </summary>
        /// <param name="DBIDs">一个或多个账套编号(多个编号用逗号分开),传空值则加载全部账套</param>
        public static void LoadDatabase(string DBIDs)
        {
            var sp = SystemDatabase.CreateSqlProc("sp_sys_GetDataSet");
            sp.AddParam("DBIDs", DBIDs);
            var dt =
                SystemDatabase.GetTable(sp.Command, tb_DataSet.__TableName);

            //第一次加载数据账套表
            if (DataSetConfigList == null)
            {
                DataSetConfigList = new DataSetData(dt);
            }
            else //添加数据库
            {
                var ds = new DataSetData(dt);
                var dbs = DBIDs.Split(',');
                if (dbs.Length > 0) AddDatabase(ds.GetConfig(dbs[0]));
            }
        }

        /// <summary>
        ///     系统初始化时 --> 加载系统数据库
        /// </summary>
        /// <param name="config"></param>
        public static void LoadSystemDatabase(IWriteSQLConfigValue config)
        {
            //创建系统数据库实例
            SystemDatabaseType = (DatabaseType)Enum.Parse(typeof(DatabaseType),
                config.DatabaseType);
            SystemDatabase = DatabaseFactory.CreateDatabase(SystemDatabaseType,
                config.ConnectionString);

            //添加缓存            
            _ConnectionString[Globals.DEF_SYSTEM_DBID] =
                config.ConnectionString;
            _ActivedDBs[Globals.DEF_SYSTEM_DBID] = SystemDatabase;
        }

        /// <summary>
        ///     系统初始化时 --> 加载系统数据库
        /// </summary>
        /// <param name="connectionString"></param>
        public static void LoadSystemDatabase(DatabaseType databaseType,
            string connectionString)
        {
            //创建系统数据库实例
            SystemDatabaseType = databaseType;
            SystemDatabase =
                DatabaseFactory.CreateDatabase(databaseType, connectionString);

            //添加缓存            
            _ConnectionString[Globals.DEF_SYSTEM_DBID] = connectionString;
            _ActivedDBs[Globals.DEF_SYSTEM_DBID] = SystemDatabase;
        }
    }
}