src/FlexApp/Service/AdsFilters/FilterAdsFilesDataService.php line 41

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace FlexApp\Service\AdsFilters;
  7. use Exception;
  8. use RuntimeException;
  9. use Symfony\Component\Yaml\Yaml;
  10. use WebBundle\Helper\ProxyHelper;
  12. /**
  13.  * Сервис для чтения файлов (локально или по SFTP), а также парсинга YAML-файлов с ссылками (Ads/Filters).
  14.  */
  15. class FilterAdsFilesDataService
  16. {
  17.     private const FILTERS_ADS_PATH_TEMPLATE = 'var/filters_ads/links_%s.txt';
  19.     /**
  20.      * Универсальный метод чтения файла:
  21.      *  - Если !App::isGeneral(), то пытается прочитать файл локально.
  22.      *  - Если App::isGeneral(), то читает через SFTP, используя ProxyHelper::getConnection().
  23.      *
  24.      * @param string $relativePath Относительный путь к файлу, например:
  25.      *                             "var/sitemap/sitemap.da-dk_part1.xml"
  26.      *
  27.      * @return string Содержимое файла.
  28.      *
  29.      */
  30.     public function getFileContents(string $relativePath): string
  31.     {
  32.         $fullPath = ProxyHelper::getFullPathByRelative($relativePath);
  34.         if (is_file($fullPath) && is_readable($fullPath)) {
  35.             $data = @file_get_contents($fullPath);
  36.             if ($data !== false) {
  37.                 return $data;
  38.             }
  39.         }
  41.         $conn = ProxyHelper::getConnection(ProxyHelper::ADMIN_SERV_ID);
  42.         if (!is_resource($conn)) {
  43.             throw new RuntimeException(sprintf(
  44.                 'Файл [%s] не найден локально, и не удалось установить SSH-соединение (conn == null).',
  45.                 $fullPath
  46.             ));
  47.         }
  49.         $sftp = @ssh2_sftp($conn);
  50.         if (!is_resource($sftp)) {
  51.             throw new RuntimeException(sprintf(
  52.                 'Файл [%s] не найден локально, и SFTP-ресурс недоступен.',
  53.                 $fullPath
  54.             ));
  55.         }
  57.         $sftpPath = sprintf('ssh2.sftp://%d/%s', (int) $sftp, ltrim($fullPath, '/'));
  58.         $data = @file_get_contents($sftpPath);
  59.         if ($data === false) {
  60.             throw new RuntimeException(sprintf(
  61.                 'Не удалось прочитать файл [%s] ни локально, ни через SFTP.',
  62.                 $fullPath
  63.             ));
  64.         }
  66.         return $data;
  67.     }
  69.     /**
  70.      * Возвращает содержимое YAML-файла var/filters_ads/links_{locale}.txt
  71.      * (указанного в FILTERS_ADS_PATH_TEMPLATE) в виде массива.
  72.      *
  73.      * @param string $locale Код локали, например "ru".
  74.      *
  75.      * @return array Ассоциативный массив (распарсенные данные), либо [] если не удалось.
  76.      */
  77.     public function getFiltersAdsByLocale(string $locale): array
  78.     {
  79.         // Подставим локаль в шаблон пути
  80.         $relativePath = sprintf(self::FILTERS_ADS_PATH_TEMPLATE, $locale);
  82.         // Универсальное чтение (локально или через SFTP)
  83.         $content = $this->getFileContents($relativePath);
  85.         try {
  86.             $parsed = Yaml::parse($content);
  87.         } catch (Exception $e) {
  88.             throw new Exception(sprintf(
  89.                 'Ошибка парсинга YAML для локали "%s": %s',
  90.                 $locale,
  91.                 $e->getMessage()
  92.             ), 0, $e);
  93.         }
  95.         if (!is_array($parsed)) {
  96.             return [];
  97.         }
  99.         return $parsed;
  100.     }
  101. }