repos_ecs/Service_1.0.0.5/Service/ServerSocket.h

#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 ProcessRetureOperateResult(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 nWarningLevel,int nAlarmIndex,int nNoticeDelay );
		int ProcessAutoSendNoticeConfigToAllClient( CSocketHandle &sockHandle, char *pDevUid, int nVarID, int nAlarmIndex );
		int ProcessAutoSendPastDueInfoToAllClient( CSocketHandle &sockHandle,int iPastDue,int iSlaveVersion,CString sPassDueInfo );
		int ProcessInsertRomoteDB( CSocketHandle &sockHandle,CHAR *sDevNmae, CHAR *sTime,CHAR *sMemo,CHAR *sDesc,double dbParaValue,CHAR *sUid,CHAR *sVarName );
		int ProcessAutoSendOtherInfoToAllClient( CSocketHandle &sockHandle,int iMainType,int iSlaveType,int iData1,int iData2,int iData3,float fData1,float fData2,float fData3,CHAR *sData1,CHAR *sData2,CHAR *sData3 );
		int ProcessNoticeServerVer(CSocketHandle &sockHandle, void *pBuffer);
	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 nWarningLevel,int nAlarmIndex,int nNoticeDelay );
		void AutoSendNoticeConfigToAllClient( char *pDevUid, int nVarID, int nAlarmIndex );
		void AutoSendPastDueInfoToAllClient( int iPastDue,int iSlaveVersion,CString sPassDueInfo );
		void InsertRomoteDB( CHAR *sDevNmae, CHAR *sTime,CHAR *sMemo,CHAR *sDesc,double dbParaValue,CHAR *sUid,CHAR *sVarName );

		void AutoSendOtherInfoToAllClient( int iMainType,int iSlaveType,int iData1,int iData2,int iData3,float fData1,float fData2,float fData3,CHAR *sData1,CHAR *sData2,CHAR *sData3 );

		CSocketServer m_SocketServer;
		int m_nSocketIndex;
		CRITICAL_SECTION m_csProcessData;
	};

	extern CServerSocket* g_pServerSocket[MAX_SERVER_LISTEN];
};