OpenCart 🇺🇦

$log = new Log('amazon.log');

$requestXml = '<Request>
<ResponseURL>' . HTTPS_CATALOG . 'index.php?route=amazon/order' . '</ResponseURL>
<MarketplaceIDs>';

foreach ($data['openbay_amazon_orders_marketplace_ids'] as $marketplaceId) {
	$requestXml .= '    <MarketplaceID>' . $marketplaceId . '</MarketplaceID>';
}

$requestXml .= '
</MarketplaceIDs>
Request>';

$response = $this->openbay->amazon->callWithResponse('order/scheduleOrders', $requestXml, false);

libxml_use_internal_errors(true);
$responseXml = simplexml_load_string($response);
libxml_use_internal_errors(false);

if ($responseXml && $responseXml->Status == '0') {
	$log->write('Scheduling orders call was successful');
	return true;
}

$log->write('Failed to schedule orders. Response: ' . $response);

return false;

if(isset($dataArray['fields']['item-price'])) {
	$price = $dataArray['fields']['item-price'];
} else if(isset($dataArray['fields']['price'])) {
	$price = $dataArray['fields']['price'];
} else if(isset($dataArray['fields']['StandardPrice'])) {
	$price = $dataArray['fields']['StandardPrice'];
}   else {
	$price = 0;
}

$category = (isset($dataArray['category'])) ? $dataArray['category'] : "";
$sku = (isset($dataArray['fields']['sku'])) ? $dataArray['fields']['sku'] : "";
if(isset($dataArray['fields']['sku'])) {
	$sku = $dataArray['fields']['sku'];
} else if(isset($dataArray['fields']['SKU'])) {
	$sku = $dataArray['fields']['SKU'];
}

$var = isset($dataArray['optionVar']) ? $dataArray['optionVar'] : '';

$marketplaces = isset($dataArray['marketplace_ids']) ? serialize($dataArray['marketplace_ids']) : serialize(array());

$dataEncoded = json_encode(array('fields' => $dataArray['fields']));

$this->db->query("
	REPLACE INTO `" . DB_PREFIX . "amazon_product`
	SET `product_id` = '" . (int)$product_id . "',
		`sku` = '" . $this->db->escape($sku) . "',
		`category` = '" . $this->db->escape($category) . "',
		`data` = '" . $this->db->escape($dataEncoded) . "',
		`status` = 'saved',
		`insertion_id` = '',
		`price` = '" . $price . "',
		`var` = '" . $this->db->escape($var) . "',
		`marketplaces` = '" . $this->db->escape($marketplaces) . "'");

$this->db->query("DELETE FROM `" . DB_PREFIX . "amazon_product`
	WHERE `product_id` = '" . (int)$product_id . "' AND `var` = '" . $this->db->escape($var) . "'");

return $this->db->query("
	SELECT `ap`.`status`, `ap`.`product_id`, `ap`.`sku` as `amazon_sku`, `pd`.`name` as `product_name`, `p`.`model` as `product_model`, `p`.`sku` as `product_sku`, `ap`.`var` as `var`
	FROM `" . DB_PREFIX . "amazon_product` as `ap`
	LEFT JOIN `" . DB_PREFIX . "product_description` as `pd`
	ON `ap`.`product_id` = `pd`.`product_id`
	LEFT JOIN `" . DB_PREFIX . "product` as `p`
	ON `ap`.`product_id` = `p`.`product_id`
	WHERE `ap`.`status` = 'saved'
	AND `pd`.`language_id` = '" . (int)$this->config->get('config_language_id') . "'")->rows;

return $this->db->query("
	SELECT * FROM `" . DB_PREFIX . "amazon_product`
	WHERE `status` = 'saved' AND `version` = 2")->rows;

return $this->db->query("
	SELECT * FROM `" . DB_PREFIX . "amazon_product`
	WHERE `product_id` = '" . (int)$product_id . "' AND `var` = '" . $this->db->escape($var) . "' AND `version` = 2")->row;

$row = $this->db->query("
	SELECT `category` FROM `" . DB_PREFIX . "amazon_product`
	WHERE `product_id` = '" . (int)$product_id . "' AND `var` = '" . $this->db->escape($var) . "' AND `version` = 2")->row;
if(isset($row['category'])) {
	return $row['category'];
} else {
	return "";
}

$this->db->query(
	"UPDATE `" . DB_PREFIX . "amazon_product`
	SET `status` = 'uploaded', `insertion_id` = '" . $this->db->escape($insertion_id) . "'
	WHERE `product_id` = '" . (int)$product_id . "' AND `var` = '" . $this->db->escape($var) . "' AND `version` = 2");

$this->db->query(
	"UPDATE `" . DB_PREFIX . "amazon_product`
	SET `status` = 'saved', `insertion_id` = ''
	WHERE `insertion_id` = '" . $this->db->escape($insertion_id) . "' AND `version` = 2");

$rowsUploaded = $this->db->query("
	SELECT COUNT(*) count
	FROM `" . DB_PREFIX . "amazon_product`
	WHERE `product_id` = '" . (int)$product_id . "' AND status = 'uploaded'")->row;
$rowsUploaded = $rowsUploaded['count'];

$rowsOk = $this->db->query("
	SELECT COUNT(*) count
	FROM `" . DB_PREFIX . "amazon_product`
	WHERE `product_id` = '" . (int)$product_id . "' AND status = 'ok'")->row;
$rowsOk = $rowsOk['count'];

$rowsError = $this->db->query("
	SELECT COUNT(*) count
	FROM `" . DB_PREFIX . "amazon_product`
	WHERE `product_id` = '" . (int)$product_id . "' AND status = 'error'")->row;
$rowsError = $rowsError['count'];

$rowsSaved = $this->db->query("
	SELECT COUNT(*) count
	FROM `" . DB_PREFIX . "amazon_product`
	WHERE `product_id` = '" . (int)$product_id . "' AND status = 'saved'")->row;
$rowsSaved = $rowsSaved['count'];

$rowsTotal = $rowsUploaded + $rowsOk + $rowsError + $rowsSaved;

$links = $this->db->query("
	SELECT COUNT(*) as count
	FROM `" . DB_PREFIX . "amazon_product_link`
	WHERE `product_id` = '" . (int)$product_id . "'")->row;
$links = $links['count'];


if($rowsTotal === 0 && $links > 0) {
	return 'linked';
} else if($rowsTotal == 0) {
	return false;
}

if($rowsUploaded > 0) {
	return 'processing';
}

if($rowsUploaded == 0 && $rowsOk > 0 && $rowsError == 0) {
	return 'ok';
}

if($rowsSaved > 0) {
	return 'saved';
}

if($rowsUploaded == 0 && $rowsError > 0 && $rowsOk == 0) {
	$quick = $this->db->query("
		SELECT *
		FROM `" . DB_PREFIX . "amazon_product`
		WHERE `product_id` = " . (int)$product_id . " AND `version` = 3")->row;

	if($quick) {
		return 'error_quick';
	} else {
		return 'error_advanced';
	}
} else {
	return 'error_few';
}

return false;

if($version == 3) {
	$messageRow = $this->db->query("
	SELECT `messages` FROM `" . DB_PREFIX . "amazon_product`
	WHERE `product_id` = '" . (int)$product_id . "' AND `version` = 3")->row;

	return json_decode($messageRow['messages']);
}


$result = array();

$insertionRows = $this->db->query("
	SELECT `sku`, `insertion_id` FROM `" . DB_PREFIX . "amazon_product`
	WHERE `product_id` = '" . (int)$product_id . "' AND `version` = 2")->rows;

if(!empty($insertionRows)) {
	foreach($insertionRows as $insertionRow) {
		$errorRows = $this->db->query("
			SELECT * FROM `" . DB_PREFIX . "amazon_product_error`
			WHERE `sku` = '" . $this->db->escape($insertionRow['sku']) . "' AND `insertion_id` = '" . $this->db->escape($insertionRow['insertion_id']) . "'")->rows;
		foreach($errorRows as $errorRow) {
			$result[] = $errorRow;
		}
	}
}
return $result;

return $this->db->query("
	SELECT `product_id`, `sku` FROM `" . DB_PREFIX . "amazon_product`
	WHERE `status` = 'error' AND `version` = 2")->rows;

$this->db->query(
	"DELETE FROM `" . DB_PREFIX . "amazon_product`
	WHERE `product_id` = '" . (int)$product_id . "'");

$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) . "'");
}

$this->db->query(
	"DELETE FROM `" . DB_PREFIX . "amazon_product_link`
	WHERE `amazon_sku` = '" . $this->db->escape($amazon_sku) . "'");

$product_rows = $this->db->query("
	SELECT `insertion_id` FROM `" . DB_PREFIX . "amazon_product`
	WHERE `product_id` = '" . (int)$product_id . "' AND `version` = 2")->rows;

foreach ($product_rows as $product) {
	$this->db->query(
		"DELETE FROM `" . DB_PREFIX . "amazon_product_error`
		WHERE `insertion_id` = '" . $this->db->escape($product['insertion_id']) . "'");
}

$this->db->query(
	"UPDATE `" . DB_PREFIX . "amazon_product`
	SET `status` = 'saved', `insertion_id` = ''
	WHERE `product_id` = '" . (int)$product_id . "' AND `status` = 'error' AND `version` = 2");

$query = "SELECT `apl`.`amazon_sku`, `apl`.`product_id`, `pd`.`name` as `product_name`, `p`.`model`, `p`.`sku`, `apl`.`var`, '' as `combi`
	FROM `" . DB_PREFIX . "amazon_product_link` as `apl`
	LEFT JOIN `" . DB_PREFIX . "product_description` as `pd`
	ON `apl`.`product_id` = `pd`.`product_id`
	LEFT JOIN `" . DB_PREFIX . "product` as `p`
	ON `apl`.`product_id` = `p`.`product_id`";
if($product_id != 'all') {
	$query .= " WHERE `apl`.`product_id` = '" . (int)$product_id . "' AND `pd`.`language_id` = '" . (int)$this->config->get('config_language_id') . "'";
}else{
	$query .= "WHERE `pd`.`language_id` = '" . (int)$this->config->get('config_language_id') . "'";
}

$rows = $this->db->query($query)->rows;

$this->load->library('amazon');
if ($this->openbay->addonLoad('openstock')) {
	$this->load->model('openstock/openstock');
	$this->load->model('tool/image');
	$rowsWithVar = array();
	foreach($rows as $row) {
		$stockOpts = $this->model_openstock_openstock->getProductOptionStocks($row['product_id']);
		foreach($stockOpts as $opt) {
			if($opt['var'] == $row['var']) {
				$row['combi'] = $opt['combi'];
				$row['sku'] = $opt['sku'];
				break;
			}
		}
		$rowsWithVar[] = $row;
	}
	return $rowsWithVar;
} else {
	return $rows;
}

$this->load->library('amazon');
if ($this->openbay->addonLoad('openstock')) {

	$rows = $this->db->query("
		SELECT `p`.`product_id`, `p`.`model`, `p`.`sku`, `pd`.`name` as `product_name`, '' as `var`, '' as `combi`, `p`.`has_option`
		FROM `" . DB_PREFIX . "product` as `p`
		LEFT JOIN `" . DB_PREFIX . "product_description` as `pd`
		ON `p`.`product_id` = `pd`.`product_id`
		AND `pd`.`language_id` = '" . (int)$this->config->get('config_language_id') . "'")->rows;

	$result = array();
	$this->load->model('openstock/openstock');
	$this->load->model('tool/image');
	foreach($rows as $row) {
		if ($row['has_option'] == 1) {
			$stockOpts = $this->model_openstock_openstock->getProductOptionStocks($row['product_id']);
			foreach($stockOpts as $opt) {
				if($this->productLinkExists($row['product_id'], $opt['var'])) {
					continue;
				}
				$row['var'] = $opt['var'];
				$row['combi'] = $opt['combi'];
				$row['sku'] = $opt['sku'];
				$result[] = $row;
			}
		} else {
			if(!$this->productLinkExists($row['product_id'], $row['var'])) {
				$result[] = $row;
			}
		}
	}
} else {
	$result = $this->db->query("
		SELECT `p`.`product_id`, `p`.`model`, `p`.`sku`, `pd`.`name` as `product_name`, '' as `var`, '' as `combi`
		FROM `" . DB_PREFIX . "product` as `p`
		LEFT JOIN `" . DB_PREFIX . "product_description` as `pd`
		ON `p`.`product_id` = `pd`.`product_id`
		LEFT JOIN `" . DB_PREFIX . "amazon_product_link` as `apl`
		ON `apl`.`product_id` = `p`.`product_id`
		WHERE `apl`.`amazon_sku` IS NULL
		AND `pd`.`language_id` = '" . (int)$this->config->get('config_language_id') . "'")->rows;
}

return $result;

$link = $this->db->query("SELECT * FROM `" . DB_PREFIX . "amazon_product_link` WHERE `product_id` = " . (int)$product_id . " AND var = '" . $this->db->escape($var) . "'")->row;

if(empty($link)) {
	return false;
} else {
	return true;
}

$row = $this->db->query("
	SELECT `s`.`key`
	FROM `" . DB_PREFIX . "order` `o`
	JOIN `" . DB_PREFIX . "setting` `s` ON `o`.`order_id` = " . (int)$orderId . " AND `s`.`value` = `o`.`order_status_id`
	WHERE `s`.`key` = 'openbay_amazon_order_status_shipped' OR `s`.`key` = 'openbay_amazon_order_status_canceled'
	LIMIT 1")->row;

if (!isset($row['key']) || empty($row['key'])) {
	return null;
}

$key = $row['key'];

switch ($key) {
	case 'openbay_amazon_order_status_shipped':
		$orderStatus = 'shipped';
		break;
	case 'openbay_amazon_order_status_canceled':
		$orderStatus = 'canceled';
		break;

	default:
		$orderStatus = null;
		break;
}

return $orderStatus;

$this->db->query("
	UPDATE `" . DB_PREFIX . "amazon_order`
	SET `courier_id` = '" . $courierId . "',
		`courier_other` = " . (int)!$courierFromList . ",
		`tracking_no` = '" . $trackingNo . "'
	WHERE `order_id` = " . (int)$orderId . "");

$row = $this->db->query("
	SELECT `amazon_order_id`
	FROM `" . DB_PREFIX . "amazon_order`
	WHERE `order_id` = " . (int)$orderId . "
	LIMIT 1")->row;

if (isset($row['amazon_order_id']) && !empty($row['amazon_order_id'])) {
	return $row['amazon_order_id'];
}

return null;

return $this->db->query("
	SELECT `aop`.`amazon_order_item_id`, `op`.`quantity`
	FROM `" . DB_PREFIX . "amazon_order_product` `aop`
	JOIN `" . DB_PREFIX . "order_product` `op` ON `op`.`order_product_id` = `aop`.`order_product_id`
		AND `op`.`order_id` = " . (int)$orderId)->rows;

$this->load->library('amazon');

$result = null;

if ($var !== '' && $this->openbay->addonLoad('openstock')) {
	$this->load->model('tool/image');
	$this->load->model('openstock/openstock');
	$optionStocks = $this->model_openstock_openstock->getProductOptionStocks($product_id);

	$option = null;
	foreach ($optionStocks as $optionIterator) {
		if($optionIterator['var'] === $var) {
			$option = $optionIterator;
			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;

$sql = "
	SELECT COUNT(*) AS product_total
	FROM " . DB_PREFIX . "product p
	LEFT JOIN " . DB_PREFIX . "amazon_product_search aps ON p.product_id = aps.product_id AND aps.marketplace = '" . $this->db->escape($data['filter_marketplace']) . "'
	LEFT JOIN " . DB_PREFIX . "amazon_product_link apl ON p.product_id = apl.product_id
	LEFT JOIN " . DB_PREFIX . "amazon_product ap ON p.product_id = ap.product_id
	WHERE apl.product_id IS NULL AND ap.product_id IS NULL ";

if (!empty($data['status'])) {
	$sql .= " AND aps.status = '" . $this->db->escape($data['status']) . "'";
}

return $this->db->query($sql)->row['product_total'];

$sql = "
	SELECT p.product_id, marketplace, aps.status, aps.data, aps.matches
	FROM " . DB_PREFIX . "product p
	LEFT JOIN " . DB_PREFIX . "amazon_product_search aps ON p.product_id = aps.product_id AND aps.marketplace = '" . $this->db->escape($data['filter_marketplace']) . "'
	LEFT JOIN " . DB_PREFIX . "amazon_product_link apl ON p.product_id = apl.product_id
	LEFT JOIN " . DB_PREFIX . "amazon_product ap ON p.product_id = ap.product_id
	WHERE apl.product_id IS NULL AND ap.product_id IS NULL ";

if (!empty($data['status'])) {
	$sql .= " AND aps.status = '" . $this->db->escape($data['status']) . "'";
}

$sql .= " LIMIT " . (int)$data['start'] . ", " . (int)$data['limit'];

$results = array();

$rows = $this->db->query($sql)->rows;

foreach ($rows as $row) {
	$results[] = array(
		'product_id' => $row['product_id'],
		'marketplace' => $row['marketplace'],
		'status' => $row['status'],
		'matches' => $row['matches'],
		'data' => json_decode($row['data'], 1),
	);
}

return $results;

$skuArray = array();

foreach ($skus as $sku) {
	$skuArray[] = "'" . $this->db->escape($sku) . "'";
}

if ($this->openbay->addonLoad('openstock')) {
	$rows = $this->db->query("
		SELECT apl.amazon_sku, IF(por.product_id IS NULL, p.quantity, por.stock) AS 'quantity'
		FROM " . DB_PREFIX . "amazon_product_link apl
		JOIN " . DB_PREFIX . "product p ON apl.product_id = p.product_id
		LEFT JOIN " . DB_PREFIX . "product_option_relation por ON apl.product_id = por.product_id AND apl.var = por.var
		WHERE apl.amazon_sku IN (" . implode(',', $skuArray) . ")
	")->rows;
} else {
	$rows = $this->db->query("
		SELECT apl.amazon_sku, p.quantity
		FROM " . DB_PREFIX . "amazon_product_link apl
		JOIN " . DB_PREFIX . "product p ON apl.product_id = p.product_id
		WHERE apl.amazon_sku IN (" . implode(',', $skuArray) . ")
	")->rows;
}

$return = array();

foreach ($rows as $row) {
	$return[$row['amazon_sku']] = $row['quantity'];
}

$this->openbay->amazon->updateQuantities($return);

$this->db->query("
	DELETE FROM " . DB_PREFIX . "amazon_listing_report
	WHERE marketplace = '" . $this->db->escape($marketplace) . "'
");

if ($this->openbay->addonLoad('openstock')) {
	$result = $this->db->query("
		SELECT alr.sku AS 'amazon_sku', alr.quantity AS 'amazon_quantity', alr.asin, alr.price AS 'amazon_price', oc_sku.product_id, pd.name, oc_sku.sku, oc_sku.var, oc_sku.quantity,
		  (
			SELECT GROUP_CONCAT(ovd.name ORDER BY o.sort_order SEPARATOR ' > ')
			FROM " . DB_PREFIX . "product_option_value pov
			JOIN " . DB_PREFIX . "option_value_description ovd ON ovd.option_value_id = pov.option_value_id AND ovd.language_id = " . (int)$this->config->get('config_language_id') . "
			JOIN `" . DB_PREFIX . "option` o ON o.option_id = pov.option_id
			WHERE oc_sku.var LIKE CONCAT('%:', pov.product_option_value_id ,':%') OR oc_sku.var LIKE CONCAT(pov.product_option_value_id ,':%')
			  OR oc_sku.var LIKE CONCAT('%:', pov.product_option_value_id) OR oc_sku.var LIKE pov.product_option_value_id
		  ) AS 'combination'
		FROM " . DB_PREFIX . "amazon_listing_report alr
		LEFT JOIN (
		  SELECT p.product_id, IF(por.product_id IS NULL, p.sku, por.sku) AS 'sku', IF(por.product_id IS NULL, NULL, por.var) AS 'var', IF(por.product_id IS NULL, p.quantity, por.stock) AS 'quantity'
		  FROM " . DB_PREFIX . "product p
		  LEFT JOIN " . DB_PREFIX . "product_option_relation por USING(product_id)
		) AS oc_sku ON alr.sku = oc_sku.sku
		LEFT JOIN " . DB_PREFIX . "amazon_product_link apl ON (oc_sku.var IS NULL AND oc_sku.product_id = apl.product_id) OR (oc_sku.var IS NOT NULL AND oc_sku.product_id = apl.product_id AND oc_sku.var = apl.var)
		LEFT JOIN " . DB_PREFIX . "product_description pd ON oc_sku.product_id = pd.product_id AND pd.language_id = " . (int)$this->config->get('config_language_id') . "
		WHERE apl.product_id IS NULL AND alr.marketplace = '" . $this->db->escape($marketplace) . "'
		ORDER BY alr.sku
	");
} else {
	$result = $this->db->query("
		SELECT alr.sku AS 'amazon_sku', alr.quantity AS 'amazon_quantity', alr.asin, alr.price AS 'amazon_price', oc_sku.product_id, pd.name, oc_sku.sku, oc_sku.var, oc_sku.quantity, '' AS combination
		FROM " . DB_PREFIX . "amazon_listing_report alr
		LEFT JOIN (
			SELECT p.product_id, p.sku, NULL AS 'var', p.quantity
			FROM " . DB_PREFIX . "product p
		) AS oc_sku ON alr.sku = oc_sku.sku
		LEFT JOIN " . DB_PREFIX . "amazon_product_link apl ON (oc_sku.var IS NULL AND oc_sku.product_id = apl.product_id) OR (oc_sku.var IS NOT NULL AND oc_sku.product_id = apl.product_id AND oc_sku.var = apl.var)
		LEFT JOIN " . DB_PREFIX . "product_description pd ON oc_sku.product_id = pd.product_id AND pd.language_id = " . (int)$this->config->get('config_language_id') . "
		WHERE apl.product_id IS NULL AND alr.marketplace = '" . $this->db->escape($marketplace) . "'
		ORDER BY alr.sku
	");
}

return (int)$result->num_rows;

$start = $limit * ($page - 1);

$products = array();

if ($this->openbay->addonLoad('openstock')) {
	$rows = $this->db->query("
		SELECT alr.sku AS 'amazon_sku', alr.quantity AS 'amazon_quantity', alr.asin, alr.price AS 'amazon_price', oc_sku.product_id, pd.name, oc_sku.sku, oc_sku.var, oc_sku.quantity,
		  (
			SELECT GROUP_CONCAT(ovd.name ORDER BY o.sort_order SEPARATOR ' > ')
			FROM " . DB_PREFIX . "product_option_value pov
			JOIN " . DB_PREFIX . "option_value_description ovd ON ovd.option_value_id = pov.option_value_id AND ovd.language_id = " . (int)$this->config->get('config_language_id') . "
			JOIN `" . DB_PREFIX . "option` o ON o.option_id = pov.option_id
			WHERE oc_sku.var LIKE CONCAT('%:', pov.product_option_value_id ,':%') OR oc_sku.var LIKE CONCAT(pov.product_option_value_id ,':%')
			  OR oc_sku.var LIKE CONCAT('%:', pov.product_option_value_id) OR oc_sku.var LIKE pov.product_option_value_id
		  ) AS 'combination'
		FROM " . DB_PREFIX . "amazon_listing_report alr
		LEFT JOIN (
		  SELECT p.product_id, IF(por.product_id IS NULL, p.sku, por.sku) AS 'sku', IF(por.product_id IS NULL, NULL, por.var) AS 'var', IF(por.product_id IS NULL, p.quantity, por.stock) AS 'quantity'
		  FROM " . DB_PREFIX . "product p
		  LEFT JOIN " . DB_PREFIX . "product_option_relation por USING(product_id)
		) AS oc_sku ON alr.sku = oc_sku.sku
		LEFT JOIN " . DB_PREFIX . "amazon_product_link apl ON (oc_sku.var IS NULL AND oc_sku.product_id = apl.product_id) OR (oc_sku.var IS NOT NULL AND oc_sku.product_id = apl.product_id AND oc_sku.var = apl.var)
		LEFT JOIN " . DB_PREFIX . "product_description pd ON oc_sku.product_id = pd.product_id AND pd.language_id = " . (int)$this->config->get('config_language_id') . "
		WHERE apl.product_id IS NULL AND alr.marketplace = '" . $this->db->escape($marketplace) . "'
		ORDER BY alr.sku
		LIMIT " . (int)$start . "," . (int)$limit)->rows;
} else {
	$rows = $this->db->query("
		SELECT alr.sku AS 'amazon_sku', alr.quantity AS 'amazon_quantity', alr.asin, alr.price AS 'amazon_price', oc_sku.product_id, pd.name, oc_sku.sku, oc_sku.var, oc_sku.quantity, '' AS combination
		FROM " . DB_PREFIX . "amazon_listing_report alr
		LEFT JOIN (
			SELECT p.product_id, p.sku, NULL AS 'var', p.quantity
			FROM " . DB_PREFIX . "product p
		) AS oc_sku ON alr.sku = oc_sku.sku
		LEFT JOIN " . DB_PREFIX . "amazon_product_link apl ON (oc_sku.var IS NULL AND oc_sku.product_id = apl.product_id) OR (oc_sku.var IS NOT NULL AND oc_sku.product_id = apl.product_id AND oc_sku.var = apl.var)
		LEFT JOIN " . DB_PREFIX . "product_description pd ON oc_sku.product_id = pd.product_id AND pd.language_id = " . (int)$this->config->get('config_language_id') . "
		WHERE apl.product_id IS NULL AND alr.marketplace = '" . $this->db->escape($marketplace) . "'
		ORDER BY alr.sku
		LIMIT " . (int)$start . "," . (int)$limit)->rows;
}

foreach ($rows as $row) {
	$products[] = array(
		'product_id' => $row['product_id'],
		'name' => $row['name'],
		'sku' => $row['sku'],
		'var' => $row['var'],
		'quantity' => $row['quantity'],
		'amazon_sku' => $row['amazon_sku'],
		'amazon_quantity' => $row['amazon_quantity'],
		'amazon_price' => number_format($row['amazon_price'], 2, '.', ''),
		'asin' => $row['asin'],
		'combination' => $row['combination'],
	);
}

return $products;

$link = '';

switch ($marketplace) {
	case 'uk':
		$link = 'https://www.amazon.co.uk/dp/' . $asin . '/';
		break;
	case 'de':
		$link = 'https://www.amazon.de/dp/' . $asin . '/';
		break;
	case 'fr':
		$link = 'https://www.amazon.fr/dp/' . $asin . '/';
		break;
	case 'it':
		$link = 'https://www.amazon.it/dp/' . $asin . '/';
		break;
	case 'es':
		$link = 'https://www.amazon.es/dp/' . $asin . '/';
		break;
}

return $link;

$this->db->query("
	CREATE TABLE IF NOT EXISTS `" . DB_PREFIX . "amazon_order` (
	  `order_id` int(11) NOT NULL ,
	  `amazon_order_id` char(19) NOT NULL ,
	  `courier_id` varchar(255) NOT NULL ,
	  `courier_other` tinyint(1) NOT NULL,
	  `tracking_no` varchar(255) NOT NULL ,
	  PRIMARY KEY (`order_id`, `amazon_order_id`)
) DEFAULT COLLATE=utf8_general_ci;");

$this->db->query("
	CREATE TABLE IF NOT EXISTS `" . DB_PREFIX . "amazon_order_product` (
		`order_product_id` int(11) NOT NULL ,
		`amazon_order_item_id` varchar(255) NOT NULL,
		PRIMARY KEY(`order_product_id`, `amazon_order_item_id`)
);");

$this->db->query("
	CREATE TABLE IF NOT EXISTS `" . DB_PREFIX . "amazon_product_unshipped` (
		`order_id` int(11) NOT NULL,
		`product_id` int(11) NOT NULL,
		`quantity` int(11) NOT NULL DEFAULT '0',
		PRIMARY KEY (`order_id`,`product_id`)
	) DEFAULT COLLATE=utf8_general_ci;;");

$this->db->query("
CREATE TABLE IF NOT EXISTS `" . DB_PREFIX . "amazon_product` (
  `version` int(11) NOT NULL DEFAULT 2,
  `product_id`  int(11) NOT NULL ,
  `category`  varchar(255) NOT NULL ,
  `sku`  varchar(255) NOT NULL ,
  `insertion_id` varchar(255) NOT NULL ,
  `data`  text NOT NULL ,
  `status` enum('saved','uploaded','ok','error') NOT NULL ,
  `price`  decimal(15,4) NOT NULL COMMENT 'Price on Amazon' ,
  `var` char(100) NOT NULL DEFAULT '',
  `marketplaces` text NOT NULL ,
  `messages` text NOT NULL,
  PRIMARY KEY (`product_id`, `var`)
);");

$this->db->query("
CREATE TABLE IF NOT EXISTS `" . DB_PREFIX . "amazon_product_error` (
  `error_id` int(11) NOT NULL AUTO_INCREMENT,
  `sku` varchar(255) NOT NULL ,
  `insertion_id` varchar(255) NOT NULL ,
  `error_code` int(11) NOT NULL ,
  `message` text NOT NULL ,
  PRIMARY KEY (`error_id`)
);");

$this->db->query("
CREATE TABLE IF NOT EXISTS `" . DB_PREFIX . "amazon_product_link` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `amazon_sku` varchar(255) NOT NULL,
  `var` char(100) NOT NULL DEFAULT '',
  `product_id` int(11) NOT NULL,
  PRIMARY KEY (`id`)
) DEFAULT COLLATE=utf8_general_ci;");

$this->db->query("
CREATE TABLE IF NOT EXISTS `" . DB_PREFIX . "amazon_product_search` (
	`product_id` int(11) NOT NULL,
	`marketplace` enum('uk','de','es','it','fr') NOT NULL,
	`status` enum('searching','finished') NOT NULL,
	`matches` int(11) DEFAULT NULL,
	`data` text,
	PRIMARY KEY (`product_id`,`marketplace`)
) DEFAULT COLLATE=utf8_general_ci;");

$this->db->query("
	CREATE TABLE IF NOT EXISTS `" . DB_PREFIX . "amazon_listing_report` (
		`marketplace` enum('uk','de','fr','es','it') NOT NULL,
		`sku` varchar(255) NOT NULL,
		`quantity` int(10) unsigned NOT NULL,
		`asin` varchar(255) NOT NULL,
		`price` decimal(10,4) NOT NULL,
		PRIMARY KEY (`marketplace`,`sku`)
	) DEFAULT COLLATE=utf8_general_ci;");

$this->db->query("DROP TABLE IF EXISTS `" . DB_PREFIX . "amazon_order`");
$this->db->query("DROP TABLE IF EXISTS `" . DB_PREFIX . "amazon_order_product`");
$this->db->query("DROP TABLE IF EXISTS `" . DB_PREFIX . "amazon_product2`");
$this->db->query("DROP TABLE IF EXISTS `" . DB_PREFIX . "amazon_product`");
$this->db->query("DROP TABLE IF EXISTS `" . DB_PREFIX . "amazon_product_link`");
$this->db->query("DROP TABLE IF EXISTS `" . DB_PREFIX . "amazon_product_unshipped`");
$this->db->query("DROP TABLE IF EXISTS `" . DB_PREFIX . "amazon_product_error`");
$this->db->query("DROP TABLE IF EXISTS `" . DB_PREFIX . "amazon_process`");
$this->db->query("DROP TABLE IF EXISTS `" . DB_PREFIX . "amazon_product_unshipped`");
$this->db->query("DROP TABLE IF EXISTS `" . DB_PREFIX . "amazon_product_search`");
$this->db->query("DROP TABLE IF EXISTS `" . DB_PREFIX . "amazon_listing_report`");

$this->db->query("DELETE FROM `" . DB_PREFIX . "setting` WHERE `group` = 'openbay_amazon'");