Saltar a contenido

Especificación Técnica: mae_equipos_consignacion

Esquema: fuerza_ventas
Base de Datos: crm
Tabla Legacy Origen: c221t / c222t (equipos en consignación)
Propósito: Control y trazabilidad de activos de la empresa entregados a clientes en calidad de comodato o consignación (neveras, dispensadores, exhibidores POP, racks, balanzas).

1. Justificación y Mejoras de Arquitectura

  • Seguimiento Físico y Comercial de Activos: Asocia el activo fijo al cliente receptor, local físico específico y promotor comercial custodio.
  • Aislamiento Multi-Tenant (RLS): Integra empresa_id BIGINT NOT NULL con políticas RLS obligatorias.
  • Integridad Referencial Compuesta: Claves foráneas compuestas hacia clientes.mae_clientes, clientes.mae_locales_cliente y fuerza_ventas.mae_promotores.
  • 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

Table fuerza_ventas.mae_equipos_consignacion {
    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 custodio']
    local_id                    uuid          [note: 'Local o sucursal donde se ubica el activo']
    promotor_id                 uuid          [not null, note: 'Promotor custodio comercial']
    codigo_activo               varchar(50)   [not null, note: 'Código interno de placa o activo fijo']
    serial_fabricante           varchar(100)  [not null, note: 'Número de serie único de fabricante']
    tipo_equipo_id              uuid          [not null, note: 'Tipo de equipo (FK cat_tipos_equipo)']
    marca_modelo                varchar(150)  [not null, note: 'Marca y modelo del equipo']
    valor_comercial             numeric(12,2) [not null, default: `0.00`, note: 'Valorización contable/comercial']
    fecha_entrega               date          [not null, note: 'Fecha de entrega en comodato']
    estado_equipo_id             uuid          [not null, note: 'Estado del equipo (FK cat_estados_equipo)']
    numero_contrato_comodato    varchar(50)   [note: 'Número de contrato legal firmado']
    foto_comodato_url           varchar(500)  [note: 'URL de evidencia fotográfica en Object Storage']

    // 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_mae_equipos_consignacion_empresa_id']
        (empresa_id, serial_fabricante) [unique, name: 'uq_mae_equipos_consignacion_empresa_serial']
        (empresa_id, is_activo) [name: 'ix_mae_equipos_consignacion_empresa_activo']
        (empresa_id, cliente_id) [name: 'ix_mae_equipos_consignacion_empresa_cliente']
        (empresa_id, promotor_id) [name: 'ix_mae_equipos_consignacion_empresa_promotor']
        (empresa_id, local_id) [name: 'ix_mae_equipos_consignacion_empresa_local']
    }
}

Ref: fuerza_ventas.mae_equipos_consignacion.(empresa_id, cliente_id) > clientes.mae_clientes.(empresa_id, id)
Ref: fuerza_ventas.mae_equipos_consignacion.(empresa_id, local_id) > clientes.mae_locales_cliente.(empresa_id, id)
Ref: fuerza_ventas.mae_equipos_consignacion.(empresa_id, promotor_id) > fuerza_ventas.mae_promotores.(empresa_id, id)
Ref: fuerza_ventas.mae_equipos_consignacion.(empresa_id, tipo_equipo_id) > fuerza_ventas.cat_tipos_equipo.(empresa_id, id)
Ref: fuerza_ventas.mae_equipos_consignacion.(empresa_id, estado_equipo_id) > fuerza_ventas.cat_estados_equipo.(empresa_id, id)

CREATE TABLE IF NOT EXISTS fuerza_ventas.mae_equipos_consignacion (
    id UUID NOT NULL DEFAULT gen_random_uuid(),
    empresa_id BIGINT NOT NULL,
    cliente_id UUID NOT NULL,
    local_id UUID,
    promotor_id UUID NOT NULL,
    codigo_activo VARCHAR(50) NOT NULL,
    serial_fabricante VARCHAR(100) NOT NULL,
    tipo_equipo_id UUID NOT NULL,
    marca_modelo VARCHAR(150) NOT NULL,
    valor_comercial NUMERIC(12,2) NOT NULL DEFAULT 0.00,
    fecha_entrega DATE NOT NULL,
    estado_equipo_id UUID NOT NULL,
    numero_contrato_comodato VARCHAR(50),
    foto_comodato_url VARCHAR(500),

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

    CONSTRAINT uq_mae_equipos_consignacion_empresa_id
        UNIQUE (empresa_id, id),

    CONSTRAINT uq_mae_equipos_consignacion_empresa_serial
        UNIQUE (empresa_id, serial_fabricante),

    CONSTRAINT fk_mae_equipos_consignacion_cliente
        FOREIGN KEY (empresa_id, cliente_id)
        REFERENCES clientes.mae_clientes (empresa_id, id),

    CONSTRAINT fk_mae_equipos_consignacion_local
        FOREIGN KEY (empresa_id, local_id)
        REFERENCES clientes.mae_locales_cliente (empresa_id, id),

    CONSTRAINT fk_mae_equipos_consignacion_promotor
        FOREIGN KEY (empresa_id, promotor_id)
        REFERENCES fuerza_ventas.mae_promotores (empresa_id, id)
);

CREATE INDEX IF NOT EXISTS ix_mae_equipos_consignacion_empresa_activo
    ON fuerza_ventas.mae_equipos_consignacion (empresa_id, is_activo);

CREATE INDEX IF NOT EXISTS ix_mae_equipos_consignacion_empresa_cliente
    ON fuerza_ventas.mae_equipos_consignacion (empresa_id, cliente_id);

CREATE INDEX IF NOT EXISTS ix_mae_equipos_consignacion_empresa_promotor
    ON fuerza_ventas.mae_equipos_consignacion (empresa_id, promotor_id);

CREATE INDEX IF NOT EXISTS ix_mae_equipos_consignacion_empresa_local
    ON fuerza_ventas.mae_equipos_consignacion (empresa_id, local_id);

COMMENT ON TABLE fuerza_ventas.mae_equipos_consignacion IS
    'Equipos y Activos en Consignación / Comodato: Control de activos de la empresa entregados a clientes en calidad de comodato o consignación.';

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

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

COMMENT ON COLUMN fuerza_ventas.mae_equipos_consignacion.cliente_id IS
    'Cliente custodio';

COMMENT ON COLUMN fuerza_ventas.mae_equipos_consignacion.local_id IS
    'Local o sucursal donde se ubica el activo';

COMMENT ON COLUMN fuerza_ventas.mae_equipos_consignacion.promotor_id IS
    'Promotor custodio comercial';

COMMENT ON COLUMN fuerza_ventas.mae_equipos_consignacion.codigo_activo IS
    'Código interno de placa o activo fijo';

COMMENT ON COLUMN fuerza_ventas.mae_equipos_consignacion.serial_fabricante IS
    'Número de serie único de fabricante';

COMMENT ON COLUMN fuerza_ventas.mae_equipos_consignacion.tipo_equipo_id IS
    'Tipo de equipo o activo (FK cat_tipos_equipo)';

COMMENT ON COLUMN fuerza_ventas.mae_equipos_consignacion.marca_modelo IS
    'Marca y modelo del equipo';

COMMENT ON COLUMN fuerza_ventas.mae_equipos_consignacion.valor_comercial IS
    'Valorización contable/comercial';

COMMENT ON COLUMN fuerza_ventas.mae_equipos_consignacion.fecha_entrega IS
    'Fecha de entrega en comodato';

COMMENT ON COLUMN fuerza_ventas.mae_equipos_consignacion.estado_equipo_id IS
    'Estado de condición del equipo (FK cat_estados_equipo)';

COMMENT ON COLUMN fuerza_ventas.mae_equipos_consignacion.numero_contrato_comodato IS
    'Número de contrato legal firmado';

COMMENT ON COLUMN fuerza_ventas.mae_equipos_consignacion.foto_comodato_url IS
    'URL de evidencia fotográfica en Object Storage';

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

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

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

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

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

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

ALTER TABLE fuerza_ventas.mae_equipos_consignacion
    ENABLE ROW LEVEL SECURITY;

CREATE POLICY rls_mae_equipos_consignacion_empresa
    ON fuerza_ventas.mae_equipos_consignacion
    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 decimal import Decimal
from typing import Optional

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

from app.db.base import Base


class MaeEquiposConsignacion(Base):
    """
    Equipos y Activos en Consignación / Comodato.

    Control de activos de la empresa entregados a clientes en calidad de
    comodato o consignación (neveras, dispensadores, exhibidores POP, racks).

    Legacy:
        c221t / c222t
    """

    __tablename__ = "mae_equipos_consignacion"

    __table_args__ = (
        UniqueConstraint(
            "empresa_id",
            "id",
            name="uq_mae_equipos_consignacion_empresa_id",
        ),
        UniqueConstraint(
            "empresa_id",
            "serial_fabricante",
            name="uq_mae_equipos_consignacion_empresa_serial",
        ),
        ForeignKeyConstraint(
            ["empresa_id", "cliente_id"],
            ["clientes.mae_clientes.empresa_id", "clientes.mae_clientes.id"],
            name="fk_mae_equipos_consignacion_cliente",
        ),
        ForeignKeyConstraint(
            ["empresa_id", "local_id"],
            ["clientes.mae_locales_cliente.empresa_id", "clientes.mae_locales_cliente.id"],
            name="fk_mae_equipos_consignacion_local",
        ),
        ForeignKeyConstraint(
            ["empresa_id", "tipo_equipo_id"],
            ["fuerza_ventas.cat_tipos_equipo.empresa_id", "fuerza_ventas.cat_tipos_equipo.id"],
            name="fk_mae_equipos_consignacion_tipo_equipo",
        ),
        ForeignKeyConstraint(
            ["empresa_id", "estado_equipo_id"],
            ["fuerza_ventas.cat_estados_equipo.empresa_id", "fuerza_ventas.cat_estados_equipo.id"],
            name="fk_mae_equipos_consignacion_estado_equipo",
        ),
        ForeignKeyConstraint(
            ["empresa_id", "promotor_id"],
            ["fuerza_ventas.mae_promotores.empresa_id", "fuerza_ventas.mae_promotores.id"],
            name="fk_mae_equipos_consignacion_promotor",
        ),
        Index(
            "ix_mae_equipos_consignacion_empresa_activo",
            "empresa_id",
            "is_activo",
        ),
        Index(
            "ix_mae_equipos_consignacion_empresa_cliente",
            "empresa_id",
            "cliente_id",
        ),
        Index(
            "ix_mae_equipos_consignacion_empresa_promotor",
            "empresa_id",
            "promotor_id",
        ),
        Index(
            "ix_mae_equipos_consignacion_empresa_local",
            "empresa_id",
            "local_id",
        ),
        {
            "schema": "fuerza_ventas",
            "comment": "Equipos y Activos en Consignación / Comodato",
        },
    )

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

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

    local_id: Mapped[Optional[uuid.UUID]] = mapped_column(
        UUID(as_uuid=True),
        nullable=True,
        comment="Local o sucursal donde se ubica el activo",
    )

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

    codigo_activo: Mapped[str] = mapped_column(
        String(50),
        nullable=False,
        comment="Código interno de placa o activo fijo",
    )

    serial_fabricante: Mapped[str] = mapped_column(
        String(100),
        nullable=False,
        comment="Número de serie único de fabricante",
    )

    tipo_equipo_id: Mapped[uuid.UUID] = mapped_column(
        UUID(as_uuid=True),
        nullable=False,
        comment="Tipo de equipo (FK cat_tipos_equipo)",
    )

    marca_modelo: Mapped[str] = mapped_column(
        String(150),
        nullable=False,
        comment="Marca y modelo del equipo",
    )

    valor_comercial: Mapped[Decimal] = mapped_column(
        Numeric(12, 2),
        nullable=False,
        server_default=text("0.00"),
        comment="Valorización contable/comercial",
    )

    fecha_entrega: Mapped[date] = mapped_column(
        Date,
        nullable=False,
        comment="Fecha de entrega en comodato",
    )

    estado_equipo_id: Mapped[uuid.UUID] = mapped_column(
        UUID(as_uuid=True),
        nullable=False,
        comment="Estado del equipo (FK cat_estados_equipo)",
    )

    numero_contrato_comodato: Mapped[Optional[str]] = mapped_column(
        String(50),
        nullable=True,
        comment="Número de contrato legal firmado",
    )

    foto_comodato_url: Mapped[Optional[str]] = mapped_column(
        String(500),
        nullable=True,
        comment="URL de evidencia fotográfica en Object Storage",
    )

    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 mae_equipos_consignacion

Revision ID: mae_0005
Revises: mae_0004
Create Date: 2026-09-09
"""

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 = "mae_0005"
down_revision: Union[str, Sequence[str], None] = "mae_0004"
branch_labels: Union[str, Sequence[str], None] = None
depends_on: Union[str, Sequence[str], None] = None


def upgrade() -> None:

    op.create_table(
        "mae_equipos_consignacion",

        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(
            "cliente_id",
            postgresql.UUID(as_uuid=True),
            nullable=False,
            comment="Cliente custodio",
        ),

        sa.Column(
            "local_id",
            postgresql.UUID(as_uuid=True),
            nullable=True,
            comment="Local o sucursal donde se ubica el activo",
        ),

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

        sa.Column(
            "codigo_activo",
            sa.String(length=50),
            nullable=False,
            comment="Código interno de placa o activo fijo",
        ),

        sa.Column(
            "serial_fabricante",
            sa.String(length=100),
            nullable=False,
            comment="Número de serie único de fabricante",
        ),

        sa.Column(
            "tipo_equipo_id",
            postgresql.UUID(as_uuid=True),
            nullable=False,
            comment="Tipo de equipo (FK cat_tipos_equipo)",
        ),

        sa.Column(
            "marca_modelo",
            sa.String(length=150),
            nullable=False,
            comment="Marca y modelo del equipo",
        ),

        sa.Column(
            "valor_comercial",
            sa.Numeric(precision=12, scale=2),
            nullable=False,
            server_default=sa.text("0.00"),
            comment="Valorización contable/comercial",
        ),

        sa.Column(
            "fecha_entrega",
            sa.Date(),
            nullable=False,
            comment="Fecha de entrega en comodato",
        ),

        sa.Column(
            "estado_equipo_id",
            postgresql.UUID(as_uuid=True),
            nullable=False,
            comment="Estado del equipo (FK cat_estados_equipo)",
        ),

        sa.Column(
            "numero_contrato_comodato",
            sa.String(length=50),
            nullable=True,
            comment="Número de contrato legal firmado",
        ),

        sa.Column(
            "foto_comodato_url",
            sa.String(length=500),
            nullable=True,
            comment="URL de evidencia fotográfica en Object Storage",
        ),

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

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

        sa.UniqueConstraint(
            "empresa_id",
            "serial_fabricante",
            name="uq_mae_equipos_consignacion_empresa_serial",
        ),

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

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

        comment="Equipos y Activos en Consignación / Comodato",
        schema="fuerza_ventas",
    )

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

    op.create_index(
        "ix_mae_equipos_consignacion_empresa_cliente",
        "mae_equipos_consignacion",
        ["empresa_id", "cliente_id"],
        unique=False,
        schema="fuerza_ventas",
    )

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

    op.create_index(
        "ix_mae_equipos_consignacion_empresa_local",
        "mae_equipos_consignacion",
        ["empresa_id", "local_id"],
        unique=False,
        schema="fuerza_ventas",
    )

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

    op.execute(
        """
        CREATE POLICY rls_mae_equipos_consignacion_empresa
        ON fuerza_ventas.mae_equipos_consignacion
        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_mae_equipos_consignacion_empresa
        ON fuerza_ventas.mae_equipos_consignacion;
        """
    )

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

    op.drop_index(
        "ix_mae_equipos_consignacion_empresa_local",
        table_name="mae_equipos_consignacion",
        schema="fuerza_ventas",
    )

    op.drop_index(
        "ix_mae_equipos_consignacion_empresa_promotor",
        table_name="mae_equipos_consignacion",
        schema="fuerza_ventas",
    )

    op.drop_index(
        "ix_mae_equipos_consignacion_empresa_cliente",
        table_name="mae_equipos_consignacion",
        schema="fuerza_ventas",
    )

    op.drop_index(
        "ix_mae_equipos_consignacion_empresa_activo",
        table_name="mae_equipos_consignacion",
        schema="fuerza_ventas",
    )

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