Merge pull request #1249 from MaiM-with-u/dev

Dev

Author: SengokuCola

README.md

@@ -26,12 +26,10 @@
 **🍔MaiCore 是一个基于大语言模型的可交互智能体**
 
 - 💭 **智能对话系统**：基于 LLM 的自然语言交互，聊天时机控制。
-- 🔌 **强大插件系统**：全面重构的插件架构，更多API。
 - 🤔 **实时思维系统**：模拟人类思考过程。
 - 🧠 **表达学习功能**：学习群友的说话风格和表达方式
 - 💝 **情感表达系统**：情绪系统和表情包系统。
-- 🧠 **持久记忆系统**：基于图的长期记忆存储。
-- 🔄 **动态人格系统**：自适应的性格特征和表达方式。
+- 🔌 **强大插件系统**：提供API和事件系统，可编写强大插件。
 
 <div style="text-align: center">
 <a href="https://www.bilibili.com/video/BV1amAneGE3P" target="_blank">
@@ -46,7 +44,7 @@
 
 ## 🔥 更新和安装
 
-**最新版本: v0.10.2** ([更新日志](changelogs/changelog.md))
+**最新版本: v0.10.3** ([更新日志](changelogs/changelog.md))
 
 可前往 [Release](https://github.com/MaiM-with-u/MaiBot/releases/) 页面下载最新版本
 可前往 [启动器发布页面](https://github.com/MaiM-with-u/mailauncher/releases/)下载最新启动器
@@ -64,21 +62,21 @@
 > - QQ 机器人存在被限制风险，请自行了解，谨慎使用。
 > - 由于程序处于开发中，可能消耗较多 token。
 
-## 麦麦MC项目（早期开发）
+## 麦麦MC项目MaiCraft（早期开发）
 [让麦麦玩MC](https://github.com/MaiM-with-u/Maicraft)
 
 交流群：1058573197
 
 ## 💬 讨论
 
 **技术交流群：**
-- [一群](https://qm.qq.com/q/VQ3XZrWgMs) | 
-  [二群](https://qm.qq.com/q/RzmCiRtHEW) | 
-  [三群](https://qm.qq.com/q/wlH5eT8OmQ) |
-  [四群](https://qm.qq.com/q/wGePTl1UyY)
+  [麦麦脑电图](https://qm.qq.com/q/RzmCiRtHEW) | 
+  [麦麦脑磁图](https://qm.qq.com/q/wlH5eT8OmQ) |
+  [麦麦大脑磁共振](https://qm.qq.com/q/VQ3XZrWgMs) | 
+  [麦麦要当VTB](https://qm.qq.com/q/wGePTl1UyY)
 
 **聊天吹水群：**
-- [五群](https://qm.qq.com/q/JxvHZnxyec)
+- [麦麦之闲聊群](https://qm.qq.com/q/JxvHZnxyec)
 
 **插件开发测试版群：**
 - [插件开发群](https://qm.qq.com/q/1036092828)

bot.py

@@ -62,9 +62,10 @@ def easter_egg():
 async def graceful_shutdown():  # sourcery skip: use-named-expression
     try:
         logger.info("正在优雅关闭麦麦...")
-        
+
         from src.plugin_system.core.events_manager import events_manager
         from src.plugin_system.base.component_types import EventType
+
         # 触发 ON_STOP 事件
         await events_manager.handle_mai_events(event_type=EventType.ON_STOP)
 

changelogs/changelog.md

@@ -1,8 +1,26 @@
 # Changelog
 
-0.10.3饼：
-重名问题
-动态频率进一步优化
+0.10.4饼 表达方式优化
+无了
+
+## [0.10.3] - 2025-9-22
+### 🌟 主要功能更改
+- planner支持多动作，移除Sub_planner
+- 移除激活度系统，现在回复完全由planner控制
+- 现可自定义planner行为，更优化的聊天频率控制
+- 支持发送转发和合并转发
+- 关系现在支持多人的信息
+- 更好的event系统，正式建立
+
+### 细节功能更改
+- 支持所有表达方式互通
+- 现可使用付费嵌入模型
+- 添加多种发送类型
+- 优化识图token限制
+- 为空回复添加重试机制
+- 加入brainchat模式，为私聊支持做准备
+- 修复qq号格式
+
 
 
 ## [0.10.2] - 2025-8-31

plugins/hello_world_plugin/plugin.py

@@ -1,3 +1,4 @@
+import random
 from typing import List, Tuple, Type, Any
 from src.plugin_system import (
     BasePlugin,
@@ -12,7 +13,10 @@
     EventType,
     MaiMessages,
     ToolParamType,
+    ReplyContentType,
+    emoji_api,
 )
+from src.config.config import global_config
 
 
 class CompareNumbersTool(BaseTool):
@@ -24,6 +28,7 @@ class CompareNumbersTool(BaseTool):
         ("num1", ToolParamType.FLOAT, "第一个数字", True, None),
         ("num2", ToolParamType.FLOAT, "第二个数字", True, None),
     ]
+    available_for_llm = True
 
     async def execute(self, function_args: dict[str, Any]) -> dict[str, Any]:
         """执行比较两个数的大小
@@ -136,12 +141,80 @@ class PrintMessage(BaseEventHandler):
     handler_name = "print_message_handler"
     handler_description = "打印接收到的消息"
 
-    async def execute(self, message: MaiMessages | None) -> Tuple[bool, bool, str | None, None]:
+    async def execute(self, message: MaiMessages | None) -> Tuple[bool, bool, str | None, None, None]:
         """执行打印消息事件处理"""
         # 打印接收到的消息
         if self.get_config("print_message.enabled", False):
             print(f"接收到消息: {message.raw_message if message else '无效消息'}")
-        return True, True, "消息已打印", None
+        return True, True, "消息已打印", None, None
+
+
+class ForwardMessages(BaseEventHandler):
+    """
+    把接收到的消息转发到指定聊天ID
+
+    此组件是HYBRID消息和FORWARD消息的使用示例。
+    每收到10条消息，就会以1%的概率使用HYBRID消息转发，否则使用FORWARD消息转发。
+    """
+
+    event_type = EventType.ON_MESSAGE
+    handler_name = "forward_messages_handler"
+    handler_description = "把接收到的消息转发到指定聊天ID"
+
+    def __init__(self, *args, **kwargs):
+        super().__init__(*args, **kwargs)
+        self.counter = 0  # 用于计数转发的消息数量
+        self.messages: List[str] = []
+
+    async def execute(self, message: MaiMessages | None) -> Tuple[bool, bool, None, None, None]:
+        if not message:
+            return True, True, None, None, None
+        stream_id = message.stream_id or ""
+
+        if message.plain_text:
+            self.messages.append(message.plain_text)
+            self.counter += 1
+        if self.counter % 10 == 0:
+            if random.random() < 0.01:
+                success = await self.send_hybrid(stream_id, [(ReplyContentType.TEXT, msg) for msg in self.messages])
+            else:
+                success = await self.send_forward(
+                    stream_id,
+                    [
+                        (
+                            str(global_config.bot.qq_account),
+                            str(global_config.bot.nickname),
+                            [(ReplyContentType.TEXT, msg)],
+                        )
+                        for msg in self.messages
+                    ],
+                )
+            if not success:
+                raise ValueError("转发消息失败")
+            self.messages = []
+        return True, True, None, None, None
+
+
+class RandomEmojis(BaseCommand):
+    command_name = "random_emojis"
+    command_description = "发送多张随机表情包"
+    command_pattern = r"^/random_emojis$"
+
+    async def execute(self):
+        emojis = await emoji_api.get_random(5)
+        if not emojis:
+            return False, "未找到表情包", False
+        emoji_base64_list = []
+        for emoji in emojis:
+            emoji_base64_list.append(emoji[0])
+        return await self.forward_images(emoji_base64_list)
+
+    async def forward_images(self, images: List[str]):
+        """
+        把多张图片用合并转发的方式发给用户
+        """
+        success = await self.send_forward([("0", "神秘用户", [(ReplyContentType.IMAGE, img)]) for img in images])
+        return (True, "已发送随机表情包", True) if success else (False, "发送随机表情包失败", False)
 
 
 # ===== 插件注册 =====
@@ -153,7 +226,7 @@ class HelloWorldPlugin(BasePlugin):
 
     # 插件基本信息
     plugin_name: str = "hello_world_plugin"  # 内部标识符
-    enable_plugin: bool = True
+    enable_plugin: bool = False
     dependencies: List[str] = []  # 插件依赖列表
     python_dependencies: List[str] = []  # Python包依赖列表
     config_file_name: str = "config.toml"  # 配置文件名
@@ -185,6 +258,8 @@ def get_plugin_components(self) -> List[Tuple[ComponentInfo, Type]]:
             (ByeAction.get_action_info(), ByeAction),  # 添加告别Action
             (TimeCommand.get_command_info(), TimeCommand),
             (PrintMessage.get_handler_info(), PrintMessage),
+            (ForwardMessages.get_handler_info(), ForwardMessages),
+            (RandomEmojis.get_command_info(), RandomEmojis),
         ]