groupthread.php

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

<?php
namespace Bitrix\Sender\Internals\Model;
 
use Bitrix\Main\Entity;
use Bitrix\Main\Localization\Loc;
use Bitrix\Main\ORM\Query\Query;
 
Loc::loadMessages(__FILE__);

class GroupThreadTable extends Entity\DataManager
{
    const STATUS_NEW         = 'N';
    const STATUS_IN_PROGRESS = 'P';
    const STATUS_DONE        = 'D';

    public static function getTableName()
    {
        return 'b_sender_group_thread';
    }

    public static function getMap()
    {
        return [
            'THREAD_ID'   => [
                'data_type'    => 'integer',
                'primary'      => true,
                'autocomplete' => true,
            ],
            'GROUP_STATE_ID'  => [
                'data_type' => 'integer',
                'primary'   => true,
                'required'  => true,
            ],
            'STEP'      => [
                'data_type' => 'integer',
                'required'  => true,
            ],
            'STATUS'      => [
                'data_type' => 'string',
                'required'  => true,
            ],
            'THREAD_TYPE' => [
                'data_type' => 'string',
                'required'  => true,
            ],
            'EXPIRE_AT' => [
                'data_type' => 'datetime',
                'required'  => true,
            ],
        ];
    }

    public static function deleteList(array $filter)
    {
        $entity = static::getEntity();
        $connection = $entity->getConnection();
 
        \CTimeZone::disable();
        $sql = sprintf(
            'DELETE FROM %s WHERE %s',
            $connection->getSqlHelper()->quote($entity->getDbTableName()),
            Query::buildFilterSql($entity, $filter)
        );
        $res = $connection->query($sql);
        \CTimeZone::enable();
 
        return $res;
    }
}