src/ConnectBundle/EventListener/ObjectListener.php line 45

Open in your IDE?
  1. <?php
  3. /**
  4.  * CONNECT BUNDLE
  5.  * Copyright © 2019 onacy GmbH
  6.  *
  7.  * According to our dual licensing model, this program can be used either
  8.  * under the terms of the GNU Affero General Public License, version 3,
  9.  * or under a proprietary license.
  10.  *
  11.  * The texts of the GNU Affero General Public License, supplemented by an additional
  12.  * permission, and of our proprietary license can be found
  13.  * in the LICENSE file you have received along with this program.
  14.  *
  15.  * This program is distributed in the hope that it will be useful,
  16.  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  17.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  18.  * GNU Affero General Public License for more details.
  19.  *
  20.  * "shopware" is a registered trademark of shopware AG.
  21.  * "onacy" is a registered trademark of onacy GmbH.
  22.  * The licensing of the program under the AGPLv3 does not imply a
  23.  * trademark license. Therefore any rights, titles and interests in the
  24.  * above trademarks remain entirely with the trademark owners.
  25.  *
  26.  * @copyright  Copyright (c) 2019, onacy GmbH (http://www.onacy.de)
  27.  * @author     onacy GmbH <dev@onacy.de>
  28.  */
  30. namespace ConnectBundle\EventListener;
  32. use ConnectBundle\Components\Shopware\ArticleApi;
  33. use ConnectBundle\Components\Shopware\CategoryApi;
  34. use ConnectBundle\Components\Shopware\FilterSetApi;
  35. use ConnectBundle\Helper\ShopwareApi;
  36. use Pimcore\Event\Model\DataObjectEvent;
  37. use Pimcore\Event\Model\ElementEventInterface;
  38. use Pimcore\Model\DataObject;
  39. use Pimcore\Model\Version;
  41. class ObjectListener
  42. {
  43.     private $handled = array();
  45.     public function onPostUpdate(ElementEventInterface $e)
  46.     {
  47.         if (!$e instanceof DataObjectEvent) {
  48.             return;
  49.         }
  51.         $object = $e->getObject();
  53.         if ($object instanceof DataObject\Concrete) {
  54.             /** @var Version $latestVersion */
  55.             $latestVersion = end($object->getVersions());
  56.             if ($latestVersion->getUserId() === 0) {
  57.                 return; // Skip if change is from system user
  58.             }
  59.         }
  61.         if (isset($this->handled) && $this->handled[$object->getId()]) {
  62.             return;
  63.         }
  64.         $this->handled[$object->getId()] = true;
  66.         if ($object instanceof DataObject\Category) {
  68.             $categoryApi = new CategoryApi($this->getShopwareApi());
  69.             $categoryApi->load($object);
  70.             if ($categoryApi->upsert()) {
  71.                 $this->Logger()->info("Category update successful", [
  72.                     "relatedObject" => $object,
  73.                 ]);
  74.             }
  75.             else {
  76.                 $this->Logger()->warning("Category update not successful", [
  77.                     "relatedObject" => $object,
  78.                 ]);
  79.             }
  81.         }
  83.         //delete variant from sw if unpublished in pim
  84.         if ($object instanceof DataObject\Article) {
  85.         $time_start = microtime(true);
  86.             $articleApi = new ArticleApi($this->getShopwareApi());
  87.             $articleApi->load($object);
  88.             if ($articleApi->upsert()) {
  89.         $time_end = microtime(true);
  90.         $execution_time = ($time_end - $time_start)/60;
  91.                 $this->Logger()->info("Article update successful", [
  92.                     "relatedObject" => $object,
  93.                 ]);
  94.                 $this->Logger()->debug("Article Speed Time " .$execution_time . " Minutes");
  95.             }
  96.             else {
  97.                 $this->Logger()->warning("Article update not successful", [
  98.                     "relatedObject" => $object,
  99.                 ]);
  100.             }
  102.         }
  105.         if ($object instanceof DataObject\FilterSet) {
  107.             $filterSetApi = new FilterSetApi($this->getShopwareApi());
  108.             $filterSetApi->load($object);
  109.             if ($filterSetApi->upsert()) {
  110.                 $this->Logger()->info("Filter Set update successful", [
  111.                     "relatedObject" => $object,
  112.                 ]);
  113.             }
  114.             else {
  115.                 $this->Logger()->warning("Filter Set update not successful", [
  116.                     "relatedObject" => $object,
  117.                 ]);
  118.             }
  119.         }
  121.         if ($object instanceof DataObject\FilterGroup) {
  123.             // todo: implement filter group updater
  125.         }
  127.         if ($object instanceof DataObject\FilterOption) {
  129.             // todo: implement filter option updater
  131.         }
  133.         if ($object instanceof DataObject\Supplier) {
  135.             // todo: implement suppier updater
  137.         }
  138.     }
  140.     private $shopwareApi = null;
  142.     private function getShopwareApi()
  143.     {
  144.         if ($this->shopwareApi === null) {
  145.             $this->shopwareApi = new ShopwareApi();
  146.         }
  147.         return $this->shopwareApi;
  148.     }
  149.     private $logger = null;
  151.     private function Logger()
  152.     {
  153.         if ($this->logger === null) {
  154.             $this->logger = \Pimcore\Log\ApplicationLogger::getInstance("BwSyncOnSave", true);
  155.         }
  156.         return $this->logger;
  157.     }
  159. }