CmtsBundle/Command/CmtsInterfaceStatsCommand.php

<?php

namespace CmtsBundle\Command;

use BaseStatsBundle\Command\BaseCmtsCommand;
use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;
use CmtsBundle\SNMP\SNMP as SNMP;
use Symfony\Component\Yaml\Parser;

class CmtsInterfaceStatsCommand extends BaseCmtsCommand
{

    protected function configure()
    {
        $this
            ->setName('cmts:interface:stats')
            ->setDescription('Obtener Stats de Interfaces')
            ->setHelp('Se requieren parámetros para poder realizar la correcta consulta. El comando requiere Redis.')
            ->setDefinition(array(
                new InputOption('cmts-device-id', null, InputOption::VALUE_OPTIONAL, "DeviceId del CMTS",1),
                new InputOption('cmts-server-id', null, InputOption::VALUE_OPTIONAL, "ServerDevice del CMTS",1),
                new InputOption('cmts-ip', false, InputOption::VALUE_OPTIONAL, "IP del CMTS"),
                new InputOption('cmts-community', false, InputOption::VALUE_OPTIONAL, "Community del CMTS"),
                new InputOption('cmts-snmp-library', false, InputOption::VALUE_OPTIONAL, "Versión de librería SNMP")
            ))
        ;
    }

    /**
     * @param InputInterface $input
     * @param OutputInterface $output
     */
    protected function execute(InputInterface $input, OutputInterface $output)
    {
        parent::execute($input, $output);
        
        $key_cmts_scan = "cmts_scan_ifs_{$this->d_s}";
        $key_cm_scan = "cmts_scan_{$this->d_s}";
        $inicio = microtime(true);
        
        $SNMP = new SNMP($this->cmtsIp, $this->cmtsCommunity);
        $library = "use".$this->cmtsSnmpLibrary;
        $this->apiSNMP = $SNMP->$library();

        $dataCached = $this->getData($key_cmts_scan, true);
        
        if(empty($dataCached)) {
            $this->output->writeln("Se requiere {$key_cmts_scan}.");
            $this->removeLock($this->flag);
            return true;
        }
        
        
        $_utilization = $this->getSNMP("docsIfCmtsChannelUtilization","cmtsIfUtilization");
        $utilization = array();

        foreach($_utilization as $compIndex => $value) {
            $params = explode(".",$compIndex);
            if($params > 1) {
                $index = $params[0];
                $aux = implode(".", array_slice($params,1));
            } else {
                $index = $compIndex;
                $aux = 0;
            }

            $utilization[$index] = array($aux => $value);
        }

        $microreflection = $this->getSNMP("docsIfSigQMicroreflections","cmtsIfMicroreflection");
        $signal = $this->getSNMP("docsIfSigQSignalNoise","cmtsIfSignal");

        
        print_r($utilization);
        print_r($microreflection);
        print_r($signal);


        $cmCached = $this->getData($key_cm_scan, true);
        $states = array();
        if(empty($cmCached)) {
            $this->output->writeln("Se requiere {$key_cm_scan} para obtener cantidad de CM por Interface.");
        } else {
            foreach($cmCached as $index => $value) {
                $up = $value['upInterface'];
                $down = $value['downInterface'];
                $state = $value['status'];

                if(!isset($states[$up])) $states[$up] = array(0 => 0, 1 => 0);
                if(!isset($states[$down])) $states[$down] = array(0 => 0, 1 => 0);

                $states[$up][$state]++;
                $states[$down][$state]++;
            }
        }

        $ifStatsCached = $sendData = array();

        $subId = $this->d_s;
        $metrics = array("utilization" => "{$subId}_if_utilization_", "microreflection" => "{$subId}_if_microreflection_", "signal" => "{$subId}_if_signal_", "states" => "{$subId}_if_state_");

        foreach($dataCached as $index => $interface) {
            
            $stats = array();
            
            foreach($metrics as $data => $metric) {

                if(!isset($$data[$index])) continue;

                $m = "{$metric}{$index}";

                if($data == "signal") {
                    $v = $$data[$index] * 0.1;
                    $sendData[$m] = "{$v}|g";
                } elseif($data == "utilization") {
                    foreach($$data[$index] as $aux => $v) {
                        $sendData["{$m}.{$aux}"] = "{$v}|g";
                    }
                    $v = $$data[$index];
                } elseif($data == "states") {
                    $v = $$data[$index];
                    $on = "{$subId}_if_state_on_{$index}";
                    $off = "{$subId}_if_state_off_{$index}";
                    
                    $sendData[$on] = "{$v[1]}|g";
                    $sendData[$off] = "{$v[0]}|g";
                } else {
                    $v = $$data[$index];
                }
                
                $stats[$data] = $v;
            }
            $ifStatsCached[$index] = $stats;
        }

        print_r($ifStatsCached);
        print_r($sendData);

        die;

        $dataCached = array();
        $countIfs = 0;

        $interfaces = $this->getSNMP("docsIfDescription","cmtsIf");
        
        

        $this->setData($key_cmts_scan, $dataCached, true);

        /* Fin de bloqueo */
        $this->removeLock($this->flag);

        $fin = microtime(true);
        $time = $fin - $inicio;
        $this->output->writeln("Tiempo: $time segundos / Cantidad Interfaces: {$countIfs}");
    }

}