refactor(Utils): 重构 AccessToken 获取逻辑

- 修复大小写错误：将 config.logger 改为 config.Logger
- 优化 get_access_token 函数：
  - 添加超时和重试机制
  - 使用 AccessTokenPayload 直接解析响应数据
  - 采用分段睡眠避免长时间阻塞
  - 增加异常处理，提高程序健壮性
- 重新组织代码结构，提高可读性和可维护性

Author: Shanshui2024

src/Utils/Config.py

@@ -16,8 +16,8 @@ def __init__ (self):
 _config = ConfigBase(**yaml_config)
 
 if _config.Advanced.debug:
-    _config.logger.level = "DEBUG"
+    _config.Logger.level = "DEBUG"
 else:
-    _config.logger.level = _config.logger.level
+    _config.Logger.level = _config.Logger.level
 
 config = _config

src/Utils/GetAccessToken.py

@@ -1,34 +1,45 @@
 import threading, requests, time
 
-
 from src.Utils.Logger import logger
 from src.Utils.Config import config
-from src.Utils.EventClass import AccessTokenPayload, OpenAPIErrorPayload
-
-ACCESS_TOKEN: str = ""
-
-async def get_access_token():
-    threading.Thread(target=access_token, daemon=True,name="AccessToekn 鉴权获取线程").start()
+from src.Utils.EventClass import AccessTokenPayload
 
+ACCESS_TOKEN = ""
+TOKEN_LOCK = threading.Lock()
 
-def access_token():
-    """获取access_token"""
+def token_manager():
     while True:
         logger.debug("正在获取access_token...")
-        response = requests.post("https://bots.qq.com/app/getAppAccessToken", 
-                      json={"appId": str(config.Bot.appid), "clientSecret": config.Bot.appsecret}
-                    )
-        response.raise_for_status
-        code = response.status_code
-        response = response.json()
-        if code != 200:
-            response = OpenAPIErrorPayload(**response)
-            logger.error(f"获取access_token失败,错误码:{response.code}；原因:{response.message}")
-            logger.debug("当前输出内容：" + str({"appId": str(config.Bot.appid),"clientSecret": config.Bot.appsecret}))
-            time.sleep(60)
-        else:
-            response_json = AccessTokenPayload(**response)
-            logger.debug(f"获取AccessToken成功，token: {response_json.access_token} 将于 {response_json.expires_in} s后过期")
-            global ACCESS_TOKEN
-            ACCESS_TOKEN = response_json.access_token
-            time.sleep(response_json.expires_in - 30)
+        try:
+            # 添加超时和重试机制
+            response = requests.post(
+                "https://bots.qq.com/app/getAppAccessToken",
+                json={"appId": str(config.Bot.appid), "clientSecret": config.Bot.appsecret},
+                timeout=10
+            )
+            response.raise_for_status()  # 修复：添加括号调用方法
+            
+            token_data = AccessTokenPayload(**response.json())
+            logger.debug(f"获取AccessToken成功，token: {token_data.access_token} 将于 {token_data.expires_in}s后过期")
+            
+            with TOKEN_LOCK:
+                global ACCESS_TOKEN
+                ACCESS_TOKEN = token_data.access_token
+            
+            # 分段睡眠，避免长时间阻塞
+            sleep_time = token_data.expires_in - 30
+            while sleep_time > 0:
+                chunk = min(sleep_time, 300)  # 每5分钟唤醒一次
+                time.sleep(chunk)
+                sleep_time -= chunk
+                
+        except requests.exceptions.RequestException as e:
+            logger.error(f"请求失败: {str(e)}")
+            time.sleep(10)  # 短时间等待后重试
+        except Exception as e:
+            logger.error(f"意外错误: {str(e)}")
+            time.sleep(30)
+
+async def get_access_token():
+    # 启动线程
+    threading.Thread(target=token_manager, daemon=True, name="AccessToekn 鉴权获取线程").start()