Small fixes
This commit is contained in:
@@ -4,11 +4,11 @@ from aiohttp import web
|
||||
from database import add_payment, async_session_maker, update_balance
|
||||
from handlers.payments.utils import send_payment_success_notification
|
||||
from handlers.payments.kassai import verify_kassai_signature
|
||||
from aiogram.fsm.context import FSMContext
|
||||
from aiogram.fsm.storage.base import StorageKey
|
||||
from config import KASSAI_SECRET_KEY, KASSAI_SHOP_ID
|
||||
from logger import logger
|
||||
import bot
|
||||
|
||||
# Хранилище обработанных платежей для предотвращения дублирования
|
||||
processed_payments = set()
|
||||
|
||||
|
||||
@@ -60,12 +60,7 @@ async def kassai_payment_webhook(request: web.Request):
|
||||
await send_payment_success_notification(tg_id, amount_float, session)
|
||||
await add_payment(session, tg_id, amount_float, "kassai")
|
||||
|
||||
# Попытка удалить сообщение с кнопкой оплаты
|
||||
try:
|
||||
from aiogram.fsm.context import FSMContext
|
||||
from aiogram.fsm.storage.base import StorageKey
|
||||
|
||||
# Получаем данные из FSM state пользователя
|
||||
storage_key = StorageKey(bot_id=bot.bot.id, chat_id=tg_id, user_id=tg_id)
|
||||
state_data = await bot.dp.storage.get_data(storage_key)
|
||||
|
||||
@@ -77,7 +72,6 @@ async def kassai_payment_webhook(request: web.Request):
|
||||
except Exception as e:
|
||||
logger.warning(f"Could not delete payment message for user {tg_id}: {e}")
|
||||
|
||||
# Очищаем state после успешной оплаты
|
||||
await bot.dp.storage.set_state(storage_key, None)
|
||||
await bot.dp.storage.set_data(storage_key, {})
|
||||
except Exception as e:
|
||||
|
||||
Reference in New Issue
Block a user