<?php
/***************************************************************************
 *                                                                          *
 *   (c) 2004 Vladimir V. Kalynyak, Alexey V. Vinokurov, Ilya M. Shalnev    *
 *                                                                          *
 * This  is  commercial  software,  only  users  who have purchased a valid *
 * license  and  accept  to the terms of the  License Agreement can install *
 * and use this program.                                                    *
 *                                                                          *
 ****************************************************************************
 * PLEASE READ THE FULL TEXT  OF THE SOFTWARE  LICENSE   AGREEMENT  IN  THE *
 * "copyright.txt" FILE PROVIDED WITH THIS DISTRIBUTION PACKAGE.            *
 ****************************************************************************/

use Tygh\Enum\NotificationSeverity;
use Tygh\Enum\ObjectStatuses;
use Tygh\Enum\ProductFeatures;
use Tygh\Addons\MasterProducts\ServiceProvider;
use Tygh\Enum\UserTypes;
use Tygh\Enum\YesNo;
use Tygh\Providers\StorefrontProvider;
use Tygh\Registry;
use Tygh\Tools\Url;
use Tygh\Tygh;

defined('BOOTSTRAP') or die('Access denied');

/** @var string $controller */
/** @var string $mode */
/** @var string $action */

/** @var array $auth */
$auth = Tygh::$app['session']['auth'];

if ($_SERVER['REQUEST_METHOD'] === 'POST') {
    if ($mode === 'sell_master_product') {
        $service = ServiceProvider::getService();
        $company_id = Registry::get('runtime.company_id');

        $result = $service->createVendorProduct($_REQUEST['master_product_id'], Registry::get('runtime.company_id'));

        if (!$result->isSuccess()) {
            $result->showNotifications();
            return [CONTROLLER_STATUS_NO_PAGE];
        }

        return [CONTROLLER_STATUS_OK, 'products.update?product_id=' . $result->getData('vendor_product_id')];
    }

    if ($mode === 'm_sell_master_product') {
        $service = ServiceProvider::getService();

        $updated_products = [];

        if (!empty($_REQUEST['master_product_ids'])) {
            foreach ($_REQUEST['master_product_ids'] as $master_product_id) {

                $result = $service->createVendorProduct($master_product_id, Registry::get('runtime.company_id'));

                if ($result->isSuccess() && !$result->getData('vendor_product_exists', false)) {
                    $updated_products[] = $result->getData('vendor_product_id');
                }
            }
        }

        if ($updated_products) {
            fn_set_notification(
                'N',
                __('notice'),
                __('master_products.products_were_added_to_your_products', [count($updated_products)])
            );

            unset($_REQUEST['redirect_url']);

            return [CONTROLLER_STATUS_REDIRECT, 'products.manage?' . http_build_query(['pid' => $updated_products])];
        }

        return [CONTROLLER_STATUS_REDIRECT, 'products.master_products'];
    }

    return [CONTROLLER_STATUS_OK];
}

if ($mode === 'master_products') {
    unset(Tygh::$app['session']['product_ids']);
    unset(Tygh::$app['session']['selected_fields']);

    $params = $_REQUEST;
    $params['only_short_fields'] = true;
    $params['apply_disabled_filters'] = true;
    $params['show_master_products_only'] = true;
    $params['extend'][] = 'companies';

    if (UserTypes::isVendor($auth['user_type'])) {
        $storefront_repository = StorefrontProvider::getRepository();
        /** @var array $company_storefronts */
        $company_storefronts = $storefront_repository->findAvailableForCompanyId($auth['company_id'], false) ?: [];
        $company_storefronts_ids = array_map(
            static function ($company_storefront) {
                return $company_storefront->storefront_id;
            },
            $company_storefronts
        );
        $company_storefronts_ids[] = 0;
        $categories_list = db_get_fields('SELECT category_id FROM ?:categories WHERE storefront_id IN (?n)', $company_storefronts_ids);
        if (!empty($params['cid'])) {
            $cids = is_array($params['cid']) ? $params['cid'] : explode(',', $params['cid']);
            $available_cids = array_intersect($cids, $categories_list);
            $params['cid'] = !empty($available_cids) ? $available_cids : $categories_list;
        } else {
            $params['cid'] = $categories_list;
        }
    }

    list($products, $search) = fn_get_products(
        $params,
        Registry::get('settings.Appearance.admin_elements_per_page'),
        DESCR_SL
    );
    fn_gather_additional_products_data($products, [
        'get_icon'            => true,
        'get_detailed'        => true,
        'get_options'         => false,
        'get_discounts'       => false,
        'get_vendor_products' => true
    ]);

    $page = $search['page'];
    $valid_page = db_get_valid_page($page, $search['items_per_page'], $search['total_items']);

    if ($page > $valid_page) {
        $_REQUEST['page'] = $valid_page;

        return [CONTROLLER_STATUS_REDIRECT, Registry::get('config.current_url')];
    }
    $has_select_permission = fn_check_permissions('products', 'm_sell_master_product', 'admin')
        || fn_check_permissions('products', 'export_range', 'admin');
    /** @var \Tygh\SmartyEngine\Core $view */
    $view = Tygh::$app['view'];

    $view->assign('products', $products);
    $view->assign('search', $search);
    $view->assign('has_select_permission', $has_select_permission);

    $selected_fields = fn_get_product_fields();

    $view->assign('selected_fields', $selected_fields);
    $filter_params = [
        'get_product_features' => true,
        'short'        => true,
        'feature_type' => str_split(ProductFeatures::getAllTypes()),
    ];

    if (!empty($_REQUEST['filter_variants'])) {
        $filter_params['variants_only'] = $_REQUEST['filter_variants'];
    }

    list($filters) = fn_get_product_filters($filter_params);
    $view->assign('filter_items', $filters);
    unset($filters);

    $feature_params = [
        'plain'           => true,
        'statuses'        => ['A', 'H'],
        'variants'        => true,
        'exclude_group'   => true,
        'exclude_filters' => true,
    ];

    // Preload variants selected at search form. They will be shown at AJAX variants loader as pre-selected.
    if (!empty($_REQUEST['feature_variants'])) {
        $feature_params['variants_only'] = $_REQUEST['feature_variants'];
    }

    // Action buttons: hide Export found products button, if products are not available
    if (empty($products)) {
        Registry::del('navigation.dynamic.actions.export_found_products');
    }

    list($features, $features_search) = fn_get_product_features($feature_params, PRODUCT_FEATURES_THRESHOLD);

    if ($features_search['total_items'] <= PRODUCT_FEATURES_THRESHOLD) {
        $view->assign('feature_items', $features);
    } else {
        $view->assign('feature_items_too_many', true);
    }
} elseif ($mode === 'get_products_list') {
    if (!defined('AJAX_REQUEST')) {
        return [CONTROLLER_STATUS_NO_PAGE];
    }

    /** @var \Tygh\Ajax $ajax */
    $ajax = Tygh::$app['ajax'];
    $objects = $ajax->getAssignedVar('objects', []);

    if (Registry::get('runtime.company_id')) {
        return;
    }

    foreach ($objects as $object_key => $object) {
        if (!isset($object['data']['company_id']) || (int) $object['data']['company_id'] !== 0) {
            continue;
        }

        $objects[$object_key]['data']['company_name'] = __('master_products.all_vendors_master_product');
    }
    unset($object);

    $ajax->assign('objects', $objects);
} elseif ($mode === 'recalculate_master_products_stocks') {
    if (Registry::get('addons.warehouses.status') !== ObjectStatuses::ACTIVE) {
        return [CONTROLLER_STATUS_REDIRECT, 'index.index'];
    }

    /** @var \Tygh\Database\Connection $db */
    $db = Tygh::$app['db'];

    /** @var array<array-key, string|int> $_REQUEST */
    $last_processed_master_product_id = !empty($_REQUEST['last_processed_master_product_id'])
        ? (int) $_REQUEST['last_processed_master_product_id']
        : 0;

    $limit_master_products_selection = 1000;
    $master_products_ids = $db->getColumn(
        'SELECT products.master_product_id AS master_product_id'
        . ' FROM ?:warehouses_sum_products_amount AS warehouses_sum_products_amount'
        . ' INNER JOIN ?:products AS products'
        . ' ON warehouses_sum_products_amount.product_id = products.product_id'
        . ' WHERE products.master_product_id > 0 AND products.master_product_id > ?i AND warehouses_sum_products_amount.amount > 0'
        . ' GROUP BY products.master_product_id'
        . ' ORDER BY products.master_product_id ASC'
        . ' LIMIT ?i',
        $last_processed_master_product_id,
        $limit_master_products_selection
    );

    if (
        empty($master_products_ids)
        && empty($last_processed_master_product_id)
    ) {
        fn_set_notification(
            NotificationSeverity::NOTICE,
            __('notice'),
            __('master_products.recalculate_master_products_stocks.notification.no_master_products_found')
        );
        return [CONTROLLER_STATUS_REDIRECT, 'index.index'];
    }

    if (!empty($master_products_ids)) {
        fn_master_products_recalculate_master_products_warehouses_stocks($master_products_ids);

        $db->query(
            'UPDATE ?:products SET is_stock_split_by_warehouses = ?s'
            . ' WHERE product_id IN (?n) AND is_stock_split_by_warehouses = ?s',
            YesNo::YES,
            $master_products_ids,
            YesNo::NO
        );

        $count_master_products_ids = count($master_products_ids);
        $last_processed_master_product_id = end($master_products_ids);

        if ($count_master_products_ids === $limit_master_products_selection) {
            return [
                CONTROLLER_STATUS_REDIRECT,
                Url::buildUrn(
                    ['products', 'recalculate_master_products_stocks'],
                    ['last_processed_master_product_id' => $last_processed_master_product_id]
                )
            ];
        }
    }

    fn_set_notification(
        NotificationSeverity::NOTICE,
        __('notice'),
        __('master_products.recalculate_master_products_stocks.notification.success')
    );

    return [CONTROLLER_STATUS_REDIRECT, 'index.index'];
}

if (!Registry::get('runtime.company_id') && ($mode === 'update' || $mode === 'add' || $mode === 'm_add' || $mode === 'm_update')) {
    /** @var \Tygh\SmartyEngine\Core $view */
    $view = Tygh::$app['view'];
    $view->assign('zero_company_id_name_lang_var', 'master_products.all_vendors_master_product');
}

return [CONTROLLER_STATUS_OK];
