From 895a831ff82ceb5c94029de2805735bcdec365db Mon Sep 17 00:00:00 2001 From: Consult AS Technology Date: Wed, 2 Sep 2026 02:13:13 +0000 Subject: [PATCH] feat(mi-dia): seccion 'Mis capturas de afluencia' en el panel del vendedor Nueva tabla LeadCaptura (quien capturo cada lead, algo que Monday no guarda porque el creador del item siempre es el token del API). El POST /api/leads la registra con el usuario del token y el resumen de Mi dia la enriquece con el estado/origen actual del lead en Monday. La captura rapida refresca el panel al registrar. --- .../20260902090000_lead_captura/migration.sql | 17 ++++ api-gateway/prisma/schema.prisma | 15 ++++ .../src/controllers/leads.controller.test.ts | 80 ++++++++++++++++++- .../src/controllers/leads.controller.ts | 20 +++++ .../src/controllers/mi-dia.controller.ts | 7 ++ .../src/services/mi-dia.service.test.ts | 65 ++++++++++++--- api-gateway/src/services/mi-dia.service.ts | 32 ++++++++ apps/mi-dia/src/lib/mi-dia.ts | 10 +++ apps/mi-dia/src/pages/MiDiaPage.tsx | 31 +++++++ 9 files changed, 266 insertions(+), 11 deletions(-) create mode 100644 api-gateway/prisma/migrations/20260902090000_lead_captura/migration.sql diff --git a/api-gateway/prisma/migrations/20260902090000_lead_captura/migration.sql b/api-gateway/prisma/migrations/20260902090000_lead_captura/migration.sql new file mode 100644 index 0000000..078f4f1 --- /dev/null +++ b/api-gateway/prisma/migrations/20260902090000_lead_captura/migration.sql @@ -0,0 +1,17 @@ +-- CreateTable +CREATE TABLE "LeadCaptura" ( + "id" TEXT NOT NULL PRIMARY KEY, + "leadId" TEXT NOT NULL, + "oportunidadId" TEXT, + "usuarioId" TEXT NOT NULL, + "nombreLead" TEXT NOT NULL, + "telefono" TEXT, + "createdAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP +); + +-- CreateIndex +CREATE UNIQUE INDEX "LeadCaptura_leadId_key" ON "LeadCaptura"("leadId"); + +-- CreateIndex +CREATE INDEX "LeadCaptura_usuarioId_idx" ON "LeadCaptura"("usuarioId"); + diff --git a/api-gateway/prisma/schema.prisma b/api-gateway/prisma/schema.prisma index 37460d2..6621f53 100644 --- a/api-gateway/prisma/schema.prisma +++ b/api-gateway/prisma/schema.prisma @@ -150,6 +150,21 @@ model LeadOportunidad { createdAt DateTime @default(now()) } +// Registro local de qué usuario del ecosistema capturó cada lead (alta de +// afluencia). Monday no guarda al capturista (el creador del item siempre es +// el token del API); esta tabla alimenta "Mis capturas" del panel Mi día. +model LeadCaptura { + id String @id @default(uuid()) + leadId String @unique // item del tablero Leads (Monday) + oportunidadId String? // item del tablero Oportunidades ligado al capturar + usuarioId String // Usuario.id del capturista + nombreLead String + telefono String? + createdAt DateTime @default(now()) + + @@index([usuarioId]) +} + // Estado persistente de las automatizaciones de Monday (round-robin, recordatorios). // Clave-valor genérico: 'rr:indice', 'rr:vendedores', 'recordatorio::', etc. model AutomatizacionState { diff --git a/api-gateway/src/controllers/leads.controller.test.ts b/api-gateway/src/controllers/leads.controller.test.ts index f91b8ac..b7c5b42 100644 --- a/api-gateway/src/controllers/leads.controller.test.ts +++ b/api-gateway/src/controllers/leads.controller.test.ts @@ -1,13 +1,26 @@ -import { describe, expect, it, vi } from 'vitest' +import { beforeEach, describe, expect, it, vi } from 'vitest' +import type { Request, Response } from 'express' import { buscarLeads, buscarLeadsEndpoint, cambiarEstadoLead, crearLead, + crearLeadEndpoint, descartarLead, ESTADOS_LEAD_PERMITIDOS, } from './leads.controller.js' -import type { LeadMonday } from '../services/monday.service.js' +import { mondayService, type LeadMonday } from '../services/monday.service.js' +import { funnelService } from '../services/funnel.service.js' + +// ---------- Prisma mockeado (los tests no tocan la BD) ---------- + +const prismaMock = vi.hoisted(() => ({ + leadCaptura: { + create: vi.fn(), + }, +})) + +vi.mock('../services/prisma.js', () => ({ prisma: prismaMock })) /** Monday mockeado: registra escrituras y devuelve catálogos controlados */ function mondayMock( @@ -306,6 +319,69 @@ describe('descartarLead (POST /api/leads/:itemId/descartar)', () => { }) }) +describe('crearLeadEndpoint (POST /api/leads)', () => { + beforeEach(() => { + vi.clearAllMocks() + // El singleton Monday responde como si creara el lead; el funnel liga la oportunidad + vi.spyOn(mondayService, 'buscarLeadPorTelefono').mockResolvedValue(null) + vi.spyOn(mondayService, 'crearLead').mockResolvedValue('lead-nuevo-9') + vi.spyOn(funnelService, 'asegurarOportunidadAfluencia').mockResolvedValue('op-9') + }) + + function reqFake(overrides: Partial = {}): Request { + return { + body: { nombre: 'Lead Prueba', telefono: '4771234567' }, + usuarioToken: { sub: 'u-1', username: 'asesor uno', rol: 'vendedor' }, + ...overrides, + } as Request + } + + function resFake() { + const json = vi.fn() + const status = vi.fn().mockReturnValue({ json }) + return { res: { json, status } as unknown as Response, status, json } + } + + it('201: registra la captura local con el usuario del token', async () => { + prismaMock.leadCaptura.create.mockResolvedValue({}) + const { res, status, json } = resFake() + + await crearLeadEndpoint(reqFake(), res) + + expect(prismaMock.leadCaptura.create).toHaveBeenCalledWith({ + data: { + leadId: 'lead-nuevo-9', + oportunidadId: 'op-9', + usuarioId: 'u-1', + nombreLead: 'Lead Prueba', + telefono: '4771234567', + }, + }) + expect(status).toHaveBeenCalledWith(201) + expect(json).toHaveBeenCalledWith({ id: 'lead-nuevo-9', estado: 'NUEVO', oportunidadId: 'op-9' }) + }) + + it('sin token (AUTH_ENABLED=false) no registra captura y responde 201 igual', async () => { + const { res, status } = resFake() + + await crearLeadEndpoint(reqFake({ usuarioToken: undefined }), res) + + expect(prismaMock.leadCaptura.create).not.toHaveBeenCalled() + expect(status).toHaveBeenCalledWith(201) + }) + + it('un fallo del registro local no rompe la respuesta (el lead ya quedó en Monday)', async () => { + prismaMock.leadCaptura.create.mockRejectedValue(new Error('SQLite bloqueado')) + const espia = vi.spyOn(console, 'error').mockImplementation(() => {}) + const { res, status } = resFake() + + await crearLeadEndpoint(reqFake(), res) + + expect(status).toHaveBeenCalledWith(201) + espia.mockRestore() + }) +}) + describe('buscarLeads (GET /api/leads/buscar)', () => { const lead = (overrides: Partial): LeadMonday => ({ id: 'lead-1', diff --git a/api-gateway/src/controllers/leads.controller.ts b/api-gateway/src/controllers/leads.controller.ts index c4ff9f6..4af197b 100644 --- a/api-gateway/src/controllers/leads.controller.ts +++ b/api-gateway/src/controllers/leads.controller.ts @@ -3,6 +3,7 @@ import { z } from 'zod' import { config } from '../config/index.js' import { mondayService, type LeadMonday, type MondayService } from '../services/monday.service.js' import { funnelService, type FunnelService } from '../services/funnel.service.js' +import { prisma } from '../services/prisma.js' import { MOTIVOS_NO_COMPRA } from './oportunidades.controller.js' import { AppError } from '../utils/errors.js' @@ -236,6 +237,25 @@ export async function crearLeadEndpoint(req: Request, res: Response): Promise m.mondayUserId !== null).map((m) => [m.mondayUserId!, m.nombre]), ) + // Capturas de afluencia registradas por el usuario (registro local) + const capturas = await prisma.leadCaptura.findMany({ + where: { usuarioId: usuario.id }, + orderBy: { createdAt: 'desc' }, + }) + res.json( await resumenMiDia( mondayService, { nombre: usuario.nombre, rol: usuario.rol, mondayUserId: usuario.mondayUserId }, nombresPorMondayId, + capturas, ), ) } diff --git a/api-gateway/src/services/mi-dia.service.test.ts b/api-gateway/src/services/mi-dia.service.test.ts index 6f24bc6..182522e 100644 --- a/api-gateway/src/services/mi-dia.service.test.ts +++ b/api-gateway/src/services/mi-dia.service.test.ts @@ -83,7 +83,7 @@ describe('resumenMiDia (GET /api/mi-dia/resumen)', () => { lead({ id: '6', estado: 'NUEVO', vendedorIds: [OTRO_ID] }), ], }) - const r = await resumenMiDia(monday, vendedor, new Map(), AHORA) + const r = await resumenMiDia(monday, vendedor, new Map(), [], AHORA) expect(r.sinMapeoMonday).toBe(false) expect(r.misLeads.map((l) => l.id)).toEqual(['1', '2']) expect(r.misLeads[1]?.telefono).toBe('4771234567') @@ -101,7 +101,7 @@ describe('resumenMiDia (GET /api/mi-dia/resumen)', () => { actividad({ id: 'a7', fecha: '' }), // sin fecha: no ], }) - const r = await resumenMiDia(monday, vendedor, new Map(), AHORA) + const r = await resumenMiDia(monday, vendedor, new Map(), [], AHORA) // Ordenadas por fecha: vencida primero expect(r.misActividadesHoy.map((a) => a.id)).toEqual(['a3', 'a1', 'a2']) expect(r.conteos.actividadesAbiertas).toBe(5) // abiertas mías: a1,a2,a3,a4,a7 @@ -118,7 +118,7 @@ describe('resumenMiDia (GET /api/mi-dia/resumen)', () => { apartado({ id: 'p6', fechaLimite: '2026-09-01', estado: 'Cancelacion' }), ], }) - const r = await resumenMiDia(monday, vendedor, new Map(), AHORA) + const r = await resumenMiDia(monday, vendedor, new Map(), [], AHORA) expect(r.apartadosPorVencer.map((a) => a.id)).toEqual(['p1', 'p2']) expect(r.apartadosPorVencer[0]?.diasRestantes).toBe(0) expect(r.apartadosPorVencer[1]?.diasRestantes).toBe(7) @@ -130,7 +130,7 @@ describe('resumenMiDia (GET /api/mi-dia/resumen)', () => { actividades: [actividad({ id: 'a1' })], apartados: [apartado({ id: 'p1' })], }) - const r = await resumenMiDia(monday, sinMapeo, new Map(), AHORA) + const r = await resumenMiDia(monday, sinMapeo, new Map(), [], AHORA) expect(r.sinMapeoMonday).toBe(true) expect(r.misLeads).toEqual([]) expect(r.misActividadesHoy).toEqual([]) @@ -148,12 +148,12 @@ describe('resumenMiDia (GET /api/mi-dia/resumen)', () => { lead({ id: '4', createdAt: '2026-08-27T08:00:00', vendedorIds: [OTRO_ID] }), // de otro ], }) - const r = await resumenMiDia(monday, vendedor, new Map(), AHORA) + const r = await resumenMiDia(monday, vendedor, new Map(), [], AHORA) expect(r.conteos.leadsNuevosSemana).toBe(2) }) it('oportunidades se omiten con nota (el board no tiene columna de asesor)', async () => { - const r = await resumenMiDia(mondayMock({}), vendedor, new Map(), AHORA) + const r = await resumenMiDia(mondayMock({}), vendedor, new Map(), [], AHORA) expect(r.misOportunidades).toBeNull() expect(r.notaOportunidades).toContain('asesor') }) @@ -171,10 +171,10 @@ describe('resumenMiDia (GET /api/mi-dia/resumen)', () => { }) const nombres = new Map([[MI_ID, 'Martin Zavala']]) - const rVendedor = await resumenMiDia(monday, vendedor, nombres, AHORA) + const rVendedor = await resumenMiDia(monday, vendedor, nombres, [], AHORA) expect(rVendedor.equipo).toBeUndefined() - const rCoord = await resumenMiDia(monday, coordinador, nombres, AHORA) + const rCoord = await resumenMiDia(monday, coordinador, nombres, [], AHORA) expect(rCoord.equipo?.leadsNuevosSinAsignar).toBe(1) expect(rCoord.equipo?.porVendedor).toEqual([ { mondayUserId: OTRO_ID, nombre: null, leadsAsignados: 2, leadsNuevosSemana: 1 }, @@ -185,10 +185,57 @@ describe('resumenMiDia (GET /api/mi-dia/resumen)', () => { it('corporativo y admin también ven equipo', async () => { const monday = mondayMock({ leads: [lead({ id: '1' })] }) for (const rol of ['corporativo', 'admin']) { - const r = await resumenMiDia(monday, { nombre: 'X', rol, mondayUserId: null }, new Map(), AHORA) + const r = await resumenMiDia(monday, { nombre: 'X', rol, mondayUserId: null }, new Map(), [], AHORA) expect(r.equipo).toBeDefined() } }) + + it('mis capturas: enriquecidas con el estado/origen actual del lead en Monday', async () => { + const monday = mondayMock({ + leads: [lead({ id: '100', nombre: 'Ana López', estado: 'CONTACTADO', origen: 'WhatsApp', vendedorIds: [OTRO_ID] })], + }) + const capturas = [ + { leadId: '100', nombreLead: 'Ana López', telefono: '6641112233', createdAt: new Date('2026-08-27T09:00:00Z') }, + ] + const r = await resumenMiDia(monday, vendedor, new Map(), capturas, AHORA) + // Aunque el lead quedó asignado a OTRO por round-robin, la captura es mía + expect(r.misCapturas).toEqual([ + { + leadId: '100', + nombre: 'Ana López', + telefono: '6641112233', + estado: 'CONTACTADO', + origen: 'WhatsApp', + capturadoEn: '2026-08-27T09:00:00.000Z', + }, + ]) + }) + + it('mis capturas: si el lead ya no existe en Monday, estado y origen van vacíos', async () => { + const monday = mondayMock({}) + const capturas = [ + { leadId: 'borrado-1', nombreLead: 'Lead Borrado', telefono: null, createdAt: new Date('2026-08-26T09:00:00Z') }, + ] + const r = await resumenMiDia(monday, vendedor, new Map(), capturas, AHORA) + expect(r.misCapturas).toEqual([ + { leadId: 'borrado-1', nombre: 'Lead Borrado', telefono: '', estado: '', origen: '', capturadoEn: '2026-08-26T09:00:00.000Z' }, + ]) + }) + + it('mis capturas: ordenadas por fecha de captura descendente', async () => { + const monday = mondayMock({}) + const capturas = [ + { leadId: '1', nombreLead: 'Antiguo', telefono: null, createdAt: new Date('2026-08-20T09:00:00Z') }, + { leadId: '2', nombreLead: 'Reciente', telefono: null, createdAt: new Date('2026-08-27T09:00:00Z') }, + ] + const r = await resumenMiDia(monday, vendedor, new Map(), capturas, AHORA) + expect(r.misCapturas.map((c) => c.leadId)).toEqual(['2', '1']) + }) + + it('sin capturas: misCapturas va vacío', async () => { + const r = await resumenMiDia(mondayMock({}), vendedor, new Map(), [], AHORA) + expect(r.misCapturas).toEqual([]) + }) }) describe('clasificadores de estado', () => { diff --git a/api-gateway/src/services/mi-dia.service.ts b/api-gateway/src/services/mi-dia.service.ts index cdc0af3..05794cd 100644 --- a/api-gateway/src/services/mi-dia.service.ts +++ b/api-gateway/src/services/mi-dia.service.ts @@ -5,6 +5,8 @@ import type { MondayService } from './monday.service.js' * Todo se filtra por su mondayUserId (columna people de cada tablero); si el * usuario aún no tiene cuenta Monday (mondayUserId null), las listas personales * van vacías con sinMapeoMonday: true (las acciones del CRM siguen funcionando). + * "Mis capturas" viene del registro local (tabla LeadCaptura), no de Monday: + * es la lista de leads que el usuario dio de alta, con su estado actual. */ // Estados del board Leads en los que el lead ya no es trabajo activo del vendedor @@ -48,10 +50,20 @@ export interface ApartadoPorVencer { diasRestantes: number } +export interface CapturaMiDia { + leadId: string + nombre: string + telefono: string + estado: string // estado ACTUAL en Monday; '' si el lead ya no existe en el board + origen: string + capturadoEn: string // ISO +} + export interface ResumenMiDia { generadoEn: string sinMapeoMonday: boolean misLeads: LeadMiDia[] + misCapturas: CapturaMiDia[] misActividadesHoy: ActividadMiDia[] apartadosPorVencer: ApartadoPorVencer[] // null = el tablero Oportunidades no tiene columna people de asesor (hoy no existe) @@ -100,6 +112,8 @@ export async function resumenMiDia( usuario: UsuarioMiDia, /** mondayUserId -> nombre para mostrar (usuarios del ecosistema ya mapeados) */ nombresPorMondayId: Map, + /** Capturas locales del usuario (tabla LeadCaptura), ya filtradas por él */ + capturas: { leadId: string; nombreLead: string; telefono: string | null; createdAt: Date }[] = [], ahora: Date = new Date(), ): Promise { const miId = usuario.mondayUserId @@ -130,6 +144,23 @@ export async function resumenMiDia( updatedAt: l.updatedAt, })) + // "Mis capturas" se enriquece con el estado/origen ACTUAL del lead en Monday + // (si ya no existe en el board, estado y origen van ''), más reciente primero + const leadsPorId = new Map(leads.map((l) => [l.id, l])) + const misCapturas: CapturaMiDia[] = capturas + .map((c) => { + const lead = leadsPorId.get(c.leadId) + return { + leadId: c.leadId, + nombre: c.nombreLead, + telefono: c.telefono ?? '', + estado: lead?.estado ?? '', + origen: lead?.origen ?? '', + capturadoEn: c.createdAt.toISOString(), + } + }) + .sort((a, b) => b.capturadoEn.localeCompare(a.capturadoEn)) + const misActividades = sinMapeo ? [] : actividades.filter((a) => a.responsableIds.includes(miId)) const misActividadesHoy: ActividadMiDia[] = misActividades .filter((a) => a.estado.trim().toUpperCase() === 'ABIERTO' && a.fecha !== '' && a.fecha <= manana) @@ -164,6 +195,7 @@ export async function resumenMiDia( generadoEn: ahora.toISOString(), sinMapeoMonday: sinMapeo, misLeads, + misCapturas, misActividadesHoy, apartadosPorVencer, // El tablero Oportunidades no tiene columna people de asesor: no se puede diff --git a/apps/mi-dia/src/lib/mi-dia.ts b/apps/mi-dia/src/lib/mi-dia.ts index 722abb8..7fd775e 100644 --- a/apps/mi-dia/src/lib/mi-dia.ts +++ b/apps/mi-dia/src/lib/mi-dia.ts @@ -27,10 +27,20 @@ export interface ApartadoPorVencer { diasRestantes: number } +export interface CapturaMiDia { + leadId: string + nombre: string + telefono: string + estado: string // estado actual en Monday; '' si el lead ya no existe en el board + origen: string + capturadoEn: string // ISO +} + export interface ResumenMiDia { generadoEn: string sinMapeoMonday: boolean misLeads: LeadMiDia[] + misCapturas: CapturaMiDia[] misActividadesHoy: ActividadMiDia[] apartadosPorVencer: ApartadoPorVencer[] misOportunidades: { porEtapa: Record } | null diff --git a/apps/mi-dia/src/pages/MiDiaPage.tsx b/apps/mi-dia/src/pages/MiDiaPage.tsx index 4e78e1e..60653c6 100644 --- a/apps/mi-dia/src/pages/MiDiaPage.tsx +++ b/apps/mi-dia/src/pages/MiDiaPage.tsx @@ -243,6 +243,8 @@ export default function MiDiaPage() { setCapEmail('') setCapDesarrollo('') setCapNotas('') + // Refresca el resumen para que la captura aparezca al momento en "Mis capturas" + await cargar() } catch (err) { setCapMensaje({ tipo: 'error', texto: err instanceof Error ? err.message : 'No se pudo registrar el lead' }) } finally { @@ -367,6 +369,35 @@ export default function MiDiaPage() { )} +
+ Mis capturas de afluencia + {resumen.misCapturas.length === 0 ? ( + + ) : ( +
    + {resumen.misCapturas.map((c) => ( +
  • +
    +

    {c.nombre}

    +

    + {c.telefono || 'Sin teléfono'} + {c.origen ? ` · ${c.origen}` : ''} +

    +
    +
    + + {c.estado || '—'} + + + {formatoFechaCorta(c.capturadoEn.slice(0, 10))} + +
    +
    • + ))} +
+ )} +
+
Captura rápida de lead