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-01-28 02:44:28 -05:00
parent 6ebf5c9a22
commit e9aecc6bd2
6 changed files with 130 additions and 70 deletions
Download Patch File Download Diff File Expand all files Collapse all files
api/sse_events.php
+96 -59
View File
@@ -125,67 +125,104 @@ try {
// Revisar nuevos mensajes en BD cada 3 segundos
if (time() - $lastCheck >= 3) {
// 1. Verificar mensajes nuevos individuales (últimos 10 segundos)
$recentMessages = $db->fetchAll(
"SELECT c.*, u.phone_number, u.name as user_name
FROM conversations c
INNER JOIN users u ON c.user_id = u.id
WHERE c.created_at >= DATE_SUB(NOW(), INTERVAL 10 SECOND)
AND c.direction = 'incoming'
ORDER BY c.created_at DESC
LIMIT 10"
);
// Mantener track de mensajes ya enviados para evitar duplicados
static $lastMessageId = 0;
static $lastConversationCheck = null;
foreach ($recentMessages as $msg) {
sendSSEEvent('new_message', [
'message_id' => $msg['id'],
'user_id' => $msg['user_id'],
'phone_number' => $msg['phone_number'],
'user_name' => $msg['user_name'],
'content' => $msg['message_content'],
'message_type' => $msg['message_type'] ?? 'text',
'direction' => $msg['direction'],
'created_at' => $msg['created_at'],
'timestamp' => time()
]);
}
// 2. Verificar si hay nuevas conversaciones desde la última revisión
$recentConversations = $db->fetchAll(
"SELECT DISTINCT c.user_id, u.phone_number, u.name,
MAX(c.created_at) as last_message_time,
COUNT(*) as message_count
FROM conversations c
INNER JOIN users u ON c.user_id = u.id
WHERE c.created_at >= DATE_SUB(NOW(), INTERVAL 10 SECOND)
GROUP BY c.user_id
ORDER BY last_message_time DESC
LIMIT 5"
);
foreach ($recentConversations as $conv) {
sendSSEEvent('new_conversation', [
'user_id' => $conv['user_id'],
'phone_number' => $conv['phone_number'],
'name' => $conv['name'],
'message_count' => $conv['message_count'],
'timestamp' => $conv['last_message_time']
]);
}
// Verificar notificaciones no leídas
try {
$notifications = $db->fetchAll(
"SELECT id, user_id, type, message, data, is_read, created_at
FROM notifications
WHERE is_read = 0
ORDER BY created_at DESC
LIMIT 10"
if ($lastConversationCheck === null) {
// Primera vez: obtener el ID más alto y timestamp actual de la BD, sin enviar nada
$maxMsg = $db->fetch("SELECT MAX(id) as max_id FROM conversations");
$lastMessageId = $maxMsg['max_id'] ?? 0;
// Usar el timestamp de la BD para evitar problemas de zona horaria
$dbTime = $db->fetch("SELECT NOW() as now");
$lastConversationCheck = $dbTime['now'] ?? date('Y-m-d H:i:s');
} else {
// 1. Verificar mensajes NUEVOS (solo los que tienen ID mayor al último visto)
$recentMessages = $db->fetchAll(
"SELECT c.*, u.phone_number, u.name as user_name
FROM conversations c
INNER JOIN users u ON c.user_id = u.id
WHERE c.id > ?
AND c.direction = 'incoming'
ORDER BY c.id ASC
LIMIT 10",
[$lastMessageId]
);
if ($notifications && count($notifications) > 0) {
foreach ($notifications as $notification) {
sendSSEEvent('notification', $notification);
foreach ($recentMessages as $msg) {
sendSSEEvent('new_message', [
'message_id' => $msg['id'],
'user_id' => $msg['user_id'],
'phone_number' => $msg['phone_number'],
'user_name' => $msg['user_name'],
'content' => $msg['message_content'],
'message_type' => $msg['message_type'] ?? 'text',
'direction' => $msg['direction'],
'created_at' => $msg['created_at'],
'timestamp' => time()
]);
// Actualizar último ID visto
if ($msg['id'] > $lastMessageId) {
$lastMessageId = $msg['id'];
}
}
// 2. Verificar si hay nuevas conversaciones desde la última revisión
$recentConversations = $db->fetchAll(
"SELECT DISTINCT c.user_id, u.phone_number, u.name,
MAX(c.created_at) as last_message_time,
COUNT(*) as message_count
FROM conversations c
INNER JOIN users u ON c.user_id = u.id
WHERE c.created_at > ?
GROUP BY c.user_id
ORDER BY last_message_time DESC
LIMIT 5",
[$lastConversationCheck]
);
foreach ($recentConversations as $conv) {
sendSSEEvent('new_conversation', [
'user_id' => $conv['user_id'],
'phone_number' => $conv['phone_number'],
'name' => $conv['name'],
'message_count' => $conv['message_count'],
'timestamp' => $conv['last_message_time']
]);
// Actualizar timestamp
if ($conv['last_message_time'] > $lastConversationCheck) {
$lastConversationCheck = $conv['last_message_time'];
}
}
} // Fin del else (primera inicialización vs verificaciones posteriores)
// Verificar notificaciones NUEVAS (solo las creadas desde la última verificación)
// NO enviar notificaciones guardadas - solo las que llegan en tiempo real
try {
static $lastNotificationCheck = null;
if ($lastNotificationCheck === null) {
// Primera vez: usar el timestamp de la BD, NO enviar nada
$dbTimeNotif = $db->fetch("SELECT NOW() as now");
$lastNotificationCheck = $dbTimeNotif['now'] ?? date('Y-m-d H:i:s');
} else {
// Verificaciones posteriores: solo notificaciones NUEVAS
$notifications = $db->fetchAll(
"SELECT id, user_id, type, message, data, is_read, created_at
FROM notifications
WHERE created_at > ?
ORDER BY created_at ASC
LIMIT 10",
[$lastNotificationCheck]
);
if ($notifications && count($notifications) > 0) {
foreach ($notifications as $notification) {
sendSSEEvent('notification', $notification);
// Actualizar timestamp para evitar duplicados
if ($notification['created_at'] > $lastNotificationCheck) {
$lastNotificationCheck = $notification['created_at'];
}
}
}
}
} catch (Exception $e) {