usercontentview.php

<?php
namespace Bitrix\Socialnetwork;
 
use Bitrix\Main\Entity;
use Bitrix\Main\ModuleManager;
use Bitrix\Main\NotImplementedException;
use Bitrix\Main\SystemException;
use Bitrix\Main\DB\SqlExpression;
use Bitrix\Main\DB\SqlQueryException;
use Bitrix\Main\UserTable;
 
class UserContentViewTable extends Entity\DataManager
{
    public static function getTableName()
    {
        return 'b_sonet_user_content_view';
    }
 
    public static function getMap()
    {
        $fieldsMap = array(
            'USER_ID' => array(
                'data_type' => 'integer',
                'primary' => true
            ),
            'USER' => array(
                'data_type' => 'Bitrix\Main\UserTable',
                'reference' => array('=this.USER_ID' => 'ref.ID'),
            ),
            'RATING_TYPE_ID' => array(
                'data_type' => 'string',
                'primary' => true
            ),
            'RATING_ENTITY_ID' => array(
                'data_type' => 'integer',
                'primary' => true
            ),
            'CONTENT_ID' => array(
                'data_type' => 'string'
            ),
            'DATE_VIEW' => array(
                'data_type' => 'datetime'
            ),
        );
 
        return $fieldsMap;
    }
 
    public static function set($params = array())
    {
        static $controllerUser = array();
 
        $userId = (isset($params['userId']) ? intval($params['userId']) : 0);
        $typeId = (isset($params['typeId']) ? trim($params['typeId']) : false);
        $entityId = (isset($params['entityId']) ? intval($params['entityId']) : 0);
        $save = (isset($params['save']) ? !!$params['save'] : false);
 
        if (
            $userId <= 0
            || empty($typeId)
            || $entityId <= 0
        )
        {
            throw new SystemException("Invalid input data.");
        }
 
        $saved = false;
 
        if (ModuleManager::isModuleInstalled('bitrix24'))
        {
            if (!isset($controllerUser[$userId]))
            {
                $res = UserTable::getList(array(
                    'filter' => array(
                        '=ID' => $userId,
                        '=EXTERNAL_AUTH_ID' => '__controller'
                    ),
                    'select' => array('ID')
                ));
                if ($res->fetch())
                {
                    $controllerUser[$userId] = true;
                }
                else
                {
                    $controllerUser[$userId] = false;
                }
            }
 
            if ($controllerUser[$userId])
            {
                return array(
                    'success' => true,
                    'savedInDB' => false
                );
            }
        }
 
        if ($save)
        {
            $connection = \Bitrix\Main\Application::getConnection();
            $helper = $connection->getSqlHelper();
 
            $nowDate = new SqlExpression($helper->getCurrentDateTimeFunction());
 
            $insertFields = array(
                "USER_ID" => $userId,
                "RATING_TYPE_ID" => $typeId,
                "RATING_ENTITY_ID" => $entityId,
                "CONTENT_ID" => $typeId."-".$entityId,
                "DATE_VIEW" => $nowDate
            );
 
            $tableName = static::getTableName();
            list($prefix, $values) = $helper->prepareInsert($tableName, $insertFields);
 
            $connection->queryExecute(
                "INSERT INTO {$tableName} ({$prefix}) VALUES ({$values})
                        ON DUPLICATE KEY UPDATE DATE_VIEW = {$nowDate}"
            );
 
            $saved = true;
        }
 
        return array(
            'success' => true,
            'savedInDB' => $saved
        );
    }
 
    public static function add(array $data)
    {
        throw new NotImplementedException("Use set() method of the class.");
    }
 
    public static function update($primary, array $data)
    {
        throw new NotImplementedException("Use set() method of the class.");
    }
}