<?php
/**
 * MIT License
 *
 * Copyright (c) 2021 DIGITAL RETAIL TECHNOLOGIES SL
 *
 * Permission is hereby granted, free of charge, to any person obtaining a copy
 * of this software and associated documentation files (the "Software"), to deal
 * in the Software without restriction, including without limitation the rights
 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
 * copies of the Software, and to permit persons to whom the Software is
 * furnished to do so, subject to the following conditions:
 *
 * The above copyright notice and this permission notice shall be included in
 * all copies or substantial portions of the Software.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 * SOFTWARE.
 *
 * DISCLAIMER
 *
 * Do not edit or add to this file if you wish to upgrade PrestaShop to newer
 * versions in the future. If you wish to customize PrestaShop for your
 * needs please refer to http://www.prestashop.com for more information.
 *
 *  @author    DIGITAL RETAIL TECHNOLOGIES SL <mail@simlachat.com>
 *  @copyright 2021 DIGITAL RETAIL TECHNOLOGIES SL
 *  @license   https://opensource.org/licenses/MIT  The MIT License
 *
 * Don't forget to prefix your containers with your own identifier
 * to avoid any conflicts with others containers.
 */

class RetailcrmHistory
{
    /** @var \RetailcrmApiClientV5 */
    public static $api;
    public static $default_lang;

    /**
     * Get customers history
     *
     * @return mixed
     */
    public static function customersHistory()
    {
        $lastSync = Configuration::get('RETAILCRM_LAST_CUSTOMERS_SYNC');

        $customerFix = [];

        $filter = false === $lastSync
            ? ['startDate' => date('Y-m-d H:i:s', strtotime('-1 days', strtotime(date('Y-m-d H:i:s'))))]
            : ['sinceId' => $lastSync];

        $request = new RetailcrmApiPaginatedRequest();
        $historyChanges = [];
        $history = $request
            ->setApi(self::$api)
            ->setMethod('customersHistory')
            ->setParams([$filter, '{{page}}'])
            ->setDataKey('history')
            ->setLimit(100)
            ->setPageLimit(50)
            ->execute()
            ->getData()
        ;

        if (0 < count($history)) {
            $historyChanges = static::filterHistory($history, 'customer');
            $end = end($history);
            Configuration::updateValue('RETAILCRM_LAST_CUSTOMERS_SYNC', $end['id']);
        }

        if (count($historyChanges)) {
            $customersHistory = RetailcrmHistoryHelper::assemblyCustomer($historyChanges);
            RetailcrmLogger::writeDebugArray(__METHOD__, ['Assembled history:', $customersHistory]);

            foreach ($customersHistory as $customerHistory) {
                $customerHistory = RetailcrmTools::filter(
                    'RetailcrmFilterCustomersHistory',
                    $customerHistory
                );

                if (isset($customerHistory['deleted']) && $customerHistory['deleted']) {
                    continue;
                }

                $customerBuilder = new RetailcrmCustomerBuilder();

                if (isset($customerHistory['externalId'])) {
                    $crmCustomerResponse = self::$api->customersGet($customerHistory['externalId'], 'externalId');

                    if (empty($crmCustomerResponse)
                        || !$crmCustomerResponse->isSuccessful()
                        || !$crmCustomerResponse->offsetExists('customer')
                    ) {
                        continue;
                    }

                    $customerData = RetailcrmTools::filter(
                        'RetailcrmFilterCustomersHistoryUpdate',
                        $crmCustomerResponse['customer']
                    );

                    $foundCustomer = new Customer($customerHistory['externalId']);
                    $customerAddress = new Address(RetailcrmTools::searchIndividualAddress($foundCustomer));
                    $addressBuilder = new RetailcrmCustomerAddressBuilder();

                    $addressBuilder
                        ->setCustomerAddress($customerAddress)
                    ;

                    $customerBuilder
                        ->setCustomer($foundCustomer)
                        ->setAddressBuilder($addressBuilder)
                        ->setDataCrm($customerData)
                        ->build()
                    ;

                    $customer = $customerBuilder->getData()->getCustomer();
                    $address = $customerBuilder->getData()->getCustomerAddress();

                    if (false === self::loadInCMS($customer, 'update')) {
                        continue;
                    }

                    if (!empty($address)) {
                        RetailcrmTools::assignAddressIdsByFields($customer, $address);

                        if (false === self::loadInCMS($address, 'update')) {
                            continue;
                        }
                    }
                } else {
                    $customerBuilder
                        ->setDataCrm($customerHistory)
                        ->build()
                    ;

                    $customer = $customerBuilder->getData()->getCustomer();

                    if (false === self::loadInCMS($customer, 'add')) {
                        continue;
                    }

                    $customerFix[] = [
                        'id' => $customerHistory['id'],
                        'externalId' => $customer->id,
                    ];

                    $customer->update();

                    if (isset($customerHistory['address'])) {
                        $address = $customerBuilder->getData()->getCustomerAddress();

                        $address->id_customer = $customer->id;

                        if (false === self::loadInCMS($address, 'add')) {
                            continue;
                        }
                    }
                }
            }

            if (!empty($customerFix)) {
                self::$api->customersFixExternalIds($customerFix);
            }

            return true;
        } else {
            return 'Nothing to sync';
        }
    }

    /**
     * Get orders history
     *
     * @return mixed
     *
     * @throws \PrestaShopException
     * @throws \PrestaShopDatabaseException
     */
    public static function ordersHistory()
    {
        $lastSync = Configuration::get('RETAILCRM_LAST_ORDERS_SYNC');
        $lastDate = Configuration::get('RETAILCRM_LAST_SYNC');

        if (false === $lastSync && false === $lastDate) {
            $filter = [
                'startDate' => date(
                    'Y-m-d H:i:s',
                    strtotime('-1 days', strtotime(date('Y-m-d H:i:s')))
                ),
            ];
        } elseif (false === $lastSync && false !== $lastDate) {
            $filter = ['startDate' => $lastDate];
        } elseif (false !== $lastSync) {
            $filter = ['sinceId' => $lastSync];
        } else {
            $filter = [];
        }

        $orderFix = [];
        $updateOrderIds = [];
        $updateOrderStatuses = [];
        $newItemsIdsByOrderId = [];
        $historyChanges = [];

        $request = new RetailcrmApiPaginatedRequest();
        $history = $request
            ->setApi(self::$api)
            ->setMethod('ordersHistory')
            ->setParams([$filter, '{{page}}'])
            ->setDataKey('history')
            ->setLimit(100)
            ->setPageLimit(50)
            ->execute()
            ->getData()
        ;

        if (0 < count($history)) {
            $historyChanges = static::filterHistory($history, 'order');
            $end = end($history);
            Configuration::updateValue('RETAILCRM_LAST_ORDERS_SYNC', $end['id']);
        }

        if (count($historyChanges)) {
            $default_currency = (int) Configuration::get('PS_CURRENCY_DEFAULT');
            $references = new RetailcrmReferences(self::$api);
            $receiveOrderNumber = (bool) (Configuration::get(RetailCRM::ENABLE_ORDER_NUMBER_RECEIVING));
            $sendOrderNumber = (bool) (Configuration::get(RetailCRM::ENABLE_ORDER_NUMBER_SENDING));
            $statuses = array_flip(array_filter(json_decode(Configuration::get('RETAILCRM_API_STATUS'), true)));
            $cartStatus = (string) (Configuration::get('RETAILCRM_API_SYNCHRONIZED_CART_STATUS'));
            $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);

            $paymentsCMS = [];
            foreach ($references->getSystemPaymentModules() as $paymentCMS) {
                $paymentsCMS[$paymentCMS['code']] = $paymentCMS['name'];
            }

            $orders = RetailcrmHistoryHelper::assemblyOrder($historyChanges);
            RetailcrmLogger::writeDebugArray(__METHOD__, ['Assembled history:', $orders]);

            foreach ($orders as $order_history) {
                $order_history = RetailcrmTools::filter(
                    'RetailcrmFilterOrdersHistory',
                    $order_history
                );

                if (isset($order_history['deleted']) && true == $order_history['deleted']) {
                    continue;
                }
                $infoOrder = null;

                if (!array_key_exists('externalId', $order_history)) {
                    // get full order
                    $order = self::getCRMOrder($order_history['id'], 'id');
                    if (!$order) {
                        continue;
                    }
                    if ($order['status'] == $cartStatus) {
                        continue;
                    }

                    $order = RetailcrmTools::filter(
                        'RetailcrmFilterOrdersHistoryCreate',
                        $order
                    );

                    // status
                    $state = $order['status'];
                    if (array_key_exists($state, $statuses) && '' != $statuses[$state]) {
                        $orderStatus = $statuses[$state];
                    }

                    // payment
                    $paymentTypeCRM = null;
                    $paymentId = null;
                    $paymentType = null;
                    if (isset($order['payments'])) {
                        if (1 === count($order['payments'])) {
                            $paymentCRM = end($order['payments']);
                            $paymentTypeCRM = $paymentCRM['type'];
                        } elseif (1 < count($order['payments'])) {
                            foreach ($order['payments'] as $paymentCRM) {
                                if (isset($paymentCRM['status']) && 'paid' !== $paymentCRM['status']) {
                                    $paymentTypeCRM = $paymentCRM['type'];
                                    break;
                                }
                            }
                        }
                    }
                    unset($paymentCRM);

                    // todo move to separate function
                    if ($paymentTypeCRM) {
                        if (array_key_exists($paymentTypeCRM, $payments) && !empty($payments[$paymentTypeCRM])) {
                            $paymentId = $payments[$paymentTypeCRM];
                        } else {
                            RetailcrmLogger::writeCaller(
                                __METHOD__,
                                sprintf(
                                    'unmapped payment type %s (error in order where id = %d)',
                                    $paymentTypeCRM,
                                    $order['id']
                                )
                            );

                            continue;
                        }
                    } elseif ($paymentDefault) {
                        $paymentId = $paymentDefault;
                    } else {
                        RetailcrmLogger::writeCaller(
                            __METHOD__,
                            sprintf(
                                'set default payment (error in order where id = %d)',
                                $order['id']
                            )
                        );

                        continue;
                    }

                    if ($paymentId && isset($paymentsCMS[$paymentId])) {
                        $paymentType = $paymentsCMS[$paymentId];
                    } else {
                        $paymentType = $paymentId;
                    }

                    // delivery
                    $delivery = isset($order['delivery']['code']) ? $order['delivery']['code'] : false;
                    if ($delivery && array_key_exists($delivery, $deliveries) && '' != $deliveries[$delivery]) {
                        $deliveryType = $deliveries[$delivery];
                    }

                    if (!isset($deliveryType) || !$deliveryType) {
                        if ($deliveryDefault) {
                            $deliveryType = $deliveryDefault;
                        } else {
                            RetailcrmLogger::writeCaller(
                                __METHOD__,
                                sprintf(
                                    'set default delivery(error in order where id = %d)',
                                    $order['id']
                                )
                            );

                            continue;
                        }
                    }

                    $customer = null;
                    $customerId = null;

                    if ('customer_corporate' === $order['customer']['type']
                        && RetailcrmTools::isCorporateEnabled()
                        && !empty($order['contact'])
                        && array_key_exists('externalId', $order['contact'])
                    ) {
                        if (isset($order['contact']['externalId'])) {
                            $customerId = Customer::customerIdExistsStatic($order['contact']['externalId']);
                        }

                        if (empty($customerId) && !empty($order['contact']['email'])) {
                            $customer = Customer::getCustomersByEmail($order['contact']['email']);
                            $customer = is_array($customer) ? reset($customer) : [];

                            if (array_key_exists('id_customer', $customer)) {
                                $customerId = $customer['id_customer'];
                            }
                        }
                    } elseif (array_key_exists('externalId', $order['customer'])) {
                        $customerId = Customer::customerIdExistsStatic($order['customer']['externalId']);
                    }

                    // address invoice
                    if (!empty($order['company']) && RetailcrmTools::isCorporateEnabled()) {
                        $corporateCustomerBuilder = new RetailcrmCorporateCustomerBuilder();
                        $dataOrder = array_merge(
                            $order['contact'],
                            ['address' => $order['company']['address']]
                        );

                        $corporateCustomerBuilder
                            ->setCustomer(new Customer($customerId))
                            ->setDataCrm($dataOrder)
                            ->extractCompanyDataFromOrder($order)
                            ->build()
                        ;

                        $customer = $corporateCustomerBuilder->getData()->getCustomer();
                        $addressInvoice = $corporateCustomerBuilder->getData()->getCustomerAddress();
                    } else {
                        $customerBuilder = new RetailcrmCustomerBuilder();
                        if ($customerId) {
                            $customerBuilder->setCustomer(new Customer($customerId));
                        }

                        $customerBuilder
                            ->setDataCrm($order['customer'])
                            ->build()
                        ;

                        $customer = $customerBuilder->getData()->getCustomer();
                        $addressInvoice = $customerBuilder->getData()->getCustomerAddress();
                    }

                    if (empty($customer->id) && !empty($customer->email)) {
                        $customer->id = self::getCustomerIdByEmail($customer->email);
                    }

                    if (false === self::loadInCMS($customer, 'save')) {
                        continue;
                    }

                    if (RetailcrmTools::validateEntity($addressInvoice)) {
                        $addressInvoice->id_customer = $customer->id;
                        RetailcrmTools::assignAddressIdsByFields($customer, $addressInvoice);

                        if (empty($addressInvoice->id)) {
                            self::loadInCMS($addressInvoice, 'add');

                            if (!empty($order['company']) && RetailcrmTools::isCorporateEnabled()) {
                                self::$api->customersCorporateAddressesEdit(
                                    $order['customer']['id'],
                                    $order['company']['address']['id'],
                                    array_merge(
                                        $order['company']['address'],
                                        ['externalId' => $addressInvoice->id]
                                    ),
                                    'id',
                                    'id'
                                );

                                time_nanosleep(0, 20000000);
                            }
                        } else {
                            self::loadInCMS($addressInvoice, 'save');
                        }
                    }

                    // address delivery
                    $addressBuilder = new RetailcrmCustomerAddressBuilder();
                    $addressDelivery = $addressBuilder
                        ->setIdCustomer($customer->id)
                        ->setDataCrm(isset($order['delivery']['address']) ? $order['delivery']['address'] : [])
                        ->setFirstName(isset($order['firstName']) ? $order['firstName'] : null)
                        ->setLastName(isset($order['lastName']) ? $order['lastName'] : null)
                        ->setPhone(isset($order['phone']) ? $order['phone'] : null)
                        ->build()
                        ->getData()
                    ;

                    if (RetailcrmTools::validateEntity($addressDelivery)) {
                        RetailcrmTools::assignAddressIdsByFields($customer, $addressDelivery);

                        if (empty($addressDelivery->id)) {
                            self::loadInCMS($addressDelivery, 'add');
                        } else {
                            self::loadInCMS($addressDelivery, 'save');
                        }
                    }

                    // cart
                    $cart = new Cart();
                    $cart->id_currency = $default_currency;
                    $cart->id_lang = self::$default_lang;
                    $cart->id_shop = Context::getContext()->shop->id;
                    $cart->id_shop_group = (int) (Context::getContext()->shop->id_shop_group);
                    $cart->id_customer = $customer->id;
                    $cart->id_address_delivery = isset($addressDelivery->id) ? (int) $addressDelivery->id : 0;
                    $cart->id_address_invoice = isset($addressInvoice->id) ? (int) $addressInvoice->id : 0;
                    $cart->id_carrier = (int) $deliveryType;

                    self::loadInCMS($cart, 'add');

                    $products = [];
                    if (!empty($order['items'])) {
                        foreach ($order['items'] as $item) {
                            if (RetailcrmOrderBuilder::isGiftItem($item)) {
                                continue;
                            }

                            $productId = explode('#', $item['offer']['externalId']);
                            $product = [];
                            $product['id_product'] = (int) $productId[0];
                            $product['id_product_attribute'] = !empty($productId[1]) ? $productId[1] : 0;
                            $product['quantity'] = $item['quantity'];
                            $product['id_address_delivery'] = isset($addressDelivery->id) ? (int) $addressDelivery->id : 0;
                            $products[] = $product;
                        }
                    }

                    $cart->setWsCartRows($products);

                    self::loadInCMS($cart, 'update');

                    /*
                     * Create order
                    */
                    $newOrder = new Order();
                    $newOrder->id_shop = Context::getContext()->shop->id;
                    $newOrder->id_shop_group = (int) (Context::getContext()->shop->id_shop_group);
                    $newOrder->id_address_delivery = isset($addressDelivery->id) ? (int) $addressDelivery->id : 0;
                    $newOrder->id_address_invoice = isset($addressInvoice->id) ? (int) $addressInvoice->id : 0;
                    $newOrder->id_cart = (int) $cart->id;
                    $newOrder->id_currency = $default_currency;
                    $newOrder->id_lang = self::$default_lang;
                    $newOrder->id_customer = (int) $customer->id;
                    $orderNumber = $receiveOrderNumber ? $order['number'] : $newOrder->generateReference();
                    $newOrder->reference = $orderNumber;

                    if (isset($deliveryType)) {
                        $newOrder->id_carrier = (int) $deliveryType;
                    }

                    if (isset($paymentType)) {
                        $newOrder->payment = $paymentType;
                        $newOrder->module = $paymentId;
                    }

                    // totals
                    $totalPaid = $order['totalSumm'];
                    $orderTotalProducts = array_reduce($order['items'], function ($sum, $it) {
                        $sum += $it['initialPrice'] * $it['quantity'];

                        return $sum;
                    });
                    $deliveryCost = $order['delivery']['cost'];
                    $totalDiscount = round($deliveryCost + $orderTotalProducts - $totalPaid, 2);

                    $newOrder->total_discounts = $totalDiscount;
                    $newOrder->total_discounts_tax_incl = $totalDiscount;
                    $newOrder->total_discounts_tax_excl = $totalDiscount;

                    $newOrder->total_paid = $totalPaid;
                    $newOrder->total_paid_tax_incl = $totalPaid;
                    $newOrder->total_paid_tax_excl = $totalPaid;
                    $newOrder->total_paid_real = $totalPaid;

                    $newOrder->total_products = (int) $orderTotalProducts;
                    $newOrder->total_products_wt = (int) $orderTotalProducts;

                    $newOrder->total_shipping = $deliveryCost;
                    $newOrder->total_shipping_tax_incl = $deliveryCost;
                    $newOrder->total_shipping_tax_excl = $deliveryCost;

                    $newOrder->conversion_rate = 1.000000;

                    if (isset($orderStatus)) {
                        $newOrder->current_state = (int) $orderStatus;
                        $newOrderHistoryRecord = new OrderHistory(
                            null,
                            static::$default_lang,
                            Context::getContext()->shop->id
                        );
                    }

                    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());

                    // save order
                    try {
                        RetailcrmLogger::writeDebug(
                            __METHOD__,
                            sprintf(
                                '<Customer ID: %d> %s::%s',
                                $newOrder->id_customer,
                                get_class($newOrder),
                                'add'
                            )
                        );

                        $newOrder->add(false, false);

                        // set status for the order
                        if (isset($newOrderHistoryRecord)) {
                            $newOrderHistoryRecord->id_order = $newOrder->id;
                            $newOrderHistoryRecord->id_order_state = $newOrder->current_state;
                            $newOrderHistoryRecord->id_employee = static::getFirstEmployeeId();
                            $newOrderHistoryRecord->date_add = date('Y-m-d H:i:s');
                            $newOrderHistoryRecord->date_upd = $newOrderHistoryRecord->date_add;

                            self::loadInCMS($newOrderHistoryRecord, 'add');
                        }
                    } catch (\Exception $e) {
                        RetailcrmLogger::writeCaller(
                            __METHOD__,
                            sprintf('Error adding order id=%d: %s', $order['id'], $e->getMessage())
                        );

                        RetailcrmLogger::writeNoCaller($e->getTraceAsString());
                    }

                    // payment
                    if (isset($order['payments']) && !empty($order['payments'])) {
                        foreach ($order['payments'] as $payment) {
                            if (!isset($payment['externalId'])
                                && isset($payment['status'])
                                && 'paid' === $payment['status']
                            ) {
                                $paymentTypeCRM = isset($payment['type']) ? $payment['type'] : null;
                                $paymentType = null;
                                $paymentId = null;

                                if ($paymentTypeCRM) {
                                    if (array_key_exists($paymentTypeCRM, $payments) && !empty($payments[$paymentTypeCRM])) {
                                        $paymentId = $payments[$paymentTypeCRM];
                                    } else {
                                        continue;
                                    }
                                } elseif ($paymentDefault) {
                                    $paymentId = $paymentDefault;
                                } else {
                                    continue;
                                }

                                $paymentType = isset($paymentsCMS[$paymentId]) ? $paymentsCMS[$paymentId] : $paymentId;

                                $orderPayment = new OrderPayment();
                                $orderPayment->payment_method = $paymentType;
                                $orderPayment->order_reference = $newOrder->reference;
                                $orderPayment->id_currency = $default_currency;
                                $orderPayment->amount = $payment['amount'];
                                $orderPayment->date_add = $payment['paidAt'];

                                RetailcrmLogger::writeDebug(
                                    __METHOD__,
                                    sprintf(
                                        '<Order Reference: %s> %s::%s',
                                        $newOrder->reference,
                                        get_class($orderPayment),
                                        'save'
                                    )
                                );

                                $orderPayment->save();
                            }
                        }
                    }

                    // delivery save
                    $carrier = new OrderCarrier();
                    $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'];

                    RetailcrmLogger::writeDebug(
                        __METHOD__,
                        sprintf(
                            '<Order ID: %d> %s::%s',
                            $carrier->id_order,
                            get_class($carrier),
                            'add'
                        )
                    );

                    $carrier->add(true, false);

                    /*
                     * Create order details
                    */

                    $newItemsIds = [];
                    if (!empty($order['items'])) {
                        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 (RetailcrmOrderBuilder::isGiftItem($item)) {
                                continue;
                            }

                            if (false !== strpos($item['offer']['externalId'], '#')) {
                                $externalIds = explode('#', $item['offer']['externalId']);
                                $product_id = $externalIds[0];
                                $product_attribute_id = $externalIds[1];
                            }

                            if (0 != $product_attribute_id) {
                                $productName = htmlspecialchars(
                                    strip_tags(Product::getProductName($product_id, $product_attribute_id))
                                );
                            } else {
                                $productName = htmlspecialchars(strip_tags($product->name));
                            }

                            $productPrice = round($item['initialPrice'], 2);

                            $orderDetail = new OrderDetail();
                            static::setOrderDetailProductName($orderDetail, $productName);

                            $orderDetail->id_order = $newOrder->id;
                            $orderDetail->id_order_invoice = $newOrder->invoice_number;
                            $orderDetail->id_shop = Context::getContext()->shop->id;

                            $orderDetail->product_id = (int) $product_id;
                            $orderDetail->product_attribute_id = (int) $product_attribute_id;
                            $orderDetail->product_reference = implode('', ['\'', $product->reference, '\'']);

                            $orderDetail->product_price = $productPrice;
                            $orderDetail->original_product_price = $productPrice;
                            $orderDetail->product_quantity = (int) $item['quantity'];
                            $orderDetail->product_quantity_in_stock = (int) $item['quantity'];

                            $orderDetail->total_price_tax_incl = $productPrice * $orderDetail->product_quantity;
                            $orderDetail->unit_price_tax_incl = $productPrice;

                            $orderDetail->id_warehouse = !empty($newOrder->id_warehouse) ? $newOrder->id_warehouse : 0;

                            if (!$product->checkQty($orderDetail->product_quantity)) {
                                self::$api->ordersFixExternalIds([[
                                    'id' => $order['id'],
                                    'externalId' => $newOrder->id,
                                ]]);

                                self::setOutOfStockStatus(
                                    $order,
                                    $newOrder,
                                    $statuses
                                );
                            }

                            StockAvailable::updateQuantity(
                                $product_id,
                                $product_attribute_id,
                                -1 * $orderDetail->product_quantity,
                                Context::getContext()->shop->id
                            );

                            if (self::loadInCMS($orderDetail, 'save')) {
                                $newItemsIds[Db::getInstance()->Insert_ID()] = $item['id'];
                            }

                            unset($orderDetail);
                        }
                    }

                    // collect order ids for single fix request
                    $orderFix[] = ['id' => $order['id'], 'externalId' => $newOrder->id];

                    // update order items ids in crm
                    $newItemsIdsByOrderId[$newOrder->id] = $newItemsIds;

                    // collect orders id and reference if option sendOrderNumber enabled
                    if ($sendOrderNumber) {
                        $updateOrderIds[] = [
                            'externalId' => $newOrder->id,
                            'number' => $newOrder->reference,
                        ];
                    }
                } else {
                    $order = $order_history;

                    if (false !== stripos($order['externalId'], 'pscart_')) {
                        continue;
                    }

                    $orderToUpdate = new Order((int) $order['externalId']);
                    if (!Validate::isLoadedObject($orderToUpdate)) {
                        continue;
                    }

                    $order = RetailcrmTools::filter(
                        'RetailcrmFilterOrdersHistoryUpdate',
                        $order,
                        [
                            'orderToUpdate' => $orderToUpdate,
                        ]
                    );

                    self::handleCustomerDataChange($orderToUpdate, $order);

                    /*
                     * check delivery changes
                     */
                    if (isset($order['delivery']['address'])
                        || array_key_exists('firstName', $order)
                        || array_key_exists('lastName', $order)
                        || array_key_exists('phone', $order)
                    ) {
                        $addressBuilder = new RetailcrmCustomerAddressBuilder();

                        $orderAddress = new Address($orderToUpdate->id_address_delivery);
                        $orderAddressCrm = isset($order['delivery']['address']) ? $order['delivery']['address'] : [];
                        $orderFirstName = $orderAddress->firstname;
                        $orderLastName = $orderAddress->lastname;
                        $orderPhone = $orderAddress->phone;

                        if (RetailcrmHistoryHelper::isAddressLineChanged($orderAddressCrm)
                            || !Validate::isLoadedObject($orderAddress)
                        ) {
                            $infoOrder = self::getCRMOrder($order['externalId']);
                            if (isset($infoOrder['delivery']['address'])) {
                                // array_replace used to save changes, made by custom filters
                                $orderAddressCrm = array_replace(
                                    $infoOrder['delivery']['address'],
                                    $orderAddressCrm
                                );
                            }

                            if (isset($infoOrder['firstName'])) {
                                $orderFirstName = $infoOrder['firstName'];
                            }
                            if (isset($infoOrder['lastName'])) {
                                $orderLastName = $infoOrder['lastName'];
                            }
                            if (isset($infoOrder['phone'])) {
                                $orderPhone = $infoOrder['phone'];
                            }
                        }

                        // may override actual order data, but used to save changes, made by custom filters
                        if (array_key_exists('firstName', $order)) {
                            $orderFirstName = $order['firstName'];
                        }
                        if (array_key_exists('lastName', $order)) {
                            $orderLastName = $order['lastName'];
                        }
                        if (array_key_exists('phone', $order)) {
                            $orderPhone = $order['phone'];
                        }

                        $address = $addressBuilder
                            ->setCustomerAddress($orderAddress)
                            ->setIdCustomer($orderToUpdate->id_customer)
                            ->setDataCrm($orderAddressCrm)
                            ->setFirstName($orderFirstName)
                            ->setLastName($orderLastName)
                            ->setPhone($orderPhone)
                            ->setAlias($orderAddress->alias)
                            ->build()
                            ->getData()
                        ;

                        if (RetailcrmTools::validateEntity($address, $orderToUpdate)) {
                            $address->id = null;
                            RetailcrmTools::assignAddressIdsByFields(new Customer($orderToUpdate->id_customer), $address);

                            if (null === $address->id) {
                                // Modifying an address in order creates another address
                                // instead of changing the original one. This issue has been fixed in PS 1.7.7
                                if (version_compare(_PS_VERSION_, '1.7.7', '<')) {
                                    self::loadInCMS($address, 'add');

                                    $orderToUpdate->id_address_delivery = $address->id;
                                    self::loadInCMS($orderToUpdate, 'update');
                                } else {
                                    $address->id = $orderToUpdate->id_address_delivery;
                                    self::loadInCMS($address, 'update');
                                }
                            } elseif ($address->id !== $orderToUpdate->id_address_delivery) {
                                RetailcrmLogger::writeDebug(__METHOD__, sprintf(
                                    'Binding to existing address [%d]',
                                    $address->id
                                ));

                                $orderToUpdate->id_address_delivery = $address->id;
                                self::loadInCMS($orderToUpdate, 'update');
                            }
                        }
                    }

                    /*
                     * check delivery type and cost
                     */
                    if (!empty($order['delivery']['code']) || !empty($order['delivery']['cost'])) {
                        $dtype = !empty($order['delivery']['code']) ? $order['delivery']['code'] : null;
                        $dcost = !empty($order['delivery']['cost']) ? $order['delivery']['cost'] : null;

                        if (
                            (
                                null !== $dtype
                                && isset($deliveries[$dtype])
                                && null !== $deliveries[$dtype]
                                && $deliveries[$dtype] !== $orderToUpdate->id_carrier
                            )
                            || null !== $dcost
                        ) {
                            if (property_exists($orderToUpdate, 'id_order_carrier')) {
                                $idOrderCarrier = $orderToUpdate->id_order_carrier;
                            } elseif (method_exists($orderToUpdate, 'getIdOrderCarrier')) {
                                $idOrderCarrier = $orderToUpdate->getIdOrderCarrier();
                            } else {
                                $idOrderCarrier = null;
                            }

                            $orderCarrier = new OrderCarrier($idOrderCarrier);

                            if (null != $dtype) {
                                $orderCarrier->id_carrier = $deliveries[$dtype];
                            }

                            if (null != $dcost) {
                                $orderCarrier->shipping_cost_tax_incl = $dcost;
                                $orderCarrier->shipping_cost_tax_excl = $dcost;
                            }

                            $orderCarrier->id_order = $orderToUpdate->id;

                            self::loadInCMS($orderCarrier, 'update');
                        }
                    }

                    /*
                     * check payment type
                     */
                    if (!empty($order['payments'])) {
                        foreach ($order['payments'] as $payment) {
                            if (!isset($payment['externalId'])
                                && isset($payment['status'])
                                && 'paid' === $payment['status']
                            ) {
                                $paymentTypeCRM = isset($payment['type']) ? $payment['type'] : null;
                                $paymentType = null;
                                $paymentId = null;

                                if ($paymentTypeCRM) {
                                    if (array_key_exists($paymentTypeCRM, $payments) && !empty($payments[$paymentTypeCRM])) {
                                        $paymentId = $payments[$paymentTypeCRM];
                                    } else {
                                        continue;
                                    }
                                } elseif ($paymentDefault) {
                                    $paymentId = $paymentDefault;
                                } else {
                                    continue;
                                }

                                $paymentType = isset($paymentsCMS[$paymentId]) ? $paymentsCMS[$paymentId] : $paymentId;

                                $orderToUpdate->payment = $paymentType;
                                $orderPayment = new OrderPayment();
                                $orderPayment->payment_method = $paymentType;
                                $orderPayment->order_reference = $orderToUpdate->reference;

                                if (isset($payment['amount'])) {
                                    $orderPayment->amount = $payment['amount'];
                                } else {
                                    $orderPayment->amount = $orderToUpdate->total_paid;
                                }

                                $orderPayment->id_currency = $default_currency;
                                $orderPayment->date_add =
                                    isset($payment['paidAt']) ? $payment['paidAt'] : date('Y-m-d H:i:s');

                                RetailcrmLogger::writeDebug(
                                    __METHOD__,
                                    sprintf(
                                        '<Order Reference: %s> %s::%s',
                                        $orderToUpdate->reference,
                                        get_class($orderPayment),
                                        'save'
                                    )
                                );

                                $orderPayment->save();
                            }
                        }
                    }

                    // change order totals
                    if (isset($order['items']) || isset($order['delivery']['cost'])) {
                        // get full order
                        if (empty($infoOrder)) {
                            $infoOrder = self::getCRMOrder($order['externalId']);
                        }

                        // items
                        if (isset($order['items']) && is_array($order['items'])) {
                            /*
                             * Clean deleted items
                             */
                            $id_order_detail = null;
                            foreach ($order['items'] as $key => $item) {
                                if (isset($item['delete']) && true == $item['delete']) {
                                    if (RetailcrmOrderBuilder::isGiftItem($item)) {
                                        $orderToUpdate->gift = false;
                                    }

                                    $parsedExtId = static::parseItemExternalId($item);
                                    $product_id = $parsedExtId['product_id'];
                                    $product_attribute_id = $parsedExtId['product_attribute_id'];
                                    $id_order_detail = !empty($parsedExtId['id_order_detail'])
                                        ? $parsedExtId['id_order_detail'] : 0;

                                    if (isset($item['quantity'])) {
                                        StockAvailable::updateQuantity(
                                            $product_id,
                                            $product_attribute_id,
                                            $item['quantity'],
                                            Context::getContext()->shop->id
                                        );
                                    }

                                    self::deleteOrderDetailByProduct(
                                        $orderToUpdate->id,
                                        $product_id,
                                        $product_attribute_id,
                                        $id_order_detail
                                    );
                                    unset($order['items'][$key]);
                                }
                            }

                            /*
                             * Check items quantity and discount
                             */
                            foreach ($orderToUpdate->getProductsDetail() as $orderItem) {
                                foreach ($order['items'] as $key => $item) {
                                    if (RetailcrmOrderBuilder::isGiftItem($item)) {
                                        continue;
                                    }

                                    $parsedExtId = static::parseItemExternalId($item);
                                    $product_id = $parsedExtId['product_id'];
                                    $product_attribute_id = $parsedExtId['product_attribute_id'];
                                    $isExistingItem = isset($item['create']) ? false : true;

                                    if ($isExistingItem
                                        && $product_id == $orderItem['product_id']
                                        && $product_attribute_id == $orderItem['product_attribute_id']
                                    ) {
                                        $product = new Product((int) $product_id, false, self::$default_lang);

                                        $orderDetailId = !empty($parsedExtId['id_order_detail'])
                                            ? $parsedExtId['id_order_detail'] : $orderItem['id_order_detail'];
                                        $orderDetail = new OrderDetail($orderDetailId);

                                        // price
                                        if (isset($item['initialPrice'])) {
                                            $productPrice = round($item['initialPrice'], 2);
                                            $orderDetail->unit_price_tax_incl = $productPrice;
                                        }

                                        // quantity
                                        if (
                                            isset($item['quantity'])
                                            && $item['quantity'] != $orderItem['product_quantity']
                                        ) {
                                            $deltaQuantity = $orderDetail->product_quantity - $item['quantity'];
                                            $orderDetail->product_quantity = $item['quantity'];
                                            $orderDetail->product_quantity_in_stock = $item['quantity'];

                                            if (0 > $deltaQuantity && !$product->checkQty(-1 * $deltaQuantity)) {
                                                $newStatus = self::setOutOfStockStatus(
                                                    $infoOrder,
                                                    $orderToUpdate,
                                                    $statuses
                                                );

                                                if ($newStatus) {
                                                    $updateOrderStatuses[$orderToUpdate->id] = $orderToUpdate->id;
                                                    $orderToUpdate->current_state = $statuses[$newStatus];
                                                }
                                            }

                                            StockAvailable::updateQuantity(
                                                $product_id,
                                                $product_attribute_id,
                                                $deltaQuantity,
                                                Context::getContext()->shop->id
                                            );
                                        }

                                        $orderDetail->id_warehouse = !empty($orderToUpdate->id_warehouse)
                                            ? $orderToUpdate->id_warehouse : 0;

                                        self::loadInCMS($orderDetail, 'update');
                                        unset($order['items'][$key]);
                                    }
                                }
                            }

                            /*
                             * Check new items
                             */
                            $isNewItemsExist = false;
                            $newItemsIds = [];
                            foreach ($order['items'] as $key => $newItem) {
                                if (RetailcrmOrderBuilder::isGiftItem($newItem)) {
                                    continue;
                                }

                                $isNewItem = isset($newItem['create']) ? $newItem['create'] : false;
                                if (!$isNewItem) {
                                    continue;
                                }

                                $parsedExtId = static::parseItemExternalId($newItem);
                                $product_id = $parsedExtId['product_id'];
                                $product_attribute_id = $parsedExtId['product_attribute_id'];

                                $product = new Product((int) $product_id, false, self::$default_lang);

                                if (0 != $product_attribute_id) {
                                    $productName = htmlspecialchars(
                                        strip_tags(Product::getProductName($product_id, $product_attribute_id))
                                    );
                                } else {
                                    $productName = htmlspecialchars(strip_tags($product->name));
                                }

                                $productPrice = $newItem['initialPrice'];

                                $orderDetail = new OrderDetail(
                                    !empty($parsedExtId['id_order_detail']) ? $parsedExtId['id_order_detail'] : null
                                );

                                static::setOrderDetailProductName($orderDetail, $productName);

                                $orderDetail->id_order = $orderToUpdate->id;
                                $orderDetail->id_order_invoice = $orderToUpdate->invoice_number;
                                $orderDetail->id_shop = Context::getContext()->shop->id;

                                $orderDetail->product_id = (int) $product_id;
                                $orderDetail->product_attribute_id = (int) $product_attribute_id;
                                $orderDetail->product_reference = implode('', ['\'', $product->reference, '\'']);

                                $orderDetail->product_price = $productPrice;
                                $orderDetail->original_product_price = $productPrice;
                                $orderDetail->product_quantity = (int) $newItem['quantity'];
                                $orderDetail->product_quantity_in_stock = (int) $newItem['quantity'];

                                $orderDetail->total_price_tax_incl = $productPrice * $orderDetail->product_quantity;
                                $orderDetail->unit_price_tax_incl = $productPrice;

                                $orderDetail->id_warehouse = !empty($orderToUpdate->id_warehouse)
                                    ? $orderToUpdate->id_warehouse : 0;
                                $orderDetail->id_order_detail = !empty($parsedExtId['id_order_detail'])
                                    ? $parsedExtId['id_order_detail'] : null;

                                if (!$product->checkQty($orderDetail->product_quantity)) {
                                    $newStatus = self::setOutOfStockStatus(
                                        $infoOrder,
                                        $orderToUpdate,
                                        $statuses
                                    );

                                    if ($newStatus) {
                                        $updateOrderStatuses[$orderToUpdate->id] = $orderToUpdate->id;
                                        $orderToUpdate->current_state = $statuses[$newStatus];
                                    }
                                }

                                StockAvailable::updateQuantity(
                                    $product_id,
                                    $product_attribute_id,
                                    -1 * $orderDetail->product_quantity,
                                    Context::getContext()->shop->id
                                );

                                if (self::loadInCMS($orderDetail, 'save')) {
                                    $newItemsIds[Db::getInstance()->Insert_ID()] = $newItem['id'];
                                }

                                unset($orderDetail);
                                unset($order['items'][$key]);
                                $isNewItemsExist = true;
                            }

                            // update order items ids in crm
                            if ($isNewItemsExist) {
                                $newItemsIdsByOrderId[$orderToUpdate->id] = $newItemsIds;
                            }
                        }

                        // totals
                        $totalPaid = $infoOrder['totalSumm'];
                        $orderTotalProducts = array_reduce($infoOrder['items'], function ($sum, $it) {
                            $sum += $it['initialPrice'] * $it['quantity'];

                            return $sum;
                        });
                        $deliveryCost = $infoOrder['delivery']['cost'];
                        $totalDiscount = round($deliveryCost + $orderTotalProducts - $totalPaid, 2);

                        // delete all cart discount
                        $orderCartRules = $orderToUpdate->getCartRules();
                        foreach ($orderCartRules as $valCartRules) {
                            $order_cart_rule = new OrderCartRule($valCartRules['id_order_cart_rule']);
                            $order_cart_rule->delete();
                        }

                        $orderToUpdate->total_discounts = $totalDiscount;
                        $orderToUpdate->total_discounts_tax_incl = $totalDiscount;
                        $orderToUpdate->total_discounts_tax_excl = $totalDiscount;
                        $orderToUpdate->total_shipping = $deliveryCost;
                        $orderToUpdate->total_shipping_tax_incl = $deliveryCost;
                        $orderToUpdate->total_shipping_tax_excl = $deliveryCost;
                        $orderToUpdate->total_paid = $totalPaid;
                        $orderToUpdate->total_paid_tax_incl = $totalPaid;
                        $orderToUpdate->total_paid_tax_excl = $totalPaid;
                        $orderToUpdate->total_products_wt = $orderTotalProducts;

                        self::loadInCMS($orderToUpdate, 'update');
                    }

                    /*
                     * check status
                     */
                    if (!empty($order['status']) && !array_key_exists($orderToUpdate->id, $updateOrderStatuses)) {
                        $stype = $order['status'];

                        if (isset($statuses[$stype]) && !empty($statuses[$stype])) {
                            if ($statuses[$stype] != $orderToUpdate->current_state) {
                                $orderHistory = new OrderHistory();
                                $orderHistory->id_employee = 0;
                                $orderHistory->id_order = $orderToUpdate->id;
                                $orderHistory->id_order_state = $statuses[$stype];
                                $orderHistory->date_add = date('Y-m-d H:i:s');

                                self::loadInCMS($orderHistory, 'save');

                                RetailcrmLogger::writeDebug(
                                    __METHOD__,
                                    sprintf(
                                        '<Order ID: %d> %s::%s',
                                        $orderToUpdate->id,
                                        get_class($orderHistory),
                                        'changeIdOrderState'
                                    )
                                );

                                $orderHistory->changeIdOrderState($statuses[$stype], $orderToUpdate->id, true);
                            }
                        }
                    }

                    // update order number in PS if receiveOrderNumber option (CRM->PS) enabled
                    if (isset($order['number']) && $receiveOrderNumber) {
                        $orderToUpdate->reference = $order['number'];
                        $orderToUpdate->update();
                    }

                    // collect orders id and reference if option sendOrderNumber enabled
                    if ($sendOrderNumber) {
                        $updateOrderIds[] = [
                            'externalId' => $orderToUpdate->id,
                            'number' => $orderToUpdate->reference,
                        ];
                    }
                }
            }

            // fix order externalId
            if (!empty($orderFix)) {
                self::$api->ordersFixExternalIds($orderFix);
            }

            // update orders number in CRM
            if (!empty($updateOrderIds)) {
                foreach ($updateOrderIds as $upOrder) {
                    self::$api->ordersEdit($upOrder);
                }
            }

            // update order items ids in crm
            if (!empty($newItemsIdsByOrderId)) {
                foreach ($newItemsIdsByOrderId as $newOrderId => $newItemsIds) {
                    static::updateOrderItems($newOrderId, $newItemsIds);
                }
            }

            return true;
        } else {
            return 'Nothing to sync';
        }
    }

    /**
     * Returns retailCRM order by id or by externalId.
     * It returns only order data, not ApiResponse or something.
     *
     * @param string $id Order identifier
     * @param string $by Search field (default: 'externalId')
     *
     * @return array
     */
    protected static function getCRMOrder($id, $by = 'externalId')
    {
        $crmOrderResponse = self::$api->ordersGet($id, $by);

        if (!empty($crmOrderResponse)
            && $crmOrderResponse->isSuccessful()
            && $crmOrderResponse->offsetExists('order')
        ) {
            return (array) $crmOrderResponse['order'];
        }

        return [];
    }

    /**
     * Sets all needed data for customer switch to switcher state
     *
     * @param array $crmCustomer
     * @param \RetailcrmCustomerSwitcherState $data
     * @param bool $isContact
     */
    protected static function prepareChangeToIndividual($crmCustomer, $data, $isContact = false)
    {
        RetailcrmLogger::writeDebugArray(
            __METHOD__,
            [
                'Using this individual person data in order to set it into order,',
                $data->getOrder()->id,
                ': ',
                $crmCustomer,
            ]
        );

        if ($isContact) {
            $data->setNewContact($crmCustomer);
        } else {
            $data->setNewCustomer($crmCustomer);
        }
    }

    /**
     * Sets order status to 'outOfStock' and returns CRM status or false if status will not change
     *
     * @param array $crmOrder
     * @param \Order $cmsOrder
     * @param array $statuses
     *
     * @return string|false
     */
    private static function setOutOfStockStatus($crmOrder, $cmsOrder, $statuses)
    {
        $statusArray = json_decode(
            Configuration::get(RetailCRM::OUT_OF_STOCK_STATUS),
            true
        );

        if (isset($crmOrder['fullPaidAt']) && !empty($crmOrder['fullPaidAt'])) {
            $stype = $statusArray['out_of_stock_paid'];

            if ('' == $stype) {
                return false;
            }
        } else {
            $stype = $statusArray['out_of_stock_not_paid'];

            if ('' == $stype) {
                return false;
            }
        }

        if ($statuses[$stype] != $cmsOrder->current_state) {
            $orderHistory = new OrderHistory();
            $orderHistory->id_order = $cmsOrder->id;
            $orderHistory->id_order_state = $statuses[$stype];
            $orderHistory->date_add = date('Y-m-d H:i:s');

            self::loadInCMS($orderHistory, 'save');

            RetailcrmLogger::writeDebug(
                __METHOD__,
                sprintf(
                    '<Order ID: %d> %s::%s',
                    $cmsOrder->id,
                    get_class($orderHistory),
                    'changeIdOrderState'
                )
            );

            $orderHistory->changeIdOrderState(
                (int) $statuses[$stype],
                $cmsOrder->id,
                true
            );

            return $stype;
        }

        return false;
    }

    /**
     * Handle customer data change (from individual to corporate, company change, etc)
     *
     * @param \Order $order
     * @param array $historyOrder
     *
     * @return bool true if customer change happened; false otherwise
     */
    private static function handleCustomerDataChange($order, $historyOrder)
    {
        $handled = false;
        $crmOrder = [];
        $newCustomerId = null;
        $switcher = new RetailcrmCustomerSwitcher();
        $data = new RetailcrmCustomerSwitcherState();
        $data->setOrder($order);

        RetailcrmLogger::writeDebug(
            __METHOD__,
            $historyOrder
        );

        if (isset($historyOrder['customer'])) {
            $crmOrder = self::getCRMOrder($historyOrder['id'], 'id');

            if (empty($crmOrder)) {
                RetailcrmLogger::writeCaller(__METHOD__, sprintf(
                    'Cannot get order data from retailCRM. Skipping customer change. History data: %s',
                    print_r($historyOrder, true)
                ));

                return false;
            }

            $newCustomerId = $historyOrder['customer']['id'];
            $isChangedToRegular = RetailcrmTools::isCustomerChangedToRegular($historyOrder);
            $isChangedToCorporate = RetailcrmTools::isCustomerChangedToLegal($historyOrder);

            if (!$isChangedToRegular && !$isChangedToCorporate) {
                $isChangedToCorporate = RetailcrmTools::isCrmOrderCorporate($crmOrder);
                $isChangedToRegular = !$isChangedToCorporate;
            }

            if ($isChangedToRegular) {
                self::prepareChangeToIndividual(
                    RetailcrmTools::arrayValue($crmOrder, 'customer', []),
                    $data
                );
            }
        }

        if (isset($historyOrder['contact'])) {
            $newCustomerId = $historyOrder['contact']['id'];

            if (empty($crmOrder)) {
                $crmOrder = self::getCRMOrder($historyOrder['id'], 'id');
            }

            if (empty($crmOrder)) {
                RetailcrmLogger::writeCaller(__METHOD__, sprintf(
                    'Cannot get order data from retailCRM. Skipping customer change. History data: %s',
                    print_r($historyOrder, true)
                ));

                return false;
            }

            if (RetailcrmTools::isCrmOrderCorporate($crmOrder)) {
                self::prepareChangeToIndividual(
                    RetailcrmTools::arrayValue($crmOrder, 'contact', []),
                    $data,
                    true
                );

                $data->setNewCustomer([]);
            }
        }

        if (isset($historyOrder['company'])) {
            if (!empty($crmOrder['company'])) {
                $data->setNewCompany($crmOrder['company']);
            } else {
                $data->setNewCompany($historyOrder['company']);
            }
        }

        if ($data->feasible()) {
            if (!empty($crmOrder) && !empty($crmOrder['delivery']) && !empty($crmOrder['delivery']['address'])) {
                $data->setCrmOrderShippingAddress($crmOrder['delivery']['address']);
            }

            try {
                $result = $switcher->setData($data)
                    ->build()
                    ->getResult()
                ;
                $result->save();
                $handled = true;
            } catch (\Exception $exception) {
                $errorMessage = sprintf(
                    'Error switching order externalId=%s to customer id=%s (new company: id=%s %s). Reason: %s',
                    $historyOrder['externalId'],
                    $newCustomerId,
                    isset($historyOrder['company']) ? $historyOrder['company']['id'] : '',
                    isset($historyOrder['company']) ? $historyOrder['company']['name'] : '',
                    $exception->getMessage()
                );
                RetailcrmLogger::writeCaller(__METHOD__, $errorMessage);
                RetailcrmLogger::writeDebug(__METHOD__, sprintf(
                    '%s%s%s',
                    $errorMessage,
                    PHP_EOL,
                    $exception->getTraceAsString()
                ));
                $handled = false;
            }
        }

        return $handled;
    }

    /**
     * Delete order product from order by product
     *
     * @param $order_id
     * @param $product_id
     * @param $product_attribute_id
     *
     * @return void
     */
    private static function deleteOrderDetailByProduct($order_id, $product_id, $product_attribute_id, $id_order_detail)
    {
        Db::getInstance()->execute('
            DELETE FROM ' . _DB_PREFIX_ . 'order_detail
            WHERE id_order = ' . pSQL((int) $order_id) . '
            AND product_id = ' . pSQL((int) $product_id) . '
            AND product_attribute_id = ' . pSQL((int) $product_attribute_id) . '
            AND id_order_detail = ' . pSQL((int) $id_order_detail)
        );
    }

    private static function getNewOrderDetailId()
    {
        return Db::getInstance()->getRow('
            SELECT MAX(id_order_detail) FROM  ' . _DB_PREFIX_ . 'order_detail'
        );
    }

    /**
     * load and catch exception
     *
     * @param \ObjectModel|\ObjectModelCore $object
     * @param string $action
     *
     * @return bool
     */
    private static function loadInCMS($object, $action)
    {
        try {
            $prefix = $object->id;

            if (empty($object->id)) {
                if (property_exists(get_class($object), 'id_customer')) {
                    $prefix = sprintf('Customer ID: %d', $object->id_customer);
                }

                if (property_exists(get_class($object), 'id_order')) {
                    $prefix = sprintf('Order ID: %d', $object->id_order);
                }
            }

            RetailcrmLogger::writeDebug(
                __METHOD__,
                sprintf(
                    '<%s> %s::%s',
                    $prefix,
                    get_class($object),
                    $action
                )
            );
            $object->$action();
        } catch (PrestaShopException $e) {
            RetailcrmLogger::writeCaller(
                'loadInCMS',
                sprintf(
                    ' > %s %s',
                    (string) $action,
                    $e->getMessage()
                )
            );
            RetailcrmLogger::writeNoCaller($e->getTraceAsString());

            return false;
        }

        return true;
    }

    /**
     * Filters out history by these terms:
     *  - Changes from current API key will be added only if CMS changes are more actual than history.
     *  - All other changes will be merged as usual.
     * It fixes these problems:
     *  - Changes from current API key are merged when it's not needed.
     *  - Changes from CRM can overwrite more actual changes from CMS due to ignoring current API key changes.
     *
     * @param array $historyEntries Raw history from CRM
     * @param string $recordType Entity field name, e.g. `customer` or `order`.
     *
     * @return array
     */
    private static function filterHistory($historyEntries, $recordType)
    {
        $history = [];
        $organizedHistory = [];
        $notOurChanges = [];

        foreach ($historyEntries as $entry) {
            if (!isset($entry[$recordType]['externalId'])) {
                if ('api' == $entry['source']
                    && isset($change['apiKey']['current'])
                    && true == $entry['apiKey']['current']
                    && 'externalId' != $entry['field']
                ) {
                    continue;
                } else {
                    $history[] = $entry;
                }

                continue;
            }

            $externalId = $entry[$recordType]['externalId'];
            $field = $entry['field'];

            if (!isset($organizedHistory[$externalId])) {
                $organizedHistory[$externalId] = [];
            }

            if (!isset($notOurChanges[$externalId])) {
                $notOurChanges[$externalId] = [];
            }

            if (
                'api' == $entry['source']
                && isset($entry['apiKey']['current'])
                && true == $entry['apiKey']['current']
            ) {
                if (isset($notOurChanges[$externalId][$field]) || 'externalId' == $field || 'status' == $field) {
                    $organizedHistory[$externalId][] = $entry;
                } else {
                    continue;
                }
            } else {
                $organizedHistory[$externalId][] = $entry;
                $notOurChanges[$externalId][$field] = true;
            }
        }

        unset($notOurChanges);

        foreach ($organizedHistory as $historyChunk) {
            $history = array_merge($history, $historyChunk);
        }

        return $history;
    }

    /**
     * Returns customer ID by email if such customer was found in the DB.
     *
     * @param string $customerEmail
     *
     * @return int
     */
    private static function getCustomerIdByEmail($customerEmail)
    {
        if (!empty($customerEmail)) {
            $item = Customer::getCustomersByEmail($customerEmail);

            if (is_array($item) && 0 < count($item)) {
                $item = reset($item);

                return (int) $item['id_customer'];
            }
        }

        return 0;
    }

    /**
     * Returns array with product id and product attribute id.
     * Returns 0 as attribute id if attribute is not present.
     * Returns array(0, 0) in case of failure.
     *
     * @param $item
     *
     * @return array
     */
    private static function parseItemExternalId($item)
    {
        if (isset($item['externalIds'])) {
            foreach ($item['externalIds'] as $externalId) {
                if ('prestashop' == $externalId['code']) {
                    return static::parseItemExternalIdString($externalId['value']);
                }
            }
        } else {
            return static::parseItemExternalIdString($item['offer']['externalId']);
        }

        return static::parseItemExternalIdString('0#0_0');
    }

    /**
     * Parse item externalId
     *
     * @param $externalIdString
     *
     * @return array
     */
    private static function parseItemExternalIdString($externalIdString)
    {
        $parsed = explode('_', $externalIdString);
        $data = [
            'product_id' => 0,
            'product_attribute_id' => 0,
            'id_order_detail' => 0,
        ];

        if (0 < count($parsed)) {
            $productIdParsed = explode('#', $parsed[0]);

            if (2 == count($productIdParsed)) {
                $data['product_id'] = $productIdParsed[0];
                $data['product_attribute_id'] = $productIdParsed[1];
            } elseif (1 == count($productIdParsed)) {
                $data['product_id'] = $parsed[0];
            }

            if (2 == count($parsed)) {
                $data['id_order_detail'] = $parsed[1];
            }
        }

        return $data;
    }

    /**
     * Returns oldest active employee id. For order history record.
     *
     * @return false|string|null
     */
    private static function getFirstEmployeeId()
    {
        return Db::getInstance()->getValue('
            SELECT `id_employee`
            FROM `' . _DB_PREFIX_ . 'employee`
            WHERE `active` = 1
            ORDER BY `id_employee` ASC
		');
    }

    /**
     * Removes quotes on string start and end
     *
     * @param $str
     *
     * @return false|string
     */
    private static function removeEdgeQuotes($str)
    {
        if (2 <= strlen($str)) {
            $newStr = $str;

            if ('\'' == $newStr[0] && '\'' == $newStr[strlen($newStr) - 1]) {
                $newStr = substr($newStr, 1, strlen($newStr) - 2);
            }

            return $newStr;
        }

        return $str;
    }

    /**
     * Sets product_name in OrderDetail through validation
     *
     * @param OrderDetail|\OrderDetailCore $object
     * @param string $name
     *
     * @throws \PrestaShopException
     */
    private static function setOrderDetailProductName(&$object, $name)
    {
        $object->product_name = static::removeEdgeQuotes($name);

        if (true !== $object->validateField('product_name', $object->product_name)) {
            $object->product_name = implode('', ['\'', $name, '\'']);
        }
    }

    private static function updateOrderItems($orderId, $newItemsIds)
    {
        $upOrderItems = [
            'externalId' => $orderId,
        ];

        $orderdb = new Order($orderId);
        foreach ($orderdb->getProducts() as $item) {
            if (isset($item['product_attribute_id']) && 0 < $item['product_attribute_id']) {
                $productId = $item['product_id'] . '#' . $item['product_attribute_id'];
            } else {
                $productId = $item['product_id'];
            }

            $crmItem = [
                'externalIds' => [
                    [
                        'code' => 'prestashop',
                        'value' => $productId . '_' . $item['id_order_detail'],
                    ],
                ],
            ];

            if (array_key_exists($item['id_order_detail'], $newItemsIds)) {
                $crmItem['id'] = $newItemsIds[$item['id_order_detail']];
            }

            $upOrderItems['items'][] = $crmItem;
        }

        unset($orderdb);
        if (isset($upOrderItems['items'])) {
            self::$api->ordersEdit($upOrderItems);
        }
    }

    /**
     * Updates sinceId for orders or customers to the latest value
     *
     * @param string $entity Can be either 'orders' or 'customers'
     *
     * @return bool
     */
    public static function updateSinceId($entity)
    {
        if ('orders' === $entity) {
            $key = 'RETAILCRM_LAST_ORDERS_SYNC';
            $method = 'ordersHistory';
        } elseif ('customers' === $entity) {
            $key = 'RETAILCRM_LAST_CUSTOMERS_SYNC';
            $method = 'customersHistory';
        } else {
            return false;
        }

        $currentSinceID = Configuration::get($key);
        RetailcrmLogger::writeDebug(__METHOD__, "Current $entity sinceId: $currentSinceID");

        $historyResponse = call_user_func_array(
            [self::$api, $method],
            [
                ['sinceId' => $currentSinceID],
                null,
                20,
            ]
        );

        if ($historyResponse instanceof RetailcrmApiResponse && $historyResponse->offsetExists('pagination')) {
            $lastPage = $historyResponse['pagination']['totalPageCount'];
            if (1 < $lastPage) {
                $historyResponse = call_user_func_array(
                    [self::$api, $method],
                    [
                        ['sinceId' => $currentSinceID],
                        $lastPage,
                        20,
                    ]
                );
            }

            if ($historyResponse instanceof RetailcrmApiResponse
                && $historyResponse->offsetExists('history')
                && !empty($historyResponse['history'])
            ) {
                $history = $historyResponse['history'];
                $lastSinceId = end($history)['id'];

                if ($currentSinceID !== (string) $lastSinceId) {
                    RetailcrmLogger::writeDebug(__METHOD__, "Updating to: $lastSinceId");
                    Configuration::updateValue($key, $lastSinceId);
                }
            }
        }

        return true;
    }
}