1 parent
624283d879
commit
0afc6112cf
1 file changed
+27
-28
+27
-28
@@ -17,14 +17,17 @@ def process_message_callback(
|
||||
app_id, app_secret, bitable_token, table_id, cache_dir, data
|
||||
) -> None:
|
||||
# 记录问题到多维表格逻辑
|
||||
# 如果 @机器人 不等于"记录问题", 什么都不做
|
||||
# 如果 @机器人 等于"记录问题", 获取当前的话题, 从话题中提取问题发起人的所有消息和图片, 记录到多维表格中
|
||||
|
||||
# 如果 @机器人 等于"记录问题", 获取当前的话题
|
||||
message_type = data.get("message_type")
|
||||
content = data.get("content")
|
||||
sender_id = data.get("sender_id")
|
||||
message_id = data.get("message_id")
|
||||
|
||||
message_content = ""
|
||||
record = {}
|
||||
images = []
|
||||
images_token = []
|
||||
|
||||
if message_type == "post":
|
||||
content = content["content"]
|
||||
@@ -43,42 +46,38 @@ def process_message_callback(
|
||||
return
|
||||
|
||||
lark.logger.info(f"message_content: {message_content}")
|
||||
return
|
||||
|
||||
client = lark.Client.builder().app_id(app_id).app_secret(app_secret).build()
|
||||
# # 从话题中提取问题发起人的所有消息和图片, 记录到多维表格中, 记录发消息人 openid 并将处理人设置为@机器人的人
|
||||
# client = lark.Client.builder().app_id(app_id).app_secret(app_secret).build()
|
||||
|
||||
record = {}
|
||||
images = []
|
||||
images_token = []
|
||||
# record["问题概述"] = message_content
|
||||
# record["创建人"] = [{"id": sender_id}]
|
||||
|
||||
record["问题概述"] = message_content
|
||||
record["创建人"] = [{"id": sender_id}]
|
||||
# # 对 image_key 处理并并上传至多维表格
|
||||
|
||||
# 对 image_key 处理并并上传至多维表格
|
||||
# for image in images:
|
||||
# image_path = get_message_resource(client, message_id, image, "image", cache_dir)
|
||||
# print("下载文件成功:", image, image_path)
|
||||
# file_token = upload_media(client, image_path, "bitable_image", bitable_token)
|
||||
# print("上传文件成功:", file_token)
|
||||
# images_token.append(file_token)
|
||||
|
||||
for image in images:
|
||||
image_path = get_message_resource(client, message_id, image, "image", cache_dir)
|
||||
print("下载文件成功:", image, image_path)
|
||||
file_token = upload_media(client, image_path, "bitable_image", bitable_token)
|
||||
print("上传文件成功:", file_token)
|
||||
images_token.append(file_token)
|
||||
# if images:
|
||||
# record["附件"] = [{"file_token": image} for image in images_token]
|
||||
|
||||
if images:
|
||||
record["附件"] = [{"file_token": image} for image in images_token]
|
||||
# record_id = add_record(client, bitable_token, table_id, record)
|
||||
|
||||
record_id = add_record(client, bitable_token, table_id, record)
|
||||
# time.sleep(1)
|
||||
|
||||
time.sleep(1)
|
||||
# update_data = {"处理人": {"id": sender_id}}
|
||||
# update_record(client, bitable_token, table_id, record_id, update_data)
|
||||
|
||||
update_data = {"创建人": {"id": sender_id}}
|
||||
update_record(client, bitable_token, table_id, record_id, update_data)
|
||||
# # content = {"text": "反馈的问题已经记录到多维表格, 稍后有小伙伴跟进"}
|
||||
# # send_message(receive_id, content)
|
||||
|
||||
# content = {"text": "反馈的问题已经记录到多维表格, 稍后有小伙伴跟进"}
|
||||
# send_message(receive_id, content)
|
||||
|
||||
# 回复群组的消息
|
||||
content = f'{{"text": "反馈的问题已经记录到多维表格, 稍后有小伙伴跟进"}}'
|
||||
send_group_message(client, message_id, content)
|
||||
# # 回复群组的消息
|
||||
content = f'{{"text": "问题已经记录到多维表格, 及时更新工单状态"}}'
|
||||
send_message(client, message_id, content)
|
||||
|
||||
|
||||
@shared_task()
|
||||
|
||||
Reference in new issue
Block a user