import logging import json import os import sqlite3 from aiogram import Router, F, Bot from aiogram.types import CallbackQuery, Message, InlineKeyboardMarkup, InlineKeyboardButton from aiogram.fsm.context import FSMContext from aiogram.filters import Command import aiohttp # ИСПРАВЛЕННЫЙ ИМПОРТ ДЛЯ ФАЙЛА В ПАПКЕ HANDLERS from .order_save import save_order from db import get_user_language, get_language_text, get_button_text logger = logging.getLogger(__name__) router = Router(name="cryptobot") # Загрузка API ключа из crypto_api.json def load_cryptobot_token(): try: current_dir = os.path.dirname(os.path.abspath(__file__)) config_path = os.path.join(current_dir, 'crypto_api.json') print(f"Looking for config at: {config_path}") with open(config_path, 'r', encoding='utf-8') as f: config = json.load(f) token = config.get('cryptobot_token') print(f"Token loaded: {token[:10]}..." if token else "Token not found") return token except Exception as e: logger.error(f"Ошибка загрузки crypto_api.json: {e}") return None # Загружаем токен при старте CRYPTOBOT_TOKEN = load_cryptobot_token() CRYPTOBOT_API_URL = "https://pay.crypt.bot/api" print(f"CRYPTOBOT_TOKEN loaded: {CRYPTOBOT_TOKEN is not None}") # Callback для проверки оплаты CHECK_PAYMENT_CB = "check_payment_crypto" async def create_cryptobot_invoice(amount: float, description: str = "Оплата товара") -> dict: """ Создает инвойс в CryptoBot """ if not CRYPTOBOT_TOKEN: logger.error("CryptoBot token not loaded") return None url = f"{CRYPTOBOT_API_URL}/createInvoice" headers = { "Crypto-Pay-API-Token": CRYPTOBOT_TOKEN, "Content-Type": "application/json" } data = { "asset": "USDT", "amount": str(amount), "description": description, "paid_btn_name": "viewItem", "paid_btn_url": "https://t.me/your_bot", "allow_comments": False, "allow_anonymous": False, "expires_in": 3600 } print(f"Creating invoice for amount: {amount}") try: async with aiohttp.ClientSession() as session: async with session.post(url, headers=headers, json=data) as response: result = await response.json() print(f"CryptoBot API response: {result}") if result.get("ok"): return result.get("result") else: logger.error(f"CryptoBot API error: {result}") return None except Exception as e: logger.error(f"CryptoBot request error: {e}") return None async def check_cryptobot_invoice(invoice_id: int) -> dict: """ Проверяет статус инвойса в CryptoBot """ if not CRYPTOBOT_TOKEN: logger.error("CryptoBot token not loaded") return None url = f"{CRYPTOBOT_API_URL}/getInvoices" headers = { "Crypto-Pay-API-Token": CRYPTOBOT_TOKEN } params = { "invoice_ids": str(invoice_id), "count": 1 } try: async with aiohttp.ClientSession() as session: async with session.get(url, headers=headers, params=params) as response: result = await response.json() print(f"Check invoice response: {result}") if result.get("ok") and result.get("result", {}).get("items"): return result["result"]["items"][0] else: return None except Exception as e: logger.error(f"CryptoBot check invoice error: {e}") return None def build_payment_keyboard(lang: str, invoice_url: str) -> InlineKeyboardMarkup: """ Создает клавиатуру с кнопками оплаты и проверки """ # Текст кнопок из базы данных pay_button_text = get_button_text(lang, "button17", "💳 Оплатить") check_button_text = get_button_text(lang, "button15", "✅ Проверить оплату") keyboard = InlineKeyboardMarkup( inline_keyboard=[ [InlineKeyboardButton(text=pay_button_text, url=invoice_url)], [InlineKeyboardButton(text=check_button_text, callback_data=CHECK_PAYMENT_CB)] ] ) return keyboard async def handle_cryptobot_payment(cb: CallbackQuery, state: FSMContext): """ Обработчик оплаты через CryptoBot - вызывается из catalog.py """ user_id = cb.from_user.id lang = get_user_language(user_id) print(f"=== HANDLE CRYPTOBOT PAYMENT FROM CATALOG ===") # Получаем данные из состояния state_data = await state.get_data() base_price = state_data.get('product_base_price') product_id = state_data.get('product_id') if not base_price or base_price <= 0: error_text = "Ошибка: неверная цена товара" await cb.message.answer(error_text) return # Получаем детали товара для описания from db import DATA_DB try: conn = sqlite3.connect(DATA_DB) cur = conn.cursor() cur.execute("SELECT product_name FROM products WHERE product_id = ?", (product_id,)) row = cur.fetchone() conn.close() product_name = str(row[0]).strip() if row and row[0] else 'Товар' except Exception as e: logger.error(f"Error getting product name: {e}") product_name = 'Товар' # Создаем инвойс invoice = await create_cryptobot_invoice( amount=base_price, description=f"Оплата товара: {product_name}" ) if not invoice or not invoice.get('pay_url'): error_text = "Ошибка: не удалось создать инвойс для оплаты" await cb.message.answer(error_text) return print(f"Invoice created: {invoice['invoice_id']}") # Сохраняем ID инвойса в состоянии для будущей проверки await state.update_data( cryptobot_invoice_id=invoice['invoice_id'], cryptobot_amount=base_price ) # Формируем текст сообщения amount_text = get_language_text(lang, "text13") or "Оплатите : {amount} USDT" description_text = get_language_text(lang, "text14") or "Для оплаты нажмите кнопку ниже:" payment_text = f"{amount_text.format(amount=base_price)}\n\n{description_text}" # Создаем клавиатуру с кнопками keyboard = build_payment_keyboard(lang, invoice['pay_url']) # Отправляем сообщение с оплатой payment_message = await cb.message.answer(payment_text, reply_markup=keyboard) # Сохраняем ID сообщения с оплатой для удаления при проверке await state.update_data(payment_message_id=payment_message.message_id) @router.callback_query(F.data == CHECK_PAYMENT_CB) async def check_payment_callback(cb: CallbackQuery, state: FSMContext, bot: Bot): """ Обработчик кнопки проверки оплаты (button15) """ user_id = cb.from_user.id lang = get_user_language(user_id) print(f"=== CHECK PAYMENT CALLBACK ===") print(f"User: {user_id}") # Получаем данные из состояния state_data = await state.get_data() invoice_id = state_data.get('cryptobot_invoice_id') payment_message_id = state_data.get('payment_message_id') print(f"Invoice ID from state: {invoice_id}") print(f"Payment message ID: {payment_message_id}") if not invoice_id: # Если нет invoice_id в состоянии error_text = get_language_text(lang, "text16") or "Оплата не прошла" await cb.message.answer(error_text) print("No invoice ID in state - sending text16") return # Проверяем статус инвойса invoice_data = await check_cryptobot_invoice(invoice_id) if not invoice_data: error_text = get_language_text(lang, "text16") or "Оплата не прошла" await cb.message.answer(error_text) print("Invoice check failed - sending text16") return status = invoice_data.get('status', 'active') print(f"Invoice status: {status}") if status == 'paid': # Удаляем сообщение с оплатой только при успешной оплате try: if payment_message_id: await bot.delete_message(chat_id=cb.message.chat.id, message_id=payment_message_id) print(f"Deleted payment message: {payment_message_id}") except Exception as e: print(f"Error deleting payment message: {e}") # ДЕБАГ: Проверяем какие данные есть в состоянии print(f"State data for order save: {state_data}") # Сохраняем заказ в базу данных через универсальную функцию order_saved = await save_order(state_data, user_id, "cryptobot", bot) if order_saved: print("Order successfully saved to database via order_save.py") else: print("Failed to save order to database via order_save.py") # Всегда показываем text15 при успешной оплате success_text = get_language_text(lang, "text15") or "Оплата прошла успешно!" await cb.message.answer(success_text) print("Payment successful - sending text15") # Очищаем состояние после успешной проверки await state.clear() else: # При неуспешной оплате НЕ удаляем сообщение с кнопками error_text = get_language_text(lang, "text16") or "Оплата не прошла" await cb.answer(error_text, show_alert=True) print(f"Payment not completed (status: {status}) - showing alert") @router.message(Command("check")) async def check_payment_command(message: Message, state: FSMContext): """ Команда /check - проверяет статус оплаты """ user_id = message.from_user.id lang = get_user_language(user_id) print(f"=== CHECK PAYMENT COMMAND ===") print(f"User: {user_id}") # Получаем данные из состояния state_data = await state.get_data() invoice_id = state_data.get('cryptobot_invoice_id') print(f"Invoice ID from state: {invoice_id}") if not invoice_id: # Если нет invoice_id в состоянии error_text = get_language_text(lang, "text16") or "Оплата не прошла" await message.answer(error_text) print("No invoice ID in state - sending text16") return # Проверяем статус инвойса invoice_data = await check_cryptobot_invoice(invoice_id) if not invoice_data: error_text = get_language_text(lang, "text16") or "Оплата не прошла" await message.answer(error_text) print("Invoice check failed - sending text16") return status = invoice_data.get('status', 'active') print(f"Invoice status: {status}") if status == 'paid': # Сохраняем заказ в базу данных через универсальную функцию order_saved = await save_order(state_data, user_id, "cryptobot", message.bot) if order_saved: print("Order successfully saved to database") else: print("Failed to save order to database") # Всегда показываем text15 при успешной оплате success_text = get_language_text(lang, "text15") or "Оплата прошла успешно!" await message.answer(success_text) print("Payment successful - sending text15") # Очищаем состояние после успешной проверки await state.clear() else: error_text = get_language_text(lang, "text16") or "Оплата не прошла" await message.answer(error_text) print(f"Payment not completed (status: {status}) - sending text16")