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

fix(turnero): route incoming messages by phone_number_id and fix WhatsAppService canal

Browse Source 
- WhatsAppService($canal): when 'turnero', swaps phoneNumberId to whatsapp_phone_number_id_turnero
  so outgoing messages actually go from the turnero number (not the main bot)
- webhook.php: reads metadata.phone_number_id from the payload and compares it to
  whatsapp_phone_number_id_turnero; if it matches, saves canal='turnero' and skips bot processing
- Previously all incoming messages had canal=NULL/bot so Chat Turnero never saw them,
  and all outgoing messages from Chat Turnero were sent via the wrong (main bot) number

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
This commit is contained in:
Lizandro Guarnizo
2026-07-03 08:26:11 -05:00
co-authored by Claude Sonnet 4.6
parent 00aee615c5
commit 5acd46df5a
2 changed files with 28 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
api/webhook.php
+14 -6
View File
@@ -98,6 +98,11 @@ class WhatsAppWebhook {
} }
private function processconversations($value) { private function processconversations($value) {
// Detectar si este mensaje llegó al número turnero
$receivingPhoneId = $value['metadata']['phone_number_id'] ?? null;
$turneroPhoneId = getConfigFromDB('whatsapp_phone_number_id_turnero', '');
$isTurnero = $receivingPhoneId && $turneroPhoneId && ($receivingPhoneId === $turneroPhoneId);
// Aceptar tanto payloads con 'conversations' como con 'messages' (WhatsApp varía según la integración) // Aceptar tanto payloads con 'conversations' como con 'messages' (WhatsApp varía según la integración)
$items = []; $items = [];
if (isset($value['conversations']) && is_array($value['conversations'])) { if (isset($value['conversations']) && is_array($value['conversations'])) {
@@ -299,7 +304,8 @@ class WhatsAppWebhook {
'content' => $messageText, 'content' => $messageText,
'media_url' => $mediaUrl, 'media_url' => $mediaUrl,
'status' => 'received', 'status' => 'received',
'is_read' => 0 'is_read' => 0,
'canal' => $isTurnero ? 'turnero' : 'bot',
]; ];
// Guardar whatsapp_media_id si el mediaUrl es un ID numérico de WhatsApp // Guardar whatsapp_media_id si el mediaUrl es un ID numérico de WhatsApp
@@ -413,11 +419,13 @@ class WhatsAppWebhook {
'timestamp' => date('Y-m-d H:i:s') 'timestamp' => date('Y-m-d H:i:s')
]); ]);
// Procesar con bot (protección contra excepciones externas) // Procesar con bot solo si el mensaje llegó al número principal
try { if (!$isTurnero) {
$this->botService->processMessage($user, $messageText, $messageType); try {
} catch (Exception $e) { $this->botService->processMessage($user, $messageText, $messageType);
error_log("Bot processing failed: " . $e->getMessage()); } catch (Exception $e) {
error_log("Bot processing failed: " . $e->getMessage());
}
} }
} }
services/WhatsAppService.php
+14 -5
View File
@@ -22,14 +22,23 @@ class WhatsAppService
private $db; private $db;
private $rateLimitMonitor; private $rateLimitMonitor;
public function __construct() public function __construct($canal = null)
{ {
// Obtener configuración desde base de datos // Obtener configuración desde base de datos
$config = getWhatsAppConfigFromDB(); $config = getWhatsAppConfigFromDB();
$this->token = $config['token']; // Usar token de BD $this->token = $config['token'];
$this->phoneNumberId = $config['phone_number_id']; // Usar phone_number_id de BD $this->phoneNumberId = $config['phone_number_id'];
$this->apiUrl = $config['api_url'] ?: 'https://graph.facebook.com/v22.0/'; // Usar api_url de BD $this->apiUrl = $config['api_url'] ?: 'https://graph.facebook.com/v22.0/';
// Si se especifica canal 'turnero', usar el phone ID del número turnero
if ($canal === 'turnero') {
$turneroPhoneId = getConfigFromDB('whatsapp_phone_number_id_turnero', '');
if ($turneroPhoneId) {
$this->phoneNumberId = $turneroPhoneId;
}
}
$this->db = Database::getInstance(); $this->db = Database::getInstance();
// Inicializar monitor de rate limit // Inicializar monitor de rate limit