Account.php

Go to the documentation of this file.

<?php

namespace Combu;

class Account extends DataClass {

    const TABLE_NAME = "Account";

    public $Id = 0;
    public $Username = "";
    public $Password = "";
    public $GUID = "";
    public $LastLoginDate = "";
    public $LastLoginIp = "";
    public $Email = "";
    public $ActivationCode = "";
    public $ChangePwdCode = "";
    public $Enabled = 0;
    
    private $Session = NULL;

    public function __construct($src = null, $stripSlashes = false) {
        global $Database;
        if (!empty($src)) {
            if (is_array($src)) {
                // Load by array
                $this->_loadByRow($src, $stripSlashes);
            } else if (is_numeric($src)) {
                // Load by Id
                $this->_loadFilter(self::GetTableName(__CLASS__), sprintf("Id = %d", $src));
            } else {
                // Load by Username
                $this->_loadFilter(self::GetTableName(__CLASS__), "Username = '" . $Database->Escape($src) . "'");
                if ($this->Id < 1) {
                    // Load by Email
                    $this->_loadFilter(self::GetTableName(__CLASS__), "Email = '" . $Database->Escape($src) . "'");
                }
            }
        }
    }

    public function ExistsUsername() {
        global $Database;
        $sql = "SELECT Id FROM " . self::GetTableName(__CLASS__) . " WHERE Username = '" . $Database->Escape($this->Username) . "'";
        if ($this->Id > 0)
            $sql .= " AND Id <> " . $this->Id;
        $res = $Database->Query($sql);
        if ($res) {
            $row = $Database->FetchAssoc($res);
            if ($row)
                return TRUE;
        }
        return FALSE;
    }

    public function ExistsEmail() {
        global $Database;
        $sql = "SELECT Id FROM " . self::GetTableName(__CLASS__) . " WHERE Email = '" . $Database->Escape($this->Email) . "'";
        if ($this->Id > 0)
            $sql .= " AND Id <> " . $this->Id;
        $res = $Database->Query($sql);
        if ($res) {
            $row = $Database->FetchAssoc($res);
            if ($row)
                return TRUE;
        }
        return FALSE;
    }

    public function IsLogged() {
        global $LoggedAccount;
        return ($this->Id > 0 && $this->Id == $LoggedAccount->Id && !$this->ActivationCode);
    }
    
    public function IsOnline() {
        $lastAction = $this->GetLastActionDate();
        if ($lastAction) {
            if (time() - Utils::GetTimestamp($lastAction) <= ONLINE_SECONDS) {
                return TRUE;
            }
        }
        return FALSE;
    }
    
    public function GetLastActionDate() {
        if ($this->Id > 0) {
            $session = $this->GetSession();
            if ($session) {
                return $session->Updated;
            }
        }
        return NULL;
    }
    
    public function GetSession() {
        if ($this->Id > 0 && !$this->Session) {
            $this->LoadSession();
        }
        return $this->Session;
    }

    public static function Load($username = "", $email = "", $customData = NULL, $appCustomData = NULL, $isOnline = FALSE, $limit = NULL, $offset = NULL, &$count = NULL, $returnArray = FALSE) {
        global $AppId;
        return self::LoadAny($AppId->Id, $username, $email, $customData, $appCustomData = NULL, $isOnline, $limit, $offset, $count, $returnArray);
    }
    
    public static function LoadAny($idApp = 0, $username = "", $email = "", $customData = NULL, $appCustomData = NULL, $isOnline = FALSE, $limit = NULL, $offset = NULL, &$count = NULL, $returnArray = FALSE) {
        return self::LoadAnyByIp(NULL, $idApp, $username, $email, $customData, $appCustomData, $isOnline, $limit, $offset, $count, $returnArray);
    }
    
    public static function LoadAnyByIp($ip, $idApp = 0, $username = "", $email = "", $customData = NULL, $appCustomData = NULL, $isOnline = FALSE, $limit = NULL, $offset = NULL, &$count = NULL, $returnArray = FALSE) {
        global $Database;
        $select = "a.*";
        $from = self::GetTableName(__CLASS__) . " a";
        $where = "";
        if (!empty($ip)) {
            $from .= sprintf(" INNER JOIN %s session ON (a.Id = session.IdAccount AND IPAddress LIKE '%s')",
                    self::GetTableName(SessionToken::class),
                    $Database->Escape($ip) . "%");
        }
        if ($idApp > 0) {
            $from .= sprintf(" INNER JOIN %s aapp ON (a.Id = aapp.IdAccount AND aapp.IdApp = %d)",
                    self::GetTableName(Account_App::class),
                    $idApp);
        }
        if ($isOnline) {
            $usersOnlineTicks = time() - ONLINE_SECONDS;
            $where .= ($where == "" ? "" : " AND ") . sprintf("(Id IN (SELECT DISTINCT IdAccount FROM %s WHERE Updated >= '%s' %s GROUP BY IdAccount))",
                    self::GetTableName(SessionToken::class),
                    date("Y-m-d H:i:s", $usersOnlineTicks),
                    $idApp > 0 ? " AND IdApp = " . intval($idApp) : "");
        }
        if ($username != "") {
            $where .= ($where == "" ? "" : " AND ") . sprintf("(Username LIKE '%s')", $Database->Escape($username . "%"));
        }
        if ($email != "") {
            $where .= ($where == "" ? "" : " AND ") . sprintf("(Email LIKE '%s')", $Database->Escape("%" . $email . "%"));
        }
        if ($customData && is_array($customData) && count($customData) > 0) {
            foreach ($customData as $search_row) {
                if (!is_array($search_row)) {
                    continue;
                }
                $key = $search_row["key"];
                $op = $search_row["op"];
                $value = $search_row["value"];
                if (!is_numeric($value)) {
                    $value = "'" . $Database->Escape($value) . "'";
                }
                $whereCustom = sprintf("(DataKey = '%s' AND DataValue %s %s)", $Database->Escape($key), $op, $value);
                $where .= ($where == "" ? "" : " AND ") . sprintf("(ID IN (SELECT DISTINCT IdAccount FROM %s WHERE %s GROUP BY IdAccount))", self::GetTableName(CustomData::class), $whereCustom);
            }
        }
        if ($appCustomData && is_array($appCustomData) && count($appCustomData) > 0) {
            foreach ($appCustomData as $search_row) {
                if (!is_array($search_row)) {
                    continue;
                }
                $key = $search_row["key"];
                $op = $search_row["op"];
                $value = $search_row["value"];
                if (!is_numeric($value)) {
                    $value = "'" . $Database->Escape($value) . "'";
                }
                $whereCustom = sprintf("(DataKey = '%s' AND DataValue %s %s)", $Database->Escape($key), $op, $value);
                if ($idApp > 0) {
                    $whereCustom .= sprintf(" AND (IdApp = %d)", $idApp);
                }
                $where .= ($where == "" ? "" : " AND ") . sprintf("(ID IN (SELECT DISTINCT IdAccount FROM %s WHERE %s GROUP BY IdAccount))", self::GetTableName(AppCustomData::class), $whereCustom);
            }
        }
        $where .= ($where ? "" : "(1 = 1)") . " GROUP BY a.Id";
        return self::_loadEx($select, $from, ($returnArray ? "" : __CLASS__), $where, "Username", $limit, $offset, $count);
    }
    
    public static function LoadIds($ids, $returnArray = FALSE) {
        if (!$ids || !is_array($ids)) {
            return array();
        }
        $where = sprintf("(Id IN (%s))", implode(",", $ids));
        return self::_load(self::GetTableName(__CLASS__), ($returnArray ? "" : __CLASS__), $where, "Username");
    }
    
    public static function LoadUsernames($usernames, $returnArray = FALSE) {
        global $Database;
        if (!$usernames || !is_array($usernames)) {
            return array();
        }
        $array_usernames = array();
        foreach ($usernames as $username) {
            $array_usernames[] = "'" . $Database->Escape($username) . "'";
        }
        $where = sprintf("(Username IN (%s))", implode(",", $array_usernames));
        return self::_load(self::GetTableName(__CLASS__), ($returnArray ? "" : __CLASS__), $where, "Username");
    }

    private function LoadSession() {
        if ($this->Id > 0) {
            if ($this->GUID) {
                // Load the session
                $session = new SessionToken($this->GUID);
                if ($session->IdAccount == $this->Id) {
                    $this->Session = $session;
                }
            } else {
                $this->Session = SessionToken::GetLastSession($this->Id);
            }
        }
    }

    public static function CheckLogin($username, $password, &$account = null) {
        global $Database;
        $account = null;
        $query = sprintf("SELECT * FROM " . self::GetTableName(__CLASS__) . " WHERE (Username = '%s' OR Email = '%s') AND Password = '%s'", $Database->Escape($username), $Database->Escape($username), $Database->Escape($password));
        $res = $Database->Query($query);
        if ($res) {
            $row = $Database->FetchAssoc($res);
            if ($row) {
                $account = new self($row);
                return TRUE;
            }
        }
        return FALSE;
    }
    
    public function UpdateLastLogin() {
        global $Database;
        if ($this->Id > 0) {
            $this->LastLoginDate = Utils::GetCurrentDateTimeFormat();
            $this->LastLoginIp = Utils::GetClientIP();
            $query = sprintf("UPDATE %s SET LastLoginDate = %s, LastLoginIp = '%s' WHERE Id = %d",
                    self::GetTableName(__CLASS__),
                    $Database->EscapeDate($this->LastLoginDate),
                    $Database->Escape($this->LastLoginIp),
                    $this->Id);
            return $Database->Query($query);
        }
        return FALSE;
    }

    public static function SetSession(&$account) {
        global $LoggedAccount, $WS_TOKEN, $AppId;
        if ($account && is_a($account, __CLASS__) && $account->Id > 0) {
            // Delete older sessions or every other session
            SessionToken::ClearSessions($account->Id, defined("CLEAR_PLAYER_SESSIONS") && CLEAR_PLAYER_SESSIONS === TRUE);
            $account->GUID = $WS_TOKEN;
            $account->UpdateLastLogin();
            SessionToken::SetSession($account->Id, $account->GUID);
            $LoggedAccount = $account;
            if ($AppId->IsValid()) {
                Account_App::InsertOrUpdate($LoggedAccount->Id, $AppId->Id);
            }
        }
    }

    public static function UnsetSession() {
        global $LoggedAccount;
        if ($LoggedAccount != NULL && $LoggedAccount->IsLogged()) {
            SessionToken::UnsetSession($LoggedAccount->Id, $LoggedAccount->GUID);
            $LoggedAccount->GUID = "";
        }
        $LoggedAccount = new self();
    }

    public static function Logout() {
        self::UnsetSession();
    }

    public function Save() {
        global $Database;
        if ($this->Id < 1) {
            $query = sprintf("INSERT INTO %s (Username, Password, Email, ActivationCode, Enabled) VALUES ('%s', '%s', '%s', '%s', %d)",
                    self::GetTableName(__CLASS__),
                    $Database->Escape($this->Username),
                    $Database->Escape($this->Password),
                    $Database->Escape($this->Email),
                    $Database->Escape($this->ActivationCode),
                    $this->Enabled);
        } else {
            $query = sprintf("UPDATE %s SET Username = '%s', Email = '%s', ActivationCode = '%s', ChangePwdCode = '%s', Enabled = %d WHERE Id = %d",
                    self::GetTableName(__CLASS__),
                    $Database->Escape($this->Username),
                    $Database->Escape($this->Email),
                    $Database->Escape($this->ActivationCode),
                    $Database->Escape($this->ChangePwdCode),
                    $this->Enabled,
                    $this->Id);
        }
        $saved = $Database->Query($query);
        if ($saved) {
            if ($this->Id <= 0) {
                $this->Id = $Database->InsertedId();
            }
            return TRUE;
        }
        return FALSE;
    }

    public function Delete() {
        if ($this->Id > 0 && $this->_Delete(self::GetTableName(__CLASS__), "Id = " . $this->Id)) {
            // Delete all the associated resources
            $this->_Delete(self::GetTableName(Account_Platform::class), sprintf("IdAccount = %d", $this->Id));
            $this->_Delete(self::GetTableName(Friend::class), sprintf("IdAccount = %d OR IdFriend = %d", $this->Id, $this->Id));
            $this->_Delete(self::GetTableName(CustomData::class), "IdAccount = " . $this->Id);
            $this->_Delete(self::GetTableName(Inventory::class), "IdAccount = " . $this->Id);
            $this->_Delete(self::GetTableName(UserFile::class), "IdAccount = " . $this->Id);
            $this->_Delete(self::GetTableName(LeaderBoard_User::class), "IdAccount = " . $this->Id);
            $this->_Delete(self::GetTableName(Achievement_User::class), "IdAccount = " . $this->Id);
            $this->_Delete(self::GetTableName(GameMail::class), sprintf("IdAccount = %d OR IdSender = %d", $this->Id, $this->Id));
            return TRUE;
        }
        return FALSE;
    }
    
    public static function Prune() {
        self::TruncateClass(__CLASS__);
        self::TruncateClass(Account_App::class);
        self::TruncateClass(Account_Platform::class);
        self::TruncateClass(Friend::class);
        self::TruncateClass(Achievement_User::class);
        self::TruncateClass(UserGroup::class);
        self::TruncateClass(UserGroupAccount::class);
        self::TruncateClass(NewsletterLog::class);
        CustomData::Prune();
        UserFile::Prune();
        Inventory::Prune();
        SessionToken::Prune();
        GameMail::Prune();
        LeaderBoard_User::Prune();
        Tournament::Prune();
    }
    
    public function ChangePassword($newPassword) {
        global $Database;
        if ($this->Id > 0) {
            $query = sprintf("UPDATE %s SET Password = '%s' WHERE Id = %d",
                    self::GetTableName(__CLASS__),
                    $Database->Escape($newPassword),
                    $this->Id);
            if ($Database->Query($query)) {
                $this->Password = $newPassword;
                return TRUE;
            }
        }
        return FALSE;
    }

    public static function LoadRandom($excludeIds = array(), $customData = NULL, $limit = null, $offset = null, &$count = null, $returnArray = false) {
        global $Database;
        $where = "";
        if (!is_array($excludeIds))
            $excludeIds = array($excludeIds);
        if (count($excludeIds) > 0) {
            $ids = array();
            foreach ($excludeIds as $id) {
                if ($id > 0)
                    $ids[] = intval($id);
            }
            $where .= ($where == "" ? "" : " AND ") . "Id NOT IN (" . implode(",", $excludeIds) . ")";
        }
        if ($customData && is_array($customData) && count($customData) > 0) {
            foreach ($customData as $search_row) {
                if (!is_array($search_row))
                    continue;
                $key = $search_row["key"];
                $op = $search_row["op"];
                $value = $search_row["value"];
                
                if (!is_numeric($value))
                    $value = "'" . $Database->Escape($value) . "'";
                
                $whereCustom = sprintf("(DataKey = '%s' AND DataValue %s %s)", $Database->Escape($key), $op, $value);
                $where .= ($where == "" ? "" : " AND ") . sprintf("(ID IN (SELECT IdAccount FROM %s WHERE %s))", self::GetTableName(CustomData::class), $whereCustom);
            }
        }
        return self::_load(self::GetTableName(__CLASS__), ($returnArray ? "" : __CLASS__), $where, "RAND()", $limit, $offset, $count);
    }

    public static function LoadRandomFriends($idUser, $excludeIds = array(), $customData = NULL, $limit = null, $offset = null, &$count = null, $returnArray = false) {
        global $Database;
        $where = sprintf("(Id IN (SELECT IdFriend FROM %s WHERE IdAccount = %d AND State = %d))", self::GetTableName(Friend::class), $idUser, FRIEND_STATE_ACCEPTED);
        if (!is_array($excludeIds))
            $excludeIds = array($excludeIds);
        if (count($excludeIds) > 0) {
            $ids = array();
            foreach ($excludeIds as $id) {
                if ($id > 0)
                    $ids[] = intval($id);
            }
            if (count($ids) > 0)
                $where .= ($where == "" ? "" : " AND ") . "(Id NOT IN (" . implode(",", $ids) . "))";
        }
        if ($customData && is_array($customData) && count($customData) > 0) {
            foreach ($customData as $search_row) {
                if (!is_array($search_row))
                    continue;
                $key = $search_row["key"];
                $op = $search_row["op"];
                $value = $search_row["value"];
                
                if (!is_numeric($value))
                    $value = "'" . $Database->Escape($value) . "'";
                
                $whereCustom = sprintf("(DataKey = '%s' AND DataValue %s %s)", $Database->Escape($key), $op, $value);
                $where .= ($where == "" ? "" : " AND ") . sprintf("(ID IN (SELECT IdAccount FROM %s WHERE %s))", self::GetTableName(CustomData::class), $whereCustom);
            }
        }
        return self::_load(self::GetTableName(__CLASS__), ($returnArray ? "" : __CLASS__), $where, "RAND()", $limit, $offset, $count);
    }
    
    public static function CreateRandom($prefix, &$account = NULL) {
        $account = NULL;
        $new = new self();
        $new->Username = "__TEMP__" . session_id() . "_" . time();
        if ($new->Save()) {
            $new->Username = $prefix . $new->Id;
            $new->Save();
            $account = $new;
            return TRUE;
        }
        return FALSE;
    }

    public function ToJson () {
        $array = $this->ToArray();
        return json_encode($array);
    }
    
    public function ToArray () {
        global $LoggedAccount, $AppId;
        $array = array();
        if ($this->Id > 0 || $this->Username) {
            $array = Utils::ObjectToArray($this);
            // Remove Password from any response
            unset($array["Password"]);
            // Remove GUID token and other personal info from response if it's not me
            if ($this->Id > 0 && $this->Id == $LoggedAccount->Id) {
                $array["GUID"] = $LoggedAccount->GUID;
            } else {
                unset($array["GUID"]);
                unset($array["Email"]);
            }
            // Rename signature timestamp in something more user-friendly :P
            $lastAction = $this->GetLastActionDate();
            if ($lastAction) {
                $array["LastSeen"] = $lastAction;
            }
            // Add Custom data
            $array["CustomData"] = array();
            $customData = CustomData::Load($this->Id);
            foreach ($customData as $data) {
                $array["CustomData"][$data->DataKey] = $data->DataValue;
            }
            // Add Custom data for current App when running as web service
            $array["AppCustomData"] = array();
            $appCustomData = AppCustomData::Load($AppId->Id, $this->Id);
            foreach ($appCustomData as $data) {
                $array["AppCustomData"][$data->DataKey] = $data->DataValue;
            }
            // Add Platforms
            $array["Platforms"] = array();
            $platforms = Account_Platform::Load($this->Id);
            foreach ($platforms as $platform) {
                $array["Platforms"][] = $platform->ToArray();
            }
        }
        return $array;
    }
    
    public function ToArrayFiltered() {
        global $AppId;
        $array = $this->ToArray();
        unset($array["LastLoginDate"]);
        unset($array["LastLoginIp"]);
        unset($array["ActivationCode"]);
        unset($array["ChangePwdCode"]);
        unset($array["Enabled"]);
        // Add Custom Data
        $customData = $array["CustomData"];
        AddonModule::ProcessOutputUserCustomData($this, $customData);
        if (!$customData) {
            $customData = array();
        } else if (!is_array($customData)) {
            $customData = array($customData);
        }
        $array["CustomData"] = $customData;
        // Add Custom Data for App
        $appCustomData = $array["AppCustomData"];
        AddonModule::ProcessOutputUserCustomData($this, $appCustomData);
        if (!$appCustomData) {
            $appCustomData = array();
        } else if (!is_array($appCustomData)) {
            $appCustomData = array($appCustomData);
        }
        $array["AppCustomData"] = $appCustomData;
        AddonModule::ProcessOutputUser($array);
        return $array;
    }
    
    public function ToJsonFiltered() {
        $array = $this->ToArrayFiltered();
        return json_encode($array);
    }
}