using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using SqlSugar;
namespace IStation.DAL
{
///
/// 年监测记录
///
public partial class MonitorYearRecord : CorpDAL
{
///
///
///
public override ConnectionConfig ConnectionConfig
{
get { return ConfigHelper.MonitorRecordConnectionConfig; }
}
#region 通过 MonitorPointID 获取
///
/// 通过 MonitorPointID 获取
///
public List GetByMonitorPointID(long CorpID, long MonitorPointID)
{
using (var db = new SqlSugarClient(ConnectionConfig))
{
return db.Queryable()
.Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID)
.OrderBy(x => x.DataTime, OrderByType.Asc).ToList();
}
}
///
/// 通过 MonitorPointID 获取某年的数据
///
public List GetByMonitorPointIDOfYear(long CorpID, long MonitorPointID, int Year)
{
using (var db = new SqlSugarClient(ConnectionConfig))
{
return db.Queryable()
.Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID)
.Where(x => x.DataYear == Year)
.OrderBy(x => x.DataTime, OrderByType.Asc).ToList();
}
}
///
/// 通过 MonitorPointID 获取年区间的数据
///
public List GetByMonitorPointIDOfYearRange(long CorpID, long MonitorPointID, int StartYear, int EndYear)
{
using (var db = new SqlSugarClient(ConnectionConfig))
{
return db.Queryable()
.Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID)
.Where(x => x.DataYear >= StartYear && x.DataYear <= EndYear)
.OrderBy(x => x.DataTime, OrderByType.Asc).ToList();
}
}
#endregion
#region 通过 SignalID 获取
///
/// 通过 SignalID 获取
///
public List GetBySignalID(long CorpID, long MonitorPointID, long SignalID)
{
using (var db = new SqlSugarClient(ConnectionConfig))
{
return db.Queryable()
.Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID && x.SignalID == SignalID)
.OrderBy(x => x.DataTime, OrderByType.Asc).ToList();
}
}
///
/// 通过 SignalID 获取某年的数据
///
public Entity.MonitorYearRecord GetBySignalIDOfYear(long CorpID, long MonitorPointID, long SignalID, int Year)
{
using (var db = new SqlSugarClient(ConnectionConfig))
{
return db.Queryable()
.Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID && x.SignalID == SignalID)
.Where(x => x.DataYear == Year)
.First();
}
}
///
/// 通过 SignalID 获取年区间的数据
///
public List GetBySignalIDOfYearRange(long CorpID, long MonitorPointID, long SignalID, int StartYear, int EndYear)
{
using (var db = new SqlSugarClient(ConnectionConfig))
{
return db.Queryable()
.Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID && x.SignalID == SignalID)
.Where(x => x.DataYear >= StartYear && x.DataYear <= EndYear)
.OrderBy(x => x.DataTime, OrderByType.Asc).ToList();
}
}
#endregion
#region Delete
///
/// 通过 SignalID 删除某年的数据
///
public bool DeleteBySignalIDOfYear(long CorpID, long MonitorPointID, long SignalID, int Year)
{
using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
{
return db.Deleteable()
.Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID && x.SignalID == SignalID)
.Where(x => x.DataYear == Year)
.ExecuteCommand() > 0;
}
}
///
/// 通过 SignalID 删除年区间的数据
///
public bool DeleteBySignalIDOfYearRange(long CorpID, long MonitorPointID, long SignalID, int StartYear, int EndYear)
{
if (StartYear > EndYear)
return false;
using (var db = new SqlSugarClient(ConnectionConfig))
{
return db.Deleteable()
.Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID && x.SignalID == SignalID)
.Where(x => x.DataYear>=StartYear&&x.DataYear<=EndYear)
.ExecuteCommand() > 0;
}
}
#endregion
}
}