daycontext.php

<?php
 
namespace Bitrix\Conversion;
 
use Bitrix\Main;
use Bitrix\Main\SiteTable;
use Bitrix\Main\EventManager;
use Bitrix\Main\Web\Json;
use Bitrix\Main\Type\Date;
use Bitrix\Main\ArgumentException;
use Bitrix\Main\ArgumentTypeException;
 
final class DayContext extends Internals\BaseContext
{
    public function addCounter($day, $name, $value = null)
    {
        if (func_num_args() == 2)
        {
            $value = $name;
            $name  = $day;
            $day   = new Date();
        }
 
        $instance = self::getInstance();
 
        if ($this->id === null && $this === $instance)
        {
            $pending =& self::$session['PENDING_COUNTERS'];
 
            if (empty($pending[$name]))
                $pending[$name] = 0;
 
            $pending[$name] += (float) $value;
        }
        else
        {
            parent::addCounter($day, $name, $value);
        }
    }
 
    public function addDayCounter($name, $value)
    {
        $instance = self::getInstance();
        $session =& self::$session;
 
        if ($this->id === null && $this === $instance)
        {
            $session['PENDING_DAY_COUNTERS'][$name] = (float) $value;
        }
        else
        {
            $unique =& $session['UNIQUE'];
 
            if (!in_array($name, $unique, true))
            {
                $unique[] = $name;
 
                $this->addCounter($name, $value);
                $this->setCookie();
            }
        }
    }
    
    public function subDayCounter($day, $name, $value)
    {
        $this->subCounter($day, $name, $value);
        
        // is today - clear session
        $isToday = $day instanceof Date ? $day->format('dmY') === date('dmY') : false;
        if ($isToday)
        {
            $unique =& self::$session['UNIQUE'];
            if (($i = array_search($name, $unique, true)) !== false)
            {
                unset($unique[$i]);
                $this->setCookie();
            }
        }
    }
 
    public function addCurrencyCounter($name, $value, $currency)
    {
        $this->addCounter($name, Utils::convertToBaseCurrency($value, $currency));
    }
 
    public function subCurrencyCounter($day, $name, $value, $currency)
    {
        $this->subCounter($day, $name, Utils::convertToBaseCurrency($value, $currency));
    }
 
    public function attachEntityItem($entity, $item)
    {
        if (! is_string($entity))
            throw new ArgumentTypeException('entity', 'string');
 
        if (! is_scalar($item))
            throw new ArgumentTypeException('item', 'scalar');
 
        $instance = self::getInstance();
 
        if ($this->id === null && $this === $instance)
        {
            self::$session['PENDING_ENTITY_ITEMS'][$entity.':'.$item] = array('ENTITY' => $entity, 'ITEM' => $item);
        }
        else
        {
            try
            {
                Internals\ContextEntityItemTable::add(array(
                    'CONTEXT_ID' => $this->id,
                    'ENTITY'     => $entity,
                    'ITEM'       => $item,
                ));
            }
            catch (\Bitrix\Main\DB\SqlQueryException $e)
            {
            }
        }
    }
 
    public static function getEntityItemInstance($entity, $item)
    {
        $instance = self::getInstance();
 
        $context = Internals\ContextEntityItemTable::getList(array(
            'select' => array('CONTEXT_ID'),
            'filter' => array('=ENTITY' => $entity, '=ITEM' => $item),
            'limit'  => 1,
        ))->fetch();
 
        $contextId = !empty($context['CONTEXT_ID']) ? $context['CONTEXT_ID'] : self::EMPTY_CONTEXT_ID;
        if ($contextId !== $instance->id)
        {
            $instance = new self;
            $instance->id = $contextId;
        }
 
        return $instance;
    }
 
    public static function getSiteInstance($siteId)
    {
        $instance = self::getInstance();
 
        if (preg_match('/[a-z0-9_]{2}/i', $siteId) && self::getSiteId() != $siteId && \CSite::getById($siteId)->fetch())
        {
            $instance = new self;
 
            foreach (EventManager::getInstance()->findEventHandlers('conversion', 'OnSetDayContextAttributes') as $handler)
                ExecuteModuleEventEx($handler, array($instance));
 
            $instance->setAttribute('conversion_site', $siteId);
            $instance->save();
        }
 
        return $instance;
    }
 
    private static $instance;
    private static $session;
 
    public static function getInstance()
    {
        if (! self::$instance)
        {
            $instance = new self;
            $varName  = self::getVarName();
            $session  =& $_SESSION[$varName];
            $expire   = strtotime('today 23:59');
 
            if (! (is_array($session) && is_int($session['ID']) && $session['EXPIRE'] === $expire))
            {
                $session = array('ID' => null, 'EXPIRE' => $expire, 'UNIQUE' => array());
 
                if ($cookie = $_COOKIE[$varName])
                {
                    try
                    {
                        $cookie = Json::decode($cookie);
                    }
                    catch (ArgumentException $e)
                    {
                    }
                }
 
                // check if cookie is valid
                if (   is_array($cookie)
                    && is_array($cookie['UNIQUE'])
                    && $cookie['EXPIRE'] === $expire
                    && ($id = $cookie['ID']) !== null
                    && is_int($id)
                    && ($id === self::EMPTY_CONTEXT_ID || Internals\ContextTable::getByPrimary($id)->fetch())
                )
                {
                    $session['ID'    ] = $id;
                    $session['UNIQUE'] = $cookie['UNIQUE'];
                }
            }
 
            $instance->id = $session['ID'];
            self::$session =& $session;
            self::$instance = $instance;
        }
 
        return self::$instance;
    }
 
    private function setCookie()
    {
        $session = self::$session;
 
        $cookie = new Main\Web\Cookie(
            self::getVarName(),
            Json::encode(array(
                'ID' => $session['ID'],
                'EXPIRE' => $session['EXPIRE'],
                'UNIQUE' => $session['UNIQUE'],
            )),
            strtotime('+1 year'),
            false
        );
        $cookie->setHttpOnly(false);
 
        Main\Context::getCurrent()->getResponse()->addCookie($cookie);
    }
 
    public static function saveInstance()
    {
        $instance = self::getInstance();
        $session =& self::$session;
 
        if ($instance->id === null)
        {
            foreach (EventManager::getInstance()->findEventHandlers('conversion', 'OnSetDayContextAttributes') as $handler)
                ExecuteModuleEventEx($handler, array($instance));
 
            $instance->save();
        }
 
        $session['ID'] = $instance->id;
        $instance->setCookie();
 
        if (!empty($session['PENDING_COUNTERS']) && is_array($session['PENDING_COUNTERS']))
        {
            foreach ($session['PENDING_COUNTERS'] as $name => $value)
                $instance->addCounter($name, $value);
        }
 
        if (!empty($session['PENDING_DAY_COUNTERS']) && is_array($session['PENDING_DAY_COUNTERS']))
        {
            foreach ($session['PENDING_DAY_COUNTERS'] as $name => $value)
                $instance->addDayCounter($name, $value);
        }
 
        if (!empty($session['PENDING_ENTITY_ITEMS']) && is_array($session['PENDING_ENTITY_ITEMS']))
        {
            foreach ($session['PENDING_ENTITY_ITEMS'] as $i)
                $instance->attachEntityItem($i['ENTITY'], $i['ITEM']);
        }
    }
 
    public static function getVarName()
    {
        static $name;
 
        if (! $name)
        {
            $name = 'BITRIX_CONVERSION_CONTEXT_'.self::getSiteId();
        }
 
        return $name;
    }
 
    public static function getSiteId()
    {
        static $siteId = null;
 
        if ($siteId === null)
        {
            $siteId = '';
 
            if (defined('ADMIN_SECTION') && ADMIN_SECTION === true)
            {
                if ($row = SiteTable::getList(array(
                    'select' => array('LID'),
                    'order'  => array('DEF' => 'DESC', 'SORT' => 'ASC'),
                    'limit'  => 1,
                ))->fetch())
                {
                    $siteId = $row['LID'];
                }
            }
            else
            {
                $siteId = SITE_ID;
            }
        }
 
        return $siteId;
    }
}