using Quartz;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace IStation.Server
|
{
|
/// <summary>
|
/// 能效分析计划服务任务
|
/// </summary>
|
[DisallowConcurrentExecution]
|
public class EtaAnalyCronServiceJob : IJob
|
{
|
private static readonly List<EtaAnalyCronJobHelper> _jobHelpers = new List<EtaAnalyCronJobHelper>();
|
|
/// <summary>
|
///
|
/// </summary>
|
public Task Execute(IJobExecutionContext context)
|
{
|
return Task.Run(async () =>
|
{
|
try
|
{
|
#region 加载目标客户
|
|
var corpIds = CorpHelper.GetCorpIds();
|
if (corpIds == null || corpIds.Count < 1)
|
{
|
LogHelper.Error("能效分析计划服务任务中，未检索到目标客户信息");
|
CancelJobs();
|
return;
|
}
|
|
#endregion
|
|
#region 加载配置
|
|
var service_configure = new Service.EtaAnalyConfigure();
|
var configure_list = service_configure.GetByCorpIds(corpIds);
|
if (configure_list == null || configure_list.Count < 1)
|
{
|
LogHelper.Error("能效分析计划服务任务中，未检索到能效分析配置信息！");
|
CancelJobs();
|
return;
|
}
|
configure_list = configure_list.Where(x => x.UseStatus == Model.eUseStatus.Enable).ToList();
|
if (configure_list.Count < 1)
|
{
|
LogHelper.Error("能效分析计划服务任务中，未检索到有效能效分析配置信息！");
|
CancelJobs();
|
return;
|
}
|
|
#endregion
|
|
#region 开启任务
|
|
foreach (var configure in configure_list)
|
{
|
var jobHelper = _jobHelpers.Find(x => x.CorpID == configure.CorpID && x.Frequency == configure.Frequency);
|
if (jobHelper == null)
|
{
|
jobHelper = new EtaAnalyCronJobHelper();
|
await jobHelper.StartJob(configure.CorpID, configure.Frequency);
|
_jobHelpers.Add(jobHelper);
|
LogHelper.Info($"能效分析计划服务任务中，客户标识：{configure.CorpID}，分析频率：{configure.Frequency},计划任务开启！");
|
}
|
}
|
|
#endregion
|
|
#region 关闭任务
|
|
foreach (var jobHelper in _jobHelpers.ToList())
|
{
|
var configure = configure_list.Find(x => x.CorpID == jobHelper.CorpID && x.Frequency == jobHelper.Frequency);
|
if (configure == null)
|
{
|
await jobHelper.CancelJob();
|
_jobHelpers.Remove(jobHelper);
|
LogHelper.Info($"能效分析计划服务任务中，客户标识：{jobHelper.CorpID}，分析频率：{jobHelper.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();
|
}
|
}
|
|
|
|
}
|
}
|
