File: //home/retile.ru/public_html/storage/modification/admin/model/catalog/product.php
<?php
class ModelCatalogProduct extends Model {
public function addProduct($data) {
// handle extra data for universal import
$univimp_extra = '';
if (!empty($data['product_id']) && defined('GKD_UNIV_IMPORT')) {
$univimp_extra .= 'product_id = "' . (int) $data['product_id'] . '", ';
}
if (!empty($data['import_batch'])) {
$univimp_extra .= 'import_batch = "' . $this->db->escape($data['import_batch']) . '", ';
}
if (!empty($data['gkd_extra_fields']) && defined('GKD_UNIV_IMPORT')) {
foreach ($data['gkd_extra_fields'] as $extra_field) {
if (isset($data[$extra_field])) {
$univimp_extra .= '`' . $this->db->escape($extra_field) .'` = "' . $this->db->escape($data[$extra_field]) . '", ';
}
}
}
$this->db->query("INSERT INTO " . DB_PREFIX . "product SET " . $univimp_extra . " model = '" . $this->db->escape($data['model']) . "', sku = '" . $this->db->escape($data['sku']) . "', upc = '" . $this->db->escape($data['upc']) . "', ean = '" . $this->db->escape($data['ean']) . "', jan = '" . $this->db->escape($data['jan']) . "', isbn = '" . $this->db->escape($data['isbn']) . "', mpn = '" . $this->db->escape($data['mpn']) . "', location = '" . $this->db->escape($data['location']) . "', quantity = '" . (int)$data['quantity'] . "', minimum = '" . (int)$data['minimum'] . "', subtract = '" . (int)$data['subtract'] . "', stock_status_id = '" . (int)$data['stock_status_id'] . "', date_available = '" . $this->db->escape($data['date_available']) . "', manufacturer_id = '" . (int)$data['manufacturer_id'] . "', shipping = '" . (int)$data['shipping'] . "', price = '" . (float)$data['price'] . "', points = '" . (int)$data['points'] . "', weight = '" . (float)$data['weight'] . "', weight_class_id = '" . (int)$data['weight_class_id'] . "', length = '" . (float)$data['length'] . "', width = '" . (float)$data['width'] . "', height = '" . (float)$data['height'] . "', length_class_id = '" . (int)$data['length_class_id'] . "', status = '" . (int)$data['status'] . "', tax_class_id = '" . (int)$data['tax_class_id'] . "', sort_order = '" . (int)$data['sort_order'] . "', date_added = NOW(), date_modified = NOW()");
$product_id = $this->db->getLastId();
if (isset($data['product_attach'])) {
foreach ($data['product_attach'] as $product_attach) {
if(is_file(DIR_IMAGE . '' .$product_attach['filename'])){
$login_required = isset($product_attach['login_required']) ? 1 : 0;
$filename = $this->db->escape($product_attach['filename']);
$mask = $this->db->escape($product_attach['mask']);
$download = 0;
$this->db->query("INSERT INTO " . DB_PREFIX . "product_attach_file SET product_id = '" . (int)$product_id . "', filename = '" . $filename . "', mask = '" . $mask . "', login_required = '" . $login_required . "' ,download = '" . $download . "'");
}
}
}
if (isset($data['exten_link'])) {
foreach ($data['exten_link'] as $link) {
$link_name = trim($this->db->escape($link['link_name']));
$link_download = trim($this->db->escape($link['link_download']));
$login_required = isset($link['login_required']) ? 1 : 0 ;
$this->db->query("INSERT INTO " . DB_PREFIX . "product_attach_extendlink SET product_id = '" . (int)$product_id . "',link_name = '" . $link_name . "',link_download = '" . $link_download . "', login_required = '" . $login_required . "'");
}
}
if (isset($data['image'])) {
$this->db->query("UPDATE " . DB_PREFIX . "product SET image = '" . $this->db->escape($data['image']) . "' WHERE product_id = '" . (int)$product_id . "'");
}
foreach ($data['product_description'] as $language_id => $value) {
// handle extra data for universal import
$univimp_extra_desc = '';
if (!empty($data['gkd_extra_desc_fields']) && defined('GKD_UNIV_IMPORT')) {
foreach ($data['gkd_extra_desc_fields'] as $extra_field) {
if (isset($value[$extra_field])) {
$univimp_extra_desc .= '`' . $this->db->escape($extra_field) .'` = "' . $this->db->escape($value[$extra_field]) . '", ';
}
}
}
$this->db->query("INSERT INTO " . DB_PREFIX . "product_description SET " . $univimp_extra_desc . " product_id = '" . (int)$product_id . "', language_id = '" . (int)$language_id . "', name = '" . $this->db->escape($value['name']) . "', description = '" . $this->db->escape($value['description']) . "', short_description = '" . $this->db->escape($value['short_description']) . "', tag = '" . $this->db->escape($value['tag']) . "', meta_title = '" . $this->db->escape($value['meta_title']) . "', meta_description = '" . $this->db->escape($value['meta_description']) . "', meta_keyword = '" . $this->db->escape($value['meta_keyword']) . "'");
}
if (isset($data['product_store'])) {
foreach ($data['product_store'] as $store_id) {
$this->db->query("INSERT INTO " . DB_PREFIX . "product_to_store SET product_id = '" . (int)$product_id . "', store_id = '" . (int)$store_id . "'");
}
}
if (isset($data['product_attribute'])) {
foreach ($data['product_attribute'] as $product_attribute) {
if ($product_attribute['attribute_id']) {
// Removes duplicates
$this->db->query("DELETE FROM " . DB_PREFIX . "product_attribute WHERE product_id = '" . (int)$product_id . "' AND attribute_id = '" . (int)$product_attribute['attribute_id'] . "'");
foreach ($product_attribute['product_attribute_description'] as $language_id => $product_attribute_description) {
$this->db->query("DELETE FROM " . DB_PREFIX . "product_attribute WHERE product_id = '" . (int)$product_id . "' AND attribute_id = '" . (int)$product_attribute['attribute_id'] . "' AND language_id = '" . (int)$language_id . "'");
$this->db->query("INSERT INTO " . DB_PREFIX . "product_attribute SET product_id = '" . (int)$product_id . "', attribute_id = '" . (int)$product_attribute['attribute_id'] . "', language_id = '" . (int)$language_id . "', text = '" . $this->db->escape($product_attribute_description['text']) . "'");
}
}
}
}
if (isset($data['product_option'])) {
foreach ($data['product_option'] as $product_option) {
if ($product_option['type'] == 'select' || $product_option['type'] == 'radio' || $product_option['type'] == 'checkbox' || $product_option['type'] == 'image') {
if (isset($product_option['product_option_value'])) {
$this->db->query("INSERT INTO " . DB_PREFIX . "product_option SET product_id = '" . (int)$product_id . "', option_id = '" . (int)$product_option['option_id'] . "', required = '" . (int)$product_option['required'] . "'");
$product_option_id = $this->db->getLastId();
foreach ($product_option['product_option_value'] as $product_option_value) {
$this->db->query("INSERT INTO " . DB_PREFIX . "product_option_value SET product_option_id = '" . (int)$product_option_id . "', product_id = '" . (int)$product_id . "', option_id = '" . (int)$product_option['option_id'] . "', option_value_id = '" . (int)$product_option_value['option_value_id'] . "', quantity = '" . (int)$product_option_value['quantity'] . "', subtract = '" . (int)$product_option_value['subtract'] . "', price = '" . (float)$product_option_value['price'] . "', price_prefix = '" . $this->db->escape($product_option_value['price_prefix']) . "', points = '" . (int)$product_option_value['points'] . "', points_prefix = '" . $this->db->escape($product_option_value['points_prefix']) . "', weight = '" . (float)$product_option_value['weight'] . "', weight_prefix = '" . $this->db->escape($product_option_value['weight_prefix']) . "'");
}
}
} else {
$this->db->query("INSERT INTO " . DB_PREFIX . "product_option SET product_id = '" . (int)$product_id . "', option_id = '" . (int)$product_option['option_id'] . "', value = '" . $this->db->escape($product_option['value']) . "', required = '" . (int)$product_option['required'] . "'");
}
}
}
if (isset($data['product_recurring'])) {
foreach ($data['product_recurring'] as $recurring) {
$this->db->query("INSERT INTO `" . DB_PREFIX . "product_recurring` SET `product_id` = " . (int)$product_id . ", customer_group_id = " . (int)$recurring['customer_group_id'] . ", `recurring_id` = " . (int)$recurring['recurring_id']);
}
}
if (isset($data['product_discount'])) {
foreach ($data['product_discount'] as $product_discount) {
$this->db->query("INSERT INTO " . DB_PREFIX . "product_discount SET product_id = '" . (int)$product_id . "', customer_group_id = '" . (int)$product_discount['customer_group_id'] . "', quantity = '" . (int)$product_discount['quantity'] . "', priority = '" . (int)$product_discount['priority'] . "', price = '" . (float)$product_discount['price'] . "', date_start = '" . $this->db->escape($product_discount['date_start']) . "', date_end = '" . $this->db->escape($product_discount['date_end']) . "'");
}
}
if (isset($data['product_special'])) {
foreach ($data['product_special'] as $product_special) {
$this->db->query("INSERT INTO " . DB_PREFIX . "product_special SET product_id = '" . (int)$product_id . "', customer_group_id = '" . (int)$product_special['customer_group_id'] . "', priority = '" . (int)$product_special['priority'] . "', price = '" . (float)$product_special['price'] . "', date_start = '" . $this->db->escape($product_special['date_start']) . "', date_end = '" . $this->db->escape($product_special['date_end']) . "'");
}
}
if (isset($data['product_image'])) {
foreach ($data['product_image'] as $product_image) {
$this->db->query("INSERT INTO " . DB_PREFIX . "product_image SET product_id = '" . (int)$product_id . "', image = '" . $this->db->escape($product_image['image']) . "', sort_order = '" . (int)$product_image['sort_order'] . "'");
}
}
if (isset($data['product_download'])) {
foreach ($data['product_download'] as $download_id) {
$this->db->query("INSERT INTO " . DB_PREFIX . "product_to_download SET product_id = '" . (int)$product_id . "', download_id = '" . (int)$download_id . "'");
}
}
if (isset($data['product_category'])) {
foreach ($data['product_category'] as $category_id) {
$this->db->query("INSERT INTO " . DB_PREFIX . "product_to_category SET product_id = '" . (int)$product_id . "', category_id = '" . (int)$category_id . "'");
}
}
if (isset($data['product_filter'])) {
foreach ($data['product_filter'] as $filter_id) {
$this->db->query("INSERT INTO " . DB_PREFIX . "product_filter SET product_id = '" . (int)$product_id . "', filter_id = '" . (int)$filter_id . "'");
// Universal Import/Export - apply filters to cateogories
if (!empty($data['uiep_filter_to_category'])) {
if (!empty($data['product_filter']) && !empty($data['product_category'])) {
foreach ($data['product_category'] as $category_id) {
foreach ($data['product_filter'] as $filter_id) {
$this->db->query("INSERT IGNORE INTO " . DB_PREFIX . "category_filter SET category_id = '" . (int)$category_id . "', filter_id = '" . (int)$filter_id . "'");
}
}
}
}
}
}
if (isset($data['product_related'])) {
foreach ($data['product_related'] as $related_id) {
$this->db->query("DELETE FROM " . DB_PREFIX . "product_related WHERE product_id = '" . (int)$product_id . "' AND related_id = '" . (int)$related_id . "'");
$this->db->query("INSERT INTO " . DB_PREFIX . "product_related SET product_id = '" . (int)$product_id . "', related_id = '" . (int)$related_id . "'");
$this->db->query("DELETE FROM " . DB_PREFIX . "product_related WHERE product_id = '" . (int)$related_id . "' AND related_id = '" . (int)$product_id . "'");
$this->db->query("INSERT INTO " . DB_PREFIX . "product_related SET product_id = '" . (int)$related_id . "', related_id = '" . (int)$product_id . "'");
}
}
if (isset($data['product_reward'])) {
foreach ($data['product_reward'] as $customer_group_id => $product_reward) {
if ((int)$product_reward['points'] > 0) {
$this->db->query("INSERT INTO " . DB_PREFIX . "product_reward SET product_id = '" . (int)$product_id . "', customer_group_id = '" . (int)$customer_group_id . "', points = '" . (int)$product_reward['points'] . "'");
}
}
}
// SEO URL
// SEO URL Generator . begin
// product_id not exist in controller when add() product
$this->load->model('extension/module/seo_url_generator');
$sug_log = new StdeLog('seo_url_generator');
$sug_log->setDebug($this->config->get('module_seo_url_generator_debug'));
$sug_log->write(4, 'model/product.php :: addProduct() is called');
$sug_log->write(4, $data['product_seo_url'], 'model/product.php :: addProduct() : $data["product_seo_url"] BEFORE SUG');
#
# SETTING
#
$sug_data['setting'] = array();
$this->load->model('localisation/language');
$data['languages'] = $this->model_localisation_language->getLanguages();
$this->load->model('setting/setting');
$data['store_setting'] = array();
foreach ($data['product_seo_url'] as $store_id => $store) {
$store_setting = $this->model_setting_setting->getSetting('module_seo_url_generator', $store_id);
$data['store_setting'][$store_id]['translit_function'] = $store_setting['module_seo_url_generator_translit_function'];
$data['store_setting'][$store_id]['formula'] = $store_setting['module_seo_url_generator_product_formula'];
$data['store_setting'][$store_id]['delimiter_char'] = $store_setting['module_seo_url_generator_delimiter_char'];
$data['store_setting'][$store_id]['change_delimiter_char'] = $store_setting['module_seo_url_generator_change_delimiter_char'];
$data['store_setting'][$store_id]['rewrite_on_save'] = $store_setting['module_seo_url_generator_rewrite_on_save'];
$data['store_setting'][$store_id]['custom_replace_from'] = $store_setting['module_seo_url_generator_custom_replace_from'];
$data['store_setting'][$store_id]['custom_replace_to'] = $store_setting['module_seo_url_generator_custom_replace_to'];
}
foreach ($data['product_seo_url'] as $store_id => $store) {
foreach ($store as $language_id => $url) {
if (empty($data['product_seo_url'][$store_id][$language_id])) {
$sug_data = array(
'name' =>$data['product_description'][$language_id]['name'],
'model' =>$data['model'],
'manufacturer_id' => $data['manufacturer_id'],
'sku' => $data['sku'],
'primary_key' => 'product_id',
'essence' => 'product',
'essence_id' => $product_id,
);
$sug_data['setting'] = array(
'translit_function' =>$data['store_setting'][$store_id]['translit_function'][$language_id],
'formula' =>$data['store_setting'][$store_id]['formula'][$language_id],
'delimiter_char' =>$data['store_setting'][$store_id]['delimiter_char'][$language_id],
'change_delimiter_char' =>$data['store_setting'][$store_id]['change_delimiter_char'][$language_id],
'rewrite_on_save' =>$data['store_setting'][$store_id]['rewrite_on_save'][$language_id],
'custom_replace_from' =>$data['store_setting'][$store_id]['custom_replace_from'][$language_id],
'custom_replace_to' =>$data['store_setting'][$store_id]['custom_replace_to'][$language_id],
);
$data['product_seo_url'][$store_id][$language_id] = $this->load->controller('extension/module/seo_url_generator/generateSeoUrl', $sug_data);
$sug_log->write(4, $data['product_seo_url'][$store_id][$language_id], 'model/product.php :: addProduct() : $data["product_seo_url"][$store_id][$language_id]');
}
}
}
$sug_log->write(4, $data['product_seo_url'], 'model/product.php :: addProduct() : $data["product_seo_url"] AFTER SUG');
// SEO URL Generator . end
if (isset($data['product_seo_url'])) {
foreach ($data['product_seo_url'] as $store_id => $language) {
foreach ($language as $language_id => $keyword) {
if (!empty($keyword)) {
$this->db->query("INSERT INTO " . DB_PREFIX . "seo_url SET store_id = '" . (int)$store_id . "', language_id = '" . (int)$language_id . "', query = 'product_id=" . (int)$product_id . "', keyword = '" . $this->db->escape($keyword) . "'");
}
}
}
}
if (isset($data['product_layout'])) {
foreach ($data['product_layout'] as $store_id => $layout_id) {
$this->db->query("INSERT INTO " . DB_PREFIX . "product_to_layout SET product_id = '" . (int)$product_id . "', store_id = '" . (int)$store_id . "', layout_id = '" . (int)$layout_id . "'");
}
}
$this->cache->delete('product');
return $product_id;
}
public function editProduct($product_id, $data) {
// handle extra data for universal import
$univimp_extra = array();
if (!empty($data['import_batch'])) {
$univimp_extra[] = 'import_batch = "' . $this->db->escape($data['import_batch']) . '"';
}
if (!empty($data['gkd_extra_fields']) && defined('GKD_UNIV_IMPORT')) {
foreach ($data['gkd_extra_fields'] as $extra_field) {
if (isset($data[$extra_field])) {
$univimp_extra[] = '`' . $this->db->escape($extra_field) .'` = "' . $this->db->escape($data[$extra_field]) . '"';
}
}
}
if (!empty($univimp_extra)) {
$this->db->query("UPDATE ".DB_PREFIX."product SET " . implode(',', $univimp_extra) . " WHERE product_id = '" . (int)$product_id . "'");
}
$this->db->query("UPDATE " . DB_PREFIX . "product SET model = '" . $this->db->escape($data['model']) . "', sku = '" . $this->db->escape($data['sku']) . "', upc = '" . $this->db->escape($data['upc']) . "', ean = '" . $this->db->escape($data['ean']) . "', jan = '" . $this->db->escape($data['jan']) . "', isbn = '" . $this->db->escape($data['isbn']) . "', mpn = '" . $this->db->escape($data['mpn']) . "', location = '" . $this->db->escape($data['location']) . "', quantity = '" . (int)$data['quantity'] . "', minimum = '" . (int)$data['minimum'] . "', subtract = '" . (int)$data['subtract'] . "', stock_status_id = '" . (int)$data['stock_status_id'] . "', date_available = '" . $this->db->escape($data['date_available']) . "', manufacturer_id = '" . (int)$data['manufacturer_id'] . "', shipping = '" . (int)$data['shipping'] . "', price = '" . (float)$data['price'] . "', points = '" . (int)$data['points'] . "', weight = '" . (float)$data['weight'] . "', weight_class_id = '" . (int)$data['weight_class_id'] . "', length = '" . (float)$data['length'] . "', width = '" . (float)$data['width'] . "', height = '" . (float)$data['height'] . "', length_class_id = '" . (int)$data['length_class_id'] . "', status = '" . (int)$data['status'] . "', tax_class_id = '" . (int)$data['tax_class_id'] . "', sort_order = '" . (int)$data['sort_order'] . "', date_modified = NOW() WHERE product_id = '" . (int)$product_id . "'");
if (isset($data['image'])) {
$this->db->query("UPDATE " . DB_PREFIX . "product SET image = '" . $this->db->escape($data['image']) . "' WHERE product_id = '" . (int)$product_id . "'");
}
$this->db->query("DELETE FROM " . DB_PREFIX . "product_description WHERE product_id = '" . (int)$product_id . "'");
foreach ($data['product_description'] as $language_id => $value) {
// handle extra data for universal import
$univimp_extra_desc = '';
if (!empty($data['gkd_extra_desc_fields']) && defined('GKD_UNIV_IMPORT')) {
foreach ($data['gkd_extra_desc_fields'] as $extra_field) {
if (isset($value[$extra_field])) {
$univimp_extra_desc .= '`' . $this->db->escape($extra_field) .'` = "' . $this->db->escape($value[$extra_field]) . '", ';
}
}
}
$this->db->query("INSERT INTO " . DB_PREFIX . "product_description SET " . $univimp_extra_desc . " product_id = '" . (int)$product_id . "', language_id = '" . (int)$language_id . "', name = '" . $this->db->escape($value['name']) . "', description = '" . $this->db->escape($value['description']) . "', short_description = '" . $this->db->escape($value['short_description']) . "', tag = '" . $this->db->escape($value['tag']) . "', meta_title = '" . $this->db->escape($value['meta_title']) . "', meta_description = '" . $this->db->escape($value['meta_description']) . "', meta_keyword = '" . $this->db->escape($value['meta_keyword']) . "'");
}
$this->db->query("DELETE FROM " . DB_PREFIX . "product_to_store WHERE product_id = '" . (int)$product_id . "'");
if (isset($data['product_store'])) {
foreach ($data['product_store'] as $store_id) {
$this->db->query("INSERT INTO " . DB_PREFIX . "product_to_store SET product_id = '" . (int)$product_id . "', store_id = '" . (int)$store_id . "'");
}
}
$this->db->query("DELETE FROM " . DB_PREFIX . "product_attribute WHERE product_id = '" . (int)$product_id . "'");
$this->db->query("DELETE FROM " . DB_PREFIX . "product_attach_extendlink WHERE product_id = '" . (int) $product_id . "'");
$this->db->query("DELETE FROM " . DB_PREFIX . "product_attach_file WHERE product_id = '" . (int) $product_id . "'");
if (isset($data['product_attach'])) {
foreach ($data['product_attach'] as $product_attach) {
if(is_file(DIR_IMAGE . '' .$product_attach['filename'])){
$login_required = isset($product_attach['login_required']) ? 1 : 0;
$filename = $this->db->escape($product_attach['filename']);
$mask = $this->db->escape($product_attach['mask']);
$download = isset($product_attach['download']) ? $product_attach['download'] : 0;
$this->db->query("INSERT INTO " . DB_PREFIX . "product_attach_file SET product_id = '" . (int)$product_id . "', filename = '" . $filename . "', mask = '" . $mask . "', login_required = '" . $login_required . "' ,download = '" . $download . "'");
}
}
}
if (isset($data['exten_link'])) {
foreach ($data['exten_link'] as $link) {
$link_name = trim($this->db->escape($link['link_name']));
$link_download = trim($this->db->escape($link['link_download']));
$login_required = isset($link['login_required']) ? 1 : 0 ;
$this->db->query("INSERT INTO " . DB_PREFIX . "product_attach_extendlink SET product_id = '" . (int)$product_id . "',link_name = '" . $link_name . "',link_download = '" . $link_download . "', login_required = '" . $login_required . "'");
}
}
if (!empty($data['product_attribute'])) {
foreach ($data['product_attribute'] as $product_attribute) {
if ($product_attribute['attribute_id']) {
// Removes duplicates
$this->db->query("DELETE FROM " . DB_PREFIX . "product_attribute WHERE product_id = '" . (int)$product_id . "' AND attribute_id = '" . (int)$product_attribute['attribute_id'] . "'");
foreach ($product_attribute['product_attribute_description'] as $language_id => $product_attribute_description) {
$this->db->query("INSERT INTO " . DB_PREFIX . "product_attribute SET product_id = '" . (int)$product_id . "', attribute_id = '" . (int)$product_attribute['attribute_id'] . "', language_id = '" . (int)$language_id . "', text = '" . $this->db->escape($product_attribute_description['text']) . "'");
}
}
}
}
$this->db->query("DELETE FROM " . DB_PREFIX . "product_option WHERE product_id = '" . (int)$product_id . "'");
$this->db->query("DELETE FROM " . DB_PREFIX . "product_option_value WHERE product_id = '" . (int)$product_id . "'");
if (isset($data['product_option'])) {
foreach ($data['product_option'] as $product_option) {
if ($product_option['type'] == 'select' || $product_option['type'] == 'radio' || $product_option['type'] == 'checkbox' || $product_option['type'] == 'image') {
if (isset($product_option['product_option_value'])) {
if (defined('GKD_UNIV_IMPORT') && !isset($product_option['product_option_id'])) {
$product_option['product_option_id'] = '';
}
$this->db->query("INSERT INTO " . DB_PREFIX . "product_option SET product_option_id = '" . (int)$product_option['product_option_id'] . "', product_id = '" . (int)$product_id . "', option_id = '" . (int)$product_option['option_id'] . "', required = '" . (int)$product_option['required'] . "'");
$product_option_id = $this->db->getLastId();
foreach ($product_option['product_option_value'] as $product_option_value) {
if (defined('GKD_UNIV_IMPORT') && !isset($product_option_value['product_option_value_id'])) {
$product_option_value['product_option_value_id'] = '';
}
$this->db->query("INSERT INTO " . DB_PREFIX . "product_option_value SET product_option_value_id = '" . (int)$product_option_value['product_option_value_id'] . "', product_option_id = '" . (int)$product_option_id . "', product_id = '" . (int)$product_id . "', option_id = '" . (int)$product_option['option_id'] . "', option_value_id = '" . (int)$product_option_value['option_value_id'] . "', quantity = '" . (int)$product_option_value['quantity'] . "', subtract = '" . (int)$product_option_value['subtract'] . "', price = '" . (float)$product_option_value['price'] . "', price_prefix = '" . $this->db->escape($product_option_value['price_prefix']) . "', points = '" . (int)$product_option_value['points'] . "', points_prefix = '" . $this->db->escape($product_option_value['points_prefix']) . "', weight = '" . (float)$product_option_value['weight'] . "', weight_prefix = '" . $this->db->escape($product_option_value['weight_prefix']) . "'");
}
}
} else {
if (defined('GKD_UNIV_IMPORT') && !isset($product_option['product_option_id'])) {
$product_option['product_option_id'] = '';
}
$this->db->query("INSERT INTO " . DB_PREFIX . "product_option SET product_option_id = '" . (int)$product_option['product_option_id'] . "', product_id = '" . (int)$product_id . "', option_id = '" . (int)$product_option['option_id'] . "', value = '" . $this->db->escape($product_option['value']) . "', required = '" . (int)$product_option['required'] . "'");
}
}
}
$this->db->query("DELETE FROM `" . DB_PREFIX . "product_recurring` WHERE product_id = " . (int)$product_id);
if (isset($data['product_recurring'])) {
foreach ($data['product_recurring'] as $product_recurring) {
$this->db->query("INSERT INTO `" . DB_PREFIX . "product_recurring` SET `product_id` = " . (int)$product_id . ", customer_group_id = " . (int)$product_recurring['customer_group_id'] . ", `recurring_id` = " . (int)$product_recurring['recurring_id']);
}
}
$this->db->query("DELETE FROM " . DB_PREFIX . "product_discount WHERE product_id = '" . (int)$product_id . "'");
if (isset($data['product_discount'])) {
foreach ($data['product_discount'] as $product_discount) {
$this->db->query("INSERT INTO " . DB_PREFIX . "product_discount SET product_id = '" . (int)$product_id . "', customer_group_id = '" . (int)$product_discount['customer_group_id'] . "', quantity = '" . (int)$product_discount['quantity'] . "', priority = '" . (int)$product_discount['priority'] . "', price = '" . (float)$product_discount['price'] . "', date_start = '" . $this->db->escape($product_discount['date_start']) . "', date_end = '" . $this->db->escape($product_discount['date_end']) . "'");
}
}
$this->db->query("DELETE FROM " . DB_PREFIX . "product_special WHERE product_id = '" . (int)$product_id . "'");
if (isset($data['product_special'])) {
foreach ($data['product_special'] as $product_special) {
$this->db->query("INSERT INTO " . DB_PREFIX . "product_special SET product_id = '" . (int)$product_id . "', customer_group_id = '" . (int)$product_special['customer_group_id'] . "', priority = '" . (int)$product_special['priority'] . "', price = '" . (float)$product_special['price'] . "', date_start = '" . $this->db->escape($product_special['date_start']) . "', date_end = '" . $this->db->escape($product_special['date_end']) . "'");
}
}
$this->db->query("DELETE FROM " . DB_PREFIX . "product_image WHERE product_id = '" . (int)$product_id . "'");
if (isset($data['product_image'])) {
foreach ($data['product_image'] as $product_image) {
$this->db->query("INSERT INTO " . DB_PREFIX . "product_image SET product_id = '" . (int)$product_id . "', image = '" . $this->db->escape($product_image['image']) . "', sort_order = '" . (int)$product_image['sort_order'] . "'");
}
}
$this->db->query("DELETE FROM " . DB_PREFIX . "product_to_download WHERE product_id = '" . (int)$product_id . "'");
if (isset($data['product_download'])) {
foreach ($data['product_download'] as $download_id) {
$this->db->query("INSERT INTO " . DB_PREFIX . "product_to_download SET product_id = '" . (int)$product_id . "', download_id = '" . (int)$download_id . "'");
}
}
$this->db->query("DELETE FROM " . DB_PREFIX . "product_to_category WHERE product_id = '" . (int)$product_id . "'");
if (isset($data['product_category'])) {
foreach ($data['product_category'] as $category_id) {
$this->db->query("INSERT INTO " . DB_PREFIX . "product_to_category SET product_id = '" . (int)$product_id . "', category_id = '" . (int)$category_id . "'");
}
}
$this->db->query("DELETE FROM " . DB_PREFIX . "product_filter WHERE product_id = '" . (int)$product_id . "'");
if (isset($data['product_filter'])) {
foreach ($data['product_filter'] as $filter_id) {
$this->db->query("INSERT INTO " . DB_PREFIX . "product_filter SET product_id = '" . (int)$product_id . "', filter_id = '" . (int)$filter_id . "'");
// Universal Import/Export - apply filters to cateogories
if (!empty($data['uiep_filter_to_category'])) {
if (!empty($data['product_filter']) && !empty($data['product_category'])) {
foreach ($data['product_category'] as $category_id) {
foreach ($data['product_filter'] as $filter_id) {
$this->db->query("INSERT IGNORE INTO " . DB_PREFIX . "category_filter SET category_id = '" . (int)$category_id . "', filter_id = '" . (int)$filter_id . "'");
}
}
}
}
}
}
$this->db->query("DELETE FROM " . DB_PREFIX . "product_related WHERE product_id = '" . (int)$product_id . "'");
$this->db->query("DELETE FROM " . DB_PREFIX . "product_related WHERE related_id = '" . (int)$product_id . "'");
if (isset($data['product_related'])) {
foreach ($data['product_related'] as $related_id) {
$this->db->query("DELETE FROM " . DB_PREFIX . "product_related WHERE product_id = '" . (int)$product_id . "' AND related_id = '" . (int)$related_id . "'");
$this->db->query("INSERT INTO " . DB_PREFIX . "product_related SET product_id = '" . (int)$product_id . "', related_id = '" . (int)$related_id . "'");
$this->db->query("DELETE FROM " . DB_PREFIX . "product_related WHERE product_id = '" . (int)$related_id . "' AND related_id = '" . (int)$product_id . "'");
$this->db->query("INSERT INTO " . DB_PREFIX . "product_related SET product_id = '" . (int)$related_id . "', related_id = '" . (int)$product_id . "'");
}
}
$this->db->query("DELETE FROM " . DB_PREFIX . "product_reward WHERE product_id = '" . (int)$product_id . "'");
if (isset($data['product_reward'])) {
foreach ($data['product_reward'] as $customer_group_id => $value) {
if ((int)$value['points'] > 0) {
$this->db->query("INSERT INTO " . DB_PREFIX . "product_reward SET product_id = '" . (int)$product_id . "', customer_group_id = '" . (int)$customer_group_id . "', points = '" . (int)$value['points'] . "'");
}
}
}
// SEO URL
/* SEO URL Generator . begin
------------------------------------------------------------------------- */
// В случае редактирования из админки мы имеем сразу 3 ЧПУ
// 1 - $keyword_old - тот, который есть в базе на момент до редактирования - именно для него нужен редирект (!)
// 2 - $data['product_seo_url'][$store_id][$language_id] - тот, который введен в форму - он может совпадать с $keyword_old, быть введенным вручную или вообще отсутствовать
// 3 - $keyword_new - тот, который генерируется автоматически, в случае, когда это необходимо
$this->load->model('extension/module/seo_url_generator');
$sug_log = new StdeLog('seo_url_generator');
$sug_log->setDebug($this->config->get('module_seo_url_generator_debug'));
$sug_log->write(2, 'model/product.php :: editProduct() is called');
$sug_log->write(4, $data['product_seo_url'], 'model/product.php :: editProduct() : $data["product_seo_url"] BEFORE SUG');
if (isset($data['seo_url_generator_redirects'])) {
$sug_log->write(4, $data['seo_url_generator_redirects'], 'model/product.php :: editProduct() : $data["seo_url_generator_redirects"]');
}
if (isset($data['seo_url_generator_front_works'])) {
$sug_front_ok = true;
$sug_log->write(4, 'ISSET', 'model/product.php :: editProduct() : $data["seo_url_generator_front_works"]');
} else {
$sug_front_ok = false;
$sug_log->write(4, 'NULL', 'model/product.php :: editProduct() : $data["seo_url_generator_front_works"]');
}
#
# SETTING
#
$sug_data['setting'] = array();
$this->load->model('localisation/language');
$data['languages'] = $this->model_localisation_language->getLanguages();
$this->load->model('setting/setting');
$data['store_setting'] = array();
foreach ($data['product_seo_url'] as $store_id => $store) {
$store_setting = $this->model_setting_setting->getSetting('module_seo_url_generator', $store_id);
$data['store_setting'][$store_id]['translit_function'] = $store_setting['module_seo_url_generator_translit_function'];
$data['store_setting'][$store_id]['formula'] = $store_setting['module_seo_url_generator_product_formula'];
$data['store_setting'][$store_id]['delimiter_char'] = $store_setting['module_seo_url_generator_delimiter_char'];
$data['store_setting'][$store_id]['change_delimiter_char'] = $store_setting['module_seo_url_generator_change_delimiter_char'];
$data['store_setting'][$store_id]['rewrite_on_save'] = $store_setting['module_seo_url_generator_rewrite_on_save'];
$data['store_setting'][$store_id]['custom_replace_from'] = $store_setting['module_seo_url_generator_custom_replace_from'];
$data['store_setting'][$store_id]['custom_replace_to'] = $store_setting['module_seo_url_generator_custom_replace_to'];
}
$keywords_old = $this->model_extension_module_seo_url_generator->getURLs('product_id', $this->request->get['product_id']);
$sug_log->write(4, $keywords_old, 'model/product.php :: editProduct() : $keywords_old');
$redirects_exist = $this->model_extension_module_seo_url_generator->getRedirects('product_id', $this->request->get['product_id']);
$sug_log->write(4, $redirects_exist, 'model/product.php :: editProduct() : $redirects_exist');
#
# ITTERATIONS
#
foreach ($data['product_seo_url'] as $store_id => $store) {
foreach ($store as $language_id => $url) {
# SEO URL PROCESSING
$sug_data = array(
'name' => $data['product_description'][$language_id]['name'],
'model' => $data['model'],
'manufacturer_id' => $data['manufacturer_id'],
'sku' => $data['sku'],
'primary_key' => 'product_id',
'essence' => 'product',
'essence_id' => $this->request->get['product_id'],
);
$sug_data['setting'] = array(
'translit_function' =>$data['store_setting'][$store_id]['translit_function'][$language_id],
'formula' =>$data['store_setting'][$store_id]['formula'][$language_id],
'delimiter_char' =>$data['store_setting'][$store_id]['delimiter_char'][$language_id],
'change_delimiter_char' =>$data['store_setting'][$store_id]['change_delimiter_char'][$language_id],
'rewrite_on_save' =>$data['store_setting'][$store_id]['rewrite_on_save'][$language_id],
'custom_replace_from' =>$data['store_setting'][$store_id]['custom_replace_from'][$language_id],
'custom_replace_to' =>$data['store_setting'][$store_id]['custom_replace_to'][$language_id],
);
$data['product_seo_url'][$store_id][$language_id] = trim($data['product_seo_url'][$store_id][$language_id]);
$sug_log->write(2, $data['product_seo_url'][$store_id][$language_id], 'model/product.php :: editProduct() : $data["product_seo_url"][$store_id][$language_id]');
$sug_set_backend_autoredirects = false;
$keyword_new = false;
$keyword_old = count($keywords_old) > 0 && isset($keywords_old[$store_id][$language_id]) ? $keywords_old[$store_id][$language_id] : '';
$sug_log->write(4, $keyword_old, 'model/product.php :: editProduct() : $keyword_old');
$sug_log->write(4, $sug_data, 'model/product.php :: editProduct() : $sug_data');
if (!$keyword_old && !$data['product_seo_url'][$store_id][$language_id]) {
// Все понятно: старого ЧПУ нет, просто генерим новый. Редиректы не нужны.
$sug_log->write(4, $keyword_old, 'model/product.php :: editProduct() : EMPTY $keyword_old & $data["product_seo_url"][$store_id][$language_id]');
$data['product_seo_url'][$store_id][$language_id] = $this->load->controller('extension/module/seo_url_generator/generateSeoUrl', $sug_data);
//$this->cache->delete('seo_pro');
continue;
}
if (!$keyword_old && $data['product_seo_url'][$store_id][$language_id]) {
// Снова все понятно: старого ЧПУ в базе нет, соглашаемся с ЧПУ из формы
// Q?
// А транлитировать этот ЧПУ надо или нет?..
//$this->cache->delete('seo_pro');
continue;
}
if ($keyword_old && !$data['product_seo_url'][$store_id][$language_id]) {
// Просто используем существующий ЧПУ из базы
$data['product_seo_url'][$store_id][$language_id] = $keyword_old;
}
if ($keyword_old && $data['product_seo_url'][$store_id][$language_id] && $keyword_old != $data['product_seo_url'][$store_id][$language_id]) {
// Запускаем механизм редиректов, только если на фронте не работает
if (!$sug_front_ok) {
$sug_set_backend_autoredirects = true;
}
$keyword_new = $data['product_seo_url'][$store_id][$language_id];
// Q?
// А транлитировать этот ЧПУ надо или нет?..
// Минуем актуализацию, итак понятно, что $keyword_old != $data['product_seo_url'][$store_id][$language_id]
goto sug_edit_end;
}
if ($keyword_old && $data['product_seo_url'][$store_id][$language_id] && $keyword_old == $data['product_seo_url'][$store_id][$language_id] && $sug_data['setting']['rewrite_on_save']) {
// Актуализация по данным сущности - название, другая формула
// ставить ли редирект, будет понятно лишь после сравнения старого и нового ЧПУ
$keyword_new = $this->load->controller('extension/module/seo_url_generator/generateSeoUrl', $sug_data);
}
// Make unique
if ($keyword_new && !$this->model_extension_module_seo_url_generator->isUnique($keyword_new, $sug_data['primary_key'], $sug_data['essence_id'], $store_id)) {
$keyword_new = $this->model_extension_module_seo_url_generator->makeUniqueUrl($keyword_new, $store_id);
}
// Актуализация по разделителю
if ($keyword_new && $sug_data['setting']['rewrite_on_save']) {
$sug_log->write(4, 'model/product.php :: editProduct() : Actualization by delimeter BEGIN');
if ('donot' != $sug_data['setting']['change_delimiter_char']) {
// Compare without delimiters
$keyword_old_without_delimiters = preg_replace(array('|_+|', '|-+|'), array('', ''), $keyword_old);
$keyword_new_without_delimiters = preg_replace(array('|_+|', '|-+|'), array('', ''), $keyword_new);
$sug_log->write(3, $keyword_old_without_delimiters, 'generateSeoUrl() : $keyword_old_without_delimiters');
$sug_log->write(3, $keyword_new_without_delimiters, 'generateSeoUrl() : $keyword_new_without_delimiters');
if ($keyword_old_without_delimiters != $keyword_new_without_delimiters) {
$sug_set_backend_autoredirects = true;
$data['product_seo_url'][$store_id][$language_id] = $keyword_new;
}
} else {
// Compare with delimiters
if ($keyword_old != $keyword_new) {
$sug_set_backend_autoredirects = true;
$data['product_seo_url'][$store_id][$language_id] = $keyword_new;
}
}
}
// Write Redirect
sug_edit_end:
$sug_log->write(4, 'model/product.php :: editProduct() : sug_redirects BEGIN');
$sug_log->write(4, $sug_set_backend_autoredirects, 'model/product.php :: editProduct() : $sug_set_backend_autoredirects');
$sug_log->write(4, $keyword_new, 'model/product.php :: editProduct() : $keyword_new');
// Удаляем все существующие редиректы из базы для данной сущности - на фронте предупреждение было выдано, чтобы не убирали из формы
$this->db->query("DELETE FROM " . DB_PREFIX . "seo_url_generator_redirects WHERE query = 'product_id=" . (int)$product_id . "'");
// Обрабатываем редиректы из формы - все управление редриректами у пользователя на фронте!
if (isset($data['seo_url_generator_redirects'][$store_id][$language_id]) && count($data['seo_url_generator_redirects'][$store_id][$language_id]) > 0) {
$sug_log->write(4, $data['seo_url_generator_redirects'][$store_id][$language_id], 'model/product.php :: editProduct() : $data["seo_url_generator_redirects"][$store_id][$language_id]');
$data['seo_url_generator_redirects'][$store_id][$language_id] = array_unique($data['seo_url_generator_redirects'][$store_id][$language_id]); // на всякий случай...
foreach ($data['seo_url_generator_redirects'][$store_id][$language_id] as $redirect) {
$this->db->query("INSERT INTO " . DB_PREFIX . "seo_url_generator_redirects SET store_id = '" . (int)$store_id . "', language_id = '" . (int)$language_id . "', seo_url_old = '" . $this->db->escape($redirect) . "', seo_url_actual = '" . $this->db->escape($data['product_seo_url'][$store_id][$language_id]) . "', query = 'product_id=" . (int)$product_id . "'");
}
}
if ($sug_set_backend_autoredirects && !in_array($keyword_old, $data['seo_url_generator_redirects'][$store_id][$language_id]) && !$sug_front_ok) {
$sug_log->write(4, 'model/product.php :: editProduct() : Autoredirect was created on backend');
// setRedirect() кроме того, что просто записывет текущий редирект, также обновляет новый ЧПУ для всех старый редиректов
$this->model_extension_module_seo_url_generator->setRedirect($keyword_new, $keyword_old, $sug_data['primary_key'], $sug_data['essence_id'], $store_id, $language_id);
}
}
}
/* SEO URL Generator . end
------------------------------------------------------------------------- */
$this->db->query("DELETE FROM " . DB_PREFIX . "seo_url WHERE query = 'product_id=" . (int)$product_id . "'");
if (isset($data['product_seo_url'])) {
foreach ($data['product_seo_url']as $store_id => $language) {
foreach ($language as $language_id => $keyword) {
if (!empty($keyword)) {
$this->db->query("INSERT INTO " . DB_PREFIX . "seo_url SET store_id = '" . (int)$store_id . "', language_id = '" . (int)$language_id . "', query = 'product_id=" . (int)$product_id . "', keyword = '" . $this->db->escape($keyword) . "'");
}
}
}
}
$this->db->query("DELETE FROM " . DB_PREFIX . "product_to_layout WHERE product_id = '" . (int)$product_id . "'");
if (isset($data['product_layout'])) {
foreach ($data['product_layout'] as $store_id => $layout_id) {
$this->db->query("INSERT INTO " . DB_PREFIX . "product_to_layout SET product_id = '" . (int)$product_id . "', store_id = '" . (int)$store_id . "', layout_id = '" . (int)$layout_id . "'");
}
}
$this->cache->delete('product');
}
public function copyProduct($product_id) {
$query = $this->db->query("SELECT DISTINCT * FROM " . DB_PREFIX . "product p WHERE p.product_id = '" . (int)$product_id . "'");
if ($query->num_rows) {
$data = $query->row;
$data['sku'] = '';
$data['upc'] = '';
$data['viewed'] = '0';
$data['keyword'] = '';
$data['product_seo_url'] = array(); // SEO URL Generator
$data['status'] = '0';
$data['product_attribute'] = $this->getProductAttributes($product_id);
$data['product_description'] = $this->getProductDescriptions($product_id);
$data['product_discount'] = $this->getProductDiscounts($product_id);
$data['product_filter'] = $this->getProductFilters($product_id);
$data['product_image'] = $this->getProductImages($product_id);
$data['product_option'] = $this->getProductOptions($product_id);
$data['product_related'] = $this->getProductRelated($product_id);
$data['product_reward'] = $this->getProductRewards($product_id);
$data['product_special'] = $this->getProductSpecials($product_id);
$data['product_category'] = $this->getProductCategories($product_id);
$data['product_download'] = $this->getProductDownloads($product_id);
$data['product_layout'] = $this->getProductLayouts($product_id);
$data['product_store'] = $this->getProductStores($product_id);
$data['product_recurrings'] = $this->getRecurrings($product_id);
$data = array_merge($data, array('product_attach' => $this->getProductattachmanager($product_id)));
$data = array_merge($data, array('exten_link' => $this->getLinkdownload($product_id)));
$this->addProduct($data);
}
}
public function deleteProduct($product_id) {
$this->db->query("DELETE FROM " . DB_PREFIX . "product WHERE product_id = '" . (int)$product_id . "'");
// SEO URL Generator . begin
$this->db->query("DELETE FROM " . DB_PREFIX . "seo_url_generator_redirects WHERE query = 'product_id=" . (int)$product_id . "'");
// SEO URL Generator . end
$this->db->query("DELETE FROM " . DB_PREFIX . "product_attribute WHERE product_id = '" . (int)$product_id . "'");
$this->db->query("DELETE FROM " . DB_PREFIX . "product_description WHERE product_id = '" . (int)$product_id . "'");
$this->db->query("DELETE FROM " . DB_PREFIX . "product_discount WHERE product_id = '" . (int)$product_id . "'");
$this->db->query("DELETE FROM " . DB_PREFIX . "product_filter WHERE product_id = '" . (int)$product_id . "'");
$this->db->query("DELETE FROM " . DB_PREFIX . "product_image WHERE product_id = '" . (int)$product_id . "'");
$this->db->query("DELETE FROM " . DB_PREFIX . "product_option WHERE product_id = '" . (int)$product_id . "'");
$this->db->query("DELETE FROM " . DB_PREFIX . "product_option_value WHERE product_id = '" . (int)$product_id . "'");
$this->db->query("DELETE FROM " . DB_PREFIX . "product_related WHERE product_id = '" . (int)$product_id . "'");
$this->db->query("DELETE FROM " . DB_PREFIX . "product_related WHERE related_id = '" . (int)$product_id . "'");
$this->db->query("DELETE FROM " . DB_PREFIX . "product_reward WHERE product_id = '" . (int)$product_id . "'");
$this->db->query("DELETE FROM " . DB_PREFIX . "product_special WHERE product_id = '" . (int)$product_id . "'");
$this->db->query("DELETE FROM " . DB_PREFIX . "product_to_category WHERE product_id = '" . (int)$product_id . "'");
$this->db->query("DELETE FROM " . DB_PREFIX . "product_to_download WHERE product_id = '" . (int)$product_id . "'");
$this->db->query("DELETE FROM " . DB_PREFIX . "product_to_layout WHERE product_id = '" . (int)$product_id . "'");
$this->db->query("DELETE FROM " . DB_PREFIX . "product_to_store WHERE product_id = '" . (int)$product_id . "'");
$this->db->query("DELETE FROM " . DB_PREFIX . "product_recurring WHERE product_id = " . (int)$product_id);
$this->db->query("DELETE FROM " . DB_PREFIX . "product_attach_extendlink WHERE product_id = '" . (int) $product_id . "'");
$this->db->query("DELETE FROM " . DB_PREFIX . "product_attach_file WHERE product_id = '" . (int) $product_id . "'");
$this->db->query("DELETE FROM " . DB_PREFIX . "review WHERE product_id = '" . (int)$product_id . "'");
$this->db->query("DELETE FROM " . DB_PREFIX . "seo_url WHERE query = 'product_id=" . (int)$product_id . "'");
$this->db->query("DELETE FROM " . DB_PREFIX . "coupon_product WHERE product_id = '" . (int)$product_id . "'");
$this->cache->delete('product');
}
public function getProduct($product_id) {
$query = $this->db->query("SELECT DISTINCT * FROM " . DB_PREFIX . "product p LEFT JOIN " . DB_PREFIX . "product_description pd ON (p.product_id = pd.product_id) WHERE p.product_id = '" . (int)$product_id . "' AND pd.language_id = '" . (int)$this->config->get('config_language_id') . "'");
return $query->row;
}
public function getProducts($data = array()) {
$sql = "SELECT * FROM " . DB_PREFIX . "product p LEFT JOIN " . DB_PREFIX . "product_description pd ON (p.product_id = pd.product_id) WHERE pd.language_id = '" . (int)$this->config->get('config_language_id') . "'";
if (!empty($data['filter_import_batch'])) {
$sql .= " AND p.import_batch = '" . $this->db->escape($data['filter_import_batch']) . "'";
}
if (!empty($data['filter_name'])) {
$sql .= " AND pd.name LIKE '" . $this->db->escape($data['filter_name']) . "%'";
}
if (!empty($data['filter_model'])) {
$sql .= " AND p.model LIKE '" . $this->db->escape($data['filter_model']) . "%'";
}
if (!empty($data['filter_price'])) {
$sql .= " AND p.price LIKE '" . $this->db->escape($data['filter_price']) . "%'";
}
if (isset($data['filter_quantity']) && $data['filter_quantity'] !== '') {
$sql .= " AND p.quantity = '" . (int)$data['filter_quantity'] . "'";
}
if (isset($data['filter_status']) && $data['filter_status'] !== '') {
$sql .= " AND p.status = '" . (int)$data['filter_status'] . "'";
}
$sql .= " GROUP BY p.product_id";
$sort_data = array(
'pd.name',
'p.model',
'p.price',
'p.quantity',
'p.status',
'p.sort_order'
);
if (isset($data['sort']) && in_array($data['sort'], $sort_data)) {
$sql .= " ORDER BY " . $data['sort'];
} else {
$sql .= " ORDER BY pd.name";
}
if (isset($data['order']) && ($data['order'] == 'DESC')) {
$sql .= " DESC";
} else {
$sql .= " ASC";
}
if (isset($data['start']) || isset($data['limit'])) {
if ($data['start'] < 0) {
$data['start'] = 0;
}
if ($data['limit'] < 1) {
$data['limit'] = 20;
}
$sql .= " LIMIT " . (int)$data['start'] . "," . (int)$data['limit'];
}
$query = $this->db->query($sql);
return $query->rows;
}
public function getProductsByCategoryId($category_id) {
$query = $this->db->query("SELECT * FROM " . DB_PREFIX . "product p LEFT JOIN " . DB_PREFIX . "product_description pd ON (p.product_id = pd.product_id) LEFT JOIN " . DB_PREFIX . "product_to_category p2c ON (p.product_id = p2c.product_id) WHERE pd.language_id = '" . (int)$this->config->get('config_language_id') . "' AND p2c.category_id = '" . (int)$category_id . "' ORDER BY pd.name ASC");
return $query->rows;
}
public function getProductDescriptions($product_id) {
$product_description_data = array();
$query = $this->db->query("SELECT * FROM " . DB_PREFIX . "product_description WHERE product_id = '" . (int)$product_id . "'");
foreach ($query->rows as $result) {
$product_description_data[$result['language_id']] = array(
'name' => $result['name'],
'description' => $result['description'],
'short_description'=> $result['short_description'],
'meta_title' => $result['meta_title'],
'meta_description' => $result['meta_description'],
'meta_keyword' => $result['meta_keyword'],
'tag' => $result['tag']
);
}
return $product_description_data;
}
public function getProductCategories($product_id) {
$product_category_data = array();
$query = $this->db->query("SELECT * FROM " . DB_PREFIX . "product_to_category WHERE product_id = '" . (int)$product_id . "'");
foreach ($query->rows as $result) {
$product_category_data[] = $result['category_id'];
}
return $product_category_data;
}
public function getProductFilters($product_id) {
$product_filter_data = array();
$query = $this->db->query("SELECT * FROM " . DB_PREFIX . "product_filter WHERE product_id = '" . (int)$product_id . "'");
foreach ($query->rows as $result) {
$product_filter_data[] = $result['filter_id'];
}
return $product_filter_data;
}
public function getProductAttributes($product_id) {
$product_attribute_data = array();
$product_attribute_query = $this->db->query("SELECT attribute_id FROM " . DB_PREFIX . "product_attribute WHERE product_id = '" . (int)$product_id . "' GROUP BY attribute_id");
foreach ($product_attribute_query->rows as $product_attribute) {
$product_attribute_description_data = array();
$product_attribute_description_query = $this->db->query("SELECT * FROM " . DB_PREFIX . "product_attribute WHERE product_id = '" . (int)$product_id . "' AND attribute_id = '" . (int)$product_attribute['attribute_id'] . "'");
foreach ($product_attribute_description_query->rows as $product_attribute_description) {
$product_attribute_description_data[$product_attribute_description['language_id']] = array('text' => $product_attribute_description['text']);
}
$product_attribute_data[] = array(
'attribute_id' => $product_attribute['attribute_id'],
'product_attribute_description' => $product_attribute_description_data
);
}
return $product_attribute_data;
}
public function getProductOptions($product_id) {
$product_option_data = array();
$product_option_query = $this->db->query("SELECT * FROM `" . DB_PREFIX . "product_option` po LEFT JOIN `" . DB_PREFIX . "option` o ON (po.option_id = o.option_id) LEFT JOIN `" . DB_PREFIX . "option_description` od ON (o.option_id = od.option_id) WHERE po.product_id = '" . (int)$product_id . "' AND od.language_id = '" . (int)$this->config->get('config_language_id') . "'");
foreach ($product_option_query->rows as $product_option) {
$product_option_value_data = array();
$product_option_value_query = $this->db->query("SELECT * FROM " . DB_PREFIX . "product_option_value pov LEFT JOIN " . DB_PREFIX . "option_value ov ON(pov.option_value_id = ov.option_value_id) WHERE pov.product_option_id = '" . (int)$product_option['product_option_id'] . "' ORDER BY ov.sort_order ASC");
foreach ($product_option_value_query->rows as $product_option_value) {
$product_option_value_data[] = array(
'product_option_value_id' => $product_option_value['product_option_value_id'],
'option_value_id' => $product_option_value['option_value_id'],
'quantity' => $product_option_value['quantity'],
'subtract' => $product_option_value['subtract'],
'price' => $product_option_value['price'],
'price_prefix' => $product_option_value['price_prefix'],
'points' => $product_option_value['points'],
'points_prefix' => $product_option_value['points_prefix'],
'weight' => $product_option_value['weight'],
'weight_prefix' => $product_option_value['weight_prefix']
);
}
$product_option_data[] = array(
'product_option_id' => $product_option['product_option_id'],
'product_option_value' => $product_option_value_data,
'option_id' => $product_option['option_id'],
'name' => $product_option['name'],
'type' => $product_option['type'],
'value' => $product_option['value'],
'required' => $product_option['required']
);
}
return $product_option_data;
}
public function getProductOptionValue($product_id, $product_option_value_id) {
$query = $this->db->query("SELECT pov.option_value_id, ovd.name, pov.quantity, pov.subtract, pov.price, pov.price_prefix, pov.points, pov.points_prefix, pov.weight, pov.weight_prefix FROM " . DB_PREFIX . "product_option_value pov LEFT JOIN " . DB_PREFIX . "option_value ov ON (pov.option_value_id = ov.option_value_id) LEFT JOIN " . DB_PREFIX . "option_value_description ovd ON (ov.option_value_id = ovd.option_value_id) WHERE pov.product_id = '" . (int)$product_id . "' AND pov.product_option_value_id = '" . (int)$product_option_value_id . "' AND ovd.language_id = '" . (int)$this->config->get('config_language_id') . "'");
return $query->row;
}
public function getProductImages($product_id) {
$query = $this->db->query("SELECT * FROM " . DB_PREFIX . "product_image WHERE product_id = '" . (int)$product_id . "' ORDER BY sort_order ASC");
return $query->rows;
}
public function getProductDiscounts($product_id) {
$query = $this->db->query("SELECT * FROM " . DB_PREFIX . "product_discount WHERE product_id = '" . (int)$product_id . "' ORDER BY quantity, priority, price");
return $query->rows;
}
public function getProductSpecials($product_id) {
$query = $this->db->query("SELECT * FROM " . DB_PREFIX . "product_special WHERE product_id = '" . (int)$product_id . "' ORDER BY priority, price");
return $query->rows;
}
public function getProductRewards($product_id) {
$product_reward_data = array();
$query = $this->db->query("SELECT * FROM " . DB_PREFIX . "product_reward WHERE product_id = '" . (int)$product_id . "'");
foreach ($query->rows as $result) {
$product_reward_data[$result['customer_group_id']] = array('points' => $result['points']);
}
return $product_reward_data;
}
public function getProductDownloads($product_id) {
$product_download_data = array();
$query = $this->db->query("SELECT * FROM " . DB_PREFIX . "product_to_download WHERE product_id = '" . (int)$product_id . "'");
foreach ($query->rows as $result) {
$product_download_data[] = $result['download_id'];
}
return $product_download_data;
}
public function getProductattachmanager($product_id) {
$query = $this->db->query("SELECT * FROM " . DB_PREFIX . "product_attach_file WHERE product_id = '" . (int)$product_id . "'");
return $query->rows;
}
public function getLinkdownload($product_id) {
$query = $this->db->query("SELECT * FROM " . DB_PREFIX . "product_attach_extendlink WHERE product_id = '" . (int)$product_id . "'");
return $query->rows;
}
public function getProductStores($product_id) {
$product_store_data = array();
$query = $this->db->query("SELECT * FROM " . DB_PREFIX . "product_to_store WHERE product_id = '" . (int)$product_id . "'");
foreach ($query->rows as $result) {
$product_store_data[] = $result['store_id'];
}
return $product_store_data;
}
public function getProductSeoUrls($product_id) {
$product_seo_url_data = array();
$query = $this->db->query("SELECT * FROM " . DB_PREFIX . "seo_url WHERE query = 'product_id=" . (int)$product_id . "'");
foreach ($query->rows as $result) {
$product_seo_url_data[$result['store_id']][$result['language_id']] = $result['keyword'];
}
return $product_seo_url_data;
}
public function getProductLayouts($product_id) {
$product_layout_data = array();
$query = $this->db->query("SELECT * FROM " . DB_PREFIX . "product_to_layout WHERE product_id = '" . (int)$product_id . "'");
foreach ($query->rows as $result) {
$product_layout_data[$result['store_id']] = $result['layout_id'];
}
return $product_layout_data;
}
public function getProductRelated($product_id) {
$product_related_data = array();
$query = $this->db->query("SELECT * FROM " . DB_PREFIX . "product_related WHERE product_id = '" . (int)$product_id . "'");
foreach ($query->rows as $result) {
$product_related_data[] = $result['related_id'];
}
return $product_related_data;
}
public function getRecurrings($product_id) {
$query = $this->db->query("SELECT * FROM `" . DB_PREFIX . "product_recurring` WHERE product_id = '" . (int)$product_id . "'");
return $query->rows;
}
public function getTotalProducts($data = array()) {
$sql = "SELECT COUNT(DISTINCT p.product_id) AS total FROM " . DB_PREFIX . "product p LEFT JOIN " . DB_PREFIX . "product_description pd ON (p.product_id = pd.product_id)";
$sql .= " WHERE pd.language_id = '" . (int)$this->config->get('config_language_id') . "'";
if (!empty($data['filter_import_batch'])) {
$sql .= " AND p.import_batch = '" . $this->db->escape($data['filter_import_batch']) . "'";
}
if (!empty($data['filter_name'])) {
$sql .= " AND pd.name LIKE '" . $this->db->escape($data['filter_name']) . "%'";
}
if (!empty($data['filter_model'])) {
$sql .= " AND p.model LIKE '" . $this->db->escape($data['filter_model']) . "%'";
}
if (isset($data['filter_price']) && !is_null($data['filter_price'])) {
$sql .= " AND p.price LIKE '" . $this->db->escape($data['filter_price']) . "%'";
}
if (isset($data['filter_quantity']) && $data['filter_quantity'] !== '') {
$sql .= " AND p.quantity = '" . (int)$data['filter_quantity'] . "'";
}
if (isset($data['filter_status']) && $data['filter_status'] !== '') {
$sql .= " AND p.status = '" . (int)$data['filter_status'] . "'";
}
$query = $this->db->query($sql);
return $query->row['total'];
}
public function getTotalProductsByTaxClassId($tax_class_id) {
$query = $this->db->query("SELECT COUNT(*) AS total FROM " . DB_PREFIX . "product WHERE tax_class_id = '" . (int)$tax_class_id . "'");
return $query->row['total'];
}
public function getTotalProductsByStockStatusId($stock_status_id) {
$query = $this->db->query("SELECT COUNT(*) AS total FROM " . DB_PREFIX . "product WHERE stock_status_id = '" . (int)$stock_status_id . "'");
return $query->row['total'];
}
public function getTotalProductsByWeightClassId($weight_class_id) {
$query = $this->db->query("SELECT COUNT(*) AS total FROM " . DB_PREFIX . "product WHERE weight_class_id = '" . (int)$weight_class_id . "'");
return $query->row['total'];
}
public function getTotalProductsByLengthClassId($length_class_id) {
$query = $this->db->query("SELECT COUNT(*) AS total FROM " . DB_PREFIX . "product WHERE length_class_id = '" . (int)$length_class_id . "'");
return $query->row['total'];
}
public function getTotalProductsByDownloadId($download_id) {
$query = $this->db->query("SELECT COUNT(*) AS total FROM " . DB_PREFIX . "product_to_download WHERE download_id = '" . (int)$download_id . "'");
return $query->row['total'];
}
public function getTotalProductsByManufacturerId($manufacturer_id) {
$query = $this->db->query("SELECT COUNT(*) AS total FROM " . DB_PREFIX . "product WHERE manufacturer_id = '" . (int)$manufacturer_id . "'");
return $query->row['total'];
}
public function getTotalProductsByAttributeId($attribute_id) {
$query = $this->db->query("SELECT COUNT(*) AS total FROM " . DB_PREFIX . "product_attribute WHERE attribute_id = '" . (int)$attribute_id . "'");
return $query->row['total'];
}
public function getTotalProductsByOptionId($option_id) {
$query = $this->db->query("SELECT COUNT(*) AS total FROM " . DB_PREFIX . "product_option WHERE option_id = '" . (int)$option_id . "'");
return $query->row['total'];
}
public function getTotalProductsByProfileId($recurring_id) {
$query = $this->db->query("SELECT COUNT(*) AS total FROM " . DB_PREFIX . "product_recurring WHERE recurring_id = '" . (int)$recurring_id . "'");
return $query->row['total'];
}
public function getTotalProductsByLayoutId($layout_id) {
$query = $this->db->query("SELECT COUNT(*) AS total FROM " . DB_PREFIX . "product_to_layout WHERE layout_id = '" . (int)$layout_id . "'");
return $query->row['total'];
}
}