@@ -886,6 +889,42 @@
alert('Error liberando espera');
}
};
+
+ // Attender (marcar 'en servicio' sin liberar)
+ const attendBtn = document.getElementById('attend-btn');
+ if (attendBtn) {
+ attendBtn.style.display = (conv.advisor_requested && !conv.in_service) ? 'inline-block' : 'none';
+ attendBtn.onclick = async () => {
+ try {
+ const resp = await fetch('api/attend.php', {
+ method: 'POST',
+ headers: { 'Content-Type': 'application/json' },
+ body: JSON.stringify({ user_id: userId })
+ });
+ if (resp.status === 401) {
+ alert('Sesi贸n expirada. Por favor inicie sesi贸n de nuevo.');
+ return;
+ }
+ const json = await resp.json();
+ if (json && json.success) {
+ conv.in_service = true;
+ conv.advisor_requested = 0;
+ holdIndicator.textContent = 'EN SERVICIO';
+ holdIndicator.style.color = '#28a745';
+ holdIndicator.style.display = 'inline';
+ attendBtn.style.display = 'none';
+ // keep release available
+ releaseBtn.style.display = 'inline-block';
+ await this.loadConversations();
+ } else {
+ alert('Error al marcar como atendida');
+ }
+ } catch (e) {
+ console.error('Error attending', e);
+ alert('Error al atender');
+ }
+ };
+ }
}
}
};
diff --git a/scripts/add_user_in_service_column.php b/scripts/add_user_in_service_column.php
new file mode 100644
index 0000000..efb1732
--- /dev/null
+++ b/scripts/add_user_in_service_column.php
@@ -0,0 +1,50 @@
+fetch("SHOW COLUMNS FROM users LIKE 'in_service'");
+ if ($col) {
+ echo "Column in_service already exists\n";
+ } else {
+ $db->query("ALTER TABLE users ADD COLUMN in_service TINYINT(1) DEFAULT 0 AFTER advisor_requested");
+ echo "Added in_service column\n";
+ }
+
+ $col = $db->fetch("SHOW COLUMNS FROM users LIKE 'in_service_by'");
+ if ($col) {
+ echo "Column in_service_by already exists\n";
+ } else {
+ $db->query("ALTER TABLE users ADD COLUMN in_service_by INT NULL AFTER in_service");
+ echo "Added in_service_by column\n";
+ }
+
+ $col = $db->fetch("SHOW COLUMNS FROM users LIKE 'in_service_at'");
+ if ($col) {
+ echo "Column in_service_at already exists\n";
+ } else {
+ $db->query("ALTER TABLE users ADD COLUMN in_service_at DATETIME NULL AFTER in_service_by");
+ echo "Added in_service_at column\n";
+ }
+
+ // Crear tabla operator_activity si no existe
+ $check = $db->fetch("SHOW TABLES LIKE 'operator_activity'");
+ if ($check) {
+ echo "Table operator_activity already exists\n";
+ } else {
+ $sql = "CREATE TABLE operator_activity (
+ id INT AUTO_INCREMENT PRIMARY KEY,
+ user_id INT NULL,
+ operator_id INT NULL,
+ action VARCHAR(50) NOT NULL,
+ details TEXT NULL,
+ created_at DATETIME NOT NULL
+ ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4";
+ $db->query($sql);
+ echo "Created table operator_activity\n";
+ }
+
+ echo "Done.\n";
+} catch (Exception $e) {
+ echo "Migration failed: " . $e->getMessage() . "\n";
+}
diff --git a/services/BotService.php b/services/BotService.php
index 0c1bac4..a1ed429 100644
--- a/services/BotService.php
+++ b/services/BotService.php
@@ -138,7 +138,7 @@ class BotService {
} else {
// Opcional: informar que el asesor ya respondi贸 y no podemos enviar autom谩ticas
try {
- $this->whatsappService->sendTextMessage($phoneNumber, "馃敃 Un asesor ya ha intervenido en la conversaci贸n, por favor espera su respuesta o utiliza *menu* para ver opciones.");
+ //$this->whatsappService->sendTextMessage($phoneNumber, "馃敃 Un asesor ya ha intervenido en la conversaci贸n, por favor espera su respuesta o utiliza *menu* para ver opciones.");
} catch (Exception $e) {
// ignore
}
@@ -504,6 +504,47 @@ class BotService {
}
}
+ /**
+ * Marcar la conversaci贸n como "en servicio" por un operador (Atender)
+ */
+ public function attendConversation($phoneNumber, $operatorId = null) {
+ try {
+ $now = date('Y-m-d H:i:s');
+ $update = ['in_service' => 1, 'in_service_at' => $now, 'advisor_requested' => 0];
+ if ($operatorId) $update['in_service_by'] = $operatorId;
+ $this->db->update('users', $update, 'phone_number = :phone', ['phone' => $phoneNumber]);
+
+ // Notificar al usuario
+ try {
+ $this->whatsappService->sendTextMessage($phoneNumber, "馃敂 Un asesor est谩 atendiendo tu conversaci贸n. Por favor, espera su respuesta.");
+ } catch (Exception $e) {
+ // ignore send errors
+ }
+
+ // Registrar actividad del operador si hay informaci贸n disponible
+ $user = $this->db->fetch('SELECT id FROM users WHERE phone_number = :phone', ['phone' => $phoneNumber]);
+ $userId = $user['id'] ?? null;
+ $activity = [
+ 'user_id' => $userId,
+ 'operator_id' => $operatorId,
+ 'action' => 'attend',
+ 'details' => 'Operator started attending the conversation',
+ 'created_at' => $now
+ ];
+ try {
+ $this->db->insert('operator_activity', $activity);
+ } catch (Exception $e) {
+ if (function_exists('writeLog')) writeLog('WARN', 'Failed to insert operator_activity: ' . $e->getMessage());
+ error_log('Failed to insert operator_activity: ' . $e->getMessage());
+ }
+
+ if (function_exists('writeLog')) writeLog('INFO', "Operator {$operatorId} attending conversation for {$phoneNumber}");
+ } catch (Exception $e) {
+ error_log('attendConversation failed: ' . $e->getMessage());
+ throw $e;
+ }
+ }
+
/**
* Actualizar estado del men煤 del usuario
*/