ChShoutBoxDb.php

Go to the documentation of this file.

<?php
 
require_once(CH_DIRECTORY_PATH_CLASSES . 'ChWsbModuleDb.php');
 
class ChShoutBoxDb extends ChWsbModuleDb
{
    var $_oConfig;
 
    var $_aObjects = array();
 
    function __construct(&$oConfig)
    {
        parent::__construct();
 
        $this->_oConfig  = $oConfig;
        $this->_aObjects = $this->getShoutboxObjects();
    }
 
    function getShoutboxObjects()
    {
        if (!isset($GLOBALS['ch_dol_shoutbox_objects'])) {
            $GLOBALS['ch_dol_shoutbox_objects'] = $GLOBALS['MySQL']->fromCache('ch_shoutbox_objects', 'getAllWithKey',
                'SELECT * FROM `ch_shoutbox_objects`', 'name');
        }
 
        return $GLOBALS['ch_dol_shoutbox_objects'];
    }
 
    function clearShoutboxObjectsCache()
    {
        $this->cleanCache('ch_shoutbox_objects');
    }
 
    function writeMessage($sObject, $iHandler, $sMessage, $iOwnerId = 0, $iIP = 0)
    {
        if (!isset($this->_aObjects[$sObject])) {
            return false;
        }
 
        $sMessage = process_db_input($sMessage, 0, CH_SLASHES_AUTO);
        $iOwnerId = (int)$iOwnerId;
        if (!preg_match('/^[0-9]+$/', $iIP)) {
            $iIP = 0;
        }
 
        $sQuery =
            "
                INSERT INTO
                    `{$this -> _aObjects[$sObject]['table']}`
                SET
                    `HandlerID` = {$iHandler},
                    `OwnerID` = {$iOwnerId},
                    `Message` = '{$sMessage}',
                    `Date` = TIMESTAMP( NOW() ),
                    `IP` = {$iIP}
            ";
 
        return (int)$this->query($sQuery) > 0 ? $this->lastId() : false;
    }
 
    function getLastMessageId($sObject, $iHandler)
    {
        if (!isset($this->_aObjects[$sObject])) {
            return false;
        }
 
        $sQuery  = "SELECT `ID` FROM `{$this -> _aObjects[$sObject]['table']}` WHERE `HandlerID` = '{$iHandler}' ORDER BY `ID` DESC LIMIT 1";
        $iLastId = $this->getOne($sQuery);
 
        return ($iLastId) ? $iLastId : 0;
    }
 
    function getMessages($sObject, $iHandler, $iLastId)
    {
        if (!isset($this->_aObjects[$sObject])) {
            return false;
        }
 
        $iLastId = (int)$iLastId;
        $sQuery  = "SELECT *, UNIX_TIMESTAMP(`Date`) AS `DateTS` FROM `{$this -> _aObjects[$sObject]['table']}` WHERE `HandlerID` = '{$iHandler}' AND `ID` > " . (int)$iLastId . " ORDER BY `ID`";
 
        return $this->getAll($sQuery);
    }
 
    function getMessagesCount($sObject, $iHandler)
    {
        if (!isset($this->_aObjects[$sObject])) {
            return false;
        }
 
        $sQuery = "SELECT COUNT(*) FROM `{$this -> _aObjects[$sObject]['table']}` WHERE `HandlerID` = '{$iHandler}'";
 
        return $this->getOne($sQuery);
    }
 
    function getMessageInfo($sObject, $iHandler, $iMessageId)
    {
        if (!isset($this->_aObjects[$sObject])) {
            return array();
        }
 
        $iMessageId = (int)$iMessageId;
        $sQuery     = "SELECT * FROM `{$this -> _aObjects[$sObject]['table']}` WHERE `HandlerID` = '{$iHandler}' AND `ID` = {$iMessageId}";
        $aInfo      = $this->getAll($sQuery);
 
        return $aInfo ? array_shift($aInfo) : array();
    }
 
    function deleteMessages($sObject, $iHandler, $iLimit)
    {
        if (!isset($this->_aObjects[$sObject])) {
            return false;
        }
 
        $iLimit = (int)$iLimit;
        $sQuery = "DELETE FROM `{$this -> _aObjects[$sObject]['table']}` WHERE `HandlerID` = {$iHandler} ORDER BY `ID` LIMIT {$iLimit}";
        $this->query($sQuery);
    }
 
    function deleteMessage($sObject, $iHandler, $iMessageId)
    {
        if (!isset($this->_aObjects[$sObject])) {
            return false;
        }
 
        $iMessageId = (int)$iMessageId;
        $sQuery     = "DELETE FROM `{$this -> _aObjects[$sObject]['table']}` WHERE `HandlerID` = {$iHandler} AND `ID` = {$iMessageId}";
 
        return $this->query($sQuery);
    }
 
    function deleteMessagesByIp($sObject, $iHandler, $iIp)
    {
        if (!isset($this->_aObjects[$sObject])) {
            return false;
        }
 
        $iIp = (int)$iIp;
 
        foreach ($this->_aObjects as $a) {
            $sQuery = "DELETE FROM `{$a['table']}` WHERE `IP` = {$iIp}";
            $this->query($sQuery);
        }
    }
 
    function deleteMessagesByProfile($iProfileId)
    {
        $iProfileId = (int)$iProfileId;
        foreach ($this->_aObjects as $a) {
            $sQuery = "DELETE  FROM `{$a['table']}` WHERE `OwnerID` = {$iProfileId}";
            $this->query($sQuery);
        }
    }
 
    function deleteOldMessages($iLifeTime)
    {
        if (!is_numeric($iLifeTime)) {
            return;
        }
 
        foreach ($this->_aObjects as $a) {
            $sQuery = "DELETE FROM `{$a['table']}` WHERE FROM_UNIXTIME( UNIX_TIMESTAMP() - {$iLifeTime} ) >= `Date`";
            db_res($sQuery);
        }
    }
 
    function getSettingsCategory($sName)
    {
        return $this->getOne("SELECT `kateg` FROM `sys_options` WHERE `Name` = ?", [$sName]);
    }
 
    function insertData($aData)
    {
        foreach ($aData as $a) {
            $this->query("INSERT INTO `ch_shoutbox_objects` (`name`, `title`, `table`, `code_allow_use`, `code_allow_delete`, `code_allow_block`) VALUES (?, ?, ?, ?, ?, ?)",
                [
                    $a['name'],
                    $a['title'],
                    $a['table'],
                    $a['code_allow_use'],
                    $a['code_allow_delete'],
                    $a['code_allow_block']
                ]);
        }
    }
 
    function deleteData($aData)
    {
        foreach ($aData as $a) {
            $this->query("DELETE FROM `ch_shoutbox_objects` WHERE `name` = ?", [$a['name']]);
        }
    }
 
}