Source of file api.switchportassign.php

<?php

/**

 * Users to switch port assign basic implementation

 */

class SwitchPortAssign {

    /**

     * Contains system alter config as key=>value

     *

     * @var array

     */

    protected $altCfg = array();

    /**

     * Assigns database abstraction layer

     * 

     * @var object

     */

    protected $assignsDb = '';

    /**

     * Contains all available switches data

     * 

     * @var array

     */

    protected $allSwitches = array();

    /**

     * Contains all available switchport assigns as id=>id/login/switchid/port

     * 

     * @var array

     */

    protected $allAssigns = array();

    /**

     * Some predefined stuff

     */

    const TABLE_ASSIGNS = 'switchportassign';

    const PROUTE_LOGIN = 'swassignlogin';

    const PROUTE_SWITCH = 'swassignswid';

    const PROUTE_PORT = 'swassignswport';

    const PROUTE_DELETE = 'swassigndelete';

    public function __construct() {

        $this->loadAlter();

        $this->initDb();

        $this->loadSwitches();

        $this->loadAssigns();

    }

    /**

     * Loads system alter config into protected prop

     * 

     * @global object $ubillingConfig

     * 

     * @return void

     */

    protected function loadAlter() {

        global $ubillingConfig;

        $this->altCfg = $ubillingConfig->getAlter();

    }

    /**

     * Inits assigns database abstraction layer

     * 

     * @return void

     */

    protected function initDb() {

        $this->assignsDb = new NyanORM(self::TABLE_ASSIGNS);

    }

    /**

     * 

     * @return void

     */

    protected function loadSwitches() {

        $this->allSwitches = $this->getAllSwitches();

    }

    /**

     * Returns coinfurable switches array

     * 

     * @return array

     */

    protected function getAllSwitches() {

        $result = array();

        //optional switches arrange

        switch ($this->altCfg['SWITCHPORT_IN_PROFILE']) {

            //switch selector arranged by id (default)

            case 1:

                $result = zb_SwitchesGetAll();

                break;

            //switch selector arranged by location

            case 2:

                $result = zb_SwitchesGetAll('ORDER BY `location` ASC');

                break;

            //switch selector arranged by ip

            case 3:

                $result = zb_SwitchesGetAll('ORDER BY `ip` ASC');

                break;

            //switch selector arranged by id (default)

            case 4:

                $result = zb_SwitchesGetAll();

                break;

            default :

                $result = zb_SwitchesGetAll();

                break;

        }

        return($result);

    }

    /**

     * Loads all assigns data into protected prop

     * 

     * @return void

     */

    protected function loadAssigns() {

        $this->allAssigns = $this->assignsDb->getAll('id');

    }

    /**

     * Returns some user assign data if it exists

     * 

     * @param string $login

     * 

     * @return array

     */

    public function getAssignData($login) {

        $result = array();

        if (!empty($this->allAssigns)) {

            foreach ($this->allAssigns as $io => $each) {

                if ($each['login'] == $login) {

                    $result = $each;

                    break;

                }

            }

        }

        return($result);

    }

    /**

     * Checks is switch-port pair free or not

     * 

     * @param int $switchId

     * @param int $port

     * 

     * @return bool

     */

    protected function isPortFree($switchId, $port) {

        $result = true;

        if (!empty($this->allSwitches)) {

            if ((!empty($switchId)) AND (!empty($port))) {

                foreach ($this->allAssigns as $io => $each) {

                    if ($each['switchid'] == $switchId AND $each['port'] == $port) {

                        $result = false;

                    }

                }

            }

        } else {

            $result = false;

        }

        return($result);

    }

    /**

     * Returns all other users with assigned same port on the same switch

     * 

     * @param string $login

     * @param int $currentSwitchPort

     * @param int $currentSwitchId

     * 

     * @return array

     */

    protected function getSameUsers($login, $currentSwitchPort, $currentSwitchId) {

        $result = array();

        $currentSwitchId = ubRouting::filters($currentSwitchId, 'int');

        $currentSwitchPort = ubRouting::filters($currentSwitchPort, 'int');

        if (!empty($login) AND !empty($currentSwitchId) AND !empty($currentSwitchPort)) {

            if (!empty($this->allAssigns)) {

                foreach ($this->allAssigns as $io => $each) {

                    if ($each['switchid'] == $currentSwitchId AND $each['port'] == $currentSwitchPort) {

                        if ($each['login'] != $login) {

                            $result[$each['login']] = $each;

                        }

                    }

                }

            }

        }

        return($result);

    }

    /**

     * Deletes existing assign database record by user login

     * 

     * @param string $login

     * 

     * @return void

     */

    public function delete($login) {

        $login = ubRouting::filters($login, 'mres');

        $this->assignsDb->where('login', '=', $login);

        $this->assignsDb->delete();

        log_register('SWITCHPORT DELETE (' . $login . ')');

        // Rebuild DHCP configuration if switch used on option82

        if ($this->altCfg['OPT82_ENABLED']) {

            $loginNetType = multinet_get_network_params_by_login($login);

            if (!empty($loginNetType) and $loginNetType['nettype'] = 'dhcp82') {

                multinet_rebuild_all_handlers();

            }

        }

    }

    /**

     * Creates new or updates existing assign record

     * 

     * @param string $login

     * @param int $switchId

     * @param int $port

     * 

     * @return void/string on error

     */

    public function save($login, $switchId, $port) {

        $result = '';

        $newAssignLoging = ubRouting::filters($login, 'mres');

        $newSwitchId = ubRouting::filters($switchId, 'int');

        $newPort = ubRouting::filters($port, 'int');

        if ($this->isPortFree($newSwitchId, $newPort)) {

            $currenAssignData = $this->getAssignData($login);

            //creating new assign

            if (empty($currenAssignData)) {

                $this->assignsDb->data('login', $login);

                $this->assignsDb->data('switchid', $newSwitchId);

                $this->assignsDb->data('port', $newPort);

                $this->assignsDb->create();

            } else {

                //updating existing record

                $this->assignsDb->where('login', '=', $login);

                $this->assignsDb->data('switchid', $newSwitchId);

                $this->assignsDb->data('port', $newPort);

                $this->assignsDb->save();

            }

            log_register('SWITCHPORT CHANGE (' . $login . ') ON SWITCHID [' . $newSwitchId . '] PORT [' . $newPort . ']');

            // Rebuild DHCP configs if switch used on option82

            if ($this->altCfg['OPT82_ENABLED']) {

                $loginNetType = multinet_get_network_params_by_login($login);

                if (!empty($loginNetType) and $loginNetType['nettype'] = 'dhcp82') {

                    multinet_rebuild_all_handlers();

                }

            }

        } else {

            log_register('SWITCHPORT FAIL (' . $login . ') ON SWITCHID [' . $newSwitchId . '] PORT [' . $newPort . ']');

            $result .= __('Port already assigned for another user');

        }

        return($result);

    }

    /**

     * Switchport modification controller

     * 

     * @param string $returnUrl

     * 

     * @return void

     */

    public function catchChangeRequest($returnUrl = '') {

        //update

        if (ubRouting::checkPost(array(self::PROUTE_LOGIN, self::PROUTE_SWITCH, self::PROUTE_PORT))) {

            $updateResult = $this->save(ubRouting::post(self::PROUTE_LOGIN), ubRouting::post(self::PROUTE_SWITCH), ubRouting::post(self::PROUTE_PORT));

            if (empty($updateResult)) {

                if (!empty($returnUrl)) {

                    ubRouting::nav($returnUrl);

                }

            } else {

                show_error($updateResult);

            }

        }

        //delete

        if (ubRouting::post(self::PROUTE_DELETE)) {

            $assignToDelete = ubRouting::post(self::PROUTE_LOGIN);

            $this->delete($assignToDelete);

            if (!empty($returnUrl)) {

                ubRouting::nav($returnUrl);

            }

        }

    }

    /**

     * Returns users switch port assign form

     * 

     * @param string $login

     * 

     * @return string

     */

    public function renderEditForm($login) {

        $result = '';

        $login = ubRouting::filters($login, 'mres');

        $switcharr = array();

        $switcharrFull = array();

        $switchswpoll = array();

        $switchgeo = array();

        $sameArr = array();

        $sameUsers = '';

        $currentSwitchPort = '';

        $currentSwitchId = '';

        $assignData = $this->getAssignData($login);

        if (!empty($this->allSwitches)) {

            foreach ($this->allSwitches as $io => $eachswitch) {

                $switcharrFull[$eachswitch['id']] = $eachswitch['ip'] . ' - ' . $eachswitch['location'];

                if (mb_strlen($eachswitch['location']) > 32) {

                    $switcharr[$eachswitch['id']] = $eachswitch['ip'] . ' - ' . mb_substr($eachswitch['location'], 0, 32, 'utf-8') . '...';

                } else {

                    $switcharr[$eachswitch['id']] = $eachswitch['ip'] . ' - ' . $eachswitch['location'];

                }

                if (ispos($eachswitch['desc'], 'SWPOLL')) {

                    $switchswpoll[$eachswitch['id']] = $eachswitch['ip'];

                }

                if (!empty($eachswitch['geo'])) {

                    $switchgeo[$eachswitch['id']] = $eachswitch['geo'];

                }

            }

        }

        if (!empty($assignData)) {

            $currentSwitchPort = $assignData['port'];

            $currentSwitchId = $assignData['switchid'];

            $sameArr = $this->getSameUsers($login, $currentSwitchPort, $currentSwitchId);

        }

        //rendering other users with same switch+port 

        if ((!empty($currentSwitchId)) AND (!empty($currentSwitchPort))) {

            if (!empty($sameArr)) {

                foreach ($sameArr as $ip => $each) {

                    $sameUsers .= ' ' . wf_Link(UserProfile::URL_PROFILE . $each['login'], web_profile_icon() . ' ' . $each['login'], false, '');

                }

            }

        }

        //control form construct

        $formStyle = 'glamour';

        $inputs = wf_HiddenInput(self::PROUTE_LOGIN, $login);

        if ($this->altCfg['SWITCHPORT_IN_PROFILE'] != 4) {

            $inputs .= wf_Selector(self::PROUTE_SWITCH, $switcharr, __('Switch'), $currentSwitchId, true);

        } else {

            $inputs .= wf_JuiComboBox(self::PROUTE_SWITCH, $switcharr, __('Switch'), $currentSwitchId, true);

            $formStyle = 'floatpanelswide';

        }

        $inputs .= wf_TextInput(self::PROUTE_PORT, __('Port'), $currentSwitchPort, false, 2, 'digits');

        $inputs .= wf_CheckInput(self::PROUTE_DELETE, __('Delete'), true, false);

        $inputs .= wf_Submit('Save');

        $controlForm = wf_Form('', "POST", $inputs, $formStyle);

        //form end

        $switchAssignController = wf_modalAuto(web_edit_icon(), __('Switch port assign'), $controlForm);

        //switch location and polling controls

        $switchLocators = '';

        if (!empty($currentSwitchId)) {

            $switchProfileIcon = wf_img_sized('skins/switch16.png', __('Switch'), 10, 10);

            $switchLocators .= wf_Link('?module=switches&edit=' . $currentSwitchId, $switchProfileIcon, false, '');

        }

        if (isset($switchswpoll[$currentSwitchId])) {

            $snmpSwitchLocatorIcon = wf_img_sized('skins/snmp.png', __('SNMP query'), 10, 10);

            $switchLocators .= wf_Link('?module=switchpoller&switchid=' . $currentSwitchId, $snmpSwitchLocatorIcon, false, '');

        }

        if (isset($switchgeo[$currentSwitchId])) {

            $geoSwitchLocatorIcon = wf_img_sized('skins/icon_search_small.gif', __('Find on map'), 10, 10);

            $switchLocators .= wf_Link('?module=switchmap&finddevice=' . $switchgeo[$currentSwitchId], $geoSwitchLocatorIcon, false, '');

        }

        $cells = wf_TableCell(__('Switch'), '30%', 'row2');

        $cells .= wf_TableCell(@$switcharrFull[$currentSwitchId] . ' ' . $switchLocators);

        $rows = wf_TableRow($cells, 'row3');

        $cells = wf_TableCell(__('Port'), '30%', 'row2');

        $cells .= wf_TableCell($currentSwitchPort);

        $rows .= wf_TableRow($cells, 'row3');

        $cells = wf_TableCell(__('Change'), '30%', 'row2');

        $cells .= wf_TableCell($switchAssignController . ' ' . $sameUsers);

        $rows .= wf_TableRow($cells, 'row3');

        $result = wf_TableBody($rows, '100%', '0');

        return($result);

    }

}