eqemu-server/world/expedition_database.cpp

/**
 * EQEmulator: Everquest Server Emulator
 * Copyright (C) 2001-2020 EQEmulator Development Team (https://github.com/EQEmu/Server)
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; version 2 of the License.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY except by those people which sell it, which
 * are required to give you total support for your newly bought product;
 * without even the implied warranty of MERCHANTABILITY or FITNESS FOR
 * A PARTICULAR PURPOSE. See the GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
 *
 */

#include "expedition_database.h"
#include "expedition.h"
#include "worlddb.h"

void ExpeditionDatabase::PurgeExpiredExpeditions()
{
	std::string query = SQL(
		SELECT
			expeditions.id
		FROM expeditions
			LEFT JOIN instance_list ON expeditions.instance_id = instance_list.id
			LEFT JOIN
				(
					SELECT expedition_id, COUNT(*) member_count
					FROM expedition_members
					GROUP BY expedition_id
				) expedition_members
				ON expedition_members.expedition_id = expeditions.id
		WHERE
			instance_list.id IS NULL
			OR expedition_members.member_count IS NULL
			OR (instance_list.start_time + instance_list.duration) <= UNIX_TIMESTAMP();
	);

	auto results = database.QueryDatabase(query);
	if (results.Success())
	{
		std::vector<uint32_t> expedition_ids;
		for (auto row = results.begin(); row != results.end(); ++row)
		{
			expedition_ids.emplace_back(static_cast<uint32_t>(strtoul(row[0], nullptr, 10)));
		}
		ExpeditionDatabase::DeleteExpeditions(expedition_ids);
	}
}

void ExpeditionDatabase::PurgeExpiredCharacterLockouts()
{
	std::string query = SQL(
		DELETE FROM character_expedition_lockouts
		WHERE expire_time <= NOW();
	);

	database.QueryDatabase(query);
}

std::vector<Expedition> ExpeditionDatabase::LoadExpeditions()
{
	std::vector<Expedition> expeditions;

	std::string query = SQL(
		SELECT
			expeditions.id,
			expeditions.instance_id,
			instance_list.zone,
			instance_list.start_time,
			instance_list.duration,
			expedition_members.character_id
		FROM expeditions
			INNER JOIN instance_list ON expeditions.instance_id = instance_list.id
			INNER JOIN expedition_members ON expedition_members.expedition_id = expeditions.id
		ORDER BY expeditions.id;
	);

	auto results = database.QueryDatabase(query);
	if (results.Success())
	{
		uint32_t last_expedition_id = 0;

		for (auto row = results.begin(); row != results.end(); ++row)
		{
			uint32_t expedition_id = strtoul(row[0], nullptr, 10);

			if (last_expedition_id != expedition_id)
			{
				expeditions.emplace_back(
					static_cast<uint32_t>(strtoul(row[0], nullptr, 10)), // expedition_id
					static_cast<uint32_t>(strtoul(row[1], nullptr, 10)), // dz_instance_id
					static_cast<uint32_t>(strtoul(row[2], nullptr, 10)), // dz_zone_id
					static_cast<uint32_t>(strtoul(row[3], nullptr, 10)), // start_time
					static_cast<uint32_t>(strtoul(row[4], nullptr, 10))  // duration
				);
			}

			last_expedition_id = expedition_id;

			uint32_t member_id = static_cast<uint32_t>(strtoul(row[5], nullptr, 10));
			expeditions.back().AddMember(member_id);
		}
	}

	return expeditions;
}

Expedition ExpeditionDatabase::LoadExpedition(uint32_t expedition_id)
{
	LogExpeditions("Loading expedition [{}] for world cache", expedition_id);

	Expedition expedition;

	std::string query = fmt::format(SQL(
		SELECT
			expeditions.id,
			expeditions.instance_id,
			instance_list.zone,
			instance_list.start_time,
			instance_list.duration,
			expedition_members.character_id
		FROM expeditions
			INNER JOIN instance_list ON expeditions.instance_id = instance_list.id
			INNER JOIN expedition_members ON expedition_members.expedition_id = expeditions.id
		WHERE expeditions.id = {};
	), expedition_id);

	auto results = database.QueryDatabase(query);
	if (results.Success())
	{
		bool created = false;
		for (auto row = results.begin(); row != results.end(); ++row)
		{
			if (!created)
			{
				expedition = Expedition{
					static_cast<uint32_t>(strtoul(row[0], nullptr, 10)), // expedition_id
					static_cast<uint32_t>(strtoul(row[1], nullptr, 10)), // dz_instance_id
					static_cast<uint32_t>(strtoul(row[2], nullptr, 10)), // dz_zone_id
					static_cast<uint32_t>(strtoul(row[3], nullptr, 10)), // start_time
					static_cast<uint32_t>(strtoul(row[4], nullptr, 10))  // duration
				};
				created = true;
			}

			auto member_id = static_cast<uint32_t>(strtoul(row[5], nullptr, 10));
			expedition.AddMember(member_id);
		}
	}

	return expedition;
}

void ExpeditionDatabase::DeleteExpeditions(const std::vector<uint32_t>& expedition_ids)
{
	LogExpeditionsDetail("Deleting [{}] expedition(s)", expedition_ids.size());

	std::string expedition_ids_query;
	for (const auto& expedition_id : expedition_ids)
	{
		fmt::format_to(std::back_inserter(expedition_ids_query), "{},", expedition_id);
	}

	if (!expedition_ids_query.empty())
	{
		expedition_ids_query.pop_back(); // trailing comma

		std::string query = fmt::format(
			"DELETE FROM expeditions WHERE id IN ({});", expedition_ids_query
		);
		database.QueryDatabase(query);

		query = fmt::format(
			"DELETE FROM expedition_members WHERE expedition_id IN ({});", expedition_ids_query
		);
		database.QueryDatabase(query);

		query = fmt::format(
			"DELETE FROM expedition_lockouts WHERE expedition_id IN ({});", expedition_ids_query
		);
		database.QueryDatabase(query);
	}
}

void ExpeditionDatabase::UpdateDzDuration(uint16_t instance_id, uint32_t new_duration)
{
	std::string query = fmt::format(
		"UPDATE instance_list SET duration = {} WHERE id = {};",
		new_duration, instance_id
	);

	database.QueryDatabase(query);
}