Напоминания о записи в WhatsApp для клиник, салонов и автосервисов

Здравствуйте, Айгерим! Напоминаем о записи в клинике «Здоровье»: завтра, 14 ноября, в 10:30. Памятку о подготовке к визиту пришлём отдельно.
Ответьте 1 — подтверждаю, 2 — не смогу прийти.

Айгерим, ждём вас сегодня в 10:30. Адрес: Алматы, ул. Сатпаева, 30, вход со двора.

# remind.py — cron: */15 * * * * python3 /opt/remind/remind.py   (pip install requests)
import os, sqlite3, time
from datetime import datetime, timedelta
from zoneinfo import ZoneInfo
import requests

TZ = ZoneInfo("Asia/Almaty")
HEADERS = {"Authorization": "Bearer " + os.environ["WAPI_KEY"]}
FROM = os.environ.get("WAPI_FROM")              # id номера из GET /numbers, если номеров несколько
PLACE, ADDRESS = "клиника «Здоровье»", "Алматы, ул. Сатпаева, 30"
PLAN = [  # отметка, окно «от–до» часов до визита, текст
    ("reminded_day", 3, 24, "Здравствуйте, {name}! Напоминаем о записи: {place}, {date} в {time}, {service}.\n"
                            "Ответьте 1 — подтверждаю, 2 — не смогу прийти."),
    ("reminded_soon", 0, 2, "{name}, ждём вас сегодня в {time}. Адрес: {address}."),
]

db = sqlite3.connect("bookings.db")
db.row_factory = sqlite3.Row
now = datetime.now(TZ).replace(tzinfo=None)
fmt = lambda d: d.strftime("%Y-%m-%d %H:%M")   # starts_at хранится как «2026-11-14 10:30» по Алматы

if 8 <= now.hour < 21:
    for flag, h_from, h_to, template in PLAN:
        rows = db.execute(f"SELECT * FROM appointments WHERE status IN ('booked', 'confirmed') AND {flag} = 0 "
                          "AND starts_at > ? AND starts_at <= ?",
                          (fmt(now + timedelta(hours=h_from)), fmt(now + timedelta(hours=h_to)))).fetchall()
        for a in rows:
            t = datetime.strptime(a["starts_at"], "%Y-%m-%d %H:%M")
            text = template.format(name=a["name"], place=PLACE, address=ADDRESS, service=a["service"],
                                   date=f"{t:%d.%m}", time=f"{t:%H:%M}")
            r = requests.post("https://wapi.kz/api/v1/messages/send", headers=HEADERS,
                              json={"to": a["phone"], "text": text, **({"from": int(FROM)} if FROM else {})}, timeout=15)
            code = r.json().get("code")
            if r.status_code == 200 or code in ("invalid_to", "empty_text", "text_too_long"):
                db.execute(f"UPDATE appointments SET {flag} = 1 WHERE id = ?", (a["id"],))   # негодный номер — проверьте запись вручную
                db.commit()
            elif code != "rate_limited":
                raise SystemExit(f"Стоп: {r.json().get('error')}")   # лимит, пауза, номер отключён
            time.sleep(5)                       # первые сообщения новым людям — не чаще раза в 5 секунд

# hook.py — pip install flask requests
import os, sqlite3, threading
from datetime import datetime
from zoneinfo import ZoneInfo
import requests
from flask import Flask, request

app = Flask(__name__)
REPLIES = {"1": ("confirmed", "Спасибо, запись подтверждена. Ждём вас!"),
           "2": ("cancelled", "Поняли, запись отменили. Администратор напишет вам, чтобы подобрать другое время.")}


def notify_admin(phone, booking_id):
    print("Отмена записи", booking_id, phone)   # замените на сообщение в Telegram или задачу в CRM


def handle(phone, answer, number_id):
    status, reply = REPLIES[answer]
    db = sqlite3.connect("bookings.db")
    now = datetime.now(ZoneInfo("Asia/Almaty")).strftime("%Y-%m-%d %H:%M")
    row = db.execute("SELECT id FROM appointments WHERE phone = ? AND status = 'booked' AND reminded_day = 1 "
                     "AND starts_at > ? ORDER BY starts_at LIMIT 1", (phone, now)).fetchone()
    if not row:
        return                                  # подтверждать нечего — ответит человек
    db.execute("UPDATE appointments SET status = ? WHERE id = ?", (status, row[0]))
    db.commit()
    requests.post("https://wapi.kz/api/v1/messages/send", timeout=15,
                  headers={"Authorization": "Bearer " + os.environ["WAPI_KEY"]},
                  json={"to": phone, "text": reply, "from": number_id})
    if status == "cancelled":
        notify_admin(phone, row[0])


@app.post("/whatsapp/webhook")
def webhook():
    if request.args.get("token") != os.environ["WAPI_HOOK_TOKEN"]:
        return "", 403
    e = request.get_json(silent=True) or {}
    p = e.get("payload") or {}
    answer = (p.get("body") or "").strip()
    if e.get("event") == "message" and p.get("from", "").endswith("@c.us") and answer in REPLIES:
        threading.Thread(target=handle, args=(p["from"].split("@")[0], answer, e["wapi"]["number_id"])).start()
    return "", 200                              # остальные сообщения — живой разговор