custom/plugins/ProxaImportExportExtension/src/Subscribers/ImportExportSubscriber.php line 61

Open in your IDE?
  1. <?php
  3. namespace ProxaImportExportExtension\Subscribers;
  5. use ProxaImportExportExtension\ProxaImportExportExtension;
  6. use Shopware\Core\Checkout\Document\DocumentEntity;
  7. use Shopware\Core\Checkout\Order\Aggregate\OrderAddress\OrderAddressEntity;
  8. use Shopware\Core\Checkout\Order\Aggregate\OrderTransaction\OrderTransactionEntity;
  9. use Shopware\Core\Content\ImportExport\Event\ImportExportBeforeExportRecordEvent;
  10. use Shopware\Core\Framework\Context;
  11. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. class ImportExportSubscriber implements EventSubscriberInterface
  17. {
  18.     /**
  19.      * @var EntityRepositoryInterface
  20.      */
  21.     private EntityRepositoryInterface $repositoryDocuments;
  22.     /**
  23.      * @var EntityRepositoryInterface
  24.      */
  25.     private EntityRepositoryInterface $repositoryOrderAddress;
  26.     /**
  27.      * @var EntityRepositoryInterface
  28.      */
  29.     private EntityRepositoryInterface $repositoryOrderTransaction;
  31.     /**
  32.      * @param EntityRepositoryInterface $repositoryDocuments
  33.      * @param EntityRepositoryInterface $repositoryOrderAddress
  34.      * @param EntityRepositoryInterface $repositoryOrderTransaction
  35.      */
  36.     public function __construct(
  37.         EntityRepositoryInterface $repositoryDocuments,
  38.         EntityRepositoryInterface $repositoryOrderAddress,
  39.         EntityRepositoryInterface $repositoryOrderTransaction
  40.     )
  41.     {
  42.         $this->repositoryDocuments = $repositoryDocuments;
  43.         $this->repositoryOrderAddress = $repositoryOrderAddress;
  44.         $this->repositoryOrderTransaction = $repositoryOrderTransaction;
  45.     }
  47.     /**
  48.      * @return string[]
  49.      */
  50.     public static function getSubscribedEvents(): array
  51.     {
  52.         return [
  53.             ImportExportBeforeExportRecordEvent::class => 'onImportExportBeforeExportRecord'
  54.         ];
  55.     }
  57.     /**
  58.      * @param ImportExportBeforeExportRecordEvent $event
  59.      * @return void
  60.      */
  61.     public function onImportExportBeforeExportRecord(ImportExportBeforeExportRecordEvent $event): void
  62.     {
  63.         if ($event->getConfig()->get('profileName') != ProxaImportExportExtension::IMPORT_EXPORT_PROFILE_ORDER_NAME) {
  64.             return;
  65.         }
  66.         $record = $event->getRecord();
  67.         $record[ProxaImportExportExtension::INVOICE_NUMBER['mappedKey']] = $this->getInvoiceNumber($event->getOriginalRecord());
  68.         $record[ProxaImportExportExtension::TOTAL_WITHOUT_SHIPPING['mappedKey']] = $this->calculateTotalWithoutShipping($event->getOriginalRecord());
  69.         $record[ProxaImportExportExtension::CUSTOMER_ADDRESS['mappedKey']] = $this->getCustomerAddress($event->getOriginalRecord());
  70.         $record[ProxaImportExportExtension::PAYMENT_METHOD['mappedKey']] = $this->getPaymentMethod($event->getOriginalRecord());
  71.         $event->setRecord($record);
  72.     }
  74.     /**
  75.      * @param array $record
  76.      * @return float
  77.      */
  78.     private function calculateTotalWithoutShipping(array $record): float
  79.     {
  80.         return round($record['amountTotal'] - $record['shippingCosts']->getTotalPrice(), 2);
  81.     }
  83.     /**
  84.      * @param array $record
  85.      * @return string|null
  86.      */
  87.     private function getInvoiceNumber(array $record): ?string
  88.     {
  89.         $criteria = new Criteria();
  90.         $criteria->addFilter(new EqualsFilter('orderId', $record['id']));
  91.         $searchResult = $this->repositoryDocuments->search($criteria, Context::createDefaultContext());
  92.         /** @var DocumentEntity $document */
  93.         foreach ($searchResult as $document) {
  94.             $config = $document->getConfig();
  95.             if (
  96.                 isset($config['name'])
  97.                 && $config['name'] == 'invoice'
  98.             ) {
  99.                 return $config['documentNumber'] ?? null;
  100.             }
  101.         }
  102.         return null;
  103.     }
  105.     /**
  106.      * @param array $record
  107.      * @return string|null
  108.      */
  109.     private function getCustomerAddress(array $record): ?string
  110.     {
  111.         $criteria = new Criteria([$record['billingAddressId']]);
  112.         $criteria->addAssociation('country');
  113.         /** @var OrderAddressEntity|null $result */
  114.         $result = $this->repositoryOrderAddress->search($criteria, Context::createDefaultContext())->first();
  115.         if (!$result) {
  116.             return null;
  117.         }
  118.         $address = [
  119.             $result->getStreet(),
  120.             $result->getZipcode(),
  121.             $result->getCity(),
  122.             $result->getCountry()->getIso()
  123.         ];
  124.         return implode(' | ', $address);
  125.     }
  127.     private function getPaymentMethod(array $record): string
  128.     {
  129.         $criteria = new Criteria();
  130.         $criteria->addFilter(new EqualsFilter('orderId', $record['id']));
  131.         $criteria->addAssociation('paymentMethod');
  132.         $result = $this->repositoryOrderTransaction->search($criteria, Context::createDefaultContext());
  134.         $names = [];
  135.         /** @var OrderTransactionEntity $entity */
  136.         foreach ($result as $entity) {
  137.             $names[] = $entity->getPaymentMethod()->getName();
  138.         }
  139.         return implode(' | ', $names);
  140.     }
  141. }