namespace IStation.DAL.SQLite
|
{
|
/// <summary>
|
/// 能效（多）实时记录
|
/// </summary>
|
public class EtaMultiRealRecord : IEtaMultiRealRecord
|
{
|
/// <summary>
|
///
|
/// </summary>
|
public ConnectionConfig ConnectionConfig
|
{
|
get
|
{
|
var dbName = "eta.db";
|
var filePath = $"{Settings.ParasHelper.LocalFile.DataFolderDirectory}\\{dbName}";
|
var config = new ConnectionConfig
|
{
|
DbType = SqlSugar.DbType.Sqlite,//数据库类型
|
ConnectionString = $"DataSource={filePath}",
|
IsAutoCloseConnection = true,//是否自动关闭
|
MoreSettings = new ConnMoreSettings()
|
{
|
//PgSqlIsAutoToLower = false //数据库存在大写字段的 ，需要把这个设为false ，并且实体和字段名称要一样
|
},
|
AopEvents = new AopEvents
|
{
|
OnLogExecuting = (sql, p) =>
|
{
|
var sqlString = UtilMethods.GetNativeSql(sql, p);
|
}
|
},
|
ConfigureExternalServices = new ConfigureExternalServices()
|
{
|
EntityService = (property, column) =>
|
{
|
//除主键外都可空
|
if (!column.IsPrimarykey)
|
{
|
column.IsNullable = true;
|
}
|
}
|
}
|
};
|
return config;
|
}
|
}
|
|
|
|
/// <summary>
|
/// 通过 ObjectType 和 ObjectID 获取流量、扬程、日期区间内运行的汇总内容数据
|
/// </summary>
|
public List<Entity.EtaMultiRunSummaryContent> GetRunSummaryContentByStationOfQHDayRange(int Station, double Qmin, double Qmax, double Hmin, double Hmax, DateTime StartDay, DateTime EndDay)
|
{
|
//判断流量
|
if (Qmin > Qmax)
|
{
|
return default;
|
}
|
//判断扬程
|
if (Hmin > Hmax)
|
{
|
return default;
|
}
|
//判断日期
|
if (StartDay.Date > EndDay.Date)
|
{
|
return default;
|
}
|
|
using (var db = new SqlSugarClient(ConnectionConfig))
|
{
|
return db.Queryable<Entity.EtaMultiRealRecord>()
|
.GroupBy(x => new { x.Station, x.RunningCount, x.RunningFlag })
|
.Where(x => x.DataTime >= StartDay.Date && x.DataTime < EndDay.Date.AddDays(1))
|
.Where(x => x.Station == Station)
|
.Where(x => x.RunningCount > 0)
|
.Where(x => SqlFunc.Between(x.Qa, Qmin, Qmax))
|
.Where(x => SqlFunc.Between(x.Ha, Hmin, Hmax))
|
.Select(x => new Entity.EtaMultiRunSummaryContent()
|
{
|
Station = x.Station,
|
RunningCount = x.RunningCount,
|
RunningFlag = x.RunningFlag,
|
Qavg = SqlFunc.AggregateAvg(x.Qa.Value),
|
Havg = SqlFunc.AggregateAvg(x.Ha.Value),
|
Pavg = SqlFunc.AggregateAvg(x.Pa.Value),
|
Eavg = SqlFunc.AggregateAvg(x.Ea.Value),
|
Tsum = SqlFunc.AggregateSum(x.Duration)
|
}).ToList();
|
}
|
|
}
|
|
|
|
/// <summary>
|
/// 通过 ObjectType 和 ObjectID 获取时间区间内的运行QHET
|
/// </summary>
|
public List<Entity.EtaQHET> GetRunQHETByStationOfDayRange(int Station, DateTime StartDay, DateTime EndDay)
|
{
|
//判断日期
|
if (StartDay.Date > EndDay.Date)
|
{
|
return default;
|
}
|
|
using (var db = new SqlSugarClient(ConnectionConfig))
|
{
|
return db.Queryable<Model.EtaMultiRealRecord>()
|
.Where(x => x.DataTime >= StartDay.Date && x.DataTime < EndDay.Date.AddDays(1))
|
.Where(x => x.Station == Station)
|
.Where(x => x.RunningCount > 0)
|
.Select(x => new Entity.EtaQHET() { Q = x.Qa.Value, H = x.Ha.Value, E = x.Ea.Value, T = x.Duration }).ToList();
|
}
|
}
|
|
|
|
}
|
}
|
