bot_palmas/services/ErpMonitor.php

<?php
declare(strict_types=1);

class ErpMonitor
{
    public static function checkAll(): array
    {
        $companies = CompanyRepository::findAll();
        $results   = [];

        foreach ($companies as $company) {
            $results[] = self::check($company);
        }

        return $results;
    }

    public static function check(array $company): array
    {
        // El ERP no expone /health sino ?peticion=ping, y la URL sale de
        // company_endpoints como el resto de las llamadas: api_base_url no
        // sirve para esto. Sin esto el panel mostraba el ERP siempre caído.
        $apiKey    = $company['api_key'] ?? '';
        $healthUrl = '';
        try {
            $stmt = db()->prepare(
                "SELECT url FROM company_endpoints WHERE company_id = ? AND endpoint_key = ? AND is_active = 1 LIMIT 1"
            );
            $stmt->execute([(int)$company['id'], 'numeros_dn']);
            $url = (string)($stmt->fetchColumn() ?: '');
            if ($url !== '') {
                // Cualquier endpoint sirve de referencia; se reemplaza por ping
                $healthUrl = preg_replace('/peticion=[^&]*/', 'peticion=ping', $url);
            }
        } catch (\PDOException $e) {
            $healthUrl = '';
        }

        if ($healthUrl === '') {
            return [
                'company_id'   => (int)$company['id'],
                'company_name' => $company['name'] ?? '',
                'status'       => 'unknown',
                'latency_ms'   => null,
                'error'        => 'Sin endpoint registrado para esta empresa',
                'last_check'   => date('Y-m-d H:i:s'),
            ];
        }

        $start = microtime(true);

        $ch = curl_init($healthUrl);
        curl_setopt_array($ch, [
            CURLOPT_RETURNTRANSFER => true,
            CURLOPT_TIMEOUT        => 10,
            CURLOPT_CONNECTTIMEOUT => 5,
            CURLOPT_HTTPHEADER     => [
                'Authorization: Bearer ' . $apiKey,
                'X-API-Key: ' . $apiKey,
                'User-Agent: bot-palmas360-monitor/1.0',
            ],
        ]);

        $response = curl_exec($ch);
        $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
        $error    = curl_error($ch);
        curl_close($ch);

        $latency = (int)((microtime(true) - $start) * 1000);

        if ($error !== '') {
            return [
                'company_id'   => (int)$company['id'],
                'company_name' => $company['name'] ?? '',
                'status'       => 'down',
                'latency_ms'   => $latency,
                'error'        => $error,
                'last_check'   => date('Y-m-d H:i:s'),
            ];
        }

        if ($httpCode >= 200 && $httpCode < 400) {
            return [
                'company_id'   => (int)$company['id'],
                'company_name' => $company['name'] ?? '',
                'status'       => 'up',
                'latency_ms'   => $latency,
                'error'        => null,
                'last_check'   => date('Y-m-d H:i:s'),
            ];
        }

        return [
            'company_id'   => (int)$company['id'],
            'company_name' => $company['name'] ?? '',
            'status'       => 'degraded',
            'latency_ms'   => $latency,
            'error'        => "HTTP {$httpCode}",
            'last_check'   => date('Y-m-d H:i:s'),
        ];
    }

    public static function checkById(int $companyId): ?array
    {
        $company = CompanyRepository::findById($companyId);
        if ($company === null) return null;
        return self::check($company);
    }

    public static function summary(): array
    {
        $results = self::checkAll();
        $up      = 0;
        $down    = 0;
        $degraded = 0;
        $unknown = 0;

        foreach ($results as $r) {
            match ($r['status']) {
                'up'       => $up++,
                'down'     => $down++,
                'degraded' => $degraded++,
                default    => $unknown++,
            };
        }

        return [
            'total'    => count($results),
            'up'       => $up,
            'down'     => $down,
            'degraded' => $degraded,
            'unknown'  => $unknown,
            'results'  => $results,
        ];
    }
}