custom/plugins/TTTrustedShops/src/Subscriber/TrustedShopsSubscriber.php line 43

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace TTTrustedShops\Subscriber;
  5. use Shopware\Core\Framework\DataAbstractionLayer\Exception\InconsistentCriteriaIdsException;
  6. use Shopware\Storefront\Page\Product\ProductPageLoadedEvent;
  7. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  8. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  9. use Shopware\Core\System\SystemConfig\SystemConfigService;
  10. use DreiscSeoPro\Subscriber\Installment\RichSnippet\RichSnippetSubscriber;
  12. class TrustedShopsSubscriber implements EventSubscriberInterface
  13. {
  14.     private $productReviewsApiUrl = 'https://cdn1.api.trustedshops.com/shops/{{tsId}}/products/public/v1/feed.json';
  16.     /**
  17.      * @var SystemConfigService
  18.      */
  19.     private $systemConfigService;
  21.     /**
  22.      * @var EntityRepositoryInterface
  23.      */
  24.     private $productRepository;
  26.     public function __construct(EntityRepositoryInterface $productRepository, SystemConfigService $systemConfigService)
  27.     {
  28.         $this->productRepository = $productRepository;
  29.         $this->systemConfigService = $systemConfigService;
  30.     }
  32.     public static function getSubscribedEvents()
  33.     {
  34.         return [
  35.             ProductPageLoadedEvent::class => 'addSnippetReviewRating',
  36.         ];
  37.     }
  39.     /**
  40.      * @param ProductPageLoadedEvent $event
  41.      * @throws InconsistentCriteriaIdsException
  42.      */
  43.     public function addSnippetReviewRating(ProductPageLoadedEvent $event)
  44.     {
  45.         $page = $event->getPage();
  46.         $product = $page->getProduct();
  47.         $richSnippetData = $page->getExtension(RichSnippetSubscriber::DREISC_SEO_INSTALLMENT_RICH_SNIPPET_DATA);
  48.         if($richSnippetData) {
  49.             $ld = $richSnippetData->getLdJson();
  50.             $domain = 'TrustedShops.config.';
  51.             $tsId = $this->systemConfigService->get( $domain . 'tsId' );
  53.             $apiUrl = str_replace( '{{tsId}}', $tsId, $this->productReviewsApiUrl );
  55.             $ch = curl_init();
  56.             curl_setopt($ch, CURLOPT_HTTPHEADER, [ 'Accept: application/json' ] );
  57.             curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  58.             curl_setopt($ch, CURLOPT_URL, $apiUrl);
  59.             $result = curl_exec($ch);
  60.             curl_close($ch);
  62.             $shopReviews = json_decode( $result );
  64.             if ($shopReviews && $shopReviews->response && $shopReviews->response->data->shop->products) {
  65.                 foreach ($shopReviews->response->data->shop->products as $_product) {
  66.                     if ($product->getProductNumber() == $_product->sku) {
  67.                         $this->addAggregateRatingAndReviews($ld, $_product);
  68.                     }
  69.                 }
  70.             }
  72.             //AM-760 Snippetanpassung für Hauptbild auf den SERPS
  73.             $this->fixMediaSnippets($ld, $product);
  75.             $richSnippetData->setLdJson($ld);
  76.             if(!empty($richSnippetData->getLdJson())) {
  77.                 $page->addExtension(
  78.                     RichSnippetSubscriber::DREISC_SEO_INSTALLMENT_RICH_SNIPPET_DATA,
  79.                     $richSnippetData
  80.                 );
  81.             }
  82.         }
  83.     }
  84.     
  85.     private function fixMediaSnippets(array &$ld, $_product) {
  86.         if(isset($ld[0]['image']) && count($ld[0]['image']) > 1) {
  87.             $images = $ld[0]['image'];
  88.             //keep only image is a cover of product if product have a cover
  89.             foreach($images as $key => $image) {
  90.                 if(!empty($_product->getCover())) {
  91.                     if($image != $_product->getCover()->getMedia()->getUrl()) {
  92.                         unset($ld[0]['image'][$key]);
  93.                     }
  94.                 }
  95.             }
  96.             //keep a first image if product have not a cover
  97.             if(count($ld[0]['image']) > 1) {
  98.                 array_slice($ld[0]['image'],0,1);
  99.             }
  100.         }
  101.     }
  103.     private function addAggregateRatingAndReviews(array &$ld, $_product)
  104.     {
  105.         /** Add the aggregate rating */
  106.         $ld[0]['aggregateRating'] = [
  107.             '@type' => 'AggregateRating',
  108.             'ratingValue' => $_product->qualityIndicators->reviewIndicator->overallMark,
  109.             'bestRating'  => '5',
  110.             'ratingCount' => $_product->qualityIndicators->reviewIndicator->totalReviewCount
  111.         ];
  113.         /** Add the reviews */
  114.         $reviews = [];
  116.         foreach($_product->productReviews as $productReview) {
  117.             $datePublished = $productReview->creationDate;
  119.             $review = [
  120.                 '@type' => 'Review',
  121.                 'datePublished' => $datePublished,
  122.                 'name' => $_product->name,
  123.                 'description' => $productReview->comment,
  124.                 'author' => [
  125.                     '@type' => 'Person',
  126.                     'name' => 'unknown'
  127.                 ]
  128.             ];
  130.             $reviews[] = $review;
  131.         }
  133.         $ld[0]['review'] = $reviews;
  134.     }
  135. }