FD3-235 Se agrega opción para enviar datos al StatsD.

Command/HuaweiOnuCatvRxCommand.php

@@ -23,7 +23,8 @@ class HuaweiOnuCatvRxCommand extends BaseCommand
                 new InputOption('olt-server-id', null, InputOption::VALUE_OPTIONAL, "ServerDevice de la OLT",1),
                 new InputOption('olt-ip', false, InputOption::VALUE_OPTIONAL, "IP de la OLT"),
                 new InputOption('olt-community', false, InputOption::VALUE_OPTIONAL, "COMMUNITY de la OLT"),
-                new InputOption('olt-snmp-library', false, InputOption::VALUE_OPTIONAL, "Versión de librería SNMP")
+                new InputOption('olt-snmp-library', false, InputOption::VALUE_OPTIONAL, "Versión de librería SNMP"),
+                new InputOption('save-historic', null, InputOption::VALUE_OPTIONAL, "Send data to StatsD",1)
             ))
         ;
     }
@@ -46,6 +47,7 @@ class HuaweiOnuCatvRxCommand extends BaseCommand
         $oltIp = $input->getOption('olt-ip');
         $oltCommunity = $input->getOption('olt-community');
         $oltSnmpLibrary = $input->getOption('olt-snmp-library');
+        $saveHistoric = (int) $input->getOption('save-historic');
         
         $flag = "olt_onus_catvrx_d_{$oltDeviceId}_s_{$oltServerId}.lock";
         $key_olt_scan = "olt_scan_d_{$oltDeviceId}_s_{$oltServerId}";
@@ -87,7 +89,7 @@ class HuaweiOnuCatvRxCommand extends BaseCommand
 
         $this->setData($key_onu_rx, $rxCached, true);
 
-        if($sendData) {
+        if($sendData && $saveHistoric) {
             $t_start_script = microtime(true); 
             $statsdService = $this->getContainer()->get('statsd');
             $statsdService->send($sendData);

Command/HuaweiOnuRxCommand.php

@@ -23,7 +23,8 @@ class HuaweiOnuRxCommand extends BaseCommand
                 new InputOption('olt-server-id', null, InputOption::VALUE_OPTIONAL, "ServerDevice de la OLT",1),
                 new InputOption('olt-ip', false, InputOption::VALUE_OPTIONAL, "IP de la OLT"),
                 new InputOption('olt-community', false, InputOption::VALUE_OPTIONAL, "COMMUNITY de la OLT"),
-                new InputOption('olt-snmp-library', false, InputOption::VALUE_OPTIONAL, "Versión de librería SNMP")
+                new InputOption('olt-snmp-library', false, InputOption::VALUE_OPTIONAL, "Versión de librería SNMP"),
+                new InputOption('save-historic', null, InputOption::VALUE_OPTIONAL, "Send data to StatsD",1)
             ))
         ;
     }
@@ -46,6 +47,7 @@ class HuaweiOnuRxCommand extends BaseCommand
         $oltIp = $input->getOption('olt-ip');
         $oltCommunity = $input->getOption('olt-community');
         $oltSnmpLibrary = $input->getOption('olt-snmp-library');
+        $saveHistoric = (int) $input->getOption('save-historic');
         
         $flag = "olt_onus_rx_d_{$oltDeviceId}_s_{$oltServerId}.lock";
         $key_olt_scan = "olt_scan_d_{$oltDeviceId}_s_{$oltServerId}";
@@ -87,7 +89,7 @@ class HuaweiOnuRxCommand extends BaseCommand
 
         $this->setData($key_onu_rx, $rxCached, true);
 
-        if($sendData) {
+        if($sendData && $saveHistoric) {
             $t_start_script = microtime(true); 
             $statsdService = $this->getContainer()->get('statsd');
             $statsdService->send($sendData);

Command/HuaweiOnuStatsCommand.php

@@ -23,7 +23,8 @@ class HuaweiOnuStatsCommand extends BaseCommand
                 new InputOption('olt-server-id', null, InputOption::VALUE_OPTIONAL, "ServerDevice de la OLT",1),
                 new InputOption('olt-ip', false, InputOption::VALUE_OPTIONAL, "IP de la OLT"),
                 new InputOption('olt-community', false, InputOption::VALUE_OPTIONAL, "COMMUNITY de la OLT"),
-                new InputOption('olt-snmp-library', false, InputOption::VALUE_OPTIONAL, "Versión de librería SNMP")
+                new InputOption('olt-snmp-library', false, InputOption::VALUE_OPTIONAL, "Versión de librería SNMP"),
+                new InputOption('save-historic', null, InputOption::VALUE_OPTIONAL, "Send data to StatsD",1)
             ))
         ;
     }
@@ -45,6 +46,7 @@ class HuaweiOnuStatsCommand extends BaseCommand
         $oltIp = $input->getOption('olt-ip');
         $oltCommunity = $input->getOption('olt-community');
         $oltSnmpLibrary = $input->getOption('olt-snmp-library');
+        $saveHistoric = (int) $input->getOption('save-historic');
         
         $flag = "olt_onu_stats_d_{$oltDeviceId}_s_{$oltServerId}.lock";
         $key_olt_scan = "olt_scan_d_{$oltDeviceId}_s_{$oltServerId}";
@@ -112,7 +114,7 @@ class HuaweiOnuStatsCommand extends BaseCommand
             $this->setData($key_onu_stats, $data, true);
         }
         
-        if($sendData) {
+        if($sendData && $saveHistoric) {
             $t_start_script = microtime(true); 
             $statsdService = $this->getContainer()->get('statsd');
             $statsdService->send($sendData);

Command/HuaweiOnuStatusCommand.php

@@ -23,7 +23,8 @@ class HuaweiOnuStatusCommand extends BaseCommand
                 new InputOption('olt-server-id', null, InputOption::VALUE_OPTIONAL, "ServerDevice de la OLT",1),
                 new InputOption('olt-ip', false, InputOption::VALUE_OPTIONAL, "IP de la OLT"),
                 new InputOption('olt-community', false, InputOption::VALUE_OPTIONAL, "COMMUNITY de la OLT"),
-                new InputOption('olt-snmp-library', false, InputOption::VALUE_OPTIONAL, "Versión de librería SNMP")
+                new InputOption('olt-snmp-library', false, InputOption::VALUE_OPTIONAL, "Versión de librería SNMP"),
+                new InputOption('save-historic', null, InputOption::VALUE_OPTIONAL, "Send data to StatsD",1)
             ))
         ;
     }
@@ -46,6 +47,7 @@ class HuaweiOnuStatusCommand extends BaseCommand
         $oltIp = $input->getOption('olt-ip');
         $oltCommunity = $input->getOption('olt-community');
         $oltSnmpLibrary = $input->getOption('olt-snmp-library');
+        $saveHistoric = (int) $input->getOption('save-historic');
         
         $flag = "olt_onus_status_d_{$oltDeviceId}_s_{$oltServerId}.lock";
         $key_olt_scan = "olt_scan_d_{$oltDeviceId}_s_{$oltServerId}";
@@ -87,7 +89,7 @@ class HuaweiOnuStatusCommand extends BaseCommand
 
         $this->setData($key_onu_status, $statusCached, true);
 
-        if($sendData) {
+        if($sendData && $saveHistoric) {
             $t_start_script = microtime(true); 
             $statsdService = $this->getContainer()->get('statsd');
             $statsdService->send($sendData);

Command/HuaweiOnuTemperatureCommand.php

@@ -23,7 +23,8 @@ class HuaweiOnuTemperatureCommand extends BaseCommand
                 new InputOption('olt-server-id', null, InputOption::VALUE_OPTIONAL, "ServerDevice de la OLT",1),
                 new InputOption('olt-ip', false, InputOption::VALUE_OPTIONAL, "IP de la OLT"),
                 new InputOption('olt-community', false, InputOption::VALUE_OPTIONAL, "COMMUNITY de la OLT"),
-                new InputOption('olt-snmp-library', false, InputOption::VALUE_OPTIONAL, "Versión de librería SNMP")
+                new InputOption('olt-snmp-library', false, InputOption::VALUE_OPTIONAL, "Versión de librería SNMP"),
+                new InputOption('save-historic', null, InputOption::VALUE_OPTIONAL, "Send data to StatsD",1)
             ))
         ;
     }
@@ -46,6 +47,7 @@ class HuaweiOnuTemperatureCommand extends BaseCommand
         $oltIp = $input->getOption('olt-ip');
         $oltCommunity = $input->getOption('olt-community');
         $oltSnmpLibrary = $input->getOption('olt-snmp-library');
+        $saveHistoric = (int) $input->getOption('save-historic');
         
         $flag = "olt_onus_temperature_d_{$oltDeviceId}_s_{$oltServerId}.lock";
         $key_olt_scan = "olt_scan_d_{$oltDeviceId}_s_{$oltServerId}";
@@ -87,7 +89,7 @@ class HuaweiOnuTemperatureCommand extends BaseCommand
 
         $this->setData($key_onu_temperature, $temperatureCached, true);
 
-        if($sendData) {
+        if($sendData && $saveHistoric) {
             $t_start_script = microtime(true); 
             $statsdService = $this->getContainer()->get('statsd');
             $statsdService->send($sendData);

Command/HuaweiOnuTxCommand.php

@@ -23,7 +23,8 @@ class HuaweiOnuTxCommand extends BaseCommand
                 new InputOption('olt-server-id', null, InputOption::VALUE_OPTIONAL, "ServerDevice de la OLT",1),
                 new InputOption('olt-ip', false, InputOption::VALUE_OPTIONAL, "IP de la OLT"),
                 new InputOption('olt-community', false, InputOption::VALUE_OPTIONAL, "COMMUNITY de la OLT"),
-                new InputOption('olt-snmp-library', false, InputOption::VALUE_OPTIONAL, "Versión de librería SNMP")
+                new InputOption('olt-snmp-library', false, InputOption::VALUE_OPTIONAL, "Versión de librería SNMP"),
+                new InputOption('save-historic', null, InputOption::VALUE_OPTIONAL, "Send data to StatsD",1)
             ))
         ;
     }
@@ -46,6 +47,7 @@ class HuaweiOnuTxCommand extends BaseCommand
         $oltIp = $input->getOption('olt-ip');
         $oltCommunity = $input->getOption('olt-community');
         $oltSnmpLibrary = $input->getOption('olt-snmp-library');
+        $saveHistoric = (int) $input->getOption('save-historic');
         
         $flag = "olt_onus_tx_d_{$oltDeviceId}_s_{$oltServerId}.lock";
         $key_olt_scan = "olt_scan_d_{$oltDeviceId}_s_{$oltServerId}";
@@ -87,7 +89,7 @@ class HuaweiOnuTxCommand extends BaseCommand
 
         $this->setData($key_onu_tx, $txCached, true);
 
-        if($sendData) {
+        if($sendData && $saveHistoric) {
             $t_start_script = microtime(true); 
             $statsdService = $this->getContainer()->get('statsd');
             $statsdService->send($sendData);

Command/HuaweiOnuVoltageCommand.php

@@ -23,7 +23,8 @@ class HuaweiOnuVoltageCommand extends BaseCommand
                 new InputOption('olt-server-id', null, InputOption::VALUE_OPTIONAL, "ServerDevice de la OLT",1),
                 new InputOption('olt-ip', false, InputOption::VALUE_OPTIONAL, "IP de la OLT"),
                 new InputOption('olt-community', false, InputOption::VALUE_OPTIONAL, "COMMUNITY de la OLT"),
-                new InputOption('olt-snmp-library', false, InputOption::VALUE_OPTIONAL, "Versión de librería SNMP")
+                new InputOption('olt-snmp-library', false, InputOption::VALUE_OPTIONAL, "Versión de librería SNMP"),
+                new InputOption('save-historic', null, InputOption::VALUE_OPTIONAL, "Send data to StatsD",1)
             ))
         ;
     }
@@ -46,6 +47,7 @@ class HuaweiOnuVoltageCommand extends BaseCommand
         $oltIp = $input->getOption('olt-ip');
         $oltCommunity = $input->getOption('olt-community');
         $oltSnmpLibrary = $input->getOption('olt-snmp-library');
+        $saveHistoric = (int) $input->getOption('save-historic');
         
         $flag = "olt_onus_voltage_d_{$oltDeviceId}_s_{$oltServerId}.lock";
         $key_olt_scan = "olt_scan_d_{$oltDeviceId}_s_{$oltServerId}";
@@ -87,7 +89,7 @@ class HuaweiOnuVoltageCommand extends BaseCommand
 
         $this->setData($key_onu_voltage, $voltageCached, true);
 
-        if($sendData) {
+        if($sendData && $saveHistoric) {
             $t_start_script = microtime(true); 
             $statsdService = $this->getContainer()->get('statsd');
             $statsdService->send($sendData);

Command/HuaweiPonOctetsCommand.php

@@ -23,7 +23,8 @@ class HuaweiPonOctetsCommand extends BaseCommand
                 new InputOption('olt-server-id', null, InputOption::VALUE_OPTIONAL, "ServerDevice de la OLT",1),
                 new InputOption('olt-ip', false, InputOption::VALUE_OPTIONAL, "IP de la OLT"),
                 new InputOption('olt-community', false, InputOption::VALUE_OPTIONAL, "COMMUNITY de la OLT"),
-                new InputOption('olt-snmp-library', false, InputOption::VALUE_OPTIONAL, "Versión de librería SNMP")
+                new InputOption('olt-snmp-library', false, InputOption::VALUE_OPTIONAL, "Versión de librería SNMP"),
+                new InputOption('save-historic', null, InputOption::VALUE_OPTIONAL, "Send data to StatsD",1)
             ))
         ;
     }
@@ -45,6 +46,7 @@ class HuaweiPonOctetsCommand extends BaseCommand
         $oltIp = $input->getOption('olt-ip');
         $oltCommunity = $input->getOption('olt-community');
         $oltSnmpLibrary = $input->getOption('olt-snmp-library');
+        $saveHistoric = (int) $input->getOption('save-historic');
         
         $flag = "olt_pon_octets_d_{$oltDeviceId}_s_{$oltServerId}.lock";
         $key_olt_scan = "olt_scan_pons_d_{$oltDeviceId}_s_{$oltServerId}";
@@ -118,7 +120,7 @@ class HuaweiPonOctetsCommand extends BaseCommand
 
         $this->setData($key_olt_pon_bandwidth, $bandwidthCached, true);
 
-        if($sendData) {
+        if($sendData && $saveHistoric) {
             $t_start_script = microtime(true); 
             $statsdService = $this->getContainer()->get('statsd');
             $statsdService->send($sendData);

Command/HuaweiPonStatsCommand.php

@@ -23,7 +23,8 @@ class HuaweiPonStatsCommand extends BaseCommand
                 new InputOption('olt-server-id', null, InputOption::VALUE_OPTIONAL, "ServerDevice de la OLT",1),
                 new InputOption('olt-ip', false, InputOption::VALUE_OPTIONAL, "IP de la OLT"),
                 new InputOption('olt-community', false, InputOption::VALUE_OPTIONAL, "COMMUNITY de la OLT"),
-                new InputOption('olt-snmp-library', false, InputOption::VALUE_OPTIONAL, "Versión de librería SNMP")
+                new InputOption('olt-snmp-library', false, InputOption::VALUE_OPTIONAL, "Versión de librería SNMP"),
+                new InputOption('save-historic', null, InputOption::VALUE_OPTIONAL, "Send data to StatsD",1)
             ))
         ;
     }
@@ -45,6 +46,7 @@ class HuaweiPonStatsCommand extends BaseCommand
         $oltIp = $input->getOption('olt-ip');
         $oltCommunity = $input->getOption('olt-community');
         $oltSnmpLibrary = $input->getOption('olt-snmp-library');
+        $saveHistoric = (int) $input->getOption('save-historic');
         
         $flag = "olt_pon_stats_d_{$oltDeviceId}_s_{$oltServerId}.lock";
         $key_olt_scan = "olt_scan_pons_d_{$oltDeviceId}_s_{$oltServerId}";
@@ -136,7 +138,7 @@ class HuaweiPonStatsCommand extends BaseCommand
             $this->setData($key_pon_stats, $ponStatsCached, true);
         }
 
-        if($sendData) {
+        if($sendData && $saveHistoric) {
             $t_start_script = microtime(true); 
             $statsdService = $this->getContainer()->get('statsd');
             $statsdService->send($sendData);