fix(*)

Author: liuchuancong

lib/recorder/ffmpeg/ffmpeg_command_builder.dart

@@ -20,43 +20,32 @@ class FFmpegCommandBuilder {
     final ua = headers?['user-agent'] ?? defaultUserAgent;
     final headerStr = _buildHeader(headers);
     final normalizedOutputPath = '$outputDir${Platform.pathSeparator}%Y%m%d_%H%M%S.ts';
+    final rwTimeoutMicro = (rwTimeout * 1000000).clamp(0, 2147483647);
+
     final args = <String>[
       '-y',
       '-hide_banner',
       '-loglevel', 'info',
-      // 允许的协议白名单，确保直播流能正常加载
       '-protocol_whitelist', 'httpproxy,udp,rtp,tcp,tls,data,file,http,https,crypto',
-
-      // --- 重连与网络优化 ---
       '-reconnect', '1',
       '-reconnect_streamed', '1',
       '-reconnect_delay_max', '2',
       '-reconnect_at_eof', '1',
-      '-rw_timeout', '${rwTimeout * 1000000}', // 转化为微秒
+      '-rw_timeout', rwTimeoutMicro.toString(),
       '-max_delay', '5000000',
       '-thread_queue_size', threadQueueSize.toString(),
-
-      // --- 身份伪装 ---
-      '-user_agent', _quote(ua),
-      if (headerStr.isNotEmpty) ...['-headers', _quote(headerStr)], // 关键：headers必须包裹在引号内
-      // --- 输入 ---
-      '-i', _quote(url),
-
-      // --- 轨道处理 ---
-      // 使用 copy 模式避免 CPU 占用过高
+      '-user_agent', ua,
+      if (headerStr.isNotEmpty) ...['-headers', _quote(headerStr)], //关键：headers
+      '-i', url,
       '-map', preferBestStream ? '0:v:0' : '0:v',
       '-map', preferBestStream ? '0:a:0' : '0:a',
       '-c', 'copy',
-
-      // --- 分段逻辑 ---
       '-f', 'segment',
       '-segment_format', 'mpegts',
       '-segment_time', segmentTime.toString(),
       '-reset_timestamps', '1',
       '-strftime', '1',
-
-      // 输出路径 (使用 .ts 格式以防断流导致文件损坏)
-      _quote(normalizedOutputPath),
+      normalizedOutputPath,
     ];
 
     return args.join(' ');
@@ -68,8 +57,6 @@ class FFmpegCommandBuilder {
         .where((e) => e.key.toLowerCase() != 'user-agent')
         .map((e) => '${e.key}: ${e.value}')
         .join('\r\n');
-
-    // FFmpeg 要求 headers 末尾也必须有换行符
     return lines.isEmpty ? '' : '$lines\r\n';
   }
 }

lib/recorder/pages/recorder/recorder_controller.dart

@@ -287,6 +287,10 @@ class RecorderController extends GetxService {
     if (task.status == RecordStatus.running || task.status == RecordStatus.preparing) {
       log('Stopping task: ${task.taskId}');
     }
+    if (task.status == RecordStatus.reconnecting) {
+      task.status = RecordStatus.stopped;
+      updateTask(task);
+    }
   }
 
   Future<void> _onComplete(LiveRecordTask task) async {

lib/recorder/services/ffmpeg_service.dart

@@ -61,9 +61,9 @@ class FFmpegService {
       );
     });
     ffempgSession.setCompleteCallback((completedSession) {
-      log('FFmpeg complete => $taskId');
       final code = completedSession.getReturnCode();
       final success = ReturnCode.isSuccess(code);
+      log('FFmpeg complete => taskId: $taskId;successCode: $code ');
       onEvent(
         FFmpegEvent(
           taskId: taskId,