439 lines
28 KiB
C#
439 lines
28 KiB
C#
using System;
|
|
using System.Collections.Generic;
|
|
using System.Text;
|
|
using MySql.Data.MySqlClient;
|
|
using solarApp.Model;
|
|
using System.Configuration;
|
|
using Dapper;
|
|
using Microsoft.Extensions.Logging;
|
|
using System.Windows.Forms;
|
|
|
|
namespace solarApp.Service
|
|
{
|
|
class archiveLowData
|
|
{
|
|
string Connection1 = string.Empty;
|
|
|
|
public archiveLowData(string Connection_parame = null)
|
|
{
|
|
if (!string.IsNullOrEmpty(Connection_parame))
|
|
{
|
|
Connection1 = Connection_parame;
|
|
}
|
|
else
|
|
{
|
|
Connection1 = ConfigurationManager.ConnectionStrings["mySql"].ConnectionString;
|
|
}
|
|
}
|
|
|
|
public string _siteID { get; set; }
|
|
public string _siteDB { get; set; }
|
|
public string _siteID01 { get; set; }
|
|
public string _powerStationID { get; set; }
|
|
|
|
/// <summary>
|
|
/// 要搬動的月份
|
|
/// </summary>
|
|
public string move_month { get; set; }
|
|
|
|
public bool archiveData(string siteID)
|
|
{
|
|
bool result = false;
|
|
// string yyyymm = System.DateTime.Now.AddMonths(-2).ToString("yyyy-MM");
|
|
_siteID = siteID;
|
|
//搬移的月份
|
|
move_month = System.DateTime.Now.AddMonths(-1).ToString("yyyy-MM");
|
|
//_date1 = date1;
|
|
get_siteInfo();
|
|
checkTable();
|
|
|
|
moveData_station();
|
|
moveData_inv();
|
|
moveData_sensor();
|
|
|
|
|
|
result = true;
|
|
|
|
return result;
|
|
}
|
|
|
|
public bool get_siteInfo()
|
|
{
|
|
bool result = false;
|
|
try
|
|
{
|
|
using (MySqlConnection conn = new MySqlConnection(Connection1))
|
|
{
|
|
conn.Open();
|
|
#region 取得 PowerStationID
|
|
string sql = @" select id , `code` siteID, siteDB, `name` siteName
|
|
from solar_master.power_station where `code` = @siteID";
|
|
var ds = conn.Query<station_list>(sql, new { siteID = _siteID }).AsList<station_list>();
|
|
foreach (var item in ds)
|
|
{
|
|
_powerStationID = item.id;
|
|
_siteDB = item.SiteDB;
|
|
_siteID01 = item.SiteID + "01";
|
|
}
|
|
#endregion
|
|
conn.Close();
|
|
}
|
|
result = true;
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
throw ex;
|
|
}
|
|
return result;
|
|
}
|
|
|
|
bool checkTable()
|
|
{
|
|
bool result = false;
|
|
using (MySqlConnection conn = new MySqlConnection(Connection1))
|
|
{
|
|
conn.Open();
|
|
try
|
|
{
|
|
//先判斷是否存在 DB
|
|
string ss = $@"SELECT * FROM information_schema.SCHEMATA where SCHEMA_NAME= '" + _siteDB + "'; ";
|
|
List<string> ds_db = conn.Query<string>(ss, new { siteDB = _siteDB }).AsList<string>();
|
|
|
|
////如果該 DB不存在 則create
|
|
if (ds_db.Count == 0)
|
|
{
|
|
string createDb = $@"CREATE DATABASE " + _siteDB + " DEFAULT CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci";
|
|
}
|
|
|
|
//判斷table是否存在
|
|
string checkStationExists = $@"SELECT * FROM information_schema.tables WHERE table_schema = '{_siteDB}_history' AND table_name = 's{_siteID01}_station';";
|
|
List<string> ds_stationExists = conn.Query<string>(checkStationExists).AsList<string>();
|
|
|
|
//如果該 table不存在 則create
|
|
if (ds_stationExists.Count == 0)
|
|
{
|
|
string ss_station = $@"CREATE TABLE {_siteDB}_history. `s{_siteID01}_station` (
|
|
`ID` int(11) NOT NULL AUTO_INCREMENT,
|
|
`TIMESTAMP` bigint(20) NULL DEFAULT NULL,
|
|
`SITEID` varchar(500) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
|
|
`SITETYPE` int(11) NULL DEFAULT NULL,
|
|
`CONTROLLERID` varchar(500) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
|
|
`KWH` double NULL DEFAULT NULL,
|
|
`TODAYKWH` double NULL DEFAULT NULL,
|
|
`TOTALKWH` double NULL DEFAULT NULL,
|
|
`KWHKWP` double NULL DEFAULT NULL,
|
|
`PR` double NULL DEFAULT NULL,
|
|
`MP` double NULL DEFAULT NULL,
|
|
`SOLARHOUR` double NULL DEFAULT NULL,
|
|
`CreatedTime` datetime(0) NULL DEFAULT NULL,
|
|
`insertTime` datetime(0) NULL DEFAULT CURRENT_TIMESTAMP(0),
|
|
PRIMARY KEY (`ID`) USING BTREE
|
|
) ENGINE = InnoDB AUTO_INCREMENT = 8920 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;";
|
|
int ds_station = conn.Execute(ss_station);
|
|
}
|
|
|
|
//判斷table是否存在
|
|
string checkInvExists = $@"SELECT * FROM information_schema.tables WHERE table_schema = '{_siteDB}_history' AND table_name = 's{_siteID01}_inv';";
|
|
List<string> ds_InvExists = conn.Query<string>(checkInvExists).AsList<string>();
|
|
|
|
//如果該 table不存在 則create
|
|
if (ds_InvExists.Count == 0)
|
|
{
|
|
string ss_inv = $@"CREATE TABLE {_siteDB}_history.`s{_siteID01}_inv` (
|
|
`ID` int(11) NOT NULL AUTO_INCREMENT,
|
|
`TIMESTAMP` bigint(20) NULL DEFAULT NULL,
|
|
`SITEID` varchar(500) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
|
|
`SITETYPE` int(11) NULL DEFAULT NULL,
|
|
`CONTROLLERID` varchar(500) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
|
|
`INVERTERID` varchar(500) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
|
|
`SN` double NULL DEFAULT NULL,
|
|
`AC1V` double NULL DEFAULT NULL,
|
|
`AC1A` double NULL DEFAULT NULL,
|
|
`AC1W` double NULL DEFAULT NULL,
|
|
`AC1F` double NULL DEFAULT NULL,
|
|
`AC1WH` double NULL DEFAULT NULL,
|
|
`AC2V` double NULL DEFAULT NULL,
|
|
`AC2A` double NULL DEFAULT NULL,
|
|
`AC2W` double NULL DEFAULT NULL,
|
|
`AC2F` double NULL DEFAULT NULL,
|
|
`AC2WH` double NULL DEFAULT NULL,
|
|
`AC3V` double NULL DEFAULT NULL,
|
|
`AC3A` double NULL DEFAULT NULL,
|
|
`AC3W` double NULL DEFAULT NULL,
|
|
`AC3F` double NULL DEFAULT NULL,
|
|
`AC3WH` double NULL DEFAULT NULL,
|
|
`ACRUNTIME` double NULL DEFAULT NULL,
|
|
`DC1V` double NULL DEFAULT NULL,
|
|
`DC1A` double NULL DEFAULT NULL,
|
|
`DC1W` double NULL DEFAULT NULL,
|
|
`DC1WH` double NULL DEFAULT NULL,
|
|
`DC2V` double NULL DEFAULT NULL,
|
|
`DC2A` double NULL DEFAULT NULL,
|
|
`DC2W` double NULL DEFAULT NULL,
|
|
`DC2WH` double NULL DEFAULT NULL,
|
|
`DC3V` double NULL DEFAULT NULL,
|
|
`DC3A` double NULL DEFAULT NULL,
|
|
`DC3W` double NULL DEFAULT NULL,
|
|
`DC3WH` double NULL DEFAULT NULL,
|
|
`DC4V` double NULL DEFAULT NULL,
|
|
`DC4A` double NULL DEFAULT NULL,
|
|
`DC4W` double NULL DEFAULT NULL,
|
|
`DC4WH` double NULL DEFAULT NULL,
|
|
`DC5V` double NULL DEFAULT NULL,
|
|
`DC5A` double NULL DEFAULT NULL,
|
|
`DC5W` double NULL DEFAULT NULL,
|
|
`DC5WH` double NULL DEFAULT NULL,
|
|
`DCRUNTIME` double NULL DEFAULT NULL,
|
|
`WH` double NULL DEFAULT NULL,
|
|
`TODAYKWH` double NULL DEFAULT NULL,
|
|
`TOTALKWH` double NULL DEFAULT NULL,
|
|
`PR` double NULL DEFAULT NULL,
|
|
`RA1` double NULL DEFAULT NULL,
|
|
`RA2` double NULL DEFAULT NULL,
|
|
`RA3` double NULL DEFAULT NULL,
|
|
`RA4` double NULL DEFAULT NULL,
|
|
`RA5` double NULL DEFAULT NULL,
|
|
`CreatedTime` datetime(0) NULL DEFAULT NULL ON UPDATE CURRENT_TIMESTAMP(0),
|
|
`CrdTime` datetime(0) NULL DEFAULT NULL,
|
|
PRIMARY KEY (`ID`) USING BTREE,
|
|
INDEX `IDX01`(`TIMESTAMP`, `INVERTERID`) USING BTREE,
|
|
INDEX `IDX02`(`INVERTERID`, `CrdTime`) USING BTREE,
|
|
INDEX `IDX03`(`CrdTime`) USING BTREE
|
|
) ENGINE = InnoDB AUTO_INCREMENT = 1197423 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;";
|
|
int ds_inv = conn.Execute(ss_inv);
|
|
}
|
|
|
|
//判斷table是否存在
|
|
string checkSensorAvgExists = $@"SELECT * FROM information_schema.tables WHERE table_schema = '{_siteDB}_history' AND table_name = 's{_siteID01}_sensoravg';";
|
|
List<string> ds_sensorAvgExists = conn.Query<string>(checkSensorAvgExists).AsList<string>();
|
|
|
|
//如果該 table不存在 則create
|
|
if (ds_sensorAvgExists.Count == 0)
|
|
{
|
|
string ss_sensorAvg = $@"CREATE TABLE {_siteDB}_history.`s{_siteID01}_sensoravg` (
|
|
`ID` int(11) NOT NULL AUTO_INCREMENT,
|
|
`TIMESTAMP` bigint(20) NULL DEFAULT NULL,
|
|
`SITEID` varchar(500) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
|
|
`SITETYPE` int(11) NULL DEFAULT NULL,
|
|
`CONTROLLERID` varchar(500) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
|
|
`SENSORAVG01` double NULL DEFAULT NULL,
|
|
`SENSORAVG02` double NULL DEFAULT NULL,
|
|
`SENSORAVG03` double NULL DEFAULT NULL,
|
|
`SENSORAVG04` double NULL DEFAULT NULL,
|
|
`SENSORAVG05` double NULL DEFAULT NULL,
|
|
`SENSORAVG06` double NULL DEFAULT NULL,
|
|
`SENSORAVG07` double NULL DEFAULT NULL,
|
|
`SENSORAVG08` double NULL DEFAULT NULL,
|
|
`SENSORAVG09` double NULL DEFAULT NULL,
|
|
`SENSORAVG10` double NULL DEFAULT NULL,
|
|
`SENSORAVG11` double NULL DEFAULT NULL,
|
|
`SENSORAVG12` double NULL DEFAULT NULL,
|
|
`SENSORAVG13` double NULL DEFAULT NULL,
|
|
`SENSORAVG14` double NULL DEFAULT NULL,
|
|
`SENSORAVG15` double NULL DEFAULT NULL,
|
|
`SENSORAVG16` double NULL DEFAULT NULL,
|
|
`SENSORAVG17` double NULL DEFAULT NULL,
|
|
`SENSORAVG18` double NULL DEFAULT NULL,
|
|
`SENSORAVG19` double NULL DEFAULT NULL,
|
|
`SENSORAVG20` double NULL DEFAULT NULL,
|
|
`SENSORAVG21` double NULL DEFAULT NULL,
|
|
`SENSORAVG22` double NULL DEFAULT NULL,
|
|
`SENSORAVG23` double NULL DEFAULT NULL,
|
|
`SENSORAVG24` double NULL DEFAULT NULL,
|
|
`SENSORAVG25` double NULL DEFAULT NULL,
|
|
`SENSORAVG26` double NULL DEFAULT NULL,
|
|
`SENSORAVG27` double NULL DEFAULT NULL,
|
|
`SENSORAVG28` double NULL DEFAULT NULL,
|
|
`SENSORAVG29` double NULL DEFAULT NULL,
|
|
`SENSORAVG30` double NULL DEFAULT NULL,
|
|
`SENSORAVG31` double NULL DEFAULT NULL,
|
|
`SENSORAVG32` double NULL DEFAULT NULL,
|
|
`SENSORAVG33` double NULL DEFAULT NULL,
|
|
`SENSORAVG34` double NULL DEFAULT NULL,
|
|
`SENSORAVG35` double NULL DEFAULT NULL,
|
|
`SENSORAVG36` double NULL DEFAULT NULL,
|
|
`SENSORAVG37` double NULL DEFAULT NULL,
|
|
`SENSORAVG38` double NULL DEFAULT NULL,
|
|
`SENSORAVG39` double NULL DEFAULT NULL,
|
|
`SENSORAVG40` double NULL DEFAULT NULL,
|
|
`SENSORAVG41` double NULL DEFAULT NULL,
|
|
`SENSORAVG42` double NULL DEFAULT NULL,
|
|
`SENSORAVG43` double NULL DEFAULT NULL,
|
|
`SENSORAVG44` double NULL DEFAULT NULL,
|
|
`SENSORAVG45` double NULL DEFAULT NULL,
|
|
`SENSORAVG46` double NULL DEFAULT NULL,
|
|
`SENSORAVG47` double NULL DEFAULT NULL,
|
|
`SENSORAVG48` double NULL DEFAULT NULL,
|
|
`SENSORAVG49` double NULL DEFAULT NULL,
|
|
`SENSORAVG50` double NULL DEFAULT NULL,
|
|
`CreatedTime` datetime(0) NULL DEFAULT NULL ON UPDATE CURRENT_TIMESTAMP(0),
|
|
`CrdTime` datetime(0) NULL DEFAULT NULL,
|
|
PRIMARY KEY (`ID`) USING BTREE,
|
|
INDEX `IDX_01`(`TIMESTAMP`) USING BTREE,
|
|
INDEX `IDX_02`(`CrdTime`) USING BTREE
|
|
) ENGINE = InnoDB AUTO_INCREMENT = 108099 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;";
|
|
int ds_sensorAvg = conn.Execute(ss_sensorAvg);
|
|
}
|
|
result = true;
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
throw ex;
|
|
}
|
|
conn.Close();
|
|
}
|
|
return result;
|
|
}
|
|
|
|
bool moveData_station()
|
|
{
|
|
bool result = false;
|
|
procArchiveLog arclog = new procArchiveLog();
|
|
using (MySqlConnection conn = new MySqlConnection(Connection1))
|
|
{
|
|
conn.Open();
|
|
DateTime dt_start1 = DateTime.Now;
|
|
var dateTime = DateTime.Now.ToString("yyyy-MM-dd HH");
|
|
try
|
|
{
|
|
#region station搬移
|
|
//System.Diagnostics.Debug.WriteLine($"【ArchiveRowData】開始執行[{_siteDB}.s{_siteID}_station]的資料表向[{_siteDB}_history.s{_siteID}_station]搬移");
|
|
string for_insert_station = $@"INSERT {_siteDB}_history.s{_siteID01}_station(`ID`, `TIMESTAMP`, `SITEID`, `SITETYPE`, `CONTROLLERID`, `KWH`, `TODAYKWH`, `TOTALKWH`, `KWHKWP`, `PR`, `MP`, `SOLARHOUR`, `insertTime`)
|
|
SELECT `ID`, `TIMESTAMP`, `SITEID`, `SITETYPE`, `CONTROLLERID`, `KWH`, `TODAYKWH`, `TOTALKWH`, `KWHKWP`, `PR`, `MP`, `SOLARHOUR`, `insertTime` FROM {_siteDB}.s{_siteID01}_station
|
|
WHERE FROM_UNIXTIME(`TIMESTAMP`/1000,'%Y-%m-%d') < '{move_month}'";
|
|
int rowCT = conn.Execute(for_insert_station, commandTimeout : 600);
|
|
// System.Diagnostics.Debug.WriteLine($"【ArchiveRowData】{_siteDB}.s{_siteID}_station的七月前資料寫入至{_siteDB}_history.s{_siteID}_station【寫入成功】於{dateTime}");
|
|
|
|
// log
|
|
TimeSpan duration = DateTime.Now - dt_start1;
|
|
arclog.insert_log(_powerStationID, "move raw s1", duration.TotalSeconds, $"{_siteDB}.s{_siteID}_station", $"{_siteDB}_history.s{_siteID}_station", "0", "", rowCT.ToString(), conn, null);
|
|
|
|
|
|
dt_start1 = DateTime.Now;
|
|
|
|
//刪除原本的資料
|
|
string for_delete_station = $@"DELETE FROM {_siteDB}.s{_siteID01}_station
|
|
WHERE FROM_UNIXTIME(`TIMESTAMP`/1000,'%Y-%m-%d') < '{move_month}'";
|
|
rowCT = conn.Execute(for_delete_station, commandTimeout: 600);
|
|
//System.Diagnostics.Debug.WriteLine($"【ArchiveRowData】{_siteDB}.s{_siteID}_sensoravg搬移至{_siteDB}_history.s{_siteID}_sensoravg【搬移資料成功】於{dateTime} 共 {delete_station.ToString()} 筆");
|
|
duration = DateTime.Now - dt_start1;
|
|
|
|
arclog.insert_log(_powerStationID, "delete raw s2", duration.TotalSeconds, $"{_siteDB}.s{_siteID}_station", "", "0", "", rowCT.ToString(), conn, null);
|
|
|
|
|
|
#endregion
|
|
|
|
|
|
result = true;
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
//System.Diagnostics.Debug.WriteLine("【ArchiveRowData】[搬移資料失敗】");
|
|
TimeSpan duration = DateTime.Now - dt_start1;
|
|
arclog.insert_log(_powerStationID, "move raw s1", duration.TotalSeconds, $"{_siteDB}.s{_siteID}_station", $"{_siteDB}_history.s{_siteID}_station", "1", ex.Message, "0", conn, null);
|
|
|
|
throw ex;
|
|
}
|
|
|
|
conn.Close();
|
|
}
|
|
return result;
|
|
}
|
|
|
|
bool moveData_inv()
|
|
{
|
|
bool result = false;
|
|
procArchiveLog arclog = new procArchiveLog();
|
|
using (MySqlConnection conn = new MySqlConnection(Connection1))
|
|
{
|
|
conn.Open();
|
|
DateTime dt_start1 = DateTime.Now;
|
|
var dateTime = DateTime.Now.ToString("yyyy-MM-dd HH");
|
|
try
|
|
{
|
|
#region inv搬移
|
|
dt_start1 = DateTime.Now;
|
|
if (_powerStationID == "19")
|
|
{
|
|
//MessageBox.Show("here");
|
|
}
|
|
// System.Diagnostics.Debug.WriteLine($"【ArchiveRowData】開始執行[{_siteDB}.s{_siteID}_inv]的資料表向[{_siteDB}_history.s{_siteID}_inv]搬移");
|
|
string for_insert_inv = $@"INSERT {_siteDB}_history.s{_siteID01}_inv(`ID`, `TIMESTAMP`, `SITEID`, `SITETYPE`, `CONTROLLERID`, `INVERTERID`, `SN`, `AC1V`, `AC1A`, `AC1W`, `AC1F`, `AC1WH`, `AC2V`, `AC2A`, `AC2W`, `AC2F`, `AC2WH`, `AC3V`, `AC3A`, `AC3W`, `AC3F`, `AC3WH`, `ACRUNTIME`, `DC1V`, `DC1A`, `DC1W`, `DC1WH`, `DC2V`, `DC2A`, `DC2W`, `DC2WH`, `DC3V`, `DC3A`, `DC3W`, `DC3WH`, `DC4V`, `DC4A`, `DC4W`, `DC4WH`, `DC5V`, `DC5A`, `DC5W`, `DC5WH`, `DCRUNTIME`, `WH`, `TODAYKWH`, `TOTALKWH`, `PR`, `RA1`, `RA2`, `RA3`, `RA4`, `RA5`, `CrdTime`)
|
|
SELECT `ID`, `TIMESTAMP`, `SITEID`, `SITETYPE`, `CONTROLLERID`, `INVERTERID`, `SN`, `AC1V`, `AC1A`, `AC1W`, `AC1F`, `AC1WH`, `AC2V`, `AC2A`, `AC2W`, `AC2F`, `AC2WH`, `AC3V`, `AC3A`, `AC3W`, `AC3F`, `AC3WH`, `ACRUNTIME`, `DC1V`, `DC1A`, `DC1W`, `DC1WH`, `DC2V`, `DC2A`, `DC2W`, `DC2WH`, `DC3V`, `DC3A`, `DC3W`, `DC3WH`, `DC4V`, `DC4A`, `DC4W`, `DC4WH`, `DC5V`, `DC5A`, `DC5W`, `DC5WH`, `DCRUNTIME`, `WH`, `TODAYKWH`, `TOTALKWH`, `PR`, `RA1`, `RA2`, `RA3`, `RA4`, `RA5`, `CrdTime` FROM {_siteDB}.s{_siteID01}_inv
|
|
WHERE LEFT(crdTime, 7) < '{move_month}'";
|
|
int rowCT = conn.Execute(for_insert_inv, commandTimeout: 6000);
|
|
//System.Diagnostics.Debug.WriteLine($"【ArchiveRowData】{_siteDB}.s{_siteID}_inv的七月前資料寫入至{_siteDB}_history.s{_siteID}_inv【寫入成功】於{dateTime}");
|
|
// log
|
|
TimeSpan duration = DateTime.Now - dt_start1;
|
|
arclog.insert_log(_powerStationID, "move raw s1", duration.TotalSeconds, $"{_siteDB}.s{_siteID01}_inv", $"{_siteDB}_history.s{_siteID01}_inv", "0", "", rowCT.ToString(), conn, null);
|
|
//arclog.insert_log(_powerStationID, "sensor step1", duration.TotalSeconds, "sensor_history_hour", "insert sensor hour", "0", "", rowCT.ToString(), conn, cmd);
|
|
dt_start1 = DateTime.Now;
|
|
|
|
string for_delete_inv = $@"DELETE FROM {_siteDB}.s{_siteID01}_inv
|
|
WHERE LEFT(crdTime, 7) < '{move_month}'";
|
|
rowCT = conn.Execute(for_delete_inv, commandTimeout: 6000);
|
|
//System.Diagnostics.Debug.WriteLine($"【ArchiveRowData】{_siteDB}.s{_siteID}_sensoravg搬移至{_siteDB}_history.s{_siteID}_sensoravg【搬移資料成功】於{dateTime} 共 {delete_inv.ToString()} 筆");
|
|
duration = DateTime.Now - dt_start1;
|
|
arclog.insert_log(_powerStationID, "delete raw s2", duration.TotalSeconds, $"{_siteDB}.s{_siteID01}_inv", "", "0", "", rowCT.ToString(), conn, null);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
TimeSpan duration = DateTime.Now - dt_start1;
|
|
arclog.insert_log(_powerStationID, "move raw s1", duration.TotalSeconds, $"{_siteDB}.s{_siteID01}_station", $"{_siteDB}_history.s{_siteID01}_station", "1", ex.Message, "0", conn, null);
|
|
//arclog.insert_log(_powerStationID, "sensor step1", duration.TotalSeconds, "sensor_history_hour", "insert sensor hour", "0", "", rowCT.ToString(), conn, cmd);
|
|
throw ex;
|
|
}
|
|
#endregion
|
|
conn.Close();
|
|
}
|
|
return result;
|
|
}
|
|
|
|
|
|
bool moveData_sensor() {
|
|
bool result = false;
|
|
procArchiveLog arclog = new procArchiveLog();
|
|
using (MySqlConnection conn = new MySqlConnection(Connection1))
|
|
{
|
|
conn.Open();
|
|
DateTime dt_start1 = DateTime.Now;
|
|
var dateTime = DateTime.Now.ToString("yyyy-MM-dd HH");
|
|
try
|
|
{
|
|
#region sensoravg搬移
|
|
dt_start1 = DateTime.Now;
|
|
//System.Diagnostics.Debug.WriteLine($"【ArchiveRowData】開始執行[{_siteDB}.s{_siteID}_sensoravg]的資料表向[{_siteDB}_history.s{_siteID}_sensoravg]搬移");
|
|
string for_insert_sensoravg = $@"INSERT {_siteDB}_history.s{_siteID01}_sensoravg(`ID`, `TIMESTAMP`, `SITEID`, `SITETYPE`, `CONTROLLERID`, `SENSORAVG01`, `SENSORAVG02`, `SENSORAVG03`, `SENSORAVG04`, `SENSORAVG05`, `SENSORAVG06`, `SENSORAVG07`, `SENSORAVG08`, `SENSORAVG09`, `SENSORAVG10`, `SENSORAVG11`, `SENSORAVG12`, `SENSORAVG13`, `SENSORAVG14`, `SENSORAVG15`, `SENSORAVG16`, `SENSORAVG17`, `SENSORAVG18`, `SENSORAVG19`, `SENSORAVG20`, `SENSORAVG21`, `SENSORAVG22`, `SENSORAVG23`, `SENSORAVG24`, `SENSORAVG25`, `SENSORAVG26`, `SENSORAVG27`, `SENSORAVG28`, `SENSORAVG29`, `SENSORAVG30`, `SENSORAVG31`, `SENSORAVG32`, `SENSORAVG33`, `SENSORAVG34`, `SENSORAVG35`, `SENSORAVG36`, `SENSORAVG37`, `SENSORAVG38`, `SENSORAVG39`, `SENSORAVG40`, `SENSORAVG41`, `SENSORAVG42`, `SENSORAVG43`, `SENSORAVG44`, `SENSORAVG45`, `SENSORAVG46`, `SENSORAVG47`, `SENSORAVG48`, `SENSORAVG49`, `SENSORAVG50`, `CrdTime`)
|
|
SELECT `ID`, `TIMESTAMP`, `SITEID`, `SITETYPE`, `CONTROLLERID`, `SENSORAVG01`, `SENSORAVG02`, `SENSORAVG03`, `SENSORAVG04`, `SENSORAVG05`, `SENSORAVG06`, `SENSORAVG07`, `SENSORAVG08`, `SENSORAVG09`, `SENSORAVG10`, `SENSORAVG11`, `SENSORAVG12`, `SENSORAVG13`, `SENSORAVG14`, `SENSORAVG15`, `SENSORAVG16`, `SENSORAVG17`, `SENSORAVG18`, `SENSORAVG19`, `SENSORAVG20`, `SENSORAVG21`, `SENSORAVG22`, `SENSORAVG23`, `SENSORAVG24`, `SENSORAVG25`, `SENSORAVG26`, `SENSORAVG27`, `SENSORAVG28`, `SENSORAVG29`, `SENSORAVG30`, `SENSORAVG31`, `SENSORAVG32`, `SENSORAVG33`, `SENSORAVG34`, `SENSORAVG35`, `SENSORAVG36`, `SENSORAVG37`, `SENSORAVG38`, `SENSORAVG39`, `SENSORAVG40`, `SENSORAVG41`, `SENSORAVG42`, `SENSORAVG43`, `SENSORAVG44`, `SENSORAVG45`, `SENSORAVG46`, `SENSORAVG47`, `SENSORAVG48`, `SENSORAVG49`, `SENSORAVG50`, `CrdTime`
|
|
FROM {_siteDB}.s{_siteID01}_sensoravg
|
|
WHERE LEFT(crdTime, 7) < '{move_month}'";
|
|
int rowCT = conn.Execute(for_insert_sensoravg, commandTimeout: 600);
|
|
// log
|
|
TimeSpan duration = DateTime.Now - dt_start1;
|
|
arclog.insert_log(_powerStationID, "move raw s1", duration.TotalSeconds, $"{_siteDB}.s{_siteID01}_sensoravg", $"{_siteDB}_history.s{_siteID01}_sensoravg", "0", "", rowCT.ToString(), conn, null);
|
|
dt_start1 = DateTime.Now;
|
|
|
|
string for_delete_sensoravg = $@"DELETE FROM {_siteDB}.s{_siteID01}_sensoravg WHERE LEFT(crdTime, 7) < '{move_month}'";
|
|
rowCT = conn.Execute(for_delete_sensoravg, commandTimeout: 600);
|
|
|
|
duration = DateTime.Now - dt_start1;
|
|
arclog.insert_log(_powerStationID, "delete raw s2", duration.TotalSeconds, $"{_siteDB}.s{_siteID01}_sensoravg", "", "0", "", rowCT.ToString(), conn, null);
|
|
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
TimeSpan duration = DateTime.Now - dt_start1;
|
|
arclog.insert_log(_powerStationID, "move raw s1", duration.TotalSeconds, $"{_siteDB}.s{_siteID01}_sensoravg", $"{_siteDB}_history.s{_siteID01}_sensoravg", "1", ex.Message, "0", conn, null);
|
|
|
|
throw;
|
|
}
|
|
#endregion
|
|
|
|
conn.Close();
|
|
}
|
|
return result;
|
|
}
|
|
|
|
}
|
|
}
|