mirror of
https://bitbucket.org/Ioncannon/project-meteor-server.git
synced 2025-04-02 19:42:05 -04:00
337 lines
13 KiB
C#
337 lines
13 KiB
C#
using FFXIVClassic.Common;
|
|
using FFXIVClassic_World_Server.DataObjects;
|
|
using FFXIVClassic_World_Server.DataObjects.Group;
|
|
using FFXIVClassic_World_Server.Packets.Send.Subpackets;
|
|
using FFXIVClassic_World_Server.Packets.Send.Subpackets.Groups;
|
|
using FFXIVClassic_World_Server.Packets.WorldPackets.Send;
|
|
using FFXIVClassic_World_Server.Packets.WorldPackets.Send.Group;
|
|
using MySql.Data.MySqlClient;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Net;
|
|
using System.Net.Sockets;
|
|
using System.Text;
|
|
using System.Threading.Tasks;
|
|
|
|
namespace FFXIVClassic_World_Server
|
|
{
|
|
class WorldManager
|
|
{
|
|
private Server mServer;
|
|
public Dictionary<string, ZoneServer> mZoneServerList;
|
|
private Dictionary<uint, ZoneEntrance> zoneEntranceList;
|
|
|
|
//World Scope Group Management
|
|
private Object mGroupLock = new object();
|
|
private ulong mRunningGroupIndex = 1;
|
|
private Dictionary<ulong, Group> mCurrentWorldGroups = new Dictionary<ulong, Group>();
|
|
|
|
private PartyManager mPartyManager;
|
|
private RetainerGroupManager mRetainerGroupManager;
|
|
private LinkshellManager mLinkshellManager;
|
|
private RelationGroupManager mRelationGroupManager;
|
|
|
|
public WorldManager(Server server)
|
|
{
|
|
mServer = server;
|
|
mPartyManager = new PartyManager(this, mGroupLock, mCurrentWorldGroups);
|
|
mLinkshellManager = new LinkshellManager(this, mGroupLock, mCurrentWorldGroups);
|
|
mRetainerGroupManager = new RetainerGroupManager(this, mGroupLock, mCurrentWorldGroups);
|
|
mRelationGroupManager = new RelationGroupManager(this, mGroupLock, mCurrentWorldGroups);
|
|
}
|
|
|
|
public void LoadZoneServerList()
|
|
{
|
|
mZoneServerList = new Dictionary<string, ZoneServer>();
|
|
|
|
using (MySqlConnection conn = new MySqlConnection(String.Format("Server={0}; Port={1}; Database={2}; UID={3}; Password={4}", ConfigConstants.DATABASE_HOST, ConfigConstants.DATABASE_PORT, ConfigConstants.DATABASE_NAME, ConfigConstants.DATABASE_USERNAME, ConfigConstants.DATABASE_PASSWORD)))
|
|
{
|
|
try
|
|
{
|
|
conn.Open();
|
|
|
|
string query = @"
|
|
SELECT
|
|
id,
|
|
serverIp,
|
|
serverPort
|
|
FROM server_zones
|
|
WHERE serverIp IS NOT NULL";
|
|
|
|
MySqlCommand cmd = new MySqlCommand(query, conn);
|
|
|
|
using (MySqlDataReader reader = cmd.ExecuteReader())
|
|
{
|
|
while (reader.Read())
|
|
{
|
|
uint id = reader.GetUInt32(0);
|
|
string ip = reader.GetString(1);
|
|
int port = reader.GetInt32(2);
|
|
string address = ip + ":" + port;
|
|
|
|
if (!mZoneServerList.ContainsKey(address))
|
|
{
|
|
ZoneServer zone = new ZoneServer(ip, port, id);
|
|
mZoneServerList.Add(address, zone);
|
|
}
|
|
else
|
|
mZoneServerList[address].AddLoadedZone(id);
|
|
}
|
|
}
|
|
}
|
|
catch (MySqlException e)
|
|
{ Console.WriteLine(e); }
|
|
finally
|
|
{
|
|
conn.Dispose();
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
public void LoadZoneEntranceList()
|
|
{
|
|
zoneEntranceList = new Dictionary<uint, ZoneEntrance>();
|
|
int count = 0;
|
|
using (MySqlConnection conn = new MySqlConnection(String.Format("Server={0}; Port={1}; Database={2}; UID={3}; Password={4}", ConfigConstants.DATABASE_HOST, ConfigConstants.DATABASE_PORT, ConfigConstants.DATABASE_NAME, ConfigConstants.DATABASE_USERNAME, ConfigConstants.DATABASE_PASSWORD)))
|
|
{
|
|
try
|
|
{
|
|
conn.Open();
|
|
|
|
string query = @"
|
|
SELECT
|
|
id,
|
|
zoneId,
|
|
spawnType,
|
|
spawnX,
|
|
spawnY,
|
|
spawnZ,
|
|
spawnRotation,
|
|
privateAreaName
|
|
FROM server_zones_spawnlocations";
|
|
|
|
MySqlCommand cmd = new MySqlCommand(query, conn);
|
|
|
|
using (MySqlDataReader reader = cmd.ExecuteReader())
|
|
{
|
|
while (reader.Read())
|
|
{
|
|
uint id = reader.GetUInt32(0);
|
|
string privArea = null;
|
|
|
|
if (!reader.IsDBNull(7))
|
|
privArea = reader.GetString(7);
|
|
|
|
ZoneEntrance entance = new ZoneEntrance(reader.GetUInt32(1), privArea, reader.GetByte(2), reader.GetFloat(3), reader.GetFloat(4), reader.GetFloat(5), reader.GetFloat(6));
|
|
zoneEntranceList[id] = entance;
|
|
count++;
|
|
}
|
|
}
|
|
}
|
|
catch (MySqlException e)
|
|
{ Console.WriteLine(e); }
|
|
finally
|
|
{
|
|
conn.Dispose();
|
|
}
|
|
}
|
|
|
|
Program.Log.Info(String.Format("Loaded {0} zone spawn locations.", count));
|
|
}
|
|
|
|
public void ConnectToZoneServers()
|
|
{
|
|
Program.Log.Info("--------------------------");
|
|
Program.Log.Info("Connecting to zone servers");
|
|
Program.Log.Info("--------------------------");
|
|
|
|
foreach (ZoneServer zs in mZoneServerList.Values)
|
|
{
|
|
zs.Connect();
|
|
}
|
|
}
|
|
|
|
public ZoneServer GetZoneServer(uint zoneId)
|
|
{
|
|
foreach (ZoneServer zs in mZoneServerList.Values)
|
|
{
|
|
if (zs.ownedZoneIds.Contains(zoneId))
|
|
return zs;
|
|
}
|
|
|
|
return null;
|
|
}
|
|
|
|
//Moves the actor to the new zone if exists. No packets are sent nor position changed.
|
|
public void DoSeamlessZoneServerChange(Session session, uint destinationZoneId)
|
|
{
|
|
|
|
}
|
|
|
|
//Moves actor to new zone, and sends packets to spawn at the given zone entrance
|
|
public void DoZoneServerChange(Session session, uint zoneEntrance)
|
|
{
|
|
if (!zoneEntranceList.ContainsKey(zoneEntrance))
|
|
{
|
|
Program.Log.Error("Given zone entrance was not found: " + zoneEntrance);
|
|
return;
|
|
}
|
|
|
|
ZoneEntrance ze = zoneEntranceList[zoneEntrance];
|
|
DoZoneServerChange(session, ze.zoneId, ze.privateAreaName, ze.spawnType, ze.spawnX, ze.spawnY, ze.spawnZ, ze.spawnRotation);
|
|
}
|
|
|
|
//Moves actor to new zone, and sends packets to spawn at the given coords.
|
|
public void DoZoneServerChange(Session session, uint destinationZoneId, string destinationPrivateArea, byte spawnType, float spawnX, float spawnY, float spawnZ, float spawnRotation)
|
|
{
|
|
ZoneServer zs = GetZoneServer(destinationZoneId);
|
|
|
|
if (zs == null)
|
|
return;
|
|
|
|
session.currentZoneId = destinationZoneId;
|
|
|
|
//Intrazone change, just update the id
|
|
if (zs.Equals(session.routing1))
|
|
return;
|
|
|
|
if (zs.isConnected)
|
|
session.routing1.SendSessionEnd(session, destinationZoneId, destinationPrivateArea, spawnType, spawnX, spawnY, spawnZ, spawnRotation);
|
|
else if (zs.Connect())
|
|
session.routing1.SendSessionEnd(session, destinationZoneId, destinationPrivateArea, spawnType, spawnX, spawnY, spawnZ, spawnRotation);
|
|
else
|
|
session.routing1.SendPacket(ErrorPacket.BuildPacket(session, 1));
|
|
}
|
|
|
|
//Login Zone In
|
|
public void DoLogin(Session session)
|
|
{
|
|
SendMotD(session);
|
|
|
|
//Send party, retainer, ls groups
|
|
Party pt = mPartyManager.GetParty(session.sessionId);
|
|
|
|
|
|
if (session.sessionId == 156)
|
|
{
|
|
mPartyManager.AddToParty(pt.groupIndex, 0x6c);
|
|
mPartyManager.AddToParty(pt.groupIndex, 157);
|
|
}
|
|
|
|
pt.SendGroupPackets(session);
|
|
SendPartySync(pt);
|
|
mRetainerGroupManager.GetRetainerGroup(session.sessionId).SendGroupPackets(session);
|
|
List<Linkshell> linkshells = mLinkshellManager.GetPlayerLinkshellMembership(session.sessionId);
|
|
foreach (Linkshell ls in linkshells)
|
|
ls.SendGroupPackets(session);
|
|
|
|
mRelationGroupManager.CreateRelationGroup(157, session.sessionId, 10001).SendGroupPackets(session);
|
|
}
|
|
|
|
private void SendMotD(Session session)
|
|
{
|
|
session.clientConnection.QueuePacket(SendMessagePacket.BuildPacket(session.sessionId, session.sessionId, SendMessagePacket.MESSAGE_TYPE_GENERAL_INFO, "", "-------- Login Message --------"), true, false);
|
|
session.clientConnection.QueuePacket(SendMessagePacket.BuildPacket(session.sessionId, session.sessionId, SendMessagePacket.MESSAGE_TYPE_GENERAL_INFO, "", String.Format("Welcome to {0}!", ConfigConstants.PREF_SERVERNAME)), true, false);
|
|
session.clientConnection.QueuePacket(SendMessagePacket.BuildPacket(session.sessionId, session.sessionId, SendMessagePacket.MESSAGE_TYPE_GENERAL_INFO, "", "Welcome to Eorzea!"), true, false);
|
|
session.clientConnection.QueuePacket(SendMessagePacket.BuildPacket(session.sessionId, session.sessionId, SendMessagePacket.MESSAGE_TYPE_GENERAL_INFO, "", "Here is a test Message of the Day from the World Server!"), true, false);
|
|
}
|
|
|
|
public void SendPartySync(Party party)
|
|
{
|
|
List<ZoneServer> alreadySent = new List<ZoneServer>();
|
|
foreach (uint member in party.members)
|
|
{
|
|
Session session = Server.GetServer().GetSession(member);
|
|
if (session == null)
|
|
continue;
|
|
|
|
if (alreadySent.Contains(session.routing1))
|
|
continue;
|
|
|
|
alreadySent.Add(session.routing1);
|
|
SubPacket syncPacket = PartySyncPacket.BuildPacket(session, party);
|
|
session.routing1.SendPacket(syncPacket);
|
|
}
|
|
}
|
|
|
|
public class ZoneEntrance
|
|
{
|
|
public uint zoneId;
|
|
public string privateAreaName;
|
|
public byte spawnType;
|
|
public float spawnX;
|
|
public float spawnY;
|
|
public float spawnZ;
|
|
public float spawnRotation;
|
|
|
|
public ZoneEntrance(uint zoneId, string privateAreaName, byte spawnType, float x, float y, float z, float rot)
|
|
{
|
|
this.zoneId = zoneId;
|
|
this.privateAreaName = privateAreaName;
|
|
this.spawnType = spawnType;
|
|
this.spawnX = x;
|
|
this.spawnY = y;
|
|
this.spawnZ = z;
|
|
this.spawnRotation = rot;
|
|
}
|
|
}
|
|
|
|
public void SendGroupData(Session session, ulong groupId)
|
|
{
|
|
if (mCurrentWorldGroups.ContainsKey(groupId))
|
|
{
|
|
Group group = mCurrentWorldGroups[groupId];
|
|
group.SendGroupPackets(session);
|
|
}
|
|
}
|
|
|
|
public void SendGroupDataToAllMembers(ulong groupId)
|
|
{
|
|
if (mCurrentWorldGroups.ContainsKey(groupId))
|
|
{
|
|
Group group = mCurrentWorldGroups[groupId];
|
|
foreach (GroupMember member in group.BuildMemberList(0))
|
|
group.SendGroupPackets(mServer.GetSession(member.actorId));
|
|
}
|
|
}
|
|
|
|
public void IncrementGroupIndex()
|
|
{
|
|
mRunningGroupIndex++;
|
|
}
|
|
|
|
public ulong GetGroupIndex()
|
|
{
|
|
return mRunningGroupIndex | 0x8000000000000000;
|
|
}
|
|
|
|
public bool SendGroupInit(Session session, ulong groupId)
|
|
{
|
|
if (mCurrentWorldGroups.ContainsKey(groupId))
|
|
{
|
|
mCurrentWorldGroups[groupId].SendInitWorkValues(session);
|
|
return true;
|
|
}
|
|
return false;
|
|
}
|
|
|
|
public PartyManager GetPartyManager()
|
|
{
|
|
return mPartyManager;
|
|
}
|
|
|
|
public RetainerGroupManager GetRetainerManager()
|
|
{
|
|
return mRetainerGroupManager;
|
|
}
|
|
|
|
public LinkshellManager GetLinkshellManager()
|
|
{
|
|
return mLinkshellManager;
|
|
}
|
|
}
|
|
|
|
}
|