supersam/scripts/sms_first_campaign.py

#!/usr/bin/env python3
"""
SuperSam — SMS First Campaign (State Machine)
Заменяет n8n workflow "Первая отправка согласования"

Архитектура: state machine через cron (каждые 5 мин)
Каждый запуск:
  1. Отправляет SMS новым группам (ready_to_launch + pending_confirmation + нет недавней SMS)
  2. Проверяет статус ранее отправленных SMS (sent но не delivered, в пределах max_check_duration)
  3. Обновляет статусы в order_groups + sms_campaign_log

Защита от повторной отправки (ДВОЙНАЯ):
  1. После отправки SMS → notification_status = 'sms_sending' (не 'link_ready')
     → get_groups_to_send НЕ находит эту группу (фильтр по notification_status = 'link_ready')
  2. Дополнительно: EXISTS проверка в sms_campaign_log (status sent/checking за последние 24h)
  3. Код 231/132 = лимит одинаковых → не повторять

needs_check=true — admin нажал "Проверить снова" в UI
  → скрипт проверяет даже если запись старше max_check_duration

Коды sms.ru:
  100 = в очереди, 101 = оператору, 102 = в пути → ждём
  103 = доставлено → цель
  104-108, 130-132, 230-232 = ошибки доставки / лимиты
"""

import os
import sys
import json
import logging
from datetime import datetime, timezone, timedelta

import requests
import psycopg2
from psycopg2.extras import RealDictCursor

# ─── Конфигурация ────────────────────────────────────────────────────────────

DB_HOST = os.environ.get("DB_HOST", "10.0.4.12")
DB_PORT = os.environ.get("DB_PORT", "5432")
DB_NAME = os.environ.get("DB_NAME", "postgres")
DB_USER = os.environ.get("DB_USER", "supabase_admin")
DB_PASS = os.environ.get("DB_PASS", "4fe80bb21c7c3d17a8d8b226adf7a479")

TELEGRAM_BOT_TOKEN = os.environ.get("TELEGRAM_BOT_TOKEN", "")
TELEGRAM_CHAT_ID = os.environ.get("TELEGRAM_CHAT_ID", "25164483")

SMS_API_ID = os.environ.get("SMS_API_ID", "C92063B3-95ED-8559-157B-1946EB5A2486")
SMS_SEND_URL = "https://sms.ru/sms/send"
SMS_STATUS_URL = "https://sms.ru/sms/status"

LOG_FILE = "/var/log/supersam-sms-first.log"

# ТЕСТОВЫЙ РЕЖИМ — управляется из админки (sms_campaign_settings.test_mode)
# По умолчанию ВКЛЮЧЕН — SMS идут только на test_phone
# Мегаадмин выключает через админку → SMS идут реальным клиентам

# Коды, которые означают "в процессе" (ждём дальше)
IN_TRANSIT_CODES = {"100", "101", "102"}
# Код доставки
DELIVERED_CODE = "103"
# Коды ошибок доставки (не временные, можно повторять отправку)
DELIVERY_ERROR_CODES = {"104", "105", "106", "107", "108", "130"}
# Коды превышения лимитов (нельзя повторять отправку — заблокируют)
LIMIT_ERROR_CODES = {"131", "132", "230", "231", "232"}

# ─── Тексты SMS ──────────────────────────────────────────────────────────────
# Шаблоны живут в админке (sms_campaign_settings):
#   sms_text_template         — текст для ДОСТАВКИ
#   sms_text_template_pickup  — текст для САМОВЫВОЗА
# {link} подставляется ссылкой согласования. Пустой шаблон → DEFAULT_TEXT_*.

DEFAULT_TEXT_DELIVERY = "Ваш заказ готов. Согласуйте дату доставки по ссылке: {link}"
DEFAULT_TEXT_PICKUP = "Ваш заказ готов. Согласуйте дату самовывоза по ссылке: {link}"
DEFAULT_TEXT_NOTIFICATION = "Ваш заказ готов."


def is_pickup_group(group):
    return (group.get("delivery_type") or "delivery").strip().lower() == "pickup"


def build_sms_text(group, settings):
    """Текст SMS по типу отгрузки: самовывоз → pickup-шаблон, доставка → обычный.

    Приоритет:
      1. текст профиля города (режим «Уведомление», sms_city_profiles) — как было;
      2. шаблон кампании из админки для этого типа отгрузки;
      3. дефолт по типу отгрузки.
    """
    link = group.get("delivery_link") or ""
    mode = (group.get("sms_mode") or "link").strip().lower()
    profile_text = (group.get("sms_text_custom") or "").strip()
    pickup = is_pickup_group(group)
    template = (settings.get(
        "sms_text_template_pickup" if pickup else "sms_text_template"
    ) or "").strip()
    if not template:
        template = DEFAULT_TEXT_PICKUP if pickup else DEFAULT_TEXT_DELIVERY

    if mode == "notification":
        if profile_text:
            return profile_text
        # уведомление без ссылки: шаблон годится, только если в нём нет {link}
        if template and "{link}" not in template:
            return template
        return DEFAULT_TEXT_NOTIFICATION

    return template.replace("{link}", link).strip()

# ─── Логирование ─────────────────────────────────────────────────────────────

logging.basicConfig(
    level=logging.INFO,
    format="%(asctime)s [%(levelname)s] %(message)s",
    handlers=[
        logging.FileHandler(LOG_FILE),
        logging.StreamHandler(sys.stdout),
    ],
)
log = logging.getLogger("sms_first")

# ─── БД ──────────────────────────────────────────────────────────────────────

def get_db_conn():
    return psycopg2.connect(
        host=DB_HOST, port=DB_PORT, dbname=DB_NAME,
        user=DB_USER, password=DB_PASS,
    )

def load_settings(conn):
    with conn.cursor(cursor_factory=RealDictCursor) as cur:
        cur.execute("SELECT * FROM sms_campaign_settings WHERE campaign_type = 'first_sms'")
        row = cur.fetchone()
        if not row:
            return {
                "wait_between_checks_seconds": 25,
                "max_check_duration_minutes": 90,
                "max_attempts": 2,
                "enabled": True,
                "telegram_chat_id": "25164483",
                "sms_api_id": SMS_API_ID,
                "test_mode": True,
                "test_phone": "79788382260",
            }
        return dict(row)

# ─── SMS API ─────────────────────────────────────────────────────────────────

def normalize_phone(phone):
    """Нормализует телефон: только цифры, начинается с 7"""
    clean = "".join(c for c in str(phone) if c.isdigit())
    if clean.startswith("8"):
        clean = "7" + clean[1:]
    elif not clean.startswith("7"):
        clean = "7" + clean
    return clean

def send_sms(phone, message, api_id):
    """Отправляет SMS, возвращает (sms_id, raw_response)"""
    try:
        clean_phone = normalize_phone(phone)
        resp = requests.post(SMS_SEND_URL, params={
            "api_id": api_id,
            "to": clean_phone,
        }, data={"msg": message}, timeout=30)
        text = resp.text
        log.info(f"SMS send to {clean_phone}: {text[:200]}")
        
        lines = text.strip().split("\n")
        status_code = lines[0].strip() if lines else ""
        
        if status_code == "100" and len(lines) >= 2:
            sms_id = lines[1].strip()
            return sms_id, text, "100"
        else:
            return None, text, status_code
    except Exception as e:
        log.error(f"SMS send error: {e}")
        return None, str(e), "error"

def check_sms_status(sms_id, api_id):
    """Проверяет статус, возвращает (code, raw_response)"""
    try:
        resp = requests.post(SMS_STATUS_URL, params={
            "api_id": api_id,
            "sms_id": sms_id,
        }, timeout=30)
        text = resp.text
        lines = text.strip().split("\n")
        status_code = lines[0].strip() if lines else ""
        sms_status_code = lines[1].strip() if len(lines) >= 2 else None
        
        log.info(f"SMS status for {sms_id}: code={status_code}, sms_status={sms_status_code}")
        return sms_status_code, text, status_code
    except Exception as e:
        log.error(f"SMS status check error: {e}")
        return None, str(e), "error"

# ─── Telegram ────────────────────────────────────────────────────────────────

def send_telegram(message, chat_id):
    if not TELEGRAM_BOT_TOKEN:
        log.warning("TELEGRAM_BOT_TOKEN not set, skipping Telegram")
        return
    try:
        resp = requests.post(
            f"https://api.telegram.org/bot{TELEGRAM_BOT_TOKEN}/sendMessage",
            json={"chat_id": chat_id, "text": message, "parse_mode": "HTML"},
            timeout=10,
        )
        if resp.status_code != 200:
            log.warning(f"Telegram error: {resp.text[:200]}")
    except Exception as e:
        log.warning(f"Telegram failed: {e}")

# ─── State Machine ───────────────────────────────────────────────────────────

def get_groups_to_send(conn, max_attempts):
    """Группы, которым ещё не отправили SMS.
    
    Режимы (из sms_city_profiles):
    - link: отправка ссылки на согласование (старый флоу)
    - notification: уведомление без ссылки (для доставки/самовывоза без согласования)
    """
    with conn.cursor(cursor_factory=RealDictCursor) as cur:
        cur.execute("""
            SELECT og.id, og.group_key, og.customer_name, og.customer_phone,
                   og.customer_phone_normalized, og.delivery_link, og.notification_status,
                   og.delivery_type, og.town, og.sms_attempts,
                   -- Профиль города (fallback на дефолтные значения если нет записи)
                   COALESCE(scp.delivery_mode, 'link') as delivery_mode,
                   COALESCE(scp.delivery_text, '') as delivery_text,
                   COALESCE(scp.pickup_mode, 'link') as pickup_mode,
                   COALESCE(scp.pickup_text, '') as pickup_text,
                   COALESCE(scp.sms_enabled, true) as sms_enabled,
                   -- Выбор режима и текста по типу доставки
                   CASE
                     WHEN og.delivery_type = 'pickup'
                       THEN COALESCE(scp.pickup_mode, 'link')
                     ELSE
                       COALESCE(scp.delivery_mode, 'link')
                   END as sms_mode,
                   CASE
                     WHEN og.delivery_type = 'pickup'
                       THEN COALESCE(scp.pickup_text, '')
                     ELSE
                       COALESCE(scp.delivery_text, '')
                   END as sms_text_custom
            FROM order_groups og
            LEFT JOIN sms_city_profiles scp ON scp.city = og.town
            WHERE og.status = 'ready_to_launch'
              AND og.delivery_status = 'pending_confirmation'
              AND COALESCE(og.notification_status, '') = 'link_ready'
              -- Профиль sms_enabled (замена старого sms_allowed_for_city)
              AND COALESCE(scp.sms_enabled, true) = true
              -- Гео-исключения — общие для SMS и звонков: правило города
              -- (campaign_type '*' — все каналы) блокирует и отправку SMS.
              AND NOT EXISTS (
                SELECT 1 FROM sms_city_rules r
                WHERE r.city = og.town
                  AND r.enabled = false
                  AND r.campaign_type IN ('*', 'first_sms')
                  AND (r.valid_from IS NULL OR r.valid_from <= CURRENT_DATE)
                  AND (r.valid_until IS NULL OR r.valid_until >= CURRENT_DATE)
              )
              -- Нет активной SMS в логе (sent/checking) за последние 2 часа
              AND NOT EXISTS (
                SELECT 1 FROM sms_campaign_log scl
                WHERE scl.order_group_id = og.id
                  AND scl.campaign_type = 'first_sms'
                  AND scl.status IN ('sent', 'checking')
                  AND scl.created_at > NOW() - INTERVAL '2 hours'
              )
              -- Лимит попыток: считаем ВСЕ строки кампании по группе, а не строку,
              -- которую проверяем (иначе счётчик всегда 1 и повторы бесконечны)
              AND (
                SELECT count(*) FROM sms_campaign_log scl2
                WHERE scl2.order_group_id = og.id
                  AND scl2.campaign_type = 'first_sms'
              ) < %s
            ORDER BY og.created_at ASC
        """, (max_attempts,))
        return [dict(r) for r in cur.fetchall()]

def get_sms_to_check(conn, max_duration_min):
    """SMS в логе со status='sent'/'checking', которые ещё не доставлены.
    Включает:
    - Записи младше max_duration_min (обычная автопроверка)
    - Записи с needs_check=true (admin нажал 'Проверить снова') — независимо от возраста
    """
    with conn.cursor(cursor_factory=RealDictCursor) as cur:
        cur.execute("""
            SELECT scl.id as log_id, scl.sms_id, scl.order_group_id, scl.customer_phone,
                   scl.attempts, scl.created_at, scl.sms_code, scl.needs_check,
                   og.customer_name, og.group_key
            FROM sms_campaign_log scl
            JOIN order_groups og ON og.id = scl.order_group_id
            WHERE scl.campaign_type = 'first_sms'
              AND scl.status IN ('sent', 'checking')
              AND scl.sms_id IS NOT NULL
              AND (
                scl.created_at > NOW() - INTERVAL '%s minutes'
                OR scl.needs_check = true
              )
            ORDER BY scl.needs_check DESC, scl.created_at ASC
        """ % max_duration_min)
        return [dict(r) for r in cur.fetchall()]

def get_sms_expired(conn, max_duration_min):
    """SMS, у которых истёк срок проверки (старше max_check_duration, не доставлены)"""
    with conn.cursor(cursor_factory=RealDictCursor) as cur:
        cur.execute("""
            SELECT scl.id as log_id, scl.sms_id, scl.order_group_id, scl.customer_phone,
                   scl.attempts, scl.created_at,
                   og.customer_name, og.group_key, og.delivery_link
            FROM sms_campaign_log scl
            JOIN order_groups og ON og.id = scl.order_group_id
            WHERE scl.campaign_type = 'first_sms'
              AND scl.status IN ('sent', 'checking')
              AND scl.sms_id IS NOT NULL
              AND scl.created_at < NOW() - INTERVAL '%s minutes'
            ORDER BY scl.created_at ASC
        """ % max_duration_min)
        return [dict(r) for r in cur.fetchall()]

def insert_sms_log(conn, **kwargs):
    with conn.cursor() as cur:
        cols = ", ".join(kwargs.keys())
        placeholders = ", ".join(["%s"] * len(kwargs))
        cur.execute(f"INSERT INTO sms_campaign_log ({cols}) VALUES ({placeholders}) RETURNING id", list(kwargs.values()))
        log_id = cur.fetchone()[0]
    conn.commit()
    return log_id

def update_sms_log(conn, log_id, **kwargs):
    with conn.cursor() as cur:
        set_parts = []
        values = []
        for k, v in kwargs.items():
            if v == "NOW()":
                set_parts.append(f"{k} = NOW()")
            else:
                set_parts.append(f"{k} = %s")
                values.append(v)
        values.append(log_id)
        cur.execute(f"UPDATE sms_campaign_log SET {', '.join(set_parts)}, updated_at = NOW() WHERE id = %s", values)
    conn.commit()

def update_order_group(conn, group_id, fields):
    with conn.cursor() as cur:
        set_parts = []
        values = []
        for k, v in fields.items():
            if v == "NOW()":
                set_parts.append(f"{k} = NOW()")
            else:
                set_parts.append(f"{k} = %s")
                values.append(v)
        values.append(group_id)
        cur.execute(f"UPDATE order_groups SET {', '.join(set_parts)} WHERE id = %s", values)
    conn.commit()

def count_sms_attempts(conn, group_id, campaign_type="first_sms"):
    """Сколько раз эту SMS уже пытались отправить (строк в логе этой кампании).

    Номер попытки — свойство ГРУППЫ, а не строки лога: каждая попытка создаёт
    новую строку, поэтому в самой строке всегда было бы attempts=1, условие
    «attempts < max_attempts» выполнялось бы вечно и кампания слала бы SMS
    каждые 5 минут бесконечно (проверено на заказе ТП-010543: 457 отправок за
    3,5 суток, ни одна не доставлена, в ручную работу заказ не ушёл).
    """
    with conn.cursor() as cur:
        cur.execute("""
            SELECT COUNT(*) FROM sms_campaign_log
            WHERE order_group_id = %s AND campaign_type = %s
        """, (group_id, campaign_type))
        return cur.fetchone()[0]

# ─── Основная логика ─────────────────────────────────────────────────────────

def step_send_new(conn, settings):
    """Шаг 1: Отправка SMS новым группам"""
    api_id = settings.get("sms_api_id", SMS_API_ID)
    tg_chat = settings.get("telegram_chat_id", TELEGRAM_CHAT_ID)
    max_attempts = settings.get("max_attempts", 2)
    second_sms_delay = settings.get("second_sms_delay_hours", 3)
    
    groups = get_groups_to_send(conn, max_attempts)
    log.info(f"Step 1: {len(groups)} groups to send SMS")
    
    sent_count = 0
    for group in groups:
        group_id = str(group["id"])
        name = group.get("customer_name") or group.get("group_key", "—")
        phone = group.get("customer_phone_normalized") or group.get("customer_phone", "")
        delivery_link = group.get("delivery_link", "")
        delivery_type = group.get("delivery_type") or "delivery"
        town = group.get("town") or "—"
        sms_mode = group.get("sms_mode") or "link"
        custom_text = group.get("sms_text_custom") or ""
        
        # Проверяем: была ли уже SMS этой группе сегодня (защита от повторной отправки)
        with conn.cursor() as cur:
            cur.execute("""
                SELECT COUNT(*) as cnt FROM sms_campaign_log
                WHERE order_group_id = %s AND campaign_type = 'first_sms'
                  AND created_at > NOW() - INTERVAL '24 hours'
                  AND status IN ('sent', 'checking', 'delivered')
            """, (group_id,))
            recent_count = cur.fetchone()[0]
        if recent_count > 0:
            log.info(f"Group {group_id}: already has recent SMS in log, skipping")
            continue
        
        # Формируем текст SMS по типу отгрузки (доставка / самовывоз) и режиму
        sms_text = build_sms_text(group, settings)
        if sms_mode == "notification":
            log.info(f"Group {group_id}: NOTIFICATION mode (town={town}, type={delivery_type}): {sms_text!r}")
        else:
            log.info(f"Group {group_id}: LINK mode (town={town}, type={delivery_type}): {sms_text!r}")
        
        # ТЕСТОВЫЙ РЕЖИМ: подменяем номер на тестовый
        send_phone = phone
        if settings.get("test_mode", True):
            send_phone = settings.get("test_phone", "79788382260")
            log.info(f"TEST MODE: sending to {send_phone} instead of {phone}")
        
        log.info(f"Sending SMS to {name} (orig={phone}, send={send_phone})")
        attempt_no = count_sms_attempts(conn, group_id) + 1
        log.info(f"Group {group_id}: attempt {attempt_no}/{max_attempts}")
        sms_id, raw, code = send_sms(send_phone, sms_text, api_id)
        
        if sms_id:
            log_id = insert_sms_log(conn,
                campaign_type="first_sms",
                order_group_id=group_id,
                customer_phone=phone,
                sms_id=sms_id,
                sms_text=sms_text,
                status="sent",
                sms_code=code,
                attempts=attempt_no,
            )
            # ДВОЙНАЯ ЗАЩИТА: сразу меняем notification_status
            if sms_mode == "notification":
                # Notification: нет 2-й SMS, сразу first_sms_sent
                update_order_group(conn, group_id, {
                    "notification_status": "first_sms_sent",
                    "sms_sent_at": "NOW()",
                    "first_sms_sent_at": "NOW()",
                    "status": "first_sms_sent",
                    "sms_attempts": attempt_no,
                })
                log.info(f"Group {group_id}: NOTIFICATION SMS sent, status→first_sms_sent (no second SMS)")
            else:
                # Link: ждём доставки SMS, потом 2-я SMS
                update_order_group(conn, group_id, {
                    "notification_status": "sms_sending",
                    "sms_sent_at": "NOW()",
                    "sms_attempts": attempt_no,
                })
                log.info(f"Group {group_id}: LINK SMS sent, status→sms_sending")
            sent_count += 1
        else:
            # Ошибка отправки
            error = raw[:500] if raw else "Unknown error"
            log_id = insert_sms_log(conn,
                campaign_type="first_sms",
                order_group_id=group_id,
                customer_phone=phone,
                sms_text=sms_text,
                status="send_failed",
                sms_code=code,
                attempts=attempt_no,
                error_message=error,
            )
            log.error(f"Group {group_id}: SMS send failed (code={code}): {error[:200]}")
            
            update_order_group(conn, group_id, {
                "notification_status": "send_failed",
                "last_sms_error": error[:200],
                "sms_attempts": attempt_no,
            })
            send_telegram(f"❌ SMS не отправлена: {name} ({phone})\nКод: {code}\nОшибка: {error[:200]}", tg_chat)
    
    return sent_count

def step_check_status(conn, settings):
    """Шаг 2: Проверка статуса ранее отправленных SMS"""
    api_id = settings.get("sms_api_id", SMS_API_ID)
    tg_chat = settings.get("telegram_chat_id", TELEGRAM_CHAT_ID)
    max_duration = settings.get("max_check_duration_minutes", 90)
    max_attempts = settings.get("max_attempts", 2)
    second_sms_delay = settings.get("second_sms_delay_hours", 3)
    
    sms_list = get_sms_to_check(conn, max_duration)
    log.info(f"Step 2: {len(sms_list)} SMS to check status")
    
    delivered = 0
    for item in sms_list:
        log_id = item["log_id"]
        sms_id = item["sms_id"]
        group_id = str(item["order_group_id"])
        name = item.get("customer_name") or item.get("group_key", "—")
        phone = item.get("customer_phone", "")
        attempts = item.get("attempts") or 1
        was_needs_check = item.get("needs_check", False)
        
        code, raw, api_code = check_sms_status(sms_id, api_id)
        
        # Сбрасываем needs_check + ставим checked_at
        update_sms_log(conn, log_id, needs_check=False, checked_at="NOW()")
        
        if code == DELIVERED_CODE:
            # Доставлено!
            log.info(f"Group {group_id}: SMS delivered (103)!")
            update_sms_log(conn, log_id, status="delivered", sms_code=code)
            
            next_check = (datetime.now(timezone.utc) + timedelta(hours=second_sms_delay)).isoformat()
            update_order_group(conn, group_id, {
                "notification_status": "first_sms_sent",
                "sms_attempts": attempts,
                "first_sms_sent_at": "NOW()",
                "last_sms_error": None,
                "sms_sent_at": "NOW()",
                "next_notification_check_at": next_check,
                "status": "first_sms_sent",
            })
            send_telegram(f"✅ SMS доставлена: {name} ({phone})", tg_chat)
            delivered += 1
            
        elif code in IN_TRANSIT_CODES:
            # В пути / в очереди — продолжаем ждать
            log.info(f"Group {group_id}: SMS in transit (code={code}), will check again next run")
            update_sms_log(conn, log_id, status="checking", sms_code=code)
            
        elif code in DELIVERY_ERROR_CODES:
            # Ошибка доставки — можно повторить отправку
            log.error(f"Group {group_id}: SMS delivery error (code={code})")
            update_sms_log(conn, log_id, status="error", sms_code=code, 
                          error_message=f"Delivery error: {code}")
            # Переход к следующей попытке отправки (если есть)
            if attempts < max_attempts:
                log.info(f"Group {group_id}: will retry send on next run (attempt {attempts+1}/{max_attempts})")
                update_sms_log(conn, log_id, status="expired")
                # Сбрасываем notification_status → link_ready для повторной отправки
                update_order_group(conn, group_id, {
                    "notification_status": "link_ready",
                })
            else:
                update_order_group(conn, group_id, {
                    "notification_status": "manual_required",
                    "last_sms_error": f"SMS не доставлена после {max_attempts} попыток (код {code})",
                })
                log.error(f"Group {group_id}: attempts exhausted ({attempts}/{max_attempts}), "
                          f"notification_status→manual_required")
                send_telegram(f"⚠️ SMS не доставлена после {max_attempts} попыток: {name} ({phone})\nКод: {code}", tg_chat)
                
        elif code in LIMIT_ERROR_CODES:
            # Превышен лимит — НЕ повторять отправку!
            log.error(f"Group {group_id}: SMS limit exceeded (code={code}) — NOT retrying")
            update_sms_log(conn, log_id, status="limit_exceeded", sms_code=code,
                          error_message=f"Limit exceeded: code={code}")
            update_order_group(conn, group_id, {
                "notification_status": "send_failed",
                "last_sms_error": f"Limit exceeded (code={code}), sending blocked",
            })
            send_telegram(f"🚫 SMS заблокирована (лимит {code}): {name} ({phone})", tg_chat)
            
        else:
            # Неизвестный код — логируем, продолжаем проверять
            log.warning(f"Group {group_id}: unknown SMS code: {code}")
            update_sms_log(conn, log_id, status="checking", sms_code=code,
                          error_message=f"Unknown code: {code}")
    
    return delivered

def step_handle_expired(conn, settings):
    """Шаг 3: Обработка SMS с истёкшим сроком проверки"""
    max_duration = settings.get("max_check_duration_minutes", 90)
    max_attempts = settings.get("max_attempts", 2)
    tg_chat = settings.get("telegram_chat_id", TELEGRAM_CHAT_ID)
    
    expired = get_sms_expired(conn, max_duration)
    log.info(f"Step 3: {len(expired)} SMS expired (older than {max_duration} min)")
    
    for item in expired:
        log_id = item["log_id"]
        group_id = str(item["order_group_id"])
        name = item.get("customer_name") or item.get("group_key", "—")
        phone = item.get("customer_phone", "")
        attempts = item.get("attempts") or 1
        delivery_link = item.get("delivery_link", "")
        
        log.warning(f"Group {group_id}: SMS expired after {max_duration} min, attempts={attempts}/{max_attempts}")
        update_sms_log(conn, log_id, status="expired", 
                      error_message=f"Not delivered in {max_duration} minutes")
        
        if attempts < max_attempts:
            # Сбрасываем notification_status → link_ready для повторной отправки
            update_order_group(conn, group_id, {
                "notification_status": "link_ready",
            })
            log.info(f"Group {group_id}: will retry SMS send (attempt {attempts+1}), notification_status→link_ready")
        else:
            # Все попытки исчерпаны
            update_order_group(conn, group_id, {
                "notification_status": "manual_required",
                "last_sms_error": f"Not delivered after {max_attempts} attempts",
            })
            send_telegram(
                f"🔧 Требуется ручное управление: {name} ({phone})\n"
                f"SMS не доставлена после {max_attempts} попыток",
                tg_chat,
            )

def step_release_exhausted(conn, settings):
    """Шаг 4: группы, у которых попытки исчерпаны, а статус остался 'link_ready'.

    Такое состояние возникает как следствие сбоя счётчика: группа выпадает из
    выборки по лимиту попыток, но из очереди не уходит — висит в 'link_ready'
    вечно, клиент не получает ссылку, в ручную работу заказ не переводится.
    Шаг закрывает эту дыру: попытки кончились → «нужен менеджер».
    """
    max_attempts = settings.get("max_attempts", 2)
    tg_chat = settings.get("telegram_chat_id", TELEGRAM_CHAT_ID)
    
    with conn.cursor(cursor_factory=RealDictCursor) as cur:
        cur.execute("""
            SELECT og.id, og.group_key, og.customer_name, og.customer_phone,
                   (SELECT count(*) FROM sms_campaign_log l
                     WHERE l.order_group_id = og.id
                       AND l.campaign_type = 'first_sms') AS attempts
            FROM order_groups og
            WHERE og.delivery_status = 'pending_confirmation'
              AND COALESCE(og.notification_status, '') = 'link_ready'
              AND (
                SELECT count(*) FROM sms_campaign_log l
                WHERE l.order_group_id = og.id
                  AND l.campaign_type = 'first_sms'
              ) >= %s
              -- Активная отправка в работе — не мешаем ей
              AND NOT EXISTS (
                SELECT 1 FROM sms_campaign_log l2
                WHERE l2.order_group_id = og.id
                  AND l2.campaign_type = 'first_sms'
                  AND l2.status IN ('sent', 'checking')
              )
        """, (max_attempts,))
        groups = [dict(r) for r in cur.fetchall()]
    
    for group in groups:
        group_id = str(group["id"])
        name = group.get("customer_name") or group.get("group_key", "—")
        phone = group.get("customer_phone", "")
        attempts = group.get("attempts") or max_attempts
        
        log.warning(f"Group {group_id}: попыток {attempts}/{max_attempts}, статус остался link_ready "
                    f"→ manual_required (клиент SMS не получил)")
        update_order_group(conn, group_id, {
            "notification_status": "manual_required",
            "last_sms_error": f"SMS не доставлена после {attempts} попыток — нужен менеджер",
        })
        send_telegram(
            f"🔧 <b>Нужен менеджер</b>\n{name} ({phone})\n"
            f"SMS не доставлена после {attempts} попыток — клиенту не ушла ссылка",
            tg_chat,
        )
    
    if groups:
        log.info(f"Step 4: {len(groups)} groups released from link_ready → manual_required")
    return len(groups)

# ─── Main ────────────────────────────────────────────────────────────────────

def main():
    log.info("=" * 60)
    log.info("SMS First Campaign — START")
    conn = get_db_conn()
    
    try:
        settings = load_settings(conn)
        log.info(f"Settings: wait={settings.get('wait_between_checks_seconds')}s, "
                 f"max_duration={settings.get('max_check_duration_minutes')}min, "
                 f"max_attempts={settings.get('max_attempts')}")
        
        if not settings.get("enabled", True):
            log.info("Campaign disabled, exiting")
            return
        
        # State machine — каждый шаг быстрый, без blocking
        sent = step_send_new(conn, settings)
        delivered = step_check_status(conn, settings)
        step_handle_expired(conn, settings)
        released = step_release_exhausted(conn, settings)
        
        log.info(f"Run summary: sent={sent}, delivered={delivered}, released_to_manual={released}")
        
        if sent > 0 or delivered > 0:
            send_telegram(
                f"📊 <b>Первая отправка</b>\nОтправлено: {sent}\nДоставлено: {delivered}",
                settings.get("telegram_chat_id", TELEGRAM_CHAT_ID),
            )
        
    except Exception as e:
        log.error(f"Fatal error: {e}", exc_info=True)
    finally:
        conn.close()
    
    log.info("SMS First Campaign — END")
    log.info("=" * 60)


if __name__ == "__main__":
    main()