using AutoMapper;
|
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 MonitorAlarmRecord
|
{
|
|
#region 最近记录
|
|
/// <summary>
|
/// 通过 MonitorPointID 获取最近一条记录列表
|
/// </summary>
|
public List<Model.MonitorAlarmRecordPure> GetLastRecordListByMonitorPointID(long CorpID, long MonitorPointID)
|
{
|
var list = new RedisCache.MonitorAlarmRecordCacheHelper().GetLastRecordList(CorpID,MonitorPointID);
|
return list;
|
}
|
|
/// <summary>
|
/// 通过 MonitorPointID 获取最近一条记录
|
/// </summary>
|
public Model.MonitorAlarmRecordPure GetLastRecordByMonitorPointID(long CorpID, long MonitorPointID)
|
{
|
var list=new RedisCache.MonitorAlarmRecordCacheHelper().GetLastRecordList(CorpID, MonitorPointID);
|
if (list == null || list.Count < 1)
|
return default;
|
return list.OrderBy(x => x.AlarmTime).Last();
|
}
|
|
/// <summary>
|
/// 通过 MonitorPointIds 获取最近一条记录
|
/// </summary>
|
public List<Model.MonitorAlarmRecordPure> GetLastRecordByMonitorPointIds(long CorpID, IEnumerable<long> MonitorPointIds)
|
{
|
if (MonitorPointIds == null || MonitorPointIds.Count() < 1)
|
return default;
|
var redisHelper = new RedisCache.MonitorAlarmRecordCacheHelper();
|
return MonitorPointIds.Select(x =>
|
{
|
var list = redisHelper.GetLastRecordList(CorpID, x);
|
return list?.OrderBy(x => x.AlarmTime).LastOrDefault();
|
}).Where(x => x != null).ToList();
|
}
|
|
/// <summary>
|
/// 通过 SignalID 获取最近一条记录列表
|
/// </summary>
|
public List<Model.MonitorAlarmRecordPure> GetLastRecordListBySignalID(long CorpID, long MonitorPointID, long SignalID)
|
{
|
var list = new RedisCache.MonitorAlarmRecordCacheHelper().GetLastRecordList(CorpID, MonitorPointID,SignalID);
|
return list;
|
}
|
|
/// <summary>
|
/// 通过 SignalID 获取最近一条记录列表
|
/// </summary>
|
public Model.MonitorAlarmRecordPure GetLastRecordBySignalID(long CorpID, long MonitorPointID, long SignalID)
|
{
|
var list = new RedisCache.MonitorAlarmRecordCacheHelper().GetLastRecordList(CorpID, MonitorPointID, SignalID);
|
if (list == null || list.Count < 1)
|
return default;
|
return list.OrderBy(x => x.AlarmTime).Last();
|
}
|
|
#endregion
|
|
#region Query
|
|
/// <summary>
|
/// 通过 CorpID 获取
|
/// </summary>
|
public List<Model.MonitorAlarmRecord> GetByCorpID(long CorpID)
|
{
|
var dal=new DAL.MonitorAlarmRecord();
|
var entity_list = dal.GetByCorpID(CorpID);
|
var model_list = Entity2Models(entity_list);
|
return model_list;
|
}
|
|
/// <summary>
|
/// 通过 ID 获取
|
/// </summary>
|
public Model.MonitorAlarmRecord GetByID(long CorpID, long ID)
|
{
|
var dal = new DAL.MonitorAlarmRecord();
|
var entity = dal.GetByID(CorpID, ID);
|
var model = Entity2Model(entity);
|
return model;
|
}
|
|
/// <summary>
|
/// 通过 Ids 获取
|
/// </summary>
|
public List<Model.MonitorAlarmRecord> GetByIds(long CorpID, List<long> Ids)
|
{
|
if (Ids == null || Ids.Count() < 1)
|
return default;
|
var dal = new DAL.MonitorAlarmRecord();
|
var entity_list = dal.GetByIds(CorpID, Ids);
|
var model_list = Entity2Models(entity_list);
|
return model_list;
|
}
|
|
/// <summary>
|
/// 通过 ConfigureID 获取
|
/// </summary>
|
public List<Model.MonitorAlarmRecord> GetByConfigureID(long CorpID, long ConfigureID)
|
{
|
var dal = new DAL.MonitorAlarmRecord();
|
var entity_list = dal.GetByConfigureID(CorpID, ConfigureID);
|
var model_list = Entity2Models(entity_list);
|
return model_list;
|
}
|
|
/// <summary>
|
/// 通过 ConfigureID 获取某天的数据
|
/// </summary>
|
public List<Model.MonitorAlarmRecord> GetByConfigureIDOfDay(long CorpID, long ConfigureID, DateTime Day)
|
{
|
var dal = new DAL.MonitorAlarmRecord();
|
var entity_list = dal.GetByConfigureIDOfDay(CorpID, ConfigureID, Day);
|
var model_list = Entity2Models(entity_list);
|
return model_list;
|
}
|
|
/// <summary>
|
/// 通过 MonitorPointID 获取
|
/// </summary>
|
public List<Model.MonitorAlarmRecord> GetByMonitorPointID(long CorpID, long MonitorPointID)
|
{
|
var dal = new DAL.MonitorAlarmRecord();
|
var entity_list = dal.GetByMonitorPointID(CorpID, MonitorPointID);
|
var model_list = Entity2Models(entity_list);
|
return model_list;
|
}
|
|
/// <summary>
|
/// 通过 MonitorPointID 获取某天的数据
|
/// </summary>
|
public List<Model.MonitorAlarmRecord> GetByMonitorPointIDOfDay(long CorpID, long MonitorPointID, DateTime Day)
|
{
|
var dal = new DAL.MonitorAlarmRecord();
|
var entity_list = dal.GetByMonitorPointIDOfDay(CorpID, MonitorPointID, Day);
|
var model_list = Entity2Models(entity_list);
|
return model_list;
|
}
|
|
/// <summary>
|
/// 通过 CorpID 获取最近一条
|
/// </summary>
|
public Model.MonitorAlarmRecord GetLastByCorpID(long CorpID)
|
{
|
return GetLastByCorpID(CorpID, 1)?.FirstOrDefault();
|
}
|
|
/// <summary>
|
/// 通过 CorpID 获取最近几条
|
/// </summary>
|
public List<Model.MonitorAlarmRecord> GetLastByCorpID(long CorpID, int Number)
|
{
|
if (Number < 1)
|
Number = 1;
|
var dal = new DAL.MonitorAlarmRecord();
|
var entity_list = dal.GetLastByCorpID(CorpID, Number);
|
var model_list = Entity2Models(entity_list);
|
return model_list;
|
}
|
|
/// <summary>
|
/// 通过 MonitorPointID 获取最近一条
|
/// </summary>
|
public Model.MonitorAlarmRecord GetLastByMonitorPointID(long CorpID, long MonitorPointID)
|
{
|
return GetLastByMonitorPointID(CorpID, MonitorPointID, 1)?.FirstOrDefault();
|
}
|
|
/// <summary>
|
/// 通过 MonitorPointID 获取最近几条
|
/// </summary>
|
public List<Model.MonitorAlarmRecord> GetLastByMonitorPointID(long CorpID, long MonitorPointID, int Number)
|
{
|
if (Number < 1)
|
Number = 1;
|
var dal = new DAL.MonitorAlarmRecord();
|
var entity_list = dal.GetLastByMonitorPointID(CorpID, MonitorPointID, Number);
|
var model_list = Entity2Models(entity_list);
|
return model_list;
|
}
|
|
/// <summary>
|
/// 获取模糊列表
|
/// </summary>
|
public List<Model.MonitorAlarmRecord> GetFluzzyList
|
(long CorpID, long? MonitorPointID, string AlarmType, int? AlarmLevel, int? HandleStatus, DateTime? StartTime, DateTime? EndTime)
|
{
|
var dal = new DAL.MonitorAlarmRecord();
|
var entity_list = dal.GetFluzzyList(CorpID, MonitorPointID, AlarmType, AlarmLevel, HandleStatus, StartTime, EndTime);
|
var model_list = Entity2Models(entity_list);
|
return model_list;
|
}
|
|
/// <summary>
|
/// 获取模糊分页列表
|
/// </summary>
|
public List<Model.MonitorAlarmRecord> GetFluzzyPageList
|
(long CorpID, List<long> MonitorPointIds, string AlarmType, int? AlarmLevel, int? HandleStatus, DateTime? StartTime, DateTime? EndTime,int PageIndex,int PageSize,ref int Total)
|
{
|
Total = 0;
|
if (StartTime > EndTime)
|
return default;
|
var dal = new DAL.MonitorAlarmRecord();
|
var entity_list = dal.GetFluzzyPageList(CorpID, MonitorPointIds, AlarmType, AlarmLevel, HandleStatus, StartTime, EndTime,PageIndex,PageSize,ref Total);
|
var model_list = Entity2Models(entity_list);
|
return model_list;
|
}
|
|
/// <summary>
|
/// 通过 CorpID 获取分页列表
|
/// </summary>
|
public List<Model.MonitorAlarmRecord> GetPageListByCorpID(long CorpID, DateTime StartTime, DateTime EndTime, int PageIndex, int PageSize, ref int Total)
|
{
|
Total = 0;
|
if (StartTime > EndTime)
|
return default;
|
var dal = new DAL.MonitorAlarmRecord();
|
var entity_list = dal.GetPageListByCorpID(CorpID, StartTime, EndTime, PageIndex, PageSize, ref Total);
|
var model_list = Entity2Models(entity_list);
|
return model_list;
|
}
|
|
/// <summary>
|
/// 通过 MonitorPointID 获取分页列表
|
/// </summary>
|
public List<Model.MonitorAlarmRecord> GetPageListByMonitorPointID
|
(long CorpID, long MonitorPointID, DateTime StartTime, DateTime EndTime, int PageIndex, int PageSize, ref int Total)
|
{
|
Total = 0;
|
if (StartTime > EndTime)
|
return default;
|
var dal = new DAL.MonitorAlarmRecord();
|
var entity_list = dal.GetPageListByMonitorPointID(CorpID, MonitorPointID, StartTime, EndTime, PageIndex, PageSize, ref Total);
|
var model_list = Entity2Models(entity_list);
|
return model_list;
|
}
|
|
/// <summary>
|
/// 通过 MonitorPointIds 获取分页列表
|
/// </summary>
|
public List<Model.MonitorAlarmRecord> GetPageListByMonitorPointIds
|
(long CorpID, List<long> MonitorPointIds, DateTime StartTime, DateTime EndTime, int PageIndex, int PageSize, ref int Total)
|
{
|
Total = 0;
|
if (MonitorPointIds == null || MonitorPointIds.Count() < 1)
|
return default;
|
if (StartTime > EndTime)
|
return default;
|
var dal = new DAL.MonitorAlarmRecord();
|
var entity_list = dal.GetPageListByMonitorPointIds(CorpID, MonitorPointIds, StartTime, EndTime, PageIndex, PageSize, ref Total);
|
var model_list = Entity2Models(entity_list);
|
return model_list;
|
}
|
|
/// <summary>
|
/// 获取报警类型数量列表
|
/// </summary>
|
public Dictionary<string, int> GetAlarmTypeCountList
|
(long CorpID, List<long> MonitorPointIds, int? AlarmLevel, int? HandleStatus, DateTime? StartTime, DateTime? EndTime)
|
{
|
var dal = new DAL.MonitorAlarmRecord();
|
var dict = new Dictionary<string, int>();
|
foreach (var alarmType in IStation.Alarm.GetAlarmTypeList())
|
{
|
var count= dal.GetCount(CorpID, MonitorPointIds,alarmType, AlarmLevel, HandleStatus, StartTime, EndTime );
|
dict.Add(alarmType,count);
|
}
|
return dict;
|
}
|
|
#endregion
|
|
#region Insert
|
|
/// <summary>
|
/// 插入一条数据
|
/// </summary>
|
public long Insert(Model.MonitorAlarmRecord model)
|
{
|
if (model == null)
|
return default;
|
if (model.CorpID < 1)
|
return default;
|
var entity = Model2Entity(model);
|
var dal = new DAL.MonitorAlarmRecord();
|
return dal.Insert(entity);
|
}
|
|
/// <summary>
|
/// 插入多条
|
/// </summary>
|
public bool Inserts(List<Model.MonitorAlarmRecord> list)
|
{
|
if (list == null || list.Count() < 1)
|
return default;
|
var corpIds = list.Select(x => x.CorpID).Distinct().ToList();
|
if (corpIds.Count != 1 || corpIds[0] < 1)
|
return default;
|
var entity_list = Model2Entities(list.ToList());
|
var dal = new DAL.MonitorAlarmRecord();
|
return dal.Inserts(entity_list);
|
}
|
|
/// <summary>
|
/// 插入最后一条记录
|
/// </summary>
|
public bool InsertLastRecord(Model.MonitorAlarmRecordPure model)
|
{
|
if (model == null)
|
return default;
|
if (model.CorpID < 1)
|
return default;
|
var entity = Model2Entity(model);
|
var dal = new DAL.MonitorAlarmRecord();
|
var id= dal.Insert(entity);
|
if (id > 0)
|
{
|
new RedisCache.MonitorAlarmRecordCacheHelper().SetLastRecord(model);
|
return true;
|
}
|
return false;
|
}
|
|
#endregion
|
|
#region Update
|
|
/// <summary>
|
/// 更新一条
|
/// </summary>
|
public bool Update(Model.MonitorAlarmRecord model)
|
{
|
if (model == null)
|
return default;
|
if (model.CorpID < 1)
|
return default;
|
if (model.ID < 1)
|
return default;
|
var entity = Model2Entity(model);
|
var dal = new DAL.MonitorAlarmRecord();
|
return dal.Update(entity);
|
|
}
|
|
/// <summary>
|
/// 更新多条
|
/// </summary>
|
public bool Updates(List<Model.MonitorAlarmRecord> list)
|
{
|
if (list == null || list.Count() < 1)
|
return default;
|
var corpIds = list.Select(x => x.CorpID).Distinct().ToList();
|
if (corpIds.Count != 1 || corpIds[0] < 1)
|
return default;
|
if (list.ToList().Exists(x => x.ID < 1))
|
return default;
|
var entity_list = Model2Entities(list.ToList());
|
var dal = new DAL.MonitorAlarmRecord();
|
return dal.Updates(entity_list);
|
}
|
|
/// <summary>
|
/// 更新 HandleStatus
|
/// </summary>
|
public bool UpdateHandleStatus(long CorpID, long ID, Model.Alarm.eHandleStatus HandleStatus)
|
{
|
var dal = new DAL.MonitorAlarmRecord();
|
var bol = dal.UpdateHandleStatus(CorpID, ID, (int)HandleStatus);
|
return bol;
|
}
|
|
#endregion
|
|
|
|
|
|
|
|
|
|
}
|
|
}
|
