调度算法 大致完成

ningshuxia

2024-05-06 8f6d2b48f22b695574bd4a6c4ac91b1ac9f780b1

 Schedule/IStation.Algorithm/DAL/ScheduleCombine.cs

@@ -20,6 +20,8 @@
            return $"{_tableNamePrefix}{runFlag}";
        }

        private readonly string _createTable = "(\r\n    ID        BIGINT        NOT NULL\r\n                            PRIMARY KEY,\r\n    RunFlag   VARCHAR (255),\r\n    RunCount  INTEGER,\r\n    Pump1     REAL,\r\n    Pump2     REAL,\r\n    Pump3     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    AnaStatus BIT\r\n);";

        /// <summary>
        /// 获取全部表名
        /// </summary>
@@ -60,52 +62,6 @@
        }


        /// <summary>
        /// 大批量插入
        /// </summary>
        public bool BulkInserts_SplitTable(List<Entity.ScheduleCombine> list)
        {
            if (list == null || list.Count < 1)
                return default;
            using (SqlSugarClient db = Connection)
            {
                ///自己来制定定义的规则
                db.CurrentConnectionConfig.ConfigureExternalServices.SplitTableService = new Entity.ScheduleCombineSubTableService();
                db.CodeFirst
                    .SplitTables()//标识分表
                    .InitTables<Entity.ScheduleCombine>(); //程序启动时加这一行,如果一张表没有会初始化一张

                //大数据写入+表不存在会建表
                //自动找表大数据写入 
                return db.Fastest<Entity.ScheduleCombine>().SplitTable().BulkCopy(list) > 0;
            }
        }



        /// <summary>
        /// 大批量插入
        /// </summary>
        public async Task<bool> BulkInserts_Create_Async(string runFlag, List<Entity.ScheduleCombine> list)
        {
            if (list == null || list.Count < 1)
                return default;
            var tableName = GetTableName(runFlag);
            using (SqlSugarClient db = Connection)
            {
                var exist_sql = $"select count(*)  from sqlite_master where type = 'table' and name = '{tableName}' ;";
                if (db.Ado.GetInt(exist_sql) < 1)
                {
                    var sql_create_table = $"CREATE TABLE {tableName} (\r\n ID   BIGINT NOT NULL\r\n    PRIMARY KEY,\r\n    RunFlag VARCHAR (255),\r\n  RunCount    INTEGER,\r\n    Pump1   REAL,\r\n   Pump2  REAL,\r\n    Pump3   REAL,\r\n   CurveQH    VARCHAR (255),\r\n    CurveQP    VARCHAR (255),\r\n   AnaStatus BIT\r\n);";
                    if (db.Ado.ExecuteCommand(sql_create_table) < 1)
                    {
                        return false;
                    }
                }
                return await db.Fastest<Entity.ScheduleCombine>().AS(tableName).BulkCopyAsync(list) > 0;
            }
        }


        /// <summary>
        /// 大批量插入
@@ -118,54 +74,14 @@
            using (SqlSugarClient db = Connection)
            {
                var exist_sql = $"select count(*)  from sqlite_master where type = 'table' and name = '{tableName}';";
                if (db.Ado.ExecuteCommand(exist_sql) < 1)
                if (db.Ado.GetInt(exist_sql) < 1)
                {
                    var sql_create_table = $"CREATE TABLE {tableName} (\r\n ID   BIGINT NOT NULL\r\n    PRIMARY KEY,\r\n    RunFlag VARCHAR (255),\r\n  RunCount    INTEGER,\r\n    Pump1   REAL,\r\n   Pump2  REAL,\r\n    Pump3   REAL,\r\n   CurveQH    VARCHAR (255),\r\n    CurveQP    VARCHAR (255),\r\n   AnaStatus BIT\r\n);";
                    var sql_create_table = $"CREATE TABLE {tableName} {_createTable}";
                    db.Ado.ExecuteCommand(sql_create_table);
                }
                //大数据写入
                return db.Fastest<Entity.ScheduleCombine>().AS(tableName).BulkCopy(list) > 0;
            }
        }

        /// <summary>
        /// 大批量插入
        /// </summary> 
        public bool BulkInserts_NativeSql(string runFlag, List<Entity.ScheduleCombine> list)
        {
            var tableName = GetTableName(runFlag);
            var connect = ConfigHelper.ConnectionString;
            SQLiteConnection connection = new SQLiteConnection(connect);//连接对象初始化 
            connection.Open();//打开连接

            SQLiteCommand command = new SQLiteCommand(connection);//命令对象初始化 
            command.CommandText = $"VACUUM;";//执行VACUUM命令收缩数据库
            command.ExecuteNonQuery();

            SQLiteTransaction transaction = connection.BeginTransaction();//开始事务 
            var sql_exist_table = $"select count(*)  from sqlite_master where type = 'table' and name = '{tableName}';";
            command.CommandText = sql_exist_table;
            if (command.ExecuteNonQuery() < 1)//没有表就创建表
            {
                var sql_create_table = $"CREATE TABLE {tableName} (\r\n    ID        BIGINT        NOT NULL\r\n                            PRIMARY KEY,\r\n    RunFlag   VARCHAR (255),\r\n    RunCount  INTEGER,\r\n    Pump1     REAL,\r\n    Pump2     REAL,\r\n    Pump3     REAL,\r\n    CurveQH   VARCHAR (255),\r\n    CurveQP   VARCHAR (255),\r\n    AnaStatus BIT\r\n);";
                command.CommandText = sql_create_table;
                command.ExecuteNonQuery();
            }

            var group = list.GroupBy(x => x.ID).Where(x => x.Count() > 1).Count();

            for (int i = 0; i < list.Count; i++) //[---使用事务---]执行INSERT命令
            {
                var item = list[i];
                var sql_insert = $"INSERT INTO {tableName}(ID, RunFlag, RunCount, Pump1, Pump2, Pump3, CurveQH, CurveQP, AnaStatus) " +
                    $"VALUES ('{item.ID}','{item.RunFlag}','{item.RunCount}','{item.Pump1}','{item.Pump2}','{item.Pump3}','{item.CurveQH}','{item.CurveQP}','{item.AnaStatus}')";
                command.CommandText = sql_insert;
                command.ExecuteNonQuery();
            }
            // var result = command.ExecuteScalar();
            transaction.Commit();//提交事务
            connection.Close();//关闭连接 
            return true;
        }