add thread_id

app/__init__.py

@@ -56,12 +56,16 @@ def do_p2_im_message_receive_v1(data: P2ImMessageReceiveV1) -> None:
     content = json.loads(data.event.message.content)
     sender_id = data.event.sender.sender_id.open_id
     message_id = data.event.message.message_id
+    thread_id = data.event.message.thread_id
 
     clear_data = {}
     clear_data["message_type"] = message_type
     clear_data["content"] = content
     clear_data["sender_id"] = sender_id
     clear_data["message_id"] = message_id
+    clear_data["thread_id"] = thread_id
+
+    print(f"thread_id: {thread_id}")
 
     process_message_callback.delay(
         app_id, app_secret, bitable_token, table_id, cache_dir, clear_data

app/task.py

@@ -16,6 +16,11 @@ from app.utils.utils import update_record
 def process_message_callback(
     app_id, app_secret, bitable_token, table_id, cache_dir, data
 ) -> None:
+    # 记录问题到多维表格逻辑
+    # 如果 @机器人 不等于"记录问题", 什么都不做
+    # 如果 @机器人 等于"记录问题", 获取当前的话题, 从话题中提取问题发起人的所有消息和图片, 记录到多维表格中
+    
+
     client = lark.Client.builder().app_id(app_id).app_secret(app_secret).build()
 
     record = {}