GameMail.php

Go to the documentation of this file.

<?php

namespace Combu;

class GameMail extends DataClass {

    const TABLE_NAME = "Mail";

    public $Id = 0;
    public $IdAccount = 0;
    public $IdGroup = 0;
    public $IdSender = 0;
    public $IsPublic = 0;
    public $SendDate = "";
    public $ReadDate = "";
    public $Subject = "";
    public $Message = "";

    public function __construct($src = null, $stripSlashes = false) {
        global $Database;
        if ($src == null)
            return;
        if (is_array($src)) {
            // Load by array
            $this->_loadByRow($src, $stripSlashes);
        } else if (is_numeric($src) && intval($src) > 0) {
            // Load by Id
            $this->_loadFilter(self::GetTableName(__CLASS__), "Id = " . intval($src));
        }
    }

    public static function Load ($idAccount = 0, $idSender = 0, $idGroup = 0, $unread = FALSE, $limit = null, $offset = null, &$count = null, $returnArray = false) {
        $where = NULL;
        if ($idAccount > 0) {
            $where .= ($where ? " AND " : "") . sprintf("(IdAccount = %d)", $idAccount);
        }
        if ($idSender > 0) {
            $where .= ($where ? " AND " : "") . sprintf("(IdSender = %d)", $idSender);
        }
        if ($idGroup > 0) {
            $where .= ($where ? " AND " : "") . sprintf("(IdGroup = %d)", $idGroup);
        }
        if ($unread === TRUE) {
            $where .= ($where ? " AND " : "") . "(ReadDate IS NULL)";
        }
        return self::_load(self::GetTableName(__CLASS__), ($returnArray ? "" : __CLASS__), $where, "SendDate DESC", $limit, $offset, $count);
    }
    
    public static function LoadUnread($idAccount, $idSenders = array(), $idGroups = array(), $returnArray = false) {
        $where = sprintf("(ReadDate IS NULL AND IdAccount = %d)", $idAccount);
        if (count($idSenders) > 0)
            $where .= ($where ? " AND " : "") . sprintf("(IdGroup = 0 AND IdSender IN (%s))", implode(",", $idSenders));
        if (count($idGroups) > 0)
            $where .= ($where ? " AND " : "") . sprintf("(IdGroup IN (%s))", implode(",", $idGroups));
        return self::_load(self::GetTableName(__CLASS__), ($returnArray ? "" : __CLASS__), $where, "SendDate DESC", $limit, $offset, $count);
    }
    
    public static function LoadConversations ($idAccount) {
        $where = sprintf("(IdAccount = %d OR IdSender = %d)", $idAccount, $idAccount);
        $query = "SELECT * FROM (" .
                "SELECT IF(IdSender = " . $idAccount . ", IdAccount, IdSender) AS IdSender, IdGroup, SendDate FROM " . self::GetTableName(__CLASS__) . " WHERE IdGroup = 0 AND " . $where . " GROUP BY IF(IdSender = " . $idAccount . ", IdAccount, IdSender)" .
                " UNION SELECT 0 AS IdSender, IdGroup, SendDate FROM " . self::GetTableName(__CLASS__) . " WHERE IdGroup > 0 AND IdAccount = " . $idAccount . " GROUP BY IdGroup ORDER BY SendDate DESC" .
                ") T ORDER BY SendDate DESC";
        $recs = self::_loadQuery($query);
        $result = array();
        foreach ($recs as $r) {
            if ($r["IdGroup"] > 0) {
                $group = new UserGroup($r["IdGroup"]);
                $result[] = $group->ToArray();
            } else {
                $user = new Account($r["IdSender"]);
                $result[] = $user->ToArray();
            }
        }
        return $result;
    }

    public static function LoadConversationMessages ($myAccount, $otherAccount, $idGroup, $limit = null, $offset = null, &$count = null, $returnArray = false) {
        if ($otherAccount < 1 && $idGroup < 1) {
            return array();
        }
        $where = sprintf("(IdAccount = %d OR IdSender = %d)", $myAccount, $myAccount);
        if ($otherAccount > 0)
            $where .= sprintf(" AND (IdAccount = %d OR IdSender = %d)", $otherAccount, $otherAccount);
        if ($idGroup > 0)
            $where .= sprintf(" AND (IdGroup = %d)", $idGroup) . " GROUP BY IdSender, SendDate";
        return self::_load(self::GetTableName(__CLASS__), ($returnArray ? "" : __CLASS__), $where, "SendDate DESC", $limit, $offset, $count);
    }

    public function Save() {
        global $Database;
        if ($this->Id > 0) {
            $query = sprintf("UPDATE %s SET IsPublic = %d, Subject = '%s', Message = '%s', ReadDate = %s WHERE Id = %d",
                    self::GetTableName(__CLASS__),
                    $this->IsPublic,
                    $Database->Escape($this->Subject),
                    $Database->Escape($this->Message),
                    $Database->EscapeDate($this->ReadDate),
                    $this->Id);
        } else {
            if (!$this->SendDate)
                $this->SendDate = date("Y-m-d H:i:s");
            $query = sprintf("INSERT INTO %s (SendDate, ReadDate, IdAccount, IdGroup, IdSender, IsPublic, Subject, Message) VALUES (%s, NULL, %d, %d, %d, %d, '%s', '%s')",
                    self::GetTableName(__CLASS__),
                    $Database->EscapeDate($this->SendDate),
                    $this->IdAccount,
                    $this->IdGroup,
                    $this->IdSender,
                    $this->IsPublic,
                    $Database->Escape($this->Subject),
                    $Database->Escape($this->Message));
        }
        if ($Database->Query($query)) {
            if ($this->Id < 1)
                $this->Id = $Database->InsertedId();
            return TRUE;
        }
        return FALSE;
    }

    public function Delete() {
        if ($this->Id < 1)
            return FALSE;
        return $this->_Delete(self::GetTableName(__CLASS__), "Id = " . $this->Id);
    }
    
    public static function Prune() {
        self::TruncateClass(__CLASS__);
    }
    
    public function ToArray() {
        $from = new Account($this->IdSender);
        $to = new Account($this->IdAccount);
        $array = Utils::ObjectToArray($this);
        $array["From"] = $from->ToJson();
        $array["To"] = $to->ToJson();
        if ($this->IdGroup > 0) {
            $group = new UserGroup($this->IdGroup);
            $array["ToGroup"] = $group->ToArray();
        }
        return $array;
    }
    
    public function ToJson() {
        $array = $this->ToArray();
        return json_encode($array);
    }
}