* @copyright 2007-2011 PrestaShop SA * @version Release: $Revision$ * @license http://opensource.org/licenses/afl-3.0.php Academic Free License (AFL 3.0) * International Registred Trademark & Property of PrestaShop SA */ if (!defined('_PS_VERSION_')) exit; class BlockLayered extends Module { private $products; private $nbr_products; public function __construct() { $this->name = 'blocklayered'; $this->tab = 'front_office_features'; $this->version = 1.4; $this->author = 'PrestaShop'; $this->need_instance = 0; parent::__construct(); $this->displayName = $this->l('Layered navigation block'); $this->description = $this->l('Displays a block with layered navigation filters.'); } public function install() { if ($result = parent::install() && $this->registerHook('leftColumn') && $this->registerHook('header') && $this->registerHook('footer') && $this->registerHook('categoryAddition') && $this->registerHook('categoryUpdate') && $this->registerHook('attributeGroupForm') && $this->registerHook('afterSaveAttributeGroup') && $this->registerHook('afterDeleteAttributeGroup') && $this->registerHook('featureForm') && $this->registerHook('afterDeleteFeature') && $this->registerHook('afterSaveFeature') && $this->registerHook('categoryDeletion') && $this->registerHook('afterSaveProduct') && $this->registerHook('productListAssign')) { Configuration::updateValue('PS_LAYERED_HIDE_0_VALUES', 0); Configuration::updateValue('PS_LAYERED_SHOW_QTIES', 1); $this->rebuildLayeredStructure(); $this->rebuildLayeredCache(); } self::_installPriceIndexTable(); self::_installFriendlyUrlTable(); self::_installIndexableAttributeTable(); return $result; } public function uninstall() { /* Delete all configurations */ Configuration::deleteByName('PS_LAYERED_HIDE_0_VALUES'); Configuration::deleteByName('PS_LAYERED_SHOW_QTIES'); Db::getInstance()->Execute('DROP TABLE '._DB_PREFIX_.'price_static_index'); Db::getInstance()->Execute('DROP TABLE '._DB_PREFIX_.'layered_friendly_url'); Db::getInstance()->Execute('DROP TABLE '._DB_PREFIX_.'layered_indexable_attribute_group'); Db::getInstance()->Execute('DROP TABLE '._DB_PREFIX_.'layered_indexable_feature'); Db::getInstance()->Execute('DROP TABLE '._DB_PREFIX_.'layered_category'); Db::getInstance()->Execute('DROP TABLE '._DB_PREFIX_.'layered_filter'); return parent::uninstall(); } private function _installPriceIndexTable() { Db::getInstance()->Execute('DROP TABLE IF EXISTS `'._DB_PREFIX_.'price_static_index`'); Db::getInstance()->Execute(' CREATE TABLE `'._DB_PREFIX_.'price_static_index` ( `id_product` INT NOT NULL, `id_currency` INT NOT NULL, `price_min` INT NOT NULL, `price_max` INT NOT NULL, PRIMARY KEY (`id_product`, `id_currency`), INDEX `id_currency` (`id_currency`), INDEX `price_min` (`price_min`), INDEX `price_max` (`price_max`)) ENGINE = '._MYSQL_ENGINE_); } private function _installFriendlyUrlTable() { Db::getInstance()->Execute('DROP TABLE IF EXISTS `'._DB_PREFIX_.'layered_friendly_url`'); Db::getInstance()->Execute(' CREATE TABLE `'._DB_PREFIX_.'layered_friendly_url` ( `id_layered_friendly_url` INT NOT NULL AUTO_INCREMENT, `url_key` varchar(32) NOT NULL, `data` varchar(200) NOT NULL, `id_lang` INT NOT NULL, PRIMARY KEY (`id_layered_friendly_url`), INDEX `id_lang` (`id_lang`)) ENGINE = '._MYSQL_ENGINE_); Db::getInstance()->Execute('CREATE INDEX `url_key` ON `'._DB_PREFIX_.'layered_friendly_url`(url_key(5))'); } private function _installIndexableAttributeTable() { Db::getInstance()->Execute('DROP TABLE IF EXISTS `'._DB_PREFIX_.'layered_indexable_attribute_group`'); Db::getInstance()->Execute(' CREATE TABLE `'._DB_PREFIX_.'layered_indexable_attribute_group` ( `id_attribute_group` INT NOT NULL, `indexable` BOOL NOT NULL DEFAULT 0, PRIMARY KEY (`id_attribute_group`)) ENGINE = '._MYSQL_ENGINE_); Db::getInstance()->Execute(' INSERT INTO `'._DB_PREFIX_.'layered_indexable_attribute_group` SELECT id_attribute_group, 1 FROM `'._DB_PREFIX_.'attribute_group`'); Db::getInstance()->Execute('DROP TABLE IF EXISTS `'._DB_PREFIX_.'layered_indexable_feature`'); Db::getInstance()->Execute(' CREATE TABLE `'._DB_PREFIX_.'layered_indexable_feature` ( `id_feature` INT NOT NULL, `indexable` BOOL NOT NULL DEFAULT 0, PRIMARY KEY (`id_feature`)) ENGINE = '._MYSQL_ENGINE_); Db::getInstance()->Execute(' INSERT INTO `'._DB_PREFIX_.'layered_indexable_feature` SELECT id_feature, 1 FROM `'._DB_PREFIX_.'feature`'); } /* * Url indexation */ public function indexUrl($idCategory = null, $truncate = true) { if($truncate) Db::getInstance()->execute('TRUNCATE '._DB_PREFIX_.'layered_friendly_url'); if(!empty($idCategory)) $categorySubQuery = ' AND lc.id_category = '.(int)$idCategory; else $categorySubQuery = ''; $attributeValues = array(); $filters = Db::getInstance(_PS_USE_SQL_SLAVE_)->ExecuteS('SELECT lc.*, id_lang, name, link_rewrite, cl.id_category FROM '._DB_PREFIX_.'layered_category lc INNER JOIN '._DB_PREFIX_.'category_lang cl ON (cl.id_category = lc.id_category AND lc.id_category <> 1'.$categorySubQuery.') ORDER BY position ASC'); if (!$filters) return; foreach ($filters as $filter) switch ($filter['type']) { case 'id_attribute_group': $attributes = Db::getInstance(_PS_USE_SQL_SLAVE_)->ExecuteS(' SELECT agl.public_name name, a.id_attribute_group id_name, al.name value, a.id_attribute id_value, al.id_lang FROM '._DB_PREFIX_.'attribute_group ag INNER JOIN '._DB_PREFIX_.'attribute_group_lang agl ON (agl.id_attribute_group = ag.id_attribute_group) INNER JOIN '._DB_PREFIX_.'attribute a ON (a.id_attribute_group = ag.id_attribute_group) INNER JOIN '._DB_PREFIX_.'attribute_lang al ON (al.id_attribute = a.id_attribute) INNER JOIN '._DB_PREFIX_.'layered_indexable_attribute_group liag ON (liag.id_attribute_group = a.id_attribute_group AND liag.indexable = 1) WHERE a.id_attribute_group = '.(int)$filter['id_value'].' AND agl.id_lang = al.id_lang AND agl.id_lang = '.(int)$filter['id_lang']); foreach ($attributes as $attribute) { if (!isset($attributeValues[$attribute['id_lang']])) $attributeValues[$attribute['id_lang']] = array(); if (!isset($attributeValues[$attribute['id_lang']][$filter['id_category']])) $attributeValues[$attribute['id_lang']][$filter['id_category']] = array(); if (!isset($attributeValues[$attribute['id_lang']][$filter['id_category']]['c'.$attribute['id_name']])) $attributeValues[$attribute['id_lang']][$filter['id_category']]['c'.$attribute['id_name']] = array(); $attributeValues[$attribute['id_lang']][$filter['id_category']]['c'.$attribute['id_name']][] = array('name' => $attribute['name'], 'id_name' => 'c'.$attribute['id_name'], 'value' => $attribute['value'], 'id_value' => $attribute['id_value'], 'category_name' => $filter['link_rewrite'], 'type' => $filter['type']); } break; case 'id_feature': $features = Db::getInstance(_PS_USE_SQL_SLAVE_)->ExecuteS(' SELECT fl.name name, fl.id_feature id_name, fvl.id_feature_value id_value, fvl.value value, fl.id_lang FROM '._DB_PREFIX_.'feature_lang fl INNER JOIN '._DB_PREFIX_.'layered_indexable_feature lif ON (lif.id_feature = fl.id_feature AND indexable = 1) INNER JOIN '._DB_PREFIX_.'feature_value fv ON (fv.id_feature = fl.id_feature) INNER JOIN '._DB_PREFIX_.'feature_value_lang fvl ON (fvl.id_feature_value = fv.id_feature_value) WHERE fl.id_feature = '.(int)$filter['id_value'].' AND fvl.id_lang = fl.id_lang AND fvl.id_lang = '.(int)$filter['id_lang']); foreach ($features as $feature) { if (!isset($attributeValues[$feature['id_lang']])) $attributeValues[$feature['id_lang']] = array(); if (!isset($attributeValues[$feature['id_lang']][$filter['id_category']])) $attributeValues[$feature['id_lang']][$filter['id_category']] = array(); if (!isset($attributeValues[$feature['id_lang']][$filter['id_category']]['f'.$feature['id_name']])) $attributeValues[$feature['id_lang']][$filter['id_category']]['f'.$feature['id_name']] = array(); $attributeValues[$feature['id_lang']][$filter['id_category']]['f'.$feature['id_name']][] = array('name' => $feature['name'], 'id_name' => 'f'.$feature['id_name'], 'value' => $feature['value'], 'id_value' => $feature['id_value'], 'category_name' => $filter['link_rewrite'], 'type' => $filter['type']); } break; case 'category': $categories = Db::getInstance(_PS_USE_SQL_SLAVE_)->ExecuteS(' SELECT cl.name, cl.id_lang, c.id_category FROM '._DB_PREFIX_.'category c INNER JOIN '._DB_PREFIX_.'category_lang cl ON (c.id_category = cl.id_category) WHERE nleft > (SELECT nleft FROM '._DB_PREFIX_.'category WHERE id_category = 2) AND nright < (SELECT nright FROM '._DB_PREFIX_.'category WHERE id_category = 2) '); foreach($categories as $category) { if (!isset($attributeValues[$category['id_lang']])) $attributeValues[$category['id_lang']] = array(); if (!isset($attributeValues[$category['id_lang']][$filter['id_category']])) $attributeValues[$category['id_lang']][$filter['id_category']] = array(); if (!isset($attributeValues[$category['id_lang']][$filter['id_category']]['cat'.$category['id_category']])) $attributeValues[$category['id_lang']][$filter['id_category']]['cat'.$category['id_category']] = array(); $attributeValues[$category['id_lang']][$filter['id_category']]['cat'.$category['id_category']][] = array('name' => $this->l('Categories'), 'id_name' => null, 'value' => $category['name'], 'id_value' => $category['id_category'], 'category_name' => $filter['link_rewrite'], 'type' => $filter['type']); } $filter['id_category']; break; case 'manufacturer': // @TODO break; case 'avaibility': // @TODO break; } // Foreach langs foreach ($attributeValues as $id_lang => $tmp1) { // Foreach categories foreach ($tmp1 as $id_category => $tmp2) { $cursors = array_fill(0, count($tmp2), 0); $limits = array(); $nbName = count($tmp2); $nbPosibilities = 1; $tmp2 = array_values($tmp2); // fill limits and calculate the number of combination possible foreach ($tmp2 as $name) { $count = count($name)+1; $limits[] = $count; $nbPosibilities *= $count; } // Loop all url posibilities for ($i = 1; $i < $nbPosibilities; $i++) { // generate all parameters posibilities $a = 1; foreach ($cursors as $position => $cursor) { // Get all possible combination (one by group) // 0 means no combinations selected in the group $cursors[$position] = (($i / ($a)) % $limits[$position]); $a *= $limits[$position]; } $link = ''; $selectedFilters = array('category' => array()); // Generate url with selected filters foreach ($cursors as $position => $cursor) { if ($cursor != 0) { $link .= '/'.Tools::link_rewrite($tmp2[$position][$cursor-1]['name'].'-'.$tmp2[$position][$cursor-1]['value']); if (!isset($selectedFilters[$tmp2[$position][$cursor-1]['type']])) $selectedFilters[$tmp2[$position][$cursor-1]['type']] = array(); $selectedFilters[$tmp2[$position][$cursor-1]['type']][$tmp2[$position][$cursor-1]['id_value']] = $tmp2[$position][$cursor-1]['id_value']; } } $urlKey = md5($link); $idLayeredFriendlyUrl = Db::getInstance()->getValue('SELECT id_layered_friendly_url FROM `'._DB_PREFIX_.'layered_friendly_url` WHERE `url_key` = \''.$urlKey.'\''); if ($idLayeredFriendlyUrl == false) { Db::getInstance()->AutoExecute(_DB_PREFIX_.'layered_friendly_url', array('url_key' => $urlKey, 'data' => serialize($selectedFilters), 'id_lang' => $id_lang), 'INSERT'); $idLayeredFriendlyUrl = Db::getInstance()->Insert_ID(); } } } } return 1; } public function hookProductListAssign($params) { if (!Configuration::get('PS_LAYERED_INDEXED')) return; $params['hookExecuted'] = true; $params['catProducts'] = array(); $selectedFilters = $this->getSelectedFilters(); $this->getProducts($selectedFilters, $params['catProducts'], $params['nbProducts'], $p, $n, $pages_nb, $start, $stop, $range); } public function hookAfterSaveProduct($params) { if (!$params['id_product']) return; self::indexProduct((int)$params['id_product']); } public function hookAfterSaveFeature($params) { if (!$params['id_feature'] || Tools::getValue('layered_indexable') === false) return; Db::getInstance()->Execute('DELETE FROM '._DB_PREFIX_.'layered_indexable_feature WHERE id_feature = '.(int)$params['id_feature']); Db::getInstance()->Execute('INSERT INTO '._DB_PREFIX_.'layered_indexable_feature VALUES ('.(int)$params['id_feature'].', '.(int)Tools::getValue('layered_indexable').')'); } public function hookAfterDeleteFeature($params) { if (!$params['id_feature']) return; Db::getInstance()->Execute('DELETE FROM '._DB_PREFIX_.'layered_indexable_feature WHERE id_feature = '.(int)$params['id_feature']); } public function hookAfterSaveAttributeGroup($params) { if (!$params['id_attribute_group'] || Tools::getValue('layered_indexable') === false) return; Db::getInstance()->Execute('DELETE FROM '._DB_PREFIX_.'layered_indexable_attribute_group WHERE id_attribute_group = '.(int)$params['id_attribute_group']); Db::getInstance()->Execute('INSERT INTO '._DB_PREFIX_.'layered_indexable_attribute_group VALUES ('.(int)$params['id_attribute_group'].', '.(int)Tools::getValue('layered_indexable').')'); } public function hookAfterDeleteAttributeGroup($params) { if (!$params['id_attribute_group']) return; Db::getInstance()->Execute('DELETE FROM '._DB_PREFIX_.'layered_indexable_attribute_group WHERE id_attribute_group = '.(int)$params['id_attribute_group']); } public function hookAttributeGroupForm($params) { $indexable = Db::getInstance(_PS_USE_SQL_SLAVE_)->getValue('SELECT indexable FROM '._DB_PREFIX_.'layered_indexable_attribute_group WHERE id_attribute_group = '.(int)$params['id_attribute_group']); if($indexable === false) $on = true; else $on = (bool)$indexable; return '

'.$this->l('Use this attribute in url generated by the module block layered navigation').'

'; } public function hookFeatureForm($params) { $indexable = Db::getInstance(_PS_USE_SQL_SLAVE_)->getValue('SELECT indexable FROM '._DB_PREFIX_.'layered_indexable_feature WHERE id_feature = '.(int)$params['id_feature']); if($indexable === false) $on = true; else $on = (bool)$indexable; return '

'.$this->l('Use this feature in url generated by the module block layered navigation').'

'; } /* * $cursor $cursor in order to restart indexing from the last state */ public static function fullIndexProcess($cursor = 0, $ajax = false, $smart = false) { if ($cursor == 0 AND !$smart) self::_installPriceIndexTable(); return self::_indexer($cursor, true, $ajax, $smart); } /* * $cursor $cursor in order to restart indexing from the last state */ public static function indexProcess($cursor = 0, $ajax = false) { return self::_indexer($cursor, false, $ajax); } private static function _indexer($cursor = null, $full = false, $ajax = false, $smart = false) { if ($full) $nbProducts = (int)Db::getInstance()->getValue('SELECT count(*) FROM '._DB_PREFIX_.'product WHERE `active` = 1'); else $nbProducts = (int)Db::getInstance()->getValue( 'SELECT COUNT(*) FROM `'._DB_PREFIX_.'product` p LEFT JOIN `'._DB_PREFIX_.'price_static_index` psi ON (psi.id_product = p .id_product) WHERE `active` = 1 AND psi.id_product IS NULL'); $maxExecutionTime = ini_get('max_execution_time') * 0.9; // 90% of safety margin if ($maxExecutionTime > 5) $maxExecutionTime = 5; $startTime = microtime(true); do { $cursor = (int)self::_index((int)$cursor, $full, $smart); $timeElapsed = microtime(true) - $startTime; } while($cursor < $nbProducts AND (Tools::getMemoryLimit() * 0.9) > memory_get_peak_usage() AND $timeElapsed < $maxExecutionTime); if (($nbProducts > 0 AND !$full OR $cursor < $nbProducts AND $full) AND !$ajax) { if (!Tools::file_get_contents(Tools::getProtocol().Tools::getHttpHost().'/modules/blocklayered/blocklayered-indexer.php'.'?token='.substr(Tools::encrypt('blocklayered/index'), 0, 10).'&cursor='.(int)$cursor.'&full='.(int)$full)) self::_indexer((int)$cursor, (int)$full); return $cursor; } if ($ajax AND $nbProducts > 0 AND $cursor < $nbProducts AND $full) return '{"cursor": '.$cursor.', "count": '.($nbProducts - $cursor).'}'; elseif ($ajax AND $nbProducts > 0 AND !$full) return '{"cursor": '.$cursor.', "count": '.($nbProducts).'}'; else { Configuration::updateValue('PS_LAYERED_INDEXED', 1); if ($ajax) return '{"result": "ok"}'; else return -1; } } /* * $cursor $cursor in order to restart indexing from the last state */ private static function _index($cursor, $full = false, $smart = false) { static $length = 100; // Nb of products to index if (is_null($cursor)) $cursor = 0; if ($full) $query = ' SELECT id_product FROM `'._DB_PREFIX_.'product` WHERE `active` = 1 ORDER by id_product LIMIT '.(int)$cursor.','.(int)$length; else $query = ' SELECT p.id_product FROM `'._DB_PREFIX_.'product` p LEFT JOIN `'._DB_PREFIX_.'price_static_index` psi ON (psi.id_product = p.id_product) WHERE `active` = 1 AND psi.id_product is null ORDER by id_product LIMIT 0,'.(int)$length; foreach (Db::getInstance()->ExecuteS($query) as $product) self::indexProduct((int)$product['id_product'], ($smart AND $full)); return (int)($cursor + $length); } public static function indexProduct($idProduct, $smart = true) { static $groups = null; if (is_null($groups)) $groups = Db::getInstance(_PS_USE_SQL_SLAVE_)->ExecuteS('SELECT id_group FROM `'._DB_PREFIX_.'group_reduction`'); if(!$groups) $groups = array(); static $currencyList = null; if (is_null($currencyList)) $currencyList = Currency::getCurrencies(); $minPrice = array(); $maxPrice = array(); if ($smart) Db::getInstance()->execute('DELETE FROM `'._DB_PREFIX_.'price_static_index` WHERE `id_product` = '.(int)$idProduct); $maxTaxRate = Db::getInstance()->getValue(' SELECT max(t.rate) max_rate FROM `'._DB_PREFIX_.'product` p LEFT JOIN `'._DB_PREFIX_.'tax_rules_group` trg ON (trg.id_tax_rules_group = p.id_tax_rules_group) LEFT JOIN `'._DB_PREFIX_.'tax_rule` tr ON (tr.id_tax_rules_group = trg.id_tax_rules_group) LEFT JOIN `'._DB_PREFIX_.'tax` t ON (t.id_tax = tr.id_tax AND t.active = 1) WHERE id_product = '.(int)$idProduct.' GROUP BY id_product'); $productMinPrices = Db::getInstance(_PS_USE_SQL_SLAVE_)->ExecuteS(' SELECT id_shop, id_currency, id_country, id_group, from_quantity FROM `'._DB_PREFIX_.'specific_price` WHERE id_product = '.(int)$idProduct); // Get min price foreach ($currencyList as $currency) { $price = Product::priceCalculation(null, (int)$idProduct, null, null, null, null, $currency['id_currency'], null, null, false, true, false, true, true, $specificPriceOutput, true); if (!isset($maxPrice[$currency['id_currency']])) $maxPrice[$currency['id_currency']] = 0; if (!isset($minPrice[$currency['id_currency']])) $minPrice[$currency['id_currency']] = null; if ($price > $maxPrice[$currency['id_currency']]) $maxPrice[$currency['id_currency']] = $price; if ($price == 0) continue; if (is_null($minPrice[$currency['id_currency']]) OR $price < $minPrice[$currency['id_currency']]) $minPrice[$currency['id_currency']] = $price; } foreach ($productMinPrices as $specificPrice) foreach ($currencyList as $currency) { if ($specificPrice['id_currency'] AND $specificPrice['id_currency'] != $currency['id_currency']) continue; $price = Product::priceCalculation((($specificPrice['id_shop'] == 0) ? null : (int)$specificPrice['id_shop']), (int)$idProduct, null, (($specificPrice['id_country'] == 0) ? null : $specificPrice['id_country']), null, null, $currency['id_currency'], (($specificPrice['id_group'] == 0) ? null : $specificPrice['id_group']), $specificPrice['from_quantity'], false, true, false, true, true, $specificPriceOutput, true); if (!isset($maxPrice[$currency['id_currency']])) $maxPrice[$currency['id_currency']] = 0; if (!isset($minPrice[$currency['id_currency']])) $minPrice[$currency['id_currency']] = null; if ($price > $maxPrice[$currency['id_currency']]) $maxPrice[$currency['id_currency']] = $price; if ($price == 0) continue; if (is_null($minPrice[$currency['id_currency']]) OR $price < $minPrice[$currency['id_currency']]) $minPrice[$currency['id_currency']] = $price; } foreach ($groups as $group) foreach ($currencyList as $currency) { $price = Product::priceCalculation(null, (int)$idProduct, null, null, null, null, (int)$currency['id_currency'], (int)$group['id_group'], null, false, true, false, true, true, $specificPriceOutput, true); if (!isset($maxPrice[$currency['id_currency']])) $maxPrice[$currency['id_currency']] = 0; if (!isset($minPrice[$currency['id_currency']])) $minPrice[$currency['id_currency']] = null; if ($price > $maxPrice[$currency['id_currency']]) $maxPrice[$currency['id_currency']] = $price; if ($price == 0) continue; if (is_null($minPrice[$currency['id_currency']]) OR $price < $minPrice[$currency['id_currency']]) $minPrice[$currency['id_currency']] = $price; } $values = array(); foreach ($currencyList as $currency) $values[] = '('.(int)$idProduct.', '.(int)$currency['id_currency'].', '.(int)$minPrice[$currency['id_currency']].', '.(int)$maxPrice[$currency['id_currency']].')'; Db::getInstance()->Execute(' INSERT INTO `'._DB_PREFIX_.'price_static_index` (id_product, id_currency, price_min, price_max) VALUES '.implode(',', $values)); } public function hookLeftColumn($params) { return $this->generateFiltersBlock($this->getSelectedFilters()); } public function hookRightColumn($params) { return $this->hookLeftColumn($params); } public function hookHeader($params) { if (Tools::getValue('id_category', Tools::getValue('id_category_layered', 1)) == 1) return; Tools::addJS(($this->_path).'blocklayered.js'); Tools::addJS(_PS_JS_DIR_.'jquery/jquery-ui-1.8.10.custom.min.js'); Tools::addCSS(_PS_CSS_DIR_.'jquery-ui-1.8.10.custom.css', 'all'); Tools::addCSS(($this->_path).'blocklayered.css', 'all'); } public function hookFooter($params) { if (basename($_SERVER['PHP_SELF']) == 'category.php') return ' '; } public function hookCategoryAddition($params) { $this->rebuildLayeredCache(array(), array((int)$params['category']->id)); } public function hookCategoryUpdate($params) { /* The category status might (active, inactive) have changed, we have to update the layered cache table structure */ if (!$params['category']->active) $this->hookCategoryDeletion($params); } public function hookCategoryDeletion($params) { Db::getInstance()->Execute('DELETE FROM '._DB_PREFIX_.'layered_category WHERE id_category = '.(int)$params['category']->id); } public function getContent() { global $cookie; $html = ''; if (Tools::isSubmit('SubmitFilter')) { if(!Tools::getValue('layered_tpl_name')) $html .= '
X '.$this->l('Filter template name required (cannot be empty)').'
'; else { if (isset($_POST['id_layered_filter']) AND $_POST['id_layered_filter']) Db::getInstance()->Execute('DELETE FROM '._DB_PREFIX_.'layered_filter WHERE id_layered_filter = '.(int)Tools::getValue('id_layered_filter')); if (Tools::getValue('scope') == 1) { Db::getInstance()->Execute('TRUNCATE TABLE '._DB_PREFIX_.'layered_filter'); $categories = Db::getInstance(_PS_USE_SQL_SLAVE_)->ExecuteS('SELECT id_category FROM '._DB_PREFIX_.'category'); foreach ($categories AS $category) $_POST['categoryBox'][] = (int)$category['id_category']; } if (sizeof($_POST['categoryBox'])) { /* Clean categoryBox before use */ if (isset($_POST['categoryBox']) AND is_array($_POST['categoryBox'])) foreach ($_POST['categoryBox'] AS &$value) $value = (int)$value; Db::getInstance()->Execute('DELETE FROM '._DB_PREFIX_.'layered_category WHERE id_category IN ('.implode(',', $_POST['categoryBox']).')'); $filterValues = array(); foreach (Tools::getValue('categoryBox') AS $idc) $filterValues['categories'][] = (int)$idc; $sqlToInsert = 'INSERT INTO '._DB_PREFIX_.'layered_category (id_category, id_value, type, position) VALUES '; foreach ($_POST['categoryBox'] AS $id_category_layered) { $n = 0; foreach ($_POST AS $key => $value) if (substr($key, 0, 17) == 'layered_selection' AND $value == 'on') { $filterValues[$key] = $value; $n++; if ($key == 'layered_selection_stock') $sqlToInsert .= '('.(int)$id_category_layered.',NULL,\'quantity\','.(int)$n.'),'; elseif ($key == 'layered_selection_subcategories') $sqlToInsert .= '('.(int)$id_category_layered.',NULL,\'category\','.(int)$n.'),'; elseif ($key == 'layered_selection_condition') $sqlToInsert .= '('.(int)$id_category_layered.',NULL,\'condition\','.(int)$n.'),'; elseif ($key == 'layered_selection_weight_slider') $sqlToInsert .= '('.(int)$id_category_layered.',NULL,\'weight\','.(int)$n.'),'; elseif ($key == 'layered_selection_price_slider') $sqlToInsert .= '('.(int)$id_category_layered.',NULL,\'price\','.(int)$n.'),'; elseif ($key == 'layered_selection_manufacturer') $sqlToInsert .= '('.(int)$id_category_layered.',NULL,\'manufacturer\','.(int)$n.'),'; elseif (substr($key, 0, 21) == 'layered_selection_ag_') $sqlToInsert .= '('.(int)$id_category_layered.','.(int)str_replace('layered_selection_ag_', '', $key).',\'id_attribute_group\','.(int)$n.'),'; elseif (substr($key, 0, 23) == 'layered_selection_feat_') $sqlToInsert .= '('.(int)$id_category_layered.','.(int)str_replace('layered_selection_feat_', '', $key).',\'id_feature\','.(int)$n.'),'; } } Db::getInstance()->Execute(rtrim($sqlToInsert, ',')); $valuesToInsert = array('name' => pSQL(Tools::getValue('layered_tpl_name')), 'filters' => pSQL(serialize($filterValues)), 'n_categories' => (int)sizeof($filterValues['categories']), 'date_add' => date('Y-m-d H:i:s')); if (isset($_POST['id_layered_filter']) AND $_POST['id_layered_filter']) $valuesToInsert['id_layered_filter'] = (int)Tools::getValue('id_layered_filter'); Db::getInstance()->AutoExecute(_DB_PREFIX_.'layered_filter', $valuesToInsert, 'INSERT'); echo '
'.$this->l('Your filter').' "'.Tools::getValue('layered_tpl_name').'" '.((isset($_POST['id_layered_filter']) AND $_POST['id_layered_filter']) ? $this->l('was updated successfully.') : $this->l('was added successfully.')).'
'; } } } elseif (Tools::isSubmit('submitLayeredSettings')) { Configuration::updateValue('PS_LAYERED_HIDE_0_VALUES', Tools::getValue('ps_layered_hide_0_values')); Configuration::updateValue('PS_LAYERED_SHOW_QTIES', Tools::getValue('ps_layered_show_qties')); $html .= '
'.$this->l('Settings saved successfully').'
'; } elseif (isset($_GET['deleteFilterTemplate'])) { $layeredValues = Db::getInstance(_PS_USE_SQL_SLAVE_)->getValue(' SELECT filters FROM '._DB_PREFIX_.'layered_filter WHERE id_layered_filter = '.(int)$_GET['id_layered_filter']); if ($layeredValues) { Db::getInstance()->Execute('DELETE FROM '._DB_PREFIX_.'layered_filter WHERE id_layered_filter = '.(int)$_GET['id_layered_filter'].' LIMIT 1'); $html .= '
'.$this->l('Filters template deleted, categories updated (reverted to default Filters template).').'
'; } else { $html .= '
'.$this->l('Filters template not found').'
'; } } $html .= '

'.$this->l('Layered navigation').'

'.$this->l('Indexes and caches').' '; if(!Configuration::get('PS_LAYERED_INDEXED')) $html .= ' '; $categoryList = array(); foreach(Db::getInstance()->ExecuteS('SELECT id_category FROM `'._DB_PREFIX_.'category`') as $category) if($category['id_category'] != 1) $categoryList[] = $category['id_category']; $html .= ' '.$this->l('Index all missing prices').'
'.$this->l('Re-build entire price index').'
'.$this->l('Build url index').'

'.$this->l('You can set a cron job that will re-build price index using the following URL:').'
'.Tools::getProtocol().Tools::getHttpHost().__PS_BASE_URI__.'modules/blocklayered/blocklayered-indexer.php'.'?token='.substr(Tools::encrypt('blocklayered/index'), 0, 10).'&full=1
'.$this->l('You can set a cron job that will re-build url index using the following URL:').'
'.Tools::getProtocol().Tools::getHttpHost().__PS_BASE_URI__.'modules/blocklayered/blocklayered-url-indexer.php'.'?token='.substr(Tools::encrypt('blocklayered/index'), 0, 10).'&truncate=1

'.$this->l('A nightly rebuild is recommended.').'

'.$this->l('Existing filters templates').''; $filtersTemplates = Db::getInstance(_PS_USE_SQL_SLAVE_)->ExecuteS('SELECT * FROM '._DB_PREFIX_.'layered_filter ORDER BY date_add DESC'); if (sizeof($filtersTemplates)) { $html .= '

'.sizeof($filtersTemplates).' '.$this->l('filters templates are configured:').'

'; foreach ($filtersTemplates AS $filtersTemplate) { /* Clean request URI first */ $_SERVER['REQUEST_URI'] = preg_replace('/&deleteFilterTemplate=[0-9]*&id_layered_filter=[0-9]*/', '', $_SERVER['REQUEST_URI']); $html .= ' '; } $html .= '
'.$this->l('ID').' '.$this->l('Name').' '.$this->l('Categories').' '.$this->l('Created on').' '.$this->l('Actions').'
'.(int)$filtersTemplate['id_layered_filter'].' '.$filtersTemplate['name'].' '.(int)$filtersTemplate['n_categories'].' '.Tools::displayDate($filtersTemplate['date_add'], (int)$cookie->id_lang, true).'
'; } else $html .= $this->l('No filter template found.'); $html .= '

'.$this->l('Build your own filters template').'
'; $html.= '

'.$this->l('Step 1/3 - Select categories').'

'.$this->l('Use this template for:').'

'.$this->l('Categories using this template').'

  1. '.$this->l('Select one ore more category using this filter template').'
  2. '.$this->l('Press "Save this selection" or close the window to save').'
'; $trads = array(); $selectedCat = array(); foreach (Helper::$translationsKeysForAdminCategorieTree AS $key) $trads[$key] = $this->l($key); $html .= Helper::renderAdminCategorieTree($trads, $selectedCat, 'categoryBox'); $html .= '

'.$this->l('Step 2/3 - Select filters').'

'.$this->l('Selected filters').' (0)

'.$this->l('No filters selected yet.').'

    '.$this->ajaxCallBackOffice().'

    '.$this->l('Errors:').'
    • '.$this->l('Filter template name required (cannot be empty)').'

    '.$this->l('Step 3/3 - Name your template').'

    '.$this->l('Template name:').' ('.$this->l('only as a reminder').')




    '.$this->l('Configuration').'
    '.$this->l('Option').' '.$this->l('Value').'
    '.$this->l('Hide filter values with no product is matching').' '.$this->l('Yes').' '.$this->l('Yes').' '.$this->l('No').' '.$this->l('No').'
    '.$this->l('Show the number of matching products').' '.$this->l('Yes').' '.$this->l('Yes').' '.$this->l('No').' '.$this->l('No').'

    '; return $html; } private function getSelectedFilters() { $id_parent = (int)Tools::getValue('id_category', Tools::getValue('id_category_layered', 1)); if ($id_parent == 1) return; if (strpos($_SERVER['SCRIPT_FILENAME'], 'blocklayered-ajax.php') === false) { $data = Db::getInstance()->getValue('SELECT data FROM `'._DB_PREFIX_.'layered_friendly_url` WHERE `url_key` = \''.md5(preg_replace('/\/(\w*)\/([0-9]+[-\w]*)/', '',$_SERVER['REQUEST_URI'])).'\''); if($data !== false) return unserialize($data); } /* Analyze all the filters selected by the user and store them into a tab */ $selectedFilters = array('category' => array(), 'manufacturer' => array(), 'quantity' => array(), 'condition' => array()); foreach ($_GET AS $key => $value) if (substr($key, 0, 8) == 'layered_') { preg_match('/^(.*)_[0-9|new|used|refurbished|slider]+$/', substr($key, 8, strlen($key) - 8), $res); if (isset($res[1])) { $tmpTab = explode('_', $value); $value = $tmpTab[0]; $id_key = false; if (isset($tmpTab[1])) $id_key = $tmpTab[1]; if ($res[1] == 'condition' AND in_array($value, array('new', 'used', 'refurbished'))) $selectedFilters['condition'][] = $value; elseif ($res[1] == 'quantity' AND (!$value OR $value == 1)) $selectedFilters['quantity'][] = $value; elseif (in_array($res[1], array('category', 'manufacturer'))) { if (!isset($selectedFilters[$res[1].($id_key ? '_'.$id_key : '')])) $selectedFilters[$res[1].($id_key ? '_'.$id_key : '')] = array(); $selectedFilters[$res[1].($id_key ? '_'.$id_key : '')][] = (int)$value; } elseif (in_array($res[1], array('id_attribute_group', 'id_feature'))) { if (!isset($selectedFilters[$res[1]])) $selectedFilters[$res[1]] = array(); $selectedFilters[$res[1]][(int)$value] = $id_key.'_'.(int)$value; } elseif ($res[1] == 'weight') $selectedFilters[$res[1]] = $tmpTab; elseif ($res[1] == 'price') $selectedFilters[$res[1]] = $tmpTab; } } return $selectedFilters; } public function getProductByFilters($selectedFilters = array()) { global $cookie; if (!empty($this->products)) return $this->products; /* If the current category isn't defined of if it's homepage, we have nothing to display */ $id_parent = (int)Tools::getValue('id_category', Tools::getValue('id_category_layered', 1)); if ($id_parent == 1) return; $queryFilters = ' AND p.active = 1'; $parent = new Category((int)$id_parent); if (!sizeof($selectedFilters['category'])) $queryFilters .= ' AND p.id_product IN (SELECT id_product FROM '._DB_PREFIX_.'category_product cp LEFT JOIN '._DB_PREFIX_.'category c ON (c.id_category = cp.id_category) WHERE 1 AND c.nleft >= '.(int)$parent->nleft.' AND c.nright <= '.(int)$parent->nright.')'; foreach ($selectedFilters AS $key => $filterValues) { if (!sizeof($filterValues)) continue; preg_match('/^(.*[^_0-9])/', $key, $res); $key = $res[1]; switch ($key) { case 'id_feature': $subQueries = array(); foreach ($filterValues AS $filterValue) { $filterValueArray = explode('_',$filterValue); if(!isset($subQueries[$filterValueArray[0]])) $subQueries[$filterValueArray[0]] = array(); $subQueries[$filterValueArray[0]][] = 'fp.`id_feature_value` = '.(int)$filterValueArray[1]; //$queryFilters .= 'pac.`id_attribute` = '.(int)$filterValue.' OR '; } foreach($subQueries as $subQuery) { $queryFilters .= ' AND p.id_product IN (SELECT `id_product` FROM `'._DB_PREFIX_.'feature_product` fp WHERE '; $queryFilters .= implode(' OR ', $subQuery).') '; } break; case 'id_attribute_group': $subQueries = array(); foreach ($filterValues AS $filterValue) { $filterValueArray = explode('_',$filterValue); if(!isset($subQuery[$filterValueArray[0]])) $subQueries[$filterValueArray[0]] = array(); $subQueries[$filterValueArray[0]][] = 'pac.`id_attribute` = '.(int)$filterValueArray[1]; //$queryFilters .= 'pac.`id_attribute` = '.(int)$filterValue.' OR '; } foreach($subQueries as $subQuery) { $queryFilters .= ' AND p.id_product IN (SELECT pa.`id_product` FROM `'._DB_PREFIX_.'product_attribute_combination` pac LEFT JOIN `'._DB_PREFIX_.'product_attribute` pa ON (pa.`id_product_attribute` = pac.`id_product_attribute`) WHERE '; $queryFilters .= implode(' OR ', $subQuery).') '; } break; case 'category': $queryFilters .= ' AND p.id_product IN (SELECT id_product FROM '._DB_PREFIX_.'category_product cp WHERE '; foreach ($selectedFilters['category'] AS $id_category) $queryFilters .= 'cp.`id_category` = '.(int)$id_category.' OR '; $queryFilters = rtrim($queryFilters, 'OR ').')'; break; case 'quantity': if (sizeof($selectedFilters['quantity']) == 2) break; $queryFilters .= ' AND p.quantity '.(!$selectedFilters['quantity'][0] ? '=' : '>').' 0'; break; case 'manufacturer': $queryFilters .= ' AND p.id_manufacturer IN ('.implode($selectedFilters['manufacturer'], ',').')'; break; case 'condition': if (sizeof($selectedFilters['condition']) == 3) break; $queryFilters .= ' AND p.condition IN ('; foreach ($selectedFilters['condition'] AS $cond) $queryFilters .= '\''.$cond.'\','; $queryFilters = rtrim($queryFilters, ',').')'; break; case 'weight': if ($selectedFilters['weight'][0] != 0 OR $selectedFilters['weight'][1] != 0) $queryFilters .= ' AND p.`weight` BETWEEN '.(float)($selectedFilters['weight'][0] - 0.001).' AND '.(float)($selectedFilters['weight'][1] + 0.001); case 'price': if (isset($selectedFilters['price'])) { if ($selectedFilters['price'][0] != 0 OR $selectedFilters['price'][1] != 0) { $priceFilter = array(); $priceFilter['min'] = (float)($selectedFilters['price'][0]); $priceFilter['max'] = (float)($selectedFilters['price'][1]); } } else $priceFilter = false; break; } } $idCurrency = Currency::getCurrent()->id; $priceFilterQueryIn = ''; // All products with price range between price filters limits $priceFilterQueryOut = ''; // All products with a price filters limit on it price range if (isset($priceFilter) AND $priceFilter) { $priceFilterQueryIn = 'INNER JOIN `'._DB_PREFIX_.'price_static_index` psi ON psi.price_min >= '.(int)$priceFilter['min'].' AND psi.price_max <= '.(int)$priceFilter['max'].' AND psi.`id_product` = p.`id_product` AND psi.`id_currency` = '.(int)$idCurrency; $priceFilterQueryOut = 'INNER JOIN `'._DB_PREFIX_.'price_static_index` psi ON ((psi.price_min < '.(int)$priceFilter['min'].' AND psi.price_max > '.(int)$priceFilter['min'].') OR (psi.price_max > '.(int)$priceFilter['max'].' AND psi.price_min < '.(int)$priceFilter['max'].')) AND psi.`id_product` = p.`id_product` AND psi.`id_currency` = '.(int)$idCurrency; } $allProductsOut = Db::getInstance(_PS_USE_SQL_SLAVE_)->ExecuteS(' SELECT p.`id_product` id_product FROM `'._DB_PREFIX_.'product` p '.$priceFilterQueryOut.' WHERE 1 '.$queryFilters.' GROUP BY id_product'); $allProductsIn = Db::getInstance(_PS_USE_SQL_SLAVE_)->ExecuteS(' SELECT p.`id_product` id_product FROM `'._DB_PREFIX_.'product` p '.$priceFilterQueryIn.' WHERE 1 '.$queryFilters.' GROUP BY id_product'); $productIdList = array(); foreach ($allProductsIn as $product) $productIdList[] = (int)$product['id_product']; foreach ($allProductsOut as $product) if (isset($priceFilter) AND $priceFilter) { $price = Product::getPriceStatic($product['id_product']); if ($price < $priceFilter['min'] OR $price > $priceFilter['max']) continue; $productIdList[] = (int)$product['id_product']; } $this->nbr_products = count($productIdList); if ($this->nbr_products == 0) $this->products = array(); else { $n = (int)Tools::getValue('n', Configuration::get('PS_PRODUCTS_PER_PAGE')); $this->products = Db::getInstance(_PS_USE_SQL_SLAVE_)->ExecuteS(' SELECT p.id_product, p.on_sale, p.out_of_stock, p.available_for_order, p.quantity, p.minimal_quantity, p.id_category_default, p.customizable, p.show_price, p.`weight`, p.ean13, pl.available_later, pl.description_short, pl.link_rewrite, pl.name, i.id_image, il.legend, m.name manufacturer_name, p.condition, p.id_manufacturer, DATEDIFF(p.`date_add`, DATE_SUB(NOW(), INTERVAL '.(Validate::isUnsignedInt(Configuration::get('PS_NB_DAYS_NEW_PRODUCT')) ? Configuration::get('PS_NB_DAYS_NEW_PRODUCT') : 20).' DAY)) > 0 AS new FROM `'._DB_PREFIX_.'category_product` cp LEFT JOIN '._DB_PREFIX_.'category c ON (c.id_category = cp.id_category) LEFT JOIN `'._DB_PREFIX_.'product` p ON p.`id_product` = cp.`id_product` LEFT JOIN '._DB_PREFIX_.'product_lang pl ON (pl.id_product = p.id_product) LEFT JOIN '._DB_PREFIX_.'image i ON (i.id_product = p.id_product AND i.cover = 1) LEFT JOIN '._DB_PREFIX_.'image_lang il ON (i.id_image = il.id_image AND il.id_lang = '.(int)($cookie->id_lang).') LEFT JOIN '._DB_PREFIX_.'manufacturer m ON (m.id_manufacturer = p.id_manufacturer) WHERE p.`active` = 1 AND c.nleft >= '.(int)$parent->nleft.' AND c.nright <= '.(int)$parent->nright.' AND pl.id_lang = '.(int)$cookie->id_lang.' AND p.id_product IN ('.implode(',', $productIdList).')' .' GROUP BY p.id_product ORDER BY '.Tools::getProductsOrder('by', Tools::getValue('orderby'), true).' '.Tools::getProductsOrder('way', Tools::getValue('orderway')). ' LIMIT '.(((int)Tools::getValue('p', 1) - 1) * $n.','.$n)); } return $this->products; } public function generateFiltersBlockNew($selectedFilters = array()) { global $cookie, $smarty; $id_parent = (int)Tools::getValue('id_category', Tools::getValue('id_category_layered', 1)); if ($id_parent == 1) return; $parent = new Category((int)$id_parent); /* Get the filters for the current category */ $filters = Db::getInstance(_PS_USE_SQL_SLAVE_)->ExecuteS('SELECT * FROM '._DB_PREFIX_.'layered_category WHERE id_category = '.(int)$id_parent.' GROUP BY `type`, id_value ORDER BY position ASC'); // Remove all empty selected filters foreach ($selectedFilters as $key => $value) switch($key) { case 'price': case 'weight': if ($value[0] == '' AND $value[1] == '' OR $value[0] == 0 AND $value[1] == 0) unset($selectedFilters[$key]); break; default: if ($value == '') unset($selectedFilters[$key]); break; } $filterBlocks = array(); foreach ($filters as $filter) { $sqlQuery = array('select' => '', 'from' => '', 'join' => '', 'where' => '', 'group' => ''); switch($filter['type']) { // conditions + quantities + weight + price case 'price': case 'weight': case 'condition': case 'quantity': $sqlQuery['select'] = ' SELECT p.`id_product`, p.`condition`, p.`id_manufacturer`, p.`quantity`, p.`weight`, (SELECT GROUP_CONCAT(`id_category`) FROM `'._DB_PREFIX_.'category_product` cp WHERE cp.`id_product` = p.`id_product`) ids_cat, (SELECT GROUP_CONCAT(`id_feature_value`) FROM `'._DB_PREFIX_.'feature_product` fp WHERE fp.`id_product` = p.`id_product`) ids_feat, (SELECT GROUP_CONCAT(DISTINCT(pac.`id_attribute`)) FROM `'._DB_PREFIX_.'product_attribute_combination` pac LEFT JOIN `'._DB_PREFIX_.'product_attribute` pa ON (pa.`id_product_attribute` = pac.`id_product_attribute`) WHERE pa.`id_product` = p.`id_product`) ids_attr'; $sqlQuery['from'] = ' FROM '._DB_PREFIX_.'product p '; $sqlQuery['join'] = ' INNER JOIN '._DB_PREFIX_.'category_product cp ON (cp.id_product = p.id_product) INNER JOIN '._DB_PREFIX_.'category c ON (c.id_category = cp.id_category AND c.nleft >= '.(int)$parent->nleft.' AND c.nright <= '.(int)$parent->nright.') '; $sqlQuery['where'] = 'WHERE p.`active` = 1 '; break; case 'manufacturer': $sqlQuery['select'] = 'SELECT m.name, count(p.id_product) nbr, m.id_manufacturer '; $sqlQuery['from'] = ' FROM `'._DB_PREFIX_.'category_product` cp INNER JOIN `'._DB_PREFIX_.'category` c ON (c.id_category = cp.id_category) INNER JOIN '._DB_PREFIX_.'product p ON (p.id_product = cp.id_product AND p.active = 1) INNER JOIN '._DB_PREFIX_.'manufacturer m ON (m.id_manufacturer = p.id_manufacturer) '; $sqlQuery['where'] = ' WHERE c.nleft >= '.(int)$parent->nleft.' AND c.nright <= '.(int)$parent->nright.' '; $sqlQuery['group'] = ' GROUP BY p.id_manufacturer '; break; case 'id_attribute_group':// attribute group $sqlQuery['select'] = ' SELECT COUNT(tmp.id_attribute) nbr, tmp.id_attribute_group, tmp.color, tmp.attribute_name name, agl.public_name attributeName, tmp.id_attribute id_attribute, a.is_color_group FROM (SELECT p.id_product, pac.id_attribute, a.color, al.name attribute_name, a.id_attribute_group'; $sqlQuery['from'] = ' FROM '._DB_PREFIX_.'product_attribute_combination pac LEFT JOIN '._DB_PREFIX_.'product_attribute pa ON (pa.id_product_attribute = pac.id_product_attribute) LEFT JOIN '._DB_PREFIX_.'product p ON (pa.id_product = p.id_product) LEFT JOIN '._DB_PREFIX_.'category_product cp ON (cp.id_product = pa.id_product) INNER JOIN '._DB_PREFIX_.'category c ON (c.id_category = cp.id_category AND c.nleft >= '.(int)$parent->nleft.' AND c.nright <= '.(int)$parent->nright.') LEFT JOIN '._DB_PREFIX_.'attribute a ON (a.id_attribute = pac.id_attribute) LEFT JOIN '._DB_PREFIX_.'attribute_lang al ON (al.id_attribute = pac.id_attribute AND al.id_lang = '.(int)$cookie->id_lang.') '; $sqlQuery['group'] = ' WHERE p.`active` = 1 AND a.id_attribute_group = '.(int)$filter['id_value'].' GROUP BY pac.id_attribute, p.id_product) tmp LEFT JOIN '._DB_PREFIX_.'attribute_group_lang al ON (al.id_attribute_group = tmp.id_attribute_group AND al.id_lang = '.(int)$cookie->id_lang.') LEFT JOIN '._DB_PREFIX_.'attribute_group a ON (a.id_attribute_group = al.id_attribute_group) LEFT JOIN '._DB_PREFIX_.'attribute_group_lang agl ON (a.id_attribute_group = agl.id_attribute_group AND agl.id_lang = '.(int)$cookie->id_lang.') GROUP BY tmp.id_attribute ORDER BY id_attribute_group, id_attribute'; break; case 'id_feature': $sqlQuery['select'] = 'SELECT fl.name feature_name, fp.id_feature, fv.id_feature_value, fvl.value, count(fv.id_feature_value) nbr '; $sqlQuery['from'] = ' FROM '._DB_PREFIX_.'feature_product fp LEFT JOIN `'._DB_PREFIX_.'category_product` cp ON (cp.`id_product` = fp.`id_product`) INNER JOIN `'._DB_PREFIX_.'category` c ON (c.id_category = cp.id_category AND c.nleft >= '.(int)$parent->nleft.' AND c.nright <= '.(int)$parent->nright.') INNER JOIN '._DB_PREFIX_.'product p ON (p.id_product = cp.id_product AND p.active = 1) LEFT JOIN '._DB_PREFIX_.'feature_lang fl ON (fl.id_feature = fp.id_feature AND fl.id_lang = '.(int)$cookie->id_lang.') INNER JOIN '._DB_PREFIX_.'feature_value fv ON (fv.id_feature_value = fp.id_feature_value AND (fv.custom IS NULL OR fv.custom = 0)) LEFT JOIN '._DB_PREFIX_.'feature_value_lang fvl ON (fvl.id_feature_value = fp.id_feature_value AND fvl.id_lang = '.(int)$cookie->id_lang.') '; $sqlQuery['where'] = 'WHERE p.`active` = 1 '; $sqlQuery['group'] = 'GROUP BY fv.id_feature_value '; break; case 'category': $sqlQuery['select'] = ' SELECT c.id_category, c.id_parent, cl.name, (SELECT count(*) # '; $sqlQuery['from'] = ' FROM '._DB_PREFIX_.'category_product cp LEFT JOIN '._DB_PREFIX_.'product p ON (p.id_product = cp.id_product) '; $sqlQuery['where'] = ' WHERE cp.id_category = c.id_category '; $sqlQuery['group'] = ') count_products FROM '._DB_PREFIX_.'category c LEFT JOIN '._DB_PREFIX_.'category_lang cl ON (cl.id_category = c.id_category AND cl.id_lang = '.(int)$cookie->id_lang.') WHERE c.id_parent = '.(int)$id_parent.' GROUP BY c.id_category ORDER BY level_depth'; } foreach ($filters as $filterTmp) { $methodName = 'get'.ucfirst($filterTmp['type']).'FilterSubQuery'; if (method_exists('BlockLayered', $methodName) && (!in_array($filter['type'], array('price', 'weight')) && $filter['type'] != $filterTmp['type'] || $filter['type'] == $filterTmp['type'])) { if ($filter['type'] == $filterTmp['type']) $subQueryFilter = self::$methodName(array(), $filter['type'] == $filterTmp['type']); else $subQueryFilter = self::$methodName(@$selectedFilters[$filterTmp['type']], $filter['type'] == $filterTmp['type']); foreach ($subQueryFilter as $key => $value) $sqlQuery[$key] .= $value; } } $products = false; if (!empty($sqlQuery['from'])) $products = Db::getInstance(_PS_USE_SQL_SLAVE_)->ExecuteS($sqlQuery['select']."\n".$sqlQuery['from']."\n".$sqlQuery['join']."\n".$sqlQuery['where']."\n".$sqlQuery['group']); foreach ($filters as $filterTmp) { $methodName = 'filterProductsBy'.ucfirst($filterTmp['type']); if (method_exists('BlockLayered', $methodName) && (!in_array($filter['type'], array('price', 'weight')) && $filter['type'] != $filterTmp['type'] || $filter['type'] == $filterTmp['type'])) if ($filter['type'] == $filterTmp['type']) $products = self::$methodName(array(), $products); else $products = self::$methodName(@$selectedFilters[$filterTmp['type']], $products); } switch($filter['type']) { case 'price': $priceArray = array('type_lite' => 'price', 'type' => 'price', 'id_key' => 0, 'name' => $this->l('Price'), 'slider' => true, 'max' => '0', 'min' => null, 'values' => array ('1' => 0), 'unit' => Currency::getCurrent()->sign); if (isset($products) AND $products) foreach ($products as $product) { if (is_null($priceArray['min'])) { $priceArray['min'] = $product['price_min']; $priceArray['values'][0] = $product['price_min']; } elseif ($priceArray['min'] > $product['price_min']) { $priceArray['min'] = $product['price_min']; $priceArray['values'][0] = $product['price_min']; } if ($priceArray['max'] < $product['price_max']) { $priceArray['max'] = $product['price_max']; $priceArray['values'][1] = $product['price_max']; } } if (isset($selectedFilters['price']) AND isset($selectedFilters['price'][0]) AND isset($selectedFilters['price'][1])) { $priceArray['values'][0] = $selectedFilters['price'][0]; $priceArray['values'][1] = $selectedFilters['price'][1]; } $filterBlocks[] = $priceArray; break; case 'weight': $weightArray = array('type_lite' => 'weight', 'type' => 'weight', 'id_key' => 0, 'name' => $this->l('Weight'), 'slider' => true, 'max' => '0', 'min' => null, 'values' => array ('1' => 0), 'unit' => Configuration::get('PS_WEIGHT_UNIT')); if (isset($products) AND $products) foreach ($products as $product) { if (is_null($weightArray['min'])) { $weightArray['min'] = $product['weight']; $weightArray['values'][0] = $product['weight']; } elseif ($weightArray['min'] > $product['weight']) { $weightArray['min'] = $product['weight']; $weightArray['values'][0] = $product['weight']; } if ($weightArray['max'] < $product['weight']) { $weightArray['max'] = $product['weight']; $weightArray['values'][1] = $product['weight']; } } if (isset($selectedFilters['weight']) AND isset($selectedFilters['weight'][0]) AND isset($selectedFilters['weight'][1])) { $weightArray['values'][0] = $selectedFilters['weight'][0]; $weightArray['values'][1] = $selectedFilters['weight'][1]; } $filterBlocks[] = $weightArray; break; case 'condition': $conditionArray = array('new' => array('name' => $this->l('New'), 'nbr' => 0), 'used' => array('name' => $this->l('Used'), 'nbr' => 0), 'refurbished' => array('name' => $this->l('Refurbished'), 'nbr' => 0)); if (isset($products) AND $products) foreach ($products as $product) if (isset($selectedFilters['condition']) AND in_array($product['condition'], $selectedFilters['condition'])) $conditionArray[$product['condition']]['checked'] = true; foreach ($conditionArray as $key => $condition) if (isset($selectedFilters['condition']) AND in_array($key, $selectedFilters['condition'])) $conditionArray[$key]['checked'] = true; if (isset($products) AND $products) foreach ($products as $product) $conditionArray[$product['condition']]['nbr']++; $filterBlocks[] = array('type_lite' => 'condition', 'type' => 'condition', 'id_key' => 0, 'name' => $this->l('Condition'), 'values' => $conditionArray); break; case 'quantity': $quantityArray = array (0 => array('name' => $this->l('Not available'), 'nbr' => 0), 1 => array('name' => $this->l('In stock'), 'nbr' => 0)); foreach ($quantityArray as $key => $quantity) if (isset($selectedFilters['quantity']) AND in_array($key, $selectedFilters['quantity'])) $quantityArray[$key]['checked'] = true; if (isset($products) AND $products) foreach ($products as $product) $quantityArray[(int)($product['quantity'] > 0)]['nbr']++; $filterBlocks[] = array('type_lite' => 'quantity', 'type' => 'quantity', 'id_key' => 0, 'name' => $this->l('Availability'), 'values' => $quantityArray); break; case 'manufacturer': $manufaturersArray = array(); if (isset($products) AND $products) foreach ($products as $manufacturer) { $manufaturersArray[$manufacturer['id_manufacturer']] = array('name' => $manufacturer['name'], 'nbr' => $manufacturer['nbr']); if (isset($selectedFilters['manufacturer']) AND in_array((int)$manufacturer['id_manufacturer'], $selectedFilters['manufacturer'])) $manufaturersArray[$manufacturer['id_manufacturer']]['checked'] = true; } $filterBlocks[] = array('type_lite' => 'manufacturer', 'type' => 'manufacturer', 'id_key' => 0, 'name' => $this->l('Manufacturer'), 'values' => $manufaturersArray); break; case 'id_attribute_group': $attributesArray = array(); if (isset($products) AND $products) { foreach ($products as $attributes) { if (!isset($attributesArray[$attributes['id_attribute_group']])) { $attributesArray[$attributes['id_attribute_group']] = array ('type_lite' => 'id_attribute_group', 'type' => 'id_attribute_group', 'id_key' => (int)$attributes['id_attribute_group'], 'name' => $attributes['attributeName'], 'is_color_group' => (bool)$attributes['is_color_group'], 'values' => array()); } $attributesArray[$attributes['id_attribute_group']]['values'][$attributes['id_attribute']] = array( 'color' => $attributes['color'], 'name' => $attributes['name'], 'nbr' => (int)$attributes['nbr']); if (isset($selectedFilters['id_attribute_group'][$attributes['id_attribute']])) $attributesArray[$attributes['id_attribute_group']]['values'][$attributes['id_attribute']]['checked'] = true; } $filterBlocks = array_merge($filterBlocks, $attributesArray); } break; case 'id_feature': $featureArray = array (); if (isset($products) AND $products) { foreach ($products as $feature) { if (!isset($featureArray[$feature['id_feature']])) $featureArray[$feature['id_feature']] = array('type_lite' => 'id_feature', 'type' => 'id_feature', 'id_key' => (int)$feature['id_feature'], 'values' => array(), 'name' => $feature['feature_name']); $featureArray[$feature['id_feature']]['values'][$feature['id_feature_value']] = array('nbr' => (int)$feature['nbr'], 'name' => $feature['value']); if (isset($selectedFilters['id_feature'][$feature['id_feature_value']])) $featureArray[$feature['id_feature']]['values'][$feature['id_feature_value']]['checked'] = true; } $filterBlocks = array_merge($filterBlocks, $featureArray); } break; case 'category': $tmpArray = array(); if (isset($products) AND $products) { foreach ($products as $category) { $tmpArray[$category['id_category']] = array('name' => $category['name'], 'nbr' => (int)$category['count_products']); if (isset($selectedFilters['category']) AND in_array($category['id_category'], $selectedFilters['category'])) $tmpArray[$category['id_category']]['checked'] = true; } $filterBlocks[] = array ('type_lite' => 'category', 'type' => 'category', 'id_key' => 0, 'name' => $this->l('Categories'), 'values' => $tmpArray); } break; } } //generate SEO link $optionCheckedArray = array(); $paramGroupSelectedArray = array(); $link = new Link(); $linkBase = $link->getCategoryLink($id_parent,Category::getLinkRewrite($id_parent, (int)($cookie->id_lang)), (int)($cookie->id_lang)); $filterBlockList = array(); foreach ($filterBlocks as $typeFilter) { $paramGroupSelected = ''; foreach ($typeFilter['values'] as $key => $value) { if (is_array($value) AND array_key_exists('checked', $value )) { $paramGroupSelected .= '-'.Tools::link_rewrite($value['name']); $paramGroupSelectedArray [Tools::link_rewrite($typeFilter['name'])][] = Tools::link_rewrite($value['name']); } else $paramGroupSelectedArray [Tools::link_rewrite($typeFilter['name'])][] = array(); } if(!empty($paramGroupSelected)) $optionCheckedArray[Tools::link_rewrite($typeFilter['name'])] = $paramGroupSelected; $filterBlockList[] = Tools::link_rewrite($typeFilter['name']); } $blackList = array('weight','price'); foreach ($filterBlocks as &$typeFilter) if (count($typeFilter) > 0 AND !in_array($typeFilter['type'], $blackList)){ foreach ($typeFilter['values'] as $key => $values) { $optionCheckedCloneArray = $optionCheckedArray; //if not filters checked, add parameter if(!in_array(Tools::link_rewrite($values['name']), $paramGroupSelectedArray[Tools::link_rewrite($typeFilter['name'])])) { //filter checked $optionCheckedCloneArray[Tools::link_rewrite($typeFilter['name'])] = '-'.Tools::link_rewrite($values['name']); } $parametersLink = ''; //create order order by filter position foreach ($filterBlockList as $keyFilter => $valueFilter) { if(!empty($optionCheckedCloneArray[$valueFilter])) $parametersLink .= '/'.$valueFilter.$optionCheckedCloneArray[$valueFilter]; } //write link $typeFilter['values'][$key]['link'] = $linkBase.$parametersLink; } } $nFilters = 0; if(isset($selectedFilters['price'])) if($priceArray['min'] == $selectedFilters['price'][0] && $priceArray['max'] == $selectedFilters['price'][1]) unset($selectedFilters['price']); if(isset($selectedFilters['weight'])) if($weightArray['min'] == $selectedFilters['weight'][0] && $weightArray['max'] == $selectedFilters['weight'][1]) unset($selectedFilters['weight']); foreach ($selectedFilters AS $filters) $nFilters += sizeof($filters); $smarty->assign(array('layered_show_qties' => (int)Configuration::get('PS_LAYERED_SHOW_QTIES'), 'id_category_layered' => (int)$id_parent, 'selected_filters' => $selectedFilters, 'n_filters' => (int)$nFilters, 'nbr_filterBlocks' => sizeof($filterBlocks), 'filters' => $filterBlocks)); return $this->display(__FILE__, 'blocklayered.tpl'); } /* * This function must be improved * For the moment, we don't "filter filters" */ private static function getPriceFilterSubQuery($filterValue) { $idCurrency = (int)Currency::getCurrent()->id; $priceFilterQuery = ''; if (isset($filterValue) AND $filterValue) { $idCurrency = Currency::getCurrent()->id; $priceFilterQuery = ' INNER JOIN `'._DB_PREFIX_.'price_static_index` psi ON (psi.id_product = p.id_product AND psi.id_currency = '.(int)$idCurrency.' AND psi.price_min <= '.(int)$filterValue[1].' AND psi.price_max >= '.(int)$filterValue[0].') '; } else{ $idCurrency = Currency::getCurrent()->id; $priceFilterQuery = ' INNER JOIN `'._DB_PREFIX_.'price_static_index` psi ON (psi.id_product = p.id_product AND psi.id_currency = '.(int)$idCurrency.' AND psi.`id_product` = p.`id_product` AND psi.`id_currency` = '.(int)$idCurrency.') '; } return array('join' => $priceFilterQuery, 'select' => ', psi.price_min, psi.price_max'); } private static function filterProductsByPrice($filterValue, $productCollection) { if (empty($filterValue)) return $productCollection; foreach ($productCollection as $key => $product) { if (isset($filterValue) AND $filterValue AND isset($product['price_min']) AND isset($product['id_product']) AND ((int)$filterValue[0] > $product['price_min'] OR (int)$filterValue[1] < $product['price_max'])) { $price = Product::getPriceStatic($product['id_product']); if ($price < $filterValue[0] OR $price > $filterValue[1]) continue; unset($productCollection[$key]); } } return $productCollection; } private static function getWeightFilterSubQuery($filterValue, $ignoreJoin) { if (isset($filterValue) AND $filterValue) if ($filterValue[0] != 0 OR $filterValue[1] != 0) return array('where' => ' AND p.`weight` BETWEEN '.(float)($filterValue[0] - 0.001).' AND '.(float)($filterValue[1] + 0.001).' '); return array(); } private static function getFeatureFilterSubQuery($filterValue, $ignoreJoin) { if (empty($filterValue)) return array(); $queryFilters = ' AND p.id_product IN (SELECT id_product FROM '._DB_PREFIX_.'feature_product fp WHERE '; foreach ($filterValue AS $filterVal) $queryFilters .= 'fp.`id_feature_value` = '.(int)$filterVal.' OR '; $queryFilters = rtrim($queryFilters, 'OR ').') '; return array('where' => $queryFilters); } private static function getId_attribute_groupFilterSubQuery($filterValue, $ignoreJoin) { if (empty($filterValue)) return array(); $queryFilters = ' AND p.id_product IN (SELECT pa.`id_product` FROM `'._DB_PREFIX_.'product_attribute_combination` pac LEFT JOIN `'._DB_PREFIX_.'product_attribute` pa ON (pa.`id_product_attribute` = pac.`id_product_attribute`) WHERE '; foreach ($filterValue AS $filterVal) $queryFilters .= 'pac.`id_attribute` = '.(int)$filterVal.' OR '; $queryFilters = rtrim($queryFilters, 'OR ').') '; return array('where' => $queryFilters); } private static function getCategoryFilterSubQuery($filterValue, $ignoreJoin) { if (empty($filterValue)) return array(); $queryFiltersJoin = ''; $queryFiltersWhere = ' AND p.id_product IN (SELECT id_product FROM '._DB_PREFIX_.'category_product cp WHERE '; foreach ($filterValue AS $id_category) $queryFiltersWhere .= 'cp.`id_category` = '.(int)$id_category.' OR '; $queryFiltersWhere = rtrim($queryFiltersWhere, 'OR ').') '; return array('where' => $queryFiltersWhere, 'join' => $queryFiltersJoin); } private static function getQuantityFilterSubQuery($filterValue, $ignoreJoin) { if (sizeof($filterValue) == 2 OR empty($filterValue)) return array(); $queryFilters = ' AND p.quantity '.(!$filterValue[0] ? '=' : '>').' 0 '; return array('where' => $queryFilters); } private static function getManufacturerFilterSubQuery($filterValue, $ignoreJoin) { if (empty($filterValue)) $queryFilters = ''; else { array_walk($filterValue, create_function('&$id_manufacturer', '$id_manufacturer = (int)$id_manufacturer;')); $queryFilters = ' AND p.id_manufacturer IN ('.implode($filterValue, ',').')'; } if($ignoreJoin) return array('where' => $queryFilters, 'select' => ', m.name'); else return array('where' => $queryFilters, 'select' => ', m.name', 'join' => 'LEFT JOIN `'._DB_PREFIX_.'manufacturer` m ON (m.id_manufacturer = p.id_manufacturer) '); } private static function getConditionFilterSubQuery($filterValue, $ignoreJoin) { if (sizeof($filterValue) == 3 OR empty($filterValue)) return array(); $queryFilters = ' AND p.condition IN ('; foreach ($filterValue AS $cond) $queryFilters .= '\''.$cond.'\','; $queryFilters = rtrim($queryFilters, ',').') '; return array('where' => $queryFilters); } /* * This function must be improved * For the moment, we don't "filter filters" */ public function generateFiltersBlock($selectedFilters = array()) { return self::generateFiltersBlockNew($selectedFilters); } public function ajaxCallBackOffice($categoryBox = array(), $id_layered_filter = NULL) { global $cookie; if (!empty($id_layered_filter)) { $layeredFilter = Db::getInstance(_PS_USE_SQL_SLAVE_)->getRow('SELECT * FROM '._DB_PREFIX_.'layered_filter WHERE id_layered_filter = '.(int)$id_layered_filter); if ($layeredFilter AND isset($layeredFilter['filters']) AND !empty($layeredFilter['filters'])) $layeredValues = unserialize($layeredFilter['filters']); if (isset($layeredValues['categories']) AND sizeof($layeredValues['categories'])) foreach ($layeredValues['categories'] AS $id_category) $categoryBox[] = (int)$id_category; } /* Clean categoryBox before use */ if (isset($categoryBox) AND is_array($categoryBox)) foreach ($categoryBox AS &$value) $value = (int)$value; $attributeGroups = Db::getInstance(_PS_USE_SQL_SLAVE_)->ExecuteS(' SELECT ag.id_attribute_group, ag.is_color_group, agl.name, COUNT(DISTINCT(a.id_attribute)) n FROM '._DB_PREFIX_.'attribute_group ag LEFT JOIN '._DB_PREFIX_.'attribute_group_lang agl ON (agl.id_attribute_group = ag.id_attribute_group) LEFT JOIN '._DB_PREFIX_.'attribute a ON (a.id_attribute_group = ag.id_attribute_group) '.(sizeof($categoryBox) ? ' LEFT JOIN '._DB_PREFIX_.'product_attribute_combination pac ON (pac.id_attribute = a.id_attribute) LEFT JOIN '._DB_PREFIX_.'product_attribute pa ON (pa.id_product_attribute = pac.id_product_attribute) LEFT JOIN '._DB_PREFIX_.'category_product cp ON (cp.id_product = pa.id_product)' : '').' WHERE agl.id_lang = '.(int)$cookie->id_lang. (sizeof($categoryBox) ? ' AND cp.id_category IN ('.implode(',', $categoryBox).')' : '').' GROUP BY ag.id_attribute_group'); $features = Db::getInstance(_PS_USE_SQL_SLAVE_)->ExecuteS(' SELECT fl.id_feature, fl.name, COUNT(DISTINCT(fv.id_feature_value)) n FROM '._DB_PREFIX_.'feature_lang fl LEFT JOIN '._DB_PREFIX_.'feature_value fv ON (fv.id_feature = fl.id_feature) '.(sizeof($categoryBox) ? ' LEFT JOIN '._DB_PREFIX_.'feature_product fp ON (fp.id_feature = fv.id_feature) LEFT JOIN '._DB_PREFIX_.'category_product cp ON (cp.id_product = fp.id_product)' : '').' WHERE (fv.custom IS NULL OR fv.custom = 0) AND fl.id_lang = '.(int)$cookie->id_lang. (sizeof($categoryBox) ? ' AND cp.id_category IN ('.implode(',', $categoryBox).')' : '').' GROUP BY fl.id_feature'); $nElements = sizeof($attributeGroups) + sizeof($features) + 4; if ($nElements > 20) $nElements = 20; $html = '

    '.$this->l('Available filters').' (0)

    '; if (sizeof($attributeGroups)) { $html .= ''; } if (sizeof($features)) { $html .= ''; } $html .= '
    '; if (isset($layeredValues)) { $html .= ' '; } return $html; } public function ajaxCall() { global $smarty; $selectedFilters = $this->getSelectedFilters(); $this->getProducts($selectedFilters, $products, $nbProducts, $p, $n, $pages_nb, $start, $stop, $range); $smarty->assign('nb_products', $nbProducts); $smarty->assign('category', (object)array('id' => Tools::getValue('id_category_layered', 1))); $pagination_infos = array('pages_nb' => (int)($pages_nb), 'p' => (int)$p, 'n' => (int)$n, 'range' => (int)$range, 'start' => (int)$start, 'stop' => (int)$stop, 'nArray' => $nArray = (int)Configuration::get('PS_PRODUCTS_PER_PAGE') != 10 ? array((int)Configuration::get('PS_PRODUCTS_PER_PAGE'), 10, 20, 50) : array(10, 20, 50)); $smarty->assign($pagination_infos); $smarty->assign('comparator_max_item', (int)(Configuration::get('PS_COMPARATOR_MAX_ITEM'))); $smarty->assign('products', $products); /* We are sending an array in jSon to the .js controller, it will update both the filters and the products zones */ return Tools::jsonEncode(array( 'filtersBlock' => $this->generateFiltersBlock($selectedFilters), 'productList' => $smarty->fetch(_PS_THEME_DIR_.'product-list.tpl'), 'pagination' => $smarty->fetch(_PS_THEME_DIR_.'pagination.tpl'), 'categoryCount' => $smarty->fetch(_PS_THEME_DIR_.'category-count.tpl'))); } public function getProducts($selectedFilters, &$products, &$nbProducts, &$p, &$n, &$pages_nb, &$start, &$stop, &$range) { global $cookie; $products = $this->getProductByFilters($selectedFilters); $products = Product::getProductsProperties((int)$cookie->id_lang, $products); $nbProducts = $this->nbr_products; $range = 2; /* how many pages around page selected */ $n = (int)Tools::getValue('n', Configuration::get('PS_PRODUCTS_PER_PAGE')); $p = Tools::getValue('p', 1); if ($p < 0) $p = 0; if ($p > ($nbProducts / $n)) $p = ceil($nbProducts / $n); $pages_nb = ceil($nbProducts / (int)($n)); $start = (int)($p - $range); if ($start < 1) $start = 1; $stop = (int)($p + $range); if ($stop > $pages_nb) $stop = (int)($pages_nb); } public function rebuildLayeredStructure() { @set_time_limit(0); /* Set memory limit to 128M only if current is lower */ $memory_limit = ini_get('memory_limit'); if (substr($memory_limit,-1) != 'G' AND ((substr($memory_limit,-1) == 'M' AND substr($memory_limit,0,-1) < 128) OR is_numeric($memory_limit) AND (intval($memory_limit) < 131072))) @ini_set('memory_limit','128M'); /* Delete and re-create the layered categories table */ Db::getInstance()->Execute('DROP TABLE IF EXISTS '._DB_PREFIX_.'layered_category'); Db::getInstance()->Execute(' CREATE TABLE IF NOT EXISTS `'._DB_PREFIX_.'layered_category` ( `id_layered_category` INT(10) UNSIGNED NOT NULL AUTO_INCREMENT, `id_category` INT(10) UNSIGNED NOT NULL, `id_value` INT(10) UNSIGNED NULL DEFAULT \'0\', `type` ENUM(\'category\',\'id_feature\',\'id_attribute_group\',\'quantity\',\'condition\',\'manufacturer\',\'weight\',\'price\') NOT NULL, `position` INT(10) UNSIGNED NOT NULL, PRIMARY KEY (`id_layered_category`), KEY `id_category` (`id_category`,`type`) ) ENGINE=MyISAM DEFAULT CHARSET=latin1 AUTO_INCREMENT=1;'); /* MyISAM + latin1 = Smaller/faster */ Db::getInstance()->Execute(' CREATE TABLE IF NOT EXISTS `'._DB_PREFIX_.'layered_filter` ( `id_layered_filter` INT(10) UNSIGNED NOT NULL AUTO_INCREMENT PRIMARY KEY, `name` VARCHAR(64) NOT NULL, `filters` TEXT NULL, `n_categories` INT(10) UNSIGNED NOT NULL, `date_add` DATETIME NOT NULL)'); } public function rebuildLayeredCache($productsIds = array(), $categoriesIds = array()) { @set_time_limit(0); /* Set memory limit to 128M only if current is lower */ $memory_limit = ini_get('memory_limit'); if (substr($memory_limit,-1) != 'G' AND ((substr($memory_limit,-1) == 'M' AND substr($memory_limit,0,-1) < 128) OR is_numeric($memory_limit) AND (intval($memory_limit) < 131072))) @ini_set('memory_limit','128M'); $db = Db::getInstance(_PS_USE_SQL_SLAVE_); $nCategories = array(); $doneCategories = array(); $attributeGroups = Db::getInstance(_PS_USE_SQL_SLAVE_)->ExecuteS(' SELECT a.id_attribute, a.id_attribute_group FROM '._DB_PREFIX_.'attribute a LEFT JOIN '._DB_PREFIX_.'product_attribute_combination pac ON (pac.id_attribute = a.id_attribute) LEFT JOIN '._DB_PREFIX_.'product_attribute pa ON (pa.id_product_attribute = pac.id_product_attribute) LEFT JOIN '._DB_PREFIX_.'product p ON (p.id_product = pa.id_product) LEFT JOIN '._DB_PREFIX_.'category_product cp ON (cp.id_product = p.id_product) LEFT JOIN '._DB_PREFIX_.'category c ON (c.id_category = cp.id_category) WHERE c.active = 1'.(sizeof($categoriesIds) ? ' AND cp.id_category IN ('.implode(',', $categoriesIds).')' : '').' AND p.active = 1'.(sizeof($productsIds) ? ' AND p.id_product IN ('.implode(',', $productsIds).')' : ''), false); $attributeGroupsById = array(); while ($row = $db->nextRow($attributeGroups)) $attributeGroupsById[(int)$row['id_attribute']] = (int)$row['id_attribute_group']; $features = Db::getInstance(_PS_USE_SQL_SLAVE_)->ExecuteS(' SELECT fv.id_feature_value, fv.id_feature FROM '._DB_PREFIX_.'feature_value fv LEFT JOIN '._DB_PREFIX_.'feature_product fp ON (fp.id_feature_value = fv.id_feature_value) LEFT JOIN '._DB_PREFIX_.'product p ON (p.id_product = fp.id_product) LEFT JOIN '._DB_PREFIX_.'category_product cp ON (cp.id_product = p.id_product) LEFT JOIN '._DB_PREFIX_.'category c ON (c.id_category = cp.id_category) WHERE (fv.custom IS NULL OR fv.custom = 0) AND c.active = 1'.(sizeof($categoriesIds) ? ' AND cp.id_category IN ('.implode(',', $categoriesIds).')' : '').' AND p.active = 1'.(sizeof($productsIds) ? ' AND p.id_product IN ('.implode(',', $productsIds).')' : ''), false); $featuresById = array(); while ($row = $db->nextRow($features)) $featuresById[(int)$row['id_feature_value']] = (int)$row['id_feature']; $result = $db->ExecuteS(' SELECT p.id_product, GROUP_CONCAT(DISTINCT fv.id_feature_value) features, GROUP_CONCAT(DISTINCT cp.id_category) categories, GROUP_CONCAT(DISTINCT pac.id_attribute) attributes FROM '._DB_PREFIX_.'product p LEFT JOIN '._DB_PREFIX_.'category_product cp ON (cp.id_product = p.id_product) LEFT JOIN '._DB_PREFIX_.'category c ON (c.id_category = cp.id_category) LEFT JOIN '._DB_PREFIX_.'feature_product fp ON (fp.id_product = p.id_product) LEFT JOIN '._DB_PREFIX_.'feature_value fv ON (fv.id_feature_value = fp.id_feature_value) LEFT JOIN '._DB_PREFIX_.'product_attribute pa ON (pa.id_product = p.id_product) LEFT JOIN '._DB_PREFIX_.'product_attribute_combination pac ON (pac.id_product_attribute = pa.id_product_attribute) WHERE c.active = 1'.(sizeof($categoriesIds) ? ' AND cp.id_category IN ('.implode(',', $categoriesIds).')' : '').' AND p.active = 1'.(sizeof($productsIds) ? ' AND p.id_product IN ('.implode(',', $productsIds).')' : '').' AND (fv.custom IS NULL OR fv.custom = 0) GROUP BY p.id_product', false); while ($product = $db->nextRow($result)) { $a = $c = $f = array(); if (!empty($product['attributes'])) $a = array_flip(explode(',', $product['attributes'])); if (!empty($product['categories'])) $c = array_flip(explode(',', $product['categories'])); if (!empty($product['features'])) $f = array_flip(explode(',', $product['features'])); $queryCategory = 'INSERT INTO '._DB_PREFIX_.'layered_category (id_category, id_value, type, position) VALUES '; $toInsert = false; foreach ($c AS $id_category => $category) { if (!isset($nCategories[(int)$id_category])) $nCategories[(int)$id_category] = 1; if (!isset($doneCategories[(int)$id_category]['cat'])) { $doneCategories[(int)$id_category]['cat'] = true; $queryCategory .= '('.(int)$id_category.',NULL,\'category\','.(int)$nCategories[(int)$id_category]++.'),'; $toInsert = true; } foreach ($a AS $kAttribute => $attribute) if (!isset($doneCategories[(int)$id_category]['a'.(int)$attributeGroupsById[(int)$kAttribute]])) { $doneCategories[(int)$id_category]['a'.(int)$attributeGroupsById[(int)$kAttribute]] = true; $queryCategory .= '('.(int)$id_category.','.(int)$attributeGroupsById[(int)$kAttribute].',\'id_attribute_group\','.(int)$nCategories[(int)$id_category]++.'),'; $toInsert = true; } foreach ($f AS $kFeature => $feature) if (!isset($doneCategories[(int)$id_category]['f'.(int)$featuresById[(int)$kFeature]])) { $doneCategories[(int)$id_category]['f'.(int)$featuresById[(int)$kFeature]] = true; $queryCategory .= '('.(int)$id_category.','.(int)$featuresById[(int)$kFeature].',\'id_feature\','.(int)$nCategories[(int)$id_category]++.'),'; $toInsert = true; } if (!isset($doneCategories[(int)$id_category]['q'])) { $doneCategories[(int)$id_category]['q'] = true; $queryCategory .= '('.(int)$id_category.',NULL,\'quantity\','.(int)$nCategories[(int)$id_category]++.'),'; $toInsert = true; } if (!isset($doneCategories[(int)$id_category]['m'])) { $doneCategories[(int)$id_category]['m'] = true; $queryCategory .= '('.(int)$id_category.',NULL,\'manufacturer\','.(int)$nCategories[(int)$id_category]++.'),'; $toInsert = true; } if (!isset($doneCategories[(int)$id_category]['c'])) { $doneCategories[(int)$id_category]['c'] = true; $queryCategory .= '('.(int)$id_category.',NULL,\'condition\','.(int)$nCategories[(int)$id_category]++.'),'; $toInsert = true; } if (!isset($doneCategories[(int)$id_category]['w'])) { $doneCategories[(int)$id_category]['w'] = true; $queryCategory .= '('.(int)$id_category.',NULL,\'weight\','.(int)$nCategories[(int)$id_category]++.'),'; $toInsert = true; } if (!isset($doneCategories[(int)$id_category]['p'])) { $doneCategories[(int)$id_category]['p'] = true; $queryCategory .= '('.(int)$id_category.',NULL,\'price\','.(int)$nCategories[(int)$id_category]++.'),'; $toInsert = true; } } if ($toInsert) Db::getInstance()->Execute(rtrim($queryCategory, ',')); } } function filterProducts($products, $selectedFilters, $excludeType = false) { static $priceStatics = array(); $productsToKeep = array(); $filterByLetter = array('id_attribute_group' => 'a', 'id_feature' => 'f', 'category' => 'c', 'manufacturer' => 'id_manufacturer', 'quantity' => 'quantity', 'condition' => 'condition', 'weight' => 'weight', 'price' => 'price'); foreach ($selectedFilters AS $type => $filters) { if ($type == $excludeType OR !sizeof($filters)) continue; else { $type = preg_match('/^(.*[^_0-9])/', $type, $res); $type = $res[1]; switch ($type) { case 'category': foreach ($products AS $k => $product) if ($filter = Tools::getValue('id_category_layered')) $productsToKeep[] = (int)$k; //don't break me case 'id_attribute_group': case 'id_feature': foreach ($products AS $k => $product) foreach ($filters AS $filter) if (in_array($filter, $product[$filterByLetter[$type]])) $productsToKeep[] = (int)$k; break; case 'manufacturer': case 'condition': case 'quantity': foreach ($products AS $k => $product) foreach ($filters AS $filter) if ($product[$filterByLetter[$type]] == $filter) $productsToKeep[] = (int)$k; break; case 'weight': $min = $filters[0]; $max = $filters[1]; foreach ($products AS $k => $product) if ((float)$min <= (float)$product[$filterByLetter[$type]] AND (float)$product[$filterByLetter[$type]] <= (float)$max) $productsToKeep[] = (int)$k; break; case 'price': $min = $filters[0]; $max = $filters[1]; foreach ($products AS $k => $product) if ((float)$min <= (float)$product['price_min'] AND (float)$product['price_max'] <= (float)$max) $productsToKeep[] = (int)$k; elseif ((float)$product['price_min'] < (float)$max AND (float)$product['price_max'] > (float)$max OR (float)$product['price_min'] < (float)$min AND (float)$product['price_max'] > (float)$min) { if (!isset($priceStatics[(int)$k])) $priceStatics[(int)$k] = Product::getPriceStatic((int)$k); $price = $priceStatics[(int)$k]; if ((float)$min <= $price AND $price <= (float)$max) $productsToKeep[] = (int)$k; } break; } foreach ($products AS $k => $product) if (!in_array($k, $productsToKeep)) unset($products[(int)$k]); $productsToKeep = array(); } } return $products; } }