logtag.php

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

<?php
namespace Bitrix\Socialnetwork;
 
use Bitrix\Main\Entity;

class LogTagTable extends Entity\DataManager
{
    const ITEM_TYPE_LOG = 'L';
    const ITEM_TYPE_COMMENT = 'LC';
 
    public static function getTableName()
    {
        return 'b_sonet_log_tag';
    }
 
    public static function getItemTypes()
    {
        return array(
            self::ITEM_TYPE_LOG,
            self::ITEM_TYPE_COMMENT
        );
    }
 
    public static function getMap()
    {
        return array(
            'LOG_ID' => array(
                'data_type' => 'integer',
            ),
            'LOG' => array(
                'data_type' => '\Bitrix\Socialnetwork\Log',
                'reference' => array('=this.LOG_ID' => 'ref.ID')
            ),
            'ITEM_TYPE' => array(
                'data_type' => 'string',
                'primary' => true,
            ),
            'ITEM_ID' => array(
                'data_type' => 'string',
                'primary' => true,
            ),
            'NAME' => array(
                'data_type' => 'string',
                'primary' => true
            )
        );
    }
 
    public static function deleteByLogId($params = array())
    {
        if (
            !is_array($params)
            || empty($params['logId'])
            || intval($params['logId']) <= 0
        )
        {
            return false;
        }
 
        \Bitrix\Main\Application::getConnection()->queryExecute('DELETE FROM '.self::getTableName().' WHERE LOG_ID = '.intval($params['logId']));
        return true;
    }
 
    public static function deleteByItem($params = array())
    {
        if (
            !is_array($params)
            || empty($params['itemId'])
            || intval($params['itemId']) <= 0
        )
        {
            return false;
        }
 
        if (
            empty($params['itemType'])
            || !in_array($params['itemType'], self::getItemTypes())
        )
        {
            $params['itemType'] = self::ITEM_TYPE_LOG;
        }
 
        \Bitrix\Main\Application::getConnection()->queryExecute('DELETE FROM '.self::getTableName().' WHERE ITEM_TYPE = \''.$params['itemType'].'\' AND ITEM_ID = '.intval($params['itemId']));
        return true;
    }
 
    public static function set($params = array())
    {
        if (
            !is_array($params)
            || empty($params['itemId'])
            || intval($params['itemId']) <= 0
            || !isset($params['tags'])
            || !is_array($params['tags'])
        )
        {
            return false;
        }
 
        if (
            empty($params['itemType'])
            || !in_array($params['itemType'], self::getItemTypes())
        )
        {
            $params['itemType'] = self::ITEM_TYPE_LOG;
        }
 
        if ($params['itemType'] == self::ITEM_TYPE_LOG)
        {
            $params['logId'] = intval($params['itemId']);
        }
        elseif (
            empty($params['logId'])
            || intval($params['logId']) <= 0
        )
        {
            $res = LogCommentTable::getList(array(
                'filter' => array(
                    'ID' => intval($params['itemId'])
                ),
                'select' => array('LOG_ID')
            ));
            if ($logEntry = $res->fetch())
            {
                $params['logId'] = intval($logEntry['LOG_ID']);
            }
        }
 
        if (
            empty($params['logId'])
            || intval($params['logId']) <= 0
        )
        {
            return false;
        }
 
        self::deleteByItem(array(
            'itemType' => $params['itemType'],
            'itemId' => intval($params['itemId'])
        ));
 
        $addedLowerCaseTagsList = [];
 
        $connection = \Bitrix\Main\Application::getConnection();
        $sqlHelper = $connection->getSqlHelper();
 
        foreach($params['tags'] as $tag)
        {
            $lowerCaseTag = mb_strtolower($tag);
            if (in_array($lowerCaseTag, $addedLowerCaseTagsList))
            {
                continue;
            }
 
            $sqlQuery = $connection->getSqlHelper()->getInsertIgnore(
                self::getTableName(),
                ' (ITEM_TYPE, ITEM_ID, LOG_ID, NAME) ',
                "VALUES('"
                . $sqlHelper->forSql($params['itemType']) . "', "
                . (int)$params['itemId'] . ", "
                . (int)$params['logId'] . ", '"
                . $sqlHelper->forSql($tag) . "')"
            );
 
            $connection->query($sqlQuery);
 
            $addedLowerCaseTagsList[] = $lowerCaseTag; // index requirement;
        }
 
        return true;
    }
}