agent-bigo/app/src/main/java/com/example/retention/device/ArmCloudApiClient.java

package com.example.retention.device;

import android.util.Log;
import com.example.retention.utils.LogFileUtil;
import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.util.Arrays;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.TimeUnit;
import javax.crypto.Mac;
import javax.crypto.spec.SecretKeySpec;
import okhttp3.MediaType;
import okhttp3.OkHttpClient;
import okhttp3.OkHttpClient.Builder;
import okhttp3.Request;
import okhttp3.RequestBody;
import okhttp3.Response;
import okhttp3.ResponseBody;
import org.json.JSONArray;
import org.json.JSONException;
import org.json.JSONObject;

/**
 * @Time: 2025-06-08 17:06
 * @Creator: 初屿贤
 * @File: ArmCloudApiClient
 * @Project: study.App
 * @Description:
 */
public class ArmCloudApiClient {

  private final OkHttpClient client;
  private final String baseUrl = "https://openapi-hk.armcloud.net";
  private final String accessKey = "gz8f1u0t63byzdu6ozbx8r5qs3e5lipt";
  private final String secretKey = "3yc8c8bg1dym0zaiwjh867al";

  public ArmCloudApiClient() {
    this.client = new Builder()
        .connectTimeout(10, TimeUnit.SECONDS)
        .readTimeout(10, TimeUnit.SECONDS)
        .build();
  }

  private static final String ALGORITHM = "HmacSHA256";

  public static String calculateSignature(String timestamp, String path, String body, String secretKey) throws Exception {
    String stringToSign = timestamp + path + (body != null ? body : "");
    Mac hmacSha256 = Mac.getInstance(ALGORITHM);
    SecretKeySpec secretKeySpec = new SecretKeySpec(secretKey.getBytes(StandardCharsets.UTF_8), ALGORITHM);
    hmacSha256.init(secretKeySpec);
    byte[] hash = hmacSha256.doFinal(stringToSign.getBytes(StandardCharsets.UTF_8));
    return bytesToHex(hash);
  }

  private static String bytesToHex(byte[] bytes) {
    StringBuilder hexString = new StringBuilder();
    for (byte b : bytes) {
      String hex = Integer.toHexString(0xff & b);
      if (hex.length() == 1) {
        hexString.append('0');
      }
      hexString.append(hex);
    }
    return hexString.toString();
  }

  /**
   * 修改实例安卓改机属性 静态设置安卓改机属性，需要重启实例才能够生效，一般用于修改设备信息 该接口与修改实例属性接口的区别在于生效时机，该接口生效时间为每次开机初始化 设置实例属性后，属性数据会持久化存储，重启或重置实例无需再调用该接口
   *
   * @param padCode 实例 ID，非空
   * @param props   属性映射，非空
   * @param restart 是否自动重启
   * @return 接口返回结果字符串
   * @throws IOException 请求失败或网络错误
   */
  public String updateAndroidModProperties(String padCode, Map<String, String> props, boolean restart) throws IOException {
    // 参数校验
    if (padCode == null || padCode.isEmpty()) {
      throw new IllegalArgumentException("padCode 不能为空");
    }
    if (props == null) {
      throw new IllegalArgumentException("props 不能为 null");
    }

    // 构造请求体
    JSONObject json = new JSONObject();

    try {
      json.put("padCode", padCode);
      json.put("props", new JSONObject(props));
      json.put("restart", restart);
    } catch (JSONException e) {
      LogFileUtil.logAndWrite(Log.ERROR, "ArmCloudApiClient", "updateAndroidModProperties: JSON error", e);
    }

    String jsonBody = json.toString();

    // 生成时间戳
    String timestamp = String.valueOf(System.currentTimeMillis());

    String API_PATH = "/openapi/open/pad/updatePadAndroidProp";

    String signature = "";
    try {
      signature = calculateSignature(timestamp, API_PATH, jsonBody, secretKey);
    } catch (Exception e) {
      LogFileUtil.logAndWrite(Log.ERROR, "ArmCloudApiClient", "updateAndroidModProperties: Signature error", e);
    }

    RequestBody body = RequestBody.create(
        MediaType.parse("application/json; charset=utf-8"),
        jsonBody
    );

    Request request = new Request.Builder()
        .url(baseUrl + API_PATH)
        .addHeader("authver", "2.0")
        .addHeader("x-ak", accessKey)
        .addHeader("x-timestamp", timestamp)
        .addHeader("x-sign", signature)
        .post(body)
        .build();

    try (Response response = client.newCall(request).execute()) {
      if (!response.isSuccessful()) {
        throw new IOException("请求失败: " + response);
      }

      ResponseBody responseBody = response.body();
      if (responseBody == null) {
        throw new IOException("响应体为空");
      }

      return responseBody.string();
    }
  }


  /**
   * 修改实例属性 动态修改实例的属性信息，包括系统属性和设置 实例需要处于开机状态，该接口为即时生效
   * <p>
   * 示例： String[] padCodes = new String[]{"AC21020010001"}; List<PropertyItem> systemProps = Arrays.asList( new PropertyItem("ro.build.id", "QQ3A.200805.001")
   * ); List<PropertyItem> oaidProps = Arrays.asList( new PropertyItem("oaid", "001") );
   * <p>
   * String response = client.updateInstanceProperties( padCodes, null,  // modemPersistProps null,  // modemProps null,  // systemPersistProps systemProps,
   * null,  // settingProps oaidProps );
   */
  public String updateInstanceProperties(
      String[] padCodes,
      List<PropertyItem> modemPersistProps,
      List<PropertyItem> modemProps,
      List<PropertyItem> systemPersistProps,
      List<PropertyItem> systemProps,
      List<PropertyItem> settingProps,
      List<PropertyItem> oaidProps
  ) throws IOException {
    if (padCodes == null || padCodes.length == 0) {
      throw new IllegalArgumentException("padCodes 不能为空");
    }

    // 检查 padCodes 是否有重复项
    Set<String> padCodeSet = new HashSet<>();
    for (String code : padCodes) {
      if (!padCodeSet.add(code)) {
        throw new IllegalArgumentException("padCodes 包含重复项: " + code);
      }
    }

    JSONObject json = new JSONObject();
    try {
      json.put("padCodes", new JSONArray(Arrays.asList(padCodes)));
      putPropertyItems(json, "modemPersistPropertiesList", modemPersistProps);
      putPropertyItems(json, "modemPropertiesList", modemProps);
      putPropertyItems(json, "systemPersistPropertiesList", systemPersistProps);
      putPropertyItems(json, "systemPropertiesList", systemProps);
      putPropertyItems(json, "settingPropertiesList", settingProps);
      putPropertyItems(json, "oaidPropertiesList", oaidProps);

    } catch (JSONException e) {
      LogFileUtil.logAndWrite(Log.ERROR, "ArmCloudApiClient", "updateInstanceProperties: JSON 构建失败", e);
      throw new IOException("JSON 构建失败", e);
    }

    String jsonBody = json.toString();
    String timestamp = String.valueOf(System.currentTimeMillis());
    String API_PATH = "/openapi/open/pad/updatePadProperties";

    if (secretKey == null || secretKey.isEmpty()) {
      throw new IllegalArgumentException("secretKey 不能为空");
    }

    String signature;
    try {
      signature = calculateSignature(timestamp, API_PATH, jsonBody, secretKey);
    } catch (Exception e) {
      LogFileUtil.logAndWrite(Log.ERROR, "ArmCloudApiClient", "updateInstanceProperties: 签名计算失败", e);
      throw new IOException("签名计算失败", e);
    }

    RequestBody body = RequestBody.create(
        MediaType.get("application/json; charset=utf-8"),
        jsonBody
    );

    Request request = new Request.Builder()
        .url(baseUrl + API_PATH)
        .addHeader("authver", "2.0")
        .addHeader("x-ak", accessKey)
        .addHeader("x-timestamp", timestamp)
        .addHeader("x-sign", signature)
        .post(body)
        .build();

    try (Response response = client.newCall(request).execute()) {
      if (!response.isSuccessful()) {
        throw new IOException("请求失败: " + response);
      }

      ResponseBody responseBody = response.body();
      if (responseBody == null) {
        throw new IOException("响应体为空");
      }

      String responseBodyString = responseBody.string();
      JSONObject responseJson = new JSONObject(responseBodyString);

      // 校验返回码
      if (responseJson.has("code")) {
        int code = responseJson.getInt("code");
        if (code != 200) {
          String errorMsg = responseJson.optString("msg", "未知错误");
          LogFileUtil.logAndWrite(Log.ERROR, "ArmCloudApiClient", "updateInstanceProperties: 接口返回错误码 " + code + ", 错误信息: " + errorMsg, null);
        }
      } else {
        LogFileUtil.logAndWrite(Log.ERROR, "ArmCloudApiClient", "updateInstanceProperties: 响应中缺少 'code' 字段", null);
      }

      return responseBodyString;
    } catch (JSONException e) {
      LogFileUtil.logAndWrite(Log.ERROR, "ArmCloudApiClient", "updateInstanceProperties: 响应解析失败", e);
      throw new IOException("响应解析失败", e);
    }
  }


  private void putPropertyItems(JSONObject json, String key, List<PropertyItem> items) throws JSONException {
    if (items != null && !items.isEmpty()) {
      JSONArray array = new JSONArray();
      for (PropertyItem item : items) {
        array.put(item.toJson());
      }
      json.put(key, array);
    }
  }


  public static class PropertyItem {

    private String propertiesName;
    private String propertiesValue;

    public PropertyItem(String name, String value) {
      this.propertiesName = name;
      this.propertiesValue = value;
    }

    public JSONObject toJson() throws JSONException {
      JSONObject json = new JSONObject();
      json.put("propertiesName", propertiesName);
      json.put("propertiesValue", propertiesValue);
      return json;
    }
  }

  /**
   * 分页查询实例列表信息
   *
   * @param page          页码
   * @param rows          每页条数
   * @param armServerCode 服务器编号
   * @param deviceCode    板卡编号
   * @param padCodes      实例编号数组
   * @param groupIds      实例分组ID数组
   * @param idc           机房Id
   * @return 匹配的 padCode 数组
   * @throws IOException 请求失败或网络错误
   */
  public String[] getInstanceListInfo(
      int page,
      int rows,
      String armServerCode,
      String deviceCode,
      String[] padCodes,
      Integer[] groupIds,
      String idc) throws IOException {

    JSONObject json = new JSONObject();
    try {
      json.put("page", page);
      json.put("rows", rows);

      if (armServerCode != null) {
        json.put("armServerCode", armServerCode);
      }
      if (deviceCode != null) {
        json.put("deviceCode", deviceCode);
      }
      if (padCodes != null && padCodes.length > 0) {
        json.put("padCodes", new JSONArray(Arrays.asList(padCodes)));
      }
      if (groupIds != null && groupIds.length > 0) {
        json.put("groupIds", new JSONArray(Arrays.asList(groupIds)));
      }
      if (idc != null) {
        json.put("idc", idc);
      }

    } catch (JSONException e) {
      LogFileUtil.logAndWrite(Log.ERROR, "ArmCloudApiClient", "getInstanceListInfo: JSON 构建失败", e);
      throw new IOException("JSON 构建失败", e);
    }

    String jsonBody = json.toString();
    String timestamp = String.valueOf(System.currentTimeMillis());
    String API_PATH = "/openapi/open/pad/infos";

    if (secretKey == null || secretKey.isEmpty()) {
      throw new IllegalArgumentException("secretKey 不能为空");
    }

    String signature;
    try {
      signature = calculateSignature(timestamp, API_PATH, jsonBody, secretKey);
    } catch (Exception e) {
      LogFileUtil.logAndWrite(Log.ERROR, "ArmCloudApiClient", "getInstanceListInfo: 签名计算失败", e);
      throw new IOException("签名计算失败", e);
    }

    RequestBody body = RequestBody.create(
        MediaType.get("application/json; charset=utf-8"),
        jsonBody
    );

    Request request = new Request.Builder()
        .url(baseUrl + API_PATH)
        .addHeader("authver", "2.0")
        .addHeader("x-ak", accessKey)
        .addHeader("x-timestamp", timestamp)
        .addHeader("x-sign", signature)
        .post(body)
        .build();

    try (Response response = client.newCall(request).execute()) {
      if (!response.isSuccessful()) {
        throw new IOException("请求失败: " + response);
      }

      ResponseBody responseBody = response.body();
      if (responseBody == null) {
        throw new IOException("响应体为空");
      }

      String responseBodyString = responseBody.string();
      JSONObject responseJson = new JSONObject(responseBodyString);

      // 校验返回码
      if (responseJson.has("code")) {
        int code = responseJson.getInt("code");
        if (code != 200) {
          String errorMsg = responseJson.optString("msg", "未知错误");
          LogFileUtil.logAndWrite(Log.ERROR, "ArmCloudApiClient", "getInstanceListInfo: 接口返回错误码 " + code + ", 错误信息: " + errorMsg, null);
          throw new IOException("接口返回错误码: " + code + ", 错误信息: " + errorMsg);
        }
      } else {
        LogFileUtil.logAndWrite(Log.ERROR, "ArmCloudApiClient", "getInstanceListInfo: 响应中缺少 'code' 字段", null);
        throw new IOException("响应中缺少 'code' 字段");
      }

      // 提取 padCode 列表
      JSONArray pageDataArray = responseJson.optJSONObject("data")
          .optJSONArray("pageData");

      if (pageDataArray == null || pageDataArray.length() == 0) {
        LogFileUtil.logAndWrite(Log.WARN, "ArmCloudApiClient", "getInstanceListInfo: 查询结果为空", null);
        return new String[0];
      }

      int length = pageDataArray.length();
      String[] padCodesResult = new String[length];

      for (int i = 0; i < length; i++) {
        JSONObject item = pageDataArray.getJSONObject(i);
        if (!item.has("padCode")) {
          LogFileUtil.logAndWrite(Log.WARN, "ArmCloudApiClient", "getInstanceListInfo: 返回对象缺少 'padCode' 字段", null);
          throw new IOException("返回对象缺少 'padCode' 字段");
        }
        padCodesResult[i] = item.getString("padCode");
      }

      return padCodesResult;

    } catch (JSONException e) {
      LogFileUtil.logAndWrite(Log.ERROR, "ArmCloudApiClient", "getInstanceListInfo: 响应解析失败", e);
      throw new IOException("响应解析失败", e);
    }
  }

}