Source of file api.vlan.php
Size: 86,425 Bytes - Last Modified: 2026-08-12T15:26:42+03:00
/tmp/current_snapshot/api/libs/api.vlan.php
| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369 | <?php/** * Vlan MAC history class */class VlanMacHistory { const MODULE = "vlan_mac_history"; const MODULE_URL = "?module=vlan_mac_history"; const DB_NAME = "vlan_mac_history"; const FLAGPREFIX = 'exports/ONLINEVLANS'; /** * Contains all available switches data * * @var array */protected $AllSwitches = array(); /** * Contains all available switch models data * * @var array */protected $AllSwitchModels = array(); /** * Contains all vlan terminators data * * @var array */protected $allTerminators = array(); /** * Contains all vlan hosts data * * @var array */protected $allVlanHosts = array(); /** * Contains system alter config as key=>value * * @var array */protected $altCfg = array(); /** * Contains all vlan and mac history * * @var array */public $allHistory = array(); public function __construct() { $this->LoadTerminators(); $this->LoadAlter(); $this->LoadVlanHosts(); $this->LoadAllSwitches(); $this->LoadAllSwitchModels(); $this->LoadVlanMacHistory(); } /** * load all data from `vlan_terminators` to $allTerminators * * @return void */protected function LoadTerminators() { $query = "SELECT * FROM " . VlanTerminator::DB_TABLE; $data = simple_queryall($query); if (!empty($data)) { foreach ($data as $each) { $this->allTerminators[$each['vlanpoolid']] = $each; } } } /** * load alter.ini config * * @return void */protected function LoadAlter() { global $ubillingConfig; $this->altCfg = $ubillingConfig->getAlter(); } /** * load all data from vlanhosts to $allVlanHosts * * @return void */protected function LoadVlanHosts() { $query = "SELECT * FROM " . VlanGen::DB_TABLE; $data = simple_queryall($query); if (!empty($data)) { foreach ($data as $each) { $this->allVlanHosts[$each['login']] = $each; } } } /** * Function for getting all switches and place them to $AllSwitches * * @return void */protected function LoadAllSwitches() { $data = zb_SwitchesGetAll(); if (!empty($data)) { foreach ($data as $each) { $this->AllSwitches[$each['ip']] = $each; } } } /** * Function for getting all switch models and place them to $AllSwitchModels * * @return void */protected function LoadAllSwitchModels() { $query = "SELECT * FROM `switchmodels`"; $data = simple_queryall($query); if (!empty($data)) { foreach ($data as $each) { $this->AllSwitchModels[$each['id']] = $each['snmptemplate']; } } } /** * load all from `vlan_mac_history` to $allHistory * * @return void */protected function LoadVlanMacHistory() { $query = "SELECT * FROM " . self::DB_NAME; $data = simple_queryall($query); if (!empty($data)) { foreach ($data as $each) { $this->allHistory[$each['login']] = $each; } } } /** * Find vlan terminators snmp template * * @param string $login * * @return string */protected function GetTerminatorSnmpTemplate($login) { $data = $this->AllSwitchModels[$this->AllSwitches[$this->allTerminators[$this->allVlanHosts[$login]['vlanpoolid']]['ip']]['modelid']]; return $data; } /** * Read online detect oid from snmp template * * @param string $login * @param int $vlan * * @return string */protected function GetOnlineDetectOid($login, $vlan = false) { $oid = false; $template = $this->GetTerminatorSnmpTemplate($login); $snmpData = rcms_parse_ini_file(CONFIG_PATH . "/snmptemplates/" . $template, true); if (isset($snmpData['define']['ONLINEVLAN'])) { if ($vlan) { $oid = $snmpData['define']['ONLINEVLAN'] . "." . $vlan; } else { $oid = $snmpData['define']['ONLINEVLAN']; } } return ($oid); } /** * Check weather user online * * @param string $login * @param int $vlan * * @return string */public function GetUserVlanOnline($login, $vlan) { snmp_set_oid_output_format(SNMP_OID_OUTPUT_NUMERIC); if ($this->GetOnlineDetectOid($login, $vlan)) { $data = @snmp2_real_walk($this->allTerminators[$this->allVlanHosts[$login]['vlanpoolid']]['ip'], $this->AllSwitches[$this->allTerminators[$this->allVlanHosts[$login]['vlanpoolid']]['ip']]['snmp'], $this->GetOnlineDetectOid($login, $vlan)); if (empty($data)) { return "Offline" . " " . wf_img_sized('skins/icon_inactive.gif', '', '', '12'); } else { return "Online" . " " . wf_img_sized('skins/icon_active.gif', '', '', '12'); } } else { return 'empty'; } } /** * Parse snmp reply and pass it to function which writes data to DB * * @return void */public function WriteVlanMacData() { $count = 0; if (!empty($this->allTerminators) AND ! empty($this->allVlanHosts)) { foreach ($this->allTerminators as $eachTerminator) { $ip = $eachTerminator["ip"]; $vlanPoolId = $eachTerminator['vlanpoolid']; $data = @snmp2_real_walk($ip, $this->AllSwitches[$ip]['snmp'], '.1.3.6.1.4.1.9.9.380.1.4.1.1.3'); foreach ($data as $each => $value) { $decmac = str_replace('.1.3.6.1.4.1.9.9.380.1.4.1.1.3.', '', $each); $vlanPlusMac = explode(".", $decmac, 2); $vlan = $vlanPlusMac[0]; $mac = $this->dec2mac($vlanPlusMac[1]); foreach ($this->allVlanHosts as $eachHost) { if ($eachHost['vlanpoolid'] == $vlanPoolId AND $eachHost['vlan'] == $vlan) { $login = $eachHost['login']; } } if (!empty($this->allHistory)) { if ($this->allHistory[$login]['mac'] != $mac) { $this->WriteHistory($login, $vlan, $mac); } } else { $this->WriteHistory($login, $vlan, $mac); } $count++; } } } file_put_contents(self::FLAGPREFIX, $count); } /** * Get parsed snmp data about vlan, mac and time when device was assigned IP address and write it to DB * * @param string $login * @param int $vlan * @param string $mac * * @return void */protected function WriteHistory($login, $vlan, $mac) { $query = "INSERT INTO " . self::DB_NAME . " (`id`, `login`, `vlan`, `mac`, `date`) VALUES (NULL,'" . $login . "','" . $vlan . "','" . $mac . "', NULL);"; nr_query($query); } /** * Converts decimal (delimiter is dot) MAC to heximal (delimiter is semicolon) * * @param string $mac * * @return string */protected function dec2mac($mac) { $res = array(); $args = explode(".", $mac); foreach ($args as $each) { $each = dechex($each); strlen($each) < 2 ? $res[] = "0$each" : $res[] = $each; } $string = implode(":", $res); return ($string); } /** * Gether web form and return in in table view * * @param string $login * * @return void */public function RenderHistory($login) { $history = $this->allHistory; $tablecells = wf_TableCell(__('ID')); $tablecells .= wf_TableCell(__('Login')); $tablecells .= wf_TableCell(__('VLAN')); $tablecells .= wf_TableCell(__('MAC')); $tablecells .= wf_TableCell(__('Date')); $tablerows = wf_TableRow($tablecells, 'row1'); if (!empty($history)) { $tablecells = wf_TableCell($history[$login]['id']); $tablecells .= wf_TableCell($history[$login]['login']); $tablecells .= wf_TableCell($history[$login]['vlan']); $tablecells .= wf_TableCell($history[$login]['mac']); $tablecells .= wf_TableCell($history[$login]['date']); $tablerows .= wf_TableRow($tablecells, 'row3'); } $result = wf_TableBody($tablerows, '100%', '0', 'sortable'); show_window(__('History'), $result); } }/** * VLAN gen - nothing to see here! */class VlanGen { /** * Contains all vlan pools as vlanPool['id'] => vlanPool['desc'] for vlan pool selector * * @var array */protected $VlanPoolsSelector = array(); /** * Contains all vlan hosts data * * @var array */protected $AllVlanHosts = array(); /** * Contains all vlan pools data * * @var array */protected $AllVlanPools = array(); /** * Contains all vlan terminators data * * @var array */protected $AllTerminators = array(); /** * Contains system alter config as key=>value * * @var array */protected $AltCfg = array(); const MODULE = 'VlanGen'; const MODULE_URL = '?module=pl_vlangen'; const DB_TABLE = 'vlanhosts'; const QINQ_DB_TABLE = 'vlanhosts_qinq'; const SCRIPT_PATH = './config/scripts/'; const MODULE_ADDVLAN = 'addvlan'; const MODULE_URL_ADDVLAN = '?module=addvlan'; const POOL_DB_TABLE = 'vlan_pools'; public function __construct() { $this->LoadVlanHosts(); $this->LoadVlanPoolsSelector(); $this->LoadTerminators(); $this->loadAlter(); } /** * select all data from vlan_terminators and load to $AllTerminators * * @return void */protected function LoadTerminators() { $query = "SELECT * FROM " . VlanTerminator::DB_TABLE; $data = simple_queryall($query); if (!empty($data)) { foreach ($data as $each) { $this->AllTerminators[$each['id']] = $each; } } } /** * select all data from vlanhosts and load it to $allVlanHosts * * @return void */protected function LoadVlanHosts() { $query = "SELECT * FROM " . self::DB_TABLE; $data = simple_queryall($query); if (!empty($data)) { foreach ($data as $each) { $this->AllVlanHosts[$each['id']] = $each; } } } /** * select data from vlan_pools and load data to $AllVlanPools and loading data for vlan pool selector * * @return void */protected function LoadVlanPoolsSelector() { $query = "SELECT * FROM " . self::POOL_DB_TABLE; $data = simple_queryall($query); if (!empty($data)) { foreach ($data as $each) { $this->AllVlanPools[$each['id']] = $each; $this->VlanPoolsSelector[$each['id']] = $each['desc']; } } } /** * load alter.ini config * * @return void */protected function loadAlter() { global $ubillingConfig; $this->AltCfg = $ubillingConfig->getAlter(); } /** * Searching vlan by login in AllVlanHosts * * @param string $login * * @return int $vlan */public function GetVlan($login) { if (!empty($this->AllVlanHosts)) { foreach ($this->AllVlanHosts as $each => $io) { if ($io['login'] == $login) { return($io['vlan']); } } } } /** * Searching QinQ value for vlan pool in AllVlanPools * * @param type $VlanPoolID * * @return int $QinQ */protected function GetVlanPoolQinQ($VlanPoolID) { foreach ($this->AllVlanPools as $Pool => $each) { if ($each['id'] == $VlanPoolID) { return ($each['qinq']); } } } /** * Fills array by every possible int value between $first and $end * * @param int $first * @param int $end * * @return array $pool */protected function VlanPoolExpand($first, $end) { for ($i = $first; $i <= $end; $i++) { $total[] = $i; } if (!empty($total)) { foreach ($total as $EachVlan) { $pool[] = $EachVlan; } } return($pool); } /** * Find all unused values from all possible values from VlanPoolExpand * * @param int $VlanPoolID * * @return array $freePool */protected function GetAllFreeVlan($VlanPoolID) { $poolData = $this->AllVlanPools[$VlanPoolID]; $clearVlans = array(); $fullPool = $this->VlanPoolExpand($poolData['firstvlan'], $poolData['endvlan']); $queryUsed = "SELECT `vlan` from " . self::DB_TABLE; $allUsedVlan = simple_queryall($queryUsed); if (!empty($allUsedVlan)) { foreach ($allUsedVlan as $io => $usedVlan) { $clearVlans[] = $usedVlan['vlan']; } $freePool = array_diff($fullPool, $clearVlans); } else { $freePool = $fullPool; } return($freePool); } /** * Find all unused values from all possible values from VlanPoolExpand * * @param int $vlanPoolID * * @return array $freePool */protected function GetAllFreeVlanQinQ($vlanPoolID) { $poolData = $this->AllVlanPools[$vlanPoolID]; $first = $poolData['firstvlan']; $end = $poolData['endvlan']; $clearVlans = array(); $fullPool = $this->VlanPoolExpand($first, $end); $usedQuery = "SELECT `svlan`,`cvlan`, FROM" . self::QINQ_DB_TABLE; $allUsedVlan = simple_queryall($usedQuery); if (!empty($allUsedVlan)) { foreach ($allUsedVlan as $io => $usedVlan) { $clearVlans[] = $usedVlan['cvlan']; } $freePool = array_diff($fullPool, $clearVlans); } else { $freePool = $fullPool; } return($freePool); } /** * Getting first unused value in all possible values of vlan pool * * @param int $vlanPoolID * * @return int $allFreeVlans[$tmp[0] */protected function GetNextFreeVlan($vlanPoolID) { $allFreeVlans = $this->GetAllFreeVlan($vlanPoolID); $tmp = array_keys($allFreeVlans); return($allFreeVlans[$tmp[0]]); } /** * Getting first unused value in all possible values of vlan pool * * @param int $vlanPoolID * * @return int $allFreeVlans[$tmp[0] */protected function GetNextFreeVlanQinQ($vlanPoolID) { $allFreeVlans = $this->GetAllFreeVlanQinQ($vlanPoolID); $tmp = array_keys($allFreeVlans); return($allFreeVlans[$tmp[0]]); } /** * Find netid by user's IP * * @param string $ip * * @return int $data['netid'] */protected function GetNetidByIP($ip) { $query = "SELECT `netid` FROM `nethosts` WHERE `ip`='" . $ip . "'"; $data = simple_query($query); return($data['netid']); } /** * Find vlan terminator id by netid * * @param int $netid * * @return int $data['id'] */protected function GetTermIdByNetid($netid) { $query = "SELECT `id` FROM `vlan_terminators` WHERE `netid`='" . $netid . "'"; $data = simple_query($query); return($data['id']); } /** * Apply vlan to user and write to DB * * @param int $VlanPoolID * @param int $vlan * @param string $login * * @return void */protected function AddVlanHost($VlanPoolID, $vlan, $login) { $query = "INSERT INTO `vlanhosts` (`id` , `vlanpoolid` , `vlan` , `login`) VALUES (NULL , '" . $VlanPoolID . "', '" . $vlan . "', '" . $login . "');"; nr_query($query); } /** * Adding vlan pool data to DB * * @param string $Desc * @param int $FirstVlan * @param int $LastVlan * @param int $QinQ * @param int $sVlan * * @return void */public function AddVlanPool($Desc, $FirstVlan, $LastVlan, $QinQ, $sVlan) { $Desc = vf(mysql_real_escape_string($Desc)); $FirstVlan = vf(trim($FirstVlan), 3); $LastVlan = vf(trim($LastVlan), 3); $QinQ = vf(trim($QinQ), 3); $sVlan = vf(trim($sVlan), 3); if (empty($sVlan)) { $sVlan = 'NULL'; } $query = " INSERT INTO " . self::POOL_DB_TABLE . " (`id`, `desc`, `firstvlan`, `endvlan`, `qinq`, `svlan`) VALUES (NULL, '" . $Desc . "', '" . $FirstVlan . "', '" . $LastVlan . "', '" . $QinQ . "', '" . $sVlan . "')"; nr_query($query); log_register('ADD VlanPool `' . $Desc . '`'); } /** * Apply vlan to user and write to DB * * @param int $vlanpoolid * @param int $svlan * @param int $cvlan * @param string $login * * @return void */protected function AddVlanHostQinQ($vlanpoolid, $svlan, $cvlan, $login) { $query = "INSERT INTO `vlanhosts_qinq` (`id` , `vlanpoolid` , `svlan` , `cvlan` , `login`) VALUES (NULL , '" . $vlanpoolid . "', '" . $svlan . "', '" . $cvlan . "', '" . $login . "');"; nr_query($query); } /** * Show all available data in vlan pools * * @return void */public function ShowVlanPools() { $allVlanPool = $this->AllVlanPools; $tablecells = wf_TableCell(__('ID')); $tablecells .= wf_TableCell(__('First Vlan')); $tablecells .= wf_TableCell(__('Last Vlan')); $tablecells .= wf_TableCell(__('Desc')); $tablecells .= wf_TableCell(__('qinq')); $tablecells .= wf_TableCell(__('svlan')); $tablecells .= wf_TableCell(__('Actions')); $tablerows = wf_TableRow($tablecells, 'row1'); if (!empty($allVlanPool)) { foreach ($allVlanPool as $eachVlan => $io) { $tablecells = wf_TableCell($io['id']); $tablecells .= wf_TableCell($io['firstvlan']); $tablecells .= wf_TableCell($io['endvlan']); $tablecells .= wf_TableCell($io['desc']); $tablecells .= wf_TableCell($io ['qinq']); if (isset($io['qinq'])) { $tablecells .= wf_TableCell($io['svlan']); } $actionlinks = wf_JSAlert(self::MODULE_URL_ADDVLAN . '&DeleteVlanPool=' . $io['id'], web_delete_icon(), 'Removing this may lead to irreparable results'); $actionlinks .= wf_Link(self::MODULE_URL_ADDVLAN . '&EditVlanPool=' . $io['id'], web_edit_icon(), false); $tablecells .= wf_TableCell($actionlinks); $tablerows .= wf_TableRow($tablecells, 'row3'); } } $result = wf_TableBody($tablerows, '100%', '0', 'sortable'); show_window(__('Vlans'), $result); } /** * Form for adding vlan pool data * * @return void */public function AddVlanPoolForm() { $useQinQArr = array('0' => __('No'), '1' => __('Yes')); $sup = wf_tag('sup') . '*' . wf_tag('sup', true); $inputs = wf_HiddenInput('AddVlan', 'true'); $inputs .= wf_TextInput('FirstVlan', __('First Vlan') . $sup, '', true, '20'); $inputs .= wf_TextInput('LastVlan', __('Last Vlan') . $sup, '', true, '20'); $inputs .= wf_TextInput('Desc', __('Desc') . $sup, '', true, '20'); $inputs .= wf_Selector('UseQinQ', $useQinQArr, __('Use qinq'), '', true); $inputs .= wf_TextInput('sVlan', __('Svlan') . $sup, '', true, '20'); $inputs .= wf_Tag('br'); $inputs .= wf_Submit(__('Add')); $form = wf_Form("", 'POST', $inputs, 'glamour'); show_window(__('Add Vlan'), $form); } /** * Delete users vlan data from DB * * @param string $login * * @return void */public function DeleteVlanHost($login) { $query = "DELETE from " . self::DB_TABLE . " WHERE `login`='" . $login . "'"; nr_query($query); log_register("DELETE VLanHost (" . $login . ")"); } /** * Delete users vlan data from DB * * @param type $login * * @return void */public function DeleteVlanHostQinQ($login) { $query = "DELETE from " . self::QINQ_DB_TABLE . " WHERE `login`='" . $login . "'"; nr_query($query); log_register("DELETE VLanHost (" . $login . ")"); } /** * Delete vlan pool data from DB * * @param int $VlanPoolID * * @return void */public function DeleteVlanPool($VlanPoolID) { $query = "DELETE FROM " . self::POOL_DB_TABLE . " WHERE `id`='" . $VlanPoolID . "'"; nr_query($query); log_register('DELETE VlanPool [' . $VlanPoolID . ']'); } /** * Gather web form and returns it. * Form is used for applying vlan on onu. * * @return string */public function ChangeOnOnuForm() { $Inputs = wf_SubmitClassed('true', 'vlanButton', 'ChangeOnuPvid', __('Change pvid on onu port')); $Form = wf_Form("", 'POST', $Inputs); return($Form); } /** * For for changing pvid on switch port * * @return string */public function ChangeOnPortForm() { $inputs = wf_SubmitClassed('true', 'vlanButton', 'ChangeVlanOnPort', __('Change vlan on switch port')); $form = wf_Form("", 'POST', $inputs); return($form); } /** * Returns form for change\apply vlan on user * * @return string */public function ChangeForm() { $inputs = wf_tag('label', false, 'vlanLabel'); $inputs .= wf_SelectorClassed('VlanPoolSelected', $this->VlanPoolsSelector, '', '', false, 'vlanSelector'); $inputs .= wf_tag('label', true); $inputs .= wf_delimiter(); $inputs .= wf_SubmitClassed('true', 'vlanButton', 'AddVlanHost', __('Change user Vlan')); $inputs .= wf_delimiter(2); $result = wf_Form("", 'POST', $inputs); return($result); } /** * Returns form for delete users vlan * * @return string */public function DeleteForm() { $inputs = wf_SubmitClassed('true', 'vlanButton', 'DeleteVlanHost', __('Delete user Vlan')); $inputs .= wf_delimiter(2); $result = wf_form("", 'POST', $inputs); return($result); } /** * Edit vlan pool data in DB * * @param int $first * @param int $last * @param string $desc * @param int $qinq * @param int $svlan * @param int $id * * @return void */public function EditVlanPool($first, $last, $desc, $qinq, $svlan, $id) { $first = vf(trim($first), 3); $last = vf(trim($last), 3); $desc = vf($desc); $qinq = vf(trim($qinq), 3); $svlan = vf(trim($svlan), 3); if (empty($sVlan)) { $svlan = 'NULL'; } simple_update_field(self::POOL_DB_TABLE, 'firstvlan', $first, "WHERE `id`='" . $id . "'"); simple_update_field(self::POOL_DB_TABLE, 'endvlan', $last, "WHERE `id`='" . $id . "'"); simple_update_field(self::POOL_DB_TABLE, 'desc', $desc, "WHERE `id`='" . $id . "'"); simple_update_field(self::POOL_DB_TABLE, 'qinq', $qinq, "WHERE `id`='" . $id . "'"); simple_update_field(self::POOL_DB_TABLE, 'svlan', $svlan, "WHERE `id`='" . $id . "'"); log_register('MODIFY VlanPool [' . $id . ']'); } /** * Form for editing vlan pool data * * @param int $PoolID * * @return string */public function VlanPoolEditForm($PoolID) { $PoolData = $this->AllVlanPools[$PoolID]; $useQinQArr = array('0' => __('No'), '1' => __('Yes')); $sup = wf_tag('sup') . '*' . wf_tag('sup', true); $inputs = wf_HiddenInput('EditVlanPool', 'true'); $inputs .= wf_TextInput('FirstVlan', __('First Vlan') . $sup, $PoolData['firstvlan'], true, '20'); $inputs .= wf_TextInput('LastVlan', __('Last Vlan') . $sup, $PoolData['endvlan'], true, '20'); $inputs .= wf_TextInput('Desc', __('Desc') . $sup, $PoolData['desc'], true, '20'); $inputs .= wf_Selector('UseQinQ', $useQinQArr, __('Use qinq'), $PoolData['qinq'], true); $inputs .= wf_TextInput('sVlan', __('sVlan') . $sup, $PoolData['svlan'], true, '20'); $inputs .= wf_Tag('br'); $inputs .= wf_Submit(__('Save')); $form = wf_Form('', "POST", $inputs, 'glamour'); $form .= wf_BackLink(self::MODULE_URL_ADDVLAN, '', true); show_window(__('Edit'), $form); } /** * Apply vlan on vlan terminator * * @param string $ip * @param int $vlan * * @return void */protected function OnVlanConnect($ip, $vlan) { multinet_rebuild_all_handlers(); $networkID = $this->GetNetidByIP($ip); $terminatorID = $this->GetTermIdByNetid($networkID); $termData = $this->AllTerminators[$terminatorID]; $term_ip = $termData ['ip']; $term_type = $termData['type']; $term_user = $termData['username']; $term_pass = $termData['password']; $term_int = $termData['interface']; $relay = $termData['relay']; if ($term_ip == '127.0.0.1') { if ($term_type == 'FreeBSD') { $res = shell_exec(self::SCRIPT_PATH . "bsd.local.sh $term_int $ip $vlan"); } if ($term_type == 'Linux') { $res = shell_exec(self::SCRIPT_PATH . "linux.local.sh"); } } else { if ($term_type == 'FreeBSD') { $res = shell_exec(self::SCRIPT_PATH . "bsd.remote.sh $term_user $term_pass $term_int $ip $vlan"); } if ($term_type == 'Linux') { $res = shell_exec(self::SCRIPT_PATH . "linux.remote.sh $term_user $term_pass $term_int $ip $vlan"); } if ($term_type == 'Cisco') { $res = shell_exec(self::SCRIPT_PATH . "cisco.sh $term_user $term_pass $vlan $term_int $relay $term_ip"); } if ($term_type == 'Cisco_static') { $res = shell_exec(self::SCRIPT_PATH . "cisco_static.sh $term_user $term_pass $vlan $term_int $relay $term_ip"); } } } /** * Changes\applies users vlan on vlan terminator * * @param int $newVlanPoolID * @param string $login * * @return void */public function VlanChange($newVlanPoolID, $login) { $QinQ = $this->GetVlanPoolQinQ($newVlanPoolID); $ip = zb_UserGetIP($login); $this->DeleteVlanHost($login); $this->DeleteVlanHostQinQ($login); if ($QinQ == 0) { $newVlan = $this->GetNextFreeVlan($newVlanPoolID); if (empty($newVlan)) { $alert = wf_JSAlert(self::MODULE_URL_ADDVLAN, __("Error"), __("No free Vlan available in selected pool")); print($alert); rcms_redirect(self::MODULE_URL_ADDVLAN); } $this->AddVlanHost($newVlanPoolID, $newVlan, $login); } else { $poolData = $this->AllVlanPools[$newVlanPoolID]; $svlan = $poolData['svlan']; $this->AddVlanHostQinQ($newVlanPoolID, $svlan, $newVlan, $login); } $this->OnVlanConnect($ip, $newVlan); log_register(__("Change vlan") . " " . "(" . $login . ")" . " " . __("ON") . " " . $newVlan); } }/** * VLAN terminator class */class VlanTerminator { const MODULE = 'Vlan Terminator'; const MODULE_URL = '?module=nas'; const DB_TABLE = 'vlan_terminators'; /** * Contains all vlan terminators data * * @var array */protected $AllTerminators = array(); /** * Contains all vlan pools as vlanPool['id'] => vlanPool['desc'] for vlan pool selector * * @var array */protected $VlanPoolsSelector = array(); /** * Contains all networks pool as network['id'] => network['desc'] for networks selector * * @var type */protected $NetworkSelector = array(); public function __construct() { $this->LoadTerminators(); $this->LoadVlanPoolsSelector(); $this->LoadNetworkSelecor(); } /** * Load all from `vlan_terminator` to $allTerminators * * @return void */protected function LoadTerminators() { $query = "SELECT * FROM " . self::DB_TABLE; $data = simple_queryall($query); if (!empty($data)) { foreach ($data as $each) { $this->AllTerminators[$each['id']] = $each; } } } /** * Load data for making web form (select) for selecting vlan pool * * @return void */protected function LoadVlanPoolsSelector() { $query = "SELECT * FROM " . VlanGen::POOL_DB_TABLE; $data = simple_queryall($query); if (!empty($data)) { foreach ($data as $each) { $this->VlanPoolsSelector[$each['id']] = $each['desc']; } } } /** * Load data for making web form (select) for selecting network. * * @return void */protected function LoadNetworkSelecor() { $query = "SELECT * FROM `networks`"; $data = simple_queryall($query); if (!empty($data)) { foreach ($data as $each) { $this->NetworkSelector[$each['id']] = $each['desc']; } } } /** * Delete vlan terminator data from DB * * @param int $id * * @return void */public function delete($id) { $query = "DELETE FROM " . self::DB_TABLE . " WHERE `id`='" . $id . "'"; nr_query($query); log_register('DELETE Terminator [' . $id . ']'); } /** * Add vlan terminator data to DB * * @param int $netid * @param int $vlanpoolid * @param string $ip * @param string $type * @param string $username * @param string $password * @param string $remote * @param string $interface * @param string $relay * * @return void */public function add($netid, $vlanpoolid, $ip, $type, $username, $password, $remote, $interface, $relay) { $query = "INSERT INTO " . self::DB_TABLE . " (`id`, `netid`, `vlanpoolid`, `ip`, `type`, `username`, `password`, `remote-id`, `interface`, `relay`) VALUES (NULL, '" . $netid . "', '" . $vlanpoolid . "', '" . $ip . "', '" . $type . "', '" . $username . "', '" . $password . "', '" . $remote . "', '" . $interface . "', '" . $relay . "' )"; nr_query($query); log_register('ADD Terminator `' . $type . '`'); } /** * Editing vlan terminator data in DB * * @param int $NetID * @param int $VlanPool * @param string $TerminatorIP * @param string $TerminatorType * @param string $TerminatorLogin * @param string $TerminatorPass * @param string $RemoteID * @param string $Interface * @param string $Relay * @param int $id * * @return void */public function edit($NetID, $VlanPool, $TerminatorIP, $TerminatorType, $TerminatorLogin, $TerminatorPass, $RemoteID, $Interface, $Relay, $id) { simple_update_field(self::DB_TABLE, 'netid', $NetID, "WHERE `id`='" . $id . "'"); simple_update_field(self::DB_TABLE, 'vlanpoolid', $VlanPool, "WHERE `id`='" . $id . "'"); simple_update_field(self::DB_TABLE, 'ip', $TerminatorIP, "WHERE `id`='" . $id . "'"); simple_update_field(self::DB_TABLE, 'type', $TerminatorType, "WHERE `id`='" . $id . "'"); simple_update_field(self::DB_TABLE, 'username', $TerminatorLogin, "WHERE `id`='" . $id . "'"); simple_update_field(self::DB_TABLE, 'password', $TerminatorPass, "WHERE `id`='" . $id . "'"); simple_update_field(self::DB_TABLE, 'remote-id', $RemoteID, "WHERE `id`='" . $id . "'"); simple_update_field(self::DB_TABLE, 'interface', $Interface, "WHERE `id`='" . $id . "'"); simple_update_field(self::DB_TABLE, 'relay', $Relay, "WHERE `id`='" . $id . "'"); log_register('MODIFY Vlan Terminator [' . $id . ']'); } /** * Show's all vlan terminators data * * @return string */public function RenderTerminators() { $tablecells = wf_TableCell(__('ID')); $tablecells .= wf_TableCell(__('Network')); $tablecells .= wf_TableCell(__('Vlan pool')); $tablecells .= wf_TableCell(__('IP')); $tablecells .= wf_TableCell(__('Type')); $tablecells .= wf_TableCell(__('Username')); $tablecells .= wf_TableCell(__('Password')); $tablecells .= wf_TableCell(__('Remote-ID')); $tablecells .= wf_TableCell(__('Interface')); $tablecells .= wf_TableCell(__('Relay Address')); $tablecells .= wf_TableCell(__('Actions')); $tablerows = wf_TableRow($tablecells, 'row1'); if (!empty($this->AllTerminators)) { foreach ($this->AllTerminators as $each => $term) { $tablecells = wf_TableCell($term['id']); $tablecells .= wf_TableCell($this->NetworkSelector[$term ['netid']]); $tablecells .= wf_TableCell($this->VlanPoolsSelector[$term['vlanpoolid']]); $tablecells .= wf_TableCell($term['ip']); $tablecells .= wf_TableCell($term['type']); $tablecells .= wf_TableCell($term['username']); $tablecells .= wf_TableCell($term['password']); $tablecells .= wf_TableCell($term['remote-id']); $tablecells .= wf_TableCell($term['interface']); $tablecells .= wf_TableCell($term['relay']); $actionlinks = wf_JSAlert(self::MODULE_URL . '&DeleteTerminator=' . $term['id'], web_delete_icon(), 'Removing this may lead to irreparable results'); $actionlinks .= wf_Link(self::MODULE_URL . '&EditTerminator=' . $term['id'], web_edit_icon(), false); $tablecells .= wf_TableCell($actionlinks); $tablerows .= wf_TableRow($tablecells, 'row3'); } } $result = wf_TableBody($tablerows, '100%', '0', 'sortable'); show_window(__('Terminators'), $result); } /** * Returns form for adding vlan terminator to DB * * @return string */public function AddForm() { $type = array('FreeBSD' => 'FreeBSD', 'Linux' => 'Linux', 'Cisco' => 'Cisco', 'Cisco_static' => 'Cisco_static'); $sup = wf_tag('sup') . '*' . wf_tag('sup', true); $inputs = wf_HiddenInput('AddTerminator', 'true'); $inputs .= wf_Selector('NetworkSelected', $this->NetworkSelector, __('Network'), '', true); $inputs .= wf_Selector('VlanPoolSelected', $this->VlanPoolsSelector, __('Vlan Pool ID'), '', true); $inputs .= wf_TextInput('IP', __('IP') . $sup, '', true, '20'); $inputs .= wf_Selector('Type', $type, __('Type'), '', true); $inputs .= wf_TextInput('Username', __('Username') . $sup, '', true, '20'); $inputs .= wf_TextInput('Password', __('Password') . $sup, '', true, '20'); $inputs .= wf_TextInput('RemoteID', __('Remote-ID') . $sup, '', true, '20'); $inputs .= wf_TextInput('Interface', __('Interface') . $sup, '', true, '20'); $inputs .= wf_TextInput('Relay', __('Relay Address') . $sup, '', true, '20'); $inputs .= wf_Tag('br'); $inputs .= wf_Submit(__('Add')); $form = wf_Form("", 'POST', $inputs, 'glamour'); show_window(__('ADD Terminator'), $form); } /** * Returns form for editing vlan terminators data in DB * * @param int $id * * @return string */public function EditForm($id) { $TermData = $this->AllTerminators[$id]; $type = array('FreeBSD' => 'FreeBSD', 'Linux' => 'Linux', 'Cisco' => 'Cisco', 'Cisco_static' => 'Cisco_static'); $sup = wf_tag('sup') . '*' . wf_tag('sup', true); $inputs = wf_HiddenInput('TerminatorEdit', 'true'); $inputs .= wf_Selector('NetworkSelected', $this->NetworkSelector, __('Network'), $TermData['netid'], true); $inputs .= wf_Selector('VlanPoolSelected', $this->VlanPoolsSelector, __('Vlan Pool ID'), $TermData['vlanpoolid'], true); $inputs .= wf_TextInput('IP', __('IP') . $sup, $TermData['ip'], true, '20'); $inputs .= wf_Selector('Type', $type, __('Type'), $TermData['type'], true); $inputs .= wf_TextInput('Username', __('Username') . $sup, $TermData['username'], true, '20'); $inputs .= wf_TextInput('Password', __('Password') . $sup, $TermData['password'], true, '20'); $inputs .= wf_TextInput('RemoteID', __('Remote-ID') . $sup, $TermData['remote-id'], true, '20'); $inputs .= wf_TextInput('Interface', __('Interface') . $sup, $TermData['interface'], true, '20'); $inputs .= wf_TextInput('Relay', __('Relay Address') . $sup, $TermData['relay'], true, '20'); $inputs .= wf_Tag('br'); $inputs .= wf_Submit(__('Save')); $form = wf_Form("", 'POST', $inputs, 'glamour'); $form .= wf_BackLink(self::MODULE_URL, '', true); show_window(__('Edit'), $form); } }/** * Network devices automatic configuration */class AutoConfigurator { const AUTOCONFIG = 'config/autoconfig/'; /** * Contains all available switches data * * @var array */protected $AllSwitches = array(); /** * Contains all available switch models data * * @var array */protected $AllSwitchModels = array(); /** * Contain all available switch ports data * * @var array */protected $AllSwitchPort = array(); /** * Contains all available switch login data * * @var array */protected $AllSwitchLogin = array(); /** * Contains all available vlan terminators * * @var array */protected $AllTerminators = array(); /** * Placeholder for SNMPHelper() object * * @var object */protected $SnmpHelper = ''; /** * Containt config of alter.ini * * @var object */protected $AltCfg = ''; public function __construct() { $this->LoadAllSwitches(); $this->LoadAllSwitchPort(); $this->LoadAllSwitchLogin(); $this->LoadTerminators(); $this->SnmpHelper = new SNMPHelper(); } /** * Function for getting all switches and place them to $AllSwitches * * @return void */protected function LoadAllSwitches() { $data = zb_SwitchesGetAll(); if (!empty($data)) { foreach ($data as $each) { $this->AllSwitches[$each['id']] = $each; } } } /** * Function for getting all switchport data and place it to $AllSwitchPort * * @return void */protected function LoadAllSwitchPort() { $query = "SELECT * FROM `switchportassign`"; $data = simple_queryall($query); if (!empty($data)) { foreach ($data as $each) { $this->AllSwitchPort[$each['id']] = $each; } } } /** * Function for getting all switch login data and place it to $AllSwitchLogin * * @return void */protected function LoadAllSwitchLogin() { $query = "SELECT * FROM " . SwitchLogin::TABLE_NAME; $data = simple_queryall($query); if (!empty($data)) { foreach ($data as $each) { $this->AllSwitchLogin[$each['id']] = $each; } } } /** * Get all available vlan terminators data and place it to $AllTerminators * * @return void */protected function LoadTerminators() { $query = "SELECT * FROM " . VlanTerminator::DB_TABLE; $data = simple_queryall($query); if (!empty($data)) { foreach ($data as $each) { $this->AllTerminators[$each['id']] = $each; } } } /** * load alter.ini config * * @return void */protected function loadAlter() { global $ubillingConfig; $this->AltCfg = $ubillingConfig->getAlter(); } /** * Load all from `switchmodels` to $AllSwitchModels. * * @return void */protected function LoadAllSwitchModels() { $query = "SELECT * FROM `switchmodels`"; $data = simple_queryall($query); if (!empty($data)) { foreach ($data as $each) { $this->AllSwitchModels[$each['id']] = $each['modelname']; } } } /** * Function for getting switchport data by login * * @param string $login * * @return array/bool bool if false */protected function GetSwitchPortData($login) { $data = $this->AllSwitchPort; if (!empty($data)) { foreach ($data as $each) { if ($each['login'] == $login) { $SwitchPortData = $each; } } if (isset($SwitchPortData)) { return($SwitchPortData); } else { return(false); } } else { return(false); } } /** * Function for getting switch login data by switchid * * @param integer $switchid * * @return array */protected function GetSwitchLoginData($switchid) { $data = $this->AllSwitchLogin; if (!empty($data)) { foreach ($data as $each) { if ($each['swid'] == $switchid) { $SwitchLoginData = $each; } } if (isset($SwitchLoginData)) { return ($SwitchLoginData); } else { return (false); } } else { return (false); } } /** * Function for getting switch data by switchid * * @param integer $switchid * * @return array or false */protected function GetSwitchesData($switchid) { $data = $this->AllSwitches; if (!empty($data)) { foreach ($data as $each) { if ($each['id'] == $switchid) { $SwitchesData = $each; } } if (isset($SwitchesData)) { return($SwitchesData); } else { return(false); } } else { return (false); } } /** * Get switch IP by ID * * @param integer $parentid * * @return string or false */protected function GetSwUplinkIP($parentid) { $data = $this->AllSwitches; if (!empty($data)) { foreach ($data as $each) { if ($each['id'] == $parentid) { $result = $each['ip']; } } if (isset($result)) { return($result); } else { return(false); } } else { return (false); } } /** * Check if IP belongs to vlan terminator * * @param string $ip * * @return bool */protected function CheckTermIP($ip) { $result = false; if (!empty($this->AllTerminators)) { foreach ($this->AllTerminators as $each) { if ($each['ip'] == $ip) { $result = true; } } } return($result); } /** * Check weather vlan already created on switch * * @param string $ip * @param string $community * @param string $oid * * @return bool */protected function CheckVlan($ip, $community, $oid) { $query = $this->SnmpHelper->walk($ip, $community, $oid, false); $query = trim($query); $tmp = explode("=", $query); if (isset($tmp[1])) { if (!empty($tmp[1])) { return(true); } else { return (false); } } else { return(false); } } /** * Check if vlan was applied on port * * @param string $ip * @param string $community * @param string $oid * @param integer $vlan * * @return bool */protected function CheckPvid($ip, $community, $oid, $vlan) { $query = $this->SnmpHelper->walk($ip, $community, $oid, false); $query = trim($query); $tmp = explode(":", $query); if (isset($tmp[1])) { if ($tmp[1] == $vlan) { return(true); } else { return(false); } } else { return(false); } } /** * Change pvid on users port * * @param string $login * @param integer $vlan * * @return void */public function ChangePvid($login, $vlan) { if ($this->GetSwitchPortData($login)) { $SwitchPortData = $this->GetSwitchPortData($login); $port = $SwitchPortData['port']; $SwitchId = $SwitchPortData['switchid']; $ModelId = $this->AllSwitches[$SwitchId]['modelid']; if ($this->GetSwitchLoginData($SwitchId)) { $SwitchLoginData = $this->GetSwitchLoginData($SwitchId); $method = $SwitchLoginData['method']; if ($method == 'SNMP') { $community = $SwitchLoginData['community']; $snmpTemplate = $SwitchLoginData['snmptemplate']; if ($this->GetSwitchesData($SwitchId)) { $SwitchesData = $this->GetSwitchesData($SwitchId); $ip = $SwitchesData['ip']; $ParentId = $SwitchesData['parentid']; if (file_exists(self::AUTOCONFIG . $snmpTemplate)) { $SNMPData = rcms_parse_ini_file(self::AUTOCONFIG . $snmpTemplate, true); if (isset($SNMPData['define']['HEX'])) { $group = 0; if ($port > 4) { $portPlace = $port % 4; if ($portPlace == 0) { $portPlace = 4; } $counter = $port; while ($counter > 0) { $group++; $counter -= 4; } } else { $group = 1; $portPlace = $port; } switch ($portPlace) { case 1: $portPlaceHex = 8; break; case 2: $portPlaceHex = 4; break; case 3: $portPlaceHex = 2; break; case 4: $portPlaceHex = 1; break; } $hexString = $SNMPData['define']['HEX']; $hexString = str_replace(' ', '', $hexString); $hexString[$group - 1] = $portPlaceHex; $split = str_split($hexString); $hexString = ''; $stringCounter = 1; foreach ($split as $each) { if (($stringCounter % 2) == 0) { $hexString .= $each . " "; } else { $hexString .= $each; } $stringCounter++; } $pattern = array('/PORT/', '/VLAN/', '/HEX/', '/LOGIN/'); $replace = array($port, $vlan, $hexString, $login); } else { $pattern = array('/PORT/', '/VLAN/', '/LOGIN/'); $replace = array($port, $vlan, $login); } if ($SNMPData['define']['TYPE'] == 'simple') { foreach ($SNMPData as $section => $eachpoll) { if ($section != 'define') { if ($this->CheckVlan($ip, $community, $SNMPData['define']['CHECK'] . "." . $vlan)) { if ($section != 'create') { $data[] = array( 'oid' => preg_replace($pattern, $replace, $eachpoll['OID']), 'type' => $eachpoll['TYPE'], 'value' => preg_replace($pattern, $replace, $eachpoll['VALUE']) ); } } else { $data[] = array( 'oid' => preg_replace($pattern, $replace, $eachpoll['OID']), 'type' => $eachpoll['TYPE'], 'value' => preg_replace($pattern, $replace, $eachpoll['VALUE']) ); } } } $result = $this->SnmpHelper->set($ip, $community, $data); if (isset($result)) { $CheckOid = preg_replace($pattern, $replace, $SNMPData['change']['OID']); if ($this->CheckPvid($ip, $community, $CheckOid, $vlan)) { if (!empty($ParentId)) { $this->CreateVlanLooped($ParentId, $vlan); } else { show_warning(__("Switch has no uplink")); } log_register(__("Change PVID to") . " " . $vlan . " vlan " . __("on port") . " " . $port . " " . __("switch") . " " . $ip . " " . __("for") . " " . $login); show_success($result); } else { show_error(__("Something goes wrong, vlan wasnt applied on port")); } } else { show_error(__('Nothing happend')); } } if ($SNMPData['define']['TYPE'] == 'alcatel') { $data = ''; foreach ($SNMPData as $section => $eachpoll) { if ($section != 'define') { if ($this->CheckVlan($ip, $community, $SNMPData['define']['CHECK'] . "." . $vlan)) { if ($section != 'create') { $oid = preg_replace($pattern, $replace, $eachpoll['OID']); $type = $eachpoll['TYPE']; $value = preg_replace($pattern, $replace, $eachpoll['VALUE']); $data .= $oid . ' ' . $type . ' ' . $value . ' '; } } else { $oid = preg_replace($pattern, $replace, $eachpoll['OID']); $type = $eachpoll['TYPE']; $value = preg_replace($pattern, $replace, $eachpoll['VALUE']); $data .= $oid . ' ' . $type . ' ' . $value . ' '; } } } $this->loadAlter(); if ($this->AltCfg['SNMP_MODE'] != 'system') { $snmpSet = $this->AltCfg['SNMPSET_PATH']; $snmpSet .= ' -c ' . $community . ' ' . $ip . ' ' . $data; $result = shell_exec($snmpSet); } else { $result = $this->SnmpHelper->set($ip, $community, $data); } if (isset($result)) { $CheckOid = preg_replace($pattern, $replace, $SNMPData['change']['OID']); if ($this->CheckPvid($ip, $community, $CheckOid, $vlan)) { if (!empty($ParentId)) { $this->CreateVlanLooped($ParentId, $vlan); } else { show_warning(__("Switch has no uplink")); } log_register(__("Change PVID to") . " " . $vlan . " vlan " . __("on port") . " " . $port . " " . __("switch") . " " . $ip . " " . __("for") . " " . $login); show_success($result); } else { show_error(__("Something goes wrong, vlan wasnt applied on port")); } } else { show_error(__('Nothing happend')); } } } else { show_error(__("No suitable SNMP template found")); } } else { show_error(__('Swich has no ip or parent for switchid' . ' ' . $SwitchId)); } } else { $swlogin = $SwitchLoginData['swlogin']; $swpass = $SwitchLoginData['swpass']; if ($this->GetSwitchesData($SwitchId)) { $SwitchesData = $this->GetSwitchesData($SwitchId); $ip = $SwitchesData['ip']; $this->LoadAllSwitchModels(); $swmodel = $this->AllSwitchModels[$ModelId]; shell_exec(CONFIG_PATH . "scripts/$swmodel $swlogin $swpass $ip $vlan $port"); show_success(__("Success")); } } } else { show_error(__('No switch login data found for switchid' . ' ' . $SwitchId)); } } else { show_error(__('No switchport data found')); } } /** * Create vlan on transit switches * * @param integer $SwitchId * @param integer $vlan * * @return void */public function CreateVlanLooped($SwitchId, $vlan, $parent = true) { if (!$parent) { if ($this->GetSwitchesData($SwitchId)) { $SwitchesDataParent = $this->GetSwitchesData($SwitchId); $ParentIdtmp = $SwitchesDataParent['parentid']; $SwitchId = $ParentIdtmp; } } $result = ''; while (!empty($SwitchId)) { $SwitchIp = $this->GetSwUplinkIP($SwitchId); if ($this->CheckTermIP($SwitchIp)) { break; } if ($this->GetSwitchLoginData($SwitchId)) { $SwitchLoginData = $this->GetSwitchLoginData($SwitchId); $method = $SwitchLoginData['method']; if ($method == 'SNMP') { $community = $SwitchLoginData['community']; $snmpTemplate = $SwitchLoginData['snmptemplate']; if ($this->GetSwitchesData($SwitchId)) { $SwitchesData = $this->GetSwitchesData($SwitchId); $ip = $SwitchesData['ip']; $ParentId = $SwitchesData['parentid']; if (file_exists(self::AUTOCONFIG . $snmpTemplate)) { $SNMPData = rcms_parse_ini_file(self::AUTOCONFIG . $snmpTemplate, true); $pattern = '/VLAN/'; $replace = $vlan; $CheckOid = preg_replace($pattern, $replace, $SNMPData['create']['OID']); if ($SNMPData['define']['TYPE'] == 'simple') { if ($this->CheckVlan($ip, $community, $CheckOid)) { foreach ($SNMPData as $section => $eachpoll) { if ($section == 'save') { $data[] = array( 'oid' => preg_replace($pattern, $replace, $eachpoll['OID']), 'type' => $eachpoll['TYPE'], 'value' => preg_replace($pattern, $replace, $eachpoll['VALUE']) ); } } log_register(__("VLAN") . " " . $vlan . " " . __("already created") . " " . __("on switch") . " " . $ip); } else { foreach ($SNMPData as $section => $eachpoll) { if ($section != 'define') { if ($section != 'change') { $data[] = array( 'oid' => preg_replace($pattern, $replace, $eachpoll['OID']), 'type' => $eachpoll['TYPE'], 'value' => preg_replace($pattern, $replace, $eachpoll['VALUE']) ); } } } } $result .= $this->SnmpHelper->set($ip, $community, $data); if ($this->CheckVlan($ip, $community, $CheckOid)) { log_register(__("Created vlan") . " " . $vlan . " " . __("on switch") . " " . $ip); } $SwitchId = $ParentId; } } else { break; } } else { show_error(__('Swich has no ip or parent for switchid' . ' ' . $SwitchId)); } } } else { show_error(__('No switch login data found for switchid' . ' ' . $SwitchId)); } } return ($result); } }/** * PON ONU configuration class */class OnuConfigurator { /** * Contains all onu data * * @var array */protected $allOnu = array(); /** * Contains all OLT's data * * @var array */protected $allOlt = array(); /** * Contains all olt models and snmptemplates * * @var array */protected $allOltModels = array(); /** * Contains alter.ini config file * * @var array */protected $altCfg = array(); /** * Placeholder for AutoConfigurator() class * * @var placeholder */protected $AutoConfig = array(); public function __construct() { $this->loadOnu(); $this->LoadAllOlt(); $this->loadOltModels(); $this->snmp = new SNMPHelper(); $this->AutoConfig = new AutoConfigurator; $this->loadAlter(); } /** * Read and load alter.ini to $AltCfg. * * @global type $ubillingConfig * * @return void */protected function loadAlter() { global $ubillingConfig; $this->AltCfg = $ubillingConfig->getAlter(); } /** * Load all from `switches` to $allswitches * * @return void */protected function LoadAllOlt() { $query = "SELECT `id`,`ip`,`snmp`,`modelid` from `switches` WHERE `desc` LIKE '%OLT%'"; $raw = simple_queryall($query); if (!empty($raw)) { foreach ($raw as $io => $each) { if (!empty($each['snmp'])) { $this->allOlt[$each['id']]['ip'] = $each['ip']; $this->allOlt[$each['id']]['snmp'] = $each['snmp']; $this->allOlt[$each['id']]['modelid'] = $each['modelid']; } } } } /** * Load all from `pononu` to $allOnu * * @return void */protected function loadOnu() { $query = "SELECT * from `pononu`"; $all = simple_queryall($query); if (!empty($all)) { foreach ($all as $io => $each) { $this->allOnu[$each['id']] = $each; } } } /** * 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']; } } } /** * Getting olt's snmptemplate by it's ID * * @param int $modelid * * @return string */protected function GetOltModelTemplate($modelid) { $result = ''; if (!empty($this->allOltModels)) { $data = $this->allOltModels[$modelid]; $result = $data['snmptemplate']; } return($result); } /** * get olt data like ip and snmp community * * @param int $id * * @return array */protected function GetOltData($id) { $result = array(); if (!empty($this->allOlt)) { $Olt = $this->allOlt[$id]; $result[] = $Olt['ip']; $result[] = $Olt['snmp']; $result[] = $Olt['modelid']; } return($result); } /** * Get onu data mac and olt ID to which onu is linked * * @param string $login * * @return array */protected function GetOnuMac($login) { $allOnu = $this->allOnu; $result = array(); if (!empty($allOnu)) { foreach ($allOnu as $eachOnu => $each) { if ($each['login'] == $login) { $result[] = $each['mac']; $result[] = $each['oltid']; } } } return $result; } /** * Format heximal mac address to decimal or show error * * @param string $macOnu * * @return string */protected function MacHexToDec($macOnu) { if (check_mac_format($macOnu)) { $res = array(); $args = explode(":", $macOnu); foreach ($args as $each) { $res[] = hexdec($each); } $string = implode(".", $res); return ($string); } else { show_error("Wrong mac format (shoud be XX:XX:XX:XX:XX:XX)"); } } /** * Get snmp index which linked to onu * * @param string $macOnu * @param string $oltIp * @param string $oltCommunity * * @return int */protected function GetClientIface($macOnu, $oltIp, $oltCommunity, $ifindex) { $macOnuRew = $this->MacHexToDec($macOnu); $interface = ($ifindex . "." . $macOnuRew); $OltInt = @snmp2_get($oltIp, $oltCommunity, $interface); $index = explode(":", $OltInt); if (isset($index[1])) { $tmp = trim($index[1]); return($tmp); } else { return (false); } } /** * Check wheather vlan already exists (if exists return false, if not return true) * * @param int $vlan * @param string $oltIp * @param string $oltCommunity * * @return bool */protected function CheckOltVlan($vlan, $oltIp, $oltCommunity, $oid) { $tmp = @snmp2_get($oltIp, $oltCommunity, $oid . "." . $vlan); $tmp = trim(str_replace("INTEGER:", '', $tmp)); if ($tmp == '1') { $res = false; } else { $res = true; } return ($res); } /** * Changes onu pvid by snmp query and if needed creates vlan * * @param string $login * @param int $vlan * * @return string */public function ChangeOnuPvid($login, $vlan, $onu_port = '1') { $OnuData = $this->GetOnuMac($login); if (!empty($OnuData)) { $OnuMac = $OnuData[0]; $oltId = $OnuData[1]; $oltData = $this->GetOltData($oltId); if (!empty($oltData)) { $oltIp = $oltData[0]; $oltCommunity = $oltData[1]; $template = $this->GetOltModelTemplate($oltData[2]); if (!empty($template)) { if (file_exists('config/snmptemplates/' . $template)) { $iniData = rcms_parse_ini_file('config/snmptemplates/' . $template, true); if ($iniData['vlan']['VLANMODE'] == 'BDCOM_B') { $vlanCreateOid = $iniData['vlan']['CREATE']; $ChangeOnuPvidOid = $iniData['vlan']['PVID']; $SaveConfigOid = $iniData['vlan']['SAVE']; $CheckVlanOid = $iniData['vlan']['CHECK']; $IfIndexOid = $iniData['vlan']['IFINDEX']; $IfIndex = $this->GetClientIface($OnuMac, $oltIp, $oltCommunity, $IfIndexOid); if ($IfIndex) { $VlanCheck = $this->CheckOltVlan($vlan, $oltIp, $oltCommunity, $CheckVlanOid); $data = array(); if ($VlanCheck) { //create vlan on OLT $data[] = array( 'oid' => $vlanCreateOid . "." . $vlan, 'type' => 'i', 'value' => '4' ); } //Change pvid on onu port by default port 1 $data[] = array( 'oid' => $ChangeOnuPvidOid . "." . $IfIndex . "." . $onu_port, 'type' => 'i', 'value' => "$vlan" ); $data[] = array( 'oid' => $SaveConfigOid, 'type' => 'i', 'value' => '1' ); $result = $this->snmp->set($oltIp, $oltCommunity, $data); $result .= $this->AutoConfig->CreateVlanLooped($oltId, $vlan, false); return ($result); } else { show_error(__('Cant find onu')); } } //hacks for BDCOM 3310C if ($iniData['vlan']['VLANMODE'] == 'BDCOM_C') { $vlanCreateOid = $iniData['vlan']['CREATE']; $ChangeOnuPvidOid = $iniData['vlan']['PVID']; $SaveConfigOid = $iniData['vlan']['SAVE']; $CheckVlanOid = $iniData['vlan']['CHECK']; $allOnuOid = $iniData['signal']['MACINDEX']; snmp_set_oid_output_format(SNMP_OID_OUTPUT_NUMERIC); $allOnu = @snmp2_real_walk($oltIp, $oltCommunity, $allOnuOid); $searchArray = array(); if (!empty($allOnu)) { foreach ($allOnu as $eachIndex => $eachOnu) { $eachIndex = trim(str_replace($allOnuOid . '.', '', $eachIndex)); $eachOnu = strtolower(trim(str_replace($iniData['signal']['MACVALUE'], '', $eachOnu))); $eachOnuMacArray = explode(" ", $eachOnu); $eachOnuMac = implode(":", $eachOnuMacArray); $searchArray[$eachOnuMac] = $eachIndex; } if (!empty($searchArray) and isset($searchArray[$OnuMac])) { $IfIndex = $searchArray[$OnuMac]; $VlanCheck = $this->CheckOltVlan($vlan, $oltIp, $oltCommunity, $CheckVlanOid); $data = array(); if ($VlanCheck) { //create vlan on OLT $data[] = array( 'oid' => $vlanCreateOid . "." . $vlan, 'type' => 'i', 'value' => '4' ); } //Change pvid on onu port by default port 1 $data[] = array( 'oid' => $ChangeOnuPvidOid . "." . $IfIndex . "." . $onu_port, 'type' => 'i', 'value' => "$vlan" ); $data[] = array( 'oid' => $SaveConfigOid, 'type' => 'i', 'value' => '1' ); $result = $this->snmp->set($oltIp, $oltCommunity, $data); $result .= $this->AutoConfig->CreateVlanLooped($oltId, $vlan, false); return ($result); } else { show_error(__('Cant find onu')); } } } if ($iniData['signal']['SIGNALMODE'] == 'ZTE') { $UniIndex = ''; $allCards = array(); $allCardsRange = array(); $OnuUniRange = array(); $FoundCardData = ''; $ChangeOnuPvidOid = $iniData['vlan']['PVID']; $ChangeOnuPvidAddOid = $iniData['vlan']['ADDUNI']; $GetAllOnuOid = $iniData['vlan']['ALLONU']; $AllCardsOid = $iniData['vlan']['ALLCARDS']; $ApplyOnuPvidOid = $iniData['vlan']['PVID']; $ChangeOnuTrunkOid = $iniData['vlan']['TRUNK']; $ChangeOnuTrunkAddOid = $iniData['vlan']['ADDPON']; $AllOnu = @snmp2_real_walk($oltIp, $oltCommunity, $GetAllOnuOid); $zteFormat = explode(":", $OnuMac); $zteFormatMac = $zteFormat[0] . $zteFormat[1] . '.' . $zteFormat[2] . $zteFormat[3] . '.' . $zteFormat[4] . $zteFormat[5]; foreach ($AllOnu as $index => $eachOnu) { $eachOnu = trim(str_replace('Hex-STRING:', '', $eachOnu)); if ($eachOnu == $zteFormatMac) { $UniIndex = str_replace($GetAllOnuOid, '', $index); } } if (empty($UniIndex)) { show_error(__('Cant find onu')); die(); } if (!empty($UniIndex)) { //Need to find out what cards installed into OLT. //Then need expand array of all possible UNI IDs. //Then need expand array of all possible PON port IDs. //Maybe make some advanced search by found out slot and port and expand array for onu pon ports //only for founded slot and port. It could be usefull if many slots and ports are used. $allCards = @snmp2_real_walk($oltIp, $oltCommunity, $AllCardsOid); if (!empty($allCards)) { foreach ($allCards as $cardIndex => $eachCard) { $startId = 805830912; $searchIndex[] = $AllCardsOid . '.0.0.'; $searchIndex[] = $AllCardsOid . '.1.1.'; $cardIndex = str_replace($searchIndex, '', $cardIndex); $searchCard4[] = '/EPFC/'; $searchCard4[] = '/EPFCB/'; $searchCard8[] = '/ETGO/'; if (preg_match($searchCard4, $eachCard)) { $counter = $startId + (524288 * ($cardIndex - 1)); for ($i = 1; $i <= 4; $i++) { $allCardsRange[$cardIndex][$i][]['start'] = $counter; $allCardsRange[$cardIndex][$i][]['end'] = $counter + (64 * 256); $counter += 65536; } } if (preg_match($searchCard8, $eachCard)) { $counter = $startId + (524288 * ($cardIndex - 1)); for ($i = 1; $i <= 8; $i++) { $allCardsRange[$cardIndex][$i][]['start'] = $counter; $allCardsRange[$cardIndex][$i][]['end'] = $counter + (64 * 256); $counter += 65536; } } } } else { show_error(__('No cards found on OLT')); die(); } if (!empty($allCardsRange)) { foreach ($allCardsRange as $CardNumber) { foreach ($CardNumber as $PortNumber => $range) { if ($UniIndex > $range['start'] AND $UniIndex < $range['end']) { $FoundCardData['card'] = $CardNumber; $FoundCardData['port'] = $PortNumber; } } } } else { show_error(__('No suitable cards found on OLT. Supported: EPFC, EPFCB, ETGO.')); die(); } if (!empty($FoundCardData)) { //Make array of all available onu number for onu and find it out $UniIdStart = 805830912; $UniIdCard = $UniIdStart + (524288 * ($FoundCardData['card'] - 1)); $UniIdPort = $UniIdCard + (65536 * ($FoundCardData['port'] - 1)); for ($i = 1; $i <= 64; $i++) { $OnuUniRange[$UniIdCard] = $i; $UniIdCard += 256; } $onuNumber = $OnuUniRange[$UniIndex]; //ONU PON PORT FIND PART $OnuPonStartId = 1073741824; $OnuPonPortOltCardId = $OnuPonStartId + (524288 * ($FoundCardData['card'] - 1)); $OnuPonPortOltPortId = $OnuPonPortOltCardId + (65536 * ($FoundCardData['port'] - 1)); $OnuPonPortId = $OnuPonPortOltPortId + (256 * ($onuNumber - 1)); $snmpSet = $this->altCfg['SNMPSET_PATH']; $result = ''; $result .= shell_exec($snmpSet . ' -c ' . $oltCommunity . ' ' . $oltIp . ' ' . $ChangeOnuPvidAddOid . $UniIndex . '.1' . ' i 2 ' . $ChangeOnuPvidOid . $UniIndex . '.1' . ' i ' . $vlan); $result .= shell_exec($snmpSet . ' -c ' . $oltCommunity . ' ' . $oltIp . ' ' . $ApplyOnuPvidOid . $UniIndex . '.1' . ' i 2'); $result .= shell_exec($snmpSet . ' -c ' . $oltCommunity . ' ' . $oltIp . ' ' . $ChangeOnuTrunkAddOid . $OnuPonPortId . ' i 1 ' . $ChangeOnuTrunkOid . ' i ' . $vlan); $result .= $this->AutoConfig->CreateVlanLooped($oltId, $vlan, false); return($result); } else { show_error(__('Onu is out of range of supported cards.')); die(); } } } } else { show_error(__('SNMP template for OTL file not exists for modelid' . ' ' . $oltData[2])); } } else { show_error(__('No snmp template for OLT found') . ' modelid ' . $oltData[2]); } } else { show_error(__('No olt data found for oltid' . ' ' . $oltId)); } } else { show_error(__('No pair onu->login found in PONizer')); } } }/** * Get users login by IP * * @param string $ip * * @return string */function UserGetLoginByIP($ip) { $login = ''; $query = "SELECT * FROM `users` WHERE `ip`='" . $ip . "'"; $res = simple_query($query); if (!empty($res)) { $login = $res['login']; } return($login); }function GetAllUserIp() { $query = "SELECT ip,login FROM `users`"; $data = simple_queryall($query); $result = array(); if (!empty($data)) { foreach ($data as $each) { $result[$each['ip']] = $each['login']; } } return($result); }/** * * @return type */function GetAllUserVlan() { $query = "SELECT * FROM `vlanhosts`"; $result = array(); $data = simple_queryall($query); if (!empty($data)) { foreach ($data as $each) { $result[$each['login']] = $each['vlan']; } } return($result); }function GetAllUserOnu() { $query = "SELECT * FROM `pononu`"; $result = array(); $data = simple_queryall($query); if (!empty($data)) { foreach ($data as $each) { $result[$each['login']] = $each; } } return($result); }function loadOltDevices() { $allOlts = array(); $query = "SELECT `switches`.`id`,`switches`.`modelid`,`switchmodels`.`snmptemplate` from `switches` LEFT JOIN `switchmodels` ON (`switches`.`modelid` = `switchmodels`.`id`) WHERE `switches`.`desc` LIKE '%OLT%';"; $raw = simple_queryall($query); if (!empty($raw)) { foreach ($raw as $io => $each) { $allOlts[$each['id']] = $each; } } return($allOlts); }function loadOltSnmpTemplates() { $allOlts = loadOltDevices(); $allOltSnmpTemplates = array(); if (!empty($allOlts)) { foreach ($allOlts as $oltId => $eachOltData) { $templateFile = 'config/snmptemplates/' . $eachOltData['snmptemplate']; $privateTemplateFile = DATA_PATH . 'documents/mysnmptemplates/' . $eachOltData['snmptemplate']; if (file_exists($templateFile)) { $allOltSnmpTemplates[$eachOltData['id']] = rcms_parse_ini_file($templateFile, true); if (file_exists($privateTemplateFile)) { $allOltSnmpTemplates[$eachOltData['id']] = rcms_parse_ini_file($privateTemplateFile, true); } } } } return($allOltSnmpTemplates); }/** * Get users vlan by login * * @param string $login * * @return int */function UserGetVlan($login) { $query = "select vlan from vlanhosts where login='" . $login . "'"; $vlan = simple_query($query); $result = ''; if (!empty($vlan)) { $result = $vlan['vlan']; } return $result; }/** * Get network id by ip * * @param string $ip * * @return int */function GetNetidByIP($ip) { $query = "SELECT `netid` FROM `nethosts` WHERE `ip`='" . $ip . "'"; $res = simple_query($query); $result = ''; if (!empty($res)) { $result = $res['netid']; } return $result; }/** * Get vlan terminators remote id by network id * * @param int $netid * * @return string */function GetTermRemoteByNetid($netid) { $query = "SELECT `remote-id` FROM `vlan_terminators` where `netid`='" . $netid . "'"; $remote = simple_query($query); $result = ''; if (!empty($remote)) { $result = $remote['remote-id']; } return $result; }/** * * @param string $login * * @return string */function web_ProfileVlanControlForm($login) { $login = mysql_real_escape_string($login); $query = "SELECT * from `vlanhosts` WHERE `login`='" . $login . "'"; $formStyle = 'glamour'; $alterconf = rcms_parse_ini_file(CONFIG_PATH . 'alter.ini'); if ($alterconf['VLAN_IN_PROFILE'] == 1) { $data = simple_query($query); if (!empty($data)) { $current_vlan = $data ['vlan']; $current_vlan_pool = $data['vlanpoolid']; $query_desc = "SELECT * FROM `vlan_pools` WHERE `id`='" . $current_vlan_pool . "'"; $current_vlan_pool_desc = simple_query($query_desc); $current_vlan_pool_descr = $current_vlan_pool_desc['desc']; $cells = wf_TableCell(__('Vlan Pool'), '30%', 'row2'); $cells .= wf_TableCell($current_vlan_pool_descr); $rows = wf_TableRow($cells, 'row3'); $cells = wf_TableCell(__('Vlan'), '30%', 'row2'); $cells .= wf_TableCell($current_vlan); $rows .= wf_TableRow($cells, 'row3'); $result = wf_TableBody($rows, '100%', '0'); return($result); } } }/** * Function for deleting entry from DB * * @param string $login * * @return void */function vlan_delete_host($login) { $query = "DELETE FROM `vlanhosts` WHERE `login`='" . $login . "'"; nr_query($query); log_register("DELETE VLanHost (" . $login . ")"); } |