Control Tower for 3PL Operations

"text-slate-500">// src/app/actions/reception.ts
"text-purple-400">import { createServerClient } "text-purple-400">from '@supabase/ssr'
"text-purple-400">import { cookies } "text-purple-400">from 'next/headers'

"text-purple-400">export "text-purple-400">async "text-purple-400">function createReception(data: ReceptionData) {
  "text-purple-400">const cookieStore = cookies()
  "text-purple-400">const supabase = createServerClient(
    process.env.NEXT_PUBLIC_SUPABASE_URL!,
    process.env.NEXT_PUBLIC_SUPABASE_ANON_KEY!,
    { cookies: { get(name: string) { "text-purple-400">return cookieStore.get(name)?.value } } }
  )

  "text-slate-500">// 1. Verificar autenticación
  "text-purple-400">const { data: { user }, error: authError } = "text-purple-400">await supabase.auth.getUser()
  "text-purple-400">if (authError || !user) "text-purple-400">throw "text-purple-400">new Error('Unauthorized')

  "text-slate-500">// 2. Obtener empresa del perfil (nunca del cliente)
  "text-purple-400">const { data: profile } = "text-purple-400">await supabase
    ."text-purple-400">from('perfiles')
    .select('empresa_id')
    .eq('id', user.id)
    .single()

  "text-slate-500">// 3. Insertar con aislamiento multi-tenant garantizado por RLS
  "text-purple-400">const { data: newReception, error } = "text-purple-400">await supabase
    ."text-purple-400">from('tickets_recepcion')
    .insert([{
      ...data,
      estatus: 'RECIBIDO',
      creado_por: user.id,
      empresa_id: profile.empresa_id "text-slate-500">// Inferido del perfil, nunca del cliente
    }])
    .select()
    .single()

  "text-purple-400">if (error) "text-purple-400">throw "text-purple-400">new Error('Failed to create reception')
  "text-purple-400">return { success: true, data: newReception }
}

-- Trigger 1: Recalcula ítems recibidos en el PO
-- Se ejecuta en INSERT, UPDATE y DELETE sobre tickets_recepcion
CREATE OR REPLACE FUNCTION update_cantidad_recibidos()
RETURNS TRIGGER AS $$
BEGIN
  IF (TG_OP = 'INSERT' OR TG_OP = 'UPDATE') THEN
    UPDATE paquetes_cliente
    SET cantidad_items_recibidos = (
      SELECT COALESCE(SUM(items_parciales_recibidos), 0)
      FROM tickets_recepcion
      WHERE paquete_cliente_id = NEW.paquete_cliente_id
        AND estatus NOT IN ('CANCELADO')
    )
    WHERE id = NEW.paquete_cliente_id;
    RETURN NEW;
  END IF;

  IF (TG_OP = 'DELETE') THEN
    UPDATE paquetes_cliente
    SET cantidad_items_recibidos = (
      SELECT COALESCE(SUM(items_parciales_recibidos), 0)
      FROM tickets_recepcion
      WHERE paquete_cliente_id = OLD.paquete_cliente_id
        AND estatus NOT IN ('CANCELADO')
    )
    WHERE id = OLD.paquete_cliente_id;
    RETURN OLD;
  END IF;
END;
$$ LANGUAGE plpgsql;

-- Trigger 2: Sincronización automática del estado del PO
-- Cuando el PO está completo, marca todos sus tickets como LISTO_PARA_ENVIAR
CREATE OR REPLACE FUNCTION auto_sync_po_status()
RETURNS TRIGGER AS $$
BEGIN
  IF NEW.ref_cliente_po IS NOT NULL THEN
    PERFORM sync_po_status(NEW.ref_cliente_po, NEW.cliente_id);
  END IF;
  RETURN NEW;
END;
$$ LANGUAGE plpgsql;