Carga de histórico

-- Modelo canónico de origen (canonico-v1). Generado por conectores.canonico.esquema.
create schema if not exists canonico;

create table if not exists canonico.clientes (
    cliente_id text not null,
    fecha_alta timestamptz,
    canal_alta text,
    segmento text,
    perfil text,
    primary key (cliente_id)
);
comment on table canonico.clientes is 'Un registro por cliente identificable en el CRM.';

create table if not exists canonico.tickets (
    ticket_id text not null,
    cliente_id text not null,
    ts timestamptz not null,
    tienda text,
    canal text,
    total numeric(14,2),
    primary key (ticket_id),
    foreign key (cliente_id) references canonico.clientes (cliente_id)
);
comment on table canonico.tickets is 'Una fila por ticket de venta.';

create table if not exists canonico.lineas_ticket (
    ticket_id text not null,
    linea bigint not null,
    articulo_id text not null,
    cantidad numeric(14,2) not null,
    importe numeric(14,2) not null,
    margen numeric(14,2),
    coste numeric(14,2),
    primary key (ticket_id, linea),
    foreign key (ticket_id) references canonico.tickets (ticket_id),
    foreign key (articulo_id) references canonico.articulos (articulo_id)
);
comment on table canonico.lineas_ticket is 'Una fila por línea de ticket. El margen sale de `margen`, de `importe − coste` o del coste estándar del artículo, en ese orden.';

create table if not exists canonico.articulos (
    articulo_id text not null,
    categoria text not null,
    subcategoria text,
    marca text,
    coste_estandar numeric(14,2),
    primary key (articulo_id)
);
comment on table canonico.articulos is 'Catálogo de artículos con su categoría (la unidad de agregación de las compras).';

create table if not exists canonico.campanas (
    campana_id text not null,
    fecha_envio timestamptz,
    canal text,
    descripcion text,
    primary key (campana_id)
);
comment on table canonico.campanas is 'Campañas de cupones (opcional; da contexto a los envíos).';

create table if not exists canonico.cupones_emitidos (
    cupon_emitido_id text not null,
    cliente_id text not null,
    cupon_tipo_id text not null,
    ts_envio timestamptz not null,
    caducidad timestamptz not null,
    campana_id text,
    canal text,
    descuento_pct numeric(14,2),
    valor_max numeric(14,2),
    decision_id text,
    primary key (cupon_emitido_id),
    foreign key (cliente_id) references canonico.clientes (cliente_id),
    foreign key (campana_id) references canonico.campanas (campana_id)
);
comment on table canonico.cupones_emitidos is 'Un cupón enviado a un cliente. Genera CUPON_RECIBIDO y, si vence sin redención, CUPON_CADUCADO.';

create table if not exists canonico.redenciones (
    cupon_emitido_id text not null,
    ticket_id text not null,
    ts timestamptz not null,
    descuento numeric(14,2) not null,
    primary key (cupon_emitido_id, ticket_id),
    foreign key (cupon_emitido_id) references canonico.cupones_emitidos (cupon_emitido_id),
    foreign key (ticket_id) references canonico.tickets (ticket_id)
);
comment on table canonico.redenciones is 'Un cupón usado en un ticket.';

create table if not exists canonico.bajas (
    cliente_id text not null,
    ts timestamptz not null,
    clave text not null,
    canal text,
    primary key (cliente_id, ts, clave),
    foreign key (cliente_id) references canonico.clientes (cliente_id)
);
comment on table canonico.bajas is 'Bajas de comunicaciones o de cuenta.';