Compare commits
No commits in common. "2d65ab71f5928f5641797f16938b6d36c671faaa" and "ebd11fd36f2a3683c4baa6d407963c70db22196e" have entirely different histories.
2d65ab71f5
...
ebd11fd36f
@ -1,6 +0,0 @@
|
|||||||
IP地址,MAC地址,版本号,通道1名称,通道1绑定设备,通道2名称,通道2绑定设备
|
|
||||||
192.168.0.161,50-29-4D-20-12-01,1.1,通道1名称,通道1绑定设备,通道2名称,通道2绑定设备
|
|
||||||
192.168.0.177,50-29-4D-20-12-02,2.1,通道2名称,通道2绑定设备,通道3名称,通道3绑定设备
|
|
||||||
192.168.0.174,50-29-4D-20-12-03,3.1,通道3名称,通道3绑定设备,通道4名称,通道4绑定设备
|
|
||||||
192.168.0.185,50-29-4D-20-12-04,4.1,通道4名称,通道4绑定设备,通道5名称,通道5绑定设备
|
|
||||||
192.168.0.168,50-29-4D-20-12-05,5.1,通道5名称,通道5绑定设备,通道6名称,通道6绑定设备
|
|
|
101
all_info2.csv
101
all_info2.csv
@ -1,101 +0,0 @@
|
|||||||
IP地址,MAC地址,版本号,通道1名称,通道1绑定设备,通道2名称,通道2绑定设备
|
|
||||||
192.168.0.161,50-29-4D-20-12-01,1.1,通道1名称,通道1绑定设备,通道2名称,通道2绑定设备
|
|
||||||
192.168.0.177,50-29-4D-20-12-02,2.1,通道2名称,通道2绑定设备,通道3名称,通道3绑定设备
|
|
||||||
192.168.0.174,50-29-4D-20-12-03,3.1,通道3名称,通道3绑定设备,通道4名称,通道4绑定设备
|
|
||||||
192.168.0.185,50-29-4D-20-12-04,4.1,通道4名称,通道4绑定设备,通道5名称,通道5绑定设备
|
|
||||||
192.168.0.168,50-29-4D-20-12-05,5.1,通道5名称,通道5绑定设备,通道6名称,通道6绑定设备
|
|
||||||
192.168.0.161,50-29-4D-20-12-01,1.1,通道1名称,通道1绑定设备,通道2名称,通道2绑定设备
|
|
||||||
192.168.0.177,50-29-4D-20-12-02,2.1,通道2名称,通道2绑定设备,通道3名称,通道3绑定设备
|
|
||||||
192.168.0.174,50-29-4D-20-12-03,3.1,通道3名称,通道3绑定设备,通道4名称,通道4绑定设备
|
|
||||||
192.168.0.185,50-29-4D-20-12-04,4.1,通道4名称,通道4绑定设备,通道5名称,通道5绑定设备
|
|
||||||
192.168.0.168,50-29-4D-20-12-05,5.1,通道5名称,通道5绑定设备,通道6名称,通道6绑定设备
|
|
||||||
192.168.0.161,50-29-4D-20-12-01,1.1,通道1名称,通道1绑定设备,通道2名称,通道2绑定设备
|
|
||||||
192.168.0.177,50-29-4D-20-12-02,2.1,通道2名称,通道2绑定设备,通道3名称,通道3绑定设备
|
|
||||||
192.168.0.174,50-29-4D-20-12-03,3.1,通道3名称,通道3绑定设备,通道4名称,通道4绑定设备
|
|
||||||
192.168.0.185,50-29-4D-20-12-04,4.1,通道4名称,通道4绑定设备,通道5名称,通道5绑定设备
|
|
||||||
192.168.0.168,50-29-4D-20-12-05,5.1,通道5名称,通道5绑定设备,通道6名称,通道6绑定设备
|
|
||||||
192.168.0.161,50-29-4D-20-12-01,1.1,通道1名称,通道1绑定设备,通道2名称,通道2绑定设备
|
|
||||||
192.168.0.177,50-29-4D-20-12-02,2.1,通道2名称,通道2绑定设备,通道3名称,通道3绑定设备
|
|
||||||
192.168.0.174,50-29-4D-20-12-03,3.1,通道3名称,通道3绑定设备,通道4名称,通道4绑定设备
|
|
||||||
192.168.0.185,50-29-4D-20-12-04,4.1,通道4名称,通道4绑定设备,通道5名称,通道5绑定设备
|
|
||||||
192.168.0.168,50-29-4D-20-12-05,5.20,通道5名称,通道5绑定设备,通道6名称,通道6绑定设备
|
|
||||||
192.168.0.161,50-29-4D-20-12-01,1.1,通道1名称,通道1绑定设备,通道2名称,通道2绑定设备
|
|
||||||
192.168.0.177,50-29-4D-20-12-02,2.1,通道2名称,通道2绑定设备,通道3名称,通道3绑定设备
|
|
||||||
192.168.0.174,50-29-4D-20-12-03,3.1,通道3名称,通道3绑定设备,通道4名称,通道4绑定设备
|
|
||||||
192.168.0.185,50-29-4D-20-12-04,4.1,通道4名称,通道4绑定设备,通道5名称,通道5绑定设备
|
|
||||||
192.168.0.168,50-29-4D-20-12-05,5.1,通道5名称,通道5绑定设备,通道6名称,通道6绑定设备
|
|
||||||
192.168.0.161,50-29-4D-20-12-01,1.1,通道1名称,通道1绑定设备,通道2名称,通道2绑定设备
|
|
||||||
192.168.0.177,50-29-4D-20-12-02,2.1,通道2名称,通道2绑定设备,通道3名称,通道3绑定设备
|
|
||||||
192.168.0.174,50-29-4D-20-12-03,3.1,通道3名称,通道3绑定设备,通道4名称,通道4绑定设备
|
|
||||||
192.168.0.185,50-29-4D-20-12-04,4.1,通道4名称,通道4绑定设备,通道5名称,通道5绑定设备
|
|
||||||
192.168.0.168,50-29-4D-20-12-05,5.1,通道5名称,通道5绑定设备,通道6名称,通道6绑定设备
|
|
||||||
192.168.0.161,50-29-4D-20-12-01,1.1,通道1名称,通道1绑定设备,通道2名称,通道2绑定设备
|
|
||||||
192.168.0.177,50-29-4D-20-12-02,2.1,通道2名称,通道2绑定设备,通道3名称,通道3绑定设备
|
|
||||||
192.168.0.174,50-29-4D-20-12-03,3.1,通道3名称,通道3绑定设备,通道4名称,通道4绑定设备
|
|
||||||
192.168.0.185,50-29-4D-20-12-04,4.1,通道4名称,通道4绑定设备,通道5名称,通道5绑定设备
|
|
||||||
192.168.0.168,50-29-4D-20-12-05,5.1,通道5名称,通道5绑定设备,通道6名称,通道6绑定设备
|
|
||||||
192.168.0.161,50-29-4D-20-12-01,1.1,通道1名称,通道1绑定设备,通道2名称,通道2绑定设备
|
|
||||||
192.168.0.177,50-29-4D-20-12-02,2.1,通道2名称,通道2绑定设备,通道3名称,通道3绑定设备
|
|
||||||
192.168.0.174,50-29-4D-20-12-03,3.1,通道3名称,通道3绑定设备,通道4名称,通道4绑定设备
|
|
||||||
192.168.0.185,50-29-4D-20-12-04,4.1,通道4名称,通道4绑定设备,通道5名称,通道5绑定设备
|
|
||||||
192.168.0.168,50-29-4D-20-12-05,5.41,通道5名称,通道5绑定设备,通道6名称,通道6绑定设备
|
|
||||||
192.168.0.161,50-29-4D-20-12-01,1.1,通道1名称,通道1绑定设备,通道2名称,通道2绑定设备
|
|
||||||
192.168.0.177,50-29-4D-20-12-02,2.1,通道2名称,通道2绑定设备,通道3名称,通道3绑定设备
|
|
||||||
192.168.0.174,50-29-4D-20-12-03,3.1,通道3名称,通道3绑定设备,通道4名称,通道4绑定设备
|
|
||||||
192.168.0.185,50-29-4D-20-12-04,4.1,通道4名称,通道4绑定设备,通道5名称,通道5绑定设备
|
|
||||||
192.168.0.168,50-29-4D-20-12-05,5.1,通道5名称,通道5绑定设备,通道6名称,通道6绑定设备
|
|
||||||
192.168.0.161,50-29-4D-20-12-01,1.1,通道1名称,通道1绑定设备,通道2名称,通道2绑定设备
|
|
||||||
192.168.0.177,50-29-4D-20-12-02,2.1,通道2名称,通道2绑定设备,通道3名称,通道3绑定设备
|
|
||||||
192.168.0.174,50-29-4D-20-12-03,3.1,通道3名称,通道3绑定设备,通道4名称,通道4绑定设备
|
|
||||||
192.168.0.185,50-29-4D-20-12-04,4.1,通道4名称,通道4绑定设备,通道5名称,通道5绑定设备
|
|
||||||
192.168.0.168,50-29-4D-20-12-05,5.1,通道5名称,通道5绑定设备,通道6名称,通道6绑定设备
|
|
||||||
192.168.0.161,50-29-4D-20-12-01,1.1,通道1名称,通道1绑定设备,通道2名称,通道2绑定设备
|
|
||||||
192.168.0.177,50-29-4D-20-12-02,2.1,通道2名称,通道2绑定设备,通道3名称,通道3绑定设备
|
|
||||||
192.168.0.174,50-29-4D-20-12-03,3.1,通道3名称,通道3绑定设备,通道4名称,通道4绑定设备
|
|
||||||
192.168.0.185,50-29-4D-20-12-04,4.1,通道4名称,通道4绑定设备,通道5名称,通道5绑定设备
|
|
||||||
192.168.0.168,50-29-4D-20-12-05,5.1,通道5名称,通道5绑定设备,通道6名称,通道6绑定设备
|
|
||||||
192.168.0.161,50-29-4D-20-12-01,1.1,通道1名称,通道1绑定设备,通道2名称,通道2绑定设备
|
|
||||||
192.168.0.177,50-29-4D-20-12-02,2.1,通道2名称,通道2绑定设备,通道3名称,通道3绑定设备
|
|
||||||
192.168.0.174,50-29-4D-20-12-03,3.1,通道3名称,通道3绑定设备,通道4名称,通道4绑定设备
|
|
||||||
192.168.0.185,50-29-4D-20-12-04,4.1,通道4名称,通道4绑定设备,通道5名称,通道5绑定设备
|
|
||||||
192.168.0.168,50-29-4D-20-12-05,5.61,通道5名称,通道5绑定设备,通道6名称,通道6绑定设备
|
|
||||||
192.168.0.161,50-29-4D-20-12-01,1.1,通道1名称,通道1绑定设备,通道2名称,通道2绑定设备
|
|
||||||
192.168.0.177,50-29-4D-20-12-02,2.1,通道2名称,通道2绑定设备,通道3名称,通道3绑定设备
|
|
||||||
192.168.0.174,50-29-4D-20-12-03,3.1,通道3名称,通道3绑定设备,通道4名称,通道4绑定设备
|
|
||||||
192.168.0.185,50-29-4D-20-12-04,4.1,通道4名称,通道4绑定设备,通道5名称,通道5绑定设备
|
|
||||||
192.168.0.168,50-29-4D-20-12-05,5.1,通道5名称,通道5绑定设备,通道6名称,通道6绑定设备
|
|
||||||
192.168.0.161,50-29-4D-20-12-01,1.1,通道1名称,通道1绑定设备,通道2名称,通道2绑定设备
|
|
||||||
192.168.0.177,50-29-4D-20-12-02,2.1,通道2名称,通道2绑定设备,通道3名称,通道3绑定设备
|
|
||||||
192.168.0.174,50-29-4D-20-12-03,3.1,通道3名称,通道3绑定设备,通道4名称,通道4绑定设备
|
|
||||||
192.168.0.185,50-29-4D-20-12-04,4.1,通道4名称,通道4绑定设备,通道5名称,通道5绑定设备
|
|
||||||
192.168.0.168,50-29-4D-20-12-05,5.1,通道5名称,通道5绑定设备,通道6名称,通道6绑定设备
|
|
||||||
192.168.0.161,50-29-4D-20-12-01,1.1,通道1名称,通道1绑定设备,通道2名称,通道2绑定设备
|
|
||||||
192.168.0.177,50-29-4D-20-12-02,2.1,通道2名称,通道2绑定设备,通道3名称,通道3绑定设备
|
|
||||||
192.168.0.174,50-29-4D-20-12-03,3.1,通道3名称,通道3绑定设备,通道4名称,通道4绑定设备
|
|
||||||
192.168.0.185,50-29-4D-20-12-04,4.1,通道4名称,通道4绑定设备,通道5名称,通道5绑定设备
|
|
||||||
192.168.0.168,50-29-4D-20-12-05,5.1,通道5名称,通道5绑定设备,通道6名称,通道6绑定设备
|
|
||||||
192.168.0.161,50-29-4D-20-12-01,1.1,通道1名称,通道1绑定设备,通道2名称,通道2绑定设备
|
|
||||||
192.168.0.177,50-29-4D-20-12-02,2.1,通道2名称,通道2绑定设备,通道3名称,通道3绑定设备
|
|
||||||
192.168.0.174,50-29-4D-20-12-03,3.1,通道3名称,通道3绑定设备,通道4名称,通道4绑定设备
|
|
||||||
192.168.0.185,50-29-4D-20-12-04,4.1,通道4名称,通道4绑定设备,通道5名称,通道5绑定设备
|
|
||||||
192.168.0.168,50-29-4D-20-12-05,5.81,通道5名称,通道5绑定设备,通道6名称,通道6绑定设备
|
|
||||||
192.168.0.161,50-29-4D-20-12-01,1.1,通道1名称,通道1绑定设备,通道2名称,通道2绑定设备
|
|
||||||
192.168.0.177,50-29-4D-20-12-02,2.1,通道2名称,通道2绑定设备,通道3名称,通道3绑定设备
|
|
||||||
192.168.0.174,50-29-4D-20-12-03,3.1,通道3名称,通道3绑定设备,通道4名称,通道4绑定设备
|
|
||||||
192.168.0.185,50-29-4D-20-12-04,4.1,通道4名称,通道4绑定设备,通道5名称,通道5绑定设备
|
|
||||||
192.168.0.168,50-29-4D-20-12-05,5.1,通道5名称,通道5绑定设备,通道6名称,通道6绑定设备
|
|
||||||
192.168.0.161,50-29-4D-20-12-01,1.1,通道1名称,通道1绑定设备,通道2名称,通道2绑定设备
|
|
||||||
192.168.0.177,50-29-4D-20-12-02,2.1,通道2名称,通道2绑定设备,通道3名称,通道3绑定设备
|
|
||||||
192.168.0.174,50-29-4D-20-12-03,3.1,通道3名称,通道3绑定设备,通道4名称,通道4绑定设备
|
|
||||||
192.168.0.185,50-29-4D-20-12-04,4.1,通道4名称,通道4绑定设备,通道5名称,通道5绑定设备
|
|
||||||
192.168.0.168,50-29-4D-20-12-05,5.1,通道5名称,通道5绑定设备,通道6名称,通道6绑定设备
|
|
||||||
192.168.0.161,50-29-4D-20-12-01,1.1,通道1名称,通道1绑定设备,通道2名称,通道2绑定设备
|
|
||||||
192.168.0.177,50-29-4D-20-12-02,2.1,通道2名称,通道2绑定设备,通道3名称,通道3绑定设备
|
|
||||||
192.168.0.174,50-29-4D-20-12-03,3.1,通道3名称,通道3绑定设备,通道4名称,通道4绑定设备
|
|
||||||
192.168.0.185,50-29-4D-20-12-04,4.1,通道4名称,通道4绑定设备,通道5名称,通道5绑定设备
|
|
||||||
192.168.0.168,50-29-4D-20-12-05,5.1,通道5名称,通道5绑定设备,通道6名称,通道6绑定设备
|
|
||||||
192.168.0.161,50-29-4D-20-12-01,1.1,通道1名称,通道1绑定设备,通道2名称,通道2绑定设备
|
|
||||||
192.168.0.177,50-29-4D-20-12-02,2.1,通道2名称,通道2绑定设备,通道3名称,通道3绑定设备
|
|
||||||
192.168.0.174,50-29-4D-20-12-03,3.1,通道3名称,通道3绑定设备,通道4名称,通道4绑定设备
|
|
||||||
192.168.0.185,50-29-4D-20-12-04,4.1,通道4名称,通道4绑定设备,通道5名称,通道5绑定设备
|
|
||||||
192.168.0.168,50-29-4D-20-12-05,5.101,通道5名称,通道5绑定设备,通道6名称,通道6绑定设备
|
|
|
357
batch_dialog.py
357
batch_dialog.py
@ -1,357 +0,0 @@
|
|||||||
import os
|
|
||||||
import sys
|
|
||||||
import csv
|
|
||||||
import socket, struct
|
|
||||||
import time
|
|
||||||
|
|
||||||
from PyQt5.QtWidgets import QApplication, QDialog, QVBoxLayout, QHBoxLayout, QTableWidget, QTableWidgetItem, \
|
|
||||||
QPushButton, QCheckBox, QFileDialog, QMessageBox
|
|
||||||
from PyQt5.QtCore import Qt
|
|
||||||
|
|
||||||
|
|
||||||
class BatchOperationDialog(QDialog):
|
|
||||||
def __init__(self):
|
|
||||||
super().__init__()
|
|
||||||
self.setWindowTitle("批量操作节点")
|
|
||||||
self.setGeometry(100, 100, 1093, 737)
|
|
||||||
|
|
||||||
# 初始化分页
|
|
||||||
self.current_page = 0
|
|
||||||
self.rows_per_page = 20
|
|
||||||
|
|
||||||
# 初始化数据
|
|
||||||
self.data = []
|
|
||||||
|
|
||||||
# 初始化UI
|
|
||||||
self.init_ui()
|
|
||||||
|
|
||||||
def init_ui(self):
|
|
||||||
# 主布局
|
|
||||||
main_layout = QVBoxLayout()
|
|
||||||
|
|
||||||
# 创建表格(8列,初始行数可以设置为20)
|
|
||||||
self.table_widget = QTableWidget(self.rows_per_page, 8) # 默认显示20行
|
|
||||||
self.table_widget.setHorizontalHeaderLabels(
|
|
||||||
["选择", "IP地址", "MAC地址", "版本号", "通道1名称", "通道1绑定设备", "通道2名称", "通道2绑定设备"]
|
|
||||||
)
|
|
||||||
|
|
||||||
# 使通道列可编辑
|
|
||||||
for row in range(self.table_widget.rowCount()):
|
|
||||||
self.table_widget.setItem(row, 4, QTableWidgetItem()) # 通道1名称
|
|
||||||
self.table_widget.setItem(row, 5, QTableWidgetItem()) # 通道1绑定设备
|
|
||||||
self.table_widget.setItem(row, 6, QTableWidgetItem()) # 通道2名称
|
|
||||||
self.table_widget.setItem(row, 7, QTableWidgetItem()) # 通道2绑定设备
|
|
||||||
|
|
||||||
# 添加勾选框到第1列
|
|
||||||
for row in range(self.table_widget.rowCount()):
|
|
||||||
check_box_item = QTableWidgetItem()
|
|
||||||
check_box_item.setCheckState(0) # 初始状态为未选中
|
|
||||||
self.table_widget.setItem(row, 0, check_box_item)
|
|
||||||
|
|
||||||
# 按钮布局
|
|
||||||
button_layout = QHBoxLayout()
|
|
||||||
|
|
||||||
# 创建按钮
|
|
||||||
self.select_all_button = QPushButton("全选")
|
|
||||||
self.select_none_button = QPushButton("全不选")
|
|
||||||
self.get_version_button = QPushButton("获取版本")
|
|
||||||
self.get_mac_button = QPushButton("获取MAC")
|
|
||||||
self.upgrade_button = QPushButton("升级节点")
|
|
||||||
self.load_ips_button = QPushButton("加载IP列表")
|
|
||||||
self.load_all_button = QPushButton("加载完整信息列表")
|
|
||||||
self.save_button = QPushButton("保存表数据")
|
|
||||||
self.prev_page_button = QPushButton("上一页")
|
|
||||||
self.next_page_button = QPushButton("下一页")
|
|
||||||
|
|
||||||
# 按钮连接
|
|
||||||
self.select_all_button.clicked.connect(self.select_all)
|
|
||||||
self.select_none_button.clicked.connect(self.select_none)
|
|
||||||
self.get_version_button.clicked.connect(self.get_version)
|
|
||||||
self.get_mac_button.clicked.connect(self.get_mac)
|
|
||||||
self.upgrade_button.clicked.connect(self.upgrade_node)
|
|
||||||
self.save_button.clicked.connect(self.save_data)
|
|
||||||
self.load_ips_button.clicked.connect(self.load_ips)
|
|
||||||
self.load_all_button.clicked.connect(self.load_all_info)
|
|
||||||
self.prev_page_button.clicked.connect(self.prev_page)
|
|
||||||
self.next_page_button.clicked.connect(self.next_page)
|
|
||||||
|
|
||||||
# 将按钮加入布局
|
|
||||||
button_layout.addWidget(self.select_all_button)
|
|
||||||
button_layout.addWidget(self.select_none_button)
|
|
||||||
button_layout.addWidget(self.get_version_button)
|
|
||||||
button_layout.addWidget(self.get_mac_button)
|
|
||||||
button_layout.addWidget(self.upgrade_button)
|
|
||||||
button_layout.addWidget(self.load_ips_button)
|
|
||||||
button_layout.addWidget(self.load_all_button)
|
|
||||||
button_layout.addWidget(self.save_button)
|
|
||||||
button_layout.addWidget(self.prev_page_button)
|
|
||||||
button_layout.addWidget(self.next_page_button)
|
|
||||||
|
|
||||||
# 将表格和按钮布局添加到主布局
|
|
||||||
main_layout.addWidget(self.table_widget)
|
|
||||||
main_layout.addLayout(button_layout)
|
|
||||||
|
|
||||||
# 设置对话框的布局
|
|
||||||
self.setLayout(main_layout)
|
|
||||||
|
|
||||||
# 允许最大化
|
|
||||||
# self.setWindowState(Qt.WindowMaximized)
|
|
||||||
|
|
||||||
def select_all(self):
|
|
||||||
for row in range(self.table_widget.rowCount()):
|
|
||||||
item = self.table_widget.item(row, 0)
|
|
||||||
item.setCheckState(2) # 选中
|
|
||||||
|
|
||||||
def select_none(self):
|
|
||||||
for row in range(self.table_widget.rowCount()):
|
|
||||||
item = self.table_widget.item(row, 0)
|
|
||||||
item.setCheckState(0) # 未选中
|
|
||||||
|
|
||||||
def get_version(self):
|
|
||||||
# 遍历表格的第1列,获取选中的行的IP地址
|
|
||||||
for row in range(self.table_widget.rowCount()):
|
|
||||||
item = self.table_widget.item(row, 0)
|
|
||||||
if item.checkState() == Qt.Checked: # 如果该行被选中
|
|
||||||
ip = self.table_widget.item(row, 1).text() # 获取IP地址
|
|
||||||
if ip:
|
|
||||||
try:
|
|
||||||
# 创建TCP连接到IP地址的12345端口
|
|
||||||
with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
|
|
||||||
s.settimeout(5) # 设置连接超时时间为5秒
|
|
||||||
s.connect((ip, 12345))
|
|
||||||
|
|
||||||
# 发送消息
|
|
||||||
message = bytes([0xAA, 0x55, 0xAA, 0x0F, 0x01, 0x00])
|
|
||||||
s.sendall(message)
|
|
||||||
|
|
||||||
# 接收返回的数据(假设返回数据至少有8个字节)
|
|
||||||
response = s.recv(1024)
|
|
||||||
if len(response) >= 8:
|
|
||||||
# 解析第7、8字节作为版本号
|
|
||||||
version = f"{response[6]}-{response[7]}"
|
|
||||||
# 将版本号写入到第4列(版本号列)
|
|
||||||
self.table_widget.setItem(row, 3, QTableWidgetItem(version))
|
|
||||||
else:
|
|
||||||
print(f"接收到的数据长度不足:{len(response)},无法提取版本号")
|
|
||||||
except Exception as e:
|
|
||||||
print(f"与IP {ip} 连接失败: {e}")
|
|
||||||
self.table_widget.setItem(row, 3, QTableWidgetItem("连接失败"))
|
|
||||||
|
|
||||||
def get_mac(self):
|
|
||||||
for row in range(self.table_widget.rowCount()):
|
|
||||||
item = self.table_widget.item(row, 0)
|
|
||||||
if item.checkState() == Qt.Checked: # 如果该行被选中
|
|
||||||
ip = self.table_widget.item(row, 1).text() # 获取IP地址
|
|
||||||
if ip:
|
|
||||||
try:
|
|
||||||
# 创建TCP连接到IP地址的12345端口
|
|
||||||
with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
|
|
||||||
s.settimeout(5) # 设置连接超时时间为5秒
|
|
||||||
s.connect((ip, 12345))
|
|
||||||
|
|
||||||
# 发送消息
|
|
||||||
message = bytes([0xAA, 0x55, 0xAA, 0x12, 0x01, 0x00])
|
|
||||||
s.sendall(message)
|
|
||||||
|
|
||||||
# 接收返回的数据(假设返回数据至少有8个字节)
|
|
||||||
response = s.recv(1024)
|
|
||||||
if len(response) >= 8:
|
|
||||||
# 解析第7、8字节作为mac后2字节
|
|
||||||
mac = f"50-29-4D-20-{response[6]}-{response[7]}"
|
|
||||||
# 将版本号写入到第3列(MAC列)
|
|
||||||
self.table_widget.setItem(row, 2, QTableWidgetItem(mac))
|
|
||||||
else:
|
|
||||||
print(f"接收到的数据长度不足:{len(response)},无法提取版本号")
|
|
||||||
except Exception as e:
|
|
||||||
print(f"与IP {ip} 连接失败: {e}")
|
|
||||||
self.table_widget.setItem(row, 3, QTableWidgetItem("连接失败"))
|
|
||||||
|
|
||||||
def calculate_crc(self, data: bytes) -> int:
|
|
||||||
"""计算数据的累加和CRC"""
|
|
||||||
crc = 0
|
|
||||||
for byte in data:
|
|
||||||
crc += byte
|
|
||||||
return crc & 0xFF # 只保留最低字节
|
|
||||||
|
|
||||||
def upgrade_node(self):
|
|
||||||
"""打开文件选择对话框"""
|
|
||||||
file_path, _ = QFileDialog.getOpenFileName(
|
|
||||||
self, "选择升级文件", "", "二进制文件 (*.bin);;所有文件 (*)"
|
|
||||||
)
|
|
||||||
|
|
||||||
if file_path:
|
|
||||||
file_name = os.path.basename(file_path)
|
|
||||||
# self.status_bar.showMessage(f"已选择: {file_name}")
|
|
||||||
|
|
||||||
try:
|
|
||||||
print("Starting upgrade process...")
|
|
||||||
if not os.path.exists(file_path):
|
|
||||||
raise FileNotFoundError(f"Upgrade file {file_path} not found")
|
|
||||||
|
|
||||||
with open(file_path, "rb") as f:
|
|
||||||
package_data = f.read()
|
|
||||||
|
|
||||||
if not package_data:
|
|
||||||
raise ValueError("Upgrade file is empty")
|
|
||||||
|
|
||||||
print(f"Read upgrade package, size: {len(package_data)} bytes")
|
|
||||||
|
|
||||||
upgrade_len = len(package_data)
|
|
||||||
crc = self.calculate_crc(package_data)
|
|
||||||
upgrade_req = struct.pack("<IB", upgrade_len, crc) + package_data
|
|
||||||
|
|
||||||
header_magic = bytes([0xAA, 0x55, 0xAA])
|
|
||||||
cmd = 0x05
|
|
||||||
version = 1
|
|
||||||
result_code = 0
|
|
||||||
|
|
||||||
package_head = struct.pack("<3sBBB", header_magic, cmd, version, result_code)
|
|
||||||
full_packet = package_head + upgrade_req
|
|
||||||
|
|
||||||
print("Full packet prepared:")
|
|
||||||
print(f"Header magic: {package_head[:3].hex()}")
|
|
||||||
print(f"Command: {cmd}, Version: {version}")
|
|
||||||
print(f"Upgrade length: {upgrade_len}, CRC: {crc}")
|
|
||||||
print(f"Total packet size: {len(full_packet)} bytes")
|
|
||||||
|
|
||||||
# 分包处理:每包最大1500字节
|
|
||||||
max_packet_size = 1500
|
|
||||||
total_size = len(full_packet)
|
|
||||||
num_packets = (total_size // max_packet_size) + (1 if total_size % max_packet_size != 0 else 0)
|
|
||||||
|
|
||||||
print(f"Total packets: {num_packets}, each up to {max_packet_size} bytes")
|
|
||||||
|
|
||||||
for row in range(self.table_widget.rowCount()):
|
|
||||||
item = self.table_widget.item(row, 0)
|
|
||||||
if item.checkState() == Qt.Checked: # 如果该行被选中
|
|
||||||
ip = self.table_widget.item(row, 1).text() # 获取IP地址
|
|
||||||
if ip:
|
|
||||||
try:
|
|
||||||
# 创建TCP连接到IP地址的12345端口
|
|
||||||
with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
|
|
||||||
s.settimeout(5) # 设置连接超时时间为5秒
|
|
||||||
s.connect((ip, 12345))
|
|
||||||
|
|
||||||
for i in range(num_packets):
|
|
||||||
start_index = i * max_packet_size
|
|
||||||
end_index = min((i + 1) * max_packet_size, total_size)
|
|
||||||
packet_chunk = full_packet[start_index:end_index]
|
|
||||||
|
|
||||||
print(f"Sending packet {i + 1}/{num_packets}, size: {len(packet_chunk)} bytes")
|
|
||||||
s.sendall(packet_chunk)
|
|
||||||
print(f"Packet {i + 1} sent successfully")
|
|
||||||
time.sleep(0.03)
|
|
||||||
except Exception as e:
|
|
||||||
print(f"与IP {ip} 连接失败: {e}")
|
|
||||||
# self.table_widget.setItem(row, 3, QTableWidgetItem("连接失败"))
|
|
||||||
QMessageBox.information(self, "升级", "升级全部完成")
|
|
||||||
except Exception as e:
|
|
||||||
print(f"Upgrade failed: {str(e)}")
|
|
||||||
QMessageBox.critical(
|
|
||||||
self,
|
|
||||||
"升级",
|
|
||||||
"升级包上传失败"
|
|
||||||
)
|
|
||||||
|
|
||||||
def save_data(self):
|
|
||||||
# 打开文件保存对话框
|
|
||||||
options = QFileDialog.Options()
|
|
||||||
file_path, _ = QFileDialog.getSaveFileName(self, "保存表数据", "", "CSV Files (*.csv);;All Files (*)", options=options)
|
|
||||||
if file_path:
|
|
||||||
# 保存表格数据到CSV文件
|
|
||||||
with open(file_path, mode='w', newline='', encoding='utf-8') as file:
|
|
||||||
writer = csv.writer(file)
|
|
||||||
# 写入表头
|
|
||||||
headers = [self.table_widget.horizontalHeaderItem(i).text() for i in range(self.table_widget.columnCount())]
|
|
||||||
writer.writerow(headers[1:])
|
|
||||||
# 写入表格内容
|
|
||||||
for row in range(self.table_widget.rowCount()):
|
|
||||||
row_data = [self.table_widget.item(row, col).text() if self.table_widget.item(row, col) else ""
|
|
||||||
for col in
|
|
||||||
range(1, self.table_widget.columnCount())] # Start from col=1 to skip the first column
|
|
||||||
writer.writerow(row_data)
|
|
||||||
|
|
||||||
print(f"数据已保存到 {file_path}")
|
|
||||||
|
|
||||||
def load_ips(self):
|
|
||||||
# 打开文件选择对话框
|
|
||||||
options = QFileDialog.Options()
|
|
||||||
file_path, _ = QFileDialog.getOpenFileName(self, "选择IP地址文件", "", "Text Files (*.txt);;All Files (*)", options=options)
|
|
||||||
if file_path:
|
|
||||||
# 读取IP地址
|
|
||||||
with open(file_path, 'r') as file:
|
|
||||||
lines = file.readlines()
|
|
||||||
|
|
||||||
invalid_ips = []
|
|
||||||
for i, line in enumerate(lines):
|
|
||||||
ip = line.strip()
|
|
||||||
# 验证IP地址格式
|
|
||||||
if not self.validate_ip(ip):
|
|
||||||
invalid_ips.append(i + 1)
|
|
||||||
|
|
||||||
if invalid_ips:
|
|
||||||
# 如果有无效IP,弹出提示框
|
|
||||||
QMessageBox.warning(self, "错误", f"以下行的IP地址无效:{', '.join(map(str, invalid_ips))}")
|
|
||||||
else:
|
|
||||||
# 将IP地址加载到表格
|
|
||||||
self.table_widget.setRowCount(len(lines))
|
|
||||||
for i, line in enumerate(lines):
|
|
||||||
ip = line.strip()
|
|
||||||
if i < self.table_widget.rowCount():
|
|
||||||
self.table_widget.setItem(i, 1, QTableWidgetItem(ip)) # 设置IP地址列
|
|
||||||
print(f"加载了{len(lines)}个IP地址")
|
|
||||||
|
|
||||||
def validate_ip(self, ip):
|
|
||||||
# IP地址验证正则表达式
|
|
||||||
import re
|
|
||||||
pattern = r"^(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)$"
|
|
||||||
return bool(re.match(pattern, ip))
|
|
||||||
|
|
||||||
def load_all_info(self):
|
|
||||||
# 打开CSV文件选择对话框
|
|
||||||
options = QFileDialog.Options()
|
|
||||||
file_path, _ = QFileDialog.getOpenFileName(self, "选择CSV文件", "", "CSV Files (*.csv);;All Files (*)",
|
|
||||||
options=options)
|
|
||||||
if file_path:
|
|
||||||
# 读取CSV文件
|
|
||||||
with open(file_path, mode='r', encoding='utf-8') as file:
|
|
||||||
reader = csv.reader(file)
|
|
||||||
headers = next(reader) # 跳过表头
|
|
||||||
self.data = [row for row in reader]
|
|
||||||
if len(self.data) <= 20:
|
|
||||||
self.table_widget.setRowCount(len(self.data))
|
|
||||||
# 确保加载数据后更新分页
|
|
||||||
self.current_page = 0 # 每次加载新数据,默认回到第一页
|
|
||||||
self.update_table()
|
|
||||||
|
|
||||||
def update_table(self):
|
|
||||||
# 获取当前页的数据
|
|
||||||
start_row = self.current_page * self.rows_per_page
|
|
||||||
end_row = start_row + self.rows_per_page
|
|
||||||
rows_to_display = self.data[start_row:end_row]
|
|
||||||
|
|
||||||
# 更新表格内容
|
|
||||||
for row_num, row_data in enumerate(rows_to_display):
|
|
||||||
for col_num, cell_data in enumerate(row_data):
|
|
||||||
self.table_widget.setItem(row_num, col_num + 1, QTableWidgetItem(cell_data)) # +1跳过“选择”列
|
|
||||||
|
|
||||||
# 根据数据量调整上一页和下一页按钮的状态
|
|
||||||
self.prev_page_button.setEnabled(self.current_page > 0)
|
|
||||||
self.next_page_button.setEnabled((self.current_page + 1) * self.rows_per_page < len(self.data))
|
|
||||||
|
|
||||||
def prev_page(self):
|
|
||||||
if self.current_page > 0:
|
|
||||||
self.current_page -= 1
|
|
||||||
self.update_table()
|
|
||||||
|
|
||||||
def next_page(self):
|
|
||||||
if (self.current_page + 1) * self.rows_per_page < len(self.data):
|
|
||||||
self.current_page += 1
|
|
||||||
self.update_table()
|
|
||||||
|
|
||||||
|
|
||||||
if __name__ == "__main__":
|
|
||||||
app = QApplication(sys.argv)
|
|
||||||
dialog = BatchOperationDialog()
|
|
||||||
dialog.show()
|
|
||||||
sys.exit(app.exec_())
|
|
21
hell2.csv
21
hell2.csv
@ -1,21 +0,0 @@
|
|||||||
IP地址,MAC地址,版本号,通道1名称,通道1绑定设备,通道2名称,通道2绑定设备
|
|
||||||
192.168.0.161,50-29-4D-20-12-01,1.1,通道1名称,通道1绑定设备,通道2名称,通道2绑定设备
|
|
||||||
192.168.0.177,50-29-4D-20-12-02,2.1,通道2名称,通道2绑定设备,通道3名称,通道3绑定设备
|
|
||||||
192.168.0.174,50-29-4D-20-12-03,3.1,通道3名称,通道3绑定设备,通道4名称,通道4绑定设备
|
|
||||||
192.168.0.185,50-29-4D-20-12-04,4.1,通道4名称,通道4绑定设备,通道5名称,通道5绑定设备
|
|
||||||
192.168.0.168,50-29-4D-20-12-05,5.1,通道5名称,通道5绑定设备,通道6名称,通道6绑定设备
|
|
||||||
,,,,,,
|
|
||||||
,,,,,,
|
|
||||||
,,,,,,
|
|
||||||
,,,,,,
|
|
||||||
,,,,,,
|
|
||||||
,,,,,,
|
|
||||||
,,,,,,
|
|
||||||
,,,,,,
|
|
||||||
,,,,,,
|
|
||||||
,,,,,,
|
|
||||||
,,,,,,
|
|
||||||
,,,,,,
|
|
||||||
,,,,,,
|
|
||||||
,,,,,,
|
|
||||||
,,,,,,
|
|
|
21
hello.csv
21
hello.csv
@ -1,21 +0,0 @@
|
|||||||
选择,IP地址,MAC地址,版本号,通道1名称,通道1绑定设备,通道2名称,通道2绑定设备
|
|
||||||
,192.168.0.161,50-29-4D-20-12-01,1.1,通道1名称,通道1绑定设备,通道2名称,通道2绑定设备
|
|
||||||
,192.168.0.177,50-29-4D-20-12-02,2.1,通道2名称,通道2绑定设备,通道3名称,通道3绑定设备
|
|
||||||
,192.168.0.174,50-29-4D-20-12-03,3.1,通道3名称,通道3绑定设备,通道4名称,通道4绑定设备
|
|
||||||
,192.168.0.185,50-29-4D-20-12-04,4.1,通道4名称,通道4绑定设备,通道5名称,通道5绑定设备
|
|
||||||
,192.168.0.168,50-29-4D-20-12-05,5.1,通道5名称,通道5绑定设备,通道6名称,通道6绑定设备
|
|
||||||
,,,,,,,
|
|
||||||
,,,,,,,
|
|
||||||
,,,,,,,
|
|
||||||
,,,,,,,
|
|
||||||
,,,,,,,
|
|
||||||
,,,,,,,
|
|
||||||
,,,,,,,
|
|
||||||
,,,,,,,
|
|
||||||
,,,,,,,
|
|
||||||
,,,,,,,
|
|
||||||
,,,,,,,
|
|
||||||
,,,,,,,
|
|
||||||
,,,,,,,
|
|
||||||
,,,,,,,
|
|
||||||
,,,,,,,
|
|
|
5
ips.txt
5
ips.txt
@ -1,5 +0,0 @@
|
|||||||
192.168.0.161
|
|
||||||
192.168.0.177
|
|
||||||
192.168.0.174
|
|
||||||
192.168.0.185
|
|
||||||
192.168.0.168
|
|
@ -14,7 +14,6 @@ from scipy.fft import fft, fftfreq
|
|||||||
|
|
||||||
from SamplingDialog import *
|
from SamplingDialog import *
|
||||||
from feauture_calculate import *
|
from feauture_calculate import *
|
||||||
from batch_dialog import BatchOperationDialog
|
|
||||||
|
|
||||||
# 启用高DPI支持
|
# 启用高DPI支持
|
||||||
QApplication.setAttribute(Qt.AA_EnableHighDpiScaling)
|
QApplication.setAttribute(Qt.AA_EnableHighDpiScaling)
|
||||||
@ -177,7 +176,6 @@ class SocketClientApp(QMainWindow):
|
|||||||
self.get_mac_button = QPushButton("获取MAC地址")
|
self.get_mac_button = QPushButton("获取MAC地址")
|
||||||
self.mac_config_button = QPushButton("mac配置")
|
self.mac_config_button = QPushButton("mac配置")
|
||||||
self.ipv4_config_button = QPushButton("网络配置")
|
self.ipv4_config_button = QPushButton("网络配置")
|
||||||
self.batch_process_button = QPushButton("批量操作")
|
|
||||||
self.calibration_config_button = QPushButton("校准")
|
self.calibration_config_button = QPushButton("校准")
|
||||||
self.get_version_button = QPushButton("版本")
|
self.get_version_button = QPushButton("版本")
|
||||||
self.upgrade_button_sampling = QPushButton("采样率/时间")
|
self.upgrade_button_sampling = QPushButton("采样率/时间")
|
||||||
@ -237,7 +235,6 @@ class SocketClientApp(QMainWindow):
|
|||||||
button_layout.addWidget(self.get_mac_button)
|
button_layout.addWidget(self.get_mac_button)
|
||||||
button_layout.addWidget(self.mac_config_button)
|
button_layout.addWidget(self.mac_config_button)
|
||||||
button_layout.addWidget(self.ipv4_config_button)
|
button_layout.addWidget(self.ipv4_config_button)
|
||||||
button_layout.addWidget(self.batch_process_button)
|
|
||||||
button_layout.addWidget(self.calibration_config_button)
|
button_layout.addWidget(self.calibration_config_button)
|
||||||
button_layout.addWidget(self.get_version_button)
|
button_layout.addWidget(self.get_version_button)
|
||||||
button_layout.addWidget(self.save_button_csv)
|
button_layout.addWidget(self.save_button_csv)
|
||||||
@ -298,15 +295,9 @@ class SocketClientApp(QMainWindow):
|
|||||||
self.ipv4_config_button.clicked.connect(self.ipv4_config_dialog)
|
self.ipv4_config_button.clicked.connect(self.ipv4_config_dialog)
|
||||||
self.calibration_config_button.clicked.connect(self.calibration_dialog)
|
self.calibration_config_button.clicked.connect(self.calibration_dialog)
|
||||||
self.get_version_button.clicked.connect(self.on_button_get_version)
|
self.get_version_button.clicked.connect(self.on_button_get_version)
|
||||||
self.batch_process_button.clicked.connect(self.on_button_batch)
|
|
||||||
# 设置布局策略,确保控件大小随窗口调整
|
# 设置布局策略,确保控件大小随窗口调整
|
||||||
self.setSizePolicy(QSizePolicy.Expanding, QSizePolicy.Expanding)
|
self.setSizePolicy(QSizePolicy.Expanding, QSizePolicy.Expanding)
|
||||||
|
|
||||||
def on_button_batch(self):
|
|
||||||
dialog = BatchOperationDialog()
|
|
||||||
if dialog.exec_() == QDialog.Accepted:
|
|
||||||
dialog.close()
|
|
||||||
|
|
||||||
def get_extremes(self, data):
|
def get_extremes(self, data):
|
||||||
"""获取最大和最小的10个值(排序法)"""
|
"""获取最大和最小的10个值(排序法)"""
|
||||||
sorted_data = np.sort(data)
|
sorted_data = np.sort(data)
|
||||||
@ -697,7 +688,7 @@ class SocketClientApp(QMainWindow):
|
|||||||
print(f"Sending packet {i + 1}/{num_packets}, size: {len(packet_chunk)} bytes")
|
print(f"Sending packet {i + 1}/{num_packets}, size: {len(packet_chunk)} bytes")
|
||||||
self.socket.write(packet_chunk)
|
self.socket.write(packet_chunk)
|
||||||
print(f"Packet {i + 1} sent successfully")
|
print(f"Packet {i + 1} sent successfully")
|
||||||
time.sleep(0.03)
|
time.sleep(0.05)
|
||||||
print("Upgrade packet ready to send (commented out actual send code)")
|
print("Upgrade packet ready to send (commented out actual send code)")
|
||||||
QMessageBox.information(
|
QMessageBox.information(
|
||||||
self,
|
self,
|
||||||
|
Loading…
x
Reference in New Issue
Block a user