升级前备份

Shuxia Ning

2024-09-10 049f546f25cabfb5b08e29c54f49d61a544b0395

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

ÎļþÃû´Ó IStation.Service/04-dal/03-sqlite/01-analysis/AnalysisCombine.cs ÐÞ¸Ä
@@ -3,7 +3,7 @@
    /// <summary>
    /// 
    /// </summary>
    public partial class AnalysisCombine : Yw.DAL.SQLite.BaseDAL<Entity.AnalysisCombine>, IAnalysisCombine
    public partial class AnalysisPump : Yw.DAL.SQLite.BaseDAL<Entity.AnalysisPump>, IAnalysisPump
    {
        /// <summary>
        /// 
@@ -18,7 +18,7 @@
        /// </summary>
        private string TableNamePrefix
        {
            get { return "AnalysisCombine_Cb_"; }
            get { return "AnalysisPump_"; }
        }

        /// <summary>
@@ -26,7 +26,7 @@
        /// </summary>
        /// <param name="runFlag"></param>
        /// <returns></returns>
        private string GetTableName(string runFlag)
        public string GetTableName(string runFlag)
        {
            return $"{this.TableNamePrefix}{runFlag}";
        }
@@ -38,7 +38,7 @@
        /// <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";
            var sql = $"CREATE TABLE {tableName}  (ID   BIGINT   NOT NULL\r\n   PRIMARY KEY,\r\n    Flag    INTEGER,\r\n    Hz  REAL,\r\n    CurveQH VARCHAR (255),\r\n    CurveQP VARCHAR (255),\r\n    MaxFlow REAL,\r\n    MinFlow REAL,\r\n    MaxHead REAL,\r\n    MinHead REAL\r\n);";
            return sql;
        }

@@ -75,8 +75,7 @@
                {
                    while (reader.Read())
                    {
                        var tableName = reader["name"].ToString();
                        // tableName = tableName.Replace(this.TableNamePrefix, null);
                        var tableName = reader["name"].ToString(); 
                        list.Add(tableName);
                    }
                }
@@ -87,7 +86,7 @@
        /// <summary>
        /// èŽ·å–全部表
        /// </summary> 
        public Dictionary<string, List<Entity.AnalysisCombine>> GetAllTable()
        public Dictionary<string, List<Entity.AnalysisPump>> GetAllTable()
        {
            using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
            {
@@ -102,11 +101,11 @@
                if (tableNames == null || !tableNames.Any())
                    return default;

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

        /// <summary>
        /// é€šè¿‡è¡¨åèŽ·å–未分析组合
        /// é€šè¿‡è¡¨åèŽ·å–全部
        /// </summary>
        public List<Entity.AnalysisCombine> GetNoAnalysisByTableName(string tableName)
        public List<Entity.AnalysisPump> GetAllByTableName(string tableName)
        {
            using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
            {
                var sql = $"select * from {tableName} where AnaStatus=False";
                var list = db.Ado.SqlQuery<Entity.AnalysisCombine>(sql);
                var sql = $"select * from {tableName}";
                var list = db.Ado.SqlQuery<Entity.AnalysisPump>(sql);
                return list;
            }
        }
@@ -131,7 +130,7 @@
        /// <summary>
        /// å¤§æ‰¹é‡æ’å…¥(表不存在就新建)
        /// </summary>
        public bool BulkInsertsEx(string runFlag, List<Entity.AnalysisCombine> list)
        public bool BulkInsertsEx(string runFlag, List<Entity.AnalysisPump> list)
        {
            if (list == null || list.Count < 1)
                return default;
@@ -145,36 +144,11 @@
                    db.Ado.ExecuteCommand(sql_create_table);
                }
                //大数据写入
                return db.Fastest<Entity.AnalysisCombine>().AS(tableName).BulkCopy(list) > 0;
                return db.Fastest<Entity.AnalysisPump>().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>
        /// åˆ¤æ–­æ•°æ®åº“是否存在表