Merge branch 'main' into dev

Reviewed-on: #9
  - 上游源码合并增补相关功能与补丁
  - v1.3.6版本开始付费用户可以自行选择中国大陆地区优化专线节点以及手动申请独享专线节点
    - 进入优化专线节点方式为各客户端中设置页面下"网络测试"选项进入即可看到“自定义线路”选项

.gitea/workflows/android-release.yml

@@ -12,6 +12,9 @@ permissions:
   contents: write
   releases: write
 
+env:
+  FLUTTER_STORAGE_BASE_URL: https://storage.flutter-io.cn
+
 jobs:
   android:
     name: Build Android APK
@@ -113,7 +116,7 @@ jobs:
           flutter doctor -v
 
       - name: Install dependencies
-        run: flutter pub get
+        run: flutter pub get --enforce-lockfile
 
       - name: Restore Android signing files
         shell: bash
@@ -145,7 +148,7 @@ jobs:
         run: |
           set -euo pipefail
 
-          rm -rf build dist .dart_tool android/.gradle
+          rm -rf build dist android/.gradle
 
           pkg_dir="$PWD/dist/android"
           if [ -d "$pkg_dir" ]; then
@@ -153,7 +156,7 @@ jobs:
             rm -rf "$pkg_dir"
           fi
 
-          build_args=(--release)
+          build_args=(--release --no-pub)
           if [ -n "${IP_NODE_API_BASE_URL:-}" ]; then
             build_args+=("--dart-define=IP_NODE_API_BASE_URL=${IP_NODE_API_BASE_URL}")
           fi

README.md

@@ -160,6 +160,14 @@ Linux: Debian 12
 flutter pub get
 ```
 
+如果当前网络无法解析 `pub.dev`，先设置 Pub/Flutter 镜像：
+
+```powershell
+$env:PUB_HOSTED_URL="https://pub.flutter-io.cn"
+$env:FLUTTER_STORAGE_BASE_URL="https://storage.flutter-io.cn"
+flutter pub get
+```
+
 ### 运行项目
 
 ```bash
@@ -170,11 +178,11 @@ flutter run  # pdf 和 音视频会再构建过程中下载github上的依赖,
 
 ```bash
 # Android
-flutter build apk --release
+flutter build apk --release --no-pub
 # Linux
-flutter build -d linux --release
+flutter build -d linux --release --no-pub
 # windows
-flutter build -d windows --release
+flutter build -d windows --release --no-pub
 ```
 
 ---

lib/core/constants/storage_keys.dart

@@ -14,6 +14,7 @@ class StorageKeys {
   static const String downloadTasks = 'download_tasks';
   static const String downloadWifiOnly = 'download_wifi_only';
   static const String downloadRetries = 'download_retries';
+  static const String selectedCustomLineNode = 'selected_custom_line_node';
 
   // 任务记录
   static const String taskRetentionDays = 'task_retention_days';

lib/main.dart

@@ -29,6 +29,7 @@ import 'services/storage_service.dart';
 import 'services/server_service.dart';
 import 'services/cache_manager_service.dart';
 import 'services/avatar_cache_service.dart';
+import 'services/host_mapping_proxy_service.dart';
 import 'core/utils/video_fullscreen.dart';
 import 'services/desktop_service.dart';
 import 'router/app_router.dart';
@@ -51,6 +52,7 @@ Level _parseLogLevel(String level) {
 
 void main() async {
   WidgetsFlutterBinding.ensureInitialized();
+  HttpOverrides.global = HostMappingHttpOverrides();
 
   await AppLogger.init();
   final savedLevel = await StorageService.instance.getString(

lib/presentation/pages/preview/audio_preview_page.dart

@@ -1,6 +1,7 @@
 import 'package:flutter/material.dart';
 import 'package:media_kit/media_kit.dart';
 import '../../../data/models/file_model.dart';
+import '../../../services/custom_line_service.dart';
 import '../../../services/file_service.dart';
 
 /// 音频预览页面
@@ -43,7 +44,11 @@ class _AudioPreviewPageState extends State<AudioPreviewPage> {
           setState(() {
             _isLoading = false;
           });
-          player.open(Media(url), play: true);
+          await CustomLineService.instance.configureMediaPlayerProxy(
+            player,
+            url,
+          );
+          await player.open(Media(url), play: true);
         }
       } else {
         if (mounted) {
@@ -104,11 +109,7 @@ class _AudioPreviewPageState extends State<AudioPreviewPage> {
         child: Column(
           mainAxisAlignment: MainAxisAlignment.center,
           children: [
-            const Icon(
+            const Icon(Icons.error_outline, size: 64, color: Colors.white54),
-              Icons.error_outline,
-              size: 64,
-              color: Colors.white54,
-            ),
             const SizedBox(height: 16),
             Text(
               _errorMessage!,
@@ -140,14 +141,17 @@ class AudioPlayerWidget extends StatefulWidget {
   final Player player;
   final String fileName;
 
-  const AudioPlayerWidget({super.key, required this.player, required this.fileName});
+  const AudioPlayerWidget({
+    super.key,
+    required this.player,
+    required this.fileName,
+  });
 
   @override
   State<AudioPlayerWidget> createState() => _AudioPlayerWidgetState();
 }
 
 class _AudioPlayerWidgetState extends State<AudioPlayerWidget> {
-
   @override
   Widget build(BuildContext context) {
     return Container(
@@ -155,10 +159,7 @@ class _AudioPlayerWidgetState extends State<AudioPlayerWidget> {
         gradient: LinearGradient(
           begin: Alignment.topCenter,
           end: Alignment.bottomCenter,
-          colors: [
+          colors: [const Color(0xFF1A1A2E), const Color(0xFF16213E)],
-            const Color(0xFF1A1A2E),
-            const Color(0xFF16213E),
-          ],
         ),
       ),
       child: Padding(
@@ -246,12 +247,18 @@ class _AudioPlayerWidgetState extends State<AudioPlayerWidget> {
                 return SliderTheme(
                   data: SliderThemeData(
                     trackHeight: 4,
-                    thumbShape: const RoundSliderThumbShape(enabledThumbRadius: 8),
+                    thumbShape: const RoundSliderThumbShape(
-                    overlayShape: const RoundSliderOverlayShape(overlayRadius: 16),
+                      enabledThumbRadius: 8,
+                    ),
+                    overlayShape: const RoundSliderOverlayShape(
+                      overlayRadius: 16,
+                    ),
                     activeTrackColor: const Color(0xFFE94560),
                     inactiveTrackColor: Colors.white.withValues(alpha: 0.1),
                     thumbColor: const Color(0xFFE94560),
-                    overlayColor: const Color(0xFFE94560).withValues(alpha: 0.3),
+                    overlayColor: const Color(
+                      0xFFE94560,
+                    ).withValues(alpha: 0.3),
                   ),
                   child: Slider(
                     value: position.inMilliseconds.toDouble(),
@@ -259,9 +266,7 @@ class _AudioPlayerWidgetState extends State<AudioPlayerWidget> {
                         ? duration.inMilliseconds.toDouble()
                         : 1.0,
                     onChanged: (value) {
-                      widget.player.seek(
+                      widget.player.seek(Duration(milliseconds: value.toInt()));
-                        Duration(milliseconds: value.toInt()),
-                      );
                     },
                   ),
                 );

lib/presentation/pages/preview/document_preview_page.dart

@@ -8,6 +8,7 @@ import 'package:highlight/highlight.dart';
 import 'package:highlight/languages/all.dart';
 import 'package:http/http.dart' as http;
 import '../../../data/models/file_model.dart';
+import '../../../services/custom_line_service.dart';
 import '../../../services/file_service.dart';
 import '../../../core/utils/file_type_utils.dart';
 
@@ -62,6 +63,7 @@ class _DocumentPreviewPageState extends State<DocumentPreviewPage> {
       if (urls.isEmpty) throw Exception('获取URL为空');
       final urlData = urls[0] as Map<String, dynamic>;
       final url = urlData['url'] as String;
+      await CustomLineService.instance.activateSelectedNodeForUrl(url);
 
       final responseContent = await http.get(Uri.parse(url));
       if (responseContent.statusCode != 200) {
@@ -93,7 +95,8 @@ class _DocumentPreviewPageState extends State<DocumentPreviewPage> {
     _codeController = CodeController(text: _content, language: _languageMode);
   }
 
-  int _countLines(String text) => text.isEmpty ? 0 : '\n'.allMatches(text).length + 1;
+  int _countLines(String text) =>
+      text.isEmpty ? 0 : '\n'.allMatches(text).length + 1;
 
   Mode _detectLanguageMode(String fileName) {
     final ext = FileTypeUtils.getExtension(fileName);
@@ -131,16 +134,21 @@ class _DocumentPreviewPageState extends State<DocumentPreviewPage> {
       appBar: AppBar(
         backgroundColor: _backgroundColor,
         elevation: 0,
-        iconTheme: const IconThemeData(
+        iconTheme: const IconThemeData(color: Colors.white),
-          color: Colors.white,
-        ),
         title: Column(
           // crossAxisAlignment: CrossAxisAlignment.start,
           children: [
-            Text(widget.file.name, style: const TextStyle(color: Colors.white, fontSize: 15), textAlign: TextAlign.center,),
+            Text(
+              widget.file.name,
+              style: const TextStyle(color: Colors.white, fontSize: 15),
+              textAlign: TextAlign.center,
+            ),
             if (!_isLoading)
-              Text('$_languageName · $_lineCount 行 · 字号: ${_fontSize.toInt()}', 
+              Text(
-                style: TextStyle(color: Colors.grey.shade400, fontSize: 12), textAlign: TextAlign.center,),
+                '$_languageName · $_lineCount 行 · 字号: ${_fontSize.toInt()}',
+                style: TextStyle(color: Colors.grey.shade400, fontSize: 12),
+                textAlign: TextAlign.center,
+              ),
           ],
         ),
         actions: [
@@ -159,60 +167,64 @@ class _DocumentPreviewPageState extends State<DocumentPreviewPage> {
 
   /// 现在是一次性渲染的, 所以代码行数太多会有性能问题, 渲染会耗时较长, 而且会卡顿
   Widget _buildCodeEditor(double lineNumberWidth) {
-      // 核心改进：根据当前字号，动态计算一个更宽松的行号宽度
+    // 核心改进：根据当前字号，动态计算一个更宽松的行号宽度
-      // 13号字大概每个数字占 8-9 像素，我们按 10 像素算并加上边距
+    // 13号字大概每个数字占 8-9 像素，我们按 10 像素算并加上边距
-      int digits = _lineCount.toString().length;
+    int digits = _lineCount.toString().length;
-      // 这里的 12.0 是根据 13-15号字体的平均宽度预留，46 是基础间距 (调试火葬场)
+    // 这里的 12.0 是根据 13-15号字体的平均宽度预留，46 是基础间距 (调试火葬场)
-      double stableWidth = _showLineNumbers 
+    double stableWidth = _showLineNumbers
-          ? (digits * (_fontSize * 0.75)) + 46
+        ? (digits * (_fontSize * 0.75)) + 46
-          : 0;
+        : 0;
-      return Container(
+    return Container(
-        margin: const EdgeInsets.symmetric(horizontal: 2, vertical: 2),
+      margin: const EdgeInsets.symmetric(horizontal: 2, vertical: 2),
-        clipBehavior: Clip.antiAlias,
+      clipBehavior: Clip.antiAlias,
-        decoration: BoxDecoration(
+      decoration: BoxDecoration(
-          color: _backgroundColor,
+        color: _backgroundColor,
-          borderRadius: BorderRadius.circular(12),
+        borderRadius: BorderRadius.circular(12),
+      ),
+      child: ScrollConfiguration(
+        behavior: ScrollConfiguration.of(context).copyWith(
+          dragDevices: {PointerDeviceKind.touch, PointerDeviceKind.mouse},
         ),
-        child: ScrollConfiguration(
+        child: CodeTheme(
-          behavior: ScrollConfiguration.of(context).copyWith(
+          data: CodeThemeData(styles: {...atomOneDarkTheme}),
-            dragDevices: {PointerDeviceKind.touch, PointerDeviceKind.mouse},
+          child: Scrollbar(
-          ),
+            controller: _customCodeScrollController,
-          child: CodeTheme(
+            child: SingleChildScrollView(
-            data: CodeThemeData(styles: {...atomOneDarkTheme}),
-            child: Scrollbar(
               controller: _customCodeScrollController,
-              child: SingleChildScrollView(
+              child: CodeField(
-                controller: _customCodeScrollController,
+                controller: _codeController!,
-                child: CodeField(
+                textStyle: TextStyle(
-                  controller: _codeController!,
+                  fontFamily: 'SourceCodePro',
+                  fontSize: _fontSize,
+                  height: 1.5,
+                ),
+                enabled: false,
+                readOnly: true,
+                background: Colors.transparent,
+                // 关键点 1：调整行号样式
+                lineNumberStyle: LineNumberStyle(
+                  width: stableWidth,
+                  textAlign: TextAlign.right, // 回归右对齐，更符合代码习惯
+                  margin: _showLineNumbers ? 12 : 0, // 增加间距防止数字贴边触发换行
                   textStyle: TextStyle(
-                    fontFamily: 'SourceCodePro',
+                    color: _showLineNumbers
-                    fontSize: _fontSize,
+                        ? Colors.grey.shade600
-                    height: 1.5,
+                        : Colors.transparent,
-                  ),
+                    fontSize: _fontSize * 0.8,
-                  enabled: false,
+                    height: 1.5, // 必须和正文高度完全一致
-                  readOnly: true,
+                    // 核心修复：通过强制单词不换行来防止数字断裂
-                  background: Colors.transparent,
+                    fontFeatures: const [
-                  // 关键点 1：调整行号样式
+                      FontFeature.tabularFigures(),
-                  lineNumberStyle: LineNumberStyle(
+                    ], // 使用等宽数字
-                    width: stableWidth,
-                    textAlign: TextAlign.right, // 回归右对齐，更符合代码习惯
-                    margin: _showLineNumbers ? 12 : 0, // 增加间距防止数字贴边触发换行
-                    textStyle: TextStyle(
-                      color: _showLineNumbers ? Colors.grey.shade600 : Colors.transparent,
-                      fontSize: _fontSize * 0.8,
-                      height: 1.5, // 必须和正文高度完全一致
-                      // 核心修复：通过强制单词不换行来防止数字断裂
-                      fontFeatures: const [FontFeature.tabularFigures()], // 使用等宽数字
-                    ),
                   ),
                 ),
               ),
             ),
           ),
         ),
-      );
+      ),
-    }
+    );
+  }
 
   // 构建功能组合按钮
   Widget _buildExpandableFab() {
@@ -225,7 +237,9 @@ class _DocumentPreviewPageState extends State<DocumentPreviewPage> {
           heroTag: 'font_up',
           mini: true,
           backgroundColor: Colors.grey.shade800,
-          onPressed: () => setState(() { if(_fontSize < 30) _fontSize++; }),
+          onPressed: () => setState(() {
+            if (_fontSize < 30) _fontSize++;
+          }),
           child: const Icon(Icons.add, color: Colors.white, size: 20),
         ),
         const SizedBox(height: 8),
@@ -234,7 +248,9 @@ class _DocumentPreviewPageState extends State<DocumentPreviewPage> {
           heroTag: 'font_down',
           mini: true,
           backgroundColor: Colors.grey.shade800,
-          onPressed: () => setState(() { if(_fontSize > 8) _fontSize--; }),
+          onPressed: () => setState(() {
+            if (_fontSize > 8) _fontSize--;
+          }),
           child: const Icon(Icons.remove, color: Colors.white, size: 20),
         ),
         const SizedBox(height: 8),
@@ -242,7 +258,9 @@ class _DocumentPreviewPageState extends State<DocumentPreviewPage> {
         FloatingActionButton(
           heroTag: 'line_toggle',
           mini: true,
-          backgroundColor: _showLineNumbers ? Colors.blue : Colors.grey.shade800,
+          backgroundColor: _showLineNumbers
+              ? Colors.blue
+              : Colors.grey.shade800,
           onPressed: () => setState(() => _showLineNumbers = !_showLineNumbers),
           child: Icon(
             _showLineNumbers ? Icons.format_list_numbered : Icons.short_text,

lib/presentation/pages/preview/image_preview_page.dart

@@ -4,6 +4,7 @@ import 'package:flutter/material.dart';
 import 'package:flutter/services.dart';
 import 'package:photo_view/photo_view.dart';
 import '../../../data/models/file_model.dart';
+import '../../../services/custom_line_service.dart';
 import '../../../services/file_service.dart';
 import '../../../services/cache_manager_service.dart';
 import '../../widgets/toast_helper.dart';
@@ -44,6 +45,7 @@ class _ImagePreviewPageState extends State<ImagePreviewPage> {
       if (urls.isNotEmpty) {
         final urlData = urls[0] as Map<String, dynamic>;
         final url = urlData['url'] as String;
+        await CustomLineService.instance.activateSelectedNodeForUrl(url);
 
         if (mounted) {
           setState(() {

lib/presentation/pages/preview/markdown_preview_page.dart

@@ -11,6 +11,7 @@ import 'package:markdown_widget/widget/blocks/leaf/link.dart';
 import 'package:markdown_widget/widget/markdown.dart';
 import 'package:url_launcher/url_launcher.dart';
 import '../../../data/models/file_model.dart';
+import '../../../services/custom_line_service.dart';
 import '../../../services/file_service.dart';
 
 class MarkdownPreviewPage extends StatefulWidget {
@@ -62,6 +63,7 @@ class _MarkdownPreviewPageState extends State<MarkdownPreviewPage> {
 
       final urlData = urls[0] as Map<String, dynamic>;
       final url = urlData['url'] as String;
+      await CustomLineService.instance.activateSelectedNodeForUrl(url);
 
       final responseContent = await http.get(Uri.parse(url));
       if (responseContent.statusCode != 200) {
@@ -104,7 +106,10 @@ class _MarkdownPreviewPageState extends State<MarkdownPreviewPage> {
         backgroundColor: bgColor,
         elevation: 0,
         leading: IconButton(
-          icon: Icon(Icons.arrow_back, color: isDark ? Colors.white : Colors.black87),
+          icon: Icon(
+            Icons.arrow_back,
+            color: isDark ? Colors.white : Colors.black87,
+          ),
           onPressed: () => Navigator.of(context).pop(),
         ),
         title: Column(
@@ -120,13 +125,19 @@ class _MarkdownPreviewPageState extends State<MarkdownPreviewPage> {
               overflow: TextOverflow.ellipsis,
             ),
             if (!_isLoading && _error == null)
-              Text('Markdown 预览', style: TextStyle(color: Colors.grey, fontSize: 12)),
+              Text(
+                'Markdown 预览',
+                style: TextStyle(color: Colors.grey, fontSize: 12),
+              ),
           ],
         ),
         actions: [
           if (!_isLoading && _error == null)
             IconButton(
-              icon: Icon(Icons.copy, color: isDark ? Colors.white : Colors.black87),
+              icon: Icon(
+                Icons.copy,
+                color: isDark ? Colors.white : Colors.black87,
+              ),
               onPressed: () => Clipboard.setData(ClipboardData(text: _content)),
             ),
         ],
@@ -134,8 +145,8 @@ class _MarkdownPreviewPageState extends State<MarkdownPreviewPage> {
       body: _isLoading
           ? const Center(child: CircularProgressIndicator())
           : _error != null
-              ? _buildErrorWidget()
+          ? _buildErrorWidget()
-              : _buildResponsiveBody(isWideScreen, screenWidth),
+          : _buildResponsiveBody(isWideScreen, screenWidth),
       floatingActionButton: _buildFAB(isDark),
     );
   }
@@ -159,10 +170,14 @@ class _MarkdownPreviewPageState extends State<MarkdownPreviewPage> {
             decoration: BoxDecoration(
               border: Border(
                 right: BorderSide(
-                  color: _isDarkMode ? Colors.white10 : Colors.grey.withValues(alpha: 0.2)
+                  color: _isDarkMode
+                      ? Colors.white10
+                      : Colors.grey.withValues(alpha: 0.2),
                 ),
               ),
-              color: _isDarkMode ? const Color(0xFF252525) : Colors.grey.shade50,
+              color: _isDarkMode
+                  ? const Color(0xFF252525)
+                  : Colors.grey.shade50,
             ),
             child: ClipRect(
               child: Column(
@@ -178,7 +193,10 @@ class _MarkdownPreviewPageState extends State<MarkdownPreviewPage> {
                       ),
                     ),
                   ),
-                  Divider(height: 1, color: _isDarkMode ? Colors.white10 : Colors.grey.shade300),
+                  Divider(
+                    height: 1,
+                    color: _isDarkMode ? Colors.white10 : Colors.grey.shade300,
+                  ),
                   Expanded(
                     child: GestureDetector(
                       onTap: () {
@@ -198,9 +216,7 @@ class _MarkdownPreviewPageState extends State<MarkdownPreviewPage> {
                             bodySmall: TextStyle(color: subTextColor),
                           ),
                         ),
-                        child: TocWidget(
+                        child: TocWidget(controller: _tocController),
-                          controller: _tocController,
-                        ),
                       ),
                     ),
                   ),
@@ -228,8 +244,11 @@ class _MarkdownPreviewPageState extends State<MarkdownPreviewPage> {
   }
 
   Widget _buildMarkdownWidget(String content) {
-    final config = _isDarkMode ? MarkdownConfig.darkConfig : MarkdownConfig.defaultConfig;
+    final config = _isDarkMode
-    CodeWrapperWidget codeWrapper(child, text, language) => CodeWrapperWidget(child, text, language);
+        ? MarkdownConfig.darkConfig
+        : MarkdownConfig.defaultConfig;
+    CodeWrapperWidget codeWrapper(child, text, language) =>
+        CodeWrapperWidget(child, text, language);
 
     return MarkdownWidget(
       data: content,
@@ -237,7 +256,10 @@ class _MarkdownPreviewPageState extends State<MarkdownPreviewPage> {
       config: config.copy(
         configs: [
           _isDarkMode
-              ? PreConfig.darkConfig.copy(theme: a11yLightTheme, wrapper: codeWrapper)
+              ? PreConfig.darkConfig.copy(
+                  theme: a11yLightTheme,
+                  wrapper: codeWrapper,
+                )
               : PreConfig(theme: atomOneDarkTheme).copy(wrapper: codeWrapper),
           LinkConfig(
             style: TextStyle(
@@ -266,12 +288,14 @@ class _MarkdownPreviewPageState extends State<MarkdownPreviewPage> {
     );
   }
 
-Widget _buildFAB(bool isDark) {
+  Widget _buildFAB(bool isDark) {
     if (_isLoading || _error != null) return const SizedBox.shrink();
 
     // 定义统一的按钮背景颜色，增加视觉一致性
     final Color activeColor = isDark ? Colors.blue.shade700 : Colors.blue;
-    final Color inactiveColor = isDark ? Colors.grey.shade800 : Colors.grey.shade200;
+    final Color inactiveColor = isDark
+        ? Colors.grey.shade800
+        : Colors.grey.shade200;
     final Color iconColor = isDark ? Colors.white : Colors.black87;
 
     return Column(

lib/presentation/pages/preview/pdf_preview_page.dart

@@ -1,6 +1,7 @@
 import 'package:flutter/material.dart';
 import 'package:pdfrx/pdfrx.dart';
 import '../../../data/models/file_model.dart';
+import '../../../services/custom_line_service.dart';
 import '../../../services/file_service.dart';
 
 /// PDF预览页面
@@ -37,6 +38,7 @@ class _PdfPreviewPageState extends State<PdfPreviewPage> {
       if (urls.isNotEmpty) {
         final urlData = urls[0] as Map<String, dynamic>;
         final url = urlData['url'] as String;
+        await CustomLineService.instance.activateSelectedNodeForUrl(url);
 
         if (mounted) {
           setState(() {

lib/presentation/pages/preview/video_preview_page.dart

@@ -2,6 +2,7 @@ import 'package:flutter/material.dart';
 import 'package:media_kit/media_kit.dart';
 import 'package:media_kit_video/media_kit_video.dart';
 import '../../../data/models/file_model.dart';
+import '../../../services/custom_line_service.dart';
 import '../../../services/file_service.dart';
 import 'widgets/video_controls_overlay.dart';
 
@@ -45,7 +46,11 @@ class _VideoPreviewPageState extends State<VideoPreviewPage> {
 
         if (mounted) {
           setState(() => _isLoading = false);
-          player.open(Media(url), play: true);
+          await CustomLineService.instance.configureMediaPlayerProxy(
+            player,
+            url,
+          );
+          await player.open(Media(url), play: true);
         }
       } else {
         if (mounted) {
@@ -78,37 +83,42 @@ class _VideoPreviewPageState extends State<VideoPreviewPage> {
       body: _isLoading
           ? const Center(child: CircularProgressIndicator(color: Colors.white))
           : _errorMessage != null
-              ? Center(
+          ? Center(
-                  child: Column(
+              child: Column(
-                    mainAxisAlignment: MainAxisAlignment.center,
+                mainAxisAlignment: MainAxisAlignment.center,
-                    children: [
+                children: [
-                      const Icon(Icons.error_outline, size: 64, color: Colors.white),
+                  const Icon(
-                      const SizedBox(height: 16),
+                    Icons.error_outline,
-                      Text(
+                    size: 64,
-                        _errorMessage!,
+                    color: Colors.white,
-                        textAlign: TextAlign.center,
-                        style: const TextStyle(color: Colors.white70),
-                      ),
-                      const SizedBox(height: 16),
-                      FilledButton(
-                        onPressed: () {
-                          setState(() {
-                            _isLoading = true;
-                            _errorMessage = null;
-                          });
-                          _loadVideoUrl();
-                        },
-                        child: const Text('重试'),
-                      ),
-                    ],
                   ),
-                )
+                  const SizedBox(height: 16),
-              : ExcludeSemantics(
+                  Text(
-                  child: Video(
+                    _errorMessage!,
-                    controller: controller,
+                    textAlign: TextAlign.center,
-                    controls: (state) => VideoControlsOverlay(state: state, title: widget.file.name),
+                    style: const TextStyle(color: Colors.white70),
                   ),
-                ),
+                  const SizedBox(height: 16),
+                  FilledButton(
+                    onPressed: () {
+                      setState(() {
+                        _isLoading = true;
+                        _errorMessage = null;
+                      });
+                      _loadVideoUrl();
+                    },
+                    child: const Text('重试'),
+                  ),
+                ],
+              ),
+            )
+          : ExcludeSemantics(
+              child: Video(
+                controller: controller,
+                controls: (state) =>
+                    VideoControlsOverlay(state: state, title: widget.file.name),
+              ),
+            ),
     );
   }
 }

lib/presentation/pages/settings/network_test_page.dart

@@ -8,6 +8,7 @@ import 'package:provider/provider.dart';
 import 'package:url_launcher/url_launcher.dart';
 
 import '../../../services/api_service.dart';
+import '../../../services/custom_line_service.dart';
 import '../../../services/storage_service.dart';
 import '../../providers/auth_provider.dart';
 import '../../widgets/desktop_constrained.dart';
@@ -45,6 +46,7 @@ class _NetworkTestPageState extends State<NetworkTestPage> {
   _NetworkDiagnostics? _networkDiagnostics;
   _ServiceDiagnostics? _serviceDiagnostics;
   _CustomLineDiagnostics? _customDiagnostics;
+  String? _selectedCustomNodeId;
   String? _networkError;
   String? _serviceError;
   String? _customError;
@@ -52,6 +54,7 @@ class _NetworkTestPageState extends State<NetworkTestPage> {
   @override
   void initState() {
     super.initState();
+    unawaited(_loadSelectedCustomNode());
     WidgetsBinding.instance.addPostFrameCallback((_) => _runNetworkTest());
   }
 
@@ -122,7 +125,9 @@ class _NetworkTestPageState extends State<NetworkTestPage> {
                     loading: _customLoading,
                     error: _customError,
                     diagnostics: _customDiagnostics,
+                    selectedNodeId: _selectedCustomNodeId,
                     onRefresh: _runCustomLineTest,
+                    onSelectNode: _selectCustomNode,
                     onOpenTelegram: () => _openExternalUrl(_telegramUri),
                   ),
                 },
@@ -173,6 +178,43 @@ class _NetworkTestPageState extends State<NetworkTestPage> {
     }
   }
 
+  Future<void> _loadSelectedCustomNode() async {
+    final selected = await CustomLineService.instance.getSelectedNode();
+    if (!mounted) return;
+    setState(() => _selectedCustomNodeId = selected?.id);
+  }
+
+  Future<void> _selectCustomNode(_CustomNodeProbe? probe) async {
+    if (probe == null) {
+      await CustomLineService.instance.clearSelectedNode();
+      if (mounted) setState(() => _selectedCustomNodeId = null);
+      ToastHelper.success('已关闭自定义线路节点');
+      return;
+    }
+
+    if (probe.successCount <= 0) {
+      ToastHelper.failure('该节点当前不可用，无法选择');
+      return;
+    }
+    if (!probe.node.canRewriteDownloadUrl) {
+      ToastHelper.failure('该节点未配置可用于下载加速的 IP 地址');
+      return;
+    }
+
+    await CustomLineService.instance.setSelectedNode(
+      probe.node.toSelectedNode(),
+    );
+    final endpoint = await CustomLineService.instance
+        .activateSelectedNodeForHost(probe.node.host);
+    if (endpoint == null) {
+      await CustomLineService.instance.clearSelectedNode();
+      ToastHelper.failure('节点启用失败，请稍后重试');
+      return;
+    }
+    if (mounted) setState(() => _selectedCustomNodeId = probe.node.id);
+    ToastHelper.success('已选择节点：${probe.node.displayName}');
+  }
+
   bool _isUserGroup(String groupName) =>
       groupName.trim().toLowerCase() == 'user';
 
@@ -229,9 +271,11 @@ class _NetworkTestPageState extends State<NetworkTestPage> {
       final nodes = await _fetchCustomNodes(
         clientId: clientId,
         groupName: groupName,
+        userId: auth.user!.id,
       );
       final probes = await Future.wait(nodes.map(_testCustomNode));
       final recommended = _bestCustomNode(probes);
+      final selectedNodeId = await _resolveSelectedCustomNodeId(probes);
 
       if (!mounted) return;
       setState(() {
@@ -240,6 +284,7 @@ class _NetworkTestPageState extends State<NetworkTestPage> {
           nodes: probes,
           recommended: recommended,
         );
+        _selectedCustomNodeId = selectedNodeId;
       });
     } catch (e) {
       if (mounted) setState(() => _customError = e.toString());
@@ -248,9 +293,29 @@ class _NetworkTestPageState extends State<NetworkTestPage> {
     }
   }
 
+  Future<String?> _resolveSelectedCustomNodeId(
+    List<_CustomNodeProbe> probes,
+  ) async {
+    final selectable = probes
+        .where(
+          (probe) => probe.successCount > 0 && probe.node.canRewriteDownloadUrl,
+        )
+        .toList();
+
+    final current = await CustomLineService.instance.getSelectedNode();
+    if (current != null &&
+        selectable.any((probe) => probe.node.id == current.id)) {
+      return current.id;
+    }
+
+    await CustomLineService.instance.clearSelectedNode();
+    return null;
+  }
+
   Future<List<_CustomNode>> _fetchCustomNodes({
     required String clientId,
     required String groupName,
+    required String userId,
   }) async {
     final handshakeResponse = await http
         .post(
@@ -277,7 +342,10 @@ class _NetworkTestPageState extends State<NetworkTestPage> {
 
     final nodesResponse = await http
         .get(
-          _ipNodeApiUri('/api/v1/nodes', queryParameters: {'group': groupName}),
+          _ipNodeApiUri(
+            '/api/v1/nodes',
+            queryParameters: {'group': groupName, 'user_id': userId},
+          ),
           headers: {
             'Accept': 'application/json',
             'X-Client-UUID': clientId,
@@ -834,7 +902,9 @@ class _CustomLinePanel extends StatelessWidget {
   final bool loading;
   final String? error;
   final _CustomLineDiagnostics? diagnostics;
+  final String? selectedNodeId;
   final VoidCallback onRefresh;
+  final ValueChanged<_CustomNodeProbe?> onSelectNode;
   final VoidCallback onOpenTelegram;
 
   const _CustomLinePanel({
@@ -842,7 +912,9 @@ class _CustomLinePanel extends StatelessWidget {
     required this.loading,
     required this.error,
     required this.diagnostics,
+    required this.selectedNodeId,
     required this.onRefresh,
+    required this.onSelectNode,
     required this.onOpenTelegram,
   });
 
@@ -868,11 +940,21 @@ class _CustomLinePanel extends StatelessWidget {
                 value: recommended.node.displayName,
                 valueColor: Colors.green,
               ),
-              _InfoRow(label: '节点地址', value: recommended.node.endpointLabel),
-              _InfoRow(label: '地区', value: recommended.node.locationLabel),
-              _InfoRow(label: '运营商', value: recommended.node.carrierLabel),
               _InfoRow(label: '平均延迟', value: recommended.latencyLabel),
               _InfoRow(label: '丢包率', value: recommended.lossLabel),
+              _InfoRow(label: '样本', value: recommended.sampleLabel),
+              Align(
+                alignment: Alignment.centerLeft,
+                child: TextButton.icon(
+                  onPressed:
+                      recommended.successCount > 0 &&
+                          recommended.node.canRewriteDownloadUrl
+                      ? () => onSelectNode(recommended)
+                      : null,
+                  icon: const Icon(Icons.check_circle_outline),
+                  label: const Text('使用推荐节点'),
+                ),
+              ),
             ] else if (!loading && data != null) ...[
               const _DescriptionLine('暂无可推荐节点，请刷新后重试或联系官方支持。'),
             ] else if (!loading && error == null) ...[
@@ -880,6 +962,24 @@ class _CustomLinePanel extends StatelessWidget {
             ],
           ],
         ),
+        if (data != null && selectedNodeId != null)
+          _SectionCard(
+            title: '当前选择',
+            children: [
+              _InfoRow(
+                label: '节点',
+                value: data.selectedNodeName(selectedNodeId!) ?? '已选择节点',
+              ),
+              Align(
+                alignment: Alignment.centerLeft,
+                child: TextButton.icon(
+                  onPressed: () => onSelectNode(null),
+                  icon: const Icon(Icons.close),
+                  label: const Text('关闭自定义线路'),
+                ),
+              ),
+            ],
+          ),
         _SectionCard(title: '可选节点', children: _availableNodeChildren(data)),
         _SectionCard(
           title: '自定义节点',
@@ -923,7 +1023,11 @@ class _CustomLinePanel extends StatelessWidget {
     return [
       for (var i = 0; i < data.nodes.length; i++) ...[
         if (i > 0) const Divider(height: 18),
-        _CustomNodeTile(probe: data.nodes[i]),
+        _CustomNodeTile(
+          probe: data.nodes[i],
+          selected: data.nodes[i].node.id == selectedNodeId,
+          onSelect: () => onSelectNode(data.nodes[i]),
+        ),
       ],
     ];
   }
@@ -931,48 +1035,106 @@ class _CustomLinePanel extends StatelessWidget {
 
 class _CustomNodeTile extends StatelessWidget {
   final _CustomNodeProbe probe;
+  final bool selected;
+  final VoidCallback onSelect;
 
-  const _CustomNodeTile({required this.probe});
+  const _CustomNodeTile({
+    required this.probe,
+    required this.selected,
+    required this.onSelect,
+  });
 
   @override
   Widget build(BuildContext context) {
     final available = probe.successCount > 0;
     final statusColor = _statusColor(context, available);
-    return Padding(
+    final selectable = available && probe.node.canRewriteDownloadUrl;
-      padding: const EdgeInsets.symmetric(vertical: 4),
+    return InkWell(
-      child: Column(
+      onTap: selectable ? onSelect : null,
-        crossAxisAlignment: CrossAxisAlignment.start,
+      borderRadius: BorderRadius.circular(8),
-        children: [
+      child: Padding(
-          Row(
+        padding: const EdgeInsets.symmetric(vertical: 6),
-            crossAxisAlignment: CrossAxisAlignment.start,
+        child: Row(
-            children: [
+          crossAxisAlignment: CrossAxisAlignment.start,
-              Expanded(
+          children: [
-                child: Text(
+            Icon(
-                  probe.node.displayName,
+              selected
-                  style: Theme.of(
+                  ? Icons.radio_button_checked
-                    context,
+                  : Icons.radio_button_unchecked,
-                  ).textTheme.bodyLarge?.copyWith(fontWeight: FontWeight.w700),
+              color: selected ? Colors.green : statusColor,
-                ),
+            ),
+            const SizedBox(width: 10),
+            Expanded(
+              child: Column(
+                crossAxisAlignment: CrossAxisAlignment.start,
+                children: [
+                  Row(
+                    crossAxisAlignment: CrossAxisAlignment.start,
+                    children: [
+                      Expanded(
+                        child: Wrap(
+                          spacing: 8,
+                          runSpacing: 4,
+                          crossAxisAlignment: WrapCrossAlignment.center,
+                          children: [
+                            Text(
+                              probe.node.displayName,
+                              style: Theme.of(context).textTheme.bodyLarge
+                                  ?.copyWith(fontWeight: FontWeight.w700),
+                            ),
+                            if (probe.node.dedicated)
+                              Container(
+                                padding: const EdgeInsets.symmetric(
+                                  horizontal: 7,
+                                  vertical: 2,
+                                ),
+                                decoration: BoxDecoration(
+                                  color: const Color(0xFFFFF3D6),
+                                  borderRadius: BorderRadius.circular(999),
+                                  border: Border.all(
+                                    color: const Color(0xFFE5B454),
+                                  ),
+                                ),
+                                child: const Text(
+                                  '专线',
+                                  style: TextStyle(
+                                    color: Color(0xFF8A5A00),
+                                    fontSize: 12,
+                                    fontWeight: FontWeight.w800,
+                                  ),
+                                ),
+                              ),
+                          ],
+                        ),
+                      ),
+                      const SizedBox(width: 12),
+                      Text(
+                        available ? '可用' : '不可用',
+                        style: TextStyle(
+                          color: statusColor,
+                          fontWeight: FontWeight.w700,
+                        ),
+                      ),
+                    ],
+                  ),
+                  const SizedBox(height: 4),
+                  Text(
+                    '平均延迟 ${probe.latencyLabel} / 丢包率 ${probe.lossLabel} / 样本 ${probe.sampleLabel}',
+                  ),
+                  if (available && !probe.node.canRewriteDownloadUrl) ...[
+                    const SizedBox(height: 4),
+                    Text(
+                      '未配置可用于下载加速的 IP',
+                      style: TextStyle(
+                        color: Theme.of(context).colorScheme.error,
+                      ),
+                    ),
+                  ],
+                ],
               ),
-              const SizedBox(width: 12),
+            ),
-              Text(
+          ],
-                available ? '可用' : '不可用',
+        ),
-                style: TextStyle(
-                  color: statusColor,
-                  fontWeight: FontWeight.w700,
-                ),
-              ),
-            ],
-          ),
-          const SizedBox(height: 4),
-          Text(probe.node.endpointLabel),
-          const SizedBox(height: 4),
-          Text('${probe.node.locationLabel} / ${probe.node.carrierLabel}'),
-          const SizedBox(height: 4),
-          Text(
-            '平均延迟 ${probe.latencyLabel} / 丢包率 ${probe.lossLabel} / 样本 ${probe.sampleLabel}',
-          ),
-        ],
       ),
     );
   }
@@ -1125,6 +1287,13 @@ class _CustomLineDiagnostics {
     required this.nodes,
     required this.recommended,
   });
+
+  String? selectedNodeName(String nodeId) {
+    for (final probe in nodes) {
+      if (probe.node.id == nodeId) return probe.node.displayName;
+    }
+    return null;
+  }
 }
 
 class _CustomNode {
@@ -1139,6 +1308,7 @@ class _CustomNode {
   final String province;
   final String carrier;
   final List<String> groups;
+  final bool dedicated;
   final bool enabled;
   final String probeUrl;
 
@@ -1154,6 +1324,7 @@ class _CustomNode {
     required this.province,
     required this.carrier,
     required this.groups,
+    required this.dedicated,
     required this.enabled,
     required this.probeUrl,
   });
@@ -1171,6 +1342,7 @@ class _CustomNode {
       province: json['province']?.toString() ?? '',
       carrier: json['carrier']?.toString() ?? '',
       groups: _asStringList(json['groups']),
+      dedicated: json['dedicated'] == true,
       enabled: json['enabled'] != false,
       probeUrl: json['probe_url']?.toString() ?? '',
     );
@@ -1189,6 +1361,20 @@ class _CustomNode {
     return ip.trim();
   }
 
+  bool get canRewriteDownloadUrl =>
+      ip.trim().isNotEmpty && host.trim().isNotEmpty;
+
+  SelectedCustomLineNode toSelectedNode() {
+    return SelectedCustomLineNode(
+      id: id,
+      name: displayName,
+      ip: ip.trim(),
+      host: host.trim(),
+      protocol: protocol.trim(),
+      port: port,
+    );
+  }
+
   String get endpointLabel {
     final endpoint = endpointHost;
     if (endpoint.isEmpty) return '未配置地址';

lib/services/custom_line_service.dart

@@ -0,0 +1,223 @@
+import 'dart:convert';
+
+import 'package:media_kit/media_kit.dart';
+
+import '../core/constants/storage_keys.dart';
+import '../core/utils/app_logger.dart';
+import 'host_mapping_proxy_service.dart';
+import 'server_service.dart';
+import 'storage_service.dart';
+
+class CustomLineService {
+  CustomLineService._();
+
+  static final CustomLineService instance = CustomLineService._();
+
+  HostMappingProxyEndpoint? get currentProxyEndpoint =>
+      HostMappingProxyService.instance.endpoint;
+
+  Future<SelectedCustomLineNode?> getSelectedNode() async {
+    final raw = await StorageService.instance.getString(
+      StorageKeys.selectedCustomLineNode,
+    );
+    if (raw == null || raw.isEmpty) return null;
+
+    try {
+      final decoded = jsonDecode(raw);
+      if (decoded is! Map<String, dynamic>) return null;
+      final node = SelectedCustomLineNode.fromJson(decoded);
+      if (!node.canRewriteDownloadUrl) return null;
+      return node;
+    } catch (_) {
+      return null;
+    }
+  }
+
+  Future<void> setSelectedNode(SelectedCustomLineNode node) async {
+    if (!node.canRewriteDownloadUrl) {
+      throw ArgumentError('The selected custom line node has no usable IP.');
+    }
+    await StorageService.instance.setString(
+      StorageKeys.selectedCustomLineNode,
+      jsonEncode(node.toJson()),
+    );
+  }
+
+  Future<void> clearSelectedNode() async {
+    await StorageService.instance.remove(StorageKeys.selectedCustomLineNode);
+    await HostMappingProxyService.instance.stop();
+  }
+
+  Future<CustomLineDownloadRoute> routeDownloadUrl(String url) async {
+    if (!_canUseCustomLine()) {
+      await HostMappingProxyService.instance.stop();
+      return CustomLineDownloadRoute(url: url);
+    }
+
+    final node = await getSelectedNode();
+    if (node == null) return CustomLineDownloadRoute(url: url);
+
+    final uri = Uri.tryParse(url);
+    if (uri == null || uri.host.isEmpty) {
+      return CustomLineDownloadRoute(url: url);
+    }
+
+    final endpoint = await activateSelectedNodeForHost(uri.host);
+    if (endpoint == null) {
+      return CustomLineDownloadRoute(url: url);
+    }
+
+    return CustomLineDownloadRoute(
+      url: url,
+      nodeName: node.name,
+      originalHost: uri.host,
+      proxy: endpoint,
+    );
+  }
+
+  Future<HostMappingProxyEndpoint?> activateSelectedNodeForHost(String host) {
+    return activateSelectedNodeForHosts([host]);
+  }
+
+  Future<HostMappingProxyEndpoint?> activateSelectedNodeForHosts(
+    Iterable<String> hosts,
+  ) async {
+    if (!_canUseCustomLine()) {
+      await HostMappingProxyService.instance.stop();
+      return null;
+    }
+
+    final node = await getSelectedNode();
+    if (node == null) {
+      await HostMappingProxyService.instance.stop();
+      return null;
+    }
+
+    final hostMap = <String, String>{};
+    void addHost(String value) {
+      final host = value.trim();
+      if (host.isNotEmpty) hostMap[host] = node.ip;
+    }
+
+    addHost(node.host);
+    for (final host in hosts) {
+      addHost(host);
+    }
+
+    if (hostMap.isEmpty) {
+      await HostMappingProxyService.instance.stop();
+      return null;
+    }
+    return HostMappingProxyService.instance.configure(hostMap);
+  }
+
+  Future<HostMappingProxyEndpoint?> activateSelectedNodeForUrl(String url) {
+    final uri = Uri.tryParse(url);
+    return activateSelectedNodeForHost(uri?.host ?? '');
+  }
+
+  Future<HostMappingProxyEndpoint?> activateSelectedNodeForUrls(
+    Iterable<String> urls,
+  ) {
+    final hosts = urls
+        .map((url) => Uri.tryParse(url)?.host ?? '')
+        .where((host) => host.trim().isNotEmpty);
+    return activateSelectedNodeForHosts(hosts);
+  }
+
+  Future<void> configureMediaPlayerProxy(Player player, String url) async {
+    final endpoint = await activateSelectedNodeForUrl(url);
+    final platform = player.platform;
+    if (platform is! NativePlayer) return;
+
+    try {
+      await platform.setProperty('http-proxy', endpoint?.proxyUri ?? '');
+      AppLogger.d('媒体播放器自定义线路代理已配置: ${endpoint?.proxyUri ?? 'DIRECT'}');
+    } catch (e) {
+      AppLogger.d('媒体播放器自定义线路代理配置失败: $e');
+    }
+  }
+
+  bool _canUseCustomLine() {
+    final user = ServerService.instance.currentServer?.user;
+    final groupName = user?.group?.name.trim().toLowerCase();
+    return user != null &&
+        groupName != null &&
+        groupName.isNotEmpty &&
+        groupName != 'user';
+  }
+}
+
+class SelectedCustomLineNode {
+  final String id;
+  final String name;
+  final String ip;
+  final String host;
+  final String protocol;
+  final int? port;
+
+  const SelectedCustomLineNode({
+    required this.id,
+    required this.name,
+    required this.ip,
+    required this.host,
+    this.protocol = '',
+    this.port,
+  });
+
+  bool get canRewriteDownloadUrl =>
+      ip.trim().isNotEmpty && host.trim().isNotEmpty;
+
+  String routeScheme(String fallback) {
+    final value = protocol.trim().toLowerCase();
+    return value == 'http' || value == 'https' ? value : fallback;
+  }
+
+  int? get routePort => port != null && port! > 0 ? port : null;
+
+  factory SelectedCustomLineNode.fromJson(Map<String, dynamic> json) {
+    return SelectedCustomLineNode(
+      id: json['id']?.toString() ?? '',
+      name: json['name']?.toString() ?? '',
+      ip: json['ip']?.toString() ?? '',
+      host: json['host']?.toString() ?? '',
+      protocol: json['protocol']?.toString() ?? '',
+      port: _asNullableInt(json['port']),
+    );
+  }
+
+  Map<String, dynamic> toJson() {
+    return {
+      'id': id,
+      'name': name,
+      'ip': ip,
+      'host': host,
+      if (protocol.trim().isNotEmpty) 'protocol': protocol,
+      if (routePort != null) 'port': routePort,
+    };
+  }
+
+  static int? _asNullableInt(Object? value) {
+    if (value is int) return value;
+    if (value is num) return value.round();
+    return int.tryParse(value?.toString() ?? '');
+  }
+}
+
+class CustomLineDownloadRoute {
+  final String url;
+  final Map<String, String> headers;
+  final String? nodeName;
+  final String? originalHost;
+  final HostMappingProxyEndpoint? proxy;
+
+  const CustomLineDownloadRoute({
+    required this.url,
+    this.headers = const {},
+    this.nodeName,
+    this.originalHost,
+    this.proxy,
+  });
+
+  bool get changed => proxy != null || headers.isNotEmpty;
+}

lib/services/download_service.dart

@@ -7,6 +7,7 @@ import 'package:path_provider/path_provider.dart';
 import 'package:permission_handler/permission_handler.dart';
 import '../core/constants/storage_keys.dart';
 import '../data/models/download_task_model.dart';
+import 'custom_line_service.dart';
 import 'file_service.dart';
 import 'storage_service.dart';
 import '../core/utils/app_logger.dart';
@@ -261,7 +262,14 @@ class DownloadService {
         await file.delete();
       }
 
-      return _startBdDownload(task, url, dir);
+      final route = await CustomLineService.instance.routeDownloadUrl(url);
+      if (route.changed) {
+        AppLogger.d(
+          '自定义线路下载代理已应用: node=${route.nodeName}, host=${route.originalHost}, proxy=${route.proxy?.proxyUri}',
+        );
+      }
+
+      return _startBdDownload(task, route.url, dir, headers: route.headers);
     } catch (e) {
       AppLogger.d('下载失败: $e');
       rethrow;
@@ -272,12 +280,15 @@ class DownloadService {
   Future<String?> _startBdDownload(
     DownloadTaskModel task,
     String url,
-    Directory dir,
+    Directory dir, {
-  ) async {
+    Map<String, String> headers = const {},
+  }) async {
+    await _configureCustomLineProxy();
     final wifiOnly = await isWifiOnlyEnabled();
     final retries = await getRetries();
     final bdTask = bd.DownloadTask(
       url: url,
+      headers: headers,
       filename: task.fileName,
       directory: dir.path,
       baseDirectory: bd.BaseDirectory.root,
@@ -340,10 +351,19 @@ class DownloadService {
       }
 
       // 恢复任务：不删除部分文件，使用 resume 方式重建 bdTask
+      final route = await CustomLineService.instance.routeDownloadUrl(url);
+      if (route.changed) {
+        AppLogger.d(
+          '自定义线路下载代理已应用: node=${route.nodeName}, host=${route.originalHost}, proxy=${route.proxy?.proxyUri}',
+        );
+      }
+
+      await _configureCustomLineProxy();
       final wifiOnly = await isWifiOnlyEnabled();
       final retries = await getRetries();
       final bdTask = bd.DownloadTask(
-        url: url,
+        url: route.url,
+        headers: route.headers,
         filename: task.fileName,
         directory: dir.path,
         baseDirectory: bd.BaseDirectory.root,
@@ -382,6 +402,14 @@ class DownloadService {
     }
   }
 
+  Future<void> _configureCustomLineProxy() async {
+    final endpoint = CustomLineService.instance.currentProxyEndpoint;
+    final config = endpoint == null ? false : (endpoint.host, endpoint.port);
+    await bd.FileDownloader().configure(
+      globalConfig: (bd.Config.proxy, config),
+    );
+  }
+
   /// 暂停下载
   Future<void> pauseDownload(String taskId) async {
     final bdTask = _bdTasks[taskId];

lib/services/file_service.dart

@@ -1,6 +1,7 @@
 import 'api_service.dart';
 import '../core/utils/app_logger.dart';
 import '../core/utils/file_utils.dart';
+import 'custom_line_service.dart';
 
 /// 文件服务
 class FileService {
@@ -156,10 +157,25 @@ class FileService {
       data: data,
       headers: headers,
     );
+    await _activateCustomLineForUrls(response);
 
     return response;
   }
 
+  Future<void> _activateCustomLineForUrls(Map<String, dynamic> response) async {
+    final urls = response['urls'];
+    if (urls is! List) return;
+
+    final resolvedUrls = <String>[];
+    for (final item in urls) {
+      if (item is! Map) continue;
+      final url = item['url']?.toString();
+      if (url == null || url.isEmpty) continue;
+      resolvedUrls.add(url);
+    }
+    await CustomLineService.instance.activateSelectedNodeForUrls(resolvedUrls);
+  }
+
   /// 创建直接链接（分享链接）
   Future<List<Map<String, dynamic>>> createDirectLinks({
     required List<String> uris,

lib/services/host_mapping_proxy_service.dart

@@ -0,0 +1,314 @@
+import 'dart:async';
+import 'dart:convert';
+import 'dart:io';
+import 'dart:typed_data';
+
+import '../core/utils/app_logger.dart';
+
+class HostMappingProxyService {
+  HostMappingProxyService._();
+
+  static final HostMappingProxyService instance = HostMappingProxyService._();
+
+  ServerSocket? _server;
+  HostMappingProxyEndpoint? _endpoint;
+  Map<String, String> _hostMap = const {};
+
+  HostMappingProxyEndpoint? get endpoint => _hostMap.isEmpty ? null : _endpoint;
+
+  Future<HostMappingProxyEndpoint?> configure(
+    Map<String, String> hostMap,
+  ) async {
+    final cleaned = <String, String>{};
+    for (final entry in hostMap.entries) {
+      final host = _normalizeHost(entry.key);
+      final ip = entry.value.trim();
+      if (host.isNotEmpty && ip.isNotEmpty) {
+        cleaned[host] = ip;
+      }
+    }
+
+    if (cleaned.isEmpty) {
+      await stop();
+      return null;
+    }
+
+    _hostMap = cleaned;
+    if (_server == null) {
+      _server = await ServerSocket.bind(InternetAddress.loopbackIPv4, 0);
+      _endpoint = HostMappingProxyEndpoint(
+        host: InternetAddress.loopbackIPv4.address,
+        port: _server!.port,
+      );
+      _server!.listen(
+        _handleClient,
+        onError: (e) {
+          AppLogger.d('自定义线路本地代理监听错误: $e');
+        },
+      );
+      AppLogger.d('自定义线路本地代理已启动: ${_endpoint!.proxyUri}');
+    }
+    return _endpoint;
+  }
+
+  Future<void> stop() async {
+    _hostMap = const {};
+    final server = _server;
+    _server = null;
+    _endpoint = null;
+    if (server != null) {
+      await server.close();
+      AppLogger.d('自定义线路本地代理已关闭');
+    }
+  }
+
+  void _handleClient(Socket client) {
+    unawaited(_serveClient(client));
+  }
+
+  Future<void> _serveClient(Socket client) async {
+    Socket? remote;
+    StreamController<List<int>>? rest;
+    try {
+      client.setOption(SocketOption.tcpNoDelay, true);
+      final initial = await _readInitialRequest(client);
+      rest = initial.rest;
+      final lines = latin1.decode(initial.header).split('\r\n');
+      if (lines.isEmpty || lines.first.trim().isEmpty) {
+        throw const FormatException('empty proxy request');
+      }
+
+      final first = lines.first.split(' ');
+      if (first.length < 3) {
+        throw FormatException('invalid proxy request: ${lines.first}');
+      }
+
+      final method = first[0].toUpperCase();
+      if (method == 'CONNECT') {
+        final target = _splitAuthority(first[1], 443);
+        remote = await _connectMapped(target.host, target.port);
+        client.add(utf8.encode('HTTP/1.1 200 Connection Established\r\n\r\n'));
+        await client.flush();
+      } else {
+        final target = _httpTarget(first[1], lines);
+        remote = await _connectMapped(target.host, target.port);
+        remote.add(_rewriteHttpHeader(initial.header, target.requestTarget));
+      }
+
+      remote.setOption(SocketOption.tcpNoDelay, true);
+      unawaited(rest.stream.pipe(remote).catchError((_) {}));
+      unawaited(remote.cast<List<int>>().pipe(client).catchError((_) {}));
+    } catch (e) {
+      AppLogger.d('自定义线路本地代理请求失败: $e');
+      try {
+        client.add(utf8.encode('HTTP/1.1 502 Bad Gateway\r\n\r\n'));
+        await client.flush();
+      } catch (_) {}
+      await rest?.close();
+      remote?.destroy();
+      client.destroy();
+    }
+  }
+
+  Future<_ProxyInitialRequest> _readInitialRequest(Socket socket) {
+    final completer = Completer<_ProxyInitialRequest>();
+    final builder = BytesBuilder(copy: false);
+    final rest = StreamController<List<int>>(sync: true);
+    late StreamSubscription<Uint8List> subscription;
+
+    subscription = socket.listen(
+      (chunk) {
+        if (completer.isCompleted) {
+          rest.add(chunk);
+          return;
+        }
+
+        builder.add(chunk);
+        final bytes = builder.toBytes();
+        final end = _headerEnd(bytes);
+        if (end >= 0) {
+          final headerEnd = end + 4;
+          completer.complete(
+            _ProxyInitialRequest(
+              header: bytes.sublist(0, headerEnd),
+              rest: rest,
+            ),
+          );
+          if (bytes.length > headerEnd) {
+            rest.add(bytes.sublist(headerEnd));
+          }
+        } else if (bytes.length > 64 * 1024) {
+          completer.completeError(
+            const FormatException('proxy request header too large'),
+          );
+          unawaited(subscription.cancel());
+          unawaited(rest.close());
+        }
+      },
+      onError: (Object error, StackTrace stackTrace) {
+        if (!completer.isCompleted) {
+          completer.completeError(error, stackTrace);
+        } else {
+          rest.addError(error, stackTrace);
+        }
+      },
+      onDone: () {
+        if (!completer.isCompleted) {
+          completer.completeError(const SocketException('proxy client closed'));
+        }
+        unawaited(rest.close());
+      },
+      cancelOnError: false,
+    );
+
+    return completer.future;
+  }
+
+  int _headerEnd(List<int> bytes) {
+    for (var i = 0; i <= bytes.length - 4; i++) {
+      if (bytes[i] == 13 &&
+          bytes[i + 1] == 10 &&
+          bytes[i + 2] == 13 &&
+          bytes[i + 3] == 10) {
+        return i;
+      }
+    }
+    return -1;
+  }
+
+  Future<Socket> _connectMapped(String host, int port) {
+    final normalized = _normalizeHost(host);
+    final targetHost = _hostMap[normalized] ?? host;
+    return Socket.connect(
+      targetHost,
+      port,
+      timeout: const Duration(seconds: 12),
+    );
+  }
+
+  _ProxyTarget _httpTarget(String target, List<String> lines) {
+    final uri = Uri.tryParse(target);
+    if (uri != null && uri.hasScheme && uri.host.isNotEmpty) {
+      return _ProxyTarget(
+        host: uri.host,
+        port: uri.hasPort ? uri.port : (uri.scheme == 'https' ? 443 : 80),
+        requestTarget: _originForm(uri),
+      );
+    }
+
+    final hostHeader = _headerValue(lines, 'Host');
+    final authority = _splitAuthority(hostHeader, 80);
+    return _ProxyTarget(
+      host: authority.host,
+      port: authority.port,
+      requestTarget: target,
+    );
+  }
+
+  List<int> _rewriteHttpHeader(List<int> header, String requestTarget) {
+    final text = latin1.decode(header);
+    final lines = text.split('\r\n');
+    final first = lines.first.split(' ');
+    first[1] = requestTarget.isEmpty ? '/' : requestTarget;
+    lines[0] = first.join(' ');
+    final filtered = lines
+        .where((line) => !line.toLowerCase().startsWith('proxy-connection:'))
+        .join('\r\n');
+    return latin1.encode(filtered);
+  }
+
+  String _originForm(Uri uri) {
+    final path = uri.path.isEmpty ? '/' : uri.path;
+    return uri.hasQuery ? '$path?${uri.query}' : path;
+  }
+
+  String _headerValue(List<String> lines, String name) {
+    final prefix = '${name.toLowerCase()}:';
+    for (final line in lines.skip(1)) {
+      if (line.toLowerCase().startsWith(prefix)) {
+        return line.substring(line.indexOf(':') + 1).trim();
+      }
+    }
+    throw FormatException('missing $name header');
+  }
+
+  _ProxyAuthority _splitAuthority(String value, int defaultPort) {
+    final authority = value.trim();
+    if (authority.startsWith('[')) {
+      final end = authority.indexOf(']');
+      if (end > 0) {
+        final host = authority.substring(1, end);
+        final port = authority.length > end + 2
+            ? int.tryParse(authority.substring(end + 2)) ?? defaultPort
+            : defaultPort;
+        return _ProxyAuthority(host, port);
+      }
+    }
+
+    final colon = authority.lastIndexOf(':');
+    if (colon > 0 && colon < authority.length - 1) {
+      final port = int.tryParse(authority.substring(colon + 1));
+      if (port != null) {
+        return _ProxyAuthority(authority.substring(0, colon), port);
+      }
+    }
+    return _ProxyAuthority(authority, defaultPort);
+  }
+
+  String _normalizeHost(String host) {
+    final value = host.trim();
+    final uri = Uri.tryParse(value);
+    final resolved = uri != null && uri.hasScheme && uri.host.isNotEmpty
+        ? uri.host
+        : value;
+    return resolved.toLowerCase().replaceAll(RegExp(r'\.$'), '');
+  }
+}
+
+class HostMappingProxyEndpoint {
+  final String host;
+  final int port;
+
+  const HostMappingProxyEndpoint({required this.host, required this.port});
+
+  String get proxyUri => 'http://$host:$port';
+}
+
+class HostMappingHttpOverrides extends HttpOverrides {
+  @override
+  HttpClient createHttpClient(SecurityContext? context) {
+    final client = super.createHttpClient(context);
+    client.findProxy = (_) {
+      final endpoint = HostMappingProxyService.instance.endpoint;
+      if (endpoint == null) return 'DIRECT';
+      return 'PROXY ${endpoint.host}:${endpoint.port}; DIRECT';
+    };
+    return client;
+  }
+}
+
+class _ProxyInitialRequest {
+  final Uint8List header;
+  final StreamController<List<int>> rest;
+
+  const _ProxyInitialRequest({required this.header, required this.rest});
+}
+
+class _ProxyAuthority {
+  final String host;
+  final int port;
+
+  const _ProxyAuthority(this.host, this.port);
+}
+
+class _ProxyTarget {
+  final String host;
+  final int port;
+  final String requestTarget;
+
+  const _ProxyTarget({
+    required this.host,
+    required this.port,
+    required this.requestTarget,
+  });
+}

lib/services/server_service.dart

@@ -45,12 +45,7 @@ class ServerService {
     } catch (e) {
       AppLogger.d('加载服务器列表失败: $e');
       // 加载失败时使用默认服务器
-      _servers = [
+      _servers = [ServerModel(label: _defaultLabel, baseUrl: _defaultBaseUrl)];
-        ServerModel(
-          label: _defaultLabel,
-          baseUrl: _defaultBaseUrl,
-        ),
-      ];
       _currentServer = _servers.first;
     }
   }
@@ -65,15 +60,10 @@ class ServerService {
       }
     }
 
-    _currentServer = (savedDefaultServer ??
+    _currentServer =
-            ServerModel(
+        (savedDefaultServer ??
-              label: _defaultLabel,
+                ServerModel(label: _defaultLabel, baseUrl: _defaultBaseUrl))
-              baseUrl: _defaultBaseUrl,
+            .copyWith(label: _defaultLabel, baseUrl: _defaultBaseUrl);
-            ))
-        .copyWith(
-      label: _defaultLabel,
-      baseUrl: _defaultBaseUrl,
-    );
 
     _servers = [_currentServer!];
   }
@@ -91,7 +81,9 @@ class ServerService {
   /// 保存上次选中的服务器
   Future<void> _saveLastSelected() async {
     if (_currentServer != null) {
-      await StorageService.instance.setLastSelectedServerLabel(_currentServer!.label);
+      await StorageService.instance.setLastSelectedServerLabel(
+        _currentServer!.label,
+      );
     }
   }
 
@@ -125,16 +117,21 @@ class ServerService {
     String? password,
     UserModel? user,
     bool? rememberMe,
+    bool clearEmail = false,
+    bool clearPassword = false,
+    bool clearUser = false,
   }) async {
     if (_currentServer == null) {
       throw Exception('没有选中的服务器');
     }
 
-    _currentServer = _currentServer!.copyWith(
+    _currentServer = ServerModel(
-      email: email,
+      label: _currentServer!.label,
-      password: password,
+      baseUrl: _currentServer!.baseUrl,
-      user: user,
       rememberMe: rememberMe ?? _currentServer!.rememberMe,
+      email: clearEmail ? null : (email ?? _currentServer!.email),
+      password: clearPassword ? null : (password ?? _currentServer!.password),
+      user: clearUser ? null : (user ?? _currentServer!.user),
     );
 
     // 更新列表中的引用
@@ -152,17 +149,15 @@ class ServerService {
       email: null,
       password: null,
       user: null,
+      clearEmail: true,
+      clearPassword: true,
+      clearUser: true,
     );
   }
 
   /// 重置为默认服务器列表
   Future<void> resetToDefault() async {
-    _servers = [
+    _servers = [ServerModel(label: _defaultLabel, baseUrl: _defaultBaseUrl)];
-      ServerModel(
-        label: _defaultLabel,
-        baseUrl: _defaultBaseUrl,
-      ),
-    ];
     _currentServer = _servers.first;
     await _saveServers();
     await _saveLastSelected();

lib/services/thumbnail_service.dart

@@ -2,6 +2,7 @@ import 'api_service.dart';
 import '../core/utils/app_logger.dart';
 import '../core/utils/file_utils.dart';
 import '../core/utils/time_flow_decoder.dart';
+import 'custom_line_service.dart';
 
 /// 缩略图缓存条目
 class _ThumbCacheEntry {
@@ -41,6 +42,9 @@ class ThumbnailService {
     // 1. 检查内存缓存
     final cached = _urlCache[cacheKey];
     if (cached != null && !cached.isExpired) {
+      await CustomLineService.instance.activateSelectedNodeForUrl(
+        cached.imageUrl,
+      );
       return cached.imageUrl;
     }
     if (cached != null) {
@@ -64,7 +68,10 @@ class ThumbnailService {
     }
   }
 
-  Future<String?> _fetchThumbnailUrl(String fileUri, String? contextHint) async {
+  Future<String?> _fetchThumbnailUrl(
+    String fileUri,
+    String? contextHint,
+  ) async {
     try {
       final uri = FileUtils.toCloudreveUri(fileUri);
       final headers = contextHint != null
@@ -97,12 +104,15 @@ class ThumbnailService {
       if (url.isEmpty) return null;
 
       AppLogger.d('ThumbnailService: resolved URL for $fileUri = $url');
+      await CustomLineService.instance.activateSelectedNodeForUrl(url);
 
       // 解析过期时间，缓存提前 30 秒过期
       DateTime expiresAt;
       if (expiresStr != null) {
         try {
-          expiresAt = DateTime.parse(expiresStr).subtract(const Duration(seconds: 30));
+          expiresAt = DateTime.parse(
+            expiresStr,
+          ).subtract(const Duration(seconds: 30));
         } catch (_) {
           expiresAt = DateTime.now().add(const Duration(minutes: 5));
         }
@@ -118,7 +128,9 @@ class ThumbnailService {
 
       return url;
     } catch (e) {
-      AppLogger.d('ThumbnailService: failed to get thumbnail URL for $fileUri: $e');
+      AppLogger.d(
+        'ThumbnailService: failed to get thumbnail URL for $fileUri: $e',
+      );
       return null;
     }
   }

test/custom_line_service_test.dart

@@ -0,0 +1,143 @@
+import 'package:cloudreve4_flutter/data/models/user_model.dart';
+import 'package:cloudreve4_flutter/services/custom_line_service.dart';
+import 'package:cloudreve4_flutter/services/server_service.dart';
+import 'package:cloudreve4_flutter/services/storage_service.dart';
+import 'package:flutter_test/flutter_test.dart';
+import 'package:shared_preferences/shared_preferences.dart';
+
+void main() {
+  test('selected node json round trip preserves rewrite fields', () {
+    const node = SelectedCustomLineNode(
+      id: 'node-1',
+      name: 'HK 01',
+      ip: '203.0.113.10',
+      host: 'node.example.com',
+      protocol: 'https',
+      port: 443,
+    );
+
+    final restored = SelectedCustomLineNode.fromJson(node.toJson());
+
+    expect(restored.id, 'node-1');
+    expect(restored.name, 'HK 01');
+    expect(restored.ip, '203.0.113.10');
+    expect(restored.host, 'node.example.com');
+    expect(restored.protocol, 'https');
+    expect(restored.port, 443);
+    expect(restored.canRewriteDownloadUrl, isTrue);
+  });
+
+  test('download route defaults to unchanged', () {
+    const route = CustomLineDownloadRoute(url: 'https://pan.example.com/file');
+
+    expect(route.changed, isFalse);
+    expect(route.headers, isEmpty);
+  });
+
+  test(
+    'routeDownloadUrl keeps url unchanged and enables host mapping proxy',
+    () async {
+      SharedPreferences.setMockInitialValues({});
+      await ServerService.instance.init();
+      await ServerService.instance.updateCurrentServerLogin(
+        user: UserModel(
+          id: 'user-1',
+          nickname: 'VIP',
+          createdAt: DateTime(2026, 1),
+          group: GroupModel(id: 'vip', name: 'VIP'),
+        ),
+      );
+      await CustomLineService.instance.setSelectedNode(
+        const SelectedCustomLineNode(
+          id: 'node-1',
+          name: 'HK 01',
+          ip: '203.0.113.10',
+          host: 'node.example.com',
+        ),
+      );
+
+      final route = await CustomLineService.instance.routeDownloadUrl(
+        'https://storage.example.com:8443/download/file.txt?token=abc',
+      );
+
+      expect(
+        route.url,
+        'https://storage.example.com:8443/download/file.txt?token=abc',
+      );
+      expect(route.headers, isEmpty);
+      expect(route.changed, isTrue);
+      expect(route.originalHost, 'storage.example.com');
+      expect(route.proxy, isNotNull);
+      expect(route.proxy!.host, '127.0.0.1');
+      expect(route.proxy!.port, greaterThan(0));
+
+      await CustomLineService.instance.clearSelectedNode();
+      await StorageService.instance.clear();
+    },
+  );
+
+  test('routeDownloadUrl stays unchanged for User group', () async {
+    SharedPreferences.setMockInitialValues({});
+    await ServerService.instance.init();
+    await ServerService.instance.updateCurrentServerLogin(
+      user: UserModel(
+        id: 'user-2',
+        nickname: 'Normal',
+        createdAt: DateTime(2026, 1),
+        group: GroupModel(id: 'user', name: 'User'),
+      ),
+    );
+    await CustomLineService.instance.setSelectedNode(
+      const SelectedCustomLineNode(
+        id: 'node-1',
+        name: 'HK 01',
+        ip: '203.0.113.10',
+        host: 'node.example.com',
+      ),
+    );
+
+    final route = await CustomLineService.instance.routeDownloadUrl(
+      'https://storage.example.com/download/file.txt',
+    );
+
+    expect(route.url, 'https://storage.example.com/download/file.txt');
+    expect(route.headers, isEmpty);
+    expect(route.changed, isFalse);
+
+    await CustomLineService.instance.clearSelectedNode();
+    await StorageService.instance.clear();
+  });
+
+  test('routeDownloadUrl stays unchanged after login is cleared', () async {
+    SharedPreferences.setMockInitialValues({});
+    await ServerService.instance.init();
+    await ServerService.instance.updateCurrentServerLogin(
+      user: UserModel(
+        id: 'user-3',
+        nickname: 'VIP',
+        createdAt: DateTime(2026, 1),
+        group: GroupModel(id: 'vip', name: 'VIP'),
+      ),
+    );
+    await CustomLineService.instance.setSelectedNode(
+      const SelectedCustomLineNode(
+        id: 'node-1',
+        name: 'HK 01',
+        ip: '203.0.113.10',
+        host: 'node.example.com',
+      ),
+    );
+    await ServerService.instance.clearCurrentServerLogin();
+
+    final route = await CustomLineService.instance.routeDownloadUrl(
+      'https://storage.example.com/download/file.txt',
+    );
+
+    expect(route.url, 'https://storage.example.com/download/file.txt');
+    expect(route.headers, isEmpty);
+    expect(route.changed, isFalse);
+
+    await CustomLineService.instance.clearSelectedNode();
+    await StorageService.instance.clear();
+  });
+}