zzkj/smart_storage_java
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

国外区域、天气api获取

Browse Source
This commit is contained in:
root
2025-07-22 17:01:54 +08:00
parent 2a7c3d42c0
commit c12b165816
6 changed files with 232 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
business-service-dao/src/main/java/com/ho/business/service/impl/StationServiceImpl.java
View File

@ -310,9 +310,9 @@ public class StationServiceImpl implements StationService {
* @param station
*/
private void updateStationInfo(Station station) {
MyAddress address = AddressUntils.getAddress(String.valueOf(station.getLatitude()),String.valueOf(station.getLongitude()));
MyAddress address = AbroadAddressUtils.getAddress(String.valueOf(station.getLatitude()),String.valueOf(station.getLongitude()));
if (null != address) {
String adCode = address.getAdcode();
String adCode = address.getCityCode();
station.setAdCode(adCode);
station.setDistrict(address.getDistrict());
station.setCity(address.getCity());
@ -320,7 +320,7 @@ public class StationServiceImpl implements StationService {
station.setNation(address.getNation());
String key = RedisKeyConstant.WEATHER_PROVINCE_CITY + adCode;
if (!redisService.hasKey(key)) {
WeatherRespVo weatherRespVo = WeatherUntils.getWeatherRespVo(station.getAdCode());
WeatherRespVo weatherRespVo = AbroadWeatherUtils.getWeatherRespVo(String.valueOf(station.getLatitude()),String.valueOf(station.getLongitude()));
if (weatherRespVo != null) {
weatherRespVo.setUpdateTime(System.currentTimeMillis());
redisService.set(key, weatherRespVo);

5
common-tools/pom.xml
View File

@ -46,6 +46,11 @@
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
</dependency>
<dependency>
<groupId>org.json</groupId>
<artifactId>json</artifactId>
<version>20231013</version>
</dependency>
<!--jackson-->
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>

3
common-tools/src/main/java/com/ho/common/tools/entity/WeatherRespVo.java
View File

@ -25,6 +25,9 @@ public class WeatherRespVo {
@ApiModelProperty(value = "天气现象")
String skyCon;
@ApiModelProperty(value = "天气现象编码")
int code;
@ApiModelProperty(value = "风向风速")
String speedAndDirection;

128
common-tools/src/main/java/com/ho/common/tools/util/AbroadAddressUtils.java Normal file
View File

@ -0,0 +1,128 @@
package com.ho.common.tools.util;
import com.ho.common.tools.entity.MyAddress;
import lombok.extern.slf4j.Slf4j;
import org.json.JSONArray;
import org.json.JSONObject;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.*;
/**
* @author kerwin
*
* 海外地址反向解析
*
*/
@Slf4j
public class AbroadAddressUtils {
static String apiKey = "AIzaSyAM4JOtE9yt48f60ATwByB7uWzTIrYSSUg";
public static MyAddress getAddress(String lat, String lng){
// 构建API请求URL
String urlString = "https://maps.googleapis.com/maps/api/geocode/json?" +
"latlng=" + lat + "," + lng +
"&key=" + apiKey;
// 发送HTTP请求
URL url = null;
StringBuilder response = new StringBuilder();
try {
url = new URL(urlString);
// 创建代理（如果不需要代理，可以移除这部分）
Proxy proxy = new Proxy(Proxy.Type.SOCKS, new InetSocketAddress("127.0.0.1", 4781));
HttpURLConnection conn = (HttpURLConnection) url.openConnection(proxy);
conn.setRequestMethod("GET");
conn.setConnectTimeout(10000); // 10秒连接超时
conn.setReadTimeout(10000); // 10秒读取超时
// 检查响应状态
int responseCode = conn.getResponseCode();
if (responseCode != 200) {
throw new RuntimeException("HTTP请求失败: " + responseCode);
}
// 读取响应内容
try (BufferedReader reader = new BufferedReader(
new InputStreamReader(conn.getInputStream()))) {
String line;
while ((line = reader.readLine()) != null) {
response.append(line);
}
}
} catch (MalformedURLException e) {
throw new RuntimeException(e);
} catch (ProtocolException e) {
throw new RuntimeException(e);
} catch (IOException e) {
throw new RuntimeException(e);
}
// 解析JSON响应
return parseGeocodeResponse(response.toString());
}
private static MyAddress parseGeocodeResponse(String jsonResponse) {
JSONObject json = new JSONObject(jsonResponse);
String status = json.getString("status");
if (!"OK".equals(status)) {
throw new RuntimeException("地理编码API错误: " + status);
}
MyAddress address = new MyAddress();
// 获取第一个结果（最精确的匹配）
JSONObject firstResult = json.getJSONArray("results").getJSONObject(0);
// 解析地址组件
JSONArray components = firstResult.getJSONArray("address_components");
for (int i = 0; i < components.length(); i++) {
JSONObject component = components.getJSONObject(i);
JSONArray types = component.getJSONArray("types");
String longName = component.getString("long_name");
// 国家信息
if (types.toString().contains("country")) {
address.setNation(longName);
}
// 省份/州信息
if (types.toString().contains("administrative_area_level_1")) {
address.setProvince(longName);
}
// 城市信息
if (types.toString().contains("locality")) {
address.setCity(longName);
}
// 区县信息
if (types.toString().contains("sublocality")) {
address.setDistrict(longName);
}
// 邮政编码
if (types.toString().contains("postal_code")) {
address.setCityCode(longName);
}
}
return address;
}
public static void main(String[] args) {
// 示例坐标 - 纽约
String latitude = "48.877132";
String longitude = "2.356407";
try {
// 获取地址信息
MyAddress address = getAddress(latitude, longitude);
// 打印结果
System.out.println("============ 反向地理编码结果 ============");
System.out.println("国家: " + address.getNation() );
System.out.println("省份/州: " + address.getProvince());
System.out.println("城市: " + address.getCity());
System.out.println("地区/区县: " + address.getDistrict());
System.out.println("邮政编码: " + address.getCityCode());
} catch (Exception e) {
System.err.println("发生错误: " + e.getMessage());
e.printStackTrace();
}
}
}

91
common-tools/src/main/java/com/ho/common/tools/util/AbroadWeatherUtils.java Normal file
View File

@ -0,0 +1,91 @@
package com.ho.common.tools.util;
import com.ho.common.tools.entity.WeatherRespVo;
import lombok.extern.slf4j.Slf4j;
import org.json.JSONArray;
import org.json.JSONObject;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.math.BigDecimal;
import java.net.HttpURLConnection;
import java.net.URL;
/**
* @author kerwin
*
* 获取海外天气
*/
@Slf4j
public class AbroadWeatherUtils {
static String apiKey = "6358b3081a5849f09ac90138252107";
public static void main(String[] args) {
String latitude = "40.714224";
String longitude = "-73.961452";
try {
System.out.println(getWeatherRespVo(latitude, longitude));
} catch (Exception e) {
e.printStackTrace();
}
}
public static WeatherRespVo getWeatherRespVo(String lat, String lng) {
String urlString = "http://api.weatherapi.com/v1/forecast.json?key="+apiKey+"&q=" + lat + "," + lng +"&days=1";
URL url = null;
StringBuilder response = new StringBuilder();
try {
url = new URL(urlString);
HttpURLConnection conn = (HttpURLConnection) url.openConnection();
conn.setRequestMethod("GET");
try (BufferedReader reader = new BufferedReader(
new InputStreamReader(conn.getInputStream()))) {
String line;
while ((line = reader.readLine()) != null) {
response.append(line);
}
}
} catch (IOException e) {
throw new RuntimeException(e);
}
return parseWeatherData(response.toString());
}
private static WeatherRespVo parseWeatherData(String jsonResponse) {
WeatherRespVo weatherRespVo =new WeatherRespVo();
JSONObject root = new JSONObject(jsonResponse);
// 解析地区信息
JSONObject location = root.getJSONObject("location");
String area = location.getString("name");
weatherRespVo.setCityzh(area);
// 获取天气预报数据
JSONObject forecast = root.getJSONObject("forecast");
JSONArray forecastday = forecast.getJSONArray("forecastday");
JSONObject day = forecastday.getJSONObject(0).getJSONObject("day");
// 解析温度数据
double maxTemp = day.getDouble("maxtemp_c");
weatherRespVo.setMaxTemperature(new BigDecimal(String.valueOf(maxTemp)));
double minTemp = day.getDouble("mintemp_c");
weatherRespVo.setMinTemperature(new BigDecimal(String.valueOf(minTemp)));
String condition = day.getJSONObject("condition").getString("text");
weatherRespVo.setSkyCon(condition);
int code = day.getJSONObject("condition").getInt("code");
weatherRespVo.setCode(code);
double maxWindKph = day.getDouble("maxwind_kph");
// 获取风向（从最近的小时数据中获取）
JSONArray hours = forecastday.getJSONObject(0).getJSONArray("hour");
String windDirection = hours.getJSONObject(0).getString("wind_dir");
// 组合风向风速信息
String windInfo = windDirection + " " + maxWindKph + " km/h";
weatherRespVo.setSpeedAndDirection(windInfo);
weatherRespVo.setUpdateTime(System.currentTimeMillis());
return weatherRespVo;
}
}

3
file-center/src/main/java/com/ho/filecenter/controller/WeatherController.java
View File

@ -12,6 +12,7 @@ import com.ho.common.tools.entity.MyAddress;
import com.ho.common.tools.entity.WeatherRespVo;
import com.ho.common.tools.exception.DataResult;
import com.ho.common.tools.service.RedisService;
import com.ho.common.tools.util.AbroadWeatherUtils;
import com.ho.common.tools.util.AddressUntils;
import com.ho.common.tools.util.IPUtils;
import com.ho.common.tools.util.WeatherUntils;
@ -241,7 +242,7 @@ public class WeatherController {
continue;
}
String key = RedisKeyConstant.WEATHER_PROVINCE_CITY + adCode;
WeatherRespVo weatherRespVo = WeatherUntils.getWeatherRespVo(station.getAdCode());
WeatherRespVo weatherRespVo = AbroadWeatherUtils.getWeatherRespVo(String.valueOf(station.getLatitude()),String.valueOf(station.getLongitude()));
weatherRespVo.setUpdateTime(updateTime);
redisService.set(key, weatherRespVo);
map.put(adCode, adCode);