From 8f6d2b48f22b695574bd4a6c4ac91b1ac9f780b1 Mon Sep 17 00:00:00 2001
From: ningshuxia <ningshuxia0927@outlook.com>
Date: 星期一, 06 五月 2024 17:28:35 +0800
Subject: [PATCH] 调度算法 大致完成
---
Schedule/IStation.Algorithm/DAL/ScheduleCombine.cs | 92 ++--------------------------------------------
1 files changed, 4 insertions(+), 88 deletions(-)
diff --git a/Schedule/IStation.Algorithm/DAL/ScheduleCombine.cs b/Schedule/IStation.Algorithm/DAL/ScheduleCombine.cs
index eb57faa..1517966 100644
--- a/Schedule/IStation.Algorithm/DAL/ScheduleCombine.cs
+++ b/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;
}
--
Gitblit v1.9.3