Symfony Profiler

<?php
namespace NewsletterSendinblue\Subscriber;
use Monolog\Logger;
use NewsletterSendinblue\Service\BaseSyncService;
use NewsletterSendinblue\Service\Cart\CartEventProducer;
use NewsletterSendinblue\Service\ConfigService;
use NewsletterSendinblue\Service\Constant;
use NewsletterSendinblue\Service\Customer\CustomerProducer;
use NewsletterSendinblue\Service\OrderSyncService;
use NewsletterSendinblue\Traits\HelperTrait;
use Shopware\Core\Checkout\Cart\Event\CheckoutOrderPlacedEvent;
use Shopware\Core\Checkout\Cart\LineItem\LineItem;
use Shopware\Core\Checkout\Order\Aggregate\OrderTransaction\OrderTransactionDefinition;
use Shopware\Core\Checkout\Order\Aggregate\OrderTransaction\OrderTransactionEntity;
use Shopware\Core\Checkout\Order\Aggregate\OrderTransaction\OrderTransactionStates;
use Shopware\Core\Checkout\Order\OrderDefinition;
use Shopware\Core\Checkout\Order\OrderEntity;
use Shopware\Core\Checkout\Order\OrderStates;
use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
use Shopware\Core\Framework\Uuid\Uuid;
use Shopware\Core\System\SalesChannel\Context\AbstractSalesChannelContextFactory;
use Shopware\Core\System\SalesChannel\Context\SalesChannelContextService;
use Shopware\Core\System\StateMachine\Aggregation\StateMachineState\StateMachineStateEntity;
use Shopware\Core\System\StateMachine\Event\StateMachineTransitionEvent;
use Shopware\Core\Checkout\Order\Aggregate\OrderCustomer\OrderCustomerEntity;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
use Symfony\Component\HttpFoundation\RequestStack;
class CartOrderSubscriber implements EventSubscriberInterface
{
use HelperTrait;
const ORDER_OPEN = 'open';
/**
* @var AbstractSalesChannelContextFactory
*/
private $salesChannelContextFactory;
/**
* @var ConfigService
*/
private $configService;
/**
* @var CartEventProducer
*/
private $cartEventProducer;
/**
* @var CustomerProducer
*/
private $customerProducer;
/**
* @var EntityRepositoryInterface
*/
private $systemConfigRepository;
/**
* @var EntityRepositoryInterface
*/
private $orderTransactionRepository;
/**
* @var OrderSyncService
*/
private $orderSyncService;
/**
* @var Logger
*/
private $logger;
/**
* @var EntityRepositoryInterface
*/
private $brevoAbandonedCartRepository;
/**
* @var BaseSyncService
*/
private $productSyncService;
/**
* @var RequestStack
*/
private $requestStack;
/**
* @param AbstractSalesChannelContextFactory $salesChannelContextFactory
* @param ConfigService $configService
* @param CartEventProducer $cartEventProducer
* @param CustomerProducer $customerProducer
* @param EntityRepositoryInterface $systemConfigRepository
* @param EntityRepositoryInterface $orderTransactionRepository
* @param OrderSyncService $orderSyncService
* @param Logger $logger
* @param EntityRepositoryInterface $brevoAbandonedCartRepository
* @param BaseSyncService $productSyncService
* @param RequestStack $requestStack
*/
public function __construct(
AbstractSalesChannelContextFactory $salesChannelContextFactory,
ConfigService $configService,
CartEventProducer $cartEventProducer,
CustomerProducer $customerProducer,
EntityRepositoryInterface $systemConfigRepository,
EntityRepositoryInterface $orderTransactionRepository,
OrderSyncService $orderSyncService,
Logger $logger,
EntityRepositoryInterface $brevoAbandonedCartRepository,
BaseSyncService $productSyncService,
RequestStack $requestStack
)
{
$this->salesChannelContextFactory = $salesChannelContextFactory;
$this->configService = $configService;
$this->cartEventProducer = $cartEventProducer;
$this->customerProducer = $customerProducer;
$this->systemConfigRepository = $systemConfigRepository;
$this->orderTransactionRepository = $orderTransactionRepository;
$this->orderSyncService = $orderSyncService;
$this->logger = $logger;
$this->brevoAbandonedCartRepository = $brevoAbandonedCartRepository;
$this->productSyncService = $productSyncService;
$this->requestStack = $requestStack;
}
/**
* @return string[]
*/
public static function getSubscribedEvents(): array
{
return [
CheckoutOrderPlacedEvent::class => 'onOrderPlaced',
StateMachineTransitionEvent::class => 'onStateChanged',
];
}
/**
* @param StateMachineTransitionEvent $event
* @return void
*/
public function onStateChanged(StateMachineTransitionEvent $event): void
{
$orderId = $this->getOrderId($event);
if (!$orderId) {
return;
}
$order = $this->orderSyncService->getOrder($orderId, $event->getContext());
if (!$order instanceof OrderEntity) {
return;
}
$salesChannelOptions = [
SalesChannelContextService::LANGUAGE_ID => $order->getLanguageId(),
SalesChannelContextService::CURRENCY_ID => $order->getCurrencyId(),
];
$orderCustomer = $order->getOrderCustomer();
if ($orderCustomer !== null) {
$salesChannelOptions[SalesChannelContextService::CUSTOMER_ID] = $orderCustomer->getId();
}
$salesChannelContext = $this->salesChannelContextFactory->create(
Uuid::randomHex(), // unique token
$order->getSalesChannelId(),
$salesChannelOptions
);
$this->configService->setSalesChannelId($order->getSalesChannelId());
$connectionId = $this->getAutoSyncConnectionId(
ConfigService::CONFIG_IS_ORDERS_AUTO_SYNC_ENABLED,
$salesChannelContext->getContext(),
$order->getSalesChannelId()
);
if (empty($connectionId)) {
return;
}
$entity = $event->getEntityName();
$toState = $event->getToPlace()->getTechnicalName();
if ($entity === OrderDefinition::ENTITY_NAME
&& $toState === OrderStates::STATE_CANCELLED
) {
foreach ($order->getLineItems() as $lineItem) {
if ($lineItem->getType() !== LineItem::PRODUCT_LINE_ITEM_TYPE) {
continue;
}
if (!empty($lineItem->getProductId())) {
$this->productSyncService->sync(
$lineItem->getProductId(),
$connectionId,
$salesChannelContext->getContext()
);
}
}
}
if (
($entity === OrderTransactionDefinition::ENTITY_NAME
&& in_array($toState, OrderSyncService::PAYMENT_SYNC_STATUSES))
) {
if ($toState === OrderTransactionStates::STATE_CHARGEBACK) {
$toState = OrderTransactionStates::STATE_OPEN;
}
$this->orderSyncService->sync($order, $connectionId, $toState, $salesChannelContext->getContext(), true);
}
}
/**
* @param CheckoutOrderPlacedEvent $event
* @return void
*/
public function onOrderPlaced(CheckoutOrderPlacedEvent $event): void
{
$this->configService->setSalesChannelId($event->getSalesChannelId());
if ($this->configService->isAutoSyncEnabled()) {
$this->cartEventProducer->createTransactionalOrder(
$event->getOrder(), $event->getContext(), $event->getSalesChannelId()
);
}
// ORDER AUTO SYNC
$connectionId = $this->getAutoSyncConnectionId(
ConfigService::CONFIG_IS_ORDERS_AUTO_SYNC_ENABLED,
$event->getContext(),
$event->getSalesChannelId()
);
if (!empty($connectionId)) {
$order = $event->getOrder();
$toState = self::ORDER_OPEN;
if ($order->getTransactions()->first() instanceof OrderTransactionEntity
&& $order->getTransactions()->first()->getStateMachineState() instanceof StateMachineStateEntity
) {
$toState = $order->getTransactions()->first()->getStateMachineState()->getTechnicalName();
}
$this->orderSyncService->sync($order, $connectionId, $toState, $event->getContext());
}
// PRODUCT AUTO SYNC (stock)
$productAutoSyncConnectionId = $this->getAutoSyncConnectionId(
ConfigService::CONFIG_IS_PRODUCTS_AUTO_SYNC_ENABLED,
$event->getContext(),
$event->getSalesChannelId()
);
if (!empty($productAutoSyncConnectionId)) {
$order = $event->getOrder();
foreach ($order->getLineItems() as $lineItem) {
if ($lineItem->getType() !== LineItem::PRODUCT_LINE_ITEM_TYPE) {
continue;
}
if (!empty($lineItem->getProductId())) {
$this->productSyncService->sync(
$lineItem->getProductId(),
$productAutoSyncConnectionId,
$event->getContext()
);
}
}
}
if ($this->configService->isAbandonedCartTrackingEnabled()) {
if ($event->getOrder()->getOrderCustomer() instanceof OrderCustomerEntity) {
try {
$this->brevoAbandonedCartRepository->delete([
['id' => md5($event->getOrder()->getOrderCustomer()->getEmail())]
], $event->getContext());
} catch (\Throwable $e) {
}
}
}
// OPT-IN ATTR
if ($this->configService->isFullCustomerSyncEnabled()
&& $this->requestStack
&& ($request = $this->requestStack->getCurrentRequest())
) {
try {
$isCheckoutOptInChecked = $request->request->get('brevoCheckoutConfirmOptin', false);
$this->customerProducer->setAdditionalUpdateData([
Constant::OPT_IN_ENABLED => $this->configService->isDisplayOptInEnabled() ? 'true' : 'false',
Constant::OPT_IN_CHECKED => $isCheckoutOptInChecked ? 'true' : 'false',
]);
$this->customerProducer->updateContact($event->getCustomerId(), $event->getContext(), $event->getSalesChannelId());
} catch (\Throwable $e) {
$this->logger->addRecord(Logger::ERROR, $e->getMessage(), ['onOrderPlaced: opt-in attr.']);
}
}
}
/**
* @param StateMachineTransitionEvent $event
* @return string|null
*/
private function getOrderId(StateMachineTransitionEvent $event): ?string
{
$orderId = null;
switch ($event->getEntityName()) {
case OrderDefinition::ENTITY_NAME:
$orderId = $event->getEntityId();
break;
case OrderTransactionDefinition::ENTITY_NAME:
$transactions = $this->orderTransactionRepository->search(new Criteria([$event->getEntityId()]), $event->getContext());
if (count($transactions) > 0) {
$orderId = $transactions->first()->getOrderId();
}
break;
}
return $orderId;
}
}

custom/plugins/NewsletterSendinblue/src/Subscriber/CartOrderSubscriber.php line 149