user.php

См. документацию.

<?
namespace Bitrix\Forum\Statistic;
 
use Bitrix\Forum\UserTable;
use Bitrix\Main\Localization\Loc;
use Bitrix\Main;
use Bitrix\Forum;
 
Loc::loadMessages(__FILE__);
 
class User extends Main\Update\Stepper
{
    protected static $moduleId = "forum";
    private static $limit = 10;
 
    public static function getTitle()
    {
        return 'User statistic calculation';
    }
 
    public function execute(array &$option)
    {
        $option["steps"] = 1;
        $option["count"] = 1;
        if (self::do() > 0)
        {
            return self::FINISH_EXECUTION;
        }
        return self::CONTINUE_EXECUTION;
    }
 
    private static function do()
    {
        $limit = self::$limit;
        $dbRes = Main\Application::getConnection()->query(<<<SQL
SELECT ID, ENTITY_ID 
FROM b_forum_service_statistic_queue
WHERE ENTITY_TYPE='USER'
ORDER BY ID ASC
LIMIT {$limit}
SQL
        );
 
        $last = null;
        while (($res = $dbRes->fetch()))
        {
            if ($usr = Forum\User::getById($res['ENTITY_ID']))
            {
                $usr->calculateStatistic();
            }
            $last = $res;
        }
 
        if ($last)
        {
            Main\Application::getConnection()->queryExecute(<<<SQL
DELETE FROM b_forum_service_statistic_queue WHERE ID >= {$last['ID']} AND ENTITY_TYPE='USER'
SQL
            );
        }
        return $limit;
    }
 
    public static function runForTopic(int $topicId)
    {
        if (Main\Application::getConnection()->getType() === 'pgsql')
        {
            Main\Application::getConnection()->queryExecute(<<<SQL
INSERT INTO b_forum_service_statistic_queue (ENTITY_TYPE, ENTITY_ID)
SELECT 'USER', AUTHOR_ID
FROM b_forum_message 
WHERE TOPIC_ID = {$topicId} AND AUTHOR_ID > 0 AND APPROVED='Y'
GROUP BY AUTHOR_ID
ON CONFLICT (ENTITY_TYPE, ENTITY_ID) DO NOTHING
SQL
            );
        }
        else
        {
            Main\Application::getConnection()->queryExecute(<<<SQL
INSERT IGNORE INTO b_forum_service_statistic_queue (ENTITY_TYPE, ENTITY_ID)
SELECT 'USER', AUTHOR_ID
FROM b_forum_message 
WHERE TOPIC_ID = {$topicId} AND AUTHOR_ID > 0 AND APPROVED='Y'
GROUP BY AUTHOR_ID
SQL
            );
        }
 
        self::bind(0);
    }
    
    public static function calcForTopics(array $topicIds)
    {
        $topicIds = implode(', ', array_map('intval', $topicIds));
        if ($topicIds === '')
        {
            return;
        }
        if (Main\Application::getConnection()->getType() === 'pgsql')
        {
            Main\Application::getConnection()->queryExecute(<<<SQL
INSERT INTO b_forum_service_statistic_queue (ENTITY_TYPE, ENTITY_ID)
SELECT 'USER', AUTHOR_ID
FROM b_forum_message 
WHERE TOPIC_ID IN ({$topicIds}) AND AUTHOR_ID > 0 AND APPROVED='Y'
GROUP BY AUTHOR_ID
ON CONFLICT (ENTITY_TYPE, ENTITY_ID) DO NOTHING
SQL
            );
        }
        else
        {
            Main\Application::getConnection()->queryExecute(<<<SQL
INSERT IGNORE INTO b_forum_service_statistic_queue (ENTITY_TYPE, ENTITY_ID)
SELECT 'USER', AUTHOR_ID
FROM b_forum_message 
WHERE TOPIC_ID IN ({$topicIds}) AND AUTHOR_ID > 0 AND APPROVED='Y'
GROUP BY AUTHOR_ID
SQL
            );
        }
 
        self::bind(300);
    }
}