- ${itemsHtml}
+
+ ${rowsHtml}
-
-
-
`;
}
-function filterTaskWidget(widgetId, status, btnEl) {
- const state = activeWidgetTasksMap.get(widgetId);
- if (!state) return;
- state.filter = status;
+// ⭐️ Обработчики чекбоксов
+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);
+};
- const widgetEl = document.getElementById(widgetId);
- if (!widgetEl) return;
+window.updateSelectedSnapshots = function(itemCb) {
+ const root = itemCb.closest('.snapshots-widget-root');
+ if (!root) return;
+ window.syncBulkDeleteFooter(root);
+};
- widgetEl.querySelectorAll(".widget-tab-btn").forEach(b => {
- b.className = "widget-tab-btn px-2.5 py-1 rounded-lg text-slate-500 hover:text-slate-700";
+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;
});
- btnEl.className = "widget-tab-btn px-2.5 py-1 rounded-lg bg-indigo-50 text-indigo-600 font-bold border border-indigo-200";
- const container = widgetEl.querySelector(".widget-items-container");
- if (container) {
- container.innerHTML = renderTaskItemsHtml(state.tasks, status);
- }
+ const getPrioBadge = (prio) => {
+ const p = (prio || 'MEDIUM').toUpperCase();
+ if (p === 'HIGH' || p === 'CRITICAL') return '
🔥 HIGH';
+ if (p === 'LOW') return '
☕ LOW';
+ return '
⚡ MEDIUM';
+ };
+
+ const getStatusBadge = (status) => {
+ const s = (status || 'BACKLOG').toUpperCase();
+ if (s === 'IN_PROGRESS' || s === 'PROGRESS') return '
⚙️ В работе';
+ if (s === 'COMPLETED' || s === 'DONE') return '
✓ Готово';
+ return '
📋 В планах';
+ };
+
+ 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
+ ? `
`
+ : (!isDone
+ ? `
`
+ : '');
+
+ return `
+
+
+
+ #${id}
+ ${title}
+
+
+ ${actionBtn}
+
+
+
+
+
+
+ ${getPrioBadge(t.priority)}
+ ${getStatusBadge(t.status)}
+ ${t.module || 'general'}
+ ${t.due_date ? `📅 срок: ${t.due_date}` : ''}
+ ${t.created_at ? `создана: ${t.created_at.split(' ')[0]}` : ''}
+
+
+
+
+
+ `;
+ }).join('');
+
+ const emptyState = `
+
+
📭
+
Нет задач в категории «${currentFilter}»
+
+ `;
+
+ return `
+
+ `;
}
-async function toggleTaskStatusInline(taskId, isChecked) {
- const token = typeof API_TOKEN !== 'undefined' && API_TOKEN ? API_TOKEN : localStorage.getItem("scud_api_auth_token");
- const newStatus = isChecked ? "COMPLETED" : "BACKLOG";
+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/${taskId}`, {
- method: "PATCH",
- headers: {
- "Content-Type": "application/json",
- "Authorization": "Bearer " + token
- },
- body: JSON.stringify({ status: newStatus })
+ 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) {
- for (let [wId, state] of activeWidgetTasksMap.entries()) {
- const targetTask = state.tasks.find(t => t.task_id === taskId);
- if (targetTask) {
- targetTask.status = newStatus;
- const widgetEl = document.getElementById(wId);
- const container = widgetEl?.querySelector(".widget-items-container");
- if (container) {
- container.innerHTML = renderTaskItemsHtml(state.tasks, state.filter);
- }
- }
- }
- if (typeof loadTasks === "function") loadTasks();
+ window.activeTaskFilter = (statusInput && statusInput.value === 'IN_PROGRESS') ? 'IN_PROGRESS' : 'PLANNED';
+ window.sendChatAction('покажи задачи');
+ } else {
+ const err = await res.json();
+ alert('Ошибка создания задачи: ' + (err.detail || 'Неизвестная ошибка'));
}
- } catch (err) {
- console.error("[Task Patch Error]", err);
+ } catch (e) {
+ console.error('Ошибка создания задачи:', e);
+ alert('Сетевая ошибка при создании задачи');
}
-}
+};
-async function deleteTaskInline(taskId) {
- if (!confirm(`Удалить задачу ${taskId}?`)) return;
- const token = typeof API_TOKEN !== 'undefined' && API_TOKEN ? API_TOKEN : localStorage.getItem("scud_api_auth_token");
+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/${taskId}`, {
- method: "DELETE",
- headers: { "Authorization": "Bearer " + token }
+ 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) {
- for (let [wId, state] of activeWidgetTasksMap.entries()) {
- state.tasks = state.tasks.filter(t => t.task_id !== taskId);
- const widgetEl = document.getElementById(wId);
- const container = widgetEl?.querySelector(".widget-items-container");
- if (container) {
- container.innerHTML = renderTaskItemsHtml(state.tasks, state.filter);
- }
- }
- if (typeof loadTasks === "function") loadTasks();
+ window.sendChatAction('покажи задачи');
+ } else {
+ const err = await res.json();
+ alert('Ошибка обновления задачи: ' + (err.detail || 'Неизвестная ошибка'));
}
- } catch (err) {
- console.error("[Task Delete Error]", err);
+ } catch (e) {
+ console.error('Ошибка сохранения задачи:', e);
+ alert('Сетевая ошибка при обновлении задачи');
}
-}
-
-async function addTaskInline(widgetId, inputEl) {
- if (!inputEl) return;
- const title = inputEl.value.trim();
- if (!title) return;
-
- const token = typeof API_TOKEN !== 'undefined' && API_TOKEN ? API_TOKEN : localStorage.getItem("scud_api_auth_token");
-
- try {
- const res = await fetch("/api/v1/tasks", {
- method: "POST",
- headers: {
- "Content-Type": "application/json",
- "Authorization": "Bearer " + token
- },
- body: JSON.stringify({ title: title, priority: "MEDIUM", module: "general" })
- });
-
- if (res.ok) {
- inputEl.value = "";
- const tasksRes = await fetch("/api/v1/tasks", {
- headers: { "Authorization": "Bearer " + token }
- });
- const updatedTasks = await tasksRes.json();
-
- const state = activeWidgetTasksMap.get(widgetId);
- if (state) {
- state.tasks = updatedTasks;
- const widgetEl = document.getElementById(widgetId);
- const container = widgetEl?.querySelector(".widget-items-container");
- if (container) {
- container.innerHTML = renderTaskItemsHtml(updatedTasks, state.filter);
- }
- }
- if (typeof loadTasks === "function") loadTasks();
- }
- } catch (err) {
- console.error("[Task Add Error]", err);
- }
-}
+};
```
## File: `./modules/web_api/static/css/styles.css`
@@ -6304,80 +6139,168 @@ def update_draft_endpoint(
if not state or state.get("state_type") != "PROMPT_PREVIEW":
raise HTTPException(status_code=400, detail="Нет активного превью для редактирования")
- db_set_session_state(req.session_id, "PROMPT_PREVIEW", {"draft_text": req.draft_text.strip()})
+ # Сохраняем чистый текст с пометкой 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": "Черновик успешно обновлен в сессии"}
```
+## File: `./modules/web_api/routers/files.py`
+```py
+"""
+===============================================================================
+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}"
+ }
+ )
+```
+
## File: `./modules/web_api/routers/tasks.py`
```py
"""
===============================================================================
FILE: modules/web_api/routers/tasks.py
-ROLE: REST API управления задачами (GET / POST / PATCH / DELETE).
+PROJECT: SCUD Orion AI (Unified Architecture)
+MODULE: web_api / routers
+ROLE: REST API эндпоинты реестра задач (получение, создание и обновление).
===============================================================================
"""
-# ANCHOR[TASKS_ROUTER_IMPORTS]
-from typing import Dict, Any, Optional
-from fastapi import APIRouter, Depends, HTTPException
+from fastapi import APIRouter, Depends, HTTPException, Request
from pydantic import BaseModel
+from typing import Optional, Dict, Any
-from .auth import get_current_user
-from llm.db_tools import (
- db_get_tasks,
- db_add_task,
- db_update_task_status,
- db_delete_task
-)
+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"])
+router = APIRouter(prefix="/api/v1/tasks", tags=["Tasks"])
-# ANCHOR[TASKS_SCHEMAS]
-class CreateTaskRequest(BaseModel):
+class TaskCreateRequest(BaseModel):
title: str
priority: Optional[str] = "MEDIUM"
module: Optional[str] = "general"
due_date: Optional[str] = None
+ status: Optional[str] = "BACKLOG"
-class UpdateTaskRequest(BaseModel):
- status: Optional[str] = "COMPLETED"
+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
+
-# ANCHOR[TASKS_ENDPOINTS]
@router.get("")
-def get_tasks(user: Dict[str, Any] = Depends(get_current_user)):
- """Получить список всех задач текущего авторизованного пользователя."""
- return db_get_tasks(user_id=user["id"])
+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("")
-def create_task_endpoint(req: CreateTaskRequest, user: Dict[str, Any] = Depends(get_current_user)):
- """Прямое создание задачи."""
+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 or "general",
- title=req.title.strip(),
- priority=req.priority or "MEDIUM",
- due_date=req.due_date
- )
- return res
-
-@router.patch("/{task_id}")
-def update_task_endpoint(task_id: str, req: UpdateTaskRequest, user: Dict[str, Any] = Depends(get_current_user)):
- """Прямое обновление статуса и срока задачи."""
- res = db_update_task_status(
- user_id=user["id"],
- task_id=task_id,
- status=req.status or "COMPLETED",
- due_date=req.due_date
+ 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=404, detail=res["error"])
+ raise HTTPException(status_code=400, detail=res["error"])
return res
-@router.delete("/{task_id}")
-def delete_task_endpoint(task_id: str, user: Dict[str, Any] = Depends(get_current_user)):
- """Прямое удаление задачи."""
- res = db_delete_task(user_id=user["id"], task_id=task_id)
+
+@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
@@ -6395,13 +6318,22 @@ def delete_task_endpoint(task_id: str, user: Dict[str, Any] = Depends(get_curren
FILE: modules/web_api/llm/agent.py
PROJECT: SCUD Orion AI (Unified Architecture)
MODULE: web_api / llm (Core Agent Coordinator)
-ROLE: Оркестратор диалога, диспетчер реляционных узлов промпта и инструментов.
+ROLE: Нативный оркестратор диалога, диспетчер инструментов (Function Calling)
+ и управление сессионными стейтами через ContextManager.
+
+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]: Защита контекста и обработка свободных тем.
===============================================================================
"""
+
+# ANCHOR[AGENT_IMPORTS]
import sys
import json
import logging
-import re
from typing import List, Dict, Any, Tuple, Optional
from .db.connection import get_db_connection
@@ -6413,6 +6345,8 @@ from .db_tools import (
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,
@@ -6433,6 +6367,12 @@ 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
+)
logger = logging.getLogger("SCUD_AGENT")
logger.setLevel(logging.INFO)
@@ -6445,6 +6385,7 @@ if not logger.handlers:
logger.addHandler(handler)
+# ANCHOR[AGENT_MAIN_PIPELINE]
def process_chat_message(
user_id: int,
user_message: str,
@@ -6453,58 +6394,93 @@ def process_chat_message(
chat_history: List[Dict[str, Any]] = None,
session_id: str = "web_session_main"
) -> Tuple[str, List[Dict[str, Any]], Optional[Dict[str, Any]]]:
- """Главный конвейер диалога с нативным Function Calling и реляционными узлами."""
+ """
+ Главный конвейер обработки входящего сообщения чата на базе нативного Function Calling.
+ """
logger.info(f"Получено сообщение от user_id={user_id}, session_id={session_id}: {user_message}")
- full_user_content = f"{user_message}\n\n[СОДЕРЖИМОЕ ПРИКРЕПЛЕННОГО ФАЙЛА]:\n{file_context}" if file_context else user_message
session_state = db_get_session_state(session_id)
+ if not session_state:
+ db_purge_ephemeral_messages(session_id)
- # 1. Fast-Path перехват кнопок
+ full_user_content = f"{user_message}\n\n[СОДЕРЖИМОЕ ПРИКРЕПЛЕННОГО ФАЙЛА]:\n{file_context}" if file_context else user_message
+
+ # 1. Быстрый перехват строго системных кнопок UI (подтверждение превью промпта)
fast_path_res = handle_fast_path_intercept(session_id, user_message, full_user_content, session_state)
if fast_path_res:
return fast_path_res
- # 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)
+ # 2. Фиксация сообщения пользователя
+ db_save_chat_message(session_id, "user", full_user_content, is_ephemeral=0)
db_history = db_get_chat_history(session_id, limit=20)
- # 3. Сборка системного контекста
- 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 "Гость"
+ current_state_type = session_state.get("state_type") if session_state else None
+ state_data = session_state.get("data_json") or {} if session_state else {}
+ if not isinstance(state_data, dict):
+ state_data = {}
+ idle_turns = state_data.get("idle_turns", 0)
+
active_state_context = ""
- if session_state and session_state.get("state_type") == "PROMPT_PREVIEW":
+ if current_state_type == "PROMPT_PREVIEW":
active_state_context = (
- "\n[ВНИМАНИЕ: АКТИВНЫЙ РЕЖИМ ПРЕДПРОСМОТРА ПРОМПТА]\n"
- "- Сейчас открыт предпросмотр изменения системного промпта.\n"
- "- Если пользователь просит изменить, скорректировать формулировку или удалить пункт — вызови инструмент db_prompt_node_edit.\n"
- "- Если пользователь переключился на другую тему (задачи, логи, аномалии, общие вопросы) — вежливо напомни ему, что открыто несохраненное превью, и спроси, желает ли он сначала применить или отменить правку промпта.\n"
+ "\n[ТЕКУЩИЙ РЕЖИМ: ПРЕДПРОСМОТР СИСТЕМНОГО ПРОМПТА]\n"
+ "- Открыт предпросмотр изменений промпта. Для любых правок вызывай db_prompt_node_edit.\n"
+ )
+ elif current_state_type == "PROMPT_FOLLOWUP":
+ active_state_context = (
+ "\n[ТЕКУЩИЙ РЕЖИМ: СЕССИЯ РЕДАКТИРОВАНИЯ ПРОМПТА]\n"
+ "- Оператор просматривает или редактирует системный промпт.\n"
+ "- На любые команды вида 'удали пункт 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"
)
system_prompt_content = (
- f"Ты — интеллектуальный ассистент SCUD Orion AI. "
- f"Ты управляешь задачами, аналитикой СКУД и системными настройками с помощью инструментов (tools).\n\n"
- f"СТРОГИЕ ПРАВИЛА СТИЛЯ:\n"
- f"- Запрещено использовать панибратские или шутливые обращения. Отвечай профессионально и строго по существу.\n\n"
- f"[ОКРУЖЕНИЕ]\n"
+ f"Ты — интеллектуальный ассистент SCUD Orion AI.\n"
+ f"Ты управляешь задачами, аналитикой СКУД и системными настройками исключительно через инструменты (tools).\n\n"
+ f"СТРОГИЕ ПРАВИЛА:\n"
+ f"1. К оператору всегда обращайся на Вы.\n"
+ f"2. Для получения данных всегда вызывай соответствующий инструмент:\n"
+ 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}\n"
- f"[ПРАВИЛА ИСПОЛЬЗОВАНИЯ ИНСТРУМЕНТОВ]\n"
- f"1. Для ЛЮБЫХ изменений системного промпта (добавить, изменить, удалить пункт) ТЫ ОБЯЗАН ВЫЗВАТЬ db_prompt_node_edit.\n"
- f" - Пример: 'добавь пункт 3.4 Текст' -> вызови db_prompt_node_edit(action='ADD', section_id=3, item_id=4, content='Текст')\n"
- f" - Пример: 'удали пункт 2.9' -> вызови db_prompt_node_edit(action='DELETE', section_id=2, item_id=9)\n"
- f" Категорически запрещено подтверждать добавление или удаление простым текстом без вызова db_prompt_node_edit!\n"
- f"2. Для просмотра системного промпта ВСЕГДА вызывай db_get_system_prompt().\n"
- f"3. Для просмотра задач ВСЕГДА вызывай db_get_tasks().\n\n"
- f"[ТЕКУЩИЙ АКТИВНЫЙ СИСТЕМНЫЙ ПРОМПТ]:\n{dynamic_prompt_text}"
+ f"{active_state_context}"
)
user_msg_object = {"role": "user", "content": full_user_content}
- # 4. Вызов модели
+ # ANCHOR[AGENT_TOOL_DISPATCHER]
try:
if image_b64:
user_msg_object["images"] = [image_b64]
@@ -6522,172 +6498,331 @@ def process_chat_message(
raw_text_reply = msg.get("content", "")
tool_calls = msg.get("tool_calls", [])
- tool_calls = inject_tools_if_needed(user_message, raw_text_reply, 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)
- tool_names_called = []
+
+ tool = tool_calls[0]
+ fn_name = tool["function"]["name"]
+ fn_args = tool["function"].get("arguments", {})
+ if isinstance(fn_args, str):
+ try:
+ fn_args = json.loads(fn_args)
+ except Exception:
+ fn_args = {}
- for tool in tool_calls:
- fn_name = tool["function"]["name"]
- fn_args = tool["function"].get("arguments", {})
- tool_names_called.append(fn_name)
- logger.info(f"Вызов функции (Tool): {fn_name} с аргументами: {fn_args}")
- tool_result_content = ""
+ logger.info(f"Вызов функции (Tool): {fn_name} с аргументами: {fn_args}")
- if fn_name == "db_get_tasks":
+ # Ротация контекста: закрываем старую сессию инструмента
+ close_tool_session_and_cleanup(session_id, close_reason=f"ACTIVATE_{fn_name}")
+ session_state = None
+ mark_last_user_message_ephemeral(session_id)
+
+ # 1. Задачи (Просмотр)
+ if fn_name == "db_get_tasks":
+ raw_tasks = db_get_tasks(user_id, status=fn_args.get("status"))
+ reply_text = "Вот интерактивный список ваших текущих задач:"
+ 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
+ }
+
+ # 2. Единый диспетчер задач
+ elif fn_name in ["db_tasks_edit", "db_add_task", "db_update_task_status", "db_delete_task"]:
+ action = fn_args.get("action", "UPDATE").upper()
+ if fn_name == "db_add_task": action = "ADD"
+ elif fn_name == "db_delete_task": action = "DELETE"
+ elif fn_name == "db_update_task_status": action = "UPDATE"
+
+ if action == "DELETE":
+ task_id_raw = str(fn_args.get("task_id", "")).replace("#", "").replace("TASK-", "").strip()
+ db_set_session_state(session_id, "TASK_DELETE_CONFIRM", {"task_id": task_id_raw, "idle_turns": 0})
+ reply_text = f"Вы действительно хотите удалить задачу #{task_id_raw}?"
+ db_save_chat_message(session_id, "assistant", reply_text, is_ephemeral=1)
+ return reply_text, db_get_chat_history(session_id), {
+ "type": "TASK_DELETE_CONFIRM",
+ "buttons": [
+ {"label": f"Удалить #{task_id_raw}", "value": f"подтверждаю удаление задачи {task_id_raw}", "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 = "Вот интерактивный список ваших текущих задач:"
+ 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
}
- elif fn_name == "db_prompt_node_edit":
- action = fn_args.get("action", "ADD").upper()
- sec_id = int(fn_args.get("section_id", 2))
- itm_id = int(fn_args.get("item_id", 1))
- content = fn_args.get("content", "").strip()
+ # 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
- 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()
+ 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
- nodes_dict = {(sec, itm): txt for sec, itm, txt in existing_nodes}
-
- if action == "DELETE":
- nodes_dict.pop((sec_id, itm_id), None)
+ 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:
- nodes_dict[(sec_id, itm_id)] = content
+ draft_lines.append(f" {s_id}.{i_id}. {txt}")
+ merged_prompt = "\n".join(draft_lines)
- virtual_lines = []
- curr_sec = None
- for (s_id, i_id), txt in sorted(nodes_dict.items()):
- if i_id == 0:
- if curr_sec is not None:
- virtual_lines.append("")
- virtual_lines.append(f"{s_id}. {txt}")
- curr_sec = s_id
+ 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'
{s_id}.{i_id}. {txt} [УДАЛЕНИЕ]' if action == "DELETE" else f'
{s_id}.{i_id}. {txt}'
else:
line_str = f" {s_id}.{i_id}. {txt}"
- if s_id == sec_id and i_id == itm_id:
- line_str = f'
{s_id}.{i_id}. {txt}'
- virtual_lines.append(line_str)
+ diff_lines.append(line_str)
- merged_prompt = "\n".join([re.sub(r'<[^>]+>', '', l) for l in virtual_lines])
- diff_html = "\n".join(virtual_lines)
+ 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
+ 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
})
-
- with get_db_connection() as conn_fix:
- conn_fix.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_fix.commit()
-
- preview_reply = (
- f"Предпросмотр изменений системного промпта:\n\n"
- f"{diff_html}\n\n"
- f"Для применения подтвердите действие, отредактируйте или отмените."
- )
-
- 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,
+ 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": "Подтвердить", "value": "подтверждаю", "style": "primary"},
- {"label": "Отменить", "value": "отмена", "style": "danger"},
- {"label": "✏️ Редактировать", "value": "action:open_editor", "style": "secondary"}
+ {"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)
- 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)
+ 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
- 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)
+ # Прямое выполнение удаления в 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)
- elif fn_name == "db_get_current_server_time":
- tool_result_content = json.dumps(db_get_current_server_time(), ensure_ascii=False)
+ 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_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)
-
- elif fn_name == "db_add_task":
- 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())
- tool_result_content = json.dumps(res, 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"))
- tool_result_content = json.dumps(res, ensure_ascii=False)
-
- messages.append({"role": "tool", "content": tool_result_content})
+ # 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 = "{}"
+ messages.append(msg)
+ 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))
+ final_content = clean_raw_tool_tags(clean_output(raw_content)) or "Запрос выполнен."
- is_output_ephemeral = 1 if any(name in ["db_get_system_prompt", "db_get_system_prompts", "db_prompt_node_edit"] for name in tool_names_called) else 0
+ for artifact in ["почемучка,", "почемучка!", "почемучка?", "почемучка", "почемучто", "почему-то"]:
+ if final_content.lower().startswith(artifact):
+ final_content = final_content[len(artifact):].lstrip(",.!?:; -")
- db_save_chat_message(session_id, "assistant", final_content, is_ephemeral=is_output_ephemeral)
+ is_ephem = 1 if fn_name in ["db_get_snapshots", "db_get_system_prompt", "db_prompt_node_edit"] else 0
+ db_save_chat_message(session_id, "assistant", final_content, is_ephemeral=is_ephem)
return final_content, db_get_chat_history(session_id), None
- # Обычный текстовый ответ модели (включая вежливый Guard при смене темы)
+ # ANCHOR[AGENT_TOPIC_DRIFT]
raw_str = msg.get("content", "").strip().replace("**", "").replace("*", "")
final_reply = clean_raw_tool_tags(clean_output(raw_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") == "PROMPT_PREVIEW":
- action_payload = {
- "type": "PROMPT_PREVIEW",
- "buttons": [
- {"label": "Подтвердить", "value": "подтверждаю", "style": "primary"},
- {"label": "Отменить", "value": "отмена", "style": "danger"},
- {"label": "✏️ Редактировать", "value": "action:open_editor", "style": "secondary"}
- ]
- }
- db_save_chat_message(session_id, "assistant", final_reply, is_ephemeral=(1 if session_state else 0))
+ 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), 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
```
@@ -6695,36 +6830,49 @@ def process_chat_message(
## File: `./modules/web_api/llm/db_tools.py`
```py
"""
+===============================================================================
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_rules,
db_get_stats,
db_get_anomalies,
db_get_reference
)
-
-def db_get_current_server_time():
- now = datetime.now()
- days_ru = ["понедельник", "вторник", "среда", "четверг", "пятница", "суббота", "воскресенье"]
- return {
- "current_date": now.strftime("%d.%m.%Y"),
- "current_time": now.strftime("%H:%M:%S"),
- "day_of_week": days_ru[now.weekday()],
- "iso_date": now.strftime("%Y-%m-%d")
- }
+from .db.db_chat import (
+ db_save_chat_message,
+ db_get_chat_history,
+ db_purge_ephemeral_messages,
+ db_clear_chat_history
+)
+from .db.db_tasks import (
+ normalize_task_id,
+ 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
```
## File: `./modules/web_api/llm/file_parser.py`
@@ -6821,18 +6969,80 @@ def extract_text_from_file(file_bytes: bytes, filename: str) -> dict:
## File: `./modules/web_api/llm/schemas.py`
```py
+"""
+===============================================================================
+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_prompt_node_edit",
+ "description": (
+ "Управление элементами системного промпта (добавление, изменение, удаление). "
+ "Если пользователь пишет 'удали 2.9' или 'удали пункт 2.9', вызывай action='DELETE', section_id=2, item_id=9. "
+ "Действие action может быть ADD, EDIT или DELETE."
+ ),
+ "parameters": {
+ "type": "object",
+ "properties": {
+ "action": {
+ "type": "string",
+ "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_system_prompt",
+ "description": "Просмотр текущего активного системного промпта ассистента из базы данных.",
+ "parameters": {
+ "type": "object",
+ "properties": {}
+ }
+ }
+ },
+ # ANCHOR[SCHEMA_TASKS_EDIT]
{
"type": "function",
"function": {
"name": "db_get_tasks",
- "description": "ПОЛУЧИТЬ СПИСОК ЗАДАЧ ТЕКУЩЕГО ПОЛЬЗОВАТЕЛЯ. Вызывай СРАЗУ при запросе 'покажи мои задачи' или 'список задач'. ВАЖНОЕ ПРАВИЛО ВЫВОДА: Выводи задачи ЕДИНЫМ плоским списком (нумерованным или маркированным) по порядку ID. КАТЕГОРИЧЕСКИ ЗАПРЕЩЕНО группировать задачи по статусам (В процессе, Бэклог, Завершены) или создавать подзаголовки, если оператор явно не попросил о группировке!",
+ "description": "Просмотр реестра задач и бэклога текущего пользователя.",
"parameters": {
"type": "object",
"properties": {
"status": {
"type": "string",
- "description": "Фильтр статуса: BACKLOG, IN_PROGRESS или COMPLETED."
+ "enum": ["ALL", "IN_PROGRESS", "PLANNED", "COMPLETED"],
+ "description": "Опциональный фильтр статуса задач"
}
}
}
@@ -6841,64 +7051,63 @@ TOOLS_SCHEMA = [
{
"type": "function",
"function": {
- "name": "db_get_rules",
- "description": "ПОЛУЧИТЬ БАЗУ ЗНАНИЙ ИИ И ПРАВИЛА АРБИТРАЖА (ai_knowledge_base). Вызывай когда пользователь просит показать базу знаний, правила, инструкции или промпты.",
- "parameters": {"type": "object", "properties": {}}
- }
- },
- {
- "type": "function",
- "function": {
- "name": "db_get_system_prompt",
- "description": "ВЫЗЫВАЙ ВСЕГДА при наличии в сообщении фраз: 'покажи системный промпт', 'покажи промпт', 'выведи промпт', 'системный промпт'. Запрещено отвечать текстом без вызова этого инструмента.",
- "parameters": {
- "type": "object",
- "properties": {},
- "required": []
- }
- }
- },
- {
- "type": "function",
- "function": {
- "name": "db_update_task_status",
- "description": "Изменить статус и/или срок выполнения задачи в реестре.",
+ "name": "db_tasks_edit",
+ "description": "Единый инструмент управления задачами: создание (ADD), изменение статуса/дедлайна (UPDATE), удаление (DELETE) и экспорт задач в Markdown-файл (EXPORT).",
"parameters": {
"type": "object",
"properties": {
- "task_id": {"type": "string", "description": "Идентификатор задачи, например TASK-17"},
- "status": {"type": "string", "description": "Новый статус: COMPLETED, IN_PROGRESS или BACKLOG"},
- "due_date": {"type": "string", "description": "Срок выполнения задачи"}
+ "action": {
+ "type": "string",
+ "enum": ["ADD", "UPDATE", "DELETE", "EXPORT"],
+ "description": "Тип действия: ADD, UPDATE, DELETE или EXPORT"
+ },
+ "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": ["task_id"]
- }
- }
- },
- {
- "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"]
+ "required": ["action"]
}
}
},
+ # 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": "Дата в формате ДД.ММ.ГГГГ или относительное слово"
}
}
}
@@ -6908,12 +7117,18 @@ TOOLS_SCHEMA = [
"type": "function",
"function": {
"name": "db_delete_snapshots",
- "description": "УДАЛИТЬ СНАПШОТ(Ы) ИЗ БАЗЫ ДАННЫХ. Вызывай, когда пользователь явно просит удалить конкретный снапшот по ID или все снапшоты за выбранный день.",
+ "description": "Удаление снапшотов СКУД по идентификатору или дате.",
"parameters": {
"type": "object",
"properties": {
- "snapshot_id": {"type": "string", "description": "Идентификатор снапшота для удаления, например Y20260805-007"},
- "day_str": {"type": "string", "description": "Дата в формате ДД.ММ.ГГГГ для удаления всех снапшотов за день"}
+ "snapshot_id": {
+ "type": "string",
+ "description": "Идентификатор конкретного снапшота"
+ },
+ "day_str": {
+ "type": "string",
+ "description": "Дата всех снапшотов за день"
+ }
}
}
}
@@ -6921,29 +7136,31 @@ TOOLS_SCHEMA = [
{
"type": "function",
"function": {
- "name": "db_get_current_server_time",
- "description": "ПОЛУЧИТЬ ТЕКУЩУЮ ДАТУ, ВРЕМЯ И ДЕНЬ НЕДЕЛИ СЕРВЕРА. Вызывай МГНОВЕННО при любых вопросах пользователя про точное текущее время или текущую дату.",
+ "name": "db_get_anomalies",
+ "description": "Просмотр истории аномалий и расхождений между СКУД и 1С.",
"parameters": {
"type": "object",
- "properties": {},
- "required": []
+ "properties": {
+ "date_str": {
+ "type": "string",
+ "description": "Опциональная дата в формате ДД.ММ.ГГГГ"
+ },
+ "limit": {
+ "type": "integer",
+ "description": "Лимит записей"
+ }
+ }
}
}
},
{
"type": "function",
"function": {
- "name": "db_add_task",
- "description": "Добавить новую задачу в бэклог проекта.",
+ "name": "db_get_rules",
+ "description": "Просмотр базы знаний и правил кадрового арбитража компании.",
"parameters": {
"type": "object",
- "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"]
+ "properties": {}
}
}
},
@@ -6951,81 +7168,39 @@ TOOLS_SCHEMA = [
"type": "function",
"function": {
"name": "db_get_stats",
- "description": "ПОЛУЧИТЬ ОБЩУЮ СТАТИСТИКУ БАЗЫ ДАННЫХ. Вызывай, когда пользователь просит показать общую статистику БД, количество записей в таблицах или размер базы.",
- "parameters": {"type": "object", "properties": {}}
- }
- },
- {
- "type": "function",
- "function": {
- "name": "db_get_anomalies",
- "description": "ПОЛУЧИТЬ ИСТОРИЮ АНОМАЛИЙ СКУД ⟷ 1С. Вызывай при запросах на просмотр аномалий или расхождений. Передавай date_str если пользователь просит аномалии за конкретный день, или увеличенный limit (например 100) если просит все.",
+ "description": "Получение статистики количества записей в таблицах базы данных.",
"parameters": {
"type": "object",
- "properties": {
- "limit": {"type": "integer", "description": "Максимальное количество записей (по умолчанию 100)"},
- "date_str": {"type": "string", "description": "Опциональная дата в формате ДД.ММ.ГГГГ"}
- }
+ "properties": {}
}
}
},
{
"type": "function",
"function": {
- "name": "db_get_session_states",
- "description": "ПОЛУЧИТЬ АКТИВНЫЕ СЕССИИ И ПРЕВЬЮ (session_states). Вызывай, когда пользователь просит показать текущие сессии или статус превью.",
- "parameters": {"type": "object", "properties": {}}
+ "name": "db_get_current_server_time",
+ "description": "Получение текущего точного времени сервера.",
+ "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_prompt_node_edit",
- "description": (
- "Сформировать предпросмотр изменения системного промпта через реляционные узлы. "
- "Вызывай при любых запросах на добавление, изменение или удаление пунктов. "
- "Раздел и пункт передавай числами (например, для пункта '2.9' -> section_id=2, item_id=9)."
- ),
- "parameters": {
- "type": "object",
- "properties": {
- "action": {
- "type": "string",
- "enum": ["ADD", "UPDATE", "DELETE"],
- "description": "Действие: ADD (добавить пункт), UPDATE (изменить пункт), DELETE (удалить пункт)"
- },
- "section_id": {
- "type": "integer",
- "description": "Номер раздела (например, 2)"
- },
- "item_id": {
- "type": "integer",
- "description": "Номер пункта внутри раздела (например, 9)"
- },
- "content": {
- "type": "string",
- "description": "Текст формулировки пункта (для ADD и UPDATE). Без префикса номера!"
- }
- },
- "required": ["action", "section_id", "item_id"]
- }
- }
}
]
```
@@ -7127,6 +7302,7 @@ ROLE: Реляционное управление системным промп
базой знаний, реестром действий и сессионными стейтами.
===============================================================================
"""
+import re
import json
import logging
from typing import List, Dict, Any, Optional
@@ -7359,7 +7535,7 @@ def db_get_reference(category: Optional[str] = None) -> Dict[str, Any]:
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:
@@ -7369,30 +7545,28 @@ def db_add_system_prompt(name: str, prompt_text: str) -> Dict[str, Any]:
current_sec = 1
current_itm = 0
- for line in prompt_text.splitlines():
- stripped = line.strip()
- if not stripped:
+ for raw_line in prompt_text.splitlines():
+ clean_line = re.sub(r'<[^>]+>', '', raw_line).strip()
+ if not clean_line:
continue
-
- # Проверяем заголовок раздела (например, "1. РОЛЬ И ЗАДАЧИ...")
- parts = stripped.split(".", 1)
- if len(parts) == 2 and parts[0].strip().isdigit():
- sec_num = int(parts[0].strip())
- rest = parts[1].strip()
-
- # Проверяем, это подпункт (например, "1.1. Текст") или заголовок раздела
- sub_parts = rest.split(".", 1)
- if len(sub_parts) == 2 and sub_parts[0].strip().isdigit():
- current_sec = sec_num
- current_itm = int(sub_parts[0].strip())
- content = sub_parts[1].strip()
- else:
- current_sec = sec_num
- current_itm = 0
- content = rest
+
+ # 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 = stripped
+ content = clean_line
cursor.execute("""
INSERT OR REPLACE INTO system_prompt_nodes (prompt_name, section_id, item_id, content, is_active)
@@ -7409,140 +7583,418 @@ def db_add_system_prompt(name: str, prompt_text: str) -> Dict[str, Any]:
## File: `./modules/web_api/llm/db/db_snapshots.py`
```py
"""
+===============================================================================
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
- if "." in date_str:
- parts = date_str.split(".")
+
+ clean_date = date_str.strip() if date_str else ""
+ if not clean_date or not re.search(r'\d{2}\.\d{2}\.\d{4}', clean_date):
+ 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 ? "
- params.extend([date_str, iso_date, f"{iso_date}%"])
+ compact_date = f"{parts[2]}{parts[1]}{parts[0]}"
+
+ 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 ORDER BY id DESC LIMIT 50"
+ query += """
+ GROUP BY snapshot_id, log_date, snapshot_time
+ ORDER BY snapshot_time DESC, snapshot_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]:
- if not snapshot_id and not day_str:
- return {"status": "error", "message": "Необходимо указать snapshot_id или day_str (ДД.ММ.ГГГГ)."}
+# ANCHOR[DB_DEL_SNAPSHOTS]
+def db_delete_snapshots(
+ 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:
- cursor.execute("DELETE FROM scud_logs WHERE snapshot_id = ?", (snapshot_id,))
+ deleted = 0
+
+ if snapshot_ids and isinstance(snapshot_ids, list):
+ # Исключаем любые итоговые снапшоты, начинающиеся с 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:
- cursor.execute("DELETE FROM scud_logs WHERE log_date = ? OR snapshot_id LIKE ?", (day_str, f"%{day_str.replace('.', '')}%"))
- deleted = cursor.rowcount
+ 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}"}
```
## File: `./modules/web_api/llm/db/db_tasks.py`
```py
"""
+===============================================================================
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()
- 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,))
+
+ 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', ?, ?)
- """, (new_task_id, module, title, priority.upper(), due_date, user_id))
+ VALUES (?, ?, ?, ?, ?, ?, ?)
+ """, (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("""
- UPDATE tasks
- SET status = ?, due_date = ?
- WHERE (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("""
- 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))
+
+ 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 {', '.join(updates)}
+ WHERE (id = ? OR UPPER(task_id) = ? OR task_id LIKE ?) AND user_id = ?
+ """
+ cursor.execute(sql, params)
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 = ?
- """, (formatted_id, f"%{task_id.strip()}", user_id))
+ WHERE (id = ? OR UPPER(task_id) = ? OR task_id LIKE ?) AND 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}'"}
```
## File: `./modules/web_api/llm/core/__init__.py`
@@ -7590,75 +8042,161 @@ def get_dynamic_calendar_context() -> str:
return "\n".join(lines)
```
-## File: `./modules/web_api/llm/core/fast_path.py`
+## File: `./modules/web_api/llm/core/context_manager.py`
```py
"""
===============================================================================
-FILE: modules/web_api/llm/core/fast_path.py
+FILE: modules/web_api/llm/core/context_manager.py
PROJECT: SCUD Orion AI (Unified Architecture)
MODULE: web_api / llm / core
-ROLE: Детерминированный перехват подтверждения, отмены и мгновенной очистки
- эфемерного контекста без повторного вывода кнопок-вилок.
+ROLE: Интеллектуальный менеджер контекста: разделение служебных транзакций
+ инструментов и содержательного диалога с сохранением Topic Drift.
===============================================================================
"""
-# ANCHOR[FAST_PATH_IMPORTS]
import logging
-from typing import Dict, Any, Tuple, Optional
+from typing import Dict, Any, Optional, List
-from llm.db_tools import (
- db_add_system_prompt,
- db_clear_session_state,
- db_purge_ephemeral_messages,
+from ..db.connection import get_db_connection
+from ..db_tools import (
db_save_chat_message,
- db_get_chat_history
+ db_get_chat_history,
+ db_purge_ephemeral_messages,
+ db_clear_session_state,
+ db_set_session_state
)
-logger = logging.getLogger("FAST_PATH")
+logger = logging.getLogger("CONTEXT_MANAGER")
-# ANCHOR[FAST_PATH_ROUTER]
+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
+```
+
+## File: `./modules/web_api/llm/core/fast_path.py`
+```py
+"""
+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]]]]:
- """
- 1. Подтвердить -> запись в БД + db_purge_ephemeral_messages + инфо-текст.
- 2. Отменить -> сброс стейта + db_purge_ephemeral_messages + инфо-текст.
- """
- if not session_state or session_state.get("state_type") != "PROMPT_PREVIEW":
+
+ if not session_state:
return None
- user_msg_clean = user_message.lower().strip(" .!?:;")
+ state_type = session_state.get("state_type")
+ msg = user_message.strip().lower()
- draft_text = ""
- if session_state.get("data_json") and isinstance(session_state["data_json"], dict):
- draft_text = session_state["data_json"].get("draft_text", "")
- else:
- draft_text = session_state.get("pending_data", "")
+ # ⭐️ Управление системным промптом (Превью)
+ 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", "")
- # 1. ПОДТВЕРДИТЬ ИЗМЕНЕНИЯ
- if user_msg_clean in ["подтверждаю", "подтвердить", "да", "сохранить", "применить", "ок", "хорошо"]:
- db_add_system_prompt("main_agent", draft_text)
- db_clear_session_state(session_id)
- deleted_count = db_purge_ephemeral_messages(session_id)
- logger.info(f"Системный промпт сохранен в БД. Удалено эфемерных сообщений: {deleted_count}")
+ 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)
- reply_text = "Системный промпт успешно сохранен и применен в базе данных."
- db_save_chat_message(session_id, "assistant", reply_text, is_ephemeral=0)
- return reply_text, db_get_chat_history(session_id), None
+ 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
- # 2. ОТМЕНИТЬ ИЗМЕНЕНИЯ
- elif user_msg_clean in ["отмена", "отменить", "отклонить", "назад", "стоп"]:
- db_clear_session_state(session_id)
- deleted_count = db_purge_ephemeral_messages(session_id)
- logger.info(f"Изменения промпта отменены. Удалено эфемерных сообщений: {deleted_count}")
+ 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
- reply_text = "Изменения системного промпта отменены. Контекст диалога чист."
- db_save_chat_message(session_id, "assistant", reply_text, is_ephemeral=0)
- return reply_text, db_get_chat_history(session_id), 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
```
@@ -7688,9 +8226,9 @@ VISION_MODEL = "qwen2.5vl:7b-q8_0"
LLM_OPTIONS = {
"num_predict": 8192,
"num_ctx": 8192,
- "temperature": 0.1,
- "repeat_penalty": 1.1,
- "presence_penalty": 0.5,
+ "temperature": 0.0,
+ "repeat_penalty": 1.0,
+ "presence_penalty": 0.0,
"top_p": 0.9
}
@@ -7813,49 +8351,36 @@ def highlight_prompt_diff(old_prompt: str, new_prompt: str) -> str:
FILE: modules/web_api/llm/core/tool_injector.py
PROJECT: SCUD Orion AI (Unified Architecture)
MODULE: web_api / llm / core
-ROLE: Санитарная очистка сырых артефактов и тегов из ответов LLM.
+ROLE: Базовая санитарная очистка артефактов без эвристик и регулярных выражений.
+
+AI-CONTEXT-ANCHORS:
+ - ANCHOR[CLEAN_RAW_TOOLS]: Очистка строковых тегов.
+ - ANCHOR[PASS_THROUGH_TOOLS]: Чистый проходной интерфейс инструментов.
===============================================================================
"""
-import re
-import logging
-from typing import List, Dict, Any
-logger = logging.getLogger("TOOL_INJECTOR")
+# ANCHOR[CLEAN_RAW_TOOLS]
+from typing import List, Dict, Any
def clean_raw_tool_tags(text: str) -> str:
- """Удаляет сырые теги вызова инструментов, если модель случайно вывела их в текст."""
+ """Удаляет только технические теги разметки, если они попали в текст."""
if not text:
return ""
- text = re.sub(r'\{"name":\s*"db_[^}]+\}\s*()?', '', text)
- text = re.sub(r'
.*?', '', text, flags=re.DOTALL)
- text = re.sub(r'\w*\[\]\(\)', '', text)
- text = re.sub(r'', '', text)
- return text.strip()
+ return text.replace("
", "").replace("", "").strip()
def clean_output(text: str) -> str:
- """Удаляет слова-паразиты и склейки в начале ответа."""
+ """Возвращает текст ответа без изменения смысла."""
if not text:
- return text
-
- artifacts = [
- "почемучка", "почемучка,", "почемучка!", "почемучка?",
- "почемучто", "почто", "почему что", "почему-то",
- "здравствуйте!", "привет!"
- ]
-
- cleaned = text.strip()
- for art in artifacts:
- if cleaned.lower().startswith(art):
- cleaned = cleaned[len(art):].lstrip(",.!?:; -")
-
- return cleaned.strip()
+ return ""
+ 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]]:
"""
- Проходной фильтр: все решения о вызове инструментов принимает исключительно LLM.
+ Чистый сквозной проход: все решения принимает исключительно языковая модель.
"""
return tool_calls
```