custom/plugins/FourtwosixThemeExtension/src/Core/Content/Flow/Dispatching/Action/SendOrderDataAction.php line 71

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace FourtwosixThemeExtension\Core\Content\Flow\Dispatching\Action;
  6. use GuzzleHttp\Client;
  7. use GuzzleHttp\Psr7\Request as GuzzleRequest;
  8. use Psr\Log\LoggerInterface;
  9. use Shopware\Core\Checkout\Order\Event\OrderStateMachineStateChangeEvent;
  10. use Shopware\Core\Checkout\Order\OrderEntity;
  11. use Shopware\Core\Content\Flow\Dispatching\Action\FlowAction;
  12. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  13. use Shopware\Core\Framework\Event\FlowEvent;
  14. use Shopware\Core\Framework\Event\OrderAware;
  15. use Shopware\Core\System\SystemConfig\SystemConfigService;
  17. class SendOrderDataAction extends FlowAction
  18. {
  19.     private SystemConfigService $systemConfigService;
  20.     protected EntityRepositoryInterface $customerGroupRepository;
  21.     protected EntityRepositoryInterface $orderAddressRepository;
  22.     protected EntityRepositoryInterface $salesChannelRepository;
  23.     protected EntityRepositoryInterface $countryRepository;
  24.     protected EntityRepositoryInterface $paymentMethodRepository;
  26.     protected LoggerInterface $logger;
  28.     public function __construct(
  29.         SystemConfigService $systemConfigService,
  30.         EntityRepositoryInterface $customerGroupRepository,
  31.         EntityRepositoryInterface $orderAddressRepository,
  32.         EntityRepositoryInterface $salesChannelRepository,
  33.         EntityRepositoryInterface $countryRepository,
  34.         EntityRepositoryInterface $paymentMethodRepository,
  35.         LoggerInterface $logger
  37.     ) {
  38.         // you would need this repository to create a tag
  39.         $this->systemConfigService = $systemConfigService;
  40.         $this->customerGroupRepository = $customerGroupRepository;
  41.         $this->orderAddressRepository = $orderAddressRepository;
  42.         $this->salesChannelRepository = $salesChannelRepository;
  43.         $this->countryRepository = $countryRepository;
  44.         $this->paymentMethodRepository = $paymentMethodRepository;
  45.         $this->logger = $logger;
  47.     }
  49.     public static function getName(): string
  50.     {
  51.         // your own action name
  52.         return 'action.send.order.data';
  53.     }
  55.     public static function getSubscribedEvents(): array
  56.     {
  57.         return [
  58.             self::getName() => 'handle',
  59.         ];
  60.     }
  62.     public function requirements(): array
  63.     {
  64.         return [OrderAware::class];
  65.     }
  67.     /**
  68.      * @param FlowEvent $event
  69.      * @return void
  70.      */
  71.     public function handle(FlowEvent $event): void
  72.     {
  74.         $this->logger->info("FTS - Started flow for order",[]);
  75.         $orderEvent = $event->getEvent();
  77.         if ( !$orderEvent instanceof OrderAware) {
  78.             return;
  79.         }
  81.         // @fourtwosix-edit: wait on state change because it may happen together with order placed
  82.         if ($orderEvent instanceof OrderStateMachineStateChangeEvent) {
  83.             sleep(10);
  84.         }
  86.         /** @var OrderEntity $order */
  87.         $order = $orderEvent->getOrder();
  89.         $client = new Client();
  90.         $headers = [
  91.             'Content-Type' => 'application/json',
  92.         ];
  94.         $host = rtrim($this->systemConfigService->get('FourtwosixThemeExtension.config.hubUrl'), '/');
  95.         $secret = $this->systemConfigService->get('FourtwosixThemeExtension.config.hubSecret');
  96.         $endpoint = sprintf("/forward-orders/%s", $order->getId());
  97.         $completeUrl = sprintf("%s%s?secret=%s", $host, $endpoint, urlencode($secret));
  98.         $body = '';
  100.         $guzzleRequest = new GuzzleRequest('POST', $completeUrl, $headers, $body);
  101.         $client->sendAsync($guzzleRequest)->wait();
  102.         $this->logger->info("Forward order with id {$order->getId()}",[]);
  103.     }
  104. }