usercontentview.php

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

<?php
 
namespace Bitrix\Socialnetwork;
 
use Bitrix\Main\Application;
use Bitrix\Main\ArgumentException;
use Bitrix\Main\Entity;
use Bitrix\Main\ModuleManager;
use Bitrix\Main\NotImplementedException;
use Bitrix\Main\ObjectPropertyException;
use Bitrix\Main\ORM\Data\Internal\MergeTrait;
use Bitrix\Main\SystemException;
use Bitrix\Main\DB\SqlExpression;
use Bitrix\Main\UserTable;

class UserContentViewTable extends Entity\DataManager
{
    use MergeTrait;
 
    public static function getTableName(): string
    {
        return 'b_sonet_user_content_view';
    }
 
    public static function getMap(): array
    {
        return [
            'USER_ID' => [
                'data_type' => 'integer',
                'primary' => true,
            ],
            'USER' => [
                'data_type' => 'Bitrix\Main\UserTable',
                'reference' => ['=this.USER_ID' => 'ref.ID'],
            ],
            'RATING_TYPE_ID' => [
                'data_type' => 'string',
                'primary' => true,
            ],
            'RATING_ENTITY_ID' => [
                'data_type' => 'integer',
                'primary' => true,
            ],
            'CONTENT_ID' => [
                'data_type' => 'string',
            ],
            'DATE_VIEW' => [
                'data_type' => 'datetime',
            ],
        ];
    }

    public static function set($params = []): array
    {
        static $controllerUser = [];
 
        $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([
                    'filter' => [
                        '=ID' => $userId,
                        '=EXTERNAL_AUTH_ID' => '__controller',
                    ],
                    'select' => ['ID'],
                ]);
                if ($res->fetch())
                {
                    $controllerUser[$userId] = true;
                }
                else
                {
                    $controllerUser[$userId] = false;
                }
            }
 
            if ($controllerUser[$userId])
            {
                return [
                    'success' => true,
                    'savedInDB' => false,
                ];
            }
        }
 
        if ($save)
        {
            $connection = Application::getConnection();
            $helper = $connection->getSqlHelper();
 
            $nowDate = new SqlExpression($helper->getCurrentDateTimeFunction());
 
            $insertFields = [
                "USER_ID" => $userId,
                "RATING_TYPE_ID" => $typeId,
                "RATING_ENTITY_ID" => $entityId,
                "CONTENT_ID" => $typeId . "-" . $entityId,
                "DATE_VIEW" => $nowDate,
            ];
 
            $updateFields = [
                'DATE_VIEW' => $nowDate,
            ];
 
            static::merge($insertFields, $updateFields);
            $saved = true;
        }
 
        return [
            '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.");
    }
}