using Quartz;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using IStation.Calculation;
|
|
namespace IStation.Server
|
{
|
/// <summary>
|
/// 报警中断分析任务
|
/// </summary>
|
[DisallowConcurrentExecution]//此特性标识 必须等待这次任务执行完成后，才能执行下次任务
|
public class AlarmInterruptAnalyJob : IJob
|
{
|
|
/// <summary>
|
///
|
/// </summary>
|
/// <param name="context"></param>
|
/// <returns></returns>
|
public Task Execute(IJobExecutionContext context)
|
{
|
|
return Task.Run(() =>
|
{
|
try
|
{
|
|
#region 加载目标客户
|
|
var corpIds = CorpHelper.GetCorpIds();
|
if (corpIds == null || corpIds.Count < 1)
|
{
|
LogHelper.Info("报警中断分析任务中，未检索到目标客户信息");
|
return;
|
}
|
|
#endregion
|
|
#region 加载所有数据中断报警配置
|
|
var configureList = new Service.MonitorAlarmConfigure().GetByCorpIds(corpIds);
|
if (configureList == null || configureList.Count < 1)
|
{
|
LogHelper.Info("报警中断分析任务中，未检索到监测报警配置！");
|
return;
|
}
|
configureList = configureList.Where(x => x.AlarmType == Alarm.Type_Interrupted).ToList();
|
if (configureList.Count < 1)
|
{
|
LogHelper.Info("报警中断分析任务中，未检索到数据中断监测报警配置！");
|
return;
|
}
|
configureList = configureList.Where(x => x.UseStatus == Model.eUseStatus.Enable).ToList();
|
if (configureList.Count < 1)
|
{
|
LogHelper.Info("报警中断分析任务中，未检索到有效数据中断监测报警配置！");
|
return;
|
}
|
|
#endregion
|
|
#region 遍历分析
|
|
var service_record = new Service.MonitorRecord();
|
var service_monitor = new Service.MonitorPoint();
|
var service_signal = new Service.Signal();
|
var service_alarm = new Service.MonitorAlarmRecord();
|
foreach (var configure in configureList)
|
{
|
if (!configure.MonitorPointID.HasValue)
|
continue;
|
if (double.TryParse(configure.ThresholdValue, out double thresholdValue))
|
{
|
var monitor = service_monitor.GetByID(configure.CorpID,configure.MonitorPointID.Value);
|
if (monitor == null)
|
continue;
|
if (monitor.UseStatus != Model.eUseStatus.Enable)
|
continue;
|
Model.Signal signal = null;
|
DateTime? lastTime = null;
|
if (!configure.SignalID.HasValue)
|
{
|
var lastRecordList = service_record.GetLastRecord(configure.CorpID, configure.MonitorPointID.Value);
|
if (lastRecordList != null && lastRecordList.Count > 0)
|
{
|
lastTime = lastRecordList.Max(t => t.DataTime);
|
}
|
}
|
else
|
{
|
signal = service_signal.GetByID(configure.CorpID,configure.SignalID.Value);
|
if (signal == null)
|
continue;
|
var lastRecord = service_record.GetLastRecord(configure.CorpID, configure.MonitorPointID.Value, configure.SignalID.Value);
|
if (lastRecord != null)
|
{
|
lastTime = lastRecord.DataTime;
|
}
|
}
|
|
if (AlarmInterruptAnalyHelper.IsAlarm(configure.CorpID, configure.MonitorPointID.Value, configure.SignalID, lastTime, thresholdValue))
|
{
|
var alarm = MonitorAlarmCalcuHelper.Create(monitor,signal,configure,null);
|
var bol = service_alarm.InsertLastRecord(alarm);
|
if (!bol)
|
{
|
LogHelper.Error($"报警中断分析任务中,客户标识:{configure.CorpID},配置标识:{configure.ID},报警记录保存失败！");
|
}
|
}
|
}
|
}
|
|
#endregion
|
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Error("报警中断分析任务出错", ex);
|
var e = new JobExecutionException(ex);
|
throw e;
|
}
|
|
});
|
|
|
}
|
|
|
|
|
|
|
}
|
}
|
