Afiliados

tx = client.affiliates.cross(
    [
        {"document_type": "CC", "document_number": "1032456789", "nombres": "María",
         "apellidos": "Gómez", "fecha_nacimiento": "15/03/1990", "correo": "maria.gomez@example.co",
         "salario": "$2.500.000", "estado_laboral": "ACTIVO"},
        {"document_type": "CE", "document_number": "998877", "nombres": "Andrés",
         "apellidos": "Pérez", "fecha_nacimiento": "1985-07-02", "celular": "3001234567"},
        {"document_type": "CC", "document_number": "52987654", "nombres": "Luisa",
         "apellidos": "Rojas"},  # sin fecha de nacimiento: se rechaza esta fila
    ],
    idempotency_key="horizonte-afiliados-2026-11-02-lote-001",
)
print(tx.transaction_id, tx.data["created"], tx.data["updated"], tx.data["rejected"])
for err in tx.data["errors"]:
    print("Fila", err.get("row"), err.get("document_number"), err.get("error"))

const tx = await client.affiliates.cross(
  [
    { document_type: "CC", document_number: "1032456789", nombres: "María",
      apellidos: "Gómez", fecha_nacimiento: "15/03/1990", correo: "maria.gomez@example.co",
      salario: "$2.500.000", estado_laboral: "ACTIVO" },
    { document_type: "CE", document_number: "998877", nombres: "Andrés",
      apellidos: "Pérez", fecha_nacimiento: "1985-07-02", celular: "3001234567" },
    { document_type: "CC", document_number: "52987654", nombres: "Luisa", apellidos: "Rojas" },
  ],
  { idempotencyKey: "horizonte-afiliados-2026-11-02-lote-001" },
);
console.log(tx.transactionId, tx.data.created, tx.data.updated, tx.data.rejected);
for (const err of (tx.data.errors as Array<Record<string, unknown>>) ?? []) {
  console.log("Fila", err.row, err.document_number, err.error);
}

$tx = $client->affiliates->cross([
    ['document_type' => 'CC', 'document_number' => '1032456789', 'nombres' => 'María',
     'apellidos' => 'Gómez', 'fecha_nacimiento' => '15/03/1990', 'correo' => 'maria.gomez@example.co',
     'salario' => '$2.500.000', 'estado_laboral' => 'ACTIVO'],
    ['document_type' => 'CE', 'document_number' => '998877', 'nombres' => 'Andrés',
     'apellidos' => 'Pérez', 'fecha_nacimiento' => '1985-07-02', 'celular' => '3001234567'],
    ['document_type' => 'CC', 'document_number' => '52987654', 'nombres' => 'Luisa', 'apellidos' => 'Rojas'],
], idempotencyKey: 'horizonte-afiliados-2026-11-02-lote-001');

echo $tx->transactionId, ' creados=', $tx->data['created'], ' rechazados=', $tx->data['rejected'], PHP_EOL;
foreach ($tx->data['errors'] ?? [] as $err) {
    echo 'Fila ', $err['row'] ?? '-', ': ', $err['error'] ?? '', PHP_EOL;
}

var lote = new[]
{
    new AffiliateRef("CC", "1032456789")
    {
        Extra = new Dictionary<string, object?>
        {
            ["nombres"] = "María", ["apellidos"] = "Gómez", ["fecha_nacimiento"] = "15/03/1990",
            ["correo"] = "maria.gomez@example.co", ["salario"] = "$2.500.000", ["estado_laboral"] = "ACTIVO",
        },
    },
    new AffiliateRef("CE", "998877")
    {
        Extra = new Dictionary<string, object?>
        {
            ["nombres"] = "Andrés", ["apellidos"] = "Pérez", ["fecha_nacimiento"] = "1985-07-02",
            ["celular"] = "3001234567",
        },
    },
    new AffiliateRef("CC", "52987654")
    {
        Extra = new Dictionary<string, object?> { ["nombres"] = "Luisa", ["apellidos"] = "Rojas" },
    },
};

Transaction tx = await client.Affiliates.CrossAsync(lote,
    idempotencyKey: "horizonte-afiliados-2026-11-02-lote-001");
Console.WriteLine($"{tx.TransactionId} creados={tx.Data["created"]} rechazados={tx.Data["rejected"]}");

tx, err := client.Affiliates.Cross(ctx, []map[string]any{
	{"document_type": "CC", "document_number": "1032456789", "nombres": "María",
		"apellidos": "Gómez", "fecha_nacimiento": "15/03/1990", "correo": "maria.gomez@example.co",
		"salario": "$2.500.000", "estado_laboral": "ACTIVO"},
	{"document_type": "CE", "document_number": "998877", "nombres": "Andrés",
		"apellidos": "Pérez", "fecha_nacimiento": "1985-07-02", "celular": "3001234567"},
	{"document_type": "CC", "document_number": "52987654", "nombres": "Luisa", "apellidos": "Rojas"},
}, compense.WithIdempotencyKey("horizonte-afiliados-2026-11-02-lote-001"))
if err != nil {
	log.Fatal(err)
}
fmt.Println(tx.TransactionID, tx.Data["created"], tx.Data["updated"], tx.Data["rejected"])

curl -X POST https://sandbox.dev.compense.co/gw/v1/gateway/affiliates/ \
  -H "X-API-Key: $COMPENSE_API_KEY" \
  -H "Idempotency-Key: horizonte-afiliados-2026-11-02-lote-001" \
  -H "Content-Type: application/json" \
  -d '[
    {"document_type": "CC", "document_number": "1032456789", "nombres": "María",
     "apellidos": "Gómez", "fecha_nacimiento": "15/03/1990", "correo": "maria.gomez@example.co",
     "salario": "$2.500.000", "estado_laboral": "ACTIVO"},
    {"document_type": "CE", "document_number": "998877", "nombres": "Andrés",
     "apellidos": "Pérez", "fecha_nacimiento": "1985-07-02", "celular": "3001234567"},
    {"document_type": "CC", "document_number": "52987654", "nombres": "Luisa", "apellidos": "Rojas"}
  ]'

# Un archivo abierto en binario, o una tupla (nombre, contenido, MIME) para fijar nombre y tipo.
with open("afiliados-horizonte-2026-11.csv", "rb") as fh:
    tx = client.affiliates.upload(
        ("afiliados-horizonte-2026-11.csv", fh, "text/csv"),
        idempotency_key="horizonte-afiliados-archivo-2026-11",
    )
print(tx.data["filename"], tx.data["created"], tx.data["updated"], tx.data["rejected"])

import { readFile } from "node:fs/promises";

// Acepta Blob/File, Uint8Array (un Buffer sirve), ArrayBuffer o el texto del CSV.
const tx = await client.affiliates.upload(await readFile("afiliados-horizonte-2026-11.csv"), {
  filename: "afiliados-horizonte-2026-11.csv",
  contentType: "text/csv",
  idempotencyKey: "horizonte-afiliados-archivo-2026-11",
});
console.log(tx.data.filename, tx.data.created, tx.data.updated, tx.data.rejected);

// Una ruta, un stream abierto (fopen), un SplFileInfo o un stream PSR-7.
$tx = $client->affiliates->upload(
    'afiliados-horizonte-2026-11.csv',
    idempotencyKey: 'horizonte-afiliados-archivo-2026-11',
);
echo $tx->data['filename'], ' creados=', $tx->data['created'], PHP_EOL;

await using FileStream file = File.OpenRead("afiliados-horizonte-2026-11.csv");
Transaction tx = await client.Affiliates.UploadAsync(
    file, "afiliados-horizonte-2026-11.csv", "text/csv",
    idempotencyKey: "horizonte-afiliados-archivo-2026-11");
Console.WriteLine($"{tx.Data["filename"]} creados={tx.Data["created"]} rechazados={tx.Data["rejected"]}");

f, err := os.Open("afiliados-horizonte-2026-11.csv")
if err != nil {
	log.Fatal(err)
}
defer f.Close()

// Cualquier io.Reader; el SDK lo guarda en memoria para poder reintentar.
tx, err := client.Affiliates.Upload(ctx, "afiliados-horizonte-2026-11.csv", f,
	compense.WithIdempotencyKey("horizonte-afiliados-archivo-2026-11"))
if err != nil {
	log.Fatal(err)
}
fmt.Println(tx.Data["filename"], tx.Data["created"], tx.Data["rejected"])

curl -X POST https://sandbox.dev.compense.co/gw/v1/gateway/affiliates/upload/ \
  -H "X-API-Key: $COMPENSE_API_KEY" \
  -H "Idempotency-Key: horizonte-afiliados-archivo-2026-11" \
  -F "file=@afiliados-horizonte-2026-11.csv;type=text/csv"

from compense_gateway import NotFoundError

try:
    lookup = client.affiliates.get("1.032.456.789")
    print(lookup.exists, lookup.document_number, lookup.affiliate.get("first_name"))
except NotFoundError as e:
    print("No es afiliado:", e.detail, e.trace_id)

import { NotFoundError } from "@compense/sdk";

try {
  const lookup = await client.affiliates.get("1.032.456.789");
  console.log(lookup.exists, lookup.documentNumber, lookup.affiliate.first_name);
} catch (err) {
  if (err instanceof NotFoundError) console.log("No es afiliado:", err.detail, err.traceId);
  else throw err;
}

use Compense\Sdk\Exception\NotFoundException;

try {
    $lookup = $client->affiliates->get('1.032.456.789');
    echo $lookup->documentNumber, ' ', $lookup->affiliate['first_name'] ?? '-', PHP_EOL;
} catch (NotFoundException $e) {
    echo 'No es afiliado: ', $e->detail, ' ', $e->traceId, PHP_EOL;
}

try
{
    AffiliateLookup lookup = await client.Affiliates.GetAsync("1.032.456.789");
    Console.WriteLine($"{lookup.Exists} {lookup.DocumentNumber} {lookup.Affiliate["first_name"]}");
}
catch (NotFoundException e)
{
    Console.WriteLine($"No es afiliado: {e.Detail} {e.TraceId}");
}

lookup, err := client.Affiliates.Get(ctx, "1.032.456.789")
switch {
case compense.IsNotFound(err):
	fmt.Println("No es afiliado")
case err != nil:
	log.Fatal(err)
default:
	fmt.Println(lookup.Exists, lookup.DocumentNumber, lookup.Affiliate["first_name"])
}

curl https://sandbox.dev.compense.co/gw/v1/gateway/affiliates/1032456789/ \
  -H "X-API-Key: $COMPENSE_API_KEY"
# {"exists": true, "document_number": "1032456789", "affiliate": {"first_name": "María", ...}}