diff --git a/app/demo.py b/app/demo.py index 8399376..ddc8d11 100644 --- a/app/demo.py +++ b/app/demo.py @@ -41,55 +41,55 @@ if not os.path.exists(cache_dir): def do_p2_im_message_receive_v1(data: P2ImMessageReceiveV1) -> None: print(lark.JSON.marshal(data)) - record = {} - images = [] - images_token = [] - message_content = "" - message_type = data.event.message.message_type - content = json.loads(data.event.message.content) + # record = {} + # images = [] + # images_token = [] + # message_content = "" + # message_type = data.event.message.message_type + # content = json.loads(data.event.message.content) - if message_type == "post": - content = content["content"] - for item in chain.from_iterable(content): - if item.get("tag") == "text": - message_content += item["text"] + # if message_type == "post": + # content = content["content"] + # for item in chain.from_iterable(content): + # if item.get("tag") == "text": + # message_content += item["text"] - if item.get("tag") == "img": - images.append(item["image_key"]) + # if item.get("tag") == "img": + # images.append(item["image_key"]) - if message_type == "text": - message_content = content["text"].replace("@_user_1", "").strip() + # if message_type == "text": + # message_content = content["text"].replace("@_user_1", "").strip() - sender_id = data.event.sender.sender_id.open_id - record["问题概述"] = message_content - record["创建人"] = sender_id - message_id = data.event.message.message_id + # sender_id = data.event.sender.sender_id.open_id + # record["问题概述"] = message_content + # record["创建人"] = sender_id + # message_id = data.event.message.message_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_group_message(client, message_id, content) def do_customized_event(data: lark.CustomizedEvent) -> None: @@ -101,15 +101,15 @@ handler = ( encrypt_key, verification_token, lark.LogLevel.DEBUG ) .register_p2_im_message_receive_v1(do_p2_im_message_receive_v1) + .register_p1_customized_event("message", do_customized_event) .build() ) -# .register_p1_customized_event("message", do_customized_event) @app.route("/event", methods=["POST"]) def event(): + print("receive event: ", time.time()) resp = handler.do(parse_req()) - print(resp) return parse_resp(resp)