From 6fb4b8d8856461d1bc0372910e19550152953213 Mon Sep 17 00:00:00 2001 From: zouyiqing <854938661@qq.com> Date: Fri, 26 Jan 2024 13:26:57 +0800 Subject: [PATCH] =?UTF-8?q?win=E4=BB=A3=E7=A0=81=E4=B8=8A=E4=BC=A0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../system/RadarStatusController.java | 125 +++++++----------- 1 file changed, 47 insertions(+), 78 deletions(-) diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/system/RadarStatusController.java b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/system/RadarStatusController.java index 538204a..cffc66a 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/system/RadarStatusController.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/system/RadarStatusController.java @@ -71,84 +71,7 @@ public class RadarStatusController implements InitializingBean { public TableDataInfo list(@RequestBody SysRadar sysRadar) { TableDataInfo rspData = new TableDataInfo(); List radarList = service.selectRadarList(sysRadar); -// int year = 2024; -// int month = 2; // 8月代表9月，因为月份是从0开始计数的 -// int day = 25; -// java.sql.Date date2 = new java.sql.Date(year - 1900, month - 1, day); -// List tsanaRadarList = new ArrayList<>(); -// TsanaRadar tsanaRadar = new TsanaRadar("111","111","111","111",date2,date2 , 1); -// TsanaRadar tsanaRadar1 = new TsanaRadar("222","222","222","222",date2,date2 , 2); -// TsanaRadar tsanaRadar2 = new TsanaRadar("333","333","333","333",date2,date2 , 3); -// TsanaRadar tsanaRadar3 = new TsanaRadar("444","444","444","444",date2,date2 , 4); -// TsanaRadar tsanaRadar4 = new TsanaRadar("555","555","555","555",date2,date2 , 5); -// tsanaRadarList.add(tsanaRadar); -// tsanaRadarList.add(tsanaRadar1); -// tsanaRadarList.add(tsanaRadar2); -// tsanaRadarList.add(tsanaRadar3); -// tsanaRadarList.add(tsanaRadar4); -// -// Connection connection = null; -// PreparedStatement preparedStatement = null; -// try { -// Class.forName("oracle.jdbc.driver.OracleDriver"); -// -// String url = "jdbc:oracle:thin:@172.16.18.195:1523:xccb"; -// String user = "radartest"; -// String password = "radartest"; -// connection = DriverManager.getConnection(url,user,password); -// System.out.println(" ============= 连接数据库成功 =========="); -// String insertStatement = "INSERT INTO xccb.TS_ANARADAR (RADARCODE, LABELCODE, LOCATIONIP , LABELNUM , TIMEBEGIN , TIMEEND , TIMECOUNT) VALUES (?, ?, ?, ?, ?, ?, ?)"; -// -// preparedStatement = connection.prepareStatement(insertStatement); -// for (TsanaRadar radar : tsanaRadarList) { -// preparedStatement.setString(1,radar.getRadarCode()); -// preparedStatement.setString(2,radar.getLabelCode()); -// preparedStatement.setString(3,radar.getLocationIp()); -// preparedStatement.setString(4,radar.getLabelNum()); -// preparedStatement.setDate(5,radar.getTimeBegin()); -// preparedStatement.setDate(6,radar.getTimeEnd()); -// preparedStatement.setInt(7,radar.getTimeCount()); -// } -// int i = preparedStatement.executeUpdate(); -// System.out.println("新增数据成功，新增数量： " + i); -// }catch (Exception e){ -// System.out.println("连接异常======" + e); -// }finally { -// // 关闭连接和statement -// if (preparedStatement != null) { -// try { -// preparedStatement.close(); -// } catch (SQLException e) { -// e.printStackTrace(); -// } -// } -// if (connection != null) { -// try { -// connection.close(); -// } catch (SQLException e) { -// e.printStackTrace(); -// } -// } -// } - - - - - - - - - - - - - - - - - - - +// oracleInsert(tsanaRadarList); PageDomain pageDomain = TableSupport.buildPageRequest(); @@ -169,6 +92,52 @@ public class RadarStatusController implements InitializingBean { return rspData; } + private static void oracleInsert(TsanaRadar tsanaRadar) { + Connection connection = null; + PreparedStatement preparedStatement = null; + try { + Class.forName("oracle.jdbc.driver.OracleDriver"); + + String url = "jdbc:oracle:thin:@172.16.18.195:1523:xccb"; + String user = "radartest"; + String password = "radartest"; + connection = DriverManager.getConnection(url,user,password); + System.out.println(" ============= 连接数据库成功 =========="); + String insertStatement = "INSERT INTO xccb.TS_ANARADAR (RADARCODE, LABELCODE, LOCATIONIP , LABELNUM , TIMEBEGIN , TIMEEND , TIMECOUNT) VALUES (?, ?, ?, ?, ?, ?, ?)"; + + preparedStatement = connection.prepareStatement(insertStatement); + + preparedStatement.setString(1,tsanaRadar.getRadarCode()); + preparedStatement.setString(2,tsanaRadar.getLabelCode()); + preparedStatement.setString(3,tsanaRadar.getLocationIp()); + preparedStatement.setString(4,tsanaRadar.getLabelNum()); + preparedStatement.setDate(5,tsanaRadar.getTimeBegin()); + preparedStatement.setDate(6,tsanaRadar.getTimeEnd()); + preparedStatement.setInt(7,tsanaRadar.getTimeCount()); + + int i = preparedStatement.executeUpdate(); + System.out.println("新增数据成功，新增数量： " + i); + }catch (Exception e){ + System.out.println("连接异常======" + e); + }finally { + // 关闭连接和statement + if (preparedStatement != null) { + try { + preparedStatement.close(); + } catch (SQLException e) { + e.printStackTrace(); + } + } + if (connection != null) { + try { + connection.close(); + } catch (SQLException e) { + e.printStackTrace(); + } + } + } + } + private void asyncWebSocket(List radarList) { CompletableFuture.runAsync(() -> {