feat: 增加 app_analyze 接口异步记录设备信息功能

api_routes.py

@@ -53,6 +53,7 @@ from database import (
     fetch_records_by_paths,
     infer_category_from_filename,
     fetch_today_category_counts,
+    upsert_device_record,
 )
 
 SERVER_HOSTNAME = os.environ.get("HOSTNAME", "")
@@ -1574,6 +1575,35 @@ async def app_analyze_face(
     """
     App专用人脸分析接口，参数与原 /analyze 保持完全一致并透传。
     """
+    # 异步记录设备信息
+    device_id = request.headers.get("x-device-id")
+    if device_id:
+        try:
+            # 提取公共头
+            ts_str = request.headers.get("x-timestamp")
+            ts_ms = int(ts_str) if ts_str and ts_str.isdigit() else None
+            
+            device_info = {
+                "device_id": device_id,
+                "device_type": request.headers.get("x-device-type"),
+                "device_model": request.headers.get("x-device-model"),
+                "os_version": request.headers.get("x-os-version"),
+                "app_id": request.headers.get("x-app-id"),
+                "app_version": request.headers.get("x-app-version"),
+                "bundle_id": request.headers.get("x-bundle-id"),
+                "timezone": request.headers.get("x-timezone"),
+                "region": request.headers.get("x-region"),
+                "language": request.headers.get("Accept-Language"),
+                "request_id": request.headers.get("x-request-id"),
+                "timestamp_ms": ts_ms,
+                "nonce": request.headers.get("x-nonce"),
+                "nickname": nickname
+            }
+            # 创建异步任务，不阻塞当前请求
+            asyncio.create_task(upsert_device_record(**device_info))
+        except Exception as e:
+            logger.warning(f"Failed to record device info for {device_id}: {e}")
+
     return await analyze_face(
         request=request,
         file=file,

database.py

@@ -334,6 +334,85 @@ def infer_category_from_filename(filename: str, default: str = "other") -> str:
 
 from config import HOSTNAME
 
+async def upsert_device_record(
+    *,
+    device_id: str,
+    device_type: Optional[str] = None,
+    device_model: Optional[str] = None,
+    os_version: Optional[str] = None,
+    app_id: Optional[str] = None,
+    app_version: Optional[str] = None,
+    bundle_id: Optional[str] = None,
+    timezone: Optional[str] = None,
+    region: Optional[str] = None,
+    language: Optional[str] = None,
+    request_id: Optional[str] = None,
+    timestamp_ms: Optional[int] = None,
+    nonce: Optional[str] = None,
+    nickname: Optional[str] = None,
+) -> None:
+    """写入或更新设备记录"""
+    query = """
+        INSERT INTO tpl_app_user_devices (
+            device_id,
+            device_type,
+            device_model,
+            os_version,
+            app_id,
+            app_version,
+            bundle_id,
+            timezone,
+            region,
+            language,
+            request_id,
+            timestamp_ms,
+            nonce,
+            nickname
+        ) VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s)
+        ON DUPLICATE KEY UPDATE
+            device_type = VALUES(device_type),
+            device_model = VALUES(device_model),
+            os_version = VALUES(os_version),
+            app_id = VALUES(app_id),
+            app_version = VALUES(app_version),
+            bundle_id = VALUES(bundle_id),
+            timezone = VALUES(timezone),
+            region = VALUES(region),
+            language = VALUES(language),
+            request_id = VALUES(request_id),
+            timestamp_ms = VALUES(timestamp_ms),
+            nonce = VALUES(nonce),
+            nickname = VALUES(nickname),
+            updated_at = CURRENT_TIMESTAMP
+    """
+    import time
+    start_time = time.perf_counter()
+    try:
+        await execute(
+            query,
+            (
+                device_id,
+                device_type,
+                device_model,
+                os_version,
+                app_id,
+                app_version,
+                bundle_id,
+                timezone,
+                region,
+                language,
+                request_id,
+                timestamp_ms,
+                nonce,
+                nickname,
+            ),
+        )
+        duration = (time.perf_counter() - start_time) * 1000
+        logger.info(f"Device record updated for {device_id}, cost: {duration:.2f}ms")
+    except Exception as exc:
+        logger.warning(f"写入设备记录失败: {exc}")
+
+
 async def record_image_creation(
     *,
     file_path: str,