custom/plugins/X10SocialReviews/src/Subscribers/PageLoader.php line 48

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace X10\SocialReviews\Subscribers;
  5. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  6. use Shopware\Core\Framework\DataAbstractionLayer\Search\Sorting\FieldSorting;
  7. use Shopware\Storefront\Page\GenericPageLoadedEvent;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. use Doctrine\DBAL\Connection;
  10. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  11. use X10\SocialReviews\Services\SocialReviewService;
  12. class PageLoader implements EventSubscriberInterface
  13. {
  15.     /**
  16.      * @var Connection
  17.      */
  18.     private $connection;
  20.     /**
  21.      * @var EntityRepositoryInterface $socialReviewRepository
  22.      */
  23.     private $socialReviewRepository;
  25.     /**
  26.      * @var SocialReviewService $socialReviewService
  27.      *
  28.      */
  29.     private $socialReviewService;
  31.     public function __construct(Connection $connection,
  32.                                 EntityRepositoryInterface $socialReviewRepository,
  33.                                 SocialReviewService $socialReviewService){
  34.         $this->connection = $connection;
  35.         $this->socialReviewRepository = $socialReviewRepository;
  36.         $this->socialReviewService = $socialReviewService;
  38.     }
  40.     public static function getSubscribedEvents(): array
  41.     {
  43.         return [
  44.             GenericPageLoadedEvent::class => 'pageLoadedEvent',
  45.         ];
  46.     }
  48.     public function pageLoadedEvent(GenericPageLoadedEvent $event): void
  49.     {
  51.         /**
  52.          * wegen performance
  53.          */
  54.         $sql = "SELECT CEIL(SUM(points) / count(*)) as summery FROM view_social_review";
  55.         $result = $this->connection->executeQuery(
  56.             $sql
  57.         );
  58.         $summery = $result->fetchAssociative()['summery'];
  61.         $table_name = $this->socialReviewRepository->getDefinition()->getEntityName();
  62.         $sql = "SELECT count(*) as total FROM $table_name";
  63.         $result = $this->connection->executeQuery(
  64.             $sql
  65.         );
  67.         $total = $result->fetchAssociative()['total'];
  70.         /*
  71.         $result = $this->socialReviewRepository->search((new Criteria())
  72.             ->setLimit(3)
  73.             ->addSorting(
  74.                 new FieldSorting('createdAt', FieldSorting::DESCENDING)
  75.             ), $event->getContext());*/
  79.         //$result = $this->socialReviewRepository->search((new Criteria()), $event->getContext());
  81.         /*
  82.         $total = $this->socialReviewRepository->search((new Criteria()), $event->getContext());
  83.         dump($total->count());exit;*/
  84.         $result = $this->socialReviewService->getRawSqlReviewResults(3, 0);
  86.         $event->getPage()->assign(['x10'=>
  87.             [
  88.                 'ratings' => $result,
  89.                 'ratingSummery'=>$summery,
  90.                 'ratingTotal'=>$total
  91.             ]
  92.         ]);
  94.         /**
  95.          * @var Facebook\Facebook
  97.         //$fb = $this->faceBookService->getFb();
  98.         try{
  99.             $decoded_body = $fb->get('/kartenmachen.de?fields=access_token')->getDecodedBody();
  100.             $fbRatings = $fb->get("/$decoded_body[id]/ratings?limit=5", $decoded_body['access_token']);
  103.             $event->getPage()->assign(['x10'=>['ratings' => $fbRatings->getDecodedBody()['data']]]);
  105.         }catch (\Facebook\Exceptions\FacebookResponseException $exception){
  106.             $event->getPage()->assign(['x10'=>['ratings' =>
  107.                 [],
  108.                 ]
  109.             ]);
  110.         }catch (\ErrorException $e){
  112.         }
  113.         */
  114.     }
  116. }