חתימת מסמכים בכמות גדולה: שליחה אוטומטית, מעקב ותזכורות

עם ניסיון של למעלה מ-5 שנים באוטומציה של מסמכים ו-50+ פרויקטים מוצלחים, חידדנו את הארכיטקטורה הזו כדי להתמודד עם עומסים של 10K+ מסמכים ללא קריסה.

כשממזגים שתי חברות, צריך לשלוח 5000 חוזי עבודה בתוך 48 שעות. שליחה ידנית דורשת 10 עובדים למשך שבוע, ומובילה לשגיאות הקלדה, אימיילים שאבדו וטרחה מרובה. אנחנו הופכים את התהליך לאוטומטי: העלאת CSV, יצירת PDF מותאם אישית, שליחה דרך תור משימות, מעקב אחר סטטוס ותזכורות אוטומטיות. להלן הארכיטקטורה שמתמודדת עם עומסים של 10K+ מסמכים ללא קריסה.

אתגרים מרכזיים ופתרונות

יצירת אלפי מסמכים ללא תקיעות בשרת. יצירה סינכרונית הייתה מפילה את השרת — אנו משתמשים בתור משימות המבוסס על BullMQ. כל מסמך נוצר על ידי עובד (worker) נפרד, עם מקביליות של עד 10. אפילו בשיא של 5000 מסמכים, המערכת נשארת מגיבה.

הגבלת קצב מספקי האימייל. Resend נותן 100 אימיילים בשנייה, ו-Postmark דומה.תיעוד ה-API של Resend עבור אצווה של 10K אימיילים, אנו מיישמים הגבלת קצב בתור: השליחה מתבצעת בקצב של 100–200 אימיילים לדקה כדי להימנע מחסימה. פסקי זמן וניסיונות חוזרים הם חובה.

חוסר חתימה של חלק מהנמענים. תזכורות אוטומטיות לאחר יומיים ו-4 ימים. מספר ניתן להגדרה (עד 3). לוח מחוונים מראה מי לא פתח את האימייל ומאפשר שליחת תזכורת ידנית.

טיפול בתור משימות באלפי מסמכים

יצירה סינכרונית של 5000 קבצי PDF הייתה גורמת לפסק זמן בשרת. תור BullMQ עם עובדים (מקביליות 10) מעבד מסמכים בהדרגה ללא חסימת בקשות. Redis מאחסן את ההתקדמות. אם עובד קורס, המשימה מתחילה מחדש אוטומטית. זה מספק אמינות וסקלביליות.

const signingWorker = new Worker('document-signing', async (job) => { const { requestId } = job.data; const request = await db.signingRequests.findByPk(requestId); try { await db.signingRequests.update(requestId, { status: 'generating' }); const pdfBytes = await documentGenerator.generate( request.template, request.templateData ); const document = await documentStorage.store(pdfBytes, { batchId: request.batchId, requestId: request.id, }); const signingUrl = `${process.env.APP_URL}/sign/${request.signingToken}`; await emailService.send({ to: request.recipientEmail, subject: 'Документ ожидает вашей подписи', template: 'signing-invitation', data: { recipientName: request.recipientName, documentName: request.template.name, signingUrl, expiresAt: request.expiresAt, }, }); await db.signingRequests.update(requestId, { status: 'sent', documentId: document.id, sentAt: new Date(), }); await db.signingBatches.increment(request.batchId, 'sent_count'); } catch (error) { await db.signingRequests.update(requestId, { status: 'failed', errorMessage: error.message, }); await db.signingBatches.increment(request.batchId, 'failed_count'); } }, { concurrency: 10, connection: redisConnection, }); 

ספקי אימייל חוסמים כשחורגים מהמגבלות. אנו מגדירים את התור עם השהיה בין שליחות. אנו משתמשים בשרתי שליחה ייעודיים (ממסרי SMTP) ועוקבים אחר סטטוסי האימייל (הקפצה, ספאם). אנו מבטיחים 99% מסירה.

הגדרת תזכורות אוטומטיות

אם הנמען לא חתם, המערכת שולחת תזכורות אוטומטית ביום השני וה-4. ביום השביעי, היא מסמנת כ'באיחור' ומודיעה למנהל. לוח המחוונים מאפשר שליחת אימייל חוזר עם קישור חדש. מגבלת תזכורות ניתנת להגדרה מ-0 עד 5.

async function sendSigningReminders() { const pending = await db.signingRequests.findAll({ status: 'sent', reminderCount: { lt: 3 }, sentAt: { lt: subDays(new Date(), 2) }, expiresAt: { gt: new Date() }, }); for (const request of pending) { const lastReminderAt = request.lastReminderAt || request.sentAt; const daysSinceLastReminder = differenceInDays(new Date(), lastReminderAt); if (daysSinceLastReminder >= 2) { await emailService.sendReminder(request); await db.signingRequests.update(request.id, { reminderCount: request.reminderCount + 1, lastReminderAt: new Date(), }); } } } 

יתרונות והשוואה

הפתרון האוטומטי שלנו מהיר פי 20 וזול פי 20 מעיבוד ידני. חיסכון משוער: עד $5,000 לאצווה, עם החזר השקעה (ROI) של 500% תוך חודשיים. המחיר הקבוע שלנו להקמה סטנדרטית הוא $4,900, כך שההשקעה מוחזרת באצווה הראשונה.

כיצד להגדיר חתימה בכמות גדולה

1. העלה CSV עם נתוני נמענים.
2. בחר תבנית מסמך.
3. הגדר הגדרות תור.
4. הפעל את האצווה.
5. עקוב אחר ההתקדמות בלוח המחוונים.

מודל נתונים

CREATE TABLE signing_batches ( id UUID PRIMARY KEY DEFAULT gen_random_uuid(), name VARCHAR(500), template_id UUID REFERENCES document_templates(id), initiated_by UUID REFERENCES users(id), total_count INT NOT NULL, sent_count INT DEFAULT 0, signed_count INT DEFAULT 0, failed_count INT DEFAULT 0, status VARCHAR(50) DEFAULT 'pending', -- pending → processing → completed / partially_failed deadline_at TIMESTAMPTZ, created_at TIMESTAMPTZ DEFAULT NOW() ); CREATE TABLE signing_requests ( id UUID PRIMARY KEY DEFAULT gen_random_uuid(), batch_id UUID REFERENCES signing_batches(id), recipient_email VARCHAR(500) NOT NULL, recipient_name VARCHAR(500), recipient_phone VARCHAR(50), template_data JSONB NOT NULL, document_id UUID REFERENCES documents(id), signing_token UUID UNIQUE DEFAULT gen_random_uuid(), status VARCHAR(50) DEFAULT 'pending', sent_at TIMESTAMPTZ, opened_at TIMESTAMPTZ, signed_at TIMESTAMPTZ, reminder_count INT DEFAULT 0, expires_at TIMESTAMPTZ, error_message TEXT ); 

העלאת CSV ואימות

async function processBatchUpload(file: Express.Multer.File, templateId: string) { const records = await parseCSV(file.buffer, { headers: true }); const template = await db.documentTemplates.findByPk(templateId); const requiredFields = extractTemplateVariables(template.content); const errors: ValidationError[] = []; const validRows: RecipientRow[] = []; records.forEach((row, index) => { const rowErrors = []; if (!row.email || !isValidEmail(row.email)) { rowErrors.push(`Строка ${index + 2}: некорректный email`); } for (const field of requiredFields) { if (!row[field]) { rowErrors.push(`Строка ${index + 2}: отсутствует поле "${field}"`); } } if (rowErrors.length > 0) { errors.push(...rowErrors); } else { validRows.push(row); } }); return { valid: validRows, errors, totalRows: records.length }; } 

דף חתימה ולוח מחוונים

הנמען עוקב אחר קישור חתימה ייחודי — אין צורך באימות, גישה רק דרך טוקן:

app.get('/sign/:token', async (req, res) => { const request = await db.signingRequests.findOne({ signingToken: req.params.token, status: { not: ['expired', 'signed', 'declined'] }, }); if (!request) return res.redirect('/sign/invalid'); if (request.expiresAt < new Date()) { await db.signingRequests.update(request.id, { status: 'expired' }); return res.redirect('/sign/expired'); } if (!request.openedAt) { await db.signingRequests.update(request.id, { openedAt: new Date() }); } res.render('signing-page', { request, document: request.document }); }); 

תכונות לוח מחוונים לניטור אצווה: סרגל התקדמות עם ספירות של נשלח/נחתם/לא נפתח/באיחור, טבלה עם מסנני סטטוס, ייצוא ל-CSV, וכפתור 'שלח תזכורת' לנמענים נבחרים.

מסירת פרויקט

מה כלול