logpinned.php

<?php
namespace Bitrix\Socialnetwork;
 
use Bitrix\Main;
use Bitrix\Main\Entity;
use Bitrix\Main\Localization\Loc;
use Bitrix\Main\NotImplementedException;
 
Loc::loadMessages(__FILE__);
 
class LogPinnedTable extends Entity\DataManager
{
    public static function getTableName()
    {
        return 'b_sonet_log_pinned';
    }
 
    public static function getMap()
    {
        $fieldsMap = [
            'LOG_ID' => [
                'data_type' => 'integer',
                'primary' => true
            ],
            'USER_ID' => [
                'data_type' => 'integer',
                'primary' => true
            ],
            'PINNED_DATE' => [
                'data_type' => 'datetime',
            ],
        ];
 
        return $fieldsMap;
    }
 
 
    public static function set(array $params = [])
    {
        global $USER;
 
        $logId = (isset($params['logId']) ? intval($params['logId']) : 0);
        $userId = (isset($params['userId']) ? intval($params['userId']) : (is_object($USER) && $USER instanceof \CUser ? $USER->getId() : 0));
 
        if ($logId <= 0)
        {
            throw new Main\SystemException("Empty logId.");
        }
 
        if ($userId <= 0)
        {
            throw new Main\SystemException("Empty userId.");
        }
 
        $connection = \Bitrix\Main\Application::getConnection();
        $helper = $connection->getSqlHelper();
 
        $insertFields = [
            'LOG_ID' => $logId,
            'USER_ID' => $userId,
            'PINNED_DATE' => new \Bitrix\Main\DB\SqlExpression($helper->getCurrentDateTimeFunction()),
        ];
 
        $updateFields = [
            'PINNED_DATE' => new \Bitrix\Main\DB\SqlExpression($helper->getCurrentDateTimeFunction()),
        ];
 
        $merge = $helper->prepareMerge(
            static::getTableName(),
            [ 'LOG_ID', 'USER_ID' ],
            $insertFields,
            $updateFields
        );
 
        if ($merge[0] != "")
        {
            $connection->query($merge[0]);
        }
    }
 
    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.");
    }
}