custom/plugins/IwvDatevV6/src/Service/VariablesExporterService.php line 44

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Iwv\IwvDatevV6\Service;
  7. use Doctrine\DBAL\Connection;
  8. use Iwv\IwvDatevV6\Helper\ArrayHelper;
  9. use Iwv\IwvDatevV6\Service\VariablesExporterExt\VariablesExporterConfig;
  10. use Iwv\IwvVariablesHelper\Services\VariablesExporterServiceAbstract;
  11. use Shopware\Core\Checkout\Order\Aggregate\OrderTransaction\OrderTransactionDefinition;
  12. use Shopware\Core\Checkout\Order\OrderEntity;
  13. use Shopware\Core\Framework\Context;
  14. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Search\EntitySearchResult;
  17. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsAnyFilter;
  18. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  19. use Shopware\Core\Framework\DataAbstractionLayer\Search\Sorting\FieldSorting;
  21. class VariablesExporterService extends VariablesExporterServiceAbstract
  22. {
  23.     /** @var Connection */
  24.     protected $connection;
  26.     /** @var EntityRepositoryInterface */
  27.     protected $stateMachineHistoryRepository;
  29.     /** @var EntitySearchResult */
  30.     protected $loadedOrdersDB;
  32.     /** @var Context */
  33.     protected $context;
  35.     /** @var VariablesExporterConfig */
  36.     protected $variablesExporterConfig;
  38.     public function __construct(
  39.         Connection $connection,
  40.         EntityRepositoryInterface $orderRepository,
  41.         EntityRepositoryInterface $stateMachineHistoryRepository
  42.     ) {
  43.         $this->connection = $connection;
  44.         $this->orderRepository = $orderRepository;
  45.         $this->stateMachineHistoryRepository = $stateMachineHistoryRepository;
  46.         parent::__construct($connection);
  47.     }
  49.     /**
  50.      * @param Criteria $criteria
  51.      * @param Context $context
  52.      * @return EntitySearchResult
  53.      */
  54.     public function loadLatestOrders(Criteria $criteria, VariablesExporterConfig $variablesExporterConfig, Context $context): EntitySearchResult
  55.     {
  56.         $this->variablesExporterConfig = $variablesExporterConfig;
  57.         $associations = [
  58.             'lineItems',
  59.             'transactions',
  60.             'transactions.paymentMethod',
  61.             'transactions.paymentMethod.translations',
  62.             'transactions.stateMachineState',
  63.             'orderCustomer.customer',
  64.             'orderCustomer.customer.group',
  65.             'deliveries',
  66.             'deliveries.stateMachineState',
  67.             'salesChannel.currency',
  68.         ];
  69.         if ($this->variablesExporterConfig->loadField('order_delivery_states')) {
  70.             $associations[] = 'deliveries.stateMachineState.toStateMachineHistoryEntries';
  71.         }
  72.         $criteria->addAssociations($associations);
  74.         if ($this->variablesExporterConfig->loadField('order_delivery_states')) {
  75.             $criteria->getAssociation('deliveries.stateMachineState.toStateMachineHistoryEntries')->setLimit(1)->addSorting(new FieldSorting('createdAt', FieldSorting::DESCENDING));
  76.         }
  77.         $criteria->getAssociation('transactions')->addSorting(new FieldSorting('createdAt', FieldSorting::DESCENDING));
  78.         $this->context = $context;
  79.         $this->loadedOrdersDB = $this->orderRepository->search($criteria, $this->context);
  80.         return $this->loadedOrdersDB;
  81.     }
  83.     /**
  84.      * @param string $orderId
  85.      * @param array $settingsArray [paymentStates]
  86.      * @return array
  87.      * @throws \Exception
  88.      */
  89.     public function getLatestOrderVariables(string $orderId, array $settingsArray): array
  90.     {
  91.         $variablesArray = [];
  92.         /** @var OrderEntity $orderDB */
  93.         $orderDB = $this->loadedOrdersDB->get($orderId);
  94.         if (!$orderDB) {
  95.             return $variablesArray;
  96.         }
  98.         $transactions = $orderDB->getTransactions();
  99.         $hasTransactions = $transactions && $transactions->first();
  100.         $paymentMethod = $paymentMethodName = '';
  101.         if ($hasTransactions) {
  102.             $customFields = $transactions->first()->getCustomFields();
  103.             $paymentCodeArray = explode("\\", $transactions->first()->getPaymentMethod()->getHandlerIdentifier());
  104.             $paymentMethod = end($paymentCodeArray);
  105.             $paymentCustomFields = $transactions->first()->getPaymentMethod()->getCustomFields();
  106.             if ($paymentCustomFields) {
  107.                 $variablesArray = array_merge($variablesArray, ArrayHelper::arrayFlat($paymentCustomFields, 'payment_method_cf', '_'));
  108.             }
  110.             $paymentMethodName = $transactions->first()->getPaymentMethod()->getTranslated() && isset($transactions->first()->getPaymentMethod()->getTranslated()['name']) ? $transactions->first()->getPaymentMethod()->getTranslated()['name'] : '';
  111.             if ($customFields) {
  112.                 $variablesArray = array_merge($variablesArray, ArrayHelper::arrayFlat($customFields, 'order_transaction_cf', '.', $this->variablesExporterConfig->loadField('order_transaction_cf_export') === 'deep_load'));
  113.                 $variablesArray = array_merge($variablesArray, ArrayHelper::arrayFlat($customFields, 'order_transaction_cf', '_', $this->variablesExporterConfig->loadField('order_transaction_cf_export') === 'deep_load'));
  114.             }
  116.             if (isset($settingsArray['paymentsErloes'][$transactions->first()->getPaymentMethod()->getId()])) {
  117.                 $variablesArray['{payment_datev_konto}'] = $settingsArray['paymentsErloes'][$transactions->first()->getPaymentMethod()->getId()]['counterAccount'];
  118.             } elseif (isset($settingsArray['paymentsErloes']['default'])) {
  119.                 $variablesArray['{payment_datev_konto}'] = $settingsArray['paymentsErloes']['default']['counterAccount'];
  120.             }
  121.         }
  122.         $variablesArray['{payment_method_cf_datev_gegenkonto}'] = $variablesArray['{payment_datev_konto}'] ?? '';
  124.         $variablesArray['{order_number}'] = $orderDB->getOrderNumber();
  125.         $variablesArray['{order_date}'] = $orderDB->getOrderDateTime()->setTimezone(new \DateTimeZone($this->variablesExporterConfig->exportTimeZone))->format('Y-m-d');
  126.         $variablesArray['{order_affiliate_code}'] = $orderDB->getAffiliateCode();
  127.         $variablesArray['{order_payment_status}'] = $hasTransactions && $orderDB->getTransactions()->first()->getStateMachineState() ? $orderDB->getTransactions()->first()->getStateMachineState()->getTechnicalName() : '';
  128.         $variablesArray['{order_status}'] = $orderDB->getStateMachineState() ? $orderDB->getStateMachineState()->getTechnicalName() : '';
  129.         $variablesArray['{order_delivery_status}'] = $orderDB->getDeliveries() && $orderDB->getDeliveries()->first() && $orderDB->getDeliveries()->first()->getStateMachineState() ? $orderDB->getDeliveries()->first()->getStateMachineState()->getTechnicalName() : '';
  130.         $variablesArray['{order_customer_comment}'] = $orderDB->getCustomerComment() ?: '';
  131.         $variablesArray['{payment_method}'] = $paymentMethod;
  132.         $variablesArray['{payment_method_name}'] = $paymentMethodName;
  133.         $variablesArray['{customer_number}'] = $orderDB->getOrderCustomer()->getCustomerNumber();
  134.         $variablesArray['{customer_email}'] = $orderDB->getOrderCustomer()->getEmail();
  135.         $customerGroupDB = $orderDB->getOrderCustomer()->getCustomer() ? $orderDB->getOrderCustomer()->getCustomer()->getGroup() : '';
  136.         $variablesArray['{customer_group_id}'] = $customerGroupDB ? $customerGroupDB->getId() : '';
  137.         $variablesArray['{customer_group_name}'] = $customerGroupDB ? ($customerGroupDB->getTranslated()['name'] ?? $customerGroupDB->getName()) : '';
  139.         $variablesArray['{sales_channel_currency}'] = $orderDB->getSalesChannel()->getCurrency()->getIsoCode();
  140.         $variablesArray['{sales_channel_name}'] = $orderDB->getSalesChannel()->getName();;
  141.         $variablesArray['{sales_channel_id}'] = $orderDB->getSalesChannelId();
  142.         $variablesArray['{order_delivery_date}'] = $orderDB->getDeliveries() && $orderDB->getDeliveries()->last() ? $orderDB->getDeliveries()->last()->getShippingDateEarliest()->setTimezone(new \DateTimeZone($this->variablesExporterConfig->exportTimeZone))->format('Y-m-d') : '';
  144.         /* order custom fields */
  145.         if ($this->variablesExporterConfig->loadField('order_cf_export') && ($orderCustomFields = $orderDB->getCustomFields())) {
  146.             foreach ($orderCustomFields as $pdcfKey => $pdcf) {
  147.                 if (is_string($pdcf) || is_numeric($pdcf)) {
  148.                     $variablesArray['{order_cf_' . $pdcfKey . '}'] = $pdcf;
  149.                 } elseif (is_bool($pdcf)) {
  150.                     $variablesArray['{order_cf_' . $pdcfKey . '}'] = $pdcf ? '1' : '0';
  151.                 }
  152.             }
  153.             $variablesArray = array_merge($variablesArray, ArrayHelper::arrayFlat($orderCustomFields, 'order_cf', '.', $this->variablesExporterConfig->loadField('order_cf_export') === 'deep_load'));
  154.         }
  156.         /* customer group custom fields */
  157.         if ($this->variablesExporterConfig->loadField('customer_group_cf_export') && ($customFields = $customerGroupDB && $customerGroupDB->getCustomFields() ? $customerGroupDB->getCustomFields() : false)) {
  158.             foreach ($customFields as $pdcfKey => $pdcf) {
  159.                 if (is_string($pdcf) || is_numeric($pdcf)) {
  160.                     $variablesArray['{customer_group_cf_' . $pdcfKey . '}'] = $pdcf;
  161.                 } elseif (is_bool($pdcf)) {
  162.                     $variablesArray['{customer_group_cf_' . $pdcfKey . '}'] = $pdcf ? '1' : '0';
  163.                 }
  164.             }
  165. //            $variablesArray = array_merge($variablesArray, ArrayHelper::arrayFlat($orderCustomFields, 'order_cf', '.', $this->variablesExporterConfig->loadField('order_cf_export') === 'deep_load'));
  166.         }
  168.         /* customer custom fields */
  169.         if ($orderDB->getOrderCustomer() && $orderDB->getOrderCustomer()->getCustomer() && ($customFields = $orderDB->getOrderCustomer()->getCustomer()->getCustomFields())) {
  170.             foreach ($customFields as $pdcfKey => $pdcf) {
  171.                 if (is_string($pdcf) || is_numeric($pdcf)) {
  172.                     $variablesArray['{customer_cf_' . $pdcfKey . '}'] = $pdcf;
  173.                 } elseif (is_bool($pdcf)) {
  174.                     $variablesArray['{customer_cf_' . $pdcfKey . '}'] = $pdcf ? '1' : '0';
  175.                 }
  176.             }
  177.         }
  178.         if ($this->variablesExporterConfig->loadField('payment_states_export') || isset($settingsArray['paymentRowLegacyExport'])) {
  179.             foreach (
  180.             ($orderDB->getTransactions() ? $this->stateMachineHistoryRepository->search((new Criteria)
  181.                 ->addFilter(new EqualsFilter('entityName', OrderTransactionDefinition::ENTITY_NAME))
  182.                 ->addFilter(new EqualsAnyFilter('entityId.id', $orderDB->getTransactions()->getIds()))
  183.                 ->addFilter(new EqualsAnyFilter('transitionActionName', $settingsArray['paymentStates']['selectStates']))
  184.                 ->addSorting(new FieldSorting('createdAt', FieldSorting::DESCENDING)), $this->context) : []) as $transactionDate
  185.             ) {
  186.                 if (isset($settingsArray['paymentStates']['paid'][$transactionDate->getTransitionActionName()]) && empty($variablesArray['{payment_date}'])) {
  187.                     $variablesArray['{payment_date}'] = $transactionDate->getCreatedAt()->setTimezone(new \DateTimeZone($this->variablesExporterConfig->exportTimeZone))->format('Y-m-d');
  188.                 }
  189.                 if (isset($settingsArray['paymentStates']['refunded'][$transactionDate->getTransitionActionName()]) && empty($variablesArray['{refunded_date}'])) {
  190.                     $variablesArray['{refunded_date}'] = $transactionDate->getCreatedAt()->setTimezone(new \DateTimeZone($this->variablesExporterConfig->exportTimeZone))->format('Y-m-d');
  191.                 }
  192.             }
  193.         }
  195.         /* delivery states */
  196.         if ($orderDB->getDeliveries() && $orderDB->getDeliveries()->first()) {
  197.             /** @var \Shopware\Core\Checkout\Order\Aggregate\OrderDelivery\OrderDeliveryEntity $deliveryDB */
  198.             $variablesArray['{order_delivery_state}'] = $orderDB->getDeliveries()->first()->getStateMachineState()->getTechnicalName();
  199.             foreach ($orderDB->getDeliveries() as $deliveryDB) {
  200.                 if (empty($variablesArray['{order_tracking_id}']) && ($trackingIds = implode(', ', $deliveryDB->getTrackingCodes()))) {
  201.                     $variablesArray['{order_tracking_id}'] = $trackingIds;
  202.                 }
  203.                 if ($this->variablesExporterConfig->loadField('order_delivery_states')) {
  204.                     if ($deliveryDB->getStateMachineState()->getTechnicalName() === 'shipped') {
  205.                         $variablesArray['{order_shipped_date}'] = $deliveryDB->getStateMachineState()->getToStateMachineHistoryEntries() && $deliveryDB->getStateMachineState()->getToStateMachineHistoryEntries()->first() ? $deliveryDB->getStateMachineState()->getToStateMachineHistoryEntries()->first()->getCreatedAt()->setTimezone(new \DateTimeZone($this->variablesExporterConfig->exportTimeZone))->format('Y-m-d') : ($deliveryDB->getUpdatedAt() ? $deliveryDB->getUpdatedAt()->setTimezone(new \DateTimeZone($this->variablesExporterConfig->exportTimeZone))->format('Y-m-d') : ($deliveryDB->getCreatedAt() ? $deliveryDB->getCreatedAt()->setTimezone(new \DateTimeZone($this->variablesExporterConfig->exportTimeZone))->format('Y-m-d') : ''));
  206.                         break 1;
  207.                     } elseif ($deliveryDB->getStateMachineState()->getTechnicalName() === 'shipped_partially') {
  208.                         $variablesArray['{order_shipped_date}'] = $deliveryDB->getStateMachineState()->getToStateMachineHistoryEntries() && $deliveryDB->getStateMachineState()->getToStateMachineHistoryEntries()->first() ? $deliveryDB->getStateMachineState()->getToStateMachineHistoryEntries()->first()->getCreatedAt()->setTimezone(new \DateTimeZone($this->variablesExporterConfig->exportTimeZone))->format('Y-m-d') : ($deliveryDB->getUpdatedAt() ? $deliveryDB->getUpdatedAt()->setTimezone(new \DateTimeZone($this->variablesExporterConfig->exportTimeZone))->format('Y-m-d') : ($deliveryDB->getCreatedAt() ? $deliveryDB->getCreatedAt()->setTimezone(new \DateTimeZone($this->variablesExporterConfig->exportTimeZone))->format('Y-m-d') : ''));
  209.                     }
  210.                 }
  211.             }
  212.         }
  214.         /* sw635 compatibility fix */
  215.         $query = 'SELECT platform,special FROM magnalister_orders WHERE current_orders_id = ?';
  216.         $params = [$orderDB->getId()];
  217.         if (isset($settingsArray['hasPluginMagnalister']) && $settingsArray['hasPluginMagnalister'] && ($q = method_exists($this->connection, 'fetchAssociative') ? $this->connection->fetchAssociative($query, $params) : $this->connection->fetchAssoc($query, $params))) {
  218.             $variablesArray['{channel_name}'] = $q['platform'];
  219.             $variablesArray['{channel_order_number}'] = $q['special'];
  220.         }
  222.         $variablesArray['{currency_factor_order_total}'] = $this->formatPrice($orderDB->getAmountTotal() / $orderDB->getCurrencyFactor());
  224.         return array_merge($this->getOrderPluginVariables($orderDB)['entityVars'], $variablesArray);
  225.     }
  227.     /**
  228.      *
  229.      * @param float $price
  230.      * @return string
  231.      */
  232.     protected function formatPrice($price): string
  233.     {
  234.         return number_format($price, 2, ',', '');
  235.     }
  237.     /**
  238.      * @param OrderEntity $orderDB
  239.      * @return array[]
  240.      */
  241.     public function getOrderPluginVariables(OrderEntity $orderDB): array
  242.     {
  243.         $entityVars = [];
  244.         foreach ($this->pluginVariables as $plugin) {
  245.             $entityVars = array_merge($entityVars, $plugin->getVariablesFromOrderDB($orderDB));
  246.         }
  247.         $entityVars['{order_transaction_id}'] = ($entityVars['{paypal_payment_id}'] ?? '') ?: ($entityVars['{payone_transaction_id}'] ?: ($entityVars['{mollie_third_party_payment_id}'] ?: ($entityVars['{klarna_order_id}'] ?: ($entityVars['{easycredit_transaction_id}'] ?: ($entityVars['{swag_amazon_pay_charge_id}'] ?: '')))));
  248.         return [
  249.             'entityVars' => $entityVars,
  250.         ];
  251.     }
  253. }