custom/plugins/theme/src/Core/Content/Flow/Dispatching/Action/SendOrderDataAction.php line 64

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace DonCarneTheme\Core\Content\Flow\Dispatching\Action;
  5. use Monolog\Logger;
  6. use Shopware\Core\Checkout\Order\Aggregate\OrderLineItem\OrderLineItemEntity;
  7. use Shopware\Core\Content\Flow\Dispatching\Action\FlowAction;
  8. use Shopware\Core\Content\Media\MediaEntity;
  9. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  10. use Shopware\Core\Framework\Event\FlowEvent;
  11. use Shopware\Core\Framework\Event\OrderAware;
  12. use DonCarneTheme\Service\GraphQLClient;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  14. use DateTime;
  15. use Shopware\Core\Checkout\Order\OrderEntity;
  16. use Shopware\Core\Checkout\Order\OrderEvents;
  18. class SendOrderDataAction extends FlowAction
  19. {
  20.     const TRIGGER = 'order_inProgress';
  21.     const FEMALE_SALUTATION_ID = 'f3183bb9f683437e9f862cbe2b63237e';
  23.     private GraphQLClient $graphQLClient;
  25.     private EntityRepositoryInterface $productRepository;
  27.     private EntityRepositoryInterface $customerGroupRepository;
  29.     private EntityRepositoryInterface $orderAddressRepository;
  31.     private Logger $logger;
  33.     public function __construct(
  34.         GraphQLClient $graphQLClient,
  35.         EntityRepositoryInterface $productRepository,
  36.         EntityRepositoryInterface $customerGroupRepository,
  37.         EntityRepositoryInterface $orderAddressRepository,
  38.         Logger $logger
  39.     ) {
  40.         $this->graphQLClient = $graphQLClient;
  41.         $this->productRepository = $productRepository;
  42.         $this->customerGroupRepository = $customerGroupRepository;
  43.         $this->orderAddressRepository = $orderAddressRepository;
  44.         $this->logger = $logger;
  45.     }
  47.     public static function getName(): string
  48.     {
  49.         return 'action.send.order.data';
  50.     }
  52.     public static function getSubscribedEvents(): array
  53.     {
  54.         return [
  55.             self::getName() => 'handle',
  56.         ];
  57.     }
  59.     public function requirements(): array
  60.     {
  61.         return [OrderAware::class];
  62.     }
  64.     public function handle(FlowEvent $event): void
  65.     {
  66.         $orderEvent = $event->getEvent();
  68.         if (!$orderEvent instanceof OrderAware) {
  69.             return;
  70.         }
  72.         $orderData = [];
  73.         /** @var OrderEntity $order */
  74.         $order = $orderEvent->getOrder();
  75.         $customer = $order->getOrderCustomer()->getCustomer();
  76.         $shipping = $order->getDeliveries()->first();
  77.         $customFields = $order->getCustomFields() ?? [];
  78.         $expectedDelivery = $customFields['expected_delivery_date'] ?? date_format($shipping->getShippingDateEarliest(),"Y-m-d");
  80.         $orderData['email'] = $customer->getEmail();
  81.         $orderData['subscriberKey'] = $customer->getEmail();
  82.         $orderData['trigger'] = self::TRIGGER;
  83.         $orderData['order_date'] = date_format($order->getOrderDate(),"Y-m-d");
  84.         $orderData['delivery_date'] = $expectedDelivery;
  85.         $orderData['order_id'] = $order->getOrderNumber();
  86.         $orderData['gender'] = 'M';
  88.         // Billing data
  89.         $criteria = new Criteria([$order->getBillingAddressId()]);
  90.         $criteria->addAssociation('country');
  91.         $billingAddress = $this->orderAddressRepository->search($criteria, $event->getContext())->first();
  93.         //prior method did not work. Salutation was always empty. Salutation is not available here either, just the id is set
  94.         if($billingAddress->getSalutationId() == self::FEMALE_SALUTATION_ID) {
  95.             $orderData['gender'] = 'F';
  96.         }
  98.         $orderData['billing'] = $this->getBillingData($billingAddress);
  100.         // Shipping data
  101.         $orderData['shipping'] = $this->getShippingData($shipping);
  103.         $orderData['payment_method'] = $order->getTransactions()->first()->getPaymentMethod()->getName();
  105.         $orderData['positions'] = $this->getPositions($order, $event)['positions'];
  107.         $orderData['order_sum'] = (string) round($this->getPositions($order, $event)['totalPositionsPrice'],2);
  109.         $orderData['shipping_cost'] = (string) $shipping->getShippingCosts()->getTotalPrice();
  111.         $orderData['promotions'] = $this->getPromotions($order, $event);
  113.         $orderData['total_order_sum'] = (string) $order->getAmountTotal();
  115.         $orderData['customer_group'] = $this->customerGroupRepository->search(new Criteria([$customer->getGroupId()]), $event->getContext())->first()->getName();
  117.         $orderData['voucher'] = '[]';
  119.         $response = $this->graphQLClient->sendOrderData($orderData);
  120.     }
  122.     /* Get all billing infos */
  123.     private function getBillingData($billingAddress) {
  124.         $billingData = [];
  125.         $billingData['firstname'] = $billingAddress->getFirstName();
  126.         $billingData['lastname'] = $billingAddress->getLastName();
  127.         $billingData['company'] = $billingAddress->getCompany() ?: "";
  128.         $billingData['street'] = $billingAddress->getStreet();
  129.         $billingData['postalcode'] = $billingAddress->getZipcode();
  130.         $billingData['city'] = $billingAddress->getCity();
  131.         $billingData['country'] = $billingAddress->getCountry()->getIso();
  133.         return $billingData;
  134.     }
  136.     /* Get all shipping infos */
  137.     private function getShippingData($shipping) {
  138.         $shippingAddress = $shipping->getShippingOrderAddress();
  140.         $shippingData = [];
  141.         $shippingData['shipping_firstname'] = $shippingAddress->getFirstName();
  142.         $shippingData['shipping_lastname'] = $shippingAddress->getLastName();
  143.         $shippingData['shipping_company'] = $shippingAddress->getCompany() ?: "";
  144.         $shippingData['shipping_street'] = $shippingAddress->getStreet();
  145.         $shippingData['shipping_postalcode'] = $shippingAddress->getZipcode();
  146.         $shippingData['shipping_city'] = $shippingAddress->getCity();
  147.         $shippingData['shipping_country'] = $shippingAddress->getCountry()->getIso();
  148.         $shippingData['delivery_date'] = date_format($shipping->getShippingDateEarliest(),"Y-m-d");
  149.         $shippingData['delivery_method'] = $shipping->getShippingMethod()->getName();
  151.         $shippingCustomFields = $shipping->getShippingMethod()->getCustomFields();
  153.         /* If shipping method has a graphql id redo the delivery options request to retrieve the correct shipping method name and date */
  154.         if ($shippingCustomFields && isset($shippingCustomFields['custom_shipping_graphql_id'])) {
  155.             $availableShippingMethods = $this->graphQLClient->getDeliveryOptions($shippingData['shipping_country'], $shippingData['shipping_postalcode']);
  157.             $deliveryGqlOptions = json_decode($availableShippingMethods->getResponseBody())->data->deliveryOptions;
  159.             foreach ($deliveryGqlOptions as $deliveryGqlOption) {
  160.                 if ($deliveryGqlOption->id === $shippingCustomFields['custom_shipping_graphql_id']) {
  161.                     $shippingData['delivery_method'] = $deliveryGqlOption->name;
  162.                     $shippingData['delivery_date'] = $this->getNearestDeliveryDate($deliveryGqlOption->dates);
  163.                 }
  164.             }
  165.         }
  167.         return $shippingData;
  168.     }
  170.     /* Get all products data */
  171.     private function getPositions($order, $event) {
  172.         $positions = [];
  173.         // We need this variable to calculate the order_sum value
  174.         $positionsPrice = 0;
  176.         foreach ($order->getLineItems() as $lineItem) {
  177.             /**
  178.              * @var OrderLineItemEntity $lineItem
  179.              */
  180.             if ($lineItem->getType() === 'product') {
  181.                 $lineItemData = [];
  183.                 $criteria = new Criteria([$lineItem->getProductId()]);
  184.                 $criteria->addAssociation('properties.group');
  185.                 $criteria->addAssociation('media');
  186.                 $criteria->addAssociation('customFields');
  187.                 $product = $this->productRepository->search($criteria, $event->getContext())->first();
  188.                 $lineItemData['product_condition'] = "";
  189.                 if ($product->getProperties()) {
  190.                     foreach ($product->getProperties() as $property) {
  191.                         $propertyGroupCustomFields = $property->getGroup()->getCustomFields();
  192.                         if ($propertyGroupCustomFields &&
  193.                             isset($propertyGroupCustomFields['custom_property_group_is_kuehlbedingung']) &&
  194.                             $propertyGroupCustomFields['custom_property_group_is_kuehlbedingung']
  195.                         ) {
  196.                             $lineItemData['product_condition'] = $property->getName();
  197.                         }
  198.                         if ($propertyGroupCustomFields &&
  199.                             isset($propertyGroupCustomFields['custom_property_group_is_kuehlbedingung']) &&
  200.                             $propertyGroupCustomFields['custom_property_group_is_kuehlbedingung']
  201.                         ) {
  202.                             $lineItemData['product_condition'] = $property->getName();
  203.                         }
  205.                     }
  206.                 }
  207.                 $lineItemData['product_imageurl'] = '';
  208.                 //Cover Image is not available. Therefore cycle through all images and use the one with position 0
  209.                 if($customFields = $product->getCustomFields()) {
  210.                     if(!empty($customFields['mail_thumb'])) {
  211.                         $lineItemData['product_imageurl'] = 'https://doncarne.de' . $customFields['mail_thumb'];
  212.                     }
  213.                 }
  214.                 if($lineItemData['product_imageurl'] == ''){
  215.                     if ($media = $product->getMedia()) {
  216.                         foreach($media as $m) {
  217.                             if($m->getPosition() == 0) {
  218.                                 $lineItemData['product_imageurl'] = $m->getMedia()->getUrl();
  219.                             }
  220.                         }
  221.                         if(empty($lineItemData['product_imageurl'])) {
  222.                             $lineItemData['product_imageurl'] = $product->getMedia()->first()->getMedia()->getUrl();
  223.                         }
  224.                     }
  225.                 }
  226.                 $lineItemData['product_name'] = str_replace(["'",'"', '\\'], '',$lineItem->getLabel());
  227.                 $lineItemData['product_weight'] = (string) $product->getWeight();
  228.                 $lineItemData['product_id'] = $product->getProductNumber();
  229.                 $lineItemData['order_amount'] = (string) $lineItem->getQuantity();
  230.                 $lineItemData['product_price_per_amount'] = (string) $lineItem->getUnitPrice();
  231.                 $lineItemData['product_price_total'] = (string) $lineItem->getTotalPrice();
  233.                 $positions[] = addslashes(json_encode($lineItemData, JSON_UNESCAPED_UNICODE));
  235.                 $positionsPrice += $lineItem->getTotalPrice();
  236.             }
  238.             if ($lineItem->getType() == 'easy-coupon') {
  239.                 $lineItemData = [];
  240.                 $lineItemData['product_imageurl'] = '';
  241.                 $lineItemData['product_name'] = 'Gutschein Einlösung';
  242.                 $lineItemData['product_condition'] = "";
  243.                 $lineItemData['product_weight'] = '';
  244.                 $lineItemData['product_id'] = 'voucher' . $lineItem->getUnitPrice();
  245.                 $lineItemData['order_amount'] = (string) $lineItem->getQuantity();
  246.                 $lineItemData['product_price_per_amount'] = (string) $lineItem->getUnitPrice();
  247.                 $lineItemData['product_price_total'] = (string) $lineItem->getTotalPrice();
  248.                 $positions[] = addslashes(json_encode($lineItemData, JSON_UNESCAPED_UNICODE));
  249.                 $positionsPrice += $lineItem->getTotalPrice();
  250.             }
  251.             if ($lineItem->getType() == 'dvsn_pseudo_product') {
  252.                 $lineItemData = [];
  253.                 $lineItemData['product_imageurl'] = '';
  254.                 $lineItemData['product_name'] = str_replace(["'",'"', '\\'], '',$lineItem->getLabel());
  255.                 $lineItemData['product_condition'] = "";
  256.                 $lineItemData['product_weight'] = '';
  257.                 $lineItemData['product_id'] = '';
  258.                 $lineItemData['order_amount'] = 1;
  259.                 $lineItemData['product_price_per_amount'] = (string) $lineItem->getUnitPrice();
  260.                 $lineItemData['product_price_total'] = (string) $lineItem->getTotalPrice();
  261.                 $positions[] = addslashes(json_encode($lineItemData, JSON_UNESCAPED_UNICODE));
  262.                 $positionsPrice += $lineItem->getTotalPrice();
  263.             }
  264.         }
  266.         $returnData = [
  267.             'positions' => implode(',', $positions),
  268.             'totalPositionsPrice' => $positionsPrice
  269.         ];
  270.         return $returnData;
  271.     }
  273.     /* Get all the promotions */
  274.     private function getPromotions($order) {
  275.         $discounts = [];
  277.         foreach ($order->getLineItems() as $lineItem) {
  278.             if ($lineItem->getType() === 'promotion') {
  280.                 $lineItemData = [];
  282.                 $lineItemData['name'] = $lineItem->getLabel();
  283.                 $lineItemData['value'] = (string) (-1 * $lineItem->getTotalPrice());
  285.                 $discounts[] = addslashes(json_encode($lineItemData, JSON_UNESCAPED_UNICODE));
  286.             }
  287.         }
  289.         return implode(',', $discounts);
  290.     }
  292.     private function getNearestDeliveryDate($dates)
  293.     {
  294.         $nearestDate = null;
  296.         foreach ($dates as $date) {
  297.             $currentDate = $date->date;
  298.             if (!$nearestDate || $currentDate < $nearestDate) {
  299.                 $nearestDate = $currentDate;
  300.             }
  301.         }
  303.         $nearestDate = DateTime::createFromFormat("Y-md-", strval($nearestDate));
  305.         return $nearestDate;
  306.     }
  307. }