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\Service;
  30. use Pimcore\Model\DataObject\ULicense;
  31. use Symfony\Component\Console\Input\InputInterface;
  32. use Symfony\Component\Console\Input\InputOption;
  33. use Symfony\Component\Console\Output\OutputInterface;
  35. class ImportCommand extends AbstractCommand
  36. {
  37.     use DryRun;
  39.     const TIMESTAMPFILE = '/alpstein_import_timestamp.tmp';
  41.     protected $alpsteinConfig;
  42.     protected $defaultLicense;
  43.     protected $doRemoveICCProfile;
  44.     protected $minimumRanking;
  45.     protected $importOnlyCCCompliant;
  46.     protected $validLanguage = [];
  47.     protected $categoryFolder;
  48.     protected $regionCache;
  49.     protected $regionFolder;
  50.     protected $regionCategoryFolder;
  51.     protected $tourFolder;
  52.     protected $poiFolder;
  53.     protected $videosFolder;
  54.     protected $assetIconFolder;
  55.     protected $assetImageFolder = '/Alpstein/Images/';
  56.     protected $assetImageFolderObject;
  57.     protected $assetPropertiesFolder;
  58.     protected $objectPropertiesFolder;
  59.     protected $objectKeyFolder;
  60.     protected $importedTourIds = [];
  61.     protected $importedPoiIds = [];
  62.     protected $importedRegions = [];
  64.     protected $options = [];
  65.     protected $numToursPerImportIteration = 0;
  66.     protected $importTime = 0;
  67.     /**
  68.      * @var Client
  69.      */
  70.     private $client;
  71.     private ApplicationLogger $applicationLogger;
  73.     protected function configure()
  74.     {
  75.         $this
  76.             ->setName('alpstein:import')
  77.             ->setDescription('Migrate existing structure to new file extensions')
  78.             ->addOption('full', 'f', null, 'start Full Import')
  79.             ->addOption('regions', 'r', null, 'also includes regions in Import')
  80.             ->addOption('pois', 'p', null, 'also includes pois in Import')
  81.             ->addOption('override', 'o', null, 'Override Images')
  82.             ->addOption('delta', 'd', null, 'Only Import changed Tours')
  83.             ->addOption('skip-images', null, null, 'Ignore Images')
  84.             ->addOption('tourId', null, InputOption::VALUE_OPTIONAL, 'Import selected Tour only')
  85.             ->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)
  86.         ;
  88.         $this->configureDryRunOption();
  89.     }
  91.     /**
  92.      * ImportCommand constructor.
  93.      * @param AlpsteinConfig $alpsteinConfig
  94.      * @param Client $client
  95.      */
  96.     public function __construct(AlpsteinConfig $alpsteinConfig, Client $client, ApplicationLogger $applicationLogger)
  97.     {
  98.         parent::__construct();
  99.         $this->alpsteinConfig = $alpsteinConfig->getConfig();
  100.         $this->doRemoveICCProfile = $alpsteinConfig->doRemoveICCProfile();
  101.         $this->minimumRanking = $alpsteinConfig->getMinimumRanking();
  102.         $this->importOnlyCCCompliant = $alpsteinConfig->getImportOnlyCCCompliant();
  103.         $this->client = $client;
  104.         $this->applicationLogger = $applicationLogger;
  105.     }
  107.     /**
  108.      * @param InputInterface $input
  109.      * @param OutputInterface $output
  110.      * @return int|null|void
  111.      * @throws \GuzzleHttp\Exception\GuzzleException
  112.      */
  113.     protected function execute(InputInterface $input, OutputInterface $output)
  114.     {
  115.         if( $input->getOption('full') ){
  116.             $this->options[] = 'full';
  117.         }
  118.         if( $input->getOption('regions') ){
  119.             $this->options[] = 'regions';
  120.         }
  121.         if( $input->getOption('pois') ){
  122.             $this->options[] = 'pois';
  123.         }
  124.         if( $input->getOption('override') ){
  125.             $this->options[] = 'override';
  126.         }
  127.         if( $input->getOption('delta') ){
  128.             $this->options[] = 'delta';
  129.         }
  130.         if( $input->getOption('skip-images') ){
  131.             $this->options[] = 'skip-images';
  132.         }
  133.         if($input->getOption('tours-per-iterations')) {
  134.             $this->numToursPerImportIteration = (int)$input->getOption('tours-per-iterations');
  135.         }
  136.         $tourId = $input->getOption('tourId');
  140.         $this->validLanguage = ['de'];
  141.         foreach( \Pimcore\Tool::getValidLanguages() as $lang ){
  142.             if( $lang != 'de' ){
  143.                 $this->validLanguage[] = $lang;
  144.             }
  145.         }
  147.         $defaultLicense = ULicense::getByCode('AlpsteinDefault', 1);
  148.         if (!$defaultLicense instanceof ULicense) {
  149.             $defaultLicense = new ULicense();
  150.             $defaultLicense->setKey('AlpsteinDefaultLicense');
  151.             $defaultLicense->setParent(Service::createFolderByPath('Alpstein/License'));
  152.             $defaultLicense->setPublished(true);
  153.             $defaultLicense->setCode('AlpsteinDefault');
  154.             $defaultLicense->setName('Outdooractive AGB', 'de');
  155.             $defaultLicense->setName('Outdooractive Terms of Service', 'en');
  156.             $defaultLicense->save();
  157.         }
  158.         $this->defaultLicense = $defaultLicense;
  160.         $this->categoryFolder = Service::createFolderByPath('/Alpstein/Categories');
  162.         $this->regionFolder = Service::createFolderByPath('/Alpstein/Regions');
  164.         $this->regionCategoryFolder = Service::createFolderByPath('/Alpstein/RegionCategories');
  166.         $this->assetIconFolder = \Pimcore\Model\Asset\Service::createFolderByPath('/Alpstein/Icons');
  168.         $this->tourFolder = Service::createFolderByPath('/Alpstein/Tour');
  170.         $this->poiFolder = Service::createFolderByPath('/Alpstein/Poi');
  172.         $this->assetImageFolderObject = \Pimcore\Model\Asset\Service::createFolderByPath( $this->assetImageFolder );
  174.         $this->assetPropertiesFolder = \Pimcore\Model\Asset\Service::createFolderByPath( '/Alpstein/Properties');
  176.         $this->objectPropertiesFolder = Service::createFolderByPath( '/Alpstein/Properties');
  178.         $this->videosFolder = Service::createFolderByPath( '/Alpstein/Videos');
  180.         $this->objectKeyFolder = Service::createFolderByPath( '/Alpstein/Key');
  182.         $this->importTime = time();
  183.         try {
  184.             if( is_array($this->alpsteinConfig['project']) ){
  185.                 foreach( $this->alpsteinConfig['project'] as $key => $project ){
  186.                     $alpsteinConfig = [
  187.                         'project' => $project,
  188.                         'apiKey' => $this->alpsteinConfig['apiKey'][$key]
  189.                     ];
  190.                     $alpsteinConfig['keyObject'] = $this->createAndGetKey( $alpsteinConfig['project'], $alpsteinConfig['apiKey'] );
  192.                     $this->importCategories( $alpsteinConfig );
  193.                     if ($tourId != '') {
  194.                         $this->importSingleTour($tourId, $alpsteinConfig);
  195.                     } else {
  196.                         if (in_array('regions', $this->options)) {
  197.                             $this->importRegions( $alpsteinConfig );
  198.                         }
  200.                         if (in_array('pois', $this->options)) {
  201.                             $this->importPois( $alpsteinConfig );
  202.                         }
  203.                         $this->importTours( $alpsteinConfig );
  204.                     }
  205.                 }
  206.             } else {
  207.                 $this->alpsteinConfig['keyObject'] = $this->createAndGetKey( $this->alpsteinConfig['project'], $this->alpsteinConfig['apiKey'] );
  208.                 if ($tourId != '') {
  209.                     $this->importSingleTour($tourId, $this->alpsteinConfig);
  210.                 } else {
  211.                     $this->importCategories( $this->alpsteinConfig );
  212.                     if (in_array('regions', $this->options)) {
  213.                         $this->importRegions( $this->alpsteinConfig );
  214.                     }
  215.                     if (in_array('pois', $this->options)) {
  216.                         $this->importPois( $this->alpsteinConfig );
  217.                     }
  218.                     $this->importTours( $this->alpsteinConfig );
  219.                 }
  220.             }
  222.             if (!empty($this->importedTourIds) && !in_array('delta', $this->options) && $tourId == '') {
  223.                 $tours = new AlpsteinTour\Listing();
  224.                 $tours->addConditionParam('alpsteinId IS NOT NULL AND alpsteinId != "" AND alpsteinId NOT IN (' . implode(',', $this->importedTourIds) . ')');
  225.                 foreach ($tours as $tour) {
  226.                     $tour->setPublished(false);
  227.                     $tour->save();
  228.                 }
  229.             }
  230.         } catch (\Exception $exception) {
  231.             $this->applicationLogger->info("Error:\n{$exception->getMessage()}\n\n{$exception->getTraceAsString()}", ['component' => 'AlpsteinImportCommand']);
  232.         }
  234.         if ($tourId == '') {
  235.             file_put_contents(PIMCORE_PRIVATE_VAR . self::TIMESTAMPFILE, $this->importTime);
  236.         }
  238.         return 0;
  239.     }
  242.     /**
  243.      * @param $project
  244.      * @param $apiKey
  245.      * @return AlpsteinKey|AlpsteinKey\Listing
  246.      * @throws \Exception
  247.      */
  248.     private function createAndGetKey( $project, $apiKey ){
  250.         $keyObject = AlpsteinKey::getByApiKey( $apiKey, ['limit' => 1] );
  251.         if( !$keyObject instanceof AlpsteinKey ){
  252.             $keyObject = new AlpsteinKey();
  253.             $keyObject->setName($project);
  254.             $keyObject->setApiKey($apiKey);
  255.             $keyObject->setKey( \Pimcore\File::getValidFilename($project . '-' . $apiKey) );
  256.             $keyObject->setParent( $this->objectKeyFolder );
  257.             $keyObject->setPublished( true );
  258.             $keyObject->save();
  259.         }
  261.         return $keyObject;
  262.     }
  265.     /**
  266.      * Import Categories
  267.      * @param $alpsteinConfig
  268.      * @throws \GuzzleHttp\Exception\GuzzleException
  269.      */
  270.     private function importCategories( $alpsteinConfig )
  271.     {
  273.         foreach( $this->validLanguage as $language ){
  275.             $url = 'https://www.outdooractive.com/api/project/' . $alpsteinConfig['project'] . '/category/tree?lang=' . $language . '&key=' . $alpsteinConfig['apiKey'];
  277.             $client = $this->client;
  278.             $requestType = 'GET';
  279.             $config = [
  280.                 \GuzzleHttp\RequestOptions::ALLOW_REDIRECTS => [
  281.                     'max' => 2
  282.                 ],
  283.                 \GuzzleHttp\RequestOptions::TIMEOUT => 60
  284.             ];
  286.             $config[\GuzzleHttp\RequestOptions::HEADERS] = [
  287.                 'Accept' => 'application/json'
  288.             ];
  290.             /**
  291.              * @var $response \GuzzleHttp\Psr7\Response
  292.              */
  293.             try {
  294.                 $response = $client->request($requestType, $url, $config);
  295.             } catch (\Throwable $exception) {
  296.                 $this->dump('################### ERROR ###################');
  297.                 $this->dump($exception->getMessage());
  298.                 $this->dump($exception->getTraceAsString());
  299.                 $this->dump('################### ERROR ###################');
  300.             }
  302.             if ($response && $response->getStatusCode() == 200) {
  303.                 $data = $response->getBody();
  305.                 $categoryArray = json_decode( $data->getContents() );
  306.                 foreach( $categoryArray as $itemArray ){
  308.                     // Top Category
  309.                     foreach( $itemArray as $item ){
  310.                         $parentId = $this->createCategory( $item, $alpsteinConfig['keyObject'], $this->categoryFolder->getId(), $language );
  312.                         // Sub Category
  313.                         foreach( $item->category ?? [] as $subCategory ){
  314.                             $this->createCategory( $subCategory, $alpsteinConfig['keyObject'], $parentId, $language );
  315.                         }
  316.                     }
  317.                 }
  318.             }
  319.         }
  320.     }
  323.     /**
  324.      * Import Categories
  325.      * @param $alpsteinConfig
  326.      * @throws \GuzzleHttp\Exception\GuzzleException
  327.      */
  328.     private function importRegions( $alpsteinConfig )
  329.     {
  330.         foreach( $this->validLanguage as $language ){
  331.             $url = 'https://www.outdooractive.com/api/project/' . $alpsteinConfig['project'] . '/region/tree?lang=' . $language . '&key=' . $alpsteinConfig['apiKey'];
  333.             $client = $this->client;
  334.             $requestType = 'GET';
  335.             $config = [
  336.                 \GuzzleHttp\RequestOptions::ALLOW_REDIRECTS => [
  337.                     'max' => 2
  338.                 ],
  339.                 \GuzzleHttp\RequestOptions::TIMEOUT => 60
  340.             ];
  342.             $config[\GuzzleHttp\RequestOptions::HEADERS] = [
  343.                 'Accept' => 'application/json'
  344.             ];
  346.             /**
  347.              * @var $response \GuzzleHttp\Psr7\Response
  348.              */
  349.             try {
  350.                 $response = $client->request($requestType, $url, $config);
  351.             } catch (\Throwable $exception) {
  352.                 $this->dump('################### ERROR ###################');
  353.                 $this->dump($exception->getMessage());
  354.                 $this->dump($exception->getTraceAsString());
  355.                 $this->dump('################### ERROR ###################');
  356.             }
  357.             if ($response && $response->getStatusCode() == 200) {
  358.                 $data = $response->getBody();
  360.                 $regionArray = json_decode( $data->getContents() );
  361.                 foreach( $regionArray->region as $regionData ){
  362.                     $this->createRegion($regionData, $this->regionFolder->getId(), $language, $alpsteinConfig['keyObject']);
  363.                 }
  364.             }
  365.         }
  366.     }
  369.     /**
  370.      * @param $item
  371.      * @param null $parentId
  372.      * @param string $language
  373.      * @param $keyObject AlpsteinKey
  374.      * @return int
  375.      * @throws \Exception
  376.      */
  377.     private function createCategory( $item, $keyObject, $parentId = null, $language = 'de' ){
  379.         $category = AlpsteinCategory::getByCategoryId( (int)$item->id, 1 );
  381.         if( !$category instanceof AlpsteinCategory ){
  382.             $category = new AlpsteinCategory();
  383.             $category->setParentId( $parentId );
  384.             $category->setPublished( true );
  385.             $category->setKey( \Pimcore\File::getValidFilename( $item->name . '-' . $item->id ) );
  386.             $category->setCategoryId((int)$item->id);
  388.             if( $language == 'de' && !$category->getIcon() instanceof Image ){
  389.                 if( isset($item->iconUrl) ){
  391.                     preg_match('/^.*\.(jpg|jpeg|png|gif|svg)$/i', $item->iconUrl, $reg);
  392.                     $imageName = \Pimcore\File::getValidFilename( $item->name . '-' . $item->id ) . '.' . $reg[1];
  393.                     $image = Image::getByPath( $this->assetIconFolder->getFullPath() . '/' . $imageName );
  395.                     if( !$image instanceof Image ){
  397.                         try {
  398.                             $iconUrl = \Pimcore\Tool::getHttpData($item->iconUrl, [], [], ['timeout' => 60]);
  399.                         } catch (\Throwable $exception) {
  400.                             $this->dump('################### ERROR ###################');
  401.                             $this->dump($exception->getMessage());
  402.                             $this->dump($exception->getTraceAsString());
  403.                             $this->dump('################### ERROR ###################');
  404.                         }
  405.                         if( $iconUrl ){
  406.                             $image = new Image();
  407.                             $image->setData( $iconUrl );
  408.                             $image->setFilename( $imageName = \Pimcore\File::getValidFilename( $item->name . '-' . $item->id ) . '.' . $reg[1] );
  409.                             $image->setParent( $this->assetIconFolder );
  410.                             $image->save();
  411.                             $category->setIcon($image);
  412.                         }
  414.                     }else{
  415.                         $category->setIcon($image);
  416.                     }
  417.                 }
  418.             }
  419.         }
  421.         $catAlpsteinKeys = $category->getAlpsteinKey();
  422.         $hasKey = false;
  423.         foreach( $catAlpsteinKeys as $keyObj ){
  424.             if( $keyObj->getApiKey() == $keyObject->getApiKey() ){
  425.                 $hasKey = true;
  426.                 break;
  427.             }
  428.         }
  429.         if( !$hasKey ){
  430.             $catAlpsteinKeys[] = $keyObject;
  431.         }
  432.         $category->setAlpsteinKey( $catAlpsteinKeys );
  435.         $category->setModificationDate( time() );
  436.         $category->setName( $item->name, $language );
  437.         $category->save();
  439.         return $category->getId();
  440.     }
  445.     /**
  446.      * @param $regionData
  447.      * @param $parentId
  448.      * @param string $language
  449.      * @param $keyObject AlpsteinKey
  450.      * @throws \Exception
  451.      */
  452.     private function createRegion( $regionData, $parentId, $language = 'de', $keyObject ){
  453.         if (array_key_exists($language, $this->importedRegions) && array_key_exists($regionData->id, $this->importedRegions[$language]) && ($region = $this->importedRegions[$language][$regionData->id])) {
  454.             return $region;
  455.         }
  457.         $region = AlpsteinRegion::getByAlpsteinId( (int)$regionData->id, 1 );
  459.         if( !$region instanceof AlpsteinRegion ){
  460.             $region = new AlpsteinRegion();
  461.             $region->setParentId( $parentId );
  462.             $region->setPublished( true );
  463.             $region->setKey( \Pimcore\File::getValidFilename( $regionData->name . '-' . $regionData->id ) );
  464.             $region->setAlpsteinId((int)$regionData->id);
  465.         }
  466.         $alpsteinKeys = $region->getAlpsteinKey();
  467.         $hasKey = false;
  468.         foreach( $alpsteinKeys as $keyObj ){
  469.             if( $keyObj->getApiKey() == $keyObject->getApiKey() ){
  470.                 $hasKey = true;
  471.                 break;
  472.             }
  473.         }
  474.         if( !$hasKey ){
  475.             $alpsteinKeys[] = $keyObject;
  476.         }
  477.         $region->setAlpsteinKey( $alpsteinKeys );
  479.         $region->setModificationDate( time() );
  480.         $region->setName( $regionData->name, $language );
  481.         $region->setRegionType( $regionData->type );
  482.         $region->setLevel( $regionData->level );
  483.         $region->setHasTour($regionData->hasTour);
  484.         if ($regionData->bbox) {
  485.             $geodata = explode(',', $regionData->bbox);
  486.             $southWest = new GeoCoordinates($geodata[1], $geodata[0]);
  487.             $northEast = new GeoCoordinates($geodata[3], $geodata[2]);
  488.             $bbox = new Geobounds($northEast, $southWest);
  489.             $region->setBbox($bbox);
  490.         }
  492.         $region->setCategory($this->createRegionCategory($regionData->categoryId, $regionData->categoryTitle, $language, $keyObject));
  494.         $region->save();
  495.         $subregions = $region->getSubRegions();
  496.         $containingRegions = [];
  497.         foreach ($subregions ?: [] as $subRegionObj) {
  498.             $containingRegions[] = $subRegionObj->getAlpsteinId();
  499.         }
  500.         if (!empty($regionData->region)) {
  501.             foreach ($regionData->region as $subRegionData) {
  502.                 $subRegion = $this->createRegion($subRegionData, $region->getId(), $language, $keyObject);
  503.                 if (!in_array($subRegion->getAlpsteinId(), $containingRegions)) {
  504.                     $subregions[] = $subRegion;
  505.                     $containingRegions[] = $subRegion->getAlpsteinId();
  506.                 }
  507.             }
  508.         }
  510.         $region->setSubRegions($subregions);
  511.         $region->save();
  513.         $this->importedRegions[$language][$regionData->id] = $region;
  515.         return $region;
  517.     }
  519.     /**
  520.      * @param $regionCategoryId
  521.      * @param $regionCategoryName
  522.      * @param string $language
  523.      * @param $keyObject AlpsteinKey
  524.      * @return AlpsteinRegionCategory
  525.      * @throws \Exception
  526.      */
  527.     private function createRegionCategory( $regionCategoryId, $regionCategoryName, $language = 'de', $keyObject ){
  529.         $regionCategory = AlpsteinRegionCategory::getByAlpsteinId( (int)$regionCategoryId, 1 );
  531.         if( !$regionCategory instanceof AlpsteinRegionCategory ){
  532.             $regionCategory = new AlpsteinRegionCategory();
  533.             $regionCategory->setParentId( $this->regionCategoryFolder->getId() );
  534.             $regionCategory->setPublished( true );
  535.             $regionCategory->setKey( \Pimcore\File::getValidFilename( $regionCategoryName . '-' . $regionCategoryId ) );
  536.             $regionCategory->setAlpsteinId((int)$regionCategoryId);
  537.         }
  539.         $alpsteinKeys = $regionCategory->getAlpsteinKey();
  540.         $hasKey = false;
  541.         foreach( $alpsteinKeys as $keyObj ){
  542.             if( $keyObj->getApiKey() == $keyObject->getApiKey() ){
  543.                 $hasKey = true;
  544.                 break;
  545.             }
  546.         }
  547.         if( !$hasKey ){
  548.             $alpsteinKeys[] = $keyObject;
  549.         }
  550.         $regionCategory->setAlpsteinKey( $alpsteinKeys );
  551.         $regionCategory->setName( $regionCategoryName, $language );
  554.         $regionCategory->setModificationDate( time() );
  556.         $regionCategory->save();
  558.         return $regionCategory;
  559.     }
  561.     private function importSingleTour ($tourObjectId, $alpsteinConfig) {
  562.         $tour = AlpsteinTour::getById($tourObjectId);
  563.         if ($tour instanceof AlpsteinTour) {
  564.             $lastImport = 0;
  565.             $importTimeStampFile = PIMCORE_PRIVATE_VAR . '/alpstein-single-import-' . $tourObjectId . '.txt';
  566.             if (file_exists($importTimeStampFile)) {
  567.                 $lastImport = file_get_contents($importTimeStampFile);
  568.             }
  569.             if ($lastImport < strtotime('-2 hours')) {
  570.                 file_put_contents((string)time(), $importTimeStampFile);
  571.                 $tourId = $tour->getAlpsteinId();
  572.                 foreach ($this->validLanguage as $language) {
  573.                     $url = 'https://www.outdooractive.com/api/project/' . $alpsteinConfig['project'] . '/oois/' . $tourId . '?lang=' . $language . '&key=' . $alpsteinConfig['apiKey'];
  574.                     $client = $this->client;
  575.                     $requestType = 'GET';
  576.                     $config = [
  577.                         \GuzzleHttp\RequestOptions::ALLOW_REDIRECTS => [
  578.                             'max' => 2
  579.                         ],
  580.                         \GuzzleHttp\RequestOptions::TIMEOUT => 60
  581.                     ];
  583.                     $config[\GuzzleHttp\RequestOptions::HEADERS] = [
  584.                         'Accept' => 'application/json'
  585.                     ];
  587.                     /**
  588.                      * @var $response \GuzzleHttp\Psr7\Response
  589.                      */
  590.                     try {
  591.                         $response = $client->request($requestType, $url, $config);
  592.                     } catch (\Throwable $exception) {
  593.                         $this->dump('################### ERROR ###################');
  594.                         $this->dump($exception->getMessage());
  595.                         $this->dump($exception->getTraceAsString());
  596.                         $this->dump('################### ERROR ###################');
  597.                     }
  599.                     if ($response && $response->getStatusCode() == 200) {
  600.                         $data = $response->getBody();
  602.                         $tourArray = json_decode($data->getContents());
  603.                         if( $tourArray->tour[0] && in_array($language, $tourArray->tour[0]->meta->translation ) ){
  604.                             $this->createTour( $tourArray->tour[0], $language, $alpsteinConfig['keyObject'] );
  605.                         }
  606.                     }
  607.                 }
  608.                 unlink($importTimeStampFile);
  609.             }
  610.         }
  611.     }
  613.     private function importTours( $alpsteinConfig ){
  614.         $tourIds = $this->importTourIdList($alpsteinConfig);
  615.         $tourIdPackages = $this->createTourIdPackages($tourIds);
  616.         $numPackages = count($tourIdPackages);
  617.         try {
  618.             foreach ($tourIdPackages as $key => $tourIds) {
  619.                 $this->applicationLogger->info('Tour Import Package #' . $key+1 . "/{$numPackages}", ['component' => 'AlpsteinImportCommand']);
  620.                 $this->dump("Importing package #" . ($key + 1) . "/{$numPackages}; package size: " . count($tourIds));
  621.                 foreach ($this->validLanguage as $language) {
  622.                     foreach ($tourIds as $tourId) {
  623.                         $url = 'https://www.outdooractive.com/api/project/' . $alpsteinConfig['project'] . '/oois/' . $tourId . '?lang=' . $language . '&key=' . $alpsteinConfig['apiKey'];
  625.                         $client = $this->client;
  626.                         $requestType = 'GET';
  627.                         $config = [
  628.                             \GuzzleHttp\RequestOptions::ALLOW_REDIRECTS => [
  629.                                 'max' => 2
  630.                             ],
  631.                             \GuzzleHttp\RequestOptions::TIMEOUT => 60
  632.                         ];
  634.                         $config[\GuzzleHttp\RequestOptions::HEADERS] = [
  635.                             'Accept' => 'application/json'
  636.                         ];
  638.                         /**
  639.                          * @var $response \GuzzleHttp\Psr7\Response
  640.                          */
  641.                         try {
  642.                             $response = $client->request($requestType, $url, $config);
  643.                         } catch (\Throwable $exception) {
  644.                             $this->dump('################### ERROR ###################');
  645.                             $this->dump($exception->getMessage());
  646.                             $this->dump($exception->getTraceAsString());
  647.                             $this->dump('################### ERROR ###################');
  648.                         }
  650.                         if ($response && $response->getStatusCode() == 200) {
  651.                             $data = $response->getBody();
  653.                             $tourArray = json_decode($data->getContents());
  654.                             if ($tourArray->tour[0] && in_array($language, $tourArray->tour[0]->meta->translation)) {
  655.                                 $this->createTour($tourArray->tour[0], $language, $alpsteinConfig['keyObject']);
  656.                             }
  657.                         }
  658.                         $this->dump(" ");
  659.                     }
  660.                 }
  661.                 \Pimcore::collectGarbage();
  662.             }
  663.         } catch (\Throwable $e) {
  664.             $this->applicationLogger->info("Error while importing tour\n{$e->getMessage()}\n\n{$e->getTraceAsString()}", ['component' => 'AlpsteinImportCommand']);
  665.         }
  666.         $this->dump('----> Done');
  667.     }
  669.     private function importPois( $alpsteinConfig ){
  670.         $poiIds = $this->importPoiIdList($alpsteinConfig);
  671.         foreach ($this->validLanguage as $language) {
  672.             foreach( $poiIds as $poiId ){
  673.                 $url = 'https://www.outdooractive.com/api/project/' . $alpsteinConfig['project'] . '/oois/' . $poiId . '?lang=' . $language . '&key=' . $alpsteinConfig['apiKey'];
  675.                 $client = $this->client;
  676.                 $requestType = 'GET';
  677.                 $config = [
  678.                     \GuzzleHttp\RequestOptions::ALLOW_REDIRECTS => [
  679.                         'max' => 2
  680.                     ],
  681.                     \GuzzleHttp\RequestOptions::TIMEOUT => 60
  682.                 ];
  684.                 $config[\GuzzleHttp\RequestOptions::HEADERS] = [
  685.                     'Accept' => 'application/json'
  686.                 ];
  688.                 /**
  689.                  * @var $response \GuzzleHttp\Psr7\Response
  690.                  */
  691.                 try {
  692.                     $response = $client->request($requestType, $url, $config);
  693.                 } catch (\Throwable $exception) {
  694.                     $this->dump('################### ERROR ###################');
  695.                     $this->dump($exception->getMessage());
  696.                     $this->dump($exception->getTraceAsString());
  697.                     $this->dump('################### ERROR ###################');
  698.                 }
  700.                 if ($response && $response->getStatusCode() == 200) {
  701.                     $data = $response->getBody();
  703.                     $poiArray = json_decode($data->getContents());
  705.                     if( $poiArray->poi[0] && in_array($language, $poiArray->poi[0]->meta->translation ) ){
  706.                         $this->createPoi( $poiArray->poi[0], $language, $alpsteinConfig['keyObject'] );
  707.                     }
  708.                 }
  709.                 $this->dump(" ");
  710.             }
  711.         }
  712.         $this->dump('----> Done');
  713.     }
  715.     /**
  716.      * Import List of Id's
  717.      * @param string $language
  718.      * @return array
  719.      * @throws \GuzzleHttp\Exception\GuzzleException
  720.      */
  721.     private function importTourIdList( $alpsteinConfig, $language = 'de' ) : array {
  722.         $tourIds = [];
  725.         $url = 'https://www.outdooractive.com/api/project/' . $alpsteinConfig['project'] . '/tours?key=' . $alpsteinConfig['apiKey'];
  726.         if (in_array('delta', $this->options) && file_exists(PIMCORE_PRIVATE_VAR . self::TIMESTAMPFILE)) {
  727.             $timestamp = Carbon::createFromTimestamp((int)file_get_contents(PIMCORE_PRIVATE_VAR . self::TIMESTAMPFILE));
  728.             $url .= '&lastModifiedAfter=' . $timestamp->format('d.m.Y');
  729.         }
  730.         $client = $this->client;
  731.         $requestType = 'GET';
  732.         $config = [
  733.             \GuzzleHttp\RequestOptions::ALLOW_REDIRECTS => [
  734.                 'max' => 2
  735.             ],
  736.             \GuzzleHttp\RequestOptions::TIMEOUT => 60
  737.         ];
  739.         $config[\GuzzleHttp\RequestOptions::HEADERS] = [
  740.             'Accept' => 'application/json'
  741.         ];
  743.         /**
  744.          * @var $response \GuzzleHttp\Psr7\Response
  745.          */
  746.         try {
  747.             $response = $client->request($requestType, $url, $config);
  748.         } catch (\Throwable $exception) {
  749.             $this->dump('################### ERROR ###################');
  750.             $this->dump($exception->getMessage());
  751.             $this->dump($exception->getTraceAsString());
  752.             $this->dump('################### ERROR ###################');
  753.             $this->applicationLogger->info("error importing tour: \n{$exception->getMessage()}", ['component' => 'AlpsteinImportCommand']);
  754.         }
  756.         if ($response && $response->getStatusCode() == 200) {
  757.             $data = $response->getBody();
  759.             $tourArray = json_decode($data->getContents());
  761.             foreach ($tourArray->data ?? [] as $itemArray) {
  763.                 $tourIds[] = $itemArray->id;
  764.             }
  765.         }
  768.         return $tourIds;
  769.     }
  771.     /**
  772.      * Import List of Id's
  773.      * @param string $language
  774.      * @return array
  775.      * @throws \GuzzleHttp\Exception\GuzzleException
  776.      */
  777.     private function importPoiIdList( $alpsteinConfig, $language = 'de' ) : array {
  778.         $poiIds = [];
  781.         $url = 'https://www.outdooractive.com/api/project/' . $alpsteinConfig['project'] . '/pois?key=' . $alpsteinConfig['apiKey'];
  783.         if (in_array('delta', $this->options) && file_exists(PIMCORE_PRIVATE_VAR . self::TIMESTAMPFILE)) {
  784.             $timestamp = Carbon::createFromTimestamp((int)file_get_contents(PIMCORE_PRIVATE_VAR . self::TIMESTAMPFILE));
  785.             $url .= '&lastModifiedAfter=' . $timestamp->format('d.m.Y');
  786.         }
  787.         $client = $this->client;
  788.         $requestType = 'GET';
  789.         $config = [
  790.             \GuzzleHttp\RequestOptions::ALLOW_REDIRECTS => [
  791.                 'max' => 2
  792.             ],
  793.             \GuzzleHttp\RequestOptions::TIMEOUT => 60
  794.         ];
  796.         $config[\GuzzleHttp\RequestOptions::HEADERS] = [
  797.             'Accept' => 'application/json'
  798.         ];
  800.         /**
  801.          * @var $response \GuzzleHttp\Psr7\Response
  802.          */
  803.         try {
  804.             $response = $client->request($requestType, $url, $config);
  805.         } catch (\Throwable $exception) {
  806.             $this->dump('################### ERROR ###################');
  807.             $this->dump($exception->getMessage());
  808.             $this->dump($exception->getTraceAsString());
  809.             $this->dump('################### ERROR ###################');
  810.         }
  812.         if ($response && $response->getStatusCode() == 200) {
  813.             $data = $response->getBody();
  815.             $poiArray = json_decode($data->getContents());
  817.             foreach ($poiArray->data as $itemArray) {
  819.                 $poiIds[] = $itemArray->id;
  820.             }
  821.         }
  824.         return $poiIds;
  825.     }
  828.     // Create or Update Tour
  829.     private function createTour( $tour, $language = 'de', $keyObject ){
  830.         /** not yet considered Fields:
  831.          * - lineOptions
  832.          * - riskPotential
  833.          * - exposition
  834.          * - wayType
  835.          * - elements
  836.          * - difficulties
  837.          * - literature
  838.          * - maps
  839.          * - bookWorks
  840.          * - mapWorks
  841.          * - localizedTitle
  842.          * - type
  843.          * - frontendtype
  844.          * - license
  845.          */
  847.         $tourObject = AlpsteinTour::getByAlpsteinId( (int)$tour->id, [ 'limit' => 1, 'unpublished' => true ] );
  849.         // ignore tours not meeting minimumRanking condition and unpublish if already exists
  850.         if ($this->minimumRanking && $tour->ranking < $this->minimumRanking) {
  851.             if ($tourObject instanceof AlpsteinTour) {
  852.                 $tourObject->setPublished(false);
  853.                 $tourObject->save();
  854.             }
  855.             return;
  856.         }
  858.         if( !$tourObject instanceof AlpsteinTour ){
  859.             $tourObject = new AlpsteinTour();
  860.             $tourObject->setKey( \Pimcore\File::getValidFilename( ($tour->title ?? 'no-title') . '-' . $tour->id ) );
  861.             $tourObject->setAlpsteinId( (int)$tour->id );
  862.             $tourObject->setParent( $this->tourFolder );
  863.             $tourObject->save();
  864.         }
  867.         $catAlpsteinKeys = $tourObject->getAlpsteinKey();
  868.         $hasKey = false;
  869.         foreach( $catAlpsteinKeys as $keyObj ){
  870.             if( $keyObj->getApiKey() == $keyObject->getApiKey() ){
  871.                 $hasKey = true;
  872.                 break;
  873.             }
  874.         }
  875.         if( !$hasKey ){
  876.             $catAlpsteinKeys[] = $keyObject;
  877.         }
  878.         $tourObject->setAlpsteinKey( $catAlpsteinKeys );
  880.         $this->dump('-> Tour: ' . $tourObject->getName('de') . '(' . $tourObject->getId() . ')');
  882.         $published = false;
  883.         if( $tour->meta->workflow->state == 'published' ){
  884.             $published = true;
  885.         }
  886.         if ($tourObject->getId() == '' ) {
  887.             p_r($tour->meta->workflow); die();
  888.         }
  889.         $tourObject->setPublished( $published );
  891.         $tourObject->setName( $tour->title ?? '', $language );
  892.         $tourObject->setRanking($tour->ranking ?? '');
  894.         // Destination
  895.         $tourObject->setDestination( $tour->destination ?? '', $language );
  896.         //ShortText
  897.         $tourObject->setShortText( $tour->shortText ?? '', $language );
  899.         // Longtext
  900.         $tourObject->setLongText( $tour->longText ?? '', $language );
  902.         // Import all Images and return an array [ primaryImage, allImages ]
  905.         $primaryId = null;
  906.         $primaryTitle = 'primaryImage';
  908.         if( isset($tour->primaryImage) && isset($tour->primaryImage->id) ){
  910.             $primaryId = $tour->primaryImage->id;
  911.             if(isset($tour->primaryImage->title)) {
  912.                 $primaryTitle = $tour->primaryImage->title;
  913.             }
  914.         }
  916.         if (!in_array('skip-images', $this->options)) {
  917.             if( isset( $tour->images ) ){
  918.                 $images = $this->loadAllImages( $tourObject, $tour->id, $tour->images->image, $primaryId, $language, $primaryTitle );
  919.                 if( !is_null( $images[ 'primaryImage' ] ) ){
  920.                     $tourObject->setPrimaryImage( $images[ 'primaryImage' ] );
  921.                 }
  922.                 if( !is_null( $images[ 'videos' ] ) ){
  923.                     $tourObject->setVideos( $images[ 'videos' ] );
  924.                 }
  925.                 if( in_array( 'full', $this->options ) ){
  926.                     if( !is_null( $images[ 'allImages' ] ) ){
  927.                         $tourObject->setImages( $images[ 'allImages' ] );
  928.                     }
  929.                 }
  930.             }
  931.         }
  934.         // set Category
  935.         $category = AlpsteinCategory::getByCategoryId( $tour->category->id, [ 'limit' => 1, 'unpublished' => true ] );
  936.         if( $category ){
  937.             $tourObject->setCategory([ $category ]);
  938.         }
  940.         // Opened
  941.         if (isset( $tour->opened ) && $tour->opened !== null){
  942.             $tourObject->setOpened($tour->opened);
  943.         } else {
  944.             $tourObject->setOpened(true);
  945.         }
  947.         // -- Regions
  948.         $oldRegions = $tourObject->getRegions();
  949.         if( isset($tour->regions) && isset($tour->regions->region) ) {
  950.             $regions = [];
  951.             foreach ($tour->regions->region as $regionData) {
  953.                 if (!isset($this->regionCache[$regionData->id]) instanceof AlpsteinRegion) {
  954.                     $this->regionCache[$regionData->id] = AlpsteinRegion::getByAlpsteinId((string) $regionData->id, 1);
  955.                 }
  957.                 $region = $this->regionCache[$regionData->id];
  958.                 if ($region instanceof AlpsteinRegion) {
  959.                     $objectMetadata = new ObjectMetadata('regions', ['isStartingRegion'], $region);
  960.                     $oldIsStartingRegion = null;
  961.                     if($tourObject->getDoNotUpdateStartingRegion()) { //if not set, always update starting region
  962.                         $oldIsStartingRegion = $this->getStartingRegionFromOldRegionsArray($region, $oldRegions);
  963.                     }
  964.                     if($oldIsStartingRegion === null) {
  965.                         if (isset($regionData->isStartRegion)) {
  966.                             $objectMetadata->setIsStartingRegion(true);
  967.                         } else {
  968.                             $objectMetadata->setIsStartingRegion(false);
  969.                         }
  970.                     } else { //old region did exist + getDoNotUpdateStartingRegion === true
  971.                         $objectMetadata->setIsStartingRegion($oldIsStartingRegion);
  972.                     }
  973.                     $regions[] = $objectMetadata;
  974.                 }
  975.             }
  976.             $tourObject->setRegions($regions);
  977.         }
  978.         // -- Texte
  979.         if( in_array( 'full', $this->options ) ){
  980.             // global
  981.             $tourObject->setStartingPointDesc( $tour->startingPointDescr ?? '', $language );
  982.             // transit
  983.             $tourObject->setPublicTransit( $tour->publicTransit ?? '', $language );
  984.             // getting There
  985.             $tourObject->setGettingThere( $tour->gettingThere ?? '', $language );
  986.             // parking
  987.             $tourObject->setParking( $tour->parking ?? '', $language );
  988.             // Safety Guide
  989.             $tourObject->setSafetyGuidlines( $tour->safetyGuidlines ?? '', $language );
  990.             // Tip
  991.             $tourObject->setTip( $tour->tip ?? '', $language );
  992.             // Additional Information
  993.             $tourObject->setEquipment( $tour->equipment ?? '', $language );
  995.             // Additional Information
  996.             $tourObject->setAdditionalInformation( $tour->additionalInformation ?? '', $language );
  997.             // Direction
  998.             $tourObject->setDirections( $tour->directions ?? '', $language);
  1000.             // -- Labels
  1002.             // top
  1003.             $tourObject->setTop( $tour->labels->top ?? '' );
  1005.             //publicTransportFriendly
  1006.             if( isset( $tour->labels) ){
  1007.                 $tourObject->setPublicTransportFriendly( $tour->labels->publicTransportFriendly ?? '' );
  1008.             }
  1010.             // winter activity
  1011.             $tourObject->setWinterActivity( $tour->winterActivity ?? '' );
  1013.             // -- Data
  1015.             // Publisher ID
  1016.             $tourObject->setPublisherID( $tour->meta->source->id ?? '' );
  1018.             // Time Min
  1019.             $tourObject->setTimeMin( $tour->time->min ?? '' );
  1020.             // Length
  1021.             $tourObject->setLength( $tour->length ?? '' );
  1023.             // Elevation
  1024.             $tourObject->setElevationAscent( $tour->elevation->ascent ?? '' );
  1025.             $tourObject->setElevationDescent( $tour->elevation->descent ?? '' );
  1026.             $tourObject->setElevationMinAltitude( $tour->elevation->minAltitude ?? '' );
  1027.             $tourObject->setElevationMaxAltitude( $tour->elevation->maxAltitude ?? '' );
  1028.             $tourObject->setElevationProfileId( $tour->elevationProfile->id ?? '');
  1030.             // Rating
  1031.             $tourObject->setRatingCondition( $tour->rating->condition ?? '' );
  1032.             $tourObject->setRatingDifficulty( $tour->rating->difficulty ?? '' );
  1033.             $tourObject->setRatingTechnique( $tour->rating->technique ?? '' );
  1034.             $tourObject->setRatingQualityExp( $tour->rating->qualityOfExperience ?? '' );
  1035.             $tourObject->setRatingLandscape( $tour->rating->landscape ?? '' );
  1037.             // -- Season
  1038.             foreach( [ 'jan', 'feb', 'mar', 'apr', 'may', 'jun', 'jul', 'aug', 'sep', 'oct', 'nov', 'dec' ] as $season ){
  1040.                 $setter = 'set' . ucfirst($season);
  1041.                 $tourObject->$setter( $tour->season->{$season} );
  1043.             }
  1044.             // -- License
  1045.             $license = false;
  1046.             if (isset($tour->meta) && isset($tour->meta->license)) {
  1047.                 $license = $this->getLicenseByFid($tour->meta->license->short);
  1048.             }
  1050.             if ($license) {
  1051.                 $tourObject->setProperty('ulicense_object', 'object', $license);
  1052.             } else {
  1053.                 $tourObject->setProperty('ulicense_object', 'object', $this->defaultLicense);
  1054.             }
  1056.             $pois = [];
  1057.             if( isset( $tour->pois ) ){
  1058.                 foreach ($tour->pois->poi ?? [] as $poi) {
  1059.                     $poiObject = AlpsteinPoi::getByAlpsteinId($poi->id, 1);
  1060.                     if ($poiObject instanceof AlpsteinPoi) {
  1061.                         $objectMetadata = new ObjectMetadata('pois', ['isElevationProfilePoi', 'isReststopPoi', 'isRecommendationPoi'], $poiObject);
  1062.                         if ($poi->isElevationProfilePoi ?? false) {
  1063.                             $objectMetadata->setIsElevationProfilePoi(true);
  1064.                         }
  1065.                         if ($poi->isReststopPoi ?? false) {
  1066.                             $objectMetadata->setIsReststopPoi(true);
  1067.                         }
  1068.                         if ($poi->isRecommendationPoi ?? false) {
  1069.                             $objectMetadata->setIsRecommendationPoi(true);
  1070.                         }
  1071.                         $pois[] = $objectMetadata;
  1072.                     }
  1073.                 }
  1074.             }
  1075.             $tourObject->setPois($pois);
  1077.             // -- GEO
  1078.             // Destination
  1079.             $tourObject->setDestination( $tour->destination ?? '', $language );
  1080.             // startingPoint
  1081.             $startingGeo = new GeoCoordinates();
  1082.             $startingGeo->setLatitude( $tour->startingPoint->lat );
  1083.             $startingGeo->setLongitude( $tour->startingPoint->lon );
  1084.             $tourObject->setStartingPoint( $startingGeo );
  1086.             // geoPositions (tour)
  1087.             $tourObject->setGeometry( $tour->geometry );
  1090.             // -- Properties
  1091.             if( isset( $tour->properties)){
  1092.                 $tourProperties = $this->tourProperties( $tour->properties->property ?? '', $language );
  1093.                 $tourObject->setTourProperties( $tourProperties );
  1094.             }
  1095.         } // end only full import
  1097.         $tourObject->save();
  1098.         $this->importedTourIds[] = $tourObject->getAlpsteinId();
  1099.     }
  1102.     // Create or Update Poi
  1103.     private function createPoi( $poi, $language = 'de', $keyObject ){
  1104.         /** not yet considered Fields:
  1105.          * - frontendtype
  1106.          * - license
  1107.          */
  1109.         $poiObject = AlpsteinPoi::getByAlpsteinId( (int)$poi->id, [ 'limit' => 1, 'unpublished' => true ] );
  1111.         // ignore tours not meeting minimumRanking condition and unpublish if already exists
  1112.         if ($this->minimumRanking && $poi->ranking < $this->minimumRanking) {
  1113.             if ($poiObject instanceof AlpsteinPoi) {
  1114.                 $poiObject->setPublished(false);
  1115.                 $poiObject->save();
  1116.             }
  1117.             return;
  1118.         }
  1120.         if( !$poiObject instanceof AlpsteinPoi ){
  1121.             $poiObject = new AlpsteinPoi();
  1122.             $poiObject->setKey( \Pimcore\File::getValidFilename( $poi->title . '-' . $poi->id ) );
  1123.             $poiObject->setAlpsteinId( (int)$poi->id );
  1124.             $poiObject->setParent( $this->poiFolder );
  1125.             $poiObject->save();
  1126.         }
  1129.         $catAlpsteinKeys = $poiObject->getAlpsteinKey();
  1130.         $hasKey = false;
  1131.         foreach( $catAlpsteinKeys as $keyObj ){
  1132.             if( $keyObj->getApiKey() == $keyObject->getApiKey() ){
  1133.                 $hasKey = true;
  1134.                 break;
  1135.             }
  1136.         }
  1137.         if( !$hasKey ){
  1138.             $catAlpsteinKeys[] = $keyObject;
  1139.         }
  1140.         $poiObject->setAlpsteinKey( $catAlpsteinKeys );
  1142.         $this->dump('-> POI: ' . $poiObject->getName('de') . '(' . $poiObject->getId() . ')');
  1144.         $published = false;
  1145.         if( $poi->meta->workflow->state == 'published' ){
  1146.             $published = true;
  1147.         }
  1148.         if ($poiObject->getId() == '' ) {
  1149.             p_r($poi->meta->workflow); die();
  1150.         }
  1151.         $poiObject->setPublished( $published );
  1153.         $poiObject->setName( $poi->title ?? '', $language );
  1154.         $poiObject->setRanking($poi->ranking ?? '');
  1155.         $poiObject->setFrontendType($poi->frontendtype ?? '');
  1157.         //ShortText
  1158.         $poiObject->setShortText( $poi->shortText ?? '', $language );
  1160.         // Longtext
  1161.         $poiObject->setLongText( $poi->longText ?? '', $language );
  1163.         // Import all Images and return an array [ primaryImage, allImages ]
  1165.         $primaryId = null;
  1166.         $primaryTitle = 'primaryImage';
  1168.         if( isset($poi->primaryImage) && isset($poi->primaryImage->id) ){
  1170.             $primaryId = $poi->primaryImage->id;
  1171.             if(isset($poi->primaryImage->title)) {
  1172.                 $primaryTitle = $poi->primaryImage->title;
  1173.             }
  1174.         }
  1176.         if (!in_array('skip-images', $this->options)) {
  1177.             if (isset($poi->images)) {
  1178.                 $images = $this->loadAllImages($poiObject, $poi->id, $poi->images->image, $primaryId, $language,
  1179.                     $primaryTitle);
  1181.                 if (!is_null($images['primaryImage'])) {
  1182.                     $poiObject->setPrimaryImage($images['primaryImage']);
  1183.                 }
  1185.                 if (!is_null($images['videos'])) {
  1186.                     $poiObject->setVideos($images['videos']);
  1187.                 }
  1189.                 if (in_array('full', $this->options)) {
  1190.                     if (!is_null($images['allImages'])) {
  1191.                         $poiObject->setImages($images['allImages']);
  1192.                     }
  1193.                 }
  1194.             }
  1195.         }
  1196.         // set Category
  1197.         $category = AlpsteinCategory::getByCategoryId( $poi->category->id, [ 'limit' => 1, 'unpublished' => true ] );
  1198.         if( $category ){
  1199.             $poiObject->setCategory([ $category ]);
  1200.         }
  1202.         // -- Labels
  1204.         // top
  1205.         $poiObject->setTop( $poi->labels->top ?? '' );
  1206.         // winter activity
  1207.         $poiObject->setWinterActivity( $poi->winterActivity ?? '' );
  1208.         $poiObject->setAltitude( $poi->altitude ?? '' );
  1209.         // contact data
  1210.         $poiObject->setStreet($poi->address->street ?? '');
  1211.         $poiObject->setZipcode($poi->address->zipcode ?? '');
  1212.         $poiObject->setTown($poi->address->town ?? '');
  1213.         $poiObject->setHomepage($poi->homepage ?? '');
  1214.         $poiObject->setEmail($poi->email ?? '');
  1215.         $poiObject->setPhone($poi->phone ?? '');
  1217.         // Texte
  1218.         $poiObject->setPublicTransit($poi->publicTransit ?? '', $language);
  1219.         $poiObject->setGettingThere($poi->gettingThere ?? '', $language);
  1220.         $poiObject->setParking($poi->parking ?? '', $language);
  1222.         // Publisher ID
  1223.         $poiObject->setPublisherID( $poi->meta->source->id ?? '');
  1225.         // -- Regions
  1226.         if( isset($poi->regions) && isset($poi->regions->region) ) {
  1227.             $regions = [];
  1228.             foreach ($poi->regions->region as $regionData) {
  1229.                 if (!isset($this->regionCache[$regionData->id]) || !$this->regionCache[$regionData->id] instanceof AlpsteinRegion) {
  1230.                     $this->regionCache[$regionData->id] = AlpsteinRegion::getByAlpsteinId((string) $regionData->id, 1);
  1231.                 }
  1232.                 $region = $this->regionCache[$regionData->id];
  1233.                 if ($region instanceof AlpsteinRegion) {
  1234.                     $objectMetadata = new ObjectMetadata('regions', ['isStartingRegion'], $region);
  1235.                     if ($regionData->isStartRegion) {
  1236.                         $objectMetadata->setIsStartingRegion(true);
  1237.                     }
  1238.                     $regions[] = $objectMetadata;
  1239.                 }
  1240.             }
  1241.             $poiObject->setRegions($regions);
  1242.         }
  1244.         // -- GEO
  1245.         // positions
  1246.         if (isset($poi->geometry)) {
  1247.             $posData = explode(',', $poi->geometry);
  1248.             $poiObject->setPosition( new GeoCoordinates($posData[0], $posData[1]) );
  1249.         }
  1251.         // -- Properties
  1252.         $poiProperties = $this->tourProperties( $poi->properties->property ?? [], $language );
  1253.         $poiObject->setPoiProperties( $poiProperties );
  1255.         $poiObject->setBusinessHours($poi->businessHours ?? '', $language);
  1256.         $this->poiSetOpeningTimes($poiObject, $poi->openingHours ?? []);
  1258.         $poiObject->save();
  1259.         $this->importedTourIds[] = $poiObject->getAlpsteinId();
  1261.     }
  1263.     private function poiSetOpeningTimes($object, $openingHours = []) {
  1265.         $dates = $object->getOpeningTimes();
  1266.         if (!$dates) {
  1267.             $dates = new RecurringDateDefinition();
  1268.         }
  1269.         $definitionArray = [];
  1271.         if (!empty($openingHours->weekday->openTime)) {
  1273.             // as no daterange is given for the general openingtimes, but recurring dates needs a
  1274.             // daterange (otherwise for fromDate and toDate the current date from the import will be used),
  1275.             // the first day of the year is used for fromDate and the last day of the next year is for toDate
  1277.             $times = [];
  1278.             $dayMapping = [
  1279.                 'Monday' => 'mo',
  1280.                 'Tuesday' => 'tu',
  1281.                 'Wednesday' => 'we',
  1282.                 'Thursday' => 'th',
  1283.                 'Friday' => 'fr',
  1284.                 'Saturday' => 'sa',
  1285.                 'Sunday' => 'su',
  1286.             ];
  1289.             // start to get the times for every weekday
  1290.             foreach ($openingHours->weekday->openTime ?? [] as $date) {
  1291.                 foreach ($date->openHours ?? [] as $openHour) {
  1292.                     $timeFrom = $openHour->from ?? null;
  1293.                     $timeTo = $openHour->to ?? null;
  1294.                     $weekday = $dayMapping[$date->weekday];
  1295.                     $times[$weekday]['times'][] = [
  1296.                         'start' => $timeFrom == '24:00' ? '23:59' : $timeFrom,
  1297.                         'end' => $timeTo == '24:00' ? '23:59' : $timeTo
  1298.                     ];
  1299.                 }
  1300.             }
  1302.             // combine all identical time entries to only get one entry for the same time on different weekdays
  1303.             $identicalTimes = [];
  1304.             $hashes = [];
  1305.             foreach ($times as $weekday => $time) {
  1306.                 $hash = hash('sha256', serialize($time));
  1308.                 if (isset($hashes[$hash])) {
  1309.                     $identicalTimes[$hash] = array_merge($identicalTimes[$hash], [
  1310.                         $weekday => true
  1311.                     ]);
  1312.                 } else {
  1314.                     $hashes[$hash] = $weekday;
  1315.                     $identicalTimes[$hash] = array_merge($time, [
  1316.                         $weekday => true,
  1317.                         'fromDate' => Carbon::today()->setMonth(1)->setDay(1)->format('Y-m-d'),
  1318.                         'toDate' => Carbon::today()->setMonth(12)->setDay(31)->addYear()->format('Y-m-d'),
  1319.                     ]);
  1320.                 }
  1321.             }
  1323.             foreach ($identicalTimes as $entries) {
  1324.                 $definitionArray[] = [
  1325.                     'type' => RecurringDateDefinition::DEFINITION_TYPE_RECURRING_DATE_TIME,
  1326.                     'values' => $entries,
  1327.                 ];
  1328.             }
  1329.         }
  1331.         if (!empty($openingHours->special->openTime)) {
  1333.             $times = ['times' => []];
  1334.             foreach ($openingHours->special->openTime as $openTime) {
  1335.                 foreach ($openTime->openHours ?? [] as $openHour) {
  1336.                     $timeFrom = $openHour->from ?? null;
  1337.                     $timeTo = $openHour->to ?? null;
  1338.                     $times = [
  1339.                         'times' => [
  1340.                             [
  1341.                                 'start' => $timeFrom == '24:00' ? '23:59' : $timeFrom,
  1342.                                 'end' => $timeTo == '24:00' ? '23:59' : $timeTo
  1343.                             ]
  1344.                         ],
  1345.                         'mo' => in_array('MON', $openHour->days ?? []),
  1346.                         'tu' => in_array('TUE', $openHour->days ?? []),
  1347.                         'we' => in_array('WED', $openHour->days ?? []),
  1348.                         'th' => in_array('THU', $openHour->days ?? []),
  1349.                         'fr' => in_array('FRI', $openHour->days ?? []),
  1350.                         'sa' => in_array('SAT', $openHour->days ?? []),
  1351.                         'su' => in_array('SUN', $openHour->days ?? []),
  1352.                     ];
  1353.                 }
  1355.                 // special opening times depend on a time range, and can also be excluded
  1356.                 $definitionArray[] = [
  1357.                     'type' => RecurringDateDefinition::DEFINITION_TYPE_RECURRING_DATE_TIME,
  1358.                     'values' =>  array_merge([
  1359.                         'fromDate' => (string)$openTime->dateFrom,
  1360.                         'toDate' => (string)$openTime->dateTo,
  1361.                         'excluded' => $openTime->isOpen != 'true',
  1362.                     ], $times)
  1363.                 ];
  1364.             }
  1365.         }
  1367.         $dates->setDefinitionArray($definitionArray);
  1368.         $object->setOpeningTimes($dates);
  1369.     }
  1372.     /**
  1373.      * @param DataObject $relatedObject
  1374.      * @param $folderName
  1375.      * @param $imagesArray
  1376.      * @param string $language
  1377.      * @return array
  1378.      * @throws \Exception
  1379.      */
  1380.     private function loadAllImages( DataObject $relatedObject, $folderName, $imagesArray, $primaryId = null, $language = 'de', $primaryTitle = 'primaryImage' ) : array{
  1382.         $this->dump('-> LoadImages');
  1383.         $imagesArray = $imagesArray ?? [];
  1384.         $assetImage = [
  1385.             'primaryImage' => null,
  1386.             'allImages' => null,
  1387.             'videos' => null
  1388.         ];
  1390.         // Get Image Folder for Tour
  1391.         $folder = \Pimcore\Model\Asset\Service::createFolderByPath( $this->assetImageFolder . $folderName );
  1393.         // Load Available Images
  1394.         $availableImages = [];
  1395.         foreach( $folder->getChildren() as $avImg ){
  1396.             try {
  1397.                 $availableImages[ $avImg->getMetadata('alpstein-img-id') ] = $avImg;
  1398.             } catch(\Exception $e) {
  1399.                 $this->applicationLogger->info("error accessing metadata (Folder: {$folder->getId()}, Image: {$avImg->getId()}): \n{$e->getMessage()}\n\n{$e->getTraceAsString()}", ['component' => 'AlpsteinImportCommand']);
  1400.             }
  1401.         }
  1403.         $this->dump('---> Images Available: ' . (bool)!empty($availableImages));
  1405.         // get all new Images
  1406.         foreach( $imagesArray as $image ){
  1407.             try {
  1409.                 $inGallery = $image->gallery ?? '';
  1410.                 $isVideo = $image->isVideo ?? '';
  1411.                 $isPrimary = $image->primary ?? '';
  1412.                 if( !$isPrimary && !is_null($primaryId) ){
  1413.                     $isPrimary = $primaryId == $image->id ? true : false;
  1414.                 }
  1415.                 $date = new Carbon($image->meta->date->lastModified);
  1417.                 // -- License
  1418.                 $license = false;
  1419.                 if (isset($image->meta) && isset($image->meta->license)) {
  1420.                     $license = $this->getLicenseByFid($image->meta->license->short);
  1421.                 }
  1423.                 $this->dump('-------> Image: ' . ($image->title ?? ' no - title') . ' Primary: ' . (bool)$isPrimary );
  1425.                 if ($isVideo) {
  1426.                     if ($image->video && $image->video->youtubeId) { // only youtube supported for now
  1427.                         $videoObject = AlpsteinVideo::getByAlpsteinId(trim($image->id), 1);
  1428.                         if (!$videoObject instanceof AlpsteinVideo) {
  1429.                             $videoObject = new AlpsteinVideo();
  1430.                             $videoObject->setPublished(true);
  1431.                             $videoObject->setKey(Service::getValidKey(trim($image->id), 'object'));
  1432.                             $videoObject->setParent($this->videosFolder);
  1433.                             $videoObject->setAlpsteinId(trim($image->id));
  1434.                         }
  1436.                         $videoData = new Video();
  1437.                         $videoData->setType('youtube');
  1438.                         $videoData->setData((string)$image->video->youtubeId);
  1439.                         $videoData->setTitle((string)$image->title ?? '');
  1440.                         $videoData->setDescription((string)$image->description);
  1441.                         $videoObject->setVideo($videoData, $language);
  1442.                         $videoObject->setSource( $image->source ?? '' );
  1443.                         if ($license) {
  1444.                             $videoObject->setProperty('ulicense_object', 'object', $license);
  1445.                         } else {
  1446.                             $videoObject->setProperty('ulicense_object', 'object', $this->defaultLicense);
  1447.                         }
  1448.                         $videoObject->save();
  1449.                         $assetImage['videos'][] = $videoObject;
  1450.                     }
  1451.                 } 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
  1452.                     $imageUrl = 'http://img.oastatic.com/img/2048/2048/' . $image->id . '/.jpg';
  1453.                     try {
  1454.                         $loadedImage = \Pimcore\Tool::getHttpData( $imageUrl, [], [], ['timeout' => 60] );
  1455.                     } catch (\Throwable $exception) {
  1456.                         $this->dump('################### ERROR ###################');
  1457.                         $this->dump($exception->getMessage());
  1458.                         $this->dump($exception->getTraceAsString());
  1459.                         $this->dump('################### ERROR ###################');
  1460.                     }
  1462.                     if( $loadedImage ){
  1463.                         $name = \Pimcore\Tool\Transliteration::toASCII($image->title ?? '');
  1464.                         if (strlen($name ?: '') > 50) {
  1465.                             $name = substr($name, 0, 50);
  1466.                         }
  1467.                         $filename = \Pimcore\File::getValidFilename( $name . '-' . $image->id ) . '.jpg';
  1468.                         if ($this->doRemoveICCProfile) {
  1469.                             $loadedImage = \Elements\Bundle\AlpsteinBundle\Tools\Image::removeICCProfile($loadedImage, $filename);
  1470.                         }
  1472.                         if( array_key_exists(trim($image->id), $availableImages) ){
  1473.                             $this->dump('------------> Override Image' );
  1474.                             /**
  1475.                              * @var $editImage Image
  1476.                              */
  1477.                             $newImage = $availableImages[$image->id];
  1478.                             $newImage->setData( $loadedImage );
  1479.                         }else{
  1480.                             $this->dump('------------> new Image' );
  1481.                             $newImage = Image::getByPath( $folder->getFullPath() . '/' . $filename );
  1482.                             if( !$newImage instanceof Image ) {
  1483.                                 $newImage = new Image();
  1484.                             }
  1485.                             $newImage->addMetadata( 'alpstein-img-id', 'input', trim($image->id) );
  1486.                             $newImage->setData($loadedImage);
  1487.                             $newImage->setFilename( $filename );
  1488.                             $newImage->setParent( $folder );
  1489.                             $availableImages[trim($image->id)] = $newImage;
  1490.                         }
  1492.                         $newImage = $this->addImageMetadata($newImage, $image, $language, $date, $inGallery, $isPrimary, $license);
  1494.                         $saveImageSuccess = false;
  1495.                         try {
  1496.                             $newImage->save();
  1497.                             $saveImageSuccess = true;
  1499.                             $this->dump('Image ID:' . $image->id . ' Image: ' . ($image->title ?? 'no-title' ));
  1501.                         } catch (\Throwable $exception) {
  1502.                             if (strpos($exception->getMessage(), 'Duplicate full path') === false) {
  1503.                                 $this->dump('Delete and retry Image ID:' . $image->id . ' Image: ' . ($image->title ?? 'no-title' ) . PHP_EOL . $exception->getMessage());
  1504.                                 try {
  1505.                                     $newImage->delete();
  1506.                                 } catch (\Throwable $e) {
  1507.                                     $this->applicationLogger->info("Could not delete image after error occured\nrecreating image...:\n\n{$exception->getMessage()}\n{$exception->getTraceAsString()}", ['component' => 'AlpsteinImportCommand', 'relatedObject' => $relatedObject]);
  1508.                                 }
  1510.                                 $newImage = new Image();
  1511.                                 $newImage->addMetadata( 'alpstein-img-id', 'input', trim($image->id) );
  1512.                                 $newImage->setData($loadedImage);
  1513.                                 $newImage->setFilename( $filename );
  1514.                                 $newImage->setParent( $folder );
  1515.                                 $availableImages[trim($image->id)] = $newImage;
  1516.                                 $newImage = $this->addImageMetadata($newImage, $image, $language, $date, $inGallery, $isPrimary, $license);
  1517.                                 $newImage->save();
  1518.                                 $saveImageSuccess = true;
  1520.                                 $this->dump('Image ID:' . $image->id . ' Image: ' . ($image->title ?? 'no-title'));
  1521.                             } else {
  1522.                                 $saveImageSuccess = false;
  1523.                                 $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]);
  1524.                             }
  1525.                         }
  1527.                         if( $saveImageSuccess && $isPrimary ){
  1528.                             $assetImage['primaryImage'] = $newImage;
  1529.                         }
  1530.                         if( $saveImageSuccess && $inGallery ){
  1531.                             $assetImage['allImages'][] = $newImage;
  1532.                         }
  1533.                     }
  1535.                 }
  1536.             } catch (\Exception $e) {
  1537.                 $this->applicationLogger->info("Could not import image " .
  1538.                     ($image && $image->id ? $image->id : null) .
  1539.                     "\n{$e->getMessage()}\n\n{$e->getTraceAsString()}",
  1540.                     ['component' => 'AlpsteinImportCommand', 'relatedObject' => $relatedObject]);
  1541.             }
  1542.         }
  1544.         if(empty($assetImage['primaryImage']) && $primaryId) {
  1545.             $newPrimaryImage =  $this->createNewPrimaryImage($primaryId, $folder, $primaryTitle);
  1546.             $assetImage['primaryImage'] = $newPrimaryImage;
  1547.         }
  1549.         foreach( $imagesArray as $img ){
  1550.             if( array_key_exists($img->id, $availableImages) ){
  1551.                 unset($availableImages[$img->id]);
  1552.             }
  1553.         }
  1554.         foreach( $availableImages as $deleteImage ){
  1555.             $deleteImage->delete();
  1556.         }
  1558.         return $assetImage;
  1559.     }
  1561.     private function addImageMetadata($newImage, $image, $language, $date, $inGallery, $isPrimary, $license ) {
  1562.         $imageAuthorName = '';
  1563.         if (isset($image->author)) {
  1564.             $imageAuthorName = $image->author;
  1565.         } else if (isset($image->meta->authorFull)) {
  1566.             $imageAuthorName = $image->meta->authorfull->name;
  1567.         } else if (isset($image->meta->author)) {
  1568.             $imageAuthorName = $image->meta->author;
  1569.         }
  1571.         $imageSourceName = '';
  1572.         $imageSourceUrl = '';
  1573.         if (isset($image->source)) {
  1574.             $imageSourceName = (string)$image->source ?? '';
  1575.         }
  1576.         if ($image->meta->source) {
  1577.             $imageSourceName = (string)$image->meta->source->name ?? '';
  1578.             $imageSourceUrl =  isset($image->meta->source->url) ? (string)$image->meta->source->url : '';
  1579.         }
  1581.         if ($imageAuthorName) {
  1582.             $newImage->addMetadata( 'author', 'input', $imageAuthorName);
  1583.         }
  1584.         if ($imageSourceName) {
  1585.             $newImage->addMetadata('source', 'input', $imageSourceName);
  1586.         }
  1587.         if ($imageSourceUrl) {
  1588.             $newImage->addMetadata('sourceUrl', 'input', $imageSourceUrl);
  1589.         }
  1591.         $newImage->addMetadata( 'copyright', 'input', $image->meta->source->name);
  1592.         $newImage->addMetadata( 'title', 'input', $image->title ?? '', $language );
  1593.         $newImage->addMetadata( 'last-modified', 'input', $date->timestamp );
  1594.         $newImage->addMetadata( 'gallery', 'checkbox', $inGallery );
  1595.         $newImage->addMetadata( 'primary', 'checkbox', $isPrimary );
  1596.         if ($license) {
  1597.             $newImage->setProperty('ulicense_object', 'object', $license);
  1598.         } else {
  1599.             $newImage->setProperty('ulicense_object', 'object', $this->defaultLicense);
  1600.         }
  1601.         return $newImage;
  1602.     }
  1605.     /**
  1606.      * @param $properties
  1607.      * @param string $language
  1608.      * @return array
  1609.      * @throws \Exception
  1610.      */
  1611.     private function tourProperties( $properties, $language = 'de' ){
  1612.         $tourPropertiesArray = [];
  1614.         $properties = $properties ?? [];
  1616.         foreach( $properties as $prop ){
  1617.             $propObj = AlpsteinProperty::getByTag( $prop->tag, [ 'limit' => 1, 'unpublished' => true ] );
  1619.             if( !$propObj instanceof AlpsteinProperty ){
  1620.                 $propObj = new AlpsteinProperty();
  1621.                 $propObj->setKey( \Pimcore\File::getValidFilename($prop->tag . '-' . time() ) );
  1622.                 $propObj->setParent( $this->objectPropertiesFolder );
  1623.                 $propObj->setPublished( true );
  1624.                 $propObj->setTag( $prop->tag );
  1625.             }
  1627.             if (isset($prop->text) && $prop->text != '') {
  1628.                 $propObj->setName( $prop->text, $language );
  1629.             }
  1630.             if(isset($prop->hasIcon)){
  1631.                 $filename = \Pimcore\File::getValidFilename( $prop->text );
  1632.                 $icon = Image::getByPath( $this->assetPropertiesFolder->getFullPath() . '/' . $filename . '.svg' );
  1634.                 //$this->assetPropertiesFolder;
  1635.                 if( !$icon instanceof Image && isset($prop->iconURL) ){
  1636.                     try {
  1637.                         $imageUrl = \Pimcore\Tool::getHttpData($prop->iconURL, [], [], ['timeout' => 60]);
  1638.                     } catch (\Throwable $exception) {
  1639.                         $this->dump('################### ERROR ###################');
  1640.                         $this->dump($exception->getMessage());
  1641.                         $this->dump($exception->getTraceAsString());
  1642.                         $this->dump('################### ERROR ###################');
  1643.                     }
  1644.                     if( $imageUrl ){
  1645.                         $icon = new Image();
  1646.                         $icon->setFilename( $filename . '.svg' );
  1647.                         $icon->setParent( $this->assetPropertiesFolder );
  1648.                         $icon->setData($imageUrl);
  1649.                         $icon->save();
  1650.                         $propObj->setIcon( $icon );
  1651.                     }
  1652.                 }
  1653.             }
  1655.             $propObj->save();
  1656.             $tourPropertiesArray[] = $propObj;
  1658.         }
  1660.         return $tourPropertiesArray;
  1661.     }
  1663.     protected $licenses = [];
  1664.     protected function getLicenseByFid($fid) {
  1665.         if (!array_key_exists($fid, $this->licenses) || !$this->licenses[$fid]) {
  1666.             $db = Db::get();
  1667.             $id = $db->fetchOne('SELECT o_id FROM object_collection_ULicenseFid_ULicense WHERE systemIdentifier = "Alpstein" AND fid = ' . $db->quote($fid));
  1668.             if ($id) {
  1669.                 $this->licenses[$fid] = ULicense::getById($id);
  1670.             }
  1671.         }
  1672.         if (!array_key_exists($fid, $this->licenses) || !$this->licenses[$fid]) {
  1673.             ApplicationLogger::getInstance()->warning('Could not find License for FID ' . $fid, ['component' => 'Alpstein Importer']);
  1674.         }
  1675.         return $this->licenses[$fid];
  1676.     }
  1678.     private function createNewPrimaryImage($primaryId, $folder, $primaryTitle)
  1679.     {
  1680.         $this->dump('------------> new Primary Image' );
  1681.         $imageUrl = 'http://img.oastatic.com/img/2048/2048/' . $primaryId . '/.jpg';
  1682.         try {
  1683.             $loadedImage = \Pimcore\Tool::getHttpData( $imageUrl, [], [], ['timeout' => 60] );
  1684.         } catch (\Throwable $exception) {
  1685.             $this->dump('################### ERROR ###################');
  1686.             $this->dump($exception->getMessage());
  1687.             $this->dump($exception->getTraceAsString());
  1688.             $this->dump('################### ERROR ###################');
  1689.             return null;
  1690.         }
  1691.         if ($loadedImage) {
  1692.             if (strlen($primaryTitle ?: '') > 50) {
  1693.                 $primaryTitle = substr($primaryTitle, 0, 50);
  1694.             }
  1695.             $filename = \Pimcore\File::getValidFilename( $primaryTitle . '-' . $primaryId ) . '.jpg';
  1697.             if ($this->doRemoveICCProfile) {
  1698.                 $loadedImage = \Elements\Bundle\AlpsteinBundle\Tools\Image::removeICCProfile($loadedImage, $filename);
  1699.             }
  1700.             $newImage = Image::getByPath( $folder->getFullPath() . '/' . $filename );
  1701.             if( !$newImage instanceof Image ) {
  1702.                 $newImage = new Image();
  1703.             }
  1704.             $newImage->addMetadata( 'alpstein-img-id', 'input', trim($primaryId) );
  1705.             $newImage->setData($loadedImage);
  1706.             $newImage->setFilename( $filename );
  1707.             $newImage->setParent( $folder );
  1708.             //no metadata in primary Image
  1709. //        $newImage = $this->addImageMetadata($newImage, $image);
  1710.             $newImage->save();
  1711.             return $newImage;
  1712.         }
  1713.         return null;
  1714.     }
  1716.     protected function createTourIdPackages(array $tourIds) {
  1717.         if($this->numToursPerImportIteration) {
  1718.             return array_chunk($tourIds, $this->numToursPerImportIteration);
  1719.         }
  1720.         return [$tourIds]; //single package
  1721.     }
  1723.     /**
  1724.      * @param AlpsteinRegion $region
  1725.      * @param ObjectMetadata[] $objectMetadata
  1726.      */
  1727.     private function getStartingRegionFromOldRegionsArray(AlpsteinRegion $region, array $objectMetadata) {
  1728.         foreach ($objectMetadata as $metadata) {
  1729.             $metadataElement = $metadata->getElement();
  1730.             if($metadataElement instanceof AlpsteinRegion && $metadataElement->getId() === $region->getId()){
  1731.                 return $metadata->getData()['isStartingRegion'];
  1732.             }
  1733.         }
  1734.         return null; //region does not exists => new region
  1735.     }
  1736. }