hicccc77/WeFlow
1
0
Fork 0
mirror of https://github.com/hicccc77/WeFlow.git synced 2026-03-25 07:16:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

导出方面再优化 媒体并行导出

Browse Source
This commit is contained in:
xuncha
2026-01-31 13:49:21 +08:00
parent 834aa6eecb
commit 3c9ab6763c
1 changed files with 15 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
electron/services/exportService.ts
View File

@@ -142,6 +142,12 @@ class ExportService {
this.configService = new ConfigService() this.configService = new ConfigService()
} }
private getClampedConcurrency(value: number | undefined, fallback = 2, max = 6): number {
if (typeof value !== 'number' || !Number.isFinite(value)) return fallback
const raw = Math.floor(value)
return Math.max(1, Math.min(raw, max))
}
private cleanAccountDirName(dirName: string): string { private cleanAccountDirName(dirName: string): string {
const trimmed = dirName.trim() const trimmed = dirName.trim()
if (!trimmed) return trimmed if (!trimmed) return trimmed
@@ -1740,9 +1746,9 @@ class ExportService {
phase: 'exporting-media' phase: 'exporting-media'
}) })
// 并行导出媒体，限制 8 个并发 // 并行导出媒体，并发数跟随导出设置
const MEDIA_CONCURRENCY = 8 const mediaConcurrency = this.getClampedConcurrency(options.exportConcurrency)
await parallelLimit(mediaMessages, MEDIA_CONCURRENCY, async (msg) => { await parallelLimit(mediaMessages, mediaConcurrency, async (msg) => {
const mediaKey = `${msg.localType}_${msg.localId}` const mediaKey = `${msg.localType}_${msg.localId}`
if (!mediaCache.has(mediaKey)) { if (!mediaCache.has(mediaKey)) {
const mediaItem = await this.exportMediaForMessage(msg, sessionId, mediaRootDir, mediaRelativePrefix, { const mediaItem = await this.exportMediaForMessage(msg, sessionId, mediaRootDir, mediaRelativePrefix, {
@@ -1956,8 +1962,8 @@ class ExportService {
phase: 'exporting-media' phase: 'exporting-media'
}) })
const MEDIA_CONCURRENCY = 8 const mediaConcurrency = this.getClampedConcurrency(options.exportConcurrency)
await parallelLimit(mediaMessages, MEDIA_CONCURRENCY, async (msg) => { await parallelLimit(mediaMessages, mediaConcurrency, async (msg) => {
const mediaKey = `${msg.localType}_${msg.localId}` const mediaKey = `${msg.localType}_${msg.localId}`
if (!mediaCache.has(mediaKey)) { if (!mediaCache.has(mediaKey)) {
const mediaItem = await this.exportMediaForMessage(msg, sessionId, mediaRootDir, mediaRelativePrefix, { const mediaItem = await this.exportMediaForMessage(msg, sessionId, mediaRootDir, mediaRelativePrefix, {
@@ -2348,8 +2354,8 @@ class ExportService {
phase: 'exporting-media' phase: 'exporting-media'
}) })
const MEDIA_CONCURRENCY = 8 const mediaConcurrency = this.getClampedConcurrency(options.exportConcurrency)
await parallelLimit(mediaMessages, MEDIA_CONCURRENCY, async (msg) => { await parallelLimit(mediaMessages, mediaConcurrency, async (msg) => {
const mediaKey = `${msg.localType}_${msg.localId}` const mediaKey = `${msg.localType}_${msg.localId}`
if (!mediaCache.has(mediaKey)) { if (!mediaCache.has(mediaKey)) {
const mediaItem = await this.exportMediaForMessage(msg, sessionId, mediaRootDir, mediaRelativePrefix, { const mediaItem = await this.exportMediaForMessage(msg, sessionId, mediaRootDir, mediaRelativePrefix, {
@@ -2653,8 +2659,8 @@ class ExportService {
phase: 'exporting-media' phase: 'exporting-media'
}) })
const MEDIA_CONCURRENCY = 8 const mediaConcurrency = this.getClampedConcurrency(options.exportConcurrency)
await parallelLimit(mediaMessages, MEDIA_CONCURRENCY, async (msg) => { await parallelLimit(mediaMessages, mediaConcurrency, async (msg) => {
const mediaKey = `${msg.localType}_${msg.localId}` const mediaKey = `${msg.localType}_${msg.localId}`
if (!mediaCache.has(mediaKey)) { if (!mediaCache.has(mediaKey)) {
const mediaItem = await this.exportMediaForMessage(msg, sessionId, mediaRootDir, mediaRelativePrefix, { const mediaItem = await this.exportMediaForMessage(msg, sessionId, mediaRootDir, mediaRelativePrefix, {