diff --git a/app/task.py b/app/task.py index 880c3ff..4569f8e 100644 --- a/app/task.py +++ b/app/task.py @@ -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()