Файл: upload/catalog/model/openbay/amazonus_order.php
Строк: 242
<?php
class ModelOpenbayAmazonusOrder extends Model {
public function acknowledgeOrder($order_id) {
$amazonus_order_id = $this->getAmazonusOrderId($order_id);
$request_xml = "<Request>
<AmazonOrderId>$amazonus_order_id</AmazonOrderId>
<MerchantOrderId>$order_id</MerchantOrderId>
</Request>";
$this->openbay->amazonus->callNoResponse('order/acknowledge', $request_xml, false);
}
public function getProductId($sku) {
$row = $this->db->query("SELECT `product_id` FROM `" . DB_PREFIX . "amazonus_product_link` WHERE `amazonus_sku` = '" . $this->db->escape($sku) . "'")->row;
if (isset($row['product_id']) && !empty($row['product_id'])) {
return $row['product_id'];
}
return 0;
}
public function getProductVar($sku) {
$row = $this->db->query("SELECT `var` FROM `" . DB_PREFIX . "amazonus_product_link` WHERE `amazonus_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($amazonus_status) {
$amazonus_status = trim(strtolower($amazonus_status));
switch ($amazonus_status) {
case 'pending':
$order_status = $this->config->get('openbay_amazonus_order_status_pending');
break;
case 'unshipped':
$order_status = $this->config->get('openbay_amazonus_order_status_unshipped');
break;
case 'partiallyshipped':
$order_status = $this->config->get('openbay_amazonus_order_status_partially_shipped');
break;
case 'shipped':
$order_status = $this->config->get('openbay_amazonus_order_status_shipped');
break;
case 'canceled':
$order_status = $this->config->get('openbay_amazonus_order_status_canceled');
break;
case 'unfulfillable':
$order_status = $this->config->get('openbay_amazonus_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 addAmazonusOrder($order_id, $amazonus_order_id) {
$this->db->query("INSERT INTO `" . DB_PREFIX . "amazonus_order` (`order_id`, `amazonus_order_id`) VALUES (" . (int)$order_id . ", '" . $this->db->escape($amazonus_order_id) . "')");
}
/* $data = array(PRODUCT_SKU => ORDER_ITEM_ID) */
public function addAmazonusOrderProducts($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 . "amazonus_order_product` (`order_product_id`, `amazonus_order_item_id`) VALUES (" . (int)$order_product_id . ", '" . $this->db->escape($order_item_id) . "')");
}
}
public function getOrderId($amazonus_order_id) {
$row = $this->db->query("SELECT `order_id` FROM `" . DB_PREFIX . "amazonus_order` WHERE `amazonus_order_id` = '" . $this->db->escape($amazonus_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 $row['order_status_id'];
}
return 0;
}
public function getAmazonusOrderId($order_id) {
$row = $this->db->query("SELECT `amazonus_order_id` FROM `" . DB_PREFIX . "amazonus_order` WHERE `order_id` = " . (int)$order_id . " LIMIT 1")->row;
if (isset($row['amazonus_order_id']) && !empty($row['amazonus_order_id'])) {
return $row['amazonus_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) {
if ($this->config->get('openbay_amazonus_status') != 1) {
return;
}
$this->load->library('log');
$logger = new Log('amazonus_stocks.log');
$logger->write('addOrder() called with order id: ' . $order_id);
$order_products = $this->openbay->getOrderProducts($order_id);
foreach($order_products as $order_product) {
$this->openbay->amazonus->productUpdateListen($order_product['product_id']);
}
$logger->write('addOrder() exiting');
}
}