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