Especificación Técnica: `rel_clientes_contactos`¶

Esquema: clientes
Base de Datos: crm
Servicio: svc-clientes
Tabla Legacy Origen: i134t_contacto_cliente (relación)
Propósito: Tabla de relación N:M entre clientes comerciales (mae_clientes) y el directorio de contactos (mae_contactos_cliente). Define la función, atribuciones y facultades operativas (decisión de compra, emisión de pedidos, recepción de mercadería) del contacto en cada cliente específico.

1. Justificación y Mejoras de Arquitectura¶

Normalización N:M Flexible: Desacopla los contactos del cliente para permitir que un mismo profesional o interlocutor pueda representar o estar vinculado a múltiples razones sociales o establecimientos clientes con roles y facultades diferenciadas.
Atribuciones Operativas por Cliente: Modela con precisión las banderas de autorización por cada cliente comercial (is_contacto_principal, is_tomador_decision, is_autorizado_pedidos, is_autorizado_recibir).
Aislamiento Multi-Tenant (RLS): Integra empresa_id BIGINT NOT NULL con políticas RLS obligatorias (USING y WITH CHECK).
Integridad Referencial Compuesta: Clave única compuesta (empresa_id, id) y claves foráneas compuestas hacia clientes.mae_clientes(empresa_id, id) y clientes.mae_contactos_cliente(empresa_id, id) con borrado en cascada (ON DELETE CASCADE).
Unicidad de Vinculación: Restricción UNIQUE (empresa_id, cliente_id, contacto_id) para prevenir duplicidad de asignaciones activas.
Trazabilidad y Auditoría: Auditoría integral (created_at, updated_at, deleted_at, created_by, updated_by).

2. Definiciones de Implementación¶

DBMLSQLSQLAlchemyAlembic

Table clientes.rel_clientes_contactos {
    id                      uuid          [pk, default: `gen_random_uuid()`, note: 'Identificador único UUID']
    empresa_id              bigint        [not null, note: 'Identificador BIGINT de la empresa en core.identidad (RLS)']
    cliente_id              uuid          [not null, note: 'Cliente comercial vinculado']
    contacto_id             uuid          [not null, note: 'Persona de contacto vinculada']
    cargo_en_cliente        varchar(100)  [note: 'Cargo o rol desempeñado específicamente para este cliente']
    departamento            varchar(100)  [note: 'Departamento o área (Compras, Tesorería, Bodega)']
    is_contacto_principal   boolean       [not null, default: `false`, note: 'Indica si es el interlocutor titular del cliente']
    is_tomador_decision     boolean       [not null, default: `false`, note: 'Indica si aprueba cotizaciones o presupuestos']
    is_autorizado_pedidos   boolean       [not null, default: `true`, note: 'Indica si puede autorizar u ordenar pedidos']
    is_autorizado_recibir   boolean       [not null, default: `true`, note: 'Indica si puede recibir y firmar entregas de mercadería']

    // Auditoría General
    is_activo               boolean       [not null, default: `true`, note: 'Estado lógico del registro']
    created_at              timestamptz   [not null, default: `now()`, note: 'Fecha de creación']
    updated_at              timestamptz   [not null, default: `now()`, note: 'Fecha de última actualización']
    deleted_at              timestamptz   [note: 'Fecha de eliminación lógica']
    created_by              uuid          [note: 'Usuario creador']
    updated_by              uuid          [note: 'Usuario modificador']

    Indexes {
        (empresa_id, id) [unique, name: 'uq_rel_clientes_contactos_empresa_id']
        (empresa_id, cliente_id, contacto_id) [unique, name: 'uq_rel_clientes_contactos_asignacion']
        (empresa_id, is_activo) [name: 'ix_rel_clientes_contactos_empresa_activo']
        (empresa_id, cliente_id) [name: 'ix_rel_clientes_contactos_empresa_cliente']
        (empresa_id, contacto_id) [name: 'ix_rel_clientes_contactos_empresa_contacto']
    }
}

Ref: clientes.rel_clientes_contactos.(empresa_id, cliente_id) > clientes.mae_clientes.(empresa_id, id) [delete: cascade]
Ref: clientes.rel_clientes_contactos.(empresa_id, contacto_id) > clientes.mae_contactos_cliente.(empresa_id, id) [delete: cascade]

CREATE TABLE IF NOT EXISTS clientes.rel_clientes_contactos (
    id UUID NOT NULL DEFAULT gen_random_uuid(),
    empresa_id BIGINT NOT NULL,
    cliente_id UUID NOT NULL,
    contacto_id UUID NOT NULL,
    cargo_en_cliente VARCHAR(100),
    departamento VARCHAR(100),
    is_contacto_principal BOOLEAN NOT NULL DEFAULT false,
    is_tomador_decision BOOLEAN NOT NULL DEFAULT false,
    is_autorizado_pedidos BOOLEAN NOT NULL DEFAULT true,
    is_autorizado_recibir BOOLEAN NOT NULL DEFAULT true,

    -- Auditoría General
    is_activo BOOLEAN NOT NULL DEFAULT true,
    created_at TIMESTAMPTZ NOT NULL DEFAULT now(),
    updated_at TIMESTAMPTZ NOT NULL DEFAULT now(),
    deleted_at TIMESTAMPTZ,
    created_by UUID,
    updated_by UUID,

    CONSTRAINT pk_rel_clientes_contactos
        PRIMARY KEY (id),

    CONSTRAINT uq_rel_clientes_contactos_empresa_id
        UNIQUE (empresa_id, id),

    CONSTRAINT uq_rel_clientes_contactos_asignacion
        UNIQUE (empresa_id, cliente_id, contacto_id),

    CONSTRAINT fk_rel_clientes_contactos_cliente
        FOREIGN KEY (empresa_id, cliente_id)
        REFERENCES clientes.mae_clientes (empresa_id, id)
        ON DELETE CASCADE,

    CONSTRAINT fk_rel_clientes_contactos_contacto
        FOREIGN KEY (empresa_id, contacto_id)
        REFERENCES clientes.mae_contactos_cliente (empresa_id, id)
        ON DELETE CASCADE
);

CREATE INDEX IF NOT EXISTS ix_rel_clientes_contactos_empresa_activo
    ON clientes.rel_clientes_contactos (empresa_id, is_activo);

CREATE INDEX IF NOT EXISTS ix_rel_clientes_contactos_empresa_cliente
    ON clientes.rel_clientes_contactos (empresa_id, cliente_id);

CREATE INDEX IF NOT EXISTS ix_rel_clientes_contactos_empresa_contacto
    ON clientes.rel_clientes_contactos (empresa_id, contacto_id);

COMMENT ON TABLE clientes.rel_clientes_contactos IS
    'Relación Clientes y Contactos: Vinculación N:M entre clientes comerciales y contactos con atribuciones operativas.';

COMMENT ON COLUMN clientes.rel_clientes_contactos.id IS
    'Identificador único UUID';

COMMENT ON COLUMN clientes.rel_clientes_contactos.empresa_id IS
    'Identificador BIGINT de la empresa en core.identidad (RLS)';

COMMENT ON COLUMN clientes.rel_clientes_contactos.cliente_id IS
    'Cliente comercial vinculado';

COMMENT ON COLUMN clientes.rel_clientes_contactos.contacto_id IS
    'Persona de contacto vinculada';

COMMENT ON COLUMN clientes.rel_clientes_contactos.cargo_en_cliente IS
    'Cargo o función desempeñada específicamente para este cliente';

COMMENT ON COLUMN clientes.rel_clientes_contactos.departamento IS
    'Departamento o área (Compras, Tesorería, Bodega)';

COMMENT ON COLUMN clientes.rel_clientes_contactos.is_contacto_principal IS
    'Indica si es el interlocutor titular del cliente';

COMMENT ON COLUMN clientes.rel_clientes_contactos.is_tomador_decision IS
    'Indica si aprueba cotizaciones o presupuestos';

COMMENT ON COLUMN clientes.rel_clientes_contactos.is_autorizado_pedidos IS
    'Indica si puede autorizar u ordenar pedidos';

COMMENT ON COLUMN clientes.rel_clientes_contactos.is_autorizado_recibir IS
    'Indica si puede recibir y firmar entregas de mercadería';

COMMENT ON COLUMN clientes.rel_clientes_contactos.is_activo IS
    'Estado lógico del registro';

COMMENT ON COLUMN clientes.rel_clientes_contactos.created_at IS
    'Fecha de creación';

COMMENT ON COLUMN clientes.rel_clientes_contactos.updated_at IS
    'Fecha de última actualización';

COMMENT ON COLUMN clientes.rel_clientes_contactos.deleted_at IS
    'Fecha de eliminación lógica';

COMMENT ON COLUMN clientes.rel_clientes_contactos.created_by IS
    'Usuario creador';

COMMENT ON COLUMN clientes.rel_clientes_contactos.updated_by IS
    'Usuario modificador';

ALTER TABLE clientes.rel_clientes_contactos
    ENABLE ROW LEVEL SECURITY;

CREATE POLICY rls_rel_clientes_contactos_empresa
    ON clientes.rel_clientes_contactos
    FOR ALL
    USING (
        empresa_id = current_setting(
            'app.current_empresa_id',
            true
        )::BIGINT
    )
    WITH CHECK (
        empresa_id = current_setting(
            'app.current_empresa_id',
            true
        )::BIGINT
    );

import uuid
from datetime import datetime
from typing import Optional

from sqlalchemy import (
    BigInteger,
    Boolean,
    ForeignKeyConstraint,
    Index,
    String,
    UniqueConstraint,
    text,
)
from sqlalchemy.dialects.postgresql import TIMESTAMPTZ, UUID
from sqlalchemy.orm import Mapped, mapped_column

from app.db.base import Base


class RelClientesContactos(Base):
    """
    Relación Clientes y Contactos.

    Vinculación N:M entre clientes comerciales y contactos, definiendo
    roles y autorizaciones operativas.

    Legacy:
        i134t_contacto_cliente
    """

    __tablename__ = "rel_clientes_contactos"

    __table_args__ = (
        UniqueConstraint(
            "empresa_id",
            "id",
            name="uq_rel_clientes_contactos_empresa_id",
        ),
        UniqueConstraint(
            "empresa_id",
            "cliente_id",
            "contacto_id",
            name="uq_rel_clientes_contactos_asignacion",
        ),
        ForeignKeyConstraint(
            ["empresa_id", "cliente_id"],
            ["clientes.mae_clientes.empresa_id", "clientes.mae_clientes.id"],
            ondelete="CASCADE",
            name="fk_rel_clientes_contactos_cliente",
        ),
        ForeignKeyConstraint(
            ["empresa_id", "contacto_id"],
            ["clientes.mae_contactos_cliente.empresa_id", "clientes.mae_contactos_cliente.id"],
            ondelete="CASCADE",
            name="fk_rel_clientes_contactos_contacto",
        ),
        Index(
            "ix_rel_clientes_contactos_empresa_activo",
            "empresa_id",
            "is_activo",
        ),
        Index(
            "ix_rel_clientes_contactos_empresa_cliente",
            "empresa_id",
            "cliente_id",
        ),
        Index(
            "ix_rel_clientes_contactos_empresa_contacto",
            "empresa_id",
            "contacto_id",
        ),
        {
            "schema": "clientes",
            "comment": "Relación Clientes y Contactos",
        },
    )

    id: Mapped[uuid.UUID] = mapped_column(
        UUID(as_uuid=True),
        primary_key=True,
        server_default=text("gen_random_uuid()"),
        comment="Identificador único UUID",
    )

    empresa_id: Mapped[int] = mapped_column(
        BigInteger,
        nullable=False,
        comment="Identificador BIGINT de la empresa en core.identidad (RLS)",
    )

    cliente_id: Mapped[uuid.UUID] = mapped_column(
        UUID(as_uuid=True),
        nullable=False,
        comment="Cliente comercial vinculado",
    )

    contacto_id: Mapped[uuid.UUID] = mapped_column(
        UUID(as_uuid=True),
        nullable=False,
        comment="Persona de contacto vinculada",
    )

    cargo_en_cliente: Mapped[Optional[str]] = mapped_column(
        String(100),
        nullable=True,
        comment="Cargo o función desempeñada específicamente para este cliente",
    )

    departamento: Mapped[Optional[str]] = mapped_column(
        String(100),
        nullable=True,
        comment="Departamento o área (Compras, Tesorería, Bodega)",
    )

    is_contacto_principal: Mapped[bool] = mapped_column(
        Boolean,
        nullable=False,
        server_default=text("false"),
        comment="Indica si es el interlocutor titular del cliente",
    )

    is_tomador_decision: Mapped[bool] = mapped_column(
        Boolean,
        nullable=False,
        server_default=text("false"),
        comment="Indica si aprueba cotizaciones o presupuestos",
    )

    is_autorizado_pedidos: Mapped[bool] = mapped_column(
        Boolean,
        nullable=False,
        server_default=text("true"),
        comment="Indica si puede autorizar u ordenar pedidos",
    )

    is_autorizado_recibir: Mapped[bool] = mapped_column(
        Boolean,
        nullable=False,
        server_default=text("true"),
        comment="Indica si puede recibir y firmar entregas de mercadería",
    )

    is_activo: Mapped[bool] = mapped_column(
        Boolean,
        nullable=False,
        server_default=text("true"),
        comment="Estado lógico del registro",
    )

    created_at: Mapped[datetime] = mapped_column(
        TIMESTAMPTZ,
        nullable=False,
        server_default=text("now()"),
        comment="Fecha de creación",
    )

    updated_at: Mapped[datetime] = mapped_column(
        TIMESTAMPTZ,
        nullable=False,
        server_default=text("now()"),
        comment="Fecha de última actualización",
    )

    deleted_at: Mapped[Optional[datetime]] = mapped_column(
        TIMESTAMPTZ,
        nullable=True,
        comment="Fecha de eliminación lógica",
    )

    created_by: Mapped[Optional[uuid.UUID]] = mapped_column(
        UUID(as_uuid=True),
        nullable=True,
        comment="Usuario creador",
    )

    updated_by: Mapped[Optional[uuid.UUID]] = mapped_column(
        UUID(as_uuid=True),
        nullable=True,
        comment="Usuario modificador",
    )

"""create rel_clientes_contactos

Revision ID: rel_cli_0004
Revises: rel_0004
Create Date: 2026-09-14
"""

from typing import Sequence, Union

from alembic import op
import sqlalchemy as sa
from sqlalchemy.dialects import postgresql


revision: str = "rel_cli_0004"
down_revision: Union[str, None] = "rel_0004"
branch_labels: Union[str, Sequence[str], None] = None
depends_on: Union[str, Sequence[str], None] = None


def upgrade() -> None:

    op.create_table(
        "rel_clientes_contactos",

        sa.Column(
            "id",
            postgresql.UUID(as_uuid=True),
            nullable=False,
            server_default=sa.text("gen_random_uuid()"),
            comment="Identificador único UUID",
        ),

        sa.Column(
            "empresa_id",
            sa.BigInteger(),
            nullable=False,
            comment="Identificador BIGINT de la empresa en core.identidad (RLS)",
        ),

        sa.Column(
            "cliente_id",
            postgresql.UUID(as_uuid=True),
            nullable=False,
            comment="Cliente comercial vinculado",
        ),

        sa.Column(
            "contacto_id",
            postgresql.UUID(as_uuid=True),
            nullable=False,
            comment="Persona de contacto vinculada",
        ),

        sa.Column(
            "cargo_en_cliente",
            sa.String(length=100),
            nullable=True,
            comment="Cargo o función desempeñada específicamente para este cliente",
        ),

        sa.Column(
            "departamento",
            sa.String(length=100),
            nullable=True,
            comment="Departamento o área (Compras, Tesorería, Bodega)",
        ),

        sa.Column(
            "is_contacto_principal",
            sa.Boolean(),
            nullable=False,
            server_default=sa.text("false"),
            comment="Indica si es el interlocutor titular del cliente",
        ),

        sa.Column(
            "is_tomador_decision",
            sa.Boolean(),
            nullable=False,
            server_default=sa.text("false"),
            comment="Indica si aprueba cotizaciones o presupuestos",
        ),

        sa.Column(
            "is_autorizado_pedidos",
            sa.Boolean(),
            nullable=False,
            server_default=sa.text("true"),
            comment="Indica si puede autorizar u ordenar pedidos",
        ),

        sa.Column(
            "is_autorizado_recibir",
            sa.Boolean(),
            nullable=False,
            server_default=sa.text("true"),
            comment="Indica si puede recibir y firmar entregas de mercadería",
        ),

        # Auditoría General
        sa.Column(
            "is_activo",
            sa.Boolean(),
            nullable=False,
            server_default=sa.text("true"),
            comment="Estado lógico del registro",
        ),

        sa.Column(
            "created_at",
            sa.TIMESTAMP(timezone=True),
            nullable=False,
            server_default=sa.text("now()"),
            comment="Fecha de creación",
        ),

        sa.Column(
            "updated_at",
            sa.TIMESTAMP(timezone=True),
            nullable=False,
            server_default=sa.text("now()"),
            comment="Fecha de última actualización",
        ),

        sa.Column(
            "deleted_at",
            sa.TIMESTAMP(timezone=True),
            nullable=True,
            comment="Fecha de eliminación lógica",
        ),

        sa.Column(
            "created_by",
            postgresql.UUID(as_uuid=True),
            nullable=True,
            comment="Usuario creador",
        ),

        sa.Column(
            "updated_by",
            postgresql.UUID(as_uuid=True),
            nullable=True,
            comment="Usuario modificador",
        ),

        sa.PrimaryKeyConstraint(
            "id",
            name="pk_rel_clientes_contactos",
        ),

        sa.UniqueConstraint(
            "empresa_id",
            "id",
            name="uq_rel_clientes_contactos_empresa_id",
        ),

        sa.UniqueConstraint(
            "empresa_id",
            "cliente_id",
            "contacto_id",
            name="uq_rel_clientes_contactos_asignacion",
        ),

        sa.ForeignKeyConstraint(
            ["empresa_id", "cliente_id"],
            ["clientes.mae_clientes.empresa_id", "clientes.mae_clientes.id"],
            ondelete="CASCADE",
            name="fk_rel_clientes_contactos_cliente",
        ),

        sa.ForeignKeyConstraint(
            ["empresa_id", "contacto_id"],
            ["clientes.mae_contactos_cliente.empresa_id", "clientes.mae_contactos_cliente.id"],
            ondelete="CASCADE",
            name="fk_rel_clientes_contactos_contacto",
        ),

        comment="Relación Clientes y Contactos",
        schema="clientes",
    )

    op.create_index(
        "ix_rel_clientes_contactos_empresa_activo",
        "rel_clientes_contactos",
        ["empresa_id", "is_activo"],
        unique=False,
        schema="clientes",
    )

    op.create_index(
        "ix_rel_clientes_contactos_empresa_cliente",
        "rel_clientes_contactos",
        ["empresa_id", "cliente_id"],
        unique=False,
        schema="clientes",
    )

    op.create_index(
        "ix_rel_clientes_contactos_empresa_contacto",
        "rel_clientes_contactos",
        ["empresa_id", "contacto_id"],
        unique=False,
        schema="clientes",
    )

    op.execute(
        """
        ALTER TABLE clientes.rel_clientes_contactos
        ENABLE ROW LEVEL SECURITY;
        """
    )

    op.execute(
        """
        CREATE POLICY rls_rel_clientes_contactos_empresa
        ON clientes.rel_clientes_contactos
        FOR ALL
        USING (
            empresa_id = current_setting(
                'app.current_empresa_id',
                true
            )::BIGINT
        )
        WITH CHECK (
            empresa_id = current_setting(
                'app.current_empresa_id',
                true
            )::BIGINT
        );
        """
    )


def downgrade() -> None:

    op.execute(
        """
        DROP POLICY IF EXISTS rls_rel_clientes_contactos_empresa
        ON clientes.rel_clientes_contactos;
        """
    )

    op.execute(
        """
        ALTER TABLE clientes.rel_clientes_contactos
        DISABLE ROW LEVEL SECURITY;
        """
    )

    op.drop_index(
        "ix_rel_clientes_contactos_empresa_contacto",
        table_name="rel_clientes_contactos",
        schema="clientes",
    )

    op.drop_index(
        "ix_rel_clientes_contactos_empresa_cliente",
        table_name="rel_clientes_contactos",
        schema="clientes",
    )

    op.drop_index(
        "ix_rel_clientes_contactos_empresa_activo",
        table_name="rel_clientes_contactos",
        schema="clientes",
    )

    op.drop_table(
        "rel_clientes_contactos",
        schema="clientes",
    )

Especificación Técnica: rel_clientes_contactos¶

1. Justificación y Mejoras de Arquitectura¶

2. Definiciones de Implementación¶

Especificación Técnica: `rel_clientes_contactos`¶