818 lines
20 KiB
C++
818 lines
20 KiB
C++
#include "StdAfx.h"
|
||
#include "QuestSystem.h"
|
||
#include "../base/Container.hpp"
|
||
|
||
void CQuestSystem::OnEnterGame()
|
||
{
|
||
CheckCanAcceptQuest();
|
||
}
|
||
CQuestSystem::CQuestSystem()
|
||
{
|
||
m_GoingQuestList.clear();
|
||
isDataModify = false;
|
||
memset(m_FinishedQuest, 0, sizeof(m_FinishedQuest));
|
||
}
|
||
|
||
CQuestSystem::~CQuestSystem()
|
||
{
|
||
m_GoingQuestList.clear();
|
||
}
|
||
|
||
bool CQuestSystem::Initialize(void *data,SIZE_T size)
|
||
{
|
||
PACTORDBDATA pActorData = (ACTORDBDATA *)data;
|
||
if(pActorData ==NULL || size != sizeof(ACTORDBDATA))
|
||
{
|
||
OutputMsg(rmError,_T("data len error len=%d ,correct len=%d"),size, sizeof(ACTORDBDATA));
|
||
return false;
|
||
}
|
||
//将db的数据拷贝过来
|
||
memcpy( m_FinishedQuest,pActorData->quest,sizeof(m_FinishedQuest));
|
||
|
||
|
||
return true;
|
||
}
|
||
|
||
VOID CQuestSystem::OnDbRetData(INT_PTR nCmd,INT_PTR nErrorCode, CDataPacketReader &inPacket)
|
||
{
|
||
OutputMsg(rmNormal,_T("CQuestSystem::OnDbRetData nCmd=%d"), nCmd);
|
||
if (m_pEntity == NULL) return;
|
||
if (nCmd == jxInterSrvComm::DbServerProto::dcSaveQuest)
|
||
{
|
||
//这个是保存数据时返回的结果
|
||
if (nErrorCode != jxInterSrvComm::DbServerProto::reSucc)
|
||
{
|
||
OutputMsg(rmTip,_T("save quest data,errorcode=%d,ActorId=%d"),nErrorCode,m_pEntity->GetId());
|
||
}
|
||
return;
|
||
}
|
||
else if(nCmd == jxInterSrvComm::DbServerProto::dcLoadQuest)
|
||
{
|
||
m_GoingQuestList.clear();
|
||
WORD nCount = 0;
|
||
inPacket >> nCount;
|
||
if(HasDbDataInit()) return ; //如果已经装载了任务的数据，就不装载了
|
||
for (int i = 0; i < nCount; i++)
|
||
{
|
||
QuestItem item;
|
||
inPacket.readBuf(&item, sizeof(item));
|
||
if(item.nStartId > 0)
|
||
m_RingStartQId.push_back(item.nStartId);
|
||
m_GoingQuestList.push_back(item);
|
||
}
|
||
OnDbInitData();
|
||
//第一次下发可接任务
|
||
}
|
||
}
|
||
|
||
VOID CQuestSystem::OnTimeCheck(TICKCOUNT nTickCount)
|
||
{
|
||
}
|
||
|
||
void CQuestSystem::ProcessNetData(INT_PTR nCmd,CDataPacketReader &packet )
|
||
{
|
||
if (m_pEntity == NULL)
|
||
{
|
||
return;
|
||
}
|
||
switch (nCmd)
|
||
{
|
||
case sQueryQuest:
|
||
SendAllQuestData();
|
||
break;
|
||
case cChangetQuestState:
|
||
{
|
||
int nQid = 0;
|
||
int nState = 0;
|
||
Uint64 npcHandle = 0;
|
||
packet >> nQid >> nState >> npcHandle;
|
||
ChangeQuestItemState(nQid, nState, npcHandle);
|
||
break;
|
||
}
|
||
case cQuestTel: //传送
|
||
{
|
||
int nQid = 0;
|
||
BYTE nType = 0;
|
||
BYTE nId = 0;
|
||
packet >>nQid >> nType >> nId;
|
||
QuestTeleport(nQid, nType, nId);
|
||
break;
|
||
}
|
||
default:
|
||
OutputMsg(rmTip, _T("%s:客户端请求[%d]的数据包没处理，请检查是否做了多余的请求"), __FUNCTION__, nCmd);
|
||
break;
|
||
}
|
||
}
|
||
|
||
void CQuestSystem::QuestTeleport(int nQid, int nType, int nId)
|
||
{
|
||
if( !m_pEntity ) return;
|
||
int nCode = 0;
|
||
int nNpcId = 0;
|
||
int nIsOpen = 0;
|
||
int nQstate = 0;
|
||
int nAuto = 0;
|
||
do
|
||
{
|
||
CActor* pActor = (CActor*)m_pEntity;
|
||
if(GetfinishQuestState(nQid)) {
|
||
nCode = 1;
|
||
break;
|
||
}
|
||
|
||
QuestItem* item = GetGoingQuestData(nQid);
|
||
if(!item) {
|
||
nCode = 5;
|
||
break;
|
||
}
|
||
|
||
QuestInfoCfg* cfg = GetLogicServer()->GetDataProvider()->GetQuestConfig()->GetQuestConfig(item->nQid, item->nState);
|
||
if(!cfg) {
|
||
nCode = 3;
|
||
break;
|
||
}
|
||
|
||
if(!GetLogicServer()->CheckOpenServer(cfg->nOpenDayLimit) || !m_pEntity->CheckLevel(cfg->nLevelLimit, cfg->nCircle)) {
|
||
nCode = 4;
|
||
break;
|
||
}
|
||
TeleportInfo* tel = cfg->GetTelInfo(nType, nId);
|
||
if(!tel)
|
||
{
|
||
nCode = 10;
|
||
break;
|
||
}
|
||
QuestAward pCost;;
|
||
cfg->GetCostFsValue(item->nUseFsTimes, pCost);
|
||
if(pCost.nCount)
|
||
{
|
||
if(!pActor->CheckActorSource(pCost.nType, pCost.nId, pCost.nCount, tstUI))
|
||
{
|
||
nCode = 20;
|
||
break;
|
||
}
|
||
}
|
||
int nEffId = GetLogicServer()->GetDataProvider()->GetGlobalConfig().nBlinkEnterEffect;
|
||
if( pActor->FlyShoseToStaticScene(tel->nMapid, tel->nX, tel->nY, tel->nRange,0,enDefaultTelePort,nEffId))
|
||
{
|
||
if(pCost.nCount)
|
||
{
|
||
pActor->RemoveConsume(pCost.nType, pCost.nId, pCost.nCount, -1, -1, -1, 0,GameLog::Log_Quest);
|
||
}
|
||
}
|
||
if(nType == 3)
|
||
{
|
||
item->nUseFsTimes++;
|
||
returnClientQuestState(nQid, 0);
|
||
}
|
||
m_infos.nAuto = tel->nAuto;
|
||
m_infos.nIsOpen = tel->nIsOpen;
|
||
m_infos.nQstate = item->nState;
|
||
m_infos.nTelNpcId = tel->nTelNpcId;
|
||
m_infos.nQid = nQid;
|
||
if(tel->nTelNpcId) {
|
||
return;
|
||
}
|
||
// nAuto = tel->nAuto;
|
||
// nIsOpen = tel->nIsOpen;
|
||
// nQstate = item->nState;
|
||
}
|
||
while(false);
|
||
// SendQuestTelResult(nCode);
|
||
CActorPacket ap;
|
||
CDataPacket & data = m_pEntity->AllocPacket(ap);
|
||
data<<(BYTE)GetSystemID() << (BYTE)sQuestTel;
|
||
data<<(BYTE)nCode;
|
||
data<<(BYTE)m_infos.nIsOpen;
|
||
data<<(BYTE)m_infos.nAuto;
|
||
data<<(int)m_infos.nQid;
|
||
data<<(int)m_infos.nQstate;
|
||
data<<(int)m_infos.nTelNpcId;
|
||
ap.flush();
|
||
memset(&m_infos, 0,sizeof(m_infos));
|
||
}
|
||
|
||
void CQuestSystem::SendQuestTelResult(int nCode)
|
||
{
|
||
if( nCode != 0 || m_infos.nTelNpcId != 0 )
|
||
{
|
||
CActorPacket ap;
|
||
CDataPacket & data = m_pEntity->AllocPacket(ap);
|
||
data<<(BYTE)GetSystemID() << (BYTE)sQuestTel;
|
||
data<<(BYTE)nCode;
|
||
data<<(BYTE)m_infos.nIsOpen;
|
||
data<<(BYTE)m_infos.nAuto;
|
||
data<<(int)m_infos.nQid;
|
||
data<<(int)m_infos.nQstate;
|
||
data<<(int)m_infos.nTelNpcId;
|
||
ap.flush();
|
||
memset(&m_infos, 0,sizeof(m_infos));
|
||
}
|
||
|
||
}
|
||
|
||
|
||
void CQuestSystem::SendAllQuestData()
|
||
{
|
||
if (m_pEntity == NULL) return;
|
||
CActorPacket AP;
|
||
CDataPacket& DataPacket = m_pEntity->AllocPacket(AP);
|
||
|
||
//需保证任务数据已经从数据库中载入
|
||
DataPacket << (BYTE)enQuestSystemID << (BYTE)sQueryQuest;
|
||
//遍历任务数据
|
||
size_t nQCountPos = DataPacket.getPosition();
|
||
|
||
DataPacket << (int)m_GoingQuestList.size();//任务的数量
|
||
int nCount = 0;
|
||
for (int i = 0; i < m_GoingQuestList.size(); i++)
|
||
{
|
||
QuestItem& item = m_GoingQuestList[i];
|
||
QuestInfoCfg* cfg = GetLogicServer()->GetDataProvider()->GetQuestConfig()->GetQuestConfig(item.nQid, item.nState);
|
||
if(!cfg)
|
||
continue;
|
||
if(GetfinishQuestState(item.nQid))
|
||
continue;
|
||
if(returnQuestData(&item, DataPacket))
|
||
nCount++;
|
||
|
||
}
|
||
int * pInt = (int*)DataPacket.getPositionPtr(nQCountPos);
|
||
*pInt = nCount;
|
||
AP.flush();
|
||
}
|
||
|
||
|
||
bool CQuestSystem::HasQuest(int nQid)
|
||
{
|
||
for(int i = 0; i < m_GoingQuestList.size(); i++)
|
||
{
|
||
if(m_GoingQuestList[i].nQid == nQid)
|
||
return true;
|
||
}
|
||
return false;
|
||
}
|
||
|
||
|
||
|
||
bool CQuestSystem::HasInRingQuest(int nQid)
|
||
{
|
||
for(int i = 0; i < m_RingStartQId.size(); i++)
|
||
{
|
||
if(m_RingStartQId[i] == nQid)
|
||
return true;
|
||
}
|
||
return false;
|
||
}
|
||
|
||
/*
|
||
此方法尽量不要在高频方法中调用，如要调用，务必尽可能屏筛选掉不必要的循环
|
||
对于杀怪任务事件，首先由怪物的归属者处理事件，然后队友再处理
|
||
还有处理师徒关系
|
||
*/
|
||
VOID CQuestSystem::OnQuestEvent(INT_PTR nTargetType, INT_PTR nCount, INT_PTR nId)
|
||
{
|
||
if (m_pEntity == NULL) return;
|
||
for( int i = 0; i < m_GoingQuestList.size(); i++)
|
||
{
|
||
QuestItem& item = m_GoingQuestList[i];
|
||
|
||
int nQuestType = item.nType / 100;
|
||
int nSubType = item.nType % 100;
|
||
|
||
if(nTargetType == nQuestType)
|
||
{
|
||
QuestInfoCfg* cfg = GetLogicServer()->GetDataProvider()->GetQuestConfig()->GetQuestConfig(item.nQid, item.nState);
|
||
if(!cfg)
|
||
continue;
|
||
int nSceneId = ((CActor*)m_pEntity)->GetSceneID();
|
||
if(!cfg->checkIdMapidInLimitIds(nId, nSceneId))
|
||
{
|
||
continue;
|
||
}
|
||
if(!cfg->inGroup(nId))
|
||
continue;
|
||
//处理技能 或者其他牵扯到子类型的任务进度
|
||
if(nQuestType == CQuestData::qtEquip && (cfg->GeLimitSubType() != 0 && cfg->GeLimitSubType() <= nId )) {
|
||
|
||
} else {
|
||
if(cfg->GeLimitSubType() != 0 && cfg->GeLimitSubType() != nId) {
|
||
continue;
|
||
}
|
||
}
|
||
|
||
if(nSubType == 1) //
|
||
item.nValue += nCount;
|
||
else {
|
||
if (item.nValue < nCount)
|
||
item.nValue = nCount;
|
||
}
|
||
isDataModify = true;
|
||
if(cfg->nShowSchedule)
|
||
{
|
||
returnClientQuestState(item.nQid, 0);
|
||
}
|
||
if(item.nValue >= cfg->GetLimitValue())
|
||
{
|
||
DealAutoChangeQuestState(2, item.nQid, item.nState, cfg);
|
||
returnClientQuestState(item.nQid, 0);
|
||
}
|
||
}
|
||
}
|
||
|
||
//如果是杀怪，并且同队伍的成员也有这个任务，则两个人都增加值(杀指定怪、场景怪、等级怪)
|
||
|
||
if (nTargetType == CQuestData::qtLevel || nTargetType == CQuestData::qtcircle)
|
||
{//如果等级变化了，更新可接任务列表
|
||
CheckCanAcceptQuest();
|
||
}
|
||
}
|
||
|
||
|
||
void CQuestSystem::CheckCanAcceptQuest() {
|
||
if (m_pEntity == NULL) return;
|
||
int Job = m_pEntity->GetProperty<int>(PROP_ACTOR_VOCATION);
|
||
std::map<int, QuestInfoCfg*>& questlist = GetLogicServer()->GetDataProvider()->GetQuestConfig()->m_vMainRootQuestConfig;
|
||
if(questlist.size() > 0) {
|
||
|
||
std::map<int, QuestInfoCfg*>::iterator it = questlist.begin();
|
||
for(; it != questlist.end(); it++) {
|
||
|
||
QuestInfoCfg* cfg = it->second;
|
||
int nJob = cfg->nQid /QUESTMAIN;
|
||
if( (nJob != 0 && nJob != Job) || HasQuest(cfg->nQid) || GetfinishQuestState(cfg->nQid) || HasInRingQuest(cfg->nQid))
|
||
continue;
|
||
if( (cfg->nFrontQid != 0 && !GetfinishQuestState(cfg->nFrontQid)))
|
||
continue;
|
||
|
||
// 等级检查
|
||
CActor* pActor = (CActor *)m_pEntity;
|
||
int level = pActor->GetLevel();
|
||
int circle = pActor->GetCircleLevel();
|
||
if (cfg->nQid == 1 && cfg->nState == 101 && circle >= 2)
|
||
{
|
||
continue;
|
||
}
|
||
if(GetLogicServer()->CheckOpenServer(cfg->nOpenDayLimit) && m_pEntity->CheckLevel(cfg->nLevelLimit, cfg->nCircle))
|
||
{
|
||
AddQuest(cfg);
|
||
}
|
||
}
|
||
}
|
||
|
||
|
||
|
||
}
|
||
|
||
|
||
int CQuestSystem::GetfinishQuestState(int nQid)
|
||
{
|
||
int nState = 0;
|
||
nQid = nQid%QUESTMAIN;
|
||
int nIndex = nQid/8;
|
||
int nbit = nQid%8 -1;
|
||
if(nbit < 0)
|
||
nbit = 7;
|
||
if((nIndex >= 0) || (nIndex < QUESTBTYE))
|
||
{
|
||
|
||
BYTE nValue = m_FinishedQuest[nIndex];
|
||
nState = (int)( nValue & (1 << nbit));
|
||
}
|
||
|
||
return nState;
|
||
}
|
||
|
||
void CQuestSystem::SetfinishQuest(int nQid)
|
||
{
|
||
nQid = nQid%QUESTMAIN;
|
||
int nIndex = nQid/8;
|
||
int nbit = nQid%8 -1;
|
||
if(nbit < 0)
|
||
nbit = 7;
|
||
if((nIndex >= 0) || (nIndex < QUESTBTYE))
|
||
{
|
||
BYTE nValue = m_FinishedQuest[nIndex];
|
||
nValue |= (1 << nbit);
|
||
m_FinishedQuest[nIndex] = (BYTE)nValue;
|
||
}
|
||
|
||
}
|
||
|
||
void CQuestSystem::ChangeQuestItemState(int nQid, int nState, Uint64 npcHandle)
|
||
{
|
||
if(!m_pEntity) return;
|
||
int nCode = 0;
|
||
do
|
||
{
|
||
if(GetfinishQuestState(nQid)) {
|
||
nCode = 1;
|
||
break;
|
||
}
|
||
|
||
if(!HasQuest(nQid)) {
|
||
nCode = 2;
|
||
break;
|
||
}
|
||
QuestItem* item = GetGoingQuestData(nQid);
|
||
if(!item || item->nState != nState) {
|
||
nCode = 5;
|
||
break;
|
||
}
|
||
|
||
QuestInfoCfg* cfg = GetLogicServer()->GetDataProvider()->GetQuestConfig()->GetQuestConfig(nQid, nState);
|
||
if(!cfg) {
|
||
nCode = 3;
|
||
break;
|
||
}
|
||
|
||
if(!GetLogicServer()->CheckOpenServer(cfg->nOpenDayLimit) || !m_pEntity->CheckLevel(cfg->nLevelLimit, cfg->nCircle)) {
|
||
nCode = 4;
|
||
break;
|
||
}
|
||
//策划 王自宜 不需要判断npc 距离
|
||
// TeleportInfo* tel = cfg->GetTelInfo(1);
|
||
// if(tel && tel->nNpcId > 0)
|
||
// {
|
||
// CEntity* pEntity = GetGlobalLogicEngine()->GetEntityMgr()->GetEntity(npcHandle);
|
||
// if (!pEntity || !((CActor*)m_pEntity)->CheckTargetDistance((CActor*)pEntity, 15))
|
||
// {
|
||
// nCode = 14;
|
||
// break ;
|
||
// }
|
||
// }
|
||
|
||
if(!CheckComplete(item, cfg->mQuestInfo.nValue)) {
|
||
nCode = 6;
|
||
break;
|
||
}
|
||
|
||
DealAutoChangeQuestState(1, nQid, nState, cfg);
|
||
|
||
}while(false);
|
||
// //客户端需求 需要改变任务状态进行推送
|
||
// SendClientQuestState(nQid);
|
||
returnClientQuestState(nQid, nCode);
|
||
}
|
||
|
||
void CQuestSystem::returnClientQuestState(int nQid, int nCode)
|
||
{
|
||
QuestItem* item = GetGoingQuestData(nQid);
|
||
if(item)
|
||
{
|
||
CActorPacket ap;
|
||
CDataPacket &data = ((CActor*)m_pEntity)->AllocPacket(ap);
|
||
data <<(BYTE)enQuestSystemID <<(BYTE)sChangetQuestState;
|
||
data <<(BYTE)nCode;
|
||
returnQuestData(item, data);
|
||
ap.flush();
|
||
}
|
||
}
|
||
|
||
void CQuestSystem::SendClientQuestState(int nQid)
|
||
{
|
||
QuestItem* item = GetGoingQuestData(nQid);
|
||
if(item)
|
||
{
|
||
CActorPacket ap;
|
||
CDataPacket &data = ((CActor*)m_pEntity)->AllocPacket(ap);
|
||
data <<(BYTE)enQuestSystemID <<(BYTE)sChangeQuestState;
|
||
returnQuestData(item, data);
|
||
ap.flush();
|
||
}
|
||
}
|
||
|
||
|
||
void CQuestSystem::DealAutoChangeQuestState(int Type, int nQid, int nState, QuestInfoCfg* cfg)
|
||
{
|
||
if(!cfg) return;
|
||
|
||
if(cfg->awards.size() > 0)
|
||
{
|
||
if(!m_pEntity->GetBagSystem().bagIsEnough(BagRequest))
|
||
{
|
||
m_pEntity->SendTipmsgFormatWithId(tmLeftBagNumNotEnough,tstUI);
|
||
return;
|
||
}
|
||
|
||
for(int k = 0; k < cfg->awards.size(); k++)
|
||
{
|
||
((CActor*)m_pEntity)->GiveAward(cfg->awards[k].nType, cfg->awards[k].nId,cfg->awards[k].nCount,0,0,0,0, GameLog::Log_Quest);
|
||
}
|
||
}
|
||
int Job = m_pEntity->GetProperty<int>(PROP_ACTOR_VOCATION);
|
||
std::vector<ChangeQuestState> Lists;
|
||
Lists.clear();
|
||
if(Type == 1)
|
||
Lists = cfg->button;
|
||
else
|
||
Lists = cfg->nAuto;
|
||
|
||
if(Lists.size() > 0) {
|
||
|
||
for(int i = 0; i < Lists.size(); i++) {
|
||
|
||
if(!ChangeGoingQuestState(Lists[i].nQid, Lists[i].nState)) {
|
||
|
||
QuestInfoCfg* newCfg = GetLogicServer()->GetDataProvider()->GetQuestConfig()->GetQuestConfig(Lists[i].nQid, Lists[i].nState);
|
||
if(!newCfg)
|
||
continue;
|
||
int nJob = newCfg->nQid /QUESTMAIN;
|
||
if( nJob != 0 && nJob != Job)
|
||
continue;
|
||
if(GetLogicServer()->CheckOpenServer(newCfg->nOpenDayLimit) && m_pEntity->CheckLevel(newCfg->nLevelLimit, newCfg->nCircle)) {
|
||
AddQuest(newCfg);
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
|
||
if(cfg->nIscomplete) {
|
||
|
||
if(cfg->nAnnular == 0)
|
||
SetfinishQuest(nQid);
|
||
|
||
//记录状态
|
||
GetLogicServer()->SendTaskLocalLog(nQid, ((CActor*)m_pEntity), cfg->ntasktype, 2);
|
||
RemoveGoingQuestData(nQid);
|
||
CActorPacket ap;
|
||
CDataPacket &data = ((CActor*)m_pEntity)->AllocPacket(ap);
|
||
data <<(BYTE)enQuestSystemID <<(BYTE)sDeleteQuest;
|
||
data <<(int)nQid;
|
||
data <<(int)nState;
|
||
ap.flush();
|
||
CScriptValueList paramList,retList;
|
||
static CNpc* globalNpc = GetGlobalLogicEngine()->GetGlobalNpc();
|
||
paramList << (int)enOnCompleteQuest;
|
||
paramList << (int)nQid;
|
||
paramList << m_pEntity;
|
||
if(!globalNpc->GetScript().CallModule("QuestDispatcher","OnEvent", paramList, retList, 1))
|
||
{
|
||
OutputMsg(rmError,"[QuestSystem] OnEvent CheckEnter 错误，任务ID=%d!",nQid);
|
||
}
|
||
// if(retList.count() >= 0 && (bool)retList[0] == false)
|
||
// {
|
||
// return;
|
||
// }
|
||
}
|
||
|
||
}
|
||
|
||
|
||
QuestItem* CQuestSystem::GetGoingQuestData(int nQid)
|
||
{
|
||
for(int i = 0; i < m_GoingQuestList.size(); i++)
|
||
{
|
||
if(m_GoingQuestList[i].nQid == nQid)
|
||
return &m_GoingQuestList[i];
|
||
}
|
||
|
||
return NULL;
|
||
}
|
||
|
||
void CQuestSystem::RemoveGoingQuestData(int nQid)
|
||
{
|
||
std::vector<QuestItem>::iterator it = m_GoingQuestList.begin();
|
||
for(; it != m_GoingQuestList.end();)
|
||
{
|
||
if((*it).nQid == nQid)
|
||
{
|
||
it =m_GoingQuestList.erase(it);
|
||
}
|
||
else
|
||
{
|
||
it++;
|
||
}
|
||
}
|
||
isDataModify = true;
|
||
}
|
||
|
||
|
||
bool CQuestSystem::ChangeGoingQuestState(int nQid, int nState)
|
||
{
|
||
QuestItem* item = GetGoingQuestData(nQid);
|
||
if(item)
|
||
{
|
||
QuestInfoCfg* cfg = GetLogicServer()->GetDataProvider()->GetQuestConfig()->GetQuestConfig(nQid, nState);
|
||
if(!cfg) {
|
||
return false;
|
||
}
|
||
item->nState = nState;
|
||
item->nType = cfg->GeLimitType();
|
||
//客户端需求 需要改变任务状态进行推送
|
||
SendClientQuestState(nQid);
|
||
if (cfg->nAcceptState)
|
||
GetLogicServer()->SendTaskLocalLog(nQid, ((CActor*)m_pEntity), cfg->ntasktype, 1);
|
||
DealAutoCompleteCfgValue(nQid);
|
||
isDataModify = true;
|
||
return true;
|
||
}
|
||
return false;
|
||
}
|
||
|
||
|
||
bool CQuestSystem::returnQuestData(QuestItem* item, CDataPacket& DataPacket)
|
||
{
|
||
if(item )
|
||
{
|
||
QuestInfoCfg* cfg = GetLogicServer()->GetDataProvider()->GetQuestConfig()->GetQuestConfig(item->nQid, item->nState);
|
||
if(!cfg) {
|
||
return false;
|
||
}
|
||
DataPacket << item->nQid;
|
||
DataPacket << item->nState;
|
||
DataPacket << cfg->GetLimitValue();
|
||
DataPacket << item->nValue;
|
||
QuestAward pCost;
|
||
cfg->GetCostFsValue(item->nUseFsTimes, pCost);
|
||
// QuestCostFlyshoe* pCost = cfg->GetCostFsValue(item->nUseFsTimes);
|
||
DataPacket <<(int)(pCost.nCount);
|
||
return true;
|
||
}
|
||
return false;
|
||
}
|
||
|
||
//重载
|
||
bool CQuestSystem::ChangeGoingQuestState(std::vector<ChangeQuestState>& nChangeList)
|
||
{
|
||
if(nChangeList.size() > 0)
|
||
{
|
||
for(int i = 0; i < nChangeList.size(); i++)
|
||
{
|
||
ChangeGoingQuestState(nChangeList[i].nQid, nChangeList[i].nState);
|
||
}
|
||
}
|
||
}
|
||
|
||
|
||
bool CQuestSystem::CheckComplete(QuestItem* item, int nLimit)
|
||
{
|
||
if(nLimit == 0) return true;
|
||
if(!item) return false;
|
||
|
||
if(item->nValue >= nLimit)
|
||
return true;
|
||
|
||
return false;
|
||
}
|
||
|
||
|
||
bool CQuestSystem::AddQuest(QuestInfoCfg* cfg)
|
||
{
|
||
if(!cfg) return false;
|
||
QuestItem item;
|
||
item.nQid = cfg->nQid;
|
||
item.nType = cfg->mQuestInfo.nType;
|
||
item.nState = cfg->nState;
|
||
if (cfg->nAcceptState)
|
||
GetLogicServer()->SendTaskLocalLog(cfg->nQid, ((CActor*)m_pEntity), cfg->ntasktype, 1);
|
||
//记录接取状态
|
||
// GetLogicServer()->SendTaskLocalLog(cfg->nQid, ((CActor*)m_pEntity), cfg->mQuestInfo.nType, cfg->nState);
|
||
if(CheckComplete(&item, cfg->mQuestInfo.nValue))
|
||
{
|
||
ChangeGoingQuestState(cfg->nAuto);
|
||
}
|
||
|
||
if(cfg->nAnnular)
|
||
{
|
||
item.nStartId = cfg->nAnnular;
|
||
m_RingStartQId.push_back(item.nStartId);
|
||
}
|
||
m_GoingQuestList.push_back(item);
|
||
|
||
if (!((CActor*)m_pEntity)->OnGetIsTestSimulator()
|
||
&& !((CActor*)m_pEntity)->OnGetIsSimulator())
|
||
{
|
||
SendAddNewQuest(&item);
|
||
}
|
||
DealAutoCompleteCfgValue(cfg->nQid);
|
||
isDataModify = true;
|
||
return true;
|
||
}
|
||
|
||
void CQuestSystem::SendAddNewQuest(QuestItem* item)
|
||
{
|
||
CActorPacket ap;
|
||
CDataPacket &data = ((CActor*)m_pEntity)->AllocPacket(ap);
|
||
data <<(BYTE)enQuestSystemID <<(BYTE)sAddQuest;
|
||
returnQuestData(item, data);
|
||
ap.flush();
|
||
}
|
||
void CQuestSystem::Save(PACTORDBDATA pActorData)
|
||
{
|
||
|
||
memcpy(pActorData->quest, m_FinishedQuest,sizeof(m_FinishedQuest));
|
||
SaveData();
|
||
}
|
||
|
||
//保存玩家成就完成进度情况
|
||
void CQuestSystem::SaveData()
|
||
{
|
||
if(!m_pEntity) return;
|
||
|
||
// if(!isInitData) return;
|
||
|
||
if(!isDataModify) return;
|
||
|
||
CDataPacket& dataPacket = GetLogicServer()->GetDbClient()->allocProtoPacket(jxInterSrvComm::DbServerProto::dcSaveQuest);
|
||
dataPacket <<((CActor*)m_pEntity)->GetRawServerIndex() << GetLogicServer()->GetServerIndex();
|
||
|
||
dataPacket <<(unsigned int)m_pEntity->GetId(); //玩家id
|
||
size_t count = m_GoingQuestList.size();
|
||
dataPacket <<(int)count;
|
||
for(int i = 0; i < count; i++)
|
||
{
|
||
QuestItem & item = m_GoingQuestList[i];
|
||
dataPacket.writeBuf(&item, sizeof(item));
|
||
}
|
||
GetLogicServer()->GetDbClient()->flushProtoPacket(dataPacket);
|
||
|
||
isDataModify = false;
|
||
}
|
||
|
||
|
||
|
||
void CQuestSystem::ClearAllQuest()
|
||
{
|
||
m_GoingQuestList.clear();
|
||
memset(m_FinishedQuest, 0 ,sizeof(m_FinishedQuest));
|
||
m_RingStartQId.clear();
|
||
CheckCanAcceptQuest();
|
||
}
|
||
|
||
|
||
bool CQuestSystem::GMSetQuestState(int nQid, int nState)
|
||
{
|
||
if(!ChangeGoingQuestState(nQid, nState)) {
|
||
|
||
QuestInfoCfg* newCfg = GetLogicServer()->GetDataProvider()->GetQuestConfig()->GetQuestConfig(nQid, nState);
|
||
if(newCfg) {
|
||
AddQuest(newCfg);
|
||
}
|
||
}
|
||
|
||
QuestItem* item = GetGoingQuestData(nQid);
|
||
if(item)
|
||
{
|
||
QuestInfoCfg* newCfg = GetLogicServer()->GetDataProvider()->GetQuestConfig()->GetQuestConfig(nQid, nState);
|
||
if(newCfg && item->nValue < newCfg->GetLimitValue())
|
||
item->nValue = 0;
|
||
returnClientQuestState(nQid, 0);
|
||
}
|
||
return true;
|
||
}
|
||
|
||
|
||
|
||
//对于等级 装备等 需要自动判定是否已经完成了任务
|
||
void CQuestSystem::DealAutoCompleteCfgValue(int nQid)
|
||
{
|
||
QuestItem* item = GetGoingQuestData(nQid);
|
||
if(item)
|
||
{
|
||
QuestInfoCfg* cfg = GetLogicServer()->GetDataProvider()->GetQuestConfig()->GetQuestConfig(nQid, item->nState);
|
||
if(!cfg) {
|
||
return;
|
||
}
|
||
int nQuestType = cfg->GeLimitType() / 100;
|
||
bool nFalg = false;
|
||
if(nQuestType== CQuestData::qtEquip)
|
||
{
|
||
m_pEntity->GetEquipmentSystem().DealEquipmentAchieve();
|
||
}
|
||
else if(nQuestType == CQuestData::qtLevel)
|
||
{
|
||
|
||
OnQuestEvent(CQuestData::qtLevel, ((CActor*)m_pEntity)->GetLevel());
|
||
}
|
||
else if(nQuestType == CQuestData::qtcircle)
|
||
{
|
||
if(cfg->GetLimitValue() <= ((CActor*)m_pEntity)->GetCircleLevel() )
|
||
{
|
||
OnQuestEvent(CQuestData::qtcircle, ((CActor*)m_pEntity)->GetCircleLevel());
|
||
}
|
||
}
|
||
else if(nQuestType == CQuestData::qtSkillLv)
|
||
{
|
||
int nSkillLv = m_pEntity->GetSkillSystem().GetSkillLevel(cfg->GeLimitSubType());
|
||
if(cfg->GetLimitValue() <= nSkillLv )
|
||
{
|
||
OnQuestEvent(CQuestData::qtSkillLv, nSkillLv, cfg->GeLimitSubType());
|
||
}
|
||
}
|
||
else if(nQuestType == CQuestData::qtBless)
|
||
{
|
||
int nBlessValue = ((CActor*)m_pEntity)->GetProperty<unsigned int>(PROP_ACTOR_Bless);
|
||
int nBlessLv = 0;
|
||
BlessCfg* pBlessCfg = GetLogicServer()->GetDataProvider()->GetBlessCfg().GetBlessCfg(nBlessValue);
|
||
if(pBlessCfg)
|
||
{
|
||
nBlessLv = pBlessCfg->nLevel;
|
||
}
|
||
|
||
OnQuestEvent(CQuestData::qtBless, nBlessLv, cfg->GeLimitSubType());
|
||
}
|
||
}
|
||
}
|