Файловый менеджер

Файловый менеджер - Редактировать - /home/lmsyaran/public_html/administrator/components/com_jea/gateways/import.php

Назад
<?php /** * This file is part of Joomla Estate Agency - Joomla! extension for real estate agency * * @package Joomla.Administrator * @subpackage com_jea * @copyright Copyright (C) 2008 - 2020 PHILIP Sylvain. All rights reserved. * @license GNU General Public License version 2 or later; see LICENSE.txt / defined('_JEXEC') or die; require_once JPATH_COMPONENT_ADMINISTRATOR . '/gateways/gateway.php'; /* * The base class for import gateways * * @since 3.4 / abstract class JeaGatewayImport extends JeaGateway { /* * Delete Jea properties which are not included in the import set * * @var boolean / protected $autoDeletion = true; /* * Remember the last import * * @var boolean / protected $persistance = false; /* * The number of properties to import. * Used to split the import in several requests (AJAX) * * @var integer / protected $propertiesPerStep = 0; /* * The number of properties created during import * * @var integer / protected $created = 0; /* * The number of properties updated during import * * @var integer / protected $updated = 0; /* * The number of properties created or imported during import * * @var integer / protected $imported = 0; /* * The number of properties removed during import * * @var integer / protected $removed = 0; /* * The number of properties that should be imported * * @var integer / protected $total = 0; /* * Array of properties already imported * * @var array / protected $importedProperties = array(); /* * Constructor * * @param object $subject The object to observe * @param array $config An optional associative array of configuration settings. / public function __construct(&$subject, $config = array()) { parent::__construct($subject, $config); $this->autoDeletion = (bool) $this->params->get('auto_deletion', 0); } /* * Remember the last import * * @return void / public function activatePersistance() { $this->persistance = true; $this->propertiesPerStep = $this->params->get('properties_per_step', 5); } /* * InitWebConsole event handler * * @return void / public function initWebConsole() { JHtml::script('media/com_jea/js/admin/gateway.js'); $title = addslashes($this->title); // Register script messages JText::script('COM_JEA_IMPORT_START_MESSAGE', true); JText::script('COM_JEA_IMPORT_END_MESSAGE', true); JText::script('COM_JEA_GATEWAY_PROPERTIES_FOUND', true); JText::script('COM_JEA_GATEWAY_PROPERTIES_CREATED', true); JText::script('COM_JEA_GATEWAY_PROPERTIES_UPDATED', true); JText::script('COM_JEA_GATEWAY_PROPERTIES_DELETED', true); $script = "jQuery(document).on('registerGatewayAction', function(event, webConsole, dispatcher) {\n" . " dispatcher.register(function() {\n" . " JeaGateway.startImport($this->id, '$title', webConsole);\n" . " });\n" . "});"; JFactory::getDocument()->addScriptDeclaration($script); } /* * Method called before the import * This could be overriden in child class * * @return void / protected function beforeImport() { } /* * Method called after the import * This could be overriden in child class * * @return void / protected function afterImport() { } /* * The import handler method * * @return array the import summary / public function import() { if ($this->persistance == true && $this->hasPersistentProperties()) { $properties = $this->getPersistentProperties(); } else { $this->beforeImport(); $properties = & $this->parse(); } $this->total = count($properties); if (empty($this->total)) { // Do nothing if there is no properties return $this->getSummary(); } $idsToRemove = array(); $db = JFactory::getDbo(); $query = $db->getQuery(true); $query->select('')->from('#__jea_properties'); if (! empty($this->provider)) { $query->where('provider=' . $db->quote($this->provider)); } $db->setQuery($query); $existingProperties = $db->loadObjectList(); foreach ($existingProperties as $row) { if (isset($this->importedProperties[$row->ref])) { // Property already been imported continue; } if (isset($properties[$row->ref]) && $properties[$row->ref] instanceof JEAPropertyInterface) { if ($this->persistance == true && $this->propertiesPerStep > 0 && $this->updated == $this->propertiesPerStep) { break; } // Verify update time $date = new JDate($row->modified); if ($date->toUnix() < $properties[$row->ref]->modified) { // Update needed if ($properties[$row->ref]->save($this->provider, $row->id)) { $this->updated ++; } } $this->imported ++; $this->importedProperties[$row->ref] = true; unset($properties[$row->ref]); } elseif ($this->autoDeletion === true) { // Property not in the $imported_properties // So we can delete it if the autodeletion option is set to true $idsToRemove[] = $row->id; } } if ($this->autoDeletion === true) { // Remove outdated properties $this->removeProperties($idsToRemove); } foreach ($properties as $ref => $row) { if ($this->persistance == true && $this->propertiesPerStep > 0 && ($this->updated + $this->created) == $this->propertiesPerStep) { break; } if ($row instanceof JEAPropertyInterface) { if ($row->save($this->provider)) { $this->created ++; $this->importedProperties[$ref] = true; } else { $msg = "Property can't be saved : "; foreach ($row->getErrors() as $error) { $msg .= " $error\n"; } $this->log($msg, 'WARN'); JError::raiseNotice(200, "A property cant'be saved. See logs for more infos"); } } $this->imported ++; unset($properties[$ref]); } if ($this->persistance == true && ! empty($properties)) { $this->setPersistentProperties($properties); } elseif ($this->persistance == true && empty($properties)) { $this->cleanPersistentProperties(); } if (empty($properties)) { $msg = JText::sprintf('COM_JEA_IMPORT_END_MESSAGE', $this->title) . '. [' . JText::sprintf('COM_JEA_GATEWAY_PROPERTIES_FOUND', $this->total) . ' - ' . JText::sprintf('COM_JEA_GATEWAY_PROPERTIES_CREATED', $this->created) . ' - ' . JText::sprintf('COM_JEA_GATEWAY_PROPERTIES_UPDATED', $this->updated) . ' - ' . JText::sprintf('COM_JEA_GATEWAY_PROPERTIES_DELETED', $this->removed) . ']'; $this->out($msg); $this->log($msg, 'info'); $this->afterImport(); } return $this->getSummary(); } /** * Return import summary * * @return number[] / protected function getSummary() { return array( 'gateway_id' => $this->id, 'gateway_title' => $this->title, 'total' => $this->total, 'created' => $this->created, 'updated' => $this->updated, 'imported' => $this->imported, 'removed' => $this->removed ); } /* * The gateway parser method. * This method must be overriden in child class * * @return JEAPropertyInterface[] / protected function &parse() { $properties = array(); return $properties; } /* * Check for properties stored in cache * * @return boolean / protected function hasPersistentProperties() { $cache = JFactory::getCache('jea_import', 'output', 'file'); $cache->setCaching(true); $properties = $cache->get('properties'); if (is_string($properties)) { return true; } return false; } /* * Get properties stored in cache * * @return array / protected function getPersistentProperties() { $cache = JFactory::getCache('jea_import', 'output', 'file'); $cache->setCaching(true); $infos = $cache->get('infos'); if (is_string($infos)) { $infos = unserialize($infos); $this->importedProperties = $infos->importedProperties; } $properties = $cache->get('properties'); if ($properties === false) { return array(); } return unserialize($properties); } /* * Store properties in cache * * @param JEAPropertyInterface[] $properties An array of JEAPropertyInterface instances * * @return void / protected function setPersistentProperties($properties = array()) { $cache = JFactory::getCache('jea_import', 'output', 'file'); $cache->setCaching(true); $cache->store(serialize($properties), 'properties'); $infos = $cache->get('infos'); if (! $infos) { $infos = new stdClass; $infos->total = $this->total; $infos->updated = $this->updated; $infos->removed = $this->removed; $infos->created = $this->created; $infos->imported = $this->imported; $infos->importedProperties = $this->importedProperties; $cache->store(serialize($infos), 'infos'); } else { $infos = unserialize($infos); $infos->updated += $this->updated; $infos->removed += $this->removed; $infos->created += $this->created; $infos->imported += $this->imported; foreach ($this->importedProperties as $k => $v) { $infos->importedProperties[$k] = $v; } $cache->store(serialize($infos), 'infos'); } // Update interface informations $this->total = $infos->total; $this->updated = $infos->updated; $this->removed = $infos->removed; $this->created = $infos->created; $this->imported = $infos->imported; } /* * Remove properties stored in cache * * @return void / protected function cleanPersistentProperties() { $cache = JFactory::getCache('jea_import', 'output', 'file'); $cache->setCaching(true); $infos = $cache->get('infos'); if (is_string($infos)) { $infos = @unserialize($infos); // Update interface informations $this->total = $infos->total; $this->updated += $infos->updated; $this->removed += $infos->removed; $this->created += $infos->created; $this->imported += $infos->imported; } // Delete cache infos $cache->clean(); } /* * Remove JEA properties * * @param array $ids An array of ids to remove * * @return boolean / protected function removeProperties($ids = array()) { if (empty($ids)) { return false; } $dbo = JFactory::getDbo(); $dbo->setQuery('DELETE FROM #__jea_properties WHERE id IN(' . implode(',', $ids) . ')'); $dbo->execute(); // Remove images folder foreach ($ids as $id) { if (JFolder::exists(JPATH_ROOT . '/images/com_jea/images/' . $id)) { JFolder::delete(JPATH_ROOT . '/images/com_jea/images/' . $id); } } $this->removed = count($ids); return true; } /* * Return the cache path for the gateway instance * * @param boolean $createDir If true, the Directory will be created * * @return string / protected function getCachePath($createDir = false) { $cachePath = JFactory::getApplication()->get('cache_path', JPATH_CACHE) . '/' . $this->type . '_' . $this->provider; if (!JFolder::exists($cachePath) && $createDir) { JFolder::create($cachePath); } if (!JFolder::exists($cachePath)) { throw RuntimeException("Cache directory : $cachePath cannot be created."); } return $cachePath; } /* * Parse an xml file * * @param string $xmlFile The xml file path * * @return SimpleXMLElement * * @throws Exception if xml cannot be parsed / protected function parseXmlFile($xmlFile = '') { // Disable libxml errors and allow to fetch error information as needed libxml_use_internal_errors(true); $xml = simplexml_load_file($xmlFile, 'SimpleXMLElement', LIBXML_PARSEHUGE); if (! $xml) { $msg = "Cannot load : $xmlFile. "; $errors = libxml_get_errors(); foreach ($errors as $error) { switch ($error->level) { case LIBXML_ERR_WARNING: $msg .= "Warning $error->code: "; break; case LIBXML_ERR_ERROR: $msg .= "Err Error $error->code: "; break; case LIBXML_ERR_FATAL: $msg .= "Fatal Error $error->code: "; break; } $msg .= trim($error->message) . " - Line: $error->line - Column: $error->column"; if ($error->file) { $msg .= " File: $error->file"; } } libxml_clear_errors(); throw new Exception($msg, $error->code); } return $xml; } /* * Download a file and return the file as local file path * * @param string $url The file url to download * @param string $destFile Optionnal file destination name * * @return string the downloaded file destination name */ protected function downloadFile($url, $destFile = '') { if (empty($destFile)) { $cachePath = $this->getCachePath(true); $fileName = JFilterOutput::stringUrlSafe(basename($url)); if (strlen($fileName) > 20) { $fileName = substr($fileName, 0, 20); } $destFile = $cachePath . '/' . $fileName; } if (JFile::exists($destFile)) { JFile::delete($destFile); } $ch = curl_init(); curl_setopt($ch, CURLOPT_URL, $url); // Don't check SSL certificate curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false); curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); curl_setopt($ch, CURLOPT_HEADER, false); $data = curl_exec($ch); if ($data === false) { $errno = curl_errno($ch); $error = curl_error($ch); $msg = "Cannot download $url. Error code : $errno, Message : $error"; $this->log($msg, 'ERR'); throw new RuntimeException($msg); } curl_close($ch); JFile::write($destFile, $data); return $destFile; } }

| ver. 1.4 | Github | . | PHP 8.1.33 | Генерация страницы: 0 | proxy | phpinfo | Настройка