");
        print_r($data);
        print_r($sum.PHP_EOL);
        print_r($total.PHP_EOL);
        print_r($totalIn.PHP_EOL);
        print_r($totalOut.PHP_EOL);
        die; */
        
        return $this->render('StatsBundle:Device:Report/ponBandwidth.html.twig', array(
            'data'  => $data,
            'sum'   => $sum,
            'total' => $total,
            'totalIn'   => $totalIn,
            'totalOut'   => $totalOut,
            'restPercent'   => $restPercent
        ));
    }

    public function oltConsumptionAction($oltServerId, $oltDeviceId) {
        
        $subName = "d_{$oltDeviceId}_s_{$oltServerId}";

        $result = $targets = array();
        $endpoint = $this->get('endpoint.mysql');

        $targets["in_consumption"] = array("target" => "{$subName}_inconsumption_olt");
        $targets["out_consumption"] = array("target" => "{$subName}_outconsumption_olt");
        $errors = array();

        foreach($targets as $index => $t) {
            $search = array('targets' => array(0 => $t), 'maxDataPoints' => 50);
            try {
                $data = $endpoint->get(json_encode($search),'last', true);
            } catch(\Exception $e) {
                $errors[] = array("msg" => "Falla mysql_json_endpoint({$index}): {$e->getMessage()}");
                $data = array();
            }
            
            if(isset($data[0]) && isset($data[0]['datapoints'])) {
                $points = $data[0]['datapoints']; krsort($points);
                $result[$index] = $points;
            } else {
                $result[$index] = array();
            }
        }
        
        if($errors) {$this->logReport($oltDeviceId, $oltServerId, $errors);}

        return $this->render('StatsBundle:Device:Report/oltConsumption.html.twig', array(
            'inCons' => $result['in_consumption'],
            'outCons' => $result['out_consumption']
        ));
    }

    private function logReport($deviceId, $serverId, $errors) {
        $em = $this->get('doctrine')->getManager();
        $device = $em->getRepository('\StatsBundle\Entity\Device')->findOneBy(array('deviceServer' => $serverId, 'deviceType' => 'FTTHBundle\Entity\OLT', 'deviceId' => $deviceId));
        if($device) {
            $tenancyId = $device->getTenancyId();
            $reportManager = $this->get('stats.report.manager');

            foreach($errors as $error) {
                $reportManager->create("FTTHBundle\Entity\OLT", "MYSQL_ENDPOINT_ERROR", $deviceId, $serverId, $tenancyId, $error);
            }
        }
    }

    public function oltReportAction($oltServerId, $oltDeviceId) {
        
        $em = $this->get('doctrine')->getManager();
        
        $reports = $em->getRepository('StatsBundle:Report')->createQueryBuilder('r')
            ->select('r')
            ->where('r.deviceServer = :oltServerId')
            ->andWhere('r.deviceId = :oltDeviceId')
            ->andWhere('r.deviceType = :deviceType')
            ->andWhere('r.created >= :created')
            ->setParameter('oltServerId', $oltServerId)
            ->setParameter('oltDeviceId', $oltDeviceId)
            ->setParameter('deviceType', 'FTTHBundle\Entity\OLT')
            ->setParameter('created', date("Y-m-d 00:00:00",strtotime("-5 days")))
            ->orderBy('r.id', 'DESC')
            ->getQuery()->getResult();

        $results = array();
        foreach($reports as $report) {
            $row = array();
            $row['type'] = $report->getReportType();
            $row['time'] = $report->getCreated()->format('Y-m-d H:i:s');
            $aux = json_decode($report->getExtraData(),true);
            if(isset($aux['msg'])) {
                $row['msg'] = $aux['msg'];
            } else {
                continue;
            }
            $results[] = $row;
        }


        return $this->render('StatsBundle:Device:Report/reportList.html.twig', array(
            'results' => $results
        ));
    }

    public function onuSignalAction($oltServerId, $oltDeviceId) {
        
        $em = $this->get('doctrine')->getManager();
        $onus = $em->getRepository('StatsBundle:Onu')->createQueryBuilder('o')
            ->select('o.txPower','o.rxPowerOlt', 'o.ponSerialNumber')
            ->where('o.deviceServer = :oltServerId')
            ->andWhere('o.oltDeviceId = :oltDeviceId')
            ->setParameter('oltServerId', $oltServerId)
            ->setParameter('oltDeviceId', $oltDeviceId)
            ->getQuery()->getResult();
        
        $colors = $signals = array();

        foreach($onus as $data) {
            if($data['txPower'] == null || $data['rxPowerOlt'] == null) continue;

            $color = $this->getRxColor($data['rxPowerOlt']);

            if(!isset($signals[$color])) $signals[$color] = array();

            $signals[$color][] = array('x' => $data['txPower'],'y' => $data['rxPowerOlt'], 'extraData' => $data['ponSerialNumber'], 'id' => "{$data['ponSerialNumber']}~{$oltDeviceId}~{$oltServerId}");
            
            //$colors[] = $this->getRxColor($data['rxPowerOlt']);
        }
        $_signals = array();
        foreach($signals as $color => $points) {
            $_signals[$color] = json_encode($points);
        }


        return $this->render('StatsBundle:Device:Report/onuSignal.html.twig', array(
            'signals' => $_signals
        ));
    }

    private function getRxColor($value) {


        if($value < -30)
            return "#a00400"; //bordó
        elseif($value >= -30 and $value < -28)
            return "#ff4d3f"; //rojo
        elseif($value >= -28 and $value < -26)
            return "#ffa732"; //amarillo
        elseif($value >= -26 and $value < -20)
            return "#00a65a"; //verde
        elseif($value >= -20 and $value < -15)
            return "#ffa732"; //amarillo
        elseif($value >= -15 and $value < -13)
            return "#ff4d3f"; //rojo
        else
            return "#a00400"; //bordó
    }
    
}