点击 和 输入 全部完成的初版

2 加密 和 解密

lib/windows/code.dart

@@ -1,4 +1,6 @@
 // 定义密钥
+import 'dart:convert';
+
 List skey = [8, 1, 2, 5, 4];
 
 // 单个字符异或运算
@@ -11,8 +13,8 @@ String makecodeChar(String c, int key, int key2) {
 // 单个字符解密
 String cutcodeChar(String c, int key, int key2) {
   int charCode = c.codeUnitAt(0);
-  charCode = (((charCode - 1) ^ key) ^ key2) - key;
-  return String.fromCharCode(charCode);
+  int decryptedCharCode = (((charCode - 1) ^ key) ^ key2) - key;
+  return String.fromCharCode(decryptedCharCode);
 }
 
 // 加密
@@ -25,8 +27,11 @@ String makecode(String pstr, List pkey) {
 }
 
 // 解密
-void cutecode(String pstr, List pkey) {
-  for (int i = 0; i < pstr.length; i++) {
-    pstr = pstr.replaceRange(i, i + 1, cutcodeChar(pstr[i], pkey[i % 5], pkey[(i + 18) % 5]));
+String cutecode(List<int> pstr) {
+  int len = pstr.length;
+  for (int i = 0; i < len; i++) {
+    pstr[i] = cutcodeChar(String.fromCharCode(pstr[i])
+        , skey[i % 5], skey[(i + 18) % 5]).codeUnitAt(0);
   }
+  return String.fromCharCodes(pstr);
 }

lib/windows/number_tool.dart

@@ -7,18 +7,42 @@ class NumberTool {
   /// @allNum: 随机数的和
   /// @num: 随机数的数量
   List<int> randomNum(int allNum, {int num = 10}) {
-    List<int> randomNumbers = [];
-    int remainingNum = allNum;
+    Random random = Random();
+
+    // 基础数字 最小值
+    int base = allNum ~/ 1.5 ~/ num;
+    List<int> numbers = List.generate(num, (index) => base);
+
 
     for (int i = 0; i < num - 1; i++) {
-      int randomNumber = Random().nextInt(remainingNum) + 1;
-      randomNumbers.add(randomNumber);
-      remainingNum -= randomNumber;
+      int randomNumber = random.nextInt(base); // 生成0到base之间的随机整数
+      numbers[i] += randomNumber;
     }
 
-    randomNumbers.add(allNum - randomNumbers.fold(0, (prev, element) => prev + element));
+    int sum = numbers.reduce((a, b) => a + b) ;
+    int lastNumber = allNum - sum;
 
-    return randomNumbers;
+    // 将最后一个数 /2  再/数量 取整数
+    base = (lastNumber / 2) ~/ (num);
+    for (int i = 0; i < num - 1; i++) {
+      numbers[i] += base;
+    }
+
+    sum = numbers.reduce((a, b) => a + b);
+    lastNumber = allNum - sum;
+
+    // 将最后一个数 切一半 随机加到数组中
+    base = lastNumber ~/ 2;
+    numbers[ random.nextInt(num - 1)] = base;
+    sum = numbers.reduce((a, b) => a + b);
+    lastNumber = allNum - sum;
+
+    numbers.add(lastNumber);
+
+    // 打乱顺序
+    numbers.shuffle();
+
+    return numbers;
   }
 
 }

lib/windows/socket_tool.dart

@@ -2,8 +2,11 @@ import 'dart:async';
 import 'dart:convert';
 import 'dart:io';
 import 'dart:typed_data';
+import 'package:web_synchronization_tool/windows/synchronization_web_tool.dart';
+
 import 'little_extension.dart';
 import 'code.dart';
+import 'number_tool.dart';
 
 class SocketUtils extends Socket{
   // 私有构造函数
@@ -21,39 +24,114 @@ class SocketUtils extends Socket{
 
 class Socket {
 
-  static String url = '127.0.0.1';
+  String url = '127.0.0.1';
   static int port = 12345;
 
   RawDatagramSocket? socket;
 
+  // IC 0主机 1 从机
+  int ic = 1;
+
+  /// 从机ip
+  List<String> childrenIp = [];
+
   connect() async {
-    socket = await RawDatagramSocket.bind('127.0.0.2', 1);
-    print('UDP Socket bound to ${socket?.address.address}:${socket?.port}');
+    socket = await RawDatagramSocket.bind(InternetAddress.anyIPv4, 0);
+
+    // 发送身份包
+    Map data = {
+      "op": 0,
+      "IC": ic
+    };
+    socket?.send(dataMake(data), InternetAddress(url), port);
 
     // 监听来自网络的数据包
     socket?.listen((RawSocketEvent e) {
       Datagram? d = socket?.receive();
       if (d == null) return;
 
-      // String message = String.fromCharCodes(d.data).trim();
-      // print('Datagram from ${d.address.address}:${d.port}: $message');
+      Map data = dataCute(d.data);
+
+      // 收到消息
+      if (data['op'] == 2){
+
+        print(data);
+
+        //点击
+        if (data['click'] != null){
+          Map click = data['click'];
+          int x = click['x'] as int;
+          int y = click['y'] as int;
+
+          SynchronizationWebTool.getInstance().clickSynchronization(x, y);
+        }
+        //输入
+        if (data['input'] != null){
+          int input = data['input'];
+          List<int> nums = NumberTool().randomNum(input);
+          SynchronizationWebTool.getInstance().input(nums);
+        }
+
+      }
+
+      // 心跳
+      if (data['op'] == 11){
+
+      }
+      // 服务器 已连接的ip
+      if (data['Arr'] != null){
+        List arr = data['Arr'];
+        List<String> ips = [];
+        arr.forEach((clientMap) {
+          String ip = clientMap['Client'];
+          ips.add(ip);
+        });
+        childrenIp = ips;
+      }
+
     });
 
-    heartbeat();
   }
 
   /// 发送消息
-  sendMessage(Map data){
-    socket?.send(dataMake(data), InternetAddress(url), port);
+  sendClickMessage(Map data){
+    Map messageMap = {
+      "op": 2,
+      "click": data
+    };
+    socket?.send(dataMake(messageMap), InternetAddress(url), port);
+  }
+
+  /// 发送获取从机 消息
+  sendGetChilds(){
+    Map messageMap = {
+      "op": 3,
+    };
+    socket?.send(dataMake(messageMap), InternetAddress(url), port);
   }
 
 
+  /// 发送输入喜消息
+  sendInpuMessage(int num){
+    Map messageMap = {
+      "op": 2,
+      "input": num
+    };
+    socket?.send(dataMake(messageMap), InternetAddress(url), port);
+  }
+
   /// 心跳
   heartbeat(){
-    Timer timer = Timer(const Duration(seconds: 10), () {
+    Timer timer = Timer(const Duration(seconds: 10), () async {
+
+      if (socket == null){
+        // 重连
+        await connect();
+      }
+
       Map data =   {
         "op": 1,
-        "IC": 0
+        "IC": ic
       };
       socket?.send(dataMake(data), InternetAddress(url), port);
 
@@ -74,4 +152,18 @@ class Socket {
     return uinData.toList();
   }
 
+  /// 接收数据处理
+  Map dataCute(Uint8List data){
+
+    if (data.length <= 4) return {};
+
+    Uint8List pData = data.sublist(4,data.length);
+
+    String str = cutecode(pData);
+
+    Map map = json.decode(str);
+
+    return map;
+  }
+
 }

lib/windows/synchronization_web_tool.dart

@@ -50,11 +50,11 @@ class SynchronizationWebTool{
 
       if (event['click'] != null) {
         Map click = event['click'];
-        double x = (click['x'] as int).toDouble();
-        double y = (click['y'] as int).toDouble();
+        int x = click['x'] as int;
+        int y = click['y'] as int;
 
         clickSynchronization(x, y);
-        SocketUtils.getInstance().sendMessage(event);
+        SocketUtils.getInstance().sendClickMessage(click);
       }
 
       if (event['scroll']  != null ) {
@@ -72,7 +72,7 @@ class SynchronizationWebTool{
   }
 
   /// 点击同步
-  clickSynchronization(double x,double y){
+  clickSynchronization(int x,int y){
     for (var controller in childController) {
       controller.executeScript(WindowsJs.clickJs(x, y));
     }

lib/windows/web_grid_view.dart

@@ -1,5 +1,6 @@
 import 'package:flutter/material.dart';
 import 'package:web_synchronization_tool/windows/number_tool.dart';
+import 'package:web_synchronization_tool/windows/socket_tool.dart';
 import 'package:web_synchronization_tool/windows/synchronization_web_tool.dart';
 import 'package:web_synchronization_tool/windows/windowsJs.dart';
 import 'package:webview_windows/webview_windows.dart';
@@ -115,8 +116,12 @@ class ShowWebWidget extends StatefulWidget {
 
 class _ShowWebWidgetState extends State<ShowWebWidget> {
 
-   TextEditingController textController = TextEditingController();
+   /// 网址
+   TextEditingController urlController = TextEditingController();
+   /// 总金额
    TextEditingController numController = TextEditingController();
+   /// 服务器ip
+   TextEditingController ipController = TextEditingController();
 
   @override
   void dispose() {
@@ -152,29 +157,7 @@ class _ShowWebWidgetState extends State<ShowWebWidget> {
               widget.controller.openDevTools();
             },
             child: const Text('开发者')),
-        Row(
-          children: [
-            SizedBox(width: 100, child: TextField(style: const TextStyle(fontSize: 14),controller: numController,)),
-            TextButton(
-                onPressed: () {
-                  try{
-                    int num = int.parse(numController.text);
-                    if (num <= 10){
-                      numController.text = '金额不能小于10';
-                      return;
-                    }
-
-                    List<int> nums = NumberTool().randomNum(num,num: SynchronizationWebTool.getInstance().childController.length);
-                    widget.controller.executeScript(WindowsJs.inputJs(nums.first));
-                    nums.removeAt(0);
-                    SynchronizationWebTool.getInstance().input(nums);
-                  }catch(e){
-                    numController.text = '请输入数字';
-                  }
-                },
-                child: const Text('填入总金额')),
-          ],
-        ),
+        inputNumber(),
         Row(
           children: [
             const Text('同步'),
@@ -183,21 +166,26 @@ class _ShowWebWidgetState extends State<ShowWebWidget> {
                 onChanged: (value) {
                   setState(() {
                     SynchronizationWebTool.getInstance().webSync = value;
+                    if (value){ // 打开同步获取 从机
+                      SocketUtils.getInstance().sendGetChilds();
+                    }
                   });
                 })
           ],
         ),
-        input()
+        input(),
+        ipSet()
       ],
     );
   }
 
+  /// 跳转网址
   input(){
     return Row(
       children: [
-        SizedBox(width: 400, child: TextField(style: const TextStyle(fontSize: 14),controller: textController,)),
+        SizedBox(width: 400, child: TextField(style: const TextStyle(fontSize: 14),controller: urlController,)),
         TextButton(onPressed: (){
-          String url = textController.text;
+          String url = urlController.text;
           // if (!url.startsWith("https://") ) {
           //   url = "https://$url";
           // }
@@ -207,6 +195,53 @@ class _ShowWebWidgetState extends State<ShowWebWidget> {
     );
   }
 
+  ipSet(){
+    ipController.text = SocketUtils.getInstance().url;
+    return Row(
+      children: [
+        SizedBox(width: 100, child: TextField(style: const TextStyle(fontSize: 14),controller: ipController,)),
+        TextButton(onPressed: (){
+          SocketUtils.getInstance().url = ipController.text;
+          SocketUtils.getInstance().connect();
+        }, child: const Text('保存服务器ip',style: TextStyle(fontSize: 14),))
+      ],
+    );
+  }
+
+  /// 输入总金额
+  inputNumber(){
+    return Row(
+      children: [
+        SizedBox(width: 100, child: TextField(style: const TextStyle(fontSize: 14),controller: numController,)),
+        TextButton(
+            onPressed: () {
+              try{
+                int num = int.parse(numController.text);
+
+                int chidNum = SocketUtils.getInstance().childrenIp.length + 1;
+
+                if (num <= chidNum * 10){
+                  numController.text = '金额不能小于${chidNum*10}';
+                  return;
+                }
+
+                int maxNum = num ~/ chidNum;
+                SocketUtils.getInstance().sendInpuMessage(maxNum);
+
+                // 本地处理
+                List<int> nums = NumberTool().randomNum(maxNum);
+                widget.controller.executeScript(WindowsJs.inputJs(nums.first));
+                nums.removeAt(0);
+                SynchronizationWebTool.getInstance().input(nums);
+              }catch(e){
+                numController.text = '请输入数字';
+              }
+            },
+            child: const Text('填入总金额')),
+      ],
+    );
+  }
+
 
 }
 

lib/windows/windowsJs.dart

@@ -75,7 +75,7 @@ document.addEventListener("click", function (event) {
   }
 
   /// 模拟点击
-  static String clickJs(double x, double y) {
+  static String clickJs(int x, int y) {
     return 'document.elementFromPoint($x, $y).click();';
   }
 

lib/windows/windows_main_page.dart

@@ -24,6 +24,9 @@ class _WindowsPageState extends State<WindowsPage> {
   void initState() {
     super.initState();
 
+    SocketUtils.getInstance().connect();
+    SocketUtils.getInstance().heartbeat();
+    
     controllerInit();
   }
 
@@ -42,8 +45,6 @@ class _WindowsPageState extends State<WindowsPage> {
   @override
   Widget build(BuildContext context) {
 
-    SocketUtils.getInstance().connect();
-
     if (initDone == false) return Container();
 
     return Scaffold(