mirror of
https://github.com/algerkong/AlgerMusicPlayer.git
synced 2026-04-23 15:47:23 +08:00
feat: add custom api
This commit is contained in:
shano
+43
-23
@@ -10,6 +10,8 @@ import requestMusic from '@/utils/request_music';
|
||||
|
||||
import { searchAndGetBilibiliAudioUrl } from './bilibili';
|
||||
import { parseFromGDMusic } from './gdmusic';
|
||||
import { parseFromCustomApi } from './parseFromCustomApi';
|
||||
import type { ParsedMusicResult } from './gdmusic';
|
||||
|
||||
const { addData, getData, deleteData } = musicDB;
|
||||
|
||||
@@ -114,7 +116,7 @@ const getBilibiliAudio = async (data: SongResult) => {
|
||||
* @param data 歌曲数据
|
||||
* @returns 解析结果，失败时返回null
|
||||
*/
|
||||
const getGDMusicAudio = async (id: number, data: SongResult) => {
|
||||
const getGDMusicAudio = async (id: number, data: SongResult): Promise<ParsedMusicResult | null> => { // <-- 在这里明确声明返回类型
|
||||
try {
|
||||
const gdResult = await parseFromGDMusic(id, data, '999');
|
||||
if (gdResult) {
|
||||
@@ -146,19 +148,19 @@ const getUnblockMusicAudio = (id: number, data: SongResult, sources: any[]) => {
|
||||
* @returns 解析结果
|
||||
*/
|
||||
export const getParsingMusicUrl = async (id: number, data: SongResult) => {
|
||||
if(isElectron){
|
||||
if (isElectron) {
|
||||
const settingStore = useSettingsStore();
|
||||
|
||||
// 如果禁用了音乐解析功能，则直接返回空结果
|
||||
if (!settingStore.setData.enableMusicUnblock) {
|
||||
return Promise.resolve({ data: { code: 404, message: '音乐解析功能已禁用' } });
|
||||
}
|
||||
|
||||
|
||||
// 1. 确定使用的音源列表(自定义或全局)
|
||||
const songId = String(id);
|
||||
const savedSourceStr = localStorage.getItem(`song_source_${songId}`);
|
||||
let musicSources: any[] = [];
|
||||
|
||||
|
||||
try {
|
||||
if (savedSourceStr) {
|
||||
// 使用自定义音源
|
||||
@@ -168,37 +170,55 @@ export const getParsingMusicUrl = async (id: number, data: SongResult) => {
|
||||
// 使用全局音源设置
|
||||
musicSources = settingStore.setData.enabledMusicSources || [];
|
||||
console.log(`使用全局音源设置:`, musicSources);
|
||||
if (musicSources.length > 0) {
|
||||
return getUnblockMusicAudio(id, data, musicSources);
|
||||
}
|
||||
}
|
||||
} catch (e) {
|
||||
console.error('解析音源设置失败，使用全局设置', e);
|
||||
console.error('解析音源设置失败，回退到默认全局设置', e);
|
||||
musicSources = settingStore.setData.enabledMusicSources || [];
|
||||
}
|
||||
|
||||
// 2. 按优先级解析
|
||||
|
||||
// 2.1 Bilibili解析(优先级最高)
|
||||
|
||||
const quality = settingStore.setData.musicQuality || 'higher';
|
||||
|
||||
// 优先级 1: 自定义 API
|
||||
if (musicSources.includes('custom') && settingStore.setData.customApiPlugin) {
|
||||
console.log('尝试使用 自定义API 解析...');
|
||||
const customResult = await parseFromCustomApi(id, data, quality);
|
||||
if (customResult) {
|
||||
return customResult; // 成功则直接返回
|
||||
}
|
||||
console.log('自定义API解析失败，继续尝试其他音源...');
|
||||
}
|
||||
|
||||
// 优先级 2: Bilibili
|
||||
if (musicSources.includes('bilibili')) {
|
||||
return await getBilibiliAudio(data);
|
||||
console.log('尝试使用 Bilibili 解析...');
|
||||
const bilibiliResult = await getBilibiliAudio(data);
|
||||
if (bilibiliResult?.data?.data?.url) { // 检查返回的 URL 是否有效
|
||||
return bilibiliResult;
|
||||
}
|
||||
console.log('Bilibili解析失败，继续尝试其他音源...');
|
||||
}
|
||||
|
||||
// 2.2 GD音乐台解析
|
||||
|
||||
// 优先级 3: GD 音乐台
|
||||
if (musicSources.includes('gdmusic')) {
|
||||
console.log('尝试使用 GD音乐台 解析...');
|
||||
const gdResult = await getGDMusicAudio(id, data);
|
||||
if (gdResult) return gdResult;
|
||||
// GD解析失败，继续下一步
|
||||
console.log('GD音乐台解析失败，尝试使用其他音源');
|
||||
if (gdResult) {
|
||||
return gdResult;
|
||||
}
|
||||
console.log('GD音乐台解析失败，继续尝试其他音源...');
|
||||
}
|
||||
console.log('musicSources', musicSources);
|
||||
// 2.3 使用unblockMusic解析其他音源
|
||||
if (musicSources.length > 0) {
|
||||
return getUnblockMusicAudio(id, data, musicSources);
|
||||
|
||||
// 优先级 4: UnblockMusic (migu, kugou, pyncmd)
|
||||
const unblockSources = musicSources.filter(
|
||||
source => !['custom', 'bilibili', 'gdmusic'].includes(source)
|
||||
);
|
||||
if (unblockSources.length > 0) {
|
||||
console.log('尝试使用 UnblockMusic 解析:', unblockSources);
|
||||
return getUnblockMusicAudio(id, data, unblockSources);
|
||||
}
|
||||
}
|
||||
|
||||
// 3. 后备方案：使用API请求
|
||||
// 后备方案：使用API请求
|
||||
console.log('无可用音源或不在Electron环境中，使用API请求');
|
||||
return requestMusic.get<any>('/music', { params: { id } });
|
||||
};
|
||||
|
||||
@@ -0,0 +1,106 @@
|
||||
import axios from 'axios';
|
||||
import {get} from 'lodash';
|
||||
import {useSettingsStore} from '@/store';
|
||||
|
||||
// 从同级目录的 gdmusic.ts 导入类型，确保兼容性
|
||||
import type {ParsedMusicResult} from './gdmusic';
|
||||
|
||||
/**
|
||||
* 定义自定义API JSON插件的结构
|
||||
*/
|
||||
interface CustomApiPlugin {
|
||||
name: string;
|
||||
apiUrl: string;
|
||||
method?: 'GET' | 'POST';
|
||||
params: Record<string, string>;
|
||||
qualityMapping?: Record<string, string>;
|
||||
responseUrlPath: string;
|
||||
}
|
||||
|
||||
/**
|
||||
* 从用户导入的自定义API JSON配置中解析音乐URL
|
||||
*/
|
||||
export const parseFromCustomApi = async (
|
||||
id: number,
|
||||
_songData: any,
|
||||
quality: string = 'higher',
|
||||
timeout: number = 10000
|
||||
): Promise<ParsedMusicResult | null> => {
|
||||
const settingsStore = useSettingsStore();
|
||||
const pluginString = settingsStore.setData.customApiPlugin;
|
||||
|
||||
if (!pluginString) {
|
||||
return null;
|
||||
}
|
||||
|
||||
let plugin: CustomApiPlugin;
|
||||
try {
|
||||
plugin = JSON.parse(pluginString);
|
||||
if (!plugin.apiUrl || !plugin.params || !plugin.responseUrlPath) {
|
||||
console.error('自定义API：JSON配置文件格式不正确。');
|
||||
return null;
|
||||
}
|
||||
} catch (error) {
|
||||
console.error('自定义API：解析JSON配置文件失败。', error);
|
||||
return null;
|
||||
}
|
||||
|
||||
console.log(`自定义API：正在使用插件 [${plugin.name}] 进行解析...`);
|
||||
|
||||
try {
|
||||
// 1. 准备请求参数，替换占位符
|
||||
const finalParams: Record<string, string> = {};
|
||||
for (const [key, value] of Object.entries(plugin.params)) {
|
||||
if (value === '{songId}') {
|
||||
finalParams[key] = String(id);
|
||||
} else if (value === '{quality}') {
|
||||
// 使用 qualityMapping (如果存在) 进行音质翻译，否则直接使用原quality
|
||||
finalParams[key] = plugin.qualityMapping?.[quality] ?? quality;
|
||||
} else {
|
||||
// 固定值参数
|
||||
finalParams[key] = value;
|
||||
}
|
||||
}
|
||||
|
||||
// 2. 判断请求方法，默认为GET
|
||||
const method = plugin.method?.toUpperCase() === 'POST' ? 'POST' : 'GET';
|
||||
let response;
|
||||
|
||||
// 3. 根据方法发送不同的请求
|
||||
if (method === 'POST') {
|
||||
console.log('自定义API：发送 POST 请求到:', plugin.apiUrl, '参数:', finalParams);
|
||||
response = await axios.post(plugin.apiUrl, finalParams, { timeout });
|
||||
} else { // 默认为 GET
|
||||
const finalUrl = `${plugin.apiUrl}?${new URLSearchParams(finalParams).toString()}`;
|
||||
console.log('自定义API：发送 GET 请求到:', finalUrl);
|
||||
response = await axios.get(finalUrl, { timeout });
|
||||
}
|
||||
|
||||
// 4. 使用 lodash.get 安全地从响应数据中提取URL
|
||||
const musicUrl = get(response.data, plugin.responseUrlPath);
|
||||
|
||||
if (musicUrl && typeof musicUrl === 'string') {
|
||||
console.log('自定义API：成功获取URL！');
|
||||
// 5. 组装成应用所需的标准格式并返回
|
||||
return {
|
||||
data: {
|
||||
data: {
|
||||
url: musicUrl,
|
||||
br: parseInt(quality) * 1000,
|
||||
size: 0,
|
||||
md5: '',
|
||||
platform: plugin.name.toLowerCase().replace(/\s/g, ''),
|
||||
gain: 0
|
||||
},
|
||||
params: { id, type: 'song' }
|
||||
}
|
||||
};
|
||||
} else {
|
||||
console.error('自定义API：根据路径未能从响应中找到URL:', plugin.responseUrlPath);
|
||||
return null;
|
||||
}
|
||||
} catch (error) {
|
||||
console.error(`自定义API [${plugin.name}] 执行失败:`, error);
|
||||
return null;
|
||||
}
|
||||
};
|
||||
Reference in New Issue
Block a user