From 929f00b34ea43acd02ffed7c86e316a21949bd2d Mon Sep 17 00:00:00 2001
From: "mark.tian" <mark.tian@shiliulizi.cn>
Date: Thu, 4 Dec 2025 10:21:04 +0800
Subject: [PATCH] =?UTF-8?q?=E9=80=9A=E8=AF=9D=E8=AF=A6=E6=83=85=E5=A2=9E?=
 =?UTF-8?q?=E5=8A=A0user=5Fid?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/database.py | 1 +
 app/routes.py   | 4 ++++
 2 files changed, 5 insertions(+)

diff --git a/app/database.py b/app/database.py
index a9dff38..8d4eafe 100644
--- a/app/database.py
+++ b/app/database.py
@@ -32,6 +32,7 @@ class CallbackFailureData(Base):
     id = Column(Integer, primary_key=True, autoincrement=True, comment="数据ID")
     callback_failure_log_id = Column(Integer, nullable=False, comment="回调失败日志ID")
     phone_number = Column(String(20), nullable=False, comment="手机号")
+    user_id = Column(String(100), nullable=True, comment="用户ID")
     task_id = Column(String(100), nullable=False, comment="任务ID")
     status = Column(Integer, nullable=False, comment="状态")
     status_description = Column(String(200), nullable=False, comment="状态描述")
diff --git a/app/routes.py b/app/routes.py
index 241ea83..c072ecd 100644
--- a/app/routes.py
+++ b/app/routes.py
@@ -114,6 +114,9 @@ async def save_callback_data_items(
             task = item.get('task', {})
             task_id = task.get('id', '')
             
+            # 获取用户ID
+            user_id = item.get('user_id', '')
+            
             # 获取状态信息
             status = item.get('status', 0)
             status_description = item.get('status_str', '')
@@ -138,6 +141,7 @@ async def save_callback_data_items(
                 callback_failure_log_id=callback_failure_log_id,
                 phone_number=phone_number,
                 task_id=task_id,
+                user_id=user_id,  # 保存用户ID
                 status=status,
                 status_description=status_description,
                 raw_data=raw_data_json,  # 保存原始JSON字符串