874 lines
53 KiB
C#
874 lines
53 KiB
C#
using Microsoft.AspNetCore.Hosting;
|
||
using Microsoft.Extensions.Hosting;
|
||
using Microsoft.Extensions.Logging;
|
||
using Newtonsoft.Json;
|
||
using Quartz;
|
||
using SolarPower.Models.PowerStation;
|
||
using SolarPower.Repository.Interface;
|
||
using System;
|
||
using System.Collections.Generic;
|
||
using System.Linq;
|
||
using System.Net.Http;
|
||
using System.Threading.Tasks;
|
||
|
||
namespace SolarPower.Quartz.Jobs
|
||
{
|
||
[DisallowConcurrentExecution]
|
||
public class CalcPowerStationJob : IJob
|
||
{
|
||
private readonly ILogger<CalcPowerStationJob> logger;
|
||
private readonly IPowerStationRepository powerStationRepository;
|
||
|
||
public IWebHostEnvironment environment;
|
||
|
||
private double carbonRate;
|
||
|
||
public CalcPowerStationJob(
|
||
ILogger<CalcPowerStationJob> logger,
|
||
IPowerStationRepository powerStationRepository,
|
||
IWebHostEnvironment environment)
|
||
{
|
||
this.logger = logger;
|
||
this.powerStationRepository = powerStationRepository;
|
||
this.environment = environment;
|
||
}
|
||
|
||
public async Task Execute(IJobExecutionContext context)
|
||
{
|
||
try
|
||
{
|
||
var DateTimeNow = DateTime.Now;
|
||
var dateTime = DateTimeNow.AddHours(-1).ToString("yyyy-MM-dd HH");
|
||
|
||
Root2 observation = null;
|
||
|
||
if (this.environment.IsDevelopment())
|
||
{
|
||
dateTime = "2021-08-16 09";
|
||
}
|
||
|
||
logger.LogInformation("【CalcPowerStationJob】【任務開始】");
|
||
|
||
#region step1. 找出所有電站
|
||
logger.LogInformation("【CalcPowerStationJob】【開始取得電站資料】");
|
||
var powerStations = await powerStationRepository.GetAllAsync();
|
||
logger.LogInformation("【CalcPowerStationJob】【取得成功電站資料】");
|
||
logger.LogInformation("【CalcPowerStationJob】【電站資料】 - {0}", System.Text.Json.JsonSerializer.Serialize(powerStations));
|
||
#endregion
|
||
|
||
List<PowerStationHistory> powerStationHistoriesHour = new List<PowerStationHistory>();
|
||
List<PyrheliometerHistory> sensorHistoriesHour = new List<PyrheliometerHistory>();
|
||
|
||
List<PyrheliometerHistory> pyrheliometerHistoriesHour = new List<PyrheliometerHistory>();
|
||
List<PyrheliometerHistory> TempHistoriesHour = new List<PyrheliometerHistory>();
|
||
List<InverterHistory> inverterHistoriesHour = new List<InverterHistory>();
|
||
List<PowerStation> calcPowerStations = new List<PowerStation>();
|
||
List<SensorAvgHistory> sensorAvgHistoryHour = new List<SensorAvgHistory>();
|
||
List<MeterHistory> meterHistoriesHour = new List<MeterHistory>();
|
||
List<WeatherObservation> weatherObservations = new List<WeatherObservation>();
|
||
|
||
#region 氣象觀測(取資料)
|
||
try
|
||
{
|
||
logger.LogInformation("【CalcPowerStationJob】【開始取得氣象觀測】");
|
||
var client = new HttpClient();
|
||
var UVUri = "https://opendata.cwb.gov.tw/api/v1/rest/datastore/O-A0003-001?Authorization=CWB-EA24220B-DDCC-4188-84E5-AD37A0E03F80&elementName=TIME,TEMP";
|
||
HttpResponseMessage response = client.GetAsync(UVUri).Result;
|
||
String jsonUVs = response.Content.ReadAsStringAsync().Result.ToString();
|
||
observation = JsonConvert.DeserializeObject<Root2>(jsonUVs);
|
||
logger.LogInformation("【CalcPowerStationJob】【取得成功氣象觀測】");
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
logger.LogError("【CalcPowerStationJob】【取得失敗氣象觀測】");
|
||
logger.LogError("【{0}】{1}", "CalcPowerStationJob", ex.Message);
|
||
observation = null;
|
||
}
|
||
|
||
|
||
#endregion
|
||
|
||
#region step2. 從電站的DB及電站編號找出該電站的控制器
|
||
foreach (var powerStation in powerStations)
|
||
{
|
||
try
|
||
{
|
||
var calcPowerStation = new PowerStation();
|
||
calcPowerStation.Id = powerStation.Id;
|
||
|
||
#region step2-1. 取得該電站的當前這小時的歷史資料
|
||
var table_name = String.Format("s{1}01_station", powerStation.SiteDB, powerStation.Code);
|
||
var full_table_name = String.Format("`{0}`.`{1}`", powerStation.SiteDB, table_name);
|
||
var exist = await powerStationRepository.ExistTable(powerStation.SiteDB, table_name);
|
||
|
||
if (string.IsNullOrEmpty(exist))
|
||
{
|
||
logger.LogError("【CalcPowerStationJob】【查無電站[{0}]的s{0}01_station資料表】", powerStation.Code);
|
||
}
|
||
else
|
||
{
|
||
logger.LogInformation("【CalcPowerStationJob】【開始取得電站[{0}]在{1}的每小時歷史資料】", powerStation.Code, dateTime);
|
||
var history = await powerStationRepository.GetPowerStationHistoryPerHour(dateTime, full_table_name);
|
||
logger.LogInformation("【CalcPowerStationJob】【取得成功電站[{0}]在{1}的每小時歷史資料】", powerStation.Code, dateTime);
|
||
logger.LogInformation("【CalcPowerStationJob】【電站[{0}]在{1}的每小時歷史資料】 - {2}", powerStation.Code, dateTime, System.Text.Json.JsonSerializer.Serialize(history));
|
||
var lastmoneyhistorybyhour = await powerStationRepository.GetLastMoneyAndCarbonInHour(powerStation.Id, 0, dateTime);
|
||
|
||
if (history != null)
|
||
{
|
||
logger.LogInformation("【CalcPowerStationJob】【開始計算電站[{0}]在{1}的每小時歷史資料】", powerStation.Code, dateTime);
|
||
history.PowerStationId = powerStation.Id;
|
||
history.Timestamp = Convert.ToDateTime(history.Timestamp + ":00:00").ToString("yyyy-MM-dd HH:mm:ss");
|
||
|
||
#region 計算單一電站每小時發電量、發電金額等資料
|
||
|
||
#region 發電量
|
||
//每小時發電量(直接填寫
|
||
calcPowerStation.kwh = history.KWH;
|
||
//今日發電量(直接填寫
|
||
calcPowerStation.Today_kWh = history.TodayKWh;
|
||
//總發電量(直接填寫
|
||
calcPowerStation.Total_kWh = history.TotalKWH;
|
||
#endregion
|
||
|
||
#region 發電金額
|
||
|
||
history.MONEY = history.KWH * powerStation.PowerRate;
|
||
|
||
//即時發電金額
|
||
switch (powerStation.SolarType)
|
||
{
|
||
case (int)SolarTypeEnum.SelfSold: //自建躉售
|
||
|
||
if (lastmoneyhistorybyhour != null)
|
||
{
|
||
history.TODAYMONEY = lastmoneyhistorybyhour.TODAYMONEY + history.KWH * powerStation.PowerRate;
|
||
history.TOTALMONEY = lastmoneyhistorybyhour.TOTALMONEY + history.KWH * powerStation.PowerRate;
|
||
}
|
||
else
|
||
{
|
||
history.TODAYMONEY = history.KWH * powerStation.PowerRate;
|
||
history.TOTALMONEY = history.KWH * powerStation.PowerRate;
|
||
}
|
||
|
||
//今日發電金額 計算方式：todaykWh * 授電費率，如有上筆資料，需累加 上一筆金額
|
||
//calcPowerStation.Today_Money = history.TodayKWh * powerStation.PowerRate;
|
||
calcPowerStation.Today_Money = history.TODAYMONEY;
|
||
|
||
////總發電金額 計算方式：totalkWh * 授電費率，如有上筆資料，需累加 上一筆金額
|
||
//calcPowerStation.Total_Money = history.TotalKWH * powerStation.PowerRate;
|
||
calcPowerStation.Total_Money = history.TOTALMONEY;
|
||
break;
|
||
case (int)SolarTypeEnum.HireSold: //租建躉售
|
||
//找出該電站的所有土地房屋資訊
|
||
var landBuildings = await powerStationRepository.GetAllLandBuildingInfoByPowerStationId(powerStation.Id, powerStation.SiteDB);
|
||
var sumLeaseRate = 0.00;
|
||
var avgLeaseRate = 0.00;
|
||
|
||
foreach (var landBuilding in landBuildings)
|
||
{
|
||
sumLeaseRate += landBuilding.LeaseRate;
|
||
}
|
||
//avgLeaseRate = sumLeaseRate / landBuildings.Count();
|
||
|
||
if (lastmoneyhistorybyhour != null)
|
||
{
|
||
history.TODAYMONEY = lastmoneyhistorybyhour.TODAYMONEY + history.KWH * powerStation.PowerRate;
|
||
history.TOTALMONEY = lastmoneyhistorybyhour.TOTALMONEY + history.KWH * powerStation.PowerRate;
|
||
|
||
//今日發電金額計算方式：todaykWh * 出借費率(各個土地房屋租借比率平均)
|
||
calcPowerStation.Today_Money = lastmoneyhistorybyhour.TODAYMONEY + (history.KWH * powerStation.PowerRate * sumLeaseRate);
|
||
//總發電金額 計算方式：totalkWh * 授電費率
|
||
calcPowerStation.Total_Money = lastmoneyhistorybyhour.TOTALMONEY + (history.KWH * powerStation.PowerRate * sumLeaseRate);
|
||
}
|
||
else
|
||
{
|
||
history.TODAYMONEY = history.KWH * powerStation.PowerRate;
|
||
history.TOTALMONEY = history.KWH * powerStation.PowerRate;
|
||
|
||
calcPowerStation.Today_Money = history.KWH * powerStation.PowerRate * sumLeaseRate;
|
||
calcPowerStation.Total_Money = history.KWH * powerStation.PowerRate * sumLeaseRate;
|
||
}
|
||
break;
|
||
case (int)SolarTypeEnum.SelfUse: //自建自用
|
||
|
||
if (lastmoneyhistorybyhour != null)
|
||
{
|
||
history.TODAYMONEY = lastmoneyhistorybyhour.TODAYMONEY + history.KWH * powerStation.PowerRate;
|
||
history.TOTALMONEY = lastmoneyhistorybyhour.TOTALMONEY + history.KWH * powerStation.PowerRate;
|
||
}
|
||
else
|
||
{
|
||
history.TODAYMONEY = history.KWH * powerStation.PowerRate;
|
||
history.TOTALMONEY = history.KWH * powerStation.PowerRate;
|
||
}
|
||
|
||
//今日發電金額 計算方式：todaykWh * 授電費率
|
||
calcPowerStation.Today_Money = history.TODAYMONEY;
|
||
|
||
//總發電金額 計算方式：totalkWh * 授電費率
|
||
calcPowerStation.Total_Money = history.TOTALMONEY;
|
||
break;
|
||
}
|
||
#endregion
|
||
|
||
#region kWh/kWp
|
||
//直接填寫
|
||
calcPowerStation.Today_kwhkwp = history.KWHKWP;
|
||
#endregion
|
||
|
||
#region PR
|
||
//直接填寫
|
||
calcPowerStation.Today_PR = history.PR;
|
||
#endregion
|
||
|
||
#region 減碳量
|
||
carbonRate = Convert.ToDouble(await powerStationRepository.GetOneVariableByName("CarbonRate"));
|
||
|
||
history.CARBON = history.KWH * carbonRate;
|
||
if (lastmoneyhistorybyhour != null)
|
||
{
|
||
history.TODAYCARBON = lastmoneyhistorybyhour.TODAYCARBON + history.KWH * carbonRate;
|
||
history.TOTALCARBON = lastmoneyhistorybyhour.TOTALCARBON + history.KWH * carbonRate;
|
||
|
||
//今日減碳量( 今日發電量 * (0.554/1000)[抓資料庫值]
|
||
calcPowerStation.Today_Carbon = history.TODAYCARBON;
|
||
|
||
//總減碳量(總發電量 * (0.554/1000)[抓資料庫值]
|
||
calcPowerStation.Total_Carbon = history.TOTALCARBON;
|
||
}
|
||
else
|
||
{
|
||
history.TODAYCARBON = history.KWH * carbonRate;
|
||
history.TOTALCARBON = history.KWH * carbonRate;
|
||
|
||
//今日減碳量( 今日發電量 * (0.554/1000)[抓資料庫值]
|
||
calcPowerStation.Today_Carbon = history.TODAYCARBON;
|
||
|
||
history.CARBON = history.KWH * carbonRate;
|
||
//總減碳量(總發電量 * (0.554/1000)[抓資料庫值]
|
||
calcPowerStation.Total_Carbon = history.TotalKWH * carbonRate;
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region 發電時間
|
||
calcPowerStation.SolarHour = history.SolarHour;
|
||
#endregion
|
||
#endregion
|
||
|
||
powerStationHistoriesHour.Add(history);
|
||
|
||
logger.LogInformation("【CalcPowerStationJob】【計算完成電站[{0}]在{1}的每小時歷史資料】", powerStation.Code, dateTime);
|
||
}
|
||
}
|
||
#endregion
|
||
|
||
#region step2-2. 取得該電站的當前這小時的設備歷史資料
|
||
var sensoravg_table_name = String.Format("s{1}01_sensoravg", powerStation.SiteDB, powerStation.Code);
|
||
var full_sensoravg_table_name = String.Format("`{0}`.`{1}`", powerStation.SiteDB, sensoravg_table_name);
|
||
var sensoravg_table_exist = await powerStationRepository.ExistTable(powerStation.SiteDB, sensoravg_table_name);
|
||
if (string.IsNullOrEmpty(sensoravg_table_exist))
|
||
{
|
||
logger.LogError("【CalcPowerStationJob】【查無電站[0]的s{0}01_sensoravg資料表】", powerStation.Code);
|
||
}
|
||
else
|
||
{
|
||
logger.LogInformation("【CalcPowerStationJob】【開始計算電站[{0}]在{1}的設備資訊】", powerStation.Code, dateTime);
|
||
PyrheliometerHistory sensorHistory = new PyrheliometerHistory();
|
||
sensorHistory.PowerStationId = powerStation.Id;
|
||
sensorHistory.Timestamp = Convert.ToDateTime(dateTime + ":00:00").ToString("yyyy-MM-dd HH:mm:ss");
|
||
|
||
//1. 計算該電站sensor平均值 - 日照計(PYR)
|
||
try
|
||
{
|
||
logger.LogInformation("【CalcPowerStationJob】【開始取得電站[{0}]在{1}的日照計設備資訊】", powerStation.Code, dateTime);
|
||
var deviceInfos = await powerStationRepository.GetListPyrheliometerByPowerStationId(powerStation.Id, powerStation.SiteDB);
|
||
logger.LogInformation("【CalcPowerStationJob】【取得成功電站[{0}]在{1}的日照計設備資訊】", powerStation.Code, dateTime);
|
||
logger.LogInformation("【CalcPowerStationJob】【電站[{0}]在{1}的日照計設備資訊】 - {2}", powerStation.Code, dateTime, System.Text.Json.JsonSerializer.Serialize(deviceInfos));
|
||
|
||
if (deviceInfos != null && deviceInfos.Count() > 0)
|
||
{
|
||
logger.LogInformation("【CalcPowerStationJob】【開始計算電站[{0}]在{1}的日照計的平均值】", powerStation.Code, dateTime);
|
||
var pyrheliometerHistory = await powerStationRepository.CalcSensorHistoryPerHour(dateTime, deviceInfos, Convert.ToInt32(SensorTypeEnum.PYR));
|
||
|
||
if (pyrheliometerHistory != null)
|
||
{
|
||
calcPowerStation.Today_irradiance = pyrheliometerHistory.Irradiance;
|
||
|
||
sensorHistory.Irradiance = pyrheliometerHistory.Irradiance;
|
||
|
||
//pyrheliometerHistory.Timestamp = Convert.ToDateTime(pyrheliometerHistory.Timestamp + ":00:00").ToString("yyyy-MM-dd HH:mm:ss");
|
||
//pyrheliometerHistory.PowerStationId = powerStation.Id;
|
||
//pyrheliometerHistoriesHour.Add(pyrheliometerHistory);
|
||
}
|
||
logger.LogInformation("【CalcPowerStationJob】【計算完成電站[{0}]在{1}的日照計的平均值】", powerStation.Code, dateTime);
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
logger.LogError("【CalcPowerStationJob】【計算失敗電站[{0}]在{1}的日照計的平均值】", powerStation.Code, dateTime);
|
||
logger.LogError("【CalcPowerStationJob】【失敗原因】- {0}", ex.Message);
|
||
}
|
||
|
||
//2. 計算該電站sensor平均值 - 模組溫度計(MTR)
|
||
try
|
||
{
|
||
logger.LogInformation("【CalcPowerStationJob】【開始取得電站[{0}]在{1}的模組溫度計設備資訊】", powerStation.Code, dateTime);
|
||
var tempdeviceInfos = await powerStationRepository.GetDeviceListByPowerStationIdAndType(powerStation.Id, "MTR", powerStation.SiteDB);
|
||
logger.LogInformation("【CalcPowerStationJob】【取得成功電站[{0}]在{1}的模組溫度計設備資訊】", powerStation.Code, dateTime);
|
||
logger.LogInformation("【CalcPowerStationJob】【電站[{0}]在{1}的模組溫度計設備資訊】 - {2}", powerStation.Code, dateTime, System.Text.Json.JsonSerializer.Serialize(tempdeviceInfos));
|
||
if (tempdeviceInfos != null && tempdeviceInfos.Count() > 0)
|
||
{
|
||
logger.LogInformation("【CalcPowerStationJob】【開始計算電站[{0}]在{1}的模組溫度計的平均值】", powerStation.Code, dateTime);
|
||
var tempHistory = await powerStationRepository.CalcSensorHistoryPerHour(dateTime, tempdeviceInfos, Convert.ToInt32(SensorTypeEnum.MTR));
|
||
if (tempHistory != null)
|
||
{
|
||
//tempHistory.Timestamp = Convert.ToDateTime(tempHistory.Timestamp + ":00:00").ToString("yyyy-MM-dd HH:mm:ss");
|
||
//tempHistory.PowerStationId = powerStation.Id;
|
||
//TempHistoriesHour.Add(tempHistory);
|
||
|
||
sensorHistory.Temperature = tempHistory.Temperature;
|
||
|
||
logger.LogInformation("【CalcPowerStationJob】【計算完成電站[{0}]在{1}的模組溫度計的平均值】", powerStation.Code, dateTime);
|
||
}
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
logger.LogError("【CalcPowerStationJob】【計算失敗電站[{0}]在{1}的模組溫度計的平均值】", powerStation.Code, dateTime);
|
||
logger.LogError("【CalcPowerStationJob】【失敗原因】- {0}", ex.Message);
|
||
}
|
||
|
||
//3. 計算該電站sensor平均值 - 環境溫度計(ETR)
|
||
try
|
||
{
|
||
logger.LogInformation("【CalcPowerStationJob】【開始取得電站[{0}]在{1}的環境溫度計設備資訊】", powerStation.Code, dateTime);
|
||
var ETRdeviceInfos = await powerStationRepository.GetDeviceListByPowerStationIdAndType(powerStation.Id, SensorTypeEnum.ETR.ToString(), powerStation.SiteDB);
|
||
logger.LogInformation("【CalcPowerStationJob】【取得成功電站[{0}]在{1}的環境溫度計設備資訊】", powerStation.Code, dateTime);
|
||
logger.LogInformation("【CalcPowerStationJob】【電站[{0}]在{1}的環境溫度計設備資訊】 - {2}", powerStation.Code, dateTime, System.Text.Json.JsonSerializer.Serialize(ETRdeviceInfos));
|
||
if (ETRdeviceInfos != null && ETRdeviceInfos.Count() > 0)
|
||
{
|
||
logger.LogInformation("【CalcPowerStationJob】【開始計算電站[{0}]在{1}的環境溫度計的平均值】", powerStation.Code, dateTime);
|
||
var ETRHistory = await powerStationRepository.CalcSensorHistoryPerHour(dateTime, ETRdeviceInfos, Convert.ToInt32(SensorTypeEnum.ETR));
|
||
if (ETRHistory != null)
|
||
{
|
||
sensorHistory.EnvTemperature = ETRHistory.EnvTemperature;
|
||
logger.LogInformation("【CalcPowerStationJob】【計算完成電站[{0}]在{1}的環境溫度計的平均溫度】", powerStation.Code, dateTime);
|
||
}
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
logger.LogError("【CalcPowerStationJob】【計算失敗電站[{0}]在{1}的環境溫度計的平均值】", powerStation.Code, dateTime);
|
||
logger.LogError("【CalcPowerStationJob】【失敗原因】- {0}", ex.Message);
|
||
}
|
||
|
||
//4. 計算該電站 - 環境濕度計(EMM)
|
||
try
|
||
{
|
||
logger.LogInformation("【CalcPowerStationJob】【開始取得電站[{0}]在{1}的環境濕度計設備資訊】", powerStation.Code, dateTime);
|
||
var EMMdeviceInfos = await powerStationRepository.GetDeviceListByPowerStationIdAndType(powerStation.Id, SensorTypeEnum.EMM.ToString(), powerStation.SiteDB);
|
||
logger.LogInformation("【CalcPowerStationJob】【取得成功電站[{0}]在{1}的環境濕度計設備資訊】", powerStation.Code, dateTime);
|
||
logger.LogInformation("【CalcPowerStationJob】【電站[{0}]在{1}的環境濕度計設備資訊】 - {2}", powerStation.Code, dateTime, System.Text.Json.JsonSerializer.Serialize(EMMdeviceInfos));
|
||
if (EMMdeviceInfos != null && EMMdeviceInfos.Count() > 0)
|
||
{
|
||
logger.LogInformation("【CalcPowerStationJob】【開始計算電站[{0}]在{1}的環境濕度計的平均值】", powerStation.Code, dateTime);
|
||
var EMMHistory = await powerStationRepository.CalcSensorHistoryPerHour(dateTime, EMMdeviceInfos, Convert.ToInt32(SensorTypeEnum.EMM));
|
||
if (EMMHistory != null)
|
||
{
|
||
sensorHistory.Humidity = EMMHistory.Humidity;
|
||
logger.LogInformation("【CalcPowerStationJob】【計算完成電站[{0}]在{1}的環境濕度計的平均值】", powerStation.Code, dateTime);
|
||
}
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
logger.LogError("【CalcPowerStationJob】【計算失敗電站[{0}]在{1}的環境濕度計的平均值】", powerStation.Code, dateTime);
|
||
logger.LogError("【CalcPowerStationJob】【失敗原因】- {0}", ex.Message);
|
||
}
|
||
|
||
//5. 計算該電站 - 風速計(VAN)
|
||
try
|
||
{
|
||
logger.LogInformation("【CalcPowerStationJob】【開始取得電站[{0}]在{1}的風速計設備資訊】", powerStation.Code, dateTime);
|
||
var VANdeviceInfos = await powerStationRepository.GetDeviceListByPowerStationIdAndType(powerStation.Id, SensorTypeEnum.VAN.ToString(), powerStation.SiteDB);
|
||
logger.LogInformation("【CalcPowerStationJob】【取得成功電站[{0}]在{1}的風速計設備資訊】", powerStation.Code, dateTime);
|
||
logger.LogInformation("【CalcPowerStationJob】【電站[{0}]在{1}的風速計設備資訊】 - {2}", powerStation.Code, dateTime, System.Text.Json.JsonSerializer.Serialize(VANdeviceInfos));
|
||
if (VANdeviceInfos != null && VANdeviceInfos.Count() > 0)
|
||
{
|
||
logger.LogInformation("【CalcPowerStationJob】【開始計算電站[{0}]在{1}的風速計的平均值】", powerStation.Code, dateTime);
|
||
var VANHistory = await powerStationRepository.CalcSensorHistoryPerHour(dateTime, VANdeviceInfos, Convert.ToInt32(SensorTypeEnum.VAN));
|
||
if (VANHistory != null)
|
||
{
|
||
sensorHistory.Vane = VANHistory.Vane;
|
||
logger.LogInformation("【CalcPowerStationJob】【計算完成電站[{0}]在{1}的風速計的平均值】", powerStation.Code, dateTime);
|
||
}
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
logger.LogError("【CalcPowerStationJob】【計算失敗電站[{0}]在{1}的風速計的平均值】", powerStation.Code, dateTime);
|
||
logger.LogError("【CalcPowerStationJob】【失敗原因】- {0}", ex.Message);
|
||
}
|
||
|
||
//5. 計算該電站 - 落塵計(FOM)
|
||
try
|
||
{
|
||
logger.LogInformation("【CalcPowerStationJob】【開始取得電站[{0}]在{1}的落塵計設備資訊】", powerStation.Code, dateTime);
|
||
var FOMdeviceInfos = await powerStationRepository.GetDeviceListByPowerStationIdAndType(powerStation.Id, SensorTypeEnum.FOM.ToString(), powerStation.SiteDB);
|
||
logger.LogInformation("【CalcPowerStationJob】【取得成功電站[{0}]在{1}的落塵計設備資訊】", powerStation.Code, dateTime);
|
||
logger.LogInformation("【CalcPowerStationJob】【電站[{0}]在{1}的落塵計設備資訊】 - {2}", powerStation.Code, dateTime, System.Text.Json.JsonSerializer.Serialize(FOMdeviceInfos));
|
||
if (FOMdeviceInfos != null && FOMdeviceInfos.Count() > 0)
|
||
{
|
||
logger.LogInformation("【CalcPowerStationJob】【開始計算電站[{0}]在{1}的落塵計的平均%】", powerStation.Code, dateTime);
|
||
var FOMHistory = await powerStationRepository.CalcSensorHistoryPerHour(dateTime, FOMdeviceInfos, Convert.ToInt32(SensorTypeEnum.FOM));
|
||
if (FOMHistory != null)
|
||
{
|
||
sensorHistory.Dust = FOMHistory.Dust;
|
||
logger.LogInformation("【CalcPowerStationJob】【計算完成電站[{0}]在{1}的落塵計的平均值】", powerStation.Code, dateTime);
|
||
}
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
logger.LogError("【CalcPowerStationJob】【計算失敗電站[{0}]在{1}的落塵計的平均值】", powerStation.Code, dateTime);
|
||
logger.LogError("【CalcPowerStationJob】【失敗原因】- {0}", ex.Message);
|
||
}
|
||
|
||
sensorHistoriesHour.Add(sensorHistory);
|
||
}
|
||
|
||
calcPowerStations.Add(calcPowerStation);
|
||
#endregion
|
||
|
||
#region step2-3. 計算該電站所有逆變器每小時值
|
||
|
||
var inverter_table_name = String.Format("s{0}01_inv", powerStation.Code);
|
||
var full_inverter_table_name = String.Format("`{0}`.`{1}`", powerStation.SiteDB, inverter_table_name);
|
||
var inverter_exist = await powerStationRepository.ExistTable(powerStation.SiteDB, inverter_table_name);
|
||
if (string.IsNullOrEmpty(inverter_exist))
|
||
{
|
||
logger.LogError("【CalcPowerStationJob】【查無電站[0]的s{0}01_inv資料表】", powerStation.Code);
|
||
}
|
||
else
|
||
{
|
||
try
|
||
{
|
||
logger.LogInformation("【CalcPowerStationJob】【開始取得電站[{0}]在{1}的逆變器設備資訊】", powerStation.Code, dateTime);
|
||
var controllers = await powerStationRepository.GetAllDeviceControllerId(powerStation.Id, powerStation.SiteDB);
|
||
var inverters = await powerStationRepository.InverterTable(controllers, powerStation.SiteDB);
|
||
var inverterIds = inverters.Where(x => x.Enabled == 1 && x.Status != 0).Select(x => x.InverterId).ToList();
|
||
logger.LogInformation("【CalcPowerStationJob】【取得成功電站[{0}]在{1}的逆變器設備資訊】", powerStation.Code, dateTime);
|
||
logger.LogInformation("【CalcPowerStationJob】【電站[{0}]在{1}的逆變器設備資訊】 - {2}", powerStation.Code, dateTime, System.Text.Json.JsonSerializer.Serialize(inverterIds));
|
||
|
||
if (inverterIds != null && inverterIds.Count() > 0)
|
||
{
|
||
logger.LogInformation("【CalcPowerStationJob】【開始計算電站[{0}]在{1}的逆變器的資訊】", powerStation.Code, dateTime);
|
||
var inverterHistories = await powerStationRepository.CalcInverterHisyortHourData(dateTime, powerStation.SiteDB, full_inverter_table_name, inverterIds);
|
||
//取得日照計要找的欄位資訊
|
||
var pyrheliometer = await powerStationRepository.GetFirstPyrheliometerInfo(powerStation.Id, powerStation.SiteDB);
|
||
var pyrheliometerValue = await powerStationRepository.GetFirstPyrheliometerValue(dateTime, pyrheliometer.DBName, pyrheliometer.TableName, pyrheliometer.ColName);
|
||
foreach (var inverterHistory in inverterHistories)
|
||
{
|
||
inverterHistory.Irradiance = pyrheliometerValue;
|
||
inverterHistory.DC1KW = inverterHistory.DC1W / 1000;
|
||
inverterHistory.DC2KW = inverterHistory.DC2W / 1000;
|
||
inverterHistory.DC3KW = inverterHistory.DC3W / 1000;
|
||
inverterHistory.DC4KW = inverterHistory.DC4W / 1000;
|
||
inverterHistory.DC5KW = inverterHistory.DC5W / 1000;
|
||
|
||
inverterHistory.DCKW = (inverterHistory.DC1W + inverterHistory.DC2W + inverterHistory.DC3W + inverterHistory.DC4W + inverterHistory.DC5W) / 1000;
|
||
inverterHistory.ACKW = (inverterHistory.AC1W + inverterHistory.AC2W + inverterHistory.AC3W) / 1000;
|
||
|
||
inverterHistory.TIMESTAMP = Convert.ToDateTime(inverterHistory.TIMESTAMP + ":00:00").ToString("yyyy-MM-dd HH:mm:ss");
|
||
inverterHistory.PowerStationId = powerStation.Id;
|
||
|
||
inverterHistoriesHour.Add(inverterHistory);
|
||
}
|
||
logger.LogInformation("【CalcPowerStationJob】【計算完成電站[{0}]在{1}的逆變器的資訊】", powerStation.Code, dateTime);
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
logger.LogError("【CalcPowerStationJob】【計算失敗電站[{0}]在{1}的逆變器的資訊】", powerStation.Code, dateTime);
|
||
logger.LogError("【CalcPowerStationJob】【失敗原因】- {0}", ex.Message);
|
||
}
|
||
}
|
||
#endregion
|
||
|
||
#region step2-4. 計算該電站所有sensoravg
|
||
try
|
||
{
|
||
|
||
//var seneoravg_table_name = String.Format("s{0}01_sensoravg", powerStation.Code);
|
||
//var full_seneoravg_table_name = String.Format("`{0}`.`{1}`", powerStation.SiteDB, seneoravg_table_name);
|
||
//var exist_seneoravg_table = await powerStationRepository.ExistTable(powerStation.SiteDB, seneoravg_table_name);
|
||
|
||
if (!string.IsNullOrEmpty(sensoravg_table_exist))
|
||
{
|
||
logger.LogInformation("【CalcPowerStationJob】【開始計算電站[{0}]在{1}的sensor avg的資訊】", powerStation.Code, dateTime);
|
||
var sensorAvgHistory = await powerStationRepository.CalcSensorAvgHistory(dateTime, full_sensoravg_table_name);
|
||
logger.LogInformation("【CalcPowerStationJob】【計算完成電站[{0}]在{1}的sensor avg的資訊】", powerStation.Code, dateTime);
|
||
|
||
if (sensorAvgHistory != null)
|
||
{
|
||
sensorAvgHistory.PowerStationId = powerStation.Id;
|
||
sensorAvgHistory.TIMESTAMP = Convert.ToDateTime(sensorAvgHistory.TIMESTAMP + ":00:00").ToString("yyyy-MM-dd HH:mm:ss");
|
||
|
||
sensorAvgHistoryHour.Add(sensorAvgHistory);
|
||
}
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
logger.LogError("【CalcPowerStationJob】【計算失敗電站[{0}]在{1}的sensor avg的資訊】", powerStation.Code, dateTime);
|
||
logger.LogError("【CalcPowerStationJob】【失敗原因】- {0}", ex.Message);
|
||
}
|
||
#endregion
|
||
|
||
#region step2-5. 計算該電站meter
|
||
try
|
||
{
|
||
var meter_table_name = String.Format("s{0}01_meter", powerStation.Code);
|
||
var full_meter_table_name = String.Format("`{0}`.`{1}`", powerStation.SiteDB, meter_table_name);
|
||
var exist_meter_table = await powerStationRepository.ExistTable(powerStation.SiteDB, meter_table_name);
|
||
if (string.IsNullOrEmpty(exist_meter_table))
|
||
{
|
||
logger.LogError("【CalcPowerStationJob】【查無電站[{0}]的s{0}01_meter資料表】", powerStation.Code);
|
||
}
|
||
else
|
||
{
|
||
logger.LogInformation("【CalcPowerStationJob】【開始計算電站[{0}]在{1}的meter的資訊】", powerStation.Code, dateTime);
|
||
var meterHistory = await powerStationRepository.CalcMeterHistory(dateTime, full_meter_table_name);
|
||
logger.LogInformation("【CalcPowerStationJob】【計算完成電站[{0}]在{1}的meter的資訊】", powerStation.Code, dateTime);
|
||
|
||
if (meterHistory != null)
|
||
{
|
||
meterHistory.PowerStationId = powerStation.Id;
|
||
meterHistory.TIMESTAMP = Convert.ToDateTime(meterHistory.TIMESTAMP + ":00:00").ToString("yyyy-MM-dd HH:mm:ss");
|
||
|
||
meterHistoriesHour.Add(meterHistory);
|
||
}
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
logger.LogError("【CalcPowerStationJob】【計算失敗電站[{0}]在{1}的meter的資訊】", powerStation.Code, dateTime);
|
||
logger.LogError("【CalcPowerStationJob】【失敗原因】- {0}", ex.Message);
|
||
}
|
||
#endregion
|
||
|
||
#region 確認是否有觀測站(沒有則新增)
|
||
try
|
||
{
|
||
if (powerStation.WeathersStationId == null)
|
||
{
|
||
var weatherStationId = "";
|
||
double shortLocation = 9999;
|
||
foreach (var Location in observation.Records.Location)
|
||
{
|
||
|
||
if (powerStation.Coordinate != null)
|
||
{
|
||
var powerLocation = powerStation.Coordinate.Split(',');
|
||
var nowLocation = Math.Sqrt(Math.Pow(Convert.ToDouble(powerLocation[0]) - Convert.ToDouble(Location.Lat), 2) + Math.Pow(Convert.ToDouble(powerLocation[1]) - Convert.ToDouble(Location.Lon), 2));
|
||
if (nowLocation < shortLocation)
|
||
{
|
||
shortLocation = nowLocation;
|
||
weatherStationId = Location.StationId;
|
||
calcPowerStation.TodayWeatherTemp = Convert.ToDouble(Location.WeatherElement[0].ElementValue);
|
||
}
|
||
}
|
||
}
|
||
|
||
calcPowerStation.WeathersStationId = weatherStationId;
|
||
}
|
||
|
||
WeatherObservation weatherObservation = new WeatherObservation();
|
||
if (powerStation.WeathersStationId != null && observation != null)
|
||
{
|
||
foreach (var Location in observation.Records.Location)
|
||
{
|
||
if (Location.StationId == powerStation.WeathersStationId)
|
||
{
|
||
calcPowerStation.TodayWeatherTemp = Convert.ToDouble(Location.WeatherElement[0].ElementValue);
|
||
weatherObservation.PowerStationId = powerStation.Id;
|
||
weatherObservation.Temp = Convert.ToDouble(Location.WeatherElement[0].ElementValue);
|
||
weatherObservation.ObsTime = !string.IsNullOrEmpty(Location.Time.ObsTime) ? Convert.ToInt32(Location.Time.ObsTime.Substring(0, 4)) >= 1971 ? Location.Time.ObsTime : DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") : DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
|
||
calcPowerStation.WeathersStationId = powerStation.WeathersStationId;
|
||
break;
|
||
}
|
||
}
|
||
weatherObservations.Add(weatherObservation);
|
||
}
|
||
|
||
logger.LogInformation("【CalcPowerStationJob】【開始取得電站[{0}]在{1}的天氣預報的資訊】", powerStation.Code, dateTime);
|
||
var weather = await powerStationRepository.SelectNowWeather(powerStation.CityId);
|
||
logger.LogInformation("【CalcPowerStationJob】【取得成功電站[{0}]在{1}的天氣預報的資訊】", powerStation.Code, dateTime);
|
||
if (weather != null)
|
||
{
|
||
calcPowerStation.TodayWeather = weather.WeatherKey;
|
||
calcPowerStation.RateOfRain = weather.PoP;
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
logger.LogError("【CalcPowerStationJob】【取得失敗電站[{0}]在{1}的天氣預報的資訊】", powerStation.Code, dateTime);
|
||
logger.LogError("【CalcPowerStationJob】【失敗原因】- {0}", ex.Message);
|
||
}
|
||
#endregion
|
||
}
|
||
catch (Exception exception)
|
||
{
|
||
logger.LogError("【{0}】{1}", "CalcPowerStationJob", exception.Message);
|
||
}
|
||
}
|
||
#endregion
|
||
|
||
if (!this.environment.IsDevelopment())
|
||
{
|
||
#region step3. 將historiers INSERT 到 power_station_history_hour 資料表
|
||
List<string> history_properties = new List<string>()
|
||
{
|
||
"PowerStationId",
|
||
"TIMESTAMP",
|
||
"SITEID",
|
||
"SITETYPE",
|
||
"KWH",
|
||
"TODAYKWH",
|
||
"TOTALKWH",
|
||
"KWHKWP",
|
||
"PR",
|
||
"MP",
|
||
"SolarHour",
|
||
"MONEY",
|
||
"CARBON",
|
||
"TODAYMONEY",
|
||
"TOTALMONEY",
|
||
"TODAYCARBON",
|
||
"TOTALCARBON"
|
||
};
|
||
|
||
await powerStationRepository.AddPowerStationHistory(powerStationHistoriesHour, history_properties);
|
||
#endregion
|
||
|
||
#region step4. 將sensor History INSERT 到 sensor_history_hour 資料表
|
||
List<string> sensor_history_properties = new List<string>()
|
||
{
|
||
"PowerStationId",
|
||
"TIMESTAMP",
|
||
"Irradiance",
|
||
"Temperature",
|
||
"EnvTemperature",
|
||
"Humidity",
|
||
"Vane",
|
||
"Dust"
|
||
};
|
||
|
||
await powerStationRepository.AddSensorHistoryHour(sensorHistoriesHour, sensor_history_properties);
|
||
|
||
//List<string> Temp_history_properties = new List<string>()
|
||
//{
|
||
// "PowerStationId",
|
||
// "TIMESTAMP",
|
||
// "Temperature"
|
||
//};
|
||
|
||
//await powerStationRepository.AddTempHistory(TempHistoriesHour, Temp_history_properties);
|
||
#endregion
|
||
|
||
#region step5. calcPowerStations UPDATE 到 power_station 資料表
|
||
List<string> power_station_properties = new List<string>()
|
||
{
|
||
"Id",
|
||
"kwh",
|
||
"Today_kwh",
|
||
"Total_kwh",
|
||
"today_kwhkwp",
|
||
"today_money",
|
||
"total_money",
|
||
"today_PR",
|
||
"today_carbon",
|
||
"total_carbon",
|
||
"today_irradiance",
|
||
"SolarHour",
|
||
"WeathersStationId",
|
||
"TodayWeatherTemp",
|
||
"TodayWeather",
|
||
"RateOfRain"
|
||
};
|
||
|
||
await powerStationRepository.UpdateList(calcPowerStations, power_station_properties);
|
||
#endregion
|
||
|
||
#region step6. 將 inverter INSERT 到 inverter_history_hour 資料表
|
||
List<string> inverter_history_properties = new List<string>()
|
||
{
|
||
"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",
|
||
};
|
||
|
||
await powerStationRepository.AddInverterHistory(inverterHistoriesHour, inverter_history_properties);
|
||
#endregion
|
||
|
||
#region step7. 將 sensoravg INSERT 到 sensoravg_history_hour 資料表
|
||
List<string> sensoravg_history_properties = new List<string>()
|
||
{
|
||
"PowerStationId",
|
||
"TIMESTAMP",
|
||
"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",
|
||
};
|
||
|
||
await powerStationRepository.AddSensorAvgHistory(sensorAvgHistoryHour, sensoravg_history_properties);
|
||
#endregion
|
||
|
||
#region step8. 將 meter INSERT 到 meter_history_hour 資料表
|
||
List<string> memter_history_properties = new List<string>()
|
||
{
|
||
"PowerStationId",
|
||
"TIMESTAMP",
|
||
"METERID",
|
||
"V_AB",
|
||
"V_BC",
|
||
"V_CA",
|
||
"I_A",
|
||
"I_B",
|
||
"I_C",
|
||
"I_C",
|
||
"P",
|
||
"F",
|
||
"INPUT_KWH",
|
||
"OUTPUT_KWH"
|
||
};
|
||
|
||
await powerStationRepository.AddMeterHistory(meterHistoriesHour, memter_history_properties);
|
||
#endregion
|
||
|
||
#region step9. 新增天氣資訊
|
||
List<string> weather_observation_properties = new List<string>()
|
||
{
|
||
"PowerStationId",
|
||
"ObsTime",
|
||
"Temp"
|
||
};
|
||
await powerStationRepository.AddWeatherObservation(weatherObservations, weather_observation_properties);
|
||
#endregion
|
||
}
|
||
|
||
logger.LogInformation("【CalcPowerStationJob】【任務完成】");
|
||
}
|
||
catch (Exception exception)
|
||
{
|
||
logger.LogError("【CalcPowerStationJob】[Exception] - {0}", exception.Message);
|
||
if (exception.InnerException != null)
|
||
{
|
||
logger.LogError("【CalcPowerStationJob】[InnerException] - {0}", exception.InnerException.Message);
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|