#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

typedef std::list<SOCKET> CSocketList;

class CServerSocket :
	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;
	BOOL GetClientSocketHandle(CSocketHandle &sockHandle, const SockAddrIn &addr);
	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);
public:
	CSocketServer m_SocketServer;

};