blacklist.php

<?php
 
namespace Bitrix\Main\Mail\Internal;
 
use Bitrix\Main\Application;
use Bitrix\Main\Entity;
use Bitrix\Main\Type\DateTime;
 
class BlacklistTable extends Entity\DataManager
{
    const CategoryAuto = 0;
    const CategoryManual = 1;
 
    public static function getTableName()
    {
        return 'b_main_mail_blacklist';
    }
 
    public static function getMap()
    {
        return array(
            'ID' => array(
                'data_type'    => 'integer',
                'primary'      => true,
                'autocomplete' => true,
            ),
            'CATEGORY_ID' => array(
                'data_type' => 'integer',
                'required'  => true,
                'default_value'  => self::CategoryAuto,
            ),
            'CODE' => array(
                'data_type' => 'string',
                'required'  => true,
            ),
            'DATE_INSERT' => array(
                'data_type' => 'datetime',
                'required'  => new DateTime(),
            ),
        );
    }
 
    public static function hasBlacklistedEmails()
    {
        static $hasEmails = null;
        if ($hasEmails === null)
        {
            $row = static::getRow([
                'select' => ['ID'],
                'limit' => 1,
                'order' => ['ID' => 'ASC'],
                'cache' => ['ttl' => 36000]
            ]);
 
            $hasEmails = $row !== null;
        }
 
        return $hasEmails;
    }
 
    public static function insertBatch(array $list)
    {
        $connection = Application::getConnection();
        $helper = $connection->getSqlHelper();
        $tableName = static::getTableName();
        $dateNow = $helper->convertToDbDateTime(new DateTime());
 
        foreach (self::divideList($list) as $batchList)
        {
            $values = [];
            foreach ($batchList as $code)
            {
                $code = trim($code);
                if (!$code)
                {
                    continue;
                }
 
                $code = $helper->forSql($code);
                $values[] = "$dateNow, \"$code\"";
            }
 
            if (empty($values))
            {
                return;
            }
 
            $values = '(' . implode('), (', $values) . ')';
 
            $sql = $helper->getInsertIgnore($tableName, '(DATE_INSERT, CODE)', 'VALUES ' . $values);
            $connection->query($sql);
 
            static::getEntity()->cleanCache();
        }
    }
 
    protected static function divideList(array $list, $limit = 300)
    {
        $length = count($list);
        if ($length < $limit)
        {
            return array($list);
        }
 
        $result = array();
        $partsCount = ceil($length / $limit);
        for ($index = 0; $index < $partsCount; $index++)
        {
            $result[$index] = array_slice($list, $limit * $index, $limit);
        }
 
        return $result;
    }
}