Lizandro Guarnizo
51c187e47d
- NormalBot: nueva funcion api_report para descargar PDF/Excel del ERP y enviarlo por WhatsApp - NormalBot: resolveMenu() para referenciar menus por nombre en los flujos - WhatsAppSender: uploadMedia() y sendDocument() para envio de documentos - BotRouter: guarda respuestas en conversations para visibilidad en el chat - Script apply-menus.php con estructura completa de menus y endpoints
339 lines
13 KiB
PHP
339 lines
13 KiB
PHP
<?php
|
|
declare(strict_types=1);
|
|
|
|
class NormalBot
|
|
{
|
|
public static function process(array $company, array $context, string $input): ?array
|
|
{
|
|
$config = self::getConfig($company);
|
|
$commands = $config['commands'] ?? [];
|
|
$flows = $config['flows'] ?? [];
|
|
$menus = $config['menus'] ?? [];
|
|
|
|
$ctxId = null;
|
|
$botCtx = ConversationContext::getOrCreate((int)$company['id'], $context['from'], 'normal');
|
|
$ctxId = (int)$botCtx['id'];
|
|
$currentNode = $botCtx['current_node'];
|
|
|
|
$normalized = self::normalize($input);
|
|
|
|
if ($currentNode !== null && isset($flows[$currentNode])) {
|
|
return self::handleFlow($flows[$currentNode], $context, $company, $ctxId);
|
|
}
|
|
|
|
$matchedCommand = null;
|
|
foreach ($commands as $keyword => $action) {
|
|
if ($normalized === self::normalize($keyword)) {
|
|
$matchedCommand = $action;
|
|
break;
|
|
}
|
|
}
|
|
|
|
if ($matchedCommand !== null) {
|
|
ConversationContext::updateNode($ctxId, $matchedCommand);
|
|
|
|
if (isset($flows[$matchedCommand])) {
|
|
return self::handleFlow($flows[$matchedCommand], $context, $company, $ctxId);
|
|
}
|
|
|
|
if (isset($menus[$matchedCommand])) {
|
|
return self::buildMenuResponse($menus[$matchedCommand], $context['from'], $company);
|
|
}
|
|
|
|
return null;
|
|
}
|
|
|
|
$greeting = $config['greeting'] ?? null;
|
|
if ($greeting !== null && $currentNode === null) {
|
|
ConversationContext::updateNode($ctxId, 'greeting');
|
|
|
|
if (isset($flows['greeting'])) {
|
|
return self::handleFlow($flows['greeting'], $context, $company, $ctxId);
|
|
}
|
|
|
|
return self::sendText($greeting, $context['from'], $company);
|
|
}
|
|
|
|
$fallback = $config['fallback'] ?? null;
|
|
if ($fallback !== null) {
|
|
return self::sendText($fallback, $context['from'], $company);
|
|
}
|
|
|
|
return null;
|
|
}
|
|
|
|
private static function resolveMenu($menuRef, array $company): array
|
|
{
|
|
if (is_string($menuRef)) {
|
|
$config = self::getConfig($company);
|
|
$menus = $config['menus'] ?? [];
|
|
return $menus[$menuRef] ?? [];
|
|
}
|
|
return is_array($menuRef) ? $menuRef : [];
|
|
}
|
|
|
|
private static function handleFlow(array $flow, array $context, array $company, int $ctxId): ?array
|
|
{
|
|
$type = $flow['type'] ?? 'text';
|
|
|
|
return match ($type) {
|
|
'text' => self::sendText($flow['message'] ?? '', $context['from'], $company),
|
|
'image' => self::sendImage($flow['media_id'] ?? '', $flow['caption'] ?? null, $context['from'], $company),
|
|
'menu' => self::buildMenuResponse(self::resolveMenu($flow['menu'] ?? [], $company), $context['from'], $company),
|
|
'function' => self::executeFunction($flow['function'] ?? '', $flow['params'] ?? [], $context, $company, $ctxId),
|
|
default => null,
|
|
};
|
|
}
|
|
|
|
private static function executeFunction(string $function, array $params, array $context, array $company, int $ctxId): ?array
|
|
{
|
|
return match ($function) {
|
|
'reset' => (function () use ($ctxId, $context, $company) {
|
|
ConversationContext::reset($ctxId);
|
|
return self::sendText('¿En qué más puedo ayudarte?', $context['from'], $company);
|
|
})(),
|
|
'forward_to_ai' => null,
|
|
'api_report' => self::executeApiReport($params, $context, $company, $ctxId),
|
|
default => null,
|
|
};
|
|
}
|
|
|
|
private static function executeApiReport(array $params, array $context, array $company, int $ctxId): ?array
|
|
{
|
|
$endpoint = $params['endpoint'] ?? '';
|
|
if ($endpoint === '') {
|
|
return self::sendText('Error: endpoint no configurado.', $context['from'], $company);
|
|
}
|
|
|
|
$baseUrl = rtrim($company['api_base_url'] ?? '', '/');
|
|
$url = $baseUrl . '/' . ltrim($endpoint, '/');
|
|
$apiKey = $company['api_key'] ?? '';
|
|
|
|
$query = $params['query'] ?? [];
|
|
if (!empty($query)) {
|
|
$url .= '?' . http_build_query($query);
|
|
}
|
|
|
|
$url .= (str_contains($url, '?') ? '&' : '?') . 'telefono=' . urlencode($context['from']) . '&nombre=' . urlencode($context['name'] ?? '');
|
|
|
|
$ch = curl_init($url);
|
|
curl_setopt_array($ch, [
|
|
CURLOPT_RETURNTRANSFER => true,
|
|
CURLOPT_FOLLOWLOCATION => true,
|
|
CURLOPT_TIMEOUT => 60,
|
|
CURLOPT_HTTPHEADER => [
|
|
'X-API-Key: ' . $apiKey,
|
|
'User-Agent: bot-palmas360/1.0',
|
|
],
|
|
]);
|
|
$content = curl_exec($ch);
|
|
$httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
|
|
$contentType = curl_getinfo($ch, CURLINFO_CONTENT_TYPE);
|
|
$error = curl_error($ch);
|
|
curl_close($ch);
|
|
|
|
if ($error) {
|
|
self::log("API report error [{$endpoint}]: {$error}");
|
|
return self::sendText('Error al obtener el reporte. Intenta de nuevo.', $context['from'], $company);
|
|
}
|
|
|
|
if ($httpCode >= 400) {
|
|
self::log("API report HTTP {$httpCode} [{$endpoint}]: " . mb_substr($content, 0, 200));
|
|
return self::sendText('Error al obtener el reporte. Intenta de nuevo.', $context['from'], $company);
|
|
}
|
|
|
|
$mimeMap = [
|
|
'application/pdf' => ['pdf', 'pdf'],
|
|
'application/vnd.openxmlformats-officedocument.spreadsheetml.sheet' => ['xlsx', 'xlsx'],
|
|
'application/vnd.ms-excel' => ['xls', 'xls'],
|
|
'text/csv' => ['csv', 'csv'],
|
|
'application/vnd.oasis.opendocument.spreadsheet' => ['ods', 'ods'],
|
|
];
|
|
|
|
$ext = 'pdf';
|
|
$mime = 'application/pdf';
|
|
foreach ($mimeMap as $m => $info) {
|
|
if (str_starts_with($contentType ?? '', $m)) {
|
|
$ext = $info[0];
|
|
$mime = $info[1] ?? $m;
|
|
break;
|
|
}
|
|
}
|
|
|
|
$phoneNumberId = $company['phone_number_id'] ?? env('WHATSAPP_PHONE_NUMBER_ID', '');
|
|
if ($phoneNumberId === '') {
|
|
return self::sendText('Error: canal de envío no configurado.', $context['from'], $company);
|
|
}
|
|
|
|
$tmpFile = sys_get_temp_dir() . '/report_' . bin2hex(random_bytes(8)) . '.' . $ext;
|
|
file_put_contents($tmpFile, $content);
|
|
|
|
$upload = WhatsAppSender::uploadMedia($tmpFile, $mime, $phoneNumberId);
|
|
|
|
if (!$upload['success'] || !$upload['media_id']) {
|
|
self::log("API report upload failed [{$endpoint}]: " . ($upload['error'] ?? 'unknown'));
|
|
return self::sendText('Error al enviar el reporte. Intenta de nuevo.', $context['from'], $company);
|
|
}
|
|
|
|
$reportName = $params['filename'] ?? ('reporte.' . $ext);
|
|
$caption = $params['caption'] ?? 'Aquí tienes el reporte solicitado.';
|
|
|
|
$result = WhatsAppSender::sendDocument($context['from'], $upload['media_id'], $phoneNumberId, $caption, $reportName);
|
|
|
|
ConversationContext::reset($ctxId);
|
|
|
|
return null;
|
|
}
|
|
|
|
private static function buildMenuResponse(array $menu, string $to, array $company): array
|
|
{
|
|
$menuType = $menu['type'] ?? 'list';
|
|
|
|
if ($menuType === 'list') {
|
|
$interactive = [
|
|
'type' => 'list',
|
|
'header' => [
|
|
'type' => 'text',
|
|
'text' => mb_substr($menu['header'] ?? 'Menú', 0, 60),
|
|
],
|
|
'body' => [
|
|
'text' => mb_substr($menu['body'] ?? 'Selecciona una opción:', 0, 1024),
|
|
],
|
|
'footer' => [
|
|
'text' => mb_substr($menu['footer'] ?? $company['display_name'] ?? '', 0, 60),
|
|
],
|
|
'action' => [
|
|
'button' => mb_substr($menu['button'] ?? 'Ver opciones', 0, 20),
|
|
'sections' => [],
|
|
],
|
|
];
|
|
|
|
foreach ($menu['sections'] ?? [] as $section) {
|
|
$rows = [];
|
|
foreach ($section['rows'] ?? [] as $row) {
|
|
$rows[] = [
|
|
'id' => mb_substr($row['id'] ?? '', 0, 200),
|
|
'title' => mb_substr($row['title'] ?? '', 0, 24),
|
|
'description' => isset($row['description']) ? mb_substr($row['description'], 0, 72) : null,
|
|
];
|
|
}
|
|
$interactive['action']['sections'][] = [
|
|
'title' => mb_substr($section['title'] ?? '', 0, 24),
|
|
'rows' => $rows,
|
|
];
|
|
}
|
|
|
|
return self::enqueueInteractive($to, $interactive, $company);
|
|
}
|
|
|
|
if ($menuType === 'buttons') {
|
|
$buttons = [];
|
|
foreach ($menu['buttons'] ?? [] as $btn) {
|
|
$buttons[] = [
|
|
'type' => 'reply',
|
|
'reply' => [
|
|
'id' => mb_substr($btn['id'] ?? '', 0, 256),
|
|
'title' => mb_substr($btn['title'] ?? '', 0, 20),
|
|
],
|
|
];
|
|
}
|
|
|
|
$interactive = [
|
|
'type' => 'button',
|
|
'body' => [
|
|
'text' => mb_substr($menu['body'] ?? 'Selecciona:', 0, 1024),
|
|
],
|
|
'action' => ['buttons' => $buttons],
|
|
];
|
|
|
|
return self::enqueueInteractive($to, $interactive, $company);
|
|
}
|
|
|
|
return null;
|
|
}
|
|
|
|
private static function sendText(string $text, string $to, array $company): array
|
|
{
|
|
return [
|
|
'action' => 'send',
|
|
'type' => 'text',
|
|
'to' => $to,
|
|
'payload' => json_encode(['text' => $text]),
|
|
];
|
|
}
|
|
|
|
private static function sendImage(string $mediaId, ?string $caption, string $to, array $company): array
|
|
{
|
|
return [
|
|
'action' => 'send',
|
|
'type' => 'image',
|
|
'to' => $to,
|
|
'payload' => json_encode(['media_id' => $mediaId, 'caption' => $caption]),
|
|
];
|
|
}
|
|
|
|
private static function enqueueInteractive(string $to, array $interactive, array $company): array
|
|
{
|
|
return [
|
|
'action' => 'send',
|
|
'type' => 'interactive',
|
|
'to' => $to,
|
|
'payload' => json_encode(['interactive' => $interactive]),
|
|
];
|
|
}
|
|
|
|
private static function getConfig(array $company): array
|
|
{
|
|
$json = $company['config_json'] ?? '';
|
|
if ($json === '') {
|
|
return [];
|
|
}
|
|
$config = json_decode($json, true);
|
|
return is_array($config) ? $config : [];
|
|
}
|
|
|
|
private static function normalize(string $input): string
|
|
{
|
|
$input = mb_strtolower(trim($input));
|
|
$input = str_replace(['á', 'é', 'í', 'ó', 'ú', 'ü', 'ñ'], ['a', 'e', 'i', 'o', 'u', 'u', 'n'], $input);
|
|
return preg_replace('/[^a-z0-9\s]/', '', $input);
|
|
}
|
|
|
|
public static function processInteractive(array $company, array $context, string $input): ?array
|
|
{
|
|
$config = self::getConfig($company);
|
|
$flows = $config['flows'] ?? [];
|
|
|
|
$botCtx = ConversationContext::getOrCreate((int)$company['id'], $context['from'], 'normal');
|
|
$ctxId = (int)$botCtx['id'];
|
|
|
|
foreach ($flows as $flowId => $flow) {
|
|
if (($flow['type'] ?? '') === 'menu') {
|
|
$menu = self::resolveMenu($flow['menu'] ?? [], $company);
|
|
foreach ($menu['sections'] ?? [] as $section) {
|
|
foreach ($section['rows'] ?? [] as $row) {
|
|
if (($row['id'] ?? '') === $input) {
|
|
ConversationContext::updateNode($ctxId, $row['id']);
|
|
if (isset($flows[$row['id']])) {
|
|
return self::handleFlow($flows[$row['id']], $context, $company, $ctxId);
|
|
}
|
|
return null;
|
|
}
|
|
}
|
|
}
|
|
foreach ($menu['buttons'] ?? [] as $btn) {
|
|
if (($btn['id'] ?? '') === $input) {
|
|
ConversationContext::updateNode($ctxId, $btn['id']);
|
|
if (isset($flows[$btn['id']])) {
|
|
return self::handleFlow($flows[$btn['id']], $context, $company, $ctxId);
|
|
}
|
|
return null;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
return null;
|
|
}
|
|
}
|