mirror of
https://github.com/langbot-app/LangBot.git
synced 2025-11-25 03:15:06 +08:00
fix:lark message_id and dingtalk incoming_message
This commit is contained in:
@@ -74,7 +74,7 @@ class ChatMessageHandler(handler.MessageHandler):
|
|||||||
raise ValueError(f'未找到请求运行器: {query.pipeline_config["ai"]["runner"]["runner"]}')
|
raise ValueError(f'未找到请求运行器: {query.pipeline_config["ai"]["runner"]["runner"]}')
|
||||||
if is_stream:
|
if is_stream:
|
||||||
resp_message_id = uuid.uuid4()
|
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):
|
async for result in runner.run(query):
|
||||||
result.resp_message_id = resp_message_id
|
result.resp_message_id = resp_message_id
|
||||||
if query.resp_messages:
|
if query.resp_messages:
|
||||||
|
|||||||
@@ -180,7 +180,7 @@ class DingTalkAdapter(adapter.MessagePlatformAdapter):
|
|||||||
|
|
||||||
async def create_message_card(self,message_id,event):
|
async def create_message_card(self,message_id,event):
|
||||||
card_template_id = self.config['card_template_id']
|
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
|
# message_id = incoming_message.message_id
|
||||||
card_instance, card_instance_id = await self.bot.create_and_card(card_template_id, incoming_message)
|
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)
|
self.card_instance_id_dict[message_id] = (card_instance, card_instance_id)
|
||||||
|
|||||||
Reference in New Issue
Block a user