ModelCatalogProduct::addProduct()

Complexity

Conditions	48
Paths	> 20000

Size

Total Lines	344
Code Lines	199

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function addProduct($data)

Expected 2 blank lines before function; 0 found

    {
        $this->db->query("
            INSERT INTO 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'] . "', 
                manufacturer_id = '" . (int)$data['manufacturer_id'] . "', 
                shipping = '" . (int)$data['shipping'] . "', 
                price = '" . (float)$data['price'] . "', 
                points = '" . (int)$data['points'] . "', 
                width = '" . (float)$data['width'] . "', 
                height = '" . (float)$data['height'] . "', 
                status = '" . (int)$data['status'] . "', 
                noindex = '" . (int)$data['noindex'] . "', 
                sort_order = '" . (int)$data['sort_order'] . "', 
                date_added = NOW()
        ");

        $product_id = $this->db->getLastId();
        
        if (isset($data['product_tab'])) {
            foreach ($data['product_tab'] as $tabdata) {
                $this->db->query("
                    INSERT INTO product_tab 
                    SET product_id = '".(int)$product_id."', 
                        status = '".(int)$tabdata['status']."', 
                        sort_order='".(int)$tabdata['sort_order']."'
                ");
            
                $product_tab_id = $this->db->getLastId();
                foreach ($tabdata['description'] as $language_id => $value) {
                    $this->db->query("
                        INSERT INTO product_tab_desc 
                        SET product_tab_id = '".(int)$product_tab_id."', 
                            heading = '".$this->db->escape($value['heading'])."', 
                            description = '".$this->db->escape($value['description'])."', 
                            product_id = '".(int)$product_id."', 
                            language_id = '".(int)$language_id."'
                    ");
                }
            }
        }

        if (isset($data['image'])) {
            $this->db->query("
                UPDATE product 
                SET image = '" . $this->db->escape($data['image']) . "' 
                WHERE product_id = '" . (int)$product_id . "'
            ");
        }

        foreach ($data['product_description'] as $language_id => $value) {
            $this->db->query("
                INSERT INTO product_description 
                SET product_id = '" . (int)$product_id . "', 
                    language_id = '" . (int)$language_id . "', 
                    name = '" . $this->db->escape($value['name']) . "', 
                    description = '" . $this->db->escape($value['description']) . "', 
                    description_mini = '" . $this->db->escape($value['description_mini']) . "', 
                    tag = '" . $this->db->escape($value['tag']) . "', 
                    meta_title = '" . $this->db->escape($value['meta_title']) . "', 
                    meta_h1 = '" . $this->db->escape($value['meta_h1']) . "', 
                    meta_description = '" . $this->db->escape($value['meta_description']) . "'
            ");
        }

        if (isset($data['product_attribute'])) {
            foreach ($data['product_attribute'] as $product_attribute) {
                if ($product_attribute['attribute_id']) {
                    // Removes duplicates
                    $this->db->query("
                        DELETE 
			FROM 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 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 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 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 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']) . "'
                            ");
                        }
                    }
                } else {
                    $this->db->query("
                        INSERT INTO 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_discount'])) {
            foreach ($data['product_discount'] as $product_discount) {
                $this->db->query("
                    INSERT INTO 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 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 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 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 product_to_category 
                    SET product_id = '" . (int)$product_id . "', 
                        category_id = '" . (int)$category_id . "'
                ");
            }
        }
        
        if (isset($data['main_category_id']) && $data['main_category_id'] > 0) {
            $this->db->query("
                DELETE 
			FROM product_to_category 
                WHERE product_id = '" . (int)$product_id . "' 
                    AND category_id = '" . (int)$data['main_category_id'] . "'
            ");
            $this->db->query("
                INSERT INTO product_to_category 
                SET product_id = '" . (int)$product_id . "', 
                    category_id = '" . (int)$data['main_category_id'] . "', 
                    main_category = 1
            ");
        } elseif (isset($data['product_category'][0])) {
            $this->db->query("
                UPDATE product_to_category 
                SET main_category = 1 
                WHERE product_id = '" . (int)$product_id . "' 
                    AND category_id = '" . (int)$data['product_category'][0] . "'
            ");
        }

        if (isset($data['product_filter'])) {
            foreach ($data['product_filter'] as $filter_id) {
                $this->db->query("
                    INSERT INTO product_filter 
                    SET product_id = '" . (int)$product_id . "', 
                        filter_id = '" . (int)$filter_id . "'
                ");
            }
        }

        if (isset($data['product_related'])) {
            foreach ($data['product_related'] as $related_id) {
                $this->db->query("
                    DELETE 
			FROM product_related 
                    WHERE product_id = '" . (int)$product_id . "' 
                        AND related_id = '" . (int)$related_id . "'
                ");
                $this->db->query("
                    INSERT INTO product_related 
                    SET product_id = '" . (int)$product_id . "', 
                        related_id = '" . (int)$related_id . "'
                ");
                $this->db->query("
                    DELETE 
			FROM product_related 
                    WHERE product_id = '" . (int)$related_id . "' 
                        AND related_id = '" . (int)$product_id . "'
                ");
                $this->db->query("
                    INSERT INTO product_related 
                    SET product_id = '" . (int)$related_id . "', 
                        related_id = '" . (int)$product_id . "'
                ");
            }
        }
        
        if (isset($data['product_related_article'])) {
            foreach ($data['product_related_article'] as $article_id) {
                $this->db->query("
                    DELETE 
			FROM product_related_article 
                    WHERE product_id = '" . (int)$product_id . "' 
                        AND article_id = '" . (int)$article_id . "'
                ");
                $this->db->query("
                    INSERT INTO product_related_article 
                    SET product_id = '" . (int)$product_id . "', 
                        article_id = '" . (int)$article_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 product_reward 
                        SET product_id = '" . (int)$product_id . "', 
                            customer_group_id = '" . (int)$customer_group_id . "', 
                            points = '" . (int)$product_reward['points'] . "'
                    ");
                }
            }
        }
        
        if (isset($data['product_benefits'])) {
            foreach ($data['product_benefits'] as $benefit_id) {
                $this->db->query("
                    INSERT INTO product_to_benefit 
                    SET product_id = '" . (int)$product_id . "', 
                        benefit_id = '" . (int)$benefit_id . "'
                ");
            }
        }
        
        if (isset($data['product_stickers'])) {
            foreach ($data['product_stickers'] as $key => $sticker_id) {
                if ($sticker_id) {
                    $this->db->query("
                        INSERT INTO product_to_sticker 
                        SET product_id = '" . (int)$product_id . "', 
                            position = '" . (int)$key . "', 
                            sticker_id = '" . (int)$sticker_id . "'
                    ");
                }
            }
        }

        if (isset($data['product_layout'])) {
            foreach ($data['product_layout'] as $store_id => $layout_id) {
                $this->db->query("
                    INSERT INTO product_to_layout 
                    SET product_id = '" . (int)$product_id . "', 
                        layout_id = '" . (int)$layout_id . "'
                ");
            }
        }
        
        $this->cache->delete('url_formatter');


        if ($data['keyword']) {
            $this->db->query("
                INSERT INTO url_alias 
                SET query = 'product_id=" . (int)$product_id . "', 
                    keyword = '" . $this->db->escape($data['keyword']) . "'
            ");
        }

        $this->cache->delete('product');

        return $product_id;
    }