using HDLCloudMonitorSupportCtrlOldUdpGate.Context;
|
using HDLCloudMonitorSupportCtrlOldUdpGate.Logs;
|
using System;
|
using System.Linq;
|
using System.Collections.Generic;
|
using System.Threading.Tasks;
|
using System.Text;
|
using JumpKick.HttpLib;
|
using Newtonsoft.Json;
|
using System.Net;
|
|
namespace HDLCloudMonitorSupportCtrlOldUdpGate
|
{
|
public static class EarlyWarningTimerServoce
|
{
|
private const int AvgCount= 360;
|
private const int EarlyWarningAvgTime= 150;
|
private const int EarlyWarningCount = 500;
|
|
private static List<string> executeList = new List<string>();
|
|
public static async Task StartEarlyWarning()
|
{
|
await Task.Run(async() =>
|
{
|
while (true)
|
{
|
try
|
{
|
string currentDateHourStr = DateTime.Now.ToString(Consts.DateTimeFormatHoursStr);
|
if (!executeList.Contains(currentDateHourStr))
|
{
|
string lastHour = DateTime.Now.AddHours(-1).ToString(Consts.DateTimeFormatHoursStr);
|
|
//拿上一小时日志数据
|
var currentPointDataList = MqttLogHp.ReadDataByDateHours(lastHour);
|
|
//执行第1种策略
|
ExecuteFirstStrategy(currentPointDataList, lastHour);
|
|
//执行第2种策略
|
ExecuteSecondStrategy(currentPointDataList, lastHour);
|
|
if (executeList.Count > 2)
|
{
|
executeList.Clear();
|
}
|
executeList.Add(currentDateHourStr);
|
}
|
|
await Task.Delay(TimeSpan.FromSeconds(1));
|
}
|
catch(Exception ex)
|
{
|
}
|
}
|
});
|
}
|
|
private static void ExecuteFirstStrategy(List<CtrlRecordDto> currentPointDataList,string lastHour)
|
{
|
try
|
{
|
/*
|
第一种策略：
|
去网关时间 求平均超过150，发邮件
|
网关回复控制端 求平均超过150，发邮件
|
*/
|
double arrivalsAvg = currentPointDataList.Sum(s => s.ArrivalsMilliseconds) / AvgCount;
|
double comebackAvg = currentPointDataList.Sum(s => s.ComebackMilliseconds) / AvgCount;
|
|
var sb = new StringBuilder();
|
|
if (arrivalsAvg > EarlyWarningAvgTime)
|
{
|
sb.AppendLine($"第一种策略:{lastHour}去的时间平均值:{arrivalsAvg}<br/>");
|
}
|
|
if (comebackAvg > EarlyWarningAvgTime)
|
{
|
sb.AppendLine($"第一种策略:{lastHour}回的时间平均值:{comebackAvg}");
|
}
|
|
string notifyContent = sb.ToString();
|
if (string.IsNullOrEmpty(notifyContent))
|
{
|
notifyContent = $"第一种策略:{lastHour}过滤程序去与回监控时间正常!";
|
}
|
|
//发邮件通知
|
|
string reqStr = JsonConvert.SerializeObject(new { RequestVersion = "RequestVersion11", EarlyWarningNotifyEmailList = Config.EarlyWarningNotifyEmailList, NotifyContent = notifyContent });
|
|
ServicePointManager.ServerCertificateValidationCallback += (sender, cert, chain, error) =>
|
{
|
return true;
|
};
|
Http.Post(Config.EarlyWarningNotifyEmailListReqUrl).Body("application/json", reqStr).Go();
|
}
|
catch
|
{
|
}
|
}
|
|
private static void ExecuteSecondStrategy(List<CtrlRecordDto> currentPointDataList, string lastHour)
|
{
|
/*
|
第二种策略：
|
(不管是去还是回,时间超过500ms的10次报警依次预警)
|
*/
|
try
|
{
|
bool arrivalsIsNoOk = currentPointDataList.Where(w => w.ArrivalsMilliseconds > EarlyWarningCount).ToList().Count > Consts.TEN;
|
bool comebackIsNoOk = currentPointDataList.Where(w => w.ComebackMilliseconds > EarlyWarningCount).ToList().Count > Consts.TEN;
|
|
var sb = new StringBuilder();
|
if (arrivalsIsNoOk)
|
{
|
sb.AppendLine($"第二种策略:{lastHour}去的时间有超过10次过500ms!<br/>");
|
}
|
|
|
if (comebackIsNoOk)
|
{
|
sb.AppendLine($"第二种策略:{lastHour}回的时间有超过10次过500ms!<br/>");
|
}
|
|
if (!arrivalsIsNoOk && !comebackIsNoOk)
|
{
|
sb.AppendLine($"第二种策略:{lastHour}过滤程序去与回监控超过500次数正常!");
|
}
|
|
string notifyContent = sb.ToString();
|
string reqStr = JsonConvert.SerializeObject(new { RequestVersion = "RequestVersion11", EarlyWarningNotifyEmailList = Config.EarlyWarningNotifyEmailList, NotifyContent = notifyContent });
|
ServicePointManager.ServerCertificateValidationCallback += (sender, cert, chain, error) =>
|
{
|
return true;
|
};
|
Http.Post(Config.EarlyWarningNotifyEmailListReqUrl).Body("application/json", reqStr).Go();
|
}
|
catch
|
{
|
}
|
}
|
}
|
}
|
