diff --git a/app/task.py b/app/task.py
index f5f362a..bb0dfba 100644
--- a/app/task.py
+++ b/app/task.py
@@ -21,6 +21,7 @@ def parse_history_message(data):
     items = data.get("items")
 
     for index, item in enumerate(items):
+        print("=======================")
 
         sender_id_item = item.get("sender").get("id")
         if index == 0:
@@ -31,6 +32,8 @@ def parse_history_message(data):
 
         item_content = json.loads(item.get("body").get("content"))
 
+        message_id = item.get("message_id")
+
         if item_content.get("text"):
             message_content_data.append(item_content.get("text"))
 
@@ -47,7 +50,8 @@ def parse_history_message(data):
                 if tmp_content_data_item.get("tag") == "text":
                     message_content_data.append(tmp_content_data_item.get("text"))
                 if tmp_content_data_item.get("tag") == "img":
-                    message_images_data.append(tmp_content_data_item.get("image_key"))
+                    message_images_data.append({message_id: tmp_content_data_item.get("image_key")})
+
 
     print(message_content_data)
     print(message_images_data)
@@ -128,8 +132,10 @@ def process_message_callback(
 
     record["问题概述"] = "\n".join(message_content_data)
 
-    for image in message_images_data:
-        image_path = get_message_resource(client, message_id, image, "image", cache_dir)
+    for message_image_message_id, message_image_id in message_images_data.items():
+        image_path = get_message_resource(
+            client, message_image_message_id, message_image_id, "image", cache_dir
+        )
         print(f"下载文件成功: {image}, {image_path}")
         file_token = upload_media(client, image_path, "bitable_image", bitable_token)
         print("上传文件成功:", file_token)
diff --git a/app/test/tmp.py b/app/test/tmp.py
index fa345ae..b7e7070 100644
--- a/app/test/tmp.py
+++ b/app/test/tmp.py
@@ -138,6 +138,8 @@ for index, item in enumerate(items):
 
     item_content = json.loads(item.get("body").get("content"))
 
+    message_id = item.get("message_id")
+
     if item_content.get("text"):
         message_content_data.append(item_content.get("text"))
 
@@ -154,7 +156,7 @@ for index, item in enumerate(items):
             if tmp_content_data_item.get("tag") == "text":
                 message_content_data.append(tmp_content_data_item.get("text"))
             if tmp_content_data_item.get("tag") == "img":
-                message_images_data.append(tmp_content_data_item.get("image_key"))
+                message_images_data.append({message_id: tmp_content_data_item.get("image_key")})
 
     # print(item_content)