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';
?>