完善PR审查后出现的问题

.gitea/workflows/android-release.yml

@@ -191,7 +191,7 @@ jobs:
             exit 1
           fi
 
-          if [[ "$GITHUB_REF" == refs/tags/android-app-v* ]]; then
+          if [[ "$GITHUB_REF" == refs/tags/v* ]]; then
             tag_name="${GITHUB_REF#refs/tags/}"
           else
             app_version="$(awk -F '[:+]' '/^version:/ {gsub(/[[:space:]]/, "", $2); print $2; exit}' pubspec.yaml)"
@@ -199,7 +199,7 @@ jobs:
               echo "Unable to resolve app version from pubspec.yaml."
               exit 1
             fi
-            tag_name="android-app-v${app_version}"
+            tag_name="v${app_version}"
           fi
 
           echo "tag_name=$tag_name" >> "$GITHUB_OUTPUT"
@@ -249,7 +249,7 @@ jobs:
 
           releases_url="$GITEA_API_URL/repos/$GITEA_OWNER/$GITEA_REPO/releases"
           release_by_tag_url="$releases_url/tags/$TAG_NAME"
-          export RELEASE_TITLE="Android App APK ${TAG_NAME}"
+          export RELEASE_TITLE="${TAG_NAME}"
           export RELEASE_BODY="Android app installation package (APK) for ${TAG_NAME}."
 
           status="$(curl -sS -o release.json -w "%{http_code}" \
@@ -265,7 +265,7 @@ jobs:
           print(json.dumps({
               "tag_name": tag,
               "target_commitish": os.environ.get("TARGET_COMMITISH", ""),
-              "name": f"Android App APK {tag}",
+              "name": os.environ["RELEASE_TITLE"],
               "body": f"Android app installation package (APK) for {tag}.",
               "draft": False,
               "prerelease": False,
@@ -353,7 +353,7 @@ jobs:
             fi
           done < asset-ids-to-delete.txt
 
-          release_asset_name="gongyun-${TAG_NAME}.apk"
+          release_asset_name="app-release-${TAG_NAME}.apk"
           curl -sS -f \
             -X POST \
             -H "Authorization: token $GITEA_TOKEN" \

lib/core/constants/storage_keys.dart

@@ -39,4 +39,8 @@ class StorageKeys {
   // 公告
   static const String siteAnnouncementDismissedFingerprint =
       'site_announcement_dismissed_fingerprint';
+
+  // 版本更新
+  static const String updatePromptSkipUntil = 'update_prompt_skip_until';
+  static const String updatePromptSkipVersion = 'update_prompt_skip_version';
 }

lib/presentation/pages/preview/cloudreve_file_app_page.dart

@@ -325,8 +325,12 @@ class _CloudreveFileAppPageState extends State<CloudreveFileAppPage> {
         initialSettings: desktop.InAppWebViewSettings(
           javaScriptEnabled: true,
           domStorageEnabled: true,
+          isInspectable: true,
+          cacheMode: desktop.CacheMode.LOAD_DEFAULT,
+          supportMultipleWindows: true,
           transparentBackground: true,
-          supportZoom: false,
+          supportZoom: true,
+          useHybridComposition: true,
         ),
         onWebViewCreated: (controller) async {
           _desktopController = controller;

lib/presentation/pages/settings/network_test_page.dart

@@ -0,0 +1,800 @@
+import 'dart:async';
+import 'dart:convert';
+import 'dart:math';
+
+import 'package:flutter/material.dart';
+import 'package:http/http.dart' as http;
+import 'package:url_launcher/url_launcher.dart';
+
+import '../../widgets/desktop_constrained.dart';
+import '../../widgets/toast_helper.dart';
+
+enum _NetworkTestTab { network, service, custom }
+
+class NetworkTestPage extends StatefulWidget {
+  const NetworkTestPage({super.key});
+
+  @override
+  State<NetworkTestPage> createState() => _NetworkTestPageState();
+}
+
+class _NetworkTestPageState extends State<NetworkTestPage> {
+  static final _panUri = Uri.parse('https://pan.gongyun.org');
+  static final _infoUri = Uri.parse('https://www.gongyun.org/appnetinfo.html');
+  static final _primaryIpLookupUri = Uri.parse('https://ipwho.is/');
+  static final _secondaryIpLookupUri = Uri.parse('https://ipapi.co/json/');
+  static const _probeHeaders = {'Cache-Control': 'no-cache'};
+  static const _probeGetFallbackHeaders = {
+    'Cache-Control': 'no-cache',
+    'Range': 'bytes=0-0',
+  };
+
+  _NetworkTestTab _tab = _NetworkTestTab.network;
+  bool _networkLoading = false;
+  bool _serviceLoading = false;
+  _NetworkDiagnostics? _networkDiagnostics;
+  _ServiceDiagnostics? _serviceDiagnostics;
+  String? _networkError;
+  String? _serviceError;
+
+  @override
+  void initState() {
+    super.initState();
+    WidgetsBinding.instance.addPostFrameCallback((_) => _runNetworkTest());
+  }
+
+  @override
+  Widget build(BuildContext context) {
+    return Scaffold(
+      appBar: AppBar(
+        title: const Text('网络测试'),
+        actions: [
+          IconButton(
+            tooltip: '说明',
+            icon: const Icon(Icons.info_outline),
+            onPressed: () => _openExternalUrl(_infoUri),
+          ),
+        ],
+      ),
+      body: DesktopConstrained(
+        child: Column(
+          children: [
+            Padding(
+              padding: const EdgeInsets.fromLTRB(16, 12, 16, 8),
+              child: SizedBox(
+                width: double.infinity,
+                child: SegmentedButton<_NetworkTestTab>(
+                  segments: const [
+                    ButtonSegment(
+                      value: _NetworkTestTab.network,
+                      icon: Icon(Icons.public),
+                      label: Text('网络'),
+                    ),
+                    ButtonSegment(
+                      value: _NetworkTestTab.service,
+                      icon: Icon(Icons.dns_outlined),
+                      label: Text('服务'),
+                    ),
+                    ButtonSegment(
+                      value: _NetworkTestTab.custom,
+                      icon: Icon(Icons.route_outlined),
+                      label: Text('自定义线路'),
+                    ),
+                  ],
+                  selected: {_tab},
+                  onSelectionChanged: (selection) {
+                    final selected = selection.first;
+                    if (selected == _NetworkTestTab.custom) {
+                      _showCustomUnavailableDialog();
+                      return;
+                    }
+                    setState(() => _tab = selected);
+                    if (selected == _NetworkTestTab.network &&
+                        _networkDiagnostics == null &&
+                        !_networkLoading) {
+                      _runNetworkTest();
+                    }
+                    if (selected == _NetworkTestTab.service &&
+                        _serviceDiagnostics == null &&
+                        !_serviceLoading) {
+                      _runServiceTest();
+                    }
+                  },
+                ),
+              ),
+            ),
+            Expanded(
+              child: AnimatedSwitcher(
+                duration: const Duration(milliseconds: 180),
+                child: switch (_tab) {
+                  _NetworkTestTab.network => _NetworkPanel(
+                    key: const ValueKey('network'),
+                    loading: _networkLoading,
+                    error: _networkError,
+                    diagnostics: _networkDiagnostics,
+                    onRefresh: _runNetworkTest,
+                  ),
+                  _NetworkTestTab.service => _ServicePanel(
+                    key: const ValueKey('service'),
+                    loading: _serviceLoading,
+                    error: _serviceError,
+                    diagnostics: _serviceDiagnostics,
+                    onRefresh: _runServiceTest,
+                  ),
+                  _NetworkTestTab.custom => const SizedBox.shrink(),
+                },
+              ),
+            ),
+          ],
+        ),
+      ),
+    );
+  }
+
+  Future<void> _showCustomUnavailableDialog() async {
+    await showDialog<void>(
+      context: context,
+      builder: (dialogContext) => AlertDialog(
+        title: const Text('自定义线路'),
+        content: const Text('自定义线路为会员功能，当前版本暂未开放。'),
+        actions: [
+          FilledButton(
+            onPressed: () => Navigator.of(dialogContext).pop(),
+            child: const Text('好'),
+          ),
+        ],
+      ),
+    );
+  }
+
+  Future<void> _openExternalUrl(Uri uri) async {
+    try {
+      final opened = await launchUrl(uri, mode: LaunchMode.externalApplication);
+      if (!opened) {
+        ToastHelper.failure('无法打开链接: $uri');
+      }
+    } catch (e) {
+      ToastHelper.failure('无法打开链接: $e');
+    }
+  }
+
+  Future<void> _runNetworkTest() async {
+    if (_networkLoading) return;
+
+    setState(() {
+      _networkLoading = true;
+      _networkError = null;
+    });
+
+    try {
+      final ipFuture = _fetchIpInfo();
+      final panProbe = await _probeUri(_panUri);
+      final stability = await _testStability(_panUri);
+      final ipInfo = await ipFuture;
+
+      if (!mounted) return;
+      setState(() {
+        _networkDiagnostics = _NetworkDiagnostics(
+          panReachable: panProbe.reachable,
+          latencyMs: panProbe.latencyMs,
+          ipInfo: ipInfo,
+          stable: stability.stable,
+          sampleCount: stability.sampleCount,
+          successCount: stability.successCount,
+        );
+      });
+    } catch (e) {
+      if (mounted) setState(() => _networkError = e.toString());
+    } finally {
+      if (mounted) setState(() => _networkLoading = false);
+    }
+  }
+
+  Future<void> _runServiceTest() async {
+    if (_serviceLoading) return;
+
+    setState(() {
+      _serviceLoading = true;
+      _serviceError = null;
+    });
+
+    try {
+      final monitorHeartbeats = await _fetchMonitorHeartbeats('gongyun');
+
+      _ServiceItem monitor(String label, int monitorId) {
+        return _monitorItem(
+          label: label,
+          monitorId: monitorId,
+          heartbeats: monitorHeartbeats,
+        );
+      }
+
+      final telegramBot = await _probeItem(
+        label: 'Telegram bot',
+        uri: Uri.parse('https://bot.mygongyun.com'),
+        healthyStatusCodes: const {200, 401},
+      );
+
+      final business = <_ServiceItem>[
+        monitor('官网', 3),
+        monitor('网盘', 2),
+        monitor('短链', 37),
+        monitor('SSO', 39),
+        telegramBot,
+      ];
+
+      final dc = <_ServiceItem>[
+        monitor('DC3-CN-SZ', 13),
+        monitor('DC3-CN-MIAMI', 11),
+        monitor('DC3-CN-NY', 12),
+        monitor('DC3-CN-LV', 10),
+      ];
+
+      final backend = <_ServiceItem>[monitor('数据库', 32), monitor('键值对数据库', 36)];
+
+      final storage = <_ServiceItem>[
+        monitor('DC-S-NA-1', 5),
+        monitor('DC-S-NA-2', 6),
+        monitor('DC-S-EU', 7),
+        monitor('DC-S-EP', 8),
+      ];
+
+      final acceleration = <_ServiceItem>[
+        monitor('香港', 18),
+        monitor('香港', 19),
+        monitor('新加坡', 22),
+        monitor('洛杉矶', 24),
+        monitor('蒙特利尔', 21),
+      ];
+
+      if (!mounted) return;
+      setState(() {
+        _serviceDiagnostics = _ServiceDiagnostics(
+          fetchedAt: DateTime.now(),
+          business: business,
+          dc: dc,
+          backend: backend,
+          storage: storage,
+          acceleration: acceleration,
+        );
+      });
+    } catch (e) {
+      if (mounted) setState(() => _serviceError = e.toString());
+    } finally {
+      if (mounted) setState(() => _serviceLoading = false);
+    }
+  }
+
+  Future<_IpInfo> _fetchIpInfo() async {
+    try {
+      final response = await http
+          .get(_primaryIpLookupUri)
+          .timeout(const Duration(seconds: 8));
+      if (response.statusCode >= 200 && response.statusCode < 300) {
+        final data = jsonDecode(response.body) as Map<String, dynamic>;
+        if (data['success'] != false) {
+          final connection = data['connection'];
+          final connectionMap = connection is Map<String, dynamic>
+              ? connection
+              : <String, dynamic>{};
+          return _IpInfo(
+            ip: data['ip']?.toString() ?? '未知',
+            asn: connectionMap['asn']?.toString() ?? '未知',
+            operatorName: connectionMap['isp']?.toString().isNotEmpty == true
+                ? connectionMap['isp'].toString()
+                : (connectionMap['org']?.toString() ?? '未知'),
+          );
+        }
+      }
+    } catch (_) {
+      // Fall back to the next public endpoint.
+    }
+
+    try {
+      final response = await http
+          .get(_secondaryIpLookupUri)
+          .timeout(const Duration(seconds: 8));
+      if (response.statusCode >= 200 && response.statusCode < 300) {
+        final data = jsonDecode(response.body) as Map<String, dynamic>;
+        return _IpInfo(
+          ip: data['ip']?.toString() ?? '未知',
+          asn: data['asn']?.toString() ?? '未知',
+          operatorName: data['org']?.toString() ?? '未知',
+        );
+      }
+    } catch (_) {
+      // Handled by the default value below.
+    }
+
+    return const _IpInfo(ip: '未知', asn: '未知', operatorName: '未知');
+  }
+
+  _ServiceItem _monitorItem({
+    required String label,
+    required int monitorId,
+    required Map<int, _MonitorHeartbeat> heartbeats,
+  }) {
+    final heartbeat = heartbeats[monitorId];
+    return _ServiceItem(
+      label: label,
+      online: heartbeat?.online ?? false,
+      latencyMs: heartbeat?.pingMs,
+    );
+  }
+
+  Future<Map<int, _MonitorHeartbeat>> _fetchMonitorHeartbeats(
+    String pageId,
+  ) async {
+    try {
+      final response = await http
+          .get(
+            Uri.parse('https://status.gongyun.org/api/monitor?pageId=$pageId'),
+            headers: _probeHeaders,
+          )
+          .timeout(const Duration(seconds: 10));
+      if (response.statusCode < 200 || response.statusCode >= 300) {
+        return const {};
+      }
+
+      final decoded = jsonDecode(response.body);
+      if (decoded is! Map<String, dynamic>) return const {};
+      final data = decoded['data'];
+      if (data is! Map<String, dynamic>) return const {};
+      final heartbeatList = data['heartbeatList'];
+      if (heartbeatList is! Map<String, dynamic>) return const {};
+
+      final result = <int, _MonitorHeartbeat>{};
+      for (final entry in heartbeatList.entries) {
+        final monitorId = int.tryParse(entry.key);
+        final records = entry.value;
+        if (monitorId == null || records is! List || records.isEmpty) continue;
+        final latest = records.last;
+        if (latest is! Map<String, dynamic>) continue;
+        final status = _asInt(latest['status']);
+        final ping = _asInt(latest['ping']);
+        result[monitorId] = _MonitorHeartbeat(
+          online: status == 1,
+          pingMs: ping,
+        );
+      }
+
+      return result;
+    } catch (_) {
+      return const {};
+    }
+  }
+
+  int? _asInt(Object? value) {
+    if (value is int) return value;
+    if (value is num) return value.round();
+    return int.tryParse(value?.toString() ?? '');
+  }
+
+  Future<_ServiceItem> _probeItem({
+    required String label,
+    required Uri uri,
+    Set<int> healthyStatusCodes = const {},
+  }) async {
+    final probe = await _probeUri(uri, healthyStatusCodes: healthyStatusCodes);
+    return _ServiceItem(
+      label: label,
+      online: probe.reachable,
+      latencyMs: probe.latencyMs,
+    );
+  }
+
+  Future<_ProbeResult> _probeUri(
+    Uri uri, {
+    Set<int> healthyStatusCodes = const {},
+  }) async {
+    final stopwatch = Stopwatch()..start();
+    try {
+      var response = await http
+          .head(uri, headers: _probeHeaders)
+          .timeout(const Duration(seconds: 8));
+      if (_shouldRetryProbeWithGet(response.statusCode)) {
+        response = await http
+            .get(uri, headers: _probeGetFallbackHeaders)
+            .timeout(const Duration(seconds: 8));
+      }
+      stopwatch.stop();
+      final isHealthy = _isHealthyStatus(
+        response.statusCode,
+        healthyStatusCodes,
+      );
+      return _ProbeResult(
+        reachable: isHealthy,
+        latencyMs: stopwatch.elapsedMilliseconds,
+      );
+    } catch (_) {
+      stopwatch.stop();
+      return const _ProbeResult(reachable: false);
+    }
+  }
+
+  bool _shouldRetryProbeWithGet(int statusCode) {
+    return statusCode == 403 || statusCode == 405 || statusCode == 501;
+  }
+
+  bool _isHealthyStatus(int statusCode, Set<int> healthyStatusCodes) {
+    if (healthyStatusCodes.isNotEmpty) {
+      return healthyStatusCodes.contains(statusCode);
+    }
+    return statusCode >= 200 && statusCode < 500;
+  }
+
+  Future<_StabilityResult> _testStability(Uri uri) async {
+    final latencies = <int>[];
+    var successCount = 0;
+    const sampleCount = 3;
+
+    for (var i = 0; i < sampleCount; i++) {
+      final probe = await _probeUri(uri);
+      if (probe.reachable) {
+        successCount += 1;
+        if (probe.latencyMs != null) latencies.add(probe.latencyMs!);
+      }
+      if (i < sampleCount - 1) {
+        await Future<void>.delayed(const Duration(milliseconds: 350));
+      }
+    }
+
+    final jitter = latencies.isEmpty
+        ? 999999
+        : latencies.reduce(max) - latencies.reduce(min);
+    return _StabilityResult(
+      stable: successCount == sampleCount && jitter < 1500,
+      sampleCount: sampleCount,
+      successCount: successCount,
+    );
+  }
+}
+
+class _NetworkPanel extends StatelessWidget {
+  final bool loading;
+  final String? error;
+  final _NetworkDiagnostics? diagnostics;
+  final VoidCallback onRefresh;
+
+  const _NetworkPanel({
+    super.key,
+    required this.loading,
+    required this.error,
+    required this.diagnostics,
+    required this.onRefresh,
+  });
+
+  @override
+  Widget build(BuildContext context) {
+    final data = diagnostics;
+    final errorColor = Theme.of(context).colorScheme.error;
+    return ListView(
+      padding: const EdgeInsets.fromLTRB(16, 4, 16, 18),
+      children: [
+        _SectionCard(
+          title: '网络',
+          children: [
+            if (loading) const LinearProgressIndicator(),
+            if (error != null) _ErrorText(error!),
+            _InfoRow(
+              label: '公云存储网盘访问测试',
+              value: data == null ? '检测中' : (data.panReachable ? '正常' : '离线'),
+              valueColor: _statusColor(context, data?.panReachable),
+            ),
+            _InfoRow(label: '当前网络 IP 地址', value: data?.ipInfo.ip ?? '检测中'),
+            _InfoRow(label: 'IP 归属 AS', value: data?.ipInfo.asn ?? '检测中'),
+            _InfoRow(label: '运营商', value: data?.ipInfo.operatorName ?? '检测中'),
+            _InfoRow(
+              label: '连接时延',
+              value: data?.latencyMs == null ? '检测中' : '${data!.latencyMs} ms',
+            ),
+            _InfoRow(
+              label: '长期连接稳定性',
+              value: data == null
+                  ? '检测中'
+                  : '${data.stable ? '稳定' : '不稳定'} '
+                        '(${data.successCount}/${data.sampleCount})',
+              valueColor: _statusColor(context, data?.stable),
+            ),
+          ],
+        ),
+        _SectionCard(
+          title: '说明',
+          children: const [
+            _DescriptionLine('公云存储作为国际化云存储产品，已接入Cloudflare CDN作为全球加速引擎。'),
+            _DescriptionLine(
+              '当前网络 IP 地址、AS 与运营商信息通过第三方服务 ipwho.is 查询；如该服务不可用，将使用 ipapi.co 作为备用查询。',
+            ),
+            _DescriptionLine(
+              '由于部分国家/地区有法律法规限制与审查，可能会出现包括但不限于网络波动、网络丢包以及网络连接不稳定现象',
+            ),
+            _DescriptionLine(
+              '如若出现网络连接问题，您可将本页面内容向公云存储团队报告，团队会根据相关诊断线索进行排查与优化。',
+            ),
+          ],
+        ),
+        _SectionCard(
+          title: '警告',
+          titleColor: errorColor,
+          children: [
+            Text(
+              '本页面内容涉及你本人敏感信息请勿提供给非公云存储团队人员，以避免你本人相关信息泄露！',
+              style: TextStyle(color: errorColor, fontWeight: FontWeight.w700),
+            ),
+          ],
+        ),
+        const SizedBox(height: 8),
+        FilledButton.icon(
+          onPressed: loading ? null : onRefresh,
+          icon: const Icon(Icons.refresh),
+          label: const Text('重新检测'),
+        ),
+      ],
+    );
+  }
+}
+
+class _ServicePanel extends StatelessWidget {
+  final bool loading;
+  final String? error;
+  final _ServiceDiagnostics? diagnostics;
+  final VoidCallback onRefresh;
+
+  const _ServicePanel({
+    super.key,
+    required this.loading,
+    required this.error,
+    required this.diagnostics,
+    required this.onRefresh,
+  });
+
+  @override
+  Widget build(BuildContext context) {
+    final data = diagnostics;
+    return ListView(
+      padding: const EdgeInsets.fromLTRB(16, 4, 16, 18),
+      children: [
+        _SectionCard(
+          title: '业务状态',
+          children: [
+            if (loading) const LinearProgressIndicator(),
+            if (error != null) _ErrorText(error!),
+            ..._itemsOrLoading(data?.business),
+          ],
+        ),
+        _SectionCard(title: '离线下载与计算节点', children: _itemsOrLoading(data?.dc)),
+        _SectionCard(title: '后端', children: _itemsOrLoading(data?.backend)),
+        _SectionCard(title: '存储节点', children: _itemsOrLoading(data?.storage)),
+        _SectionCard(
+          title: '加速线路',
+          children: _itemsOrLoading(data?.acceleration, showLatency: true),
+        ),
+        const SizedBox(height: 8),
+        FilledButton.icon(
+          onPressed: loading ? null : onRefresh,
+          icon: const Icon(Icons.refresh),
+          label: const Text('重新检测'),
+        ),
+      ],
+    );
+  }
+
+  List<Widget> _itemsOrLoading(
+    List<_ServiceItem>? items, {
+    bool showLatency = false,
+  }) {
+    if (items == null) {
+      return const [_InfoRow(label: '状态', value: '检测中')];
+    }
+    return items
+        .map(
+          (item) => _InfoRow(
+            label: item.label,
+            value: showLatency
+                ? item.latencyLabel
+                : (item.online ? '正常' : '离线'),
+            valueColor: item.online ? Colors.green : Colors.red,
+          ),
+        )
+        .toList();
+  }
+}
+
+class _SectionCard extends StatelessWidget {
+  final String title;
+  final List<Widget> children;
+  final Color? titleColor;
+
+  const _SectionCard({
+    required this.title,
+    required this.children,
+    this.titleColor,
+  });
+
+  @override
+  Widget build(BuildContext context) {
+    return Padding(
+      padding: const EdgeInsets.only(bottom: 12),
+      child: Card(
+        child: Padding(
+          padding: const EdgeInsets.fromLTRB(16, 14, 16, 12),
+          child: Column(
+            crossAxisAlignment: CrossAxisAlignment.start,
+            children: [
+              Text(
+                title,
+                style: Theme.of(context).textTheme.titleSmall?.copyWith(
+                  color: titleColor,
+                  fontWeight: FontWeight.w800,
+                ),
+              ),
+              const SizedBox(height: 10),
+              ...children,
+            ],
+          ),
+        ),
+      ),
+    );
+  }
+}
+
+class _InfoRow extends StatelessWidget {
+  final String label;
+  final String value;
+  final Color? valueColor;
+
+  const _InfoRow({required this.label, required this.value, this.valueColor});
+
+  @override
+  Widget build(BuildContext context) {
+    final theme = Theme.of(context);
+    return Padding(
+      padding: const EdgeInsets.symmetric(vertical: 6),
+      child: Row(
+        crossAxisAlignment: CrossAxisAlignment.start,
+        children: [
+          Expanded(child: Text(label, style: theme.textTheme.bodyMedium)),
+          const SizedBox(width: 16),
+          Flexible(
+            child: Text(
+              value,
+              textAlign: TextAlign.right,
+              style: theme.textTheme.bodyMedium?.copyWith(
+                color: valueColor,
+                fontWeight: FontWeight.w700,
+              ),
+            ),
+          ),
+        ],
+      ),
+    );
+  }
+}
+
+class _DescriptionLine extends StatelessWidget {
+  final String text;
+
+  const _DescriptionLine(this.text);
+
+  @override
+  Widget build(BuildContext context) {
+    return Padding(
+      padding: const EdgeInsets.symmetric(vertical: 5),
+      child: Text(text),
+    );
+  }
+}
+
+class _ErrorText extends StatelessWidget {
+  final String error;
+
+  const _ErrorText(this.error);
+
+  @override
+  Widget build(BuildContext context) {
+    return Padding(
+      padding: const EdgeInsets.only(bottom: 8),
+      child: Text(
+        '检测失败：$error',
+        style: TextStyle(color: Theme.of(context).colorScheme.error),
+      ),
+    );
+  }
+}
+
+Color? _statusColor(BuildContext context, bool? value) {
+  if (value == null) return null;
+  return value ? Colors.green : Theme.of(context).colorScheme.error;
+}
+
+class _NetworkDiagnostics {
+  final bool panReachable;
+  final int? latencyMs;
+  final _IpInfo ipInfo;
+  final bool stable;
+  final int sampleCount;
+  final int successCount;
+
+  const _NetworkDiagnostics({
+    required this.panReachable,
+    required this.latencyMs,
+    required this.ipInfo,
+    required this.stable,
+    required this.sampleCount,
+    required this.successCount,
+  });
+}
+
+class _IpInfo {
+  final String ip;
+  final String asn;
+  final String operatorName;
+
+  const _IpInfo({
+    required this.ip,
+    required this.asn,
+    required this.operatorName,
+  });
+}
+
+class _ServiceDiagnostics {
+  final DateTime fetchedAt;
+  final List<_ServiceItem> business;
+  final List<_ServiceItem> dc;
+  final List<_ServiceItem> backend;
+  final List<_ServiceItem> storage;
+  final List<_ServiceItem> acceleration;
+
+  const _ServiceDiagnostics({
+    required this.fetchedAt,
+    required this.business,
+    required this.dc,
+    required this.backend,
+    required this.storage,
+    required this.acceleration,
+  });
+}
+
+class _ServiceItem {
+  final String label;
+  final bool online;
+  final int? latencyMs;
+
+  const _ServiceItem({
+    required this.label,
+    required this.online,
+    this.latencyMs,
+  });
+
+  String get latencyLabel {
+    if (!online) return '离线';
+    if (latencyMs == null) return '正常 / -- ms';
+    return '正常 / $latencyMs ms';
+  }
+}
+
+class _MonitorHeartbeat {
+  final bool online;
+  final int? pingMs;
+
+  const _MonitorHeartbeat({required this.online, this.pingMs});
+}
+
+class _ProbeResult {
+  final bool reachable;
+  final int? latencyMs;
+
+  const _ProbeResult({required this.reachable, this.latencyMs});
+}
+
+class _StabilityResult {
+  final bool stable;
+  final int sampleCount;
+  final int successCount;
+
+  const _StabilityResult({
+    required this.stable,
+    required this.sampleCount,
+    required this.successCount,
+  });
+}

lib/presentation/pages/settings/settings_page.dart

@@ -1,9 +1,11 @@
 import 'package:flutter/material.dart';
+import 'package:flutter/gestures.dart';
 import 'package:provider/provider.dart';
 import 'package:url_launcher/url_launcher.dart';
 import 'package:package_info_plus/package_info_plus.dart';
 import '../../../data/models/user_model.dart';
 import '../../../data/models/user_setting_model.dart';
+import '../../../services/update_service.dart';
 import '../../../services/user_setting_service.dart';
 import '../../providers/auth_provider.dart';
 import '../../providers/user_setting_provider.dart';
@@ -16,6 +18,7 @@ import 'file_preferences_page.dart';
 import 'app_settings_page.dart';
 import 'credit_history_page.dart';
 import 'quick_access_settings_page.dart';
+import 'network_test_page.dart';
 import '../../../router/app_router.dart';
 
 /// 设置主页
@@ -99,7 +102,8 @@ class _SettingsPageState extends State<SettingsPage> {
                   icon: Icons.security_outlined,
                   title: '安全设置',
                   subtitle: _securitySubtitle(settings),
-                onTap: () => _navigateTo(context, const SecuritySettingsPage()),
+                  onTap: () =>
+                      _navigateTo(context, const SecuritySettingsPage()),
                 ),
               ],
             ),
@@ -110,19 +114,22 @@ class _SettingsPageState extends State<SettingsPage> {
                   icon: Icons.sync_outlined,
                   title: '文件同步',
                   subtitle: '本地与云端文件自动同步',
-                onTap: () => Navigator.of(context).pushNamed(RouteNames.syncSettings),
+                  onTap: () =>
+                      Navigator.of(context).pushNamed(RouteNames.syncSettings),
                 ),
                 _SettingsTile(
                   icon: Icons.apps_outlined,
                   title: '快捷入口',
                   subtitle: '自定义概览页快捷目录',
-                onTap: () => _navigateTo(context, const QuickAccessSettingsPage()),
+                  onTap: () =>
+                      _navigateTo(context, const QuickAccessSettingsPage()),
                 ),
                 _SettingsTile(
                   icon: Icons.folder_outlined,
                   title: '文件偏好',
                   subtitle: '版本保留、视图同步、分享可见性',
-                onTap: () => _navigateTo(context, const FilePreferencesPage()),
+                  onTap: () =>
+                      _navigateTo(context, const FilePreferencesPage()),
                 ),
                 _SettingsTile(
                   icon: Icons.tune,
@@ -130,6 +137,12 @@ class _SettingsPageState extends State<SettingsPage> {
                   subtitle: '缓存、主题、语言',
                   onTap: () => _navigateTo(context, const AppSettingsPage()),
                 ),
+                _SettingsTile(
+                  icon: Icons.network_check,
+                  title: '网络测试',
+                  subtitle: '服务连通性测试与自定义线路(会员)',
+                  onTap: () => _openNetworkTest(context),
+                ),
               ],
             ),
             // 财务区域（有数据时才显示）
@@ -142,11 +155,7 @@ class _SettingsPageState extends State<SettingsPage> {
                   title: const Text('应用名称'),
                   subtitle: const Text('公云存储'),
                 ),
-              ListTile(
-                leading: const Icon(Icons.tag),
-                title: const Text('版本号'),
-                subtitle: Text(_appVersion.isEmpty ? '加载中...' : _appVersion),
-              ),
+                _buildVersionTile(),
                 ListTile(
                   leading: const Icon(Icons.copyright),
                   title: const Text('License'),
@@ -158,9 +167,8 @@ class _SettingsPageState extends State<SettingsPage> {
                   subtitle: const Text('gongyun_app'),
                   trailing: const Icon(Icons.open_in_new, size: 16),
                   onTap: () {
-                  launchUrl(
+                    _openExternalUrl(
                       Uri.parse('https://git.saont.net/gongyun/app'),
-                    mode: LaunchMode.externalApplication,
                     );
                   },
                 ),
@@ -170,9 +178,10 @@ class _SettingsPageState extends State<SettingsPage> {
                   subtitle: const Text('cloudreve4_flutter'),
                   trailing: const Icon(Icons.open_in_new, size: 16),
                   onTap: () {
-                  launchUrl(
-                    Uri.parse('https://github.com/LimoYuan/cloudreve4_flutter'),
-                    mode: LaunchMode.externalApplication,
+                    _openExternalUrl(
+                      Uri.parse(
+                        'https://github.com/LimoYuan/cloudreve4_flutter',
+                      ),
                     );
                   },
                 ),
@@ -188,7 +197,10 @@ class _SettingsPageState extends State<SettingsPage> {
   }
 
   /// 财务区域（存储包、积分、会员）
-  List<Widget> _buildProSections(BuildContext context, UserSettingModel settings) {
+  List<Widget> _buildProSections(
+    BuildContext context,
+    UserSettingModel settings,
+  ) {
     final sections = <Widget>[];
     final hasStoragePacks = settings.storagePacks.isNotEmpty;
     final hasCredit = settings.credit > 0;
@@ -197,7 +209,8 @@ class _SettingsPageState extends State<SettingsPage> {
     if (hasStoragePacks || hasCredit || hasMembership) {
       final children = <Widget>[];
       if (hasMembership) {
-        children.add(ListTile(
+        children.add(
+          ListTile(
             leading: const Icon(Icons.workspace_premium_outlined),
             title: const Text('会员'),
             subtitle: Text('到期: ${_formatDate(settings.groupExpires!)}'),
@@ -205,32 +218,45 @@ class _SettingsPageState extends State<SettingsPage> {
               onPressed: () => _cancelMembership(context),
               child: const Text('取消会员', style: TextStyle(color: Colors.red)),
             ),
-        ));
+          ),
+        );
       }
       if (hasStoragePacks) {
-        children.add(ListTile(
+        children.add(
+          ListTile(
             leading: const Icon(Icons.inventory_2_outlined),
             title: Text('存储包 (${settings.storagePacks.length})'),
             subtitle: Text(_storagePackSummary(settings.storagePacks)),
             trailing: const Icon(Icons.chevron_right),
             onTap: () => _showStoragePacks(context, settings.storagePacks),
-        ));
+          ),
+        );
       }
       if (hasCredit) {
-        children.add(ListTile(
+        children.add(
+          ListTile(
             leading: const Icon(Icons.account_balance_wallet_outlined),
             title: const Text('积分'),
             subtitle: Text('${settings.credit} 积分'),
             trailing: const Icon(Icons.chevron_right),
-          onTap: () => _navigateTo(context, CreditHistoryPage(currentCredit: settings.credit)),
-        ));
+            onTap: () => _navigateTo(
+              context,
+              CreditHistoryPage(currentCredit: settings.credit),
+            ),
+          ),
+        );
       }
       sections.add(_buildSection(title: '财务', children: children));
     }
     return sections;
   }
 
-  Widget _buildProfileCard(BuildContext context, UserModel? user, UserSettingModel? settings, UserCapacityModel? capacity) {
+  Widget _buildProfileCard(
+    BuildContext context,
+    UserModel? user,
+    UserSettingModel? settings,
+    UserCapacityModel? capacity,
+  ) {
     final theme = Theme.of(context);
     final colorScheme = theme.colorScheme;
 
@@ -253,17 +279,24 @@ class _SettingsPageState extends State<SettingsPage> {
                       children: [
                         Text(
                           user?.nickname ?? '未登录',
-                          style: theme.textTheme.titleMedium?.copyWith(fontWeight: FontWeight.bold),
+                          style: theme.textTheme.titleMedium?.copyWith(
+                            fontWeight: FontWeight.bold,
+                          ),
                         ),
                         const SizedBox(height: 2),
                         Text(
                           user?.email ?? '',
-                          style: theme.textTheme.bodySmall?.copyWith(color: colorScheme.onSurfaceVariant),
+                          style: theme.textTheme.bodySmall?.copyWith(
+                            color: colorScheme.onSurfaceVariant,
+                          ),
                         ),
                         if (user?.group != null) ...[
                           const SizedBox(height: 4),
                           Container(
-                            padding: const EdgeInsets.symmetric(horizontal: 8, vertical: 2),
+                            padding: const EdgeInsets.symmetric(
+                              horizontal: 8,
+                              vertical: 2,
+                            ),
                             decoration: BoxDecoration(
                               color: colorScheme.primaryContainer,
                               borderRadius: BorderRadius.circular(8),
@@ -316,9 +349,12 @@ class _SettingsPageState extends State<SettingsPage> {
           mainAxisAlignment: MainAxisAlignment.spaceBetween,
           children: [
             Text('存储空间', style: theme.textTheme.bodySmall),
-            Text('$usedText / $totalText', style: theme.textTheme.bodySmall?.copyWith(
+            Text(
+              '$usedText / $totalText',
+              style: theme.textTheme.bodySmall?.copyWith(
                 color: colorScheme.onSurfaceVariant,
-            )),
+              ),
+            ),
           ],
         ),
         const SizedBox(height: 6),
@@ -334,7 +370,10 @@ class _SettingsPageState extends State<SettingsPage> {
     );
   }
 
-  Widget _buildSection({required String title, required List<Widget> children}) {
+  Widget _buildSection({
+    required String title,
+    required List<Widget> children,
+  }) {
     return Padding(
       padding: const EdgeInsets.symmetric(vertical: 4),
       child: Column(
@@ -360,17 +399,43 @@ class _SettingsPageState extends State<SettingsPage> {
     );
   }
 
+  Widget _buildVersionTile() {
+    return AnimatedBuilder(
+      animation: UpdateService.instance,
+      builder: (context, _) {
+        final hasUpdate = UpdateService.instance.hasUpdate;
+        return ListTile(
+          leading: Icon(
+            hasUpdate ? Icons.new_releases_outlined : Icons.tag,
+            color: hasUpdate ? Theme.of(context).colorScheme.primary : null,
+          ),
+          title: const Text('版本号'),
+          subtitle: Text(_appVersion.isEmpty ? '加载中...' : _appVersion),
+          onTap: hasUpdate ? () => _openDownloadsPage() : null,
+          trailing: hasUpdate ? const _UpdateAvailableBadge() : null,
+        );
+      },
+    );
+  }
+
   Widget _buildLogoutButton(BuildContext context, AuthProvider auth) {
     return Padding(
       padding: const EdgeInsets.symmetric(horizontal: 16),
       child: OutlinedButton.icon(
         onPressed: () => _confirmLogout(context, auth),
         icon: Icon(Icons.logout, color: Theme.of(context).colorScheme.error),
-        label: Text('退出登录', style: TextStyle(color: Theme.of(context).colorScheme.error)),
+        label: Text(
+          '退出登录',
+          style: TextStyle(color: Theme.of(context).colorScheme.error),
+        ),
         style: OutlinedButton.styleFrom(
           minimumSize: const Size(double.infinity, 48),
-          side: BorderSide(color: Theme.of(context).colorScheme.error.withValues(alpha: 0.3)),
-          shape: RoundedRectangleBorder(borderRadius: BorderRadius.circular(12)),
+          side: BorderSide(
+            color: Theme.of(context).colorScheme.error.withValues(alpha: 0.3),
+          ),
+          shape: RoundedRectangleBorder(
+            borderRadius: BorderRadius.circular(12),
+          ),
         ),
       ),
     );
@@ -407,7 +472,8 @@ class _SettingsPageState extends State<SettingsPage> {
               padding: const EdgeInsets.symmetric(vertical: 16),
               child: Text('存储包', style: Theme.of(ctx).textTheme.titleMedium),
             ),
-            ...packs.map((pack) => Card(
+            ...packs.map(
+              (pack) => Card(
                 child: Padding(
                   padding: const EdgeInsets.all(12),
                   child: Column(
@@ -416,8 +482,14 @@ class _SettingsPageState extends State<SettingsPage> {
                       Row(
                         mainAxisAlignment: MainAxisAlignment.spaceBetween,
                         children: [
-                        Text(pack.name, style: Theme.of(ctx).textTheme.titleSmall),
-                        Text(_formatBytes(pack.size), style: Theme.of(ctx).textTheme.labelLarge),
+                          Text(
+                            pack.name,
+                            style: Theme.of(ctx).textTheme.titleSmall,
+                          ),
+                          Text(
+                            _formatBytes(pack.size),
+                            style: Theme.of(ctx).textTheme.labelLarge,
+                          ),
                         ],
                       ),
                       const SizedBox(height: 4),
@@ -428,12 +500,19 @@ class _SettingsPageState extends State<SettingsPage> {
                       ),
                       if (pack.isExpired) ...[
                         const SizedBox(height: 4),
-                      Text('已过期', style: TextStyle(color: Theme.of(ctx).colorScheme.error, fontSize: 12)),
+                        Text(
+                          '已过期',
+                          style: TextStyle(
+                            color: Theme.of(ctx).colorScheme.error,
+                            fontSize: 12,
+                          ),
+                        ),
                       ],
                     ],
                   ),
                 ),
-            )),
+              ),
+            ),
             const SizedBox(height: 16),
           ],
         ),
@@ -449,10 +528,15 @@ class _SettingsPageState extends State<SettingsPage> {
         title: const Text('取消会员'),
         content: const Text('确定要取消当前会员吗？取消后将失去会员权益。'),
         actions: [
-          TextButton(onPressed: () => Navigator.of(ctx).pop(false), child: const Text('取消')),
+          TextButton(
+            onPressed: () => Navigator.of(ctx).pop(false),
+            child: const Text('取消'),
+          ),
           FilledButton(
             onPressed: () => Navigator.of(ctx).pop(true),
-            style: FilledButton.styleFrom(backgroundColor: Theme.of(ctx).colorScheme.error),
+            style: FilledButton.styleFrom(
+              backgroundColor: Theme.of(ctx).colorScheme.error,
+            ),
             child: const Text('确认取消'),
           ),
         ],
@@ -479,6 +563,59 @@ class _SettingsPageState extends State<SettingsPage> {
     }
   }
 
+  Future<void> _openExternalUrl(Uri uri) async {
+    try {
+      final opened = await launchUrl(uri, mode: LaunchMode.externalApplication);
+      if (!opened) {
+        ToastHelper.failure('无法打开链接: $uri');
+      }
+    } catch (e) {
+      ToastHelper.failure('无法打开链接: $e');
+    }
+  }
+
+  Future<void> _openDownloadsPage() async {
+    try {
+      await UpdateService.instance.openDownloadsPage();
+    } catch (e) {
+      ToastHelper.failure('打开下载页面失败: $e');
+    }
+  }
+
+  Future<void> _openNetworkTest(BuildContext context) async {
+    final agreed = await showDialog<bool>(
+      context: context,
+      barrierDismissible: false,
+      builder: (dialogContext) => AlertDialog(
+        title: const Text('会话信息授权'),
+        content: _NetworkTestConsentText(
+          onOpenPrivacy: () => _openExternalUrl(
+            Uri.parse('https://www.gongyun.org/policy/privacy.html'),
+          ),
+          onOpenTerms: () => _openExternalUrl(
+            Uri.parse('https://www.gongyun.org/policy/terms.html'),
+          ),
+        ),
+        actions: [
+          TextButton(
+            onPressed: () => Navigator.of(dialogContext).pop(false),
+            child: const Text('不同意'),
+          ),
+          FilledButton(
+            onPressed: () => Navigator.of(dialogContext).pop(true),
+            child: const Text('同意'),
+          ),
+        ],
+      ),
+    );
+
+    if (agreed == true && context.mounted) {
+      await Navigator.of(
+        context,
+      ).push(MaterialPageRoute(builder: (_) => const NetworkTestPage()));
+    }
+  }
+
   Future<void> _confirmLogout(BuildContext context, AuthProvider auth) async {
     final confirmed = await showDialog<bool>(
       context: context,
@@ -486,10 +623,15 @@ class _SettingsPageState extends State<SettingsPage> {
         title: const Text('退出登录'),
         content: const Text('确定要退出当前账号吗？'),
         actions: [
-          TextButton(onPressed: () => Navigator.of(ctx).pop(false), child: const Text('取消')),
+          TextButton(
+            onPressed: () => Navigator.of(ctx).pop(false),
+            child: const Text('取消'),
+          ),
           FilledButton(
             onPressed: () => Navigator.of(ctx).pop(true),
-            style: FilledButton.styleFrom(backgroundColor: Theme.of(context).colorScheme.error),
+            style: FilledButton.styleFrom(
+              backgroundColor: Theme.of(context).colorScheme.error,
+            ),
             child: const Text('退出'),
           ),
         ],
@@ -506,7 +648,9 @@ class _SettingsPageState extends State<SettingsPage> {
   String _formatBytes(int bytes) {
     if (bytes < 1024) return '$bytes B';
     if (bytes < 1024 * 1024) return '${(bytes / 1024).toStringAsFixed(1)} KB';
-    if (bytes < 1024 * 1024 * 1024) return '${(bytes / (1024 * 1024)).toStringAsFixed(1)} MB';
+    if (bytes < 1024 * 1024 * 1024) {
+      return '${(bytes / (1024 * 1024)).toStringAsFixed(1)} MB';
+    }
     return '${(bytes / (1024 * 1024 * 1024)).toStringAsFixed(1)} GB';
   }
 
@@ -515,6 +659,140 @@ class _SettingsPageState extends State<SettingsPage> {
   }
 }
 
+class _UpdateAvailableBadge extends StatefulWidget {
+  const _UpdateAvailableBadge();
+
+  @override
+  State<_UpdateAvailableBadge> createState() => _UpdateAvailableBadgeState();
+}
+
+class _UpdateAvailableBadgeState extends State<_UpdateAvailableBadge>
+    with SingleTickerProviderStateMixin {
+  late final AnimationController _controller;
+  late final Animation<double> _opacity;
+
+  @override
+  void initState() {
+    super.initState();
+    _controller = AnimationController(
+      vsync: this,
+      duration: const Duration(milliseconds: 900),
+    )..repeat(reverse: true);
+    _opacity = Tween<double>(
+      begin: 0.3,
+      end: 1,
+    ).animate(CurvedAnimation(parent: _controller, curve: Curves.easeInOut));
+  }
+
+  @override
+  void dispose() {
+    _controller.dispose();
+    super.dispose();
+  }
+
+  @override
+  Widget build(BuildContext context) {
+    final colorScheme = Theme.of(context).colorScheme;
+    return FadeTransition(
+      opacity: _opacity,
+      child: Row(
+        mainAxisSize: MainAxisSize.min,
+        children: [
+          Container(
+            width: 8,
+            height: 8,
+            decoration: BoxDecoration(
+              color: colorScheme.error,
+              shape: BoxShape.circle,
+            ),
+          ),
+          const SizedBox(width: 6),
+          Text(
+            '发现新版本',
+            style: TextStyle(
+              color: colorScheme.error,
+              fontWeight: FontWeight.w700,
+            ),
+          ),
+          const SizedBox(width: 4),
+          Icon(Icons.chevron_right, size: 18, color: colorScheme.error),
+        ],
+      ),
+    );
+  }
+}
+
+class _NetworkTestConsentText extends StatefulWidget {
+  final VoidCallback onOpenPrivacy;
+  final VoidCallback onOpenTerms;
+
+  const _NetworkTestConsentText({
+    required this.onOpenPrivacy,
+    required this.onOpenTerms,
+  });
+
+  @override
+  State<_NetworkTestConsentText> createState() =>
+      _NetworkTestConsentTextState();
+}
+
+class _NetworkTestConsentTextState extends State<_NetworkTestConsentText> {
+  late final TapGestureRecognizer _privacyRecognizer;
+  late final TapGestureRecognizer _termsRecognizer;
+
+  @override
+  void initState() {
+    super.initState();
+    _privacyRecognizer = TapGestureRecognizer()..onTap = widget.onOpenPrivacy;
+    _termsRecognizer = TapGestureRecognizer()..onTap = widget.onOpenTerms;
+  }
+
+  @override
+  void didUpdateWidget(covariant _NetworkTestConsentText oldWidget) {
+    super.didUpdateWidget(oldWidget);
+    _privacyRecognizer.onTap = widget.onOpenPrivacy;
+    _termsRecognizer.onTap = widget.onOpenTerms;
+  }
+
+  @override
+  void dispose() {
+    _privacyRecognizer.dispose();
+    _termsRecognizer.dispose();
+    super.dispose();
+  }
+
+  @override
+  Widget build(BuildContext context) {
+    final linkStyle = TextStyle(
+      color: Theme.of(context).colorScheme.primary,
+      fontWeight: FontWeight.w700,
+    );
+
+    return Text.rich(
+      TextSpan(
+        children: [
+          const TextSpan(text: '您需同意'),
+          TextSpan(
+            text: '隐私政策',
+            style: linkStyle,
+            recognizer: _privacyRecognizer,
+          ),
+          const TextSpan(text: '与'),
+          TextSpan(
+            text: '用户协议',
+            style: linkStyle,
+            recognizer: _termsRecognizer,
+          ),
+          const TextSpan(
+            text:
+                '方可进入网络测试页。测试会访问公云存储服务，并通过第三方服务 ipwho.is 查询当前网络 IP、AS 与运营商信息；如 ipwho.is 不可用，将使用 ipapi.co 作为备用查询。',
+          ),
+        ],
+      ),
+    );
+  }
+}
+
 class _SettingsTile extends StatelessWidget {
   final IconData icon;
   final String title;

lib/presentation/pages/share/share_link_page.dart

@@ -1442,8 +1442,12 @@ class _OfficialDownloadDesktopWebViewState
         domStorageEnabled: true,
         supportZoom: false,
         transparentBackground: true,
+        isInspectable: true,
+        cacheMode: desktop.CacheMode.LOAD_DEFAULT,
+        supportMultipleWindows: false,
         useShouldOverrideUrlLoading: true,
         useOnDownloadStart: true,
+        useHybridComposition: true,
       ),
       onWebViewCreated: (controller) {
         _controller = controller;
@@ -1457,6 +1461,18 @@ class _OfficialDownloadDesktopWebViewState
         );
       },
       onLoadStop: (_, url) => _installHook(),
+      shouldInterceptRequest: (_, request) async {
+        final url = request.url.toString();
+        if (widget.onNavigationUrl(url)) {
+          return null;
+        }
+        return null;
+      },
+      onLoadStart: (_, url) {
+        if (url != null) {
+          widget.onNavigationUrl(url.toString());
+        }
+      },
       shouldOverrideUrlLoading: (_, action) {
         final url = action.request.url?.toString();
         if (url != null && widget.onNavigationUrl(url)) {

lib/presentation/widgets/announcement_dialog.dart

@@ -201,6 +201,9 @@ $body
         onLoadStop: (_, url) {
           if (mounted) setState(() => _loading = false);
         },
+        onReceivedError: (_, request, error) {
+          if (mounted) setState(() => _loading = false);
+        },
       );
     }
 

lib/presentation/widgets/update_prompt.dart

@@ -1,5 +1,3 @@
-import 'dart:io';
-
 import 'package:flutter/material.dart';
 
 import '../../data/models/app_update_model.dart';
@@ -31,6 +29,8 @@ class _UpdatePromptState extends State<UpdatePrompt> {
 
     final update = await UpdateService.instance.checkForUpdate();
     if (update == null || !mounted) return;
+    final shouldShow = await UpdateService.instance.shouldShowPrompt(update);
+    if (!shouldShow || !mounted) return;
 
     _dialogVisible = true;
     try {
@@ -41,101 +41,58 @@ class _UpdatePromptState extends State<UpdatePrompt> {
   }
 
   Future<void> _showUpdateDialog(AppUpdateInfo update) async {
-    var downloading = false;
-    var progress = 0.0;
-    String? status;
-
     await showDialog<void>(
       context: context,
       barrierDismissible: false,
       builder: (dialogContext) {
-        return StatefulBuilder(
-          builder: (context, setDialogState) {
-            final canDownload =
-                update.downloadUrl != null &&
-                (Platform.isAndroid || Platform.isWindows);
-
-            Future<void> startUpdate() async {
-              if (downloading || !canDownload) return;
-
-              setDialogState(() {
-                downloading = true;
-                progress = 0;
-                status = '正在下载更新...';
-              });
-
+        Future<void> openDownloadsPage() async {
           try {
-                final file = await UpdateService.instance.downloadUpdate(
-                  update,
-                  onProgress: (received, total) {
-                    if (!mounted || total <= 0) return;
-                    setDialogState(() {
-                      progress = received / total;
-                    });
-                  },
-                );
-                if (file == null) return;
-
-                setDialogState(() {
-                  progress = 1;
-                  status = '下载完成，正在打开安装包...';
-                });
-                await UpdateService.instance.openInstaller(file);
+            await UpdateService.instance.openDownloadsPage();
             if (dialogContext.mounted) Navigator.of(dialogContext).pop();
           } catch (e) {
-                setDialogState(() {
-                  downloading = false;
-                  status = '下载或打开安装包失败';
-                });
-                ToastHelper.failure('更新失败: $e');
+            ToastHelper.failure('打开下载页面失败: $e');
           }
         }
 
+        Future<void> skipPrompt() async {
+          await UpdateService.instance.skipPromptForFiveDays(update);
+          if (dialogContext.mounted) Navigator.of(dialogContext).pop();
+        }
+
+        final releaseNotes = (update.description ?? '').trim();
+
         return AlertDialog(
           title: Text('发现新版本 ${update.version}'),
           content: ConstrainedBox(
-                constraints: const BoxConstraints(maxWidth: 420),
+            constraints: const BoxConstraints(maxWidth: 420, maxHeight: 360),
+            child: SingleChildScrollView(
               child: Column(
                 mainAxisSize: MainAxisSize.min,
                 crossAxisAlignment: CrossAxisAlignment.start,
                 children: [
-                    Text(update.title),
-                    if ((update.description ?? '').isNotEmpty) ...[
+                  Text('新版本号：${update.version}'),
                   const SizedBox(height: 12),
                   Text(
-                        update.description!,
-                        maxLines: 6,
-                        overflow: TextOverflow.ellipsis,
+                    '版本日志',
+                    style: Theme.of(dialogContext).textTheme.titleSmall,
                   ),
+                  const SizedBox(height: 6),
+                  Text(releaseNotes.isEmpty ? update.title : releaseNotes),
                 ],
-                    if (downloading) ...[
-                      const SizedBox(height: 16),
-                      LinearProgressIndicator(
-                        value: progress == 0 ? null : progress,
               ),
-                      const SizedBox(height: 8),
-                      Text(status ?? ''),
-                    ],
-                  ],
             ),
           ),
           actions: [
+            TextButton(onPressed: skipPrompt, child: const Text('跳过')),
             TextButton(
-                  onPressed: downloading
-                      ? null
-                      : () => Navigator.of(dialogContext).pop(),
-                  child: const Text('稍后'),
-                ),
-                FilledButton(
-                  onPressed: downloading ? null : startUpdate,
-                  child: const Text('立即更新'),
+              onPressed: () => Navigator.of(dialogContext).pop(),
+              child: const Text('取消'),
             ),
+            FilledButton(onPressed: openDownloadsPage, child: const Text('更新')),
           ],
         );
       },
     );
-      },
-    );
   }
 
   @override

lib/services/update_service.dart

@@ -9,11 +9,22 @@ import 'package:path_provider/path_provider.dart';
 import 'package:url_launcher/url_launcher.dart';
 import 'package:xml/xml.dart';
 
+import '../core/constants/storage_keys.dart';
 import '../core/utils/app_logger.dart';
 import '../data/models/app_update_model.dart';
+import 'storage_service.dart';
 
-class UpdateService {
-  UpdateService._();
+class UpdateService extends ChangeNotifier {
+  UpdateService._()
+    : _dio = Dio(_dioOptions),
+      _packageInfoProvider = PackageInfo.fromPlatform;
+
+  @visibleForTesting
+  UpdateService.test({
+    Dio? dio,
+    Future<PackageInfo> Function()? packageInfoProvider,
+  }) : _dio = dio ?? Dio(_dioOptions),
+       _packageInfoProvider = packageInfoProvider ?? PackageInfo.fromPlatform;
 
   static final UpdateService instance = UpdateService._();
 
@@ -23,28 +34,39 @@ class UpdateService {
   static final Uri releasesPageUrl = Uri.parse(
     'https://git.saont.net/gongyun/app/releases',
   );
+  static final Uri downloadsPageUrl = Uri.parse(
+    'https://www.gongyun.org/downloads.html',
+  );
 
-  final Dio _dio = Dio(
-    BaseOptions(
+  static final BaseOptions _dioOptions = BaseOptions(
     connectTimeout: const Duration(seconds: 12),
     receiveTimeout: const Duration(seconds: 20),
     followRedirects: true,
     responseType: ResponseType.plain,
-    ),
   );
 
+  final Dio _dio;
+  final Future<PackageInfo> Function() _packageInfoProvider;
+
   bool _checking = false;
+  AppUpdateInfo? _availableUpdate;
+
+  AppUpdateInfo? get availableUpdate => _availableUpdate;
+  bool get hasUpdate => _availableUpdate != null;
 
   Future<AppUpdateInfo?> checkForUpdate() async {
     if (_checking) return null;
-    if (!_supportsAutoDownload) return null;
 
     _checking = true;
     try {
-      final current = await PackageInfo.fromPlatform();
+      final current = await _packageInfoProvider();
       final latest = await _fetchLatestRelease(currentVersion: current.version);
-      if (latest == null) return null;
-      if (_compareVersions(latest.version, current.version) <= 0) return null;
+      if (latest == null ||
+          _compareVersions(latest.version, current.version) <= 0) {
+        _setAvailableUpdate(null);
+        return null;
+      }
+      _setAvailableUpdate(latest);
       return latest;
     } catch (e, stackTrace) {
       AppLogger.e('检查更新失败: $e\n$stackTrace');
@@ -54,6 +76,34 @@ class UpdateService {
     }
   }
 
+  Future<bool> shouldShowPrompt(AppUpdateInfo update) async {
+    final storage = StorageService.instance;
+    final skipVersion = await storage.getString(
+      StorageKeys.updatePromptSkipVersion,
+    );
+    final skipUntil = await storage.getInt(StorageKeys.updatePromptSkipUntil);
+    if (skipVersion != update.version || skipUntil == null) return true;
+
+    final now = DateTime.now().millisecondsSinceEpoch;
+    if (skipUntil > now) return false;
+
+    await storage.remove(StorageKeys.updatePromptSkipUntil);
+    await storage.remove(StorageKeys.updatePromptSkipVersion);
+    return true;
+  }
+
+  Future<void> skipPromptForFiveDays(AppUpdateInfo update) async {
+    final skipUntil = DateTime.now()
+        .add(const Duration(days: 5))
+        .millisecondsSinceEpoch;
+    final storage = StorageService.instance;
+    await storage.setString(
+      StorageKeys.updatePromptSkipVersion,
+      update.version,
+    );
+    await storage.setInt(StorageKeys.updatePromptSkipUntil, skipUntil);
+  }
+
   Future<File?> downloadUpdate(
     AppUpdateInfo update, {
     void Function(int received, int total)? onProgress,
@@ -96,6 +146,15 @@ class UpdateService {
     }
   }
 
+  Future<void> openDownloadsPage() async {
+    if (!await launchUrl(
+      downloadsPageUrl,
+      mode: LaunchMode.externalApplication,
+    )) {
+      throw Exception('无法打开下载页面: $downloadsPageUrl');
+    }
+  }
+
   Future<AppUpdateInfo?> _fetchLatestRelease({String? currentVersion}) async {
     final response = await _dio.getUri<String>(releasesRssUrl);
     final body = response.data;
@@ -119,7 +178,6 @@ class UpdateService {
       final update = await _buildUpdateInfo(release);
       if (update == null) continue;
 
-      if (update.downloadUrl == null) continue;
       return update;
     }
 
@@ -206,8 +264,6 @@ class UpdateService {
     return null;
   }
 
-  bool get _supportsAutoDownload => Platform.isAndroid || Platform.isWindows;
-
   bool _isReleaseAttachment(Uri uri) {
     return uri.path.contains('/releases/download/');
   }
@@ -345,6 +401,16 @@ class UpdateService {
     return Uri.decodeComponent(segment);
   }
 
+  void _setAvailableUpdate(AppUpdateInfo? update) {
+    final previous = _availableUpdate;
+    if (previous?.version == update?.version &&
+        previous?.pageUrl == update?.pageUrl) {
+      return;
+    }
+    _availableUpdate = update;
+    notifyListeners();
+  }
+
   @visibleForTesting
   Future<AppUpdateInfo?> debugFetchLatestRelease() => _fetchLatestRelease();
 }

native/sync-core/src/api_client.rs

@@ -1,5 +1,6 @@
 use crate::errors::{Result, SyncError};
 use crate::models::*;
+use crate::server_error_code::api_code_to_error;
 use reqwest::Client;
 use serde::Deserialize;
 use std::sync::Arc;
@@ -154,12 +155,11 @@ impl ApiClient {
             return Err(SyncError::Network(format!("HTTP {}", resp.status())));
         }
         let api_resp: ApiResponse<serde_json::Value> = resp.json().await?;
-        if api_resp.code == 401 {
-            return Err(SyncError::Auth("Login required".into()));
-        }
-        if api_resp.code == 40004 {
-            return Err(SyncError::ObjectExisted);
+        if api_resp.code == 0 {
+            return Ok(api_resp.data.unwrap_or_default());
         }
+
+        // 40073 锁冲突需要特殊处理 data
         if api_resp.code == 40073 {
             let items = api_resp.data
                 .and_then(|d| d.as_array().cloned())
@@ -177,12 +177,11 @@ impl ApiClient {
                 .collect();
             return Err(SyncError::LockConflict { tokens: items });
         }
-        if api_resp.code != 0 {
-            return Err(SyncError::Network(
-                api_resp.msg.unwrap_or_else(|| format!("错误码: {}", api_resp.code)),
-            ));
-        }
-        Ok(api_resp.data.unwrap_or_default())
+
+        let msg = api_resp.msg
+            .filter(|m| !m.is_empty())
+            .unwrap_or_default();
+        Err(api_code_to_error(api_resp.code, &msg))
     }
 
     /// 发送带认证的请求，自动处理 401（刷新 token 后重试一次）
@@ -196,9 +195,22 @@ impl ApiClient {
 
         // 第一次尝试
         let token = self.token().await;
-        let resp = request_builder(token)
+        let resp = match request_builder(token)
             .header("X-Cr-Client-Id", &client_id)
-            .send().await?;
+            .send()
+            .await
+        {
+            Ok(r) => r,
+            Err(e) => {
+                tracing::warn!(
+                    "请求发送失败: kind={:?}, url={:?}, error={}",
+                    e.is_connect(),
+                    e.url().map(|u| u.as_str()),
+                    e
+                );
+                return Err(e.into());
+            }
+        };
         let result = self.parse_response(resp).await;
 
         if let Err(SyncError::Auth(_)) = result {
@@ -206,9 +218,22 @@ impl ApiClient {
             self.refresh_access_token().await?;
             // 用新 token 重试
             let new_token = self.token().await;
-            let resp = request_builder(new_token)
+            let resp = match request_builder(new_token)
                 .header("X-Cr-Client-Id", &client_id)
-                .send().await?;
+                .send()
+                .await
+            {
+                Ok(r) => r,
+                Err(e) => {
+                    tracing::warn!(
+                        "重试请求发送失败: kind={:?}, url={:?}, error={}",
+                        e.is_connect(),
+                        e.url().map(|u| u.as_str()),
+                        e
+                    );
+                    return Err(e.into());
+                }
+            };
             return self.parse_response(resp).await;
         }
 
@@ -261,7 +286,22 @@ impl ApiClient {
             }
 
             for dir_uri in dirs_to_recurse {
-                self.list_all_files_recursive(&dir_uri, result).await?;
+                let mut retry = 0u32;
+                loop {
+                    match self.list_all_files_recursive(&dir_uri, result).await {
+                        Ok(()) => break,
+                        Err(e) => {
+                            retry += 1;
+                            if retry > 3 {
+                                tracing::error!("递归列出目录失败，跳过: {}: {}", dir_uri, e);
+                                break;
+                            }
+                            let delay = crate::utils::retry_delay_ms(retry, 2000, 30000);
+                            tracing::warn!("递归列出目录失败 (重试 {}/3): {}: {}, {}ms后重试", retry, dir_uri, e, delay);
+                            tokio::time::sleep(std::time::Duration::from_millis(delay)).await;
+                        }
+                    }
+                }
             }
 
             Ok(())
@@ -274,6 +314,33 @@ impl ApiClient {
         page: u32,
         page_size: u32,
         next_page_token: Option<&str>,
+    ) -> Result<ListFilesResponse> {
+        let max_retries = 3u32;
+        let mut attempt = 0u32;
+        loop {
+            attempt += 1;
+            match self.list_files_page_inner(uri, page, page_size, next_page_token).await {
+                Ok(resp) => return Ok(resp),
+                Err(SyncError::Auth(_)) => return Err(SyncError::Auth("Token 过期".into())),
+                Err(e) if attempt <= max_retries => {
+                    let delay = crate::utils::retry_delay_ms(attempt, 2000, 30000);
+                    tracing::warn!(
+                        "列出文件失败 (重试 {}/{}): uri={}, error={}, {}ms后重试",
+                        attempt, max_retries, uri, e, delay,
+                    );
+                    tokio::time::sleep(std::time::Duration::from_millis(delay)).await;
+                }
+                Err(e) => return Err(e),
+            }
+        }
+    }
+
+    async fn list_files_page_inner(
+        &self,
+        uri: &str,
+        page: u32,
+        page_size: u32,
+        next_page_token: Option<&str>,
     ) -> Result<ListFilesResponse> {
         let data = self.send_with_auth_retry(|token| {
             let mut req = self.client
@@ -389,14 +456,56 @@ impl ApiClient {
         let chunk_size = data.get("chunk_size")
             .and_then(|c| c.as_u64())
             .unwrap_or(10 * 1024 * 1024);
+        let upload_urls: Vec<String> = data.get("upload_urls")
+            .and_then(|u| u.as_array())
+            .map(|arr| arr.iter().filter_map(|v| v.as_str().map(String::from)).collect())
+            .unwrap_or_default();
+        let storage_policy_type = data.get("storage_policy")
+            .and_then(|sp| sp.get("type"))
+            .and_then(|t| t.as_str())
+            .unwrap_or("local")
+            .to_string();
+        let callback_secret = data.get("callback_secret")
+            .and_then(|s| s.as_str())
+            .unwrap_or("")
+            .to_string();
+
+        let file_name = uri.rsplit('/').next().unwrap_or(uri).to_string();
+
+        tracing::info!(
+            "[{}] 创建上传会话: policy={}, urls={}, chunk_size={}",
+            file_name, storage_policy_type, upload_urls.len(), chunk_size,
+        );
 
         Ok(UploadSession {
             session_id,
             chunk_size,
+            upload_urls,
+            storage_policy_type,
+            callback_secret,
+            file_name,
         })
     }
 
     pub async fn upload_chunk(
+        &self,
+        session: &UploadSession,
+        index: u32,
+        data: &[u8],
+        file_size: u64,
+        task_id: &str,
+    ) -> Result<()> {
+        if let Some(url) = session.chunk_upload_url(index as usize) {
+            // 远程存储策略：直接上传到外部 URL（OneDrive/S3/OSS 等）
+            self.upload_chunk_to_remote(url, data, index, file_size, session, task_id).await
+        } else {
+            // 本地存储策略：上传到 Cloudreve 服务端
+            self.upload_chunk_local(&session.session_id, index, data).await
+        }
+    }
+
+    /// 本地存储：上传分片到 /file/upload/{session_id}/{index}
+    async fn upload_chunk_local(
         &self,
         session_id: &str,
         index: u32,
@@ -417,6 +526,88 @@ impl ApiClient {
         Ok(())
     }
 
+    /// 远程存储：上传分片到外部 URL（OneDrive/S3 等），无需 Cloudreve token
+    /// 必须带 Content-Range 头：bytes {start}-{end}/{total}
+    async fn upload_chunk_to_remote(
+        &self,
+        url: &str,
+        data: &[u8],
+        index: u32,
+        file_size: u64,
+        session: &UploadSession,
+        task_id: &str,
+    ) -> Result<()> {
+        let chunk_size = session.chunk_size;
+        let file_name = &session.file_name;
+        let start = index as u64 * chunk_size;
+        let end = start + data.len() as u64 - 1;
+        let content_range = format!("bytes {}-{}/{}", start, end, file_size);
+        let content_len = data.len().to_string();
+
+        tracing::debug!("[{}][{}] 远程存储上传分片 {}: Content-Range={}", task_id, file_name, index, content_range);
+
+        let resp = self.client
+            .put(url)
+            .header("Content-Length", &content_len)
+            .header("Content-Range", &content_range)
+            .body(data.to_vec())
+            .timeout(std::time::Duration::from_secs(300))
+            .send()
+            .await
+            .map_err(|e| {
+                tracing::warn!("[{}][{}] 远程存储上传失败: error={}", task_id, file_name, e);
+                SyncError::from(e)
+            })?;
+
+        if !resp.status().is_success() {
+            let status = resp.status();
+            let body = resp.text().await.unwrap_or_default();
+            return Err(SyncError::UploadFailed(format!(
+                "远程存储返回 HTTP {}: {}",
+                status,
+                body.chars().take(200).collect::<String>()
+            )));
+        }
+
+        // 202 = 分片已接收，上传未完成，继续下一个分片
+        // 200/201 = 上传完成，文件已创建
+        let status = resp.status();
+        if status.as_u16() == 202 {
+            tracing::debug!("[{}][{}] 远程存储分片 {} 已接收(202)，继续上传", task_id, file_name, index);
+        } else if status.as_u16() == 200 || status.as_u16() == 201 {
+            tracing::info!("[{}][{}] 远程存储上传完成({}), 分片 {}", task_id, file_name, status, index);
+        }
+
+        Ok(())
+    }
+
+    /// 远程存储上传完成后回调 Cloudreve 服务端
+    /// POST /callback/{storage_policy_type}/{session_id}/{callback_secret}
+    pub async fn callback_upload_complete(&self, session: &UploadSession, task_id: &str) -> Result<()> {
+        if session.callback_secret.is_empty() {
+            tracing::warn!("[{}][{}] 上传回调跳过: callback_secret 为空", task_id, session.file_name);
+            return Ok(());
+        }
+
+        let url = format!(
+            "{}/callback/{}/{}/{}",
+            self.base_url,
+            session.storage_policy_type,
+            session.session_id,
+            session.callback_secret,
+        );
+        tracing::info!("[{}][{}] 上传完成回调: policy={}, session={}", task_id, session.file_name, session.storage_policy_type, session.session_id);
+
+        self.send_with_auth_retry(|token| {
+            self.client
+                .post(&url)
+                .bearer_auth(&token)
+        }).await?;
+
+        tracing::info!("[{}][{}] 上传完成回调成功: policy={}, session={}", task_id, session.file_name, session.storage_policy_type, session.session_id);
+        Ok(())
+    }
+
     // ===== 下载 =====
 
     pub async fn get_download_url(&self, uris: &[&str]) -> Result<Vec<String>> {

native/sync-core/src/errors.rs

@@ -1,3 +1,4 @@
+use std::error::Error as StdError;
 use thiserror::Error;
 
 #[derive(Error, Debug)]
@@ -14,6 +15,18 @@ pub enum SyncError {
     #[error("远程文件已存在")]
     ObjectExisted,
 
+    #[error("存储策略不允许: {0}")]
+    StoragePolicyDenied(String),
+
+    #[error("上传失败: {0}")]
+    UploadFailed(String),
+
+    #[error("文件未找到: {0}")]
+    FileNotFound(String),
+
+    #[error("权限不足: {0}")]
+    PermissionDenied(String),
+
     #[error("文件锁定冲突")]
     LockConflict { tokens: Vec<LockConflictItem> },
 
@@ -56,7 +69,39 @@ impl From<r2d2::Error> for SyncError {
 
 impl From<reqwest::Error> for SyncError {
     fn from(e: reqwest::Error) -> Self {
-        SyncError::Network(e.to_string())
+        let mut detail = String::new();
+        if e.is_connect() {
+            detail.push_str("连接失败");
+        } else if e.is_timeout() {
+            detail.push_str("请求超时");
+        } else if e.is_request() {
+            detail.push_str("请求构建失败");
+        } else if e.is_body() {
+            detail.push_str("请求体错误");
+        } else if e.is_decode() {
+            detail.push_str("响应解码失败");
+        } else if e.is_redirect() {
+            detail.push_str("重定向过多");
+        }
+        let url = e.url().map(|u| u.to_string()).unwrap_or_default();
+        let source = StdError::source(&e)
+            .map(|s| format!(": {s}"))
+            .unwrap_or_default();
+        let msg = e.to_string();
+        // 如果 detail 为空，用 reqwest 原始消息
+        if detail.is_empty() {
+            SyncError::Network(if url.is_empty() {
+                format!("{msg}{source}")
+            } else {
+                format!("{msg} [{url}]{source}")
+            })
+        } else {
+            SyncError::Network(if url.is_empty() {
+                format!("{detail}: {msg}{source}")
+            } else {
+                format!("{detail}: {msg} [{url}]{source}")
+            })
+        }
     }
 }
 

native/sync-core/src/lib.rs

@@ -5,6 +5,7 @@ pub mod errors;
 pub mod utils;
 pub mod sync_db;
 pub mod api_client;
+pub mod server_error_code;
 pub mod fs_scanner;
 pub mod conflict_resolver;
 pub mod transfer;

native/sync-core/src/models.rs

@@ -283,6 +283,35 @@ pub enum PlatformCallbackEvent {
 pub struct UploadSession {
     pub session_id: String,
     pub chunk_size: u64,
+    /// 远程存储的上传 URL 列表（每个分片一个 URL）
+    /// 仅当 storage_policy_type != "local" 时有值
+    pub upload_urls: Vec<String>,
+    /// 存储策略类型：local / onedrive / s3 / oss / cos / etc.
+    pub storage_policy_type: String,
+    /// 回调密钥（远程存储上传完成后需要回调通知服务端）
+    pub callback_secret: String,
+    /// 上传文件名（仅用于日志标识，并发时区分不同文件）
+    pub file_name: String,
+}
+
+impl UploadSession {
+    /// 是否使用远程存储直接上传（非本地策略）
+    pub fn is_remote_storage(&self) -> bool {
+        self.storage_policy_type != "local" && !self.upload_urls.is_empty()
+    }
+
+    /// 获取第 index 个分片的上传 URL
+    /// 远程存储：返回 upload_urls[index]（不足则用最后一个）
+    /// 本地存储：返回 None，由调用方拼接 /file/upload/{session_id}/{index}
+    pub fn chunk_upload_url(&self, index: usize) -> Option<&str> {
+        if !self.is_remote_storage() {
+            return None;
+        }
+        if self.upload_urls.is_empty() {
+            return None;
+        }
+        Some(self.upload_urls[index.min(self.upload_urls.len() - 1)].as_str())
+    }
 }
 
 // ===== API 分页响应 =====

native/sync-core/src/server_error_code.rs

@@ -0,0 +1,92 @@
+use crate::errors::SyncError;
+
+/// Cloudreve 服务端错误码 → 中文描述映射
+pub fn server_code_desc(code: i32) -> Option<&'static str> {
+    Some(match code {
+        // HTTP 语义码
+        203 => "部分操作未成功",
+        401 => "未登录",
+        403 => "无权限访问",
+        404 => "资源不存在",
+        409 => "资源冲突",
+        // 4xxxx 业务码
+        40001 => "参数错误",
+        40002 => "上传失败",
+        40003 => "文件夹创建失败",
+        40004 => "对象已存在",
+        40005 => "签名已过期",
+        40006 => "当前存储策略不允许",
+        40007 => "用户组不允许此操作",
+        40008 => "需要管理员权限",
+        40009 => "主节点未注册",
+        40010 => "需要绑定手机",
+        40011 => "上传会话已过期",
+        40012 => "无效的分片序号",
+        40013 => "无效的 Content-Length",
+        40014 => "批量源大小超限",
+        40016 => "父目录不存在",
+        40017 => "用户被封禁",
+        40018 => "用户未激活",
+        40019 => "功能未启用",
+        40020 => "凭据无效",
+        40021 => "用户不存在",
+        40022 => "两步验证码错误",
+        40023 => "登录会话不存在",
+        40026 => "验证码错误",
+        40027 => "验证码需要刷新",
+        40035 => "存储策略不存在",
+        40044 => "文件未找到",
+        40045 => "列出文件失败",
+        40049 => "文件过大",
+        40050 => "文件类型不允许",
+        40051 => "用户容量不足",
+        40052 => "非法对象名",
+        40053 => "根目录受保护",
+        40054 => "同名文件正在上传",
+        40055 => "元数据不匹配",
+        40057 => "可用存储策略已变更",
+        40071 => "签名无效",
+        40073 => "文件锁定冲突",
+        40074 => "URI 数量过多",
+        40075 => "锁令牌已过期",
+        40077 => "实体不存在",
+        40078 => "文件在回收站中",
+        40079 => "文件数量已达上限",
+        40081 => "批量操作未完全完成",
+        40082 => "仅所有者可操作",
+        // 5xxxx 服务端内部错误
+        50001 => "数据库操作失败",
+        50002 => "加密失败",
+        50004 => "IO 操作失败",
+        50006 => "缓存操作失败",
+        50007 => "回调失败",
+        50010 => "节点离线",
+        _ => return None,
+    })
+}
+
+/// 将服务端业务错误码转为 SyncError
+pub fn api_code_to_error(code: i32, msg: &str) -> SyncError {
+    let desc = server_code_desc(code);
+    let detail = if msg.is_empty() {
+        desc.unwrap_or("未知错误").to_string()
+    } else if let Some(d) = desc {
+        if msg != d {
+            format!("{}: {}", d, msg)
+        } else {
+            msg.to_string()
+        }
+    } else {
+        msg.to_string()
+    };
+
+    match code {
+        401 => SyncError::Auth(detail),
+        40004 => SyncError::ObjectExisted,
+        40006 | 40035 | 40057 => SyncError::StoragePolicyDenied(detail),
+        40002 | 40011 | 40012 | 40013 | 40054 => SyncError::UploadFailed(detail),
+        40044 | 40077 => SyncError::FileNotFound(detail),
+        40017 | 40018 | 40007 | 40008 => SyncError::PermissionDenied(detail),
+        _ => SyncError::Network(format!("[{}] {}", code, detail)),
+    }
+}

native/sync-core/src/sync_engine/album.rs

@@ -22,7 +22,7 @@ impl SyncEngine {
                     let file_size = metadata.len();
                     match self.api.create_upload_session(remote_dcim_uri, file_size, false, None, None, None).await {
                         Ok(session) => {
-                            match crate::uploader::upload_file_chunked(&self.api, local_path, &session).await {
+                            match crate::uploader::upload_file_chunked(&self.api, local_path, &session, "album").await {
                                 Ok(_) => {
                                     let remote_uri = format!("{}/{}", remote_dcim_uri, file_name);
                                     let hash = crate::utils::quick_hash(local_path, file_size).await.unwrap_or_default();

native/sync-core/src/sync_engine/remote_events.rs

@@ -78,6 +78,10 @@ impl SyncEngine {
                 }
             }
             RemoteFileEvent::Deleted { uri, name } => {
+                // 清理过期抑制条目
+                let now = std::time::Instant::now();
+                self.suppress_paths.retain(|_, ts| now.duration_since(*ts).as_secs() < 30);
+
                 let relative = crate::diff::remote_relative_path(
                     remote_root,
                     uri,
@@ -86,6 +90,13 @@ impl SyncEngine {
                 );
                 tracing::info!("[远程事件] 删除: {}", relative);
 
+                // 被抑制的路径：上传失败清理远端碎片等场景，不应删除本地文件
+                if self.suppress_paths.contains_key(&relative) {
+                    tracing::info!("[远程事件] 删除已抑制，跳过本地删除: {}", relative);
+                    self.suppress_paths.remove(&relative);
+                    return;
+                }
+
                 let local_path = local_root.join(&relative);
                 if local_path.exists() {
                     if local_path.is_dir() {

native/sync-core/src/uploader.rs

@@ -126,9 +126,15 @@ pub async fn upload_file(
         let chunk = &buf[..filled];
         let mut chunk_retries = 0u32;
         loop {
-            match api.upload_chunk(&session.session_id, index, chunk).await {
+            match api.upload_chunk(&session, index, chunk, local.size, task_id).await {
                 Ok(_) => break,
                 Err(SyncError::Auth(_)) => return Err(SyncError::Auth("Token 过期".into())),
+                // 业务错误，重试无意义，直接失败
+                Err(e @ SyncError::StoragePolicyDenied(_))
+                | Err(e @ SyncError::UploadFailed(_))
+                | Err(e @ SyncError::FileNotFound(_))
+                | Err(e @ SyncError::PermissionDenied(_))
+                | Err(e @ SyncError::ObjectExisted) => return Err(e),
                 Err(e) if chunk_retries < max_retries => {
                     chunk_retries += 1;
                     let delay = crate::utils::retry_delay_ms(chunk_retries, 1000, 30000);
@@ -141,6 +147,13 @@ pub async fn upload_file(
         index += 1;
     }
 
+    // 远程存储策略：上传完成后回调 Cloudreve 服务端
+    if session.is_remote_storage() {
+        if let Err(e) = api.callback_upload_complete(&session, task_id).await {
+            tracing::warn!("[{}][{}] 上传完成回调失败: {}", task_id, session.file_name, e);
+        }
+    }
+
     // 上传完成后获取远程文件信息
     let remote_uri = file_uri.clone();
     let (remote_file_id, remote_hash) = match api.get_file_info(&remote_uri).await {
@@ -206,6 +219,11 @@ pub async fn retry_upload_session(
                 }
                 return Err(SyncError::LockConflict { tokens });
             }
+            // 业务错误，重试无意义，直接失败
+            Err(e @ SyncError::StoragePolicyDenied(_))
+            | Err(e @ SyncError::UploadFailed(_))
+            | Err(e @ SyncError::FileNotFound(_))
+            | Err(e @ SyncError::PermissionDenied(_)) => return Err(e),
             Err(e) if attempt <= max_retries => {
                 let delay = crate::utils::retry_delay_ms(attempt, 1000, 30000);
                 tracing::warn!("[{}] 创建上传会话失败，{}ms后重试 ({}): {}", task_id, delay, attempt, e);
@@ -273,9 +291,11 @@ pub async fn upload_file_chunked(
     api: &ApiClient,
     local_path: &Path,
     session: &UploadSession,
+    task_id: &str,
 ) -> Result<()> {
     let chunk_size = session.chunk_size as usize;
     let file = tokio::fs::File::open(local_path).await?;
+    let file_size = file.metadata().await.map(|m| m.len()).unwrap_or(0);
     let mut reader = tokio::io::BufReader::new(file);
     let mut buf = vec![0u8; chunk_size];
     let mut index: u32 = 0;
@@ -291,9 +311,16 @@ pub async fn upload_file_chunked(
         }
         if filled == 0 { break; }
 
-        api.upload_chunk(&session.session_id, index, &buf[..filled]).await?;
+        api.upload_chunk(session, index, &buf[..filled], file_size, task_id).await?;
         index += 1;
     }
 
+    // 远程存储策略：上传完成后回调 Cloudreve 服务端
+    if session.is_remote_storage() {
+        if let Err(e) = api.callback_upload_complete(session, task_id).await {
+            tracing::warn!("[{}][{}] 上传完成回调失败: {}", task_id, session.file_name, e);
+        }
+    }
+
     Ok(())
 }

native/sync-core/src/worker/pool.rs

@@ -26,6 +26,8 @@ pub struct WorkerPool {
     file_locks: Arc<FileLockRegistry>,
     ensured_dirs: Arc<DashMap<String, ()>>,
     event_sink: Arc<crate::event_sink::EventSink>,
+    /// 抑制路径：上传失败清理远端碎片时，防止 SSE 删除事件误删本地文件
+    suppress_paths: Arc<DashMap<String, std::time::Instant>>,
     shutdown_token: std::sync::Mutex<CancellationToken>,
     #[cfg(feature = "windows-cfapi")]
     platform_adapter: std::sync::Mutex<Option<Arc<dyn PlaceholderCreator>>>,
@@ -67,6 +69,7 @@ impl WorkerPool {
             file_locks,
             ensured_dirs,
             event_sink,
+            suppress_paths: Arc::new(DashMap::new()),
             shutdown_token: std::sync::Mutex::new(shutdown_token),
             #[cfg(feature = "windows-cfapi")]
             platform_adapter: std::sync::Mutex::new(None),
@@ -133,6 +136,7 @@ impl WorkerPool {
             self.ensured_dirs.clone(),
             conflict_resolver,
             self.event_sink.clone(),
+            self.suppress_paths.clone(),
             self.shutdown_token.lock().unwrap().clone(),
             #[cfg(feature = "windows-cfapi")]
             self.platform_adapter.lock().unwrap().clone(),
@@ -232,6 +236,7 @@ impl WorkerPool {
         let file_locks = self.file_locks.clone();
         let ensured_dirs = self.ensured_dirs.clone();
         let event_sink = self.event_sink.clone();
+        let suppress_paths = self.suppress_paths.clone();
         let shutdown_token = self.shutdown_token.lock().unwrap().clone();
         let active_workers = self.active_workers.clone();
         let active_upload_paths = self.active_upload_paths.clone();
@@ -255,6 +260,7 @@ impl WorkerPool {
                 ensured_dirs,
                 conflict_resolver,
                 event_sink,
+                suppress_paths,
                 shutdown_token,
                 #[cfg(feature = "windows-cfapi")]
                 platform_adapter,

native/sync-core/src/worker/worker_impl.rs

@@ -37,6 +37,8 @@ pub struct Worker {
     ensured_dirs: Arc<DashMap<String, ()>>,
     conflict_resolver: ConflictResolver,
     event_sink: Arc<crate::event_sink::EventSink>,
+    /// 抑制路径：上传失败清理远端碎片时，防止 SSE 删除事件误删本地文件
+    suppress_paths: Arc<DashMap<String, std::time::Instant>>,
     shutdown_token: CancellationToken,
     #[cfg(feature = "windows-cfapi")]
     platform_adapter: Option<Arc<dyn PlaceholderCreator>>,
@@ -55,6 +57,7 @@ impl Worker {
         ensured_dirs: Arc<DashMap<String, ()>>,
         conflict_resolver: ConflictResolver,
         event_sink: Arc<crate::event_sink::EventSink>,
+        suppress_paths: Arc<DashMap<String, std::time::Instant>>,
         shutdown_token: CancellationToken,
         #[cfg(feature = "windows-cfapi")] platform_adapter: Option<Arc<dyn PlaceholderCreator>>,
     ) -> Self {
@@ -69,6 +72,7 @@ impl Worker {
             ensured_dirs,
             conflict_resolver,
             event_sink,
+            suppress_paths,
             shutdown_token,
             #[cfg(feature = "windows-cfapi")]
             platform_adapter,
@@ -783,6 +787,8 @@ impl Worker {
                             Some(&e.to_string()),
                         )
                         .await;
+                    // 清理远端碎片：强制解锁 + 删除
+                    self.cleanup_failed_upload(&rel_path).await;
                 }
                 Err(e) => {
                     tracing::error!("[{}] 上传任务异常: {}: {}", tid, rel_path, e);
@@ -798,6 +804,8 @@ impl Worker {
                             Some(&e.to_string()),
                         )
                         .await;
+                    // 清理远端碎片：强制解锁 + 删除
+                    self.cleanup_failed_upload(&rel_path).await;
                 }
             }
         }
@@ -1208,7 +1216,22 @@ impl Worker {
         }
     }
 
-    /// 7. 删除远程文件（Full 始终删除；MirrorWcf 仅在 WcfDeleteMode::SyncRemote 时删除）
+    // 上传失败后清理远端碎片：删除远端可能已创建的部分文件
+    // delete_files 内部遇到锁冲突(40073)会自动解锁后重试
+    // 删除前先插入 suppress_paths，防止 SSE 删除事件误删本地文件
+    async fn cleanup_failed_upload(&self, relative_path: &str) {
+        let remote_uri = format!("{}/{}", self.config.remote_root, relative_path);
+        let tid = &self.task_id;
+
+        // 先标记抑制，30s 内 SSE 删除事件不会删本地文件
+        self.suppress_paths.insert(relative_path.to_string(), std::time::Instant::now());
+
+        match self.api.delete_files(&[&remote_uri]).await {
+            Ok(_) => tracing::info!("[{}] 上传失败清理-已删除远端碎片: {}", tid, remote_uri),
+            Err(e) => tracing::debug!("[{}] 上传失败清理-删除失败（可能不存在）: {}", tid, e),
+        }
+    }
+
     async fn step_delete_remote(&self, summary: &mut SyncSummary) {
         let should_delete = matches!(self.config.sync_mode, SyncMode::Full)
             || (matches!(self.config.sync_mode, SyncMode::MirrorWcf)

pubspec.yaml

@@ -16,7 +16,7 @@ publish_to: 'none' # Remove this line if you wish to publish to pub.dev
 # https://developer.apple.com/library/archive/documentation/General/Reference/InfoPlistKeyReference/Articles/CoreFoundationKeys.html
 # In Windows, build-name is used as the major, minor, and patch parts
 # of the product and file versions while build-number is used as the build suffix.
-version: 1.3.3+4
+version: 1.3.5+5
 
 environment:
   sdk: ^3.11.4

test/services/update_service_test.dart

@@ -0,0 +1,23 @@
+import 'package:cloudreve4_flutter/services/update_service.dart';
+import 'package:flutter_test/flutter_test.dart';
+
+void main() {
+  group('UpdateService', () {
+    test(
+      'checkForUpdate releases checking flag when package info fails',
+      () async {
+        var calls = 0;
+        final service = UpdateService.test(
+          packageInfoProvider: () async {
+            calls += 1;
+            throw Exception('package info unavailable');
+          },
+        );
+
+        expect(await service.checkForUpdate(), isNull);
+        expect(await service.checkForUpdate(), isNull);
+        expect(calls, 2);
+      },
+    );
+  });
+}