From c297ce1f0704a6dd927d68042df3e31fa36f8194 Mon Sep 17 00:00:00 2001
From: ningshuxia <ningshuxia0927@outlook.com>
Date: 星期一, 29 四月 2024 17:44:59 +0800
Subject: [PATCH] 基础分析差不多 准备开始调度分析
---
Schedule/IStation.Algorithm/DAL/ScheduleConclusion.cs | 61 +++++++++++++++++++-----------
1 files changed, 39 insertions(+), 22 deletions(-)
diff --git a/Schedule/IStation.Algorithm/DAL/ScheduleConclusion.cs b/Schedule/IStation.Algorithm/DAL/ScheduleConclusion.cs
index f41ae35..c101ab8 100644
--- a/Schedule/IStation.Algorithm/DAL/ScheduleConclusion.cs
+++ b/Schedule/IStation.Algorithm/DAL/ScheduleConclusion.cs
@@ -1,7 +1,4 @@
-锘縰sing MathNet.Numerics.Distributions;
-using System.Collections.Generic;
-
-namespace IStation.DAL
+锘縩amespace IStation.DAL
{
/// <summary>
///
@@ -76,7 +73,42 @@
}
}
+ /// <summary>
+ /// 澶ф壒閲忔彃鍏�
+ /// </summary>
+ public bool BulkInserts(string runFlag, List<Entity.ScheduleConclusion> list)
+ {
+ if (list == null || list.Count < 1)
+ return default;
+ var tableName = GetTableName(runFlag);
+ using (SqlSugarClient db = Connection)
+ {
+ return db.Fastest<Entity.ScheduleConclusion>().AS(tableName).BulkCopy(list) > 0;
+ }
+ }
+ /// <summary>
+ /// 澶ф壒閲忔彃鍏�
+ /// </summary>
+ public async Task<bool> BulkInserts_Create_Async(string runFlag, List<Entity.ScheduleConclusion> 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 ScheduleCombineID BIGINT,\r\n RunFlag VARCHAR (255),\r\n Pump1 REAL,\r\n Pump2 REAL,\r\n Pump3 REAL,\r\n Head REAL,\r\n Flow REAL,\r\n Power REAL,\r\n WP REAL,\r\n UWP REAL\r\n);";
+ if (db.Ado.ExecuteCommand(sql_create_table) < 1)
+ {
+ return false;
+ }
+ }
+ return await db.Fastest<Entity.ScheduleConclusion>().AS(tableName).BulkCopyAsync(list) > 0;
+ }
+ }
/// <summary>
/// 澶ф壒閲忔彃鍏�
@@ -99,10 +131,11 @@
}
}
+
/// <summary>
/// 澶ф壒閲忔彃鍏�
/// </summary>
- public bool BulkInserts_SplitTable_Create(string runFlag, List<Entity.ScheduleConclusion> list)
+ public bool BulkInserts_Create(string runFlag, List<Entity.ScheduleConclusion> list)
{
if (list == null || list.Count < 1)
return default;
@@ -113,29 +146,13 @@
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 ScheduleCombineID BIGINT,\r\n RunFlag VARCHAR (255),\r\n Pump1 REAL,\r\n Pump2 REAL,\r\n Pump3 REAL,\r\n Head REAL,\r\n Flow REAL,\r\n Power REAL,\r\n WP REAL,\r\n UWP REAL\r\n);";
- if (db.Ado.ExecuteCommand(sql_create_table) < 1)
- {
- return false;
- }
+ db.Ado.ExecuteCommand(sql_create_table);
}
//澶ф暟鎹啓鍏�
return db.Fastest<Entity.ScheduleConclusion>().AS(tableName).BulkCopy(list) > 0;
}
}
- /// <summary>
- /// 澶ф壒閲忔彃鍏�
- /// </summary>
- public bool BulkInserts(string runFlag, List<Entity.ScheduleConclusion> list)
- {
- if (list == null || list.Count < 1)
- return default;
- var tableName = GetTableName(runFlag);
- using (SqlSugarClient db = Connection)
- {
- return db.Fastest<Entity.ScheduleConclusion>().AS(tableName).BulkCopy(list) > 0;
- }
- }
/// <summary>
--
Gitblit v1.9.3