DIKER/popa_minecraft_launcher_api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix coins collections

Browse Source
This commit is contained in:
DIKER0K
2025-12-07 15:52:43 +05:00
parent f720b51c60
commit e7ed7ab977
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
app/services/coins.py
View File

@ -1,9 +1,12 @@
from datetime import datetime from datetime import datetime
from app.db.database import users_collection, sessions_collection from app.db.database import users_collection
from fastapi import HTTPException from fastapi import HTTPException
from app.db.database import db
MAX_MINUTES_PER_UPDATE = 120 MAX_MINUTES_PER_UPDATE = 120
coins_sessions_collection = db.coins_sessions
class CoinsService: class CoinsService:
async def update_player_coins(self, player_id: str, player_name: str, online_time: int, server_ip: str): async def update_player_coins(self, player_id: str, player_name: str, online_time: int, server_ip: str):
"""Обновляет монеты игрока на основе времени онлайн""" """Обновляет монеты игрока на основе времени онлайн"""
@ -14,7 +17,7 @@ class CoinsService:
return # Пользователь не найден return # Пользователь не найден
# Находим последнее обновление монет # Находим последнее обновление монет
last_update = await sessions_collection.find_one({ last_update = await coins_sessions_collection.find_one({
"player_id": player_id, "player_id": player_id,
"server_ip": server_ip, "server_ip": server_ip,
"update_type": "coins_update" "update_type": "coins_update"
@ -55,7 +58,7 @@ class CoinsService:
) )
# Сохраняем запись о начислении # Сохраняем запись о начислении
await sessions_collection.insert_one({ await coins_sessions_collection.insert_one({
"player_id": player_id, "player_id": player_id,
"player_name": player_name, "player_name": player_name,
"server_ip": server_ip, "server_ip": server_ip,