支持实况图(live图)：抖音/小红书 live 提取、相册内图视频混发、Web 端可播放可下载

app.py

@@ -55,6 +55,16 @@ def api_parse():
 
     images = data.get("images") or []
     data["images_proxy"] = [_proxy_url(u, data.get("platform", "")) for u in images]
+
+    # 实况图（live 图）：和 images 下标一一对应，非实况位置是空串
+    lives = list(data.get("lives") or [])
+    lives += [""] * max(0, len(images) - len(lives))
+    data["lives"] = lives
+    data["lives_proxy"] = [
+        _proxy_url(u, data.get("platform", "")) if u else "" for u in lives
+    ]
+    data["live_count"] = sum(1 for u in lives if u)
+
     if data.get("video_url"):
         data["video_proxy"] = _proxy_url(data["video_url"], data.get("platform", ""))
     if data.get("cover"):

big_send.py

@@ -55,29 +55,19 @@ async def _send_video(chat_id, path, caption, duration, width, height,
         )
 
 
-async def _send_photos(chat_id, photos, caption):
-    """发送 URL 图集"""
-    from pyrogram.types import InputMediaPhoto
+async def _send_album(chat_id, specs, caption):
+    """specs = [("photo"|"video", 地址或本地路径)]，图和实况视频可混发"""
+    from pyrogram.types import InputMediaPhoto, InputMediaVideo
     async with _get_client() as app:
         media = []
-        for i, u in enumerate(photos[:10]):
+        for i, (kind, src) in enumerate(specs[:10]):
+            kw = {}
             if i == 0 and caption:
-                media.append(InputMediaPhoto(u, caption=caption, parse_mode=ParseMode.HTML))
+                kw = {"caption": caption, "parse_mode": ParseMode.HTML}
+            if kind == "video":
+                media.append(InputMediaVideo(src, supports_streaming=True, **kw))
             else:
-                media.append(InputMediaPhoto(u))
-        await app.send_media_group(chat_id, media)
-
-
-async def _send_local_photos(chat_id, paths, caption):
-    """发送本地图片文件"""
-    from pyrogram.types import InputMediaPhoto
-    async with _get_client() as app:
-        media = []
-        for i, p in enumerate(paths[:10]):
-            if i == 0 and caption:
-                media.append(InputMediaPhoto(p, caption=caption, parse_mode=ParseMode.HTML))
-            else:
-                media.append(InputMediaPhoto(p))
+                media.append(InputMediaPhoto(src, **kw))
         await app.send_media_group(chat_id, media)
 
 
@@ -87,11 +77,16 @@ def send_big_video(chat_id, path, caption="", duration=0, width=0, height=0,
                             thumbnail, reply_markup))
 
 
+def send_album_mtproto(chat_id, specs, caption=""):
+    """发送混合相册（图片 + 实况视频），通过 mtproto"""
+    asyncio.run(_send_album(chat_id, specs, caption))
+
+
 def send_photos_mtproto(chat_id, photos, caption=""):
     """发送 URL 图集（通过 mtproto）"""
-    asyncio.run(_send_photos(chat_id, photos, caption))
+    send_album_mtproto(chat_id, [("photo", u) for u in photos], caption)
 
 
 def send_local_photos_mtproto(chat_id, paths, caption=""):
     """发送本地图片文件（通过 mtproto）"""
-    asyncio.run(_send_local_photos(chat_id, paths, caption))
+    send_album_mtproto(chat_id, [("photo", p) for p in paths], caption)

bot.py

@@ -20,7 +20,8 @@ import yt_dlp
 from xhs_extract import extract_xhs
 from douyin_extract import extract_douyin
 try:
-    from big_send import send_big_video, send_photos_mtproto, send_local_photos_mtproto
+    from big_send import (send_big_video, send_photos_mtproto,
+                          send_local_photos_mtproto, send_album_mtproto)
 except Exception as _e:   # 未装 pyrogram / 未配 TG_API_ID 时也能跑 Web 前端
     print("big_send 不可用（大文件与 mtproto 兜底关闭）:", _e)
 
@@ -28,6 +29,7 @@ except Exception as _e:   # 未装 pyrogram / 未配 TG_API_ID 时也能跑 Web
         raise RuntimeError("mtproto 未启用：请安装 pyrofork 并配置 TG_API_ID / TG_API_HASH")
 
     send_big_video = send_photos_mtproto = send_local_photos_mtproto = _mtproto_off
+    send_album_mtproto = _mtproto_off
 
 # ========== 反代 ==========
 apihelper.API_URL = "https://bot.nine7.cc.cd/bot{0}/{1}"
@@ -45,6 +47,14 @@ BOT_API_LIMIT = 50 * 1024 * 1024
 MTPROTO_LIMIT = 2000 * 1024 * 1024
 MAX_IMAGES = 30          # 图文最多发多少张（Telegram 每组 10 张，自动分组）
 
+# 实况图（live 图）处理方式：
+#   video = 实况那张发成会动的视频（默认，Telegram 相册里图和视频可以混着发）
+#   both  = 静态图和实况视频都发
+#   off   = 忽略实况，只发静态图
+LIVE_PHOTO_MODE = (os.environ.get("LIVE_PHOTO_MODE") or "video").strip().lower()
+if LIVE_PHOTO_MODE not in ("video", "both", "off"):
+    LIVE_PHOTO_MODE = "video"
+
 # 没有 token 也允许启动（只跑 Web 前端）
 bot = telebot.TeleBot(BOT_TOKEN or "0:disabled", parse_mode="HTML")
 
@@ -444,33 +454,65 @@ def _download_direct(url: str, workdir: str, referer: str = "") -> str:
     return fp
 
 # ========== 图片批量下载（抖音等国内 CDN 需先下载） ==========
-def _download_images(urls: list, workdir: str, headers: dict = None) -> list:
-    """下载图片到本地，返回本地路径列表"""
-    if headers is None:
-        headers = {
-            "User-Agent": DOUYIN_HEADERS["User-Agent"],
-            "Referer": "https://www.douyin.com/",
-        }
-    paths = []
+def _default_img_headers():
+    return {
+        "User-Agent": DOUYIN_HEADERS["User-Agent"],
+        "Referer": "https://www.douyin.com/",
+    }
+
+
+def _download_one(url: str, fp: str, headers: dict) -> str:
+    """下载单个文件，成功返回本地路径，失败返回空字符串"""
+    try:
+        with requests.get(url, headers=headers, stream=True, timeout=60) as r:
+            r.raise_for_status()
+            with open(fp, "wb") as f:
+                for chunk in r.iter_content(1024 * 64):
+                    if chunk:
+                        f.write(chunk)
+        if os.path.exists(fp) and os.path.getsize(fp) > 0:
+            return fp
+    except Exception as e:
+        print(f"download failed {url[:80]}:", e)
+    return ""
+
+
+def _download_gallery(urls: list, workdir: str, headers: dict = None,
+                      lives: list = None):
+    """
+    下载图集到本地。返回 (图片路径列表, live 视频路径列表)，两个列表严格等长、
+    下标对应；某张图下载失败就整项跳过，不会让 live 和图片错位。
+    """
+    headers = headers or _default_img_headers()
+    lives = list(lives or [])
+    lives += [""] * max(0, len(urls) - len(lives))
+
+    paths, live_paths = [], []
     for i, url in enumerate(urls[:MAX_IMAGES]):
-        try:
-            ext = ".jpg"
-            for e in (".webp", ".png", ".jpeg"):
-                if e in url.lower():
-                    ext = e
-                    break
-            fp = os.path.join(workdir, f"img_{i}{ext}")
-            with requests.get(url, headers=headers, stream=True, timeout=30) as r:
-                r.raise_for_status()
-                with open(fp, "wb") as f:
-                    for chunk in r.iter_content(1024 * 64):
-                        if chunk:
-                            f.write(chunk)
-            if os.path.exists(fp) and os.path.getsize(fp) > 0:
-                paths.append(fp)
-        except Exception as e:
-            print(f"download image {i} failed:", e)
-    return paths
+        ext = ".jpg"
+        for e in (".webp", ".png", ".jpeg"):
+            if e in url.lower():
+                ext = e
+                break
+        fp = _download_one(url, os.path.join(workdir, f"img_{i}{ext}"), headers)
+        if not fp:
+            continue
+        lp = ""
+        if LIVE_PHOTO_MODE != "off" and lives[i]:
+            lp = _download_one(lives[i], os.path.join(workdir, f"live_{i}.mp4"),
+                               headers)
+        paths.append(fp)
+        live_paths.append(lp)
+
+    if any(live_paths):
+        print(f"[gallery] {len(paths)} 张，其中实况 "
+              f"{sum(1 for x in live_paths if x)} 个")
+    return paths, live_paths
+
+
+def _download_images(urls: list, workdir: str, headers: dict = None) -> list:
+    """下载图片到本地，返回本地路径列表（不含 live）"""
+    return _download_gallery(urls, workdir, headers)[0]
 
 # ========== 只 remux 不转码 ==========
 def _ensure_h264_aac(path: str) -> str:
@@ -712,31 +754,59 @@ def _img_caption_limit(images):
     return CAPTION_LIMIT if len(images) <= 10 else TEXT_LIMIT - 64
 
 
-def _send_images(chat_id, images, caption, local_files=False, buttons=None):
+def _build_media_specs(images, lives=None):
     """
-    发送图集。Telegram 一组最多 10 张，超过就自动分组发送
+    把图集摊平成 [(类型, 地址)] —— 类型是 "photo" 或 "video"。
+    实况图按 LIVE_PHOTO_MODE 决定发视频、图+视频、还是只发静态图。
+    """
+    lives = list(lives or [])
+    lives += [""] * max(0, len(images) - len(lives))
+    specs = []
+    for i, im in enumerate(images):
+        lv = lives[i] if LIVE_PHOTO_MODE != "off" else ""
+        if lv and LIVE_PHOTO_MODE == "video":
+            specs.append(("video", lv))
+        elif lv:                       # both
+            specs.append(("photo", im))
+            specs.append(("video", lv))
+        else:
+            specs.append(("photo", im))
+    return specs
+
+
+def _send_images(chat_id, images, caption, local_files=False, buttons=None,
+                 lives=None):
+    """
+    发送图集。Telegram 一组最多 10 项，超过就自动分组发送
     （抖音图文经常有 13~35 张，原来直接被截断到 10 张）。
 
+    实况图（live 图）会发成视频，和静态图混在同一个相册里，顺序不变。
+
     文案位置：
-      · 只有一组（≤10 张）—— 文案直接作为图集 caption；
+      · 只有一组（≤10 项）—— 文案直接作为图集 caption；
       · 多组 —— 图先全部发完，文案 / 作者 / 原链接作为最后一条消息单独发，
         免得刷了几十张图之后还要往上翻才能看到文案和原链接。
     """
     if not images:
         return
-    chunks = [images[i:i + 10] for i in range(0, len(images), 10)]
+    specs = _build_media_specs(images, lives)
+    live_n = sum(1 for k, _ in specs if k == "video")
+    chunks = [specs[i:i + 10] for i in range(0, len(specs), 10)]
     inline = len(chunks) == 1 and len(caption or "") <= CAPTION_LIMIT
     for ch in chunks:
         _send_images_chunk(chat_id, ch, caption if inline else "", local_files)
     if not inline:
-        _send_caption_message(chat_id, caption, len(images))
+        _send_caption_message(chat_id, caption, len(images), live_n)
 
 
-def _send_caption_message(chat_id, caption, total=0):
+def _send_caption_message(chat_id, caption, total=0, live_n=0):
     """图集发完后，把文案 / 作者 / 原链接作为最后一条消息发出去。"""
     if not caption:
         return
-    text = f"🖼 共 {total} 张\n{caption}" if total else caption
+    head = f"🖼 共 {total} 张" if total else ""
+    if head and live_n:
+        head += f"（含 {live_n} 个实况 🎞）"
+    text = f"{head}\n{caption}" if head else caption
     text = text[:TEXT_LIMIT]
     try:
         bot.send_message(chat_id, text, parse_mode="HTML",
@@ -750,23 +820,34 @@ def _send_caption_message(chat_id, caption, total=0):
             print("send caption plain text also failed:", e2)
 
 
-def _send_images_chunk(chat_id, images, caption, local_files=False):
+def _make_input_media(kind, src, caption=""):
+    if kind == "video":
+        inp = telebot.types.InputMediaVideo(src, supports_streaming=True)
+    else:
+        inp = telebot.types.InputMediaPhoto(src)
+    if caption:
+        inp.caption = caption
+        inp.parse_mode = "HTML"
+    return inp
+
+
+def _send_images_chunk(chat_id, specs, caption, local_files=False):
+    """specs = [(\"photo\"|\"video\", 地址)]，一次最多 10 项"""
+    if not specs:
+        return
     if local_files:
         # ---- 本地文件：先尝试 Bot API，失败则走 mtproto ----
         files = []
         try:
             media = []
-            for i, fp in enumerate(images):
+            for i, (kind, fp) in enumerate(specs):
                 f = open(fp, "rb")
                 files.append(f)
-                inp = telebot.types.InputMediaPhoto(f)
-                if i == 0 and caption:
-                    inp.caption = caption
-                    inp.parse_mode = "HTML"
-                media.append(inp)
-            bot.send_media_group(chat_id, media, timeout=120)
+                media.append(_make_input_media(kind, f,
+                                               caption if i == 0 else ""))
+            bot.send_media_group(chat_id, media, timeout=180)
         except Exception as e:
-            print("bot api send local images failed, fallback mtproto:", e)
+            print("bot api send local media failed, fallback mtproto:", e)
             # 关闭已打开的句柄
             for f in files:
                 try:
@@ -775,9 +856,9 @@ def _send_images_chunk(chat_id, images, caption, local_files=False):
                     pass
             files.clear()
             try:
-                send_local_photos_mtproto(chat_id, images, caption)
+                send_album_mtproto(chat_id, specs, caption)
             except Exception as e2:
-                print("mtproto send local photos also failed:", e2)
+                print("mtproto send local album also failed:", e2)
         finally:
             for f in files:
                 try:
@@ -787,14 +868,12 @@ def _send_images_chunk(chat_id, images, caption, local_files=False):
     else:
         # ---- URL 列表 ----
         try:
-            media = [telebot.types.InputMediaPhoto(u) for u in images]
-            if caption:
-                media[0].caption = caption
-                media[0].parse_mode = "HTML"
-            bot.send_media_group(chat_id, media, timeout=120)
+            media = [_make_input_media(k, u, caption if i == 0 else "")
+                     for i, (k, u) in enumerate(specs)]
+            bot.send_media_group(chat_id, media, timeout=180)
         except Exception as e:
             print("bot api send_media_group failed, fallback mtproto:", e)
-            send_photos_mtproto(chat_id, images, caption)
+            send_album_mtproto(chat_id, specs, caption)
 
 # ========== 命令 ==========
 @bot.message_handler(commands=["start", "help"])
@@ -989,21 +1068,35 @@ def _process_link(chat_id, from_user, url, original_msg_id):
                         platform=platform,
                         limit=_img_caption_limit(data["images"]),
                     )
-                    try:
-                        _send_images(chat_id, data["images"], cap)
-                    except Exception as e:
-                        # URL 直发失败（CDN 防盗链）时，落地到本地再发
-                        print("xhs url images failed, download locally:", e)
-                        local_paths = _download_images(
+                    lives = data.get("lives") or []
+                    has_live = any(lives) and LIVE_PHOTO_MODE != "off"
+
+                    def _xhs_send_local():
+                        local_paths, local_lives = _download_gallery(
                             data["images"], tmp,
                             headers={
                                 "User-Agent": XHS_HEADERS_UA["User-Agent"],
                                 "Referer": "https://www.xiaohongshu.com/",
                             },
+                            lives=lives,
                         )
                         if not local_paths:
                             raise RuntimeError("小红书图片全部下载失败")
-                        _send_images(chat_id, local_paths, cap, local_files=True)
+                        _send_images(chat_id, local_paths, cap, local_files=True,
+                                     lives=local_lives)
+
+                    if has_live:
+                        # 实况的 mp4 直链 Telegram 服务器基本拉不动（防盗链），
+                        # 直接本地中转，省得发一半失败再整组重发出现重复
+                        _update_status(status, "🎞 正在下载实况图...")
+                        _xhs_send_local()
+                    else:
+                        try:
+                            _send_images(chat_id, data["images"], cap, lives=lives)
+                        except Exception as e:
+                            # URL 直发失败（CDN 防盗链）时，落地到本地再发
+                            print("xhs url images failed, download locally:", e)
+                            _xhs_send_local()
                     try:
                         if status:
                             bot.delete_message(status.chat.id, status.message_id)
@@ -1028,12 +1121,13 @@ def _process_link(chat_id, from_user, url, original_msg_id):
                 if data and data.get("type") == "image" and data.get("images"):
                     # ★ 抖音图片 CDN 需要先下载到本地再发送
                     _update_status(status, "🖼 正在下载图片...")
-                    local_paths = _download_images(
+                    local_paths, local_lives = _download_gallery(
                         data["images"], tmp,
                         headers={
                             "User-Agent": DOUYIN_HEADERS["User-Agent"],
                             "Referer": "https://www.douyin.com/",
                         },
+                        lives=data.get("lives") or [],
                     )
                     if local_paths:
                         _update_status(status, "📤 正在发送图集...")
@@ -1048,7 +1142,8 @@ def _process_link(chat_id, from_user, url, original_msg_id):
                             sender, url, platform=platform,
                             limit=_img_caption_limit(local_paths),
                         )
-                        _send_images(chat_id, local_paths, cap, local_files=True)
+                        _send_images(chat_id, local_paths, cap, local_files=True,
+                                     lives=local_lives)
                     else:
                         raise RuntimeError("抖音图片全部下载失败")
                     try:

douyin_extract.py

@@ -208,17 +208,37 @@ def _pick_image_url(url_list) -> str:
     return cands[0]
 
 
-def _get_images(aweme: dict) -> list:
-    """抖音图文取图：aweme['images'] 是标准字段，image_post_info 为备用"""
+def _pick_live_url(img: dict) -> str:
+    """
+    抖音实况图（live 图）：图文里每一张图都可能自带一个 video 对象，
+    里面是这张图对应的几秒 mp4。没有就是普通静态图。
+    """
+    if not isinstance(img, dict):
+        return ""
+    for key in ("video", "clip_video", "live_photo", "livePhoto"):
+        v = img.get(key)
+        if isinstance(v, dict):
+            u = _get_best_video_url(v)
+            if u:
+                return u
+    return ""
+
+
+def _get_images(aweme: dict):
+    """
+    抖音图文取图：aweme['images'] 是标准字段，image_post_info 为备用。
+    返回 (图片直链列表, live 视频直链列表)，两个列表下标一一对应，
+    非实况图对应的位置是空字符串。
+    """
     if not isinstance(aweme, dict):
-        return []
+        return [], []
 
     img_list = aweme.get("images") or []
     if not img_list:
         ipi = aweme.get("image_post_info") or {}
         img_list = ipi.get("images") or []
 
-    images = []
+    images, lives = [], []
     for img in img_list:
         if not isinstance(img, dict):
             continue
@@ -242,9 +262,11 @@ def _get_images(aweme: dict) -> list:
 
         if picked and picked not in images:
             images.append(picked)
+            lives.append(_pick_live_url(img))
 
-    print(f"[douyin] images: {len(images)} / raw {len(img_list)}")
-    return images
+    print(f"[douyin] images: {len(images)} / raw {len(img_list)}, "
+          f"live: {sum(1 for x in lives if x)}")
+    return images, lives
 
 
 def _clean_music(mus: dict) -> str:
@@ -312,11 +334,13 @@ def extract_douyin(url: str, cookie_header: str = ""):
             music = _clean_music(aweme.get("music") or {})
 
             # ---------- 图文 ----------
-            images = _get_images(aweme)
+            images, lives = _get_images(aweme)
             if images:
                 return {
                     "type": "image",
                     "images": images,
+                    "lives": lives,
+                    "live_count": sum(1 for x in lives if x),
                     "title": title,
                     "tags": tags,
                     "author": author,

static/index.html

@@ -46,6 +46,10 @@ button.ghost{background:var(--card2);border:1px solid var(--line);color:var(--fg
   padding:1px 7px;font-size:11px}
 .cell .dl{position:absolute;right:6px;bottom:6px;background:rgba(0,0,0,.65);border-radius:8px;
   padding:4px 9px;font-size:12px;color:#fff;text-decoration:none}
+.cell video{width:100%;height:100%;object-fit:cover;display:block;border-radius:0;max-height:none}
+.cell .lv{position:absolute;right:6px;top:6px;background:rgba(255,255,255,.92);color:#111;
+  border-radius:6px;padding:1px 6px;font-size:10px;font-weight:700;letter-spacing:.5px}
+.cell.live{cursor:pointer}
 video{width:100%;border-radius:12px;background:#000;max-height:60vh}
 .acts{display:flex;flex-wrap:wrap;gap:8px;margin-top:12px}
 .sp{height:14px}
@@ -132,15 +136,29 @@ function render(d){
   if(d.width && d.height) meta.push(`<span class="pill">${d.width}×${d.height}</span>`);
   if(d.duration) meta.push(`<span class="pill">${fmtDur(d.duration)}</span>`);
   if(d.music) meta.push(`<span class="pill">🎵 ${esc(d.music)}</span>`);
+  if(d.live_count) meta.push(`<span class="pill">🎞 ${d.live_count} 个实况</span>`);
 
   let media = "";
   if(d.type === "image"){
-    media = '<div class="grid">' + d.images_proxy.map((u,i)=>`
-      <div class="cell">
+    const lv = d.lives_proxy || [];
+    media = '<div class="grid">' + d.images_proxy.map((u,i)=>{
+      const v = lv[i] || "";
+      const name = encodeURIComponent((d.title||'img').slice(0,20)+'_'+(i+1));
+      if(v){
+        // 实况图：鼠标移上去 / 点一下就播放，下载给的是 mp4
+        return `<div class="cell live" onmouseenter="playLive(this)" onmouseleave="stopLive(this)" onclick="toggleLive(this)">
+          <video src="${v}" poster="${u}" muted loop playsinline preload="none"></video>
+          <div class="n">${i+1}</div>
+          <div class="lv">实况</div>
+          <a class="dl" href="${v}&name=${name}" download onclick="event.stopPropagation()">下载</a>
+        </div>`;
+      }
+      return `<div class="cell">
         <img src="${u}" loading="lazy">
         <div class="n">${i+1}</div>
-        <a class="dl" href="${u}&name=${encodeURIComponent((d.title||'img').slice(0,20)+'_'+(i+1))}" download>下载</a>
-      </div>`).join("") + "</div>";
+        <a class="dl" href="${u}&name=${name}" download>下载</a>
+      </div>`;
+    }).join("") + "</div>";
   } else {
     const src = d.video_proxy || d.video_url || "";
     media = `<video controls preload="metadata" ${d.cover_proxy?`poster="${d.cover_proxy}"`:""} src="${src}"></video>`;
@@ -150,6 +168,8 @@ function render(d){
     ? `<button class="ghost" onclick="sendTG()">发送到 Telegram</button>` : "";
   const dlAll = d.type === "image"
     ? `<button class="ghost" onclick="dlAll()">下载全部 ${d.count} 张</button>` : "";
+  const dlLive = (d.type === "image" && d.live_count)
+    ? `<button class="ghost" onclick="dlLive()">下载 ${d.live_count} 个实况</button>` : "";
   const dlVideo = d.type === "video"
     ? `<a class="ghost" style="display:inline-block;text-decoration:none;padding:8px 14px;border-radius:10px;background:var(--card2);border:1px solid var(--line);color:var(--fg);font-size:13px"
          href="${(d.video_proxy||d.video_url)}&name=${encodeURIComponent((d.title||'video').slice(0,20))}" download>下载视频</a>` : "";
@@ -161,7 +181,7 @@ function render(d){
     ${d.author ? `<div class="author">👤 ${d.author_url?`<a href="${d.author_url}" target="_blank">${esc(d.author)}</a>`:esc(d.author)}</div>` : ""}
     ${media}
     <div class="acts">
-      ${dlAll}${dlVideo}
+      ${dlAll}${dlLive}${dlVideo}
       <button class="ghost" onclick="copyText()">复制文案</button>
       <button class="ghost" onclick="copyLinks()">复制直链</button>
       ${tgBtn}
@@ -170,6 +190,31 @@ function render(d){
   box.scrollIntoView({behavior:"smooth", block:"nearest"});
 }
 
+function playLive(el){ const v = el.querySelector("video"); if(v) v.play().catch(()=>{}); }
+function stopLive(el){ const v = el.querySelector("video"); if(v){ v.pause(); v.currentTime = 0; } }
+function toggleLive(el){
+  const v = el.querySelector("video"); if(!v) return;
+  v.paused ? v.play().catch(()=>{}) : v.pause();
+}
+
+async function dlSeq(urls, base){
+  for(let i=0;i<urls.length;i++){
+    if(!urls[i]) continue;
+    const a = document.createElement("a");
+    a.href = urls[i] + "&name=" + encodeURIComponent(base+"_"+(i+1));
+    a.download = "";
+    document.body.appendChild(a); a.click(); a.remove();
+    await new Promise(r=>setTimeout(r,350));
+  }
+}
+
+async function dlLive(){
+  const d = LAST; if(!d) return;
+  const list = (d.lives_proxy||[]).filter(Boolean);
+  await dlSeq(list, (d.title||"live").slice(0,20));
+  msg("已触发 " + list.length + " 个实况下载", "info");
+}
+
 async function dlAll(){
   const d = LAST; if(!d) return;
   for(let i=0;i<d.images_proxy.length;i++){
@@ -190,7 +235,8 @@ function copyText(){
 
 function copyLinks(){
   const d = LAST; if(!d) return;
-  const list = d.type === "image" ? d.images : [d.video_url];
+  let list = d.type === "image" ? d.images.slice() : [d.video_url];
+  if(d.type === "image") list = list.concat((d.lives||[]).filter(Boolean));
   navigator.clipboard.writeText(list.join("\n")).then(()=>msg("原始直链已复制","info"));
 }
 

xhs_extract.py

@@ -91,6 +91,37 @@ def _grab_json_object(html: str, anchor: str):
     return None
 
 
+def _norm_url(u) -> str:
+    if isinstance(u, list):
+        u = u[0] if u else ""
+    if not isinstance(u, str) or not u:
+        return ""
+    if u.startswith("//"):
+        u = "https:" + u
+    return u.replace("http://", "https://")
+
+
+def _pick_live_url(img: dict) -> str:
+    """
+    小红书实况图（live 图）：imageList[i].stream 里带这张图对应的短视频。
+    优先 h264 —— Telegram 客户端对 h265/av1 支持很差。
+    """
+    if not isinstance(img, dict):
+        return ""
+    stream = img.get("stream") or img.get("livePhoto") or {}
+    if not isinstance(stream, dict):
+        return ""
+    for quality in ("h264", "h265", "av1", "h266"):
+        for s in (stream.get(quality) or []):
+            if not isinstance(s, dict):
+                continue
+            u = _norm_url(s.get("masterUrl")) or _norm_url(s.get("backupUrls")) \
+                or _norm_url(s.get("backupUrl"))
+            if u:
+                return u
+    return ""
+
+
 def _normalize_xhs_url(url: str) -> str:
     """xhslink.cn / xhs.cn 等 .cn 短链统一走 https，笔记页统一 www.xiaohongshu.com"""
     url = url.strip()
@@ -190,22 +221,21 @@ def extract_xhs(url: str, cookie_header: str = ""):
 
     # 图片
     image_list = note.get("imageList") or note.get("image_list") or []
-    images = []
+    images, lives = [], []
     for img in image_list:
         if isinstance(img, dict):
-            u = (
+            u = _norm_url(
                 img.get("urlDefault")
                 or img.get("url_default")
                 or img.get("url")
                 or img.get("original")
                 or ""
             )
-            if u:
-                if u.startswith("//"):
-                    u = "https:" + u
-                u = u.replace("http://", "https://")
-                if u not in images:
-                    images.append(u)
+            if u and u not in images:
+                images.append(u)
+                lives.append(_pick_live_url(img))
+    if any(lives):
+        print(f"[xhs] images: {len(images)}, live: {sum(1 for x in lives if x)}")
 
     # 视频
     video_url = ""
@@ -253,6 +283,8 @@ def extract_xhs(url: str, cookie_header: str = ""):
         return {
             "type": "image",
             "images": images,
+            "lives": lives,
+            "live_count": sum(1 for x in lives if x),
             "title": title,
             "tags": tags,
             "author": author,