1 parent
4e58e5b3aa
commit
2a47d89047
2 files changed
+12
-4
No files matched your search
+9
-3
@@ -21,6 +21,7 @@ def parse_history_message(data):
|
|||||||
items = data.get("items")
|
items = data.get("items")
|
||||||
|
|
||||||
for index, item in enumerate(items):
|
for index, item in enumerate(items):
|
||||||
|
print("=======================")
|
||||||
|
|
||||||
sender_id_item = item.get("sender").get("id")
|
sender_id_item = item.get("sender").get("id")
|
||||||
if index == 0:
|
if index == 0:
|
||||||
@@ -31,6 +32,8 @@ def parse_history_message(data):
|
|||||||
|
|
||||||
item_content = json.loads(item.get("body").get("content"))
|
item_content = json.loads(item.get("body").get("content"))
|
||||||
|
|
||||||
|
message_id = item.get("message_id")
|
||||||
|
|
||||||
if item_content.get("text"):
|
if item_content.get("text"):
|
||||||
message_content_data.append(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":
|
if tmp_content_data_item.get("tag") == "text":
|
||||||
message_content_data.append(tmp_content_data_item.get("text"))
|
message_content_data.append(tmp_content_data_item.get("text"))
|
||||||
if tmp_content_data_item.get("tag") == "img":
|
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_content_data)
|
||||||
print(message_images_data)
|
print(message_images_data)
|
||||||
@@ -128,8 +132,10 @@ def process_message_callback(
|
|||||||
|
|
||||||
record["问题概述"] = "\n".join(message_content_data)
|
record["问题概述"] = "\n".join(message_content_data)
|
||||||
|
|
||||||
for image in message_images_data:
|
for message_image_message_id, message_image_id in message_images_data.items():
|
||||||
image_path = get_message_resource(client, message_id, image, "image", cache_dir)
|
image_path = get_message_resource(
|
||||||
|
client, message_image_message_id, message_image_id, "image", cache_dir
|
||||||
|
)
|
||||||
print(f"下载文件成功: {image}, {image_path}")
|
print(f"下载文件成功: {image}, {image_path}")
|
||||||
file_token = upload_media(client, image_path, "bitable_image", bitable_token)
|
file_token = upload_media(client, image_path, "bitable_image", bitable_token)
|
||||||
print("上传文件成功:", file_token)
|
print("上传文件成功:", file_token)
|
||||||
|
|||||||
+3
-1
@@ -138,6 +138,8 @@ for index, item in enumerate(items):
|
|||||||
|
|
||||||
item_content = json.loads(item.get("body").get("content"))
|
item_content = json.loads(item.get("body").get("content"))
|
||||||
|
|
||||||
|
message_id = item.get("message_id")
|
||||||
|
|
||||||
if item_content.get("text"):
|
if item_content.get("text"):
|
||||||
message_content_data.append(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":
|
if tmp_content_data_item.get("tag") == "text":
|
||||||
message_content_data.append(tmp_content_data_item.get("text"))
|
message_content_data.append(tmp_content_data_item.get("text"))
|
||||||
if tmp_content_data_item.get("tag") == "img":
|
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)
|
# print(item_content)
|
||||||
|
|
||||||
|
|||||||
Reference in new issue
Block a user