diff --git a/app/demo.py b/app/demo.py index 8d728bb..fd601df 100644 --- a/app/demo.py +++ b/app/demo.py @@ -54,9 +54,19 @@ def do_p2_im_message_receive_v1(data: P2ImMessageReceiveV1) -> None: record["问题概述"] = message_content record["创建人"] = data.event.sender.sender_id.open_id receive_id = data.event.sender.sender_id.open_id + message_id = data.event.message.message_id add_record(record) content = '{"text":"反馈的问题已经记录到多维表格, 稍后有小伙伴跟进"}' - send_message(receive_id, content) + # send_message(receive_id, content) + + message = { + "content": '{"text":"反馈的问题已经记录到多维表格, 稍后有小伙伴跟进"}', + "msg_type": "text", + "reply_in_thread": True, + } + + send_group_message(message_id, message) + def do_customized_event(data: lark.CustomizedEvent) -> None: @@ -99,6 +109,35 @@ def add_record(data): lark.logger.info(lark.JSON.marshal(response.data, indent=4)) +def send_group_message(message_id, content): + # 构造请求对象 + request: ReplyMessageRequest = ( + ReplyMessageRequest.builder() + .request_body( + ReplyMessageRequestBody.builder() + .content(json.djumps(content)) + .msg_type("text") + .reply_in_thread(True) + .uuid(message_id) + .build() + ) + .build() + ) + + # 发起请求 + response: ReplyMessageResponse = client.im.v1.message.reply(request) + + # 处理失败返回 + if not response.success(): + lark.logger.error( + f"client.im.v1.message.reply failed, code: {response.code}, msg: {response.msg}, log_id: {response.get_log_id()}" + ) + return + + # 处理业务结果 + lark.logger.info(lark.JSON.marshal(response.data, indent=4)) + + def send_message(receive_id, content): # 构造请求对象 request: CreateMessageRequest = (