Тренируюсь с подключением юмани к боту. Нужна помощь Счет на оплату from yoomoney import Quickpay quickpay = Quickpay( receiver="4100117476417051", # Номер вашего аккаунта quickpay_form="shop", # Это я хз зачем, но я это не трогаю targets="Sponsor this project", # Цели, я их не изменяю, потому что особой нужды в этом нет. paymentType="SB", # Это лучше не трогать sum=10, # Это сумма label="test123" # Это комментарий для проверки на наличие оплаты ) print(quickpay.base_url) Python from yoomoney import Quickpay quickpay = Quickpay( receiver="4100117476417051", # Номер вашего аккаунта quickpay_form="shop", # Это я хз зачем, но я это не трогаю targets="Sponsor this project", # Цели, я их не изменяю, потому что особой нужды в этом нет. paymentType="SB", # Это лучше не трогать sum=10, # Это сумма label="test123" # Это комментарий для проверки на наличие оплаты ) print(quickpay.base_url) Проверка оплаты from yoomoney import ClientTOKEN = "ВАШ_TOKEN"client = Client(TOKEN)history = client.operation_history(label="test123") #Просмотр истории транзакций, label - комментарий который вы указали ранееif history.operations == []: print("Оплата не найдена!")for operation in history.operations: if operation.status == 'success': print("Оплата найдена!") Python from yoomoney import ClientTOKEN = "ВАШ_TOKEN"client = Client(TOKEN)history = client.operation_history(label="test123") #Просмотр истории транзакций, label - комментарий который вы указали ранееif history.operations == []: print("Оплата не найдена!")for operation in history.operations: if operation.status == 'success': print("Оплата найдена!") У меня есть платежка Lava Там реализовано все вот так Код лавы # Создание инвойса Lava async def create_lava_invoice(amount, order_id): shop_id = PROJECT_ID secret_key = SECRET_KEY data = { "shopId": shop_id, "sum": amount, "orderId": order_id, "comment": "Оплата через LavaPay", "failUrl": "https://t.me/lyzex***bot", "successUrl": "https://t.me/lyzex***bot", "hookUrl": "https://example.com/hook", "expire": 300 } json_str = json.dumps(data, separators=(',', ':')).encode() sign = hmac.new(secret_key.encode('utf-8'), json_str, hashlib.sha256).hexdigest() url = 'https://api.lava.ru/business/invoice/create' headers = { 'Accept': 'application/json', 'Content-Type': 'application/json', 'Signature': sign } async with aiohttp.ClientSession() as session: async with session.post(url, data=json_str, headers=headers) as response: response_data = await response.json() if response.status == 200 and response_data.get('status_check'): return response_data['data']['url'], response_data['data']['id'] else: print(f"Ошибка при создании инвойса: {response_data}") return None, None # Проверка статуса счета async def check_lava_invoice(invoice_id: str): shop_id = PROJECT_ID secret_key = SECRET_KEY data = { "shopId": shop_id, "invoiceId": invoice_id } json_str = json.dumps(data, separators=(',', ':')).encode() sign = hmac.new(secret_key.encode('utf-8'), json_str, hashlib.sha256).hexdigest() url = f"https://api.lava.ru/business/invoice/status" headers = { 'Accept': 'application/json', 'Content-Type': 'application/json', 'Signature': sign } Python # Создание инвойса Lava async def create_lava_invoice(amount, order_id): shop_id = PROJECT_ID secret_key = SECRET_KEY data = { "shopId": shop_id, "sum": amount, "orderId": order_id, "comment": "Оплата через LavaPay", "failUrl": "https://t.me/lyzex***bot", "successUrl": "https://t.me/lyzex***bot", "hookUrl": "https://example.com/hook", "expire": 300 } json_str = json.dumps(data, separators=(',', ':')).encode() sign = hmac.new(secret_key.encode('utf-8'), json_str, hashlib.sha256).hexdigest() url = 'https://api.lava.ru/business/invoice/create' headers = { 'Accept': 'application/json', 'Content-Type': 'application/json', 'Signature': sign } async with aiohttp.ClientSession() as session: async with session.post(url, data=json_str, headers=headers) as response: response_data = await response.json() if response.status == 200 and response_data.get('status_check'): return response_data['data']['url'], response_data['data']['id'] else: print(f"Ошибка при создании инвойса: {response_data}") return None, None # Проверка статуса счета async def check_lava_invoice(invoice_id: str): shop_id = PROJECT_ID secret_key = SECRET_KEY data = { "shopId": shop_id, "invoiceId": invoice_id } json_str = json.dumps(data, separators=(',', ':')).encode() sign = hmac.new(secret_key.encode('utf-8'), json_str, hashlib.sha256).hexdigest() url = f"https://api.lava.ru/business/invoice/status" headers = { 'Accept': 'application/json', 'Content-Type': 'application/json', 'Signature': sign } Может кто помочь обернуть функции что бы можно было вставить в код
В итоге у меня получилось все вот так import time import hashlib import hmac import json import aiohttp from aiogram import types from aiogram.dispatcher import filters from main import bot, dp from aiogram.dispatcher.storage import FSMContext from database.db import get_user, edit_user_balance from keyboards.user import * from keyboards.admin import * from database.db import Config from states.state import * from utils.helper import comment_generation, convert_usd_to_rub from utils.crypto_api import AioCryptoPay, get_crypto_bot_sum, check_crypto_bot_invoice from utils.lolz_api import LolzteamApi from utils.aaio_api import aaio_create_invoice, aaio_check_invoice from config import PROJECT_ID, SECRET_KEY from yoomoney import Quickpay, Client async def create_lava_invoice(amount, order_id): shop_id = PROJECT_ID secret_key = SECRET_KEY data = { "shopId": shop_id, "sum": amount, "orderId": order_id, "comment": "Оплата через LavaPay", "failUrl": "https://t.me//wix***_bot", "successUrl": "https://t.me//wix***_bot", "hookUrl": "https://example.com/hook", "expire": 300 } json_str = json.dumps(data, separators=(',', ':')).encode() sign = hmac.new(secret_key.encode('utf-8'), json_str, hashlib.sha256).hexdigest() url = 'https://api.lava.ru/business/invoice/create' headers = { 'Accept': 'application/json', 'Content-Type': 'application/json', 'Signature': sign } async with aiohttp.ClientSession() as session: async with session.post(url, data=json_str, headers=headers) as response: response_data = await response.json() if response.status == 200 and response_data.get('status_check'): return response_data['data']['url'], response_data['data']['id'] else: print(f"Ошибка при создании инвойса: {response_data}") return None, None async def check_lava_invoice(invoice_id: str): shop_id = PROJECT_ID secret_key = SECRET_KEY data = { "shopId": shop_id, "invoiceId": invoice_id } json_str = json.dumps(data, separators=(',', ':')).encode() sign = hmac.new(secret_key.encode('utf-8'), json_str, hashlib.sha256).hexdigest() url = f"https://api.lava.ru/business/invoice/status" headers = { 'Accept': 'application/json', 'Content-Type': 'application/json', 'Signature': sign } async with aiohttp.ClientSession() as session: async with session.post(url, data=json_str, headers=headers) as response: response_data = await response.json() return response_data async def create_yoomoney_invoice(amount, order_id): try: quickpay = Quickpay( receiver="4100117476417051", quickpay_form="shop", targets="Оплата заказа", paymentType="SB", sum=amount, label=order_id ) return quickpay.base_url, order_id except Exception as e: print(f"Ошибка при создании платежа ЮMoney: {e}") return None, None async def check_yoomoney_invoice(label): try: TOKEN = "4100117874609540.A075EF6BA45D51FCB6D6895B961B94ACC2F0D3E424C6C800B883122B275B75A4342100AA67C78F7FC3016F95D983F8920414249A4886629F37D90BC564FD6644CE3F802830CD1D5413BAA34A2EFD8754F6366B1B4B4497C58CBCBC180DBB6EDE8D71570891E898075A4A84D48E007AFFBABBDD7A19194140A2832CFE96A1B3D4" client = Client(TOKEN) history = client.operation_history(label=label) if not history.operations: return False for operation in history.operations: if operation.status == 'success': return True return False except Exception as e: print(f"Ошибка при проверке платежа ЮMoney: {e}") return False @dp.callback_query_handler(text="topup", state="*") async def topup_msg(call: types.CallbackQuery, state: FSMContext): await state.update_data(cl=call) text = '<b> Введите сумму пополнения:\n\n❗ Минимальная сумма 100₽ </b>' await call.message.edit_caption( caption=text, reply_markup=await user_back_profile(), ) await Topup.sum.set() @dp.message_handler(state=Topup.sum) async def Topup_sum_state(msg: types.Message, state: FSMContext): data = await state.get_data() cl = data["cl"] await bot.delete_message(chat_id=msg.from_user.id, message_id=msg.message_id) try: message_text = float(msg.text) if message_text > 10000: await cl.message.edit_caption( caption="<b>❗ Максимальная сумма пополнения: 10.000₽.</b>", reply_markup=await back_profile_menu(), ) await state.finish() return if message_text < 100: await cl.message.edit_caption( caption="<b>❗ Минимальная сумма пополнения: 100₽.</b>", reply_markup=await back_profile_menu(), ) await state.finish() return if message_text <= 0: await cl.message.edit_caption( caption="<b>❗ Введите допустимую сумму.</b>", reply_markup=await back_profile_menu(), ) await state.finish() return topup_sum_rub = message_text await state.update_data(topup_sum_rub=topup_sum_rub) text = '<b> Выберите способ пополнения!</b>\n\n❗<b>Если какая то из платежек выдает ошибку при пополнении бота:</b>\n\n<u>✅ Вы так же можете сделать перевод напрямую через СБП.</u>\n\n <b>+7 (967) 777 85-38 ОЗОН БАНК</b>\n В комментарии обязательно укажите ваш уникальный <a href="https://t.me//username_to_id_bot">Id телеграмм</a>' await cl.message.edit_caption( caption=text, reply_markup=await payment_currency_menu(), ) await Topup.currency.set() except ValueError: await cl.message.edit_caption( caption="<b> Вводите только цифры</b>", reply_markup=await back_profile_menu(), ) await state.finish() @dp.callback_query_handler(filters.Text(startswith='method:'), state=Topup.currency) async def top_up_methods(call: types.CallbackQuery, state: FSMContext): data = await state.get_data() topup_sum_rub = data["topup_sum_rub"] method = call.data.split(':')[1] template_text = '<b> Пополнение через {0}</>\n\n' \ '<i>Для депозита средств откройте ссылку ниже и оплатите выставленный для вас счет, оплатить можно любым доступным способом, Важно при замене любых параметров пополнения, он засчитан не будет!</>\n\n' \ '<b> ID платежа: <code>{1}</>\n' \ ' Сумма к оплате: {2}{3}</b>' if method == 'lolzteam': lolz_username = await Config.get('lolzUsername') comment = comment_generation(call.message.from_user.id) amount_usd = topup_sum_rub / convert_usd_to_rub(1) text = template_text.format('zelenka.guru', comment, topup_sum_rub, '₽') pay_url = f"https://zelenka.guru/market/balance/transfer?username={lolz_username}&amount={topup_sum_rub}&comment={comment}" await call.message.edit_caption( caption=text, reply_markup=await lolz_payment_kb(pay_url, comment, amount_usd, topup_sum_rub) ) await state.finish() elif method == 'cryptobot': await call.message.edit_caption('<b> Выберите способ оплаты:</>', reply_markup=cryptobot_currency()) elif method == 'aaio': bill = await aaio_create_invoice(topup_sum_rub) text = template_text.format('aaio.so', bill['bill_id'], topup_sum_rub, '₽') kb = await check_aaio(bill['pay_url'], amount=topup_sum_rub, invoice_id=bill['bill_id']) await call.message.edit_caption(text, reply_markup=kb) await state.finish() elif method == 'lava': order_id = f"order-{int(time.time())}" pay_url, invoice_id = await create_lava_invoice(topup_sum_rub, order_id) if pay_url: text = ( f"<b> Пополнение через Lava</b>\n\n" f"<i>Для депозита средств нажмите кнопку 'Оплатить' и следуйте инструкциям.</i>\n\n" f" Сумма к оплате: {topup_sum_rub}₽" ) keyboard = types.InlineKeyboardMarkup() keyboard.add(types.InlineKeyboardButton("Оплатить", url=pay_url)) keyboard.add(types.InlineKeyboardButton("Проверить оплату", callback_data=f"check_lava:{invoice_id}")) keyboard.add(types.InlineKeyboardButton(text='❌ Отменить', callback_data='back')) await call.message.edit_caption(caption=text, reply_markup=keyboard) else: await call.message.edit_caption( caption="❌ Ошибка при создании счета.", reply_markup=await back_profile_menu() ) await state.finish() elif method == 'yoomoney': order_id = f"order-{int(time.time())}" pay_url, invoice_id = await create_yoomoney_invoice(topup_sum_rub, order_id) if pay_url: text = ( f"<b> Пополнение через ЮMoney</b>\n\n" f"<i>Для депозита средств нажмите кнопку 'Оплатить' и следуйте инструкциям.</i>\n\n" f" Сумма к оплате: {topup_sum_rub}₽" ) keyboard = types.InlineKeyboardMarkup() keyboard.add(types.InlineKeyboardButton("Оплатить", url=pay_url)) keyboard.add(types.InlineKeyboardButton("Проверить оплату", callback_data=f"check_yoomoney:{invoice_id}:{topup_sum_rub}")) # Добавляем сумму в callback_data keyboard.add(types.InlineKeyboardButton(text='❌ Отменить', callback_data='back')) await call.message.edit_caption(caption=text, reply_markup=keyboard) else: await call.message.edit_caption( caption="❌ Ошибка при создании счета.", reply_markup=await back_profile_menu() ) await state.finish() @dp.callback_query_handler(lambda call: call.data.startswith("add_funds|lolz|"), state="*") async def check_lolz_payment(call: types.CallbackQuery, state: FSMContext): lolz_token, lolz_id = await Config.get('lolzToken'), await Config.get("lolzId") **** = await Config.get('logsId') api = LolzteamApi(lolz_token, lolz_id) data = call.data.split("|") amount_usd = data[2] comment = data[3] amount_rub = int(data[4]) check_paym = api.market_payments( type_="income", pmin=amount_rub, pmax=amount_rub, comment=comment )["payments"] if check_paym: await call.message.answer( f"✅ Успешно, ваш платеж найден, баланс пополнен на <b>{amount_rub} RUB / {amount_usd} USD при помощи LolzPay</b>.", reply_markup=await delete_msg_menu(), ) await call.message.edit_caption( caption=f"<b> Добро пожаловать {call.from_user.get_mention()}.</b>", reply_markup=await main_menu(call.from_user.id), ) user_id = call.from_user.id user = await get_user(user_id) plused_amount = int(user[1]) + int(amount_usd) await edit_user_balance(int(user_id), int(plused_amount)) await bot.send_message( ****, text=f"<b>✅ Новое пополнение\n\n◽ Пользователь: {call.from_user.get_mention()}\n◽ ЮзерID: {user_id}\n◽ Сумма: {amount_usd} $\n◽ Система: LZT\n</b>", ) else: await call.message.answer( f" <b>Ваш платеж не найден</>. Попробуйте проверить позже или обратитесь в поддержку, если средства не были зачислены.", reply_markup=await delete_msg_menu(), ) @dp.callback_query_handler(text_startswith="check_crypto_bot") async def check_crypto_bot_funds(call: types.CallbackQuery): **** = await Config.get('logsId') try: amount_usd_str = call.data.split("|")[2] amount_usd = float(amount_usd_str) topup_sum_rub = amount_usd * convert_usd_to_rub(1) if await check_crypto_bot_invoice(int(call.data.split("|")[1])): user_id = call.from_user.id user = await get_user(user_id) new_balance = float(user["balance"]) + float(topup_sum_rub) await edit_user_balance(user_id, new_balance) referrer_id = user["referrer_id"] if referrer_id: print(f"Начисление бонуса для реферера {referrer_id}") referral_bonus = topup_sum_rub * 0.2 referrer = await get_user(referrer_id) if referrer: new_referrer_balance = float(referrer["balance"]) + referral_bonus await edit_user_balance(referrer_id, new_referrer_balance) print(f"Бонус {referral_bonus}₽ начислен рефереру {referrer_id}") await bot.send_message( referrer_id, f" Ваш реферал {call.from_user.get_mention()} пополнил баланс на {topup_sum_rub:.2f}₽.\n" f" Вы получили реферальный бонус: {referral_bonus:.2f}₽!" ) await bot.answer_callback_query( call.id, f'✅ Счет успешно оплачен + {topup_sum_rub:.2f}₽' ) await call.message.answer( f"✅ Успешно, ваш платеж найден, баланс пополнен на <b>{topup_sum_rub:.2f} ₽</b> при помощи CryptoPay", reply_markup=await delete_msg_menu() ) await call.message.edit_caption( caption=f"<b> Добро пожаловать {call.from_user.get_mention()}.</b>", reply_markup=await main_menu(call.from_user.id) ) await bot.send_message( ****, text=f'<b>✅ Новое пополнение\n\n◽ Пользователь: {call.from_user.get_mention()}\n◽ ЮзерID: {user_id}\n◽ Сумма: {topup_sum_rub:.2f} ₽\n◽ Система: CryptoBot\n</b>' ) else: await bot.answer_callback_query(call.id, "❗ Оплата не найдена") except ValueError as ve: await bot.answer_callback_query(call.id, f"❗ Ошибка: {str(ve)}") except Exception as e: print(f"Произошла ошибка: {e}") @dp.callback_query_handler(text_startswith="check_yoomoney", state="*") async def check_yoomoney_payment(call: types.CallbackQuery): **** = await Config.get('logsId') try: invoice_id = call.data.split(":")[1] amount_rub = float(call.data.split(":")[2]) # Добавляем сумму в callback_data if await check_yoomoney_invoice(invoice_id): user_id = call.from_user.id user = await get_user(user_id) new_balance = float(user["balance"]) + amount_rub await edit_user_balance(user_id, new_balance) referrer_id = user["referrer_id"] if referrer_id: print(f"Начисление бонуса для реферера {referrer_id}") referral_bonus = amount_rub * 0.2 referrer = await get_user(referrer_id) if referrer: new_referrer_balance = float(referrer["balance"]) + referral_bonus await edit_user_balance(referrer_id, new_referrer_balance) print(f"Бонус {referral_bonus}₽ начислен рефереру {referrer_id}") await bot.send_message( referrer_id, f" Ваш реферал {call.from_user.get_mention()} пополнил баланс на {amount_rub:.2f}₽.\n" f" Вы получили реферальный бонус: {referral_bonus:.2f}₽!" ) await bot.answer_callback_query( call.id, f'✅ Счет успешно оплачен + {amount_rub:.2f}₽' ) await call.message.answer( f"✅ Успешно, ваш платеж найден, баланс пополнен на <b>{amount_rub:.2f} ₽</b> при помощи ЮMoney", reply_markup=await delete_msg_menu() ) await call.message.edit_caption( caption=f"<b> Добро пожаловать {call.from_user.get_mention()}.</b>", reply_markup=await main_menu(call.from_user.id) ) await bot.send_message( ****, text=f'<b>✅ Новое пополнение\n\n◽ Пользователь: {call.from_user.get_mention()}\n◽ ЮзерID: {user_id}\n◽ Сумма: {amount_rub:.2f} ₽\n◽ Система: ЮMoney\n</b>' ) else: await bot.answer_callback_query(call.id, "❗ Оплата не найдена") except ValueError as ve: await bot.answer_callback_query(call.id, f"❗ Ошибка: {str(ve)}") except Exception as e: print(f"Произошла ошибка: {e}") @dp.callback_query_handler(text_startswith="check_lava", state="*") async def check_lava_payment(call: types.CallbackQuery): invoice_id = call.data.split(":")[1] **** = await Config.get('logsId') response_data = await check_lava_invoice(invoice_id) if response_data and response_data.get("status") == 0: user_id = call.from_user.id user = await get_user(user_id) topup_sum_rub = float(response_data['data']['amount']) new_balance = float(user["balance"]) + topup_sum_rub await edit_user_balance(user_id, new_balance) referrer_id = user["referrer_id"] if referrer_id: referral_bonus = topup_sum_rub * 0.2 referrer = await get_user(referrer_id) if referrer: new_referrer_balance = float(referrer["balance"]) + referral_bonus await edit_user_balance(referrer_id, new_referrer_balance) await bot.send_message( referrer_id, f" Ваш реферал {call.from_user.get_mention()} пополнил баланс на {topup_sum_rub}₽.\n" f" Вы получили реферальный бонус: {referral_bonus}₽!" ) await bot.answer_callback_query( call.id, f'✅ Счет успешно оплачен + {topup_sum_rub}₽' ) await call.message.answer( f"✅ Успешно, ваш платеж найден, баланс пополнен на <b>{topup_sum_rub} ₽</b> при помощи Lava", reply_markup=await delete_msg_menu() ) await call.message.edit_caption( caption=f"<b> Добро пожаловать {call.from_user.get_mention()}.</b>", reply_markup=await main_menu(call.from_user.id) ) await bot.send_message( ****, text=f'<b>✅ Новое пополнение\n\n◽ Пользователь: {call.from_user.get_mention()}\n◽ ЮзерID: {user_id}\n◽ Сумма: {topup_sum_rub} ₽\n◽ Система: Lava\n</b>' ) else: await bot.answer_callback_query(call.id, "❗ Оплата не найдена") @dp.callback_query_handler(text_startswith="check_aaio") async def check_aaio_payment(call: types.CallbackQuery): try: bill_id = call.data.split("|")[1] amount = float(call.data.split("|")[2]) **** = await Config.get('logsId') if (await aaio_check_invoice(bill_id)).get('success'): user_id = call.from_user.id user = await get_user(user_id) new_balance = float(user["balance"]) + amount await edit_user_balance(user_id, new_balance) referrer_id = user["referrer_id"] if referrer_id: referral_bonus = amount * 0.2 referrer = await get_user(referrer_id) if referrer: new_referrer_balance = float(referrer["balance"]) + referral_bonus await edit_user_balance(referrer_id, new_referrer_balance) await bot.send_message( referrer_id, f" Ваш реферал {call.from_user.get_mention()} пополнил баланс на {amount}₽.\n" f" Вы получили реферальный бонус: {referral_bonus}₽!" ) await bot.answer_callback_query( call.id, f'✅ Счет успешно оплачен + {amount}₽' ) await call.message.answer( f"✅ Успешно, ваш платеж найден, баланс пополнен на <b>{amount} ₽</b> при помощи aaio.so", reply_markup=await delete_msg_menu() ) await call.message.edit_caption( caption=f"<b> Добро пожаловать {call.from_user.get_mention()}.</b>", reply_markup=await main_menu(call.from_user.id) ) await bot.send_message( ****, text=f'<b>✅ Новое пополнение\n\n◽ Пользователь: {call.from_user.get_mention()}\n◽ ЮзерID: {user_id}\n◽ Сумма: {amount} ₽\n◽ Система: aaio.so\n</b>' ) else: await bot.answer_callback_query(call.id, "❗ Оплата не найдена") except Exception as e: print(f"Ошибка при проверке платежа aaio: {e}") await bot.answer_callback_query(call.id, "❗ Произошла ошибка при проверке") async def payment_currency_menu(): keyboard = types.InlineKeyboardMarkup() keyboard.add( types.InlineKeyboardButton(" Карты / Юмани", callback_data="method:yoomoney"), types.InlineKeyboardButton(" LolzTeam", callback_data="method:lolzteam") ) keyboard.add( types.InlineKeyboardButton(" CryptoBot", callback_data="method:cryptobot"), #types.InlineKeyboardButton("AAIO.SO", callback_data="method:aaio") ) #keyboard.add( # types.InlineKeyboardButton("Lava", callback_data="method:lava") # ) keyboard.add( types.InlineKeyboardButton("❌ Отменить", callback_data="back") ) return keyboard Python import time import hashlib import hmac import json import aiohttp from aiogram import types from aiogram.dispatcher import filters from main import bot, dp from aiogram.dispatcher.storage import FSMContext from database.db import get_user, edit_user_balance from keyboards.user import * from keyboards.admin import * from database.db import Config from states.state import * from utils.helper import comment_generation, convert_usd_to_rub from utils.crypto_api import AioCryptoPay, get_crypto_bot_sum, check_crypto_bot_invoice from utils.lolz_api import LolzteamApi from utils.aaio_api import aaio_create_invoice, aaio_check_invoice from config import PROJECT_ID, SECRET_KEY from yoomoney import Quickpay, Client async def create_lava_invoice(amount, order_id): shop_id = PROJECT_ID secret_key = SECRET_KEY data = { "shopId": shop_id, "sum": amount, "orderId": order_id, "comment": "Оплата через LavaPay", "failUrl": "https://t.me//wix***_bot", "successUrl": "https://t.me//wix***_bot", "hookUrl": "https://example.com/hook", "expire": 300 } json_str = json.dumps(data, separators=(',', ':')).encode() sign = hmac.new(secret_key.encode('utf-8'), json_str, hashlib.sha256).hexdigest() url = 'https://api.lava.ru/business/invoice/create' headers = { 'Accept': 'application/json', 'Content-Type': 'application/json', 'Signature': sign } async with aiohttp.ClientSession() as session: async with session.post(url, data=json_str, headers=headers) as response: response_data = await response.json() if response.status == 200 and response_data.get('status_check'): return response_data['data']['url'], response_data['data']['id'] else: print(f"Ошибка при создании инвойса: {response_data}") return None, None async def check_lava_invoice(invoice_id: str): shop_id = PROJECT_ID secret_key = SECRET_KEY data = { "shopId": shop_id, "invoiceId": invoice_id } json_str = json.dumps(data, separators=(',', ':')).encode() sign = hmac.new(secret_key.encode('utf-8'), json_str, hashlib.sha256).hexdigest() url = f"https://api.lava.ru/business/invoice/status" headers = { 'Accept': 'application/json', 'Content-Type': 'application/json', 'Signature': sign } async with aiohttp.ClientSession() as session: async with session.post(url, data=json_str, headers=headers) as response: response_data = await response.json() return response_data async def create_yoomoney_invoice(amount, order_id): try: quickpay = Quickpay( receiver="4100117476417051", quickpay_form="shop", targets="Оплата заказа", paymentType="SB", sum=amount, label=order_id ) return quickpay.base_url, order_id except Exception as e: print(f"Ошибка при создании платежа ЮMoney: {e}") return None, None async def check_yoomoney_invoice(label): try: TOKEN = "4100117874609540.A075EF6BA45D51FCB6D6895B961B94ACC2F0D3E424C6C800B883122B275B75A4342100AA67C78F7FC3016F95D983F8920414249A4886629F37D90BC564FD6644CE3F802830CD1D5413BAA34A2EFD8754F6366B1B4B4497C58CBCBC180DBB6EDE8D71570891E898075A4A84D48E007AFFBABBDD7A19194140A2832CFE96A1B3D4" client = Client(TOKEN) history = client.operation_history(label=label) if not history.operations: return False for operation in history.operations: if operation.status == 'success': return True return False except Exception as e: print(f"Ошибка при проверке платежа ЮMoney: {e}") return False @dp.callback_query_handler(text="topup", state="*") async def topup_msg(call: types.CallbackQuery, state: FSMContext): await state.update_data(cl=call) text = '<b> Введите сумму пополнения:\n\n❗ Минимальная сумма 100₽ </b>' await call.message.edit_caption( caption=text, reply_markup=await user_back_profile(), ) await Topup.sum.set() @dp.message_handler(state=Topup.sum) async def Topup_sum_state(msg: types.Message, state: FSMContext): data = await state.get_data() cl = data["cl"] await bot.delete_message(chat_id=msg.from_user.id, message_id=msg.message_id) try: message_text = float(msg.text) if message_text > 10000: await cl.message.edit_caption( caption="<b>❗ Максимальная сумма пополнения: 10.000₽.</b>", reply_markup=await back_profile_menu(), ) await state.finish() return if message_text < 100: await cl.message.edit_caption( caption="<b>❗ Минимальная сумма пополнения: 100₽.</b>", reply_markup=await back_profile_menu(), ) await state.finish() return if message_text <= 0: await cl.message.edit_caption( caption="<b>❗ Введите допустимую сумму.</b>", reply_markup=await back_profile_menu(), ) await state.finish() return topup_sum_rub = message_text await state.update_data(topup_sum_rub=topup_sum_rub) text = '<b> Выберите способ пополнения!</b>\n\n❗<b>Если какая то из платежек выдает ошибку при пополнении бота:</b>\n\n<u>✅ Вы так же можете сделать перевод напрямую через СБП.</u>\n\n <b>+7 (967) 777 85-38 ОЗОН БАНК</b>\n В комментарии обязательно укажите ваш уникальный <a href="https://t.me//username_to_id_bot">Id телеграмм</a>' await cl.message.edit_caption( caption=text, reply_markup=await payment_currency_menu(), ) await Topup.currency.set() except ValueError: await cl.message.edit_caption( caption="<b> Вводите только цифры</b>", reply_markup=await back_profile_menu(), ) await state.finish() @dp.callback_query_handler(filters.Text(startswith='method:'), state=Topup.currency) async def top_up_methods(call: types.CallbackQuery, state: FSMContext): data = await state.get_data() topup_sum_rub = data["topup_sum_rub"] method = call.data.split(':')[1] template_text = '<b> Пополнение через {0}</>\n\n' \ '<i>Для депозита средств откройте ссылку ниже и оплатите выставленный для вас счет, оплатить можно любым доступным способом, Важно при замене любых параметров пополнения, он засчитан не будет!</>\n\n' \ '<b> ID платежа: <code>{1}</>\n' \ ' Сумма к оплате: {2}{3}</b>' if method == 'lolzteam': lolz_username = await Config.get('lolzUsername') comment = comment_generation(call.message.from_user.id) amount_usd = topup_sum_rub / convert_usd_to_rub(1) text = template_text.format('zelenka.guru', comment, topup_sum_rub, '₽') pay_url = f"https://zelenka.guru/market/balance/transfer?username={lolz_username}&amount={topup_sum_rub}&comment={comment}" await call.message.edit_caption( caption=text, reply_markup=await lolz_payment_kb(pay_url, comment, amount_usd, topup_sum_rub) ) await state.finish() elif method == 'cryptobot': await call.message.edit_caption('<b> Выберите способ оплаты:</>', reply_markup=cryptobot_currency()) elif method == 'aaio': bill = await aaio_create_invoice(topup_sum_rub) text = template_text.format('aaio.so', bill['bill_id'], topup_sum_rub, '₽') kb = await check_aaio(bill['pay_url'], amount=topup_sum_rub, invoice_id=bill['bill_id']) await call.message.edit_caption(text, reply_markup=kb) await state.finish() elif method == 'lava': order_id = f"order-{int(time.time())}" pay_url, invoice_id = await create_lava_invoice(topup_sum_rub, order_id) if pay_url: text = ( f"<b> Пополнение через Lava</b>\n\n" f"<i>Для депозита средств нажмите кнопку 'Оплатить' и следуйте инструкциям.</i>\n\n" f" Сумма к оплате: {topup_sum_rub}₽" ) keyboard = types.InlineKeyboardMarkup() keyboard.add(types.InlineKeyboardButton("Оплатить", url=pay_url)) keyboard.add(types.InlineKeyboardButton("Проверить оплату", callback_data=f"check_lava:{invoice_id}")) keyboard.add(types.InlineKeyboardButton(text='❌ Отменить', callback_data='back')) await call.message.edit_caption(caption=text, reply_markup=keyboard) else: await call.message.edit_caption( caption="❌ Ошибка при создании счета.", reply_markup=await back_profile_menu() ) await state.finish() elif method == 'yoomoney': order_id = f"order-{int(time.time())}" pay_url, invoice_id = await create_yoomoney_invoice(topup_sum_rub, order_id) if pay_url: text = ( f"<b> Пополнение через ЮMoney</b>\n\n" f"<i>Для депозита средств нажмите кнопку 'Оплатить' и следуйте инструкциям.</i>\n\n" f" Сумма к оплате: {topup_sum_rub}₽" ) keyboard = types.InlineKeyboardMarkup() keyboard.add(types.InlineKeyboardButton("Оплатить", url=pay_url)) keyboard.add(types.InlineKeyboardButton("Проверить оплату", callback_data=f"check_yoomoney:{invoice_id}:{topup_sum_rub}")) # Добавляем сумму в callback_data keyboard.add(types.InlineKeyboardButton(text='❌ Отменить', callback_data='back')) await call.message.edit_caption(caption=text, reply_markup=keyboard) else: await call.message.edit_caption( caption="❌ Ошибка при создании счета.", reply_markup=await back_profile_menu() ) await state.finish() @dp.callback_query_handler(lambda call: call.data.startswith("add_funds|lolz|"), state="*") async def check_lolz_payment(call: types.CallbackQuery, state: FSMContext): lolz_token, lolz_id = await Config.get('lolzToken'), await Config.get("lolzId") **** = await Config.get('logsId') api = LolzteamApi(lolz_token, lolz_id) data = call.data.split("|") amount_usd = data[2] comment = data[3] amount_rub = int(data[4]) check_paym = api.market_payments( type_="income", pmin=amount_rub, pmax=amount_rub, comment=comment )["payments"] if check_paym: await call.message.answer( f"✅ Успешно, ваш платеж найден, баланс пополнен на <b>{amount_rub} RUB / {amount_usd} USD при помощи LolzPay</b>.", reply_markup=await delete_msg_menu(), ) await call.message.edit_caption( caption=f"<b> Добро пожаловать {call.from_user.get_mention()}.</b>", reply_markup=await main_menu(call.from_user.id), ) user_id = call.from_user.id user = await get_user(user_id) plused_amount = int(user[1]) + int(amount_usd) await edit_user_balance(int(user_id), int(plused_amount)) await bot.send_message( ****, text=f"<b>✅ Новое пополнение\n\n◽ Пользователь: {call.from_user.get_mention()}\n◽ ЮзерID: {user_id}\n◽ Сумма: {amount_usd} $\n◽ Система: LZT\n</b>", ) else: await call.message.answer( f" <b>Ваш платеж не найден</>. Попробуйте проверить позже или обратитесь в поддержку, если средства не были зачислены.", reply_markup=await delete_msg_menu(), ) @dp.callback_query_handler(text_startswith="check_crypto_bot") async def check_crypto_bot_funds(call: types.CallbackQuery): **** = await Config.get('logsId') try: amount_usd_str = call.data.split("|")[2] amount_usd = float(amount_usd_str) topup_sum_rub = amount_usd * convert_usd_to_rub(1) if await check_crypto_bot_invoice(int(call.data.split("|")[1])): user_id = call.from_user.id user = await get_user(user_id) new_balance = float(user["balance"]) + float(topup_sum_rub) await edit_user_balance(user_id, new_balance) referrer_id = user["referrer_id"] if referrer_id: print(f"Начисление бонуса для реферера {referrer_id}") referral_bonus = topup_sum_rub * 0.2 referrer = await get_user(referrer_id) if referrer: new_referrer_balance = float(referrer["balance"]) + referral_bonus await edit_user_balance(referrer_id, new_referrer_balance) print(f"Бонус {referral_bonus}₽ начислен рефереру {referrer_id}") await bot.send_message( referrer_id, f" Ваш реферал {call.from_user.get_mention()} пополнил баланс на {topup_sum_rub:.2f}₽.\n" f" Вы получили реферальный бонус: {referral_bonus:.2f}₽!" ) await bot.answer_callback_query( call.id, f'✅ Счет успешно оплачен + {topup_sum_rub:.2f}₽' ) await call.message.answer( f"✅ Успешно, ваш платеж найден, баланс пополнен на <b>{topup_sum_rub:.2f} ₽</b> при помощи CryptoPay", reply_markup=await delete_msg_menu() ) await call.message.edit_caption( caption=f"<b> Добро пожаловать {call.from_user.get_mention()}.</b>", reply_markup=await main_menu(call.from_user.id) ) await bot.send_message( ****, text=f'<b>✅ Новое пополнение\n\n◽ Пользователь: {call.from_user.get_mention()}\n◽ ЮзерID: {user_id}\n◽ Сумма: {topup_sum_rub:.2f} ₽\n◽ Система: CryptoBot\n</b>' ) else: await bot.answer_callback_query(call.id, "❗ Оплата не найдена") except ValueError as ve: await bot.answer_callback_query(call.id, f"❗ Ошибка: {str(ve)}") except Exception as e: print(f"Произошла ошибка: {e}") @dp.callback_query_handler(text_startswith="check_yoomoney", state="*") async def check_yoomoney_payment(call: types.CallbackQuery): **** = await Config.get('logsId') try: invoice_id = call.data.split(":")[1] amount_rub = float(call.data.split(":")[2]) # Добавляем сумму в callback_data if await check_yoomoney_invoice(invoice_id): user_id = call.from_user.id user = await get_user(user_id) new_balance = float(user["balance"]) + amount_rub await edit_user_balance(user_id, new_balance) referrer_id = user["referrer_id"] if referrer_id: print(f"Начисление бонуса для реферера {referrer_id}") referral_bonus = amount_rub * 0.2 referrer = await get_user(referrer_id) if referrer: new_referrer_balance = float(referrer["balance"]) + referral_bonus await edit_user_balance(referrer_id, new_referrer_balance) print(f"Бонус {referral_bonus}₽ начислен рефереру {referrer_id}") await bot.send_message( referrer_id, f" Ваш реферал {call.from_user.get_mention()} пополнил баланс на {amount_rub:.2f}₽.\n" f" Вы получили реферальный бонус: {referral_bonus:.2f}₽!" ) await bot.answer_callback_query( call.id, f'✅ Счет успешно оплачен + {amount_rub:.2f}₽' ) await call.message.answer( f"✅ Успешно, ваш платеж найден, баланс пополнен на <b>{amount_rub:.2f} ₽</b> при помощи ЮMoney", reply_markup=await delete_msg_menu() ) await call.message.edit_caption( caption=f"<b> Добро пожаловать {call.from_user.get_mention()}.</b>", reply_markup=await main_menu(call.from_user.id) ) await bot.send_message( ****, text=f'<b>✅ Новое пополнение\n\n◽ Пользователь: {call.from_user.get_mention()}\n◽ ЮзерID: {user_id}\n◽ Сумма: {amount_rub:.2f} ₽\n◽ Система: ЮMoney\n</b>' ) else: await bot.answer_callback_query(call.id, "❗ Оплата не найдена") except ValueError as ve: await bot.answer_callback_query(call.id, f"❗ Ошибка: {str(ve)}") except Exception as e: print(f"Произошла ошибка: {e}") @dp.callback_query_handler(text_startswith="check_lava", state="*") async def check_lava_payment(call: types.CallbackQuery): invoice_id = call.data.split(":")[1] **** = await Config.get('logsId') response_data = await check_lava_invoice(invoice_id) if response_data and response_data.get("status") == 0: user_id = call.from_user.id user = await get_user(user_id) topup_sum_rub = float(response_data['data']['amount']) new_balance = float(user["balance"]) + topup_sum_rub await edit_user_balance(user_id, new_balance) referrer_id = user["referrer_id"] if referrer_id: referral_bonus = topup_sum_rub * 0.2 referrer = await get_user(referrer_id) if referrer: new_referrer_balance = float(referrer["balance"]) + referral_bonus await edit_user_balance(referrer_id, new_referrer_balance) await bot.send_message( referrer_id, f" Ваш реферал {call.from_user.get_mention()} пополнил баланс на {topup_sum_rub}₽.\n" f" Вы получили реферальный бонус: {referral_bonus}₽!" ) await bot.answer_callback_query( call.id, f'✅ Счет успешно оплачен + {topup_sum_rub}₽' ) await call.message.answer( f"✅ Успешно, ваш платеж найден, баланс пополнен на <b>{topup_sum_rub} ₽</b> при помощи Lava", reply_markup=await delete_msg_menu() ) await call.message.edit_caption( caption=f"<b> Добро пожаловать {call.from_user.get_mention()}.</b>", reply_markup=await main_menu(call.from_user.id) ) await bot.send_message( ****, text=f'<b>✅ Новое пополнение\n\n◽ Пользователь: {call.from_user.get_mention()}\n◽ ЮзерID: {user_id}\n◽ Сумма: {topup_sum_rub} ₽\n◽ Система: Lava\n</b>' ) else: await bot.answer_callback_query(call.id, "❗ Оплата не найдена") @dp.callback_query_handler(text_startswith="check_aaio") async def check_aaio_payment(call: types.CallbackQuery): try: bill_id = call.data.split("|")[1] amount = float(call.data.split("|")[2]) **** = await Config.get('logsId') if (await aaio_check_invoice(bill_id)).get('success'): user_id = call.from_user.id user = await get_user(user_id) new_balance = float(user["balance"]) + amount await edit_user_balance(user_id, new_balance) referrer_id = user["referrer_id"] if referrer_id: referral_bonus = amount * 0.2 referrer = await get_user(referrer_id) if referrer: new_referrer_balance = float(referrer["balance"]) + referral_bonus await edit_user_balance(referrer_id, new_referrer_balance) await bot.send_message( referrer_id, f" Ваш реферал {call.from_user.get_mention()} пополнил баланс на {amount}₽.\n" f" Вы получили реферальный бонус: {referral_bonus}₽!" ) await bot.answer_callback_query( call.id, f'✅ Счет успешно оплачен + {amount}₽' ) await call.message.answer( f"✅ Успешно, ваш платеж найден, баланс пополнен на <b>{amount} ₽</b> при помощи aaio.so", reply_markup=await delete_msg_menu() ) await call.message.edit_caption( caption=f"<b> Добро пожаловать {call.from_user.get_mention()}.</b>", reply_markup=await main_menu(call.from_user.id) ) await bot.send_message( ****, text=f'<b>✅ Новое пополнение\n\n◽ Пользователь: {call.from_user.get_mention()}\n◽ ЮзерID: {user_id}\n◽ Сумма: {amount} ₽\n◽ Система: aaio.so\n</b>' ) else: await bot.answer_callback_query(call.id, "❗ Оплата не найдена") except Exception as e: print(f"Ошибка при проверке платежа aaio: {e}") await bot.answer_callback_query(call.id, "❗ Произошла ошибка при проверке") async def payment_currency_menu(): keyboard = types.InlineKeyboardMarkup() keyboard.add( types.InlineKeyboardButton(" Карты / Юмани", callback_data="method:yoomoney"), types.InlineKeyboardButton(" LolzTeam", callback_data="method:lolzteam") ) keyboard.add( types.InlineKeyboardButton(" CryptoBot", callback_data="method:cryptobot"), #types.InlineKeyboardButton("AAIO.SO", callback_data="method:aaio") ) #keyboard.add( # types.InlineKeyboardButton("Lava", callback_data="method:lava") # ) keyboard.add( types.InlineKeyboardButton("❌ Отменить", callback_data="back") ) return keyboard