Интеграция оплаты Юкасса в telegramm для самозанятых

Привет тем кто хочет опробовать себя в качестве бизнесмена! Недавно в голову пришла идея, получить некоторый опыт предпринимательства. В качестве продукта выступает доступ к некоторой цифровой услуге, а контроль за оплатой этой услуги ложиться на плечи телеграмм бота. В ходе поисков системы оплаты была найдена Юкасса, одна из немногих систем (если вообще не единственная), которая работает с самозанятыми.

На сайте подробно описана интеграция оплаты в telegramm бота. Однако на этапе подписания документов выясняется что интеграция недоступна для самозанятых.

Обидно, но других вариантов оплаты самозанятому найти не удалось, поэтому решено было попробовать написать собственный вариант оплаты. В ходе беглого гугления, не удалось найти готовых решений по самостоятельной реализации оплаты, чему я был сильно огорчен, так-как это скорее всего означало большую сложность собственноручной реализации оплаты. Но так-как, бот был уже готов, я решил попробовать какие-то ещё варианты. Изначально я не думал делать собственную интеграцию, а хотел выставлять многоразовые счета, а потом по примечанию к платежу отслеживать успешные оплаты. Однако, оказалось что интеграция оплаты реализуется гораздо проще, и по факту, в самом дубовом варианте без веб хуков, состоит всего из двух функций.

Интеграция для самозанятых

Реализовать оплату услуг самозанятого можно через сайт юкассы. Я это реализовал следующим образом: клиент запрашивает в боте услугу, в ответ ему приходит ссылка на оплату, клиент переходит и оплачивает товар, после чего его перенаправляет обратно в бот. Обработка же платежа работает следующим образом: как только создается ссылка на оплату, бот запрашивает статус платежа, до тех пор пока статус является «pending». Как только статус меняется на «succeeded» бот выполняет действие (отправляет товар/оказывает услугу и тд).

Для реализации такой схемы необходим модуль yookassa откуда мы возьмем классы Configuration и Payment. Далее необходимо заполнить два поля класса Configuration: Configuration.account_id и Configuration.secret_key , в первый записываем id магазина, во второй api ключ магазина.

import json from yookassa import Configuration,Payment import config  Configuration.account_id = config.SHOP_ID Configuration.secret_key = config.SHOP_API_TOKEN

Далее с помощью метода Payment.create , необходимо создать объект платежа. При создании этот метод сам отправит данные в юкассу.

import json from yookassa import Configuration,Payment import config  Configuration.account_id = config.SHOP_ID Configuration.secret_key = config.SHOP_API_TOKEN  payment = Payment.create({     "amount": {         "value": сумма платежа,         "currency": "RUB"     },     "payment_method_data": {         "type": "bank_card"     },     "confirmation": {         "type": "redirect",         "return_url": "Ссылка, куда перенаправить после совершения платежа"     },     "capture": True,     "description": description })

Платеж создан, теперь необходимо получить id операции (понадобиться позже) и ссылку на оплату, которую мы и отправим пользователю. Для этого воспользуемся методом json(), который запросит данные по платежу на сервере юкассы и вернет их в формате json. Для удобства преобразуем json в словарь python :

import json from yookassa import Configuration,Payment import config  Configuration.account_id = config.SHOP_ID Configuration.secret_key = config.SHOP_API_TOKEN  payment = Payment.create({     "amount": {         "value": сумма платежа,         "currency": "RUB"     },     "payment_method_data": {         "type": "bank_card"     },     "confirmation": {         "type": "redirect",         "return_url": "Ссылка, куда перенаправить после совершения платежа"     },     "capture": True,     "description": description })         payment_data = json.loads(payment.json())   payment_id = payment_data['id']   payment_url = (payment_data['confirmation'])['confirmation_url']

Теперь можно отправить payment_url пользователю, по которому он сможет оплатить товар. Однако мы пока не знаем оплатил пользователь товар или нет. Для получения статуса платежа реализуем метод Payment.find_one(payment_id)).json(), которые найдет платеж по указанному id (который мы получили на прошлом шаге) и пришлет его статус в формате json. Далее мы будем опрашивать этот метод до тех пор пока статус платежа не измениться с pending на успешный / не успешный.

import json from yookassa import Configuration,Payment import config import time  Configuration.account_id = config.SHOP_ID Configuration.secret_key = config.SHOP_API_TOKEN  payment = Payment.create({     "amount": {         "value": сумма платежа,         "currency": "RUB"     },     "payment_method_data": {         "type": "bank_card"     },     "confirmation": {         "type": "redirect",         "return_url": "Ссылка, куда перенаправить после совершения платежа"     },     "capture": True,     "description": description })         payment_data = json.loads(payment.json())   payment_id = payment_data['id']   payment_url = (payment_data['confirmation'])['confirmation_url']      payment = json.loads((Payment.find_one(payment_id)).json())   while payment['status'] == 'pending': payment = json.loads((Payment.find_one(payment_id)).json()) time.sleep(время между опросами)   

Теперь при успешной оплате или таймауте операции (что-то около 15 минут), мы выйдем из цикла, однако здесь существует огромная проблема, с тем, что если вызывать эти методы из бота, бот будет заблокирован на весь период оплаты. Чтобы избежать подобного поведения будем использовать асинхронный sleep. А также реализуем логику оплаты в виде двух функций: создания и проверки статуса платежа

import json from yookassa import Configuration,Payment import config import asyncio  Configuration.account_id = config.SHOP_ID Configuration.secret_key = config.SHOP_API_TOKEN  def payment(value,description): payment = Payment.create({     "amount": {         "value": value,         "currency": "RUB"     },     "payment_method_data": {         "type": "bank_card"     },     "confirmation": {         "type": "redirect",         "return_url": "урл редиректа"     },     "capture": True,     "description": description })  return json.loads(payment.json())  async def check_payment(payment_id): payment = json.loads((Payment.find_one(payment_id)).json()) while payment['status'] == 'pending': payment = json.loads((Payment.find_one(payment_id)).json()) await asyncio.sleep(3)  if payment['status']=='succeeded': print("SUCCSESS RETURN") print(payment) return True else: print("BAD RETURN") print(payment) return False

Теперь посмотрим как это может выглядеть в боте (aiogram)

import json from aiogram import Bot, Dispatcher, executor, types, filters from yookassa import Configuration,Payment import payment import config   API_TOKEN = config.API_TOKEN BASE=config.BASE REFBASE=config.REFBASE CURRENT_ENDPOINT=config.CURRENT_ENDPOINT   #--- buttons --- btnbuy = types.KeyboardButton("купить") btnprologue = types.KeyboardButton("продлить") btnstatus = types.KeyboardButton("статус") btnsinfo = types.KeyboardButton("инфо")  mainmenu=types.ReplyKeyboardMarkup(resize_keyboard = True).add(btnbuy,btnprologue,btnstatus,btnsinfo)  # Initialize bot and dispatcher bot = Bot(token=API_TOKEN) dp = Dispatcher(bot)  @dp.message_handler(commands=['start']) async def send_welcome(message: types.Message): await message.answer("Hello", reply_markup = mainmenu)   @dp.message_handler(commands=['info']) async def info(message: types.Message): await message.answer("info", disable_web_page_preview=True)  @dp.message_handler(commands=['buy']) async def BuyVPNforMonth(message: types.Message): await message.answer(msg.buy_message) payment_deatils = payment.payment(100,'Купить товар1') await message.answer( (payment_deatils['confirmation'])['confirmation_url'] ) if await payment.check_payment(payment_deatils['id']):     message.answer("платеж")  else: message.answer("платеж не прошел")  @dp.message_handler() async def menu_message(message: types.Message): if message.text == "купить": await BuyVPNforMonth(message) if message.text == "инфо": await info(message)  if __name__ == '__main__':     executor.start_polling(dp, skip_updates=True)

Пример работы бота, с интеграцией оплаты, можно посмотреть здесь