custom/plugins/MyPaShopware/src/Subscriber/CartConversionSubscriber.php line 77

Open in your IDE?
  1. <?php
  3. namespace MyPa\Shopware\Subscriber;
  5. use MyPa\Shopware\Core\Content\ShippingOption\ShippingOptionEntity;
  6. use MyPa\Shopware\Defaults;
  7. use MyPa\Shopware\Service\Config\ConfigGenerator;
  8. use MyPa\Shopware\Service\Config\MyParcelCarriers;
  9. use MyParcelNL\Sdk\src\Model\Consignment\AbstractConsignment;
  10. use Psr\Log\LoggerInterface;
  11. use Shopware\Core\Checkout\Cart\Order\CartConvertedEvent;
  12. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. class CartConversionSubscriber implements EventSubscriberInterface
  18. {
  19.     /**
  20.      * ShippingOptionEntity::FIELD_DELIVERY_TYPE is not needed because it will always be read from the checkout settings
  21.      * ShippingOptionEntity::FIELD_ONLY_RECIPIENT will only be read in defaults, not from checkout
  22.      */
  23.     private const SHIPPING_OPTIONS_WITH_DEFAULT = [
  24.         ShippingOptionEntity::FIELD_DELIVERY_DATE      => "",
  25.         ShippingOptionEntity::FIELD_REQUIRES_AGE_CHECK => "myParcelDefaultAgeCheck",
  26.         ShippingOptionEntity::FIELD_REQUIRES_SIGNATURE => "myParcelDefaultSignature",
  27.         ShippingOptionEntity::FIELD_ONLY_RECIPIENT     => "myParcelDefaultOnlyRecipient",
  28.         ShippingOptionEntity::FIELD_RETURN_IF_NOT_HOME => "myParcelDefaultReturnNotHome",
  29.         ShippingOptionEntity::FIELD_LARGE_FORMAT       => "myParcelDefaultLargeFormat",
  30.         ShippingOptionEntity::FIELD_PACKAGE_TYPE       => "myParcelDefaultPackageType",
  31.     ];
  33.     /**
  34.      * @var LoggerInterface
  35.      */
  36.     protected $logger;
  38.     /**
  39.      * @var ConfigGenerator
  40.      */
  41.     private $configReader;
  43.     /**
  44.      * @var EntityRepository
  45.      */
  46.     private $countryRepository;
  48.     /**
  49.      * @param LoggerInterface $logger
  50.      * @param ConfigGenerator $configReader
  51.      * @param EntityRepository $countryRepository
  52.      */
  53.     public function __construct(
  54.         LoggerInterface $logger,
  55.         ConfigGenerator $configReader,
  56.         EntityRepository $countryRepository
  57.     ){
  58.         $this->logger = $logger;
  59.         $this->configReader = $configReader;
  60.         $this->countryRepository = $countryRepository;
  61.     }
  63.     /**
  64.      * @return string[]
  65.      */
  66.     public static function getSubscribedEvents()
  67.     {
  68.         return [
  69.             CartConvertedEvent::class => 'cartConverted',
  70.         ];
  71.     }
  73.     /**
  74.      * @param CartConvertedEvent $event
  75.      * @return void
  76.      */
  77.     public function cartConverted(CartConvertedEvent $event)
  78.     {
  79.         $myParcelExtension = $event->getCart()->getExtension(Defaults::CART_EXTENSION_KEY);
  80.         if (null === $myParcelExtension) {
  81.             return;
  82.         }
  83.         $myParcelData = $myParcelExtension->getVars();
  84.         $options = $this->setGeneralDefaults($event->getSalesChannelContext()->getSalesChannelId());
  86.         //Cart extension data check if it is a myparcel shipping
  87.         if (!empty($myParcelData) && !empty($myParcelData['myparcel']['deliveryData'])) {
  89.             /** @var \stdClass $deliveryData */
  90.             $deliveryData = $myParcelData['myparcel']['deliveryData'];
  91.             $deliveryData = json_decode(json_encode($deliveryData), true);
  93.             foreach ($deliveryData as $key => $value) {
  94.                 switch ($key) {
  95.                     case 'deliveryType':
  96.                         $options[ShippingOptionEntity::FIELD_DELIVERY_TYPE] = AbstractConsignment::DELIVERY_TYPES_NAMES_IDS_MAP[$value ?? 'standard'];
  97.                         break;
  99.                     case 'date':
  100.                         $strDate = \strtotime($value);
  101.                         if (!$strDate) {
  102.                             $strDate = strtotime("+1 day");
  103.                         }
  104.                         $options[ShippingOptionEntity::FIELD_DELIVERY_DATE] = \date('Y-m-d', $strDate);
  105.                         break;
  107.                     case 'shipmentOptions':
  108.                         //Check if the option was even shown via 'allowSignature' and 'allowOnlyRecipient', otherwise use the given value
  109.                         $carrierId = $deliveryData['carrier'];
  111.                         if (isset($value['only_recipient'])
  112.                             && $this->configReader->isSettingEnabled(
  113.                                 $event->getSalesChannelContext()->getSalesChannelId(),
  114.                                 'allowOnlyRecipient',
  115.                                 MyParcelCarriers::NPM_CARRIER_TO_CONFIG_CARRIER[$carrierId]
  116.                             )
  117.                         ) {
  118.                             $options[ShippingOptionEntity::FIELD_ONLY_RECIPIENT] = $value['only_recipient'];
  119.                         }
  121.                         if (isset($value['signature'])
  122.                             && $this->configReader->isSettingEnabled(
  123.                                 $event->getSalesChannelContext()->getSalesChannelId(),
  124.                                 'allowSignature',
  125.                                 MyParcelCarriers::NPM_CARRIER_TO_CONFIG_CARRIER[$carrierId]
  126.                             )
  127.                         ) {
  128.                             $options[ShippingOptionEntity::FIELD_REQUIRES_SIGNATURE] = $value['signature'];
  129.                         }
  130.                         break;
  132.                     case 'carrier':
  133.                         $options[ShippingOptionEntity::FIELD_CARRIER_ID] = Defaults::CARRIER_TO_ID[$value];
  134.                         break;
  136.                     case 'pickupLocation':
  137.                         $options[ShippingOptionEntity::FIELD_PICKUP_LOCATION_ID] = (int) $value['location_code'];
  138.                         $options[ShippingOptionEntity::FIELD_PICKUP_NAME] = $value['location_name'];
  139.                         $options[ShippingOptionEntity::FIELD_PICKUP_STREET] = $value['street'];
  140.                         $options[ShippingOptionEntity::FIELD_PICKUP_NUMBER] = $value['number'] . $value['number_suffix'];
  141.                         $options[ShippingOptionEntity::FIELD_PICKUP_POSTAL_CODE] = $value['postal_code'];
  142.                         $options[ShippingOptionEntity::FIELD_PICKUP_CITY] = $value['city'];
  143.                         $options[ShippingOptionEntity::FIELD_PICKUP_CC] = $value['cc'];
  144.                         $options[ShippingOptionEntity::FIELD_RETAIL_NETWORK_ID] = $value['retail_network_id'];
  145.                         $this->setShippingAddress($event, $options);
  146.                         break;
  147.                     case 'packageType':
  148.                         $options[ShippingOptionEntity::FIELD_PACKAGE_TYPE] = AbstractConsignment::PACKAGE_TYPES_NAMES_IDS_MAP[$value ?? 'package'];
  149.                 }
  150.             }
  151.         }
  153.         //Rest of the data will be done in OrderPlacedSubscriber, this ferries the data there
  154.         $event->setConvertedCart(array_merge($event->getConvertedCart(), ['customFields' => [Defaults::MYPARCEL_DELIVERY_OPTIONS_KEY => $options]]));
  155.     }
  157.     /**
  158.      * Sets all the defaults for values that will not be filled but the implementation of createOrUpdateShippingOptions()
  159.      * still needs.
  160.      *
  161.      * @param string $salesChannelId
  162.      * @return array
  163.      */
  164.     private function setGeneralDefaults(string $salesChannelId): array
  165.     {
  166.         $options = [];
  168.         foreach (self::SHIPPING_OPTIONS_WITH_DEFAULT as $key => $value) {
  169.             switch ($key) {
  170.                 case ShippingOptionEntity::FIELD_DELIVERY_DATE:
  171.                     $options[ShippingOptionEntity::FIELD_DELIVERY_DATE] = \date('Y-m-d', strtotime("+1 day"));
  172.                     break;
  173.                 case ShippingOptionEntity::FIELD_REQUIRES_AGE_CHECK:
  174.                     $options[ShippingOptionEntity::FIELD_REQUIRES_AGE_CHECK] = $this->configReader->getConfigBool($salesChannelId, $value);
  175.                     break;
  176.                 case ShippingOptionEntity::FIELD_REQUIRES_SIGNATURE:
  177.                     $options[ShippingOptionEntity::FIELD_REQUIRES_SIGNATURE] = $this->configReader->getConfigBool($salesChannelId, $value);
  178.                     break;
  179.                 case ShippingOptionEntity::FIELD_ONLY_RECIPIENT:
  180.                     $options[ShippingOptionEntity::FIELD_ONLY_RECIPIENT] = $this->configReader->getConfigBool($salesChannelId, $value);
  181.                     break;
  182.                 case ShippingOptionEntity::FIELD_RETURN_IF_NOT_HOME:
  183.                     $options[ShippingOptionEntity::FIELD_RETURN_IF_NOT_HOME] = $this->configReader->getConfigBool($salesChannelId, $value);
  184.                     break;
  185.                 case ShippingOptionEntity::FIELD_LARGE_FORMAT:
  186.                     $options[ShippingOptionEntity::FIELD_LARGE_FORMAT] = $this->configReader->getConfigBool($salesChannelId, $value);
  187.                     break;
  188.                 case ShippingOptionEntity::FIELD_PACKAGE_TYPE:
  189.                     $options[ShippingOptionEntity::FIELD_PACKAGE_TYPE] = $this->configReader->getConfigInt($salesChannelId, $value);
  190.                     break;
  191.             }
  192.         }
  193.         return $options;
  194.     }
  196.     /**
  197.      * @param CartConvertedEvent $event
  198.      * @param $value
  199.      * @return void
  200.      */
  201.     protected function setShippingAddress(CartConvertedEvent $event, array $options): void
  202.     {
  203.         $cart = $event->getConvertedCart();
  205.         // copy shippingOrderAddress to addresses when no separate billing address is used
  206.         $billingAddressId = $cart['billingAddressId'];
  207.         $orderAddress = $cart['deliveries'][0]['shippingOrderAddress'];
  209.         if (!isset($cart['addresses'])) {
  210.             $cart['addresses'] = [$orderAddress];
  211.         } elseif (!array_filter($cart['addresses'], function ($address) use ($billingAddressId) {
  212.             return $address['id'] === $billingAddressId;
  213.         })) {
  214.             $cart['addresses'][] = $orderAddress;
  215.         }
  217.         // find country by country code iso 2
  218.         $country = $this->countryRepository->search(
  219.             (new Criteria())->addFilter(new EqualsFilter('iso', $options[ShippingOptionEntity::FIELD_PICKUP_CC])),
  220.             $event->getSalesChannelContext()->getContext()
  221.         )->first();
  223.         // manipulate shipping address, remove id to prevent it being stored in the account
  224.         $cart['deliveries'][0]['shippingOrderAddress']['id'] = null;
  225.         $cart['deliveries'][0]['shippingOrderAddress']['company'] = $options[ShippingOptionEntity::FIELD_PICKUP_NAME];
  226.         $cart['deliveries'][0]['shippingOrderAddress']['department'] = 'pickup point';
  227.         $cart['deliveries'][0]['shippingOrderAddress']['street'] = $options[ShippingOptionEntity::FIELD_PICKUP_STREET] . ' ' . $options[ShippingOptionEntity::FIELD_PICKUP_NUMBER];
  228.         $cart['deliveries'][0]['shippingOrderAddress']['zipcode'] = $options[ShippingOptionEntity::FIELD_PICKUP_POSTAL_CODE];
  229.         $cart['deliveries'][0]['shippingOrderAddress']['city'] = $options[ShippingOptionEntity::FIELD_PICKUP_CITY];
  230.         if (isset($country)) {
  231.             $cart['deliveries'][0]['shippingOrderAddress']['countryId'] = $country->getId();
  232.         }
  233.         $event->setConvertedCart($cart);
  234.     }
  235. }