custom/plugins/ErpOrdersWriter/src/Subscriber/OrderSubscriber.php line 71

Open in your IDE?
  1. <?php
  3. namespace CodeCouncil\ErpOrdersWriter\Subscriber;
  5. use CodeCouncil\ErpOrdersWriter\ERP\ERPConnectorService;
  6. use Psr\Log\LoggerInterface;
  7. use Shopware\Core\Checkout\Cart\Event\CheckoutOrderPlacedCriteriaEvent;
  8. use Shopware\Core\Checkout\Cart\Event\CheckoutOrderPlacedEvent;
  9. use Shopware\Core\Checkout\Order\Aggregate\OrderTransaction\OrderTransactionEntity;
  10. use Shopware\Core\Checkout\Order\Aggregate\OrderTransaction\OrderTransactionStates;
  11. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  13. use Shopware\Core\System\StateMachine\Event\StateMachineStateChangeEvent;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. class OrderSubscriber implements EventSubscriberInterface
  17. {
  18.     private ERPConnectorService $ERPConnectorService;
  19.     private LoggerInterface $logger;
  20.     private EntityRepository $orderTransactionRepository;
  22.     public function __construct(ERPConnectorService $ERPConnectorService, LoggerInterface $logger, EntityRepository $orderTransactionRepository)
  23.     {
  24.         $this->ERPConnectorService = $ERPConnectorService;
  25.         $this->logger = $logger;
  26.         $this->orderTransactionRepository = $orderTransactionRepository;
  27.     }
  29.     public static function getSubscribedEvents()
  30.     {
  31.         return [
  32.             CheckoutOrderPlacedCriteriaEvent::class => 'orderCreatedCriteriaEvent',
  33.             CheckoutOrderPlacedEvent::class => "orderCreatedEvent",
  34.             'state_machine.order_transaction.state_changed' => 'orderTransactionStateChange',
  35.         ];
  36.     }
  38.     public function orderCreatedCriteriaEvent(CheckoutOrderPlacedCriteriaEvent $event)
  39.     {
  40.         //We need following for email sent to order@iceberg.de
  41.         $criteria = $event->getCriteria();
  42.         $criteria->addAssociations([
  43.             'billingAddress.country',
  44.             'billingAddress.countryState',
  45.             'deliveries.shippingOrderAddress.country',
  46.             'deliveries.shippingOrderAddress.countryState'
  47.         ]);
  48.     }
  50.     /**
  51.      * Triggered when order is placed.
  52.      *
  53.      * @param CheckoutOrderPlacedEvent $event
  54.      * @return void
  55.      */
  56.     public function orderCreatedEvent(CheckoutOrderPlacedEvent $event)
  57.     {
  58.         $this->logger->info("Order placed event order: " . $event->getOrder()->getOrderNumber());
  60.         $orderIds = $this->ERPConnectorService->createOrder($event->getOrder(), $event->getContext());
  62.         if ($orderIds === null) {
  63.             $this->logger->error("Failed to place order (number) " . $event->getOrder()->getOrderNumber() . " into ERP after order has been placed in shop!");
  64.             return;
  65.         }
  67.         ['erpOrderId' => $orderId, 'erpCustomerId' => $customerId] = $orderIds;
  68.         $this->ERPConnectorService->sendInvoicePDFForOrder($orderId, $customerId);
  69.     }
  71.     public function orderTransactionStateChange(StateMachineStateChangeEvent $event)
  72.     {
  73.         $nextState = $event->getNextState()->getTechnicalName();
  74.         $prevState = $event->getPreviousState()->getTechnicalName();
  76.         $this->logger->info("Order transaction state changed from: " . $prevState . " to: " . $nextState);
  78.         //We want to mark paid if new state is paid or authorized.
  79.         if ($nextState !== OrderTransactionStates::STATE_PAID && $nextState !== OrderTransactionStates::STATE_AUTHORIZED)
  80.             return;
  82.         //Probably after order is authortized it will be marked as paid so if from state is authorized lets not do anything.
  83.         if($prevState === OrderTransactionStates::STATE_AUTHORIZED)
  84.             return;
  86.         if ($event->getTransition()->getEntityName() !== 'order_transaction') {
  87.             $this->logger->warning("Expected orderTransactionStateChange entity name to be order_transaction, given: " . $event->getTransition()->getEntityName());
  88.             return;
  89.         }
  91.         $context = $event->getContext();
  92.         $criteria = new Criteria([$event->getTransition()->getEntityId()]);
  93.         $criteria->setLimit(1);
  94.         $criteria->addAssociation('order.transactions');
  96.         /** @var OrderTransactionEntity $orderTransaction */
  97.         $orderTransaction = $this->orderTransactionRepository->search($criteria, $context)->first();
  98.         if ($orderTransaction === null) {
  99.             $this->logger->error("Failed to fetch order transaction inside orderTransactionStateChange event!");
  100.             return;
  101.         }
  103.         $order = $orderTransaction->getOrder();
  104.         if ($order === null) {
  105.             $this->logger->error("Failed to fetch order inside orderTransactionStateChange event!");
  106.             return;
  107.         }
  109.         $this->logger->info("Marking order " . $order->getOrderNumber() . " as paid...");
  110.         $status = $this->ERPConnectorService->markOrderAsPaid($order, $context);
  111.         if (!$status)
  112.             $this->logger->error("Failed to mark order as paid inside orderTransactionStateChange event!");
  113.     }
  114. }