feat(v1.3): 强化搜索定位与安全传输收尾

变更内容:
- 为聊天搜索增加历史结果定位能力，支持从未加载页直接载入命中消息所在页，并在刷新时合并已加载历史避免视图被最新 50 条重置。
- 调整链接打开逻辑，Windows 改为直接启动 explorer.exe，避免通过 cmd.exe 解释消息中的特殊字符。
- 传输取消流程新增主动通知对端收尾，支持活动传输和整组传输先远端取消再本地中止，并补充传输中心相关状态展示。
- 强化身份与发布安全：安全存储缺失私钥时失败关闭，Android release 构建改为强制固定签名，不再静默回退 debug 签名。
- 补充聊天页分页搜索、密钥迁移失败关闭、活动流取消清理接收端、陈旧 queued/sending 恢复等测试。

影响范围:
- 影响聊天页搜索跳转、刷新保留历史、消息链接打开、传输取消收尾以及 Android release 打包策略。
- 本次未提交 pubspec.lock 的镜像源地址变更，也未包含未跟踪的 dist 目录。

验证:
- 已运行 . .\\scripts\\flutter_env.ps1; flutter test test/chat_page_test.dart test/secure_key_migration_test.dart test/transfer_queue_test.dart
- 结果: 17 tests passed.
- 未运行 Android release 构建，原因: 当前提交将缺少 keystore.properties 视为失败，未在本次提交流程中提供发布签名凭据。

Author: Mintcolour

android/app/build.gradle.kts

@@ -7,8 +7,8 @@ plugins {
     id("dev.flutter.flutter-gradle-plugin")
 }
 
-// 读取本地签名凭据（keystore.properties，不入库）。缺失时回退 debug 签名，
-// 保证无证书环境仍可构建；正式发布需提供该文件与对应 .jks（计划 P0：固定签名）。
+// 读取本地签名凭据（keystore.properties，不入库）。Release 始终使用固定签名；
+// 缺少凭据时让构建失败，避免静默产出无法覆盖升级的 debug 签名安装包。
 val keystoreProperties = Properties()
 val keystoreFile = rootProject.file("keystore.properties")
 if (keystoreFile.exists()) {
@@ -47,12 +47,7 @@ android {
 
     buildTypes {
         release {
-            // 优先使用固定 release 签名；凭据缺失时回退 debug，保证可构建。
-            signingConfig = if (keystoreProperties.containsKey("storeFile")) {
-                signingConfigs.getByName("release")
-            } else {
-                signingConfigs.getByName("debug")
-            }
+            signingConfig = signingConfigs.getByName("release")
         }
     }
 }

lib/app/app_controller.dart

@@ -60,6 +60,7 @@ class AppController extends ChangeNotifier {
   late final SecurityService securityService;
   late final TransportService transportService;
   late final DiscoveryService discoveryService;
+
   /// 设置子控制器：语言/外观/自动复制/托盘/开机自启。对外字段与方法通过下方 getter
   /// 与同名方法委托，UI 无需感知拆分（计划 P1 控制器拆分）。
   late final SettingsController settings;
@@ -69,10 +70,13 @@ class AppController extends ChangeNotifier {
   List<Conversation> conversations = [];
   List<ChatMessage> messages = [];
   Map<String, Transfer> transfersById = {};
+
   /// 各会话未读数（conversationId -> count）。
   Map<String, int> unreadCounts = {};
+
   /// 各会话最后一条消息预览（conversationId -> message）。
   Map<String, ChatMessage> lastMessages = {};
+
   /// 会话列表名称过滤关键字。
   String conversationFilter = '';
 
@@ -81,15 +85,18 @@ class AppController extends ChangeNotifier {
     conversationFilter = value;
     notifyListeners();
   }
+
   /// 当前会话分页游标（用于判断是否还有更早的页 + 向前加载）。
   ChatPageCursor? messageCursor;
+
   /// 当前会话是否还有更早的消息可加载。
   bool hasMoreMessages = false;
   Device? selectedDevice;
   Conversation? selectedConversation;
   PendingPairRequest? pendingPairRequest;
   bool initialized = false;
   bool busy = false;
+
   /// 细粒度操作状态：记录正在进行的特定操作（配对、重试等），替代仅靠全局 busy
   /// 禁用输入的做法。文件传输已入队异步执行，不再阻塞输入框（计划 P1）。
   final Set<String> activeOperations = {};
@@ -205,12 +212,22 @@ class AppController extends ChangeNotifier {
             selectedDevice;
         selectedConversation = await db.ensureConversation(selectedDevice!);
         // 分页：刷新时只重载最新一页，避免大历史全量加载。
-        final page = await db.listMessagesPage(
+        final latestPage = await db.listMessagesPage(
           conversationId: selectedConversation!.id,
           limit: 50,
         );
-        messages = page;
-        _updateMessageCursor(page);
+        // 保留用户已经加载的旧页或搜索定位页，只合并最新页的状态与新增消息。
+        // 否则传输进度/在线状态触发的 refresh 会每 200ms 把视图重置回最新 50 条。
+        final merged =
+            <String, ChatMessage>{
+              for (final message in messages) message.id: message,
+              for (final message in latestPage) message.id: message,
+            }.values.toList()..sort((a, b) {
+              final byTime = a.createdAt.compareTo(b.createdAt);
+              return byTime != 0 ? byTime : a.id.compareTo(b.id);
+            });
+        messages = merged;
+        _updateMessageCursor(messages);
         final transferIds = messages
             .map((message) => message.transferId)
             .whereType<String>();
@@ -287,6 +304,26 @@ class AppController extends ChangeNotifier {
     return db.searchMessages(conversation.id, query.trim());
   }
 
+  /// 将搜索命中的历史消息所在页载入当前会话，避免只搜索到结果却无法定位。
+  Future<bool> loadSearchResult(ChatMessage target) async {
+    final conversation = selectedConversation;
+    if (conversation == null || target.conversationId != conversation.id) {
+      return false;
+    }
+    if (messages.any((message) => message.id == target.id)) return true;
+    final page = await db.listMessagesPageEndingAt(
+      conversationId: conversation.id,
+      createdAt: target.createdAt,
+      id: target.id,
+      limit: 50,
+    );
+    messages = page;
+    _updateMessageCursor(page);
+    await _ensureTransfersForCurrentMessages();
+    notifyListeners();
+    return page.any((message) => message.id == target.id);
+  }
+
   void _updateMessageCursor(List<ChatMessage> page) {
     if (page.isEmpty) {
       messageCursor = null;
@@ -424,9 +461,7 @@ class AppController extends ChangeNotifier {
   Future<void> setAutostartEnabled(bool value) async {
     await settings.setAutostartEnabled(value);
     status = value
-        ? (settings.languageCode == 'en'
-              ? 'Start on boot enabled'
-              : '已开启开机自启')
+        ? (settings.languageCode == 'en' ? 'Start on boot enabled' : '已开启开机自启')
         : (settings.languageCode == 'en'
               ? 'Start on boot disabled'
               : '已关闭开机自启');
@@ -759,10 +794,12 @@ class AppController extends ChangeNotifier {
 
   /// 打开消息中的链接：Windows 用默认浏览器，其他平台用 OpenFilex。
   Future<void> openUrl(String url) async {
-    if (url.isEmpty) return;
+    final uri = Uri.tryParse(url);
+    if (uri == null || (uri.scheme != 'http' && uri.scheme != 'https')) return;
     if (Platform.isWindows) {
       try {
-        await Process.run('cmd', ['/c', 'start', '', url]);
+        // 不经过 cmd.exe，避免消息中的 &、| 等字符被解释为 shell 命令。
+        await Process.start('explorer.exe', [url]);
         return;
       } catch (_) {}
     }
@@ -955,11 +992,17 @@ class AppController extends ChangeNotifier {
   /// 取消一个出站传输。优先本地取消（排队或活动任务）；若该任务已发送到对端且
   /// 对端支持取消能力，则同时请求对端中断接收。返回是否成功取消。
   Future<bool> cancelTransfer(Transfer transfer) async {
+    final wasActive = transportService.isOutboundActive(transfer.id);
+    if (wasActive) {
+      final peer = await db.getDevice(transfer.peerDeviceId);
+      if (peer != null && transportService.deviceSupportsCancel(peer)) {
+        // 先让接收端关闭并清理临时文件，再中止本地发送流。
+        await transportService.requestRemoteCancel(peer, transfer.id);
+      }
+    }
     final localCanceled = await transportService.cancelOutbound(transfer.id);
     if (localCanceled) {
-      status = languageCode == 'en'
-          ? 'Transfer canceled'
-          : '已取消传输';
+      status = languageCode == 'en' ? 'Transfer canceled' : '已取消传输';
       notifyListeners();
       return true;
     }
@@ -976,15 +1019,26 @@ class AppController extends ChangeNotifier {
     final ok = await transportService.requestRemoteCancel(peer, transfer.id);
     status = ok
         ? (languageCode == 'en' ? 'Transfer canceled' : '已取消传输')
-        : (languageCode == 'en'
-              ? 'Transfer could not be canceled'
-              : '无法取消该传输');
+        : (languageCode == 'en' ? 'Transfer could not be canceled' : '无法取消该传输');
     notifyListeners();
     return ok;
   }
 
   /// 取消整组出站传输（文件夹或批量附件）。
   Future<int> cancelTransferGroup(String groupId) async {
+    final activeTransferId = transportService.activeOutboundTransferIdForGroup(
+      groupId,
+    );
+    if (activeTransferId != null) {
+      final transfers = await db.listTransfersByIds([activeTransferId]);
+      final active = transfers.firstOrNull;
+      if (active != null) {
+        final peer = await db.getDevice(active.peerDeviceId);
+        if (peer != null && transportService.deviceSupportsCancel(peer)) {
+          await transportService.requestRemoteCancel(peer, active.id);
+        }
+      }
+    }
     final count = await transportService.cancelOutboundGroup(groupId);
     status = languageCode == 'en'
         ? 'Canceled $count transfer(s)'

lib/data/app_database.dart

@@ -264,7 +264,8 @@ class AppDatabase extends _$AppDatabase {
       // 发现信息只刷新地址、名称、头像、在线状态与能力；签名/交换公钥/指纹绝不
       // 被覆盖。检测到任一身份字段变化即标记 identity_changed，发送侧据此拦截，
       // 要求用户删除后重新配对。
-      final identityChanged = existing.identityChanged == true ||
+      final identityChanged =
+          existing.identityChanged == true ||
           signingPublicKey != existing.signingPublicKey ||
           exchangePublicKey != existing.exchangePublicKey ||
           fingerprint != existing.fingerprint;
@@ -543,6 +544,29 @@ class AppDatabase extends _$AppDatabase {
     });
   }
 
+  /// 读取以指定消息为末尾的一页，用于从全历史搜索结果直接定位到尚未加载的消息。
+  Future<List<ChatMessage>> listMessagesPageEndingAt({
+    required String conversationId,
+    required DateTime createdAt,
+    required String id,
+    int limit = 50,
+  }) {
+    final query = select(chatMessages)
+      ..where((tbl) => tbl.conversationId.equals(conversationId))
+      ..where(
+        (tbl) =>
+            tbl.createdAt.isSmallerThanValue(createdAt) |
+            (tbl.createdAt.equals(createdAt) &
+                (tbl.id.isSmallerThanValue(id) | tbl.id.equals(id))),
+      )
+      ..orderBy([
+        (tbl) => OrderingTerm.desc(tbl.createdAt),
+        (tbl) => OrderingTerm.desc(tbl.id),
+      ])
+      ..limit(limit);
+    return query.get().then((rows) => rows.reversed.toList());
+  }
+
   /// 计算会话在 lastReadAt 之后的未读消息数。lastReadAt 为空时全部计入。
   Future<int> unreadCount(String conversationId, {DateTime? lastReadAt}) async {
     final query = select(chatMessages)
@@ -561,22 +585,21 @@ class AppDatabase extends _$AppDatabase {
     String query,
   ) async {
     final like = '%$query%';
-    final rows = await (select(chatMessages)
-          ..where((tbl) => tbl.conversationId.equals(conversationId))
-          ..where(
-            (tbl) =>
-                (tbl.body.like(like)) | (tbl.fileName.like(like)),
-          )
-          ..orderBy([(tbl) => OrderingTerm.asc(tbl.createdAt)])
-          ..limit(100))
-        .get();
+    final rows =
+        await (select(chatMessages)
+              ..where((tbl) => tbl.conversationId.equals(conversationId))
+              ..where(
+                (tbl) => (tbl.body.like(like)) | (tbl.fileName.like(like)),
+              )
+              ..orderBy([(tbl) => OrderingTerm.asc(tbl.createdAt)])
+              ..limit(100))
+            .get();
     return rows;
   }
 
   /// 更新会话最后阅读时间，用于未读统计清零。
   Future<void> markConversationRead(String conversationId) async {
-    await (update(conversations)
-          ..where((tbl) => tbl.id.equals(conversationId)))
+    await (update(conversations)..where((tbl) => tbl.id.equals(conversationId)))
         .write(ConversationsCompanion(lastReadAt: Value(DateTime.now())));
   }