devbox
不正经
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

python modbus-tk 实现三菱FX5U modbus-tcp 从站通讯_三菱fx5umodbustcp通讯程序

作者：不正经 | 2024-04-28 05:22:53

赞

踩

三菱fx5umodbustcp通讯程序

一、三菱FX5U 从站设置

        1. 打开GX works3 软件

        2. 新建项目

        3.按向导流程指示设置modbus-tcp从站功能

                                                 

                 

 

         4.下载模块参数到PLC，并断电重启PLC。

注意：部分PLC会发生模块参数报警，需要PLC做固件升级。

二、PC端设置

        1. pip install modbus-tk，struct

        2. main.py

  1. import modbus_tk
  2. import modbus_tk.defines as cst
  3. import modbus_tk.modbus_tcp as modbus_tcp
  4. from shuJuZhuangHuang import WriteDint as wd
  5. import os
  6. import tkinter as tk
  7. import tkinter.font as tkFont
  8. import tkinter.ttk as ttk
  9. import csv
  10. from socket import *
  11. import sys
  12. import threading
  13. import time,random,queue  
  14. import pickle
  15. import re
  16. from configparser import ConfigParser
  17. logger = modbus_tk.utils.create_logger("console")
  18.  
  19. # 读取配置文件
  20. cfg = ConfigParser()
  21. cfg.read('config.ini')
  22. SERVER= cfg.get('Server','IP')
  23. PORT= cfg.getint('Server','PORT')
  24. MACROFILE = cfg.get('File','macroFile')
  25. MACROCOPY = cfg.get('File','macroCopy')
  26.  
  27. timeSave = os.path.getmtime(MACROFILE)
  28.  
  29.  
  30. # 打包函数
  31. def thread_it(func,*args):
  32.     '''将函数打包进程'''
  33.     # 创建进程
  34.     t = threading.Thread(target=func,args=args)
  35.     # 守护进程
  36.     t.setDaemon(True)
  37.     # 启动
  38.     t.start()
  39.  
  40.  
  41. class GuiPart():  
  42.     def __init__(self):
  43.         self.threadFlg1 = True
  44.         self.caiLiao = 0
  45.         self.jiaGongZongShu = 0
  46.         self.gongJianChanDu = 0
  47.         self.qiShiWeiZhi1 = 0
  48.         self.jieShuWeiZhi1 = 0
  49.         self.qiShiWeiZhi2 = 0
  50.         self.jieShuWeiZhi2 = 0
  51.         self.qiShiWeiZhi3 = 0
  52.         self.jieShuWeiZhi3 = 0
  53.         self.qiShiWeiZhi4 = 0
  54.         self.jieShuWeiZhi4 = 0
  55.         self.tuiHuoCiShu = 0
  56.         self.xieRuFlg = 0 # 写入允许-0 禁止-1
  57.  
  58.         # 连接MODBUS TCP从机
  59.         try:
  60.             master = modbus_tcp.TcpMaster(host=SERVER,port=PORT)
  61.             master.set_timeout(5.0)
  62.             self.master = master
  63.         except modbus_tk.modbus.ModbusError as e:
  64.             logger.error("%s- Code=%d" % (e, e.get_exception_code()))
  65.  
  66.         thread_it(self.readMacro)
  67.         self.guiProcess()
  68.  
  69.  
  70.     # 调整屏幕
  71.     def center_window(self,root,w,h):
  72.         '''
  73.         窗口居于屏幕中央
  74.         :param root: root
  75.         :param w: 窗口宽度
  76.         :param h: 窗口高度
  77.         :return:
  78.         '''
  79.         # 获取屏幕 宽、高
  80.         ws = root.winfo_screenwidth()
  81.         hs = root.winfo_screenheight()
  82.         # 计算x、y位置
  83.         x = (ws/2) - (w/2)
  84.         y = (hs/2) - (h/2)
  85.         root.geometry('%dx%d+%d+%d' %(w,h,x,y))
  86.  
  87.  
  88.     def send(self):
  89.         try:
  90.             # # 写寄存器起始地址为500的保持寄存器，操作寄存器个数为1
  91.             logger.info(self.master.execute(1, cst.WRITE_MULTIPLE_REGISTERS, 500 , output_value=[self.caiLiao]))
  92.             logger.info(self.master.execute(1, cst.WRITE_MULTIPLE_REGISTERS, 604, output_value=[self.jiaGongZongShu]))
  93.             logger.info(self.master.execute(1, cst.WRITE_MULTIPLE_REGISTERS, 608, output_value=wd(self.gongJianChanDu)))
  94.             logger.info(self.master.execute(1, cst.WRITE_MULTIPLE_REGISTERS, 4606, output_value=wd(self.qiShiWeiZhi1)))
  95.             logger.info(self.master.execute(1, cst.WRITE_MULTIPLE_REGISTERS, 4608, output_value=wd(self.jieShuWeiZhi1)))
  96.             logger.info(self.master.execute(1, cst.WRITE_MULTIPLE_REGISTERS, 4610, output_value=wd(self.qiShiWeiZhi2)))
  97.             logger.info(self.master.execute(1, cst.WRITE_MULTIPLE_REGISTERS, 4612, output_value=wd(self.jieShuWeiZhi2)))
  98.             logger.info(self.master.execute(1, cst.WRITE_MULTIPLE_REGISTERS, 4614, output_value=wd(self.qiShiWeiZhi3)))
  99.             logger.info(self.master.execute(1, cst.WRITE_MULTIPLE_REGISTERS, 4616, output_value=wd(self.jieShuWeiZhi3)))
  100.             logger.info(self.master.execute(1, cst.WRITE_MULTIPLE_REGISTERS, 4618, output_value=wd(self.qiShiWeiZhi4)))
  101.             logger.info(self.master.execute(1, cst.WRITE_MULTIPLE_REGISTERS, 4620, output_value=wd(self.jieShuWeiZhi4)))
  102.             logger.info(self.master.execute(1, cst.WRITE_MULTIPLE_REGISTERS, 4622, output_value=[self.tuiHuoCiShu]))
  103.         except modbus_tk.modbus.ModbusError as e:
  104.             logger.error("%s- Code=%d" % (e, e.get_exception_code()))
  105.  
  106.  
  107.     def reset(self):
  108.         print('reset')
  109.         self.threadFlg1 = True 
  110.         thread_it(self.readMacro)
  111.  
  112.  
  113.     def readMacro(self):
  114.         global timeSave
  115.         
  116.         while self.threadFlg1:
  117.             time.sleep(0.2)
  118.             # 读取PLC M4606 写入标志
  119.             try:
  120.                 self.xieRuFlg = self.master.execute(2, cst.READ_COILS, 9228, 1)[0]
  121.             except modbus_tk.modbus.ModbusError as e:
  122.                 logger.error("%s- Code=%d" % (e, e.get_exception_code()))
  123.  
  124.             """
  125.             # print("flg: " )
  126.             self.xieRuFlg = 1
  127.             print(self.xieRuFlg)
  128.             """
  129.  
  130.             # 如果写入标志==0可以写入，否则禁止更新。
  131.             if self.xieRuFlg == 0:
  132.                 timeLast = os.path.getmtime(MACROFILE)
  133.                 # print(timeLast,' > ',timeSave)
  134.                 if timeLast > timeSave:
  135.                     # print('time change')
  136.                     timeSave = timeLast
  137.                     os.system(r'copy %s %s'%(MACROFILE,MACROCOPY)) 
  138.                     f = open (MACROCOPY,'r')
  139.                     fileLines = f.readlines()
  140.                     f.close()
  141.                     # 读取数据
  142.                     for item in fileLines:
  143.                         patt = r'(\d+)\D+?((-)?\d+\.?\d{0,3})' # 匹配 500 = 34 500=34 500 = 34. 500 =34.5 500 = -34.565 不完全匹配 34.34352345
  144.                         m = re.match(patt,item)
  145.                         if m:
  146.                             shapu = m.group(1)
  147.                             data = m.group(2)
  148.                         # 读取变量
  149.                             if shapu == '500':
  150.                                 self.caiLiao = int(data)
  151.                             elif shapu == '501':
  152.                                 self.jiaGongZongShu = int(data)
  153.                             elif shapu == '502':
  154.                                 self.gongJianChanDu = int(float (data) * 10000)
  155.                             elif shapu == '503':
  156.                                 self.qiShiWeiZhi1 = int(float (data) * 10000)
  157.                             elif shapu == '504':
  158.                                 self.jieShuWeiZhi1 =int(float (data) * 10000)
  159.                             elif shapu == '505':
  160.                                 self.qiShiWeiZhi2 =int(float (data) * 10000)
  161.                             elif shapu == '506':
  162.                                 self.jieShuWeiZhi2 =int(float (data) * 10000)
  163.                             elif shapu == '507':
  164.                                 self.qiShiWeiZhi3 =int(float (data) * 10000)
  165.                             elif shapu == '508':
  166.                                 self.jieShuWeiZhi3 =int(float (data) * 10000)
  167.                             elif shapu == '509':
  168.                                 self.qiShiWeiZhi4 =int(float (data) * 10000)
  169.                             elif shapu == '510':
  170.                                 self.jieShuWeiZhi4 =int(float (data) * 10000)
  171.                             elif shapu == '511':
  172.                                 self.tuiHuoCiShu = int(data)
  173.                     self.send()
  174.                     self.l_0_state.configure(bg = 'green')
  175.                     self.varState.set("数据已更新！")
  176.  
  177.             else:
  178.                 #设置标签为红色
  179.                 # print("help")
  180.                 self.l_0_state.configure(bg = 'red')
  181.                 self.varState.set("设备运行中，禁止写入。设备停止后自动更新数据，请注意！")
  182.  
  183.         self.threadFlg1 = False
  184.  
  185.  
  186.     # 定义Gui界面
  187.     def guiProcess(self):
  188.         '''
  189.         GUI主界面
  190.         :param
  191.         :retuen
  192.         '''
  193.         root=tk.Tk()  
  194.         self.root = root
  195.         # 设置窗口位置
  196.         root.title('********* V1')
  197.         self.center_window(root,400,120)
  198.         root.resizable(0,0)#  窗体大小可调整，分别表示x、y方向的可变性
  199.  
  200.         # 设置字体
  201.         ft20 =tkFont.Font(family = 'Fixdsys',size = 20,weight = tkFont.BOLD)
  202.         ft30 =tkFont.Font(family = 'Fixdsys',size = 30,weight = tkFont.BOLD)
  203.         ft40 =tkFont.Font(family = 'Fixdsys',size = 40,weight = tkFont.BOLD)
  204.         ft50 =tkFont.Font(family = 'Fixdsys',size = 50,weight = tkFont.BOLD)
  205.         ft55 =tkFont.Font(family = 'Fixdsys',size = 55,weight = tkFont.BOLD)
  206.         ft80 =tkFont.Font(family = 'Fixdsys',size = 80,weight = tkFont.BOLD)
  207.  
  208.         # 设置标签窗体
  209.         labelFm1= tk.LabelFrame(root)
  210.         labelFm1.pack(padx=5,pady=5,side=tk.TOP,fill=tk.X)
  211.         self.labelFm1 = labelFm1
  212.  
  213.         # labelFm1
  214.         self.varState = tk.StringVar()
  215.         self.varState.set('*'*10)
  216.         l_0_state = tk.Label(labelFm1,textvariable =self.varState )
  217.         l_0_state.grid(row=0,column=0,padx=5,pady=5)
  218.         self.l_0_state = l_0_state 
  219.         self.l_0_state.configure(bg = 'green')
  220.  
  221.         button1 = tk.Button(labelFm1,text= "RESET" ,font=ft20)
  222.         button1.grid(row=3,column=0,padx = 5,pady=5)
  223.         self.button1 = button1
  224.  
  225.         # 定义事件响应
  226.         button1.configure(command=self.reset) # 系统复位
  227.  
  228.         root.mainloop() 
  229.  
  230.         self.threadFlg1 = False
  231.         print('self.threadFlg1 = ',self.threadFlg1)
  232.  
  233.  
  234. if __name__=='__main__':
  235.     ui = GuiPart()

         3. shuJuZhuangHuang.py   作为数据转换模块使用

  1. import struct
  2.  
  3. def ReadFloat(*args,reverse=False):
  4.     for n,m in args:
  5.         n,m = '%04x'%n,'%04x'%m
  6.     if reverse:
  7.         v = n + m
  8.     else:
  9.         v = m + n
  10.     y_bytes = bytes.fromhex(v)
  11.     y = struct.unpack('!f',y_bytes)[0]
  12.     y = round(y,6)
  13.     return y
  14.  
  15. def WriteFloat(value,reverse=False):
  16.     y_bytes = struct.pack('!f',value)
  17.     # y_hex = bytes.hex(y_bytes)
  18.     y_hex = ''.join(['%02x' % i for i in y_bytes])
  19.     n,m = y_hex[:-4],y_hex[-4:]
  20.     n,m = int(n,16),int(m,16)
  21.     if reverse:
  22.         v = [n,m]
  23.     else:
  24.         v = [m,n]
  25.     return v
  26.  
  27. def ReadDint(*args,reverse=False):
  28.     for n,m in args:
  29.         n,m = '%04x'%n,'%04x'%m
  30.     if reverse:
  31.         v = n + m
  32.     else:
  33.         v = m + n
  34.     y_bytes = bytes.fromhex(v)
  35.     y = struct.unpack('!i',y_bytes)[0]
  36.     return y
  37.  
  38. def WriteDint(value,reverse=False):
  39.     y_bytes = struct.pack('!i',value)
  40.     # y_hex = bytes.hex(y_bytes)
  41.     y_hex = ''.join(['%02x' % i for i in y_bytes])
  42.     n,m = y_hex[:-4],y_hex[-4:]
  43.     n,m = int(n,16),int(m,16)
  44.     if reverse:
  45.         v = [n,m]
  46.     else:
  47.         v = [m,n]
  48.     return v
  49.  
  50. if __name__ == "__main__":
  51.     print(ReadFloat((15729,16458)))
  52.     print(WriteFloat(3.16))
  53.     print(ReadDint((1734,6970)))
  54.     print(WriteDint(456787654))

        4. 添加配置文件 config.ini

  1. ;config.ini
  2.  
  3. [Server]
  4. IP=192.168.3.39
  5. PORT=502
  6.  
  7. [File]
  8. macroFile=c:\\macro\\macro.txt
  9. macroCopy=macro.txt

        5.添加macro.txt文本

  1. 500 = 2
  2. 501 = 3
  3. 502 = 40.03
  4. 503 = 5.5
  5. 504 = 6.6
  6. 505 = 7.8
  7. 506 = 8.8
  8. 507 = 9.6
  9. 508 = 8.7
  10. 509 = 7.7
  11. 510 = 6.7
  12. 511 = 3

       6.添加指令定义

  1. #modbus exception codes
  2. ILLEGAL_FUNCTION = 1
  3. ILLEGAL_DATA_ADDRESS = 2
  4. ILLEGAL_DATA_VALUE = 3
  5. SLAVE_DEVICE_FAILURE = 4
  6. COMMAND_ACKNOWLEDGE = 5
  7. SLAVE_DEVICE_BUSY = 6
  8. MEMORY_PARITY_ERROR = 8
  9.  
  10. #supported modbus functions
  11. RAW = 0
  12. READ_COILS = 1
  13. READ_DISCRETE_INPUTS = 2
  14. READ_HOLDING_REGISTERS = 3
  15. READ_INPUT_REGISTERS = 4
  16. WRITE_SINGLE_COIL = 5
  17. WRITE_SINGLE_REGISTER = 6
  18. READ_EXCEPTION_STATUS = 7
  19. DIAGNOSTIC = 8
  20. REPORT_SLAVE_ID = 17
  21. WRITE_MULTIPLE_COILS = 15
  22. WRITE_MULTIPLE_REGISTERS = 16
  23. READ_FILE_RECORD = 20
  24. READ_WRITE_MULTIPLE_REGISTERS = 23
  25. DEVICE_INFO = 43
  26.  
  27. #supported block types
  28. COILS = 1
  29. DISCRETE_INPUTS = 2
  30. HOLDING_REGISTERS = 3
  31. ANALOG_INPUTS = 4

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/不正经/article/detail/500603
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号