سورس ربات ثبت سفارش تلگرام

# -*- coding: utf-8 -*-
# ------------------------------------------------------------
#  ربات ثبت سفارش تلگرام
#  طراحی و کدنویسی: سروش مقدمی — فیلتور (filtori.com)
# ------------------------------------------------------------
#  این ربات یک گفتگوی مرحله‌ای با مشتری انجام می‌ده و سفارش رو
#  می‌گیره و داخل فایل orders.csv ذخیره می‌کنه:
#     ۱) اسم مشتری
#     ۲) محصول یا خدمتی که می‌خواد
#     ۳) شمارهٔ تماس
#  در پایان یک خلاصهٔ سفارش برای مشتری می‌فرسته.
#
#  ⚠️ نکته: ربات تلگرام باید روی سروری اجرا بشه که به
#     api.telegram.org دسترسی داره.
#
#  آموزش کامل:
#     https://filtori.com/telegram-bot-source/order-bot/
#  نسخهٔ اختصاصی + اتصال به پنل و پرداخت؟  09122874862
#  تلگرام ما: https://t.me/filtori
# ------------------------------------------------------------

import csv
import time
from datetime import datetime

import requests

TOKEN = "توکن_ربات_خودت_را_اینجا_بگذار"
BASE = f"https://api.telegram.org/bot{TOKEN}"

# فایلی که سفارش‌ها توش ذخیره می‌شن (کنار همین فایل ساخته می‌شه)
ORDERS_FILE = "orders.csv"

# ------------------------------------------------------------
#  حافظهٔ موقت گفتگو:
#  برای هر کاربر نگه می‌داریم که در کدوم مرحله از ثبت سفارشه.
#  توجه: این حافظه در رم هست؛ اگر ربات ری‌استارت بشه پاک می‌شه.
#  برای پروژهٔ واقعی بهتره از دیتابیس استفاده بشه (تیم فیلتور کمکت می‌کنه).
# ------------------------------------------------------------
sessions = {}


def send_message(chat_id, text):
    url = f"{BASE}/sendMessage"
    try:
        requests.post(url, json={"chat_id": chat_id, "text": text}, timeout=15)
    except requests.RequestException as error:
        print("خطا در ارسال پیام:", error)


def get_updates(offset):
    url = f"{BASE}/getUpdates"
    params = {"offset": offset, "timeout": 30}
    try:
        return requests.get(url, params=params, timeout=40).json()
    except requests.RequestException as error:
        print("خطا در دریافت پیام‌ها:", error)
        return {"ok": False, "result": []}


def save_order(data):
    """ذخیرهٔ یک سفارش کامل در فایل CSV."""
    is_new_file = False
    try:
        with open(ORDERS_FILE, "r", encoding="utf-8"):
            pass
    except FileNotFoundError:
        is_new_file = True

    with open(ORDERS_FILE, "a", newline="", encoding="utf-8") as file:
        writer = csv.writer(file)
        if is_new_file:
            writer.writerow(["تاریخ", "نام", "محصول", "تلفن"])
        writer.writerow(
            [
                datetime.now().strftime("%Y-%m-%d %H:%M"),
                data["name"],
                data["product"],
                data["phone"],
            ]
        )


def handle(chat_id, text):
    """منطق گفتگوی مرحله‌ای ثبت سفارش."""
    if text == "/start":
        sessions[chat_id] = {"step": "name", "data": {}}
        send_message(chat_id, "سلام 👋 برای ثبت سفارش، لطفاً «نام و نام خانوادگی» خود را بنویسید:")
        return

    if chat_id not in sessions:
        send_message(chat_id, "برای شروع ثبت سفارش، دستور /start را بفرستید.")
        return

    session = sessions[chat_id]
    step = session["step"]

    if step == "name":
        session["data"]["name"] = text
        session["step"] = "product"
        send_message(chat_id, "ممنون ✅ حالا بنویس چه محصول یا خدمتی می‌خوای؟")

    elif step == "product":
        session["data"]["product"] = text
        session["step"] = "phone"
        send_message(chat_id, "عالیه 👌 در آخر شمارهٔ تماست رو بنویس تا باهات هماهنگ کنیم:")

    elif step == "phone":
        session["data"]["phone"] = text
        data = session["data"]
        save_order(data)

        send_message(
            chat_id,
            "سفارشت با موفقیت ثبت شد ✅\n\n"
            f"👤 نام: {data['name']}\n"
            f"🛍️ محصول: {data['product']}\n"
            f"📞 تلفن: {data['phone']}\n\n"
            "به‌زودی باهات تماس می‌گیریم. ممنون که فیلتور رو انتخاب کردی 🙏",
        )
        del sessions[chat_id]


def main():
    print("ربات ثبت سفارش فیلتور روشن شد... (Ctrl+C برای خاموش‌کردن)")
    offset = 0
    while True:
        updates = get_updates(offset)
        if not updates.get("ok"):
            time.sleep(2)
            continue

        for update in updates.get("result", []):
            offset = update["update_id"] + 1
            message = update.get("message")
            if not message:
                continue
            chat_id = message["chat"]["id"]
            text = message.get("text", "")
            if text:
                handle(chat_id, text)

        time.sleep(0.5)


if __name__ == "__main__":
    main()