Merge pull request #57 from luoqiz/event-test

feat: 添加@我事件处理示例

Author: lich0821

src-tauri/Cargo.lock

@@ -42,6 +42,7 @@ ureq = { version = "2.10", features = ["json"] }
 rust_socketio = {version = "0.6.0", features = ["async"] }
 futures-util = "0.3.31"
 regex = "1"
+quickxml_to_serde = {version ="0.6.0", features = ["json_types", "regex_path"] }
 
 [features]
 # this feature is used for production builds or when `devPath` points to the filesystem

src-tauri/Cargo.toml

@@ -0,0 +1,64 @@
+use async_trait::async_trait;
+use quickxml_to_serde::{xml_string_to_json, Config};
+
+use crate::{handler::event_entity::{Event, EventHandler}, service::global_service::GLOBAL, wcferry::wcf};
+
+/// 日志打印
+pub struct EventMessageHandler {
+    pub id: String,
+}
+
+#[async_trait]
+impl EventHandler for EventMessageHandler {
+    async fn handle(&mut self, event: Event) {
+        if let Event::ClientMessage(ref msg) = event {
+            if msg.r#type == 1 {
+                
+                log::debug!("[{}] 接收到事件推送：{:?}", self.id, msg);
+                if !msg.content.contains("关键词")  {
+                    return
+                }
+
+                // 解析xml 判断是否是at自己的信息
+                let mut is_at_me = false;
+
+                let global = GLOBAL.get().unwrap();
+                let wechat_service = global.wechat_service.clone();
+                let self_wx_id = wechat_service.lock().unwrap().get_self_wxid();
+
+                let json = xml_string_to_json(msg.xml.clone(), &Config::new_with_defaults()).unwrap();
+                let msgsource = json.get("msgsource");
+                if msgsource.is_some(){
+                    // 事件推送中包含 @某人，记录 @某人列表
+                    let at_user_list = msgsource.unwrap().get("atuserlist");
+                    if at_user_list.is_some() {
+                        
+                        let at_user_list = at_user_list.unwrap();
+                        for at_user_item in at_user_list.as_str().unwrap().split(",") {
+                            if self_wx_id == at_user_item {
+                                is_at_me = true;
+                            }
+                        }
+                    }
+                }
+
+                // 如果不是@我，则停止处理
+                if !is_at_me {
+                    return;
+                }
+                log::debug!("[{}] 接收到事件有人@我：{:?}", self.id, msg);
+                let wechat_service = global.wechat_service.clone();
+                let text_msg = wcf::TextMsg{
+                    msg: format!("@{} {}",msg.sender.clone()," 事件推送有人at我".to_string()),
+                    receiver: msg.roomid.clone(),
+                    aters: msg.sender.clone()
+                };
+                log::debug!("发送的文本信息 -- {:?}",text_msg);
+                wechat_service.lock().unwrap().send_text(text_msg);
+            }
+        }
+    }
+}
+
+
+

src-tauri/src/handler/message/event_message_handler.rs

@@ -1,4 +1,5 @@
 pub mod log_message_handler;
 pub mod console_message_handler;
 pub mod http_message_handler;
-pub mod socketio_message_handler;
+pub mod socketio_message_handler;
+pub mod event_message_handler;

src-tauri/src/handler/message/mod.rs

@@ -2,7 +2,7 @@ use std::{fs, sync::{Arc, Mutex, OnceLock, RwLock}};
 
 use rand::Rng;
 
-use crate::{handler::{message::{http_message_handler::HttpMessageHandler, log_message_handler::LogMessageHandler, socketio_message_handler::SocketIOMessageHandler}, msg_event_mgr::MsgEventBus, startup::service_handler::HttpServerHandler, startup_event_mgr::StartUpEventBus}, service::http_server_service::HttpServerService, wechat_config::WechatConfig};
+use crate::{handler::{message::{event_message_handler::EventMessageHandler, http_message_handler::HttpMessageHandler, log_message_handler::LogMessageHandler, socketio_message_handler::SocketIOMessageHandler}, msg_event_mgr::MsgEventBus, startup::service_handler::HttpServerHandler, startup_event_mgr::StartUpEventBus}, service::http_server_service::HttpServerService, wechat_config::WechatConfig};
 
 use super::{socketio_service::SocketIOService, wechat_service::WechatService};
 
@@ -66,11 +66,17 @@ pub fn initialize_global() {
   msg_event_bus.subscribe(http_handler);
 
 
-    // socketIO 消息转发
-    let socket_io_handler = Box::new(SocketIOMessageHandler {
-      id: rng.gen::<u32>().to_string(),
-    });
-    msg_event_bus.subscribe(socket_io_handler);
+  // 事件处理
+  let event_msg_handler = Box::new(EventMessageHandler {
+    id: "@事件处理器".to_string(),
+  });
+  msg_event_bus.subscribe(event_msg_handler);
+
+  // socketIO 消息转发
+  let socket_io_handler = Box::new(SocketIOMessageHandler {
+    id: rng.gen::<u32>().to_string(),
+  });
+  msg_event_bus.subscribe(socket_io_handler);
 
 
   log::info!("-------------------微信消息监听初始化 结束--------------------------------");

src-tauri/src/service/global_service.rs

@@ -1,6 +1,6 @@
 use std::sync::{Arc, Mutex};
 
-use crate::wcferry::{wcf::RichText, WeChat};
+use crate::wcferry::{wcf::{self, RichText}, WeChat};
 
 pub struct WechatService {
   pub wechat : Option<Arc<Mutex<WeChat>>>,
@@ -13,10 +13,29 @@ impl WechatService {
     WechatService { wechat }
   }
 
+  // 发送富文本信息
   pub fn send_rich_text(&mut self, msg: RichText) {
     if let Some(wc) = &self.wechat {
       let wcc = wc.lock().unwrap();
       let _ = wcc.send_rich_text(msg);
     }
   }
+
+  // 获取自身的 wxid
+  pub fn get_self_wxid(&mut self) ->  String  {
+    if let Some(wc) = &self.wechat {
+      let wcc = wc.lock().unwrap();
+      return  wcc.get_self_wxid().unwrap_or("".to_string());
+    }
+    "".to_string()
+  }
+
+  // 发送文本信息
+  pub fn send_text(&mut self, content: wcf::TextMsg) {
+    if let Some(wc) = &self.wechat {
+      let wcc = wc.lock().unwrap();
+      let _ = wcc.send_text(content);
+    }
+  }
+  
 }

src-tauri/src/service/wechat_service.rs

@@ -12,27 +12,18 @@ declare module 'vue' {
     ElAutoResizer: typeof import('element-plus/es')['ElAutoResizer']
     ElAvatar: typeof import('element-plus/es')['ElAvatar']
     ElButton: typeof import('element-plus/es')['ElButton']
-    ElCard: typeof import('element-plus/es')['ElCard']
-    ElCol: typeof import('element-plus/es')['ElCol']
     ElContainer: typeof import('element-plus/es')['ElContainer']
     ElFooter: typeof import('element-plus/es')['ElFooter']
-    ElForm: typeof import('element-plus/es')['ElForm']
-    ElFormItem: typeof import('element-plus/es')['ElFormItem']
     ElHeader: typeof import('element-plus/es')['ElHeader']
-    ElInput: typeof import('element-plus/es')['ElInput']
-    ElInputNumber: typeof import('element-plus/es')['ElInputNumber']
     ElMain: typeof import('element-plus/es')['ElMain']
     ElMenu: typeof import('element-plus/es')['ElMenu']
     ElMenuItem: typeof import('element-plus/es')['ElMenuItem']
     ElOption: typeof import('element-plus/es')['ElOption']
-    ElRow: typeof import('element-plus/es')['ElRow']
     ElSelect: typeof import('element-plus/es')['ElSelect']
     ElSpace: typeof import('element-plus/es')['ElSpace']
     ElSwitch: typeof import('element-plus/es')['ElSwitch']
     ElTable: typeof import('element-plus/es')['ElTable']
     ElTableColumn: typeof import('element-plus/es')['ElTableColumn']
-    ElTabPane: typeof import('element-plus/es')['ElTabPane']
-    ElTabs: typeof import('element-plus/es')['ElTabs']
     ElText: typeof import('element-plus/es')['ElText']
     Home: typeof import('./components/Home.vue')['default']
     JsonFormat: typeof import('./components/tools/JsonFormat.vue')['default']