privmessage.php

Go to the documentation of this file.

<?php
use Xoops\Core\Database\Connection;
use Xoops\Core\Kernel\XoopsObject;
use Xoops\Core\Kernel\XoopsPersistableObjectHandler;

class XoopsPrivmessage extends XoopsObject
{
    public function __construct()
    {
        $this->initVar('msg_id', XOBJ_DTYPE_INT, null, false);
        $this->initVar('msg_image', XOBJ_DTYPE_OTHER, null, false, 100);
        $this->initVar('subject', XOBJ_DTYPE_TXTBOX, null, true, 255);
        $this->initVar('from_userid', XOBJ_DTYPE_INT, null, true);
        $this->initVar('to_userid', XOBJ_DTYPE_INT, null, true);
        $this->initVar('msg_time', XOBJ_DTYPE_OTHER, time(), false);
        $this->initVar('msg_text', XOBJ_DTYPE_TXTAREA, null, true);
        $this->initVar('read_msg', XOBJ_DTYPE_INT, 0, false);
    }

    public function id($format = 'n')
    {
        return $this->getVar('msg_id', $format);
    }

    public function msg_id($format = '')
    {
        return $this->getVar('msg_id', $format);
    }

    public function msg_image($format = '')
    {
        return $this->getVar('msg_image', $format);
    }

    public function subject($format = '')
    {
        return $this->getVar('subject', $format);
    }

    public function from_userid($format = '')
    {
        return $this->getVar('from_userid', $format);
    }

    public function to_userid($format = '')
    {
        return $this->getVar('to_userid', $format);
    }

    public function msg_time($format = '')
    {
        return $this->getVar('msg_time', $format);
    }

    public function msg_text($format = '')
    {
        return $this->getVar('msg_text', $format);
    }

    public function read_msg($format = '')
    {
        return $this->getVar('read_msg', $format);
    }

}

class XoopsPrivmessageHandler extends XoopsPersistableObjectHandler
{
    public function __construct(Connection $db = null)
    {
        parent::__construct($db, 'priv_msgs', 'XoopsPrivmessage', 'msg_id', 'subject');
    }

    public function setRead(XoopsPrivmessage &$pm)
    {
        $qb = $this->db2->createXoopsQueryBuilder()
            ->update($this->table, 'pm')
            ->set('pm.read_msg', ':readmsg')
            ->where('pm.msg_id = :msgid')
            ->setParameter(':readmsg', 1, \PDO::PARAM_INT)
            ->setParameter(':msgid', $pm->getVar('msg_id'), \PDO::PARAM_INT);
        $result = $qb->execute();

        if (!$result) {
            return false;
        }
        return true;
    }
}