campaign.php

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

<?php
namespace Bitrix\Sender\Entity;
 
use Bitrix\Main\Localization\Loc;
use Bitrix\Main\SiteTable;
use Bitrix\Main\Entity\ExpressionField;
 
use Bitrix\Sender\MailingTable;
 
Loc::loadMessages(__FILE__);

class Campaign extends Base
{
    private static $defaultId;
 
    private static $defaultSiteId;

    public static function getList(array $parameters = array())
    {
        if (!isset($parameters['filter']))
        {
            $parameters['filter'] = [];
        }
        if (!isset($parameters['select']))
        {
            $parameters['select'] = ['*', 'SUBSCRIBER_COUNT'];
        }
        $parameters['filter']['=IS_TRIGGER'] = 'N';
        if (in_array('SUBSCRIBER_COUNT', $parameters['select']))
        {
            $parameters['runtime'][] = new ExpressionField('SUBSCRIBER_COUNT', 'COUNT(DISTINCT %s)', 'SUBSCRIBER.CONTACT_ID');
        }
 
        return MailingTable::getList($parameters);
    }

    public static function getDefaultId($siteId = null)
    {
        if ($siteId !== null)
        {
            if (!SiteTable::getList([
                'filter' => ['ACTIVE' => 'Y', 'LID' => $siteId],
                'cache' => ['ttl' => 3600],
            ])->fetch())
            {
                $siteId = null;
            }
        }
        if ($siteId === null)
        {
            if (!self::$defaultSiteId)
            {
                $defaultSite = SiteTable::getRow([
                    'select' => ['LID', 'LANGUAGE_ID'],
                    'filter' => ['=DEF' => 'Y', '=ACTIVE' => 'Y'],
                    'cache' => ['ttl' => 86400],
                ]);
                self::$defaultSiteId = ($defaultSite ? $defaultSite['LID'] : SITE_ID);
            }
            $siteId = self::$defaultSiteId;
        }
 
        if (isset(self::$defaultId[$siteId]))
        {
            return self::$defaultId[$siteId];
        }
 
        $row = MailingTable::getRow(array(
            'select' => array('ID'),
            'filter' => array('=ACTIVE' => 'Y', '=IS_TRIGGER' => 'N', 'SITE_ID' => $siteId),
            'limit' => 1,
            'order' => array('ID' => 'DESC')
        ));
        if ($row)
        {
            self::$defaultId[$siteId] = $row['ID'];
            return self::$defaultId[$siteId];
        }
 
        $result = MailingTable::add(array(
            'NAME' => Loc::getMessage('SENDER_ENTITY_CAMPAIGN_NAME_DEFAULT'),
            'SITE_ID' => $siteId
        ));
        if ($result->isSuccess())
        {
            self::$defaultId[$siteId] = $result->getId();
        }
 
        return self::$defaultId[$siteId];
    }

    public static function getSites()
    {
        static $sites = null;
        if ($sites === null)
        {
            $sites = SiteTable::getList(['select' => ['LID', 'NAME']])->fetchAll();
            $sites = array_combine(
                array_column($sites, 'LID'),
                array_column($sites, 'NAME')
            );
        }
 
        return $sites;
    }

    protected function getDefaultData()
    {
        return [
            'NAME' => '',
            'SITE_ID' => SITE_ID,
            'ACTIVE' => 'Y',
            'IS_PUBLIC' => 'Y',
        ];
    }

    protected function saveData($id, array $data)
    {
        $this->filterDataByEntityFields(MailingTable::getEntity(), $data);
        return $this->saveByEntity(MailingTable::getEntity(), $id, $data);
    }

    public function loadData($id)
    {
        return static::getList(['filter' => ['=ID' => $id], 'limit' => 1])->fetch();
    }

    public function getSiteId()
    {
        return $this->get('SITE_ID') ?: SITE_ID;
    }

    public function getSiteName()
    {
        $sites = self::getSites();
        return $this->get('SITE_ID') ? $sites[$this->get('SITE_ID')] : null;
    }

    public function getSubscriberCount()
    {
        return (int) $this->get('SUBSCRIBER_COUNT') ?: 0;
    }

    public function activate($isActivate = true)
    {
        $this->set('ACTIVE', $isActivate ? 'Y' : 'N');
        $this->save();
 
        /*
        $result = MailingTable::update($this->getId(), ['ACTIVE' => $isActivate ? 'Y' : 'N']);
        if ($result->isSuccess())
        {
            $this->set('ACTIVE', 'Y');
        }
        else
        {
            $this->errors->add($result->getErrors());
        }
        */
 
        return $this;
    }

    public function deactivate()
    {
        $this->activate(false);
        return $this;
    }

    public function remove()
    {
        return $this->removeByEntity(MailingTable::getEntity(), $this->getId());
    }

    public static function removeById($id)
    {
        return static::create()->removeByEntity(MailingTable::getEntity(), $id);
    }
}