package com.gs.xiaomi.service;

import com.fasterxml.jackson.databind.ObjectMapper;
import com.gs.xiaomi.config.DataAcquisitionConfiguration;
import com.gs.xiaomi.dto.BCS101Request;
import com.gs.xiaomi.util.X5StringUtils;
import okhttp3.*;
import org.springframework.stereotype.Service;

import java.io.IOException;
import java.net.URLEncoder;
import java.nio.charset.StandardCharsets;
import java.util.concurrent.TimeUnit;

@Service
public class BCS101ApiService {

    private final OkHttpClient client;
    private final ObjectMapper objectMapper;

    public BCS101ApiService() {
        this.client = new OkHttpClient.Builder()
                .connectTimeout(3000, TimeUnit.SECONDS)
                .readTimeout(90, TimeUnit.SECONDS)
                .build();
        this.objectMapper = new ObjectMapper();
    }

    /**
     * 获取BCS101数据
     *
     * @param request BCS101请求参数
     * @return API响应
     * @throws IOException 网络异常
     */
    public String getBCS101Data(BCS101Request request) throws IOException {
        // 直接将请求对象转换为JSON字符串
        String jsonData = objectMapper.writeValueAsString(request);

        // Base64编码
        String base64Data = X5StringUtils.encodeBase64(jsonData);

        // URL编码
        String urlEncodedData = URLEncoder.encode(base64Data, String.valueOf(StandardCharsets.UTF_8));

        // 构建form表单数据
        String formData = "data=" + urlEncodedData;

        // 构建Authorization header
        String credentials = DataAcquisitionConfiguration.BCS_USER_NAME + ":" + DataAcquisitionConfiguration.BCS_PWD;
        String auth = X5StringUtils.encodeBase64(credentials);

        // 构建请求体
        RequestBody body = RequestBody.create(formData, MediaType.parse("application/x-www-form-urlencoded"));

        // 构建请求
        Request httpRequest = new Request.Builder()
                .url(DataAcquisitionConfiguration.BCS_101_URL)
                .method("POST", body)
                .addHeader("Content-Type", "application/x-www-form-urlencoded")
                .addHeader("Authorization", "Basic " + auth)
                .build();

        // 执行请求
        try (Response response = client.newCall(httpRequest).execute()) {
            if (response.body() != null) {
                return response.body().string();
            }
            throw new IOException("Empty response body");
        }
    }
}