namespace IStation.Server
|
{
|
/// <summary>
|
/// 设备运行分析服务任务
|
/// </summary>
|
[DisallowConcurrentExecution]
|
public class EquipmentRunAnalyServiceJob : IJob
|
{
|
private static readonly List<EquipmentRunAnalySingleJobHelper> _jobHelpers = new List<EquipmentRunAnalySingleJobHelper>();
|
|
/// <summary>
|
///
|
/// </summary>
|
public Task Execute(IJobExecutionContext context)
|
{
|
return Task.Run(async () =>
|
{
|
try
|
{
|
#region 加载配置
|
|
var configureList = new Yw.Service.RunAnalyConfigure().GetAll();
|
configureList = configureList?.Where(x => x.ObjectType == Yw.Assets.DataType.Equipment).ToList();
|
if (configureList == null || configureList.Count < 1)
|
{
|
LogHelper.Error("设备运行分析服务任务中，未检索到配置信息");
|
CancelJobs();
|
return;
|
}
|
|
|
#endregion
|
|
#region 开启任务
|
|
foreach (var configure in configureList)
|
{
|
var jobHelper = _jobHelpers.Find(x => x.Configure.ObjectType == configure.ObjectType
|
&& x.Configure.ObjectID == configure.ObjectID
|
&& x.Configure.ChangeTimes == configure.ChangeTimes
|
&& x.Configure.Frequency == configure.Frequency);
|
if (jobHelper == null)
|
{
|
jobHelper = new EquipmentRunAnalySingleJobHelper();
|
await jobHelper.StartJob(configure);
|
_jobHelpers.Add(jobHelper);
|
LogHelper.Info($"设备运行分析服务任务中,数据id:{configure.ObjectID},改变次数:{configure.ChangeTimes},分析频率:{configure.Frequency},计划任务开启！");
|
}
|
}
|
|
#endregion
|
|
#region 关闭任务
|
|
foreach (var jobHelper in _jobHelpers.ToList())
|
{
|
var configure = configureList.Find(x => x.ObjectType == jobHelper.Configure.ObjectType
|
&& x.ObjectID == jobHelper.Configure.ObjectID
|
&& x.ChangeTimes == jobHelper.Configure.ChangeTimes
|
&& x.Frequency == jobHelper.Configure.Frequency);
|
if (configure == null)
|
{
|
await jobHelper.CancelJob();
|
_jobHelpers.Remove(jobHelper);
|
LogHelper.Info($"设备运行分析服务任务中，,数据id:{jobHelper.Configure.ObjectID},改变次数:{jobHelper.Configure.ChangeTimes},分析频率:{jobHelper.Configure.Frequency},计划任务关闭！");
|
}
|
}
|
|
#endregion
|
|
|
LogHelper.Info($"设备运行分析服务任务中，开启任务数量为{_jobHelpers.Count}！");
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Error("设备运行分析服务任务中，执行出错！", ex);
|
var e = new JobExecutionException(ex);
|
throw e;
|
}
|
});
|
|
|
}
|
|
/// <summary>
|
/// 取消任务
|
/// </summary>
|
public static void CancelJobs()
|
{
|
if (_jobHelpers != null && _jobHelpers.Count > 0)
|
{
|
_jobHelpers.ForEach(async x => await x.CancelJob());
|
_jobHelpers.Clear();
|
}
|
}
|
|
|
|
}
|
}
|
