Alex/stcs
1
0
Fork 0
forked from kodorvan/stcs
Code Pull Requests Activity

Fixed

Browse Source
This commit is contained in:
algizn97
2025-08-21 16:09:32 +05:00
parent d0577f163b
commit f8cedf4cb4
3 changed files with 9 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
app/telegram/database/models.py
View File

@@ -150,5 +150,4 @@ class USER_DEALS(Base):
tg_id = mapped_column(ForeignKey("user_telegram_id.tg_id"))
symbol = mapped_column(String(18), default='PENGUUSDT')
open_price = mapped_column(Integer(), default=1)
side = mapped_column(String(10), nullable=False)

9
app/telegram/database/requests.py
View File

@@ -136,11 +136,18 @@ async def get_symbol(tg_id):
async def get_user_trades(tg_id):
async with async_session() as session:
query = select(USER_DEALS.symbol, USER_DEALS.side, USER_DEALS.open_price).where(USER_DEALS.tg_id == tg_id)
query = select(USER_DEALS.symbol, USER_DEALS.side).where(USER_DEALS.tg_id == tg_id)
result = await session.execute(query)
trades = result.all()
return trades
async def update_user_trades(tg_id, symbol, side):
async with async_session() as session:
await session.execute(update(USER_DEALS).where(USER_DEALS.tg_id == tg_id).values(symbol = symbol, side = side))
await session.commit()
async def get_for_registration_trading_mode():
async with async_session() as session:
mode = await session.scalar(select(Trading_Mode.mode).where(Trading_Mode.id == 1))