完成日志功能!
This commit is contained in:
parent
1231fe3132
commit
2847747f53
@ -3,6 +3,7 @@
|
||||
"key": "fe9fa8eeeb6f4301a92541eed565dd15",
|
||||
"query_url": "https://devapi.qweather.com/v7/warning/now?",
|
||||
"wechat_officalaccount_url": "https://cxxmwx.cpic.com.cn/app/index.php?i=2&c=entry&do=send_group_tpl_api&m=ok_tplmessage",
|
||||
"query_interval": 10,
|
||||
"cities": [
|
||||
{
|
||||
"city_name": "厦门",
|
||||
|
||||
@ -2,12 +2,13 @@
|
||||
* @Author: Kane
|
||||
* @Date: 2022-04-22 10:53:49
|
||||
* @LastEditors: Kane
|
||||
* @LastEditTime: 2022-05-10 16:01:13
|
||||
* @LastEditTime: 2022-05-10 16:28:07
|
||||
* @FilePath: \DisasterWarning\src\main\java\AppMain.java
|
||||
* @Description: 和风天气预警推送厦门太保公众号主程序！
|
||||
*
|
||||
* Copyright (c) ${2022} by Kane, All Rights Reserved.
|
||||
*/
|
||||
import com.cpic.xim.config.AppConfigManager;
|
||||
import com.cpic.xim.config.City;
|
||||
import com.cpic.xim.notify.disaster.QWeatherDisasterWarning;
|
||||
import com.cpic.xim.notify.disaster.WeatherDisasterWarningGrabber;
|
||||
@ -48,7 +49,7 @@ public class AppMain
|
||||
// 读取配置
|
||||
try
|
||||
{
|
||||
config = WeatherDisasterNotifyConfig.getConfig();
|
||||
config = AppConfigManager.getConfig();
|
||||
}
|
||||
catch ( IOException error )
|
||||
{
|
||||
@ -65,59 +66,73 @@ public class AppMain
|
||||
String userKey = config.getKey();
|
||||
|
||||
// 遍历所有城市，查询是否有警报，有则推送。
|
||||
for ( City city : cities )
|
||||
while (true)
|
||||
{
|
||||
for ( City city : cities )
|
||||
{
|
||||
try
|
||||
{
|
||||
json = WeatherDisasterWarningGrabber.getWeatherDisasterWarningJSON( queryURL,
|
||||
userKey, city.getCityCode() );
|
||||
warning = WeatherDisasterWarningGrabber.convertWeatherDisasterWarning( json );
|
||||
|
||||
logger.log( Level.INFO, "查询{0}天气预警，结果：{1}。", new Object[]
|
||||
{ city.getCityName(), json} );
|
||||
|
||||
// 判断是否有警报
|
||||
if ( warning.getWarning().isEmpty() == true)
|
||||
{
|
||||
logger.log( Level.INFO, "查询{0}天气预警，无警报！。", new Object[]
|
||||
{ city.getCityName()} );
|
||||
continue;
|
||||
}
|
||||
|
||||
logger.log( Level.INFO, "查询{0}天气预警，发送日志。", new Object[]
|
||||
{ city.getCityName()} );
|
||||
|
||||
sendMessage.sendWeatherDisasterWarning( config.getWechatOfficalAccountURL(),
|
||||
warning );
|
||||
|
||||
logger.log( Level.INFO, "{0}天气预警，日志发送成功。", new Object[]
|
||||
{ city.getCityName()} );
|
||||
|
||||
sendMessage.saveWeatherDisasterWarning( city.getCityName(), warning );
|
||||
}
|
||||
catch ( IOException error )
|
||||
{
|
||||
System.out.println( "查询" + city.getCityName() + "出现异常！" );
|
||||
System.out.println( error.getMessage() );
|
||||
|
||||
logger.log( Level.SEVERE, "查询 {0} 出现异常:{1}。", new Object[]
|
||||
{ city.getCityName(), error.getMessage()} );
|
||||
}
|
||||
catch ( SQLException error )
|
||||
{
|
||||
logger.log( Level.SEVERE, "查询 {0} 写入数据库失败:{1}。", new Object[]
|
||||
{ city.getCityName(), error.getMessage()} );
|
||||
}
|
||||
catch ( ClassNotFoundException error )
|
||||
{
|
||||
logger.log( Level.SEVERE, "查询 {0} 加载oracle驱动失败:{1}。", new Object[]
|
||||
{ city.getCityName(), error.getMessage()} );
|
||||
|
||||
}
|
||||
catch ( Exception error )
|
||||
{
|
||||
logger.log( Level.SEVERE, "查询 {0} 出现未知错误:{1}。", new Object[]
|
||||
{ city.getCityName(), error.getMessage()} );
|
||||
}
|
||||
}
|
||||
|
||||
try
|
||||
{
|
||||
json = WeatherDisasterWarningGrabber.getWeatherDisasterWarningJSON( queryURL,
|
||||
userKey, city.getCityCode() );
|
||||
warning = WeatherDisasterWarningGrabber.convertWeatherDisasterWarning( json );
|
||||
|
||||
logger.log( Level.INFO, "查询{0}天气预警，结果：{1}。", new Object[]
|
||||
{ city.getCityName(), json} );
|
||||
|
||||
// 判断是否有警报
|
||||
if ( warning.getWarning().isEmpty() == true)
|
||||
{
|
||||
logger.log( Level.INFO, "查询{0}天气预警，无警报！。", new Object[]
|
||||
{ city.getCityName()} );
|
||||
continue;
|
||||
}
|
||||
|
||||
logger.log( Level.INFO, "查询{0}天气预警，发送日志。", new Object[]
|
||||
{ city.getCityName()} );
|
||||
|
||||
sendMessage.sendWeatherDisasterWarning( config.getWechatOfficalAccountURL(),
|
||||
warning );
|
||||
|
||||
logger.log( Level.INFO, "{0}天气预警，日志发送成功。", new Object[]
|
||||
{ city.getCityName()} );
|
||||
|
||||
sendMessage.saveWeatherDisasterWarning( city.getCityName(), warning );
|
||||
logger.log( Level.INFO, "查询结束，休眠{0}分钟。", config.getQueryInterval() );
|
||||
Thread.sleep( config.getQueryInterval() * 1000 * 60 );
|
||||
}
|
||||
catch ( IOException error )
|
||||
catch ( InterruptedException error )
|
||||
{
|
||||
System.out.println( "查询" + city.getCityName() + "出现异常！" );
|
||||
System.out.println( error.getMessage() );
|
||||
|
||||
logger.log( Level.SEVERE, "查询 {0} 出现异常:{1}。", new Object[]
|
||||
{ city.getCityName(), error.getMessage()} );
|
||||
}
|
||||
catch ( SQLException error )
|
||||
{
|
||||
logger.log( Level.SEVERE, "查询 {0} 写入数据库失败:{1}。", new Object[]
|
||||
{ city.getCityName(), error.getMessage()} );
|
||||
}
|
||||
catch ( ClassNotFoundException error )
|
||||
{
|
||||
logger.log( Level.SEVERE, "查询 {0} 加载oracle驱动失败:{1}。", new Object[]
|
||||
{ city.getCityName(), error.getMessage()} );
|
||||
|
||||
}
|
||||
catch ( Exception error )
|
||||
{
|
||||
logger.log( Level.SEVERE, "查询 {0} 出现未知错误:{1}。", new Object[]
|
||||
{ city.getCityName(), error.getMessage()} );
|
||||
logger.log( Level.SEVERE, "线程休眠异常，错误信息:{0}", new Object[]
|
||||
{ error.getMessage()} );
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -127,20 +142,6 @@ public class AppMain
|
||||
*/
|
||||
private static void setRootLogger() throws IOException
|
||||
{
|
||||
// Logger rootLogger = Logger.getLogger( "com.cpicxim" );
|
||||
// ConsoleHandler consoleHandler = new ConsoleHandler();
|
||||
// FileHandler fileHandler = new FileHandler( LOG_FILE_PATH );
|
||||
// SimpleFormatter formatter = new SimpleFormatter();
|
||||
|
||||
// consoleHandler.setFormatter( formatter );
|
||||
// fileHandler.setFormatter( formatter );
|
||||
|
||||
// rootLogger.addHandler( consoleHandler );
|
||||
// rootLogger.addHandler( fileHandler );
|
||||
|
||||
// rootLogger.setUseParentHandlers( false );
|
||||
// rootLogger.setLevel( Level.ALL );
|
||||
|
||||
LogManager logManager = LogManager.getLogManager();
|
||||
// 使用外部的配置文件。
|
||||
FileInputStream configFile = new FileInputStream( "./logging.properties" );
|
||||
@ -150,6 +151,6 @@ public class AppMain
|
||||
|
||||
logManager.readConfiguration( configFile );
|
||||
|
||||
Logger rootLogger = Logger.getLogger( "com.cpicxim" );
|
||||
Logger.getLogger( "com.cpicxim" );
|
||||
}
|
||||
}
|
||||
|
||||
@ -0,0 +1,79 @@
|
||||
/*
|
||||
* @Author: Kane
|
||||
* @Date: 2022-05-10 16:06:14
|
||||
* @LastEditors: Kane
|
||||
* @LastEditTime: 2022-05-10 16:09:07
|
||||
* @FilePath: \DisasterWarning\src\main\java\com\cpic\xim\config\AppConfigManager.java
|
||||
* @Description:
|
||||
*
|
||||
* Copyright (c) ${2022} by Kane, All Rights Reserved.
|
||||
*/
|
||||
|
||||
package com.cpic.xim.config;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.io.InputStreamReader;
|
||||
import java.io.FileInputStream;
|
||||
|
||||
import com.fasterxml.jackson.databind.ObjectMapper;
|
||||
import com.fasterxml.jackson.databind.PropertyNamingStrategy;
|
||||
|
||||
public class AppConfigManager
|
||||
{
|
||||
private static final int BUFFER_SIZE = 1024;
|
||||
private static final String CONFIG_FILE_CHARSET = "UTF-8";
|
||||
private static final String CONFIG_FILE_PATH = "./config.json";
|
||||
private static WeatherDisasterNotifyConfig appConfig = null;
|
||||
|
||||
public static WeatherDisasterNotifyConfig getConfig() throws IOException
|
||||
|
||||
{
|
||||
if ( appConfig != null)
|
||||
{
|
||||
return appConfig;
|
||||
}
|
||||
|
||||
ObjectMapper mapper = new ObjectMapper();
|
||||
FileInputStream configFile = null;
|
||||
InputStreamReader in = null;
|
||||
StringBuffer json = null;
|
||||
char[] buffer = new char[BUFFER_SIZE];
|
||||
|
||||
// 设置json属性
|
||||
mapper.setPropertyNamingStrategy( PropertyNamingStrategy.SNAKE_CASE );
|
||||
|
||||
try
|
||||
{
|
||||
configFile = new FileInputStream( CONFIG_FILE_PATH );
|
||||
in = new InputStreamReader( configFile, CONFIG_FILE_CHARSET );
|
||||
json = new StringBuffer();
|
||||
|
||||
int length = in.read( buffer );
|
||||
|
||||
while (length != -1)
|
||||
{
|
||||
json.append( buffer );
|
||||
|
||||
length = in.read( buffer );
|
||||
}
|
||||
|
||||
appConfig = mapper.readValue( json.toString(), WeatherDisasterNotifyConfig.class );
|
||||
}
|
||||
finally
|
||||
{
|
||||
if ( configFile != null)
|
||||
{
|
||||
try
|
||||
{
|
||||
configFile.close();
|
||||
}
|
||||
catch ( IOException e )
|
||||
{
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return appConfig;
|
||||
}
|
||||
}
|
||||
@ -1,72 +1,22 @@
|
||||
/*
|
||||
* @Author: Kane
|
||||
* @Date: 2022-04-24 10:21:46
|
||||
* @LastEditors: Kane
|
||||
* @LastEditTime: 2022-05-10 16:16:28
|
||||
* @FilePath: \DisasterWarning\src\main\java\com\cpic\xim\config\WeatherDisasterNotifyConfig.java
|
||||
* @Description:
|
||||
*
|
||||
* Copyright (c) ${2022} by Kane, All Rights Reserved.
|
||||
*/
|
||||
package com.cpic.xim.config;
|
||||
|
||||
import java.io.InputStreamReader;
|
||||
import java.io.FileInputStream;
|
||||
import java.io.IOException;
|
||||
import java.util.Vector;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||
import com.fasterxml.jackson.databind.ObjectMapper;
|
||||
import com.fasterxml.jackson.databind.PropertyNamingStrategy;
|
||||
|
||||
|
||||
public class WeatherDisasterNotifyConfig
|
||||
{
|
||||
private static final int BUFFER_SIZE = 1024;
|
||||
private static final String CONFIG_FILE_CHARSET = "UTF-8";
|
||||
private static final String CONFIG_FILE_PATH = "./config.json";
|
||||
private static WeatherDisasterNotifyConfig appConfig = null;
|
||||
|
||||
public static WeatherDisasterNotifyConfig getConfig() throws IOException
|
||||
|
||||
{
|
||||
if ( appConfig != null)
|
||||
{
|
||||
return appConfig;
|
||||
}
|
||||
|
||||
ObjectMapper mapper = new ObjectMapper();
|
||||
FileInputStream configFile = null;
|
||||
InputStreamReader in = null;
|
||||
StringBuffer json = null;
|
||||
char[] buffer = new char[BUFFER_SIZE];
|
||||
|
||||
// 设置json属性
|
||||
mapper.setPropertyNamingStrategy( PropertyNamingStrategy.SNAKE_CASE );
|
||||
|
||||
try
|
||||
{
|
||||
configFile = new FileInputStream( CONFIG_FILE_PATH );
|
||||
in = new InputStreamReader( configFile, CONFIG_FILE_CHARSET );
|
||||
json = new StringBuffer();
|
||||
|
||||
int length = in.read( buffer );
|
||||
|
||||
while (length != -1)
|
||||
{
|
||||
json.append( buffer );
|
||||
|
||||
length = in.read( buffer );
|
||||
}
|
||||
|
||||
appConfig = mapper.readValue( json.toString(), WeatherDisasterNotifyConfig.class );
|
||||
}
|
||||
finally
|
||||
{
|
||||
if ( configFile != null)
|
||||
{
|
||||
try
|
||||
{
|
||||
configFile.close();
|
||||
}
|
||||
catch ( IOException e )
|
||||
{
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return appConfig;
|
||||
}
|
||||
|
||||
public WeatherDisasterNotifyConfig()
|
||||
{};
|
||||
@ -106,6 +56,18 @@ public class WeatherDisasterNotifyConfig
|
||||
return cities;
|
||||
}
|
||||
|
||||
|
||||
public int getQueryInterval()
|
||||
{
|
||||
return queryInterval;
|
||||
}
|
||||
|
||||
public void setQueryInterval( int queryInterval )
|
||||
{
|
||||
this.queryInterval = queryInterval;
|
||||
}
|
||||
|
||||
|
||||
public void setCities( Vector<City> cities )
|
||||
{
|
||||
this.cities = cities;
|
||||
@ -131,12 +93,24 @@ public class WeatherDisasterNotifyConfig
|
||||
this.wechatOfficalAccountURL = wechatOfficalAccountURL;
|
||||
}
|
||||
|
||||
@JsonProperty( "title")
|
||||
private String title;
|
||||
|
||||
@JsonProperty( "key")
|
||||
private String key;
|
||||
|
||||
@JsonProperty( "query_url")
|
||||
private String queryUrl;
|
||||
|
||||
@JsonProperty( "query_interval")
|
||||
private int queryInterval;
|
||||
|
||||
@JsonProperty( "wechat_officalaccount_url")
|
||||
private String wechatOfficalAccountURL;
|
||||
|
||||
@JsonProperty( "cities")
|
||||
private Vector<City> cities;
|
||||
|
||||
@JsonProperty( "notify_stuffs")
|
||||
private Vector<CpicxmStuff> notifyStuffs;
|
||||
}
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user