wantedmanager.cpp

墨香最新私服

// WantedManager.cpp: implementation of the CWantedManager class.
//
//////////////////////////////////////////////////////////////////////

#include "stdafx.h"
#include "WantedManager.h"
#include "MapDBMsgParser.h"
#include "UserTable.h"
#include "Network.h"
#include "Player.h"
#include "WantedInfo.h"
#include "PackedData.h"
//////////////////////////////////////////////////////////////////////
// Construction/Destruction
//////////////////////////////////////////////////////////////////////

CWantedManager::CWantedManager()
{
	m_WantedHashTable.Initialize(10);
}

CWantedManager::~CWantedManager()
{
	void * pInfo;
	m_WantedHashTable.SetPositionHead();
	while(pInfo = m_WantedHashTable.GetData())
		delete pInfo;
	m_WantedHashTable.RemoveAll();
}

void CWantedManager::NetworkMsgParse( BYTE Protocol, void* pMsg )
{
	switch(Protocol)
	{
	case MP_WANTED_ORDERLIST_SYN:
		{
			SEND_WANTED_ORDER_SYN* pmsg = (SEND_WANTED_ORDER_SYN*)pMsg;
			CPlayer* pPlayer = (CPlayer*)g_pUserTable->FindUser(pmsg->dwObjectID);
			if(!pPlayer)
				return;
			if(m_WantedHashTable.GetDataNum() == 0)
			{
				MSG_BYTE msg;
				msg.Category = MP_WANTED;
				msg.Protocol = MP_WANTED_ORDERLIST_NACK;
				msg.bData = 0;
				pPlayer->SendMsg(&msg, sizeof(msg));
				return;
			}
			DWORD Totalpage = ((m_WantedHashTable.GetDataNum()-1)/WANTUNIT_PER_PAGE) +1;
			if(Totalpage < pmsg->page)
			{
				MSG_BYTE msg;
				msg.Category = MP_WANTED;
				msg.Protocol = MP_WANTED_ORDERLIST_NACK;
				msg.bData = 1;
				pPlayer->SendMsg(&msg, sizeof(msg));
				return;
			}
			char type[16];
			GetOrderType(pmsg->type, type);
			WantedOrderedList(pmsg->dwObjectID, pmsg->page, type, WANTUNIT_PER_PAGE);
		}
		break;
	case MP_WANTED_MYLIST_SYN:
		{
			MSG_WORD* pmsg = (MSG_WORD*)pMsg;
			CPlayer* pPlayer = (CPlayer*)g_pUserTable->FindUser(pmsg->dwObjectID);
			if(!pPlayer)
				return;
			if(pPlayer->GetWantedNum() == 0)
			{
				MSG_BYTE msg;
				msg.Category = MP_WANTED;
				msg.Protocol = MP_WANTED_MYLIST_NACK;
				msg.bData = 0;// have no
				pPlayer->SendMsg(&msg, sizeof(msg));
				return;
			}
			DWORD Totalpage = ((pPlayer->GetWantedNum()-1) / WANTUNIT_PER_PAGE)+1;
			if(Totalpage < pmsg->wData)
			{
				MSG_BYTE msg;
				msg.Category = MP_WANTED;
				msg.Protocol = MP_WANTED_MYLIST_NACK;
				msg.bData = 2;// Total less than go to page
				pPlayer->SendMsg(&msg, sizeof(msg));
				ASSERT(0);
				return;
			}
			WantedMyList(pmsg->dwObjectID, pmsg->wData, WANTUNIT_PER_PAGE);
		}
		break;
	case MP_WANTED_REGIST_SYN:
		{
			MSG_DWORD2 * pmsg = (MSG_DWORD2*)pMsg;
			CPlayer* pPlayer = (CPlayer*)g_pUserTable->FindUser(pmsg->dwObjectID);
			if(!pPlayer)
				return;
			RegistKillerSyn(pPlayer, pmsg->dwData1, pmsg->dwData2);
		}
		break;
	case MP_WANTED_REGIST_CANCEL:
		{
			MSGBASE* pmsg = (MSGBASE*)pMsg;
			CPlayer* pPlayer = (CPlayer*)g_pUserTable->FindUser(pmsg->dwObjectID);
			if(!pPlayer)
				return;
		//	InsertLogExp( pPlayer->GetID(), pPlayer->GetLevel(), 0, pPlayer->GetPlayerExpPoint(), pPlayer->GetMurderKind(), pPlayer->GetMurderIDX(), pPlayer->GetPlayerAbilityExpPoint());
			pPlayer->SetReadyToRevive(TRUE);

		}
		break;
	case MP_WANTED_BUYRIGHT_SYN:
		{
			MSG_WORD * pmsg = (MSG_WORD*)pMsg;
			CPlayer* pPlayer = (CPlayer*)g_pUserTable->FindUser(pmsg->dwObjectID);
			if(!pPlayer)
				return;
			BuyWantedRightSyn(pPlayer, pmsg->wData);
		}
		break;
	case MP_WANTED_GIVEUPRIGHT_SYN:
		{
			MSG_WORD * pmsg = (MSG_WORD*)pMsg;
			CPlayer* pPlayer = (CPlayer*)g_pUserTable->FindUser(pmsg->dwObjectID);
			if(!pPlayer)
				return;
			GiveUpWantedRightSyn(pPlayer, pmsg->wData);			
		}
		break;
	case MP_WANTED_BUY_TO_MAP:
		{
			MSG_DWORD2 * pmsg = (MSG_DWORD2*)pMsg;
			CWantedInfo * pWantedInfo = GetWantedInfo(pmsg->dwData1);
			if(pWantedInfo == 0)
				return;
			pWantedInfo->SetTotalPrize(pWantedInfo->GetTotalPrize() + WANTED_CHARGE*0.8);
			pWantedInfo->IncreVolunteerNum();
		}
		break;
	case MP_WANTED_GIVEUPRIGHT_TO_MAP:
		{
			MSGBASE * pmsg = (MSGBASE*)pMsg;
			CWantedInfo * pWantedInfo = GetWantedInfo(pmsg->dwObjectID);
			if(pWantedInfo == 0)
				return;
			pWantedInfo->DecreVolunteerNum();
		}
		break;
	//broadcasting
	case MP_WANTED_NOTIFY_REGIST_TO_MAP:
		{
			SEND_WANTEDINFO_TO_SERVER * pmsg = (SEND_WANTEDINFO_TO_SERVER*)pMsg;
			DoRegistKiller(&pmsg->Info);
		}
		break;
	case MP_WANTED_NOTIFY_DELETE_TO_MAP:
		{
			MSGBASE* pmsg = (MSGBASE*)pMsg;
			DoDeleteFromWantedList(pmsg->dwObjectID);			
		}
		break;
	case MP_WANTED_NOTIFY_NOTCOMPLETE_TO_MAP:
		{
			SEND_WANTED_NOTCOMPLETE* pmsg = (SEND_WANTED_NOTCOMPLETE*)pMsg;
			CPlayer* pPlayer = (CPlayer*)g_pUserTable->FindUser(pmsg->dwObjectID);
			if(!pPlayer)
				return;
			CanNotComplete(pPlayer, pmsg->WantedIDX, pmsg->CompleterName, pmsg->type);
		}
		break;


		//from agent
	case MP_WANTED_DELETE_BY_DELETECHR: 
		{
			MSGBASE* pmsg = (MSGBASE*)pMsg;
			DoDeleteFromWantedList(pmsg->dwObjectID);
		}
		break;
	case MP_WANTED_NOTCOMPLETE_BY_DELCHR:
		{
			MSG_DWORD*pmsg = (MSG_DWORD*)pMsg;
			CPlayer* pPlayer = (CPlayer*)g_pUserTable->FindUser(pmsg->dwObjectID);
			if(!pPlayer)
				return;
			CanNotCompleteByDelChr(pPlayer, pmsg->dwData);
		}
		break;
	default:
		{
			char buf[68];
			sprintf(buf, "Protocol : %d", ((MSGBASE*)pMsg)->Protocol );
			ASSERTMSG(0, buf);
		}
	}
}

void CWantedManager::LoadWantedList(WANTEDINFO_LOAD* pInfo)
{
	for(int i=0; i<pInfo->count; ++i)
	{
		CWantedInfo* pWantedInfo = new CWantedInfo;
		pWantedInfo->InitWantedInfo(&pInfo->m_WantedInfo[i]);
		m_WantedHashTable.Add(pWantedInfo, pWantedInfo->GetWantedIDX());
	}
}

void CWantedManager::RegistKillerSyn(CPlayer* pPlayer, DWORD TargetID, MONEYTYPE Prize)
{
	DWORD dwMinPrize = MIN_PRIZE;

	if( g_pServerSystem->GetNation() == eNATION_CHINA )
		dwMinPrize = MIN_PRIZE_CHINA;
	
	if((Prize < dwMinPrize) || (Prize > MAX_PRIZE))
	{
		ASSERT(0);
		SendRegistNackMsg(pPlayer, 1);
		return;
	}
	if(pPlayer->GetMoney() < Prize)
	{
		ASSERT(0);
		SendRegistNackMsg(pPlayer, 2);
		return;
	}
	if(pPlayer->GetMurderIDX() != TargetID)
	{
		ASSERT(0);
		SendRegistNackMsg(pPlayer, 3);
		return;
	}

	pPlayer->SetMoney(Prize, MONEY_SUBTRACTION, 0, eItemTable_Inventory, eMoneyLog_LoseWantedRegist, TargetID);

	//db update return wanted_idx, target id, total prize,  -> add to wantedlist
	WantedRegist(pPlayer->GetID(), TargetID, Prize);

	//ack
	MSGBASE msg;
	msg.Category = MP_WANTED;
	msg.Protocol = MP_WANTED_REGIST_ACK;
	pPlayer->SendMsg(&msg, sizeof(msg));

//	InsertLogExp( pPlayer->GetID(), pPlayer->GetLevel(), 0, pPlayer->GetPlayerExpPoint(), pPlayer->GetMurderKind(), pPlayer->GetMurderIDX(), pPlayer->GetPlayerAbilityExpPoint());
	pPlayer->SetReadyToRevive(TRUE);
}

void CWantedManager::SendRegistNackMsg(CPlayer* pPlayer, BYTE err)
{
	MSG_BYTE msg;
	msg.Category = MP_WANTED;
	msg.Protocol = MP_WANTED_REGIST_NACK;
	msg.bData = err;
	pPlayer->SendMsg(&msg, sizeof(msg));
	pPlayer->SetReadyToRevive(TRUE);
}

void CWantedManager::RegistKillerResult(WANTEDINFO* pInfo)
{
	// add to WantedList
	DoRegistKiller(pInfo);

	//broadcasting to another map servers
	SEND_WANTEDINFO_TO_SERVER msg;
	msg.Category = MP_WANTED;
	msg.Protocol = MP_WANTED_NOTIFY_REGIST_TO_MAP;
	msg.Info.WantedIDX = pInfo->WantedIDX;
	msg.Info.WantedChrIDX = pInfo->WantedChrIDX;
	msg.Info.TotalPrize = pInfo->TotalPrize;
	msg.Info.RegistChrIDX = pInfo->RegistChrIDX;
	SafeStrCpy(msg.Info.WantedChrName, pInfo->WantedChrName, MAX_NAME_LENGTH+1);
	g_Network.Send2AgentServer((char*)&msg, sizeof(msg));
	
	CPlayer* pWanted = (CPlayer*)g_pUserTable->FindUser(pInfo->WantedChrIDX);
	if(!pWanted)
		return;
	pWanted->ClearWantedList();
	MSGBASE rmsg;
	rmsg.Category = MP_WANTED;
	rmsg.Protocol = MP_WANTED_LET_KNOW_REGIST;
	pWanted->SendMsg(&rmsg, sizeof(rmsg));
}

void CWantedManager::DoRegistKiller(WANTEDINFO* pInfo)
{