#pragma once
|
|
#include "CCLinkIEControl.h"
|
|
#include <thread>
|
#include <atomic>
|
#include <functional>
|
#include <vector>
|
|
using OutValuesArray = std::array<double, 4>;
|
using Callback = std::function<void()>;
|
using AnalyzeCallback = std::function<OutValuesArray()>;
|
using LogCallback = std::function<void(const CString& strContent, int type)>;
|
|
class CPLCSignalListener
|
{
|
public:
|
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:
|
/**
|
* @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:
|
// === PLC ͨÐźËÐĶÔÏó ===
|
std::unique_ptr<CCCLinkIEControl> m_pPlc; // PLC ͨÐÅ¿ØÖÆÆ÷
|
StationIdentifier m_station; // PLC Õ¾ºÅ
|
std::atomic<bool> m_bConnected{ false }; // ÊÇ·ñ³É¹¦Á¬½Ó
|
|
// === ¿ØÖƲÎÊý ===
|
int m_nIntervalMs = 200; // ÂÖѯÖÜÆÚ£¨ms£©
|
|
// === ÃüÁî´¥·¢×´Ì¬»º´æ ===
|
std::vector<bool> m_vecPrevBits; // ÉÏÒ»ÖÜÆÚµÄÃüÁîλ״̬£¨ÓÃÓÚ¼ì²âÉÏÉýÑØ£©
|
|
// === »Øµ÷º¯Êý£¨¿ØÖÆ/¼ÆËã/ÈÕÖ¾£©===
|
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 µôÏߣ©
|
};
|
