lastsearch.php

<?php
namespace Bitrix\Im;
 
use Bitrix\Main\Application;
use Bitrix\Main\DB\Exception;
 
class LastSearch
{
    const LIMIT = 30;
    const CACHE_TTL = 31536000;
    const CACHE_PATH = '/bx/im/search/last/';
 
    public static function add($dialogId, $userId = null)
    {
        $userId = \Bitrix\Im\Common::getUserId($userId);
        if (!$userId)
        {
            return false;
        }
 
        if (!$dialogId || $dialogId == 'chat0')
        {
            return false;
        }
 
        if (!\Bitrix\Im\Common::isDialogId($dialogId))
        {
            return false;
        }
 
        if (\Bitrix\Im\Common::isChatId($dialogId))
        {
            $chatId = \Bitrix\Im\Dialog::getChatId($dialogId);
            $relations = Chat::getRelation($chatId, ['WITHOUT_COUNTERS' => 'Y']);
            if (!$relations[$userId])
            {
                return false;
            }
 
            $relationId = $relations[$userId]['ID'];
        }
        else
        {
            $relations = \Bitrix\Im\Dialog::getRelation($userId, $dialogId, ['WITHOUT_COUNTERS' => 'Y']);
            if (!$relations[$userId])
            {
                return false;
            }
 
            $chatId = $relations[$userId]['CHAT_ID'];
            $relationId = $relations[$userId]['ID'];
        }
 
        $orm = \Bitrix\Im\Model\LastSearchTable::getList(Array(
            'filter' => Array('USER_ID' => $userId, 'DIALOG_ID' => $dialogId),
            'order' => Array('ID' => 'DESC')
        ));
        if ($orm->fetch())
        {
            return true;
        }
 
        $result = \Bitrix\Im\Model\LastSearchTable::add(Array(
            'USER_ID' => $userId,
            'DIALOG_ID' => $dialogId,
            'ITEM_CID' => $chatId,
            'ITEM_RID' => $relationId,
        ));
 
        if (!$result->isSuccess())
            return false;
 
        $count = 0;
        $delete = Array();
 
        $orm = \Bitrix\Im\Model\LastSearchTable::getList(Array(
            'filter' => Array('USER_ID' => $userId),
            'order' => Array('ID' => 'DESC')
        ));
        while ($row = $orm->fetch())
        {
            $count++;
 
            if ($count > self::LIMIT)
            {
                $delete[] = $row['ID'];
            }
        }
 
        foreach ($delete as $id)
        {
            \Bitrix\Im\Model\LastSearchTable::delete($id);
        }
 
        self::clearCache($userId);
 
        return $result->getId();
    }
 
    public static function delete($dialogId, $userId = null)
    {
        $userId = \Bitrix\Im\Common::getUserId($userId);
        if (!$userId)
        {
            return false;
        }
 
        if (!$dialogId || $dialogId == 'chat0')
        {
            return false;
        }
 
        if (!\Bitrix\Im\Common::isDialogId($dialogId))
        {
            return false;
        }
 
        $orm = \Bitrix\Im\Model\LastSearchTable::getList(Array(
            'filter' => Array(
                '=USER_ID' => $userId,
                '=DIALOG_ID' => $dialogId
            )
        ));
        $row = $orm->fetch();
        if (!$row)
        {
            return false;
        }
 
        \Bitrix\Im\Model\LastSearchTable::delete($row['ID']);
 
        self::clearCache($userId);
 
        return true;
    }
 
    public static function get($userId = null, $options = array())
    {
        $userId = \Bitrix\Im\Common::getUserId($userId);
        if (!$userId)
        {
            return false;
        }
 
        $result = array();
 
        $cacheId = 'list_v2_'.$userId.'_'.Color::isEnabled();
        $cachePath = self::CACHE_PATH.\Bitrix\Im\Common::getCacheUserPostfix($userId);
 
        $cache = \Bitrix\Main\Application::getInstance()->getCache();
        $taggedCache = \Bitrix\Main\Application::getInstance()->getTaggedCache();
        if($cache->initCache(self::CACHE_TTL, $cacheId, $cachePath))
        {
            $result = $cache->getVars();
        }
        else
        {
            $generalChatId = \CIMChat::GetGeneralChatId();
 
            $select = Array(
                '*',
                'RELATION_USER_ID' => 'RELATION.USER_ID',
                'RELATION_NOTIFY_BLOCK' => 'RELATION.NOTIFY_BLOCK',
                'CHAT_TITLE' => 'CHAT.TITLE',
                'CHAT_TYPE' => 'CHAT.TYPE',
                'CHAT_AVATAR' => 'CHAT.AVATAR',
                'CHAT_LAST_MESSAGE_STATUS' => 'CHAT.LAST_MESSAGE_STATUS',
 
                'CHAT_AUTHOR_ID' => 'CHAT.AUTHOR_ID',
                'CHAT_EXTRANET' => 'CHAT.EXTRANET',
                'CHAT_COLOR' => 'CHAT.COLOR',
                'CHAT_ENTITY_TYPE' => 'CHAT.ENTITY_TYPE',
                'CHAT_ENTITY_ID' => 'CHAT.ENTITY_ID',
                'CHAT_ENTITY_DATA_1' => 'CHAT.ENTITY_DATA_1',
                'CHAT_ENTITY_DATA_2' => 'CHAT.ENTITY_DATA_2',
                'CHAT_ENTITY_DATA_3' => 'CHAT.ENTITY_DATA_3',
                'CHAT_DATE_CREATE' => 'CHAT.DATE_CREATE',
            );
 
            $orm = \Bitrix\Im\Model\LastSearchTable::getList(Array(
                'select' => $select,
                'filter' => Array('=USER_ID' => $userId),
                'order' => Array('ID' => 'DESC')
            ));
            while ($row = $orm->fetch())
            {
                $isUser = mb_strpos($row['DIALOG_ID'], 'chat') !== 0;
                $id = $row['DIALOG_ID'];
 
                $item = Array(
                    'ID' => $isUser? (int)$id: $id,
                    'TYPE' => $isUser? 'user': 'chat',
                    'AVATAR' => Array(),
                    'TITLE' => Array(),
                );
 
                if ($isUser)
                {
                    $item['USER'] = Array(
                        'ID' => (int)$row['DIALOG_ID'],
                    );
                }
                else
                {
                    $avatar = \CIMChat::GetAvatarImage($row['CHAT_AVATAR'], 200, false);
                    $color = $row['CHAT_COLOR'] <> ''? Color::getColor($row['CHAT_COLOR']): Color::getColorByNumber($row['ITEM_ID']);
                    $chatType = \Bitrix\Im\Chat::getType($row);
 
                    if ($generalChatId == $row['ITEM_ID'])
                    {
                        $row["CHAT_ENTITY_TYPE"] = 'GENERAL';
                    }
 
                    $muteList = Array();
                    if ($row['RELATION_NOTIFY_BLOCK'] == 'Y')
                    {
                        $muteList = Array($row['RELATION_USER_ID'] => true);
                    }
 
                    $item['AVATAR'] = Array(
                        'URL' => $avatar,
                        'COLOR' => $color
                    );
                    $item['TITLE'] = $row['CHAT_TITLE'];
                    $item['CHAT'] = Array(
                        'ID' => (int)$row['ITEM_CID'],
                        'NAME' => $row['CHAT_TITLE'],
                        'OWNER' => (int)$row['CHAT_AUTHOR_ID'],
                        'EXTRANET' => $row['CHAT_EXTRANET'] == 'Y',
                        'AVATAR' => $avatar,
                        'COLOR' => $color,
                        'TYPE' => $chatType,
                        'ENTITY_TYPE' => (string)$row['CHAT_ENTITY_TYPE'],
                        'ENTITY_ID' => (string)$row['CHAT_ENTITY_ID'],
                        'ENTITY_DATA_1' => (string)$row['CHAT_ENTITY_DATA_1'],
                        'ENTITY_DATA_2' => (string)$row['CHAT_ENTITY_DATA_2'],
                        'ENTITY_DATA_3' => (string)$row['CHAT_ENTITY_DATA_3'],
                        'MUTE_LIST' => $muteList,
                        'DATE_CREATE' => $row['CHAT_DATE_CREATE'],
                        'MESSAGE_TYPE' => $row["CHAT_TYPE"],
                    );
                }
 
                $result[$id] = $item;
            }
 
            $taggedCache->startTagCache($cachePath);
            $taggedCache->registerTag("USER_NAME");
            $taggedCache->endTagCache();
 
            $cache->startDataCache();
            $cache->endDataCache($result);
        }
 
        foreach ($result as $id => $item)
        {
            if ($options['SKIP_OPENLINES'] == 'Y')
            {
                if ($item['TYPE'] == 'chat' && $item['CHAT']['TYPE'] == 'lines')
                {
                    unset($result[$id]);
                    continue;
                }
            }
            if ($options['SKIP_CHAT'] == 'Y')
            {
                if ($item['TYPE'] == 'chat' && $item['CHAT']['TYPE'] != 'lines')
                {
                    unset($result[$id]);
                    continue;
                }
            }
            if ($options['SKIP_DIALOG'] == 'Y')
            {
                if ($item['TYPE'] == 'user')
                {
                    unset($result[$id]);
                    continue;
                }
            }
 
            if ($item['USER']['ID'] > 0)
            {
                $user = User::getInstance($item['USER']['ID'])->getArray();
                if (!$user)
                {
                    $user = Array('ID' => 0);
                }
                else if ($item['TYPE'] == 'user')
                {
                    $item['AVATAR'] = Array(
                        'URL' => $user['AVATAR'],
                        'COLOR' => $user['COLOR']
                    );
                    $item['TITLE'] = $user['NAME'];
                }
 
                $item['USER'] = $user;
 
                $result[$id] = $item;
            }
        }
 
        $result = array_values($result);
 
        if ($options['JSON'])
        {
            foreach ($result as $index => $item)
            {
                foreach ($item as $key => $value)
                {
                    if ($value instanceof \Bitrix\Main\Type\DateTime)
                    {
                        $item[$key] = date('c', $value->getTimestamp());
                    }
                    else if (is_array($value))
                    {
                        foreach ($value as $subKey => $subValue)
                        {
                            if ($subValue instanceof \Bitrix\Main\Type\DateTime)
                            {
                                $value[$subKey] = date('c', $subValue->getTimestamp());
                            }
                            else if (is_string($subValue) && $subValue && in_array($subKey, Array('URL', 'AVATAR')) && mb_strpos($subValue, 'http') !== 0)
                            {
                                $value[$subKey] = \Bitrix\Im\Common::getPublicDomain().$subValue;
                            }
                            else if (is_array($subValue))
                            {
                                $value[$subKey] = array_change_key_case($subValue, CASE_LOWER);
                            }
                        }
                        $item[$key] = array_change_key_case($value, CASE_LOWER);
                    }
                }
                $result[$index] = array_change_key_case($item, CASE_LOWER);
            }
        }
 
        return $result;
    }
 
 
    public static function clearCache($userId = null)
    {
        $cache = Application::getInstance()->getCache();
        $cache->cleanDir(self::CACHE_PATH.($userId? Common::getCacheUserPostfix($userId): ''));
    }
}