init

app.py

@@ -1,64 +1,94 @@
 import gradio as gr
-from huggingface_hub import InferenceClient
+from langchain_core.messages import HumanMessage, AIMessage
+from get_classification import get_graph_class
+from datetime import datetime
 
-"""
-For more information on `huggingface_hub` Inference API support, please check the docs: https://huggingface.co/docs/huggingface_hub/v0.22.2/en/guides/inference
-"""
-client = InferenceClient("HuggingFaceH4/zephyr-7b-beta")
+# Глобальные переменные состояния (аналог session_state в Streamlit)
+messages = []
+bot_instance = None
 
+def find_last_bot_message(messages_list):
+    """Находит последнее сообщение бота"""
+    for message in messages_list[::-1]:
+        if isinstance(message, AIMessage) and len(message.content) > 0:
+            return message.content
+    return None
 
-def respond(
-    message,
-    history: list[tuple[str, str]],
-    system_message,
-    max_tokens,
-    temperature,
-    top_p,
-):
-    messages = [{"role": "system", "content": system_message}]
-
-    for val in history:
-        if val[0]:
-            messages.append({"role": "user", "content": val[0]})
-        if val[1]:
-            messages.append({"role": "assistant", "content": val[1]})
+def save_broken_case(messages_dict):
+    """Сохраняет 'сломанные' кейсы (заглушка)"""
+    result_str = ""
+    for elem in messages_dict:
+        role = elem["role"]
+        content = elem["content"]
+        result_str += f"{role}: {content}\n"
+    
+    current_datetime = datetime.now()
+    formatted_datetime = current_datetime.strftime("%Y-%m-%d %H:%M:%S")
+    print(f"Saved broken case at {formatted_datetime}:\n{result_str}")
 
+def predict(message, history):
+    """Обработка ввода пользователя и генерация ответа"""
+    global messages, bot_instance
+    
+    # Обработка команды log
+    if message.lower().startswith("log"):
+        save_broken_case(messages)
+        messages = []
+        return ""
+    
+    # Добавляем сообщение пользователя
     messages.append({"role": "user", "content": message})
+    
+    try:
+        # Инициализация бота при первом запросе
+        if bot_instance is None:
+            bot_instance = get_graph_class(message)
+        
+        # Вызываем бота
+        bot_instance.invoke(message)
+        
+        # Извлекаем последний ответ бота
+        last_bot_message = find_last_bot_message(bot_instance.messages)
+        last_bot_message = last_bot_message or "Извините, не удалось сгенерировать ответ"
+        
+        # Добавляем ответ в историю
+        messages.append({"role": "assistant", "content": last_bot_message})
+        return last_bot_message
+    
+    except Exception as e:
+        error_msg = f"Ошибка: {str(e)}"
+        messages.append({"role": "assistant", "content": error_msg})
+        return error_msg
 
-    response = ""
-
-    for message in client.chat_completion(
-        messages,
-        max_tokens=max_tokens,
-        stream=True,
-        temperature=temperature,
-        top_p=top_p,
-    ):
-        token = message.choices[0].delta.content
-
-        response += token
-        yield response
+def clear_chat():
+    """Очистка чата и сброс состояния"""
+    global messages, bot_instance
+    messages = []
+    bot_instance = None
+    return []
 
-
-"""
-For information on how to customize the ChatInterface, peruse the gradio docs: https://www.gradio.app/docs/chatinterface
-"""
-demo = gr.ChatInterface(
-    respond,
+# Создаем интерфейс чата
+chat_interface = gr.ChatInterface(
+    fn=predict,
+    title="Чат-бот технической поддержки",
+    description="Задайте ваш вопрос технической поддержке",
     additional_inputs=[
-        gr.Textbox(value="You are a friendly Chatbot.", label="System message"),
-        gr.Slider(minimum=1, maximum=2048, value=512, step=1, label="Max new tokens"),
-        gr.Slider(minimum=0.1, maximum=4.0, value=0.7, step=0.1, label="Temperature"),
-        gr.Slider(
-            minimum=0.1,
-            maximum=1.0,
-            value=0.95,
-            step=0.05,
-            label="Top-p (nucleus sampling)",
-        ),
+        gr.Button("Clear", variant="stop")
     ],
+    examples=[
+        "Как настроить VPN?",
+        "Почему не работает принтер?",
+        "Как сбросить пароль?"
+    ]
 )
 
+# Добавляем обработчик для кнопки Clear
+chat_interface.additional_inputs[0].click(
+    fn=clear_chat,
+    inputs=[],
+    outputs=chat_interface.chatbot
+)
 
+# Запускаем приложение
 if __name__ == "__main__":
-    demo.launch()
+    chat_interface.launch()

b2b/b2b_prompts.py

@@ -0,0 +1,59 @@
+SYSTEM_PROMPT = """
+ИНСТРУКЦИЯ — Как помочь сотруднику с сервисом B2B
+
+---
+
+**1. Узнай, что случилось**
+
+- Спросить: "Опишите, пожалуйста, с чем именно у вас возникла проблема в сервисе B2B?"
+  (Если сам не рассказал — уточни, что именно пытается сделать: войти в систему, посмотреть договор, создать договор и т.д.)
+
+---
+
+**2. Определи тип проблемы**
+
+- Если сотрудник говорит, что не может зайти в систему или не хватает нужной функции — это проблема с доступом.
+- Если сотрудник говорит, что система открывается, но не заводится договор, не совпадает сумма/информация, выдает ошибку при работе с договорами — это "не наша проблема".
+
+---
+
+**3. Помоги по инструкции**
+
+**A. Проблема с работой договора (суммы, данные, ошибки в процессе заполнения/оформления договора)**
+
+- Скажи: "По таким вопросам вам нужно обратиться в чат поддержки BS4osc. Мы помогаем только с доступом в B2B."
+- Объясни, где найти этот чат или скинь ссылку, если спрашивают.
+- На этом помощь заканчивается.
+
+---
+
+**B. Проблема с доступом (невозможно войти, недоступен нужный функционал, ошибка при входе)**
+
+1. Уточни, по какой ссылке сотрудник заходит на сайт.
+2. Проверь, правильно ли вводит логин, пароль.
+3. Подскажи, где взять нужные данные (если не знает).
+4. Если не помогает — предложи сбросить пароль:
+   - Запусти функцию для сброса пароля, если умеешь (или подсчитай по инструкции/обратись к старшему).
+5. Если после сброса пароля не получилось войти или доступа по-прежнему недостаточно:
+   - Скажи: "Скоро с вами свяжется специалист, чтобы помочь с вашей проблемой."
+   - Затем вызови функцию make_jira_task.
+
+---
+
+**4. Если не понимаешь, что это за проблема или не уверен, что делать**
+
+- Спроси у сотрудника дополнительные подробности.
+- Если все равно не ясно или не можешь помочь — скажи: "Скоро вами займётся специалист."  
+- После этого вызови функцию make_jira_task.
+
+---
+
+**5. Завершение общения**
+
+- Если у сотрудника получилось войти/решить его вопрос — вызови closing_task и скажи: "Спасибо за обращение! Хорошего дня!"
+- Если не смог помочь — вызови make_jira_task и скажи, что вопрос передан специалисту.
+
+---
+
+**ЗАПОМНИ: не нужно предлагать ничего скачивать из интернета, не проси отправлять лишнюю информацию, объясняй только простыми словами ПО ЭТОЙ ИНСТРУКЦИИ!**
+"""

b2b/b2b_service.py

@@ -0,0 +1,28 @@
+from langchain_core.tools import BaseTool, tool
+from base_service import BaseService
+from b2b.b2b_prompts import SYSTEM_PROMPT
+from typing import List
+import logging
+import time
+
+logger = logging.getLogger(__name__)
+
+
+class B2BService(BaseService):
+    @property
+    def system_prompt(self) -> str:
+        return SYSTEM_PROMPT
+    
+    @property
+    def tools(self) -> List[BaseTool]:
+        return self._base_tools + [
+            self.example_func,
+        ]
+
+    @tool
+    def example_func(question: str) -> None:
+        """Пример функции, как её здесь оформлять. Просто для примера, нужно удалить при реальном использовании"""
+        print("Я example_func")
+        time.sleep(4)
+        logger.info("Кто-то забыл удалить example_func!")
+

base_graph.py

@@ -0,0 +1,116 @@
+from typing import Annotated, Type
+from langgraph.graph import StateGraph
+from langchain_core.messages import HumanMessage, ToolMessage
+from langgraph.graph.message import add_messages
+from typing_extensions import TypedDict
+from base_service import BaseService
+from get_answer_gigachat import AnswerGigaChat
+import logging
+import os
+
+logger = logging.getLogger(__name__)
+
+class State(TypedDict):
+    messages: Annotated[list, add_messages]
+
+class BaseGraph:
+    def __init__(self, service: Type[BaseService]):
+        self.service = service
+        self.tools_dict = {tool.name: tool for tool in service.tools}
+        self.llm_with_tools = AnswerGigaChat().bind_tools(service.tools)
+        self.messages = service.get_initial_messages()
+        self.graph = self._build_graph()
+        logger.info(f"BaseGraph with service {service} was built")
+
+    def rebuild_with_new_service(self, service: Type[BaseService]):
+        self.service = service
+        self.tools_dict = {tool.name: tool for tool in service.tools}
+        self.llm_with_tools = AnswerGigaChat().bind_tools(service.tools)
+        self.graph = self._build_graph()
+        self.messages = service.get_messages_from_redirect(self.messages)
+        logger.info(f"BaseGraph was rebuilt with service {service}")
+
+    def _agent_node(self, state: State):
+        try:
+            logger.info("Starting agent_node")
+            messages = state["messages"]
+            response = self.llm_with_tools.invoke(messages)
+            response.content = self._clean_response(response.content)
+            return {"messages": [response]}
+        except Exception as e:
+            logger.error(f"Error in agent_node: {str(e)}", exc_info=True)
+            raise
+
+    def _tool_node(self, state: State):
+        try:
+            logger.info("Starting tool_node")
+            last_message = state["messages"][-1]
+            tool_calls = last_message.tool_calls
+            
+            results = []
+            for call in tool_calls:
+                tool_name = call["name"]
+                logger.info(f"Running tool {tool_name}")
+                args = call["args"]
+                
+                tool = self.tools_dict.get(tool_name)
+                if not tool:
+                    raise ValueError(f"Tool {tool_name} not found")
+                
+                tool_response = tool.invoke(args)
+                if tool_name == "make_redirect":
+                    self.rebuild_with_new_service(tool_response)
+                results.append(str(tool_response))
+            
+            return {"messages": [ToolMessage(content=", ".join(results), tool_call_id=call["id"])]}
+        except Exception as e:
+            logger.error(f"Error in tool_node: {str(e)}", exc_info=True)
+            raise
+
+    def _should_continue(self, state: State):
+        try:
+            logger.info("Checking should continue")
+            last_message = state["messages"][-1]
+            return "tool" if "function_call" in last_message.additional_kwargs else "end"
+        except Exception as e:
+            logger.error(f"Error in should_continue: {str(e)}", exc_info=True)
+            raise
+
+    def _build_graph(self):
+        try:
+            logger.info("Building graph")
+            graph_builder = StateGraph(State)
+
+            graph_builder.add_node("agent", self._agent_node)
+            graph_builder.add_node("tool", self._tool_node)
+
+            graph_builder.add_conditional_edges(
+                "agent",
+                self._should_continue,
+                {"tool": "tool", "end": "__end__"}
+            )
+            graph_builder.add_edge("tool", "agent")
+            graph_builder.set_entry_point("agent")
+
+            return graph_builder.compile()
+        except Exception as e:
+            logger.error(f"Error building graph: {str(e)}", exc_info=True)
+            raise
+
+    def _clean_response(self, content: str) -> str:
+        content = content.replace("</final_answer>", "<final_answer>").replace("</thinking>", "<thinking>")
+        if "<final_answer>" in content:
+            content = content.split("<final_answer>")[1]
+        if "<thinking>" in content:
+            content = content.split("<thinking>")[-1]
+        return content
+
+    def invoke(self, user_input):
+        try:
+            self.messages.append(HumanMessage(content=user_input))
+            result = self.graph.invoke({"messages": self.messages})
+            self.messages = result["messages"]
+            return result
+        except Exception as e:
+            logger.error(f"Error invoking graph: {str(e)}", exc_info=True)
+            raise

base_service.py

@@ -0,0 +1,76 @@
+from abc import ABC, abstractmethod
+from langchain_core.messages import SystemMessage, HumanMessage, AIMessage
+from system_prompt_template import DIALOG_PROMPT
+from typing import List
+from langchain_core.tools import BaseTool, tool
+from service_by_name import get_service_by_name
+import logging
+import time
+import os
+from dotenv import load_dotenv
+
+load_dotenv()
+logger = logging.getLogger(__name__)
+
+class BaseService(ABC):
+    def __init__(self):
+        self._base_tools = [self.closing_task,
+                            self.make_jira_task,
+                            ]
+ 
+    @property
+    @abstractmethod
+    def system_prompt(self) -> str:
+        """Возвращает системный промпт для сервиса"""
+        pass
+    
+    @property
+    @abstractmethod
+    def tools(self) -> List[BaseTool]:
+        """Возвращает список инструментов сервиса"""
+        pass
+
+    @property
+    def log_path(self) -> str:
+        """Возвращает путь до папки с логами"""
+        return os.path.join("/tmp", "service.log")
+    
+    def get_initial_messages(self):
+        """Возвращает начальные сообщения для графа"""
+        return [SystemMessage(content=self.system_prompt)]
+    
+    def get_messages_from_redirect(self, messages):
+        messages_formatted = ""
+        for message in messages:
+            if isinstance(message, HumanMessage):
+                message += f"user: '{message.content}'\n"
+            elif isinstance(message, AIMessage):
+                message += f"assistant: '{message.content}'\n"
+
+        return [SystemMessage(content=self.system_prompt + DIALOG_PROMPT.format(messages_formatted))]
+    
+    @tool
+    def make_redirect(service_name: str):
+        """Когда оказывается, что пользователю нужен эксперт в другом сервисе, 
+        пользователя нужно перенаправить на соответствующего эксперта.
+        Функция принимает аргумент service_name из списка:
+        ['openvpn', 'corporate_email', 'internet_access'] и пересоздает класс эксперта
+        с соответствующими новому сервису знаниями."""
+        logger.info("redirecting question to service {service_name}")
+        return get_service_by_name(service_name)
+
+    
+    @tool
+    def closing_task(question: str) -> None:
+        """Задача выполнена, сохраняем результаты"""
+        print("### Задача выполнена, сохраняем результаты")
+        time.sleep(2)
+        logger.info("task closed")
+
+    @tool
+    def make_jira_task(question: str) -> None:
+        """Задача не может быть выполнена с помощью ии, создаем задачу в jira для того,
+        чтобы её выполнил человек"""
+        time.sleep(2)
+        print("### Скриптом создается задача в jira с соответствующими деталями")
+        logger.info("jira task was make")

borlas/borlas_prompts.py

@@ -0,0 +1,68 @@
+SYSTEM_PROMPT = """
+**ИНСТРУКЦИЯ — Как помочь сотруднику решить проблему с сервисом Borlas**
+
+---
+
+**1. Определи, что не работает**
+
+Попроси сотрудника рассказать, что не получается сделать:
+- Что он хотел сделать?
+- Какая страница (или окно) открывается?
+- Есть ли какие-то ошибки/надписи?  
+  (Попроси прислать скриншот, если сотрудник может.)
+
+---
+
+**2. Действуй по ситуации:**
+
+---
+
+**A. Проблема с запуском Borlas через браузер (не открывается плагин, нет начальной страницы, ошибка java)**
+
+- Спроси, что именно видно на экране:
+  - Если открывается обычная страница браузера (а не окно входа Borlas)
+  - Если пишет ошибку «no Java plugin» или что-то про Java
+- Вежливо скажи: "Сейчас передам вашу задачу в IT-отдел для проверки."
+- Вызови функцию make_jira_task.
+
+---
+
+**B. Borlas открывается, но не удаётся сделать нужное: проблема с документами или полями (например, не находится договор, поля неправильные, ошибки в работе самой системы)**
+
+- Уточни, с каким именно документом или действием возникла проблема (номер договора или скрин окна, если можно).
+- Вежливо скажи: "Сейчас передам вашу задачу специалисту по системе Borlas для исправления."
+- Вызови функцию make_jira_task.  
+  (Если доступна отдельная функция для проектов Borlas, используй её, например make_redirect('borlas_project').)
+
+---
+
+**C. Нет доступа или не хватает прав (не открывается вкладка, не подходит пароль, нет нужной функции)**
+
+- Спроси: "Что именно не видно или не работает? Можете прислать скриншот?"
+- Если сотрудник не видит нужную вкладку, не может зайти или пишет, что пароль не подходит:
+  - Вежливо скажи: "Сейчас передам вашу заявку, чтобы вам помогли восстановить доступ."
+  - Вызови функцию make_jira_task.
+
+---
+
+**3. Если не понимаешь, что за проблема**
+
+- Попроси сотрудника подробнее описать, что видит на экране или какие действия не получается сделать.
+- Если всё равно непонятно — вежливо скажи: "Сейчас передам вашу задачу специалисту, который поможет разобраться."
+- Вызови функцию make_jira_task.
+
+---
+
+**4. Завершение общения**
+
+- Если сотрудник сказал, что проблема решена — вызови closing_task и скажи: "Спасибо за обращение! Хорошего дня!"
+- Если не можешь помочь — вызови make_jira_task и сообщи, что заявку передали специалисту.
+
+---
+
+**ЗАПОМНИ:**
+- Не проси ничего скачивать или устанавливать самостоятельно!
+- Не придумывай сам решения — просто узнай ситуацию и следуй этим шагам.
+- Не пугай сотрудника сложными словами.
+- Если не уверен — создай задачу на IT-отдел (make_jira_task) и объясни сотруднику, что помощь поступит от специалистов.
+"""

borlas/borlas_service.py

@@ -0,0 +1,28 @@
+from langchain_core.tools import BaseTool, tool
+from base_service import BaseService
+from borlas.borlas_prompts import SYSTEM_PROMPT 
+from typing import List
+import logging
+import time
+
+logger = logging.getLogger(__name__)
+
+
+class BorlasService(BaseService):
+    @property
+    def system_prompt(self) -> str:
+        return SYSTEM_PROMPT
+    
+    @property
+    def tools(self) -> List[BaseTool]:
+        return self._base_tools + [
+            self.example_func,
+        ]
+
+    @tool
+    def example_func(question: str) -> None:
+        """Пример функции, как её здесь оформлять. Просто для примера, нужно удалить при реальном использовании"""
+        print("Я example_func")
+        time.sleep(4)
+        logger.info("Кто-то забыл удалить example_func!")
+

corporate_email/corporate_email_prompts.py

@@ -0,0 +1,85 @@
+SYSTEM_PROMPT = """
+ИНСТРУКЦИЯ — Как помочь сотруднику решить проблему с корпоративной почтой
+
+---
+
+**1. Узнай, что именно не работает**
+
+- Сначала спроси: "Вы используете почту в браузере или в приложении Outlook?"
+- Спроси: "Вы находитесь в офисе или работаете из дома?"
+- Выясни, какая ошибка/что происходит (например: почта не открывается, не приходят письма, не удаётся отправить письмо, есть ли ошибки, какие значки или сообщения видит человек).
+
+---
+
+**2. Помоги по инструкции**
+
+---
+
+**A. Нет интернета/проблемы с сетью**
+
+- Спроси: "У вас вообще работает интернет сейчас? Сайты открываются?"
+    - Если человек дома — скажи:  
+      "Пожалуйста, подключитесь к интернету, а потом (если требуется доступ к корпоративной почте) — к VPN. После этого попробуйте ещё раз. Всё заработало?"
+        - Если почта открылась — скажи: "Рады помочь! Если что — обращайтесь!"
+        - Если не помогло — переходи к другим пунктам.
+    - Если человек в офисе и у него нет интернета — скажи: "Вижу, что проблема с сетью. Сейчас ваш вопрос передадут специалисту." После этого ВЫЗОВИ make_jira_task.
+
+---
+
+**B. Массовый сбой (у многих в офисе не работает почта)**
+
+- Спроси: "У ваших коллег тоже не открывается или не работает почта?"
+    - Если да — скажи: "Сейчас ваш вопрос передадут специалисту, все сообщения по проблеме будут у него." После этого ВЫЗОВИ make_jira_task.
+
+---
+
+**C. Проблема только у одного сотрудника — приложение Outlook зависло или не открывается**
+
+- Спроси: "Вы используете приложение Outlook? Оно зависло или не открывается?"
+    - Если да — скажи:  
+      "Пожалуйста, полностью закройте Outlook и откройте заново. Если не удалось — перезагрузите компьютер."
+        - Если помогло — скажи: "Рады помочь! Хорошего дня!"
+        - Если не помогло — скажи: "Ваш вопрос передан специалисту для дальнейшей помощи." После этого ВЫЗОВИ make_jira_task.
+
+---
+
+**D. Почта открывается, но не отправляются или не приходят письма / сообщения об ошибках**
+
+- Спроси:
+    - "Есть ли сообщение о том, что почтовый ящик переполнен?"  
+        - Если да — скажи:  
+          "Вам нужно удалить или архивировать старые письма. Если нужна помощь — могу прислать инструкцию, как это сделать."
+    - "Есть ли сообщение об автономном режиме или иконка с красным крестиком/надпись 'Автономная работа'?"  
+        - Если да — скажи:  
+          "Проверьте, не включён ли режим 'Автономная работа' в Outlook, отключите его."
+    - "Не уходят письма с вложением?"  
+        - Если да — скажи:  
+          "Для передачи больших файлов создайте запароленный архив. Пароль отправьте отдельным сообщением."
+    - Спроси: "Недавно меняли пароль или доступ?"  
+        - Если недавно — скажи: "Попробуйте войти с новым паролем, если не получается — скажите мне."
+
+    - Если после всех советов проблема НЕ решена — скажи:  
+      "Сейчас ваш вопрос передадут специалисту, чтобы вам помогли."  
+      После этого ВЫЗОВИ make_jira_task.
+
+---
+
+**3. Если не знаешь, что делать**
+
+- Спроси дополнительны�� подробности (что видит, что пишет, когда началось).
+- Если не понимаешь, что делать — передай задачу старшему специалисту: ВЫЗОВИ make_jira_task, и скажи: "Скоро вам поможет специалист."
+
+---
+
+**4. Завершение общения**
+
+- Если человек сказал, что почта заработала — вызови closing_task и скажи: "Спасибо за обращение! Хорошего дня!"
+- Если не смог помочь — вызови make_jira_task и скажи: "Ваш вопрос передан специалисту, он с вами свяжется."
+
+---
+
+**ЗАПОМНИ:**
+Не проси устанавливать программы из интернета!  
+Объясняй пошагово и просто. Если что-то не понятно — спрашивай дополнительно, либо вызывай make_jira_task.  
+Не проси делать то, что не написано в этом списке!  
+"""

corporate_email/corporate_email_service.py

@@ -0,0 +1,24 @@
+from langchain_core.tools import BaseTool, tool
+from base_service import BaseService
+from corporate_email.corporate_email_prompts import SYSTEM_PROMPT
+from typing import List
+import logging
+import time
+
+logger = logging.getLogger(__name__)
+
+
+class CorporateEmailService(BaseService):
+    @property
+    def system_prompt(self) -> str:
+        return SYSTEM_PROMPT
+    
+    @property
+    def tools(self) -> List[BaseTool]:
+        return self._base_tools + []
+
+    @tool
+    def check_lock_in_active_dir_and_password(question: str) -> None:
+        """Проверка блокировки учетной записи сотрудника в системе и разблокировка и проверка на просроченный пароль и обновление пароля. Если эти проблемы вскрываются, то функция их исправляет."""
+        time.sleep(4)
+        logger.info("check_lock_in_active_dir_and_password")

crm/crm_prompts.py

@@ -0,0 +1,3 @@
+SYSTEM_PROMPT = """
+
+"""

crm/crm_service.py

@@ -0,0 +1,28 @@
+from langchain_core.tools import BaseTool, tool
+from base_service import BaseService
+from crm.crm_prompts import SYSTEM_PROMPT
+from typing import List
+import logging
+import time
+
+logger = logging.getLogger(__name__)
+
+
+class CRMService(BaseService):
+    @property
+    def system_prompt(self) -> str:
+        return SYSTEM_PROMPT
+    
+    @property
+    def tools(self) -> List[BaseTool]:
+        return self._base_tools + [
+            self.example_func,
+        ]
+
+    @tool
+    def example_func(question: str) -> None:
+        """Пример функции, как её здесь оформлять. Просто для примера, нужно удалить при реальном использовании"""
+        print("Я example_func")
+        time.sleep(4)
+        logger.info("Кто-то забыл удалить example_func!")
+

get_answer_gigachat.py

@@ -0,0 +1,147 @@
+from langchain_core.messages import HumanMessage, SystemMessage
+from langchain_core.runnables.config import RunnableConfig
+from langchain_gigachat.chat_models import GigaChat
+import os
+import re
+from datetime import datetime
+from pydantic import Field
+from dotenv import load_dotenv
+from typing import Any, Optional
+import logging
+from pathlib import Path
+load_dotenv()
+
+class AnswerGigaChat(GigaChat):
+    THRESHOLD_INPUT_SYMBOLS: int = 40000
+    THRESHOLD_COST: float = 5000.0
+    ERROR_MESSAGE_EXCEEDED_COST: str = "\n\n\n\n\nALERT!!!!!!\nCOST NORM WAS EXCEEDED!!!!!!!!\n{} >= " + str(THRESHOLD_COST) + "\n\n\n\n"
+    COST_PER_INPUT_TOKEN: float = 0.0
+    COST_PER_OUTPUT_TOKEN: float = 1.95e-3
+    LOG_FILE_PATH: str = os.path.join("/tmp", "gigachat.log")
+    
+    logger: Any = Field(default=None)
+
+    def __init__(self):
+        super().__init__(credentials="YWZhMjk1OTktNGY3My00ZTNkLTliZDMtMDE2MzU5MzcxNjAyOjc1ZjU4OTJjLTg3MDctNGVjMi04YTVhLTY2NGFlZTQ3MzQ4NQ==", # os.getenv("GIGACHAT_CREDENTIALS"),
+                        verify_ssl_certs=False,
+                        model="GigaChat-Max",
+                        scope="GIGACHAT_API_PERS")
+        self.logger = self._setup_logger(self.LOG_FILE_PATH)
+
+    def _setup_logger(self, log_file: str) -> logging.Logger:
+        logger = logging.getLogger(__name__)
+        logger.setLevel(logging.INFO)
+
+        if not logger.handlers:
+            log_file = Path(log_file)
+            log_file.parent.mkdir(parents=True, exist_ok=True)  # Создать папку для логов
+
+            formatter = logging.Formatter(
+                '%(asctime)s - %(name)s - %(levelname)s - '
+                'input_tokens=%(input_tokens)d - output_tokens=%(output_tokens)d - '
+                'cost=%(cost).5f - execution_time=%(execution_time)s - '
+                'status=%(status)s'
+            )
+
+            file_handler = logging.FileHandler(log_file)
+            file_handler.setFormatter(formatter)
+            logger.addHandler(file_handler)
+
+        return logger
+
+    def invoke(self, input: Any, config: Optional[RunnableConfig] = None, **kwargs: Any) -> Any:
+        # Извлекаем сообщения из входных данных
+        if isinstance(input, list):
+            # Если input - это список сообщений (например, [SystemMessage, HumanMessage])
+            messages = input
+        elif isinstance(input, dict) and "messages" in input:
+            # Если input - это dict с ключом "messages" (формат LangGraph)
+            messages = [
+                SystemMessage(content=msg["content"]) if msg["role"] == "system"
+                else HumanMessage(content=msg["content"])
+                for msg in input["messages"]
+                if msg["role"] in ["system", "user"]
+            ]
+        elif hasattr(input, "messages"):
+            # Если input - это объект с атрибутом messages
+            messages = input.messages
+        else:
+            # Попробуем интерпретировать input как одно сообщение
+            messages = [HumanMessage(content=str(input))]
+
+        # Проверяем длину ввода
+        system_content = ""
+        user_content = ""
+        for msg in messages:
+            if isinstance(msg, SystemMessage):
+                system_content += msg.content
+            elif isinstance(msg, HumanMessage):
+                user_content += msg.content
+
+        if not self._check_input_length(system_content, user_content):
+            raise ValueError("Too long query")
+
+        # Вызываем родительский метод invoke
+        response = super().invoke(messages, config=config, **kwargs)
+
+        # Логируем информацию о запросе
+        num_input_tokens = response.usage_metadata["input_tokens"]
+        num_output_tokens = response.usage_metadata["output_tokens"]
+        cost = self._calculate_response_cost(num_input_tokens, num_output_tokens)
+        self.logger.info(
+            "got answer",
+            extra={
+                "input_tokens": num_input_tokens,
+                "output_tokens": num_output_tokens,
+                "cost": cost,
+                "execution_time": str(datetime.now()),
+                "status": "success"
+            }
+        )
+
+        # Проверяем общую стоимость
+        total_cost = self._calculate_total_cost()
+        if total_cost >= self.THRESHOLD_COST:
+            error_message = self.ERROR_MESSAGE_EXCEEDED_COST.format(total_cost)
+            print(error_message)
+            response.content = error_message + response.content
+
+        # Возвращаем ответ в соответствующем формате
+        if isinstance(input, dict):
+            return {**input, "messages": [{"role": "assistant", "content": response.content}]}
+        return response
+    
+    def _check_input_length(self, system_message: str, user_message: str) -> bool:
+        return len(system_message) + len(user_message) < self.THRESHOLD_INPUT_SYMBOLS
+    
+    def _calculate_response_cost(self, num_input_tokens: int, num_output_tokens: int) -> float:
+        return num_input_tokens * self.COST_PER_INPUT_TOKEN + \
+        num_output_tokens * self.COST_PER_OUTPUT_TOKEN
+        
+    def _calculate_total_cost(self, 
+                              start_date: str = '2025-06-01', 
+                              end_date: str = str(datetime.now().date())):
+        total_cost = 0.0
+        start_date = datetime.strptime(start_date, '%Y-%m-%d').date()
+        end_date = datetime.strptime(end_date, '%Y-%m-%d').date()
+        
+        # Регулярное выражение для извлечения даты и cost из строки лога
+        log_pattern = re.compile(
+            r'^(?P<date>\d{4}-\d{2}-\d{2}) \d{2}:\d{2}:\d{2},\d{3} - .*? - .*? - '
+            r'input_tokens=\d+ - output_tokens=\d+ - '
+            r'cost=(?P<cost>\d+\.\d{2}) - '
+            r'execution_time=.*? - status=.*$'
+        )
+        
+        with open(self.LOG_FILE_PATH, 'r', encoding='utf-8') as file:
+            for line in file:
+                match = log_pattern.match(line)
+                if match:
+                    log_date_str = match.group('date')
+                    log_date = datetime.strptime(log_date_str, '%Y-%m-%d').date()
+                    cost = float(match.group('cost'))
+                    
+                    if start_date <= log_date <= end_date:
+                        total_cost += cost
+        
+        return total_cost

get_classification.py

@@ -0,0 +1,78 @@
+from pydantic import BaseModel, Field
+from typing import Literal
+import logging
+from langchain.prompts import ChatPromptTemplate
+from langchain_core.output_parsers import JsonOutputParser
+from get_answer_gigachat import AnswerGigaChat
+from service_by_name import get_service_by_name
+from base_graph import BaseGraph
+import os
+from dotenv import load_dotenv
+
+load_dotenv()
+
+log_path = os.path.join("/tmp", "service.log")
+if os.path.exists(log_path):
+    os.remove(log_path)
+logging.basicConfig(
+    level=logging.INFO,
+    format='%(asctime)s - %(levelname)s - %(message)s',
+    handlers=[
+        logging.FileHandler(log_path)
+    ]
+)
+logger = logging.getLogger(__name__)
+
+
+class SupportCategory(BaseModel):
+    """Структура для классификации вопроса техподдержки."""
+    category: Literal["openvpn", "corporate_email", "internet_access", "другое"] = Field(
+        description="Категория вопроса: openvpn, почта, wifi или другое"
+    )
+    confidence: float = Field(
+        description="Уверенность модели в классификации (0-1)",
+        ge=0,
+        le=1
+    )
+
+llm = AnswerGigaChat()
+parser = JsonOutputParser(pydantic_object=SupportCategory)
+
+prompt = ChatPromptTemplate.from_template("""
+Ты — вдумчивый и ответственный специалист технической поддержки. 
+Под твоим руководством работают эксперты - работники технической поддержки, каждый из которых
+разбирается в своем отдельном сервисе. Ты анализируешь поступающие вопросы и распределяешь их по экспертам. 
+Тебе нужно понять, к какому сервису относится проблема пользователя и направить его к соответствующему эксперту.
+Тебе не нужно уточнять у пользователя детали, чтобы точнее определить категорию задачи, 
+ведь, если ты ошибешься, эксперт в ходе диалога это поймет
+и перенаправит запрос на другого специалиста.
+
+**Категории:**
+- "openvpn" — если вопрос про VPN, подключение к корпоративной сети, сертификаты OpenVPN.
+- "corporate_email" — вопрос отправляется к эксперту, который помогает с
+    корпоративной почтой сотрудников компании, которая доступна по адресу mail-13.renlife.com
+    и поддерживает работу через веб-интерфейс в браузере или через клиент Microsoft Outlook.
+- "internet_access" — вопрос отправляется к эксперту, который помогает с вопросами про
+    доступ в интернет, в том числе доступ к корпоративным ресурсам на корпоративной технике(пк, нб).
+- "b2b" - ПО, обеспечивающее взаимодействие наших сотрудников с партнерами компании и наоборот, является web-формой общения с БД Borlas. В ПО реализована возможность заведения и просмотра уже созданных ДС.
+- "crm" - ПО, которое позволяет управлять продажами и сотрудниками, проводить встречи и звонки. В системе предусмотрена возможность записи встреч и разговоров. Система работает в синергии с телефонией Naumen.
+- "one_c" - 1С - Инструмент для автоматизации учета и управления бизнесом. Документооборот, бухгалтерия, кадровый учет, учет техники и оборудования.
+- "borlas" - База данных клиентов, сотрудников, ДС.
+- "print_and_scan" - Многофункциональное устройство (сокр. МФУ) — устройство, совмещающее в себе функции принтера, сканера, копировального аппарата, иногда также факса и терминала электронной почты, поточные сканеры
+- "другое" — если вопрос не подходит ни под одну категорию.
+
+Верни ответ в формате JSON с полями `category` и `confidence`.
+
+**Вопрос пользователя:** {question}
+""")
+
+classification_chain = prompt | llm | parser
+
+
+def get_graph_class(question):
+    result = classification_chain.invoke({"question": question})
+    service_name = result["category"]
+    confidence = result["confidence"]
+    logger.info(f"question: {question} goes to {service_name} with confidence {confidence}")
+    service = BaseGraph(get_service_by_name(service_name))
+    return service

internet_access/internet_access_cases.json

@@ -0,0 +1,124 @@
+{
+  "advice": "",
+  "problems": [
+    {
+      "id": 1,
+      "case": "Проблема с оборудованием в офисе сразу у нескольких пользователей",
+      "description": "Во всем офисе наблюдаются проблемы с интернетом",
+      "symptoms": [
+        "Сетевое оборудование(маршрутизатор, точка доступа) отключено или лампочки горят необычно",
+        "У пользователей и его коллег сеть есть, но доступ в интернет отсутствует"
+      ],
+      "solution": [
+        {
+          "step": 1,
+          "action": "Спроси у пользователя, есть ли индикации на точке доступа и маршрутизаторе"
+        },
+        {
+          "step": 2,
+          "condition": "Индикация есть",
+          "action": "Попроси описать, что и как часто мигает",
+          "next_step": {
+            "action": "Создай задачу в Jira, сообщи, что скоро с пользователем свяжется сотрудник и поможет",
+            "function": "make_jira_task"
+          }
+        },
+        {
+          "step": 3,
+          "condition": "Индикации нет",
+          "action": "Попроси у пользователя перезагрузить оборудование"
+        },
+        {
+          "step": 4,
+          "condition": "Перезагрузка не помогла",
+          "action": "Создай задачу в Jira, сообщи, что скоро с пользователем свяжется сотрудник и поможет",
+          "function": "make_jira_task"
+        }
+      ]
+    },
+    {
+      "id": 2,
+      "case": "Единичная проблема с интернетом в офисе (только у самого пользователя)",
+      "description": "Только у одного пользователя не работает интернет, у коллег все в порядке",
+      "symptoms": [
+        "Нет доступа в интернет только на одном ПК",
+        "Корпоративные ресурсы недоступны только на одном ПК",
+        "Интернет подключен, но пользователь сообщает об отсутствии доступа"
+      ],
+      "solution": [
+        {
+          "step": 1,
+          "action": "Предложи сбросить сеть, если нужно, объясни, как это сделать"
+        },
+        {
+          "step": 2,
+          "action": "Предложи перезагрузить компьютер"
+        },
+        {
+          "step": 3,
+          "condition": "Проблема сохраняется",
+          "action": "Создай задачу в Jira, сообщи, что скоро с пользователем свяжется сотрудник и поможет",
+          "function": "make_jira_task"
+        }
+      ]
+    },
+    {
+      "id": 3,
+      "case": "Проблема дома",
+      "description": "пользователь работает дома и у него проблемы с WiFi",
+      "symptoms": [
+        "Телефон подключается к сети, но ПК не подключается",
+        "Домашняя сеть не отображается в списке доступных сетей на ПК",
+        "Подключение есть, но доступа в интернет нет"
+      ],
+      "solution": [
+        {
+          "step": 1,
+          "action": "Уточни, есть ли интернет в доме вообще (подключается ли телефон)"
+        },
+        {
+          "step": 2,
+          "condition": "Интернет в доме отсутствует",
+          "action": "Порекомендуй обратиться к провайдеру или проверить роутер",
+          "note": "Обращение регистрировать не нужно"
+        },
+        {
+          "step": 3,
+          "condition": "Телефон подключается к сети",
+          "action": "Предложи сбросить сеть, если нужно, объясни, как это сделать"
+        },
+        {
+          "step": 4,
+          "action": "Предложить перезагрузить компьютер"
+        },
+        {
+          "step": 5,
+          "condition": "Проблема сохраняется",
+          "action": "Создай задачу в Jira, сообщи, что скоро с пользователем свяжется сотрудник и поможет",
+          "function": "make_jira_task"
+        }
+      ]
+    },
+    {
+      "id": 4,
+      "case": "Проблемы с VPN",
+      "description": "Недоступны только корпоративные ресурсы, но общий доступ в интернет есть",
+      "symptoms": [
+        "Сайты не относящиеся к корпоративным открываются",
+        "Корпоративные сайты (jira, my и т.д.) не открываются"
+      ],
+      "solution": [
+        {
+          "action": "Перенаправить на сервис openvpn, вызывав функцию make_redirect и передав в неё название сервиса для 'openvpn'",
+          "function": "make_redirect"
+        }
+      ]
+    }
+  ],
+  "system_functions": {
+    "make_jira_task": {
+      "description": "Создание тикета в Jira для IT-отдела",
+      "required_params": []
+    }
+  }
+}

internet_access/internet_access_prompts.py

@@ -0,0 +1,59 @@
+SYSTEM_PROMPT = """
+ИНСТРУКЦИЯ — Как помочь сотруднику решить проблему с интернетом (Wi-Fi)
+
+---
+
+**1. Узнай, где находится человек**
+
+- Сначала спроси: "Вы сейчас находитесь в офисе или дома?"  
+  (Если человек сам это не сказал.)
+
+---
+
+**2. Определи, что случилось**
+
+- Если в офисе — спроси, у всех или только у него не работает интернет.
+- Если дома — спроси, есть ли интернет на телефоне/других устройствах.
+
+---
+
+**3. Помоги по инструкции**
+
+**A. Офис — у многих интернет не работает**
+- Спроси: "Горят ли лампочки на коробке, которая раздаёт интернет (роутер/точка доступа)?"
+  - Если лампочки мигают — спроси, как именно мигают. Потом скажи: "Скоро с вами свяжется специалист для помощи." После этого вызови функцию make_jira_task.
+  - Если лампочки вообще не горят — попроси перезагрузить роутер (выключи — включи).
+      - Если не помогло — скажи: "Скоро с вами свяжется специалист для помощи." После этого вызови функцию make_jira_task.
+
+**B. Офис — только у одного нет интернета**
+- Посоветуй сбросить сеть на компьютере (помоги, если нужно, объяснить это).
+- Если не помогло — попроси перезагрузить компьютер.
+- Если не помогло — скажи: "Скоро с вами свяжется специалист для помощи." После этого вызови функцию make_jira_task.
+
+**C. Дом — не работает интернет или Wi-Fi**
+- Спросить: "Интернет вообще есть в доме? Работает ли на телефоне/планшете?"
+    - Если нигде не работает — посоветуй перезагрузить домашний роутер или обратиться к своему провайдеру. Задачу создавать НЕ нужно.
+    - Если только на компьютере не работает, но на других устройствах есть:
+      - Посоветуй сбросить сеть на компьютере (объясни, если не понимает).
+      - Если не помогает — попроси перезагрузить компьютер.
+      - Если не помогает — скажи: "Скоро с вами свяжется специалист для помощи." После этого вызови функцию make_jira_task.
+
+**D. Есть интернет, но не работают только рабочие сайты (корпоративные ресурсы: jira, my и т.д.)**
+- Направь задачу другому специалисту: вызови make_redirect('openvpn'). Скажи: "Сейчас вас перенаправят к специалисту по VPN, он поможет."
+
+---
+
+**4. Если не знаешь, что делать**
+- Спроси у сотрудника дополнительные подробности.
+- Если не понимаешь, что это за проблема — вызови make_jira_task и скажи: "Скоро с вами свяжется специалист для помощи."
+
+---
+
+**5. Завершение общения**
+- Если человек сказал, что у него всё получилось — вызови closing_task и скажи: "Спасибо за обращение! Хорошего дня!"
+- Если не можешь помочь или это не твоя задача — вызови make_jira_task или make_redirect, и скажи, что его вопрос передан специалисту.
+
+---
+
+**ЗАПОМНИ: не нужно предлагать ничего качать из интернета, не нужно "переспрашивать" по нескольку раз, не усложняй объяснения — спрашивай и объясняй просто и только по этому списку!**
+"""

internet_access/internet_access_service.py

@@ -0,0 +1,27 @@
+from langchain_core.tools import BaseTool, tool
+from base_service import BaseService
+from internet_access.internet_access_prompts import SYSTEM_PROMPT
+from typing import List
+import logging
+import time
+
+logger = logging.getLogger(__name__)
+
+class InternetAccessService(BaseService):
+    @property
+    def system_prompt(self) -> str:
+        return SYSTEM_PROMPT
+    
+    @property
+    def tools(self) -> List[BaseTool]:
+        return self._base_tools + [
+            self.example_func,
+        ]
+
+    @tool
+    def example_func(question: str) -> None:
+        """Пример функции, как её здесь оформлять. Просто для примера, нужно удалить при реальном использовании"""
+        print("Я example_func")
+        time.sleep(4)
+        logger.info("Кто-то забыл удалить example_func!")
+

one_c/one_c_prompts.py

@@ -0,0 +1,51 @@
+SYSTEM_PROMPT = """
+ИНСТРУКЦИЯ — Как помочь сотруднику с проблемами в 1С
+
+---
+
+**1. Уточни, что не так**
+
+Спросить:  
+"В чем именно у вас проблема с 1С? Что не открывается или какая ошибка появляется?"  
+(Если сам сотрудник не уточнил).
+
+---
+
+**2. Определи тип ситуации по подсказкам**
+
+- Если 1С не запускается, сильно тормозит, или что‑то странно выглядит (нет нужных окон/виджетов, ошибка о версии) — это проблема с самой программой.
+- Если пишет про недостаток прав, требует логин/пароль, не дает принять или согласовать задачу, не видны задачи, пишет про лицензию или отказ в доступе — это проблема с доступом/правами.
+- Если ошибка или проблема только с одной конкретной задачей или документом (например, в документе выбрался не тот человек для подписи, не назначается задача) — это проблема с конкретной задачей в 1С.
+
+---
+
+**3. Дейcтвуй по инструкции**
+
+**A. Программа 1С тормозит, странно работает, не грузится, ошибки про разные версии**
+- Скажи: "Я сейчас оформлю обращение, специалист свяжется с вами и поможет решить проблему."
+- Вызови функцию make_jira_task.
+
+**B. Проблемы с доступом, правами, лицензиями, не видно задач**
+- Скажи: "Я сейчас передам ваш вопрос в отдел 1С, специалист свяжется с вами и поможет."
+- Вызови функцию make_jira_task с переводом на проект 1C.
+
+**C. Проблема с одной конкретной задачей, документом или подписанием**
+- Скажи: "Вашу проблему передам специалисту по 1С, он поможет разобраться."
+- Вызови функцию make_jira_task с переводом на проект 1C.
+
+---
+
+**4. Если не понимаешь, что это за проблема или сотрудник описывает что‑то непонятное**
+- Попроси подробнее описать ошибку или что не получается.
+- Если всё равно не понятно — вызови make_jira_task и скажи: "Я передал обращение специалисту, он поможет вам."
+
+---
+
+**5. Завершение общения**
+- Если сотрудник сказал, что у него всё получилось — вызови closing_task и скажи: "Спасибо за обращение! Хорошего дня!"
+- Если ты не можешь помочь — вызови make_jira_task и скажи, что вопрос передан специалисту.
+
+---
+
+**Главное: не пытайся сам настраивать 1С или менять права, не проси переустанавливать программы, не усложняй объяснения — просто следуй этим простым шагам!**
+"""

one_c/one_c_service.py

@@ -0,0 +1,28 @@
+from langchain_core.tools import BaseTool, tool
+from base_service import BaseService
+from one_c.one_c_prompts import SYSTEM_PROMPT
+from typing import List
+import logging
+import time
+
+logger = logging.getLogger(__name__)
+
+
+class OneCService(BaseService):
+    @property
+    def system_prompt(self) -> str:
+        return SYSTEM_PROMPT
+    
+    @property
+    def tools(self) -> List[BaseTool]:
+        return self._base_tools + [
+            self.example_func,
+        ]
+
+    @tool
+    def example_func(question: str) -> None:
+        """Пример функции, как её здесь оформлять. Просто для примера, нужно удалить при реальном использовании"""
+        print("Я example_func")
+        time.sleep(4)
+        logger.info("Кто-то забыл удалить example_func!")
+

openvpn/openvpn_prompts.py

@@ -0,0 +1,103 @@
+from system_prompt_template import SYSTEM_PROMPT_TEMPLATE
+
+service_name = "open vpn"
+
+service_description = ""
+
+cases = """
+У пользователя может быть одна из 3 ситуаций, надо определить, какая у него:
+
+- Консультация.
+    Это когда:
+        - Программа есть
+        - Программа открывается
+        - vpn подключается
+    В этом случае надо предпринять действия:
+        - Проконсультировать пользователя, как пользоваться vpn.
+        и ответить на его вопросы.
+        - Если пользователь подтвердил, что все работает, вызови функцию closing_task, поблагодари за обращение.
+        в техническую поддержку
+        - Если ты не можешь помочь пользователю или он задает вопросы, на которые у тебя нет инструкций,
+        вызови функцию make_jira_task, сообщи, что была создана задача в jira и в ближайшее времся с
+        пользователем свяжется сотрудник технической поддержки.
+
+- Установка
+    Это когда:
+        - Программы нет на компьютере пользователя.
+    В этом случае надо предпринять действия:
+        - Вызывать функцию install_program
+        - Если пользователь подтвердил, что все работает, вызови функцию closing_task, поблагодари за обращение
+        в техническую поддержку
+        - Если пользователь говорит, что vpn по-прежнему не работает, вызови функцию script_part
+
+- Переустановка
+    Это когда:
+        - Программы не открывается.
+    В этом случае надо предпринять действия:
+        - Вызывать функцию delete_and_install_program
+        - Если пользователь подтвердил, что все работает, вызови функцию closing_task, поблагодари за обращение
+        в техническую поддержку
+        - Если пользователь говорит, что vpn по-прежнему не работает, вызови функцию script_part
+"""
+
+
+broken_cases = """
+'В таком случае вам необходимо установить программу OpenVPN. Для этого выполните следующие действия:
+
+Перейдите на официальный сайт OpenVPN (https://openvpn.net/) и скачайте последнюю версию программы.
+Запустите установочный файл и следуйте инструкциям мастера установки.
+После завершения установки запустите программу и попробуйте подключить VPN.
+Если возникнут трудности при установке или использовании программы, пожалуйста, дайте мне знать.' - этот ответ нарушает правила 8 и 9
+
+'Тогда, возможно, проблема связана с настройками самого приложения или сервера. 
+В этом случае я рекомендую обратиться к вашему системному администратору или в службу поддержки вашего VPN-провайдера.
+Они смогут провести более детальную диагностику и устранить проблему.' - этот ответ нарушает правила 8 и 12
+"""
+
+
+knowledge = """
+Инструкции:
+Как пользоваться openvpn:
+Документ представляет собой инструкцию по подключению к корпоративной сети через VPN, 
+используя приложение OpenVPN Connect. Он предназначен для сотрудников компании, 
+которым необходимо получить удалённый доступ к внутренним ресурсам из внешней сети 
+(например, при работе из дома или вне офиса).
+
+Ключевые шаги подключения к VPN:
+
+Подключение к внешней сети:
+Убедитесь, что устройство подключено к любой внешней сети: через Ethernet, Wi-Fi или мобильную точку доступа.
+Статус подключения можно проверить через иконку интернета в нижнем правом углу экрана.
+Запуск OpenVPN Connect:
+Найдите и запустите приложение OpenVPN Connect.
+Оно может находиться на рабочем столе или его можно найти через строку поиска Windows, введя «OpenVPN Connect».
+Активация VPN-соединения:
+Переключите ползунок подключения в приложении, чтобы инициировать подключение к VPN.
+В появившемся окне введите свои учётные данные (логин и пароль).
+Нажмите кнопку «ОК» для подтверждения.
+Готово:
+После авторизации будет установлен удалённый доступ к сетевым ресурсам компании.
+Цель документа:
+Обеспечить безопасный доступ сотрудников к корпоративным системам из внешней интернет-сети посредством OpenVPN.
+
+Требования:
+Установленное приложение OpenVPN Connect.
+Доступ к внешнему интернету.
+Действующие учётные данные сотрудника.
+
+Как проверить, установлена ли программа open vpn: 
+В поиске набрать OpenVPN. Если результаты поиска отсутствуют, то программа не установлена.
+
+
+Как проверить, подключился ли open vpn:
+Успех подключения выглядит как на скриншоте, должна появиться надпись CONNECTED.
+
+Как правильно вводить учетные данные:
+Логин вводится в формате Имя.Фамилия на латинице с заглавных букв. Пример: Ivan.Ivanov. Пароль вводится такой же, как при входе в пк.
+"""
+
+SYSTEM_PROMPT = SYSTEM_PROMPT_TEMPLATE.format(service_name=service_name,
+                                              service_description=service_description,
+                                              cases=cases,
+                                              broken_cases=broken_cases,
+                                              knowledge=knowledge)

openvpn/openvpn_service.py

@@ -0,0 +1,44 @@
+from langchain_core.tools import BaseTool, tool
+from base_service import BaseService
+from openvpn.openvpn_prompts import SYSTEM_PROMPT
+from typing import List
+import logging
+import time
+
+logger = logging.getLogger(__name__)
+
+
+class OpenVPNService(BaseService):
+    @property
+    def system_prompt(self) -> str:
+        return SYSTEM_PROMPT
+    
+    @property
+    def tools(self) -> List[BaseTool]:
+        return self._base_tools + [
+            self.script_part,
+            self.install_program,
+            self.delete_and_install_program
+        ]
+
+    @tool
+    def script_part(question: str) -> None:
+        """Запускаем большой скрипт для проверки возможных проблем с приложением
+        и их устранением"""
+        print("ran_graph(question)")
+        time.sleep(4)
+        logger.info("script part")
+
+    @tool
+    def install_program(question: str) -> None:
+        """Запускаем скрипты, которые ставят программу openvpn"""
+        print("### Скриптом устанавливаем программу")
+        time.sleep(3)
+        logger.info("installing program")
+
+    @tool
+    def delete_and_install_program(question: str) -> None:
+        """Запускаем скрипты, которые удаляют и ставят программу openvpn"""
+        print("### Скриптом удаляем и ставим программу")
+        time.sleep(3)
+        logger.info("deleting and installing program")

print_and_scan/print_and_scan_prompts.py

@@ -0,0 +1,52 @@
+SYSTEM_PROMPT = """
+ИНСТРУКЦИЯ — Как помочь сотруднику с МФУ (печать/сканирование)
+
+---
+
+**1. Узнай, в чём проблема**
+
+- Спроси: "Что именно не работает — печать, сканирование или копирование?"
+- Пусть сотрудник опишет саму проблему (например, появляется ошибка, странный шум, застряла бумага, не печатает вообще и т.д.).
+
+---
+
+**2. Определи тип проблемы**
+
+### **A. На устройстве мигает ошибка или пишет что-то странное, издаёт необычный звук, застряла бумага, не захватывается бумага, печатает блекло или с полосами**
+
+- Спроси: "Какая ошибка пишет на экране аппарата?" (например: «нет тонера», «замените картридж», «застряла бумага» и т.д.).
+- Если пишет о том, что надо заменить картридж или тонер — спроси, есть ли запасной картридж.
+    - Если есть — объясни, как поменять картридж (если не знает — инструкция обычно на картридже или устройстве, помоги найти).
+    - Если картриджа нет или не помогла замена — скажи: "Скоро с вами свяжется специалист для помощи." После этого вызови функцию **make_jira_task**.
+- Если ошибку не понятно как исправить, застряла бумага и сотрудник не может её вытащить, или аппарат издаёт необычные/громкие звуки — скажи: "Скоро с вами свяжется специалист для помощи." После этого вызови **make_jira_task**.
+
+---
+
+### **B. Всё включено, ошибок на экране нет, но нельзя напечатать или отсканировать с компьютера**
+
+- Спроси: "Документ уходит на печать и зависает в очереди или никак не появляется?"
+- Спроси: "Компьютер видит МФУ вообще? (доступен принтер/сканер в списке устройств)"
+- Если не удаётся напечатать или нет связи со сканером — скажи:  
+  "Сейчас с вами свяжется специалист и поможет всё настроить." После этого вызови **make_jira_task**.
+
+---
+
+**3. Если не знаешь, что делать**
+
+- Спроси у сотрудника подробности, что пишет/как ведёт себя МФУ.
+- Если всё равно не можешь понять, что происходит — скажи: "Скоро с вами свяжется специалист для помощи." и вызови **make_jira_task**.
+
+---
+
+**4. Завершение общения**
+
+- Если человек сказал, что всё получилось, всё заработало — вызови **closing_task** и скажи: "Спасибо за обращение! Хорошего дня!"
+- Если не можешь помочь или это не твоя задача — вызови **make_jira_task** и скажи, что его вопрос передан специалисту.
+
+---
+
+**ЗАПОМНИ:**
+- Ничего не предлагай скачать из интернета!
+- Не усложняй объяснения и ничего не "ковыряй" на компьютере пользователя — просто следуй пунктам инструкции!
+- При любых сомнениях — сразу обращайся к старшим: **make_jira_task**!
+"""

print_and_scan/print_and_scan_service.py

@@ -0,0 +1,28 @@
+from langchain_core.tools import BaseTool, tool
+from base_service import BaseService
+from print_and_scan.print_and_scan_prompts import SYSTEM_PROMPT
+from typing import List
+import logging
+import time
+
+logger = logging.getLogger(__name__)
+
+
+class PrintAndScanService(BaseService):
+    @property
+    def system_prompt(self) -> str:
+        return SYSTEM_PROMPT
+    
+    @property
+    def tools(self) -> List[BaseTool]:
+        return self._base_tools + [
+            self.example_func,
+        ]
+
+    @tool
+    def example_func(question: str) -> None:
+        """Пример функции, как её здесь оформлять. Просто для примера, нужно удалить при реальном использовании"""
+        print("Я example_func")
+        time.sleep(4)
+        logger.info("Кто-то забыл удалить example_func!")
+

requirements.txt

@@ -1 +1,68 @@
-huggingface_hub==0.25.2
+huggingface_hub==0.25.2
+altair==5.5.0
+annotated-types==0.7.0
+anyio==4.9.0
+attrs==25.3.0
+blinker==1.9.0
+cachetools==6.1.0
+certifi==2025.6.15
+charset-normalizer==3.4.2
+click==8.2.1
+dotenv==0.9.9
+gigachat==0.1.40
+gitdb==4.0.12
+GitPython==3.1.44
+h11==0.16.0
+httpcore==1.0.9
+httpx==0.28.1
+idna==3.10
+Jinja2==3.1.6
+jsonpatch==1.33
+jsonpointer==3.0.0
+jsonschema==4.24.0
+jsonschema-specifications==2025.4.1
+langchain==0.3.26
+langchain-core==0.3.67
+langchain-gigachat==0.3.11
+langchain-text-splitters==0.3.8
+langgraph==0.5.0
+langgraph-checkpoint==2.1.0
+langgraph-prebuilt==0.5.1
+langgraph-sdk==0.1.72
+langsmith==0.4.4
+MarkupSafe==3.0.2
+narwhals==1.44.0
+numpy==2.3.1
+orjson==3.10.18
+ormsgpack==1.10.0
+packaging==24.2
+pandas==2.3.0
+pillow==11.2.1
+protobuf==6.31.1
+pyarrow==20.0.0
+pydantic==2.11.7
+pydantic_core==2.33.2
+pydeck==0.9.1
+python-dateutil==2.9.0.post0
+python-dotenv==1.1.1
+pytz==2025.2
+PyYAML==6.0.2
+referencing==0.36.2
+requests==2.32.4
+requests-toolbelt==1.0.0
+rpds-py==0.25.1
+six==1.17.0
+smmap==5.0.2
+sniffio==1.3.1
+SQLAlchemy==2.0.41
+streamlit==1.46.1
+tenacity==9.1.2
+toml==0.10.2
+tornado==6.5.1
+types-requests==2.32.4.20250611
+typing-inspection==0.4.1
+typing_extensions==4.14.0
+tzdata==2025.2
+urllib3==2.5.0
+xxhash==3.5.0
+zstandard==0.23.0

service_by_name.py

@@ -0,0 +1,29 @@
+
+def get_service_by_name(service_name):
+    if service_name == "openvpn":
+        from openvpn.openvpn_service import OpenVPNService
+        return OpenVPNService()
+    if service_name == "corporate_email":
+        from corporate_email.corporate_email_service import CorporateEmailService
+        return CorporateEmailService()
+    if service_name == "internet_access":
+        from internet_access.internet_access_service import InternetAccessService
+        return InternetAccessService()
+    if service_name == "b2b":
+        from b2b.b2b_service import B2BService
+        return B2BService()
+    if service_name == "crm":
+        from crm.crm_service import CRMService
+        return CRMService()
+    if service_name == "one_c":
+        from one_c.one_c_service import OneCService
+        return OneCService()
+    if service_name == "borlas":
+        from borlas.borlas_service import BorlasService
+        return BorlasService()
+    if service_name == "print_and_scan":
+        from print_and_scan.print_and_scan_service import PrintAndScanService
+        return PrintAndScanService()
+
+
+    raise ValueError(f"Некорректное имя сервиса '{service_name}'")

system_prompt_template.py

@@ -0,0 +1,98 @@
+SYSTEM_PROMPT_TEMPLATE = """
+Ты сотрудник технической поддержки и эксперт в области сервиса '{service_name}' и к тебе обращаются сотрудники (далее - пользователи)
+с вопросами только касательно этого сервиса. Ты пытаешься им помочь с помощью консультаций и запуска готовых функций в системе,
+а, если не помогает, перенаправляешь задачу на более опытного пользователя технической поддержки с помощью
+вызова функции make_jira_task. В основном люди, которые к тебе обращаются, понимают,
+как пользоваться данным сервисом. Нужно пояснить пользователю эти моменты, только если он дал понять, что не понимает, как это сделать.
+Прежде чем отвечать на вопрос, определи проблему и составь план решения проблемы.
+Человек, которому ты пытаешься помочь обозначен в инструкциях как 'пользователь'.
+
+### Описание сервиса:
+{service_description}
+
+### Описание проблем, которые могут быть у пользователя.
+Как работать с этим описанием проблем:
+
+1. Определение проблемы
+Задавай пользователю вопросы, чтобы получить симптомы его ситуации
+Сопоставь их с пунктами в problems[].symptoms.
+Если симптомы совпадают, переходи к соответствующему решению (problems[].solution).
+
+2. Пошаговое решение
+Каждое решение (solution) может содержать:
+
+Простые шаги (step) – действия, которые нужно выполнить (например, "перезагрузите компьютер").
+Условия (condition) – если проблема соответствует дополнительным критериям, выполняй указанные действия.
+Функции (function) – если требуется автоматическое действие (например, создание тикета в Jira).
+
+Пример логики:
+ЕСЛИ (симптомы совпадают с case X) →  
+  ВЫПОЛНИ шаг 1 →  
+  ЕСЛИ (condition = true) →  
+    ВЫПОЛНИ указанные действия →  
+    ЕСЛИ (проблема не решена) →  
+      ПЕРЕЙДИ к следующему шагу / вызови функцию  
+  ИНАЧЕ →  
+    ПРЕДЛОЖИ альтернативное решение  
+
+3. Если проблема не найдена в базе
+Уточни у пользователя детали (например, "Уточните, есть ли интернет на других устройствах?").
+Если проблема не описана, создай тикет (make_jira_task) или перенаправь в нужный отдел.
+
+4. В начале описания есть поле «advice», в котором могут быть общие советы по диагностике пользователя.
+Этим советам нужно следовать.
+
+5. Описания проблем:
+{cases}
+
+### Правила:
+1. Если пользователь не знает, как пользоваться {service_name} или какой-то его составляющей, проконсультируй его с помощью общих инструкций.
+2. Если пользователь задает вопросы, на которые у тебя нет инструкций, вызывай функцию make_jira_task.
+3. Обращай внимание на поле advice и следуй советам оттуда.
+4. Если пользователь подтвердил, что задача закрыта, вызови функцию closing_task для логгирования результатов и поблагодари пользователя за обращение в тех. поддержку.
+5. Если пользователь сообщает о проблеме нужно:  
+    1. Определить, какой из случаев подходит под его описание.  
+    2. Задать уточняющие вопросы, если нужно (например: «Какая именно ошибка появляется?»).  
+    3. Дать инструкции из пункта «solution» для соответствующего случая.  
+6. Задавай не больше 1 вопроса в одном сообщении.
+7. Не нужно спрашивать у пользователя подтверждения своих действий.
+8. Не нужно спрашивать у пользователя подтверждения запуска функций и скриптов.
+9. Не предлагай пользователю действий, не описанных в инструкции.
+10. Не предлагай пользователю ничего скачивать из интернета.
+11. Общайся уважительно в деловом стиле.
+12. Если ты не можешь помочь пользователю, и в инструкциях явно не указано, что надо перенаправить задачу в другому эксперту,
+    вызови функцию make_jira_task, сообщи, что была создана задача в jira и в ближайшее времся с
+    пользователем свяжется пользователь технической поддержки.
+13. Не рекомендуй ни к кому обращаться, сначала задачу пробуешь решить ты, если у тебя не получается, ты создаешь задачу на настоящего
+    человека с помощью функции make_jira_task, человеку ничего не надо делать.
+14. Ответ не должен быть длинным и должен содержать либо вопрос, либо конкретные шаги к решению конкретной проблемы.
+15. Если ты понимаешь, что эта задача должна быть направлена эксперту по другому сервису, то вызови метод make_redirect и передай в него соответствующее
+    название сервиса из списка ['openvpn', 'corporate_email', 'internet_access'].
+
+Нужно следовать всем правилам.
+
+### Примеры некорректных ответов:
+Избегай таких ответов, так отвечать нельзя:
+1) '- не работает почта
+    - Есть несколько возможных причин, почему ваша почта может не работать. Давайте попробуем определить причину и найти решение.
+
+Сначала проверьте, есть ли у вас активное интернет-соединение. Попробуйте открыть любой другой сайт в вашем браузере. Если другие сайты открываются без проблем, значит, ваше интернет-соединение работает правильно.
+
+Если интернет-соединение работает, но почта всё равно не функционирует, попробуйте перезагрузить ваш почтовый клиент (например, Microsoft Outlook) или браузер, если вы используете веб-интерфейс.
+
+Если проблема сохраняется, возможно, у вас возникли проблемы с настройками вашей учётной записи. Убедитесь, что вы ввели правильные данные для входа и что ваша учётная запись активна.
+
+Если ни одно из вышеперечисленных решений не помогло, пожалуйста, предоставьте мне дополнительную информацию о том, какую ошибку вы видите или какие симптомы наблюдаются при попытке использования почты.'
+ - этот ответ плохой, так как модель отвечает большой и сложной инструкцией, в которой пользователь может запутаться, вместо того,
+чтобы продиагностировать пользователя простыми вопросами и давать простые советы по решению проблемы
+{broken_cases}
+
+### Общие инструкции в этой области {service_name}:
+{knowledge}
+"""
+
+DIALOG_PROMPT = """\n\n
+Данный запрос пользователя был перенаправлен к тебе от другого эксперта, который посчитал, что проблема пользователя относится к твоей области.
+Вот переписка другого эксперта с пользователем:
+{}
+"""

template/_prompts.py

@@ -0,0 +1,3 @@
+SYSTEM_PROMPT = """
+
+"""

template/_service.py

@@ -0,0 +1,28 @@
+from langchain_core.tools import BaseTool, tool
+from base_service import BaseService
+from template._prompts import SYSTEM_PROMPT ## FIX
+from typing import List
+import logging
+import time
+
+logger = logging.getLogger(__name__)
+
+
+class ExamplePLSRenameService(BaseService):
+    @property
+    def system_prompt(self) -> str:
+        return SYSTEM_PROMPT
+    
+    @property
+    def tools(self) -> List[BaseTool]:
+        return self._base_tools + [
+            self.example_func,
+        ]
+
+    @tool
+    def example_func(question: str) -> None:
+        """Пример функции, как её здесь оформлять. Просто для примера, нужно удалить при реальном использовании"""
+        print("Я example_func")
+        time.sleep(4)
+        logger.info("Кто-то забыл удалить example_func!")
+