OpenCart 🇺🇦

$this->db->query("
	CREATE TABLE `" . DB_PREFIX . "order_amazon` (
		`order_id` int(11) NOT NULL,
		`amazon_order_id` varchar(255) NOT NULL,
		`free_shipping`  tinyint NOT NULL DEFAULT 0,
		KEY `amazon_order_id` (`amazon_order_id`),
		PRIMARY KEY `order_id` (`order_id`)
	) ENGINE=MyISAM DEFAULT CHARSET=utf8 COLLATE=utf8_general_ci;
");

$this->db->query("
	CREATE TABLE `" . DB_PREFIX . "order_amazon_product` (
	`order_product_id`  int NOT NULL ,
	`amazon_order_item_code`  varchar(255) NOT NULL,
	PRIMARY KEY (`order_product_id`)
) ENGINE=MyISAM DEFAULT CHARSET=utf8 COLLATE=utf8_general_ci;
");

$this->db->query("
	CREATE TABLE `" . DB_PREFIX . "order_amazon_report` (
		`order_id`  int NOT NULL ,
		`submission_id`  varchar(255) NOT NULL ,
		`status` enum('processing','error','success') NOT NULL ,
		`text`  text NOT NULL,
		PRIMARY KEY (`submission_id`),
		INDEX (`order_id`)
	) ENGINE=MyISAM DEFAULT CHARSET=utf8 COLLATE=utf8_general_ci;
");

$this->db->query("
	CREATE TABLE `" . DB_PREFIX . "order_total_tax` (
		`order_total_id`  INT,
		`code` VARCHAR(255),
		`tax` DECIMAL(10, 4) NOT NULL,
		PRIMARY KEY (`order_total_id`)
	) ENGINE=MyISAM DEFAULT CHARSET=utf8 COLLATE=utf8_general_ci;
");

$this->db->query("DROP TABLE IF EXISTS `" . DB_PREFIX . "order_amazon`;");
$this->db->query("DROP TABLE IF EXISTS `" . DB_PREFIX . "order_amazon_product`;");
$this->db->query("DROP TABLE IF EXISTS `" . DB_PREFIX . "order_amazon_report`;");
$this->db->query("DROP TABLE IF EXISTS `" . DB_PREFIX . "order_total_tax`;");

if ($this->config->get('amazon_checkout_status') == 1) {
	$order = $this->getOrder($order_id);

	if ($order) {
		$this->load->library('cba');
		$cba = new CBA($this->config->get('amazon_checkout_merchant_id'), $this->config->get('amazon_checkout_access_key'), $this->config->get('amazon_checkout_access_secret'));

		if ($data['order_status_id'] == $this->config->get('amazon_checkout_order_shipped_status')) {
			$cba->orderShipped($order);
		}

		if ($data['order_status_id'] == $this->config->get('amazon_checkout_order_canceled_status')) {
			$cba->orderCanceled($order);
		}
	}
}

$this->db->query("INSERT INTO `" . DB_PREFIX . "order_amazon_report` (`order_id`, `submission_id`, `status`, `text`) VALUES (" . (int)$order_id . ", '" . $this->db->escape($feed_submissionid) . "', 'processing', '')");

return $this->db->query("SELECT `submission_id`, `status`, `text` FROM `" . DB_PREFIX . "order_amazon_report` WHERE `order_id` = " . (int)$order_id)->rows;

$order = array();

$result = $this->db->query("SELECT amazon_order_id FROM " . DB_PREFIX . "order_amazon WHERE order_id = " . (int)$order_id);

if ($result->num_rows) {
	$order['amazon_order_id'] = $result->row['amazon_order_id'];

	$order['products'] = array();

	$results = $this->db->query("SELECT oap.order_product_id, amazon_order_item_code, op.quantity FROM " . DB_PREFIX . "order_amazon_product oap JOIN " . DB_PREFIX . "order_product op USING(order_product_id) WHERE order_id = " . (int)$order_id . "
	")->rows;

	foreach ($results as $result) {
		$order['products'][$result['order_product_id']] = array(
			'amazon_order_item_code' => $result['amazon_order_item_code'],
			'quantity' => $result['quantity'],
		);
	}
}

return $order;