سورس ربات پشتیبانی و تیکت تلگرام

# -*- coding: utf-8 -*-
# ------------------------------------------------------------
#  ربات پشتیبانی و تیکت تلگرام
#  طراحی و کدنویسی: سروش مقدمی — فیلتور (filtori.com)
# ------------------------------------------------------------
#  هر پیامی که کاربر بفرسته، یک «تیکت» با شمارهٔ پیگیری می‌شه:
#   - تیکت داخل فایل tickets.csv ذخیره می‌شه (با اکسل باز می‌شه)
#   - همون لحظه برای مدیر (ادمین) فرستاده می‌شه
#   - مدیر با دستور  /reply شماره_تیکت متن_پاسخ  جواب می‌ده
#     و جواب مستقیم برای همون کاربر ارسال می‌شه
#   - مدیر با دستور  /open  تیکت‌های بی‌پاسخ رو می‌بینه
#
#  ⚠️ نکته: ربات تلگرام باید روی سروری اجرا بشه که به
#     api.telegram.org دسترسی داره.
#
#  آموزش کامل:
#     https://filtori.com/telegram-bot-source/ticket-bot/
#  سوال یا راهنمایی:  https://filtori.com/contact/
#  نسخهٔ اختصاصی با پنل و چند اپراتور؟  09122874862
# ------------------------------------------------------------

import csv
import os
import time
from datetime import datetime

import requests

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

# chat_id عددی مدیر؛ ربات رو اجرا کن، /start بزن تا در ترمینال چاپ بشه.
ADMIN_CHAT_ID = 123456789  # <-- این عدد رو با chat_id خودت عوض کن

TICKETS_FILE = "tickets.csv"
FIELDS = ["id", "date", "chat_id", "name", "message", "status"]


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, ValueError) as error:
        print("خطا در دریافت پیام‌ها:", error)
        return {"ok": False, "result": []}


def load_tickets():
    """خواندن همهٔ تیکت‌ها از فایل CSV."""
    if not os.path.exists(TICKETS_FILE):
        return []
    with open(TICKETS_FILE, "r", newline="", encoding="utf-8-sig") as file:
        return list(csv.DictReader(file))


def save_tickets(tickets):
    """بازنویسی کامل فایل تیکت‌ها (برای تغییر وضعیت)."""
    with open(TICKETS_FILE, "w", newline="", encoding="utf-8-sig") as file:
        writer = csv.DictWriter(file, fieldnames=FIELDS)
        writer.writeheader()
        writer.writerows(tickets)


def create_ticket(chat_id, name, message):
    """ساخت تیکت جدید و برگرداندن شمارهٔ آن."""
    tickets = load_tickets()
    ticket_id = max([int(t["id"]) for t in tickets], default=0) + 1
    tickets.append(
        {
            "id": str(ticket_id),
            "date": datetime.now().strftime("%Y-%m-%d %H:%M"),
            "chat_id": str(chat_id),
            "name": name,
            "message": message,
            "status": "باز",
        }
    )
    save_tickets(tickets)
    return ticket_id


def admin_reply(text):
    """اجرای دستور /reply شماره متن  توسط مدیر."""
    parts = text.split(maxsplit=2)
    if len(parts) < 3 or not parts[1].isdigit():
        send_message(ADMIN_CHAT_ID, "فرمت درست:\n/reply 12 متن پاسخ شما")
        return

    ticket_id, answer = parts[1], parts[2]
    tickets = load_tickets()
    for ticket in tickets:
        if ticket["id"] == ticket_id:
            send_message(
                int(ticket["chat_id"]),
                f"📩 پاسخ پشتیبانی به تیکت #{ticket_id}:\n\n{answer}",
            )
            ticket["status"] = "پاسخ داده شد"
            save_tickets(tickets)
            send_message(ADMIN_CHAT_ID, f"پاسخ تیکت #{ticket_id} ارسال شد ✅")
            return

    send_message(ADMIN_CHAT_ID, f"تیکتی با شمارهٔ {ticket_id} پیدا نشد.")


def admin_open_list():
    """نمایش تیکت‌های بی‌پاسخ برای مدیر."""
    open_tickets = [t for t in load_tickets() if t["status"] == "باز"]
    if not open_tickets:
        send_message(ADMIN_CHAT_ID, "هیچ تیکت بی‌پاسخی نداری 👌")
        return
    lines = [f"#{t['id']} | {t['name']} | {t['message'][:40]}" for t in open_tickets[-15:]]
    send_message(ADMIN_CHAT_ID, "تیکت‌های باز:\n\n" + "\n".join(lines))


def handle(message):
    chat_id = message["chat"]["id"]
    text = message.get("text", "")
    user = message.get("from", {})
    name = (user.get("first_name", "") + " " + user.get("last_name", "")).strip() or "کاربر"

    # --- دستورهای مدیر ---
    if chat_id == ADMIN_CHAT_ID:
        if text.startswith("/reply"):
            admin_reply(text)
        elif text == "/open":
            admin_open_list()
        else:
            send_message(
                chat_id,
                "دستورهای مدیر:\n/open  ← تیکت‌های بی‌پاسخ\n/reply 12 متن  ← پاسخ به تیکت",
            )
        return

    # --- کاربران ---
    if text == "/start":
        send_message(
            chat_id,
            f"سلام {name} 👋\n"
            "به پشتیبانی ما خوش اومدی. سوال یا مشکلت رو همین‌جا بنویس؛\n"
            "یک شمارهٔ پیگیری می‌گیری و کارشناس ما همین‌جا جواب می‌ده.",
        )
        return

    if not text:
        send_message(chat_id, "فعلاً فقط پیام متنی پشتیبانی می‌شه؛ لطفاً مشکلت رو بنویس.")
        return

    ticket_id = create_ticket(chat_id, name, text)
    send_message(
        chat_id,
        f"پیامت ثبت شد ✅\nشمارهٔ پیگیری: #{ticket_id}\n"
        "به‌زودی جوابت همین‌جا ارسال می‌شه.",
    )
    send_message(
        ADMIN_CHAT_ID,
        f"🎫 تیکت جدید #{ticket_id}\n👤 {name} (chat_id: {chat_id})\n\n{text}\n\n"
        f"برای پاسخ:\n/reply {ticket_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
            print("پیام از chat_id:", message["chat"]["id"])
            handle(message)

        time.sleep(0.5)


if __name__ == "__main__":
    main()