---fix 提交企微msgId，上送给dify

Author: yuanmc

src/langbot/pkg/pipeline/pipelinemgr.py

@@ -320,7 +320,15 @@ async def process_query(self, query: pipeline_query.Query):
                 message_chain=query.message_chain,
             )
 
+            platform_message_id = getattr(query.message_event.source_platform_object, 'message_id', '')
+            self.ap.logger.debug(
+                f'MessageReceived query={query.query_id} platform_message_id={platform_message_id}'
+            )
             event_ctx = await self.ap.plugin_connector.emit_event(event_obj, bound_plugins)
+            self.ap.logger.debug(
+                f'MessageReceived result query={query.query_id} prevented={event_ctx.is_prevented_default()} '
+                f'platform_message_id={platform_message_id}'
+            )
 
             if event_ctx.is_prevented_default():
                 return

src/langbot/pkg/pipeline/preproc/preproc.py

@@ -109,6 +109,7 @@ async def process(
         elif isinstance(query.message_event, platform_events.FriendMessage):
             sender_name = query.message_event.sender.nickname
 
+        platform_message_id = getattr(query.message_event.source_platform_object, 'message_id', '')
         variables = {
             'launcher_type': query.session.launcher_type.value,
             'launcher_id': query.session.launcher_id,
@@ -122,6 +123,7 @@ async def process(
             if isinstance(query.message_event, platform_events.GroupMessage)
             else '',
             'sender_name': sender_name,
+            'platform_message_id': platform_message_id,
         }
         query.variables.update(variables)
 

src/langbot/pkg/pipeline/process/handlers/chat.py

@@ -50,7 +50,16 @@ async def handle(
 
         # Get bound plugins for filtering
         bound_plugins = query.variables.get('_pipeline_bound_plugins', None)
+        platform_message_id = getattr(query.message_event.source_platform_object, 'message_id', '')
+        self.ap.logger.debug(
+            f'PersonNormalMessageReceived query={query.query_id} platform_message_id={platform_message_id}'
+        )
         event_ctx = await self.ap.plugin_connector.emit_event(event, bound_plugins)
+        self.ap.logger.debug(
+            f'PersonNormalMessageReceived result query={query.query_id} '
+            f'prevented={event_ctx.is_prevented_default()} platform_message_id={platform_message_id} '
+            f'has_reply_chain={event_ctx.event.reply_message_chain is not None}'
+        )
 
         is_create_card = False  # 判断下是否需要创建流式卡片