wyh
/
dianci
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

win代码上传

detached
zouyiqing 2024-01-26 13:26:57 +08:00
parent ddfa81b18d
commit 6fb4b8d885
1 changed files with 47 additions and 78 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

125
ruoyi-admin/src/main/java/com/ruoyi/web/controller/system/RadarStatusController.java
View File

@ -71,84 +71,7 @@ public class RadarStatusController implements InitializingBean {
public TableDataInfo list(@RequestBody SysRadar sysRadar) {
TableDataInfo rspData = new TableDataInfo();
List<SysRadar> 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<TsanaRadar> 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<SysRadar> radarList) {
CompletableFuture.runAsync(() -> {