pmacmas.h

一个通讯管理机的源代码。比较好用。推荐

#ifndef _PMACMAS_H
#define _PMACMAS_H

#include "msystem.h"
#include "appservice.h"
#include "allmgr.h"


class CPMACMas : public CMAppService{
public:
	CPMACMas(CAllMgr* pAllMgr,CSerialPortDef* pChannel)
		: CMAppService(pAllMgr,pChannel->m_wChannelNo,pChannel->m_strChannelName)
		, m_DLService(pChannel)
	{
		m_break=0;//add by lisheng
		m_break1=0;//add by lisheng
		m_break2=0;//add by lisheng
		m_break3=0;//add by lisheng
		m_bySendOrder = 0;
		m_bySendNo = 0;
		m_byCID = 0;
		m_byLoopEnd=1;
        m_byLoopEndDEF=1;  //add by lisheng
		m_bySelect820=1;
		m_bIsAck = FALSE;
		m_tmRectify.GetCurrentTime();
		m_tmRectify += CTimeValSpan(0,0,-2,0);
		m_bFirst = true;
		for (WORD w=0;w<256;w++)
		{
			m_wBreakCount[w] = 5;
		}
	}
	~CPMACMas();
	bool Init();
	bool YK(WORD wDevNo,BYTE byRoute,bool bIsOn);
//	CFrame* GetEchoFrame() {return &m_frmEcho;}
	bool GetFV(WORD wDevNo,BYTE*& pbyData,WORD& wLength,WORD wFuncCode=0) {return false;}
	bool PutFV(WORD wDevNo,BYTE* pFixVal,WORD bySize,WORD wFuncCode=0){return false;}
	void Query();
	
	bool GetStreamNode(CDataNode*& pdnStream)
	{
		return m_DLService.GetStreamNode(pdnStream);
	}

protected:
	BYTE m_bySendOrder;
	BYTE m_byCID;
    BYTE m_break; //add by lisheng
	BYTE m_break1; //add by lisheng
	BYTE m_break2; //add by lisheng
	BYTE m_break3; //add by lisheng
	BYTE m_break4; //add by lisheng
	BYTE m_break5; //add by lisheng
	BYTE m_break6; //add by lisheng
	BYTE m_byLoopEnd;//2007.03.15
    BYTE m_byLoopEndDEF;//2007.03.29
    BYTE m_bySelect820;//2007.03.29
	CModbusDLL m_DLService;
	BYTE		m_bySendNo;
	BYTE		m_byQueryNo;
	CTimeVal	m_tmRectify;
	BYTE        m_byFrameType;
	void Get720Event(BYTE byAddr,BYTE bySOENum);
	void Get9900Event(BYTE byAddr);
	void GetDCRJNext(BYTE byAddr);
	void GetData(BYTE byAddr,BYTE byType);

	void Exp720Data(BYTE byAddr,BYTE* pbyData,WORD wSize);
	void Exp100ENData(BYTE byAddr,BYTE* pbyData,WORD wSize);
	void Exp9900EData(BYTE byAddr,BYTE* pbyData,WORD wSize);
	void Exp9900Data(BYTE byAddr,BYTE* pbyData,WORD wSize);
	void Exp720EventData(BYTE byAddr,BYTE* pbyData,WORD wSize);
	void Exp9900EventData(BYTE byAddr,BYTE* pbyData,WORD wSize);
	void Exp9900NData(BYTE byAddr,BYTE*	pbyData,WORD wSize);
	void Exp600BData(BYTE byAddr,BYTE*	pbyData,WORD wSize);
	void ExpPDM800Data(BYTE byAddr,BYTE*	pbyData,WORD wSize);//add by lisheng
	void ExpPDM803AData(BYTE byAddr,BYTE*	pbyData,WORD wSize);//add by lisheng
	void ExpDDEFData(BYTE byAddr,BYTE*	pbyData,WORD wSize);//add by lisheng
	void ExpDDEF1Data(BYTE byAddr,BYTE*	pbyData,WORD wSize);//add by lisheng
	void Exp600AData(BYTE byAddr,BYTE*	pbyData,WORD wSize);
	void ExpPMAC303Data(BYTE byAddr,BYTE*	pbyData,WORD wSize);
	void ExpPMAC503Data(BYTE byAddr,BYTE*	pbyData,WORD wSize);
	void ExpPMAC503EData(BYTE byAddr,BYTE*	pbyData,WORD wSize);
	void ExpFJTWKYData(BYTE byAddr,BYTE*	pbyData,WORD wSize);
	void ExpZGDWKYData(BYTE byAddr,BYTE*	pbyData,WORD wSize);
	void ExpDCRJData(BYTE byAddr,BYTE*	pbyData,WORD wSize,WORD wStartAddr);

	void GetLDWKYYX(BYTE byAddr);
	void ExpLDWKYYX(BYTE byAddr,BYTE*	pbyData,WORD wSize);
	void ExpLDWKYYC(BYTE byAddr,BYTE*	pbyData,WORD wSize);

	void GetREF542plusYX1(BYTE byAddr);  //add by lisheng
	void ExpREF542plusYX1(BYTE byAddr,BYTE*	pbyData,WORD wSize); //add by lisheng
	void GetREF542plusYX2(BYTE byAddr);  //add by lisheng
	void ExpREF542plusYX2(BYTE byAddr,BYTE*	pbyData,WORD wSize); //add by lisheng
	void GetREF542plusYX3(BYTE byAddr);  //add by lisheng
	void ExpREF542plusYX3(BYTE byAddr,BYTE*	pbyData,WORD wSize); //add by lisheng
	void GetREF542plusYX(BYTE byAddr);
	void ExpREF542plusYX(BYTE byAddr,BYTE*	pbyData,WORD wSize);
	void ExpREF542plusYC(BYTE byAddr,BYTE*	pbyData,WORD wSize);
    
	void GetREF543plusYX1(BYTE byAddr);  //add by lisheng
	void ExpREF543plusYX1(BYTE byAddr,BYTE*	pbyData,WORD wSize); //add by lisheng
	void GetREF543plusYX2(BYTE byAddr);  //add by lisheng
	void ExpREF543plusYX2(BYTE byAddr,BYTE*	pbyData,WORD wSize); //add by lisheng
	void GetREF543plusYX3(BYTE byAddr);  //add by lisheng
	void ExpREF543plusYX3(BYTE byAddr,BYTE*	pbyData,WORD wSize); //add by lisheng
	void GetREF543plusYX(BYTE byAddr);
	void ExpREF543plusYX(BYTE byAddr,BYTE*	pbyData,WORD wSize);
	void ExpREF543plusYC(BYTE byAddr,BYTE*	pbyData,WORD wSize);

	bool ReadCoil(BYTE byAddr,WORD wSRegAddr,BYTE byCount);
	void ExpWGKYC(BYTE byAddr,BYTE*	pbyData,WORD wSize);
	void GetJBK3000YX(BYTE byAddr);
	void ExpJBK3000YC(BYTE byAddr,BYTE*	pbyData,WORD wSize);
	void ExpJBK3000YX(BYTE byAddr,BYTE*	pbyData,WORD wSize);

	void Gethlk2YX(BYTE byAddr);
	void Exphlk2YC(BYTE byAddr,BYTE*	pbyData,WORD wSize);
	void Exphlk2YX(BYTE byAddr,BYTE*	pbyData,WORD wSize);

	void GetTTC310YX(BYTE byAddr);
	void ExpTTC310YC(BYTE byAddr,BYTE*	pbyData,WORD wSize);
	void ExpTTC310YX(BYTE byAddr,BYTE*	pbyData,WORD wSize);

	void ExpWKY0Data(BYTE byAddr,BYTE* pbyData,WORD wSize);

	void GetGKJ0YX(BYTE byAddr);
	void ExpGKJ0YC(BYTE byAddr,BYTE*	pbyData,WORD wSize);
	void ExpGKJ0YX(BYTE byAddr,BYTE*	pbyData,WORD wSize);
	
	void ExpSepam20_B21YC(BYTE byAddr,BYTE*	pbyData,WORD wSize);
	
	void ExpSepam40_S40YC(BYTE byAddr,BYTE*	pbyData,WORD wSize);

	void SyncClock();
	bool m_bIsAck;
	BYTE m_byExchanged;
	WORD m_wBreakCount[256];
	bool m_bFirst;
private:
	static void* PMACMaster(void *pVoid);
};
#endif