调度修改

Shuxia Ning

2024-08-28 1a8a81785470302fc7fbd6914a9df5d1094dac2a

 IStation.Service/04-dal/03-sqlite/01-analysis/AnalysisConclusion.cs

@@ -27,7 +27,7 @@
        /// </summary>
        /// <param name="runFlag"></param>
        /// <returns></returns>
        private string GetTableName(string runFlag)
        public string GetTableName(string runFlag)
        {
            return $"{this.TableNamePrefix}{runFlag}";
        }
@@ -39,7 +39,7 @@
        /// <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  );  ";
            var sql = $"CREATE TABLE  {tableName} (\r\n    ID   BIGINT NOT NULL\r\n    PRIMARY KEY,\r\n    CombineID BIGINT NOT NULL,\r\n    Pump     REAL   NOT NULL,\r\n    Head      REAL   NOT NULL,\r\n    Flow      REAL   NOT NULL,\r\n    Power     REAL   NOT NULL,\r\n    WP        REAL   NOT NULL,\r\n    UWP       REAL   NOT NULL\r\n);\r\n";
            return sql;
        }

@@ -76,18 +76,42 @@
        }

        /// <summary>
        /// 通过表名获取未分析组合
        /// </summary>
        public List<Entity.AnalysisConclusion> GetNoAnalysisByTableName(string tableName)
        /// 获取全部表
        /// </summary> 
        public Dictionary<string, List<Entity.AnalysisConclusion>> GetAllTable()
        {
            //var tableNames = new List<string>();
            //using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
            //{
            //    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);
            //    }
            //}

            var tableNames = GetAllTableName();
            if (tableNames == null || !tableNames.Any())
                return default;

            var dict = new Dictionary<string, List<Entity.AnalysisConclusion>>();
            using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
            {
                var sql = $"select * from {tableName} where AnaStatus=False";
                var list = db.Ado.SqlQuery<Entity.AnalysisConclusion>(sql);
                return list;
                foreach (var tableName in tableNames)
                {
                    var sql = $"select * from {tableName}";
                    var list = db.Queryable<Entity.AnalysisConclusion>().AS(tableName).ToList();
                    if (list == null || !list.Any())
                        continue;
                    dict.Add(tableName, list);
                }
                return dict;
            }
        }


        /// <summary>
        /// 大批量插入(表不存在就新建)
        /// </summary>