using Quartz;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace IStation.DataProvider
|
{
|
|
|
/// <summary>
|
/// 数据任务
|
/// </summary>
|
[DisallowConcurrentExecution]//此特性标识 必须等待这次任务执行完成后，才能执行下次任务
|
public class DataJob : IJob
|
{
|
/// <summary>
|
///
|
/// </summary>
|
public async Task Execute(IJobExecutionContext context)
|
{
|
try
|
{
|
await Task.Run(() =>
|
{
|
var dt_now = DateTime.Now;
|
var records = JsonStore.GetCurrentRecord(dt_now);
|
if (records == null || records.Count < 1)
|
return;
|
|
var bllScada = new BaseMsSqlDAL<Entity.SMIDATA>();
|
var allHisDatas = bllScada.GetAll()?.ToList();
|
if (allHisDatas == null)
|
allHisDatas = new List<Entity.SMIDATA>();
|
|
//添加
|
var records_adds = records.Where(x =>
|
{
|
var hisData = allHisDatas.Find(t => t.TagName == x.TagName);
|
return hisData == null;
|
}).ToList();
|
|
if (records_adds != null && records_adds.Count > 0)
|
{
|
var hisdata_adds = records_adds.Select(x =>
|
{
|
var entity = new Entity.SMIDATA();
|
entity.TagName = x.TagName;
|
entity.DataTime = x.DataTime;
|
entity.DataValue = x.DataValue;
|
entity.InsertTime = dt_now;
|
return entity;
|
}).ToList();
|
bllScada.Inserts(hisdata_adds);
|
LogHelper.Info(string.Format("成功插入{0}条数据！", hisdata_adds.Count));
|
}
|
|
//更新
|
var records_updates = records.Where(x =>
|
{
|
var hisData = allHisDatas.Find(t => t.TagName == x.TagName);
|
return hisData != null;
|
}).ToList();
|
|
if (records_updates != null && records_updates.Count > 0)
|
{
|
var hisdata_updates = records_updates.Select(x =>
|
{
|
var entity = allHisDatas.Find(t => t.TagName == x.TagName);
|
entity.InsertTime = dt_now;
|
entity.DataValue = x.DataValue;
|
entity.DataTime = x.DataTime;
|
return entity;
|
}).ToList();
|
bllScada.Updates(hisdata_updates);
|
LogHelper.Info(string.Format("成功更新{0}条数据！", hisdata_updates.Count));
|
}
|
|
|
});
|
}
|
catch (Exception ex)
|
{
|
var e = new JobExecutionException(ex);
|
LogHelper.Error("数据任务", ex);
|
throw e;
|
}
|
}
|
|
|
|
}
|
}
|
