Clasificación aduanera UE y China

export TTH_API_KEY="th_live_su_clave_api"

{
  "id": "a1b2c3d4-e5f6-7890-abcd-ef1234567890",
  "status": "pending",
  "analysis_mode": "operational",
  "created_at": "2026-09-10T10:30:00Z",
  "updated_at": "2026-09-10T10:30:00Z"
}

import os
import time
import uuid

import httpx

BASE_URL = "https://api.thetradehub.eu"
API_KEY = os.environ["TTH_API_KEY"]
ROUTES = {"eu": "classify", "china": "classify-china"}


def classify_product(
    content: str,
    jurisdiction: str = "eu",
    analysis_mode: str = "operational",
    classification_date: str | None = None,
) -> dict:
    route = ROUTES[jurisdiction]
    timeout_seconds = 12 * 60 if analysis_mode == "operational" else 18 * 60
    headers = {
        "X-API-Key": API_KEY,
        "Idempotency-Key": str(uuid.uuid4()),
    }
    payload = {
        "content": content,
        "analysis_mode": analysis_mode,
        "locale": "es",
    }
    if classification_date:
        payload["classification_date"] = classification_date

    with httpx.Client(base_url=BASE_URL, headers=headers, timeout=30) as client:
        response = client.post(f"/v1/{route}/jobs", json=payload)
        response.raise_for_status()
        job_id = response.json()["id"]

        deadline = time.monotonic() + timeout_seconds
        delay = 1
        while time.monotonic() < deadline:
            response = client.get(f"/v1/{route}/jobs/{job_id}")
            response.raise_for_status()
            job = response.json()

            if job["status"] == "completed":
                return job["result"]
            if job["status"] == "failed":
                raise RuntimeError(job.get("error", "Classification failed"))

            time.sleep(delay)
            delay = min(delay * 2, 5)

    raise TimeoutError(f"El job {job_id} sigue en curso")


result = classify_product(
    "Bomba centrífuga de acero inoxidable para líquidos alimentarios",
    jurisdiction="china",
    classification_date="2026-09-10",
)

decision = result["classification"]
china = result.get("china") or decision.get("china")
print(china.get("code13") or china["code10"])
print(decision["provenance"]["applied_tariff_date"])

{
  "status": "completed",
  "result": {
    "session_id": "run_abc123",
    "classification": {
      "jurisdiction": "eu",
      "status": "completed",
      "recommended_code": "8518300090",
      "candidates": [
        {
          "rank": 1,
          "code": "8518300090",
          "description": "Auriculares",
          "confidence": 0.94,
          "legal_position": "Clasificación según las RGI y las notas aplicables"
        }
      ],
      "provenance": {
        "applied_tariff_date": "2026-09-10T00:00:00Z",
        "tariff_date_basis": "request",
        "corpus_versions": {}
      }
    }
  }
}

{
  "status": "completed",
  "result": {
    "session_id": "run_def456",
    "classification": {
      "jurisdiction": "china",
      "status": "completed",
      "recommended_code": "8413709990999",
      "provenance": {
        "applied_tariff_date": "2026-09-10T00:00:00Z",
        "tariff_date_basis": "request",
        "corpus_versions": {}
      }
    },
    "china": {
      "code10": "8413709990",
      "code13": "8413709990999",
      "hs6": "841370",
      "description_zh": "离心泵",
      "confidence": 0.91,
      "justification": "Clasificación según el arancel chino y las notas nacionales",
      "ciq_candidates": [],
      "selected_ciq": "999",
      "declaration_elements": [],
      "supervision_codes": [],
      "quarantine_categories": [],
      "units": "",
      "mfn_rate": "",
      "vat_rate": "",
      "validated": true,
      "verification_status": "operational",
      "warnings": []
    }
  }
}

{
  "error": "descripción explícita del error"
}