ChPollDb.php

Go to the documentation of this file.

<?php
 
require_once( CH_DIRECTORY_PATH_CLASSES . 'ChWsbModuleDb.php' );
 
class ChPollDb extends ChWsbModuleDb
{
    var $_oConfig;
    var $_sTable;
    var $sTablePrefix;
 
    /*
     * Constructor.
     */
    function __construct(&$oConfig)
    {
        parent::__construct();
 
        $this -> _oConfig       = $oConfig;
        $this -> _sTable        = $oConfig -> sTableName;
        $this -> sTablePrefix   = $oConfig -> sTablePrefix;
    }
 
    function getAllPolls($sLimit, $iMemberID = 0, $bAllPolls = false, $iApproval = 1, $sExtraSql = null, $sOrder = '`poll_date` DESC')
    {
        $sLimit = $this -> escape($sLimit, false);
        $iMemberID = (int) $iMemberID;
        $iApproval = (int) $iApproval;
        $sExtraSql = $this -> escape($sExtraSql, false);
        $sOrder = $this -> escape($sOrder, false);
 
        // ** init some needed variables ;
 
        $sAddonSql       = null;
        $aWhereCondition = array();
 
        $aWhereCondition[0] = " AND `poll_status`   = 'active' ";
        $aWhereCondition[1] = " AND `poll_approval` = {$iApproval}";
        $aWhereCondition[2] = " AND `id_profile`    = {$iMemberID} ";
 
        // if need the only member's pools ;
        if ( !$bAllPolls ) {
            if ( $iMemberID  ) {
                $sAddonSql  = $aWhereCondition[1] . $aWhereCondition[2];
            } else {
                $sAddonSql  = $aWhereCondition[0] . $aWhereCondition[1];
            }
        }
 
        $sQuery =
        "
            SELECT
                `id_poll`,
                `id_profile`,
                `poll_date`,
                (UNIX_TIMESTAMP() - `poll_date`) AS 'sec',
                `poll_approval`,
                `poll_featured`
            FROM
                `{$this -> _sTable}`
            WHERE
                1
                {$sAddonSql}
                {$sExtraSql}
            ORDER BY
                {$sOrder}
            {$sLimit}
        ";
 
        return $this -> getAll($sQuery);
    }
 
    function getFeaturedCount($iStatus = 1, $bOnlyPublic = false)
    {
        $iStatus = (int) $iStatus;
        settype($bOnlyPublic, 'boolean');
 
        $sExtraSql = $bOnlyPublic ? ' AND `allow_view_to` = ' . CH_WSB_PG_ALL : null;
        $sQuery = "SELECT COUNT(*) FROM  `{$this -> _sTable}` WHERE `poll_featured` = {$iStatus} {$sExtraSql}";
        return $this -> getOne($sQuery);
    }
 
    function getAllFeaturedPolls($sLimit, $iStatus = 1, $bOnlyPublic = false)
    {
        $sLimit = $this -> escape($sLimit, false);
        $iStatus = (int) $iStatus;
        settype($bOnlyPublic, 'boolean');
 
        $sExtraSql = $bOnlyPublic ? ' AND `allow_view_to` = ' . CH_WSB_PG_ALL : null;
        $sQuery = "SELECT *, UNIX_TIMESTAMP()-`poll_date` AS `poll_ago` FROM `{$this -> _sTable}` WHERE `poll_status`='active' AND `poll_approval`='1' AND `poll_featured`='{$iStatus}' {$sExtraSql} ORDER BY `poll_date` DESC {$sLimit}";
        return $this -> getAll($sQuery);
    }
 
    function getPollsCount($iMemberID = 0, $bAllPools = false, $iApproval = 1, $sExtraSql = null)
    {
        $iMemberID = (int) $iMemberID;
//        $bOnlyPublic = (bool) $bOnlyPublic;
        $iApproval = (int) $iApproval;
        $sExtraSql = $this -> escape($sExtraSql, false);
 
        // ** init some needed variables ;
 
        $sAddonSql       = null;
        $aWhereCondition = array();
 
        $aWhereCondition[0] = " AND `poll_status`   = 'active' ";
        $aWhereCondition[1] = " AND `poll_approval` = {$iApproval} ";
        $aWhereCondition[2] = " AND `id_profile`    = {$iMemberID} ";
 
        // if need the only member's pools ;
        $sIsEmpty = true;
        if ( $iMemberID  ) {
            if ( !$bAllPools ) {
                // only approved  member's polls ;
                $sAddonSql  = $aWhereCondition[1] . $aWhereCondition[2];
            } else {
                $sAddonSql  = $aWhereCondition[2];
            }
        } else {
            if ( !$bAllPools ) {
                $sAddonSql  = $aWhereCondition[0] . $aWhereCondition[1];
            }
        }
 
        $sQuery =
        "
        SELECT
            COUNT(*)
        FROM
            `{$this -> _sTable}`
        WHERE
            1
            {$sAddonSql}
            {$sExtraSql}
        ";
 
        return $this -> getOne($sQuery);
    }
 
 
    function getUnApprovedPolls($iProfileId)
    {
        $iProfileId = (int) $iProfileId;
 
        $sQuery = "SELECT COUNT(*) FROM `{$this -> _sTable}` WHERE `poll_approval` = 0 AND `id_profile` = {$iProfileId}";
        return $this -> getOne($sQuery);
    }
 
    function getPollInfo($iPollId)
    {
        $iPollId = (int) $iPollId;
 
        $sQuery ="SELECT *, UNIX_TIMESTAMP()-`poll_date` AS 'poll_ago' FROM `{$this -> _sTable}` WHERE `id_poll` = {$iPollId}";
        return $this -> getAll($sQuery);
    }
 
    function setVotes( $iPollId, $sVotes, $iVotesCount )
    {
        $iPollId = (int) $iPollId;
        $sVotes = process_db_input($sVotes, CH_TAGS_STRIP);
        $iVotesCount = (int) $iVotesCount;
 
        $sQuery =
        "
            UPDATE
                `{$this -> _sTable}`
            SET
                `poll_results`      = '{$sVotes}',
                `poll_total_votes`  = {$iVotesCount}
            WHERE
                `id_poll` = {$iPollId}
        ";
 
        return $this -> query($sQuery);
    }
 
    function setOption($iPollId, $sAction = 'approval')
    {
        $iPollId = (int) $iPollId;
 
        $sQuery =
        "
            UPDATE
                `{$this -> _sTable}`
            SET
                `poll_{$sAction}` = IF (`poll_{$sAction}` = 1, 0, 1)
            WHERE
               `id_poll` = {$iPollId}
        ";
 
        return $this -> query($sQuery);
    }
 
    function createPoll($aPoolInfo, $isAdmin = false)
    {
        $isAdmin = (bool) $isAdmin;
 
        if( !is_array($aPoolInfo) ) {
            return;
        }
 
        // process recived array
        foreach($aPoolInfo as $sKey => $sValue) {
            $aPoolInfo[$sKey] = process_db_input($sValue, CH_TAGS_NO_ACTION
                , CH_SLASHES_AUTO);
        }
 
        // ** init some needed variables ;
 
        $iPollsCount = -1;
        $iAutoActive =  1;
        $iResponse   =  0;
 
        if ($aPoolInfo['owner_id']) {
            $iPollsCount = $this -> getPollsCount( $aPoolInfo['owner_id'], true );
            $iAutoActive = ($this -> _oConfig -> iAutoActivate) ? 1 : 0;
 
            if (!$this -> _oConfig -> iAlowMembersPolls) {
                return 0;
            }
        }
 
        if ($iPollsCount < $this -> _oConfig -> iAlowPollNumber || $isAdmin) {
            $iCurrentDate = date('U');
            $sQuery =
            "
                INSERT INTO
                    `{$this -> _sTable}`
                SET
                    `id_profile`        = {$aPoolInfo['owner_id']},
                    `poll_question`     = '{$aPoolInfo['question']}',
                    `poll_answers`      = '{$aPoolInfo['answers']}',
                    `poll_results`      = '{$aPoolInfo['results']}',
                    `poll_status`       = 'active',
                    `poll_approval`     = {$iAutoActive},
                    `poll_date`         = {$iCurrentDate},
                    `poll_tags`         = '{$aPoolInfo['tags']}',
                    `allow_comment_to`  = {$aPoolInfo['allow_comment']},
                    `allow_vote_to`     = {$aPoolInfo['allow_vote']},
                    `poll_categories`   = '{$aPoolInfo['category']}',
                    `allow_view_to`     = '{$aPoolInfo['allow_view']}'
            ";
 
            $this -> query($sQuery);
            $iResponse = 1;
        } else {
            $iResponse = 2;
        }
 
        return $iResponse;
    }
 
    function editPoll($aPoolInfo)
    {
        if( !is_array($aPoolInfo) ) {
            return;
        }
 
        // procces recived array
        foreach($aPoolInfo as $sKey => $sValue) {
            if($sKey != 'answers' ) {
                $aPoolInfo[$sKey] = process_db_input($sValue, CH_TAGS_STRIP);
            } else {
                $aPoolInfo[$sKey] = process_db_input($sValue);
            }
        }
 
        // ** init some neede variables ;
 
        $sAddonSql = null;
 
        if ( isset($aPoolInfo['approve']) ) {
            $sAddonSql = ( $aPoolInfo['approve'] )
                ? ',`poll_approval` = 1'
                : ',`poll_approval` = 0';
        }
 
        $sQuery =
        "
            UPDATE
              `{$this -> _sTable}`
            SET
                `poll_question`     = '{$aPoolInfo['question']}',
                `poll_answers`      = '{$aPoolInfo['answers']}',
                `poll_status`       = '{$aPoolInfo['status']}',
                `poll_tags`         = '{$aPoolInfo['tags']}',
                `allow_comment_to`  = {$aPoolInfo['allow_comment']},
                `allow_vote_to`     = {$aPoolInfo['allow_vote']},
                `poll_categories`   = '{$aPoolInfo['category']}',
                `allow_view_to`     = '{$aPoolInfo['allow_view']}'
                {$sAddonSql}
            WHERE
                `id_poll` = {$aPoolInfo['Id']}
        ";
 
       return $this -> query($sQuery);
    }
 
    function deletePoll($iPollId)
    {
        $iPollId = (int) $iPollId;
        $this -> clearAttachetData($iPollId);
        $sQuery = "DELETE FROM  `{$this -> _sTable}` WHERE `id_poll` = {$iPollId}";
        return $this -> query($sQuery);
    }
 
    function clearAttachetData($iPollId)
    {
        $iPollId = (int) $iPollId;
 
        // delete from comments;
        $sQuery =
        "
            DELETE
                `{$this -> sTablePrefix}cmts`,
                `{$this -> sTablePrefix}cmts_track`
            FROM
                `{$this -> sTablePrefix}cmts`
            LEFT JOIN
                `{$this -> sTablePrefix}cmts_track`
            ON
                `{$this -> sTablePrefix}cmts_track`.`cmt_id` = `{$this -> sTablePrefix}cmts`.`cmt_id`
            WHERE
                `{$this -> sTablePrefix}cmts`.`cmt_object_id` = {$iPollId}
        ";
        db_res($sQuery);
 
        // delete from votings;
        $sQuery =
        "
            DELETE
                `{$this -> sTablePrefix}rating`,
                `{$this -> sTablePrefix}voting_track`
            FROM
                `{$this -> sTablePrefix}rating`
            LEFT JOIN
                `{$this -> sTablePrefix}voting_track`
            ON
                `{$this -> sTablePrefix}voting_track`.`id` = `{$this -> sTablePrefix}rating`.`id`
            WHERE
                `{$this -> sTablePrefix}rating`.`id` = {$iPollId}
        ";
        db_res($sQuery);
    }
 
    function getPollsByMonth ($iYear, $iMonth, $iNextYear, $iNextMonth)
    {
        $iYear = (int) $iYear;
        $iMonth = (int) $iMonth;
        $iNextYear = (int) $iNextYear;
        $iNextMonth = (int) $iNextMonth;
 
        return $this->getAll ("SELECT `id_poll`, DAYOFMONTH(FROM_UNIXTIME(`poll_date`)) AS `Day`
            FROM `{$this -> _sTable}`
            WHERE `poll_date` >= UNIX_TIMESTAMP('{$iYear}-{$iMonth}-1') AND `poll_date` < UNIX_TIMESTAMP('{$iNextYear}-{$iNextMonth}-1') AND `poll_approval` = 1");
    }
 
    function getSettingsCategory($sCatName)
    {
        $sCatName = process_db_input($sCatName, CH_TAGS_STRIP);
        return $this -> getOne('SELECT `kateg` FROM `sys_options` WHERE `Name` = "' . $sCatName . '"');
    }
}