without k_metrics

SYSTEM_PROMPT.py

@@ -0,0 +1,20 @@
+
+SYSTEM_PROMPT = (
+    "Ты — опытный финансовый аналитик и инвестиционный советник. "
+    "Твоя задача — анализировать ключевые метрики инвестиционных портфелей и давать содержательные, прямолинейные и живые комментарии, которые легко воспринимаются даже непрофессионалами. "
+    "Твоя сила — в способности объяснять сложное просто, без лишней терминологии и формальной канцелярщины.\n\n"
+
+    "Формируй ответы уверенно, избегай сухих, повторяющихся формулировок. Не начинай каждый абзац с 'Это означает...', 'Это говорит о том, что...', 'Это хороший показатель...' — "
+    "такие обороты утомляют и делают речь однообразной. Вариативность важна. Используй живой язык, строй выводы, делай переходы между метриками логично и естественно.\n\n"
+
+    "Если метрика высокая — обозначь, чем это выгодно для инвестора. Если слабая — не скрывай риски и ограничения. Не бойся критиковать стратегию. "
+    "Будь честным, как на встрече с клиентом: без лишнего позитивного окраса, только по делу. Допускается лёгкая ирония, если она помогает донести суть.\n\n"
+
+    "Ты можешь делать предположения и гипотезы: например, как стратегия поведёт себя в растущем рынке, при кризисе, при высокой инфляции или волатильности. "
+    "Портфель может быть описан как 'агрессивный', 'консервативный', 'высокочастотный', 'рискованный', 'подходит для пассивного дохода' и т.д. — не бойся давать такие оценки.\n\n"
+
+    "Пиши как будто общаешься напрямую с человеком, который хочет понять: стоит ли ему доверять деньги этой стратегии. В конце — можешь кратко подытожить общую картину и настроение по портфелю.\n\n"
+
+    "Всё это должно выглядеть как профессиональный, но понятный разговор — не как слайд с конференции. В очередном описании ключевой метрики, старайся применять иные формулировки, нежели те, которые применял для описания предыдущей."
+    "При сравнении двух портфелей, СТРОГО используй 'портфель А' и портфель B', выделяй сильные и слабые стороны каждого, делай акцент на различиях и потенциальных рисках."
+)

analyzer.py

@@ -1,32 +1,48 @@
-#Извлечение UUID из строки
-def extract_portfolio_id(text: str) -> str | None:
-    match = re.search(
-        r"[0-9a-fA-F]{8}-[0-9a-fA-F]{4}-[0-9a-fA-F]{4}-[0-9a-fA-F]{4}-[0-9a-fA-F]{12}",
-        text
-    )
-    return match.group(0) if match else None
+import SYSTEM_PROMPT
+# Анализ одного портфеля
+def analyze_portfolio_streaming(text: str):
+    portfolio_id = extract_portfolio_id(text)
+    if not portfolio_id:
+        yield "❗ Укажите корректный portfolioId или ссылку."
+        return
 
-def fetch_metrics(portfolio_id: str) -> dict | None:
     try:
+        # Получение JSON по API
         url = f"https://api.tradelink.pro/portfolio/get?portfolioId={portfolio_id}&extended=1&declaration=1&step=day&lang=en&incViews=1"
         response = requests.get(url)
-        response.raise_for_status()
-        extended = response.json().get("data", {}).get("extended", {})
-        keys = [
-            # 🔹 Доходность и риск
-            "alphaRatio", "betaRatio", "cagr", "sharpe", "sortino", "volatility",
-            "kSortino", "kCalmar", "kSharpe",
+        json_data = response.json()
+        extended = json_data.get("data", {}).get("extended", {})
 
-            # 🔹 Просадки
-            "maxDD", "mddDuration", "maxBalance",
+        if not extended:
+            yield "❗ Метрики не найдены в ответе API."
+            return
 
-            # 🔹 Поведение стратегии
-            "losingDays", "winningDays", "selfProfitRate",
+        # Передаём все числовые метрики, без фильтрации
+        metrics = {k: v for k, v in extended.items() if isinstance(v, (int, float))}
+        if not metrics:
+            yield "❗ Нет числовых метрик для анализа."
+            return
 
-            # 🔹 Актуальные показатели доходности
-            "lastWeekNetProfit", "lastMonthNetProfit", "lastQuarterGrowth", "lastYearNetGrowth"
-        ]
+        metrics_text = ", ".join([f"{k}: {v}" for k, v in metrics.items()])
+        prompt = f"""Вот метрики портфеля: {metrics_text}. 
+Проанализируй их и объясни сильные и слабые стороны на русском языке, как финансовый аналитик."""
 
-        return {k: extended[k] for k in keys if isinstance(extended.get(k), (int, float))}
-    except:
-        return None
+        # Запрос к модели
+        response_llm = client.chat.completions.create(
+            model="nasiruddin15/Mistral-dolphin-2.8-grok-instract-2-7B-slerp",
+            messages=[
+                {"role": "system", "content": SYSTEM_PROMPT},
+                {"role": "user", "content": prompt}
+            ],
+            stream=True
+        )
+
+        partial = ""
+        for chunk in response_llm:
+            delta = chunk.choices[0].delta.content
+            if delta:
+                partial += delta
+                yield partial
+
+    except Exception as e:
+        yield f"❌ Ошибка при обработке: {e}"

app.py

@@ -2,8 +2,8 @@ import gradio as gr
 import requests
 import re
 import os
-from analyzer import fetch_metrics
-# from analyzer import extract_portfolio_id
+from analyzer import analyze_portfolio_streaming
+from fetch import fetch_metrics
 from openai import OpenAI
 
 api_key = os.getenv("featherless")  #
@@ -105,7 +105,7 @@ def extract_portfolio_id(text: str) -> str | None:
 #     response_llm = client.chat.completions.create(
 #         model="meta-llama/Meta-Llama-3.1-8B-Instruct",
 #         messages=[
-#             {"role": "system", "content": SYSTEM_PROMPT},
+#             {"role": "system", "content": SYSTEM_PROMPT.py},
 #             {"role": "user", "content": prompt}
 #         ],
 #         stream=True
@@ -120,52 +120,52 @@ def extract_portfolio_id(text: str) -> str | None:
 #             yield partial
 
 # Анализ одного портфеля
-def analyze_portfolio_streaming(text: str):
-    portfolio_id = extract_portfolio_id(text)
-    if not portfolio_id:
-        yield "❗ Укажите корректный portfolioId или ссылку."
-        return
-
-    try:
-        # Получение JSON по API
-        url = f"https://api.tradelink.pro/portfolio/get?portfolioId={portfolio_id}&extended=1&declaration=1&step=day&lang=en&incViews=1"
-        response = requests.get(url)
-        json_data = response.json()
-        extended = json_data.get("data", {}).get("extended", {})
-
-        if not extended:
-            yield "❗ Метрики не найдены в ответе API."
-            return
-
-        # Передаём все числовые метрики, без фильтрации
-        metrics = {k: v for k, v in extended.items() if isinstance(v, (int, float))}
-        if not metrics:
-            yield "❗ Нет числовых метрик для анализа."
-            return
-
-        metrics_text = ", ".join([f"{k}: {v}" for k, v in metrics.items()])
-        prompt = f"""Вот метрики портфеля: {metrics_text}. 
-Проанализируй их и объясни сильные и слабые стороны на русском языке, как финансовый аналитик."""
-
-        # Запрос к модели
-        response_llm = client.chat.completions.create(
-            model="nasiruddin15/Mistral-dolphin-2.8-grok-instract-2-7B-slerp",
-            messages=[
-                {"role": "system", "content": SYSTEM_PROMPT},
-                {"role": "user", "content": prompt}
-            ],
-            stream=True
-        )
-
-        partial = ""
-        for chunk in response_llm:
-            delta = chunk.choices[0].delta.content
-            if delta:
-                partial += delta
-                yield partial
-
-    except Exception as e:
-        yield f"❌ Ошибка при обработке: {e}"
+# def analyze_portfolio_streaming(text: str):
+#     portfolio_id = extract_portfolio_id(text)
+#     if not portfolio_id:
+#         yield "❗ Укажите корректный portfolioId или ссылку."
+#         return
+#
+#     try:
+#         # Получение JSON по API
+#         url = f"https://api.tradelink.pro/portfolio/get?portfolioId={portfolio_id}&extended=1&declaration=1&step=day&lang=en&incViews=1"
+#         response = requests.get(url)
+#         json_data = response.json()
+#         extended = json_data.get("data", {}).get("extended", {})
+#
+#         if not extended:
+#             yield "❗ Метрики не найдены в ответе API."
+#             return
+#
+#         # Передаём все числовые метрики, без фильтрации
+#         metrics = {k: v for k, v in extended.items() if isinstance(v, (int, float))}
+#         if not metrics:
+#             yield "❗ Нет числовых метрик для анализа."
+#             return
+#
+#         metrics_text = ", ".join([f"{k}: {v}" for k, v in metrics.items()])
+#         prompt = f"""Вот метрики портфеля: {metrics_text}.
+# Проанализируй их и объясни сильные и слабые стороны на русском языке, как финансовый аналитик."""
+#
+#         # Запрос к модели
+#         response_llm = client.chat.completions.create(
+#             model="nasiruddin15/Mistral-dolphin-2.8-grok-instract-2-7B-slerp",
+#             messages=[
+#                 {"role": "system", "content": SYSTEM_PROMPT},
+#                 {"role": "user", "content": prompt}
+#             ],
+#             stream=True
+#         )
+#
+#         partial = ""
+#         for chunk in response_llm:
+#             delta = chunk.choices[0].delta.content
+#             if delta:
+#                 partial += delta
+#                 yield partial
+#
+#     except Exception as e:
+#         yield f"❌ Ошибка при обработке: {e}"
 
 
 # Сравнение двух портфелей

fetch.py

@@ -0,0 +1,33 @@
+#Извлечение UUID из строки
+def extract_portfolio_id(text: str) -> str | None:
+    match = re.search(
+        r"[0-9a-fA-F]{8}-[0-9a-fA-F]{4}-[0-9a-fA-F]{4}-[0-9a-fA-F]{4}-[0-9a-fA-F]{12}",
+        text
+    )
+    return match.group(0) if match else None
+
+def fetch_metrics(portfolio_id: str) -> dict | None:
+    try:
+        url = f"https://api.tradelink.pro/portfolio/get?portfolioId={portfolio_id}&extended=1&declaration=1&step=day&lang=en&incViews=1"
+        response = requests.get(url)
+        response.raise_for_status()
+        extended = response.json().get("data", {}).get("extended", {})
+        keys = [
+            # 🔹 Доходность и риск
+            "alphaRatio", "betaRatio", "cagr", "sharpe", "sortino", "volatility",
+            "kSortino", "kCalmar", "kSharpe",
+
+            # 🔹 Просадки
+            "maxDD", "mddDuration", "maxBalance",
+
+            # 🔹 Поведение стратегии
+            "losingDays", "winningDays", "selfProfitRate",
+
+            # 🔹 Актуальные показатели доходности
+            "lastWeekNetProfit", "lastMonthNetProfit", "lastQuarterGrowth", "lastYearNetGrowth"
+        ]
+
+        return {k: extended[k] for k in keys if isinstance(extended.get(k), (int, float))}
+    except:
+        return None
+