class MainWindow(QMainWindow): def init(self, user_id): super().init() self.user_id = user_id self.initUI() # 打开串口 self.ser = serial.Serial('COM7', 9600, timeout=1) def initUI(self): # 创建用于显示员工信息的控件 self.info_label = QLabel("员工信息", self) self.info_label.move(100, 50) self.info_label.setStyleSheet("font-size: 24px; color: black; background-color: #eee; border-radius: 10px;") self.id_label = QLabel("员工ID:", self) self.id_label.move(70, 100) self.id_label.setStyleSheet("font-size: 18px; color: black;") self.name_label = QLabel("姓名:", self) self.name_label.move(70, 150) self.name_label.setStyleSheet("font-size: 18px; color: black;") self.six_label = QLabel("性别:", self) self.six_label.move(70, 200) self.six_label.setStyleSheet("font-size: 18px; color: black;") self.sfz_label = QLabel("身份证:", self) self.sfz_label.move(70, 250) self.sfz_label.setStyleSheet("font-size: 18px; color: black;") self.tel_label = QLabel("电话:", self) self.tel_label.move(70, 300) self.tel_label.setStyleSheet("font-size: 18px; color: black;") self.setFixedSize(800, 500) self.setWindowTitle('员工信息') # 查询员工信息 def query_employee(self, id): conn = pymysql.connect(host='39.99.214.172', user='root', password='Solotion.123', database='jj_tset') cursor = conn.cursor() cursor.execute("SELECT * FROM employee_table WHERE user_id='%s'" % id) result = cursor.fetchone() conn.close() return result # 读取数据 def read_data(self): data = self.ser.readline() if data: # 解析数据 id = data.decode().strip() # 查询员工信息 result = self.query_employee(id) if result: # 更新UI界面 self.id_label.setText("员工ID:" + result[0]) self.name_label.setText("姓名:" + str(result[1])) self.six_label.setText("性别:" + result[2]) self.sfz_label.setText("身份证:" + str(result[3])) self.tel_label.setText("电话:" + result[4]) print(result[0],result[1],result[2],result[3],result[4]) else: # 显示空白信息 self.id_label.setText("员工ID:") self.name_label.setText("姓名:") self.six_label.setText("性别:") self.sfz_label.setText("身份证:") self.tel_label.setText("电话:") # 定时读取数据 QTimer.singleShot(100, self.read_data) def closeEvent(self, event): # 关闭串口 self.ser.close()把这个改为多线程
时间: 2024-02-11 14:07:03 浏览: 182
好的,为了将串口读取数据和更新UI的操作放在不同的线程中,我们可以使用Python的`threading`库来创建多线程。具体来说,我们可以创建一个新的线程来读取串口数据,并将读取到的数据放入一个队列中,然后在主线程中不断从队列中读取数据并更新UI。
下面是修改后的代码:
```python
import serial
import pymysql
from PyQt5.QtWidgets import QApplication, QMainWindow, QLabel
from PyQt5.QtCore import QTimer, QObject, pyqtSignal
import threading
class SerialThread(QObject):
data_received = pyqtSignal(str)
def __init__(self):
super().__init__()
self.ser = serial.Serial('COM7', 9600, timeout=1)
def run(self):
while True:
data = self.ser.readline().decode().strip()
if data:
self.data_received.emit(data)
class MainWindow(QMainWindow):
def __init__(self, user_id):
super().__init__()
self.user_id = user_id
self.initUI()
# 创建串口线程
self.serial_thread = SerialThread()
self.serial_thread.data_received.connect(self.handle_data)
self.serial_thread_thread = threading.Thread(target=self.serial_thread.run)
self.serial_thread_thread.start()
def initUI(self):
# 创建用于显示员工信息的控件
self.info_label = QLabel("员工信息", self)
self.info_label.move(100, 50)
self.info_label.setStyleSheet("font-size: 24px; color: black; background-color: #eee; border-radius: 10px;")
self.id_label = QLabel("员工ID:", self)
self.id_label.move(70, 100)
self.id_label.setStyleSheet("font-size: 18px; color: black;")
self.name_label = QLabel("姓名:", self)
self.name_label.move(70, 150)
self.name_label.setStyleSheet("font-size: 18px; color: black;")
self.six_label = QLabel("性别:", self)
self.six_label.move(70, 200)
self.six_label.setStyleSheet("font-size: 18px; color: black;")
self.sfz_label = QLabel("身份证:", self)
self.sfz_label.move(70, 250)
self.sfz_label.setStyleSheet("font-size: 18px; color: black;")
self.tel_label = QLabel("电话:", self)
self.tel_label.move(70, 300)
self.tel_label.setStyleSheet("font-size: 18px; color: black;")
self.setFixedSize(800, 500)
self.setWindowTitle('员工信息')
# 查询员工信息
def query_employee(self, id):
conn = pymysql.connect(host='39.99.214.172', user='root', password='Solotion.123', database='jj_tset')
cursor = conn.cursor()
cursor.execute("SELECT * FROM employee_table WHERE user_id='%s'" % id)
result = cursor.fetchone()
conn.close()
return result
# 处理读取到的数据
def handle_data(self, data):
# 查询员工信息
result = self.query_employee(data)
if result:
# 更新UI界面
self.id_label.setText("员工ID:" + result[0])
self.name_label.setText("姓名:" + str(result[1]))
self.six_label.setText("性别:" + result[2])
self.sfz_label.setText("身份证:" + str(result[3]))
self.tel_label.setText("电话:" + result[4])
print(result[0],result[1],result[2],result[3],result[4])
else:
# 显示空白信息
self.id_label.setText("员工ID:")
self.name_label.setText("姓名:")
self.six_label.setText("性别:")
self.sfz_label.setText("身份证:")
self.tel_label.setText("电话:")
def closeEvent(self, event):
# 关闭串口
self.serial_thread.ser.close()
if __name__ == '__main__':
app = QApplication([])
window = MainWindow('user_id')
window.show()
app.exec_()
```
修改后的代码中,我们首先创建了一个`SerialThread`类,该类继承自`QObject`类,并且定义了一个`data_received`信号和一个`run`方法。`data_received`信号用于在读取到串口数据时发射信号,`run`方法用于在新线程中读取串口数据并发射`data_received`信号。
在`MainWindow`类中,我们在初始化时创建了一个`SerialThread`对象,并将其`data_received`信号连接到`handle_data`方法。我们还创建了一个新的线程,用于运行`SerialThread`的`run`方法。
在`handle_data`方法中,我们查询员工信息并更新UI,这个方法会在主线程中执行。而读取串口数据的工作则在`SerialThread`类的新线程中执行。这样就实现了串口读取数据和更新UI的异步操作。
阅读全文