Mibew/mibew
1
0
Fork 0
mirror of https://github.com/Mibew/mibew.git synced 2025-06-06 17:16:15 +03:00
Code Issues Actions Packages Projects Releases Wiki Activity

set message count on close thread

Browse Source
This commit is contained in:
Silron88 2015-08-19 02:58:51 +03:00
parent e30eafb2d0
commit 9439ca4ffe
1 changed files with 22 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
src/mibew/libs/classes/Mibew/Thread.php
View File

@ -437,6 +437,7 @@ class Thread
$thread->modified = $now; $thread->modified = $now;
$thread->closed = $now; $thread->closed = $now;
$thread->state = self::STATE_CLOSED; $thread->state = self::STATE_CLOSED;
$thread->messageCount = $thread->getUserMessageCount();
$thread->save(); $thread->save();
unset($thread); unset($thread);
} }
@ -908,6 +909,26 @@ class Thread
); );
} }
public function getUserMessageCount() {
// Get messages count
$db = Database::getInstance();
list($message_count) = $db->query(
("SELECT COUNT(*) FROM {message} "
. "WHERE {message}.threadid = :threadid AND ikind = :kind_user"),
array(
':threadid' => $this->id,
':kind_user' => Thread::KIND_USER,
),
array(
'return_rows' => Database::RETURN_ONE_ROW,
'fetch_type' => Database::FETCH_NUM,
)
);
return $message_count;
}
/** /**
* Close thread and send closing messages to the conversation members * Close thread and send closing messages to the conversation members
* *
@ -953,27 +974,11 @@ class Thread
} }
} }
// Get messages count
$db = Database::getInstance();
list($message_count) = $db->query(
("SELECT COUNT(*) FROM {message} "
. "WHERE {message}.threadid = :threadid AND ikind = :kind_user"),
array(
':threadid' => $this->id,
':kind_user' => Thread::KIND_USER,
),
array(
'return_rows' => Database::RETURN_ONE_ROW,
'fetch_type' => Database::FETCH_NUM,
)
);
// Close thread if it's not already closed // Close thread if it's not already closed
if ($this->state != self::STATE_CLOSED) { if ($this->state != self::STATE_CLOSED) {
$this->state = self::STATE_CLOSED; $this->state = self::STATE_CLOSED;
$this->closed = time(); $this->closed = time();
$this->messageCount = $message_count; $this->messageCount = $this->getUserMessageCount();
$this->save(); $this->save();
$args = array('thread' => $this); $args = array('thread' => $this);