From d662c08aee9ea241eb5ef89e60eee704667ca47c Mon Sep 17 00:00:00 2001 From: tangxu <tangxu76880903> Date: 星期一, 13 五月 2024 09:26:11 +0800 Subject: [PATCH] 文件遗漏 --- Model/IStation.Model.Basic/waterLevel/WaterPredictRecord.cs | 73 ++++++++++++++++++++++++ DAL/IStation.DAL.Project/DAL/WaterPredictRecord.cs | 68 ++++++++++++++++++++++ 2 files changed, 141 insertions(+), 0 deletions(-) diff --git a/DAL/IStation.DAL.Project/DAL/WaterPredictRecord.cs b/DAL/IStation.DAL.Project/DAL/WaterPredictRecord.cs new file mode 100644 index 0000000..00b43f8 --- /dev/null +++ b/DAL/IStation.DAL.Project/DAL/WaterPredictRecord.cs @@ -0,0 +1,68 @@ +锘縰sing System; +using System.Collections.Generic; +using System.IO; +using System.Linq; +using System.Text; +using System.Threading.Tasks; +using SqlSugar; + +namespace IStation.DAL +{ + public class WaterPredictRecord + { + + static Dictionary<int, ConnectionConfig> _connectionConfigDict = new Dictionary<int, ConnectionConfig>(); + public static ISqlSugarClient CreateConnection(int year) + { + if (_connectionConfigDict.ContainsKey(year)) + { + return new SqlSugarClient(_connectionConfigDict[year]); + } + + var root_directory = System.Configuration.ConfigurationManager.AppSettings["WaterPredictDsPath"]; + if (System.IO.File.Exists(root_directory) || !System.IO.Directory.Exists(root_directory)) + { + throw new Exception($"缂哄皯WaterPredictDsPath閰嶇疆"); + } + var dsName = string.Format("WaterPredict{0}.db", year); + + var filePath = Path.Combine(root_directory, dsName); + if (!System.IO.File.Exists(filePath)) + { + throw new Exception($"缂哄皯db鏂囦欢:"+ dsName); + } + + var connectionConfig = new ConnectionConfig() + { + DbType = SqlSugar.DbType.Sqlite, + ConnectionString = "Data Source=" + filePath,// + ";Version=3;", + IsAutoCloseConnection = true,//鏄惁鑷姩鍏抽棴 + }; + + _connectionConfigDict[year] = connectionConfig; + ISqlSugarClient conn = new SqlSugarClient(connectionConfig); + return conn; + } + + + + #region Query + + /// <summary> + /// 鏌ヨnum鏉� + /// </summary> + public List<IStation.Model.WaterPredictRecord> GetLast(int num) + { + using (ISqlSugarClient db = CreateConnection(DateTime.Now.Year)) + { + return db.Queryable<IStation.Model.WaterPredictRecord>().Take(num).ToList(); + } + } + + + + + #endregion + + } +} diff --git a/Model/IStation.Model.Basic/waterLevel/WaterPredictRecord.cs b/Model/IStation.Model.Basic/waterLevel/WaterPredictRecord.cs new file mode 100644 index 0000000..01a529c --- /dev/null +++ b/Model/IStation.Model.Basic/waterLevel/WaterPredictRecord.cs @@ -0,0 +1,73 @@ +锘縰sing System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace IStation.Model +{ + /// <summary> + /// + /// </summary> + public class WaterPredictRecord //: Model.BaseModel, System.ICloneable + { + /// <summary> + /// + /// </summary> + public WaterPredictRecord() { } + /// <summary> + /// + /// </summary> + /// <param name="rhs"></param> + public WaterPredictRecord(WaterPredictRecord rhs) + { + this.ID = rhs.ID; + this.DayHour = rhs.DayHour; + this.LastPredictValue = rhs.LastPredictValue; + this.RealValue = rhs.RealValue; + this.LastPredictTime = rhs.LastPredictTime; + + this.PredictValueList = rhs.PredictValueList; + this.PredictTime = rhs.PredictTime; + } + + /// <summary> + /// id + /// </summary> + public long ID { get; set; } + + /// <summary> + /// 灏忔椂: 渚嬪2024-05-14 01:00 琛ㄧず涓� 051401 + /// </summary> + public int DayHour { get; set; } + + /// <summary> + /// 鐪熷疄绱娴侀噺 + /// </summary> + public double RealValue { get; set; } + + /// <summary> + /// 鏈�鏂伴娴嬫祦閲�(婊氬姩鍊�) + /// </summary> + public double LastPredictValue { get; set; } + + /// <summary> + /// 鏈�鏂伴娴嬫椂闂�(婊氬姩鍊煎搴旀椂闂�) + /// </summary> + public DateTime LastPredictTime { get; set; } + + /// <summary> + /// 棰勬祴娴侀噺鍊�(澶氫釜鐢ㄩ�楀彿闅斿紑) + /// </summary> + public string PredictValueList { get; set; } + + /// <summary> + /// 棰勬祴娴侀噺鍊兼椂闂�:PredictValueList瀵瑰簲鏃堕棿 + /// </summary> + public DateTime PredictTime { get; set; } + + + + + } +} \ No newline at end of file -- Gitblit v1.9.3