usite-sas-bic/whatsapp
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

up

Browse Source
This commit is contained in:
Lizandro Guarnizo
2026-02-20 11:21:06 -05:00
parent c9ec58979e
commit 602e6d3724
11 changed files with 130 additions and 30 deletions
Download Patch File Download Diff File Expand all files Collapse all files
scripts/media_worker.php
+80 -19
View File
@@ -1,37 +1,98 @@
<?php
/**
* Worker simple para reintentar descargas de media fallidas (opcional)
* Revisa la tabla media_queue (si existe) e intenta procesar
* Worker para reintentar descargas de media fallidas
* Se ejecuta via cron cada 2 minutos
* Revisa la tabla media_queue e intenta procesar pendientes
*/
set_time_limit(300);
require_once __DIR__ . '/../config/config.php';
require_once __DIR__ . '/../classes/MediaService.php';
$db = Database::getInstance();
$rows = $db->fetchAll('SELECT * FROM media_queue WHERE status = ? ORDER BY created_at ASC LIMIT 10', ['pending']);
// Incluir 'failed' con menos de 5 intentos para reintento
$rows = $db->fetchAll(
"SELECT * FROM media_queue WHERE (status = 'pending' OR (status = 'failed' AND (attempts IS NULL OR attempts < 5))) ORDER BY created_at ASC LIMIT 10"
);
if (empty($rows)) {
echo date('Y-m-d H:i:s') . " - No pending media jobs\n";
exit(0);
}
$ms = new MediaService();
$processed = 0;
$success = 0;
$failed = 0;
foreach ($rows as $r) {
$processed++;
$attempts = intval($r['attempts'] ?? 0) + 1;
try {
// Marcar como procesando
$db->query("UPDATE media_queue SET status = 'processing', attempts = :att WHERE id = :id", ['att' => $attempts, 'id' => $r['id']]);
$res = null;
if (!empty($r['media_id'])) {
$res = $ms->fetchAndStoreFromGraph($r['media_id'], $r['subdir'] ?? date('Y/m'));
} elseif (!empty($r['media_url'])) {
$res = $ms->fetchAndStoreFromUrl($r['media_url'], $r['subdir'] ?? date('Y/m'));
}
if ($res) {
// Actualizar fila media_queue
$db->update('media_queue', ['status' => 'done', 'result' => json_encode($res)], 'id = :id', ['id' => $r['id']]);
// Actualizar conversations si tenemos conversation_id
if (!empty($r['conversation_id'])) {
$update = [];
if (!empty($res['local_file'])) $update['local_file'] = $res['local_file'];
if (!empty($res['local_thumb'])) $update['local_thumb'] = $res['local_thumb'];
if (!empty($update)) {
$db->update('conversations', $update, 'id = :id', ['id' => $r['conversation_id']]);
}
if (preg_match('/^\d+$/', $r['media_url'])) {
$res = $ms->fetchAndStoreFromGraph($r['media_url'], $r['subdir'] ?? date('Y/m'));
} else {
$res = $ms->fetchAndStoreFromUrl($r['media_url'], $r['subdir'] ?? date('Y/m'));
}
}
if ($res && !empty($res['local_file'])) {
// Éxito
$db->query(
"UPDATE media_queue SET status = 'done', result = :res WHERE id = :id",
['res' => json_encode($res), 'id' => $r['id']]
);
// Actualizar conversations con el archivo local
if (!empty($r['conversation_id'])) {
$update = ['local_file' => $res['local_file']];
if (!empty($res['local_thumb'])) $update['local_thumb'] = $res['local_thumb'];
if (!empty($res['mime_type'])) $update['mime_type'] = $res['mime_type'];
$db->update('conversations', $update, 'id = :id', ['id' => $r['conversation_id']]);
echo date('Y-m-d H:i:s') . " - OK Media #{$r['id']} -> {$res['local_file']} (conv:{$r['conversation_id']})\n";
} else {
// Sin conversation_id: buscar por media_id/media_url
$mediaRef = !empty($r['media_id']) ? $r['media_id'] : $r['media_url'];
if ($mediaRef) {
try {
$db->query(
"UPDATE conversations SET local_file = :lf, local_thumb = :lt, mime_type = :mt WHERE (media_url = :mid OR whatsapp_media_id = :mid2) AND (local_file IS NULL OR local_file = '') LIMIT 5",
[
'lf' => $res['local_file'],
'lt' => $res['local_thumb'] ?? null,
'mt' => $res['mime_type'] ?? null,
'mid' => $mediaRef,
'mid2' => $mediaRef
]
);
} catch (Exception $e) {
error_log("[media_worker] Error updating conversations: " . $e->getMessage());
}
}
echo date('Y-m-d H:i:s') . " - OK Media #{$r['id']} -> {$res['local_file']} (sin conv_id)\n";
}
$success++;
} else {
throw new Exception('Download returned empty result');
}
} catch (Exception $e) {
$db->update('media_queue', ['status' => 'failed', 'result' => json_encode(['error' => $e->getMessage()])], 'id = :id', ['id' => $r['id']]);
$failed++;
$status = ($attempts >= 5) ? 'permanently_failed' : 'failed';
$db->query(
"UPDATE media_queue SET status = :st, attempts = :att, result = :res WHERE id = :id",
['st' => $status, 'att' => $attempts, 'res' => json_encode(['error' => $e->getMessage()]), 'id' => $r['id']]
);
echo date('Y-m-d H:i:s') . " - FAIL Media #{$r['id']} attempt {$attempts}: " . $e->getMessage() . "\n";
}
}
echo "Processed " . count($rows) . " jobs\n";
echo date('Y-m-d H:i:s') . " - Processed {$processed}: {$success} ok, {$failed} failed\n";