filterentity.php

<?php
namespace Bitrix\Landing\Internals;
 
use Bitrix\Main\Application;
use Bitrix\Main\Entity;
use Bitrix\Main\Localization\Loc;
 
Loc::loadMessages(__FILE__);
 
class FilterEntityTable extends Entity\DataManager
{
    public static function getTableName()
    {
        return 'b_landing_filter_entity';
    }
 
    public static function getMap()
    {
        return array(
            'ID' => new Entity\IntegerField('ID', array(
                'primary' => true,
                'autocomplete' => true,
                'title' => 'ID'
            )),
            'SOURCE_ID' => new Entity\StringField('SOURCE_ID', array(
                'title' => Loc::getMessage('LANDING_TABLE_FIELD_SOURCE_ID'),
                'required' => true
            )),
            'FILTER_HASH' => new Entity\StringField('FILTER_HASH', array(
                'title' => Loc::getMessage('LANDING_TABLE_FIELD_FILTER_HASH'),
                'required' => true
            )),
            'FILTER' => new Entity\StringField('FILTER', array(
                'title' => Loc::getMessage('LANDING_TABLE_FIELD_FILTER'),
                'serialized' => true,
                'required' => true
            )),
            'CREATED_BY_ID' => new Entity\IntegerField('CREATED_BY_ID', array(
                'title' => Loc::getMessage('LANDING_TABLE_FIELD_CREATED_BY_ID'),
                'required' => true
            )),
            'MODIFIED_BY_ID' => new Entity\IntegerField('MODIFIED_BY_ID', array(
                'title' => Loc::getMessage('LANDING_TABLE_FIELD_MODIFIED_BY_ID'),
                'required' => true
            )),
            'DATE_CREATE' => new Entity\DatetimeField('DATE_CREATE', array(
                'title' => Loc::getMessage('LANDING_TABLE_FIELD_DATE_CREATE'),
                'required' => true
            )),
            'DATE_MODIFY' => new Entity\DatetimeField('DATE_MODIFY', array(
                'title' => Loc::getMessage('LANDING_TABLE_FIELD_DATE_MODIFY'),
                'required' => true
            ))
        );
    }
 
    public static function applyBlock($filterId, $blockId)
    {
        $res = FilterBlockTable::getList([
            'select' => [
                'ID'
            ],
            'filter' => [
                'FILTER_ID' => $filterId,
                'BLOCK_ID' => $blockId
            ]
        ]);
        if (!$res->fetch())
        {
            FilterBlockTable::add([
                'FILTER_ID' => $filterId,
                'BLOCK_ID' => $blockId
            ]);
        }
        unset($res);
        self::actualFilters();
    }
 
    public static function removeBlock($blockId)
    {
        $res = FilterBlockTable::getList([
            'select' => [
                'ID'
            ],
            'filter' => [
                'BLOCK_ID' => $blockId
            ]
        ]);
        while ($row = $res->fetch())
        {
            FilterBlockTable::delete($row['ID']);
        }
        unset($res, $row);
        self::actualFilters();
    }
 
    protected static function actualFilters(): void
    {
        $connection = Application::getConnection();
        if ($connection->getType() === 'pgsql')
        {
            $connection->query('
                DELETE FROM b_landing_filter_entity
                WHERE ID IN (
                    SELECT F.ID
                    FROM b_landing_filter_entity F
                    LEFT JOIN b_landing_filter_block B ON B.FILTER_ID = F.ID
                    WHERE B.ID IS NULL
                );
            ');
        } else {
            $connection->query('
                DELETE F FROM 
                    b_landing_filter_entity F
                LEFT JOIN 
                    b_landing_filter_block B ON B.FILTER_ID = F.ID
                WHERE 
                    B.ID IS NULL;
            ');
        }
    }
}