iec104linkh.txt

电力系统104规约源码,C++实现

www.pudn.com > 104Master.rar > IEC104link.h

   

#ifndef		_IEC104link_ 
#define		_IEC104link_ 
 
 
#include  
 
///////////////////////////////////////////////////////////////////////////// 
// CChanSock command target 
//class CPingclientDlg; 
class AFX_EXT_CLASS CBasechSocket 
{ 
public: 
	void Close(); 
	int Receive(char *buff,int bufflen); 
	int Send(char *buff,int len); 
	bool Create(UINT Serport); 
	bool Accept(); 
	void thread_process(); 
	CBasechSocket(); 
	~CBasechSocket(); 
	BOOL Connect( LPCTSTR lpszHostAddress, UINT nHostPort ); 
	BOOL ShutDown( int nHow = 1 ); 
	virtual void OnAccept(int nErrorCode); 
	virtual void OnReceive(int nErrorCode); 
	virtual void OnClose(int nErrorCode); 
	HANDLE thread_handle; 
	DWORD ThreadID; 
	static void thread(void *pp); 
	SOCKET sock,newsock; 
	int length; 
	struct sockaddr_in SockAddr; 
	struct sockaddr tcpaddr; 
	char buf[1024]; 
	int rval,len; 
	char cli_name[64]; 
	char cli_ip[32]; 
 
	bool bConn; 
	 
}; 
 
#include "typedef.h" 
 
#define MAXLINKBUFF 249 
#define MAXSOCKLBUFF 4096 
#define MAXNUM_K 32 
//#define MAX_W 8 
#define SOCKDELAY 250 
#define CMD_CONN	0 
#define CMD_DISCONN 1 
#define CMD_USTOP   2 
#define CMD_USTART  3 
 
#define SOUR_ 
#define APP2_ 
#define INFO3_ 
class AFX_EXT_CLASS CIEC104link:public CBasechSocket 
{ 
public: 
	_int MAX_K; 
	_int MAX_W; 
	HANDLE rxmutex; 
	CIEC104link(); 
	~CIEC104link(); 
	char HostAddress[32]; 
	_WORD port; 
	_int GetSizeofInput_buffer(_int *OneFrameLen,_int *FrameNum); 
	_int GetSizeofOutput_buffer(_int *OneFrameLen,_int *FrameNum); 
 
	 
	//Copy ASDU msg to the Input_buffer 
	// When exit ,inputbuff_available=0; 
	// if urgent equ 1 then ACD=1; 
	bool ApplayerToLink(_BYTE *asbuff,_int aslen);// put msg into input_buffer 
	bool ApplayerControltoLink(_BYTE cmd); 
//	_BYTE  in_mutex; //0:available     1:unvailable  
	bool inputbuff_available;//0:unavailable   1:available 
	virtual void On_init_Link_process(){}; 
	virtual void On_init_Sock_process(){}; 
	virtual void OnTxRemark()=0; 
	virtual void OnRxRemark()=0; 
	virtual void OnNoteRemark()=0; 
	_int rxraw_length; 
	_int rxraw_buffer[MAXSOCKLBUFF]; 
	_int GetLinkerTxRemark(_char * disp,_int Maxlen); 
	_int GetLinkerRxRemark(_char * disp,_int Maxlen); 
	_int GetLinkerNoteRemark(_char * disp,_int Maxlen); 
	_char notestr[256]; 
	//The class inherited from this class, 
	virtual void OnApplayer(_int counts)=0; // 
	_int LinkToApplayer(_BYTE *asbuff,_int asmaxlen);// get msg from output_buffer , when exit outputbuff_available=0; 
	bool outputbuff_available;//0:unavailable   1:available 
	bool connected; 
	bool started; 
	bool proc_flag; 
	_int	timer_conn,TIMER_CONN;//30s 
	_int	TIMER_CLOSE;//15s 
	_int	TIMER_SFORMAT;//10s 
	_int	timer_Utest,TIMER_UTEST;//20 
	HANDLE Ontimer_handle; 
	_int Ontimercnt; 
protected: 
//	void OnRxOneFrame(_BYTE *rxbuf,_int *rxlen); 
	bool InitLink(); 
	bool CloseLink(); 
private: 
	_int I_confirm_cnt; 
	bool I_nocontinue; 
 
 
	_int timer_Confirm; 
	bool timer_Confirmflag; 
	_WORD Rxcnt; 
	_WORD Txcnt; 
	 
	_int timer_U_Start; 
	bool timer_U_Startflag; 
 
	_int timer_U_Stop; 
	bool timer_U_Stopflag; 
 
	_int timer_U_Test; 
	bool timer_U_Testflag; 
 
	static void Ontimer_thread(void *pp); 
//	void linkprocess(); 
	_int Sendtimercnt; 
 
 
	typedef struct Inputstru 
	{ 
		_int timer_close; 
		bool timer_flag; 
		_WORD Txcnt; 
		_BYTE Input_buffer[MAXLINKBUFF]; 
		_int Inlength; 
	} Input_Stru; 
 
	Input_Stru In_area[MAXNUM_K]; 
	_int In_area_frm_num; 
 
	typedef struct Outputstru 
	{ 
	_BYTE Output_buffer[MAXLINKBUFF]; 
	_int Outlength; 
 
	} Output_Stru; 
 
	Output_Stru Out_area[MAXNUM_K]; 
	_int Out_area_frm_num; 
 
	_BYTE rxbuffer[MAXSOCKLBUFF*2]; 
	_BYTE txbuffer[MAXSOCKLBUFF]; 
	_int rxlength; 
	_int txlength; 
	virtual void OnReceive(int nErrorCode); 
	virtual void OnClose(int nErrorCode); 
 
	void Start_process(); 
	void OnTimer(); 
	void SendProcess(); 
	_int RxOneBigFrame(_BYTE *rxbuf,_int maxbuflen); 
	void DecodeOneBigFrame(_BYTE *bigrxbuf,_int *biglength); 
	 
 
	void DecodeFrame(_BYTE *rxbuf,_int rxlen); 
	_int TxOneBigFrame(_BYTE *txbuf,_int txlen); 
	_int EncodeFrame(_BYTE *txbuf); 
 
 
	//when enter, rxbuff_dealing_flag=1; 
	//when exit, rxbuff_dealing_flag=0 outputbuff_available=1; 
	//make output_buffer full of msg 
	// rxbuffer(msg: linker+ASDU)===>Output_buffer(msg: ASDU) 
	_int IND_decodeApplayer(_BYTE *rxbuf,_int rxlen); 
	 
	 
	 
	//when enter 
	//when exit,  inputbuff_available=1; 
	//make output_buffer full of msg 
	//Input_buffer(msg: ASDU)===>txbuffer(msg: linker+ ASDU) 
	_int REQ_encodeApplayer(_BYTE *inputbuf,_int inputlen);//when enter, rxbuff_dealing_flag=1;when exit, rxbuff_dealing_flag=0 
	bool rxbuff_dealing_flag;// 0:idle    1:busy 
	void TimerIncrease(); 
	void scan_closeTimeout(); 
	void scan_timer_Sformat(); 
	void scan_timer_U_test(); 
	void Send_I_frame(); 
	void Recv_I_frame(_BYTE *rxbuf,bool * I_nocont); 
	void Recv_Utestcon_frame(); 
 
	void Recv_Utest_frame(); 
 
	void Recv_Ustartcon_frame(); 
 
	void Recv_Ustopcon_frame(); 
 
	void Recv_S_format(_BYTE *rxbuf); 
 
	void Send_U_Start(); 
 
	void Send_Ustop_frame(); 
 
	void Send_S_frame(); 
 
	void Send_Utest_frame(); 
 
	void Send_Utestcon_frame(); 
}; 
 
class AFX_EXT_CLASS CIEC104ASDU:public CIEC104link 
{ 
public: 
	void InitInstance(); 
	bool has_been_registered; 
	WORD limit_rtunum; 
	WORD limit_days; 
	char m_hardno[128]; 
	bool ReadRegisterKey(); 
 
	CIEC104ASDU(); 
	~CIEC104ASDU(); 
	virtual void On_Recv_ASDU_Msg(BYTE *recvbuf,int len ){};//显示接收报文 
	virtual void On_SendMsg(BYTE *msgbuf,int len){}; 
	virtual void On_RecvMsg(BYTE *msgbuf,int len){}; 
	virtual void On_ErrorMsg(char *msgbuf){}; 
 
	 
	virtual void OnApplayer(_int counts); 
	virtual void OnTxRemark(); 
	virtual void OnRxRemark(); 
	virtual void OnNoteRemark(); 
 
 
	BYTE asdispRxbuf[MAXLINKBUFF*MAXNUM_K]; 
	_BYTE asdispTxbuf[MAXLINKBUFF*MAXNUM_K]; 
	_int asdispRxlen; 
	_int asdispTxlen; 
 
	BYTE asnoteRxbuf[MAXLINKBUFF*MAXNUM_K]; 
	_int asnoteRxlen; 
 
	_BYTE asRxbuf[MAXLINKBUFF*MAXNUM_K]; 
	_BYTE asTxbuf[MAXLINKBUFF]; 
	_int asRxlen; 
	_int asTxlen; 
	bool I_need; 
	bool Cmd_need; 
	_BYTE Cmd_need_code; 
 
}; 
 
 
 
#endif