core: Message Clone + ServiceManager Broadcast 完整实现

张明远交付:
- Message/PlayerCommand/WifiCommand/Destination 加 derive(Clone)
- Broadcast 分支遍历所有插件转发 msg.clone()
- running 标志控制主循环
- Manager 收到 Shutdown 时先广播给所有插件再停
- cargo check 零 warning

Co-Authored-By: GPT-5.4 <noreply@openai.com>
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

src/core/service_manager.rs

@@ -10,6 +10,7 @@ pub struct ServiceManager {
     config: Arc<AppConfig>,
     tx: mpsc::Sender<Envelope>,
     rx: mpsc::Receiver<Envelope>,
+    running: bool,
 }
 
 impl ServiceManager {
@@ -20,6 +21,7 @@ impl ServiceManager {
             config: Arc::new(config),
             tx,
             rx,
+            running: false,
         }
     }
 
@@ -51,7 +53,9 @@ impl ServiceManager {
     /// 主消息循环（阻塞）
     pub fn run(&mut self) -> Result<()> {
         println!("[ServiceManager] 进入主消息循环");
-        loop {
+        self.running = true;
+
+        while self.running {
             let envelope = match self.rx.recv() {
                 Ok(env) => env,
                 Err(_) => {
@@ -72,19 +76,25 @@ impl ServiceManager {
                 }
                 Destination::Broadcast => {
                     let from = envelope.from;
+                    let msg = envelope.message;
+
                     for plugin in &mut self.plugins {
-                        // 不回送给发送者
                         if plugin.id() == from {
                             continue;
                         }
-                        // Broadcast 需要重建 Message（Message 不是 Clone）
-                        // 对于 Broadcast 我们跳过非 Shutdown 消息的深拷贝问题
-                        // 实际实现中 Shutdown 是最关键的广播消息
+
+                        if let Err(e) = plugin.handle_message(msg.clone()) {
+                            eprintln!(
+                                "[ServiceManager] 插件 '{}' 处理广播消息失败: {}",
+                                plugin.id(),
+                                e
+                            );
+                        }
                     }
-                    // 处理 Shutdown
-                    if matches!(envelope.message, Message::Shutdown) {
+
+                    if matches!(msg, Message::Shutdown) {
                         println!("[ServiceManager] 收到 Shutdown 广播");
-                        break;
+                        self.running = false;
                     }
                 }
                 Destination::Manager => {
@@ -113,8 +123,19 @@ impl ServiceManager {
         match msg {
             Message::Shutdown => {
                 println!("[ServiceManager] 收到 Shutdown 指令");
-                // 通过返回 Err 来退出 run 循环不合适，用标志位
-                // 实际上 run() 中已经 break 了
+
+                let shutdown = Message::Shutdown;
+                for plugin in &mut self.plugins {
+                    if let Err(e) = plugin.handle_message(shutdown.clone()) {
+                        eprintln!(
+                            "[ServiceManager] 插件 '{}' 处理 Shutdown 失败: {}",
+                            plugin.id(),
+                            e
+                        );
+                    }
+                }
+
+                self.running = false;
             }
             Message::ConfigReloadRequest => {
                 println!("[ServiceManager] 收到配置重载请求");