修复wxautox库加载问题

Author: jingyi0605

app/__init__.py

@@ -9,6 +9,11 @@ def create_app():
     werkzeug_logger = logging.getLogger('werkzeug')
     werkzeug_logger.setLevel(logging.ERROR)  # 只显示错误级别的日志
 
+    # 确保所有日志处理器立即刷新
+    for handler in logging.getLogger().handlers:
+        handler.setLevel(logging.DEBUG)
+        handler.flush()
+
     # 初始化微信相关配置
     from app.wechat_init import initialize as init_wechat
     init_wechat()
@@ -20,6 +25,11 @@ def create_app():
     app = Flask(__name__)
     app.config.from_object(Config)
 
+    # 配置Flask日志处理
+    if not app.debug:
+        # 在非调试模式下，禁用自动重载器
+        app.config['USE_RELOADER'] = False
+
     # 初始化限流器
     limiter = Limiter(
         app=app,

app/api/routes.py

@@ -21,16 +21,26 @@ def before_request():
     g.start_time = time.time()
     # 记录请求信息，但不记录详细的请求头和请求体
     logger.info(f"收到请求: {request.method} {request.path}")
+    # 确保日志立即刷新
+    for handler in logger.logger.handlers:
+        handler.flush()
+
     # 只在开发环境下记录请求体，且不记录请求头
     if Config.DEBUG and request.method in ['POST', 'PUT', 'PATCH'] and request.is_json:
         logger.debug(f"请求体: {request.get_json()}")
+        # 确保日志立即刷新
+        for handler in logger.logger.handlers:
+            handler.flush()
 
 @api_bp.after_request
 def after_request(response):
     if hasattr(g, 'start_time'):
         duration = time.time() - g.start_time
         # 修改日志格式，确保API计数器能够正确识别 - 确保状态码周围有空格
         logger.info(f"请求处理完成: {request.method} {request.path} - 状态码: {response.status_code} - 耗时: {duration:.2f}秒")
+        # 确保日志立即刷新
+        for handler in logger.logger.handlers:
+            handler.flush()
     return response
 
 @api_bp.errorhandler(Exception)

app/app_ui.py

@@ -1436,6 +1436,7 @@ def show_api_documentation(self):
     def on_lib_change(self):
         """处理库选择变更"""
         selected_lib = self.lib_var.get()
+        self.add_log(f"库选择变更: {selected_lib}")
 
         # 检查所选库是否已安装
         if selected_lib == "wxauto" and not self.check_wxauto_status():
@@ -1450,14 +1451,38 @@ def on_lib_change(self):
 
         try:
             # 加载当前配置
+            self.add_log(f"正在加载配置文件...")
             config = config_manager.load_app_config()
+            self.add_log(f"当前配置: {config}")
 
             # 更新库配置
+            old_lib = config.get('wechat_lib', 'wxauto')
             config['wechat_lib'] = selected_lib
+            self.add_log(f"更新库配置: {old_lib} -> {selected_lib}")
 
             # 保存配置
+            self.add_log(f"正在保存配置文件...")
             config_manager.save_app_config(config)
 
+            # 验证配置是否成功保存
+            try:
+                new_config = config_manager.load_app_config()
+                saved_lib = new_config.get('wechat_lib', 'wxauto')
+                if saved_lib != selected_lib:
+                    self.add_log(f"警告：配置保存后验证失败，期望值: {selected_lib}，实际值: {saved_lib}")
+                    messagebox.showwarning("配置验证", f"配置可能未正确保存，请检查配置文件权限")
+                else:
+                    self.add_log(f"配置保存成功并验证通过: {saved_lib}")
+            except Exception as ve:
+                self.add_log(f"配置验证失败: {str(ve)}")
+
+            # 同时更新.env文件中的配置（作为备份）
+            try:
+                self.update_env_file('WECHAT_LIB', selected_lib)
+                self.add_log(f"已更新.env文件中的WECHAT_LIB配置")
+            except Exception as env_e:
+                self.add_log(f"更新.env文件失败: {str(env_e)}")
+
             # 标记配置已修改
             global CONFIG_MODIFIED
             CONFIG_MODIFIED = True
@@ -1475,6 +1500,31 @@ def on_lib_change(self):
         if self.api_running:
             messagebox.showinfo("需要重启", "库已切换，需要重启服务才能生效")
 
+    def update_env_file(self, key, value):
+        """更新.env文件中的配置"""
+        env_file = ".env"
+        lines = []
+        key_found = False
+
+        # 读取现有内容
+        if os.path.exists(env_file):
+            with open(env_file, "r", encoding="utf-8") as f:
+                lines = f.readlines()
+
+        # 更新或添加配置
+        for i, line in enumerate(lines):
+            if line.strip().startswith(f"{key}="):
+                lines[i] = f"{key}={value}\n"
+                key_found = True
+                break
+
+        if not key_found:
+            lines.append(f"{key}={value}\n")
+
+        # 写回文件
+        with open(env_file, "w", encoding="utf-8") as f:
+            f.writelines(lines)
+
     # 这些方法已被移除，配置现在通过插件配置对话框进行管理
 
     def start_api_service(self):