query("SELECT language_code, flag_emoji FROM supported_languages WHERE is_active = 1"); $languages = $stmt->fetchAll(); if (count($languages) <= 1) { return []; } return [ 'telegram' => buildTelegramTranslationButtons($pdo, $languages, $text), 'discord' => buildDiscordTranslationButtons($languages, $text) ]; } function buildTelegramTranslationButtons(PDO $pdo, array $languages, string $text): array { if (count($languages) <= 1) { return []; } // Guardar texto en la base de datos con hash consistente $textHash = md5($text); $stmt = $pdo->prepare("INSERT INTO translation_cache (text_hash, original_text) VALUES (?, ?) ON DUPLICATE KEY UPDATE original_text = VALUES(original_text)"); $stmt->execute([$textHash, $text]); $buttons = []; foreach ($languages as $lang) { $buttons[] = [ 'text' => $lang['flag_emoji'] . ' ' . strtoupper($lang['language_code']), 'callback_data' => 'translate:' . $lang['language_code'] . ':' . $textHash ]; } return [ 'inline_keyboard' => array_chunk($buttons, 3) ]; } function buildDiscordTranslationButtons(array $languages, string $text): array { $buttons = []; $textHash = md5($text); foreach ($languages as $lang) { $buttons[] = [ 'label' => $lang['flag_emoji'] . ' ' . strtoupper($lang['language_code']), 'custom_id' => 'translate_' . $lang['language_code'] . ':' . $textHash, 'style' => 1 ]; } return [ [ 'type' => 1, 'components' => array_slice($buttons, 0, 5) ] ]; } $pageTitle = t('Crear Mensaje'); $recipients = []; $templates = []; $galleryImages = []; try { $pdo = getDbConnection(); $stmt = $pdo->query("SELECT * FROM recipients ORDER BY platform, name"); $recipients = $stmt->fetchAll(); $stmt = $pdo->query("SELECT * FROM recurrent_messages ORDER BY name"); $templates = $stmt->fetchAll(); // Cargar imágenes de la galería $galleryPath = __DIR__ . '/galeria'; if (is_dir($galleryPath)) { $files = scandir($galleryPath); foreach ($files as $file) { if (in_array(strtolower(pathinfo($file, PATHINFO_EXTENSION)), ['jpg', 'jpeg', 'png', 'gif', 'webp'])) { $galleryImages[] = $file; } } } } catch (Exception $e) { $error = $e->getMessage(); } if ($_SERVER['REQUEST_METHOD'] === 'POST' && isset($_POST['action']) && $_POST['action'] === 'create') { $result = handleCreateMessage($_POST); if ($result['success']) { // Si es "enviar ahora", procesar inmediatamente if ($_POST['send_type'] === 'now') { $scheduleId = $result['schedule_id']; // Obtener datos del schedule $stmt = $pdo->prepare(" SELECT s.*, m.content, r.platform_id, r.platform, r.name as recipient_name FROM schedules s JOIN messages m ON s.message_id = m.id JOIN recipients r ON s.recipient_id = r.id WHERE s.id = ? "); $stmt->execute([$scheduleId]); $schedule = $stmt->fetch(); if ($schedule) { $stmt = $pdo->prepare("UPDATE schedules SET status = 'processing' WHERE id = ?"); $stmt->execute([$schedule['id']]); try { $sender = \Common\Helpers\SenderFactory::create($schedule['platform']); // Obtener botones de traducción (convertir HTML a texto plano) $plainText = $schedule['content']; // Convertir saltos de párrafo a saltos de línea $plainText = preg_replace('/<\/p>/i', "\n", $plainText); $plainText = preg_replace('/]*>/i', '', $plainText); $plainText = preg_replace('//i', "\n", $plainText); // Eliminar HTML $plainText = html_entity_decode(strip_tags($plainText), ENT_QUOTES | ENT_HTML5, 'UTF-8'); // Limpiar espacios múltiples pero preservar saltos de línea $plainText = preg_replace('/[ \t]+/', ' ', $plainText); $plainText = preg_replace('/\n\s*\n/', "\n", $plainText); $plainText = trim($plainText); $translationButtons = getTranslationButtons($pdo, $plainText); $segments = $sender->parseContent($schedule['content']); $messageCount = 0; foreach ($segments as $segment) { if ($segment['type'] === 'text') { $textContent = \Common\Helpers\ConverterFactory::convert($schedule['platform'], $segment['content']); if (!empty(trim($textContent))) { // Agregar botones de traducción al último segmento de texto $buttons = null; if ($segment === end($segments)) { $buttons = $schedule['platform'] === 'telegram' ? $translationButtons['telegram'] : $translationButtons['discord']; } if ($schedule['platform'] === 'telegram') { $sender->sendMessage($schedule['platform_id'], $textContent, $buttons); } else { $sender->sendMessage($schedule['platform_id'], $textContent, null, $buttons); } $messageCount++; } } elseif ($segment['type'] === 'image') { $imagePath = $segment['src']; $imgPath = parse_url($imagePath, PHP_URL_PATH) ?: $imagePath; if (file_exists($imgPath)) { $sender->sendMessageWithAttachments($schedule['platform_id'], '', [$imgPath]); $messageCount++; } elseif (strpos($imagePath, 'http') === 0) { $embed = ['image' => ['url' => $imagePath]]; $sender->sendMessage($schedule['platform_id'], '', $embed); $messageCount++; } } } $stmt = $pdo->prepare(" INSERT INTO sent_messages (schedule_id, recipient_id, platform_message_id, message_count, sent_at) VALUES (?, ?, '', ?, NOW()) "); $stmt->execute([$schedule['id'], $schedule['recipient_id'], $messageCount]); $stmt = $pdo->prepare("UPDATE schedules SET status = 'sent', sent_at = NOW() WHERE id = ?"); $stmt->execute([$schedule['id']]); } catch (Exception $e) { $stmt = $pdo->prepare("UPDATE schedules SET status = 'failed', error_message = ? WHERE id = ?"); $stmt->execute([$e->getMessage(), $schedule['id']]); } } } header('Location: scheduled_messages.php?success=1'); exit; } else { $error = $result['error']; } } require_once __DIR__ . '/templates/header.php'; ?>