MPStats API — каталог под поиск новинок

РАЗВЕДКА     POST /wb/get/category  → 100–500 артикулов по категории + бюджет
   ↓
ОБОГАЩЕНИЕ   GET /wb/get/item/{sku}/sales    (по топ-30)
             GET /wb/get/item/{sku}/by_keywords  (по топ-10)
   ↓
ФИЛЬТР       возраст ≤ 180 дн + отзывов ≤ 100 + тренд не падает
   ↓
РАНЖИР       потенциал (revenue + lost_profit) / (capital_needed)
   ↓
ОТЧЁТ        csv с топ-10 → человек финально оценивает в интерфейсе

# scripts/mpstats_new_products.py — заглушка под фазу 2 «Рынок»
# Запускать когда будет подписка Advanced Jam и токен.

import os
from datetime import date, timedelta
import httpx

TOKEN = os.getenv("MPSTATS_TOKEN")  # токен появится с подпиской
BASE = "https://mpstats.io/api"
HEADERS = {"X-Mpstats-TOKEN": TOKEN} if TOKEN else {}


def discover_new_products(
    path: str,             # напр. "Дом/Инструменты/Ручной инструмент"
    budget_rub: int,       # напр. 150_000
    days_back: int = 60,   # окно анализа продаж
    max_reviews: int = 100,
    max_age_days: int = 180,
) -> list[dict]:
    """Фаза 2 «Рынок» — разведка кандидатов."""
    d2 = date.today()
    d1 = d2 - timedelta(days=days_back)
    cutoff = d2 - timedelta(days=max_age_days)

    body = {
        "path": path,
        "d1": d1.isoformat(),
        "d2": d2.isoformat(),
        "startRow": 0,
        "endRow": 500,
        "sortModel": [{"colId": "revenue", "sort": "desc"}],
        "filterModel": {
            "revenue": {
                "type": "inRange",
                "filter": int(budget_rub * 0.67),
                "filterTo": int(budget_rub * 2),
            },
            "firstAppearOn": {"type": "greaterThan", "filter": cutoff.isoformat()},
            "comments": {"type": "lessThanOrEqual", "filter": max_reviews},
        },
    }

    r = httpx.post(f"{BASE}/wb/get/category", headers=HEADERS, json=body, timeout=30)
    r.raise_for_status()
    return r.json().get("data", [])


def check_trend_not_falling(path: str, months: int = 6) -> bool:
    """Контрольная точка: тренд ниши не падает за последние 6 мес."""
    d2 = date.today()
    d1 = d2 - timedelta(days=30 * months)
    body = {"path": path, "d1": d1.isoformat(), "d2": d2.isoformat()}
    r = httpx.post(f"{BASE}/wb/get/category/trend", headers=HEADERS, json=body, timeout=30)
    r.raise_for_status()
    monthly = r.json().get("revenue_by_month", [])
    if len(monthly) < 3:
        return True
    first_third = sum(monthly[:2]) / 2
    last_third = sum(monthly[-2:]) / 2
    return last_third >= first_third * 0.9  # падение не больше 10%


def rank_by_potential(items: list[dict]) -> list[dict]:
    """Сортировка по суммарному потенциалу = выручка + упущенная."""
    for item in items:
        item["potential"] = (item.get("revenue") or 0) + (item.get("lost_profit") or 0)
    return sorted(items, key=lambda x: x["potential"], reverse=True)


if __name__ == "__main__":
    if not TOKEN:
        raise SystemExit("MPSTATS_TOKEN не задан — дождёмся подписки Advanced Jam")
    candidates = discover_new_products(
        path="Дом/Инструменты/Ручной инструмент",
        budget_rub=150_000,
    )
    ranked = rank_by_potential(candidates)[:10]
    for i, x in enumerate(ranked, 1):
        print(f"{i}. {x['name'][:50]:50} | {x['revenue']:>8} ₽ | отз {x['comments']}")