Especificación Técnica: `rel_promotores_supervisores`¶

Esquema: fuerza_ventas
Base de Datos: crm
Tabla Legacy Origen: i127t_promotor (co_promotor_padre)
Propósito: Asignación jerárquica histórica y activa entre promotores de campo y sus supervisores comerciales dentro de la estructura de ventas.

1. Justificación y Mejoras de Arquitectura¶

Normalización Jerárquica N:M Temporal: Desacopla la relación rígida 1:1 de supervisor en el maestro de promotores, permitiendo registrar líneas de supervisión activas e históricas con fechas de asignación (fecha_asignacion) y cierre (fecha_desasignacion).
Aislamiento Multi-Tenant (RLS): Integra empresa_id BIGINT NOT NULL con políticas RLS obligatorias (USING y WITH CHECK) garantizando que promotor y supervisor pertenezcan estrictamente al mismo tenant.
Integridad Referencial Compuesta: Claves foráneas compuestas (empresa_id, promotor_id) y (empresa_id, supervisor_id) hacia fuerza_ventas.mae_promotores(empresa_id, id).
Reglas de Dominio e Integridad:
CHECK (promotor_id <> supervisor_id) para impedir auto-supervisión circular.
CHECK (fecha_desasignacion IS NULL OR fecha_desasignacion >= fecha_asignacion) para consistencia en la línea de tiempo.
UNIQUE (empresa_id, promotor_id, supervisor_id, fecha_asignacion) para evitar asignaciones duplicadas en la misma fecha.
Trazabilidad y Auditoría: Auditoría integral (created_at, updated_at, deleted_at, created_by, updated_by) con auditoría integral.

2. Definiciones de Implementación¶

DBMLSQLSQLAlchemyAlembic

Table fuerza_ventas.rel_promotores_supervisores {
    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)']
    promotor_id         uuid        [not null, note: 'Promotor subordinado']
    supervisor_id       uuid        [not null, note: 'Promotor con rol de supervisor']
    fecha_asignacion    date        [not null, default: `CURRENT_DATE`, note: 'Fecha de inicio de supervisión']
    fecha_desasignacion date        [note: 'Fecha de finalización de supervisión']

    // 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_promotores_supervisores_empresa_id']
        (empresa_id, promotor_id, supervisor_id, fecha_asignacion) [unique, name: 'uq_rel_promotores_supervisores_asignacion']
        (empresa_id, is_activo) [name: 'ix_rel_promotores_supervisores_empresa_activo']
        (empresa_id, promotor_id) [name: 'ix_rel_promotores_supervisores_empresa_promotor']
        (empresa_id, supervisor_id) [name: 'ix_rel_promotores_supervisores_empresa_supervisor']
    }
}

Ref: fuerza_ventas.rel_promotores_supervisores.(empresa_id, promotor_id) > fuerza_ventas.mae_promotores.(empresa_id, id) [delete: cascade]
Ref: fuerza_ventas.rel_promotores_supervisores.(empresa_id, supervisor_id) > fuerza_ventas.mae_promotores.(empresa_id, id)

CREATE TABLE IF NOT EXISTS fuerza_ventas.rel_promotores_supervisores (
    id UUID NOT NULL DEFAULT gen_random_uuid(),
    empresa_id BIGINT NOT NULL,
    promotor_id UUID NOT NULL,
    supervisor_id UUID NOT NULL,
    fecha_asignacion DATE NOT NULL DEFAULT CURRENT_DATE,
    fecha_desasignacion DATE,

    -- 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_promotores_supervisores
        PRIMARY KEY (id),

    CONSTRAINT uq_rel_promotores_supervisores_empresa_id
        UNIQUE (empresa_id, id),

    CONSTRAINT uq_rel_promotores_supervisores_asignacion
        UNIQUE (empresa_id, promotor_id, supervisor_id, fecha_asignacion),

    CONSTRAINT ck_rel_promotores_supervisores_distintos
        CHECK (promotor_id <> supervisor_id),

    CONSTRAINT ck_rel_promotores_supervisores_fechas
        CHECK (fecha_desasignacion IS NULL OR fecha_desasignacion >= fecha_asignacion),

    CONSTRAINT fk_rel_promotores_supervisores_promotor
        FOREIGN KEY (empresa_id, promotor_id)
        REFERENCES fuerza_ventas.mae_promotores (empresa_id, id)
        ON DELETE CASCADE,

    CONSTRAINT fk_rel_promotores_supervisores_supervisor
        FOREIGN KEY (empresa_id, supervisor_id)
        REFERENCES fuerza_ventas.mae_promotores (empresa_id, id)
);

CREATE INDEX IF NOT EXISTS ix_rel_promotores_supervisores_empresa_activo
    ON fuerza_ventas.rel_promotores_supervisores (empresa_id, is_activo);

CREATE INDEX IF NOT EXISTS ix_rel_promotores_supervisores_empresa_promotor
    ON fuerza_ventas.rel_promotores_supervisores (empresa_id, promotor_id);

CREATE INDEX IF NOT EXISTS ix_rel_promotores_supervisores_empresa_supervisor
    ON fuerza_ventas.rel_promotores_supervisores (empresa_id, supervisor_id);

COMMENT ON TABLE fuerza_ventas.rel_promotores_supervisores IS
    'Relación Jerárquica Promotores y Supervisores: Asignación jerárquica histórica y activa entre promotores de campo y sus supervisores comerciales.';

COMMENT ON COLUMN fuerza_ventas.rel_promotores_supervisores.id IS
    'Identificador único UUID';

COMMENT ON COLUMN fuerza_ventas.rel_promotores_supervisores.empresa_id IS
    'Identificador UUID de la empresa en core.identidad (RLS)';

COMMENT ON COLUMN fuerza_ventas.rel_promotores_supervisores.promotor_id IS
    'Promotor subordinado';

COMMENT ON COLUMN fuerza_ventas.rel_promotores_supervisores.supervisor_id IS
    'Promotor con rol de supervisor';

COMMENT ON COLUMN fuerza_ventas.rel_promotores_supervisores.fecha_asignacion IS
    'Fecha de inicio de supervisión';

COMMENT ON COLUMN fuerza_ventas.rel_promotores_supervisores.fecha_desasignacion IS
    'Fecha de finalización de supervisión';

COMMENT ON COLUMN fuerza_ventas.rel_promotores_supervisores.is_activo IS
    'Estado lógico del registro';

COMMENT ON COLUMN fuerza_ventas.rel_promotores_supervisores.created_at IS
    'Fecha de creación';

COMMENT ON COLUMN fuerza_ventas.rel_promotores_supervisores.updated_at IS
    'Fecha de última actualización';

COMMENT ON COLUMN fuerza_ventas.rel_promotores_supervisores.deleted_at IS
    'Fecha de eliminación lógica';

COMMENT ON COLUMN fuerza_ventas.rel_promotores_supervisores.created_by IS
    'Usuario creador';

COMMENT ON COLUMN fuerza_ventas.rel_promotores_supervisores.updated_by IS
    'Usuario modificador';

ALTER TABLE fuerza_ventas.rel_promotores_supervisores
    ENABLE ROW LEVEL SECURITY;

CREATE POLICY rls_rel_promotores_supervisores_empresa
    ON fuerza_ventas.rel_promotores_supervisores
    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 date, datetime
from typing import Optional

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

from app.db.base import Base


class RelPromotoresSupervisores(Base):
    """
    Relación Jerárquica Promotores y Supervisores.

    Asignación jerárquica histórica y activa entre promotores de campo
    y sus supervisores comerciales.

    Legacy:
        i127t_promotor (co_promotor_padre)
    """

    __tablename__ = "rel_promotores_supervisores"

    __table_args__ = (
        UniqueConstraint(
            "empresa_id",
            "id",
            name="uq_rel_promotores_supervisores_empresa_id",
        ),
        UniqueConstraint(
            "empresa_id",
            "promotor_id",
            "supervisor_id",
            "fecha_asignacion",
            name="uq_rel_promotores_supervisores_asignacion",
        ),
        CheckConstraint(
            "promotor_id <> supervisor_id",
            name="ck_rel_promotores_supervisores_distintos",
        ),
        CheckConstraint(
            "fecha_desasignacion IS NULL OR fecha_desasignacion >= fecha_asignacion",
            name="ck_rel_promotores_supervisores_fechas",
        ),
        ForeignKeyConstraint(
            ["empresa_id", "promotor_id"],
            ["fuerza_ventas.mae_promotores.empresa_id", "fuerza_ventas.mae_promotores.id"],
            ondelete="CASCADE",
            name="fk_rel_promotores_supervisores_promotor",
        ),
        ForeignKeyConstraint(
            ["empresa_id", "supervisor_id"],
            ["fuerza_ventas.mae_promotores.empresa_id", "fuerza_ventas.mae_promotores.id"],
            name="fk_rel_promotores_supervisores_supervisor",
        ),
        Index(
            "ix_rel_promotores_supervisores_empresa_activo",
            "empresa_id",
            "is_activo",
        ),
        Index(
            "ix_rel_promotores_supervisores_empresa_promotor",
            "empresa_id",
            "promotor_id",
        ),
        Index(
            "ix_rel_promotores_supervisores_empresa_supervisor",
            "empresa_id",
            "supervisor_id",
        ),
        {
            "schema": "fuerza_ventas",
            "comment": "Relación Jerárquica Promotores y Supervisores",
        },
    )

    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 UUID de la empresa en core.identidad (RLS)",
    )

    promotor_id: Mapped[uuid.UUID] = mapped_column(
        UUID(as_uuid=True),
        nullable=False,
        comment="Promotor subordinado",
    )

    supervisor_id: Mapped[uuid.UUID] = mapped_column(
        UUID(as_uuid=True),
        nullable=False,
        comment="Promotor con rol de supervisor",
    )

    fecha_asignacion: Mapped[date] = mapped_column(
        Date,
        nullable=False,
        server_default=text("CURRENT_DATE"),
        comment="Fecha de inicio de supervisión",
    )

    fecha_desasignacion: Mapped[Optional[date]] = mapped_column(
        Date,
        nullable=True,
        comment="Fecha de finalización de supervisión",
    )

    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_promotores_supervisores

Revision ID: rel_0001
Revises: trx_0007
Create Date: 2026-09-10
"""

from typing import Sequence, Union

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


# revision identifiers, used by Alembic.
revision: str = "rel_0001"
down_revision: Union[str, Sequence[str], None] = "trx_0007"
branch_labels: Union[str, Sequence[str], None] = None
depends_on: Union[str, Sequence[str], None] = None


def upgrade() -> None:

    op.create_table(
        "rel_promotores_supervisores",

        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 UUID de la empresa en core.identidad (RLS)",
        ),

        sa.Column(
            "promotor_id",
            postgresql.UUID(as_uuid=True),
            nullable=False,
            comment="Promotor subordinado",
        ),

        sa.Column(
            "supervisor_id",
            postgresql.UUID(as_uuid=True),
            nullable=False,
            comment="Promotor con rol de supervisor",
        ),

        sa.Column(
            "fecha_asignacion",
            sa.Date(),
            nullable=False,
            server_default=sa.text("CURRENT_DATE"),
            comment="Fecha de inicio de supervisión",
        ),

        sa.Column(
            "fecha_desasignacion",
            sa.Date(),
            nullable=True,
            comment="Fecha de finalización de supervisión",
        ),

        # 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_promotores_supervisores",
        ),

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

        sa.UniqueConstraint(
            "empresa_id",
            "promotor_id",
            "supervisor_id",
            "fecha_asignacion",
            name="uq_rel_promotores_supervisores_asignacion",
        ),

        sa.CheckConstraint(
            "promotor_id <> supervisor_id",
            name="ck_rel_promotores_supervisores_distintos",
        ),

        sa.CheckConstraint(
            "fecha_desasignacion IS NULL OR fecha_desasignacion >= fecha_asignacion",
            name="ck_rel_promotores_supervisores_fechas",
        ),

        sa.ForeignKeyConstraint(
            ["empresa_id", "promotor_id"],
            ["fuerza_ventas.mae_promotores.empresa_id", "fuerza_ventas.mae_promotores.id"],
            ondelete="CASCADE",
            name="fk_rel_promotores_supervisores_promotor",
        ),

        sa.ForeignKeyConstraint(
            ["empresa_id", "supervisor_id"],
            ["fuerza_ventas.mae_promotores.empresa_id", "fuerza_ventas.mae_promotores.id"],
            name="fk_rel_promotores_supervisores_supervisor",
        ),

        comment="Relación Jerárquica Promotores y Supervisores",
        schema="fuerza_ventas",
    )

    op.create_index(
        "ix_rel_promotores_supervisores_empresa_activo",
        "rel_promotores_supervisores",
        ["empresa_id", "is_activo"],
        unique=False,
        schema="fuerza_ventas",
    )

    op.create_index(
        "ix_rel_promotores_supervisores_empresa_promotor",
        "rel_promotores_supervisores",
        ["empresa_id", "promotor_id"],
        unique=False,
        schema="fuerza_ventas",
    )

    op.create_index(
        "ix_rel_promotores_supervisores_empresa_supervisor",
        "rel_promotores_supervisores",
        ["empresa_id", "supervisor_id"],
        unique=False,
        schema="fuerza_ventas",
    )

    op.execute(
        """
        ALTER TABLE fuerza_ventas.rel_promotores_supervisores
        ENABLE ROW LEVEL SECURITY;
        """
    )

    op.execute(
        """
        CREATE POLICY rls_rel_promotores_supervisores_empresa
        ON fuerza_ventas.rel_promotores_supervisores
        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_promotores_supervisores_empresa
        ON fuerza_ventas.rel_promotores_supervisores;
        """
    )

    op.execute(
        """
        ALTER TABLE fuerza_ventas.rel_promotores_supervisores
        DISABLE ROW LEVEL SECURITY;
        """
    )

    op.drop_index(
        "ix_rel_promotores_supervisores_empresa_supervisor",
        table_name="rel_promotores_supervisores",
        schema="fuerza_ventas",
    )

    op.drop_index(
        "ix_rel_promotores_supervisores_empresa_promotor",
        table_name="rel_promotores_supervisores",
        schema="fuerza_ventas",
    )

    op.drop_index(
        "ix_rel_promotores_supervisores_empresa_activo",
        table_name="rel_promotores_supervisores",
        schema="fuerza_ventas",
    )

    op.drop_table(
        "rel_promotores_supervisores",
        schema="fuerza_ventas",
    )

Especificación Técnica: rel_promotores_supervisores¶

1. Justificación y Mejoras de Arquitectura¶

2. Definiciones de Implementación¶

Especificación Técnica: `rel_promotores_supervisores`¶