diff --git a/src/api/Webhook.py b/src/api/Webhook.py index 3b762fac3..02cbde407 100644 --- a/src/api/Webhook.py +++ b/src/api/Webhook.py @@ -9,14 +9,13 @@ from datetime import datetime import json import hmac import hashlib -import logging +from loguru import logger from fastapi.responses import PlainTextResponse import os from src.utils.websocket_logger_fixed import manager, test_websocket_logging # 设置日志配置 -logging.basicConfig(level=logging.INFO) -logger = logging.getLogger(__name__) +logger.add("logs/app.log", rotation="500 MB", retention="10 days") def detect_webhook_source(data: dict, headers: dict) -> str: """检测webhook来源平台""" @@ -98,7 +97,7 @@ def get_webhook_event_info(data: dict, source: str) -> dict: event_info["user"] = pr.get("user", {}).get("name", "unknown") except Exception as e: - logger.error(f"解析webhook事件信息失败: {e}") + logger.error(f"❌ 解析webhook事件信息失败: {e}") return event_info @@ -1000,7 +999,7 @@ async def logs_viewer(): @WEBHOOK.get("/health") async def health_check(): """健康检查接口""" - logger.info("💚 Webhook健康检查") + logger.info("💚 Webhook健康检查请求") return {"status": "healthy", "message": "Webhook service is running"} @WEBHOOK.post("/admin/logs/test")