woniu
/
web_synchronization_tool
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: woniu:8e8bf0d53cef571a37da8d964ebf5dee01732f37
Branches Tags
woniu:master
woniu:Dev
woniu:主控
woniu:受控
..
compare: woniu:625579e51098e574534226a68dc8bcab97a61085
Branches Tags
woniu:Dev
woniu:master
woniu:主控
woniu:受控

No commits in common. "8e8bf0d53cef571a37da8d964ebf5dee01732f37" and "625579e51098e574534226a68dc8bcab97a61085" have entirely different histories.
8e8bf0d53c ... 625579e510

7 changed files with 56 additions and 213 deletions
Show Stats Expand all files Collapse all files

15
lib/windows/code.dart
View File

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

38
lib/windows/number_tool.dart
View File

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

112
lib/windows/socket_tool.dart
View File

@ -2,11 +2,8 @@ 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{
// 私有构造函数
@ -24,114 +21,39 @@ class SocketUtils extends Socket{
class Socket {
String url = '127.0.0.1';
static 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(InternetAddress.anyIPv4, 0);
// 发送身份包
Map data = {
"op": 0,
"IC": ic
};
socket?.send(dataMake(data), InternetAddress(url), port);
socket = await RawDatagramSocket.bind('127.0.0.2', 1);
print('UDP Socket bound to ${socket?.address.address}:${socket?.port}');
// 监听来自网络的数据包
socket?.listen((RawSocketEvent e) {
Datagram? d = socket?.receive();
if (d == null) return;
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;
}
// String message = String.fromCharCodes(d.data).trim();
// print('Datagram from ${d.address.address}:${d.port}: $message');
});
heartbeat();
}
/// 发送消息
sendClickMessage(Map data){
Map messageMap = {
"op": 2,
"click": data
};
socket?.send(dataMake(messageMap), InternetAddress(url), port);
sendMessage(Map data){
socket?.send(dataMake(data), 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), () async {
if (socket == null){
// 重连
await connect();
}
Timer timer = Timer(const Duration(seconds: 10), () {
Map data = {
"op": 1,
"IC": ic
"IC": 0
};
socket?.send(dataMake(data), InternetAddress(url), port);
@ -152,18 +74,4 @@ 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;
}
}

8
lib/windows/synchronization_web_tool.dart
View File

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

89
lib/windows/web_grid_view.dart
View File

@ -1,6 +1,5 @@
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';
@ -116,12 +115,8 @@ class ShowWebWidget extends StatefulWidget {
class _ShowWebWidgetState extends State<ShowWebWidget> {
/// 网址
TextEditingController urlController = TextEditingController();
/// 总金额
TextEditingController textController = TextEditingController();
TextEditingController numController = TextEditingController();
/// 服务器ip
TextEditingController ipController = TextEditingController();
@override
void dispose() {
@ -157,7 +152,29 @@ class _ShowWebWidgetState extends State<ShowWebWidget> {
widget.controller.openDevTools();
},
child: const Text('开发者')),
inputNumber(),
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('填入总金额')),
],
),
Row(
children: [
const Text('同步'),
@ -166,26 +183,21 @@ class _ShowWebWidgetState extends State<ShowWebWidget> {
onChanged: (value) {
setState(() {
SynchronizationWebTool.getInstance().webSync = value;
if (value){ // 打开同步获取 从机
SocketUtils.getInstance().sendGetChilds();
}
});
})
],
),
input(),
ipSet()
input()
],
);
}
/// 跳转网址
input(){
return Row(
children: [
SizedBox(width: 400, child: TextField(style: const TextStyle(fontSize: 14),controller: urlController,)),
SizedBox(width: 400, child: TextField(style: const TextStyle(fontSize: 14),controller: textController,)),
TextButton(onPressed: (){
String url = urlController.text;
String url = textController.text;
// if (!url.startsWith("https://") ) {
// url = "https://$url";
// }
@ -195,53 +207,6 @@ 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('填入总金额')),
],
);
}
}

2
lib/windows/windowsJs.dart
View File

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

5
lib/windows/windows_main_page.dart
View File

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