遗漏提交

duheng

2025-02-11 7e0414c91a51219a92515c90ccb803ebade5613a

 WaterPredict/IStation.ChEr.DAL.WaterPredict/BLL/WaterPredict.cs

@@ -4,18 +4,16 @@
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))
@@ -36,10 +34,11 @@
                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))
@@ -51,7 +50,7 @@
        /// <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))
@@ -60,10 +59,43 @@
            }
        }

        //找出最近数据
        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());
            }
        }

        //找出所有数据
        public List<Model.WaterPredictRecord> GetAll()
        {
            var ConnectionConfig = ConnectionFactory.MainConnection(DateTime.Now.Year);
            using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
            {
                var entitys = db.Queryable<Entity.WaterPredictRecord>().ToList();
                return Entity2Models(entitys);
            }
        }

        //找出所有数据
        public List<Model.WaterPredictRecord> GetEndData(int num)
        {
            var ConnectionConfig = ConnectionFactory.MainConnection(DateTime.Now.Year);
            using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
            {
                int totalRecords = db.Queryable<Entity.WaterPredictRecord>().Count();
                var entitys = db.Queryable<Entity.WaterPredictRecord>()
                                .Skip(totalRecords - num)
                                .Take(num)
                                .ToList();
                return Entity2Models(entitys);
            }
        }

        #endregion Get


        /// <summary>
        /// 批量设置:每次更新23条, 添加1条
@@ -74,40 +106,38 @@
                return default;
            var entities = Model2Entities(list.ToList());

            var insert_model = list.Find(x => x.ID == 0);
            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_model != null)
                if (insert_models != null)
                {
                    var insert_entity = Model2Entity(insert_model);
                    db.Insertable(insert_entity).ExecuteReturnSnowflakeId();
                    var insert_entity = Model2Entities(insert_models);
                    db.Insertable(insert_entity).ExecuteReturnSnowflakeIdList();
                }
                //更新滚动数据
                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;
                        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

@@ -138,8 +168,28 @@
            var ConnectionConfig = ConnectionFactory.MainConnection(DateTime.Now.Year);
            using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Insertable(list).ExecuteReturnSnowflakeIdList().Count() > 0;
            } 
                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
@@ -156,11 +206,11 @@
            if (model.ID < 1)
                return default;
            var entity = Model2Entity(model);
            var ConnectionConfig = ConnectionFactory.MainConnection(model.PredictTime.Year);
            var ConnectionConfig = ConnectionFactory.MainConnection(DateTime.Now.Year);
            using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Updateable(entity).ExecuteCommand() > 0;
            } 
            }
        }

        /// <summary>
@@ -173,16 +223,13 @@
            {
                Entity.WaterPredictRecord t = new Entity.WaterPredictRecord();
                t.ID = ID;
                t.RealValue = RealValue;
                t.RealTotalValue = RealValue;

                return db.Updateable<Entity.WaterPredictRecord>(t).UpdateColumns(t => new { t.RealValue }).Where(t => t.ID == ID).ExecuteCommand();
                return db.Updateable<Entity.WaterPredictRecord>(t).UpdateColumns(t => new { t.RealTotalValue }).Where(t => t.ID == ID).ExecuteCommand();
            }
        }

        #endregion Update




        #region Delete