refactor(universign): replace sage_client with email_queue for PDF generation
This commit is contained in:
parent
9f5ccb8e7b
commit
19811a2290
1 changed files with 8 additions and 11 deletions
|
|
@ -6,7 +6,8 @@ from typing import List, Optional
|
||||||
from datetime import datetime
|
from datetime import datetime
|
||||||
from pydantic import BaseModel, EmailStr
|
from pydantic import BaseModel, EmailStr
|
||||||
import logging
|
import logging
|
||||||
|
from api import normaliser_type_doc
|
||||||
|
from email_queue import email_queue
|
||||||
from database import get_session
|
from database import get_session
|
||||||
from database import (
|
from database import (
|
||||||
UniversignTransaction,
|
UniversignTransaction,
|
||||||
|
|
@ -19,6 +20,10 @@ from services.universign_sync import UniversignSyncService
|
||||||
from config.config import settings
|
from config.config import settings
|
||||||
from utils.universign_status_mapping import get_status_message
|
from utils.universign_status_mapping import get_status_message
|
||||||
|
|
||||||
|
from database.models.email import EmailLog
|
||||||
|
from database.enum.status import StatutEmail
|
||||||
|
|
||||||
|
|
||||||
logger = logging.getLogger(__name__)
|
logger = logging.getLogger(__name__)
|
||||||
router = APIRouter(prefix="/universign", tags=["Universign"])
|
router = APIRouter(prefix="/universign", tags=["Universign"])
|
||||||
|
|
||||||
|
|
@ -74,11 +79,8 @@ async def create_signature(
|
||||||
request: CreateSignatureRequest, session: AsyncSession = Depends(get_session)
|
request: CreateSignatureRequest, session: AsyncSession = Depends(get_session)
|
||||||
):
|
):
|
||||||
try:
|
try:
|
||||||
# === 1. GÉNÉRATION PDF ===
|
pdf_bytes = email_queue._generate_pdf(
|
||||||
from sage_client import sage_client
|
request.doc_id, normaliser_type_doc(request.type_doc)
|
||||||
|
|
||||||
pdf_bytes = sage_client.generer_pdf_document(
|
|
||||||
request.sage_document_id, request.sage_document_type.value
|
|
||||||
)
|
)
|
||||||
|
|
||||||
if not pdf_bytes:
|
if not pdf_bytes:
|
||||||
|
|
@ -217,11 +219,6 @@ async def create_signature(
|
||||||
|
|
||||||
await session.commit()
|
await session.commit()
|
||||||
|
|
||||||
# === 4. ENVOI EMAIL (via email_queue) ===
|
|
||||||
from email_queue import email_queue
|
|
||||||
from database.models.email import EmailLog
|
|
||||||
from database.enum.status import StatutEmail
|
|
||||||
|
|
||||||
email_log = EmailLog(
|
email_log = EmailLog(
|
||||||
id=str(uuid.uuid4()),
|
id=str(uuid.uuid4()),
|
||||||
destinataire=request.signer_email,
|
destinataire=request.signer_email,
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue