ChWsbAlerts.php

Go to the documentation of this file.

<?php
 
class ChWsbAlerts
{
    var $sUnit;
    var $sAction;
    var $iObject;
    var $iSender;
    var $aExtras;
 
    var $_aAlerts;
    var $_aHandlers;
 
    function __construct($sUnit, $sAction, $iObjectId, $iSender = 0, $aExtras = array())
    {
        require_once(CH_DIRECTORY_PATH_INC . 'db.inc.php');
        $oDb = ChWsbDb::getInstance();
        $oCache = $oDb->getDbCacheObject();
        $aData = $oCache->getData($oDb->genDbCacheKey('sys_alerts'));
        if (null === $aData)
            $aData = ChWsbAlerts::cache();
 
        $this->_aAlerts = $aData['alerts'];
        $this->_aHandlers = $aData['handlers'];
 
        $this->sUnit = $sUnit;
        $this->sAction = $sAction;
        $this->iObject = (int)$iObjectId;
        $this->iSender = !empty($iSender) ? (int)$iSender :
            (empty($_COOKIE['memberID']) ? 0 : (int)$_COOKIE['memberID']);
        $this->aExtras = $aExtras;
    }
 
    function alert()
    {
        ch_import('ChWsbSubscription');
        $oSubscription = ChWsbSubscription::getInstance();
        $oSubscription->send($this->sUnit, $this->sAction, $this->iObject, $this->aExtras);
 
        if(isset($this->_aAlerts[$this->sUnit]) && isset($this->_aAlerts[$this->sUnit][$this->sAction]))
            foreach($this->_aAlerts[$this->sUnit][$this->sAction] as $iHandlerId) {
                $aHandler = $this->_aHandlers[$iHandlerId];
 
                if(!empty($aHandler['file']) && !empty($aHandler['class']) && file_exists(CH_DIRECTORY_PATH_ROOT . $aHandler['file'])) {
                    if(!class_exists($aHandler['class']))
                        require_once(CH_DIRECTORY_PATH_ROOT . $aHandler['file']);
 
                    $oHandler = new $aHandler['class']();
                    $oHandler->response($this);
                } else if(!empty($aHandler['eval'])) {
                    eval($aHandler['eval']);
                }
            }
    }
 
    public static function cache()
    {
        $aResult = array('alerts' => array(), 'handlers' => array());
 
        $rAlerts = db_res("SELECT `unit`, `action`, `handler_id` FROM `sys_alerts` ORDER BY `id` ASC");
        while($aAlert = $rAlerts->fetch())
            $aResult['alerts'][$aAlert['unit']][$aAlert['action']][] = $aAlert['handler_id'];
 
        $rHandlers = db_res("SELECT `id`, `class`, `file`, `eval` FROM `sys_alerts_handlers` ORDER BY `id` ASC");
        while($aHandler = $rHandlers->fetch())
            $aResult['handlers'][$aHandler['id']] = array('class' => $aHandler['class'], 'file' => $aHandler['file'], 'eval' => $aHandler['eval']);
 
 
        $oCache = $GLOBALS['MySQL']->getDbCacheObject();
        $oCache->setData ($GLOBALS['MySQL']->genDbCacheKey('sys_alerts'), $aResult);
 
        return $aResult;
    }
}
 
class ChWsbAlertsResponse
{
    function __construct(){}
    function response($oAlert) {}
}