app add send message

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)