182 lines
9.7 KiB
C#
182 lines
9.7 KiB
C#
using Microsoft.Extensions.Logging;
|
|
using Quartz;
|
|
using SolarPower.Models.PowerStation;
|
|
using SolarPower.Repository.Interface;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Threading.Tasks;
|
|
|
|
namespace SolarPower.Quartz.Jobs
|
|
{
|
|
[DisallowConcurrentExecution]
|
|
public class CalcInverter15minJob : IJob
|
|
{
|
|
private readonly ILogger<CalcInverter15minJob> logger;
|
|
private readonly IPowerStationRepository powerStationRepository;
|
|
|
|
public CalcInverter15minJob(ILogger<CalcInverter15minJob> logger, IPowerStationRepository powerStationRepository)
|
|
{
|
|
this.logger = logger;
|
|
this.powerStationRepository = powerStationRepository;
|
|
}
|
|
|
|
public async Task Execute(IJobExecutionContext context)
|
|
{
|
|
try
|
|
{
|
|
//var day_array = new string[] { "15", "16", "17", "18", "19" };
|
|
//var day_array = new string[] { "22" };
|
|
//var time_array = new string[] { "00:02", "00:17", "00:32", "00:47",
|
|
// "01:02", "01:17", "01:32", "01:47",
|
|
// "02:02", "02:17", "02:32", "02:47",
|
|
// "03:02", "03:17", "03:32", "03:47",
|
|
// "04:02", "04:17", "04:32", "04:47",
|
|
// "05:02", "05:17", "05:32", "05:47",
|
|
// "06:02", "06:17", "06:32", "06:47",
|
|
// "07:02", "07:17", "07:32", "07:47",
|
|
// "08:02", "08:17", "08:32", "08:47",
|
|
// "09:02", "09:17", "09:32", "09:47",
|
|
// "10:02", "10:17", "10:32", "10:47",
|
|
// "11:02", "11:17", "11:32", "11:47",
|
|
// "12:02", "12:17", "12:32", "12:47",
|
|
// "13:02", "13:17", "13:32", "13:47",
|
|
// "14:02", "14:17", "14:32", "14:47",
|
|
// "15:02", "15:17", "15:32", "15:47",
|
|
// "16:02", "16:17", "16:32", "16:47",
|
|
// "17:02", "17:17", "17:32", "17:47",
|
|
// "18:02", "18:17", "18:32", "18:47",
|
|
// "19:02", "19:17", "19:32", "19:47",
|
|
// "20:02", "20:17", "20:32", "20:47",
|
|
// "21:02", "21:17", "21:32", "21:47",
|
|
// "22:02", "22:17", "22:32", "22:47",
|
|
// "23:02", "23:17", "23:32", "23:47",
|
|
//};
|
|
|
|
#region step1. 找出所有電站
|
|
logger.LogInformation("【CalcInverter15minJob】【開始取得電站資料】");
|
|
var powerStations = await powerStationRepository.GetAllAsync();
|
|
logger.LogInformation("【CalcInverter15minJob】【取得成功電站資料】");
|
|
logger.LogInformation("【CalcInverter15minJob】【電站資料】 - {0}", System.Text.Json.JsonSerializer.Serialize(powerStations));
|
|
#endregion
|
|
|
|
List<InverterHistory> calcInverter15mins = new List<InverterHistory>();
|
|
List<string> updateInvPowerStationDBName = new List<string>();
|
|
|
|
var DateTimeNow = DateTime.Now;
|
|
|
|
|
|
var dateNowTime = DateTimeNow.ToString("yyyy-MM-dd HH:mm");
|
|
|
|
//for (var i = 0; i < day_array.Count(); i++)
|
|
//{
|
|
// for (var j = 0; j < time_array.Count(); j++)
|
|
// {
|
|
//var dateNowTime = string.Format("2021-07-{0} {1}", day_array[i], time_array[j]);
|
|
|
|
|
|
#region step2. 從電站的DB及電站編號找出該電站的控制器
|
|
foreach (var powerStation in powerStations)
|
|
{
|
|
|
|
//取得所有該電站的逆變器
|
|
logger.LogInformation("【CalcInverter15minJob】【開始取得電站[{0}]在{1}的逆變器設備資訊】", powerStation.Code, dateNowTime);
|
|
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("【CalcInverter15minJob】【取得成功電站[{0}]在{1}的逆變器設備資訊】", powerStation.Code, dateNowTime);
|
|
|
|
#region step2-1. 計算該電站逆變器每15min 的值
|
|
var table_name = String.Format("s{1}01_inv", 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.LogInformation("【CalcInverter15minJob】【開始計算電站[{0}]在{1}的每15分鐘逆變器資訊】", powerStation.Code, dateNowTime);
|
|
var calcInverter15min = await powerStationRepository.CalcInverterHisyort15minData(dateNowTime, powerStation.SiteDB, full_table_name, inverterIds);
|
|
logger.LogInformation("【CalcInverter15minJob】【計算完成電站[{0}]在{1}的每15分鐘逆變器資訊】", powerStation.Code, dateNowTime);
|
|
logger.LogInformation("【CalcInverter15minJob】【計算結果】 - {0}", System.Text.Json.JsonSerializer.Serialize(calcInverter15mins));
|
|
if (calcInverter15min.Count() > 0)
|
|
{
|
|
foreach (var inverterHistory in calcInverter15min)
|
|
{
|
|
inverterHistory.TIMESTAMP = Convert.ToDateTime(inverterHistory.TIMESTAMP + ":00").ToString("yyyy-MM-dd HH:mm:ss");
|
|
inverterHistory.PowerStationId = powerStation.Id;
|
|
|
|
calcInverter15mins.Add(inverterHistory);
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
#endregion
|
|
|
|
|
|
}
|
|
#endregion
|
|
|
|
#region step3. 將 inverter INSERT 到 inverter_history_15min 資料表
|
|
List<string> inverter_history_properties = new List<string>()
|
|
{
|
|
"PowerStationId",
|
|
"INVERTERID",
|
|
"TIMESTAMP",
|
|
"KWH",
|
|
"TODAYKWH",
|
|
"KWHKWP",
|
|
};
|
|
|
|
await powerStationRepository.AddInverter15minHistory(calcInverter15mins, inverter_history_properties);
|
|
#endregion
|
|
// }
|
|
//}
|
|
|
|
try
|
|
{
|
|
powerStations = await powerStationRepository.GetAllNoStatusAsync();
|
|
|
|
logger.LogInformation("【CalcInverter15minJob】開始檢測逆變器狀態");
|
|
var ps_groupby_SitDB = powerStations.GroupBy(x => x.SiteDB).ToList();
|
|
|
|
var updateInvStatusList = new Dictionary<string, List<string>>();
|
|
var psCodes = new List<string>();
|
|
|
|
foreach (var ps in ps_groupby_SitDB)
|
|
{
|
|
//updateInvStatusList.Add(ps.Key, ps.Select(x => x.Code).ToList());
|
|
await powerStationRepository.UpdateInvStatus(ps.Key, ps.Select(x => x.Code).ToList(), null, 1);
|
|
psCodes.AddRange(ps.Select(x => x.Code).ToList());
|
|
}
|
|
|
|
//foreach(var list in updateInvStatusList)
|
|
//{
|
|
// await powerStationRepository.UpdateInvStatus(list.Key, list.Value, null, 1);
|
|
// psCodes.AddRange(list.Value);
|
|
//}
|
|
|
|
var invStatusErr = await powerStationRepository.GetInvStatusErr(psCodes);
|
|
|
|
var invStatusErr_Group = invStatusErr.GroupBy(x => x.SiteDB).ToList();
|
|
|
|
foreach (var update_invStatusErr in invStatusErr_Group)
|
|
{
|
|
await powerStationRepository.UpdateInvStatus(update_invStatusErr.Key, null, update_invStatusErr.Select(x => x.InverterId).ToList(), 2);
|
|
}
|
|
|
|
logger.LogInformation("【CalcInverter15minJob】檢測完成逆變器狀態");
|
|
}
|
|
catch(Exception exception)
|
|
{
|
|
logger.LogError("【CalcInverter15minJob】檢測逆變器狀態失敗 - [Exception] {0}", exception.Message);
|
|
}
|
|
|
|
}
|
|
catch (Exception exception)
|
|
{
|
|
logger.LogError("【{0}】{1}", "CalcInverter15minJob", exception.Message);
|
|
}
|
|
}
|
|
}
|
|
}
|