#include "StdAfx.h"
|
#include "ResultServerControl.h"
|
#include "IOCPNetwork/NetDefinition.h"
|
#include "CHReviewResult/GlassResult.h"
|
#include "IOCPNetwork/NetServer.h"
|
|
CResultServerControl::CResultServerControl(void)
|
{
|
m_pServerSocket = NULL;
|
InitResultServer();
|
}
|
|
CResultServerControl::~CResultServerControl(void)
|
{
|
DeinitResultServer();
|
}
|
|
// Result Server
|
int CResultServerControl::InitResultServer()
|
{
|
if (m_pServerSocket)
|
{
|
delete m_pServerSocket;
|
m_pServerSocket = NULL;
|
}
|
|
m_pServerSocket = new CNetServer();
|
|
if (m_pServerSocket==NULL) return 0;
|
|
int nClientCount = 10;
|
m_pServerSocket->SetIN2P(static_cast<IIOCPNetwork2Parent*>(this));
|
m_pServerSocket->SetClientInfo(Socket_All_Client, nClientCount, NETCODE_RESULT_SERVER_ALL, NETVER_RESULT_SERVER_ALL, FALSE);
|
|
BOOL bResult = m_pServerSocket->InitNetwork(ServerMode, nClientCount, NETPORT_RESULT_SERVER_ALL);
|
|
return bResult;
|
}
|
|
void CResultServerControl::DeinitResultServer()
|
{
|
if (m_pServerSocket)
|
{
|
m_pServerSocket->DeinitNetwork();
|
delete m_pServerSocket;
|
}
|
m_pServerSocket = NULL;
|
}
|
|
void CResultServerControl::IOCPNet2P_Connected(int nType)
|
{
|
g_pLog->DisplayMessage(_T("ResultServer Client Connect! [%d]"), nType);
|
}
|
|
void CResultServerControl::IOCPNet2P_Disconnected(int nType, int nModuleNo)
|
{
|
g_pLog->DisplayMessage(_T("ResultServer Client Disconnected! [%d, %d]"), nType, nModuleNo);
|
}
|
|
BOOL CResultServerControl::IOCPNet2P_Received(int Type, CNetPacket* pPacket, __int64 nContext)
|
{
|
if(!pPacket) return FALSE;
|
|
if (Type!=Socket_All_Client) return FALSE;
|
|
CNetJoiner* pNetJoiner = NULL;
|
|
switch(pPacket->GetPacketCode())
|
{
|
case CR_MODULE_INDEX:
|
g_pLog->DisplayMessage(_T("[%d]NetIOCP2P_Received CA_MODULE_INDEX"), pPacket->GetModuleNo());
|
for(int i = 0; i < m_pServerSocket->GetClientCount(); i++)
|
{
|
pNetJoiner = m_pServerSocket->GetJoinerArray(i);
|
if (pNetJoiner && reinterpret_cast<int>(pNetJoiner->GetSocketContext()) == nContext)
|
{
|
pNetJoiner->SetModuleNo(pPacket->GetModuleNo(), FALSE);
|
m_pServerSocket->SendToClient(i, RC_MODULE_INDEX, NET_RESULT_SUCCESS);
|
}
|
}
|
break;
|
|
case CR_RESULT_INFO:
|
g_pLog->DisplayMessage(_T("[%d]NetIOCP2P_Received CR_RESULT_INFO"), pPacket->GetModuleNo());
|
break;
|
|
default:
|
break;
|
}
|
|
return TRUE;
|
}
|
|
BOOL CResultServerControl::SendReviewResult(int nModuleIdx, int nResultIdx, const SReviewResult* pReviewResult)
|
{
|
if (m_pServerSocket==NULL || pReviewResult==NULL) return FALSE;
|
|
CNetPacket *pSendPacket = m_pServerSocket->GetPacket();
|
if (pSendPacket)
|
{
|
// set result packet
|
int nResultCode = 0; // result code
|
int nModuleIndex = nModuleIdx; // module index
|
int nTotalGlassResultCount = 0; // total glass result count
|
int nCurGlassResultCount = 0; // current glass result count
|
int nTotalModuleResultCount = 0; // total module result count
|
int nCurModuleResultCount = nResultIdx; // current module result count
|
CString strImagePath = _T("");
|
strImagePath.Format(_T("%s"), pReviewResult->strUploadImgFileName);
|
|
pSendPacket->SetInt(nResultCode);
|
pSendPacket->SetInt(nModuleIndex);
|
pSendPacket->SetInt(nTotalGlassResultCount);
|
pSendPacket->SetInt(nCurGlassResultCount);
|
pSendPacket->SetInt(nTotalModuleResultCount);
|
pSendPacket->SetInt(nCurModuleResultCount);
|
pSendPacket->SetString(strImagePath);
|
|
return m_pServerSocket->InvokeToClient(RC_RESULT_INFO, NET_RESULT_SUCCESS, pSendPacket);
|
}
|
|
return m_pServerSocket->InvokeToClient(RC_RESULT_INFO, NET_RESULT_FAIL);
|
}
|
