Gửi tin

curl -X POST https://business.adflex.vn/api/v1/messages/send \
  -H "Authorization: Bearer $ADFLEX_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "template_id": "123456",
    "phone": "84912345678",
    "template_data": { "otp": "246813", "time": "5 phut" },
    "tracking_id": "otp-login-8842"
  }'

function sendZns(array $payload): array {
    $ch = curl_init('https://business.adflex.vn/api/v1/messages/send');
    curl_setopt_array($ch, [
        CURLOPT_POST           => true,
        CURLOPT_RETURNTRANSFER => true,
        CURLOPT_TIMEOUT        => 15,
        CURLOPT_HTTPHEADER     => [
            'Authorization: Bearer ' . getenv('ADFLEX_API_KEY'),
            'Content-Type: application/json',
        ],
        CURLOPT_POSTFIELDS     => json_encode($payload, JSON_UNESCAPED_UNICODE),
    ]);
    $body = curl_exec($ch);
    $code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    $err  = curl_error($ch);
    curl_close($ch);

    if ($body === false) throw new RuntimeException("Lỗi mạng: $err");
    $json = json_decode($body, true);
    if ($code !== 202) {
        throw new RuntimeException($json['error']['message'] ?? "HTTP $code");
    }
    return $json;
}

async function sendZns(payload) {
  const res = await fetch('https://business.adflex.vn/api/v1/messages/send', {
    method: 'POST',
    headers: {
      Authorization: `Bearer ${process.env.ADFLEX_API_KEY}`,
      'Content-Type': 'application/json',
    },
    body: JSON.stringify(payload),
    signal: AbortSignal.timeout(15_000),
  });
  const json = await res.json();
  if (res.status !== 202) {
    throw new Error(json?.error?.message ?? `HTTP ${res.status}`);
  }
  return json;
}

HttpClient http = HttpClient.newHttpClient();

String body = """
    {"template_id":"123456","phone":"84912345678",
     "template_data":{"otp":"246813","time":"5 phut"},
     "tracking_id":"otp-login-8842"}
    """;

HttpRequest req = HttpRequest.newBuilder()
    .uri(URI.create("https://business.adflex.vn/api/v1/messages/send"))
    .header("Authorization", "Bearer " + System.getenv("ADFLEX_API_KEY"))
    .header("Content-Type", "application/json")
    .timeout(Duration.ofSeconds(15))
    .POST(HttpRequest.BodyPublishers.ofString(body, StandardCharsets.UTF_8))
    .build();

HttpResponse<String> res = http.send(req, HttpResponse.BodyHandlers.ofString());
if (res.statusCode() != 202) {
    throw new IllegalStateException("Gửi thất bại: " + res.body());
}