From 5e74099283e5896fc8e4a6f95ac9d73790a67814 Mon Sep 17 00:00:00 2001
From: OctagonalStar <76486554+OctagonalStar@users.noreply.github.com>
Date: Mon, 23 Feb 2026 17:00:09 +0800
Subject: [PATCH 01/11] feat: local pk ui and base server

Signed-off-by: OctagonalStar <76486554+OctagonalStar@users.noreply.github.com>
---
 android/app/src/main/AndroidManifest.xml      |   3 +
 lib/funcs/local_pk_server.dart                |  66 ++++++++++++
 lib/pages/test_page.dart                      |  28 ++++-
 .../test_pages/local_pk_page.dart             | 101 ++++++++++++++++++
 macos/Flutter/GeneratedPluginRegistrant.swift |   2 +
 pubspec.lock                                  |  42 +++++++-
 pubspec.yaml                                  |   3 +
 7 files changed, 243 insertions(+), 2 deletions(-)
 create mode 100644 lib/funcs/local_pk_server.dart
 create mode 100644 lib/sub_pages_builder/test_pages/local_pk_page.dart

diff --git a/android/app/src/main/AndroidManifest.xml b/android/app/src/main/AndroidManifest.xml
index b366333..1b86e8e 100644
--- a/android/app/src/main/AndroidManifest.xml
+++ b/android/app/src/main/AndroidManifest.xml
@@ -58,6 +58,9 @@
     <uses-permission android:name="android.permission.RECEIVE_BOOT_COMPLETED"/>
     <uses-permission android:name="android.permission.SCHEDULE_EXACT_ALARM"/>
     <uses-permission android:name="android.permission.POST_NOTIFICATIONS" />
+    <uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" />
+    <uses-permission android:name="android.permission.ACCESS_WIFI_STATE" />
+    <uses-permission android:name="android.permission.NEARBY_WIFI_DEVICES" />
     <!-- Required to query activities that can process text, see:
          https://developer.android.com/training/package-visibility and
          https://developer.android.com/reference/android/content/Intent#ACTION_PROCESS_TEXT.
diff --git a/lib/funcs/local_pk_server.dart b/lib/funcs/local_pk_server.dart
new file mode 100644
index 0000000..1c61aa6
--- /dev/null
+++ b/lib/funcs/local_pk_server.dart
@@ -0,0 +1,66 @@
+import 'dart:io' show HttpServer;
+import 'dart:math';
+import 'dart:convert';
+import 'dart:typed_data' show Uint8List;
+import 'package:network_info_plus/network_info_plus.dart';
+import 'package:arabic_learning/vars/statics_var.dart';
+import 'package:flutter/foundation.dart' show ChangeNotifier;
+import 'package:shelf/shelf.dart';
+import 'package:shelf/shelf_io.dart' as io;
+import 'package:shelf_router/shelf_router.dart';
+
+class PKServer with ChangeNotifier{
+
+  bool started = false;
+  late final HttpServer _server;
+  late final int _port;
+  late final String? _localIP;
+  final NetworkInfo _networkInfo = NetworkInfo();
+
+  String? get connectpwd {
+    if(!started) return null;
+    List<int> tmp = List<int>.generate(3, (int index) => int.parse(_localIP!.split(".")[index + 1]), growable: false);
+    int iphex = (((tmp[0] << 16) | (tmp[1] << 8) | tmp[2]) << 16) | (_port & 0xFFFF);
+    Uint8List bytes = Uint8List(5);
+    bytes[0] = (iphex >> 32) & 0xFF;
+    bytes[1] = (iphex >> 24) & 0xFF;
+    bytes[2] = (iphex >> 16) & 0xFF;
+    bytes[3] = (iphex >> 8) & 0xFF;
+    bytes[4] = iphex & 0xFF;
+    return base64Encode(bytes).replaceAll("=", "");
+  }
+
+  Future<bool> start() async {
+    if(started) return true;
+
+    _port = Random().nextInt(55535)+10000;
+    final router = Router();
+
+    router.get('/api/check', (Request req) {
+      return Response.ok(
+        '{"version":${StaticsVar.appVersion}}',
+        headers: {'Content-Type': 'application/json'},
+      );
+    });
+
+    router.post('/api/exchangeDictSum', (Request req) async {
+      final body = await req.readAsString();
+      return Response.ok('{"received": "$body"}');
+    });
+
+    _server = await io.serve(
+      router.call,
+      '0.0.0.0', // 局域网可访问
+      _port,
+    );
+
+    _localIP = await _networkInfo.getWifiIP();
+
+    started = true;
+    return true;
+  }
+
+  Future<void> stop() async {
+    await _server.close();
+  }
+}
diff --git a/lib/pages/test_page.dart b/lib/pages/test_page.dart
index f14f8e0..94374d2 100644
--- a/lib/pages/test_page.dart
+++ b/lib/pages/test_page.dart
@@ -1,9 +1,11 @@
+import 'package:arabic_learning/funcs/local_pk_server.dart' show PKServer;
 import 'package:flutter/material.dart';
 import 'package:provider/provider.dart';
 
 import 'package:arabic_learning/vars/global.dart';
 import 'package:arabic_learning/vars/statics_var.dart';
-import 'package:arabic_learning/sub_pages_builder/test_pages/listening_test_page.dart';
+import 'package:arabic_learning/sub_pages_builder/test_pages/local_pk_page.dart' show LocalPKSelectPage;
+import 'package:arabic_learning/sub_pages_builder/test_pages/listening_test_page.dart' show ForeListeningSettingPage;
 
 class TestPage extends StatelessWidget {
   const TestPage({super.key});
@@ -14,6 +16,30 @@ class TestPage extends StatelessWidget {
     return Column(
       mainAxisAlignment: MainAxisAlignment.start,
       children: [
+        SizedBox(height: mediaQuery.size.height * 0.05),
+        ElevatedButton.icon(
+          icon: Icon(Icons.connect_without_contact, size: 36.0),
+          label: FittedBox(child: Text('局域网联机', style: TextStyle(fontSize: 34.0))),
+          style: ElevatedButton.styleFrom(
+            backgroundColor: Theme.of(context).colorScheme.onPrimary.withAlpha(150),
+            fixedSize: Size(mediaQuery.size.width * 0.8, mediaQuery.size.height * 0.15),
+            shape: RoundedRectangleBorder(
+              borderRadius: StaticsVar.br,
+            ),
+          ),
+          onPressed: () {
+            context.read<Global>().uiLogger.info("跳转: TestPage => LocalPKSelectPage");
+            Navigator.push(
+              context, 
+              MaterialPageRoute(
+                builder: (context) => ChangeNotifierProvider(
+                  create: (context) => PKServer(),
+                  child: LocalPKSelectPage()
+                )
+              )
+            );
+          },
+        ),
         SizedBox(height: mediaQuery.size.height * 0.05),
         ElevatedButton.icon(
           icon: Icon(Icons.multitrack_audio, size: 36.0),
diff --git a/lib/sub_pages_builder/test_pages/local_pk_page.dart b/lib/sub_pages_builder/test_pages/local_pk_page.dart
new file mode 100644
index 0000000..24b00fd
--- /dev/null
+++ b/lib/sub_pages_builder/test_pages/local_pk_page.dart
@@ -0,0 +1,101 @@
+import 'package:arabic_learning/funcs/local_pk_server.dart';
+import 'package:arabic_learning/vars/statics_var.dart';
+import 'package:flutter/material.dart';
+import 'package:provider/provider.dart';
+
+
+class LocalPKSelectPage extends StatefulWidget {
+  const LocalPKSelectPage({super.key});
+
+  @override
+  State<StatefulWidget> createState() => _LocalPKSelectPage();
+}
+class _LocalPKSelectPage extends State<LocalPKSelectPage> {
+  final TextEditingController connectpwdController = TextEditingController();
+  
+  @override
+  Widget build(BuildContext context) {
+    MediaQueryData mediaQuery = MediaQuery.of(context);
+    PKServer notifier = context.read<PKServer>();
+    return Scaffold(
+      appBar: AppBar(title: Text("局域网联机")),
+      body: Column(
+        children: [
+          SizedBox(height: mediaQuery.size.height * 0.05),
+          ElevatedButton.icon(
+            style: ElevatedButton.styleFrom(
+              fixedSize: Size(mediaQuery.size.width * 0.8, mediaQuery.size.height * 0.2),
+              shape: RoundedRectangleBorder(borderRadius: StaticsVar.br)
+            ),
+            onPressed: (){
+              Navigator.push(
+                context, 
+                MaterialPageRoute(
+                  builder: (context) => ChangeNotifierProvider.value(
+                    value: notifier,
+                    child: ServerHostWatingPage(),
+                  )
+                )
+              );
+            }, 
+            icon: Icon(Icons.manage_accounts, size: 36),
+            label: Text("我做房主（邀请别人）", style: TextStyle(fontSize: 36))
+          ),
+          Divider(height: mediaQuery.size.height * 0.1, thickness: 3),
+          Text("我加入联机", style: Theme.of(context).textTheme.displaySmall),
+          TextField(
+            autocorrect: false,
+            controller: connectpwdController,
+            expands: false,
+            maxLines: 1,
+            keyboardType: TextInputType.visiblePassword,
+            decoration: InputDecoration(
+              labelText: "联机口令",
+              border: OutlineInputBorder(
+                borderRadius: StaticsVar.br,
+                borderSide: BorderSide(color: Theme.of(context).colorScheme.outline),
+              ),
+              suffix: ElevatedButton(
+                onPressed: () {
+                  // TODO
+                }, 
+                child: Text("加入")
+              ),
+            ),
+            onSubmitted: (text) {
+              // TODO
+            },
+          ),
+        ],
+      ),
+    );
+  }
+}
+
+class ServerHostWatingPage extends StatefulWidget {
+  const ServerHostWatingPage({super.key});
+
+  @override
+  State<StatefulWidget> createState() => _ServerHostWatingPage();
+}
+
+class _ServerHostWatingPage extends State<ServerHostWatingPage> {
+  @override
+  Widget build(BuildContext context) {
+    MediaQueryData mediaQuery = MediaQuery.of(context);
+    return FutureBuilder(
+      future: context.read<PKServer>().start(), 
+      initialData: false,
+      builder: (context, snapshot) {
+        return Scaffold(
+          appBar: AppBar(title: Text(snapshot.data??false ? "等待其他人进入" : "正在启动服务")),
+          body: Center(
+            child: snapshot.data??false
+                  ? Text("联机口令: ${context.read<PKServer>().connectpwd}")
+                  : CircularProgressIndicator(semanticsLabel: "服务加载中")
+          ),
+        );
+      }
+    );
+  }
+}
\ No newline at end of file
diff --git a/macos/Flutter/GeneratedPluginRegistrant.swift b/macos/Flutter/GeneratedPluginRegistrant.swift
index c1d2358..13fa8e1 100644
--- a/macos/Flutter/GeneratedPluginRegistrant.swift
+++ b/macos/Flutter/GeneratedPluginRegistrant.swift
@@ -10,6 +10,7 @@ import file_picker
 import flutter_local_notifications
 import flutter_tts
 import just_audio
+import network_info_plus
 import screen_retriever_macos
 import shared_preferences_foundation
 import url_launcher_macos
@@ -21,6 +22,7 @@ func RegisterGeneratedPlugins(registry: FlutterPluginRegistry) {
   FlutterLocalNotificationsPlugin.register(with: registry.registrar(forPlugin: "FlutterLocalNotificationsPlugin"))
   FlutterTtsPlugin.register(with: registry.registrar(forPlugin: "FlutterTtsPlugin"))
   JustAudioPlugin.register(with: registry.registrar(forPlugin: "JustAudioPlugin"))
+  NetworkInfoPlusPlugin.register(with: registry.registrar(forPlugin: "NetworkInfoPlusPlugin"))
   ScreenRetrieverMacosPlugin.register(with: registry.registrar(forPlugin: "ScreenRetrieverMacosPlugin"))
   SharedPreferencesPlugin.register(with: registry.registrar(forPlugin: "SharedPreferencesPlugin"))
   UrlLauncherPlugin.register(with: registry.registrar(forPlugin: "UrlLauncherPlugin"))
diff --git a/pubspec.lock b/pubspec.lock
index ea47f08..cd04235 100644
--- a/pubspec.lock
+++ b/pubspec.lock
@@ -384,6 +384,14 @@ packages:
       url: "https://pub.dev"
     source: hosted
     version: "1.6.0"
+  http_methods:
+    dependency: transitive
+    description:
+      name: http_methods
+      sha256: "6bccce8f1ec7b5d701e7921dca35e202d425b57e317ba1a37f2638590e29e566"
+      url: "https://pub.dev"
+    source: hosted
+    version: "1.1.1"
   http_multi_server:
     dependency: transitive
     description:
@@ -560,6 +568,30 @@ packages:
       url: "https://pub.dev"
     source: hosted
     version: "1.0.0"
+  network_info_plus:
+    dependency: "direct main"
+    description:
+      name: network_info_plus
+      sha256: "2866dadcbee2709e20d67737a1556f5675b8b0cdcf2c1659ba74bc21bffede4f"
+      url: "https://pub.dev"
+    source: hosted
+    version: "7.0.0"
+  network_info_plus_platform_interface:
+    dependency: transitive
+    description:
+      name: network_info_plus_platform_interface
+      sha256: "7e7496a8a9d8136859b8881affc613c4a21304afeb6c324bcefc4bd0aff6b94b"
+      url: "https://pub.dev"
+    source: hosted
+    version: "2.0.2"
+  nm:
+    dependency: transitive
+    description:
+      name: nm
+      sha256: "2c9aae4127bdc8993206464fcc063611e0e36e72018696cd9631023a31b24254"
+      url: "https://pub.dev"
+    source: hosted
+    version: "0.5.0"
   node_preamble:
     dependency: transitive
     description:
@@ -841,7 +873,7 @@ packages:
     source: hosted
     version: "2.4.1"
   shelf:
-    dependency: transitive
+    dependency: "direct main"
     description:
       name: shelf
       sha256: e7dd780a7ffb623c57850b33f43309312fc863fb6aa3d276a754bb299839ef12
@@ -856,6 +888,14 @@ packages:
       url: "https://pub.dev"
     source: hosted
     version: "3.0.2"
+  shelf_router:
+    dependency: "direct main"
+    description:
+      name: shelf_router
+      sha256: f5e5d492440a7fb165fe1e2e1a623f31f734d3370900070b2b1e0d0428d59864
+      url: "https://pub.dev"
+    source: hosted
+    version: "1.1.4"
   shelf_static:
     dependency: transitive
     description:
diff --git a/pubspec.yaml b/pubspec.yaml
index 2698397..2178e3c 100644
--- a/pubspec.yaml
+++ b/pubspec.yaml
@@ -50,6 +50,9 @@ dependencies:
   logging: ^1.3.0
   flutter_local_notifications: ^20.1.0
   workmanager: ^0.9.0+3
+  shelf: ^1.4.2
+  shelf_router: ^1.1.4
+  network_info_plus: ^7.0.0
   # file_saver: ^0.3.1
   cupertino_icons: ^1.0.8
   bk_tree: ^0.1.2

From bc7fc777ae30da2718875424618aac0757cbd7cf Mon Sep 17 00:00:00 2001
From: OctagonalStar <76486554+OctagonalStar@users.noreply.github.com>
Date: Mon, 23 Feb 2026 20:36:20 +0800
Subject: [PATCH 02/11] feat: local pk pre connection

Signed-off-by: OctagonalStar <76486554+OctagonalStar@users.noreply.github.com>
---
 lib/funcs/local_pk_server.dart                | 104 ++++++++++++++++--
 lib/funcs/ui.dart                             |  19 +++-
 lib/pages/test_page.dart                      |   2 +-
 .../test_pages/local_pk_page.dart             |  51 +++++++--
 lib/vars/config_structure.dart                |   5 +
 pubspec.lock                                  |   2 +-
 pubspec.yaml                                  |   1 +
 7 files changed, 159 insertions(+), 25 deletions(-)

diff --git a/lib/funcs/local_pk_server.dart b/lib/funcs/local_pk_server.dart
index 1c61aa6..5e9227f 100644
--- a/lib/funcs/local_pk_server.dart
+++ b/lib/funcs/local_pk_server.dart
@@ -2,19 +2,27 @@ import 'dart:io' show HttpServer;
 import 'dart:math';
 import 'dart:convert';
 import 'dart:typed_data' show Uint8List;
+import 'package:arabic_learning/vars/config_structure.dart';
+import 'package:arabic_learning/vars/global.dart';
+import 'package:logging/logging.dart';
 import 'package:network_info_plus/network_info_plus.dart';
 import 'package:arabic_learning/vars/statics_var.dart';
 import 'package:flutter/foundation.dart' show ChangeNotifier;
 import 'package:shelf/shelf.dart';
 import 'package:shelf/shelf_io.dart' as io;
 import 'package:shelf_router/shelf_router.dart';
+import 'package:dio/dio.dart' as dio;
 
 class PKServer with ChangeNotifier{
 
   bool started = false;
+  bool connected = false;
+  final Logger logger = Logger("PKServer");
   late final HttpServer _server;
   late final int _port;
   late final String? _localIP;
+  List<SourceItem> selectableSource = [];
+  late Global global;
   final NetworkInfo _networkInfo = NetworkInfo();
 
   String? get connectpwd {
@@ -30,10 +38,15 @@ class PKServer with ChangeNotifier{
     return base64Encode(bytes).replaceAll("=", "");
   }
 
-  Future<bool> start() async {
-    if(started) return true;
+  Future<void> init(Global outerglobal) async {
+    _localIP = await _networkInfo.getWifiIP();
+    global = outerglobal;
+  }
 
+  Future<bool> startHost() async {
+    if(started) return true;
     _port = Random().nextInt(55535)+10000;
+    logger.fine("正在启动服务，随机端口: $_port");
     final router = Router();
 
     router.get('/api/check', (Request req) {
@@ -43,9 +56,21 @@ class PKServer with ChangeNotifier{
       );
     });
 
-    router.post('/api/exchangeDictSum', (Request req) async {
-      final body = await req.readAsString();
-      return Response.ok('{"received": "$body"}');
+    router.post('/api/testDictSum', (Request req) async {
+      Map<String, dynamic> body = json.decode(await req.readAsString());
+      // {
+      //  "dictSum": ["SHA256", ...]
+      // }
+      List sumList = body["dictSum"];
+      selectableSource.clear();
+      for(SourceItem source in global.wordData.classes) {
+        if(sumList.contains(source.getHash())) selectableSource.add(source);
+      }
+      if(selectableSource.isNotEmpty) connected = true;
+      return Response.ok(json.encode({
+        "accept": selectableSource.isNotEmpty,
+        "allowed": List<String>.generate(selectableSource.length, (int index) => selectableSource[index].getHash(), growable: false)
+      }));
     });
 
     _server = await io.serve(
@@ -54,13 +79,76 @@ class PKServer with ChangeNotifier{
       _port,
     );
 
-    _localIP = await _networkInfo.getWifiIP();
-
+    logger.fine("服务端已启动");
     started = true;
     return true;
   }
 
-  Future<void> stop() async {
+  Future<void> stopHost() async {
     await _server.close();
+    logger.info("服务端已关闭");
+  }
+
+  List<int>? decodeConnectPwd(String connectpwd){
+    logger.info("尝试解码$connectpwd");
+    while (connectpwd.length == 7) {
+      connectpwd = "$connectpwd=";
+    }
+    late Uint8List tmp;
+    try{
+      tmp = base64Decode(connectpwd);
+    } catch (e) {
+      logger.warning("解码错误");
+      return null;
+    }
+    
+    if(tmp.length != 5){
+      logger.warning("解码错误");
+      return null;
+    }
+    int comb = (tmp[0] << 32) | (tmp[1] << 24) | (tmp[2] << 16) | (tmp[3] << 8) | tmp[4];
+    int port = comb & 0xFFFF;
+    int iphex= comb >> 16;
+    return [(iphex >> 16) & 0xFF, (iphex >> 8 & 0xFF), iphex & 0xFF, port];
+  }
+
+  Future<int> testConnect(String connectpwd) async {
+    List<int>? addressinfo = decodeConnectPwd(connectpwd);
+    if(addressinfo == null) {
+      logger.severe("联机口令解析失败，终止连接");
+      return 1;
+    }
+    final String address = "http://${_localIP!.split(".")[0]}.${addressinfo[0]}.${addressinfo[1]}.${addressinfo[2]}:${addressinfo[3]}";
+    final dio.Dio client = dio.Dio();
+    final checkRes = await client.get("$address/api/check");
+    if(checkRes.statusCode != 200) {
+      logger.severe("连接服务端失败");
+      return 2;
+    }
+    if(checkRes.data["version"] != StaticsVar.appVersion) {
+      logger.severe("版本校验不通过，对方版本为: ${checkRes.data["version"]}，我方为${StaticsVar.appVersion}");
+      return 3;
+    }
+    final dictRes = await client.post(
+      "$address/api/testDictSum", 
+      data: {
+        "dictSum": List<String>.generate(global.wordData.classes.length, (int index) => global.wordData.classes[index].getHash(), growable: false)
+      }
+    );
+    if(dictRes.statusCode != 200) {
+      logger.severe("连接服务端失败");
+      return 2;
+    }
+    if(!json.decode(dictRes.data)["accept"]) {
+      logger.severe("本地与服务端无可使用的相同词库");
+      return 4;
+    }
+    selectableSource.clear();
+    List remoteDict = json.decode(dictRes.data)["allowed"];
+    for(SourceItem source in global.wordData.classes) {
+      if(remoteDict.contains(source.getHash())) selectableSource.add(source);
+    }
+    connected = true;
+    return 0;
   }
 }
diff --git a/lib/funcs/ui.dart b/lib/funcs/ui.dart
index c3e3a87..d845479 100644
--- a/lib/funcs/ui.dart
+++ b/lib/funcs/ui.dart
@@ -36,10 +36,11 @@ import 'package:arabic_learning/funcs/utili.dart';
 /// List<List<String>> value = await popSelectClasses(context);
 /// List<Map<String, dynamic>> words = getSelectedWords(context , forceSelectClasses: value);
 /// ```
-Future<ClassSelection> popSelectClasses(BuildContext context, {bool withCache = false, bool withReviewChoose = true}) async {
+Future<ClassSelection> popSelectClasses(BuildContext context, {bool withCache = false, bool withReviewChoose = true, List<SourceItem>? forceSelectRange}) async {
   context.read<Global>().uiLogger.info("弹出课程选择（ClassSelectPage），withCache: $withCache");
   final List<ClassItem> beforeSelectedClasses = [];
   if(withCache) {
+    if(forceSelectRange != null) throw Exception("popSelectClasses不允许forceSelectRange时使用withCache");
     final String tpcPrefs = context.read<Global>().prefs.getString("tempConfig") ?? jsonEncode(StaticsVar.tempConfig);
     final List<List<String>> cacheList = (jsonDecode(tpcPrefs)["SelectedClasses"] as List)
         .cast<List>()
@@ -92,9 +93,14 @@ Future<ClassSelection> popSelectClasses(BuildContext context, {bool withCache =
 /// [isClassSelected] :需要一个函数判断该课程是否被选中
 /// 
 /// 一般情况下该函数只会在 [ClassSelectPage] 中被使用，若非必要你不应该使用此函数
-List<Widget> classesSelectionList(BuildContext context, Function (ClassItem) onChanged, bool Function (ClassItem) isClassSelected) {
+List<Widget> classesSelectionList(BuildContext context, Function (ClassItem) onChanged, bool Function (ClassItem) isClassSelected, List<SourceItem>? forceSelectRange) {
   context.read<Global>().uiLogger.fine("构建课程选择列表");
-  List<SourceItem> sourcesList = context.read<Global>().wordData.classes;
+  late List<SourceItem> sourcesList;
+  if(forceSelectRange != null) {
+    sourcesList = forceSelectRange;
+  } else {
+    sourcesList = context.read<Global>().wordData.classes;
+  }
   List<Widget> widgetList = [];
   for (SourceItem source in sourcesList) {
     widgetList.add(
@@ -613,14 +619,15 @@ class WordCard extends StatelessWidget {
 class ClassSelectPage extends StatelessWidget { 
   final List<ClassItem> beforeSelectedClasses;
   final bool withReviewChoose;
-  const ClassSelectPage({super.key, this.beforeSelectedClasses = const [], this.withReviewChoose = false});
+  final List<SourceItem>? forceSelectRange;
+  const ClassSelectPage({super.key, this.beforeSelectedClasses = const [], this.withReviewChoose = false, this.forceSelectRange});
   @override
   Widget build(BuildContext context) {
     final MediaQueryData mediaQuery = MediaQuery.of(context);
     ClassSelection classSelection = ClassSelection(
       selectedClass: beforeSelectedClasses.toList(), 
       countInReview: context.read<Global>().globalFSRS.config.enabled
-      );
+    );
     void addClass(ClassItem classInfo) {
       classSelection.selectedClass.add(classInfo);
     }
@@ -646,7 +653,7 @@ class ClassSelectPage extends StatelessWidget {
         children: [
           Expanded(
             child: ListView(
-              children: classesSelectionList(context, onClassChanged, isClassSelected)
+              children: classesSelectionList(context, onClassChanged, isClassSelected, forceSelectRange)
             ),
           ),
           if(withReviewChoose) StatefulBuilder(
diff --git a/lib/pages/test_page.dart b/lib/pages/test_page.dart
index 94374d2..5170e97 100644
--- a/lib/pages/test_page.dart
+++ b/lib/pages/test_page.dart
@@ -33,7 +33,7 @@ class TestPage extends StatelessWidget {
               context, 
               MaterialPageRoute(
                 builder: (context) => ChangeNotifierProvider(
-                  create: (context) => PKServer(),
+                  create: (context) => PKServer()..init(context.read<Global>()),
                   child: LocalPKSelectPage()
                 )
               )
diff --git a/lib/sub_pages_builder/test_pages/local_pk_page.dart b/lib/sub_pages_builder/test_pages/local_pk_page.dart
index 24b00fd..65024ea 100644
--- a/lib/sub_pages_builder/test_pages/local_pk_page.dart
+++ b/lib/sub_pages_builder/test_pages/local_pk_page.dart
@@ -1,4 +1,5 @@
 import 'package:arabic_learning/funcs/local_pk_server.dart';
+import 'package:arabic_learning/funcs/ui.dart';
 import 'package:arabic_learning/vars/statics_var.dart';
 import 'package:flutter/material.dart';
 import 'package:provider/provider.dart';
@@ -12,7 +13,8 @@ class LocalPKSelectPage extends StatefulWidget {
 }
 class _LocalPKSelectPage extends State<LocalPKSelectPage> {
   final TextEditingController connectpwdController = TextEditingController();
-  
+  bool isconnecting = false;
+
   @override
   Widget build(BuildContext context) {
     MediaQueryData mediaQuery = MediaQuery.of(context);
@@ -56,16 +58,26 @@ class _LocalPKSelectPage extends State<LocalPKSelectPage> {
                 borderSide: BorderSide(color: Theme.of(context).colorScheme.outline),
               ),
               suffix: ElevatedButton(
-                onPressed: () {
-                  // TODO
+                onPressed: () async {
+                  if(isconnecting) return;
+                  setState(() {
+                    isconnecting = true;
+                  });
+                  int statue = await context.read<PKServer>().testConnect(connectpwdController.text);
                 }, 
                 child: Text("加入")
               ),
             ),
-            onSubmitted: (text) {
-              // TODO
+            onSubmitted: (text) async {
+              if(isconnecting) return;
+              setState(() {
+                isconnecting = true;
+              });
+              int statue = await context.read<PKServer>().testConnect(text);
             },
           ),
+          SizedBox(height: mediaQuery.size.height * 0.1),
+          if(isconnecting) CircularProgressIndicator()
         ],
       ),
     );
@@ -83,15 +95,36 @@ class _ServerHostWatingPage extends State<ServerHostWatingPage> {
   @override
   Widget build(BuildContext context) {
     MediaQueryData mediaQuery = MediaQuery.of(context);
-    return FutureBuilder(
-      future: context.read<PKServer>().start(), 
+    return context.watch<PKServer>().connected 
+    ? Scaffold(
+      appBar: AppBar(title: Text("连接成功")),
+      body: Center(
+        child: Column(
+          children: [
+            SizedBox(height: mediaQuery.size.height * 0.1),
+            TextContainer(text: "你们双方有一下共有词库，请选择其中的课程开始", style: Theme.of(context).textTheme.headlineMedium),
+            SizedBox(height: mediaQuery.size.height * 0.05),
+            ...List.generate(context.read<PKServer>().selectableSource.length, (int index) => Text(context.read<PKServer>().selectableSource[index].sourceJsonFileName), growable: false),
+            SizedBox(height: mediaQuery.size.height * 0.1),
+            ElevatedButton(
+              onPressed: (){
+                popSelectClasses(context, forceSelectRange: context.read<PKServer>().selectableSource);
+              }, 
+              child: Text("开始选课")
+            )
+          ],
+        ),
+      ),
+    )
+    : FutureBuilder(
+      future: context.read<PKServer>().startHost(), 
       initialData: false,
       builder: (context, snapshot) {
         return Scaffold(
-          appBar: AppBar(title: Text(snapshot.data??false ? "等待其他人进入" : "正在启动服务")),
+          appBar: AppBar(title: Text(snapshot.data??false ? "等待其他人进入..." : "正在启动服务")),
           body: Center(
             child: snapshot.data??false
-                  ? Text("联机口令: ${context.read<PKServer>().connectpwd}")
+                  ? Text("联机口令: ${context.read<PKServer>().connectpwd}", style: Theme.of(context).textTheme.displayMedium)
                   : CircularProgressIndicator(semanticsLabel: "服务加载中")
           ),
         );
diff --git a/lib/vars/config_structure.dart b/lib/vars/config_structure.dart
index c7e47f8..0359474 100644
--- a/lib/vars/config_structure.dart
+++ b/lib/vars/config_structure.dart
@@ -1,5 +1,6 @@
 import 'dart:convert';
 
+import 'package:crypto/crypto.dart';
 import 'package:arabic_learning/vars/statics_var.dart' show StaticsVar;
 import 'package:flutter/foundation.dart' show immutable;
 
@@ -694,6 +695,10 @@ class SourceItem {
     }
     return classesMap;
   }
+
+  String getHash() {
+    return sha256.convert(utf8.encode(toMap().toString())).toString();
+  }
 }
 
 @immutable
diff --git a/pubspec.lock b/pubspec.lock
index cd04235..61565c3 100644
--- a/pubspec.lock
+++ b/pubspec.lock
@@ -154,7 +154,7 @@ packages:
     source: hosted
     version: "0.3.5+2"
   crypto:
-    dependency: transitive
+    dependency: "direct main"
     description:
       name: crypto
       sha256: c8ea0233063ba03258fbcf2ca4d6dadfefe14f02fab57702265467a19f27fadf
diff --git a/pubspec.yaml b/pubspec.yaml
index 2178e3c..e4c2931 100644
--- a/pubspec.yaml
+++ b/pubspec.yaml
@@ -53,6 +53,7 @@ dependencies:
   shelf: ^1.4.2
   shelf_router: ^1.1.4
   network_info_plus: ^7.0.0
+  crypto: ^3.0.7
   # file_saver: ^0.3.1
   cupertino_icons: ^1.0.8
   bk_tree: ^0.1.2

From 4dd4fe4c20f06ea3bd9ea1eb12053c29b661f9de Mon Sep 17 00:00:00 2001
From: OctagonalStar <76486554+OctagonalStar@users.noreply.github.com>
Date: Tue, 24 Feb 2026 17:36:27 +0800
Subject: [PATCH 03/11] feat: added qr code scan

Signed-off-by: OctagonalStar <76486554+OctagonalStar@users.noreply.github.com>
---
 lib/funcs/local_pk_server.dart                |  87 +++++++--
 .../test_pages/local_pk_page.dart             | 180 ++++++++++++++++--
 lib/vars/config_structure.dart                |  19 +-
 macos/Flutter/GeneratedPluginRegistrant.swift |   2 +
 pubspec.lock                                  |  24 +++
 pubspec.yaml                                  |   2 +
 6 files changed, 281 insertions(+), 33 deletions(-)

diff --git a/lib/funcs/local_pk_server.dart b/lib/funcs/local_pk_server.dart
index 5e9227f..a75753a 100644
--- a/lib/funcs/local_pk_server.dart
+++ b/lib/funcs/local_pk_server.dart
@@ -15,16 +15,25 @@ import 'package:dio/dio.dart' as dio;
 
 class PKServer with ChangeNotifier{
 
-  bool started = false;
+  // both
   bool connected = false;
   final Logger logger = Logger("PKServer");
-  late final HttpServer _server;
-  late final int _port;
   late final String? _localIP;
+  late int rndSeed;
   List<SourceItem> selectableSource = [];
+  ClassSelection? classSelection;
   late Global global;
   final NetworkInfo _networkInfo = NetworkInfo();
 
+  // server
+  bool started = false;
+  late final HttpServer _server;
+  late final int _port;
+
+  // client
+  late final String serverAddress;
+  final dio.Dio client = dio.Dio();
+
   String? get connectpwd {
     if(!started) return null;
     List<int> tmp = List<int>.generate(3, (int index) => int.parse(_localIP!.split(".")[index + 1]), growable: false);
@@ -57,6 +66,7 @@ class PKServer with ChangeNotifier{
     });
 
     router.post('/api/testDictSum', (Request req) async {
+      if(connected == true) return Response.forbidden("");
       Map<String, dynamic> body = json.decode(await req.readAsString());
       // {
       //  "dictSum": ["SHA256", ...]
@@ -64,13 +74,33 @@ class PKServer with ChangeNotifier{
       List sumList = body["dictSum"];
       selectableSource.clear();
       for(SourceItem source in global.wordData.classes) {
-        if(sumList.contains(source.getHash())) selectableSource.add(source);
+        if(sumList.contains(source.getHash(global.wordData.words))) selectableSource.add(source);
       }
       if(selectableSource.isNotEmpty) connected = true;
+      notifyListeners();
       return Response.ok(json.encode({
         "accept": selectableSource.isNotEmpty,
-        "allowed": List<String>.generate(selectableSource.length, (int index) => selectableSource[index].getHash(), growable: false)
-      }));
+        "allowed": List<String>.generate(selectableSource.length, (int index) => selectableSource[index].getHash(global.wordData.words), growable: false)
+        }),
+        headers: {'Content-Type': 'application/json'}
+      );
+    });
+
+    router.get('/api/selection', (Request req) {
+      if(classSelection == null) {
+        return Response.ok(json.encode({"statue": false}), headers: {'Content-Type': 'application/json'});
+      }
+      rndSeed = Random().nextInt(1024);
+      return Response.ok(
+        json.encode(
+          {
+            "statue": true,
+            "selected": List<String>.generate(classSelection!.selectedClass.length, (int index) => classSelection!.selectedClass[index].getHash(), growable: false),
+            "seed": rndSeed
+          }
+        ),
+        headers: {'Content-Type': 'application/json'},
+      );
     });
 
     _server = await io.serve(
@@ -118,9 +148,8 @@ class PKServer with ChangeNotifier{
       logger.severe("联机口令解析失败，终止连接");
       return 1;
     }
-    final String address = "http://${_localIP!.split(".")[0]}.${addressinfo[0]}.${addressinfo[1]}.${addressinfo[2]}:${addressinfo[3]}";
-    final dio.Dio client = dio.Dio();
-    final checkRes = await client.get("$address/api/check");
+    serverAddress = "http://${_localIP!.split(".")[0]}.${addressinfo[0]}.${addressinfo[1]}.${addressinfo[2]}:${addressinfo[3]}";
+    final checkRes = await client.get("$serverAddress/api/check");
     if(checkRes.statusCode != 200) {
       logger.severe("连接服务端失败");
       return 2;
@@ -130,25 +159,55 @@ class PKServer with ChangeNotifier{
       return 3;
     }
     final dictRes = await client.post(
-      "$address/api/testDictSum", 
+      "$serverAddress/api/testDictSum", 
       data: {
-        "dictSum": List<String>.generate(global.wordData.classes.length, (int index) => global.wordData.classes[index].getHash(), growable: false)
+        "dictSum": List<String>.generate(global.wordData.classes.length, (int index) => global.wordData.classes[index].getHash(global.wordData.words), growable: false)
       }
     );
     if(dictRes.statusCode != 200) {
       logger.severe("连接服务端失败");
       return 2;
     }
-    if(!json.decode(dictRes.data)["accept"]) {
+    if(!dictRes.data["accept"]) {
       logger.severe("本地与服务端无可使用的相同词库");
       return 4;
     }
     selectableSource.clear();
-    List remoteDict = json.decode(dictRes.data)["allowed"];
+    List remoteDict = dictRes.data["allowed"];
     for(SourceItem source in global.wordData.classes) {
-      if(remoteDict.contains(source.getHash())) selectableSource.add(source);
+      if(remoteDict.contains(source.getHash(global.wordData.words))) selectableSource.add(source);
     }
     connected = true;
+    notifyListeners();
     return 0;
   }
+
+  Future<ClassSelection> watingSelection() async {
+    while(classSelection == null) {
+      await Future.delayed(Duration(seconds: 1));
+      try{
+        final selectionRes = await client.get("$serverAddress/api/selection", options: dio.Options(connectTimeout: Duration(seconds: 1)));
+        if(selectionRes.statusCode == 200) {
+          Map payload = selectionRes.data;
+          if(!payload["statue"]) continue;
+          rndSeed = payload["seed"];
+          List<ClassItem> selectedClass = [];
+          for(SourceItem sourceItem in selectableSource) {
+            for(ClassItem classItem in sourceItem.subClasses){
+              if(payload["selected"].contains(classItem.getHash())){
+                selectedClass.add(classItem);
+              }
+            }
+          }
+          classSelection = ClassSelection(selectedClass: selectedClass, countInReview: false);
+        } else {
+          throw Exception("Unexcepted statusCode: ${selectionRes.statusCode}");
+        }
+      } catch (e) {
+        logger.shout("连接服务端发生错误: $e");
+        rethrow;
+      } 
+    }
+    return classSelection!;
+  }
 }
diff --git a/lib/sub_pages_builder/test_pages/local_pk_page.dart b/lib/sub_pages_builder/test_pages/local_pk_page.dart
index 65024ea..42392d7 100644
--- a/lib/sub_pages_builder/test_pages/local_pk_page.dart
+++ b/lib/sub_pages_builder/test_pages/local_pk_page.dart
@@ -1,7 +1,12 @@
+import 'dart:math';
+
 import 'package:arabic_learning/funcs/local_pk_server.dart';
 import 'package:arabic_learning/funcs/ui.dart';
+import 'package:arabic_learning/vars/config_structure.dart';
 import 'package:arabic_learning/vars/statics_var.dart';
 import 'package:flutter/material.dart';
+import 'package:qr_flutter/qr_flutter.dart';
+import 'package:mobile_scanner/mobile_scanner.dart';
 import 'package:provider/provider.dart';
 
 
@@ -13,7 +18,45 @@ class LocalPKSelectPage extends StatefulWidget {
 }
 class _LocalPKSelectPage extends State<LocalPKSelectPage> {
   final TextEditingController connectpwdController = TextEditingController();
+  final MobileScannerController scannerController = MobileScannerController();
   bool isconnecting = false;
+  bool isScaning = false;
+
+  Future<void> connecting(BuildContext context) async {
+    if(isconnecting || connectpwdController.text.isEmpty) return;
+    setState(() {
+      isconnecting = true;
+    });
+    late final int statue;
+    try {
+      statue = await context.read<PKServer>().testConnect(connectpwdController.text);
+    } catch (e) {
+      if(context.mounted) alart(context, "连接发生错误: $e");
+    }
+    if(!context.mounted) return;
+    if(statue == 0){
+      PKServer notifier = context.read<PKServer>();
+      Navigator.push(
+        context, 
+        MaterialPageRoute(builder: (context) => ChangeNotifierProvider.value(
+          value: notifier,
+          child: ClientWatingPage(),
+        ))
+      );
+    } else if (statue == 1) {
+      alart(context, "联机口令错误");
+    } else if (statue == 2) {
+      alart(context, "连接服务端失败\n请检查是否在同一局域网内及对方防火墙是否放行");
+    } else if (statue == 3) {
+      alart(context, "版本校验不通过: 双方版本不一致");
+    } else if (statue == 4) {
+      alart(context, "本地与服务端无可使用的相同词库");
+    }
+    if(isScaning) scannerController.dispose();
+    setState(() {
+      isconnecting = false;
+    });
+  }
 
   @override
   Widget build(BuildContext context) {
@@ -26,7 +69,7 @@ class _LocalPKSelectPage extends State<LocalPKSelectPage> {
           SizedBox(height: mediaQuery.size.height * 0.05),
           ElevatedButton.icon(
             style: ElevatedButton.styleFrom(
-              fixedSize: Size(mediaQuery.size.width * 0.8, mediaQuery.size.height * 0.2),
+              fixedSize: Size(mediaQuery.size.width * 0.8, mediaQuery.size.height * 0.1),
               shape: RoundedRectangleBorder(borderRadius: StaticsVar.br)
             ),
             onPressed: (){
@@ -41,10 +84,10 @@ class _LocalPKSelectPage extends State<LocalPKSelectPage> {
               );
             }, 
             icon: Icon(Icons.manage_accounts, size: 36),
-            label: Text("我做房主（邀请别人）", style: TextStyle(fontSize: 36))
+            label: Text("我做房主", style: TextStyle(fontSize: 24))
           ),
-          Divider(height: mediaQuery.size.height * 0.1, thickness: 3),
-          Text("我加入联机", style: Theme.of(context).textTheme.displaySmall),
+          Divider(height: mediaQuery.size.height * 0.05, thickness: 3),
+          Text("我加入联机", style: Theme.of(context).textTheme.headlineMedium),
           TextField(
             autocorrect: false,
             controller: connectpwdController,
@@ -59,24 +102,39 @@ class _LocalPKSelectPage extends State<LocalPKSelectPage> {
               ),
               suffix: ElevatedButton(
                 onPressed: () async {
-                  if(isconnecting) return;
-                  setState(() {
-                    isconnecting = true;
-                  });
-                  int statue = await context.read<PKServer>().testConnect(connectpwdController.text);
+                  connecting(context);
                 }, 
                 child: Text("加入")
               ),
             ),
             onSubmitted: (text) async {
-              if(isconnecting) return;
+              connecting(context);
+            },
+          ),
+          SizedBox(height: mediaQuery.size.height * 0.02),
+          ElevatedButton.icon(
+            onPressed: () {
+              if(isScaning) scannerController.stop();
               setState(() {
-                isconnecting = true;
+                isScaning = !isScaning;
               });
-              int statue = await context.read<PKServer>().testConnect(text);
-            },
+            }, 
+            icon: Icon(isScaning ? Icons.stop : Icons.qr_code_scanner),
+            label: Text(isScaning ? "停止扫描" : "扫描二维码")
+          ),
+          if(isScaning) SizedBox(
+            width: mediaQuery.size.width * 0.8,
+            height: mediaQuery.size.height * 0.4,
+            child: MobileScanner(
+              controller: scannerController,
+              fit: BoxFit.scaleDown,
+              onDetect: (barcodes) {
+                if(5 > (barcodes.barcodes.first.rawValue??"").length || 8 < (barcodes.barcodes.first.rawValue??"").length) return;
+                connectpwdController.text = barcodes.barcodes.first.rawValue??"";
+                connecting(context);
+              },
+            ),
           ),
-          SizedBox(height: mediaQuery.size.height * 0.1),
           if(isconnecting) CircularProgressIndicator()
         ],
       ),
@@ -107,8 +165,18 @@ class _ServerHostWatingPage extends State<ServerHostWatingPage> {
             ...List.generate(context.read<PKServer>().selectableSource.length, (int index) => Text(context.read<PKServer>().selectableSource[index].sourceJsonFileName), growable: false),
             SizedBox(height: mediaQuery.size.height * 0.1),
             ElevatedButton(
-              onPressed: (){
-                popSelectClasses(context, forceSelectRange: context.read<PKServer>().selectableSource);
+              onPressed: () async {
+                ClassSelection selection = await popSelectClasses(context, forceSelectRange: context.read<PKServer>().selectableSource, withCache: false, withReviewChoose: false);
+                if(!context.mounted) return;
+                context.read<PKServer>().classSelection = selection;
+                PKServer notifier = context.read<PKServer>();
+                Navigator.push(
+                  context, 
+                  MaterialPageRoute(builder: (context) => ChangeNotifierProvider.value(
+                    value: notifier,
+                    child: PKPreparePage(),
+                  ))
+                );
               }, 
               child: Text("开始选课")
             )
@@ -124,11 +192,89 @@ class _ServerHostWatingPage extends State<ServerHostWatingPage> {
           appBar: AppBar(title: Text(snapshot.data??false ? "等待其他人进入..." : "正在启动服务")),
           body: Center(
             child: snapshot.data??false
-                  ? Text("联机口令: ${context.read<PKServer>().connectpwd}", style: Theme.of(context).textTheme.displayMedium)
+                  ? Center(child: Column(
+                    children: [
+                      Text("联机口令:\n${context.read<PKServer>().connectpwd}", style: Theme.of(context).textTheme.displayMedium),
+                      SizedBox(height: mediaQuery.size.height * 0.1),
+                      Container(
+                        padding: EdgeInsets.all(8.0),
+                        decoration: BoxDecoration(
+                          borderRadius: StaticsVar.br,
+                          color: Colors.white
+                        ),
+                        child: QrImageView(
+                          data: context.read<PKServer>().connectpwd!,
+                          backgroundColor: Colors.white,
+                          version: QrVersions.auto,
+                          size: min(mediaQuery.size.width, mediaQuery.size.height) * 0.4,
+                        ),
+                      ),
+                    ],
+                  ))
                   : CircularProgressIndicator(semanticsLabel: "服务加载中")
           ),
         );
       }
     );
   }
+}
+
+class ClientWatingPage extends StatefulWidget {
+  const ClientWatingPage({super.key});
+
+  @override
+  State<StatefulWidget> createState() => _ClientWatingPage();
+}
+
+class _ClientWatingPage extends State<ClientWatingPage> {
+  
+  @override
+  Widget build(BuildContext context) {
+    return FutureBuilder(
+      future: context.read<PKServer>().watingSelection(),
+      builder: (context, asyncSnapshot) {
+        return asyncSnapshot.hasData 
+        ? PKPreparePage()
+        : Scaffold(
+          appBar: AppBar(title: Text("连接成功")),
+          body: Center(child: Column(
+            mainAxisSize: MainAxisSize.min,
+            children: [
+              CircularProgressIndicator(),
+              Text("正在等待房主选择课程")
+            ]
+          ))
+        );
+      }
+    );
+  }
+}
+
+class PKPreparePage extends StatelessWidget {
+  const PKPreparePage({super.key});
+
+  @override
+  Widget build(BuildContext context) {
+    MediaQueryData mediaQuery = MediaQuery.of(context);
+
+    return Scaffold(
+      appBar: AppBar(title: Text("请准备")),
+      body: Center(
+        child: Column(
+          children: [
+            SizedBox(height: mediaQuery.size.height * 0.05),
+            TextContainer(text: "已选择以下课程，准备完成后开始"),
+            ...List.generate(context.read<PKServer>().classSelection!.selectedClass.length, (int index) => Text(context.read<PKServer>().classSelection!.selectedClass[index].className), growable: false),
+            SizedBox(height: mediaQuery.size.height * 0.1),
+            ElevatedButton(
+              onPressed: (){
+                // TODO
+              }, 
+              child: Text("准备")
+            )
+          ],
+        ),
+      ),
+    );
+  }
 }
\ No newline at end of file
diff --git a/lib/vars/config_structure.dart b/lib/vars/config_structure.dart
index 0359474..1cec2b8 100644
--- a/lib/vars/config_structure.dart
+++ b/lib/vars/config_structure.dart
@@ -696,8 +696,19 @@ class SourceItem {
     return classesMap;
   }
 
-  String getHash() {
-    return sha256.convert(utf8.encode(toMap().toString())).toString();
+  Map<String, List<Map>> toComparableMap(List<WordItem> words) {
+    Map<String, List<Map<String, String>>> classesMap = {};
+    for(ClassItem classItem in subClasses) {
+      classesMap[classItem.className] = [];
+      for(int index in classItem.wordIndexs) {
+        classesMap[classItem.className]!.add(words[index].toMap());
+      }
+    }
+    return classesMap;
+  }
+
+  String getHash(List<WordItem> words) {
+    return sha256.convert(utf8.encode(toComparableMap(words).toString())).toString();
   }
 }
 
@@ -715,6 +726,10 @@ class ClassItem {
   String toString() {
     return className;
   }
+
+  String getHash() {
+    return sha256.convert(utf8.encode(toString())).toString();
+  }
 }
 
 @immutable
diff --git a/macos/Flutter/GeneratedPluginRegistrant.swift b/macos/Flutter/GeneratedPluginRegistrant.swift
index 13fa8e1..2bf2e54 100644
--- a/macos/Flutter/GeneratedPluginRegistrant.swift
+++ b/macos/Flutter/GeneratedPluginRegistrant.swift
@@ -10,6 +10,7 @@ import file_picker
 import flutter_local_notifications
 import flutter_tts
 import just_audio
+import mobile_scanner
 import network_info_plus
 import screen_retriever_macos
 import shared_preferences_foundation
@@ -22,6 +23,7 @@ func RegisterGeneratedPlugins(registry: FlutterPluginRegistry) {
   FlutterLocalNotificationsPlugin.register(with: registry.registrar(forPlugin: "FlutterLocalNotificationsPlugin"))
   FlutterTtsPlugin.register(with: registry.registrar(forPlugin: "FlutterTtsPlugin"))
   JustAudioPlugin.register(with: registry.registrar(forPlugin: "JustAudioPlugin"))
+  MobileScannerPlugin.register(with: registry.registrar(forPlugin: "MobileScannerPlugin"))
   NetworkInfoPlusPlugin.register(with: registry.registrar(forPlugin: "NetworkInfoPlusPlugin"))
   ScreenRetrieverMacosPlugin.register(with: registry.registrar(forPlugin: "ScreenRetrieverMacosPlugin"))
   SharedPreferencesPlugin.register(with: registry.registrar(forPlugin: "SharedPreferencesPlugin"))
diff --git a/pubspec.lock b/pubspec.lock
index 61565c3..7c9501c 100644
--- a/pubspec.lock
+++ b/pubspec.lock
@@ -552,6 +552,14 @@ packages:
       url: "https://pub.dev"
     source: hosted
     version: "2.0.0"
+  mobile_scanner:
+    dependency: "direct main"
+    description:
+      name: mobile_scanner
+      sha256: c92c26bf2231695b6d3477c8dcf435f51e28f87b1745966b1fe4c47a286171ce
+      url: "https://pub.dev"
+    source: hosted
+    version: "7.2.0"
   native_toolchain_c:
     dependency: transitive
     description:
@@ -744,6 +752,22 @@ packages:
       url: "https://pub.dev"
     source: hosted
     version: "1.5.0"
+  qr:
+    dependency: transitive
+    description:
+      name: qr
+      sha256: "5a1d2586170e172b8a8c8470bbbffd5eb0cd38a66c0d77155ea138d3af3a4445"
+      url: "https://pub.dev"
+    source: hosted
+    version: "3.0.2"
+  qr_flutter:
+    dependency: "direct main"
+    description:
+      name: qr_flutter
+      sha256: "5095f0fc6e3f71d08adef8feccc8cea4f12eec18a2e31c2e8d82cb6019f4b097"
+      url: "https://pub.dev"
+    source: hosted
+    version: "4.1.0"
   retry:
     dependency: transitive
     description:
diff --git a/pubspec.yaml b/pubspec.yaml
index e4c2931..b198354 100644
--- a/pubspec.yaml
+++ b/pubspec.yaml
@@ -54,6 +54,8 @@ dependencies:
   shelf_router: ^1.1.4
   network_info_plus: ^7.0.0
   crypto: ^3.0.7
+  qr_flutter: ^4.1.0
+  mobile_scanner: ^7.2.0
   # file_saver: ^0.3.1
   cupertino_icons: ^1.0.8
   bk_tree: ^0.1.2

From 347c2cc7e0ecae998d6fa2070f4cc8a44412c625 Mon Sep 17 00:00:00 2001
From: OctagonalStar <76486554+OctagonalStar@users.noreply.github.com>
Date: Wed, 25 Feb 2026 16:14:29 +0800
Subject: [PATCH 04/11] feat: base pk logic

Signed-off-by: OctagonalStar <76486554+OctagonalStar@users.noreply.github.com>
---
 lib/funcs/local_pk_server.dart                | 155 +++++++
 lib/funcs/utili.dart                          |  29 +-
 lib/pages/learning_page.dart                  |   2 +-
 .../test_pages/listening_test_page.dart       |   4 +-
 .../test_pages/local_pk_page.dart             | 402 +++++++++++++++++-
 5 files changed, 550 insertions(+), 42 deletions(-)

diff --git a/lib/funcs/local_pk_server.dart b/lib/funcs/local_pk_server.dart
index a75753a..cc8c883 100644
--- a/lib/funcs/local_pk_server.dart
+++ b/lib/funcs/local_pk_server.dart
@@ -2,6 +2,7 @@ import 'dart:io' show HttpServer;
 import 'dart:math';
 import 'dart:convert';
 import 'dart:typed_data' show Uint8List;
+import 'package:arabic_learning/funcs/utili.dart';
 import 'package:arabic_learning/vars/config_structure.dart';
 import 'package:arabic_learning/vars/global.dart';
 import 'package:logging/logging.dart';
@@ -24,9 +25,14 @@ class PKServer with ChangeNotifier{
   ClassSelection? classSelection;
   late Global global;
   final NetworkInfo _networkInfo = NetworkInfo();
+  DateTime? startTime;
+  bool preparedP1 = false;
+  bool preparedP2 = false;
+  late final PKState pkState;
 
   // server
   bool started = false;
+  Duration? delay;
   late final HttpServer _server;
   late final int _port;
 
@@ -103,6 +109,61 @@ class PKServer with ChangeNotifier{
       );
     });
 
+    router.post('/api/prepare', (Request req) async {
+      Map<String, dynamic> body = json.decode(await req.readAsString());
+      if(body["time"] != null && delay == null) {
+        delay = DateTime.tryParse(body["time"])!.difference(DateTime.now());
+      }
+      if(body["prepared"]) {
+        preparedP2 = true;
+        if(preparedP1 && startTime == null) {
+          startTime = DateTime.now().add(Duration(seconds: 5));
+          pkState = PKState(
+            testWords: getSelectedWords(global.wordData, classSelection!.selectedClass, doShuffle: true, shuffleSeed: rndSeed), 
+            selfProgress: [], 
+            sideProgress: []
+          );
+        }
+        notifyListeners();
+      }
+      
+      
+      return Response.ok(json.encode({
+        "prepared": preparedP1,
+        "start": startTime?.add(delay!).toIso8601String()
+        }),
+        headers: {'Content-Type': 'application/json'}
+      );
+    });
+
+    router.post('/api/sync', (Request req) async {
+      Map<String, dynamic> body = json.decode(await req.readAsString());
+      bool changed = false;
+      if(body["progress"] != null && body["progress"].length != pkState.sideProgress.length) {
+        pkState.sideProgress = List.generate(body["progress"].length, (int index) => body["progress"][index] as bool);
+        changed = true;
+      }
+      if(pkState.sideProgress.length == pkState.testWords.length && body["tooken"] != null) {
+        pkState.sideTookenTime = body["tooken"] - delay!.inSeconds;
+        changed = true;
+      }
+      if(changed) notifyListeners();
+      return Response.ok(json.encode({
+        "progress": pkState.selfProgress,
+        "tooken": pkState.selfTookenTime
+        }),
+        headers: {'Content-Type': 'application/json'}
+      );
+    });
+
+    router.get('/api/done', (Request req) async {
+      Future.delayed(Duration(seconds: 1), () {
+        stopHost();
+      });
+      notifyListeners();
+      return Response.ok(null);
+    });
+
     _server = await io.serve(
       router.call,
       '0.0.0.0', // 局域网可访问
@@ -210,4 +271,98 @@ class PKServer with ChangeNotifier{
     }
     return classSelection!;
   }
+
+  Future<void> watingPrepare() async {
+    while (!preparedP2 || startTime == null) {
+      try{
+        await Future.delayed(Duration(seconds: 1));
+        final prepareRes = await client.post(
+          "$serverAddress/api/prepare", 
+          data: {
+            "prepared": preparedP1,
+            "time": DateTime.now().toIso8601String()
+          }
+        );
+        if(prepareRes.statusCode != 200) throw Exception("Unexcepted statusCode: ${prepareRes.statusCode}");
+        bool changed = false;
+        if(preparedP2 != prepareRes.data["prepared"]) {
+          preparedP2 = prepareRes.data["prepared"];
+          changed = true;
+        }
+        if(preparedP1 && preparedP2 && prepareRes.data["start"] != null) {
+          startTime = DateTime.tryParse(prepareRes.data["start"]) as DateTime;
+          changed = true;
+        }
+        if(changed) notifyListeners();
+      } catch (e) {
+        logger.shout("连接服务端失败: $e");
+        rethrow;
+      }
+    }
+  }
+
+  void initPK() {
+    pkState = PKState(
+      testWords: getSelectedWords(global.wordData, classSelection!.selectedClass, doShuffle: true, shuffleSeed: rndSeed), 
+      selfProgress: [], 
+      sideProgress: []
+    );
+    syncPKState();
+  }
+
+  Future<void> syncPKState() async {
+    while(true) {
+      try{
+        await Future.delayed(Duration(milliseconds: 500));
+        final syncRes = await client.post(
+          "$serverAddress/api/sync",
+          data: {
+            "progress": pkState.selfProgress,
+            "tooken": pkState.selfTookenTime
+          },
+          options: dio.Options(connectTimeout: Duration(seconds: 1))
+        );
+        if(syncRes.statusCode != 200) throw Exception("Unexcepted statusCode: ${syncRes.statusCode}");
+        bool changed = false;
+        if(syncRes.data["progress"] != null && syncRes.data["progress"].length != pkState.sideProgress.length) {
+          pkState.sideProgress = List.generate(syncRes.data["progress"].length, (int index) => syncRes.data["progress"][index] as bool);
+          changed = true;
+        }
+        if(pkState.sideProgress.length == pkState.testWords.length && syncRes.data["tooken"] != null) {
+          pkState.sideTookenTime = syncRes.data["tooken"];
+          changed = true;
+        }
+        if(changed) notifyListeners();
+        if(pkState.selfTookenTime != null && pkState.sideTookenTime != null) {
+          client.get("$serverAddress/api/done");
+          break;
+        }
+      } catch (e) {
+        logger.shout("同步状态失败 $e");
+      }
+    }
+  }
+
+  void updateState(bool correct) {
+    pkState.selfProgress.add(correct);
+    notifyListeners();
+  }
+
+  double calculatePt(List<bool> progress, int tookenTime) {
+    int correctCount = 0;
+    for(bool value in progress) {
+      if(value) correctCount++;
+    }
+    return 750*(correctCount/progress.length) + 250 - tookenTime;
+  }
 }
+
+class PKState {
+  List<WordItem> testWords;
+  List<bool> selfProgress;
+  int? selfTookenTime;
+  List<bool> sideProgress;
+  int? sideTookenTime;
+
+  PKState({required this.testWords, required this.selfProgress, required this.sideProgress});
+}
\ No newline at end of file
diff --git a/lib/funcs/utili.dart b/lib/funcs/utili.dart
index 2e1c13e..f222142 100644
--- a/lib/funcs/utili.dart
+++ b/lib/funcs/utili.dart
@@ -1,4 +1,3 @@
-import 'dart:convert';
 import 'dart:math';
 
 import 'package:flutter/material.dart';
@@ -33,35 +32,15 @@ Future<void> downloadFile(String url, String savePath, {ProgressCallback? onDown
   );
 }
 
-List<WordItem> getSelectedWords(BuildContext context , {List<ClassItem>? forceSelectClasses, bool doShuffle = false, bool doDouble = false}) {
-  final List<ClassItem> courseList = forceSelectClasses??[];
-  if(forceSelectClasses == null) {
-    final tpcPrefs = context.read<Global>().prefs.getString("tempConfig") ?? jsonEncode(StaticsVar.tempConfig);
-    final List<List<String>> cacheList = (jsonDecode(tpcPrefs)["SelectedClasses"] as List)
-        .cast<List>()
-        .map((e) => e.cast<String>().toList())
-        .toList();
-    for(List<String> cachedClass in cacheList) {
-      for(SourceItem sourceItem in context.read<Global>().wordData.classes){
-        if(sourceItem.sourceJsonFileName != cachedClass[0]){
-          continue;
-        }
-        if(sourceItem.subClasses.any((ClassItem classItem) => classItem.className == cachedClass[1])){
-          courseList.add(
-            sourceItem.subClasses.firstWhere((ClassItem classItem) => classItem.className == cachedClass[1])
-          );
-        }
-      }
-    }
-  }
+List<WordItem> getSelectedWords(DictData wordData , List<ClassItem> selectedClasses, {bool doShuffle = false, bool doDouble = false, int? shuffleSeed}) {
   List<WordItem> ans = [];
-  for(ClassItem c in courseList) {
+  for(ClassItem c in selectedClasses) {
     for (int wordIndex in c.wordIndexs){
-      ans.add(context.read<Global>().wordData.words[wordIndex]); // 保留id方便后面进度保存
+      ans.add(wordData.words[wordIndex]); // 保留id方便后面进度保存
     }
   }
   if(doDouble) ans = [...ans, ...ans];
-  if(doShuffle) ans.shuffle();
+  if(doShuffle) ans.shuffle(Random(shuffleSeed));
   return ans;
 }
 
diff --git a/lib/pages/learning_page.dart b/lib/pages/learning_page.dart
index 9399138..f1f9b23 100644
--- a/lib/pages/learning_page.dart
+++ b/lib/pages/learning_page.dart
@@ -159,7 +159,7 @@ Future<void> shiftToStudy(BuildContext context) async {
   context.read<Global>().uiLogger.info("准备转向学习页面");
   final ClassSelection classSelection = await popSelectClasses(context, withCache: false, withReviewChoose: true);
   if(classSelection.selectedClass.isEmpty || !context.mounted) return;
-  final List<WordItem> words = getSelectedWords(context, doShuffle: false, doDouble: false, forceSelectClasses: classSelection.selectedClass);
+  final List<WordItem> words = getSelectedWords(context.read<Global>().wordData, classSelection.selectedClass, doShuffle: false, doDouble: false);
   context.read<Global>().uiLogger.info("完成单词挑拣，共${words.length}个");
   if(words.isEmpty) return;
   context.read<Global>().uiLogger.info("跳转: LearningPage => InLearningPage");
diff --git a/lib/sub_pages_builder/test_pages/listening_test_page.dart b/lib/sub_pages_builder/test_pages/listening_test_page.dart
index 96add9f..533038a 100644
--- a/lib/sub_pages_builder/test_pages/listening_test_page.dart
+++ b/lib/sub_pages_builder/test_pages/listening_test_page.dart
@@ -26,7 +26,7 @@ class _ForeListeningSettingPage extends State<ForeListeningSettingPage> {
   Widget build(BuildContext context) {
     context.read<Global>().uiLogger.info("构建 ForeListeningSettingPage");
     MediaQueryData mediaQuery = MediaQuery.of(context);
-    int wordCount = getSelectedWords(context, forceSelectClasses: selectedClasses.selectedClass).length;
+    int wordCount = getSelectedWords(context.read<Global>().wordData, selectedClasses.selectedClass).length;
     return Scaffold(
       appBar: AppBar(
         title: Text('自主听写预设置'),
@@ -210,7 +210,7 @@ class _ForeListeningSettingPage extends State<ForeListeningSettingPage> {
                       playTimes: playTimes, 
                       interval: interval, 
                       intervalBetweenWords: intervalBetweenWords, 
-                      words: getSelectedWords(context, forceSelectClasses: selectedClasses.selectedClass, doShuffle: true)
+                      words: getSelectedWords(context.read<Global>().wordData, selectedClasses.selectedClass, doShuffle: true)
                     )
                   )
                 );
diff --git a/lib/sub_pages_builder/test_pages/local_pk_page.dart b/lib/sub_pages_builder/test_pages/local_pk_page.dart
index 42392d7..a7a5231 100644
--- a/lib/sub_pages_builder/test_pages/local_pk_page.dart
+++ b/lib/sub_pages_builder/test_pages/local_pk_page.dart
@@ -1,8 +1,11 @@
+import 'dart:async';
 import 'dart:math';
 
 import 'package:arabic_learning/funcs/local_pk_server.dart';
 import 'package:arabic_learning/funcs/ui.dart';
+import 'package:arabic_learning/funcs/utili.dart';
 import 'package:arabic_learning/vars/config_structure.dart';
+import 'package:arabic_learning/vars/global.dart';
 import 'package:arabic_learning/vars/statics_var.dart';
 import 'package:flutter/material.dart';
 import 'package:qr_flutter/qr_flutter.dart';
@@ -219,14 +222,8 @@ class _ServerHostWatingPage extends State<ServerHostWatingPage> {
   }
 }
 
-class ClientWatingPage extends StatefulWidget {
+class ClientWatingPage extends StatelessWidget {
   const ClientWatingPage({super.key});
-
-  @override
-  State<StatefulWidget> createState() => _ClientWatingPage();
-}
-
-class _ClientWatingPage extends State<ClientWatingPage> {
   
   @override
   Widget build(BuildContext context) {
@@ -250,13 +247,36 @@ class _ClientWatingPage extends State<ClientWatingPage> {
   }
 }
 
-class PKPreparePage extends StatelessWidget {
+class PKPreparePage extends StatefulWidget {
   const PKPreparePage({super.key});
 
+  @override
+  State<StatefulWidget> createState() => _PKPreparePage();
+}
+
+class _PKPreparePage extends State<PKPreparePage> {
+  bool watching = false;
+  bool downCount = false;
+
   @override
   Widget build(BuildContext context) {
     MediaQueryData mediaQuery = MediaQuery.of(context);
-
+    if(!watching && !context.read<PKServer>().started) context.read<PKServer>().watingPrepare();
+    if(context.read<PKServer>().startTime != null&&!downCount) {
+      downCount = true;
+      Future.delayed(context.read<PKServer>().startTime!.difference(DateTime.now()), () {
+        if(!context.mounted) return;
+        PKServer notifier = context.read<PKServer>();
+        Navigator.pop(context);
+        Navigator.push(
+          context, 
+          MaterialPageRoute(builder: (context) => ChangeNotifierProvider.value(
+            value: notifier,
+            child: PKOngoingPage(),
+          ))
+        );
+      });
+    }
     return Scaffold(
       appBar: AppBar(title: Text("请准备")),
       body: Center(
@@ -266,15 +286,369 @@ class PKPreparePage extends StatelessWidget {
             TextContainer(text: "已选择以下课程，准备完成后开始"),
             ...List.generate(context.read<PKServer>().classSelection!.selectedClass.length, (int index) => Text(context.read<PKServer>().classSelection!.selectedClass[index].className), growable: false),
             SizedBox(height: mediaQuery.size.height * 0.1),
-            ElevatedButton(
-              onPressed: (){
-                // TODO
-              }, 
-              child: Text("准备")
+            Row(
+              mainAxisAlignment: MainAxisAlignment.spaceEvenly,
+              
+              children: [
+                Container(
+                  padding: EdgeInsets.all(8.0),
+                  height: mediaQuery.size.height * 0.3,
+                  width: mediaQuery.size.width * 0.4,
+                  decoration: BoxDecoration(
+                    color: Theme.of(context).colorScheme.onPrimary,
+                    borderRadius: StaticsVar.br
+                  ),
+                  child: Column(
+                    children: [
+                      Text("你", style: Theme.of(context).textTheme.headlineSmall),
+                      SizedBox(height: mediaQuery.size.height * 0.05),
+                      context.watch<PKServer>().preparedP1
+                      ? Text("已准备")
+                      : ElevatedButton(
+                        onPressed: (){
+                          setState(() {
+                            context.read<PKServer>().preparedP1 = true;
+                          });
+                        }, 
+                        child: Text("准备")
+                      )
+                    ],
+                  ),
+                ),
+                Container(
+                  padding: EdgeInsets.all(8.0),
+                  height: mediaQuery.size.height * 0.3,
+                  width: mediaQuery.size.width * 0.4,
+                  decoration: BoxDecoration(
+                    color: Theme.of(context).colorScheme.onSecondary,
+                    borderRadius: StaticsVar.br
+                  ),
+                  child: Column(
+                    children: [
+                      Text("对方", style: Theme.of(context).textTheme.headlineSmall),
+                      SizedBox(height: mediaQuery.size.height * 0.05),
+                      Text("${context.watch<PKServer>().preparedP2 ? "已" : "未"}准备")
+                    ],
+                  ),
+                )
+              ],
+            ),
+            if(downCount) TweenAnimationBuilder<double>(
+              tween: Tween(
+                begin: 1,
+                end: 0
+              ), 
+              duration: context.read<PKServer>().startTime!.difference(DateTime.now()), 
+              builder: (context, value, child) => Column(
+                children: [
+                  CircularProgressIndicator(value: value),
+                  child!
+                ],
+              ),
+              child: Text("即将开始..."),
             )
           ],
         ),
       ),
     );
   }
+}
+
+class PKOngoingPage extends StatefulWidget {
+  const PKOngoingPage({super.key});
+
+  @override
+  State<StatefulWidget> createState() => _PKOngoingPage();
+}
+
+class _PKOngoingPage extends State<PKOngoingPage> {
+  int state = 0;
+  PageController pageController = PageController();
+  List<List<String>> choiceOptions = [];
+
+  @override
+  Widget build(BuildContext context) {
+    MediaQueryData mediaQuery = MediaQuery.of(context);
+
+    if(state == 0) {
+      if(!context.read<PKServer>().started) context.read<PKServer>().initPK();
+      Random rnd = Random(context.read<PKServer>().rndSeed);
+      for(WordItem wordItem in context.read<PKServer>().pkState.testWords) {
+        List<WordItem> optionWords = getRandomWords(4, context.read<Global>().wordData, allowRepet: false, include: wordItem, shuffle: true, rnd: rnd);
+        choiceOptions.add(List.generate(4, (int index) => optionWords[index].chinese));
+      }
+      state++;
+    }
+
+    return PopScope(
+      canPop: false,
+      child: Scaffold(
+        appBar: AppBar(title: Text("局域网联机"), automaticallyImplyLeading: false),
+        body: Column(
+          children: [
+            TopScoreBar(state: context.watch<PKServer>().pkState),
+            Expanded(
+              child: SizedBox(
+                width: mediaQuery.size.width,
+                child: PageView.builder(
+                  controller: pageController,
+                  itemCount: context.read<PKServer>().pkState.testWords.length + 1,
+                  physics: NeverScrollableScrollPhysics(),
+                  itemBuilder: (context, index) {
+                    if(index == context.read<PKServer>().pkState.testWords.length) {
+                      context.read<PKServer>().pkState.selfTookenTime = DateTime.now().difference(context.read<PKServer>().startTime!).inSeconds;
+                      if(context.read<PKServer>().pkState.sideTookenTime == null) {
+                        return Center(
+                          child: Text("等待对方完成中...", style: Theme.of(context).textTheme.headlineSmall),
+                        );
+                      } else {
+                        int selfCorrect = 0;
+                        int sideCorrect = 0;
+                        for(int i = 0;i < context.read<PKServer>().pkState.testWords.length; i++) {
+                          if(context.read<PKServer>().pkState.sideProgress[i]) {
+                            sideCorrect++;
+                          }
+                          if (context.read<PKServer>().pkState.selfProgress[i]) {
+                            selfCorrect++;
+                          }
+                        }
+                        double selfPt = context.read<PKServer>().calculatePt(context.read<PKServer>().pkState.selfProgress, context.read<PKServer>().pkState.selfTookenTime!);
+                        double sidePt = context.read<PKServer>().calculatePt(context.read<PKServer>().pkState.sideProgress, context.read<PKServer>().pkState.sideTookenTime!);
+                        return PKConclue(
+                          selfCorrect: selfCorrect, 
+                          sideCorrect: sideCorrect, 
+                          selfPt: selfPt, 
+                          sidePt: sidePt
+                        );
+                      }
+                    }
+                    return ChoiceQuestions(
+                      mainWord: context.read<PKServer>().pkState.testWords[index].arabic, 
+                      choices: choiceOptions[index], 
+                      allowAudio: true, 
+                      allowAnitmation: false,
+                      onSelected: (int choosed) {
+                        pageController.nextPage(duration: Duration(milliseconds: 500), curve: StaticsVar.curve);
+                        if(choiceOptions[index][choosed] == context.read<PKServer>().pkState.testWords[index].chinese) {
+                          context.read<PKServer>().updateState(true);
+                          return true;
+                        } else {
+                          context.read<PKServer>().updateState(false);
+                          return false;
+                        }
+                      },
+                      allowMutipleSelect: false,
+                    );
+                  }
+                ),
+              ),
+            )
+          ],
+        )
+      ),
+    );
+  }
+}
+
+class PKConclue extends StatelessWidget {
+  const PKConclue({
+    super.key,
+    required this.selfCorrect,
+    required this.sideCorrect,
+    required this.selfPt,
+    required this.sidePt,
+  });
+
+  final int selfCorrect;
+  final int sideCorrect;
+  final double selfPt;
+  final double sidePt;
+
+  @override
+  Widget build(BuildContext context) {
+    MediaQueryData mediaQuery = MediaQuery.of(context);
+
+    return Column(
+      children: [
+        Text("回答正确数", style:Theme.of(context).textTheme.titleLarge),
+        TweenAnimationBuilder<double>(
+          tween: Tween(
+            begin: 0,
+            end: 1
+          ), 
+          curve: StaticsVar.curve,
+          duration: Duration(seconds: 1), 
+          builder: (context, value, child) {
+            return Row(
+              mainAxisAlignment: MainAxisAlignment.spaceBetween,
+              children: [
+                Container(
+                  padding: EdgeInsets.all(16.0),
+                  height: mediaQuery.size.height * 0.1,
+                  width: min(value*2, 1) * mediaQuery.size.width * (0.5 + 0.25*((selfCorrect - sideCorrect)/context.read<PKServer>().pkState.testWords.length)),
+                  decoration: BoxDecoration(
+                    color: Theme.of(context).colorScheme.onPrimary,
+                  ),
+                  child: Text("你  ${(value*selfCorrect).floor()}", style: Theme.of(context).textTheme.headlineMedium, textAlign: TextAlign.end),
+                ),
+                Container(
+                  padding: EdgeInsets.all(16.0),
+                  height: mediaQuery.size.height * 0.1,
+                  width: min(value*2, 1) * mediaQuery.size.width * (0.5 - 0.25*((selfCorrect - sideCorrect)/context.read<PKServer>().pkState.testWords.length)),
+                  decoration: BoxDecoration(
+                    color: Theme.of(context).colorScheme.onSecondary,
+                  ),
+                  child: Text("${(value*sideCorrect).floor()}  对方", style: Theme.of(context).textTheme.headlineMedium, textAlign: TextAlign.start),
+                ),
+              ],
+            );
+          }
+        ),
+        SizedBox(height: mediaQuery.size.height * 0.05),
+        Text("回答用时", style:Theme.of(context).textTheme.titleLarge),
+        TweenAnimationBuilder<double>(
+          tween: Tween(
+            begin: 0,
+            end: 1
+          ), 
+          curve: StaticsVar.curve,
+          duration: Duration(milliseconds: 500), 
+          builder: (context, value, child) {
+            return Row(
+              mainAxisAlignment: MainAxisAlignment.spaceBetween,
+              children: [
+                Container(
+                  padding: EdgeInsets.all(16.0),
+                  height: mediaQuery.size.height * 0.1,
+                  width: min(value*2, 1) * mediaQuery.size.width * (0.5 - 0.25*(context.read<PKServer>().pkState.selfTookenTime! - context.read<PKServer>().pkState.sideTookenTime!)/300),
+                  decoration: BoxDecoration(
+                    color: Theme.of(context).colorScheme.onPrimary,
+                  ),
+                  child: Text("你  ${(value*context.read<PKServer>().pkState.selfTookenTime!).floor()}秒", style: Theme.of(context).textTheme.headlineMedium, textAlign: TextAlign.end),
+                ),
+                Container(
+                  padding: EdgeInsets.all(16.0),
+                  height: mediaQuery.size.height * 0.1,
+                  width: min(value*2, 1) * mediaQuery.size.width * (0.5 + 0.25*(context.read<PKServer>().pkState.selfTookenTime! - context.read<PKServer>().pkState.sideTookenTime!)/300),
+                  decoration: BoxDecoration(
+                    color: Theme.of(context).colorScheme.onSecondary,
+                  ),
+                  child: Text("${(value*context.read<PKServer>().pkState.sideTookenTime!).floor()}秒  对方", style: Theme.of(context).textTheme.headlineMedium, textAlign: TextAlign.start),
+                ),
+              ],
+            );
+          }
+        ),
+        SizedBox(height: mediaQuery.size.height * 0.05),
+        Text("计算得分", style:Theme.of(context).textTheme.titleLarge),
+        TweenAnimationBuilder<double>(
+          tween: Tween(
+            begin: 0,
+            end: 1
+          ), 
+          curve: StaticsVar.curve,
+          duration: Duration(seconds: 2), 
+          builder: (context, value, child) {
+            return Row(
+              mainAxisAlignment: MainAxisAlignment.spaceBetween,
+              children: [
+                Container(
+                  padding: EdgeInsets.all(16.0),
+                  height: mediaQuery.size.height * 0.1,
+                  width: min(value*2, 1) * mediaQuery.size.width * (0.5 + 0.25*(selfPt - sidePt)/300),
+                  decoration: BoxDecoration(
+                    color: Theme.of(context).colorScheme.onPrimary,
+                  ),
+                  child: Text("你  ${(value*selfPt).round()}Pt", style: Theme.of(context).textTheme.headlineMedium, textAlign: TextAlign.end),
+                ),
+                Container(
+                  padding: EdgeInsets.all(16.0),
+                  height: mediaQuery.size.height * 0.1,
+                  width: min(value*2, 1) * mediaQuery.size.width * (0.5 - 0.25*(selfPt - sidePt)/300),
+                  decoration: BoxDecoration(
+                    color: Theme.of(context).colorScheme.onSecondary,
+                  ),
+                  child: Text("${(value*sidePt).round()}Pt  对方", style: Theme.of(context).textTheme.headlineMedium, textAlign: TextAlign.start),
+                ),
+              ],
+            );
+          }
+        ),
+        Expanded(child: SizedBox()),
+        ElevatedButton.icon(
+          style: ElevatedButton.styleFrom(
+            fixedSize: Size(mediaQuery.size.width * 0.8, mediaQuery.size.height * 0.15),
+            shape: RoundedRectangleBorder(borderRadius: StaticsVar.br)
+          ),
+          onPressed: () {
+            Navigator.popUntil(context, (route) => route.isFirst);
+          },
+          icon: Icon(Icons.exit_to_app),
+          label: Text("退出"),
+        )
+      ]
+    );
+  }
+}
+
+class TopScoreBar extends StatelessWidget {
+  final PKState state;
+  const TopScoreBar({super.key, required this.state});
+
+  @override
+  Widget build(BuildContext context) {
+    MediaQueryData mediaQuery = MediaQuery.of(context);
+
+    return Column(
+      mainAxisSize: MainAxisSize.min,
+      children: [
+        Row(
+          children: [
+            SizedBox(width: mediaQuery.size.width * 0.02),
+            Text("你的"),
+            Expanded(
+              child: TweenAnimationBuilder(
+                tween: Tween(
+                  begin: 0.0,
+                  end: context.watch<PKServer>().pkState.selfProgress.length/context.watch<PKServer>().pkState.testWords.length
+                ),
+                duration: Duration(milliseconds: 500),
+                builder: (context, value, child) {
+                  return LinearProgressIndicator(
+                    value: value,
+                    minHeight: 15,
+                    borderRadius: StaticsVar.br,
+                  );
+                }
+              ),
+            ),
+            SizedBox(width: mediaQuery.size.width * 0.02)
+          ],
+        ),
+        Row(
+          children: [
+            SizedBox(width: mediaQuery.size.width * 0.02),
+            Text("对方"),
+            Expanded(
+              child: TweenAnimationBuilder(
+                tween: Tween(
+                  begin: 0.0,
+                  end: context.watch<PKServer>().pkState.sideProgress.length/context.watch<PKServer>().pkState.testWords.length
+                ),
+                duration: Duration(milliseconds: 500),
+                builder: (context, value, child) {
+                  return LinearProgressIndicator(
+                    value: value,
+                    minHeight: 15,
+                    borderRadius: StaticsVar.br,
+                  );
+                }
+              ),
+            ),
+            SizedBox(width: mediaQuery.size.width * 0.02),
+          ],
+        ),
+      ],
+    );
+  }
 }
\ No newline at end of file

From 1e2cdb4be8cff96f0fe318b80fd6ed7530436db5 Mon Sep 17 00:00:00 2001
From: OctagonalStar <76486554+OctagonalStar@users.noreply.github.com>
Date: Wed, 25 Feb 2026 16:50:20 +0800
Subject: [PATCH 05/11] feat: complete logger in pk part

Signed-off-by: OctagonalStar <76486554+OctagonalStar@users.noreply.github.com>
---
 lib/funcs/local_pk_server.dart                | 55 ++++++++++++++-----
 .../test_pages/local_pk_page.dart             |  6 ++
 2 files changed, 48 insertions(+), 13 deletions(-)

diff --git a/lib/funcs/local_pk_server.dart b/lib/funcs/local_pk_server.dart
index cc8c883..ec967d2 100644
--- a/lib/funcs/local_pk_server.dart
+++ b/lib/funcs/local_pk_server.dart
@@ -55,6 +55,7 @@ class PKServer with ChangeNotifier{
 
   Future<void> init(Global outerglobal) async {
     _localIP = await _networkInfo.getWifiIP();
+    logger.finer("获取到局域网IP: $_localIP");
     global = outerglobal;
   }
 
@@ -65,6 +66,7 @@ class PKServer with ChangeNotifier{
     final router = Router();
 
     router.get('/api/check', (Request req) {
+      logger.fine("收到check请求");
       return Response.ok(
         '{"version":${StaticsVar.appVersion}}',
         headers: {'Content-Type': 'application/json'},
@@ -74,6 +76,7 @@ class PKServer with ChangeNotifier{
     router.post('/api/testDictSum', (Request req) async {
       if(connected == true) return Response.forbidden("");
       Map<String, dynamic> body = json.decode(await req.readAsString());
+      logger.fine("收到testDictSum请求，负载: $body");
       // {
       //  "dictSum": ["SHA256", ...]
       // }
@@ -81,6 +84,7 @@ class PKServer with ChangeNotifier{
       selectableSource.clear();
       for(SourceItem source in global.wordData.classes) {
         if(sumList.contains(source.getHash(global.wordData.words))) selectableSource.add(source);
+        logger.fine("计算得到${source.sourceJsonFileName}在哈希中有匹配");
       }
       if(selectableSource.isNotEmpty) connected = true;
       notifyListeners();
@@ -93,10 +97,13 @@ class PKServer with ChangeNotifier{
     });
 
     router.get('/api/selection', (Request req) {
+      logger.fine("收到selection请求");
       if(classSelection == null) {
+        logger.fine("房主暂未完成选择，statue: false");
         return Response.ok(json.encode({"statue": false}), headers: {'Content-Type': 'application/json'});
       }
       rndSeed = Random().nextInt(1024);
+      logger.finer("随机种子: $rndSeed");
       return Response.ok(
         json.encode(
           {
@@ -111,11 +118,15 @@ class PKServer with ChangeNotifier{
 
     router.post('/api/prepare', (Request req) async {
       Map<String, dynamic> body = json.decode(await req.readAsString());
+      logger.fine("收到prepare请求，负载 $body");
+
       if(body["time"] != null && delay == null) {
         delay = DateTime.tryParse(body["time"])!.difference(DateTime.now());
+        logger.info("已加载双端延迟补偿: ${delay!.inSeconds}秒");
       }
       if(body["prepared"]) {
         preparedP2 = true;
+        logger.fine("对方准备完毕");
         if(preparedP1 && startTime == null) {
           startTime = DateTime.now().add(Duration(seconds: 5));
           pkState = PKState(
@@ -123,6 +134,7 @@ class PKServer with ChangeNotifier{
             selfProgress: [], 
             sideProgress: []
           );
+          logger.fine("已生成开始时间: $startTime(添加delay后为: ${startTime?.add(delay!).toIso8601String()}); PKState已初始化");
         }
         notifyListeners();
       }
@@ -138,16 +150,20 @@ class PKServer with ChangeNotifier{
 
     router.post('/api/sync', (Request req) async {
       Map<String, dynamic> body = json.decode(await req.readAsString());
+      logger.finer("收到sync请求，负载: $body");
       bool changed = false;
       if(body["progress"] != null && body["progress"].length != pkState.sideProgress.length) {
         pkState.sideProgress = List.generate(body["progress"].length, (int index) => body["progress"][index] as bool);
+        logger.fine("已更新本地PKState.sideProgress");
         changed = true;
       }
       if(pkState.sideProgress.length == pkState.testWords.length && body["tooken"] != null) {
         pkState.sideTookenTime = body["tooken"] - delay!.inSeconds;
+        logger.fine("已更新本地PKState.sideTookenTime");
         changed = true;
       }
       if(changed) notifyListeners();
+      if(pkState.selfTookenTime != null) logger.fine("回报本地tokenTime: ${pkState.selfTookenTime}");
       return Response.ok(json.encode({
         "progress": pkState.selfProgress,
         "tooken": pkState.selfTookenTime
@@ -157,6 +173,7 @@ class PKServer with ChangeNotifier{
     });
 
     router.get('/api/done', (Request req) async {
+      logger.info("收到done请求");
       Future.delayed(Duration(seconds: 1), () {
         stopHost();
       });
@@ -210,6 +227,7 @@ class PKServer with ChangeNotifier{
       return 1;
     }
     serverAddress = "http://${_localIP!.split(".")[0]}.${addressinfo[0]}.${addressinfo[1]}.${addressinfo[2]}:${addressinfo[3]}";
+    logger.info("服务端口解析结果: $serverAddress");
     final checkRes = await client.get("$serverAddress/api/check");
     if(checkRes.statusCode != 200) {
       logger.severe("连接服务端失败");
@@ -219,6 +237,7 @@ class PKServer with ChangeNotifier{
       logger.severe("版本校验不通过，对方版本为: ${checkRes.data["version"]}，我方为${StaticsVar.appVersion}");
       return 3;
     }
+    logger.fine("双端版本校验通过");
     final dictRes = await client.post(
       "$serverAddress/api/testDictSum", 
       data: {
@@ -244,26 +263,26 @@ class PKServer with ChangeNotifier{
   }
 
   Future<ClassSelection> watingSelection() async {
+    logger.fine("开始等待服务端选择课程");
     while(classSelection == null) {
       await Future.delayed(Duration(seconds: 1));
       try{
+        logger.fine("正在检查选择情况");
         final selectionRes = await client.get("$serverAddress/api/selection", options: dio.Options(connectTimeout: Duration(seconds: 1)));
-        if(selectionRes.statusCode == 200) {
-          Map payload = selectionRes.data;
-          if(!payload["statue"]) continue;
-          rndSeed = payload["seed"];
-          List<ClassItem> selectedClass = [];
-          for(SourceItem sourceItem in selectableSource) {
-            for(ClassItem classItem in sourceItem.subClasses){
-              if(payload["selected"].contains(classItem.getHash())){
-                selectedClass.add(classItem);
-              }
+        if(selectionRes.statusCode != 200) throw Exception("Unexcepted statusCode: ${selectionRes.statusCode}");
+        Map payload = selectionRes.data;
+        logger.finer("此次检查结果: $payload");
+        if(!payload["statue"]) continue;
+        rndSeed = payload["seed"];
+        List<ClassItem> selectedClass = [];
+        for(SourceItem sourceItem in selectableSource) {
+          for(ClassItem classItem in sourceItem.subClasses){
+            if(payload["selected"].contains(classItem.getHash())){
+              selectedClass.add(classItem);
             }
           }
-          classSelection = ClassSelection(selectedClass: selectedClass, countInReview: false);
-        } else {
-          throw Exception("Unexcepted statusCode: ${selectionRes.statusCode}");
         }
+        classSelection = ClassSelection(selectedClass: selectedClass, countInReview: false);
       } catch (e) {
         logger.shout("连接服务端发生错误: $e");
         rethrow;
@@ -273,8 +292,10 @@ class PKServer with ChangeNotifier{
   }
 
   Future<void> watingPrepare() async {
+    logger.fine("开始等待双端准备");
     while (!preparedP2 || startTime == null) {
       try{
+        logger.fine("正在交换等待情况");
         await Future.delayed(Duration(seconds: 1));
         final prepareRes = await client.post(
           "$serverAddress/api/prepare", 
@@ -284,6 +305,7 @@ class PKServer with ChangeNotifier{
           }
         );
         if(prepareRes.statusCode != 200) throw Exception("Unexcepted statusCode: ${prepareRes.statusCode}");
+        logger.finer("交换结果: ${prepareRes.data}");
         bool changed = false;
         if(preparedP2 != prepareRes.data["prepared"]) {
           preparedP2 = prepareRes.data["prepared"];
@@ -307,13 +329,16 @@ class PKServer with ChangeNotifier{
       selfProgress: [], 
       sideProgress: []
     );
+    logger.fine("已完成PKState初始化");
     syncPKState();
   }
 
   Future<void> syncPKState() async {
+    logger.info("开始进行双端状态同步");
     while(true) {
       try{
         await Future.delayed(Duration(milliseconds: 500));
+        logger.finer("进行状态数据交换");
         final syncRes = await client.post(
           "$serverAddress/api/sync",
           data: {
@@ -323,18 +348,22 @@ class PKServer with ChangeNotifier{
           options: dio.Options(connectTimeout: Duration(seconds: 1))
         );
         if(syncRes.statusCode != 200) throw Exception("Unexcepted statusCode: ${syncRes.statusCode}");
+        logger.finer("对方交换结果为: ${syncRes.data}");
         bool changed = false;
         if(syncRes.data["progress"] != null && syncRes.data["progress"].length != pkState.sideProgress.length) {
           pkState.sideProgress = List.generate(syncRes.data["progress"].length, (int index) => syncRes.data["progress"][index] as bool);
+          logger.fine("已更新本地PKState.sideProgress");
           changed = true;
         }
         if(pkState.sideProgress.length == pkState.testWords.length && syncRes.data["tooken"] != null) {
+          logger.fine("已更新本地PKState.sideTookenTime");
           pkState.sideTookenTime = syncRes.data["tooken"];
           changed = true;
         }
         if(changed) notifyListeners();
         if(pkState.selfTookenTime != null && pkState.sideTookenTime != null) {
           client.get("$serverAddress/api/done");
+          logger.fine("已通知服务端联机进程完成");
           break;
         }
       } catch (e) {
diff --git a/lib/sub_pages_builder/test_pages/local_pk_page.dart b/lib/sub_pages_builder/test_pages/local_pk_page.dart
index a7a5231..44a68ea 100644
--- a/lib/sub_pages_builder/test_pages/local_pk_page.dart
+++ b/lib/sub_pages_builder/test_pages/local_pk_page.dart
@@ -63,6 +63,7 @@ class _LocalPKSelectPage extends State<LocalPKSelectPage> {
 
   @override
   Widget build(BuildContext context) {
+    context.read<Global>().uiLogger.info("构建局域网联机主页面");
     MediaQueryData mediaQuery = MediaQuery.of(context);
     PKServer notifier = context.read<PKServer>();
     return Scaffold(
@@ -155,6 +156,7 @@ class ServerHostWatingPage extends StatefulWidget {
 class _ServerHostWatingPage extends State<ServerHostWatingPage> {
   @override
   Widget build(BuildContext context) {
+    context.read<Global>().uiLogger.info("构建局域网联机课程选择页面");
     MediaQueryData mediaQuery = MediaQuery.of(context);
     return context.watch<PKServer>().connected 
     ? Scaffold(
@@ -227,6 +229,7 @@ class ClientWatingPage extends StatelessWidget {
   
   @override
   Widget build(BuildContext context) {
+    context.read<Global>().uiLogger.info("构建局域网联机等待页面");
     return FutureBuilder(
       future: context.read<PKServer>().watingSelection(),
       builder: (context, asyncSnapshot) {
@@ -260,6 +263,7 @@ class _PKPreparePage extends State<PKPreparePage> {
 
   @override
   Widget build(BuildContext context) {
+    context.read<Global>().uiLogger.info("构建局域网联机准备页面");
     MediaQueryData mediaQuery = MediaQuery.of(context);
     if(!watching && !context.read<PKServer>().started) context.read<PKServer>().watingPrepare();
     if(context.read<PKServer>().startTime != null&&!downCount) {
@@ -368,6 +372,7 @@ class _PKOngoingPage extends State<PKOngoingPage> {
 
   @override
   Widget build(BuildContext context) {
+    context.read<Global>().uiLogger.info("构建局域网联机对局页面");
     MediaQueryData mediaQuery = MediaQuery.of(context);
 
     if(state == 0) {
@@ -466,6 +471,7 @@ class PKConclue extends StatelessWidget {
 
   @override
   Widget build(BuildContext context) {
+    context.read<Global>().uiLogger.info("构建局域网联机总结");
     MediaQueryData mediaQuery = MediaQuery.of(context);
 
     return Column(

From b80b0d75d72ea93f83a2aa41365d8f619076f70e Mon Sep 17 00:00:00 2001
From: OctagonalStar <76486554+OctagonalStar@users.noreply.github.com>
Date: Wed, 25 Feb 2026 17:03:58 +0800
Subject: [PATCH 06/11] feat: improve prepare button ui

Signed-off-by: OctagonalStar <76486554+OctagonalStar@users.noreply.github.com>
---
 lib/sub_pages_builder/test_pages/local_pk_page.dart | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)

diff --git a/lib/sub_pages_builder/test_pages/local_pk_page.dart b/lib/sub_pages_builder/test_pages/local_pk_page.dart
index 44a68ea..eda7a3a 100644
--- a/lib/sub_pages_builder/test_pages/local_pk_page.dart
+++ b/lib/sub_pages_builder/test_pages/local_pk_page.dart
@@ -309,13 +309,18 @@ class _PKPreparePage extends State<PKPreparePage> {
                       context.watch<PKServer>().preparedP1
                       ? Text("已准备")
                       : ElevatedButton(
+                        style: ElevatedButton.styleFrom(
+                          fixedSize: Size.fromHeight(mediaQuery.size.height * 0.1),
+                          shape: RoundedRectangleBorder(borderRadius: StaticsVar.br)
+                        ),
                         onPressed: (){
                           setState(() {
                             context.read<PKServer>().preparedP1 = true;
                           });
                         }, 
                         child: Text("准备")
-                      )
+                      ),
+                      if(context.watch<PKServer>().preparedP1) Icon(Icons.done, color: Colors.greenAccent, size: 36)
                     ],
                   ),
                 ),
@@ -331,7 +336,8 @@ class _PKPreparePage extends State<PKPreparePage> {
                     children: [
                       Text("对方", style: Theme.of(context).textTheme.headlineSmall),
                       SizedBox(height: mediaQuery.size.height * 0.05),
-                      Text("${context.watch<PKServer>().preparedP2 ? "已" : "未"}准备")
+                      Text("${context.watch<PKServer>().preparedP2 ? "已" : "未"}准备"),
+                      if(context.watch<PKServer>().preparedP2) Icon(Icons.done, color: Colors.greenAccent, size: 36)
                     ],
                   ),
                 )

From 0c3d9dc0fe93fdde9cffd06320e54503b4312f09 Mon Sep 17 00:00:00 2001
From: OctagonalStar <76486554+OctagonalStar@users.noreply.github.com>
Date: Wed, 25 Feb 2026 18:19:24 +0800
Subject: [PATCH 07/11] fix: sync not catch up sometime

Signed-off-by: OctagonalStar <76486554+OctagonalStar@users.noreply.github.com>
---
 lib/funcs/local_pk_server.dart                | 30 ++++---
 .../test_pages/local_pk_page.dart             | 86 ++++++++++---------
 2 files changed, 66 insertions(+), 50 deletions(-)

diff --git a/lib/funcs/local_pk_server.dart b/lib/funcs/local_pk_server.dart
index ec967d2..dffc245 100644
--- a/lib/funcs/local_pk_server.dart
+++ b/lib/funcs/local_pk_server.dart
@@ -158,7 +158,7 @@ class PKServer with ChangeNotifier{
         changed = true;
       }
       if(pkState.sideProgress.length == pkState.testWords.length && body["tooken"] != null) {
-        pkState.sideTookenTime = body["tooken"] - delay!.inSeconds;
+        pkState.sideTookenTime = body["tooken"] - (delay!.inMilliseconds/1000).round();
         logger.fine("已更新本地PKState.sideTookenTime");
         changed = true;
       }
@@ -262,7 +262,7 @@ class PKServer with ChangeNotifier{
     return 0;
   }
 
-  Future<ClassSelection> watingSelection() async {
+  Future<void> watingSelection(Function onEnd) async {
     logger.fine("开始等待服务端选择课程");
     while(classSelection == null) {
       await Future.delayed(Duration(seconds: 1));
@@ -288,7 +288,7 @@ class PKServer with ChangeNotifier{
         rethrow;
       } 
     }
-    return classSelection!;
+    onEnd();
   }
 
   Future<void> watingPrepare() async {
@@ -335,7 +335,7 @@ class PKServer with ChangeNotifier{
 
   Future<void> syncPKState() async {
     logger.info("开始进行双端状态同步");
-    while(true) {
+    while(pkState.selfTookenTime == null || pkState.sideTookenTime == null) {
       try{
         await Future.delayed(Duration(milliseconds: 500));
         logger.finer("进行状态数据交换");
@@ -343,7 +343,7 @@ class PKServer with ChangeNotifier{
           "$serverAddress/api/sync",
           data: {
             "progress": pkState.selfProgress,
-            "tooken": pkState.selfTookenTime
+            "tooken": null
           },
           options: dio.Options(connectTimeout: Duration(seconds: 1))
         );
@@ -361,15 +361,25 @@ class PKServer with ChangeNotifier{
           changed = true;
         }
         if(changed) notifyListeners();
-        if(pkState.selfTookenTime != null && pkState.sideTookenTime != null) {
-          client.get("$serverAddress/api/done");
-          logger.fine("已通知服务端联机进程完成");
-          break;
-        }
       } catch (e) {
         logger.shout("同步状态失败 $e");
       }
     }
+    try{
+      await client.post(
+        "$serverAddress/api/sync",
+        data: {
+          "progress": pkState.selfProgress,
+          "tooken": pkState.selfTookenTime
+        },
+        options: dio.Options(connectTimeout: Duration(seconds: 1))
+      );
+      client.get("$serverAddress/api/done");
+      logger.fine("已通知服务端联机进程完成");
+    } catch (e) {
+      logger.shout("同步状态失败 $e");
+    }
+    
   }
 
   void updateState(bool correct) {
diff --git a/lib/sub_pages_builder/test_pages/local_pk_page.dart b/lib/sub_pages_builder/test_pages/local_pk_page.dart
index eda7a3a..b3a220f 100644
--- a/lib/sub_pages_builder/test_pages/local_pk_page.dart
+++ b/lib/sub_pages_builder/test_pages/local_pk_page.dart
@@ -43,7 +43,7 @@ class _LocalPKSelectPage extends State<LocalPKSelectPage> {
         context, 
         MaterialPageRoute(builder: (context) => ChangeNotifierProvider.value(
           value: notifier,
-          child: ClientWatingPage(),
+          child: ServerPage(isServer: false),
         ))
       );
     } else if (statue == 1) {
@@ -82,7 +82,7 @@ class _LocalPKSelectPage extends State<LocalPKSelectPage> {
                 MaterialPageRoute(
                   builder: (context) => ChangeNotifierProvider.value(
                     value: notifier,
-                    child: ServerHostWatingPage(),
+                    child: ServerPage(isServer: true),
                   )
                 )
               );
@@ -146,14 +146,40 @@ class _LocalPKSelectPage extends State<LocalPKSelectPage> {
   }
 }
 
-class ServerHostWatingPage extends StatefulWidget {
-  const ServerHostWatingPage({super.key});
+class ServerPage extends StatefulWidget {
+  final bool isServer;
+  const ServerPage({super.key, required this.isServer});
 
   @override
-  State<StatefulWidget> createState() => _ServerHostWatingPage();
+  State<StatefulWidget> createState() => _ServerPage();
 }
 
-class _ServerHostWatingPage extends State<ServerHostWatingPage> {
+class _ServerPage extends State<ServerPage> {
+  final PageController pageController = PageController();
+  bool clientWaited = false;
+
+  @override
+  Widget build(BuildContext context) {
+    if(!widget.isServer && !clientWaited) {
+      context.read<PKServer>().watingSelection(() => pageController.nextPage(duration: Duration(milliseconds: 500), curve: StaticsVar.curve));
+      clientWaited = true;
+    }
+    return PageView(
+      physics: NeverScrollableScrollPhysics(),
+      controller: pageController,
+      children: [
+        widget.isServer ? ServerHostWatingPage(pageController: pageController) : ClientWatingPage(),
+        PKPreparePage(pageController: pageController),
+        PKOngoingPage()
+      ],
+    );
+  }
+}
+
+class ServerHostWatingPage extends StatelessWidget {
+  final PageController pageController;
+  const ServerHostWatingPage({super.key, required this.pageController});
+
   @override
   Widget build(BuildContext context) {
     context.read<Global>().uiLogger.info("构建局域网联机课程选择页面");
@@ -174,14 +200,7 @@ class _ServerHostWatingPage extends State<ServerHostWatingPage> {
                 ClassSelection selection = await popSelectClasses(context, forceSelectRange: context.read<PKServer>().selectableSource, withCache: false, withReviewChoose: false);
                 if(!context.mounted) return;
                 context.read<PKServer>().classSelection = selection;
-                PKServer notifier = context.read<PKServer>();
-                Navigator.push(
-                  context, 
-                  MaterialPageRoute(builder: (context) => ChangeNotifierProvider.value(
-                    value: notifier,
-                    child: PKPreparePage(),
-                  ))
-                );
+                pageController.nextPage(duration: Duration(milliseconds: 500), curve: StaticsVar.curve);
               }, 
               child: Text("开始选课")
             )
@@ -230,28 +249,23 @@ class ClientWatingPage extends StatelessWidget {
   @override
   Widget build(BuildContext context) {
     context.read<Global>().uiLogger.info("构建局域网联机等待页面");
-    return FutureBuilder(
-      future: context.read<PKServer>().watingSelection(),
-      builder: (context, asyncSnapshot) {
-        return asyncSnapshot.hasData 
-        ? PKPreparePage()
-        : Scaffold(
-          appBar: AppBar(title: Text("连接成功")),
-          body: Center(child: Column(
-            mainAxisSize: MainAxisSize.min,
-            children: [
-              CircularProgressIndicator(),
-              Text("正在等待房主选择课程")
-            ]
-          ))
-        );
-      }
+    
+    return Scaffold(
+      appBar: AppBar(title: Text("连接成功")),
+      body: Center(child: Column(
+        mainAxisSize: MainAxisSize.min,
+        children: [
+          CircularProgressIndicator(),
+          Text("正在等待房主选择课程")
+        ]
+      ))
     );
   }
 }
 
 class PKPreparePage extends StatefulWidget {
-  const PKPreparePage({super.key});
+  final PageController pageController;
+  const PKPreparePage({super.key, required this.pageController});
 
   @override
   State<StatefulWidget> createState() => _PKPreparePage();
@@ -270,15 +284,7 @@ class _PKPreparePage extends State<PKPreparePage> {
       downCount = true;
       Future.delayed(context.read<PKServer>().startTime!.difference(DateTime.now()), () {
         if(!context.mounted) return;
-        PKServer notifier = context.read<PKServer>();
-        Navigator.pop(context);
-        Navigator.push(
-          context, 
-          MaterialPageRoute(builder: (context) => ChangeNotifierProvider.value(
-            value: notifier,
-            child: PKOngoingPage(),
-          ))
-        );
+        widget.pageController.nextPage(duration: Duration(milliseconds: 500), curve: StaticsVar.curve);
       });
     }
     return Scaffold(

From 0c9681b2053ccec573d3752135100d162f4b6d80 Mon Sep 17 00:00:00 2001
From: OctagonalStar <76486554+OctagonalStar@users.noreply.github.com>
Date: Wed, 25 Feb 2026 18:39:50 +0800
Subject: [PATCH 08/11] feat: add error handel

Signed-off-by: OctagonalStar <76486554+OctagonalStar@users.noreply.github.com>
---
 lib/funcs/local_pk_server.dart                | 27 +++++++--
 .../test_pages/local_pk_page.dart             | 60 ++++++++++++++-----
 2 files changed, 67 insertions(+), 20 deletions(-)

diff --git a/lib/funcs/local_pk_server.dart b/lib/funcs/local_pk_server.dart
index dffc245..24998a8 100644
--- a/lib/funcs/local_pk_server.dart
+++ b/lib/funcs/local_pk_server.dart
@@ -28,16 +28,16 @@ class PKServer with ChangeNotifier{
   DateTime? startTime;
   bool preparedP1 = false;
   bool preparedP2 = false;
-  late final PKState pkState;
+  late PKState pkState;
 
   // server
   bool started = false;
   Duration? delay;
-  late final HttpServer _server;
-  late final int _port;
+  late HttpServer _server;
+  late int _port;
 
   // client
-  late final String serverAddress;
+  String? serverAddress;
   final dio.Dio client = dio.Dio();
 
   String? get connectpwd {
@@ -59,6 +59,18 @@ class PKServer with ChangeNotifier{
     global = outerglobal;
   }
 
+  void renew() {
+    connected = false;
+    selectableSource = [];
+    classSelection = null;
+    startTime = null;
+    preparedP1 = false;
+    preparedP2 = false;
+    started = false;
+    delay = null;
+    serverAddress = null;
+  }
+
   Future<bool> startHost() async {
     if(started) return true;
     _port = Random().nextInt(55535)+10000;
@@ -335,8 +347,12 @@ class PKServer with ChangeNotifier{
 
   Future<void> syncPKState() async {
     logger.info("开始进行双端状态同步");
+    int expCount = 0;
     while(pkState.selfTookenTime == null || pkState.sideTookenTime == null) {
       try{
+        if(expCount == 5) {
+          break;
+        }
         await Future.delayed(Duration(milliseconds: 500));
         logger.finer("进行状态数据交换");
         final syncRes = await client.post(
@@ -360,11 +376,14 @@ class PKServer with ChangeNotifier{
           pkState.sideTookenTime = syncRes.data["tooken"];
           changed = true;
         }
+        expCount = 0;
         if(changed) notifyListeners();
       } catch (e) {
         logger.shout("同步状态失败 $e");
+        expCount++;
       }
     }
+    if(expCount == 5) throw Exception("Server disconnected");
     try{
       await client.post(
         "$serverAddress/api/sync",
diff --git a/lib/sub_pages_builder/test_pages/local_pk_page.dart b/lib/sub_pages_builder/test_pages/local_pk_page.dart
index b3a220f..34791fe 100644
--- a/lib/sub_pages_builder/test_pages/local_pk_page.dart
+++ b/lib/sub_pages_builder/test_pages/local_pk_page.dart
@@ -43,7 +43,7 @@ class _LocalPKSelectPage extends State<LocalPKSelectPage> {
         context, 
         MaterialPageRoute(builder: (context) => ChangeNotifierProvider.value(
           value: notifier,
-          child: ServerPage(isServer: false),
+          child: LocalPKPage(isServer: false),
         ))
       );
     } else if (statue == 1) {
@@ -82,7 +82,7 @@ class _LocalPKSelectPage extends State<LocalPKSelectPage> {
                 MaterialPageRoute(
                   builder: (context) => ChangeNotifierProvider.value(
                     value: notifier,
-                    child: ServerPage(isServer: true),
+                    child: LocalPKPage(isServer: true),
                   )
                 )
               );
@@ -146,32 +146,47 @@ class _LocalPKSelectPage extends State<LocalPKSelectPage> {
   }
 }
 
-class ServerPage extends StatefulWidget {
+class LocalPKPage extends StatefulWidget {
   final bool isServer;
-  const ServerPage({super.key, required this.isServer});
+  const LocalPKPage({super.key, required this.isServer});
 
   @override
   State<StatefulWidget> createState() => _ServerPage();
 }
 
-class _ServerPage extends State<ServerPage> {
+class _ServerPage extends State<LocalPKPage> {
   final PageController pageController = PageController();
   bool clientWaited = false;
 
   @override
   Widget build(BuildContext context) {
     if(!widget.isServer && !clientWaited) {
-      context.read<PKServer>().watingSelection(() => pageController.nextPage(duration: Duration(milliseconds: 500), curve: StaticsVar.curve));
+      try{
+        context.read<PKServer>().watingSelection(() => pageController.nextPage(duration: Duration(milliseconds: 500), curve: StaticsVar.curve));
+      } catch (e) {
+        alart(context, "连接丢失 ${e.toString()}");
+        Navigator.pop(context);
+      }
+      
       clientWaited = true;
     }
-    return PageView(
-      physics: NeverScrollableScrollPhysics(),
-      controller: pageController,
-      children: [
-        widget.isServer ? ServerHostWatingPage(pageController: pageController) : ClientWatingPage(),
-        PKPreparePage(pageController: pageController),
-        PKOngoingPage()
-      ],
+    return PopScope(
+      canPop: true,
+      onPopInvokedWithResult: (didPop, result) {
+        if(widget.isServer) {
+          context.read<PKServer>().stopHost();
+        }
+        context.read<PKServer>().renew();
+      },
+      child: PageView(
+        physics: NeverScrollableScrollPhysics(),
+        controller: pageController,
+        children: [
+          widget.isServer ? ServerHostWatingPage(pageController: pageController) : ClientWatingPage(),
+          PKPreparePage(pageController: pageController),
+          PKOngoingPage()
+        ],
+      ),
     );
   }
 }
@@ -279,7 +294,14 @@ class _PKPreparePage extends State<PKPreparePage> {
   Widget build(BuildContext context) {
     context.read<Global>().uiLogger.info("构建局域网联机准备页面");
     MediaQueryData mediaQuery = MediaQuery.of(context);
-    if(!watching && !context.read<PKServer>().started) context.read<PKServer>().watingPrepare();
+    if(!watching && !context.read<PKServer>().started) {
+      try{
+        context.read<PKServer>().watingPrepare();
+      } catch (e) {
+        alart(context, "连接丢失 ${e.toString()}");
+        Navigator.pop(context);
+      }
+    }
     if(context.read<PKServer>().startTime != null&&!downCount) {
       downCount = true;
       Future.delayed(context.read<PKServer>().startTime!.difference(DateTime.now()), () {
@@ -388,7 +410,13 @@ class _PKOngoingPage extends State<PKOngoingPage> {
     MediaQueryData mediaQuery = MediaQuery.of(context);
 
     if(state == 0) {
-      if(!context.read<PKServer>().started) context.read<PKServer>().initPK();
+      try {
+        if(!context.read<PKServer>().started) context.read<PKServer>().initPK();
+      } catch (e) {
+        alart(context, "连接丢失: ${e.toString()}");
+        Navigator.pop(context);
+      }
+      
       Random rnd = Random(context.read<PKServer>().rndSeed);
       for(WordItem wordItem in context.read<PKServer>().pkState.testWords) {
         List<WordItem> optionWords = getRandomWords(4, context.read<Global>().wordData, allowRepet: false, include: wordItem, shuffle: true, rnd: rnd);

From d635c5c2588258107b78090e708b24987458eaba Mon Sep 17 00:00:00 2001
From: OctagonalStar <76486554+OctagonalStar@users.noreply.github.com>
Date: Wed, 25 Feb 2026 19:02:22 +0800
Subject: [PATCH 09/11] fix: on net work exception hangler

Signed-off-by: OctagonalStar <76486554+OctagonalStar@users.noreply.github.com>
---
 lib/funcs/local_pk_server.dart                | 26 ++++++++++++-------
 .../test_pages/local_pk_page.dart             | 22 +++-------------
 2 files changed, 20 insertions(+), 28 deletions(-)

diff --git a/lib/funcs/local_pk_server.dart b/lib/funcs/local_pk_server.dart
index 24998a8..c37a0e3 100644
--- a/lib/funcs/local_pk_server.dart
+++ b/lib/funcs/local_pk_server.dart
@@ -2,9 +2,11 @@ import 'dart:io' show HttpServer;
 import 'dart:math';
 import 'dart:convert';
 import 'dart:typed_data' show Uint8List;
+import 'package:arabic_learning/funcs/ui.dart' show alart;
 import 'package:arabic_learning/funcs/utili.dart';
 import 'package:arabic_learning/vars/config_structure.dart';
 import 'package:arabic_learning/vars/global.dart';
+import 'package:flutter/material.dart' show BuildContext, Navigator;
 import 'package:logging/logging.dart';
 import 'package:network_info_plus/network_info_plus.dart';
 import 'package:arabic_learning/vars/statics_var.dart';
@@ -274,8 +276,9 @@ class PKServer with ChangeNotifier{
     return 0;
   }
 
-  Future<void> watingSelection(Function onEnd) async {
+  Future<void> watingSelection(BuildContext context, Function onEnd) async {
     logger.fine("开始等待服务端选择课程");
+    bool isException = false;
     while(classSelection == null) {
       await Future.delayed(Duration(seconds: 1));
       try{
@@ -297,13 +300,15 @@ class PKServer with ChangeNotifier{
         classSelection = ClassSelection(selectedClass: selectedClass, countInReview: false);
       } catch (e) {
         logger.shout("连接服务端发生错误: $e");
-        rethrow;
+        if(context.mounted) alart(context, "连接丢失 ${e.toString()}", onConfirmed: () => Navigator.popUntil(context, (route) => route.isFirst));
+        isException = true;
+        break;
       } 
     }
-    onEnd();
+    if(!isException) onEnd();
   }
 
-  Future<void> watingPrepare() async {
+  Future<void> watingPrepare(BuildContext context) async {
     logger.fine("开始等待双端准备");
     while (!preparedP2 || startTime == null) {
       try{
@@ -330,22 +335,23 @@ class PKServer with ChangeNotifier{
         if(changed) notifyListeners();
       } catch (e) {
         logger.shout("连接服务端失败: $e");
-        rethrow;
+        if(context.mounted) alart(context, "连接丢失 ${e.toString()}", onConfirmed: () => Navigator.popUntil(context, (route) => route.isFirst));
+        break;
       }
     }
   }
 
-  void initPK() {
+  void initPK(BuildContext context) {
     pkState = PKState(
       testWords: getSelectedWords(global.wordData, classSelection!.selectedClass, doShuffle: true, shuffleSeed: rndSeed), 
       selfProgress: [], 
       sideProgress: []
     );
     logger.fine("已完成PKState初始化");
-    syncPKState();
+    syncPKState(context);
   }
 
-  Future<void> syncPKState() async {
+  Future<void> syncPKState(BuildContext context) async {
     logger.info("开始进行双端状态同步");
     int expCount = 0;
     while(pkState.selfTookenTime == null || pkState.sideTookenTime == null) {
@@ -383,7 +389,9 @@ class PKServer with ChangeNotifier{
         expCount++;
       }
     }
-    if(expCount == 5) throw Exception("Server disconnected");
+    if(expCount == 5) {
+      if(context.mounted) alart(context, "连接丢失 无法连接到服务端", onConfirmed: () => Navigator.popUntil(context, (route) => route.isFirst));
+    }
     try{
       await client.post(
         "$serverAddress/api/sync",
diff --git a/lib/sub_pages_builder/test_pages/local_pk_page.dart b/lib/sub_pages_builder/test_pages/local_pk_page.dart
index 34791fe..3305876 100644
--- a/lib/sub_pages_builder/test_pages/local_pk_page.dart
+++ b/lib/sub_pages_builder/test_pages/local_pk_page.dart
@@ -161,13 +161,7 @@ class _ServerPage extends State<LocalPKPage> {
   @override
   Widget build(BuildContext context) {
     if(!widget.isServer && !clientWaited) {
-      try{
-        context.read<PKServer>().watingSelection(() => pageController.nextPage(duration: Duration(milliseconds: 500), curve: StaticsVar.curve));
-      } catch (e) {
-        alart(context, "连接丢失 ${e.toString()}");
-        Navigator.pop(context);
-      }
-      
+      context.read<PKServer>().watingSelection(context, () => pageController.nextPage(duration: Duration(milliseconds: 500), curve: StaticsVar.curve));
       clientWaited = true;
     }
     return PopScope(
@@ -295,12 +289,7 @@ class _PKPreparePage extends State<PKPreparePage> {
     context.read<Global>().uiLogger.info("构建局域网联机准备页面");
     MediaQueryData mediaQuery = MediaQuery.of(context);
     if(!watching && !context.read<PKServer>().started) {
-      try{
-        context.read<PKServer>().watingPrepare();
-      } catch (e) {
-        alart(context, "连接丢失 ${e.toString()}");
-        Navigator.pop(context);
-      }
+      context.read<PKServer>().watingPrepare(context);
     }
     if(context.read<PKServer>().startTime != null&&!downCount) {
       downCount = true;
@@ -410,12 +399,7 @@ class _PKOngoingPage extends State<PKOngoingPage> {
     MediaQueryData mediaQuery = MediaQuery.of(context);
 
     if(state == 0) {
-      try {
-        if(!context.read<PKServer>().started) context.read<PKServer>().initPK();
-      } catch (e) {
-        alart(context, "连接丢失: ${e.toString()}");
-        Navigator.pop(context);
-      }
+      if(!context.read<PKServer>().started) context.read<PKServer>().initPK(context);
       
       Random rnd = Random(context.read<PKServer>().rndSeed);
       for(WordItem wordItem in context.read<PKServer>().pkState.testWords) {

From 08a87a8de53772185b0cec5a286a4a5eb80ded6f Mon Sep 17 00:00:00 2001
From: OctagonalStar <76486554+OctagonalStar@users.noreply.github.com>
Date: Wed, 25 Feb 2026 21:28:33 +0800
Subject: [PATCH 10/11] feat: not allow web in pk

Signed-off-by: OctagonalStar <76486554+OctagonalStar@users.noreply.github.com>
---
 lib/funcs/local_pk_server.dart                |  2 +-
 .../fake_local_pk_page.dart                   | 10 ++++
 .../fake_local_pk_server.dart                 | 57 +++++++++++++++++++
 lib/pages/test_page.dart                      | 10 +++-
 .../test_pages/local_pk_page.dart             |  7 ++-
 lib/vars/statics_var.dart                     |  2 +-
 6 files changed, 81 insertions(+), 7 deletions(-)
 create mode 100644 lib/package_replacement/fake_local_pk_page.dart
 create mode 100644 lib/package_replacement/fake_local_pk_server.dart

diff --git a/lib/funcs/local_pk_server.dart b/lib/funcs/local_pk_server.dart
index c37a0e3..57dabe4 100644
--- a/lib/funcs/local_pk_server.dart
+++ b/lib/funcs/local_pk_server.dart
@@ -172,7 +172,7 @@ class PKServer with ChangeNotifier{
         changed = true;
       }
       if(pkState.sideProgress.length == pkState.testWords.length && body["tooken"] != null) {
-        pkState.sideTookenTime = body["tooken"] - (delay!.inMilliseconds/1000).round();
+        pkState.sideTookenTime = body["tooken"];
         logger.fine("已更新本地PKState.sideTookenTime");
         changed = true;
       }
diff --git a/lib/package_replacement/fake_local_pk_page.dart b/lib/package_replacement/fake_local_pk_page.dart
new file mode 100644
index 0000000..03d2a42
--- /dev/null
+++ b/lib/package_replacement/fake_local_pk_page.dart
@@ -0,0 +1,10 @@
+import 'package:flutter/material.dart';
+
+class LocalPKSelectPage extends StatelessWidget{
+  const LocalPKSelectPage({super.key});
+
+  @override
+  Widget build(BuildContext context) {
+    throw UnimplementedError();
+  }
+}
\ No newline at end of file
diff --git a/lib/package_replacement/fake_local_pk_server.dart b/lib/package_replacement/fake_local_pk_server.dart
new file mode 100644
index 0000000..9bdb386
--- /dev/null
+++ b/lib/package_replacement/fake_local_pk_server.dart
@@ -0,0 +1,57 @@
+import 'package:arabic_learning/vars/config_structure.dart';
+import 'package:arabic_learning/vars/global.dart';
+import 'package:flutter/material.dart';
+
+class PKServer with ChangeNotifier{
+  bool get connected => false;
+
+  List<SourceItem> selectableSource = [];
+
+  String? connectpwd = "";
+
+  bool get started => false;
+
+  DateTime? startTime;
+
+  ClassSelection? classSelection;
+
+  bool preparedP1 = false;
+  bool preparedP2 = false;
+
+  int? get rndSeed => null;
+
+  late PKState pkState;
+
+  Future<int> testConnect(String text) async {return 0;}
+
+  void watingSelection(BuildContext context, Future<dynamic> Function() param1) {}
+
+  void stopHost() {}
+
+  void renew() {}
+
+  Future<bool>? startHost() async {return false;}
+
+  void watingPrepare(BuildContext context) {}
+
+  void initPK(BuildContext context) {}
+
+  double calculatePt(List selfProgress, int param1) {return 0;}
+
+  void updateState(bool bool) {}
+
+  Future<void> init(Global read) async {}
+
+}
+
+class PKState {
+  final List<WordItem> testWords = [];
+
+  int? selfTookenTime;
+
+  int? sideTookenTime;
+
+  List<bool> selfProgress = [];
+
+  List<bool> sideProgress = [];
+}
\ No newline at end of file
diff --git a/lib/pages/test_page.dart b/lib/pages/test_page.dart
index 5170e97..bdcf55b 100644
--- a/lib/pages/test_page.dart
+++ b/lib/pages/test_page.dart
@@ -1,11 +1,13 @@
-import 'package:arabic_learning/funcs/local_pk_server.dart' show PKServer;
+import 'package:arabic_learning/funcs/ui.dart';
+import 'package:flutter/foundation.dart';
 import 'package:flutter/material.dart';
 import 'package:provider/provider.dart';
 
 import 'package:arabic_learning/vars/global.dart';
 import 'package:arabic_learning/vars/statics_var.dart';
-import 'package:arabic_learning/sub_pages_builder/test_pages/local_pk_page.dart' show LocalPKSelectPage;
 import 'package:arabic_learning/sub_pages_builder/test_pages/listening_test_page.dart' show ForeListeningSettingPage;
+import 'package:arabic_learning/package_replacement/fake_local_pk_server.dart' if (dart.library.io) 'package:arabic_learning/funcs/local_pk_server.dart' show PKServer;
+import 'package:arabic_learning/package_replacement/fake_local_pk_page.dart' if (dart.library.io) 'package:arabic_learning/sub_pages_builder/test_pages/local_pk_page.dart' show LocalPKSelectPage;
 
 class TestPage extends StatelessWidget {
   const TestPage({super.key});
@@ -28,6 +30,10 @@ class TestPage extends StatelessWidget {
             ),
           ),
           onPressed: () {
+            if(kIsWeb) {
+              alart(context, "局域网联机功能因为技术原因，不对网页端开放。");
+              return;
+            }
             context.read<Global>().uiLogger.info("跳转: TestPage => LocalPKSelectPage");
             Navigator.push(
               context, 
diff --git a/lib/sub_pages_builder/test_pages/local_pk_page.dart b/lib/sub_pages_builder/test_pages/local_pk_page.dart
index 3305876..add7407 100644
--- a/lib/sub_pages_builder/test_pages/local_pk_page.dart
+++ b/lib/sub_pages_builder/test_pages/local_pk_page.dart
@@ -1,7 +1,7 @@
 import 'dart:async';
+import 'dart:io';
 import 'dart:math';
 
-import 'package:arabic_learning/funcs/local_pk_server.dart';
 import 'package:arabic_learning/funcs/ui.dart';
 import 'package:arabic_learning/funcs/utili.dart';
 import 'package:arabic_learning/vars/config_structure.dart';
@@ -11,6 +11,7 @@ import 'package:flutter/material.dart';
 import 'package:qr_flutter/qr_flutter.dart';
 import 'package:mobile_scanner/mobile_scanner.dart';
 import 'package:provider/provider.dart';
+import 'package:arabic_learning/package_replacement/fake_local_pk_server.dart' if (dart.library.io) 'package:arabic_learning/funcs/local_pk_server.dart';
 
 
 class LocalPKSelectPage extends StatefulWidget {
@@ -116,7 +117,7 @@ class _LocalPKSelectPage extends State<LocalPKSelectPage> {
             },
           ),
           SizedBox(height: mediaQuery.size.height * 0.02),
-          ElevatedButton.icon(
+          if(Platform.isAndroid) ElevatedButton.icon(
             onPressed: () {
               if(isScaning) scannerController.stop();
               setState(() {
@@ -425,7 +426,7 @@ class _PKOngoingPage extends State<PKOngoingPage> {
                   physics: NeverScrollableScrollPhysics(),
                   itemBuilder: (context, index) {
                     if(index == context.read<PKServer>().pkState.testWords.length) {
-                      context.read<PKServer>().pkState.selfTookenTime = DateTime.now().difference(context.read<PKServer>().startTime!).inSeconds;
+                      context.read<PKServer>().pkState.selfTookenTime ??= DateTime.now().difference(context.read<PKServer>().startTime!).inSeconds;
                       if(context.read<PKServer>().pkState.sideTookenTime == null) {
                         return Center(
                           child: Text("等待对方完成中...", style: Theme.of(context).textTheme.headlineSmall),
diff --git a/lib/vars/statics_var.dart b/lib/vars/statics_var.dart
index 89047d2..cfca7d0 100644
--- a/lib/vars/statics_var.dart
+++ b/lib/vars/statics_var.dart
@@ -1,5 +1,5 @@
 import 'package:flutter/foundation.dart' show kIsWeb;
-import '../package_replacement/fake_dart_io.dart' if (dart.library.io) 'dart:io' show Platform;
+import 'package:arabic_learning/package_replacement/fake_dart_io.dart' if (dart.library.io) 'dart:io' show Platform;
 
 import 'package:flutter/material.dart';
 import 'package:just_audio/just_audio.dart';

From 73656ce19dbe1aa85b1d28e6ec764f2f4e627b10 Mon Sep 17 00:00:00 2001
From: OctagonalStar <76486554+OctagonalStar@users.noreply.github.com>
Date: Wed, 25 Feb 2026 21:30:16 +0800
Subject: [PATCH 11/11] docs: update change log

Signed-off-by: OctagonalStar <76486554+OctagonalStar@users.noreply.github.com>
---
 CHANGELOG.md | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/CHANGELOG.md b/CHANGELOG.md
index 1af256d..e7dc5e2 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -2,6 +2,10 @@
 
 ## v?.?.? - ????-??-?? - (??????)
 
+### Added
+
+- 添加了局域网联机功能
+
 ### Improvement
 
 - 优化了单词卡片的排版