using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using SqlSugar;
|
|
namespace IStation.DAL
|
{
|
/// <summary>
|
///
|
/// </summary>
|
public class MonitorRealRecord : CorpDAL<Entity.MonitorRealRecord>
|
{
|
/// <summary>
|
///
|
/// </summary>
|
public override ConnectionConfig ConnectionConfig
|
{
|
get { return ConfigHelper.MonitorRecordConnectionConfig; }
|
}
|
|
#region 通过 MonitorPointID 获取
|
|
/// <summary>
|
/// 通过 MonitorPointID 获取某天的全部数据
|
/// </summary>
|
public List<Entity.MonitorRealRecord> GetByMonitorPointIDOfDay(long CorpID, long MonitorPointID, DateTime Day)
|
{
|
if (CorpID < 1)
|
return default;
|
if (MonitorPointID < 1)
|
return default;
|
using (var db = new SqlSugarClient(ConnectionConfig))
|
{
|
return db.Queryable<Entity.MonitorRealRecord>()
|
.Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID && x.DataTime >= Day.Date && x.DataTime < Day.Date.AddDays(1))
|
.OrderBy(x => x.DataTime, OrderByType.Asc).ToList();
|
}
|
}
|
|
/// <summary>
|
/// 通过 MonitorPointID 获取某天固定数量的数据
|
/// </summary>
|
public List<Entity.MonitorRealRecord> GetFixedByMonitorPointIDOfDay(long CorpID, long MonitorPointID, DateTime Day, int Fixed)
|
{
|
if (CorpID < 1)
|
return default;
|
if (MonitorPointID < 1)
|
return default;
|
using (var db = new SqlSugarClient(ConnectionConfig))
|
{
|
var list = db.Queryable<Entity.MonitorRealRecord>()
|
.Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID && x.DataTime >= Day.Date && x.DataTime < Day.Date.AddDays(1))
|
.OrderBy(x => x.DataTime, OrderByType.Asc).ToList();
|
var group_list = list.GroupBy(x => x.MonitorPointID).ToList();
|
var fixed_list = group_list.SelectMany(x => GetFixedList(x.ToList(), Fixed)).OrderBy(x => x.DataTime).ToList();
|
return fixed_list;
|
}
|
}
|
|
/// <summary>
|
/// 通过 MonitorPointID 获取日期区间内的数据
|
/// </summary>
|
public List<Entity.MonitorRealRecord> GetByMonitorPointIDOfDayRange(long CorpID, long MonitorPointID, DateTime StartDay, DateTime EndDay)
|
{
|
if (StartDay.Date > EndDay.Date)
|
return default;
|
using (var db = new SqlSugarClient(ConnectionConfig))
|
{
|
return db.Queryable<Entity.MonitorRealRecord>()
|
.Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID && x.DataTime >= StartDay.Date && x.DataTime < EndDay.Date.AddDays(1))
|
.OrderBy(x => x.DataTime, OrderByType.Asc).ToList();
|
}
|
}
|
|
/// <summary>
|
/// 通过 MonitorPointID 获取日期区间内固定数量的数据
|
/// </summary>
|
public List<Entity.MonitorRealRecord> GetFixedByMonitorPointIDOfDayRange(long CorpID, long MonitorPointID, DateTime StartDay, DateTime EndDay, int Fixed)
|
{
|
if (StartDay.Date > EndDay.Date)
|
return default;
|
using (var db = new SqlSugarClient(ConnectionConfig))
|
{
|
var list = db.Queryable<Entity.MonitorRealRecord>()
|
.Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID && x.DataTime >= StartDay.Date && x.DataTime < EndDay.Date.AddDays(1))
|
.OrderBy(x => x.DataTime, OrderByType.Asc).ToList();
|
var group_list = list.GroupBy(x => x.MonitorPointID).ToList();
|
var fixed_list = group_list.SelectMany(x => GetFixedList(x.ToList(), Fixed)).OrderBy(x => x.DataTime).ToList();
|
return fixed_list;
|
}
|
}
|
|
/// <summary>
|
/// 通过 MonitorPointID 获取时间区间内的数据
|
/// </summary>
|
public List<Entity.MonitorRealRecord> GetByMonitorPointIDOfTimeRange(long CorpID, long MonitorPointID, DateTime StartTime, DateTime EndTime)
|
{
|
if (StartTime > EndTime)
|
return default;
|
using (var db = new SqlSugarClient(ConnectionConfig))
|
{
|
return db.Queryable<Entity.MonitorRealRecord>()
|
.Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID && x.DataTime >= StartTime && x.DataTime <= EndTime)
|
.OrderBy(x => x.DataTime, OrderByType.Asc).ToList();
|
}
|
}
|
|
/// <summary>
|
/// 通过 MonitorPointID 获取时间区间内固定数量的数据
|
/// </summary>
|
public List<Entity.MonitorRealRecord> GetFixedByMonitorPointIDOfTimeRange(long CorpID, long MonitorPointID, DateTime StartTime, DateTime EndTime, int Fixed)
|
{
|
if (StartTime > EndTime)
|
return default;
|
using (var db = new SqlSugarClient(ConnectionConfig))
|
{
|
var list = db.Queryable<Entity.MonitorRealRecord>()
|
.Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID && x.DataTime >= StartTime && x.DataTime <= EndTime)
|
.OrderBy(x => x.DataTime, OrderByType.Asc).ToList();
|
var group_list = list.GroupBy(x => x.MonitorPointID).ToList();
|
var fixed_list = group_list.SelectMany(x => GetFixedList(x.ToList(), Fixed)).OrderBy(x => x.DataTime).ToList();
|
return fixed_list;
|
}
|
}
|
|
#endregion
|
|
#region 通过 SignalID 获取
|
|
/// <summary>
|
/// 通过 SignalID 获取某一时间的数据
|
/// </summary>
|
public Entity.MonitorRealRecord GetBySignalIDOfDataTime(long CorpID, long MonitorPointID, long SignalID, DateTime DataTime)
|
{
|
using (var db = new SqlSugarClient(ConnectionConfig))
|
{
|
return db.Queryable<Entity.MonitorRealRecord>()
|
.Where(x=>x.DataTime> DataTime.AddDays(-1)&& x.DataTime<=DataTime)
|
.Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID && x.SignalID == SignalID)
|
.OrderBy(x => x.DataTime, OrderByType.Desc).First();
|
}
|
}
|
|
/// <summary>
|
/// 通过 SignalID 获取某天的全部数据
|
/// </summary>
|
public List<Entity.MonitorRealRecord> GetBySignalIDOfDay(long CorpID, long MonitorPointID, long SignalID, DateTime Day)
|
{
|
using (var db = new SqlSugarClient(ConnectionConfig))
|
{
|
return db.Queryable<Entity.MonitorRealRecord>()
|
.Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID && x.SignalID == SignalID && x.DataTime >= Day.Date && x.DataTime < Day.AddDays(1).Date)
|
.OrderBy(x => x.DataTime, OrderByType.Asc).ToList();
|
}
|
}
|
|
/// <summary>
|
/// 通过 SignalIds 获取某天的全部数据
|
/// </summary>
|
public List<Entity.MonitorRealRecord> GetBySignalIdsOfDay(long CorpID, long MonitorPointID, IEnumerable<long> SignalIds, DateTime Day)
|
{
|
if (SignalIds == null || SignalIds.Count() < 1)
|
return default;
|
using (var db = new SqlSugarClient(ConnectionConfig))
|
{
|
return db.Queryable<Entity.MonitorRealRecord>()
|
.Where(x=>x.DataTime>=Day.Date&&x.DataTime<Day.AddDays(1).Date)
|
.Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID && SignalIds.Contains(x.SignalID))
|
.OrderBy(x => x.DataTime, OrderByType.Asc).ToList();
|
}
|
}
|
|
/// <summary>
|
/// 通过 SignalID 获取某天固定数量的数据
|
/// </summary>
|
public List<Entity.MonitorRealRecord> GetFixedBySignalIDOfDay(long CorpID, long MonitorPointID, long SignalID, DateTime Day, int Fixed)
|
{
|
using (var db = new SqlSugarClient(ConnectionConfig))
|
{
|
var list = db.Queryable<Entity.MonitorRealRecord>()
|
.Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID && x.SignalID == SignalID && x.DataTime >= Day.Date && x.DataTime < Day.AddDays(1).Date)
|
.OrderBy(x => x.DataTime, OrderByType.Asc).ToList();
|
return GetFixedList(list, Fixed);
|
}
|
|
}
|
|
/// <summary>
|
/// 通过 SignalID 获取某天的第一条数据
|
/// </summary>
|
public Entity.MonitorRealRecord GetFirstBySignalIDOfDay(long CorpID, long MonitorPointID, long SignalID, DateTime Day)
|
{
|
using (var db = new SqlSugarClient(ConnectionConfig))
|
{
|
return db.Queryable<Entity.MonitorRealRecord>()
|
.Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID && x.SignalID == SignalID && x.DataTime >= Day.Date && x.DataTime < Day.AddDays(1).Date)
|
.OrderBy(x => x.DataTime, OrderByType.Asc).First();
|
}
|
}
|
|
/// <summary>
|
/// 通过 SignalID 获取某天的最后一条数据
|
/// </summary>
|
public Entity.MonitorRealRecord GetLastBySignalIDOfDay(long CorpID, long MonitorPointID, long SignalID, DateTime Day)
|
{
|
using (var db = new SqlSugarClient(ConnectionConfig))
|
{
|
return db.Queryable<Entity.MonitorRealRecord>()
|
.Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID && x.SignalID == SignalID && x.DataTime >= Day.Date && x.DataTime < Day.AddDays(1).Date)
|
.OrderBy(x => x.DataTime, OrderByType.Desc).First();
|
}
|
}
|
|
/// <summary>
|
/// 通过 SignalID 获取日期区间内的数据
|
/// </summary>
|
public List<Entity.MonitorRealRecord> GetBySignalIDOfDayRange(long CorpID, long MonitorPointID, long SignalID, DateTime StartDay, DateTime EndDay)
|
{
|
if (StartDay.Date > EndDay.Date)
|
return default;
|
using (var db = new SqlSugarClient(ConnectionConfig))
|
{
|
return db.Queryable<Entity.MonitorRealRecord>()
|
.Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID && x.SignalID == SignalID && x.DataTime >= StartDay.Date && x.DataTime < EndDay.AddDays(1).Date)
|
.OrderBy(x => x.DataTime, OrderByType.Asc).ToList();
|
}
|
}
|
|
/// <summary>
|
/// 通过 SignalID 获取日期区间内固定数量的数据
|
/// </summary>
|
public List<Entity.MonitorRealRecord> GetFixedBySignalIDOfDayRange(long CorpID, long MonitorPointID, long SignalID, DateTime StartDay, DateTime EndDay, int Fixed)
|
{
|
if (StartDay.Date > EndDay.Date)
|
return default;
|
using (var db = new SqlSugarClient(ConnectionConfig))
|
{
|
var list = db.Queryable<Entity.MonitorRealRecord>()
|
.Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID && x.SignalID == SignalID && x.DataTime >= StartDay.Date && x.DataTime < EndDay.AddDays(1).Date)
|
.OrderBy(x => x.DataTime, OrderByType.Asc).ToList();
|
return GetFixedList(list, Fixed);
|
}
|
|
}
|
|
/// <summary>
|
/// 通过 SignalID 获取日期区间内的第一条数据
|
/// </summary>
|
public Entity.MonitorRealRecord GetFirstBySignalIDOfDayRange(long CorpID, long MonitorPointID, long SignalID, DateTime StartDay, DateTime EndDay)
|
{
|
if (StartDay.Date > EndDay.Date)
|
return default;
|
using (var db = new SqlSugarClient(ConnectionConfig))
|
{
|
return db.Queryable<Entity.MonitorRealRecord>()
|
.Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID && x.SignalID == SignalID && x.DataTime >= StartDay.Date && x.DataTime < EndDay.AddDays(1).Date)
|
.OrderBy(x => x.DataTime, OrderByType.Asc).First();
|
}
|
}
|
|
/// <summary>
|
/// 通过 SignalID 获取日期区间内的最后一条数据
|
/// </summary>
|
public Entity.MonitorRealRecord GetLastBySignalIDOfDayRange(long CorpID, long MonitorPointID, long SignalID, DateTime StartDay, DateTime EndDay)
|
{
|
if (StartDay.Date > EndDay.Date)
|
return default;
|
using (var db = new SqlSugarClient(ConnectionConfig))
|
{
|
return db.Queryable<Entity.MonitorRealRecord>()
|
.Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID && x.SignalID == SignalID && x.DataTime >= StartDay.Date && x.DataTime < EndDay.AddDays(1).Date)
|
.OrderBy(x => x.DataTime, OrderByType.Desc).First();
|
}
|
}
|
|
/// <summary>
|
/// 通过 SignalID 获取时间区间内的数据
|
/// </summary>
|
public List<Entity.MonitorRealRecord> GetBySignalIDOfTimeRange(long CorpID, long MonitorPointID, long SignalID, DateTime StartTime, DateTime EndTime)
|
{
|
if (StartTime > EndTime)
|
return default;
|
using (var db = new SqlSugarClient(ConnectionConfig))
|
{
|
return db.Queryable<Entity.MonitorRealRecord>()
|
.Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID && x.SignalID == SignalID && x.DataTime >= StartTime && x.DataTime <= EndTime)
|
.OrderBy(x => x.DataTime, OrderByType.Asc).ToList();
|
}
|
}
|
|
/// <summary>
|
/// 通过 SignalID 获取时间区间内固定数量的数据
|
/// </summary>
|
public List<Entity.MonitorRealRecord> GetFixedBySignalIDOfTimeRange(long CorpID, long MonitorPointID, long SignalID, int Fixed, DateTime StartTime, DateTime EndTime)
|
{
|
if (StartTime > EndTime)
|
return default;
|
using (var db = new SqlSugarClient(ConnectionConfig))
|
{
|
var list = db.Queryable<Entity.MonitorRealRecord>()
|
.Where(x=>x.DataTime>=StartTime&&x.DataTime<=EndTime)
|
.Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID && x.SignalID == SignalID)
|
.OrderBy(x => x.DataTime, OrderByType.Asc).ToList();
|
return GetFixedList(list, Fixed);
|
}
|
}
|
|
/// <summary>
|
/// 通过 SignalID 获取时间区间内的第一条数据
|
/// </summary>
|
public Entity.MonitorRealRecord GetFirstBySignalIDOfTimeRange(long CorpID, long MonitorPointID, long SignalID, DateTime StartTime, DateTime EndTime)
|
{
|
if (StartTime > EndTime)
|
return default;
|
using (var db = new SqlSugarClient(ConnectionConfig))
|
{
|
return db.Queryable<Entity.MonitorRealRecord>()
|
.Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID && x.SignalID == SignalID && x.DataTime >= StartTime && x.DataTime <= EndTime)
|
.OrderBy(x => x.DataTime, OrderByType.Asc).First();
|
}
|
}
|
|
/// <summary>
|
/// 通过 SignalID 获取时间区间内的最后一条数据
|
/// </summary>
|
public Entity.MonitorRealRecord GetLastBySignalIDOfTimeRange(long CorpID, long MonitorPointID, long SignalID, DateTime StartTime, DateTime EndTime)
|
{
|
if (StartTime > EndTime)
|
return default;
|
using (var db = new SqlSugarClient(ConnectionConfig))
|
{
|
return db.Queryable<Entity.MonitorRealRecord>()
|
.Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID && x.SignalID == SignalID && x.DataTime >= StartTime && x.DataTime <= EndTime)
|
.OrderBy(x => x.DataTime, OrderByType.Desc).First();
|
}
|
}
|
|
#endregion
|
|
#region Method
|
|
//返回固定数量的列表(包含首位和末位、均匀分布)
|
private static List<T> GetFixedList<T>(List<T> s, int n)
|
{
|
if (s == null || s.Count < 1)
|
return s;
|
if (n <= 0)
|
return null;
|
if (n == 1)
|
return new List<T>() { s.First() };
|
if (s.Count <= n)
|
return s;
|
var r = new List<T>();
|
float step = (s.Count - 1f) / (n - 1f);
|
for (int i = 0; i < n; i++)
|
{
|
r.Add(s[(int)Math.Round(step * i)]);
|
}
|
return r;
|
}
|
|
#endregion
|
|
#region Update
|
|
/// <summary>
|
/// 更新
|
/// </summary>
|
public override bool Update(Entity.MonitorRealRecord entity)
|
{
|
if (entity == null)
|
return false;
|
using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
|
{
|
return db.Updateable(entity).IgnoreColumns(x => x.DataTime).Where(x=>x.ID==entity.ID).ExecuteCommand() > 0;
|
}
|
}
|
|
/// <summary>
|
/// 批量更新
|
/// </summary>
|
public override bool Updates(List<Entity.MonitorRealRecord> list)
|
{
|
if (list == null || list.Count < 1)
|
return false;
|
var corpIds = list.Select(x => x.CorpID).Distinct().ToList();
|
if (corpIds.Count() != 1 || corpIds[0] < 1)
|
return false;
|
using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
|
{
|
return db.Updateable(list).IgnoreColumns(x => x.DataTime).WhereColumns(it => new { it.ID }).ExecuteCommand() > 0;
|
}
|
}
|
|
#endregion
|
|
#region Delete
|
|
/// <summary>
|
/// 通过 SignalID 删除数据时间下的数据
|
/// </summary>
|
public bool DeleteBySignalIDOfDataTime(long CorpID,long MonitorPointID,long SignalID,DateTime DataTime)
|
{
|
using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
|
{
|
return db.Deleteable<Entity.MonitorRealRecord>()
|
.Where(x => x.CorpID == CorpID && x.MonitorPointID ==MonitorPointID&&x.SignalID==SignalID)
|
.Where(x=>x.DataTime>DataTime.AddSeconds(-1)&&x.DataTime<DataTime.AddSeconds(1))
|
.ExecuteCommand() > 0;
|
}
|
}
|
|
/// <summary>
|
/// 通过 SignalID 删除时间区间下的数据
|
/// </summary>
|
public bool DeleteBySignalIDOfTimeRange(long CorpID, long MonitorPointID, long SignalID, DateTime StartTime, DateTime EndTime)
|
{
|
if (EndTime < StartTime)
|
return false;
|
using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
|
{
|
return db.Deleteable<Entity.MonitorRealRecord>()
|
.Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID && x.SignalID == SignalID)
|
.Where(x => x.DataTime > StartTime.AddSeconds(-1) && x.DataTime < EndTime.AddSeconds(1))
|
.ExecuteCommand() > 0;
|
}
|
}
|
|
#endregion
|
}
|
}
|
