diff --git a/web/app.py b/web/app.py index f312f69..68f6f6f 100644 --- a/web/app.py +++ b/web/app.py @@ -249,6 +249,24 @@ async def api_approve_verification(req_id: int, username: str = Depends(get_curr req.reviewed_at = datetime.utcnow() await session.execute(update(User).where(User.user_id == req.user_id).values(verified=True, apartment=req.apartment, verification_date=datetime.utcnow())) await session.commit() + + # Уведомляем пользователя + try: + proxy_url = config.get_proxy_url() + async with aiohttp.ClientSession() as http_session: + await http_session.post( + f"https://api.telegram.org/bot{config.BOT_TOKEN}/sendMessage", + json={ + "chat_id": req.user_id, + "text": f"✅ Ваша заявка на верификацию одобрена!\n\nКвартира: {req.apartment}\nТеперь вам доступны все функции бота.", + "parse_mode": "HTML" + }, + proxy=proxy_url, + timeout=10 + ) + except Exception as e: + logger.error(f"Error notifying user {req.user_id}: {e}") + return JSONResponse({"success": True}) @app.post("/api/verification/{req_id}/reject") @@ -261,6 +279,49 @@ async def api_reject_verification(req_id: int, username: str = Depends(get_curre await session.commit() return JSONResponse({"success": True}) +@app.post("/api/user/{user_id}/verify") +async def api_verify_user(user_id: int, username: str = Depends(get_current_admin)): + async with AsyncSessionLocal() as session: + user = (await session.execute(select(User).where(User.user_id == user_id))).scalar_one_or_none() + if not user: + return JSONResponse({"success": False, "error": "Пользователь не найден"}) + + user.verified = True + user.verification_date = datetime.utcnow() + await session.commit() + + # Уведомляем пользователя через бот + try: + proxy_url = config.get_proxy_url() + async with aiohttp.ClientSession() as http_session: + await http_session.post( + f"https://api.telegram.org/bot{config.BOT_TOKEN}/sendMessage", + json={ + "chat_id": user_id, + "text": "✅ Верификация подтверждена!\n\nТеперь у вас есть полный доступ ко всем функциям бота LKM37.", + "parse_mode": "HTML" + }, + proxy=proxy_url, + timeout=10 + ) + except Exception as e: + logger.error(f"Error notifying user {user_id}: {e}") + + return JSONResponse({"success": True}) + +@app.post("/api/user/{user_id}/unverify") +async def api_unverify_user(user_id: int, username: str = Depends(get_current_admin)): + async with AsyncSessionLocal() as session: + user = (await session.execute(select(User).where(User.user_id == user_id))).scalar_one_or_none() + if not user: + return JSONResponse({"success": False, "error": "Пользователь не найден"}) + + user.verified = False + user.verification_date = None + await session.commit() + + return JSONResponse({"success": True}) + # ============================================================================ # ТЕЛЕФОНЫ / ОБЪЯВЛЕНИЯ / ОПРОСЫ / СОБЫТИЯ / ГРАФИКИ # ============================================================================