custom/plugins/ShopsyKlaviyo6/src/Subscriber/Subscriber.php line 92

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopsy\ShopsyKlaviyo\Subscriber;
  5. use Frosh\ShareBasket\Services\ShareBasketServiceInterface;
  6. use KlaviyoAPI\KlaviyoAPI;
  7. use Shopsy\ShopsyKlaviyo\Service\DalService;
  8. use Shopsy\ShopsyKlaviyo\Service\KlaviyoEventService;
  9. use Shopware\Core\Checkout\Cart\Cart;
  10. use Shopware\Core\Checkout\Cart\Event\AfterLineItemAddedEvent;
  11. use Shopware\Core\Checkout\Cart\LineItem\LineItem;
  12. use Shopware\Core\Checkout\Order\Aggregate\OrderCustomer\OrderCustomerEntity;
  13. use Shopware\Core\Checkout\Order\Aggregate\OrderLineItem\OrderLineItemEntity;
  14. use Shopware\Core\Checkout\Order\Event\OrderStateMachineStateChangeEvent;
  15. use Shopware\Core\Checkout\Order\OrderDefinition;
  16. use Shopware\Core\Checkout\Order\OrderEntity;
  17. use Shopware\Core\Checkout\Order\OrderEvents;
  18. use Shopware\Core\Content\Newsletter\NewsletterEvents;
  19. use Shopware\Core\Content\Product\ProductEntity;
  20. use Shopware\Core\Defaults;
  21. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  22. use Shopware\Core\Framework\Event\ShopwareSalesChannelEvent;
  23. use Shopware\Core\Framework\Struct\ArrayEntity;
  24. use Shopware\Core\System\SalesChannel\SalesChannelEntity;
  25. use Shopware\Core\System\SystemConfig\SystemConfigService;
  26. use Shopware\Storefront\Event\StorefrontRenderEvent;
  27. use Shopware\Storefront\Page\Checkout\Finish\CheckoutFinishPageLoadedEvent;
  28. use Shopware\Storefront\Page\Page;
  29. use Shopware\Storefront\Page\Product\ProductPage;
  30. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  31. use Symfony\Component\HttpFoundation\RequestStack;
  33. class Subscriber implements EventSubscriberInterface
  34. {
  35.     /**
  36.      * @var SystemConfigService
  37.      */
  38.     private $systemConfigService;
  40.     /**
  41.      * @var RequestStack
  42.      */
  43.     private $requestStack;
  45.     /**
  46.      * @var DalService $dalService
  47.      */
  48.     private $dalService;
  50.     /**
  51.      * @var KlaviyoEventService $klaviyoEventService
  52.      */
  53.     private $klaviyoEventService;
  55.     /**
  56.      * @var ShareBasketServiceInterface $shareBasketService
  57.      */
  58.     private $shareBasketService;
  60.     public function __construct(
  61.         SystemConfigService $systemConfigService,
  62.         RequestStack $requestStack,
  63.         DalService $dalService,
  64.         KlaviyoEventService $klaviyoEventService,
  65.         $shareBasketService = null
  66.     ) {
  67.         $this->systemConfigService = $systemConfigService;
  68.         $this->requestStack = $requestStack;
  69.         $this->dalService = $dalService;
  70.         $this->klaviyoEventService = $klaviyoEventService;
  71.         $this->shareBasketService = $shareBasketService;
  72.     }
  74.     public static function getSubscribedEvents(): array
  75.     {
  76.         return [
  77.             StorefrontRenderEvent::class => 'onStorefrontRender',
  78.             OrderEvents::ORDER_WRITTEN_EVENT => 'onOrderWritten',
  79.             CheckoutFinishPageLoadedEvent::class => 'onOrderPlaced',
  80.             NewsletterEvents::NEWSLETTER_RECIPIENT_WRITTEN_EVENT => 'onNewsletterWritten',
  81.             AfterLineItemAddedEvent::class => 'onAfterLineItemAdd',
  82.             'state_enter.order_transaction.state.paid' => 'onOrderStateChanged',
  83.             'state_enter.order_delivery.state.shipped' => 'onOrderStateChanged',
  84.             'state_enter.order_transaction.state.cancelled' => 'onOrderStateChanged',
  85.             'state_enter.order_transaction.state.refunded' => 'onOrderStateChanged'
  86.         ];
  87.     }
  89.     /**
  90.      * @param EntityWrittenEvent $event
  91.      */
  92.     public function onNewsletterWritten(EntityWrittenEvent $event)
  93.     {
  94.         $payload = $event->getWriteResults()[0]->getPayload();
  96.         if($payload['email'] == '') {
  97.             return;
  98.         }
  100.         $salesChannelId = $payload['salesChannelId'] ?? $event->getContext()->getSource()->getSalesChannelId();
  101.         if($this->systemConfigService->get('ShopsyKlaviyo6.config.klaviyoPrivateApiKey', $salesChannelId) == '') {
  102.             return;
  103.         }
  105.         $klaviyo = new KlaviyoAPI($this->systemConfigService->get('ShopsyKlaviyo6.config.klaviyoPrivateApiKey', $salesChannelId), 3, 2, [], 'ShopwareHostedSync/Shopsy/6');
  107.         if($klaviyo->api_key == '') {
  108.             return;
  109.         }
  111.         $salesChannel = $this->dalService->getSalesChannel($salesChannelId, $event->getContext());
  112.         $klaviyoListId = $this->getKlaviyoList($klaviyo, $salesChannel);
  114.         if($klaviyoListId == '') {
  115.             return;
  116.         }
  118.         //unsubscribe remove from newsletter list
  119.         if(isset($payload['status']) && $payload['status'] == 'optOut') {
  120.             $unsubscribeProfile = array(
  121.                 'data' => array(
  122.                     'type' => 'profile-subscription-bulk-delete-job',
  123.                     'attributes' => array(
  124.                         'profiles' => array(
  125.                             'data' => [
  126.                                 array(
  127.                                     'type' => 'profile',
  128.                                     'attributes' => array(
  129.                                         'email' => $payload['email']
  130.                                     )
  131.                                 )
  132.                             ]
  133.                         )
  134.                     ),
  135.                     'relationships' => array(
  136.                         'list' => array(
  137.                             'data' => array(
  138.                                 'type' => 'list',
  139.                                 'id' => $klaviyoListId
  140.                             )
  141.                         )
  142.                     )
  143.                 )
  144.             );
  145.             try {
  146.                 $klaviyo->Profiles->unsubscribeProfiles($unsubscribeProfile);
  147.             }catch (\Exception $ex) {}
  148.         }
  149.         else {
  150.             //check if email is already in list
  151.             $filter = 'any(email,["' . $payload['email']. '"])';
  152.             $newsletterProfile = $klaviyo->Lists->getListProfiles($klaviyoListId, null, null, $filter, null, 1);
  154.             if (count($newsletterProfile['data']) > 0 && isset($newsletterProfile[0]['id']) && $newsletterProfile[0]['id'] != '') {
  155.                 return;
  156.             }
  158.             //subscribe add to newsletter list
  159.             $newsletterProfileBody = array(
  160.                 'data' => array(
  161.                     'type' => 'profile-subscription-bulk-create-job',
  162.                     'attributes' => array(
  163.                         'profiles' => array(
  164.                             'data' => array(
  165.                                 array(
  166.                                     'type' => 'profile',
  167.                                     'attributes' => array(
  168.                                         'email' => $payload['email'],
  169.                                         'subscriptions' => array(
  170.                                             "email" => array(
  171.                                                 'marketing' => array(
  172.                                                     'consent' => 'SUBSCRIBED'
  173.                                                 )
  174.                                             )
  175.                                         )
  176.                                     )
  177.                                 )
  178.                             )
  179.                         )
  180.                     ),
  181.                     'relationships' => array(
  182.                         'list' => array(
  183.                             'data' => array(
  184.                                 'type' => 'list',
  185.                                 'id' => $klaviyoListId
  186.                             )
  187.                         )
  188.                     )
  189.                 )
  190.             );
  192.             try {
  193.                 $klaviyo->Profiles->subscribeProfiles($newsletterProfileBody);
  194.             }catch (\Exception $ex) {}
  195.         }
  196.     }
  198.     /**
  199.      * @param StorefrontRenderEvent $event
  200.      * @return void
  201.      */
  202.     public function onStorefrontRender(StorefrontRenderEvent $event): void
  203.     {
  204.         $shopId = $event->getSalesChannelContext()->getSalesChannel()->getId();
  205.         if($this->systemConfigService->get('ShopsyKlaviyo6.config.klaviyoApiKey', $shopId) == ''
  206.             && $this->systemConfigService->get('ShopsyKlaviyo6.config.klaviyoPrivateApiKey', $shopId) == '') {
  207.             return;
  208.         }
  210.         if(!isset($event->getParameters('page')['page'])) {
  211.             return;
  212.         }
  214.         $page = $event->getParameters('page')['page'];
  216.         $customer = $event->getSalesChannelContext()->getCustomer();
  218.         $controllerData = $this->getCurrentController();
  220.         if($controllerData[1] === 'Affiliate') {
  221.             return;
  222.         }
  224.         if($event->getRequest()->get('backInStockSuccess')) {
  225.             $page->assign([
  226.                 'backInStockSuccess' => true
  227.             ]);
  228.         }
  230.         if($page instanceof ProductPage) {
  231.             $page->assign([
  232.                 'backInStock' => $this->systemConfigService->get('ShopsyKlaviyo6.config.backInStock', $shopId)
  233.             ]);
  234.         }
  236.         $category = '';
  237.         if ($controllerData[1] == 'Product') {
  238.             $pageData = $event->getParameters('page');
  240.             if (is_array($pageData) && array_key_exists('page', $pageData)) {
  241.                 $productPage = $pageData['page'];
  243.                 if ($productPage instanceof ProductPage) {
  244.                     $productEntity = $productPage->getProduct();
  245.                     if ($productEntity && $productEntity instanceof ProductEntity) {
  246.                         $category = $this->dalService->getCategory($productEntity->getCategoryTree(), $event->getContext());
  247.                     }
  249.                 }
  250.             }
  251.         }
  252.         if($controllerData[1] == 'Register' && $controllerData[2] == 'checkoutRegisterPage') {
  253.             $this->setKlaviyoCartItemExtension($event->getParameters()['page']->getCart(), $shopId, $event);
  254.         }
  256.         if(!$customer) {
  257.             if($page instanceof Page) {
  258.                 $salesChannel = $this->dalService->getSalesChannel($event->getSalesChannelContext()->getSalesChannelId(), $event->getContext());
  260.                 $page->assign([
  261.                     'shopsyKlaviyo' => [
  262.                         'apiKey' => $this->systemConfigService->get('ShopsyKlaviyo6.config.klaviyoApiKey', $shopId),
  263.                         'cookieRequired' => $this->systemConfigService->get('ShopsyKlaviyo6.config.cookieRequired', $shopId),
  264.                         'trackingMethod' => $this->systemConfigService->get('ShopsyKlaviyo6.config.trackingMethod', $shopId),
  265.                         'category' => $category,
  266.                         'salesChannel' => $salesChannel->getName()
  267.                     ]
  268.                 ]);
  269.             }
  271.             return;
  272.         }
  274.         $customer->setGroup($event->getSalesChannelContext()->getCurrentCustomerGroup());
  276.         if($customer->getBirthday() == '') {
  277.             $customerBirthday = null;
  278.         }
  279.         else {
  280.             $customerBirthday = $customer->getBirthday()->format("m/d/Y");
  281.         }
  283.         if($customer->getNewsletter() == '') {
  284.             $newsletter = 0;
  285.         }
  286.         else {
  287.             $newsletter = 1;
  288.         }
  290.         $checkOutURL = '';
  291.         if($controllerData[1] == 'Product' && $controllerData[2] == 'index'
  292.             && $this->systemConfigService->get('ShopsyKlaviyo6.config.trackingMethod', $shopId) == 'serverSide' && !$event->getRequest()->get('backInStockSuccess')) {
  293.             if (isset($event->getParameters('page')['page'])) {
  294.                 if(!method_exists($event->getParameters('page')['page'], 'getProduct')) {
  295.                     return;
  296.                 }
  297.                 /** @var ProductEntity $product */
  298.                 $product = $event->getParameters('page')['page']->getProduct();
  300.                 if($product) {
  301.                     $category = $this->dalService->getCategory($product->getCategoryTree(), $event->getContext());
  302.                 }
  304.                 $klaviyo = new KlaviyoAPI($this->systemConfigService->get('ShopsyKlaviyo6.config.klaviyoPrivateApiKey', $shopId), 3, 2, [], 'ShopwareHostedSync/Shopsy/6');
  306.                 if($klaviyo->api_key == '') {
  307.                     return;
  308.                 }
  310.                 $this->klaviyoEventService->trackViewedProduct($klaviyo, $customer, $customerBirthday, $newsletter, $product, $category);
  311.             }
  312.         }
  313.         elseif($controllerData[1] == 'Checkout' && $controllerData[2] == 'confirmPage') {
  314.             $this->setKlaviyoCartItemExtension($event->getParameters()['page']->getCart(), $shopId, $event);
  316.             // Plugin "ShareBasket" from "Friends of Shopware" needed!
  317.             if($this->shareBasketService != null) {
  318.                 $data = $this->shareBasketService->prepareLineItems($event->getSalesChannelContext());
  319.                 $checkOutURL = $this->shareBasketService->saveCart($data, $event->getSalesChannelContext());
  320.             }
  322.             if($this->systemConfigService->get('ShopsyKlaviyo6.config.trackingMethod', $shopId) == 'serverSide') {
  323.                 $klaviyo = new KlaviyoAPI($this->systemConfigService->get('ShopsyKlaviyo6.config.klaviyoPrivateApiKey', $shopId), 3, 2, [], 'ShopwareHostedSync/Shopsy/6');
  325.                 if($klaviyo->api_key == '') {
  326.                     return;
  327.                 }
  329.                 $cart = $event->getParameters()['page']->getCart();
  330.                 if($cart) {
  331.                     $excludeTypes = explode(';', $this->systemConfigService->get('ShopsyKlaviyo6.config.excludeType', $shopId));
  333.                     $this->klaviyoEventService->trackStartedCheckout($klaviyo, $customer, $customerBirthday, $newsletter, $cart, $excludeTypes, $event, $checkOutURL);
  334.                 }
  335.             }
  336.         }
  337.         elseif($controllerData[1] == 'Checkout' && $controllerData[2] == 'finishPage') {
  338.             if (method_exists($event->getParameters('page')['page'], 'getOrder')) {
  339.                 /** @var OrderEntity $order */
  340.                 $order = $event->getParameters('page')['page']->getOrder();
  341.                 $excludeTypes = explode(';', $this->systemConfigService->get('ShopsyKlaviyo6.config.excludeType', $shopId));
  343.                 /** @var OrderLineItemEntity $lineItem */
  344.                 foreach ($order->getLineItems() as $lineItem) {
  345.                     if (!in_array($lineItem->getType(), $excludeTypes)) {
  346.                         if(array_key_exists('categoryIds', $lineItem->getPayload())) {
  347.                             $category = $this->dalService->getCategory($lineItem->getPayload()['categoryIds'], $event->getContext());
  348.                         }
  349.                         else {
  350.                             $category = null;
  351.                         }
  352.                         $manufacturer = $this->dalService->getManufacturer($lineItem->getProductId(), $event->getContext());
  353.                         $productUrl = $this->dalService->getProductUrl(
  354.                             $lineItem->getProductId(),
  355.                             $event->getSalesChannelContext()->getSalesChannel()->getDomains()->first()->getUrl()
  356.                         );
  358.                         $shopsyKlaviyoExtension = [
  359.                             'category' => $category,
  360.                             'manufacturer' => $manufacturer,
  361.                             'productUrl' => $productUrl
  362.                         ];
  364.                         $lineItem->addExtension('shopsyKlaviyo', new ArrayEntity($shopsyKlaviyoExtension));
  365.                     }
  366.                 }
  367.             }
  368.         }
  370.         $salesChannel = $this->dalService->getSalesChannel($event->getSalesChannelContext()->getSalesChannelId(), $event->getContext());
  371.         $page->assign([
  372.             'shopsyKlaviyo' => [
  373.                 'apiKey' => $this->systemConfigService->get('ShopsyKlaviyo6.config.klaviyoApiKey', $shopId),
  374.                 'cookieRequired' => $this->systemConfigService->get('ShopsyKlaviyo6.config.cookieRequired', $shopId),
  375.                 'trackingMethod' => $this->systemConfigService->get('ShopsyKlaviyo6.config.trackingMethod', $shopId),
  376.                 'birthday' => $customerBirthday,
  377.                 'phoneNumber' => $customer->getActiveBillingAddress()->getPhoneNumber(),
  378.                 'customerGroup' => $customer->getGroup()->getName(),
  379.                 'newsletter' => $newsletter,
  380.                 'category' => $category,
  381.                 'salesChannel' => $salesChannel->getName(),
  382.                 'checkOutURL' => $checkOutURL
  383.             ]
  384.         ]);
  385.     }
  387.     /**
  388.      * @param CheckoutFinishPageLoadedEvent $event
  389.      * @return void
  390.      */
  391.     public function onOrderPlaced(CheckoutFinishPageLoadedEvent $event)
  392.     {
  393.         $order = $event->getPage()->getOrder();
  394.         $shopId = $event->getSalesChannelContext()->getSalesChannelId();
  396.         if ($this->systemConfigService->get('ShopsyKlaviyo6.config.trackingMethod', $shopId) == 'serverSide') {
  397.             $excludeTypes = explode(';', $this->systemConfigService->get('ShopsyKlaviyo6.config.excludeType', $shopId));
  399.             foreach ($order->getLineItems() as $lineItem) {
  400.                 if (!in_array($lineItem->getType(), $excludeTypes)) {
  401.                     if (array_key_exists('categoryIds', $lineItem->getPayload())) {
  402.                         $category = $this->dalService->getCategory($lineItem->getPayload()['categoryIds'], $event->getContext());
  403.                     } else {
  404.                         $category = null;
  405.                     }
  406.                     $manufacturer = $this->dalService->getManufacturer($lineItem->getProductId(), $event->getContext());
  407.                     $productUrl = $this->dalService->getProductUrl(
  408.                         $lineItem->getProductId(),
  409.                         ''
  410.                     );
  412.                     $shopsyKlaviyoExtension = [
  413.                         'category' => $category,
  414.                         'manufacturer' => $manufacturer,
  415.                         'productUrl' => $productUrl
  416.                     ];
  418.                     $lineItem->addExtension('shopsyKlaviyo', new ArrayEntity($shopsyKlaviyoExtension));
  419.                 }
  420.             }
  423.             $klaviyo = new KlaviyoAPI($this->systemConfigService->get('ShopsyKlaviyo6.config.klaviyoPrivateApiKey', $shopId), 3, 2, [], 'ShopwareHostedSync/Shopsy/6');
  425.             if ($klaviyo->api_key == '') {
  426.                 return;
  427.             }
  429.             if ($event->getPage()->getOrder()->getOrderCustomer()->getCustomer()->getBirthday() == '') {
  430.                 $customerBirthday = null;
  431.             } else {
  432.                 $customerBirthday = $event->getPage()->getOrder()->getOrderCustomer()->getCustomer()->getBirthday()->format("m/d/Y");
  433.             }
  435.             $this->klaviyoEventService->trackCheckoutCompleted($klaviyo, $event->getPage()->getOrder()->getOrderCustomer()->getCustomer(), $customerBirthday, $event->getPage()->getOrder()->getOrderCustomer()->getCustomer()->getNewsletter(), $order, $excludeTypes, $event);
  436.         }
  437.     }
  439.     /**
  440.      * @param EntityWrittenEvent $event
  441.      */
  442.     public function onOrderWritten(EntityWrittenEvent $event): void
  443.     {
  444.         if ($event->getEntityName() !== OrderDefinition::ENTITY_NAME
  445.             || $event->getWriteResults()[0]->getOperation() ==='update') {
  446.             return;
  447.         }
  449.         $versionId = $event->getWriteResults()[0]->getPayload()['versionId'];
  450.         if($versionId !== Defaults::LIVE_VERSION) {
  451.             return;
  452.         }
  455.         $shopId = $event->getWriteResults()[0]->getPayload()['salesChannelId'];
  456.         if($this->systemConfigService->get('ShopsyKlaviyo6.config.klaviyoApiKey', $shopId) == ''
  457.             && $this->systemConfigService->get('ShopsyKlaviyo6.config.klaviyoPrivateApiKey', $shopId) == '') {
  458.             return;
  459.         }
  461.         $klaviyo = new KlaviyoAPI($this->systemConfigService->get('ShopsyKlaviyo6.config.klaviyoPrivateApiKey', $shopId), 3, 2, [], 'ShopwareHostedSync/Shopsy/6');
  463.         if($klaviyo->api_key == '') {
  464.             return;
  465.         }
  467.         /** @var OrderCustomerEntity $customer */
  468.         $customer = $this->dalService->getCustomer($event->getPayloads()[0]['id'], $event->getContext());
  470.         $lineItems = $this->dalService->getLineItems($event->getPayloads()[0]['id'], $event->getContext());
  471.         $excludeTypes = explode(';', $this->systemConfigService->get('ShopsyKlaviyo6.config.excludeType', $shopId));
  473.         /** @var OrderLineItemEntity $lineItem */
  474.         foreach ($lineItems as $lineItem) {
  475.             if(!in_array($lineItem->getType(), $excludeTypes)) {
  476.                 $category = $this->dalService->getCategory($lineItem->getProduct()->getCategoryTree(), $event->getContext());
  478.                 if ($this->systemConfigService->get('ShopsyKlaviyo6.config.trackOrderedProduct', $shopId)) {
  479.                     $this->klaviyoEventService->trackOrderedProduct($klaviyo, $customer, $lineItem, $category,
  480.                         $event->getContext(), $event);
  481.                 }
  482.             }
  483.         }
  485.         if($this->systemConfigService->get('ShopsyKlaviyo6.config.trackPlacedOrder', $shopId)) {
  486.             $this->klaviyoEventService->trackPlacedOrder($klaviyo, $lineItems, $excludeTypes, $customer, $event->getContext(), $event, $this->systemConfigService->get('ShopsyKlaviyo6.config.trackPlacedOrderExtraData', $shopId));
  487.         }
  488.     }
  490.     /**
  491.      * @param OrderStateMachineStateChangeEvent $event
  492.      */
  493.     public function onOrderStateChanged(OrderStateMachineStateChangeEvent $event): void
  494.     {
  495.         $context = $event->getContext();
  496.         $salesChannel = $event->getSalesChannelId();
  498.         if($this->systemConfigService->get('ShopsyKlaviyo6.config.klaviyoApiKey', $salesChannel) == ''
  499.             && $this->systemConfigService->get('ShopsyKlaviyo6.config.klaviyoPrivateApiKey', $salesChannel) == '') {
  500.             return;
  501.         }
  503.         $klaviyo = new KlaviyoAPI($this->systemConfigService->get('ShopsyKlaviyo6.config.klaviyoPrivateApiKey', $salesChannel), 3, 2, [], 'ShopwareHostedSync/Shopsy/6');
  505.         if($klaviyo->api_key == '') {
  506.             return;
  507.         }
  509.         $order = $this->dalService->getOrder($event->getOrder()->getId());
  510.         $excludeTypes = explode(';', $this->systemConfigService->get('ShopsyKlaviyo6.config.excludeType', $salesChannel));
  512.         $orderCustomFields = $order->getCustomFields();
  513.         if($event->getName() == 'state_enter.order_delivery.state.shipped' && (!isset($orderCustomFields) || !isset($orderCustomFields['shopsy_klaviyo_tracked_fulfilled_order']) || $orderCustomFields['shopsy_klaviyo_tracked_fulfilled_order'] == 0)) {
  514.             if($this->systemConfigService->get('ShopsyKlaviyo6.config.trackFulfilledOrder', $salesChannel)) {
  515.                 $this->klaviyoEventService->trackFulfilledOrder($klaviyo, $order, $excludeTypes, $context);
  516.                 $this->dalService->setShopsyKlaviyoTrackedFulfilledOrder($order->getId());
  517.             }
  518.         }
  520.         if($event->getName() == 'state_enter.order_transaction.state.paid' && (!isset($orderCustomFields) || !isset($orderCustomFields['shopsy_klaviyo_tracked_purchased_items']) || $orderCustomFields['shopsy_klaviyo_tracked_purchased_items'] == 0)) {
  521.             if($this->systemConfigService->get('ShopsyKlaviyo6.config.trackPurchasedItems', $salesChannel)) {
  522.                 $this->klaviyoEventService->trackPurchasedItems($klaviyo, $order, $excludeTypes, $context);
  523.                 $this->dalService->setShopsyKlaviyoTrackPurchasedItemsOrder($order->getId());
  524.             }
  525.         }
  527.         if($event->getName() == 'state_enter.order_transaction.state.cancelled' && (!isset($orderCustomFields) || !isset($orderCustomFields['shopsy_klaviyo_tracked_cancelled_order']) || $orderCustomFields['shopsy_klaviyo_tracked_cancelled_order'] == 0)) {
  528.             if($this->systemConfigService->get('ShopsyKlaviyo6.config.trackCancelledOrder', $salesChannel)) {
  529.                 $this->klaviyoEventService->trackCancelledOrder($klaviyo, $order, $excludeTypes, $context);
  530.                 $this->dalService->setShopsyKlaviyoTrackedCancelledOrder($order->getId());
  531.             }
  532.         }
  534.         if($event->getName() == 'state_enter.order_transaction.state.refunded' && (!isset($orderCustomFields) || !isset($orderCustomFields['shopsy_klaviyo_tracked_refunded_order']) || $orderCustomFields['shopsy_klaviyo_tracked_refunded_order'] == 0)) {
  535.             if($this->systemConfigService->get('ShopsyKlaviyo6.config.trackRefundedOrder', $salesChannel)) {
  536.                 $this->klaviyoEventService->trackRefundedOrder($klaviyo, $order, $excludeTypes, $context);
  537.                 $this->dalService->setShopsyKlaviyoTrackedRefundedOrder($order->getId());
  538.             }
  539.         }
  540.     }
  542.     /**
  543.      * @param ShopwareSalesChannelEvent $event
  544.      * @return void
  545.      */
  546.     public function onAfterLineItemAdd(ShopwareSalesChannelEvent $event)
  547.     {
  548.         $shopId = $event->getSalesChannelContext()->getSalesChannel()->getId();
  550.         if($this->systemConfigService->get('ShopsyKlaviyo6.config.trackingMethod', $shopId) == 'serverSide') {
  551.             $customer = $event->getSalesChannelContext()->getCustomer();
  553.             if(!$customer) {
  554.                 return;
  555.             }
  557.             $customer->setGroup($event->getSalesChannelContext()->getCurrentCustomerGroup());
  559.             if ($event->getLineItems()[0]) {
  560.                 $excludeTypes = explode(';', $this->systemConfigService->get('ShopsyKlaviyo6.config.excludeType', $shopId));
  562.                 /** @var LineItem $lineItem */
  563.                 $lineItem = $event->getLineItems()[0];
  565.                 if(!in_array($lineItem->getType(), $excludeTypes) && $lineItem->getLabel() != '') {
  566.                     $category = '';
  567.                     if(isset($lineItem->getPayload()['categoryIds'])) {
  568.                         $category = $this->dalService->getCategory($lineItem->getPayload()['categoryIds'], $event->getContext());
  569.                     }
  571.                     $klaviyo = new KlaviyoAPI($this->systemConfigService->get('ShopsyKlaviyo6.config.klaviyoPrivateApiKey', $shopId), 3, 2, [], 'ShopwareHostedSync/Shopsy/6');
  573.                     if ($klaviyo->api_key == '') {
  574.                         return;
  575.                     }
  577.                     $customer = $event->getSalesChannelContext()->getCustomer();
  578.                     if($customer->getBirthday() == '') {
  579.                         $customerBirthday = null;
  580.                     }
  581.                     else {
  582.                         $customerBirthday = $customer->getBirthday()->format("m/d/Y");
  583.                     }
  585.                     if($customer->getNewsletter() == '') {
  586.                         $newsletter = 0;
  587.                     }
  588.                     else {
  589.                         $newsletter = 1;
  590.                     }
  592.                     $this->klaviyoEventService->trackAddedToCart($klaviyo, $customer, $customerBirthday, $newsletter, $lineItem, $category);
  593.                 }
  594.             }
  595.         }
  596.     }
  598.     /**
  599.      * @return array|false
  600.      */
  601.     private function getCurrentController()
  602.     {
  603.         $controllerData = [];
  604.         $currentRequest = $this->requestStack->getCurrentRequest();
  605.         $currentController = $currentRequest->attributes->get('_controller');
  607.         if(!$currentController) {
  608.             return false;
  609.         }
  611.         preg_match('/Controller\\\\(\w+)Controller::?(\w+)$/', $currentController, $controllerData);
  613.         return $controllerData;
  614.     }
  616.     /**
  617.      * @param $cart
  618.      * @param $shopId
  619.      * @param $event
  620.      */
  621.     private function setKlaviyoCartItemExtension($cart, $shopId, $event) {
  622.         /** @var Cart $cart */
  623.         $excludeTypes = explode(';', $this->systemConfigService->get('ShopsyKlaviyo6.config.excludeType', $shopId));
  625.         /** @var LineItem $lineItem */
  626.         foreach ($cart->getLineItems() as $lineItem) {
  627.             if(!in_array($lineItem->getType(), $excludeTypes)) {
  628.                 $category = $this->dalService->getCategory($lineItem->getPayloadValue('categoryIds'), $event->getContext());
  629.                 $productUrl = $this->dalService->getProductUrl(
  630.                     $lineItem->getId(),
  631.                     $event->getSalesChannelContext()->getSalesChannel()->getDomains()->first()->getUrl()
  632.                 );
  634.                 $shopsyKlaviyoExtension = [
  635.                     'category' => $category,
  636.                     'productUrl' => $productUrl
  637.                 ];
  639.                 $lineItem->addExtension('shopsyKlaviyo', new ArrayEntity($shopsyKlaviyoExtension));
  640.             }
  641.         }
  642.     }
  644.     /**
  645.      * @param KlaviyoAPI $klaviyo
  646.      * @param SalesChannelEntity $salesChannel
  647.      * @return mixed|string
  648.      */
  649.     private function getKlaviyoList(KlaviyoAPI $klaviyo, SalesChannelEntity $salesChannel) {
  650.         //get klaviyo newsletter list depending on saleschannel name
  651.         $listName = 'Shopware_Newsletter_' . $salesChannel->getTranslated()['name'];
  652.         $filter = 'equals(name,"' . $listName . '")';
  654.         $klaviyoList = $klaviyo->Lists->getLists(null, null, $filter, 'tags', null);
  655.         if(count($klaviyoList['data']) > 0) {
  656.             $klaviyoListId = '';
  657.             if($klaviyoList['data'][0]['type'] == 'list' && $klaviyoList['data'][0]['attributes']['name'] == 'Shopware_Newsletter_' . $salesChannel->getTranslated()['name']) {
  658.                 return $klaviyoList['data'][0]['id'];
  659.             }
  661.             //create new newsletterlist in Klaviyo
  662.             if($klaviyoListId == '') {
  663.                 $newsletterList = array(
  664.                     'data' => array(
  665.                         'type' => 'list',
  666.                         'attributes' => array(
  667.                             'name' => 'Shopware_Newsletter_' . $salesChannel->getTranslated()['name']
  668.                         )
  669.                     )
  670.                 );
  672.                 $newKlaviyoList = $klaviyo->Lists->createList($newsletterList);
  674.                 if(isset($newKlaviyoList['data']['id'])) {
  675.                     return $newKlaviyoList['data']['id'];
  676.                 }
  677.             }
  678.         }
  679.         else {
  680.             //create new newsletterlist in Klaviyo
  681.             $newsletterList = array(
  682.                 'data' => array(
  683.                     'type' => 'list',
  684.                     'attributes' => array(
  685.                         'name' => 'Shopware_Newsletter_' . $salesChannel->getTranslated()['name']
  686.                     )
  687.                 )
  688.             );
  690.             $newKlaviyoList = $klaviyo->Lists->createList($newsletterList);
  692.             if(isset($newKlaviyoList['data']['id'])) {
  693.                 return $newKlaviyoList['data']['id'];
  694.             }
  695.         }
  697.         return '';
  698.     }
  699. }