修改数据保存方式!

This commit is contained in:
Kane Wang 2022-05-12 10:09:35 +08:00
parent 6671cb69c9
commit e800558a32
4 changed files with 22 additions and 23 deletions

View File

@ -2,7 +2,7 @@
* @Author: Kane * @Author: Kane
* @Date: 2022-04-22 10:53:49 * @Date: 2022-04-22 10:53:49
* @LastEditors: Kane * @LastEditors: Kane
* @LastEditTime: 2022-05-10 19:03:56 * @LastEditTime: 2022-05-12 09:52:45
* @FilePath: \DisasterWarning\src\main\java\AppMain.java * @FilePath: \DisasterWarning\src\main\java\AppMain.java
* @Description: 和风天气预警推送厦门太保公众号主程序 * @Description: 和风天气预警推送厦门太保公众号主程序
* *
@ -111,10 +111,10 @@ public class AppMain
logger.log( Level.INFO, "{0}天气预警,日志发送成功。", new Object[] logger.log( Level.INFO, "{0}天气预警,日志发送成功。", new Object[]
{ city.getCityName()} ); { city.getCityName()} );
}
// 将发送的警报保存起来 // 将发送的警报保存起来
sendMessage.saveWeatherDisasterWarning( city.getCityName(), warning ); sendMessage.saveWeatherDisasterWarning( city.getCityName(), item );
}
} }
catch ( IOException error ) catch ( IOException error )
{ {

View File

@ -2,7 +2,7 @@
* @Author: Kane * @Author: Kane
* @Date: 2022-04-22 10:53:49 * @Date: 2022-04-22 10:53:49
* @LastEditors: Kane * @LastEditors: Kane
* @LastEditTime: 2022-05-10 19:02:32 * @LastEditTime: 2022-05-12 09:51:13
* @FilePath: \DisasterWarning\src\main\java\com\cpic\xim\wechat\officalAccount\sendMessage.java * @FilePath: \DisasterWarning\src\main\java\com\cpic\xim\wechat\officalAccount\sendMessage.java
* @Description: 用来推送公众号消息的程序库 * @Description: 用来推送公众号消息的程序库
* *
@ -172,7 +172,8 @@ public class sendMessage
* @throws IOException 读取数据库配置文件时可能抛出的异常 * @throws IOException 读取数据库配置文件时可能抛出的异常
* @throws ClassNotFoundException 加载oracle jdbc驱动时可能抛出的异常 * @throws ClassNotFoundException 加载oracle jdbc驱动时可能抛出的异常
*/ */
public static void saveWeatherDisasterWarning( String city, QWeatherDisasterWarning warnings ) public static void saveWeatherDisasterWarning( String city,
QWeatherDisasterWarningItem warning )
throws SQLException, IOException, ClassNotFoundException throws SQLException, IOException, ClassNotFoundException
{ {
Connection conn = null; Connection conn = null;
@ -197,23 +198,19 @@ public class sendMessage
conn.setAutoCommit( false ); conn.setAutoCommit( false );
for ( QWeatherDisasterWarningItem warning : warnings.getWarning() ) java.sql.Timestamp pubTime = new java.sql.Timestamp( warning.getPubTime().getTime() );
{
java.sql.Timestamp pubTime =
new java.sql.Timestamp( warning.getPubTime().getTime() );
stmt.setString( 1, warning.getId() ); stmt.setString( 1, warning.getId() );
stmt.setString( 2, warning.getSender() ); stmt.setString( 2, warning.getSender() );
stmt.setString( 3, city ); stmt.setString( 3, city );
stmt.setString( 4, warning.getLevel() ); stmt.setString( 4, warning.getLevel() );
stmt.setString( 5, warning.getType() ); stmt.setString( 5, warning.getType() );
stmt.setString( 6, warning.getTypeName() ); stmt.setString( 6, warning.getTypeName() );
stmt.setString( 7, warning.getTitle() ); stmt.setString( 7, warning.getTitle() );
stmt.setString( 8, warning.getText() ); stmt.setString( 8, warning.getText() );
stmt.setTimestamp( 9, pubTime ); stmt.setTimestamp( 9, pubTime );
stmt.execute(); stmt.execute();
}
// 没有问题就提交 // 没有问题就提交
conn.commit(); conn.commit();

View File

@ -2,7 +2,7 @@
* @Author: Kane * @Author: Kane
* @Date: 2022-04-22 10:53:49 * @Date: 2022-04-22 10:53:49
* @LastEditors: Kane * @LastEditors: Kane
* @LastEditTime: 2022-05-10 11:33:41 * @LastEditTime: 2022-05-12 09:54:36
* @FilePath: \DisasterWarning\src\test\java\com\cpic\xim\wechat\officalAccount\sendMessageTest.java * @FilePath: \DisasterWarning\src\test\java\com\cpic\xim\wechat\officalAccount\sendMessageTest.java
* @Description: * @Description:
* *
@ -75,7 +75,7 @@ public class sendMessageTest
String city = "东山县"; String city = "东山县";
sendMessage.saveWeatherDisasterWarning( city, warning ); // sendMessage.saveWeatherDisasterWarning( city, warning );
} }
catch ( Exception error ) catch ( Exception error )
{ {

2
应用/1.0/run.bat Normal file
View File

@ -0,0 +1,2 @@
java -jar disaster_warning-1.0-SNAPSHOT-jar-with-dependencies.jar
pause