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/ScheduleCombine.cs | 32 +++++++++++++++++++++++++++-----
1 files changed, 27 insertions(+), 5 deletions(-)
diff --git a/Schedule/IStation.Algorithm/DAL/ScheduleCombine.cs b/Schedule/IStation.Algorithm/DAL/ScheduleCombine.cs
index 414b858..eb57faa 100644
--- a/Schedule/IStation.Algorithm/DAL/ScheduleCombine.cs
+++ b/Schedule/IStation.Algorithm/DAL/ScheduleCombine.cs
@@ -82,10 +82,35 @@
}
+
/// <summary>
/// 澶ф壒閲忔彃鍏�
/// </summary>
- public bool BulkInserts_SplitTable_Create(string runFlag, List<Entity.ScheduleCombine> list)
+ 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>
+ /// 澶ф壒閲忔彃鍏�
+ /// </summary>
+ public bool BulkInserts_Create(string runFlag, List<Entity.ScheduleCombine> list)
{
if (list == null || list.Count < 1)
return default;
@@ -96,10 +121,7 @@
if (db.Ado.ExecuteCommand(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;
- }
+ db.Ado.ExecuteCommand(sql_create_table);
}
//澶ф暟鎹啓鍏�
return db.Fastest<Entity.ScheduleCombine>().AS(tableName).BulkCopy(list) > 0;
--
Gitblit v1.9.3