| | |
| | | namespace IStation.ChEr.BLL |
| | | { |
| | | /// <summary> |
| | | /// |
| | | /// |
| | | /// </summary> |
| | | public partial class WaterPredictRecord |
| | | public partial class WaterPredictRecord |
| | | { |
| | | |
| | | #region Get |
| | | |
| | | |
| | | /// <summary> |
| | | /// 查询num条 |
| | | /// </summary> |
| | | public List<Model.WaterPredictRecord> GetLast (int num) |
| | | public List<Model.WaterPredictRecord> GetLast(int num) |
| | | { |
| | | 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( ) |
| | | public List<Model.WaterPredictRecord> GetLast48() |
| | | { |
| | | var ConnectionConfig = ConnectionFactory.MainConnection(DateTime.Now.Year); |
| | | using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig)) |
| | |
| | | /// <summary> |
| | | /// 根据 ID 查询 |
| | | /// </summary> |
| | | public Model.WaterPredictRecord QueryByID(long id) |
| | | public Model.WaterPredictRecord QueryByID(long id) |
| | | { |
| | | var ConnectionConfig = ConnectionFactory.MainConnection(DateTime.Now.Year); |
| | | using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig)) |
| | |
| | | } |
| | | } |
| | | |
| | | |
| | | //找出最近数据 |
| | | public List<Model.WaterPredictRecord> GerEnd2Days(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条 |
| | |
| | | //更新滚动数据 |
| | | if (update_models != null) |
| | | { |
| | | foreach(var model in update_models) |
| | | foreach (var model in update_models) |
| | | { |
| | | Entity.WaterPredictRecord t = new Entity.WaterPredictRecord(); |
| | | t.ID = model.ID; |
| | | t.LastPredictValue = model.LastPredictValue; |
| | | t.LastPredictTime = DateTime.Now; |
| | | |
| | | db.Updateable<Entity.WaterPredictRecord>(t).UpdateColumns(t => new { t.LastPredictValue, t.LastPredictTime }).Where(t => t.ID == model.ID).ExecuteCommand(); |
| | | t.PredictValueList = model.PredictValueList; |
| | | db.Updateable<Entity.WaterPredictRecord>(t).UpdateColumns(t => new { t.LastPredictValue, t.LastPredictTime, t.PredictValueList }).Where(t => t.ID == model.ID).ExecuteCommand(); |
| | | } |
| | | } |
| | | |
| | | |
| | | } |
| | | |
| | | |
| | | |
| | | return true; |
| | | } |
| | | |
| | | |
| | | #region Insert |
| | | |
| | |
| | | using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig)) |
| | | { |
| | | return db.Insertable(list).ExecuteReturnSnowflakeIdList().Count() > 0; |
| | | } |
| | | // db.Insertable(entities).ExecuteCommand(); |
| | | //return true; |
| | | } |
| | | } |
| | | |
| | | #endregion Insert |
| | |
| | | using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig)) |
| | | { |
| | | return db.Updateable(entity).ExecuteCommand() > 0; |
| | | } |
| | | } |
| | | } |
| | | |
| | | /// <summary> |
| | |
| | | } |
| | | |
| | | #endregion Update |
| | | |
| | | |
| | | |
| | | |
| | | #region Delete |
| | | |