{% extends "base.html" %}
{% from "_macros.html" import icon %}
{% from "_macros_ui.html" import empty_state, task_status_badge, task_status_text %}
{% block title %}Планировщик — TG Agent{% endblock %}
{% block content %}
<h1>Планировщик</h1>

{% macro task_type_label(t) %}
    {% if t.task_type.value == 'channel_collect' %}Сбор канала
    {% elif t.task_type.value == 'stats_all' %}Статистика
    {% elif t.task_type.value == 'sq_stats' %}Статистика запроса
    {% elif t.task_type.value == 'photo_due' %}Фото
    {% elif t.task_type.value == 'photo_auto' %}Автофото
    {% else %}{{ t.task_type.value }}
    {% endif %}
{% endmacro %}

{#
  Preserve user's filter/page/limit on every POST — the route handlers read
  these via request.query_params and echo them in the redirect Location.
  Fix for #457 round 3: clicking "Запустить" used to reset the page to the
  default `status=all` (all 7000+ tasks, 143 pages) even if the user was on
  `status=active`.
#}
{% set _q_parts = [] %}
{% if status_filter and status_filter != 'all' %}{% set _ = _q_parts.append('status=' ~ status_filter) %}{% endif %}
{% if page and page != 1 %}{% set _ = _q_parts.append('page=' ~ page) %}{% endif %}
{% if limit and limit != 50 %}{% set _ = _q_parts.append('limit=' ~ limit) %}{% endif %}
{% set filter_qs = ('?' ~ _q_parts|join('&')) if _q_parts else '' %}

<div class="card mb-4">
    <div class="card-header fw-semibold">
        Планировщик
        <span class="hint" data-tooltip="Планировщик автоматически ставит задачи в очередь: сбор, статистику">?</span>
    </div>
    <div class="card-body">
        <small class="text-muted d-block mb-2">Автоматическое создание задач: сбор каждые {{ interval_minutes }} мин.</small>
        <p>Статус: <strong>{{ "Запущен" if is_running else "Остановлен" }}</strong></p>

        <div class="d-flex flex-wrap gap-2">
            {% if not is_running %}
            <form method="post" action="/scheduler/start{{ filter_qs }}" data-busy>
                <button type="submit" class="btn btn-primary">{{ icon("run") }} Запустить</button>
            </form>
            {% else %}
            <form method="post" action="/scheduler/stop{{ filter_qs }}" data-busy>
                <button type="submit" class="btn btn-secondary">&#9724; Остановить</button>
            </form>
            {% endif %}
            <form method="post" action="/scheduler/trigger{{ filter_qs }}" data-busy>
                <button type="submit" class="btn btn-outline-primary">{{ icon("run") }} Собрать все каналы</button>
            </form>
            {% if pending_collect_count > 0 %}
            <form method="post" action="/scheduler/tasks/clear-pending-collect{{ filter_qs }}" data-busy>
                <button type="submit" class="btn btn-outline-danger">
                    Очистить очередь загрузки ({{ pending_collect_count }})
                </button>
            </form>
            {% endif %}
            <form method="post" action="/scheduler/test-notification{{ filter_qs }}" data-busy>
                <button type="submit" class="btn btn-outline-secondary"
                        {% if not bot_configured %}disabled title="Подключите бот в Настройках → Уведомления"{% endif %}>
                    Тест
                </button>
            </form>
            <button type="button" class="btn btn-outline-info"
                    onclick="dryRunNotifications()"
                    id="dry-run-btn">
                Dry-run
            </button>
        </div>
    </div>
</div>

{% if collector_health.state != 'healthy' or collector_health.load_level != 'ok' %}
<div class="card mb-4 border-{% if collector_health.state in ['worker_down', 'all_flooded', 'no_clients'] or collector_health.load_level == 'overload' %}danger{% else %}warning{% endif %}">
    <div class="card-header fw-semibold">
        Здоровье коллектора
        {% if collector_health.state == 'worker_down' %}
        <span class="badge text-bg-danger ms-2">Telegram-воркер не запущен</span>
        {% elif collector_health.state == 'all_flooded' %}
        <span class="badge text-bg-danger ms-2">Все аккаунты во Flood Wait</span>
        {% elif collector_health.state == 'no_clients' %}
        <span class="badge text-bg-danger ms-2">Нет доступных клиентов</span>
        {% elif collector_health.state == 'degraded' %}
        <span class="badge text-bg-warning ms-2">Частичная деградация</span>
        {% endif %}
        {% if collector_health.load_level == 'overload' %}
        <span class="badge text-bg-danger ms-1">Перегрузка</span>
        {% elif collector_health.load_level == 'high' %}
        <span class="badge text-bg-warning ms-1">Высокая нагрузка</span>
        {% endif %}
    </div>
    <div class="card-body">
        <div class="row g-3 mb-3">
            <div class="col-6 col-md-3">
                <div class="small text-muted">Аккаунты</div>
                <div><strong>{{ collector_health.available_accounts_now }}</strong> доступно сейчас</div>
                <div><strong>{{ collector_health.connected_accounts }}</strong> подключено</div>
            </div>
            <div class="col-6 col-md-3">
                <div class="small text-muted">Flood Wait</div>
                <div><strong>{{ collector_health.flooded_accounts_count }}</strong> заблокировано</div>
                {% if collector_health.next_available_label %}
                {% set _secs = collector_health.retry_after_sec %}
                <div class="small">Раньше всего: {{ collector_health.next_available_label }}
                  {%- if _secs and _secs >= 60 %}
                    {% set _h = (_secs // 3600) | int %}
                    {% set _m = ((_secs % 3600) // 60) | int %}
                    ({% if _h > 0 %}{{ _h }} ч {% endif %}{{ _m }} мин)
                  {%- endif %}
                </div>
                {% endif %}
            </div>
            <div class="col-6 col-md-3">
                <div class="small text-muted">Нагрузка</div>
                <div><strong>{{ collector_health.active_unfiltered_channels }}</strong> активных каналов</div>
                <div class="small">Интервал: {{ collector_health.collect_interval_minutes }} мин</div>
            </div>
            <div class="col-6 col-md-3">
                <div class="small text-muted">Симптом</div>
                <div><strong>{{ collector_health.recent_zero_collect_count }}</strong> недавних задач с нулевым результатом</div>
                <div class="small">{% if collector_health.is_running %}Коллектор занят{% else %}Коллектор ждёт{% endif %}</div>
            </div>
        </div>

        {% if collector_health.state == 'worker_down' %}
        <p class="mb-2"><strong>Почему сейчас не собираем:</strong> веб-процесс принимает задачи и пишет их в БД, но Telegram-коннекты держит отдельный воркер-процесс — он сейчас не запущен (нет свежего heartbeat в <code>runtime_snapshots</code>). Задачи из <code>collection_tasks</code> копятся в статусе <em>pending</em>, но никто их не исполняет.</p>
        <p class="mb-2"><strong>Как починить:</strong> запустите воркер во втором терминале — он подхватит все накопившиеся задачи автоматически:</p>
        <pre class="mb-2"><code>python -m src.main worker</code></pre>
        {% endif %}

        {% if collector_health.flooded_accounts %}
        <p class="mb-2"><strong>Почему сейчас не собираем:</strong> доступных аккаунтов нет или их недостаточно. Flood Wait активен для:
        {% for item in collector_health.flooded_accounts %}
            <code>{{ item.phone }}</code>{% if not loop.last %}, {% endif %}
        {% endfor %}
        </p>
        {% endif %}

        {% if collector_health.recommendations %}
        <p class="mb-1"><strong>Что делать:</strong></p>
        <ul class="mb-2">
            {% for item in collector_health.recommendations %}
            <li>{{ item }}</li>
            {% endfor %}
        </ul>
        {% endif %}

        {% if collector_health.recent_unavailability_events %}
        <p class="mb-1"><strong>Последние причины недоступности:</strong></p>
        <ul class="mb-0">
            {% for item in collector_health.recent_unavailability_events %}
            <li><small>{{ item }}</small></li>
            {% endfor %}
        </ul>
        {% endif %}
    </div>
</div>
{% endif %}

<!-- Scheduler Jobs -->
{% if scheduler_jobs %}
<div class="card mb-4">
    <div class="card-header fw-semibold">
        Джобы планировщика
        <span class="badge text-bg-secondary ms-1">{{ scheduler_jobs|length }}</span>
        {% if not is_running %}
        <small class="text-muted ms-2">(будут зарегистрированы при запуске)</small>
        {% endif %}
    </div>
    <div class="card-body p-0">
        <div class="table-responsive">
        <table class="tga-table-striped mb-0">
            <thead>
                <tr>
                    <th>Вкл.</th>
                    <th>Джоб</th>
                    <th>Интервал</th>
                    <th>Следующий запуск</th>
                </tr>
            </thead>
            <tbody>
                {% for j in scheduler_jobs %}
                <tr>
                    <td>
                        <form method="post" action="/scheduler/jobs/{{ j.job_id }}/toggle{{ filter_qs }}" class="mb-0">
                            <input type="checkbox" onchange="this.form.submit()"
                                   {% if j.enabled %}checked{% endif %}
                                   title="{{ 'Отключить' if j.enabled else 'Включить' }}">
                        </form>
                    </td>
                    <td class="{% if not j.enabled %}text-muted{% endif %}">{{ j.label }}</td>
                    <td>
                        {% if j.interval_editable and j.interval_minutes is not none %}
                            <form method="post" action="/scheduler/jobs/{{ j.job_id }}/set-interval{{ filter_qs }}"
                                  class="d-flex gap-1 mb-0">
                                <input type="number" name="interval_minutes" value="{{ j.interval_minutes }}"
                                       min="1" max="1440" class="form-control form-control-sm" style="width:75px">
                                <button type="submit" class="btn btn-sm btn-outline-secondary">{{ icon("save") }}</button>
                            </form>
                        {% elif j.interval_minutes %}
                            {{ j.interval_minutes }} мин.
                        {% else %}
                            —
                        {% endif %}
                    </td>
                    <td>
                        {% if j.next_run %}
                            {{ j.next_run|local_dt("time") }}
                        {% elif is_running and j.enabled %}
                            —
                        {% elif not j.enabled %}
                            <span class="text-muted">отключён</span>
                        {% else %}
                            <span class="text-muted">остановлен</span>
                        {% endif %}
                    </td>
                </tr>
                {% endfor %}
            </tbody>
        </table>
        </div>
    </div>
</div>
{% endif %}

<!-- Dry-run results (populated via fetch) -->
<div id="dry-run-results" class="mb-4" style="display:none"></div>

{% if search_log %}
<div class="card mb-4">
    <div class="card-header fw-semibold">
        Лог поиска
        <span class="hint" data-tooltip="Последние результаты поиска: какой запрос, сколько найдено, каким аккаунтом">?</span>
    </div>
    <div class="card-body p-0">
        <!-- Desktop -->
        <div class="table-responsive d-none d-md-block">
        <table class="tga-table-striped mb-0">
            <thead>
                <tr>
                    <th>Запрос</th>
                    <th>Аккаунт</th>
                    <th>Результатов</th>
                    <th>Дата</th>
                </tr>
            </thead>
            <tbody>
                {% for entry in search_log %}
                <tr>
                    <td>{{ entry.query }}</td>
                    <td>{{ entry.phone }}</td>
                    <td>{{ entry.results_count }}</td>
                    <td>{{ entry.created_at|local_dt }}</td>
                </tr>
                {% endfor %}
            </tbody>
        </table>
        </div>
        <!-- Mobile -->
        <div class="d-md-none mobile-cards p-2">
            {% for entry in search_log %}
            <div class="card mb-2">
                <div class="card-body">
                    <div class="d-flex justify-content-between">
                        <strong class="text-truncate">{{ entry.query }}</strong>
                        <span class="badge text-bg-secondary">{{ entry.results_count }}</span>
                    </div>
                    <small class="text-muted">{{ entry.phone }} &middot; {{ entry.created_at|local_dt }}</small>
                </div>
            </div>
            {% endfor %}
        </div>
    </div>
</div>
{% endif %}

{% if all_count > 0 %}
<div class="card mb-4">
    <div class="card-header fw-semibold">Задачи</div>
    <div class="card-body p-0">
        <p class="px-3 pt-3"><small class="text-muted">Все задачи: сбор каналов, статистика, фото.</small></p>

        <!-- Filter tabs -->
        <div class="px-3 pb-2">
            <div class="btn-group" role="tablist">
                <a href="/scheduler?status=all&page=1&limit={{ limit }}" class="btn btn-sm {% if status_filter == 'all' %}btn-primary{% else %}btn-outline-primary{% endif %}">
                    Все ({{ all_count }})
                </a>
                <a href="/scheduler?status=active&page=1&limit={{ limit }}" class="btn btn-sm {% if status_filter == 'active' %}btn-primary{% else %}btn-outline-primary{% endif %}">
                    Активные ({{ active_count }})
                </a>
                <a href="/scheduler?status=completed&page=1&limit={{ limit }}" class="btn btn-sm {% if status_filter == 'completed' %}btn-primary{% else %}btn-outline-primary{% endif %}">
                    Завершенные ({{ completed_count }})
                </a>
            </div>
        </div>

        {% if tasks %}
        <!-- Desktop -->
        <div class="table-responsive d-none d-md-block">
        <table class="tga-table-striped mb-0">
            <thead>
                <tr>
                    <th>Тип</th>
                    <th>Канал / Описание</th>
                    <th>Статус</th>
                    <th>{{ result_column_title }}</th>
                    <th>Создана</th>
                    <th>Завершена</th>
                    <th>Действие</th>
                </tr>
            </thead>
            <tbody>
                {% for t in tasks %}
                <tr>
                    <td><span class="badge text-bg-info">{{ task_type_label(t) }}</span></td>
                    <td>
                        {{ t.channel_title or t.channel_id or '—' }}
                        {% if t.channel_username %}
                        <br><small class="text-muted">@{{ t.channel_username }}</small>
                        {% endif %}
                    </td>
                    <td>
                        {{ task_status_text(t) }}
                    </td>
                    <td>
                        {% set pipeline_meta = pipeline_result_meta.get(t.id) if pipeline_result_meta else None %}
                        {% if t.task_type == 'stats_all' and t.payload and t.payload.channel_ids %}
                            {{ t.messages_collected }}/{{ t.payload.channel_ids|length }}
                        {% elif t.task_type.value == 'pipeline_run' and pipeline_meta %}
                            <small class="text-muted d-block">{{ pipeline_meta.label }}</small>
                            {{ pipeline_meta.count }}
                            {% if pipeline_meta.errors_count %}
                                <span class="badge text-bg-warning pipe-run-warning ms-1"
                                      title="{{ pipeline_meta.first_error_detail or '' }}">⚠ {{ pipeline_meta.errors_count }}</span>
                            {% endif %}
                        {% else %}
                            {{ t.messages_collected }}
                        {% endif %}
                    </td>
                    <td>{{ t.created_at|local_dt }}</td>
                    <td>{{ t.completed_at|local_dt }}</td>
                    <td>
                        {% if t.status == 'running' %}
                            <form method="post" action="/scheduler/tasks/{{ t.id }}/cancel{{ filter_qs }}" class="mb-0" data-busy>
                                <button type="submit" class="btn btn-outline-secondary btn-sm">Отменить</button>
                            </form>
                        {% elif t.status == 'pending' %}
                            <form method="post" action="/scheduler/tasks/{{ t.id }}/cancel{{ filter_qs }}" class="mb-0" data-busy>
                                <button type="submit" class="btn btn-outline-secondary btn-sm">Удалить</button>
                            </form>
                        {% endif %}
                    </td>
                </tr>
                {% endfor %}
            </tbody>
        </table>
        </div>
        <!-- Mobile -->
        <div class="d-md-none mobile-cards p-2">
            {% for t in tasks %}
            <div class="card mb-2">
                <div class="card-body">
                    <div class="d-flex justify-content-between align-items-start mb-1">
                        <div>
                            <span class="badge text-bg-info me-1">{{ task_type_label(t) }}</span>
                            <strong>{{ t.channel_title or t.channel_id or '—' }}</strong>
                            {% if t.channel_username %}<br><small class="text-muted">@{{ t.channel_username }}</small>{% endif %}
                        </div>
                        <span>
                            {{ task_status_badge(t) }}
                        </span>
                    </div>
                    <small class="text-muted">
                        {% set pipeline_meta = pipeline_result_meta.get(t.id) if pipeline_result_meta else None %}
                        {% if t.task_type == 'stats_all' and t.payload and t.payload.channel_ids %}
                            {{ t.messages_collected }}/{{ t.payload.channel_ids|length }}
                        {% elif t.task_type.value == 'pipeline_run' and pipeline_meta %}
                            {{ pipeline_meta.label }}: {{ pipeline_meta.count }}
                            {% if pipeline_meta.errors_count %}
                                <span class="badge text-bg-warning pipe-run-warning ms-1"
                                      title="{{ pipeline_meta.first_error_detail or '' }}">⚠ {{ pipeline_meta.errors_count }}</span>
                            {% endif %}
                        {% else %}
                            {{ t.messages_collected }} сообщ.
                        {% endif %}
                        {% if t.created_at %}&middot; {{ t.created_at|local_dt }}{% endif %}
                    </small>
                    {% if t.status == 'running' or t.status == 'pending' %}
                    <div class="mt-1">
                        <form method="post" action="/scheduler/tasks/{{ t.id }}/cancel{{ filter_qs }}" class="mb-0" data-busy>
                            <button type="submit" class="btn btn-outline-secondary btn-sm">{{ 'Отменить' if t.status == 'running' else 'Удалить' }}</button>
                        </form>
                    </div>
                    {% endif %}
                </div>
            </div>
            {% endfor %}
        </div>

        <!-- Pagination -->
        {% if total_pages > 1 %}
        <nav>
            <ul class="pagination justify-content-center mb-0">
                {% if page > 1 %}
                <li class="page-item"><a class="page-link" href="/scheduler?status={{ status_filter }}&page={{ page - 1 }}&limit={{ limit }}">Назад</a></li>
                {% endif %}
                <li class="page-item disabled"><span class="page-link">Страница {{ page }} из {{ total_pages }}</span></li>
                {% if page < total_pages %}
                <li class="page-item"><a class="page-link" href="/scheduler?status={{ status_filter }}&page={{ page + 1 }}&limit={{ limit }}">Далее</a></li>
                {% endif %}
            </ul>
        </nav>
        {% endif %}
        {% else %}
        {{ empty_state("Нет задач с выбранным фильтром.") }}
        {% endif %}
    </div>
</div>
{% endif %}

<script>
{% if has_active_tasks %}
setTimeout(function() {
    window.location.reload();
}, 5000);
{% endif %}

function dryRunNotifications() {
    var btn = document.getElementById('dry-run-btn');
    var container = document.getElementById('dry-run-results');
    setAsyncButtonBusy(btn, true, 'Dry-run');
    fetch('/scheduler/dry-run-notifications', {method: 'POST'})
        .then(function(r) { return r.text(); })
        .then(function(html) {
            container.innerHTML = html;
            container.style.display = '';
        })
        .catch(function() {
            container.innerHTML = '<div class="alert alert-danger">Ошибка при выполнении dry-run</div>';
            container.style.display = '';
        })
        .finally(function() {
            setAsyncButtonBusy(btn, false);
        });
}
</script>
{% endblock %}