遗漏提交

duheng

2025-02-11 7e0414c91a51219a92515c90ccb803ebade5613a

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

@@ -69,6 +69,32 @@
            }
        }

        //找出所有数据
        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>
@@ -102,7 +128,10 @@
                        t.LastPredictValue = model.LastPredictValue;
                        t.LastPredictTime = DateTime.Now;
                        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();
                        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();
                    }
                }
            }
@@ -155,8 +184,8 @@
                    foreach (var model in update_models)
                    {
                        Entity.WaterPredictRecord t = new Entity.WaterPredictRecord();
                        t.RealValue = model.RealValue;
                        db.Updateable<Entity.WaterPredictRecord>(t).UpdateColumns(t => new { t.RealValue, }).Where(t => t.ID == model.ID).ExecuteCommand();
                        t.RealTotalValue = model.RealTotalValue;
                        db.Updateable<Entity.WaterPredictRecord>(t).UpdateColumns(t => new { t.RealTotalValue, }).Where(t => t.ID == model.ID).ExecuteCommand();
                    }
                }
            }
@@ -177,7 +206,7 @@
            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;
@@ -194,9 +223,9 @@
            {
                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();
            }
        }