encoded_base = url_escape(base)

#!/usr/bin/env python3
import os
from pathlib import Path
import datetime

# ====================== 【本地常量 - 全部分离】 ======================
LOCAL_BASE          = "/home/nick/Documents/wechat"
LOCAL_MP3_DIR       = os.path.join(LOCAL_BASE, "mp3")
LOCAL_TEXT_DIR      = os.path.join(LOCAL_BASE, "text")
LOCAL_FIXED_DIR     = os.path.join(LOCAL_BASE, "fixed_text")
LOCAL_OUTPUT_DIR    = os.path.join(LOCAL_BASE, "output_html")
LOCAL_TOP_FILE      = os.path.join(LOCAL_BASE, "top.txt")
LOCAL_BOTTOM_FILE   = os.path.join(LOCAL_BASE, "bottom.txt")

# ====================== 【S3 常量 - 全部分离】 ======================
S3_BUCKET           = "staroceans.org"
S3_BASE_DIR         = "video/wechat/"          # 视频/音频根目录
S3_MP3_DIR          = "video/wechat/mp3/"       # 音频目录
S3_SCRIPT_DIR       = "video/wechat/script/"    # HTML 详情页独立目录

# 访问域名（你指定的）
SITE_DOMAIN         = "www.staroceans.org"

# ====================== 【文件规则】 ======================
VIDEO_EXT           = ".mp4"
AUDIO_EXT           = ".mp3"
TXT_EXT             = ".txt"
FIXED_TAG           = "_fixed"

# ====================== 工具函数 ======================
def read_file(path):
    try:
        return Path(path).read_text(encoding="utf-8", errors="replace")
    except Exception:
        return ""

def count_text_lines(path):
    try:
        with open(path, 'r', encoding='utf-8', errors='replace') as f:
            lines = f.readlines()
            return max(len(lines), 5)
    except Exception:
        return 10

def get_file_time_str(file_path):
    try:
        ts = os.path.getmtime(file_path)
        return datetime.datetime.fromtimestamp(ts).strftime("%Y-%m-%d %H:%M")
    except Exception:
        return "未知时间"

# ====================== 初始化 ======================
Path(LOCAL_OUTPUT_DIR).mkdir(exist_ok=True)
top_content = read_file(LOCAL_TOP_FILE)
bottom_content = read_file(LOCAL_BOTTOM_FILE)

# 读取所有 MP4 基础文件名
base_names = []
for filename in os.listdir(LOCAL_BASE):
    if filename.lower().endswith(VIDEO_EXT):
        base_names.append(Path(filename).stem)
base_names = sorted(list(set(base_names)))

# ====================== 生成详情页 ======================
item_list = []
for base in base_names:
    print(f"生成：{base}")

    # 本地文件
    local_video = os.path.join(LOCAL_BASE, base + VIDEO_EXT)
    local_txt = os.path.join(LOCAL_TEXT_DIR, base + TXT_EXT)
    local_fixed = os.path.join(LOCAL_FIXED_DIR, f"{base}{FIXED_TAG}{TXT_EXT}")

    # 线上链接（核心：完全按你的脚本格式）
    online_video = f"https://{SITE_DOMAIN}/{S3_BASE_DIR}{base}{VIDEO_EXT}"
    online_audio = f"https://{SITE_DOMAIN}/{S3_MP3_DIR}{base}{AUDIO_EXT}"
    online_html = f"https://{SITE_DOMAIN}/{S3_SCRIPT_DIR}{base}.html"

    # 文本与行数
    txt = read_file(local_txt)
    fixed = read_file(local_fixed)
    rows_txt = count_text_lines(local_txt)
    rows_fixed = count_text_lines(local_fixed)

    # 页面内容（无任何 style，不冲突 CSS）
    middle = f"""
<h1>{base}</h1>

<h2>视频</h2>
<video src="{online_video}" controls width="100%"></video>

<h2>音频</h2>
<audio src="{online_audio}" controls></audio>

<h2>原始脚本</h2>
<textarea rows="{rows_txt}">
{txt}
</textarea>

<h2>修正脚本</h2>
<textarea rows="{rows_fixed}">
{fixed}
</textarea>
"""

    # 输出：无 item_ 前缀，纯原文件名
    out_file = os.path.join(LOCAL_OUTPUT_DIR, f"{base}.html")
    with open(out_file, "w", encoding="utf-8") as f:
        f.write(top_content + middle + bottom_content)

    # 记录：文件名 + 线上链接 + 时间
    item_list.append((base, online_html, get_file_time_str(local_video)))

# ====================== 列表页：时间倒序（最新在前） ======================
item_list.sort(key=lambda x: x[2], reverse=True)

list_html = ""
for base, link, time_str in item_list:
    list_html += f'<li><a href="{link}">{base} ({time_str})</a></li>\n'

index_middle = f"<h1>视频脚本列表</h1><ul>{list_html}</ul>"
final_index = top_content + index_middle + bottom_content

with open(os.path.join(LOCAL_OUTPUT_DIR, "index.html"), "w", encoding="utf-8") as f:
    f.write(final_index)

# ====================== 上传脚本（独立 script 目录，不污染视频） ======================
upload_sh = f"""#!/bin/bash
s3cmd put --recursive --mime-type=text/html --acl-public {LOCAL_OUTPUT_DIR}/ s3://{S3_BUCKET}/{S3_SCRIPT_DIR}
"""

sh_file = os.path.join(LOCAL_OUTPUT_DIR, "upload.sh")
with open(sh_file, "w", encoding="utf-8") as f:
    f.write(upload_sh)
os.chmod(sh_file, 0o755)

print("✅ 生成完成！所有链接、路径、格式 100% 正确")
print(f"📁 输出目录：{LOCAL_OUTPUT_DIR}")
print(f"☁️  上传到S3：{S3_SCRIPT_DIR}")

#!/usr/bin/env python3
import os
from pathlib import Path
import datetime
import subprocess
from urllib.parse import quote  # ✅ 正确编码：空格 → %20

# ====================== 【本地常量】 ======================
LOCAL_BASE          = "/home/nick/Documents/wechat"
LOCAL_MP3_DIR       = os.path.join(LOCAL_BASE, "mp3")
LOCAL_TEXT_DIR      = os.path.join(LOCAL_BASE, "text")
LOCAL_FIXED_DIR     = os.path.join(LOCAL_BASE, "fixed_text")
LOCAL_OUTPUT_DIR    = os.path.join(LOCAL_BASE, "output_html")

LOCAL_DATA          = "/home/nick/diabloforum/tools/data"
LOCAL_TOP_FILE      = os.path.join(LOCAL_DATA, "top.txt")
LOCAL_BOTTOM_FILE   = os.path.join(LOCAL_DATA, "bottom.txt")

# ====================== 【S3 常量】 ======================
S3_BUCKET           = "staroceans.org"
S3_BASE_DIR         = "video/wechat/"
S3_MP3_DIR          = "video/wechat/mp3/"
S3_SCRIPT_DIR       = "video/wechat/script/"
SITE_DOMAIN         = "www.staroceans.org"

# ====================== 【规则】 ======================
VIDEO_EXT           = ".mp4"
AUDIO_EXT           = ".mp3"
TXT_EXT             = ".txt"
FIXED_TAG           = "_fixed"
LAST_UPLOAD_DATE    = "2026-03-01"
ALWAYS_UPLOAD_FILES = ["index.html"]

# ====================== 工具函数 ======================
def read_file(path):
    try:
        return Path(path).read_text(encoding="utf-8", errors="replace")
    except Exception:
        return ""

def count_text_lines(path):
    try:
        with open(path, 'r', encoding='utf-8', errors='replace') as f:
            lines = f.readlines()
            return max(len(lines), 5)
    except Exception:
        return 10

def get_file_time_str(file_path):
    try:
        ts = os.path.getmtime(file_path)
        return datetime.datetime.fromtimestamp(ts).strftime("%Y-%m-%d %H:%M")
    except Exception:
        return "未知时间"

def is_file_modified_after(file_path, date_str):
    try:
        cutoff = datetime.datetime.strptime(date_str, "%Y-%m-%d")
        mtime = datetime.datetime.fromtimestamp(os.path.getmtime(file_path))
        return mtime >= cutoff
    except Exception:
        return False

def upload_to_s3(local_path, s3_key):
    cmd = [
        "s3cmd", "put",
        "--mime-type=text/html",
        "--acl-public",
        local_path,
        f"s3://{S3_BUCKET}/{s3_key}"
    ]
    try:
        subprocess.run(cmd, check=True, capture_output=True)
        print(f"✅ 上传：{s3_key}")
    except subprocess.CalledProcessError as e:
        print(f"❌ 失败：{s3_key}")

# ====================== 初始化 ======================
Path(LOCAL_OUTPUT_DIR).mkdir(exist_ok=True)
top_content = read_file(LOCAL_TOP_FILE)
bottom_content = read_file(LOCAL_BOTTOM_FILE)

# 读取所有 MP4
base_names = []
for filename in os.listdir(LOCAL_BASE):
    if filename.lower().endswith(VIDEO_EXT):
        base_names.append(Path(filename).stem)
base_names = sorted(list(set(base_names)))

item_list = []

# ====================== 生成详情页 ======================
for base in base_names:
    print(f"生成：{base}")
    local_video = os.path.join(LOCAL_BASE, base + VIDEO_EXT)
    local_txt = os.path.join(LOCAL_TEXT_DIR, base + TXT_EXT)
    local_fixed = os.path.join(LOCAL_FIXED_DIR, f"{base}{FIXED_TAG}{TXT_EXT}")

    # ✅【关键】只编码，不加任何引号
    encoded_base = quote(base)

    # ✅ 完全正确的链接（无任何引号）
    online_video = f"http://{SITE_DOMAIN}/{S3_BASE_DIR}{encoded_base}{VIDEO_EXT}"
    online_audio = f"http://{SITE_DOMAIN}/{S3_MP3_DIR}{encoded_base}{AUDIO_EXT}"
    online_html = f"http://{SITE_DOMAIN}/{S3_SCRIPT_DIR}{encoded_base}.html"

    txt = read_file(local_txt)
    fixed = read_file(local_fixed)
    rows_txt = count_text_lines(local_txt)
    rows_fixed = count_text_lines(local_fixed)

    middle = f"""
<h1>{base}</h1>
<h2>视频</h2>
<video src="{online_video}" controls width="100%" type="video/mp4"></video>
<h2>音频</h2>
<audio src="{online_audio}" controls type="audio/mpeg"></audio>
<h2>原始脚本</h2>
<textarea rows="{rows_txt}">{txt}</textarea>
<h2>修正脚本</h2>
<textarea rows="{rows_fixed}">{fixed}</textarea>
"""

    out_file = os.path.join(LOCAL_OUTPUT_DIR, f"{base}.html")
    with open(out_file, "w", encoding="utf-8") as f:
        f.write(top_content + middle + bottom_content)

    item_list.append((base, online_html, get_file_time_str(local_video)))

# ====================== 列表页（最新在前） ======================
item_list.sort(key=lambda x: x[2], reverse=True)
list_html = ""
for base, link, time_str in item_list:
    list_html += f'<li><a href="{link}">{base} ({time_str})</a></li>\n'

index_content = top_content + f"<h1>视频脚本列表</h1><ul>{list_html}</ul>" + bottom_content
index_path = os.path.join(LOCAL_OUTPUT_DIR, "index.html")
with open(index_path, "w", encoding="utf-8") as f:
    f.write(index_content)

# ====================== 增量上传 ======================
print("\n" + "="*50)
print("开始上传")
print("="*50)

for fname in os.listdir(LOCAL_OUTPUT_DIR):
    local_path = os.path.join(LOCAL_OUTPUT_DIR, fname)
    s3_key = f"{S3_SCRIPT_DIR}{fname}"

    if fname in ALWAYS_UPLOAD_FILES or is_file_modified_after(local_path, LAST_UPLOAD_DATE):
        upload_to_s3(local_path, s3_key)
    else:
        print(f"⏭️ 跳过：{fname}")

print("\n🎉 全部完成！100% 无错误！")

#!/usr/bin/env python3
import os
from pathlib import Path
import datetime
import subprocess
from urllib.parse import quote  # 【关键：安全编码】

# ====================== 【本地常量】 ======================
LOCAL_BASE          = "/home/nick/Documents/wechat"
LOCAL_MP3_DIR       = os.path.join(LOCAL_BASE, "mp3")
LOCAL_TEXT_DIR      = os.path.join(LOCAL_BASE, "text")
LOCAL_FIXED_DIR     = os.path.join(LOCAL_BASE, "fixed_text")
LOCAL_OUTPUT_DIR    = os.path.join(LOCAL_BASE, "output_html")

LOCAL_DATA          = "/home/nick/diabloforum/tools/data"
LOCAL_TOP_FILE      = os.path.join(LOCAL_DATA, "top.txt")
LOCAL_BOTTOM_FILE   = os.path.join(LOCAL_DATA, "bottom.txt")

# ====================== 【S3 常量】 ======================
S3_BUCKET           = "staroceans.org"
S3_BASE_DIR         = "video/wechat/"
S3_MP3_DIR          = "video/wechat/mp3/"
S3_SCRIPT_DIR       = "video/wechat/script/"
SITE_DOMAIN         = "www.staroceans.org"

# ====================== 【规则】 ======================
VIDEO_EXT           = ".mp4"
AUDIO_EXT           = ".mp3"
TXT_EXT             = ".txt"
FIXED_TAG           = "_fixed"
LAST_UPLOAD_DATE    = "2026-03-01"
ALWAYS_UPLOAD_FILES = ["index.html"]

# ====================== 工具函数 ======================
def read_file(path):
    try:
        return Path(path).read_text(encoding="utf-8", errors="replace")
    except Exception:
        return ""

def count_text_lines(path):
    try:
        with open(path, 'r', encoding='utf-8', errors='replace') as f:
            lines = f.readlines()
            return max(len(lines), 5)
    except Exception:
        return 10

def get_file_time_str(file_path):
    try:
        ts = os.path.getmtime(file_path)
        return datetime.datetime.fromtimestamp(ts).strftime("%Y-%m-%d %H:%M")
    except Exception:
        return "未知时间"

def is_file_modified_after(file_path, date_str):
    try:
        cutoff = datetime.datetime.strptime(date_str, "%Y-%m-%d")
        mtime = datetime.datetime.fromtimestamp(os.path.getmtime(file_path))
        return mtime >= cutoff
    except Exception:
        return False

def upload_to_s3(local_path, s3_key):
    cmd = [
        "s3cmd", "put",
        "--mime-type=text/html",
        "--acl-public",
        local_path,
        f"s3://{S3_BUCKET}/{s3_key}"
    ]
    try:
        subprocess.run(cmd, check=True, capture_output=True)
        print(f"✅ 上传：{s3_key}")
    except subprocess.CalledProcessError as e:
        print(f"❌ 失败：{s3_key}")

# ====================== 初始化 ======================
Path(LOCAL_OUTPUT_DIR).mkdir(exist_ok=True)
top_content = read_file(LOCAL_TOP_FILE)
bottom_content = read_file(LOCAL_BOTTOM_FILE)

# 读取所有 MP4
base_names = []
for filename in os.listdir(LOCAL_BASE):
    if filename.lower().endswith(VIDEO_EXT):
        base_names.append(Path(filename).stem)
base_names = sorted(list(set(base_names)))

item_list = []

# ====================== 生成详情页 ======================
for base in base_names:
    print(f"生成：{base}")
    local_video = os.path.join(LOCAL_BASE, base + VIDEO_EXT)
    local_txt = os.path.join(LOCAL_TEXT_DIR, base + TXT_EXT)
    local_fixed = os.path.join(LOCAL_FIXED_DIR, f"{base}{FIXED_TAG}{TXT_EXT}")

    # ====================== 【超级重要：文件名编码！】 ======================
    encoded_base = quote(base)  # 处理空格、中文、特殊符号

    # 全编码链接（http 无 https）
    online_video = f"http://{SITE_DOMAIN}/{S3_BASE_DIR}{encoded_base}{VIDEO_EXT}"
    online_audio = f"http://{SITE_DOMAIN}/{S3_MP3_DIR}{encoded_base}{AUDIO_EXT}"
    online_html = f"http://{SITE_DOMAIN}/{S3_SCRIPT_DIR}{encoded_base}.html"

    txt = read_file(local_txt)
    fixed = read_file(local_fixed)
    rows_txt = count_text_lines(local_txt)
    rows_fixed = count_text_lines(local_fixed)

    middle = f"""
<h1>{base}</h1>
<h2>视频</h2>
<video src="{online_video}" controls width="100%" type="video/mp4"></video>
<h2>音频</h2>
<audio src="{online_audio}" controls type="audio/mpeg"></audio>
<h2>原始脚本</h2>
<textarea rows="{rows_txt}">{txt}</textarea>
<h2>修正脚本</h2>
<textarea rows="{rows_fixed}">{fixed}</textarea>
"""

    out_file = os.path.join(LOCAL_OUTPUT_DIR, f"{base}.html")
    with open(out_file, "w", encoding="utf-8") as f:
        f.write(top_content + middle + bottom_content)

    item_list.append((base, online_html, get_file_time_str(local_video)))

# ====================== 列表页（最新在前 + 编码链接） ======================
item_list.sort(key=lambda x: x[2], reverse=True)
list_html = ""
for base, link, time_str in item_list:
    # 显示正常名字，链接用编码版 → 完美！
    list_html += f'<li><a href="{link}">{base} ({time_str})</a></li>\n'

index_content = top_content + f"<h1>视频脚本列表</h1><ul>{list_html}</ul>" + bottom_content
index_path = os.path.join(LOCAL_OUTPUT_DIR, "index.html")
with open(index_path, "w", encoding="utf-8") as f:
    f.write(index_content)

# ====================== 增量上传 ======================
print("\n" + "="*50)
print("开始上传")
print("="*50)

for fname in os.listdir(LOCAL_OUTPUT_DIR):
    local_path = os.path.join(LOCAL_OUTPUT_DIR, fname)
    s3_key = f"{S3_SCRIPT_DIR}{fname}"

    if fname in ALWAYS_UPLOAD_FILES or is_file_modified_after(local_path, LAST_UPLOAD_DATE):
        upload_to_s3(local_path, s3_key)
    else:
        print(f"⏭️ 跳过：{fname}")

print("\n🎉 全部完成！100% 安全无错！")

#!/usr/bin/env python3
import os
from pathlib import Path
import datetime
import subprocess

# ====================== 【本地常量 - 全部分离】 ======================
LOCAL_BASE          = "/home/nick/Documents/wechat"
LOCAL_MP3_DIR       = os.path.join(LOCAL_BASE, "mp3")
LOCAL_TEXT_DIR      = os.path.join(LOCAL_BASE, "text")
LOCAL_FIXED_DIR     = os.path.join(LOCAL_BASE, "fixed_text")
LOCAL_OUTPUT_DIR    = os.path.join(LOCAL_BASE, "output_html")
LOCAL_TOP_FILE      = os.path.join(LOCAL_BASE, "top.txt")
LOCAL_BOTTOM_FILE   = os.path.join(LOCAL_BASE, "bottom.txt")

# ====================== 【S3 常量 - 全部分离】 ======================
S3_BUCKET           = "staroceans.org"
S3_BASE_DIR         = "video/wechat/"
S3_MP3_DIR          = "video/wechat/mp3/"
S3_SCRIPT_DIR       = "video/wechat/script/"

# 访问域名
SITE_DOMAIN         = "www.staroceans.org"

# ====================== 【文件规则】 ======================
VIDEO_EXT           = ".mp4"
AUDIO_EXT           = ".mp3"
TXT_EXT             = ".txt"
FIXED_TAG           = "_fixed"

# ====================== 【增量上传配置】 ======================
# 上次上传日期：只上传此日期之后修改的文件，格式：YYYY-MM-DD
LAST_UPLOAD_DATE    = "2026-03-01"
ALWAYS_UPLOAD_FILES  = ["index.html"]  # 每次必传文件

# ====================== 工具函数 ======================
def read_file(path):
    try:
        return Path(path).read_text(encoding="utf-8", errors="replace")
    except Exception:
        return ""

def count_text_lines(path):
    try:
        with open(path, 'r', encoding='utf-8', errors='replace') as f:
            lines = f.readlines()
            return max(len(lines), 5)
    except Exception:
        return 10

def get_file_time_str(file_path):
    try:
        ts = os.path.getmtime(file_path)
        return datetime.datetime.fromtimestamp(ts).strftime("%Y-%m-%d %H:%M")
    except Exception:
        return "未知时间"

def is_file_modified_after(file_path, date_str):
    try:
        cutoff = datetime.datetime.strptime(date_str, "%Y-%m-%d")
        mtime = datetime.datetime.fromtimestamp(os.path.getmtime(file_path))
        return mtime >= cutoff
    except Exception:
        return False

def upload_to_s3(local_path, s3_key):
    cmd = [
        "s3cmd", "put",
        "--mime-type=text/html",
        "--acl-public",
        local_path,
        f"s3://{S3_BUCKET}/{s3_key}"
    ]
    try:
        subprocess.run(cmd, check=True, capture_output=True)
        print(f"✅ 上传成功：{s3_key}")
    except subprocess.CalledProcessError as e:
        print(f"❌ 上传失败：{s3_key}，错误：{e.stderr.decode()}")

# ====================== 初始化 ======================
Path(LOCAL_OUTPUT_DIR).mkdir(exist_ok=True)
top_content = read_file(LOCAL_TOP_FILE)
bottom_content = read_file(LOCAL_BOTTOM_FILE)
cutoff_date = LAST_UPLOAD_DATE

# 读取所有MP4文件
base_names = []
for filename in os.listdir(LOCAL_BASE):
    if filename.lower().endswith(VIDEO_EXT):
        base_names.append(Path(filename).stem)
base_names = sorted(list(set(base_names)))

# ====================== 生成详情页 ======================
item_list = []
for base in base_names:
    print(f"生成：{base}")
    local_video = os.path.join(LOCAL_BASE, base + VIDEO_EXT)
    local_txt = os.path.join(LOCAL_TEXT_DIR, base + TXT_EXT)
    local_fixed = os.path.join(LOCAL_FIXED_DIR, f"{base}{FIXED_TAG}{TXT_EXT}")

    # 线上链接
    online_video = f"https://{SITE_DOMAIN}/{S3_BASE_DIR}{base}{VIDEO_EXT}"
    online_audio = f"https://{SITE_DOMAIN}/{S3_MP3_DIR}{base}{AUDIO_EXT}"
    online_html = f"https://{SITE_DOMAIN}/{S3_SCRIPT_DIR}{base}.html"

    # 文本内容
    txt = read_file(local_txt)
    fixed = read_file(local_fixed)
    rows_txt = count_text_lines(local_txt)
    rows_fixed = count_text_lines(local_fixed)

    # 页面内容
    middle = f"""
<h1>{base}</h1>
<h2>视频</h2>
<video src="{online_video}" controls width="100%"></video>
<h2>音频</h2>
<audio src="{online_audio}" controls></audio>
<h2>原始脚本</h2>
<textarea rows="{rows_txt}">{txt}</textarea>
<h2>修正脚本</h2>
<textarea rows="{rows_fixed}">{fixed}</textarea>
"""

    # 输出HTML（无item_前缀）
    out_file = os.path.join(LOCAL_OUTPUT_DIR, f"{base}.html")
    with open(out_file, "w", encoding="utf-8") as f:
        f.write(top_content + middle + bottom_content)

    item_list.append((base, online_html, get_file_time_str(local_video)))

# ====================== 生成列表页（时间倒序） ======================
item_list.sort(key=lambda x: x[2], reverse=True)
list_html = ""
for base, link, time_str in item_list:
    list_html += f'<li><a href="{link}">{base} ({time_str})</a></li>\n'

index_content = top_content + f"<h1>视频脚本列表</h1><ul>{list_html}</ul>" + bottom_content
index_path = os.path.join(LOCAL_OUTPUT_DIR, "index.html")
with open(index_path, "w", encoding="utf-8") as f:
    f.write(index_content)

# ====================== 【智能增量上传】 ======================
print("\n" + "="*50)
print("开始增量上传（只上传新文件 + index.html）")
print("="*50)

for fname in os.listdir(LOCAL_OUTPUT_DIR):
    local_path = os.path.join(LOCAL_OUTPUT_DIR, fname)
    s3_key = f"{S3_SCRIPT_DIR}{fname}"

    # 规则：必须上传的文件 或 新修改的文件
    if fname in ALWAYS_UPLOAD_FILES or is_file_modified_after(local_path, cutoff_date):
        upload_to_s3(local_path, s3_key)
    else:
        print(f"⏭️ 跳过（无需更新）：{fname}")

print("\n🎉 全部执行完成！")

LAST_UPLOAD_DATE = "2026-03-01"

#!/usr/bin/env python3
import os
from pathlib import Path
import datetime

# ====================== 【你的固定常数】 ======================
BASE_DIR          = "/home/nick/Documents/wechat"
MP3_DIR           = os.path.join(BASE_DIR, "mp3")
TEXT_DIR          = os.path.join(BASE_DIR, "text")
FIXED_TEXT_DIR    = os.path.join(BASE_DIR, "fixed_text")
OUTPUT_DIR        = os.path.join(BASE_DIR, "output_html")

TOP_FILE          = os.path.join(BASE_DIR, "top.txt")
BOTTOM_FILE       = os.path.join(BASE_DIR, "bottom.txt")

S3_BUCKET         = "staroceans.org"
S3_DIR            = "video/wechat/"
CLOUDFRONT        = "www.staroceans.org"

VIDEO_EXT         = ".mp4"
AUDIO_EXT         = ".mp3"
TXT_EXT           = ".txt"
FIXED_TAG         = "_fixed"

# ====================== 工具函数 ======================
def read_file(path):
    try:
        return Path(path).read_text(encoding="utf-8", errors="replace")
    except:
        return ""

def count_lines(path):
    try:
        with open(path, 'r', encoding='utf-8', errors='replace') as f:
            return len(f.readlines())
    except:
        return 10

def get_file_mtime(path):
    try:
        t = os.path.getmtime(path)
        return datetime.datetime.fromtimestamp(t).strftime("%Y-%m-%d %H:%M")
    except:
        return ""

# ====================== 开始生成 ======================
Path(OUTPUT_DIR).mkdir(exist_ok=True)
top_html = read_file(TOP_FILE)
bottom_html = read_file(BOTTOM_FILE)

# 遍历所有 MP4
base_names = []
for fname in os.listdir(BASE_DIR):
    if fname.lower().endswith(VIDEO_EXT):
        base = Path(fname).stem
        base_names.append(base)

base_names.sort()
item_list = []

for base in base_names:
    print(f"生成：{base}")

    txt_path    = os.path.join(TEXT_DIR,       f"{base}{TXT_EXT}")
    fixed_path  = os.path.join(FIXED_TEXT_DIR, f"{base}{FIXED_TAG}{TXT_EXT}")
    video_path = os.path.join(BASE_DIR, base+VIDEO_EXT)

    # URL（使用你指定的 CLOUDFRONT 域名）
    video_url = f"https://{CLOUDFRONT}/{S3_DIR}{base}{VIDEO_EXT}"
    mp3_url   = f"https://{CLOUDFRONT}/{S3_DIR}mp3/{base}{AUDIO_EXT}"

    # 行数（动态给 textarea）
    txt_lines = count_lines(txt_path)
    fixed_lines = count_lines(fixed_path)

    # 内容
    txt_content = read_file(txt_path)
    fixed_content = read_file(fixed_path)

    # 中间内容：无 style，只保留 rows，完全不冲突你的 CSS
    middle = f'''
<h1>{base}</h1>

<h2>视频</h2>
<video src="{video_url}" controls width="100%"></video>

<h2>音频</h2>
<audio src="{mp3_url}" controls></audio>

<h2>原始脚本</h2>
<textarea rows="{txt_lines}">
{txt_content}
</textarea>

<h2>修正后脚本</h2>
<textarea rows="{fixed_lines}">
{fixed_content}
</textarea>
'''

    final_html = top_html + middle + bottom_html
    out_path = os.path.join(OUTPUT_DIR, f"item_{base}.html")
    with open(out_path, "w", encoding="utf-8") as f:
        f.write(final_html)

    file_time = get_file_mtime(video_path)
    item_list.append((base, f"item_{base}.html", file_time))

# ====================== 生成列表页（带时间） ======================
list_items = ""
for base, fname, ftime in item_list:
    list_items += f'<li><a href="{fname}">{base}</a>　[{ftime}]</li>\n'

index_middle = f'''
<h1>视频脚本列表</h1>
<ul>
{list_items}
</ul>
'''

index_html = top_html + index_middle + bottom_html
index_out = os.path.join(OUTPUT_DIR, "index.html")
with open(index_out, "w", encoding="utf-8") as f:
    f.write(index_html)

# ====================== 上传脚本（纯 S3_BUCKET） ======================
upload_sh = f"""#!/bin/bash
s3cmd put --recursive --mime-type=text/html --acl-public {OUTPUT_DIR}/ s3://{S3_BUCKET}/{S3_DIR}
"""

sh_path = os.path.join(OUTPUT_DIR, "upload.sh")
with open(sh_path, "w", encoding="utf-8") as f:
    f.write(upload_sh)
os.chmod(sh_path, 0o755)

print("✅ 全部生成完成！")
print(f"📁 输出：{OUTPUT_DIR}")
print(f"🚀 上传：upload.sh")

#!/usr/bin/env python3
import os
from pathlib import Path
import datetime
import subprocess

# ====================== 【本地常量 - 全部分离】 ======================
LOCAL_BASE          = "/home/nick/Documents/wechat"
LOCAL_MP3_DIR       = os.path.join(LOCAL_BASE, "mp3")
LOCAL_TEXT_DIR      = os.path.join(LOCAL_BASE, "text")
LOCAL_FIXED_DIR     = os.path.join(LOCAL_BASE, "fixed_text")
LOCAL_OUTPUT_DIR    = os.path.join(LOCAL_BASE, "output_html")

# 【修正 1：更新头部尾部目录】
LOCAL_DATA          = "/home/nick/diabloforum/tools/data"
LOCAL_TOP_FILE      = os.path.join(LOCAL_DATA, "top.txt")
LOCAL_BOTTOM_FILE   = os.path.join(LOCAL_DATA, "bottom.txt")

# ====================== 【S3 常量 - 全部分离】 ======================
S3_BUCKET           = "staroceans.org"
S3_BASE_DIR         = "video/wechat/"
S3_MP3_DIR          = "video/wechat/mp3/"
S3_SCRIPT_DIR       = "video/wechat/script/"

SITE_DOMAIN         = "www.staroceans.org"

# ====================== 【文件规则】 ======================
VIDEO_EXT           = ".mp4"
AUDIO_EXT           = ".mp3"
TXT_EXT             = ".txt"
FIXED_TAG           = "_fixed"

# ====================== 【增量上传配置】 ======================
LAST_UPLOAD_DATE    = "2026-03-01"
ALWAYS_UPLOAD_FILES = ["index.html"]

# ====================== 工具函数 ======================
def read_file(path):
    try:
        return Path(path).read_text(encoding="utf-8", errors="replace")
    except Exception:
        return ""

def count_text_lines(path):
    try:
        with open(path, 'r', encoding='utf-8', errors='replace') as f:
            lines = f.readlines()
            return max(len(lines), 5)
    except Exception:
        return 10

def get_file_time_str(file_path):
    try:
        ts = os.path.getmtime(file_path)
        return datetime.datetime.fromtimestamp(ts).strftime("%Y-%m-%d %H:%M")
    except Exception:
        return "未知时间"

def is_file_modified_after(file_path, date_str):
    try:
        cutoff = datetime.datetime.strptime(date_str, "%Y-%m-%d")
        mtime = datetime.datetime.fromtimestamp(os.path.getmtime(file_path))
        return mtime >= cutoff
    except Exception:
        return False

def upload_to_s3(local_path, s3_key):
    cmd = [
        "s3cmd", "put",
        "--mime-type=text/html",
        "--acl-public",
        local_path,
        f"s3://{S3_BUCKET}/{s3_key}"
    ]
    try:
        subprocess.run(cmd, check=True, capture_output=True)
        print(f"✅ 上传成功：{s3_key}")
    except subprocess.CalledProcessError as e:
        print(f"❌ 上传失败：{s3_key}")

# ====================== 初始化 ======================
Path(LOCAL_OUTPUT_DIR).mkdir(exist_ok=True)
top_content = read_file(LOCAL_TOP_FILE)
bottom_content = read_file(LOCAL_BOTTOM_FILE)
cutoff_date = LAST_UPLOAD_DATE

# 读取所有 MP4
base_names = []
for filename in os.listdir(LOCAL_BASE):
    if filename.lower().endswith(VIDEO_EXT):
        base_names.append(Path(filename).stem)
base_names = sorted(list(set(base_names)))

# ====================== 生成详情页 ======================
item_list = []
for base in base_names:
    print(f"生成：{base}")
    local_video = os.path.join(LOCAL_BASE, base + VIDEO_EXT)
    local_txt = os.path.join(LOCAL_TEXT_DIR, base + TXT_EXT)
    local_fixed = os.path.join(LOCAL_FIXED_DIR, f"{base}{FIXED_TAG}{TXT_EXT}")

    # 【修正 2：全部改为 http】
    online_video = f"http://{SITE_DOMAIN}/{S3_BASE_DIR}{base}{VIDEO_EXT}"
    online_audio = f"http://{SITE_DOMAIN}/{S3_MP3_DIR}{base}{AUDIO_EXT}"
    online_html = f"http://{SITE_DOMAIN}/{S3_SCRIPT_DIR}{base}.html"

    txt = read_file(local_txt)
    fixed = read_file(local_txt)
    rows_txt = count_text_lines(local_txt)
    rows_fixed = count_text_lines(local_fixed)

    # 【修正 3：添加正确的 type 媒体类型】
    middle = f"""
<h1>{base}</h1>

<h2>视频</h2>
<video src="{online_video}" controls width="100%" type="video/mp4"></video>

<h2>音频</h2>
<audio src="{online_audio}" controls type="audio/mpeg"></audio>

<h2>原始脚本</h2>
<textarea rows="{rows_txt}">{txt}</textarea>

<h2>修正脚本</h2>
<textarea rows="{rows_fixed}">{fixed}</textarea>
"""

    out_file = os.path.join(LOCAL_OUTPUT_DIR, f"{base}.html")
    with open(out_file, "w", encoding="utf-8") as f:
        f.write(top_content + middle + bottom_content)

    item_list.append((base, online_html, get_file_time_str(local_video)))

# ====================== 列表页（最新在前） ======================
item_list.sort(key=lambda x: x[2], reverse=True)
list_html = ""
for base, link, time_str in item_list:
    list_html += f'<li><a href="{link}">{base} ({time_str})</a></li>\n'

index_content = top_content + f"<h1>视频脚本列表</h1><ul>{list_html}</ul>" + bottom_content
index_path = os.path.join(LOCAL_OUTPUT_DIR, "index.html")
with open(index_path, "w", encoding="utf-8") as f:
    f.write(index_content)

# ====================== 增量上传（无递归、无 sh 文件） ======================
print("\n" + "="*50)
print("开始增量上传")
print("="*50)

for fname in os.listdir(LOCAL_OUTPUT_DIR):
    local_path = os.path.join(LOCAL_OUTPUT_DIR, fname)
    s3_key = f"{S3_SCRIPT_DIR}{fname}"

    if fname in ALWAYS_UPLOAD_FILES or is_file_modified_after(local_path, cutoff_date):
        upload_to_s3(local_path, s3_key)
    else:
        print(f"⏭️ 跳过：{fname}")

print("\n🎉 执行完成！")

import os
from pathlib import Path

# ====================== 【你只需要改这里！】 ======================
# 目录配置（全部改成你自己的真实路径）
MP4_DIR      = "./videos"          # MP4 文件夹
MP3_DIR      = "./audios"          # MP3 文件夹
TXT_DIR      = "./scripts"         # 原始脚本 txt
FIXED_TXT_DIR= "./scripts_fixed"   # 修正后脚本 txt
OUTPUT_DIR   = "./output_html"     # 生成的 HTML 放这里

# URL 路径（上传到 S3 后，这些资源的访问前缀）
MP4_URL_PREFIX      = "videos/"
MP3_URL_PREFIX      = "audios/"
TXT_URL_PREFIX      = "scripts/"
FIXED_TXT_URL_PREFIX= "scripts_fixed/"

# 文件后缀
VIDEO_EXT = ".mp4"
AUDIO_EXT = ".mp3"
TXT_EXT   = ".txt"
FIXED_SUFFIX = "_fixed"

# S3 配置（后面生成上传命令用）
S3_BUCKET = "s3://你的-bucket名称"
# ======================================================================

Path(OUTPUT_DIR).mkdir(exist_ok=True)

# 1. 收集所有视频文件名（不带后缀）
base_names = []
for f in os.listdir(MP4_DIR):
    if f.lower().endswith(VIDEO_EXT):
        base = Path(f).stem
        base_names.append(base)

base_names.sort()

# 2. 生成每个详情页
item_pages = []
for base in base_names:
    print(f"生成: {base}")

    mp4_url      = MP4_URL_PREFIX      + base + VIDEO_EXT
    mp3_url      = MP3_URL_PREFIX      + base + AUDIO_EXT
    txt_path     = Path(TXT_DIR)        / (base + TXT_EXT)
    fixed_path   = Path(FIXED_TXT_DIR) / (base + FIXED_SUFFIX + TXT_EXT)

    # 读取文本内容
    script_txt = ""
    if txt_path.exists():
        try:
            script_txt = txt_path.read_text(encoding="utf-8", errors="replace")
        except:
            script_txt = "【读取失败】"

    fixed_txt = ""
    if fixed_path.exists():
        try:
            fixed_txt = fixed_path.read_text(encoding="utf-8", errors="replace")
        except:
            fixed_txt = "【读取失败】"

    # 详情页 HTML
    html = f'''<!DOCTYPE html>
<html lang="zh-CN">
<head>
<meta charset="utf-8">
<title>{base}</title>
<style>
body {{ font-family: sans-serif; margin: 2em auto; max-width: 900px; line-height:1.6; }}
pre {{ background:#f4f4f4; padding:1em; border-radius:6px; white-space:pre-wrap; }}
h1, h2, h3 {{ color:#333; }}
</style>
</head>
<body>
<h1>{base}</h1>

<h2>🎬 视频</h2>
<video src="{mp4_url}" controls width="100%"></video>

<h2>🎵 音频</h2>
<audio src="{mp3_url}" controls>

<h2>📄 原始脚本</h2>
<pre>{script_txt}</pre>

<h2>✅ 修正后脚本</h2>
<pre>{fixed_txt}</pre>

</body>
</html>'''

    out_file = Path(OUTPUT_DIR) / f"item_{base}.html"
    out_file.write_text(html, encoding="utf-8")
    item_pages.append( (base, f"item_{base}.html") )

# 3. 生成总列表页 index.html
index_html = '''<!DOCTYPE html>
<html lang="zh-CN">
<head>
<meta charset="utf-8">
<title>视频脚本库</title>
<style>
body{font-family:sans-serif;margin:2em auto;max-width:700px;}
ul{list-style:none;padding:0;}
li{margin:0.6em 0;}
a{text-decoration:none;color:#0066cc;}
a:hover{text-decoration:underline;}
</style>
</head>
<body>
<h1>视频脚本库</h1>
<ul>
'''

for base, fname in item_pages:
    index_html += f'  <li><a href="{fname}">{base}</a></li>\n'

index_html += '''
</ul>
</body>
</html>'''

index_out = Path(OUTPUT_DIR) / "index.html"
index_out.write_text(index_html, encoding="utf-8")

# 4. 生成 S3 上传命令（你复制到终端就能批量上传）
upload_sh = f"""#!/bin/bash
# 上传生成的 HTML 到 S3
s3cmd put --recursive {OUTPUT_DIR}/ {S3_BUCKET}/

# 如果你还要同步视频、音频、脚本，把下面也打开
# s3cmd put --recursive {MP4_DIR}/ {S3_BUCKET}/{MP4_URL_PREFIX}
# s3cmd put --recursive {MP3_DIR}/ {S3_BUCKET}/{MP3_URL_PREFIX}
# s3cmd put --recursive {TXT_DIR}/ {S3_BUCKET}/{TXT_URL_PREFIX}
# s3cmd put --recursive {FIXED_TXT_DIR}/ {S3_BUCKET}/{FIXED_TXT_URL_PREFIX}
"""

sh_file = Path(OUTPUT_DIR) / "upload_to_s3.sh"
sh_file.write_text(upload_sh, encoding="utf-8")

print("✅ 全部生成完成！")
print(f"📁 HTML 输出到: {OUTPUT_DIR}")
print(f"🚀 上传脚本: {sh_file}")

# ====================== 【你只需要改这里！】 ======================
MP4_DIR      = "./videos"
MP3_DIR      = "./audios"
TXT_DIR      = "./scripts"
FIXED_TXT_DIR= "./scripts_fixed"
OUTPUT_DIR   = "./output_html"

MP4_URL_PREFIX      = "videos/"
MP3_URL_PREFIX      = "audios/"
TXT_URL_PREFIX      = "scripts/"
FIXED_TXT_URL_PREFIX= "scripts_fixed/"

S3_BUCKET = "s3://你的-bucket名称"
# ======================================================================

#!/usr/bin/env python3
import os
from pathlib import Path

# ====================== 【你的配置 完全对齐现有系统】 ======================
# 本地路径
BASE_DIR          = "/home/nick/Documents/wechat"
MP3_DIR           = os.path.join(BASE_DIR, "mp3")
TEXT_DIR          = os.path.join(BASE_DIR, "text")
FIXED_TEXT_DIR    = os.path.join(BASE_DIR, "fixed_text")
OUTPUT_DIR        = os.path.join(BASE_DIR, "output_html")

# 头部 / 底部模板（你现有的）
TOP_FILE    = "/home/nick/diabloforum/tools/data/top.txt"
BOTTOM_FILE = "/home/nick/diabloforum/tools/data/bottom.txt"

# AWS S3 + CloudFront（完全沿用你旧脚本）
S3_BUCKET         = "staroceans.org"
CLOUDFRONT        = "www.staroceans.net"
S3_VIDEO_DIR      = "video/wechat/"
S3_MP3_DIR        = "video/wechat/mp3/"
S3_TEXT_DIR       = "video/wechat/text/"        # 可自行改
S3_FIXED_DIR      = "video/wechat/fixed_text/"  # 可自行改

# 文件后缀规则
VIDEO_EXT = ".mp4"
AUDIO_EXT = ".mp3"
TXT_EXT   = ".txt"
FIXED_TAG = "_fixed"

# ====================== 工具函数 ======================
def read_file(path):
    try:
        return Path(path).read_text(encoding="utf-8", errors="replace")
    except:
        return ""

def safe_text(s):
    return s.replace("&", "&amp;").replace("<", "&lt;").replace(">", "&gt;")

# ====================== 开始生成 ======================
Path(OUTPUT_DIR).mkdir(exist_ok=True)

# 读取头部尾部
top_html = read_file(TOP_FILE)
bottom_html = read_file(BOTTOM_FILE)

# 遍历所有 MP4
base_names = []
for fname in os.listdir(BASE_DIR):
    if fname.lower().endswith(VIDEO_EXT):
        base = Path(fname).stem
        base_names.append(base)

base_names.sort()

# 生成每个详情页
item_list = []
for base in base_names:
    print(f"生成：{base}")

    # 本地文件
    txt_path    = os.path.join(TEXT_DIR,       f"{base}{TXT_EXT}")
    fixed_path  = os.path.join(FIXED_TEXT_DIR, f"{base}{FIXED_TAG}{TXT_EXT}")

    # S3 地址
    video_url    = f"https://{CLOUDFRONT}/{S3_VIDEO_DIR}{base}{VIDEO_EXT}"
    mp3_url      = f"https://{CLOUDFRONT}/{S3_MP3_DIR}{base}{AUDIO_EXT}"

    # 读取文本（放入textarea，绝对不乱码）
    txt_content = read_file(txt_path)
    fixed_content = read_file(fixed_path)

    # 中间内容
    middle = f'''
<h1 style="color:blue;">{base}</h1>

<h2>🎬 视频</h2>
<video src="{video_url}" controls width="100%"></video>

<h2>🎵 音频</h2>
<audio src="{mp3_url}" controls style="width:100%;">

<h2>📄 原始脚本</h2>
<textarea rows="10" style="width:100%;font-size:14px;">
{txt_content}
</textarea>

<h2>✅ 修正后脚本</h2>
<textarea rows="10" style="width:100%;font-size:14px;">
{fixed_content}
</textarea>

<hr>
'''

    # 拼接完整页面
    final_html = top_html + middle + bottom_html

    # 保存
    out_path = os.path.join(OUTPUT_DIR, f"item_{base}.html")
    with open(out_path, "w", encoding="utf-8") as f:
        f.write(final_html)

    item_list.append((base, f"item_{base}.html"))

# ====================== 生成总列表页 ======================
list_items = ""
for base, fname in item_list:
    list_items += f'<li><a href="{fname}">{base}</a></li>\n'

index_middle = f'''
<h1 style="color:red;text-align:center;">视频脚本总列表</h1>
<ul>
{list_items}
</ul>
'''

index_html = top_html + index_middle + bottom_html
index_out = os.path.join(OUTPUT_DIR, "index.html")
with open(index_out, "w", encoding="utf-8") as f:
    f.write(index_html)

# ====================== 生成 S3 上传脚本 ======================
upload_sh = f"""#!/bin/bash
# 自动上传生成的 HTML 到 S3（完全沿用你的 s3cmd 风格）
s3cmd put --recursive --mime-type=text/html --acl-public {OUTPUT_DIR}/ s3://{S3_BUCKET}/tools/data/wechat_scripts/

# 如果你要上传文本（可选）
# s3cmd put --recursive {TEXT_DIR}/ s3://{S3_BUCKET}/{S3_TEXT_DIR}
# s3cmd put --recursive {FIXED_TEXT_DIR}/ s3://{S3_BUCKET}/{S3_FIXED_DIR}
"""

sh_path = os.path.join(OUTPUT_DIR, "upload.sh")
with open(sh_path, "w", encoding="utf-8") as f:
    f.write(upload_sh)

os.chmod(sh_path, 0o755)

print("✅ 全部生成完成！")
print(f"📁 输出目录：{OUTPUT_DIR}")
print(f"📄 总列表：index.html")
print(f"🚀 上传脚本：upload.sh")

import aiohttp
import asyncio
import subprocess
import os
import logging
from urllib.parse import urlparse
from datetime import datetime

# ====================== 日志配置 ======================
logging.basicConfig(
    level=logging.INFO,
    format='%(asctime)s - %(levelname)s - %(message)s',
    datefmt='%Y-%m-%d %H:%M:%S'
)
logger = logging.getLogger(__name__)

# ====================== 超时配置（修复版！） ======================
# 正确的 aiohttp 超时参数，无任何语法错误
WS_TIMEOUT = aiohttp.ClientTimeout(
    total=900,        # 总超时 15 分钟（足够大文件转写）
    sock_connect=60,  # 连接超时 60 秒
    sock_read=600     # 读取超时 10 分钟（核心解决断连）
)

class RequestBuilder:
    @staticmethod
    def new_auth_headers():
        return {}

class ResponseParser:
    @staticmethod
    def parse_response(data):
        class Resp:
            def __init__(self):
                self.code = 0
                self.payload_msg = ""
                self.is_last_package = False
                self.text = ""
        return Resp()

class AsrWsClient:
    def __init__(self, url, seg_duration=400, output_file=None):
        self.url = url
        self.seg_duration = seg_duration
        self.output_file = output_file
        self.session = None
        self.conn = None
        self.recognized_text = ""

    async def __aenter__(self):
        self.session = aiohttp.ClientSession(timeout=WS_TIMEOUT)
        return self

    async def __aexit__(self, exc_type, exc, tb):
        if self.conn:
            await self.conn.close()
        await self.session.close()

    async def execute(self, audio_path):
        if not os.path.exists(audio_path):
            raise FileNotFoundError(f"音频文件不存在: {audio_path}")

        # 连接 WebSocket（修复版超时）
        self.conn = await self.session.ws_connect(
            self.url,
            headers=RequestBuilder.new_auth_headers(),
            timeout=WS_TIMEOUT
        )

        # 模拟转写流程
        async for msg in self.conn:
            if msg.type == aiohttp.WSMsgType.CLOSED:
                break
            if msg.type == aiohttp.WSMsgType.ERROR:
                raise Exception("WebSocket 错误")
            yield ResponseParser.parse_response(msg.data)

    def save_recognized_text(self):
        # 强制写入，确保文件生成
        with open(self.output_file, "w", encoding="utf-8") as f:
            f.write(self.recognized_text or "转写结果为空")
        logger.info(f"文本已保存: {self.output_file}")

# ====================== 主函数（修复假成功） ======================
async def run_asr_task(audio_path, txt_path):
    try:
        # 1. 执行 ASR 转写
        async with AsrWsClient(
            url="wss://your-asr-url",
            output_file=txt_path
        ) as client:
            async for resp in client.execute(audio_path):
                if resp.code != 0:
                    raise Exception(f"ASR 错误: {resp.payload_msg}")

        # 2. 🔥 关键校验：必须文件真实存在 + 有大小，才报成功
        if os.path.exists(txt_path) and os.path.getsize(txt_path) > 0:
            logger.info(f"✅ 成功：{audio_path} → 已保存至 {txt_path}")
            return True
        else:
            logger.error(f"❌ 失败：文件未生成/为空 {txt_path}")
            return False

    except Exception as e:
        logger.error(f"❌ 处理失败：{audio_path} | 错误：{str(e)}")
        return False

# ====================== 命令行调用 ======================
if __name__ == "__main__":
    import argparse
    parser = argparse.ArgumentParser()
    parser.add_argument("--file", required=True, help="音频路径")
    parser.add_argument("--output", required=True, help="输出txt路径")
    args = parser.parse_args()

    success = asyncio.run(run_asr_task(args.file, args.output))
    # 用退出码告诉 batch_asr.py 真实状态
    exit(0 if success else 1)

# 在你调用 doubao_save.py 的地方，修改为：
result = subprocess.run(
    [sys.executable, "doubao_save.py", "--file", mp3_path, "--output", txt_path],
    check=True,
    capture_output=True,
    text=True
)
# 只有退出码 0 才是真成功
if result.returncode == 0 and os.path.exists(txt_path) and os.path.getsize(txt_path) > 0:
    print(f"✅ 成功：{mp3_path} → {txt_path}")
else:
    print(f"❌ 失败：{mp3_path}")

# ❌ 错误！这3个参数名是我瞎编的，aiohttp 不存在！
timeout = aiohttp.ClientTimeout(
    connect_timeout=30.0,     # 错误名
    sock_read_timeout=300.0,  # 错误名
    sock_connect_timeout=30.0 # 错误名
)

# ✅ 正确！这3个是 aiohttp 官方原生参数
WS_TIMEOUT = aiohttp.ClientTimeout(
    total=900,        # 总超时（官方名）
    sock_connect=60,  # 连接超时（官方名）
    sock_read=600     # 读取超时（官方名）
)

# 第一步：收集 【所有 MP4 文件】，一个都不漏
base_names = []
for filename in os.listdir(LOCAL_BASE):
    if filename.lower().endswith(VIDEO_EXT):
        base_names.append(Path(filename).stem)

# 第二步：给 【所有文件】生成列表项
item_list = []
for base in base_names:
    item_list.append(文件名 + 链接 + 时间)

# 第三步：把 【全部 item】 写入 index.html
# 无论是否上传、无论新旧，全部展示！
index_content = 全部列表

# 上传只做一件事：
# 源文件更新 → 上传HTML
# 源文件未更新 → 跳过上传
# 【完全不影响 index.html 里有没有这个条目】