using Quartz;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using IStation.Untity;
|
|
namespace IStation.DataProvider
|
{
|
|
|
/// <summary>
|
/// 数据任务
|
/// </summary>
|
[DisallowConcurrentExecution]//此特性标识 必须等待这次任务执行完成后，才能执行下次任务
|
public class DataJob : IJob
|
{
|
/// <summary>
|
///
|
/// </summary>
|
public async Task Execute(IJobExecutionContext context)
|
{
|
try
|
{
|
await Task.Run(() =>
|
{
|
var srcList = JsonStore.GetCurrentRecord();
|
var response= HttpRequestHelper.Post(ConfigHelper.StoreUrl,JsonHelper.Object2Json(srcList));
|
var result = JsonHelper.Json2Object<Result>(response);
|
if (result.Code == 0)
|
{
|
if (result.Data)
|
{
|
LogHelper.Info($"成功插入{srcList.Count}条数据！");
|
}
|
else
|
{
|
LogHelper.Info($"数据插入失败，原因:{result.Message}");
|
}
|
}
|
else
|
{
|
LogHelper.Info($"数据插入失败，原因:{result.Message}");
|
}
|
});
|
}
|
catch (Exception ex)
|
{
|
var e = new JobExecutionException(ex);
|
IStation.LogHelper.Error("数据任务", ex);
|
throw e;
|
}
|
}
|
|
|
|
}
|
}
|
