-
✅ Note vérifiée — paiement à valider
+ note.email,
+ `❌ Note refusée — corrections demandées : ${note.reference}`,
+ `
+
+
❌ Votre note a été refusée par la Finance
+
${lignesRefusees.length} ligne${lignesRefusees.length > 1 ? 's' : ''} à corriger
-
Bonjour ${val.prenom} ${val.nom},
-
La note ${note.reference} de ${note.prenom} ${note.nom} (${montantFormate} €)
- a été vérifiée par ${verificateurNom} et est prête pour le paiement.
- ${commentaire ? `
- 💬 Commentaire vérificateur : ${commentaire}
` : ''}
-
+
Bonjour ${note.prenom} ${note.nom},
+
Votre note ${note.reference} (${montantFormate} €) a été refusée par ${verificateurNom} (Vérificateur Finance).
+
+
+
+
+ Lignes à corriger (${lignesRefusees.length})
+
+
- | Référence | ${note.reference} |
- | Collaborateur | ${note.prenom} ${note.nom} |
- | Montant | ${montantFormate} € |
- | Campus | ${note.campus || '—'} |
+
+
+ | N° |
+ Ligne |
+ Motif |
+
+
+ ${tableLignesHtml}
-
`
);
- } catch (e) { console.error('Email ValidateurFinance:', e.message); }
+ } catch (e) { console.error('Email collab refus:', e.message); }
+
+ // Notif N1
+ if (note.n1Id && note.emailN1) {
+ try {
+ await creerNotification({
+ destinataireId: note.n1Id,
+ destinataireEmail: note.emailN1,
+ type: 'refus',
+ titre: `⚠️ Note ${note.reference} refusée par la Finance`,
+ message: `La note ${note.reference} de ${note.prenom} ${note.nom} a été refusée par ${verificateurNom} (${lignesRefusees.length} ligne${lignesRefusees.length > 1 ? 's' : ''} à corriger).`,
+ noteId
+ });
+ notifiedN1 = true;
+ } catch (e) { console.error('Notif BDD N1 refus:', e.message); }
+
+ try {
+ await sendMailGraph(
+ note.emailN1,
+ `⚠️ Note ${note.reference} refusée par la Finance`,
+ `
+
+
⚠️ Note refusée par la Finance
+
+
+
Bonjour ${note.prenomN1} ${note.nomN1},
+
La note ${note.reference} de ${note.prenom} ${note.nom} que vous aviez validée a été refusée par ${verificateurNom} (Vérificateur Finance).
+
+
${lignesRefusees.length} ligne${lignesRefusees.length > 1 ? 's' : ''} à corriger
+
+ ${lignesRefusees.map(r => {
+ const ligne = lignesData[r.index] || {};
+ const label = ligne.libelle || ligne.categorie || `Ligne ${r.index + 1}`;
+ return `| ${label} | ${r.motif.trim()} |
`;
+ }).join('')}
+
+
+
${note.prenom} ${note.nom} a été notifié et doit corriger uniquement les lignes listées.
+
+
`
+ );
+ } catch (e) { console.error('Email N1 refus:', e.message); }
+ }
}
-
- // Notifier aussi le collaborateur
- try {
- await creerNotification({
- destinataireId: note.collaborateurId,
- destinataireEmail: note.email,
- type: 'paiement',
- titre: `Note ${note.reference} en cours de traitement`,
- message: `Votre note ${note.reference} (${montantFormate} €) a été vérifiée et est en attente de validation du paiement.`,
- noteId: noteId
- });
- } catch (e) { console.error('Notif collab vérification:', e.message); }
-
- res.json({ success: true, statut: 'verifie', notifiesCount: validateurs.recordset.length });
-
+
+ res.json({
+ success: true,
+ statut: 'refuse_verif',
+ nbLignesRefusees: lignesRefusees.length,
+ notifiedCollab,
+ notifiedN1
+ });
+
} catch (error) {
- console.error('Erreur PUT verificateur/notes/:id/verifier:', error.message);
+ try { await transaction.rollback(); } catch { }
+ console.error('Erreur POST /verificateur/notes/:id/refuser:', error.message);
res.status(500).json({ error: error.message });
}
});
-// GET /api/verificateur/historique
app.get('/api/verificateur/historique', authenticateToken, async (req, res) => {
if (!hasAnyRole(req.user, 'VerificateurFinance', 'Finance', 'superUtilisateur'))
return res.status(403).json({ error: 'Accès refusé' });
-
+
try {
const request = pool.request().input('verificateurId', sql.Int, req.user.id);
-
+
let campusWhere = '';
if (req.user.campus && !hasAnyRole(req.user, 'superUtilisateur')) {
const campusCode = normalizeCampus(req.user.campus);
@@ -923,62 +1487,71 @@ app.get('/api/verificateur/historique', authenticateToken, async (req, res) => {
campusWhere = 'AND c.campus LIKE @campus';
}
}
-
+
const result = await request.query(`
SELECT
- n.id, n.reference, n.libelle, n.montant,
+ n.id, n.reference, n.libelle, n.montant, n.statut,
n.dateVerification, n.commentaireVerification,
n.lignesJson, n.fichiers,
c.nom + ' ' + c.prenom AS collaborateur,
- c.campus, c.departement,
- (SELECT COUNT(*) FROM JustificatifsNonConformes j
- WHERE j.noteDeFraisId = n.id) AS nbNonConformes
+ c.campus, c.departement
FROM NoteDeFrais n
JOIN CollaborateurAD c ON c.id = n.collaborateurId
WHERE n.verificateurFinanceId = @verificateurId
- AND n.statut IN ('verifie', 'paiementenattente', 'payee')
+ AND n.statut IN ('verifie', 'paiementenattente', 'payee', 'refuse_verif',
+ 'refuse_verif_archive', 'non_conforme_verif', 'non_conforme_archive')
${campusWhere}
ORDER BY n.dateVerification DESC
`);
-
- const notesAvecNC = await Promise.all(result.recordset.map(async row => {
- const ncResult = await pool.request()
- .input('noteId', sql.Int, row.id)
- .query(`
- SELECT fileName, motif, statut, dateSignalement
- FROM JustificatifsNonConformes
- WHERE noteDeFraisId = @noteId
- ORDER BY dateSignalement DESC
- `);
-
- const nonConformes = ncResult.recordset;
-
- let nbJustifs = 0;
- try {
- const fichiers = JSON.parse(row.fichiers || '[]');
- const SYSTEME = ['soumission', 'resoumission', 'recap-paiement', 'recap', 'signe-approuve', 'signeapprouve', 'signe_approuve'];
- nbJustifs = fichiers.filter(f =>
- !SYSTEME.some(kw => (f.fileName || '').toLowerCase().includes(kw))
- ).length;
- } catch { }
-
- const nbNonConformes = nonConformes.length;
- const nbConformes = Math.max(0, nbJustifs - nbNonConformes);
-
+
+ const notes = result.recordset;
+ if (!notes.length) return res.json([]);
+
+ // Récupérer toutes les lignes refusées en un seul appel
+ const noteIds = notes.map(n => n.id).join(',');
+ const refusedRows = await pool.request().query(`
+ SELECT noteDeFraisId, ligneIndex, ligneLibelle, ligneCategorie, motif, dateRefus
+ FROM LignesRefusees
+ WHERE noteDeFraisId IN (${noteIds})
+ ORDER BY noteDeFraisId, ligneIndex ASC
+ `);
+
+ const refusedByNote = {};
+ for (const r of refusedRows.recordset) {
+ if (!refusedByNote[r.noteDeFraisId]) refusedByNote[r.noteDeFraisId] = [];
+ refusedByNote[r.noteDeFraisId].push({
+ index: r.ligneIndex,
+ motif: r.motif,
+ ligneLibelle: r.ligneLibelle,
+ ligneCategorie: r.ligneCategorie,
+ dateRefus: r.dateRefus
+ });
+ }
+
+ const enriched = notes.map(row => {
+ let nbLignes = 0;
+ try { nbLignes = (JSON.parse(row.lignesJson || '[]')).length; } catch { }
+ const lignesRefusees = refusedByNote[row.id] || [];
+ const nbLignesRefusees = lignesRefusees.length;
+ const nbLignesOk = Math.max(0, nbLignes - nbLignesRefusees);
+ const isRefusee = row.statut === 'refuse_verif' || row.statut === 'refuse_verif_archive'
+ || row.statut === 'non_conforme_verif' || row.statut === 'non_conforme_archive';
+
return {
...row,
- nbJustifs,
- nbConformes,
- nbNonConformes,
- nonConformes,
- dateVerification: row.dateVerification,
+ statut: isRefusee ? 'REFUSEE' : 'VERIFIEE',
+ nbLignes,
+ nbLignesOk: isRefusee ? nbLignesOk : nbLignes,
+ nbLignesRefusees,
+ lignesRefusees,
commentaire: row.commentaireVerification,
};
- }));
-
- res.json(notesAvecNC);
-
+ });
+
+ res.json(enriched);
+
} catch (error) {
+ console.error('GET /api/verificateur/historique:', error.message);
res.status(500).json({ error: error.message });
}
});
@@ -1196,9 +1769,24 @@ async function uploadToSharePoint(file, ndfReference, collaborateurNomPrenom) {
);
return { fileName, uploadUrl: res.data.webUrl };
}
-
+const downloadUrlCache = new Map(); // webUrl SP → { url, expiresAt }
async function downloadFromSharePoint(webUrl) {
const accessToken = await getGraphToken();
+
+ // ✅ Cache de l'URL de téléchargement direct (valable ~1h)
+ const cached = downloadUrlCache.get(webUrl);
+ if (cached && Date.now() < cached.expiresAt) {
+ try {
+ const fileRes = await axios.get(cached.url, {
+ responseType: 'arraybuffer',
+ timeout: 15000
+ });
+ return Buffer.from(fileRes.data);
+ } catch {
+ downloadUrlCache.delete(webUrl); // URL expirée, on refait
+ }
+ }
+
const urlObj = new URL(webUrl);
const fullPath = decodeURIComponent(urlObj.pathname);
const marker = '/Shared Documents/';
@@ -1210,11 +1798,23 @@ async function downloadFromSharePoint(webUrl) {
const parts = fullPath.split('/sites/')[1]?.split('/');
relativePath = parts?.slice(2).join('/') || '';
}
- const res = await axios.get(
- `https://graph.microsoft.com/v1.0/sites/${SHAREPOINT_CONFIG.siteId}/drives/${SHAREPOINT_CONFIG.driveId}/root:/${relativePath}:/content`,
- { headers: { Authorization: `Bearer ${accessToken}` }, responseType: 'arraybuffer' }
+
+ const metaRes = await axios.get(
+ `https://graph.microsoft.com/v1.0/sites/${SHAREPOINT_CONFIG.siteId}/drives/${SHAREPOINT_CONFIG.driveId}/root:/${relativePath}`,
+ { headers: { Authorization: `Bearer ${accessToken}` }, timeout: 5000 }
);
- return Buffer.from(res.data);
+
+ const downloadUrl = metaRes.data['@microsoft.graph.downloadUrl'];
+ if (!downloadUrl) throw new Error('downloadUrl absent de la réponse Graph');
+
+ // Mettre en cache 50 min (les URLs pré-signées expirent vers 1h)
+ downloadUrlCache.set(webUrl, { url: downloadUrl, expiresAt: Date.now() + 50 * 60 * 1000 });
+
+ const fileRes = await axios.get(downloadUrl, {
+ responseType: 'arraybuffer',
+ timeout: 15000
+ });
+ return Buffer.from(fileRes.data);
}
async function uploadToSharePointHierarchique(file, noteRef, nomDossier, moisDossier) {
@@ -1273,111 +1873,203 @@ async function generateRecapWithJustifs(noteData, justifFiles, signaturesOpt) {
return Buffer.from(await finalPdf.save());
}
+// GET /api/notes/:id/download-urls — préchargement des URLs directes
+app.get('/api/notes/:id/download-urls', authenticateToken, async (req, res) => {
+ try {
+ const noteId = parseInt(req.params.id);
+
+ // Récupérer les fichiers de la note
+ const noteResult = await pool.request()
+ .input('id', sql.Int, noteId)
+ .query(`SELECT fichiers, lignesJson FROM NoteDeFrais WHERE id = @id`);
+
+ if (!noteResult.recordset.length) return res.json({});
+
+ const note = noteResult.recordset[0];
+ let allUrls = [];
+
+ // Fichiers globaux
+ try {
+ const fichiers = JSON.parse(note.fichiers || '[]');
+ fichiers.forEach(f => { if (f.uploadUrl) allUrls.push(f.uploadUrl); });
+ } catch { }
+
+ // Fichiers des lignes
+ try {
+ const lignes = JSON.parse(note.lignesJson || '[]');
+ lignes.forEach(l => {
+ (l.qrFiles || []).forEach(f => { if (f.uploadUrl) allUrls.push(f.uploadUrl); });
+ });
+ } catch { }
+
+ if (!allUrls.length) return res.json({});
+
+ const accessToken = await getGraphToken();
+ const result = {};
+
+ // ✅ Graph Batch — résout toutes les URLs en UNE SEULE requête HTTP
+ const batchRequests = allUrls.slice(0, 20).map((url, i) => {
+ const urlObj = new URL(url);
+ const fullPath = decodeURIComponent(urlObj.pathname);
+ const marker = '/Shared Documents/';
+ const markerAlt = '/Documents/';
+ let relativePath = '';
+ if (fullPath.includes(marker)) relativePath = fullPath.split(marker)[1];
+ else if (fullPath.includes(markerAlt)) relativePath = fullPath.split(markerAlt)[1];
+ else {
+ const parts = fullPath.split('/sites/')[1]?.split('/');
+ relativePath = parts?.slice(2).join('/') || '';
+ }
+ return {
+ id: String(i),
+ method: 'GET',
+ url: `/sites/${SHAREPOINT_CONFIG.siteId}/drives/${SHAREPOINT_CONFIG.driveId}/root:/${relativePath}`
+ };
+ });
+
+ const batchRes = await axios.post(
+ 'https://graph.microsoft.com/v1.0/$batch',
+ { requests: batchRequests },
+ { headers: { Authorization: `Bearer ${accessToken}`, 'Content-Type': 'application/json' } }
+ );
+
+ for (const response of batchRes.data.responses) {
+ const i = parseInt(response.id);
+ const downloadUrl = response.body?.['@microsoft.graph.downloadUrl'];
+ if (downloadUrl && allUrls[i]) {
+ result[allUrls[i]] = downloadUrl;
+ // Mettre en cache côté serveur aussi
+ downloadUrlCache.set(allUrls[i], {
+ url: downloadUrl,
+ expiresAt: Date.now() + 50 * 60 * 1000
+ });
+ }
+ }
+
+ res.json(result);
+ } catch (error) {
+ console.error('GET /api/notes/:id/download-urls:', error.message);
+ res.json({}); // Fail silencieux — le client tombera sur le proxy normal
+ }
+});
+
// ══════════════════════════════════════════════════════
// POST /api/notes — Créer une note de frais (multi-lignes)
// ══════════════════════════════════════════════════════
app.post('/api/notes', authenticateToken, upload.any(), async (req, res) => {
+ try {
+ const { libelle, date, description, participants, nombreParticipants, lignes, qrNoteRef } = req.body;
+
+ if (!libelle || !date || !lignes)
+ return res.status(400).json({ error: 'Libellé, date et lignes sont obligatoires' });
+
+ let lignesParsed;
try {
- const { libelle, date, description, participants, nombreParticipants, lignes, qrNoteRef } = req.body;
+ lignesParsed = typeof lignes === 'string' ? JSON.parse(lignes) : lignes;
+ } catch {
+ return res.status(400).json({ error: 'Format des lignes invalide' });
+ }
+ if (!Array.isArray(lignesParsed) || lignesParsed.length === 0)
+ return res.status(400).json({ error: 'Au moins une ligne est obligatoire' });
- if (!libelle || !date || !lignes)
- return res.status(400).json({ error: 'Libellé, date et lignes sont obligatoires' });
+ // ── Tarif KM ─────────────────────────────────────────────────────
+ let tarifKm = await getTarifKm();
+ try {
+ const annee = new Date().getFullYear();
+ const kmParam = await pool.request()
+ .input('annee', sql.Int, annee)
+ .query(`SELECT TOP 1 tarifParKm FROM ParametresKm WHERE annee = @annee AND actif = 1 ORDER BY DateCreation DESC`);
+ if (kmParam.recordset[0]?.tarifParKm) tarifKm = parseFloat(kmParam.recordset[0].tarifParKm);
+ } catch { }
- let lignesParsed;
- try {
- lignesParsed = typeof lignes === 'string' ? JSON.parse(lignes) : lignes;
- } catch {
- return res.status(400).json({ error: 'Format des lignes invalide' });
+ const lignesPDF = preparerLignesPDF(lignesParsed, tarifKm);
+ const montantTTC = lignesPDF.reduce((s, l) => s + l.montantTTC, 0);
+ const indemKm = lignesPDF.reduce((s, l) => s + l.indemniteKm, 0);
+ const kmTotal = lignesPDF.reduce((s, l) => s + (l.km || 0), 0);
+ const montantFinal = parseFloat((montantTTC + indemKm).toFixed(2));
+ const montantFormate = montantFinal.toFixed(2);
+ const isKmOnly = lignesPDF.every(l => l.montantTTC === 0 && l.indemniteKm > 0);
+ const categorieNote = isKmOnly ? 'Kilométrique pur' : 'Multiple';
+
+ // ── Collaborateur + hiérarchie (2 requêtes SQL, inchangé) ────────
+ const collabResult = await pool.request()
+ .input('id', sql.Int, req.user.id)
+ .query(`SELECT id, email, prenom, nom, departement, campus FROM CollaborateurAD WHERE id = @id`);
+ if (!collabResult.recordset.length)
+ return res.status(404).json({ error: 'Collaborateur non trouvé' });
+ const collaborateur = collabResult.recordset[0];
+ const nomPrenom = `${collaborateur.nom.toUpperCase()} ${collaborateur.prenom}`;
+
+ const dateObj = new Date(date);
+ const moisStr = dateObj.toLocaleDateString('fr-FR', { month: 'long', year: 'numeric' });
+ const moisCapitalized = moisStr.charAt(0).toUpperCase() + moisStr.slice(1);
+
+ const hierarchie = await pool.request()
+ .input('collabId', sql.Int, req.user.id)
+ .query(`
+ SELECT h.SuperieurId, h.[SuperieurIdn+2],
+ s1.email AS emailN1, s1.prenom AS prenomN1, s1.nom AS nomN1,
+ s2.email AS emailN2
+ FROM HierarchieValidationNDF h
+ LEFT JOIN CollaborateurAD s1 ON s1.id = h.SuperieurId
+ LEFT JOIN CollaborateurAD s2 ON s2.id = h.[SuperieurIdn+2]
+ WHERE h.CollaborateurId = @collabId
+ `);
+ const n1Id = hierarchie.recordset[0]?.SuperieurId ?? null;
+ const n2Id = hierarchie.recordset[0]?.['SuperieurIdn+2'] ?? null;
+ const emailN1 = hierarchie.recordset[0]?.emailN1 ?? null;
+ const prenomN1 = hierarchie.recordset[0]?.prenomN1 ?? null;
+ const nomN1 = hierarchie.recordset[0]?.nomN1 ?? null;
+
+ const reference = await genererReference(collaborateur.campus, collaborateur.nom, collaborateur.prenom);
+ const nomDossier = `${collaborateur.prenom}_${collaborateur.nom}`.replace(/\s+/g, '_');
+ const now = new Date();
+ const moisDossier = `${now.getFullYear()}-${String(now.getMonth() + 1).padStart(2, '0')}`;
+
+ // ── Collecte des fichiers (QR global) ────────────────────────────
+ const allFiles = [...(req.files || [])];
+ if (qrNoteRef) {
+ const qrToken = await pool.request()
+ .input('noteRef', sql.NVarChar, qrNoteRef)
+ .query(`SELECT TOP 1 fichiers FROM UploadTokens WHERE noteRef = @noteRef AND used = 1 ORDER BY expiresAt DESC`);
+ if (qrToken.recordset.length && qrToken.recordset[0].fichiers) {
+ const qrFichiers = JSON.parse(qrToken.recordset[0].fichiers);
+ // ✅ Téléchargements QR globaux en parallèle
+ const qrDownloads = await Promise.all(
+ qrFichiers.map(f =>
+ downloadFromSharePoint(f.uploadUrl)
+ .then(buf => ({
+ buffer: buf,
+ originalname: f.fileName,
+ mimetype: f.fileName?.endsWith('.pdf') ? 'application/pdf' : 'image/jpeg',
+ size: buf.length
+ }))
+ .catch(e => { console.warn('⚠️ QR global download fail:', e.message); return null; })
+ )
+ );
+ qrDownloads.filter(Boolean).forEach(f => allFiles.push(f));
}
- if (!Array.isArray(lignesParsed) || lignesParsed.length === 0)
- return res.status(400).json({ error: 'Au moins une ligne est obligatoire' });
+ }
- let tarifKm = await getTarifKm();
- try {
- const annee = new Date().getFullYear();
- const kmParam = await pool.request()
- .input('annee', sql.Int, annee)
- .query(`SELECT TOP 1 tarifParKm FROM ParametresKm WHERE annee = @annee AND actif = 1 ORDER BY DateCreation DESC`);
- if (kmParam.recordset[0]?.tarifParKm) tarifKm = parseFloat(kmParam.recordset[0].tarifParKm);
- } catch { }
-
- const lignesPDF = preparerLignesPDF(lignesParsed, tarifKm);
- const montantTTC = lignesPDF.reduce((s, l) => s + l.montantTTC, 0);
- const indemKm = lignesPDF.reduce((s, l) => s + l.indemniteKm, 0);
- const kmTotal = lignesPDF.reduce((s, l) => s + (l.km || 0), 0);
- const montantFinal = parseFloat((montantTTC + indemKm).toFixed(2));
- const montantFormate = montantFinal.toFixed(2);
- const isKmOnly = lignesPDF.every(l => l.montantTTC === 0 && l.indemniteKm > 0);
- console.log('🔍 isKmOnly:', isKmOnly, 'kmTotal:', kmTotal, 'montantTTC:', montantTTC);
-
- const categorieNote = isKmOnly ? 'Kilométrique pur' : 'Multiple';
-
- // POST /api/notes — ligne ~420
- const collabResult = await pool.request()
- .input('id', sql.Int, req.user.id)
- .query(`SELECT id, email, prenom, nom, departement, campus FROM CollaborateurAD WHERE id = @id`);
- if (!collabResult.recordset.length) return res.status(404).json({ error: 'Collaborateur non trouvé' });
- const collaborateur = collabResult.recordset[0];
- const nomPrenom = `${collaborateur.nom.toUpperCase()} ${collaborateur.prenom}`;
-
- const dateObj = new Date(date);
- const moisStr = dateObj.toLocaleDateString('fr-FR', { month: 'long', year: 'numeric' });
- const moisCapitalized = moisStr.charAt(0).toUpperCase() + moisStr.slice(1);
-
- const hierarchie = await pool.request()
- .input('collabId', sql.Int, req.user.id)
- .query(`
- SELECT h.SuperieurId, h.[SuperieurIdn+2],
- s1.email AS emailN1, s1.prenom AS prenomN1, s1.nom AS nomN1,
- s2.email AS emailN2
- FROM HierarchieValidationNDF h
- LEFT JOIN CollaborateurAD s1 ON s1.id = h.SuperieurId
- LEFT JOIN CollaborateurAD s2 ON s2.id = h.[SuperieurIdn+2]
- WHERE h.CollaborateurId = @collabId
- `);
- const n1Id = hierarchie.recordset[0]?.SuperieurId ?? null;
- const n2Id = hierarchie.recordset[0]?.['SuperieurIdn+2'] ?? null;
- const emailN1 = hierarchie.recordset[0]?.emailN1 ?? null;
- const prenomN1 = hierarchie.recordset[0]?.prenomN1 ?? null;
- const nomN1 = hierarchie.recordset[0]?.nomN1 ?? null;
-
- const reference = await genererReference(collaborateur.campus, collaborateur.nom, collaborateur.prenom);
-
- const nomDossier = `${collaborateur.prenom}_${collaborateur.nom}`.replace(/\s+/g, '_');
- const now = new Date();
- const moisDossier = `${now.getFullYear()}-${String(now.getMonth() + 1).padStart(2, '0')}`;
-
- const allFiles = [...(req.files || [])];
- if (qrNoteRef) {
- const qrToken = await pool.request()
- .input('noteRef', sql.NVarChar, qrNoteRef)
- .query(`SELECT TOP 1 fichiers FROM UploadTokens WHERE noteRef = @noteRef AND used = 1 ORDER BY expiresAt DESC`);
- if (qrToken.recordset.length && qrToken.recordset[0].fichiers) {
- const qrFichiers = JSON.parse(qrToken.recordset[0].fichiers);
- for (const f of qrFichiers) {
- try {
- const buf = await downloadFromSharePoint(f.uploadUrl);
- allFiles.push({ buffer: buf, originalname: f.fileName, mimetype: f.fileName?.endsWith('.pdf') ? 'application/pdf' : 'image/jpeg', size: buf.length });
- } catch (e) { console.warn('⚠️ QR global download fail:', e.message); }
- }
- }
- }
-
- // ✅ QR par ligne — récupère et STOCKE les fichiers dans qrFiles de chaque ligne
- for (let i = 0; i < lignesParsed.length; i++) {
- const ligneQrRef = lignesParsed[i].qrNoteRef;
- if (!ligneQrRef) continue;
+ // ── QR par ligne : téléchargement + upload en parallèle ──────────
+ await Promise.all(
+ lignesParsed.map(async (ligne, i) => {
+ const ligneQrRef = ligne.qrNoteRef;
+ if (!ligneQrRef) return;
try {
const qrLigne = await pool.request()
.input('noteRef', sql.NVarChar, ligneQrRef)
.query(`SELECT TOP 1 fichiers FROM UploadTokens WHERE noteRef = @noteRef AND used = 1 ORDER BY expiresAt DESC`);
- if (qrLigne.recordset.length && qrLigne.recordset[0].fichiers) {
- const qrFichiers = JSON.parse(qrLigne.recordset[0].fichiers);
+ if (!qrLigne.recordset.length || !qrLigne.recordset[0].fichiers) {
+ console.warn(`⚠️ QR ligne ${i} (${ligneQrRef}) : token introuvable ou non utilisé`);
+ return;
+ }
+ const qrFichiers = JSON.parse(qrLigne.recordset[0].fichiers);
+ if (!ligne.qrFiles) ligne.qrFiles = [];
- // ✅ Initialiser qrFiles pour cette ligne
- if (!lignesParsed[i].qrFiles) lignesParsed[i].qrFiles = [];
-
- for (const f of qrFichiers) {
+ // téléchargement + upload SharePoint en parallèle pour chaque fichier de la ligne
+ await Promise.all(
+ qrFichiers.map(async f => {
try {
const buf = await downloadFromSharePoint(f.uploadUrl);
const fileObj = {
@@ -1386,211 +2078,230 @@ app.post('/api/notes', authenticateToken, upload.any(), async (req, res) => {
mimetype: f.fileName?.endsWith('.pdf') ? 'application/pdf' : 'image/jpeg',
size: buf.length
};
-
- // Ajouter à allFiles pour le récap PDF global
allFiles.push(fileObj);
- // ✅ Uploader vers SP avec la référence finale et stocker dans qrFiles
- try {
- const uploaded = await uploadToSharePointHierarchique(
- fileObj, reference, nomDossier, moisDossier
- );
- // Éviter les doublons
- const dejaSauve = lignesParsed[i].qrFiles.some(x => x.fileName === uploaded.fileName);
- if (!dejaSauve) {
- lignesParsed[i].qrFiles.push({
- fileName: uploaded.fileName,
- uploadUrl: uploaded.uploadUrl
- });
- }
- console.log(`✅ QR ligne ${i} stocké dans qrFiles: ${uploaded.fileName}`);
- } catch (uploadErr) {
- console.warn(`⚠️ Upload SP ligne ${i}:`, uploadErr.message);
+ const uploaded = await uploadToSharePointHierarchique(fileObj, reference, nomDossier, moisDossier);
+ const dejaSauve = ligne.qrFiles.some(x => x.fileName === uploaded.fileName);
+ if (!dejaSauve) {
+ ligne.qrFiles.push({ fileName: uploaded.fileName, uploadUrl: uploaded.uploadUrl });
}
- } catch (e) { console.warn(`⚠️ QR ligne ${i} download fail:`, e.message); }
- }
- } else {
- console.warn(`⚠️ QR ligne ${i} (${ligneQrRef}) : token introuvable ou non utilisé`);
- }
+ console.log(`✅ QR ligne ${i} stocké: ${uploaded.fileName}`);
+ } catch (e) {
+ console.warn(`⚠️ QR ligne ${i} download/upload fail:`, e.message);
+ }
+ })
+ );
} catch (e) {
console.warn(`⚠️ QR ligne ${i} erreur DB:`, e.message);
}
- }
+ })
+ );
- // ✅ Recalculer lignesJson APRÈS enrichissement des qrFiles
- const lignesJsonFinal = JSON.stringify(lignesParsed);
+ // ✅ Recalculer lignesJson APRÈS enrichissement des qrFiles
+ const lignesJsonFinal = JSON.stringify(lignesParsed);
- const fichiersUploades = [];
- for (const file of allFiles) {
+ // ── Upload justificatifs en parallèle ────────────────────────────
+ const fichiersUploades = (await Promise.all(
+ allFiles.map(file =>
+ uploadToSharePointHierarchique(file, reference, nomDossier, moisDossier)
+ .catch(e => { console.error(`❌ Upload justif ${file.originalname}:`, e.message); return null; })
+ )
+ )).filter(Boolean);
+
+ // ── Préparer noteDataPDF (utilisé en sync ET en async) ───────────
+ const noteDataPDF = {
+ reference,
+ nomPrenom,
+ mois: moisCapitalized,
+ date,
+ categorie: categorieNote,
+ libelle,
+ montant: montantFinal,
+ lignes: lignesParsed,
+ lignesJson: lignesJsonFinal,
+ tarifKm,
+ statut: 'enattente',
+ departement: collaborateur.departement,
+ participants: participants || null,
+ };
+
+ // ── Insérer la note en BDD ───────────────────────────────────────
+ const insertResult = await pool.request()
+ .input('reference', sql.NVarChar, reference)
+ .input('collaborateurId', sql.Int, req.user.id)
+ .input('libelle', sql.NVarChar, libelle)
+ .input('montant', sql.Decimal, montantFinal)
+ .input('date', sql.Date, new Date(date))
+ .input('categorie', sql.NVarChar, categorieNote)
+ .input('description', sql.NVarChar, description || null)
+ .input('participants', sql.NVarChar, participants ? String(participants) : null)
+ .input('nombreParticipants', sql.Int, nombreParticipants ? parseInt(nombreParticipants) : null)
+ .input('sharepointUrl', sql.NVarChar, fichiersUploades[0]?.uploadUrl || null)
+ .input('fichiers', sql.NVarChar, JSON.stringify(fichiersUploades))
+ .input('statut', sql.NVarChar, 'enattente')
+ .input('validateurN1Id', sql.Int, n1Id)
+ .input('validateurN2Id', sql.Int, n2Id)
+ .input('montantHT', sql.Decimal, null)
+ .input('tauxTVA', sql.Decimal, null)
+ .input('montantTVA21', sql.Decimal, null)
+ .input('montantTVA55', sql.Decimal, null)
+ .input('montantTVA10', sql.Decimal, null)
+ .input('montantTVA20', sql.Decimal, null)
+ .input('km', sql.Decimal, kmTotal || null)
+ .input('indemniteKm', sql.Decimal, indemKm || null)
+ .input('lignesJson', sql.NVarChar, lignesJsonFinal)
+ .query(`
+ INSERT INTO NoteDeFrais
+ (reference, collaborateurId, libelle, montant, date, categorie,
+ description, participants, nombreParticipants, sharepointUrl, fichiers,
+ statut, validateurN1Id, validateurN2Id,
+ montantHT, tauxTVA, montantTVA21, montantTVA55, montantTVA10, montantTVA20,
+ km, indemniteKm, lignesJson)
+ OUTPUT INSERTED.id, INSERTED.reference
+ VALUES
+ (@reference, @collaborateurId, @libelle, @montant, @date, @categorie,
+ @description, @participants, @nombreParticipants, @sharepointUrl, @fichiers,
+ @statut, @validateurN1Id, @validateurN2Id,
+ @montantHT, @tauxTVA, @montantTVA21, @montantTVA55, @montantTVA10, @montantTVA20,
+ @km, @indemniteKm, @lignesJson)
+ `);
+
+ const noteCreee = insertResult.recordset[0];
+
+ // ── Insérer les lignes (séquentiel, rapide car SQL local) ────────
+ for (let i = 0; i < lignesParsed.length; i++) {
+ const l = lignesParsed[i];
+ const pdf = lignesPDF[i];
+ try {
+ await pool.request()
+ .input('noteId', sql.Int, noteCreee.id)
+ .input('numPiece', sql.Int, i + 1)
+ .input('date', sql.Date, new Date(l.date))
+ .input('nature', sql.NVarChar, l.categorie || '')
+ .input('libelle', sql.NVarChar, l.libelle || '')
+ .input('km', sql.Decimal, pdf.km || null)
+ .input('montantTTC', sql.Decimal, pdf.montantTTC || null)
+ .input('tva21', sql.Decimal, pdf.tva21 || null)
+ .input('tva55', sql.Decimal, pdf.tva55 || null)
+ .input('tva10', sql.Decimal, pdf.tva10 || null)
+ .input('tva20', sql.Decimal, pdf.tva20 || null)
+ .input('montantHT', sql.Decimal, pdf.montantHT || null)
+ .input('tauxTVA', sql.Decimal, parseFloat(l.tauxTVA) || null)
+ .input('indemniteKm', sql.Decimal, pdf.indemniteKm || null)
+ .query(`
+ INSERT INTO LigneNoteDeFrais
+ (noteDeFraisId, numPiece, date, nature, libelle,
+ km, montantTTC, tva21, tva55, tva10, tva20,
+ montantHT, tauxTVA, indemniteKm)
+ VALUES
+ (@noteId, @numPiece, @date, @nature, @libelle,
+ @km, @montantTTC, @tva21, @tva55, @tva10, @tva20,
+ @montantHT, @tauxTVA, @indemniteKm)
+ `);
+ } catch (e) { console.error(`❌ Insertion ligne ${i + 1}:`, e.message); }
+ }
+
+ console.log(`✅ Note créée: ${reference} (${lignesParsed.length} lignes) par ${collaborateur.email}`);
+
+ // ✅ Répondre immédiatement — le client n'attend plus le PDF
+ res.status(201).json({
+ success: true,
+ id: noteCreee.id,
+ reference: noteCreee.reference,
+ fichiers: fichiersUploades,
+ recapUrl: null, // sera mis à jour en BDD en arrière-plan
+ pending: true,
+ });
+
+ // ── Traitement lourd en arrière-plan (non bloquant) ──────────────
+ setImmediate(async () => {
+ const fichiersAsync = [...fichiersUploades]; // copie locale pour l'async
+ try {
+ console.log(`🔄 [ASYNC] PDF + emails pour ${reference}...`);
+ const frontendUrl = process.env.FRONTEND_URL || 'myndf.ensup-adm.net';
+
+ // Fiche PDF soumission
+ let ficheResult = null;
try {
- const r = await uploadToSharePointHierarchique(file, reference, nomDossier, moisDossier);
- fichiersUploades.push(r);
- } catch (e) { console.error(`❌ Upload justif ${file.originalname}:`, e.message); }
- }
+ const fichePDF = await generateFicheSignee(
+ noteDataPDF,
+ [{ niveau: 'COLLAB', nomPrenom, date: new Date(), action: 'soumettre', commentaire: null }]
+ );
+ ficheResult = await uploadToSharePointHierarchique(
+ { buffer: fichePDF, originalname: `${reference}_soumission.pdf`, mimetype: 'application/pdf', size: fichePDF.length },
+ reference, nomDossier, moisDossier
+ );
+ fichiersAsync.push(ficheResult);
+ console.log(`✅ [ASYNC] Fiche soumission: ${ficheResult.fileName}`);
+ } catch (e) { console.error('❌ [ASYNC] Fiche PDF:', e.message); }
- const noteDataPDF = {
- reference,
- nomPrenom,
- mois: moisCapitalized,
- date,
- categorie: categorieNote,
- libelle,
- montant: montantFinal,
- lignes: lignesParsed,
- lignesJson: JSON.stringify(lignesParsed),
- tarifKm: await getTarifKm(),
- statut: 'enattente',
- departement: collaborateur.departement,
- participants: participants || null,
- };
+ // Récap PDF complet
+ let recapUrl = null;
+ try {
+ const recapBuffer = await generateRecapWithJustifs(noteDataPDF, allFiles);
+ const recapResult = await uploadToSharePointHierarchique(
+ { buffer: recapBuffer, originalname: `${reference}_recap.pdf`, mimetype: 'application/pdf', size: recapBuffer.length },
+ reference, nomDossier, moisDossier
+ );
+ fichiersAsync.push(recapResult);
+ recapUrl = recapResult.uploadUrl;
+ console.log(`✅ [ASYNC] Récap PDF: ${recapResult.fileName}`);
+ } catch (e) { console.error('❌ [ASYNC] Récap PDF:', e.message); }
- let ficheResult = null;
- try {
- const fichePDF = await generateFicheSignee(
- noteDataPDF,
- [{ niveau: 'COLLAB', nomPrenom, date: new Date(), action: 'soumettre', commentaire: null }]
- );
- ficheResult = await uploadToSharePointHierarchique(
- { buffer: fichePDF, originalname: `${reference}_soumission.pdf`, mimetype: 'application/pdf', size: fichePDF.length },
- reference, nomDossier, moisDossier
- );
- fichiersUploades.push(ficheResult);
- console.log('✅ Fiche soumission uploadée:', ficheResult.fileName);
- } catch (e) { console.error('❌ Génération fiche PDF:', e.message, e.stack); }
-
- let recapUrl = null;
- try {
- const recapBuffer = await generateRecapWithJustifs(noteDataPDF, allFiles);
- const recapResult = await uploadToSharePointHierarchique(
- { buffer: recapBuffer, originalname: `${reference}_recap.pdf`, mimetype: 'application/pdf', size: recapBuffer.length },
- reference, nomDossier, moisDossier
- );
- fichiersUploades.push(recapResult);
- recapUrl = recapResult.uploadUrl;
- console.log('✅ Récap PDF uploadé:', recapResult.fileName);
- } catch (e) { console.error('❌ Génération récap PDF:', e.message); }
-
- const insertResult = await pool.request()
- .input('reference', sql.NVarChar, reference)
- .input('collaborateurId', sql.Int, req.user.id)
- .input('libelle', sql.NVarChar, libelle)
- .input('montant', sql.Decimal, montantFinal)
- .input('date', sql.Date, new Date(date))
- .input('categorie', sql.NVarChar, categorieNote)
- .input('description', sql.NVarChar, description || null)
- .input('participants', sql.NVarChar, participants ? String(participants) : null)
- .input('nombreParticipants', sql.Int, nombreParticipants ? parseInt(nombreParticipants) : null)
- .input('sharepointUrl', sql.NVarChar, recapUrl || ficheResult?.uploadUrl || fichiersUploades[0]?.uploadUrl || null)
- .input('fichiers', sql.NVarChar, JSON.stringify(fichiersUploades))
- .input('statut', sql.NVarChar, 'enattente')
- .input('validateurN1Id', sql.Int, n1Id)
- .input('validateurN2Id', sql.Int, n2Id)
- .input('montantHT', sql.Decimal, null)
- .input('tauxTVA', sql.Decimal, null)
- .input('montantTVA21', sql.Decimal, null)
- .input('montantTVA55', sql.Decimal, null)
- .input('montantTVA10', sql.Decimal, null)
- .input('montantTVA20', sql.Decimal, null)
- .input('km', sql.Decimal, kmTotal || null)
- .input('indemniteKm', sql.Decimal, indemKm || null)
- .input('lignesJson', sql.NVarChar, lignesJsonFinal)
- .query(`
- INSERT INTO NoteDeFrais
- (reference, collaborateurId, libelle, montant, date, categorie,
- description, participants, nombreParticipants, sharepointUrl, fichiers,
- statut, validateurN1Id, validateurN2Id,
- montantHT, tauxTVA, montantTVA21, montantTVA55, montantTVA10, montantTVA20,
- km, indemniteKm, lignesJson)
- OUTPUT INSERTED.id, INSERTED.reference
- VALUES
- (@reference, @collaborateurId, @libelle, @montant, @date, @categorie,
- @description, @participants, @nombreParticipants, @sharepointUrl, @fichiers,
- @statut, @validateurN1Id, @validateurN2Id,
- @montantHT, @tauxTVA, @montantTVA21, @montantTVA55, @montantTVA10, @montantTVA20,
- @km, @indemniteKm, @lignesJson)
- `);
-
- const noteCreee = insertResult.recordset[0];
-
- for (let i = 0; i < lignesParsed.length; i++) {
- const l = lignesParsed[i];
- const pdf = lignesPDF[i];
+ // Mettre à jour BDD avec PDF final
try {
await pool.request()
- .input('noteId', sql.Int, noteCreee.id)
- .input('numPiece', sql.Int, i + 1)
- .input('date', sql.Date, new Date(l.date))
- .input('nature', sql.NVarChar, l.categorie || '')
- .input('libelle', sql.NVarChar, l.libelle || '')
- .input('km', sql.Decimal, pdf.km || null)
- .input('montantTTC', sql.Decimal, pdf.montantTTC || null)
- .input('tva21', sql.Decimal, pdf.tva21 || null)
- .input('tva55', sql.Decimal, pdf.tva55 || null)
- .input('tva10', sql.Decimal, pdf.tva10 || null)
- .input('tva20', sql.Decimal, pdf.tva20 || null)
- .input('montantHT', sql.Decimal, pdf.montantHT || null)
- .input('tauxTVA', sql.Decimal, parseFloat(l.tauxTVA) || null)
- .input('indemniteKm', sql.Decimal, pdf.indemniteKm || null)
+ .input('id', sql.Int, noteCreee.id)
+ .input('sharepointUrl', sql.NVarChar, recapUrl || ficheResult?.uploadUrl || null)
+ .input('fichiers', sql.NVarChar, JSON.stringify(fichiersAsync))
.query(`
- INSERT INTO LigneNoteDeFrais
- (noteDeFraisId, numPiece, date, nature, libelle,
- km, montantTTC, tva21, tva55, tva10, tva20,
- montantHT, tauxTVA, indemniteKm)
- VALUES
- (@noteId, @numPiece, @date, @nature, @libelle,
- @km, @montantTTC, @tva21, @tva55, @tva10, @tva20,
- @montantHT, @tauxTVA, @indemniteKm)
+ UPDATE NoteDeFrais SET
+ sharepointUrl = @sharepointUrl,
+ fichiers = @fichiers,
+ DateModification = GETDATE()
+ WHERE id = @id
`);
- } catch (e) { console.error(`❌ Insertion ligne ${i + 1}:`, e.message); }
- }
+ } catch (e) { console.error('❌ [ASYNC] UPDATE BDD fichiers:', e.message); }
- console.log(`✅ Note créée: ${reference} (${lignesParsed.length} lignes) par ${collaborateur.email}`);
+ // Notifications BDD (parallèle)
+ await Promise.all([
+ creerNotification({
+ destinataireId: collaborateur.id, destinataireEmail: null, type: 'soumission',
+ titre: `✅ Note ${reference} soumise avec succès`,
+ message: `Votre note ${reference} — ${libelle} (${montantFormate} €) a bien été reçue.`,
+ noteId: noteCreee.id
+ }).catch(e => console.error('❌ [ASYNC] Notif BDD collab:', e.message)),
- const dateFormatee = new Date(date).toLocaleDateString('fr-FR');
- const frontendUrl = process.env.FRONTEND_URL || 'myndf.ensup-adm.net';
-
- try {
- await creerNotification({
- destinataireId: collaborateur.id, destinataireEmail: null, type: 'soumission',
- titre: `✅ Note ${reference} soumise avec succès`,
- message: `Votre note ${reference} — ${libelle} (${montantFormate} €) a bien été reçue.`,
- noteId: noteCreee.id
- });
- } catch (e) { console.error('❌ Notif BDD collab:', e.message); }
-
- try {
- await sendMailGraph(
- collaborateur.email,
- `✅ Accusé de réception — Note ${reference}`,
- `
-
-
✅ Note de frais bien reçue
-
-
-
Bonjour ${collaborateur.prenom} ${collaborateur.nom},
-
Votre note ${reference} — ${libelle} (${montantFormate} €) a bien été enregistrée.
- ${nomN1 ? `
Validateur : ${prenomN1} ${nomN1}
` : ''}
- ${recapUrl ? `
📎 Voir le récapitulatif PDF
` : ''}
-
-
-
`
- );
- } catch (e) { console.error('❌ Email accusé collab:', e.message); }
-
- if (n1Id && emailN1) {
- try {
- await creerNotification({
+ n1Id ? creerNotification({
destinataireId: n1Id, destinataireEmail: emailN1, type: 'validation',
titre: `📋 Note à valider — ${reference}`,
- message: `${collaborateur.prenom} ${collaborateur.nom} a soumis une note de frais de ${montantFormate} € en attente de votre validation.`,
+ message: `${collaborateur.prenom} ${collaborateur.nom} a soumis une note de ${montantFormate} € en attente de votre validation.`,
noteId: noteCreee.id
- });
- } catch (e) { console.error('❌ Notif BDD N1:', e.message); }
+ }).catch(e => console.error('❌ [ASYNC] Notif BDD N1:', e.message)) : Promise.resolve(),
+ ]);
- try {
- await sendMailGraph(
+ // Emails (parallèle)
+ await Promise.all([
+ sendMailGraph(
+ collaborateur.email,
+ `✅ Accusé de réception — Note ${reference}`,
+ `
+
+
✅ Note de frais bien reçue
+
+
+
Bonjour ${collaborateur.prenom} ${collaborateur.nom},
+
Votre note ${reference} — ${libelle} (${montantFormate} €) a bien été enregistrée.
+ ${nomN1 ? `
Validateur : ${prenomN1} ${nomN1}
` : ''}
+ ${recapUrl ? `
📎 Voir le récapitulatif PDF
` : ''}
+
+
+
`
+ ).catch(e => console.error('❌ [ASYNC] Email collab:', e.message)),
+
+ (n1Id && emailN1) ? sendMailGraph(
emailN1,
`📋 Note de frais à valider — ${reference}`,
`
@@ -1606,21 +2317,21 @@ app.post('/api/notes', authenticateToken, upload.any(), async (req, res) => {
`
- );
- } catch (e) { console.error('❌ Email N1:', e.message); }
+ ).catch(e => console.error('❌ [ASYNC] Email N1:', e.message)) : Promise.resolve(),
+ ]);
+
+ console.log(`✅ [ASYNC] Traitement terminé pour ${reference}`);
+ } catch (e) {
+ console.error(`❌ [ASYNC] Erreur générale ${reference}:`, e.message);
}
+ });
- res.status(201).json({
- success: true, id: noteCreee.id, reference: noteCreee.reference,
- fichiers: fichiersUploades, recapUrl,
- });
-
- } catch (error) {
- console.error('❌ Erreur POST /api/notes:', error.message);
- res.status(500).json({ error: error.message });
- }
+ } catch (error) {
+ console.error('❌ Erreur POST /api/notes:', error.message);
+ res.status(500).json({ error: error.message });
}
-);
+});
+
app.put('/api/notes/:id', authenticateToken, upload.any(), async (req, res) => {
try {
const noteId = parseInt(req.params.id);
@@ -1632,7 +2343,8 @@ app.put('/api/notes/:id', authenticateToken, upload.any(), async (req, res) => {
.query(`
SELECT * FROM NoteDeFrais
WHERE id = @id AND collaborateurId = @collabId
- AND statut IN ('enattente', 'refuse', 'non_conforme_verif')
+ AND statut IN ('enattente', 'refuse', 'refuse_verif', 'non_conforme_verif', 'brouillon')
+
`);
if (!noteCheck.recordset.length)
@@ -1641,7 +2353,9 @@ app.put('/api/notes/:id', authenticateToken, upload.any(), async (req, res) => {
const noteExist = noteCheck.recordset[0];
// ✅ Détecter si correction (refusée ou non-conforme) → nouvelle note
- const estCorrection = noteExist.statut === 'refuse' || noteExist.statut === 'non_conforme_verif';
+ const estCorrection = noteExist.statut === 'refuse'
+ || noteExist.statut === 'refuse_verif'
+ || noteExist.statut === 'non_conforme_verif';
const { libelle, date, description, participants, nombreParticipants, lignes } = req.body;
@@ -1699,7 +2413,9 @@ app.put('/api/notes/:id', authenticateToken, upload.any(), async (req, res) => {
// 1. Archiver l'ancienne note
const statutArchive = noteExist.statut === 'non_conforme_verif'
? 'non_conforme_archive'
- : 'refuse_archive';
+ : noteExist.statut === 'refuse_verif'
+ ? 'refuse_verif_archive'
+ : 'refuse_archive';
await pool.request()
.input('id', sql.Int, noteId)
@@ -2103,62 +2819,78 @@ app.get('/api/notes', authenticateToken, async (req, res) => {
`);
const notes = result.recordset;
- for (const note of notes) {
- // ✅ Parser fichiers → sharepointFiles pour le frontend
- if (note.fichiers) {
- try { note.sharepointFiles = JSON.parse(note.fichiers); } catch { note.sharepointFiles = []; }
- } else { note.sharepointFiles = []; }
- if (note.statut === 'non_conforme_verif') {
- try {
- const ncResult = await pool.request()
- .input('noteId', sql.Int, note.id)
- .query(`
- SELECT fileName, motif, dateSignalement
+ if (!notes.length) return res.json([]);
+
+ // ── 1. Une seule requête pour tous les non-conformes ─────────────
+ const noteIds = notes.map(n => n.id).join(',');
+ let ncByNote = {};
+ try {
+ const ncAll = await pool.request().query(`
+ SELECT noteDeFraisId, fileName, motif, statut, dateSignalement
FROM JustificatifsNonConformes
- WHERE noteDeFraisId = @noteId
+ WHERE noteDeFraisId IN (${noteIds})
ORDER BY dateSignalement DESC
`);
- note.nonConformes = ncResult.recordset;
- } catch (e) { note.nonConformes = []; }
+ for (const row of ncAll.recordset) {
+ if (!ncByNote[row.noteDeFraisId]) ncByNote[row.noteDeFraisId] = [];
+ ncByNote[row.noteDeFraisId].push(row);
}
- // ✅ Toujours re-parser lignesJson depuis la BDD pour avoir les qrFiles à jour
- // Ne reconstruire depuis LigneNoteDeFrais qu'en dernier recours
- // ✅ Enrichir chaque ligne avec ses fichiers QR depuis UploadTokens
+ } catch (e) { console.warn('⚠️ NC batch fetch:', e.message); }
+
+ // ── 2. Collecter tous les qrNoteRef qui manquent encore de qrFiles
+ const allQrRefs = new Set();
+ for (const note of notes) {
+ if (!note.lignesJson) continue;
+ try {
+ const lignes = JSON.parse(note.lignesJson);
+ for (const l of lignes) {
+ if (l.qrNoteRef && !(l.qrFiles?.length)) allQrRefs.add(l.qrNoteRef);
+ }
+ } catch { }
+ }
+
+ // ── 3. Une seule requête pour tous les tokens QR manquants ───────
+ let qrByRef = {};
+ if (allQrRefs.size > 0) {
+ const refsStr = [...allQrRefs]
+ .map(r => `'${r.replace(/'/g, "''")}'`)
+ .join(',');
+ try {
+ const qrAll = await pool.request().query(`
+ SELECT noteRef, fichiers
+ FROM UploadTokens
+ WHERE noteRef IN (${refsStr}) AND used = 1
+ `);
+ for (const row of qrAll.recordset) {
+ try { qrByRef[row.noteRef] = JSON.parse(row.fichiers || '[]'); } catch { }
+ }
+ } catch (e) { console.warn('⚠️ QR batch fetch:', e.message); }
+ }
+
+ // ── 4. Enrichissement en mémoire — zéro requête SQL ──────────────
+ for (const note of notes) {
+ // Parser fichiers → sharepointFiles
+ try { note.sharepointFiles = JSON.parse(note.fichiers || '[]'); } catch { note.sharepointFiles = []; }
+
+ // Non-conformes depuis le batch
+ if (note.statut === 'non_conforme_verif') {
+ note.nonConformes = ncByNote[note.id] || [];
+ }
+
+ // Enrichissement QR en mémoire
if (note.lignesJson) {
try {
const lignes = JSON.parse(note.lignesJson);
let enrichi = false;
-
- const lignesEnrichies = await Promise.all(lignes.map(async (l) => {
- if (l.qrFiles && l.qrFiles.length > 0) return l;
-
- const qrRef = l.qrNoteRef || '';
- if (!qrRef) return l;
-
- try {
- const qrResult = await pool.request()
- .input('noteRef', sql.NVarChar, qrRef)
- .query(`SELECT TOP 1 fichiers FROM UploadTokens
- WHERE noteRef = @noteRef AND used = 1
- ORDER BY expiresAt DESC`);
-
- if (qrResult.recordset.length && qrResult.recordset[0].fichiers) {
- const fichiers = JSON.parse(qrResult.recordset[0].fichiers);
- if (fichiers.length > 0) {
- enrichi = true;
- return { ...l, qrFiles: fichiers };
- }
- }
- } catch (e) { }
+ const lignesEnrichies = lignes.map(l => {
+ if (l.qrFiles?.length > 0) return l;
+ if (!l.qrNoteRef) return l;
+ const fichiers = qrByRef[l.qrNoteRef];
+ if (fichiers?.length) { enrichi = true; return { ...l, qrFiles: fichiers }; }
return l;
- }));
-
- if (enrichi) {
- note.lignesJson = JSON.stringify(lignesEnrichies);
- }
- } catch (e) {
- console.warn('⚠️ Enrichissement QR fail:', note.id, e.message);
- }
+ });
+ if (enrichi) note.lignesJson = JSON.stringify(lignesEnrichies);
+ } catch (e) { console.warn('⚠️ Enrichissement QR fail:', note.id, e.message); }
}
}
@@ -2172,21 +2904,26 @@ app.get('/api/notes', authenticateToken, async (req, res) => {
// 🔑 TOKEN SHAREPOINT (scope différent de Graph)
// ================================================
async function getSharePointToken() {
+ const now = Date.now();
+ if (_sharePointTokenCache && now < _sharePointTokenCache.expiresAt) {
+ return _sharePointTokenCache.token;
+ }
try {
const params = new URLSearchParams({
grant_type: 'client_credentials',
client_id: AZURE_CONFIG.clientId,
client_secret: AZURE_CONFIG.clientSecret,
- scope: 'https://ensup.sharepoint.com/.default' // ← scope SharePoint
+ scope: 'https://ensup.sharepoint.com/.default'
});
-
const response = await axios.post(
`https://login.microsoftonline.com/${AZURE_CONFIG.tenantId}/oauth2/v2.0/token`,
params.toString(),
{ headers: { 'Content-Type': 'application/x-www-form-urlencoded' } }
);
-
- return response.data.access_token;
+ const token = response.data.access_token;
+ _sharePointTokenCache = { token, expiresAt: now + 55 * 60 * 1000 };
+ console.log('✅ Token SharePoint mis en cache (55 min)');
+ return token;
} catch (error) {
console.error('❌ Erreur token SharePoint:', error.response?.data || error.message);
return null;
@@ -2203,40 +2940,50 @@ app.get('/api/proxy-pdf', async (req, res) => {
url = url.split('/api/proxy-pdf?url=')[1];
try { url = decodeURIComponent(url); } catch { }
}
- if (!url.startsWith('http')) return res.status(400).send('URL invalide : ' + url);
+ if (!url.startsWith('http')) return res.status(400).send('URL invalide');
- // ✅ Headers cache navigateur
- res.setHeader('Cache-Control', 'private, max-age=600');
- res.setHeader('Access-Control-Allow-Origin', '*');
- res.setHeader('Content-Disposition', 'inline');
-
- // ✅ Vérifier cache serveur
- const cached = getCached(url);
- if (cached) {
- res.setHeader('Content-Type', cached.contentType);
- res.setHeader('X-Cache', 'HIT');
- return res.send(cached.buffer);
+ // ✅ Cache HIT → redirection instantanée vers CDN
+ const cached = downloadUrlCache.get(url);
+ if (cached && Date.now() < cached.expiresAt) {
+ res.setHeader('Cache-Control', 'private, max-age=3600');
+ return res.redirect(302, cached.url);
}
try {
- const buffer = await downloadFromSharePoint(url);
- const urlLower = url.toLowerCase();
- let contentType = 'application/octet-stream';
- if (urlLower.includes('.pdf')) contentType = 'application/pdf';
- else if (urlLower.includes('.jpg') || urlLower.includes('.jpeg')) contentType = 'image/jpeg';
- else if (urlLower.includes('.png')) contentType = 'image/png';
+ const accessToken = await getGraphToken();
+ const urlObj = new URL(url);
+ const fullPath = decodeURIComponent(urlObj.pathname);
+ const marker = '/Shared Documents/';
+ const markerAlt = '/Documents/';
+ let relativePath = '';
+ if (fullPath.includes(marker)) relativePath = fullPath.split(marker)[1];
+ else if (fullPath.includes(markerAlt)) relativePath = fullPath.split(markerAlt)[1];
+ else {
+ const parts = fullPath.split('/sites/')[1]?.split('/');
+ relativePath = parts?.slice(2).join('/') || '';
+ }
+
+ const metaRes = await axios.get(
+ `https://graph.microsoft.com/v1.0/sites/${SHAREPOINT_CONFIG.siteId}/drives/${SHAREPOINT_CONFIG.driveId}/root:/${relativePath}`,
+ {
+ headers: { Authorization: `Bearer ${accessToken}` },
+ timeout: 15000 // ← 5000 → 15000ms
+ }
+ );
+ const downloadUrl = metaRes.data['@microsoft.graph.downloadUrl'];
+ if (!downloadUrl) throw new Error('downloadUrl absent');
+
+ downloadUrlCache.set(url, { url: downloadUrl, expiresAt: Date.now() + 50 * 60 * 1000 });
+
+ res.setHeader('Cache-Control', 'private, max-age=3600');
+ return res.redirect(302, downloadUrl);
- setCache(url, buffer, contentType);
- res.setHeader('Content-Type', contentType);
- res.setHeader('X-Cache', 'MISS');
- res.send(buffer);
} catch (err) {
- console.error('❌ proxy-pdf erreur:', err.message);
- res.status(500).json({ error: err.message, url });
+ console.error('proxy-pdf erreur:', err.message);
+ res.status(500).json({ error: err.message });
}
});
-
// ================================================
// GET /api/notes/pending
// ================================================
@@ -2391,13 +3138,11 @@ app.get('/api/notes/:id/detail', authenticateToken, async (req, res) => {
// ================================================
// PUT /api/notes/:id/statut — Valider ou refuser
// ================================================
-// PUT /api/notes/:id/statut — Valider ou refuser
app.put('/api/notes/:id/statut', authenticateToken, async (req, res) => {
try {
const { id } = req.params;
const { action, commentaire, motifRefus } = req.body;
const userId = Number(req.user.id);
- console.log('Validation demande', id, action, userId);
const noteResult = await pool.request()
.input('id', sql.Int, id)
@@ -2457,43 +3202,60 @@ app.put('/api/notes/:id/statut', authenticateToken, async (req, res) => {
(@noteId, @validateurId, @niveau, @action, @commentaire, @motifRefus, @statut, GETDATE())
`);
- // Génération PDF signé
- let signedPdfUrl = null;
- try {
- const validateurSelfResult = await pool.request()
- .input('id', sql.Int, userId)
- .query('SELECT prenom, nom FROM CollaborateurAD WHERE id = @id');
- const validateurSelf = validateurSelfResult.recordset[0];
- const nomValidateurActuel = (validateurSelf
- ? `${validateurSelf.prenom} ${validateurSelf.nom}`
- : `${req.user.prenom} ${req.user.nom}`).trim();
+ res.json({ success: true, statut: nouveauStatut, niveau: niveauValidation });
- const noteComplete = await pool.request()
- .input('id', sql.Int, id)
- .query(`
- SELECT n.reference, n.libelle, n.montant, n.date, n.categorie,
- n.montantHT, n.tauxTVA, n.km, n.participants, n.description,
- n.fichiers, n.DateCreation, n.collaborateurId, n.lignesJson,
- n.commentaireN1, n.commentaireN2, n.dateValidationN1, n.dateValidationN2,
- c.prenom + ' ' + c.nom AS nomPrenom,
- c.prenom AS collabPrenom, c.nom AS collabNom, c.departement,
- v1.prenom + ' ' + v1.nom AS nomValidateurN1,
- v2.prenom + ' ' + v2.nom AS nomValidateurN2
- FROM NoteDeFrais n
- JOIN CollaborateurAD c ON c.id = n.collaborateurId
- LEFT JOIN CollaborateurAD v1 ON v1.id = n.validateurN1Id
- LEFT JOIN CollaborateurAD v2 ON v2.id = n.validateurN2Id
- WHERE n.id = @id
- `);
+ setImmediate(async () => {
+ try {
+ console.log(`🔄 [ASYNC] PDF + emails validation ${id} → ${nouveauStatut}`);
- if (noteComplete.recordset.length) {
- const nd = noteComplete.recordset[0];
+ const frontendUrl = process.env.FRONTEND_URL || 'myndf.ensup-adm.net';
+ const montantFormate = parseFloat(note.montant).toFixed(2);
+
+ const [collabResult, validateurResult, noteCompleteResult] = await Promise.all([
+ pool.request()
+ .input('id', sql.Int, note.collaborateurId)
+ .query('SELECT id, email, prenom, nom FROM CollaborateurAD WHERE id = @id'),
+ pool.request()
+ .input('id', sql.Int, userId)
+ .query('SELECT id, email, prenom, nom FROM CollaborateurAD WHERE id = @id'),
+ pool.request()
+ .input('id', sql.Int, id)
+ .query(`
+ SELECT n.reference, n.libelle, n.montant, n.date, n.categorie,
+ n.fichiers, n.DateCreation, n.collaborateurId, n.lignesJson,
+ n.commentaireN1, n.commentaireN2, n.dateValidationN1, n.dateValidationN2,
+ c.prenom + ' ' + c.nom AS nomPrenom,
+ c.prenom AS collabPrenom, c.nom AS collabNom, c.departement,
+ v1.prenom + ' ' + v1.nom AS nomValidateurN1,
+ v2.prenom + ' ' + v2.nom AS nomValidateurN2
+ FROM NoteDeFrais n
+ JOIN CollaborateurAD c ON c.id = n.collaborateurId
+ LEFT JOIN CollaborateurAD v1 ON v1.id = n.validateurN1Id
+ LEFT JOIN CollaborateurAD v2 ON v2.id = n.validateurN2Id
+ WHERE n.id = @id
+ `)
+ ]);
+
+ const c = collabResult.recordset[0];
+ const v = validateurResult.recordset[0];
+ const nd = noteCompleteResult.recordset[0];
+
+ if (!c || !nd) {
+ console.error(`❌ [ASYNC] Données manquantes pour note ${id}`);
+ return;
+ }
+
+ const nomValidateurActuel = v
+ ? `${v.prenom} ${v.nom}`.trim()
+ : `${req.user.prenom} ${req.user.nom}`.trim();
+
+ // ── Construire les signatures ──────────────────────────────
const signatures = [
{ niveau: 'COLLAB', nomPrenom: nd.nomPrenom, date: nd.DateCreation, action: 'soumettre', commentaire: null }
];
if (niveauValidation === 'N1') {
signatures.push({ niveau: 'N1', nomPrenom: nomValidateurActuel, date: new Date(), action, commentaire: commentaire ?? null });
- } else if (niveauValidation === 'N2') {
+ } else {
if (nd.nomValidateurN1 && nd.dateValidationN1)
signatures.push({ niveau: 'N1', nomPrenom: nd.nomValidateurN1, date: nd.dateValidationN1, action: 'valider', commentaire: nd.commentaireN1 ?? null });
signatures.push({ niveau: 'N2', nomPrenom: nomValidateurActuel, date: new Date(), action, commentaire: commentaire ?? null });
@@ -2507,169 +3269,224 @@ app.put('/api/notes/:id/statut', authenticateToken, async (req, res) => {
})();
const noteDataPDF = {
- reference: nd.reference, nomPrenom: nd.nomPrenom, mois: moisStr,
- departement: nd.departement, lignesJson: nd.lignesJson,
- tarifKm: await getTarifKm(), statut: nouveauStatut
+ reference: nd.reference,
+ nomPrenom: nd.nomPrenom,
+ mois: moisStr,
+ departement: nd.departement,
+ lignesJson: nd.lignesJson,
+ tarifKm: await getTarifKm(),
+ statut: nouveauStatut
};
- const pdfSigne = await generateFicheSignee(noteDataPDF, signatures);
- const suffixe = nouveauStatut === 'approuve' ? 'signe-approuve'
- : nouveauStatut === 'refuse' ? 'signe-refuse' : `signe-${nouveauStatut}`;
-
let fichiersExistants = [];
- try { fichiersExistants = JSON.parse(nd.fichiers); } catch { }
+ try { fichiersExistants = JSON.parse(nd.fichiers || '[]'); } catch { }
const existingFolder = fichiersExistants[0]?.folderPath;
const nomDossier = existingFolder
? existingFolder.split('/')[1]
- : `${nd.collabPrenom}${nd.collabNom}`.replace(/[^a-zA-Z0-9]/g, '');
+ : `${nd.collabPrenom}_${nd.collabNom}`.replace(/[^a-zA-Z0-9]/g, '_');
const moisDossier = existingFolder
? existingFolder.split('/')[2]
: `${new Date().getFullYear()}-${String(new Date().getMonth() + 1).padStart(2, '0')}`;
- const signedResult = await uploadToSharePointHierarchique(
- { buffer: pdfSigne, originalname: `${nd.reference}-${suffixe}.pdf`, mimetype: 'application/pdf', size: pdfSigne.length },
- nd.reference, nomDossier, moisDossier
- );
- fichiersExistants.push(signedResult);
+ // ── Génération PDF signé (fiche seule) ────────────────────
+ try {
+ const pdfSigne = await generateFicheSignee(noteDataPDF, signatures);
+ const suffixe = nouveauStatut === 'approuve' ? 'signe-approuve'
+ : nouveauStatut === 'refuse' ? 'signe-refuse'
+ : `signe-${nouveauStatut}`;
- await pool.request()
- .input('id', sql.Int, id)
- .input('fichiers', sql.NVarChar, JSON.stringify(fichiersExistants))
- .query('UPDATE NoteDeFrais SET fichiers = @fichiers WHERE id = @id');
+ const signedResult = await uploadToSharePointHierarchique(
+ { buffer: pdfSigne, originalname: `${nd.reference}-${suffixe}.pdf`, mimetype: 'application/pdf', size: pdfSigne.length },
+ nd.reference, nomDossier, moisDossier
+ );
+ fichiersExistants.push(signedResult);
- signedPdfUrl = signedResult.uploadUrl;
- console.log('PDF signé uploadé:', signedResult.fileName, suffixe);
- }
- } catch (pdfError) {
- console.error('Erreur génération PDF signé:', pdfError.message);
- }
+ await pool.request()
+ .input('id', sql.Int, id)
+ .input('fichiers', sql.NVarChar, JSON.stringify(fichiersExistants))
+ .query('UPDATE NoteDeFrais SET fichiers = @fichiers WHERE id = @id');
- // Notifications collaborateur + validateur suivant
- const frontendUrl = process.env.FRONTEND_URL || 'myndf.ensup-adm.net';
- const montantFormate = parseFloat(note.montant).toFixed(2);
- const collabResult = await pool.request().input('id', sql.Int, note.collaborateurId).query('SELECT id, email, prenom, nom FROM CollaborateurAD WHERE id = @id');
- const validateurResult = await pool.request().input('id', sql.Int, userId).query('SELECT id, email, prenom, nom FROM CollaborateurAD WHERE id = @id');
-
- if (collabResult.recordset.length) {
- const c = collabResult.recordset[0];
- const v = validateurResult.recordset[0];
- const isApprouve = nouveauStatut === 'approuve';
- const isValidn1 = nouveauStatut === 'validen1';
- const isRefus = nouveauStatut === 'refuse';
- const titreCollab = isApprouve ? `Note ${note.reference} approuvée` : isValidn1 ? `Note ${note.reference} validée N1` : `Note ${note.reference} refusée`;
- const msgCollab = isApprouve
- ? `Votre note ${note.reference} (${montantFormate}€) a été approuvée.`
- : isValidn1
- ? `Votre note ${note.reference} a été validée N1 par ${v?.prenom} ${v?.nom}.`
- : `Votre note ${note.reference} a été refusée. Motif : ${motifRefus || commentaire || 'Non précisé'}`;
-
- try { await creerNotification({ destinataireId: c.id, destinataireEmail: c.email, type: isRefus ? 'refus' : 'validation', titre: titreCollab, message: msgCollab, noteId: parseInt(id) }); } catch { }
-
- // ── Email collaborateur ──────────────────────────────────────────
- try {
- const motifAffiche = motifRefus || commentaire || 'Non précisé';
- const nomValidateur = `${v?.prenom || ''} ${v?.nom || ''}`.trim();
-
- await sendMailGraph(
- c.email,
- isRefus
- ? `❌ Note refusée — action requise : ${note.reference}`
- : titreCollab,
- isRefus
- ? `
-
-
❌ Votre note de frais a été refusée
-
Une action de votre part est nécessaire
-
-
-
Bonjour ${c.prenom} ${c.nom},
-
Votre note ${note.reference} a été refusée par ${nomValidateur}.
-
-
-
Motif du refus
-
${motifAffiche}
-
-
-
-
- | Référence | ${note.reference} |
- | Libellé | ${note.libelle} |
- | Montant | ${montantFormate} € |
- | Refusé par | ${nomValidateur} |
- | Date | ${new Date().toLocaleDateString('fr-FR', { day: '2-digit', month: 'long', year: 'numeric' })} |
-
-
-
-
-
📝 Que faire maintenant ?
-
- - Connectez-vous à la plateforme NDF
- - Rendez-vous dans Mes notes
- - Cliquez sur la note ${note.reference}
- - Corrigez les informations demandées
- - Resoumettez la note
-
-
-
-
-
- Vous pouvez modifier votre note tant qu'elle est au statut "Refusée".
-
-
-
`
- : `
-
-
${titreCollab}
-
-
-
Bonjour ${c.prenom} ${c.nom},
-
${msgCollab}
-
-
-
`
- );
- } catch { }
-
- // Notifier N2 si validation N1
- if (action === 'valider' && niveauValidation === 'N1' && note.validateurN2Id && n2Id !== userId) {
- const n2Result = await pool.request().input('id', sql.Int, note.validateurN2Id).query('SELECT id, email, prenom, nom FROM CollaborateurAD WHERE id = @id');
- if (n2Result.recordset.length) {
- const n2 = n2Result.recordset[0];
- try { await creerNotification({ destinataireId: n2.id, destinataireEmail: n2.email, type: 'validation', titre: `Note à valider N2 : ${note.reference}`, message: `La note ${note.reference} (${montantFormate}€) de ${c.prenom} ${c.nom} attend votre validation finale.`, noteId: parseInt(id) }); } catch { }
- try {
- await sendMailGraph(n2.email, `Note à valider N2 : ${note.reference}`, `
-
-
-
Note à valider — Niveau N2
-
-
-
Bonjour ${n2.prenom} ${n2.nom},
-
La note ${note.reference} de ${c.prenom} ${c.nom} (${montantFormate}€) a été validée N1 et attend votre validation finale.
-
-
-
`);
- } catch { }
+ console.log(`✅ [ASYNC] PDF signé uploadé: ${signedResult.fileName}`);
+ } catch (pdfError) {
+ console.error('❌ [ASYNC] Génération PDF signé:', pdfError.message);
}
- }
- }
- res.json({ success: true, statut: nouveauStatut, niveau: niveauValidation });
+ // ── Régénérer le recap complet (fiche + justifs + signatures à jour) ──
+ try {
+ const EXCLUS_RECAP = ['soumission', 'resoumission', 'signe', 'verifie', 'recap'];
+ const justifFiles = [];
+
+ for (const f of fichiersExistants) {
+ const fname = (f.fileName || '').toLowerCase();
+ if (EXCLUS_RECAP.some(kw => fname.includes(kw))) continue;
+ try {
+ const buf = await downloadFromSharePoint(f.uploadUrl);
+ const mimetype = fname.endsWith('.pdf') ? 'application/pdf'
+ : fname.endsWith('.png') ? 'image/png' : 'image/jpeg';
+ justifFiles.push({ buffer: buf, originalname: f.fileName, mimetype, size: buf.length });
+ } catch (e) { console.warn(`⚠️ Justif recap non récupérable: ${f.fileName}`, e.message); }
+ }
+
+ const recapBuffer = await generateRecapWithJustifs(noteDataPDF, justifFiles, signatures);
+ const recapResult = await uploadToSharePointHierarchique(
+ {
+ buffer: recapBuffer,
+ originalname: `${nd.reference}_recap.pdf`,
+ mimetype: 'application/pdf',
+ size: recapBuffer.length
+ },
+ nd.reference, nomDossier, moisDossier
+ );
+
+ // Remplacer l'ancien _recap.pdf (sauf recap-paiement)
+ const fichiersAvecRecap = fichiersExistants.filter(f => {
+ const fname = (f.fileName || '').toLowerCase();
+ return !fname.endsWith('_recap.pdf') || fname.includes('recap-paiement');
+ });
+ fichiersAvecRecap.push(recapResult);
+
+ await pool.request()
+ .input('id', sql.Int, id)
+ .input('fichiers', sql.NVarChar, JSON.stringify(fichiersAvecRecap))
+ .query('UPDATE NoteDeFrais SET fichiers = @fichiers WHERE id = @id');
+
+ console.log(`✅ [ASYNC] Recap PDF régénéré avec ${signatures.length} signature(s): ${recapResult.fileName}`);
+ } catch (recapError) {
+ console.error('❌ [ASYNC] Régénération recap:', recapError.message);
+ }
+
+ // ── Notifications + emails ────────────────────────────────
+ const isApprouve = nouveauStatut === 'approuve';
+ const isValidn1 = nouveauStatut === 'validen1';
+ const isRefus = nouveauStatut === 'refuse';
+ const titreCollab = isApprouve ? `Note ${note.reference} approuvée`
+ : isValidn1 ? `Note ${note.reference} validée N1`
+ : `Note ${note.reference} refusée`;
+ const msgCollab = isApprouve
+ ? `Votre note ${note.reference} (${montantFormate}€) a été approuvée.`
+ : isValidn1
+ ? `Votre note ${note.reference} a été validée N1 par ${nomValidateurActuel}.`
+ : `Votre note ${note.reference} a été refusée. Motif : ${motifRefus || commentaire || 'Non précisé'}`;
+
+ const motifAffiche = motifRefus || commentaire || 'Non précisé';
+
+ const emailCollabHtml = isRefus
+ ? `
+
+
❌ Votre note de frais a été refusée
+
Une action de votre part est nécessaire
+
+
+
Bonjour ${c.prenom} ${c.nom},
+
Votre note ${note.reference} a été refusée par ${nomValidateurActuel}.
+
+
Motif du refus
+
${motifAffiche}
+
+
+
+ | Référence | ${note.reference} |
+ | Libellé | ${note.libelle} |
+ | Montant | ${montantFormate} € |
+ | Refusé par | ${nomValidateurActuel} |
+ | Date | ${new Date().toLocaleDateString('fr-FR', { day: '2-digit', month: 'long', year: 'numeric' })} |
+
+
+
+
📝 Que faire maintenant ?
+
+ - Connectez-vous à la plateforme NDF
+ - Rendez-vous dans Mes notes
+ - Cliquez sur la note ${note.reference}
+ - Corrigez les informations demandées
+ - Resoumettez la note
+
+
+
+
+
`
+ : `
+
+
${titreCollab}
+
+
+
Bonjour ${c.prenom} ${c.nom},
+
${msgCollab}
+
+
+
`;
+
+ const taches = [
+ creerNotification({
+ destinataireId: c.id,
+ destinataireEmail: c.email,
+ type: isRefus ? 'refus' : 'validation',
+ titre: titreCollab,
+ message: msgCollab,
+ noteId: parseInt(id)
+ }).catch(e => console.error('❌ [ASYNC] Notif collab:', e.message)),
+
+ sendMailGraph(
+ c.email,
+ isRefus ? `❌ Note refusée — action requise : ${note.reference}` : titreCollab,
+ emailCollabHtml
+ ).catch(e => console.error('❌ [ASYNC] Email collab:', e.message)),
+ ];
+
+ if (action === 'valider' && niveauValidation === 'N1' && note.validateurN2Id && n2Id !== userId) {
+ const n2Result = await pool.request()
+ .input('id', sql.Int, note.validateurN2Id)
+ .query('SELECT id, email, prenom, nom FROM CollaborateurAD WHERE id = @id');
+
+ if (n2Result.recordset.length) {
+ const n2 = n2Result.recordset[0];
+ taches.push(
+ creerNotification({
+ destinataireId: n2.id, destinataireEmail: n2.email,
+ type: 'validation',
+ titre: `Note à valider N2 : ${note.reference}`,
+ message: `La note ${note.reference} (${montantFormate}€) de ${c.prenom} ${c.nom} attend votre validation finale.`,
+ noteId: parseInt(id)
+ }).catch(e => console.error('❌ [ASYNC] Notif N2:', e.message)),
+
+ sendMailGraph(n2.email, `Note à valider N2 : ${note.reference}`,
+ `
+
+
Note à valider — Niveau N2
+
+
+
Bonjour ${n2.prenom} ${n2.nom},
+
La note ${note.reference} de ${c.prenom} ${c.nom} (${montantFormate}€) a été validée N1 et attend votre validation finale.
+
+
+
`
+ ).catch(e => console.error('❌ [ASYNC] Email N2:', e.message))
+ );
+ }
+ }
+
+ await Promise.all(taches);
+ console.log(`✅ [ASYNC] Validation terminée pour note ${id} → ${nouveauStatut}`);
+
+ } catch (e) {
+ console.error(`❌ [ASYNC] Erreur générale validation note ${id}:`, e.message);
+ }
+ });
+
} catch (error) {
console.error('Erreur validation:', error.message);
res.status(500).json({ error: error.message });
}
});
-
// ================================================
// GET /api/notes/:id/historique
// ================================================
@@ -3127,12 +3944,26 @@ app.get('/api/notes-all', authenticateToken, async (req, res) => {
const request = pool.request();
let campusWhere = '';
+
if (req.user.campus) {
const campusCode = normalizeCampus(req.user.campus);
- if (campusCode) {
- request.input('campus', sql.NVarChar, `%${campusCode}%`);
- campusWhere = `AND c.campus LIKE @campus`;
- }
+
+ // Variantes de recherche par campus normalisé
+ const campusVariants = {
+ 'SQY': ['%SQY%', '%SAINT%'],
+ 'CGY': ['%CGY%', '%CERGY%'],
+ 'MRS': ['%MRS%', '%MARSEILLE%'],
+ 'NTE': ['%NTE%', '%NANTES%'],
+ };
+
+ const variants = campusVariants[campusCode] || [`%${campusCode}%`];
+
+ // Construire les conditions OR pour chaque variante
+ const conditions = variants.map((v, i) => {
+ request.input(`campus${i}`, sql.NVarChar, v);
+ return `c.campus LIKE @campus${i}`;
+ });
+ campusWhere = `AND (${conditions.join(' OR ')})`;
}
const statutFilter = hasAnyRole(req.user, 'ValidateurFinance') && !hasAnyRole(req.user, 'Finance')
@@ -3143,7 +3974,6 @@ app.get('/api/notes-all', authenticateToken, async (req, res) => {
const result = await request.query(`
SELECT n.*,
-
c.nom + ' ' + c.prenom AS collaborateur,
c.departement, c.campus, c.societe,
v1.nom + ' ' + v1.prenom AS nomN1,
@@ -3195,16 +4025,20 @@ app.post('/api/paiements/generer-xml', authenticateToken, async (req, res) => {
if (!notes.recordset.length)
return res.status(404).json({ error: 'Aucune note approuvée/vérifiée trouvée' });
+ // ── Validation des données AVANT de générer quoi que ce soit ─────
+ // On fait toutes les vérifications en une seule requête SQL (batch)
+ const checksResult = await pool.request().query(`
+ SELECT id AS collabId, IBAN, BIC, adresse_rue, adresse_cp, adresse_ville, adresse_pays,
+ nom, prenom
+ FROM CollaborateurAD
+ WHERE id IN (${notes.recordset.map(n => n.collabId).join(',')})
+ `);
+ const checksMap = {};
+ for (const c of checksResult.recordset) checksMap[c.collabId] = c;
+
const erreurs = [];
for (const n of notes.recordset) {
- const checks = await pool.request()
- .input('collabId', sql.Int, n.collabId)
- .query(`
- SELECT IBAN, BIC, adresse_rue, adresse_cp, adresse_ville, adresse_pays
- FROM CollaborateurAD
- WHERE id = @collabId
- `);
- const c = checks.recordset[0];
+ const c = checksMap[n.collabId];
if (!c) { erreurs.push(`${n.reference} : collaborateur introuvable`); continue; }
if (!c.IBAN) erreurs.push(`${n.reference} (${n.prenom} ${n.nom}) : IBAN manquant`);
if (!c.BIC) erreurs.push(`${n.reference} (${n.prenom} ${n.nom}) : BIC manquant`);
@@ -3212,10 +4046,7 @@ app.post('/api/paiements/generer-xml', authenticateToken, async (req, res) => {
erreurs.push(`${n.reference} (${n.prenom} ${n.nom}) : adresse postale incomplète`);
}
if (erreurs.length > 0)
- return res.status(422).json({
- error: 'Données manquantes — XML non généré',
- details: erreurs
- });
+ return res.status(422).json({ error: 'Données manquantes — XML non généré', details: erreurs });
const now = new Date();
const annee = now.getFullYear();
@@ -3226,20 +4057,25 @@ app.post('/api/paiements/generer-xml', authenticateToken, async (req, res) => {
const total = notes.recordset.reduce((s, n) => s + parseFloat(n.montant), 0);
const totalFormate = total.toFixed(2);
- // ── Config débiteur depuis .env ──────────────────────────────────
- const cfg = await getConfigDebiteur();
- const dbtrNom = cfg.companyName;
- const dbtrIban = cfg.companyIban;
- const dbtrBic = cfg.companyBic;
- const dbtrAdrLine = cfg.companyAddress;
- const dbtrCp = cfg.companyCp;
- const dbtrVille = cfg.companyVille;
- const dbtrPays = cfg.companyPays;
+ // Détecter le campus dominant des notes sélectionnées
+ const campusDominant = (() => {
+ const campusCounts = {};
+ for (const n of notes.recordset) {
+ const code = normalizeCampus(n.campus || '') || n.campus || '';
+ if (code) campusCounts[code] = (campusCounts[code] || 0) + 1;
+ }
+ // Campus le plus fréquent parmi les notes
+ return Object.entries(campusCounts).sort((a, b) => b[1] - a[1])[0]?.[0] || null;
+ })();
- // ── Générer les transactions ──────────────────────────────────────
+ const cfg = await getConfigDebiteur(campusDominant);
+ console.log(`🏦 Config débiteur utilisée : ${cfg.companyName} (campus: ${campusDominant || 'global'})`);
+ const { companyName: dbtrNom, companyIban: dbtrIban, companyBic: dbtrBic,
+ companyAddress: dbtrAdrLine, companyCp: dbtrCp,
+ companyVille: dbtrVille, companyPays: dbtrPays } = cfg;
+
+ // ── Générer les transactions XML ──────────────────────────────────
let transactions = '';
- let numTx = 1;
-
for (const n of notes.recordset) {
let ibanClair = 'FR0000000000000000000000000';
try {
@@ -3254,8 +4090,6 @@ app.post('/api/paiements/generer-xml', authenticateToken, async (req, res) => {
const cp = n.adresse_cp || '';
const ville = (n.adresse_ville || '').toUpperCase();
const pays = (n.adresse_pays || 'FR').slice(0, 2).toUpperCase();
-
- // BIC bénéficiaire : si présent utiliser, sinon NOTPROVIDED
const benefBicBlock = n.bic
? `
${n.bic}`
: `
NOTPROVIDED`;
@@ -3288,10 +4122,8 @@ app.post('/api/paiements/generer-xml', authenticateToken, async (req, res) => {
`;
- numTx++;
}
- // ── XML final au format PAIN.001.001.03 ──────────────────────────
const xml = `
@@ -3342,127 +4174,10 @@ app.post('/api/paiements/generer-xml', authenticateToken, async (req, res) => {
`;
- // ── Upload XML sur SharePoint dans Virements/{annee}/{mois}/ ─────
- let xmlSharepointUrl = null;
- try {
- const xmlFileName = `virements-ndf-${annee}-${mois}-${Date.now().toString().slice(-5)}.xml`;
- const xmlFolderPath = `Virements/${annee}/${mois}`;
- const xmlUploadPath = `${xmlFolderPath}/${xmlFileName}`;
-
- const accessToken = await getGraphToken();
- if (accessToken) {
- const spRes = await axios.put(
- `https://graph.microsoft.com/v1.0/sites/${SHAREPOINT_CONFIG.siteId}/drives/${SHAREPOINT_CONFIG.driveId}/root:/${xmlUploadPath}:/content`,
- Buffer.from(xml, 'utf-8'),
- {
- headers: {
- Authorization: `Bearer ${accessToken}`,
- 'Content-Type': 'application/xml'
- },
- maxBodyLength: Infinity
- }
- );
- xmlSharepointUrl = spRes.data.webUrl;
- console.log(`✅ XML virement uploadé sur SharePoint : ${xmlUploadPath}`);
- }
- } catch (spErr) {
- console.error('⚠️ Upload XML SharePoint échoué (XML quand même téléchargé) :', spErr.message);
- }
-
- // ── Générer les PDF récap pour chaque note ────────────────────────
- for (const note of notes.recordset) {
- try {
- let fichiersExistants = [];
- try { fichiersExistants = JSON.parse(note.fichiers || '[]'); } catch { }
-
- const justifFiles = [];
- for (const f of fichiersExistants) {
- const name = (f.fileName || '').toLowerCase();
- if (name.includes('soumission') || name.includes('resoumission') || name.includes('recap')) continue;
- try {
- const buf = await downloadFromSharePoint(f.uploadUrl);
- const mimetype = name.endsWith('.pdf') ? 'application/pdf'
- : name.endsWith('.png') ? 'image/png' : 'image/jpeg';
- justifFiles.push({ buffer: buf, originalname: f.fileName, mimetype, size: buf.length });
- } catch (e) { console.warn(`⚠️ Justif non récupérable: ${f.fileName}`, e.message); }
- }
-
- const dateObj = new Date(note.date);
- const moisStr = dateObj.toLocaleDateString('fr-FR', { month: 'long', year: 'numeric' });
- const moisCapitalized = moisStr.charAt(0).toUpperCase() + moisStr.slice(1);
- const nomPrenom = `${note.nom.toUpperCase()} ${note.prenom}`;
-
- const histResult = await pool.request()
- .input('noteId', sql.Int, note.id)
- .query(`
- SELECT h.Niveau, h.Action, h.Commentaire, h.DateAction,
- c.prenom + ' ' + c.nom AS nomPrenom
- FROM HistoriqueValidation h
- JOIN CollaborateurAD c ON c.id = h.ValidateurId
- WHERE h.NoteDeFraisId = @noteId
- ORDER BY h.DateAction ASC
- `);
-
- const signatures = [
- { niveau: 'COLLAB', nomPrenom, date: note.DateCreation || new Date(), action: 'soumettre', commentaire: null },
- ...histResult.recordset.map(h => ({
- niveau: h.Niveau, nomPrenom: h.nomPrenom,
- date: h.DateAction, action: h.Action, commentaire: h.Commentaire || null
- }))
- ];
-
- const noteDataPDF = {
- reference: note.reference, nomPrenom, mois: moisCapitalized,
- date: note.date, categorie: note.categorie || 'Multiple',
- libelle: note.libelle, montant: parseFloat(note.montant),
- lignesJson: note.lignesJson, tarifKm: await getTarifKm(),
- statut: note.statut, departement: note.departement,
- };
-
- const recapBuffer = await generateRecapWithJustifs(noteDataPDF, justifFiles, signatures);
-
- const existingFolder = fichiersExistants[0]?.folderPath;
- const nomDossier = existingFolder
- ? existingFolder.split('/')[1]
- : `${note.prenom}_${note.nom}`.replace(/[^a-zA-Z0-9]/g, '_');
- const moisDossier = existingFolder
- ? existingFolder.split('/')[2]
- : `${annee}-${mois}`;
-
- const recapResult = await uploadToSharePointHierarchique(
- {
- buffer: recapBuffer,
- originalname: `${note.reference}_recap-paiement.pdf`,
- mimetype: 'application/pdf',
- size: recapBuffer.length
- },
- note.reference, nomDossier, moisDossier
- );
-
- fichiersExistants.push(recapResult);
-
- await pool.request()
- .input('id', sql.Int, note.id)
- .input('fichiers', sql.NVarChar, JSON.stringify(fichiersExistants))
- .input('recapUrl', sql.NVarChar, recapResult.uploadUrl)
- .query(`
- UPDATE NoteDeFrais
- SET fichiers = @fichiers,
- sharepointUrl = @recapUrl,
- DateModification = GETDATE()
- WHERE id = @id
- `);
-
- console.log(`✅ PDF récap-paiement généré pour ${note.reference}`);
- } catch (pdfErr) {
- console.error(`❌ PDF récap ${note.reference}:`, pdfErr.message);
- }
- }
-
// ── Passer en 'paiementenattente' + enregistrer date XML ─────────
+ // Fait AVANT res.send pour que le statut soit correct immédiatement
await pool.request()
.input('dateXml', sql.DateTime, now)
- .input('xmlUrl', sql.NVarChar, xmlSharepointUrl || null)
.query(`
UPDATE NoteDeFrais
SET statut = 'paiementenattente',
@@ -3472,32 +4187,139 @@ app.post('/api/paiements/generer-xml', authenticateToken, async (req, res) => {
AND statut IN ('approuve', 'approuvé', 'verifie')
`);
- // ── Notifier chaque collaborateur ─────────────────────────────────
- for (const n of notes.recordset) {
- try {
- await creerNotification({
- destinataireId: n.collabId,
- destinataireEmail: n.email,
- type: 'paiement',
- titre: `Paiement en cours de traitement : ${n.reference}`,
- message: `Votre note ${n.reference} de ${parseFloat(n.montant).toFixed(2)} € est en cours de traitement bancaire.`,
- noteId: n.id
- });
- } catch (e) { console.error('Notif paiementenattente:', e.message); }
- }
-
- // ── Téléchargement du XML côté client ────────────────────────────
+ // ── Réponse immédiate — le client reçoit le XML sans attendre ────
const xmlFileName = `virements-ndf-${annee}-${mois}-${todayISO}.xml`;
res.setHeader('Content-Type', 'application/xml; charset=iso-8859-1');
res.setHeader('Content-Disposition', `attachment; filename=${xmlFileName}`);
res.send(xml);
+ // ── Tout le reste en arrière-plan (non bloquant) ─────────────────
+ setImmediate(async () => {
+ console.log(`🔄 [ASYNC] Post-XML : SharePoint + PDFs + notifs pour ${notes.recordset.length} note(s)...`);
+
+ // 1. Upload XML sur SharePoint
+ try {
+ const spXmlFileName = `virements-ndf-${annee}-${mois}-${Date.now().toString().slice(-5)}.xml`;
+ const xmlUploadPath = `Virements/${annee}/${mois}/${spXmlFileName}`;
+ const accessToken = await getGraphToken();
+ if (accessToken) {
+ await axios.put(
+ `https://graph.microsoft.com/v1.0/sites/${SHAREPOINT_CONFIG.siteId}/drives/${SHAREPOINT_CONFIG.driveId}/root:/${xmlUploadPath}:/content`,
+ Buffer.from(xml, 'utf-8'),
+ { headers: { Authorization: `Bearer ${accessToken}`, 'Content-Type': 'application/xml' }, maxBodyLength: Infinity }
+ );
+ console.log(`✅ [ASYNC] XML uploadé sur SharePoint : ${xmlUploadPath}`);
+ }
+ } catch (spErr) {
+ console.error('⚠️ [ASYNC] Upload XML SharePoint échoué :', spErr.message);
+ }
+
+ // 2. Générer les PDFs récap + notifier en parallèle par note
+ const tarifKm = await getTarifKm();
+
+ await Promise.allSettled(notes.recordset.map(async (note) => {
+ try {
+ // PDFs récap
+ let fichiersExistants = [];
+ try { fichiersExistants = JSON.parse(note.fichiers || '[]'); } catch { }
+
+ const justifFiles = [];
+ for (const f of fichiersExistants) {
+ const name = (f.fileName || '').toLowerCase();
+ if (name.includes('soumission') || name.includes('resoumission') || name.includes('recap')) continue;
+ try {
+ const buf = await downloadFromSharePoint(f.uploadUrl);
+ const mimetype = name.endsWith('.pdf') ? 'application/pdf'
+ : name.endsWith('.png') ? 'image/png' : 'image/jpeg';
+ justifFiles.push({ buffer: buf, originalname: f.fileName, mimetype, size: buf.length });
+ } catch (e) { console.warn(`⚠️ [ASYNC] Justif non récupérable: ${f.fileName}`, e.message); }
+ }
+
+ const dateObj = new Date(note.date);
+ const moisStr = dateObj.toLocaleDateString('fr-FR', { month: 'long', year: 'numeric' });
+ const moisCapitalized = moisStr.charAt(0).toUpperCase() + moisStr.slice(1);
+ const nomPrenom = `${note.nom.toUpperCase()} ${note.prenom}`;
+
+ const histResult = await pool.request()
+ .input('noteId', sql.Int, note.id)
+ .query(`
+ SELECT h.Niveau, h.Action, h.Commentaire, h.DateAction,
+ c.prenom + ' ' + c.nom AS nomPrenom
+ FROM HistoriqueValidation h
+ JOIN CollaborateurAD c ON c.id = h.ValidateurId
+ WHERE h.NoteDeFraisId = @noteId
+ ORDER BY h.DateAction ASC
+ `);
+
+ const signatures = [
+ { niveau: 'COLLAB', nomPrenom, date: note.DateCreation || new Date(), action: 'soumettre', commentaire: null },
+ ...histResult.recordset.map(h => ({
+ niveau: h.Niveau, nomPrenom: h.nomPrenom,
+ date: h.DateAction, action: h.Action, commentaire: h.Commentaire || null
+ }))
+ ];
+
+ const noteDataPDF = {
+ reference: note.reference, nomPrenom, mois: moisCapitalized,
+ date: note.date, categorie: note.categorie || 'Multiple',
+ libelle: note.libelle, montant: parseFloat(note.montant),
+ lignesJson: note.lignesJson, tarifKm,
+ statut: note.statut, departement: note.departement,
+ };
+
+ const recapBuffer = await generateRecapWithJustifs(noteDataPDF, justifFiles, signatures);
+
+ const existingFolder = fichiersExistants[0]?.folderPath;
+ const nomDossier = existingFolder
+ ? existingFolder.split('/')[1]
+ : `${note.prenom}_${note.nom}`.replace(/[^a-zA-Z0-9]/g, '_');
+ const moisDossier = existingFolder
+ ? existingFolder.split('/')[2]
+ : `${annee}-${mois}`;
+
+ const recapResult = await uploadToSharePointHierarchique(
+ { buffer: recapBuffer, originalname: `${note.reference}_recap-paiement.pdf`, mimetype: 'application/pdf', size: recapBuffer.length },
+ note.reference, nomDossier, moisDossier
+ );
+
+ fichiersExistants.push(recapResult);
+
+ await pool.request()
+ .input('id', sql.Int, note.id)
+ .input('fichiers', sql.NVarChar, JSON.stringify(fichiersExistants))
+ .input('recapUrl', sql.NVarChar, recapResult.uploadUrl)
+ .query(`
+ UPDATE NoteDeFrais
+ SET fichiers = @fichiers, sharepointUrl = @recapUrl, DateModification = GETDATE()
+ WHERE id = @id
+ `);
+
+ console.log(`✅ [ASYNC] PDF récap-paiement généré : ${note.reference}`);
+ } catch (pdfErr) {
+ console.error(`❌ [ASYNC] PDF récap ${note.reference}:`, pdfErr.message);
+ }
+
+ // Notification collaborateur (indépendante du PDF)
+ try {
+ await creerNotification({
+ destinataireId: note.collabId,
+ destinataireEmail: note.email,
+ type: 'paiement',
+ titre: `Paiement en cours de traitement : ${note.reference}`,
+ message: `Votre note ${note.reference} de ${parseFloat(note.montant).toFixed(2)} € est en cours de traitement bancaire.`,
+ noteId: note.id
+ });
+ } catch (e) { console.error(`❌ [ASYNC] Notif ${note.reference}:`, e.message); }
+ }));
+
+ console.log(`✅ [ASYNC] Traitement post-XML terminé`);
+ });
+
} catch (error) {
console.error('Erreur génération XML:', error.message);
res.status(500).json({ error: error.message });
}
});
-
// GET /api/paiements/xml-historique — liste les XML générés
app.get('/api/paiements/xml-historique', authenticateToken, async (req, res) => {
if (!hasAnyRole(req.user, 'Finance', 'ValidateurFinance', 'superUtilisateur'))
@@ -3580,7 +4402,15 @@ app.post('/api/paiements/regenerer-xml', authenticateToken, async (req, res) =>
const creDtTm = now.toISOString().slice(0, 19);
const msgId = `NDF-REGEN-${annee}${mois}-${Date.now().toString().slice(-7)}`;
const total = notes.recordset.reduce((s, n) => s + parseFloat(n.montant), 0).toFixed(2);
- const cfg = await getConfigDebiteur();
+ const campusDominant = (() => {
+ const campusCounts = {};
+ for (const n of notes.recordset) {
+ const code = normalizeCampus(n.campus || '') || n.campus || '';
+ if (code) campusCounts[code] = (campusCounts[code] || 0) + 1;
+ }
+ return Object.entries(campusCounts).sort((a, b) => b[1] - a[1])[0]?.[0] || null;
+ })();
+ const cfg = await getConfigDebiteur(campusDominant);
const dbtrNom = cfg.companyName;
const dbtrIban = cfg.companyIban;
const dbtrBic = cfg.companyBic;
@@ -3663,39 +4493,49 @@ app.post('/api/paiements/regenerer-xml', authenticateToken, async (req, res) =>
});
// GET /api/paiements/config-debiteur
+// GET — récupérer toutes les configs actives (une par campus)
app.get('/api/paiements/config-debiteur', authenticateToken, async (req, res) => {
if (!hasAnyRole(req.user, 'Finance', 'superUtilisateur'))
return res.status(403).json({ error: 'Accès réservé Finance' });
try {
const result = await pool.request().query(`
- SELECT TOP 1 id, companyName, companyIban, companyBic,
- companyAddress, companyCp, companyVille, companyPays,
- DateModification
+ SELECT id, companyName, companyIban, companyBic,
+ companyAddress, companyCp, companyVille, companyPays,
+ campus, DateModification
FROM ConfigDebiteurXML WHERE actif = 1
- ORDER BY DateModification DESC
+ ORDER BY CASE WHEN campus IS NULL THEN 1 ELSE 0 END, campus
`);
- res.json(result.recordset[0] ?? null);
+ res.json(result.recordset);
} catch (e) {
res.status(500).json({ error: e.message });
}
});
-// PUT /api/paiements/config-debiteur
+// PUT — créer/remplacer la config pour un campus donné
app.put('/api/paiements/config-debiteur', authenticateToken, async (req, res) => {
if (!hasAnyRole(req.user, 'Finance', 'superUtilisateur'))
return res.status(403).json({ error: 'Accès réservé Finance' });
- const { companyName, companyIban, companyBic, companyAddress, companyCp, companyVille, companyPays } = req.body;
+ const { companyName, companyIban, companyBic, companyAddress,
+ companyCp, companyVille, companyPays, campus } = req.body;
if (!companyName || !companyIban || !companyBic)
return res.status(400).json({ error: 'Nom, IBAN et BIC sont obligatoires' });
const ibanClean = companyIban.replace(/\s+/g, '').toUpperCase();
const bicClean = companyBic.replace(/\s+/g, '').toUpperCase();
+ const campusCode = campus ? (normalizeCampus(campus) || campus) : null;
try {
- // Désactiver l'ancienne config et insérer la nouvelle
- await pool.request().query(`UPDATE ConfigDebiteurXML SET actif = 0 WHERE actif = 1`);
+ // Désactiver uniquement la config du même campus
+ if (campusCode) {
+ await pool.request()
+ .input('campus', sql.NVarChar, campusCode)
+ .query(`UPDATE ConfigDebiteurXML SET actif = 0 WHERE actif = 1 AND campus = @campus`);
+ } else {
+ await pool.request()
+ .query(`UPDATE ConfigDebiteurXML SET actif = 0 WHERE actif = 1 AND campus IS NULL`);
+ }
await pool.request()
.input('companyName', sql.NVarChar, companyName.trim())
@@ -3705,25 +4545,27 @@ app.put('/api/paiements/config-debiteur', authenticateToken, async (req, res) =>
.input('companyCp', sql.NVarChar, (companyCp || '').trim())
.input('companyVille', sql.NVarChar, (companyVille || '').trim())
.input('companyPays', sql.NVarChar, (companyPays || 'FR').trim().slice(0, 2).toUpperCase())
+ .input('campus', sql.NVarChar, campusCode)
.input('modifiePar', sql.Int, req.user.id)
.query(`
INSERT INTO ConfigDebiteurXML
(companyName, companyIban, companyBic, companyAddress,
- companyCp, companyVille, companyPays, actif, modifiePar,
+ companyCp, companyVille, companyPays, campus, actif, modifiePar,
DateCreation, DateModification)
VALUES
(@companyName, @companyIban, @companyBic, @companyAddress,
- @companyCp, @companyVille, @companyPays, 1, @modifiePar,
+ @companyCp, @companyVille, @companyPays, @campus, 1, @modifiePar,
GETDATE(), GETDATE())
`);
- console.log(`✅ Config débiteur XML mise à jour par ${req.user.email}`);
- res.json({ success: true, companyName, companyIban: ibanClean, companyBic: bicClean });
+ res.json({ success: true, campus: campusCode, companyName, companyIban: ibanClean });
} catch (e) {
- console.error('PUT /api/paiements/config-debiteur:', e.message);
res.status(500).json({ error: e.message });
}
});
+
+// PUT /api/paiements/config-debiteur
+
// POST /api/paiements/confirmer-paiement
// Body: { noteIds: number[], datePaiement: string (ISO) }
// POST /api/paiements/confirmer-paiement — Confirme paiement et passe statut à 'payee'
@@ -4646,28 +5488,42 @@ app.get('/api/paiements/filtres-disponibles', authenticateToken, async (req, res
`);
const campusSet = new Set();
+ // Map : campusCode → Set de sociétés
+ const societeParCampus = {};
const societeSet = new Set();
for (const row of result.recordset) {
if (row.campus) {
- const code = (() => {
- const c = row.campus.toUpperCase();
- if (c.includes('SQY') || c.includes('SAINT')) return 'SQY';
- if (c.includes('CGY') || c.includes('CERGY')) return 'CGY';
- if (c.includes('MRS') || c.includes('MARSEILLE')) return 'MRS';
- if (c.includes('NTE') || c.includes('NANTES')) return 'NTE';
- return row.campus;
- })();
+ const c = row.campus.toUpperCase();
+ const code =
+ c.includes('SQY') || c.includes('SAINT') ? 'SQY' :
+ c.includes('CGY') || c.includes('CERGY') ? 'CGY' :
+ c.includes('MRS') || c.includes('MARSEILLE') ? 'MRS' :
+ c.includes('NTE') || c.includes('NANTES') ? 'NTE' :
+ row.campus;
+
campusSet.add(code);
+
+ // Grouper les sociétés par campus normalisé
+ if (!societeParCampus[code]) societeParCampus[code] = new Set();
+
+ if (row.societe && row.societe.trim()) {
+ societeParCampus[code].add(row.societe.trim());
+ societeSet.add(row.societe.trim());
+ }
}
- if (row.societe && row.societe.trim()) {
- societeSet.add(row.societe.trim());
- }
+ }
+
+ // Convertir les Sets en tableaux triés
+ const societeParCampusFinal = {};
+ for (const [campus, set] of Object.entries(societeParCampus)) {
+ societeParCampusFinal[campus] = [...set].sort();
}
res.json({
campus: [...campusSet].sort(),
- societes: [...societeSet].sort()
+ societes: [...societeSet].sort(), // toutes sociétés (fallback)
+ societeParCampus: societeParCampusFinal, // sociétés par campus ← nouveau
});
} catch (error) {
diff --git a/ndf/src/components/Login.css b/ndf/src/components/Login.css
index 1b79aa6..4386c58 100644
--- a/ndf/src/components/Login.css
+++ b/ndf/src/components/Login.css
@@ -29,7 +29,7 @@
}
.login-header {
- background: linear-gradient(135deg, #f5f5dc 0%, #e8d7c3 100%);
+
color: white;
padding: 40px 30px;
text-align: center;
diff --git a/ndf/src/components/RoleSelector.tsx b/ndf/src/components/RoleSelector.tsx
index d868c85..e461dae 100644
--- a/ndf/src/components/RoleSelector.tsx
+++ b/ndf/src/components/RoleSelector.tsx
@@ -64,6 +64,31 @@ const ROLE_CONFIG: Record
{
validateur: 'Validateur',
validatrice: 'Validatrice',
finance: 'Finance',
+ verificateurfinance: 'VerificateurFinance',
+ validateurfinance: 'ValidateurFinance',
};
return map[role.toLowerCase()] ?? role;
};
diff --git a/ndf/src/index.css b/ndf/src/index.css
index 6d8de26..46a8158 100644
--- a/ndf/src/index.css
+++ b/ndf/src/index.css
@@ -8,7 +8,7 @@ body {
font-family: -apple-system, BlinkMacSystemFont, 'Segoe UI', 'Roboto', 'Oxygen', 'Ubuntu', 'Cantarell', 'Fira Sans', 'Droid Sans', 'Helvetica Neue', sans-serif;
-webkit-font-smoothing: antialiased;
-moz-osx-font-smoothing: grayscale;
- background: linear-gradient(135deg, #f5f5dc 0%, #e8d7c3 100%);
+
min-height: 100vh;
}
diff --git a/ndf/src/pages/AuthCallback.tsx b/ndf/src/pages/AuthCallback.tsx
index 2defeb7..25558bd 100644
--- a/ndf/src/pages/AuthCallback.tsx
+++ b/ndf/src/pages/AuthCallback.tsx
@@ -32,7 +32,7 @@ const AuthCallback = (): JSX.Element => {
justifyContent: 'center',
fontFamily: 'sans-serif',
fontSize: '18px',
- color: '#f5f5dc',
+
}}>
⏳ Connexion en cours...
diff --git a/ndf/src/pages/Dashboard.tsx b/ndf/src/pages/Dashboard.tsx
index f4b0f90..340e4af 100644
--- a/ndf/src/pages/Dashboard.tsx
+++ b/ndf/src/pages/Dashboard.tsx
@@ -4,8 +4,10 @@ import { RoleSwitcherSidebar } from '../components/RoleSwitcher';
import { ThemeToggleButton } from '../context/ThemeContext';
import NouvelleNote from './NouvelleNote';
import VerificateurFinanceLight from './VerificateurFinanceLight';
+import NDFChatbot from './NdfChatbot';
import QRCode from 'react-qr-code';
+
import {
LayoutDashboard, PlusCircle, FileText, CheckSquare, History,
CreditCard, User, LogOut, Receipt, Upload, Send,
@@ -30,7 +32,17 @@ function getMontantTVA(ttc: number, taux: number) {
// ── NORMALISATION STATUT ──────────────────────────────
const normalizeStatut = (s?: string) =>
s?.trim().toLowerCase().normalize('NFD').replace(/[\u0300-\u036f]/g, '') ?? '';
+// ── Cache client pour les fichiers proxy (évite de re-télécharger) ──
+const clientProxyCache = new Map