NF-e em lote: do XML ao DANFE em A4 ou 10×15

curl -X POST "https://convertaja.com.br/v1/tools/xml-nfe-para-pdf?wait=true" \
  -H "Authorization: Bearer $CONVERTAJA_KEY" \
  -F "files=@nota.xml" \
  -F "layout=a4"

import { openAsBlob } from 'node:fs';

const form = new FormData();
form.append('files', await openAsBlob('nota.xml'), 'nota.xml');
form.append('layout', 'a4'); // ou "simplificado" (10×15)

const res = await fetch('https://convertaja.com.br/v1/tools/xml-nfe-para-pdf?wait=true', {
  method: 'POST',
  headers: { Authorization: `Bearer ${process.env.CONVERTAJA_KEY}` },
  body: form,
});
const job = await res.json();
console.log(job.status, job.info, job.outputs?.[0]?.name);

import os
import requests

with open("nota.xml", "rb") as f:
    res = requests.post(
        "https://convertaja.com.br/v1/tools/xml-nfe-para-pdf",
        params={"wait": "true"},
        headers={"Authorization": f"Bearer {os.environ['CONVERTAJA_KEY']}"},
        files=[("files", ("nota.xml", f, "application/xml"))],
        data={"layout": "a4"},  # ou "simplificado" (10×15)
        timeout=90,
    )
job = res.json()
print(job["status"], job.get("info"), job["outputs"][0]["name"] if job.get("outputs") else "")

<?php
$ch = curl_init('https://convertaja.com.br/v1/tools/xml-nfe-para-pdf?wait=true');
curl_setopt_array($ch, [
  CURLOPT_POST => true,
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_TIMEOUT => 90,
  CURLOPT_HTTPHEADER => ['Authorization: Bearer ' . getenv('CONVERTAJA_KEY')],
  CURLOPT_POSTFIELDS => [
    'files' => new CURLFile('nota.xml', 'application/xml'),
    'layout' => 'a4', // ou 'simplificado' (10×15)
  ],
]);
$job = json_decode(curl_exec($ch), true);
echo "{$job['status']} {$job['info']}\n";

# Repita -F "files=@…" para cada XML; merge=true junta tudo num PDF só
curl -X POST "https://convertaja.com.br/v1/tools/xml-nfe-para-pdf?wait=true" \
  -H "Authorization: Bearer $CONVERTAJA_KEY" \
  -F "files=@nota-4521.xml" \
  -F "files=@nota-4522.xml" \
  -F 'options={"layout":"a4","merge":true}'

# Um ZIP com vários XMLs; sem merge, cada nota vira um PDF
curl -s -X POST "https://convertaja.com.br/v1/tools/xml-nfe-para-pdf?wait=true" \
  -H "Authorization: Bearer $CONVERTAJA_KEY" \
  -F "files=@notas-outubro.zip" \
  -F "layout=simplificado" > tarefa.json

# download_url devolve um ZIP quando há mais de um PDF (requer jq)
curl -fs -o danfes.zip "$(jq -r .download_url tarefa.json)" \
  -H "Authorization: Bearer $CONVERTAJA_KEY"

// danfe-lote.mjs: gera os DANFEs de todos os XMLs de uma pasta
// Uso: node danfe-lote.mjs ./xml a4      (ou: node danfe-lote.mjs ./xml simplificado)
import { openAsBlob } from 'node:fs';
import { readdir, writeFile } from 'node:fs/promises';
import path from 'node:path';

const BASE = 'https://convertaja.com.br/v1';
const headers = { Authorization: `Bearer ${process.env.CONVERTAJA_KEY}` };
const PASTA = process.argv[2] || './xml';
const LAYOUT = process.argv[3] || 'a4';

async function api(p, options = {}) {
  const res = await fetch(BASE + p, { ...options, headers });
  const data = await res.json();
  if (!res.ok) throw new Error(`${res.status} ${data.error.code}: ${data.error.message}`);
  return data;
}

// Quantos arquivos cabem numa tarefa depende do plano (10 no Sandbox, 50 no Start…)
const me = await api('/me');
const porTarefa = me.limits.max_files_per_job;
const xmls = (await readdir(PASTA)).filter((n) => n.toLowerCase().endsWith('.xml'));
console.log(`${xmls.length} XMLs · ${porTarefa} por tarefa · ${me.credits.remaining} créditos disponíveis`);

for (let i = 0, lote = 1; i < xmls.length; i += porTarefa, lote++) {
  const form = new FormData();
  for (const nome of xmls.slice(i, i + porTarefa)) form.append('files', await openAsBlob(path.join(PASTA, nome)), nome);
  form.append('options', JSON.stringify({ layout: LAYOUT, merge: false }));

  let job = await api('/tools/xml-nfe-para-pdf?wait=true', { method: 'POST', body: form });
  while (job.status !== 'done' && job.status !== 'error') { // lotes grandes podem passar de 60 s
    await new Promise((r) => setTimeout(r, 2000));
    job = await api(`/jobs/${job.id}`);
  }
  if (job.status === 'error') {
    console.error(`Lote ${lote}: ${job.error.message} (créditos devolvidos)`);
    continue;
  }
  // download_url: o PDF, se for um só, ou um ZIP com todos
  const res = await fetch(job.download_url, { headers });
  const destino = job.outputs.length === 1 ? job.outputs[0].name : `danfes-lote-${lote}.zip`;
  await writeFile(destino, Buffer.from(await res.arrayBuffer()));
  console.log(`Lote ${lote}: ${job.info} → ${destino}`);
}

# danfe_lote.py: gera os DANFEs de todos os XMLs de uma pasta
# Uso: python danfe_lote.py ./xml a4      (ou: python danfe_lote.py ./xml simplificado)
import json
import os
import sys
import time
import requests

BASE = "https://convertaja.com.br/v1"
HEADERS = {"Authorization": f"Bearer {os.environ['CONVERTAJA_KEY']}"}
PASTA = sys.argv[1] if len(sys.argv) > 1 else "./xml"
LAYOUT = sys.argv[2] if len(sys.argv) > 2 else "a4"


def api(method, path, **kwargs):
    res = requests.request(method, BASE + path, headers=HEADERS, timeout=120, **kwargs)
    data = res.json()
    if not res.ok:
        raise RuntimeError(f"{res.status_code} {data['error']['code']}: {data['error']['message']}")
    return data


# Quantos arquivos cabem numa tarefa depende do plano (10 no Sandbox, 50 no Start…)
me = api("GET", "/me")
por_tarefa = me["limits"]["max_files_per_job"]
xmls = sorted(n for n in os.listdir(PASTA) if n.lower().endswith(".xml"))
print(f"{len(xmls)} XMLs · {por_tarefa} por tarefa · {me['credits']['remaining']} créditos disponíveis")

for lote, i in enumerate(range(0, len(xmls), por_tarefa), start=1):
    abertos = [open(os.path.join(PASTA, n), "rb") for n in xmls[i:i + por_tarefa]]
    try:
        job = api("POST", "/tools/xml-nfe-para-pdf", params={"wait": "true"},
                  files=[("files", (os.path.basename(f.name), f, "application/xml")) for f in abertos],
                  data={"options": json.dumps({"layout": LAYOUT, "merge": False})})
    finally:
        for f in abertos:
            f.close()
    while job["status"] not in ("done", "error"):  # lotes grandes podem passar de 60 s
        time.sleep(2)
        job = api("GET", f"/jobs/{job['id']}")
    if job["status"] == "error":
        print(f"Lote {lote}: {job['error']['message']} (créditos devolvidos)")
        continue
    # download_url: o PDF, se for um só, ou um ZIP com todos
    res = requests.get(job["download_url"], headers=HEADERS, timeout=120)
    destino = job["outputs"][0]["name"] if len(job["outputs"]) == 1 else f"danfes-lote-{lote}.zip"
    with open(destino, "wb") as f:
        f.write(res.content)
    print(f"Lote {lote}: {job['info']} → {destino}")

<?php
// danfe-lote.php: gera os DANFEs de todos os XMLs de uma pasta
// Uso: php danfe-lote.php ./xml a4      (ou: php danfe-lote.php ./xml simplificado)
const BASE = 'https://convertaja.com.br/v1';
$pasta = $argv[1] ?? './xml';
$layout = $argv[2] ?? 'a4';

function api(string $method, string $path, $body = null): array {
  $ch = curl_init(BASE . $path);
  curl_setopt_array($ch, [
    CURLOPT_CUSTOMREQUEST => $method,
    CURLOPT_RETURNTRANSFER => true,
    CURLOPT_TIMEOUT => 120,
    CURLOPT_HTTPHEADER => ['Authorization: Bearer ' . getenv('CONVERTAJA_KEY')],
  ]);
  if ($body !== null) curl_setopt($ch, CURLOPT_POSTFIELDS, $body);
  $data = json_decode(curl_exec($ch), true);
  $status = curl_getinfo($ch, CURLINFO_HTTP_CODE);
  if ($status >= 400) throw new RuntimeException("$status {$data['error']['code']}: {$data['error']['message']}");
  return $data;
}

// Quantos arquivos cabem numa tarefa depende do plano (10 no Sandbox, 50 no Start…)
$me = api('GET', '/me');
$porTarefa = $me['limits']['max_files_per_job'];
$xmls = array_values(array_filter(glob(rtrim($pasta, '/') . '/*'), fn($f) => strtolower(pathinfo($f, PATHINFO_EXTENSION)) === 'xml'));
echo count($xmls) . " XMLs · $porTarefa por tarefa · {$me['credits']['remaining']} créditos disponíveis\n";

foreach (array_chunk($xmls, $porTarefa) as $n => $grupo) {
  $lote = $n + 1;
  $campos = ['options' => json_encode(['layout' => $layout, 'merge' => false])];
  foreach ($grupo as $i => $arquivo) {
    $campos["files[$i]"] = new CURLFile($arquivo, 'application/xml', basename($arquivo));
  }
  $job = api('POST', '/tools/xml-nfe-para-pdf?wait=true', $campos);
  while (!in_array($job['status'], ['done', 'error'], true)) { // lotes grandes podem passar de 60 s
    sleep(2);
    $job = api('GET', "/jobs/{$job['id']}");
  }
  if ($job['status'] === 'error') {
    echo "Lote $lote: {$job['error']['message']} (créditos devolvidos)\n";
    continue;
  }
  // download_url: o PDF, se for um só, ou um ZIP com todos
  $destino = count($job['outputs']) === 1 ? $job['outputs'][0]['name'] : "danfes-lote-$lote.zip";
  $fp = fopen($destino, 'wb');
  $ch = curl_init($job['download_url']);
  curl_setopt_array($ch, [CURLOPT_FILE => $fp, CURLOPT_HTTPHEADER => ['Authorization: Bearer ' . getenv('CONVERTAJA_KEY')]]);
  curl_exec($ch);
  fclose($fp);
  echo "Lote $lote: {$job['info']} → $destino\n";
}