#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();
|
|
bool Initialize(StationIdentifier station, int nIntervalMs = 200);
|
|
void SetStartCallback(Callback cb);
|
void SetStopCallback(Callback cb);
|
void SetAnalyzeCallback(AnalyzeCallback cb);
|
void SetLogCallback(LogCallback cb);
|
|
bool Start();
|
void Stop();
|
|
bool WriteOutValues(const OutValuesArray& values);
|
|
private:
|
void PulseBitDevice(DeviceType eDevType, short nBitNo, int nDelayMs = 50);
|
void HandleAckLife(int i, bool bCurrTriggerBit);
|
void ThreadProc();
|
|
private:
|
std::unique_ptr<CCCLinkIEControl> m_pPlc;
|
StationIdentifier m_station;
|
int m_nIntervalMs = 200;
|
|
std::atomic<bool> m_bConnected{ false };
|
std::atomic<bool> m_bRunning{ false };
|
std::thread m_thread;
|
std::vector<bool> m_vecPrevBits;
|
|
std::array<bool, 2> m_vecAckSent = { false, false }; // ÊÇ·ñÒÑ·¢ËÍ M10/M11
|
std::array<int, 2> m_vecAckCounter = { 0, 0 }; // ¼ÆÊýÆ÷£¬³¬Ê±×Ô¶¯Çå³ý
|
|
Callback m_cbStart;
|
Callback m_cbStop;
|
AnalyzeCallback m_cbAnalyze;
|
LogCallback m_cbLog;
|
};
|
