messageparam.php

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

<?php
namespace Bitrix\Im\Model;
 
use Bitrix\Main\Entity;
use Bitrix\Main;
 

 
class MessageParamTable extends Entity\DataManager
{
    public static function getTableName()
    {
        return 'b_im_message_param';
    }

    public static function getMap()
    {
        return array(
            'ID' => array(
                'data_type' => 'integer',
                'primary' => true,
                'autocomplete' => true,
                //'title' => Loc::getMessage('MESSAGE_PARAM_ENTITY_ID_FIELD'),
            ),
            'MESSAGE_ID' => array(
                'data_type' => 'integer',
                'required' => true,
                //'title' => Loc::getMessage('MESSAGE_PARAM_ENTITY_MESSAGE_ID_FIELD'),
            ),
            'PARAM_NAME' => array(
                'data_type' => 'string',
                'required' => true,
                'validation' => array(__CLASS__, 'validateParamName'),
                //'title' => Loc::getMessage('MESSAGE_PARAM_ENTITY_PARAM_NAME_FIELD'),
            ),
            'PARAM_VALUE' => array(
                'data_type' => 'string',
                'validation' => array(__CLASS__, 'validateParamValue'),
                //'title' => Loc::getMessage('MESSAGE_PARAM_ENTITY_PARAM_VALUE_FIELD'),
                'save_data_modification' => array('\Bitrix\Main\Text\Emoji', 'getSaveModificator'),
                'fetch_data_modification' => array('\Bitrix\Main\Text\Emoji', 'getFetchModificator'),
            ),
            'PARAM_JSON' => array(
                'data_type' => 'text',
                //'title' => Loc::getMessage('MESSAGE_PARAM_ENTITY_PARAM_JSON_FIELD'),
                'save_data_modification' => array('\Bitrix\Main\Text\Emoji', 'getSaveModificator'),
                'fetch_data_modification' => array('\Bitrix\Main\Text\Emoji', 'getFetchModificator'),
            ),
            'MESSAGE' => array(
                'data_type' => 'Bitrix\Im\Model\MessageTable',
                'reference' => array('=this.MESSAGE_ID' => 'ref.ID'),
                'join_type' => 'INNER',
            ),
        );
    }

    public static function validateParamName()
    {
        return array(
            new Entity\Validator\Length(null, 100),
        );
    }

    public static function validateParamValue()
    {
        return array(
            new Entity\Validator\Length(null, 100),
        );
    }

    public static function deleteBatch(array $filter)
    {
        $whereSql = \Bitrix\Main\Entity\Query::buildFilterSql(static::getEntity(), $filter);
 
        if ($whereSql <> '')
        {
            $tableName = static::getTableName();
            $connection = Main\Application::getConnection();
            $connection->queryExecute("DELETE FROM {$tableName} WHERE {$whereSql}");
        }
    }
}