custom/plugins/System4InterfacePlugin/src/Subscriber/OrderSubscriber.php line 69

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace System4InterfacePlugin\Subscriber;
  5. use Shopware\Core\Checkout\Cart\Event\CheckoutOrderPlacedEvent;
  6. use Shopware\Core\Checkout\Cart\Order\CartConvertedEvent;
  7. use Shopware\Core\Checkout\Order\Aggregate\OrderTransaction\OrderTransactionDefinition;
  8. use Shopware\Core\Checkout\Order\OrderEntity;
  9. use Shopware\Core\Checkout\Order\OrderStates;
  10. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  13. use Shopware\Core\System\StateMachine\Event\StateMachineTransitionEvent;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. use System4InterfacePlugin\Services\OrderService;
  16. use Shopware\Core\Framework\Context;
  17. use Shopware\Core\Defaults;
  19. class OrderSubscriber implements EventSubscriberInterface
  20. {
  21.     /**
  22.      * @var EntityRepository
  23.      */
  24.     private $orderRepository;
  26.     /**
  27.      * @var OrderService
  28.      */
  29.     private $orderService;
  31.     /**
  32.      * @var CartConvertedEvent
  33.      */
  34.     protected $cartConvertedEvent;
  36.     public function __construct(
  37.         EntityRepository $orderRepository,
  38.         OrderService $orderService
  39.     ) {
  40.         $this->orderRepository = $orderRepository;
  41.         $this->orderService = $orderService;
  42.     }
  44.     public static function getSubscribedEvents()
  45.     {
  46.         return [
  47.             CheckoutOrderPlacedEvent::class => 'onOrderPlaced',
  48.             StateMachineTransitionEvent::class => 'onStateChanged'
  49.         ];
  50.     }
  52.     public function onOrderPlaced(CheckoutOrderPlacedEvent $event)
  53.     {   
  54.         $order = $event->getOrder();
  55.         $this->orderRepository->update([
  56.             [
  57.                 'id' => $order->getId(),
  58.                 'customFields' => ['system4_erp_status' => "Not Received"]
  59.             ]
  60.         ], Context::createDefaultContext());
  62.         $orderTransaction = $order->getTransactions()->first();
  63.         if ($orderTransaction->getPaymentMethod() && $orderTransaction->getPaymentMethod()->isSynchronous()) {
  64.             $order = $this->getOrder($event, $order->getId());
  65.             $response = $this->orderService->sendOrderPayload($order, $order->getOrderCustomer()->getCustomer());
  66.         }
  67.     }
  69.     public function onStateChanged(StateMachineTransitionEvent $event)
  70.     {
  71.         if ($event->getEntityName() !== OrderTransactionDefinition::ENTITY_NAME) {
  72.             return;
  73.         }
  75.         $to = $event->getToPlace()->getTechnicalName();
  76.         $from = $event->getFromPlace()->getTechnicalName();
  78.         if ($from === OrderStates::STATE_OPEN && $to !== OrderStates::STATE_CANCELLED) {
  79.             $order = $this->getOrderTransaction($event, $event->getEntityId());
  80.             $this->orderRepository->update([
  81.                 [
  82.                     'id' => $order->getId(),
  83.                     'customFields' => ['system4_erp_status' => "Not Received"]
  84.                 ]
  85.             ], Context::createDefaultContext());
  86.             $orderTransaction = $order->getTransactions()->first();
  88.             if ($orderTransaction->getPaymentMethod()->isAsynchronous()) {
  89.                 $response = $this->orderService->sendOrderPayload($order, $order->getOrderCustomer()->getCustomer());
  90.             }
  91.         }
  92.     }
  94.     private function getOrder(CheckoutOrderPlacedEvent $event, string $id): ?OrderEntity
  95.     {
  96.         $criteria = new Criteria([$id]);
  97.         $criteria->addAssociation('orderCustomer.customer');
  98.         $criteria->addAssociation('lineItems');
  99.         $criteria->addAssociation('transactions.paymentMethod');
  100.         $criteria->addAssociation('billingAddress.country');
  101.         $criteria->addAssociation('deliveries.shippingMethod');
  102.         $criteria->addAssociation('deliveries.shippingOrderAddress.country');
  103.         $criteria->addAssociation('currency');
  104.         $criteria->addAssociation('language.translationCode');
  106.         return $this->orderRepository->search($criteria, $event->getContext())->first();
  107.     }
  109.     private function getOrderTransaction(StateMachineTransitionEvent $event, string $id): ?OrderEntity
  110.     {
  111.         $criteria = new Criteria();
  112.         $criteria->addFilter(new EqualsFilter('transactions.id', $id));
  113.         $criteria->addAssociation('orderCustomer.customer');
  114.         $criteria->addAssociation('lineItems');
  115.         $criteria->addAssociation('transactions.paymentMethod');
  116.         $criteria->addAssociation('billingAddress.country');
  117.         $criteria->addAssociation('deliveries.shippingMethod');
  118.         $criteria->addAssociation('deliveries.shippingOrderAddress.country');
  120.         return $this->orderRepository->search($criteria, $event->getContext())->first();
  121.     }
  122. }