#region

using System;
using System.Data;
using System.Text;
using CSFramework.DB;
using CSFrameworkV5.Common;
using CSFrameworkV5.Core;
using CSFrameworkV5.Core.CodeGenerator;
using CSFrameworkV5.Interfaces;
using CSFrameworkV5.Models;

#endregion

/*===================================================================
 *   程序说明: FieldNameDefs的数据访问层源码
 *   作者资料: 楚楚.C/S框架网
 *   创建日期: 2014/05/23 08:57:01
 *   最后修改: 2014/05/23 08:57:01
 *
 *   注: 本代码由代码生成器(Code Generator)自动生成
 *   版权所有 copyright 2006~2014, C/S框架网 http://www.csframework.com
 *===================================================================*/

namespace CSFrameworkV5.DataAccess
{
    /// <summary>
    ///     DAL数据层:dalFieldNameDefs
    /// </summary>
    [DefaultORM_UpdateMode(typeof(sys_FieldNameDefs), true)]
    public class dalFieldNameDefs : dalBaseDataDict, IBridge_FieldNameDefs
    {
        /// <summary>
        ///     构造器
        /// </summary>
        /// <param name="loginer">当前登录用户</param>
        public dalFieldNameDefs(Loginer loginer)
            : base(loginer)
        {
            _KeyName = sys_FieldNameDefs.__KeyName; //主键字段
            _TableName = sys_FieldNameDefs.__TableName; //表名
            _ModelType = typeof(sys_FieldNameDefs); //指定ORM模型
            _Database = DatabaseProvider.SystemDatabase;
        }

        public string GetCaption(string dbName, string fieldName)
        {
            var sql =
                "SELECT DISTINCT DisplayName FROM sys_FieldNameDefs WHERE DBName=@DBName AND FieldName=@FieldName AND FieldName<>DisplayName AND ISNULL(DisplayName,'')<>''";
            var sp = _Database.CreateCommand(sql);
            sp.AddParam("DBName", DbType.String, dbName);
            sp.AddParam("FieldName", DbType.String, fieldName);
            return DatabaseProvider.SystemDatabase.ExecuteScalar(sp.Command)
                .ToStringEx();
        }

        /// <summary>
        ///     获取账套数据库名称列表
        /// </summary>
        /// <returns></returns>
        public DataTable GetDataBaseList()
        {
            return DatabaseProvider.SystemDatabase.GetTable(
                "sp_sys_GetDataSetDBs", "DBs");
        }

        /// <summary>
        ///     获取字段列表
        /// </summary>
        /// <param name="databaseName"></param>
        /// <param name="tableName"></param>
        /// <returns></returns>
        public DataTable GetFields(string databaseName, string tableName)
        {
            var sql =
                $"SELECT * FROM sys_FieldNameDefs WHERE DBName={_Database.ParamSymboName}DBName AND TableName={_Database.ParamSymboName}TableName ORDER BY FieldOrder;";
            var cmd = _Database.CreateCommand(sql);
            cmd.AddParam("DBName", databaseName);
            cmd.AddParam("TableName", tableName);
            return _Database.GetTable(sql, sys_FieldNameDefs.__TableName);
        }

        /// <summary>
        ///     获取数据日志字段配置(sys_LogFields表)的数据，关联查询sys_FieldNameDefs的DisplayName字段
        /// </summary>
        /// <param name="DatasetDB"></param>
        /// <param name="DBName"></param>
        /// <param name="tableName"></param>
        /// <returns></returns>
        public DataTable GetTableFields(string DatasetDB, string DBName,
            string tableName)
        {
            var sp =
                _Database.CreateSqlProc(
                    "sp_sys_GetTableFieldsByDBName"); //sp在系统数据库            
            sp.AddParam("SystemDBName", DbType.String,
                Globals.DEF_SYSTEM_DBName);
            sp.AddParam("BusinessDBName", DbType.String, DatasetDB);
            sp.AddParam("DBName", DbType.String, DBName);
            sp.AddParam("TableName", DbType.String, tableName);
            var ds =
                DatabaseProvider.SystemDatabase.GetDataSet(sp.Command); //系统数据库
            ds.Tables[0].TableName = sys_LogFields.__TableName;
            return ds.Tables[0];
        }

        /// <summary>
        ///     获取账套数据库的表名
        /// </summary>
        /// <param name="DBName">账套数据库名</param>
        /// <returns></returns>
        public DataTable GetTableNames(string DBName)
        {
            DataTable dtTmp;

            //特殊处理！！！SQL数据库仅能查当前数据库的表名称
            if (DatabaseProvider.SystemDatabaseType == DatabaseType.SqlServer)
            {
                var db = DatabaseProvider.GetDatabaseByDbName(DBName);
                dtTmp = db.meta_GetTableNames();
            }
            else
            {
                dtTmp = _Database.meta_GetTableNames(DBName);
            }

            var tmp = new DataTable();
            tmp.Columns.Add("TableName", typeof(string));
            foreach (DataRow R in dtTmp.Rows) tmp.Rows.Add(R["name"]);

            tmp.AcceptChanges();

            return tmp;
        }

        public DataTable Search(string TableName, string FieldName,
            string DisplayName)
        {
            var cmd = _Database.CreateCommand("");

            var sb = new StringBuilder();
            sb.Append("SELECT * FROM sys_FieldNameDefs WHERE 1=1 ");

            if (string.IsNullOrEmpty(TableName) == false)
            {
                sb.Append(
                    $" AND TableName ={_Database.ParamSymboName}TableName");
                cmd.AddParam("TableName", TableName);
            }

            if (string.IsNullOrEmpty(FieldName) == false)
            {
                sb.Append(
                    $" AND FieldName ={_Database.ParamSymboName}FieldName");
                cmd.AddParam("FieldName", FieldName);
            }

            if (string.IsNullOrEmpty(DisplayName) == false)
            {
                sb.Append(
                    $" AND DisplayName LIKE {_Database.ParamSymboName}DisplayName");
                cmd.AddParam("DisplayName", "%" + DisplayName + "%");
            }

            sb.Append(" ORDER BY " + sys_FieldNameDefs.__KeyName);
            sb.Append(";");

            cmd.Command.CommandText =
                CodeSafeHelper.GetSafeSQL(sb.ToStringEx());
            return _Database.GetTable(cmd.Command,
                sys_FieldNameDefs.__TableName);
        }

        /// <summary>
        ///     同步表结构到系统数据库的sys_FieldNameDefs表
        /// </summary>
        /// <param name="tableName"></param>
        /// <returns></returns>
        public DataTable SyncTable(string DBName, string tableName)
        {
            var db = DatabaseProvider.GetDatabaseByDbName(DBName);

            var sp = db.CreateSqlProc("sp_sys_SyncTableFieldDef");
            sp.AddParam("DBName", DbType.String, DBName);
            sp.AddParam("TableName", DbType.String, tableName);

            return db.GetTable(sp.Command, sys_FieldNameDefs.__TableName);
        }

        /// <summary>
        ///     根据表名获取该表的SQL命令生成器
        /// </summary>
        /// <param name="tableName">表名</param>
        /// <returns></returns>
        protected override IGenerateSqlCommand CreateSqlGenerator(
            DataTable table)
        {
            Type ORM = null;
            if (table.TableName == sys_FieldNameDefs.__TableName)
                ORM = typeof(sys_FieldNameDefs); //指定表与ORM模型的对应关系

            if (ORM == null) throw new Exception(table.TableName + "表没有ORM模型！");

            return new GenerateSqlCmdByTableFields(ORM, table,
                GeneratorFactory);
        }
    } //public class
} //namespace