diff options
Diffstat (limited to 'src/server/game/Groups/GroupMgr.cpp')
| -rw-r--r-- | src/server/game/Groups/GroupMgr.cpp | 180 |
1 files changed, 180 insertions, 0 deletions
diff --git a/src/server/game/Groups/GroupMgr.cpp b/src/server/game/Groups/GroupMgr.cpp new file mode 100644 index 0000000000..9de0626147 --- /dev/null +++ b/src/server/game/Groups/GroupMgr.cpp @@ -0,0 +1,180 @@ +/* + * Copyright (C) + * + * 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; either version 2 of the License, or (at your + * option) any later version. + * + * This program is distributed in the hope that it will be useful, but WITHOUT + * ANY WARRANTY; 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, see <http://www.gnu.org/licenses/>. + */ + +#include "Common.h" +#include "GroupMgr.h" +#include "InstanceSaveMgr.h" +#include "World.h" +#include "DBCStores.h" + +GroupMgr::GroupMgr() +{ + _nextGroupId = 0; +} + +GroupMgr::~GroupMgr() +{ + for (GroupContainer::iterator itr = GroupStore.begin(); itr != GroupStore.end(); ++itr) + delete itr->second; +} + +void GroupMgr::InitGroupIds() +{ + _nextGroupId = 1; + + QueryResult result = CharacterDatabase.Query("SELECT MAX(guid) FROM groups"); + if (result) + { + uint32 maxId = (*result)[0].GetUInt32(); + _groupIds.resize(maxId+1); + } +} + +void GroupMgr::RegisterGroupId(uint32 groupId) +{ + // Allocation was done in InitGroupIds() + _groupIds[groupId] = true; + + // Groups are pulled in ascending order from db and _nextGroupId is initialized with 1, + // so if the instance id is used, increment + if (_nextGroupId == groupId) + ++_nextGroupId; +} + +uint32 GroupMgr::GenerateGroupId() +{ + uint32 newGroupId = _nextGroupId; + + // find the lowest available id starting from the current _nextGroupId + while (_nextGroupId < 0xFFFFFFFF && ++_nextGroupId < _groupIds.size() && _groupIds[_nextGroupId]); + + if (_nextGroupId == 0xFFFFFFFF) + { + sLog->outError("Group ID overflow!! Can't continue, shutting down server."); + World::StopNow(ERROR_EXIT_CODE); + } + + return newGroupId; +} + +Group* GroupMgr::GetGroupByGUID(uint32 groupId) const +{ + GroupContainer::const_iterator itr = GroupStore.find(groupId); + if (itr != GroupStore.end()) + return itr->second; + + return NULL; +} + +void GroupMgr::AddGroup(Group* group) +{ + GroupStore[group->GetLowGUID()] = group; +} + +void GroupMgr::RemoveGroup(Group* group) +{ + GroupStore.erase(group->GetLowGUID()); +} + +void GroupMgr::LoadGroups() +{ + { + uint32 oldMSTime = getMSTime(); + + // Delete all groups whose leader does not exist + CharacterDatabase.DirectExecute("DELETE FROM groups WHERE leaderGuid NOT IN (SELECT guid FROM characters)"); + // Delete all groups with less than 2 members (or less than 1 for lfg groups) + CharacterDatabase.DirectExecute("DELETE groups FROM groups LEFT JOIN ((SELECT guid, count(*) as cnt FROM group_member GROUP BY guid) t) ON groups.guid = t.guid WHERE t.guid IS NULL OR (t.cnt<=1 AND groups.groupType <> 12)"); + // Delete invalid lfg_data + CharacterDatabase.DirectExecute("DELETE lfg_data FROM lfg_data LEFT JOIN groups ON lfg_data.guid = groups.guid WHERE groups.guid IS NULL OR groups.groupType <> 12"); + // CharacterDatabase.DirectExecute("DELETE groups FROM groups LEFT JOIN lfg_data ON groups.guid = lfg_data.guid WHERE groups.groupType=12 AND lfg_data.guid IS NULL"); // group should be left so binds are cleared when disbanded + + InitGroupIds(); + + // 0 1 2 3 4 5 6 7 8 9 + QueryResult result = CharacterDatabase.Query("SELECT g.leaderGuid, g.lootMethod, g.looterGuid, g.lootThreshold, g.icon1, g.icon2, g.icon3, g.icon4, g.icon5, g.icon6" + // 10 11 12 13 14 15 16 17 18 + ", g.icon7, g.icon8, g.groupType, g.difficulty, g.raiddifficulty, g.masterLooterGuid, g.guid, lfg.dungeon, lfg.state FROM groups g LEFT JOIN lfg_data lfg ON lfg.guid = g.guid ORDER BY g.guid ASC"); + + if (!result) + { + sLog->outString(">> Loaded 0 group definitions. DB table `groups` is empty!"); + sLog->outString(); + } + else + { + uint32 count = 0; + do + { + Field* fields = result->Fetch(); + Group* group = new Group; + if (!group->LoadGroupFromDB(fields)) + { + delete group; + continue; + } + AddGroup(group); + + RegisterGroupId(group->GetLowGUID()); + + ++count; + } + while (result->NextRow()); + + sLog->outString(">> Loaded %u group definitions in %u ms", count, GetMSTimeDiffToNow(oldMSTime)); + sLog->outString(); + } + } + + sLog->outString("Loading Group members..."); + { + uint32 oldMSTime = getMSTime(); + + // Delete all rows from group_member with no group + CharacterDatabase.DirectExecute("DELETE FROM group_member WHERE guid NOT IN (SELECT guid FROM groups)"); + // Delete all members that does not exist + CharacterDatabase.DirectExecute("DELETE FROM group_member WHERE memberGuid NOT IN (SELECT guid FROM characters)"); + + // 0 1 2 3 4 + QueryResult result = CharacterDatabase.Query("SELECT guid, memberGuid, memberFlags, subgroup, roles FROM group_member ORDER BY guid"); + if (!result) + { + sLog->outString(">> Loaded 0 group members. DB table `group_member` is empty!"); + sLog->outString(); + } + else + { + uint32 count = 0; + do + { + Field* fields = result->Fetch(); + Group* group = GetGroupByGUID(fields[0].GetUInt32()); + + if (group) + group->LoadMemberFromDB(fields[1].GetUInt32(), fields[2].GetUInt8(), fields[3].GetUInt8(), fields[4].GetUInt8()); + //else + // sLog->outError("GroupMgr::LoadGroups: Consistency failed, can't find group (storage id: %u)", fields[0].GetUInt32()); + + ++count; + } + while (result->NextRow()); + + sLog->outString(">> Loaded %u group members in %u ms", count, GetMSTimeDiffToNow(oldMSTime)); + sLog->outString(); + } + } +} |