restmanager.php

<?php
 
 
namespace Bitrix\Sale\Rest;
 
 
use Bitrix\Main\Loader;
use Bitrix\Main\ModuleManager;
use Bitrix\Rest\RestException;
use Bitrix\Sale\Internals\Entity;
use Bitrix\Sale\Rest\Synchronization\LoggerDiag;
use Bitrix\Sale\Rest\Synchronization\Manager;
use Bitrix\Sale\Rest\Synchronization\Synchronizer;
 
class RestManager
{
 
//RegisterModuleDependences("rest", "onRestGetModule", "sale", "\\Bitrix\\Sale\\Rest\\RestManager", "onRestGetModule");
//RegisterModuleDependences("rest", "OnRestServiceBuildDescription", "sale", "\\Bitrix\\Sale\\Rest\\RestManager", "onRestServiceBuildDescription");
 
//  public static function onRestGetModule()
//  {
//      return ['MODULE_ID' => 'sale'];
//  }
 
    public static function onRestServiceBuildDescription()
    {
        Loader::includeModule('sale');
 
        return [
            'sale' => [
                \CRestUtil::EVENTS=>[
                    'OnSaleOrderSaved'=>[
                        'sale',
                        'OnSaleOrderSaved',
                        [
                            RestManager::class,
                            'processEvent'
                        ],
                        [
                            'category' => \Bitrix\Rest\Sqs::CATEGORY_CRM
                        ]
                    ],
                    'OnSaleBeforeOrderDelete'=>[
                        'sale',
                        'OnSaleBeforeOrderDelete',
                        [
                            RestManager::class,
                            'processEvent'
                        ],
                        [
                            'category' => \Bitrix\Rest\Sqs::CATEGORY_CRM
                        ]
                    ],
 
                    'OnPropertyValueEntitySaved'=>[
                        'sale',
                        'OnSalePropertyValueEntitySaved',
                        [
                            RestManager::class,
                            'processEvent'
                        ],
                        [
                            'category' => \Bitrix\Rest\Sqs::CATEGORY_CRM
                        ]
                    ],
                    'OnPaymentEntitySaved'=>[
                        'sale',
                        'OnSalePaymentEntitySaved',
                        [
                            RestManager::class,
                            'processEvent'
                        ],
                        [
                            'category' => \Bitrix\Rest\Sqs::CATEGORY_CRM
                        ]
                    ],
                    'OnShipmentEntitySaved'=>[
                        'sale',
                        'OnSaleShipmentEntitySaved',
                        [
                            RestManager::class,
                            'processEvent'
                        ],
                        [
                            'category' => \Bitrix\Rest\Sqs::CATEGORY_CRM
                        ]
                    ],
                    'OnOrderEntitySaved'=>[
                        'sale',
                        'OnSaleOrderEntitySaved',
                        [
                            RestManager::class,
                            'processEvent'
                        ],
                        [
                            'category' => \Bitrix\Rest\Sqs::CATEGORY_CRM
                        ]
                    ],
                    'OnPropertyValueDeleted'=>[
                        'sale',
                        'OnSalePropertyValueDeleted',
                        [
                            RestManager::class,
                            'processEvent'
                        ],
                        [
                            'category' => \Bitrix\Rest\Sqs::CATEGORY_CRM
                        ]
                    ],
                    'OnPaymentDeleted'=>[
                        'sale',
                        'OnSalePaymentDeleted',
                        [
                            RestManager::class,
                            'processEvent'
                        ],
                        [
                            'category' => \Bitrix\Rest\Sqs::CATEGORY_CRM
                        ]
                    ],
                    'OnShipmentDeleted'=>[
                        'sale',
                        'OnSaleShipmentDeleted',
                        [
                            RestManager::class,
                            'processEvent'
                        ],
                        [
                            'category' => \Bitrix\Rest\Sqs::CATEGORY_CRM
                        ]
                    ],
                    'OnOrderDeleted'=>[
                        'sale',
                        'OnSaleOrderEntitySaved',
                        [
                            RestManager::class,
                            'processEvent'
                        ],
                        [
                            'category' => \Bitrix\Rest\Sqs::CATEGORY_CRM
                        ]
                    ],
                ]
            ]
        ];
    }
 
    public static function processEvent(array $params, array $handlerFields)
    {
        $event = $params[0];
        $eventName = $handlerFields['EVENT_NAME'];
        $eventHandler = $handlerFields['EVENT_HANDLER'];
 
        $instance = Manager::getInstance();
 
        LoggerDiag::addMessage('processEvent', var_export([
            'processEvent [process-01]'=> [
                'eventName'=>$eventName,
                'action'=>$instance->getAction()
            ]
        ], true));
 
        switch(mb_strtolower($eventName))
        {
            case 'onsaleordersaved':
 
                $entity = $event->getParameters()['ENTITY'];
 
                // ���� ���������� ����� ������, �� ������ ��������� �������
                // ���� ��������� ��������, �� ���� ������ ������� �.�. ������� onsaleordersaved ��� ����� ���������� ��� ��������
                // �������� �� deleted ����� ������ ����� ������ ������� onsalebeforeorderdeleterest
                // ���� ���������� ��������, �� ������ ��������� ������� ������ ��� ��������� ������������ ������� �����������
                if($instance->getAction() == Manager::ACTION_IMPORT || $instance->getAction() == Manager::ACTION_DELETED)
                {
                    // ������ ��� ��������
                    throw new RestException("Event stopped");
                }
                elseif($instance->isExecutedHandler($eventHandler))
                {
                    //��������� ������������ �������
                    throw new RestException("Event stopped");
                }
 
 
                if($entity->getId() <= 0)
                {
                    throw new RestException("Could not find entity ID in fields of event \"{$eventName}\"");
                }
 
                //�������� ������� �������, ��� ������ �� ����� ��������� ��� ������������� ����������|��������
                $parameters = ['FIELDS' => ['ID' => $entity->getId(), 'XML_ID' => $entity->getField('XML_ID'), 'ACTION' => Synchronizer::MODE_SAVE]];
 
                LoggerDiag::addMessage(mb_strtolower($eventName), var_export([
                    'processEvent [process-02]' => [
                        'parameters' => $parameters
                    ]
                ], true));
 
                // ��������� ��������� ���������� �����������, ���� ��������� ������ ������� ���������� �������������� ������, �������� ����������� �����
                $instance->pushHandlerExecuted($eventHandler);
 
                return $parameters;
                break;
            case 'onsalebeforeorderdelete':
 
                $entity = $event->getParameters()['ENTITY'];
 
                // ���� �������� ����� ������, �� ������ ��������� �������
                // ���� ��������� ��������, �� ���������� ��������� ��������� �� ������� �������� � ��������� ��������
                // ���� ��������� �������� � ������� �������� �������� ������ �������� (onpropertyvaluedeleted)
                if($instance->getAction() == Manager::ACTION_IMPORT || $instance->getAction() == Manager::ACTION_DELETED)
                {
                    throw new RestException("Event stopped");
                }
 
                //TODO: chack - ������������� action � deleted ��� ����� �������� ��������� ������� onsaleordersavedrest.
                $instance->setAction(Manager::ACTION_DELETED);
 
                //�������� ������� �������, ��� ������ �� ����� ��������� ��� ������������� ����������|��������
                $parameters = ['FIELDS' => ['ID' => $entity->getId(), 'XML_ID' => $entity->getField('XML_ID'), 'ACTION' => Synchronizer::MODE_DELETE]];
 
                LoggerDiag::addMessage(mb_strtolower($eventName), var_export([
                    'processEvent [process-03]' => [
                        'parameters' => $parameters
                    ]
                ], true));
 
                return $parameters;
                break;
 
            case 'onpropertyvalueentitysaved':
            case 'onpaymententitysaved':
            case 'onshipmententitysaved':
            case 'onorderentitysaved':
            case 'onpropertyvaluedeleted':
            case 'onpaymentdeleted':
            case 'onshipmentdeleted':
            case 'onorderdeleted':
 
                $entity = $event->getParameters()['ENTITY'];
                $entityId = 0;
                if($entity !== null)
                {
                    $entityId = $entity->getId();
                }
                elseif(isset($event->getParameters()['VALUES']))
                {
                    $entityId = $event->getParameters()['VALUES']['ID'];
                }
 
                $parameters = ['FIELDS' => ['ID' => $entityId]];
 
                LoggerDiag::addMessage(mb_strtolower($eventName), var_export([
                    'processEvent [process-04]' => [
                        'parameters' => $parameters
                    ]
                ], true));
 
                return $parameters;
                break;
            default:
                throw new RestException("The Event \"{$eventName}\" is not supported in current context");
        }
    }
}