namespace IStation.DAL.SQLite
{
    /// <summary>
    /// 
    /// </summary>
    public partial class AnalysisCombine : Yw.DAL.SQLite.BaseDAL<Entity.AnalysisCombine>, IAnalysisCombine
    {
        /// <summary>
        /// 
        /// </summary>
        public override ConnectionConfig ConnectionConfig
        {
            get { return ConfigHelper.AnalysisConnectionConfig; }
        }

        /// <summary>
        /// 
        /// </summary>
        private string TableNamePrefix
        {
            get { return "AnalysisCombine_Cb_"; }
        }

        /// <summary>
        /// 
        /// </summary>
        /// <param name="runFlag"></param>
        /// <returns></returns>
        private string GetTableName(string runFlag)
        {
            return $"{this.TableNamePrefix}{runFlag}";
        }

        /// <summary>
        /// 
        /// </summary>
        /// <param name="tableName"></param>
        /// <returns></returns>
        private string GetCreateTableSql(string tableName)
        {
            var sql = $"CREATE TABLE {tableName}  (\r\n  ID    BIGINT  NOT NULL\r\n    PRIMARY KEY,\r\n    Pump     REAL  NOT NULL,\r\n    CurveQH   VARCHAR (255) NOT NULL,\r\n    CurveQP   VARCHAR (255) NOT NULL,\r\n    MaxFlow   REAL    NOT NULL,\r\n    MinFlow   REAL   NOT NULL,\r\n    MaxHead   REAL  NOT NULL,\r\n    MinHead   REAL NOT NULL,\r\n  AnaStatus BIT NOT NULL\r\n);\r\n";
            return sql;
        }

        /// <summary>
        /// 
        /// </summary>
        /// <param name="tableName"></param>
        /// <returns></returns>
        private string GetExistTableSql(string tableName)
        {
            return ConfigHelper.GetExistTableSql(tableName);
        }

        /// <summary>
        /// 
        /// </summary>
        /// <param name="tableName"></param>
        /// <returns></returns>
        public string GetRunFlag(string tableName)
        {
            return tableName.Replace(this.TableNamePrefix, null);
        }

        /// <summary>
        /// 获取全部表名
        /// </summary>
        public List<string> GetAllTableName()
        {
            using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
            {
                var list = new List<string>();
                var sql = $"select name from sqlite_master where type='table' and name like '%{this.TableNamePrefix}%';";
                using (var reader = db.Ado.GetDataReader(sql))
                {
                    while (reader.Read())
                    {
                        var tableName = reader["name"].ToString();
                        // tableName = tableName.Replace(this.TableNamePrefix, null);
                        list.Add(tableName);
                    }
                }
                return list;
            }
        }

        /// <summary>
        /// 获取全部表
        /// </summary> 
        public Dictionary<string, List<Entity.AnalysisCombine>> GetAllTable()
        {
            using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
            {
                var tableNames = new List<string>();
                var sql_sel_table = $"select name from sqlite_master where type='table' and name like '%{this.TableNamePrefix}%';";
                var reader = db.Ado.GetDataReader(sql_sel_table);
                while (reader.Read())
                {
                    var tableName = reader["name"].ToString();
                    tableNames.Add(tableName);
                }
                if (tableNames == null || !tableNames.Any())
                    return default;

                var dict = new Dictionary<string, List<Entity.AnalysisCombine>>();
                foreach (var tableName in tableNames)
                {
                    var sql = $"select * from {tableName}";
                    var list = db.Ado.SqlQuery<Entity.AnalysisCombine>(sql);
                    if (list == null || !list.Any())
                        continue;
                    dict.Add(tableName, list);
                }
                return dict;
            }
        }

        /// <summary>
        /// 通过表名获取未分析组合
        /// </summary>
        public List<Entity.AnalysisCombine> GetNoAnalysisByTableName(string tableName)
        {
            using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
            {
                var sql = $"select * from {tableName} where AnaStatus=False";
                var list = db.Ado.SqlQuery<Entity.AnalysisCombine>(sql);
                return list;
            }
        }

        /// <summary>
        /// 大批量插入(表不存在就新建)
        /// </summary>
        public bool BulkInsertsEx(string runFlag, List<Entity.AnalysisCombine> list)
        {
            if (list == null || list.Count < 1)
                return default;
            var tableName = GetTableName(runFlag);
            using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
            {
                var exist_sql = GetExistTableSql(tableName);
                if (db.Ado.GetInt(exist_sql) < 1)
                {
                    var sql_create_table = GetCreateTableSql(tableName);
                    db.Ado.ExecuteCommand(sql_create_table);
                }
                //大数据写入
                return db.Fastest<Entity.AnalysisCombine>().AS(tableName).BulkCopy(list) > 0;
            }
        }

        /// <summary>
        /// 设置已分析状态
        /// </summary>
        public bool UpdateAnaStatus(string tableName, long id)
        {
            using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
            {
                var sql = $"update {tableName} set AnaStatus=True where ID={id}";
                var bol = db.Ado.ExecuteCommand(sql) > 0;
                return bol;
            }
        }

        /// <summary>
        /// 设置已分析状态
        /// </summary>
        public bool UpdateAnaStatus(string tableName, List<long> ids)
        {
            using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
            {
                var sql = $"update {tableName} set AnaStatus=True where ID in(@ids)";
                var obj = new { ids = ids.ToArray() };
                var bol = db.Ado.ExecuteCommand(sql, obj) > 0;
                return bol;
            }
        }

        /// <summary>
        /// 判断数据库是否存在表
        /// </summary> 
        public bool ExistTable(string runFlag)
        {
            using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
            {
                var tableName = GetTableName(runFlag);
                var sql = GetExistTableSql(tableName);
                var bol = db.Ado.ExecuteCommand(sql) > 0;
                return bol;
            }
        }

        /// <summary>
        /// 删除所有表
        /// </summary>
        public bool DeleteAllTable()
        {
            var tables = GetAllTableName();
            if (tables == null || !tables.Any())
                return false;
            using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
            {
                db.BeginTran();
                foreach (var table in tables)
                {
                    var sql = $"drop table {table};";
                    db.Ado.ExecuteCommand(sql);
                }
                db.CommitTran();
            }
            return true;
        }

    }
}