using Quartz;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
|
namespace IStation.Server
|
{
|
/// <summary>
|
/// 单个任务
|
/// </summary>
|
[DisallowConcurrentExecution]//此特性标识 必须等待这次任务执行完成后，才能执行下次任务
|
internal class SingleJob : IJob
|
{
|
public const string ConfigureTagName = "Configure";
|
|
public Task Execute(IJobExecutionContext context)
|
{
|
return Task.Run(() =>
|
{
|
//获取MiddleLib配置
|
var dataMap = context.MergedJobDataMap;
|
var configure = (Model.DataDockingConfigureExMiddleLib)dataMap[ConfigureTagName];
|
if (configure == null)
|
return;
|
try
|
{
|
if (configure.Mappers == null || configure.Mappers.Count < 1)
|
{
|
LogHelper.Info($"中间库数据对接中:{configure.Name}，未配置映射关系！");
|
return;
|
}
|
|
//创建对接对象
|
var dataDocking = DataDockingMiddleLibFactory.CreateMiddleLib<IDataDockingMiddleLib.IHandleHelper>(configure.ConfigureParas.DependencyFile);
|
if (dataDocking == null)
|
{
|
LogHelper.Info($"中间库数据对接中:{configure.Name} ,创建对接对象失败！");
|
return;
|
}
|
dataDocking.HandleData(configure.Mappers, (receive_list) =>
|
{
|
if (receive_list == null || receive_list.Count < 1)
|
{
|
LogHelper.Info($"中间库数据对接中:{configure.Name} ,未获取到测点原始数据！");
|
return;
|
}
|
var queue = new RabbitMqQueueHelper();
|
queue.Push(ConfigHelper.QueueName, new Model.MonitorDataDockingCorpRecord() { CorpID = configure.CorpID, ConfigureID = configure.ID, Records = receive_list });
|
|
LogHelper.Info($"中间库数据对接中:{configure.Name},成功推入通道{receive_list.Count}条数据！");
|
});
|
|
|
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Error($"中间数据库对接，任务执行出错，配置名称:{configure.Name}!", ex);
|
var e = new JobExecutionException(ex);
|
throw e;
|
}
|
});
|
|
|
}
|
|
|
|
}
|
}
|
