#pragma once
|
|
#if _MSC_VER > 1000
|
#pragma once
|
#endif // _MSC_VER > 1000
|
|
#include <vector>
|
#include "TimerThreadPool.h"
|
|
enum SEND_MESSAGE_SECTION {SEND_MESSAGE_ALL=0,SEND_MESSAGE_CONTROLSIGNAL,SEND_MESSAGE_ALARM,SEND_MESSAGE_REVIEWSIGNAL,SEND_MESSAGE_UNKNOWN};
|
|
class CPostSendMessage
|
{
|
public:
|
CPostSendMessage(){Reset();}
|
virtual ~CPostSendMessage(){;}
|
void Reset()
|
{
|
nSignal = nValue = -1;
|
emSection = SEND_MESSAGE_UNKNOWN;
|
}
|
|
SEND_MESSAGE_SECTION emSection;
|
int nSignal;
|
int nValue;
|
};
|
|
class CDisableSendMessage : public CPostSendMessage
|
{
|
public:
|
CDisableSendMessage(){Reset();}
|
virtual ~CDisableSendMessage(){;}
|
void Reset()
|
{
|
CPostSendMessage::Reset();
|
dwOntime = dwStart = 0;
|
}
|
|
DWORD dwOntime;
|
DWORD dwStart;
|
};
|
|
|
interface IPLCSendInterface2Parent
|
{
|
virtual void SendMSG_Received(CPostSendMessage *pSendMSG) = 0;
|
};
|
|
/////////////////////////////////////////////////////////////////////////////
|
// CThread_SendMSG thread
|
|
#define PAD_RECIPE_NAME_CNT 200
|
class CThread_SendMSG : public CTimerThreadPool
|
{
|
public:
|
CThread_SendMSG(DWORD dwPeriod=15); // protected constructor used by dynamic creation
|
virtual ~CThread_SendMSG();
|
|
public:
|
BOOL CreateThread();
|
void SetIN2P(IPLCSendInterface2Parent *pN2M){m_pS2M=pN2M;}
|
|
std::vector<CPostSendMessage> *GetVecSendMSG(){return &m_VecSendMSG;}
|
int AddSendMSG(SEND_MESSAGE_SECTION emSection,int nSignal, int nValue);
|
|
std::vector<CDisableSendMessage> *GetVecDisableMSG(){return &m_VecDisableMSG;}
|
int AddDisableMSG(SEND_MESSAGE_SECTION emSection,int nSignal, int nValue, DWORD dwOntime);
|
|
BOOL ClearMSG();
|
|
virtual void TimerThreadProcess(PVOID pParameter);
|
|
protected:
|
CCriticalSection m_csNetMSG;
|
CCriticalSection m_csDisableMSG;
|
IPLCSendInterface2Parent *m_pS2M;
|
std::vector<CPostSendMessage> m_VecSendMSG;
|
std::vector<CDisableSendMessage> m_VecDisableMSG;
|
|
};
|
