Ubilling/api/libs/api.ponzte.php

<?php

/**
 * ZTE-like PON devices management
 */
class PonZte {

    const DESC_PONTYPE = 1;
    const DESC_SHELF = 2;
    const DESC_SLOT = 3;
    const DESC_OLT = 4;
    const DESC_ONU = 5;

    /**
     * Contains current HAL instance OLT parameters
     *
     * @var array
     */
    protected $oltParameters = array();

    /**
     * Array for checking ports count for EPON cards
     * 
     * @var array
     */
    protected $eponCards = array();

    /**
     * Array for checking ports count for GPON cards
     * 
     * @var array
     */
    protected $gponCards = array();

    /**
     * Contains snmp helper object
     * 
     * @var object
     */
    protected $snmp;

    /**
     * Contains OLTData
     *
     * @var object
     */
    protected $olt = '';

    /**
     * Contains all OLTs snmp tmplates
     * 
     * @var array
     */
    protected $snmpTemplates = array();

    /**
     * Contains all OLTs devices with proper snmp config
     * 
     * @var array
     */
    protected $allOltSnmp = array();

    /**
     * Contains all olt models
     * 
     * @var array
     */
    protected $allOltModels = array();

    /**
     * Contains all OLTs devices
     * 
     * @var array
     */
    protected $allOltDevices = array();

    /**
     * Current OLT switch id
     * 
     * @var int
     */
    protected $oltid = 0;

    /**
     * Current OLT IP with SNMP port
     * 
     * @var string
     */
    protected $oltIp = '';

    /**
     * Current OLT IP with SNMP port
     * 
     * @var string
     */
    protected $oltFullAddress = '';

    /**
     * Current OLT snmp community
     * 
     * @var string
     */
    protected $oltCommunity = '';

    /**
     * Take only needed SNMP template for current OLT.
     * 
     * @var array
     */
    protected $currentSnmpTemplate;

    /**
     * Contains all ONUs MAC addresses.
     * 
     * @var array
     */
    protected $macIndex = array();

    /**
     * Contains all signals
     * 
     * @var array
     */
    protected $sigIndex = array();

    /**
     * Contains all interface names => ONU ID
     * 
     * @var array
     */
    protected $intIndex = array();

    /**
     * Contains FDB
     * 
     * @var array
     */
    protected $fdbIndex = array();

    /**
     * Contains type EPON or GPON.
     * 
     * @var string
     */
    public $ponType = '';

    /**
     * Contains all serial numbers => index
     * 
     * @var array
     */
    protected $snIndex = array();

    /**
     * Contains distances for ONTs
     * 
     * @var array
     */
    protected $distanceIndex = array();

    /**
     * Creates new PON poller/parser proto
     * 
     * @param array $oltParameters
     * @param array $snmpTemplates
     */
    public function __construct($oltParameters, $snmpTemplates) {
        $this->oltParameters = $oltParameters;

        //unpacking OLT settings
        $oltModelId = $this->oltParameters['MODELID'];
        $oltid = $this->oltParameters['ID'];
        $oltIp = $this->oltParameters['IP'];
        $oltCommunity = $this->oltParameters['COMMUNITY'];
        $oltNoFDBQ = $this->oltParameters['NOFDB'];
        $ponType = $this->oltParameters['TYPE'];

        //setting some object properties
        $this->oltid = $oltid;
        $this->oltCommunity = $oltCommunity;
        $this->oltIp = $oltIp;
        $this->oltFullAddress = $oltIp . ':' . PONizer::SNMPPORT;
        $this->ponType = $ponType;

        $this->initSNMP();
        $this->initOltAttractor();
        $this->loadOltDevices();
        $this->loadOltModels();
        $this->snmpTemplates = $snmpTemplates;
        $this->currentSnmpTemplate = $this->snmpTemplates[$oltModelId];
        $this->eponCards = OnuRegister::allEponCards();
        $this->gponCards = OnuRegister::allGponCards();
        if (!isset($this->currentSnmpTemplate['signal']['POLLTYPE'])) {
            $this->currentSnmpTemplate['signal']['POLLTYPE'] = 'default';
        }
        if (!isset($this->currentSnmpTemplate['signal']['SIGNALTYPE'])) {
            $this->currentSnmpTemplate['signal']['SIGNALTYPE'] = 'OLTRX';
        }
    }

    /**
     * Creates single instance of SNMPHelper object
     * 
     * @return void
     */
    protected function initSNMP() {
        $this->snmp = new SNMPHelper();
    }

    /**
     * Inits current OLT data abstraction layer for further usage
     */
    protected function initOltAttractor() {
        $this->olt = new OLTAttractor($this->oltParameters['ID']);
    }

    /**
     * Loads all available snmp models data into private data property
     * 
     * @return void
     */
    protected function loadOltModels() {
        $rawModels = zb_SwitchModelsGetAll();
        if (!empty($rawModels)) {
            foreach ($rawModels as $io => $each) {
                $this->allOltModels[$each['id']]['modelname'] = $each['modelname'];
                $this->allOltModels[$each['id']]['snmptemplate'] = $each['snmptemplate'];
                $this->allOltModels[$each['id']]['ports'] = $each['ports'];
            }
        }
    }

    /**
     * Loads all available devices set as OLT
     * 
     * @return void
     */
    protected function loadOltDevices() {
        $query = "SELECT `id`,`ip`,`location`,`snmp`,`modelid` from `switches` WHERE `desc` LIKE '%OLT%';";
        $raw = simple_queryall($query);
        if (!empty($raw)) {
            foreach ($raw as $io => $each) {
                $this->allOltDevices[$each['id']] = $each['ip'] . ' - ' . $each['location'];
                if (!empty($each['snmp'])) {
                    $this->allOltSnmp[$each['id']]['community'] = $each['snmp'];
                    $this->allOltSnmp[$each['id']]['modelid'] = $each['modelid'];
                    $this->allOltSnmp[$each['id']]['ip'] = $each['ip'];
                }
            }
        }
    }

    //wrappers

    /**
     * Wrapper around $this->snmp->walk method and explodeRows function to get less string length.
     * 
     * @param string $oid
     * 
     * @return array
     */
    protected function snmpwalk($oid) {
        $data = $this->snmp->walk($this->oltFullAddress, $this->oltCommunity, $oid, PONizer::SNMPCACHE);
        return (explodeRows(trim($data)));
    }

    /**
     * Converts hex to string value
     *
     * @param string $hex
     * @return string
     */
    protected function hexToString($hex) {
        return pack('H*', $hex);
    }

    /**
     * Remove oid + dot from string
     * 
     * @param string $oid
     * @param string $str
     * 
     * @return string
     */
    protected function strRemoveOidWithDot($oid, $str) {
        return (trim(str_replace($oid . ".", '', $str)));
    }

    /**
     * Wrapper around str_replace to make code more pretty
     * 
     * @param string $search
     * @param string $str
     * 
     * @return string 
     */
    protected function strRemove($search, $str) {
        return (trim(str_replace($search, '', $str)));
    }

    //processing functions

    /**
     * Epon signals preprocessing
     * 
     * @return array
     */
    protected function signalIndexProcessing() {
        foreach ($this->sigIndex as $devIndex => &$eachsig) {
            if ($eachsig == $this->currentSnmpTemplate['signal']['DOWNVALUE']) {
                $eachsig = 'Offline';
            }
            if (isset($this->currentSnmpTemplate['signal']['DOWNVALUE2'])) {
                if ($eachsig == $this->currentSnmpTemplate['signal']['DOWNVALUE2']) {
                    $eachsig = 'Offline';
                }
            }
            if (isset($this->currentSnmpTemplate['signal']['DOWNVALUE3'])) {
                if ($eachsig == $this->currentSnmpTemplate['signal']['DOWNVALUE3']) {
                    $eachsig = 'Offline';
                }
            }
            if ($eachsig != 'Offline') {
                $eachsig = str_replace('"', '', $eachsig);
                if ($this->currentSnmpTemplate['signal']['OFFSETMODE'] == 'div') {
                    if ($this->currentSnmpTemplate['signal']['OFFSET']) {
                        $div = $this->currentSnmpTemplate['signal']['OFFSET'];
                        if ($this->currentSnmpTemplate['signal']['SIGNALTYPE'] == 'ONURX') {
                            $div = $this->currentSnmpTemplate['signal']['ONURXOFFSET'];
                            $exploDevIndex = explode('.', $devIndex);
                            $devIndex = $exploDevIndex[0] . "." . $exploDevIndex[1];
                            $this->sigIndex[$devIndex] = $eachsig / $div;
                        }
                        $eachsig = $eachsig / $div;
                    }
                }
            }
        }
    }

    /**
     * Epon mac indexes preprocessing
     * 
     * @return array
     */
    protected function macIndexEponProcessing() {
        foreach ($this->macIndex as $devIndex => &$eachmac) {
            $eachmac = str_replace(' ', ':', $eachmac);
            $eachmac = strtolower($eachmac);
        }
    }

    /**
     * Serial number indexes preprocessing.
     * 
     * @return void
     */
    protected function serialIndexGponProcessing() {
        foreach ($this->snIndex as $devIndex => &$eachSn) {
            $eachSn = str_replace(' ', ':', $eachSn);
            $eachSn = strtoupper($eachSn);
        }
    }

    /**
     * Coverts dec value to binary with byte offset.
     * 
     * @param int $binary
     * 
     * @return array()
     */
    protected function getDecodeType($binary) {
        $match = array();
        $match2 = array();
        switch (strlen($binary)) {
            case 30:
                preg_match("/(\d{4})(\d{3})(\d{4})(\d{3})(\d{8})(\d{8})/", $binary, $match);
                break;
            case 31:
                preg_match("/(\d{4})(\d{4})(\d{4})(\d{3})(\d{8})(\d{8})/", $binary, $match);
                break;
            case 32:
                preg_match("/(\d{4})(\d{4})(\d{5})(\d{3})(\d{8})(\d{8})/", $binary, $match);
                break;
        }
        foreach ($match as &$each) {
            $each = bindec($each);
        }
        if (!empty($match)) {
            $match[self::DESC_OLT] += 1;
            switch ($match[self::DESC_PONTYPE]) {
                case 9:
                    preg_match("/(\d{4})(\d{4})(\d{4})(\d{4})(\d{8})(\d{8})/", $binary, $match2);
                    break;
                case 10:
                    preg_match("/(\d{4})(\d{4})(\d{4})(\d{4})(\d{8})(\d{8})/", $binary, $match2);
                    break;
            }
            if (isset($match2[self::DESC_PONTYPE])) {
                foreach ($match2 as &$each) {
                    $each = bindec($each);
                }
                $match2[self::DESC_OLT] += 1;
                $match = $match2;
            }
        }
        return ($match);
    }

    /**
     * Coverts dec value to binary with byte offset. For ZTE C6XX/
     * 
     * @param int $binary
     * 
     * @return array()
     */
    protected function getDecodeTypeC6XX($binary) {
        $match = array();
        switch (strlen($binary)) {
            case 29:
                preg_match("/(\d{4})(\d{9})(\d{8})(\d{8})/", $binary, $match);
                break;
        }
        foreach ($match as &$each) {
            $each = bindec($each);
        }
        return ($match);
    }

    /**
     * Converts binary string to human readable format like epon-olt_1/1/10:16
     * 
     * @param array $match
     * @param boolg $default
     * 
     * @return string
     */
    protected function stdDecodeOutput($match, $default = true) {
        $typeName = array(
            1 => 'type_olt_virtualIfBER',
            3 => 'type-onu',
            8 => 'type-onu',
            9 => 'type-onu',
            10 => 'type-onu',
            12 => 'type-onu'
        );
        //rename interface to epon (or gpon if needed)
        foreach ($typeName as &$name) {
            if ($this->ponType == 'EPON') {
                $name = str_replace('type', 'epon', $name);
            } else {
                $name = str_replace('type', 'gpon', $name);
            }
        }

        if ($default) {
            return ($typeName[$match[self::DESC_PONTYPE]]
                . '_'
                . $match[self::DESC_SHELF]
                . '/'
                . $match[self::DESC_SLOT]
                . '/'
                . $match[self::DESC_OLT]
                . ':'
                . $match[self::DESC_ONU]
            );
        } else {
            return ($typeName[$match[self::DESC_PONTYPE]]
                . '_'
                . $match[self::DESC_SHELF]
                . '/'
                . $match[self::DESC_SLOT]
                . '/'
                . $match[self::DESC_OLT]
            );
        }
    }

    /**
     * Converts dec number to gpon interface name. Looks dirty but seems working.
     * 
     * @param int $dec
     * 
     * @return string
     */
    protected function gponOltInterfaceDecode($dec) {
        $result = '';
        $match = array();
        $binary = decbin((int) $dec);
        if (strlen($binary) == 29) {
            preg_match("/(\d{4})(\d{6})(\d{3})(\d{8})(\d{8})/", $binary, $match);
            foreach ($match as &$each) {
                $each = bindec($each);
            }
            if ($match[self::DESC_ONU] == 0) {
                $result = 'gpon-onu_' . $match[self::DESC_SHELF] . '/' . $match[self::DESC_SLOT] . '/' . $match[self::DESC_OLT] . ':';
            } else {
                $result = 'gpon-onu_' . $match[self::DESC_SHELF + 1] . '/' . $match[self::DESC_SLOT + 1] . '/' . $match[self::DESC_OLT + 1] . ':';
            }
        }
        return ($result);
    }

    /**
     * Calculation ZTE epon interfaces indexes.
     * 
     * @return void
     */
    protected function intIndexCalcEpon() {
        $cards = $this->cardsEponCalc();
        $onu_id_start = 805830912;
        foreach ($cards as $card) {
            $onu_id = $onu_id_start + (524288 * ($card - 1));
            for ($port = 1; $port <= 16; $port++) {
                $tmp_id = $onu_id;
                for ($onu_num = 1; $onu_num <= 64; $onu_num++) {
                    $this->intIndex[$tmp_id] = 'epon-onu_' . $card . "/" . $port . ':' . $onu_num;
                    $tmp_id += 256;
                }
                $onu_id += 65536;
            }
        }
    }

    /**
     * Check out which cards are installed
     * 
     * @return array
     */
    protected function cardsEponCalc() {
        $cards = array();
        if (isset($this->currentSnmpTemplate['misc']['ALLCARDS'])) {
            $allCards = $this->snmpwalk($this->currentSnmpTemplate['misc']['ALLCARDS']);
            foreach ($allCards as $io => $value) {
                $split = explode("=", $value);
                if (isset($split[1])) {
                    $oid = $this->strRemoveOidWithDot($this->currentSnmpTemplate['misc']['ALLCARDS'], $split[0]);
                    $oidParts = explode(".", $oid);
                    $cardNumber = end($oidParts);
                    $card = trim(str_replace("STRING:", '', $split[1]));
                    $card = str_replace('"', '', $card);
                    if (isset($this->eponCards[$card])) {
                        $cards[] = $cardNumber;
                    }
                }
            }
        }

        if (empty($cards)) {
            if (isset($this->currentSnmpTemplate['misc']['CARDOFFSET'])) {
                $start = $this->currentSnmpTemplate['misc']['CARDOFFSET'];
            } else {
                $start = 1;
            }
            for ($card = $start; $card <= 20; $card++) {
                $cards[] = $card;
            }
        }
        return ($cards);
    }

    /**
     * Getting raw snmp interface index => mac onu
     * 
     * @return array
     */
    protected function macIndexRawCalc() {
        $macIndex = array();
        $macIndexTmp = $this->snmpwalk($this->currentSnmpTemplate['signal']['MACINDEX']);
        foreach ($macIndexTmp as $io => $value) {
            $value = $this->strRemoveOidWithDot($this->currentSnmpTemplate['signal']['MACINDEX'], $value);
            $value = $this->strRemove($this->currentSnmpTemplate['signal']['MACVALUE'], $value);
            $macIndex[$io] = $value;
        }
        return ($macIndex);
    }

    /**
     * Prettyfying result of macIndexRawCalc
     * 
     * @return void
     */
    protected function macIndexCalc() {
        $macIndexRaw = $this->macIndexRawCalc();
        if (!empty($macIndexRaw)) {
            foreach ($macIndexRaw as $rawIo => $rawEach) {
                $explodeIndex = explode('=', $rawEach);
                if (isset($explodeIndex[1])) {
                    $naturalIndex = trim($explodeIndex[0]);
                    $naturalMac = trim($explodeIndex[1]);
                    $this->macIndex[$naturalIndex] = $naturalMac;
                }
            }
        }
    }

    /**
     * Getting signals => snmp interface id.
     * 
     * @return array
     */
    protected function sigIndexCalc($data) {
        $sigIndexTmp = array();
        if ($this->currentSnmpTemplate['signal']['SIGNALTYPE'] == 'ONURX') {
            $oid = $this->currentSnmpTemplate['signal']['ONURXINDEX'];
        } else {
            $oid = $this->currentSnmpTemplate['signal']['SIGINDEX'];
        }
        if (!empty($data)) {
            if ($this->currentSnmpTemplate['signal']['POLLTYPE'] == 'default') {
                foreach ($data as $ioIndex => $eachVal) {
                    $tmpSig = $this->snmpwalk($oid . $ioIndex);
                    $sigIndex = $this->strRemove($this->currentSnmpTemplate['signal']['SIGVALUE'], $tmpSig[0]);
                    $sigIndex = $this->strRemove($oid, $sigIndex);
                    $explodeSig = explode('=', $sigIndex);
                    $naturalIndex = trim($explodeSig[0]);
                    if (isset($explodeSig[1])) {
                        $naturalSig = trim($explodeSig[1]);
                        $trueIndex = $naturalIndex;
                        if ($this->currentSnmpTemplate['signal']['SIGNALTYPE'] == 'ONURX') {
                            $splitIndex = explode(".", $naturalIndex);
                            $trueIndex = $splitIndex[0] . "." . $splitIndex[1];
                            if ($naturalSig != 65535) {
                                if ($naturalSig <= 30000) {
                                    $naturalSig = $naturalSig * 0.002 - 30;
                                }
                                if ($naturalSig > 30000) {
                                    $naturalSig = ($naturalSig - 65535) * 0.002 - 30;
                                }
                            }
                        }
                        $sigIndexTmp[$trueIndex] = $naturalSig;
                    }
                }
            }
            if ($this->currentSnmpTemplate['signal']['POLLTYPE'] == 'fast') {
                $oid = substr($oid, 0, -1);
                $tmpSig = $this->snmpwalk($oid);
                foreach ($tmpSig as $eachSig) {
                    $sigIndex = $this->strRemove($this->currentSnmpTemplate['signal']['SIGVALUE'], $eachSig);
                    $sigIndex = $this->strRemoveOidWithDot($oid, $sigIndex);
                    $explodeSig = explode('=', $sigIndex);
                    $naturalIndex = trim($explodeSig[0]);
                    if (isset($explodeSig[1])) {
                        $naturalSig = trim($explodeSig[1]);
                        $trueIndex = $naturalIndex;
                        if ($this->currentSnmpTemplate['signal']['SIGNALTYPE'] == 'ONURX') {
                            $splitIndex = explode(".", $naturalIndex);
                            $trueIndex = $splitIndex[0] . "." . $splitIndex[1];
                            if ($naturalSig != 65535) {
                                if ($naturalSig <= 30000) {
                                    $naturalSig = $naturalSig * 0.002 - 30;
                                }
                                if ($naturalSig > 30000) {
                                    $naturalSig = ($naturalSig - 65535) * 0.002 - 30;
                                }
                            }
                        }
                        $sigIndexTmp[$trueIndex] = $naturalSig;
                    }
                }
            }
        }
        unset($this->sigIndex);
        $this->sigIndex = $sigIndexTmp;
    }

    /**
     * Getting FDB
     * 
     * @return void
     */
    protected function fdbCalc() {
        $this->fdbIndex = $this->snmpwalk($this->currentSnmpTemplate['misc']['FDBINDEX']);
        foreach ($this->fdbIndex as $id => &$value) {
            $value = $this->strRemoveOidWithDot($this->currentSnmpTemplate['misc']['FDBINDEX'], $value);
        }
    }

    /**
     * 
     * Function for fixing fucking zte interfaces snmp id.
     * 
     * @param int $uuid
     *        
     * @return string
     */
    protected function interfaceDecode($uuid) {
        $binary = decbin((int) $uuid);
        $match = $this->getDecodeType($binary);

        if (!empty($match) and isset($match[self::DESC_PONTYPE])) {
            switch ($match[self::DESC_PONTYPE]) {
                case 1:
                    return ($this->stdDecodeOutput($match, false));
                case 3:
                    return ($this->stdDecodeOutput($match));
                case 6:
                    return ($match[self::DESC_SHELF] . '/' . $match[self::DESC_SLOT] . '/');
                case 8:
                    $match[self::DESC_SLOT] += $this->currentSnmpTemplate['misc']['CARDOFFSET'];
                    $match[self::DESC_ONU] += 1;
                    return ($this->stdDecodeOutput($match));
                case 9:
                    return ($this->stdDecodeOutput($match));
                case 10:
                    $match[self::DESC_SLOT] += 1;
                    $match[self::DESC_ONU] += 1;
                    return ($this->stdDecodeOutput($match));
                case 12:
                    return ($this->stdDecodeOutput($match));
            }
        }
        return FALSE;
    }

    /**
     * Preprocessing serial index array with removing unneded substrings.
     * 
     * @return void
     */
    protected function snIndexProcess() {
        $this->snIndex = $this->snmpwalk($this->currentSnmpTemplate['signal']['SNINDEX']);
        foreach ($this->snIndex as $io => &$value) {
            $value = $this->strRemove($this->currentSnmpTemplate['signal']['SNVALUE'], $value);
            $value = $this->strRemoveOidWithDot($this->currentSnmpTemplate['signal']['SNINDEX'], $value);
            $value = trim($value);
        }
    }

    /**
     * Preproccess distances indexes.
     * 
     * @return void
     */
    protected function distanceIndexProcess() {
        if ($this->currentSnmpTemplate['signal']['POLLTYPE'] == 'default') {
            foreach ($this->snIndex as $ioIndex => $eachSn) {
                $tmpDist = $this->snmpwalk($this->currentSnmpTemplate['signal']['DISTANCE'] . '.' . $ioIndex);
                $distIndex = $this->strRemoveOidWithDot($this->currentSnmpTemplate['signal']['DISTANCE'], $tmpDist[0]);
                $distIndex = $this->strRemove($this->currentSnmpTemplate['signal']['DISTVALUE'], $distIndex);
                $explodeDist = explode('=', $distIndex);
                $naturalIndex = trim($explodeDist[0]);
                if (isset($explodeDist[1])) {
                    $naturalDist = trim($explodeDist[1]);
                    $this->distanceIndex[$naturalIndex] = $naturalDist;
                }
            }
        }
        if ($this->currentSnmpTemplate['signal']['POLLTYPE'] == 'fast') {
            $tmpDist = $this->snmpwalk($this->currentSnmpTemplate['signal']['DISTANCE']);
            foreach ($tmpDist as $eachDist) {
                $distIndex = $this->strRemoveOidWithDot($this->currentSnmpTemplate['signal']['DISTANCE'], $eachDist);
                $distIndex = $this->strRemove($this->currentSnmpTemplate['signal']['DISTVALUE'], $distIndex);
                $explodeDist = explode('=', $distIndex);
                $naturalIndex = trim($explodeDist[0]);
                if (isset($explodeDist[1])) {
                    $naturalDist = trim($explodeDist[1]);
                    $this->distanceIndex[$naturalIndex] = $naturalDist;
                }
            }
        }
    }

    //parser functions

    /**
     * Parses & stores in cache ZTE OLT ONU ID
     *
     * @return void
     */
    protected function onuidParseEpon() {
        $macTmp = array();

        foreach ($this->macIndex as $ioIndex => $eachMac) {
            $eachMac = strtolower($eachMac);
            $eachMac = str_replace(" ", ":", $eachMac);
            $macTmp[$ioIndex] = $eachMac;
        }
        $this->olt->writeOnuCache($macTmp);
    }

    /**
     * Parsing and validating input array. Getting hex from dec values.
     * 
     * @param array $decParts
     * 
     * @return array
     */
    protected function macPartParse($decParts) {
        $macPart = array();
        if (isset($decParts[1])) {
            for ($i = 2; $i <= 7; $i++) {
                $macPart[] = dechex($decParts[$i]);
            }
            foreach ($macPart as &$eachPart) {
                if (strlen($eachPart) < 2) {
                    $eachPart = '0' . $eachPart;
                }
            }
        }
        return ($macPart);
    }

    /**
     * Parses & stores in cache OLT ONU interfaces
     *
     * @return void
     */
    protected function fdbParseEpon() {
        $counter = 1;
        $fdbTmp = array();
        $macTmp = array();
        $result = array();
        //fdb index preprocessing
        if ((!empty($this->fdbIndex)) and (!empty($this->macIndex))) {
            foreach ($this->fdbIndex as $io => $eachfdb) {
                $line = explode('=', $eachfdb);
                $devOid = trim($line[0]);
                $decParts = explode('.', $devOid);
                $devIndex = trim($decParts[0]);
                $interfaceName = $this->interfaceDecode($devIndex);
                if ($interfaceName) {
                    if (isset($decParts[1])) {
                        $fdbVlan = trim($decParts[1]);
                        $fdbMac = implode(':', $this->macPartParse($decParts));
                        $fdbTmp[$interfaceName][$counter]['mac'] = $fdbMac;
                        $fdbTmp[$interfaceName][$counter]['vlan'] = $fdbVlan;
                        $counter++;
                    }
                }
            }
            //mac index preprocessing            
            foreach ($this->macIndex as $devIndex => $eachMac) {
                if ($this->interfaceDecode($devIndex)) {
                    $macTmp[$this->interfaceDecode($devIndex)] = $eachMac;
                }
            }

            $realData = array_intersect_key($macTmp, $fdbTmp);

            //storing results            
            foreach ($realData as $devId => $eachMac) {
                $result[$macTmp[$devId]] = $fdbTmp[$devId];
            }
        }
        $this->olt->writeFdb($result);
    }

    /**
     * Parses & stores in cache ZTE OLT ONU interfaces
     *
     * @return void
     */
    protected function interfaceParseEpon() {
        $result = array();

        foreach ($this->macIndex as $ioIndex => $eachMac) {
            if (isset($this->intIndex[$ioIndex])) {
                $eachMac = strtolower($eachMac);
                $eachMac = str_replace(" ", ":", $eachMac);
                $interface = $this->intIndex[$ioIndex];
                $result[$eachMac] = $interface;
            } elseif ($this->interfaceDecode($ioIndex)) {
                $eachMac = strtolower($eachMac);
                $eachMac = str_replace(" ", ":", $eachMac);
                $result[$eachMac] = $this->interfaceDecode($ioIndex);
            }
        }
        $this->olt->writeInterfaces($result);
    }

    /**
     * Performs signal preprocessing for sig/mac index arrays and stores it into cache for ZTE OLT
     *
     * @return void
     */
    protected function signalParseEpon() {
        $result = array();
        if ((!empty($this->sigIndex)) and (!empty($this->macIndex))) {
            $this->signalIndexProcessing();
            $this->macIndexEponProcessing();
            $realData = array_intersect_key($this->macIndex, $this->sigIndex);

            foreach ($realData as $devId => $io) {
                $result[$this->macIndex[$devId]] = $this->sigIndex[$devId];
                $tmpSig = $this->sigIndex[$devId];
                if ($this->sigIndex[$devId] == 'Offline') {
                    $tmpSig = -9000;
                }

                $this->olt->writeSignalHistory($this->macIndex[$devId], $tmpSig);
            }
        }
        $this->olt->writeSignals($result);
    }

    /**
     * Performs signal preprocessing for sig/sn index arrays and stores it into cache for ZTE OLT          
     *
     * @return void
     */
    protected function signalParseGpon() {

        $result = array();
        $curDate = curdatetime();

        //signal index preprocessing
        if ((!empty($this->sigIndex)) and (!empty($this->snIndex))) {
            $this->signalIndexProcessing();
            $this->serialIndexGponProcessing();
            $realData = array_intersect_key($this->snIndex, $this->sigIndex);

            //storing results            
            foreach ($realData as $devId => $eachSn) {
                $result[$this->snIndex[$devId]] = $this->sigIndex[$devId];
                $tmpSig = $this->sigIndex[$devId];
                if ($tmpSig == 'Offline') {
                    $tmpSig = -9000;
                }
                //signal history filling
                $this->olt->writeSignalHistory($this->snIndex[$devId], $tmpSig);
            }
        }
        $this->olt->writeSignals($result);
    }

    /**
     * Parsing distance for ZTE/Huawei GPON 
     * 
     * @param array $distIndex     
     * 
     * @return void
     */
    protected function distanceParseGpon() {
        $result = array();

        //distance index preprocessing
        if (!empty($this->distanceIndex) and !empty($this->snIndex)) {
            $realData = array_intersect_key($this->snIndex, $this->distanceIndex);
            foreach ($realData as $io => $eachsn) {
                $result[$this->snIndex[$io]] = $this->distanceIndex[$io];
            }
        }
        $this->olt->writeDistances($result);
    }

    /**
     * Parses & stores in cache OLT ONU interfaces
     *
     * @return void
     */
    protected function fdbParseGpon() {
        $counter = 1;
        $fdbTmp = array();
        $snTmp = array();
        $result = array();
        //fdb index preprocessing
        if ((!empty($this->fdbIndex)) and (!empty($this->snIndex))) {
            foreach ($this->fdbIndex as $io => $eachfdb) {
                $line = explode('=', $eachfdb);
                $devOid = trim($line[0]);
                $decParts = explode('.', $devOid);
                if ($this->currentSnmpTemplate['onu_reg']['VERSION'] == 'C6XX') {
                    if (trim($decParts[2]) != 0) {
                        $vportIndex = trim($decParts[1]);
                        $devIndex = trim($decParts[2]);
                        $interfaceVport = $this->gponOltInterfaceDecode($vportIndex);
                        /*
                          // It's real data from OLT
                          // c025.2fac.ff3c   3701   Dynamic   vport-1/3/1.5:1
                          $interfaceVport =  str_replace('gpon-onu_', 'vport-', $this->gponOltInterfaceDecode($vportIndex));
                          $interfaceVport =  str_replace(':', '.', $interfaceVport);
                          $interfaceVportDecode = $this->getDecodeTypeC6XX(decbin((int) $devIndex));
                          $interfaceName = $interfaceVport . $interfaceVportDecode[3] . ':' . $interfaceVportDecode[4];
                          $interfaceVportDecode = $this->getDecodeTypeC6XX(decbin((int) $devIndex));
                          $interfaceName = $interfaceVport . $interfaceVportDecode[3] . ':' . $interfaceVportDecode[4];
                         */
                        $interfaceVportDecode = $this->getDecodeTypeC6XX(decbin((int) $devIndex));
                        $interfaceName = $interfaceVport . $interfaceVportDecode[2];
                        if ($interfaceName) {
                            if (isset($decParts[0])) {
                                $fdbVlan = trim($decParts[0]);
                                $fdbMac = trim(str_replace('Hex-STRING:', '', $line[1]));
                                $fdbMac = strtolower(str_replace(' ', ':', $fdbMac));
                                $fdbTmp[$interfaceName][$counter]['mac'] = $fdbMac;
                                $fdbTmp[$interfaceName][$counter]['vlan'] = $fdbVlan;
                                $counter++;
                            }
                        }
                    }
                } else {
                    $devIndex = trim($decParts[0]);
                    $interfaceName = $this->interfaceDecode($devIndex);
                    if ($interfaceName) {
                        if (isset($decParts[1])) {
                            $fdbVlan = trim($decParts[1]);
                            $fdbMac = implode(':', $this->macPartParse($decParts));
                            $fdbTmp[$interfaceName][$counter]['mac'] = $fdbMac;
                            $fdbTmp[$interfaceName][$counter]['vlan'] = $fdbVlan;
                            $counter++;
                        }
                    }
                }
            }
            //mac index preprocessing            
            foreach ($this->snIndex as $devIndex => $eachSn) {
                $devIndexParts = explode(".", $devIndex);
                $onuNumber = $devIndexParts[1];
                $interfaceName = $this->gponOltInterfaceDecode($devIndexParts[0]) . $onuNumber;
                if ($interfaceName) {
                    $snTmp[$interfaceName] = $eachSn;
                }
            }

            $realData = array_intersect_key($snTmp, $fdbTmp);

            //storing results            
            foreach ($realData as $devId => $eachSn) {
                $result[$snTmp[$devId]] = $fdbTmp[$devId];
            }
        }
        $this->olt->writeFdb($result);
    }

    /**
     * Parses & stores in cache ZTE OLT ONU interfaces
     *
     * @return void
     */
    protected function interfaceParseGpon() {
        $result = array();

        //storing results

        foreach ($this->snIndex as $ioIndex => $eachSn) {
            $ioIndexSplit = explode(".", $ioIndex);
            $result[$eachSn] = $this->gponOltInterfaceDecode($ioIndexSplit[0]) . $ioIndexSplit[1];
        }
        $this->olt->writeInterfaces($result);
    }

    /**
     * Parses & stores in cache ZTE OLT ONU interfaces
     *
     * @return void
     */
    protected function interfaceParseHuaweiGpon() {
        $result = array();
        $interfaces = array();

        $data = $this->snmpwalk($this->currentSnmpTemplate['misc']['INTERFACENAME']);
        if (!empty($data)) {
            foreach ($data as $io => $value) {
                $split = explode("=", $value);
                $eachOid = trim($this->strRemoveOidWithDot($this->currentSnmpTemplate['misc']['INTERFACENAME'], $split[0]));
                $interfaces[$eachOid] = trim(str_replace('STRING:', '', $split[1]));
            }
        }

        //storing results

        foreach ($this->snIndex as $ioIndex => $eachSn) {
            $ioIndexSplit = explode(".", $ioIndex);
            if (isset($interfaces[$ioIndexSplit[0]])) {
                $result[$eachSn] = $interfaces[$ioIndexSplit[0]] . ':' . $ioIndexSplit[1];
            }
        }
        $this->olt->writeInterfaces($result);
    }

    /**
     * Parses & stores in cache ZTE OLT ONU ID
     *
     * @return void
     */
    protected function onuidParseGpon() {
        $snTmp = array();
        if ($this->currentSnmpTemplate['onu_reg']['VERSION'] == 'C6XX') {
            $snTmp = $this->snIndex;
        } else {
            foreach ($this->snIndex as $ioIndex => $eachSn) {
                $snTmp[$this->interfaceDecode($ioIndex)] = $eachSn;
            }
        }
        $this->olt->writeOnuCache($snTmp);
    }

    /**
     * Parses & stores in cache ZTE OLT ONU ID
     *
     * @return void
     */
    protected function onuidParseHuaweiGpon() {
        $snTmp = array();

        foreach ($this->snIndex as $ioIndex => $eachSn) {
            $snTmp[$this->interfaceDecode($ioIndex)] = $eachSn;
        }

        $this->olt->writeOnuCache($snTmp);
    }

    /**
     * Parsing serial numbers;
     * 
     * @return void
     */
    protected function serialNumberParse() {
        $result = array();
        foreach ($this->snIndex as $rawIo => $rawEach) {
            $split = explode("=", $rawEach);
            if (isset($split[1])) {
                $naturalIndex = trim($split[0]);
                $rawSn = trim($split[1]);
                $tmpSn = explode(" ", $rawSn);
                $check = trim($tmpSn[0]);
                if ($check == 'STRING:') {
                    $naturalSn = $this->serialNumberBinaryParse($tmpSn[1]);
                } else {
                    $naturalSn = $this->serialNumberHexParse($tmpSn);
                }

                $result[$naturalIndex] = $naturalSn;
            }
        }
        unset($this->snIndex);
        $this->snIndex = $result;
    }

    /**
     * Parsing serial number in binary format and coverting it to needed format.
     * 
     * @param array $rawSn
     * 
     * @return string
     */
    protected function serialNumberBinaryParse($rawSn) {
        $parts = array();
        $hexSn = bin2hex($rawSn);
        if (strlen($hexSn) == 20) {
            $parts[0] = $this->serialNumberPartsTranslate($hexSn[2] . $hexSn[3]);
            $parts[1] = $this->serialNumberPartsTranslate($hexSn[4] . $hexSn[5]);
            $parts[2] = $this->serialNumberPartsTranslate($hexSn[6] . $hexSn[7]);
            $parts[3] = $this->serialNumberPartsTranslate($hexSn[8] . $hexSn[9]);
            $parts[4] = '';
            for ($i = 10; $i <= 17; $i++) {
                $parts[4] .= $hexSn[$i];
            }
        } else {
            $parts[0] = $this->serialNumberPartsTranslate($hexSn[0] . $hexSn[1]);
            $parts[1] = $this->serialNumberPartsTranslate($hexSn[2] . $hexSn[3]);
            $parts[2] = $this->serialNumberPartsTranslate($hexSn[4] . $hexSn[5]);
            $parts[3] = $this->serialNumberPartsTranslate($hexSn[6] . $hexSn[7]);
            $parts[4] = '';
            for ($i = 8; $i <= 15; $i++) {
                $parts[4] .= $hexSn[$i];
            }
        }
        $result = implode("", $parts);
        return ($result);
    }

    /**
     * Parsing serial number in hex format and coverting it to needed format.
     * 
     * @param array $rawSn
     * 
     * @return string
     */
    protected function serialNumberHexParse($rawSn) {
        $parts[0] = $this->serialNumberPartsTranslate($rawSn[0]);
        $parts[1] = $this->serialNumberPartsTranslate($rawSn[1]);
        $parts[2] = $this->serialNumberPartsTranslate($rawSn[2]);
        $parts[3] = $this->serialNumberPartsTranslate($rawSn[3]);
        $parts[4] = $rawSn[4] . $rawSn[5] . $rawSn[6] . $rawSn[7];
        $result = implode("", $parts);
        return ($result);
    }

    /**
     * Check mode to convert serial number string vs raw.
     * 
     * @param string $part
     * 
     * @return string
     */
    protected function serialNumberPartsTranslate($part) {
        if ($this->currentSnmpTemplate['signal']['SNMODE'] == 'STRING') {
            return ($this->hexToString($part));
        }
        if ($this->currentSnmpTemplate['signal']['SNMODE'] == 'PURE') {
            return ($part);
        }
    }

    /**
     * Parses uptime data and saves it into uptime cache
     *
     * @param int $oltid
     * @param string $uptimeRaw
     *
     * @return void
     */
    protected function uptimeParse() {
        $uptimeIndexOid = $this->currentSnmpTemplate['system']['UPTIME'];
        $uptimeRaw = $this->snmp->walk($this->oltFullAddress, $this->oltCommunity, $uptimeIndexOid, PONizer::SNMPCACHE);
        if (!empty($this->oltid) and !empty($uptimeRaw)) {
            $uptimeRaw = explode(')', $uptimeRaw);
            $uptimeRaw = $uptimeRaw[1];
            $uptimeRaw = trim($uptimeRaw);
            $this->olt->writeUptime($uptimeRaw);
        }
    }

    /**
     * Parses temperature data and saves it into uptime cache
     *
     * @param int $oltid
     * @param string $uptimeRaw
     *
     * @return void
     */
    protected function temperatureParse() {
        $temperatureIndexOid = $this->currentSnmpTemplate['system']['TEMPERATURE'];
        $tempRaw = $this->snmp->walk($this->oltFullAddress, $this->oltCommunity, $temperatureIndexOid, PONizer::SNMPCACHE);
        if (!empty($this->oltid) and !empty($tempRaw)) {
            $tempRaw = explode(':', $tempRaw);
            $tempRaw = $tempRaw[1];
            $tempRaw = trim($tempRaw);
            $this->olt->writeTemperature($tempRaw);
        }
    }

    //Main section

    /**
     * Polling EPON device
     * 
     * @return void
     */
    public function pollEpon() {
        $this->macIndexCalc();
        $this->sigIndexCalc($this->macIndex);

        $this->signalParseEpon();

        if (isset($this->currentSnmpTemplate['misc'])) {
            if (isset($this->currentSnmpTemplate['misc']['CARDOFFSET'])) {
                $this->intIndexCalcEpon();
                $this->fdbCalc();
                $this->fdbParseEpon();
                $this->interfaceParseEpon();
                $this->onuidParseEpon();
            }
        }
    }

    /**
     * Polling GPON device
     * 
     * @return void
     */
    public function pollGpon() {
        $this->snIndexProcess();
        $this->serialNumberParse();
        $this->sigIndexCalc($this->snIndex);
        $this->signalParseGpon();

        if (isset($this->currentSnmpTemplate['signal']['DISTANCE'])) {
            $this->distanceIndexProcess();
            $this->distanceParseGpon();
        }



        if (isset($this->currentSnmpTemplate['misc'])) {
            if (isset($this->currentSnmpTemplate['misc']['CARDOFFSET'])) {
                $this->fdbCalc();
                $this->fdbParseGpon();
                $this->interfaceParseGpon();
                $this->onuidParseGpon();
            }
        }

        //getting others system data from OLT
        if (isset($this->currentSnmpTemplate['system'])) {
            //OLT uptime
            if (isset($this->currentSnmpTemplate['system']['UPTIME'])) {
                $this->uptimeParse();
            }
            //OLT temperature
            if (isset($this->currentSnmpTemplate['system']['TEMPERATURE'])) {
                $this->temperatureParse();
            }
        }
    }

    /**
     * Polling Huawei GPON device
     * 
     * @return void
     */
    public function huaweiPollGpon() {
        $this->snIndexProcess();
        $this->serialNumberParse();
        $this->sigIndexCalc($this->snIndex);
        $this->signalParseGpon();

        if (isset($this->currentSnmpTemplate['signal']['DISTANCE'])) {
            $this->distanceIndexProcess();
            $this->distanceParseGpon();
        }

        if (isset($this->currentSnmpTemplate['misc']['INTERFACENAME'])) {
            $this->interfaceParseHuaweiGpon();
            //$this->onuidParseHuaweiGpon();
        }
    }
}