Merge branch 'dev' of https://github.com/MaiM-with-u/MaiBot into dev

src/chat/message_receive/bot.py

@@ -131,6 +131,12 @@ class ChatBot:
             message = MessageRecv(message_data)
             group_info = message.message_info.group_info
             user_info = message.message_info.user_info
+            if message.message_info.additional_config:
+                sent_message = message.message_info.additional_config.get("echo", False)
+                if sent_message:  # 这一段只是为了在一切处理前劫持上报的自身消息，用于更新message_id，需要ada支持上报事件，实际测试中不会对正常使用造成任何问题
+                    await MessageStorage.update_message(message)
+                    return
+
             get_chat_manager().register_message(message)
 
             # 创建聊天流

src/chat/message_receive/storage.py

@@ -101,5 +101,33 @@ class MessageStorage:
         except Exception:
             logger.exception("删除撤回消息失败")
 
+    # 如果需要其他存储相关的函数，可以在这里添加
+    @staticmethod
+    async def update_message(
+        message: MessageRecv,
+    ) -> None:  # 用于实时更新数据库的自身发送消息ID，目前能处理text,reply,image和emoji
+        """更新最新一条匹配消息的message_id"""
+        try:
+            if message.message_segment.type == "notify":
+                mmc_message_id = message.message_segment.data.get("echo")
+                qq_message_id = message.message_segment.data.get("actual_id")
+            else:
+                logger.info(f"更新消息ID错误，seg类型为{message.message_segment.type}")
+                return
+            if not qq_message_id:
+                logger.info("消息不存在message_id，无法更新")
+                return
+            # 查询最新一条匹配消息
+            matched_message = (
+                Messages.select().where((Messages.message_id == mmc_message_id)).order_by(Messages.time.desc()).first()
+            )
 
-# 如果需要其他存储相关的函数，可以在这里添加
+            if matched_message:
+                # 更新找到的消息记录
+                Messages.update(message_id=qq_message_id).where(Messages.id == matched_message.id).execute()
+                logger.info(f"更新消息ID成功: {matched_message.message_id} -> {qq_message_id}")
+            else:
+                logger.debug("未找到匹配的消息")
+
+        except Exception as e:
+            logger.error(f"更新消息ID失败: {e}")