nuojing-data-service/src/main/java/com/nuojing/media/auth/client/KuaishouMediaClient.java

package com.nuojing.media.auth.client;

import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.nuojing.admin.common.BusinessException;
import com.nuojing.media.auth.domain.entity.MediaAuthConfig;
import lombok.RequiredArgsConstructor;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;
import org.springframework.web.client.RestTemplate;

import java.util.HashMap;
import java.util.Map;

@Component
@RequiredArgsConstructor
public class KuaishouMediaClient {

    private static final String TOKEN_URL = "https://open.e.kuaishou.com/rest/openapi/oauth2/authorize/access_token";

    private final ObjectMapper objectMapper;
    private final RestTemplate restTemplate = new RestTemplate();

    public JsonNode exchangeToken(MediaAuthConfig config, String authCode) {
        Map<String, Object> body = new HashMap<>();
        body.put("app_id", config.getAppId());
        body.put("app_secret", config.getAppSecret());
        body.put("auth_code", authCode);
        return postJson(TOKEN_URL, body);
    }

    public JsonNode requireSuccess(JsonNode response, String action) {
        if (response == null || response.isMissingNode() || response.isNull()) {
            throw new BusinessException(500, action + "返回信息为空");
        }
        int code = response.path("code").asInt(-1);
        if (code != 0) {
            String message = response.path("message").asText(action + "失败");
            throw new BusinessException(500, message);
        }
        JsonNode data = response.path("data");
        if (data.isMissingNode() || data.isNull()) {
            throw new BusinessException(500, action + "data信息为空");
        }
        return data;
    }

    private JsonNode postJson(String url, Map<String, Object> body) {
        HttpHeaders headers = new HttpHeaders();
        headers.setContentType(MediaType.APPLICATION_JSON);
        return parse(restTemplate.postForObject(url, new HttpEntity<>(body, headers), String.class));
    }

    private JsonNode parse(String response) {
        if (!StringUtils.hasText(response)) {
            return objectMapper.missingNode();
        }
        try {
            return objectMapper.readTree(response);
        } catch (Exception ex) {
            throw new BusinessException(500, "媒体响应解析失败");
        }
    }
}