ChWsbConnectDb.php

Go to the documentation of this file.

<?php
 
ch_import('ChWsbModuleDb');
 
class ChWsbConnectDb extends ChWsbModuleDb
{
    var $sTablePrefix;
 
    function __construct(&$oConfig)
    {
        parent::__construct($oConfig);
 
        $this -> sTablePrefix = $oConfig -> getDbPrefix();
    }
 
    function getProfileId($iRemoteId)
    {
        $iRemoteId = (int) $iRemoteId;
 
        $sQuery = "SELECT `local_profile` FROM `{$this -> sTablePrefix}accounts` WHERE `remote_profile` = '{$iRemoteId}' LIMIT 1";
        return $this -> getOne($sQuery);
    }
 
    function saveRemoteId($iProfileId, $iRemoteId)
    {
        $iRemoteId = (int) $iRemoteId;
        $iProfileId = (int) $iProfileId;
 
        $sQuery = "REPLACE INTO `{$this -> sTablePrefix}accounts` SET `local_profile` = {$iProfileId}, `remote_profile` = '{$iRemoteId}'";
        return $this -> query($sQuery);
    }
 
    function deleteRemoteAccount($iProfileId)
    {
        $iProfileId = (int) $iProfileId;
 
        $sQuery = "DELETE FROM `{$this -> sTablePrefix}accounts` WHERE `local_profile` = {$iProfileId}";
        return $this -> query($sQuery);
    }
 
    function makeFriend($iMemberId, $iProfileId)
    {
        $iMemberId = (int) $iMemberId;
        $iProfileId = (int) $iProfileId;
 
        $sQuery = "INSERT INTO `sys_friend_list` SET `ID` = '{$iMemberId}', `Profile` = '{$iProfileId}', `Check` = 1";
        return $this -> query($sQuery);
    }
 
    function createProfile(&$aProfileFields)
    {
        $sFields = null;
 
        // procces all recived fields;
        foreach($aProfileFields as $sKey => $mValue) {
            $mValue = process_db_input($mValue, CH_TAGS_VALIDATE, CH_SLASHES_AUTO);
            $sKey = process_db_input($sKey, CH_TAGS_STRIP, CH_SLASHES_NO_ACTION);
            $sFields .= "`{$sKey}` = '{$mValue}', ";
        }
 
        $sFields = preg_replace( '/,$/', '', trim($sFields) );
 
        $sQuery = "INSERT INTO `Profiles` SET {$sFields}";
        $this -> query($sQuery);
 
        return db_last_id();
    }
 
    function updateProfileStatus($iProfileId, $sStatus)
    {
        $iProfileId = (int)$iProfileId;
        $sStatus    = process_db_input($sStatus);
 
        $sQuery = "UPDATE `Profiles` SET `Status` = '{$sStatus}' WHERE `ID` = {$iProfileId}";
        return $this -> query($sQuery);
    }
 
    function isFieldExist($sFieldName)
    {
        $sFieldName = process_db_input($sFieldName);
 
        $sQuery = "SELECT `ID` FROM `sys_profile_fields` WHERE `Name` = '{$sFieldName}' LIMIT 1";
        return $this -> getOne($sQuery) ? true : false;
    }
 
    function isEmailExisting($sEmail)
    {
        $sEmail = process_db_input($sEmail, CH_TAGS_STRIP, CH_SLASHES_AUTO);
 
        $sQuery = "SELECT `ID` FROM `Profiles` WHERE `Email` = '{$sEmail}'";
        return $this -> getOne($sQuery);
    }
 
    function getCountryCode($sCountry)
    {
        $sCountry = process_db_input($sCountry);
        $sQuery = "SELECT `ISO2` FROM `sys_countries` WHERE `Country` = '{$sCountry}' LIMIT 1";
        return $this -> getOne($sQuery);
    }
}