Файл: upload-2031-rs1/system/library/amazonus.php
Строк: 436
<?php
class Amazonus {
private $token;
private $enc1;
private $enc2;
private $url = 'http://us-amazon.openbaypro.com/';
private $registry;
public function __construct($registry) {
$this->registry = $registry;
$this->token = $this->config->get('openbay_amazonus_token');
$this->enc1 = $this->config->get('openbay_amazonus_enc_string1');
$this->enc2 = $this->config->get('openbay_amazonus_enc_string2');
}
public function __get($name) {
return $this->registry->get($name);
}
public function call($method, $data = array(), $is_json = true) {
if ($is_json) {
$arg_string = json_encode($data);
} else {
$arg_string = $data;
}
$crypt = $this->encryptArgs($arg_string);
$defaults = array(
CURLOPT_POST => 1,
CURLOPT_HEADER => 0,
CURLOPT_URL => $this->url . $method,
CURLOPT_USERAGENT => 'OpenBay Pro for Amazonus/Opencart',
CURLOPT_FRESH_CONNECT => 1,
CURLOPT_RETURNTRANSFER => 1,
CURLOPT_FORBID_REUSE => 1,
CURLOPT_TIMEOUT => 30,
CURLOPT_SSL_VERIFYPEER => 0,
CURLOPT_SSL_VERIFYHOST => 0,
CURLOPT_POSTFIELDS => 'token=' . $this->token . '&data=' . rawurlencode($crypt) . '&opencart_version=' . VERSION,
);
$ch = curl_init();
curl_setopt_array($ch, $defaults);
$response = curl_exec($ch);
curl_close($ch);
return $response;
}
public function callNoResponse($method, $data = array(), $is_json = true) {
if ($is_json) {
$arg_string = json_encode($data);
} else {
$arg_string = $data;
}
$crypt = $this->encryptArgs($arg_string);
$defaults = array(
CURLOPT_POST => 1,
CURLOPT_HEADER => 0,
CURLOPT_URL => $this->url . $method,
CURLOPT_USERAGENT => 'OpenBay Pro for Amazonus/Opencart',
CURLOPT_FRESH_CONNECT => 1,
CURLOPT_RETURNTRANSFER => 1,
CURLOPT_FORBID_REUSE => 1,
CURLOPT_TIMEOUT => 2,
CURLOPT_SSL_VERIFYPEER => 0,
CURLOPT_SSL_VERIFYHOST => 0,
CURLOPT_POSTFIELDS => 'token=' . $this->token . '&data=' . rawurlencode($crypt) . '&opencart_version=' . VERSION,
);
$ch = curl_init();
curl_setopt_array($ch, $defaults);
curl_exec($ch);
curl_close($ch);
}
public function encryptArgs($data) {
$token = $this->openbay->pbkdf2($this->enc1, $this->enc2, 1000, 32);
$crypt = $this->openbay->encrypt($data, $token, true);
return $crypt;
}
public function decryptArgs($crypt, $is_base_64 = true) {
if ($is_base_64) {
$crypt = base64_decode($crypt, true);
if (!$crypt) {
return false;
}
}
$token = $this->openbay->pbkdf2($this->enc1, $this->enc2, 1000, 32);
$data = $this->openbay->decrypt($crypt, $token);
return $data;
}
public function getServer() {
return $this->url;
}
public function productUpdateListen($product_id, $data = array()) {
$logger = new Log('amazon_stocks.log');
$logger->write('productUpdateListen (' . (int)$product_id . ')');
$product = $this->db->query("SELECT DISTINCT * FROM `" . DB_PREFIX . "product` WHERE `product_id` = '" . (int)$product_id . "' LIMIT 1")->row;
if ($this->openbay->addonLoad('openstock') && (isset($product['has_option']) && $product['has_option'] == 1)) {
$this->load->model('module/openstock');
$logger->write('Variant item');
$quantity_data = array();
// check if post data['variant'], if not then call db to get variants
if (!isset($data['variant'])) {
$variants = $this->model_module_openstock->getVariants($product_id);
} else {
$variants = $data['variant'];
}
foreach ($variants as $variant) {
$amazon_sku_rows = $this->getLinkedSkus($product_id, $variant['sku']);
foreach($amazon_sku_rows as $amazon_sku_row) {
$quantity_data[$amazon_sku_row['amazonus_sku']] = $variant['stock'];
}
}
if(!empty($quantity_data)) {
$logger->write('Updating with: ' . print_r($quantity_data, true));
$this->updateQuantities($quantity_data);
} else {
$logger->write('Not required.');
}
} else {
$this->putStockUpdateBulk(array($product_id));
}
$logger->write('productUpdateListen() exit');
}
public function bulkUpdateOrders($orders) {
// Is the module enabled and called from admin?
if ($this->config->get('openbay_amazonus_status') != 1 || !defined('HTTPS_CATALOG')) {
return;
}
$this->load->model('openbay/amazonus');
$log = new Log('amazonus.log');
$log->write('Called bulkUpdateOrders method');
$request = array(
'orders' => array(),
);
foreach ($orders as $order) {
$amazon_order = $this->getOrder($order['order_id']);
$amazon_order_products = $this->model_openbay_amazonus->getAmazonusOrderedProducts($order['order_id']);
$products = array();
foreach ($amazon_order_products as $amazon_order_product) {
$products[] = array(
'amazon_order_item_id' => $amazon_order_product['amazonus_order_item_id'],
'quantity' => $amazon_order_product['quantity'],
);
}
$order_info = array(
'amazon_order_id' => $amazon_order['amazonus_order_id'],
'status' => $order['status'],
'products' => $products,
);
if ($order['status'] == 'shipped' && !empty($order['carrier'])) {
if ($order['carrier_from_list']) {
$order_info['carrier_id'] = $order['carrier'];
} else {
$order_info['carrier_name'] = $order['carrier'];
}
$order_info['tracking'] = $order['tracking'];
}
$request['orders'][] = $order_info;
}
$log->write('order/bulkUpdate call: ' . print_r($request, 1));
$response = $this->call('order/bulkUpdate', $request);
$log->write('order/bulkUpdate response: ' . $response);
}
public function updateOrder($order_id, $order_status_string, $courier_id = '', $courier_from_list = true, $tracking_no = '') {
if ($this->config->get('openbay_amazonus_status') != 1) {
return;
}
/* Is called from admin? */
if (!defined('HTTPS_CATALOG')) {
return;
}
$amazonus_order = $this->getOrder($order_id);
if(!$amazonus_order) {
return;
}
$amazonus_order_id = $amazonus_order['amazonus_order_id'];
$log = new Log('amazonus.log');
$log->write("Order's $amazonus_order_id status changed to $order_status_string");
$this->load->model('openbay/amazonus');
$amazonus_order_products = $this->model_openbay_amazonus->getAmazonusOrderedProducts($order_id);
$request_node = new SimpleXMLElement('<Request/>');
$request_node->addChild('AmazonusOrderId', $amazonus_order_id);
$request_node->addChild('Status', $order_status_string);
if(!empty($courier_id)) {
if($courier_from_list) {
$request_node->addChild('CourierId', $courier_id);
} else {
$request_node->addChild('CourierOther', $courier_id);
}
$request_node->addChild('TrackingNo', $tracking_no);
}
$order_items_node = $request_node->addChild('OrderItems');
foreach ($amazonus_order_products as $product) {
$new_order_item = $order_items_node->addChild('OrderItem');
$new_order_item->addChild('ItemId', htmlspecialchars($product['amazonus_order_item_id']));
$new_order_item->addChild('Quantity', (int)$product['quantity']);
}
$doc = new DOMDocument('1.0');
$doc->preserveWhiteSpace = false;
$doc->loadXML($request_node->asXML());
$doc->formatOutput = true;
$this->model_openbay_amazonus->updateAmazonusOrderTracking($order_id, $courier_id, $courier_from_list, !empty($courier_id) ? $tracking_no : '');
$log->write('Request: ' . $doc->saveXML());
$response = $this->call('order/update2', $doc->saveXML(), false);
$log->write("Response for Order's status update: $response");
}
public function getCategoryTemplates() {
$result = $this->call("productv2/RequestTemplateList");
if(isset($result)) {
return (array)json_decode($result);
} else {
return array();
}
}
public function registerInsertion($data) {
$result = $this->call("productv2/RegisterInsertionRequest", $data);
if(isset($result)) {
return (array)json_decode($result);
} else {
return array();
}
}
public function insertProduct($data) {
$result = $this->call("productv2/InsertProductRequest", $data);
if(isset($result)) {
return (array)json_decode($result);
} else {
return array();
}
}
public function updateQuantities($data) {
$result = $this->call("product/UpdateQuantityRequest", $data);
if(isset($result)) {
return (array)json_decode($result);
} else {
return array();
}
}
public function getStockUpdatesStatus($data) {
$result = $this->call("status/StockUpdates", $data);
if(isset($result)) {
return $result;
} else {
return false;
}
}
public function putStockUpdateBulk($product_id_array, $end_inactive = false){
$this->load->library('log');
$logger = new Log('amazonus_stocks.log');
$logger->write('Updating stock using putStockUpdateBulk()');
$quantity_data = array();
foreach($product_id_array as $product_id) {
$amazonus_rows = $this->getLinkedSkus($product_id);
foreach($amazonus_rows as $amazonus_row) {
$product_row = $this->db->query("SELECT quantity, status FROM `" . DB_PREFIX . "product` WHERE `product_id` = '" . (int)$product_id . "'")->row;
if(!empty($product_row)) {
if($end_inactive && $product_row['status'] == '0') {
$quantity_data[$amazonus_row['amazonus_sku']] = 0;
} else {
$quantity_data[$amazonus_row['amazonus_sku']] = $product_row['quantity'];
}
}
}
}
if(!empty($quantity_data)) {
$logger->write('Quantity data to be sent:' . print_r($quantity_data, true));
$response = $this->updateQuantities($quantity_data);
$logger->write('Submit to API. Response: ' . print_r($response, true));
} else {
$logger->write('No quantity data need to be posted.');
}
}
public function getLinkedSkus($product_id, $var='') {
return $this->db->query("SELECT `amazonus_sku` FROM `" . DB_PREFIX . "amazonus_product_link` WHERE `product_id` = '" . (int)$product_id . "' AND `var` = '" . $this->db->escape($var) . "'")->rows;
}
public function getOrderdProducts($order_id) {
return $this->db->query("SELECT `op`.`product_id`, `p`.`quantity` as `quantity_left` FROM `" . DB_PREFIX . "order_product` as `op` LEFT JOIN `" . DB_PREFIX . "product` as `p` ON `p`.`product_id` = `op`.`product_id` WHERE `op`.`order_id` = '" . (int)$order_id . "'")->rows;
}
public function validate(){
if($this->config->get('openbay_amazonus_status') != 0 &&
$this->config->get('openbay_amazonus_token') != '' &&
$this->config->get('openbay_amazonus_enc_string1') != '' &&
$this->config->get('openbay_amazonus_enc_string2') != ''){
return true;
}else{
return false;
}
}
public function deleteProduct($product_id){
$this->db->query("DELETE FROM `" . DB_PREFIX . "amazonus_product_link` WHERE `product_id` = '" . (int)$product_id . "'");
}
public function orderDelete($order_id){
/**
* @todo
*/
}
public function getOrder($order_id) {
$qry = $this->db->query("SELECT * FROM `" . DB_PREFIX . "amazonus_order` WHERE `order_id` = '" . (int)$order_id . "' LIMIT 1");
if($qry->num_rows > 0){
return $qry->row;
}else{
return false;
}
}
public function getCarriers() {
return array(
"Blue Package",
"Canada Post",
"City Link",
"DHL",
"DHL Global Mail",
"Fastway",
"FedEx",
"FedEx SmartPost",
"GLS",
"GO!",
"Hermes Logistik Gruppe",
"Newgistics",
"NipponExpress",
"OSM",
"OnTrac",
"Parcelforce",
"Royal Mail",
"SagawaExpress",
"Streamlite",
"TNT",
"Target",
"UPS",
"UPS Mail Innovations",
"USPS",
"YamatoTransport",
);
}
public function parseCategoryTemplate($xml) {
$simplexml = null;
libxml_use_internal_errors(true);
if(($simplexml = simplexml_load_string($xml)) == false) {
return false;
}
$category = (string)$simplexml->filename;
$tabs = array();
foreach($simplexml->tabs->tab as $tab) {
$attributes = $tab->attributes();
$tabs[] = array(
'id' => (string)$attributes['id'],
'name' => (string)$tab->name,
);
}
$fields = array();
$field_types = array('required', 'desired', 'optional');
foreach ($field_types as $type) {
foreach ($simplexml->fields->$type->field as $field) {
$attributes = $field->attributes();
$fields[] = array(
'name' => (string)$attributes['name'],
'title' => (string)$field->title,
'definition' => (string)$field->definition,
'accepted' => (array)$field->accepted,
'type' => (string)$type,
'child' => false,
'order' => (isset($attributes['order'])) ? (string)$attributes['order'] : '',
'tab' => (string)$attributes['tab'],
);
}
foreach ($simplexml->fields->$type->childfield as $field) {
$attributes = $field->attributes();
$fields[] = array(
'name' => (string)$attributes['name'],
'title' => (string)$field->title,
'definition' => (string)$field->definition,
'accepted' => (array)$field->accepted,
'type' => (string)$type,
'child' => true,
'parent' => (array)$field->parent,
'order' => (isset($attributes['order'])) ? (string)$attributes['order'] : '',
'tab' => (string)$attributes['tab'],
);
}
}
foreach($fields as $index => $field) {
$fields[$index]['unordered_index'] = $index;
}
usort($fields, array('Amazonus','compareFields'));
return array(
'category' => $category,
'fields' => $fields,
'tabs' => $tabs,
);
}
private static function compareFields($field1, $field2) {
if($field1['order'] == $field2['order']) {
return ($field1['unordered_index'] < $field2['unordered_index']) ? -1 : 1;
} else if(!empty($field1['order']) && empty($field2['order'])) {
return -1;
} else if(!empty($field2['order']) && empty($field1['order'])) {
return 1;
} else {
return ($field1['order'] < $field2['order']) ? -1 : 1;
}
}
}