custom/plugins/CytrusImport/src/Subscriber/OrderWrittenSubscriber.php line 39

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Cytrus\Import\Subscriber;
  5. use Psr\Container\ContainerInterface;
  6. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  7. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  8. use Shopware\Core\Checkout\Order\OrderEvents;
  9. use Shopware\Core\Checkout\Customer\CustomerEvents;
  10. use Symfony\Component\HttpFoundation\Request;
  11. use Shopware\Core\Content\Media\File\FileFetcher;
  12. use Shopware\Core\Content\Media\File\FileSaver;
  13. use Shopware\Core\Framework\Uuid\Uuid;
  14. use Shopware\Core\Framework\Context;
  16. class OrderWrittenSubscriber implements EventSubscriberInterface
  17. {
  18.     
  19.     private $container;
  20.     private $fileFetcher;
  21.     private $fileSaver;
  22.     
  23.     public function __construct(ContainerInterface $container, FileFetcher $fileFetcher, FileSaver $fileSaver)
  24.     {
  25.         $this->container = $container;
  26.         $this->fileFetcher = $fileFetcher;
  27.         $this->fileSaver = $fileSaver;
  28.     }
  29.     
  30.     public static function getSubscribedEvents(): array
  31.     {
  32.         // Return the events to listen to as array like this:  <event to listen to> => <method to execute>
  33.         return [
  34.             OrderEvents::ORDER_WRITTEN_EVENT => 'onOrderWrittenEvent',
  35.             CustomerEvents::CUSTOMER_WRITTEN_EVENT => 'onCustomerWrittenEvent',
  36.         ];
  37.     }
  39.     public function onOrderWrittenEvent(EntityWrittenEvent $event)
  40.     {
  41.         if(isset($_FILES['customerFile']) && is_array($_FILES['customerFile'])) {
  42.             foreach($_FILES['customerFile']['tmp_name'] as $key => $tmpName) {
  43.                 if($_FILES['customerFile']['error'][$key] == 0) {
  44.                     $blob = file_get_contents($tmpName);
  45.                     $ext = pathinfo($_FILES['customerFile']['name'][$key])['extension'];
  46.                     $mimeType = $_FILES['customerFile']['type'][$key];
  48.                     $file = $this->fileFetcher->fetchBlob($blob, $ext, $mimeType);
  49.                     
  50.                     $fileName = $event->getWriteResults()[0]->getPayload()['orderNumber'].'_'.basename($_FILES['customerFile']['name'][$key], '.'.$ext);
  51.                     $mediaId = Uuid::randomHex();
  52.                     
  53.                     $media = [
  54.                         [
  55.                             'id' => $mediaId,
  56.                             'fileSize' => $file->getFileSize(),
  57.                             'fileName' => $fileName,
  58.                             'mimeType' => $file->getMimeType(),
  59.                             'fileExtension' => $ext,
  60.                             'mediaFolderId' => '5f4cd6995dd94405a956de45ade11378',
  61.                         ]
  62.                     ];
  64.                     $this->container->get('media.repository')->upsert($media, Context::createDefaultContext());
  65.                     
  66.                     $this->fileSaver->persistFileToMedia(
  67.                         $file, 
  68.                         $fileName,
  69.                         $mediaId,
  70.                         Context::createDefaultContext()
  71.                     );
  72.                 }
  73.             }
  74.         }
  76.         if( isset($_POST['customField']) && is_array($_POST['customField']) && !empty($_POST['customField']) ) {
  77.             $this->container->get(\Doctrine\DBAL\Connection::class)->executeStatement('UPDATE `order` SET custom_fields=\''.json_encode($_REQUEST['customField']).'\' WHERE id = X\''.$event->getWriteResults()[0]->getPrimaryKey().'\'');
  78.         }
  79.     }
  81.     public function onCustomerWrittenEvent(EntityWrittenEvent $event)
  82.     {
  83.         if( isset($_POST['customField']) && is_array($_POST['customField']) && !empty($_POST['customField']) ) {
  84.             if(isset($_POST['customField']['custom_customers_customernumber']) && trim($_POST['customField']['custom_customers_customernumber']) != '') {
  85.                 $customerNumberPrefix = 'DI-';
  86.                 if($_POST['billingAddress']['countryId'] == 'c224f9eb849240a982273f712d9799ca' || substr($_SERVER['REQUEST_URI'],0,4) == '/fr/' ) {
  87.                     $customerNumberPrefix = 'DE-';
  88.                 }
  89.                 $_POST['customField']['custom_customers_customernumber'] = $customerNumberPrefix . str_replace(['DI-','DE-'],['',''],$_POST['customField']['custom_customers_customernumber']);
  90.                 $this->container->get(\Doctrine\DBAL\Connection::class)->executeStatement('UPDATE `customer` SET custom_fields=\''.json_encode($_POST['customField']).'\' WHERE id = X\''.$event->getWriteResults()[0]->getPrimaryKey().'\'');
  91.             }
  92.         }
  93.     }
  94. }