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 DataDockingSingleJob : IJob
|
{
|
public const string ProblemTagName = "Problem";
|
|
public Task Execute(IJobExecutionContext context)
|
{
|
|
return Task.Run(() =>
|
{
|
|
//获取配置
|
var dataMap = context.MergedJobDataMap;
|
var problem = (Model.DataDockingProblem)dataMap[ProblemTagName];
|
if (problem == null)
|
return;
|
try
|
{
|
var lastFlowRecord = new RedisCache.MonitorDataDockingFlowRecordCacheHelper().GetLastRecord(problem.CorpID,problem.ConfigureID);
|
if (lastFlowRecord == null || (DateTime.Now - lastFlowRecord.DockingTime).TotalSeconds > problem.Interruption)
|
{
|
switch (problem.HandleMethod)
|
{
|
case Model.DataDockingProblem.eHandleMethod:
|
{
|
var handleParas = Model.DataDockingProblem.SmsHandleParameters.ToModel(problem.HandleParas);
|
if (handleParas == null||handleParas.Account==null||handleParas.Telephones==null||handleParas.Telephones.Count<1)
|
{
|
LogHelper.Error($"数据对接问题，配置名称:{problem.Name},处理参数配置错误：{problem.HandleParas}");
|
}
|
else
|
{
|
DataDockingSmsHelper.Send(problem,handleParas);
|
}
|
}
|
break;
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Error($"数据对接问题，任务执行出错，配置名称:{problem.Name}", ex);
|
var e = new JobExecutionException(ex);
|
throw e;
|
}
|
});
|
|
}
|
|
|
|
}
|
}
|
