mrDarker
2025-09-12 49cab6105eccb35d8b18a12f8ea29c05a857471b
SourceCode/Bond/SGMeasurement/PLCSignalListener.cpp
@@ -1,39 +1,39 @@
#include "pch.h"
#include "PLCSignalListener.h"
// === 日志打印类型 ===
// === 日志打印类型 ===
#define LOG_TYPE_ERROR     -1
#define LOG_TYPE_SUCCESS    0
#define LOG_TYPE_WARNING    1
#define LOG_TYPE_NORMAL     2
// === 日志打印宏定义 ===
// === 日志打印宏定义 ===
#define LOG_MSG(msg, type) LogInfo(msg, type)
// === PLC 心跳相关配置 ===
#define PLC_HEARTBEAT_PC_TO_PLC_ADDR   0x107F   // PC -> PLC:PC 写入心跳
#define PLC_HEARTBEAT_PLC_TO_PC_ADDR   0x6C40   // PLC -> PC:PC 读取 PLC 写入的心跳
#define MAX_MISSED_HEARTBEAT           5        // 允许连续丢失心跳的最大次数,超过则判定 PLC 掉线
// === PLC 心跳相关配置 ===
#define PLC_HEARTBEAT_PC_TO_PLC_ADDR   0x107F   // PC -> PLC:PC 写入心跳
#define PLC_HEARTBEAT_PLC_TO_PC_ADDR   0x6C40   // PLC -> PC:PC 读取 PLC 写入的心跳
#define MAX_MISSED_HEARTBEAT           5        // 允许连续丢失心跳的最大次数,超过则判定 PLC 掉线
// === PLC 命令输入配置(PLC -> PC) ===
#define PLC_CMD_BIT_START       0x6CD3  // PLC命令起始位(通常为B6CD3)
#define PLC_CMD_BIT_COUNT       2       // 总共几个命令位(B6CD3=Start, B6CD4=Stop)
// === PLC 命令输入配置(PLC -> PC) ===
#define PLC_CMD_BIT_START       0x6CD3          // PLC命令起始位(通常为B6CD3)
#define PLC_CMD_BIT_COUNT       2               // 总共几个命令位(B6CD3=Start, B6CD4=Stop)
// === PLC 应答输出配置(PC -> PLC) ===
#define PLC_ACK_MAX_LIFE        25      // PLC响应信号最大保留周期数(每周期为 m_nIntervalMs 毫秒)
#define PLC_ACK_BASE_BIT        0x1060  // PLC应答起始地址(B1060表示B6CD3的应答;B1061表示B6CD4的应答)
// === PLC 应答输出配置(PC -> PLC) ===
#define PLC_ACK_MAX_LIFE        25              // PLC响应信号最大保留周期数(每周期为 m_nIntervalMs 毫秒)
#define PLC_ACK_BASE_BIT        0x1060          // PLC应答起始地址(B1060表示B6CD3的应答;B1061表示B6CD4的应答)
// === PLC软元件类型宏(用于应答、数据写入)===
#define PLC_BIT_DEVICE_TYPE     DeviceType::B   // 位操作设备类型(如M、B)
#define PLC_WORD_DEVICE_TYPE    DeviceType::W   // 字操作设备类型(如D、W)
// === PLC软元件类型宏(用于应答、数据写入)===
#define PLC_BIT_DEVICE_TYPE     DeviceType::B   // 位操作设备类型(如M、B)
#define PLC_WORD_DEVICE_TYPE    DeviceType::W   // 字操作设备类型(如D、W)
// === PLC结果寄存器地址配置 ===
#define PLC_RESULT_ADDR_START   0x37B0  // PLC结果寄存器起始地址(如W37B0)
#define PLC_RESULT_ADDR_COUNT   4       // 结果寄存器数量(如W37B0, W37B2, W37B4, W37B6)
// === PLC结果寄存器地址配置 ===
#define PLC_RESULT_ADDR_START   0x37B0          // PLC结果寄存器起始地址(如W37B0)
#define PLC_RESULT_ADDR_COUNT   4               // 结果寄存器数量(如W37B0, W37B2, W37B4, W37B6)
// === PLC 产品ID配置(PLC -> PC)===
#define PLC_PRODUCT_ID_ADDR      0x1B160   // 产品ID起始地址 (W1B160)
#define PLC_PRODUCT_ID_WORDS     10        // 产品ID长度(10个Word)
// === PLC 产品ID配置(PLC -> PC)===
#define PLC_PRODUCT_ID_ADDR      0x1B160        // 产品ID起始地址 (W1B160)
#define PLC_PRODUCT_ID_WORDS     10             // 产品ID长度(10个Word)
#define IS_RISING_EDGE(prev, curr) (!(prev) && (curr))
@@ -47,7 +47,7 @@
{
    m_pPlc = std::make_unique<CCCLinkIEControl>();
    if (!m_pPlc) {
        LOG_MSG(_T("PLC控制器初始化失败,无法创建 CCCLinkIEControl 实例。"), LOG_TYPE_ERROR);
      LOG_MSG(_T("PLC控制器初始化失败,无法创建 CCCLinkIEControl 实例。"), LOG_TYPE_ERROR);
        return false;
    }
@@ -56,7 +56,7 @@
        m_bConnected = false;
        CString strError;
        strError.Format(_T("PLC控制器连接失败,错误码:%d"), ret);
      strError.Format(_T("PLC控制器连接失败,错误码:%d"), ret);
        LOG_MSG(strError, LOG_TYPE_ERROR);
        return false;
@@ -94,7 +94,7 @@
bool CPLCSignalListener::Start()
{
    if (m_bRunning || !m_pPlc) {
        LOG_MSG(_T("PLC信号监听器已在运行或PLC控制器未初始化。"), LOG_TYPE_ERROR);
      LOG_MSG(_T("PLC信号监听器已在运行或PLC控制器未初始化。"), LOG_TYPE_ERROR);
        return false;
    }
@@ -164,7 +164,7 @@
        if (m_bHeartbeatLost) {
            m_bHeartbeatLost = false;
            LOG_MSG(_T("PLC心跳恢复!"), LOG_TYPE_SUCCESS);
         LOG_MSG(_T("PLC心跳恢复!"), LOG_TYPE_SUCCESS);
        }
        return true;
@@ -176,7 +176,7 @@
            if (!m_bHeartbeatLost) {
                m_bHeartbeatLost = true;
            m_nMissedHeartbeatCount = 0;
                LOG_MSG(_T("PLC心跳信号中断!"), LOG_TYPE_ERROR);
            LOG_MSG(_T("PLC心跳信号中断!"), LOG_TYPE_ERROR);
            }
            return false;
        }
@@ -236,7 +236,7 @@
            ::Sleep(m_nIntervalMs);
            CString strError;
            strError.Format(_T("PLC读取位数据失败,错误码:%d"), ret);
         strError.Format(_T("PLC读取位数据失败,错误码:%d"), ret);
            LOG_MSG(strError, LOG_TYPE_ERROR);
            continue;
@@ -244,7 +244,7 @@
        for (int i = 0; i < PLC_CMD_BIT_COUNT; ++i) {
            if (IS_RISING_EDGE(m_vecPrevBits[i], vecBits[i])) {
                // 上升沿触发
            // 上升沿触发
                switch (i) {
                case 0:
                    if (m_cbStart) {
@@ -258,7 +258,7 @@
                        std::string strProductID;
                        if (ReadProductID(strProductID)) {
                            CString msg;
                            msg.Format(_T("读取到产品ID:%s"), strProductID);
                     msg.Format(_T("读取到产品ID:%s"), strProductID);
                            LOG_MSG(msg, LOG_TYPE_SUCCESS);
                        }
                    }
@@ -292,17 +292,17 @@
bool CPLCSignalListener::WriteOutValues(const OutValuesArray& values)
{
    if (!m_pPlc || !m_bConnected) {
        LOG_MSG(_T("PLC未连接或未初始化,无法写入输出值。"), LOG_TYPE_ERROR);
      LOG_MSG(_T("PLC未连接或未初始化,无法写入输出值。"), LOG_TYPE_ERROR);
        return false;
    }
    if (PLC_RESULT_ADDR_COUNT != 4) {
        LOG_MSG(_T("PLC结果寄存器数量配置错误,必须为4个。"), LOG_TYPE_ERROR);
      LOG_MSG(_T("PLC结果寄存器数量配置错误,必须为4个。"), LOG_TYPE_ERROR);
        return false;
    }
    for (int i = 0; i < PLC_RESULT_ADDR_COUNT; ++i) {
        // 放大1000倍并四舍五入,转为PLC整数
      // 放大1000倍并四舍五入,转为PLC整数
        int32_t  nScaled = static_cast<int32_t>(std::round(values[i] * 1000.0));
        DWordContainer vec = { static_cast<uint32_t>(nScaled) };
@@ -310,7 +310,7 @@
        int ret = m_pPlc->WriteDWordDataEx(m_station, PLC_WORD_DEVICE_TYPE, nTargetAddr, vec);
        if (ret != 0) {
            CString msg;
            msg.Format(_T("写入OUT%d到地址%d失败,值=%.2f"), i + 1, nTargetAddr, values[i]);
         msg.Format(_T("写入OUT%d到地址%d失败,值=%.2f"), i + 1, nTargetAddr, values[i]);
            LOG_MSG(msg, LOG_TYPE_ERROR);
            return false;
        }
@@ -322,7 +322,7 @@
bool CPLCSignalListener::ReadProductID(std::string& strProductID)
{
    if (!m_pPlc || !m_bConnected) {
        LOG_MSG(_T("PLC未连接或未初始化,无法读取产品ID。"), LOG_TYPE_ERROR);
      LOG_MSG(_T("PLC未连接或未初始化,无法读取产品ID。"), LOG_TYPE_ERROR);
        return false;
    }
@@ -330,7 +330,7 @@
    int ret = m_pPlc->ReadWordDataEx(m_station, PLC_WORD_DEVICE_TYPE, PLC_PRODUCT_ID_ADDR, PLC_PRODUCT_ID_WORDS, vec);
    if (ret != 0 || vec.size() != PLC_PRODUCT_ID_WORDS) {
        CString msg;
        msg.Format(_T("读取产品ID失败,错误码=%d"), ret);
      msg.Format(_T("读取产品ID失败,错误码=%d"), ret);
        LOG_MSG(msg, LOG_TYPE_ERROR);
        return false;
    }
@@ -338,8 +338,8 @@
    strProductID.clear();
   strProductID.reserve(PLC_PRODUCT_ID_WORDS * 2);
    for (auto w : vec) {
        char c1 = static_cast<char>(w & 0xFF);          // 低字节
        char c2 = static_cast<char>((w >> 8) & 0xFF);   // 高字节
      char c1 = static_cast<char>(w & 0xFF);          // 低字节
      char c2 = static_cast<char>((w >> 8) & 0xFF);   // 高字节
        if (c1 == '\0') { 
            break;