src/WellCommerce/Bundle/EmarsysBundle/EventListener/EmarsysSubscriber.php line 38

Open in your IDE?
  1. <?php
  2. declare(strict_types=0);
  3. /*
  4.  * WellCommerce Foundation
  5.  *
  6.  * This file is part of the WellCommerce package.
  7.  *
  8.  * (c) Adam Piotrowski <adam@wellcommerce.org>, Adrian Potepa <adrian@wellcommerce.org>
  9.  *
  10.  * For the full copyright and license information,
  11.  * please view the LICENSE file that was distributed with this source code.
  12.  */
  14. namespace WellCommerce\Bundle\EmarsysBundle\EventListener;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. use WellCommerce\Bundle\AppBundle\Entity\NewsletterSubscriber;
  18. use WellCommerce\Bundle\AppBundle\Entity\Shop;
  19. use WellCommerce\Bundle\CoreBundle\Doctrine\Event\EntityEvent;
  20. use WellCommerce\Bundle\EmarsysBundle\Client\EmarsysClient;
  21. use WellCommerce\Component\Form\Event\FormEvent;
  23. /**
  24.  * Class EmarsysSubscriber
  25.  *
  26.  * @package WellCommerce\Bundle\EmarsysBundle\EventListener
  27.  */
  28. class EmarsysSubscriber implements EventSubscriberInterface
  29. {
  30.     public static function getSubscribedEvents()
  31.     {
  32.         return [
  33.             'admin.shop.pre_form_init'          => ['onShopFormAdminInit'],
  34.             'newsletter_subscriber.post_update' => ['onNewsletterSubscriberPostCreate'],
  35.         ];
  36.     }
  38.     public function onNewsletterSubscriberPostCreate(EntityEvent $event)
  39.     {
  40.         /** @var NewsletterSubscriber $resource */
  41.         $resource  = $event->getEntity();
  42.         $shop      = $resource->getShop();
  43.         $triggerId = (int) $shop->getEmarsysTriggerId();
  45.         if ($resource instanceof NewsletterSubscriber) {
  46.             if ($resource->isEnabled()) {
  47.                 $email = $resource->getEmail();
  49.                 $listId = (int) $shop->getEmarsysContactListId();
  51.                 if ($this->isClientEnabled($shop)) {
  52.                     $api = $this->createApiClient($shop);
  53.                     $sex = '';
  54.                     if ($resource->getSex() === 'm') {
  55.                         $sex = 1;
  56.                     }
  57.                     if ($resource->getSex() === 'f') {
  58.                         $sex = 2;
  59.                     }
  61.                     $api->send('POST', 'contact', json_encode([
  62.                         'key_id' => 3,
  63.                         '1'      => $resource->getFirstName(),
  64.                         '3'      => $email,
  65.                         '46'     => $sex,
  66.                     ]));
  68.                     $eventResult = $api->send('POST', 'event/' . $triggerId . '/trigger', json_encode([
  69.                         'key_id'      => 3,
  70.                         'external_id' => $email,
  71.                     ]));
  73.                     if ($listId > 0) {
  74.                         $api->send('POST', 'contactlist/' . $listId . '/add', json_encode([
  75.                             'key_id'       => 3,
  76.                             'external_ids' => [$email],
  77.                         ]));
  78.                     }
  79.                 }
  80.             }
  82.             if (false === $resource->isEnabled()) {
  83.                 $email = $resource->getEmail();
  85.                 if ($this->isClientEnabled($shop)) {
  86.                     $api = $this->createApiClient($shop);
  87.                     $api->send('POST', 'contact/delete', json_encode([
  88.                         '3' => $email,
  89.                     ]));
  90.                 }
  91.             }
  92.         }
  93.     }
  95.     public function onShopFormAdminInit(FormEvent $event)
  96.     {
  97.         $resource = $event->getResource();
  98.         if ($resource instanceof Shop) {
  99.             $form    = $event->getForm();
  100.             $builder = $event->getFormBuilder();
  102.             $emarsysData = $form->addChild($builder->getElement('nested_fieldset', [
  103.                 'name'  => 'emarsys_data',
  104.                 'label' => 'emarsys.fieldset.settings',
  105.             ]));
  107.             $emarsysData->addChild($builder->getElement('text_field', [
  108.                 'name'  => 'emarsysApiKey',
  109.                 'label' => 'emarsys.label.api_key',
  110.             ]));
  112.             $emarsysData->addChild($builder->getElement('text_field', [
  113.                 'name'  => 'emarsysApiSecret',
  114.                 'label' => 'emarsys.label.api_secret',
  115.             ]));
  117.             $emarsysData->addChild($builder->getElement('text_field', [
  118.                 'name'  => 'emarsysContactListId',
  119.                 'label' => 'ID listy kontaktów',
  120.             ]));
  122.             $emarsysData->addChild($builder->getElement('text_field', [
  123.                 'name'  => 'emarsysTriggerId',
  124.                 'label' => 'ID triggera',
  125.             ]));
  126.         }
  127.     }
  129.     private function createApiClient(Shop $shop): EmarsysClient
  130.     {
  131.         $username = $shop->getEmarsysApiKey();
  132.         $secret   = $shop->getEmarsysApiSecret();
  134.         return new EmarsysClient($username, $secret);
  135.     }
  137.     private function isClientEnabled(Shop $shop): bool
  138.     {
  139.         return strlen($shop->getEmarsysApiKey()) > 0 && strlen($shop->getEmarsysApiSecret()) > 0;
  140.     }
  141. }