2 namespace wcf\system\conversation
;
3 use wcf\system\database\util\PreparedStatementConditionBuilder
;
4 use wcf\system\user\storage\UserStorageHandler
;
5 use wcf\system\SingletonFactory
;
9 * Handles the number of conversations and unread conversations of the active user.
12 * @copyright 2001-2017 WoltLab GmbH
13 * @license GNU Lesser General Public License <http://opensource.org/licenses/lgpl-license.php>
14 * @package WoltLabSuite\Core\System\Conversation
16 class ConversationHandler
extends SingletonFactory
{
18 * number of unread conversations
21 protected $unreadConversationCount = [];
24 * number of conversations
27 protected $conversationCount = [];
30 * Returns the number of unread conversations for given user.
32 * @param integer $userID
33 * @param boolean $skipCache
36 public function getUnreadConversationCount($userID = null, $skipCache = false) {
37 if ($userID === null) $userID = WCF
::getUser()->userID
;
39 if (!isset($this->unreadConversationCount
[$userID]) ||
$skipCache) {
40 $this->unreadConversationCount
[$userID] = 0;
43 UserStorageHandler
::getInstance()->loadStorage([$userID]);
46 $data = UserStorageHandler
::getInstance()->getStorage([$userID], 'unreadConversationCount');
48 // cache does not exist or is outdated
49 if ($data[$userID] === null ||
$skipCache) {
50 $conditionBuilder = new PreparedStatementConditionBuilder();
51 $conditionBuilder->add('conversation.conversationID = conversation_to_user.conversationID');
52 $conditionBuilder->add('conversation_to_user.participantID = ?', [$userID]);
53 $conditionBuilder->add('conversation_to_user.hideConversation = 0');
54 $conditionBuilder->add('conversation_to_user.lastVisitTime < conversation.lastPostTime');
56 $sql = "SELECT COUNT(*) AS count
57 FROM wcf".WCF_N
."_conversation_to_user conversation_to_user,
58 wcf".WCF_N
."_conversation conversation
59 ".$conditionBuilder->__toString();
60 $statement = WCF
::getDB()->prepareStatement($sql);
61 $statement->execute($conditionBuilder->getParameters());
62 $row = $statement->fetchArray();
63 $this->unreadConversationCount
[$userID] = $row['count'];
65 // update storage data
66 UserStorageHandler
::getInstance()->update($userID, 'unreadConversationCount', serialize($this->unreadConversationCount
[$userID]));
69 $this->unreadConversationCount
[$userID] = unserialize($data[$userID]);
73 return $this->unreadConversationCount
[$userID];
77 * Returns the number of conversations for given user.
79 * @param integer $userID
82 public function getConversationCount($userID = null) {
83 if ($userID === null) $userID = WCF
::getUser()->userID
;
85 if (!isset($this->conversationCount
[$userID])) {
86 $this->conversationCount
[$userID] = 0;
89 UserStorageHandler
::getInstance()->loadStorage([$userID]);
92 $data = UserStorageHandler
::getInstance()->getStorage([$userID], 'conversationCount');
94 // cache does not exist or is outdated
95 if ($data[$userID] === null) {
96 $conditionBuilder1 = new PreparedStatementConditionBuilder();
97 $conditionBuilder1->add('conversation_to_user.participantID = ?', [$userID]);
98 $conditionBuilder1->add('conversation_to_user.hideConversation IN (0,1)');
99 $conditionBuilder2 = new PreparedStatementConditionBuilder();
100 $conditionBuilder2->add('conversation.userID = ?', [$userID]);
101 $conditionBuilder2->add('conversation.isDraft = 1');
103 $sql = "SELECT (SELECT COUNT(*)
104 FROM wcf".WCF_N
."_conversation_to_user conversation_to_user
105 ".$conditionBuilder1->__toString().")
108 FROM wcf".WCF_N
."_conversation conversation
109 ".$conditionBuilder2->__toString().") AS count";
110 $statement = WCF
::getDB()->prepareStatement($sql);
111 $statement->execute(array_merge($conditionBuilder1->getParameters(), $conditionBuilder2->getParameters()));
112 $row = $statement->fetchArray();
113 $this->conversationCount
[$userID] = $row['count'];
115 // update storage data
116 UserStorageHandler
::getInstance()->update($userID, 'conversationCount', serialize($this->conversationCount
[$userID]));
119 $this->conversationCount
[$userID] = unserialize($data[$userID]);
123 return $this->conversationCount
[$userID];