vendor/elements/alpstein-bundle/src/Command/ImportCommand.php line 452

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Elements\Bundle\AlpsteinBundle\Command;
  7. use Carbon\Carbon;
  8. use Elements\Bundle\AlpsteinBundle\Services\AlpsteinConfig;
  9. use Elements\Bundle\RecurringDatesTypeBundle\Model\RecurringDateDefinition;
  10. use GuzzleHttp\Client;
  11. use Pimcore\Console\AbstractCommand;
  12. use Pimcore\Console\Traits\DryRun;
  13. use Pimcore\Db;
  14. use Pimcore\Log\ApplicationLogger;
  15. use Pimcore\Model\Asset\Image;
  16. use Pimcore\Model\DataObject;
  17. use Pimcore\Model\DataObject\AlpsteinPoi;
  18. use Pimcore\Model\DataObject\AlpsteinProperty;
  19. use Pimcore\Model\DataObject\AlpsteinRegion;
  20. use Pimcore\Model\DataObject\AlpsteinRegionCategory;
  21. use Pimcore\Model\DataObject\AlpsteinTour;
  22. use Pimcore\Model\DataObject\AlpsteinKey;
  23. use Pimcore\Model\DataObject\AlpsteinVideo;
  24. use Pimcore\Model\DataObject\Data\Geobounds;
  25. use Pimcore\Model\DataObject\Data\GeoCoordinates;
  26. use Pimcore\Model\DataObject\Data\ObjectMetadata;
  27. use Pimcore\Model\DataObject\Data\Video;
  28. use Pimcore\Model\DataObject\AlpsteinCategory;
  29. use Pimcore\Model\DataObject\AlpsteinSource;
  30. use Pimcore\Model\DataObject\AlpsteinAuthor;
  31. use Pimcore\Model\DataObject\Service;
  32. use Pimcore\Model\DataObject\ULicense;
  33. use Symfony\Component\Console\Input\InputInterface;
  34. use Symfony\Component\Console\Input\InputOption;
  35. use Symfony\Component\Console\Output\OutputInterface;
  37. class ImportCommand extends AbstractCommand
  38. {
  39.     use DryRun;
  41.     const TIMESTAMPFILE = '/alpstein_import_timestamp.tmp';
  42.     const IGNORE_FALLBACK = 'ignore-fallback';
  44.     protected $alpsteinConfig;
  45.     protected $defaultLicense;
  46.     protected $doRemoveICCProfile;
  47.     protected $minimumRanking;
  48.     protected $importOnlyCCCompliant;
  49.     protected $validLanguage = [];
  50.     protected $categoryFolder;
  51.     protected $regionCache;
  52.     protected $regionFolder;
  53.     protected $regionCategoryFolder;
  54.     protected $tourFolder;
  55.     protected $poiFolder;
  56.     protected $videosFolder;
  57.     protected $assetIconFolder;
  58.     protected $assetImageFolder = '/Alpstein/Images/';
  59.     protected $assetImageFolderObject;
  60.     protected $assetPropertiesFolder;
  61.     protected $objectPropertiesFolder;
  62.     protected $objectSourceFolder;
  63.     protected $assetSourceFolder;
  64.     protected $objectAuthorFolder;
  65.     protected $assetAuthorFolder;
  66.     protected $objectKeyFolder;
  67.     protected $importedTourIds = [];
  68.     protected $importedPoiIds = [];
  69.     protected $importedRegions = [];
  71.     protected $options = [];
  72.     protected $numToursPerImportIteration = 0;
  73.     protected $importTime = 0;
  74.     /**
  75.      * @var Client
  76.      */
  77.     private $client;
  78.     private ApplicationLogger $applicationLogger;
  80.     protected function configure()
  81.     {
  82.         $this
  83.             ->setName('alpstein:import')
  84.             ->setDescription('Migrate existing structure to new file extensions')
  85.             ->addOption('full', 'f', null, 'start Full Import')
  86.             ->addOption('regions', 'r', null, 'also includes regions in Import')
  87.             ->addOption('pois', 'p', null, 'also includes pois in Import')
  88.             ->addOption('override', 'o', null, 'Override Images')
  89.             ->addOption('delta', 'd', null, 'Only Import changed Tours & Pois')
  90.             ->addOption('skip-images', null, null, 'Ignore Images')
  91.             ->addOption('tourId', null, InputOption::VALUE_OPTIONAL, 'Import selected Tour only')
  92.             ->addOption('tours-per-iterations', null, InputOption::VALUE_OPTIONAL, 'Import the tours in smaller packages, the value is the number of tours per package. Use 0 for not splitting tours into packages', 0)
  93.             ->addOption(self::IGNORE_FALLBACK, 'if', InputOption::VALUE_OPTIONAL, 'Adds the parameter fallback=false to the tour import, so that language fallbacks are not added.')
  94.         ;
  96.         $this->configureDryRunOption();
  97.     }
  99.     /**
  100.      * ImportCommand constructor.
  101.      * @param AlpsteinConfig $alpsteinConfig
  102.      * @param Client $client
  103.      */
  104.     public function __construct(AlpsteinConfig $alpsteinConfig, Client $client, ApplicationLogger $applicationLogger)
  105.     {
  106.         parent::__construct();
  107.         $this->alpsteinConfig = $alpsteinConfig->getConfig();
  108.         $this->doRemoveICCProfile = $alpsteinConfig->doRemoveICCProfile();
  109.         $this->minimumRanking = $alpsteinConfig->getMinimumRanking();
  110.         $this->importOnlyCCCompliant = $alpsteinConfig->getImportOnlyCCCompliant();
  111.         $this->client = $client;
  112.         $this->applicationLogger = $applicationLogger;
  113.     }
  115.     /**
  116.      * @param InputInterface $input
  117.      * @param OutputInterface $output
  118.      * @return int|null|void
  119.      * @throws \GuzzleHttp\Exception\GuzzleException
  120.      */
  121.     protected function execute(InputInterface $input, OutputInterface $output)
  122.     {
  123.         if( $input->getOption('full') ){
  124.             $this->options[] = 'full';
  125.         }
  126.         if( $input->getOption('regions') ){
  127.             $this->options[] = 'regions';
  128.         }
  129.         if( $input->getOption('pois') ){
  130.             $this->options[] = 'pois';
  131.         }
  132.         if( $input->getOption('override') ){
  133.             $this->options[] = 'override';
  134.         }
  135.         if( $input->getOption('delta') ){
  136.             $this->options[] = 'delta';
  137.         }
  138.         if( $input->getOption('skip-images') ){
  139.             $this->options[] = 'skip-images';
  140.         }
  141.         if($input->getOption('tours-per-iterations')) {
  142.             $this->numToursPerImportIteration = (int)$input->getOption('tours-per-iterations');
  143.         }
  144.         if($input->getOption(self::IGNORE_FALLBACK)) {
  145.             $this->options[] = self::IGNORE_FALLBACK;
  146.         }
  148.         $tourId = $input->getOption('tourId');
  152.         $this->validLanguage = ['de'];
  153.         foreach( \Pimcore\Tool::getValidLanguages() as $lang ){
  154.             if( $lang != 'de' ){
  155.                 $this->validLanguage[] = $lang;
  156.             }
  157.         }
  159.         $defaultLicense = ULicense::getByCode('AlpsteinDefault', 1);
  160.         if (!$defaultLicense instanceof ULicense) {
  161.             $defaultLicense = new ULicense();
  162.             $defaultLicense->setKey('AlpsteinDefaultLicense');
  163.             $defaultLicense->setParent(Service::createFolderByPath('Alpstein/License'));
  164.             $defaultLicense->setPublished(true);
  165.             $defaultLicense->setCode('AlpsteinDefault');
  166.             $defaultLicense->setName('Outdooractive AGB', 'de');
  167.             $defaultLicense->setName('Outdooractive Terms of Service', 'en');
  168.             $defaultLicense->save();
  169.         }
  170.         $this->defaultLicense = $defaultLicense;
  172.         $this->categoryFolder = Service::createFolderByPath('/Alpstein/Categories');
  174.         $this->regionFolder = Service::createFolderByPath('/Alpstein/Regions');
  176.         $this->regionCategoryFolder = Service::createFolderByPath('/Alpstein/RegionCategories');
  178.         $this->assetIconFolder = \Pimcore\Model\Asset\Service::createFolderByPath('/Alpstein/Icons');
  180.         $this->tourFolder = Service::createFolderByPath('/Alpstein/Tour');
  182.         $this->poiFolder = Service::createFolderByPath('/Alpstein/Poi');
  184.         $this->assetImageFolderObject = \Pimcore\Model\Asset\Service::createFolderByPath( $this->assetImageFolder );
  186.         $this->assetPropertiesFolder = \Pimcore\Model\Asset\Service::createFolderByPath( '/Alpstein/Properties');
  188.         $this->objectPropertiesFolder = Service::createFolderByPath( '/Alpstein/Properties');
  190.         $this->objectSourceFolder = Service::createFolderByPath( '/Alpstein/Sources');
  192.         $this->objectAuthorFolder = Service::createFolderByPath( '/Alpstein/Authors');
  194.         $this->assetSourceFolder = \Pimcore\Model\Asset\Service::createFolderByPath( '/Alpstein/Sources');
  196.         $this->assetAuthorFolder = \Pimcore\Model\Asset\Service::createFolderByPath( '/Alpstein/Authors');
  198.         $this->videosFolder = Service::createFolderByPath( '/Alpstein/Videos');
  200.         $this->objectKeyFolder = Service::createFolderByPath( '/Alpstein/Key');
  202.         $this->importTime = time();
  203.         try {
  204.             if( is_array($this->alpsteinConfig['project']) ){
  205.                 foreach( $this->alpsteinConfig['project'] as $key => $project ){
  206.                     $alpsteinConfig = [
  207.                         'project' => $project,
  208.                         'apiKey' => $this->alpsteinConfig['apiKey'][$key]
  209.                     ];
  210.                     $alpsteinConfig['keyObject'] = $this->createAndGetKey( $alpsteinConfig['project'], $alpsteinConfig['apiKey'] );
  212.                     $this->importCategories( $alpsteinConfig );
  213.                     if ($tourId != '') {
  214.                         $this->importSingleTour($tourId, $alpsteinConfig);
  215.                     } else {
  216.                         if (in_array('regions', $this->options)) {
  217.                             $this->importRegions( $alpsteinConfig );
  218.                         }
  220.                         if (in_array('pois', $this->options)) {
  221.                             $this->importPois( $alpsteinConfig );
  222.                         }
  223.                         $this->importTours( $alpsteinConfig );
  224.                     }
  225.                 }
  226.             } else {
  227.                 $this->alpsteinConfig['keyObject'] = $this->createAndGetKey( $this->alpsteinConfig['project'], $this->alpsteinConfig['apiKey'] );
  228.                 if ($tourId != '') {
  229.                     $this->importSingleTour($tourId, $this->alpsteinConfig);
  230.                 } else {
  231.                     $this->importCategories( $this->alpsteinConfig );
  232.                     if (in_array('regions', $this->options)) {
  233.                         $this->importRegions( $this->alpsteinConfig );
  234.                     }
  235.                     if (in_array('pois', $this->options)) {
  236.                         $this->importPois( $this->alpsteinConfig );
  237.                     }
  238.                     $this->importTours( $this->alpsteinConfig );
  239.                 }
  240.             }
  242.             if (!empty($this->importedTourIds) && !in_array('delta', $this->options) && $tourId == '') {
  243.                 $tours = new AlpsteinTour\Listing();
  244.                 $tours->addConditionParam('alpsteinId IS NOT NULL AND alpsteinId != "" AND alpsteinId NOT IN (' . implode(',', $this->importedTourIds) . ')');
  245.                 foreach ($tours as $tour) {
  246.                     $tour->setPublished(false);
  247.                     $tour->save();
  248.                 }
  249.             }
  251.             if (!empty($this->importedPoiIds) && !in_array('delta', $this->options)) {
  252.                 $pois = new AlpsteinPoi\Listing();
  253.                 $pois->addConditionParam('alpsteinId IS NOT NULL AND alpsteinId != "" AND alpsteinId NOT IN (' . implode(',', $this->importedPoiIds) . ')');
  254.                 foreach ($pois as $poi) {
  255.                     $poi->setPublished(false);
  256.                     $poi->save();
  257.                 }
  258.             }
  259.         } catch (\Exception $exception) {
  260.             $this->applicationLogger->info("Error:\n{$exception->getMessage()}\n\n{$exception->getTraceAsString()}", ['component' => 'AlpsteinImportCommand']);
  261.         }
  263.         if ($tourId == '') {
  264.             file_put_contents(PIMCORE_PRIVATE_VAR . self::TIMESTAMPFILE, $this->importTime);
  265.         }
  267.         return 0;
  268.     }
  271.     /**
  272.      * @param $project
  273.      * @param $apiKey
  274.      * @return AlpsteinKey|AlpsteinKey\Listing
  275.      * @throws \Exception
  276.      */
  277.     private function createAndGetKey( $project, $apiKey ){
  279.         $keyObject = AlpsteinKey::getByApiKey( $apiKey, ['limit' => 1] );
  280.         if( !$keyObject instanceof AlpsteinKey ){
  281.             $keyObject = new AlpsteinKey();
  282.             $keyObject->setName($project);
  283.             $keyObject->setApiKey($apiKey);
  284.             $keyObject->setKey( \Pimcore\File::getValidFilename($project . '-' . $apiKey) );
  285.             $keyObject->setParent( $this->objectKeyFolder );
  286.             $keyObject->setPublished( true );
  287.             $keyObject->save();
  288.         }
  290.         return $keyObject;
  291.     }
  294.     /**
  295.      * Import Categories
  296.      * @param $alpsteinConfig
  297.      * @throws \GuzzleHttp\Exception\GuzzleException
  298.      */
  299.     private function importCategories( $alpsteinConfig )
  300.     {
  302.         foreach( $this->validLanguage as $language ){
  304.             $url = 'https://www.outdooractive.com/api/project/' . $alpsteinConfig['project'] . '/category/tree?lang=' . $language . '&key=' . $alpsteinConfig['apiKey'];
  306.             $client = $this->client;
  307.             $requestType = 'GET';
  308.             $config = [
  309.                 \GuzzleHttp\RequestOptions::ALLOW_REDIRECTS => [
  310.                     'max' => 2
  311.                 ],
  312.                 \GuzzleHttp\RequestOptions::TIMEOUT => 60
  313.             ];
  315.             $config[\GuzzleHttp\RequestOptions::HEADERS] = [
  316.                 'Accept' => 'application/json'
  317.             ];
  319.             /**
  320.              * @var $response \GuzzleHttp\Psr7\Response
  321.              */
  322.             try {
  323.                 $response = $client->request($requestType, $url, $config);
  324.             } catch (\Throwable $exception) {
  325.                 $this->dump('################### ERROR ###################');
  326.                 $this->dump($exception->getMessage());
  327.                 $this->dump($exception->getTraceAsString());
  328.                 $this->dump('################### ERROR ###################');
  329.             }
  331.             if ($response && $response->getStatusCode() == 200) {
  332.                 $data = $response->getBody();
  334.                 $categoryArray = json_decode( $data->getContents() );
  335.                 foreach( $categoryArray as $itemArray ){
  337.                     // Top Category
  338.                     foreach( $itemArray as $item ){
  339.                         $parentId = $this->createCategory( $item, $alpsteinConfig['keyObject'], $this->categoryFolder->getId(), $language );
  341.                         // Sub Category
  342.                         foreach( $item->category ?? [] as $subCategory ){
  343.                             $this->createCategory( $subCategory, $alpsteinConfig['keyObject'], $parentId, $language );
  344.                         }
  345.                     }
  346.                 }
  347.             }
  348.         }
  349.     }
  352.     /**
  353.      * Import Categories
  354.      * @param $alpsteinConfig
  355.      * @throws \GuzzleHttp\Exception\GuzzleException
  356.      */
  357.     private function importRegions( $alpsteinConfig )
  358.     {
  359.         foreach( $this->validLanguage as $language ){
  360.             $url = 'https://www.outdooractive.com/api/project/' . $alpsteinConfig['project'] . '/region/tree?lang=' . $language . '&key=' . $alpsteinConfig['apiKey'];
  362.             $client = $this->client;
  363.             $requestType = 'GET';
  364.             $config = [
  365.                 \GuzzleHttp\RequestOptions::ALLOW_REDIRECTS => [
  366.                     'max' => 2
  367.                 ],
  368.                 \GuzzleHttp\RequestOptions::TIMEOUT => 60
  369.             ];
  371.             $config[\GuzzleHttp\RequestOptions::HEADERS] = [
  372.                 'Accept' => 'application/json'
  373.             ];
  375.             /**
  376.              * @var $response \GuzzleHttp\Psr7\Response
  377.              */
  378.             try {
  379.                 $response = $client->request($requestType, $url, $config);
  380.             } catch (\Throwable $exception) {
  381.                 $this->dump('################### ERROR ###################');
  382.                 $this->dump($exception->getMessage());
  383.                 $this->dump($exception->getTraceAsString());
  384.                 $this->dump('################### ERROR ###################');
  385.             }
  386.             if ($response && $response->getStatusCode() == 200) {
  387.                 $data = $response->getBody();
  389.                 $regionArray = json_decode( $data->getContents() );
  390.                 foreach( $regionArray->region as $regionData ){
  391.                     $this->createRegion($regionData, $this->regionFolder->getId(), $alpsteinConfig['keyObject'], $language);
  392.                 }
  393.             }
  394.         }
  395.     }
  398.     /**
  399.      * @param $item
  400.      * @param null $parentId
  401.      * @param string $language
  402.      * @param $keyObject AlpsteinKey
  403.      * @return int
  404.      * @throws \Exception
  405.      */
  406.     private function createCategory( $item, $keyObject, $parentId = null, $language = 'de' ){
  408.         $category = AlpsteinCategory::getByCategoryId( (int)$item->id, 1 );
  410.         if( !$category instanceof AlpsteinCategory ){
  411.             $category = new AlpsteinCategory();
  412.             $category->setParentId( $parentId );
  413.             $category->setPublished( true );
  414.             $category->setKey( \Pimcore\File::getValidFilename( $item->name . '-' . $item->id ) );
  415.             $category->setCategoryId((int)$item->id);
  417.             if( $language == 'de' && !$category->getIcon() instanceof Image ){
  418.                 if( isset($item->iconUrl) ){
  420.                     preg_match('/^.*\.(jpg|jpeg|png|gif|svg)$/i', $item->iconUrl, $reg);
  421.                     $imageName = \Pimcore\File::getValidFilename( $item->name . '-' . $item->id ) . '.' . $reg[1];
  422.                     $image = Image::getByPath( $this->assetIconFolder->getFullPath() . '/' . $imageName );
  424.                     if( !$image instanceof Image ){
  426.                         try {
  427.                             $iconUrl = \Pimcore\Tool::getHttpData($item->iconUrl, [], [], ['timeout' => 60]);
  428.                         } catch (\Throwable $exception) {
  429.                             $this->dump('################### ERROR ###################');
  430.                             $this->dump($exception->getMessage());
  431.                             $this->dump($exception->getTraceAsString());
  432.                             $this->dump('################### ERROR ###################');
  433.                         }
  434.                         if( $iconUrl ){
  435.                             $image = new Image();
  436.                             $image->setData( $iconUrl );
  437.                             $image->setFilename( $imageName = \Pimcore\File::getValidFilename( $item->name . '-' . $item->id ) . '.' . $reg[1] );
  438.                             $image->setParent( $this->assetIconFolder );
  439.                             $image->save();
  440.                             $category->setIcon($image);
  441.                         }
  443.                     }else{
  444.                         $category->setIcon($image);
  445.                     }
  446.                 }
  447.             }
  448.         }
  450.         $catAlpsteinKeys = $category->getAlpsteinKey();
  451.         $hasKey = false;
  452.         foreach( $catAlpsteinKeys as $keyObj ){
  453.             if( $keyObj->getApiKey() == $keyObject->getApiKey() ){
  454.                 $hasKey = true;
  455.                 break;
  456.             }
  457.         }
  458.         if( !$hasKey ){
  459.             $catAlpsteinKeys[] = $keyObject;
  460.         }
  461.         $category->setAlpsteinKey( $catAlpsteinKeys );
  464.         $category->setModificationDate( time() );
  465.         $category->setName( $item->name, $language );
  466.         $category->save();
  468.         return $category->getId();
  469.     }
  474.     /**
  475.      * @param $regionData
  476.      * @param $parentId
  477.      * @param string $language
  478.      * @param AlpsteinKey $keyObject
  479.      * @throws \Exception
  480.      */
  481.     private function createRegion( $regionData, $parentId, $keyObject, $language = 'de' ){
  482.         if (array_key_exists($language, $this->importedRegions) && array_key_exists($regionData->id, $this->importedRegions[$language]) && ($region = $this->importedRegions[$language][$regionData->id])) {
  483.             return $region;
  484.         }
  486.         $region = AlpsteinRegion::getByAlpsteinId( (int)$regionData->id, 1 );
  488.         if( !$region instanceof AlpsteinRegion ){
  489.             $region = new AlpsteinRegion();
  490.             $region->setParentId( $parentId );
  491.             $region->setPublished( true );
  492.             $region->setKey( \Pimcore\File::getValidFilename( $regionData->name . '-' . $regionData->id ) );
  493.             $region->setAlpsteinId((int)$regionData->id);
  494.         }
  495.         $alpsteinKeys = $region->getAlpsteinKey();
  496.         $hasKey = false;
  497.         foreach( $alpsteinKeys as $keyObj ){
  498.             if( $keyObj->getApiKey() == $keyObject->getApiKey() ){
  499.                 $hasKey = true;
  500.                 break;
  501.             }
  502.         }
  503.         if( !$hasKey ){
  504.             $alpsteinKeys[] = $keyObject;
  505.         }
  506.         $region->setAlpsteinKey( $alpsteinKeys );
  508.         $region->setModificationDate( time() );
  509.         $region->setName( $regionData->name, $language );
  510.         $region->setRegionType( $regionData->type );
  511.         $region->setLevel( $regionData->level );
  512.         $region->setHasTour($regionData->hasTour);
  513.         if ($regionData->bbox) {
  514.             $geodata = explode(',', $regionData->bbox);
  515.             $southWest = new GeoCoordinates($geodata[1], $geodata[0]);
  516.             $northEast = new GeoCoordinates($geodata[3], $geodata[2]);
  517.             $bbox = new Geobounds($northEast, $southWest);
  518.             $region->setBbox($bbox);
  519.         }
  521.         $region->setCategory($this->createRegionCategory($regionData->categoryId, $regionData->categoryTitle, $keyObject, $language));
  523.         $region->save();
  524.         $subregions = $region->getSubRegions();
  525.         $containingRegions = [];
  526.         foreach ($subregions ?: [] as $subRegionObj) {
  527.             $containingRegions[] = $subRegionObj->getAlpsteinId();
  528.         }
  529.         if (!empty($regionData->region)) {
  530.             foreach ($regionData->region as $subRegionData) {
  531.                 $subRegion = $this->createRegion($subRegionData, $region->getId(), $keyObject, $language);
  532.                 if (!in_array($subRegion->getAlpsteinId(), $containingRegions)) {
  533.                     $subregions[] = $subRegion;
  534.                     $containingRegions[] = $subRegion->getAlpsteinId();
  535.                 }
  536.             }
  537.         }
  539.         $region->setSubRegions($subregions);
  540.         $region->save();
  542.         $this->importedRegions[$language][$regionData->id] = $region;
  544.         return $region;
  546.     }
  548.     /**
  549.      * @param $regionCategoryId
  550.      * @param $regionCategoryName
  551.      * @param string $language
  552.      * @param AlpsteinKey $keyObject
  553.      * @return AlpsteinRegionCategory
  554.      * @throws \Exception
  555.      */
  556.     private function createRegionCategory( $regionCategoryId, $regionCategoryName, $keyObject, $language = 'de' ){
  558.         $regionCategory = AlpsteinRegionCategory::getByAlpsteinId( (int)$regionCategoryId, 1 );
  560.         if( !$regionCategory instanceof AlpsteinRegionCategory ){
  561.             $regionCategory = new AlpsteinRegionCategory();
  562.             $regionCategory->setParentId( $this->regionCategoryFolder->getId() );
  563.             $regionCategory->setPublished( true );
  564.             $regionCategory->setKey( \Pimcore\File::getValidFilename( $regionCategoryName . '-' . $regionCategoryId ) );
  565.             $regionCategory->setAlpsteinId((int)$regionCategoryId);
  566.         }
  568.         $alpsteinKeys = $regionCategory->getAlpsteinKey();
  569.         $hasKey = false;
  570.         foreach( $alpsteinKeys as $keyObj ){
  571.             if( $keyObj->getApiKey() == $keyObject->getApiKey() ){
  572.                 $hasKey = true;
  573.                 break;
  574.             }
  575.         }
  576.         if( !$hasKey ){
  577.             $alpsteinKeys[] = $keyObject;
  578.         }
  579.         $regionCategory->setAlpsteinKey( $alpsteinKeys );
  580.         $regionCategory->setName( $regionCategoryName, $language );
  583.         $regionCategory->setModificationDate( time() );
  585.         $regionCategory->save();
  587.         return $regionCategory;
  588.     }
  590.     private function importSingleTour ($tourObjectId, $alpsteinConfig) {
  591.         $tour = AlpsteinTour::getById($tourObjectId);
  592.         if ($tour instanceof AlpsteinTour) {
  593.             $lastImport = 0;
  594.             $importTimeStampFile = PIMCORE_PRIVATE_VAR . '/alpstein-single-import-' . $tourObjectId . '.txt';
  595.             if (file_exists($importTimeStampFile)) {
  596.                 $lastImport = file_get_contents($importTimeStampFile);
  597.             }
  598.             if ($lastImport < strtotime('-2 hours')) {
  599.                 file_put_contents((string)time(), $importTimeStampFile);
  600.                 $tourId = $tour->getAlpsteinId();
  601.                 foreach ($this->validLanguage as $language) {
  602.                     $url = 'https://www.outdooractive.com/api/project/' . $alpsteinConfig['project'] . '/oois/' . $tourId . '?lang=' . $language . '&key=' . $alpsteinConfig['apiKey'];
  603.                     if(in_array(self::IGNORE_FALLBACK, $this->options)) {
  604.                         $url .= '&fallback=false';
  605.                     }
  606.                     $client = $this->client;
  607.                     $requestType = 'GET';
  608.                     $config = [
  609.                         \GuzzleHttp\RequestOptions::ALLOW_REDIRECTS => [
  610.                             'max' => 2
  611.                         ],
  612.                         \GuzzleHttp\RequestOptions::TIMEOUT => 60
  613.                     ];
  615.                     $config[\GuzzleHttp\RequestOptions::HEADERS] = [
  616.                         'Accept' => 'application/json'
  617.                     ];
  619.                     /**
  620.                      * @var $response \GuzzleHttp\Psr7\Response
  621.                      */
  622.                     try {
  623.                         $response = $client->request($requestType, $url, $config);
  624.                     } catch (\Throwable $exception) {
  625.                         $this->dump('################### ERROR ###################');
  626.                         $this->dump($exception->getMessage());
  627.                         $this->dump($exception->getTraceAsString());
  628.                         $this->dump('################### ERROR ###################');
  629.                     }
  631.                     if ($response && $response->getStatusCode() == 200) {
  632.                         $data = $response->getBody();
  634.                         $tourArray = json_decode($data->getContents());
  635.                         if( $tourArray->tour[0] && in_array($language, $tourArray->tour[0]->meta->translation ) ){
  636.                             $this->createTour( $tourArray->tour[0], $alpsteinConfig['keyObject'], $language );
  637.                         }
  638.                     }
  639.                 }
  640.                 unlink($importTimeStampFile);
  641.             }
  642.         }
  643.     }
  645.     private function importTours( $alpsteinConfig ){
  646.         $tourIds = $this->importTourIdList($alpsteinConfig);
  647.         $tourIdPackages = $this->createTourIdPackages($tourIds);
  648.         $numPackages = count($tourIdPackages);
  649.         try {
  650.             foreach ($tourIdPackages as $key => $tourIds) {
  651.                 $this->applicationLogger->info('Tour Import Package #' . $key+1 . "/{$numPackages}", ['component' => 'AlpsteinImportCommand']);
  652.                 $this->dump("Importing package #" . ($key + 1) . "/{$numPackages}; package size: " . count($tourIds));
  653.                 foreach ($this->validLanguage as $language) {
  654.                     foreach ($tourIds as $tourId) {
  655.                         $url = 'https://www.outdooractive.com/api/project/' . $alpsteinConfig['project'] . '/oois/' . $tourId . '?lang=' . $language . '&key=' . $alpsteinConfig['apiKey'];
  656.                         if(in_array(self::IGNORE_FALLBACK, $this->options)) {
  657.                             $url .= '&fallback=false';
  658.                         }
  659.                         $client = $this->client;
  660.                         $requestType = 'GET';
  661.                         $config = [
  662.                             \GuzzleHttp\RequestOptions::ALLOW_REDIRECTS => [
  663.                                 'max' => 2
  664.                             ],
  665.                             \GuzzleHttp\RequestOptions::TIMEOUT => 60
  666.                         ];
  668.                         $config[\GuzzleHttp\RequestOptions::HEADERS] = [
  669.                             'Accept' => 'application/json'
  670.                         ];
  672.                         /**
  673.                          * @var $response \GuzzleHttp\Psr7\Response
  674.                          */
  675.                         try {
  676.                             $response = $client->request($requestType, $url, $config);
  677.                         } catch (\Throwable $exception) {
  678.                             $this->dump('################### ERROR ###################');
  679.                             $this->dump($exception->getMessage());
  680.                             $this->dump($exception->getTraceAsString());
  681.                             $this->dump('################### ERROR ###################');
  682.                         }
  684.                         if ($response && $response->getStatusCode() == 200) {
  685.                             $data = $response->getBody();
  687.                             $tourArray = json_decode($data->getContents());
  688.                             if ($tourArray->tour[0] && in_array($language, $tourArray->tour[0]->meta->translation)) {
  689.                                 $this->createTour($tourArray->tour[0], $alpsteinConfig['keyObject'], $language);
  690.                             }
  691.                         }
  692.                         $this->dump(" ");
  693.                     }
  694.                 }
  695.                 \Pimcore::collectGarbage();
  696.             }
  697.         } catch (\Throwable $e) {
  698.             $this->applicationLogger->info("Error while importing tour\n{$e->getMessage()}\n\n{$e->getTraceAsString()}", ['component' => 'AlpsteinImportCommand']);
  699.         }
  700.         $this->dump('----> Done');
  701.     }
  703.     private function importPois( $alpsteinConfig ){
  704.         $poiIds = $this->importPoiIdList($alpsteinConfig);
  705.         foreach ($this->validLanguage as $language) {
  706.             foreach( $poiIds as $poiId ){
  707.                 $url = 'https://www.outdooractive.com/api/project/' . $alpsteinConfig['project'] . '/oois/' . $poiId . '?lang=' . $language . '&key=' . $alpsteinConfig['apiKey'];
  708.                 if(in_array(self::IGNORE_FALLBACK, $this->options)) {
  709.                     $url .= '&fallback=false';
  710.                 }
  711.                 $client = $this->client;
  712.                 $requestType = 'GET';
  713.                 $config = [
  714.                     \GuzzleHttp\RequestOptions::ALLOW_REDIRECTS => [
  715.                         'max' => 2
  716.                     ],
  717.                     \GuzzleHttp\RequestOptions::TIMEOUT => 60
  718.                 ];
  720.                 $config[\GuzzleHttp\RequestOptions::HEADERS] = [
  721.                     'Accept' => 'application/json'
  722.                 ];
  724.                 /**
  725.                  * @var $response \GuzzleHttp\Psr7\Response
  726.                  */
  727.                 try {
  728.                     $response = $client->request($requestType, $url, $config);
  729.                 } catch (\Throwable $exception) {
  730.                     $this->dump('################### ERROR ###################');
  731.                     $this->dump($exception->getMessage());
  732.                     $this->dump($exception->getTraceAsString());
  733.                     $this->dump('################### ERROR ###################');
  734.                 }
  736.                 if ($response && $response->getStatusCode() == 200) {
  737.                     $data = $response->getBody();
  739.                     $poiArray = json_decode($data->getContents());
  741.                     if( $poiArray->poi[0] && in_array($language, $poiArray->poi[0]->meta->translation ) ){
  742.                         $this->createPoi( $poiArray->poi[0], $alpsteinConfig['keyObject'], $language );
  743.                     }
  744.                 }
  745.                 $this->dump(" ");
  746.             }
  747.         }
  748.         $this->dump('----> Done');
  749.     }
  751.     /**
  752.      * Import List of Id's
  753.      * @param string $language
  754.      * @return array
  755.      * @throws \GuzzleHttp\Exception\GuzzleException
  756.      */
  757.     private function importTourIdList( $alpsteinConfig, $language = 'de' ) : array {
  758.         $tourIds = [];
  761.         $url = 'https://www.outdooractive.com/api/project/' . $alpsteinConfig['project'] . '/tours?key=' . $alpsteinConfig['apiKey'];
  762.         if (in_array('delta', $this->options) && file_exists(PIMCORE_PRIVATE_VAR . self::TIMESTAMPFILE)) {
  763.             $timestamp = Carbon::createFromTimestamp((int)file_get_contents(PIMCORE_PRIVATE_VAR . self::TIMESTAMPFILE));
  764.             $url .= '&lastModifiedAfter=' . $timestamp->format('d.m.Y');
  765.         }
  766.         $client = $this->client;
  767.         $requestType = 'GET';
  768.         $config = [
  769.             \GuzzleHttp\RequestOptions::ALLOW_REDIRECTS => [
  770.                 'max' => 2
  771.             ],
  772.             \GuzzleHttp\RequestOptions::TIMEOUT => 60
  773.         ];
  775.         $config[\GuzzleHttp\RequestOptions::HEADERS] = [
  776.             'Accept' => 'application/json'
  777.         ];
  779.         /**
  780.          * @var $response \GuzzleHttp\Psr7\Response
  781.          */
  782.         try {
  783.             $response = $client->request($requestType, $url, $config);
  784.         } catch (\Throwable $exception) {
  785.             $this->dump('################### ERROR ###################');
  786.             $this->dump($exception->getMessage());
  787.             $this->dump($exception->getTraceAsString());
  788.             $this->dump('################### ERROR ###################');
  789.             $this->applicationLogger->info("error importing tour: \n{$exception->getMessage()}", ['component' => 'AlpsteinImportCommand']);
  790.         }
  792.         if ($response && $response->getStatusCode() == 200) {
  793.             $data = $response->getBody();
  795.             $tourArray = json_decode($data->getContents());
  797.             foreach ($tourArray->data ?? [] as $itemArray) {
  799.                 $tourIds[] = $itemArray->id;
  800.             }
  801.         }
  804.         return $tourIds;
  805.     }
  807.     /**
  808.      * Import List of Id's
  809.      * @param string $language
  810.      * @return array
  811.      * @throws \GuzzleHttp\Exception\GuzzleException
  812.      */
  813.     private function importPoiIdList( $alpsteinConfig, $language = 'de' ) : array {
  814.         $poiIds = [];
  817.         $url = 'https://www.outdooractive.com/api/project/' . $alpsteinConfig['project'] . '/pois?key=' . $alpsteinConfig['apiKey'];
  819.         if (in_array('delta', $this->options) && file_exists(PIMCORE_PRIVATE_VAR . self::TIMESTAMPFILE)) {
  820.             $timestamp = Carbon::createFromTimestamp((int)file_get_contents(PIMCORE_PRIVATE_VAR . self::TIMESTAMPFILE));
  821.             $url .= '&lastModifiedAfter=' . $timestamp->format('d.m.Y');
  822.         }
  823.         $client = $this->client;
  824.         $requestType = 'GET';
  825.         $config = [
  826.             \GuzzleHttp\RequestOptions::ALLOW_REDIRECTS => [
  827.                 'max' => 2
  828.             ],
  829.             \GuzzleHttp\RequestOptions::TIMEOUT => 60
  830.         ];
  832.         $config[\GuzzleHttp\RequestOptions::HEADERS] = [
  833.             'Accept' => 'application/json'
  834.         ];
  836.         /**
  837.          * @var $response \GuzzleHttp\Psr7\Response
  838.          */
  839.         try {
  840.             $response = $client->request($requestType, $url, $config);
  841.         } catch (\Throwable $exception) {
  842.             $this->dump('################### ERROR ###################');
  843.             $this->dump($exception->getMessage());
  844.             $this->dump($exception->getTraceAsString());
  845.             $this->dump('################### ERROR ###################');
  846.         }
  848.         if ($response && $response->getStatusCode() == 200) {
  849.             $data = $response->getBody();
  851.             $poiArray = json_decode($data->getContents());
  853.             foreach ($poiArray->data as $itemArray) {
  855.                 $poiIds[] = $itemArray->id;
  856.             }
  857.         }
  860.         return $poiIds;
  861.     }
  864.     // Create or Update Tour
  865.     private function createTour( $tour, $keyObject, $language = 'de' ){
  866.         /** not yet considered Fields:
  867.          * - lineOptions
  868.          * - riskPotential
  869.          * - exposition
  870.          * - wayType
  871.          * - elements
  872.          * - difficulties
  873.          * - literature
  874.          * - maps
  875.          * - bookWorks
  876.          * - mapWorks
  877.          * - localizedTitle
  878.          * - type
  879.          * - frontendtype
  880.          * - license
  881.          */
  883.         $tourObject = AlpsteinTour::getByAlpsteinId( (int)$tour->id, [ 'limit' => 1, 'unpublished' => true ] );
  885.         // ignore tours not meeting minimumRanking condition and unpublish if already exists
  886.         if ($this->minimumRanking && $tour->ranking < $this->minimumRanking) {
  887.             if ($tourObject instanceof AlpsteinTour) {
  888.                 $tourObject->setPublished(false);
  889.                 $tourObject->save();
  890.             }
  891.             return;
  892.         }
  894.         if( !$tourObject instanceof AlpsteinTour ){
  895.             $tourObject = new AlpsteinTour();
  896.             $tourObject->setKey( \Pimcore\File::getValidFilename( ($tour->title ?? 'no-title') . '-' . $tour->id ) );
  897.             $tourObject->setAlpsteinId( (int)$tour->id );
  898.             $tourObject->setParent( $this->tourFolder );
  899.             $tourObject->save();
  900.         }
  903.         $catAlpsteinKeys = $tourObject->getAlpsteinKey();
  904.         $hasKey = false;
  905.         foreach( $catAlpsteinKeys as $keyObj ){
  906.             if( $keyObj->getApiKey() == $keyObject->getApiKey() ){
  907.                 $hasKey = true;
  908.                 break;
  909.             }
  910.         }
  911.         if( !$hasKey ){
  912.             $catAlpsteinKeys[] = $keyObject;
  913.         }
  914.         $tourObject->setAlpsteinKey( $catAlpsteinKeys );
  916.         $this->dump('-> Tour: ' . $tourObject->getName('de') . '(' . $tourObject->getId() . ')');
  918.         $published = false;
  919.         if( $tour->meta->workflow->state == 'published' ){
  920.             $published = true;
  921.         }
  923.         if(isset($tour->meta->source) && $tour->meta->source != ''){
  924.             $this->dump('-> Tour Source: ' . $tourObject->getName('de') . '(' . $tour->meta->source->id . ')');
  925.             $source = $tour->meta->source;
  926.             $sourceObject = $this->createSource($source, $language);
  927.             $tourObject->setSource($sourceObject);
  928.         }
  930.         if(isset($tour->meta->authorFull)  && $tour->meta->authorFull != ''){
  931.             $this->dump('-> Tour Author: ' . $tourObject->getName('de') . '(' . $tour->meta->authorFull->id . ')');
  932.             $author = $tour->meta->authorFull;
  933.             $authorObject = $this->createAuthor($author);
  934.             $tourObject->setAuthorFull($authorObject);
  935.         }
  937.         $tourObject->setAuthor($tour->meta->author ?? '');
  939.         if ($tourObject->getId() == '' ) {
  940.             p_r($tour->meta->workflow); die();
  941.         }
  942.         $tourObject->setPublished( $published );
  944.         $tourObject->setName( $tour->title ?? '', $language );
  945.         $tourObject->setRanking($tour->ranking ?? '');
  947.         // Destination
  948.         $tourObject->setDestination( $tour->destination ?? '', $language );
  949.         //ShortText
  950.         $tourObject->setShortText( $tour->shortText ?? '', $language );
  952.         // Longtext
  953.         $tourObject->setLongText( $tour->longText ?? '', $language );
  955.         // Import all Images and return an array [ primaryImage, allImages ]
  958.         $primaryId = null;
  959.         $primaryTitle = 'primaryImage';
  961.         if( isset($tour->primaryImage) && isset($tour->primaryImage->id) ){
  963.             $primaryId = $tour->primaryImage->id;
  964.             if(isset($tour->primaryImage->title)) {
  965.                 $primaryTitle = $tour->primaryImage->title;
  966.             }
  967.         }
  969.         if (!in_array('skip-images', $this->options)) {
  970.             if( isset( $tour->images ) ){
  971.                 $images = $this->loadAllImages( $tourObject, $tour->id, $tour->images->image, $primaryId, $language, $primaryTitle );
  972.                 if( !is_null( $images[ 'primaryImage' ] ) ){
  973.                     $tourObject->setPrimaryImage( $images[ 'primaryImage' ] );
  974.                 }
  975.                 if( !is_null( $images[ 'videos' ] ) ){
  976.                     $tourObject->setVideos( $images[ 'videos' ] );
  977.                 }
  978.                 if( in_array( 'full', $this->options ) ){
  979.                     if( !is_null( $images[ 'allImages' ] ) ){
  980.                         $tourObject->setImages( $images[ 'allImages' ] );
  981.                     }
  982.                 }
  983.             }
  984.         }
  987.         // set Category
  988.         $category = AlpsteinCategory::getByCategoryId( $tour->category->id, [ 'limit' => 1, 'unpublished' => true ] );
  989.         if( $category ){
  990.             $tourObject->setCategory([ $category ]);
  991.         }
  993.         // Opened
  994.         if (isset( $tour->opened ) && $tour->opened !== null){
  995.             $tourObject->setOpened($tour->opened);
  996.         } else {
  997.             $tourObject->setOpened(true);
  998.         }
  1000.         // -- Regions
  1001.         $oldRegions = $tourObject->getRegions();
  1002.         if( isset($tour->regions) && isset($tour->regions->region) ) {
  1003.             $regions = [];
  1004.             foreach ($tour->regions->region as $regionData) {
  1006.                 if (!isset($this->regionCache[$regionData->id]) instanceof AlpsteinRegion) {
  1007.                     $this->regionCache[$regionData->id] = AlpsteinRegion::getByAlpsteinId((string) $regionData->id, 1);
  1008.                 }
  1010.                 $region = $this->regionCache[$regionData->id];
  1011.                 if ($region instanceof AlpsteinRegion) {
  1012.                     $objectMetadata = new ObjectMetadata('regions', ['isStartingRegion'], $region);
  1013.                     $oldIsStartingRegion = null;
  1014.                     if($tourObject->getDoNotUpdateStartingRegion()) { //if not set, always update starting region
  1015.                         $oldIsStartingRegion = $this->getStartingRegionFromOldRegionsArray($region, $oldRegions);
  1016.                     }
  1017.                     if($oldIsStartingRegion === null) {
  1018.                         if (isset($regionData->isStartRegion)) {
  1019.                             $objectMetadata->setIsStartingRegion(true);
  1020.                         } else {
  1021.                             $objectMetadata->setIsStartingRegion(false);
  1022.                         }
  1023.                     } else { //old region did exist + getDoNotUpdateStartingRegion === true
  1024.                         $objectMetadata->setIsStartingRegion($oldIsStartingRegion);
  1025.                     }
  1026.                     $regions[] = $objectMetadata;
  1027.                 }
  1028.             }
  1029.             $tourObject->setRegions($regions);
  1030.         }
  1031.         // -- Texte
  1032.         if( in_array( 'full', $this->options ) ){
  1033.             // global
  1034.             $tourObject->setStartingPointDesc( $tour->startingPointDescr ?? '', $language );
  1035.             // transit
  1036.             $tourObject->setPublicTransit( $tour->publicTransit ?? '', $language );
  1037.             // getting There
  1038.             $tourObject->setGettingThere( $tour->gettingThere ?? '', $language );
  1039.             // parking
  1040.             $tourObject->setParking( $tour->parking ?? '', $language );
  1041.             // Safety Guide
  1042.             $tourObject->setSafetyGuidlines( $tour->safetyGuidlines ?? '', $language );
  1043.             // Tip
  1044.             $tourObject->setTip( $tour->tip ?? '', $language );
  1045.             // Additional Information
  1046.             $tourObject->setEquipment( $tour->equipment ?? '', $language );
  1048.             // Additional Information
  1049.             $tourObject->setAdditionalInformation( $tour->additionalInformation ?? '', $language );
  1050.             // Direction
  1051.             $tourObject->setDirections( $tour->directions ?? '', $language);
  1053.             // -- Labels
  1055.             // top
  1056.             $tourObject->setTop( $tour->labels->top ?? '' );
  1058.             //publicTransportFriendly
  1059.             if( isset( $tour->labels) ){
  1060.                 $tourObject->setPublicTransportFriendly( $tour->labels->publicTransportFriendly ?? '' );
  1061.             }
  1063.             // winter activity
  1064.             $tourObject->setWinterActivity( $tour->winterActivity ?? '' );
  1066.             // -- Data
  1068.             // Publisher ID
  1069.             $tourObject->setPublisherID( $tour->meta->source->id ?? '' );
  1071.             // Time Min
  1072.             $tourObject->setTimeMin( $tour->time->min ?? '' );
  1073.             // Length
  1074.             $tourObject->setLength( $tour->length ?? '' );
  1076.             // Elevation
  1077.             $tourObject->setElevationAscent( $tour->elevation->ascent ?? '' );
  1078.             $tourObject->setElevationDescent( $tour->elevation->descent ?? '' );
  1079.             $tourObject->setElevationMinAltitude( $tour->elevation->minAltitude ?? '' );
  1080.             $tourObject->setElevationMaxAltitude( $tour->elevation->maxAltitude ?? '' );
  1081.             $tourObject->setElevationProfileId( $tour->elevationProfile->id ?? '');
  1083.             // Rating
  1084.             $tourObject->setRatingCondition( $tour->rating->condition ?? '' );
  1085.             $tourObject->setRatingDifficulty( $tour->rating->difficulty ?? '' );
  1086.             $tourObject->setRatingTechnique( $tour->rating->technique ?? '' );
  1087.             $tourObject->setRatingQualityExp( $tour->rating->qualityOfExperience ?? '' );
  1088.             $tourObject->setRatingLandscape( $tour->rating->landscape ?? '' );
  1090.             // -- Season
  1091.             foreach( [ 'jan', 'feb', 'mar', 'apr', 'may', 'jun', 'jul', 'aug', 'sep', 'oct', 'nov', 'dec' ] as $season ){
  1093.                 $setter = 'set' . ucfirst($season);
  1094.                 $tourObject->$setter( $tour->season->{$season} );
  1096.             }
  1097.             // -- License
  1098.             $license = false;
  1099.             if (isset($tour->meta) && isset($tour->meta->license)) {
  1100.                 $license = $this->getLicenseByFid($tour->meta->license->short);
  1101.             }
  1103.             if ($license) {
  1104.                 $tourObject->setProperty('ulicense_object', 'object', $license);
  1105.             } else {
  1106.                 $tourObject->setProperty('ulicense_object', 'object', $this->defaultLicense);
  1107.             }
  1109.             $pois = [];
  1110.             if( isset( $tour->pois ) ){
  1111.                 foreach ($tour->pois->poi ?? [] as $poi) {
  1112.                     $poiObject = AlpsteinPoi::getByAlpsteinId($poi->id, 1);
  1113.                     if ($poiObject instanceof AlpsteinPoi) {
  1114.                         $objectMetadata = new ObjectMetadata('pois', ['isElevationProfilePoi', 'isReststopPoi', 'isRecommendationPoi'], $poiObject);
  1115.                         if ($poi->isElevationProfilePoi ?? false) {
  1116.                             $objectMetadata->setIsElevationProfilePoi(true);
  1117.                         }
  1118.                         if ($poi->isReststopPoi ?? false) {
  1119.                             $objectMetadata->setIsReststopPoi(true);
  1120.                         }
  1121.                         if ($poi->isRecommendationPoi ?? false) {
  1122.                             $objectMetadata->setIsRecommendationPoi(true);
  1123.                         }
  1124.                         $pois[] = $objectMetadata;
  1125.                     }
  1126.                 }
  1127.             }
  1128.             $tourObject->setPois($pois);
  1130.             // -- GEO
  1131.             // Destination
  1132.             $tourObject->setDestination( $tour->destination ?? '', $language );
  1133.             // startingPoint
  1134.             $startingGeo = new GeoCoordinates();
  1135.             $startingGeo->setLatitude( $tour->startingPoint->lat );
  1136.             $startingGeo->setLongitude( $tour->startingPoint->lon );
  1137.             $tourObject->setStartingPoint( $startingGeo );
  1139.             // geoPositions (tour)
  1140.             $tourObject->setGeometry( $tour->geometry );
  1143.             // -- Properties
  1144.             if( isset( $tour->properties)){
  1145.                 $tourProperties = $this->tourProperties( $tour->properties->property ?? '', $language );
  1146.                 $tourObject->setTourProperties( $tourProperties );
  1147.             }
  1148.         } // end only full import
  1150.         $tourObject->save();
  1151.         $this->importedTourIds[] = $tourObject->getAlpsteinId();
  1152.     }
  1155.     // Create or Update Poi
  1156.     private function createPoi( $poi, $keyObject, $language = 'de' ){
  1157.         /** not yet considered Fields:
  1158.          * - frontendtype
  1159.          * - license
  1160.          */
  1162.         $poiObject = AlpsteinPoi::getByAlpsteinId( (int)$poi->id, [ 'limit' => 1, 'unpublished' => true ] );
  1164.         // ignore tours not meeting minimumRanking condition and unpublish if already exists
  1165.         if ($this->minimumRanking && $poi->ranking < $this->minimumRanking) {
  1166.             if ($poiObject instanceof AlpsteinPoi) {
  1167.                 $poiObject->setPublished(false);
  1168.                 $poiObject->save();
  1169.             }
  1170.             return;
  1171.         }
  1173.         if( !$poiObject instanceof AlpsteinPoi ){
  1174.             $poiObject = new AlpsteinPoi();
  1175.             $poiObject->setKey( \Pimcore\File::getValidFilename( $poi->title . '-' . $poi->id ) );
  1176.             $poiObject->setAlpsteinId( (int)$poi->id );
  1177.             $poiObject->setParent( $this->poiFolder );
  1178.             $poiObject->save();
  1179.         }
  1182.         $catAlpsteinKeys = $poiObject->getAlpsteinKey();
  1183.         $hasKey = false;
  1184.         foreach( $catAlpsteinKeys as $keyObj ){
  1185.             if( $keyObj->getApiKey() == $keyObject->getApiKey() ){
  1186.                 $hasKey = true;
  1187.                 break;
  1188.             }
  1189.         }
  1190.         if( !$hasKey ){
  1191.             $catAlpsteinKeys[] = $keyObject;
  1192.         }
  1193.         $poiObject->setAlpsteinKey( $catAlpsteinKeys );
  1195.         $this->dump('-> POI: ' . $poiObject->getName('de') . '(' . $poiObject->getId() . ')');
  1197.         $published = false;
  1198.         if( $poi->meta->workflow->state == 'published' ){
  1199.             $published = true;
  1200.         }
  1201.         if ($poiObject->getId() == '' ) {
  1202.             p_r($poi->meta->workflow); die();
  1203.         }
  1204.         $poiObject->setPublished( $published );
  1206.         $poiObject->setName( $poi->title ?? '', $language );
  1207.         $poiObject->setRanking($poi->ranking ?? '');
  1208.         $poiObject->setFrontendType($poi->frontendtype ?? '');
  1210.         //ShortText
  1211.         $poiObject->setShortText( $poi->shortText ?? '', $language );
  1213.         // Longtext
  1214.         $poiObject->setLongText( $poi->longText ?? '', $language );
  1216.         // Import all Images and return an array [ primaryImage, allImages ]
  1218.         $primaryId = null;
  1219.         $primaryTitle = 'primaryImage';
  1221.         if( isset($poi->primaryImage) && isset($poi->primaryImage->id) ){
  1223.             $primaryId = $poi->primaryImage->id;
  1224.             if(isset($poi->primaryImage->title)) {
  1225.                 $primaryTitle = $poi->primaryImage->title;
  1226.             }
  1227.         }
  1229.         if (!in_array('skip-images', $this->options)) {
  1230.             if (isset($poi->images)) {
  1231.                 $images = $this->loadAllImages($poiObject, $poi->id, $poi->images->image, $primaryId, $language,
  1232.                     $primaryTitle);
  1234.                 if (!is_null($images['primaryImage'])) {
  1235.                     $poiObject->setPrimaryImage($images['primaryImage']);
  1236.                 }
  1238.                 if (!is_null($images['videos'])) {
  1239.                     $poiObject->setVideos($images['videos']);
  1240.                 }
  1242.                 if (in_array('full', $this->options)) {
  1243.                     if (!is_null($images['allImages'])) {
  1244.                         $poiObject->setImages($images['allImages']);
  1245.                     }
  1246.                 }
  1247.             }
  1248.         }
  1249.         // set Category
  1250.         $category = AlpsteinCategory::getByCategoryId( $poi->category->id, [ 'limit' => 1, 'unpublished' => true ] );
  1251.         if( $category ){
  1252.             $poiObject->setCategory([ $category ]);
  1253.         }
  1255.         // -- Labels
  1257.         // top
  1258.         $poiObject->setTop( $poi->labels->top ?? '' );
  1259.         // winter activity
  1260.         $poiObject->setWinterActivity( $poi->winterActivity ?? '' );
  1261.         $poiObject->setAltitude( $poi->altitude ?? '' );
  1262.         // contact data
  1263.         $poiObject->setStreet($poi->address->street ?? '');
  1264.         $poiObject->setZipcode($poi->address->zipcode ?? '');
  1265.         $poiObject->setTown($poi->address->town ?? '');
  1266.         $poiObject->setHomepage($poi->homepage ?? '');
  1267.         $poiObject->setEmail($poi->email ?? '');
  1268.         $poiObject->setPhone($poi->phone ?? '');
  1270.         // Texte
  1271.         $poiObject->setPublicTransit($poi->publicTransit ?? '', $language);
  1272.         $poiObject->setGettingThere($poi->gettingThere ?? '', $language);
  1273.         $poiObject->setParking($poi->parking ?? '', $language);
  1275.         // Publisher ID
  1276.         $poiObject->setPublisherID( $poi->meta->source->id ?? '');
  1278.         if(isset($poi->meta->source) && $poi->meta->source != ''){
  1279.             $this->dump('-> Poi Source: ' . $poiObject->getName('de') . '(' . $poi->meta->source->id . ')');
  1280.             $source = $poi->meta->source;
  1281.             $sourceObject = $this->createSource($source, $language);
  1282.             $poiObject->setSource($sourceObject);
  1283.         }
  1285.         if(isset($poi->meta->authorFull)  && $poi->meta->authorFull != ''){
  1286.             $this->dump('-> Poi Author: ' . $poiObject->getName('de') . '(' . $poi->meta->authorFull->id . ')');
  1287.             $author = $poi->meta->authorFull;
  1288.             $authorObject = $this->createAuthor($author);
  1289.             $poiObject->setAuthorFull($authorObject);
  1290.         }
  1292.         $poiObject->setAuthor($poi->meta->author ?? '');
  1294.         // -- Regions
  1295.         if( isset($poi->regions) && isset($poi->regions->region) ) {
  1296.             $regions = [];
  1297.             foreach ($poi->regions->region as $regionData) {
  1298.                 if (!isset($this->regionCache[$regionData->id]) || !$this->regionCache[$regionData->id] instanceof AlpsteinRegion) {
  1299.                     $this->regionCache[$regionData->id] = AlpsteinRegion::getByAlpsteinId((string) $regionData->id, 1);
  1300.                 }
  1301.                 $region = $this->regionCache[$regionData->id];
  1302.                 if ($region instanceof AlpsteinRegion) {
  1303.                     $objectMetadata = new ObjectMetadata('regions', ['isStartingRegion'], $region);
  1304.                     if ($regionData->isStartRegion) {
  1305.                         $objectMetadata->setIsStartingRegion(true);
  1306.                     }
  1307.                     $regions[] = $objectMetadata;
  1308.                 }
  1309.             }
  1310.             $poiObject->setRegions($regions);
  1311.         }
  1313.         // -- GEO
  1314.         // positions
  1315.         if (isset($poi->geometry)) {
  1316.             $posData = explode(',', $poi->geometry);
  1317.             $poiObject->setPosition( new GeoCoordinates($posData[0], $posData[1]) );
  1318.         }
  1320.         // -- Properties
  1321.         $poiProperties = $this->tourProperties( $poi->properties->property ?? [], $language );
  1322.         $poiObject->setPoiProperties( $poiProperties );
  1324.         $poiObject->setBusinessHours($poi->businessHours ?? '', $language);
  1325.         $this->poiSetOpeningTimes($poiObject, $poi->openingHours ?? []);
  1327.         $poiObject->save();
  1328.         $this->importedPoiIds[] = $poiObject->getAlpsteinId();
  1330.     }
  1332.     private function poiSetOpeningTimes($object, $openingHours = []) {
  1334.         $dates = $object->getOpeningTimes();
  1335.         if (!$dates) {
  1336.             $dates = new RecurringDateDefinition();
  1337.         }
  1338.         $definitionArray = [];
  1340.         if (!empty($openingHours->weekday->openTime)) {
  1342.             // as no daterange is given for the general openingtimes, but recurring dates needs a
  1343.             // daterange (otherwise for fromDate and toDate the current date from the import will be used),
  1344.             // the first day of the year is used for fromDate and the last day of the next year is for toDate
  1346.             $times = [];
  1347.             $dayMapping = [
  1348.                 'Monday' => 'mo',
  1349.                 'Tuesday' => 'tu',
  1350.                 'Wednesday' => 'we',
  1351.                 'Thursday' => 'th',
  1352.                 'Friday' => 'fr',
  1353.                 'Saturday' => 'sa',
  1354.                 'Sunday' => 'su',
  1355.             ];
  1358.             // start to get the times for every weekday
  1359.             foreach ($openingHours->weekday->openTime ?? [] as $date) {
  1360.                 foreach ($date->openHours ?? [] as $openHour) {
  1361.                     $timeFrom = $openHour->from ?? null;
  1362.                     $timeTo = $openHour->to ?? null;
  1363.                     $weekday = $dayMapping[$date->weekday];
  1364.                     $times[$weekday]['times'][] = [
  1365.                         'start' => $timeFrom == '24:00' ? '23:59' : $timeFrom,
  1366.                         'end' => $timeTo == '24:00' ? '23:59' : $timeTo
  1367.                     ];
  1368.                 }
  1369.             }
  1371.             // combine all identical time entries to only get one entry for the same time on different weekdays
  1372.             $identicalTimes = [];
  1373.             $hashes = [];
  1374.             foreach ($times as $weekday => $time) {
  1375.                 $hash = hash('sha256', serialize($time));
  1377.                 if (isset($hashes[$hash])) {
  1378.                     $identicalTimes[$hash] = array_merge($identicalTimes[$hash], [
  1379.                         $weekday => true
  1380.                     ]);
  1381.                 } else {
  1383.                     $hashes[$hash] = $weekday;
  1384.                     $identicalTimes[$hash] = array_merge($time, [
  1385.                         $weekday => true,
  1386.                         'fromDate' => Carbon::today()->setMonth(1)->setDay(1)->format('Y-m-d'),
  1387.                         'toDate' => Carbon::today()->setMonth(12)->setDay(31)->addYear()->format('Y-m-d'),
  1388.                     ]);
  1389.                 }
  1390.             }
  1392.             foreach ($identicalTimes as $entries) {
  1393.                 $definitionArray[] = [
  1394.                     'type' => RecurringDateDefinition::DEFINITION_TYPE_RECURRING_DATE_TIME,
  1395.                     'values' => $entries,
  1396.                 ];
  1397.             }
  1398.         }
  1400.         if (!empty($openingHours->special->openTime)) {
  1402.             $times = ['times' => []];
  1403.             foreach ($openingHours->special->openTime as $openTime) {
  1404.                 foreach ($openTime->openHours ?? [] as $openHour) {
  1405.                     $timeFrom = $openHour->from ?? null;
  1406.                     $timeTo = $openHour->to ?? null;
  1407.                     $times = [
  1408.                         'times' => [
  1409.                             [
  1410.                                 'start' => $timeFrom == '24:00' ? '23:59' : $timeFrom,
  1411.                                 'end' => $timeTo == '24:00' ? '23:59' : $timeTo
  1412.                             ]
  1413.                         ],
  1414.                         'mo' => in_array('MON', $openHour->days ?? []),
  1415.                         'tu' => in_array('TUE', $openHour->days ?? []),
  1416.                         'we' => in_array('WED', $openHour->days ?? []),
  1417.                         'th' => in_array('THU', $openHour->days ?? []),
  1418.                         'fr' => in_array('FRI', $openHour->days ?? []),
  1419.                         'sa' => in_array('SAT', $openHour->days ?? []),
  1420.                         'su' => in_array('SUN', $openHour->days ?? []),
  1421.                     ];
  1422.                 }
  1424.                 // special opening times depend on a time range, and can also be excluded
  1425.                 $definitionArray[] = [
  1426.                     'type' => RecurringDateDefinition::DEFINITION_TYPE_RECURRING_DATE_TIME,
  1427.                     'values' =>  array_merge([
  1428.                         'fromDate' => (string)$openTime->dateFrom,
  1429.                         'toDate' => (string)$openTime->dateTo,
  1430.                         'excluded' => $openTime->isOpen != 'true',
  1431.                     ], $times)
  1432.                 ];
  1433.             }
  1434.         }
  1436.         $dates->setDefinitionArray($definitionArray);
  1437.         $object->setOpeningTimes($dates);
  1438.     }
  1441.     /**
  1442.      * @param DataObject $relatedObject
  1443.      * @param $folderName
  1444.      * @param $imagesArray
  1445.      * @param string $language
  1446.      * @return array
  1447.      * @throws \Exception
  1448.      */
  1449.     private function loadAllImages( DataObject $relatedObject, $folderName, $imagesArray, $primaryId = null, $language = 'de', $primaryTitle = 'primaryImage' ) : array{
  1451.         $this->dump('-> LoadImages');
  1452.         $imagesArray = $imagesArray ?? [];
  1453.         $assetImage = [
  1454.             'primaryImage' => null,
  1455.             'allImages' => null,
  1456.             'videos' => null
  1457.         ];
  1459.         // Get Image Folder for Tour
  1460.         $folder = \Pimcore\Model\Asset\Service::createFolderByPath( $this->assetImageFolder . $folderName );
  1462.         // Load Available Images
  1463.         $availableImages = [];
  1464.         foreach( $folder->getChildren() as $avImg ){
  1465.             try {
  1466.                 $availableImages[ $avImg->getMetadata('alpstein-img-id') ] = $avImg;
  1467.             } catch(\Exception $e) {
  1468.                 $this->applicationLogger->info("error accessing metadata (Folder: {$folder->getId()}, Image: {$avImg->getId()}): \n{$e->getMessage()}\n\n{$e->getTraceAsString()}", ['component' => 'AlpsteinImportCommand']);
  1469.             }
  1470.         }
  1472.         $this->dump('---> Images Available: ' . (bool)!empty($availableImages));
  1474.         // get all new Images
  1475.         foreach( $imagesArray as $image ){
  1476.             try {
  1478.                 $inGallery = $image->gallery ?? '';
  1479.                 $isVideo = $image->isVideo ?? '';
  1480.                 $isPrimary = $image->primary ?? '';
  1481.                 if( !$isPrimary && !is_null($primaryId) ){
  1482.                     $isPrimary = $primaryId == $image->id ? true : false;
  1483.                 }
  1484.                 $date = new Carbon($image->meta->date->lastModified);
  1486.                 // -- License
  1487.                 $license = false;
  1488.                 if (isset($image->meta) && isset($image->meta->license)) {
  1489.                     $license = $this->getLicenseByFid($image->meta->license->short);
  1490.                 }
  1492.                 $this->dump('-------> Image: ' . ($image->title ?? ' no - title') . ' Primary: ' . (bool)$isPrimary );
  1494.                 if ($isVideo) {
  1495.                     if ($image->video && $image->video->youtubeId) { // only youtube supported for now
  1496.                         $videoObject = AlpsteinVideo::getByAlpsteinId(trim($image->id), 1);
  1497.                         if (!$videoObject instanceof AlpsteinVideo) {
  1498.                             $videoObject = new AlpsteinVideo();
  1499.                             $videoObject->setPublished(true);
  1500.                             $videoObject->setKey(Service::getValidKey(trim($image->id), 'object'));
  1501.                             $videoObject->setParent($this->videosFolder);
  1502.                             $videoObject->setAlpsteinId(trim($image->id));
  1503.                         }
  1505.                         $videoData = new Video();
  1506.                         $videoData->setType('youtube');
  1507.                         $videoData->setData((string)$image->video->youtubeId);
  1508.                         $videoData->setTitle((string)$image->title ?? '');
  1509.                         $videoData->setDescription((string)$image->description);
  1510.                         $videoObject->setVideo($videoData, $language);
  1511.                         $videoObject->setSource( $image->source ?? '' );
  1512.                         if ($license) {
  1513.                             $videoObject->setProperty('ulicense_object', 'object', $license);
  1514.                         } else {
  1515.                             $videoObject->setProperty('ulicense_object', 'object', $this->defaultLicense);
  1516.                         }
  1517.                         $videoObject->save();
  1518.                         $assetImage['videos'][] = $videoObject;
  1519.                     }
  1520.                 } else if( in_array('full', $this->options) || $isPrimary || (isset($availableImages[$image->id]) && (int)$availableImages[$image->id]->getMetadata('last-modified') < $date->timestamp) ){ // wenn voll import oder Primary image
  1521.                     $imageUrl = 'http://img.oastatic.com/img/2048/2048/' . $image->id . '/.jpg';
  1522.                     try {
  1523.                         $loadedImage = \Pimcore\Tool::getHttpData( $imageUrl, [], [], ['timeout' => 60] );
  1524.                     } catch (\Throwable $exception) {
  1525.                         $this->dump('################### ERROR ###################');
  1526.                         $this->dump($exception->getMessage());
  1527.                         $this->dump($exception->getTraceAsString());
  1528.                         $this->dump('################### ERROR ###################');
  1529.                     }
  1531.                     if( $loadedImage ){
  1532.                         $name = \Pimcore\Tool\Transliteration::toASCII($image->title ?? '');
  1533.                         if (strlen($name ?: '') > 50) {
  1534.                             $name = substr($name, 0, 50);
  1535.                         }
  1536.                         $filename = \Pimcore\File::getValidFilename( $name . '-' . $image->id ) . '.jpg';
  1537.                         if ($this->doRemoveICCProfile) {
  1538.                             $loadedImage = \Elements\Bundle\AlpsteinBundle\Tools\Image::removeICCProfile($loadedImage, $filename);
  1539.                         }
  1541.                         if( array_key_exists(trim($image->id), $availableImages) ){
  1542.                             $this->dump('------------> Override Image' );
  1543.                             /**
  1544.                              * @var $editImage Image
  1545.                              */
  1546.                             $newImage = $availableImages[$image->id];
  1547.                             $newImage->setData( $loadedImage );
  1548.                         }else{
  1549.                             $this->dump('------------> new Image' );
  1550.                             $newImage = Image::getByPath( $folder->getFullPath() . '/' . $filename );
  1551.                             if( !$newImage instanceof Image ) {
  1552.                                 $newImage = new Image();
  1553.                             }
  1554.                             $newImage->addMetadata( 'alpstein-img-id', 'input', trim($image->id) );
  1555.                             $newImage->setData($loadedImage);
  1556.                             $newImage->setFilename( $filename );
  1557.                             $newImage->setParent( $folder );
  1558.                             $availableImages[trim($image->id)] = $newImage;
  1559.                         }
  1561.                         $newImage = $this->addImageMetadata($newImage, $image, $language, $date, $inGallery, $isPrimary, $license);
  1563.                         $saveImageSuccess = false;
  1564.                         try {
  1565.                             $newImage->save();
  1566.                             $saveImageSuccess = true;
  1568.                             $this->dump('Image ID:' . $image->id . ' Image: ' . ($image->title ?? 'no-title' ));
  1570.                         } catch (\Throwable $exception) {
  1571.                             if (strpos($exception->getMessage(), 'Duplicate full path') === false) {
  1572.                                 $this->dump('Delete and retry Image ID:' . $image->id . ' Image: ' . ($image->title ?? 'no-title' ) . PHP_EOL . $exception->getMessage());
  1573.                                 try {
  1574.                                     $newImage->delete();
  1575.                                 } catch (\Throwable $e) {
  1576.                                     $this->applicationLogger->info("Could not delete image after error occured\nrecreating image...:\n\n{$exception->getMessage()}\n{$exception->getTraceAsString()}", ['component' => 'AlpsteinImportCommand', 'relatedObject' => $relatedObject]);
  1577.                                 }
  1579.                                 $newImage = new Image();
  1580.                                 $newImage->addMetadata( 'alpstein-img-id', 'input', trim($image->id) );
  1581.                                 $newImage->setData($loadedImage);
  1582.                                 $newImage->setFilename( $filename );
  1583.                                 $newImage->setParent( $folder );
  1584.                                 $availableImages[trim($image->id)] = $newImage;
  1585.                                 $newImage = $this->addImageMetadata($newImage, $image, $language, $date, $inGallery, $isPrimary, $license);
  1586.                                 $newImage->save();
  1587.                                 $saveImageSuccess = true;
  1589.                                 $this->dump('Image ID:' . $image->id . ' Image: ' . ($image->title ?? 'no-title'));
  1590.                             } else {
  1591.                                 $saveImageSuccess = false;
  1592.                                 $this->applicationLogger->error('Could not save Image: ' . PHP_EOL . 'Foldername: ' . $folderName . PHP_EOL . 'Image URL: ' . $imageUrl . PHP_EOL . $exception->getMessage() . PHP_EOL . $exception->getTraceAsString(), ['component' => 'AlpsteinImportCommand', 'relatedObject' => $relatedObject]);
  1593.                             }
  1594.                         }
  1596.                         if( $saveImageSuccess && $isPrimary ){
  1597.                             $assetImage['primaryImage'] = $newImage;
  1598.                         }
  1599.                         if( $saveImageSuccess && $inGallery ){
  1600.                             $assetImage['allImages'][] = $newImage;
  1601.                         }
  1602.                     }
  1604.                 }
  1605.             } catch (\Exception $e) {
  1606.                 $this->applicationLogger->info("Could not import image " .
  1607.                     ($image && $image->id ? $image->id : null) .
  1608.                     "\n{$e->getMessage()}\n\n{$e->getTraceAsString()}",
  1609.                     ['component' => 'AlpsteinImportCommand', 'relatedObject' => $relatedObject]);
  1610.             }
  1611.         }
  1613.         if(empty($assetImage['primaryImage']) && $primaryId) {
  1614.             $newPrimaryImage =  $this->createNewPrimaryImage($primaryId, $folder, $primaryTitle);
  1615.             $assetImage['primaryImage'] = $newPrimaryImage;
  1616.         }
  1618.         foreach( $imagesArray as $img ){
  1619.             if( array_key_exists($img->id, $availableImages) ){
  1620.                 unset($availableImages[$img->id]);
  1621.             }
  1622.         }
  1623.         foreach( $availableImages as $deleteImage ){
  1624.             $deleteImage->delete();
  1625.         }
  1627.         return $assetImage;
  1628.     }
  1630.     private function addImageMetadata($newImage, $image, $language, $date, $inGallery, $isPrimary, $license ) {
  1631.         $imageAuthorName = '';
  1632.         if (isset($image->author)) {
  1633.             $imageAuthorName = $image->author;
  1634.         } else if (isset($image->meta->authorFull)) {
  1635.             $imageAuthorName = $image->meta->authorfull->name;
  1636.         } else if (isset($image->meta->author)) {
  1637.             $imageAuthorName = $image->meta->author;
  1638.         }
  1640.         $imageSourceName = '';
  1641.         $imageSourceUrl = '';
  1642.         if (isset($image->source)) {
  1643.             $imageSourceName = (string)$image->source ?? '';
  1644.         }
  1645.         if ($image->meta->source) {
  1646.             $imageSourceName = (string)$image->meta->source->name ?? '';
  1647.             $imageSourceUrl =  isset($image->meta->source->url) ? (string)$image->meta->source->url : '';
  1648.         }
  1650.         if ($imageAuthorName) {
  1651.             $newImage->addMetadata( 'author', 'input', $imageAuthorName);
  1652.         }
  1653.         if ($imageSourceName) {
  1654.             $newImage->addMetadata('source', 'input', $imageSourceName);
  1655.         }
  1656.         if ($imageSourceUrl) {
  1657.             $newImage->addMetadata('sourceUrl', 'input', $imageSourceUrl);
  1658.         }
  1660.         $newImage->addMetadata( 'copyright', 'input', $image->meta->source->name);
  1661.         $newImage->addMetadata( 'title', 'input', $image->title ?? '', $language );
  1662.         $newImage->addMetadata( 'last-modified', 'input', $date->timestamp );
  1663.         $newImage->addMetadata( 'gallery', 'checkbox', $inGallery );
  1664.         $newImage->addMetadata( 'primary', 'checkbox', $isPrimary );
  1665.         if ($license) {
  1666.             $newImage->setProperty('ulicense_object', 'object', $license);
  1667.         } else {
  1668.             $newImage->setProperty('ulicense_object', 'object', $this->defaultLicense);
  1669.         }
  1670.         return $newImage;
  1671.     }
  1674.     /**
  1675.      * @param $properties
  1676.      * @param string $language
  1677.      * @return array
  1678.      * @throws \Exception
  1679.      */
  1680.     private function tourProperties( $properties, $language = 'de' ){
  1681.         $tourPropertiesArray = [];
  1683.         $properties = $properties ?? [];
  1685.         foreach( $properties as $prop ){
  1686.             $propObj = AlpsteinProperty::getByTag( $prop->tag, [ 'limit' => 1, 'unpublished' => true ] );
  1688.             if( !$propObj instanceof AlpsteinProperty ){
  1689.                 $propObj = new AlpsteinProperty();
  1690.                 $propObj->setKey( \Pimcore\File::getValidFilename($prop->tag . '-' . time() ) );
  1691.                 $propObj->setParent( $this->objectPropertiesFolder );
  1692.                 $propObj->setPublished( true );
  1693.                 $propObj->setTag( $prop->tag );
  1694.             }
  1696.             if (isset($prop->text) && $prop->text != '') {
  1697.                 $propObj->setName( $prop->text, $language );
  1698.             }
  1699.             if(isset($prop->hasIcon)){
  1700.                 $filename = \Pimcore\File::getValidFilename( $prop->text );
  1701.                 $icon = Image::getByPath( $this->assetPropertiesFolder->getFullPath() . '/' . $filename . '.svg' );
  1703.                 //$this->assetPropertiesFolder;
  1704.                 if( !$icon instanceof Image && isset($prop->iconURL) ){
  1705.                     try {
  1706.                         $imageUrl = \Pimcore\Tool::getHttpData($prop->iconURL, [], [], ['timeout' => 60]);
  1707.                     } catch (\Throwable $exception) {
  1708.                         $this->dump('################### ERROR ###################');
  1709.                         $this->dump($exception->getMessage());
  1710.                         $this->dump($exception->getTraceAsString());
  1711.                         $this->dump('################### ERROR ###################');
  1712.                     }
  1713.                     if( $imageUrl ){
  1714.                         $icon = new Image();
  1715.                         $icon->setFilename( $filename . '.svg' );
  1716.                         $icon->setParent( $this->assetPropertiesFolder );
  1717.                         $icon->setData($imageUrl);
  1718.                         $icon->save();
  1719.                         $propObj->setIcon( $icon );
  1720.                     }
  1721.                 }
  1722.             }
  1724.             $propObj->save();
  1725.             $tourPropertiesArray[] = $propObj;
  1727.         }
  1729.         return $tourPropertiesArray;
  1730.     }
  1732.     /**
  1733.      * @param $source
  1734.      * @param string $language
  1735.      */
  1736.     private function createSource($source, $language = 'de' ){
  1738.         if($source && isset($source->id)) {
  1741.             $sourceObj = AlpsteinSource::getBySourceId($source->id, ['limit' => 1, 'unpublished' => true]);
  1743.             if (!$sourceObj instanceof AlpsteinSource) {
  1744.                 $this->dump('------------> new source ' . $source->id);
  1745.                 $sourceObj = new AlpsteinSource();
  1746.                 $sourceObj->setKey(\Pimcore\File::getValidFilename($source->id . '-' . $source->name));
  1747.                 $sourceObj->setParent($this->objectSourceFolder);
  1748.                 $sourceObj->setPublished(true);
  1749.                 $sourceObj->setSourceId($source->id);
  1750.             }
  1752.             if (isset($source->name) && $source->name != '') {
  1753.                 $sourceObj->setName($source->name, $language);
  1754.             }
  1755.             if (isset($source->url) && $source->url != '') {
  1756.                 $sourceObj->setUrl($source->url);
  1757.             }
  1758.             if (!in_array('skip-images', $this->options)) {
  1759.                 if (isset($source->logo)) {
  1760.                     $logo = $source->logo;
  1761.                     $folder = \Pimcore\Model\Asset\Service::createFolderByPath($this->assetSourceFolder . '/' . $source->id);
  1762.                     $sourceLogoAsset = $this->createNewPrimaryImage($logo->id, $folder, '');
  1763.                     if ($sourceLogoAsset instanceof Image) {
  1764.                         $sourceLogoAsset->addMetadata('title', 'input', $logo->title ?? '', $language);
  1766.                         if ($source->name) {
  1767.                             $sourceLogoAsset->addMetadata('source', 'input', $source->name, $language);
  1768.                         }
  1769.                         if ($source->url) {
  1770.                             $sourceLogoAsset->addMetadata('sourceUrl', 'input', $source->url);
  1771.                         }
  1772.                         try {
  1773.                             $sourceLogoAsset->save();
  1774.                         } catch (\Throwable $exception) {
  1775.                             $this->applicationLogger->info("Could not set metadata to source logo asset \n\n{$exception->getMessage()}\n{$exception->getTraceAsString()}",
  1776.                                 ['component' => 'AlpsteinImportCommand', 'relatedObject' => $sourceObj]);
  1778.                         }
  1779.                         $sourceObj->setLogo($sourceLogoAsset);
  1780.                     }
  1781.                 }
  1782.                 if (isset($source->favicon)) {
  1783.                     $favicon = $source->favicon;
  1784.                     $folder = \Pimcore\Model\Asset\Service::createFolderByPath($this->assetSourceFolder . '/' . $source->id);
  1785.                     $sourceFaviconAsset = $this->createNewPrimaryImage($favicon->id, $folder, '');
  1786.                     if ($sourceFaviconAsset instanceof Image) {
  1787.                         $sourceFaviconAsset->addMetadata('title', 'input', $favicon->title ?? '', $language);
  1789.                         if ($source->name) {
  1790.                             $sourceFaviconAsset->addMetadata('source', 'input', $source->name, $language);
  1791.                         }
  1792.                         if ($source->url) {
  1793.                             $sourceFaviconAsset->addMetadata('sourceUrl', 'input', $source->url);
  1794.                         }
  1795.                         try {
  1796.                             $sourceFaviconAsset->save();
  1797.                         } catch (\Throwable $exception) {
  1798.                             $this->applicationLogger->info("Could not set metadata to source favicon asset \n\n{$exception->getMessage()}\n{$exception->getTraceAsString()}",
  1799.                                 ['component' => 'AlpsteinImportCommand', 'relatedObject' => $sourceObj]);
  1801.                         }
  1802.                         $sourceObj->setFavicon($sourceFaviconAsset);
  1803.                     }
  1804.                 }
  1805.             }
  1807.             try {
  1808.                 $sourceObj->save();
  1809.                 return $sourceObj;
  1810.             } catch (\Throwable $exception) {
  1811.                 $this->applicationLogger->info("Could not save source object \n\n{$exception->getMessage()}\n{$exception->getTraceAsString()}",
  1812.                     ['component' => 'AlpsteinImportCommand', 'relatedObject' => $sourceObj]);
  1813.             }
  1814.         }
  1816.         return null;
  1817.     }
  1819.     /**
  1820.      * @param $authorFull
  1821.      */
  1822.     private function createAuthor($authorFull ){
  1823.         if($authorFull && isset($authorFull->id)) {
  1824.             $authorObj = AlpsteinAuthor::getByAuthorId($authorFull->id, ['limit' => 1, 'unpublished' => true]);
  1826.             if (!$authorObj instanceof AlpsteinAuthor) {
  1827.                 $this->dump('------------> new author ' . $authorFull->id);
  1828.                 $authorObj = new AlpsteinAuthor();
  1829.                 $authorObj->setKey(\Pimcore\File::getValidFilename($authorFull->id . '-' . $authorFull->name));
  1830.                 $authorObj->setParent($this->objectAuthorFolder);
  1831.                 $authorObj->setPublished(true);
  1832.                 $authorObj->setAuthorId($authorFull->id);
  1833.             }
  1835.             if (isset($authorFull->name) && $authorFull->name != '') {
  1836.                 $authorObj->setName($authorFull->name);
  1837.             }
  1839.             if (!in_array('skip-images', $this->options)) {
  1840.                 if (isset($authorFull->profileImageId)) {
  1841.                     $folder = \Pimcore\Model\Asset\Service::createFolderByPath($this->assetAuthorFolder . '/' . $authorFull->id);
  1842.                     $authorProfileAsset = $this->createNewPrimaryImage($authorFull->profileImageId, $folder,
  1843.                         $authorFull->name ?? '');
  1844.                     if ($authorProfileAsset instanceof Image) {
  1845.                         $authorProfileAsset->addMetadata('title', 'input', $authorFull->name ?? '');
  1847.                         try {
  1848.                             $authorProfileAsset->save();
  1849.                         } catch (\Throwable $exception) {
  1850.                             $this->applicationLogger->info("Could not set metadata to author profile image asset \n\n{$exception->getMessage()}\n{$exception->getTraceAsString()}",
  1851.                                 ['component' => 'AlpsteinImportCommand', 'relatedObject' => $authorObj]);
  1853.                         }
  1854.                         $authorObj->setProfileImage($authorProfileAsset);
  1855.                     }
  1856.                 }
  1857.             }
  1859.             try {
  1860.                 $authorObj->save();
  1861.                 return $authorObj;
  1862.             } catch (\Throwable $exception) {
  1863.                 $this->applicationLogger->info("Could not save author object \n\n{$exception->getMessage()}\n{$exception->getTraceAsString()}",
  1864.                     ['component' => 'AlpsteinImportCommand', 'relatedObject' => $authorObj]);
  1865.             }
  1866.         }
  1868.         return null;
  1870.     }
  1872.     protected $licenses = [];
  1873.     protected function getLicenseByFid($fid) {
  1874.         if (!array_key_exists($fid, $this->licenses) || !$this->licenses[$fid]) {
  1875.             $db = Db::get();
  1876.             $id = $db->fetchOne('SELECT o_id FROM object_collection_ULicenseFid_ULicense WHERE systemIdentifier = "Alpstein" AND fid = ' . $db->quote($fid));
  1877.             if ($id) {
  1878.                 $this->licenses[$fid] = ULicense::getById($id);
  1879.             }
  1880.         }
  1881.         if (!array_key_exists($fid, $this->licenses) || !$this->licenses[$fid]) {
  1882.             ApplicationLogger::getInstance()->warning('Could not find License for FID ' . $fid, ['component' => 'Alpstein Importer']);
  1883.         }
  1884.         return $this->licenses[$fid];
  1885.     }
  1887.     private function createNewPrimaryImage($primaryId, $folder, $primaryTitle)
  1888.     {
  1889.         $this->dump('------------> new Primary Image' );
  1890.         $imageUrl = 'http://img.oastatic.com/img/2048/2048/' . $primaryId . '/.jpg';
  1891.         try {
  1892.             $loadedImage = \Pimcore\Tool::getHttpData( $imageUrl, [], [], ['timeout' => 60] );
  1893.         } catch (\Throwable $exception) {
  1894.             $this->dump('################### ERROR ###################');
  1895.             $this->dump($exception->getMessage());
  1896.             $this->dump($exception->getTraceAsString());
  1897.             $this->dump('################### ERROR ###################');
  1898.             return null;
  1899.         }
  1900.         if ($loadedImage) {
  1901.             if (strlen($primaryTitle ?: '') > 50) {
  1902.                 $primaryTitle = substr($primaryTitle, 0, 50);
  1903.             }
  1904.             $filename = \Pimcore\File::getValidFilename( $primaryTitle . '-' . $primaryId ) . '.jpg';
  1906.             if ($this->doRemoveICCProfile) {
  1907.                 $loadedImage = \Elements\Bundle\AlpsteinBundle\Tools\Image::removeICCProfile($loadedImage, $filename);
  1908.             }
  1909.             $newImage = Image::getByPath( $folder->getFullPath() . '/' . $filename );
  1910.             if( !$newImage instanceof Image ) {
  1911.                 $newImage = new Image();
  1912.             }
  1913.             $newImage->addMetadata( 'alpstein-img-id', 'input', trim($primaryId) );
  1914.             $newImage->setData($loadedImage);
  1915.             $newImage->setFilename( $filename );
  1916.             $newImage->setParent( $folder );
  1917.             //no metadata in primary Image
  1918. //        $newImage = $this->addImageMetadata($newImage, $image);
  1919.             $newImage->save();
  1920.             return $newImage;
  1921.         }
  1922.         return null;
  1923.     }
  1925.     protected function createTourIdPackages(array $tourIds) {
  1926.         if($this->numToursPerImportIteration) {
  1927.             return array_chunk($tourIds, $this->numToursPerImportIteration);
  1928.         }
  1929.         return [$tourIds]; //single package
  1930.     }
  1932.     /**
  1933.      * @param AlpsteinRegion $region
  1934.      * @param ObjectMetadata[] $objectMetadata
  1935.      */
  1936.     private function getStartingRegionFromOldRegionsArray(AlpsteinRegion $region, array $objectMetadata) {
  1937.         foreach ($objectMetadata as $metadata) {
  1938.             $metadataElement = $metadata->getElement();
  1939.             if($metadataElement instanceof AlpsteinRegion && $metadataElement->getId() === $region->getId()){
  1940.                 return $metadata->getData()['isStartingRegion'];
  1941.             }
  1942.         }
  1943.         return null; //region does not exists => new region
  1944.     }
  1945. }