mirror of
https://github.com/retailcrm/prestashop-module.git
synced 2025-03-03 19:53:19 +03:00
815 lines
40 KiB
PHP
815 lines
40 KiB
PHP
|
<?php
|
||
|
|
|
||
|
|
class RetailcrmHistory
|
||
|
|
{
|
||
|
|
public static $api;
|
||
|
|
public static $default_lang;
|
||
|
|
public static $apiVersion;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Get customers history
|
||
|
|
*
|
||
|
|
* @return string
|
||
|
|
*/
|
||
|
|
public static function customersHistory()
|
||
|
|
{
|
||
|
|
$lastSync = Configuration::get('RETAILCRM_LAST_CUSTOMERS_SYNC');
|
||
|
|
|
||
|
|
$customerFix = array();
|
||
|
|
|
||
|
|
$filter = $lastSync === false
|
||
|
|
? array('startDate' => date('Y-m-d H:i:s', strtotime('-1 days', strtotime(date('Y-m-d H:i:s')))))
|
||
|
|
: array('sinceId' => $lastSync);
|
||
|
|
|
||
|
|
$history = self::$api->customersHistory($filter);
|
||
|
|
|
||
|
|
if ($history->isSuccessful() && count($history->history)) {
|
||
|
|
$historyChanges = $history->history;
|
||
|
|
$end = end($historyChanges);
|
||
|
|
$sinceid = $end['id'];
|
||
|
|
|
||
|
|
$customersHistory = RetailcrmHistoryHelper::assemblyCustomer($historyChanges);
|
||
|
|
|
||
|
|
foreach ($customersHistory as $customerHistory) {
|
||
|
|
if (isset($customerHistory['externalId'])) {
|
||
|
|
$customer = new Customer($customerHistory['externalId']);
|
||
|
|
|
||
|
|
if (isset($customerHistory['firstName'])) {
|
||
|
|
$customer->firstname = $customerHistory['firstName'];
|
||
|
|
}
|
||
|
|
|
||
|
|
if (isset($customerHistory['lastName'])) {
|
||
|
|
$customer->lastname = $customerHistory['lastName'];
|
||
|
|
}
|
||
|
|
|
||
|
|
if (isset($customerHistory['birthday'])) {
|
||
|
|
$customer->birthday = $customerHistory['birthday'];
|
||
|
|
}
|
||
|
|
|
||
|
|
if (isset($customerHistory['email']) && Validate::isEmail($customerHistory['email'])) {
|
||
|
|
$customer->email = $customerHistory['email'];
|
||
|
|
}
|
||
|
|
|
||
|
|
$customer->update();
|
||
|
|
} else {
|
||
|
|
$customer = new Customer();
|
||
|
|
|
||
|
|
$customer->firstname = $customerHistory['firstName'];
|
||
|
|
$customer->lastname = isset($customerHistory['lastName']) ? $customerHistory['lastName'] : '--';
|
||
|
|
$customer->id_lang = self::$default_lang;
|
||
|
|
|
||
|
|
if (isset($customerHistory['birthday'])) {
|
||
|
|
$customer->birthday = $customerHistory['birthday'];
|
||
|
|
}
|
||
|
|
|
||
|
|
if (isset($customerHistory['sex'])) {
|
||
|
|
$customer->id_gender = $customerHistory['sex'] == 'male' ? 1 : 2;
|
||
|
|
}
|
||
|
|
|
||
|
|
if (isset($customerHistory['email']) && Validate::isEmail($customerHistory['email'])) {
|
||
|
|
$customer->email = $customerHistory['email'];
|
||
|
|
} else {
|
||
|
|
$customer->email = md5($customerHistory['firstName']) . '@retailcrm.ru';
|
||
|
|
}
|
||
|
|
|
||
|
|
$customer->passwd = Tools::substr(str_shuffle(Tools::strtolower(sha1(rand() . time()))), 0, 5);
|
||
|
|
|
||
|
|
$customer->add();
|
||
|
|
|
||
|
|
if (isset($customerHistory['address'])) {
|
||
|
|
$customerAddress = new Address();
|
||
|
|
$customerAddress->id_customer = $customer->id;
|
||
|
|
$customerAddress->alias = 'default';
|
||
|
|
$customerAddress->lastname = $customer->lastname;
|
||
|
|
$customerAddress->firstname = $customer->firstname;
|
||
|
|
|
||
|
|
if (isset($customerHistory['address']['countryIso'])) {
|
||
|
|
$customerAddress->id_country = Country::getByIso($customerHistory['address']['countryIso']);
|
||
|
|
}
|
||
|
|
|
||
|
|
if (isset($customerHistory['address']['region'])) {
|
||
|
|
$customerAddress->id_state = State::getIdByName($customerHistory['address']['region']);
|
||
|
|
}
|
||
|
|
|
||
|
|
$customerAddress->city = isset($customerHistory['address']['city']) ? $customerHistory['address']['city'] : '--';
|
||
|
|
|
||
|
|
$customerAddress->address1 = isset($customerHistory['address']['text']) ? $customerHistory['address']['text'] : '--';
|
||
|
|
|
||
|
|
if (isset($customerHistory['phones'])) {
|
||
|
|
$phone = reset($customerHistory['phones']);
|
||
|
|
$customerAddress->phone = $phone['number'];
|
||
|
|
}
|
||
|
|
|
||
|
|
if (isset($customerHistory['address']['index'])) {
|
||
|
|
$customerAddress->postcode = $customerHistory['address']['index'];
|
||
|
|
}
|
||
|
|
|
||
|
|
$customerAddress->add();
|
||
|
|
}
|
||
|
|
|
||
|
|
$customerFix[] = array(
|
||
|
|
'id' => $customerHistory['id'],
|
||
|
|
'externalId' => $customer->id
|
||
|
|
);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
if (!empty($customerFix)) {
|
||
|
|
self::$api->customersFixExternalIds($customerFix);
|
||
|
|
}
|
||
|
|
|
||
|
|
/*
|
||
|
|
* Update last sync id
|
||
|
|
*/
|
||
|
|
Configuration::updateValue('RETAILCRM_LAST_CUSTOMERS_SYNC', $sinceid);
|
||
|
|
} else {
|
||
|
|
return 'Nothing to sync';
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Get orders history
|
||
|
|
*
|
||
|
|
* @return string
|
||
|
|
*/
|
||
|
|
public static function ordersHistory()
|
||
|
|
{
|
||
|
|
$default_currency = (int) Configuration::get('PS_CURRENCY_DEFAULT');
|
||
|
|
$default_country = (int) Configuration::get('PS_COUNTRY_DEFAULT');
|
||
|
|
|
||
|
|
$lastSync = Configuration::get('RETAILCRM_LAST_ORDERS_SYNC');
|
||
|
|
$lastDate = Configuration::get('RETAILCRM_LAST_SYNC');
|
||
|
|
$references = new RetailcrmReferences(self::$api);
|
||
|
|
|
||
|
|
if ($lastSync === false && $lastDate === false) {
|
||
|
|
$filter = array('startDate' => date('Y-m-d H:i:s', strtotime('-1 days', strtotime(date('Y-m-d H:i:s')))));
|
||
|
|
} elseif ($lastSync === false && $lastDate !== false) {
|
||
|
|
$filter = array('startDate' => $lastDate);
|
||
|
|
} elseif ($lastSync !== false) {
|
||
|
|
$filter = array('sinceId' => $lastSync);
|
||
|
|
}
|
||
|
|
|
||
|
|
$customerFix = array();
|
||
|
|
$orderFix = array();
|
||
|
|
$history = self::$api->ordersHistory($filter);
|
||
|
|
|
||
|
|
if ($history->isSuccessful() && count($history->history) > 0) {
|
||
|
|
$historyChanges = $history->history;
|
||
|
|
$end = end($historyChanges);
|
||
|
|
$sinceId = $end['id'];
|
||
|
|
|
||
|
|
$statuses = array_flip(array_filter(json_decode(Configuration::get('RETAILCRM_API_STATUS'), true)));
|
||
|
|
$deliveries = array_flip(array_filter(json_decode(Configuration::get('RETAILCRM_API_DELIVERY'), true)));
|
||
|
|
$payments = array_flip(array_filter(json_decode(Configuration::get('RETAILCRM_API_PAYMENT'), true)));
|
||
|
|
$deliveryDefault = json_decode(Configuration::get('RETAILCRM_API_DELIVERY_DEFAULT'), true);
|
||
|
|
$paymentDefault = json_decode(Configuration::get('RETAILCRM_API_PAYMENT_DEFAULT'), true);
|
||
|
|
$orders = RetailcrmHistoryHelper::assemblyOrder($historyChanges);
|
||
|
|
|
||
|
|
foreach ($orders as $order_history) {
|
||
|
|
if (isset($order_history['deleted']) && $order_history['deleted'] == true) {
|
||
|
|
continue;
|
||
|
|
}
|
||
|
|
|
||
|
|
if (!array_key_exists('externalId', $order_history)) {
|
||
|
|
$responce = self::$api->ordersGet($order_history['id'], 'id');
|
||
|
|
|
||
|
|
if ($responce->isSuccessful()) {
|
||
|
|
$order = $responce['order'];
|
||
|
|
} else {
|
||
|
|
continue;
|
||
|
|
}
|
||
|
|
|
||
|
|
$delivery = $order['delivery']['code'];
|
||
|
|
|
||
|
|
if (array_key_exists($delivery, $deliveries) && $deliveries[$delivery] != '') {
|
||
|
|
$deliveryType = $deliveries[$delivery];
|
||
|
|
}
|
||
|
|
|
||
|
|
if (self::$apiVersion != 5) {
|
||
|
|
$payment = $order['paymentType'];
|
||
|
|
} else {
|
||
|
|
if (isset($order['payments']) && count($order['payments']) == 1) {
|
||
|
|
$paymentCRM = end($order['payments']);
|
||
|
|
$payment = $paymentCRM['type'];
|
||
|
|
} elseif (isset($order['payments']) && count($order['payments']) > 1) {
|
||
|
|
foreach ($order['payments'] as $paymentCRM) {
|
||
|
|
if ($payment['status'] != 'paid') {
|
||
|
|
$payment = $paymentCRM['type'];
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
if (array_key_exists($payment, $payments) && $payments[$payment] != '') {
|
||
|
|
if (Module::getInstanceByName($payments[$payment])) {
|
||
|
|
$paymentType = Module::getModuleName($payments[$payment]);
|
||
|
|
} else {
|
||
|
|
$paymentType = $payments[$payment];
|
||
|
|
}
|
||
|
|
$paymentId = $payments[$payment];
|
||
|
|
}
|
||
|
|
|
||
|
|
$state = $order['status'];
|
||
|
|
|
||
|
|
if (array_key_exists($state, $statuses) && $statuses[$state] != '') {
|
||
|
|
$orderStatus = $statuses[$state];
|
||
|
|
}
|
||
|
|
if (!isset($paymentId) || !$paymentId) {
|
||
|
|
$paymentId = $paymentDefault;
|
||
|
|
}
|
||
|
|
|
||
|
|
if (!$paymentType) {
|
||
|
|
if ($paymentDefault) {
|
||
|
|
if (Module::getInstanceByName($paymentDefault)) {
|
||
|
|
$paymentType = Module::getModuleName($paymentDefault);
|
||
|
|
} else {
|
||
|
|
$paymentType = $paymentDefault;
|
||
|
|
}
|
||
|
|
} else {
|
||
|
|
error_log(
|
||
|
|
'orderHistory: set default payment(error in order where id = '.$order['id'].')',
|
||
|
|
3,
|
||
|
|
_PS_ROOT_DIR_ . '/retailcrm.log'
|
||
|
|
);
|
||
|
|
|
||
|
|
continue;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
if (!$deliveryType) {
|
||
|
|
if ($deliveryDefault) {
|
||
|
|
$deliveryType = $deliveryDefault;
|
||
|
|
} else {
|
||
|
|
error_log(
|
||
|
|
'orderHistory: set default delivery(error in order where id = '.$order['id'].')',
|
||
|
|
3,
|
||
|
|
_PS_ROOT_DIR_ . '/retailcrm.log'
|
||
|
|
);
|
||
|
|
continue;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
if (array_key_exists('externalId', $order['customer'])) {
|
||
|
|
$customerId = Customer::customerIdExistsStatic($order['customer']['externalId']);
|
||
|
|
}
|
||
|
|
|
||
|
|
if (!array_key_exists('externalId', $order['customer'])
|
||
|
|
|| (isset($customerId) && $customerId == 0)
|
||
|
|
) {
|
||
|
|
$customer = new Customer();
|
||
|
|
$customer->firstname = $order['customer']['firstName'];
|
||
|
|
$customer->lastname = !empty($order['customer']['lastName']) ? $order['customer']['lastName'] : '--';
|
||
|
|
$customer->email = Validate::isEmail($order['customer']['email']) ?
|
||
|
|
$order['customer']['email'] :
|
||
|
|
md5($order['customer']['firstName']) . '@retailcrm.ru';
|
||
|
|
$customer->passwd = Tools::substr(str_shuffle(Tools::strtolower(sha1(rand() . time()))), 0, 5);
|
||
|
|
|
||
|
|
$customer->add();
|
||
|
|
|
||
|
|
array_push(
|
||
|
|
$customerFix,
|
||
|
|
array(
|
||
|
|
'id' => $order['customer']['id'],
|
||
|
|
'externalId' => $customer->id
|
||
|
|
)
|
||
|
|
);
|
||
|
|
} else {
|
||
|
|
$customer = new Customer($customerId);
|
||
|
|
}
|
||
|
|
|
||
|
|
$address = new Address();
|
||
|
|
$address->id_customer = $customer->id;
|
||
|
|
$address->id_country = $default_country;
|
||
|
|
$address->lastname = $customer->lastname;
|
||
|
|
$address->firstname = $customer->firstname;
|
||
|
|
$address->alias = 'default';
|
||
|
|
$address->postcode = isset($order['delivery']['address']['index']) ? $order['delivery']['address']['index'] : '--';
|
||
|
|
$address->city = !empty($order['delivery']['address']['city']) ?
|
||
|
|
$order['delivery']['address']['city'] : '--';
|
||
|
|
$address->address1 = !empty($order['delivery']['address']['text']) ?
|
||
|
|
$order['delivery']['address']['text'] : '--';
|
||
|
|
$address->phone = isset($order['phone']) ? $order['phone'] : '';
|
||
|
|
$address->add();
|
||
|
|
|
||
|
|
$cart = new Cart();
|
||
|
|
$cart->id_currency = $default_currency;
|
||
|
|
$cart->id_lang = self::$default_lang;
|
||
|
|
$cart->id_customer = $customer->id;
|
||
|
|
$cart->id_address_delivery = (int) $address->id;
|
||
|
|
$cart->id_address_invoice = (int) $address->id;
|
||
|
|
$cart->id_carrier = (int) $deliveryType;
|
||
|
|
|
||
|
|
$cart->add();
|
||
|
|
|
||
|
|
$products = array();
|
||
|
|
|
||
|
|
if (!empty($order['items'])) {
|
||
|
|
foreach ($order['items'] as $item) {
|
||
|
|
$productId = explode('#', $item['offer']['externalId']);
|
||
|
|
|
||
|
|
$product = array();
|
||
|
|
$product['id_product'] = (int) $productId[0];
|
||
|
|
$product['id_product_attribute'] = !empty($productId[1]) ? $productId[1] : 0;
|
||
|
|
$product['quantity'] = $item['quantity'];
|
||
|
|
$product['id_address_delivery'] = (int) $address->id;
|
||
|
|
$products[] = $product;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
$cart->setWsCartRows($products);
|
||
|
|
$cart->update();
|
||
|
|
|
||
|
|
/*
|
||
|
|
* Create order
|
||
|
|
*/
|
||
|
|
$newOrder = new Order();
|
||
|
|
$shops = Shop::getShops();
|
||
|
|
$newOrder->id_shop = Context::getContext()->shop->id;
|
||
|
|
$newOrder->id_shop_group = (int)$shops[Context::getContext()->shop->id]['id_shop_group'];
|
||
|
|
$newOrder->reference = $newOrder->generateReference();
|
||
|
|
$newOrder->id_address_delivery = (int) $address->id;
|
||
|
|
$newOrder->id_address_invoice = (int) $address->id;
|
||
|
|
$newOrder->id_cart = (int) $cart->id;
|
||
|
|
$newOrder->id_currency = $default_currency;
|
||
|
|
$newOrder->id_lang = self::$default_lang;
|
||
|
|
$newOrder->id_customer = (int) $customer->id;
|
||
|
|
if (isset($deliveryType)) {
|
||
|
|
$newOrder->id_carrier = (int) $deliveryType;
|
||
|
|
}
|
||
|
|
if (isset($paymentType)) {
|
||
|
|
$newOrder->payment = $paymentType;
|
||
|
|
$newOrder->module = $paymentId;
|
||
|
|
}
|
||
|
|
$newOrder->total_paid = $order['summ'] + $order['delivery']['cost'];
|
||
|
|
$newOrder->total_paid_tax_incl = $order['summ'] + $order['delivery']['cost'];
|
||
|
|
$newOrder->total_paid_tax_excl = $order['summ'] + $order['delivery']['cost'];
|
||
|
|
$newOrder->total_paid_real = $order['summ'] + $order['delivery']['cost'];
|
||
|
|
$newOrder->total_products = $order['summ'];
|
||
|
|
$newOrder->total_products_wt = $order['summ'];
|
||
|
|
$newOrder->total_shipping = $order['delivery']['cost'];
|
||
|
|
$newOrder->total_shipping_tax_incl = $order['delivery']['cost'];
|
||
|
|
$newOrder->total_shipping_tax_excl = $order['delivery']['cost'];
|
||
|
|
$newOrder->conversion_rate = 1.000000;
|
||
|
|
if (isset($orderStatus)) {
|
||
|
|
$newOrder->current_state = (int) $orderStatus;
|
||
|
|
}
|
||
|
|
if (!empty($order['delivery']['date'])) {
|
||
|
|
$newOrder->delivery_date = $order['delivery']['date'];
|
||
|
|
}
|
||
|
|
$newOrder->date_add = $order['createdAt'];
|
||
|
|
$newOrder->date_upd = $order['createdAt'];
|
||
|
|
$newOrder->invoice_date = $order['createdAt'];
|
||
|
|
$newOrder->valid = 1;
|
||
|
|
$newOrder->secure_key = md5(time());
|
||
|
|
|
||
|
|
if (isset($order['discount'])) {
|
||
|
|
$newOrder->total_discounts = $order['discount'];
|
||
|
|
}
|
||
|
|
|
||
|
|
$product_list = array();
|
||
|
|
|
||
|
|
foreach ($order['items'] as $item) {
|
||
|
|
$product = new Product((int) $item['offer']['externalId'], false, self::$default_lang);
|
||
|
|
$product_id = $item['offer']['externalId'];
|
||
|
|
$product_attribute_id = 0;
|
||
|
|
if (strpos($item['offer']['externalId'], '#') !== false) {
|
||
|
|
$product_id = explode('#', $item['offer']['externalId']);
|
||
|
|
$product_attribute_id = $product_id[1];
|
||
|
|
$product_id = $product_id[0];
|
||
|
|
}
|
||
|
|
|
||
|
|
if ($product_attribute_id != 0) {
|
||
|
|
$productName = htmlspecialchars(
|
||
|
|
strip_tags(Product::getProductName($product_id, $product_attribute_id))
|
||
|
|
);
|
||
|
|
|
||
|
|
$combinationPrice = Combination::getPrice($product_attribute_id);
|
||
|
|
$productPrice = $combinationPrice > 0 ? $product->getPrice()+ $combinationPrice : $product->getPrice();
|
||
|
|
} else {
|
||
|
|
$productName = htmlspecialchars(strip_tags($product->name));
|
||
|
|
$productPrice = $product->getPrice();
|
||
|
|
}
|
||
|
|
|
||
|
|
$product_list[] = array(
|
||
|
|
'product' => $product,
|
||
|
|
'product_attribute_id' => $product_attribute_id,
|
||
|
|
'product_price' => $product->price,
|
||
|
|
'product_price_inc_tax' => $productPrice,
|
||
|
|
'product_name' => $productName,
|
||
|
|
'quantity' => $item['quantity']
|
||
|
|
);
|
||
|
|
|
||
|
|
if (isset($item['discountTotal']) && self::$apiVersion == 5) {
|
||
|
|
$newOrder->total_discounts += $item['discountTotal'] * $item['quantity'];
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
$newOrder->add(false, false);
|
||
|
|
|
||
|
|
if (isset($order['payments']) && !empty($order['payments'])) {
|
||
|
|
foreach ($order['payments'] as $pay) {
|
||
|
|
if (!isset($pay['externalId']) && $pay['status'] == 'paid') {
|
||
|
|
$ptype = $payment['type'];
|
||
|
|
$ptypes = $references->getSystemPaymentModules();
|
||
|
|
if ($payments[$ptype] != null) {
|
||
|
|
foreach ($ptypes as $pay) {
|
||
|
|
if ($pay['code'] == $payments[$ptype]) {
|
||
|
|
$payType = $pay['name'];
|
||
|
|
}
|
||
|
|
}
|
||
|
|
$paymentType = Module::getModuleName($payments[$ptype]);
|
||
|
|
Db::getInstance()->execute('INSERT INTO `' . _DB_PREFIX_ . 'order_payment`
|
||
|
|
(`payment_method`, `order_reference` , `amount`, `date_add`)
|
||
|
|
VALUES
|
||
|
|
(\'' . $payType . '\',
|
||
|
|
\'' . $newOrder->reference . '\',
|
||
|
|
\'' . $payment['amount'] . '\',
|
||
|
|
\'' . $payment['paidAt'] . '\')');
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
$carrier = new OrderCarrierCore();
|
||
|
|
$carrier->id_order = $newOrder->id;
|
||
|
|
$carrier->id_carrier = $deliveryType;
|
||
|
|
$carrier->shipping_cost_tax_excl = $order['delivery']['cost'];
|
||
|
|
$carrier->shipping_cost_tax_incl = $order['delivery']['cost'];
|
||
|
|
$carrier->date_add = isset($order['delivery']['date']) ? $order['delivery']['date'] : '';
|
||
|
|
$carrier->add(false, false);
|
||
|
|
|
||
|
|
/*
|
||
|
|
* collect order ids for single fix request
|
||
|
|
*/
|
||
|
|
array_push($orderFix, array('id' => $order['id'], 'externalId' => $newOrder->id));
|
||
|
|
|
||
|
|
/*
|
||
|
|
* Create order details
|
||
|
|
*/
|
||
|
|
$query = 'INSERT `'._DB_PREFIX_.'order_detail`
|
||
|
|
(
|
||
|
|
`id_order`, `id_order_invoice`, `id_shop`, `product_id`, `product_attribute_id`,
|
||
|
|
`product_name`, `product_quantity`, `product_quantity_in_stock`, `product_price`,
|
||
|
|
`product_reference`, `total_price_tax_excl`, `total_price_tax_incl`,
|
||
|
|
`unit_price_tax_excl`, `unit_price_tax_incl`, `original_product_price`
|
||
|
|
)
|
||
|
|
|
||
|
|
VALUES';
|
||
|
|
|
||
|
|
$context = new Context();
|
||
|
|
foreach ($product_list as $product) {
|
||
|
|
$query .= '('
|
||
|
|
.(int) $newOrder->id.',
|
||
|
|
0,
|
||
|
|
'. Context::getContext()->shop->id.',
|
||
|
|
'.(int) $product['product']->id.',
|
||
|
|
'.$product['product_attribute_id'].',
|
||
|
|
'.implode('', array('\'', $product['product_name'], '\'')).',
|
||
|
|
'.(int) $product['quantity'].',
|
||
|
|
'.(int) $product['quantity'].',
|
||
|
|
'.$product['product_price'].',
|
||
|
|
'.implode('', array('\'', $product['product']->reference, '\'')).',
|
||
|
|
'.$product['product_price'].',
|
||
|
|
'.$product['product_price_inc_tax'].',
|
||
|
|
'.$product['product_price'].',
|
||
|
|
'.$product['product_price_inc_tax'].',
|
||
|
|
'.$product['product_price'].'
|
||
|
|
),';
|
||
|
|
}
|
||
|
|
|
||
|
|
Db::getInstance()->execute(rtrim($query, ','));
|
||
|
|
|
||
|
|
if (!empty($customerFix)) {
|
||
|
|
self::$api->customersFixExternalIds($customerFix);
|
||
|
|
}
|
||
|
|
if (!empty($orderFix)) {
|
||
|
|
self::$api->ordersFixExternalIds($orderFix);
|
||
|
|
}
|
||
|
|
} else {
|
||
|
|
$order = $order_history;
|
||
|
|
$orderToUpdate = new Order((int) $order['externalId']);
|
||
|
|
|
||
|
|
/*
|
||
|
|
* check delivery type
|
||
|
|
*/
|
||
|
|
if (!empty($order['delivery']['code'])) {
|
||
|
|
$dtype = $order['delivery']['code'];
|
||
|
|
$dcost = !empty($order['delivery']['cost']) ? $order['delivery']['cost'] : null;
|
||
|
|
|
||
|
|
if ($deliveries[$dtype] != null) {
|
||
|
|
if ($deliveries[$dtype] != $orderToUpdate->id_carrier or $dcost != null) {
|
||
|
|
if ($dtype != null) {
|
||
|
|
Db::getInstance()->execute('UPDATE `' . _DB_PREFIX_ . 'orders`
|
||
|
|
SET
|
||
|
|
`id_carrier` = \'' . $deliveries[$dtype] . '\'
|
||
|
|
WHERE
|
||
|
|
`id_order` = ' . (int)$order['externalId']);
|
||
|
|
}
|
||
|
|
|
||
|
|
$updateCarrierFields = array();
|
||
|
|
if ($dtype != null) {
|
||
|
|
$updateCarrierFields[] = '`id_carrier` = \'' . $deliveries[$dtype] . '\' ';
|
||
|
|
}
|
||
|
|
if ($dcost != null) {
|
||
|
|
$updateCarrierFields[] = '`shipping_cost_tax_incl` = \'' . $dcost . '\' ';
|
||
|
|
$updateCarrierFields[] = '`shipping_cost_tax_excl` = \'' . $dcost . '\' ';
|
||
|
|
}
|
||
|
|
$updateCarrierFields = implode(', ', $updateCarrierFields);
|
||
|
|
|
||
|
|
Db::getInstance()->execute('UPDATE `' . _DB_PREFIX_ . 'order_carrier`
|
||
|
|
SET
|
||
|
|
'.$updateCarrierFields.'
|
||
|
|
WHERE
|
||
|
|
`id_order` = \'' . $orderToUpdate->id . '\'');
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/*
|
||
|
|
* check payment type
|
||
|
|
*/
|
||
|
|
|
||
|
|
if (!empty($order['paymentType']) && self::$apiVersion != 5) {
|
||
|
|
$ptype = $order['paymentType'];
|
||
|
|
|
||
|
|
if ($payments[$ptype] != null) {
|
||
|
|
$paymentType = Module::getModuleName($payments[$ptype]);
|
||
|
|
if ($payments[$ptype] != $orderToUpdate->payment) {
|
||
|
|
Db::getInstance()->execute('UPDATE `' . _DB_PREFIX_ . 'orders`
|
||
|
|
SET
|
||
|
|
`payment` = \'' . ($paymentType != null ? $paymentType : $payments[$ptype]). '\'
|
||
|
|
WHERE
|
||
|
|
`id_order` = ' . (int)$order['externalId']);
|
||
|
|
Db::getInstance()->execute('UPDATE `' . _DB_PREFIX_ . 'order_payment`
|
||
|
|
SET
|
||
|
|
`payment_method` = \'' . $payments[$ptype] . '\'
|
||
|
|
WHERE
|
||
|
|
`order_reference` = \'' . $orderToUpdate->reference . '\'');
|
||
|
|
}
|
||
|
|
}
|
||
|
|
} elseif (!empty($order['payments']) && self::$apiVersion == 5) {
|
||
|
|
foreach ($order['payments'] as $payment) {
|
||
|
|
if (!isset($payment['externalId'])
|
||
|
|
&& isset($payment['status'])
|
||
|
|
&& $payment['status'] == 'paid'
|
||
|
|
) {
|
||
|
|
$ptype = $payment['type'];
|
||
|
|
$ptypes = $references->getSystemPaymentModules();
|
||
|
|
if ($payments[$ptype] != null) {
|
||
|
|
foreach ($ptypes as $pay) {
|
||
|
|
if ($pay['code'] == $payments[$ptype]) {
|
||
|
|
$payType = $pay['name'];
|
||
|
|
}
|
||
|
|
}
|
||
|
|
$paymentType = Module::getModuleName($payments[$ptype]);
|
||
|
|
Db::getInstance()->execute('UPDATE `' . _DB_PREFIX_ . 'orders`
|
||
|
|
SET
|
||
|
|
`payment` = \'' . ($paymentType != null ? $paymentType : $payments[$ptype]). '\'
|
||
|
|
WHERE
|
||
|
|
`id_order` = ' . (int)$order['externalId']);
|
||
|
|
|
||
|
|
Db::getInstance()->execute('INSERT INTO `' . _DB_PREFIX_ . 'order_payment`
|
||
|
|
(`payment_method`, `order_reference` , `amount`, `date_add`)
|
||
|
|
VALUES
|
||
|
|
(\'' . $payType . '\',
|
||
|
|
\'' . $orderToUpdate->reference . '\',
|
||
|
|
\'' . $payment['amount'] . '\',
|
||
|
|
\'' . $payment['paidAt'] . '\')');
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/*
|
||
|
|
* Clean deleted items
|
||
|
|
*/
|
||
|
|
foreach ($order['items'] as $key => $item) {
|
||
|
|
if (isset($item['delete']) && $item['delete'] == true) {
|
||
|
|
if (strpos($item['offer']['externalId'], '#') !== false) {
|
||
|
|
$itemId = explode('#', $item['offer']['externalId']);
|
||
|
|
$product_id = $itemId[0];
|
||
|
|
$product_attribute_id = $itemId[1];
|
||
|
|
} else {
|
||
|
|
$product_id = $item['offer']['externalId'];
|
||
|
|
$product_attribute_id = 0;
|
||
|
|
}
|
||
|
|
|
||
|
|
Db::getInstance()->execute('DELETE FROM `'._DB_PREFIX_.'order_detail`
|
||
|
|
WHERE
|
||
|
|
`id_order` = '. $orderToUpdate->id .'
|
||
|
|
AND
|
||
|
|
`product_id` = '.$product_id. ' AND `product_attribute_id` = '.$product_attribute_id);
|
||
|
|
|
||
|
|
unset($order['items'][$key]);
|
||
|
|
$ItemDiscount = true;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/*
|
||
|
|
* Check items quantity and discount
|
||
|
|
*/
|
||
|
|
foreach ($orderToUpdate->getProductsDetail() as $orderItem) {
|
||
|
|
foreach ($order['items'] as $key => $item) {
|
||
|
|
if (strpos($item['offer']['externalId'], '#') !== false) {
|
||
|
|
$itemId = explode('#', $item['offer']['externalId']);
|
||
|
|
$product_id = $itemId[0];
|
||
|
|
$product_attribute_id = $itemId[1];
|
||
|
|
} else {
|
||
|
|
$product_id = $item['offer']['externalId'];
|
||
|
|
$product_attribute_id = 0;
|
||
|
|
}
|
||
|
|
|
||
|
|
if ($product_id == $orderItem['product_id'] &&
|
||
|
|
$product_attribute_id == $orderItem['product_attribute_id']) {
|
||
|
|
|
||
|
|
$product = new Product((int) $product_id, false, self::$default_lang);
|
||
|
|
$tax = new TaxCore($product->id_tax_rules_group);
|
||
|
|
|
||
|
|
if ($product_attribute_id != 0) {
|
||
|
|
$prodPrice = Combination::getPrice($product_attribute_id);
|
||
|
|
$prodPrice = $prodPrice > 0 ? $prodPrice : $product->price;
|
||
|
|
} else {
|
||
|
|
$prodPrice = $product->price;
|
||
|
|
}
|
||
|
|
|
||
|
|
$prodPrice = $prodPrice + $prodPrice / 100 * $tax->rate;
|
||
|
|
|
||
|
|
// discount
|
||
|
|
if (self::$apiVersion == 5) {
|
||
|
|
$productPrice = $prodPrice - $item['discountTotal'];
|
||
|
|
} else {
|
||
|
|
$productPrice = $prodPrice - $item['discount'];
|
||
|
|
|
||
|
|
if ($item['discountPercent'] > 0) {
|
||
|
|
$productPrice = $productPrice - ($prodPrice / 100 * $item['discountPercent']);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
$productPrice = round($productPrice, 2);
|
||
|
|
|
||
|
|
Db::getInstance()->execute('UPDATE `'._DB_PREFIX_.'order_detail`
|
||
|
|
SET
|
||
|
|
`unit_price_tax_incl` = '.$productPrice.'
|
||
|
|
WHERE
|
||
|
|
`id_order_detail` = '.$orderItem['id_order_detail']);
|
||
|
|
|
||
|
|
// quantity
|
||
|
|
if (isset($item['quantity']) && $item['quantity'] != $orderItem['product_quantity']) {
|
||
|
|
Db::getInstance()->execute('UPDATE `'._DB_PREFIX_.'order_detail`
|
||
|
|
SET
|
||
|
|
`product_quantity` = '.$item['quantity'].',
|
||
|
|
`product_quantity_in_stock` = '.$item['quantity'].'
|
||
|
|
WHERE
|
||
|
|
`id_order_detail` = '.$orderItem['id_order_detail']);
|
||
|
|
}
|
||
|
|
|
||
|
|
$ItemDiscount = true;
|
||
|
|
unset($order['items'][$key]);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/*
|
||
|
|
* Check new items
|
||
|
|
*/
|
||
|
|
if (!empty($order['items'])) {
|
||
|
|
$query = 'INSERT `'._DB_PREFIX_.'order_detail`
|
||
|
|
(
|
||
|
|
`id_order`, `id_order_invoice`, `id_shop`, `product_id`, `product_attribute_id`,
|
||
|
|
`product_name`, `product_quantity`, `product_quantity_in_stock`, `product_price`,
|
||
|
|
`product_reference`, `total_price_tax_excl`, `total_price_tax_incl`,
|
||
|
|
`unit_price_tax_excl`, `unit_price_tax_incl`, `original_product_price`
|
||
|
|
)
|
||
|
|
|
||
|
|
VALUES';
|
||
|
|
|
||
|
|
foreach ($order['items'] as $key => $newItem) {
|
||
|
|
$product_id = $newItem['offer']['externalId'];
|
||
|
|
$product_attribute_id = 0;
|
||
|
|
if (strpos($product_id, '#') !== false) {
|
||
|
|
$product_id = explode('#', $product_id);
|
||
|
|
|
||
|
|
$product_attribute_id = $product_id[1];
|
||
|
|
$product_id = $product_id[0];
|
||
|
|
}
|
||
|
|
|
||
|
|
$product = new Product((int) $product_id, false, self::$default_lang);
|
||
|
|
$tax = new TaxCore($product->id_tax_rules_group);
|
||
|
|
|
||
|
|
if ($product_attribute_id != 0) {
|
||
|
|
$productName = htmlspecialchars(
|
||
|
|
strip_tags(Product::getProductName($product_id, $product_attribute_id))
|
||
|
|
);
|
||
|
|
$productPrice = Combination::getPrice($product_attribute_id);
|
||
|
|
$productPrice = $productPrice > 0 ? $productPrice : $product->price;
|
||
|
|
} else {
|
||
|
|
$productName = htmlspecialchars(strip_tags($product->name));
|
||
|
|
$productPrice = $product->price;
|
||
|
|
}
|
||
|
|
|
||
|
|
// discount
|
||
|
|
if ($newItem['discount'] || $newItem['discountPercent']|| $newItem['discountTotal']) {
|
||
|
|
$productPrice = $productPrice - $newItem['discount'];
|
||
|
|
$productPrice = $productPrice - $newItem['discountTotal'];
|
||
|
|
$productPrice = $productPrice - ($prodPrice / 100 * $newItem['discountPercent']);
|
||
|
|
$ItemDiscount = true;
|
||
|
|
}
|
||
|
|
|
||
|
|
$query .= '('
|
||
|
|
.(int) $orderToUpdate->id.',
|
||
|
|
0,
|
||
|
|
'. Context::getContext()->shop->id.',
|
||
|
|
'.(int) $product_id.',
|
||
|
|
'.(int) $product_attribute_id.',
|
||
|
|
'.implode('', array('\'', $productName, '\'')).',
|
||
|
|
'.(int) $newItem['quantity'].',
|
||
|
|
'.(int) $newItem['quantity'].',
|
||
|
|
'.$productPrice.',
|
||
|
|
'.implode('', array('\'', $product->reference, '\'')).',
|
||
|
|
'.$productPrice * $newItem['quantity'].',
|
||
|
|
'.($productPrice + $productPrice / 100 * $tax->rate) * $newItem['quantity'].',
|
||
|
|
'.$productPrice.',
|
||
|
|
'.($productPrice + $productPrice / 100 * $tax->rate).',
|
||
|
|
'.$productPrice.'
|
||
|
|
),';
|
||
|
|
|
||
|
|
unset($order['items'][$key]);
|
||
|
|
}
|
||
|
|
|
||
|
|
Db::getInstance()->execute(rtrim($query, ','));
|
||
|
|
}
|
||
|
|
|
||
|
|
/*
|
||
|
|
* Fix prices & discounts
|
||
|
|
* Discounts only for whole order
|
||
|
|
*/
|
||
|
|
if (isset($order['discount']) ||
|
||
|
|
isset($order['discountPercent']) ||
|
||
|
|
isset($order['delivery']['cost']) ||
|
||
|
|
isset($order['discountTotal']) ||
|
||
|
|
$ItemDiscount) {
|
||
|
|
$infoOrd = self::$api->ordersGet($order['externalId']);
|
||
|
|
$infoOrder = $infoOrd->order;
|
||
|
|
$orderTotalProducts = $infoOrder['summ'];
|
||
|
|
$totalPaid = $infoOrder['totalSumm'];
|
||
|
|
$deliveryCost = $infoOrder['delivery']['cost'];
|
||
|
|
$totalDiscount = $deliveryCost + $orderTotalProducts - $totalPaid;
|
||
|
|
|
||
|
|
$orderCartRules = $orderToUpdate->getCartRules();
|
||
|
|
foreach ($orderCartRules as $valCartRules) {
|
||
|
|
$order_cart_rule = new OrderCartRule($valCartRules['id_order_cart_rule']);
|
||
|
|
$order_cart_rule->delete();
|
||
|
|
}
|
||
|
|
$orderToUpdate->update();
|
||
|
|
|
||
|
|
Db::getInstance()->execute('UPDATE `'._DB_PREFIX_.'orders`
|
||
|
|
SET
|
||
|
|
`total_discounts` = '.$totalDiscount.',
|
||
|
|
`total_discounts_tax_incl` = '.$totalDiscount.',
|
||
|
|
`total_discounts_tax_excl` = '.$totalDiscount.',
|
||
|
|
`total_shipping` = '.$deliveryCost.',
|
||
|
|
`total_shipping_tax_incl` = '.$deliveryCost.',
|
||
|
|
`total_shipping_tax_excl` = '.$deliveryCost.',
|
||
|
|
`total_paid` = '.$totalPaid.',
|
||
|
|
`total_paid_tax_incl` = '.$totalPaid.',
|
||
|
|
`total_paid_tax_excl` = '.$totalPaid.',
|
||
|
|
`total_products_wt` = '.$orderTotalProducts.'
|
||
|
|
WHERE `id_order` = '.(int) $order['externalId']);
|
||
|
|
|
||
|
|
unset($ItemDiscount);
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* check status
|
||
|
|
*/
|
||
|
|
if (!empty($order['status'])) {
|
||
|
|
$stype = $order['status'];
|
||
|
|
|
||
|
|
if ($statuses[$stype] != null) {
|
||
|
|
if ($statuses[$stype] != $orderToUpdate->current_state) {
|
||
|
|
Db::getInstance()->execute('INSERT INTO `' . _DB_PREFIX_ . 'order_history`
|
||
|
|
(`id_employee`, `id_order`, `id_order_state`, `date_add`)
|
||
|
|
VALUES
|
||
|
|
(0, ' . $orderToUpdate->id . ',
|
||
|
|
' . $statuses[$stype] . ',
|
||
|
|
"' . date('Y-m-d H:i:s') . '")');
|
||
|
|
|
||
|
|
Db::getInstance()->execute('UPDATE `' . _DB_PREFIX_ . 'orders`
|
||
|
|
SET
|
||
|
|
`current_state` = \'' . $statuses[$stype] . '\'
|
||
|
|
WHERE
|
||
|
|
`id_order` = ' . (int)$order['externalId']);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
/*
|
||
|
|
* Update last sync timestamp
|
||
|
|
*/
|
||
|
|
Configuration::updateValue('RETAILCRM_LAST_ORDERS_SYNC', $sinceId);
|
||
|
|
} else {
|
||
|
|
return 'Nothing to sync';
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|