custom/plugins/IntediaDoofinderSW6/src/Doofinder/Api/Search.php line 54

Open in your IDE?
  1. <?php
  3. namespace Intedia\Doofinder\Doofinder\Api;
  5. use GuzzleHttp\Client;
  6. use Psr\Log\LoggerInterface;
  7. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  8. use Shopware\Core\System\SystemConfig\SystemConfigService;
  10. class Search
  11. {
  12.     const API_VERSION    = '5';
  13.     const CLIENT_TIMEOUT = 2.5; // seconds
  14.     const CONFIG_KEY     = 'IntediaDoofinderSW6.config.';
  15.     const MAX_RESULTS    = 1500;
  16.     const PAGE_SIZE      = 100;
  18.     /** @var SystemConfigService */
  19.     protected $systemConfigService;
  21.     /** @var LoggerInterface */
  22.     protected $logger;
  24.     /** @var Client */
  25.     protected $client;
  27.     /** @var string */
  28.     protected $baseUrl;
  30.     /** @var string */
  31.     protected $engineHash;
  33.     /** @var string */
  34.     protected $apiKey;
  36.     /** @var string */
  37.     protected $apiZone;
  39.     /**
  40.      * Search constructor.
  41.      *
  42.      * @param SystemConfigService $systemConfigService
  43.      * @param LoggerInterface $logger
  44.      */
  45.     public function __construct(SystemConfigService $systemConfigService, LoggerInterface $logger)
  46.     {
  47.         $this->logger              = $logger;
  48.         $this->systemConfigService = $systemConfigService;
  50.         if ($this->initConfig()) {
  52.             $this->client = new Client([
  53.                 'base_uri' => $this->baseUrl,
  54.                 'timeout'  => self::CLIENT_TIMEOUT
  55.             ]);
  56.         }
  57.     }
  59.     /**
  60.      * Initializes api with config values
  61.      * @param SalesChannelContext|null $context
  62.      * @return bool
  63.      */
  64.     protected function initConfig(?SalesChannelContext $context = null): bool
  65.     {
  66.         $pluginConfig = $this->systemConfigService->getDomain(self::CONFIG_KEY, $context ? $context->getSalesChannel()->getId() : null, true);
  68.         if (!empty($pluginConfig[self::CONFIG_KEY . 'apiKey']) && !empty($pluginConfig[self::CONFIG_KEY . 'engineHashId']) && !empty($pluginConfig[self::CONFIG_KEY . 'searchDomain'])) {
  70.             $apiInfo = explode('-', $pluginConfig[self::CONFIG_KEY . 'apiKey']);
  72.             $this->apiKey     = $apiInfo[1];
  73.             $this->apiZone    = $apiInfo[0];
  74.             $this->engineHash = $pluginConfig[self::CONFIG_KEY . 'engineHashId'];
  75.             $this->baseUrl    = sprintf("https://{$pluginConfig[self::CONFIG_KEY . 'searchDomain']}/%s/", $this->apiZone,self::API_VERSION);
  77.             return true;
  78.         }
  80.         return false;
  81.     }
  83.     /**
  84.      * @param SalesChannelContext|null $context
  85.      * @return Client
  86.      */
  87.     protected function generateClient(?SalesChannelContext $context = null)
  88.     {
  89.         if ($this->initConfig($context)) {
  91.             $this->client = new Client([
  92.                 'base_uri' => $this->baseUrl,
  93.                 'timeout'  => self::CLIENT_TIMEOUT
  94.             ]);
  95.         }
  97.         return $this->client;
  98.     }
  100.     /**
  101.      * @param $term
  102.      * @param SalesChannelContext|null $context
  103.      * @return array
  104.      */
  105.     public function queryIds($term, ?SalesChannelContext $context = null)
  106.     {
  107.         if ($context) {
  108.             $this->generateClient($context);
  109.         }
  111.         $resultIds      = [];
  112.         $page           = 1;
  113.         $dfResponse     = $this->queryPage($term, $page, self::PAGE_SIZE);
  114.         $productsToLoad = self::MAX_RESULTS;
  116.         while ($dfResponse) {
  118.             $dfResults = $dfResponse['results'];
  120.             for ($i = 0; $i < count($dfResults) && ($productsToLoad > 0); $i++, --$productsToLoad) {
  122.                 if (array_key_exists('group_id', $dfResults[$i])) {
  123.                     $resultIds[$dfResults[$i]['group_id']] = $dfResults[$i]['id'];
  124.                 }
  125.                 else {
  126.                     $resultIds[] = $dfResults[$i]['id'];
  127.                 }
  128.             }
  130.             $dfResponse = $page * self::PAGE_SIZE < $dfResponse['total'] && $productsToLoad > 0 ? $this->queryPage($term, ++$page, self::PAGE_SIZE) : null;
  131.         }
  133.         return $resultIds;
  134.     }
  136.     /**
  137.      * @param $term
  138.      * @param $page
  139.      * @param $rpp
  140.      * @return mixed|null
  141.      */
  142.     protected function queryPage($term, $page, $rpp)
  143.     {
  144.         try {
  146.             if ($this->client) {
  148.                 $response = $this->client->request('GET', 'search',
  149.                     [
  150.                         'query' => [
  151.                             'hashid' => $this->engineHash,
  152.                             'query'  => $term,
  153.                             'page'   => $page,
  154.                             'rpp'    => $rpp
  155.                         ],
  156.                         'headers' => [
  157.                             'Authorization' => 'Token ' . $this->apiKey
  158.                         ]
  159.                     ]
  160.                 );
  162.                 if ($response->getStatusCode() === 200) {
  163.                     return \GuzzleHttp\json_decode($response->getBody(), true);
  164.                 }
  165.             }
  166.         }
  167.         catch (\Exception $e) {
  168.             $this->logger->error("Exception receiving results from doofinder: " . $e->getMessage());
  169.         }
  171.         return null;
  172.     }
  173. }