diff --git a/app/task.py b/app/task.py index 6de68c0..f07f858 100644 --- a/app/task.py +++ b/app/task.py @@ -19,7 +19,11 @@ def process_message_callback( # 记录问题到多维表格逻辑 # 如果 @机器人 不等于"记录问题", 什么都不做 # 如果 @机器人 等于"记录问题", 获取当前的话题, 从话题中提取问题发起人的所有消息和图片, 记录到多维表格中 - + + if message_type == "text" and message_content != "记录问题": + message_content = content["text"].replace("@_user_1", "").strip() + lark.logger.info(f"message_content: {message_content}") + client = lark.Client.builder().app_id(app_id).app_secret(app_secret).build() diff --git a/app/utils/feishu.py b/app/utils/feishu.py index e60f139..e3b7ad9 100644 --- a/app/utils/feishu.py +++ b/app/utils/feishu.py @@ -10,6 +10,7 @@ from lark_oapi.api.docx.v1 import * import lark_oapi as lark from lark_oapi.api.contact.v3 import * from lark_oapi.api.wiki.v2 import * +from lark_oapi.api.im.v1 import * def search_department(client): @@ -282,6 +283,31 @@ def create_doc_block( lark.logger.info(lark.JSON.marshal(response.data, indent=4)) +def get_messages(client, container_id_type="", container_id="", page_size=50): + # 构造请求对象 + request: ListMessageRequest = ( + ListMessageRequest.builder() + .container_id_type(container_id_type) + .container_id(container_id) + .build() + ) + + # 发起请求 + response: ListMessageResponse = client.im.v1.message.list(request) + + # 处理失败返回 + if not response.success(): + lark.logger.error( + f"client.im.v1.message.list failed, code: {response.code}, msg: {response.msg}, log_id: {response.get_log_id()}" + ) + return + + # 处理业务结果 + lark.logger.info(lark.JSON.marshal(response.data, indent=4)) + + pass + + if __name__ == "__main__": load_dotenv()