entitycompatibility.php

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

<?php
 
 
namespace Bitrix\Sale\Compatible\Internals;
 
use Bitrix\Main\Application;
use Bitrix\Main\ArgumentNullException;
use Bitrix\Main\ArgumentOutOfRangeException;
use Bitrix\Main\Entity;
use Bitrix\Main\Localization\Loc;
use Bitrix\Main\NotImplementedException;
use Bitrix\Main\ObjectNotFoundException;
use Bitrix\Main\SystemException;
use Bitrix\Main\Type\Date;
use Bitrix\Main\Type\DateTime;
use Bitrix\Sale\Compatible\Internals;
use Bitrix\Sale\Compatible;
use Bitrix\Sale;
 
abstract class EntityCompatibility
{
    protected $query = null;

    protected $filter = array();

    protected $select = array();

    protected $group = null;

    protected $sort = array();

    protected $nav = null;

    protected $queryAliasList = null;

    protected $fields = null;

    protected $rawFields = array();
 
    const ENTITY_ORDER = 'ORDER';
    const ENTITY_PAYMENT = 'PAYMENT';
 
    const ENTITY_ORDER_TABLE = 'b_sale_order';
    const ENTITY_PAYMENT_TABLE = 'b_sale_order_payment';
    protected function __construct(array $fields = array())
    {
        throw new SystemException('not set construct');
    }
 
    protected static function getRegistryType()
    {
        throw new NotImplementedException();
    }
 
    protected static function getEntity()
    {
        throw new NotImplementedException();
    }

    public static function getAliasFields()
    {
        return array();
    }

    protected static function getSelectFields()
    {
        return array();
    }

    public static function getById($id)
    {
        $compatibility = new static();
        return static::setGetListParameters($compatibility);
    }

    public static function getList($sort = array(), $filter = array(), $group = null, $nav = array(), $select = array(), $callback = false)
    {
        $compatibility = new static();
        return static::setGetListParameters($compatibility, $sort, $filter, $group, $nav, $select, $callback);
    }

    protected static function setGetListParameters(EntityCompatibility $compatibility, $sort = array(), $filter = array(), $group = null, $nav = array(), $select = array(), $callback = false)
    {
        if (empty($select))
        {
            $select = array('*');
        }
 
 
        if (!empty($filter))
        {
            $compatibility->setFilter($filter);
        }
 
        if (!empty($select))
        {
            $compatibility->setSelect($select);
        }
 
        if ($group !== null)
        {
            $compatibility->setGroup($group);
        }
 
        if (!empty($sort))
        {
            $compatibility->setSort($sort);
        }
 
        if (!empty($nav))
        {
            $compatibility->setNav($nav);
        }
 
        if (!empty($callback))
        {
            $compatibility->setCallback($callback);
        }
 
        return $compatibility->execute();
    }

    public static function add(array $fields)
    {
        throw new SystemException('not set add');
    }

    public function setFilter(array $filter = array())
    {
 
        $aliasFields = static::getAliasFields();
        foreach($filter as $fieldName => $fieldValue)
        {
            $fieldName = mb_strtoupper($fieldName);
            $filterMatch = $this->query->explodeFilterKey($fieldName);
            $fieldClearName = $filterMatch['alias'];
 
            if (!in_array($fieldClearName, $this->getQueryAliasList()))
            {
                if (isset($aliasFields[$fieldClearName]))
                {
                    $this->addQueryAlias($fieldClearName, $aliasFields[$fieldClearName]);
                }
            }
 
            if ($propKey = $this->parseField($fieldClearName))
            {
                $this->addFilter($filterMatch['modifier'].$filterMatch['operator'].$propKey, $fieldValue);
            }
            else
            {
                if (!$this->checkWhiteListFields($fieldClearName))
                {
                    continue;
                }
 
                $aliasFieldsValue = $aliasFields[$fieldClearName] ?? null;
                if (!is_array($aliasFieldsValue))
                {
                    $this->addFilter($fieldName, $fieldValue);
                }
                else
                {
                    $this->addFilterForAlias($aliasFieldsValue, $fieldName, $fieldValue);
                    $this->addSelectForAlias($aliasFieldsValue);
                }
            }
        }
    }

    public function setSelect(array $select = array())
    {
        $aliasFields = static::getAliasFields();
        if (empty($select))
        {
            $select = static::getSelectFields();
        }
 
        foreach($select as $key => $fieldName)
        {
            if ($fieldName == "*")
            {
                unset($select[$key]);
 
                $select = array_merge($select, static::getSelectFields());
 
                break;
            }
        }
 
        foreach($select as $fieldName)
        {
            $fieldName = mb_strtoupper($fieldName);
            if (!in_array($fieldName, $this->getQueryAliasList()))
            {
                if (isset($aliasFields[$fieldName]))
                {
                    $this->addQueryAlias($fieldName, $aliasFields[$fieldName]);
                }
            }
 
            if ($propKey = $this->parseField($fieldName))
            {
                $this->addSelect($propKey);
            }
            else
            {
                $aliasFieldsValue = $aliasFields[$fieldName] ?? null;
                if (!is_array($aliasFieldsValue))
                {
                    $this->addSelect($fieldName);
                }
                else
                {
                    $this->addSelectForAlias($aliasFieldsValue);
                }
            }
        }
    }

    public function parseField($key)
    {
        return null;
    }

    public function setGroup($group = null)
    {
        if (is_array($group))
        {
            if (empty($group))
            {
                $this->select = array();
                $this->group = $group;
            }
            else
            {
                foreach($group as $fieldName => $fieldValue)
                {
                    if ($propKey = $this->parseField($fieldName))
                    {
                        $this->group[$propKey] = $fieldValue;
                    }
                    else
                    {
                        $this->group[$fieldName] = $fieldValue;
                    }
                }
            }
        }
    }

    public function setSort(array $sort = array())
    {
        foreach($sort as $fieldName => $fieldValue)
        {
            $fieldName = mb_strtoupper($fieldName);
            if ($propKey = $this->parseField($fieldName))
            {
                $this->sort[$propKey] = $fieldValue;
            }
            else
            {
                $this->sort[$fieldName] = $fieldValue;
            }
        }
    }

    public function setNav(array $nav = array())
    {
        $this->nav = $nav;
    }

    public function setCallback(array $callback)
    {
        if (($sql = call_user_func_array($callback, array())) && strval(trim($sql)) != '')
        {
            $this->query->registerRuntimeField(
                '',
                new Entity\ExpressionField(
                    '__CALLBACK',
                    '(CASE WHEN ('.$sql.') THEN 1 ELSE 0 END)'
                )
            );
            $this->query->addFilter('=__CALLBACK', 1);
        }
    }

    protected function addFilter($name, $value)
    {
        if (isset($this->filter[$name]))
            return false;
 
        $this->filter[$name] = $value;
 
        return true;
    }

    protected function addFilterForAlias(array $aliasList, $name, $value)
    {
        $match = $this->query->explodeFilterKey($name);
        $rule = ($match['modifier']? $match['modifier']:"").($match['operator']? $match['operator']:"");
 
        $logic = array();
        foreach ($aliasList as $fieldName => $fieldValue)
        {
            $filterName = $rule.$fieldName;
            $logic[] = array($filterName => $value);
        }
 
        if (!empty($logic))
        {
            $logic['LOGIC'] = 'OR';
            $this->query->addFilter(null, $logic);
        }
 
        return true;
    }

    protected function addSelect($name)
    {
        if (in_array($name, $this->select))
            return false;
 
        $this->select[] = $name;
 
        return true;
    }

    protected function addSelectForAlias(array $aliasList)
    {
        foreach ($aliasList as $fieldName => $fieldValue)
        {
            $this->addSelect($fieldName);
        }
 
        return true;
    }

    protected function addQueryAlias($name, $value = null)
    {
        $list = array();
 
        if ($name == $value)
        {
            $value = null;
        }
 
        if (!empty($value) && is_array($value))
        {
            $list = $value;
        }
        else
        {
            $list[$name] = $value;
        }
 
        foreach ($list as $fieldName => $fieldValue)
        {
            if (in_array($fieldName, $this->queryAliasList))
            {
                return false;
            }
 
            $this->queryAliasList[] = $fieldName;
            $this->query->addAlias($fieldName, $fieldValue);
 
        }
 
        return true;
    }

    protected function getQueryAliasList()
    {
        if ($this->queryAliasList === null)
        {
            $this->queryAliasList = array_keys($this->query->getAliases());
        }
 
        return $this->queryAliasList;
    }

    public function execute()
    {
        $result = new Compatible\CDBResult();
        $this->query->prepare($this->sort, $this->filter, $this->group, $this->select);
        if ($this->query->counted())
        {
            return $this->query->exec()->getSelectedRowsCount();
        }
 
        return $this->query->compatibleExec($result, $this->nav);
    }
 

    public function getField($name)
    {
        return $this->fields->get($name);
    }

    public function setField($name, $value)
    {
        $this->fields->set($name, $value);
    }

    public function getFieldValues()
    {
        return $this->fields->getValues();
    }

    public function setFields(array $values)
    {
        $this->fields->resetValues($values);
    }
 

    protected static function clearFields(array $fields, array $availableFields = array())
    {
        if (empty($availableFields))
            $availableFields = static::getAvailableFields();
 
        foreach ($fields as $fieldName => $fieldValue)
        {
            if (!in_array($fieldName, $availableFields))
            {
                unset($fields[$fieldName]);
            }
        }
 
        return $fields;
    }
 

    public static function convertDateFields(array $fields, array $dateFields = array())
    {
        $resultList = array();
        foreach ($fields as $k => $value)
        {
            $resultList[$k] = static::convertDateField($k, $value, $dateFields);
        }
        return $resultList;
    }

    protected static function convertDateField($name, $value, array $dateFields = array())
    {
        $key = $name;
        if (mb_substr($key, 0, 1) == '=')
        {
            $key = mb_substr($key, 1);
        }
 
        if (!array_key_exists($key, $dateFields))
        {
            return $value;
        }
 
        $nowDate = Application::getConnection()->getSqlHelper()->getCurrentDateTimeFunction();
 
        if (!($value instanceof DateTime)
            && !($value instanceof Date))
        {
            if ($value === null)
                return null;
 
            if (strval($value) == '')
                return false;
 
 
            $setValue = null;
 
            if (mb_strtolower($value) != mb_strtolower($nowDate))
            {
                $setValue = $value;
            }
 
            if (mb_strtoupper($dateFields[$key]) == "DATE")
            {
                $value = new Date($setValue);
            }
            elseif (mb_strtoupper($dateFields[$key]) == "DATETIME")
            {
                $value = new DateTime($setValue);
            }
        }
 
        return $value;
    }

    public static function convertDateFieldsToOldFormat(array $fields)
    {
        $resultList = array();
        foreach ($fields as $k => $value)
        {
            $valueString = static::convertDateFieldToOldFormat($value);
            $resultList[$k] = $valueString;
        }
 
        return $resultList;
    }

    protected static function convertDateFieldToOldFormat($value)
    {
        $setValue = $value;
 
        if (($value instanceof DateTime)
            || ($value instanceof Date))
        {
            $setValue = $value->toString();
        }
 
        return $setValue;
    }

    public static function convertDateFieldToFormat($value, $format)
    {
        $setValue = $value;
 
        if (($value instanceof DateTime)
            || ($value instanceof Date))
        {
            $phpFormat = $value->convertFormatToPhp($format);
            $setValue = $value->format($phpFormat);
            $setValue = str_replace(" 00:00:00", "", $setValue);
        }
 
        return $setValue;
    }
 

    protected static function replaceFields(array $fields, array $replace = array())
    {
        if (empty($replace))
            return $fields;
 
        $replacedFields = $fields;
 
        foreach ($fields as $name => $value)
        {
            if (array_key_exists($name, $replace))
            {
                $replacedFields[$replace[$name]] = $replacedFields[$name];
                unset($replacedFields[$name]);
            }
        }
 
        return $replacedFields;
    }
 

    public static function getAvailableFields()
    {
        return array();
    }

    protected static function checkEntityName($entityName)
    {
        return ($entityName == static::ENTITY_ORDER
            || $entityName == static::ENTITY_PAYMENT
        );
    }

    protected function parseRawFields($entityName, array $fields, array $availableFields = array())
    {
        if (!static::checkEntityName($entityName))
        {
            throw new ArgumentOutOfRangeException('entityName');
        }
 
        if (empty($availableFields))
            $availableFields = static::getAvailableFields();
 
        foreach ($fields as $name => $value)
        {
            $firstLetter = mb_substr($name, 0, 1);
            if ($firstLetter == "~" || $firstLetter == "=")
            {
                $fieldName = ltrim($name, '=');
                $fieldName = ltrim($fieldName, '~');
 
                if (!in_array($fieldName, $availableFields))
                    continue;
 
                $this->rawFields[$entityName][$firstLetter.$fieldName] = $value;
                unset($fields[$name]);
            }
        }
 
        return $fields;
    }
 

    public function saveRawFields($entity, $entityName)
    {
        global $DB;
 
        if (!static::checkEntityName($entityName))
        {
            throw new ArgumentOutOfRangeException('entityName');
        }
 
        if (empty($this->rawFields[$entityName]) || !is_array($this->rawFields[$entityName]))
            return new Sale\Result();
 
        $tableName = null;
        if ($entityName == static::ENTITY_ORDER)
        {
            if (!$entity instanceof Sale\OrderBase)
            {
                throw new ObjectNotFoundException('Entity "Order" not found');
            }
 
            $tableName = static::ENTITY_ORDER_TABLE;
        }
        elseif ($entityName == static::ENTITY_PAYMENT)
        {
            if (!$entity instanceof Sale\Payment)
            {
                throw new ObjectNotFoundException('Entity "Payment" not found');
            }
            $tableName = static::ENTITY_PAYMENT_TABLE;
        }
 
        if ($entity->getId() <= 0)
        {
            throw new ArgumentNullException('id');
        }
 
        if (strval(trim($tableName)) == '')
        {
            throw new ArgumentNullException('tableName');
        }
 
        $result = new Sale\Result();
 
        $queryValue = $DB->PrepareUpdate($tableName, $this->rawFields[$entityName]);
 
        foreach ($this->rawFields[$entityName] as $key => $value)
        {
            if (mb_substr($key, 0, 1) != "=")
                continue;
 
            if (strval($queryValue) != '')
                $queryValue .= ", ";
 
            $queryValue .= mb_substr($key, 1)."=".$value." ";
        }
 
        $sql =
            "UPDATE ".$tableName." SET ".
            "   ".$queryValue." WHERE ID = ".$entity->getId()." ";
 
        if (!($DB->Query($sql, true)))
        {
            $result->addError(new Sale\ResultError(Loc::getMessage('SALE_COMPATIBLE_'.$entityName.'_RAW_FIELD_UPDATE_ERROR'), 'SALE_'.$entityName.'_COMPATIBLE_RAW_FIELD_UPDATE_ERROR'));
            return $result;
        }
 
        return $result;
    }

    public static function backRawField($entityName, array $fields, $separator = '=')
    {
        if (!static::checkEntityName($entityName))
        {
            throw new ArgumentOutOfRangeException('entityName');
        }
 
        if (empty($fields))
            return array();
 
        foreach($fields as $name => $value)
        {
            $fields[$separator.$name] = $value;
            unset($fields[$name]);
        }
 
        return $fields;
    }
 
 
    protected function getWhiteListFields()
    {
        return array_merge($this->getAvailableFields(), $this->getSelectFields());
    }

    protected function checkWhiteListFields($fieldName)
    {
        $fields = $this->getWhiteListFields();
        if (!empty($fields))
        {
            if (in_array($fieldName, $fields))
                return true;
 
            if (mb_strpos($fieldName, 'UF_') === 0)
                return true;
        }
 
        return false;
    }
 
 
}