开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 行业应用 > 邮电通讯系统 > 查看源码
IEC104link.h
资源名称：IEC60870-5-104.rar　[点击查看]
上传用户：tengfei
上传日期：2014-02-20
资源大小：423k
文件大小：6k
源码类别：

邮电通讯系统

开发平台：

Visual C++

IEC104link.h：源码内容
  1. #ifndef _IEC104link_
  2. #define _IEC104link_
  5. #include <winsock2.h>
  7. /////////////////////////////////////////////////////////////////////////////
  8. // CChanSock command target
  9. //class CPingclientDlg;
  10. class AFX_EXT_CLASS CBasechSocket
  11. {
  12. public:
  13. void Close();
  14. int Receive(char *buff,int bufflen);
  15. int Send(char *buff,int len);
  16. bool Create(UINT Serport);
  17. bool Accept();
  18. void thread_process();
  19. CBasechSocket();
  20. ~CBasechSocket();
  21. BOOL Connect( LPCTSTR lpszHostAddress, UINT nHostPort );
  22. BOOL ShutDown( int nHow = 1 );
  23. virtual void OnAccept(int nErrorCode);
  24. virtual void OnReceive(int nErrorCode);
  25. virtual void OnClose(int nErrorCode);
  26. HANDLE thread_handle;
  27. DWORD ThreadID;
  28. static void thread(void *pp);
  29. SOCKET sock,newsock;
  30. int length;
  31. struct sockaddr_in SockAddr;
  32. struct sockaddr tcpaddr;
  33. char buf[1024];
  34. int rval,len;
  35. char cli_name[64];
  36. char cli_ip[32];
  38. bool bConn;
  40. };
  42. #include "typedef.h"
  44. #define MAXLINKBUFF 249
  45. #define MAXSOCKLBUFF 4096
  46. #define MAXNUM_K 32
  47. //#define MAX_W 8
  48. #define SOCKDELAY 250
  49. #define CMD_CONN 0
  50. #define CMD_DISCONN 1
  51. #define CMD_USTOP   2
  52. #define CMD_USTART  3
  54. #define SOUR_
  55. #define APP2_
  56. #define INFO3_
  57. class AFX_EXT_CLASS CIEC104link:public CBasechSocket
  58. {
  59. public:
  60. _int MAX_K;
  61. _int MAX_W;
  62. HANDLE rxmutex;
  63. CIEC104link();
  64. ~CIEC104link();
  65. char HostAddress[32];
  66. _WORD port;
  67. _int GetSizeofInput_buffer(_int *OneFrameLen,_int *FrameNum);
  68. _int GetSizeofOutput_buffer(_int *OneFrameLen,_int *FrameNum);
  71. //Copy ASDU msg to the Input_buffer
  72. // When exit ,inputbuff_available=0;
  73. // if urgent equ 1 then ACD=1;
  74. bool ApplayerToLink(_BYTE *asbuff,_int aslen);// put msg into input_buffer
  75. bool ApplayerControltoLink(_BYTE cmd);
  76. // _BYTE  in_mutex; //0:available     1:unvailable 
  77. bool inputbuff_available;//0:unavailable   1:available
  78. virtual void On_init_Link_process(){};
  79. virtual void On_init_Sock_process(){};
  80. virtual void OnTxRemark()=0;
  81. virtual void OnRxRemark()=0;
  82. virtual void OnNoteRemark()=0;
  83. _int rxraw_length;
  84. _int rxraw_buffer[MAXSOCKLBUFF];
  85. _int GetLinkerTxRemark(_char * disp,_int Maxlen);
  86. _int GetLinkerRxRemark(_char * disp,_int Maxlen);
  87. _int GetLinkerNoteRemark(_char * disp,_int Maxlen);
  88. _char notestr[256];
  89. //The class inherited from this class,
  90. virtual void OnApplayer(_int counts)=0; //
  91. _int LinkToApplayer(_BYTE *asbuff,_int asmaxlen);// get msg from output_buffer , when exit outputbuff_available=0;
  92. bool outputbuff_available;//0:unavailable   1:available
  93. bool connected;
  94. bool started;
  95. bool proc_flag;
  96. _int timer_conn,TIMER_CONN;//30s
  97. _int TIMER_CLOSE;//15s
  98. _int TIMER_SFORMAT;//10s
  99. _int timer_Utest,TIMER_UTEST;//20
  100. HANDLE Ontimer_handle;
  101. _int Ontimercnt;
  102. protected:
  103. // void OnRxOneFrame(_BYTE *rxbuf,_int *rxlen);
  104. bool InitLink();
  105. bool CloseLink();
  106. private:
  107. _int I_confirm_cnt;
  108. bool I_nocontinue;
  111. _int timer_Confirm;
  112. bool timer_Confirmflag;
  113. _WORD Rxcnt;
  114. _WORD Txcnt;
  116. _int timer_U_Start;
  117. bool timer_U_Startflag;
  119. _int timer_U_Stop;
  120. bool timer_U_Stopflag;
  122. _int timer_U_Test;
  123. bool timer_U_Testflag;
  125. static void Ontimer_thread(void *pp);
  126. // void linkprocess();
  127. _int Sendtimercnt;
  130. typedef struct Inputstru
  131. {
  132. _int timer_close;
  133. bool timer_flag;
  134. _WORD Txcnt;
  135. _BYTE Input_buffer[MAXLINKBUFF];
  136. _int Inlength;
  137. } Input_Stru;
  139. Input_Stru In_area[MAXNUM_K];
  140. _int In_area_frm_num;
  142. typedef struct Outputstru
  143. {
  144. _BYTE Output_buffer[MAXLINKBUFF];
  145. _int Outlength;
  147. } Output_Stru;
  149. Output_Stru Out_area[MAXNUM_K];
  150. _int Out_area_frm_num;
  152. _BYTE rxbuffer[MAXSOCKLBUFF*2];
  153. _BYTE txbuffer[MAXSOCKLBUFF];
  154. _int rxlength;
  155. _int txlength;
  156. virtual void OnReceive(int nErrorCode);
  157. virtual void OnClose(int nErrorCode);
  159. void Start_process();
  160. void OnTimer();
  161. void SendProcess();
  162. _int RxOneBigFrame(_BYTE *rxbuf,_int maxbuflen);
  163. void DecodeOneBigFrame(_BYTE *bigrxbuf,_int *biglength);
  166. void DecodeFrame(_BYTE *rxbuf,_int rxlen);
  167. _int TxOneBigFrame(_BYTE *txbuf,_int txlen);
  168. _int EncodeFrame(_BYTE *txbuf);
  171. //when enter, rxbuff_dealing_flag=1;
  172. //when exit, rxbuff_dealing_flag=0 outputbuff_available=1;
  173. //make output_buffer full of msg
  174. // rxbuffer(msg: linker+ASDU)===>Output_buffer(msg: ASDU)
  175. _int IND_decodeApplayer(_BYTE *rxbuf,_int rxlen);
  179. //when enter
  180. //when exit,  inputbuff_available=1;
  181. //make output_buffer full of msg
  182. //Input_buffer(msg: ASDU)===>txbuffer(msg: linker+ ASDU)
  183. _int REQ_encodeApplayer(_BYTE *inputbuf,_int inputlen);//when enter, rxbuff_dealing_flag=1;when exit, rxbuff_dealing_flag=0
  184. bool rxbuff_dealing_flag;// 0:idle    1:busy
  185. void TimerIncrease();
  186. void scan_closeTimeout();
  187. void scan_timer_Sformat();
  188. void scan_timer_U_test();
  189. void Send_I_frame();
  190. void Recv_I_frame(_BYTE *rxbuf,bool * I_nocont);
  191. void Recv_Utestcon_frame();
  193. void Recv_Utest_frame();
  195. void Recv_Ustartcon_frame();
  197. void Recv_Ustopcon_frame();
  199. void Recv_S_format(_BYTE *rxbuf);
  201. void Send_U_Start();
  203. void Send_Ustop_frame();
  205. void Send_S_frame();
  207. void Send_Utest_frame();
  209. void Send_Utestcon_frame();
  210. };
  212. class AFX_EXT_CLASS CIEC104ASDU:public CIEC104link
  213. {
  214. public:
  215. void InitInstance();
  216. bool has_been_registered;
  217. WORD limit_rtunum;
  218. WORD limit_days;
  219. char m_hardno[128];
  220. bool ReadRegisterKey();
  222. CIEC104ASDU();
  223. ~CIEC104ASDU();
  224. virtual void On_Recv_ASDU_Msg(BYTE *recvbuf,int len ){};//显示接收报文
  225. virtual void On_SendMsg(BYTE *msgbuf,int len){};
  226. virtual void On_RecvMsg(BYTE *msgbuf,int len){};
  227. virtual void On_ErrorMsg(char *msgbuf){};
  230. virtual void OnApplayer(_int counts);
  231. virtual void OnTxRemark();
  232. virtual void OnRxRemark();
  233. virtual void OnNoteRemark();
  236. BYTE asdispRxbuf[MAXLINKBUFF*MAXNUM_K];
  237. _BYTE asdispTxbuf[MAXLINKBUFF*MAXNUM_K];
  238. _int asdispRxlen;
  239. _int asdispTxlen;
  241. BYTE asnoteRxbuf[MAXLINKBUFF*MAXNUM_K];
  242. _int asnoteRxlen;
  244. _BYTE asRxbuf[MAXLINKBUFF*MAXNUM_K];
  245. _BYTE asTxbuf[MAXLINKBUFF];
  246. _int asRxlen;
  247. _int asTxlen;
  248. bool I_need;
  249. bool Cmd_need;
  250. _BYTE Cmd_need_code;
  252. };
  256. #endif