opencart-module/admin/controller/extension/module/retailcrm.php

<?php

require_once DIR_SYSTEM . 'library/retailcrm/bootstrap.php';

/**
 * Class ControllerModule
 *
 * @category RetailCrm
 * @package  RetailCrm
 * @author   RetailCrm <integration@retailcrm.ru>
 * @license  https://opensource.org/licenses/MIT MIT License
 * @link     http://www.retailcrm.ru/docs/Developers/ApiVersion5
 */
class ControllerExtensionModuleRetailcrm extends Controller
{
    private $_error = array();
    protected $log, $statuses, $payments, $deliveryTypes, $retailcrm;
    public $children, $template;

    /**
     * Install method
     *
     * @return void
     */
    public function install()
    {
        $moduleTitle = $this->getModuleTitle();
        $this->load->model('setting/setting');

        $this->model_setting_setting
            ->editSetting($moduleTitle, array(
                    $moduleTitle . '_status' => 1,
                    $moduleTitle . '_country' => array($this->config->get('config_country_id'))
                )
            );
        
        $this->loadModels();

        $this->{'model_' . $this->modelEvent}
            ->addEvent(
                $moduleTitle,
                'catalog/model/checkout/order/addOrder/after',
                'extension/module/retailcrm/order_create'
            );

        $this->{'model_' . $this->modelEvent}
            ->addEvent(
                $moduleTitle,
                'catalog/model/checkout/order/addOrderHistory/after',
                'extension/module/retailcrm/order_edit'
            );

        $this->{'model_' . $this->modelEvent}
            ->addEvent(
                $moduleTitle,
                'catalog/model/account/customer/addCustomer/after',
                'extension/module/retailcrm/customer_create'
            );

        $this->{'model_' . $this->modelEvent}
            ->addEvent(
                $moduleTitle,
                'catalog/model/account/customer/editCustomer/after',
                'extension/module/retailcrm/customer_edit'
            );
            
        $this->{'model_' . $this->modelEvent}
            ->addEvent(
                $moduleTitle,
                'catalog/model/account/address/editAddress/after',
                'extension/module/retailcrm/customer_edit'
            );

        $this->{'model_' . $this->modelEvent}
            ->addEvent(
                $moduleTitle,
                'admin/model/customer/customer/editCustomer/after',
                'extension/module/retailcrm/customer_edit'
            );
    }

    /**
     * Uninstall method
     *
     * @return void
     */
    public function uninstall()
    {   
        $moduleTitle = $this->getModuleTitle();
        $this->uninstall_collector();
        $this->load->model('setting/setting');
        $this->model_setting_setting
            ->editSetting($moduleTitle, array($moduleTitle . '_status' => 0));
        $this->model_setting_setting->deleteSetting('retailcrm_history');
        $this->loadModels();
        $this->{'model_' . $this->modelEvent}->deleteEvent($moduleTitle);
    }

    /**
     * Install Demon Collector method
     *
     * @return void
     */
    public function install_collector()
    {   
        $collector = $this->getCollectorTitle();
        $moduleTitle = $this->getModuleTitle();
        $this->loadModels();
        $this->load->model('setting/setting');
        $this->{'model_' . $this->modelExtension}->install('analytics', 'daemon_collector');
        $this->model_setting_setting->editSetting($collector, array($collector . '_status' => 1));
    }

    /**
     * Uninstall Demon Collector method
     *
     * @return void
     */
    public function uninstall_collector()
    {   
        $collector = $this->getCollectorTitle();
        $this->loadModels();
        $this->load->model('setting/setting');
        $this->model_setting_setting->editSetting($collector, array($collector . '_status' => 0));
        $this->{'model_' . $this->modelExtension}->uninstall('analytics', 'daemon_collector');
    }

    /**
     * Setup page
     *
     * @return void
     */
    public function index()
    {   
        $this->loadModels();
        $this->load->model('localisation/country');
        $this->load->model('setting/setting');
        $this->load->model('extension/retailcrm/references');
        $this->load->language('extension/module/retailcrm');
        $this->document->setTitle($this->language->get('heading_title'));
        $this->document->addStyle('/admin/view/stylesheet/retailcrm.css');

        $tokenTitle = $this->getTokenTitle();
        $moduleTitle = $this->getModuleTitle();
        $collector = $this->getCollectorTitle();
        $history_setting = $this->model_setting_setting->getSetting('retailcrm_history');
        
        if ($this->request->server['REQUEST_METHOD'] == 'POST' && $this->validate()) {
            $analytics = $this->{'model_' . $this->modelExtension}->getInstalled('analytics');
            
            if ($this->request->post[$moduleTitle . '_collector_active'] == 1 && 
                !in_array($collector, $analytics)) {
                $this->install_collector();
            } elseif ($this->request->post[$moduleTitle . '_collector_active'] == 0 &&
                in_array($collector, $analytics)) {
                $this->uninstall_collector();
            }

            if (parse_url($this->request->post[$moduleTitle . '_url'])) {
                $crm_url = parse_url($this->request->post[$moduleTitle . '_url'], PHP_URL_HOST);
                $this->request->post[$moduleTitle . '_url'] = 'https://'.$crm_url;
            }
            
            if ($this->request->post[$moduleTitle . '_custom_field_active'] == 0) {
                unset($this->request->post[$moduleTitle . '_custom_field']);
            }

            $this->model_setting_setting->editSetting(
                $moduleTitle,
                $this->request->post
            );

            if ($this->request->post[$moduleTitle . '_apiversion'] != 'v3') {
                if (!isset($history_setting['retailcrm_history_orders']) && !isset($history_setting['retailcrm_history_customers'])) {
                    $api =  new RetailcrmProxy(
                        $this->request->post[$moduleTitle . '_url'],
                        $this->request->post[$moduleTitle . '_apikey'],
                        DIR_SYSTEM . 'storage/logs/retailcrm.log',
                        $this->request->post[$moduleTitle . '_apiversion']
                    );

                    $ordersHistory = $api->ordersHistory();

                    if ($ordersHistory->isSuccessful()) {
                        $ordersHistory = $api->ordersHistory(array(), $ordersHistory['pagination']['totalPageCount']);

                        if ($ordersHistory->isSuccessful()) {

                            $lastChangeOrders = end($ordersHistory['history']);
                            $sinceIdOrders = $lastChangeOrders['id'];
                            $generatedAt = $ordersHistory['generatedAt'];
                        }
                    }

                    $customersHistory = $api->customersHistory();

                    if ($customersHistory->isSuccessful()) {
                        $customersHistory = $api->customersHistory(array(), $customersHistory['pagination']['totalPageCount']);

                        if ($customersHistory->isSuccessful()) {
                            $lastChangeCustomers = end($customersHistory['history']);
                            $sinceIdCustomers = $lastChangeCustomers['id'];
                        }
                    }

                    $this->model_setting_setting->editSetting(
                        'retailcrm_history', 
                        array(
                            'retailcrm_history_orders' => $sinceIdOrders, 
                            'retailcrm_history_customers' => $sinceIdCustomers,
                            'retailcrm_history_datetime' => $generatedAt
                        )
                    );
                }
            }

            $this->session->data['success'] = $this->language->get('text_success');
            $redirect = $this->url->link(
                'extension/module/retailcrm', $tokenTitle . '=' . $this->session->data[$tokenTitle],
                'SSL'
            );

            $this->response->redirect($redirect);
        }

        $text_strings = array(
            'heading_title',
            'text_enabled',
            'text_disabled',
            'button_save',
            'button_cancel',
            'text_notice',
            'retailcrm_title',
            'retailcrm_apiversion',
            'retailcrm_url',
            'retailcrm_apikey',
            'retailcrm_base_settings',
            'retailcrm_dict_settings',
            'retailcrm_dict_delivery',
            'retailcrm_dict_status',
            'retailcrm_dict_payment',
            'retailcrm_countries_settings',
            'text_success_export',
            'text_success_export_order',
            'text_button_export',
            'text_button_export_order',
            'text_button_catalog',
            'text_success_catalog',
            'retailcrm_upload_order',
            'text_error_order',
            'text_error_order_id',
            'daemon_collector',
            'general_tab_text',
            'references_tab_text',
            'collector_tab_text',
            'text_yes',
            'text_no',
            'collector_site_key',
            'text_collector_activity',
            'text_collector_form_capture',
            'text_collector_period',
            'text_label_promo',
            'text_label_send',
            'collector_custom_text',
            'text_require',
            'custom_fields_tab_text',
            'text_error_custom_field',
            'text_error_cf_opencart',
            'text_error_cf_retailcrm',
            'retailcrm_dict_custom_fields',
            'text_payment',
            'text_shipping',
            'retailcrm_dict_default',
            'text_custom_field_activity',
            'text_orders_custom_fields',
            'text_customers_custom_fields'
        );

        $_data = &$data;

        foreach ($text_strings as $text) {
            $_data[$text] = $this->language->get($text);
        }

        $_data['retailcrm_errors'] = array();
        $_data['saved_settings'] = $this->model_setting_setting
            ->getSetting($moduleTitle);

        $url = isset($_data['saved_settings'][$moduleTitle . '_url'])
            ? $_data['saved_settings'][$moduleTitle . '_url']
            : null;
        $key = isset($_data['saved_settings'][$moduleTitle . '_apikey'])
            ? $_data['saved_settings'][$moduleTitle . '_apikey']
            : null;
        $apiVersion = isset($_data['saved_settings'][$moduleTitle . '_apiversion'])
            ? $_data['saved_settings'][$moduleTitle . '_apiversion']
            : null;

        if (!empty($url) && !empty($key)) {

            $this->retailcrm = new RetailcrmProxy(
                $url,
                $key,
                DIR_SYSTEM . 'storage/logs/retailcrm.log',
                $apiVersion
            );

            $_data['delivery'] = $this->model_extension_retailcrm_references
                ->getDeliveryTypes();
            $_data['statuses'] = $this->model_extension_retailcrm_references
                ->getOrderStatuses();
            $_data['payments'] = $this->model_extension_retailcrm_references
                ->getPaymentTypes();
            
            if ($apiVersion == 'v5') {
                $_data['customFields'] = $this->model_extension_retailcrm_references
                    ->getCustomFields();
            }
        }

        $config_data = array(
            $moduleTitle . '_status'
        );

        foreach ($config_data as $conf) {
            if (isset($this->request->post[$conf])) {
                $_data[$conf] = $this->request->post[$conf];
            } else {
                $_data[$conf] = $this->config->get($conf);
            }
        }

        if (isset($this->_error['warning'])) {
            $_data['error_warning'] = $this->_error['warning'];
        } else {
            $_data['error_warning'] = '';
        }

        $_data['breadcrumbs'] = array();

        $_data['breadcrumbs'][] = array(
            'text'      => $this->language->get('text_home'),
            'href'      => $this->url->link(
                'common/home',
                $tokenTitle . '=' . $this->session->data[$tokenTitle], 'SSL'
            ),
            'separator' => false
        );

        $_data['breadcrumbs'][] = array(
            'text'      => $this->language->get('text_module'),
            'href'      => $this->url->link(
                'extension/extension/module',
                $tokenTitle . '=' . $this->session->data[$tokenTitle], 'SSL'
            ),
            'separator' => ' :: '
        );

        $_data['breadcrumbs'][] = array(
            'text'      => $this->language->get('retailcrm_title'),
            'href'      => $this->url->link(
                'extension/module/retailcrm',
                $tokenTitle . '=' . $this->session->data[$tokenTitle], 'SSL'
            ),
            'separator' => ' :: '
        );

        $_data['action'] = $this->url->link(
            'extension/module/retailcrm',
            $tokenTitle . '=' . $this->session->data[$tokenTitle], 'SSL'
        );

        $_data['cancel'] = $this->url->link(
            version_compare(VERSION, '3.0', '<') ? 'extension/extension' : 'marketplace/extension',
            $tokenTitle . '=' . $this->session->data[$tokenTitle], 'SSL'
        );

        $_data['modules'] = array();

        if (isset($this->request->post['retailcrm_module'])) {
            $_data['modules'] = $this->request->post['retailcrm_module'];
        } elseif ($this->config->get('retailcrm_module')) {
            $_data['modules'] = $this->config->get('retailcrm_module');
        }

        $this->load->model('design/layout');
        $_data['layouts'] = $this->model_design_layout->getLayouts();

        $_data['header'] = $this->load->controller('common/header');
        $_data['column_left'] = $this->load->controller('common/column_left');
        $_data['footer'] = $this->load->controller('common/footer');
        $_data['countries'] = $this->model_localisation_country->getCountries();
        $_data['catalog'] = $this->request->server['HTTPS'] ? HTTPS_CATALOG : HTTP_CATALOG;
        $_data[$tokenTitle] = $this->request->get[$tokenTitle];

        if(file_exists(DIR_SYSTEM . '/cron/export_done')) {
            $_data['export_file'] = false;
        } else {
            $_data['export_file'] = true;
        }
        
        $collectorFields = array(
            'name' => $this->language->get('field_name'),
            'email' => $this->language->get('field_email'),
            'phone' => $this->language->get('field_phone')
        );

        $_data['collectorFields'] = $collectorFields;
        $_data['api_versions'] = array('v3', 'v4', 'v5');
        $_data['default_apiversion'] = 'v4';
        
        $this->response->setOutput(
            $this->load->view('extension/module/retailcrm', $_data)
        );
        
    }

    /**
     * History method
     *
     * @return void
     */
    public function history()
    {   
        $moduleTitle = $this->getModuleTitle();
        $this->load->model('setting/setting');
        $settings = $this->model_setting_setting->getSetting($moduleTitle);

        if ($settings[$moduleTitle . '_apiversion'] == 'v3') {
            if (file_exists(DIR_APPLICATION . 'model/extension/retailcrm/custom/history/v3.php')) {
                $this->load->model('extension/retailcrm/custom/history/v3');
                $this->model_extension_retailcrm_custom_history_v3->request();
            } else {
                $this->load->model('extension/retailcrm/history/v3');
                $this->model_extension_retailcrm_history_v3->request();
            }
        } else {
            if (file_exists(DIR_APPLICATION . 'model/extension/retailcrm/custom/history/v4-5.php')) {
                $this->load->model('extension/retailcrm/custom/history/v4-5');
                $this->model_extension_retailcrm_custom_history_v4_5->request();
            } else {
                $this->load->model('extension/retailcrm/history/v4_5');
                $this->model_extension_retailcrm_history_v4_5->request();
            }
        }
    }

    /**
     * ICML generation
     *
     * @return void
     */
    public function icml()
    {
        if (file_exists(DIR_APPLICATION . 'model/extension/retailcrm/custom/icml.php')) {
            $this->load->model('extension/retailcrm/custom/icml');
            $this->model_extension_retailcrm_custom_icml->generateICML();
        } else {
            $this->load->model('extension/retailcrm/icml');
            $this->model_extension_retailcrm_icml->generateICML();
        }
    }

    /**
     * Create order on event
     *
     * @param int $order_id order identificator
     *
     * @return void
     */
    public function order_create($order_id)
    {
        $this->load->model('checkout/order');
        $this->load->model('account/order');

        $data = $this->model_checkout_order->getOrder($order_id);
        $data['products'] = $this->model_account_order->getOrderProducts($order_id);

        if (!isset($data['fromApi'])) {
            $this->load->model('setting/setting');
            $status = $this->model_setting_setting->getSetting('retailcrm');
            $data['order_status'] = $status['retailcrm_status'][$data['order_status_id']];

            $this->load->model('extension/retailcrm/order');
            $this->model_extension_retailcrm_order->sendToCrm($data, $data['order_id']);
        }
    }

    /**
     * Update customer on event
     *
     * @param int $customer_id customer identificator
     *
     * @return void
     */
    public function customer_edit($route, $customer)
    {   
        $this->load->model('localisation/country');
        $this->load->model('localisation/zone');
        $this->load->model('customer/customer');

        $customerId = $customer[0];
        $customer = $customer[1];
        $addresses = $customer['address'];
        unset($customer);

        $customer = $this->model_customer_customer->getCustomer($customerId);

        foreach ($addresses as $address) {
            $country = $this->model_localisation_country->getCountry($address['country_id']);
            $zone = $this->model_localisation_zone->getZone($address['zone_id']);

            $customer['address'] = array(
                'address_1' => $address['address_1'],
                'address_2' => $address['address_2'],
                'city' => $address['city'],
                'postcode' => $address['postcode'],
                'iso_code_2' => $country['iso_code_2'],
                'zone' => $zone['name']
            );    
        }

        $this->load->model('extension/retailcrm/customer');
        $this->model_extension_retailcrm_customer->changeInCrm($customer);
    }

    /**
     * Export single order
     *
     *
     */
    public function exportOrder()
    {
        $order_id = isset($this->request->get['order_id']) ? $this->request->get['order_id'] : '';
        $this->load->model('sale/order');
        $moduleTitle = $this->getModuleTitle();

        $data = $this->model_sale_order->getOrder($order_id);
        $data['products'] = $this->model_sale_order->getOrderProducts($order_id);
        $data['totals'] = $this->model_sale_order->getOrderTotals($order_id);

        if (!isset($data['fromApi'])) {
            $this->load->model('setting/setting');
            $status = $this->model_setting_setting->getSetting($moduleTitle);
            $data['order_status'] = $status[$moduleTitle . '_status'][$data['order_status_id']];

            $this->load->model('extension/retailcrm/order');
            $result = $this->model_extension_retailcrm_order->uploadOrder($data);
        }

        echo json_encode($result->getStatusCode());
    }

    /**
     * Export orders
     *
     *
     */
    public function export() {

        $this->load->model('customer/customer');
        $customers = $this->model_customer_customer->getCustomers();

        $this->load->model('extension/retailcrm/customer');
        $this->model_extension_retailcrm_customer->uploadToCrm($customers);

        $this->load->model('sale/order');
        $orders = $this->model_sale_order->getOrders();

        $fullOrders = array();

        foreach($orders as $order) {
            $fullOrder = $this->model_sale_order->getOrder($order['order_id']);

            $fullOrder['order_total'] = $this->model_sale_order->getOrderTotals($order['order_id']);
            $fullOrder['products'] = $this->model_sale_order->getOrderProducts($order['order_id']);

            foreach($fullOrder['products'] as $key=>$product) {
                $fullOrder['products'][$key]['option'] = $this->model_sale_order->getOrderOptions($product['order_id'], $product['order_product_id']);
            }

            $fullOrders[] = $fullOrder;
        }

        $this->load->model('extension/retailcrm/order');
        $this->model_extension_retailcrm_order->uploadToCrm($fullOrders);
        $file = fopen(DIR_SYSTEM . '/cron/export_done', "x");
    }

    /**
     * Validate
     *
     * @return bool
     */
    private function validate()
    {
        $moduleTitle = $this->getModuleTitle();

        $versionsMap = array(
            'v3' => '3.0',
            'v4' => '4.0',
            'v5' => '5.0'
        );

        if (!empty($this->request->post[$moduleTitle . '_url']) && !empty($this->request->post[$moduleTitle . '_apikey'])) {

            $this->retailcrm = new RetailcrmProxy(
                $this->request->post[$moduleTitle . '_url'],
                $this->request->post[$moduleTitle . '_apikey'],
                DIR_SYSTEM . 'storage/logs/retailcrm.log'
            );
        }

        $response = $this->retailcrm->apiVersions();

        if ($response && $response->isSuccessful()) {
            if (!in_array($versionsMap[$this->request->post[$moduleTitle . '_apiversion']], $response['versions'])) {
                $this->_error['warning'] = $this->language->get('text_error_api');
            }
        } else {
            $this->_error['warning'] = $this->language->get('text_error_save');
        }

        if (!$this->user->hasPermission('modify', 'extension/module/retailcrm')) {
            $this->_error['warning'] = $this->language->get('error_permission');
        }

        if (isset($this->request->post[$moduleTitle . '_collector']['custom']) &&
            $this->request->post[$moduleTitle . '_collector']['custom_form'] == 1) {
            $customField = $this->request->post[$moduleTitle . '_collector']['custom'];

            if (empty($customField['name']) && empty($customField['email']) && empty($customField['phone'])) {
                $this->_error['fields'] = $this->language->get('text_error_collector_fields');
            }
        }

        if (!$this->_error) {
            return true;
        } else {
            return false;
        }
    }

    private function loadModels()
    {
        if (version_compare(VERSION, '3.0', '<')) {
            $this->load->model('extension/event');
            $this->load->model('extension/extension');
            // $this->load->model('extension/module');

            $this->modelEvent = 'extension_event';
            $this->modelExtension = 'extension_extension';
            // $this->modelModule = 'extension_module';
        } else {
            $this->load->model('setting/event');
            $this->load->model('setting/extension');
            // $this->load->model('setting/module');

            $this->modelEvent = 'setting_event';
            $this->modelExtension = 'setting_extension';
            // $this->modelModule = 'setting_module';
        }
    }

    private function getTokenTitle()
    {
        if (version_compare(VERSION, '3.0', '<')) {
            $token = 'token';
        } else {
            $token = 'user_token';
        }

        return $token;
    }

    private function getModuleTitle()
    {
        if (version_compare(VERSION, '3.0', '<')) {
            $title = 'retailcrm';
        } else {
            $title = 'module_retailcrm';
        }

        return $title;
    }

    private function getCollectorTitle()
    {
        if (version_compare(VERSION, '3.0', '<')) {
            $title = 'daemon_collector';
        } else {
            $title = 'analytics_daemon_collector';
        }

        return $title;
    }
}