Протоколы встреч из записей через API

[
  {
    "id": "M09",
    "title": "Созвон отдела продаж",
    "text": "Константин: План на октябрь — 40 сделок. Сейчас 12.\n…"
  }
]

{
  "tasks": [
    {
      "deadline": "2026-10-09",
      "owner": "Юля",
      "task": "Отчитаться по двум сделкам в работе"
    },
    {
      "deadline": "2026-10-05",
      "owner": "Артур",
      "task": "Передать клиенту «Альфа-строй» условия скидки"
    }
  ],
  "open_questions": [
    "Переход на новую CRM (обсуждается, решения пока нет)."
  ]
}

# transcribe.py — расшифровка записей встреч через Polza (папка audio/ → transcripts/)
import os, pathlib
from openai import OpenAI

MODEL = "ai-sage/gigaam-v3"  # русская речь; цена за минуту — в каталоге
ai = OpenAI(base_url="https://polza.ai/api/v1", api_key=os.environ["POLZA_API_KEY"])
out = pathlib.Path("transcripts"); out.mkdir(exist_ok=True)

for f in sorted(pathlib.Path("audio").glob("*")):
    with open(f, "rb") as audio:
        r = ai.audio.transcriptions.create(model=MODEL, file=audio, language="ru")
    (out / (f.stem + ".txt")).write_text(r.text, encoding="utf-8")
    print(f.name, "→", len(r.text), "знаков")

# make_protocol.py — протоколы встреч из расшифровок через Polza
import asyncio, json, os
from openai import AsyncOpenAI, APIStatusError

MODEL = "google/gemini-2.5-flash"  # в тесте нашла все задачи и верно поставила сроки
MEETING_DATE = "понедельник, 5 октября 2026"
CONCURRENCY = 10

ai = AsyncOpenAI(base_url="https://polza.ai/api/v1", api_key=os.environ["POLZA_API_KEY"])
SYSTEM = open("prompt.txt", encoding="utf-8").read()

TASK = {"type": "object", "properties": {"owner": {"type": "string"}, "task": {"type": "string"}, "deadline": {"type": "string"}},
        "required": ["owner", "task", "deadline"], "additionalProperties": False}
SCHEMA = {"name": "protocol", "strict": True, "schema": {"type": "object", "properties": {
    "summary": {"type": "string"},
    "decisions": {"type": "array", "items": {"type": "string"}},
    "tasks": {"type": "array", "items": TASK},
    "open_questions": {"type": "array", "items": {"type": "string"}}},
    "required": ["summary", "decisions", "tasks", "open_questions"], "additionalProperties": False}}

async def protocol(m, sem, stats):
    prompt = (f"Встреча: {m['title']}\nДата встречи: {MEETING_DATE}\n"
              f"Участники: {m.get('participants', 'имена есть в расшифровке')}\n\nРасшифровка:\n{m['text']}")
    async with sem:
        for attempt in range(5):
            try:
                r = await ai.chat.completions.create(
                    model=MODEL,
                    messages=[{"role": "system", "content": SYSTEM}, {"role": "user", "content": prompt}],
                    response_format={"type": "json_schema", "json_schema": SCHEMA},
                    extra_body={"reasoning": {"effort": "none"}},
                )
                break
            except APIStatusError as e:
                if e.status_code in (429, 500, 502, 503) and attempt < 4:
                    await asyncio.sleep(2 ** attempt)
                    continue
                raise
    stats["rub"] += r.usage.model_extra.get("cost_rub", 0)
    return {"id": m["id"], "title": m["title"], **json.loads(r.choices[0].message.content)}

async def main():
    meetings = json.load(open("meetings.json", encoding="utf-8"))
    sem, stats = asyncio.Semaphore(CONCURRENCY), {"rub": 0}
    results = await asyncio.gather(*(protocol(m, sem, stats) for m in meetings), return_exceptions=True)
    with open("protocols.jsonl", "w", encoding="utf-8") as out:
        for m, res in zip(meetings, results):
            if isinstance(res, Exception):
                print(m["id"], "ошибка:", res)
            else:
                out.write(json.dumps(res, ensure_ascii=False) + "\n")
    print(f"Готово, расход {stats['rub']:.2f} ₽")

asyncio.run(main())