rpgcallback.cc

五行MMORPG引擎系统V1.0

//RPGCallback.cc
/*/////////////////////////////////////////////////////////////////

   李亦
	[e-mail] 4040719
	2006-7-21
/*/////////////////////////////////////////////////////////////////
#include "rpg/cmd/RPGCallback.h"
#include "rpg/cmd/RPGCommand.h"
#include "console/consoleTypes.h"
#include "rpg/RPGError.h"
#include "rpg/gobjects/GPassport.h"
#include "rpg/RPGDataMan.h"
#include "rpg/RPGSetting.h"
#include "rpg/RPGPlayerAux.h"
#include "rpg/RPGChat.h"
#include "rpg/gobjects/GScene.h"
#include "rpg/gobjects/GNpc.h"


namespace RPG
{
RPGCallback *g_pRPGCallback = NULL;

IMPLEMENT_CONOBJECT(RPGCallback);

StringTableEntry RPGCallback::ms_pCallback = "CBProcess";

RPG_CALLBACK RPGCallback::ms_arCallbacks[CMD_AMOUNT]=
{
	RPGCallback::CBProcessUnknow,
	RPGCallback::CBProcessLogin,
	RPGCallback::CBProcessPCList,
	RPGCallback::CBProcessPlayer,
	NULL,
	NULL
};

StringTableEntry RPGCallback::ms_arScriptFuncs[CMD_AMOUNT]=
{
	"CBProcessUnknow",
	"CBProcessLogin",
	"CBProcessPCList",
	"CBProcessPlayer",
	NULL,
	NULL
};

/////////////////////////////////////////////////////////////////
// class RPGCallback 构造函数 /析构函数
RPGCallback::RPGCallback()
{
	for(U32 n=0; n<CMD_AMOUNT; n++)
		m_arScriptCallbacks[n] = StringTable->getBlank();

	//m_dwTimer = 0;
}
RPGCallback::~RPGCallback()
{
}

void RPGCallback::Initialize(CSTR pObjName)
{
	AssertWarn(g_pRPGCallback == NULL, "只能创建一个RPGCallback实例");
	U32 n;

	g_pRPGCallback = new RPGCallback();
	g_pRPGCallback->registerObject(pObjName);

	for(n=0; n<CMD_AMOUNT; n++)
	{	
		if(ms_arScriptFuncs[n])
			ms_arScriptFuncs[n] = StringTable->insert(ms_arScriptFuncs[n]);
		else
			ms_arScriptFuncs[n] = StringTable->getBlank();
	}

	ms_pCallback = StringTable->insert(ms_pCallback);

}

void RPGCallback::Destroy()
{
	if(g_pRPGCallback)
	{
		g_pRPGCallback->deleteObject();
		g_pRPGCallback = NULL;
	}
}

//
//void RPGCallback::AdvanceTime(SimTime timeDelta)
//{
//	if(g_pRPGCommand == NULL || g_pRPGCallback == NULL)
//		return;
//
//	//static s_nCounter = 0;
//	//	if(s_nCounter++ > 40)
//	//	{
//	//		s_nCounter = 0;
//	//		Con::printf("RPGCallback %d",s_nCounter);
//	//	}
//
//	U32 nSize;
//	U32 n;
//	GCMDTASK			*pResult;
//	RPG_CALLBACK	pCallback;
//
//	if(g_pRPGCommand->m_mutexInst.lock(false))
//	{
//		for(;pResult = g_pRPGCommand->m_resultQueue.Shift() ;)
//		{
//			Con::printf(" ------------- Callback %d %s", pResult->dwCmd,pResult->unParam1.str);
//			pCallback = ms_arCallbacks[pResult->dwCmd];
//			if(pCallback)
//				pCallback(pResult);
//
//			g_pRPGCallback->ScriptCallback(pResult);
//			RPGCommand::FreeCmdTask(pResult);
//		}
//		g_pRPGCommand->m_mutexInst.unlock();
//	}
//}


void RPGCallback::initPersistFields()
{
	Parent::initPersistFields();
   addField("arCallbacks",    TypeString,     Offset(m_arScriptCallbacks, RPGCallback), CMD_AMOUNT);

}


void RPGCallback::ProcessResult(GCMDTASK* pResult)
{
	if(!pResult)
		return;
	if(ms_arCallbacks[pResult->dwCmd])
		ms_arCallbacks[pResult->dwCmd](pResult);

	ScriptCallback(pResult);
}

void RPGCallback::ScriptCallback(GCMDTASK* pTask)
{

	//脚本回调处理
	StringTableEntry pCallback = m_arScriptCallbacks[pTask->dwCmd];
	if(pCallback && pCallback[0])
	{

		StringTableEntry str1;
		StringTableEntry str2;
		switch(pTask->dwCmd)
		{
		case CMD_UNKNOW:
		case CMD_PP_LOGIN:
		case CMD_PC_LOAD:
		case CMD_PP_PCLIST:
			str1 = (pTask->unParam1.str != 0)?pTask->unParam1.str : StringTable->getBlank();
			str2 = (pTask->unParam2.str != 0)?pTask->unParam2.str : StringTable->getBlank();
			Con::evaluatef("%s(\"%s\",\"%s\");",pCallback,str1, str2);
			return;

		default:
			//Con::evaluatef("%s(%d,%d);",pCallback,str1, str2);
			break;
		}
	}

	///////////////////////////////////////////////////////////
	StringTableEntry argv[5];

	pCallback = ms_arScriptFuncs[pTask->dwCmd];

	if(Con::checkScriptMethod(this, pCallback))
	{
		argv[0]	= pCallback;
		argv[2]	=  (pTask->unParam1.str != 0)?pTask->unParam1.str : StringTable->getBlank();
		argv[3]	=  (pTask->unParam2.str != 0)?pTask->unParam2.str : StringTable->getBlank();
		Con::execute(this,4, argv);
		return;
	}

	pCallback = ms_pCallback;
	if(Con::checkScriptMethod(this, pCallback))
	{
		argv[0]	= pCallback;
		argv[2]	=  Con::getIntArg(pTask->dwCmd);
		argv[3]	=  (pTask->unParam1.str != 0)?pTask->unParam1.str : StringTable->getBlank();
		argv[4]	=  (pTask->unParam2.str != 0)?pTask->unParam2.str : StringTable->getBlank();
		Con::execute(this,5, argv);
	}


}


U32 RPGCallback::CBProcessUnknow(GCMDTASK* pTask)
{

	return 0;
}

U32 RPGCallback::CBProcessLogin(GCMDTASK* pTask)
{
	return 0;
}

U32 RPGCallback::CBProcessPCList(GCMDTASK* pTask)
{
	if(pTask->nError == E_OK)
	{
		GPassport *pPassport = g_pRPGDataMan->GetPassport(pTask->unParam1.str);
		if(pPassport)
		{
			pPassport->assignSoleName(SCRIPT_GPassport);
		}
	}
	return 0;
}

U32 RPGCallback::CBProcessPlayer(GCMDTASK* pTask)
{
	GPlayer *pPlayer;
	GScene*	pGScene;

	if(pTask->nError == E_OK)
	{
		//////////////////////////////////
		pPlayer = g_pRPGDataMan->GetPlayer(pTask->unParam1.str);
		if(pPlayer)
		{
			pPlayer->SetMainRole(TRUE);
			pPlayer->assignSoleName(SCRIPT_GPlayer);
			
			for(U32 n=0; n<GGAR_AMOUNT; n++)
				RPGSetting::AttachGoodsArrayWithUI(pPlayer, (ERPGGoodsArrayTypes)n);
		}
		g_pGPlayer = pPlayer;


		///////////////////////////////////////
		//处理主角玩家所在地图
		pGScene = g_pRPGDataMan->GetScene(pPlayer->GetMapIDName());
		if(pGScene)
		{
			Con::setVariable("$Scene::Name",pGScene->GetSceneName());
			pGScene->assignSoleName(SCRIPT_GScene);
		}
		g_pGScene = pGScene;

		//RPGChat::OutputTipF(TIP_WELCOME, 	pPlayer->GetIDName(),	g_pRPGSetting->GetGameName() );
		//RPGChatLog();
	}
	return 0;
}

//ConsoleMethod(RPGCallback,check,bool,2,2,"check()")
//{
//	return true;
//}

//void RPGCallback::consoleInit()
//{
//}


};//namespace RPG