867 lines
34 KiB
C#
867 lines
34 KiB
C#
using System;
|
||
using System.Collections.Generic;
|
||
using System.Text;
|
||
using System.Data;
|
||
using System.IO;
|
||
using MySql.Data.MySqlClient;
|
||
using System.Configuration;
|
||
using Dapper;
|
||
using solarApp.Model;
|
||
|
||
namespace solarApp.Service
|
||
{
|
||
public class operateCSV
|
||
{
|
||
string Connection1 = ConfigurationManager.ConnectionStrings["mySql"].ConnectionString;
|
||
/// <summary>
|
||
/// 讀取CSV檔案通過文字格式
|
||
/// </summary>
|
||
/// <param name="strpath"></param>
|
||
/// <returns></returns>
|
||
public DataTable readCsvTxt(string strpath)
|
||
{
|
||
int intColCount = 0;
|
||
bool blnFlag = true;
|
||
DataTable mydt = new DataTable("myTableName");
|
||
|
||
DataColumn mydc;
|
||
DataRow mydr;
|
||
|
||
string strline;
|
||
string[] aryline;
|
||
|
||
System.IO.StreamReader mysr = new System.IO.StreamReader(strpath);
|
||
|
||
while ((strline = mysr.ReadLine()) != null)
|
||
{
|
||
aryline = strline.Split(',');
|
||
|
||
if (blnFlag)
|
||
{
|
||
blnFlag = false;
|
||
intColCount = aryline.Length;
|
||
for (int i = 0; i < aryline.Length; i++)
|
||
{
|
||
mydc = new DataColumn(aryline[i]);
|
||
mydt.Columns.Add(mydc);
|
||
}
|
||
}
|
||
|
||
mydr = mydt.NewRow();
|
||
for (int i = 0; i < intColCount; i++)
|
||
{
|
||
mydr[i] = aryline[i];
|
||
}
|
||
mydt.Rows.Add(mydr);
|
||
}
|
||
|
||
return mydt;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 利用SQL查詢CSV
|
||
/// </summary>
|
||
/// <param name="path"></param>
|
||
/// <returns></returns>
|
||
//public DataTable readCsvSql(string path, string filename, string deviceName)
|
||
//{
|
||
// string strconn = string.Format(@"Provider=Microsoft.Jet.OLEDB.4.0;Data Source={0};Extended Properties=Text;", path);
|
||
// string sql = string.Format("SELECT * FROM [{0}]", filename);
|
||
// using (OleDbConnection conn = new OleDbConnection(strconn))
|
||
// {
|
||
// DataTable dtTable = new DataTable();
|
||
// OleDbDataAdapter adapter = new OleDbDataAdapter(sql, conn);
|
||
// try
|
||
// {
|
||
// adapter.Fill(dtTable);
|
||
// logHelper.WriteLog(string.Format("[裝置]:{0}-->讀取檔案-->結果:成功", deviceName));
|
||
// }
|
||
// catch (Exception ex)
|
||
// {
|
||
// dtTable = new DataTable();
|
||
// logHelper.WriteLog(string.Format("[裝置]:{0}-->讀取檔案-->結果:{1}", deviceName, ex.Message));
|
||
// throw ex;
|
||
// }
|
||
// return dtTable;
|
||
// }
|
||
|
||
//}
|
||
|
||
/// <summary>
|
||
/// 讀取CSV檔案
|
||
/// </summary>
|
||
/// <param name="mycsvdt"></param>
|
||
/// <param name="filepath"></param>
|
||
/// <returns></returns>
|
||
public void createColumnHour(ref DataTable mycsvdt, string filepath)
|
||
{
|
||
string strpath = filepath; //csv檔案的路徑
|
||
try
|
||
{
|
||
int intColCount = 0;
|
||
bool blnFlag = true;
|
||
|
||
DataColumn mydc;
|
||
|
||
string strline;
|
||
string[] aryline;
|
||
StreamReader mysr = new StreamReader(strpath, System.Text.Encoding.Default);
|
||
|
||
int rowIndex = 0;
|
||
while ((strline = mysr.ReadLine()) != null)
|
||
{
|
||
rowIndex += 1;
|
||
if (rowIndex < 4) continue;
|
||
aryline = strline.Split(new char[] { ',' });
|
||
|
||
//給datatable加上列名
|
||
if (blnFlag)
|
||
{
|
||
blnFlag = false;
|
||
intColCount = aryline.Length;
|
||
int col = 0;
|
||
for (int i = 0; i < aryline.Length; i++)
|
||
{
|
||
col = i + 1;
|
||
mydc = new DataColumn(col.ToString());
|
||
mycsvdt.Columns.Add(mydc);
|
||
}
|
||
//最後一欄 放 Inv編號
|
||
mydc = new DataColumn("inv");
|
||
mycsvdt.Columns.Add(mydc);
|
||
}
|
||
break;
|
||
}
|
||
|
||
}
|
||
catch (Exception e)
|
||
{
|
||
//throw (Stack.GetErrorStack(strpath + "讀取CSV檔案中的資料出錯." + e.Message, "OpenCSVFile("));
|
||
//return false;
|
||
}
|
||
}
|
||
|
||
public void createColumnDay(ref DataTable mycsvdt, string filepath)
|
||
{
|
||
string strpath = filepath; //csv檔案的路徑
|
||
try
|
||
{
|
||
int intColCount = 0;
|
||
bool blnFlag = true;
|
||
|
||
DataColumn mydc;
|
||
|
||
string strline;
|
||
string[] aryline;
|
||
StreamReader mysr = new StreamReader(strpath, System.Text.Encoding.Default);
|
||
|
||
int rowIndex = 0;
|
||
while ((strline = mysr.ReadLine()) != null)
|
||
{
|
||
rowIndex += 1;
|
||
if (rowIndex < 3) continue;
|
||
aryline = strline.Split(new char[] { ',' });
|
||
|
||
//給datatable加上列名
|
||
if (blnFlag)
|
||
{
|
||
blnFlag = false;
|
||
intColCount = aryline.Length;
|
||
int col = 0; int col6 = 0;
|
||
for (int i = 0; i < aryline.Length; i++)
|
||
{
|
||
col = i + 1;
|
||
mydc = new DataColumn(col.ToString());
|
||
mycsvdt.Columns.Add(mydc);
|
||
}
|
||
////最後一欄 放 Inv編號
|
||
//mydc = new DataColumn("inv");
|
||
//mycsvdt.Columns.Add(mydc);
|
||
}
|
||
break;
|
||
}
|
||
|
||
}
|
||
catch (Exception e)
|
||
{
|
||
//throw (Stack.GetErrorStack(strpath + "讀取CSV檔案中的資料出錯." + e.Message, "OpenCSVFile("));
|
||
//return false;
|
||
}
|
||
}
|
||
|
||
public bool readCsvFile(ref DataTable mycsvdt, string filepath, string InvID, int intColCount, bool readTitle)
|
||
{
|
||
string strpath = filepath; //csv檔案的路徑
|
||
try
|
||
{
|
||
DataColumn mydc;
|
||
DataRow mydr;
|
||
|
||
string strline;
|
||
string[] aryline;
|
||
StreamReader mysr = new StreamReader(strpath, System.Text.Encoding.Default);
|
||
|
||
int rowIndex = 0;
|
||
while ((strline = mysr.ReadLine()) != null)
|
||
{
|
||
rowIndex += 1;
|
||
if (readTitle)
|
||
{
|
||
if (rowIndex < 3 && InvID == "")
|
||
continue;// 欄位需要取：row 3 invId , row 4 欄位名稱也需要讀取完
|
||
else if (rowIndex <= 4 && InvID == "")
|
||
readTitle = false;
|
||
else { //inv
|
||
if (rowIndex <= 3) continue;
|
||
readTitle = false;
|
||
}
|
||
}
|
||
else if (rowIndex < 4) continue;
|
||
|
||
aryline = strline.Split(new char[] { ',' });
|
||
//填充資料並加入到datatable中
|
||
mydr = mycsvdt.NewRow();
|
||
if (InvID != "")
|
||
{ // hour
|
||
for (int i = 0; i < intColCount - 1; i++)
|
||
{
|
||
mydr[i] = aryline[i];
|
||
}
|
||
if (!string.IsNullOrEmpty(InvID))
|
||
mydr["inv"] = InvID;
|
||
}
|
||
else
|
||
{ // day
|
||
for (int i = 0; i < intColCount; i++)
|
||
mydr[i] = aryline[i];
|
||
}
|
||
mycsvdt.Rows.Add(mydr);
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
//throw (Stack.GetErrorStack(strpath + "讀取CSV檔案中的資料出錯." + e.Message, " readCsvFile"));
|
||
throw ex;
|
||
return false;
|
||
}
|
||
return true;
|
||
}
|
||
|
||
|
||
public void taoYuan_createColumnHour(ref DataTable mycsvdt, string filepath)
|
||
{
|
||
string strpath = filepath; //csv檔案的路徑
|
||
try
|
||
{
|
||
int intColCount = 0;
|
||
bool blnFlag = true;
|
||
|
||
DataColumn mydc;
|
||
|
||
string strline;
|
||
string[] aryline;
|
||
StreamReader mysr = new StreamReader(strpath, System.Text.Encoding.Default);
|
||
|
||
int rowIndex = 0;
|
||
while ((strline = mysr.ReadLine()) != null)
|
||
{
|
||
rowIndex += 1;
|
||
if (rowIndex < 4) continue;
|
||
aryline = strline.Split(new char[] { ',' });
|
||
|
||
//給datatable加上列名
|
||
if (blnFlag)
|
||
{
|
||
blnFlag = false;
|
||
intColCount = aryline.Length;
|
||
int col = 0;
|
||
for (int i = 0; i < aryline.Length; i++)
|
||
{
|
||
col = i + 1;
|
||
mydc = new DataColumn(col.ToString());
|
||
mycsvdt.Columns.Add(mydc);
|
||
}
|
||
}
|
||
break;
|
||
}
|
||
|
||
}
|
||
catch (Exception e)
|
||
{
|
||
//throw (Stack.GetErrorStack(strpath + "讀取CSV檔案中的資料出錯." + e.Message, "OpenCSVFile("));
|
||
//return false;
|
||
}
|
||
}
|
||
/// <summary>
|
||
/// 太陽能光電 桃園全虹
|
||
/// </summary>
|
||
/// <param name="mycsvdt"></param>
|
||
/// <param name="filepath"></param>
|
||
/// <param name="InvID"></param>
|
||
/// <param name="intColCount"></param>
|
||
/// <param name="readTitle"></param>
|
||
/// <returns></returns>
|
||
public bool taoYuan_readCsvFile(ref DataTable mycsvdt, string filepath, int intColCount, bool readTitle)
|
||
{
|
||
string strpath = filepath; //csv檔案的路徑
|
||
try
|
||
{
|
||
DataColumn mydc;
|
||
DataRow mydr;
|
||
|
||
string strline;
|
||
string[] aryline;
|
||
StreamReader mysr = new StreamReader(strpath, System.Text.Encoding.Default);
|
||
|
||
int rowIndex = 0;
|
||
while ((strline = mysr.ReadLine()) != null)
|
||
{
|
||
rowIndex += 1;
|
||
if (readTitle && rowIndex == 1) {
|
||
readTitle = false;
|
||
continue;
|
||
}
|
||
|
||
aryline = strline.Split(new char[] { ',' });
|
||
//填充資料並加入到datatable中
|
||
mydr = mycsvdt.NewRow();
|
||
|
||
for (int i = 0; i < intColCount - 1; i++)
|
||
{
|
||
mydr[i] = aryline[i];
|
||
}
|
||
mycsvdt.Rows.Add(mydr);
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
//throw (Stack.GetErrorStack(strpath + "讀取CSV檔案中的資料出錯." + e.Message, " readCsvFile"));
|
||
throw ex;
|
||
return false;
|
||
}
|
||
return true;
|
||
}
|
||
|
||
public bool clear_inv(string timeType)
|
||
{
|
||
bool result = false;
|
||
StringBuilder ss = new StringBuilder();
|
||
using (MySqlConnection conn = new MySqlConnection(Connection1))
|
||
{
|
||
conn.Open();
|
||
switch (timeType)
|
||
{
|
||
case "hour": ss.Append("truncate table solar_import.src_inv;"); break;
|
||
case "day": ss.Append("truncate table solar_import.src_inv_day;"); break;
|
||
}
|
||
conn.Execute(ss.ToString());
|
||
conn.Clone();
|
||
}
|
||
return false;
|
||
}
|
||
|
||
public void taoYuan_insertHour2DB(ref DataTable dt, string dest_table)
|
||
{
|
||
List<src_inv_count> ds;
|
||
StringBuilder ss = new StringBuilder();
|
||
using (MySqlConnection conn = new MySqlConnection(Connection1))
|
||
{
|
||
conn.Open();
|
||
ss.Clear();
|
||
|
||
int i = 0;
|
||
foreach (DataRow row in dt.Rows) //sun_taoyuan
|
||
{
|
||
ss.Append(@"insert into solar_import."+ dest_table + @"(c1 , c2 , c3 , c4 , c5 , c6 , c7 , c8 , c9 , c10, c11, c12, c13, c14, c15, c16, c17, c18, c19, c20, c21, c22, c23, c24, c25, c26, c27, c28, c29, c30, c31, c32, c33, c34, c35, c36, c37, c38, c39, c40, c41, c42, c43, c44, c45, c46, c47, c48, c49, c50, c51, c52, c53, c54, c55, c56, c57, c58)
|
||
values( '" + row.Field<string>("1").ToString() + "', " +
|
||
"'" + row.Field<string>("2").ToString() + "' , " +
|
||
"'" + row.Field<string>("3").ToString() + "' , " +
|
||
"'" + row.Field<string>("4").ToString() + "' , " +
|
||
"'" + row.Field<string>("5").ToString() + "' , " +
|
||
"'" + row.Field<string>("6").ToString() + "' , " +
|
||
"'" + row.Field<string>("7").ToString() + "' , " +
|
||
"'" + row.Field<string>("8").ToString() + "' , " +
|
||
"'" + row.Field<string>("9").ToString() + "' , " +
|
||
"'" + row.Field<string>("10").ToString() + "' ," +
|
||
"'" + row.Field<string>("11").ToString() + "' ," +
|
||
"'" + row.Field<string>("12").ToString() + "' ," +
|
||
"'" + row.Field<string>("13").ToString() + "' ," +
|
||
"'" + row.Field<string>("14").ToString() + "' ," +
|
||
"'" + row.Field<string>("15").ToString() + "' ," +
|
||
"'" + row.Field<string>("16").ToString() + "' ," +
|
||
"'" + row.Field<string>("17").ToString() + "' ," +
|
||
"'" + row.Field<string>("18").ToString() + "' ," +
|
||
"'" + row.Field<string>("19").ToString() + "' ," +
|
||
"'" + row.Field<string>("20").ToString() + "' ," +
|
||
"'" + row.Field<string>("21").ToString() + "' ," +
|
||
"'" + row.Field<string>("22").ToString() + "' ," +
|
||
"'" + row.Field<string>("23").ToString() + "' ," +
|
||
"'" + row.Field<string>("24").ToString() + "' ," +
|
||
"'" + row.Field<string>("25").ToString() + "' ," +
|
||
"'" + row.Field<string>("26").ToString() + "' ," +
|
||
"'" + row.Field<string>("27").ToString() + "' ," +
|
||
"'" + row.Field<string>("28").ToString() + "' ," +
|
||
"'" + row.Field<string>("29").ToString() + "' ," +
|
||
"'" + row.Field<string>("30").ToString() + "' ," +
|
||
"'" + row.Field<string>("31").ToString() + "' ," +
|
||
"'" + row.Field<string>("32").ToString() + "' ," +
|
||
"'" + row.Field<string>("33").ToString() + "' ," +
|
||
"'" + row.Field<string>("34").ToString() + "' ," +
|
||
"'" + row.Field<string>("35").ToString() + "' ," +
|
||
"'" + row.Field<string>("36").ToString() + "' ," +
|
||
"'" + row.Field<string>("37").ToString() + "' ," +
|
||
"'" + row.Field<string>("38").ToString() + "' ," +
|
||
"'" + row.Field<string>("39").ToString() + "' ," +
|
||
"'" + row.Field<string>("40").ToString() + "' ," +
|
||
"'" + row.Field<string>("41").ToString() + "' ," +
|
||
"'" + row.Field<string>("42").ToString() + "' ," +
|
||
"'" + row.Field<string>("43").ToString() + "' ," +
|
||
"'" + row.Field<string>("44").ToString() + "' ," +
|
||
"'" + row.Field<string>("45").ToString() + "' ," +
|
||
"'" + row.Field<string>("46").ToString() + "' ," +
|
||
"'" + row.Field<string>("47").ToString() + "' ," +
|
||
"'" + row.Field<string>("48").ToString() + "' ," +
|
||
"'" + row.Field<string>("49").ToString() + "' ," +
|
||
"'" + row.Field<string>("50").ToString() + "' ," +
|
||
"'" + row.Field<string>("51").ToString() + "' ," +
|
||
"'" + row.Field<string>("52").ToString() + "' ," +
|
||
"'" + row.Field<string>("53").ToString() + "' ," +
|
||
"'" + row.Field<string>("54").ToString() + "' ," +
|
||
"'" + row.Field<string>("55").ToString() + "' ," +
|
||
"'" + row.Field<string>("56").ToString() + "' ," +
|
||
"'" + row.Field<string>("57").ToString() + "' ," +
|
||
"'" + row.Field<string>("58").ToString() + "' );");
|
||
|
||
if (i % 100 == 0)
|
||
{
|
||
conn.Execute(ss.ToString());
|
||
ss.Clear();
|
||
}
|
||
i++;
|
||
}
|
||
if (ss.Length > 0)
|
||
{
|
||
conn.Execute(ss.ToString());
|
||
ss.Clear();
|
||
}
|
||
//ss.Clear();
|
||
//ss.Append(@"select inv, left(c1, 10) date, count(*) ct from src_inv where c1 <> '欄位名稱' group by inv, left(c1, 10)");
|
||
//ds = conn.Query<src_inv_count>(ss.ToString()).AsList<src_inv_count>();
|
||
conn.Clone();
|
||
}
|
||
//return ds;
|
||
}
|
||
|
||
public List<src_inv_count> insertHour2DB(ref DataTable dt) {
|
||
List<src_inv_count> ds;
|
||
StringBuilder ss = new StringBuilder();
|
||
using (MySqlConnection conn = new MySqlConnection(Connection1))
|
||
{
|
||
conn.Open();
|
||
ss.Clear();
|
||
|
||
int i = 0;
|
||
foreach (DataRow row in dt.Rows)
|
||
{
|
||
ss.Append(@"insert into solar_import.src_inv(c1 ,c2 ,c3 ,c4 ,c5 ,c6 ,c7 ,c8 ,c9 ,c10 ,c11 ,c12 ,c13 ,c14 ,c15 ,c16 ,c17 ,c18 ,c19 ,inv)
|
||
values( '"+ row.Field<string>("1").ToString() + "' ,'" + row.Field<string>("2").ToString() + "' ,'" + row.Field<string>("3").ToString() + "' ," +
|
||
"'" + row.Field<string>("4").ToString() + "' ,'" + row.Field<string>("5").ToString() + "' ,'" + row.Field<string>("6").ToString() + "' ," +
|
||
"'" + row.Field<string>("7").ToString() + "' ,'"+ row.Field<string>("8").ToString() + "' ,'" + row.Field<string>("9").ToString() + "' ," +
|
||
"'" + row.Field<string>("10").ToString() + "' ,'" + row.Field<string>("11").ToString() + "' ,'" + row.Field<string>("12").ToString() + "' ," +
|
||
"'" + row.Field<string>("13").ToString() + "' ,'" + row.Field<string>("14").ToString() + "' ,'" + row.Field<string>("15").ToString() + "' ," +
|
||
"'" + row.Field<string>("16").ToString() + "', '" + row.Field<string>("17").ToString() + "', '" + row.Field<string>("18").ToString() + "'," +
|
||
"'" + row.Field<string>("19").ToString() + "' ,'" + row.Field<string>("inv").ToString() + "' );");
|
||
|
||
if (i % 10 == 0)
|
||
{
|
||
conn.Execute(ss.ToString());
|
||
ss.Clear();
|
||
}
|
||
i++;
|
||
}
|
||
if (ss.Length > 0)
|
||
{
|
||
conn.Execute(ss.ToString());
|
||
ss.Clear();
|
||
}
|
||
ss.Clear();
|
||
ss.Append(@"select inv, left(c1, 10) date, count(*) ct from src_inv where c1 <> '欄位名稱' group by inv, left(c1, 10)");
|
||
ds = conn.Query<src_inv_count>(ss.ToString()).AsList<src_inv_count>();
|
||
conn.Clone();
|
||
}
|
||
return ds;
|
||
}
|
||
|
||
public bool insertDay2DB(ref DataTable dt)
|
||
{
|
||
bool result = false;
|
||
StringBuilder ss = new StringBuilder();
|
||
using (MySqlConnection conn = new MySqlConnection(Connection1))
|
||
{
|
||
conn.Open();
|
||
int i = 0;
|
||
foreach (DataRow row in dt.Rows)
|
||
{
|
||
ss.Append(@"INSERT INTO solar_import.src_inv_day( c1, c2, c3, c4, c5, c6, c7, c8, c9, c10, c11, c12, c13, c14, c15, c16, c17, c18, c19, c20, c21, c22, c23, c24, c25, c26, c27, c28, c29, c30, c31, c32, c33, c34, c35, c36, c37, c38, c39, c40, c41, c42, c43, c44, c45, c46, c47, c48, c49, c50, c51, c52, c53, c54, c55)
|
||
values( '"
|
||
+ row.Field<string>("1").ToString() + "' ,'"
|
||
+ row.Field<string>("2").ToString() + "' ,'"
|
||
+ row.Field<string>("3").ToString() + "' ,'"
|
||
+ row.Field<string>("4").ToString() + "' ,'"
|
||
+ row.Field<string>("5").ToString() + "' ,'"
|
||
+ row.Field<string>("6").ToString() + "' ,'"
|
||
+ row.Field<string>("7").ToString() + "' ,'"
|
||
+ row.Field<string>("8").ToString() + "' ,'"
|
||
+ row.Field<string>("9").ToString() + "' ,'"
|
||
+ row.Field<string>("10").ToString() + "' ,'"
|
||
+ row.Field<string>("11").ToString() + "' ,'"
|
||
+ row.Field<string>("12").ToString() + "' ,'"
|
||
+ row.Field<string>("13").ToString() + "' ,'"
|
||
+ row.Field<string>("14").ToString() + "' ,'"
|
||
+ row.Field<string>("15").ToString() + "' ,'"
|
||
+ row.Field<string>("16").ToString() + "' ,'"
|
||
+ row.Field<string>("17").ToString() + "' ,'"
|
||
+ row.Field<string>("18").ToString() + "' ,'"
|
||
+ row.Field<string>("19").ToString() + "' ,'"
|
||
+ row.Field<string>("20").ToString() + "' ,'"
|
||
+ row.Field<string>("21").ToString() + "' ,'"
|
||
+ row.Field<string>("22").ToString() + "' ,'"
|
||
+ row.Field<string>("23").ToString() + "' ,'"
|
||
+ row.Field<string>("24").ToString() + "' ,'"
|
||
+ row.Field<string>("25").ToString() + "' ,'"
|
||
+ row.Field<string>("26").ToString() + "' ,'"
|
||
+ row.Field<string>("27").ToString() + "' ,'"
|
||
+ row.Field<string>("28").ToString() + "' ,'"
|
||
+ row.Field<string>("29").ToString() + "' ,'"
|
||
+ row.Field<string>("30").ToString() + "' ,'"
|
||
+ row.Field<string>("31").ToString() + "' ,'"
|
||
+ row.Field<string>("32").ToString() + "' ,'"
|
||
+ row.Field<string>("33").ToString() + "' ,'"
|
||
+ row.Field<string>("34").ToString() + "' ,'"
|
||
+ row.Field<string>("35").ToString() + "' ,'"
|
||
+ row.Field<string>("36").ToString() + "' ,'"
|
||
+ row.Field<string>("37").ToString() + "' ,'"
|
||
+ row.Field<string>("38").ToString() + "' ,'"
|
||
+ row.Field<string>("39").ToString() + "' ,'"
|
||
+ row.Field<string>("40").ToString() + "' ,'"
|
||
+ row.Field<string>("41").ToString() + "' ,'"
|
||
+ row.Field<string>("42").ToString() + "' ,'"
|
||
+ row.Field<string>("43").ToString() + "' ,'"
|
||
+ row.Field<string>("44").ToString() + "' ,'"
|
||
+ row.Field<string>("45").ToString() + "' ,'"
|
||
+ row.Field<string>("46").ToString() + "' ,'"
|
||
+ row.Field<string>("47").ToString() + "' ,'"
|
||
+ row.Field<string>("48").ToString() + "' ,'"
|
||
+ row.Field<string>("49").ToString() + "' ,'"
|
||
+ row.Field<string>("50").ToString() + "' ,'"
|
||
+ row.Field<string>("51").ToString() + "' ,'"
|
||
+ row.Field<string>("52").ToString() + "' ,'"
|
||
+ row.Field<string>("53").ToString() + "' ,'"
|
||
+ row.Field<string>("54").ToString() + "' ,'"
|
||
+ row.Field<string>("55").ToString() + "');");
|
||
|
||
if (i % 10 == 0)
|
||
{
|
||
conn.Execute(ss.ToString());
|
||
ss.Clear();
|
||
}
|
||
i++;
|
||
}
|
||
if (ss.Length > 0)
|
||
{
|
||
conn.Execute(ss.ToString());
|
||
ss.Clear();
|
||
}
|
||
conn.Clone();
|
||
}
|
||
return result;
|
||
}
|
||
|
||
public bool archive_data(string timeType)
|
||
{
|
||
bool result = false;
|
||
string ss;
|
||
using (MySqlConnection conn = new MySqlConnection(Connection1))
|
||
{
|
||
conn.Open();
|
||
|
||
if (timeType == "hour")
|
||
{ //匯入小時資料哦
|
||
// 1.src_day to master inv_day
|
||
ss = @" delete from solar_master.inverter_history_hour where powerStationID = 22;
|
||
|
||
INSERT INTO solar_master.inverter_history_hour(PowerStationId, INVERTERID, `TIMESTAMP`, Irradiance,
|
||
AC1V, AC1A, AC1W, AC1F, AC1WH, AC2V, AC2A, AC2W, AC2F, AC2WH, AC3V, AC3A, AC3W, AC3F, AC3WH,
|
||
DC1V, DC1A, DC1W, DC1KW, DC1WH, DC2V, DC2A, DC2W, DC2KW, DC2WH, DC3V, DC3A, DC3W, DC3KW, DC3WH, DC4V, DC4A, DC4W, DC4KW, DC4WH, DC5V, DC5A, DC5W, DC5KW, DC5WH,
|
||
PR, RA1, RA2, RA3, RA4, RA5, DCKW, ACKW, KWH, TODAYKWH, TOTALKWH, KWHKWP)
|
||
|
||
select 22 as PowerStationId, invId, reportdate, irr,
|
||
AC1V, AC1A, 0, 0, 0,
|
||
AC2V, AC2A, 0, 0, 0,
|
||
AC3V, AC3A, 0, 0, 0,
|
||
DC1V, DC1A, DC1W, 0, 0,
|
||
DC2V, DC2A, DC2W, 0, 0,
|
||
0, 0, 0, 0, 0,
|
||
0, 0, 0, 0, 0,
|
||
0, 0, 0, 0, 0,
|
||
0 as PR, RA as RA1, 0, 0, 0, 0,
|
||
0 as DCKW, 0 as ACKW, wh as 'KWH', wh as TODAYKWH, wh as TOTALKWH, 0 as KWHKWP
|
||
from solar_import.v_inv_hour_hj ;";
|
||
conn.Execute(ss);
|
||
}
|
||
else
|
||
{//匯入 day 資料
|
||
// 1.src_day to master inv_day
|
||
ss = @" delete from solar_master.inverter_history_day where powerStationID = 22;
|
||
|
||
insert into solar_master.inverter_history_day(powerStationID, inverterID, `TIMESTAMP`, irradiance, PR, kwh, todayKWH, totalKWh, kwhkwp)
|
||
select '22' as powerStationID, CONCAT('0802500010100', right(a.inv, 2) ) invID, concat(a.reportDate,' 00:00:00') ts, round(a.irr, 8) irr,
|
||
round(a.pr, 8) pr, round(a.kwh, 8)kwh, round((a.totalkWh - b.totalkWh), 8) as todaykWh, round(a.totalkWh, 8) totalkWh, round(a.kwhkwp, 8)kwhkwp
|
||
from solar_import.v_inv_day_huijing a join
|
||
( # 把今天的值 放到明天
|
||
select reportDate, DATE(DATE_ADD(reportDate, INTERVAL +1 DAY)) day_1, totalkWh, inv
|
||
from solar_import.v_inv_day_huijing
|
||
)b on a.inv = b.inv and a.reportDate = b.day_1;";
|
||
conn.Execute(ss);
|
||
|
||
// 2.month
|
||
ss = @" delete from solar_master.inverter_history_month where powerStationID = 22;
|
||
|
||
insert into solar_master.inverter_history_month(powerstationid, inverterid, `TIMESTAMP`, irradiance, PR, kwh, todayKWH, totalKWh, kwhkwp)
|
||
select 22 powerstationid, inverterid, concat(left(`TIMESTAMP`, 7), '-01 00:00:00') , avg(irradiance) irr,
|
||
avg(PR) PR, SUM(kwh) kwh, max(todaykwh)todaykwh, max(totalkwh)totalkwh, avg(kwhkwp) kwhkwp
|
||
from solar_master.inverter_history_day
|
||
where powerStationID = 22
|
||
group by left(`TIMESTAMP`, 7) , inverterid;";
|
||
conn.Execute(ss);
|
||
|
||
// 3.station day
|
||
ss = @" delete from solar_master.power_station_history_day where powerstationID = 22;
|
||
INSERT INTO solar_master.power_station_history_day( PowerStationId, `TIMESTAMP`, SITEID, SITETYPE, TODAYKWH, TOTALKWH, KWHKWP,
|
||
PR, MP, SOLARHOUR, MONEY, TOTALMONEY, CARBON, TOTALCARBON)
|
||
select b.id PowerStationId, a.reportdate, b.siteID, a.siteType, a.TODAYKWH, a.TOTALKWH, a.KWHKWP, a.PR, a.MP, a.SOLARHOUR,
|
||
(KWH * PowerRate) MONEY, (a.TOTALKWH * PowerRate) TOTALMONEY,
|
||
(KWH * CarbonRate) CARBON, round((a.TOTALKWH * CarbonRate), 4) TOTALCARBON
|
||
from
|
||
(
|
||
select concat(DATE_FORMAT(`TIMESTAMP`,'%Y-%m-%d'), ' 00:00:00') reportdate, '080250001' siteid, 0 siteType, round((sum(KWH)), 6) KWH,
|
||
round((sum(TODAYKWH)), 6) TODAYKWH, round((max(TOTALKWH)), 6) TOTALKWH, round((avg(KWHKWP)), 6) KWHKWP,
|
||
round((avg(PR)), 6) PR, 0 as MP, 0 SOLARHOUR
|
||
from solar_master.inverter_history_day a
|
||
where powerstationID = 22 and DATE_FORMAT(a.`TIMESTAMP`,'%Y-%m-%d') between '2020-01-01' and '2021-08-31'
|
||
group by powerstationID, DATE_FORMAT(`TIMESTAMP`,'%Y-%m-%d')
|
||
)a join
|
||
(
|
||
select id, `code` siteID, PowerRate, (select `value` from solar_master.`variable` where `name` = 'CarbonRate') as CarbonRate, SolarType
|
||
from solar_master.power_station
|
||
where `code` = '080250001'
|
||
) b on a.siteID = b.siteID ;";
|
||
conn.Execute(ss);
|
||
|
||
|
||
// 4.station month
|
||
ss = @" delete from solar_master.power_station_history_month where powerstationID = 22;
|
||
INSERT INTO solar_master.power_station_history_month( PowerStationId, `TIMESTAMP`, SITEID, SITETYPE, MonthKWH, TOTALKWH, KWHKWP,
|
||
PR, MP, SOLARHOUR, MONEY, TOTALMONEY, CARBON, TOTALCARBON)
|
||
|
||
select b.id PowerStationId, a.reportdate, b.siteID, a.siteType, a.MonthKWH, a.TOTALKWH, a.KWHKWP, a.PR, a.MP, a.SOLARHOUR,
|
||
(MonthKWH * PowerRate) MONEY, (a.TOTALKWH * PowerRate) TOTALMONEY,
|
||
(MonthKWH * CarbonRate) CARBON, round((a.TOTALKWH * CarbonRate), 4) TOTALCARBON
|
||
from
|
||
(
|
||
select concat(DATE_FORMAT(`TIMESTAMP`,'%Y-%m'), '-01 00:00:00') reportdate, '080250001' siteid, 0 siteType,
|
||
round((sum(TODAYKWH)), 6) MonthKWH, round((max(TOTALKWH)), 6) TOTALKWH, round((avg(KWHKWP)), 6) KWHKWP,
|
||
round((avg(PR)), 6) PR, 0 as MP, 0 SOLARHOUR
|
||
from solar_master.power_station_history_day a
|
||
where powerstationID = 22 and DATE_FORMAT(a.`TIMESTAMP`,'%Y-%m') between '2020-01' and '2021-08'
|
||
group by powerstationID, DATE_FORMAT(a.`TIMESTAMP`,'%Y-%m')
|
||
)a join
|
||
(
|
||
select id, `code` siteID, PowerRate, (select `value` from solar_master.`variable` where `name` = 'CarbonRate') as CarbonRate, SolarType
|
||
from solar_master.power_station
|
||
where `code` = '080250001'
|
||
) b on a.siteID = b.siteID ;";
|
||
conn.Execute(ss);
|
||
|
||
// 5. sensor day
|
||
ss = @" delete from solar_master.sensor_history_day where powerstationID = 22;
|
||
insert solar_master.sensor_history_day(powerStationID, `TIMESTAMP`, irradiance, Temperature)
|
||
select 22 powerstationid, concat(left(`TIMESTAMP`, 10), ' 00:00:00') , round(avg(irradiance), 6) irradiance , 0 Temperature
|
||
from solar_master.inverter_history_day
|
||
where powerStationID = 22
|
||
group by left(`TIMESTAMP`, 10) ;";
|
||
conn.Execute(ss);
|
||
|
||
// 6. sensor month
|
||
ss = @" delete from solar_master.sensor_history_month where powerstationID = 22;
|
||
insert solar_master.sensor_history_month(powerStationID, `TIMESTAMP`, irradiance, Temperature)
|
||
select 22 powerstationid, concat(left(`TIMESTAMP`, 7), '-01 00:00:00') , round(avg(irradiance), 6) irradiance , 0 Temperature
|
||
from solar_master.inverter_history_day
|
||
where powerStationID = 22
|
||
group by left(`TIMESTAMP`, 7);";
|
||
conn.Execute(ss);
|
||
}
|
||
}
|
||
return result;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 建立 view, 已建立 目前用不到
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
public bool create_view()
|
||
{
|
||
bool result = false;
|
||
string ss;
|
||
using (MySqlConnection conn = new MySqlConnection(Connection1))
|
||
{
|
||
conn.Open();
|
||
int i = 0;
|
||
// 1.src_day to master inv_day
|
||
ss = @" create view v_inv_hour_hj as
|
||
select
|
||
c1 as reportdate
|
||
,round(c2 , 6) as DC2A
|
||
,round(c3 , 6) as DC1A
|
||
,round(c4 , 6) as wh
|
||
,round(c5 , 6) as DC2W
|
||
,round(c6 , 6) as DC1W
|
||
,round(c7 , 6) as DC1V
|
||
,round(c8 , 6) as DC2V
|
||
,round(c9 , 6) as irr
|
||
,round(c10, 6) as RA
|
||
#,c11 as (c6 + c5) / 1000
|
||
,round(c12, 6) as AC1A
|
||
,round(c13, 6) as AC2A
|
||
,round(c14, 6) as AC3A
|
||
,round(c15, 6) as AC1V
|
||
,round(c16, 6) as AC2V
|
||
,round(c17, 6) as AC3V
|
||
-- ,c18 機內溫度(°C)
|
||
-- ,c19 裝置容量(kWp)
|
||
,CONCAT('0802500010100', right(inv, 2) ) as invID
|
||
from src_inv
|
||
where c1 <> '欄位名稱';";
|
||
conn.Execute(ss);
|
||
|
||
ss = @"create view v_inv_day_huijing
|
||
as
|
||
select
|
||
c1 reportDate,
|
||
round(c2 , 6) as kWp,
|
||
round(c3 , 6) as kWh,
|
||
round(c4 , 6) as irr,
|
||
round(c5 , 6) as kwhkwp,
|
||
round(c6 , 6) as totalkWh,
|
||
round(c7 , 6) as PR,
|
||
(select inv1 from v_invID_day_huijing) inv
|
||
from src_inv_day
|
||
where c1 not in ('裝置名稱', '欄位名稱')
|
||
union
|
||
select
|
||
c1 reportDate,
|
||
round(c8 , 6) as kWp,
|
||
round(c9 , 6) as kWh,
|
||
round(c10, 6) as irr,
|
||
round(c11, 6) as kwhkwp,
|
||
round(c12, 6) as totalkWh,
|
||
round(c13, 6) as PR,
|
||
(select inv2 from v_invID_day_huijing) inv
|
||
from src_inv_day
|
||
where c1 not in ('裝置名稱', '欄位名稱')
|
||
union
|
||
select
|
||
c1 reportDate,
|
||
round(c14, 6) as kWp,
|
||
round(c15, 6) as kWh,
|
||
round(c16, 6) as irr,
|
||
round(c17, 6) as kwhkwp,
|
||
round(c18, 6) as totalkWh,
|
||
round(c19, 6) as PR,
|
||
(select inv3 from v_invID_day_huijing) inv
|
||
from src_inv_day
|
||
where c1 not in ('裝置名稱', '欄位名稱')
|
||
union
|
||
select
|
||
c1 reportDate,
|
||
round(c20, 6) as kWp,
|
||
round(c21, 6) as kWh,
|
||
round(c22, 6) as irr,
|
||
round(c23, 6) as kwhkwp,
|
||
round(c24, 6) as totalkWh,
|
||
round(c25, 6) as PR,
|
||
(select inv4 from v_invID_day_huijing) inv
|
||
from src_inv_day
|
||
where c1 not in ('裝置名稱', '欄位名稱')
|
||
union
|
||
select
|
||
c1 reportDate,
|
||
round(c26, 6) as kWp,
|
||
round(c27, 6) as kWh,
|
||
round(c28, 6) as irr,
|
||
round(c29, 6) as kwhkwp,
|
||
round(c30, 6) as totalkWh,
|
||
round(c31, 6) as PR,
|
||
(select inv5 from v_invID_day_huijing) inv
|
||
from src_inv_day
|
||
where c1 not in ('裝置名稱', '欄位名稱')
|
||
union
|
||
select
|
||
c1 reportDate,
|
||
round(c32, 6) as kWp,
|
||
round(c33, 6) as kWh,
|
||
round(c34, 6) as irr,
|
||
round(c35, 6) as kwhkwp,
|
||
round(c36, 6) as totalkWh,
|
||
round(c37, 6) as PR,
|
||
(select inv6 from v_invID_day_huijing) inv
|
||
from src_inv_day
|
||
where c1 not in ('裝置名稱', '欄位名稱')
|
||
union
|
||
select
|
||
c1 reportDate,
|
||
round(c38, 6) as kWp,
|
||
round(c39, 6) as kWh,
|
||
round(c40, 6) as irr,
|
||
round(c41, 6) as kwhkwp,
|
||
round(c42, 6) as totalkWh,
|
||
round(c43, 6) as PR,
|
||
(select inv7 from v_invID_day_huijing) inv
|
||
from src_inv_day
|
||
where c1 not in ('裝置名稱', '欄位名稱')
|
||
union
|
||
select
|
||
c1 reportDate,
|
||
round(c44, 6) as kWp,
|
||
round(c45, 6) as kWh,
|
||
round(c46, 6) as irr,
|
||
round(c47, 6) as kwhkwp,
|
||
round(c48, 6) as totalkWh,
|
||
round(c49, 6) as PR,
|
||
(select inv8 from v_invID_day_huijing) inv
|
||
from src_inv_day
|
||
where c1 not in ('裝置名稱', '欄位名稱')
|
||
union
|
||
select
|
||
c1 reportDate,
|
||
round(c50, 6) as kWp,
|
||
round(c51, 6) as kWh,
|
||
round(c52, 6) as irr,
|
||
round(c53, 6) as kwhkwp,
|
||
round(c54, 6) as totalkWh,
|
||
round(c55, 6) as PR,
|
||
(select inv9 from v_invID_day_huijing) inv
|
||
from src_inv_day
|
||
where c1 not in ('裝置名稱', '欄位名稱');
|
||
|
||
create view v_invID_day_huijing as
|
||
select c2 as inv1, c8 as inv2, c14 as inv3, c20 as inv4, c26 as inv5, c32 as inv6, c38 as inv7, c44 as inv8, c50 as inv9
|
||
from src_inv_day where c1 = '裝置名稱';";
|
||
conn.Execute(ss);
|
||
}
|
||
return result;
|
||
}
|
||
}
|
||
}
|
||
|