<?php

declare(strict_types=1);

namespace GerSync\Import;

defined('ABSPATH') || exit;

use WC_Product;
use WC_Product_Variable;
use GerSync\Log;
use GerSync\Repo;
use GerSync\Settings;

/**
 * Товары из 1С, которых нет в полной выгрузке каталога.
 *
 * Запускается в фоне (Action Scheduler WooCommerce), когда 1С сообщила об окончании обмена
 * (mode=deactivate / complete), либо через 15 минут после последнего полного файла — для конфигураций,
 * которые этих сигналов не присылают. Обработка идёт порциями, чтобы не упираться в лимиты хостинга.
 *
 * Защита: если «пропавших» больше половины товаров из 1С — скорее всего обмен оборвался или пришёл
 * не весь каталог, поэтому ничего не делаем и пишем предупреждение в журнал.
 */
final class Missing
{
    public const HOOK  = 'gersync_process_missing';
    public const GROUP = 'gersync';
    private const BATCH = 100;
    private const DELAY = 15 * MINUTE_IN_SECONDS;

    private const SAFETY_SHARE = 0.5;

    /** «Уже обработан в этом сеансе» — чтобы следующая порция его не выбрала. */
    private const DONE_META = '_gersync_missing_done';

    public static function register(): void
    {
        add_action(self::HOOK, [self::class, 'run'], 10, 1);
    }

    /**
     * Поставить обработку в очередь. $now = true — 1С сообщила, что обмен закончен.
     */
    public static function schedule(bool $now): void
    {
        if (!function_exists('as_schedule_single_action') || Settings::str('missing_action') === 'none') {
            return;
        }
        $session = Session::get();
        if (!Session::isFull() || $session['swept']) {
            return;
        }
        as_unschedule_all_actions(self::HOOK, [], self::GROUP);
        as_schedule_single_action(time() + ($now ? 0 : self::DELAY), self::HOOK, [$session['id']], self::GROUP);
    }

    public static function cancel(): void
    {
        if (function_exists('as_unschedule_all_actions')) {
            as_unschedule_all_actions(self::HOOK, [], self::GROUP);
        }
    }

    /**
     * Один проход. Если осталось ещё — ставит следующий.
     */
    public static function run(int $sessionId): void
    {
        $session = Session::get();
        $action  = Settings::str('missing_action');

        // Начался новый обмен, выгрузка не полная или уже обработано — ничего не делаем.
        if ($session['id'] !== $sessionId || !Session::isFull() || $session['swept'] || $action === 'none') {
            return;
        }

        if (!isset($session['checked'])) {
            $total   = self::count(false, $sessionId);
            $missing = self::count(true, $sessionId);
            if ($missing > 0 && $missing > $total * self::SAFETY_SHARE) {
                Log::warning(sprintf(
                    'Полная выгрузка: нет %d из %d товаров 1С — больше половины. Похоже, каталог пришёл не целиком; товары не тронуты.',
                    $missing,
                    $total
                ));
                Session::markSwept();
                return;
            }
            Session::markChecked();
            Log::debug(sprintf('Полная выгрузка: товаров, которых нет в выгрузке, — %d', $missing));
        }

        $ids = self::missingIds($sessionId, self::BATCH);
        foreach ($ids as $id) {
            $product = wc_get_product($id);
            if ($product instanceof WC_Product) {
                self::apply($product, $action);
            }
            update_post_meta($id, self::DONE_META, $sessionId);
        }

        if (count($ids) === self::BATCH) {
            as_schedule_single_action(time(), self::HOOK, [$sessionId], self::GROUP);
        } else {
            Session::markSwept();
            Log::debug('Полная выгрузка: обработка отсутствующих товаров завершена');
        }
    }

    private static function apply(WC_Product $product, string $action): void
    {
        if ($action === 'outofstock') {
            $targets = $product instanceof WC_Product_Variable
                ? array_filter(array_map('wc_get_product', $product->get_children()))
                : [$product];
            foreach ($targets as $target) {
                if ($target->get_manage_stock()) {
                    $target->set_stock_quantity(0);
                }
                $target->set_stock_status('outofstock');
                $target->save();
            }
            if ($product instanceof WC_Product_Variable) {
                WC_Product_Variable::sync($product->get_id());
            }
            Log::debug('Нет в полной выгрузке → нет в наличии: #' . $product->get_id());
            return;
        }

        // draft / trash — как пометка удаления: товар вернётся, когда снова придёт из 1С.
        Lifecycle::hide($product, $action);
    }

    /**
     * Опубликованные товары из 1С (с GUID, в том числе от прежнего плагина), которых не было в этом сеансе.
     *
     * Сравнение идёт по значению GUID, а не по ID: у переводов Polylang/WPML тот же GUID,
     * но обновляется (и отмечается) только товар основного языка — переводы не должны считаться пропавшими.
     *
     * @return list<int>
     */
    private static function missingIds(int $sessionId, int $limit): array
    {
        global $wpdb;
        $id = (string) $sessionId;
        // phpcs:ignore WordPress.DB.DirectDatabaseQuery.DirectQuery, WordPress.DB.DirectDatabaseQuery.NoCaching -- выборка во время обмена, кеш неуместен
        $ids = $wpdb->get_col($wpdb->prepare(
            "SELECT DISTINCT p.ID FROM {$wpdb->posts} p
             INNER JOIN {$wpdb->postmeta} g ON g.post_id = p.ID AND g.meta_key IN (%s, %s)
             LEFT JOIN {$wpdb->postmeta} d ON d.post_id = p.ID AND d.meta_key = %s AND d.meta_value = %s
             WHERE p.post_type = 'product' AND p.post_status IN ('publish', 'pending', 'private')
               AND d.post_id IS NULL
               AND NOT EXISTS (
                 SELECT 1 FROM {$wpdb->postmeta} g2
                 INNER JOIN {$wpdb->postmeta} s2 ON s2.post_id = g2.post_id AND s2.meta_key = %s AND s2.meta_value = %s
                 WHERE g2.meta_key IN (%s, %s) AND g2.meta_value = g.meta_value
               )
             ORDER BY p.ID ASC LIMIT %d",
            Repo::META,
            Repo::LEGACY_META,
            self::DONE_META,
            $id,
            Session::SEEN_META,
            $id,
            Repo::META,
            Repo::LEGACY_META,
            $limit
        ));
        return array_map('intval', $ids);
    }

    private static function count(bool $missingOnly, int $sessionId): int
    {
        if ($missingOnly) {
            return count(self::missingIds($sessionId, PHP_INT_MAX));
        }
        global $wpdb;
        // phpcs:ignore WordPress.DB.DirectDatabaseQuery.DirectQuery, WordPress.DB.DirectDatabaseQuery.NoCaching -- выборка во время обмена, кеш неуместен
        return (int) $wpdb->get_var($wpdb->prepare(
            "SELECT COUNT(DISTINCT p.ID) FROM {$wpdb->posts} p
             INNER JOIN {$wpdb->postmeta} g ON g.post_id = p.ID AND g.meta_key IN (%s, %s)
             WHERE p.post_type = 'product' AND p.post_status IN ('publish', 'pending', 'private')",
            Repo::META,
            Repo::LEGACY_META
        ));
    }
}