汇川EASY300实验——python作为上位机，PLC与传感器相连，实时显示传感器值并绘制曲线，保存到MYSQL数据库

引言

汇川EASY系列PLC是一款全场景紧凑型小型PLC，其设计理念来源于真实的使用场景和用户“痛点”，旨在为用户提供易用、高效、可靠的自动化解决方案。以下是对汇川EASY系列PLC的详细介绍：

一、产品特点

二、应用场景

汇川EASY系列PLC适用于多种应用场景，包括但不限于：

• 严苛体积要求的自动化设备
• 多轴运动控制场景
• 温度、压力、流量等过程控制场景
• 通信组网需求高的场景

三、产品系列

汇川EASY系列PLC包括多个子系列，如EASY300系列和EASY500系列等，每个系列都有其特定的应用场景和优势：

• EASY300系列：适用于离散单机，设备相对简单，工艺不复杂，追求易用、便宜和快速交易。
• EASY500系列：适用于快速交付需求市场，交期很紧，点位控制居多，追求快速交付和现场零调试。

四、市场评价

汇川EASY系列PLC在市场上受到了广泛的关注和好评。其卓越的性能、易用的特性和广泛的应用场景使得它成为中小型自动化设备领域的热门选择。同时，汇川技术作为国产PLC的领军企业之一，其产品的质量和售后服务也备受用户信赖。

综上所述，汇川EASY系列PLC是一款功能强大、易于使用、灵活扩展、高效互联的全场景紧凑型小型PLC。它能够满足用户对中小型自动化设备的各种需求，为自动化行业的发展贡献自己的力量。

实验要求

实验需要分别测量输入端和输出端压力流量温度，上位机实时显示传感器值，每个量的波形曲线显示，数据保存到MYSQL数据库

编程软件AutoShop是汇川小型PLC的专用上位机软件，它提供了友好的编程和调试环境，支持多种编程语言，并具备丰富、强大的通讯和控制功能。

PLC配置

确定PLC的网络配置

检查网络设置：验证PLC的网络设置（如子网掩码、网关等）是否正确，并确保它与你的网络兼容。

确定PLC的通信协议

确定PLC使用的通信协议，如Modbus TCP、Ethernet/IP、Profinet等。选择使用Python作为上位机进行通信。例如，对于Modbus TCP，使用pymodbus库。

IO端口映射

GL20-4AD模块配置和参数设置

对于4-20mA的输入，需要设置相应的输入通道为电流输入模式，使能通道以接收4-20mA（对应0-20000）的模拟量输入，可根据具体需求修改

PYTHON上位机

数值转换

根据购买的传感器量程转换，将PLC返回的数据解析为实际值，这里转换有些误差，有更好的转换方法欢迎指出

# 压力转换
def convert_value(raw_value):
    return (raw_value / 20000) * 4


# 流量转换
def convert_value_2(raw_value):
    return (raw_value / 20000)* 120


# 温度转换
def convert_value_3(return_value):
    return -50 + (return_value / 20000) * (200 - (-50))

MYSQL数据库创建数据表

# MySQL数据库
conn = pymysql.connect(user='root', password='123456', host='localhost', database='plc')
cursor = conn.cursor()
cursor.execute("DROP TABLE IF EXISTS sensor_data")
CREATE TABLE sensor1_data(  
    id INTEGER PRIMARY KEY AUTO_INCREMENT,  
    time_stamp TIMESTAMP DEFAULT CURRENT_TIMESTAMP,  
    input_pressure FLOAT,  
    input_flow FLOAT,  
    input_temperature FLOAT,  
    output_pressure FLOAT,  
    output_flow FLOAT,  
    output_temperature FLOAT  
) 
cursor.execute(createTab)

QT主程序

使用PYQT显示六个传感器实际值到界面，绘制实时曲线并保存到MYSQL数据库

class PlotWindow(QMainWindow):
    def __init__(self):
        super().__init__()

        # 连接PLC
        self.plc_ip = '192.168.1.2'
        self.plc_port = 502
        self.client = ModbusTcpClient(self.plc_ip, port=self.plc_port)

        # 设置主窗口
        self.setWindowTitle('波形曲线据显示')
        self.setGeometry(800, 300, 1200, 1000)

        # 创建绘图部件
        self.central_widget = QWidget()
        self.setCentralWidget(self.central_widget)
        self.canvas = FigureCanvas(Figure())
        layout = QVBoxLayout(self.central_widget)
        layout.addWidget(self.canvas)

        # 初始化图表
        self.fig = self.canvas.figure
        self.axs = self.fig.subplots(3, 2)
        self.lines = []
        self.labels = ['Input Pressure', 'Output Pressure', 'Input Flow', 'Output Flow', 'Input Temperature',
                       'Output Temperature']
        self.x = np.arange(100)
        self.y = np.zeros((6, 100))
        self.values = np.zeros(6)

        for i in range(3):
            for j in range(2):
                ax = self.axs[i, j]
                ax.set_xlim(0, 100)
                ax.grid(True)
                ax.set_ylabel(self.labels[i * 2 + j])
                ax.set_xlabel("Time")
                line, = ax.plot(self.x, self.y[i * 2 + j])
                self.lines.append(line)

        self.axs[0, 0].set_ylim(0, 4000)
        self.axs[0, 1].set_ylim(0, 4000)
        self.axs[2, 0].set_ylim(-50, 200)
        self.axs[2, 1].set_ylim(-50, 200)
        self.axs[1, 1].set_ylim(10, 120)
        self.axs[1, 0].set_ylim(10, 120)


        # 启动一个线程用于读取PLC数据
        self.plc_thread = threading.Thread(target=self.read_plc_data)
        self.plc_thread.start()

        # 定时器更新图表
        self.timer = self.fig.canvas.new_timer(interval=100)
        self.timer.add_callback(self.update_plot)
        self.timer.start()

        # 传感器数据界面
        self.data_window = QWidget()
        self.data_window.setWindowTitle('传感器值')
        self.data_window.setGeometry(400, 300, 400, 1000)
        layout = QVBoxLayout(self.data_window)
        self.labels = []
        for i in range(6):
            label = QLabel()
            self.labels.append(label)
            layout.addWidget(label)

        self.data_window.show()

    def update_plot(self):

        for i in range(6):
            data = self.y[i]
            data[:-1] = data[1:]
            data[-1] = self.values1[i]
            line = self.lines[i]
            line.set_data(self.x, data)
            self.axs[i // 2, i % 2].relim()
            self.axs[i // 2, i % 2].autoscale_view(True, True, True)
            line.set_color('r')
            line.set_linewidth(2.0)

        self.fig.canvas.draw()

    def read_plc_data(self):
        while True:
            if self.client.connect():
                addresses = [100, 101, 102, 103,104, 105]
                count = 1
                new_values = []
                for address in addresses:
                    response = self.client.read_holding_registers(address, count, unit=1)
                    if response.isError():
                        print(f"读取寄存器数据时发生错误：{response}")
                    else:
                        new_values.append(response.registers[0])

                self.values = new_values
                value0_raw=self.values[0]
                print(value0_raw)
                print(self.values[2])
                # print(self.values[1])
                if value0_raw<0:
                    value0_raw=0
                value1 = convert_value(self.values[0])
                # value1 = convert_value(value0_raw)
                value2 = convert_value_2(self.values[1])
                value3 = convert_value_3(self.values[2])
                value4 = convert_value(self.values[3])
                value5 = convert_value_2(self.values[4])
                value6 = convert_value_3(self.values[5])
                self.values1 = [value1, value4, value2, value5, value3, value6]

                sql = ("INSERT INTO sensor1_data "
                       "(TIME, InputPressure,InputFlow, InputTemperature,OutputPressure, OutputFlow, "
                       "OutputTemperature) "
                       "VALUES (%(TIME)s, %(InputPressure)s, %(InputFlow)s, %(InputTemperature)s, %(OutputPressure)s,"
                       "%(OutputFlow)s,%(OutputTemperature)s)")

                data = {
                    'TIME': datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S'),
                    'InputPressure': str(value1),
                    'InputFlow': str(value2),
                    'InputTemperature': str(value3),
                    'OutputPressure': str(value4),
                    'OutputFlow': str(value5),
                    'OutputTemperature': str(value6)
                }
                cursor.execute(sql, data)
                conn.commit()

                labels_text = [
                    f'输入侧压力: {value1:.2f} MPa',
                    f'输入侧流量: {value2:.2f} m³/h',
                    f'输入侧温度: {value3:.2f} °C',
                    f'输出侧压力: {value4:.2f} MPa',
                    f'输出侧流量: {value5:.2f} m³/h',
                    f'输出侧温度: {value6:.2f} °C'
                ]
                font = QFont()
                font.setPointSize(20)
                for i in range(6):
                    self.labels[i].setFont(font)
                    self.labels[i].setText(labels_text[i])

                # 关闭连接
                self.client.close()
            else:
                print("无法连接到PLC")

            time.sleep(0.1)