custom/plugins/NieMehrStreichenTheme/src/Service/ListenToOrderChanges.php line 38

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace NieMehrStreichenTheme\Service;
  5. use Shopware\Core\Checkout\Order\OrderEvents;
  6. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  7. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use GuzzleHttp\Client;
  13. class ListenToOrderChanges implements EventSubscriberInterface
  14. {
  15.     private $restClient;
  16.     
  17.     private EntityRepository $repository;
  18.     
  19.     private OrderTransactionRepository $OrderTransactionRepository;
  21.     public function __construct(
  22.         EntityRepository $repository,
  23.         EntityRepository $orderTransactionRepository
  24.     ) {
  25.         $this->repository = $repository;
  26.         $this->orderTransactionRepository = $orderTransactionRepository;
  27.         $this->restClient = new Client();
  28.     }
  29.     
  30.     public static function getSubscribedEvents(): array
  31.     {
  32.         return [
  33.             OrderEvents::ORDER_WRITTEN_EVENT => 'notifyNewOrderToContactPro',
  34.             OrderEvents::ORDER_TRANSACTION_WRITTEN_EVENT => 'notifyPayedOrderToContactPro',
  35.         ];
  36.     }
  38.     public function notifyPayedOrderToContactPro(EntityWrittenEvent $event): void
  39.     {
  40.         $criteria = new Criteria([$event->getIds()[0]]);
  41.         $order = $this->orderTransactionRepository->search($criteria, $event->getContext())->first();
  43.         if($order->getStateId() == "06be24d74fe14faeaa7de5f153fdd847"){ // paid
  44.             $this->sendNotifyToContactPro($event, $order->getOrderId());
  45.         }
  46.     }
  48.     public function notifyNewOrderToContactPro(EntityWrittenEvent $event): void
  49.     {
  50.         foreach ($event->getWriteResults() as $writeResult) {
  51.             $orderID = $writeResult->getPrimaryKey();
  52.             
  53.             $this->sendNotifyToContactPro($event, $orderID);
  54.         }
  55.     }
  56.     
  57.     public function sendNotifyToContactPro($event, $orderID) {
  58.         
  59.         $criteria = new Criteria([$orderID]);
  60.         $criteria->addAssociation('transactions');
  61.         $criteria->addAssociation('orderCustomer');
  62.         $criteria->addAssociation('lineItems');
  63.         $order = $this->repository->search($criteria, $event->getContext())->first();
  64.         
  65.         $request = new \GuzzleHttp\Psr7\Request(
  66.             'POST',
  67.             'https://objednavky-transform.animatec.cz/transform/shopware/niemehr-order',
  68.             [
  69.                 'Content-Type' => 'application/json',
  70.                 'Authorization' => 'Bearer eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJzdWIiOiJrMDRzajNnOXU4ZzR2Nm10bWZsNWJuMXYyNyIsImlhdCI6MTY4NTQzNTU0NSwiZXhwIjpudWxsfQ.jp9ZTZRotWIeSBagO8zBWK7NbegM9yPYYbJuh0Y5mW4',
  71.             ],
  72.             json_encode([
  73.                 'external_id' => $order->orderNumber,
  74.             ])
  75.         );
  77.         $this->restClient->send($request);
  78.     }
  79. }