/** * KLINIKA FORMY CRM SYSTEM v3.3 - KOMPLETNY KOD * * CHANGELOG v3.3: * - Dodana kontrola limitów emaili (90 dziennie) * - Automatyczne odkładanie emaili gdy limit przekroczony * - Liczniki emaili z resetowaniem codziennym * - Zmieniona częstotliwość triggerów na co 2 godziny * - Dodany nocny processor dla zaległych emaili * - Monitoring wykorzystania limitów * - POPRAWIONE: Dodane wszystkie brakujące funkcje * - POPRAWIONE: Walidacja danych wejściowych * - POPRAWIONE: Obsługa wszystkich typów emaili w kolejce */// ==================== KONFIGURACJA GŁÓWNA ==================== const CONFIG = { SPREADSHEET_ID: '1Q52bzhfuYQUFteOcj4RQ4Vi5oU4sIS1OE-xDMjXQINA', EBOOK_SHEET_NAME: 'DARMOWY EBOOK', PROGRAM_SHEET_NAME: 'ZGŁOSZENIE - Z EBOOKA', EMAIL_SENDER: 'owsiany1995@gmail.com', // GetResponse GETRESPONSE_API_KEY: '6vszd9996ta5xrzvzju0jqvfwukauzp2', GETRESPONSE_CAMPAIGN_ID: 'GS3qW', // Limity emaili EMAIL_LIMITS: { DAILY_LIMIT: 90, // Bezpieczny limit dzienny HOURLY_LIMIT: 20, // Limit godzinowy BATCH_SIZE: 5 // Ile emaili przetwarzać na raz }, // Kolumny arkusza COLUMNS: { EBOOK_GETRESPONSE: 11, // K PROGRAM_GETRESPONSE: 22, // V EMAIL_1_STATUS: 12, // L EMAIL_2_STATUS: 13, // M EMAIL_3_STATUS: 14, // N EMAIL_4_STATUS: 15, // O PURCHASE_STATUS: 18, // R KONSULTACJA_POTWIERDZENIE: 23, // W KONSULTACJA_24H: 24, // X KONSULTACJA_2H: 25, // Y KONSULTACJA_15MIN: 26, // Z KONSULTACJA_10MIN_PO: 27, // AA KONSULTACJA_24H_PO: 28, // AB KONSULTACJA_3DNI_PO: 29, // AC CALENDAR_EVENT_ID: 30, // AD ANKIETA_STATUS: 31 // AE }, // Opóźnienia emaili (w milisekundach) DELAYS: { EMAIL_2: 5 * 60 * 60 * 1000, // 5 godzin EMAIL_3: 24 * 60 * 60 * 1000, // 24 godziny EMAIL_4: 48 * 60 * 60 * 1000, // 48 godzin KONSULTACJA_10MIN: 10 * 60 * 1000, // 10 minut KONSULTACJA_24H: 24 * 60 * 60 * 1000, KONSULTACJA_3DNI: 72 * 60 * 60 * 1000, KONSULTACJA_7DNI: 168 * 60 * 60 * 1000 }, // URLs URLS: { LANDING_PAGE_2: 'https://akf.klinika-formy.pl/wyslane/', CONFIRMATION_PAGE: 'https://akf.klinika-formy.pl/zgloszenie-przeslane/', OPINIONS: 'https://klinika-formy.pl/opinie/', FACEBOOK_GROUP: 'https://www.facebook.com/groups/klinikaformy', LOGO: 'https://akf.klinika-formy.pl/wp-content/uploads/2025/05/Bez-tytulu-1080-x-432-px-1.png', KAMIL_PHOTO: 'https://akf.klinika-formy.pl/wp-content/uploads/2025/07/@klinika.formy-1.png', PLATFORM_VIDEO: 'https://www.youtube.com/watch?v=KHkeiYJE6gg', GENERAL_PLAN_DOC: 'https://docs.google.com/document/d/1TS7NAsi-w_tsj4LyR0Szdjy1YyrZ6Aim3C9yCjttGAs/edit?usp=sharing', ANKIETA_FORM: 'https://akf.klinika-formy.pl/badanie/', PAYMENT_1350: 'https://buy.stripe.com/5kA4gz3m381Z0106oo', PAYMENT_3RATY: 'https://tubapay.pl/s/MPVlaYMD', PAYMENT_6RAT: 'https://tubapay.pl/s/vHNGc9CV', DOWNLOAD_PAGE: 'https://klinika-formy.pl/pobierz/' }, // System Settings QUEUE_PROCESSING_INTERVAL: 120, // minuty (co 2 godziny) MAX_QUEUE_AGE_DAYS: 30, SYSTEM_VERSION: '3.3' };// ==================== SYSTEM KONTROLI LIMITÓW ==================== function checkEmailQuota() { const properties = PropertiesService.getScriptProperties(); const today = new Date().toDateString(); const currentHour = new Date().getHours(); // Sprawdź dzienny limit const dailyCountKey = 'email_count_' + today; const dailyCount = parseInt(properties.getProperty(dailyCountKey) || '0'); if (dailyCount >= CONFIG.EMAIL_LIMITS.DAILY_LIMIT) { Logger.log('[Quota] Przekroczono dzienny limit emaili: ' + dailyCount); return false; } // Sprawdź godzinowy limit const hourlyCountKey = 'email_count_' + today + '_' + currentHour; const hourlyCount = parseInt(properties.getProperty(hourlyCountKey) || '0'); if (hourlyCount >= CONFIG.EMAIL_LIMITS.HOURLY_LIMIT) { Logger.log('[Quota] Przekroczono godzinowy limit emaili: ' + hourlyCount); return false; } return true; }function incrementEmailCounter() { const properties = PropertiesService.getScriptProperties(); const today = new Date().toDateString(); const currentHour = new Date().getHours(); // Zwiększ dzienny licznik const dailyCountKey = 'email_count_' + today; const dailyCount = parseInt(properties.getProperty(dailyCountKey) || '0'); properties.setProperty(dailyCountKey, String(dailyCount + 1)); // Zwiększ godzinowy licznik const hourlyCountKey = 'email_count_' + today + '_' + currentHour; const hourlyCount = parseInt(properties.getProperty(hourlyCountKey) || '0'); properties.setProperty(hourlyCountKey, String(hourlyCount + 1)); Logger.log(`[Quota] Emaile wysłane dziś: ${dailyCount + 1}/${CONFIG.EMAIL_LIMITS.DAILY_LIMIT}, w tej godzinie: ${hourlyCount + 1}/${CONFIG.EMAIL_LIMITS.HOURLY_LIMIT}`); }function getEmailQuotaStatus() { const properties = PropertiesService.getScriptProperties(); const today = new Date().toDateString(); const currentHour = new Date().getHours(); const dailyCount = parseInt(properties.getProperty('email_count_' + today) || '0'); const hourlyCount = parseInt(properties.getProperty('email_count_' + today + '_' + currentHour) || '0'); return { daily: { used: dailyCount, limit: CONFIG.EMAIL_LIMITS.DAILY_LIMIT, remaining: CONFIG.EMAIL_LIMITS.DAILY_LIMIT - dailyCount, percentage: Math.round((dailyCount / CONFIG.EMAIL_LIMITS.DAILY_LIMIT) * 100) }, hourly: { used: hourlyCount, limit: CONFIG.EMAIL_LIMITS.HOURLY_LIMIT, remaining: CONFIG.EMAIL_LIMITS.HOURLY_LIMIT - hourlyCount } }; }function checkEmailLimits() { const status = getEmailQuotaStatus(); Logger.log(`[Limits] Status: ${status.daily.used}/${status.daily.limit} emaili dziennie (${status.daily.percentage}%), ${status.hourly.used}/${status.hourly.limit} w tej godzinie`); if (status.daily.used >= CONFIG.EMAIL_LIMITS.DAILY_LIMIT) { Logger.log('[Limits] UWAGA: Limit dzienny wyczerpany!'); } else if (status.daily.used >= 75) { Logger.log('[Limits] UWAGA: Zbliżamy się do limitu dziennego!'); } return status; }// ==================== GŁÓWNY HANDLER POST ==================== function doPost(e) { const lock = LockService.getScriptLock(); try { lock.waitLock(10000); const data = e.parameter; // Walidacja danych wejściowych const emailRegex = /^[^\s@]+@[^\s@]+\.[^\s@]+$/; if (!data.email || !emailRegex.test(data.email)) { throw new Error('Nieprawidłowy adres email'); } if (!data.formType) { throw new Error('Brak typu formularza'); } const sheetName = data.formType === 'program' ? CONFIG.PROGRAM_SHEET_NAME : CONFIG.EBOOK_SHEET_NAME; const spreadsheet = SpreadsheetApp.openById(CONFIG.SPREADSHEET_ID); const sheet = spreadsheet.getSheetByName(sheetName); if (!sheet) { throw new Error(`Arkusz nie istnieje: ${sheetName}`); } const timestamp = new Date(); let rowData = []; if (sheetName === CONFIG.EBOOK_SHEET_NAME) { rowData = processEbookForm(data, timestamp); } else { rowData = processProgramForm(data, timestamp); } sheet.appendRow(rowData); Logger.log(`[doPost] Zapisano formularz: ${data.email} w ${sheetName}`); return ContentService .createTextOutput(JSON.stringify({ 'result': 'success', 'message': `Zapisano w: ${sheetName}`, 'timestamp': timestamp.toISOString() })) .setMimeType(ContentService.MimeType.JSON); } catch (error) { Logger.log('[doPost] Błąd: ' + error.toString()); return ContentService .createTextOutput(JSON.stringify({ 'result': 'error', 'message': error.toString() })) .setMimeType(ContentService.MimeType.JSON); } finally { lock.releaseLock(); } }// ==================== SYSTEM KOLEJKOWY ==================== class QueueManager { constructor() { this.properties = PropertiesService.getScriptProperties(); } addToQueue(type, data, delayMillis = 0) { const queueId = Utilities.getUuid(); const sendTime = new Date().getTime() + delayMillis; const queueItem = { id: queueId, type: type, sendTime: sendTime, data: data, createdAt: new Date().getTime(), attempts: 0 }; this.properties.setProperty(`queue_${queueId}`, JSON.stringify(queueItem)); Logger.log(`[Queue] Dodano do kolejki: ${type} dla ${data.email} o ${new Date(sendTime)}`); return queueId; } processQueue() { const now = new Date().getTime(); const allProperties = this.properties.getProperties(); const stats = { processed: 0, skipped: 0, errors: 0, total: 0, quotaExceeded: 0 }; let emailsSentThisBatch = 0; for (const key in allProperties) { if (!key.startsWith('queue_')) continue; stats.total++; // Ogranicz batch processing if (emailsSentThisBatch >= CONFIG.EMAIL_LIMITS.BATCH_SIZE) { Logger.log('[Queue] Osiągnięto limit batch (' + CONFIG.EMAIL_LIMITS.BATCH_SIZE + '), pozostałe zostaną przetworzone później'); break; } try { const queueItem = JSON.parse(allProperties[key]); // Sprawdź czy czas wysłać if (queueItem.sendTime <= now) { // Przetwórz element const result = this.processQueueItem(queueItem); if (result.success) { // Usuń z kolejki this.properties.deleteProperty(key); stats.processed++; emailsSentThisBatch++; Logger.log(`[Queue] Przetworzono: ${queueItem.type} dla ${queueItem.data.email}`); } else if (result.skip) { // Pomiń i usuń this.properties.deleteProperty(key); stats.skipped++; Logger.log(`[Queue] Pominięto: ${queueItem.type} - ${result.reason}`); } else if (result.retry) { // Nie usuwaj, zostaw na później if (result.newSendTime) { queueItem.sendTime = result.newSendTime; this.properties.setProperty(key, JSON.stringify(queueItem)); } stats.quotaExceeded++; Logger.log(`[Queue] Odłożono na później: ${queueItem.type}`); } else { // Błąd - spróbuj ponownie później queueItem.attempts++; if (queueItem.attempts > 3) { this.properties.deleteProperty(key); stats.errors++; Logger.log(`[Queue] Błąd (usunięto po 3 próbach): ${queueItem.type}`); } else { queueItem.sendTime = now + 60 * 60 * 1000; // Spróbuj za godzinę this.properties.setProperty(key, JSON.stringify(queueItem)); } } } } catch (error) { Logger.log(`[Queue] Błąd przetwarzania ${key}: ${error.toString()}`); stats.errors++; // Usuń uszkodzony element this.properties.deleteProperty(key); } } if (stats.processed > 0 || stats.errors > 0 || stats.quotaExceeded > 0) { Logger.log(`[Queue] Statystyki: Przetworzono=${stats.processed}, Pominięto=${stats.skipped}, Błędy=${stats.errors}, Przekroczono limit=${stats.quotaExceeded}, Pozostało=${stats.total - stats.processed - stats.skipped - stats.errors}`); } return stats; } processQueueItem(queueItem) { const { type, data } = queueItem; try { // Sprawdź limit PRZED wysłaniem if (!checkEmailQuota()) { Logger.log('[Queue] Przekroczono limit emaili - odkładam na jutro o 2:00'); // Przesuń na jutro o 2 w nocy const tomorrow2am = new Date(); tomorrow2am.setDate(tomorrow2am.getDate() + 1); tomorrow2am.setHours(2, 0, 0, 0); return { retry: true, newSendTime: tomorrow2am.getTime() }; } // Sprawdź czy klient nie kupił (dla emaili konsultacyjnych) if (type.includes('consultation') && this.checkPurchaseStatus(data.email)) { return { skip: true, reason: 'Klient kupił' }; } // Sprawdź czy email nie był już wysłany if (this.wasEmailAlreadySent(type, data.email)) { return { skip: true, reason: 'Email już wysłany' }; } // Przetwórz według typu switch(type) { // Emaile ebook case 'ebook_email_1': wyslijEmail1(data.imie, data.nazwisko, data.email); incrementEmailCounter(); this.updateEmailStatus(data.email, CONFIG.COLUMNS.EMAIL_1_STATUS, 'Wysłano'); break; case 'ebook_email_2': wyslijEmail2Function(data.imie, data.nazwisko, data.email); incrementEmailCounter(); this.updateEmailStatus(data.email, CONFIG.COLUMNS.EMAIL_2_STATUS, 'Wysłano'); break; case 'ebook_email_3': wyslijEmail3Function(data.imie, data.nazwisko, data.email); incrementEmailCounter(); this.updateEmailStatus(data.email, CONFIG.COLUMNS.EMAIL_3_STATUS, 'Wysłano'); break; case 'ebook_email_4': wyslijEmail4Function(data.imie, data.nazwisko, data.email); incrementEmailCounter(); this.updateEmailStatus(data.email, CONFIG.COLUMNS.EMAIL_4_STATUS, 'Wysłano'); break; // Email potwierdzający konsultację case 'consultation_confirmation_email': wyslijEmailPotwierdzajacyKonsultacje(data.imie, data.nazwisko, data.email); incrementEmailCounter(); break; // Emaile konsultacyjne case 'consultation_confirmation': case 'consultation_24h_before': case 'consultation_2h_before': case 'consultation_15min_before': case 'consultation_10min_after': case 'consultation_24h_after': case 'consultation_3days_after': case 'consultation_7days_after': this.sendConsultationEmail(type, data); incrementEmailCounter(); break; default: Logger.log(`[Queue] Nieznany typ: ${type}`); return { success: false }; } return { success: true }; } catch (error) { // Jeśli błąd to limit Google - odłóż na później if (error.toString().includes('zbyt wiele razy')) { Logger.log('[Queue] Limit Google - odkładam na jutro o 2:00'); const tomorrow = new Date(); tomorrow.setDate(tomorrow.getDate() + 1); tomorrow.setHours(2, 0, 0, 0); return { retry: true, newSendTime: tomorrow.getTime() }; } Logger.log(`[Queue] Błąd przetwarzania ${type}: ${error.toString()}`); return { success: false, error: error.toString() }; } } wasEmailAlreadySent(type, email) { const spreadsheet = SpreadsheetApp.openById(CONFIG.SPREADSHEET_ID); const sheet = spreadsheet.getSheetByName(CONFIG.EBOOK_SHEET_NAME); const data = sheet.getDataRange().getValues(); // Mapowanie typów na kolumny statusu const statusColumns = { 'ebook_email_1': CONFIG.COLUMNS.EMAIL_1_STATUS, 'ebook_email_2': CONFIG.COLUMNS.EMAIL_2_STATUS, 'ebook_email_3': CONFIG.COLUMNS.EMAIL_3_STATUS, 'ebook_email_4': CONFIG.COLUMNS.EMAIL_4_STATUS }; const column = statusColumns[type]; if (!column) return false; for (let i = 1; i < data.length; i++) { if (data[i][3] === email) { const status = data[i][column - 1]; return status && status.toString().includes('Wysłano'); } } return false; } sendConsultationEmail(type, data) { const template = new ConsultationEmailTemplates(); let emailContent; let columnToUpdate; // Mapowanie typów na metody i kolumny const mapping = { 'consultation_confirmation': { method: 'getConfirmationEmail', column: CONFIG.COLUMNS.KONSULTACJA_POTWIERDZENIE }, 'consultation_24h_before': { method: 'get24hBeforeEmail', column: CONFIG.COLUMNS.KONSULTACJA_24H }, 'consultation_2h_before': { method: 'get2hBeforeEmail', column: CONFIG.COLUMNS.KONSULTACJA_2H }, 'consultation_15min_before': { method: 'get15minBeforeEmail', column: CONFIG.COLUMNS.KONSULTACJA_15MIN }, 'consultation_10min_after': { method: 'get10minAfterEmail', column: CONFIG.COLUMNS.KONSULTACJA_10MIN_PO }, 'consultation_24h_after': { method: 'get24hAfterEmail', column: CONFIG.COLUMNS.KONSULTACJA_24H_PO }, 'consultation_3days_after': { method: 'get3daysAfterEmail', column: CONFIG.COLUMNS.KONSULTACJA_3DNI_PO }, 'consultation_7days_after': { method: 'get7daysAfterEmail', column: CONFIG.COLUMNS.ANKIETA_STATUS } }; const config = mapping[type]; if (!config) { throw new Error(`Nieznany typ emaila konsultacyjnego: ${type}`); } emailContent = template[config.method](data); GmailApp.sendEmail(data.email, emailContent.subject, emailContent.text, { htmlBody: emailContent.html, name: "Kamil Owsianik - Klinika Formy", replyTo: CONFIG.EMAIL_SENDER }); // Aktualizuj status w arkuszu jeśli mamy rowNumber if (data.rowNumber) { this.updateConsultationStatus(data.rowNumber, config.column, `Wysłano: ${new Date()}`); } Logger.log(`[Queue] Wysłano ${type} do ${data.email}`); } checkPurchaseStatus(email) { const spreadsheet = SpreadsheetApp.openById(CONFIG.SPREADSHEET_ID); const sheet = spreadsheet.getSheetByName(CONFIG.PROGRAM_SHEET_NAME); const data = sheet.getDataRange().getValues(); for (let i = 1; i < data.length; i++) { if (data[i][3] === email) { return data[i][CONFIG.COLUMNS.PURCHASE_STATUS - 1] === 'KUPIŁ'; } } return false; } updateEmailStatus(email, column, status) { const spreadsheet = SpreadsheetApp.openById(CONFIG.SPREADSHEET_ID); const sheet = spreadsheet.getSheetByName(CONFIG.EBOOK_SHEET_NAME); const data = sheet.getDataRange().getValues(); for (let i = 1; i < data.length; i++) { if (data[i][3] === email) { sheet.getRange(i + 1, column).setValue(status); return; } } } updateConsultationStatus(rowNumber, column, status) { const spreadsheet = SpreadsheetApp.openById(CONFIG.SPREADSHEET_ID); const sheet = spreadsheet.getSheetByName(CONFIG.PROGRAM_SHEET_NAME); sheet.getRange(rowNumber, column).setValue(status); } cleanup() { const now = new Date().getTime(); const maxAge = CONFIG.MAX_QUEUE_AGE_DAYS * 24 * 60 * 60 * 1000; const allProperties = this.properties.getProperties(); let cleaned = 0; for (const key in allProperties) { if (!key.startsWith('queue_')) continue; try { const queueItem = JSON.parse(allProperties[key]); // Usuń stare elementy if (queueItem.createdAt < (now - maxAge)) { this.properties.deleteProperty(key); cleaned++; } } catch (error) { // Usuń uszkodzone elementy this.properties.deleteProperty(key); cleaned++; } } // Wyczyść stare liczniki emaili const today = new Date().toDateString(); for (const key in allProperties) { if (key.startsWith('email_count_') && !key.includes(today)) { this.properties.deleteProperty(key); cleaned++; } } if (cleaned > 0) { Logger.log(`[Queue] Wyczyszczono ${cleaned} starych elementów`); } return cleaned; } getStatus() { const allProperties = this.properties.getProperties(); const now = new Date().getTime(); const status = { total: 0, pending: 0, overdue: 0, byType: {} }; for (const key in allProperties) { if (!key.startsWith('queue_')) continue; try { const queueItem = JSON.parse(allProperties[key]); status.total++; if (queueItem.sendTime > now) { status.pending++; } else { status.overdue++; } status.byType[queueItem.type] = (status.byType[queueItem.type] || 0) + 1; } catch (error) { // Ignoruj uszkodzone } } return status; } }// ==================== MODUŁ INTEGRACJI KALENDARZA ==================== class CalendarIntegration { constructor() { this.calendar = CalendarApp.getDefaultCalendar(); this.spreadsheet = SpreadsheetApp.openById(CONFIG.SPREADSHEET_ID); this.sheet = this.spreadsheet.getSheetByName(CONFIG.PROGRAM_SHEET_NAME); this.queue = new QueueManager(); } scanForNewConsultations() { const now = new Date(); const endDate = new Date(now.getTime() + 7 * 24 * 60 * 60 * 1000); Logger.log(`[Calendar] Skanowanie wydarzeń od ${now} do ${endDate}`); const events = this.calendar.getEvents(now, endDate); const stats = { new: 0, updated: 0, skipped: 0 }; events.forEach(event => { if (this.isConsultationEvent(event)) { const result = this.processConsultationEvent(event); stats[result]++; } }); Logger.log(`[Calendar] Wyniki skanowania: Nowe=${stats.new}, Zaktualizowane=${stats.updated}, Pominięte=${stats.skipped}`); return stats; } isConsultationEvent(event) { const title = event.getTitle().toLowerCase(); const keywords = ['konsultacja', 'spotkanie', 'meet', 'zmiana', 'rozmowa', 'call']; return keywords.some(keyword => title.includes(keyword)); } processConsultationEvent(event) { const attendees = event.getGuestList(); for (let attendee of attendees) { const email = attendee.getEmail(); if (email === CONFIG.EMAIL_SENDER) continue; const clientRow = this.findClientByEmail(email); if (!clientRow) { Logger.log(`[Calendar] Klient nieznaleziony w arkuszu: ${email}`); return 'skipped'; } const purchaseStatus = this.sheet.getRange(clientRow, CONFIG.COLUMNS.PURCHASE_STATUS).getValue(); if (purchaseStatus === 'KUPIŁ') { Logger.log(`[Calendar] Klient już kupił: ${email}`); this.sendWelcomeEmail(email, clientRow); return 'skipped'; } const existingEventId = this.sheet.getRange(clientRow, CONFIG.COLUMNS.CALENDAR_EVENT_ID).getValue(); if (existingEventId === event.getId()) { return 'skipped'; } this.sheet.getRange(clientRow, CONFIG.COLUMNS.CALENDAR_EVENT_ID).setValue(event.getId()); this.scheduleConsultationEmails(email, event, clientRow); return existingEventId ? 'updated' : 'new'; } return 'skipped'; } findClientByEmail(email) { const data = this.sheet.getDataRange().getValues(); for (let i = 1; i < data.length; i++) { if (data[i][3] === email) { return i + 1; } } return null; } scheduleConsultationEmails(email, event, rowNumber) { const eventTime = event.getStartTime(); const clientData = this.sheet.getRange(rowNumber, 1, 1, 16).getValues()[0]; const emailData = { email: email, imie: clientData[1], nazwisko: clientData[2], eventTime: eventTime.getTime(), eventId: event.getId(), meetLink: this.extractMeetLink(event), rowNumber: rowNumber }; // Wyślij natychmiast potwierdzenie if (checkEmailQuota()) { this.sendConfirmationEmail(emailData); incrementEmailCounter(); this.sheet.getRange(rowNumber, CONFIG.COLUMNS.KONSULTACJA_POTWIERDZENIE).setValue('Wysłano: ' + new Date()); } else { // Dodaj do kolejki na później this.queue.addToQueue('consultation_confirmation', emailData, 2 * 60 * 60 * 1000); Logger.log(`[Calendar] Potwierdzenie dla ${email} dodane do kolejki (limit)`); } // Dodaj pozostałe emaile do kolejki const eventTimeMs = eventTime.getTime(); const now = new Date().getTime(); // Lista emaili do zaplanowania const emailSchedule = [ { type: 'consultation_24h_before', delay: eventTimeMs - now - (24 * 60 * 60 * 1000) }, { type: 'consultation_2h_before', delay: eventTimeMs - now - (2 * 60 * 60 * 1000) }, { type: 'consultation_15min_before', delay: eventTimeMs - now - (15 * 60 * 1000) }, { type: 'consultation_10min_after', delay: eventTimeMs - now + CONFIG.DELAYS.KONSULTACJA_10MIN }, { type: 'consultation_24h_after', delay: eventTimeMs - now + CONFIG.DELAYS.KONSULTACJA_24H }, { type: 'consultation_3days_after', delay: eventTimeMs - now + CONFIG.DELAYS.KONSULTACJA_3DNI }, { type: 'consultation_7days_after', delay: eventTimeMs - now + CONFIG.DELAYS.KONSULTACJA_7DNI } ]; // Dodaj do kolejki tylko te, które są w przyszłości emailSchedule.forEach(schedule => { if (schedule.delay > 0) { this.queue.addToQueue(schedule.type, emailData, schedule.delay); } }); Logger.log(`[Calendar] Zaplanowano ${emailSchedule.filter(s => s.delay > 0).length} emaili dla ${email}`); } extractMeetLink(event) { try { const description = event.getDescription() || ''; if (!description) return ''; const meetRegex = /https:\/\/meet\.google\.com\/[a-z-]+/i; const match = description.match(meetRegex); return match ? match[0] : ''; } catch (error) { Logger.log('[Calendar] Błąd wyciągania linku: ' + error.toString()); return ''; } } sendConfirmationEmail(emailData) { const template = new ConsultationEmailTemplates(); const { subject, html, text } = template.getConfirmationEmail(emailData); GmailApp.sendEmail(emailData.email, subject, text, { htmlBody: html, name: "Kamil Owsianik - Klinika Formy", replyTo: CONFIG.EMAIL_SENDER }); } sendWelcomeEmail(email, rowNumber) { if (!checkEmailQuota()) { Logger.log('[Calendar] Limit emaili - pomijam welcome email'); return; } const clientData = this.sheet.getRange(rowNumber, 1, 1, 16).getValues()[0]; const template = new ConsultationEmailTemplates(); const { subject, html, text } = template.getWelcomeEmail({ email: email, imie: clientData[1], nazwisko: clientData[2] }); GmailApp.sendEmail(email, subject, text, { htmlBody: html, name: "Kamil Owsianik - Klinika Formy", replyTo: CONFIG.EMAIL_SENDER }); incrementEmailCounter(); } }// ==================== GŁÓWNY PROCESSOR ==================== function mainProcessor() { const startTime = new Date(); Logger.log(`[Main] ====== START PRZETWARZANIA ${startTime} ======`); try { // Sprawdź status limitów const quotaStatus = checkEmailLimits(); Logger.log(`[Main] Limit emaili: ${quotaStatus.daily.used}/${quotaStatus.daily.limit} (pozostało: ${quotaStatus.daily.remaining})`); // 1. Skanuj kalendarz NAJPIERW (jeśli mamy zapas limitów) let calendarStats = { new: 0, updated: 0, skipped: 0 }; if (quotaStatus.daily.remaining > 10) { const calendar = new CalendarIntegration(); calendarStats = calendar.scanForNewConsultations(); } else { Logger.log('[Main] Pomijam skanowanie kalendarza - mało limitów'); } // 2. Przetwórz kolejkę RAZ (włącznie z nowymi elementami z kalendarza) const queue = new QueueManager(); const queueStats = queue.processQueue(); const endTime = new Date(); const duration = (endTime - startTime) / 1000; Logger.log(`[Main] ====== KONIEC PRZETWARZANIA ======`); Logger.log(`[Main] Czas wykonania: ${duration}s`); Logger.log(`[Main] Kolejka: Przetworzono=${queueStats.processed}, Błędy=${queueStats.errors}`); Logger.log(`[Main] Kalendarz: Nowe=${calendarStats.new}, Zaktualizowane=${calendarStats.updated}`); // Sprawdź końcowy status limitów const finalQuotaStatus = checkEmailLimits(); Logger.log(`[Main] Końcowy limit: ${finalQuotaStatus.daily.used}/${finalQuotaStatus.daily.limit}`); return { duration: duration, queue: queueStats, calendar: calendarStats, quota: finalQuotaStatus }; } catch (error) { Logger.log(`[Main] BŁĄD KRYTYCZNY: ${error.toString()}`); throw error; } }// ==================== NOCNY PROCESSOR ==================== function nightProcessor() { Logger.log('[Night] ====== NOCNE PRZETWARZANIE ======'); const startTime = new Date(); try { const queue = new QueueManager(); let totalProcessed = 0; const maxEmails = 30; // Bezpieczny limit nocny // Przetwarzaj w małych porcjach while (totalProcessed < maxEmails && checkEmailQuota()) { const result = queue.processQueue(); totalProcessed += result.processed; if (result.processed === 0) { Logger.log('[Night] Brak więcej emaili do przetworzenia'); break; } // Krótka przerwa między partiami Utilities.sleep(2000); } const duration = (new Date() - startTime) / 1000; Logger.log(`[Night] Przetworzono ${totalProcessed} emaili w ${duration}s`); return { processed: totalProcessed, duration: duration }; } catch (error) { Logger.log(`[Night] Błąd: ${error.toString()}`); throw error; } }// ==================== FUNKCJE GETRESPONSE ==================== function addContactToGetResponse(imie, email) { try { const url = 'https://api.getresponse.com/v3/contacts'; if (!email || !email.includes('@')) { return "Błąd: Nieprawidłowy format adresu email"; } const payload = { 'email': email, 'name': imie, 'campaign': { 'campaignId': CONFIG.GETRESPONSE_CAMPAIGN_ID } }; Logger.log('[GetResponse] Wysyłanie: ' + email); const options = { 'method': 'post', 'contentType': 'application/json', 'headers': { 'X-Auth-Token': 'api-key ' + CONFIG.GETRESPONSE_API_KEY }, 'payload': JSON.stringify(payload), 'muteHttpExceptions': true }; const response = UrlFetchApp.fetch(url, options); const responseCode = response.getResponseCode(); if (responseCode >= 200 && responseCode < 300) { return "Dodano do GetResponse"; } else if (responseCode === 409) { return "Już istnieje w GetResponse"; } else { return "Błąd GetResponse: " + responseCode; } } catch (error) { Logger.log('[GetResponse] Błąd: ' + error.toString()); return "Błąd: " + error.toString(); } }// ==================== FUNKCJA STOPKI ==================== function createEmailFooter() { return `

Do zobaczenia Założyciel Kliniki Formy Tel: +48 733 705 478 @: kontakt@klinika-formy.pl WWW: klinika-formy.pl

`; }// ==================== FUNKCJE EMAILI EBOOK ====================function wyslijEmail1(imie, nazwisko, email) { // Sprawdź limit if (!checkEmailQuota()) { Logger.log('[Email] Przekroczono limit - email 1 zostanie wysłany później'); const queue = new QueueManager(); const tomorrow = new Date(); tomorrow.setDate(tomorrow.getDate() + 1); tomorrow.setHours(2, 0, 0, 0); queue.addToQueue('ebook_email_1', { imie, nazwisko, email }, tomorrow.getTime() - new Date().getTime()); return "Zakolejkowano na jutro (limit)"; } try { const pelneImie = imie + ' ' + nazwisko; const temat = 'MATERIAŁ WIDEO + 3 BONUSY - Twoja droga do wymarzonej sylwetki zaczyna się TUTAJ!'; const htmlBody = ` `; const plainTextBody = `Witaj ${pelneImie}! GRATULACJE! Oto link do wideo i Twoich bonusów. Obejrzyj koniecznie: ${CONFIG.URLS.LANDING_PAGE_2}`; GmailApp.sendEmail(email, temat, plainTextBody, { htmlBody: htmlBody, name: "Kamil Owsianik - Klinika Formy", replyTo: CONFIG.EMAIL_SENDER }); incrementEmailCounter(); Logger.log('[Email] Wysłano email 1 do: ' + email); return "Wysłano pomyślnie"; } catch (error) { // Jeśli błąd to limit Google if (error.toString().includes('zbyt wiele razy')) { Logger.log('[Email] Limit Google - odkładam email 1 na później'); const queue = new QueueManager(); const tomorrow = new Date(); tomorrow.setDate(tomorrow.getDate() + 1); tomorrow.setHours(2, 0, 0, 0); queue.addToQueue('ebook_email_1', { imie, nazwisko, email }, tomorrow.getTime() - new Date().getTime()); return "Zakolejkowano (limit Google)"; } throw new Error('Błąd wysyłania emaila 1: ' + error.toString()); } }function wyslijEmail2Function(imie, nazwisko, email) { try { const temat = imie + ', udało Ci się obejrzeć wideo? (ważna informacja o konsultacji)'; const htmlBody = ` `; const plainTextBody = `Cześć ${imie}! Czy udało Ci się obejrzeć wideo? Mam dla Ciebie bezpłatną konsultację (wartość 250 zł). Zobacz: ${CONFIG.URLS.LANDING_PAGE_2}`; GmailApp.sendEmail(email, temat, plainTextBody, { htmlBody: htmlBody, name: "Kamil Owsianik - Klinika Formy", replyTo: CONFIG.EMAIL_SENDER }); Logger.log('[Email] Wysłano email 2 do: ' + email); return "Wysłano pomyślnie"; } catch (error) { Logger.log('[Email] Błąd wysyłania emaila 2: ' + error.toString()); return "Błąd: " + error.toString(); } }function wyslijEmail3Function(imie, nazwisko, email) { try { const temat = imie + ', zobacz co osiągnęli inni! (+ Twoja konsultacja czeka)'; const htmlBody = ` `; const plainTextBody = `Witaj ${imie}! Zobacz, co osiągnęli inni - 347+ osób zmieniło swoje życie. Twoja darmowa konsultacja (wartość 250 zł) czeka: ${CONFIG.URLS.LANDING_PAGE_2}`; GmailApp.sendEmail(email, temat, plainTextBody, { htmlBody: htmlBody, name: "Kamil Owsianik - Klinika Formy", replyTo: CONFIG.EMAIL_SENDER }); Logger.log('[Email] Wysłano email 3 do: ' + email); return "Wysłano pomyślnie"; } catch (error) { Logger.log('[Email] Błąd wysyłania emaila 3: ' + error.toString()); return "Błąd: " + error.toString(); } }function wyslijEmail4Function(imie, nazwisko, email) { try { const temat = imie + ', Twoje BONUSY są gotowe! (e-book, dieta, grupa FB + OSTATNIA SZANSA na konsultację)'; const htmlBody = ` `; const plainTextBody = `Cześć ${imie}! Twoje bonusy są gotowe! E-book, dieta, grupa FB + OSTATNIA SZANSA na darmową konsultację (wartość 250 zł). Pobierz tutaj: ${CONFIG.URLS.DOWNLOAD_PAGE} i zarezerwuj konsultację: ${CONFIG.URLS.LANDING_PAGE_2}`; GmailApp.sendEmail(email, temat, plainTextBody, { htmlBody: htmlBody, name: "Kamil Owsianik - Klinika Formy", replyTo: CONFIG.EMAIL_SENDER }); Logger.log('[Email] Wysłano email 4 do: ' + email); return "Wysłano pomyślnie"; } catch (error) { Logger.log('[Email] Błąd wysyłania emaila 4: ' + error.toString()); return "Błąd: " + error.toString(); } }// ==================== BRAKUJĄCA FUNKCJA - EMAIL POTWIERDZAJĄCY KONSULTACJĘ ==================== function wyslijEmailPotwierdzajacyKonsultacje(imie, nazwisko, email) { // Sprawdź limit if (!checkEmailQuota()) { Logger.log('[Email] Przekroczono limit - potwierdzenie konsultacji zostanie wysłane później'); const queue = new QueueManager(); const tomorrow = new Date(); tomorrow.setDate(tomorrow.getDate() + 1); tomorrow.setHours(2, 0, 0, 0); queue.addToQueue('consultation_confirmation_email', { imie, nazwisko, email }, tomorrow.getTime() - new Date().getTime()); return "Zakolejkowano na jutro (limit)"; } try { const pelneImie = imie + ' ' + nazwisko; const temat = 'Potwierdzenie zgłoszenia + INSTRUKCJE przygotowania do konsultacji'; const htmlBody = ` `; const plainTextBody = `Witaj ${pelneImie}, Twoje zgłoszenie zostało przyjęte! POTWIERDŹ ZGŁOSZENIE: ${CONFIG.URLS.CONFIRMATION_PAGE} Skontaktujemy się w ciągu 24-48h z numeru +48 733 705 478. Pobierz bonusy: ${CONFIG.URLS.DOWNLOAD_PAGE}`; GmailApp.sendEmail(email, temat, plainTextBody, { htmlBody: htmlBody, name: "Kamil Owsianik - Klinika Formy", replyTo: CONFIG.EMAIL_SENDER }); incrementEmailCounter(); Logger.log('[Email] Wysłano potwierdzenie konsultacji do: ' + email); return "Wysłano pomyślnie"; } catch (error) { // Jeśli błąd to limit Google if (error.toString().includes('zbyt wiele razy')) { Logger.log('[Email] Limit Google - odkładam potwierdzenie na później'); const queue = new QueueManager(); const tomorrow = new Date(); tomorrow.setDate(tomorrow.getDate() + 1); tomorrow.setHours(2, 0, 0, 0); queue.addToQueue('consultation_confirmation_email', { imie, nazwisko, email }, tomorrow.getTime() - new Date().getTime()); return "Zakolejkowano (limit Google)"; } throw new Error('Błąd wysyłania emaila konsultacji: ' + error.toString()); } } // ==================== SZABLONY EMAILI KONSULTACYJNYCH ==================== class ConsultationEmailTemplates { getConfirmationEmail(data) { const meetingDate = new Date(data.eventTime); const formattedDate = Utilities.formatDate(meetingDate, 'Europe/Warsaw', 'dd.MM.yyyy'); const formattedTime = Utilities.formatDate(meetingDate, 'Europe/Warsaw', 'HH:mm'); const subject = 'Jutro o ' + formattedTime + ' - Twoja konsultacja'; // Tworzenie linku do kalendarza Google const eventTitle = encodeURIComponent('Konsultacja - Klinika Formy'); const eventDetails = encodeURIComponent('Konsultacja online z Kamilem Owsianik\n\nLink do spotkania: ' + data.meetLink); const startTime = meetingDate.toISOString().replace(/-|:|\.\d\d\d/g, ''); const endTime = new Date(meetingDate.getTime() + 60 * 60 * 1000).toISOString().replace(/-|:|\.\d\d\d/g, ''); const calendarLink = `https://calendar.google.com/calendar/render?action=TEMPLATE&text=${eventTitle}&details=${eventDetails}&dates=${startTime}/${endTime}`; const html = ` `; const text = 'Twoja konsultacja jest potwierdzona!'; return { subject, html, text }; } get24hBeforeEmail(data) { const meetingDate = new Date(data.eventTime); const formattedTime = Utilities.formatDate(meetingDate, 'Europe/Warsaw', 'HH:mm'); const subject = 'Jutro o ' + formattedTime + ' - Twoja konsultacja (przygotuj się!)'; const html = ` `; const text = 'Jutro konsultacja!'; return { subject, html, text }; } get2hBeforeEmail(data) { const meetingDate = new Date(data.eventTime); const formattedTime = Utilities.formatDate(meetingDate, 'Europe/Warsaw', 'HH:mm'); const subject = 'Za 2 godziny start! Konsultacja o ' + formattedTime; const html = ` `; const text = 'Za 2 godziny konsultacja!'; return { subject, html, text }; } get15minBeforeEmail(data) { const subject = 'START za 15 minut!'; const html = ` `; const text = 'START za 15 minut!'; return { subject, html, text }; } get10minAfterEmail(data) { const subject = 'Twój plan + prezentacja platformy'; const html = ` `; const text = 'Dziękuję za spotkanie!'; return { subject, html, text }; } get24hAfterEmail(data) { const subject = 'Twój plan + oferta specjalna (48h)'; const html = ` `; const text = 'Twój plan gotowy!'; return { subject, html, text }; } get3daysAfterEmail(data) { const subject = 'Ostatnia szansa na ofertę'; const html = ` `; const text = 'Ostatnia szansa!'; return { subject, html, text }; } get7daysAfterEmail(data) { const subject = 'Czy mogę zapytać?'; const html = ` `; const text = 'Czy mogę zapytać?'; return { subject, html, text }; } getWelcomeEmail(data) { const subject = 'Witaj w programie!'; const html = ` `; const text = 'Witaj w programie!'; return { subject, html, text }; } }// ==================== FUNKCJE POMOCNICZE ==================== function zaplanujKolejneEmaile(imie, nazwisko, email, timestamp) { const queue = new QueueManager(); // Dodaj emaile 2, 3, 4 do kolejki queue.addToQueue('ebook_email_2', { imie, nazwisko, email }, CONFIG.DELAYS.EMAIL_2); queue.addToQueue('ebook_email_3', { imie, nazwisko, email }, CONFIG.DELAYS.EMAIL_3); queue.addToQueue('ebook_email_4', { imie, nazwisko, email }, CONFIG.DELAYS.EMAIL_4); Logger.log(`[Email] Zaplanowano 3 emaile dla: ${email}`); }// ==================== PRZETWARZANIE FORMULARZY ==================== function processEbookForm(data, timestamp) { const rowData = [ timestamp, data.imie || '', data.nazwisko || '', data.email || '', data.tel || '', data.cel || '' ]; let emailStatus = 'Nie wysłano'; if (data.email) { try { emailStatus = wyslijEmail1(data.imie, data.nazwisko, data.email); // Planuj kolejne TYLKO jeśli pierwszy się udał if (!emailStatus.includes('Błąd') && !emailStatus.includes('Zakolejkowano')) { zaplanujKolejneEmaile(data.imie, data.nazwisko, data.email, timestamp); } } catch (error) { Logger.log('[Form] Błąd emaila: ' + error.toString()); emailStatus = 'Błąd: ' + error.toString(); } } while (rowData.length < CONFIG.COLUMNS.EMAIL_1_STATUS - 1) { rowData.push(''); } rowData.push(emailStatus); rowData.push('Zaplanowano'); rowData.push('Zaplanowano'); rowData.push('Zaplanowano'); let getResponseStatus = 'Nie wysłano'; if (data.email) { try { getResponseStatus = addContactToGetResponse(data.imie, data.email); } catch (error) { Logger.log('[Form] GetResponse błąd: ' + error.toString()); getResponseStatus = 'Błąd: ' + error.toString(); } } while (rowData.length < CONFIG.COLUMNS.EBOOK_GETRESPONSE - 1) { rowData.push(''); } rowData[CONFIG.COLUMNS.EBOOK_GETRESPONSE - 1] = getResponseStatus; return rowData; }function processProgramForm(data, timestamp) { const rowData = [ timestamp, data.imie || '', data.nazwisko || '', data.email || '', data.tel || '', data.waga || '', data.wzrost || '', data.wiek || '', data.cel || '', data.czas_proby || '', data.samopoczucie || '', data.pilnosc || '', data.budzet || '', data.godziny_kontaktu || '', data.dlaczego || '', data.choroby || '' ]; // Kolumna 17 - Status konsultacji let emailStatus = 'Nie wysłano'; if (data.email) { try { emailStatus = wyslijEmailPotwierdzajacyKonsultacje(data.imie, data.nazwisko, data.email); } catch (error) { Logger.log('[Form] Błąd emaila: ' + error.toString()); emailStatus = 'Błąd: ' + error.toString(); } } rowData.push(emailStatus); // Kolumna 18 - PURCHASE_STATUS rowData.push(''); // Wypełnij puste kolumny do 21 while (rowData.length < 21) { rowData.push(''); } // Kolumna 22 - GetResponse let getResponseStatus = 'Nie wysłano'; if (data.email) { try { getResponseStatus = addContactToGetResponse(data.imie, data.email); } catch (error) { Logger.log('[Form] GetResponse błąd: ' + error.toString()); getResponseStatus = 'Błąd: ' + error.toString(); } } rowData.push(getResponseStatus); return rowData; }// ==================== FUNKCJE SYSTEMOWE ==================== function setupOptimizedSystem() { Logger.log('[Setup] Rozpoczynam konfigurację systemu v3.3...'); // 1. Wyczyść wszystkie triggery const triggers = ScriptApp.getProjectTriggers(); triggers.forEach(trigger => { ScriptApp.deleteTrigger(trigger); Logger.log(`[Setup] Usunięto trigger: ${trigger.getHandlerFunction()}`); }); // 2. Ustaw główny processor (co 2 godziny zamiast co godzinę) ScriptApp.newTrigger('mainProcessor') .timeBased() .everyHours(2) // ZMIANA: co 2 godziny .create(); // 3. Ustaw nocny processor ScriptApp.newTrigger('nightProcessor') .timeBased() .everyDays(1) .atHour(2) // O 2 w nocy .create(); // 4. Ustaw czyszczenie (raz dziennie) ScriptApp.newTrigger('dailyMaintenance') .timeBased() .everyDays(1) .atHour(3) .create(); Logger.log('[Setup] System v3.3 skonfigurowany z kontrolą limitów!'); // 5. Sprawdź status const status = checkSystemStatus(); return { message: 'System zoptymalizowany z kontrolą limitów', version: CONFIG.SYSTEM_VERSION, triggers: 3, status: status }; }function dailyMaintenance() { Logger.log('[Maintenance] Rozpoczynam codzienną konserwację...'); const queue = new QueueManager(); const cleaned = queue.cleanup(); // Wyczyść stare properties const properties = PropertiesService.getScriptProperties().getProperties(); let oldProperties = 0; for (const key in properties) { if (key.startsWith('trigger_') || key.startsWith('consultation_') || key.startsWith('user_')) { PropertiesService.getScriptProperties().deleteProperty(key); oldProperties++; } } // Wyczyść stare liczniki emaili (starsze niż wczoraj) const yesterday = new Date(); yesterday.setDate(yesterday.getDate() - 1); const yesterdayString = yesterday.toDateString(); for (const key in properties) { if (key.startsWith('email_count_') && !key.includes(new Date().toDateString()) && !key.includes(yesterdayString)) { PropertiesService.getScriptProperties().deleteProperty(key); oldProperties++; } } Logger.log(`[Maintenance] Wyczyszczono: ${cleaned} elementów kolejki, ${oldProperties} starych properties`); return { queueCleaned: cleaned, propertiesCleaned: oldProperties }; }function checkSystemStatus() { const queue = new QueueManager(); const queueStatus = queue.getStatus(); const emailQuota = getEmailQuotaStatus(); const status = { version: CONFIG.SYSTEM_VERSION, triggers: ScriptApp.getProjectTriggers().length, maxTriggers: 20, properties: Object.keys(PropertiesService.getScriptProperties().getProperties()).length, queue: queueStatus, emailQuota: emailQuota, sheets: { ebook: SpreadsheetApp.openById(CONFIG.SPREADSHEET_ID) .getSheetByName(CONFIG.EBOOK_SHEET_NAME).getLastRow() - 1, program: SpreadsheetApp.openById(CONFIG.SPREADSHEET_ID) .getSheetByName(CONFIG.PROGRAM_SHEET_NAME).getLastRow() - 1 }, nextEvents: getUpcomingConsultations() }; Logger.log('[Status] System v' + status.version); Logger.log('[Status] Triggery: ' + status.triggers + '/' + status.maxTriggers); Logger.log('[Status] Kolejka: ' + queueStatus.total + ' (oczekujące: ' + queueStatus.pending + ', zaległe: ' + queueStatus.overdue + ')'); Logger.log('[Status] Limit emaili: ' + emailQuota.daily.used + '/' + emailQuota.daily.limit + ' (pozostało: ' + emailQuota.daily.remaining + ')'); Logger.log('[Status] Rekordy: Ebook=' + status.sheets.ebook + ', Program=' + status.sheets.program); return status; }function getUpcomingConsultations() { const cal = CalendarApp.getDefaultCalendar(); const now = new Date(); const tomorrow = new Date(now.getTime() + 24 * 60 * 60 * 1000); const events = cal.getEvents(now, tomorrow); const consultations = []; events.forEach(event => { if (event.getTitle().toLowerCase().includes('konsultacja')) { consultations.push({ title: event.getTitle(), time: event.getStartTime(), guests: event.getGuestList().map(g => g.getEmail()).filter(e => e !== CONFIG.EMAIL_SENDER) }); } }); return consultations; }// ==================== FUNKCJE ADMINISTRACYJNE ==================== function manualCalendarScan() { Logger.log('[Manual] Ręczne skanowanie kalendarza...'); const calendar = new CalendarIntegration(); const results = calendar.scanForNewConsultations(); // Przetwórz kolejkę od razu const queue = new QueueManager(); const queueResults = queue.processQueue(); return { calendar: results, queue: queueResults }; }function forceProcessQueue() { Logger.log('[Manual] Wymuszenie przetworzenia kolejki...'); const queue = new QueueManager(); return queue.processQueue(); }function clearAllData() { const ui = SpreadsheetApp.getUi(); const response = ui.alert( 'UWAGA!', 'Czy na pewno chcesz wyczyścić WSZYSTKIE dane systemowe?', ui.ButtonSet.YES_NO ); if (response === ui.Button.YES) { // Wyczyść triggery const triggers = ScriptApp.getProjectTriggers(); triggers.forEach(t => ScriptApp.deleteTrigger(t)); // Wyczyść properties const properties = PropertiesService.getScriptProperties(); properties.deleteAllProperties(); Logger.log('[Clear] Wszystkie dane systemowe wyczyszczone'); return 'Wyczyszczono wszystkie dane'; } return 'Anulowano'; }function testEmailDelivery(email) { if (!email) { email = 'test@example.com'; } // Sprawdź limit przed testem if (!checkEmailQuota()) { Logger.log('[Test] Limit emaili wyczerpany - test niemożliwy'); return 'Limit emaili wyczerpany - spróbuj jutro'; } try { GmailApp.sendEmail( email, 'TEST - Klinika Formy CRM', 'To jest email testowy.', { htmlBody: '

Test Email

System działa poprawnie.

', name: "Kamil Owsianik - TEST", replyTo: CONFIG.EMAIL_SENDER } ); incrementEmailCounter(); Logger.log(`[Test] Email testowy wysłany do: ${email}`); return 'Email testowy wysłany'; } catch (error) { Logger.log(`[Test] Błąd wysyłania: ${error.toString()}`); return 'Błąd: ' + error.toString(); } }function addTestClient(imie = 'Test', nazwisko = 'Testowy', email = 'test@example.com', telefon = '+48123456789') { const spreadsheet = SpreadsheetApp.openById(CONFIG.SPREADSHEET_ID); const sheet = spreadsheet.getSheetByName(CONFIG.PROGRAM_SHEET_NAME); const rowData = [ new Date(), imie, nazwisko, email, telefon, '80', // waga '180', // wzrost '35', // wiek 'Test systemu', '3 miesiące', 'Dobrze', 'Pilne', '1500', '10-18', 'Test', 'Brak' ]; sheet.appendRow(rowData); Logger.log(`[Test] Dodano klienta testowego: ${email}`); return 'Klient testowy dodany'; }// ==================== MENU INTERFACE ==================== function onOpen() { const ui = SpreadsheetApp.getUi(); ui.createMenu('Klinika Formy CRM v3.3') .addItem('📊 Status systemu', 'showSystemStatus') .addItem('⚡ Przetwórz kolejkę TERAZ', 'forceProcessQueue') .addItem('📈 Sprawdź limity emaili', 'showEmailQuotaStatus') .addSeparator() .addSubMenu(ui.createMenu('📅 Kalendarz') .addItem('Skanuj kalendarz TERAZ', 'manualCalendarScan') .addItem('Pokaż najbliższe konsultacje', 'showUpcomingConsultations')) .addSubMenu(ui.createMenu('📧 Email & GetResponse') .addItem('Test GetResponse', 'testGetResponseAPI') .addItem('Test wysyłki email', 'promptTestEmail') .addItem('Sprawdź limity emaili', 'showEmailQuotaStatus')) .addSubMenu(ui.createMenu('⚙️ Administracja') .addItem('Konfiguruj system v3.3', 'setupOptimizedSystem') .addItem('Ręczna konserwacja', 'dailyMaintenance') .addItem('Dodaj klienta testowego', 'addTestClient') .addItem('Wyczyść WSZYSTKO', 'clearAllData')) .addSeparator() .addItem('📚 Dokumentacja', 'showDocumentation') .addToUi(); }function showEmailQuotaStatus() { const status = getEmailQuotaStatus(); const ui = SpreadsheetApp.getUi(); const message = ` LIMITY EMAILI - STATUS:📊 DZIENNY LIMIT: • Wykorzystano: ${status.daily.used}/${status.daily.limit} • Pozostało: ${status.daily.remaining} • Wykorzystanie: ${status.daily.percentage}%⏰ GODZINOWY LIMIT: • Wykorzystano: ${status.hourly.used}/${status.hourly.limit} • Pozostało: ${status.hourly.remaining}${status.daily.remaining === 0 ? '⚠️ UWAGA: Limit dzienny wyczerpany! Emaile zostaną wysłane jutro.' : ''} ${status.daily.remaining < 10 && status.daily.remaining > 0 ? '⚠️ UWAGA: Zbliżasz się do limitu dziennego!' : ''} `; ui.alert('Status limitów emaili', message, ui.ButtonSet.OK); }function showSystemStatus() { const status = checkSystemStatus(); const html = HtmlService.createHtmlOutput(`

System Status - v${status.version}

Limity emaili

System

Rekordy w arkuszach

Arkusz	Liczba rekordów
Ebook	${status.sheets.ebook}
Program	${status.sheets.program}

Typy w kolejce

${Object.entries(status.queue.byType).map(([type, count]) => `` ).join('')}

Typ	Liczba
${type}	${count}

Najbliższe konsultacje (24h)

${status.nextEvents.length > 0 ? ` ${status.nextEvents.map(e => `` ).join('')}

Tytuł	Czas	Goście
${e.title}	${e.time}	${e.guests.join(', ')}

` : '

Brak konsultacji w najbliższych 24h

' } `) .setTitle('Status Systemu') .setWidth(800) .setHeight(700); SpreadsheetApp.getUi().showModalDialog(html, 'Status Systemu CRM v3.3'); }function showUpcomingConsultations() { const consultations = getUpcomingConsultations(); const html = HtmlService.createHtmlOutput(`

Konsultacje w najbliższych 24h

${consultations.length > 0 ? ` ${consultations.map(c => `` ).join('')}

Tytuł	Czas	Goście
${c.title}	${c.time.toLocaleString('pl-PL')}	${c.guests.join(' ')}

` : '

Brak konsultacji w najbliższych 24 godzinach

' } `) .setTitle('Najbliższe konsultacje') .setWidth(600) .setHeight(400); SpreadsheetApp.getUi().showModalDialog(html, 'Najbliższe konsultacje'); }function promptTestEmail() { const ui = SpreadsheetApp.getUi(); const response = ui.prompt( 'Test email', 'Podaj adres email do testu:', ui.ButtonSet.OK_CANCEL ); if (response.getSelectedButton() === ui.Button.OK) { const result = testEmailDelivery(response.getResponseText()); ui.alert('Wynik', result, ui.ButtonSet.OK); } } function showDocumentation() { const html = HtmlService.createHtmlOutput(`

Klinika Formy CRM v3.3 - Dokumentacja

Główne funkcje:

Jak działa kontrola limitów?

1. Przed wysłaniem: System sprawdza czy nie przekroczono limitu
2. Jeśli limit OK: Email jest wysyłany, licznik zwiększany
3. Jeśli limit przekroczony: Email odkładany na jutro o 2:00
4. Nocne przetwarzanie: O 2:00 system przetwarza zaległe emaile
5. Reset liczników: O północy liczniki są resetowane

Triggery systemowe:

• mainProcessor: Co 2 godziny - główne przetwarzanie
• nightProcessor: O 2:00 - zaległe emaile
• dailyMaintenance: O 3:00 - czyszczenie systemu

Monitoring:

• Menu → "📊 Status systemu" - pełny przegląd
• Menu → "📈 Sprawdź limity emaili" - szybki status limitów
• Logi pokazują wykorzystanie po każdym emailu

Rozwiązywanie problemów:

• Emaile nie wysyłają się: Sprawdź limity, może być przekroczony
• Limit wyczerpany: Poczekaj do jutra lub do 2:00
• Zaległe emaile: Zostaną wysłane automatycznie o 2:00
• Chcesz wymusić: "Przetwórz kolejkę TERAZ" - ale limity nadal obowiązują

Kontakt wsparcia:

Email: owsiany1995@gmail.com

WhatsApp: +48 733 705 478

`) .setTitle('Dokumentacja') .setWidth(700) .setHeight(600); SpreadsheetApp.getUi().showModalDialog(html, 'Dokumentacja CRM v3.3'); }// ==================== FUNKCJE TESTOWE ==================== function testGetResponseAPI() { const url = 'https://api.getresponse.com/v3/campaigns'; const options = { 'method': 'get', 'contentType': 'application/json', 'headers': { 'X-Auth-Token': 'api-key ' + CONFIG.GETRESPONSE_API_KEY }, 'muteHttpExceptions': true }; try { const response = UrlFetchApp.fetch(url, options); Logger.log('[GetResponse Test] Kod: ' + response.getResponseCode()); if (response.getResponseCode() === 200) { const campaigns = JSON.parse(response.getContentText()); Logger.log('[GetResponse Test] Znaleziono kampanii: ' + campaigns.length); // Test dodania kontaktu const testEmail = "test_" + new Date().getTime() + "@example.com"; const testResult = addContactToGetResponse("Test", testEmail); Logger.log('[GetResponse Test] Dodanie testowego kontaktu: ' + testResult); return "GetResponse działa poprawnie"; } else { return "Błąd GetResponse: " + response.getResponseCode(); } } catch (error) { Logger.log('[GetResponse Test] Błąd: ' + error.toString()); return "Błąd testu: " + error.toString(); } }// ==================== INICJALIZACJA ==================== function init() { Logger.log('[Init] Inicjalizacja systemu CRM v3.3...'); // Sprawdź czy arkusze istnieją const spreadsheet = SpreadsheetApp.openById(CONFIG.SPREADSHEET_ID); const ebookSheet = spreadsheet.getSheetByName(CONFIG.EBOOK_SHEET_NAME); const programSheet = spreadsheet.getSheetByName(CONFIG.PROGRAM_SHEET_NAME); if (!ebookSheet || !programSheet) { throw new Error('Brak wymaganych arkuszy! Sprawdź nazwy arkuszy.'); } // Ustaw system const result = setupOptimizedSystem(); Logger.log('[Init] System v3.3 z kontrolą limitów gotowy do pracy!'); Logger.log('[Init] Limity: 90 emaili/dzień, 20 emaili/godzinę, batch 5 emaili'); Logger.log('[Init] Triggery: mainProcessor (co 2h), nightProcessor (2:00), dailyMaintenance (3:00)'); return result; }// ==================== DEBUGOWANIE ==================== function debugQueue() { const queue = new QueueManager(); const status = queue.getStatus(); console.log('=== STATUS KOLEJKI ==='); console.log('Całkowita liczba: ' + status.total); console.log('Oczekujące: ' + status.pending); console.log('Zaległe: ' + status.overdue); console.log('\nPo typach:'); for (const type in status.byType) { console.log(` ${type}: ${status.byType[type]}`); } // Pokaż szczegóły pierwszych 5 elementów const properties = PropertiesService.getScriptProperties().getProperties(); let shown = 0; console.log('\n=== PIERWSZE 5 ELEMENTÓW ==='); for (const key in properties) { if (!key.startsWith('queue_')) continue; if (shown >= 5) break; const item = JSON.parse(properties[key]); const sendTime = new Date(item.sendTime); console.log(`\n${item.type}:`); console.log(` Email: ${item.data.email}`); console.log(` Czas wysyłki: ${sendTime}`); console.log(` Próby: ${item.attempts}`); shown++; } return status; }function resetEmailCounters() { const properties = PropertiesService.getScriptProperties(); const allProperties = properties.getProperties(); let removed = 0; for (const key in allProperties) { if (key.startsWith('email_count_')) { properties.deleteProperty(key); removed++; } } console.log(`Usunięto ${removed} liczników emaili`); return `Zresetowano ${removed} liczników`; }function simulateDayChange() { // Ta funkcja symuluje zmianę dnia dla testów const properties = PropertiesService.getScriptProperties(); // Ustaw wczorajszą datę dla obecnych liczników const today = new Date().toDateString(); const yesterday = new Date(); yesterday.setDate(yesterday.getDate() - 1); const yesterdayString = yesterday.toDateString(); const allProperties = properties.getProperties(); for (const key in allProperties) { if (key.includes(today)) { const newKey = key.replace(today, yesterdayString); properties.setProperty(newKey, allProperties[key]); properties.deleteProperty(key); } } console.log('Symulacja zmiany dnia zakończona - liczniki przeniesione na wczoraj'); return 'Dzień zmieniony'; }// ==================== MONITORING WYDAJNOŚCI ==================== function performanceReport() { const startTime = new Date(); const report = { timestamp: startTime, emailQuota: getEmailQuotaStatus(), queueStatus: new QueueManager().getStatus(), systemHealth: checkSystemHealth(), recommendations: [] }; // Analiza i rekomendacje if (report.emailQuota.daily.percentage > 80) { report.recommendations.push('Zbliżasz się do limitu dziennego emaili - rozważ przesunięcie niektórych na jutro'); } if (report.queueStatus.overdue > 10) { report.recommendations.push('Masz ' + report.queueStatus.overdue + ' zaległych emaili - uruchom forceProcessQueue()'); } if (report.systemHealth.properties > 400) { report.recommendations.push('Dużo properties - uruchom dailyMaintenance() aby wyczyścić stare'); } const duration = (new Date() - startTime) / 1000; report.checkDuration = duration; console.log('=== RAPORT WYDAJNOŚCI ==='); console.log(`Czas sprawdzenia: ${duration}s`); console.log(`\nLimity emaili: ${report.emailQuota.daily.used}/${report.emailQuota.daily.limit}`); console.log(`Kolejka: ${report.queueStatus.total} (zaległe: ${report.queueStatus.overdue})`); console.log(`\nRekomendacje:`); report.recommendations.forEach(r => console.log(' • ' + r)); return report; }function checkSystemHealth() { return { triggers: ScriptApp.getProjectTriggers().length, properties: Object.keys(PropertiesService.getScriptProperties().getProperties()).length, executionsToday: getExecutionCount(), lastRun: PropertiesService.getScriptProperties().getProperty('last_main_run') }; }function getExecutionCount() { // Przybliżona liczba wykonań dzisiaj const properties = PropertiesService.getScriptProperties(); const today = new Date().toDateString(); const count = properties.getProperty('executions_' + today) || 0; return parseInt(count); }// ==================== BACKUP I RESTORE ==================== function backupConfiguration() { const backup = { version: CONFIG.SYSTEM_VERSION, timestamp: new Date().toISOString(), config: CONFIG, properties: PropertiesService.getScriptProperties().getProperties() }; // Zapisz backup w arkuszu const spreadsheet = SpreadsheetApp.openById(CONFIG.SPREADSHEET_ID); let backupSheet = spreadsheet.getSheetByName('BACKUP_CONFIG'); if (!backupSheet) { backupSheet = spreadsheet.insertSheet('BACKUP_CONFIG'); backupSheet.appendRow(['Timestamp', 'Version', 'Backup Data']); } backupSheet.appendRow([ backup.timestamp, backup.version, JSON.stringify(backup) ]); console.log('Backup utworzony: ' + backup.timestamp); return backup; }function restoreConfiguration(backupRow) { if (!backupRow) { console.log('Podaj numer wiersza backup do przywrócenia'); return 'Błąd: brak numeru wiersza'; } const spreadsheet = SpreadsheetApp.openById(CONFIG.SPREADSHEET_ID); const backupSheet = spreadsheet.getSheetByName('BACKUP_CONFIG'); if (!backupSheet) { return 'Błąd: brak arkusza BACKUP_CONFIG'; } const backupData = backupSheet.getRange(backupRow, 3).getValue(); const backup = JSON.parse(backupData); // Przywróć properties const properties = PropertiesService.getScriptProperties(); properties.setProperties(backup.properties); console.log('Przywrócono konfigurację z: ' + backup.timestamp); return 'Przywrócono backup z ' + backup.timestamp; }// ==================== KOŃCOWA WALIDACJA ==================== function validateSystem() { const errors = []; const warnings = []; const info = []; // Sprawdź arkusze try { const spreadsheet = SpreadsheetApp.openById(CONFIG.SPREADSHEET_ID); const ebookSheet = spreadsheet.getSheetByName(CONFIG.EBOOK_SHEET_NAME); const programSheet = spreadsheet.getSheetByName(CONFIG.PROGRAM_SHEET_NAME); if (!ebookSheet) errors.push('Brak arkusza: ' + CONFIG.EBOOK_SHEET_NAME); if (!programSheet) errors.push('Brak arkusza: ' + CONFIG.PROGRAM_SHEET_NAME); info.push('Arkusze: OK'); } catch (e) { errors.push('Nie można otworzyć arkusza: ' + e.toString()); } // Sprawdź triggery const triggers = ScriptApp.getProjectTriggers(); if (triggers.length === 0) { warnings.push('Brak triggerów - uruchom setupOptimizedSystem()'); } else { info.push('Triggery: ' + triggers.length); } // Sprawdź limity const quota = getEmailQuotaStatus(); if (quota.daily.remaining < 10) { warnings.push('Mało limitów emaili: ' + quota.daily.remaining); } else { info.push('Limit emaili: ' + quota.daily.remaining + ' pozostało'); } // Sprawdź kolejkę const queueStatus = new QueueManager().getStatus(); if (queueStatus.overdue > 0) { warnings.push('Zaległe emaile w kolejce: ' + queueStatus.overdue); } console.log('=== WALIDACJA SYSTEMU ==='); if (errors.length > 0) { console.log('\n❌ BŁĘDY:'); errors.forEach(e => console.log(' • ' + e)); } if (warnings.length > 0) { console.log('\n⚠️ OSTRZEŻENIA:'); warnings.forEach(w => console.log(' • ' + w)); } console.log('\n✅ INFORMACJE:'); info.forEach(i => console.log(' • ' + i)); return { valid: errors.length === 0, errors: errors, warnings: warnings, info: info }; }

/** * KLINIKA FORMY CRM SYSTEM v3.2 - POPRAWIONE EMAILE BEZ EMOJI * * CHANGELOG v3.2: * - Usunięte problematyczne emoji * - Dodana stopka ze zdjęciem do wszystkich wiadomości * - Poprawione treści w emailu 1 (2 lata, 4 min wideo) * - Dodana informacja o potwierdzeniu przez WhatsApp * - Poprawiony przycisk kalendarza * - Rozbudowane emaile konsultacyjne */// ==================== KONFIGURACJA GŁÓWNA ==================== const CONFIG = { SPREADSHEET_ID: '1Q52bzhfuYQUFteOcj4RQ4Vi5oU4sIS1OE-xDMjXQINA', EBOOK_SHEET_NAME: 'DARMOWY EBOOK', PROGRAM_SHEET_NAME: 'ZGŁOSZENIE - Z EBOOKA', EMAIL_SENDER: 'owsiany1995@gmail.com', // GetResponse GETRESPONSE_API_KEY: '6vszd9996ta5xrzvzju0jqvfwukauzp2', GETRESPONSE_CAMPAIGN_ID: 'GS3qW', // Kolumny arkusza COLUMNS: { EBOOK_GETRESPONSE: 11, // K PROGRAM_GETRESPONSE: 22, // V EMAIL_1_STATUS: 12, // L EMAIL_2_STATUS: 13, // M EMAIL_3_STATUS: 14, // N EMAIL_4_STATUS: 15, // O PURCHASE_STATUS: 18, // R KONSULTACJA_POTWIERDZENIE: 23, // W KONSULTACJA_24H: 24, // X KONSULTACJA_2H: 25, // Y KONSULTACJA_15MIN: 26, // Z KONSULTACJA_10MIN_PO: 27, // AA KONSULTACJA_24H_PO: 28, // AB KONSULTACJA_3DNI_PO: 29, // AC CALENDAR_EVENT_ID: 30, // AD ANKIETA_STATUS: 31 // AE }, // Opóźnienia emaili DELAYS: { EMAIL_2: 5 * 60 * 60 * 1000, // 5 godzin EMAIL_3: 24 * 60 * 60 * 1000, // 24 godziny EMAIL_4: 48 * 60 * 60 * 1000, // 48 godzin KONSULTACJA_10MIN: 10 * 60 * 1000, // 10 minut KONSULTACJA_24H: 24 * 60 * 60 * 1000, KONSULTACJA_3DNI: 72 * 60 * 60 * 1000, KONSULTACJA_7DNI: 168 * 60 * 60 * 1000 }, // URLs URLS: { LANDING_PAGE_2: 'https://akf.klinika-formy.pl/wyslane/', CONFIRMATION_PAGE: 'https://akf.klinika-formy.pl/zgloszenie-przeslane/', OPINIONS: 'https://klinika-formy.pl/opinie/', FACEBOOK_GROUP: 'https://www.facebook.com/groups/klinikaformy', LOGO: 'https://akf.klinika-formy.pl/wp-content/uploads/2025/05/Bez-tytulu-1080-x-432-px-1.png', KAMIL_PHOTO: 'https://akf.klinika-formy.pl/wp-content/uploads/2025/07/@klinika.formy-1.png', PLATFORM_VIDEO: 'https://www.youtube.com/watch?v=KHkeiYJE6gg', GENERAL_PLAN_DOC: 'https://docs.google.com/document/d/1TS7NAsi-w_tsj4LyR0Szdjy1YyrZ6Aim3C9yCjttGAs/edit?usp=sharing', ANKIETA_FORM: 'https://akf.klinika-formy.pl/badanie/', PAYMENT_1350: 'https://buy.stripe.com/5kA4gz3m381Z0106oo', PAYMENT_3RATY: 'https://tubapay.pl/s/MPVlaYMD', PAYMENT_6RAT: 'https://tubapay.pl/s/vHNGc9CV', DOWNLOAD_PAGE: 'https://klinika-formy.pl/pobierz/' }, // System Settings QUEUE_PROCESSING_INTERVAL: 60, // minuty MAX_QUEUE_AGE_DAYS: 30, SYSTEM_VERSION: '3.2' };// ==================== GŁÓWNY HANDLER POST ==================== function doPost(e) { const lock = LockService.getScriptLock(); try { lock.waitLock(10000); const data = e.parameter; const sheetName = data.formType === 'program' ? CONFIG.PROGRAM_SHEET_NAME : CONFIG.EBOOK_SHEET_NAME; const spreadsheet = SpreadsheetApp.openById(CONFIG.SPREADSHEET_ID); const sheet = spreadsheet.getSheetByName(sheetName); if (!sheet) { throw new Error(`Arkusz nie istnieje: ${sheetName}`); } const timestamp = new Date(); let rowData = []; if (sheetName === CONFIG.EBOOK_SHEET_NAME) { rowData = processEbookForm(data, timestamp); } else { rowData = processProgramForm(data, timestamp); } sheet.appendRow(rowData); Logger.log(`[doPost] Zapisano formularz: ${data.email} w ${sheetName}`); return ContentService .createTextOutput(JSON.stringify({ 'result': 'success', 'message': `Zapisano w: ${sheetName}`, 'timestamp': timestamp.toISOString() })) .setMimeType(ContentService.MimeType.JSON); } catch (error) { Logger.log('[doPost] Błąd: ' + error.toString()); return ContentService .createTextOutput(JSON.stringify({ 'result': 'error', 'message': error.toString() })) .setMimeType(ContentService.MimeType.JSON); } finally { lock.releaseLock(); } }// ==================== SYSTEM KOLEJKOWY ==================== class QueueManager { constructor() { this.properties = PropertiesService.getScriptProperties(); } addToQueue(type, data, delayMillis = 0) { const queueId = Utilities.getUuid(); const sendTime = new Date().getTime() + delayMillis; const queueItem = { id: queueId, type: type, sendTime: sendTime, data: data, createdAt: new Date().getTime(), attempts: 0 }; this.properties.setProperty(`queue_${queueId}`, JSON.stringify(queueItem)); Logger.log(`[Queue] Dodano do kolejki: ${type} dla ${data.email} o ${new Date(sendTime)}`); return queueId; } processQueue() { const now = new Date().getTime(); const allProperties = this.properties.getProperties(); const stats = { processed: 0, skipped: 0, errors: 0, total: 0 }; for (const key in allProperties) { if (!key.startsWith('queue_')) continue; stats.total++; try { const queueItem = JSON.parse(allProperties[key]); // Sprawdź czy czas wysłać if (queueItem.sendTime <= now) { // Przetwórz element const result = this.processQueueItem(queueItem); if (result.success) { // Usuń z kolejki this.properties.deleteProperty(key); stats.processed++; Logger.log(`[Queue] Przetworzono: ${queueItem.type} dla ${queueItem.data.email}`); } else if (result.skip) { // Pomiń i usuń this.properties.deleteProperty(key); stats.skipped++; Logger.log(`[Queue] Pominięto: ${queueItem.type} - ${result.reason}`); } else { // Błąd - spróbuj ponownie później queueItem.attempts++; if (queueItem.attempts > 3) { this.properties.deleteProperty(key); stats.errors++; Logger.log(`[Queue] Błąd (usunięto po 3 próbach): ${queueItem.type}`); } else { queueItem.sendTime = now + 60 * 60 * 1000; // Spróbuj za godzinę this.properties.setProperty(key, JSON.stringify(queueItem)); } } } } catch (error) { Logger.log(`[Queue] Błąd przetwarzania ${key}: ${error.toString()}`); stats.errors++; // Usuń uszkodzony element this.properties.deleteProperty(key); } } if (stats.processed > 0 || stats.errors > 0) { Logger.log(`[Queue] Statystyki: Przetworzono=${stats.processed}, Pominięto=${stats.skipped}, Błędy=${stats.errors}, Pozostało=${stats.total - stats.processed - stats.skipped - stats.errors}`); } return stats; } processQueueItem(queueItem) { const { type, data } = queueItem; try { // Sprawdź czy klient nie kupił (dla emaili konsultacyjnych) if (type.includes('consultation') && this.checkPurchaseStatus(data.email)) { return { skip: true, reason: 'Klient kupił' }; } // Przetwórz według typu switch(type) { // Emaile ebook case 'ebook_email_2': wyslijEmail2Function(data.imie, data.nazwisko, data.email); this.updateEmailStatus(data.email, CONFIG.COLUMNS.EMAIL_2_STATUS, 'Wysłano'); break; case 'ebook_email_3': wyslijEmail3Function(data.imie, data.nazwisko, data.email); this.updateEmailStatus(data.email, CONFIG.COLUMNS.EMAIL_3_STATUS, 'Wysłano'); break; case 'ebook_email_4': wyslijEmail4Function(data.imie, data.nazwisko, data.email); this.updateEmailStatus(data.email, CONFIG.COLUMNS.EMAIL_4_STATUS, 'Wysłano'); break; // Emaile konsultacyjne case 'consultation_24h_before': case 'consultation_2h_before': case 'consultation_15min_before': case 'consultation_10min_after': case 'consultation_24h_after': case 'consultation_3days_after': case 'consultation_7days_after': this.sendConsultationEmail(type, data); break; default: Logger.log(`[Queue] Nieznany typ: ${type}`); return { success: false }; } return { success: true }; } catch (error) { Logger.log(`[Queue] Błąd przetwarzania ${type}: ${error.toString()}`); return { success: false, error: error.toString() }; } } sendConsultationEmail(type, data) { const template = new ConsultationEmailTemplates(); let emailContent; let columnToUpdate; // Mapowanie typów na metody i kolumny const mapping = { 'consultation_24h_before': { method: 'get24hBeforeEmail', column: CONFIG.COLUMNS.KONSULTACJA_24H }, 'consultation_2h_before': { method: 'get2hBeforeEmail', column: CONFIG.COLUMNS.KONSULTACJA_2H }, 'consultation_15min_before': { method: 'get15minBeforeEmail', column: CONFIG.COLUMNS.KONSULTACJA_15MIN }, 'consultation_10min_after': { method: 'get10minAfterEmail', column: CONFIG.COLUMNS.KONSULTACJA_10MIN_PO }, 'consultation_24h_after': { method: 'get24hAfterEmail', column: CONFIG.COLUMNS.KONSULTACJA_24H_PO }, 'consultation_3days_after': { method: 'get3daysAfterEmail', column: CONFIG.COLUMNS.KONSULTACJA_3DNI_PO }, 'consultation_7days_after': { method: 'get7daysAfterEmail', column: CONFIG.COLUMNS.ANKIETA_STATUS } }; const config = mapping[type]; if (!config) { throw new Error(`Nieznany typ emaila konsultacyjnego: ${type}`); } emailContent = template[config.method](data); GmailApp.sendEmail(data.email, emailContent.subject, emailContent.text, { htmlBody: emailContent.html, name: "Kamil Owsianik - Klinika Formy", replyTo: CONFIG.EMAIL_SENDER }); // Aktualizuj status w arkuszu this.updateConsultationStatus(data.rowNumber, config.column, `Wysłano: ${new Date()}`); Logger.log(`[Queue] Wysłano ${type} do ${data.email}`); } checkPurchaseStatus(email) { const spreadsheet = SpreadsheetApp.openById(CONFIG.SPREADSHEET_ID); const sheet = spreadsheet.getSheetByName(CONFIG.PROGRAM_SHEET_NAME); const data = sheet.getDataRange().getValues(); for (let i = 1; i < data.length; i++) { if (data[i][3] === email) { return data[i][CONFIG.COLUMNS.PURCHASE_STATUS - 1] === 'KUPIŁ'; } } return false; } updateEmailStatus(email, column, status) { const spreadsheet = SpreadsheetApp.openById(CONFIG.SPREADSHEET_ID); const sheet = spreadsheet.getSheetByName(CONFIG.EBOOK_SHEET_NAME); const data = sheet.getDataRange().getValues(); for (let i = 1; i < data.length; i++) { if (data[i][3] === email) { sheet.getRange(i + 1, column).setValue(status); return; } } } updateConsultationStatus(rowNumber, column, status) { const spreadsheet = SpreadsheetApp.openById(CONFIG.SPREADSHEET_ID); const sheet = spreadsheet.getSheetByName(CONFIG.PROGRAM_SHEET_NAME); sheet.getRange(rowNumber, column).setValue(status); } cleanup() { const now = new Date().getTime(); const maxAge = CONFIG.MAX_QUEUE_AGE_DAYS * 24 * 60 * 60 * 1000; const allProperties = this.properties.getProperties(); let cleaned = 0; for (const key in allProperties) { if (!key.startsWith('queue_')) continue; try { const queueItem = JSON.parse(allProperties[key]); // Usuń stare elementy if (queueItem.createdAt < (now - maxAge)) { this.properties.deleteProperty(key); cleaned++; } } catch (error) { // Usuń uszkodzone elementy this.properties.deleteProperty(key); cleaned++; } } if (cleaned > 0) { Logger.log(`[Queue] Wyczyszczono ${cleaned} starych elementów`); } return cleaned; } getStatus() { const allProperties = this.properties.getProperties(); const now = new Date().getTime(); const status = { total: 0, pending: 0, overdue: 0, byType: {} }; for (const key in allProperties) { if (!key.startsWith('queue_')) continue; try { const queueItem = JSON.parse(allProperties[key]); status.total++; if (queueItem.sendTime > now) { status.pending++; } else { status.overdue++; } status.byType[queueItem.type] = (status.byType[queueItem.type] || 0) + 1; } catch (error) { // Ignoruj uszkodzone } } return status; } }// ==================== MODUŁ INTEGRACJI KALENDARZA ==================== class CalendarIntegration { constructor() { this.calendar = CalendarApp.getDefaultCalendar(); this.spreadsheet = SpreadsheetApp.openById(CONFIG.SPREADSHEET_ID); this.sheet = this.spreadsheet.getSheetByName(CONFIG.PROGRAM_SHEET_NAME); this.queue = new QueueManager(); } scanForNewConsultations() { const now = new Date(); const endDate = new Date(now.getTime() + 7 * 24 * 60 * 60 * 1000); Logger.log(`[Calendar] Skanowanie wydarzeń od ${now} do ${endDate}`); const events = this.calendar.getEvents(now, endDate); const stats = { new: 0, updated: 0, skipped: 0 }; events.forEach(event => { if (this.isConsultationEvent(event)) { const result = this.processConsultationEvent(event); stats[result]++; } }); Logger.log(`[Calendar] Wyniki skanowania: Nowe=${stats.new}, Zaktualizowane=${stats.updated}, Pominięte=${stats.skipped}`); return stats; } isConsultationEvent(event) { const title = event.getTitle().toLowerCase(); const keywords = ['konsultacja', 'spotkanie', 'meet', 'zmiana', 'rozmowa', 'call']; return keywords.some(keyword => title.includes(keyword)); } processConsultationEvent(event) { const attendees = event.getGuestList(); for (let attendee of attendees) { const email = attendee.getEmail(); if (email === CONFIG.EMAIL_SENDER) continue; const clientRow = this.findClientByEmail(email); if (!clientRow) { Logger.log(`[Calendar] Klient nieznaleziony w arkuszu: ${email}`); return 'skipped'; } const purchaseStatus = this.sheet.getRange(clientRow, CONFIG.COLUMNS.PURCHASE_STATUS).getValue(); if (purchaseStatus === 'KUPIŁ') { Logger.log(`[Calendar] Klient już kupił: ${email}`); this.sendWelcomeEmail(email, clientRow); return 'skipped'; } const existingEventId = this.sheet.getRange(clientRow, CONFIG.COLUMNS.CALENDAR_EVENT_ID).getValue(); if (existingEventId === event.getId()) { return 'skipped'; } this.sheet.getRange(clientRow, CONFIG.COLUMNS.CALENDAR_EVENT_ID).setValue(event.getId()); this.scheduleConsultationEmails(email, event, clientRow); return existingEventId ? 'updated' : 'new'; } return 'skipped'; } findClientByEmail(email) { const data = this.sheet.getDataRange().getValues(); for (let i = 1; i < data.length; i++) { if (data[i][3] === email) { return i + 1; } } return null; } scheduleConsultationEmails(email, event, rowNumber) { const eventTime = event.getStartTime(); const clientData = this.sheet.getRange(rowNumber, 1, 1, 16).getValues()[0]; const emailData = { email: email, imie: clientData[1], nazwisko: clientData[2], eventTime: eventTime.getTime(), eventId: event.getId(), meetLink: this.extractMeetLink(event), rowNumber: rowNumber }; // Wyślij natychmiast potwierdzenie this.sendConfirmationEmail(emailData); this.sheet.getRange(rowNumber, CONFIG.COLUMNS.KONSULTACJA_POTWIERDZENIE).setValue('Wysłano: ' + new Date()); // Dodaj pozostałe emaile do kolejki const eventTimeMs = eventTime.getTime(); const now = new Date().getTime(); // Lista emaili do zaplanowania const emailSchedule = [ { type: 'consultation_24h_before', delay: eventTimeMs - now - (24 * 60 * 60 * 1000) }, { type: 'consultation_2h_before', delay: eventTimeMs - now - (2 * 60 * 60 * 1000) }, { type: 'consultation_15min_before', delay: eventTimeMs - now - (15 * 60 * 1000) }, { type: 'consultation_10min_after', delay: eventTimeMs - now + CONFIG.DELAYS.KONSULTACJA_10MIN }, { type: 'consultation_24h_after', delay: eventTimeMs - now + CONFIG.DELAYS.KONSULTACJA_24H }, { type: 'consultation_3days_after', delay: eventTimeMs - now + CONFIG.DELAYS.KONSULTACJA_3DNI }, { type: 'consultation_7days_after', delay: eventTimeMs - now + CONFIG.DELAYS.KONSULTACJA_7DNI } ]; // Dodaj do kolejki tylko te, które są w przyszłości emailSchedule.forEach(schedule => { if (schedule.delay > 0) { this.queue.addToQueue(schedule.type, emailData, schedule.delay); } }); Logger.log(`[Calendar] Zaplanowano ${emailSchedule.filter(s => s.delay > 0).length} emaili dla ${email}`); } extractMeetLink(event) { const description = event.getDescription(); const meetRegex = /https:\/\/meet\.google\.com\/[a-z-]+/i; const match = description.match(meetRegex); return match ? match[0] : ''; } sendConfirmationEmail(emailData) { const template = new ConsultationEmailTemplates(); const { subject, html, text } = template.getConfirmationEmail(emailData); GmailApp.sendEmail(emailData.email, subject, text, { htmlBody: html, name: "Kamil Owsianik - Klinika Formy", replyTo: CONFIG.EMAIL_SENDER }); } sendWelcomeEmail(email, rowNumber) { const clientData = this.sheet.getRange(rowNumber, 1, 1, 16).getValues()[0]; const template = new ConsultationEmailTemplates(); const { subject, html, text } = template.getWelcomeEmail({ email: email, imie: clientData[1], nazwisko: clientData[2] }); GmailApp.sendEmail(email, subject, text, { htmlBody: html, name: "Kamil Owsianik - Klinika Formy", replyTo: CONFIG.EMAIL_SENDER }); } }// ==================== GŁÓWNY PROCESSOR ==================== function mainProcessor() { const startTime = new Date(); Logger.log(`[Main] ====== START PRZETWARZANIA ${startTime} ======`); try { // 1. Przetwórz kolejkę emaili const queue = new QueueManager(); const queueStats = queue.processQueue(); // 2. Skanuj kalendarz const calendar = new CalendarIntegration(); const calendarStats = calendar.scanForNewConsultations(); // 3. Przetwórz kolejkę ponownie (dla nowych elementów z kalendarza) const queueStats2 = queue.processQueue(); const endTime = new Date(); const duration = (endTime - startTime) / 1000; Logger.log(`[Main] ====== KONIEC PRZETWARZANIA ======`); Logger.log(`[Main] Czas wykonania: ${duration}s`); Logger.log(`[Main] Kolejka: Przetworzono=${queueStats.processed + queueStats2.processed}, Błędy=${queueStats.errors + queueStats2.errors}`); Logger.log(`[Main] Kalendarz: Nowe=${calendarStats.new}, Zaktualizowane=${calendarStats.updated}`); return { duration: duration, queue: { processed: queueStats.processed + queueStats2.processed, errors: queueStats.errors + queueStats2.errors }, calendar: calendarStats }; } catch (error) { Logger.log(`[Main] BŁĄD KRYTYCZNY: ${error.toString()}`); throw error; } }// ==================== FUNKCJE GETRESPONSE ==================== function addContactToGetResponse(imie, email) { try { const url = 'https://api.getresponse.com/v3/contacts'; if (!email || !email.includes('@')) { return "Błąd: Nieprawidłowy format adresu email"; } const payload = { 'email': email, 'name': imie, 'campaign': { 'campaignId': CONFIG.GETRESPONSE_CAMPAIGN_ID } }; Logger.log('[GetResponse] Wysyłanie: ' + email); const options = { 'method': 'post', 'contentType': 'application/json', 'headers': { 'X-Auth-Token': 'api-key ' + CONFIG.GETRESPONSE_API_KEY }, 'payload': JSON.stringify(payload), 'muteHttpExceptions': true }; const response = UrlFetchApp.fetch(url, options); const responseCode = response.getResponseCode(); if (responseCode >= 200 && responseCode < 300) { return "Dodano do GetResponse"; } else if (responseCode === 409) { return "Już istnieje w GetResponse"; } else { return "Błąd GetResponse: " + responseCode; } } catch (error) { Logger.log('[GetResponse] Błąd: ' + error.toString()); return "Błąd: " + error.toString(); } }// ==================== FUNKCJA STOPKI ==================== function createEmailFooter() { return `

Do zobaczenia Założyciel Kliniki Formy Tel: +48 733 705 478 @: kontakt@klinika-formy.pl WWW: klinika-formy.pl

`; }// ==================== FUNKCJE EMAILI EBOOK - POPRAWIONE ====================function wyslijEmail1(imie, nazwisko, email) { try { const pelneImie = imie + ' ' + nazwisko; const temat = 'MATERIAŁ WIDEO + 3 BONUSY - Twoja droga do wymarzonej sylwetki zaczyna się TUTAJ!'; const htmlBody = ` `; const plainTextBody = `Witaj ${pelneImie}! GRATULACJE! Oto link do wideo i Twoich bonusów. Obejrzyj koniecznie: ${CONFIG.URLS.LANDING_PAGE_2}`; GmailApp.sendEmail(email, temat, plainTextBody, { htmlBody: htmlBody, name: "Kamil Owsianik - Klinika Formy", replyTo: CONFIG.EMAIL_SENDER }); Logger.log('[Email] Wysłano email 1 do: ' + email); return "Wysłano pomyślnie"; } catch (error) { throw new Error('Błąd wysyłania emaila 1: ' + error.toString()); } }function wyslijEmail2Function(imie, nazwisko, email) { try { const temat = imie + ', udało Ci się obejrzeć wideo? (ważna informacja o konsultacji)'; const htmlBody = ` `; const plainTextBody = `Cześć ${imie}! Czy udało Ci się obejrzeć wideo? Mam dla Ciebie bezpłatną konsultację (wartość 250 zł). Zobacz: ${CONFIG.URLS.LANDING_PAGE_2}`; GmailApp.sendEmail(email, temat, plainTextBody, { htmlBody: htmlBody, name: "Kamil Owsianik - Klinika Formy", replyTo: CONFIG.EMAIL_SENDER }); Logger.log('[Email] Wysłano email 2 do: ' + email); return "Wysłano pomyślnie"; } catch (error) { Logger.log('[Email] Błąd wysyłania emaila 2: ' + error.toString()); return "Błąd: " + error.toString(); } }function wyslijEmail3Function(imie, nazwisko, email) { try { const temat = imie + ', zobacz co osiągnęli inni! (+ Twoja konsultacja czeka)'; const htmlBody = ` `; const plainTextBody = `Witaj ${imie}! Zobacz, co osiągnęli inni - 347+ osób zmieniło swoje życie. Twoja darmowa konsultacja (wartość 250 zł) czeka: ${CONFIG.URLS.LANDING_PAGE_2}`; GmailApp.sendEmail(email, temat, plainTextBody, { htmlBody: htmlBody, name: "Kamil Owsianik - Klinika Formy", replyTo: CONFIG.EMAIL_SENDER }); Logger.log('[Email] Wysłano email 3 do: ' + email); return "Wysłano pomyślnie"; } catch (error) { Logger.log('[Email] Błąd wysyłania emaila 3: ' + error.toString()); return "Błąd: " + error.toString(); } }function wyslijEmail4Function(imie, nazwisko, email) { try { const temat = imie + ', Twoje BONUSY są gotowe! (e-book, dieta, grupa FB + OSTATNIA SZANSA na konsultację)'; const htmlBody = ` `; const plainTextBody = `Cześć ${imie}! Twoje bonusy są gotowe! E-book, dieta, grupa FB + OSTATNIA SZANSA na darmową konsultację (wartość 250 zł). Pobierz tutaj: ${CONFIG.URLS.DOWNLOAD_PAGE} i zarezerwuj konsultację: ${CONFIG.URLS.LANDING_PAGE_2}`; GmailApp.sendEmail(email, temat, plainTextBody, { htmlBody: htmlBody, name: "Kamil Owsianik - Klinika Formy", replyTo: CONFIG.EMAIL_SENDER }); Logger.log('[Email] Wysłano email 4 do: ' + email); return "Wysłano pomyślnie"; } catch (error) { Logger.log('[Email] Błąd wysyłania emaila 4: ' + error.toString()); return "Błąd: " + error.toString(); } }function wyslijEmailPotwierdzajacyKonsultacje(imie, nazwisko, email) { try { const pelneImie = imie + ' ' + nazwisko; const temat = 'Potwierdzenie zgłoszenia + INSTRUKCJE przygotowania do konsultacji'; const htmlBody = ` `; const plainTextBody = `Witaj ${pelneImie}, Twoje zgłoszenie zostało przyjęte! POTWIERDŹ ZGŁOSZENIE: ${CONFIG.URLS.CONFIRMATION_PAGE} Skontaktujemy się w ciągu 24-48h z numeru +48 733 705 478. Pobierz bonusy: ${CONFIG.URLS.DOWNLOAD_PAGE}`; GmailApp.sendEmail(email, temat, plainTextBody, { htmlBody: htmlBody, name: "Kamil Owsianik - Klinika Formy", replyTo: CONFIG.EMAIL_SENDER }); Logger.log('[Email] Wysłano potwierdzenie konsultacji do: ' + email); return "Wysłano pomyślnie"; } catch (error) { throw new Error('Błąd wysyłania emaila konsultacji: ' + error.toString()); } }// ==================== SZABLONY EMAILI KONSULTACYJNYCH ==================== class ConsultationEmailTemplates { getConfirmationEmail(data) { const meetingDate = new Date(data.eventTime); const formattedDate = Utilities.formatDate(meetingDate, 'Europe/Warsaw', 'dd.MM.yyyy'); const formattedTime = Utilities.formatDate(meetingDate, 'Europe/Warsaw', 'HH:mm'); const subject = 'Jutro o ' + formattedTime + ' - Twoja konsultacja'; // Tworzenie linku do kalendarza Google const eventTitle = encodeURIComponent('Konsultacja - Klinika Formy'); const eventDetails = encodeURIComponent('Konsultacja online z Kamilem Owsianik\n\nLink do spotkania: ' + data.meetLink); const startTime = meetingDate.toISOString().replace(/-|:|\.\d\d\d/g, ''); const endTime = new Date(meetingDate.getTime() + 60 * 60 * 1000).toISOString().replace(/-|:|\.\d\d\d/g, ''); const calendarLink = `https://calendar.google.com/calendar/render?action=TEMPLATE&text=${eventTitle}&details=${eventDetails}&dates=${startTime}/${endTime}`; const html = ` `; const text = 'Twoja konsultacja jest potwierdzona!'; return { subject, html, text }; } get24hBeforeEmail(data) { const meetingDate = new Date(data.eventTime); const formattedTime = Utilities.formatDate(meetingDate, 'Europe/Warsaw', 'HH:mm'); const subject = 'Jutro o ' + formattedTime + ' - Twoja konsultacja (przygotuj się!)'; const html = ` `; const text = 'Jutro konsultacja!'; return { subject, html, text }; } get2hBeforeEmail(data) { const meetingDate = new Date(data.eventTime); const formattedTime = Utilities.formatDate(meetingDate, 'Europe/Warsaw', 'HH:mm'); const subject = 'Za 2 godziny start! Konsultacja o ' + formattedTime; const html = ` `; const text = 'Za 2 godziny konsultacja!'; return { subject, html, text }; } get15minBeforeEmail(data) { const subject = 'START za 15 minut!'; const html = ` `; const text = 'START za 15 minut!'; return { subject, html, text }; } get10minAfterEmail(data) { const subject = 'Twój plan + prezentacja platformy'; const html = ` `; const text = 'Dziękuję za spotkanie!'; return { subject, html, text }; } get24hAfterEmail(data) { const subject = 'Twój plan + oferta specjalna (48h)'; const html = ` `; const text = 'Twój plan gotowy!'; return { subject, html, text }; } get3daysAfterEmail(data) { const subject = 'Ostatnia szansa na ofertę'; const html = ` `; const text = 'Ostatnia szansa!'; return { subject, html, text }; } get7daysAfterEmail(data) { const subject = 'Czy mogę zapytać?'; const html = ` `; const text = 'Czy mogę zapytać?'; return { subject, html, text }; } getWelcomeEmail(data) { const subject = 'Witaj w programie!'; const html = ` `; const text = 'Witaj w programie!'; return { subject, html, text }; } }// ==================== FUNKCJE POMOCNICZE ==================== function zaplanujKolejneEmaile(imie, nazwisko, email, timestamp) { const queue = new QueueManager(); // Dodaj emaile 2, 3, 4 do kolejki queue.addToQueue('ebook_email_2', { imie, nazwisko, email }, CONFIG.DELAYS.EMAIL_2); queue.addToQueue('ebook_email_3', { imie, nazwisko, email }, CONFIG.DELAYS.EMAIL_3); queue.addToQueue('ebook_email_4', { imie, nazwisko, email }, CONFIG.DELAYS.EMAIL_4); Logger.log(`[Email] Zaplanowano 3 emaile dla: ${email}`); }// ==================== PRZETWARZANIE FORMULARZY ==================== function processEbookForm(data, timestamp) { const rowData = [ timestamp, data.imie || '', data.nazwisko || '', data.email || '', data.tel || '', data.cel || '' ]; let emailStatus = 'Nie wysłano'; if (data.email) { try { emailStatus = wyslijEmail1(data.imie, data.nazwisko, data.email); zaplanujKolejneEmaile(data.imie, data.nazwisko, data.email, timestamp); } catch (error) { Logger.log('[Form] Błąd emaila: ' + error.toString()); emailStatus = 'Błąd: ' + error.toString(); } } while (rowData.length < CONFIG.COLUMNS.EMAIL_1_STATUS - 1) { rowData.push(''); } rowData.push(emailStatus); rowData.push('Zaplanowano'); rowData.push('Zaplanowano'); rowData.push('Zaplanowano'); let getResponseStatus = 'Nie wysłano'; if (data.email) { try { getResponseStatus = addContactToGetResponse(data.imie, data.email); } catch (error) { Logger.log('[Form] GetResponse błąd: ' + error.toString()); getResponseStatus = 'Błąd: ' + error.toString(); } } while (rowData.length < CONFIG.COLUMNS.EBOOK_GETRESPONSE - 1) { rowData.push(''); } rowData[CONFIG.COLUMNS.EBOOK_GETRESPONSE - 1] = getResponseStatus; return rowData; }function processProgramForm(data, timestamp) { const rowData = [ timestamp, data.imie || '', data.nazwisko || '', data.email || '', data.tel || '', data.waga || '', data.wzrost || '', data.wiek || '', data.cel || '', data.czas_proby || '', data.samopoczucie || '', data.pilnosc || '', data.budzet || '', data.godziny_kontaktu || '', data.dlaczego || '', data.choroby || '' ]; let emailStatus = 'Nie wysłano'; if (data.email) { try { emailStatus = wyslijEmailPotwierdzajacyKonsultacje(data.imie, data.nazwisko, data.email); } catch (error) { Logger.log('[Form] Błąd emaila: ' + error.toString()); emailStatus = 'Błąd: ' + error.toString(); } } rowData.push(emailStatus); rowData.push(''); // PURCHASE_STATUS let getResponseStatus = 'Nie wysłano'; if (data.email) { try { getResponseStatus = addContactToGetResponse(data.imie, data.email); } catch (error) { Logger.log('[Form] GetResponse błąd: ' + error.toString()); getResponseStatus = 'Błąd: ' + error.toString(); } } while (rowData.length < CONFIG.COLUMNS.PROGRAM_GETRESPONSE - 1) { rowData.push(''); } rowData.push(getResponseStatus); return rowData; }// ==================== FUNKCJE SYSTEMOWE ==================== function setupOptimizedSystem() { Logger.log('[Setup] Rozpoczynam konfigurację systemu v3.2...'); // 1. Wyczyść wszystkie triggery const triggers = ScriptApp.getProjectTriggers(); triggers.forEach(trigger => { ScriptApp.deleteTrigger(trigger); Logger.log(`[Setup] Usunięto trigger: ${trigger.getHandlerFunction()}`); }); // 2. Ustaw główny processor (co godzinę) ScriptApp.newTrigger('mainProcessor') .timeBased() .everyHours(1) .create(); // 3. Ustaw czyszczenie (raz dziennie) ScriptApp.newTrigger('dailyMaintenance') .timeBased() .everyDays(1) .atHour(3) .create(); Logger.log('[Setup] System v3.2 skonfigurowany! Używa tylko 2 triggery.'); // 4. Sprawdź status const status = checkSystemStatus(); return { message: 'System zoptymalizowany', version: CONFIG.SYSTEM_VERSION, triggers: 2, status: status }; }function dailyMaintenance() { Logger.log('[Maintenance] Rozpoczynam codzienną konserwację...'); const queue = new QueueManager(); const cleaned = queue.cleanup(); // Wyczyść stare properties const properties = PropertiesService.getScriptProperties().getProperties(); let oldProperties = 0; for (const key in properties) { if (key.startsWith('trigger_') || key.startsWith('consultation_') || key.startsWith('user_')) { PropertiesService.getScriptProperties().deleteProperty(key); oldProperties++; } } Logger.log(`[Maintenance] Wyczyszczono: ${cleaned} elementów kolejki, ${oldProperties} starych properties`); return { queueCleaned: cleaned, propertiesCleaned: oldProperties }; }function checkSystemStatus() { const queue = new QueueManager(); const queueStatus = queue.getStatus(); const status = { version: CONFIG.SYSTEM_VERSION, triggers: ScriptApp.getProjectTriggers().length, maxTriggers: 20, properties: Object.keys(PropertiesService.getScriptProperties().getProperties()).length, queue: queueStatus, sheets: { ebook: SpreadsheetApp.openById(CONFIG.SPREADSHEET_ID) .getSheetByName(CONFIG.EBOOK_SHEET_NAME).getLastRow() - 1, program: SpreadsheetApp.openById(CONFIG.SPREADSHEET_ID) .getSheetByName(CONFIG.PROGRAM_SHEET_NAME).getLastRow() - 1 }, nextEvents: getUpcomingConsultations() }; Logger.log('[Status] System v' + status.version); Logger.log('[Status] Triggery: ' + status.triggers + '/' + status.maxTriggers); Logger.log('[Status] Kolejka: ' + queueStatus.total + ' (oczekujące: ' + queueStatus.pending + ', zaległe: ' + queueStatus.overdue + ')'); Logger.log('[Status] Rekordy: Ebook=' + status.sheets.ebook + ', Program=' + status.sheets.program); return status; }function getUpcomingConsultations() { const cal = CalendarApp.getDefaultCalendar(); const now = new Date(); const tomorrow = new Date(now.getTime() + 24 * 60 * 60 * 1000); const events = cal.getEvents(now, tomorrow); const consultations = []; events.forEach(event => { if (event.getTitle().toLowerCase().includes('konsultacja')) { consultations.push({ title: event.getTitle(), time: event.getStartTime(), guests: event.getGuestList().map(g => g.getEmail()).filter(e => e !== CONFIG.EMAIL_SENDER) }); } }); return consultations; }// ==================== FUNKCJE ADMINISTRACYJNE ==================== function manualCalendarScan() { Logger.log('[Manual] Ręczne skanowanie kalendarza...'); const calendar = new CalendarIntegration(); const results = calendar.scanForNewConsultations(); // Przetwórz kolejkę od razu const queue = new QueueManager(); const queueResults = queue.processQueue(); return { calendar: results, queue: queueResults }; }function forceProcessQueue() { Logger.log('[Manual] Wymuszenie przetworzenia kolejki...'); const queue = new QueueManager(); return queue.processQueue(); }function clearAllData() { const ui = SpreadsheetApp.getUi(); const response = ui.alert( 'UWAGA!', 'Czy na pewno chcesz wyczyścić WSZYSTKIE dane systemowe?', ui.ButtonSet.YES_NO ); if (response === ui.Button.YES) { // Wyczyść triggery const triggers = ScriptApp.getProjectTriggers(); triggers.forEach(t => ScriptApp.deleteTrigger(t)); // Wyczyść properties const properties = PropertiesService.getScriptProperties(); properties.deleteAllProperties(); Logger.log('[Clear] Wszystkie dane systemowe wyczyszczone'); return 'Wyczyszczono wszystkie dane'; } return 'Anulowano'; }function testEmailDelivery(email) { if (!email) { email = 'test@example.com'; } try { GmailApp.sendEmail( email, 'TEST - Klinika Formy CRM', 'To jest email testowy.', { htmlBody: '

Test Email

System działa poprawnie.

', name: "Kamil Owsianik - TEST", replyTo: CONFIG.EMAIL_SENDER } ); Logger.log(`[Test] Email testowy wysłany do: ${email}`); return 'Email testowy wysłany'; } catch (error) { Logger.log(`[Test] Błąd wysyłania: ${error.toString()}`); return 'Błąd: ' + error.toString(); } }function addTestClient(imie = 'Test', nazwisko = 'Testowy', email = 'test@example.com', telefon = '+48123456789') { const spreadsheet = SpreadsheetApp.openById(CONFIG.SPREADSHEET_ID); const sheet = spreadsheet.getSheetByName(CONFIG.PROGRAM_SHEET_NAME); const rowData = [ new Date(), imie, nazwisko, email, telefon, '80', // waga '180', // wzrost '35', // wiek 'Test systemu', '3 miesiące', 'Dobrze', 'Pilne', '1500', '10-18', 'Test', 'Brak' ]; sheet.appendRow(rowData); Logger.log(`[Test] Dodano klienta testowego: ${email}`); return 'Klient testowy dodany'; }// ==================== MENU INTERFACE ==================== function onOpen() { const ui = SpreadsheetApp.getUi(); ui.createMenu('Klinika Formy CRM v3.2') .addItem('Status systemu', 'showSystemStatus') .addItem('Przetwórz kolejkę TERAZ', 'forceProcessQueue') .addSeparator() .addSubMenu(ui.createMenu('Kalendarz') .addItem('Skanuj kalendarz TERAZ', 'manualCalendarScan') .addItem('Pokaż najbliższe konsultacje', 'showUpcomingConsultations')) .addSubMenu(ui.createMenu('Email & GetResponse') .addItem('Test GetResponse', 'testGetResponseAPI') .addItem('Test wysyłki email', 'promptTestEmail')) .addSubMenu(ui.createMenu('Administracja') .addItem('Konfiguruj system v3.2', 'setupOptimizedSystem') .addItem('Ręczna konserwacja', 'dailyMaintenance') .addItem('Dodaj klienta testowego', 'addTestClient') .addItem('Wyczyść WSZYSTKO', 'clearAllData')) .addSeparator() .addItem('Dokumentacja', 'showDocumentation') .addToUi(); }function showSystemStatus() { const status = checkSystemStatus(); const html = HtmlService.createHtmlOutput(`

System Status - v${status.version}

Rekordy w arkuszach

Arkusz	Liczba rekordów
Ebook	${status.sheets.ebook}
Program	${status.sheets.program}

Typy w kolejce

${Object.entries(status.queue.byType).map(([type, count]) => `` ).join('')}

Typ	Liczba
${type}	${count}

Najbliższe konsultacje (24h)

${status.nextEvents.length > 0 ? ` ${status.nextEvents.map(e => `` ).join('')}

Tytuł	Czas	Goście
${e.title}	${e.time}	${e.guests.join(', ')}

` : '

Brak konsultacji w najbliższych 24h

' } `) .setTitle('Status Systemu') .setWidth(800) .setHeight(600); SpreadsheetApp.getUi().showModalDialog(html, 'Status Systemu CRM v3.2'); }function showUpcomingConsultations() { const consultations = getUpcomingConsultations(); const html = HtmlService.createHtmlOutput(`

Konsultacje w najbliższych 24h

${consultations.length > 0 ? ` ${consultations.map(c => `` ).join('')}

Tytuł	Czas	Goście
${c.title}	${c.time.toLocaleString('pl-PL')}	${c.guests.join(' ')}

` : '

Brak konsultacji w najbliższych 24 godzinach

' } `) .setTitle('Najbliższe konsultacje') .setWidth(600) .setHeight(400); SpreadsheetApp.getUi().showModalDialog(html, 'Najbliższe konsultacje'); }function promptTestEmail() { const ui = SpreadsheetApp.getUi(); const response = ui.prompt( 'Test email', 'Podaj adres email do testu:', ui.ButtonSet.OK_CANCEL ); if (response.getSelectedButton() === ui.Button.OK) { const result = testEmailDelivery(response.getResponseText()); ui.alert('Wynik', result, ui.ButtonSet.OK); } }function showDocumentation() { const html = HtmlService.createHtmlOutput(`

Klinika Formy CRM v3.2 - Dokumentacja

Główne funkcje:

Sekwencja emaili follow-up:

1. Email 1 (natychmiast): 4-min wideo + 3 bonusy + wartość 497 zł gratis
2. Email 2 (po 5h): Przypomnienie + instrukcje konsultacji
3. Email 3 (po 24h): Opinie klientów + dowody społeczne
4. Email 4 (po 48h): Ostatnia szansa + wszystkie bonusy do pobrania

Potwierdzenie zgłoszenia:

Po wypełnieniu formularza program, klient otrzymuje email z prośbą o potwierdzenie przez:

• WhatsApp: +48 733 705 478
• Stronę: ${CONFIG.URLS.CONFIRMATION_PAGE}

Jak dodać klienta do konsultacji?

1. Klient musi najpierw wypełnić formularz (być w arkuszu)
2. Dodaj wydarzenie w kalendarzu z słowem "KONSULTACJA"
3. Dodaj email klienta jako gościa
4. System automatycznie wyśle 7 emaili

Ważne informacje o konsultacji:

• Jeśli klient nie może uczestniczyć, musi dać znać min. 10h wcześniej
• Link do Google Meet jest automatycznie pobierany z kalendarza
• Kamerka NIE jest wymagana

Płatności:

• Stripe: 1350 zł jednorazowo
• TubaPay: 3 raty (533 zł) lub 6 rat (291 zł)

Bonusy dla klientów:

• E-book "ZMIANA" (wartość 147 zł)
• 7-dniowa dieta startowa (wartość 97 zł)
• Grupa wsparcia na FB (wartość 67 zł/mies)
• Bezpłatna konsultacja z planem 12-tyg (wartość 250 zł)

Monitoring:

Użyj checkSystemStatus() aby sprawdzić stan systemu

Rozwiązywanie problemów:

• Emaile nie wysyłają się: Kliknij "Przetwórz kolejkę TERAZ"
• Konsultacja nie wykryta: Sprawdź czy klient jest w arkuszu
• Za dużo triggerów: System automatycznie zarządza triggerami

Kontakt wsparcia:

Email: owsiany1995@gmail.com

WhatsApp: +48 733 705 478

`) .setTitle('Dokumentacja') .setWidth(700) .setHeight(600); SpreadsheetApp.getUi().showModalDialog(html, 'Dokumentacja CRM v3.2'); }// ==================== FUNKCJE TESTOWE ==================== function testGetResponseAPI() { const url = 'https://api.getresponse.com/v3/campaigns'; const options = { 'method': 'get', 'contentType': 'application/json', 'headers': { 'X-Auth-Token': 'api-key ' + CONFIG.GETRESPONSE_API_KEY }, 'muteHttpExceptions': true }; try { const response = UrlFetchApp.fetch(url, options); Logger.log('[GetResponse Test] Kod: ' + response.getResponseCode()); if (response.getResponseCode() === 200) { const campaigns = JSON.parse(response.getContentText()); Logger.log('[GetResponse Test] Znaleziono kampanii: ' + campaigns.length); // Test dodania kontaktu const testEmail = "test_" + new Date().getTime() + "@example.com"; const testResult = addContactToGetResponse("Test", testEmail); Logger.log('[GetResponse Test] Dodanie testowego kontaktu: ' + testResult); return "GetResponse działa poprawnie"; } else { return "Błąd GetResponse: " + response.getResponseCode(); } } catch (error) { Logger.log('[GetResponse Test] Błąd: ' + error.toString()); return "Błąd testu: " + error.toString(); } }// ==================== INICJALIZACJA ==================== function init() { Logger.log('[Init] Inicjalizacja systemu CRM v3.2...'); // Sprawdź czy arkusze istnieją const spreadsheet = SpreadsheetApp.openById(CONFIG.SPREADSHEET_ID); const ebookSheet = spreadsheet.getSheetByName(CONFIG.EBOOK_SHEET_NAME); const programSheet = spreadsheet.getSheetByName(CONFIG.PROGRAM_SHEET_NAME); if (!ebookSheet || !programSheet) { throw new Error('Brak wymaganych arkuszy! Sprawdź nazwy arkuszy.'); } // Ustaw system const result = setupOptimizedSystem(); Logger.log('[Init] System gotowy do pracy!'); return result; }