string> = {
orderConfirmed: (v) =>
`Hola, ${v.CLIENTE_NOMBRE} 👋
` +
`| ✅ Pedido confirmado ${v.NRO_PEDIDO} |
| 🚚 Método de entrega ${v.METODO_ENTREGA} |
`,
orderInvoiced: (v) =>
`Hola, ${v.CLIENTE_NOMBRE} 👋
` +
`| 📄 Factura emitida ${v.NRO_PEDIDO} | 📄 |
| Total facturado ${v.TOTAL} | ✅ Pagado |
| 📎 Archivo adjunto Tu factura en formato PDF está adjunta a este correo. Guardala o imprimila cuando quieras. |
`,
orderShipped: (v) =>
`¡Tu pedido está en camino, ${v.CLIENTE_NOMBRE}! 🎉
` +
`✅ Pedido | ✅ Confirmado | 🚚 En camino | 🏠 Entregado |
|
| 📍 Dirección de entrega ${v.DIRECCION_ENTREGA} |
| 🚚 Método ${v.METODO_ENTREGA} |
`,
orderCancelled: (v) =>
`Hola, ${v.CLIENTE_NOMBRE}
` +
`| ❌ Pedido cancelado ${v.NRO_PEDIDO} |
| ¿QUÉ SIGUE? |
🔄 Reintegro: Si realizaste algún pago, será procesado en los próximos días hábiles. 🛒 Nuevo pedido: Podés volver a la tienda y realizar tu compra cuando quieras. 💬 ¿Necesitás ayuda? Respondé este correo y te asistimos de inmediato. |
| 📞 ¿Hablamos? Respondé este correo o contactanos directamente. Estamos para ayudarte. |
`,
newOrderAdmin: (v) =>
`| 🔔 Nuevo pedido recibido ${v.NRO_PEDIDO} | 🛍️ |
👤 Datos del cliente
| CAMPO | VALOR |
| Nombre | ${v.CLIENTE_NOMBRE} |
| Email | ${v.CLIENTE_EMAIL} |
| Teléfono | ${v.CLIENTE_TELEFONO} |
📦 Productos
| PRODUCTO | CANT. | P. UNIT. | SUBTOTAL |
${v.ITEMS}| Total del pedido | ${v.TOTAL} |
🚚 ${v.METODO_ENTREGA} 📍 ${v.DIRECCION_ENTREGA} |
`,
};
function formatItems(items: any[]): string {
const gs = (n: number) => `Gs. ${n.toLocaleString('es-PY')}`;
return items
.map((i) => {
const name = i.name ?? i.productName ?? 'Producto';
const qty = Number(i.quantity ?? 1);
const unitPrice = Number(i.unitPrice ?? i.price ?? 0);
const subtotal = Number(i.lineTotal ?? unitPrice * qty);
const imgUrl: string = i.imageUrl ?? '';
const imgCell = imgUrl
? ` | `
: `📦 | `;
return (
`${imgCell}` +
`| ${name} | ` +
`× ${qty} | ` +
`${gs(unitPrice)} | ` +
`${gs(subtotal)} |
`
);
})
.join('');
}
function formatTotal(totals: any): string {
const total = Number(totals?.total ?? totals?.subtotal ?? 0);
return `Gs. ${total.toLocaleString('es-PY')}`;
}
@Injectable()
export class EcommerceNotificationsService {
private readonly logger = new Logger(EcommerceNotificationsService.name);
constructor(
private readonly prisma: PrismaService,
private readonly mail: MailService,
) {}
/**
* Carga la config de notificaciones. Los pedidos reales usan la versión PUBLICADA;
* el mail de prueba usa el borrador (`borrador: true`) para poder ver una plantilla
* antes de publicarla.
*/
private async loadNotificationsConfig(empresaId: string, opts: { borrador?: boolean } = {}): Promise {
const row: { notifications_config?: unknown; nombre_comercial?: string | null } | null = opts.borrador
? await this.prisma.ecommerce_config.findUnique({
where: { empresa_id: empresaId },
select: { notifications_config: true, nombre_comercial: true },
})
: await leerConfigPublicada(this.prisma, empresaId, ['notifications_config', 'nombre_comercial'] as const);
const def = (DEFAULT_STORE_CONFIG as any).notifications;
const cfg = (row?.notifications_config as any) ?? {};
return {
tiendaNombre: row?.nombre_comercial ?? 'La tienda',
adminEmail: cfg.adminEmail ?? def.adminEmail ?? '',
orderConfirmed: { ...def.orderConfirmed, ...(cfg.orderConfirmed ?? {}) },
orderInvoiced: { ...def.orderInvoiced, ...(cfg.orderInvoiced ?? {}) },
orderShipped: { ...def.orderShipped, ...(cfg.orderShipped ?? {}) },
orderCancelled: { ...def.orderCancelled, ...(cfg.orderCancelled ?? {}) },
newOrderAdmin: { ...def.newOrderAdmin, ...(cfg.newOrderAdmin ?? {}) },
};
}
private buildVars(session: any, tiendaNombre: string): OrderNotificationVars {
const customer = (session.customer_snapshot as any) ?? {};
const delivery = (session.delivery_snapshot as any) ?? {};
const items = (session.items_snapshot as any[]) ?? [];
const totals = (session.totals_snapshot as any) ?? {};
const direccion = [delivery.address, delivery.city, delivery.district, delivery.department]
.filter(Boolean)
.join(', ');
const metodo = delivery.methodName ?? (delivery.type === 'pickup' ? 'Retiro en tienda' : 'Delivery');
return {
NRO_PEDIDO: session.codigo ?? '',
CLIENTE_NOMBRE: customer.name ?? 'Cliente',
CLIENTE_EMAIL: customer.email ?? '',
CLIENTE_TELEFONO: customer.phone ?? '',
TOTAL: formatTotal(totals),
ITEMS: formatItems(items),
METODO_ENTREGA: metodo,
DIRECCION_ENTREGA: direccion || 'No especificada',
TIENDA_NOMBRE: tiendaNombre,
};
}
private async sendIfEnabled(
tpl: { enabled: boolean; subject: string; body: string },
to: string,
vars: OrderNotificationVars,
tplKey: string,
pdfAttachment?: { filename: string; content: Buffer },
): Promise {
// Cada envío deja rastro en el log: antes un mail de pedido real no se registraba
// ni al salir ni al fallar, y no había forma de saber si el comprador lo recibió.
if (!tpl.enabled) {
this.logger.log(`Email ${tplKey} del pedido ${vars.NRO_PEDIDO} omitido: la plantilla está desactivada.`);
return;
}
if (!to) {
this.logger.warn(`Email ${tplKey} del pedido ${vars.NRO_PEDIDO} omitido: no hay destinatario.`);
return;
}
const subject = render(tpl.subject, vars);
const structureHtml = EMAIL_STRUCTURE_BUILDERS[tplKey]?.(vars) ?? '';
const bodyHtml = render(tpl.body, vars);
const html = structureHtml + (bodyHtml ? `${bodyHtml}
` : '');
try {
await this.mail.sendStoreEmail({ to, subject, html, pdfAttachment });
} catch (err) {
this.logger.error(`Email ${tplKey} del pedido ${vars.NRO_PEDIDO} a ${to} falló: ${(err as Error).message}`);
throw err;
}
this.logger.log(`Email ${tplKey} del pedido ${vars.NRO_PEDIDO} enviado a ${to}.`);
}
/**
* Envía un email de PRUEBA de una plantilla con datos de ejemplo, para que el
* comercio vea cómo llega antes de que haya pedidos reales. Va al email indicado
* o, si no, al del administrador configurado.
*/
async sendTestEmail(empresaId: string, tplKey: string, toEmail?: string): Promise<{ to: string }> {
const cfg = await this.loadNotificationsConfig(empresaId, { borrador: true });
const plantillas: Record = {
orderConfirmed: cfg.orderConfirmed,
orderInvoiced: cfg.orderInvoiced,
orderShipped: cfg.orderShipped,
orderCancelled: cfg.orderCancelled,
newOrderAdmin: cfg.newOrderAdmin,
};
const tpl = plantillas[tplKey];
if (!tpl) throw new BadRequestException('Plantilla de notificación desconocida.');
const to = (toEmail?.trim() || cfg.adminEmail || '').trim();
if (!to) {
throw new BadRequestException(
'Indicá un email de destino o configurá el email del administrador para enviar la prueba.',
);
}
const vars: OrderNotificationVars = {
NRO_PEDIDO: 'ECOM-2026-0001',
CLIENTE_NOMBRE: 'Cliente de Prueba',
CLIENTE_EMAIL: to,
CLIENTE_TELEFONO: '0981 000 000',
TOTAL: 'Gs. 250.000',
ITEMS: '2 × Producto de ejemplo',
METODO_ENTREGA: 'Delivery programado',
DIRECCION_ENTREGA: 'Asunción, Paraguay',
TIENDA_NOMBRE: cfg.tiendaNombre,
};
const subject = `[PRUEBA] ${render(tpl.subject, vars)}`;
const structureHtml = EMAIL_STRUCTURE_BUILDERS[tplKey]?.(vars) ?? '';
const bodyHtml = render(tpl.body, vars);
const html = structureHtml + (bodyHtml ? `${bodyHtml}
` : '');
await this.mail.sendStoreEmail({ to, subject, html });
this.logger.log(`Email de prueba (${tplKey}) enviado a ${to} para empresa ${empresaId}`);
return { to };
}
/** Pedido confirmado por el cliente (checkout creado). */
async onOrderCreated(empresaId: string, sessionId: string): Promise {
try {
const [session, cfg] = await Promise.all([
this.prisma.ecommerce_checkout_session.findUnique({ where: { id: sessionId } }),
this.loadNotificationsConfig(empresaId),
]);
if (!session) return;
const vars = this.buildVars(session, cfg.tiendaNombre);
const customerEmail = (session.customer_snapshot as any)?.email ?? '';
await Promise.allSettled([
this.sendIfEnabled(cfg.orderConfirmed, customerEmail, vars, 'orderConfirmed'),
this.sendIfEnabled(cfg.newOrderAdmin, cfg.adminEmail, vars, 'newOrderAdmin'),
]);
} catch (err) {
this.logger.warn(`onOrderCreated failed for session ${sessionId}: ${(err as Error).message}`);
}
}
/** Pedido listo/despachado (estado → listo). */
async onOrderShipped(empresaId: string, sessionId: string): Promise {
try {
const [session, cfg] = await Promise.all([
this.prisma.ecommerce_checkout_session.findUnique({ where: { id: sessionId } }),
this.loadNotificationsConfig(empresaId),
]);
if (!session) return;
const vars = this.buildVars(session, cfg.tiendaNombre);
const customerEmail = (session.customer_snapshot as any)?.email ?? '';
await this.sendIfEnabled(cfg.orderShipped, customerEmail, vars, 'orderShipped');
} catch (err) {
this.logger.warn(`onOrderShipped failed for session ${sessionId}: ${(err as Error).message}`);
}
}
/** Pedido cancelado. */
async onOrderCancelled(empresaId: string, sessionId: string): Promise {
try {
const [session, cfg] = await Promise.all([
this.prisma.ecommerce_checkout_session.findUnique({ where: { id: sessionId } }),
this.loadNotificationsConfig(empresaId),
]);
if (!session) return;
const vars = this.buildVars(session, cfg.tiendaNombre);
const customerEmail = (session.customer_snapshot as any)?.email ?? '';
await this.sendIfEnabled(cfg.orderCancelled, customerEmail, vars, 'orderCancelled');
} catch (err) {
this.logger.warn(`onOrderCancelled failed for session ${sessionId}: ${(err as Error).message}`);
}
}
/**
* Pedido facturado — llamado desde facturas.service al crear factura
* vinculada a un pedido ERP que proviene de ecommerce.
*/
async onOrderInvoiced(
empresaId: string,
pedidoId: string,
pdfAttachment?: { filename: string; content: Buffer },
): Promise {
try {
const session = await this.prisma.ecommerce_checkout_session.findFirst({
where: { empresa_id: empresaId, pedido_id: pedidoId },
});
if (!session) return; // pedido no proviene de ecommerce
const cfg = await this.loadNotificationsConfig(empresaId);
const vars = this.buildVars(session, cfg.tiendaNombre);
const customerEmail = (session.customer_snapshot as any)?.email ?? '';
await this.sendIfEnabled(cfg.orderInvoiced, customerEmail, vars, 'orderInvoiced', pdfAttachment);
} catch (err) {
this.logger.warn(`onOrderInvoiced failed for pedido ${pedidoId}: ${(err as Error).message}`);
}
}
}