# cases/email_notifications.py
"""
Envoi des notifications email lors des modifications de dossiers.
Appelé depuis le signal post_save de Case.
"""
import logging
import threading
from django.conf import settings
from django.core.mail import EmailMultiAlternatives
logger = logging.getLogger(__name__)
TRACKED_FIELDS = {
"status": "Statut",
"priority": "Priorité",
"title": "Titre",
"balance_amount": "Solde",
"due_date": "Échéance",
"assigned_to_id": "Agent responsable",
"creditor_id": "Créancier",
"portfolio_id": "Portefeuille",
}
STATUS_LABELS = {
"open": "Ouvert",
"in_progress": "En cours",
"on_hold": "En attente",
"closed": "Clôturé",
}
PRIORITY_LABELS = {
"low": "Faible",
"medium": "Moyenne",
"high": "Élevée",
"urgent": "Urgente",
}
def _human(field: str, value) -> str:
if value is None:
return "—"
if field == "status":
return STATUS_LABELS.get(str(value), str(value))
if field == "priority":
return PRIORITY_LABELS.get(str(value), str(value))
return str(value)
def _build_html(case, changes: dict, actor_name: str) -> str:
rows = ""
for field, vals in changes.items():
label = TRACKED_FIELDS.get(field, field)
old = _human(field, vals["old"])
new = _human(field, vals["new"])
rows += f"""
{label}
{old}
{new}
"""
return f"""
Dossier mis à jour
Référence : {case.reference}
Le dossier {case.title} a été modifié
par {actor_name}.
Champ
Avant
Après
{rows}
Ceci est un message automatique — merci de ne pas y répondre directement.
ACX · Gestion de recouvrement
"""
def _send_notification(case_id: int, changes: dict, actor_name: str):
"""Envoi réel — exécuté dans un thread daemon."""
try:
from cases.models import Case
case = (
Case.objects
.select_related("customer", "creditor", "debtor")
.get(pk=case_id)
)
except Exception:
return
recipients: list[str] = []
if case.notify_customer and case.customer and case.customer.email:
recipients.append(case.customer.email)
if case.notify_creditor:
cred_email = None
if case.creditor_id and case.creditor and case.creditor.email:
cred_email = case.creditor.email
elif not case.creditor_id and case.customer and case.customer.email:
# créancier = client, email déjà ajouté si notify_customer
cred_email = None
if cred_email and cred_email not in recipients:
recipients.append(cred_email)
if case.notify_debtor and case.debtor and case.debtor.email:
email = case.debtor.email
if email not in recipients:
recipients.append(email)
if not recipients:
return
subject = f"[ACX] Mise à jour dossier {case.reference}"
html = _build_html(case, changes, actor_name)
text = (
f"Dossier {case.reference} — {case.title}\n"
f"Modifié par : {actor_name}\n\n"
+ "\n".join(
f"- {TRACKED_FIELDS.get(f, f)} : {_human(f, v['old'])} → {_human(f, v['new'])}"
for f, v in changes.items()
)
)
from_email = getattr(settings, "DEFAULT_FROM_EMAIL", "noreply@acx.app")
try:
msg = EmailMultiAlternatives(subject, text, from_email, recipients)
msg.attach_alternative(html, "text/html")
msg.send(fail_silently=True)
logger.info("Notification case %s envoyée à %s", case.reference, recipients)
except Exception as exc:
logger.warning("Notification case %s échouée: %s", case.reference, exc)
def send_case_change_notifications(case_id: int, changes: dict, actor_name: str):
"""Lance l'envoi en arrière-plan pour ne pas bloquer la réponse API."""
if not changes:
return
t = threading.Thread(
target=_send_notification,
args=(case_id, changes, actor_name),
daemon=True,
)
t.start()