From 63ec2a8c3490f46b31c639913ea6b2c5619c778f Mon Sep 17 00:00:00 2001 From: Dong_master <2213070223@qq.com> Date: Mon, 21 Jul 2025 17:28:11 +0800 Subject: [PATCH] fix:lark message_id and dingtalk incoming_message --- pkg/pipeline/process/handlers/chat.py | 2 +- pkg/platform/sources/dingtalk.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/pipeline/process/handlers/chat.py b/pkg/pipeline/process/handlers/chat.py index 682be62d..c88d3ce1 100644 --- a/pkg/pipeline/process/handlers/chat.py +++ b/pkg/pipeline/process/handlers/chat.py @@ -74,7 +74,7 @@ class ChatMessageHandler(handler.MessageHandler): raise ValueError(f'未找到请求运行器: {query.pipeline_config["ai"]["runner"]["runner"]}') if is_stream: resp_message_id = uuid.uuid4() - if await query.adapter.create_message_card(resp_message_id,query.message_event.source_platform_object): + if await query.adapter.create_message_card(resp_message_id,query.message_event): async for result in runner.run(query): result.resp_message_id = resp_message_id if query.resp_messages: diff --git a/pkg/platform/sources/dingtalk.py b/pkg/platform/sources/dingtalk.py index a3c91f41..7de5975c 100644 --- a/pkg/platform/sources/dingtalk.py +++ b/pkg/platform/sources/dingtalk.py @@ -180,7 +180,7 @@ class DingTalkAdapter(adapter.MessagePlatformAdapter): async def create_message_card(self,message_id,event): card_template_id = self.config['card_template_id'] - incoming_message = event.incoming_message + incoming_message = event.source_platform_object.incoming_message # message_id = incoming_message.message_id card_instance, card_instance_id = await self.bot.create_and_card(card_template_id, incoming_message) self.card_instance_id_dict[message_id] = (card_instance, card_instance_id)