Update app.py

app.py

@@ -264,15 +264,19 @@ def build_ffmpeg_command(input_path, start_time, duration, output_path, operatio
     threads = get_optimal_threads()
     encoder = HARDWARE_ACCEL['encoder']
     
-    base_command = ['ffmpeg', '-threads', str(threads)]
+    # 处理中文文件名 - 使用绝对路径并确保路径正确
+    input_path = os.path.abspath(input_path)
+    output_path = os.path.abspath(output_path)
     
-    # 硬件加速解码
-    if HARDWARE_ACCEL['nvidia']:
-        base_command.extend(['-hwaccel', 'cuda'])
-    elif HARDWARE_ACCEL['amd']:
-        base_command.extend(['-hwaccel', 'amf'])
-    elif HARDWARE_ACCEL['intel']:
-        base_command.extend(['-hwaccel', 'qsv'])
+    base_command = ['ffmpeg']
+    
+    # 硬件加速解码 - 简化处理，避免兼容性问题
+    # if HARDWARE_ACCEL['nvidia']:
+    #     base_command.extend(['-hwaccel', 'cuda'])
+    # elif HARDWARE_ACCEL['amd']:
+    #     base_command.extend(['-hwaccel', 'amf'])
+    # elif HARDWARE_ACCEL['intel']:
+    #     base_command.extend(['-hwaccel', 'qsv'])
     
     base_command.extend(['-i', input_path])
     
@@ -281,19 +285,18 @@ def build_ffmpeg_command(input_path, start_time, duration, output_path, operatio
         
         # 编码参数
         if encoder == 'h264_nvenc':
-            # NVIDIA GPU编码参数
+            # NVIDIA GPU编码参数 - 简化版本
             base_command.extend([
                 '-c:v', 'h264_nvenc',
-                '-preset', 'p1',  # 最快预设
-                '-tune', 'ull',   # 超低延迟
-                '-cq', '28',      # 质量参数
+                '-preset', 'fast',  # 使用fast而不是p1，更兼容
+                '-cq', '28',        # 质量参数
                 '-c:a', 'aac',
                 '-b:a', '128k',
                 '-movflags', '+faststart',
                 '-y', output_path
             ])
         elif encoder == 'h264_amf':
-            # AMD GPU编码参数
+            # AMD GPU编码参数 - 简化版本
             base_command.extend([
                 '-c:v', 'h264_amf',
                 '-quality', 'speed',
@@ -306,7 +309,7 @@ def build_ffmpeg_command(input_path, start_time, duration, output_path, operatio
                 '-y', output_path
             ])
         elif encoder == 'h264_qsv':
-            # Intel Quick Sync编码参数
+            # Intel Quick Sync编码参数 - 简化版本
             base_command.extend([
                 '-c:v', 'h264_qsv',
                 '-preset', 'veryfast',
@@ -323,7 +326,6 @@ def build_ffmpeg_command(input_path, start_time, duration, output_path, operatio
                 '-preset', 'ultrafast',  # 最快预设
                 '-crf', '28',            # 质量参数
                 '-tune', 'fastdecode',   # 优化解码速度
-                '-x264opts', 'no-scenecut',  # 禁用场景检测以加快速度
                 '-c:a', 'aac',
                 '-b:a', '128k',
                 '-movflags', '+faststart',
@@ -336,8 +338,7 @@ def build_ffmpeg_command(input_path, start_time, duration, output_path, operatio
         if encoder == 'h264_nvenc':
             base_command.extend([
                 '-c:v', 'h264_nvenc',
-                '-preset', 'p1',
-                '-tune', 'ull',
+                '-preset', 'fast',
                 '-cq', '28',
                 '-c:a', 'copy',
                 '-movflags', '+faststart',
@@ -349,7 +350,6 @@ def build_ffmpeg_command(input_path, start_time, duration, output_path, operatio
                 '-preset', 'ultrafast',
                 '-crf', '28',
                 '-tune', 'fastdecode',
-                '-x264opts', 'no-scenecut',
                 '-c:a', 'copy',
                 '-movflags', '+faststart',
                 '-y', output_path
@@ -359,24 +359,52 @@ def build_ffmpeg_command(input_path, start_time, duration, output_path, operatio
 
 def ffmpeg_cut_video(input_path, start_time, duration, output_path):
     """[优化] 快速的视频切割，使用硬件加速和ultrafast预设"""
-    command = build_ffmpeg_command(input_path, start_time, duration, output_path, 'cut')
-    result = subprocess.run(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
-    return result.returncode == 0 and os.path.exists(output_path)
+    try:
+        command = build_ffmpeg_command(input_path, start_time, duration, output_path, 'cut')
+        print(f"执行FFmpeg命令: {' '.join(command)}")  # 调试输出
+        
+        # 创建输出目录（如果不存在）
+        os.makedirs(os.path.dirname(output_path), exist_ok=True)
+        
+        result = subprocess.run(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE, text=True)
+        
+        if result.returncode != 0:
+            print(f"FFmpeg错误: {result.stderr}")  # 输出错误信息
+            return False
+        
+        return os.path.exists(output_path)
+    except Exception as e:
+        print(f"切割视频异常: {e}")
+        return False
 
 def ffmpeg_resize_video(input_path, output_path, target_ratio):
     """[优化] 快速的比例调整，使用硬件���速和ultrafast预设"""
-    if target_ratio == '9:16':
-        filter_complex = "scale=1080:1920:force_original_aspect_ratio=decrease,pad=1080:1920:(ow-iw)/2:(oh-ih)/2:black"
-    else:
-        filter_complex = "scale=1920:1080:force_original_aspect_ratio=decrease,pad=1920:1080:(ow-iw)/2:(oh-ih)/2:black"
-    
-    command = build_ffmpeg_command(input_path, 0, 0, output_path, 'resize')
-    # 在resize操作中插入滤镜
-    command.insert(-5, '-vf')  # 在-y之前插入
-    command.insert(-4, filter_complex)
-    
-    result = subprocess.run(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
-    return result.returncode == 0 and os.path.exists(output_path)
+    try:
+        if target_ratio == '9:16':
+            filter_complex = "scale=1080:1920:force_original_aspect_ratio=decrease,pad=1080:1920:(ow-iw)/2:(oh-ih)/2:black"
+        else:
+            filter_complex = "scale=1920:1080:force_original_aspect_ratio=decrease,pad=1920:1080:(ow-iw)/2:(oh-ih)/2:black"
+        
+        command = build_ffmpeg_command(input_path, 0, 0, output_path, 'resize')
+        # 在resize操作中插入滤镜
+        command.insert(-5, '-vf')  # 在-y之前插入
+        command.insert(-4, filter_complex)
+        
+        print(f"执行FFmpeg调整命令: {' '.join(command)}")  # 调试输出
+        
+        # 创建输出目录（如果不存在）
+        os.makedirs(os.path.dirname(output_path), exist_ok=True)
+        
+        result = subprocess.run(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE, text=True)
+        
+        if result.returncode != 0:
+            print(f"FFmpeg调整错误: {result.stderr}")  # 输出错误信息
+            return False
+        
+        return os.path.exists(output_path)
+    except Exception as e:
+        print(f"调整视频异常: {e}")
+        return False
 
 def concat_videos(file_list, output_path):
     """稳定的视频合并"""
@@ -397,8 +425,19 @@ def concat_videos(file_list, output_path):
         # 使用多线程进行合并
         threads = get_optimal_threads()
         command = ['ffmpeg', '-threads', str(threads), '-f', 'concat', '-safe', '0', '-i', list_file.name, '-c', 'copy', '-y', output_path]
-        result = subprocess.run(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
-        return result.returncode == 0 and os.path.exists(output_path)
+        
+        print(f"执行FFmpeg合并命令: {' '.join(command)}")  # 调试输出
+        
+        # 创建输出目录（如果不存在）
+        os.makedirs(os.path.dirname(output_path), exist_ok=True)
+        
+        result = subprocess.run(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE, text=True)
+        
+        if result.returncode != 0:
+            print(f"FFmpeg合并错误: {result.stderr}")  # 输出错误信息
+            return False
+        
+        return os.path.exists(output_path)
     finally:
         try:
             os.unlink(list_file.name)
@@ -414,6 +453,7 @@ def process_single_video(video_file, clip_duration, temp_dir):
         cmd = ['ffprobe', '-v', 'quiet', '-show_entries', 'format=duration', '-of', 'default=noprint_wrappers=1:nokey=1', video_path]
         result = subprocess.run(cmd, capture_output=True, text=True, timeout=10)
         total_duration = float(result.stdout.strip())
+        print(f"视频总时长: {total_duration} 秒")
     except Exception as e:
         print(f"处理视频 {video_path} 时获取时长失败: {e}")
         return clips
@@ -425,10 +465,13 @@ def process_single_video(video_file, clip_duration, temp_dir):
         # 修改文件名，包含原始文件名和计数，避免不同视频的切片重名
         clip_path = os.path.join(temp_dir, f"clip_{os.path.splitext(os.path.basename(video_path))[0]}_{count}.mp4")
 
+        print(f"正在切割片段 {count}: {start}-{start+duration} 秒 -> {clip_path}")
+        
         if ffmpeg_cut_video(video_path, start, duration, clip_path):
             clips.append(clip_path)
+            print(f"✅ 切片成功: {clip_path}")
         else:
-            print(f"切割视频 {video_path} 的第 {count} 个片段失败")
+            print(f"❌ 切片失败: {clip_path}")
 
         start += clip_duration
         count += 1
@@ -451,9 +494,9 @@ def process_videos_with_storage(video_files, clip_duration, num_output_videos, t
 
         all_clips = []
 
-        # 使用进程池进行并行处理（避免GIL限制）
-        print(f"🚀 启动并行切片（{min(8, os.cpu_count() or 1)} 进程）...")
-        with concurrent.futures.ProcessPoolExecutor(max_workers=min(8, os.cpu_count() or 1)) as executor:
+        # 使用线程池进行并行处理（避免GIL限制）
+        print(f"🚀 启动并行切片（{min(4, os.cpu_count() or 1)} 线程）...")
+        with concurrent.futures.ThreadPoolExecutor(max_workers=min(4, os.cpu_count() or 1)) as executor:
             future_to_video = {
                 executor.submit(process_single_video, vf, clip_duration, temp_dir): vf 
                 for vf in video_files
@@ -809,35 +852,4 @@ def main():
         **⬇️ 一键下载功能:**
         - 📦 **一键下载全部**: 打包下载储存空间中所有视频
         - 📥 **选择下载**: 勾选特定文件进行批量下载
-        - 🗂️ **自动清单**: 下载包含详细文件清单
-        - ⚡ **快速打包**: 自动压缩，节省下载时间
-        
-        **🗑️ 文件管理功能:**
-        - 🗑️ 支持单个文件删除
-        - 🧹 支持清空全部储存文件
-        - 📱 灵活的文件管理操作
-        
-        **🔥 使用场景:**
-        - **批量备份**: 一键下载所有混剪作品
-        - **选择性导出**: 只下载需要的特定视频
-        - **移动设备**: 下载到手机/平板继续编辑
-        - **分享协作**: 打包分享给团队成员
-        - **存档管理**: 定期下载备份到云盘
-        
-        **⚡ 性能优化:**
-        - **硬件加速**: 自动检测并使用GPU加速
-        - **多线程处理**: 充分利用多核CPU
-        - **快速预设**: 使用ultrafast预设提升速度
-        - **并行处理**: 多个视频同时处理
-        
-        **⚠️ 注意事项:**
-        - 下载文件为ZIP格式，需要解压使用
-        - 一键下载包含储存空间中所有视频文件
-        - 选择下载可以精确控制需要的文件
-        - 下载包自动包含详细的文件清单
-        """)
-    
-    demo.launch()
-
-if __name__ == "__main__":
-    main()
+