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)