From dc5c0efdc79bda54a55da06ea335d2d099d8624a Mon Sep 17 00:00:00 2001 From: Jinhuan <412100639@qq.com> Date: Thu, 9 May 2024 00:50:45 +0800 Subject: [PATCH] =?UTF-8?q?=E5=B0=9D=E8=AF=95=E5=8A=A0=E5=85=A5mobude=20tc?= =?UTF-8?q?p=20=E4=BB=8E=E6=9C=BA=E8=AE=BE=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- Cigarette/PLC/PLCDevice.cpp | 44 ++++++++++++++++++++++++++++++++----- Cigarette/PLC/PLCDevice.h | 13 ++++++++++- Cigarette/common.h | 22 +++++++++++-------- Cigarette/threadSendTCP.cpp | 9 ++++++-- 4 files changed, 70 insertions(+), 18 deletions(-) diff --git a/Cigarette/PLC/PLCDevice.cpp b/Cigarette/PLC/PLCDevice.cpp index 0e03dd1..4926375 100644 --- a/Cigarette/PLC/PLCDevice.cpp +++ b/Cigarette/PLC/PLCDevice.cpp @@ -34,9 +34,7 @@ bool PLCDevice::init_plc(PLCDevice* PLCptr) bool PLCDevice::init_plc_tcp(PLCDevice* PLCptr) { - // modbus_connect() 建立连接，成功返回0，错误返回-1 - // modbus_new_rtu 生成RTU的连接，建立成功则返回指向modbus_t结构的指针，否则将返回NULL/0 - +#ifdef __ModebusServer PLCptr->g_modbus = modbus_new_tcp("192.168.1.200", 2000); modbus_set_debug(PLCptr->g_modbus, 0); // 用flag设置debug调试标志位，flag=1时显示modbus消息的字节 modbus_set_response_timeout(PLCptr->g_modbus, 1, 0); // 设置响应超时 @@ -56,7 +54,25 @@ bool PLCDevice::init_plc_tcp(PLCDevice* PLCptr) PLCptr->g_plc_ok = true; qDebug("TCP connect successful "); } - +#endif +#ifdef __ModebusClient + + PLCptr->g_modbus = modbus_new_tcp("127.0.0.1", 502); + modbus_set_debug(PLCptr->g_modbus, 0); // 用flag设置debug调试标志位，flag=1时显示modbus消息的字节 + modbus_set_response_timeout(PLCptr->g_modbus, 1, 0); // 设置响应超时 + // 侦听主站连接 + PLCptr->m_modbusSocket = modbus_tcp_listen(PLCptr->g_modbus, 1); // 最多支持的主机数量 1 + /*设置线圈, 离散输入, 输入寄存器, 保持寄存器个数(数组元素个数))*/ + PLCptr->mapping = modbus_mapping_new(PLCptr->m_numBits, PLCptr->m_numInputBits, PLCptr->m_numInputRegisters, PLCptr->m_numRegisters); + if (PLCptr->mapping == NULL) + { + fprintf(stderr, "Unable to assign mapping：%s\n", modbus_strerror(errno)); + modbus_free(PLCptr->g_modbus); + PLCptr->m_initialized = false; + return false; + } + PLCptr->m_initialized = true; +#endif return true; } @@ -106,9 +122,9 @@ int PLCDevice::write_short_2_plc(int addr, int nb, uint16_t* value) { if (g_plc_ok) { - //g_mutex.lock(); + g_mutex.lock(); int ret = modbus_write_registers(g_modbus, addr, nb, value); - //g_mutex.unlock(); + g_mutex.unlock(); //printf("modbus_write_registers:addr=%d,nb=%d,value=%d,ret=%d\n", addr, nb, *value, ret); return ret; } @@ -133,3 +149,19 @@ int PLCDevice::read_short_from_plc(int addr, int nb, uint16_t* value) return false; } } + +int PLCDevice::write_2_plc(int addr, int nb, uint16_t* value) +{ + if (g_plc_ok) + { + //g_mutex.lock(); + int ret = modbus_write_registers(g_modbus, addr, nb, value); + //g_mutex.unlock(); + //printf("modbus_write_registers:addr=%d,nb=%d,value=%d,ret=%d\n", addr, nb, *value, ret); + return ret; + } + else { + //std::cout << "PLC no ok" << std::endl; + return false; + } +} \ No newline at end of file diff --git a/Cigarette/PLC/PLCDevice.h b/Cigarette/PLC/PLCDevice.h index 0d91acb..ac28fad 100644 --- a/Cigarette/PLC/PLCDevice.h +++ b/Cigarette/PLC/PLCDevice.h @@ -1,6 +1,6 @@ #include #include "modbus.h" - +#include "common.h" class PLCDevice { public: @@ -11,7 +11,17 @@ public: //[0]:1=连接,0=断开 uint8_t g_plc_status; +#ifdef __ModebusClient + int m_modbusSocket; + bool m_initialized; + modbus_mapping_t* mapping{ nullptr }; + /*Mapping*/ + int m_numBits{ 500 }; + int m_numInputBits{ 500 }; + int m_numRegisters{ 500 }; + int m_numInputRegisters{ 500 }; +#endif static bool init_plc(PLCDevice* PLCptr); static bool init_plc_tcp(PLCDevice* PLCptr); @@ -19,5 +29,6 @@ public: int read_bits_from_plc(int addr, int nb, uint8_t* value); int write_short_2_plc(int addr, int nb, uint16_t* value); int read_short_from_plc(int addr, int nb, uint16_t* value); + int write_2_plc(int addr, int nb, uint16_t* value); bool disconnect_plc(void); }; diff --git a/Cigarette/common.h b/Cigarette/common.h index 7d67902..3eea1f0 100644 --- a/Cigarette/common.h +++ b/Cigarette/common.h @@ -5,25 +5,29 @@ #include "basecamera.h" #include "QtCore\qdatetime.h" -//#define __DEBUGPATH //修改debug时候的路径 -//#define __DEBUG //debug信息输出功能 -//#define __UDPSend //网络发送功能 -#define __TCPSend // TCP发送 -//#define __TCPServer // TCP服务器 -#define __ExportData // FTP发送 +//#define __DEBUGPATH //修改debug时候的路径 +//#define __DEBUG //debug信息输出功能 + +//#define __UDPSend //网络发送功能 +#define __TCPSend // TCP发送 +//#define __TCPServer // TCP服务器 +#define __ExportData // FTP发送 +//#define __ModebusServer // 建立modbus主机 +#define __ModebusClient // 建立modbus从机 + #define USB_BASLER_NEW_FW //使用basler定制固件 //#define IMM_PROCESS //拍照后立马处理，不等校验信号 //#define IMM_FEED_BACK //处理完后立马反馈，不等校验信号 #define ONE_TIME_SHIFT //错开一拍发送反馈(默认错开两次) -#define AI_WARM_UP //AI识别开始前的热身动作 -#define LICENSE_VERIFY //开启license文件校验 //CAP_FEED_BACK和DOUBLE_FEED_BACK不要一起开 #if defined (ONE_TIME_SHIFT) //#define CAP_FEED_BACK //拍照时也检测有没有测试结果，有的话就反馈 //#define DOUBLE_FEED_BACK //一次ng，两次反馈ng信号 #endif + +#define AI_WARM_UP //AI识别开始前的热身动作 +//#define LICENSE_VERIFY //开启license文件校验 //#define identify_Hik_YSXID//识别海康相机YSXID -//#define __ExportData // 输出检测数据到XML文档 //#define DRAW_RECT // 鼠标画框功能 #define SYNC_CAMERA //相机同步处理图片 diff --git a/Cigarette/threadSendTCP.cpp b/Cigarette/threadSendTCP.cpp index 65009df..561ba4f 100644 --- a/Cigarette/threadSendTCP.cpp +++ b/Cigarette/threadSendTCP.cpp @@ -104,8 +104,13 @@ void threadSendTCP::sendData(_TCPSendInfo* TCPSendInfo, int Num) { { val_[i] = asciiVals[i]; } - //m_PLCTCPDevice->write_short_2_plc(40000, 70, (uint16_t*)&val_);//小盒 - m_PLCTCPDevice->write_short_2_plc(40070, 70, (uint16_t*)&val_);//条盒 +#ifdef __ModebusServer + //m_PLCTCPDevice->write_2_plc(40000, 70, (uint16_t*)&val_);//小盒 + m_PLCTCPDevice->write_2_plc(40070, 70, (uint16_t*)&val_);//条盒 +#endif +#ifdef __ModebusClient + memcpy(&(m_PLCTCPDevice->mapping->tab_registers[0]),(uint16_t*)&val_,70); +#endif now_ts = QDateTime::currentDateTime(); qDebug() << "end-now_ts=" << now_ts;