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

        }

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

        /// <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} ( ID    BIGINT NOT NULL   PRIMARY KEY,  CombineID BIGINT,  Pump1     REAL,  Pump2     REAL,  Head      REAL,  Flow      REAL,  Power     REAL,  WP        REAL,  UWP       REAL  );  ";
            return sql;
        }

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


        /// <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();
                        list.Add(tableName);
                    }
                }
                return list;
            }
        }

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

        /// <summary>
        /// 大批量插入(表不存在就新建)
        /// </summary>
        public bool BulkInsertsEx(string runFlag, List<Entity.AnalysisConclusion> 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.AnalysisConclusion>().AS(tableName).BulkCopy(list) > 0;
            }
        }

        /// <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;
        }


        /// <summary>
        /// 查询
        /// </summary>
        public List<Entity.AnalysisConclusion> GetList(string runFlag, double targetHead)
        {
            var tableName = GetTableName(runFlag);
            using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
            {
                var sql = GetExistTableSql(tableName);
                if (db.Ado.GetInt(sql) < 1)
                {
                    return default;
                }
                var list = db.Queryable<Entity.AnalysisConclusion>().AS(tableName)
                      .Where(x => x.Head == targetHead)
                      .OrderBy(x => x.Power)
                      .ToList();
                return list;
            }
        }
    }
}