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);
          }
      }

}