后端开发日记⑦：飞行任务与大疆开放平台适配

1
public Object request(
2
        String method,
3
        String path,
4
        Object body,
5
        String contentType) {
6
    try {
7
        String normalizedMethod =
8
                method.toUpperCase(Locale.ROOT);
9
        HttpRequest request = buildRequest(
10
                normalizedMethod, path, body, contentType);
11
        HttpResponse<String> response = httpClient.send(
12
                request,
13
                HttpResponse.BodyHandlers.ofString(
14
                        StandardCharsets.UTF_8));
15

16
        if (response.statusCode() < 200
17
                || response.statusCode() >= 300) {
18
            throw new ServiceException(
19
                    "大疆 API 服务响应异常");
20
        }
21
        if (StringUtils.isEmpty(response.body())) {
22
            return Collections.emptyMap();
23
        }
24
        return objectMapper.readValue(
25
                response.body(), Object.class);
26
    } catch (ServiceException e) {
27
        throw e;
28
    } catch (Exception e) {
29
        throw new ServiceException("调用大疆 API 服务失败");
30
    }
31
}

1
private String sign(
2
        String method,
3
        String timestamp,
4
        String nonce) throws Exception {
5
    String signText = properties.getAccessKey()
6
            + method + timestamp + nonce;
7
    Mac mac = Mac.getInstance("HmacSHA256");
8
    mac.init(new SecretKeySpec(
9
            properties.getSecretKey().getBytes(
10
                    StandardCharsets.UTF_8),
11
            "HmacSHA256"));
12
    byte[] digest = mac.doFinal(
13
            signText.getBytes(StandardCharsets.UTF_8));
14
    return toHex(digest);
15
}

1
if ("GET".equals(method) || "DELETE".equals(method)) {
2
    return builder.method(
3
            method, HttpRequest.BodyPublishers.noBody())
4
            .build();
5
}
6

7
if (StringUtils.isEmpty(contentType)) {
8
    return builder.method(
9
            method, HttpRequest.BodyPublishers.noBody())
10
            .build();
11
}
12

13
builder.header("Content-Type", contentType);
14
String requestBody =
15
        "application/x-www-form-urlencoded".equals(contentType)
16
                ? String.valueOf(body)
17
                : toJson(body);
18
return builder.method(
19
        method,
20
        HttpRequest.BodyPublishers.ofString(
21
                requestBody, StandardCharsets.UTF_8))
22
        .build();

1
for (Map<String, Object> item : getObjectList(source)) {
2
    Double longitude = numberValue(pickFirst(
3
            item, "longitude", "lng", "lon"));
4
    Double latitude = numberValue(pickFirst(
5
            item, "latitude", "lat"));
6
    if (longitude == null || latitude == null
7
            || longitude == 0D || latitude == 0D) {
8
        continue;
9
    }
10
    Map<String, Object> point = new LinkedHashMap<>();
11
    point.put("longitude", longitude);
12
    point.put("latitude", latitude);
13
    Object height = pickFirst(
14
            item, "height", "altitude", "ellipsoid_height");
15
    if (height != null) {
16
        point.put("height", height);
17
    }
18
    result.add(point);
19
}