using IStation.ChEr.DAL;
|
using SqlSugar;
|
|
namespace IStation.ChEr.BLL
|
{
|
/// <summary>
|
///
|
/// </summary>
|
public partial class WaterPredictRecord
|
{
|
#region Get
|
|
/// <summary>
|
/// 查询num条
|
/// </summary>
|
public List<Model.WaterPredictRecord> GetLast(int num)
|
{
|
var ConnectionConfig = ConnectionFactory.MainConnection(DateTime.Now.Year);
|
using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
|
{
|
var entitys = db.Queryable<Entity.WaterPredictRecord>().Take(num).ToList();
|
return Entity2Models(entitys);
|
}
|
}
|
|
/// <summary>
|
/// 查询24条
|
/// </summary>
|
public List<Model.WaterPredictRecord> GetLast24()
|
{
|
var ConnectionConfig = ConnectionFactory.MainConnection(DateTime.Now.Year);
|
using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
|
{
|
return Entity2Models(db.Queryable<Entity.WaterPredictRecord>().Take(24).ToList());
|
}
|
}
|
|
/// <summary>
|
/// 查询48条
|
/// </summary>
|
public List<Model.WaterPredictRecord> GetLast48()
|
{
|
var ConnectionConfig = ConnectionFactory.MainConnection(DateTime.Now.Year);
|
using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
|
{
|
return Entity2Models(db.Queryable<Entity.WaterPredictRecord>().Take(48).ToList());
|
}
|
}
|
|
/// <summary>
|
/// 根据 ID 查询
|
/// </summary>
|
public Model.WaterPredictRecord QueryByID(long id)
|
{
|
var ConnectionConfig = ConnectionFactory.MainConnection(DateTime.Now.Year);
|
using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
|
{
|
return Entity2Model(db.Queryable<Entity.WaterPredictRecord>().First(x => x.ID == id));
|
}
|
}
|
|
//找出最近数据
|
public List<Model.WaterPredictRecord> GetEnd2Days(int num)
|
{
|
var ConnectionConfig = ConnectionFactory.MainConnection(DateTime.Now.Year);
|
using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
|
{
|
return Entity2Models(db.Queryable<Entity.WaterPredictRecord>().OrderBy(x => x.DayHour, OrderByType.Desc).Take(num).ToList());
|
}
|
}
|
|
#endregion Get
|
|
/// <summary>
|
/// 批量设置:每次更新23条, 添加1条
|
/// </summary>
|
public bool BatSet(List<Model.WaterPredictRecord> list)
|
{
|
if (list == null || list.Count() < 1)
|
return default;
|
var entities = Model2Entities(list.ToList());
|
|
var insert_models = list.Where(x => x.ID == 0).ToList();
|
var update_models = list.Where(x => x.ID > 0);
|
|
var ConnectionConfig = ConnectionFactory.MainConnection(DateTime.Now.Year);
|
using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
|
{
|
//插入新的预测
|
if (insert_models != null)
|
{
|
var insert_entity = Model2Entities(insert_models);
|
db.Insertable(insert_entity).ExecuteReturnSnowflakeIdList();
|
}
|
//更新滚动数据
|
if (update_models != null)
|
{
|
foreach (var model in update_models)
|
{
|
Entity.WaterPredictRecord t = new Entity.WaterPredictRecord();
|
t.ID = model.ID;
|
t.LastPredictValue = model.LastPredictValue;
|
t.LastPredictTime = DateTime.Now;
|
t.PredictValueList = model.PredictValueList;
|
t.BakData = model.BakData;
|
t.States = model.States;
|
t.Description = model.Description;
|
db.Updateable<Entity.WaterPredictRecord>(t).UpdateColumns(t => new { t.LastPredictValue, t.LastPredictTime, t.PredictValueList, t.Description, t.BakData, t.States }).Where(t => t.ID == model.ID).ExecuteCommand();
|
}
|
}
|
}
|
|
return true;
|
}
|
|
#region Insert
|
|
/// <summary>
|
/// 插入
|
/// </summary>
|
public long Insert(Model.WaterPredictRecord model)
|
{
|
if (model == null)
|
return default;
|
var entity = Model2Entity(model);
|
|
var ConnectionConfig = ConnectionFactory.MainConnection(DateTime.Now.Year);
|
using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
|
{
|
return db.Insertable(entity).ExecuteReturnSnowflakeId();
|
}
|
}
|
|
/// <summary>
|
/// 批量插入
|
/// </summary>
|
public bool Inserts(List<Model.WaterPredictRecord> list)
|
{
|
if (list == null || list.Count() < 1)
|
return default;
|
var entities = Model2Entities(list.ToList());
|
var ConnectionConfig = ConnectionFactory.MainConnection(DateTime.Now.Year);
|
using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
|
{
|
return db.Insertable(entities).ExecuteReturnSnowflakeIdList().Count() > 0;
|
}
|
}
|
|
//批量修改RealValue
|
public bool UpdatesRealValue(List<Model.WaterPredictRecord> list)
|
{
|
var update_models = list.Where(x => x.ID > 0);
|
var ConnectionConfig = ConnectionFactory.MainConnection(DateTime.Now.Year);
|
using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
|
{
|
if (update_models != null)
|
{
|
foreach (var model in update_models)
|
{
|
Entity.WaterPredictRecord t = new Entity.WaterPredictRecord();
|
t.RealTotalValue = model.RealTotalValue;
|
db.Updateable<Entity.WaterPredictRecord>(t).UpdateColumns(t => new { t.RealTotalValue, }).Where(t => t.ID == model.ID).ExecuteCommand();
|
}
|
}
|
}
|
return true;
|
}
|
|
#endregion Insert
|
|
#region Update
|
|
/// <summary>
|
/// 更新
|
/// </summary>
|
public bool Update(Model.WaterPredictRecord model)
|
{
|
if (model == null)
|
return default;
|
if (model.ID < 1)
|
return default;
|
var entity = Model2Entity(model);
|
var ConnectionConfig = ConnectionFactory.MainConnection(DateTime.Now.Year);
|
using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
|
{
|
return db.Updateable(entity).ExecuteCommand() > 0;
|
}
|
}
|
|
/// <summary>
|
/// 更新 实时数据
|
/// </summary>
|
public int UpdateRealValue(long ID, DateTime PredictTime, double RealValue)
|
{
|
var ConnectionConfig = ConnectionFactory.MainConnection(PredictTime.Year);
|
using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
|
{
|
Entity.WaterPredictRecord t = new Entity.WaterPredictRecord();
|
t.ID = ID;
|
t.RealTotalValue = RealValue;
|
|
return db.Updateable<Entity.WaterPredictRecord>(t).UpdateColumns(t => new { t.RealTotalValue }).Where(t => t.ID == ID).ExecuteCommand();
|
}
|
}
|
|
#endregion Update
|
|
#region Delete
|
|
///// <summary>
|
///// 根据 ID 删除
|
///// </summary>
|
//public bool DeleteByID(long id, out string msg)
|
//{
|
// msg = string.Empty;
|
// var bol = _dal.DeleteByID(id);
|
// if (bol)
|
// {
|
// RemoveCache(id);
|
// }
|
// return bol;
|
//}
|
|
#endregion Delete
|
}
|
}
|
