// monitorDemo.cpp : 定義控制臺(tái)應(yīng)用程序的入口點(diǎn)。
//

#include "stdafx.h"
#include "monitorDemo.h"


#ifdef _DEBUG
#define new DEBUG_NEW
#endif

/*
演示 CRemoteMonitorManager CBufferWnd CConsoler 的使用
1 功能在8099端口監(jiān)聽(tīng)客戶端連接
2 在處理線程中接收客戶端輸入，并且將客戶端輸入顯示到主界面和所有客戶連接上
3 定時(shí)插入一些Demo數(shù)據(jù)
4 從CClrOutputDisplay 派生新類(lèi)完成輸出顯示功能
*/
// 唯一的應(yīng)用程序?qū)ο?
CWinApp theApp;

using namespace std;

#define SVR_NAME			"MDEMOSVR"


/*
測(cè)試方法：運(yùn)行 telnet localhost 8099
*/
void RmtCallBack(CRemoteHelper* pHelper,SOCKET sockComm)
{
	CTCPSocket sock(sockComm,FALSE);
	char szBuf[400]={0};
	CString szU,szP;
	int iInput = pHelper->GetUsernameAndPwd(szU,szP,30,FALSE,TRUE);//身份驗(yàn)證
	// 比較 szU,szP確定身份

	while(1)
	{
		char szOut[200]={0};
		if(!pHelper->IsGoon())
		{
			sprintf(szOut,"{%d} IsGoon = FALSE，退出服務(wù)線程",pHelper->GetSeqID());
			pHelper->GetRemoteMonitorManager()->OutputToMainConsole(COutputDisplay::GeneralWarn,szOut,TRUE,FALSE);
			break;
		}
		if(!pHelper->SendBufMsgToClient())
		{
			printf(szOut,"{%d} 發(fā)送錯(cuò)誤，退出服務(wù)線程",pHelper->GetSeqID());
			pHelper->GetRemoteMonitorManager()->OutputToMainConsole(COutputDisplay::GeneralError,szOut,TRUE,FALSE);
			break;
		}
		/* 方法一 線程自己利用SOCKET進(jìn)行讀寫(xiě)操作
		int iRead;
		memset(szBuf,0,sizeof(szBuf));
		int iRet =sock.TestAndRecv(0,100,(BYTE*)szBuf,iRead);
		if(iRet == SP_ERR_SUCCESS || iRet == SP_ERR_NOT_FINISH)
		{//接收連接端輸入，并且在所有的屏幕上進(jìn)行顯示
			sprintf(szOut,"[%d] read %s",pHelper->GetSeqID(),szBuf);
			pHelper->GetRemoteMonitorManager()->OutputToMainConsole(szOut,TRUE,FALSE);
		}
		else if(iRet == SP_ERR_NETWORK)
		{
			sprintf(szOut,"{%d} 接收失敗【網(wǎng)絡(luò)錯(cuò)誤】，退出服務(wù)線程",pHelper->GetSeqID());
			pHelper->GetRemoteMonitorManager()->OutputToMainConsole(COutputDisplay::GeneralError,szOut,TRUE,FALSE);
			break;
		}
		*/
		// 方法二 利用 CRemoteHelper 提供的網(wǎng)絡(luò)讀功能，通過(guò)Helper對(duì)象的緩沖區(qū)接收數(shù)據(jù)
		int iRet,iErrorCode;
		//讀入數(shù)據(jù)到緩沖區(qū)
		iRet = pHelper->ReadDataFromClient(4,iErrorCode,TRUE);
		if(iRet >0)
		{
			//取出一行數(shù)據(jù)
			iRet = pHelper->RemoveLineFromBuffer(szBuf,400,FALSE);
			if(iRet >0)//數(shù)據(jù)過(guò)長(zhǎng)，則直接刪除所有數(shù)據(jù)
			{//接收連接端輸入，并且在所有的屏幕上進(jìn)行顯示
				pHelper->ClearBuffer();
				sprintf(szOut,"[%d] 緩沖區(qū)內(nèi)數(shù)據(jù)過(guò)多，直接清除",pHelper->GetSeqID());
				pHelper->GetRemoteMonitorManager()->OutputToMainConsole(szOut,FALSE,FALSE);
			}
			else if(iRet==0)
			{//在主屏幕上進(jìn)行顯示
				sprintf(szOut,"[%d] read %s",pHelper->GetSeqID(),szBuf);
				pHelper->GetRemoteMonitorManager()->OutputToMainConsole(szOut,FALSE,FALSE);
				if(strcmp("help",szBuf) == 0)
				{//help command
					pHelper->GetRemoteHandlerData()->PushMsg("help : 幫助命令\n\r");
					pHelper->GetRemoteHandlerData()->PushMsg("exit : 退出命令\n\r");
				}
				if(strcmp("exit",szBuf)==0)
				{//exit command
					break;
				}
			}
		}
		else if(iRet ==-1 && iErrorCode == -1)
		{
			sprintf(szOut,"{%d} 接收失敗【網(wǎng)絡(luò)錯(cuò)誤】，退出服務(wù)線程",pHelper->GetSeqID());
			pHelper->GetRemoteMonitorManager()->OutputToMainConsole(szOut,FALSE,FALSE);
			break;
		}
	}
}

void DoTest(void)
{
	CClrOutputDisplay oput;
	CRemoteMonitorManager *man =new CRemoteMonitorManager("Remote Monitor Test Server",RmtCallBack,"tserver",&oput,NULL,8099,100);
	BOOL fRet = man->StartMonitor();
	printf("start Monitor %s listen port = 8099\nRun \"telnet localhost 8099\" to test\n\n",(fRet)?"OK":"Error");
	for(int i=0;i<600;i++)
	{
		char szTemp[100];
		sprintf(szTemp,"%d AAAAAAAAAAAAAAAAAA %d\n\r",i,-i);
		man->PushMsg(szTemp);
		if(i % 20==0 )
		{
			sprintf(szTemp,"%d BBBBBBBBBBBBBBBBBBB %d\n\r",i,-i);
			man->PushUrgentMsg(szTemp);
			printf("No.%d\n",i);
		} 
		Sleep(5500);
	}
	printf("stop monitor\n");
	man->StopMonitor();
	delete man;
	printf("exit\n");
}

int _tmain(int argc, TCHAR* argv[], TCHAR* envp[])
{
	int nRetCode = 0;

	// 初始化 MFC 并在失敗時(shí)顯示錯(cuò)誤
	if (!AfxWinInit(::GetModuleHandle(NULL), NULL, ::GetCommandLine(), 0))
	{
		// TODO: 更改錯(cuò)誤代碼以符合您的需要
		_tprintf(_T("致命錯(cuò)誤：MFC 初始化失敗\n"));
		nRetCode = 1;
	}
	else
	{
		ASSERT(AfxSocketInit());
		DoTest();
	}

	return nRetCode;
}