feat(sat): agregar cron de recuperación diaria a las 10:00 AM

- Revisa si el sync diario falló o si hay CFDIs vigentes sin xml_original. - Si detecta facturas incompletas, lanza un sync initial con rango extendido (desde un mes antes de la factura incompleta más antigua hasta ayer). - Corre secuencialmente por contribuyente para no saturar al SAT. - Incluye soporte para tenants legacy sin contribuyentes.
feat(dashboard): utilidad neta ajustada por notas de crédito
2026-06-14 04:07:11 +00:00 · 2026-06-13 21:04:25 +00:00 · 2026-06-13 20:54:40 +00:00 · 2026-06-13 20:46:57 +00:00 · 2026-06-13 20:16:04 +00:00 · 2026-06-13 19:55:06 +00:00
21 changed files with 672 additions and 129 deletions
--- a/apps/api/src/config/database.ts
+++ b/apps/api/src/config/database.ts
@@ -187,11 +187,13 @@ class TenantConnectionManager {
  }

  /**
-   * Remove idle pools (not accessed in last 5 minutes).
+   * Remove idle pools (not accessed in last 12 hours).
+   * SAT syncs (initial/daily) can run for hours in background;
+   * a 5-minute timeout caused 'pool already ended' errors mid-sync.
   */
  private cleanupIdlePools(): void {
    const now = Date.now();
-    const maxIdle = 5 * 60 * 1000;
+    const maxIdle = 12 * 60 * 60 * 1000;

    for (const [tenantId, entry] of this.pools.entries()) {
      if (now - entry.lastAccess.getTime() > maxIdle) {
--- a/apps/api/src/controllers/alertas.controller.ts
+++ b/apps/api/src/controllers/alertas.controller.ts
@@ -125,7 +125,9 @@ export async function resolverAlertaManual(req: Request, res: Response, next: Ne
 export async function getAlertasAutomaticas(req: Request, res: Response, next: NextFunction) {
  try {
    const contribuyenteId = req.query.contribuyenteId as string | undefined;
+    console.log(`[AlertasCtrl] GET /automaticas tenant=${req.user!.tenantId} contribuyente=${contribuyenteId || 'null'} user=${req.user!.userId} role=${req.user!.role}`);
    const alertas = await generarAlertasAutomaticas(req.tenantPool!, req.user!.tenantId, contribuyenteId || null);
+    console.log(`[AlertasCtrl] GET /automaticas devuelve ${alertas.length} alertas: ${alertas.map(a => a.id).join(', ') || 'ninguna'}`);
    res.json(alertas);
  } catch (error) {
    next(error);
--- a/apps/api/src/controllers/contribuyente.controller.ts
+++ b/apps/api/src/controllers/contribuyente.controller.ts
@@ -170,6 +170,15 @@ export async function addClienteAcceso(req: Request, res: Response, next: NextFu
    const { userId } = req.body;
    if (!userId || typeof userId !== 'string') return next(new AppError(400, 'userId requerido'));
    const entidadId = String(req.params.id);
+
+    // Seguridad: supervisor solo puede asignar contribuyentes que supervise
+    if (req.user!.role === 'supervisor') {
+      const visibleIds = await getEntidadesVisibles(req.tenantPool!, req.user!.userId, req.user!.role);
+      if (!visibleIds.includes(entidadId)) {
+        return next(new AppError(403, 'No tienes acceso a este contribuyente'));
+      }
+    }
+
    await req.tenantPool!.query(
      'INSERT INTO cliente_accesos (user_id, entidad_id) VALUES ($1, $2) ON CONFLICT DO NOTHING',
      [userId, entidadId],
--- a/apps/api/src/controllers/usuarios.controller.ts
+++ b/apps/api/src/controllers/usuarios.controller.ts
@@ -3,6 +3,7 @@ import { z } from 'zod';
 import * as usuariosService from '../services/usuarios.service.js';
 import { AppError } from '../middlewares/error.middleware.js';
 import { isGlobalAdmin as checkGlobalAdmin } from '../utils/global-admin.js';
+import { prisma } from '../config/database.js';

 const inviteSchema = z.object({
  email: z.string().email('email inválido'),
@@ -64,11 +65,16 @@ export async function getAllUsuarios(req: Request, res: Response, next: NextFunc

 export async function inviteUsuario(req: Request, res: Response, next: NextFunction) {
  try {
-    if (req.user!.role !== 'owner') {
-      throw new AppError(403, 'Solo los dueños pueden invitar usuarios');
+    if (!['owner', 'cfo', 'supervisor'].includes(req.user!.role)) {
+      throw new AppError(403, 'No autorizado para invitar usuarios');
    }
    const data = inviteSchema.parse(req.body);

+    // Los supervisores solo pueden invitar clientes
+    if (req.user!.role === 'supervisor' && data.role !== 'cliente') {
+      throw new AppError(403, 'Los supervisores solo pueden invitar clientes');
+    }
+
    // Validate: auxiliar requires a supervisor
    if (data.role === 'auxiliar' && !data.supervisorUserId) {
      throw new AppError(400, 'Debes asignar un supervisor al auxiliar');
@@ -139,7 +145,16 @@ export async function getSupervisor(req: Request, res: Response, next: NextFunct
       LIMIT 1`,
      [userId],
    );
-    res.json({ supervisorUserId: rows[0]?.supervisor_user_id ?? null });
+    const supervisorUserId = rows[0]?.supervisor_user_id ?? null;
+    let supervisorNombre: string | null = null;
+    if (supervisorUserId) {
+      const u = await prisma.user.findUnique({
+        where: { id: supervisorUserId },
+        select: { nombre: true },
+      });
+      supervisorNombre = u?.nombre ?? null;
+    }
+    res.json({ supervisorUserId, supervisorNombre });
  } catch (error) {
    next(error);
  }
--- a/apps/api/src/controllers/webhook.controller.ts
+++ b/apps/api/src/controllers/webhook.controller.ts
@@ -10,6 +10,21 @@ import { despachoPlanTieneDualidadDb } from '../services/plan-catalogo.service.j
 import { emailService } from '../services/email/email.service.js';
 import { getTenantOwnerEmail } from '../utils/memberships.js';

+/**
+ * Calcula la siguiente fecha de fin de período según la frecuencia.
+ * Usa el mismo algoritmo que Mercado Pago: mismo día del mes siguiente,
+ * ajustando al último día si el mes destino tiene menos días.
+ */
+function computeNextPeriodEnd(date: Date, frequency: string): Date {
+  const d = new Date(date);
+  if (frequency === 'monthly') {
+    d.setMonth(d.getMonth() + 1);
+  } else if (frequency === 'annual' || frequency === 'yearly') {
+    d.setFullYear(d.getFullYear() + 1);
+  }
+  return d;
+}
+
 export async function handleMercadoPagoWebhook(req: Request, res: Response, next: NextFunction) {
  try {
    const { type, data } = req.body;
@@ -187,9 +202,20 @@ async function handlePaymentNotification(paymentId: string) {
    // precio de renewal. Se detecta comparando el monto cobrado contra lo que
    // `getPlanPrice(phase='firstYear')` devolvería para este plan.
    const esPrimerPago = subscription.status === 'pending';
+    const updateData: { status: string; currentPeriodEnd?: Date } = { status: 'authorized' };
+
+    // Extender currentPeriodEnd para renovaciones recurrentes.
+    // El primer pago ya tiene currentPeriodEnd establecido al crear la suscripción;
+    // solo extendemos en pagos subsecuentes para reflejar el nuevo período cobrado.
+    if (!esPrimerPago && subscription.currentPeriodEnd) {
+      const nextPeriodEnd = computeNextPeriodEnd(subscription.currentPeriodEnd, subscription.frequency);
+      updateData.currentPeriodEnd = nextPeriodEnd;
+      console.log(`[WEBHOOK] Subscription ${subscription.id} extended to ${nextPeriodEnd.toISOString()} (${subscription.frequency})`);
+    }
+
    await prisma.subscription.update({
      where: { id: subscription.id },
-      data: { status: 'authorized' },
+      data: updateData,
    });
    subscriptionService.invalidateSubscriptionCache(tenantId);

--- a/apps/api/src/jobs/sat-sync.job.ts
+++ b/apps/api/src/jobs/sat-sync.job.ts
@@ -9,8 +9,10 @@ import { resetExpiredMonthlyTimbres } from '../services/facturapi.service.js';
 import { purgeDeclaracionesAntiguas } from '../services/declaraciones.service.js';
 import { consultarConstancia, purgeConstanciasAntiguas } from '../services/constancia.service.js';
 import { tenantDb } from '../config/database.js';
+import type { Pool } from 'pg';

 const SYNC_CRON_SCHEDULE = '0 3 * * *'; // 3:00 AM todos los días
+const RECOVERY_CRON_SCHEDULE = '0 10 * * *'; // 10:00 AM todos los días
 const CONCURRENT_SYNCS = 3; // Máximo de sincronizaciones simultáneas
 const OPINION_CRON_SCHEDULE = '0 4 * * 0'; // Sundays 4:00 AM
 const CSF_CRON_SCHEDULE = '0 4 1 * *';     // Día 1 de cada mes 04:00 AM (CSF mensual)
@@ -20,6 +22,38 @@ const EXPIRY_REMINDERS_CRON = '0 9 * * *';        // 9:00 AM diario — avisos p

 let isRunning = false;
 let isIncrementalRunning = false;
+let isRecoveryRunning = false;
+
+/**
+ * Verifica si un tenant tiene FIEL a nivel tenant (legacy Horux 360)
+ * o a nivel contribuyente (modelo despacho).
+ */
+async function hasAnyFielConfigured(tenantId: string, databaseName?: string | null): Promise<boolean> {
+  // 1) FIEL legacy a nivel tenant
+  const hasLegacy = await hasFielConfigured(tenantId);
+  if (hasLegacy) return true;
+
+  // 2) FIEL por contribuyente (modelo despacho)
+  if (!databaseName) {
+    const tenant = await prisma.tenant.findUnique({
+      where: { id: tenantId },
+      select: { databaseName: true },
+    });
+    databaseName = tenant?.databaseName;
+  }
+  if (!databaseName) return false;
+
+  try {
+    const pool = await tenantDb.getPool(tenantId, databaseName);
+    const { rows } = await pool.query(
+      `SELECT 1 FROM fiel_contribuyente WHERE is_active = true LIMIT 1`
+    );
+    return rows.length > 0;
+  } catch (err: any) {
+    console.error(`[SAT Cron] Error verificando FIEL contribuyente para tenant ${tenantId}:`, err.message);
+    return false;
+  }
+}

 /**
 * Obtiene los tenants que tienen FIEL configurada y activa
@@ -27,13 +61,13 @@ let isIncrementalRunning = false;
 async function getTenantsWithFiel(): Promise<string[]> {
  const tenants = await prisma.tenant.findMany({
    where: { active: true },
-    select: { id: true },
+    select: { id: true, databaseName: true },
  });

  const tenantsWithFiel: string[] = [];

  for (const tenant of tenants) {
-    const hasFiel = await hasFielConfigured(tenant.id);
+    const hasFiel = await hasAnyFielConfigured(tenant.id, tenant.databaseName);
    if (hasFiel) {
      tenantsWithFiel.push(tenant.id);
    }
@@ -172,12 +206,12 @@ async function getTenantsConSatIncremental(): Promise<string[]> {

  const tenants = await prisma.tenant.findMany({
    where: { active: true, plan: { in: planNames as any } },
-    select: { id: true },
+    select: { id: true, databaseName: true },
  });

  const result: string[] = [];
  for (const tenant of tenants) {
-    if (await hasFielConfigured(tenant.id)) {
+    if (await hasAnyFielConfigured(tenant.id, tenant.databaseName)) {
      result.push(tenant.id);
    }
  }
@@ -351,12 +385,153 @@ async function runCsfJob(): Promise<void> {
      console.error(`[CSF Cron] Error para ${tenant.rfc}:`, error.message);
      failed++;
    }
+    // Delay entre tenants para no saturar al SAT y reducir bloqueos por IP
+    await new Promise(r => setTimeout(r, 30_000));
  }
  console.log(`[CSF Cron] Completado — éxito: ${success}, fallidos: ${failed}, sin FIEL: ${skipped}`);
 }

+function getYesterdayEnd(): Date {
+  const now = new Date();
+  return new Date(now.getFullYear(), now.getMonth(), now.getDate() - 1, 23, 59, 59);
+}
+
+async function hasIncompleteCfdis(pool: Pool, contribuyenteId: string): Promise<boolean> {
+  const { rows } = await pool.query<{ count: string }>(`
+    SELECT COUNT(*)::text as count
+    FROM cfdis
+    WHERE contribuyente_id = $1
+      AND status = 'Vigente'
+      AND tipo_comprobante IN ('I', 'E')
+      AND xml_original IS NULL
+  `, [contribuyenteId]);
+  return Number(rows[0]?.count || 0) > 0;
+}
+
+async function getOldestIncompleteCfdiDate(pool: Pool, contribuyenteId: string): Promise<Date | null> {
+  const { rows } = await pool.query<{ fecha_emision: Date | null }>(`
+    SELECT MIN(fecha_emision) as fecha_emision
+    FROM cfdis
+    WHERE contribuyente_id = $1
+      AND status = 'Vigente'
+      AND tipo_comprobante IN ('I', 'E')
+      AND xml_original IS NULL
+  `, [contribuyenteId]);
+  return rows[0]?.fecha_emision || null;
+}
+
+async function waitForRecoveryJob(jobId: string): Promise<void> {
+  while (true) {
+    const job = await prisma.satSyncJob.findUnique({ where: { id: jobId } });
+    if (!job || job.status === 'completed' || job.status === 'failed') {
+      return;
+    }
+    await new Promise(resolve => setTimeout(resolve, 60000));
+  }
+}
+
+async function recoverContribuyente(tenantId: string, databaseName: string, contribuyenteId: string): Promise<void> {
+  try {
+    const status = await getSyncStatus(tenantId, contribuyenteId);
+    if (status.hasActiveSync) {
+      console.log(`[SAT Recovery] ${contribuyenteId} tiene sync activo, omitiendo`);
+      return;
+    }
+
+    const pool = await tenantDb.getPool(tenantId, databaseName);
+    const hasIncomplete = await hasIncompleteCfdis(pool, contribuyenteId);
+
+    const lastDaily = await prisma.satSyncJob.findFirst({
+      where: { tenantId, contribuyenteId, type: 'daily' },
+      orderBy: { startedAt: 'desc' },
+    });
+
+    if (!hasIncomplete && lastDaily?.status !== 'failed') {
+      return;
+    }
+
+    const dateTo = getYesterdayEnd();
+    let dateFrom = new Date(dateTo.getFullYear() - 1, dateTo.getMonth(), dateTo.getDate());
+
+    if (hasIncomplete) {
+      const oldest = await getOldestIncompleteCfdiDate(pool, contribuyenteId);
+      if (oldest) {
+        dateFrom = new Date(oldest.getFullYear(), oldest.getMonth(), 1);
+        dateFrom.setMonth(dateFrom.getMonth() - 1);
+      }
+    }
+
+    console.log(`[SAT Recovery] Recuperando ${contribuyenteId}: ${dateFrom.toISOString()} → ${dateTo.toISOString()}`);
+    const jobId = await startSync(tenantId, 'initial', dateFrom, dateTo, contribuyenteId);
+    console.log(`[SAT Recovery] Job ${jobId} iniciado`);
+
+    await waitForRecoveryJob(jobId);
+  } catch (error: any) {
+    console.error(`[SAT Recovery] Error recuperando ${contribuyenteId}:`, error.message);
+  }
+}
+
+async function recoverTenant(tenantId: string): Promise<void> {
+  const tenant = await prisma.tenant.findUnique({
+    where: { id: tenantId },
+    select: { databaseName: true },
+  });
+  if (!tenant?.databaseName) return;
+
+  const pool = await tenantDb.getPool(tenantId, tenant.databaseName);
+  const { rows } = await pool.query<{ entidad_id: string }>('SELECT entidad_id FROM contribuyentes');
+  const contribuyenteIds = rows.map(r => r.entidad_id);
+
+  if (contribuyenteIds.length === 0) {
+    const status = await getSyncStatus(tenantId);
+    if (status.hasActiveSync) return;
+    const lastDaily = await prisma.satSyncJob.findFirst({
+      where: { tenantId, contribuyenteId: null, type: 'daily' },
+      orderBy: { startedAt: 'desc' },
+    });
+    if (lastDaily?.status === 'failed') {
+      const dateTo = getYesterdayEnd();
+      const dateFrom = new Date(dateTo.getFullYear() - 1, dateTo.getMonth(), dateTo.getDate());
+      console.log(`[SAT Recovery] Recuperando tenant legacy ${tenantId}`);
+      const jobId = await startSync(tenantId, 'initial', dateFrom, dateTo);
+      await waitForRecoveryJob(jobId);
+    }
+    return;
+  }
+
+  for (const contribuyenteId of contribuyenteIds) {
+    await recoverContribuyente(tenantId, tenant.databaseName, contribuyenteId);
+  }
+}
+
+async function runRecoverySyncJob(): Promise<void> {
+  if (isRecoveryRunning) {
+    console.log('[SAT Recovery] Ya en ejecución, omitiendo');
+    return;
+  }
+
+  isRecoveryRunning = true;
+  console.log('[SAT Recovery] Iniciando job de recuperación');
+
+  try {
+    const tenantIds = await getTenantsWithFiel();
+    console.log(`[SAT Recovery] ${tenantIds.length} tenants con FIEL`);
+
+    for (const tenantId of tenantIds) {
+      await recoverTenant(tenantId);
+    }
+
+    console.log('[SAT Recovery] Job de recuperación completado');
+  } catch (error: any) {
+    console.error('[SAT Recovery] Error:', error.message);
+  } finally {
+    isRecoveryRunning = false;
+  }
+}
+
 let scheduledTask: ReturnType<typeof cron.schedule> | null = null;
 let retryTask: ReturnType<typeof cron.schedule> | null = null;
+let recoveryTask: ReturnType<typeof cron.schedule> | null = null;
 let opinionTask: ReturnType<typeof cron.schedule> | null = null;
 let csfTask: ReturnType<typeof cron.schedule> | null = null;
 let incrementalTask: ReturnType<typeof cron.schedule> | null = null;
@@ -397,6 +572,19 @@ export function startSatSyncJob(): void {
    timezone: 'America/Mexico_City',
  });

+  // Cron de recuperación: 10:00 AM diario. Revisa si el sync diario falló o si
+  // hay CFDIs vigentes sin XML, y relanza un sync `initial` con rango extendido
+  // para completar los XML faltantes.
+  recoveryTask = cron.schedule(RECOVERY_CRON_SCHEDULE, async () => {
+    try {
+      await runRecoverySyncJob();
+    } catch (error: any) {
+      console.error('[SAT Recovery Cron] Error:', error.message);
+    }
+  }, {
+    timezone: 'America/Mexico_City',
+  });
+
  // Cron watchdog: cada 2h marca como `failed` los jobs que quedaron stale
  // (pending con nextRetryAt > 12h atrás, running con startedAt > 4h atrás).
  // Thresholds sobreescribibles vía env (STALE_PENDING_HOURS / STALE_RUNNING_HOURS)
@@ -502,6 +690,7 @@ export function startSatSyncJob(): void {

  console.log(`[SAT Cron] Job programado para: ${SYNC_CRON_SCHEDULE} (America/Mexico_City)`);
  console.log(`[SAT Cron] Retry programado cada hora`);
+  console.log(`[SAT Recovery Cron] Programado para: ${RECOVERY_CRON_SCHEDULE} (America/Mexico_City)`);
  console.log(`[Opinion Cron] Programado para: ${OPINION_CRON_SCHEDULE} (America/Mexico_City)`);
  console.log(`[CSF Cron] Programado para: ${CSF_CRON_SCHEDULE} (America/Mexico_City)`);
  console.log(`[SAT Cron Inc] Incremental Enterprise programado para: ${INCREMENTAL_CRON_SCHEDULE} (America/Mexico_City)`);
@@ -521,6 +710,10 @@ export function stopSatSyncJob(): void {
    retryTask.stop();
    retryTask = null;
  }
+  if (recoveryTask) {
+    recoveryTask.stop();
+    recoveryTask = null;
+  }
  if (opinionTask) {
    opinionTask.stop();
    opinionTask = null;
--- a/apps/api/src/services/admin-clientes.service.ts
+++ b/apps/api/src/services/admin-clientes.service.ts
@@ -66,11 +66,13 @@ export async function getClientesStats(range: ClientesStatsRange): Promise<Clien
    paymentsCount: payments._count,
  };

-  // 3) Clientes que NO renovaron: subs cuyo currentPeriodEnd cae en el rango
-  // y que están en status terminal (cancelled, trial_expired, paused) o sin
-  // payment posterior aprobado. Nota: un sub `authorized` con periodEnd
-  // pasado es un "se renovó automáticamente" — para detectar no-renovaciones
-  // miramos status efectivo + ausencia de payment en los siguientes 7 días.
+  // 3) Clientes que NO renovaron:
+  //    a) Subs cuyo currentPeriodEnd cae en el rango y están en status terminal
+  //       (cancelled, trial_expired, paused).
+  //    b) Tenants cuyo trialEndsAt ya pasó y NO tienen suscripción authorized
+  //       (incluye trials que nunca convirtieron o cuya sub fue borrada).
+  //    c) Tenants con sub trial vencida (currentPeriodEnd < ahora) que nunca
+  //       fue marcada trial_expired por el cron.
  const subsExpiradas = await prisma.subscription.findMany({
    where: {
      currentPeriodEnd: { gte: range.from, lte: range.to },
@@ -84,14 +86,99 @@ export async function getClientesStats(range: ClientesStatsRange): Promise<Clien
      tenant: { select: { id: true, nombre: true, rfc: true } },
    },
  });
-  const noRenovaciones = subsExpiradas.map(s => ({
-    tenantId: s.tenantId,
-    tenantNombre: s.tenant?.nombre ?? '',
-    rfc: s.tenant?.rfc ?? '',
-    plan: String(s.plan),
-    currentPeriodEnd: s.currentPeriodEnd?.toISOString() ?? '',
-    statusActual: s.status,
-  }));
+
+  const noRenovacionesMap = new Map<string, ClientesStats['noRenovaciones'][number]>();
+  for (const s of subsExpiradas) {
+    noRenovacionesMap.set(s.tenantId, {
+      tenantId: s.tenantId,
+      tenantNombre: s.tenant?.nombre ?? '',
+      rfc: s.tenant?.rfc ?? '',
+      plan: String(s.plan),
+      currentPeriodEnd: s.currentPeriodEnd?.toISOString() ?? '',
+      statusActual: s.status,
+    });
+  }
+
+  // b + c) Trials vencidos / sin suscripción activa / subs borradas
+  const now = new Date();
+  const tenantsConSubAutorizada = new Set(
+    (await prisma.subscription.findMany({
+      where: { status: 'authorized' },
+      select: { tenantId: true },
+    })).map(s => s.tenantId)
+  );
+  const excluded = Array.from(tenantsConSubAutorizada);
+
+  // Tenants con trialEndsAt pasado y sin sub authorized
+  const tenantsTrialsVencidos = await prisma.tenant.findMany({
+    where: {
+      trialEndsAt: { lt: now },
+      id: { notIn: excluded },
+    },
+    select: { id: true, nombre: true, rfc: true, plan: true, trialEndsAt: true },
+  });
+  for (const t of tenantsTrialsVencidos) {
+    if (noRenovacionesMap.has(t.id)) continue;
+    noRenovacionesMap.set(t.id, {
+      tenantId: t.id,
+      tenantNombre: t.nombre,
+      rfc: t.rfc ?? '',
+      plan: String(t.plan ?? 'trial'),
+      currentPeriodEnd: t.trialEndsAt?.toISOString() ?? '',
+      statusActual: 'trial_expired',
+    });
+  }
+
+  // Tenants con sub trial vencida (currentPeriodEnd < ahora) que nunca fue
+  // marcada trial_expired por el cron, y no tienen otra sub authorized.
+  const subsTrialVencidas = await prisma.subscription.findMany({
+    where: {
+      status: 'trial',
+      currentPeriodEnd: { lt: now },
+      tenantId: { notIn: excluded },
+    },
+    select: {
+      tenantId: true,
+      plan: true,
+      currentPeriodEnd: true,
+      tenant: { select: { id: true, nombre: true, rfc: true } },
+    },
+  });
+  for (const s of subsTrialVencidas) {
+    if (noRenovacionesMap.has(s.tenantId)) continue;
+    noRenovacionesMap.set(s.tenantId, {
+      tenantId: s.tenantId,
+      tenantNombre: s.tenant?.nombre ?? '',
+      rfc: s.tenant?.rfc ?? '',
+      plan: String(s.plan),
+      currentPeriodEnd: s.currentPeriodEnd?.toISOString() ?? '',
+      statusActual: 'trial_expired',
+    });
+  }
+
+  // Tenants con plan de pago asignado manualmente (plan != 'trial') pero
+  // sin NINGUNA suscripción. Indica que nunca iniciaron el flujo de pago.
+  const tenantsConPlanPeroSinSub = await prisma.tenant.findMany({
+    where: {
+      plan: { not: 'trial' },
+      id: { notIn: excluded },
+      subscriptions: { none: {} },
+    },
+    select: { id: true, nombre: true, rfc: true, plan: true, createdAt: true },
+  });
+  for (const t of tenantsConPlanPeroSinSub) {
+    if (noRenovacionesMap.has(t.id)) continue;
+    noRenovacionesMap.set(t.id, {
+      tenantId: t.id,
+      tenantNombre: t.nombre,
+      rfc: t.rfc ?? '',
+      plan: String(t.plan),
+      currentPeriodEnd: t.createdAt.toISOString(),
+      statusActual: 'sin_suscripcion',
+    });
+  }
+
+  const noRenovaciones = Array.from(noRenovacionesMap.values());

  // 4) Usuarios por cliente (memberships activos por tenant)
  const memberships = await prisma.tenantMembership.findMany({
--- a/apps/api/src/services/alertas-auto.service.ts
+++ b/apps/api/src/services/alertas-auto.service.ts
@@ -609,30 +609,46 @@ async function alertaOpinionCumplimiento(pool: Pool, contribuyenteId?: string |

 /**
 * Genera todas las alertas automáticas para un tenant.
+ * Cada alerta se envuelve en try/catch para que un fallo en una no
+ * bloquee el resto (robustez ante timeouts o errores transitorios).
 */
 export async function generarAlertasAutomaticas(
  pool: Pool,
  tenantId: string,
  contribuyenteId?: string | null,
 ): Promise<AlertaAuto[]> {
-  const alertas = await Promise.all([
-    alertaListaNegraPropia(pool, tenantId, contribuyenteId),
-    alertaClienteListaNegra(pool, contribuyenteId),
-    alertaProveedorListaNegra(pool, contribuyenteId),
-    alertaDiscrepanciaRegimen(pool, tenantId, contribuyenteId),
-    alertaConcentracionClientes(pool, contribuyenteId),
-    alertaConcentracionProveedores(pool, contribuyenteId),
-    alertaRiesgoCambiario(pool, contribuyenteId),
-    alertaRiesgoCancelaciones(pool, contribuyenteId),
-    alertaRiesgoTransaccional(pool, contribuyenteId),
-    alertaCancelacionPeriodoAnterior(pool, contribuyenteId),
-    alertaOpinionCumplimiento(pool, contribuyenteId),
-    alertaTipoRelacionSospechosa(pool, contribuyenteId),
-    alertaTareasProximasVencer(pool, contribuyenteId),
-    alertaResicoPfLimiteIngresos(pool, contribuyenteId),
-  ]);
+  const generadores: { name: string; fn: () => Promise<AlertaAuto | null> }[] = [
+    { name: 'lista-negra-propia', fn: () => alertaListaNegraPropia(pool, tenantId, contribuyenteId) },
+    { name: 'lista-negra-clientes', fn: () => alertaClienteListaNegra(pool, contribuyenteId) },
+    { name: 'lista-negra-proveedores', fn: () => alertaProveedorListaNegra(pool, contribuyenteId) },
+    { name: 'discrepancia-regimen', fn: () => alertaDiscrepanciaRegimen(pool, tenantId, contribuyenteId) },
+    { name: 'concentracion-clientes', fn: () => alertaConcentracionClientes(pool, contribuyenteId) },
+    { name: 'concentracion-proveedores', fn: () => alertaConcentracionProveedores(pool, contribuyenteId) },
+    { name: 'riesgo-cambiario', fn: () => alertaRiesgoCambiario(pool, contribuyenteId) },
+    { name: 'riesgo-cancelaciones', fn: () => alertaRiesgoCancelaciones(pool, contribuyenteId) },
+    { name: 'riesgo-transaccional', fn: () => alertaRiesgoTransaccional(pool, contribuyenteId) },
+    { name: 'cancelacion-periodo-anterior', fn: () => alertaCancelacionPeriodoAnterior(pool, contribuyenteId) },
+    { name: 'opinion-cumplimiento', fn: () => alertaOpinionCumplimiento(pool, contribuyenteId) },
+    { name: 'tipo-relacion-sospechosa', fn: () => alertaTipoRelacionSospechosa(pool, contribuyenteId) },
+    { name: 'tareas-proximas-vencer', fn: () => alertaTareasProximasVencer(pool, contribuyenteId) },
+    { name: 'resico-pf-limite-ingresos', fn: () => alertaResicoPfLimiteIngresos(pool, contribuyenteId) },
+  ];

-  return alertas.filter((a): a is AlertaAuto => a !== null);
+  const alertas: AlertaAuto[] = [];
+  for (const g of generadores) {
+    try {
+      const a = await g.fn();
+      if (a) alertas.push(a);
+    } catch (err: any) {
+      console.error(`[AlertasAuto] Fallo ${g.name} (tenant=${tenantId}, contribuyente=${contribuyenteId}):`, err.message || err);
+    }
+  }
+
+  if (alertas.length > 0) {
+    console.log(`[AlertasAuto] tenant=${tenantId} contribuyente=${contribuyenteId || 'null'} generadas=${alertas.map(a => a.id).join(', ')}`);
+  }
+
+  return alertas;
 }

 /**
--- a/apps/api/src/services/constancia.service.ts
+++ b/apps/api/src/services/constancia.service.ts
@@ -44,6 +44,9 @@ function rowToConstancia(r: any): ConstanciaRow {
 * sincroniza automáticamente domicilio + regímenes activos con lo que reporta
 * el SAT. El auto-fill NO es destructivo para datos custom del usuario:
 * solo sobreescribe campos si la CSF tiene un valor no-vacío.
+ * 
+ * Incluye retry con backoff (3 intentos) para robustez ante timeouts
+ * transitorios del portal SAT (mantenimiento nocturno, congestión, etc.).
 */
 export async function consultarConstancia(tenantId: string): Promise<ConstanciaRow> {
  const fiel = await getDecryptedFiel(tenantId);
@@ -55,72 +58,78 @@ export async function consultarConstancia(tenantId: string): Promise<ConstanciaR
  });
  if (!tenant) throw new Error('Tenant no encontrado');

-  const tempId = randomUUID();
-  const tempDir = join(tmpdir(), `horux-csf-${tempId}`);
-  mkdirSync(tempDir, { recursive: true, mode: 0o700 });
-  const cerPath = join(tempDir, 'cert.cer');
-  const keyPath = join(tempDir, 'key.key');
+  const MAX_RETRIES = 3;
+  const RETRY_DELAYS = [5_000, 15_000, 30_000]; // backoff

-  try {
-    writeFileSync(cerPath, Buffer.from(fiel.cerContent, 'binary'), { mode: 0o600 });
-    writeFileSync(keyPath, Buffer.from(fiel.keyContent, 'binary'), { mode: 0o600 });
+  for (let attempt = 0; attempt < MAX_RETRIES; attempt++) {
+    const tempId = randomUUID();
+    const tempDir = join(tmpdir(), `horux-csf-${tempId}`);
+    mkdirSync(tempDir, { recursive: true, mode: 0o700 });
+    const cerPath = join(tempDir, 'cert.cer');
+    const keyPath = join(tempDir, 'key.key');

-    // Headless por default. El fix de dispatchEvent en sat-csf-login cubre el
-    // caso donde el click sintético no dispara el handler del SAT. Si algún
-    // ambiente necesita ver el browser (debug), setear SAT_HEADLESS=false.
-    const headless = process.env.SAT_HEADLESS !== 'false';
-    const browser = await chromium.launch({
-      headless,
-      args: ['--disable-blink-features=AutomationControlled'],
-      ignoreDefaultArgs: ['--enable-automation'],
-    });
    try {
-      const timeoutPromise = new Promise<never>((_, reject) =>
-        setTimeout(() => reject(new Error('Timeout: proceso de CSF excedió 3 minutos')), PROCESS_TIMEOUT),
-      );
+      writeFileSync(cerPath, Buffer.from(fiel.cerContent, 'binary'), { mode: 0o600 });
+      writeFileSync(keyPath, Buffer.from(fiel.keyContent, 'binary'), { mode: 0o600 });

-      const resultPromise = (async () => {
-        const session = await loginSatCsf(browser, cerPath, keyPath, fiel.password, fiel.rfc);
-        const pdfBuffer = await extractCsfPdf(session);
-        const csf = await parseCsfPdf(pdfBuffer);
-
-        const pool = await tenantDb.getPool(tenantId, tenant.databaseName);
-        const { rows } = await pool.query(
-          `INSERT INTO constancias_situacion_fiscal
-             (rfc, id_cif, razon_social, estatus_padron, fecha_emision, datos, pdf)
-           VALUES ($1, $2, $3, $4, $5, $6, $7)
-           RETURNING id, rfc, id_cif, razon_social, estatus_padron, fecha_emision,
-                     datos, fecha_consulta, created_at`,
-          [
-            csf.rfc,
-            csf.idCIF,
-            csf.razonSocial ?? [csf.nombre, csf.primerApellido, csf.segundoApellido].filter(Boolean).join(' ') ?? null,
-            csf.estatusPadron,
-            csf.lugarFechaEmision,
-            JSON.stringify(csf),
-            pdfBuffer,
-          ],
+      const headless = process.env.SAT_HEADLESS !== 'false';
+      const browser = await chromium.launch({
+        headless,
+        args: ['--disable-blink-features=AutomationControlled'],
+        ignoreDefaultArgs: ['--enable-automation'],
+      });
+      try {
+        const timeoutPromise = new Promise<never>((_, reject) =>
+          setTimeout(() => reject(new Error('Timeout: proceso de CSF excedió 5 minutos')), 300_000),
        );

-        // Auto-fill domicilio del tenant + regímenes activos desde el CSF.
-        // Se hace después del INSERT para que si algo falla en la sincronización
-        // la CSF ya quedó guardada y el usuario puede verla.
-        await sincronizarDatosFiscales(tenantId, csf).catch(err => {
-          console.error(`[CSF] Error sincronizando datos fiscales para tenant ${tenantId}:`, err);
-        });
+        const resultPromise = (async () => {
+          const session = await loginSatCsf(browser, cerPath, keyPath, fiel.password, fiel.rfc);
+          const pdfBuffer = await extractCsfPdf(session);
+          const csf = await parseCsfPdf(pdfBuffer);

-        return rowToConstancia(rows[0]);
-      })();
+          const pool = await tenantDb.getPool(tenantId, tenant.databaseName);
+          const { rows } = await pool.query(
+            `INSERT INTO constancias_situacion_fiscal
+               (rfc, id_cif, razon_social, estatus_padron, fecha_emision, datos, pdf)
+             VALUES ($1, $2, $3, $4, $5, $6, $7)
+             RETURNING id, rfc, id_cif, razon_social, estatus_padron, fecha_emision,
+                       datos, fecha_consulta, created_at`,
+            [
+              csf.rfc,
+              csf.idCIF,
+              csf.razonSocial ?? [csf.nombre, csf.primerApellido, csf.segundoApellido].filter(Boolean).join(' ') ?? null,
+              csf.estatusPadron,
+              csf.lugarFechaEmision,
+              JSON.stringify(csf),
+              pdfBuffer,
+            ],
+          );

-      return await Promise.race([resultPromise, timeoutPromise]);
+          await sincronizarDatosFiscales(tenantId, csf).catch(err => {
+            console.error(`[CSF] Error sincronizando datos fiscales para tenant ${tenantId}:`, err);
+          });
+
+          return rowToConstancia(rows[0]);
+        })();
+
+        return await Promise.race([resultPromise, timeoutPromise]);
+      } finally {
+        await browser.close();
+      }
+    } catch (err: any) {
+      const willRetry = attempt < MAX_RETRIES - 1;
+      console.error(`[CSF] Intento ${attempt + 1}/${MAX_RETRIES} falló para tenant ${tenantId}: ${err.message}${willRetry ? ` — reintentando en ${RETRY_DELAYS[attempt]}ms...` : ''}`);
+      if (!willRetry) throw err;
+      await new Promise(r => setTimeout(r, RETRY_DELAYS[attempt]));
    } finally {
-      await browser.close();
+      try { unlinkSync(cerPath); } catch { /* ok */ }
+      try { unlinkSync(keyPath); } catch { /* ok */ }
+      try { rmdirSync(tempDir); } catch { /* ok */ }
    }
-  } finally {
-    try { unlinkSync(cerPath); } catch { /* ok */ }
-    try { unlinkSync(keyPath); } catch { /* ok */ }
-    try { rmdirSync(tempDir); } catch { /* ok */ }
  }
+
+  throw new Error('No debería llegar aquí');
 }

 /**
--- a/apps/api/src/services/dashboard.service.ts
+++ b/apps/api/src/services/dashboard.service.ts
@@ -1107,10 +1107,21 @@ export async function getKpis(
  const ctx = await resolveContribuyenteContext(pool, tenantId, contribuyenteId);
  const esEmisor = ctx.esEmisor;
  const esReceptor = ctx.esReceptor;
-  const ingresosData = await calcularIngresosPorRegimen(pool, tenantId, fechaInicio, fechaFin, undefined, undefined, conciliacion, contribuyenteId);
-  const egresosData = await calcularEgresosPorRegimen(pool, tenantId, fechaInicio, fechaFin, undefined, undefined, conciliacion, contribuyenteId);
-  const adquisicionData = await calcularAdquisicionesMercancias(pool, tenantId, fechaInicio, fechaFin, conciliacion, contribuyenteId);
-  const ivaData = await calcularIvaBalancePorRegimen(pool, tenantId, fechaInicio, fechaFin, undefined, undefined, conciliacion, contribuyenteId);
+  const [
+    ingresosData,
+    egresosData,
+    adquisicionData,
+    ivaData,
+    ncsEmitidasData,
+    ncsRecibidasData,
+  ] = await Promise.all([
+    calcularIngresosPorRegimen(pool, tenantId, fechaInicio, fechaFin, undefined, undefined, conciliacion, contribuyenteId),
+    calcularEgresosPorRegimen(pool, tenantId, fechaInicio, fechaFin, undefined, undefined, conciliacion, contribuyenteId),
+    calcularAdquisicionesMercancias(pool, tenantId, fechaInicio, fechaFin, conciliacion, contribuyenteId),
+    calcularIvaBalancePorRegimen(pool, tenantId, fechaInicio, fechaFin, undefined, undefined, conciliacion, contribuyenteId),
+    calcularNcsEmitidasPorRegimen(pool, tenantId, fechaInicio, fechaFin, undefined, undefined, conciliacion, contribuyenteId),
+    calcularNcsRecibidasPorRegimen(pool, tenantId, fechaInicio, fechaFin, undefined, undefined, conciliacion, contribuyenteId),
+  ]);

  // IVA a favor año actual: desde enero del año en curso
  const ivaAFavorAcumulado = await calcularIvaAFavorAcumulado(pool, tenantId, fechaFin, undefined, conciliacion, contribuyenteId);
@@ -1163,6 +1174,10 @@ export async function getKpis(
    cfdisEmitidosPorRegimen: emitidosPorRegimen,
    cfdisRecibidos: recibidosPorRegimen.reduce((s: number, r: any) => s + r.total, 0),
    cfdisRecibidosPorRegimen: recibidosPorRegimen,
+    ncsEmitidas: ncsEmitidasData.total,
+    ncsEmitidasPorRegimen: ncsEmitidasData.porRegimen,
+    ncsRecibidas: ncsRecibidasData.total,
+    ncsRecibidasPorRegimen: ncsRecibidasData.porRegimen,
  };
 }

--- a/apps/api/src/services/payment/invoicing.service.ts
+++ b/apps/api/src/services/payment/invoicing.service.ts
@@ -348,6 +348,17 @@ export async function emitInvoiceIfApplicable(paymentId: string): Promise<void>
      data: { facturapiInvoiceId: invoice.id },
    });

+    // Enviar factura por email al cliente cuando se factura con datos reales
+    // (no público en general). Fail-soft: si el envío falla, no bloquea.
+    if (customer?.email) {
+      try {
+        await facturapiService.sendInvoiceByEmail(emitter.id, invoice.id, customer.email);
+        console.log(`[Invoicing] Factura ${invoice.id} enviada a ${customer.email}`);
+      } catch (emailErr: any) {
+        console.error(`[Invoicing] Error enviando factura ${invoice.id} a ${customer.email}:`, emailErr.message || emailErr);
+      }
+    }
+
    auditLog({
      tenantId: payment.tenantId,
      action: 'invoice.emitted_auto',
--- a/apps/api/src/services/regimen.service.ts
+++ b/apps/api/src/services/regimen.service.ts
@@ -45,7 +45,10 @@ export async function getRegimenesActivosClaves(tenantId: string): Promise<strin
 /**
 * Resuelve las claves de regímenes activos para la alerta de discrepancia.
 * Si hay contribuyenteId, lee de contribuyentes.regimen_fiscal (comma-separated).
- * Si no, fallback a TenantRegimenActivo (tabla central).
+ * Si no, combina TenantRegimenActivo (tabla central) con los regímenes de
+ * todos los contribuyentes activos del tenant. Esto evita que la alerta
+ * aparezca en el correo por-contribuyente pero desaparezca en el dashboard
+ * cuando no hay un contribuyente seleccionado.
 */
 export async function getRegimenesActivosClavesEfectivos(
  tenantId: string,
@@ -61,9 +64,49 @@ export async function getRegimenesActivosClavesEfectivos(
    if (rows.length > 0 && rows[0].regimen_fiscal) {
      return rows[0].regimen_fiscal.split(',').map((c: string) => c.trim()).filter(Boolean);
    }
-    return [];
+    // Fallback: si el contribuyente no tiene regimen_fiscal, usamos los del tenant
+    // para no perder la alerta si el campo quedó vacío accidentalmente.
+    const tenantRegimenes = await getRegimenesActivosClaves(tenantId);
+    if (tenantRegimenes.length > 0) return tenantRegimenes;
+
+    const { rows: allRows } = await pool.query(
+      `SELECT DISTINCT regimen_fiscal FROM contribuyentes WHERE regimen_fiscal IS NOT NULL AND regimen_fiscal <> ''`,
+    );
+    const set = new Set<string>();
+    for (const row of allRows) {
+      if (row.regimen_fiscal) {
+        for (const clave of row.regimen_fiscal.split(',')) {
+          const trimmed = clave.trim();
+          if (trimmed) set.add(trimmed);
+        }
+      }
+    }
+    return Array.from(set);
  }
-  return getRegimenesActivosClaves(tenantId);
+
+  const tenantRegimenes = await getRegimenesActivosClaves(tenantId);
+
+  // Fallback: si no hay regímenes configurados a nivel tenant, usamos los
+  // regímenes de todos los contribuyentes activos del tenant.
+  if (tenantRegimenes.length > 0) {
+    return tenantRegimenes;
+  }
+
+  const { rows } = await pool.query(
+    `SELECT DISTINCT regimen_fiscal FROM contribuyentes WHERE regimen_fiscal IS NOT NULL AND regimen_fiscal <> ''`,
+  );
+
+  const set = new Set<string>();
+  for (const row of rows) {
+    if (row.regimen_fiscal) {
+      for (const clave of row.regimen_fiscal.split(',')) {
+        const trimmed = clave.trim();
+        if (trimmed) set.add(trimmed);
+      }
+    }
+  }
+
+  return Array.from(set);
 }

 export async function setRegimenesActivos(tenantId: string, regimenIds: number[]) {
--- a/apps/api/src/services/sat/sat-client.service.ts
+++ b/apps/api/src/services/sat/sat-client.service.ts
@@ -72,9 +72,17 @@ export async function querySat(
  requestType: 'metadata' | 'cfdi' = 'cfdi'
 ): Promise<QueryResult> {
  try {
+    // El SAT rechaza fechaInicial >= fechaFinal. Como formatDateForSat trunca
+    // a medianoche, dos fechas dentro del mismo día calendario resultan iguales.
+    // Ajustamos fechaFin al día siguiente para evitar el error.
+    let adjustedFechaFin = fechaFin;
+    if (formatDateForSat(fechaInicio) === formatDateForSat(fechaFin)) {
+      adjustedFechaFin = new Date(fechaFin.getTime() + 24 * 60 * 60 * 1000);
+    }
+
    const period = DateTimePeriod.createFromValues(
      formatDateForSat(fechaInicio),
-      formatDateForSat(fechaFin)
+      formatDateForSat(adjustedFechaFin)
    );

    const downloadType = new DownloadType(tipo === 'emitidos' ? 'issued' : 'received');
@@ -239,10 +247,11 @@ export async function downloadSatPackage(
 }

 /**
- * Formatea una fecha para el SAT (YYYY-MM-DD HH:mm:ss)
+ * Formatea una fecha para el SAT (YYYY-MM-DD HH:mm:ss).
+ * El SAT requiere hora 00:00:00; cualquier otra hora causa
+ * "Fecha final invalida" / "Fecha inicial invalida".
 */
 function formatDateForSat(date: Date): string {
  const pad = (n: number) => n.toString().padStart(2, '0');
-  return `${date.getFullYear()}-${pad(date.getMonth() + 1)}-${pad(date.getDate())} ` +
-    `${pad(date.getHours())}:${pad(date.getMinutes())}:${pad(date.getSeconds())}`;
+  return `${date.getFullYear()}-${pad(date.getMonth() + 1)}-${pad(date.getDate())} 00:00:00`;
 }
--- a/apps/api/src/services/sat/sat-csf-login.ts
+++ b/apps/api/src/services/sat/sat-csf-login.ts
@@ -30,20 +30,20 @@ export async function loginSatCsf(
  const publicPage = await context.newPage();
  publicPage.setDefaultTimeout(60_000);

-  await publicPage.goto(PUBLIC_URL, { waitUntil: 'networkidle' });
-  await publicPage.waitForTimeout(2000);
+  await publicPage.goto(PUBLIC_URL, { waitUntil: 'networkidle', timeout: 120_000 });
+  await publicPage.waitForTimeout(3000);

  // Click acordeón "Obtén tu constancia" / "Obtener constancia"
  const obtenerLocator = publicPage.locator(
    'text=/Obt[eé]n\\s+la\\s+constancia|Obt[eé]n\\s+tu\\s+constancia|Obtener\\s+constancia|Obtener\\s+la\\s+constancia/i',
  ).first();
-  await obtenerLocator.waitFor({ state: 'visible', timeout: 60_000 });
+  await obtenerLocator.waitFor({ state: 'visible', timeout: 120_000 });
  await obtenerLocator.scrollIntoViewIfNeeded();
  await obtenerLocator.click();
  await publicPage.waitForTimeout(1500);

  // Click "SERVICIO" → popup
-  const popupPromise = context.waitForEvent('page', { timeout: 60_000 });
+  const popupPromise = context.waitForEvent('page', { timeout: 120_000 });
  await publicPage.locator('text=/^\\s*SERVICIO\\s*$/i').first().click();
  const loginPage = await popupPromise;
  await loginPage.waitForLoadState('domcontentloaded');
@@ -56,7 +56,7 @@ export async function loginSatCsf(
  const efirmaBtn = loginPage
    .locator('button:has-text("e.firma"):not(:has-text("portable")), input[type="button"][value="e.firma" i], input[type="submit"][value="e.firma" i]')
    .first();
-  await efirmaBtn.waitFor({ state: 'visible', timeout: 30_000 });
+  await efirmaBtn.waitFor({ state: 'visible', timeout: 60_000 });
  await efirmaBtn.scrollIntoViewIfNeeded();
  await efirmaBtn.click();

@@ -82,7 +82,7 @@ export async function loginSatCsf(
        return rfc !== null && rfc.value.length >= 12;
      },
      null,
-      { timeout: 60_000 },
+      { timeout: 120_000 },
    );
    rfcPopulated = true;
  } catch {
@@ -121,7 +121,7 @@ export async function loginSatCsf(
  // Esperar a que salga del dominio de login y aterrice en el portal SAT
  await loginPage.waitForURL(
    url => url.toString().includes('wwwmat.sat.gob.mx/operacion/'),
-    { timeout: 60_000 },
+    { timeout: 120_000 },
  );
  await loginPage.waitForLoadState('networkidle').catch(() => undefined);
  await loginPage.waitForTimeout(2000);
--- a/apps/api/src/services/sat/sweep-stale-jobs.service.ts
+++ b/apps/api/src/services/sat/sweep-stale-jobs.service.ts
@@ -14,10 +14,10 @@ export interface SweepResult {
 }

 const DEFAULT_RUNNING_HOURS_BY_TYPE: Record<string, number> = {
-  initial: 8,
+  initial: 24,
  daily: 4,
  incremental: 2,
-  custom: 4,
+  custom: 24,
 };

 /**
--- a/apps/web/app/(dashboard)/dashboard/page.tsx
+++ b/apps/web/app/(dashboard)/dashboard/page.tsx
@@ -19,6 +19,8 @@ import {
  AlertTriangle,
  ShoppingCart,
  CheckSquare,
+  FileMinus,
+  FilePlus,
 } from 'lucide-react';
 import { cn } from '@horux/shared-ui';
 import { FiscalDisclaimer } from '@/components/fiscal-disclaimer';
@@ -118,6 +120,15 @@ export default function DashboardPage() {
    ? kpis?.ivaBalancePorRegimen?.find(r => r.regimenClave === regimenSeleccionado)?.monto || 0
    : kpis?.ivaBalance || 0;

+  // Notas de crédito
+  const ncsEmitidasDisplay = regimenSeleccionado
+    ? kpis?.ncsEmitidasPorRegimen?.find(r => r.regimenClave === regimenSeleccionado)?.monto || 0
+    : kpis?.ncsEmitidas || 0;
+
+  const ncsRecibidasDisplay = regimenSeleccionado
+    ? kpis?.ncsRecibidasPorRegimen?.find(r => r.regimenClave === regimenSeleccionado)?.monto || 0
+    : kpis?.ncsRecibidas || 0;
+
  const ivaAnterior = regimenSeleccionado
    ? kpisAnterior?.ivaBalancePorRegimen?.find(r => r.regimenClave === regimenSeleccionado)?.monto || 0
    : kpisAnterior?.ivaBalance || 0;
@@ -126,9 +137,15 @@ export default function DashboardPage() {
    ? Math.round(((ivaDisplay - ivaAnterior) / Math.abs(ivaAnterior)) * 10000) / 100
    : null;

-  const utilidadDisplay = ingresosDisplay - egresosDisplay;
-  const margenDisplay = ingresosDisplay > 0
-    ? Math.round((utilidadDisplay / ingresosDisplay) * 10000) / 100
+  // Utilidad ajustada por notas de crédito:
+  // Ingresos netos = Ingresos − NCs emitidas
+  // Egresos netos  = Gastos − NCs recibidas
+  // Utilidad neta  = Ingresos netos − Egresos netos
+  const ingresosNetosDisplay = ingresosDisplay - ncsEmitidasDisplay;
+  const egresosNetosDisplay = egresosDisplay - ncsRecibidasDisplay;
+  const utilidadDisplay = ingresosNetosDisplay - egresosNetosDisplay;
+  const margenDisplay = ingresosNetosDisplay > 0
+    ? Math.round((utilidadDisplay / ingresosNetosDisplay) * 10000) / 100
    : 0;

  const formatCurrency = (value: number) =>
@@ -203,7 +220,7 @@ export default function DashboardPage() {
        </div>

        {/* KPIs */}
-        <div className="grid gap-4 md:grid-cols-2 lg:grid-cols-4">
+        <div className="grid gap-4 md:grid-cols-2 lg:grid-cols-3">
          <KpiCard
            title={regimenSeleccionado ? `Ingresos del Mes (${regimenSeleccionado})` : 'Ingresos del Mes'}
            value={ingresosDisplay}
@@ -216,6 +233,13 @@ export default function DashboardPage() {
            }
            href={drillUrl('Ingresos del Mes - CFDIs', { bucket: 'ingresos' })}
          />
+          <KpiCard
+            title={regimenSeleccionado ? `NCs Emitidas (${regimenSeleccionado})` : 'NCs Emitidas'}
+            value={ncsEmitidasDisplay}
+            icon={<FileMinus className="h-4 w-4" />}
+            trend="neutral"
+            trendValue="Notas de crédito emitidas"
+          />
          <KpiCard
            title={regimenSeleccionado ? `Gastos del Mes (${regimenSeleccionado})` : 'Gastos del Mes'}
            value={egresosDisplay}
@@ -229,11 +253,18 @@ export default function DashboardPage() {
            href={drillUrl('Gastos del Mes - CFDIs', { bucket: 'gastos' })}
          />
          <KpiCard
-            title="Utilidad"
+            title={regimenSeleccionado ? `NCs Recibidas (${regimenSeleccionado})` : 'NCs Recibidas'}
+            value={ncsRecibidasDisplay}
+            icon={<FilePlus className="h-4 w-4" />}
+            trend="neutral"
+            trendValue="Notas de crédito recibidas"
+          />
+          <KpiCard
+            title={regimenSeleccionado ? `Utilidad Neta (${regimenSeleccionado})` : 'Utilidad Neta'}
            value={utilidadDisplay}
            icon={<Wallet className="h-4 w-4" />}
            trend={utilidadDisplay > 0 ? 'up' : 'down'}
-            trendValue={`${margenDisplay}% margen`}
+            trendValue={`${margenDisplay}% margen · incluye NCs`}
          />
          <KpiCard
            title={regimenSeleccionado ? `Balance IVA (${regimenSeleccionado})` : 'Balance IVA'}
@@ -252,7 +283,7 @@ export default function DashboardPage() {

        {/* Desglose por régimen */}
        {!regimenSeleccionado && kpis && (
-          (kpis.ingresosPorRegimen.length > 1 || kpis.egresosPorRegimen.length > 1 || kpis.ivaBalancePorRegimen.length > 1) && (
+          (kpis.ingresosPorRegimen.length > 1 || kpis.egresosPorRegimen.length > 1 || kpis.ivaBalancePorRegimen.length > 1 || kpis.ncsEmitidasPorRegimen.length > 1 || kpis.ncsRecibidasPorRegimen.length > 1) && (
          <div className="grid gap-4 md:grid-cols-2 3xl:grid-cols-3">
            {kpis.ingresosPorRegimen.length > 1 && (
              <Card>
@@ -316,6 +347,46 @@ export default function DashboardPage() {
                </CardContent>
              </Card>
            )}
+            {kpis.ncsEmitidasPorRegimen.length > 1 && (
+              <Card>
+                <CardHeader>
+                  <CardTitle className="text-base font-medium">NCs Emitidas por Regimen</CardTitle>
+                </CardHeader>
+                <CardContent>
+                  <div className="space-y-2">
+                    {kpis.ncsEmitidasPorRegimen.map((r) => (
+                      <div key={r.regimenClave} className="flex items-center justify-between py-2 border-b last:border-0">
+                        <div className="flex items-center gap-3">
+                          <span className="text-xs font-mono font-bold bg-muted px-2 py-1 rounded">{r.regimenClave}</span>
+                          <span className="text-sm">{r.regimenDescripcion}</span>
+                        </div>
+                        <span className="text-sm font-semibold">{formatCurrency(r.monto)}</span>
+                      </div>
+                    ))}
+                  </div>
+                </CardContent>
+              </Card>
+            )}
+            {kpis.ncsRecibidasPorRegimen.length > 1 && (
+              <Card>
+                <CardHeader>
+                  <CardTitle className="text-base font-medium">NCs Recibidas por Regimen</CardTitle>
+                </CardHeader>
+                <CardContent>
+                  <div className="space-y-2">
+                    {kpis.ncsRecibidasPorRegimen.map((r) => (
+                      <div key={r.regimenClave} className="flex items-center justify-between py-2 border-b last:border-0">
+                        <div className="flex items-center gap-3">
+                          <span className="text-xs font-mono font-bold bg-muted px-2 py-1 rounded">{r.regimenClave}</span>
+                          <span className="text-sm">{r.regimenDescripcion}</span>
+                        </div>
+                        <span className="text-sm font-semibold">{formatCurrency(r.monto)}</span>
+                      </div>
+                    ))}
+                  </div>
+                </CardContent>
+              </Card>
+            )}
          </div>
        ))}

--- a/apps/web/app/(dashboard)/usuarios/page.tsx
+++ b/apps/web/app/(dashboard)/usuarios/page.tsx
@@ -77,10 +77,14 @@ export default function UsuariosPage() {
  const deleteUsuario = useDeleteUsuario();

  const isDespacho = isDespachoTenant(currentUser?.tenantRfc);
-  const inviteRoles = isDespacho ? despachoInviteRoles : legacyInviteRoles;
+  const inviteRoles = isDespacho
+    ? (currentUser?.role === 'supervisor'
+        ? despachoInviteRoles.filter(r => r.value === 'cliente')
+        : despachoInviteRoles)
+    : legacyInviteRoles;
  const defaultInviteRole = isDespacho ? 'auxiliar' : 'visor';

-  const isAdmin = currentUser?.role === 'owner' || currentUser?.role === 'cfo';
+  const isAdmin = currentUser?.role === 'owner' || currentUser?.role === 'cfo' || currentUser?.role === 'supervisor';

  const [showInvite, setShowInvite] = useState(false);
  const [inviteForm, setInviteForm] = useState<{ email: string; nombre: string; role: UserInvite['role']; supervisorUserId?: string }>({
@@ -96,15 +100,18 @@ export default function UsuariosPage() {
  const [savingAccesos, setSavingAccesos] = useState(false);

  // Edit supervisor modal (para auxiliares)
-  const [editingSupervisorUser, setEditingSupervisorUser] = useState<{ id: string; nombre: string } | null>(null);
+  const [editingSupervisorUser, setEditingSupervisorUser] = useState<{ id: string; nombre: string; supervisorNombre?: string | null } | null>(null);
  const [selectedSupervisorId, setSelectedSupervisorId] = useState<string>('');
  const [savingSupervisor, setSavingSupervisor] = useState(false);

+  const [currentSupervisorNombre, setCurrentSupervisorNombre] = useState<string>('');
+
  const openEditSupervisor = async (userId: string, nombre: string) => {
    try {
-      const res = await apiClient.get<{ supervisorUserId: string | null }>(`/usuarios/${userId}/supervisor`);
+      const res = await apiClient.get<{ supervisorUserId: string | null; supervisorNombre: string | null }>(`/usuarios/${userId}/supervisor`);
      setSelectedSupervisorId(res.data.supervisorUserId ?? '');
-      setEditingSupervisorUser({ id: userId, nombre });
+      setCurrentSupervisorNombre(res.data.supervisorNombre ?? '');
+      setEditingSupervisorUser({ id: userId, nombre, supervisorNombre: res.data.supervisorNombre });
    } catch {
      alert('Error al cargar supervisor');
    }
@@ -483,7 +490,14 @@ export default function UsuariosPage() {
            <div className="space-y-2 py-2">
              {supervisores && supervisores.length > 0 ? (
                <Select value={selectedSupervisorId || 'none'} onValueChange={(v) => setSelectedSupervisorId(v === 'none' ? '' : v)}>
-                  <SelectTrigger><SelectValue placeholder="Selecciona un supervisor..." /></SelectTrigger>
+                  <SelectTrigger className="w-full">
+                    {(() => {
+                      if (!selectedSupervisorId || selectedSupervisorId === 'none') return <span className="text-muted-foreground">Sin supervisor asignado</span>;
+                      const s = supervisores?.find(x => x.userId === selectedSupervisorId);
+                      if (s) return <span>{s.nombre} — {s.email}</span>;
+                      return <span>{currentSupervisorNombre || editingSupervisorUser?.supervisorNombre || selectedSupervisorId}</span>;
+                    })()}
+                  </SelectTrigger>
                  <SelectContent>
                    <SelectItem value="none">Sin supervisor asignado</SelectItem>
                    {supervisores.map(s => (
@@ -491,6 +505,12 @@ export default function UsuariosPage() {
                        {s.nombre} — {s.email}
                      </SelectItem>
                    ))}
+                    {/* Si el supervisor actual no está en la lista de carteras, mostrarlo igual */}
+                    {selectedSupervisorId && !supervisores.some(s => s.userId === selectedSupervisorId) && (
+                      <SelectItem value={selectedSupervisorId}>
+                        {currentSupervisorNombre || editingSupervisorUser?.supervisorNombre || selectedSupervisorId}
+                      </SelectItem>
+                    )}
                  </SelectContent>
                </Select>
              ) : (
--- a/apps/web/components/contribuyente-selector.tsx
+++ b/apps/web/components/contribuyente-selector.tsx
@@ -33,6 +33,16 @@ export function ContribuyenteSelector() {
    }
  }, [contribuyentes, selectedContribuyenteId, setSelectedContribuyente]);

+  // Clear invalid selection (e.g. stale localStorage from another tenant/session)
+  useEffect(() => {
+    if (contribuyentes && contribuyentes.length > 0 && selectedContribuyenteId) {
+      const exists = contribuyentes.some(c => c.id === selectedContribuyenteId);
+      if (!exists) {
+        clearSelectedContribuyente();
+      }
+    }
+  }, [contribuyentes, selectedContribuyenteId, clearSelectedContribuyente]);
+
  if (isLoading || !contribuyentes || contribuyentes.length === 0) return null;
  if (pathname && HIDDEN_PATHS.some(p => pathname === p || pathname.startsWith(`${p}/`))) return null;

--- a/apps/web/components/layouts/sidebar.tsx
+++ b/apps/web/components/layouts/sidebar.tsx
@@ -59,7 +59,7 @@ const navigation: NavItem[] = [
  { name: 'Documentos', href: '/documentos', icon: FileCheck, feature: 'documentos' },
  { name: 'Carteras', href: '/carteras', icon: ClipboardList, roles: ['supervisor', 'auxiliar'] },
  { name: 'Contribuyentes', href: '/contribuyentes', icon: Building2, roles: ['owner', 'cfo', 'supervisor', 'contador', 'auxiliar'] },
-  { name: 'Usuarios', href: '/usuarios', icon: Users, roles: ['owner', 'cfo'] },
+  { name: 'Usuarios', href: '/usuarios', icon: Users, roles: ['owner', 'cfo', 'supervisor', 'auxiliar'] },
  { name: 'Tareas', href: '/tareas', icon: CheckSquare2, roles: ['owner', 'cfo', 'contador', 'auxiliar', 'supervisor'] },
  { name: 'Planes', href: '/configuracion/planes-despacho', icon: CreditCard, roles: ['owner', 'cfo'] },
  { name: 'Configuracion', href: '/configuracion', icon: Settings, roles: ['owner', 'cfo', 'supervisor', 'auxiliar', 'cliente'] },
--- a/apps/web/lib/api/contribuyentes.ts
+++ b/apps/web/lib/api/contribuyentes.ts
@@ -6,6 +6,7 @@ export interface Contribuyente {
  nombre: string;
  identificador: string;
  supervisorUserId: string | null;
+  supervisorNombre: string | null;
  active: boolean;
  createdAt: string;
  rfc: string;
--- a/packages/shared/src/types/dashboard.ts
+++ b/packages/shared/src/types/dashboard.ts
@@ -33,6 +33,10 @@ export interface KpiData {
  cfdisEmitidosPorRegimen: { regimen: string; total: number }[];
  cfdisRecibidos: number;
  cfdisRecibidosPorRegimen: { regimen: string; total: number }[];
+  ncsEmitidas: number;
+  ncsEmitidasPorRegimen: IngresoRegimen[];
+  ncsRecibidas: number;
+  ncsRecibidasPorRegimen: IngresoRegimen[];
 }

 export interface IngresosEgresosData {
Author	SHA1	Message	Date
Horux Dev	63908f9e9d	feat(sat): agregar cron de recuperación diaria a las 10:00 AM - Revisa si el sync diario falló o si hay CFDIs vigentes sin xml_original. - Si detecta facturas incompletas, lanza un sync initial con rango extendido (desde un mes antes de la factura incompleta más antigua hasta ayer). - Corre secuencialmente por contribuyente para no saturar al SAT. - Incluye soporte para tenants legacy sin contribuyentes.	2026-06-14 04:07:11 +00:00
Horux Dev	ed6cfed312	feat(dashboard): utilidad neta ajustada por notas de crédito - La utilidad del dashboard ahora descuenta NCs emitidas de ingresos y NCs recibidas de gastos. - El margen se calcula sobre ingresos netos. - Solo afecta la UI del dashboard; no modifica el backend ni otros reportes.	2026-06-13 21:04:25 +00:00
Horux Dev	ab6b76fcb8	ui(dashboard): reordenar scorecards de notas de crédito - NCs Emitidas ahora aparece después de Ingresos del Mes. - NCs Recibidas ahora aparece después de Gastos del Mes.	2026-06-13 20:54:40 +00:00
Horux Dev	b52ff875be	feat(dashboard): agregar scorecards de notas de crédito emitidas y recibidas - Extiende KpiData con ncsEmitidas, ncsEmitidasPorRegimen, ncsRecibidas y ncsRecibidasPorRegimen. - En getKpis se reutilizan calcularNcsEmitidasPorRegimen y calcularNcsRecibidasPorRegimen en paralelo. - En el dashboard se agregan dos KpiCard y su desglose por régimen.	2026-06-13 20:46:57 +00:00
Horux Dev	66d68c652c	Revert "feat(ui): make dashboard responsive for iPhone and mobile devices" This reverts commit `d3b326e`. The deployment caused reports of blank screens and 400 errors. Reverting to restore stable state while investigating root cause.	2026-06-13 20:16:04 +00:00
Horux Dev	d3b326e78c	feat(ui): make dashboard responsive for iPhone and mobile devices - Add Sheet primitive component for mobile drawers - Add MobileNav with hamburger menu for dashboard layout - Hide desktop sidebars on mobile; show mobile header - Make dashboard header responsive with stacked layout on small screens - Hide selector text on mobile, show icons only - Convert fixed-width filters to responsive widths (CFDI, Clientes, Admin, Documentos, Alertas) - Cap dialog widths to 95vw on mobile (CFDI viewer, Documentos, Reportes, Contribuyentes, Facturación) - Make calendar grid smaller and use single-letter weekdays on mobile - Update viewport to include viewport-fit=cover for Samsung safe areas	2026-06-13 19:55:06 +00:00
Horux Dev	b1eaf41681	fix(sat, payments, admin): multiple production fixes - sat sweep-stale-jobs: increase initial/custom sync threshold 8h→24h to prevent watchdog killing long historical syncs - sat-client: fix formatDateForSat same-day rejection by auto-adjusting fechaFin - sat-sync job: check fiel_contribuyente in addition to fiel_credentials for cron eligibility - database: extend pool idle cleanup from 5min to 12h to prevent pool closure during long syncs - webhook controller: auto-extend currentPeriodEnd on recurring MercadoPago payments - invoicing service: auto-send FacturAPI invoice by email after creation - admin-clientes: fix no-renovaciones detection to include expired trials and deleted subscriptions	2026-06-10 18:11:47 +00:00
Horux Dev	bd7e499ab7	fix(csf): retry con backoff, delays entre tenants, timeouts aumentados	2026-06-01 23:43:43 +00:00
Horux Dev	44144ebf9d	fix(contribuyente-selector): limpiar selección inválida de localStorage	2026-06-01 20:13:36 +00:00
Horux Dev	314a74982c	fix(regimen): fallback a tenant/contribuyentes cuando un contribuyente no tiene regimen_fiscal	2026-06-01 20:07:59 +00:00
Horux Dev	76d3f00f29	debug(alertas): logging en generador y endpoint /automaticas; wrap cada alerta en try/catch	2026-06-01 19:59:57 +00:00
Horux Dev	214410d2fb	fix(alertas): combinar regímenes de contribuyentes cuando no hay config a nivel tenant	2026-06-01 17:55:01 +00:00
Horux Dev	199922272f	fix(sidebar): mostrar Usuarios para supervisor y auxiliar	2026-05-29 22:06:01 +00:00
Horux Dev	6e54efe5e4	feat(usuarios): supervisor puede invitar usuarios cliente - Backend inviteUsuario: permite owner, cfo y supervisor - Backend valida que supervisor solo pueda invitar rol cliente - Backend addClienteAcceso: supervisor solo puede asignar contribuyentes que tenga visibles (getEntidadesVisibles) - Frontend: supervisor ve botón Invitar Usuario y solo puede seleccionar rol Cliente en el dropdown	2026-05-29 21:32:12 +00:00
Horux Dev	5dd53cebac	chore(usuarios): limpiar debug hardcodeado de supervisorNombre	2026-05-29 19:27:59 +00:00
Horux Dev	0de0df9357	fix(usuarios): mostrar nombre del supervisor en dropdown de forma robusta - Backend: getSupervisor devuelve supervisorNombre desde Prisma - Frontend: usa SelectTrigger con renderizado manual del label seleccionado en lugar de depender de SelectValue, que no siempre encontraba el texto del SelectItem cuando el supervisor no estaba en la lista de carteras	2026-05-29 19:03:36 +00:00
Horux Dev	20fb8ea2db	debug(usuarios): agregar console.log para diagnosticar supervisorNombre	2026-05-29 18:10:33 +00:00
Horux Dev	8c9a7b73dc	fix(usuarios): agregar import faltante de prisma en getSupervisor	2026-05-29 17:43:13 +00:00
Horux Dev	910c50d870	fix(usuarios): mostrar nombre del supervisor al editar auxiliar - Backend getSupervisor ahora devuelve supervisorNombre buscando en Prisma - Frontend usa supervisorNombre para mostrar en Select cuando el supervisor no está en la lista de carteras/supervisores	2026-05-29 17:24:18 +00:00
Horux Dev	2f49fdc9b7	fix(contribuyentes): agregar supervisorNombre al tipo Contribuyente	2026-05-29 17:12:58 +00:00