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 } }