From 2868402653dd0d0b6de8ff07f272e175e1268f7e Mon Sep 17 00:00:00 2001 From: chaiyapeng <3535863041@qq.com> Date: Wed, 4 Sep 2024 19:14:03 +0800 Subject: [PATCH] =?UTF-8?q?=E4=B8=A4=E5=8D=83=E4=B8=87=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=E6=A1=86=E6=9E=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .idea/workspace.xml | 84 ++++++--- .../java/com/muyu/domain/WeatherForecast.java | 43 +++++ .../controller/DataMillionController.java | 7 +- .../mart/controller/MarketController.java | 8 +- .../cloud/mart/mapper/DataMillionMapper.java | 3 + .../mart/service/DataMillionService.java | 5 + .../cloud/mart/service/MarketService.java | 2 + .../service/impl/DataMillionServiceImpl.java | 10 ++ .../mart/service/impl/MarketServiceImpl.java | 6 + .../mart/utils/WeatherForecastInquire.java | 160 ++++++++++++++++++ .../resources/mapper/DataMillionMapper.xml | 3 + 11 files changed, 302 insertions(+), 29 deletions(-) create mode 100644 cloud-port-common/src/main/java/com/muyu/domain/WeatherForecast.java create mode 100644 cloud-port-server/src/main/java/com/muyu/cloud/mart/utils/WeatherForecastInquire.java diff --git a/.idea/workspace.xml b/.idea/workspace.xml index 0f2d677..7bc3bd2 100644 --- a/.idea/workspace.xml +++ b/.idea/workspace.xml @@ -5,10 +5,17 @@ + + - + + + + + + - + + + @@ -143,7 +165,7 @@ - + - diff --git a/cloud-port-common/src/main/java/com/muyu/domain/WeatherForecast.java b/cloud-port-common/src/main/java/com/muyu/domain/WeatherForecast.java new file mode 100644 index 0000000..98bb77b --- /dev/null +++ b/cloud-port-common/src/main/java/com/muyu/domain/WeatherForecast.java @@ -0,0 +1,43 @@ +package com.muyu.domain; + +import lombok.Data; + +/** + * @Author：chaiyapeng + * @Package：com.muyu.domain + * @Project：cloud-port + * @name：WeatherForecast + * @Date：2024/9/4 19:05 + * 天气预报 + */ +@Data +public class WeatherForecast { + /** + * 城市 + */ + private String city; + /** + * 天气 + */ + private String info; + /** + * 温度 + */ + private String temperature; + /** + * 湿度 + */ + private String humidity; + /** + * 风向 + */ + private String direct; + /** + * 风力 + */ + private String power; + /** + * 空气质量 + */ + private String aqi; +} diff --git a/cloud-port-server/src/main/java/com/muyu/cloud/mart/controller/DataMillionController.java b/cloud-port-server/src/main/java/com/muyu/cloud/mart/controller/DataMillionController.java index 3581dee..3323472 100644 --- a/cloud-port-server/src/main/java/com/muyu/cloud/mart/controller/DataMillionController.java +++ b/cloud-port-server/src/main/java/com/muyu/cloud/mart/controller/DataMillionController.java @@ -3,6 +3,7 @@ package com.muyu.cloud.mart.controller; import cn.hutool.db.PageResult; import com.dtflys.forest.annotation.Post; import com.muyu.cloud.mart.service.DataMillionService; +import com.muyu.common.core.domain.Result; import com.muyu.common.core.web.controller.BaseController; import com.muyu.domain.DataMillion; import org.springframework.beans.factory.annotation.Autowired; @@ -11,7 +12,6 @@ import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; -import javax.xml.transform.Result; import java.util.List; /** @@ -20,6 +20,7 @@ import java.util.List; * @Project：cloud-port * @name：DataMillion * @Date：2024/9/4 12:02 + * 数据源接口 */ @RestController @RequestMapping("million") @@ -27,5 +28,9 @@ public class DataMillionController extends BaseController { @Autowired private DataMillionService dataMillionService; + @PostMapping("findMillionList") + public Result> findMillionList(@RequestBody DataMillion dataMillion){ + return dataMillionService.findMillionList(dataMillion); + } } diff --git a/cloud-port-server/src/main/java/com/muyu/cloud/mart/controller/MarketController.java b/cloud-port-server/src/main/java/com/muyu/cloud/mart/controller/MarketController.java index 6bac474..6a977bb 100644 --- a/cloud-port-server/src/main/java/com/muyu/cloud/mart/controller/MarketController.java +++ b/cloud-port-server/src/main/java/com/muyu/cloud/mart/controller/MarketController.java @@ -85,5 +85,11 @@ public class MarketController extends BaseController { public Result getPostcode(@RequestParam(name = "code") String code){ return marketService.getPostcode(code); } - + /** + * 天气预报 + */ + @GetMapping("getWeatherForecast") + public Result getWeatherForecast(@RequestParam(name = "city") String city){ + return marketService.getWeatherForecast(city); + } } diff --git a/cloud-port-server/src/main/java/com/muyu/cloud/mart/mapper/DataMillionMapper.java b/cloud-port-server/src/main/java/com/muyu/cloud/mart/mapper/DataMillionMapper.java index 53c3061..529b7ca 100644 --- a/cloud-port-server/src/main/java/com/muyu/cloud/mart/mapper/DataMillionMapper.java +++ b/cloud-port-server/src/main/java/com/muyu/cloud/mart/mapper/DataMillionMapper.java @@ -4,6 +4,8 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.muyu.domain.DataMillion; import org.apache.ibatis.annotations.Mapper; +import java.util.List; + /** * @Author：chaiyapeng * @Package：com.muyu.cloud.mart.mapper @@ -13,4 +15,5 @@ import org.apache.ibatis.annotations.Mapper; */ @Mapper public interface DataMillionMapper extends BaseMapper { + List findMillionList(DataMillion dataMillion); } diff --git a/cloud-port-server/src/main/java/com/muyu/cloud/mart/service/DataMillionService.java b/cloud-port-server/src/main/java/com/muyu/cloud/mart/service/DataMillionService.java index a29533d..35da15a 100644 --- a/cloud-port-server/src/main/java/com/muyu/cloud/mart/service/DataMillionService.java +++ b/cloud-port-server/src/main/java/com/muyu/cloud/mart/service/DataMillionService.java @@ -1,8 +1,11 @@ package com.muyu.cloud.mart.service; import com.baomidou.mybatisplus.extension.service.IService; +import com.muyu.common.core.domain.Result; import com.muyu.domain.DataMillion; +import java.util.List; + /** * @Author：chaiyapeng * @Package：com.muyu.cloud.mart.service @@ -11,4 +14,6 @@ import com.muyu.domain.DataMillion; * @Date：2024/9/4 12:04 */ public interface DataMillionService extends IService { + + Result> findMillionList(DataMillion dataMillion); } diff --git a/cloud-port-server/src/main/java/com/muyu/cloud/mart/service/MarketService.java b/cloud-port-server/src/main/java/com/muyu/cloud/mart/service/MarketService.java index 88305b1..9af15f7 100644 --- a/cloud-port-server/src/main/java/com/muyu/cloud/mart/service/MarketService.java +++ b/cloud-port-server/src/main/java/com/muyu/cloud/mart/service/MarketService.java @@ -29,4 +29,6 @@ public interface MarketService extends IService { Result getBirthday(BirthdayRes birthdayRes); Result getPostcode(String code); + + Result getWeatherForecast(String city); } diff --git a/cloud-port-server/src/main/java/com/muyu/cloud/mart/service/impl/DataMillionServiceImpl.java b/cloud-port-server/src/main/java/com/muyu/cloud/mart/service/impl/DataMillionServiceImpl.java index 1d90778..f0315e6 100644 --- a/cloud-port-server/src/main/java/com/muyu/cloud/mart/service/impl/DataMillionServiceImpl.java +++ b/cloud-port-server/src/main/java/com/muyu/cloud/mart/service/impl/DataMillionServiceImpl.java @@ -3,11 +3,14 @@ package com.muyu.cloud.mart.service.impl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.muyu.cloud.mart.mapper.DataMillionMapper; import com.muyu.cloud.mart.service.DataMillionService; +import com.muyu.common.core.domain.Result; import com.muyu.domain.DataMillion; import lombok.extern.log4j.Log4j2; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import java.util.List; + /** * @Author：chaiyapeng * @Package：com.muyu.cloud.mart.service.impl @@ -20,6 +23,13 @@ import org.springframework.stereotype.Service; public class DataMillionServiceImpl extends ServiceImpl implements DataMillionService { @Autowired private DataMillionMapper dataMillionMapper; + + + @Override + public Result> findMillionList(DataMillion dataMillion) { + List list = dataMillionMapper.findMillionList(dataMillion); + return Result.success(list); + } } diff --git a/cloud-port-server/src/main/java/com/muyu/cloud/mart/service/impl/MarketServiceImpl.java b/cloud-port-server/src/main/java/com/muyu/cloud/mart/service/impl/MarketServiceImpl.java index e58be45..5181111 100644 --- a/cloud-port-server/src/main/java/com/muyu/cloud/mart/service/impl/MarketServiceImpl.java +++ b/cloud-port-server/src/main/java/com/muyu/cloud/mart/service/impl/MarketServiceImpl.java @@ -96,4 +96,10 @@ public class MarketServiceImpl extends ServiceImpl impleme List list = PostcodeInquire.queryPostcode(code); return Result.success(list); } + + @Override + public Result getWeatherForecast(String city) { + WeatherForecast weatherForecast = WeatherForecastInquire.queryWeather(city); + return Result.success(weatherForecast); + } } diff --git a/cloud-port-server/src/main/java/com/muyu/cloud/mart/utils/WeatherForecastInquire.java b/cloud-port-server/src/main/java/com/muyu/cloud/mart/utils/WeatherForecastInquire.java new file mode 100644 index 0000000..580b9ef --- /dev/null +++ b/cloud-port-server/src/main/java/com/muyu/cloud/mart/utils/WeatherForecastInquire.java @@ -0,0 +1,160 @@ +package com.muyu.cloud.mart.utils; + + +import com.muyu.domain.WeatherForecast; +import net.sf.json.JSONObject; + +import java.io.*; +import java.net.HttpURLConnection; +import java.net.URL; +import java.net.URLEncoder; +import java.nio.charset.StandardCharsets; +import java.util.HashMap; +import java.util.Map; +/** + * @Author：chaiyapeng + * @Package：com.muyu.cloud.mart.utils + * @Project：cloud-port + * @name：WeatherForecastInquire + * @Date：2024/9/4 19:06 + */ +public class WeatherForecastInquire { + // 天气情况查询接口地址 + public static String API_URL = "http://apis.juhe.cn/simpleWeather/query"; + // 接口请求Key + public static String API_KEY = "c25e94d2042d154ac79b20d57eaec43b"; + + public static void main(String[] args) { + String cityName = "北京"; + queryWeather(cityName); + } + + /** + * 根据城市名查询天气情况 + * + * @param cityName + */ + public static WeatherForecast queryWeather(String cityName) { + Map params = new HashMap<>();//组合参数 + params.put("city", cityName); + params.put("key", API_KEY); + String queryParams = urlencode(params); + + String response = doGet(API_URL, queryParams); + WeatherForecast weatherForecast = new WeatherForecast(); + try { + JSONObject jsonObject = JSONObject.fromObject(response); + int error_code = jsonObject.getInt("error_code"); + if (error_code == 0) { + System.out.println("调用接口成功"); + + JSONObject result = jsonObject.getJSONObject("result"); + JSONObject realtime = result.getJSONObject("realtime"); + + weatherForecast.setCity(result.getString("city")); + weatherForecast.setInfo(realtime.getString("info")); + weatherForecast.setTemperature(realtime.getString("temperature")); + weatherForecast.setHumidity(realtime.getString("humidity")); + weatherForecast.setDirect(realtime.getString("direct")); + weatherForecast.setPower(realtime.getString("power")); + weatherForecast.setAqi(realtime.getString("aqi")); + + System.out.printf("城市：%s%n", result.getString("city")); + System.out.printf("天气：%s%n", realtime.getString("info")); + System.out.printf("温度：%s%n", realtime.getString("temperature")); + System.out.printf("湿度：%s%n", realtime.getString("humidity")); + System.out.printf("风向：%s%n", realtime.getString("direct")); + System.out.printf("风力：%s%n", realtime.getString("power")); + System.out.printf("空气质量：%s%n", realtime.getString("aqi")); + } else { + System.out.println("调用接口失败：" + jsonObject.getString("reason")); + } + } catch (Exception e) { + e.printStackTrace(); + } + return weatherForecast; + } + + /** + * get方式的http请求 + * + * @param httpUrl 请求地址 + * @return 返回结果 + */ + public static String doGet(String httpUrl, String queryParams) { + HttpURLConnection connection = null; + InputStream inputStream = null; + BufferedReader bufferedReader = null; + String result = null;// 返回结果字符串 + try { + // 创建远程url连接对象 + URL url = new URL(new StringBuffer(httpUrl).append("?").append(queryParams).toString()); + // 通过远程url连接对象打开一个连接，强转成httpURLConnection类 + connection = (HttpURLConnection) url.openConnection(); + // 设置连接方式：get + connection.setRequestMethod("GET"); + // 设置连接主机服务器的超时时间：15000毫秒 + connection.setConnectTimeout(5000); + // 设置读取远程返回的数据时间：60000毫秒 + connection.setReadTimeout(6000); + // 发送请求 + connection.connect(); + // 通过connection连接，获取输入流 + if (connection.getResponseCode() == 200) { + inputStream = connection.getInputStream(); + // 封装输入流，并指定字符集 + bufferedReader = new BufferedReader(new InputStreamReader(inputStream, StandardCharsets.UTF_8)); + // 存放数据 + StringBuilder sbf = new StringBuilder(); + String temp; + while ((temp = bufferedReader.readLine()) != null) { + sbf.append(temp); + sbf.append(System.getProperty("line.separator")); + } + result = sbf.toString(); + } + } catch (IOException e) { + e.printStackTrace(); + } finally { + // 关闭资源 + if (null != bufferedReader) { + try { + bufferedReader.close(); + } catch (IOException e) { + e.printStackTrace(); + } + } + if (null != inputStream) { + try { + inputStream.close(); + } catch (IOException e) { + e.printStackTrace(); + } + } + if (connection != null) { + connection.disconnect();// 关闭远程连接 + } + } + return result; + } + + /** + * 将map型转为请求参数型 + * + * @param data + * @return + */ + public static String urlencode(Map data) { + StringBuilder sb = new StringBuilder(); + for (Map.Entry i : data.entrySet()) { + try { + sb.append(i.getKey()).append("=").append(URLEncoder.encode(i.getValue() + "", "UTF-8")).append("&"); + } catch (UnsupportedEncodingException e) { + e.printStackTrace(); + } + } + String result = sb.toString(); + result = result.substring(0, result.lastIndexOf("&")); + return result; + } +} diff --git a/cloud-port-server/src/main/resources/mapper/DataMillionMapper.xml b/cloud-port-server/src/main/resources/mapper/DataMillionMapper.xml index 235047c..4e10f26 100644 --- a/cloud-port-server/src/main/resources/mapper/DataMillionMapper.xml +++ b/cloud-port-server/src/main/resources/mapper/DataMillionMapper.xml @@ -4,4 +4,7 @@ "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> +