counter.php

<?php
 
namespace Bitrix\Socialnetwork\Component\LogList;
 
class Counter
{
    protected $component;
    protected $processorInstance;
    protected $request;
 
    protected $emptyCounter = false;
 
    public function __construct($params)
    {
        if (!empty($params['component']))
        {
            $this->component = $params['component'];
        }
        if (!empty($params['processorInstance']))
        {
            $this->processorInstance = $params['processorInstance'];
        }
        if (!empty($params['request']))
        {
            $this->request = $params['request'];
        }
        else
        {
            $this->request = Util::getRequest();
        }
    }
 
    public function getRequest()
    {
        return $this->request;
    }
 
    protected function getComponent()
    {
        return $this->component;
    }
 
    protected function getProcessorInstance()
    {
        return $this->processorInstance;
    }
 
    public function setEmptyCounter($value = false): void
    {
        $this->emptyCounter = $value;
    }
 
    public function getEmptyCounter(): bool
    {
        return $this->emptyCounter;
    }
 
    public function processCounterTypeData(&$result): void
    {
        $params = $this->getComponent()->arParams;
 
        $result['COUNTER_TYPE'] = \CUserCounter::LIVEFEED_CODE;
 
        if ($params['GROUP_ID'] > 0)
        {
            $result['COUNTER_TYPE'] = \CUserCounter::LIVEFEED_CODE . 'SG' . $params['GROUP_ID'];
        }
        elseif(
            $params['IS_CRM'] === 'Y'
            && (
                $params['SET_LOG_COUNTER'] !== 'N'
                || $params['SET_LOG_PAGE_CACHE'] !== 'N'
            )
        )
        {
            $result['COUNTER_TYPE'] = (
                is_set($params['CUSTOM_DATA'])
                && is_set($params['CUSTOM_DATA']['CRM_PRESET_TOP_ID'])
                && $params['CUSTOM_DATA']['CRM_PRESET_TOP_ID'] === 'all'
                    ? 'CRM_**_ALL'
                    : 'CRM_**'
            );
        }
        elseif(($params['EXACT_EVENT_ID'] ?? '') === 'blog_post')
        {
            $result['COUNTER_TYPE'] = 'blog_post';
        }
    }
 
    public function clearLogCounter(&$result): void
    {
        $params = $this->getComponent()->arParams;
 
        if (
            $params['SET_LOG_COUNTER'] !== 'Y'
            || (isset($result['EXPERT_MODE_SET']) && $result['EXPERT_MODE_SET'])
            || !Util::checkUserAuthorized()
        )
        {
            return;
        }
 
        if (
            (int)$result['LOG_COUNTER'] > 0
            || $this->getEmptyCounter()
        )
        {
            \CUserCounter::clear(
                $result['currentUserId'],
                $result['COUNTER_TYPE'],
                [ SITE_ID, '**' ],
                true, // sendPull
                true // multiple
            );
 
            if ((int)$result['LOG_COUNTER_IMPORTANT'] > 0)
            {
                \CUserCounter::clear(
                    $result['currentUserId'],
                    'BLOG_POST_IMPORTANT',
                    SITE_ID
                );
            }
 
            $res = getModuleEvents('socialnetwork', 'OnSonetLogCounterClear');
            while ($eventFields = $res->fetch())
            {
                executeModuleEventEx($eventFields, [ $result['COUNTER_TYPE'], (int)$result['LAST_LOG_TS'] ]);
            }
        }
        elseif (in_array($result['COUNTER_TYPE'], [ '**', 'CRM_**' ], true)) // set last date only
        {
            $pool = \Bitrix\Main\Application::getInstance()->getConnectionPool();
            $pool->useMasterOnly(true);
 
            \CUserCounter::clear(
                $result['currentUserId'],
                $result['COUNTER_TYPE'],
                [ SITE_ID, '**' ],
                false, // sendPull
                false, // multiple
                false // cleanCache
            );
 
            $pool->useMasterOnly(false);
        }
    }
 
    public function setLogCounter(&$result): void
    {
        $params = $this->getComponent()->arParams;
 
        $result['LOG_COUNTER'] = 0;
        $result['LOG_COUNTER_IMPORTANT'] = 0;
 
        if (
            $params['SET_LOG_COUNTER'] !== 'Y'
            || !Util::checkUserAuthorized()
        )
        {
            return;
        }
 
        $counters = \CUserCounter::getValues($result['currentUserId'], SITE_ID);
 
        if (isset($counters['BLOG_POST_IMPORTANT']))
        {
            $result['LOG_COUNTER_IMPORTANT'] = (int)$counters['BLOG_POST_IMPORTANT'];
        }
 
        if (isset($counters[$result['COUNTER_TYPE']]))
        {
            $result['LOG_COUNTER'] = (int)$counters[$result['COUNTER_TYPE']];
        }
        else
        {
            $this->setEmptyCounter(true);
            $result['LOG_COUNTER'] = 0;
        }
    }
}