shop.balmet.com

amazon_order.php (8096B)

---

 <?php
 class ModelExtensionOpenBayAmazonOrder extends Model {
 	public function acknowledgeOrder($order_id) {
 		$amazon_order_id = $this->getAmazonOrderId($order_id);
 
 		$request_xml = "<Request>
   <AmazonOrderId>$amazon_order_id</AmazonOrderId>
   <MerchantOrderId>$order_id</MerchantOrderId>
 </Request>";
 
 		$this->openbay->amazon->callNoResponse('order/acknowledge', $request_xml, false);
 	}
 
 	public function getProductId($sku) {
 		$row = $this->db->query("SELECT `product_id` FROM `" . DB_PREFIX . "amazon_product_link` WHERE `amazon_sku` = '" . $this->db->escape($sku) . "'")->row;
 
 		if (isset($row['product_id']) && !empty($row['product_id'])) {
 			return (int)$row['product_id'];
 		}
 
 		return 0;
 	}
 
 	public function getProductVar($sku) {
 		$row = $this->db->query("SELECT `var` FROM `" . DB_PREFIX . "amazon_product_link` WHERE `amazon_sku` = '" . $this->db->escape($sku) . "'")->row;
 
 		if (isset($row['var'])) {
 			return $row['var'];
 		}
 
 		return '';
 	}
 
 	public function decreaseProductQuantity($product_id, $delta, $var = '') {
 		if ($product_id == 0) {
 			return;
 		}
 		if ($var == '') {
 			$this->db->query("UPDATE `" . DB_PREFIX . "product` SET `quantity` = GREATEST(`quantity` - '" . (int)$delta . "', 0) WHERE `product_id` = '" . (int)$product_id . "' AND `subtract` = '1'");
 		} else {
 			$this->db->query("UPDATE `" . DB_PREFIX . "product_option_variant` SET `stock` = GREATEST(`stock` - '" . (int)$delta . "', 0) WHERE `product_id` = '" . (int)$product_id . "' AND `sku` = '" . $this->db->escape($var) . "' AND `subtract` = '1'");
 		}
 	}
 
 	public function getMappedStatus($amazon_status) {
 		$amazon_status = trim(strtolower($amazon_status));
 
 		switch ($amazon_status) {
 			case 'pending':
 				$order_status = $this->config->get('openbay_amazon_order_status_pending');
 				break;
 
 			case 'unshipped':
 				$order_status = $this->config->get('openbay_amazon_order_status_unshipped');
 				break;
 
 			case 'partiallyshipped':
 				$order_status = $this->config->get('openbay_amazon_order_status_partially_shipped');
 				break;
 
 			case 'shipped':
 				$order_status = $this->config->get('openbay_amazon_order_status_shipped');
 				break;
 
 			case 'canceled':
 				$order_status = $this->config->get('openbay_amazon_order_status_canceled');
 				break;
 
 			case 'unfulfillable':
 				$order_status = $this->config->get('openbay_amazon_order_status_unfulfillable');
 				break;
 
 			default:
 				$order_status = $this->config->get('config_order_status_id');
 				break;
 		}
 
 		return $order_status;
 	}
 
 	public function getCountryName($country_code) {
 		$row = $this->db->query("SELECT `name` FROM `" . DB_PREFIX . "country` WHERE LOWER(`iso_code_2`) = '" . $this->db->escape(strtolower($country_code)) . "'")->row;
 
 		if (isset($row['name']) && !empty($row['name'])) {
 			return $row['name'];
 		}
 
 		return '';
 	}
 
 	public function getCountryId($country_code) {
 		$row = $this->db->query("SELECT `country_id` FROM `" . DB_PREFIX . "country` WHERE LOWER(`iso_code_2`) = '" . $this->db->escape(strtolower($country_code)) . "'")->row;
 
 		if (isset($row['country_id']) && !empty($row['country_id'])) {
 			return (int)$row['country_id'];
 		}
 
 		return 0;
 	}
 
 	public function getZoneId($zone_name) {
 		$row = $this->db->query("SELECT `zone_id` FROM `" . DB_PREFIX . "zone` WHERE LOWER(`name`) = '" . $this->db->escape(strtolower($zone_name)) . "'")->row;
 
 		if (isset($row['country_id']) && !empty($row['country_id'])) {
 			return (int)$row['country_id'];
 		}
 
 		return 0;
 	}
 
 	public function updateOrderStatus($order_id, $status_id) {
 		$this->db->query("INSERT INTO `" . DB_PREFIX . "order_history` (`order_id`, `order_status_id`, `notify`, `comment`, `date_added`) VALUES (" . (int)$order_id . ", " . (int)$status_id . ", 0, '', NOW())");
 
 		$this->db->query("UPDATE `" . DB_PREFIX . "order` SET `order_status_id` = " . (int)$status_id . " WHERE `order_id` = " . (int)$order_id);
 	}
 
 	public function addAmazonOrder($order_id, $amazon_order_id) {
 		$this->db->query("INSERT INTO `" . DB_PREFIX . "amazon_order` (`order_id`, `amazon_order_id`) VALUES (" . (int)$order_id . ", '" . $this->db->escape($amazon_order_id) . "')");
 	}
 
 	public function addAmazonOrderProducts($order_id, $data) {
 		foreach ($data as $sku => $order_item_id) {
 
 			$row = $this->db->query("SELECT `order_product_id` FROM `" . DB_PREFIX . "order_product` WHERE `model` = '" . $this->db->escape($sku) . "' AND `order_id` = " . (int)$order_id . " LIMIT 1")->row;
 
 			if (!isset($row['order_product_id']) || empty($row['order_product_id'])) {
 				continue;
 			}
 
 			$order_product_id = $row['order_product_id'];
 
 			$this->db->query("INSERT INTO `" . DB_PREFIX . "amazon_order_product` (`order_product_id`, `amazon_order_item_id`) VALUES (" . (int)$order_product_id . ", '" . $this->db->escape($order_item_id) . "')");
 		}
 	}
 
 	public function getOrderId($amazon_order_id) {
 		$row = $this->db->query("SELECT `order_id` FROM `" . DB_PREFIX . "amazon_order` WHERE `amazon_order_id` = '" . $this->db->escape($amazon_order_id) . "' LIMIT 1")->row;
 
 		if (isset($row['order_id']) && !empty($row['order_id'])) {
 			return $row['order_id'];
 		}
 
 		return '';
 	}
 
 	public function getOrderStatus($order_id) {
 		$row = $this->db->query("SELECT `order_status_id` FROM `" . DB_PREFIX . "order` WHERE `order_id` = " . (int)$order_id)->row;
 
 		if (isset($row['order_status_id']) && !empty($row['order_status_id'])) {
 			return (int)$row['order_status_id'];
 		}
 
 		return 0;
 	}
 
 	public function getAmazonOrderId($order_id) {
 		$row = $this->db->query("SELECT `amazon_order_id` FROM `" . DB_PREFIX . "amazon_order` WHERE `order_id` = " . (int)$order_id . " LIMIT 1")->row;
 
 		if (isset($row['amazon_order_id']) && !empty($row['amazon_order_id'])) {
 			return $row['amazon_order_id'];
 		}
 
 		return null;
 	}
 
 	public function getProductOptionsByVar($product_var) {
 		$options = array();
 
 		$option_value_ids = explode(':', $product_var);
 		foreach ($option_value_ids as $option_value_id) {
 			$option_details_row = $this->db->query("SELECT
 				pov.product_option_id,
 				pov.product_option_value_id,
 				od.name,
 				ovd.name as value,
 				opt.type
 			FROM `" . DB_PREFIX . "product_option_value` as pov,
 				 `" . DB_PREFIX . "product_option` as po,
 				 `" . DB_PREFIX . "option` as opt,
 				 `" . DB_PREFIX . "option_value_description` as ovd,
 				 `" . DB_PREFIX . "option_description` as od
 			WHERE pov.product_option_value_id = '" . (int)$option_value_id . "' AND
 				po.product_option_id = pov.product_option_id AND
 				opt.option_id = pov.option_id AND
 				ovd.option_value_id = pov.option_value_id AND ovd.language_id = '" . (int)$this->config->get('config_language_id') . "' AND
 				od.option_id = pov.option_id AND od.language_id = '" . (int)$this->config->get('config_language_id') . "'
 			")->row;
 
 			if (!empty($option_details_row)) {
 				$options[] = array(
 					'product_option_id' => (int)$option_details_row['product_option_id'],
 					'product_option_value_id' => (int)$option_details_row['product_option_value_id'],
 					'name' => $option_details_row['name'],
 					'value' => $option_details_row['value'],
 					'type' => $option_details_row['type']
 				);
 			}
 		}
 
 		return $options;
 	}
 
 	public function addOrderHistory($order_id) {
 		$logger = new Log('amazon_stocks.log');
 		$logger->write('addOrderHistory() called with order id: ' . $order_id);
 		
 		if ($this->config->get('openbay_amazon_status') != 1) {
 			$logger->write('addOrderHistory() openbay_amazon_status is disabled');
 			return;
 		}
 		
 		$order_products = $this->openbay->getOrderProducts($order_id);
 		
 		$logger->write($order_products);
 
 		if (!empty($order_products)) {
 			foreach($order_products as $order_product) {
 				$this->openbay->amazon->productUpdateListen($order_product['product_id']);
 			}
 		} else {
 			$logger->write('Order product array empty!');
 		}
 
 
 		$logger->write('addOrder() exiting');
 	}
 }