From 1efb832676e8ad27e7a495dba6ffc19479e0c76f Mon Sep 17 00:00:00 2001
From: LAPTOP-SNT8I5JK\Boounion <Chenluhua@qq.com>
Date: 星期四, 04 九月 2025 15:51:33 +0800
Subject: [PATCH] 1.机器配方参数的获取；
---
SourceCode/Bond/SGMeasurement/PLCSignalListener.h | 150 +++++++++++++++++++++++++++++++++++++++++++++----
1 files changed, 136 insertions(+), 14 deletions(-)
diff --git a/SourceCode/Bond/SGMeasurement/PLCSignalListener.h b/SourceCode/Bond/SGMeasurement/PLCSignalListener.h
index cce8782..fe8638b 100644
--- a/SourceCode/Bond/SGMeasurement/PLCSignalListener.h
+++ b/SourceCode/Bond/SGMeasurement/PLCSignalListener.h
@@ -18,39 +18,161 @@
CPLCSignalListener();
~CPLCSignalListener();
+ /**
+ * @brief 初始化 PLC 信号监听器。
+ *
+ * @param station 目标 PLC 的站号标识符。
+ * @param nIntervalMs 轮询周期（单位：毫秒），默认 200ms。
+ * @return true 初始化成功。
+ * @return false 初始化失败。
+ */
bool Initialize(StationIdentifier station, int nIntervalMs = 200);
+ /**
+ * @brief 设置开始命令的回调函数（对应 PLC 的 Start 信号）。
+ *
+ * @param cb 用户自定义的开始回调函数。
+ */
void SetStartCallback(Callback cb);
+
+ /**
+ * @brief 设置停止命令的回调函数（对应 PLC 的 Stop 信号）。
+ *
+ * @param cb 用户自定义的停止回调函数。
+ */
void SetStopCallback(Callback cb);
+
+ /**
+ * @brief 设置分析计算回调函数，在接收到停止命令后调用。
+ *
+ * @param cb 返回计算结果数组（OUT1~OUT4）的函数。
+ */
void SetAnalyzeCallback(AnalyzeCallback cb);
+
+ /**
+ * @brief 设置日志输出回调函数。
+ *
+ * @param cb 用户提供的日志输出接口（包含日志内容和日志类型）。
+ */
void SetLogCallback(LogCallback cb);
+ /**
+ * @brief 启动信号监听线程。
+ *
+ * @return true 启动成功。
+ * @return false 启动失败（可能已运行或未初始化）。
+ */
bool Start();
+
+ /**
+ * @brief 停止信号监听线程。
+ */
void Stop();
+ /**
+ * @brief 向 PLC 写入分析结果值（通常为 OUT1 ~ OUT4）。
+ *
+ * @param values 包含四个 double 类型的结果值，将转换为整数后写入 PLC。
+ * @return true 写入成功。
+ * @return false 写入失败。
+ */
bool WriteOutValues(const OutValuesArray& values);
private:
- void PulseBitDevice(DeviceType eDevType, short nBitNo, int nDelayMs = 50);
+ /**
+ * @brief 输出日志信息（封装日志回调）。
+ *
+ * @param strText 日志内容文本。
+ * @param nType 日志类型（LOG_TYPE_NORMAL / ERROR / WARNING 等）。
+ */
+ void LogInfo(const CString& strText, int nType);
+
+ /**
+ * @brief 向 PLC 写入心跳信号（交替位）。
+ *
+ * @return true 写入成功。
+ * @return false 写入失败（如未连接）。
+ */
+ bool SendHeartbeat();
+
+ /**
+ * @brief 检查从 PLC 读取到的心跳信号是否发生变化。
+ *
+ * @return true 心跳有变化（PLC 正常在线）。
+ * @return false 心跳无变化（可能离线）。
+ */
+ bool CheckHeartbeat();
+
+ /**
+ * @brief 监控 PLC 心跳是否中断，并自动记录状态。
+ *
+ * @return true PLC 在线或在允许的未响应次数内。
+ * @return false PLC 心跳中断，超过允许阈值。
+ */
+ bool MonitorHeartbeat();
+
+ /**
+ * @brief 启动心跳监控线程（独立于信号监听线程）。
+ */
+ void StartHeartbeatMonitor();
+
+ /**
+ * @brief 停止心跳监控线程。
+ */
+ void StopHeartbeatMonitor();
+
+ /**
+ * @brief 向指定软元件位写入一个脉冲（先写1，延时后自动写0）。
+ *
+ * @param eDevType 位软元件类型（如 M/B）。
+ * @param nBitNo 位地址编号。
+ * @param nDelayMs 脉冲持续时间，默认50毫秒。
+ */
+ void PulseBitDevice(DeviceType eDevType, long nBitNo, int nDelayMs = 50);
+
+ /**
+ * @brief 管理 ACK 响应的生命周期，超时自动清除。
+ *
+ * @param i 控制位索引（0=Start，1=Stop）。
+ * @param bCurrTriggerBit 当前从 PLC 读取到的触发位状态。
+ */
void HandleAckLife(int i, bool bCurrTriggerBit);
+
+ /**
+ * @brief 主监听线程逻辑，循环读取 PLC 控制信号并处理触发。
+ */
void ThreadProc();
private:
- std::unique_ptr<CCCLinkIEControl> m_pPlc;
- StationIdentifier m_station;
- int m_nIntervalMs = 200;
+ // === PLC 通信核心对象 ===
+ std::unique_ptr<CCCLinkIEControl> m_pPlc; // PLC 通信控制器
+ StationIdentifier m_station; // PLC 站号
+ std::atomic<bool> m_bConnected{ false }; // 是否成功连接
- std::atomic<bool> m_bConnected{ false };
- std::atomic<bool> m_bRunning{ false };
- std::thread m_thread;
- std::vector<bool> m_vecPrevBits;
+ // === 控制参数 ===
+ int m_nIntervalMs = 200; // 轮询周期（ms）
- std::array<bool, 2> m_vecAckSent = { false, false }; // 是否已发送 M10/M11
- std::array<int, 2> m_vecAckCounter = { 0, 0 }; // 计数器，超时自动清除
+ // === 命令触发状态缓存 ===
+ std::vector<bool> m_vecPrevBits; // 上一周期的命令位状态（用于检测上升沿）
- Callback m_cbStart;
- Callback m_cbStop;
- AnalyzeCallback m_cbAnalyze;
- LogCallback m_cbLog;
+ // === 回调函数（控制/计算/日志）===
+ Callback m_cbStart; // Start 命令回调
+ Callback m_cbStop; // Stop 命令回调
+ AnalyzeCallback m_cbAnalyze; // Analyze 计算回调（返回 OUT1~OUT4）
+ LogCallback m_cbLog; // 日志输出回调
+
+ // === 主线程控制 ===
+ std::atomic<bool> m_bRunning{ false }; // 主监听线程是否运行
+ std::thread m_thread; // 主监听线程对象
+
+ // === ACK 信号状态 ===
+ std::array<bool, 2> m_vecAckSent = { false, false }; // 是否已发送应答信号（B10/B11）
+ std::array<int, 2> m_vecAckCounter = { 0, 0 }; // 对应应答信号的生命周期计数器
+
+ // === 心跳检测相关 ===
+ std::thread m_heartbeatThread; // 心跳检测线程对象
+ std::atomic<bool> m_bHeartbeatRunning = false; // 心跳线程运行标志
+ std::atomic<bool> m_bHeartbeatLost = false; // 心跳丢失标志
+ int m_nMissedHeartbeatCount = 0; // 心跳未变化次数（用于检测 PLC 掉线）
};
--
Gitblit v1.9.3