journalprocessor.php

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

<?php
 
namespace Sale\Handlers\Delivery\YandexTaxi\EventJournal;
 
use Bitrix\Sale\Delivery\Services\Manager;
use Sale\Handlers\Delivery\YandexTaxi\Internals\ClaimsTable;
use Sale\Handlers\Delivery\YandextaxiHandler;

final class JournalProcessor
{
    protected $eventReader;

    protected $eventProcessor;

    public function __construct(EventReader $eventReader, EventProcessor $eventProcessor)
    {
        $this->eventReader = $eventReader;
        $this->eventProcessor = $eventProcessor;
    }

    public static function processJournal(int $serviceId)
    {
        $service = Manager::getObjectById($serviceId);
        if (!$service)
        {
            return null;
        }
 
        $instance = $service->getYandexTaxiJournalProcessor();
        $agent = $instance->getAgentName($serviceId);
 
        $configValues = $service->getConfigValues();
        $prevCursor = isset($configValues['MAIN']['CURSOR']) && !empty($configValues['MAIN']['CURSOR'])
            ? $configValues['MAIN']['CURSOR']
            : null;
 
 
        $readResult = $instance->eventReader->read($serviceId, $prevCursor);
 
        if ($readResult->isSuccess())
        {
            $instance->eventProcessor->process($serviceId, $readResult->getEvents());
 
            return $instance->hasMore() === false ? null : $agent;
        }
 
        return $agent;
    }

    public function getAgentName(int $serviceId): string
    {
        return '\\' . static::class . sprintf('::processJournal(%s);', $serviceId);
    }

    private function hasMore()
    {
        $notFinalizedClaim = ClaimsTable::getList(
            [
                'filter' => ['=FURTHER_CHANGES_EXPECTED' => 'Y'],
                'limit' => 1,
            ]
        )->fetch();
 
        return $notFinalizedClaim ? true : false;
    }
}