diff --git a/app/demo.py b/app/demo.py index 8cebfe4..7558f48 100644 --- a/app/demo.py +++ b/app/demo.py @@ -33,7 +33,10 @@ def do_p2_im_message_receive_v1(data: P2ImMessageReceiveV1) -> None: record = {} record["问题概述"] = data.event.message.content record["创建人"] = data.event.sender.sender_id.open_id + receive_id = data.event.sender.sender_id.open_id add_record(record) + content = '{"text":"反馈的问题已经记录到多维表格, 稍后有小伙伴跟进"}' + send_message(receive_id, content) def do_customized_event(data: lark.CustomizedEvent) -> None: @@ -76,10 +79,38 @@ def add_record(data): lark.logger.info(lark.JSON.marshal(response.data, indent=4)) +def send_message(receive_id, content): + # 构造请求对象 + request: CreateMessageRequest = ( + CreateMessageRequest.builder() + .receive_id_type("open_id") + .request_body( + CreateMessageRequestBody.builder() + .receive_id(receive_id) + .msg_type("text") + .content(content) + .build() + ) + .build() + ) + + # 发起请求 + response: CreateMessageResponse = client.im.v1.message.create(request) + + # 处理失败返回 + if not response.success(): + lark.logger.error( + f"client.im.v1.message.create failed, code: {response.code}, msg: {response.msg}, log_id: {response.get_log_id()}" + ) + return + + # 处理业务结果 + lark.logger.info(lark.JSON.marshal(response.data, indent=4)) + + @app.route("/event", methods=["POST"]) def event(): resp = handler.do(parse_req()) - return parse_resp(resp) diff --git a/docker-compose.yaml b/docker-compose.yaml index 05eb5f6..a5f1c2e 100644 --- a/docker-compose.yaml +++ b/docker-compose.yaml @@ -10,3 +10,5 @@ services: - APP_SECRET=${APP_SECRET} - ENCRYPT_KEY=${ENCRYPT_KEY} - VERIFICATION_TOKEN=${VERIFICATION_TOKEN} + - BITABLE_TOKEN=${BITABLE_TOKEN} + - TABLE_ID=${TABLE_ID}