class.ilForumTopic.php

Go to the documentation of this file.

<?php
/* Copyright (c) 1998-2012 ILIAS open source, Extended GPL, see docs/LICENSE */

require_once './Modules/Forum/classes/class.ilForumPost.php';

class ilForumTopic
{
    private $id = 0;
    
    private $forum_id = 0;
    
    private $frm_obj_id = 0;
    
    private $display_user_id = 0;
    
    private $user_alias = '';
    
    private $subject = '';
    
    private $createdate = null;
    
    private $changedate = null;
    
    private $num_posts = 0;
    
    private $last_post_string = '';
    
    private $visits = 0;
    
    private $import_name = '';
    
    private $is_sticky = 0;
    
    private $is_closed = 0;
    
    private $orderField = '';

    private $last_post = null;

    private $db = null;
    
    private $is_moderator = false;

    private $thr_author_id = 0;
    
    private $average_rating = 0;

    private $orderDirection = 'DESC';

    protected static $possibleOrderDirections = array('ASC', 'DESC');
    
    public function __construct($a_id = 0, $a_is_moderator = false, $preventImplicitRead = false)
    {
        global $DIC;

        $this->is_moderator = $a_is_moderator;
        $this->db = $DIC->database();
        $this->user = $DIC->user();
        $this->id = $a_id;
        
        if (!$preventImplicitRead) {
            $this->read();
        }
    }

    public function assignData($data)
    {
        $this->setId((int) $data['thr_pk']);
        $this->setForumId((int) $data['thr_top_fk']);
        $this->setSubject($data['thr_subject']);
        $this->setDisplayUserId((int) $data['thr_display_user_id']);
        $this->setUserAlias($data['thr_usr_alias']);
        $this->setLastPostString($data['last_post_string']);
        $this->setCreateDate($data['thr_date']);
        $this->setChangeDate($data['thr_update']);
        $this->setVisits((int) $data['visits']);
        $this->setImportName($data['import_name']);
        $this->setSticky((int) $data['is_sticky']);
        $this->setClosed((int) $data['is_closed']);
        $this->setAverageRating($data['avg_rating']);
        $this->setThrAuthorId($data['thr_author_id']);

        // Aggregated values
        $this->setNumPosts((int) $data['num_posts']);
        $this->setNumUnreadPosts((int) $data['num_unread_posts']);
        $this->setNumNewPosts((int) $data['num_new_posts']);
        $this->setUserNotificationEnabled((bool) $data['usr_notification_is_enabled']);
    }
    
    public function insert()
    {
        if ($this->forum_id) {
            $nextId = $this->db->nextId('frm_threads');
                        
            $this->db->insert(
                'frm_threads',
                array(
                'thr_pk'        => array('integer', $nextId),
                'thr_top_fk'    => array('integer', $this->forum_id),
                'thr_subject'   => array('text', $this->subject),
                'thr_display_user_id'    => array('integer', $this->display_user_id),
                'thr_usr_alias' => array('text', $this->user_alias),
                'thr_num_posts' => array('integer', $this->num_posts),
                'thr_last_post' => array('text', $this->last_post_string),
                'thr_date'      => array('timestamp', $this->createdate),
                'thr_update'    => array('timestamp', null),
                'import_name'   => array('text', $this->import_name),
                'is_sticky'     => array('integer', $this->is_sticky),
                'is_closed'     => array('integer', $this->is_closed),
                'avg_rating'    => array('float', $this->average_rating),
                'thr_author_id' => array('integer', $this->thr_author_id)
            )
            );

            $this->id = $nextId;
                            
            return true;
        }
        
        return false;
    }
    
    public function update()
    {
        if ($this->id) {
            $this->db->manipulateF(
                '
                                UPDATE frm_threads
                                SET thr_top_fk = %s,
                                        thr_subject = %s,
                                        thr_update = %s,
                                        thr_num_posts = %s,
                                        thr_last_post = %s,
                                        avg_rating = %s
                                WHERE thr_pk = %s',
                array('integer', 'text','timestamp', 'integer', 'text', 'float', 'integer'),
                array(  $this->forum_id,
                        $this->subject,
            /*                  $this->changedate, */
                        date('Y-m-d H:i:s'),
                        $this->num_posts,
                        $this->last_post_string,
                        $this->average_rating,
                        $this->id
            )
            );
            
            return true;
        }
        
        return false;
    }
    
    private function read()
    {
        if ($this->id) {
            $res = $this->db->queryf(
                '
                                SELECT frm_threads.*, top_frm_fk frm_obj_id
                                FROM frm_threads
                                INNER JOIN frm_data ON top_pk = thr_top_fk
                                WHERE thr_pk = %s',
                array('integer'),
                array($this->id)
            );

            $row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT);

            if (is_object($row)) {
                $this->thr_pk           = $row->pos_pk;   // thr_pk = pos_pk ??!??!
                $this->forum_id         = $row->thr_top_fk;
                $this->display_user_id  = $row->thr_display_user_id;
                $this->user_alias       = $row->thr_usr_alias;
                $this->subject          = html_entity_decode($row->thr_subject);
                $this->createdate       = $row->thr_date;
                $this->changedate       = $row->thr_update;
                $this->import_name      = $row->import_name;
                $this->num_posts        = $row->thr_num_posts;
                $this->last_post_string = $row->thr_last_post;
                $this->visits           = $row->visits;
                $this->is_sticky        = $row->is_sticky;
                $this->is_closed        = $row->is_closed;
                $this->frm_obj_id       = $row->frm_obj_id;
                $this->average_rating   = $row->avg_rating;
                $this->thr_author_id    = $row->thr_author_id;
                
                return true;
            }
            $this->id = 0;
            return false;
        }
        
        return false;
    }
    
    public function reload()
    {
        return $this->read();
    }
    
    public function getFirstPostId()
    {
        $res = $this->db->queryf(
            '
                        SELECT * FROM frm_posts_tree 
                        WHERE thr_fk = %s
                        AND parent_pos = %s',
            array('integer', 'integer'),
            array($this->id, '1')
        );
        
        $row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT);
        
        return $row->pos_fk ? $row->pos_fk : 0;
    }
    
    public function updateVisits()
    {
        $checkTime = time() - (60 * 60);
        
        if ($_SESSION['frm_visit_frm_threads_' . $this->id] < $checkTime) {
            $_SESSION['frm_visit_frm_threads_' . $this->id] = time();
        
            $this->db->manipulateF(
                '
                                UPDATE frm_threads
                                SET     visits = visits + 1
                                WHERE thr_pk = %s',
                array('integer'),
                array($this->id)
            );
        }
        
        return true;
    }
    
    public function countPosts()
    {
        $res = $this->db->queryf(
            '
                        SELECT COUNT(*) cnt
                        FROM frm_posts
                        WHERE pos_thr_fk = %s',
            array('integer'),
            array($this->id)
        );
        
        $rec = $res->fetchRow(ilDBConstants::FETCHMODE_ASSOC);
            
        return $rec['cnt'];
    }
    
    public function countActivePosts()
    {
        $res = $this->db->queryf(
            '
                        SELECT COUNT(*) cnt
                        FROM frm_posts
                        WHERE (pos_status = %s
                                 OR (pos_status = %s AND pos_display_user_id = %s))
                        AND pos_thr_fk = %s',
            array('integer', 'integer', 'integer', 'integer'),
            array('1', '0', $this->user->getId(), $this->id)
        );
            
        $rec = $res->fetchRow(ilDBConstants::FETCHMODE_ASSOC);
            
        return $rec['cnt'];
    }
    
    public function getFirstPostNode()
    {
        $res = $this->db->queryf(
            '
                        SELECT pos_pk
                        FROM frm_posts 
                        INNER JOIN frm_posts_tree ON pos_fk = pos_pk
                        WHERE parent_pos = %s
                        AND thr_fk = %s',
            array('integer', 'integer'),
            array('0', $this->id)
        );
            
        $row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT);
        
        return new ilForumPost($row->pos_pk);
    }
    
    public function getLastPost()
    {
        if ($this->id) {
            $this->db->setLimit(1);
            $res = $this->db->queryf(
                '
                                SELECT pos_pk
                                FROM frm_posts 
                                WHERE pos_thr_fk = %s                            
                                ORDER BY pos_date DESC',
                array('integer'),
                array($this->id)
            );
            
            $row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT);

            return new ilForumPost($row->pos_pk);
        }
        
        return false;
    }
    
    public function getLastActivePost()
    {
        if ($this->id) {
            $this->db->setLimit(1);
            $res = $this->db->queryf(
                '
                                SELECT pos_pk
                                FROM frm_posts 
                                WHERE pos_thr_fk = %s           
                                AND (pos_status = %s OR 
                                        (pos_status = %s AND pos_display_user_id = %s))                                                  
                                ORDER BY pos_date DESC',
                array('integer', 'integer', 'integer', 'integer'),
                array($this->id, '1', '0', $this->user->getId())
            );
            
            $row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT);
            
            return new ilForumPost($row->pos_pk);
        }
        
        return false;
    }
    
    public function getAllPosts()
    {
        $posts = array();
        
        if ($this->id) {
            $res = $this->db->queryf(
                '
                                SELECT pos_pk
                                FROM frm_posts 
                                WHERE pos_thr_fk = %s',
                array('integer'),
                array($this->id)
            );
            
            while ($row = $res->fetchRow(ilDBConstants::FETCHMODE_OBJECT)) {
                $posts[$row->pos_pk] = $row;
            }
        }
        
        return is_array($posts) ? $posts : array();
    }
 
    public function getPostTree(ilForumPost $a_post_node)
    {
        $posts = array();
        
        $data = array();
        $data_types = array();

        $query = '
                        SELECT                  is_author_moderator, pos_author_id, pos_pk, fpt_date, rgt, pos_top_fk, pos_thr_fk, 
                                                        pos_display_user_id, pos_usr_alias, pos_subject,
                                                        pos_status, pos_message, pos_date, pos_update,
                                                        update_user, pos_cens, pos_cens_com, notify,
                                                        import_name, fpt_pk, parent_pos, lft, depth,
                                                        (CASE
                                                        WHEN fur.post_id IS NULL ' .
                                ($this->user->getId() == ANONYMOUS_USER_ID ? ' AND 1 = 2 ' : '') . '
                                                        THEN 0
                                                        ELSE 1
                                                        END) post_read,
                                                        firstname, lastname, title, login
                                                         
                        FROM                    frm_posts_tree
                         
                        INNER JOIN              frm_posts 
                                ON                      pos_fk = pos_pk
                                
                        LEFT JOIN               usr_data
                                ON                      pos_display_user_id  = usr_id
                                
                        LEFT JOIN               frm_user_read fur
                                ON                      fur.thread_id = pos_thr_fk
                                AND                     fur.post_id = pos_pk
                                AND                     fur.usr_id = %s
                                 
                        WHERE                   lft BETWEEN %s AND %s 
                                AND             thr_fk = %s';
        
        array_push($data_types, 'integer', 'integer', 'integer', 'integer');
        array_push($data, $this->user->getId(), $a_post_node->getLft(), $a_post_node->getRgt(), $a_post_node->getThreadId());

        if ($this->orderField != "") {
            $query .= " ORDER BY " . $this->orderField . " " . $this->getOrderDirection();
        }

        $res = $this->db->queryf($query, $data_types, $data);
        
        $usr_ids = array();

        $deactivated = array();
        while ($row = $this->db->fetchAssoc($res)) {
            $tmp_object = new ilForumPost($row['pos_pk'], false, true);
            $tmp_object->assignData($row);

            if (!$this->is_moderator) {
                if (!$tmp_object->isActivated() && $tmp_object->getDisplayUserId() != $this->user->getId()) {
                    $deactivated[] = $tmp_object;
                    unset($tmp_object);
                    continue;
                }
             
                foreach ($deactivated as $deactivated_node) {
                    if ($deactivated_node->getLft() < $tmp_object->getLft() && $deactivated_node->getRgt() > $tmp_object->getLft()) {
                        $deactivated[] = $tmp_object;
                        unset($tmp_object);
                        continue 2;
                    }
                }
            }

            if ((int) $row['pos_display_user_id']) {
                $usr_ids[] = (int) $row['pos_display_user_id'];
            }
            if ((int) $row['update_user']) {
                $usr_ids[] = (int) $row['update_user'];
            }
             
            $posts[] = $tmp_object;
             
            unset($tmp_object);
        }

        require_once 'Modules/Forum/classes/class.ilForumAuthorInformationCache.php';
        ilForumAuthorInformationCache::preloadUserObjects(array_unique($usr_ids));

        return $posts;
    }
    
    public function movePosts($old_obj_id, $old_pk, $new_obj_id, $new_pk)
    {
        if ($this->id) {
            $nodes = $this->getAllPosts();
            if (is_array($nodes)) {
                $postsMoved = array();
                // Move attachments
                try {
                    foreach ($nodes as $node) {
                        $file_obj = new ilFileDataForum((int) $old_obj_id, (int) $node->pos_pk);
                        $moved = $file_obj->moveFilesOfPost((int) $new_obj_id);

                        if (true === $moved) {
                            $postsMoved[] = array(
                                'from' => $old_obj_id,
                                'to' => $new_obj_id,
                                'position_id' => (int) $node->pos_pk
                            );
                        }

                        unset($file_obj);
                    }
                } catch (\ilFileUtilsException $exception) {
                    foreach ($postsMoved as $postedInformation) {
                        $file_obj = new ilFileDataForum($postedInformation['to'], $postedInformation['position_id']);
                        $file_obj->moveFilesOfPost($postedInformation['from']);
                    }

                    throw $exception;
                }
            }

            $current_id = $this->id;

            $ilAtomQuery = $this->db->buildAtomQuery();
            $ilAtomQuery->addTableLock('frm_user_read');
            $ilAtomQuery->addTableLock('frm_thread_access');

            $ilAtomQuery->addQueryCallable(function (ilDBInterface $ilDB) use ($new_obj_id, $current_id) {
                $ilDB->manipulateF(
                    '
                                DELETE FROM frm_user_read
                                WHERE obj_id = %s AND thread_id =%s',
                    array('integer', 'integer'),
                    array($new_obj_id, $current_id)
                );

                $ilDB->manipulateF(
                    '
                                UPDATE frm_user_read
                                SET obj_id = %s
                                WHERE thread_id = %s',
                    array('integer', 'integer'),
                    array($new_obj_id, $current_id)
                );

                $ilDB->manipulateF(
                    '
                                DELETE FROM frm_thread_access
                                WHERE obj_id = %s AND thread_id =%s',
                    array('integer', 'integer'),
                    array($new_obj_id, $current_id)
                );

                $ilDB->manipulateF(
                    '
                                UPDATE frm_thread_access
                                SET obj_id = %s
                                WHERE thread_id =%s',
                    array('integer', 'integer'),
                    array($new_obj_id, $current_id)
                );
            });

            $ilAtomQuery->run();

            $this->db->manipulateF(
                '
                                UPDATE frm_posts
                                SET pos_top_fk = %s
                                WHERE pos_thr_fk = %s',
                array('integer', 'integer'),
                array($new_pk, $this->id)
            );
            
            // update all related news
            $posts = $this->db->queryf(
                '
                                SELECT * FROM frm_posts WHERE pos_thr_fk = %s',
                array('integer'),
                array($this->id)
            );
            
            $old_obj_id = ilForum::_lookupObjIdForForumId($old_pk);

            $new_obj_id = ilForum::_lookupObjIdForForumId($new_pk);

            while ($post = $posts->fetchRow(ilDBConstants::FETCHMODE_ASSOC)) {
                include_once("./Services/News/classes/class.ilNewsItem.php");
                $news_id = ilNewsItem::getFirstNewsIdForContext(
                    $old_obj_id,
                    "frm",
                    $post["pos_pk"],
                    "pos"
                );
                $news_item = new ilNewsItem($news_id);
                $news_item->setContextObjId($new_obj_id);
                $news_item->update();
                //echo "<br>-".$post["pos_pk"]."-".$old_obj_id."-".$new_obj_id."-";
            }
            
            return count($nodes);
        }
        
        return 0;
    }
    
    public function getNestedSetPostChildren($pos_id = null, $levels = null)
    {
        $data = null;
        $objProperties = ilForumProperties::getInstance($this->getFrmObjId());
        $is_post_activation_enabled = $objProperties->isPostActivationEnabled();

        if ($pos_id !== null) {
            $res = $this->db->queryF(
                "
                                SELECT          lft, rgt, depth
                                FROM            frm_posts_tree
                                WHERE           pos_fk = %s
                                AND                     thr_fk = %s",
                array('integer', 'integer'),
                array($pos_id, $this->id)
            );

            $data = $this->db->fetchAssoc($res);
        }

        $query = '
                        SELECT                  fpt.depth,
                                                        fpt.rgt,
                                                        fpt.parent_pos,
                                                        fp.pos_pk,
                                                        fp.pos_subject,
                                                        fp.pos_usr_alias,
                                                        fp.pos_date,
                                                        fp.pos_update,
                                                        fp.pos_status,
                                                        fp.pos_display_user_id,
                                                        fp.pos_usr_alias,
                                                        fp.import_name,
                                                        fp.pos_author_id,
                                                        fp.is_author_moderator,
                                                        fur.post_id,
                                                        (CASE
                                                        WHEN fur.post_id IS NULL ' .
                                ($this->user->getId() == ANONYMOUS_USER_ID ? ' AND 1 = 2 ' : '') . '
                                                        THEN 0
                                                        ELSE 1
                                                        END) post_read,
                                                        COUNT(fpt2.pos_fk) children

                        FROM                    frm_posts_tree fpt

                        INNER JOIN              frm_posts fp
                                ON                      fp.pos_pk = fpt.pos_fk
                                
                        LEFT JOIN               frm_posts_tree fpt2
                                 ON         fpt2.lft BETWEEN fpt.lft AND fpt.rgt
                                 AND            fpt.thr_fk = fpt2.thr_fk
                                 AND            fpt.pos_fk != fpt2.pos_fk ';
                                
    
        $query .= '
                        LEFT JOIN               frm_user_read fur
                                ON                      fur.thread_id = fp.pos_thr_fk
                                AND                     fur.post_id = fp.pos_pk
                                AND                     fur.usr_id = ' . $this->db->quote($this->user->getId(), 'integer') . '

                        LEFT JOIN               usr_data ud
                                ON                      ud.usr_id = fp.pos_display_user_id
                
                        WHERE                   fpt.thr_fk = ' . $this->db->quote($this->id, 'integer');

        if ($data) {
            $query .= '         AND fpt.lft > ' . $this->db->quote($data['lft'], 'integer') .
                    '           AND fpt.lft < ' . $this->db->quote($data['rgt'], 'integer') . ' ';
        }
        if ($is_post_activation_enabled && !$this->is_moderator) {
            $query .= ' AND (fp.pos_status = 1 OR fp.pos_status = 0 AND fp.pos_display_user_id = ' . $this->db->quote($this->user->getId(), 'integer') . ') ';
        }

        if ($data && is_numeric($levels)) {
            $query .= ' AND fpt.depth <= ' . $this->db->quote($data['depth'] + $levels, 'integer') . ' ';
        }

        $query .= ' GROUP BY fpt.depth,
                                                        fpt.rgt,
                                                        fpt.parent_pos,
                                                        fp.pos_pk,
                                                        fp.pos_subject,
                                                        fp.pos_usr_alias,
                                                        fp.pos_date,
                                                        fp.pos_update,
                                                        fp.pos_status,
                                                        fp.pos_display_user_id,
                                                        fp.pos_usr_alias,
                                                        fp.import_name,
                                                        fp.pos_author_id,
                                                        fp.is_author_moderator,
                                                        fur.post_id
                                        ORDER BY fpt.rgt DESC
                ';
        
        $queryCounter = '
                        SELECT                  pos_fk
                        FROM                    frm_posts_tree fpt
                        INNER JOIN              frm_posts fp
                                ON                      fp.pos_pk = fpt.pos_fk
                        WHERE                   fpt.thr_fk = ' . $this->db->quote($this->id, 'integer');

        if ($is_post_activation_enabled && !$this->is_moderator) {
            $queryCounter .= ' AND (fp.pos_status = 1 OR fp.pos_status = 0 AND fp.pos_display_user_id = ' . $this->db->quote($this->user->getId(), 'integer') . ') ';
        }
        $queryCounter .= ' ORDER BY fpt.rgt DESC';

        $resCounter = $this->db->query($queryCounter);
        $counter = array();
        $i = 0;
        while ($row = $this->db->fetchAssoc($resCounter)) {
            $counter[$row['pos_fk']] = $i++;
        }

        $res = $this->db->query($query);
        $children = array();
        $usr_ids = array();
        while ($row = $this->db->fetchAssoc($res)) {
            if ((int) $row['pos_display_user_id']) {
                $usr_ids[] = (int) $row['pos_display_user_id'];
            }
            
            $row['counter'] = $counter[$row['pos_pk']];
            $children[] = $row;
        }

        require_once 'Modules/Forum/classes/class.ilForumAuthorInformationCache.php';
        ilForumAuthorInformationCache::preloadUserObjects(array_unique($usr_ids));

        return $children;
    }
    
    public function isNotificationEnabled($a_user_id)
    {
        if ($this->id && $a_user_id) {
            $result = $this->db->queryf(
                '
                                SELECT COUNT(notification_id) cnt FROM frm_notification 
                                WHERE user_id = %s AND thread_id = %s',
                array('integer', 'integer'),
                array($a_user_id, $this->id)
            );

            while ($record = $this->db->fetchAssoc($result)) {
                return (bool) $record['cnt'];
            }
            
            return false;
        }
        
        return false;
    }
    
    public function enableNotification($a_user_id)
    {
        if ($this->id && $a_user_id) {
            if (!$this->isNotificationEnabled($a_user_id)) {
                $nextId = $this->db->nextId('frm_notification');
                $this->db->manipulateF(
                    '
                                        INSERT INTO frm_notification
                                        (       notification_id,
                                                user_id,
                                                thread_id
                                        )
                                        VALUES(%s, %s, %s)',
                    array('integer', 'integer', 'integer'),
                    array($nextId, $a_user_id, $this->id)
                );

                return true;
            }
            return false;
        }
        
        return false;
    }
    
    public function disableNotification($a_user_id)
    {
        if ($this->id && $a_user_id) {
            $this->db->manipulateF(
                '
                                DELETE FROM frm_notification
                                WHERE user_id = %s
                                AND thread_id = %s',
                array('integer', 'integer'),
                array($a_user_id, $this->id)
            );
                
            return false;
        }
        
        return false;
    }
    
    public function makeSticky()
    {
        if ($this->id && !$this->is_sticky) {
            $this->db->manipulateF(
                '
                                UPDATE frm_threads 
                                SET is_sticky = %s
                                WHERE thr_pk = %s',
                array('integer', 'integer'),
                array('1', $this->id)
            );
            
            $this->is_sticky = 1;
            
            return true;
        }
        
        return false;
    }
    
    public function unmakeSticky()
    {
        if ($this->id && $this->is_sticky) {
            $this->db->manipulateF(
                '
                                UPDATE frm_threads 
                                SET is_sticky = %s
                                WHERE thr_pk = %s',
                array('integer', 'integer'),
                array('0', $this->id)
            );
            
            $this->is_sticky = 0;
            
            return true;
        }
        
        return false;
    }
    
    public function close()
    {
        if ($this->id && !$this->is_closed) {
            $this->db->manipulateF(
                '
                                UPDATE frm_threads 
                                SET is_closed = %s
                                WHERE thr_pk = %s',
                array('integer', 'integer'),
                array('1', $this->id)
            );
                
            $this->is_closed = 1;
            
            return true;
        }
        
        return false;
    }
    
    public function reopen()
    {
        if ($this->id && $this->is_closed) {
            $this->db->manipulateF(
                '
                                UPDATE frm_threads 
                                SET is_closed = %s
                                WHERE thr_pk = %s',
                array('integer', 'integer'),
                array('0', $this->id)
            );
                                
            $this->is_closed = 0;
            
            return true;
        }
        
        return false;
    }

    public function getAverageRating()
    {
        return $this->average_rating;
    }

    public function setAverageRating($average_rating)
    {
        $this->average_rating = $average_rating;
    }

    public function setId($a_id)
    {
        $this->id = $a_id;
    }
    public function getId()
    {
        return $this->id;
    }
    public function setForumId($a_forum_id)
    {
        $this->forum_id = $a_forum_id;
    }
    public function getForumId()
    {
        return $this->forum_id;
    }
    public function setDisplayUserId($a_user_id)
    {
        $this->display_user_id = $a_user_id;
    }
    public function getDisplayUserId()
    {
        return $this->display_user_id;
    }
    public function setUserAlias($a_user_alias)
    {
        $this->user_alias = $a_user_alias;
    }
    public function getUserAlias()
    {
        return $this->user_alias;
    }
    public function setSubject($a_subject)
    {
        $this->subject = $a_subject;
    }
    public function getSubject()
    {
        return $this->subject;
    }
    public function setCreateDate($a_createdate)
    {
        $this->createdate = $a_createdate;
    }
    public function getCreateDate()
    {
        return $this->createdate;
    }
    public function setChangeDate($a_changedate)
    {
        if ($a_changedate == '0000-00-00 00:00:00') {
            $this->changedate = null;
        } else {
            $this->changedate = $a_changedate;
        }
    }
    public function getChangeDate()
    {
        return $this->changedate;
    }
    public function setImportName($a_import_name)
    {
        $this->import_name = $a_import_name;
    }
    public function getImportName()
    {
        return $this->import_name;
    }
    public function setLastPostString($a_last_post)
    {
        if ($a_last_post == '') {
            $a_last_post = null;
        }
        
        $this->last_post_string = $a_last_post;
    }
    public function getLastPostString()
    {
        return $this->last_post_string;
    }
    public function setVisits($a_visits)
    {
        $this->visits = $a_visits;
    }
    public function getVisits()
    {
        return $this->visits;
    }
    public function setSticky($a_sticky)
    {
        $this->is_sticky = $a_sticky;
    }
    public function isSticky()
    {
        return $this->is_sticky == 1 ? true : false;
    }
    public function setClosed($a_closed)
    {
        $this->is_closed = $a_closed;
    }
    public function isClosed()
    {
        return $this->is_closed == 1 ? true : false;
    }
    public function setOrderField($a_order_field)
    {
        $this->orderField = $a_order_field;
    }
    public function getOrderField()
    {
        return $this->orderField;
    }
    public function setModeratorRight($bool)
    {
        $this->is_moderator = $bool;
    }
    public function getModeratorRight()
    {
        return $this->is_moderator;
    }
    public function getFrmObjId()
    {
        return $this->frm_obj_id;
    }

    public function setThrAuthorId($thr_author_id)
    {
        $this->thr_author_id = $thr_author_id;
    }

    public function getThrAuthorId()
    {
        return $this->thr_author_id;
    }
    
    public static function _lookupTitle($a_topic_id)
    {
        global $DIC;
        $ilDB = $DIC->database();
        
        $res = $ilDB->queryf(
            '
                        SELECT thr_subject
                        FROM frm_threads
                        WHERE thr_pk = %s',
            array('integer'),
            array($a_topic_id)
        );
        $row = $ilDB->fetchObject($res);

        if (is_object($row)) {
            return $row->thr_subject;
        }
        
        return '';
    }

    public function updateThreadTitle()
    {
        $this->db->update(
            'frm_threads',
            array('thr_subject' => array('text',$this->getSubject())),
            array('thr_pk'=> array('integer', $this->getId()))
        );
    }

    public function setNumPosts($a_num_posts)
    {
        $this->num_posts = $a_num_posts;
        return $this;
    }

    public function getNumPosts()
    {
        return $this->num_posts;
    }

    public function setNumNewPosts($num_new_posts)
    {
        $this->num_new_posts = $num_new_posts;
        return $this;
    }

    public function getNumNewPosts()
    {
        return $this->num_new_posts;
    }

    public function setNumUnreadPosts($num_unread_posts)
    {
        $this->num_unread_posts = $num_unread_posts;
        return $this;
    }

    public function getNumUnreadPosts()
    {
        return $this->num_unread_posts;
    }

    public function setUserNotificationEnabled($user_notification_enabled)
    {
        $this->user_notification_enabled = $user_notification_enabled;
        return $this;
    }

    public function getUserNotificationEnabled()
    {
        return $this->user_notification_enabled;
    }

    public function setOrderDirection($direction)
    {
        if (!in_array(strtoupper($direction), self::$possibleOrderDirections)) {
            $direction = current(self::$possibleOrderDirections);
        }
        
        $this->orderDirection = $direction;
        return $this;
    }

    public function getOrderDirection()
    {
        return $this->orderDirection;
    }
    
    public function getLastPostForThreadOverview()
    {
        return $this->last_post;
    }
    
    public function setLastPostForThreadOverview(ilForumPost $post)
    {
        $this->last_post = $post;
    }
    
    public static function lookupForumIdByTopicId($a_topic_id)
    {
        global $DIC;
        $ilDB = $DIC->database();

        $res = $ilDB->queryF(
            'SELECT thr_top_fk FROM frm_threads WHERE thr_pk = %s',
            array('integer'),
            array($a_topic_id)
        );

        $row = $ilDB->fetchAssoc($res);

        return $row['thr_top_fk'];
    }
    
    public function getSorting()
    {
        return $this->thread_sorting;
    }
    public function updateMergedThread()
    {
        $this->db->update(
            'frm_threads',
            array(
                'thr_num_posts' => array('integer', $this->getNumPosts()),
                'visits'                => array('integer', $this->getVisits()),
                'thr_last_post' => array('text', $this->getLastPostString()),
                'thr_subject'           => array('text', $this->getSubject())
            ),
            array('thr_pk' => array('integer', $this->getId()))
        );
    }

    public static function deleteByThreadId($thr_id)
    {
        global $DIC;
        $DIC->database()->manipulateF(
            'DELETE FROM frm_threads WHERE thr_pk = %s',
            array('integer'),
            array($thr_id)
        );
    }


    public static function _lookupDate($thread_id)
    {
        global $DIC;
        $ilDB = $DIC->database();
        
        $res = $ilDB->queryF(
            'SELECT thr_date FROM frm_threads WHERE thr_pk = %s',
            array('integer'),
            array((int) $thread_id)
        );
        
        $row = $ilDB->fetchAssoc($res);
        
        return $row['thr_date'] ? $row['thr_date'] : '0000-00-00 00:00:00';
    }
}