custom/static-plugins/AbasConnector/src/Subscribers/Extension/AbasExtensionSubscriber.php line 44

Open in your IDE?
  1. <?php
  3. namespace Abas\AbasConnector\Subscribers\Extension;
  5. use Abas\AbasConnector\Service\Component\AbasComponentFactory;
  6. use Abas\AbasConnector\Service\Core\Enums\Duration;
  7. use Abas\AbasConnector\Service\RestApi\Response\Content\ErpDataObject;
  8. use Shopware\Core\Framework\Api\Context\SalesChannelApiSource;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Entity;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityLoadedEvent;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Symfony\Contracts\Cache\CacheInterface;
  13. use Symfony\Contracts\Cache\ItemInterface;
  15. use function str_replace;
  17. abstract class AbasExtensionSubscriber implements EventSubscriberInterface
  18. {
  19.     /**
  20.      * @var CacheInterface
  21.      */
  22.     private $cache;
  24.     /**
  25.      * @var AbasComponentFactory
  26.      */
  27.     private $componentFactory;
  29.     /**
  30.      * @param CacheInterface $cache
  31.      * @param AbasComponentFactory $componentFactory
  32.      */
  33.     public function __construct(CacheInterface $cache, AbasComponentFactory $componentFactory)
  34.     {
  35.         $this->cache = $cache;
  36.         $this->componentFactory = $componentFactory;
  37.     }
  39.     /**
  40.      * @param EntityLoadedEvent $event
  41.      *
  42.      * @return void
  43.      */
  44.     public function onEntitiesLoaded(EntityLoadedEvent $event): void
  45.     {
  46.         if (!($event->getContext()->getSource() instanceof SalesChannelApiSource)) {
  47.             return;
  48.         }
  50.         $entities = $event->getEntities();
  51.         /** @var Entity $entity */
  52.         foreach ($entities as $entity) {
  53.             $abasObject = $this->getErpObject($entity);
  54.             $entity->addExtension('abas_object', $abasObject);
  55.         }
  56.     }
  58.     /**
  59.      * @param Entity $entity
  60.      *
  61.      * @return null|ErpDataObject
  62.      */
  63.     protected function getErpObject(Entity $entity): ?ErpDataObject
  64.     {
  65.         $databaseAndGroup = $this->getDatabaseAndGroup($entity);
  66.         $id = $this->getSelectionIdentifier($entity);
  68.         if ($databaseAndGroup !== null && $id !== null) {
  69.             $key = str_replace(
  70.                 ['{', '}', '(', ')', '/', '\\', '@', ':'],
  71.                 '',
  72.                 'AbasObjectExtensionCache|' . $id
  73.             );
  75.             return $this->cache->get(
  76.                 $key,
  77.                 function (ItemInterface $item) use ($id, $databaseAndGroup) {
  78.                     $item->expiresAfter(Duration::HOUR);
  79.                     $component = $this->componentFactory->createDataComponent($databaseAndGroup);
  80.                     $component->view($id);
  82.                     return $component->getObject();
  83.                 }
  84.             );
  85.         }
  87.         return null;
  88.     }
  90.     /**
  91.      * Return the abas identifier value (GUID or ID).
  92.      *
  93.      * @param Entity $entity
  94.      *
  95.      * @return string|null
  96.      */
  97.     protected function getSelectionIdentifier(Entity $entity): ?string
  98.     {
  99.         $guid = $this->getCustomFieldValue($entity, 'abas_guid');
  100.         if ($guid !== null) {
  101.             return '$,,guid==' . $guid;
  102.         }
  104.         return $this->getCustomFieldValue($entity, 'abas_id');
  105.     }
  107.     /**
  108.      * Return the database and group for the entity.
  109.      *
  110.      * @param Entity $entity
  111.      *
  112.      * @return string|null
  113.      */
  114.     protected function getDatabaseAndGroup(Entity $entity): ?string
  115.     {
  116.         return $this->getCustomFieldValue($entity, 'abas_database_and_group');
  117.     }
  119.     /**
  120.      * Get a customFields value
  121.      *
  122.      * @param Entity $entity
  123.      * @param string $key
  124.      *
  125.      * @return string|null
  126.      */
  127.     protected function getCustomFieldValue(Entity $entity, string $key): ?string
  128.     {
  129.         if ($entity->has('customFields')) {
  130.             $customFields = $entity->get('customFields');
  131.             if ($customFields && isset($customFields[$key])) {
  132.                 return $customFields[$key];
  133.             }
  134.         }
  136.         return null;
  137.     }
  138. }