ChWsbAlbums.php

Go to the documentation of this file.

<?php
 
class ChWsbAlbums
{
    var $sAlbumTable;
    var $sAlbumObjectsTable;
    var $aAlbumFields;
    var $sType;
    var $sAlbumCoverParam;
    var $iOwnerId;
 
    function __construct($sType, $iOwnerId = 0)
    {
        $this->iOwnerId           = (int)$iOwnerId;
        $this->sType              = process_db_input($sType, CH_TAGS_STRIP);
        $this->sAlbumTable        = 'sys_albums';
        $this->sAlbumObjectsTable = 'sys_albums_objects';
        $this->aAlbumFields       = array(
            'ID',
            'Caption',
            'Uri',
            'Location',
            'Description',
            'Type',
            'Owner',
            'Status',
            'Date',
            'AllowAlbumView',
            'ObjCount',
            'LastObjId'
        );
        $this->sAlbumCoverParam   = 'sys_make_album_cover_last';
    }
 
    public static function getAbumName($sName, $iUserId)
    {
        $aReplacement = array(
            '{nickname}' => getUsername($iUserId),
            '{fullname}' => getNickName($iUserId)
        );
 
        return str_replace(array_keys($aReplacement), array_values($aReplacement), $sName);
    }
 
    public static function getAbumUri($sName, $iUserId)
    {
        return uriFilter(ChWsbAlbums::getAbumName($sName, $iUserId));
    }
 
    // inner methods
    function _getSqlPart($aFields = array(), $sBound = ', ', $bUseEmptyValues = false)
    {
        $sqlBody = "";
        foreach ($aFields as $sKey => $sValue) {
            if (in_array($sKey, $this->aAlbumFields) && ($bUseEmptyValues || strlen($sValue))) {
                switch ($sKey) {
                    case 'description':
                    case 'Description':
                        $sValue = process_db_input($sValue, CH_TAGS_STRIP_AND_NL2BR);
                        break;
 
                    default:
                        $sValue = process_db_input($sValue, CH_TAGS_STRIP);
                        break;
                }
 
                $sqlBody .= "`{$this->sAlbumTable}`.`{$sKey}` = '$sValue'" . $sBound;
            }
        }
 
        return trim($sqlBody, $sBound);
    }
 
    function _getSqlSpec($aData)
    {
        $aRes = array(
            'vis'   => '',
            'empty' => '',
            'def'   => ''
        );
        if (isset($aData['allow_view']) && is_array($aData['allow_view'])) {
            $aRes['vis'] = " AND `{$this->sAlbumTable}`.`AllowAlbumView` IN (" . implode(',',
                    $aData['allow_view']) . ")";
        }
        if (isset($aData['hide_default']) && $aData['hide_default'] === true) {
            $aRes['def'] = " AND `{$this->sAlbumTable}`.`AllowAlbumView` <> " . CH_WSB_PG_HIDDEN;
        }
        if (!isset($aData['show_empty']) || $aData['show_empty'] === false) {
            if (!isset($aData['obj_count']['min'])) {
                $aData['obj_count']['min'] = 0;
            }
        }
        if (isset($aData['obj_count'])) {
            if (!is_array($aData['obj_count'])) {
                $aData['obj_count']['min'] = (int)$aData['obj_count'];
            }
            $sqlObjMain    = " AND `{$this->sAlbumTable}`.`ObjCount`";
            $sqlMin        = isset($aData['obj_count']['min']) ? "$sqlObjMain > " . (int)$aData['obj_count']['min'] : "";
            $sqlMax        = isset($aData['obj_count']['max']) ? "$sqlObjMain < " . (int)$aData['obj_count']['max'] : "";
            $aRes['empty'] = "$sqlObjMain $sqlMin $sqlMax";
        }
 
        return $aRes;
    }
 
    // album methods
    function addAlbum($aData = array(), $bCheck = true)
    {
        // Deano - This is temp fix for album caption quoting problem.
        // I am still looking for the source of the problem.
        $aData['caption'] = str_replace('\\','', $aData['caption']);
 
        if ($bCheck) {
            $iCheck = $this->_checkAlbumExistence($aData);
            if ($iCheck != 0) {
                return $iCheck;
            }
        }
        $iOwner = (int)$aData['owner'];
 
        if (isset($aData['AllowAlbumView'])) {
            $iAllowAlbumView = (int)$aData['AllowAlbumView'];
        } elseif (strpos($aData['caption'], getUsername($iOwner)) !== false) {
            ch_import('ChWsbPrivacyQuery');
            $oPrivacy        = new ChWsbPrivacyQuery();
            $iAllowAlbumView = $oPrivacy->getDefaultValueModule(str_replace('ch_', '', $this->sType), 'album_view');
            if (!$iAllowAlbumView) {
                $iAllowAlbumView = CH_WSB_PG_ALL;
            }
        } else {
            $iAllowAlbumView = CH_WSB_PG_NOBODY;
        }
 
        $sUri = $this->getCorrectUri($aData['caption'], $iOwner, $bCheck);
        $GLOBALS['MySQL']->res("INSERT INTO  `{$this->sAlbumTable}` SET " . $this->_getSqlPart(array(
            'Caption' => $aData['caption'],
            'Uri' => $sUri,
            'Location' => $aData['location'],
            'Description' => $aData['description'],
            'AllowAlbumView' =>  $iAllowAlbumView,
            'Type' => $this->sType,
            'Owner' => $iOwner,
            'Status' => 'active',
            'Date' => time(),
            'LastObjId' => isset($aData['lastObjId']) ? (int)$aData['last_obj'] : 0
        )));
 
        $iResult = $GLOBALS['MySQL']->lastId();
        if($iResult > 0) {
            $oAlert = new ChWsbAlerts('album', 'add', $iResult, $iOwner, array('Type' => $this->sType, 'Uri' => $sUri));
            $oAlert->alert();
 
            $oAlert = new ChWsbAlerts($this->sType, 'addAlbum', $iResult, $iOwner, array('Uri' => $sUri));
            $oAlert->alert();
        }
 
        return $iResult;
    }
 
    function getCorrectUri($sCaption, $iOwnerId = 0, $bCheck = true)
    {
        $sUri = uriFilter($sCaption);
        if (!$sUri) {
            $sUri = '-';
        }
        if (!$bCheck) {
            return $sUri;
        }
        if ($this->checkUriUniq($sUri, $iOwnerId)) {
            return $sUri;
        }
        if (get_mb_len($sUri) > 240) {
            $sUri = get_mb_substr($sUri, 0, 240);
        }
        $sUri .= '-' . date('Y-m-d');
        if ($this->checkUriUniq($sUri, $iOwnerId)) {
            return $sUri;
        }
        for ($i = 0; $i < 999; ++$i) {
            if ($this->checkUriUniq($sUri . '-' . $i, $iOwnerId)) {
                return ($sUri . '-' . $i);
            }
        }
 
        return time();
    }
 
    function checkUriUniq($sUri, $iOwnerId)
    {
        $sUri     = process_db_input($sUri, CH_TAGS_STRIP);
        $iOwnerId = (int)$iOwnerId;
 
        return !$GLOBALS['MySQL']->getRow("SELECT 1 FROM $this->sAlbumTable WHERE `Uri` = ? AND `Owner` = ? AND `Type` = ? LIMIT 1",
            [$sUri, $iOwnerId, $this->sType]);
    }
 
    function updateAlbum($mixedIdent, $aData)
    {
        $sUri = process_db_input($mixedIdent, CH_TAGS_STRIP);
        $iOwner = (int)$aData['Owner'] ? (int)$aData['Owner'] : $this->iOwnerId;
        $aAlbum = $this->getAlbumInfo(array('fileUri' => $sUri, 'owner' => $iOwner), array('ID', 'Uri', 'Type'));
 
        return $this->_updateAlbum($aAlbum, $aData);
    }
 
    function updateAlbumById ($iId, $aData)
    {
        $iId = (int)$iId;
        $iOwner = (int)$aData['Owner'] ? (int)$aData['Owner'] : $this->iOwnerId;
        $aAlbum = $this->getAlbumInfo(array('fileid' => $iId, 'owner' => $iOwner), array('ID', 'Uri', 'Type'));
 
        return $this->_updateAlbum($aAlbum, $aData);
    }
 
    function _updateAlbum ($aAlbum, $aData)
    {
        if(empty($aAlbum) || !is_array($aAlbum))
            return false;
 
        $sSetClause = $this->_getSqlPart($aData, ', ', true);
        $sWhereClause = "`ID` = '" . $aAlbum['ID'] . "'";
 
        $mixedResult = $GLOBALS['MySQL']->res("UPDATE `{$this->sAlbumTable}` SET " . $sSetClause . " WHERE " . $sWhereClause . " LIMIT 1");
        if((int)$mixedResult > 0) {
            $iUserId = getLoggedId();
 
            $oAlert = new ChWsbAlerts('album', 'change', $aAlbum['ID'], $iUserId, array('Type' => $aAlbum['Type'], 'Uri' => $aAlbum['Uri']));
            $oAlert->alert();
 
            $oAlert = new ChWsbAlerts($aAlbum['Type'], 'changeAlbum', $aAlbum['ID'], $iUserId, array('Uri' => $aAlbum['Uri']));
            $oAlert->alert();
        }
 
        return $mixedResult;
    }
 
    function removeAlbum ($iAlbumId)
    {
        $iAlbumId = (int)$iAlbumId;
 
        $aObj = $this->getAlbumObjList($iAlbumId);
        $this->removeObject($iAlbumId, $aObj);
 
        $aAlbum = $this->getAlbumInfo(array('fileid' => $iAlbumId), array('ID', 'Uri', 'Type'));
        if(empty($aAlbum) || !is_array($aAlbum))
            return true;
 
        $mixedResult = $GLOBALS['MySQL']->res("DELETE FROM `{$this->sAlbumTable}` WHERE `ID`='" . $iAlbumId . "'");
        if((int)$mixedResult > 0) {
            $iUserId = getLoggedId();
 
            $oAlert = new ChWsbAlerts('album', 'delete', $iAlbumId, $iUserId, array('Type' => $aAlbum['Type'], 'Uri' => $aAlbum['Uri']));
            $oAlert->alert();
 
            $oAlert = new ChWsbAlerts($aAlbum['Type'], 'deleteAlbum', $iAlbumId, $iUserId, array('Uri' => $aAlbum['Uri']));
            $oAlert->alert();
        }
 
        return $mixedResult;
    }
 
    function _checkAlbumExistence($aData)
    {
        $aFields  = array(
            'Caption' => $aData['caption'],
            'Type'    => $this->sType,
            'Owner'   => (int)$aData['owner'],
        );
        $sqlBody  = $this->_getSqlPart($aFields, ' AND');
        $sqlQuery = "SELECT `ID` FROM {$this->sAlbumTable} WHERE $sqlBody";
 
        return (int)$GLOBALS['MySQL']->getOne($sqlQuery);
    }
 
    function getAlbumObjList($mixedAlbum)
    {
        $sqlJoin = "";
        if ((int)$mixedAlbum > 0) {
            $sqlWhere = "`id_album`='" . (int)$mixedAlbum . "'";
        } else {
            $sqlJoin  = "LEFT JOIN `sys_albums` ON `sys_albums_objects`.`id_album` = `sys_albums`.`ID`";
            $sqlWhere = "`sys_albums`.`Uri` = '" . process_db_input($mixedAlbum, CH_TAGS_STRIP) . "'";
        }
        $sqlQuery = "SELECT `id_object` FROM `{$this->sAlbumObjectsTable}` $sqlJoin WHERE $sqlWhere";
 
        return $GLOBALS['MySQL']->getPairs($sqlQuery, 'id_object', 'id_object');
    }
 
    function getAlbumCoverFiles($iAlbumId, $aJoin = array(), $aJoinCond = array(), $iLimit = 4)
    {
        $iAlbumId     = (int)$iAlbumId;
        $iLimit       = (int)$iLimit;
        $sqlWhere     = "`id_album`='$iAlbumId'";
        $sqlAddFields = '';
        if (is_array($aJoin)) {
            $sqlJoin = "INNER JOIN `{$aJoin['table']}` ON `{$aJoin['table']}`.`{$aJoin['field']}`=`{$this->sAlbumObjectsTable}`.`id_object`";
            if (is_array($aJoinCond)) {
                foreach ($aJoinCond as $aValue) {
                    $sqlWhere .= " AND `{$aJoin['table']}`.`{$aValue['field']}`='{$aValue['value']}'";
                }
            }
            if (is_array($aJoin['fields_list'])) {
                $sqlAddFields = ", `" . implode("`, `", $aJoin['fields_list']) . "`";
            }
        }
        $sqlQuery = "SELECT `id_object` $sqlAddFields FROM `{$this->sAlbumObjectsTable}` $sqlJoin WHERE $sqlWhere ORDER BY `obj_order`, `id_object` DESC LIMIT $iLimit";
 
        return $GLOBALS['MySQL']->getAll($sqlQuery);
    }
 
    function getAlbumList($aData = array(), $iPage = 1, $iPerPage = 10, $bSimple = false)
    {
        $aFields = array(
            'Type'    => $this->sType,
            'Status'  => !isset($aData['status']) ? 'active' : $aData['status'],
            'Caption' => isset($aData['caption']) ? $aData['caption'] : '',
        );
        if ($aFields['Status'] == 'any') {
            unset($aFields['Status']);
        }
        if (isset($aData['owner']) && strlen($aData['owner']) > 0) {
            if ((int)$aData['owner'] == 0) {
                $iUserId          = getID($aData['owner']);
                $aFields['Owner'] = $iUserId > 0 ? $iUserId : '';
            } else {
                $aFields['Owner'] = (int)$aData['owner'];
            }
        }
 
        $aSqlSpec = $this->_getSqlSpec($aData);
 
        $sqlLimit = "";
        if (!$bSimple) {
            $iPage    = (int)$iPage;
            $iPerPage = (int)$iPerPage;
            if ($iPage < 1) {
                $iPage = 1;
            }
            if ($iPerPage < 1) {
                $iPerPage = 10;
            }
 
            $sqlLimit = "LIMIT " . ($iPage - 1) * $iPerPage . ", " . $iPerPage;
        }
 
        $sqlJoin      = "";
        $sqlJoinWhere = "";
        if (isset($aData['ownerStatus'])) {
            $sqlJoin      = "LEFT JOIN `Profiles` ON `Profiles`.`ID`=`{$this->sAlbumTable}`.`Owner`";
            $sqlJoinWhere = "AND `Profiles`.`Status` ";
            if (is_array($aData['ownerStatus'])) {
                $sqlJoinWhere .= "NOT IN ('" . implode("','", $aData['ownerStatus']) . "')";
            } else {
                $sqlJoinWhere .= "<> '{$aData['ownerStatus']}'";
            }
        }
 
        $sqlBegin = "SELECT `{$this->sAlbumTable}`.* FROM `{$this->sAlbumTable}` $sqlJoin";
        $sqlCond  = "WHERE " . $this->_getSqlPart($aFields, ' AND ');
        $sqlOrder = "ORDER BY `{$this->sAlbumTable}`.`Date` DESC";
        $sqlQuery = "$sqlBegin $sqlCond {$aSqlSpec['vis']} {$aSqlSpec['def']} {$aSqlSpec['empty']} $sqlJoinWhere $sqlOrder $sqlLimit";
 
        return $GLOBALS['MySQL']->getAll($sqlQuery);
    }
 
    function getAlbumCount($aData = array())
    {
        // Create the Friends only album if it does not exist.
        $iProfileId = (int)$aData['owner'];
        if($iProfileId) {
            $aNew = array(
                'caption'        => _t('_sys_album_select_friends'),
                'AllowAlbumView' => 5,
                'owner'          => $iProfileId,
            );
            $this->addAlbum($aNew);
 
            // Create the Private album if it does not exist.
            $aNew = array(
                'caption'        => _t('_sys_album_select_private'),
                'AllowAlbumView' => 2,
                'owner'          => $iProfileId,
            );
            $this->addAlbum($aNew);
        }
 
        $aFields = array(
            'Type'   => $this->sType,
            'Status' => !isset($aData['status']) ? 'active' : $aData['status'],
        );
        if (isset($aData['owner']) && strlen($aData['owner']) > 0) {
            if ((int)$aData['owner'] == 0) {
                $iUserId          = getID($aData['owner']);
                $aFields['Owner'] = $iUserId > 0 ? $iUserId : '';
            } else {
                $aFields['Owner'] = (int)$aData['owner'];
            }
        }
        $aSqlSpec = $this->_getSqlSpec($aData);
 
        $sqlJoin      = "";
        $sqlJoinWhere = "";
        if (isset($aData['ownerStatus'])) {
            $sqlJoin      = "LEFT JOIN `Profiles` ON `Profiles`.`ID`=`{$this->sAlbumTable}`.`Owner`";
            $sqlJoinWhere = "AND `Profiles`.`Status` ";
            if (is_array($aData['ownerStatus'])) {
                $sqlJoinWhere .= "NOT IN ('" . implode("','", $aData['ownerStatus']) . "')";
            } else {
                $sqlJoinWhere .= "<> '{$aData['ownerStatus']}'";
            }
        }
 
        $sqlBegin = "SELECT COUNT(*) FROM `{$this->sAlbumTable}` $sqlJoin";
        $sqlCond  = "WHERE " . $this->_getSqlPart($aFields, ' AND ');
        $sqlQuery = "$sqlBegin $sqlCond {$aSqlSpec['vis']} {$aSqlSpec['def']} {$aSqlSpec['empty']} $sqlJoinWhere";
 
        return $GLOBALS['MySQL']->getOne($sqlQuery);
    }
 
    function getAlbumInfo($aIdent = array(), $aFields = array())
    {
        $sqlCondition = "`{$this->sAlbumTable}`.`Type`= ?";
        $aBindings    = [$this->sType];
        $aParams      = array();
        // TODO: need dynamic pdo bindings
        foreach ($aIdent as $sKey => $sValue) {
            switch (strtolower($sKey)) {
                case 'fileuri':
                    $aParams['Uri'] = $sValue;
                    break;
                case 'fileid':
                    $aParams['ID'] = (int)$sValue;
                    break;
                case 'owner':
                    $aParams['Owner'] = (int)$sValue;
                    break;
                default:
                    $aParams[$sKey] = $sValue;
            }
        }
        $aParams['Type'] = $this->sType;
        if (count($aFields) == 0) {
            $aFields = $this->aAlbumFields;
        }
        $sqlCondition = $this->_getSqlPart($aParams, ' AND ');
        foreach ($aFields as $sValue) {
            if (in_array($sValue, $this->aAlbumFields)) {
                $sqlFields .= "`{$this->sAlbumTable}`.`$sValue`, ";
            }
        }
        $sqlFields = trim($sqlFields, ', ');
        $sqlQuery  = "SELECT $sqlFields FROM `{$this->sAlbumTable}` WHERE $sqlCondition LIMIT 1";
 
        return $GLOBALS['MySQL']->getRow($sqlQuery);
    }
 
    function getAlbumName($iAlbumId)
    {
        $aValue = $this->getAlbumInfo(array('fileId' => (int)$iAlbumId), array('Caption'));
 
        return $aValue['Caption'];
    }
 
    function getAlbumDefaultName()
    {
        return getParam('sys_album_default_name');
    }
 
    // album's objects methods
    function addObject($iAlbumId, $mixedObj, $bUpdateCount = true)
    {
        $iAlbumId = (int)$iAlbumId;
        if ($iAlbumId == 0) {
            return;
        }
        $sqlFields  = "`id_album`, `id_object`, `obj_order`";
        $sqlBody    = "";
        $iLastObjId = $this->getLastObj($iAlbumId);
        $iCount     = 0;
        if (is_array($mixedObj)) {
            foreach ($mixedObj as $iValue) {
                $iValue = (int)$iValue;
                $sqlBody .= "('$iAlbumId', '$iValue', '$iValue'), ";
                $iCount++;
            }
        } else {
            $iValue  = (int)$mixedObj;
            $sqlBody = "('$iAlbumId', '$iValue', '$iValue')";
            $iCount++;
        }
        $sqlQuery = "INSERT INTO `{$this->sAlbumObjectsTable}` ($sqlFields) VALUES " . trim($sqlBody, ', ');
        $iRes     = $GLOBALS['MySQL']->query($sqlQuery);
 
        if ($bUpdateCount) {
            $this->updateObjCounter($iAlbumId, $iCount);
            if ($iLastObjId == 0) {
                $this->updateLastObj($iAlbumId, $iValue);
            } elseif ($iLastObjId != 0 && getParam($this->sAlbumCoverParam) == 'on') {
                $this->updateLastObj($iAlbumId, $iValue);
            }
        }
 
        return $iRes;
    }
 
    function moveObject($iAlbumId, $iNewAlbumId, $mixedObj)
    {
        $iAlbumId    = (int)$iAlbumId;
        $iNewAlbumId = (int)$iNewAlbumId;
        $sqlBody     = "";
        $iLastObjId  = $this->getLastObj($iAlbumId);
        if (!empty($mixedObj)) {
            $iCount = 0;
            if (is_array($mixedObj)) {
                if (in_array($iLastObjId, $mixedObj)) {
                    $bUpdateLastObj = true;
                }
                foreach ($mixedObj as $iValue) {
                    $iValue = (int)$iValue;
                    $sqlBody .= "'$iValue', ";
                    $iCount++;
                }
            } else {
                $iValue  = (int)$mixedObj;
                $sqlBody = "'$iValue'";
                $iCount++;
                if ($iValue == $iLastObjId) {
                    $bUpdateLastObj = true;
                }
            }
            $sqlQuery = "UPDATE `{$this->sAlbumObjectsTable}`, `{$this->sAlbumTable}`
                            SET `{$this->sAlbumObjectsTable}`.`id_album` = $iNewAlbumId
                         WHERE `{$this->sAlbumObjectsTable}`.`id_album`=`{$this->sAlbumTable}`.`ID`
                         AND `{$this->sAlbumTable}`.`Type` = '$this->sType' AND `{$this->sAlbumObjectsTable}`.`id_object` IN (" . trim($sqlBody,
                    ', ') . ")";
            $GLOBALS['MySQL']->res($sqlQuery);
            if ($bUpdateLastObj) {
                $this->updateLastObj($iAlbumId);
            }
            $this->updateLastObj($iNewAlbumId);
 
            $sqlQuery = "UPDATE `{$this->sAlbumTable}` SET `ObjCount` = CASE
                WHEN `ID`={$iAlbumId} THEN `ObjCount`-$iCount
                WHEN `ID`={$iNewAlbumId} THEN `ObjCount`+$iCount END
                WHERE `ID` IN ($iAlbumId, $iNewAlbumId)";
            $GLOBALS['MySQL']->res($sqlQuery);
        }
    }
 
    function removeObject($iAlbumId, $mixedObj, $bUpdateCount = true)
    {
        $iAlbumId   = (int)$iAlbumId;
        $sqlBody    = "";
        $iLastObjId = $this->getLastObj($iAlbumId);
        $iCount     = 0;
        if (!empty($mixedObj)) {
            if (is_array($mixedObj)) {
                if (in_array($iLastObjId, $mixedObj)) {
                    $bUpdateLastObj = true;
                }
                foreach ($mixedObj as $iValue) {
                    $iValue = (int)$iValue;
                    $sqlBody .= "'$iValue', ";
                    $iCount++;
                }
            } else {
                $iValue  = (int)$mixedObj;
                $sqlBody = "'$iValue'";
                if ($iValue == $iLastObjId) {
                    $bUpdateLastObj = true;
                }
                $iCount++;
            }
            $sqlQuery = "DELETE `{$this->sAlbumObjectsTable}`
                            FROM `{$this->sAlbumObjectsTable}`, `{$this->sAlbumTable}`
                         WHERE `{$this->sAlbumObjectsTable}`.`id_album`=`{$this->sAlbumTable}`.`ID`
                         AND `{$this->sAlbumTable}`.`Type` = '$this->sType' AND `{$this->sAlbumObjectsTable}`.`id_object` IN (" . trim($sqlBody,
                    ', ') . ")";
            $GLOBALS['MySQL']->res($sqlQuery);
            if ($bUpdateLastObj) {
                $this->updateLastObj($iAlbumId);
            }
            if ($bUpdateCount) {
                $this->updateObjCounter($iAlbumId, $iCount, false);
            }
        }
    }
 
    function removeObjectTotal($iObj, $bUpdateCounter = true)
    {
        $iObj      = (int)$iObj;
        $sqlQuery  = "SELECT `id_album` as `ID`, `ObjCount`, `LastObjId`
                         FROM `{$this->sAlbumObjectsTable}`
                         LEFT JOIN `{$this->sAlbumTable}` ON `{$this->sAlbumTable}`.`ID` = `{$this->sAlbumObjectsTable}`.`id_album`
                         WHERE `id_object` = ? AND `$this->sAlbumTable`.`Type` = ?";
        $aInfo     = $GLOBALS['MySQL']->getRow($sqlQuery, [$iObj, $this->sType]);
        $sqlDelete = "DELETE FROM `{$this->sAlbumObjectsTable}` WHERE `id_album`='{$aInfo['ID']}' AND `id_object`='$iObj' LIMIT 1";
        $GLOBALS['MySQL']->res($sqlDelete);
        if ($aInfo['ObjCount'] > 0 && $bUpdateCounter) {
            $this->updateObjCounter($aInfo['ID'], 1, false);
        }
        if ($aInfo['LastObjId'] == $iObj) {
            $this->updateLastObj($aInfo['ID']);
        }
    }
 
    function sortObjects($sAlbumUri, $aSort = array())
    {
        $aAlbumInfo   = $this->getAlbumInfo(array('fileUri' => $sAlbumUri, 'owner' => $this->iOwnerId), array('ID'));
        $sqlBegin     = "UPDATE `{$this->sAlbumObjectsTable}` SET `obj_order` = ";
        $sqlAlbumPart = " `id_album`='{$aAlbumInfo['ID']}'";
        $iNum         = is_array($aSort) ? count($aSort) : 0;
        if ($iNum > 0) {
            $sqlBegin .= " CASE ";
            $sqlWhere = "WHERE `id_object` IN (";
            for ($i = 0; $i < $iNum; $i++) {
                $iElem = (int)$aSort[$i];
                $sqlBegin .= " WHEN `id_object`='$iElem' THEN '$i'";
                $sqlWhere .= "$iElem, ";
            }
            $sqlQuery = $sqlBegin . " END " . trim($sqlWhere, ', ') . ") AND $sqlAlbumPart";
        } else {
            $sqlQuery = $sqlBegin . " `id_object` WHERE $sqlAlbumPart";
        }
        $GLOBALS['MySQL']->query($sqlQuery);
    }
 
    function updateLastObj($iAlbumId, $iObjId = 0)
    {
        $iAlbumId = (int)$iAlbumId;
        $iObjId   = (int)$iObjId;
        if ($iObjId == 0) {
            $sqlQuery = "SELECT MAX(`id_object`) FROM `{$this->sAlbumObjectsTable}` WHERE `id_album` = '{$iAlbumId}'";
            $iObjId   = (int)db_value($sqlQuery);
        }
        $sqlQuery = "UPDATE `{$this->sAlbumTable}` SET `LastObjId`='$iObjId' WHERE `ID`='{$iAlbumId}'";
 
        return $GLOBALS['MySQL']->query($sqlQuery);
    }
 
    function updateLastObjById($iObjId)
    {
        $iObjId   = (int)$iObjId;
        $sqlQuery = "UPDATE `{$this->sAlbumTable}`, `{$this->sAlbumObjectsTable}`
                     SET `LastObjId` = $iObjId
                     WHERE `{$this->sAlbumTable}`.`ID`=`{$this->sAlbumObjectsTable}`.`id_album`
                     AND `{$this->sAlbumObjectsTable}`.`id_object`=$iObjId
                     AND `{$this->sAlbumTable}`.`Type`='{$this->sType}'";
 
        return $GLOBALS['MySQL']->query($sqlQuery);
    }
 
    function getLastObj($iAlbumId)
    {
        $iAlbumId = (int)$iAlbumId;
        $sqlQuery = "SELECT `LastObjId` FROM `{$this->sAlbumTable}` WHERE `ID`='{$iAlbumId}' AND `Type`='{$this->sType}'";
 
        return $GLOBALS['MySQL']->getOne($sqlQuery);
    }
 
    // calculate closest object in album for current element
    function getClosestObj($iAlbumId, $iObjectId, $sType = 'next', $iOrder = 0, $aExcludeIds = array())
    {
        $iAlbumId  = (int)$iAlbumId;
        $iObjectId = (int)$iObjectId;
        $iOrder    = (int)$iOrder;
        $sType     = strip_tags($sType);
        $bOrder    = true;
        if ($iOrder == 0) {
            $sqlCheck = "SELECT COUNT(*) FROM `$this->sAlbumObjectsTable` WHERE `id_album`=$iAlbumId AND `obj_order`>0";
            $iCheck   = (int)db_value($sqlCheck);
            $bOrder   = $iCheck > 0 ? true : false;
        }
 
        if ($iOrder == 0 && !$bOrder) {
            $sqlField = "id_object";
            $sqlValue = $iObjectId;
            $sKey     = 'prev';
        } else {
            $sqlField = "obj_order";
            $sqlValue = $iOrder;
            $sKey     = 'next';
        }
 
        if ($sType == $sKey) {
            $sSign   = ">";
            $sqlType = "ASC";
        } else {
            $sSign   = "<";
            $sqlType = "DESC";
        }
 
        $sqlIds = "";
        if (is_array($aExcludeIds) && !empty($aExcludeIds)) {
            $sqlIds = "AND `id_object` NOT IN ('" . implode("','", $aExcludeIds) . "')";
        }
 
        $sqlQuery = "SELECT `id_object` FROM `$this->sAlbumObjectsTable`
                     WHERE `id_album`=$iAlbumId AND `$sqlField`$sSign $sqlValue $sqlIds
                     ORDER BY `$sqlField` $sqlType LIMIT 1";
 
        return (int)db_value($sqlQuery);
    }
 
    function getObjCount($aIdent)
    {
        $aInfo = $this->getAlbumInfo($aIdent, array('ObjCount'));
 
        return $aInfo['ObjCount'];
    }
 
    function getObjTotalCount($aData = array())
    {
        $aFields = array(
            'Type'   => $this->sType,
            'Status' => !isset($aData['status']) ? 'active' : $aData['status'],
        );
        if (isset($aData['owner'])) {
            if ((int)$aData['owner'] == 0) {
                $iUserId          = getID($aData['owner']);
                $aFields['Owner'] = $iUserId > 0 ? $iUserId : '';
            } else {
                $aFields['Owner'] = (int)$aData['owner'];
            }
        }
        $sqlQuery = "SELECT SUM(`ObjCount`) FROM `{$this->sAlbumTable}` WHERE " . $this->_getSqlPart($aFields, ' AND ');
 
        return (int)$GLOBALS['MySQL']->getOne($sqlQuery);
    }
 
    function calcObjCount($iAlbumId)
    {
        $iAlbumId = (int)$iAlbumId;
        $sqlQuery = "SELECT COUNT(*) FROM `{$this->sAlbumObjectsTable}` WHERE `id_album`='$iAlbumId'";
 
        return $GLOBALS['MySQL']->getOne($sqlQuery);
    }
 
    function updateObjCounter($iAlbumId, $iNumber, $bIncrease = true)
    {
        $iAlbumId  = (int)$iAlbumId;
        $iNumber   = (int)$iNumber;
        $sOperator = $bIncrease ? '+' : '-';
        $sqlQuery  = "UPDATE `{$this->sAlbumTable}` SET `ObjCount`=`ObjCount` $sOperator $iNumber WHERE `ID`='{$iAlbumId}'";
        $GLOBALS['MySQL']->res($sqlQuery);
    }
 
    function updateObjCounterById($iObjId, $bIncrease = true)
    {
        $iObjId    = (int)$iObjId;
        $sOperator = $bIncrease ? '+' : '-';
        $sqlQuery  = "UPDATE `{$this->sAlbumTable}`, `{$this->sAlbumObjectsTable}`
                     SET `ObjCount` = `ObjCount` $sOperator 1
                     WHERE `{$this->sAlbumTable}`.`ID`=`{$this->sAlbumObjectsTable}`.`id_album`
                     AND `{$this->sAlbumObjectsTable}`.`id_object`=$iObjId
                     AND `{$this->sAlbumTable}`.`Type`='{$this->sType}'";
        $GLOBALS['MySQL']->res($sqlQuery);
    }
}