Compare commits

...

3 Commits

Author SHA1 Message Date
mula.liu af735bd93d 1.1.1 2026-04-07 17:26:34 +08:00
mula.liu 3c2ac639b4 Merge remote-tracking branch 'origin/codex/dev' into codex/dev 2026-04-07 16:56:44 +08:00
mula.liu 2591996a48 修改了音频播放器 2026-04-07 15:51:51 +08:00
15 changed files with 1114 additions and 441 deletions

View File

@ -963,8 +963,7 @@ def start_meeting_transcription(
"task_id": existing_status['task_id'], "status": existing_status['status']
})
task_id = transcription_service.start_transcription(meeting_id, audio_file['file_path'])
background_tasks.add_task(
async_meeting_service.monitor_and_auto_summarize,
async_meeting_service.enqueue_transcription_monitor(
meeting_id,
task_id,
meeting.get('prompt_id') if meeting.get('prompt_id') not in (None, 0) else None,
@ -1103,9 +1102,24 @@ def generate_meeting_summary_async(meeting_id: int, request: GenerateSummaryRequ
"task_id": transcription_status.get('task_id'),
"status": transcription_status.get('status')
})
llm_status = async_meeting_service.get_meeting_llm_status(meeting_id)
if llm_status and llm_status.get('status') in ['pending', 'processing']:
return create_api_response(code="409", message="总结任务已存在", data={
"task_id": llm_status.get('task_id'),
"status": llm_status.get('status')
})
# 传递 prompt_id 和 model_code 参数给服务层
task_id = async_meeting_service.start_summary_generation(meeting_id, request.user_prompt, request.prompt_id, request.model_code)
background_tasks.add_task(async_meeting_service._process_task, task_id)
task_id, created = async_meeting_service.enqueue_summary_generation(
meeting_id,
request.user_prompt,
request.prompt_id,
request.model_code,
)
if not created:
return create_api_response(code="409", message="总结任务已存在", data={
"task_id": task_id,
"status": "pending"
})
return create_api_response(code="200", message="Summary generation task has been accepted.", data={
"task_id": task_id, "status": "pending", "meeting_id": meeting_id
})

View File

@ -98,4 +98,10 @@ TRANSCRIPTION_POLL_CONFIG = {
'max_wait_time': int(os.getenv('TRANSCRIPTION_MAX_WAIT_TIME', '1800')), # 最大等待30分钟
}
# 后台任务配置
BACKGROUND_TASK_CONFIG = {
'summary_workers': int(os.getenv('SUMMARY_TASK_MAX_WORKERS', '2')),
'monitor_workers': int(os.getenv('MONITOR_TASK_MAX_WORKERS', '8')),
'transcription_status_cache_ttl': int(os.getenv('TRANSCRIPTION_STATUS_CACHE_TTL', '3')),
}

View File

@ -1,6 +1,6 @@
"""
异步会议服务 - 处理会议总结生成的异步任务
采用FastAPI BackgroundTasks模式
采用受控线程池执行避免阻塞 Web 请求进程
"""
import uuid
import time
@ -11,11 +11,22 @@ from typing import Optional, Dict, Any, List
from pathlib import Path
import redis
from app.core.config import REDIS_CONFIG, TRANSCRIPTION_POLL_CONFIG, AUDIO_DIR
from app.core.config import REDIS_CONFIG, TRANSCRIPTION_POLL_CONFIG, BACKGROUND_TASK_CONFIG, AUDIO_DIR
from app.core.database import get_db_connection
from app.services.async_transcription_service import AsyncTranscriptionService
from app.services.background_task_runner import KeyedBackgroundTaskRunner
from app.services.llm_service import LLMService
summary_task_runner = KeyedBackgroundTaskRunner(
max_workers=BACKGROUND_TASK_CONFIG['summary_workers'],
thread_name_prefix="imeeting-summary",
)
monitor_task_runner = KeyedBackgroundTaskRunner(
max_workers=BACKGROUND_TASK_CONFIG['monitor_workers'],
thread_name_prefix="imeeting-monitor",
)
class AsyncMeetingService:
"""异步会议服务类 - 处理会议相关的异步任务"""
@ -26,9 +37,42 @@ class AsyncMeetingService:
self.redis_client = redis.Redis(**REDIS_CONFIG)
self.llm_service = LLMService() # 复用现有的同步LLM服务
def enqueue_summary_generation(
self,
meeting_id: int,
user_prompt: str = "",
prompt_id: Optional[int] = None,
model_code: Optional[str] = None
) -> tuple[str, bool]:
"""创建并提交总结任务;若已有运行中的同会议总结任务,则直接返回现有任务。"""
existing_task = self._get_existing_summary_task(meeting_id)
if existing_task:
return existing_task, False
task_id = self.start_summary_generation(meeting_id, user_prompt, prompt_id, model_code)
summary_task_runner.submit(f"meeting-summary:{task_id}", self._process_task, task_id)
return task_id, True
def enqueue_transcription_monitor(
self,
meeting_id: int,
transcription_task_id: str,
prompt_id: Optional[int] = None,
model_code: Optional[str] = None
) -> bool:
"""提交转录监控任务,避免同一转录任务重复轮询。"""
return monitor_task_runner.submit(
f"transcription-monitor:{transcription_task_id}",
self.monitor_and_auto_summarize,
meeting_id,
transcription_task_id,
prompt_id,
model_code,
)
def start_summary_generation(self, meeting_id: int, user_prompt: str = "", prompt_id: Optional[int] = None, model_code: Optional[str] = None) -> str:
"""
创建异步总结任务任务的执行将由外部如API层的BackgroundTasks触发
创建异步总结任务任务的执行将由后台线程池触发
Args:
meeting_id: 会议ID
@ -70,9 +114,11 @@ class AsyncMeetingService:
def _process_task(self, task_id: str):
"""
处理单个异步任务的函数设计为由BackgroundTasks调用
处理单个异步任务的函数在线程池中执行
"""
print(f"Background task started for meeting summary task: {task_id}")
lock_token = None
lock_key = f"lock:meeting-summary-task:{task_id}"
try:
# 从Redis获取任务数据
task_data = self.redis_client.hgetall(f"llm_task:{task_id}")
@ -85,6 +131,10 @@ class AsyncMeetingService:
prompt_id_str = task_data.get('prompt_id', '')
prompt_id = int(prompt_id_str) if prompt_id_str and prompt_id_str != '' else None
model_code = task_data.get('model_code', '') or None
lock_token = self._acquire_lock(lock_key, ttl_seconds=7200)
if not lock_token:
print(f"Task {task_id} is already being processed, skipping duplicate execution")
return
# 1. 更新状态为processing
self._update_task_status_in_redis(task_id, 'processing', 10, message="任务已开始...")
@ -127,6 +177,8 @@ class AsyncMeetingService:
# 更新失败状态
self._update_task_in_db(task_id, 'failed', 0, error_message=error_msg)
self._update_task_status_in_redis(task_id, 'failed', 0, error_message=error_msg)
finally:
self._release_lock(lock_key, lock_token)
def monitor_and_auto_summarize(
self,
@ -156,6 +208,11 @@ class AsyncMeetingService:
poll_interval = TRANSCRIPTION_POLL_CONFIG['poll_interval']
max_wait_time = TRANSCRIPTION_POLL_CONFIG['max_wait_time']
max_polls = max_wait_time // poll_interval
lock_key = f"lock:transcription-monitor:{transcription_task_id}"
lock_token = self._acquire_lock(lock_key, ttl_seconds=max_wait_time + poll_interval)
if not lock_token:
print(f"[Monitor] Monitor task already running for transcription task {transcription_task_id}, skipping duplicate worker")
return
# 延迟导入以避免循环导入
transcription_service = AsyncTranscriptionService()
@ -186,16 +243,16 @@ class AsyncMeetingService:
else:
# 启动总结任务
try:
summary_task_id = self.start_summary_generation(
summary_task_id, created = self.enqueue_summary_generation(
meeting_id,
user_prompt="",
prompt_id=prompt_id,
model_code=model_code
)
print(f"[Monitor] Summary task {summary_task_id} started for meeting {meeting_id}")
# 在后台执行总结任务
self._process_task(summary_task_id)
if created:
print(f"[Monitor] Summary task {summary_task_id} started for meeting {meeting_id}")
else:
print(f"[Monitor] Reused existing summary task {summary_task_id} for meeting {meeting_id}")
except Exception as e:
error_msg = f"Failed to start summary generation: {e}"
@ -232,6 +289,8 @@ class AsyncMeetingService:
except Exception as e:
print(f"[Monitor] Fatal error in monitor_and_auto_summarize: {e}")
finally:
self._release_lock(lock_key, lock_token)
# --- 会议相关方法 ---
@ -682,5 +741,30 @@ class AsyncMeetingService:
print(f"Error checking existing summary task: {e}")
return None
def _acquire_lock(self, lock_key: str, ttl_seconds: int) -> Optional[str]:
"""使用 Redis 分布式锁防止多 worker 重复执行同一后台任务。"""
try:
token = str(uuid.uuid4())
acquired = self.redis_client.set(lock_key, token, nx=True, ex=max(30, ttl_seconds))
if acquired:
return token
except Exception as e:
print(f"Error acquiring lock {lock_key}: {e}")
return None
def _release_lock(self, lock_key: str, token: Optional[str]) -> None:
if not token:
return
try:
release_script = """
if redis.call('get', KEYS[1]) == ARGV[1] then
return redis.call('del', KEYS[1])
end
return 0
"""
self.redis_client.eval(release_script, 1, lock_key, token)
except Exception as e:
print(f"Error releasing lock {lock_key}: {e}")
# 创建全局实例
async_meeting_service = AsyncMeetingService()

View File

@ -10,7 +10,7 @@ from http import HTTPStatus
import dashscope
from dashscope.audio.asr import Transcription
from app.core.config import QWEN_API_KEY, REDIS_CONFIG, APP_CONFIG
from app.core.config import QWEN_API_KEY, REDIS_CONFIG, APP_CONFIG, BACKGROUND_TASK_CONFIG
from app.core.database import get_db_connection
from app.services.system_config_service import SystemConfigService
@ -211,56 +211,70 @@ class AsyncTranscriptionService:
current_status = 'failed'
progress = 0
error_message = "An unknown error occurred."
updated_at = datetime.now().isoformat()
status_cache_key = f"task_status_cache:{business_task_id}"
try:
# 1. 获取任务数据优先Redis回源DB
task_data = self._get_task_data(business_task_id)
paraformer_task_id = task_data['paraformer_task_id']
# 2. 查询外部API获取状态
try:
session = self._create_requests_session()
try:
paraformer_response = Transcription.fetch(task=paraformer_task_id, session=session)
finally:
session.close()
if paraformer_response.status_code != HTTPStatus.OK:
raise Exception(f"Failed to fetch task status from provider: {paraformer_response.message}")
paraformer_status = paraformer_response.output.task_status
current_status = self._map_paraformer_status(paraformer_status)
progress = self._calculate_progress(paraformer_status)
error_message = None #执行成功,清除初始状态
except Exception as e:
current_status = 'failed'
progress = 0
error_message = f"Error fetching status from provider: {e}"
# 直接进入finally块更新状态后返回
return
# 3. 如果任务完成,处理结果
if current_status == 'completed' and paraformer_response.output.get('results'):
# 防止并发处理:先检查数据库中的状态
db_task_status = self._get_task_status_from_db(business_task_id)
if db_task_status != 'completed':
# 只有当数据库中状态不是completed时才处理
# 先将状态更新为completed作为分布式锁
self._update_task_status_in_db(business_task_id, 'completed', 100, None)
stored_status = str(task_data.get('status') or '').lower()
if stored_status in {'completed', 'failed'}:
current_status = stored_status
progress = int(task_data.get('progress') or 0)
error_message = task_data.get('error_message') or None
updated_at = task_data.get('updated_at') or updated_at
else:
cached_status = self.redis_client.hgetall(status_cache_key)
if cached_status and cached_status.get('status') in {'pending', 'processing'}:
current_status = cached_status.get('status', 'pending')
progress = int(cached_status.get('progress') or 0)
error_message = cached_status.get('error_message') or None
updated_at = cached_status.get('updated_at') or updated_at
else:
paraformer_task_id = task_data['paraformer_task_id']
# 2. 查询外部API获取状态
try:
self._process_transcription_result(
business_task_id,
int(task_data['meeting_id']),
paraformer_response.output
)
session = self._create_requests_session()
try:
paraformer_response = Transcription.fetch(task=paraformer_task_id, session=session)
finally:
session.close()
if paraformer_response.status_code != HTTPStatus.OK:
raise Exception(f"Failed to fetch task status from provider: {paraformer_response.message}")
paraformer_status = paraformer_response.output.task_status
current_status = self._map_paraformer_status(paraformer_status)
progress = self._calculate_progress(paraformer_status)
error_message = None #执行成功,清除初始状态
except Exception as e:
current_status = 'failed'
progress = 100 # 进度为100但状态是失败
error_message = f"Error processing transcription result: {e}"
print(error_message)
else:
print(f"Task {business_task_id} already processed, skipping duplicate processing")
progress = 0
error_message = f"Error fetching status from provider: {e}"
# 3. 如果任务完成,处理结果
if current_status == 'completed' and paraformer_response.output.get('results'):
# 防止并发处理:先检查数据库中的状态
db_task_status = self._get_task_status_from_db(business_task_id)
if db_task_status != 'completed':
# 只有当数据库中状态不是completed时才处理
# 先将状态更新为completed作为分布式锁
self._update_task_status_in_db(business_task_id, 'completed', 100, None)
try:
self._process_transcription_result(
business_task_id,
int(task_data['meeting_id']),
paraformer_response.output
)
except Exception as e:
current_status = 'failed'
progress = 100 # 进度为100但状态是失败
error_message = f"Error processing transcription result: {e}"
print(error_message)
else:
print(f"Task {business_task_id} already processed, skipping duplicate processing")
except Exception as e:
error_message = f"Error getting task status: {e}"
@ -281,33 +295,33 @@ class AsyncTranscriptionService:
if error_message:
update_data['error_message'] = error_message
self.redis_client.hset(f"task:{business_task_id}", mapping=update_data)
self.redis_client.hset(status_cache_key, mapping=update_data)
self.redis_client.expire(
status_cache_key,
max(1, int(BACKGROUND_TASK_CONFIG.get('transcription_status_cache_ttl', 3)))
)
# 更新数据库
self._update_task_status_in_db(business_task_id, current_status, progress, error_message)
# 5. 构造并返回最终结果
result = {
'task_id': business_task_id,
'status': current_status,
'progress': progress,
'error_message': error_message,
'updated_at': updated_at,
'meeting_id': None,
'created_at': None,
}
if task_data:
result['meeting_id'] = int(task_data['meeting_id'])
result['created_at'] = task_data.get('created_at')
return result
return self._build_task_status_result(
business_task_id,
task_data,
current_status,
progress,
error_message,
updated_at,
)
def _get_task_data(self, business_task_id: str) -> Dict[str, Any]:
"""从Redis或数据库获取任务数据"""
# 尝试从Redis获取
task_data_bytes = self.redis_client.hgetall(f"task:{business_task_id}")
if task_data_bytes and task_data_bytes.get(b'paraformer_task_id'):
# Redis返回的是bytes需要解码
return {k.decode('utf-8'): v.decode('utf-8') for k, v in task_data_bytes.items()}
task_data_raw = self.redis_client.hgetall(f"task:{business_task_id}")
if task_data_raw:
task_data = self._normalize_redis_mapping(task_data_raw)
if task_data.get('paraformer_task_id'):
return task_data
# 如果Redis没有从数据库回源
task_data_from_db = self._get_task_from_db(business_task_id)
@ -465,7 +479,8 @@ class AsyncTranscriptionService:
cursor = connection.cursor(dictionary=True)
query = """
SELECT tt.task_id as business_task_id, tt.paraformer_task_id, tt.meeting_id, tt.status, tt.created_at
SELECT tt.task_id as business_task_id, tt.paraformer_task_id, tt.meeting_id, tt.status, tt.progress,
tt.error_message, tt.created_at, tt.completed_at
FROM transcript_tasks tt
WHERE tt.task_id = %s
"""
@ -480,13 +495,55 @@ class AsyncTranscriptionService:
'paraformer_task_id': result['paraformer_task_id'],
'meeting_id': str(result['meeting_id']),
'status': result['status'],
'created_at': result['created_at'].isoformat() if result['created_at'] else None
'progress': str(result.get('progress') or 0),
'error_message': result.get('error_message') or '',
'created_at': result['created_at'].isoformat() if result['created_at'] else None,
'updated_at': (
result['completed_at'].isoformat()
if result.get('completed_at')
else result['created_at'].isoformat() if result.get('created_at') else None
),
}
return None
except Exception as e:
print(f"Error getting task from database: {e}")
return None
def _normalize_redis_mapping(self, mapping: Dict[Any, Any]) -> Dict[str, Any]:
normalized: Dict[str, Any] = {}
for key, value in mapping.items():
normalized_key = key.decode('utf-8') if isinstance(key, bytes) else str(key)
if isinstance(value, bytes):
normalized_value = value.decode('utf-8')
else:
normalized_value = value
normalized[normalized_key] = normalized_value
return normalized
def _build_task_status_result(
self,
business_task_id: str,
task_data: Optional[Dict[str, Any]],
status: str,
progress: int,
error_message: Optional[str],
updated_at: str
) -> Dict[str, Any]:
result = {
'task_id': business_task_id,
'status': status,
'progress': progress,
'error_message': error_message,
'updated_at': updated_at,
'meeting_id': None,
'created_at': None,
}
if task_data:
meeting_id = task_data.get('meeting_id')
result['meeting_id'] = int(meeting_id) if meeting_id is not None else None
result['created_at'] = task_data.get('created_at')
return result
def _process_transcription_result(self, business_task_id: str, meeting_id: int, paraformer_output: Any):
"""

View File

@ -45,7 +45,7 @@ def handle_audio_upload(
meeting_id: 会议ID
current_user: 当前用户信息
auto_summarize: 是否自动生成总结默认True
background_tasks: FastAPI 后台任务对象
background_tasks: 为兼容现有调用保留实际后台执行由服务层线程池完成
prompt_id: 提示词模版ID可选如果不指定则使用默认模版
model_code: 总结模型编码可选如果不指定则使用默认模型
duration: 音频时长
@ -141,16 +141,15 @@ def handle_audio_upload(
transcription_task_id = transcription_service.start_transcription(meeting_id, file_path)
print(f"Transcription task {transcription_task_id} started for meeting {meeting_id}")
# 5. 如果启用自动总结且提供了 background_tasks添加监控任务
if auto_summarize and transcription_task_id and background_tasks:
background_tasks.add_task(
async_meeting_service.monitor_and_auto_summarize,
# 5. 如果启用自动总结,则提交后台监控任务
if auto_summarize and transcription_task_id:
async_meeting_service.enqueue_transcription_monitor(
meeting_id,
transcription_task_id,
prompt_id,
model_code
)
print(f"[audio_service] Auto-summarize enabled, monitor task added for meeting {meeting_id}, prompt_id: {prompt_id}, model_code: {model_code}")
print(f"[audio_service] Auto-summarize enabled, monitor task scheduled for meeting {meeting_id}, prompt_id: {prompt_id}, model_code: {model_code}")
except Exception as e:
print(f"Failed to start transcription: {e}")

View File

@ -0,0 +1,38 @@
from concurrent.futures import ThreadPoolExecutor
from itertools import count
from threading import Lock
from typing import Any, Callable, Dict
import traceback
class KeyedBackgroundTaskRunner:
"""按 key 去重的后台任务执行器,避免同类长任务重复堆积。"""
def __init__(self, max_workers: int, thread_name_prefix: str):
self._executor = ThreadPoolExecutor(max_workers=max_workers, thread_name_prefix=thread_name_prefix)
self._lock = Lock()
self._seq = count(1)
self._tasks: Dict[str, Dict[str, Any]] = {}
def submit(self, key: str, func: Callable[..., Any], *args: Any, **kwargs: Any) -> bool:
with self._lock:
current = self._tasks.get(key)
if current and not current["future"].done():
return False
token = next(self._seq)
future = self._executor.submit(self._run_task, key, token, func, *args, **kwargs)
self._tasks[key] = {"token": token, "future": future}
return True
def _run_task(self, key: str, token: int, func: Callable[..., Any], *args: Any, **kwargs: Any) -> None:
try:
func(*args, **kwargs)
except Exception:
print(f"[BackgroundTaskRunner] Task failed, key={key}")
traceback.print_exc()
finally:
with self._lock:
current = self._tasks.get(key)
if current and current["token"] == token:
self._tasks.pop(key, None)

View File

@ -0,0 +1,179 @@
.audio-player-bar {
display: flex;
align-items: center;
gap: 10px;
min-height: 42px;
padding: 4px 12px;
border-radius: 999px;
border: 1px solid #e3ebf6;
background: linear-gradient(180deg, rgba(255, 255, 255, 0.98) 0%, #f7faff 100%);
box-shadow: 0 8px 18px rgba(40, 72, 120, 0.06);
}
.audio-player-bar.is-empty {
justify-content: center;
}
.audio-player-bar-audio {
display: none;
}
.audio-player-bar-play {
width: 24px;
min-width: 24px;
height: 24px;
padding: 0;
border: 0;
border-radius: 999px;
background: transparent;
color: #5f7392;
box-shadow: none;
}
.audio-player-bar-play.ant-btn:hover,
.audio-player-bar-play.ant-btn:focus {
background: rgba(233, 241, 251, 0.7) !important;
color: #355171 !important;
}
.audio-player-bar-play.ant-btn:disabled {
background: transparent !important;
color: #a8b7ca !important;
}
.audio-player-bar-time {
flex: 0 0 auto;
min-width: 102px;
font-size: 12px;
font-weight: 700;
color: #5f7392;
letter-spacing: 0.01em;
white-space: nowrap;
}
.audio-player-bar-progress {
position: relative;
flex: 1;
height: 5px;
border: 0;
border-radius: 999px;
background: #edf2fa;
cursor: pointer;
appearance: none;
outline: none;
}
.audio-player-bar-progress::-webkit-slider-runnable-track {
height: 5px;
border-radius: 999px;
background: linear-gradient(
90deg,
#bfd1e8 0%,
#bfd1e8 var(--progress, 0%),
#edf2fa var(--progress, 0%),
#edf2fa 100%
);
}
.audio-player-bar-progress::-webkit-slider-thumb {
appearance: none;
width: 10px;
height: 10px;
margin-top: -2.5px;
border: 2px solid #ffffff;
border-radius: 50%;
background: #b9cde7;
box-shadow: 0 2px 5px rgba(79, 111, 157, 0.12);
}
.audio-player-bar-progress::-moz-range-track {
height: 5px;
border-radius: 999px;
background: #edf2fa;
}
.audio-player-bar-progress::-moz-range-progress {
height: 5px;
border-radius: 999px;
background: #bfd1e8;
}
.audio-player-bar-progress::-moz-range-thumb {
width: 10px;
height: 10px;
border: 2px solid #ffffff;
border-radius: 50%;
background: #b9cde7;
box-shadow: 0 2px 5px rgba(79, 111, 157, 0.12);
}
.audio-player-bar-volume {
display: inline-flex;
align-items: center;
justify-content: center;
color: #5f7392;
font-size: 14px;
}
.audio-player-bar-divider {
width: 1px;
height: 16px;
background: #e4ebf5;
}
.audio-player-bar-control.ant-btn {
height: 24px;
min-height: 24px;
padding: 0 6px;
border: 0;
border-radius: 999px;
background: transparent;
color: #5f7392;
box-shadow: none;
font-size: 11px;
}
.audio-player-bar-control.ant-btn:hover,
.audio-player-bar-control.ant-btn:focus {
background: rgba(240, 245, 252, 0.75) !important;
color: #355171 !important;
}
.audio-player-bar-control.ant-btn:disabled {
background: #f8fafc !important;
color: #a8b7ca !important;
}
.audio-player-bar-rate.ant-btn {
min-width: 46px;
font-weight: 700;
}
.audio-player-bar-more.ant-btn {
width: 24px;
min-width: 24px;
padding: 0;
border-radius: 999px;
}
.audio-player-bar-empty-text {
color: #5f7392;
font-size: 12px;
}
@media (max-width: 768px) {
.audio-player-bar {
gap: 8px;
padding: 4px 9px;
}
.audio-player-bar-time {
min-width: 78px;
font-size: 12px;
}
.audio-player-bar-volume,
.audio-player-bar-divider {
display: none;
}
}

View File

@ -0,0 +1,185 @@
import React, { useEffect, useMemo, useState } from 'react';
import { Button, Dropdown } from 'antd';
import {
CaretRightFilled,
DownOutlined,
MoreOutlined,
PauseOutlined,
SoundOutlined,
} from '@ant-design/icons';
import tools from '../utils/tools';
import './AudioPlayerBar.css';
const DEFAULT_RATE_OPTIONS = [0.75, 1, 1.25, 1.5, 2];
const AudioPlayerBar = ({
audioRef,
src,
playbackRate = 1,
onPlaybackRateChange,
onTimeUpdate,
onLoadedMetadata,
moreMenuItems = [],
emptyText = '暂无音频',
showMoreButton = true,
rateOptions = DEFAULT_RATE_OPTIONS,
}) => {
const [isPlaying, setIsPlaying] = useState(false);
const [currentTime, setCurrentTime] = useState(0);
const [duration, setDuration] = useState(0);
useEffect(() => {
const audio = audioRef?.current;
if (!audio) {
return undefined;
}
const syncState = () => {
setCurrentTime(audio.currentTime || 0);
setDuration(audio.duration || 0);
setIsPlaying(!audio.paused && !audio.ended);
};
const handleMeta = (event) => {
syncState();
onLoadedMetadata?.(event);
};
const handleTime = (event) => {
syncState();
onTimeUpdate?.(event);
};
const handlePlay = () => setIsPlaying(true);
const handlePause = () => setIsPlaying(false);
const handleEnded = () => {
setIsPlaying(false);
setCurrentTime(audio.duration || 0);
};
syncState();
audio.addEventListener('loadedmetadata', handleMeta);
audio.addEventListener('durationchange', syncState);
audio.addEventListener('timeupdate', handleTime);
audio.addEventListener('play', handlePlay);
audio.addEventListener('pause', handlePause);
audio.addEventListener('ended', handleEnded);
return () => {
audio.removeEventListener('loadedmetadata', handleMeta);
audio.removeEventListener('durationchange', syncState);
audio.removeEventListener('timeupdate', handleTime);
audio.removeEventListener('play', handlePlay);
audio.removeEventListener('pause', handlePause);
audio.removeEventListener('ended', handleEnded);
};
}, [audioRef, onLoadedMetadata, onTimeUpdate, src]);
useEffect(() => {
if (audioRef?.current) {
audioRef.current.playbackRate = playbackRate;
}
}, [audioRef, playbackRate]);
const rateMenuItems = useMemo(
() => rateOptions.map((rate) => ({
key: String(rate),
label: `${rate.toFixed(rate % 1 === 0 ? 1 : 2)}x`,
onClick: () => onPlaybackRateChange?.(rate),
})),
[onPlaybackRateChange, rateOptions],
);
const progress = duration > 0 ? Math.min((currentTime / duration) * 100, 100) : 0;
const togglePlay = async () => {
const audio = audioRef?.current;
if (!audio || !src) {
return;
}
if (audio.paused || audio.ended) {
try {
await audio.play();
} catch {
setIsPlaying(false);
}
} else {
audio.pause();
}
};
const handleSeek = (event) => {
const audio = audioRef?.current;
if (!audio || !src) {
return;
}
const nextTime = Number(event.target.value);
audio.currentTime = nextTime;
setCurrentTime(nextTime);
};
if (!src) {
return (
<div className="audio-player-bar is-empty">
<span className="audio-player-bar-empty-text">{emptyText}</span>
</div>
);
}
return (
<div className="audio-player-bar">
<audio ref={audioRef} className="audio-player-bar-audio" src={src} preload="metadata" />
<Button
type="text"
className="audio-player-bar-play"
icon={isPlaying ? <PauseOutlined /> : <CaretRightFilled />}
onClick={togglePlay}
/>
<div className="audio-player-bar-time">
{tools.formatDuration(currentTime)} / {tools.formatDuration(duration)}
</div>
<input
className="audio-player-bar-progress"
type="range"
min={0}
max={duration || 0}
step={0.1}
value={Math.min(currentTime, duration || 0)}
onChange={handleSeek}
style={{ '--progress': `${progress}%` }}
/>
<span className="audio-player-bar-volume">
<SoundOutlined />
</span>
<span className="audio-player-bar-divider" />
<Dropdown menu={{ items: rateMenuItems, selectable: true, selectedKeys: [String(playbackRate)] }} trigger={['click']}>
<Button type="text" className="audio-player-bar-control audio-player-bar-rate">
<span>{playbackRate.toFixed(playbackRate % 1 === 0 ? 1 : 2)}x</span>
<DownOutlined />
</Button>
</Dropdown>
{showMoreButton ? (
<>
<span className="audio-player-bar-divider" />
{moreMenuItems.length > 0 ? (
<Dropdown menu={{ items: moreMenuItems }} trigger={['click']}>
<Button type="text" className="audio-player-bar-control audio-player-bar-more" icon={<MoreOutlined />} />
</Dropdown>
) : (
<Button type="text" disabled className="audio-player-bar-control audio-player-bar-more" icon={<MoreOutlined />} />
)}
</>
) : null}
</div>
);
};
export default AudioPlayerBar;

View File

@ -6,9 +6,16 @@ import { FullscreenOutlined, ZoomInOutlined, ZoomOutOutlined, SyncOutlined } fro
const transformer = new Transformer();
const hasRenderableSize = (element) => {
if (!element) return false;
const rect = element.getBoundingClientRect();
return Number.isFinite(rect.width) && Number.isFinite(rect.height) && rect.width > 0 && rect.height > 0;
};
const MindMap = ({ content, title }) => {
const svgRef = useRef(null);
const markmapRef = useRef(null);
const latestRootRef = useRef(null);
const [loading, setLoading] = useState(true);
useEffect(() => {
@ -17,16 +24,22 @@ const MindMap = ({ content, title }) => {
setLoading(true);
try {
const { root } = transformer.transform(content);
latestRootRef.current = root;
if (markmapRef.current) {
markmapRef.current.setData(root);
markmapRef.current.fit();
} else {
markmapRef.current = Markmap.create(svgRef.current, {
autoFit: true,
autoFit: false,
duration: 500,
}, root);
}
requestAnimationFrame(() => {
if (svgRef.current && hasRenderableSize(svgRef.current)) {
markmapRef.current?.fit();
}
});
} catch (error) {
console.error('Markmap error:', error);
} finally {
@ -34,6 +47,33 @@ const MindMap = ({ content, title }) => {
}
}, [content]);
useEffect(() => {
const svgElement = svgRef.current;
if (!svgElement || typeof ResizeObserver === 'undefined') {
return undefined;
}
const observer = new ResizeObserver(() => {
if (!hasRenderableSize(svgElement)) {
return;
}
if (!markmapRef.current && latestRootRef.current) {
markmapRef.current = Markmap.create(svgElement, {
autoFit: false,
duration: 500,
}, latestRootRef.current);
}
requestAnimationFrame(() => {
markmapRef.current?.fit();
});
});
observer.observe(svgElement);
return () => observer.disconnect();
}, []);
const handleFit = () => markmapRef.current?.fit();
const handleZoomIn = () => markmapRef.current?.rescale(1.2);
const handleZoomOut = () => markmapRef.current?.rescale(0.8);

View File

@ -0,0 +1,118 @@
.transcript-scroll-panel {
overflow-y: auto;
padding: 12px 12px 12px 4px;
}
.transcript-scroll-panel-fill {
flex: 1;
min-height: 0;
height: 100%;
}
.transcript-loading {
display: flex;
justify-content: center;
padding-top: 120px;
}
.transcript-entry {
margin-left: -4px;
padding: 10px 12px;
border: 1px solid transparent;
border-radius: 14px;
background: rgba(255, 255, 255, 0.82);
cursor: pointer;
transition: background 0.2s ease, border-color 0.2s ease, box-shadow 0.2s ease;
}
.transcript-entry:hover {
background: #f8fbff;
border-color: #d9e8fb;
}
.transcript-entry.is-active {
background: linear-gradient(180deg, #eef6ff 0%, #e2f0ff 100%);
border-color: #bfd8fb;
box-shadow: 0 10px 22px rgba(29, 78, 216, 0.12);
}
.transcript-entry-dot {
width: 10px;
height: 10px;
border-radius: 50%;
background: var(--speaker-color, #1677ff);
box-shadow: none;
transition: box-shadow 0.2s ease;
}
.transcript-entry-dot.is-active {
box-shadow: 0 0 0 3px rgba(22, 119, 255, 0.16);
}
.transcript-entry-time.ant-typography {
font-size: 12px;
white-space: nowrap;
}
.transcript-entry-header {
display: flex;
align-items: center;
gap: 8px;
margin-bottom: 4px;
}
.transcript-entry-speaker {
display: flex;
align-items: center;
gap: 8px;
min-width: 0;
}
.transcript-entry-avatar.ant-avatar {
flex-shrink: 0;
}
.transcript-entry-speaker-label.ant-typography {
margin: 0 !important;
font-size: 13px;
font-weight: 700;
color: #1677ff;
}
.transcript-entry-speaker-label.is-editable {
cursor: pointer;
}
.transcript-entry-speaker-edit {
font-size: 11px;
margin-left: 3px;
}
.transcript-entry-content {
color: #334155;
font-size: 14px;
line-height: 1.72;
}
.transcript-entry-content.ant-typography {
margin: 0 !important;
}
.transcript-render-hint {
text-align: center;
padding: 8px 0 20px;
}
@media (max-width: 768px) {
.transcript-scroll-panel {
padding-right: 6px;
}
.transcript-entry {
padding: 9px 10px;
}
.transcript-entry-content {
font-size: 13px;
}
}

View File

@ -0,0 +1,219 @@
import React from 'react';
import {
Avatar,
Button,
Empty,
Input,
Space,
Spin,
Timeline,
Typography,
} from 'antd';
import {
CheckOutlined,
CloseOutlined,
EditOutlined,
UserOutlined,
} from '@ant-design/icons';
import tools from '../utils/tools';
import './TranscriptTimeline.css';
const { Text } = Typography;
const TranscriptTimeline = ({
transcript = [],
loading = false,
visibleCount,
currentHighlightIndex = -1,
onJumpToTime,
onScroll,
transcriptRefs,
getSpeakerColor,
emptyDescription = '暂无对话数据',
loadingTip = '正在加载转录内容...',
showRenderHint = false,
fillHeight = false,
maxHeight = null,
editable = false,
isMeetingOwner = false,
editing = {},
}) => {
const {
inlineSpeakerEdit = null,
inlineSpeakerEditSegmentId = null,
inlineSpeakerValue = '',
setInlineSpeakerValue,
startInlineSpeakerEdit,
saveInlineSpeakerEdit,
cancelInlineSpeakerEdit,
inlineSegmentEditId = null,
inlineSegmentValue = '',
setInlineSegmentValue,
startInlineSegmentEdit,
saveInlineSegmentEdit,
cancelInlineSegmentEdit,
savingInlineEdit = false,
} = editing;
const renderCount = Math.min(visibleCount ?? transcript.length, transcript.length);
if (loading) {
return (
<div
className={`transcript-scroll-panel${fillHeight ? ' transcript-scroll-panel-fill' : ''}`}
onScroll={onScroll}
style={maxHeight ? { maxHeight } : undefined}
>
<div className="transcript-loading">
<Spin size="large" tip={loadingTip} />
</div>
</div>
);
}
if (!transcript.length) {
return (
<div
className={`transcript-scroll-panel${fillHeight ? ' transcript-scroll-panel-fill' : ''}`}
onScroll={onScroll}
style={maxHeight ? { maxHeight } : undefined}
>
<Empty image={Empty.PRESENTED_IMAGE_SIMPLE} description={emptyDescription} style={{ marginTop: 80 }} />
</div>
);
}
return (
<div
className={`transcript-scroll-panel${fillHeight ? ' transcript-scroll-panel-fill' : ''}`}
onScroll={onScroll}
style={maxHeight ? { maxHeight } : undefined}
>
<Timeline
mode="left"
className="transcript-timeline"
items={transcript.slice(0, renderCount).map((item, index) => {
const isActive = currentHighlightIndex === index;
const speakerColor = getSpeakerColor(item.speaker_id);
const speakerEditKey = `speaker-${item.speaker_id}-${item.segment_id}`;
return {
label: (
<Text type="secondary" className="transcript-entry-time">
{tools.formatDuration(item.start_time_ms / 1000)}
</Text>
),
dot: (
<span
className={`transcript-entry-dot${isActive ? ' is-active' : ''}`}
style={{ '--speaker-color': speakerColor }}
/>
),
children: (
<div
ref={(el) => {
if (transcriptRefs?.current) {
transcriptRefs.current[index] = el;
}
}}
className={`transcript-entry${isActive ? ' is-active' : ''}`}
onClick={() => onJumpToTime?.(item.start_time_ms)}
>
<div className="transcript-entry-header">
<div className="transcript-entry-speaker">
<Avatar
size={24}
icon={<UserOutlined />}
className="transcript-entry-avatar"
style={{ backgroundColor: speakerColor }}
/>
{editable && inlineSpeakerEdit === item.speaker_id && inlineSpeakerEditSegmentId === speakerEditKey ? (
<Space.Compact onClick={(event) => event.stopPropagation()}>
<Input
size="small"
autoFocus
value={inlineSpeakerValue}
onChange={(event) => setInlineSpeakerValue?.(event.target.value)}
onPressEnter={saveInlineSpeakerEdit}
style={{ width: 180 }}
/>
<Button
size="small"
type="text"
icon={<CheckOutlined />}
loading={savingInlineEdit}
onClick={saveInlineSpeakerEdit}
/>
<Button
size="small"
type="text"
icon={<CloseOutlined />}
disabled={savingInlineEdit}
onClick={cancelInlineSpeakerEdit}
/>
</Space.Compact>
) : (
<Text
className={`transcript-entry-speaker-label${editable && isMeetingOwner ? ' is-editable' : ''}`}
onClick={editable && isMeetingOwner ? (event) => {
event.stopPropagation();
startInlineSpeakerEdit?.(item.speaker_id, item.speaker_tag, item.segment_id);
} : undefined}
>
{item.speaker_tag || `发言人 ${item.speaker_id}`}
{editable && isMeetingOwner ? <EditOutlined className="transcript-entry-speaker-edit" /> : null}
</Text>
)}
</div>
</div>
{editable && inlineSegmentEditId === item.segment_id ? (
<div onClick={(event) => event.stopPropagation()}>
<Input.TextArea
autoFocus
autoSize={{ minRows: 2, maxRows: 6 }}
value={inlineSegmentValue}
onChange={(event) => setInlineSegmentValue?.(event.target.value)}
onPressEnter={(event) => {
if (event.ctrlKey || event.metaKey) {
saveInlineSegmentEdit?.();
}
}}
/>
<Space style={{ marginTop: 8 }}>
<Button size="small" type="primary" icon={<CheckOutlined />} loading={savingInlineEdit} onClick={saveInlineSegmentEdit}>
保存
</Button>
<Button size="small" icon={<CloseOutlined />} disabled={savingInlineEdit} onClick={cancelInlineSegmentEdit}>
取消
</Button>
</Space>
</div>
) : (
<Text
className="transcript-entry-content"
onDoubleClick={editable && isMeetingOwner ? (event) => {
event.stopPropagation();
startInlineSegmentEdit?.(item);
} : undefined}
>
{item.text_content}
</Text>
)}
</div>
),
};
})}
/>
{showRenderHint && renderCount < transcript.length ? (
<div className="transcript-render-hint">
<Text type="secondary">
已渲染 {renderCount} / {transcript.length} 条转录继续向下滚动将自动加载更多
</Text>
</div>
) : null}
</div>
);
};
export default TranscriptTimeline;

View File

@ -3,7 +3,7 @@ import { useParams, useNavigate } from 'react-router-dom';
import {
Card, Row, Col, Button, Space, Typography, Tag, Avatar,
Tooltip, Progress, Spin, App, Dropdown,
Divider, List, Timeline, Tabs, Input, Upload, Empty, Drawer, Select, Switch
Divider, List, Tabs, Input, Upload, Empty, Drawer, Select, Switch
} from 'antd';
import {
ClockCircleOutlined, UserOutlined, TeamOutlined,
@ -13,13 +13,15 @@ import {
EyeOutlined, FileTextOutlined, PartitionOutlined,
SaveOutlined, CloseOutlined,
StarFilled, RobotOutlined, DownloadOutlined,
DownOutlined, CheckOutlined,
CheckOutlined,
MoreOutlined, AudioOutlined, CopyOutlined
} from '@ant-design/icons';
import MarkdownRenderer from '../components/MarkdownRenderer';
import MarkdownEditor from '../components/MarkdownEditor';
import MindMap from '../components/MindMap';
import ActionButton from '../components/ActionButton';
import AudioPlayerBar from '../components/AudioPlayerBar';
import TranscriptTimeline from '../components/TranscriptTimeline';
import apiClient from '../utils/apiClient';
import tools from '../utils/tools';
import { buildApiUrl, API_ENDPOINTS } from '../config/api';
@ -823,14 +825,6 @@ const MeetingDetails = ({ user }) => {
{ key: 'upload', icon: <UploadOutlined />, label: isUploading ? '上传中...' : '上传音频', disabled: isUploading, onClick: openAudioUploadPicker },
];
const playbackRateMenuItems = [
{ key: '0.75', label: '0.75x', onClick: () => changePlaybackRate(0.75) },
{ key: '1', label: '1.0x', onClick: () => changePlaybackRate(1) },
{ key: '1.25', label: '1.25x', onClick: () => changePlaybackRate(1.25) },
{ key: '1.5', label: '1.5x', onClick: () => changePlaybackRate(1.5) },
{ key: '2', label: '2.0x', onClick: () => changePlaybackRate(2) },
];
/* ══════════════════ 渲染 ══════════════════ */
if (loading) return <div style={{ textAlign: 'center', padding: '100px' }}><Spin size="large" tip="正在加载..." /></div>;
@ -983,188 +977,54 @@ const MeetingDetails = ({ user }) => {
{/* 音频播放器 */}
<div style={{ padding: '8px 20px 0' }}>
<div className="meeting-audio-toolbar">
<div className="meeting-audio-toolbar-player">
{audioUrl ? (
<audio
className="meeting-audio-toolbar-native"
ref={audioRef}
src={audioUrl}
controls
controlsList="nodownload noplaybackrate"
onLoadedMetadata={() => {
if (audioRef.current) {
audioRef.current.playbackRate = playbackRate;
}
}}
onTimeUpdate={handleTimeUpdate}
style={{ width: '100%', height: 36 }}
/>
) : (
<div className="meeting-audio-toolbar-empty">
<Text type="secondary">暂无音频可通过右侧更多操作上传音频</Text>
</div>
)}
</div>
<div className="meeting-audio-toolbar-actions">
<Dropdown
menu={{ items: playbackRateMenuItems, selectable: true, selectedKeys: [String(playbackRate)] }}
trigger={['click']}
>
<Button
className="meeting-audio-toolbar-button meeting-audio-toolbar-rate btn-pill-secondary"
disabled={!audioUrl}
>
<span>{playbackRate.toFixed(playbackRate % 1 === 0 ? 1 : 2)}x</span>
<DownOutlined />
</Button>
</Dropdown>
<Dropdown menu={{ items: audioMoreMenuItems }} trigger={['click']}>
<Button
className="meeting-audio-toolbar-button meeting-audio-toolbar-more btn-pill-secondary"
icon={<MoreOutlined />}
/>
</Dropdown>
</div>
</div>
<AudioPlayerBar
audioRef={audioRef}
src={audioUrl}
playbackRate={playbackRate}
onPlaybackRateChange={changePlaybackRate}
onTimeUpdate={handleTimeUpdate}
onLoadedMetadata={() => {
if (audioRef.current) {
audioRef.current.playbackRate = playbackRate;
}
}}
moreMenuItems={audioMoreMenuItems}
emptyText="暂无音频,可通过右侧更多操作上传音频"
/>
</div>
{/* 转录时间轴 */}
<div
style={{ flex: 1, overflowY: 'auto', padding: '12px 12px 12px 4px' }}
onScroll={handleTranscriptScroll}
>
{transcriptLoading ? (
<div style={{ display: 'flex', justifyContent: 'center', paddingTop: 120 }}>
<Spin size="large" tip="正在加载转录内容..." />
</div>
) : transcript.length > 0 ? (
<>
<Timeline
mode="left"
className="transcript-timeline"
items={transcript.slice(0, transcriptVisibleCount).map((item, index) => {
const isActive = currentHighlightIndex === index;
return {
label: (
<Text type="secondary" style={{ fontSize: 12, whiteSpace: 'nowrap' }}>
{tools.formatDuration(item.start_time_ms / 1000)}
</Text>
),
dot: (
<div style={{
width: 10, height: 10, borderRadius: '50%',
background: getSpeakerColor(item.speaker_id),
boxShadow: isActive ? `0 0 0 3px ${getSpeakerColor(item.speaker_id)}33` : 'none',
}} />
),
children: (
<div
ref={el => transcriptRefs.current[index] = el}
style={{
padding: '6px 10px',
borderRadius: 8,
background: isActive ? '#e6f4ff' : 'transparent',
cursor: 'pointer',
transition: 'background 0.2s',
marginLeft: -4,
}}
onClick={() => jumpToTime(item.start_time_ms)}
>
<div style={{ display: 'flex', alignItems: 'center', gap: 8, marginBottom: 2 }}>
<Avatar
size={24}
icon={<UserOutlined />}
style={{ backgroundColor: getSpeakerColor(item.speaker_id), flexShrink: 0 }}
/>
{inlineSpeakerEdit === item.speaker_id && inlineSpeakerEditSegmentId === `speaker-${item.speaker_id}-${item.segment_id}` ? (
<Space.Compact onClick={(e) => e.stopPropagation()}>
<Input
size="small"
autoFocus
value={inlineSpeakerValue}
onChange={(e) => setInlineSpeakerValue(e.target.value)}
onPressEnter={saveInlineSpeakerEdit}
style={{ width: 180 }}
/>
<Button
size="small"
type="text"
icon={<CheckOutlined />}
loading={savingInlineEdit}
onClick={saveInlineSpeakerEdit}
/>
<Button
size="small"
type="text"
icon={<CloseOutlined />}
disabled={savingInlineEdit}
onClick={cancelInlineSpeakerEdit}
/>
</Space.Compact>
) : (
<Text
strong
style={{ color: '#1677ff', cursor: isMeetingOwner ? 'pointer' : 'default', fontSize: 13 }}
onClick={isMeetingOwner ? (e) => {
e.stopPropagation();
startInlineSpeakerEdit(item.speaker_id, item.speaker_tag, item.segment_id);
} : undefined}
>
{item.speaker_tag || `发言人 ${item.speaker_id}`}
{isMeetingOwner ? <EditOutlined style={{ fontSize: 11, marginLeft: 3 }} /> : null}
</Text>
)}
</div>
{inlineSegmentEditId === item.segment_id ? (
<div onClick={(e) => e.stopPropagation()}>
<Input.TextArea
autoFocus
autoSize={{ minRows: 2, maxRows: 6 }}
value={inlineSegmentValue}
onChange={(e) => setInlineSegmentValue(e.target.value)}
onPressEnter={(e) => {
if (e.ctrlKey || e.metaKey) {
saveInlineSegmentEdit();
}
}}
/>
<Space style={{ marginTop: 8 }}>
<Button size="small" type="primary" icon={<CheckOutlined />} loading={savingInlineEdit} onClick={saveInlineSegmentEdit}>
保存
</Button>
<Button size="small" icon={<CloseOutlined />} disabled={savingInlineEdit} onClick={cancelInlineSegmentEdit}>
取消
</Button>
</Space>
</div>
) : (
<Text
style={{ fontSize: 14, lineHeight: 1.7, color: '#333', cursor: isMeetingOwner ? 'text' : 'default' }}
onDoubleClick={isMeetingOwner ? (e) => {
e.stopPropagation();
startInlineSegmentEdit(item);
} : undefined}
>
{item.text_content}
</Text>
)}
</div>
),
};
})}
/>
{transcriptVisibleCount < transcript.length ? (
<div style={{ textAlign: 'center', padding: '8px 0 20px' }}>
<Text type="secondary">
已渲染 {transcriptVisibleCount} / {transcript.length} 条转录继续向下滚动将自动加载更多
</Text>
</div>
) : null}
</>
) : (
<Empty image={Empty.PRESENTED_IMAGE_SIMPLE} description="暂无对话数据" style={{ marginTop: 80 }} />
)}
<div style={{ flex: 1, overflow: 'hidden', display: 'flex', minHeight: 0 }}>
<TranscriptTimeline
transcript={transcript}
loading={transcriptLoading}
visibleCount={transcriptVisibleCount}
currentHighlightIndex={currentHighlightIndex}
onJumpToTime={jumpToTime}
onScroll={handleTranscriptScroll}
transcriptRefs={transcriptRefs}
getSpeakerColor={getSpeakerColor}
showRenderHint
fillHeight
editable
isMeetingOwner={isMeetingOwner}
editing={{
inlineSpeakerEdit,
inlineSpeakerEditSegmentId,
inlineSpeakerValue,
setInlineSpeakerValue,
startInlineSpeakerEdit,
saveInlineSpeakerEdit,
cancelInlineSpeakerEdit,
inlineSegmentEditId,
inlineSegmentValue,
setInlineSegmentValue,
startInlineSegmentEdit,
saveInlineSegmentEdit,
cancelInlineSegmentEdit,
savingInlineEdit,
}}
/>
</div>
</Card>
</Col>

View File

@ -591,9 +591,14 @@
======================================== */
.transcript-wrapper {
display: block;
padding: 20px 0;
}
.preview-audio-toolbar {
padding: 0;
}
.preview-audio-player {
background: linear-gradient(135deg, #667eea, #764ba2);
border-radius: 12px;
@ -823,34 +828,4 @@
font-size: 15px;
}
/* 预览页面播放器移动端优化 */
.preview-audio-player {
padding: 16px;
}
.preview-player-controls {
gap: 12px;
}
.preview-progress-wrapper {
width: 100%;
}
.preview-current-time {
font-size: 11px;
padding: 4px 8px;
}
.preview-current-time::after {
border-left: 4px solid transparent;
border-right: 4px solid transparent;
border-top: 4px solid white;
bottom: -3px;
}
.preview-slider-thumb::after {
width: 14px;
height: 14px;
border-width: 2px;
}
}

View File

@ -1,11 +1,13 @@
import React, { useEffect, useRef, useState } from 'react';
import { useParams, Link } from 'react-router-dom';
import { Layout, Space, Button, App, Empty, Input, Tabs } from 'antd';
import { LockOutlined, EyeOutlined, CopyOutlined, ShareAltOutlined, HomeOutlined, UserOutlined, FileTextOutlined, PartitionOutlined, AudioOutlined } from '@ant-design/icons';
import { LockOutlined, EyeOutlined, CopyOutlined, ShareAltOutlined, HomeOutlined, FileTextOutlined, PartitionOutlined, AudioOutlined } from '@ant-design/icons';
import apiClient from '../utils/apiClient';
import { buildApiUrl, API_ENDPOINTS } from '../config/api';
import MarkdownRenderer from '../components/MarkdownRenderer';
import MindMap from '../components/MindMap';
import AudioPlayerBar from '../components/AudioPlayerBar';
import TranscriptTimeline from '../components/TranscriptTimeline';
import tools from '../utils/tools';
import configService, { DEFAULT_BRANDING_CONFIG } from '../utils/configService';
import './MeetingPreview.css';
@ -16,6 +18,7 @@ const MeetingPreview = () => {
const { meeting_id } = useParams();
const { message } = App.useApp();
const audioRef = useRef(null);
const transcriptRefs = useRef([]);
const [meeting, setMeeting] = useState(null);
const [loading, setLoading] = useState(true);
const [error, setError] = useState(null);
@ -27,6 +30,7 @@ const MeetingPreview = () => {
const [transcript, setTranscript] = useState([]);
const [audioUrl, setAudioUrl] = useState('');
const [activeSegmentIndex, setActiveSegmentIndex] = useState(-1);
const [playbackRate, setPlaybackRate] = useState(1);
useEffect(() => {
configService.getBrandingConfig().then(setBranding).catch(() => {});
@ -35,8 +39,10 @@ const MeetingPreview = () => {
useEffect(() => {
setMeeting(null);
setTranscript([]);
transcriptRefs.current = [];
setAudioUrl('');
setActiveSegmentIndex(-1);
setPlaybackRate(1);
setError(null);
setPassword('');
setPasswordError('');
@ -132,6 +138,14 @@ const MeetingPreview = () => {
audioRef.current.play().catch(() => {});
};
useEffect(() => {
if (activeSegmentIndex < 0) {
return;
}
transcriptRefs.current[activeSegmentIndex]?.scrollIntoView({ behavior: 'smooth', block: 'center' });
}, [activeSegmentIndex]);
const handleVerify = () => {
if (!password) {
message.warning('请输入访问密码');
@ -274,39 +288,28 @@ const MeetingPreview = () => {
children: (
<div className="transcript-wrapper">
{audioUrl ? (
<div className="preview-audio-player">
<audio
ref={audioRef}
src={audioUrl}
controls
controlsList="nodownload noplaybackrate"
onTimeUpdate={handleTimeUpdate}
style={{ width: '100%' }}
/>
</div>
<AudioPlayerBar
audioRef={audioRef}
src={audioUrl}
playbackRate={playbackRate}
onPlaybackRateChange={setPlaybackRate}
onTimeUpdate={handleTimeUpdate}
showMoreButton={false}
/>
) : null}
{transcript.length ? (
<div className="transcript-list">
{transcript.map((segment, index) => (
<div
key={segment.segment_id}
className={`transcript-segment${activeSegmentIndex === index ? ' active' : ''}`}
onClick={() => jumpToSegment(segment)}
>
<div className="segment-header">
<span className="speaker-name">
<UserOutlined style={{ marginRight: 6 }} />
{segment.speaker_tag || `发言人 ${segment.speaker_id}`}
</span>
<span className="segment-time">{tools.formatDuration((segment.start_time_ms || 0) / 1000)}</span>
</div>
<div className="segment-text">{segment.text_content}</div>
</div>
))}
</div>
) : (
<div className="empty-transcript">暂无转录内容</div>
)}
<TranscriptTimeline
transcript={transcript}
visibleCount={transcript.length}
currentHighlightIndex={activeSegmentIndex}
onJumpToTime={(timeMs) => jumpToSegment({ start_time_ms: timeMs })}
transcriptRefs={transcriptRefs}
maxHeight="520px"
getSpeakerColor={(speakerId) => {
const palette = ['#1677ff', '#52c41a', '#fa8c16', '#eb2f96', '#722ed1', '#13c2c2', '#2f54eb', '#faad14'];
return palette[(speakerId ?? 0) % palette.length];
}}
emptyDescription="暂无转录内容"
/>
</div>
),
}

View File

@ -439,110 +439,6 @@ body {
width: calc(100% - 96px) !important;
}
.meeting-audio-toolbar {
display: flex;
align-items: center;
gap: 12px;
padding: 0;
}
.meeting-audio-toolbar-player {
flex: 1;
min-width: 0;
}
.meeting-audio-toolbar-native {
width: 100%;
height: 40px;
border-radius: 999px;
background: #f5f7fb;
}
.meeting-audio-toolbar-native::-webkit-media-controls-panel {
background: #f5f7fb;
}
.meeting-audio-toolbar-empty {
height: 40px;
display: flex;
align-items: center;
padding: 0 14px;
border-radius: 999px;
background: #f5f7fb;
}
.meeting-audio-toolbar-actions {
display: inline-flex;
align-items: center;
gap: 8px;
padding: 0;
}
.meeting-audio-toolbar-button.ant-btn {
height: 32px;
padding: 0 10px;
border: 1px solid #dbe3ef;
border-radius: 999px;
background: #fff;
color: #526581;
font-size: 12px;
font-weight: 600;
box-shadow: none;
}
.meeting-audio-toolbar-button.ant-btn:hover,
.meeting-audio-toolbar-button.ant-btn:focus {
color: #355171;
border-color: #c7d4e4;
background: #f8fafc !important;
box-shadow: none;
}
.meeting-audio-toolbar-button.ant-btn:disabled {
color: #a1b1c4;
border-color: #e3e8f0;
background: #f8fafc !important;
box-shadow: none;
}
.meeting-audio-toolbar-rate.ant-btn {
display: inline-flex;
align-items: center;
gap: 5px;
min-width: 68px;
justify-content: center;
font-weight: 700;
}
.meeting-audio-toolbar-button .anticon {
font-size: 11px;
}
.meeting-audio-toolbar-rate .anticon {
font-size: 9px;
}
.meeting-audio-toolbar-more.ant-btn {
width: 32px;
min-width: 32px;
padding-inline: 0;
padding: 0;
border-color: #c9ddfb;
background: linear-gradient(180deg, #f8fbff 0%, #eef5ff 100%);
color: #1d4ed8;
}
.meeting-audio-toolbar-more.ant-btn:hover,
.meeting-audio-toolbar-more.ant-btn:focus {
border-color: #a9c9fa;
background: linear-gradient(180deg, #f2f8ff 0%, #e7f0ff 100%) !important;
color: #1d4ed8;
}
.meeting-audio-toolbar-more.ant-btn .anticon {
font-size: 12px;
}
.console-tab-toolbar {
display: flex;
justify-content: space-between;