Бот напоминаний об авансовых платежах: календарь, тексты и выгрузка из 1С

{
  "items": [
    {
      "id": "romashka-2026-10-06-1",
      "chat_id": 123456789,
      "remind_on": "2026-09-29",
      "text": "Добрый день. На следующей неделе у вас авансовый платёж. Напишите, пожалуйста, в какой день планируете его отправить, чтобы мы сверили поступление."
    },
    {
      "id": "romashka-2026-10-06-2",
      "chat_id": 123456789,
      "remind_on": "2026-10-05",
      "text": "Добрый день. Напоминаю про аванс: срок — 6 октября. Ответьте сегодня, пожалуйста, ушёл ли платёж или на какой день он перенесён."
    }
  ]
}

Функция ДатаЗаNРабочихДней(ДатаОтсчета, ЧислоДней)
    Дата = НачалоДня(ДатаОтсчета);
    Осталось = ЧислоДней;
    Пока Осталось > 0 Цикл
        Дата = Дата - 86400;
        День = ДеньНедели(Дата);
        Если День < 6 Тогда
            Осталось = Осталось - 1;
        КонецЕсли;
    КонецЦикла;
    Возврат Дата;
КонецФункции

Функция ТокенНапоминаний()
    Возврат "";
КонецФункции

Функция AdvancesGET(Запрос)
    Ожидаем = "Bearer " + ТокенНапоминаний();
    Если Запрос.Заголовки.Получить("Authorization") <> Ожидаем Тогда
        Возврат Новый HTTPСервисОтвет(401);
    КонецЕсли;

    Данные = Новый Запрос;
    Данные.Текст =
    "ВЫБРАТЬ
    |    График.Идентификатор КАК Идентификатор,
    |    График.ChatId КАК ChatId,
    |    График.ДатаНапоминания КАК ДатаНапоминания,
    |    График.Текст КАК Текст
    |ИЗ
    |    РегистрСведений.ГрафикНапоминаний КАК График
    |ГДЕ
    |    График.ДатаНапоминания = &Сегодня
    |    И График.Отправлено = ЛОЖЬ
    |    И (График.ПаузаДо = ДАТАВРЕМЯ(1, 1, 1) ИЛИ График.ПаузаДо < &Сегодня)";
    Данные.УстановитьПараметр("Сегодня", НачалоДня(ТекущаяДатаСеанса()));

    Массив = Новый Массив;
    Выборка = Данные.Выполнить().Выбрать();
    Пока Выборка.Следующий() Цикл
        Строка = Новый Структура;
        Строка.Вставить("id", Выборка.Идентификатор);
        Строка.Вставить("chat_id", Выборка.ChatId);
        Строка.Вставить("remind_on", Формат(Выборка.ДатаНапоминания, "ДФ=yyyy-MM-dd"));
        Строка.Вставить("text", Выборка.Текст);
        Массив.Добавить(Строка);
    КонецЦикла;

    Запись = Новый ЗаписьJSON;
    Запись.УстановитьСтроку();
    ЗаписатьJSON(Запись, Новый Структура("items", Массив));

    Ответ = Новый HTTPСервисОтвет(200);
    Ответ.Заголовки.Вставить("Content-Type", "application/json; charset=utf-8");
    Ответ.УстановитьТелоИзСтроки(Запись.Закрыть(), КодировкаТекста.UTF8);
    Возврат Ответ;
КонецФункции

Функция AckPOST(Запрос)
    Ожидаем = "Bearer " + ТокенНапоминаний();
    Если Запрос.Заголовки.Получить("Authorization") <> Ожидаем Тогда
        Возврат Новый HTTPСервисОтвет(401);
    КонецЕсли;

    Чтение = Новый ЧтениеJSON;
    Чтение.УстановитьСтроку(Запрос.ПолучитьТелоКакСтроку());
    Данные = ПрочитатьJSON(Чтение);
    Чтение.Закрыть();

    Идентификатор = "";
    Если ТипЗнч(Данные) = Тип("Структура") И Данные.Свойство("id") Тогда
        Идентификатор = Строка(Данные.id);
    ИначеЕсли ТипЗнч(Данные) = Тип("Соответствие") Тогда
        Идентификатор = Строка(Данные.Получить("id"));
    КонецЕсли;

    Если Идентификатор <> "" Тогда
        Набор = РегистрыСведений.ГрафикНапоминаний.СоздатьНаборЗаписей();
        Набор.Отбор.Идентификатор.Установить(Идентификатор);
        Набор.Прочитать();
        Если Набор.Количество() > 0 Тогда
            Набор[0].Отправлено = Истина;
            Набор.Записать();
        КонецЕсли;
    КонецЕсли;

    Возврат Новый HTTPСервисОтвет(204);
КонецФункции

requests

import json
import os
import time
from datetime import date, datetime
from pathlib import Path
from zoneinfo import ZoneInfo

import requests

BOT_TOKEN = os.environ["BOT_TOKEN"]
ONEC_URL = os.environ.get("ONEC_URL", "").strip()
ONEC_ACK_URL = os.environ.get("ONEC_ACK_URL", "").strip()
ONEC_REPLY_URL = os.environ.get("ONEC_REPLY_URL", "").strip()
ONEC_TOKEN = os.environ.get("ONEC_TOKEN", "").strip()
ACCOUNTANT_CHAT_ID = os.environ.get("ACCOUNTANT_CHAT_ID", "").strip()
STATE_PATH = Path(os.environ.get("STATE_PATH", "sent.json"))
POLL_SECONDS = int(os.environ.get("POLL_SECONDS", "600"))
TZ = ZoneInfo(os.environ.get("BOT_TZ", "Europe/Moscow"))

OFFSET_PATH = Path(os.environ.get("OFFSET_PATH", "offset.txt"))


def headers():
    return {"Authorization": f"Bearer {ONEC_TOKEN}"}


def load_sent():
    if not STATE_PATH.exists():
        return set()
    try:
        data = json.loads(STATE_PATH.read_text(encoding="utf-8"))
    except json.JSONDecodeError:
        return set()
    return set(data.get("sent", []))


def save_sent(sent):
    STATE_PATH.write_text(
        json.dumps({"sent": sorted(sent)}, ensure_ascii=False, indent=2),
        encoding="utf-8",
    )


def fetch_items():
    if ONEC_URL:
        response = requests.get(ONEC_URL, headers=headers(), timeout=30)
        response.raise_for_status()
        payload = response.json()
    else:
        payload = json.loads(Path("schedule.json").read_text(encoding="utf-8"))
    items = payload.get("items", [])
    if not isinstance(items, list):
        raise ValueError("В ответе нет списка items")
    return items


def send_message(chat_id, text):
    response = requests.post(
        f"https://api.telegram.org/bot{BOT_TOKEN}/sendMessage",
        json={"chat_id": chat_id, "text": text},
        timeout=20,
    )
    response.raise_for_status()
    body = response.json()
    if not body.get("ok"):
        raise RuntimeError(body.get("description", "telegram error"))


def ack(item_id):
    if not ONEC_ACK_URL or not item_id:
        return
    response = requests.post(
        ONEC_ACK_URL,
        headers=headers(),
        json={"id": item_id},
        timeout=20,
    )
    response.raise_for_status()


def dispatch_due():
    today = datetime.now(TZ).date()
    sent = load_sent()
    for item in fetch_items():
        item_id = str(item.get("id", "")).strip()
        raw_date = str(item.get("remind_on", "")).strip()
        text = str(item.get("text", "")).strip()
        chat_id = item.get("chat_id")
        if not item_id or item_id in sent or not text or chat_id in (None, ""):
            continue
        try:
            remind_on = date.fromisoformat(raw_date)
        except ValueError:
            print(f"bad date {item_id}")
            continue
        if remind_on != today:
            continue
        send_message(int(chat_id), text)
        sent.add(item_id)
        save_sent(sent)
        try:
            ack(item_id)
        except requests.RequestException as exc:
            print(f"ack {item_id} failed: {exc}")
        print(f"sent {item_id}")


def load_offset():
    if not OFFSET_PATH.exists():
        return 0
    raw = OFFSET_PATH.read_text(encoding="utf-8").strip()
    return int(raw) if raw.isdigit() else 0


def save_offset(value):
    OFFSET_PATH.write_text(str(value), encoding="utf-8")


def forward_reply(chat_id, text):
    if ACCOUNTANT_CHAT_ID:
        send_message(int(ACCOUNTANT_CHAT_ID), f"Ответ из чата {chat_id}:\n{text}")
    if not ONEC_REPLY_URL:
        return
    try:
        response = requests.post(
            ONEC_REPLY_URL,
            headers=headers(),
            json={"chat_id": str(chat_id), "text": text},
            timeout=20,
        )
        response.raise_for_status()
    except requests.RequestException as exc:
        print(f"reply sync failed: {exc}")


def poll_replies():
    offset = load_offset()
    response = requests.get(
        f"https://api.telegram.org/bot{BOT_TOKEN}/getUpdates",
        params={"timeout": 30, "offset": offset},
        timeout=40,
    )
    response.raise_for_status()
    body = response.json()
    if not body.get("ok"):
        raise RuntimeError(body.get("description", "getUpdates error"))
    for update in body.get("result", []):
        update_id = int(update["update_id"])
        message = update.get("message") or {}
        text = str(message.get("text") or "").strip()
        chat = message.get("chat") or {}
        chat_id = chat.get("id")
        if text and chat_id is not None and str(chat_id) != ACCOUNTANT_CHAT_ID:
            forward_reply(chat_id, text)
        save_offset(update_id + 1)


def main():
    next_send = 0.0
    while True:
        now = time.time()
        if now >= next_send:
            try:
                dispatch_due()
            except Exception as exc:
                print(f"dispatch failed: {exc}")
            next_send = now + POLL_SECONDS
        try:
            poll_replies()
        except Exception as exc:
            print(f"poll failed: {exc}")
            time.sleep(5)


if __name__ == "__main__":
    main()