Skip to content

Fixed: Fix the issue of playing sliced recordings #1427

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
ZhaoJiSen merged 1 commit into from
Aug 18, 2025
Merged

Fixed: Fix the issue of playing sliced recordings #1427

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
30 changes: 17 additions & 13 deletions src/app/elements/replay/parts/parts.component.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -145,8 +145,12 @@ export class ElementsPartsComponent implements OnInit {
// 3.5 的 TS 版本无法使用 ?.
// @ts-ignore
const data = res.type ? res : res.resp ? res.resp.data : undefined;
// 某些后端会把状态放在 data 中，兜底读取
// @ts-ignore
const status = (res && res.status) || (data && data.status);

if (data && data.src && res.status !== 'running') {
// 只要拿到 src 就先构建分片并播放，后续是否 still running 由后台继续处理
if (data && data.src) {
section = {
id: this.id,
account: data.account,
Expand Down Expand Up @@ -176,7 +180,7 @@ export class ElementsPartsComponent implements OnInit {

return false;
}
} else if (res && res.status === 'running') {
} else if (status === 'running') {
this.alertShown = true;
await this.delay(3000);
return await this.fetchSection(item, sessionId, isFirstPush);
Expand All @@ -198,19 +202,19 @@ export class ElementsPartsComponent implements OnInit {
async handlePartFileReplay(file: IFile[], sessionId: string) {
let isFirstPush = true;

for (const item of file) {
// 先拿第一个保证有东西可以播出来
isFirstPush = await this.fetchSection(file[0], sessionId, isFirstPush);
if (!file || file.length === 0) {
return;
}

// 其他的放到异步任务中
Promise.resolve().then(async () => {
for(const item of file.slice(1)) {
await this.fetchSection(item, sessionId, isFirstPush);
}
})
// 先请求第一个，保证尽快有可播放的内容
isFirstPush = await this.fetchSection(file[0], sessionId, isFirstPush);

// isFirstPush = await this.fetchSection(item, sessionId, isFirstPush);
}
// 其余分片放到后台依次请求，避免与首个分片并发拥塞
Promise.resolve().then(async () => {
for (const rest of file.slice(1)) {
await this.fetchSection(rest, sessionId, false);
}
});
}

/**
Expand Down