yeyinly/MoonTVPlus
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

百度网盘在线播放

Browse Source
This commit is contained in:
mtvpls
2026-04-26 20:40:08 +08:00
parent c877397682
commit 59706b17c1
14 changed files with 808 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/app/api/admin/netdisk/route.ts
+17 -1
View File
@@ -5,6 +5,7 @@ import { NextRequest, NextResponse } from 'next/server';
import { getAuthInfoFromCookie } from '@/lib/auth';
import { getConfig, setCachedConfig } from '@/lib/config';
import { db } from '@/lib/db';
import { assertBaiduCookieHeaderSafe, normalizeBaiduCookie } from '@/lib/netdisk/baidu.client';
import {
assertMobileAuthorizationHeaderSafe,
normalizeMobileAuthorization,
@@ -44,7 +45,7 @@ export async function POST(request: NextRequest) {
}
const body = await request.json();
const { action, Quark, Mobile, provider } = body;
const { action, Quark, Mobile, Baidu, provider } = body;
const adminConfig = await getConfig();
if (action === 'save') {
@@ -52,6 +53,7 @@ export async function POST(request: NextRequest) {
const normalizedMobileAuthorization = Mobile?.Authorization
? assertMobileAuthorizationHeaderSafe(Mobile.Authorization)
: '';
const normalizedBaiduCookie = Baidu?.Cookie ? assertBaiduCookieHeaderSafe(Baidu.Cookie) : '';
adminConfig.NetDiskConfig = adminConfig.NetDiskConfig || {};
adminConfig.NetDiskConfig.Quark = {
@@ -65,6 +67,10 @@ export async function POST(request: NextRequest) {
Enabled: Boolean(Mobile?.Enabled),
Authorization: normalizedMobileAuthorization,
};
adminConfig.NetDiskConfig.Baidu = {
Enabled: Boolean(Baidu?.Enabled),
Cookie: normalizedBaiduCookie,
};
await db.saveAdminConfig(adminConfig);
await setCachedConfig(adminConfig);
@@ -84,6 +90,16 @@ export async function POST(request: NextRequest) {
message: '移动云盘 Authorization 格式正常',
});
}
if (provider === 'baidu') {
if (!Baidu?.Cookie) {
return NextResponse.json({ error: '请先填写百度网盘 Cookie' }, { status: 400 });
}
normalizeBaiduCookie(Baidu.Cookie);
return NextResponse.json({
success: true,
message: '百度网盘 Cookie 格式正常',
});
}
if (!Quark?.Cookie) {
return NextResponse.json({ error: '请先填写夸克 Cookie' }, { status: 400 });
src/app/api/netdisk/baidu/instant-play/route.ts
+57
View File
@@ -0,0 +1,57 @@
import { NextRequest, NextResponse } from 'next/server';
import { getAuthInfoFromCookie } from '@/lib/auth';
import { getConfig } from '@/lib/config';
import { listBaiduShareVideos } from '@/lib/netdisk/baidu.client';
import { createBaiduNetdiskSession } from '@/lib/netdisk/baidu-session-cache';
import { NETDISK_BAIDU_SOURCE } from '@/lib/netdisk/source';
import { hasFeaturePermission } from '@/lib/permissions';
export const runtime = 'nodejs';
export async function POST(request: NextRequest) {
try {
const authInfo = getAuthInfoFromCookie(request);
if (!authInfo?.username) {
return NextResponse.json({ error: '未登录' }, { status: 401 });
}
if (!(await hasFeaturePermission(authInfo.username, 'netdisk_temp_play'))) {
return NextResponse.json({ error: '无权限使用临时播放' }, { status: 403 });
}
const { shareUrl, passcode, title } = await request.json();
if (!shareUrl) {
return NextResponse.json({ error: '分享链接不能为空' }, { status: 400 });
}
const config = await getConfig();
const baiduConfig = config.NetDiskConfig?.Baidu;
if (!baiduConfig?.Enabled || !baiduConfig.Cookie) {
return NextResponse.json({ error: '百度网盘未配置或未启用' }, { status: 400 });
}
const result = await listBaiduShareVideos(shareUrl, baiduConfig.Cookie, passcode || '');
const session = createBaiduNetdiskSession({
title: title || result.title,
shareUrl,
passcode,
files: result.files,
meta: result.meta,
cookie: result.cookie,
});
return NextResponse.json({
success: true,
source: NETDISK_BAIDU_SOURCE,
id: session.id,
title: title || result.title,
totalFiles: result.files.length,
expiresAt: session.expiresAt,
});
} catch (error) {
return NextResponse.json(
{ error: error instanceof Error ? error.message : '立即播放失败' },
{ status: 500 }
);
}
}
src/app/api/netdisk/baidu/play/route.ts
+38
View File
@@ -0,0 +1,38 @@
import { NextRequest, NextResponse } from 'next/server';
import { getAuthInfoFromCookie } from '@/lib/auth';
export const runtime = 'nodejs';
export async function GET(request: NextRequest) {
try {
const authInfo = getAuthInfoFromCookie(request);
if (!authInfo?.username) {
return NextResponse.json({ error: '未授权' }, { status: 401 });
}
const { searchParams } = new URL(request.url);
const id = searchParams.get('id');
const episodeIndexRaw = searchParams.get('episodeIndex');
const format = searchParams.get('format');
if (!id || episodeIndexRaw == null) {
return NextResponse.json({ error: '缺少参数' }, { status: 400 });
}
const episodeIndex = Number.parseInt(episodeIndexRaw, 10);
if (!Number.isInteger(episodeIndex) || episodeIndex < 0) {
return NextResponse.json({ error: '无效的 episodeIndex' }, { status: 400 });
}
const proxyUrl = `/api/netdisk/baidu/proxy?id=${encodeURIComponent(id)}&episodeIndex=${episodeIndex}`;
if (format === 'json') {
return NextResponse.json({ url: proxyUrl, headers: {} });
}
return NextResponse.redirect(new URL(proxyUrl, request.url));
} catch (error) {
return NextResponse.json(
{ error: error instanceof Error ? error.message : '获取播放地址失败' },
{ status: 500 }
);
}
}
src/app/api/netdisk/baidu/proxy/route.ts
+70
View File
@@ -0,0 +1,70 @@
import { NextRequest, NextResponse } from 'next/server';
import { getAuthInfoFromCookie } from '@/lib/auth';
import { getBaiduDirectPlayUrl } from '@/lib/netdisk/baidu.client';
import { resolveBaiduSession } from '@/lib/netdisk/baidu-session-resolver';
export const runtime = 'nodejs';
export async function GET(request: NextRequest) {
try {
const authInfo = getAuthInfoFromCookie(request);
if (!authInfo?.username) {
return NextResponse.json({ error: '未授权' }, { status: 401 });
}
const { searchParams } = new URL(request.url);
const id = searchParams.get('id');
const episodeIndexRaw = searchParams.get('episodeIndex');
if (!id || episodeIndexRaw == null) {
return NextResponse.json({ error: '缺少参数' }, { status: 400 });
}
const episodeIndex = Number.parseInt(episodeIndexRaw, 10);
if (!Number.isInteger(episodeIndex) || episodeIndex < 0) {
return NextResponse.json({ error: '无效的 episodeIndex' }, { status: 400 });
}
const { session, cookie } = await resolveBaiduSession(id);
const file = session.files[episodeIndex];
if (!file) {
return NextResponse.json({ error: '播放文件不存在' }, { status: 404 });
}
const { url, headers } = await getBaiduDirectPlayUrl(session.meta, file.fid, cookie);
const range = request.headers.get('range');
const upstream = await fetch(url, {
headers: {
...headers,
Cookie: cookie,
...(range ? { Range: range } : {}),
},
cache: 'no-store',
});
if (!upstream.ok || !upstream.body) {
return NextResponse.json(
{ error: `百度网盘视频代理失败 (${upstream.status})` },
{ status: upstream.status || 500 }
);
}
const responseHeaders = new Headers();
const copyHeaders = ['content-type', 'content-length', 'content-range', 'accept-ranges', 'etag', 'last-modified'];
copyHeaders.forEach((name) => {
const value = upstream.headers.get(name);
if (value) responseHeaders.set(name, value);
});
responseHeaders.set('Cache-Control', 'private, no-store');
return new Response(upstream.body, {
status: range && upstream.headers.get('content-range') ? 206 : 200,
headers: responseHeaders,
});
} catch (error) {
return NextResponse.json(
{ error: error instanceof Error ? error.message : '百度网盘代理失败' },
{ status: 500 }
);
}
}
src/app/api/source-detail/route.ts
+77 -1
View File
@@ -6,13 +6,19 @@ import { getAuthInfoFromCookie } from '@/lib/auth';
import { getAvailableApiSites, getCacheTime, getConfig } from '@/lib/config';
import { getDetailFromApiV2 } from '@/lib/downstream';
import { getProxyToken } from '@/lib/emby-token';
import {
createBaiduNetdiskSession,
getBaiduNetdiskSession,
parseBaiduNetdiskId,
refreshBaiduNetdiskSession,
} from '@/lib/netdisk/baidu-session-cache';
import {
createMobileNetdiskSession,
getMobileNetdiskSession,
parseMobileNetdiskId,
refreshMobileNetdiskSession,
} from '@/lib/netdisk/mobile-session-cache';
import { LEGACY_QUARK_TEMP_SOURCE, NETDISK_MOBILE_SOURCE, NETDISK_QUARK_SOURCE, normalizeNetdiskSource } from '@/lib/netdisk/source';
import { LEGACY_QUARK_TEMP_SOURCE, NETDISK_BAIDU_SOURCE, NETDISK_MOBILE_SOURCE, NETDISK_QUARK_SOURCE, normalizeNetdiskSource } from '@/lib/netdisk/source';
import {
executeSavedSourceScript,
normalizeScriptDetailResult,
@@ -354,6 +360,76 @@ export async function GET(request: NextRequest) {
}
}
if (sourceCode === NETDISK_BAIDU_SOURCE) {
try {
const config = await getConfig();
const baiduConfig = config.NetDiskConfig?.Baidu;
if (!baiduConfig?.Enabled || !baiduConfig.Cookie) {
throw new Error('百度网盘未配置或未启用');
}
let session = refreshBaiduNetdiskSession(id) || getBaiduNetdiskSession(id);
if (!session) {
const payload = parseBaiduNetdiskId(id);
const { listBaiduShareVideos } = await import('@/lib/netdisk/baidu.client');
const result = await listBaiduShareVideos(payload.shareUrl, baiduConfig.Cookie, payload.passcode || '');
session = createBaiduNetdiskSession({
title: title || result.title,
shareUrl: payload.shareUrl,
passcode: payload.passcode,
files: result.files,
meta: result.meta,
cookie: result.cookie,
});
}
if (!session) {
throw new Error('百度网盘播放信息恢复失败');
}
const baiduSession = session;
const { parseVideoFileName } = await import('@/lib/video-parser');
const parsedFiles = baiduSession.files
.map((file, index) => {
const parsed = parseVideoFileName(file.name);
return {
...file,
originalIndex: index,
sortEpisode: parsed.episode || index + 1,
isOVA: parsed.isOVA,
displayTitle:
parsed.title || (parsed.episode ? `第${parsed.episode}集` : file.name),
};
})
.sort((a, b) => {
if (a.isOVA && !b.isOVA) return 1;
if (!a.isOVA && b.isOVA) return -1;
return a.sortEpisode !== b.sortEpisode
? a.sortEpisode - b.sortEpisode
: a.name.localeCompare(b.name, 'zh-Hans-CN', { numeric: true, sensitivity: 'base' });
});
return NextResponse.json({
source: NETDISK_BAIDU_SOURCE,
source_name: '百度网盘',
id: baiduSession.id,
title: title || baiduSession.title,
poster: '',
year: '',
douban_id: 0,
desc: `百度网盘分享：${baiduSession.shareUrl}`,
episodes: parsedFiles.map((file) => (
`/api/netdisk/baidu/play?id=${encodeURIComponent(baiduSession.id)}&episodeIndex=${file.originalIndex}`
)),
episodes_titles: parsedFiles.map((file) => file.displayTitle),
proxyMode: false,
});
} catch (error) {
return NextResponse.json(
{ error: (error as Error).message },
{ status: 500 }
);
}
}
if (sourceCode === NETDISK_QUARK_SOURCE || sourceCode === LEGACY_QUARK_TEMP_SOURCE) {
try {
const config = await getConfig();