From 096abd16d07228aba3189302a14b24f56bb63abd Mon Sep 17 00:00:00 2001
From: 张洋洋 <10611411+yang-yang-z@user.noreply.gitee.com>
Date: 星期五, 10 一月 2025 14:24:02 +0800
Subject: [PATCH] [add]h5读取改造

---
 src/main/java/com/se/simu/utils/CsvToSQLiteUtils.java |   77 +++++++++++++++++++++++++++++++++++++-
 1 files changed, 75 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/se/simu/utils/CsvToSQLiteUtils.java b/src/main/java/com/se/simu/utils/CsvToSQLiteUtils.java
index d4df8b0..94c8c5e 100644
--- a/src/main/java/com/se/simu/utils/CsvToSQLiteUtils.java
+++ b/src/main/java/com/se/simu/utils/CsvToSQLiteUtils.java
@@ -3,6 +3,7 @@
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
+import com.se.simu.domain.vo.StationRainVo;
 import org.apache.commons.csv.CSVFormat;
 import org.apache.commons.csv.CSVRecord;
 
@@ -12,6 +13,10 @@
 import java.nio.file.Files;
 import java.nio.file.Paths;
 import java.sql.*;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
 
 /**
  * CSV 鍒� SQLite 瀹炵敤绋嬪簭
@@ -161,7 +166,7 @@
      */
     public static JSONArray readCsvSaveLocal(String stationRainFile, String tableName) {
         // 1. 鍒涘缓SQLite鏁版嵁搴撹繛鎺�
-        JSONArray array=null;
+        JSONArray array = null;
         try (Connection conn = DriverManager.getConnection("jdbc:sqlite:rainfall.db")) {
             if (conn != null) {
                 // 2. 鍒涘缓琛紙濡傛灉涓嶅瓨鍦級
@@ -268,7 +273,6 @@
         } catch (SQLException e) {
             System.err.println("SQLite杩炴帴澶辫触: " + e.getMessage());
         }
-
         return null;
     }
 
@@ -299,4 +303,73 @@
         return 1440;
     }
 
+    /**
+     * 鍒嗙粍鏌ヨ
+     *
+     * @param tableName 琛ㄥ悕绉�
+     * @return {@link Double}
+     */
+    public static List<String> getNameList(String tableName) {
+        // 1. 鍒涘缓SQLite鏁版嵁搴撹繛鎺�
+        try (Connection conn = DriverManager.getConnection("jdbc:sqlite:rainfall.db")) {
+            if (conn != null) {
+                // 2. 鎵цSQL鏌ヨ
+                String queryDataSql = "SELECT station_name FROM " + tableName + " GROUP BY station_name";
+                // 3. 澶勭悊鏌ヨ缁撴灉
+                try (PreparedStatement pstmt = conn.prepareStatement(queryDataSql)) {
+                    ResultSet rs = pstmt.executeQuery();
+                    List<String> list = new ArrayList<>();
+                    while (rs.next()) {
+                        // 鑾峰彇鎬诲拰
+                        list.add(rs.getString("station_name"));
+                    }
+                    return list;
+                } catch (SQLException e) {
+                    System.err.println("鏌ヨ鏁版嵁鏃跺嚭閿�: " + e.getMessage());
+                }
+            }
+        } catch (SQLException e) {
+            System.err.println("SQLite杩炴帴澶辫触: " + e.getMessage());
+        }
+        return null;
+    }
+
+    /**
+     * 鍒嗙粍鏌ヨ
+     *
+     * @param tableName 琛ㄥ悕绉�
+     * @return {@link Double}
+     */
+    public static List<StationRainVo> getList(String tableName, String name) {
+        // 1. 鍒涘缓SQLite鏁版嵁搴撹繛鎺�
+        try (Connection conn = DriverManager.getConnection("jdbc:sqlite:rainfall.db")) {
+            if (conn != null) {
+                // 2. 鎵цSQL鏌ヨ
+                String queryDataSql = "SELECT * FROM " + tableName + " WHERE station_name='" + name + "' ORDER BY datetime asc";
+                // 3. 澶勭悊鏌ヨ缁撴灉
+                try (PreparedStatement pstmt = conn.prepareStatement(queryDataSql)) {
+                    ResultSet rs = pstmt.executeQuery();
+                    List<StationRainVo> list = new ArrayList<>();
+                    StationRainVo vo;
+                    while (rs.next()) {
+                        vo = new StationRainVo();
+                        vo.setId(rs.getLong("id"));
+                        vo.setStationName(rs.getString("station_name"));
+                        vo.setRainfall(rs.getDouble("rainfall"));
+                        vo.setLatitude(rs.getDouble("latitude"));
+                        vo.setLongitude(rs.getDouble("longitude"));
+                        vo.setDatetime(rs.getString("datetime"));
+                        list.add(vo);
+                    }
+                    return list;
+                } catch (SQLException e) {
+                    System.err.println("鏌ヨ鏁版嵁鏃跺嚭閿�: " + e.getMessage());
+                }
+            }
+        } catch (SQLException e) {
+            System.err.println("SQLite杩炴帴澶辫触: " + e.getMessage());
+        }
+        return null;
+    }
+
 }

--
Gitblit v1.9.3