from app.database.models import async_session
from app.database.models import User, Category, Item
from sqlalchemy import select
async def set_user(tg_id):
async with async_session() as session:
user = await session.scalar(select(User).where(User.tg_id == tg_id))
if not user:
session.add(User(tg_id == tg_id))
await session.commit()
это чтоб добавлялось в дб
import asyncio
import aiogram
from aiogram import Bot, Router, F
from aiogram.types import Message
from aiogram.filters import CommandStart, Command
import app.keyboard as kb
import app.database.requests as rq
rt = Router()
@rt.message(CommandStart())
async def start(message:Message):
await rq.set_user(message.from_user.id)
await message.reply('Привет!')
await message.answer("Вот Главное меню:", reply_markup=kb.main)
@rt.message(Command('help'))
async def help(message: Message):
await message.reply('Все вопросы ->:')
@rt.message(F.text == 'Каталог ')
async def catlog(message:Message):
await message.answer('Вот наш каталог:', reply_markup=kb.catalog)
@rt.message(F.text == 'Вернуться на главную страницу')
async def catlog(message:Message):
await message.answer('Главное меню:', reply_markup=kb.main)
это исполняет при команде /start
Простой
