vampireportalitem.cpp

天之炼狱1服务器端源文件游戏服务端不完整

//////////////////////////////////////////////////////////////////////////////
// class VampirePortalItemInfo member methods
//////////////////////////////////////////////////////////////////////////////

void VampirePortalItemInfoManager::load() 
	throw(Error)
{
	__BEGIN_TRY

	Statement* pStmt   = NULL;
	Result*    pResult = NULL;

	BEGIN_DB 
	{
		pStmt = g_pDatabaseManager->getConnection("DARKEDEN")->createStatement();
		pResult = pStmt->executeQuery("SELECT MAX(ItemType) FROM VampirePortalItemInfo");

        pResult->next();

        m_InfoCount = pResult->getInt(1);

        m_pItemInfos = new ItemInfo*[m_InfoCount+1];

        for (uint i = 0 ; i <= m_InfoCount ; i ++)
            m_pItemInfos[i] = NULL;

        pResult = pStmt->executeQuery(
			"SELECT ItemType, Name, EName, Price, Volume, Weight, Ratio, MaxCharge, ReqAbility FROM VampirePortalItemInfo"
		);

		while (pResult->next()) 
		{
			uint i = 0;

			VampirePortalItemInfo* pVampirePortalItemInfo = new VampirePortalItemInfo();
			pVampirePortalItemInfo->setItemType(pResult->getInt(++i));
			pVampirePortalItemInfo->setName(pResult->getString(++i));
			pVampirePortalItemInfo->setEName(pResult->getString(++i));
			pVampirePortalItemInfo->setPrice(pResult->getInt(++i));
			pVampirePortalItemInfo->setVolumeType(pResult->getInt(++i));
			pVampirePortalItemInfo->setWeight(pResult->getInt(++i));
			pVampirePortalItemInfo->setRatio(pResult->getInt(++i));
			pVampirePortalItemInfo->setMaxCharge(pResult->getInt(++i));
			pVampirePortalItemInfo->setReqAbility(pResult->getString(++i));

			addItemInfo(pVampirePortalItemInfo);
		}
		
		SAFE_DELETE(pStmt);
	}
	END_DB(pStmt)
	
	__END_CATCH
}

string VampirePortalItemInfo::toString() const 
	throw()
{
	__BEGIN_TRY

	StringStream msg;
	msg << "VampirePortalItemInfo("
		<< "ItemType:"     << m_ItemType
		<< ",Name:"        << m_Name
		<< ",EName:"       << m_EName
		<< ",Price:"       << m_Price
		<< ",VolumeType:"  << Volume2String[m_VolumeType]
		<< ",Weight:"      << m_Weight
		<< ",MaxCharge:"   << m_MaxCharge
		<< ")";
	return msg.toString();

	__END_CATCH
}


//////////////////////////////////////////////////////////////////////////////
// class VampirePortalItemLoader member methods
//////////////////////////////////////////////////////////////////////////////

void VampirePortalItemLoader::load(Creature* pCreature) 
	throw(Error)
{
	__BEGIN_TRY

	Assert(pCreature != NULL);

	Statement* pStmt = NULL;
	Result* pResult = NULL;

	BEGIN_DB 
	{
		pStmt   = g_pDatabaseManager->getConnection("DARKEDEN")->createStatement();

		/*
		StringStream sql;

		sql << "SELECT ItemID, ObjectID, ItemType, Storage, StorageID, X, Y, Charge, TargetZID, TargetX, TargetY FROM VampirePortalItemObject"
			<< " WHERE OwnerID = '" << pCreature->getName() << "' AND Storage IN("
			<< (int)STORAGE_INVENTORY << "," << (int)STORAGE_GEAR       << "," <<(int)STORAGE_BELT << "," 
			<< (int)STORAGE_EXTRASLOT << "," << (int)STORAGE_MOTORCYCLE << "," <<(int)STORAGE_STASH << ", " 
			<<(int)STORAGE_GARBAGE << ")";

		pResult = pStmt->executeQuery(sql.toString());
		*/

		pResult = pStmt->executeQuery( "SELECT ItemID, ObjectID, ItemType, Storage, StorageID, X, Y, Charge, TargetZID, TargetX, TargetY FROM VampirePortalItemObject WHERE OwnerID = '%s' AND Storage IN(0, 1, 2, 3, 4, 9)",
												pCreature->getName().c_str() );




		while (pResult->next())
		{
			try {
				uint i = 0;

				ItemID_t     itemID    = pResult->getDWORD(++i);
				ObjectID_t   objectID  = pResult->getDWORD(++i);
				ItemType_t   itemType  = pResult->getDWORD(++i);
				Storage      storage   = (Storage)pResult->getInt(++i);
				StorageID_t  storageID = pResult->getDWORD(++i);
				BYTE         x         = pResult->getBYTE(++i);
				BYTE         y         = pResult->getBYTE(++i);
				int          charge    = pResult->getInt(++i);
				ZoneID_t     TargetZID = pResult->getWORD(++i);
				ZoneCoord_t  TargetX   = pResult->getWORD(++i);
				ZoneCoord_t  TargetY   = pResult->getWORD(++i);

				VampirePortalItem* pVampirePortalItem = new VampirePortalItem();
				pVampirePortalItem->setItemID(itemID);
				pVampirePortalItem->setObjectID(objectID);
				pVampirePortalItem->setItemType(itemType);
				pVampirePortalItem->setCharge(charge);
				pVampirePortalItem->setZoneID(TargetZID);
				pVampirePortalItem->setX(TargetX);
				pVampirePortalItem->setY(TargetY);

				Inventory*  pInventory      = NULL;
				Slayer*     pSlayer         = NULL;
				Vampire*    pVampire        = NULL;
				Motorcycle* pMotorcycle     = NULL;
				Inventory*  pMotorInventory = NULL;
				//Item*       pItem           = NULL;
				Stash*      pStash          = NULL;
				//Belt*       pBelt           = NULL;
				//Inventory*  pBeltInventory  = NULL;

				if (pCreature->isSlayer())
				{
					pSlayer     = dynamic_cast<Slayer*>(pCreature);
					pInventory  = pSlayer->getInventory();
					pStash      = pSlayer->getStash();
					pMotorcycle = pSlayer->getMotorcycle();

					if (pMotorcycle != NULL) pMotorInventory = pMotorcycle->getInventory();
				}
				else if (pCreature->isVampire()) 
				{
					pVampire   = dynamic_cast<Vampire*>(pCreature);
					pInventory = pVampire->getInventory();
					pStash     = pVampire->getStash();
				}
				else throw UnsupportedError("Monster,NPC 牢亥配府狼 历厘篮 酒流 瘤盔登瘤 臼嚼聪促.");

				if (storage == STORAGE_INVENTORY)
				{
					if (pInventory->canAddingEx(x, y, pVampirePortalItem))
					{
						pInventory->addItemEx(x, y, pVampirePortalItem);
					}
					else
					{
						processItemBugEx(pCreature, pVampirePortalItem);
					}
				}
				else if (storage == STORAGE_GEAR)
				{
					processItemBugEx(pCreature, pVampirePortalItem);
				}
				else if (storage == STORAGE_BELT)
				{
					processItemBugEx(pCreature, pVampirePortalItem);
				}
				else if (storage == STORAGE_EXTRASLOT)
				{
					if (pCreature->isSlayer())       pSlayer->addItemToExtraInventorySlot(pVampirePortalItem);
					else if (pCreature->isVampire()) pVampire->addItemToExtraInventorySlot(pVampirePortalItem);
				}
				else if (storage == STORAGE_MOTORCYCLE)
				{
					processItemBugEx(pCreature, pVampirePortalItem);
				}
				else if (storage == STORAGE_STASH)
				{
					if (pStash->isExist(x, y))
					{
						processItemBugEx(pCreature, pVampirePortalItem);
					}
					else pStash->insert(x, y, pVampirePortalItem);
				}
				else if (storage == STORAGE_GARBAGE)
				{
					processItemBug(pCreature, pVampirePortalItem);
				}
				else
				{
					SAFE_DELETE(pStmt);	// by sigi
					throw Error("invalid storage or OwnerID must be NULL");
				}
			} catch (Error& error) {
				filelog("itemLoadError.txt", "[%s] %s", getItemClassName().c_str(), error.toString().c_str());
				throw;
			} catch (Throwable& t) {
				filelog("itemLoadError.txt", "[%s] %s", getItemClassName().c_str(), t.toString().c_str());
			}
		}

		SAFE_DELETE(pStmt);
	}
	END_DB(pStmt)
	
	__END_CATCH
}

void VampirePortalItemLoader::load(Zone* pZone) 
	throw(Error)
{
	__BEGIN_TRY

	Assert(pZone != NULL);

	Statement* pStmt   = NULL;
	Result*    pResult = NULL;

	BEGIN_DB 
	{
		StringStream sql;
		sql << "SELECT ItemID, ObjectID, ItemType, Storage, StorageID, X, Y, Charge FROM VampirePortalItemObject"
			<< " WHERE Storage = " <<(int)STORAGE_ZONE << " AND StorageID = " << pZone->getZoneID();

		pStmt   = g_pDatabaseManager->getConnection("DARKEDEN")->createStatement();
		pResult = pStmt->executeQuery(sql.toString());

		while (pResult->next())
		{
			uint i = 0;

			ItemID_t     itemID    = pResult->getDWORD(++i);
			ObjectID_t   objectID  = pResult->getDWORD(++i);
			ItemType_t   itemType  = pResult->getDWORD(++i);
			Storage      storage   = (Storage)pResult->getInt(++i);
			StorageID_t  storageID = pResult->getDWORD(++i);
			BYTE         x         = pResult->getBYTE(++i);
			BYTE         y         = pResult->getBYTE(++i);
			int          charge    = pResult->getInt(++i);
			ZoneID_t     TargetZID = pResult->getWORD(++i);
			ZoneCoord_t  TargetX   = pResult->getWORD(++i);
			ZoneCoord_t  TargetY   = pResult->getWORD(++i);

			VampirePortalItem* pVampirePortalItem = new VampirePortalItem();
			pVampirePortalItem->setItemID(itemID);
			pVampirePortalItem->setObjectID(objectID);
			pVampirePortalItem->setItemType(itemType);
			pVampirePortalItem->setCharge(charge);
			pVampirePortalItem->setZoneID(TargetZID);
			pVampirePortalItem->setX(TargetX);
			pVampirePortalItem->setY(TargetY);

			if (storage == STORAGE_ZONE)
			{
				Tile & pTile = pZone->getTile(x,y);
				Assert(!pTile.hasItem());
				pTile.addItem(pVampirePortalItem);
			}
			else
			{
				throw Error("Storage must be STORAGE_ZONE");
			}
		}

		SAFE_DELETE(pStmt);
	}
	END_DB(pStmt)

	__END_CATCH
}

void VampirePortalItemLoader::load(StorageID_t storageID, Inventory* pInventory) 
	throw(Error)
{
	__BEGIN_TRY
	__END_CATCH
}