chore: 发布 bili-sync 2.5.0

docs: 文档跟进最新代码变化
chore: 修改 error 判断，考虑 chain (#291 )
2026-05-09 22:15:58 +08:00 · 2025-02-27 14:04:40 +08:00 · 2025-02-27 14:03:47 +08:00 · 2025-02-27 13:39:00 +08:00 · 2025-02-25 20:55:50 +08:00 · 2025-02-24 19:48:07 +08:00
41 changed files with 392 additions and 258 deletions
--- a/.github/workflows/build-binary.yaml
+++ b/.github/workflows/build-binary.yaml
@@ -68,6 +68,8 @@ jobs:
    steps:
      - name: Checkout repo
        uses: actions/checkout@v4
+        with:
+          fetch-depth: 0
      - name: Download Web Build Artifact
        uses: actions/download-artifact@v4
        with:
--- a/.github/workflows/commit-build.yaml
+++ b/.github/workflows/commit-build.yaml
@@ -7,4 +7,5 @@ on:

 jobs:
  build-binary:
+    if: ${{ !startsWith(github.ref, 'refs/tags/') }}
    uses: amtoaer/bili-sync/.github/workflows/build-binary.yaml@main
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -114,9 +114,9 @@ dependencies = [

 [[package]]
 name = "anyhow"
-version = "1.0.95"
+version = "1.0.96"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "34ac096ce696dc2fcabef30516bb13c0a68a11d30131d3df6f04711467681b04"
+checksum = "6b964d184e89d9b6b67dd2715bc8e74cf3107fb2b529990c90cf517326150bf4"
 dependencies = [
 "backtrace",
 ]
@@ -454,7 +454,7 @@ dependencies = [

 [[package]]
 name = "bili_sync"
-version = "2.4.0"
+version = "2.5.0"
 dependencies = [
 "anyhow",
 "arc-swap",
@@ -490,7 +490,7 @@ dependencies = [
 "serde",
 "serde_json",
 "serde_urlencoded",
- "strum",
+ "strum 0.27.1",
 "thiserror 2.0.11",
 "tokio",
 "tokio-util",
@@ -504,7 +504,7 @@ dependencies = [

 [[package]]
 name = "bili_sync_entity"
-version = "2.4.0"
+version = "2.5.0"
 dependencies = [
 "sea-orm",
 "serde_json",
@@ -512,7 +512,7 @@ dependencies = [

 [[package]]
 name = "bili_sync_migration"
-version = "2.4.0"
+version = "2.5.0"
 dependencies = [
 "async-std",
 "sea-orm-migration",
@@ -684,9 +684,9 @@ dependencies = [

 [[package]]
 name = "clap"
-version = "4.5.26"
+version = "4.5.30"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "a8eb5e908ef3a6efbe1ed62520fb7287959888c88485abe072543190ecc66783"
+checksum = "92b7b18d71fad5313a1e320fa9897994228ce274b60faa4d694fe0ea89cd9e6d"
 dependencies = [
 "clap_builder",
 "clap_derive",
@@ -694,9 +694,9 @@ dependencies = [

 [[package]]
 name = "clap_builder"
-version = "4.5.26"
+version = "4.5.30"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "96b01801b5fc6a0a232407abc821660c9c6d25a1cafc0d4f85f29fb8d9afc121"
+checksum = "a35db2071778a7344791a4fb4f95308b5673d219dee3ae348b86642574ecc90c"
 dependencies = [
 "anstream",
 "anstyle",
@@ -706,9 +706,9 @@ dependencies = [

 [[package]]
 name = "clap_derive"
-version = "4.5.24"
+version = "4.5.28"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "54b755194d6389280185988721fffba69495eed5ee9feeee9a599b53db80318c"
+checksum = "bf4ced95c6f4a675af3da73304b9ac4ed991640c36374e4b46795c49e17cf1ed"
 dependencies = [
 "heck 0.5.0",
 "proc-macro2",
@@ -1352,9 +1352,9 @@ dependencies = [

 [[package]]
 name = "handlebars"
-version = "6.3.0"
+version = "6.3.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "3d6b224b95c1e668ac0270325ad563b2eef1469fbbb8959bc7c692c844b813d9"
+checksum = "d752747ddabc4c1a70dd28e72f2e3c218a816773e0d7faf67433f1acfa6cba7c"
 dependencies = [
 "derive_builder",
 "log",
@@ -1957,9 +1957,9 @@ dependencies = [

 [[package]]
 name = "once_cell"
-version = "1.20.2"
+version = "1.20.3"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "1261fe7e33c73b354eab43b1273a57c8f967d0391e80353e51f764ac02cf6775"
+checksum = "945462a4b81e43c4e3ba96bd7b49d834c6f61198356aa858733bc4acf3cbe62e"

 [[package]]
 name = "option-ext"
@@ -2229,9 +2229,9 @@ dependencies = [

 [[package]]
 name = "prost"
-version = "0.13.4"
+version = "0.13.5"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "2c0fef6c4230e4ccf618a35c59d7ede15dea37de8427500f50aff708806e42ec"
+checksum = "2796faa41db3ec313a31f7624d9286acf277b52de526150b7e69f3debf891ee5"
 dependencies = [
 "bytes",
 "prost-derive",
@@ -2239,9 +2239,9 @@ dependencies = [

 [[package]]
 name = "prost-derive"
-version = "0.13.4"
+version = "0.13.5"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "157c5a9d7ea5c2ed2d9fb8f495b64759f7816c7eaea54ba3978f0d63000162e3"
+checksum = "8a56d757972c98b346a9b766e3f02746cde6dd1cd1d1d563472929fdd74bec4d"
 dependencies = [
 "anyhow",
 "itertools",
@@ -2734,9 +2734,9 @@ dependencies = [

 [[package]]
 name = "sea-orm"
-version = "1.1.4"
+version = "1.1.5"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "1a93194430b419da0801f404baf3b986399d6a2a4f43bc79bc96dea83f92ca43"
+checksum = "00733e5418e8ae3758cdb988c3654174e716230cc53ee2cb884207cf86a23029"
 dependencies = [
 "async-stream",
 "async-trait",
@@ -2752,7 +2752,7 @@ dependencies = [
 "serde",
 "serde_json",
 "sqlx",
- "strum",
+ "strum 0.26.3",
 "thiserror 1.0.63",
 "time",
 "tracing",
@@ -2762,9 +2762,9 @@ dependencies = [

 [[package]]
 name = "sea-orm-cli"
-version = "1.1.4"
+version = "1.1.5"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "0e6e0e741bfdf434e6f6aadab156ba4d439e78c9449048698d98fa377871224a"
+checksum = "0646647444d3a0366e30f26ff39f1656cc062b3dbf1f2e3d70cd9dc244b62cf7"
 dependencies = [
 "chrono",
 "clap",
@@ -2779,9 +2779,9 @@ dependencies = [

 [[package]]
 name = "sea-orm-macros"
-version = "1.1.4"
+version = "1.1.5"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "d19e8f22fb474a8a622eb516c46885a080535d8d559386188f525977eaad32b3"
+checksum = "a98408f82fb4875d41ef469a79944a7da29767c7b3e4028e22188a3dd613b10f"
 dependencies = [
 "heck 0.4.1",
 "proc-macro2",
@@ -2793,9 +2793,9 @@ dependencies = [

 [[package]]
 name = "sea-orm-migration"
-version = "1.1.4"
+version = "1.1.5"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "c0bb76ba314552ce15e3a24778cf9c116fc1225fa406e48b0a36e5a3cdbc1e21"
+checksum = "b97ed0bea0d92241722718e239d899c051066a5fb259ced9986b9f60e488e076"
 dependencies = [
 "async-trait",
 "clap",
@@ -2886,18 +2886,18 @@ checksum = "1c107b6f4780854c8b126e228ea8869f4d7b71260f962fefb57b996b8959ba6b"

 [[package]]
 name = "serde"
-version = "1.0.217"
+version = "1.0.218"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "02fc4265df13d6fa1d00ecff087228cc0a2b5f3c0e87e258d8b94a156e984c70"
+checksum = "e8dfc9d19bdbf6d17e22319da49161d5d0108e4188e8b680aef6299eed22df60"
 dependencies = [
 "serde_derive",
 ]

 [[package]]
 name = "serde_derive"
-version = "1.0.217"
+version = "1.0.218"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "5a9bf7cf98d04a2b28aead066b7496853d4779c9cc183c440dbac457641e19a0"
+checksum = "f09503e191f4e797cb8aac08e9a4a4695c5edf6a2e70e376d961ddd5c969f82b"
 dependencies = [
 "proc-macro2",
 "quote",
@@ -2906,9 +2906,9 @@ dependencies = [

 [[package]]
 name = "serde_json"
-version = "1.0.135"
+version = "1.0.139"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "2b0d7ba2887406110130a978386c4e1befb98c674b4fba677954e4db976630d9"
+checksum = "44f86c3acccc9c65b153fe1b85a3be07fe5515274ec9f0653b4a0875731c72a6"
 dependencies = [
 "itoa",
 "memchr",
@@ -2928,9 +2928,9 @@ dependencies = [

 [[package]]
 name = "serde_spanned"
-version = "0.6.7"
+version = "0.6.8"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "eb5b1b31579f3811bf615c144393417496f152e12ac8b7663bf664f4a815306d"
+checksum = "87607cb1398ed59d48732e575a4c28a7a8ebf2454b964fe3f224f2afc07909e1"
 dependencies = [
 "serde",
 ]
@@ -3299,15 +3299,21 @@ name = "strum"
 version = "0.26.3"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "8fec0f0aef304996cf250b31b5a10dee7980c85da9d759361292b8bca5a18f06"
+
+[[package]]
+name = "strum"
+version = "0.27.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "f64def088c51c9510a8579e3c5d67c65349dcf755e5479ad3d010aa6454e2c32"
 dependencies = [
 "strum_macros",
 ]

 [[package]]
 name = "strum_macros"
-version = "0.26.4"
+version = "0.27.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "4c6bee85a5a24955dc440386795aa378cd9cf82acd5f764469152d2270e581be"
+checksum = "c77a8c5abcaf0f9ce05d62342b7d298c346515365c36b673df4ebe3ced01fde8"
 dependencies = [
 "heck 0.5.0",
 "proc-macro2",
@@ -3547,14 +3553,14 @@ dependencies = [

 [[package]]
 name = "toml"
-version = "0.8.19"
+version = "0.8.20"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "a1ed1f98e3fdc28d6d910e6737ae6ab1a93bf1985935a1193e68f93eeb68d24e"
+checksum = "cd87a5cdd6ffab733b2f74bc4fd7ee5fff6634124999ac278c35fc78c6120148"
 dependencies = [
 "serde",
 "serde_spanned",
 "toml_datetime",
- "toml_edit 0.22.22",
+ "toml_edit 0.22.24",
 ]

 [[package]]
@@ -3579,15 +3585,15 @@ dependencies = [

 [[package]]
 name = "toml_edit"
-version = "0.22.22"
+version = "0.22.24"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "4ae48d6208a266e853d946088ed816055e556cc6028c5e8e2b84d9fa5dd7c7f5"
+checksum = "17b4795ff5edd201c7cd6dca065ae59972ce77d1b80fa0a84d94950ece7d1474"
 dependencies = [
 "indexmap",
 "serde",
 "serde_spanned",
 "toml_datetime",
- "winnow 0.6.24",
+ "winnow 0.7.3",
 ]

 [[package]]
@@ -4199,9 +4205,9 @@ dependencies = [

 [[package]]
 name = "winnow"
-version = "0.6.24"
+version = "0.7.3"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "c8d71a593cc5c42ad7876e2c1fda56f314f3754c084128833e64f1345ff8a03a"
+checksum = "0e7f4ea97f6f78012141bcdb6a216b2609f0979ada50b20ca5b52dde2eac2bb1"
 dependencies = [
 "memchr",
 ]
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -4,41 +4,41 @@ default-members = ["crates/bili_sync"]
 resolver = "2"

 [workspace.package]
-version = "2.4.0"
+version = "2.5.0"
 authors = ["amtoaer <amtoaer@gmail.com>"]
 license = "MIT"
 description = "由 Rust & Tokio 驱动的哔哩哔哩同步工具"
-edition = "2021"
+edition = "2024"
 publish = false

 [workspace.dependencies]
 bili_sync_entity = { path = "crates/bili_sync_entity" }
 bili_sync_migration = { path = "crates/bili_sync_migration" }

-anyhow = { version = "1.0.95", features = ["backtrace"] }
+anyhow = { version = "1.0.96", features = ["backtrace"] }
 arc-swap = { version = "1.7.1", features = ["serde"] }
-assert_matches = "1.5"
+assert_matches = "1.5.0"
 async-std = { version = "1.13.0", features = ["attributes", "tokio1"] }
 async-stream = "0.3.6"
-async-trait = "0.1.85"
+async-trait = "0.1.86"
 axum = { version = "0.8.1", features = ["macros"] }
 built = { version = "0.7.7", features = ["git2", "chrono"] }
 chrono = { version = "0.4.39", features = ["serde"] }
-clap = { version = "4.5.26", features = ["env", "string"] }
+clap = { version = "4.5.30", features = ["env", "string"] }
 cookie = "0.18.1"
 cow-utils = "0.1.3"
 dirs = "6.0.0"
 enum_dispatch = "0.3.13"
 float-ord = "0.3.2"
 futures = "0.3.31"
-handlebars = "6.3.0"
+handlebars = "6.3.1"
 hex = "0.4.3"
 leaky-bucket = "1.1.2"
 md5 = "0.7.0"
 memchr = "2.7.4"
-mime_guess = "=2.0.5"
-once_cell = "1.20.2"
-prost = "0.13.4"
+mime_guess = "2.0.5"
+once_cell = "1.20.3"
+prost = "0.13.5"
 quick-xml = { version = "0.37.2", features = ["async-tokio"] }
 rand = "0.8.5"
 regex = "1.11.1"
@@ -53,24 +53,24 @@ reqwest = { version = "0.12.12", features = [
 ], default-features = false }
 rsa = { version = "0.9.7", features = ["sha2"] }
 rust-embed = "8.5.0"
-sea-orm = { version = "1.1.4", features = [
+sea-orm = { version = "1.1.5", features = [
    "macros",
    "runtime-tokio-rustls",
    "sqlx-sqlite",
 ] }
-sea-orm-migration = { version = "1.1.4", features = [] }
-serde = { version = "1.0.217", features = ["derive"] }
-serde_json = "1.0.135"
+sea-orm-migration = { version = "1.1.5", features = [] }
+serde = { version = "1.0.218", features = ["derive"] }
+serde_json = "1.0.139"
 serde_urlencoded = "0.7.1"
-strum = { version = "0.26.3", features = ["derive"] }
+strum = { version = "0.27.1", features = ["derive"] }
 thiserror = "2.0.11"
 tokio = { version = "1.43.0", features = ["full"] }
 tokio-util = { version = "0.7.13", features = ["io", "rt"] }
-toml = "0.8.19"
+toml = "0.8.20"
 tower = "0.5.2"
 tracing = "0.1.41"
 tracing-subscriber = { version = "0.3.19", features = ["chrono"] }
-utoipa = { version = "5", features = ["axum_extras"] }
+utoipa = { version = "5.3.1", features = ["axum_extras"] }
 utoipa-swagger-ui = { version = "9.0.0", features = ["axum", "vendored"] }

 [workspace.metadata.release]
--- a/crates/bili_sync/src/adapter/collection.rs
+++ b/crates/bili_sync/src/adapter/collection.rs
@@ -3,13 +3,14 @@ use std::pin::Pin;

 use anyhow::{Context, Result};
 use bili_sync_entity::*;
+use chrono::Utc;
 use futures::Stream;
+use sea_orm::ActiveValue::Set;
 use sea_orm::entity::prelude::*;
 use sea_orm::sea_query::{OnConflict, SimpleExpr};
-use sea_orm::ActiveValue::Set;
 use sea_orm::{DatabaseConnection, Unchanged};

-use crate::adapter::{VideoSource, VideoSourceEnum, _ActiveModel};
+use crate::adapter::{_ActiveModel, VideoSource, VideoSourceEnum};
 use crate::bilibili::{BiliClient, Collection, CollectionItem, CollectionType, VideoInfo};

 impl VideoSource for collection::Model {
@@ -37,13 +38,19 @@ impl VideoSource for collection::Model {
        })
    }

+    fn should_take(&self, _release_datetime: &chrono::DateTime<Utc>, _latest_row_at: &chrono::DateTime<Utc>) -> bool {
+        // collection（视频合集/视频列表）返回的内容似乎并非严格按照时间排序，并且不同 collection 的排序方式也不同
+        // 为了保证程序正确性，collection 不根据时间提前 break，而是每次都全量拉取
+        true
+    }
+
    fn log_refresh_video_start(&self) {
        info!("开始扫描{}「{}」..", CollectionType::from(self.r#type), self.name);
    }

    fn log_refresh_video_end(&self, count: usize) {
        info!(
-            "扫描{}「{}」完成，获取到 {} 条新视频",
+            "扫描{}「{}」完成，已拉取 {} 条视频",
            CollectionType::from(self.r#type),
            self.name,
            count,
--- a/crates/bili_sync/src/adapter/favorite.rs
+++ b/crates/bili_sync/src/adapter/favorite.rs
@@ -4,12 +4,12 @@ use std::pin::Pin;
 use anyhow::{Context, Result};
 use bili_sync_entity::*;
 use futures::Stream;
+use sea_orm::ActiveValue::Set;
 use sea_orm::entity::prelude::*;
 use sea_orm::sea_query::{OnConflict, SimpleExpr};
-use sea_orm::ActiveValue::Set;
 use sea_orm::{DatabaseConnection, Unchanged};

-use crate::adapter::{VideoSource, VideoSourceEnum, _ActiveModel};
+use crate::adapter::{_ActiveModel, VideoSource, VideoSourceEnum};
 use crate::bilibili::{BiliClient, FavoriteList, VideoInfo};

 impl VideoSource for favorite::Model {
--- a/crates/bili_sync/src/adapter/mod.rs
+++ b/crates/bili_sync/src/adapter/mod.rs
@@ -7,11 +7,12 @@ use std::path::Path;
 use std::pin::Pin;

 use anyhow::Result;
+use chrono::Utc;
 use enum_dispatch::enum_dispatch;
 use futures::Stream;
+use sea_orm::DatabaseConnection;
 use sea_orm::entity::prelude::*;
 use sea_orm::sea_query::SimpleExpr;
-use sea_orm::DatabaseConnection;

 #[rustfmt::skip]
 use bili_sync_entity::collection::Model as Collection;
@@ -52,6 +53,11 @@ pub trait VideoSource {
    /// Box<dyn ActiveModelTrait> 又提示 ActiveModelTrait 没有 object safety，因此手写一个 Enum 静态分发
    fn update_latest_row_at(&self, datetime: DateTime) -> _ActiveModel;

+    // 判断是否应该继续拉取视频
+    fn should_take(&self, release_datetime: &chrono::DateTime<Utc>, latest_row_at: &chrono::DateTime<Utc>) -> bool {
+        release_datetime > latest_row_at
+    }
+
    /// 开始刷新视频
    fn log_refresh_video_start(&self);

@@ -71,7 +77,7 @@ pub trait VideoSource {
    fn log_download_video_end(&self);
 }

-#[derive(Clone, Copy)]
+#[derive(Clone, Copy, Debug)]
 pub enum Args<'a> {
    Favorite { fid: &'a str },
    Collection { collection_item: &'a CollectionItem },
--- a/crates/bili_sync/src/adapter/submission.rs
+++ b/crates/bili_sync/src/adapter/submission.rs
@@ -4,12 +4,12 @@ use std::pin::Pin;
 use anyhow::{Context, Result};
 use bili_sync_entity::*;
 use futures::Stream;
+use sea_orm::ActiveValue::Set;
 use sea_orm::entity::prelude::*;
 use sea_orm::sea_query::{OnConflict, SimpleExpr};
-use sea_orm::ActiveValue::Set;
 use sea_orm::{DatabaseConnection, Unchanged};

-use crate::adapter::{VideoSource, VideoSourceEnum, _ActiveModel};
+use crate::adapter::{_ActiveModel, VideoSource, VideoSourceEnum};
 use crate::bilibili::{BiliClient, Submission, VideoInfo};

 impl VideoSource for submission::Model {
--- a/crates/bili_sync/src/adapter/watch_later.rs
+++ b/crates/bili_sync/src/adapter/watch_later.rs
@@ -4,12 +4,12 @@ use std::pin::Pin;
 use anyhow::{Context, Result};
 use bili_sync_entity::*;
 use futures::Stream;
+use sea_orm::ActiveValue::Set;
 use sea_orm::entity::prelude::*;
 use sea_orm::sea_query::{OnConflict, SimpleExpr};
-use sea_orm::ActiveValue::Set;
 use sea_orm::{DatabaseConnection, Unchanged};

-use crate::adapter::{VideoSource, VideoSourceEnum, _ActiveModel};
+use crate::adapter::{_ActiveModel, VideoSource, VideoSourceEnum};
 use crate::bilibili::{BiliClient, VideoInfo, WatchLater};

 impl VideoSource for watch_later::Model {
--- a/crates/bili_sync/src/api/auth.rs
+++ b/crates/bili_sync/src/api/auth.rs
@@ -3,8 +3,8 @@ use axum::http::HeaderMap;
 use axum::middleware::Next;
 use axum::response::{IntoResponse, Response};
 use reqwest::StatusCode;
-use utoipa::openapi::security::{ApiKey, ApiKeyValue, SecurityScheme};
 use utoipa::Modify;
+use utoipa::openapi::security::{ApiKey, ApiKeyValue, SecurityScheme};

 use crate::api::wrapper::ApiResponse;
 use crate::config::CONFIG;
--- a/crates/bili_sync/src/api/handler.rs
+++ b/crates/bili_sync/src/api/handler.rs
@@ -1,6 +1,6 @@
 use std::sync::Arc;

-use anyhow::{anyhow, Result};
+use anyhow::{Result, anyhow};
 use axum::extract::{Extension, Path, Query};
 use bili_sync_entity::*;
 use bili_sync_migration::{Expr, OnConflict};
--- a/crates/bili_sync/src/api/wrapper.rs
+++ b/crates/bili_sync/src/api/wrapper.rs
@@ -1,6 +1,6 @@
 use anyhow::Error;
-use axum::response::IntoResponse;
 use axum::Json;
+use axum::response::IntoResponse;
 use reqwest::StatusCode;
 use serde::Serialize;
 use utoipa::ToSchema;
--- a/crates/bili_sync/src/bilibili/analyzer.rs
+++ b/crates/bili_sync/src/bilibili/analyzer.rs
@@ -1,7 +1,8 @@
-use anyhow::{bail, Context, Result};
+use anyhow::{Context, Result, bail};
 use serde::{Deserialize, Serialize};

 use crate::bilibili::error::BiliError;
+use crate::config::CONFIG;

 pub struct PageAnalyzer {
    info: serde_json::Value,
@@ -101,24 +102,43 @@ pub enum Stream {
    EpisodeTryMp4(String),
    DashVideo {
        url: String,
+        backup_url: Vec<String>,
        quality: VideoQuality,
        codecs: VideoCodecs,
    },
    DashAudio {
        url: String,
+        backup_url: Vec<String>,
        quality: AudioQuality,
    },
 }

 // 通用的获取流链接的方法，交由 Downloader 使用
 impl Stream {
-    pub fn url(&self) -> &str {
+    pub fn urls(&self) -> Vec<&str> {
        match self {
-            Self::Flv(url) => url,
-            Self::Html5Mp4(url) => url,
-            Self::EpisodeTryMp4(url) => url,
-            Self::DashVideo { url, .. } => url,
-            Self::DashAudio { url, .. } => url,
+            Self::Flv(url) | Self::Html5Mp4(url) | Self::EpisodeTryMp4(url) => vec![url],
+            Self::DashVideo { url, backup_url, .. } | Self::DashAudio { url, backup_url, .. } => {
+                let mut urls = std::iter::once(url.as_str())
+                    .chain(backup_url.iter().map(|s| s.as_str()))
+                    .collect();
+                if !CONFIG.cdn_sorting {
+                    urls
+                } else {
+                    urls.sort_by_key(|u| {
+                        if u.contains("upos-") {
+                            0 // 服务商 cdn
+                        } else if u.contains("cn-") {
+                            1 // 自建 cdn
+                        } else if u.contains("mcdn") {
+                            2 // mcdn
+                        } else {
+                            3 // pcdn 或者其它
+                        }
+                    });
+                    urls
+                }
+            }
        }
    }
 }
@@ -180,10 +200,12 @@ impl PageAnalyzer {
            )]);
        }
        let mut streams: Vec<Stream> = Vec::new();
-        for video in self.info["dash"]["video"]
-            .as_array()
+        for video in self
+            .info
+            .pointer_mut("/dash/video")
+            .and_then(|v| v.as_array_mut())
            .ok_or(BiliError::RiskControlOccurred)?
-            .iter()
+            .iter_mut()
        {
            let (Some(url), Some(quality), Some(codecs)) = (
                video["baseUrl"].as_str(),
@@ -211,12 +233,13 @@ impl PageAnalyzer {
            }
            streams.push(Stream::DashVideo {
                url: url.to_string(),
+                backup_url: serde_json::from_value(video["backupUrl"].take()).unwrap_or_default(),
                quality,
                codecs,
            });
        }
-        if let Some(audios) = self.info["dash"]["audio"].as_array() {
-            for audio in audios.iter() {
+        if let Some(audios) = self.info.pointer_mut("/dash/audio").and_then(|a| a.as_array_mut()) {
+            for audio in audios.iter_mut() {
                let (Some(url), Some(quality)) = (audio["baseUrl"].as_str(), audio["id"].as_u64()) else {
                    continue;
                };
@@ -226,34 +249,44 @@ impl PageAnalyzer {
                }
                streams.push(Stream::DashAudio {
                    url: url.to_string(),
+                    backup_url: serde_json::from_value(audio["backupUrl"].take()).unwrap_or_default(),
                    quality,
                });
            }
        }
-        let flac = &self.info["dash"]["flac"]["audio"];
-        if !(filter_option.no_hires || flac.is_null()) {
-            let (Some(url), Some(quality)) = (flac["baseUrl"].as_str(), flac["id"].as_u64()) else {
-                bail!("invalid flac stream");
-            };
-            let quality = AudioQuality::from_repr(quality as usize).context("invalid flac stream quality")?;
-            if quality >= filter_option.audio_min_quality && quality <= filter_option.audio_max_quality {
-                streams.push(Stream::DashAudio {
-                    url: url.to_string(),
-                    quality,
-                });
+        if !filter_option.no_hires {
+            if let Some(flac) = self.info.pointer_mut("/dash/flac/audio") {
+                let (Some(url), Some(quality)) = (flac["baseUrl"].as_str(), flac["id"].as_u64()) else {
+                    bail!("invalid flac stream");
+                };
+                let quality = AudioQuality::from_repr(quality as usize).context("invalid flac stream quality")?;
+                if quality >= filter_option.audio_min_quality && quality <= filter_option.audio_max_quality {
+                    streams.push(Stream::DashAudio {
+                        url: url.to_string(),
+                        backup_url: serde_json::from_value(flac["backupUrl"].take()).unwrap_or_default(),
+                        quality,
+                    });
+                }
            }
        }
-        let dolby_audio = &self.info["dash"]["dolby"]["audio"][0];
-        if !(filter_option.no_dolby_audio || dolby_audio.is_null()) {
-            let (Some(url), Some(quality)) = (dolby_audio["baseUrl"].as_str(), dolby_audio["id"].as_u64()) else {
-                bail!("invalid dolby audio stream");
-            };
-            let quality = AudioQuality::from_repr(quality as usize).context("invalid dolby audio stream quality")?;
-            if quality >= filter_option.audio_min_quality && quality <= filter_option.audio_max_quality {
-                streams.push(Stream::DashAudio {
-                    url: url.to_string(),
-                    quality,
-                });
+        if !filter_option.no_dolby_audio {
+            if let Some(dolby_audio) = self
+                .info
+                .pointer_mut("/dash/dolby/audio/0")
+                .and_then(|a| a.as_object_mut())
+            {
+                let (Some(url), Some(quality)) = (dolby_audio["baseUrl"].as_str(), dolby_audio["id"].as_u64()) else {
+                    bail!("invalid dolby audio stream");
+                };
+                let quality =
+                    AudioQuality::from_repr(quality as usize).context("invalid dolby audio stream quality")?;
+                if quality >= filter_option.audio_min_quality && quality <= filter_option.audio_max_quality {
+                    streams.push(Stream::DashAudio {
+                        url: url.to_string(),
+                        backup_url: serde_json::from_value(dolby_audio["backupUrl"].take()).unwrap_or_default(),
+                        quality,
+                    });
+                }
            }
        }
        Ok(streams)
@@ -270,32 +303,34 @@ impl PageAnalyzer {
        let (videos, audios): (Vec<Stream>, Vec<Stream>) =
            streams.into_iter().partition(|s| matches!(s, Stream::DashVideo { .. }));
        Ok(BestStream::VideoAudio {
-            video: Iterator::max_by(videos.into_iter(), |a, b| match (a, b) {
-                (
-                    Stream::DashVideo {
-                        quality: a_quality,
-                        codecs: a_codecs,
-                        ..
-                    },
-                    Stream::DashVideo {
-                        quality: b_quality,
-                        codecs: b_codecs,
-                        ..
-                    },
-                ) => {
-                    if a_quality != b_quality {
-                        return a_quality.cmp(b_quality);
-                    };
-                    filter_option
-                        .codecs
-                        .iter()
-                        .position(|c| c == b_codecs)
-                        .cmp(&filter_option.codecs.iter().position(|c| c == a_codecs))
-                }
-                _ => unreachable!(),
-            })
-            .context("no video stream found")?,
-            audio: Iterator::max_by(audios.into_iter(), |a, b| match (a, b) {
+            video: videos
+                .into_iter()
+                .max_by(|a, b| match (a, b) {
+                    (
+                        Stream::DashVideo {
+                            quality: a_quality,
+                            codecs: a_codecs,
+                            ..
+                        },
+                        Stream::DashVideo {
+                            quality: b_quality,
+                            codecs: b_codecs,
+                            ..
+                        },
+                    ) => {
+                        if a_quality != b_quality {
+                            return a_quality.cmp(b_quality);
+                        };
+                        filter_option
+                            .codecs
+                            .iter()
+                            .position(|c| c == b_codecs)
+                            .cmp(&filter_option.codecs.iter().position(|c| c == a_codecs))
+                    }
+                    _ => unreachable!(),
+                })
+                .context("no video stream found")?,
+            audio: audios.into_iter().max_by(|a, b| match (a, b) {
                (Stream::DashAudio { quality: a_quality, .. }, Stream::DashAudio { quality: b_quality, .. }) => {
                    a_quality.cmp(b_quality)
                }
@@ -313,27 +348,31 @@ mod tests {

    #[test]
    fn test_quality_order() {
-        assert!([
-            VideoQuality::Quality360p,
-            VideoQuality::Quality480p,
-            VideoQuality::Quality720p,
-            VideoQuality::Quality1080p,
-            VideoQuality::Quality1080pPLUS,
-            VideoQuality::Quality1080p60,
-            VideoQuality::Quality4k,
-            VideoQuality::QualityHdr,
-            VideoQuality::QualityDolby,
-            VideoQuality::Quality8k
-        ]
-        .is_sorted());
-        assert!([
-            AudioQuality::Quality64k,
-            AudioQuality::Quality132k,
-            AudioQuality::Quality192k,
-            AudioQuality::QualityDolby,
-            AudioQuality::QualityHiRES,
-        ]
-        .is_sorted());
+        assert!(
+            [
+                VideoQuality::Quality360p,
+                VideoQuality::Quality480p,
+                VideoQuality::Quality720p,
+                VideoQuality::Quality1080p,
+                VideoQuality::Quality1080pPLUS,
+                VideoQuality::Quality1080p60,
+                VideoQuality::Quality4k,
+                VideoQuality::QualityHdr,
+                VideoQuality::QualityDolby,
+                VideoQuality::Quality8k
+            ]
+            .is_sorted()
+        );
+        assert!(
+            [
+                AudioQuality::Quality64k,
+                AudioQuality::Quality132k,
+                AudioQuality::Quality192k,
+                AudioQuality::QualityDolby,
+                AudioQuality::QualityHiRES,
+            ]
+            .is_sorted()
+        );
    }

    #[ignore = "only for manual test"]
@@ -385,4 +424,27 @@ mod tests {
            }
        }
    }
+
+    #[test]
+    fn test_url_sort() {
+        let stream = Stream::DashVideo {
+            url: "https://xy116x207x155x163xy240ey95dy1010y700yy8dxy.mcdn.bilivideo.cn:4483".to_owned(),
+            backup_url: vec![
+                "https://upos-sz-mirrorcos.bilivideo.com".to_owned(),
+                "https://cn-tj-cu-01-11.bilivideo.com".to_owned(),
+                "https://xxx.v1d.szbdys.com".to_owned(),
+            ],
+            quality: VideoQuality::Quality1080p,
+            codecs: VideoCodecs::AVC,
+        };
+        assert_eq!(
+            stream.urls(),
+            vec![
+                "https://upos-sz-mirrorcos.bilivideo.com",
+                "https://cn-tj-cu-01-11.bilivideo.com",
+                "https://xy116x207x155x163xy240ey95dy1010y700yy8dxy.mcdn.bilivideo.cn:4483",
+                "https://xxx.v1d.szbdys.com"
+            ]
+        );
+    }
 }
--- a/crates/bili_sync/src/bilibili/client.rs
+++ b/crates/bili_sync/src/bilibili/client.rs
@@ -3,11 +3,11 @@ use std::time::Duration;

 use anyhow::{Context, Result};
 use leaky_bucket::RateLimiter;
-use reqwest::{header, Method};
+use reqwest::{Method, header};

-use crate::bilibili::credential::WbiImg;
 use crate::bilibili::Credential;
-use crate::config::{RateLimit, CONFIG};
+use crate::bilibili::credential::WbiImg;
+use crate::config::{CONFIG, RateLimit};

 // 一个对 reqwest::Client 的简单封装，用于 Bilibili 请求
 #[derive(Clone)]
--- a/crates/bili_sync/src/bilibili/collection.rs
+++ b/crates/bili_sync/src/bilibili/collection.rs
@@ -1,6 +1,6 @@
 use std::fmt::{Display, Formatter};

-use anyhow::{anyhow, Context, Result};
+use anyhow::{Context, Result, anyhow};
 use async_stream::try_stream;
 use futures::Stream;
 use reqwest::Method;
@@ -8,7 +8,7 @@ use serde::Deserialize;
 use serde_json::Value;

 use crate::bilibili::credential::encoded_query;
-use crate::bilibili::{BiliClient, Validate, VideoInfo, MIXIN_KEY};
+use crate::bilibili::{BiliClient, MIXIN_KEY, Validate, VideoInfo};

 #[derive(PartialEq, Eq, Hash, Clone, Debug)]
 pub enum CollectionType {
--- a/crates/bili_sync/src/bilibili/credential.rs
+++ b/crates/bili_sync/src/bilibili/credential.rs
@@ -1,11 +1,11 @@
 use std::borrow::Cow;
 use std::collections::HashSet;

-use anyhow::{bail, ensure, Context, Result};
+use anyhow::{Context, Result, bail, ensure};
 use cookie::Cookie;
 use cow_utils::CowUtils;
 use regex::Regex;
-use reqwest::{header, Method};
+use reqwest::{Method, header};
 use rsa::pkcs8::DecodePublicKey;
 use rsa::sha2::Sha256;
 use rsa::{Oaep, RsaPublicKey};
--- a/crates/bili_sync/src/bilibili/danmaku/canvas/lane.rs
+++ b/crates/bili_sync/src/bilibili/danmaku/canvas/lane.rs
@@ -1,5 +1,5 @@
-use crate::bilibili::danmaku::canvas::CanvasConfig;
 use crate::bilibili::danmaku::Danmu;
+use crate::bilibili::danmaku::canvas::CanvasConfig;

 pub enum Collision {
    // 会越来越远
--- a/crates/bili_sync/src/bilibili/danmaku/canvas/mod.rs
+++ b/crates/bili_sync/src/bilibili/danmaku/canvas/mod.rs
@@ -5,10 +5,10 @@ use anyhow::Result;
 use float_ord::FloatOrd;
 use lane::Lane;

+use crate::bilibili::PageInfo;
 use crate::bilibili::danmaku::canvas::lane::Collision;
 use crate::bilibili::danmaku::danmu::DanmuType;
 use crate::bilibili::danmaku::{Danmu, DrawEffect, Drawable};
-use crate::bilibili::PageInfo;

 #[derive(Debug, serde::Deserialize, serde::Serialize)]
 pub struct DanmakuOption {
--- a/crates/bili_sync/src/bilibili/danmaku/danmu.rs
+++ b/crates/bili_sync/src/bilibili/danmaku/danmu.rs
@@ -1,5 +1,5 @@
 //! 一个弹幕实例，但是没有位置信息
-use anyhow::{bail, Result};
+use anyhow::{Result, bail};

 use crate::bilibili::danmaku::canvas::CanvasConfig;

--- a/crates/bili_sync/src/bilibili/danmaku/writer.rs
+++ b/crates/bili_sync/src/bilibili/danmaku/writer.rs
@@ -3,9 +3,9 @@ use std::path::PathBuf;
 use anyhow::Result;
 use tokio::fs::{self, File};

+use crate::bilibili::PageInfo;
 use crate::bilibili::danmaku::canvas::CanvasConfig;
 use crate::bilibili::danmaku::{AssWriter, Danmu};
-use crate::bilibili::PageInfo;
 use crate::config::CONFIG;

 pub struct DanmakuWriter<'a> {
--- a/crates/bili_sync/src/bilibili/favorite_list.rs
+++ b/crates/bili_sync/src/bilibili/favorite_list.rs
@@ -1,4 +1,4 @@
-use anyhow::{anyhow, Context, Result};
+use anyhow::{Context, Result, anyhow};
 use async_stream::try_stream;
 use futures::Stream;
 use serde_json::Value;
--- a/crates/bili_sync/src/bilibili/mod.rs
+++ b/crates/bili_sync/src/bilibili/mod.rs
@@ -1,7 +1,7 @@
 use std::sync::Arc;

 pub use analyzer::{BestStream, FilterOption};
-use anyhow::{bail, ensure, Result};
+use anyhow::{Result, bail, ensure};
 use arc_swap::ArcSwapOption;
 use chrono::serde::ts_seconds;
 use chrono::{DateTime, Utc};
--- a/crates/bili_sync/src/bilibili/submission.rs
+++ b/crates/bili_sync/src/bilibili/submission.rs
@@ -1,4 +1,4 @@
-use anyhow::{anyhow, Context, Result};
+use anyhow::{Context, Result, anyhow};
 use arc_swap::access::Access;
 use async_stream::try_stream;
 use futures::Stream;
@@ -7,7 +7,7 @@ use serde_json::Value;

 use crate::bilibili::credential::encoded_query;
 use crate::bilibili::favorite_list::Upper;
-use crate::bilibili::{BiliClient, Validate, VideoInfo, MIXIN_KEY};
+use crate::bilibili::{BiliClient, MIXIN_KEY, Validate, VideoInfo};
 pub struct Submission<'a> {
    client: &'a BiliClient,
    upper_id: String,
--- a/crates/bili_sync/src/bilibili/video.rs
+++ b/crates/bili_sync/src/bilibili/video.rs
@@ -1,6 +1,6 @@
-use anyhow::{ensure, Result};
-use futures::stream::FuturesUnordered;
+use anyhow::{Result, ensure};
 use futures::TryStreamExt;
+use futures::stream::FuturesUnordered;
 use prost::Message;
 use reqwest::Method;

@@ -9,7 +9,7 @@ use crate::bilibili::client::BiliClient;
 use crate::bilibili::credential::encoded_query;
 use crate::bilibili::danmaku::{DanmakuElem, DanmakuWriter, DmSegMobileReply};
 use crate::bilibili::subtitle::{SubTitle, SubTitleBody, SubTitleInfo, SubTitlesInfo};
-use crate::bilibili::{Validate, VideoInfo, MIXIN_KEY};
+use crate::bilibili::{MIXIN_KEY, Validate, VideoInfo};

 static MASK_CODE: u64 = 2251799813685247;
 static XOR_CODE: u64 = 23442827791579;
--- a/crates/bili_sync/src/bilibili/watch_later.rs
+++ b/crates/bili_sync/src/bilibili/watch_later.rs
@@ -1,4 +1,4 @@
-use anyhow::{anyhow, Context, Result};
+use anyhow::{Context, Result, anyhow};
 use async_stream::try_stream;
 use futures::Stream;
 use serde_json::Value;
--- a/crates/bili_sync/src/config/clap.rs
+++ b/crates/bili_sync/src/config/clap.rs
@@ -1,7 +1,9 @@
+use std::borrow::Cow;
+
 use clap::Parser;

 #[derive(Parser)]
-#[command(name = "Bili-Sync", version = version(), about, long_about = None)]
+#[command(name = "Bili-Sync", version = detail_version(), about, long_about = None)]
 pub struct Args {
    #[arg(short, long, env = "SCAN_ONLY")]
    pub scan_only: bool,
@@ -14,19 +16,22 @@ mod built_info {
    include!(concat!(env!("OUT_DIR"), "/built.rs"));
 }

-fn version() -> String {
-    let version = if let (Some(git_version), Some(git_dirty)) = (built_info::GIT_VERSION, built_info::GIT_DIRTY) {
-        format!("{}{}", git_version, if git_dirty { "-dirty" } else { "" })
+pub fn version() -> Cow<'static, str> {
+    if let (Some(git_version), Some(git_dirty)) = (built_info::GIT_VERSION, built_info::GIT_DIRTY) {
+        Cow::Owned(format!("{}{}", git_version, if git_dirty { "-dirty" } else { "" }))
    } else {
-        built_info::PKG_VERSION.to_owned()
-    };
+        Cow::Borrowed(built_info::PKG_VERSION)
+    }
+}
+
+fn detail_version() -> String {
    format!(
        "{}
 Architecture: {}-{}
 Author: {}
 Built Time: {}
 Rustc Version: {}",
-        version,
+        version(),
        built_info::CFG_OS,
        built_info::CFG_TARGET_ARCH,
        built_info::PKG_AUTHORS,
--- a/crates/bili_sync/src/config/global.rs
+++ b/crates/bili_sync/src/config/global.rs
@@ -4,9 +4,9 @@ use clap::Parser;
 use handlebars::handlebars_helper;
 use once_cell::sync::Lazy;

+use crate::config::Config;
 use crate::config::clap::Args;
 use crate::config::item::PathSafeTemplate;
-use crate::config::Config;

 /// 全局的 CONFIG，可以从中读取配置信息
 pub static CONFIG: Lazy<Config> = Lazy::new(load_config);
@@ -40,6 +40,7 @@ pub static CONFIG_DIR: Lazy<PathBuf> =

 #[cfg(not(test))]
 fn load_config() -> Config {
+    info!("开始加载配置文件..");
    let config = Config::load().unwrap_or_else(|err| {
        if err
            .downcast_ref::<std::io::Error>()
@@ -47,7 +48,7 @@ fn load_config() -> Config {
        {
            panic!("加载配置文件失败，错误为： {err}");
        }
-        warn!("配置文件不存在，使用默认配置...");
+        warn!("配置文件不存在，使用默认配置..");
        Config::default()
    });
    info!("配置文件加载完毕，覆盖刷新原有配置");
@@ -80,6 +81,7 @@ fn load_config() -> Config {
    };
    Config {
        credential: arc_swap::ArcSwapOption::from(credential),
+        cdn_sorting: true,
        ..Default::default()
    }
 }
--- a/crates/bili_sync/src/config/item.rs
+++ b/crates/bili_sync/src/config/item.rs
@@ -114,7 +114,7 @@ where
                            _ => {
                                return Err(serde::de::Error::custom(
                                    "invalid collection type, should be series or season",
-                                ))
+                                ));
                            }
                        };
                        CollectionItem {
@@ -126,7 +126,7 @@ where
                    _ => {
                        return Err(serde::de::Error::custom(
                            "invalid collection key, should be series:mid:sid or season:mid:sid",
-                        ))
+                        ));
                    }
                };
                collection_list.insert(collection_item, value);
--- a/crates/bili_sync/src/config/mod.rs
+++ b/crates/bili_sync/src/config/mod.rs
@@ -12,9 +12,11 @@ mod clap;
 mod global;
 mod item;

+use crate::adapter::Args;
 use crate::bilibili::{CollectionItem, Credential, DanmakuOption, FilterOption};
+pub use crate::config::clap::version;
 pub use crate::config::global::{ARGS, CONFIG, CONFIG_DIR, TEMPLATE};
-use crate::config::item::{deserialize_collection_list, serialize_collection_list, ConcurrentLimit};
+use crate::config::item::{ConcurrentLimit, deserialize_collection_list, serialize_collection_list};
 pub use crate::config::item::{NFOTimeType, PathSafeTemplate, RateLimit, WatchLaterConfig};

 fn default_time_format() -> String {
@@ -67,6 +69,8 @@ pub struct Config {
    pub concurrent_limit: ConcurrentLimit,
    #[serde(default = "default_time_format")]
    pub time_format: String,
+    #[serde(default)]
+    pub cdn_sorting: bool,
 }

 impl Default for Config {
@@ -88,6 +92,7 @@ impl Default for Config {
            nfo_time_type: NFOTimeType::FavTime,
            concurrent_limit: ConcurrentLimit::default(),
            time_format: default_time_format(),
+            cdn_sorting: false,
        }
    }
 }
@@ -107,23 +112,35 @@ impl Config {
        Ok(toml::from_str(&config_content)?)
    }

+    pub fn as_video_sources(&self) -> Vec<(Args<'_>, &PathBuf)> {
+        let mut params = Vec::new();
+        self.favorite_list
+            .iter()
+            .for_each(|(fid, path)| params.push((Args::Favorite { fid }, path)));
+        self.collection_list
+            .iter()
+            .for_each(|(collection_item, path)| params.push((Args::Collection { collection_item }, path)));
+        if self.watch_later.enabled {
+            params.push((Args::WatchLater, &self.watch_later.path));
+        }
+        self.submission_list
+            .iter()
+            .for_each(|(upper_id, path)| params.push((Args::Submission { upper_id }, path)));
+        params
+    }
+
    #[cfg(not(test))]
    pub fn check(&self) {
        let mut ok = true;
-        if self.favorite_list.is_empty() && self.collection_list.is_empty() && !self.watch_later.enabled {
+        let video_sources = self.as_video_sources();
+        if video_sources.is_empty() {
            ok = false;
            error!("没有配置任何需要扫描的内容，程序空转没有意义");
        }
-        if self.watch_later.enabled && !self.watch_later.path.is_absolute() {
-            error!(
-                "稍后再看保存的路径应为绝对路径，检测到：{}",
-                self.watch_later.path.display()
-            );
-        }
-        for path in self.favorite_list.values() {
+        for (args, path) in video_sources {
            if !path.is_absolute() {
                ok = false;
-                error!("收藏夹保存的路径应为绝对路径，检测到: {}", path.display());
+                error!("{:?} 保存的路径应为绝对路径，检测到: {}", args, path.display());
            }
        }
        if !self.upper_path.is_absolute() {
--- a/crates/bili_sync/src/downloader.rs
+++ b/crates/bili_sync/src/downloader.rs
@@ -1,7 +1,7 @@
 use core::str;
 use std::path::Path;

-use anyhow::{bail, ensure, Result};
+use anyhow::{Context, Result, bail, ensure};
 use futures::TryStreamExt;
 use reqwest::Method;
 use tokio::fs::{self, File};
@@ -45,6 +45,22 @@ impl Downloader {
        Ok(())
    }

+    pub async fn fetch_with_fallback(&self, urls: &[&str], path: &Path) -> Result<()> {
+        if urls.is_empty() {
+            bail!("no urls provided");
+        }
+        let mut res = Ok(());
+        for url in urls {
+            match self.fetch(url, path).await {
+                Ok(_) => return Ok(()),
+                Err(err) => {
+                    res = Err(err);
+                }
+            }
+        }
+        res.with_context(|| format!("failed to download from {:?}", urls))
+    }
+
    pub async fn merge(&self, video_path: &Path, audio_path: &Path, output_path: &Path) -> Result<()> {
        let output = tokio::process::Command::new("ffmpeg")
            .args([
--- a/crates/bili_sync/src/error.rs
+++ b/crates/bili_sync/src/error.rs
@@ -26,21 +26,27 @@ impl From<Result<ExecutionStatus>> for ExecutionStatus {
        match res {
            Ok(status) => status,
            Err(err) => {
-                if let Some(error) = err.downcast_ref::<io::Error>() {
-                    let error_kind = error.kind();
-                    if error_kind == io::ErrorKind::PermissionDenied
-                        || (error_kind == io::ErrorKind::Other
-                            && error.get_ref().is_some_and(|e| {
+                for cause in err.chain() {
+                    if let Some(io_err) = cause.downcast_ref::<io::Error>() {
+                        // 权限错误
+                        if io_err.kind() == io::ErrorKind::PermissionDenied {
+                            return ExecutionStatus::Ignored(err);
+                        }
+                        // 使用 io::Error 包裹的 reqwest::Error
+                        if io_err.kind() == io::ErrorKind::Other
+                            && io_err.get_ref().is_some_and(|e| {
                                e.downcast_ref::<reqwest::Error>()
-                                    .is_some_and(|e| e.is_decode() || e.is_body() || e.is_timeout())
-                            }))
-                    {
-                        return ExecutionStatus::Ignored(err);
+                                    .is_some_and(|e| is_ignored_reqwest_error(e))
+                            })
+                        {
+                            return ExecutionStatus::Ignored(err);
+                        }
                    }
-                }
-                if let Some(error) = err.downcast_ref::<reqwest::Error>() {
-                    if error.is_decode() || error.is_body() || error.is_timeout() {
-                        return ExecutionStatus::Ignored(err);
+                    // 未包裹的 reqwest::Error
+                    if let Some(error) = cause.downcast_ref::<reqwest::Error>() {
+                        if is_ignored_reqwest_error(error) {
+                            return ExecutionStatus::Ignored(err);
+                        }
                    }
                }
                ExecutionStatus::Failed(err)
@@ -48,3 +54,7 @@ impl From<Result<ExecutionStatus>> for ExecutionStatus {
        }
    }
 }
+
+fn is_ignored_reqwest_error(err: &reqwest::Error) -> bool {
+    err.is_decode() || err.is_body() || err.is_timeout()
+}
--- a/crates/bili_sync/src/main.rs
+++ b/crates/bili_sync/src/main.rs
@@ -59,10 +59,11 @@ fn spawn_task(
    });
 }

-/// 初始化日志系统，加载命令行参数和配置文件
+/// 初始化日志系统，打印欢迎信息，加载配置文件
 fn init() {
-    Lazy::force(&ARGS);
    init_logger(&ARGS.log_level);
+    info!("欢迎使用 Bili-Sync，当前程序版本：{}", config::version());
+    info!("项目地址：https://github.com/amtoaer/bili-sync");
    Lazy::force(&CONFIG);
 }

--- a/crates/bili_sync/src/task/http_server.rs
+++ b/crates/bili_sync/src/task/http_server.rs
@@ -2,10 +2,10 @@ use std::sync::Arc;

 use anyhow::{Context, Result};
 use axum::extract::Request;
-use axum::http::{header, Uri};
+use axum::http::{Uri, header};
 use axum::response::IntoResponse;
 use axum::routing::{get, post};
-use axum::{middleware, Extension, Router, ServiceExt};
+use axum::{Extension, Router, ServiceExt, middleware};
 use reqwest::StatusCode;
 use rust_embed::Embed;
 use sea_orm::DatabaseConnection;
@@ -13,7 +13,7 @@ use utoipa::OpenApi;
 use utoipa_swagger_ui::{Config, SwaggerUi};

 use crate::api::auth;
-use crate::api::handler::{get_video, get_video_sources, get_videos, reset_video, ApiDoc};
+use crate::api::handler::{ApiDoc, get_video, get_video_sources, get_videos, reset_video};
 use crate::config::CONFIG;

 #[derive(Embed)]
@@ -42,7 +42,7 @@ pub async fn http_server(database_connection: Arc<DatabaseConnection>) -> Result
    let listener = tokio::net::TcpListener::bind(&CONFIG.bind_address)
        .await
        .context("bind address failed")?;
-    info!("开始监听 http 服务: http://{}", CONFIG.bind_address);
+    info!("开始运行管理页: http://{}", CONFIG.bind_address);
    Ok(axum::serve(listener, ServiceExt::<Request>::into_make_service(app)).await?)
 }

--- a/crates/bili_sync/src/task/video_downloader.rs
+++ b/crates/bili_sync/src/task/video_downloader.rs
@@ -1,10 +1,8 @@
-use std::path::PathBuf;
 use std::sync::Arc;

 use sea_orm::DatabaseConnection;
 use tokio::time;

-use crate::adapter::Args;
 use crate::bilibili::{self, BiliClient};
 use crate::config::CONFIG;
 use crate::workflow::process_video_source;
@@ -13,8 +11,9 @@ use crate::workflow::process_video_source;
 pub async fn video_downloader(connection: Arc<DatabaseConnection>) {
    let mut anchor = chrono::Local::now().date_naive();
    let bili_client = BiliClient::new();
-    let params = collect_task_params();
+    let video_sources = CONFIG.as_video_sources();
    loop {
+        info!("开始执行本轮视频下载任务..");
        'inner: {
            match bili_client.wbi_img().await.map(|wbi_img| wbi_img.into()) {
                Ok(Some(mixin_key)) => bilibili::set_global_mixin_key(mixin_key),
@@ -34,7 +33,7 @@ pub async fn video_downloader(connection: Arc<DatabaseConnection>) {
                }
                anchor = chrono::Local::now().date_naive();
            }
-            for (args, path) in &params {
+            for (args, path) in &video_sources {
                if let Err(e) = process_video_source(*args, &bili_client, path, &connection).await {
                    error!("处理过程遇到错误：{:#}", e);
                }
@@ -44,24 +43,3 @@ pub async fn video_downloader(connection: Arc<DatabaseConnection>) {
        time::sleep(time::Duration::from_secs(CONFIG.interval)).await;
    }
 }
-
-/// 构造下载视频任务执行所需的参数（下载类型和保存路径）
-fn collect_task_params() -> Vec<(Args<'static>, &'static PathBuf)> {
-    let mut params = Vec::new();
-    CONFIG
-        .favorite_list
-        .iter()
-        .for_each(|(fid, path)| params.push((Args::Favorite { fid }, path)));
-    CONFIG
-        .collection_list
-        .iter()
-        .for_each(|(collection_item, path)| params.push((Args::Collection { collection_item }, path)));
-    if CONFIG.watch_later.enabled {
-        params.push((Args::WatchLater, &CONFIG.watch_later.path));
-    }
-    CONFIG
-        .submission_list
-        .iter()
-        .for_each(|(upper_id, path)| params.push((Args::Submission { upper_id }, path)));
-    params
-}
--- a/crates/bili_sync/src/utils/model.rs
+++ b/crates/bili_sync/src/utils/model.rs
@@ -1,8 +1,8 @@
 use anyhow::{Context, Result};
 use bili_sync_entity::*;
+use sea_orm::DatabaseTransaction;
 use sea_orm::entity::prelude::*;
 use sea_orm::sea_query::{OnConflict, SimpleExpr};
-use sea_orm::DatabaseTransaction;

 use crate::adapter::{VideoSource, VideoSourceEnum};
 use crate::bilibili::{PageInfo, VideoInfo};
--- a/crates/bili_sync/src/utils/nfo.rs
+++ b/crates/bili_sync/src/utils/nfo.rs
@@ -1,8 +1,8 @@
 use anyhow::Result;
 use bili_sync_entity::*;
+use quick_xml::Error;
 use quick_xml::events::{BytesCData, BytesText};
 use quick_xml::writer::Writer;
-use quick_xml::Error;
 use tokio::io::AsyncWriteExt;

 use crate::config::NFOTimeType;
--- a/crates/bili_sync/src/workflow.rs
+++ b/crates/bili_sync/src/workflow.rs
@@ -2,19 +2,19 @@ use std::collections::HashSet;
 use std::path::{Path, PathBuf};
 use std::pin::Pin;

-use anyhow::{anyhow, bail, Context, Result};
+use anyhow::{Context, Result, anyhow, bail};
 use bili_sync_entity::*;
 use futures::stream::{FuturesOrdered, FuturesUnordered};
 use futures::{Future, Stream, StreamExt, TryStreamExt};
-use sea_orm::entity::prelude::*;
 use sea_orm::ActiveValue::Set;
 use sea_orm::TransactionTrait;
+use sea_orm::entity::prelude::*;
 use tokio::fs;
 use tokio::sync::Semaphore;

-use crate::adapter::{video_source_from, Args, VideoSource, VideoSourceEnum};
+use crate::adapter::{Args, VideoSource, VideoSourceEnum, video_source_from};
 use crate::bilibili::{BestStream, BiliClient, BiliError, Dimension, PageInfo, Video, VideoInfo};
-use crate::config::{PathSafeTemplate, ARGS, CONFIG, TEMPLATE};
+use crate::config::{ARGS, CONFIG, PathSafeTemplate, TEMPLATE};
 use crate::downloader::Downloader;
 use crate::error::{DownloadAbortError, ExecutionStatus, ProcessPageError};
 use crate::utils::format_arg::{page_format_args, video_format_args};
@@ -23,7 +23,7 @@ use crate::utils::model::{
    update_videos_model,
 };
 use crate::utils::nfo::{ModelWrapper, NFOMode, NFOSerializer};
-use crate::utils::status::{PageStatus, VideoStatus, STATUS_OK};
+use crate::utils::status::{PageStatus, STATUS_OK, VideoStatus};

 /// 完整地处理某个视频来源
 pub async fn process_video_source(
@@ -72,7 +72,7 @@ pub async fn refresh_video_source<'a>(
                    if release_datetime > &max_datetime {
                        max_datetime = *release_datetime;
                    }
-                    futures::future::ready(release_datetime > &latest_row_at)
+                    futures::future::ready(video_source.should_take(release_datetime, &latest_row_at))
                }
            }
        })
@@ -535,11 +535,11 @@ pub async fn fetch_page_video(
        .await?
        .best_stream(&CONFIG.filter_option)?;
    match streams {
-        BestStream::Mixed(mix_stream) => downloader.fetch(mix_stream.url(), page_path).await?,
+        BestStream::Mixed(mix_stream) => downloader.fetch_with_fallback(&mix_stream.urls(), page_path).await?,
        BestStream::VideoAudio {
            video: video_stream,
            audio: None,
-        } => downloader.fetch(video_stream.url(), page_path).await?,
+        } => downloader.fetch_with_fallback(&video_stream.urls(), page_path).await?,
        BestStream::VideoAudio {
            video: video_stream,
            audio: Some(audio_stream),
@@ -549,8 +549,12 @@ pub async fn fetch_page_video(
                page_path.with_extension("tmp_audio"),
            );
            let res = async {
-                downloader.fetch(video_stream.url(), &tmp_video_path).await?;
-                downloader.fetch(audio_stream.url(), &tmp_audio_path).await?;
+                downloader
+                    .fetch_with_fallback(&video_stream.urls(), &tmp_video_path)
+                    .await?;
+                downloader
+                    .fetch_with_fallback(&audio_stream.urls(), &tmp_audio_path)
+                    .await?;
                downloader.merge(&tmp_video_path, &tmp_audio_path, page_path).await
            }
            .await;
--- a/docs/.vitepress/config.mts
+++ b/docs/.vitepress/config.mts
@@ -21,7 +21,7 @@ export default defineConfig({
 		nav: [
 			{ text: "主页", link: "/" },
 			{
-				text: "v2.4.0",
+				text: "v2.5.0",
 				items: [
 					{
 						text: "程序更新",
--- a/docs/configuration.md
+++ b/docs/configuration.md
@@ -77,6 +77,22 @@ UP 主头像和信息的保存位置。对于使用 Emby、Jellyfin 媒体服务

 时间格式，用于设置 `fav_time` 和 `pubtime` 在 `video_name`、 `page_name` 中使用时的显示格式，支持的格式符号可以参考 [chrono strftime 文档](https://docs.rs/chrono/latest/chrono/format/strftime/index.html)。

+## `cdn_sorting`
+
+一般情况下，b 站会为视频、音频流提供一个 baseUrl 与多个 backupUrl，程序默认会按照 baseUrl -> backupUrl 的顺序请求，依次尝试下载。
+
+如果将 `cdn_sorting` 设置为 `true`，程序不再使用默认顺序，而是将所有 url 放到一起统一排序来决定请求顺序。排序优先级从高到低为：
+
+1. 服务商 CDN：`upos-sz-mirrorxxxx.bilivideo.com`
+
+2. 自建 CDN：`cn-xxxx-dx-v-xxxx.bilivideo.com`
+
+3. MCDN：`xxxx.mcdn.bilivideo.com`
+
+4. PCDN：`xxxx.v1d.szbdyd.com`
+
+这会让程序优先请求质量更高的 CDN，可能会提高下载速度并增加成功率，但效果因地区、网络环境而异。
+
 ## `credential`

 哔哩哔哩账号的身份凭据，请参考[凭据获取流程](https://nemo2011.github.io/bilibili-api/#/get-credential)获取并对应填写至配置文件中，后续 bili-sync 会在必要时自动刷新身份凭据，不再需要手动管理。
--- a/docs/introduction.md
+++ b/docs/introduction.md
@@ -1,7 +1,7 @@
 # bili-sync 是什么？

 > [!TIP]
-> 当前最新程序版本为 v2.4.0，文档将始终与最新程序版本保持一致。
+> 当前最新程序版本为 v2.5.0，文档将始终与最新程序版本保持一致。

 bili-sync 是一款专为 NAS 用户编写的哔哩哔哩同步工具。

--- a/docs/quick-start.md
+++ b/docs/quick-start.md
@@ -81,6 +81,7 @@ interval = 1200
 upper_path = "/Users/amtoaer/Library/Application Support/bili-sync/upper_face"
 nfo_time_type = "favtime"
 time_format = "%Y-%m-%d"
+cdn_sorting = false

 [credential]
 sessdata = ""
Author	SHA1	Message	Date
amtoaer	f52724b974	chore: 发布 bili-sync 2.5.0	2025-02-27 14:04:40 +08:00
amtoaer	4e1e0c40cf	docs: 文档跟进最新代码变化	2025-02-27 14:03:47 +08:00
ᴀᴍᴛᴏᴀᴇʀ	439513e5ab	chore: 修改 error 判断，考虑 chain (#291 )	2025-02-27 13:39:00 +08:00
ᴀᴍᴛᴏᴀᴇʀ	33a61ec08d	fix: 视频合集/视频列表改为全量拉取，确保正确更新 (#290 )	2025-02-25 20:55:50 +08:00
ᴀᴍᴛᴏᴀᴇʀ	a6d0d6b777	feat: 下载时考虑 backup_url，支持按照 cdn 优先级排序 (#288 )	2025-02-24 19:48:07 +08:00
amtoaer	ae685cbe61	ci: 打 tag 时仅触发 release，跳过 commit	2025-02-21 21:44:36 +08:00
amtoaer	16e14fc371	chore: 发布 bili-sync 2.4.1	2025-02-21 21:22:52 +08:00
amtoaer	b4a5dee236	ci: 使 ci 版本带有版本标签	2025-02-21 21:15:10 +08:00
ᴀᴍᴛᴏᴀᴇʀ	2b3e6f9547	chore: 程序开始时打印欢迎信息，调整日志和构建流 (#285 )	2025-02-21 21:04:39 +08:00
ᴀᴍᴛᴏᴀᴇʀ	f8b93d2c76	fix: 修复配置初始化的检测 (#284 )	2025-02-21 19:32:46 +08:00
ᴀᴍᴛᴏᴀᴇʀ	94462ca706	chore: 更新 rust edition 到 2024，更新依赖 (#283 )	2025-02-21 17:47:49 +08:00