Уведомления о заказах Kaspi в WhatsApp: как настроить через API

Здравствуйте! Это магазин «{магазин}» на Kaspi. Заказ №{номер} принят.
Самовывоз: Алматы, ул. Абая, 10, ежедневно с 10:00 до 20:00.
Вопросы по заказу — ответьте на это сообщение.

# раз в 10 минут; KASPI_TOKEN, WAPI_KEY, KASPI_PHONE_FIELD — в файле .env
*/10 * * * * cd /opt/kaspi-notify && set -a && . ./.env && python3 kaspi_notify.py >> notify.log 2>&1

# kaspi_notify.py — pip install requests; первый запуск: python3 kaspi_notify.py --init
import os, sqlite3, sys, time
from datetime import datetime
from zoneinfo import ZoneInfo
import requests

KASPI = "https://kaspi.kz/shop/api/v2"
WAPI = "https://wapi.kz/api/v1"
KASPI_HEADERS = {
    "X-Auth-Token": os.environ["KASPI_TOKEN"],
    "Accept": "application/vnd.api+json",
    "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 "
                  "(KHTML, like Gecko) Chrome/124.0 Safari/537.36",
}
WAPI_HEADERS = {"Authorization": "Bearer " + os.environ["WAPI_KEY"]}
FROM = os.environ.get("WAPI_FROM")              # id номера из GET /numbers, если номеров несколько
PHONE_FIELD = os.environ["KASPI_PHONE_FIELD"]   # поле с телефоном покупателя из заказа (сверьте с документацией Kaspi)
SHOP = "Ваш магазин"
TEXTS = {
    "PICKUP": "Здравствуйте! Это магазин «{shop}» на Kaspi. Заказ №{code} принят. Самовывоз: "
              "Алматы, ул. Абая, 10, с 10:00 до 20:00. Вопросы по заказу — ответьте на это сообщение.",
    "DELIVERY": "Здравствуйте! Заказ №{code} из магазина «{shop}» передан курьеру, "
                "он позвонит перед приездом. Вопросы по заказу — пишите сюда.",
}
STOP = {"daily_limit", "new_contacts_limit", "cold_blocked", "spam_detected", "number_paused", "not_connected"}

db = sqlite3.connect("kaspi_notified.db")
db.execute("CREATE TABLE IF NOT EXISTS notified (order_id TEXT, state TEXT, PRIMARY KEY (order_id, state))")


def kaspi_orders(state, days=7):
    now = int(time.time() * 1000)
    since = now - days * 86_400_000             # дата создания — в миллисекундах
    orders, page = [], 0
    while True:
        url = (f"{KASPI}/orders?page%5Bnumber%5D={page}&page%5Bsize%5D=100"
               f"&filter%5Borders%5D%5Bstate%5D={state}"
               f"&filter%5Borders%5D%5BcreationDate%5D%5B$ge%5D={since}"
               f"&filter%5Borders%5D%5BcreationDate%5D%5B$le%5D={now}")
        r = requests.get(url, headers=KASPI_HEADERS, timeout=30)
        r.raise_for_status()
        body = r.json()
        orders += body.get("data", [])
        page += 1
        if page >= body.get("meta", {}).get("pageCount", 1):
            return orders


def to_phone(raw):
    d = "".join(ch for ch in str(raw or "") if ch.isdigit())
    if len(d) == 10:
        d = "7" + d
    elif len(d) == 11 and d.startswith("8"):
        d = "7" + d[1:]
    return d if len(d) == 11 and d.startswith("7") else None


def wapi(path, payload):
    if FROM:
        payload["from"] = int(FROM)
    r = requests.post(WAPI + path, json=payload, headers=WAPI_HEADERS, timeout=15)
    return r.status_code, r.json()


def mark(order_id, state):
    db.execute("INSERT OR IGNORE INTO notified VALUES (?, ?)", (order_id, state))
    db.commit()


def main(init):
    if not init and not 9 <= datetime.now(ZoneInfo("Asia/Almaty")).hour < 21:
        return                                  # ночью не пишем
    for state, template in TEXTS.items():
        for order in kaspi_orders(state):
            oid, a = order["id"], order.get("attributes", {})
            if db.execute("SELECT 1 FROM notified WHERE order_id = ? AND state = ?", (oid, state)).fetchone():
                continue
            phone = to_phone((a.get("customer") or {}).get(PHONE_FIELD))
            if init or not phone:
                mark(oid, state)
                continue
            status, check = wapi("/contacts/check", {"phone": phone})
            time.sleep(1)                       # проверки — не чаще одной в секунду
            if status != 200:
                continue                        # проверка не прошла — попробуем в следующий запуск
            if not check.get("exists"):
                mark(oid, state)                # WhatsApp нет — статус покупатель увидит в Kaspi
                continue
            status, res = wapi("/messages/send", {"to": phone, "text": template.format(shop=SHOP, code=a.get("code"))})
            code = res.get("code")
            if status == 200 or code in ("invalid_to", "empty_text", "text_too_long"):
                mark(oid, state)                # отправлено или номер негодный — повтор не поможет
            elif code in STOP or status in (400, 401, 403):
                print("Стоп:", code, res.get("error"))   # лимит, пауза, from_required, неверный ключ
                return
            time.sleep(5)                       # первые сообщения новым людям — не чаще раза в 5 секунд


if __name__ == "__main__":
    main("--init" in sys.argv)