2112A-ONE
/
cloud-market
6
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

企业列表出来了

master
法外狂徒张三 2024-09-04 09:10:27 +08:00
parent 46cf10ff9a
commit 97d2dd487d
1 changed files with 35 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

47
cloud-market-server/src/main/java/com/muyu/market/controller/ThirdPartyController.java
View File

@ -1,18 +1,12 @@
package com.muyu.market.controller;
import com.muyu.common.core.domain.Result;
import jakarta.servlet.http.HttpServletResponse;
import lombok.SneakyThrows;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.UnsupportedEncodingException;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLEncoder;
@ -25,12 +19,41 @@ import java.util.stream.Collectors;
@RequestMapping("/third")
public class ThirdPartyController {
@RequestMapping("/getAirQuality")
public void getAirQuality(@RequestParam String cityId, HttpServletResponse httpResponse) throws IOException {
@GetMapping("/getAirQuality/{cityId}")
public ResponseEntity<String> airQuality(@PathVariable("cityId") String cityId) throws Exception {
String apiKey = "02ccc3ea04810432b45399ecb183195d";
String apiUrl = "http://apis.juhe.cn/fapigw/air/historyHours?key="+apiKey+"&cityId="+cityId;
httpResponse.getWriter().write(apiUrl);
httpResponse.getWriter().flush();
httpResponse.getWriter().close();
String apiUrl = "http://apis.juhe.cn/fapigw/air/historyHours";
HashMap<String, String> map = new HashMap<>();
map.put("key", apiKey);
map.put("cityId", cityId);
URL url = new URL(String.format(apiUrl + "?" + params(map)));
HttpURLConnection connection = (HttpURLConnection) url.openConnection();
connection.setRequestMethod("GET");
BufferedReader in = new BufferedReader(new InputStreamReader(connection.getInputStream()));
String inputLine;
StringBuffer response = new StringBuffer();
while ((inputLine = in.readLine()) != null) {
response.append(inputLine);
}
in.close();
connection.disconnect();
// 返回HTTP 200 OK状态码和响应体
return ResponseEntity.ok(response.toString());
}
public static String params(Map<String, String> map) {
return map.entrySet().stream()
.map(entry -> {
try {
return entry.getKey() + "=" + URLEncoder.encode(entry.getValue(), StandardCharsets.UTF_8.toString());
} catch (Exception e) {
e.printStackTrace();
return entry.getKey() + "=" + entry.getValue();
}
})
.collect(Collectors.joining("&"));
}
}