using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using IStation.RedisCache;
|
|
namespace IStation.Service
|
{
|
/// <summary>
|
/// 监测记录
|
/// </summary>
|
public partial class MonitorRecord
|
{
|
|
#region 最近一条记录
|
|
/// <summary>
|
/// 获取最近一条记录
|
/// </summary>
|
public Model.MonitorBasicRecord GetLastRecord(long CorpID, long MonitorPointID, long SignalID)
|
{
|
var redisHelper = new MonitorRecordCacheHelper();
|
var record = redisHelper.GetLastRecord(CorpID, MonitorPointID, SignalID);
|
return record;
|
}
|
|
/// <summary>
|
/// 获取最近一条记录
|
/// </summary>
|
public List<Model.MonitorBasicRecord> GetLastRecord(long CorpID, long MonitorPointID, IEnumerable<long> SignalIds)
|
{
|
if (SignalIds == null || SignalIds.Count() < 1)
|
return default;
|
var redisHelper = new MonitorRecordCacheHelper();
|
var record = redisHelper.GetLastRecord(CorpID, MonitorPointID, SignalIds);
|
return record;
|
}
|
|
/// <summary>
|
/// 获取最近一条记录
|
/// </summary>
|
public List<Model.MonitorBasicRecord> GetLastRecord(long CorpID, Dictionary<long, long> dict)
|
{
|
if (dict == null || dict.Count < 1)
|
return default;
|
var redisHelper = new MonitorRecordCacheHelper();
|
var records = redisHelper.GetLastRecord(CorpID, dict);
|
return records;
|
}
|
|
/// <summary>
|
/// 获取最近一条记录
|
/// </summary>
|
public List<Model.MonitorBasicRecord> GetLastRecord(long CorpID, long MonitorPointID)
|
{
|
var redisHelper = new MonitorRecordCacheHelper();
|
var records = redisHelper.GetLastRecord(CorpID, MonitorPointID);
|
return records;
|
}
|
|
/// <summary>
|
/// 获取最近一条记录
|
/// </summary>
|
public List<Model.MonitorBasicRecord> GetLastRecord(long CorpID, IEnumerable<long> MonitorPointIds)
|
{
|
if (MonitorPointIds == null || MonitorPointIds.Count() < 1)
|
return default;
|
var redisHelper = new MonitorRecordCacheHelper();
|
var records = redisHelper.GetLastRecord(CorpID, MonitorPointIds);
|
return records;
|
}
|
|
/// <summary>
|
/// 获取最近一条正常记录
|
/// </summary>
|
public Model.MonitorBasicRecord GetLastNormalRecord(long CorpID, long MonitorPointID, long SignalID)
|
{
|
var redisHelper = new MonitorRecordCacheHelper();
|
var record = redisHelper.GetLastNormalRecord(CorpID, MonitorPointID, SignalID);
|
return record;
|
}
|
|
|
/// <summary>
|
/// 获取最近一条正常记录
|
/// </summary>
|
public List<Model.MonitorBasicRecord> GetLastNormalRecord(long CorpID, Dictionary<long, long> dict)
|
{
|
if (dict == null || dict.Count < 1)
|
return default;
|
var redisHelper = new MonitorRecordCacheHelper();
|
var records = redisHelper.GetLastNormalRecord(CorpID, dict);
|
return records;
|
}
|
|
/// <summary>
|
/// 获取最近一条正常记录
|
/// </summary>
|
public List<Model.MonitorBasicRecord> GetLastNormalRecord(long CorpID, long MonitorPointID)
|
{
|
var redisHelper = new MonitorRecordCacheHelper();
|
var records = redisHelper.GetLastNormalRecord(CorpID, MonitorPointID);
|
return records;
|
}
|
|
/// <summary>
|
/// 获取最近一条正常记录
|
/// </summary>
|
public List<Model.MonitorBasicRecord> GetLastNormalRecord(long CorpID, IEnumerable<long> MonitorPointIds)
|
{
|
if (MonitorPointIds == null || MonitorPointIds.Count() < 1)
|
return default;
|
var redisHelper = new MonitorRecordCacheHelper();
|
var records = redisHelper.GetLastNormalRecord(CorpID, MonitorPointIds);
|
return records;
|
}
|
|
#endregion
|
|
#region 插入最近一条记录
|
|
/// <summary>
|
/// 插入最近一条记录
|
/// </summary>
|
public bool InsertLastRecord(Model.MonitorBasicRecord model)
|
{
|
if (model == null)
|
return default;
|
//实时记录
|
if (model is Model.MonitorRealRecordPure)
|
{
|
return new MonitorRealRecord().InsertLastRecord(model as Model.MonitorRealRecordPure);
|
}
|
//时记录
|
else if (model is Model.MonitorHourRecordPure)
|
{
|
return new MonitorHourRecord().InsertLastRecord(model as Model.MonitorHourRecordPure);
|
}
|
//日记录
|
else if (model is Model.MonitorDayRecordPure)
|
{
|
return new MonitorDayRecord().InsertLastRecord(model as Model.MonitorDayRecordPure);
|
}
|
//周记录
|
else if (model is Model.MonitorWeekRecordPure)
|
{
|
return new MonitorWeekRecord().InsertLastRecord(model as Model.MonitorWeekRecordPure);
|
}
|
//月记录
|
else if (model is Model.MonitorMonthRecordPure)
|
{
|
return new MonitorMonthRecord().InsertLastRecord(model as Model.MonitorMonthRecordPure);
|
}
|
//年记录
|
else if (model is Model.MonitorYearRecordPure)
|
{
|
return new MonitorYearRecord().InsertLastRecord(model as Model.MonitorYearRecordPure);
|
}
|
|
return default;
|
}
|
|
/// <summary>
|
/// 插入最近多条记录(暂时只支持同一种计划类型)
|
/// </summary>
|
public bool InsertsLastRecord(Model.Monitor.eCronType cronType, List<Model.MonitorBasicRecord> list)
|
{
|
if (list == null || list.Count() < 1)
|
return default;
|
var bol = false;
|
switch (cronType)
|
{
|
case Model.Monitor.eCronType.Real:
|
{
|
bol = new MonitorRealRecord().InsertsLastRecord(list.Select(x=>x as Model.MonitorRealRecordPure).ToList());
|
}
|
break;
|
case Model.Monitor.eCronType.EachHour:
|
{
|
bol = new MonitorHourRecord().InsertsLastRecord(list.Select(x => x as Model.MonitorHourRecordPure).ToList());
|
}
|
break;
|
case Model.Monitor.eCronType.EachDay:
|
{
|
bol = new MonitorDayRecord().InsertsLastRecord(list.Select(x => x as Model.MonitorDayRecordPure).ToList());
|
}
|
break;
|
case Model.Monitor.eCronType.EachWeek:
|
{
|
bol = new MonitorWeekRecord().InsertsLastRecord(list.Select(x => x as Model.MonitorWeekRecordPure).ToList());
|
}
|
break;
|
case Model.Monitor.eCronType.EachMonth:
|
{
|
bol = new MonitorMonthRecord().InsertsLastRecord(list.Select(x => x as Model.MonitorMonthRecordPure).ToList());
|
}
|
break;
|
case Model.Monitor.eCronType.EachYear:
|
{
|
bol = new MonitorYearRecord().InsertsLastRecord(list.Select(x => x as Model.MonitorYearRecordPure).ToList());
|
}
|
break;
|
default:break;
|
}
|
return bol;
|
}
|
|
#endregion
|
|
|
|
}
|
}
|
