mirror of
https://github.com/Zippland/Bubbles.git
synced 2026-01-19 01:21:15 +08:00
删了一些东西
This commit is contained in:
zihanjian
@@ -9,138 +9,6 @@ from typing import TYPE_CHECKING
|
||||
if TYPE_CHECKING:
|
||||
from .context import MessageContext
|
||||
|
||||
def handle_help(ctx: 'MessageContext', match: Optional[Match]) -> bool:
|
||||
"""
|
||||
处理 "帮助" 命令
|
||||
|
||||
匹配: info/帮助/指令
|
||||
"""
|
||||
help_text = [
|
||||
"🤖 泡泡的指令列表 🤖",
|
||||
"",
|
||||
"【实用工具】",
|
||||
"- 天气/温度 [城市名]",
|
||||
"- 天气预报/预报 [城市名]",
|
||||
"- 新闻",
|
||||
"- ask [问题]",
|
||||
"",
|
||||
"【提醒】",
|
||||
"- 提醒xxxxx：一次性、每日、每周",
|
||||
"- 查看提醒/我的提醒/提醒列表",
|
||||
"- 删..提醒..",
|
||||
"",
|
||||
"【群聊工具】",
|
||||
"- summary/总结",
|
||||
"- clearmessages/清除历史",
|
||||
""
|
||||
]
|
||||
help_text = "\n".join(help_text)
|
||||
|
||||
# 发送消息
|
||||
return ctx.send_text(help_text)
|
||||
|
||||
def handle_summary(ctx: 'MessageContext', match: Optional[Match]) -> bool:
|
||||
"""
|
||||
处理 "消息总结" 命令
|
||||
|
||||
匹配: summary/总结
|
||||
"""
|
||||
if not ctx.is_group:
|
||||
ctx.send_text("⚠️ 消息总结功能仅支持群聊")
|
||||
return True
|
||||
|
||||
try:
|
||||
# 获取群聊ID
|
||||
chat_id = ctx.msg.roomid
|
||||
|
||||
# 使用MessageSummary生成总结
|
||||
if ctx.robot and hasattr(ctx.robot, "message_summary") and hasattr(ctx.robot, "chat"):
|
||||
summary = ctx.robot.message_summary.summarize_messages(chat_id, ctx.robot.chat)
|
||||
|
||||
# 发送总结
|
||||
ctx.send_text(summary)
|
||||
|
||||
return True
|
||||
else:
|
||||
ctx.send_text("⚠️ 消息总结功能不可用")
|
||||
return False
|
||||
except Exception as e:
|
||||
if ctx.logger:
|
||||
ctx.logger.error(f"生成消息总结出错: {e}")
|
||||
ctx.send_text("⚠️ 生成消息总结失败")
|
||||
return False
|
||||
|
||||
def handle_clear_messages(ctx: 'MessageContext', match: Optional[Match]) -> bool:
|
||||
"""
|
||||
处理 "清除消息历史" 命令
|
||||
|
||||
匹配: clearmessages/清除消息/清除历史
|
||||
"""
|
||||
if not ctx.is_group:
|
||||
ctx.send_text("⚠️ 消息历史管理功能仅支持群聊")
|
||||
return True
|
||||
|
||||
try:
|
||||
# 获取群聊ID
|
||||
chat_id = ctx.msg.roomid
|
||||
|
||||
# 清除历史
|
||||
if ctx.robot and hasattr(ctx.robot, "message_summary"):
|
||||
if ctx.robot.message_summary.clear_message_history(chat_id):
|
||||
ctx.send_text("✅ 已清除本群的消息历史记录")
|
||||
else:
|
||||
ctx.send_text("⚠️ 本群没有消息历史记录")
|
||||
|
||||
return True
|
||||
else:
|
||||
ctx.send_text("⚠️ 消息历史管理功能不可用")
|
||||
return False
|
||||
except Exception as e:
|
||||
if ctx.logger:
|
||||
ctx.logger.error(f"清除消息历史出错: {e}")
|
||||
ctx.send_text("⚠️ 清除消息历史失败")
|
||||
return False
|
||||
|
||||
def handle_news_request(ctx: 'MessageContext', match: Optional[Match]) -> bool:
|
||||
"""
|
||||
处理 "新闻" 命令
|
||||
|
||||
匹配: 新闻
|
||||
"""
|
||||
if ctx.logger:
|
||||
ctx.logger.info(f"收到来自 {ctx.sender_name} (群聊: {ctx.msg.roomid if ctx.is_group else '无'}) 的新闻请求")
|
||||
|
||||
try:
|
||||
from function.func_news import News
|
||||
news_instance = News()
|
||||
# 调用方法，接收返回的元组(is_today, news_content)
|
||||
is_today, news_content = news_instance.get_important_news()
|
||||
|
||||
receiver = ctx.get_receiver()
|
||||
sender_for_at = ctx.msg.sender if ctx.is_group else "" # 群聊中@请求者
|
||||
|
||||
if is_today:
|
||||
# 是当天新闻，直接发送
|
||||
ctx.send_text(f"📰 今日要闻来啦：\n{news_content}", sender_for_at)
|
||||
else:
|
||||
# 不是当天新闻或获取失败
|
||||
if news_content:
|
||||
# 有内容，说明是旧闻
|
||||
prompt = "ℹ️ 今日新闻暂未发布，为您找到最近的一条新闻："
|
||||
ctx.send_text(f"{prompt}\n{news_content}", sender_for_at)
|
||||
else:
|
||||
# 内容为空，说明获取彻底失败
|
||||
ctx.send_text("❌ 获取新闻失败，请稍后重试或联系管理员。", sender_for_at)
|
||||
|
||||
return True # 无论结果如何，命令本身算成功处理
|
||||
|
||||
except Exception as e:
|
||||
if ctx.logger: ctx.logger.error(f"处理新闻请求时出错: {e}")
|
||||
receiver = ctx.get_receiver()
|
||||
sender_for_at = ctx.msg.sender if ctx.is_group else ""
|
||||
ctx.send_text("❌ 获取新闻时发生错误，请稍后重试。", sender_for_at)
|
||||
return False # 处理失败
|
||||
|
||||
def handle_chitchat(ctx: 'MessageContext', match: Optional[Match]) -> bool:
|
||||
"""
|
||||
处理闲聊，调用AI模型生成回复
|
||||
@@ -291,76 +159,6 @@ def handle_chitchat(ctx: 'MessageContext', match: Optional[Match]) -> bool:
|
||||
ctx.logger.error(f"获取AI回复时出错: {e}")
|
||||
return False
|
||||
|
||||
def handle_insult(ctx: 'MessageContext', match: Optional[Match]) -> bool:
|
||||
"""
|
||||
处理 "骂人" 命令
|
||||
|
||||
匹配: 骂一下@XX
|
||||
"""
|
||||
if not ctx.is_group:
|
||||
ctx.send_text("❌ 骂人功能只支持群聊哦~")
|
||||
return True
|
||||
|
||||
if not match:
|
||||
return False
|
||||
|
||||
# 获取目标名称
|
||||
target_mention_name = match.group(1).strip()
|
||||
|
||||
if ctx.logger:
|
||||
ctx.logger.info(f"群聊 {ctx.msg.roomid} 中检测到骂人指令，提及目标：{target_mention_name}")
|
||||
|
||||
# 默认使用提及的名称
|
||||
actual_target_name = target_mention_name
|
||||
target_wxid = None
|
||||
|
||||
# 尝试查找实际群成员昵称和wxid
|
||||
try:
|
||||
found = False
|
||||
for wxid, name in ctx.room_members.items():
|
||||
# 优先完全匹配，其次部分匹配
|
||||
if target_mention_name == name:
|
||||
target_wxid = wxid
|
||||
actual_target_name = name
|
||||
found = True
|
||||
break
|
||||
if not found: # 如果完全匹配不到，再尝试部分匹配
|
||||
for wxid, name in ctx.room_members.items():
|
||||
if target_mention_name in name:
|
||||
target_wxid = wxid
|
||||
actual_target_name = name
|
||||
break
|
||||
except Exception as e:
|
||||
if ctx.logger:
|
||||
ctx.logger.error(f"查找群成员信息时出错: {e}")
|
||||
# 出错时继续使用提及的名称
|
||||
|
||||
# 禁止骂机器人自己
|
||||
if target_wxid and target_wxid == ctx.robot_wxid:
|
||||
ctx.send_text("😅 不行，我不能骂我自己。")
|
||||
return True
|
||||
|
||||
# 即使找不到wxid，仍然尝试使用提及的名字骂
|
||||
try:
|
||||
from function.func_insult import generate_random_insult
|
||||
insult_text = generate_random_insult(actual_target_name)
|
||||
ctx.send_text(insult_text)
|
||||
|
||||
if ctx.logger:
|
||||
ctx.logger.info(f"已发送骂人消息至群 {ctx.msg.roomid}，目标: {actual_target_name}")
|
||||
|
||||
return True
|
||||
except ImportError:
|
||||
if ctx.logger:
|
||||
ctx.logger.error("无法导入 func_insult 模块。")
|
||||
ctx.send_text("Oops，我的骂人模块好像坏了...")
|
||||
return True
|
||||
except Exception as e:
|
||||
if ctx.logger:
|
||||
ctx.logger.error(f"生成或发送骂人消息时出错: {e}")
|
||||
ctx.send_text("呃，我想骂但出错了...")
|
||||
return True
|
||||
|
||||
def handle_perplexity_ask(ctx: 'MessageContext', match: Optional[Match]) -> bool:
|
||||
"""
|
||||
处理 "ask" 命令，调用 Perplexity AI
|
||||
@@ -983,73 +781,4 @@ def handle_delete_reminder(ctx: 'MessageContext', match: Optional[Match]) -> boo
|
||||
ctx.send_text(f"❌ 处理删除提醒时发生意外错误。", at_list)
|
||||
if ctx.logger:
|
||||
ctx.logger.error(f"handle_delete_reminder AI 部分顶层错误: {e}", exc_info=True)
|
||||
return True
|
||||
|
||||
def handle_weather_forecast(ctx: 'MessageContext', match: Optional[Match]) -> bool:
|
||||
"""
|
||||
处理 "天气预报" 或 "预报" 命令
|
||||
|
||||
匹配: 天气预报 [城市名] 或 预报 [城市名]
|
||||
"""
|
||||
if not match:
|
||||
return False
|
||||
|
||||
city_name = match.group(1).strip()
|
||||
if not city_name:
|
||||
ctx.send_text("🤔 请告诉我你想查询哪个城市的天气预报，例如：天气预报 北京")
|
||||
return True
|
||||
|
||||
if ctx.logger:
|
||||
ctx.logger.info(f"天气预报查询指令匹配: 城市={city_name}")
|
||||
|
||||
# --- 加载城市代码 ---
|
||||
city_codes: Dict[str, str] = {}
|
||||
city_code_path = os.path.join(os.path.dirname(__file__), '..', 'function', 'main_city.json') # 确保路径正确
|
||||
try:
|
||||
with open(city_code_path, 'r', encoding='utf-8') as f:
|
||||
city_codes = json.load(f)
|
||||
except FileNotFoundError:
|
||||
if ctx.logger:
|
||||
ctx.logger.error(f"城市代码文件未找到: {city_code_path}")
|
||||
ctx.send_text("⚠️ 抱歉，天气功能所需的城市列表文件丢失了。")
|
||||
return True
|
||||
except json.JSONDecodeError:
|
||||
if ctx.logger:
|
||||
ctx.logger.error(f"无法解析城市代码文件: {city_code_path}")
|
||||
ctx.send_text("⚠️ 抱歉，天气功能的城市列表文件格式错误。")
|
||||
return True
|
||||
except Exception as e:
|
||||
if ctx.logger:
|
||||
ctx.logger.error(f"加载城市代码时发生未知错误: {e}", exc_info=True)
|
||||
ctx.send_text("⚠️ 抱歉，加载城市代码时发生错误。")
|
||||
return True
|
||||
# --- 城市代码加载完毕 ---
|
||||
|
||||
city_code = city_codes.get(city_name)
|
||||
|
||||
if not city_code:
|
||||
# 尝试模糊匹配 (可选，如果需要)
|
||||
found = False
|
||||
for name, code in city_codes.items():
|
||||
if city_name in name: # 如果输入的名字是城市全名的一部分
|
||||
city_code = code
|
||||
city_name = name # 使用找到的完整城市名
|
||||
if ctx.logger:
|
||||
ctx.logger.info(f"城市 '{match.group(1).strip()}' 未精确匹配，使用模糊匹配结果: {city_name} ({city_code})")
|
||||
found = True
|
||||
break
|
||||
if not found:
|
||||
ctx.send_text(f"😕 找不到城市 '{city_name}' 的天气信息，请检查城市名称是否正确。")
|
||||
return True
|
||||
|
||||
# 获取天气信息 (包含预报)
|
||||
try:
|
||||
from function.func_weather import Weather
|
||||
weather_info = Weather(city_code).get_weather(include_forecast=True) # 注意这里传入True
|
||||
ctx.send_text(weather_info)
|
||||
except Exception as e:
|
||||
if ctx.logger:
|
||||
ctx.logger.error(f"获取城市 {city_name}({city_code}) 天气预报时出错: {e}", exc_info=True)
|
||||
ctx.send_text(f"😥 获取 {city_name} 天气预报时遇到问题，请稍后再试。")
|
||||
|
||||
return True
|
||||
return True
|
||||
Reference in New Issue
Block a user