| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495 |
- #pragma once
- #include <afxwin.h>
- //#include <atlbase.h>
- #pragma warning(push)
- #pragma warning(disable:4995)
- #include <list>
- #pragma warning(pop)
- #include "CritSection.h"
- #include "SocketHandle.h"
- #include "SocketServerImpl.h"
- #if defined(SOCKHANDLE_USE_OVERLAPPED)
- #include "AsyncSocketServerImpl.h"
- #endif
- #include "BaseVar.h"
- namespace ServerSocket
- {
- typedef std::list<SOCKET> CSocketList;
- class CServerSocket :
- public CDialog,
- public ISocketServerHandler
- {
- #if defined(SOCKHANDLE_USE_OVERLAPPED)
- typedef ASocketServerImpl<ISocketServerHandler> CSocketServer;
- #else
- typedef SocketServerImpl<ISocketServerHandler> CSocketServer;
- #endif
- friend CSocketServer;
- protected:
- // ISocketServerHandler
- virtual void OnThreadBegin(CSocketHandle* pSH);
- virtual void OnThreadExit(CSocketHandle* pSH);
- virtual void OnAddConnection(CSocketHandle* pSH, SOCKET newSocket);
- virtual void OnDataReceived(CSocketHandle* pSH, const BYTE* pbData, DWORD dwCount, const SockAddrIn& addr);
- virtual void OnConnectionFailure(CSocketHandle* pSH, SOCKET newSocket);
- virtual void OnConnectionDropped(CSocketHandle* pSH);
- virtual void OnConnectionError(CSocketHandle* pSH, DWORD dwError);
- protected:
- void GetAddress(const SockAddrIn& addrIn, CString& rString) const;
- bool GetDestination(SockAddrIn& addrIn) const;
- public:
- CServerSocket(void);
- ~CServerSocket(void);
- public:
- int SvrStart(CString strPort);
- void SocketStop();
- void SocketSend(CSocketHandle &sockHandle, unsigned char *pMsg, int iLength);
- protected:
- int m_nSockType;
- int m_nMode;
- void ProcessData(CSocketHandle &sockHandle, const BYTE* pData, DWORD nLen);
- int OnCmdProcess(CSocketHandle &sockHandle, void *pData);
- int ProcessResDevOnline(CSocketHandle &sockHandle, void *pBuffer);
- int ProcessResSingleVarOnline(CSocketHandle &sockHandle, void *pBuffer);
- int ProcessResMulVarOnline(CSocketHandle &sockHandle, void *pBuffer);
- int ProcessResReadSingleVarData(CSocketHandle &sockHandle, void *pBuffer);
- int ProcessResReadMulVarData(CSocketHandle &sockHandle, void *pBuffer);
- int ProcessResWriteSingleVarData(CSocketHandle &sockHandle, void *pBuffer);
- int PrcocessResWriteMulVarData(CSocketHandle &sockHandle, void *pBuffer);
- int ProcessResSoftDog(CSocketHandle &sockHandle, void *pBuffer);
- int ProcessResAlarmConfirm(CSocketHandle &sockHandle, void *pBuffer);
- int ProcessResReadSpecSingleVarData(CSocketHandle &sockHandle, void *pBuffer);
- int ProcessResReadSpecMulVarData(CSocketHandle &sockHandle, void *pBuffer);
- #if 0
- int ProcessHeart(CSocketHandle &sockHandle, void *pBuffer);
- #endif
- //重新读取数据库通知
- int ProcessNoticeReadDBVar(CSocketHandle &sockHandle, void *pBuffer);
- int ProcessNoticeReadDBDev(CSocketHandle &sockHandle, void *pBuffer);
- int ProcessNoticeReadDBUser(CSocketHandle &sockHandle, void *pBuffer);
- int ProcessNoticeTestAlarm(CSocketHandle &sockHandle, void *pBuffer);
- //主动发变量的值给客户端 没有简单变量，特殊变量之分
- int ProcessAutoSendVarDataToClient(CSocketHandle &sockHandle, CBaseVar *pBaseVar );
- //主支发报警信息给客户端
- int ProcessAutoSendAlarmDataToClient( CSocketHandle &sockHandle,CHAR *pDevUid, int nVarID, int iStatus,CHAR *pContent
- ,double dbParaValue, int nUpperLimit,int nLowerLimit, int nNormalState,int nAlarmState,int nAlarmIndex );
- public:
- void AutoSendDataToAllClient( CBaseVar *pBaseVar );
- void AutoSendAlarmDataToClient( CHAR *pDevUid, int iVarID, int iStatus,CHAR *pContent
- ,double dbParaValue, int nUpperLimit,int nLowerLimit, int nNormalState,int nAlarmState,int nAlarmIndex );
- CSocketServer m_SocketServer;
- int m_nSocketIndex;
- CRITICAL_SECTION m_csProcessData;
- };
- extern CServerSocket* g_pServerSocket[MAX_SERVER_LISTEN];
- };
|
