Symfony Profiler

<?php
declare(strict_types=1);
namespace UnzerPayment6\EventListeners\StateMachine;
use Psr\Log\LoggerInterface;
use Shopware\Core\Checkout\Document\DocumentCollection;
use Shopware\Core\Checkout\Document\DocumentEntity;
use Shopware\Core\Checkout\Order\Aggregate\OrderDelivery\OrderDeliveryDefinition;
use Shopware\Core\Checkout\Order\Aggregate\OrderDelivery\OrderDeliveryEntity;
use Shopware\Core\Checkout\Order\Aggregate\OrderTransaction\OrderTransactionEntity;
use Shopware\Core\Checkout\Order\OrderEntity;
use Shopware\Core\Framework\Context;
use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
use Shopware\Core\System\StateMachine\Event\StateMachineTransitionEvent;
use Symfony\Component\EventDispatcher\EventDispatcherInterface;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
use Throwable;
use UnzerPayment6\Components\Event\AutomaticShippingNotificationEvent;
use UnzerPayment6\Components\ShipService\ShipServiceInterface;
use UnzerPayment6\Components\Validator\AutomaticShippingValidatorInterface;
use UnzerPayment6\Installer\CustomFieldInstaller;
class TransitionEventListener implements EventSubscriberInterface
{
/** @var EntityRepository */
private $orderRepository;
/** @var EntityRepository */
private $orderDeliveryRepository;
/** @var EntityRepository */
private $transactionRepository;
/** @var LoggerInterface */
private $logger;
/** @var AutomaticShippingValidatorInterface */
private $automaticShippingValidator;
/** @var EventDispatcherInterface */
private $eventDispatcher;
/** @var ShipServiceInterface */
private $shipService;
public function __construct(
EntityRepository $orderRepository,
EntityRepository $orderDeliveryRepository,
EntityRepository $transactionRepository,
AutomaticShippingValidatorInterface $automaticShippingValidator,
LoggerInterface $logger,
EventDispatcherInterface $eventDispatcher,
ShipServiceInterface $shipService
) {
$this->orderRepository = $orderRepository;
$this->orderDeliveryRepository = $orderDeliveryRepository;
$this->transactionRepository = $transactionRepository;
$this->logger = $logger;
$this->automaticShippingValidator = $automaticShippingValidator;
$this->eventDispatcher = $eventDispatcher;
$this->shipService = $shipService;
}
/**
* {@inheritdoc}
*/
public static function getSubscribedEvents(): array
{
return [
StateMachineTransitionEvent::class => 'onStateMachineTransition',
];
}
public function onStateMachineTransition(StateMachineTransitionEvent $event): void
{
$order = $this->getOrderFromEvent($event);
if (!$order || !$this->automaticShippingValidator->shouldSendAutomaticShipping($order, $event->getToPlace())) {
return;
}
if (!$this->automaticShippingValidator->hasInvoiceDocument($order)) {
$this->logger->error(sprintf('Error during automatic shipping validation for order [%s]: No invoice could be found', $order->getOrderNumber()));
return;
}
$orderTransactions = $order->getTransactions();
if ($order->getDocuments() !== null) {
$invoiceNumber = $this->getInvoiceDocumentNumber($order->getDocuments());
}
if ($orderTransactions !== null) {
$firstTransaction = $orderTransactions->first();
}
if (empty($firstTransaction)) {
$this->logger->error(sprintf('Error while executing automatic shipping notification for order [%s]: orderTransaction could not be found', $order->getOrderNumber()));
return;
}
if (empty($invoiceNumber)) {
$this->logger->error(sprintf('Error while executing automatic shipping notification for order [%s]: Either invoice could not be found', $order->getOrderNumber()));
return;
}
try {
$this->shipService->shipTransaction($firstTransaction->getId(), $event->getContext());
$this->setCustomFields($event->getContext(), $firstTransaction);
$this->eventDispatcher->dispatch(new AutomaticShippingNotificationEvent($order, $invoiceNumber, $event->getContext()));
$this->logger->info(sprintf('The automatic shipping notification for order [%s] was executed with invoice [%s]', $order->getOrderNumber(), $invoiceNumber));
} catch (Throwable $exception) {
$this->logger->error(sprintf('Error while executing automatic shipping notification for order [%s]: %s', $order->getOrderNumber(), $exception->getMessage()), [
'trace' => $exception->getTraceAsString(),
]);
}
}
protected function setCustomFields(
Context $context,
OrderTransactionEntity $transaction
): void {
$customFields = $transaction->getCustomFields() ?? [];
$customFields = array_merge($customFields, [
CustomFieldInstaller::UNZER_PAYMENT_IS_SHIPPED => true,
]);
$update = [
'id' => $transaction->getId(),
'customFields' => $customFields,
];
$this->transactionRepository->update([$update], $context);
}
private function getOrderFromEvent(StateMachineTransitionEvent $transitionEvent): ?OrderEntity
{
if ($transitionEvent->getEntityName() === OrderDeliveryDefinition::ENTITY_NAME) {
$criteria = new Criteria([$transitionEvent->getEntityId()]);
$criteria->addAssociations([
'order',
'order.transactions',
'order.documents',
'order.documents.documentType',
]);
/** @var null|OrderDeliveryEntity $orderDeliveryEntity */
$orderDeliveryEntity = $this->orderDeliveryRepository->search($criteria, $transitionEvent->getContext())->first();
if ($orderDeliveryEntity === null) {
return null;
}
return $orderDeliveryEntity->getOrder();
}
$criteria = new Criteria([$transitionEvent->getEntityId()]);
$criteria->addAssociations([
'transactions',
'documents',
'documents.documentType',
]);
return $this->orderRepository->search($criteria, $transitionEvent->getContext())->first();
}
private function getInvoiceDocumentNumber(DocumentCollection $documents): string
{
$firstDocument = $documents->filter(static function (DocumentEntity $entity) {
if ($entity->getDocumentType() !== null && $entity->getDocumentType()->getTechnicalName() === 'invoice') {
return $entity;
}
return null;
})->first();
if (!empty($firstDocument)) {
return $firstDocument->getConfig()['documentNumber'];
}
return '';
}
}

custom/plugins/UnzerPayment6/src/EventListeners/StateMachine/TransitionEventListener.php line 77