ИИ-агент публикует объявления на Авито: 50 карточек за час вместо рабочего дня

import requests
import anthropic
import json
import time
from openpyxl import load_workbook

AVITO_CLIENT_ID     = "YOUR_CLIENT_ID"      # из кабинета developers.avito.ru
AVITO_CLIENT_SECRET = "YOUR_CLIENT_SECRET"
CLAUDE_API_KEY      = "YOUR_CLAUDE_KEY"
USER_ID             = "YOUR_AVITO_USER_ID"   # числовой ID аккаунта

AVITO_TOKEN_URL = "https://api.avito.ru/token"
AVITO_POST_URL  = "https://api.avito.ru/core/v1/items"


def get_avito_token():
  """OAuth2 client_credentials для Авито API."""
  r = requests.post(AVITO_TOKEN_URL, data={
      "grant_type":    "client_credentials",
      "client_id":     AVITO_CLIENT_ID,
      "client_secret": AVITO_CLIENT_SECRET,
  })
  r.raise_for_status()
  return r.json()["access_token"]


def load_catalog(path: str) -> list:
  """Читаем каталог авто из Excel."""
  wb = load_workbook(path)
  ws = wb.active
  headers = [cell.value for cell in ws[1]]
  items = []
  for row in ws.iter_rows(min_row=2, values_only=True):
      item = dict(zip(headers, row))
      if item.get("vin"):   # пропускаем пустые строки
          items.append(item)
  return items


def generate_listing(car: dict, client: anthropic.Anthropic) -> dict:
  """Claude генерирует заголовок и описание для конкретного авто."""
  spec = (
      f"Марка/модель: {car.get('brand')} {car.get('model')}\n"
      f"Год: {car.get('year')}\n"
      f"Пробег: {car.get('mileage_km')} км\n"
      f"КПП: {car.get('transmission')}\n"
      f"Двигатель: {car.get('engine_volume')} л, {car.get('engine_type')}\n"
      f"Цвет: {car.get('color')}\n"
      f"Цена: {car.get('price_rub')} руб.\n"
      f"Владельцев по ПТС: {car.get('owners')}\n"
      f"Особенности: {car.get('features', '')}\n"
      f"VIN: {car.get('vin')}"
  )

  message = client.messages.create(
      model="claude-haiku-4-5",   # haiku дешевле для массовой генерации
      max_tokens=512,
      system=(
          "Ты помогаешь публиковать объявления на Авито. "
          "Пиши заголовки по схеме: [Марка Модель] [Год] [КПП] пробег [N] км [главная деталь]. "
          "Описание — 3-4 абзаца, каждый про свою деталь (техсостояние, комплектация, история владения, условия сделки). "
          "НЕ вставляй телефоны, ссылки, email в текст — Авито блокирует такие объявления. "
          "НЕ используй шаблонные фразы 'в хорошем состоянии', 'торг уместен' без конкретики. "
          "Пиши уникальный текст под каждую машину — алгоритм Авито детектирует копипаст."
      ),
      messages=[{
          "role": "user",
          "content": f"Создай объявление для Авито:\n\n{spec}\n\nФормат ответа — JSON:\n{{\"title\": \"...\", \"description\": \"...\"}}"
      }]
  )

  raw = message.content[0].text.strip()
  # Claude может добавить markdown-обёртку — убираем
  if raw.startswith("```"):
      raw = raw.split("\n", 1)[1].rsplit("```", 1)[0].strip()

  return json.loads(raw)


def publish_to_avito(token: str, car: dict, listing: dict) -> dict:
  """Публикуем объявление через Авито API."""
  payload = {
      "category_id": 9,                       # 9 = Автомобили
      "title":       listing["title"][:50],   # лимит заголовка — 50 символов
      "description": listing["description"],
      "price":       int(car.get("price_rub", 0)),
      "address":     car.get("address", "Москва"),
      "contact": {
          "phone": car.get("dealer_phone"),
      },
      "params": {
          "vin":          car.get("vin"),
          "year":         int(car.get("year", 0)),
          "mileage":      int(car.get("mileage_km", 0)),
          "transmission": car.get("transmission"),
      }
  }

  r = requests.post(
      AVITO_POST_URL,
      headers={"Authorization": f"Bearer {token}"},
      json=payload
  )

  if r.status_code == 429:
      # Rate limit — ждём минуту и повторяем
      print("Rate limit, ждём 60 сек...")
      time.sleep(60)
      r = requests.post(
          AVITO_POST_URL,
          headers={"Authorization": f"Bearer {token}"},
          json=payload
      )

  r.raise_for_status()
  return r.json()


def main():
  print("Загружаем каталог...")
  cars = load_catalog("catalog.xlsx")
  print(f"Найдено {len(cars)} позиций")

  token  = get_avito_token()
  client = anthropic.Anthropic(api_key=CLAUDE_API_KEY)

  published = []
  errors    = []

  for i, car in enumerate(cars):
      print(f"[{i+1}/{len(cars)}] {car.get('brand')} {car.get('model')} {car.get('year')}")

      try:
          listing = generate_listing(car, client)
          result  = publish_to_avito(token, car, listing)
          published.append({"vin": car.get("vin"), "item_id": result.get("id")})
          print(f"  Опубликовано: {listing['title'][:60]}")
      except Exception as e:
          errors.append({"vin": car.get("vin"), "error": str(e)})
          print(f"  Ошибка: {e}")

      # Авито: не больше 20 запросов в минуту — делаем паузу
      time.sleep(3)

  print(f"\nГотово: {len(published)} опубликовано, {len(errors)} ошибок")

  with open("published_ids.json", "w", encoding="utf-8") as f:
      json.dump(published, f, ensure_ascii=False, indent=2)


if __name__ == "__main__":
  main()

import requests
import json
from datetime import datetime

AVITO_CLIENT_ID     = "YOUR_CLIENT_ID"
AVITO_CLIENT_SECRET = "YOUR_CLIENT_SECRET"
TELEGRAM_TOKEN      = "YOUR_BOT_TOKEN"
CHAT_ID             = "YOUR_CHAT_ID"
VIEWS_THRESHOLD     = 5   # если за день меньше N просмотров — алерт

AVITO_TOKEN_URL  = "https://api.avito.ru/token"
AVITO_STATS_URL  = "https://api.avito.ru/core/v1/accounts/{user_id}/stats/summary"


def get_token():
  r = requests.post(AVITO_TOKEN_URL, data={
      "grant_type":    "client_credentials",
      "client_id":     AVITO_CLIENT_ID,
      "client_secret": AVITO_CLIENT_SECRET,
  })
  r.raise_for_status()
  return r.json()["access_token"]


def get_item_stats(token: str, user_id: str, item_ids: list) -> list:
  """Статистика просмотров по списку объявлений."""
  r = requests.post(
      AVITO_STATS_URL.format(user_id=user_id),
      headers={"Authorization": f"Bearer {token}"},
      json={"item_ids": item_ids, "date_from": datetime.now().strftime("%Y-%m-%d")}
  )
  r.raise_for_status()
  return r.json().get("result", {}).get("items", [])


def send_alert(items_to_update: list):
  """Телеграм-алерт: какие объявления нужно обновить."""
  if not items_to_update:
      return

  lines = ["\U0001f4ca <b>Авито: объявления с низкими просмотрами</b>\n"]
  for item in items_to_update:
      lines.append(
          f"• {item['title'][:40]} — {item['views']} просмотров за день"
      )
  lines.append("\n\u2192 Обновите объявление или поднимите в топ")

  requests.post(
      f"https://api.telegram.org/bot{TELEGRAM_TOKEN}/sendMessage",
      json={"chat_id": CHAT_ID, "text": "\n".join(lines), "parse_mode": "HTML"}
  )


def main():
  with open("published_ids.json") as f:
      published = json.load(f)

  item_ids = [p["item_id"] for p in published if p.get("item_id")]

  token = get_token()
  stats = get_item_stats(token, "YOUR_USER_ID", item_ids)

  low_views = [
      item for item in stats
      if item.get("uniq_views", 0) < VIEWS_THRESHOLD
  ]

  send_alert(low_views)
  print(f"Проверено: {len(stats)} объявлений, алертов: {len(low_views)}")


if __name__ == "__main__":
  main()