liuwei_x_x/abot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

测试音乐信息

Browse Source
This commit is contained in:
liuwei
2025-05-26 15:00:34 +08:00
parent 4ce5fb21fc
commit 44be041eac
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
plugins/music/main.py
View File

@@ -1,3 +1,5 @@
import base64
from loguru import logger from loguru import logger
import requests import requests
from typing import Dict, Any, List, Optional, Tuple from typing import Dict, Any, List, Optional, Tuple
@@ -9,6 +11,8 @@ from utils.robot_cmd.robot_command import Feature, PermissionStatus, GroupBotMan
from utils.decorator.points_decorator import plugin_points_cost from utils.decorator.points_decorator import plugin_points_cost
from wechat_ipad import WechatAPIClient from wechat_ipad import WechatAPIClient
import aiohttp
class MusicPlugin(MessagePluginInterface): class MusicPlugin(MessagePluginInterface):
"""音乐点播插件""" """音乐点播插件"""
@@ -141,16 +145,14 @@ class MusicPlugin(MessagePluginInterface):
self.LOG.error(f"搜索歌曲出错: {e}") self.LOG.error(f"搜索歌曲出错: {e}")
return {} return {}
async def url_to_base64(self, play_url: str):
async def url_to_base64(url):
async with aiohttp.ClientSession() as session: async with aiohttp.ClientSession() as session:
async with session.get(url) as resp: async with session.get(play_url) as resp:
resp.raise_for_status() resp.raise_for_status()
data = await resp.read() data = await resp.read()
b64_str = base64.b64encode(data).decode('utf-8') b64_str = base64.b64encode(data).decode('utf-8')
return b64_str return b64_str
async def _send_music_message(self, bot: WechatAPIClient, song_info: Dict[str, Any], receiver: str) -> bool: async def _send_music_message(self, bot: WechatAPIClient, song_info: Dict[str, Any], receiver: str) -> bool:
"""发送音乐消息""" """发送音乐消息"""
try: try:
@@ -209,7 +211,7 @@ class MusicPlugin(MessagePluginInterface):
self.LOG.info(f"发送音乐消息：{xml_message}") self.LOG.info(f"发送音乐消息：{xml_message}")
res = await bot.send_app_message(wxid=receiver, xml=xml_message, type=0) res = await bot.send_app_message(wxid=receiver, xml=xml_message, type=0)
self.LOG.info(f"发送音乐消息 res:{res}") self.LOG.info(f"发送音乐消息 res:{res}")
voice_base64 =url_to_base64(play_url) voice_base64 = await self.url_to_base64(play_url)
res = await bot.send_voice_message(wxid=receiver, voice=voice_base64) res = await bot.send_voice_message(wxid=receiver, voice=voice_base64)
self.LOG.info(f"发送音乐消息 voice res:{res}") self.LOG.info(f"发送音乐消息 voice res:{res}")
return True return True