Просмотр архива ocStore-2.1.0.2.1


<?php
class ModelOpenbayAmazonProduct extends Model {
    public function setStatus($insertion_id, $status_string) {
        $this->db->query("UPDATE `" . DB_PREFIX . "amazon_product` SET `status` = '" . $this->db->escape($status_string) . "' WHERE `insertion_id` = '" . $this->db->escape($insertion_id) . "'");
    }

    public function getProductRows($insertion_id) {
        return $this->db->query("SELECT * FROM `" . DB_PREFIX . "amazon_product` WHERE `insertion_id` = '" . $this->db->escape($insertion_id) . "'")->rows;
    }

    public function getProduct($insertion_id) {
        return $this->db->query("SELECT * FROM `" . DB_PREFIX . "amazon_product` WHERE `insertion_id` = '" . $this->db->escape($insertion_id) . "'")->row;
    }

    public function linkItems(array $data) {
        foreach ($data as $amazon_sku => $product_id) {
            $var_row = $this->db->query("SELECT `var` FROM `" . DB_PREFIX . "amazon_product` WHERE `sku` = '" . $this->db->escape($amazon_sku) . "' AND `product_id` = '" . (int)$product_id . "'")->row;
            $var = isset($var_row['var']) ? $var_row['var'] : '';
            $this->linkProduct($amazon_sku, $product_id, $var);
        }
    }

    public function insertError($data) {
        $this->db->query("INSERT INTO `" . DB_PREFIX . "amazon_product_error` SET `sku` = '" . $this->db->escape($data['sku']) . "', `error_code` = '" . (int)$data['error_code'] . "', `message` = '" . $this->db->escape($data['message']) . "', `insertion_id` = '" . $this->db->escape($data['insertion_id']) . "'");

        $this->db->query("UPDATE `" . DB_PREFIX . "amazon_product`SET `status` = 'error' WHERE `sku` = '" . $this->db->escape($data['sku']) . "' AND `insertion_id` = '" . $this->db->escape($data['insertion_id']) . "'");
    }

    public function deleteErrors($insertion_id) {
        $this->db->query("DELETE FROM `" . DB_PREFIX . "amazon_product_error` WHERE `insertion_id` = '" . $this->db->escape($insertion_id) . "'");
    }

    public function setSubmitError($insertion_id, $message) {
        $sku_rows = $this->db->query("SELECT `sku` FROM `" . DB_PREFIX . "amazon_product` WHERE `insertion_id` = '" . $this->db->escape($insertion_id) . "'")->rows;

        foreach ($sku_rows as $sku_row) {
            $data = array(
                'sku' => $sku_row['sku'],
                'error_code' => '0',
                'message' => $message,
                'insertion_id' => $insertion_id
            );
            $this->insertError($data);
        }
    }

    public function linkProduct($amazon_sku, $product_id, $var = '') {
        $count = $this->db->query("SELECT COUNT(*) as 'count' FROM `" . DB_PREFIX . "amazon_product_link` WHERE `product_id` = '" . (int)$product_id . "' AND `amazon_sku` = '" . $this->db->escape($amazon_sku) . "' AND `var` = '" . $this->db->escape($var) . "' LIMIT 1")->row;
        if ($count['count'] == 0) {
            $this->db->query("INSERT INTO `" . DB_PREFIX . "amazon_product_link` SET `product_id` = '" . (int)$product_id . "', `amazon_sku` = '" . $this->db->escape($amazon_sku) . "', `var` = '" . $this->db->escape($var) . "'");
        }
    }

    public function getProductQuantity($product_id, $var = '') {
        $this->load->library('openbay/amazon');

        $result = null;

        if ($var !== '' && $this->openbay->addonLoad('openstock')) {
            $this->load->model('tool/image');
            $this->load->model('module/openstock');
            $option_stocks = $this->model_module_openstock->getVariants($product_id);

            $option = null;
            foreach ($option_stocks as $option_iterator) {
                if ($option_iterator['var'] === $var) {
                    $option = $option_iterator;
                    break;
                }
            }

            if ($option != null) {
                $result = $option['stock'];
            }
        } else {
            $this->load->model('catalog/product');
            $product_info = $this->model_catalog_product->getProduct($product_id);

            if (isset($product_info['quantity'])) {
                $result = $product_info['quantity'];
            }
        }
        return $result;
    }

    public function updateSearch($results) {
        foreach ($results as $result) {
            $results_found = count($result['results']);

            $data = json_encode($result['results']);

            $this->db->query("
                UPDATE " . DB_PREFIX . "amazon_product_search
                SET matches = " . (int)$results_found . ",
                    `data` = '" . $this->db->escape($data) . "',
                    `status` = 'finished'
                WHERE product_id = " . (int)$result['product_id'] . " AND
                      marketplace = '" . $this->db->escape($result['marketplace']) . "'
                LIMIT 1
            ");
        }
    }

    public function addListingReport($data) {
        $sql = "INSERT INTO " . DB_PREFIX . "amazon_listing_report (marketplace, sku, quantity, asin, price) VALUES ";

        $sql_values = array();

        foreach ($data as $product) {
            $sql_values[] = " ('" . $this->db->escape($product['marketplace']) . "', '" . $this->db->escape($product['sku']) . "', " . (int)$product['quantity'] . ", '" . $this->db->escape($product['asin']) . "', " . (double)$product['price'] . ") ";
        }

        $sql .= implode(',', $sql_values);

        $this->db->query($sql);
    }

    public function removeListingReportLock($marketplace) {
        $marketplaces = $this->config->get('openbay_amazon_processing_listing_reports');

        if ($marketplaces && ($key = array_search($marketplace, $marketplaces)) !== false) {
            unset($marketplaces[$key]);

            $this->config->set('openbay_amazon_processing_listing_reports', $marketplaces);

            $this->db->query("UPDATE " . DB_PREFIX . "setting SET `value` = '" . $this->db->escape(serialize($marketplaces)) . "', serialized = 1 WHERE `key` = 'openbay_amazon_processing_listing_reports'");
        }
    }
}