custom/plugins/LtcKomfortkasse6/src/Subscriber/OrderSubscriber.php line 42

Open in your IDE?
  1. <?php
  2. declare(strict_types = 1)
  3.     ;
  5. namespace Ltc\Komfortkasse\Subscriber;
  7. use Shopware\Core\Checkout\Order\OrderEvents;
  8. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  11. use Shopware\Core\System\SystemConfig\SystemConfigService;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. class OrderSubscriber implements EventSubscriberInterface
  15. {
  17.     /** @var SystemConfigService */
  18.     private $systemConfigService;
  20.     /** @var EntityRepositoryInterface */
  21.     private $orderRepo;
  24.     public function __construct(SystemConfigService $systemConfigService, EntityRepositoryInterface $orderRepo)
  25.     {
  26.         $this->systemConfigService = $systemConfigService;
  27.         $this->orderRepo = $orderRepo;
  29.     }
  32.     public static function getSubscribedEvents(): array
  35.     {
  36.         return [ OrderEvents::ORDER_WRITTEN_EVENT => 'onInsertOrder'
  37.         ];
  39.     }
  42.     public function onInsertOrder(EntityWrittenEvent $event)
  43.     {
  44.         $active = $this->systemConfigService->get('LtcKomfortkasse6.config.active');
  45.         if (!$active)
  46.             return;
  48.         foreach ($event->getWriteResults() as $result) {
  50.             $orderCriteria = new Criteria([ $result->getPrimaryKey()
  51.             ]);
  52.             $orderCriteria->addAssociation('salesChannel.domains');
  53.             $orderCriteria->addAssociation('transactions.paymentMethod');
  54.             $orders = $this->orderRepo->search($orderCriteria, $event->getContext())->getEntities();
  56.             foreach ($orders as $order) {
  57.                 $urls = array ();
  58.                 $channel = $order->getSalesChannel();
  59.                 if (!$this->systemConfigService->get('LtcKomfortkasse6.config.active', $channel->getId()))
  60.                     continue;
  62.                 foreach ($channel->getDomains() as $domain) {
  63.                     $urls [] = $domain->getUrl();
  64.                 }
  66.                 $paymentMethods = array();
  67.                 foreach ($order->getTransactions() as $t) {
  68.                     if (!in_array($t->getPaymentMethodId(), $paymentMethods))
  69.                         $paymentMethods [] = $t->getPaymentMethodId();
  70.                     if ($t->getPaymentMethod() && !in_array($t->getPaymentMethod()->getFormattedHandlerIdentifier(), $paymentMethods))
  71.                         $paymentMethods [] = $t->getPaymentMethod()->getFormattedHandlerIdentifier();
  72.                 }
  73.                 
  74.                 $query = http_build_query(array ('id' => $order->getId(),'url' => $urls, 'payment_method' => $paymentMethods));
  75.                 $ch = curl_init();
  76.                 curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  77.                 curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true);
  78.                 curl_setopt($ch, CURLOPT_URL, 'https://ssl.komfortkasse.eu/api/shop/neworder.jsf');
  79.                 curl_setopt($ch, CURLOPT_POST, true);
  80.                 curl_setopt($ch, CURLOPT_NOSIGNAL, 1);
  81.                 curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 0);
  82.                 curl_setopt($ch, CURLOPT_TIMEOUT_MS, 1001);
  83.                 curl_setopt($ch, CURLOPT_POSTFIELDS, $query);
  84.                 @curl_exec($ch);
  85.                 @curl_close ($ch);
  86.             }
  87.         }
  89.     }
  90. }