⭐ 欢迎来到虫虫下载站！ | 📦 资源下载 📁 资源专辑 ℹ️ 关于我们
⭐ 虫虫下载站
📤 上传资源

📄 package.cpp

📁 魔域的源代码
💻 CPP
字号:
🔍 
// Package.cpp: implementation of the CPackage class.
//
//////////////////////////////////////////////////////////////////////

#include "AllMsg.h"
#include "Package.h"
#include "User.h"
//#include "mapgroup.h"
MYHEAP_IMPLEMENTATION(CPackage,s_heap)
//////////////////////////////////////////////////////////////////////
// Construction/Destruction
//////////////////////////////////////////////////////////////////////
CPackage::CPackage()
{
	m_nType		= _STORE_NONE;
	m_setItem	= NULL;
}

//////////////////////////////////////////////////////////////////////
CPackage::~CPackage()
{
	if(m_setItem)
		m_setItem->Release();
}

//////////////////////////////////////////////////////////////////////
bool CPackage::Create(int nType, OBJID idOwner, OBJID idPlayer, IDatabase* pDb)		// 可重复调用
{
	CHECKF(nType != _STORE_NONE);
	if(nType == m_nType && idOwner == m_idOwner && idPlayer == m_idPlayer)
		return true;

	m_nType		= nType;
	m_idOwner	= idOwner;
	m_idPlayer	= idPlayer;

	// add by zlong 2003-11-24 ---- 判断ucType
	switch (m_nType)
	{
	case ITEMPOSITION_STORAGE:
		m_ucType	= MSGPACKAGE_TYPE_STORAGE;
		break;
	case ITEMPOSITION_TRUNK:
		m_ucType	= MSGPACKAGE_TYPE_TRUNK;
		break;
	case ITEMPOSITION_CHEST:
		m_ucType	= MSGPACKAGE_TYPE_CHEST;
		break;
	case ITEMPOSITION_EUDEMON_BROODER:
		m_ucType	= MSGPACKAGE_TYPE_EUDEMON_BROODER;
		break;
	case ITEMPOSITION_EUDEMON_STORAGE:
		m_ucType	= MSGPACKAGE_TYPE_EUDEMON_STORAGE;
		break;
	case ITEMPOSITION_AUCTION_STORAGE:
	case ITEMPOSITION_AUCTION_SYS_STORAGE:
		m_ucType    = MSGPACKAGE_TYPE_AUCTION_STORAGE;
		break;
	default:
		m_ucType = MSGPACKAGE_TYPE_NONE;
		break;
	};      
	
	
	if(m_setItem)
		m_setItem->Release();
	m_setItem	= CItemSet::CreateNew(true);
	CHECKF(m_setItem);
	
	int	nPosition = m_nType;		// 相同
	SQLBUF	szSQL;
	//-----------------------只有拍买系统用到ＬＷ-------------------------
	if(m_ucType == MSGPACKAGE_TYPE_AUCTION_STORAGE)
	{
		if(idPlayer == 0)//拍买ＮＰＣ仓库
			sprintf(szSQL,"SELECT * FROM %s WHERE owner_id=%u && position=%d", _TBL_ITEM, idOwner, nPosition/*,AUCTION_CHIP*/);
		else//玩家拍买仓库
			sprintf(szSQL,"SELECT * FROM %s WHERE owner_id=%u && player_id=%u && position=%d LIMIT 6",_TBL_ITEM, idOwner, idPlayer, nPosition);
	}
	//--------------------------------------------------------------------
	else
		sprintf(szSQL, "SELECT * FROM %s WHERE owner_id=%u && player_id=%u && position=%d  LIMIT %d", _TBL_ITEM, idOwner, idPlayer, nPosition, PACKAGE_LIMIT);
	IRecordset* pRes = pDb->CreateNewRecordset(szSQL, false);
	if(!pRes)
		return true;
	for(int i = 0; i < pRes->RecordCount(); i++,pRes->MoveNext())
	{
		CItemPtr pItem = CItem::CreateNew();
		ASSERT(pItem);
		if(!pItem)
			continue;
		
		if(pItem->Create(pRes, pDb))
		{
			m_setItem->AddObj(pItem);
			// m_setItemEx->AddObj(pItem);
		}
		else
			pItem->ReleaseByOwner();
	}
	pRes->Release();
	
	return true;
}
//----------------------------------------------------------------------
//bool CPackage::AuctionGoodsBackOff
//LW 2005-01-12
//将拍买物品返还给玩家
//----------------------------------------------------------------------
CItem* CPackage::AuctionGoodsBackOff(OBJID idOwner,OBJID idItem, bool bUpdate/* = true*/)
{	
//	CHECKF(idPlayer != NULL);
	CHECKF(idOwner != NULL);
	CHECKF(m_nType != _STORE_NONE);
	
	CItemPtr pItem = m_setItem->GetObj(idItem);
	if(!pItem)
		return false;
	pItem->SetInt(ITEMDATA_OWNERID, idOwner, UPDATE_FALSE);
	pItem->SetInt(ITEMDATA_PLAYERID, idOwner, UPDATE_FALSE);
	pItem->SetInt(ITEMDATA_POSITION, ITEMPOSITION_AUCTION_STORAGE, bUpdate);
	m_setItem->PopObj(idItem);
	return pItem;
}

//////////////////////////////////////////////////////////////////////
bool CPackage::CheckIn(CUser* pUser, CItem* pItem, bool bUpdate /*= true*/)
{
	DEBUG_TRY
	CHECKF(m_nType != _STORE_NONE);
	CHECKF(pUser);
	CHECKF(pItem);
	
	if(m_nType == ITEMPOSITION_CHEST && !pItem->IsExchangeEnable())
	{
		//		pUser->SendSysMsg("错误：此物品不宜存放!");
		return false;
	}
	
	int		nPosition = m_nType;		// 相同
	OBJID	idPlayer = (IsPlayerPackage() ? pUser->GetID() : ID_NONE);
	pItem->SetInt(ITEMDATA_OWNERID, m_idOwner, UPDATE_FALSE);
	pItem->SetInt(ITEMDATA_PLAYERID, idPlayer, UPDATE_FALSE);
	pItem->SetInt(ITEMDATA_POSITION, nPosition, bUpdate);
	m_setItem->AddObj(pItem);
	
	// synchro
	MsgPackageItemInfo	info;
	info.idItem		= pItem->GetID();
	info.idItemType	= pItem->GetInt(ITEMDATA_TYPE);
	info.usAmount	= pItem->GetInt(ITEMDATA_AMOUNT);
	info.usAmountLimit	= pItem->GetInt(ITEMDATA_AMOUNTLIMIT);
	info.ucIdent	= pItem->GetInt(ITEMDATA_IDENT);
	info.ucGem1		= pItem->GetInt(ITEMDATA_GEM1);
	info.ucGem2		= pItem->GetInt(ITEMDATA_GEM2);
	info.ucMagic1	= pItem->GetInt(ITEMDATA_MAGIC1);
	info.ucMagic2	= pItem->GetInt(ITEMDATA_MAGIC2);
	info.ucMagic3	= pItem->GetInt(ITEMDATA_MAGIC3);

	info.nData		= pItem->GetInt(ITEMDATA_DATA);
	info.dwWarGhostExp		= pItem->GetInt(ITEMDATA_WARGHOSTEXP);
	info.dwGemAtkType		= pItem->GetInt(ITEMDATA_GEMTYPE);
	info.dwAvailableTime	= pItem->GetInt(ITEMDATA_AVAILABLETIME);
	::SafeCopy(info.szName, pItem->GetStr(ITEMDATA_NAME), _MAX_NAMESIZE);

	// modified by zlong 2003-11-24 ---- 指定ucType类别
	CMsgPackage msg;
	CHECKF(msg.Create(MSGPACKAGE_CHECKIN, m_idOwner, &info, 1, m_ucType));
	pUser->SendMsg(&msg);
	DEBUG_CATCH("CPackage::CheckIn ERROR!")
	return true;
}
//----------------------------------------------------------------------
//CItem*  CPackage::CheckOut(OBJID idPlayer, OBJID idItem, bool bUpdate)
//LW 2005-01-12
//在玩家取出拍买仓库的物品时，删除在Ｎｐｃ拍买仓库中的Item内存变量，数据
//库在玩家取出物品时已修改，所以不用操作数据库
//----------------------------------------------------------------------
CItem*	CPackage::CheckOut(OBJID idItem)
{
	CItemPtr pItem = m_setItem->GetObj(idItem);
	if(!pItem)
		return false;
	m_setItem->PopObj(idItem);
	return pItem;
}
//////////////////////////////////////////////////////////////////////
CItem* CPackage::CheckOut(CUser* pUser, OBJID idItem, bool bUpdate)
{
	CHECKF(m_nType != _STORE_NONE);
	
	CItemPtr pItem = m_setItem->GetObj(idItem);
	if(!pItem)
		return false;
	
	pItem->SetInt(ITEMDATA_OWNERID, pUser->GetID(), UPDATE_FALSE);
	pItem->SetInt(ITEMDATA_PLAYERID, pUser->GetID(), UPDATE_FALSE);
	pItem->SetInt(ITEMDATA_POSITION, pUser->QueryPackage()->GetItemPosition(pItem), bUpdate);
	m_setItem->PopObj(idItem);
	// modified by zlong 2003-11-24 ---- 指定ucType类别
	// synchro
	
	CMsgPackage msg;
	CHECKF(msg.Create(MSGPACKAGE_CHECKOUT, m_idOwner, idItem, m_ucType));
	pUser->SendMsg(&msg);
	return pItem;
}
//////////////////////////////////////////////////////////////////////
bool CPackage::SendInfo(CUser* pUser)
{
	CHECKF(m_nType != _STORE_NONE);
	CHECKF(pUser);

	int nAction = MSGPACKAGE_QUERYLIST;
	MsgPackageItemInfo	buf[PACKAGE_LIMIT];
	int		nCount = 0;
	DWORD	dwCurrTime = ::TimeGet(TIME_SECOND);
	for(int i = 0; i < m_setItem->GetAmount(); i++)
	{
		CItemPtr pItem = m_setItem->GetObjByIndex(i);
		if(pItem && nCount < PACKAGE_LIMIT)
		{
			///////////////////////////////////////////////////
			// 幻兽系统的幻兽蛋孵化在这里进行
			if (m_ucType == MSGPACKAGE_TYPE_EUDEMON_BROODER && pItem->IsEudemonEgg())
			{
				if (dwCurrTime > pItem->GetInt(ITEMDATA_AVAILABLETIME)
					&& dwCurrTime - pItem->GetInt(ITEMDATA_AVAILABLETIME) >= EUDEMON_HATCH_SECS)
				{
					pUser->HatchEudemon(pItem);
				}
			}
			///////////////////////////////////////////////////

			buf[nCount].usAmount	= pItem->GetInt(ITEMDATA_AMOUNT);
			buf[nCount].usAmountLimit	= pItem->GetInt(ITEMDATA_AMOUNTLIMIT);
			buf[nCount].ucIdent		= pItem->GetInt(ITEMDATA_IDENT);
			buf[nCount].ucGem1		= pItem->GetInt(ITEMDATA_GEM1);
			buf[nCount].ucGem2		= pItem->GetInt(ITEMDATA_GEM2);
			buf[nCount].ucMagic1	= pItem->GetInt(ITEMDATA_MAGIC1);
			buf[nCount].ucMagic2	= pItem->GetInt(ITEMDATA_MAGIC2);
			buf[nCount].ucMagic3	= pItem->GetInt(ITEMDATA_MAGIC3);

			buf[nCount].idItem			= pItem->GetID();
			buf[nCount].idItemType	= pItem->GetInt(ITEMDATA_TYPE);

			buf[nCount].nData		= pItem->GetInt(ITEMDATA_DATA);
			buf[nCount].dwWarGhostExp	= pItem->GetInt(ITEMDATA_WARGHOSTEXP);
			buf[nCount].dwGemAtkType	= pItem->GetInt(ITEMDATA_GEMTYPE);
			// 如果是幻兽蛋，发送孵化剩余的时间
			if (pItem->IsEudemonEgg())
				buf[nCount].dwAvailableTime	= __max(0, EUDEMON_HATCH_SECS - (int)(dwCurrTime - pItem->GetInt(ITEMDATA_AVAILABLETIME)));
			else
				buf[nCount].dwAvailableTime	= pItem->GetInt(ITEMDATA_AVAILABLETIME);
			::SafeCopy(buf[nCount].szName, pItem->GetStr(ITEMDATA_NAME), _MAX_NAMESIZE);

			++nCount;

			// 为了避免一次数据过多，分多次发送
			const int	ITEMS_PER_PAGE	= 10;
			if (nCount >= ITEMS_PER_PAGE)
			{
				CMsgPackage msg;
				CHECKF(msg.Create(nAction, m_idOwner, buf, nCount, m_ucType));
				pUser->SendMsg(&msg);
				nCount = 0;
				nAction = MSGPACKAGE_QUERYLIST2;
			}
		}
		else
			break;
	}

	// modified by zlong 2003-11-24 ---- 指定ucType类别
	// synchro
	if (nCount > 0)
	{
		CMsgPackage msg;
		CHECKF(msg.Create(nAction, m_idOwner, buf, nCount, m_ucType));
		pUser->SendMsg(&msg);
	}

	return true;
}

//////////////////////////////////////////////////////////////////////
int CPackage::GetItemType(int index)
{
	CHECKF(m_nType != _STORE_NONE);

	if(index >= 0 && index < m_setItem->GetAmount())
	{
		CItemPtr pItem = m_setItem->GetObjByIndex(index);
		if(pItem)
			return  pItem->GetInt(ITEMDATA_TYPE);
	}

	return ID_NONE;
}

//////////////////////////////////////////////////////////////////////
int CPackage::GetWeight(OBJID idItem)
{
	CHECKF(m_nType != _STORE_NONE);

	CItemPtr pItem = m_setItem->GetObj(idItem);
	if(!pItem)
		return ERROR_WEIGHT;

	return pItem->GetWeight();
}

//////////////////////////////////////////////////////////////////////
OBJID CPackage::GetItemTypeByID(OBJID idItem)
{
	CHECKF(m_nType != _STORE_NONE);

	CItemPtr pItem = m_setItem->GetObj(idItem);
	if(!pItem)
		return ID_NONE;

	return pItem->GetInt(ITEMDATA_TYPE);
}
//----------------------------------------------------------------------
//CItem*  CPackage::CAuctionChip
//LW 2005-01-12
//给玩家一个拍买筹码，如果存在，取合并Ｄａｔａ，否则创建一个筹码
//当玩家不在线或不会拍买所在的地图组时，才会调用此函数。
//----------------------------------------------------------------------
bool  CPackage::CAuctionChip(/*OBJID idNpc,*/OBJID idUser,DWORD value,IRecordset* pRecordset,IDatabase* pDb)
{
	try{ ////////
		CHECKF(pDb);
		SQLBUF	szSQL;
		sprintf(szSQL, "SELECT * FROM %s WHERE type=%u && player_id=%d && position=%d  LIMIT 1", _TBL_ITEM, AUCTION_CHIP, idUser,ITEMPOSITION_AUCTION_STORAGE);
		IRecordset* pRes = pDb->CreateNewRecordset(szSQL);
		if(pRes && pRes->RecordCount())
		{
			DEBUG_TRY
			pRes->SetInt(ITEMDATA_DATA,pRes->GetInt(ITEMDATA_DATA)+value);
			pRes->UpdateRecord();
			pRes->Release();
			return true;
			DEBUG_CATCH("CPackage::CAuctionChip UpdateRecord() ERROR!");
			return false;
		}
		CItemPtr pItem = NULL;
		pItem = CItem::CreateNew();
		if(pItem->Create(pRecordset, AUCTION_CHIP, idUser, ITEMPOSITION_AUCTION_STORAGE))
		{
			pItem->SetInt(ITEMDATA_DATA,value,UPDATE_TRUE);
			return true;
		}
		else
		{
			LOGERROR("Create DefaultItem Error!");
			return false;
		}
	}
	catch(...)
	{
		LOGERROR("CItem*  CPackage::CAuctionChip Error!");
		return false;
	}
}
DWORD CPackage::GetItemAmountLimitByID(OBJID idItem)
{
	CHECKF(m_nType != _STORE_NONE);

	CItemPtr pItem = m_setItem->GetObj(idItem);
	if(!pItem)
		return 0;

	return pItem->GetInt(ITEMDATA_AMOUNTLIMIT);
}

⌨️ 快捷键说明

复制代码 Ctrl + C
搜索代码 Ctrl + F
全屏模式 F11
切换主题 Ctrl + Shift + D
显示快捷键 ?
增大字号 Ctrl + =
减小字号 Ctrl + -