src/CoreBundle/EventSubscriber/OrderEventSubscriber.php line 62

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace App\CoreBundle\EventSubscriber;
  7. use App\CoreBundle\Command\WooSyncOrderBatchCommand;
  8. use App\CoreBundle\Command\WooSyncOrderCommand;
  9. use App\CoreBundle\Component\WooCommerce\WooCommerce;
  10. use App\CoreBundle\Model\Order\Order;
  11. use App\CoreBundle\Model\Order\OrderDataFactoryInterface;
  12. use App\CoreBundle\Model\Order\OrderEvent;
  13. use App\CoreBundle\Model\Order\OrderFacade;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. use Symfony\Component\Process\Process;
  17. class OrderEventSubscriber implements EventSubscriberInterface
  18. {
  19.     /**
  20.      * @var \App\CoreBundle\Component\WooCommerce\WooCommerce
  21.      */
  22.     private $wooCommerce;
  24.     /**
  25.      * @var \App\CoreBundle\Command\WooSyncOrderCommand
  26.      */
  27.     private $wooSyncOrderCommand;
  29.     /**
  30.      * @var \App\CoreBundle\Command\WooSyncOrderBatchCommand
  31.      */
  32.     private $wooSyncOrderBatchCommand;
  34.     /**
  35.      * @var \App\CoreBundle\Model\Order\OrderFacade
  36.      */
  37.     private $orderFacade;
  39.     /**
  40.      * @var \App\CoreBundle\Model\Order\OrderDataFactoryInterface
  41.      */
  42.     private $orderDataFactory;
  44.     public function __construct(
  45.         WooCommerce $wooCommerce,
  46.         WooSyncOrderCommand $wooSyncOrderCommand,
  47.         WooSyncOrderBatchCommand $wooSyncOrderBatchCommand,
  48.         OrderFacade $orderFacade,
  49.         OrderDataFactoryInterface $orderDataFactory
  50.     )
  51.     {
  52.         $this->wooCommerce = $wooCommerce;
  53.         $this->wooSyncOrderCommand = $wooSyncOrderCommand;
  54.         $this->wooSyncOrderBatchCommand = $wooSyncOrderBatchCommand;
  55.         $this->orderFacade = $orderFacade;
  56.         $this->orderDataFactory = $orderDataFactory;
  57.     }
  59.     /**
  60.      * @param \App\CoreBundle\Model\Order\OrderEvent $orderEvent
  61.      */
  62.     public function syncAllOrders(OrderEvent $orderEvent): void
  63.     {
  64.         $order = $orderEvent->getOrder();
  66.         // more efficient, it will only process the modified order
  67.         $command = $this->wooSyncOrderBatchCommand->getShellCommand(array($order)); // $command = $this->wooSyncOrderCommand->getShellCommand();
  69.         $process = \Symfony\Component\Process\Process::fromShellCommandline($command);
  70.         $process->start();
  71.     }
  73.     public function waitProcess(Process $process)
  74.     {
  75.         while ($process) {
  76.             if ($process->isRunning() === true) {
  77.                 break;
  78.             }
  80.             $process = null;
  81.         }
  82.         sleep(1);
  83.     }
  84.     /**
  85.      * @return array
  86.      */
  87.     public static function getSubscribedEvents(): array
  88.     {
  89.         return [
  90.             OrderEvent::UPDATE => 'syncAllOrders',
  91.         ];
  92.     }
  93. }