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字符串