第三方接口-苹果-获取天气接口

1.rquest


import lombok.Data;/*** @version 1.0* @description: 天气* @date 2024/9/12 15:18*/
@Data
public class WeatherRequest {/*** 语言*/private String lang;/*** 经度*/private String lat;/*** 纬度*/private String lon;/*** 城市*/private String city;
}

2.Controller

import com.engwe.app.api.request.weather.WeatherRequest;
import com.engwe.app.trigger.controller.http.weather.service.WeatherService;
import com.engwe.common.frame.types.dto.R;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import javax.annotation.Resource;
import javax.validation.Valid;
import java.util.Map;@RestController
@RequestMapping("/api/app/weather")
@Validated
public class WeatherController {@Resourceprivate WeatherService weatherService;@PostMapping("/index")public R<Map<String, Object>> index(@RequestBody @Valid WeatherRequest request) {return R.ok(weatherService.weather(request));}
}

3 service

package com.engwe.app.trigger.controller.http.weather.service;import cn.hutool.jwt.JWTUtil;
import cn.hutool.jwt.signers.JWTSigner;
import cn.hutool.jwt.signers.JWTSignerUtil;
import com.engwe.app.api.IWeatherApi;
import com.engwe.app.api.request.weather.WeatherRequest;
import com.engwe.app.trigger.controller.http.weather.properties.WeatherProperties;
import com.engwe.common.redis.utils.RedisUtils;
import com.engwe.common.utils.StringUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;import javax.annotation.Resource;
import java.security.KeyFactory;
import java.security.PrivateKey;
import java.security.spec.PKCS8EncodedKeySpec;
import java.time.Duration;
import java.util.*;/*** 天气服务** @link https://developer.apple.com/documentation/weatherkitrestapi/get-api-v1-weather-_language_-_latitude_-_longitude_*/
@Slf4j
@Service
public class WeatherService {@Resourceprivate WeatherProperties weatherProperties;@Resourceprivate IWeatherApi weatherApi;public Map<String, Object> weather(WeatherRequest request) {try {String cityWeatherCacheKey = StringUtils.joinWith(":", "weather", request.getCity());Map<String, Object> cacheObject = getWeatherFromCache(cityWeatherCacheKey);if (Objects.nonNull(cacheObject) && !cacheObject.isEmpty()) {return cacheObject;}String token = getToken();Map<String, String> requestParams = new HashMap<>();requestParams.put("countryCode", request.getCity());requestParams.put("dataSets", "currentWeather,forecastHourly");cacheObject = weatherApi.getWeatherByLocation("Bearer " + token, request.getLang(), request.getLat(), request.getLon(), requestParams);RedisUtils.setCacheObject(cityWeatherCacheKey, cacheObject, Duration.ofSeconds(weatherProperties.getTokenTTL() - 60));return cacheObject;} catch (Exception e) {log.error("get weather info error", e);return null;}}private Map<String, Object> getWeatherFromCache(String cityWeatherCacheKey) {Object cacheObject = RedisUtils.getCacheObject(cityWeatherCacheKey);return Objects.nonNull(cacheObject) ? (Map<String, Object>) cacheObject : null;}private String getToken() throws Exception {final String cacheKey = StringUtils.joinWith(":", "weather", "token");Object cacheObject = RedisUtils.getCacheObject(cacheKey);if (Objects.isNull(cacheObject)) {// Define JWT claimslong currentTimeMillis = System.currentTimeMillis();Date now = new Date(currentTimeMillis);Date expiration = new Date(currentTimeMillis + weatherProperties.getTokenTTL() * 1000L); // 1-hour expirationbyte[] keyBytes = Base64.getDecoder().decode(weatherProperties.getKey());PKCS8EncodedKeySpec keySpec = new PKCS8EncodedKeySpec(keyBytes);KeyFactory keyFactory = KeyFactory.getInstance("EC");  // Apple uses EC (Elliptic Curve) algorithmPrivateKey privateKey = keyFactory.generatePrivate(keySpec);JWTSigner signer = JWTSignerUtil.createSigner("ES256", privateKey);Map<String, Object> header = new HashMap<>();header.put("alg", "ES256"); // Algorithm used for signingheader.put("kid", weatherProperties.getKeyId());  // Key IDMap<String, Object> payload = new HashMap<>();payload.put("iss", weatherProperties.getTeamId());    // Team IDpayload.put("sub", weatherProperties.getBundleId());  // Issuer IDpayload.put("iat", now.getTime() / 1000); // Issued at time in secondspayload.put("exp", expiration.getTime() / 1000); // Expiration time in secondsString token = JWTUtil.createToken(header, payload, signer);// 提前60s过期RedisUtils.setCacheObject(cacheKey, token, Duration.ofSeconds(weatherProperties.getTokenTTL() - 60));return token;}return (String) cacheObject;}}

4.WeatherProperties

package com.engwe.app.trigger.controller.http.weather.properties;import lombok.Getter;
import lombok.Setter;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;/*** @version 1.0* @description:* @date 2024/9/11 9:20*/
@Component
@ConfigurationProperties(prefix = "weather.auth.config")
@Getter
@Setter
public class WeatherProperties {private String key;private String keyId;private String teamId;private String bundleId;/*** 单位秒*/private Integer tokenTTL;private String languageCode;private String timezone;private String weatherEndpoint;private String availabilityEndpoint;}

5.nacos配置

拥有自己的苹果账号去苹果第三方的那个网址获取key这些东西

weather:auth:config:key: MIGTAgEAMBMGByqGSM49AgEGCCqGSM49AwEHBHkwdwIBAQQgHtq+c5C71dUVFQc5RWHzRRxjRqmnxpQ45pMakniZ2uugCgYIKoZIzj0DAQehRANCAAQkGzFLpI+WYcI13yunuPu1qQHBospCyVlxKaWKomCNli9ncA3HFr65qccqwk11AUPIetd5K0hh4MoNANRE94hHkeyId: JC75LXPCZ5teamId: M8PTMPM89HbundleId: com.engwe.apptokenTTL: 3600languageCode: entimezone: Asia/Shanghaidomain: https://weatherkit.apple.comweatherEndpoint: /api/v1/weatheravailabilityEndpoint: /api/v1/availability

6 IWeatherApi


import feign.Headers;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestHeader;
import org.springframework.web.bind.annotation.RequestParam;import java.util.Map;/*** @author luxin@engwebikes.cn* @version 1.0* @description: TODO* @date 2024/9/12 15:26*/
@FeignClient(name = "weather-service", url = "${weather.auth.config.domain}")
public interface IWeatherApi {//    @GetMapping("/api/v1/weather/{lang}/{lat}/{lon}")@GetMapping("${weather.auth.config.weatherEndpoint}/{lang}/{lat}/{lon}")Map<String, Object> getWeatherByLocation(@RequestHeader("Authorization") String token, @PathVariable("lang") String lang, @PathVariable("lat") String lat, @PathVariable("lon") String lon, @RequestParam Map<String, String> params);
}