From e585442b151615cb5cd57ee1d817e88848b5f5a1 Mon Sep 17 00:00:00 2001
From: jinpengyong <jpy123456>
Date: Mon, 21 Mar 2022 09:36:20 +0800
Subject: [PATCH] city_aqi小时数据第三方接口变更
---
screen-job/src/main/java/com/moral/api/service/impl/CityAqiServiceImpl.java | 18 +++++++++++++++++-
1 files changed, 17 insertions(+), 1 deletions(-)
diff --git a/screen-job/src/main/java/com/moral/api/service/impl/CityAqiServiceImpl.java b/screen-job/src/main/java/com/moral/api/service/impl/CityAqiServiceImpl.java
index e011e20..1b3630d 100644
--- a/screen-job/src/main/java/com/moral/api/service/impl/CityAqiServiceImpl.java
+++ b/screen-job/src/main/java/com/moral/api/service/impl/CityAqiServiceImpl.java
@@ -19,7 +19,12 @@
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
+import org.springframework.util.LinkedMultiValueMap;
+import org.springframework.util.MultiValueMap;
import org.springframework.util.ObjectUtils;
import org.springframework.web.client.RestTemplate;
@@ -92,13 +97,24 @@
List<CityAqi> cityAqiList = new ArrayList<>();
+
+ String url = "http://aliv13.data.moji.com/whapi/json/alicityweather/aqi";
+ String appcode = "31b6ea8f804a4472be3b633cfee44849";
+ HttpHeaders httpHeaders = new HttpHeaders();
+ httpHeaders.add("Authorization", "APPCODE " + appcode);
+ //������������
+ LinkedMultiValueMap<String, Object> requestParams = new LinkedMultiValueMap<>();
+
for (CityConfigAqi cityConfigAqi : list) {
CityAqi cityAqi = new CityAqi();
Integer cityCode = cityConfigAqi.getCityCode();
Map<String, Object> data;
try {
//������������������������������
- data = restTemplate.getForObject("http://sapi.7drlb.com/api/mj?cityID={1}&apiKey=aqi", Map.class, cityConfigAqi.getCityId());
+ requestParams.set("cityId", cityConfigAqi.getCityId());
+ HttpEntity<MultiValueMap<String, Object>> httpEntity = new HttpEntity<>(requestParams, httpHeaders);
+ ResponseEntity<String> response = restTemplate.postForEntity(url, httpEntity, String.class);
+ data = JSONObject.parseObject(response.getBody(), Map.class);
} catch (Exception e) {
continue;
}
--
Gitblit v1.8.0