新增 PostHog 产品分析，支持用户行为统计（启动、点名、抽奖事件上报）及用户属性同步（抽取次数统计）

Author: lzy98276

CHANGELOG/v2.3.0/CHANGELOG.md

@@ -12,6 +12,7 @@ v2.3 - Shiroko (砂狼白子) release 1
 - 新增 **名单设置**，支持批量配置数量（仅抽奖），以及支持配置标签（点名、抽奖）
 - 新增 **名单导入**，支持批量导入名单，且能检测并自动重命名重复项
 - 新增 **URL/IPC接口**，支持打开计时器窗口
+- 新增 **PostHog 产品分析**，支持用户行为统计（启动、点名、抽奖事件上报）及用户属性同步（抽取次数统计）
 
 ## 💡 功能优化
 
@@ -30,7 +31,7 @@ v2.3 - Shiroko (砂狼白子) release 1
 
 ## 🔧 其它变更
 
-- 新增 **PostHog 产品分析**，支持用户行为统计（启动、点名、抽奖事件上报）及用户属性同步（抽取次数统计）
+- 无
 
 ---
 

app/common/lottery/lottery_manager.py

@@ -36,7 +36,8 @@
     get_content_name_async,
     get_content_pushbutton_name_async,
 )
-from app.tools.variable import APP_INIT_DELAY, track_event
+from app.tools.variable import APP_INIT_DELAY
+from app.tools.config import track_event
 
 system_random = SystemRandom()
 

app/common/roll_call/roll_call_manager.py

@@ -37,7 +37,8 @@
     get_content_combo_name_async,
 )
 from app.tools.path_utils import get_data_path
-from app.tools.variable import APP_INIT_DELAY, track_event
+from app.tools.variable import APP_INIT_DELAY
+from app.tools.config import track_event
 
 system_random = SystemRandom()
 

app/tools/config.py

@@ -77,6 +77,91 @@ def configure_logging():
     logger.debug(f"日志系统已配置，当前日志等级: {log_level}")
 
 
+def create_sentry_before_send_filter():
+    """创建 Sentry 事件过滤器
+
+    过滤掉不需要上报的错误，如第三方库错误和常见的无害错误
+    """
+
+    def before_send(event, hint):
+        # 1. 检查是否有堆栈信息
+        has_stacktrace = False
+        if "exception" in event:
+            values = event.get("exception", {}).get("values", [])
+            for val in values:
+                if val.get("stacktrace"):
+                    has_stacktrace = True
+                    break
+
+        if not has_stacktrace and "threads" in event:
+            values = event.get("threads", {}).get("values", [])
+            for val in values:
+                if val.get("stacktrace"):
+                    has_stacktrace = True
+                    break
+
+        # 检查 loguru 的 log_record
+        log_record = hint.get("log_record")
+        if log_record:
+            if getattr(log_record, "exception", None):
+                has_stacktrace = True
+            elif hasattr(log_record, "extra") and log_record.extra.get("exc_info"):
+                has_stacktrace = True
+
+        # 如果没有堆栈信息，且是错误/严重级别，则丢弃 (logger.info 等低级别不会被丢弃，除非 event_level 设置)
+        if not has_stacktrace and event.get("level") in ("error", "fatal"):
+            return None
+
+        # 2. 过滤特定的错误类型或模块
+        if "exception" in event:
+            exceptions = event.get("exception", {}).get("values", [])
+            for exc in exceptions:
+                module = exc.get("module", "")
+                type_ = exc.get("type", "")
+                value = exc.get("value", "")
+
+                # 过滤 Qt 常见无害错误 (通常是由于对象在 C++ 侧已销毁但 Python 侧仍在尝试访问)
+                if type_ == "RuntimeError" and (
+                    "Internal C++ object" in str(value)
+                    or "has been deleted" in str(value)
+                ):
+                    return None
+
+                # 过滤 COM 相关
+                if type_ == "COMError" and "没有注册类" in str(value):
+                    return None
+
+        return event
+
+    return before_send
+
+
+posthog_client = None
+
+
+def set_posthog_client(client):
+    """设置全局 PostHog 客户端"""
+    global posthog_client
+    posthog_client = client
+
+
+def track_event(event_name: str):
+    """上报事件到 PostHog
+
+    Args:
+        event_name: 事件名称
+    """
+    if posthog_client is None:
+        return
+    from app.tools.settings_access import get_or_create_user_id
+
+    user_id = get_or_create_user_id()
+    posthog_client.capture(
+        distinct_id=user_id,
+        event=event_name,
+    )
+
+
 # ==================== 通知模块 ====================
 
 

app/tools/settings_default.py

@@ -149,13 +149,18 @@ def manage_settings_file():
             for second_level_key, second_level_value in first_level_value.items():
                 if second_level_key not in updated_settings[first_level_key]:
                     # 处理两种格式：{"default_value": xxx} 或直接值
-                    if isinstance(second_level_value, dict) and "default_value" in second_level_value:
+                    if (
+                        isinstance(second_level_value, dict)
+                        and "default_value" in second_level_value
+                    ):
                         default_val = second_level_value["default_value"]
                     else:
                         default_val = second_level_value
 
                     if default_val is not None:
-                        updated_settings[first_level_key][second_level_key] = default_val
+                        updated_settings[first_level_key][second_level_key] = (
+                            default_val
+                        )
                         settings_updated = True
 
         # 移除多余的设置项

app/tools/settings_default_storage.py

@@ -275,7 +275,9 @@
         "floating_window_opacity": {"default_value": 0.8},
         "floating_window_topmost_mode": {"default_value": 1},
         "extend_quick_draw_component": {"default_value": False},
-        "floating_window_button_control": {"default_value": ["roll_call", "quick_draw"]},
+        "floating_window_button_control": {
+            "default_value": ["roll_call", "quick_draw"]
+        },
         "floating_window_placement": {"default_value": 1},
         "floating_window_display_style": {"default_value": 0},
         "floating_window_theme": {"default_value": 0},

app/tools/variable.py

@@ -350,33 +350,3 @@ def _normalize_arch(machine: str) -> str:
 # ==================================================
 
 main_window = None  # 全局主窗口引用
-
-
-# ==================================================
-# PostHog 产品分析
-# ==================================================
-
-posthog_client = None  # 全局 PostHog 客户端
-
-
-def set_posthog_client(client):
-    """设置全局 PostHog 客户端"""
-    global posthog_client
-    posthog_client = client
-
-
-def track_event(event_name: str):
-    """上报事件到 PostHog
-
-    Args:
-        event_name: 事件名称
-    """
-    if posthog_client is None:
-        return
-    from app.tools.settings_access import get_or_create_user_id
-
-    user_id = get_or_create_user_id()
-    posthog_client.capture(
-        distinct_id=user_id,
-        event=event_name,
-    )

main.py

@@ -13,9 +13,13 @@
 from loguru import logger
 
 from app.tools.path_utils import get_app_root
-from app.tools.config import configure_logging
+from app.tools.config import (
+    configure_logging,
+    set_posthog_client,
+    create_sentry_before_send_filter,
+)
 from app.tools.settings_default import manage_settings_file
-from app.tools.settings_access import readme_settings_async, get_or_create_user_id, update_settings
+from app.tools.settings_access import readme_settings_async, get_or_create_user_id
 from app.core.app_init import calculate_total_draw_counts
 from app.tools.variable import (
     APP_QUIT_ON_LAST_WINDOW_CLOSED,
@@ -29,7 +33,6 @@
     PROCESS_EXIT_WAIT_SECONDS,
     POSTHOG_API_KEY,
     POSTHOG_HOST,
-    set_posthog_client,
 )
 from app.core.single_instance import (
     check_single_instance,
@@ -53,65 +56,6 @@
 # ==================================================
 
 
-def create_sentry_before_send_filter():
-    """创建 Sentry 事件过滤器
-
-    过滤掉不需要上报的错误，如第三方库错误和常见的无害错误
-    """
-
-    def before_send(event, hint):
-        # 1. 检查是否有堆栈信息
-        has_stacktrace = False
-        if "exception" in event:
-            values = event.get("exception", {}).get("values", [])
-            for val in values:
-                if val.get("stacktrace"):
-                    has_stacktrace = True
-                    break
-
-        if not has_stacktrace and "threads" in event:
-            values = event.get("threads", {}).get("values", [])
-            for val in values:
-                if val.get("stacktrace"):
-                    has_stacktrace = True
-                    break
-
-        # 检查 loguru 的 log_record
-        log_record = hint.get("log_record")
-        if log_record:
-            if getattr(log_record, "exception", None):
-                has_stacktrace = True
-            elif hasattr(log_record, "extra") and log_record.extra.get("exc_info"):
-                has_stacktrace = True
-
-        # 如果没有堆栈信息，且是错误/严重级别，则丢弃 (logger.info 等低级别不会被丢弃，除非 event_level 设置)
-        if not has_stacktrace and event.get("level") in ("error", "fatal"):
-            return None
-
-        # 2. 过滤特定的错误类型或模块
-        if "exception" in event:
-            exceptions = event.get("exception", {}).get("values", [])
-            for exc in exceptions:
-                module = exc.get("module", "")
-                type_ = exc.get("type", "")
-                value = exc.get("value", "")
-
-                # 过滤 Qt 常见无害错误 (通常是由于对象在 C++ 侧已销毁但 Python 侧仍在尝试访问)
-                if type_ == "RuntimeError" and (
-                    "Internal C++ object" in str(value)
-                    or "has been deleted" in str(value)
-                ):
-                    return None
-
-                # 过滤 COM 相关
-                if type_ == "COMError" and "没有注册类" in str(value):
-                    return None
-
-        return event
-
-    return before_send
-
-
 def initialize_sentry():
     """初始化 Sentry 错误监控系统"""
     sentry_sdk.init(