chore: save working baseline before v3.0 architecture refactoring

data/static_reason_workers.csv

@@ -11,4 +11,3 @@ fio,reason,note
 Ковалев Владимир Владимирович,Удаленная работа,Постоянная удаленка
 Кожокарь Татьяна Юрьевна,Удаленная работа,Постоянная удаленка
 Субетто Юлия Викторовна,Удаленная работа,Постоянная удаленка
-Ароян Станислав Месропович,Удаленная работа,Временная удаленка

docs/CHANGELOG.md

@@ -0,0 +1,82 @@
+# 📋 История изменений (CHANGELOG)
+
+Все ключевые изменения архитектуры, инструментов и модулей проекта SCUD Orion AI фиксируются в данном файле[cite: 6].
+
+---
+
+## [2026-08-19] — Инлайн-редактор задач, интеллектуальный ContextManager и стабилизация Function Calling
+
+### ✨ Добавлено
+* **Инлайн-редактирование задач (`task_widget.js` / `tasks.py`)**:
+  - Добавлена кнопка редактирования (`✏️`) на каждой карточке задачи.
+  - Карточка трансформируется в инлайн-форму с тремя полями: текст задачи, HTML5-пикер календаря планируемого срока и выпадающий список важности (`LOW`, `MEDIUM`, `HIGH`, `CRITICAL`).
+  - Добавлен REST API эндпоинт `PATCH /api/v1/tasks/{task_id}` с поддержкой комплексного обновления полей в SQLite.
+  - В карточки выведено отображение даты создания задачи.
+* **Интеллектуальный ContextManager (`context_manager.py`)**:
+  - Служебные запросы и карточки инструментов сохраняются синхронными парами (`is_ephemeral = 1`) и атомарно удаляются при завершении операций.
+  - Свободные диалоги оператора (включая темы Topic Drift) сохраняются в постоянную историю (`is_ephemeral = 0`) и не стираются при закрытии сессий промпта/задач.
+* **Поддержка Y-снапшотов (`db_snapshots.py`)**:
+  - Исправлен SQL-запрос `db_get_snapshots` для точного извлечения ночных и фоновых срезов с префиксом `Y` (например, `Y20260817-003`).
+
+### 🔧 Изменено
+* **`modules/web_api/llm/agent.py`**:
+  - Полностью удалены эвристические текстовые фильтры и принудительные сортировки инструментов.
+  - Настроен нативный возврат и исполнение инструментов без зацикливания модели.
+  - Устранена ошибка `UnboundLocalError` при вызове справочных инструментов.
+* **`modules/web_api/llm/schemas.py`**:
+  - Очищены описания инструментов от агрессивных директив и капса, стабилизирована селективность Function Calling для Qwen 2.5.
+* **`modules/web_api/llm/core/ollama_client.py`**:
+  - Оптимизированы параметры генерации для Function Calling (`repeat_penalty: 1.0`, `presence_penalty: 0.0`, `temperature: 0.0`), что исключило спам несколькими вызовами инструментов на один запрос.
+* **`modules/web_api/static/js/chat/task_widget.js`**:
+  - Фильтр по умолчанию переведен на вкладку **«В работе»** (`IN_PROGRESS`).
+
+---
+
+## [2026-08-18] — Двухфазный жизненный цикл сессий, двусторонний Diff и Topic Drift Guard
+
+### ✨ Добавлено
+* **Двусторонний клиентский Diff (`core.js`)**: Реализован алгоритм сравнения черновика с baseline-промптом. Удаленные строки остаются на экране с красным зачеркиванием `[УДАЛЕНИЕ]`, а добавленные/измененные строки выделяются красной рамкой с авто-отступами.
+* **Topic Drift Guard (`agent.py`)**: Внедрен двухуровневый контроль смены темы:
+  - Мгновенный сброс стейта и зачистка эфемерных сообщений при вызове сторонних инструментов (задачи, снапшоты, база).
+  - Мягкий счетчик отвлечений (`idle_turns` = 3) в свободном диалоге с выводом напоминания и кнопок из `tool_action_registry`.
+* **Команда `context purge` в CLI (`db_cli.py`)**: Добавлен флаг `--all` для полной очистки таблицы `chat_messages` и сброса стейтов сессий.
+
+### 🔧 Изменено
+* **`modules/web_api/llm/agent.py`**: 
+  - Прямой просмотр промпта (`db_get_system_prompt`) переведен в прозрачный режим без блокировки строки ввода и без лишних кнопок.
+  - В инструмент `db_prompt_node_edit` добавлена передача исходного `baseline_prompt` для точного сопоставления правок в UI.
+* **`modules/web_api/llm/core/fast_path.py`**: Оптимизирована зачистка эфемерных сообщений при кликах на кнопки фазы follow-up.
+
+---
+
+## [2026-08-17] — Внедрение CLI-инспекции контекста и переход на нативный Function Calling
+
+### ✨ Добавлено
+* **`scripts/db_cli.py`**: Добавлена команда `context` для инспекции истории сообщений `chat_messages` по сессиям с визуальным отображением флагов `[ЭФЕМЕРНОЕ]`[cite: 6].
+* **`ROADMAP.md`**: Сформирована актуальная дорожная карта с планом отказа от регулярных выражений в пользу нативного Function Calling[cite: 6].
+
+### 🔧 Изменено
+* **`modules/web_api/llm/db_tools.py`**: Удалены устаревшие неиспользуемые функции и заглушки счетчиков простоя[cite: 6].
+* **`modules/web_api/static/js/chat/core.js`**: Внедрена поддержка вызова инлайн-редактора черновика промпта прямо из окна диалога[cite: 6].
+
+---
+
+## [2026-08-15] — Реляционная архитектура системного промпта
+
+### ✨ Добавлено
+* **`system_prompt_nodes`**: Создана таблица реляционных узлов промпта с индексацией по разделам и пунктам (`section_id`, `item_id`)[cite: 6].
+* **`db_prompt_node_edit`**: Добавлен инструмент точечного добавления, изменения и удаления пунктов системного промпта[cite: 6].
+* **Инлайн-редактор**: Добавлен визуальный diff-просмотр изменений с подсветкой и кнопкой `[✏️ Редактировать]`[cite: 6].
+
+### 🔧 Изменено
+* **`modules/web_api/llm/agent.py`**: Генерация активного системного промпта переведена на динамическую сборку из реляционных узлов SQLite[cite: 6].
+* **`modules/web_api/llm/core/fast_path.py`**: Обработка кнопок «Подтвердить» и «Отменить» переведена на атомарную запись узлов в базу данных[cite: 6].
+
+---
+
+## [2026-08-10] — Механизм эфемерных сообщений и очистки диалога
+
+### ✨ Добавлено
+* **Эфемерные сообщения (`is_ephemeral`)**: Маркировка временных сервисных ответов и черновиков[cite: 6].
+* **`db_purge_ephemeral_messages`**: Механизм физической зачистки временных записей из SQLite при завершении операций[cite: 6].
+* **Интерактивные виджеты**: Поддержка карточек задач (`TASK_INTERACTIVE_CARD`) с кнопками быстрого действия[cite: 6].

docs/PROJECT BRAIN_ SCUD Orion AI & Context API (Master Manifesto v5.0).md

@@ -0,0 +1,185 @@
+# **PROJECT BRAIN: SCUD Orion AI & Context API (Master Technical & Architectural Manifesto)**
+
+**Версия документа:** 5.0 (Ultimate Developer & LLM Context Engine)  
+**Назначение:** Исчерпывающий контекстный дамп проекта для немедленного продолжения разработки в любой передовой LLM без потери исторического контекста, с полным пониманием бизнес-логики, схем баз данных, подводных камней и нерешенных задач.
+
+## ---
+
+**1\. Архитектурный паспорт и инфраструктурный профиль**
+
+| Компонент | Параметры и стек |
+| :---- | :---- |
+| **Среда и ОС** | Linux Docker Home (Debian/Ubuntu), Python 3.11/3.12 в виртуальном окружении venv, Git/Gitea. Разработка ведется через VS Code Remote-SSH. |
+| **Локальная СУБД проекта** | SQLite (data/scud\_orion\_ai.db), режим PRAGMA journal\_mode \= WAL, PRAGMA synchronous \= NORMAL, PRAGMA foreign\_keys \= ON. |
+| **СКУД Источник (MSSQL)** | MS SQL Server 172.16.31.221\\SQL (база Orion-14.01.21-1), драйвер ODBC Driver 18 for SQL Server (TrustServerCertificate=yes, Encrypt=no). Доступ через pyodbc. |
+| **1С:ЗУП 3.1 Источник (MSSQL)** | MS SQL Server ACCOUNT-01 (база ZUP30, пользователь scud\_reader). Прямое чтение таблиц dbo.\_Reference299 (сотрудники) и dbo.\_InfoRg16921 (состояния отсутствий). Резервная Samba-шара: /mnt/scud\_share. |
+| **Локальный контур LLM** | Ollama на http://192.168.11.3:11434 (GPU NVIDIA RTX 5070 Ti 16GB). Модель qwen2.5:14b (основной агент, Function Calling, анализ аномалий), qwen2.5vl:7b-q8\_0 (OCR документов/картинок). |
+| **Web API & Фронтенд** | FastAPI (Uvicorn), JWT (HS256, 30 дней), Passlib (bcrypt). Фронтенд: Single Page Application (HTML5, Tailwind CSS, Vanilla JS) с Generative UI виджетами. |
+
+## ---
+
+**2\. Энциклопедия подводных камней, инцидентов и принятых инженерных решений**
+
+### **2.1. Галлюцинации LLM и переход к парадигме Python-Driven Diff**
+
+> * **Проблема:** Попытка передать списки в 300 ФИО напрямую в промпт модели с командой «сравни списки» приводила к потере контекста, выдуманным опечаткам (*«ЛЕНМОРНИИПРОЕКТ ОЭС Варламова Мария»*) и плейсхолдерам ('Васильев Л.И.', ...).  
+> * **Решение:** Утверждена строгая гибридная схема:  
+  1. **Детерминированный слой (Python / Pandas / SQL):** читает файлы, нормализует строки, агрегирует совмещения и мгновенно находит 95%+ точных соответствий.  
+  2. **Интеллектуальный слой (Qwen 2.5:14b):** вызывается *только на спорный несовпавший остаток* (1–5 записей) в виде строгого JSON-интерфейса Entity Resolution.
+
+### **2.2. Символьная нормализация и кадровые совмещения (Кейс Балаевой О.Г.)**
+
+> * **Проблема символов:** Латинские омоглифы (буквы клавиатуры a, c, e, o, p, x, y вместо русских), разделители 1С в скобках ((осн.), (совм.), (внешн.)), неразрывные пробелы \\xa0, буква ё и случайный ввод цифры 0 вместо буквы О.  
+> * **Решение (normalize\_fio):** Очистка скобок через регулярное выражение re.sub(r'\\(.\*?\\)', '', fio), замена латиницы через str.maketrans('aceopxyABCEHKMOPTX', 'асеорхуАВСЕНКМОРТХ'), замена ё-\>е и удаление лишних пробелов.  
+> * **Коллизия 270 vs 271:** В СКУД 270 физических лиц (один пропуск на человека), в 1С — 271 строка. Сотрудник **Балаева Ольга Геннадьевна** числится на двух ставках в разных отделах (*Руководитель управления персоналом* и *Руководитель режимно-секретного отдела*).  
+> * **Решение:** Внедрена группировка датафрейма 1С по fio\_clean с агрегацией должностей и подразделений через разделитель " / ".
+
+### **2.3. Защита от коллизий полных тёзок и ложных связок однофамильцев (Кейс Семеновых)**
+
+> * **Инцидент:** Неограниченная строгими правилами LLM связала двух разных сотрудниц — *«Семенову Юлию Борисовну»* (работает) и *«Семенову Дину Дмитриевну»* (в отпуске), посчитав разные имена опечаткой из\-за одинаковой фамилии. В результате Юлии Борисовне ошибочно был приписан статус отпуска.  
+> * **Двухконтурный барьер:**  
+  1. **В промпте:** Запрет объединения однофамильцев с разными именами/отчествами.  
+  2. **В Python:** Проверка совпадения первых букв имени и отчества. При несовпадении сопоставление ИИ аннулируется с логированием ⚠️ \[Блокировка фейка\].
+
+### **2.4. Вынесение исключений в exceptions.json и синонимы отделов**
+
+> * Служебный персонал (отдел «ЭТО», уборщики производственных и служебных помещений, клинеры, дворники, гардеробщики) вынесен в exceptions.json.  
+> * Для сопоставления кратких аббревиатур СКУД и полных названий отделов 1С (*«ОВК» ⟷ «Отдел внутреннего контроля»*) создана таблица department\_synonyms с автоматическим самообучением при работе человека (Human-in-the-Loop).
+
+### **2.5. Разгадка феномена «исчезающих неизвестных» и аппаратный сбой СКУД 04.08.2026**
+
+> * **Аномалия:** Утром 04.08.2026 на главном КПП зависли контроллеры входа. У 119 сотрудников не записалось утреннее событие (time\_in \= 'Нет входа'). Из них 57 человек были в отпусках/командировках по 1С. Оставшиеся 74 человека были на работе без утренней отметки. Однако вечерняя сводка показала всего 4–7 «неизвестных».  
+> * **Причина:** Скрипт агрегации видел дневные перемещения (обед, внутренние двери, туалет, вечерний выход) и автоматически проставлял Статус \= 'Присутствовал' и is\_present \= 1, несмотря на то, что колонка Начало\_дня оставалась 'Нет входа'. В итоге 70 человек тихо ушли в «Итого на работе», а системный сбой оборудования был замаскирован.  
+> * **Архитектурный фикс:**  
+  1. Введена колонка **first\_activity («Первая активность»)** — вычисление MIN(TimeVal) AS FirstRawEvent по таблице pLogData без учета направления двери.  
+  2. Если time\_in \== 'Нет входа', но first\_activity \!= '—', записи ставится anomaly\_flag \= 'ANOMALY\_NO\_IN\_HAS\_ACTIVITY', а is\_present принудительно сбрасывается в 0\.  
+  3. Внедрен модуль analyze\_scud\_mass\_failure\_ai(): если доля таких аномалий превышает 5% смены (\>10 чел.), ИИ генерирует системный алерт о массовом сбое контроллеров КПП.  
+> * **Кейс Равина В.Э.:** Главный специалист официально находился в основном отпуске по 1С, утреннего входа на КПП не было, но зафиксирована активность в 14:11:06 и вечерний выход в 17:18:38. Система зарегистрировала истинную кадровую аномалию (физическое присутствие при официальном отпуске).
+
+### **2.6. Система сквозных датированных снапшотов (срезов)**
+
+> * **Формат ID:** \[Y\]YYYYMMDD-NNN (например, Y20260804-001 для вчерашнего зафиксированного вечернего среза на 22:00 и 20260805-002 для дневного).  
+> * **Оптимизация:** Функция has\_yesterday\_final\_snapshot() проверяет наличие вчерашнего среза в SQLite: если он есть, повторный тяжелый запрос к MS SQL Орион пропускается.  
+> * **CLI-управление:** Поддержка запуска отчетов по любому историческому снапшоту через ключ \--snapshot \[ID\] и пропуск выгрузки через \--skip-export.
+
+### **2.7. Web API, Generative UI и управление жизненным циклом сессий (Topic Drift & Ephemeral Buffer)**
+
+> * **Проблема засорения контекста LLM:** Вывод объемных списков задач, системных промптов и таблиц срезов забивал окно диалога, вызывая галлюцинации и «залипание» модели на старых данных.  
+> * **Решение:**  
+  * В chat\_messages введен флаг is\_ephemeral \= 1 для временных сообщений.  
+  * Двухфазные сессии (PROMPT\_PREVIEW → PROMPT\_FOLLOWUP) и детерминированный счетчик idle\_turns.  
+  * **Context Guard:** На 3-м шаге отвлечения оператора на сторонние темы система отвечает на вопрос и выводит интерактивное напоминание с кнопками \[Завершить настройку\] / \[Показать промпт\]. При idle\_turns \> 3 происходит автоочистка сессии вызовом db\_purge\_ephemeral\_messages().  
+  * **Fast-Path:** Прямой перехват команд подтверждения («да», «подтверждаю») и выхода («нет, спасибо») без обращения к LLM (ответ за 0.05 сек).  
+  * **Декларативный реестр (tool\_action\_registry):** Хранение шаблонов ответов, кнопок и настроек эфемерности в SQLite.  
+> * **Generative UI (Задачи):** Инструмент db\_get\_tasks возвращает TASK\_INTERACTIVE\_CARD, рендерящий на клиенте живой виджет задач с табами (Все / В работе / В планах / Завершенные), чекбоксами и inline-созданием задач через REST API.
+
+## ---
+
+**3\. Полная схема базы данных SQLite (data/scud\_orion\_ai.db)**
+
+| Таблица | Назначение и бизнес-логика | Структура полей |
+| :---- | :---- | :---- |
+| **scud\_logs** | Логи проходов СКУД, расчетное время в здании и снапшоты. | id INTEGER PK AUTOINCREMENT, log\_date TEXT, fio TEXT, fio\_clean TEXT, department TEXT, position TEXT, time\_in TEXT, first\_activity TEXT DEFAULT '—', time\_out TEXT, time\_in\_building TEXT, is\_present INTEGER, anomaly\_flag TEXT DEFAULT 'NONE', snapshot\_time TEXT, snapshot\_id TEXT, created\_at TIMESTAMP |
+| **zup\_staff** | Штатное расписание 1С:ЗУП на даты срезов. | id INTEGER PK AUTOINCREMENT, snapshot\_date TEXT, fio TEXT, fio\_clean TEXT, department TEXT, position TEXT, created\_at TIMESTAMP |
+| **zup\_absences** | Документы отклонений 1С (отпуска, больничные, командировки, декреты). | id INTEGER PK AUTOINCREMENT, absence\_date TEXT, fio TEXT, fio\_clean TEXT, absence\_type TEXT, created\_at TIMESTAMP |
+| **anomalies\_history** | Журнал выявленных кадровых и аппаратных аномалий. | id INTEGER PK AUTOINCREMENT, anomaly\_date TEXT, fio TEXT, anomaly\_type TEXT, details TEXT, human\_status TEXT DEFAULT 'Pending', created\_at TIMESTAMP |
+| **ai\_knowledge\_base** | Глобальные правила арбитража и приоритеты компании для ИИ. | id INTEGER PK AUTOINCREMENT, rule\_text TEXT UNIQUE, added\_by TEXT DEFAULT 'Human', created\_at TIMESTAMP |
+| **system\_prompts** | Версионные системные промпты агента (активный по is\_active=1). | id INTEGER PK AUTOINCREMENT, name TEXT, prompt\_text TEXT, is\_active INTEGER DEFAULT 1, updated\_at TIMESTAMP |
+| **tool\_action\_registry** | Декларативный реестр шаблонов, кнопок и настроек эфемерности инструментов. | id INTEGER PK AUTOINCREMENT, tool\_name TEXT UNIQUE, category TEXT, bypass\_llm INTEGER, success\_template TEXT, follow\_up\_question TEXT, action\_type TEXT, buttons\_json TEXT, is\_active INTEGER, is\_ephemeral INTEGER, updated\_at TIMESTAMP |
+| **session\_states** | Активные состояния сессий, черновики и счетчик idle\_turns. | session\_id TEXT PRIMARY KEY, state\_type TEXT, pending\_data TEXT, updated\_at TIMESTAMP |
+| **chat\_messages** | История диалогов с поддержкой разделения на постоянные и эфемерные сообщения. | id INTEGER PK AUTOINCREMENT, session\_id TEXT, role TEXT, content TEXT, is\_ephemeral INTEGER DEFAULT 0, created\_at TIMESTAMP |
+| **tasks** | Реестр задач операторов с привязкой к user\_id. | id INTEGER PK AUTOINCREMENT, task\_id TEXT, module TEXT, title TEXT, priority TEXT, status TEXT, due\_date TEXT, user\_id INTEGER, created\_at TIMESTAMP |
+| **users** | Учетные записи операторов (хэши паролей bcrypt, права администратора). | id INTEGER PK AUTOINCREMENT, username TEXT UNIQUE, password\_hash TEXT, is\_admin INTEGER, full\_name TEXT, created\_at TIMESTAMP |
+| **department\_synonyms** | База соответствия аббревиатур СКУД полным названиям отделов 1С. | id INTEGER PK AUTOINCREMENT, short\_name TEXT UNIQUE, full\_name TEXT, created\_at TIMESTAMP |
+| **system\_reference** | Справочник команд и примеров промптов для операторов. | id INTEGER PK AUTOINCREMENT, category TEXT, title TEXT, example\_prompt TEXT, description TEXT |
+
+## ---
+
+**4\. Архитектурная структура каталогов**
+
+scud\_ai/  
+├── config.py                     \# Конфигурация: пути, расчет дат, URL Ollama, параметры MS SQL  
+├── exceptions.json               \# Декларативные фильтры исключений (ОВК, уборщики, подрядчики)  
+├── main\_etl.py                   \# Оркестратор ETL: экспорт СКУД/1С \-\> SQLite \-\> Excel/MD отчеты  
+├── project\_code\_snapshot.md      \# Полный монолитный исходный код всех файлов репозитория  
+├── core/  
+│   └── database.py               \# Драйвер SQLite (WAL), функции сохранения/загрузки срезов  
+├── services/  
+│   ├── scud\_export.py            \# Прямой SQL-экспорт из MS SQL «Орион Pro»  
+│   ├── zup\_extractor.py          \# Прямой SQL-экспорт из MS SQL 1С:ЗУП 3.1  
+│   ├── data\_loader.py            \# Загрузка данных, нормализация ФИО, расчет первой активности  
+│   ├── data\_validator.py         \# Проверка свежести и наличия файлов за Вчера и Сегодня  
+│   ├── excel\_exporter.py         \# Генерация сводки и детального отчета в Excel (openpyxl)  
+│   ├── text\_reporter.py          \# Построение итогового Markdown-отчета через Qwen 2.5  
+│   ├── ai\_verifier.py            \# Модули ИИ-аудита, Fuzzy Matching и детекции сбоев СКУД  
+│   ├── feedback\_loop.py          \# Интерактивный консольный модуль Human-in-the-Loop  
+│   ├── knowledge\_base.py         \# Интерфейс работы с базой знаний правил  
+│   └── share\_copier.py           \# Резервное скачивание файлов 1С с шары /mnt/scud\_share  
+├── scripts/  
+│   ├── db\_cli.py                 \# CLI-утилита управления БД, снапшотами, дампами и сессиями  
+│   ├── fix\_snapshots.py          \# Скрипт переиндексации и нормализации снапшотов  
+│   ├── init\_tool\_registry.py     \# Инициализация декларативного реестра инструментов  
+│   └── diagnostics/  
+│       ├── inspect\_db.py         \# Диагностика структуры таблиц и количества записей  
+│       ├── inspect\_ephemeral.py  \# Анализ распределения постоянных и эфемерных сообщений  
+│       ├── inspect\_files.py      \# Аудит файлов и размеров на диске  
+│       └── show\_tree.py          \# Вывод дерева каталогов  
+├── modules/web\_api/  
+│   ├── main.py                   \# Точка входа FastAPI приложения, роутеры и раздача статики  
+│   ├── routers/ (admin, auth, chat, tasks) \# REST эндпоинты  
+│   ├── llm/  
+│   │   ├── agent.py              \# Координатор диалога, Tool Calls и Topic Drift Guard  
+│   │   ├── schemas.py            \# Описание JSON-схем инструментов для Ollama  
+│   │   ├── file\_parser.py        \# Мультимодальный парсер файлов (PDF, PNG, XLSX, TXT)  
+│   │   ├── db\_tools.py           \# Фасадные вызовы функций БД для агента  
+│   │   ├── core/ (calendar\_utils, fast\_path, ollama\_client, prompt\_merger, tool\_injector)  
+│   │   └── db/ (connection, db\_chat, db\_prompts, db\_snapshots, db\_tasks)  
+│   └── static/ (index.html, css/styles.css, js/app.js, js/auth.js, js/chat.js, js/tasks.js)  
+└── docs/  
+    └── development\_roadmap.md    \# Стратегическая дорожная карта и архитектурный бэклог
+
+## ---
+
+**5\. Справочник команд CLI (HOWTO)**
+
+### **ETL Пайплайн (main\_etl.py):**
+
+> * python main\_etl.py — стандартный дневной запуск (экспорт из MS SQL, сохранение снапшота, генерация отчетов).  
+> * python main\_etl.py \--skip-export — построение отчетов по последнему имеющемуся снапшоту из SQLite без повторного запроса к MS SQL.  
+> * python main\_etl.py \--snapshot 20260805-001 — точный расчет отчетов по указанному составному ID снапшота.  
+> * python main\_etl.py \-d — запуск в режиме расширенной отладки (DEBUG).
+
+### **CLI базы данных (scripts/db\_cli.py):**
+
+> * python scripts/db\_cli.py stats — статистика по количеству строк во всех таблицах БД.  
+> * python scripts/db\_cli.py snapshots \[ДД.ММ.ГГГГ\] — просмотр реестра снапшотов с сортировкой по времени создания (свежие сверху).  
+> * python scripts/db\_cli.py scud \[ДД.ММ.ГГГГ\] \[--snapshot ID\] \[--export-xlsx NAME\] — инспекция логов СКУД и экспорт в Excel.  
+> * python scripts/db\_cli.py absences \[ДД.ММ.ГГГГ\] — список кадровых отклонений из 1С:ЗУП.  
+> * python scripts/db\_cli.py anomalies — история выявленных аномалий.  
+> * python scripts/db\_cli.py rules — правила базы знаний компании.  
+> * python scripts/db\_cli.py prompts — системные промпты из system\_prompts.  
+> * python scripts/db\_cli.py tools — декларативный реестр действий инструментов и кнопок.  
+> * python scripts/db\_cli.py sessions — активные сессионные стейты и висящие черновики.  
+> * python scripts/db\_cli.py snapshot del \[ID\] — удаление конкретного снапшота по ID.  
+> * python scripts/db\_cli.py snapshot del \--day \[ДД.ММ.ГГГГ\] — удаление всех снапшотов за день.  
+> * python scripts/db\_cli.py dump \[backup.xlsx\] — полный дамп всех таблиц базы данных в многостраничный Excel.
+
+## ---
+
+**6\. Стратегическая дорожная карта и нерешенные задачи (Roadmap & Backlog)**
+
+> 1. **Масштабирование механизма эфемерного контекста на все инструменты (Rollout Roadmap):**  
+   * **Снапшоты (snapshots):** Перевод вывода объемных таблиц срезов в эфемерный режим (is\_ephemeral \= 1), внедрение интерактивного подтверждения при удалении снапшотов по ID/дате через состояния SNAPSHOTS\_PREVIEW / SNAPSHOTS\_FOLLOWUP.  
+   * **База знаний и аномалии (kb & anomalies):** Вывод справочников команд, правил арбитража и списков аномалий исключительно во временный слой для исключения «залипания» модели на устаревших правилах из истории сообщений.  
+   * **Декларативная унификация в tool\_action\_registry:** Расширение схемы таблицы полями followup\_state\_type, auto\_purge\_on\_exit, guard\_question\_template для устранения хардкода имен функций в agent.py.  
+> 2. **Модуль анализа внутридневных перемещений («Контроль перекуров»):**  
+   * Анализ интервалов между событиями OUT (выход) и IN (возврат) по журналу pLogData.  
+   * Подсчет суммарного времени нахождения вне рабочего места в течение смены с отсечением технологической нормы (30–40 минут).  
+   * Вывод аналитического блока и злостных нарушителей в отдельный лист Excel-отчета и итоговую Markdown-сводку.  
+> 3. **Интерактивный Task Planner & Roadmap Engine:**  
+   * Специализированный инструмент для ведения динамических проектных планов и чек-листов с чекбоксами (\[ \] / \[x\]) прямо в диалоге с синхронизацией в таблицу tasks.  
+> 4. **Изолированная среда исполнения кода (Code Execution Sandbox):**  
+   * Безопасный изолированный Docker/gVisor контейнер для динамического выполнения генерируемого моделью Python/Pandas кода на лету с возвратом stdout/stderr и графиков в контекст.  
+> 5. **Автоматизация расписания срезов и Telegram-алерты:**  
+   * Автозапуск выгрузок в 12:00, 17:00 и 19:00 через systemd-таймеры с фиксацией snapshot\_time.  
+   * Отправка мгновенных алертов о массовых сбоях турникетов (\>5%) и критических кадровых конфликтах дежурному системному администратору в Telegram.

docs/SCUD Orion AI — Полная энциклопедическая хроника, архитектурный паспорт и технический контекст (v4.0).md

@@ -0,0 +1,223 @@
+# **SCUD Orion AI — Полная энциклопедическая хроника, архитектурный паспорт, разбор всех инцидентов и технический контекст проекта**
+
+**Версия документа:** 4.0 (Исчерпывающий монолитный контекстный паспорт для новой сессии)  
+**Стек технологий и инфраструктура:** Python 3.11+, FastAPI (Uvicorn), SQLite (WAL mode, PRAGMA synchronous=NORMAL, внешние ключи ON), Ollama REST API (Qwen 2.5:14b — основной текстовый агент и классификатор, Qwen 2.5-VL:7b-q8\_0 / Qwen 3-VL:8b — OCR и зрение), MS SQL Server 2019/2022 (СКУД «Орион Pro» ЗАО НВП «Болид», 1С:ЗУП 3.1 через pyodbc / ODBC Driver 18), сетевая Samba-шара (/mnt/scud\_share), Git/Gitea, HTML5 / Vanilla JS / Tailwind CSS.
+
+## ---
+
+**1\. Исходный бизнес-контекст, роли систем и фундаментальные задачи**
+
+Проект решает комплексную проблему контроллинга трудовой дисциплины, автоматического сопоставления кадровых фактов и защиты от рассинхронизации мастер-данных на предприятии со штатом \~270–276 сотрудников.
+
+### **Источники первичных данных:**
+
+> * **СКУД «Орион Pro» (Болид):** База данных MS SQL Server (SERVER: 172.16.31.221\\SQL, DB: Orion-14.01.21-1). Основные таблицы:  
+  * pLogData — журнал всех сырых физических транзакций турникетов, калиток и внутренних дверей. Ключевые поля: TimeVal (время сервера), DeviceTime (время контроллера), HozOrgan / Hrk (ID сотрудника), Event (код события: 26, 28, 32 — вход; 27, 29, 33 — выход; 54, 55, 64, 65 — внутренние считыватели), Mode (направление: 1 — IN, 2 — OUT), ReaderIndex, DoorIndex.  
+  * pList — реестр физических лиц и пропусков (ФИО, табельный номер, статус архива).  
+  * PDivision, PPost — справочники подразделений и должностей СКУД.  
+> * **1С:ЗУП 3.1 (Кадры):** База данных MS SQL Server (SERVER: ACCOUNT-01, DB: ZUP30).  
+  * dbo.\_Reference299 — эталонный справочник сотрудников.  
+  * dbo.\_InfoRg16921 — периодический регистр сведений состояний сотрудников (отпуска основные, больничные, командировки, декретные отпуска, отпуска без сохранения оплаты).  
+  * Файловые выгрузки с сетевой шары /mnt/scud\_share: файлы Штат\_ДД\_ММ\_ГГГГ.xlsx (шапка 7–8 строк) и Отсутствия\_ДД\_ММ\_ГГГГ.xlsx (шапка 3–4 строки).  
+> * **Реестры статических исключений:** static\_reason\_workers.csv (реестр удаленщиков и постоянных разъездных сотрудников), exceptions.json (декларативный фильтр обслуживающего персонала и спец-отделов).
+
+## ---
+
+**2\. Подробнейшая пошаговая хронология разработки, эволюция идей и разбор ошибок**
+
+### **Фаза 1: Первые эксперименты с LLM, выявление галлюцинаций и гибридная парадигма**
+
+> * **Попытка передачи сырых списков в чат:** Первоначальная попытка скормить модели Qwen 2.5:14b список из сотен ФИО с инструкцией *«запомни список 1С»* показала, что у LLM нет постоянной памяти между сессиями. Модель теряла контекст, путала фамилии и выдавала ответы с троеточиями ('Васильев Л.И.', ...) или придумывала несуществующие строки (*«ЛЕНМОРНИИПРОЕКТ ОЭС Варламова Мария»*).  
+> * **Ошибки openpyxl vs pandas:** Первая генерация кода моделью использовала библиотеку openpyxl с построчным перебором ячеек, жестко зашитыми опечатками (поиск слова 'фиио') и падением по FileNotFoundError.  
+> * **Переход к детерминированному пайплайну:** Принято ключевое архитектурное решение — **LLM не считает математику и не фильтрует 300 строк текста**. Всю механическую работу (ETL, слияние, фильтрацию) выполняет быстрый детерминированный Python (pandas, SQL), а локальная LLM выступает исключительно в роли «умного ревизора» на этапе сопоставления сомнительного несовпавшего остатка (Diff).
+
+### **Фаза 2: Нормализация ФИО, кодировки и коллизия совместителей (Кейс Балаевой О.Г.)**
+
+> * **Символьные ловушки:**  
+  * Латинские буквы-двойники (омоглифы a, c, e, o, p, x, y, случайно набранные в английской раскладке).  
+  * Служебные суффиксы в скобках, добавляемые 1С ((осн.), (совм.), (внешн.)).  
+  * Буквы ё/е, двойные пробелы, неразрывные пробелы \\xa0 и случайный ввод цифры 0 вместо буквы О.  
+> * **Функция normalize\_fio():** Разработан строгий конвейер очистки:  
+>   `def normalize_fio(fio):`  
+>       `if not fio or not isinstance(fio, str): return ""`  
+>       `fio_clean = re.sub(r'\(.*?\)', '', fio) # Удаление скобок`  
+>       `fio_clean = fio_clean.replace('\xa0', ' ')`  
+>       `trans = str.maketrans('aceopxyABCEHKMOPTX', 'асеорхуАВСЕНКМОРТХ')`  
+>       `fio_clean = fio_clean.translate(trans)`  
+>       `fio_clean = fio_clean.replace('ё', 'е').replace('Ё', 'Е')`  
+>       `return " ".join(fio_clean.strip().split()).title()`  
+> * **Коллизия 270 vs 271:** В СКУД числилось 270 уникальных человек, а в 1С — 271 строка. Ручной разбор показал, что **Балаева Ольга Геннадьевна** занимает две ставки в 1С (*Руководитель управления персоналом* и *Руководитель режимно-секретного отдела*) при одном физическом пропуске в СКУД.  
+> * **Решение:** Внедрена обязательная группировка штата 1С по fio\_clean с объединением должностей и подразделений через " / ".
+
+### **Фаза 3: Защита Entity Resolution от однофамильцев (Инцидент с Семеновыми)**
+
+> * **Сбой модели:** При передаче несовпавших ФИО в Qwen 2.5 модель ошибочно сопоставила *«Семенову Юлию Борисовну»* (которая была на работе) с *«Семеновой Диной Дмитриевной»* (находившейся в отпуске), посчитав это опечаткой в имени из\-за одинаковой фамилии. В результате Юлия Борисовна получила статус нарушителя («в отпуске, но пришла»).  
+> * **Двухконтурная защита:**  
+  1. В системный промпт ИИ зашито категорическое правило: однофамильцы с разными именами/отчествами — строго разные люди, объединение запрещено.  
+  2. В Python встроен дублирующий барьер: если фамилии совпадают, но инициалы/первые буквы имен различаются, связь ИИ принудительно аннулируется с логированием ⚠️ \[Блокировка фейка\].
+
+### **Фаза 4: Декларативные исключения и синонимы отделов**
+
+> * **Переход к exceptions.json:** Исключение клининга, дворников, гардеробщиков и хозяйственного персонала отдела «ЭТО» вынесено из кода в конфигурационный файл exceptions.json (поддержка списков departments, positions, fio, position\_keywords).  
+> * **База синонимов отделов (department\_synonyms):** Для сопоставления сокращений СКУД с длинными названиями 1С (например, *«ОВК» ⟷ «Отдел внутреннего контроля»*) создана таблица SQLite, автоматически обучаемая при подтверждениях оператора.
+
+### **Фаза 5: Аппаратный сбой СКУД 04.08.2026, разгадка «исчезающих неизвестных» и Первая активность**
+
+> * **Анатомия сбоя:** Утром 04.08.2026 зависли регистраторы входа на главном КПП. У 119 сотрудников не записалось событие входа (time\_in \= 'Нет входа'). Из них 57 человек были официально закрыты документами 1С (отпуска, командировки). Оставшиеся \~74 человека реально пришли на работу, но утренней отметки не имели. Однако вечером сводка выдала всего 4–7 «неизвестных».  
+> * **Вскрытие механизма ошибки:** Было обнаружено, что скрипт агрегации видел дневные перемещения сотрудников (выходы на обед, считыватели туалетов, внутренние двери) и автоматически выставлял Статус \= 'Присутствовал' и is\_present \= 1\. Из-за этого люди попадали в категорию «Итого на работе», а массовый аппаратный сбой скрывался.  
+> * **Внедрение «Первой активности»:**  
+  1. В базу данных и выгрузки Excel добавлена колонка **first\_activity («Первая активность»)** — минимальное время любого события дня в здании (MIN(TimeVal) AS FirstRawEvent без учета направления двери).  
+  2. Если time\_in \== 'Нет входа', но first\_activity \!= '—', записи присваивается anomaly\_flag \= 'ANOMALY\_NO\_IN\_HAS\_ACTIVITY', а is\_present принудительно сбрасывается в 0\.  
+  3. Внедрен модуль analyze\_scud\_mass\_failure\_ai(): при превышении порога в 5% смены (\>10 человек) ИИ поднимает тревогу о массовом сбое контроллеров КПП.  
+> * **Кейс Равина В.Э.:** Сотрудник находился в официальном отпуске, утреннего входа не имел, но пришел после обеда (первая активность 14:11:06, выход 17:18:38). Система корректно зафиксировала истинную кадровую аномалию (физическое присутствие при официальном отпуске).
+
+### **Фаза 6: Архитектурная миграция под Gitea и система срезов (снапшотов)**
+
+> * **Безопасный рефакторинг:** Монолит разделен на слои (core/, services/, scripts/, modules/web\_api/) через git mv с сохранением истории коммитов в ветке refactor/modular-structure.  
+> * **Формат ID снапшота:** Введена схема \[Y\]YYYYMMDD-NNN (например, Y20260804-001 для вчерашнего зафиксированного вечернего среза на 22:00 и 20260805-002 для дневного).  
+> * **Оптимизация экспорта:** Если в SQLite уже зафиксирован вчерашний срез с префиксом Y, повторный тяжелый SQL-запрос к СКУД Орион не выполняется (функция has\_yesterday\_final\_snapshot).  
+> * **Инспекция и CLI:** Написан инструмент scripts/db\_cli.py с командами stats, snapshots, scud, absences, anomalies, rules, prompts, tools, sessions, dump, snapshot del.
+
+### **Фаза 7: Web API, Generative UI, управление памятью LLM и Topic Drift Guard**
+
+> * **FastAPI & Безопасность:** Развернут Web API с JWT-авторизацией (bcrypt), изолированными задачами пользователей (tasks с привязкой к user\_id), гостевым режимом и ролевой моделью.  
+> * **Проблема деградации контекста LLM:** Вывод объемных списков задач, текстов системных промптов и таблиц снапшотов засорял контекстное окно чата, приводя к галлюцинациям и «залипанию» модели на старых правилах.  
+> * **Решение проблемы памяти (Topic Drift & Ephemeral Context):**  
+  * В таблицу chat\_messages добавлен флаг is\_ephemeral \= 1 для временных сообщений.  
+  * Введены двухфазные сессии (PROMPT\_PREVIEW → PROMPT\_FOLLOWUP) и детерминированный счетчик отвлечений idle\_turns.  
+  * **Context Guard:** На 3-м шаге отвлечения оператора на сторонние темы система отвечает на вопрос и выводит интерактивное напоминание с кнопками \[Завершить настройку\] / \[Показать промпт\]. При idle\_turns \> 3 происходит автоочистка сессии вызовом db\_purge\_ephemeral\_messages().  
+  * **Fast-Path:** Прямой перехват команд подтверждения («да», «подтверждаю», «сохранить») и выхода («нет, спасибо», «закончить настройку») без обращения к LLM (ответ за 0.05 сек).  
+  * **Декларативный реестр действий (tool\_action\_registry):** Хранение шаблонов ответов, типов кнопок и признаков эфемерности в SQLite.  
+> * **Generative UI (Интерактивные карточки задач):** Инструмент db\_get\_tasks возвращает полезную нагрузку TASK\_INTERACTIVE\_CARD. Фронтенд рендерит живой виджет с табами (Все / В работе / В планах / Завершенные), чекбоксами и inline-созданием задач через REST API без вызова LLM.
+
+## ---
+
+**3\. Полная схема базы данных SQLite (data/scud\_orion\_ai.db)**
+
+| Таблица | Назначение и бизнес-логика | Полная структура колонок |
+| :---- | :---- | :---- |
+| **scud\_logs** | Хранение логов проходов СКУД, расчетного времени и снапшотов. | id (PK), log\_date, fio, fio\_clean, department, position, time\_in, first\_activity, time\_out, time\_in\_building, is\_present, anomaly\_flag, snapshot\_time, snapshot\_id, created\_at |
+| **zup\_staff** | Штатное расписание 1С:ЗУП на даты срезов. | id (PK), snapshot\_date, fio, fio\_clean, department, position, created\_at |
+| **zup\_absences** | Официальные кадровые отклонения 1С (отпуска, больничные, командировки, декреты). | id (PK), absence\_date, fio, fio\_clean, absence\_type, created\_at |
+| **anomalies\_history** | Журнал выявленных кадровых и аппаратных аномалий. | id (PK), anomaly\_date, fio, anomaly\_type, details, human\_status, created\_at |
+| **ai\_knowledge\_base** | Глобальные правила арбитража и приоритеты компании для ИИ. | id (PK), rule\_text, added\_by, created\_at |
+| **system\_prompts** | Версионные системные промпты агента (активный промпт по is\_active=1). | id (PK), name, prompt\_text, is\_active, updated\_at |
+| **tool\_action\_registry** | Декларативный реестр шаблонов, кнопок и настроек эфемерности инструментов. | id (PK), tool\_name, category, bypass\_llm, success\_template, follow\_up\_question, action\_type, buttons\_json, is\_active, is\_ephemeral, updated\_at |
+| **session\_states** | Активные состояния сессий, черновики и счетчик idle\_turns. | session\_id (PK), state\_type, pending\_data, updated\_at |
+| **chat\_messages** | История диалогов с поддержкой разделения на постоянные и эфемерные сообщения. | id (PK), session\_id, role, content, is\_ephemeral, created\_at |
+| **tasks** | Реестр задач пользователей с привязкой к user\_id. | id (PK), task\_id, module, title, priority, status, due\_date, user\_id, created\_at |
+| **users** | Учетные записи операторов (хэши паролей bcrypt, права администратора). | id (PK), username, password\_hash, is\_admin, full\_name, created\_at |
+| **department\_synonyms** | База знаний соответствия аббревиатур СКУД полным названиям отделов 1С. | id (PK), short\_name, full\_name, created\_at |
+| **system\_reference** | Справочник команд и примеров промптов для операторов. | id (PK), category, title, example\_prompt, description |
+
+## ---
+
+**4\. Актуальная архитектура каталогов и назначение файлов**
+
+`scud_ai/`  
+`├── config.py                     # Конфигурация: пути, расчет дат, URL Ollama, параметры MS SQL`  
+`├── exceptions.json               # Декларативные фильтры исключений (ОВК, уборщики, подрядчики)`  
+`├── main_etl.py                   # Оркестратор ETL: экспорт СКУД/1С -> SQLite -> Excel/MD отчеты`  
+`├── project_code_snapshot.md      # Полный исходный код всех файлов репозитория`  
+`├── core/`  
+`│   └── database.py               # Драйвер SQLite (WAL), функции сохранения/загрузки срезов`  
+`├── services/`  
+`│   ├── scud_export.py            # Прямой SQL-экспорт из MS SQL «Орион Pro»`  
+`│   ├── zup_extractor.py          # Прямой SQL-экспорт из MS SQL 1С:ЗУП 3.1`  
+`│   ├── data_loader.py            # Загрузка данных, нормализация ФИО, расчет первой активности`  
+`│   ├── data_validator.py         # Проверка свежести и наличия файлов за Вчера и Сегодня`  
+`│   ├── excel_exporter.py         # Генерация сводки и детального отчета в Excel (openpyxl)`  
+`│   ├── text_reporter.py          # Построение итогового Markdown-отчета через Qwen 2.5`  
+`│   ├── ai_verifier.py            # Модули ИИ-аудита, Fuzzy Matching и детекции сбоев СКУД`  
+`│   ├── feedback_loop.py          # Интерактивный консольный модуль Human-in-the-Loop`  
+`│   ├── knowledge_base.py         # Интерфейс работы с базой знаний правил`  
+`│   └── share_copier.py           # Резервное скачивание файлов 1С с шары /mnt/scud_share`  
+`├── scripts/`  
+`│   ├── db_cli.py                 # CLI-утилита управления БД, снапшотами, дампами и сессиями`  
+`│   ├── fix_snapshots.py          # Скрипт переиндексации и нормализации снапшотов`  
+`│   ├── init_tool_registry.py     # Инициализация декларативного реестра инструментов`  
+`│   └── diagnostics/`  
+`│       ├── inspect_db.py         # Диагностика структуры таблиц и количества записей`  
+`│       ├── inspect_ephemeral.py  # Анализ распределения постоянных и эфемерных сообщений`  
+`│       ├── inspect_files.py      # Аудит файлов и размеров на диске`  
+`│       └── show_tree.py          # Вывод дерева каталогов`  
+`├── modules/web_api/`  
+`│   ├── main.py                   # Точка входа FastAPI приложения, роутеры и раздача статики`  
+`│   ├── routers/`  
+`│   │   ├── admin.py              # Управление пользователями`  
+`│   │   ├── auth.py               # JWT аутентификация и смена паролей`  
+`│   │   ├── chat.py               # Эндпоинты диалогов (авторизованный и гостевой)`  
+`│   │   └── tasks.py              # REST API управления задачами`  
+`│   ├── llm/`  
+`│   │   ├── agent.py              # Координатор диалога, Tool Calls и Topic Drift Guard`  
+`│   │   ├── schemas.py            # Описание JSON-схем инструментов для Ollama`  
+`│   │   ├── file_parser.py        # Мультимодальный парсер файлов (PDF, PNG, XLSX, TXT)`  
+`│   │   ├── db_tools.py           # Фасадные вызовы функций БД для агента`  
+`│   │   ├── core/`  
+`│   │   │   ├── calendar_utils.py # Формирование системного контекста дат и дней недели`  
+`│   │   │   ├── fast_path.py      # Быстрый перехват команд подтверждения/отмены (0.05 с)`  
+`│   │   │   ├── ollama_client.py  # HTTP-клиент взаимодействия с Ollama API`  
+`│   │   │   ├── prompt_merger.py  # Парсинг и слияние правок системного промпта`  
+`│   │   │   └── tool_injector.py  # Очистка сырых тегов и артефактов Tool Calls`  
+`│   │   └── db/`  
+`│   │       ├── connection.py     # Подключение к scud_orion_ai.db`  
+`│   │       ├── db_chat.py        # Сохранение истории и очистка эфемерных сообщений`  
+`│   │       ├── db_prompts.py     # Системные промпты, стейты и реестр действий`  
+`│   │       ├── db_snapshots.py   # Выборка и удаление снапшотов`  
+`│   │       └── db_tasks.py       # CRUD операции с задачами пользователей`  
+`│   └── static/`  
+`│       ├── index.html            # SPA разметка (модалки, чат, боковая панель задач)`  
+`│       ├── css/styles.css        # Стили и мобильные оптимизации`  
+`│       └── js/`  
+`│           ├── app.js            # Инициализация приложения`  
+`│           ├── auth.js           # Логика входа, смены паролей и администрирования`  
+`│           ├── chat.js           # Обработка сообщений, Drag&Drop, виджет задач и кнопки`  
+`│           └── tasks.js          # Управление боковой панелью задач (Drawer)`  
+`└── docs/`  
+    `└── development_roadmap.md    # Стратегическая дорожная карта и архитектурный бэклог`
+
+## ---
+
+**5\. Справочник команд командной строки (CLI Reference)**
+
+### **Главный конвейер контроллинга (main\_etl.py)**
+
+> * python main\_etl.py — стандартный дневной запуск: экспорт свежих данных СКУД и 1С, сохранение снапшота в SQLite, генерация Excel и Markdown отчетов.  
+> * python main\_etl.py \--skip-export — построение отчетов по последнему имеющемуся снапшоту из SQLite без повторного запроса к MS SQL.  
+> * python main\_etl.py \--snapshot 20260805-001 — точный расчет отчетов по указанному составному ID снапшота.  
+> * python main\_etl.py \-d — запуск в режиме расширенной отладки (DEBUG).
+
+### **CLI-утилита управления SQLite базой данных (scripts/db\_cli.py)**
+
+> * python scripts/db\_cli.py stats — общая статистика количества записей по всем таблицам БД.  
+> * python scripts/db\_cli.py snapshots \[ДД.ММ.ГГГГ\] — просмотр реестра снапшотов с сортировкой по времени создания (самые свежие сверху).  
+> * python scripts/db\_cli.py scud \[ДД.ММ.ГГГГ\] \[--snapshot ID\] \[--export-xlsx NAME\] — просмотр логов СКУД и опциональный экспорт в Excel.  
+> * python scripts/db\_cli.py absences \[ДД.ММ.ГГГГ\] — список кадровых отклонений из 1С:ЗУП.  
+> * python scripts/db\_cli.py anomalies — история выявленных аномалий.  
+> * python scripts/db\_cli.py rules — правила базы знаний компании.  
+> * python scripts/db\_cli.py prompts — просмотр системных промптов из таблицы system\_prompts.  
+> * python scripts/db\_cli.py tools — вывод декларативного реестра действий инструментов и шаблонов кнопок.  
+> * python scripts/db\_cli.py sessions — просмотр активных сессионных стейтов и висящих черновиков.  
+> * python scripts/db\_cli.py snapshot del \[ID\] — удаление конкретного снапшота по ID.  
+> * python scripts/db\_cli.py snapshot del \--day \[ДД.ММ.ГГГГ\] — удаление всех снапшотов за выбранный день.  
+> * python scripts/db\_cli.py dump \[backup.xlsx\] — полный дамп всех таблиц базы данных в многостраничный Excel-файл.
+
+## ---
+
+**6\. Стратегическая дорожная карта развития (Roadmap & Backlog)**
+
+> 1. **Масштабирование механизма эфемерного контекста на все инструменты (Rollout Roadmap):**  
+   * **Снапшоты (snapshots):** Перевод вывода объемных таблиц срезов в эфемерный режим (is\_ephemeral \= 1), внедрение интерактивного подтверждения при удалении снапшотов по ID/дате через состояния SNAPSHOTS\_PREVIEW / SNAPSHOTS\_FOLLOWUP.  
+   * **База знаний и аномалии (kb & anomalies):** Вывод справочников команд, правил арбитража и списков аномалий исключительно во временный слой для исключения «залипания» модели на устаревших правилах из истории сообщений.  
+   * **Декларативная унификация в tool\_action\_registry:** Расширение схемы таблицы полями followup\_state\_type, auto\_purge\_on\_exit, guard\_question\_template для устранения хардкода имен функций в agent.py.  
+> 2. **Модуль анализа внутридневных перемещений («Контроль перекуров»):**  
+   * Анализ интервалов между событиями OUT (выход) и IN (возврат) по журналу pLogData.  
+   * Подсчет суммарного времени нахождения вне рабочего места в течение смены с отсечением технологической нормы (30–40 минут).  
+   * Вывод аналитического блока и злостных нарушителей в отдельный лист Excel-отчета и итоговую Markdown-сводку.  
+> 3. **Интерактивный Task Planner & Roadmap Engine:**  
+   * Специализированный инструмент для ведения динамических проектных планов и чек-листов с чекбоксами (\[ \] / \[x\]) прямо в диалоге с синхронизацией в таблицу tasks.  
+> 4. **Изолированная среда исполнения кода (Code Execution Sandbox):**  
+   * Безопасный изолированный Docker/gVisor контейнер для динамического выполнения генерируемого моделью Python/Pandas кода на лету с возвратом stdout/stderr и графиков в контекст.  
+> 5. **Автоматизация расписания срезов и Telegram-алерты:**  
+   * Автозапуск выгрузок в 12:00, 17:00 и 19:00 через systemd-таймеры с фиксацией snapshot\_time.  
+   * Отправка мгновенных алертов о массовых сбоях турникетов (\>5%) и критических кадровых конфликтах дежурному системному администратору в Telegram.

docs/development_roadmap.md

@@ -1,41 +0,0 @@
-# 🗺️ ДОРОЖНАЯ КАРТА И АРХИТЕКТУРНЫЙ РОАДМАП ПРОЕКТА SCUD ORION AI
-
-## 📌 Зафиксированные вехи и концептуальные архитектурные решения
-
-Схема веток Gitea для ближайшего развития проекта:
-
-main (100% стабильный релиз)
-  │
-  ├──► feature/tool-registry-db ──────┐ (Создание таблицы tool_action_registry в SQLite)
-  │                                   ▼
-  ├───────────────────────────────► merge to main
-  │
-  ├──► feature/interactive-buttons ───┐ (Подключение Да/Нет чипсов на фронтенде)
-  │                                   ▼
-  ├───────────────────────────────► merge to main
-  │
-  └──► feature/ephemeral-context ─────┐ (Внедрение флагов is_ephemeral для очистки памяти LLM)
-                                      ▼
-                                  merge to main
-
-
-
-
-### 1. Архитектура скользящего контекста и отслеживания смены темы (Intent / Topic Drift Tracking)
-* **Проблема:** При работе с длинными операциями (редактирование промптов, мастера табелей, снапшотов) оператор может отвлекаться на сторонние вопросы или уточнения. Жесткий сброс сессии уничтожает черновики, а вечное хранение засоряет память LLM.
-* **Решение (Сферическое / Фундаментальное):**
-  1. **Семантическая оценка моделью:** Модель через системный контекст определяет, относится ли вопрос оператора к активному черновику/инструменту или разговор ушел в сторону (`topic_shift = true`).
-  2. **Детерминированный счетчик в бэкенде:** Бэкенд фиксирует шаги отвлечения (`idle_turns`). Пока $N < 3$, оператор может свободно общаться, не теряя висящий контекст.
-  3. **Вежливый перехват и выбор (Guard):** На 3-м шаге отвлечения система отвечает на текущий вопрос оператора и мягко напоминает о незавершенной транзакции кнопками `[Применить / Сохранить]` или `[Отменить и сбросить]`.
-
----
-
-## 🚀 Будущие модули и запланированный функционал (Backlog)
-
-### 2. Интерактивный модуль планирования и дорожных карт (Checklist & Task Planner Engine)
-* **Концепция:** Специализированный инструмент для LLM-агента, позволяющий вести динамические проектные чек-листы и планы с интерактивными чекбоксами прямо в диалоге и базе данных.
-* **Ключевые возможности:**
-  * Составление многоуровневых планов с чекбоксами (`[ ]` / `[x]`).
-  * Фиксация промежуточных комментариев и статусов выполнения по каждому пункту.
-  * Синхронизация задач плана с SQLite-таблицей `tasks`.
-  * Экспорт планов в Markdown/Excel и отображение на дашборде.

docs/in_progress/ROADMAP.md

@@ -0,0 +1,136 @@
+# План реализации (ROADMAP)
+
+## 1. Очистка от регулярок и костылей (`tool_injector.py`)
+- [x] Полностью удалить принудительные перехваты текста регулярными выражениями для команд добавления, редактирования и удаления пунктов[cite: 4].
+- [x] Оставить в модуле только базовую санитарную очистку сырых тегов (`<tool_call>`)[cite: 4].
+
+---
+
+## 2. Настройка контекста и инструкций сессии (`agent.py`)
+- [x] Передать управление диалогом языковой модели через системный блок `role: "system"`[cite: 4].
+- [x] При активном состоянии `PROMPT_PREVIEW` передавать модели инструкцию:
+  - **Подтверждение / отмена / корректировка:** продолжать работу с превью и вызывать соответствующие инструменты[cite: 4].
+  - **Смена темы:** вежливо напомнить об открытом изменении и запросить решение[cite: 4].
+- [x] Обеспечить видимость эфемерных сообщений (`is_ephemeral = 1`) для модели во время активной работы с превью[cite: 4].
+- [x] Внедрить семантический Topic Drift Guard (`idle_turns` = 3) с вопросами и кнопками из `tool_action_registry`[cite: 4].
+- [x] Реализовать детерминированный мгновенный сброс сессии и зачистку эфемерного контекста при вызове сторонних инструментов[cite: 4].
+
+---
+
+## 3. Очистка эфемерных сообщений при завершении (`fast_path.py` / `context_manager.py`)
+- [x] Настроить удаление временных сообщений превью (`db_purge_ephemeral_messages`) строго в момент нажатия кнопок **«Подтвердить»** или **«Отменить»**[cite: 4].
+- [x] Сбрасывать состояние сессии в базе данных после фиксации решения[cite: 4].
+- [x] Внедрить прямое точечное применение изменений через `db_apply_prompt_node_action`[cite: 4].
+- [x] Добавить обработку фазы `PROMPT_FOLLOWUP` с кнопками завершения и очистки контекста[cite: 4].
+- [x] Создать `context_manager.py` для строгого разграничения служебных tool-пар (`is_ephemeral=1`) и содержательного диалога (`is_ephemeral=0`), сохраняя беседы Topic Drift в истории[cite: 4].
+
+---
+
+## 4. Инлайн-редактор в окне диалога (`core.js`)
+- [x] Проверить работу блока ручного редактирования (`inline-prompt-editor-container`) с кнопками **«Сохранить правки»** и **«Свернуть»**[cite: 4].
+- [x] Обеспечить сохранение черновика через API (`/api/v1/chat/draft`) и отображение обновленного текста перед подтверждением[cite: 4].
+- [x] Реализовать двусторонний клиентский Diff-рендерер (одновременная подсветка добавленных строк и зачеркивание удаленных `[УДАЛЕНИЕ]`)[cite: 4].
+- [x] Добавить авто-форматирование и отступы подпунктов (`X.Y.`) при ручном сохранении черновика[cite: 4].
+
+---
+
+## 5. Тестирование и валидация системного промпта
+- [x] **Нативные вызовы:** проверить добавление, редактирование и удаление пунктов через нативные вызовы модели (`db_prompt_node_edit`)[cite: 4].
+- [x] **Контекстные сценарии:** проверить поведение модели при смене темы диалога оператором (Guardrail)[cite: 4].
+- [x] **UI и очистка:** проверить ручное редактирование через кнопку в окне чата и последующую очистку контекста (`db_purge_ephemeral_messages`)[cite: 4].
+
+---
+
+## 6. Распространение архитектурного паттерна на модуль задач (`tasks`)
+- [x] **Масштабирование UI задач:**
+  - Увеличена ширина карточки до `max-w-4xl` и динамическая высота скролла до `70vh`[cite: 4].
+  - Реализованы переключатели фильтрации: «В работе» (по умолчанию), «В планах», «Готово», «Все»[cite: 4].
+  - Разделены кнопки действия: «В работу» (для плановых) и «Готово» (для текущих)[cite: 4].
+- [x] **Инлайн-редактирование карточки задачи:**
+  - Плавная трансформация карточки в 3-строчную форму (текст, дата со встроенным пикером, выпадающий список важности)[cite: 4].
+  - Отображение даты создания задачи[cite: 4].
+  - Сохранение через REST API эндпоинт `PATCH /api/v1/tasks/{id}`[cite: 4].
+- [x] **Детерминированный Fast-Path и двухфазное удаление:**
+  - Мгновенная смена статусов без задержек LLM[cite: 4].
+  - Карточка подтверждения удаления с автоочисткой контекста[cite: 4].
+- [x] **Генерация отчетов задач в Markdown:**
+  - Добавлен инструмент `db_export_tasks_markdown` для формирования Markdown-файла с группировкой по модулям и чекбоксами `[x]` / `[ ]`[cite: 3].
+  - Реализован роутер безопасной отдачи файлов с сохранением имени (`/api/v1/files/download/...`)[cite: 3].
+- [x] **Доменная консолидация задач:**
+  - Реализован консолидированный инструмент `db_tasks_edit(action: ["ADD", "UPDATE", "DELETE", "EXPORT"], ...)`[cite: 3].
+
+---
+
+## 7. Распространение на модуль снапшотов (`snapshots`)
+- [x] **Поддержка Y-снапшотов:** универсальный парсинг и поиск по `snapshot_id LIKE 'Y%'` и срезам за 22:00:00[cite: 4].
+- [x] **Single Active Snapshot View:** сохранение активного среза в контексте для аналитики с автоматической ротацией и зачисткой при запросе новых дат[cite: 4].
+- [x] **Интерактивный UI с чекбоксами и защитой срезов:**
+  - Чекбоксы в строках дневных срезов и кнопка «Выбрать все» в шапке[cite: 3].
+  - Защита итогового вечернего среза Y (иконка замочка `🔒`, блокировка выбора)[cite: 3].
+  - Динамическая кнопка «Удалить выбранные (N)» в подвале карточки[cite: 3].
+- [x] **Детерминированный Fast-Path удаления срезов:**
+  - Двухфазное подтверждение удаления (одиночное и пакетное) с корректным счётчиком количества удаляемых элементов[cite: 3].
+  - Защита от сброса фильтра даты (`query_date`) при обновлении карточки после удаления[cite: 3].
+
+---
+
+## 8. Архитектурный рефакторинг и декомпозиция монолитов (Текущий этап)
+> **Контроль версий:** перед каждым этапом и после его успешной проверки выполняется коммит и фиксация в репозитории **Gitea**.
+
+- [ ] **Шаг 0: Фиксация базового состояния в Gitea:**
+  - Создание тега/коммита `v2.5-pre-refactor` в Gitea перед структурными изменениями.
+- [ ] **Шаг 1: Разделение слоя данных и ядра (`core/`):**
+  - Создание `core/connection.py` (единый SQLite Connection Manager с WAL и таймаутами).
+  - Создание `core/schema.py` (DDL-инициализация всех таблиц и индексов из `database.py`).
+  - Фиксация контрольной точки в Gitea.
+- [ ] **Шаг 2: Выделение доменных сервисов (`services/` / `domain/`):**
+  - **Задачи (`services/tasks/`):** декомпозиция на `repository.py`, `service.py`, `exporter.py` (правило: до 100–150 строк на файл).
+  - **Системный промпт (`services/prompts/`):** декомпозиция на `repository.py`, `service.py`, `diff_engine.py`.
+  - **Снапшоты (`services/snapshots/`):** декомпозиция на `repository.py`, `service.py`.
+  - **База знаний и правила (`services/knowledge/`):** вынос правил арбитража и словаря синонимов подразделений.
+  - Фиксация контрольной точки в Gitea.
+- [ ] **Шаг 3: Декомпозиция ETL-конвейера (`main_etl.py` и `scud_export.py`):**
+  - Выделение `services/scud_etl/pipeline.py` (оркестрация без длинных простыней кода).
+  - Выделение `services/scud_etl/merger.py` (чистая склейка Dataframe 1С ⟷ СКУД).
+  - Выделение `services/scud_etl/anomaly_detector.py` (алгоритмическая детекция нарушений).
+  - Выделение `services/scud_etl/sql_queries.py` (вынос длинных T-SQL запросов).
+  - Фиксация контрольной точки в Gitea.
+- [ ] **Шаг 4: Выделение чистого ИИ-оркестратора (`modules/ai_engine/`):**
+  - Создание компактного `agent.py` (~60–80 строк) без ветвлений `if/elif` на сотни строк.
+  - Внедрение изолированных обработчиков инструментов:
+    - `handlers/task_handler.py`
+    - `handlers/prompt_handler.py`
+    - `handlers/snapshot_handler.py`
+    - `handlers/anomaly_handler.py`
+  - Создание `context_builder.py` (календарь, роли, сборка системного контекста).
+  - Фиксация контрольной точки в Gitea.
+- [ ] **Шаг 5: Облегчение `web_api` и адаптация роутеров:**
+  - Превращение `web_api` исключительно в тонкий транспортный шлюз (FastAPI + Статика).
+  - Очистка роутеров от прямого SQL — вызовы только через доменные сервисы.
+  - Рефакторинг CLI-утилиты `scripts/db_cli.py` (вынос форматирования в `scripts/cli/formatters.py`).
+  - Финальное сквозное тестирование и фиксация релиза в Gitea (`v3.0-clean-architecture`).
+
+---
+
+## 9. Диалоговая генерация и контроль отчетов СКУД (Conversational Reporting Engine)
+- [ ] **Инструмент построения сводок (`db_generate_scud_report`):**
+  - Создание инструмента Function Calling для запуска конвейера контроллинга за выбранную дату/снапшот прямо из чата[cite: 4].
+  - Поддержка параметров: `target_date`, `snapshot_id`, `mode` (`summary` — дневная сводка, `detailed` — вчерашний отчет)[cite: 4].
+- [ ] **Интерактивная карточка аудита отчета в UI:**
+  - Вывод статуса генерации, ключевых метрик (всего сотрудников, явка, опоздания, количество аномалий)[cite: 4].
+  - Ссылки на сгенерированные файлы Excel (`.xlsx`) и Markdown (`.md`)[cite: 4].
+- [ ] **Диалоговый разбор аномалий и исключений:**
+  - Возможность в диалоге запросить расшифровку конкретной аномалии[cite: 4].
+  - Быстрое добавление сотрудника/отдела в `exceptions.json` или базу знаний прямо из чата по кнопке карточки[cite: 4].
+- [ ] **Экспорт и отправка среза:**
+  - Команда формирования итоговой выгрузки для руководства в формате PDF/Markdown с передачей файла пользователю[cite: 4].
+
+---
+
+## 10. Изолированная песочница кода (Code Execution Sandbox Engine)
+- [ ] **Docker/gVisor контур:**
+  - Создание изолированного контейнера без доступа к внешней сети (network: none) с ограниченными лимитами по памяти и CPU (cgroups)[cite: 4].
+  - Настройка безопасного монтирования только необходимых CSV/Parquet-файлов данных в режиме Read-Only[cite: 4].
+- [ ] **Динамические Python/Pandas вычисления:**
+  - Инструмент генерации и безопасного выполнения скриптов агрегации и аналитики данных СКУД / 1С на лету[cite: 4].
+  - Перехват stdout/stderr, сбор результатов расчетов и графиков с передачей в UI-чата[cite: 4].

modules/ROADMAP.md

@@ -0,0 +1,56 @@
+# 🗺️ Дорожная карта задач проекта (ROADMAP)
+
+> **Сформировано:** 2026-08-19 18:40 | **Всего задач:** 16
+
+---
+
+## Модуль `api`
+
+- [x] **#35** [HIGH] `[ЗАВЕРШЕНО]` Создание REST API на FastAPI (/api/v1/snapshots, /api/v1/scud/logs, /api/v1/anomalies)
+
+---
+
+## Модуль `core/database`
+
+- [x] **#22** [HIGH] `[ЗАВЕРШЕНО]` Перевод подключения 1С:ЗУП на продакшн MS SQL сервер ACCOUNT-01 + гибридный фоллбэк
+- [x] **#37** [MEDIUM] `[ЗАВЕРШЕНО]` Создание модуля персистентной памяти проекта в SQLite и CLI-инструмента для фиксации архитектурных решений
+
+---
+
+## Модуль `general`
+
+- [x] **#38** [HIGH] `[ЗАВЕРШЕНО]` По запросу, вывести возможности системы, которые уже настроены. Например на запрос о возможностях по СКУД. И изменить стартовую плашку.
+- [ ] **#41** [MEDIUM] Полностью отказаться от tool_injector.py и перевести все вызовы на нативный Function Calling языковой модели. LLM будет основным арбитром *(срок: 2026-08-21)*
+- [ ] **#44** [LOW] Тестовая-3 *(срок: 2026-08-20)*
+
+---
+
+## Модуль `scripts`
+
+- [x] **#26** [MEDIUM] `[ЗАВЕРШЕНО]` Создание и выполнение скрипта сквозной переиндексации снапшотов с префиксом Y
+- [x] **#27** [MEDIUM] `[ЗАВЕРШЕНО]` Реализация CLI-инспектора БД и выравнивание номеров срезов для идеальной верстки в терминале
+- [ ] **#33** [MEDIUM] Автоматизация сбора срезов по расписанию (Cron / Systemd Timers на 12:00, 17:00, 19:00)
+
+---
+
+## Модуль `services/ai_verifier`
+
+- [x] **#28** [HIGH] `[ЗАВЕРШЕНО]` Двойная проверка исключений по department_scud и 1С, удержание 100% приоритета кадровых документов
+
+---
+
+## Модуль `services/scud_export`
+
+- [x] **#23** [HIGH] `[ЗАВЕРШЕНО]` Инцидент Равина В.Э.: Фиксация 100% приоритета сырых логов pLogData СКУД над расчетом УРВ Ориона
+- [x] **#25** [HIGH] `[ЗАВЕРШЕНО]` Исправление бага дублирования номеров снапшотов (переход на вычисление MAX() по суффиксу)
+- [x] **#29** [LOW] `[ЗАВЕРШЕНО]` Лаконичный вывод неразмеченных сотрудников с короткими аббревиатурами отделов СКУД (РУК, ОИЗ, ПУ и др.)
+- [ ] **#30** [HIGH] `[В РАБОТЕ]` Внутридневной контроль: Извлечение полных цепочек проходов pLogData (входы/выходы за смену)
+- [ ] **#31** [HIGH] `[В РАБОТЕ]` Внутридневной контроль: Расчет количества и суммарной длительности отлучек/перекуров сверх обеда
+
+---
+
+## Модуль `services/text_reporter`
+
+- [ ] **#32** [MEDIUM] `[В РАБОТЕ]` Внутридневной контроль: Вывод списка системных нарушителей внутреннего распорядка в Markdown-отчет
+
+---

modules/web_api/llm/agent.py

@@ -2,54 +2,63 @@
 ===============================================================================
 FILE: modules/web_api/llm/agent.py
 PROJECT: SCUD Orion AI (Unified Architecture)
-MODULE: web_api / llm (Core Agent & Function Calling Dispatcher)
+MODULE: web_api / llm (Core Agent Coordinator)
-ROLE: Главный оркестратор взаимодействия с Ollama LLM (Qwen 2.5), разбор вызовов 
+ROLE: Нативный оркестратор диалога, диспетчер инструментов (Function Calling)
-      инструментов (Function Calling), интеграция с декларативным реестром 
+      и управление сессионными стейтами через ContextManager.
-      действий SQLite (tool_action_registry), детерминированный Fast-Path
+
-      для подтверждений, динамические кнопки и автоочистка эфемерных сообщений.
+AI-CONTEXT-ANCHORS:
+  - ANCHOR[AGENT_IMPORTS]: Системные и доменные импорты.
+  - ANCHOR[AGENT_MAIN_PIPELINE]: Основная точка входа process_chat_message.
+  - ANCHOR[AGENT_SYSTEM_PROMPT]: Формирование динамического контекста.
+  - ANCHOR[AGENT_TOOL_DISPATCHER]: Исполнение нативных вызовов инструментов.
+  - ANCHOR[AGENT_TOPIC_DRIFT]: Защита контекста и обработка свободных тем.
 ===============================================================================
 """
 
-# --- [SECTION 1: SYSTEM PATHS & IMPORTS] --- # ANCHOR[SYS_IMPORTS]
+# ANCHOR[AGENT_IMPORTS]
-import os
 import sys
 import json
-import urllib.request
-import urllib.error
 import logging
-import re
 from typing import List, Dict, Any, Tuple, Optional
 
-# Импорт фасада базы данных
+from .db.connection import get_db_connection
 from .db_tools import (
     db_get_active_system_prompt,
-    db_add_system_prompt,
+    db_apply_prompt_node_action,
     db_get_tool_action,
     db_get_tasks,
     db_update_task_status,
     db_delete_task,
     db_add_task,
+    db_tasks_edit,
+    db_export_tasks_markdown,
     db_get_rules,
     db_set_session_state,
     db_get_session_state,
+    db_clear_session_state,
     db_get_snapshots,
     db_delete_snapshots,
-    db_clear_session_state,
     db_get_current_server_time,
     db_save_chat_message,
     db_get_chat_history,
     db_purge_ephemeral_messages,
     db_get_stats,
     db_get_anomalies,
-    db_get_session_states,
     db_get_reference
 )
 
 from .schemas import TOOLS_SCHEMA
-from .core.calendar_utils import get_dynamic_calendar_context, parse_relative_date_ru
+from .core.calendar_utils import get_dynamic_calendar_context
 from .core.tool_injector import clean_raw_tool_tags, clean_output, inject_tools_if_needed
+from .core.ollama_client import call_ollama_chat
+from .core.fast_path import handle_fast_path_intercept
+from .core.context_manager import (
+    save_tool_interaction,
+    save_dialog_interaction,
+    mark_last_user_message_ephemeral,
+    close_tool_session_and_cleanup
+)
 
-# --- [SECTION 2: LOGGING CONFIGURATION] --- # ANCHOR[LOGGING_CONFIG]
 logger = logging.getLogger("SCUD_AGENT")
 logger.setLevel(logging.INFO)
 logger.propagate = False
@@ -60,12 +69,8 @@ if not logger.handlers:
     handler.setFormatter(formatter)
     logger.addHandler(handler)
 
-OLLAMA_URL = "http://192.168.11.3:11434/api/chat"
-TEXT_MODEL = "qwen2.5:14b"
-VISION_MODEL = "qwen2.5vl:7b-q8_0"
 
-
+# ANCHOR[AGENT_MAIN_PIPELINE]
-# --- [SECTION 3: MAIN CHAT PROCESSING PIPELINE] --- # ANCHOR[CHAT_PROCESSOR]
 def process_chat_message(
     user_id: int, 
     user_message: str, 
@@ -75,327 +80,433 @@ def process_chat_message(
     session_id: str = "web_session_main"
 ) -> Tuple[str, List[Dict[str, Any]], Optional[Dict[str, Any]]]:
     """
-    Главный конвейер обработки входящего сообщения:
+    Главный конвейер обработки входящего сообщения чата на базе нативного Function Calling.
-    1. Fast-Path перехват подтверждений/отмен при активном session_state.
-    2. Перехват завершения работы ('нет, закончить настройку') с автоочисткой эфемерных сообщений.
-    3. Формирование системного контекста и вызов Ollama.
-    4. Выполнение вызванного Tool и опрос Data-Driven реестра действий.
-    5. Возврат кортежа: (reply_text, chat_history, action_metadata).
     """
     logger.info(f"Получено сообщение от user_id={user_id}, session_id={session_id}: {user_message}")
     
-    # 3.1. Обогащение текста вложением (при наличии)
-    full_user_content = user_message
-    if file_context:
-        full_user_content = f"{user_message}\n\n[СОДЕРЖИМОЕ ПРИКРЕПЛЕННОГО ФАЙЛА]:\n{file_context}"
-
     session_state = db_get_session_state(session_id)
-    user_msg_clean = user_message.lower().strip(" .!?:;")
+    if not session_state:
+        db_purge_ephemeral_messages(session_id)
 
-    # --- [FAST-PATH 1: ПЕРЕХВАТ ЗАВЕРШЕНИЯ НАСТРОЙКИ С ОЧИСТКОЙ ЭФЕМЕРНОЙ ПАМЯТИ] ---
+    full_user_content = f"{user_message}\n\n[СОДЕРЖИМОЕ ПРИКРЕПЛЕННОГО ФАЙЛА]:\n{file_context}" if file_context else user_message
-    if user_msg_clean in ["нет, спасибо", "нет, закончить настройку", "закончить настройку", "завершить", "нет"]:
-        db_clear_session_state(session_id)
-        deleted_count = db_purge_ephemeral_messages(session_id)
-        logger.info(f"🧹 Завершена работа с инструментом. Удалено эфемерных сообщений: {deleted_count}")
 
-        reply_text = "Хорошо. Настройка завершена, контекст диалога чист. Чем я могу помочь дальше?"
+    # 1. Быстрый перехват строго системных кнопок UI (подтверждение превью промпта)
-        db_save_chat_message(session_id, "assistant", reply_text, is_ephemeral=0)
+    fast_path_res = handle_fast_path_intercept(session_id, user_message, full_user_content, session_state)
-        return reply_text, db_get_chat_history(session_id), None
+    if fast_path_res:
+        return fast_path_res
 
-    # --- [FAST-PATH 2: ПЕРЕХВАТ ПОДТВЕРЖДЕНИЯ / ОТМЕНЫ ПРЕВЬЮ ПРОМПТА] ---
+    # 2. Фиксация сообщения пользователя
-    if session_state and session_state.get("state_type") == "PROMPT_PREVIEW":
+    db_save_chat_message(session_id, "user", full_user_content, is_ephemeral=0)
-        if user_msg_clean in ["подтверждаю", "подтвердить", "да", "сохранить", "применить", "ок", "хорошо"]:
-            db_add_system_prompt("main_agent", session_state.get("pending_data", ""))
-            db_clear_session_state(session_id)
-            
-            action_cfg = db_get_tool_action("db_confirm_prompt_preview")
-            reply_text = action_cfg["success_template"] if action_cfg else "✅ Системный промпт успешно сохранен и применен в базе данных."
-            if action_cfg and action_cfg.get("follow_up_question"):
-                reply_text += f"\n\n{action_cfg['follow_up_question']}"
-            
-            db_save_chat_message(session_id, "user", full_user_content, is_ephemeral=1)
-            db_save_chat_message(session_id, "assistant", reply_text, is_ephemeral=1)
-            return reply_text, db_get_chat_history(session_id), {
-                "type": action_cfg.get("action_type") if action_cfg else "FOLLOW_UP_ACTION",
-                "buttons": action_cfg.get("buttons", []) if action_cfg else []
-            }
-
-        elif user_msg_clean in ["отмена", "отменить", "отклонить", "назад", "стоп"]:
-            db_clear_session_state(session_id)
-            
-            action_cfg = db_get_tool_action("db_cancel_prompt_preview")
-            reply_text = action_cfg["success_template"] if action_cfg else "❌ Изменения системного промпта отменены."
-            if action_cfg and action_cfg.get("follow_up_question"):
-                reply_text += f"\n\n{action_cfg['follow_up_question']}"
-            
-            db_save_chat_message(session_id, "user", full_user_content, is_ephemeral=1)
-            db_save_chat_message(session_id, "assistant", reply_text, is_ephemeral=1)
-            return reply_text, db_get_chat_history(session_id), {
-                "type": action_cfg.get("action_type") if action_cfg else "FOLLOW_UP_ACTION",
-                "buttons": action_cfg.get("buttons", []) if action_cfg else []
-            }
-
-    # 3.2. Сохраняем входящее сообщение в историю диалога
-    is_user_ephemeral = 1 if session_state else 0
-    db_save_chat_message(session_id, "user", full_user_content, is_ephemeral=is_user_ephemeral)
-
-    # 3.3. Извлекаем полную актуальную историю для передачи в LLM
     db_history = db_get_chat_history(session_id, limit=20)
 
-    dynamic_prompt_text = db_get_active_system_prompt()
+    # ANCHOR[AGENT_SYSTEM_PROMPT]
     calendar_context = get_dynamic_calendar_context()
     user_info = f"Пользователь ID={user_id}" if user_id != 0 else "Гость"
 
-    system_prompt_content = (
+    current_state_type = session_state.get("state_type") if session_state else None
-        f"Ты — интеллектуальный ассистент SCUD Orion AI. "
+    state_data = session_state.get("data_json") or {} if session_state else {}
-        f"Ты управляешь задачами, аналитикой СКУД и системными настройками с помощью инструментов (tools).\n\n"
+    if not isinstance(state_data, dict):
-        f"[ОКРУЖЕНИЕ]\n"
+        state_data = {}
-        f"- Пользователь: {user_info}\n"
+    idle_turns = state_data.get("idle_turns", 0)
-        f"- {calendar_context}\n\n"
+
-        f"[ПРАВИЛА ИСПОЛЬЗОВАНИЯ ИНСТРУМЕНТОВ]\n"
+    active_state_context = ""
-        f"1. Для любых изменений системного промпта (добавить, удалить, изменить пункт) ВСЕГДА вызывай функцию db_preview_prompt_merge(prompt_text=...).\n"
+    if current_state_type == "PROMPT_PREVIEW":
-        f"2. Для просмотра системного промпта ВСЕГДА вызывай db_get_system_prompt().\n"
+        active_state_context = (
-        f"3. Для просмотра задач ВСЕГДА вызывай db_get_tasks().\n"
+            "\n[ТЕКУЩИЙ РЕЖИМ: ПРЕДПРОСМОТР СИСТЕМНОГО ПРОМПТА]\n"
-        f"4. Никогда не симулируй выполнение функций в виде обычного текста. Если требуется действие — сразу вызывай соответствующий инструмент.\n\n"
+            "- Открыт предпросмотр изменений промпта. Для любых правок вызывай db_prompt_node_edit.\n"
-        f"[ПРИМЕРЫ ВЫЗОВА ИНСТРУМЕНТОВ]:\n"
+        )
-        f"- Пользователь: 'добавь пункт 3.4. Работать от сюда и до заката.' -> Вызов: db_preview_prompt_merge(prompt_text='3.4. Работать от сюда и до заката.')\n"
+    elif current_state_type == "PROMPT_FOLLOWUP":
-        f"- Пользователь: 'удали пункт 3.4' -> Вызов: db_preview_prompt_merge(prompt_text='3.4')\n"
+        active_state_context = (
-        f"- Пользователь: 'покажи системный промпт' -> Вызов: db_get_system_prompt()\n"
+            "\n[ТЕКУЩИЙ РЕЖИМ: СЕССИЯ РЕДАКТИРОВАНИЯ ПРОМПТА]\n"
-        f"- Пользователь: 'покажи мои задачи' -> Вызов: db_get_tasks()\n\n"
+            "- Оператор просматривает или редактирует системный промпт.\n"
-        f"[ТЕКУЩИЙ АКТИВНЫЙ СИСТЕМНЫЙ ПРОМПТ]:\n{dynamic_prompt_text}"
+            "- На любые команды вида 'удали пункт X.Y' или 'удали X.Y' ТЫ ОБЯЗАН ВЫЗВАТЬ db_prompt_node_edit с action='DELETE', section_id=X, item_id=Y.\n"
+            "- На любые команды 'добавь пункт X.Y ...' вызывай action='ADD'.\n"
+            "- Запрещено путать ADD и DELETE.\n"
+        )
+    elif current_state_type == "SNAPSHOTS_VIEW":
+        active_date = state_data.get("query_date", "выбранную дату")
+        active_state_context = (
+            f"\n[ТЕКУЩИЙ РЕЖИМ: ПРОСМОТР СНАПШОТОВ СКУД]\n"
+            f"- Сейчас на экране отображаются снапшоты за {active_date}.\n"
+            f"- Ты можешь форматировать, фильтровать или анализировать этот текущий срез.\n"
+            f"- Если оператор запрашивает ДРУГУЮ дату или день недели, отличную от {active_date} (например: 'за вчера', 'а за 13.08', 'покажи за сегодня') — "
+            f"ТЫ ОБЯЗАН СРАЗУ ВЫЗВАТЬ db_get_snapshots(date_str=...).\n"
+            f"- Запрещено генерировать текст за другую дату по памяти.\n"
+        )
+    elif current_state_type == "SNAPSHOT_DELETE_CONFIRM":
+        active_state_context = (
+            "\n[ВНИМАНИЕ: ОЖИДАЕТСЯ ПОДТВЕРЖДЕНИЕ УДАЛЕНИЯ СНАПШОТОВ]\n"
+        )
+    elif current_state_type == "TASK_DELETE_CONFIRM":
+        active_state_context = (
+            "\n[ВНИМАНИЕ: ОЖИДАЕТСЯ ПОДТВЕРЖДЕНИЕ УДАЛЕНИЯ ЗАДАЧИ]\n"
         )
 
-    llm_options = {
+    system_prompt_content = (
-        "num_predict": 8192,
+        f"Ты — интеллектуальный ассистент SCUD Orion AI.\n"
-        "num_ctx": 8192,
+        f"Ты управляешь задачами, аналитикой СКУД и системными настройками исключительно через инструменты (tools).\n\n"
-        "temperature": 0.1,
+        f"СТРОГИЕ ПРАВИЛА:\n"
-        "repeat_penalty": 1.1,
+        f"1. К оператору всегда обращайся на Вы.\n"
-        "presence_penalty": 0.5,
+        f"2. Для получения данных всегда вызывай соответствующий инструмент:\n"
-        "top_p": 0.9
+        f"   - Снапшоты и срезы логов СКУД за любые даты и дни недели -> db_get_snapshots\n"
-    }
+        f"   - Удаление снапшотов -> db_delete_snapshots\n"
+        f"   - Задачи и бэклог (просмотр, создание, смена статуса, удаление, экспорт) -> db_get_tasks, db_tasks_edit\n"
+        f"   - Системный промпт -> db_get_system_prompt, db_prompt_node_edit\n"
+        f"   - Аномалии СКУД/1С -> db_get_anomalies\n"
+        f"   - База знаний -> db_get_rules\n"
+        f"   - Статистика БД -> db_get_stats\n"
+        f"   - Справка -> db_get_reference\n"
+        f"3. Запрещено сочинять данные от себя без вызова инструментов.\n\n"
+        f"[СИСТЕМНЫЙ КАЛЕНДАРЬ СЕРВЕРА]\n"
+        f"- Пользователь: {user_info}\n"
+        f"- {calendar_context}\n"
+        f"{active_state_context}"
+    )
 
     user_msg_object = {"role": "user", "content": full_user_content}
 
-    # --- [SECTION 4: ROUTING & OLLAMA PAYLOAD] --- # ANCHOR[PAYLOAD_BUILD]
+    # ANCHOR[AGENT_TOOL_DISPATCHER]
+    try:
         if image_b64:
             user_msg_object["images"] = [image_b64]
             messages = [
-            {"role": "system", "content": "Ты — строгий модуль OCR. Перепиши весь текст с изображения буква в букву без отсебятины."},
+                {"role": "system", "content": "Ты — строгий модуль OCR. Перепиши весь текст с изображения буква в букву."},
                 user_msg_object
             ]
-        payload = {"model": VISION_MODEL, "messages": messages, "stream": False, "options": llm_options}
+            msg = call_ollama_chat(messages, is_vision=True)
         else:
             clean_db_history = [dict(m) for m in db_history]
             for m in clean_db_history:
                 m.pop("images", None)
             messages = [{"role": "system", "content": system_prompt_content}] + clean_db_history + [user_msg_object]
-        payload = {"model": TEXT_MODEL, "messages": messages, "tools": TOOLS_SCHEMA, "stream": False, "options": llm_options}
+            msg = call_ollama_chat(messages, tools=TOOLS_SCHEMA, is_vision=False)
 
-    # --- [SECTION 5: EXECUTION & TOOL ROUTING] --- # ANCHOR[TOOL_ROUTER]
+        raw_text_reply = msg.get("content", "")
-    try:
-        req = urllib.request.Request(
-            OLLAMA_URL, 
-            data=json.dumps(payload).encode("utf-8"), 
-            headers={"Content-Type": "application/json"}
-        )
-        with urllib.request.urlopen(req) as response:
-            res_data = json.loads(response.read().decode("utf-8"))
-            msg = res_data.get("message", {})
         tool_calls = msg.get("tool_calls", [])
-            raw_text_content = msg.get("content", "")
 
-            #tool_calls = inject_tools_if_needed(user_message, raw_text_content, tool_calls)
+        if not tool_calls:
+            tool_calls = inject_tools_if_needed(user_message, raw_text_reply, tool_calls)
 
         if tool_calls:
             logger.info(f"Ответ от Ollama получен. Tool calls: True (кол-во: {len(tool_calls)})")
-                messages.append(msg)
             
-                for tool in tool_calls:
+            tool = tool_calls[0]
             fn_name = tool["function"]["name"]
             fn_args = tool["function"].get("arguments", {})
-                    logger.info(f"🚀 Вызов функции (Tool): {fn_name} с аргументами: {fn_args}")
-                    tool_result_content = ""
-
-                    action_cfg = db_get_tool_action(fn_name)
-                    
-                    if fn_name == "db_confirm_prompt_preview":
-                        if session_state and session_state.get("state_type") == "PROMPT_PREVIEW":
-                            db_add_system_prompt("main_agent", session_state.get("pending_data", ""))
-                            db_clear_session_state(session_id)
-                            
-                            if action_cfg and action_cfg.get("bypass_llm"):
-                                reply_text = action_cfg["success_template"]
-                                if action_cfg.get("follow_up_question"):
-                                    reply_text += f"\n\n{action_cfg['follow_up_question']}"
-                                
-                                is_eph = action_cfg.get("is_ephemeral", 1)
-                                db_save_chat_message(session_id, "assistant", reply_text, is_ephemeral=is_eph)
-                                return reply_text, db_get_chat_history(session_id), {
-                                    "type": action_cfg.get("action_type"),
-                                    "buttons": action_cfg.get("buttons", [])
-                                }
-                            tool_result_content = json.dumps({"status": "success"}, ensure_ascii=False)
-                        else:
-                            err_reply = "⚠️ Нет активного превью для подтверждения."
-                            db_save_chat_message(session_id, "assistant", err_reply, is_ephemeral=1)
-                            return err_reply, db_get_chat_history(session_id), None
-
-                    elif fn_name == "db_cancel_prompt_preview":
-                        db_clear_session_state(session_id)
-                        if action_cfg and action_cfg.get("bypass_llm"):
-                            reply_text = action_cfg["success_template"]
-                            if action_cfg.get("follow_up_question"):
-                                reply_text += f"\n\n{action_cfg['follow_up_question']}"
-                            
-                            is_eph = action_cfg.get("is_ephemeral", 1)
-                            db_save_chat_message(session_id, "assistant", reply_text, is_ephemeral=is_eph)
-                            return reply_text, db_get_chat_history(session_id), {
-                                "type": action_cfg.get("action_type"),
-                                "buttons": action_cfg.get("buttons", [])
-                            }
-                        tool_result_content = json.dumps({"status": "cancelled"}, ensure_ascii=False)
-
-                    elif fn_name == "db_get_snapshots":
-                        snapshots_res = db_get_snapshots(session_id=session_id, date_str=fn_args.get("date_str"), original_user_message=user_message)
-                        tool_result_content = json.dumps(snapshots_res, ensure_ascii=False)
-
-                    elif fn_name == "db_get_current_server_time":
-                        tool_result_content = json.dumps(db_get_current_server_time(), ensure_ascii=False)
-
-                    elif fn_name == "db_get_tasks":
-                        tool_result_content = json.dumps(db_get_tasks(user_id), ensure_ascii=False)
-
-                    elif fn_name in ["db_get_system_prompt", "db_get_system_prompts"]:
-                        tool_result_content = json.dumps({"system_prompt": db_get_active_system_prompt()}, ensure_ascii=False)
-
-                    elif fn_name == "db_get_stats":
-                        tool_result_content = json.dumps(db_get_stats(), ensure_ascii=False)
-
-                    elif fn_name == "db_get_anomalies":
-                        tool_result_content = json.dumps(db_get_anomalies(limit=fn_args.get("limit", 100), date_str=fn_args.get("date_str")), ensure_ascii=False)
-
-                    elif fn_name == "db_get_session_states":
-                        tool_result_content = json.dumps(db_get_session_states(), ensure_ascii=False)
-
-                    elif fn_name == "db_delete_snapshots":
-                        res = db_delete_snapshots(snapshot_id=fn_args.get("snapshot_id"), day_str=fn_args.get("day_str"))
-                        if action_cfg and action_cfg.get("bypass_llm"):
-                            reply_text = action_cfg["success_template"]
-                            if action_cfg.get("follow_up_question"):
-                                reply_text += f"\n\n{action_cfg['follow_up_question']}"
-                            is_eph = action_cfg.get("is_ephemeral", 1)
-                            db_save_chat_message(session_id, "assistant", reply_text, is_ephemeral=is_eph)
-                            return reply_text, db_get_chat_history(session_id), {
-                                "type": action_cfg.get("action_type"),
-                                "buttons": action_cfg.get("buttons", [])
-                            }
-                        tool_result_content = json.dumps(res, ensure_ascii=False)
-
-                    elif fn_name == "db_get_reference":
-                        tool_result_content = json.dumps(db_get_reference(category=fn_args.get("category")), ensure_ascii=False)
-
-                    # --- [SECTION 6: PROMPT MERGE & PREVIEW ENGINE] --- # ANCHOR[PROMPT_MERGE_LOGIC]
-                    elif fn_name == "db_preview_prompt_merge":
-                        proposed_text = fn_args.get("prompt_text") or fn_args.get("proposed_prompt") or ""
             if isinstance(fn_args, str):
-                            proposed_text = fn_args
+                try:
+                    fn_args = json.loads(fn_args)
+                except Exception:
+                    fn_args = {}
 
-                        current_prompt = db_get_active_system_prompt()
+            logger.info(f"Вызов функции (Tool): {fn_name} с аргументами: {fn_args}")
-                        user_msg_lower = user_message.lower()
 
-                        # 1. ОБРАБОТКА УДАЛЕНИЯ ПУНКТА
+            # Ротация контекста: закрываем старую сессию инструмента
-                        if any(w in user_msg_lower for w in ["удали", "стереть", "убрать", "вырежи", "удалить"]):
+            close_tool_session_and_cleanup(session_id, close_reason=f"ACTIVATE_{fn_name}")
-                            target_num_match = re.search(r'\d+(\.\d+)*', user_message)
+            session_state = None
-                            target_num = target_num_match.group(0) if target_num_match else ""
+            mark_last_user_message_ephemeral(session_id)
 
-                            lines = current_prompt.splitlines()
+            # 1. Задачи (Просмотр)
-                            if target_num:
+            if fn_name == "db_get_tasks":
-                                new_lines = [line for line in lines if not line.strip().startswith(f"{target_num}.")]
+                raw_tasks = db_get_tasks(user_id, status=fn_args.get("status"))
-                            else:
+                reply_text = "Вот интерактивный список ваших текущих задач:"
-                                new_lines = lines
+                db_save_chat_message(session_id, "assistant", reply_text, is_ephemeral=1)
-                            proposed_text = "\n".join(new_lines)
+                return reply_text, db_get_chat_history(session_id), {
+                    "type": "TASK_INTERACTIVE_CARD",
+                    "tasks": raw_tasks
+                }
 
-                        # 2. ОБРАБОТКА ДОБАВЛЕНИЯ / ИЗМЕНЕНИЯ ПУНКТА
+            # 2. Единый диспетчер задач
-                        elif proposed_text:
+            elif fn_name in ["db_tasks_edit", "db_add_task", "db_update_task_status", "db_delete_task"]:
-                            if len(proposed_text) < 500:
+                action = fn_args.get("action", "UPDATE").upper()
-                                clean_item = proposed_text.strip()
+                if fn_name == "db_add_task": action = "ADD"
-                                for prefix in ["добавь пункт", "добавить пункт", "вставь пункт", "добавь"]:
+                elif fn_name == "db_delete_task": action = "DELETE"
-                                    if prefix in clean_item.lower():
+                elif fn_name == "db_update_task_status": action = "UPDATE"
-                                        clean_item = re.sub(prefix, "", clean_item, flags=re.IGNORECASE).strip(" .:")
 
-                                lines = current_prompt.splitlines()
+                if action == "DELETE":
-                                new_lines = []
+                    task_id_raw = str(fn_args.get("task_id", "")).replace("#", "").replace("TASK-", "").strip()
-                                inserted = False
+                    db_set_session_state(session_id, "TASK_DELETE_CONFIRM", {"task_id": task_id_raw, "idle_turns": 0})
-                                for line in lines:
+                    reply_text = f"Вы действительно хотите удалить задачу #{task_id_raw}?"
-                                    new_lines.append(line)
+                    db_save_chat_message(session_id, "assistant", reply_text, is_ephemeral=1)
-                                    if "3.3." in line and not inserted:
+                    return reply_text, db_get_chat_history(session_id), {
-                                        item_str = clean_item if re.match(r'^\d+\.\d+\.', clean_item) else f"3.4. {clean_item}"
+                        "type": "TASK_DELETE_CONFIRM",
-                                        new_lines.append(f"   {item_str}")
-                                        inserted = True
-                                if not inserted:
-                                    new_lines.append(f"   {clean_item}")
-                                proposed_text = "\n".join(new_lines)
-
-                        db_set_session_state(session_id, "PROMPT_PREVIEW", proposed_text)
-                        preview_reply = (
-                            f"Ваше изменение успешно предпросмотрено. Полный обновленный системный промпт теперь выглядит так:\n\n"
-                            f"{proposed_text}\n\n"
-                            f"Для применения изменений подтвердите действие («подтверждаю») или отмените («отмена»)."
-                        )
-                        db_save_chat_message(session_id, "assistant", preview_reply, is_ephemeral=1)
-                        return clean_raw_tool_tags(preview_reply), db_get_chat_history(session_id), {
-                            "type": "PROMPT_PREVIEW",
                         "buttons": [
-                                {"label": "Подтвердить", "value": "подтверждаю", "style": "primary"},
+                            {"label": f"Удалить #{task_id_raw}", "value": f"подтверждаю удаление задачи {task_id_raw}", "style": "danger"},
-                                {"label": "Отменить", "value": "отмена", "style": "danger"}
+                            {"label": "Отмена", "value": "отмена", "style": "secondary"}
                         ]
                     }
 
+                elif action == "EXPORT":
+                    export_res = db_export_tasks_markdown(
+                        user_id=user_id, 
+                        filename=fn_args.get("filename"),
+                        status_filter=fn_args.get("status")
+                    )
+                    reply_text = export_res.get("message", "Отчет по задачам успешно экспортирован.")
+                    db_save_chat_message(session_id, "assistant", reply_text, is_ephemeral=0)
+                    
+                    action_payload = None
+                    if export_res.get("status") == "success":
+                        action_payload = {
+                            "type": "FILE_DOWNLOAD_CARD",
+                            "filename": export_res.get("filename"),
+                            "download_url": export_res.get("download_url"),
+                            "tasks_count": export_res.get("tasks_count")
+                        }
+                    return reply_text, db_get_chat_history(session_id), action_payload
+
+                else:
+                    res = db_tasks_edit(
+                        user_id=user_id,
+                        action=action,
+                        task_id=fn_args.get("task_id"),
+                        title=fn_args.get("title"),
+                        priority=fn_args.get("priority", "MEDIUM"),
+                        status=fn_args.get("status"),
+                        module=fn_args.get("module", "general"),
+                        due_date=fn_args.get("due_date")
+                    )
+                    raw_tasks = db_get_tasks(user_id)
+                    reply_text = res.get("message", "Операция над задачами выполнена.")
+                    db_save_chat_message(session_id, "assistant", reply_text, is_ephemeral=1)
+                    return reply_text, db_get_chat_history(session_id), {
+                        "type": "TASK_INTERACTIVE_CARD",
+                        "tasks": raw_tasks
+                    }
+
+            # 3. Системный промпт
+            elif fn_name == "db_get_system_prompt":
+                active_prompt = db_get_active_system_prompt()
+                reply_text = f"Актуальный системный промпт:\n\n{active_prompt}"
+                db_set_session_state(session_id, "PROMPT_FOLLOWUP", {"idle_turns": 0})
+                db_save_chat_message(session_id, "assistant", reply_text, is_ephemeral=1)
+                return reply_text, db_get_chat_history(session_id), None
+
+            elif fn_name == "db_prompt_node_edit":
+                action = str(fn_args.get("action", "ADD")).upper()
+                
+                try:
+                    sec_id = int(str(fn_args.get("section_id", 3)).strip())
+                except Exception:
+                    sec_id = 3
+
+                try:
+                    itm_id = int(str(fn_args.get("item_id", 1)).strip())
+                except Exception:
+                    itm_id = 1
+
+                content = str(fn_args.get("content", "")).strip()
+                baseline_prompt = db_get_active_system_prompt()
+
+                with get_db_connection() as temp_conn:
+                    temp_cursor = temp_conn.cursor()
+                    temp_cursor.execute("""
+                        SELECT section_id, item_id, content 
+                        FROM system_prompt_nodes 
+                        WHERE prompt_name = 'main_agent' AND is_active = 1 
+                        ORDER BY section_id, item_id
+                    """)
+                    existing_nodes = temp_cursor.fetchall()
+
+                nodes_dict = {(sec, itm): txt for sec, itm, txt in existing_nodes}
+                nodes_dict_for_draft = {k: v for k, v in nodes_dict.items() if k != (sec_id, itm_id)} if action == "DELETE" else dict(nodes_dict)
+                if action != "DELETE":
+                    nodes_dict_for_draft[(sec_id, itm_id)] = content
+
+                draft_lines = []
+                curr_sec = None
+                for (s_id, i_id), txt in sorted(nodes_dict_for_draft.items()):
+                    if i_id == 0:
+                        if curr_sec is not None: draft_lines.append("")
+                        draft_lines.append(f"{s_id}. {txt}")
+                        curr_sec = s_id
+                    else:
+                        draft_lines.append(f"   {s_id}.{i_id}. {txt}")
+                merged_prompt = "\n".join(draft_lines)
+
+                diff_lines = []
+                curr_sec = None
+                display_nodes = dict(nodes_dict)
+                if action != "DELETE":
+                    display_nodes[(sec_id, itm_id)] = content
+
+                for (s_id, i_id), txt in sorted(display_nodes.items()):
+                    if i_id == 0:
+                        if curr_sec is not None: diff_lines.append("")
+                        diff_lines.append(f"{s_id}. {txt}")
+                        curr_sec = s_id
+                    else:
+                        if s_id == sec_id and i_id == itm_id:
+                            line_str = f'   <span class="line-through text-rose-600 font-bold bg-rose-50 px-1.5 py-0.5 rounded border border-rose-300 opacity-80">{s_id}.{i_id}. {txt} [УДАЛЕНИЕ]</span>' if action == "DELETE" else f'   <span class="text-rose-600 font-bold bg-rose-50 px-1.5 py-0.5 rounded border border-rose-300">{s_id}.{i_id}. {txt}</span>'
+                        else:
+                            line_str = f"   {s_id}.{i_id}. {txt}"
+                        diff_lines.append(line_str)
+
+                diff_html = "\n".join(diff_lines)
+
+                db_set_session_state(session_id, "PROMPT_PREVIEW", {
+                    "draft_text": merged_prompt,
+                    "action": action,
+                    "section_id": sec_id,
+                    "item_id": itm_id,
+                    "content": content,
+                    "idle_turns": 0
+                })
+
+                preview_reply = f"Предпросмотр изменений системного промпта:\n\n{diff_html}\n\nДля применения подтвердите действие, отредактируйте или отмените."
+                db_save_chat_message(session_id, "assistant", preview_reply, is_ephemeral=1)
+                return preview_reply, db_get_chat_history(session_id), {
+                    "type": "PROMPT_PREVIEW",
+                    "raw_draft": merged_prompt,
+                    "baseline_prompt": baseline_prompt,
+                    "buttons": [
+                        {"label": "Подтвердить", "value": "подтверждаю", "style": "primary"},
+                        {"label": "Отменить", "value": "отмена", "style": "danger"},
+                        {"label": "✏️ Редактировать", "value": "action:open_editor", "style": "secondary"}
+                    ]
+                }
+
+            # 4. Снапшоты СКУД
+            elif fn_name == "db_get_snapshots":
+                snapshots_res = db_get_snapshots(session_id=session_id, date_str=fn_args.get("date_str"), original_user_message=user_message)
+                query_date = snapshots_res.get("query_date", "выбранную дату")
+                reply_text = f"Реестр срезов СКУД за {query_date}:"
+                db_save_chat_message(session_id, "assistant", reply_text, is_ephemeral=1)
+                return reply_text, db_get_chat_history(session_id), {
+                    "type": "SNAPSHOTS_CARD",
+                    "data": snapshots_res
+                }
+
+            elif fn_name == "db_delete_snapshots":
+                raw_id = fn_args.get("snapshot_id") or fn_args.get("day_str")
+                raw_ids = fn_args.get("snapshot_ids") or []
+                is_confirmed = fn_args.get("confirmed", False)
+                
+                if raw_id and not raw_ids:
+                    if isinstance(raw_id, str) and "," in raw_id:
+                        raw_ids = [s.strip() for s in raw_id.split(",")]
+                    else:
+                        raw_ids = [raw_id]
+                
+                safe_ids = [s.strip() for s in raw_ids if s and not str(s).strip().startswith("Y")]
+                if not safe_ids:
+                    reply_text = "⚠️ Итоговый срез Y защищен от удаления. Выберите дневные снапшоты."
+                    db_save_chat_message(session_id, "assistant", reply_text, is_ephemeral=1)
+                    return reply_text, db_get_chat_history(session_id), None
+
+                if not is_confirmed:
+                    query_date = state_data.get("query_date", "")
+                    db_set_session_state(session_id, "SNAPSHOT_DELETE_CONFIRM", {
+                        "snapshot_ids": safe_ids,
+                        "query_date": query_date,
+                        "idle_turns": 0
+                    })
+                    ids_str = ", ".join(safe_ids)
+                    reply_text = f"Вы действительно хотите удалить дневные снапшоты: {ids_str}?"
+                    db_save_chat_message(session_id, "assistant", reply_text, is_ephemeral=1)
+                    return reply_text, db_get_chat_history(session_id), {
+                        "type": "SNAPSHOT_DELETE_CONFIRM",
+                        "buttons": [
+                            {"label": f"Удалить ({len(safe_ids)} шт.)", "value": f"подтверждаю удаление снапшотов {ids_str}", "style": "danger"},
+                            {"label": "Отмена", "value": "отмена", "style": "secondary"}
+                        ]
+                    }
+                else:
+                    db_delete_snapshots(snapshot_ids=safe_ids)
+                    query_date = state_data.get("query_date", "")
+                    updated_snapshots_res = db_get_snapshots(session_id=session_id, date_str=query_date)
+
+                    reply_text = f"✅ Успешно удалено снапшотов: {len(safe_ids)} шт."
+                    db_save_chat_message(session_id, "assistant", reply_text, is_ephemeral=1)
+                    return reply_text, db_get_chat_history(session_id), {
+                        "type": "SNAPSHOTS_CARD",
+                        "data": updated_snapshots_res
+                    }
+                
+            elif fn_name == "db_delete_snapshots":
+                raw_id = fn_args.get("snapshot_id") or fn_args.get("day_str")
+                raw_ids = fn_args.get("snapshot_ids") or ([raw_id] if raw_id else [])
+                
+                # Защита: итоговые Y-срезы удалять запрещено
+                safe_ids = [s for s in raw_ids if not str(s).startswith("Y")]
+                if not safe_ids:
+                    reply_text = "⚠️ Итоговый срез Y защищен от удаления. Выберите дневные снапшоты."
+                    db_save_chat_message(session_id, "assistant", reply_text, is_ephemeral=1)
+                    return reply_text, db_get_chat_history(session_id), None
+
+                # Прямое выполнение удаления в SQLite без лишних текстовых подтверждений
+                del_res = db_delete_snapshots(snapshot_ids=safe_ids)
+                
+                # Получаем свежий реестр за ту же дату
+                query_date = fn_args.get("day_str", "")
+                updated_snapshots_res = db_get_snapshots(session_id=session_id, date_str=query_date)
+
+                reply_text = f"✅ Успешно удалено снапшотов: {len(safe_ids)} шт."
+                db_save_chat_message(session_id, "assistant", reply_text, is_ephemeral=1)
+                return reply_text, db_get_chat_history(session_id), {
+                    "type": "SNAPSHOTS_CARD",
+                    "data": updated_snapshots_res
+                }
+
+            # 5. Сервисные запросы
+            elif fn_name == "db_get_current_server_time":
+                tool_result_content = json.dumps(db_get_current_server_time(), ensure_ascii=False)
+            elif fn_name == "db_get_stats":
+                tool_result_content = json.dumps(db_get_stats(), ensure_ascii=False)
+            elif fn_name == "db_get_anomalies":
+                tool_result_content = json.dumps(db_get_anomalies(limit=fn_args.get("limit", 100), date_str=fn_args.get("date_str")), ensure_ascii=False)
             elif fn_name == "db_get_rules":
                 tool_result_content = json.dumps(db_get_rules(), ensure_ascii=False)
+            elif fn_name == "db_get_reference":
+                tool_result_content = json.dumps(db_get_reference(category=fn_args.get("category")), ensure_ascii=False)
+            else:
+                tool_result_content = "{}"
 
-                    elif fn_name == "db_add_task":
+            messages.append(msg)
-                        res = db_add_task(user_id=user_id, module=fn_args.get("module", "general"), title=fn_args.get("title"), priority=fn_args.get("priority", "MEDIUM"), due_date=fn_args.get("due_date"))
-                        tool_result_content = json.dumps(res, ensure_ascii=False)
-
-                    elif fn_name == "db_update_task_status":
-                        res = db_update_task_status(user_id=user_id, task_id=str(fn_args.get("task_id")), status=fn_args.get("status", "COMPLETED"), due_date=fn_args.get("due_date"))
-                        tool_result_content = json.dumps(res, ensure_ascii=False)
-
-                    elif fn_name == "db_delete_task":
-                        res = db_delete_task(user_id=user_id, task_id=str(fn_args.get("task_id", "")).upper())
-                        if action_cfg and action_cfg.get("bypass_llm"):
-                            reply_text = action_cfg["success_template"]
-                            if action_cfg.get("follow_up_question"):
-                                reply_text += f"\n\n{action_cfg['follow_up_question']}"
-                            is_eph = action_cfg.get("is_ephemeral", 1)
-                            db_save_chat_message(session_id, "assistant", reply_text, is_ephemeral=is_eph)
-                            return reply_text, db_get_chat_history(session_id), {
-                                "type": action_cfg.get("action_type"),
-                                "buttons": action_cfg.get("buttons", [])
-                            }
-                        tool_result_content = json.dumps(res, ensure_ascii=False)
-
             messages.append({"role": "tool", "content": tool_result_content})
+            sec_msg = call_ollama_chat(messages, is_vision=False)
+            raw_content = sec_msg.get("content", "").strip().replace("**", "").replace("*", "")
+            final_content = clean_raw_tool_tags(clean_output(raw_content)) or "Запрос выполнен."
 
-                # --- [SECTION 7: SECONDARY LLM PASS] --- # ANCHOR[SECONDARY_PASS]
+            for artifact in ["почемучка,", "почемучка!", "почемучка?", "почемучка", "почемучто", "почему-то"]:
-                second_payload = {"model": TEXT_MODEL, "messages": messages, "stream": False, "options": llm_options}
+                if final_content.lower().startswith(artifact):
-                sec_req = urllib.request.Request(OLLAMA_URL, data=json.dumps(second_payload).encode("utf-8"), headers={"Content-Type": "application/json"})
+                    final_content = final_content[len(artifact):].lstrip(",.!?:; -")
-                with urllib.request.urlopen(sec_req) as sec_response:
+
-                    sec_res_data = json.loads(sec_response.read().decode("utf-8"))
+            is_ephem = 1 if fn_name in ["db_get_snapshots", "db_get_system_prompt", "db_prompt_node_edit"] else 0
-                    raw_content = sec_res_data.get("message", {}).get("content", "").strip().replace("**", "")
+            db_save_chat_message(session_id, "assistant", final_content, is_ephemeral=is_ephem)
-                    final_content = clean_raw_tool_tags(clean_output(raw_content))
-                    db_save_chat_message(session_id, "assistant", final_content, is_ephemeral=0)
             return final_content, db_get_chat_history(session_id), None
 
-            # Если вызовов функций не было
+        # ANCHOR[AGENT_TOPIC_DRIFT]
-            raw_str = msg.get("content", "").strip().replace("**", "")
+        raw_str = msg.get("content", "").strip().replace("**", "").replace("*", "")
-            content_str = clean_raw_tool_tags(clean_output(raw_str))
+        final_reply = clean_raw_tool_tags(clean_output(raw_str)) or "Запрос обработан."
-            final_reply = content_str or "Запрос обработан."
+        
+        for artifact in ["почемучка,", "почемучка!", "почемучка?", "почемучка", "почемучто", "почему-то"]:
+            if final_reply.lower().startswith(artifact):
+                final_reply = final_reply[len(artifact):].lstrip(",.!?:; -")
+
+        action_payload = None
+
+        if session_state and session_state.get("state_type") in ["PROMPT_FOLLOWUP", "PROMPT_PREVIEW"]:
+            idle_turns += 1
+            if idle_turns > 3:
+                db_clear_session_state(session_id)
+                db_purge_ephemeral_messages(session_id)
+                action_payload = None
+                session_state = None
+            elif idle_turns == 3:
+                tool_action = db_get_tool_action("db_confirm_prompt_preview")
+                guard_question = tool_action.get("follow_up_question", "Желаете продолжить работу с системным промптом?") if tool_action else "Желаете продолжить работу с системным промптом?"
+                buttons = tool_action.get("buttons", []) if tool_action else []
+                final_reply += f"\n\n💡 *Напоминание:* {guard_question}"
+                action_payload = {"type": "PROMPT_FOLLOWUP", "buttons": buttons}
+                db_set_session_state(session_id, "PROMPT_FOLLOWUP", {"idle_turns": idle_turns})
+            else:
+                db_set_session_state(session_id, session_state.get("state_type"), {"idle_turns": idle_turns})
+
         db_save_chat_message(session_id, "assistant", final_reply, is_ephemeral=0)
-            return final_reply, db_get_chat_history(session_id), None
+        return final_reply, db_get_chat_history(session_id), action_payload
 
     except Exception as ex:
-        logger.exception(f"Непредвиденная ошибка: {ex}")
+        logger.exception(f"Непредвиденная ошибка агента: {ex}")
         error_reply = f"Внутренняя ошибка сервера: {ex}"
         return error_reply, db_get_chat_history(session_id), None

modules/web_api/llm/core/context_manager.py

@@ -0,0 +1,64 @@
+"""
+===============================================================================
+FILE: modules/web_api/llm/core/context_manager.py
+PROJECT: SCUD Orion AI (Unified Architecture)
+MODULE: web_api / llm / core
+ROLE: Интеллектуальный менеджер контекста: разделение служебных транзакций
+      инструментов и содержательного диалога с сохранением Topic Drift.
+===============================================================================
+"""
+
+import logging
+from typing import Dict, Any, Optional, List
+
+from ..db.connection import get_db_connection
+from ..db_tools import (
+    db_save_chat_message,
+    db_get_chat_history,
+    db_purge_ephemeral_messages,
+    db_clear_session_state,
+    db_set_session_state
+)
+
+logger = logging.getLogger("CONTEXT_MANAGER")
+
+
+def save_tool_interaction(session_id: str, user_content: str, assistant_reply: str) -> None:
+    """
+    Сохраняет синхронную служебную пару инструмента (и вопрос, и ответ = 1).
+    При очистке удалятся оба сообщения, не оставляя сирот.
+    """
+    db_save_chat_message(session_id, "user", user_content, is_ephemeral=1)
+    db_save_chat_message(session_id, "assistant", assistant_reply, is_ephemeral=1)
+
+
+def save_dialog_interaction(session_id: str, user_content: str, assistant_reply: str) -> None:
+    """
+    Сохраняет содержательный диалог пользователя и ассистента (и вопрос, и ответ = 0).
+    Эти сообщения остаются в истории навсегда (включая Topic Drift).
+    """
+    db_save_chat_message(session_id, "user", user_content, is_ephemeral=0)
+    db_save_chat_message(session_id, "assistant", assistant_reply, is_ephemeral=0)
+
+
+def mark_last_user_message_ephemeral(session_id: str) -> None:
+    """Помечает последнее сообщение пользователя как эфемерное при активации инструмента."""
+    with get_db_connection() as conn:
+        cursor = conn.cursor()
+        cursor.execute("""
+            UPDATE chat_messages 
+            SET is_ephemeral = 1 
+            WHERE id = (SELECT MAX(id) FROM chat_messages WHERE session_id = ? AND role = 'user')
+        """, (session_id,))
+        conn.commit()
+
+
+def close_tool_session_and_cleanup(session_id: str, close_reason: str = "COMPLETED") -> int:
+    """
+    Закрывает сессию инструмента и удаляет ТОЛЬКО служебные карточки/команды.
+    Весь содержательный диалог сохраняется.
+    """
+    db_clear_session_state(session_id)
+    deleted_count = db_purge_ephemeral_messages(session_id)
+    logger.info(f"[ContextManager] Сессия инструмента закрыта ({close_reason}). Очищено служебных сообщений: {deleted_count}")
+    return deleted_count

modules/web_api/llm/core/fast_path.py

@@ -0,0 +1,87 @@
+"""
+FILE: modules/web_api/llm/core/fast_path.py
+ROLE: Детерминированный технический конвейер (НЕ для ИИ-размышлений).
+      Выполняет только кнопки подтверждения для удаления задач, снапшотов и промптов.
+"""
+
+from typing import Dict, Any, Tuple, Optional
+from llm.db_tools import (
+    db_delete_task, 
+    db_get_tasks, 
+    db_delete_snapshots, 
+    db_get_snapshots,
+    db_add_system_prompt,
+    db_apply_prompt_node_action
+)
+from .context_manager import close_tool_session_and_cleanup, save_tool_interaction, save_dialog_interaction
+
+def handle_fast_path_intercept(
+    session_id: str,
+    user_message: str,
+    full_user_content: str,
+    session_state: Optional[Dict[str, Any]]
+) -> Optional[Tuple[str, list, Optional[Dict[str, Any]]]]:
+    
+    if not session_state:
+        return None
+
+    state_type = session_state.get("state_type")
+    msg = user_message.strip().lower()
+
+    # ⭐️ Управление системным промптом (Превью)
+    if state_type == "PROMPT_PREVIEW":
+        state_data = session_state.get("data_json") or {}
+        draft_text = state_data.get("draft_text", "")
+        action = state_data.get("action")
+        sec_id = state_data.get("section_id")
+        itm_id = state_data.get("item_id")
+        content = state_data.get("content", "")
+
+        if msg in ["подтверждаю", "подтвердить", "да", "сохранить", "применить", "ок", "хорошо"]:
+            if action == "MANUAL_EDIT" or not action or sec_id is None:
+                if draft_text:
+                    db_add_system_prompt("main_agent", draft_text)
+            else:
+                db_apply_prompt_node_action(action=action, section_id=sec_id, item_id=itm_id, content=content)
+
+            close_tool_session_and_cleanup(session_id, "PROMPT_APPLIED_SUCCESSFULLY")
+            reply_text = "✅ Изменения системного промпта успешно применены в базе данных."
+            save_tool_interaction(session_id, full_user_content, reply_text)
+            return reply_text, [], None
+
+        elif msg in ["отмена", "отменить", "отклонить"]:
+            close_tool_session_and_cleanup(session_id, "PROMPT_PREVIEW_CANCELLED")
+            reply_text = "❌ Изменения системного промпта отменены."
+            save_dialog_interaction(session_id, full_user_content, reply_text)
+            return reply_text, [], None
+
+    # Удаление снапшотов
+    elif state_type == "SNAPSHOT_DELETE_CONFIRM":
+        state_data = session_state.get("data_json", {})
+        ids = state_data.get("snapshot_ids", [])
+        query_date = state_data.get("query_date", "")
+
+        if msg.startswith("подтверждаю удаление снапшотов"):
+            db_delete_snapshots(snapshot_ids=ids)
+            close_tool_session_and_cleanup(session_id, "SNAPSHOTS_DELETED")
+            updated_data = db_get_snapshots(session_id=session_id, date_str=query_date)
+            return f"✅ Удалено снапшотов: {len(ids)}", [], {"type": "SNAPSHOTS_CARD", "data": updated_data}
+        
+        elif msg == "отмена":
+            close_tool_session_and_cleanup(session_id, "SNAPSHOT_CANCELLED")
+            updated_data = db_get_snapshots(session_id=session_id, date_str=query_date)
+            return "Удаление отменено.", [], {"type": "SNAPSHOTS_CARD", "data": updated_data}
+
+    # Удаление задач
+    elif state_type == "TASK_DELETE_CONFIRM":
+        task_id = session_state.get("data_json", {}).get("task_id")
+        if msg.startswith("подтверждаю удаление задачи"):
+            db_delete_task(1, str(task_id))
+            close_tool_session_and_cleanup(session_id, "TASK_DELETED")
+            return f"Задача #{task_id} удалена.", [], {"type": "TASK_INTERACTIVE_CARD", "tasks": db_get_tasks(1)}
+            
+        elif msg == "отмена":
+            close_tool_session_and_cleanup(session_id, "TASK_CANCELLED")
+            return "Удаление отменено.", [], {"type": "TASK_INTERACTIVE_CARD", "tasks": db_get_tasks(1)}
+
+    return None

modules/web_api/llm/core/ollama_client.py

@@ -0,0 +1,61 @@
+"""
+===============================================================================
+FILE: modules/web_api/llm/core/ollama_client.py
+ROLE: Транспортный клиент HTTP взаимодействия с локальным API Ollama.
+===============================================================================
+"""
+
+# ANCHOR[OLLAMA_CLIENT_IMPORTS]
+import json
+import urllib.request
+import urllib.error
+import logging
+from typing import Dict, Any, Optional
+
+logger = logging.getLogger("OLLAMA_CLIENT")
+
+OLLAMA_URL = "http://192.168.11.3:11434/api/chat"
+TEXT_MODEL = "qwen2.5:14b"
+VISION_MODEL = "qwen2.5vl:7b-q8_0"
+
+LLM_OPTIONS = {
+    "num_predict": 8192,
+    "num_ctx": 8192,
+    "temperature": 0.0,
+    "repeat_penalty": 1.0,
+    "presence_penalty": 0.0,
+    "top_p": 0.9
+}
+
+
+# ANCHOR[OLLAMA_REQUEST_DISPATCHER]
+def call_ollama_chat(
+    messages: list, 
+    tools: Optional[list] = None, 
+    is_vision: bool = False,
+    timeout: int = 120
+) -> Dict[str, Any]:
+    """
+    Отправляет подготовленный массив сообщений в API Ollama.
+    Возвращает разобранный словарь сообщения ответа или генерирует исключение.
+    """
+    model_name = VISION_MODEL if is_vision else TEXT_MODEL
+    payload = {
+        "model": model_name,
+        "messages": messages,
+        "stream": False,
+        "options": LLM_OPTIONS
+    }
+    
+    if tools and not is_vision:
+        payload["tools"] = tools
+
+    req = urllib.request.Request(
+        OLLAMA_URL,
+        data=json.dumps(payload).encode("utf-8"),
+        headers={"Content-Type": "application/json"}
+    )
+
+    with urllib.request.urlopen(req, timeout=timeout) as response:
+        res_data = json.loads(response.read().decode("utf-8"))
+        return res_data.get("message", {})

modules/web_api/llm/core/prompt_merger.py

@@ -0,0 +1,74 @@
+"""
+===============================================================================
+FILE: modules/web_api/llm/core/prompt_merger.py
+PROJECT: SCUD Orion AI (Unified Architecture)
+MODULE: web_api / llm / core
+ROLE: Алгоритмы парсинга, предпросмотра, слияния и визуального выделения правок.
+===============================================================================
+"""
+
+# ANCHOR[PROMPT_MERGER_IMPORTS]
+import re
+import logging
+
+logger = logging.getLogger("PROMPT_MERGER")
+
+
+# ANCHOR[PROMPT_MERGE_ENGINE]
+def build_prompt_preview_merge(current_prompt: str, user_message: str, proposed_text: str) -> str:
+    """
+    Вычисляет результирующий чистый текст промпта для записи в БД.
+    """
+    user_msg_lower = user_message.lower()
+
+    # 1. Сценарий удаления пункта
+    if any(w in user_msg_lower for w in ["удали", "стереть", "убрать", "вырежи", "удалить"]):
+        target_num_match = re.search(r'\d+(\.\d+)*', user_message)
+        target_num = target_num_match.group(0) if target_num_match else ""
+        
+        lines = current_prompt.splitlines()
+        if target_num:
+            new_lines = [line for line in lines if not line.strip().startswith(f"{target_num}.")]
+        else:
+            new_lines = lines
+        return "\n".join(new_lines)
+
+    # 2. Сценарий добавления или замены пункта
+    if proposed_text:
+        if len(proposed_text) < 500:
+            clean_item = proposed_text.strip()
+            for prefix in ["добавь пункт", "добавить пункт", "вставь пункт", "добавь"]:
+                if prefix in clean_item.lower():
+                    clean_item = re.sub(prefix, "", clean_item, flags=re.IGNORECASE).strip(" .:")
+
+            lines = current_prompt.splitlines()
+            new_lines = []
+            inserted = False
+            for line in lines:
+                new_lines.append(line)
+                if "3.3." in line and not inserted:
+                    item_str = clean_item if re.match(r'^\d+\.\d+\.', clean_item) else f"3.4. {clean_item}"
+                    new_lines.append(f"   {item_str}")
+                    inserted = True
+            if not inserted:
+                new_lines.append(f"   {clean_item}")
+            return "\n".join(new_lines)
+
+    return proposed_text or current_prompt
+
+
+def highlight_prompt_diff(old_prompt: str, new_prompt: str) -> str:
+    """
+    Генерирует текст с подсветкой добавленных/измененных строк HTML-классами Tailwind.
+    """
+    old_lines_set = {line.strip() for line in old_prompt.splitlines() if line.strip()}
+    diff_lines = []
+
+    for line in new_prompt.splitlines():
+        if line.strip() and line.strip() not in old_lines_set:
+            # Выделяем новую или измененную строку красным цветом
+            diff_lines.append(f'<span class="text-rose-600 font-bold bg-rose-50 px-1.5 py-0.5 rounded border border-rose-200">{line}</span>')
+        else:
+            diff_lines.append(line)
+
+    return "\n".join(diff_lines)

modules/web_api/llm/core/tool_injector.py

@@ -1,39 +1,37 @@
-import re
+"""
-import json
+===============================================================================
-import logging
+FILE: modules/web_api/llm/core/tool_injector.py
+PROJECT: SCUD Orion AI (Unified Architecture)
+MODULE: web_api / llm / core
+ROLE: Базовая санитарная очистка артефактов без эвристик и регулярных выражений.
+
+AI-CONTEXT-ANCHORS:
+  - ANCHOR[CLEAN_RAW_TOOLS]: Очистка строковых тегов.
+  - ANCHOR[PASS_THROUGH_TOOLS]: Чистый проходной интерфейс инструментов.
+===============================================================================
+"""
+
+# ANCHOR[CLEAN_RAW_TOOLS]
 from typing import List, Dict, Any
 
-logger = logging.getLogger("TOOL_INJECTOR")
 
 def clean_raw_tool_tags(text: str) -> str:
+    """Удаляет только технические теги разметки, если они попали в текст."""
     if not text:
         return ""
-    text = re.sub(r'\{"name":\s*"db_[^}]+\}\s*(</tool_call>)?', '', text)
+    return text.replace("<tool_call>", "").replace("</tool_call>", "").strip()
-    text = re.sub(r'<tool_call>.*?</tool_call>', '', text, flags=re.DOTALL)
+
-    text = re.sub(r'</tool_call>\w*\[\]\(\)', '', text)
-    text = re.sub(r'</tool_call>', '', text)
-    return text.strip()
 
 def clean_output(text: str) -> str:
+    """Возвращает текст ответа без изменения смысла."""
     if not text:
-        return text
+        return ""
-    artifacts = ["почемучто", "почто", "почему что"]
-    lower_text = text.lower()
-    for art in artifacts:
-        if lower_text.startswith(art):
-            text = text[len(art):].lstrip(",.!?:; -")
     return text.strip()
 
+
+# ANCHOR[PASS_THROUGH_TOOLS]
 def inject_tools_if_needed(user_message: str, raw_text_content: str, tool_calls: List[Dict[str, Any]]) -> List[Dict[str, Any]]:
-    if tool_calls:
+    """
-        return tool_calls
+    Чистый сквозной проход: все решения принимает исключительно языковая модель.
-    if '{"name":' in raw_text_content or '<tool_call>' in raw_text_content:
+    """
-        try:
-            match = re.search(r'\{"name":\s*"([^"]+)",\s*"(?:params|arguments|properties)":\s*(\{.*?\})\}', raw_text_content)
-            if match:
-                fn_name = match.group(1)
-                fn_args = json.loads(match.group(2))
-                return [{"function": {"name": fn_name, "arguments": fn_args}}]
-        except Exception as parse_err:
-            logger.debug(f"Ошибка парсинга сырого tool call: {parse_err}")
     return tool_calls

modules/web_api/llm/db/db_prompts.py

@@ -1,6 +1,13 @@
 """
+===============================================================================
 FILE: modules/web_api/llm/db/db_prompts.py
+PROJECT: SCUD Orion AI (Unified Architecture)
+MODULE: web_api / llm / db
+ROLE: Реляционное управление системным промптом (таблица system_prompt_nodes),
+      базой знаний, реестром действий и сессионными стейтами.
+===============================================================================
 """
+import re
 import json
 import logging
 from typing import List, Dict, Any, Optional
@@ -8,16 +15,116 @@ from .connection import get_db_connection
 
 logger = logging.getLogger("DB_PROMPTS")
 
-def db_get_active_system_prompt() -> str:
+
-    conn = get_db_connection()
+def init_prompt_nodes_table():
+    """Создает реляционную таблицу узлов промпта и заполняет базовыми данными."""
+    with get_db_connection() as conn:
         cursor = conn.cursor()
-    cursor.execute("SELECT prompt_text FROM system_prompts WHERE is_active = 1 ORDER BY id DESC LIMIT 1")
+        cursor.execute("""
-    row = cursor.fetchone()
+        CREATE TABLE IF NOT EXISTS system_prompt_nodes (
-    conn.close()
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
-    return row["prompt_text"] if row else "Ты — ИИ-ассистент SCUD Orion AI."
+            prompt_name TEXT DEFAULT 'main_agent',
+            section_id INTEGER NOT NULL,
+            item_id INTEGER NOT NULL,
+            content TEXT NOT NULL,
+            is_active INTEGER DEFAULT 1,
+            updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+            UNIQUE(prompt_name, section_id, item_id)
+        );
+        """)
+        cursor.execute("CREATE INDEX IF NOT EXISTS idx_prompt_nodes ON system_prompt_nodes(prompt_name, section_id, item_id);")
+        
+        cursor.execute("SELECT COUNT(*) FROM system_prompt_nodes WHERE prompt_name = 'main_agent'")
+        if cursor.fetchone()[0] == 0:
+            seed_nodes = [
+                # Раздел 1
+                (1, 0, "РОЛЬ И ЗАДАЧИ АССИСТЕНТА"),
+                (1, 1, "Управление бэклогом задач проекта (через db_get_tasks, db_add_task, db_update_task_status, db_delete_task)."),
+                (1, 2, "Консультация по правилам и арбитражу кадровых данных/СКУД из базы знаний (через db_get_rules)."),
+                (1, 3, "Предоставление справки о возможностях и примерах команд (СТРОГО через db_get_reference)."),
+                (1, 4, "Просмотр аномалий СКУД ⟷ 1С (СТРОГО через db_get_anomalies)."),
+                (1, 5, "Поддержка диалога с операторами и администраторами системы."),
+                (1, 7, "Работа с логами, снапшотами и срезами СКУД (через db_get_snapshots)."),
+                
+                # Раздел 2
+                (2, 0, "ПРАВИЛА ВЫЗОВА ИНСТРУМЕНТОВ И ДАТ"),
+                (2, 1, "ОБЯЗАТЕЛЬНЫЙ ПРЕВЬЮ-МЕРДЖ: Категорически ЗАПРЕЩЕНО изменять промпт напрямую! При ЛЮБОМ запросе пользователя на изменение системного промпта Ты ОБЯЗАН вызвать инструмент db_prompt_node_edit."),
+                (2, 2, "БЕЗУСЛОВНОЕ ПОДТВЕРЖДЕНИЕ ПРЕВЬЮ: Инструмент db_confirm_prompt_preview вызывается СТРОГО после того, как пользователь напишет 'подтверждаю', 'да', 'сохраняй'."),
+                (2, 3, "ПОДТВЕРЖДЕНИЕ УДАЛЕНИЯ ЗАДАЧ: При запросе на удаление задач КАТЕГОРИЧЕСКИ ЗАПРЕЩЕНО сразу вызывать db_delete_task! Ты ОБЯЗАН сначала спросить пользователя подтверждение."),
+                (2, 4, "ИСПОЛЬЗОВАНИЕ КАЛЕНДАРЯ: При любых вопросах про даты БЕРИ ТОЧНУЮ ДАТУ ИЗ [СИСТЕМНОГО КАЛЕНДАРЯ СЕРВЕРА] В НАЧАЛЕ КОНТЕКСТА."),
+                (2, 5, "СТРОГИЙ ВЫЗОВ АНОМАЛИЙ: При запросах аномалий или нарушений Ты ОБЯЗАН вызвать инструмент db_get_anomalies."),
+                (2, 6, "СТРОГИЙ ВЫЗОВ СПРАВОЧНИКА: При запросах о возможностях, примерах запросов или командах Ты ОБЯЗАН вызывать db_get_reference."),
+                (2, 7, "Запрещено писать названия функций или код вызова текстом на экран."),
+                (2, 8, "СТРОГИЙ ВЫЗОВ СНАПШОТОВ: При ЛЮБЫХ запросах про снапшоты, срезы или логи СКУД за дату/день недели Ты ОБЯЗАН вызывать инструмент db_get_snapshots."),
+                
+                # Раздел 3
+                (3, 0, "ПРАВИЛА СТИЛЯ"),
+                (3, 1, "Никогда не начинай ответ со склеек или слов-паразитов."),
+                (3, 2, "Отвечай в чистом текстовом формате (plain text) без спецсимволов или ###, если прямо не попросили."),
+                (3, 3, "Сохраняй инженерный, лаконичный и профессиональный стиль.")
+            ]
+            cursor.executemany("""
+                INSERT OR IGNORE INTO system_prompt_nodes (prompt_name, section_id, item_id, content)
+                VALUES ('main_agent', ?, ?, ?)
+            """, seed_nodes)
+        conn.commit()
+
+
+def db_get_active_system_prompt(prompt_name: str = "main_agent") -> str:
+    """Собирает структурированный текст промпта из реляционной таблицы узлов."""
+    init_prompt_nodes_table()
+    with get_db_connection() as conn:
+        cursor = conn.cursor()
+        cursor.execute("""
+            SELECT section_id, item_id, content 
+            FROM system_prompt_nodes 
+            WHERE prompt_name = ? AND is_active = 1
+            ORDER BY section_id ASC, item_id ASC
+        """, (prompt_name,))
+        rows = cursor.fetchall()
+        
+    if not rows:
+        return "Ты — ИИ-ассистент SCUD Orion AI."
+
+    lines = []
+    current_section = None
+
+    for sec_id, itm_id, content in rows:
+        if itm_id == 0:
+            if current_section is not None:
+                lines.append("")
+            lines.append(f"{sec_id}. {content}")
+            current_section = sec_id
+        else:
+            lines.append(f"   {sec_id}.{itm_id}. {content}")
+
+    return "\n".join(lines)
+
+
+def db_apply_prompt_node_action(action: str, section_id: int, item_id: int, content: str = "", prompt_name: str = "main_agent"):
+    """Прямое добавление, изменение или удаление узла в БД."""
+    init_prompt_nodes_table()
+    with get_db_connection() as conn:
+        cursor = conn.cursor()
+        action_clean = action.upper()
+        if action_clean in ["ADD", "UPDATE"]:
+            cursor.execute("""
+                INSERT INTO system_prompt_nodes (prompt_name, section_id, item_id, content, is_active, updated_at)
+                VALUES (?, ?, ?, ?, 1, CURRENT_TIMESTAMP)
+                ON CONFLICT(prompt_name, section_id, item_id) DO UPDATE SET
+                    content = excluded.content,
+                    is_active = 1,
+                    updated_at = CURRENT_TIMESTAMP
+            """, (prompt_name, section_id, item_id, content))
+        elif action_clean == "DELETE":
+            cursor.execute("""
+                DELETE FROM system_prompt_nodes 
+                WHERE prompt_name = ? AND section_id = ? AND item_id = ?
+            """, (prompt_name, section_id, item_id))
+        conn.commit()
+
 
 def db_get_tool_action(tool_name: str) -> Optional[Dict[str, Any]]:
-    """Получение шаблона, кнопок и настроек эфемерности инструмента из SQLite."""
     conn = get_db_connection()
     cursor = conn.cursor()
     cursor.execute("""
@@ -35,28 +142,6 @@ def db_get_tool_action(tool_name: str) -> Optional[Dict[str, Any]]:
         return res
     return None
 
-def db_add_system_prompt(name: str, prompt_text: str) -> Dict[str, Any]:
-    try:
-        with get_db_connection() as conn:
-            cursor = conn.cursor()
-            cursor.execute("BEGIN IMMEDIATE;")
-            cursor.execute("SELECT id FROM system_prompts WHERE name = ?", (name,))
-            existing = cursor.fetchone()
-            if existing:
-                cursor.execute(
-                    "UPDATE system_prompts SET prompt_text = ?, is_active = 1, updated_at = CURRENT_TIMESTAMP WHERE name = ?",
-                    (prompt_text, name)
-                )
-            else:
-                cursor.execute(
-                    "INSERT INTO system_prompts (name, prompt_text, is_active) VALUES (?, ?, 1)",
-                    (name, prompt_text)
-                )
-            conn.commit()
-        return {"status": "success", "message": "Системный промпт успешно обновлен"}
-    except Exception as e:
-        logger.error(f"Ошибка при сохранении промпта в БД: {e}")
-        return {"status": "error", "error": str(e)}
 
 def db_get_rules() -> List[Dict[str, Any]]:
     conn = get_db_connection()
@@ -66,9 +151,12 @@ def db_get_rules() -> List[Dict[str, Any]]:
     conn.close()
     return [dict(r) for r in rows]
 
-def db_set_session_state(session_id: str, state_type: str, data: str):
+
+def db_set_session_state(session_id: str, state_type: str, data: Any) -> None:
+    """Сохраняет состояние сессии в SQLite."""
     conn = get_db_connection()
     cursor = conn.cursor()
+    payload_str = json.dumps(data, ensure_ascii=False) if isinstance(data, (dict, list)) else (str(data) if data is not None else "")
     cursor.execute("""
         INSERT INTO session_states (session_id, state_type, pending_data, updated_at)
         VALUES (?, ?, ?, CURRENT_TIMESTAMP)
@@ -76,37 +164,40 @@ def db_set_session_state(session_id: str, state_type: str, data: str):
             state_type = excluded.state_type,
             pending_data = excluded.pending_data,
             updated_at = CURRENT_TIMESTAMP
-    """, (session_id, state_type, data))
+    """, (session_id, state_type, payload_str))
     conn.commit()
     conn.close()
 
+
 def db_get_session_state(session_id: str) -> Optional[Dict[str, Any]]:
     conn = get_db_connection()
     cursor = conn.cursor()
-    cursor.execute("SELECT state_type, pending_data FROM session_states WHERE session_id = ?", (session_id,))
+    cursor.execute("SELECT session_id, state_type, pending_data, updated_at FROM session_states WHERE session_id = ?", (session_id,))
     row = cursor.fetchone()
     conn.close()
-    return dict(row) if row else None
+    if not row:
+        return None
+    res = dict(row)
+    raw_data = res.get("pending_data") or ""
+    try:
+        res["data_json"] = json.loads(raw_data) if raw_data.strip().startswith(("{", "[")) else None
+    except Exception:
+        res["data_json"] = None
+    return res
 
-def db_clear_session_state(session_id: str):
+
+def db_clear_session_state(session_id: str) -> None:
     conn = get_db_connection()
     cursor = conn.cursor()
     cursor.execute("DELETE FROM session_states WHERE session_id = ?", (session_id,))
     conn.commit()
     conn.close()
 
-def db_get_session_states() -> Dict[str, Any]:
-    conn = get_db_connection()
-    cursor = conn.cursor()
-    cursor.execute("SELECT session_id, state_type, updated_at FROM session_states")
-    rows = cursor.fetchall()
-    conn.close()
-    return {"status": "success", "active_sessions": [dict(r) for r in rows]}
 
 def db_get_stats() -> Dict[str, Any]:
     conn = get_db_connection()
     cursor = conn.cursor()
-    tables = ['scud_logs', 'zup_staff', 'zup_absences', 'anomalies_history', 'ai_knowledge_base', 'system_prompts', 'session_states', 'tasks']
+    tables = ['scud_logs', 'zup_staff', 'zup_absences', 'anomalies_history', 'ai_knowledge_base', 'system_prompt_nodes', 'session_states', 'tasks']
     stats = {}
     for t in tables:
         try:
@@ -117,6 +208,7 @@ def db_get_stats() -> Dict[str, Any]:
     conn.close()
     return {"status": "success", "tables_stats": stats}
 
+
 def db_get_anomalies(limit: int = 100, date_str: Optional[str] = None) -> Dict[str, Any]:
     conn = get_db_connection()
     cursor = conn.cursor()
@@ -132,6 +224,7 @@ def db_get_anomalies(limit: int = 100, date_str: Optional[str] = None) -> Dict[s
     conn.close()
     return {"status": "success", "count": len(rows), "anomalies": [dict(r) for r in rows]}
 
+
 def db_get_reference(category: Optional[str] = None) -> Dict[str, Any]:
     conn = get_db_connection()
     cursor = conn.cursor()
@@ -145,3 +238,48 @@ def db_get_reference(category: Optional[str] = None) -> Dict[str, Any]:
     rows = cursor.fetchall()
     conn.close()
     return {"status": "success", "count": len(rows), "reference_items": [dict(r) for r in rows]}
+
+def db_add_system_prompt(name: str, prompt_text: str) -> Dict[str, Any]:
+    """Надежный парсер: восстанавливает разделы и пункты с авто-выравниванием отступов."""
+    try:
+        init_prompt_nodes_table()
+        with get_db_connection() as conn:
+            cursor = conn.cursor()
+            cursor.execute("DELETE FROM system_prompt_nodes WHERE prompt_name = ?", (name,))
+            
+            current_sec = 1
+            current_itm = 0
+            
+            for raw_line in prompt_text.splitlines():
+                clean_line = re.sub(r'<[^>]+>', '', raw_line).strip()
+                if not clean_line:
+                    continue
+
+                # 1. Проверяем подпункт (например: "1.8. Текст", "1.8 Текст", "1. 8 Текст")
+                sub_match = re.match(r'^(\d+)[\.\s]+(\d+)[\.\s\:\-]+(.*)$', clean_line)
+                # 2. Проверяем заголовок раздела (например: "1. РОЛЬ И ЗАДАЧИ", "1 РОЛЬ И ЗАДАЧИ")
+                sec_match = re.match(r'^(\d+)[\.\s\:\-]+(.*)$', clean_line)
+
+                if sub_match:
+                    current_sec = int(sub_match.group(1))
+                    current_itm = int(sub_match.group(2))
+                    content = sub_match.group(3).strip()
+                elif sec_match and not any(c.islower() for c in sec_match.group(2)[:15]):
+                    # Заголовок раздела (обычно капсом)
+                    current_sec = int(sec_match.group(1))
+                    current_itm = 0
+                    content = sec_match.group(2).strip()
+                else:
+                    current_itm += 1
+                    content = clean_line
+
+                cursor.execute("""
+                    INSERT OR REPLACE INTO system_prompt_nodes (prompt_name, section_id, item_id, content, is_active)
+                    VALUES (?, ?, ?, ?, 1)
+                """, (name, current_sec, current_itm, content))
+            
+            conn.commit()
+        return {"status": "success", "message": "Системный промпт успешно сохранен по узлам"}
+    except Exception as e:
+        logger.error(f"Ошибка при разборе промпта в узлы: {e}")
+        return {"status": "error", "error": str(e)}

modules/web_api/llm/db/db_snapshots.py

@@ -1,49 +1,112 @@
 """
+===============================================================================
 FILE: modules/web_api/llm/db/db_snapshots.py
+PROJECT: SCUD Orion AI (Unified Architecture)
+MODULE: web_api / llm / db
+ROLE: Выборка, фильтрация и пакетное удаление срезов логов СКУД в SQLite.
+
+AI-CONTEXT-ANCHORS:
+  - ANCHOR[DB_GET_SNAPSHOTS]: Выборка снапшотов с нормализацией дат.
+  - ANCHOR[DB_DEL_SNAPSHOTS]: Удаление снапшотов по ID, списку ID или за дату.
+===============================================================================
 """
+
 import json
-from typing import Dict, Any, Optional
+import re
+from typing import Dict, Any, Optional, List
 from .connection import get_db_connection
 from .db_prompts import db_set_session_state
+from ..core.calendar_utils import parse_relative_date_ru
 
+# ANCHOR[DB_GET_SNAPSHOTS]
 def db_get_snapshots(session_id: str = "web_session_main", date_str: Optional[str] = None, original_user_message: str = "") -> Dict[str, Any]:
     conn = get_db_connection()
     cursor = conn.cursor()
-    query = "SELECT snapshot_id, log_date, snapshot_time, COUNT(*) as record_count FROM scud_logs "
+    
+    query = """
+        SELECT 
+            snapshot_id, 
+            log_date, 
+            snapshot_time, 
+            COUNT(*) as record_count 
+        FROM scud_logs 
+    """
     params = []
-    if date_str:
+    
-        iso_date = date_str
+    clean_date = date_str.strip() if date_str else ""
-        if "." in date_str:
+    if not clean_date or not re.search(r'\d{2}\.\d{2}\.\d{4}', clean_date):
-            parts = date_str.split(".")
+        if original_user_message:
+            clean_date = parse_relative_date_ru(original_user_message)
+
+    if clean_date and re.search(r'\d{2}\.\d{2}\.\d{4}', clean_date):
+        iso_date = clean_date
+        compact_date = clean_date.replace(".", "")
+        
+        if "." in clean_date:
+            parts = clean_date.split(".")
             if len(parts) == 3:
                 iso_date = f"{parts[2]}-{parts[1]}-{parts[0]}"
-        query += " WHERE log_date = ? OR log_date = ? OR snapshot_time LIKE ? "
+                compact_date = f"{parts[2]}{parts[1]}{parts[0]}"
-        params.extend([date_str, iso_date, f"{iso_date}%"])
+                
+        query += """
+            WHERE log_date = ? 
+               OR snapshot_time LIKE ? 
+               OR snapshot_id LIKE ? 
+               OR snapshot_id LIKE ?
+        """
+        params.extend([clean_date, f"{iso_date}%", f"{compact_date}-%", f"Y{compact_date}-%"])
+        
+    query += """
+        GROUP BY snapshot_id, log_date, snapshot_time 
+        ORDER BY snapshot_time DESC, snapshot_id DESC 
+        LIMIT 50
+    """
     
-    query += " GROUP BY snapshot_id ORDER BY id DESC LIMIT 50"
     cursor.execute(query, params)
     rows = cursor.fetchall()
     snapshots = [dict(r) for r in rows]
     
     result_data = {
-        "query_date": date_str or "все",
+        "query_date": clean_date or "все",
         "snapshots_count": len(snapshots),
         "snapshots": snapshots
     }
-    db_set_session_state(session_id=session_id, state_type="SNAPSHOTS_VIEW", data=json.dumps(result_data, ensure_ascii=False))
+    db_set_session_state(session_id=session_id, state_type="SNAPSHOTS_VIEW", data=result_data)
     conn.close()
     return result_data
 
-def db_delete_snapshots(snapshot_id: Optional[str] = None, day_str: Optional[str] = None) -> Dict[str, Any]:
+# ANCHOR[DB_DEL_SNAPSHOTS]
-    if not snapshot_id and not day_str:
+def db_delete_snapshots(
-        return {"status": "error", "message": "Необходимо указать snapshot_id или day_str (ДД.ММ.ГГГГ)."}
+    snapshot_id: Optional[str] = None, 
+    snapshot_ids: Optional[List[str]] = None, 
+    day_str: Optional[str] = None
+) -> Dict[str, Any]:
+    """Удаляет один или группу дневных снапшотов с защитой итоговых Y-снапшотов."""
     conn = get_db_connection()
     cursor = conn.cursor()
-    if snapshot_id:
+    deleted = 0
-        cursor.execute("DELETE FROM scud_logs WHERE snapshot_id = ?", (snapshot_id,))
+
-    else:
+    if snapshot_ids and isinstance(snapshot_ids, list):
-        cursor.execute("DELETE FROM scud_logs WHERE log_date = ? OR snapshot_id LIKE ?", (day_str, f"%{day_str.replace('.', '')}%"))
+        # Исключаем любые итоговые снапшоты, начинающиеся с Y
+        safe_ids = [s.strip() for s in snapshot_ids if s and not str(s).strip().startswith("Y")]
+        if safe_ids:
+            placeholders = ",".join(["?"] * len(safe_ids))
+            cursor.execute(f"DELETE FROM scud_logs WHERE snapshot_id IN ({placeholders})", safe_ids)
             deleted = cursor.rowcount
+    elif snapshot_id:
+        clean_id = str(snapshot_id).strip()
+        if clean_id.startswith("Y"):
+            conn.close()
+            return {"status": "error", "message": f"Итоговый срез [{clean_id}] защищен от удаления."}
+        cursor.execute("DELETE FROM scud_logs WHERE snapshot_id = ?", (clean_id,))
+        deleted = cursor.rowcount
+    elif day_str:
+        cursor.execute("DELETE FROM scud_logs WHERE (log_date = ? OR snapshot_id LIKE ?) AND snapshot_id NOT LIKE 'Y%'", (day_str, f"%{day_str.replace('.', '')}%"))
+        deleted = cursor.rowcount
+    else:
+        conn.close()
+        return {"status": "error", "message": "Не указаны идентификаторы для удаления."}
+
     conn.commit()
     conn.close()
-    return {"status": "success", "message": f"Успешно удалено записей: {deleted}"}
+    return {"status": "success", "deleted_records": deleted, "message": f"Успешно удалено записей: {deleted}"}

modules/web_api/llm/db/db_tasks.py

@@ -1,82 +1,297 @@
 """
+===============================================================================
 FILE: modules/web_api/llm/db/db_tasks.py
+PROJECT: SCUD Orion AI (Unified Architecture)
+MODULE: web_api / llm / db
+ROLE: Комплексное управление задачами, единый диспетчер db_tasks_edit
+      и генерация структурированных отчетов в Markdown.
+===============================================================================
 """
+
+import uuid
+import logging
+import os
 import re
+from datetime import datetime
 from typing import List, Dict, Any, Optional
 from .connection import get_db_connection
 
+logger = logging.getLogger("DB_TASKS")
+
 def normalize_task_id(task_id_input: str) -> str:
+    """Нормализует идентификатор задачи к формату TASK-XX."""
     if not task_id_input:
         return ""
-    clean_id = str(task_id_input).strip().upper().replace("TASK-", "").replace("TASK", "")
+    clean_id = str(task_id_input).strip().upper().replace("TASK-", "").replace("TASK", "").replace("#", "")
     if clean_id.isdigit():
         num = int(clean_id)
         return f"TASK-{(num):02d}" if num < 100 else f"TASK-{(num):03d}"
     return f"TASK-{clean_id}"
 
-def db_get_tasks(user_id: int) -> List[Dict[str, Any]]:
+def db_get_tasks(user_id: int, status: Optional[str] = None) -> List[Dict[str, Any]]:
+    """Получает список всех задач пользователя."""
     conn = get_db_connection()
     cursor = conn.cursor()
+    
+    if status and status.upper() != "ALL":
+        target_status = status.upper()
+        if target_status in ["PROGRESS", "В РАБОТЕ"]: target_status = "IN_PROGRESS"
+        elif target_status in ["DONE", "ГОТОВО"]: target_status = "COMPLETED"
+        elif target_status in ["PLANNED", "ПЛАНЫ"]: target_status = "BACKLOG"
+        
+        cursor.execute("""
+            SELECT id, task_id, module, title, priority, status, due_date, created_at 
+            FROM tasks 
+            WHERE user_id = ? AND (status = ? OR (status = 'BACKLOG' AND ? = 'PLANNED'))
+            ORDER BY id DESC
+        """, (user_id, target_status, target_status))
+    else:
         cursor.execute("""
             SELECT id, task_id, module, title, priority, status, due_date, created_at 
             FROM tasks 
             WHERE user_id = ?
             ORDER BY id DESC
         """, (user_id,))
+        
     rows = cursor.fetchall()
     conn.close()
     return [dict(r) for r in rows]
 
-def db_add_task(user_id: int, module: str, title: str, priority: str = "MEDIUM", due_date: Optional[str] = None) -> Dict[str, Any]:
+def db_add_task(
+    user_id: int, 
+    module: str, 
+    title: str, 
+    priority: str = "MEDIUM", 
+    due_date: Optional[str] = None,
+    status: str = "BACKLOG"
+) -> Dict[str, Any]:
+    """Добавление новой задачи со статусом по умолчанию BACKLOG (В планах)."""
     conn = get_db_connection()
     cursor = conn.cursor()
     cursor.execute("SELECT MAX(id) FROM tasks")
     max_id = cursor.fetchone()[0] or 0
     new_task_id = f"TASK-{(max_id + 1):02d}"
 
+    target_status = status.upper() if status else "BACKLOG"
+    if target_status in ["PROGRESS", "В РАБОТЕ"]: target_status = "IN_PROGRESS"
+    elif target_status in ["DONE", "ГОТОВО"]: target_status = "COMPLETED"
+    elif target_status in ["PLANNED", "ПЛАНЫ", "BACKLOG"]: target_status = "BACKLOG"
+
     cursor.execute("""
         INSERT INTO tasks (task_id, module, title, priority, status, due_date, user_id)
-        VALUES (?, ?, ?, ?, 'BACKLOG', ?, ?)
+        VALUES (?, ?, ?, ?, ?, ?, ?)
-    """, (new_task_id, module, title, priority.upper(), due_date, user_id))
+    """, (new_task_id, module or "general", title.strip(), priority.upper(), target_status, due_date, user_id))
     conn.commit()
     conn.close()
-    return {"status": "success", "task_id": new_task_id, "message": f"Задача {new_task_id} создана"}
+    return {"status": "success", "task_id": new_task_id, "message": f"Задача #{max_id + 1} создана и добавлена в планы"}
 
 def db_update_task_status(user_id: int, task_id: str, status: str = "COMPLETED", due_date: Optional[str] = None) -> Dict[str, Any]:
+    """Быстрое обновление статуса задачи."""
+    return db_update_task_details(user_id=user_id, task_id=task_id, status=status, due_date=due_date)
+
+def db_update_task_details(
+    user_id: int, 
+    task_id: str, 
+    title: Optional[str] = None, 
+    priority: Optional[str] = None, 
+    status: Optional[str] = None, 
+    due_date: Optional[str] = None
+) -> Dict[str, Any]:
+    """Комплексное обновление любых параметров задачи."""
     conn = get_db_connection()
     cursor = conn.cursor()
+    
+    clean_num = re.sub(r'\D', '', str(task_id))
     formatted_id = normalize_task_id(task_id)
-    if due_date:
+
-        cursor.execute("""
+    updates = []
+    params = []
+
+    if title is not None and title.strip():
+        updates.append("title = ?")
+        params.append(title.strip())
+
+    if priority is not None and priority.strip():
+        updates.append("priority = ?")
+        params.append(priority.strip().upper())
+
+    if status is not None and status.strip():
+        target_status = status.strip().upper()
+        if target_status in ["PROGRESS", "В РАБОТЕ"]: target_status = "IN_PROGRESS"
+        elif target_status in ["DONE", "ГОТОВО"]: target_status = "COMPLETED"
+        elif target_status in ["PLANNED", "ПЛАНЫ"]: target_status = "BACKLOG"
+        updates.append("status = ?")
+        params.append(target_status)
+
+    if due_date is not None:
+        updates.append("due_date = ?")
+        params.append(due_date.strip() if due_date.strip() else None)
+
+    if not updates:
+        conn.close()
+        return {"status": "success", "message": "Нет данных для обновления"}
+
+    params.extend([clean_num, formatted_id, f"%{task_id.strip()}", user_id])
+    sql = f"""
         UPDATE tasks 
-            SET status = ?, due_date = ? 
+        SET {', '.join(updates)} 
-            WHERE (UPPER(task_id) = ? OR task_id LIKE ?) AND user_id = ?
+        WHERE (id = ? OR UPPER(task_id) = ? OR task_id LIKE ?) AND user_id = ?
-        """, (status.upper(), due_date, formatted_id, f"%{task_id.strip()}", user_id))
+    """
-    else:
+    cursor.execute(sql, params)
-        cursor.execute("""
-            UPDATE tasks 
-            SET status = ? 
-            WHERE (UPPER(task_id) = ? OR task_id LIKE ?) AND user_id = ?
-        """, (status.upper(), formatted_id, f"%{task_id.strip()}", user_id))
 
     if cursor.rowcount == 0:
         conn.close()
         return {"error": f"Задача {task_id} не найдена или принадлежит другому пользователю"}
+        
     conn.commit()
     conn.close()
-    return {"status": "success", "message": f"Статус задачи {formatted_id} обновлен на {status.upper()}"}
+    return {"status": "success", "message": f"Задача #{task_id} успешно обновлена"}
 
 def db_delete_task(user_id: int, task_id: str) -> Dict[str, Any]:
+    """Удаление задачи."""
     conn = get_db_connection()
     cursor = conn.cursor()
+    clean_num = re.sub(r'\D', '', str(task_id))
     formatted_id = normalize_task_id(task_id)
+    
     cursor.execute("""
         DELETE FROM tasks 
-        WHERE (UPPER(task_id) = ? OR task_id LIKE ?) AND user_id = ?
+        WHERE (id = ? OR UPPER(task_id) = ? OR task_id LIKE ?) AND user_id = ?
-    """, (formatted_id, f"%{task_id.strip()}", user_id))
+    """, (clean_num, formatted_id, f"%{task_id.strip()}", user_id))
+    
     if cursor.rowcount == 0:
         conn.close()
         return {"error": f"Задача {task_id} не найдена"}
     conn.commit()
     conn.close()
-    return {"status": "success", "message": f"Задача {formatted_id} удалена"}
+    return {"status": "success", "message": f"Задача #{task_id} удалена"}
+
+def db_export_tasks_markdown(user_id: int, filename: Optional[str] = None, status_filter: Optional[str] = None) -> Dict[str, Any]:
+    """Генерирует Markdown-отчет задач с сохранением в output/web/tasks_export/{uuid}/."""
+    tasks = db_get_tasks(user_id)
+    if not tasks:
+        return {"status": "error", "message": "Список задач пуст, экспорт отменен"}
+
+    # Фильтрация по статусу
+    if status_filter and status_filter.upper() != "ALL":
+        tgt = status_filter.upper()
+        if tgt in ["COMPLETED", "DONE", "ВЫПОЛНЕННЫЕ"]:
+            tasks = [t for t in tasks if str(t.get("status", "")).upper() in ["COMPLETED", "DONE"]]
+        elif tgt in ["IN_PROGRESS", "PROGRESS", "В РАБОТЕ"]:
+            tasks = [t for t in tasks if str(t.get("status", "")).upper() in ["IN_PROGRESS", "PROGRESS"]]
+        elif tgt in ["BACKLOG", "PLANNED", "В ПЛАНАХ"]:
+            tasks = [t for t in tasks if str(t.get("status", "")).upper() in ["BACKLOG", "PLANNED"]]
+
+    if not tasks:
+        return {"status": "error", "message": f"Нет задач с фильтром '{status_filter}' для экспорта"}
+
+    # Имя файла
+    target_filename = filename.strip() if (filename and filename.strip()) else "ROADMAP.md"
+    if not target_filename.endswith(".md"):
+        target_filename = f"{target_filename}.md"
+
+    now_dt = datetime.now()
+    now_str = now_dt.strftime("%Y-%m-%d %H:%M")
+
+    modules: Dict[str, List[Dict[str, Any]]] = {}
+    for t in tasks:
+        mod = t.get("module") or "general"
+        modules.setdefault(mod, []).append(t)
+
+    md_lines = [
+        "# 🗺️ Дорожная карта задач проекта (ROADMAP)\n",
+        f"> **Сформировано:** {now_str} | **Всего задач:** {len(tasks)}\n",
+        "---\n"
+    ]
+
+    for mod_name, mod_tasks in sorted(modules.items()):
+        md_lines.append(f"## Модуль `{mod_name}`\n")
+        for t in sorted(mod_tasks, key=lambda x: x.get("id", 0)):
+            status = str(t.get("status", "BACKLOG")).upper()
+            is_done = status in ["COMPLETED", "DONE"]
+            is_progress = status in ["IN_PROGRESS", "PROGRESS"]
+            
+            check_box = "[x]" if is_done else "[ ]"
+            t_id = t.get("id")
+            title = t.get("title", "Без названия")
+            prio = t.get("priority", "MEDIUM")
+            due = f" *(срок: {t['due_date']})*" if t.get("due_date") else ""
+            status_tag = " `[В РАБОТЕ]`" if is_progress else (" `[ЗАВЕРШЕНО]`" if is_done else "")
+
+            md_lines.append(f"- {check_box} **#{t_id}** [{prio}]{status_tag} {title}{due}")
+            
+        md_lines.append("\n---\n")
+
+    content = "\n".join(md_lines)
+
+    # Точный путь к корню scud_ai/output/web/tasks_export/
+    current_file_dir = os.path.dirname(os.path.abspath(__file__))
+    root_dir = os.path.abspath(os.path.join(current_file_dir, "../../../../"))
+    tool_dir = os.path.join(root_dir, "output", "web", "tasks_export")
+    os.makedirs(tool_dir, exist_ok=True)
+
+    try:
+        from routers.files import purge_old_tool_sessions
+        purge_old_tool_sessions(tool_dir)
+    except Exception:
+        pass
+
+    session_token = uuid.uuid4().hex[:8]
+    session_dir = os.path.join(tool_dir, session_token)
+    os.makedirs(session_dir, exist_ok=True)
+
+    filepath = os.path.join(session_dir, target_filename)
+    with open(filepath, "w", encoding="utf-8") as f:
+        f.write(content)
+
+    logger.info(f"Файл успешно создан: {filepath}")
+
+    return {
+        "status": "success",
+        "filename": target_filename,
+        "filepath": filepath,
+        "download_url": f"/api/v1/files/download/tasks_export/{session_token}/{target_filename}",
+        "tasks_count": len(tasks),
+        "message": f"Отчет успешно сформирован в файл `{target_filename}` (всего задач: {len(tasks)})."
+    }
+
+def db_tasks_edit(
+    user_id: int,
+    action: str,
+    task_id: Optional[str] = None,
+    title: Optional[str] = None,
+    priority: Optional[str] = "MEDIUM",
+    status: Optional[str] = None,
+    module: Optional[str] = "general",
+    due_date: Optional[str] = None,
+    filename: Optional[str] = "ROADMAP.md"
+) -> Dict[str, Any]:
+    """Единый консолидированный диспетчер операций над задачами."""
+    act = action.strip().upper()
+    
+    if act == "ADD":
+        if not title:
+            return {"status": "error", "message": "Для создания задачи требуется указать title"}
+        return db_add_task(
+            user_id=user_id, 
+            module=module or "general", 
+            title=title, 
+            priority=priority or "MEDIUM", 
+            due_date=due_date,
+            status=status or "BACKLOG"
+        )
+        
+    elif act == "UPDATE":
+        if not task_id:
+            return {"status": "error", "message": "Для обновления требуется указать task_id"}
+        return db_update_task_details(user_id=user_id, task_id=str(task_id), title=title, priority=priority, status=status, due_date=due_date)
+        
+    elif act == "DELETE":
+        if not task_id:
+            return {"status": "error", "message": "Для удаления требуется указать task_id"}
+        return db_delete_task(user_id=user_id, task_id=str(task_id))
+        
+    elif act == "EXPORT":
+        return db_export_tasks_markdown(user_id=user_id, filename=filename or "ROADMAP.md")
+        
+    return {"status": "error", "message": f"Неизвестное действие action='{action}'"}

modules/web_api/llm/db_tools.py

@@ -1,32 +1,44 @@
 """
+===============================================================================
 FILE: modules/web_api/llm/db_tools.py
+PROJECT: SCUD Orion AI (Unified Architecture)
+MODULE: web_api / llm
+ROLE: Фасадная точка доступа ко всем функциям базы данных SQLite.
+===============================================================================
 """
-from datetime import datetime
+
 from .db.connection import DB_PATH, get_db_connection
-from .db.db_chat import db_save_chat_message, db_get_chat_history, db_purge_ephemeral_messages
-from .db.db_tasks import normalize_task_id, db_get_tasks, db_add_task, db_update_task_status, db_delete_task
-from .db.db_snapshots import db_get_snapshots, db_delete_snapshots
 from .db.db_prompts import (
     db_get_active_system_prompt,
     db_add_system_prompt,
+    db_apply_prompt_node_action,
     db_get_tool_action,
-    db_get_rules,
     db_set_session_state,
     db_get_session_state,
     db_clear_session_state,
-    db_get_session_states,
+    db_get_rules,
     db_get_stats,
     db_get_anomalies,
-    db_get_reference,
+    db_get_reference
-    db_get_tool_action
 )
-
+from .db.db_chat import (
-def db_get_current_server_time():
+    db_save_chat_message,
-    now = datetime.now()
+    db_get_chat_history,
-    days_ru = ["понедельник", "вторник", "среда", "четверг", "пятница", "суббота", "воскресенье"]
+    db_purge_ephemeral_messages,
-    return {
+    db_clear_chat_history
-        "current_date": now.strftime("%d.%m.%Y"),
+)
-        "current_time": now.strftime("%H:%M:%S"),
+from .db.db_tasks import (
-        "day_of_week": days_ru[now.weekday()],
+    normalize_task_id,
-        "iso_date": now.strftime("%Y-%m-%d")
+    db_get_tasks,
-    }
+    db_add_task,
+    db_update_task_status,
+    db_update_task_details,
+    db_delete_task,
+    db_export_tasks_markdown,
+    db_tasks_edit
+)
+from .db.db_snapshots import (
+    db_get_snapshots,
+    db_delete_snapshots
+)
+from .core.calendar_utils import get_dynamic_calendar_context as db_get_current_server_time

modules/web_api/llm/schemas.py

@@ -1,81 +1,142 @@
+"""
+===============================================================================
+FILE: modules/web_api/llm/schemas.py
+PROJECT: SCUD Orion AI (Unified Architecture)
+MODULE: web_api / llm
+ROLE: Декларативная схема нативных инструментов (Function Calling) для Ollama.
+
+AI-CONTEXT-ANCHORS:
+  - ANCHOR[SCHEMA_PROMPT_EDIT]: Схема управления узлами системного промпта.
+  - ANCHOR[SCHEMA_TASKS_EDIT]: Консолидированная схема управления задачами.
+  - ANCHOR[SCHEMA_SNAPSHOTS]: Схема доступа к логам и срезам СКУД.
+===============================================================================
+"""
+
+# ANCHOR[SCHEMA_PROMPT_EDIT]
 TOOLS_SCHEMA = [
     {
         "type": "function",
         "function": {
-            "name": "db_get_tasks",
+            "name": "db_prompt_node_edit",
-            "description": "ПОЛУЧИТЬ СПИСОК ЗАДАЧ ТЕКУЩЕГО ПОЛЬЗОВАТЕЛЯ. Вызывай СРАЗУ при запросе 'покажи мои задачи' или 'список задач'. ВАЖНОЕ ПРАВИЛО ВЫВОДА: Выводи задачи ЕДИНЫМ плоским списком (нумерованным или маркированным) по порядку ID. КАТЕГОРИЧЕСКИ ЗАПРЕЩЕНО группировать задачи по статусам (В процессе, Бэклог, Завершены) или создавать подзаголовки, если оператор явно не попросил о группировке!",
+            "description": (
+                "Управление элементами системного промпта (добавление, изменение, удаление). "
+                "Если пользователь пишет 'удали 2.9' или 'удали пункт 2.9', вызывай action='DELETE', section_id=2, item_id=9. "
+                "Действие action может быть ADD, EDIT или DELETE."
+            ),
             "parameters": {
                 "type": "object",
                 "properties": {
-                    "status": {
+                    "action": {
                         "type": "string",
-                        "description": "Фильтр статуса: BACKLOG, IN_PROGRESS или COMPLETED."
+                        "enum": ["ADD", "EDIT", "DELETE"],
-                    }
+                        "description": "Действие: ADD (добавить), EDIT (изменить), DELETE (удалить)"
-                }
+                    },
-            }
+                    "section_id": {
+                        "type": "integer",
+                        "description": "Номер раздела из точки (например, 2 из 2.9)"
+                    },
+                    "item_id": {
+                        "type": "integer",
+                        "description": "Номер пункта из точки (например, 9 из 2.9)"
+                    },
+                    "content": {
+                        "type": "string",
+                        "description": "Текст пункта (для DELETE пустая строка)"
                     }
                 },
-    {
+                "required": ["action", "section_id", "item_id"]
-        "type": "function",
+            }
-        "function": {
-            "name": "db_get_rules",
-            "description": "ПОЛУЧИТЬ БАЗУ ЗНАНИЙ ИИ И ПРАВИЛА АРБИТРАЖА (ai_knowledge_base). Вызывай когда пользователь просит показать базу знаний, правила, инструкции или промпты.",
-            "parameters": {"type": "object", "properties": {}}
         }
     },
     {
         "type": "function",
         "function": {
             "name": "db_get_system_prompt",
-            "description": "ВЫЗЫВАЙ ВСЕГДА при наличии в сообщении фраз: 'покажи системный промпт', 'покажи промпт', 'выведи промпт', 'системный промпт'. Запрещено отвечать текстом без вызова этого инструмента.",
+            "description": "Просмотр текущего активного системного промпта ассистента из базы данных.",
             "parameters": {
                 "type": "object",
-                "properties": {},
+                "properties": {}
-                "required": []
+            }
+        }
+    },
+    # ANCHOR[SCHEMA_TASKS_EDIT]
+    {
+        "type": "function",
+        "function": {
+            "name": "db_get_tasks",
+            "description": "Просмотр реестра задач и бэклога текущего пользователя.",
+            "parameters": {
+                "type": "object",
+                "properties": {
+                    "status": {
+                        "type": "string",
+                        "enum": ["ALL", "IN_PROGRESS", "PLANNED", "COMPLETED"],
+                        "description": "Опциональный фильтр статуса задач"
+                    }
+                }
             }
         }
     },
     {
         "type": "function",
         "function": {
-            "name": "db_update_task_status",
+            "name": "db_tasks_edit",
-            "description": "Изменить статус и/или срок выполнения задачи в реестре.",
+            "description": "Единый инструмент управления задачами: создание (ADD), изменение статуса/дедлайна (UPDATE), удаление (DELETE) и экспорт задач в Markdown-файл (EXPORT).",
             "parameters": {
                 "type": "object",
                 "properties": {
-                    "task_id": {"type": "string", "description": "Идентификатор задачи, например TASK-17"},
+                    "action": {
-                    "status": {"type": "string", "description": "Новый статус: COMPLETED, IN_PROGRESS или BACKLOG"},
+                        "type": "string",
-                    "due_date": {"type": "string", "description": "Срок выполнения задачи"}
+                        "enum": ["ADD", "UPDATE", "DELETE", "EXPORT"],
+                        "description": "Тип действия: ADD, UPDATE, DELETE или EXPORT"
                     },
-                "required": ["task_id"]
+                    "task_id": {
-            }
+                        "type": "string",
+                        "description": "Номер задачи (для UPDATE и DELETE, например: '35')"
+                    },
+                    "title": {
+                        "type": "string",
+                        "description": "Описание или текст задачи"
+                    },
+                    "status": {
+                        "type": "string",
+                        "enum": ["IN_PROGRESS", "COMPLETED", "PLANNED"],
+                        "description": "Статус задачи"
+                    },
+                    "priority": {
+                        "type": "string",
+                        "enum": ["LOW", "MEDIUM", "HIGH", "CRITICAL"],
+                        "description": "Приоритет задачи"
+                    },
+                    "module": {
+                        "type": "string",
+                        "description": "Модуль проекта"
+                    },
+                    "due_date": {
+                        "type": "string",
+                        "description": "Срок в формате ГГГГ-ММ-ДД"
+                    },
+                    "filename": {
+                        "type": "string",
+                        "description": "Имя файла для экспорта"
                     }
                 },
-    {
+                "required": ["action"]
-        "type": "function",
-        "function": {
-            "name": "db_delete_task",
-            "description": "Удалить задачу из реестра по её task_id (например, TASK-18).",
-            "parameters": {
-                "type": "object",
-                "properties": {
-                    "task_id": {"type": "string", "description": "Идентификатор задачи для удаления, например TASK-18"}
-                },
-                "required": ["task_id"]
             }
         }
     },
+    # ANCHOR[SCHEMA_SNAPSHOTS]
     {
         "type": "function",
         "function": {
             "name": "db_get_snapshots",
-            "description": "ПОЛУЧИТЬ АКТУАЛЬНЫЙ СПИСОК СНАПШОТОВ ИЗ БАЗЫ SQLITE. Вызывай ЭТУ ФУНКЦИЮ ВСЕГДА, даже если список снапшотов уже есть в истории чата или пользователь просит 'обновить', 'повторить запрос', 'проверить снова'. ЗАПРЕЩЕНО беречь контекст и выводить старые данные из истории!",
+            "description": "Получение списка снапшотов и срезов логов СКУД из базы данных за конкретную дату.",
             "parameters": {
                 "type": "object",
                 "properties": {
                     "date_str": {
                         "type": "string",
-                        "description": "Точная дата в формате ДД.ММ.ГГГГ (например, '12.08.2026'), взятая из [СИСТЕМНОГО КАЛЕНДАРЯ СЕРВЕРА]."
+                        "description": "Дата в формате ДД.ММ.ГГГГ или относительное слово"
                     }
                 }
             }
@@ -85,12 +146,18 @@ TOOLS_SCHEMA = [
         "type": "function",
         "function": {
             "name": "db_delete_snapshots",
-                "description": "УДАЛИТЬ СНАПШОТ(Ы) ИЗ БАЗЫ ДАННЫХ. Вызывай, когда пользователь явно просит удалить конкретный снапшот по ID или все снапшоты за выбранный день.",
+            "description": "Удаление снапшотов СКУД по идентификатору или дате.",
             "parameters": {
                 "type": "object",
                 "properties": {
-                        "snapshot_id": {"type": "string", "description": "Идентификатор снапшота для удаления, например Y20260805-007"},
+                    "snapshot_id": {
-                        "day_str": {"type": "string", "description": "Дата в формате ДД.ММ.ГГГГ для удаления всех снапшотов за день"}
+                        "type": "string",
+                        "description": "Идентификатор конкретного снапшота"
+                    },
+                    "day_str": {
+                        "type": "string",
+                        "description": "Дата всех снапшотов за день"
+                    }
                 }
             }
         }
@@ -98,29 +165,31 @@ TOOLS_SCHEMA = [
     {
         "type": "function",
         "function": {
-            "name": "db_get_current_server_time",
+            "name": "db_get_anomalies",
-            "description": "ПОЛУЧИТЬ ТЕКУЩУЮ ДАТУ, ВРЕМЯ И ДЕНЬ НЕДЕЛИ СЕРВЕРА. Вызывай МГНОВЕННО при любых вопросах пользователя про точное текущее время или текущую дату.",
+            "description": "Просмотр истории аномалий и расхождений между СКУД и 1С.",
             "parameters": {
                 "type": "object",
-                "properties": {},
+                "properties": {
-                "required": []
+                    "date_str": {
+                        "type": "string",
+                        "description": "Опциональная дата в формате ДД.ММ.ГГГГ"
+                    },
+                    "limit": {
+                        "type": "integer",
+                        "description": "Лимит записей"
+                    }
+                }
             }
         }
     },
     {
         "type": "function",
         "function": {
-            "name": "db_add_task",
+            "name": "db_get_rules",
-            "description": "Добавить новую задачу в бэклог проекта.",
+            "description": "Просмотр базы знаний и правил кадрового арбитража компании.",
             "parameters": {
                 "type": "object",
-                "properties": {
+                "properties": {}
-                    "title": {"type": "string", "description": "Краткое описание задачи"},
-                    "priority": {"type": "string", "description": "Приоритет: HIGH, MEDIUM, LOW"},
-                    "module": {"type": "string", "description": "Модуль проекта, например general или services/scud_export"},
-                    "due_date": {"type": "string", "description": "Срок выполнения задачи, например '2026-08-07 12:00'"}
-                },
-                "required": ["title"]
             }
         }
     },
@@ -128,94 +197,38 @@ TOOLS_SCHEMA = [
         "type": "function",
         "function": {
             "name": "db_get_stats",
-            "description": "ПОЛУЧИТЬ ОБЩУЮ СТАТИСТИКУ БАЗЫ ДАННЫХ. Вызывай, когда пользователь просит показать общую статистику БД, количество записей в таблицах или размер базы.",
+            "description": "Получение статистики количества записей в таблицах базы данных.",
-            "parameters": {"type": "object", "properties": {}}
-        }
-    },
-    {
-        "type": "function",
-        "function": {
-            "name": "db_get_anomalies",
-            "description": "ПОЛУЧИТЬ ИСТОРИЮ АНОМАЛИЙ СКУД ⟷ 1С. Вызывай при запросах на просмотр аномалий или расхождений. Передавай date_str если пользователь просит аномалии за конкретный день, или увеличенный limit (например 100) если просит все.",
             "parameters": {
                 "type": "object",
-                "properties": {
+                "properties": {}
-                    "limit": {"type": "integer", "description": "Максимальное количество записей (по умолчанию 100)"},
-                    "date_str": {"type": "string", "description": "Опциональная дата в формате ДД.ММ.ГГГГ"}
-                }
             }
         }
     },
     {
         "type": "function",
         "function": {
-            "name": "db_get_session_states",
+            "name": "db_get_current_server_time",
-            "description": "ПОЛУЧИТЬ АКТИВНЫЕ СЕССИИ И ПРЕВЬЮ (session_states). Вызывай, когда пользователь просит показать текущие сессии или статус превью.",
+            "description": "Получение текущего точного времени сервера.",
-            "parameters": {"type": "object", "properties": {}}
+            "parameters": {
+                "type": "object",
+                "properties": {}
+            }
         }
     },
     {
         "type": "function",
         "function": {
             "name": "db_get_reference",
-            "description": "ПОЛУЧИТЬ СИСТЕМНЫЙ СПРАВОЧНИК И ПРИМЕРЫ КОМАНД ДЛЯ ОПЕРАТОРА (system_reference). Вызывай ВСЕГДА, когда пользователь спрашивает про возможности ассистента, список команд, примерах промптов или справе по работе с системой.",
+            "description": "Справка о возможностях ассистента и примеры доступных команд.",
             "parameters": {
                 "type": "object",
                 "properties": {
                     "category": {
                         "type": "string",
-                        "description": "Фильтр категории: scud, tasks, calendar или system. Если просят всё — не передавай параметр."
+                        "description": "Категория справки"
                     }
                 }
             }
         }
-    },
-    {
-        "type": "function",
-        "function": {
-            "name": "db_add_system_prompt",
-            "description": "Прямое сохранение системного промпта в БД без предварительного просмотра.",
-            "parameters": {
-                "type": "object",
-                "properties": {
-                    "name": {"type": "string", "description": "Имя промпта, по умолчанию main_agent"},
-                    "prompt_text": {"type": "string", "description": "Полный текст системного промпта"}
-                },
-                "required": ["prompt_text"]
-            }
-        }
-    },
-    {
-        "type": "function",
-        "function": {
-            "name": "db_preview_prompt_merge",
-            "description": "Сформировать предпросмотр изменения системного промпта. Вызывается при любых запросах на добавление ('добавь пункт...'), изменение или удаление пунктов системного промпта ('удали пункт...').",
-            "parameters": {
-                "type": "object",
-                "properties": {
-                    "prompt_text": {
-                        "type": "string",
-                        "description": "Полный текст добавляемого пункта или номер/описание удаляемого пункта."
-                    }
-                },
-                "required": ["prompt_text"]
-            }
-        }
-    },
-    {
-            "type": "function",
-            "function": {
-                "name": "db_confirm_prompt_preview",
-                "description": "Подтвердить и сохранить текущее подготовленное превью в БД. Вызывай этот инструмент, когда пользователь говорит 'подтверждаю', 'да', 'вноси', 'применяй', 'сохраняй' или одобряет превью в любой форме.",
-                "parameters": {"type": "object", "properties": {}}
-            }
-        },
-        {
-            "type": "function",
-            "function": {
-                "name": "db_cancel_prompt_preview",
-                "description": "Отменить текущее превью системного промпта и сбросить изменения. Вызывай, когда пользователь явно отказывается от изменений.",
-                "parameters": {"type": "object", "properties": {}}
-            }
     }
 ]

modules/web_api/main.py

@@ -2,68 +2,38 @@
 ===============================================================================
 FILE: modules/web_api/main.py
 PROJECT: SCUD Orion AI (Unified Repository)
-MODULE: web_api (FastAPI REST Server & Context Management)
+MODULE: web_api (Main Application Entry Point)
-ROLE: Главный шлюз веб-интерфейса, авторизация пользователей (JWT/Bcrypt),
+ROLE: Инициализация FastAPI приложения, подключение роутеров и статики.
-      маршрутизация диалогов с LLM, OCR-парсинг файлов и управление задачами.
-
-AI-CONTEXT-ANCHORS & INVARIANTS:
-  - ANCHOR[SYS_PATH]: Добавляет директорию модуля в sys.path для корректных импортов
-    независимо от рабочей директории запуска (root или web_api).
-  - ANCHOR[STATIC_MOUNT]: Рассчитывает абсолютный путь к папке static/ для надежного
-    рендеринга интерфейса и ассетов (css/js/favicon).
-  - ANCHOR[AUTH_JWT]: Изолирует персональные пространства задач по user_id (sub).
-  - ANCHOR[CHAT_PIPELINE]: Оркестрирует пайплайн парсинга вложений (file_parser) и 
-    генерации ответов LLM (agent.process_chat_message).
-
-DEPENDENCIES:
-  - modules/web_api/llm/agent.py (process_chat_message)
-  - modules/web_api/llm/db_tools.py (db_get_tasks, DB_PATH)
-  - modules/web_api/llm/file_parser.py (extract_text_from_file)
 ===============================================================================
 """
 
-# --- [SECTION 1: SYSTEM PATHS & IMPORTS] --- # ANCHOR[SYS_PATH]
+# ANCHOR[APP_INIT_IMPORTS]
 import os
 import sys
-import json
-import sqlite3
 import logging
-import urllib.request
-from datetime import datetime, timedelta
-from typing import List, Dict, Any, Optional
 
-# Гарантируем корректный импорт подмодулей web_api независимо от точки запуска
 CURRENT_DIR = os.path.dirname(os.path.abspath(__file__))
 if CURRENT_DIR not in sys.path:
     sys.path.insert(0, CURRENT_DIR)
 
-import jwt
+from fastapi import FastAPI, HTTPException
-from passlib.context import CryptContext
-from fastapi import FastAPI, Depends, HTTPException, status, UploadFile, File, Form
-from fastapi.security import HTTPBearer, HTTPAuthorizationCredentials
 from fastapi.staticfiles import StaticFiles
 from fastapi.responses import FileResponse, JSONResponse
 from fastapi.exceptions import RequestValidationError
-from pydantic import BaseModel
 
-# Внутренние модули LLM и БД
+from routers.auth import router as auth_router
-from llm.agent import process_chat_message
+from routers.admin import router as admin_router
-from llm.db_tools import db_get_tasks, DB_PATH
+from routers.tasks import router as tasks_router
-from llm.file_parser import extract_text_from_file
+from routers.chat import router as chat_router
+from routers.files import router as files_router
 
-# --- [SECTION 2: CONFIGURATION & SECURITY] --- # ANCHOR[AUTH_CONFIG]
+# ANCHOR[APP_CONFIG]
 logging.basicConfig(
     level=logging.INFO,
     format="%(asctime)s [%(levelname)s] %(message)s",
     handlers=[logging.StreamHandler()]
 )
 
-JWT_SECRET = "scud_jwt_secret_key_2026_orion_ai_super_secure"
-ALGORITHM = "HS256"
-
-pwd_context = CryptContext(schemes=["bcrypt"], deprecated="auto")
-security = HTTPBearer()
-
 STATIC_DIR = os.path.join(CURRENT_DIR, "static")
 
 app = FastAPI(title="SCUD Orion AI Context API", version="2.5")
@@ -79,57 +49,16 @@ async def validation_exception_handler(request, exc):
         content={"detail": exc.errors(), "body": str(exc)}
     )
 
-# --- [SECTION 3: DATABASE & TOKEN HELPERS] --- # ANCHOR[DB_HELPERS]
+# ANCHOR[ROUTER_REGISTRATION]
-def get_db():
+app.include_router(auth_router)
-    """Создает безопасное соединение с SQLite БД модуля."""
+app.include_router(admin_router)
-    conn = sqlite3.connect(DB_PATH)
+app.include_router(tasks_router)
-    conn.row_factory = sqlite3.Row
+app.include_router(chat_router)
-    return conn
+app.include_router(files_router)
 
-def create_access_token(user_id: int, username: str, is_admin: bool) -> str:
+# ANCHOR[ROOT_STATIC_ROUTES]
-    payload = {
-        "sub": str(user_id),
-        "username": username,
-        "is_admin": is_admin,
-        "exp": datetime.utcnow() + timedelta(days=30)
-    }
-    return jwt.encode(payload, JWT_SECRET, algorithm=ALGORITHM)
-
-def get_current_user(credentials: HTTPAuthorizationCredentials = Depends(security)) -> Dict[str, Any]:
-    try:
-        token = credentials.credentials
-        payload = jwt.decode(token, JWT_SECRET, algorithms=[ALGORITHM])
-        user_id = int(payload.get("sub"))
-        username = payload.get("username")
-        is_admin = bool(payload.get("is_admin", False))
-        return {"id": user_id, "username": username, "is_admin": is_admin}
-    except Exception as e:
-        logging.warning(f"Auth error: {e}")
-        raise HTTPException(
-            status_code=status.HTTP_401_UNAUTHORIZED,
-            detail="Недействительный или просроченный токен авторизации",
-            headers={"WWW-Authenticate": "Bearer"},
-        )
-
-# Pydantic-схемы валидации запросов
-class AuthRequest(BaseModel):
-    username: str
-    password: str
-
-class CreateUserRequest(BaseModel):
-    username: str
-    password: str
-    full_name: Optional[str] = None
-    is_admin: Optional[bool] = False
-
-class ChangePasswordRequest(BaseModel):
-    old_password: str
-    new_password: str
-
-# --- [SECTION 4: STATIC FILES & SPA ROUTES] --- # ANCHOR[STATIC_MOUNT]
 @app.get("/")
 def read_root():
-    """Отдает главную страницу панели управления."""
     index_path = os.path.join(STATIC_DIR, "index.html")
     if os.path.exists(index_path):
         return FileResponse(index_path)
@@ -142,175 +71,23 @@ async def favicon():
         return FileResponse(file_path)
     raise HTTPException(status_code=404)
 
-# --- [SECTION 5: AUTHENTICATION & USER MANAGEMENT] --- # ANCHOR[AUTH_JWT]
-@app.post("/api/v1/auth/login")
-def login(req: AuthRequest):
-    username = req.username.strip().lower()
-    logging.info(f"===> Попытка входа для пользователя: {username}")
-    
-    conn = get_db()
-    cursor = conn.cursor()
-    cursor.execute("SELECT id, username, password_hash, is_admin FROM users WHERE username = ?", (username,))
-    user = cursor.fetchone()
-    conn.close()
-
-    if not user or not pwd_context.verify(req.password, user["password_hash"]):
-        logging.warning(f"===> Ошибка: Неверный логин или пароль для {username}")
-        raise HTTPException(status_code=401, detail="Неверное имя пользователя или пароль")
-
-    is_admin = bool(user["is_admin"]) or (user["username"] == "puh")
-    token = create_access_token(user["id"], user["username"], is_admin)
-    logging.info(f"===> УСПЕХ: Авторизован пользователь {username}")
-    
-    return {"status": "success", "token": token, "username": user["username"], "is_admin": is_admin}
-
-@app.post("/api/v1/auth/change-password")
-def change_password(req: ChangePasswordRequest, current_user: Dict[str, Any] = Depends(get_current_user)):
-    if not req.new_password or len(req.new_password) < 4:
-        raise HTTPException(status_code=400, detail="Новый пароль должен содержать минимум 4 символа")
-
-    conn = get_db()
-    cursor = conn.cursor()
-    cursor.execute("SELECT password_hash FROM users WHERE id = ?", (current_user["id"],))
-    user = cursor.fetchone()
-
-    if not user or not pwd_context.verify(req.old_password, user["password_hash"]):
-        conn.close()
-        raise HTTPException(status_code=400, detail="Неверный старый пароль")
-
-    new_hash = pwd_context.hash(req.new_password)
-    cursor.execute("UPDATE users SET password_hash = ? WHERE id = ?", (new_hash, current_user["id"]))
-    conn.commit()
-    conn.close()
-
-    logging.info(f"Пароль успешно изменен для пользователя ID: {current_user['id']}")
-    return {"status": "success", "message": "Пароль успешно изменен"}
-
-@app.get("/api/v1/admin/users")
-def list_users(current_user: Dict[str, Any] = Depends(get_current_user)):
-    if not current_user["is_admin"]:
-        raise HTTPException(status_code=403, detail="Доступ запрещен. Только для администратора.")
-
-    conn = get_db()
-    cursor = conn.cursor()
-    cursor.execute("SELECT id, username, full_name, is_admin, created_at FROM users ORDER BY id ASC")
-    users = [dict(r) for r in cursor.fetchall()]
-    conn.close()
-    return users
-
-@app.post("/api/v1/admin/users")
-def create_user(req: CreateUserRequest, current_user: Dict[str, Any] = Depends(get_current_user)):
-    if not current_user["is_admin"]:
-        raise HTTPException(status_code=403, detail="Доступ запрещен. Только для администратора.")
-
-    username = req.username.strip().lower()
-    if not username or not req.password:
-        raise HTTPException(status_code=400, detail="Заполните имя пользователя и пароль")
-
-    conn = get_db()
-    cursor = conn.cursor()
-    cursor.execute("SELECT id FROM users WHERE username = ?", (username,))
-    if cursor.fetchone():
-        conn.close()
-        raise HTTPException(status_code=400, detail="Пользователь с таким именем уже существует")
-
-    pwd_hash = pwd_context.hash(req.password)
-    full_name = req.full_name.strip() if req.full_name else None
-    is_admin = 1 if req.is_admin else 0
-
-    cursor.execute(
-        "INSERT INTO users (username, password_hash, full_name, is_admin) VALUES (?, ?, ?, ?)",
-        (username, pwd_hash, full_name, is_admin)
-    )
-    conn.commit()
-    conn.close()
-
-    logging.info(f"Создан пользователь: {username} (admin={is_admin}) админом {current_user['username']}")
-    return {"status": "success", "message": f"Пользователь {username} создан"}
-
-@app.delete("/api/v1/admin/users/{user_id}")
-def delete_user(user_id: int, current_user: Dict[str, Any] = Depends(get_current_user)):
-    if not current_user["is_admin"]:
-        raise HTTPException(status_code=403, detail="Доступ запрещен. Только для администратора.")
-
-    if user_id == current_user["id"]:
-        raise HTTPException(status_code=400, detail="Нельзя удалить самого себя")
-
-    conn = get_db()
-    cursor = conn.cursor()
-    cursor.execute("DELETE FROM users WHERE id = ?", (user_id,))
-    conn.commit()
-    conn.close()
-
-    logging.info(f"Удален пользователь ID: {user_id}")
-    return {"status": "success", "message": "Пользователь удален"}
-
-# --- [SECTION 6: TASK TRACKER & LLM CHAT PIPELINE] --- # ANCHOR[CHAT_PIPELINE]
-@app.get("/api/v1/tasks")
-def get_tasks(user: Dict[str, Any] = Depends(get_current_user)):
-    """Получить задачи текущего авторизованного пользователя."""
-    return db_get_tasks(user_id=user["id"])
-
-# --- ЧАТ С АВТОРИЗАЦИЕЙ ---
-@app.post("/api/v1/chat")
-async def chat_endpoint(
-    session_id: str = Form("web_session_main"),
-    message: str = Form(""),
-    file: Optional[UploadFile] = File(default=None),
-    current_user: dict = Depends(get_current_user)
-):
-    parsed_file = {"text": "", "image_b64": None}
-    if file and file.filename:
-        file_bytes = await file.read()
-        parsed_file = extract_text_from_file(file_bytes, file.filename)
-
-    reply, history, action_type = process_chat_message(
-        user_id=current_user["id"],
-        user_message=message,
-        file_context=parsed_file["text"],
-        image_b64=parsed_file["image_b64"],
-        session_id=session_id
-    )
-    return {"reply": reply, "history": history, "action_type": action_type}
-
-
-# --- ГОСТЕВОЙ ЧАТ ---
-@app.post("/api/v1/chat/guest")
-async def guest_chat_endpoint(
-    session_id: str = Form("web_session_main"),
-    message: str = Form(""),
-    file: Optional[UploadFile] = File(default=None)
-):
-    parsed_file = {"text": "", "image_b64": None}
-    if file and file.filename:
-        file_bytes = await file.read()
-        parsed_file = extract_text_from_file(file_bytes, file.filename)
-
-    reply, history, action_type = process_chat_message(
-        user_id=0,
-        user_message=message,
-        file_context=parsed_file["text"],
-        image_b64=parsed_file["image_b64"],
-        session_id=session_id
-    )
-    return {"reply": reply, "history": history, "action_type": action_type}
-
-# --- [SECTION 7: STATIC FALLBACK ROUTER] --- # ANCHOR[STATIC_FALLBACK]
 @app.get("/{file_path:path}")
 def serve_static_fallback(file_path: str):
     clean_path = file_path.lstrip("/")
-    
     target = os.path.join(STATIC_DIR, clean_path)
+    
     if os.path.isfile(target):
+        if clean_path.endswith(".js"):
+            return FileResponse(target, media_type="application/javascript")
+        elif clean_path.endswith(".css"):
+            return FileResponse(target, media_type="text/css")
         return FileResponse(target)
 
     filename = os.path.basename(clean_path)
-    target_js = os.path.join(STATIC_DIR, "js", filename)
+    for root, _, files in os.walk(STATIC_DIR):
-    if filename.endswith(".js") and os.path.isfile(target_js):
+        if filename in files:
-        return FileResponse(target_js, media_type="application/javascript")
+            full_path = os.path.join(root, filename)
-
+            media = "application/javascript" if filename.endswith(".js") else "text/css"
-    target_css = os.path.join(STATIC_DIR, "css", filename)
+            return FileResponse(full_path, media_type=media)
-    if filename.endswith(".css") and os.path.isfile(target_css):
-        return FileResponse(target_css, media_type="text/css")
 
     raise HTTPException(status_code=404, detail="File not found")

modules/web_api/routers/admin.py

@@ -0,0 +1,83 @@
+"""
+===============================================================================
+FILE: modules/web_api/routers/admin.py
+ROLE: Администрирование пользователей и прав доступа.
+===============================================================================
+"""
+
+# ANCHOR[ADMIN_ROUTER_IMPORTS]
+import logging
+from typing import Dict, Any, Optional
+from fastapi import APIRouter, Depends, HTTPException
+from pydantic import BaseModel
+
+from .auth import get_current_user, get_db, pwd_context
+
+router = APIRouter(prefix="/api/v1/admin", tags=["admin"])
+
+# ANCHOR[ADMIN_SCHEMAS]
+class CreateUserRequest(BaseModel):
+    username: str
+    password: str
+    full_name: Optional[str] = None
+    is_admin: Optional[bool] = False
+
+# ANCHOR[ADMIN_ENDPOINTS]
+@router.get("/users")
+def list_users(current_user: Dict[str, Any] = Depends(get_current_user)):
+    if not current_user["is_admin"]:
+        raise HTTPException(status_code=403, detail="Доступ запрещен. Только для администратора.")
+
+    conn = get_db()
+    cursor = conn.cursor()
+    cursor.execute("SELECT id, username, full_name, is_admin, created_at FROM users ORDER BY id ASC")
+    users = [dict(r) for r in cursor.fetchall()]
+    conn.close()
+    return users
+
+@router.post("/users")
+def create_user(req: CreateUserRequest, current_user: Dict[str, Any] = Depends(get_current_user)):
+    if not current_user["is_admin"]:
+        raise HTTPException(status_code=403, detail="Доступ запрещен. Только для администратора.")
+
+    username = req.username.strip().lower()
+    if not username or not req.password:
+        raise HTTPException(status_code=400, detail="Заполните имя пользователя и пароль")
+
+    conn = get_db()
+    cursor = conn.cursor()
+    cursor.execute("SELECT id FROM users WHERE username = ?", (username,))
+    if cursor.fetchone():
+        conn.close()
+        raise HTTPException(status_code=400, detail="Пользователь с таким именем уже существует")
+
+    pwd_hash = pwd_context.hash(req.password)
+    full_name = req.full_name.strip() if req.full_name else None
+    is_admin = 1 if req.is_admin else 0
+
+    cursor.execute(
+        "INSERT INTO users (username, password_hash, full_name, is_admin) VALUES (?, ?, ?, ?)",
+        (username, pwd_hash, full_name, is_admin)
+    )
+    conn.commit()
+    conn.close()
+
+    logging.info(f"Создан пользователь: {username} (admin={is_admin}) админом {current_user['username']}")
+    return {"status": "success", "message": f"Пользователь {username} создан"}
+
+@router.delete("/users/{user_id}")
+def delete_user(user_id: int, current_user: Dict[str, Any] = Depends(get_current_user)):
+    if not current_user["is_admin"]:
+        raise HTTPException(status_code=403, detail="Доступ запрещен. Только для администратора.")
+
+    if user_id == current_user["id"]:
+        raise HTTPException(status_code=400, detail="Нельзя удалить самого себя")
+
+    conn = get_db()
+    cursor = conn.cursor()
+    cursor.execute("DELETE FROM users WHERE id = ?", (user_id,))
+    conn.commit()
+    conn.close()
+
+    logging.info(f"Удален пользователь ID: {user_id}")
+    return {"status": "success", "message": "Пользователь удален"}

modules/web_api/routers/auth.py

@@ -0,0 +1,112 @@
+"""
+===============================================================================
+FILE: modules/web_api/routers/auth.py
+ROLE: Аутентификация, валидация JWT-токенов и управление паролями.
+===============================================================================
+"""
+
+# ANCHOR[AUTH_ROUTER_IMPORTS]
+import sqlite3
+import logging
+from datetime import datetime, timedelta
+from typing import Dict, Any, Optional
+
+import jwt
+from passlib.context import CryptContext
+from fastapi import APIRouter, Depends, HTTPException, status
+from fastapi.security import HTTPBearer, HTTPAuthorizationCredentials
+from pydantic import BaseModel
+
+from llm.db_tools import DB_PATH
+
+JWT_SECRET = "scud_jwt_secret_key_2026_orion_ai_super_secure"
+ALGORITHM = "HS256"
+
+pwd_context = CryptContext(schemes=["bcrypt"], deprecated="auto")
+security = HTTPBearer()
+
+router = APIRouter(prefix="/api/v1/auth", tags=["auth"])
+
+# ANCHOR[AUTH_DB_HELPERS]
+def get_db():
+    conn = sqlite3.connect(DB_PATH)
+    conn.row_factory = sqlite3.Row
+    return conn
+
+def create_access_token(user_id: int, username: str, is_admin: bool) -> str:
+    payload = {
+        "sub": str(user_id),
+        "username": username,
+        "is_admin": is_admin,
+        "exp": datetime.utcnow() + timedelta(days=30)
+    }
+    return jwt.encode(payload, JWT_SECRET, algorithm=ALGORITHM)
+
+def get_current_user(credentials: HTTPAuthorizationCredentials = Depends(security)) -> Dict[str, Any]:
+    try:
+        token = credentials.credentials
+        payload = jwt.decode(token, JWT_SECRET, algorithms=[ALGORITHM])
+        user_id = int(payload.get("sub"))
+        username = payload.get("username")
+        is_admin = bool(payload.get("is_admin", False))
+        return {"id": user_id, "username": username, "is_admin": is_admin}
+    except Exception as e:
+        logging.warning(f"Auth error: {e}")
+        raise HTTPException(
+            status_code=status.HTTP_401_UNAUTHORIZED,
+            detail="Недействительный или просроченный токен авторизации",
+            headers={"WWW-Authenticate": "Bearer"},
+        )
+
+# ANCHOR[AUTH_SCHEMAS]
+class AuthRequest(BaseModel):
+    username: str
+    password: str
+
+class ChangePasswordRequest(BaseModel):
+    old_password: str
+    new_password: str
+
+# ANCHOR[AUTH_ENDPOINTS]
+@router.post("/login")
+def login(req: AuthRequest):
+    username = req.username.strip().lower()
+    logging.info(f"===> Попытка входа для пользователя: {username}")
+    
+    conn = get_db()
+    cursor = conn.cursor()
+    cursor.execute("SELECT id, username, password_hash, is_admin FROM users WHERE username = ?", (username,))
+    user = cursor.fetchone()
+    conn.close()
+
+    if not user or not pwd_context.verify(req.password, user["password_hash"]):
+        logging.warning(f"===> Ошибка: Неверный логин или пароль для {username}")
+        raise HTTPException(status_code=401, detail="Неверное имя пользователя или пароль")
+
+    is_admin = bool(user["is_admin"]) or (user["username"] == "puh")
+    token = create_access_token(user["id"], user["username"], is_admin)
+    logging.info(f"===> УСПЕХ: Авторизован пользователь {username}")
+    
+    return {"status": "success", "token": token, "username": user["username"], "is_admin": is_admin}
+
+@router.post("/change-password")
+def change_password(req: ChangePasswordRequest, current_user: Dict[str, Any] = Depends(get_current_user)):
+    if not req.new_password or len(req.new_password) < 4:
+        raise HTTPException(status_code=400, detail="Новый пароль должен содержать минимум 4 символа")
+
+    conn = get_db()
+    cursor = conn.cursor()
+    cursor.execute("SELECT password_hash FROM users WHERE id = ?", (current_user["id"],))
+    user = cursor.fetchone()
+
+    if not user or not pwd_context.verify(req.old_password, user["password_hash"]):
+        conn.close()
+        raise HTTPException(status_code=400, detail="Неверный старый пароль")
+
+    new_hash = pwd_context.hash(req.new_password)
+    cursor.execute("UPDATE users SET password_hash = ? WHERE id = ?", (new_hash, current_user["id"]))
+    conn.commit()
+    conn.close()
+
+    logging.info(f"Пароль успешно изменен для пользователя ID: {current_user['id']}")
+    return {"status": "success", "message": "Пароль успешно изменен"}

modules/web_api/routers/chat.py

@@ -0,0 +1,93 @@
+"""
+===============================================================================
+FILE: modules/web_api/routers/chat.py
+PROJECT: SCUD Orion AI (Unified Architecture)
+MODULE: web_api / routers
+ROLE: Маршрутизация диалогов с LLM и эндпоинт сохранения онлайн-черновиков.
+===============================================================================
+"""
+
+# ANCHOR[CHAT_ROUTER_IMPORTS]
+from typing import Optional, Dict, Any
+from fastapi import APIRouter, Depends, UploadFile, File, Form, HTTPException
+from pydantic import BaseModel
+
+from .auth import get_current_user
+from llm.agent import process_chat_message
+from llm.file_parser import extract_text_from_file
+from llm.db_tools import db_set_session_state, db_get_session_state
+
+router = APIRouter(prefix="/api/v1/chat", tags=["chat"])
+
+
+# ANCHOR[DRAFT_SCHEMA]
+class UpdateDraftRequest(BaseModel):
+    session_id: str
+    draft_text: str
+
+
+# ANCHOR[CHAT_ENDPOINTS]
+@router.post("")
+async def chat_endpoint(
+    session_id: str = Form("web_session_main"),
+    message: str = Form(""),
+    file: Optional[UploadFile] = File(default=None),
+    current_user: Dict[str, Any] = Depends(get_current_user)
+):
+    """Диалог авторизованного пользователя с агентом."""
+    parsed_file = {"text": "", "image_b64": None}
+    if file and file.filename:
+        file_bytes = await file.read()
+        parsed_file = extract_text_from_file(file_bytes, file.filename)
+
+    reply, history, action_type = process_chat_message(
+        user_id=current_user["id"],
+        user_message=message,
+        file_context=parsed_file["text"],
+        image_b64=parsed_file["image_b64"],
+        session_id=session_id
+    )
+    return {"reply": reply, "history": history, "action_type": action_type}
+
+
+@router.post("/guest")
+async def guest_chat_endpoint(
+    session_id: str = Form("web_session_main"),
+    message: str = Form(""),
+    file: Optional[UploadFile] = File(default=None)
+):
+    """Гостевой диалог (user_id=0)."""
+    parsed_file = {"text": "", "image_b64": None}
+    if file and file.filename:
+        file_bytes = await file.read()
+        parsed_file = extract_text_from_file(file_bytes, file.filename)
+
+    reply, history, action_type = process_chat_message(
+        user_id=0,
+        user_message=message,
+        file_context=parsed_file["text"],
+        image_b64=parsed_file["image_b64"],
+        session_id=session_id
+    )
+    return {"reply": reply, "history": history, "action_type": action_type}
+
+
+@router.post("/draft")
+def update_draft_endpoint(
+    req: UpdateDraftRequest,
+    current_user: Dict[str, Any] = Depends(get_current_user)
+):
+    """Обновляет черновик системного промпта напрямую из интерактивной онлайн-формы."""
+    state = db_get_session_state(req.session_id)
+    if not state or state.get("state_type") != "PROMPT_PREVIEW":
+        raise HTTPException(status_code=400, detail="Нет активного превью для редактирования")
+
+    # Сохраняем чистый текст с пометкой MANUAL_EDIT
+    db_set_session_state(req.session_id, "PROMPT_PREVIEW", {
+        "draft_text": req.draft_text.strip(),
+        "action": "MANUAL_EDIT",
+        "section_id": None,
+        "item_id": None,
+        "content": ""
+    })
+    return {"status": "success", "message": "Черновик успешно обновлен в сессии"}

modules/web_api/routers/files.py

@@ -0,0 +1,73 @@
+"""
+===============================================================================
+FILE: modules/web_api/routers/files.py
+ROLE: Раздача сформированных отчетов и выгрузок с сохранением оригинальных имен
+      через изолированные UUID-директории инструментов.
+===============================================================================
+"""
+
+import os
+import time
+import shutil
+import urllib.parse
+from fastapi import APIRouter, HTTPException
+from fastapi.responses import FileResponse
+
+router = APIRouter(prefix="/api/v1/files", tags=["Files"])
+
+BASE_ROOT = os.path.abspath(os.path.join(os.path.dirname(__file__), "../../../"))
+WEB_OUTPUT_DIR = os.path.join(BASE_ROOT, "output", "web")
+os.makedirs(WEB_OUTPUT_DIR, exist_ok=True)
+
+SESSION_TTL_HOURS = 24  # Срок жизни временных сессионных выгрузок
+
+
+def purge_old_tool_sessions(tool_dir_path: str):
+    """Удаляет временные UUID-папки старше SESSION_TTL_HOURS внутри инструмента."""
+    if not os.path.exists(tool_dir_path):
+        return
+    now = time.time()
+    cutoff = now - (SESSION_TTL_HOURS * 3600)
+    try:
+        for entry in os.listdir(tool_dir_path):
+            subpath = os.path.join(tool_dir_path, entry)
+            if os.path.isdir(subpath):
+                if os.path.getmtime(subpath) < cutoff:
+                    shutil.rmtree(subpath, ignore_errors=True)
+    except Exception:
+        pass
+
+
+@router.get("/download/{tool_name}/{session_uuid}/{filename}")
+async def download_file(tool_name: str, session_uuid: str, filename: str):
+    """
+    Безопасная отдача файла с каноническим именем из изолированной директории.
+    """
+    safe_tool = os.path.basename(tool_name)
+    safe_uuid = os.path.basename(session_uuid)
+    safe_filename = os.path.basename(filename)
+
+    file_path = os.path.join(WEB_OUTPUT_DIR, safe_tool, safe_uuid, safe_filename)
+
+    if not os.path.exists(file_path) or not os.path.isfile(file_path):
+        raise HTTPException(status_code=404, detail="Файл не найден или срок его действия истек")
+
+    # Определение MIME-типа
+    media_type = "application/octet-stream"
+    if safe_filename.endswith(".md") or safe_filename.endswith(".txt"):
+        media_type = "text/markdown; charset=utf-8"
+    elif safe_filename.endswith(".xlsx"):
+        media_type = "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet"
+    elif safe_filename.endswith(".pdf"):
+        media_type = "application/pdf"
+
+    # Корректная кодировка для кириллических имен файлов
+    encoded_filename = urllib.parse.quote(safe_filename)
+
+    return FileResponse(
+        path=file_path,
+        media_type=media_type,
+        headers={
+            "Content-Disposition": f"attachment; filename*=UTF-8''{encoded_filename}"
+        }
+    )

modules/web_api/routers/tasks.py

@@ -0,0 +1,75 @@
+"""
+===============================================================================
+FILE: modules/web_api/routers/tasks.py
+PROJECT: SCUD Orion AI (Unified Architecture)
+MODULE: web_api / routers
+ROLE: REST API эндпоинты реестра задач (получение, создание и обновление).
+===============================================================================
+"""
+
+from fastapi import APIRouter, Depends, HTTPException, Request
+from pydantic import BaseModel
+from typing import Optional, Dict, Any
+
+from routers.auth import get_current_user
+from llm.db_tools import db_get_tasks, db_add_task, db_update_task_details
+
+router = APIRouter(prefix="/api/v1/tasks", tags=["Tasks"])
+
+class TaskCreateRequest(BaseModel):
+    title: str
+    priority: Optional[str] = "MEDIUM"
+    module: Optional[str] = "general"
+    due_date: Optional[str] = None
+    status: Optional[str] = "BACKLOG"
+
+class TaskUpdateRequest(BaseModel):
+    title: Optional[str] = None
+    priority: Optional[str] = None
+    due_date: Optional[str] = None
+    status: Optional[str] = None
+
+
+def resolve_user_id(current_user: Dict[str, Any]) -> int:
+    """Извлекает корректный ID пользователя из JWT payload или ставит дефолтный 1."""
+    if not current_user:
+        return 1
+    return current_user.get("id") or current_user.get("user_id") or 1
+
+
+@router.get("")
+async def get_tasks_endpoint(status: Optional[str] = None, current_user = Depends(get_current_user)):
+    user_id = resolve_user_id(current_user)
+    return {"tasks": db_get_tasks(user_id=user_id, status=status)}
+
+
+@router.post("")
+async def create_task_endpoint(req: TaskCreateRequest, current_user = Depends(get_current_user)):
+    user_id = resolve_user_id(current_user)
+    res = db_add_task(
+        user_id=user_id,
+        module=req.module,
+        title=req.title,
+        priority=req.priority,
+        due_date=req.due_date,
+        status=req.status
+    )
+    if "error" in res:
+        raise HTTPException(status_code=400, detail=res["error"])
+    return res
+
+
+@router.patch("/{task_id}")
+async def update_task_endpoint(task_id: str, req: TaskUpdateRequest, current_user = Depends(get_current_user)):
+    user_id = resolve_user_id(current_user)
+    res = db_update_task_details(
+        user_id=user_id,
+        task_id=task_id,
+        title=req.title,
+        priority=req.priority,
+        status=req.status,
+        due_date=req.due_date
+    )
+    if "error" in res:
+        raise HTTPException(status_code=404, detail=res["error"])
+    return res

modules/web_api/scripts/diagnostics/inspect_db.py

@@ -1,47 +0,0 @@
-import os
-import sqlite3
-
-# Автопоиск файла базы данных в проекте
-db_path = '/home/puh/scud_orion_ai_v2/data/scud_orion_ai.db' if os.path.exists('/home/puh/scud_orion_ai_v2/data/scud_orion_ai.db') else 'scud_orion_ai.db'
-
-print("=" * 80)
-print(f"🔍 ДИАГНОСТИКА СУБД SQLITE: {db_path}")
-print("=" * 80)
-
-if not os.path.exists(db_path):
-    print(f"❌ Файл базы данных {db_path} не найден!")
-    exit(1)
-
-conn = sqlite3.connect(db_path)
-cursor = conn.cursor()
-
-# 1. Список всех таблиц и колонок
-cursor.execute("SELECT name FROM sqlite_master WHERE type='table' ORDER BY name")
-tables = [t[0] for t in cursor.fetchall()]
-
-print("\n📋 СТРУКТУРА ТАБЛИЦ И КОЛИЧЕСТВО ЗАПИСЕЙ:")
-print("-" * 80)
-for t_name in tables:
-    cursor.execute(f"PRAGMA table_info({t_name})")
-    cols = [c[1] for c in cursor.fetchall()]
-    
-    cursor.execute(f"SELECT COUNT(*) FROM {t_name}")
-    count = cursor.fetchone()[0]
-    
-    print(f"• [{t_name:<20}] — {count:>6} строк | Колонки: {cols}")
-
-# 2. Просмотр правил Базы Знаний
-if 'ai_knowledge_base' in tables:
-    print("\n" + "=" * 80)
-    print("🧠 АКТУАЛЬНЫЕ ПРАВИЛА БАЗЫ ЗНАНИЙ (ai_knowledge_base):")
-    print("=" * 80)
-    cursor.execute("SELECT id, rule_text, added_by FROM ai_knowledge_base ORDER BY id ASC")
-    rules = cursor.fetchall()
-    if not rules:
-        print("Таблица ai_knowledge_base пуста.")
-    else:
-        for r_id, r_text, r_author in rules:
-            print(f" {r_id}. [{r_author}] {r_text}\n")
-
-conn.close()
-print("=" * 80)

modules/web_api/scripts/diagnostics/inspect_files.py

@@ -1,23 +0,0 @@
-import os
-
-print("=" * 80)
-print("📂 ТЕКУЩЕЕ СОСТОЯНИЕ ФАЙЛОВ ПРОЕКТА (scud_orion_context)")
-print("=" * 80)
-
-total_files = 0
-total_size = 0
-
-for root, dirs, files in os.walk('.'):
-    # Исключаем служебные каталоги
-    dirs[:] = [d for d in dirs if d not in ['.git', '__pycache__', 'venv', '.venv', 'extracted_project']]
-    
-    for f in files:
-        p = os.path.join(root, f)
-        size = os.path.getsize(p)
-        total_files += 1
-        total_size += size
-        print(f"{p:<55} ({size:>10,} bytes)".replace(',', ' '))
-
-print("-" * 80)
-print(f"ИТОГО: файлов: {total_files} | Общий объем: {total_size / (1024 * 1024):.2f} MB")
-print("=" * 80)

modules/web_api/scripts/diagnostics/make_code_snapshot.py

@@ -1,31 +0,0 @@
-import os
-
-OUTPUT_SNAPSHOT = "api_code_snapshot.md"
-
-# Расширения файлов для включения в снимок
-ALLOWED_EXTENSIONS = {'.py', '.json', '.md', '.sh', '.ini', '.js', '.html', '.css'}
-EXCLUDE_DIRS = {'.git', '__pycache__', 'venv', '.venv', 'output', 'logs', 'extracted_project'}
-EXCLUDE_FILES = {OUTPUT_SNAPSHOT, 'scud_context_api.tar.gz', 'context_memory.db'}
-
-print(f"🔄 Сборка полного контекстного слепка проекта в {OUTPUT_SNAPSHOT}...")
-
-with open(OUTPUT_SNAPSHOT, 'w', encoding='utf-8') as out:
-    out.write("# 📦 ПОЛНЫЙ ИСХОДНЫЙ КОД И КОНФИГУРАЦИЯ ПРОЕКТА scud_context_api\n\n")
-    
-    for root, dirs, files in os.walk('.'):
-        dirs[:] = [d for d in dirs if d not in EXCLUDE_DIRS]
-        
-        for file in sorted(files):
-            ext = os.path.splitext(file)[1].lower()
-            if ext in ALLOWED_EXTENSIONS and file not in EXCLUDE_FILES:
-                filepath = os.path.join(root, file)
-                out.write(f"## File: `{filepath}`\n")
-                out.write("```" + (ext.replace('.', '') if ext != '.md' else '') + "\n")
-                try:
-                    with open(filepath, 'r', encoding='utf-8', errors='replace') as f:
-                        out.write(f.read())
-                except Exception as e:
-                    out.write(f"// Ошибка чтения файла: {e}\n")
-                out.write("\n```\n\n")
-
-print(f"✓ Успешно создан слепок проекта: {OUTPUT_SNAPSHOT} ({os.path.getsize(OUTPUT_SNAPSHOT):,} bytes)")

modules/web_api/static/index.html

@@ -10,7 +10,7 @@
 </head>
 <body class="bg-slate-100 text-slate-800 h-[100dvh] w-full flex flex-col font-sans overflow-hidden">
 
-    <!-- Окно авторизации -->
+    <!-- ANCHOR[AUTH_MODAL]: Модальное окно входа -->
     <div id="auth-modal" class="fixed inset-0 bg-slate-900/80 backdrop-blur-md z-50 flex items-center justify-center p-4">
         <div class="bg-white rounded-2xl p-6 sm:p-8 max-w-md w-full shadow-2xl border border-slate-200">
             <div class="flex items-center space-x-3 mb-6">
@@ -56,7 +56,7 @@
         </div>
     </div>
 
-    <!-- Модальное окно смены пароля -->
+    <!-- ANCHOR[CHANGE_PWD_MODAL]: Модальное окно смены пароля -->
     <div id="change-pwd-modal" class="fixed inset-0 bg-slate-900/60 backdrop-blur-sm z-50 hidden flex items-center justify-center p-4">
         <div class="bg-white rounded-2xl p-6 max-w-sm w-full shadow-2xl border border-slate-200">
             <div class="flex justify-between items-center mb-4">
@@ -92,7 +92,7 @@
         </div>
     </div>
 
-    <!-- Модальное окно управления пользователями -->
+    <!-- ANCHOR[ADMIN_MODAL]: Модальное окно управления пользователями -->
     <div id="admin-modal" class="fixed inset-0 bg-slate-900/60 backdrop-blur-sm z-50 hidden flex items-center justify-center p-4">
         <div class="bg-white rounded-2xl p-6 max-w-lg w-full shadow-2xl border border-slate-200 flex flex-col max-h-[85vh]">
             <div class="flex justify-between items-center mb-4 pb-2 border-b border-slate-200">
@@ -129,7 +129,7 @@
         </div>
     </div>
 
-    <!-- Хедер -->
+    <!-- ANCHOR[HEADER_BAR]: Хедер интерфейса -->
     <header class="bg-white border-b border-slate-200 px-4 py-2.5 flex justify-between items-center shadow-sm shrink-0 z-20">
         <div class="flex items-center space-x-2.5">
             <div class="bg-indigo-600 text-white p-2 rounded-xl shrink-0">
@@ -170,7 +170,7 @@
         </div>
     </header>
 
-    <!-- Главный контейнер -->
+    <!-- ANCHOR[CHAT_MAIN_CONTAINER]: Главный контейнер чата -->
     <div class="flex-1 flex flex-col min-h-0 w-full max-w-4xl mx-auto bg-white relative overflow-hidden">
         <div id="chat-window" class="flex-1 p-3.5 overflow-y-auto space-y-3 bg-slate-50/50">
             <div id="drop-overlay" class="absolute inset-0 bg-indigo-600/10 backdrop-blur-sm border-2 border-dashed border-indigo-600 rounded-2xl hidden flex-col items-center justify-center z-30 transition-all pointer-events-none">
@@ -202,9 +202,9 @@
             </button>
         </div>
 
+        <!-- Поле ввода -->
         <div class="p-2.5 pb-6 bg-white border-t border-slate-200 shrink-0 z-10 shadow-lg">
             <div class="flex items-center gap-2">
-                <!-- Скрытый инпут и кнопка прикрепления файла -->
                 <input type="file" id="file-input" class="hidden" onchange="handleFileSelect(event)" accept=".png,.jpg,.jpeg,.pdf,.txt,.csv,.xlsx">
                 <button type="button" onclick="document.getElementById('file-input').click()" class="text-slate-500 hover:text-indigo-600 p-2 rounded-xl transition" title="Прикрепить файл">
                     <i class="fa-solid fa-paperclip text-lg"></i>
@@ -223,7 +223,7 @@
         </div>
     </div>
 
-    <!-- Выезжающая панель (Drawer) -->
+    <!-- ANCHOR[TASK_DRAWER_CONTAINER]: Боковая панель задач -->
     <div id="drawer-backdrop" onclick="toggleDrawer()" class="fixed inset-0 bg-slate-900/50 backdrop-blur-sm hidden transition-opacity z-40"></div>
     
     <aside id="task-drawer" class="fixed right-0 top-0 h-full w-full sm:w-[420px] bg-white border-l border-slate-200 shadow-2xl transform translate-x-full transition-transform duration-300 ease-in-out z-50 flex flex-col">
@@ -241,11 +241,12 @@
             </div>
         </div>
 
+        <!-- ANCHOR[DRAWER_TAB_RENAMING]: Вкладки фильтрации боковой панели -->
         <div class="flex border-b border-slate-200 bg-white px-2 pt-2 text-xs font-semibold text-slate-500 gap-1 overflow-x-auto no-scrollbar shrink-0">
             <button type="button" onclick="setFilter('ALL')" id="filter-ALL" class="px-3 py-1.5 rounded-t-lg border-b-2 border-indigo-600 text-indigo-600 font-bold whitespace-nowrap">Все</button>
             <button type="button" onclick="setFilter('IN_PROGRESS')" id="filter-IN_PROGRESS" class="px-3 py-1.5 rounded-t-lg border-b-2 border-transparent whitespace-nowrap">В работе</button>
-            <button type="button" onclick="setFilter('BACKLOG')" id="filter-BACKLOG" class="px-3 py-1.5 rounded-t-lg border-b-2 border-transparent whitespace-nowrap">Бэклог</button>
+            <button type="button" onclick="setFilter('BACKLOG')" id="filter-BACKLOG" class="px-3 py-1.5 rounded-t-lg border-b-2 border-transparent whitespace-nowrap">В планах</button>
-            <button type="button" onclick="setFilter('COMPLETED')" id="filter-COMPLETED" class="px-3 py-1.5 rounded-t-lg border-b-2 border-transparent whitespace-nowrap">Завершено</button>
+            <button type="button" onclick="setFilter('COMPLETED')" id="filter-COMPLETED" class="px-3 py-1.5 rounded-t-lg border-b-2 border-transparent whitespace-nowrap">Завершенные</button>
         </div>
 
         <div id="tasks-container" class="flex-1 overflow-y-auto p-3.5 space-y-3 bg-slate-50/50 pb-8">
@@ -253,9 +254,11 @@
         </div>
     </aside>
 
+    <!-- Подключение скриптов интерфейса -->
     <script src="/static/js/auth.js"></script>
     <script src="/static/js/tasks.js"></script>
-    <script src="/static/js/chat.js"></script>
+    <script src="/static/js/chat/task_widget.js"></script>
+    <script src="/static/js/chat/core.js"></script>
     <script src="/static/js/app.js"></script>
 </body>
 </html>

modules/web_api/static/js/chat/core.js

@@ -1,4 +1,13 @@
-// Вспомогательная функция для автоматического изменения высоты текстового поля
+/**
+===============================================================================
+FILE: modules/web_api/static/js/chat/core.js
+PROJECT: SCUD Orion AI (Unified Architecture)
+MODULE: web_api / static / js / chat
+ROLE: Клиентский интерфейс диалога, Drag-and-Drop вложений, блокировка ввода
+      при активных кнопках, вызов инлайн-редактора, Diff и карточки скачивания файлов.
+===============================================================================
+*/
+
 function updateInputHeight(el) {
     if (!el) return;
     el.style.height = "24px";
@@ -36,7 +45,29 @@ function clearAttachedFile() {
     if (previewContainer) previewContainer.classList.add("hidden");
 }
 
-// Деактивация всех старых кнопок в истории
+function setInputLocked(isLocked) {
+    const input = document.getElementById("user-input");
+    const sendBtn = document.getElementById("send-btn");
+    if (input) {
+        input.disabled = isLocked;
+        if (isLocked) {
+            input.placeholder = "Выберите действие с помощью кнопок выше...";
+            input.classList.add("cursor-not-allowed", "opacity-60", "bg-slate-200/50");
+        } else {
+            input.placeholder = "Команда, вопрос или перетащите файл сюда...";
+            input.classList.remove("cursor-not-allowed", "opacity-60", "bg-slate-200/50");
+        }
+    }
+    if (sendBtn) {
+        sendBtn.disabled = isLocked;
+        if (isLocked) {
+            sendBtn.classList.add("opacity-40", "cursor-not-allowed");
+        } else {
+            sendBtn.classList.remove("opacity-40", "cursor-not-allowed");
+        }
+    }
+}
+
 function disableAllActionButtons() {
     const allBtnContainers = document.querySelectorAll(".action-buttons-container");
     allBtnContainers.forEach(container => {
@@ -47,9 +78,9 @@ function disableAllActionButtons() {
     });
 }
 
-// Быстрая отправка текста кнопки
 function handleActionButtonClick(text) {
     disableAllActionButtons();
+    setInputLocked(false);
     const input = document.getElementById("user-input");
     if (input) {
         input.value = text;
@@ -57,6 +88,154 @@ function handleActionButtonClick(text) {
     }
 }
 
+function escapeHtml(text) {
+    if (text === null || text === undefined) return "";
+    return String(text)
+        .replace(/&/g, "&")
+        .replace(/</g, "&lt;")
+        .replace(/>/g, "&gt;")
+        .replace(/"/g, "&quot;")
+        .replace(/'/g, "&#039;");
+}
+
+// --- [INLINE PROMPT EDITOR & FULL DIFF BUILDER] ---
+function openInlinePromptEditor(btnEl) {
+    const cardContainer = btnEl.closest(".chat-message-card");
+    if (!cardContainer) return;
+
+    const editorContainer = cardContainer.querySelector(".inline-prompt-editor-container");
+    const diffView = cardContainer.querySelector(".prompt-preview-diff-view");
+    const textarea = cardContainer.querySelector(".inline-prompt-textarea");
+
+    if (editorContainer && textarea) {
+        editorContainer.classList.remove("hidden");
+        
+        if (diffView) {
+            const targetHeight = Math.max(diffView.offsetHeight, 320);
+            textarea.style.height = `${targetHeight}px`;
+        }
+        
+        textarea.focus();
+    }
+}
+
+function closeInlinePromptEditor(btnEl) {
+    const cardContainer = btnEl.closest(".chat-message-card");
+    if (!cardContainer) return;
+    const editorContainer = cardContainer.querySelector(".inline-prompt-editor-container");
+    if (editorContainer) editorContainer.classList.add("hidden");
+}
+
+function parsePromptIntoMap(text) {
+    const map = new Map();
+    if (!text) return map;
+    const lines = text.split("\n");
+    for (let line of lines) {
+        let trimmed = line.trim();
+        if (!trimmed) continue;
+        const match = trimmed.match(/^(\d+)[\.\s]+(\d+)[\.\s\:\-]*(.*)$/);
+        if (match) {
+            const key = `${match[1]}.${match[2]}`;
+            map.set(key, { sec: parseInt(match[1]), itm: parseInt(match[2]), content: match[3].trim(), full: trimmed });
+        }
+    }
+    return map;
+}
+
+function buildHighlightedPromptHtml(newRawText, originalBaselineText) {
+    const origMap = parsePromptIntoMap(originalBaselineText);
+    const newMap = parsePromptIntoMap(newRawText);
+
+    const formattedLines = [];
+    const rawLines = newRawText.split("\n");
+    const handledNewKeys = new Set();
+
+    let currentSection = null;
+
+    for (let line of rawLines) {
+        let trimmed = line.trim();
+        if (!trimmed) {
+            formattedLines.push("");
+            continue;
+        }
+
+        const secMatch = trimmed.match(/^(\d+)[\.\s\:\-]+([^\d].*)$/);
+        const subMatch = trimmed.match(/^(\d+)[\.\s]+(\d+)[\.\s\:\-]*(.*)$/);
+
+        if (subMatch) {
+            const key = `${subMatch[1]}.${subMatch[2]}`;
+            handledNewKeys.add(key);
+            currentSection = parseInt(subMatch[1]);
+            const cleanContent = subMatch[3].trim();
+            const fullItemStr = `${subMatch[1]}.${subMatch[2]}. ${cleanContent}`;
+
+            if (!origMap.has(key) || origMap.get(key).content !== cleanContent) {
+                formattedLines.push(`   <span class="text-rose-600 font-bold bg-rose-50 px-1.5 py-0.5 rounded border border-rose-300">${escapeHtml(fullItemStr)}</span>`);
+            } else {
+                formattedLines.push(`   ${escapeHtml(fullItemStr)}`);
+            }
+        } else if (secMatch && !anyLower(secMatch[2].slice(0, 15))) {
+            currentSection = parseInt(secMatch[1]);
+            formattedLines.push(escapeHtml(trimmed));
+        } else {
+            formattedLines.push(escapeHtml(trimmed));
+        }
+    }
+
+    for (let [origKey, origObj] of origMap.entries()) {
+        if (!handledNewKeys.has(origKey)) {
+            const strikeMarkup = `   <span class="line-through text-rose-600 font-bold bg-rose-50 px-1.5 py-0.5 rounded border border-rose-300 opacity-80">${origKey}. ${escapeHtml(origObj.content)} [УДАЛЕНИЕ]</span>`;
+            formattedLines.push(strikeMarkup);
+        }
+    }
+
+    return formattedLines.join("\n");
+}
+
+function anyLower(str) {
+    return /[а-яa-z]/.test(str);
+}
+
+async function saveManualPromptDraft(btnEl) {
+    const cardContainer = btnEl.closest(".chat-message-card");
+    if (!cardContainer) return;
+
+    const textarea = cardContainer.querySelector(".inline-prompt-textarea");
+    const previewTextEl = cardContainer.querySelector(".prompt-preview-diff-view");
+    if (!textarea) return;
+
+    const newText = textarea.value.trim();
+    if (!newText) return;
+
+    const token = typeof API_TOKEN !== 'undefined' && API_TOKEN ? API_TOKEN : localStorage.getItem("scud_api_auth_token");
+
+    try {
+        const res = await fetch("/api/v1/chat/draft", {
+            method: "POST",
+            headers: {
+                "Content-Type": "application/json",
+                "Authorization": "Bearer " + token
+            },
+            body: JSON.stringify({
+                session_id: "web_session_main",
+                draft_text: newText
+            })
+        });
+
+        if (res.ok) {
+            closeInlinePromptEditor(btnEl);
+            if (previewTextEl) {
+                const baseline = cardContainer.dataset.originalBaseline || "";
+                const highlightedHtml = buildHighlightedPromptHtml(newText, baseline);
+                previewTextEl.innerHTML = highlightedHtml;
+            }
+        }
+    } catch (err) {
+        alert("Ошибка сохранения черновика: " + err);
+    }
+}
+
+// --- [CHAT SEND PIPELINE] ---
 async function sendMessage(e) {
     if (e && e.preventDefault) e.preventDefault();
 
@@ -69,7 +248,6 @@ async function sendMessage(e) {
 
     if (!text && !selectedFile) return;
 
-    // Деактивируем предыдущие интерактивные кнопки
     disableAllActionButtons();
 
     let userDisplayHtml = escapeHtml(text);
@@ -131,7 +309,6 @@ async function sendMessage(e) {
         const assistantTitle = isGuest ? "Локальная нейросеть (Гость)" : "ИИ-Ассистент SCUD Orion AI";
         const replyText = data.reply || "Пустой ответ от нейросети";
 
-        // Генерация блока кнопок подтверждения при необходимости
         let actionButtonsHtml = "";
         const actionData = data.action_type || data.action;
 
@@ -143,6 +320,7 @@ async function sendMessage(e) {
                 const labelLower = (btn.label || "").toLowerCase();
                 const isPrimary = btn.style === "primary" || labelLower.includes("подтверд") || labelLower.startsWith("да");
                 const isDanger = btn.style === "danger" || labelLower.includes("отмен") || labelLower.startsWith("нет") || labelLower.includes("законч") || labelLower.includes("заверш");
+                const isEdit = labelLower.includes("редактир");
 
                 if (isPrimary) {
                     btnClasses = "bg-emerald-600 hover:bg-emerald-700 active:bg-emerald-800 text-white shadow-sm";
@@ -150,10 +328,15 @@ async function sendMessage(e) {
                 } else if (isDanger) {
                     btnClasses = "bg-rose-50 hover:bg-rose-100 active:bg-rose-200 text-rose-700 border border-rose-300";
                     iconMarkup = '<i class="fa-solid fa-xmark"></i>';
+                } else if (isEdit) {
+                    btnClasses = "bg-indigo-50 hover:bg-indigo-100 active:bg-indigo-200 text-indigo-700 border border-indigo-300";
+                    iconMarkup = '<i class="fa-solid fa-pen-to-square text-xs"></i>';
                 }
 
+                const clickHandler = isEdit ? "openInlinePromptEditor(this)" : `handleActionButtonClick('${escapeHtml(btn.value)}')`;
+
                 return `
-                    <button type="button" onclick="handleActionButtonClick('${escapeHtml(btn.value)}')" 
+                    <button type="button" onclick="${clickHandler}" 
                         class="${btnClasses} font-semibold px-3 py-1.5 rounded-xl text-xs flex items-center gap-1.5 transition cursor-pointer">
                         ${iconMarkup}
                         <span>${escapeHtml(btn.label)}</span>
@@ -166,14 +349,75 @@ async function sendMessage(e) {
                     ${buttonsMarkup}
                 </div>
             `;
+
+            setInputLocked(true);
+        } else {
+            setInputLocked(false);
         }
 
+        let previewEditorHtml = "";
+        let rawDraftText = "";
+        let baselineText = "";
+
+        if (actionData && actionData.type === "PROMPT_PREVIEW") {
+            rawDraftText = actionData.raw_draft || "";
+            baselineText = actionData.baseline_prompt || rawDraftText;
+            previewEditorHtml = `
+                <div class="inline-prompt-editor-container hidden mt-3 p-3 bg-slate-50 border border-slate-300 rounded-xl space-y-2">
+                    <p class="text-[11px] font-bold text-slate-700 uppercase"><i class="fa-solid fa-pen-to-square mr-1"></i> Ручное редактирование текста промпта:</p>
+                    <textarea class="inline-prompt-textarea w-full bg-white border border-slate-300 rounded-lg p-3 text-xs font-mono text-slate-800 focus:outline-none focus:border-indigo-600 resize-y shadow-inner leading-relaxed">${escapeHtml(rawDraftText)}</textarea>
+                    <div class="flex justify-end gap-2 pt-1">
+                        <button type="button" onclick="closeInlinePromptEditor(this)" class="px-3 py-1.5 rounded-lg text-xs text-slate-600 bg-slate-200 hover:bg-slate-300 transition">Свернуть</button>
+                        <button type="button" onclick="saveManualPromptDraft(this)" class="px-3.5 py-1.5 rounded-lg text-xs font-semibold text-white bg-indigo-600 hover:bg-indigo-700 shadow-sm transition">Сохранить правки</button>
+                    </div>
+                </div>
+            `;
+        }
+
+        let interactiveWidgetHtml = "";
+        if (actionData && actionData.type === "TASK_INTERACTIVE_CARD" && typeof renderInteractiveTaskCard === "function") {
+            interactiveWidgetHtml = renderInteractiveTaskCard(actionData.tasks);
+        }
+
+        let snapshotsWidgetHtml = "";
+        if (actionData && actionData.type === "SNAPSHOTS_CARD" && typeof renderSnapshotsCard === "function") {
+            snapshotsWidgetHtml = renderSnapshotsCard(actionData.data);
+        }
+
+        // ⭐️ БЛОК КАРТОЧКИ СКАЧИВАНИЯ ФАЙЛА
+        let fileDownloadHtml = "";
+        if (actionData && actionData.type === "FILE_DOWNLOAD_CARD") {
+            fileDownloadHtml = `
+                <div class="mt-3 p-3 bg-emerald-50 border border-emerald-200 rounded-xl flex items-center justify-between gap-3">
+                    <div class="flex items-center gap-2 min-w-0">
+                        <i class="fa-solid fa-file-lines text-emerald-600 text-lg shrink-0"></i>
+                        <div class="truncate">
+                            <div class="text-xs font-bold text-slate-900 truncate">${escapeHtml(actionData.filename)}</div>
+                            <div class="text-[11px] text-emerald-700">Готов к скачиванию (задач: ${actionData.tasks_count || '—'})</div>
+                        </div>
+                    </div>
+                    <a href="${actionData.download_url}" download="${escapeHtml(actionData.filename)}" 
+                       class="px-3.5 py-1.5 bg-emerald-600 hover:bg-emerald-700 active:bg-emerald-800 text-white font-semibold rounded-lg text-xs flex items-center gap-1.5 transition shrink-0 shadow-sm">
+                        <i class="fa-solid fa-download"></i>
+                        <span>Скачать</span>
+                    </a>
+                </div>
+            `;
+        }
+
+        const isWideWidget = actionData && (actionData.type === "TASK_INTERACTIVE_CARD" || actionData.type === "PROMPT_PREVIEW");
+        const maxWidthClass = isWideWidget ? "max-w-4xl w-full" : "max-w-2xl";
+
         const botMsgHtml = `
-            <div class="bg-white border border-slate-200 rounded-2xl p-3.5 shadow-sm max-w-2xl mb-3">
+            <div class="chat-message-card bg-white border border-slate-200 rounded-2xl p-4 shadow-sm ${maxWidthClass} mb-3" data-original-baseline="${escapeHtml(baselineText)}">
                 <p class="text-[11px] font-bold text-indigo-600 uppercase tracking-wider mb-1">
                     <i class="fa-solid fa-robot mr-1"></i> ${assistantTitle}
                 </p>
-                <p class="text-slate-800 text-xs sm:text-sm whitespace-pre-wrap leading-relaxed">${escapeHtml(replyText)}</p>
+                <div class="prompt-preview-diff-view text-slate-800 text-xs sm:text-sm whitespace-pre-wrap leading-relaxed">${replyText}</div>
+                ${previewEditorHtml}
+                ${interactiveWidgetHtml}
+                ${snapshotsWidgetHtml}
+                ${fileDownloadHtml}
                 ${actionButtonsHtml}
             </div>
         `;
@@ -195,24 +439,17 @@ async function sendMessage(e) {
         `;
         chatWindow.insertAdjacentHTML("beforeend", errorHtml);
         chatWindow.scrollTop = chatWindow.scrollHeight;
+        setInputLocked(false);
     } finally {
-        if (sendBtn) {
+        const inputEl = document.getElementById("user-input");
+        if (sendBtn && (!inputEl || !inputEl.disabled)) {
             sendBtn.disabled = false;
             sendBtn.classList.remove("opacity-50");
         }
     }
 }
 
-function escapeHtml(text) {
+// --- [DRAG & DROP AND KEYBOARD LISTENERS] ---
-    if (!text) return "";
-    return text
-        .replace(/&/g, "&amp;")
-        .replace(/</g, "&lt;")
-        .replace(/>/g, "&gt;")
-        .replace(/"/g, "&quot;")
-        .replace(/'/g, "&#039;");
-}
-
 document.addEventListener("DOMContentLoaded", () => {
     const input = document.getElementById("user-input");
     const dropZone = document.getElementById("chat-window")?.parentElement;
@@ -225,6 +462,7 @@ document.addEventListener("DOMContentLoaded", () => {
         input.addEventListener("keydown", (e) => {
             if (e.key === "Enter" && !e.shiftKey) {
                 e.preventDefault();
+                if (input.disabled) return;
                 const text = input.value.trim();
                 if (text) {
                     if (localHistory.length === 0 || localHistory[0] !== text) {

modules/web_api/static/js/chat/task_widget.js

@@ -0,0 +1,445 @@
+/*
+===============================================================================
+FILE: modules/web_api/static/js/chat/task_widget.js
+ROLE: Интерактивные виджеты задач и срезов СКУД (SNAPSHOTS_CARD) с чекбоксами.
+===============================================================================
+*/
+
+window.activeTaskFilter = window.activeTaskFilter || 'IN_PROGRESS';
+window.currentTasksCache = window.currentTasksCache || [];
+
+function getAuthHeaders() {
+    const token = typeof API_TOKEN !== 'undefined' && API_TOKEN ? API_TOKEN : localStorage.getItem("scud_api_auth_token");
+    const headers = { 'Content-Type': 'application/json' };
+    if (token) {
+        headers['Authorization'] = 'Bearer ' + token;
+    }
+    return headers;
+}
+
+window.sendChatAction = function(actionText) {
+    const input = document.getElementById("user-input");
+    if (input && typeof sendMessage === "function") {
+        input.value = actionText;
+        if (typeof setInputLocked === "function") setInputLocked(false);
+        sendMessage();
+    }
+};
+
+// ============================================================================
+// РЕНДЕРИНГ КАРТОЧКИ СРЕЗОВ СКУД (SNAPSHOTS_CARD) С ЧЕКБОКСАМИ
+// ============================================================================
+function renderSnapshotsCard(data) {
+    if (!data || !data.snapshots || !Array.isArray(data.snapshots)) return '';
+    const queryDate = data.query_date || 'выбранную дату';
+    const snapshots = data.snapshots;
+
+    if (snapshots.length === 0) {
+        return `
+            <div class="p-6 bg-slate-50 border border-slate-200 rounded-xl text-center text-xs text-slate-500 my-2">
+                📸 За дату <b>${queryDate}</b> сохраненных снапшотов не найдено.
+            </div>
+        `;
+    }
+
+    const rowsHtml = snapshots.map((s, idx) => {
+        const snapId = s.snapshot_id || `ID-${idx}`;
+        const snapTime = s.snapshot_time ? s.snapshot_time.split(' ')[1] || s.snapshot_time : '—';
+        const count = s.record_count || 0;
+        const isFinal = snapId.startsWith('Y');
+
+        if (isFinal) {
+            return `
+                <div class="p-2.5 bg-purple-50/60 rounded-lg border border-purple-200 shadow-sm flex items-center justify-between gap-3">
+                    <div class="flex items-center gap-2.5 min-w-0">
+                        <span class="w-4 flex justify-center text-purple-400" title="Итоговый срез защищен">
+                            <i class="fa-solid fa-lock text-[11px]"></i>
+                        </span>
+                        <span class="font-mono text-xs font-bold px-2 py-0.5 rounded bg-purple-100 text-purple-800 border border-purple-300">
+                            #${snapId}
+                        </span>
+                        <div class="flex items-center gap-3 text-xs text-slate-600">
+                            <span class="flex items-center gap-1 font-semibold text-purple-900">
+                                <i class="fa-regular fa-clock text-purple-600 text-[11px]"></i> ${snapTime}
+                            </span>
+                            <span class="flex items-center gap-1 text-slate-500">
+                                <i class="fa-solid fa-users text-slate-400 text-[11px]"></i> ${count} записей
+                            </span>
+                        </div>
+                    </div>
+                    <span class="text-[10px] font-bold text-purple-700 bg-purple-100 border border-purple-200 px-2 py-0.5 rounded">
+                        Итоговый Y-срез
+                    </span>
+                </div>
+            `;
+        }
+
+        return `
+            <div class="p-2.5 bg-white rounded-lg border border-slate-200 shadow-sm hover:border-slate-300 transition flex items-center justify-between gap-3">
+                <div class="flex items-center gap-2.5 min-w-0">
+                    <input type="checkbox" value="${snapId}" onchange="window.updateSelectedSnapshots(this)" 
+                           class="snapshot-item-checkbox rounded border-slate-300 text-indigo-600 focus:ring-indigo-500 w-4 h-4 cursor-pointer">
+                    <span class="font-mono text-xs font-bold px-2 py-0.5 rounded bg-slate-100 text-slate-700 border border-slate-200">
+                        #${snapId}
+                    </span>
+                    <div class="flex items-center gap-3 text-xs text-slate-600">
+                        <span class="flex items-center gap-1 font-semibold text-slate-800">
+                            <i class="fa-regular fa-clock text-indigo-500 text-[11px]"></i> ${snapTime}
+                        </span>
+                        <span class="flex items-center gap-1 text-slate-500">
+                            <i class="fa-solid fa-users text-slate-400 text-[11px]"></i> ${count} записей
+                        </span>
+                    </div>
+                </div>
+                <button type="button" onclick="window.sendChatAction('удали снапшот ${snapId}')" 
+                        class="p-1 text-slate-400 hover:text-rose-600 hover:bg-rose-50 rounded border border-transparent hover:border-rose-200 transition" 
+                        title="Удалить срез">
+                    <i class="fa-solid fa-trash-can text-xs"></i>
+                </button>
+            </div>
+        `;
+    }).join('');
+
+    return `
+        <div class="snapshots-widget-root w-full max-w-4xl mx-auto my-2 bg-slate-50 border border-slate-300 rounded-xl shadow-md overflow-hidden flex flex-col">
+            <div class="px-4 py-2.5 bg-white border-b border-slate-200 flex items-center justify-between gap-2 flex-wrap">
+                <div class="flex items-center gap-2">
+                    <div class="bg-indigo-600 text-white p-1.5 rounded-lg flex items-center justify-center">
+                        <i class="fa-solid fa-camera text-xs"></i>
+                    </div>
+                    <div>
+                        <span class="text-xs font-bold text-slate-800">Реестр срезов СКУД</span>
+                        <span class="text-xs text-slate-500 ml-1">за ${queryDate}</span>
+                    </div>
+                </div>
+                <div class="flex items-center gap-3">
+                    <label class="flex items-center gap-1.5 text-xs text-slate-600 cursor-pointer select-none">
+                        <input type="checkbox" onchange="window.toggleSelectAllSnapshots(this)" class="select-all-snapshots-cb rounded border-slate-300 text-indigo-600 focus:ring-indigo-500 w-3.5 h-3.5">
+                        <span>Выбрать все</span>
+                    </label>
+                    <span class="text-[11px] font-semibold bg-indigo-50 text-indigo-700 border border-indigo-200 px-2 py-0.5 rounded-full">
+                        Срезов: ${snapshots.length}
+                    </span>
+                </div>
+            </div>
+
+            <div class="p-3 flex flex-col gap-2">
+                ${rowsHtml}
+            </div>
+
+            <!-- ПОДВАЛ С КНОПКОЙ УДАЛЕНИЯ ВЫБРАННЫХ -->
+            <div class="snapshot-bulk-actions-footer hidden px-4 py-2 bg-rose-50/70 border-t border-rose-200 flex items-center justify-between">
+                <span class="text-xs text-rose-800 font-medium bulk-selected-counter">Выбрано: 0</span>
+                <button type="button" onclick="window.submitBulkDeleteSnapshots(this)" 
+                        class="px-3 py-1.5 bg-rose-600 hover:bg-rose-700 active:bg-rose-800 text-white font-bold rounded-lg text-xs flex items-center gap-1.5 transition shadow-sm">
+                    <i class="fa-solid fa-trash-can"></i>
+                    <span>Удалить выбранные</span>
+                </button>
+            </div>
+        </div>
+    `;
+}
+
+// ⭐️ Обработчики чекбоксов
+window.toggleSelectAllSnapshots = function(masterCb) {
+    const root = masterCb.closest('.snapshots-widget-root');
+    if (!root) return;
+    const checkboxes = root.querySelectorAll('.snapshot-item-checkbox');
+    checkboxes.forEach(cb => cb.checked = masterCb.checked);
+    window.syncBulkDeleteFooter(root);
+};
+
+window.updateSelectedSnapshots = function(itemCb) {
+    const root = itemCb.closest('.snapshots-widget-root');
+    if (!root) return;
+    window.syncBulkDeleteFooter(root);
+};
+
+window.syncBulkDeleteFooter = function(root) {
+    const checkboxes = root.querySelectorAll('.snapshot-item-checkbox:checked');
+    const footer = root.querySelector('.snapshot-bulk-actions-footer');
+    const counter = root.querySelector('.bulk-selected-counter');
+    const masterCb = root.querySelector('.select-all-snapshots-cb');
+    const allCheckboxes = root.querySelectorAll('.snapshot-item-checkbox');
+
+    if (masterCb) {
+        masterCb.checked = allCheckboxes.length > 0 && checkboxes.length === allCheckboxes.length;
+    }
+
+    if (checkboxes.length > 0) {
+        if (footer) footer.classList.remove('hidden');
+        if (counter) counter.innerText = `Выбрано дневных срезов: ${checkboxes.length}`;
+    } else {
+        if (footer) footer.classList.add('hidden');
+    }
+};
+
+// Одиночная корзина в строке снапшота:
+// onclick="window.sendChatAction('удали снапшот ${snapId}')"
+
+// Кнопка пакетного удаления в подвале карточки:
+window.submitBulkDeleteSnapshots = function(btnEl) {
+    const root = btnEl.closest('.snapshots-widget-root');
+    if (!root) return;
+    const selected = Array.from(root.querySelectorAll('.snapshot-item-checkbox:checked')).map(cb => cb.value);
+    if (selected.length === 0) return;
+    window.sendChatAction(`удали снапшоты ${selected.join(', ')}`);
+};
+
+// ============================================================================
+// РЕНДЕРИНГ КАРТОЧКИ ЗАДАЧ (TASK_INTERACTIVE_CARD)
+// ============================================================================
+function renderInteractiveTaskCard(tasks) {
+    if (!tasks || !Array.isArray(tasks)) return '';
+    window.currentTasksCache = tasks;
+
+    const counts = {
+        ALL: tasks.length,
+        IN_PROGRESS: tasks.filter(t => t.status === 'IN_PROGRESS' || t.status === 'PROGRESS').length,
+        PLANNED: tasks.filter(t => t.status === 'BACKLOG' || t.status === 'PLANNED').length,
+        COMPLETED: tasks.filter(t => t.status === 'COMPLETED' || t.status === 'DONE').length
+    };
+
+    const currentFilter = window.activeTaskFilter || 'IN_PROGRESS';
+
+    const filteredTasks = tasks.filter(t => {
+        const s = (t.status || 'BACKLOG').toUpperCase();
+        if (currentFilter === 'ALL') return true;
+        if (currentFilter === 'IN_PROGRESS') return s === 'IN_PROGRESS' || s === 'PROGRESS';
+        if (currentFilter === 'PLANNED') return s === 'BACKLOG' || s === 'PLANNED';
+        if (currentFilter === 'COMPLETED') return s === 'COMPLETED' || s === 'DONE';
+        return true;
+    });
+
+    const getPrioBadge = (prio) => {
+        const p = (prio || 'MEDIUM').toUpperCase();
+        if (p === 'HIGH' || p === 'CRITICAL') return '<span class="text-[10px] px-2 py-0.5 rounded font-bold bg-rose-100 text-rose-700 border border-rose-200">🔥 HIGH</span>';
+        if (p === 'LOW') return '<span class="text-[10px] px-2 py-0.5 rounded font-semibold bg-slate-100 text-slate-600 border border-slate-200">☕ LOW</span>';
+        return '<span class="text-[10px] px-2 py-0.5 rounded font-semibold bg-amber-100 text-amber-700 border border-amber-200">⚡ MEDIUM</span>';
+    };
+
+    const getStatusBadge = (status) => {
+        const s = (status || 'BACKLOG').toUpperCase();
+        if (s === 'IN_PROGRESS' || s === 'PROGRESS') return '<span class="text-[10px] px-2 py-0.5 rounded font-bold bg-blue-50 text-blue-700 border border-blue-200">⚙️ В работе</span>';
+        if (s === 'COMPLETED' || s === 'DONE') return '<span class="text-[10px] px-2 py-0.5 rounded font-semibold bg-emerald-50 text-emerald-700 border border-emerald-200">✓ Готово</span>';
+        return '<span class="text-[10px] px-2 py-0.5 rounded font-semibold bg-slate-50 text-slate-600 border border-slate-200">📋 В планах</span>';
+    };
+
+    const taskRows = filteredTasks.map(t => {
+        const id = t.id;
+        const title = t.title || 'Без названия';
+        const isDone = t.status === 'COMPLETED' || t.status === 'DONE';
+        const isInProgress = t.status === 'IN_PROGRESS' || t.status === 'PROGRESS';
+
+        const actionBtn = isInProgress 
+            ? `<button type="button" onclick="window.sendChatAction('заверши задачу ${id}')" class="px-2.5 py-1 text-xs font-semibold rounded bg-emerald-50 text-emerald-700 border border-emerald-300 hover:bg-emerald-100 transition-colors shadow-sm" title="Завершить задачу">✓ Готово</button>`
+            : (!isDone 
+                ? `<button type="button" onclick="window.sendChatAction('возьми в работу задачу ${id}')" class="px-2.5 py-1 text-xs font-semibold rounded bg-blue-50 text-blue-700 border border-blue-300 hover:bg-blue-100 transition-colors shadow-sm" title="Взять в работу">⚙️ В работу</button>`
+                : '');
+
+        return `
+            <div id="task-card-${id}" class="p-3 bg-white rounded-lg border border-slate-200 shadow-sm hover:border-slate-300 transition-all flex flex-col gap-2">
+                <div class="task-view-mode flex items-center justify-between gap-3">
+                    <div class="flex items-center gap-2 flex-wrap flex-1 min-w-0">
+                        <span class="text-xs font-bold px-1.5 py-0.5 rounded bg-slate-100 text-slate-700 border border-slate-200">#${id}</span>
+                        <span class="text-sm font-medium text-slate-900 truncate" title="${title}">${title}</span>
+                    </div>
+                    <div class="flex items-center gap-1.5 shrink-0">
+                        ${actionBtn}
+                        <button type="button" onclick="window.openTaskInlineEditor(${id})" class="p-1 text-xs text-slate-500 hover:text-indigo-600 hover:bg-slate-50 rounded border border-slate-200 transition-colors" title="Редактировать">✏️</button>
+                        <button type="button" onclick="window.sendChatAction('удали задачу ${id}')" class="p-1 text-xs text-slate-400 hover:text-rose-600 hover:bg-rose-50 rounded border border-slate-200 transition-colors" title="Удалить">🗑️</button>
+                    </div>
+                </div>
+
+                <div class="task-view-mode flex items-center gap-2 text-xs text-slate-500 flex-wrap">
+                    ${getPrioBadge(t.priority)}
+                    ${getStatusBadge(t.status)}
+                    <span class="px-1.5 py-0.5 rounded bg-slate-50 border border-slate-200 text-slate-600 font-mono text-[11px]">${t.module || 'general'}</span>
+                    ${t.due_date ? `<span class="text-slate-500">📅 срок: <b>${t.due_date}</b></span>` : ''}
+                    ${t.created_at ? `<span class="text-slate-400">создана: ${t.created_at.split(' ')[0]}</span>` : ''}
+                </div>
+
+                <!-- ФОРМА ИНЛАЙН РЕДАКТИРОВАНИЯ -->
+                <div id="task-editor-${id}" class="hidden flex flex-col gap-2 pt-2 border-t border-slate-100">
+                    <input type="text" id="task-edit-title-${id}" value="${title.replace(/"/g, '&quot;')}" class="w-full text-xs px-2.5 py-1.5 border border-slate-300 rounded focus:border-indigo-500 focus:outline-none bg-slate-50" placeholder="Описание задачи..." />
+                    <div class="flex items-center gap-2 flex-wrap">
+                        <input type="date" id="task-edit-date-${id}" value="${t.due_date || ''}" class="text-xs px-2 py-1 border border-slate-300 rounded focus:border-indigo-500 focus:outline-none bg-slate-50" />
+                        <select id="task-edit-prio-${id}" class="text-xs px-2 py-1 border border-slate-300 rounded focus:border-indigo-500 focus:outline-none bg-slate-50">
+                            <option value="LOW" ${t.priority === 'LOW' ? 'selected' : ''}>☕ LOW</option>
+                            <option value="MEDIUM" ${t.priority === 'MEDIUM' || !t.priority ? 'selected' : ''}>⚡ MEDIUM</option>
+                            <option value="HIGH" ${t.priority === 'HIGH' ? 'selected' : ''}>🔥 HIGH</option>
+                            <option value="CRITICAL" ${t.priority === 'CRITICAL' ? 'selected' : ''}>🚨 CRITICAL</option>
+                        </select>
+                        <button type="button" onclick="window.saveTaskInlineEdit(${id})" class="px-2.5 py-1 text-xs font-semibold rounded bg-indigo-600 text-white hover:bg-indigo-700 transition-colors shadow-sm">Сохранить</button>
+                        <button type="button" onclick="window.closeTaskInlineEditor(${id})" class="px-2 py-1 text-xs font-medium rounded text-slate-500 hover:bg-slate-100 transition-colors">Отмена</button>
+                    </div>
+                </div>
+            </div>
+        `;
+    }).join('');
+
+    const emptyState = `
+        <div class="p-8 text-center text-slate-400">
+            <div class="text-3xl mb-2">📭</div>
+            <div class="text-sm font-medium">Нет задач в категории «${currentFilter}»</div>
+        </div>
+    `;
+
+    return `
+        <div class="task-widget-root w-full max-w-4xl mx-auto my-2 bg-slate-50 border border-slate-300 rounded-xl shadow-md overflow-hidden flex flex-col">
+            <div class="px-4 py-3 bg-white border-b border-slate-200 flex items-center justify-between gap-2 flex-wrap">
+                <div class="flex items-center gap-1.5 flex-wrap">
+                    <button type="button" onclick="window.switchTaskFilter('IN_PROGRESS', this)" class="px-2.5 py-1 text-xs font-bold rounded-md transition-colors ${currentFilter === 'IN_PROGRESS' ? 'bg-blue-600 text-white shadow-sm' : 'bg-slate-100 text-slate-600 hover:bg-slate-200'}">
+                        ⚙️ В работе (${counts.IN_PROGRESS})
+                    </button>
+                    <button type="button" onclick="window.switchTaskFilter('PLANNED', this)" class="px-2.5 py-1 text-xs font-bold rounded-md transition-colors ${currentFilter === 'PLANNED' ? 'bg-indigo-600 text-white shadow-sm' : 'bg-slate-100 text-slate-600 hover:bg-slate-200'}">
+                        📋 В планах (${counts.PLANNED})
+                    </button>
+                    <button type="button" onclick="window.switchTaskFilter('COMPLETED', this)" class="px-2.5 py-1 text-xs font-bold rounded-md transition-colors ${currentFilter === 'COMPLETED' ? 'bg-emerald-600 text-white shadow-sm' : 'bg-slate-100 text-slate-600 hover:bg-slate-200'}">
+                        ✓ Готово (${counts.COMPLETED})
+                    </button>
+                    <button type="button" onclick="window.switchTaskFilter('ALL', this)" class="px-2.5 py-1 text-xs font-bold rounded-md transition-colors ${currentFilter === 'ALL' ? 'bg-slate-800 text-white shadow-sm' : 'bg-slate-100 text-slate-600 hover:bg-slate-200'}">
+                        Все (${counts.ALL})
+                    </button>
+                </div>
+                
+                <button type="button" onclick="window.toggleCreateTaskForm(this)" class="px-3 py-1.5 text-xs font-bold rounded-md bg-indigo-600 hover:bg-indigo-700 text-white transition-all shadow-sm flex items-center gap-1">
+                    ➕ Добавить задачу
+                </button>
+            </div>
+
+            <div class="new-task-creation-form hidden p-3 bg-indigo-50/70 border-b border-indigo-100 flex flex-col gap-2">
+                <div class="text-xs font-bold text-indigo-900">Новая задача:</div>
+                <input type="text" class="new-task-title w-full text-xs px-2.5 py-1.5 border border-indigo-200 rounded focus:border-indigo-500 focus:outline-none bg-white" placeholder="Что необходимо сделать?..." />
+                <div class="flex items-center gap-2 flex-wrap">
+                    <input type="date" class="new-task-date text-xs px-2 py-1 border border-indigo-200 rounded focus:border-indigo-500 focus:outline-none bg-white" />
+                    <select class="new-task-prio text-xs px-2 py-1 border border-indigo-200 rounded focus:border-indigo-500 focus:outline-none bg-white">
+                        <option value="LOW">☕ LOW (Низкий)</option>
+                        <option value="MEDIUM" selected>⚡ MEDIUM (Средний)</option>
+                        <option value="HIGH">🔥 HIGH (Высокий)</option>
+                        <option value="CRITICAL">🚨 CRITICAL (Критический)</option>
+                    </select>
+                    <select class="new-task-status text-xs px-2 py-1 border border-indigo-200 rounded focus:border-indigo-500 focus:outline-none bg-white">
+                        <option value="BACKLOG" selected>📋 В планы (Бэклог)</option>
+                        <option value="IN_PROGRESS">⚙️ Сразу в работу</option>
+                    </select>
+                    <button type="button" onclick="window.submitCreateTask(this)" class="px-3 py-1 text-xs font-bold rounded bg-indigo-600 text-white hover:bg-indigo-700 transition-colors shadow-sm">Создать</button>
+                    <button type="button" onclick="window.toggleCreateTaskForm(this)" class="px-2 py-1 text-xs font-medium rounded text-slate-500 hover:bg-slate-200 transition-colors">Отмена</button>
+                </div>
+            </div>
+
+            <div class="p-3 overflow-y-auto max-h-[70vh] flex flex-col gap-2 task-rows-container">
+                ${filteredTasks.length > 0 ? taskRows : emptyState}
+            </div>
+        </div>
+    `;
+}
+
+window.switchTaskFilter = function(filterName, btnEl) {
+    window.activeTaskFilter = filterName;
+    const root = btnEl ? btnEl.closest('.task-widget-root') : document.querySelector('.task-widget-root');
+    if (root && window.currentTasksCache && window.currentTasksCache.length > 0) {
+        root.outerHTML = renderInteractiveTaskCard(window.currentTasksCache);
+    }
+};
+
+window.toggleCreateTaskForm = function(btnEl) {
+    const root = btnEl ? btnEl.closest('.task-widget-root') : document.querySelector('.task-widget-root');
+    if (!root) return;
+    const form = root.querySelector('.new-task-creation-form');
+    if (form) {
+        form.classList.toggle('hidden');
+        if (!form.classList.contains('hidden')) {
+            const input = form.querySelector('.new-task-title');
+            if (input) input.focus();
+        }
+    }
+};
+
+window.submitCreateTask = async function(btnEl) {
+    const root = btnEl ? btnEl.closest('.task-widget-root') : document.querySelector('.task-widget-root');
+    if (!root) return;
+
+    const titleInput = root.querySelector('.new-task-title');
+    const dateInput = root.querySelector('.new-task-date');
+    const prioInput = root.querySelector('.new-task-prio');
+    const statusInput = root.querySelector('.new-task-status');
+
+    if (!titleInput || !titleInput.value.trim()) {
+        alert('Введите описание задачи');
+        return;
+    }
+
+    try {
+        const res = await fetch('/api/v1/tasks', {
+            method: 'POST',
+            headers: getAuthHeaders(),
+            body: JSON.stringify({
+                title: titleInput.value.trim(),
+                due_date: dateInput ? (dateInput.value || null) : null,
+                priority: prioInput ? prioInput.value : 'MEDIUM',
+                status: statusInput ? statusInput.value : 'BACKLOG'
+            })
+        });
+
+        if (res.ok) {
+            window.activeTaskFilter = (statusInput && statusInput.value === 'IN_PROGRESS') ? 'IN_PROGRESS' : 'PLANNED';
+            window.sendChatAction('покажи задачи');
+        } else {
+            const err = await res.json();
+            alert('Ошибка создания задачи: ' + (err.detail || 'Неизвестная ошибка'));
+        }
+    } catch (e) {
+        console.error('Ошибка создания задачи:', e);
+        alert('Сетевая ошибка при создании задачи');
+    }
+};
+
+window.openTaskInlineEditor = function(id) {
+    const card = document.getElementById(`task-card-${id}`);
+    if (!card) return;
+    card.querySelectorAll('.task-view-mode').forEach(el => el.classList.add('hidden'));
+    const editor = document.getElementById(`task-editor-${id}`);
+    if (editor) editor.classList.remove('hidden');
+};
+
+window.closeTaskInlineEditor = function(id) {
+    const card = document.getElementById(`task-card-${id}`);
+    if (!card) return;
+    card.querySelectorAll('.task-view-mode').forEach(el => el.classList.remove('hidden'));
+    const editor = document.getElementById(`task-editor-${id}`);
+    if (editor) editor.classList.add('hidden');
+};
+
+window.saveTaskInlineEdit = async function(id) {
+    const titleInput = document.getElementById(`task-edit-title-${id}`);
+    const dateInput = document.getElementById(`task-edit-date-${id}`);
+    const prioInput = document.getElementById(`task-edit-prio-${id}`);
+
+    if (!titleInput || !titleInput.value.trim()) {
+        alert('Описание задачи не может быть пустым');
+        return;
+    }
+
+    try {
+        const res = await fetch(`/api/v1/tasks/${id}`, {
+            method: 'PATCH',
+            headers: getAuthHeaders(),
+            body: JSON.stringify({
+                title: titleInput.value.trim(),
+                due_date: dateInput ? (dateInput.value || null) : null,
+                priority: prioInput ? prioInput.value : 'MEDIUM'
+            })
+        });
+
+        if (res.ok) {
+            window.sendChatAction('покажи задачи');
+        } else {
+            const err = await res.json();
+            alert('Ошибка обновления задачи: ' + (err.detail || 'Неизвестная ошибка'));
+        }
+    } catch (e) {
+        console.error('Ошибка сохранения задачи:', e);
+        alert('Сетевая ошибка при обновлении задачи');
+    }
+};

modules/web_api/static/js/tasks.js

@@ -1,6 +1,20 @@
+/**
+===============================================================================
+FILE: modules/web_api/static/js/tasks.js
+ROLE: Управление боковой панелью задач (Drawer), фильтрация и рендеринг карточек.
+
+AI-CONTEXT-ANCHORS:
+  - ANCHOR[DRAWER_TOGGLE]: Открытие и закрытие выезжающей панели.
+  - ANCHOR[TASKS_FILTER]: Фильтрация списка (ALL, IN_PROGRESS, BACKLOG, COMPLETED).
+  - ANCHOR[TASKS_LOAD_FETCH]: Асинхронная загрузка задач через /api/v1/tasks.
+  - ANCHOR[TASKS_RENDER_DOM]: Генерация HTML-карточек в боковом меню.
+===============================================================================
+*/
+
 let currentFilter = 'ALL';
 let allTasks = [];
 
+// --- [SECTION 1: DRAWER TOGGLE] --- # ANCHOR[DRAWER_TOGGLE]
 function toggleDrawer() {
     if (typeof IS_GUEST !== 'undefined' && IS_GUEST) return;
     const drawer = document.getElementById("task-drawer");
@@ -18,6 +32,7 @@ function toggleDrawer() {
     }
 }
 
+// --- [SECTION 2: FILTER CONTROL] --- # ANCHOR[TASKS_FILTER]
 function setFilter(status) {
     currentFilter = status;
     ["ALL", "IN_PROGRESS", "BACKLOG", "COMPLETED"].forEach(f => {
@@ -31,6 +46,7 @@ function setFilter(status) {
     renderTasks();
 }
 
+// --- [SECTION 3: ASYNC DATA FETCH] --- # ANCHOR[TASKS_LOAD_FETCH]
 async function loadTasks() {
     const badge = document.getElementById("task-count-badge");
     const container = document.getElementById("tasks-container");
@@ -62,7 +78,6 @@ async function loadTasks() {
 
         const data = await res.json();
 
-        // Гибкое определение структуры данных (массив или объект с ключом tasks)
         if (Array.isArray(data)) {
             allTasks = data;
         } else if (data && Array.isArray(data.tasks)) {
@@ -88,6 +103,7 @@ async function loadTasks() {
     }
 }
 
+// --- [SECTION 4: DOM RENDERING] --- # ANCHOR[TASKS_RENDER_DOM]
 function renderTasks() {
     const container = document.getElementById("tasks-container");
     if (!container) return;
@@ -105,13 +121,16 @@ function renderTasks() {
 
     container.innerHTML = filtered.map(t => {
         let statusBadge = "bg-slate-100 text-slate-600 border-slate-200";
+        let statusLabel = "В планах";
         let cardBg = "bg-white";
         
         if (t.status === "COMPLETED") {
             statusBadge = "bg-emerald-50 text-emerald-700 border-emerald-300 font-semibold";
+            statusLabel = "Завершено";
             cardBg = "bg-emerald-50/20";
         } else if (t.status === "IN_PROGRESS") {
             statusBadge = "bg-amber-50 text-amber-700 border-amber-300 font-bold";
+            statusLabel = "В работе";
             cardBg = "bg-amber-50/20 border-amber-200";
         }
 
@@ -131,7 +150,7 @@ function renderTasks() {
                         <span class="font-mono text-xs font-bold text-slate-900 bg-slate-100 px-2 py-0.5 rounded border border-slate-200">${t.task_id || t.id || 'TASK'}</span>
                         <span class="text-[10px] uppercase px-1.5 py-0.5 rounded border ${priorityBadge}">${t.priority || 'MEDIUM'}</span>
                     </div>
-                    <span class="text-[10px] uppercase px-2 py-0.5 rounded border ${statusBadge}">${t.status || 'BACKLOG'}</span>
+                    <span class="text-[10px] uppercase px-2 py-0.5 rounded border ${statusBadge}">${statusLabel}</span>
                 </div>
                 <h3 class="text-xs font-semibold text-slate-800 mb-1 leading-snug">${t.title || t.description || ''}</h3>
                 <div class="text-[10px] text-slate-400 font-mono flex items-center gap-1">

scripts/db_cli.py

@@ -51,11 +51,14 @@ def print_stats():
     print("=" * 60)
     with get_connection() as conn:
         cursor = conn.cursor()
-        tables = ['scud_logs', 'zup_staff', 'zup_absences', 'anomalies_history', 'ai_knowledge_base']
+        tables = ['scud_logs', 'zup_staff', 'zup_absences', 'anomalies_history', 'ai_knowledge_base', 'chat_messages', 'session_states', 'system_prompt_nodes', 'tasks']
         for t in tables:
+            try:
                 cursor.execute(f"SELECT COUNT(*) FROM {t}")
                 cnt = cursor.fetchone()[0]
-            print(f"  • Таблица [{t:<18}]: {cnt:>6} записей")
+                print(f"  • Таблица [{t:<20}]: {cnt:>6} записей")
+            except Exception:
+                pass
     print("=" * 60 + "\n")
 
 
@@ -148,7 +151,7 @@ def inspect_scud(snapshot_id=None, date_str=None, export_xlsx=None):
     df = load_scud_from_db_by_snapshot(target_date, snapshot_param=snapshot_id)
 
     if df.empty:
-        print(f"Записи СКУД не найдены.")
+        print("Записи СКУД не найдены.")
         print("=" * 90 + "\n")
         return
 
@@ -236,28 +239,35 @@ def dump_all_to_excel(out_filename="db_dump_full.xlsx"):
     out_path = os.path.join(OUTPUT_DIR, out_filename)
     print(f"\n[🔄] Создание полного дампа БД в файл: {out_path} ...")
     with get_connection() as conn, pd.ExcelWriter(out_path, engine='openpyxl') as writer:
-        for table in ['scud_logs', 'zup_staff', 'zup_absences', 'anomalies_history', 'ai_knowledge_base']:
+        for table in ['scud_logs', 'zup_staff', 'zup_absences', 'anomalies_history', 'ai_knowledge_base', 'chat_messages', 'session_states', 'system_prompt_nodes', 'tasks']:
+            try:
                 df = pd.read_sql_query(f"SELECT * FROM {table}", conn)
                 df.to_excel(writer, sheet_name=table[:31], index=False)
+            except Exception:
+                pass
     print(f"[✓] Дамп успешно сохранен: {out_path}\n")
 
 
 def print_system_prompts():
     """Выводит все системные промпты из базы данных."""
     print("\n" + "=" * 80)
-    print("📝 СИСТЕМНЫЕ ПРОМПТЫ (system_prompts):")
+    print("📝 СИСТЕМНЫЕ ПРОМПТЫ (system_prompt_nodes):")
     print("=" * 80)
     with get_connection() as conn:
         cursor = conn.cursor()
-        cursor.execute("SELECT id, name, is_active, updated_at, prompt_text FROM system_prompts ORDER BY id DESC")
+        try:
+            cursor.execute("SELECT section_id, item_id, content, is_active, updated_at FROM system_prompt_nodes ORDER BY section_id ASC, item_id ASC")
             rows = cursor.fetchall()
+        except Exception:
+            rows = []
+        
         if not rows:
-            print("Таблица system_prompts пуста.")
+            print("Таблица system_prompt_nodes пуста.")
         else:
             for r in rows:
-                print(f"ID: {r[0]} | Name: {r[1]} | Active: {r[2]} | Updated: {r[3]}")
+                print(f"Раздел {r[0]}.{r[1]} | Active: {r[3]} | Updated: {r[4]}")
+                print(f"  {r[2]}")
                 print("-" * 80)
-                print(f"{r[4]}\n")
     print("=" * 80 + "\n")
 
 
@@ -280,6 +290,89 @@ def print_session_states():
     print("=" * 80 + "\n")    
 
 
+def print_chat_messages(session_id=None, limit=50):
+    """Выводит таблицу истории сообщений чата (контекст)."""
+    print("\n" + "=" * 105)
+    print(f"💬 ИСТОРИЯ СООБЩЕНИЙ ЧАТА (chat_messages) {f'для сессии: {session_id}' if session_id else 'все сессии'}:")
+    print("=" * 105)
+    
+    with get_connection() as conn:
+        cursor = conn.cursor()
+        if session_id:
+            cursor.execute("""
+                SELECT id, session_id, role, content, is_ephemeral, created_at 
+                FROM chat_messages 
+                WHERE session_id = ? 
+                ORDER BY id ASC 
+                LIMIT ?
+            """, (session_id, limit))
+        else:
+            cursor.execute("""
+                SELECT id, session_id, role, content, is_ephemeral, created_at 
+                FROM chat_messages 
+                ORDER BY id DESC 
+                LIMIT ?
+            """, (limit,))
+            
+        rows = cursor.fetchall()
+        if not rows:
+            print("Таблица chat_messages пуста.")
+        else:
+            if not session_id:
+                rows = list(reversed(rows))
+                
+            for r in rows:
+                msg_id, sess, role, content, ephemeral, created = r
+                eph_marker = " [ЭФЕМЕРНОЕ]" if ephemeral else ""
+                print(f"[{msg_id}] {created} | Сессия: {sess} | Роль: {role.upper()}{eph_marker}")
+                print("-" * 105)
+                content_preview = content if content else ""
+                print(f"{content_preview}")
+                print("=" * 105)
+    print("\n")
+
+
+def purge_chat_context(session_id=None, purge_all=False):
+    """
+    Очистка контекста сообщений:
+    - По умолчанию: удаляет эфемерные сообщения, осиротевшие превью и сбрасывает стейты сессий.
+    - purge_all=True (--all): полностью очищает всю таблицу chat_messages и сбрасывает сессии.
+    """
+    with get_connection() as conn:
+        cursor = conn.cursor()
+        
+        if purge_all:
+            if session_id:
+                cursor.execute("DELETE FROM chat_messages WHERE session_id = ?", (session_id,))
+                cursor.execute("DELETE FROM session_states WHERE session_id = ?", (session_id,))
+            else:
+                cursor.execute("DELETE FROM chat_messages")
+                cursor.execute("DELETE FROM session_states")
+            deleted_msgs = cursor.rowcount
+            conn.commit()
+            print(f"\n[✓] Полная очистка истории выполнена! Удалено сообщений: {deleted_msgs}\n")
+            return
+
+        query = """
+            DELETE FROM chat_messages 
+            WHERE is_ephemeral = 1 
+               OR content LIKE '%Предпросмотр изменений%'
+               OR content LIKE '%Удален пункт:%'
+               OR content LIKE '%добавлен пункт:%'
+        """
+        if session_id:
+            cursor.execute(query + " AND session_id = ?", (session_id,))
+            cursor.execute("DELETE FROM session_states WHERE session_id = ?", (session_id,))
+        else:
+            cursor.execute(query)
+            cursor.execute("DELETE FROM session_states")
+        
+        deleted_msgs = cursor.rowcount
+        conn.commit()
+        
+    print(f"\n[✓] Умная зачистка контекста выполнена! Удалено сообщений: {deleted_msgs}\n")
+
+
 HELP_TEXT = """
 CLI-утилита инспекции и управления SQLite базой данных СКУД (scud_orion_ai.db)
 
@@ -290,9 +383,11 @@ CLI-утилита инспекции и управления SQLite базой
   absences [ДД.ММ.ГГГГ]                                      -- Посмотреть список официально отсутствующих из 1С:ЗУП
   anomalies                                                  -- Посмотреть историю найденных аномалий СКУД ⟷ 1С
   rules                                                      -- Посмотреть правила Базы Знаний ИИ из SQLite
-  prompts                                                    -- Посмотреть системные промпты (system_prompts)
+  prompts                                                    -- Посмотреть узлы системного промпта (system_prompt_nodes)
   tools                                                      -- Посмотреть реестр действий инструментов и кнопок (tool_action_registry)
   sessions                                                   -- Посмотреть активные сессии и превью (session_states)
+  context [session_id] [--limit N]                           -- Посмотреть таблицу контекста сообщений чата (chat_messages)
+  context purge [session_id] [--all]                         -- Очистить контекст (умная зачистка или полная с флагом --all)
   dump [output.xlsx]                                         -- Полный дамп всех таблиц БД в многостраничный Excel
   snapshot del [ID] или [--day ДД.ММ.ГГГГ]                   -- Удаление снапшота по ID или всех за выбранный день
 
@@ -300,13 +395,15 @@ CLI-утилита инспекции и управления SQLite базой
   python scripts/db_cli.py stats
   python scripts/db_cli.py snapshots 06.08.2026
   python scripts/db_cli.py scud 06.08.2026 --export-xlsx срез_четверг
-  python scripts/db_cli.py scud --snapshot Y20260805-007
   python scripts/db_cli.py absences 07.08.2026
   python scripts/db_cli.py prompts
   python scripts/db_cli.py tools
   python scripts/db_cli.py sessions
+  python scripts/db_cli.py context web_session_main --limit 20
+  python scripts/db_cli.py context purge
+  python scripts/db_cli.py context purge --all
+  python scripts/db_cli.py context purge web_session_main --all
   python scripts/db_cli.py snapshot del Y20260805-007
-  python scripts/db_cli.py snapshot del --day 04.08.2026
   python scripts/db_cli.py dump my_dump.xlsx
 """
 
@@ -321,12 +418,14 @@ def main():
         formatter_class=argparse.RawDescriptionHelpFormatter,
         add_help=False
     )
-    parser.add_argument('command', nargs='?', default=None, choices=['stats', 'snapshots', 'scud', 'absences', 'anomalies', 'rules', 'prompts', 'sessions', 'dump', 'snapshot', 'tools'], help="Основная команда")
+    parser.add_argument('command', nargs='?', default=None, choices=['stats', 'snapshots', 'scud', 'absences', 'anomalies', 'rules', 'prompts', 'sessions', 'dump', 'snapshot', 'tools', 'context'], help="Основная команда")
-    parser.add_argument('action', nargs='?', default=None, help="Дополнительное действие (например, 'del')")
+    parser.add_argument('action', nargs='?', default=None, help="Дополнительное действие (например, 'del', 'purge') или session_id для контекста")
-    parser.add_argument('param', nargs='?', default=None, help="Параметр (дата, ID снапшота или имя файла)")
+    parser.add_argument('param', nargs='?', default=None, help="Параметр (дата, ID снапшота, session_id, '--all' или имя файла)")
     parser.add_argument('--snapshot', type=str, default=None, help="ID конкретного снапшота для инспекции")
     parser.add_argument('--export-xlsx', type=str, default=None, help="Экспорт среза СКУД в Excel-файл")
     parser.add_argument('--day', type=str, default=None, help="Удалить снапшоты за конкретный день (ДД.ММ.ГГГГ)")
+    parser.add_argument('--limit', type=int, default=50, help="Лимит выводимых сообщений чата (для команды context)")
+    parser.add_argument('--all', action='store_true', help="Полная очистка всех сообщений (для команды context purge)")
 
     if len(sys.argv) == 1:
         print_stats()
@@ -354,6 +453,14 @@ def main():
         print_session_states()
     elif args.command == 'tools':
         print_tool_actions()
+    elif args.command == 'context':
+        if args.action in ['purge', 'clear']:
+            is_all = args.all or (args.param == '--all')
+            sess_id = None if (args.param == '--all' or not args.param) else args.param
+            purge_chat_context(session_id=sess_id, purge_all=is_all)
+        else:
+            sess_id = args.action if args.action else None
+            print_chat_messages(session_id=sess_id, limit=args.limit)
     elif args.command == 'dump':
         filename = args.param if args.param else "db_dump_full.xlsx"
         dump_all_to_excel(filename)
@@ -370,7 +477,7 @@ def main():
             print(f"\n[❌] Ошибка: Неизвестное действие '{args.action}' для команды snapshot.")
             print("Используйте: python scripts/db_cli.py snapshot del [ID или --day 'ДД.ММ.ГГГГ']\n")
     else:
-        print(f"\n[❌] Ошибка: Неизвестная команда.")
+        print("\n[❌] Ошибка: Неизвестная команда.")
         print(HELP_TEXT)
 
 if __name__ == "__main__":

scripts/diagnostics/inspect_ephemeral.py

@@ -0,0 +1,58 @@
+import os
+import sqlite3
+
+DB_PATH = os.path.join(os.path.dirname(__file__), "../../data/scud_orion_ai.db")
+if not os.path.exists(DB_PATH):
+    DB_PATH = "data/scud_orion_ai.db"
+
+conn = sqlite3.connect(DB_PATH)
+cursor = conn.cursor()
+
+print("=" * 90)
+print(f"🔍 ИНСПЕКЦИЯ СООБЩЕНИЙ В БАЗЕ: {DB_PATH}")
+print("=" * 90)
+
+# 1. Проверяем наличие колонки is_ephemeral
+cursor.execute("PRAGMA table_info(chat_messages);")
+cols = [c[1] for c in cursor.fetchall()]
+
+if "is_ephemeral" not in cols:
+    print("❌ Колонка is_ephemeral отсутствует в таблице chat_messages!")
+    conn.close()
+    exit(1)
+
+# 2. Считаем общее количество и распределение
+cursor.execute("SELECT COUNT(*) FROM chat_messages")
+total_count = cursor.fetchone()[0]
+
+cursor.execute("SELECT COUNT(*) FROM chat_messages WHERE is_ephemeral = 1")
+ephemeral_count = cursor.fetchone()[0]
+
+cursor.execute("SELECT COUNT(*) FROM chat_messages WHERE is_ephemeral = 0")
+permanent_count = cursor.fetchone()[0]
+
+print(f"Всего записей в истории: {total_count}")
+print(f"  • Постоянные (is_ephemeral = 0): {permanent_count}")
+print(f"  • Фантомные / Эфемерные (is_ephemeral = 1): {ephemeral_count}")
+print("-" * 90)
+
+# 3. Выводим все фантомные записи
+if ephemeral_count == 0:
+    print("В базе нет фантомных записей (is_ephemeral = 1 пуст).")
+else:
+    print(f"📋 СПИСОК ВСЕХ ФАНТОМНЫХ СООБЩЕНИЙ ({ephemeral_count} шт.):")
+    cursor.execute("""
+        SELECT id, session_id, role, created_at, content 
+        FROM chat_messages 
+        WHERE is_ephemeral = 1 
+        ORDER BY id ASC
+    """)
+    for row in cursor.fetchall():
+        msg_id, session_id, role, created_at, content = row
+        print(f"\n[ID: {msg_id}] | Сессия: {session_id} | Роль: {role} | Время: {created_at}")
+        print("Содержимое:")
+        print(content.strip())
+        print("-" * 70)
+
+conn.close()
+print("=" * 90)

scripts/diagnostics/make_code_snapshot.py

@@ -2,15 +2,29 @@ import os
 
 OUTPUT_SNAPSHOT = "project_code_snapshot.md"
 
-# Расширения файлов для включения в снимок
+# Расширения файлов для включения в снимок (только исходный код)
-ALLOWED_EXTENSIONS = {'.py', '.json', '.md', '.sh', '.ini'}
+ALLOWED_EXTENSIONS = {'.py', '.json', '.sh', '.ini', '.js', '.html', '.css', '.sql'}
-EXCLUDE_DIRS = {'.git', '__pycache__', 'venv', '.venv', 'output', 'logs', 'extracted_project'}
-EXCLUDE_FILES = {OUTPUT_SNAPSHOT, 'scud_orion_ai_v2.tar.gz', 'context_memory.db'}
 
-print(f"🔄 Сборка полного контекстного слепка проекта в {OUTPUT_SNAPSHOT}...")
+# Исключаемые каталоги (убираем docs, кэши, архивы и окружения)
+EXCLUDE_DIRS = {
+    '.git', '__pycache__', 'venv', '.venv', 'output', 'logs', 
+    'extracted_project', 'docs', 'data'
+}
+
+# Исключаемые файлы
+EXCLUDE_FILES = {
+    OUTPUT_SNAPSHOT, 
+    'api_code_snapshot.md', 
+    'project_code_snapshot.md', 
+    'scud_orion_ai_v2.tar.gz', 
+    'scud_context_api.tar.gz',
+    'context_memory.db'
+}
+
+print(f"🔄 Сборка оптимизированного слепка кода в {OUTPUT_SNAPSHOT}...")
 
 with open(OUTPUT_SNAPSHOT, 'w', encoding='utf-8') as out:
-    out.write("# 📦 ПОЛНЫЙ ИСХОДНЫЙ КОД И КОНФИГУРАЦИЯ ПРОЕКТА scud_orion_ai_v2\n\n")
+    out.write("# 📦 ОПТИМИЗИРОВАННЫЙ СЛЕПОК ИСХОДНОГО КОДА scud_orion_ai\n\n")
     
     for root, dirs, files in os.walk('.'):
         dirs[:] = [d for d in dirs if d not in EXCLUDE_DIRS]
@@ -20,7 +34,7 @@ with open(OUTPUT_SNAPSHOT, 'w', encoding='utf-8') as out:
             if ext in ALLOWED_EXTENSIONS and file not in EXCLUDE_FILES:
                 filepath = os.path.join(root, file)
                 out.write(f"## File: `{filepath}`\n")
-                out.write("```" + (ext.replace('.', '') if ext != '.md' else '') + "\n")
+                out.write("```" + ext.replace('.', '') + "\n")
                 try:
                     with open(filepath, 'r', encoding='utf-8', errors='replace') as f:
                         out.write(f.read())
@@ -28,4 +42,5 @@ with open(OUTPUT_SNAPSHOT, 'w', encoding='utf-8') as out:
                     out.write(f"// Ошибка чтения файла: {e}\n")
                 out.write("\n```\n\n")
 
-print(f"✓ Успешно создан слепок проекта: {OUTPUT_SNAPSHOT} ({os.path.getsize(OUTPUT_SNAPSHOT):,} bytes)")
+size_kb = os.path.getsize(OUTPUT_SNAPSHOT) / 1024
+print(f"✓ Слепок успешно создан: {OUTPUT_SNAPSHOT} ({size_kb:.1f} KB)")