first commit

.gitignore

@@ -0,0 +1,162 @@
+# Byte-compiled / optimized / DLL files
+__pycache__/
+*.py[cod]
+*$py.class
+
+# C extensions
+*.so
+
+# Distribution / packaging
+.Python
+build/
+develop-eggs/
+dist/
+downloads/
+eggs/
+.eggs/
+lib/
+lib64/
+parts/
+sdist/
+var/
+wheels/
+share/python-wheels/
+*.egg-info/
+.installed.cfg
+*.egg
+MANIFEST
+
+# PyInstaller
+#  Usually these files are written by a python script from a template
+#  before PyInstaller builds the exe, so as to inject date/other infos into it.
+*.manifest
+*.spec
+
+# Installer logs
+pip-log.txt
+pip-delete-this-directory.txt
+
+# Unit test / coverage reports
+htmlcov/
+.tox/
+.nox/
+.coverage
+.coverage.*
+.cache
+nosetests.xml
+coverage.xml
+*.cover
+*.py,cover
+.hypothesis/
+.pytest_cache/
+cover/
+
+# Translations
+*.mo
+*.pot
+
+# Django stuff:
+*.log
+local_settings.py
+db.sqlite3
+db.sqlite3-journal
+
+# Flask stuff:
+instance/
+.webassets-cache
+
+# Scrapy stuff:
+.scrapy
+
+# Sphinx documentation
+docs/_build/
+
+# PyBuilder
+.pybuilder/
+target/
+
+# Jupyter Notebook
+.ipynb_checkpoints
+
+# IPython
+profile_default/
+ipython_config.py
+
+# pyenv
+#   For a library or package, you might want to ignore these files since the code is
+#   intended to run in multiple environments; otherwise, check them in:
+# .python-version
+
+# pipenv
+#   According to pypa/pipenv#598, it is recommended to include Pipfile.lock in version control.
+#   However, in case of collaboration, if having platform-specific dependencies or dependencies
+#   having no cross-platform support, pipenv may install dependencies that don't work, or not
+#   install all needed dependencies.
+#Pipfile.lock
+
+# poetry
+#   Similar to Pipfile.lock, it is generally recommended to include poetry.lock in version control.
+#   This is especially recommended for binary packages to ensure reproducibility, and is more
+#   commonly ignored for libraries.
+#   https://python-poetry.org/docs/basic-usage/#commit-your-poetrylock-file-to-version-control
+#poetry.lock
+
+# pdm
+#   Similar to Pipfile.lock, it is generally recommended to include pdm.lock in version control.
+#pdm.lock
+#   pdm stores project-wide configurations in .pdm.toml, but it is recommended to not include it
+#   in version control.
+#   https://pdm.fming.dev/#use-with-ide
+.pdm.toml
+
+# PEP 582; used by e.g. github.com/David-OConnor/pyflow and github.com/pdm-project/pdm
+__pypackages__/
+
+# Celery stuff
+celerybeat-schedule
+celerybeat.pid
+
+# SageMath parsed files
+*.sage.py
+
+# Environments
+.env
+.venv
+env/
+venv/
+ENV/
+env.bak/
+venv.bak/
+
+# Spyder project settings
+.spyderproject
+.spyproject
+
+# Rope project settings
+.ropeproject
+
+# mkdocs documentation
+/site
+
+# mypy
+.mypy_cache/
+.dmypy.json
+dmypy.json
+
+# Pyre type checker
+.pyre/
+
+# pytype static type analyzer
+.pytype/
+
+# Cython debug symbols
+cython_debug/
+
+# PyCharm
+#  JetBrains specific template is maintained in a separate JetBrains.gitignore that can
+#  be found at https://github.com/github/gitignore/blob/main/Global/JetBrains.gitignore
+#  and can be added to the global gitignore or merged into this file.  For a more nuclear
+#  option (not recommended) you can uncomment the following to ignore the entire idea folder.
+.idea/
+
+database.ini

.idea/bot_two.iml

@@ -0,0 +1,10 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<module type="PYTHON_MODULE" version="4">
+  <component name="NewModuleRootManager">
+    <content url="file://$MODULE_DIR$">
+      <excludeFolder url="file://$MODULE_DIR$/.venv" />
+    </content>
+    <orderEntry type="inheritedJdk" />
+    <orderEntry type="sourceFolder" forTests="false" />
+  </component>
+</module>

.idea/inspectionProfiles/Project_Default.xml

@@ -0,0 +1,31 @@
+<component name="InspectionProjectProfileManager">
+  <profile version="1.0">
+    <option name="myName" value="Project Default" />
+    <inspection_tool class="JsonStandardCompliance" enabled="false" level="ERROR" enabled_by_default="false" />
+    <inspection_tool class="LossyEncoding" enabled="false" level="WARNING" enabled_by_default="false" />
+    <inspection_tool class="PoetryPackageVersionsInspection" enabled="false" level="WARNING" enabled_by_default="false" />
+    <inspection_tool class="PyAugmentAssignmentInspection" enabled="true" level="WEAK WARNING" enabled_by_default="true" />
+    <inspection_tool class="PyPackageRequirementsInspection" enabled="false" level="WARNING" enabled_by_default="false">
+      <option name="ignoredPackages">
+        <value>
+          <list size="0" />
+        </value>
+      </option>
+    </inspection_tool>
+    <inspection_tool class="PyPep8Inspection" enabled="true" level="WEAK WARNING" enabled_by_default="true">
+      <option name="ignoredErrors">
+        <list>
+          <option value="E302" />
+          <option value="E303" />
+        </list>
+      </option>
+    </inspection_tool>
+    <inspection_tool class="PyUnresolvedReferencesInspection" enabled="true" level="WARNING" enabled_by_default="true">
+      <option name="ignoredIdentifiers">
+        <list>
+          <option value="str.*" />
+        </list>
+      </option>
+    </inspection_tool>
+  </profile>
+</component>

.idea/inspectionProfiles/profiles_settings.xml

@@ -0,0 +1,6 @@
+<component name="InspectionProjectProfileManager">
+  <settings>
+    <option name="USE_PROJECT_PROFILE" value="false" />
+    <version value="1.0" />
+  </settings>
+</component>

.idea/misc.xml

@@ -0,0 +1,4 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ProjectRootManager" version="2" project-jdk-name="Python 3.12 (bot_two)" project-jdk-type="Python SDK" />
+</project>

.idea/modules.xml

@@ -0,0 +1,8 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ProjectModuleManager">
+    <modules>
+      <module fileurl="file://$PROJECT_DIR$/.idea/bot_two.iml" filepath="$PROJECT_DIR$/.idea/bot_two.iml" />
+    </modules>
+  </component>
+</project>

.idea/vcs.xml

@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="VcsDirectoryMappings">
+    <mapping directory="$PROJECT_DIR$" vcs="Git" />
+  </component>
+</project>

.idea/workspace.xml

@@ -0,0 +1,47 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ChangeListManager">
+    <list default="true" id="de848e3e-3eff-4947-8a5d-ce39775caa4e" name="Changes" comment="" />
+    <option name="SHOW_DIALOG" value="false" />
+    <option name="HIGHLIGHT_CONFLICTS" value="true" />
+    <option name="HIGHLIGHT_NON_ACTIVE_CHANGELIST" value="false" />
+    <option name="LAST_RESOLUTION" value="IGNORE" />
+  </component>
+  <component name="Git.Settings">
+    <option name="RECENT_GIT_ROOT_PATH" value="$PROJECT_DIR$" />
+  </component>
+  <component name="ProjectColorInfo"><![CDATA[{
+  "associatedIndex": 4
+}]]></component>
+  <component name="ProjectId" id="2ke8A1I5QhI8zfcxop4yKYuEcO5" />
+  <component name="ProjectLevelVcsManager" settingsEditedManually="true" />
+  <component name="ProjectViewState">
+    <option name="hideEmptyMiddlePackages" value="true" />
+    <option name="showLibraryContents" value="true" />
+  </component>
+  <component name="PropertiesComponent"><![CDATA[{
+  "keyToString": {
+    "RunOnceActivity.OpenProjectViewOnStart": "true",
+    "RunOnceActivity.ShowReadmeOnStart": "true",
+    "git-widget-placeholder": "main"
+  }
+}]]></component>
+  <component name="SharedIndexes">
+    <attachedChunks>
+      <set>
+        <option value="bundled-python-sdk-67fca87a943a-d3b881c8e49f-com.jetbrains.pycharm.community.sharedIndexes.bundled-PC-233.11799.259" />
+      </set>
+    </attachedChunks>
+  </component>
+  <component name="SpellCheckerSettings" RuntimeDictionaries="0" Folders="0" CustomDictionaries="0" DefaultDictionary="application-level" UseSingleDictionary="true" transferred="true" />
+  <component name="TaskManager">
+    <task active="true" id="Default" summary="Default task">
+      <changelist id="de848e3e-3eff-4947-8a5d-ce39775caa4e" name="Changes" comment="" />
+      <created>1723632534810</created>
+      <option name="number" value="Default" />
+      <option name="presentableId" value="Default" />
+      <updated>1723632534810</updated>
+    </task>
+    <servers />
+  </component>
+</project>

Dockerfile

@@ -0,0 +1,17 @@
+# используем базовый образ Python версии 3
+FROM python:3
+
+# устанавливаем рабочую директорию внутри контейнера
+WORKDIR /code
+
+# копируем файл с зависимостями проекта в рабочую директорию внутри контейнера
+COPY ./requirements.txt .
+
+# устанавливаем зависимости внутри контейнера
+RUN pip install -r requirements.txt
+
+# копируем код приложения из текущей папки в рабочую директорию внутри контейнера
+COPY . .
+
+#команда для запуска django-приложения из контейнера
+CMD ["python", "manage.py", "runserver", "0.0.0.0:8000"]

bot.py

@@ -0,0 +1,511 @@
+import os
+
+from aiogram import types, F, Router
+from aiogram.filters import Command
+from aiogram.fsm.context import FSMContext
+
+from database_queries import (presence_user_bd, adding_user_db, update_user_db, user_search, getting_course,
+                              installation_zero_question, installation_one_question, status_question,
+                              write_hash_to_table, search_hash_in_table, number_of_streams_from_subscriptions,
+                              number_of_threads_from_threads, get_user_data, subscription_entry,
+                              subscription_end_record, check_expired_subscriptions)
+from main import bot_chat
+import qrcode
+from utils import create_connection, get_contract_ret_tron, get_contract_ret_arbitrum, payment_order_yukassa, \
+    check_payment_status
+from states import QuestionStates
+
+router = Router()
+
+
+# Словарь для хранения состояния пользователя
+user_states = {}
+
+
+@router.message(Command("start"))
+async def cmd_start(message: types.Message):
+    """ Основное меню """
+    photo = types.FSInputFile("1_IMAGE.png")
+    user_id = message.from_user.id
+    username = message.from_user.username or "No name"
+    conn = create_connection()
+    cursor = conn.cursor()
+    result = presence_user_bd(user_id)
+    if result is None:
+        adding_user_db(user_id, username)
+    keyboard = types.InlineKeyboardMarkup(
+        row_width=1,
+        inline_keyboard=[
+            [types.InlineKeyboardButton(text="Купить подписку", callback_data="buy_subscription")],
+            [types.InlineKeyboardButton(text="FAQ блок", callback_data="faq_block"),
+             types.InlineKeyboardButton(text="Моя подписка", callback_data="my_subscription")],
+            [types.InlineKeyboardButton(text="Задать вопрос", callback_data="ask_question")], ], )
+    # Отправляем меню пользователю
+    await message.reply_photo(photo=photo, reply_markup=keyboard)
+
+
+@router.callback_query(F.data == "buy_subscription")
+async def handle_buy_subscription(callback_query: types.CallbackQuery):
+    """ Выбор подписки или потоков """
+    await callback_query.message.delete()
+    keyboard = types.InlineKeyboardMarkup(row_width=1, inline_keyboard=[
+            [types.InlineKeyboardButton(text="Купить подписку на 1 мес.", callback_data="buy_1_month")],
+            [types.InlineKeyboardButton(text="Купить подписку на 2 мес.", callback_data="buy_2_month")],
+            [types.InlineKeyboardButton(text="Купить подписку на 3 мес.", callback_data="buy_3_month")],
+            [types.InlineKeyboardButton(text="Увеличение потоков.", callback_data="increase_flow")],
+            [types.InlineKeyboardButton(text="Обратно в меню", callback_data="back_to_menu")],],)
+    # Отправляем подменю пользователю
+    await callback_query.message.answer("Выберите срок подписки:", reply_markup=keyboard)
+
+
+@router.callback_query(F.data == "increase_flow")
+async def handle_increase_flow(callback_query: types.CallbackQuery, state: FSMContext):
+    """ Получение от пользователя количество потоков """
+    await state.set_state(QuestionStates.count_flow)
+    user_id = callback_query.from_user.id
+    if user_id not in user_states:  # Проверка на существование состояния пользователя
+        user_states[user_id] = {}  # Инициализация состояния пользователя
+    await callback_query.message.delete()
+    msg_to_delete = await callback_query.message.answer("Введите количество потоков:",
+                                        reply_markup=types.InlineKeyboardMarkup(row_width=1, inline_keyboard=[
+                                            [types.InlineKeyboardButton(text="Изменить",
+                                                                        callback_data="buy_subscription")]]))
+    await state.update_data(msg_to_delete=msg_to_delete)
+
+
+@router.message(QuestionStates.count_flow)
+async def handle_flow_count(message: types.Message, state: FSMContext):
+    """ Подтверждение покупки указанных потоков от пользователя """
+    await message.delete()
+    data = await state.get_data()
+    msg_to_delete = data.get('msg_to_delete')
+
+    if msg_to_delete:
+        try:
+            await msg_to_delete.delete()
+        except:
+            pass
+    user_id = message.from_user.id
+    user_states.setdefault(user_id, {})  # Инициализация состояния пользователя с помощью setdefault
+    if message.text.isdigit():
+        flow_count = int(message.text)
+        user_states[user_id] = flow_count  # Сохранение количества потоков
+        total_price_usd = flow_count * 2
+        keyboard = types.InlineKeyboardMarkup(row_width=1, inline_keyboard=[
+            [types.InlineKeyboardButton(text="Да", callback_data="yes_flow_count")],
+            [types.InlineKeyboardButton(text="Изменить", callback_data="buy_subscription")],
+            [types.InlineKeyboardButton(text="Обратно в меню", callback_data="back_to_menu")]
+        ])
+        await message.answer(f"Вы хотите купить {flow_count} поток(ов) за ${total_price_usd}?", reply_markup=keyboard)
+    else:
+        await message.answer("Пожалуйста, введите корректное число.")
+
+
+@router.callback_query(F.data == "buy_1_month")
+@router.callback_query(F.data == "buy_2_month")
+@router.callback_query(F.data == "buy_3_month")
+async def handle_buy_subscription_confirm(callback_query: types.CallbackQuery):
+    """ Получение подтверждения по покупке подписки и пользователя """
+    user_id = callback_query.from_user.id
+    user_states[user_id] = callback_query.data  # Сохраняем текущее состояние
+    # Подтверждение перехода к оплате
+    keyboard = types.InlineKeyboardMarkup(row_width=1, inline_keyboard=[
+            [types.InlineKeyboardButton(text="Да", callback_data="YES"),
+             types.InlineKeyboardButton(text="Изменить", callback_data="buy_subscription")],
+            [types.InlineKeyboardButton(text="Обратно в меню", callback_data="back_to_menu")],],)
+    months = {"buy_1_month": 1,
+              "buy_2_month": 2,
+              "buy_3_month": 3}
+    month_count = months.get(callback_query.data)
+    price = month_count * 1
+    # Отправляем запрос подтверждения
+    await callback_query.message.edit_text(
+        f"Вы хотите купить подписку сроком на {month_count} мес. за {price} $?", reply_markup=keyboard,)
+
+
+@router.callback_query(F.data == "yes_flow_count")
+async def handle_payment_method(callback_query: types.CallbackQuery):
+    """ Меню выбора способа оплаты потоков """
+    user_id = callback_query.from_user.id
+    flow_count = user_states[user_id]  # Получаем состояние пользователя
+    total_price_usd = flow_count * 2
+    # Получаем курс USD/RUB из бд
+    conn = create_connection()
+    cursor = conn.cursor()
+    course_usd_rub = getting_course(cursor)  # Функция для получения курса
+    price_rub = round(total_price_usd * course_usd_rub[1])
+    # Выбор способа оплаты
+    keyboard = types.InlineKeyboardMarkup(
+        row_width=1,
+        inline_keyboard=[
+            [types.InlineKeyboardButton(text=f"USDT TRC20 - {total_price_usd}$", callback_data="tron")],
+            [types.InlineKeyboardButton(text=f"Arbitrum - {total_price_usd}$", callback_data="Arbitrum")],
+            [types.InlineKeyboardButton(text=f"ЮКасса {price_rub} руб.", callback_data="Yukassa")],
+            [types.InlineKeyboardButton(text="Обратно в меню", callback_data="back_to_menu")],],)
+    # Отправляем запрос на выбор способа оплаты
+    await callback_query.message.edit_text(
+        f"Выберете способ оплаты товара за {total_price_usd} USDT или {price_rub} руб.",
+        reply_markup=keyboard,)
+
+@router.callback_query(F.data == "YES")
+async def handle_payment_method(callback_query: types.CallbackQuery):
+    """ Меню выбора способа оплаты подписки """
+    user_id = callback_query.from_user.id  # Получаем состояние пользователя
+    subscription_type = user_states.get(user_id)
+    if subscription_type:
+        months = {"buy_1_month": 1,
+                  "buy_2_month": 2,
+                  "buy_3_month": 3}
+        month_count = months.get(subscription_type)  # На входе мы получаем строку. далее переводим ее в int
+        price_usd = month_count * 1
+        # Получаем курс USD/RUB из бд
+        conn = create_connection()
+        cursor = conn.cursor()
+        course_usd_rub = getting_course(cursor)
+        price_rub = round(price_usd * course_usd_rub[1])
+        # Выбор способа оплаты
+        keyboard = types.InlineKeyboardMarkup(
+            row_width=1,
+            inline_keyboard=[
+                [types.InlineKeyboardButton(text=f"USDT TRC20 - {price_usd}$", callback_data="tron")],
+                [types.InlineKeyboardButton(text=f"Arbitrum - {price_usd}$", callback_data="Arbitrum")],
+                [types.InlineKeyboardButton(text=f"ЮКасса {price_rub} руб.", callback_data="Yukassa")],
+                [types.InlineKeyboardButton(text="Обратно в меню", callback_data="back_to_menu")],],)
+        # Отправляем запрос на выбор способа оплаты
+        await callback_query.message.edit_text(
+            f"Выберете способ оплаты товара на {month_count} мес. за {price_usd} USDT или {price_rub} руб.",
+            reply_markup=keyboard,)
+
+
+@router.callback_query(F.data == "tron")
+async def example(callback_query: types.CallbackQuery, state: FSMContext):
+    """ Платежный хэндлер трона на личный кошелек"""
+    await callback_query.message.delete()
+    await state.set_state(QuestionStates.waiting_for_hash)    # ожидание хэша от пользователя
+    user_id = callback_query.from_user.id   # Получение айди пользователя
+    flow_count = user_states[user_id]  # Получение количесва потоков
+    subscription_type = user_states.get(user_id)  # Получение строки по подписке
+    if isinstance(subscription_type, str):  # проверка - идет покупка потоков или подписки
+        months = {"buy_1_month": 1,
+                  "buy_2_month": 2,
+                  "buy_3_month": 3}
+        month_count = months.get(subscription_type)
+        price_usd = month_count * 1
+    else:
+        price_usd = flow_count * 2
+    payment_url = "TRFBWmb5NkvKuQpYyPaYzZAX46VCUJtiq1"  # Ссылка на кошелек заказчика
+    filename = "site.png"
+    # Генерация QR-кода
+    img = qrcode.make(payment_url)
+    img.save(filename)
+    photo = types.FSInputFile(filename)
+    await callback_query.message.answer_photo(
+        photo=photo, caption=f"Для оплаты необходимо совершить пополнение в размере {price_usd}$"
+                            f" на кошелек: {payment_url} После оплаты напишите хэш операции для проверки статуса",
+        reply_markup=types.InlineKeyboardMarkup(row_width=1, inline_keyboard=[
+            [types.InlineKeyboardButton(text="Изменить", callback_data="buy_subscription")]]))
+    os.remove(filename)
+
+
+@router.callback_query(F.data == "Arbitrum")
+async def example(callback_query: types.CallbackQuery, state: FSMContext):
+    """ Платежный хэндлер арбитрума на личный кошелек"""
+    await callback_query.message.delete()
+    await state.set_state(QuestionStates.waiting_for_hash)   # ожидание хэша от пользователя
+    user_id = callback_query.from_user.id  # Получение айди пользователя
+    flow_count = user_states[user_id]  # Получение количесва потоков
+    subscription_type = user_states.get(user_id)   # Получение строки по подписке
+    if isinstance(subscription_type, str):  # проверка - идет покупка потоков или подписки
+        months = {"buy_1_month": 1,
+                  "buy_2_month": 2,
+                  "buy_3_month": 3}
+        month_count = months.get(subscription_type)
+        price_usd = month_count * 1
+    else:
+        price_usd = flow_count * 2
+    payment_url = "0x683dc0af0d3797523104b57a7889b97a5871fbbb"  # Ссылка на кошелек заказчика
+    filename = "site.png"
+    # Генерация QR-кода
+    img = qrcode.make(payment_url)
+    img.save(filename)
+    photo = types.FSInputFile(filename)
+    await callback_query.message.answer_photo(
+        photo=photo, caption=f"Для оплаты необходимо совершить пополнение в размере {price_usd}$"
+                            f" на кошелек: {payment_url} После оплаты напишите хэш операции для проверки статуса",
+        reply_markup=types.InlineKeyboardMarkup(row_width=1, inline_keyboard=[
+            [types.InlineKeyboardButton(text="Изменить", callback_data="buy_subscription")]]))
+    os.remove(filename)
+
+
+@router.callback_query(F.data == "Yukassa")
+async def example(callback_query: types.CallbackQuery, state: FSMContext):
+    """ Платежный хэндлер юкассы """
+    await callback_query.message.delete()
+    user_id = callback_query.from_user.id  # Получение айди пользователя
+    flow_count = user_states[user_id]  # Получение количесва потоков
+    subscription_type = user_states.get(user_id)  # Получение строки по подписке
+    if isinstance(subscription_type, str):  # проверка - идет покупка потоков или подписки
+        months = {"buy_1_month": 1,
+                  "buy_2_month": 2,
+                  "buy_3_month": 3}
+        month_count = months.get(subscription_type)
+        price_usd = month_count * 1
+    else:
+        price_usd = flow_count * 2
+    # Получаем курс USD/RUB
+    conn = create_connection()
+    cursor = conn.cursor()
+    course_usd_rub = getting_course(cursor)
+    price_rub = round(price_usd * course_usd_rub[1])
+    bot_me = await bot_chat.get_me()  # эта и строчка ниже - получение имя бота
+    bot_username = bot_me.username
+    result = await payment_order_yukassa(price_rub, bot_username)  # функция возвращает словарь платежного поручения
+    payment_url = result['confirmation']['confirmation_url']  # вытаскиваем ссылку на оплату из словаря
+    payment_id = result["id"]  # вытаскиваем айди платежа
+    await state.update_data(payment_id=payment_id)  # Сохраняем payment_id в состоянии. нужен для след хэндлера
+    filename = "site.png"
+    # Генерация QR-кода
+    img = qrcode.make(payment_url)
+    img.save(filename)
+    photo = types.FSInputFile(filename)
+    await callback_query.message.answer_photo(
+        photo=photo, caption=f"Необходимо совершить оплату в размере {price_rub}руб по ссылке: {payment_url}",
+        reply_markup=types.InlineKeyboardMarkup(row_width=1, inline_keyboard=[
+            [types.InlineKeyboardButton(text="Изменить", callback_data="buy_subscription")],
+            [types.InlineKeyboardButton(text="Проверить платеж", callback_data=f"check {payment_id}")]]))
+    os.remove(filename)
+
+
+@router.callback_query(F.data.startswith("check"))
+async def check_payment(callback_query: types.CallbackQuery, state: FSMContext):
+    """ Проверка платежа юкассы по айди платежа """
+    await callback_query.message.delete()
+    await state.set_state(QuestionStates.payment_id)  # Получаем состояние айди платежки из прошлого хэндлера
+    user_id = callback_query.from_user.id  # Получаем айди пользователя
+    data = await state.get_data()  # Получаем данные состояния
+    payment_id = data.get("payment_id")  # Извлекаем payment_id
+    subscription_type = user_states.get(user_id)   # Извлекаем состояние по подписки
+    flow_count = user_states[user_id]  # Извлекаем состояние по потокам
+    if isinstance(subscription_type, str):  # Проверяем, была ли это оплата потоков или подписки
+        months = {"buy_1_month": 1,
+                  "buy_2_month": 2,
+                  "buy_3_month": 3}
+        month_count = months.get(subscription_type)
+        price_usd = month_count * 1
+    else:
+        price_usd = flow_count * 1
+    conn = create_connection()
+    cursor = conn.cursor()
+    if search_hash_in_table(cursor, payment_id):
+        await callback_query.message.answer("Повторная проверка по хешу запрещена",
+                             reply_markup=types.InlineKeyboardMarkup(row_width=1, inline_keyboard=[
+                                 [types.InlineKeyboardButton(text="Обратно в меню", callback_data="back_to_menu")]]))
+    else:
+        if check_payment_status(payment_id) == "succeeded":
+            await callback_query.message.answer(
+                "Платеж успешно произведен", reply_markup=types.InlineKeyboardMarkup
+                (row_width=1, inline_keyboard=[[types.InlineKeyboardButton
+                                                (text="Обратно в меню", callback_data="back_to_menu")]]))
+            write_hash_to_table(cursor, payment_id, user_id)
+            conn.commit()
+            if isinstance(subscription_type, str):
+                # делаем запись в бд при покупки подписки. устанавливается "3" при условии отсутсвия активной подписки
+                number_of_streams_from_subscriptions(cursor, user_id)  # Запись 3 единицы, если их не было
+                conn.commit()
+                subscription_entry(cursor, user_id, price_usd)   # Запись подписки в столбец (1,2,3 мес)
+                conn.commit()
+                subscription_end_record(cursor, user_id)  # Запись даты окончания подписки в столбцы
+                conn.commit()
+            else:
+                # добавляем в столбец количество потоков
+                number_of_threads_from_threads(cursor, user_id, price_usd)
+                conn.commit()
+        else:
+            await callback_query.answer(
+                "Ошибка, проверьте правильность написания хэша и повторите попытку проверки статуса платежа",
+                reply_markup=types.InlineKeyboardMarkup
+                (row_width=1, inline_keyboard=[[types.InlineKeyboardButton
+                                                (text="Обратно в меню", callback_data="back_to_menu")]]))
+    await callback_query.bot.unban_chat_member(-4226821992, user_id)
+
+
+@router.message(QuestionStates.waiting_for_hash)
+async def handle_hash(message: types.Message, state: FSMContext):
+    # хендлер по проверке по хешу статуса операции
+    await message.delete()
+    await state.set_state(QuestionStates.waiting_for_hash)
+    user_id = message.from_user.id
+    flow_count = user_states[user_id]
+    subscription_type = user_states.get(user_id)
+    if isinstance(subscription_type, str):
+        months = {"buy_1_month": 1,
+                  "buy_2_month": 2,
+                  "buy_3_month": 3}
+        month_count = months.get(subscription_type)
+        price_usd = month_count * 1
+    else:
+        price_usd = flow_count * 1
+    user_id = message.from_user.id
+    conn = create_connection()
+    cursor = conn.cursor()
+    user_hash = message.text.strip()  # Записываем хэш
+    # Проводим проверку на наличие хеша в таблице успешных операций. Если успешна - повторная проверка запрещена
+    if search_hash_in_table(cursor, user_hash):
+        await message.answer("Повторная проверка по хешу запрещена",
+                             reply_markup=types.InlineKeyboardMarkup(row_width=1, inline_keyboard=[
+                                 [types.InlineKeyboardButton(text="Обратно в меню", callback_data="back_to_menu")]]))
+    else:
+        result = get_contract_ret_tron(user_hash, price_usd)
+        result_2 = get_contract_ret_arbitrum(user_hash, price_usd)  # вызов функции для проверки статуса платежа
+        # если успешный статус, выводим отбивку пользователю и записываем хеш в таблицу чтобы последующие
+        # проверки были невозможны
+        if result:
+            await message.answer(
+                "Платеж успешно произведен", reply_markup=types.InlineKeyboardMarkup
+                (row_width=1, inline_keyboard=[[types.InlineKeyboardButton
+                                                (text="Обратно в меню", callback_data="back_to_menu")]]))
+            write_hash_to_table(cursor, user_hash, user_id)
+            conn.commit()
+            if isinstance(subscription_type, str):
+                print(isinstance(subscription_type, str))
+                # делаем запись в бд при покупки подписки. устанавливается "3" при условии отсутсвия активной подписки
+                number_of_streams_from_subscriptions(cursor, user_id)
+                conn.commit()
+                subscription_entry(cursor, user_id, price_usd)
+                conn.commit()
+                subscription_end_record(cursor, user_id)
+                conn.commit()
+            else:
+                # добавляем в столбец количество потоков
+                number_of_threads_from_threads(cursor, user_id, price_usd)
+                conn.commit()
+        elif result_2:
+            await message.answer(
+                "Платеж успешно произведен", reply_markup=types.InlineKeyboardMarkup
+                (row_width=1, inline_keyboard=[[types.InlineKeyboardButton
+                                                (text="Обратно в меню", callback_data="back_to_menu")]]))
+            write_hash_to_table(cursor, user_hash, user_id)
+            conn.commit()
+            if isinstance(subscription_type, str):
+                # делаем запись в бд при покупки подписки. устанавливается "3" при условии отсутсвия активной подписки
+                number_of_streams_from_subscriptions(cursor, user_id)
+                conn.commit()
+                subscription_entry(cursor, user_id, price_usd)
+                conn.commit()
+                subscription_end_record(cursor, user_id)
+                conn.commit()
+            else:
+                # добавляем в столбец количество потоков
+                number_of_threads_from_threads(cursor, user_id, price_usd)
+                conn.commit()
+        else:
+            await message.answer(
+                "Ошибка, проверьте правильность написания хэша и повторите попытку проверки статуса платежа",)
+    await message.bot.unban_chat_member(-4226821992, user_id)
+
+
+@router.callback_query(F.data == "back_to_menu")
+async def handle_back_to_menu(callback_query: types.CallbackQuery):
+    keyboard = types.InlineKeyboardMarkup(row_width=1, inline_keyboard=[
+            [types.InlineKeyboardButton(text="Купить подписку", callback_data="buy_subscription")],
+            [types.InlineKeyboardButton(text="FAQ блок", callback_data="faq_block"),
+             types.InlineKeyboardButton(text="Моя подписка", callback_data="my_subscription")],
+            [types.InlineKeyboardButton(text="Задать вопрос", callback_data="ask_question")],],)
+    # Отправляем сообщение с инлайн-клавиатурой
+    await callback_query.message.edit_text("Добро пожаловать! Выберите действие:", reply_markup=keyboard)
+
+
+@router.callback_query(F.data == "faq_block")
+async def handle_faq_block(callback_query: types.CallbackQuery):
+    # сообщение с информацией о FAQ
+    await callback_query.message.delete()
+    await callback_query.message.answer("Тут будет FAQ блок",
+                                           reply_markup=types.InlineKeyboardMarkup(row_width=1, inline_keyboard=[
+                                               [types.InlineKeyboardButton(text="Обратно в меню",
+                                                                           callback_data="back_to_menu")]],),)
+
+
+@router.callback_query(F.data == "my_subscription")
+async def handle_faq_block(callback_query: types.CallbackQuery):
+    await callback_query.message.delete()
+    user_id = callback_query.from_user.id  # выковыриваем айди пользователя
+    conn = create_connection()
+    cursor = conn.cursor()
+    user_data = get_user_data(cursor, user_id)  # Получение данных о пользователе из базы данных или API
+    # Формирование текста сообщения
+    message_text = f"Приветствуем, {user_data[2]}\n"
+    message_text += f"Ваш уникальный ID: {user_id}\n"
+    message_text += f"Ваш ZennolabID: {user_data[3]}\n"
+    message_text += f"Кол-во потоков Bcoin: {user_data[8]}\n"
+    message_text += f"Ваши активные подписки:\n-Подписка на {user_data[9]}. до {user_data[10]}\n"
+    message_text += f"Переходите по ссылке в нашу группу:  https://t.me/+Z7J58xXHeRs0MWUy"
+    await callback_query.message.answer(message_text,
+                                        reply_markup=types.InlineKeyboardMarkup(row_width=1, inline_keyboard=[
+                                               [types.InlineKeyboardButton(text="Обратно в меню",
+                                                                           callback_data="back_to_menu")]],),)
+
+
+@router.callback_query(F.data == "ask_question")
+async def handle_ask_question(callback_query: types.CallbackQuery, state: FSMContext):
+    await callback_query.message.delete()
+    user_id = callback_query.from_user.id
+    conn = create_connection()
+    cursor = conn.cursor()
+    state_user = status_question(cursor, user_id)[0]
+    if state_user == 1:
+        await callback_query.answer("Отправка вопроса запрещена. Дождитесь ответа на прошлый вопрос",
+                                    reply_markup=types.InlineKeyboardMarkup(row_width=1, inline_keyboard=[
+                                        [types.InlineKeyboardButton(text="Обратно в меню",
+                                                                    callback_data="back_to_menu")]]))
+    else:
+        # ожидание вопроса от пользователя
+        await state.set_state(QuestionStates.waiting_for_question)
+        await callback_query.message.answer(
+            "🙌 Задавайте вопрос, в ближайшее время Вам ответят.",
+            reply_markup=types.InlineKeyboardMarkup(row_width=1, inline_keyboard=[
+                [types.InlineKeyboardButton(text="Обратно в меню", callback_data="back_to_menu")]],),)
+
+
+@router.message(QuestionStates.waiting_for_question)
+async def handle_question(message: types.Message, state: FSMContext):
+    # Записываем вопрос и отправляем в группу
+    question = message.text
+    user_id = message.from_user.id
+    username = message.from_user.username or "No name"
+    conn = create_connection()
+    cursor = conn.cursor()
+    # Проверяем, существует ли пользователь в таблице
+    result = presence_user_bd(user_id)
+    if not int(result[6]) == 0:
+        # Если пользователь существует, просто обновляем информацию о вопросе
+        await message.answer(
+            "Спасибо, Ваш вопрос принят в работу!",
+            reply_markup=types.InlineKeyboardMarkup(row_width=1, inline_keyboard=[
+                [types.InlineKeyboardButton(text="Купить подписку", callback_data="buy_subscription")],
+                [types.InlineKeyboardButton(text="FAQ блок", callback_data="faq_block"),
+                 types.InlineKeyboardButton(text="Моя подписка", callback_data="my_subscription")],
+                [types.InlineKeyboardButton(text="Задать вопрос", callback_data="ask_question")],],))
+        await bot_chat.send_message(chat_id=-1002195305182, text=question, message_thread_id=result[6])
+    else:
+        await message.answer("Спасибо, Ваш вопрос принят в работу!",
+                             reply_markup=types.InlineKeyboardMarkup(row_width=1, inline_keyboard=[
+                                 [types.InlineKeyboardButton(text="Купить подписку", callback_data="buy_subscription")],
+                                 [types.InlineKeyboardButton(text="FAQ блок", callback_data="faq_block"),
+                                  types.InlineKeyboardButton(text="Моя подписка", callback_data="my_subscription")],
+                                 [types.InlineKeyboardButton(text="Задать вопрос", callback_data="ask_question")],],))
+        topic = await bot_chat.create_forum_topic(chat_id=-1002195305182, name=f"Вопрос от {username}")
+        update_user_db(cursor, topic.message_thread_id, user_id)
+        conn.commit()  # Подтверждаем изменения
+        await bot_chat.send_message(chat_id=-1002195305182, text=question, message_thread_id=topic.message_thread_id,)
+    installation_one_question(cursor, user_id)
+    conn.commit()
+
+
+@router.message(F.chat.type == "supergroup", F.text)
+async def handle_answer(message: types.Message):
+    conn = create_connection()
+    cursor = conn.cursor()
+    search_user = user_search(cursor, message.message_thread_id)
+    await bot_chat.send_message(chat_id=search_user[1], text=f"Ответ на Ваш вопрос: {message.text}")
+    installation_zero_question(cursor, search_user[1])
+    conn.commit()

docker-compose.yaml

@@ -0,0 +1,58 @@
+version: '3'
+
+services:
+  redis:
+    image: redis
+    ports:
+      - '6379:6379'
+
+  db:
+    image: postgres
+    env_file:
+      - .env
+    environment:
+      POSTGRES_DB: ${POSTGRES_DB}
+      POSTGRES_HOST: 'db'
+      POSTGRES_PORT: '5432'
+      POSTGRES_USER: ${USER_DATABASES}
+      POSTGRES_PASSWORD: ${PASSWORD_DATABASES}
+    volumes:
+      - ./postgres_data:/var/lib/postgresql/data/
+    ports:
+      - '5432:5432'
+    healthcheck:
+      test: [ "CMD-SHELL", "pg_isready -U postgres" ]
+      interval: 10s
+      timeout: 10s
+      retries: 5
+
+  app:
+    build: .
+    tty: true
+    command: sh -c "python manage.py migrate && python manage.py runserver 0.0.0.0:8000"
+    ports:
+      - '8000:8000'
+    depends_on:
+      db:
+        condition: service_healthy
+    volumes:
+      - .:/app
+
+  celery:
+    build: .
+    tty: true
+    command: celery -A config worker -l INFO
+    depends_on:
+      - redis
+      - app
+
+  celery_beat:
+    build: .
+    tty: true
+    command: celery -A config beat -l INFO -S django
+    depends_on:
+      - redis
+      - app
+
+volumes:
+  pg_data:

main.py

@@ -0,0 +1,30 @@
+from aiogram import Bot, Dispatcher
+import asyncio
+import bot
+from utils import get_usd_rub_course, checking_and_deleting_users
+from apscheduler.schedulers.asyncio import AsyncIOScheduler
+
+API_TOKEN = "6594413238:AAFahDg955k1GE9a4JE9T9yHyQoJZV5TFEk"
+
+
+# Создаем объект бота и диспетчера
+bot_chat = Bot(token=API_TOKEN)
+dp = Dispatcher()
+
+
+async def main() -> None:
+    """ Запуск бота """
+    dp.include_router(bot.router)
+    scheduler = AsyncIOScheduler()
+    # Планируем выполнение функции в 12:00, 18:00 и 00:00 планировщиком
+    scheduler.add_job(get_usd_rub_course, 'cron', hour='12,18,0')
+    # Планируем выполнение функции checking_and_deleting_users ежедневно в 00:12
+    scheduler.add_job(checking_and_deleting_users, 'cron', hour=0, minute=12)
+    scheduler.start()
+    await dp.start_polling(bot_chat)
+    while True:
+        await asyncio.sleep(1)
+
+
+if __name__ == "__main__":
+    asyncio.run(main())

requirements.txt

@@ -0,0 +1,9 @@
+tronpy
+aiogram
+requests
+mysql-connector-python
+binance.pay.merchant
+qrcode[pil]
+apscheduler
+yookassa
+uuid