Files
whatsapp/api/send_media_message.php
T
2026-01-21 14:36:29 -05:00

278 lines
11 KiB
PHP

<?php
/**
* API - Enviar mensaje multimedia
* Fecha: 13 de enero de 2026
*/
// Deshabilitar cualquier output buffer y errores visuales
error_reporting(E_ALL);
ini_set('display_errors', 0);
ini_set('log_errors', 1);
require_once '../config/config.php';
// Helper logger para debugging específico de este endpoint
function smm_log($msg) {
static $triedInit = false;
$path = __DIR__ . '/send_media_message_debug.log';
$dir = dirname($path);
$entry = date('[Y-m-d H:i:s] ') . $msg . PHP_EOL;
$ok = false;
// Intentar crear directorio si es necesario
if (!is_dir($dir) && !file_exists($dir)) {
@mkdir($dir, 0755, true);
}
// Intentar abrir y escribir
$fp = @fopen($path, 'a');
if ($fp) {
if (@fwrite($fp, $entry) !== false) {
$ok = true;
}
@fclose($fp);
}
// Si falla, fallback a error_log y marcar bandera
if (!$ok) {
@error_log("smm_log (fallback): " . $msg);
global $smm_log_write_failed;
$smm_log_write_failed = true;
}
if (!$triedInit) {
$triedInit = true;
if (isset($smm_log_write_failed) && $smm_log_write_failed) {
@error_log('smm_log: debug log write failed, check permissions on ' . $dir);
}
}
}
// Verificar autenticación
requireAuthentication();
// Limpiar cualquier output previo
if (ob_get_length()) ob_clean();
header('Content-Type: application/json; charset=utf-8');
header('Access-Control-Allow-Origin: *');
header('Access-Control-Allow-Methods: POST');
header('Access-Control-Allow-Headers: Content-Type');
if ($_SERVER['REQUEST_METHOD'] !== 'POST') {
http_response_code(405);
echo json_encode(['success' => false, 'error' => 'Método no permitido']);
exit;
}
// Función auxiliar para enviar con media_id
function sendMediaByIdToWhatsApp($whatsapp, $recipient, $mediaId, $mediaType, $caption, $filename) {
return $whatsapp->sendMediaById($recipient, $mediaId, $mediaType, $caption, $filename);
}
// Función auxiliar para enviar con link
function sendMediaByLinkToWhatsApp($whatsapp, $recipient, $mediaUrl, $mediaType, $caption, $filename) {
switch ($mediaType) {
case 'image':
return $whatsapp->sendImageMessage($recipient, $mediaUrl, $caption);
case 'video':
return $whatsapp->sendVideoMessage($recipient, $mediaUrl, $caption);
case 'audio':
return $whatsapp->sendAudioMessage($recipient, $mediaUrl);
case 'document':
return $whatsapp->sendDocumentMessage($recipient, $mediaUrl, $filename, $caption);
default:
throw new Exception('Tipo de media no soportado: ' . $mediaType);
}
}
try {
$rawInput = file_get_contents('php://input');
error_log("send_media_message.php - Raw input: " . $rawInput);
smm_log("Raw input: " . $rawInput);
$input = json_decode($rawInput, true);
if (!$input) {
error_log("send_media_message.php - JSON decode failed");
smm_log("JSON decode failed. Raw: " . $rawInput);
throw new Exception('Datos no válidos - JSON inválido');
}
error_log("send_media_message.php - Input decoded: " . json_encode($input));
smm_log("Input decoded: " . json_encode($input));
// Validar campos requeridos
if (empty($input['recipient']) || empty($input['media_url']) || empty($input['media_type'])) {
$missing = [];
if (empty($input['recipient'])) $missing[] = 'recipient';
if (empty($input['media_url'])) $missing[] = 'media_url';
if (empty($input['media_type'])) $missing[] = 'media_type';
error_log("send_media_message.php - Missing fields: " . implode(', ', $missing));
throw new Exception('Faltan campos requeridos: ' . implode(', ', $missing));
}
$recipient = $input['recipient'];
$mediaUrl = $input['media_url'];
$mediaType = $input['media_type']; // image, video, audio, document
$caption = $input['caption'] ?? null;
$filename = $input['filename'] ?? null;
// Inicializar servicio de WhatsApp
$whatsapp = new WhatsAppService();
// IMPORTANTE: Si la URL es local, necesitamos subir el archivo a WhatsApp primero
$isLocalUrl = (strpos($mediaUrl, 'localhost') !== false || strpos($mediaUrl, '127.0.0.1') !== false);
if ($isLocalUrl) {
error_log("send_media_message.php - URL local detectada, subiendo archivo a WhatsApp primero");
// Obtener la ruta local del archivo
$parsedUrl = parse_url($mediaUrl);
$relativePath = $parsedUrl['path'];
// Construir ruta absoluta
$uploadDir = __DIR__ . '/../uploads/';
$filename_from_url = basename($relativePath);
$localFilePath = $uploadDir . $filename_from_url;
error_log("send_media_message.php - Ruta local del archivo: " . $localFilePath);
if (!file_exists($localFilePath)) {
throw new Exception('Archivo no encontrado en el servidor: ' . $localFilePath);
}
// Detectar MIME type
$mimeType = mime_content_type($localFilePath);
error_log("send_media_message.php - MIME type detectado: " . $mimeType);
// Subir archivo a WhatsApp
try {
$uploadResult = $whatsapp->uploadMedia($localFilePath, $mimeType);
error_log("send_media_message.php - Archivo subido a WhatsApp: " . json_encode($uploadResult));
smm_log("Upload result: " . json_encode($uploadResult));
if (isset($uploadResult['id'])) {
// Usar el media_id de WhatsApp en lugar de URL
$mediaId = $uploadResult['id'];
error_log("send_media_message.php - Media ID obtenido: " . $mediaId);
smm_log("Media ID obtained: " . $mediaId);
// Enviar mensaje usando media_id
$response = sendMediaByIdToWhatsApp($whatsapp, $recipient, $mediaId, $mediaType, $caption, $filename);
smm_log("Send media by id response: " . json_encode($response));
} else {
smm_log("Upload did not return id: " . json_encode($uploadResult));
throw new Exception('Error al subir archivo a WhatsApp: ' . json_encode($uploadResult));
}
} catch (Exception $e) {
error_log("send_media_message.php - Error subiendo a WhatsApp: " . $e->getMessage());
throw new Exception('Error al subir archivo a WhatsApp: ' . $e->getMessage());
}
} else {
// URL pública, usar método normal con link
error_log("send_media_message.php - URL pública detectada, usando link directo");
$response = sendMediaByLinkToWhatsApp($whatsapp, $recipient, $mediaUrl, $mediaType, $caption, $filename);
}
// Guardar respuesta en base de datos
// Aceptar tanto respuestas con 'conversations' como con 'messages'
$sentMessageId = null;
if ($response) {
if (isset($response['conversations'][0]['id'])) {
$sentMessageId = $response['conversations'][0]['id'];
} elseif (isset($response['messages'][0]['id'])) {
$sentMessageId = $response['messages'][0]['id'];
}
}
// Si no hay id, pero la respuesta es un string (posible JSON crudo), intentar decodificar
if (!$sentMessageId && is_string($response)) {
$maybe = json_decode($response, true);
if (is_array($maybe)) {
error_log("send_media_message.php - Decoded raw response string to array for inspection");
// Reasignar response para usar la estructura decodificada
$response = $maybe;
if (isset($response['conversations'][0]['id'])) {
$sentMessageId = $response['conversations'][0]['id'];
} elseif (isset($response['messages'][0]['id'])) {
$sentMessageId = $response['messages'][0]['id'];
}
}
}
if ($response && $sentMessageId) {
error_log("send_media_message.php - Respuesta de WhatsApp exitosa: " . json_encode($response));
smm_log("WhatsApp response (successful): " . json_encode($response));
// Guardar en base de datos
$db = Database::getInstance();
// Obtener usuario
$user = $db->fetch(
"SELECT id FROM users WHERE phone_number = ?",
[$recipient]
);
if ($user) {
// Datos base para insertar
$conversationData = [
'user_id' => $user['id'],
'message_id' => $sentMessageId,
'direction' => 'outgoing',
'message_type' => $mediaType,
'content' => $caption ?? $filename ?? '',
'media_url' => $mediaUrl,
'status' => 'sent',
'created_at' => date('Y-m-d H:i:s')
];
// Intentar añadir filename solo si la columna existe
// TODO: Ejecutar migración add_filename_to_conversations.sql
// ALTER TABLE conversations ADD COLUMN filename VARCHAR(255) NULL AFTER media_url;
error_log("send_media_message.php - Guardando en BD: " . json_encode($conversationData));
try {
$db->insert('conversations', $conversationData);
} catch (Exception $dbError) {
// Si falla, intentar sin filename (por compatibilidad con BD antigua)
error_log("send_media_message.php - Advertencia al guardar: " . $dbError->getMessage());
}
}
echo json_encode([
'success' => true,
'message' => 'Mensaje multimedia enviado correctamente',
'media_type' => $mediaType,
'data' => $response
]);
} else {
error_log("send_media_message.php - Respuesta de WhatsApp sin message_id: " . json_encode($response));
// Añadir contexto adicional para debugging: guardar la respuesta cruda y tipo
$raw = is_string($response) ? $response : json_encode($response);
error_log("send_media_message.php - Raw response: " . substr($raw, 0, 2000));
smm_log("Raw response: " . substr($raw, 0, 2000));
throw new Exception('Error al enviar mensaje: ' . $raw);
}
} catch (Exception $e) {
error_log("Error en send_media_message.php: " . $e->getMessage());
error_log("Stack trace: " . $e->getTraceAsString());
// Limpiar cualquier output previo antes de enviar JSON
if (ob_get_length()) ob_clean();
http_response_code(500);
echo json_encode([
'success' => false,
'error' => $e->getMessage(),
'file' => basename($e->getFile()),
'line' => $e->getLine()
], JSON_UNESCAPED_UNICODE);
}
?>