diff --git a/plugins/message_sign/main.py b/plugins/message_sign/main.py index 44ea24c..b9f0c6b 100644 --- a/plugins/message_sign/main.py +++ b/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}" diff --git a/plugins/stats_dashboard/dashboard_server.py b/plugins/stats_dashboard/dashboard_server.py index 8b768bd..8ff689e 100644 --- a/plugins/stats_dashboard/dashboard_server.py +++ b/plugins/stats_dashboard/dashboard_server.py @@ -146,6 +146,7 @@ class DashboardServer: self.logger.error(f"停止统计看板服务器出错: {e}") raise + def __del__(self): """析构函数,确保资源被释放""" try: