From b993638e5bd8e9c4d81d5383e304f27aff02a580 Mon Sep 17 00:00:00 2001 From: Kane Wang Date: Wed, 11 May 2022 23:10:01 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8F=90=E4=BA=A4=E5=B0=8F=E4=BF=AE=E6=94=B9?= =?UTF-8?q?=EF=BC=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/DisasterWarning/disaster_warning.iml | 8 +- .../java/DisasterWarning/disaster_warning.ipr | 60 ++------------- .../wechat/officalAccount/sendMessage.java | 76 ++++++++++--------- 3 files changed, 51 insertions(+), 93 deletions(-) diff --git a/code/java/DisasterWarning/disaster_warning.iml b/code/java/DisasterWarning/disaster_warning.iml index a54c133..72d67b0 100644 --- a/code/java/DisasterWarning/disaster_warning.iml +++ b/code/java/DisasterWarning/disaster_warning.iml @@ -21,17 +21,13 @@ + + - - - - - - diff --git a/code/java/DisasterWarning/disaster_warning.ipr b/code/java/DisasterWarning/disaster_warning.ipr index 6106a45..b0d94c9 100644 --- a/code/java/DisasterWarning/disaster_warning.ipr +++ b/code/java/DisasterWarning/disaster_warning.ipr @@ -267,15 +267,15 @@ - + - + - + - + @@ -289,37 +289,15 @@ - + - + - + - - - - - - - - - - - - - - - - - - - - - - - + @@ -333,28 +311,6 @@ - - - - - - - - - - - - - - - - - - - - - - diff --git a/code/java/DisasterWarning/src/main/java/com/cpic/xim/wechat/officalAccount/sendMessage.java b/code/java/DisasterWarning/src/main/java/com/cpic/xim/wechat/officalAccount/sendMessage.java index e98c82b..5ae7419 100644 --- a/code/java/DisasterWarning/src/main/java/com/cpic/xim/wechat/officalAccount/sendMessage.java +++ b/code/java/DisasterWarning/src/main/java/com/cpic/xim/wechat/officalAccount/sendMessage.java @@ -14,6 +14,7 @@ import com.cpic.xim.config.db.OracleConfigManager; import com.cpic.xim.config.db.OracleConfig; import com.fasterxml.jackson.annotation.JsonProperty; + import java.io.IOException; import java.net.MalformedURLException; import java.util.HashMap; @@ -23,12 +24,13 @@ import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; + import com.cpic.xim.notify.disaster.*; import com.cpic.xim.httpUtil.HttpUtils; /** * 推送微信公众号消息。 - * + * * @author Kane */ public class sendMessage @@ -38,11 +40,12 @@ public class sendMessage /** * 推送天气灾害预警！接口文档参考 彭奕洁 编写《消息发送接口调用文档》 * 使用 post 方式，请求体内容以最基础的 post 格式。 + * * @param officalAccountURL 产险厦门分公司公众号接口网址 - * @param warningItem 灾害预警对象 + * @param warningItem 灾害预警对象 */ public static void sendWeatherDisasterWarning( String officalAccountURL, - QWeatherDisasterWarningItem warningItem ) + QWeatherDisasterWarningItem warningItem ) { // Vector warningItems = warningItem.getWarning(); StringBuilder requestBody = null; @@ -58,7 +61,7 @@ public class sendMessage // 拼接消息内容 String title = warningItem.getTitle(); - String text = warningItem.getText(); + String text = warningItem.getText(); String color = warningLevel.keySet().contains( warningItem.getLevel() ) ? warningLevel.get( warningItem.getLevel() ) : "#000000"; @@ -84,6 +87,7 @@ public class sendMessage * 检查预警是否已经推送过，通过 QWeatherDisasterWarningItem 对象的 id 属性。 * 查询 oracle xmcx1 数据库 wechat 表空间下 weather_disaster_notify 表， * 统计 warningID 的数量，如果不为0,说明该预警已经保存过，视为已经推送过。 + * * @param warningID 预警的id * @return 如果推送过，返回false，否则返回 true。 */ @@ -92,16 +96,17 @@ public class sendMessage { boolean result = false; - OracleConfig dbConfig = OracleConfigManager.getOracleConfig();; + OracleConfig dbConfig = OracleConfigManager.getOracleConfig(); + ; - Connection conn = null; + Connection conn = null; PreparedStatement stmt = null; - ResultSet rs = null; + ResultSet rs = null; - String jdbcURL = dbConfig.getJdbcURL(); + String jdbcURL = dbConfig.getJdbcURL(); String userName = dbConfig.getUserName(); String password = dbConfig.getPassword(); - String sql = "select count(*) from weather_disaster_notify where notify_id = ?"; + String sql = "select count(*) from weather_disaster_notify where notify_id = ?"; // Logger logger = Logger.getLogger( "com.cpicxim.wechat.officalAccount.sendMessage" ); @@ -115,7 +120,7 @@ public class sendMessage rs = stmt.executeQuery(); - if ( rs.next() && rs.getInt( 1 ) == 0) + if ( rs.next() && rs.getInt( 1 ) == 0 ) { result = true; } @@ -124,7 +129,7 @@ public class sendMessage { try { - if ( rs != null) + if ( rs != null ) { rs.close(); } @@ -136,7 +141,7 @@ public class sendMessage try { - if ( stmt != null) + if ( stmt != null ) { stmt.close(); } @@ -148,7 +153,7 @@ public class sendMessage try { - if ( conn != null) + if ( conn != null ) { conn.close(); } @@ -166,16 +171,17 @@ public class sendMessage * 保存天气预警警报数据。 * 保存至 oracle xmcx1 数据库 wechat 表空间下 weather_disaster_notify 表。 * 保存的数据用来判断预警是否已经推送过，以防止反复推送数据。 - * @param city 城市名称 - * @param warning 预警数据，为 QWeatherDisasterWarningItem 对象。 - * @throws SQLException 执行sql时可能抛出的异常。出现sql异常，就回滚事务。 - * @throws IOException 读取数据库配置文件时可能抛出的异常。 + * + * @param city 城市名称 + * @param warnings 预警数据，为 QWeatherDisasterWarningItem 对象。 + * @throws SQLException 执行sql时可能抛出的异常。出现sql异常，就回滚事务。 + * @throws IOException 读取数据库配置文件时可能抛出的异常。 * @throws ClassNotFoundException 加载oracle jdbc驱动时可能抛出的异常。 */ public static void saveWeatherDisasterWarning( String city, QWeatherDisasterWarning warnings ) throws SQLException, IOException, ClassNotFoundException { - Connection conn = null; + Connection conn = null; PreparedStatement stmt = null; String sql = "insert into weather_disaster_notify(notify_id, sender, city," @@ -184,7 +190,7 @@ public class sendMessage OracleConfig dbConfig = OracleConfigManager.getOracleConfig(); - String jdbcURL = dbConfig.getJdbcURL(); + String jdbcURL = dbConfig.getJdbcURL(); String userName = dbConfig.getUserName(); String password = dbConfig.getPassword(); @@ -221,7 +227,7 @@ public class sendMessage catch ( SQLException error ) { // 出现sql错误，就回滚！ - if ( conn != null) + if ( conn != null ) { conn.rollback(); } @@ -232,7 +238,7 @@ public class sendMessage { try { - if ( stmt != null) + if ( stmt != null ) { stmt.close(); } @@ -244,7 +250,7 @@ public class sendMessage try { - if ( conn != null) + if ( conn != null ) { conn.close(); } @@ -275,44 +281,44 @@ class WechatOfficalAccountMessageParameter WechatOfficalAccountMessageParameter() { - tplID = 57; + tplID = 57; groupID = 1; } - @JsonProperty( "tplid") + @JsonProperty("tplid") private int tplID; - @JsonProperty( "groupid") + @JsonProperty("groupid") private int groupID; - @JsonProperty( "first") + @JsonProperty("first") private String first; - @JsonProperty( "keyword1") + @JsonProperty("keyword1") private String keyword1; - @JsonProperty( "keyword1color") + @JsonProperty("keyword1color") private String keyword1Color; - @JsonProperty( "keyword2") + @JsonProperty("keyword2") private String keyword2; - @JsonProperty( "keyword2color") + @JsonProperty("keyword2color") private String keyword2Color; - @JsonProperty( "remark") + @JsonProperty("remark") private String remark; - @JsonProperty( "remarkcolor") + @JsonProperty("remarkcolor") private String remarkColor; - @JsonProperty( "url") + @JsonProperty("url") private String url; - @JsonProperty( "appid") + @JsonProperty("appid") private String appid; - @JsonProperty( "pagepath") + @JsonProperty("pagepath") private String pagePath; public int getTplID()