使用util發送消息

plugins/message_sign/main.py

@@ -6,6 +6,7 @@ from typing import Dict, Any, List, Optional, Tuple
 from wcferry import Wcf, WxMsg
 
 from db.connection import DBConnectionManager
+from message_util import MessageUtil
 from plugin_common.message_plugin_interface import MessagePluginInterface
 from plugin_common.plugin_interface import PluginStatus
 from plugins.stats_collector.decorators import plugin_stats_decorator
@@ -57,7 +58,7 @@ class MessageSignPlugin(MessagePluginInterface):
         # 保存上下文对象
         self.wcf = context.get("wcf")
         self.event_system = context.get("event_system")
-        self.message_util = context.get("message_util")
+        self.message_util:MessageUtil = context.get("message_util")
         self.gbm = context.get("gbm")
         self.all_contacts = context.get("all_contacts", {})
 
@@ -149,7 +150,7 @@ class MessageSignPlugin(MessagePluginInterface):
 
                 # 如果 sign_stat 已经大于或等于今天的零点，则认为用户已经签到过了
                 if sign_stat >= today_start:
-                    wcf.send_text(f"您今天已经签到过了！当前积分：{user_record['points']}", 
+                    self.message_util.send_text_msg(f"您今天已经签到过了！当前积分：{user_record['points']}",
                                   (roomid if roomid else sender), sender)
                     return True, "已签到"
 
@@ -198,12 +199,12 @@ class MessageSignPlugin(MessagePluginInterface):
             elif streak > 1:
                 output += f"连签 {streak} 天！"
 
-            wcf.send_text(output, (roomid if roomid else sender), sender)
+            self.message_util.send_text_msg(output, (roomid if roomid else sender), sender)
             return True, "签到成功"
 
         except Exception as e:
             self.LOG.error(f"处理签到请求出错: {e}")
-            wcf.send_text(f"签到出错：{e}",
+            self.message_util.send_text_msg(f"签到出错：{e}",
                           (roomid if roomid else sender), sender)
             return True, f"处理出错: {e}"
 

plugins/stats_dashboard/dashboard_server.py

@@ -146,6 +146,7 @@ class DashboardServer:
             self.logger.error(f"停止统计看板服务器出错: {e}")
             raise
 
+
     def __del__(self):
         """析构函数，确保资源被释放"""
         try: