""" email_service.py — e-mails transactionnels Meeconic (SMTP TLS 587). Deux envois : - send_order_confirmation() → reçu HTML à la famille après commande - send_company_notification()→ alerte interne à l'équipe Meeconic Variables .env (service transactionnel recommandé : Brevo ou Resend — PAS Gmail) : SMTP_HOST (ex. smtp-relay.brevo.com / smtp.resend.com) SMTP_PORT (587) SMTP_USER (login SMTP) SMTP_PASS (clé SMTP, pas le mot de passe du compte) SMTP_FROM ("Meeconic ") — défaut SMTP_USER COMPANY_NOTIFICATION_EMAIL (destinataire des alertes internes) Si SMTP n'est pas configuré, les fonctions renvoient False sans lever d'erreur. """ import html import logging import os from email import encoders from email.mime.base import MIMEBase from email.mime.multipart import MIMEMultipart from email.mime.text import MIMEText import aiosmtplib log = logging.getLogger("meeconic.email") def _cfg(): host = os.getenv("SMTP_HOST", "smtp-relay.brevo.com") port = int(os.getenv("SMTP_PORT", "587")) user = os.getenv("SMTP_USER", "").strip() # les mots de passe d'application s'affichent parfois avec des espaces pw = os.getenv("SMTP_PASSWORD", os.getenv("SMTP_PASS", "")).replace(" ", "") sender = os.getenv("SMTP_FROM", os.getenv("EMAIL_FROM", user)).strip() return host, port, user, pw, sender def is_configured() -> bool: _, _, user, pw, _ = _cfg() return bool(user and pw) def _items_rows(items: list[dict]) -> str: rows = "" for it in items: label = html.escape(str(it.get("format_label", ""))) opt = html.escape(f"{it.get('job_label') or ''}") if it.get("is_magic") else "" qty = it.get("quantity", 1) price = it.get("unit_price", 0) * qty rows += ( f"{label}" f"{opt}" f"{qty}" f"{price:.0f} €" ) return rows def _confirmation_html(name: str, order_id: str, family_code: str, items: list[dict], total: float, has_digital: bool = False, portal_url: str = "", attached: int = 0) -> str: name, family_code = html.escape(name or ""), html.escape(family_code) dl = "" if has_digital: link = html.escape(f"{portal_url.rstrip('/')}/?code={family_code}") if portal_url else "" cta = f' Ouvrir mon espace' if link else "" # Attached originals are the real delivery; the portal link stays as the permanent fallback. lead = (f"Vos photos numériques HD sont jointes à cet e-mail ({attached}). " "Vous pouvez aussi les retrouver à tout moment" if attached else "Vos photos numériques HD sont disponibles au téléchargement") dl = ("

" + lead + " dans votre espace famille (rubrique « Mes commandes »)." + cta + "

") return f"""

{dl}

MEECONIC

L'instant d'école

Commande confirmée !

Bonjour,

Votre commande {order_id[:8].upper()} a bien été reçue.

Code famille

{family_code}

{_items_rows(items)}

Format	Option	Qté	Prix
Total payé			{total:.0f} €

Livraison des tirages en classe sous 5 à 10 jours ouvrés. Merci de votre confiance.

""" async def _send(to: str, subject: str, html: str, attachments: list[tuple[str, bytes]] | None = None) -> bool: if not is_configured(): log.warning("SMTP not configured — e-mail skipped (%s)", subject) return False host, port, user, pw, sender = _cfg() try: msg = MIMEMultipart("mixed" if attachments else "alternative") msg["Subject"] = subject msg["From"] = sender msg["To"] = to msg.attach(MIMEText(html, "html", "utf-8")) for fname, data in attachments or []: part = MIMEBase("application", "octet-stream") part.set_payload(data) encoders.encode_base64(part) part.add_header("Content-Disposition", "attachment", filename=fname) msg.attach(part) await aiosmtplib.send(msg, hostname=host, port=port, username=user, password=pw, start_tls=True) log.info("E-mail sent -> %s (%s)", to, subject) return True except Exception as e: log.error("E-mail sending failed -> %s: %s", to, e) return False async def send_order_confirmation(to: str, name: str, order_id: str, family_code: str, items: list[dict], total: float, has_digital: bool = False, portal_url: str = "", attachments: list[tuple[str, bytes]] | None = None) -> bool: """Reçu de commande envoyé à la famille, avec les originaux HD en pièces jointes s'il y en a.""" subject = f"Meeconic — Commande confirmée #{order_id[:8].upper()}" body = _confirmation_html(name, order_id, family_code, items, total, has_digital, portal_url, attached=len(attachments or [])) if await _send(to, subject, body, attachments): return True if not attachments: return False # The size limit is measured on the raw files but the message travels base64-encoded (+33 %), so a # server with a lower cap can refuse it. The confirmation must still arrive: resend it without the # files, the body then points to the portal download instead of claiming they are attached. log.warning("E-mail with %d attachment(s) refused for %s — resending without them", len(attachments), order_id) body = _confirmation_html(name, order_id, family_code, items, total, has_digital, portal_url, attached=0) return await _send(to, subject, body) async def send_company_notification(order_id: str, family_code: str, customer_name: str, customer_email: str, items: list[dict], total: float, to: str = "") -> bool: """Alerte interne à l'équipe Meeconic (COMPANY_NOTIFICATION_EMAIL).""" to = (to or os.getenv("COMPANY_NOTIFICATION_EMAIL", "")).strip() if not to: return False rows = _items_rows(items) family_code_h, name_h, email_h = html.escape(family_code), html.escape(customer_name or ""), html.escape(customer_email or "") body = f"""

Notification interne

🛒 Nouvelle commande

Code famille

{family_code_h}

Classe : {name_h} — {email_h}

{rows}

Total : {total:.0f} €

ID commande : {order_id}

""" return await _send(to, f"🛒 Nouvelle commande — {family_code} — {total:.0f} €", body) async def send_payment_failed(to: str, name: str, order_id: str, portal_url: str = "") -> bool: """Prévient la famille que son paiement a échoué (elle peut recommencer).""" link = f"

Retourner sur le portail

" if portal_url else "" body = (f"" f"

Bonjour,

" f"

Le paiement de votre commande {order_id[:8].upper()} n'a pas abouti. " f"Aucun montant n'a été débité. Vous pouvez recommencer votre commande depuis le portail.

{link}" f"

— L'équipe Meeconic

") return await _send(to, f"Meeconic — Paiement non abouti #{order_id[:8].upper()}", body)