diff --git a/FFXIVClassic Map Server/Database.cs b/FFXIVClassic Map Server/Database.cs index d94443f9..9642baf3 100644 --- a/FFXIVClassic Map Server/Database.cs +++ b/FFXIVClassic Map Server/Database.cs @@ -76,7 +76,7 @@ namespace FFXIVClassic_Map_Server using (var 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))) { Dictionary gamedataItems = new Dictionary(); - + try { conn.Open(); @@ -611,7 +611,7 @@ namespace FFXIVClassic_Map_Server } } } - + public static bool IsQuestCompleted(Player player, uint questId) { bool isCompleted = false; @@ -677,7 +677,7 @@ namespace FFXIVClassic_Map_Server currentPrivateAreaType, homepoint, homepointInn - FROM characters WHERE id = @charId"; + FROM characters WHERE id = @charId"; cmd = new MySqlCommand(query, conn); cmd.Parameters.AddWithValue("@charId", player.actorId); @@ -693,7 +693,7 @@ namespace FFXIVClassic_Map_Server player.oldRotation = player.rotation = reader.GetFloat(4); player.currentMainState = reader.GetUInt16(5); player.zoneId = reader.GetUInt32(6); - player.isZoning = true; + player.isZoning = true; player.gcCurrent = reader.GetByte(7); player.gcRankLimsa = reader.GetByte(8); player.gcRankGridania = reader.GetByte(9); @@ -718,7 +718,7 @@ namespace FFXIVClassic_Map_Server if (player.destinationZone != 0) player.zoneId = player.destinationZone; - + if (player.privateArea != null && !player.privateArea.Equals("")) player.zone = Server.GetWorldManager().GetPrivateArea(player.zoneId, player.privateArea, player.privateAreaType); else @@ -888,8 +888,8 @@ namespace FFXIVClassic_Map_Server int count = 0; while (reader.Read()) { - player.charaWork.status[count] = reader.GetUInt16(0); - player.charaWork.statusShownTime[count] = reader.GetUInt32(1); + player.charaWork.status[count] = reader.GetUInt16("statusId"); + player.charaWork.statusShownTime[count] = reader.GetUInt32("expireTime"); } } @@ -1690,7 +1690,7 @@ namespace FFXIVClassic_Map_Server } finally { - conn.Dispose(); + conn.Dispose(); } } @@ -1905,7 +1905,7 @@ namespace FFXIVClassic_Map_Server SET chocoboAppearance=@chocoboAppearance WHERE - characterId = @characterId"; + characterId = @characterId"; cmd = new MySqlCommand(query, conn); cmd.Parameters.AddWithValue("@characterId", player.actorId); @@ -1924,6 +1924,53 @@ namespace FFXIVClassic_Map_Server } } - } + public static Tuple GetRetainer(Player player, int retainerIndex) + { + Tuple data = null; + + 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 server_retainers.id as retainerId, server_retainers.name as name, actorClassId FROM characters_retainers + INNER JOIN server_retainers ON characters_retainers.retainerId = server_retainers.id + WHERE characterId = @charaId + ORDER BY id + LIMIT 1 OFFSET @retainerIndex + "; + + MySqlCommand cmd = new MySqlCommand(query, conn); + cmd.Parameters.AddWithValue("@charaId", player.actorId); + cmd.Parameters.AddWithValue("@retainerIndex", retainerIndex-1); + + using (MySqlDataReader reader = cmd.ExecuteReader()) + { + while (reader.Read()) + { + uint retainerId = reader.GetUInt32("retainerId"); + string name = reader.GetString("name"); + uint actorClassId = reader.GetUInt32("actorClassId"); + data = new Tuple(retainerId, actorClassId, name); + } + } + + } + catch (MySqlException e) + { + Program.Log.Error(e.ToString()); + } + finally + { + conn.Dispose(); + } + + return data; + } + } + + } } diff --git a/FFXIVClassic Map Server/FFXIVClassic Map Server.csproj b/FFXIVClassic Map Server/FFXIVClassic Map Server.csproj index 757f98dc..3c275fc0 100644 --- a/FFXIVClassic Map Server/FFXIVClassic Map Server.csproj +++ b/FFXIVClassic Map Server/FFXIVClassic Map Server.csproj @@ -82,6 +82,7 @@ + @@ -92,6 +93,7 @@ + @@ -260,6 +262,10 @@ + + + + diff --git a/FFXIVClassic Map Server/actors/Actor.cs b/FFXIVClassic Map Server/actors/Actor.cs index ca5ab6d4..7c66e813 100644 --- a/FFXIVClassic Map Server/actors/Actor.cs +++ b/FFXIVClassic Map Server/actors/Actor.cs @@ -83,7 +83,7 @@ namespace FFXIVClassic_Map_Server.Actors public SubPacket CreateNamePacket() { - return SetActorNamePacket.BuildPacket(actorId, displayNameId, displayNameId == 0xFFFFFFFF | displayNameId == 0x0 ? customDisplayName : ""); + return SetActorNamePacket.BuildPacket(actorId, customDisplayName != null ? 0 : displayNameId, displayNameId == 0xFFFFFFFF | displayNameId == 0x0 | customDisplayName != null ? customDisplayName : ""); } public SubPacket CreateSpeedPacket() diff --git a/FFXIVClassic Map Server/actors/chara/npc/Retainer.cs b/FFXIVClassic Map Server/actors/chara/npc/Retainer.cs new file mode 100644 index 00000000..ea545e9c --- /dev/null +++ b/FFXIVClassic Map Server/actors/chara/npc/Retainer.cs @@ -0,0 +1,31 @@ +using FFXIVClassic_Map_Server.actors.chara.player; +using FFXIVClassic_Map_Server.Actors; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace FFXIVClassic_Map_Server.actors.chara.npc +{ + class Retainer : Npc + { + public Retainer(uint id, string retainerName, ActorClass actorClass, Player player, float posX, float posY, float posZ, float rot) + : base(0, actorClass, String.Format("_rtnre{0:x7}", id), player.GetZone(), posX, posY, posZ, rot, 0, 0, retainerName) + { + this.actorId = 0xD0000000 | id; + } + + public void SendBazaarItems(Player player) + { + Inventory bazaar = new Inventory(this, 4, Inventory.RETAINER_BAZAAR); + bazaar.SendFullInventory(player); + } + + public void SendStorageItems(Player player) + { + Inventory storage = new Inventory(this, 4, 1); + storage.SendFullInventory(player); + } + } +} diff --git a/FFXIVClassic Map Server/actors/chara/player/Inventory.cs b/FFXIVClassic Map Server/actors/chara/player/Inventory.cs index 970787ec..bcd82d56 100644 --- a/FFXIVClassic Map Server/actors/chara/player/Inventory.cs +++ b/FFXIVClassic Map Server/actors/chara/player/Inventory.cs @@ -11,10 +11,12 @@ namespace FFXIVClassic_Map_Server.actors.chara.player { class Inventory { - public const ushort NORMAL = 0x0000; //Max 0xC8 + public const ushort NORMAL = 0x0000; //Max 0xC8 + public const ushort TRADE = 0x0001; //Max 0x96 public const ushort LOOT = 0x0004; //Max 0xA - public const ushort MELDREQUEST = 0x0005; //Max 0x04 - public const ushort BAZAAR = 0x0007; //Max 0x0A + public const ushort MELDREQUEST = 0x0005; //Max 0x04 + public const ushort BAZAAR = 0x0007; //Max 0x0A + public const ushort RETAINER_BAZAAR = 0x0008; //???? public const ushort CURRENCY = 0x0063; //Max 0x140 public const ushort KEYITEMS = 0x0064; //Max 0x500 public const ushort EQUIPMENT = 0x00FE; //Max 0x23 diff --git a/FFXIVClassic Map Server/actors/chara/player/Player.cs b/FFXIVClassic Map Server/actors/chara/player/Player.cs index 241b74dc..1e0ab866 100644 --- a/FFXIVClassic Map Server/actors/chara/player/Player.cs +++ b/FFXIVClassic Map Server/actors/chara/player/Player.cs @@ -20,6 +20,7 @@ using FFXIVClassic_Map_Server.packets.send.actor.inventory; using FFXIVClassic_Map_Server.actors.group; using FFXIVClassic_Map_Server.packets.send.group; using FFXIVClassic_Map_Server.packets.WorldPackets.Send.Group; +using FFXIVClassic_Map_Server.actors.chara.npc; namespace FFXIVClassic_Map_Server.Actors { @@ -134,6 +135,10 @@ namespace FFXIVClassic_Map_Server.Actors public uint homepoint = 0; public byte homepointInn = 0; + //Instancing + public Retainer currentSpawnedRetainer = null; + public bool sentRetainerSpawn = false; + private List ownedDirectors = new List(); private Director loginInitDirector = null; @@ -1558,6 +1563,12 @@ namespace FFXIVClassic_Map_Server.Actors QueuePacket(InventoryEndChangePacket.BuildPacket(toBeExamined.actorId)); } + public void SendMyTradeToPlayer(Player player) + { + Inventory tradeInventory = new Inventory(this, 4, Inventory.TRADE); + tradeInventory.SendFullInventory(player); + } + public void SendDataPacket(params object[] parameters) { List lParams = LuaUtils.CreateLuaParamList(parameters); @@ -1730,5 +1741,40 @@ namespace FFXIVClassic_Map_Server.Actors Database.ChangePlayerChocoboAppearance(this, appearanceId); chocoboAppearance = appearanceId; } + + public bool SpawnMyRetainer(Npc bell, int retainerIndex) + { + Tuple retainerData = Database.GetRetainer(this, retainerIndex); + + ActorClass actorClass = Server.GetWorldManager().GetActorClass(retainerData.Item2); + + if (actorClass == null) + return false; + + float distance = (float)Math.Sqrt(((positionX - bell.positionX) * (positionX - bell.positionX)) + ((positionZ - bell.positionZ) * (positionZ - bell.positionZ))); + float posX = bell.positionX - ((-1.0f * (bell.positionX - positionX)) / distance); + float posZ = bell.positionZ - ((-1.0f * (bell.positionZ - positionZ)) / distance); + + Retainer retainer = new Retainer(retainerData.Item1, retainerData.Item3, actorClass, this, posX, bell.positionY, positionZ, (float)Math.Atan2(positionX - posX, positionZ - posZ)); + + retainer.LoadEventConditions(actorClass.eventConditions); + + //RetainerMeetingRelationGroup group = new RetainerMeetingRelationGroup(5555, this, retainer); + //group.SendGroupPackets(playerSession); + + currentSpawnedRetainer = retainer; + sentRetainerSpawn = false; + + return true; + } + + public void DespawnMyRetainer() + { + if (currentSpawnedRetainer != null) + { + currentSpawnedRetainer = null; + } + } + } } diff --git a/FFXIVClassic Map Server/actors/group/ContentGroup.cs b/FFXIVClassic Map Server/actors/group/ContentGroup.cs index f5353198..fcb3e32b 100644 --- a/FFXIVClassic Map Server/actors/group/ContentGroup.cs +++ b/FFXIVClassic Map Server/actors/group/ContentGroup.cs @@ -91,7 +91,7 @@ namespace FFXIVClassic_Map_Server.actors.group groupWork.addByte(Utils.MurmurHash2("contentGroupWork.property[0]", 0), 1); groupWork.setTarget("/_init"); - SubPacket test = groupWork.buildPacket(session.id, session.id); + SubPacket test = groupWork.buildPacket(session.id); test.DebugPrintSubPacket(); session.QueuePacket(test); } diff --git a/FFXIVClassic Map Server/actors/group/MonsterParty.cs b/FFXIVClassic Map Server/actors/group/MonsterParty.cs index b560fd38..53f2a263 100644 --- a/FFXIVClassic Map Server/actors/group/MonsterParty.cs +++ b/FFXIVClassic Map Server/actors/group/MonsterParty.cs @@ -50,7 +50,7 @@ namespace FFXIVClassic_Map_Server.actors.group SynchGroupWorkValuesPacket groupWork = new SynchGroupWorkValuesPacket(groupIndex); groupWork.setTarget("/_init"); - SubPacket test = groupWork.buildPacket(session.id, session.id); + SubPacket test = groupWork.buildPacket(session.id); session.QueuePacket(test); } diff --git a/FFXIVClassic Map Server/actors/group/Relation.cs b/FFXIVClassic Map Server/actors/group/Relation.cs index 807ef86b..600c8b9c 100644 --- a/FFXIVClassic Map Server/actors/group/Relation.cs +++ b/FFXIVClassic Map Server/actors/group/Relation.cs @@ -68,7 +68,7 @@ namespace FFXIVClassic_Map_Server.actors.group groupWork.addProperty(this, "work._globalTemp.variableCommand"); groupWork.setTarget("/_init"); - SubPacket test = groupWork.buildPacket(session.id, session.id); + SubPacket test = groupWork.buildPacket(session.id); test.DebugPrintSubPacket(); session.QueuePacket(test); } diff --git a/FFXIVClassic Map Server/actors/group/RetainerMeetingRelationGroup.cs b/FFXIVClassic Map Server/actors/group/RetainerMeetingRelationGroup.cs new file mode 100644 index 00000000..bbab8b32 --- /dev/null +++ b/FFXIVClassic Map Server/actors/group/RetainerMeetingRelationGroup.cs @@ -0,0 +1,58 @@ +using FFXIVClassic.Common; +using FFXIVClassic_Map_Server.actors.chara.npc; +using FFXIVClassic_Map_Server.Actors; +using FFXIVClassic_Map_Server.dataobjects; +using FFXIVClassic_Map_Server.packets.send.group; +using FFXIVClassic_Map_Server.packets.send.groups; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace FFXIVClassic_Map_Server.actors.group +{ + class RetainerMeetingRelationGroup : Group + { + Player player; + Retainer retainer; + + public RetainerMeetingRelationGroup(ulong groupIndex, Player player, Retainer retainer) + : base(groupIndex) + { + this.player = player; + this.retainer = retainer; + } + + public override int GetMemberCount() + { + return 2; + } + + public override List BuildMemberList(uint id) + { + List groupMembers = new List(); + + groupMembers.Add(new GroupMember(player.actorId, -1, 0x83, false, true, player.customDisplayName)); + groupMembers.Add(new GroupMember(retainer.actorId, -1, 0x83, false, true, retainer.customDisplayName)); + + return groupMembers; + } + + public override uint GetTypeId() + { + return 50003; + } + + public override void SendInitWorkValues(Session session) + { + SynchGroupWorkValuesPacket groupWork = new SynchGroupWorkValuesPacket(groupIndex); + groupWork.setTarget("/_init"); + + SubPacket test = groupWork.buildPacket(session.id); + test.DebugPrintSubPacket(); + session.QueuePacket(test); + } + + } +} diff --git a/FFXIVClassic Map Server/dataobjects/Session.cs b/FFXIVClassic Map Server/dataobjects/Session.cs index f617ee29..bd6a1639 100644 --- a/FFXIVClassic Map Server/dataobjects/Session.cs +++ b/FFXIVClassic Map Server/dataobjects/Session.cs @@ -9,6 +9,7 @@ using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; +using FFXIVClassic_Map_Server.actors.chara.npc; namespace FFXIVClassic_Map_Server.dataobjects { @@ -96,13 +97,30 @@ namespace FFXIVClassic_Map_Server.dataobjects //Remove missing actors for (int i = 0; i < actorInstanceList.Count; i++) { - if (!list.Contains(actorInstanceList[i])) + //Retainer Instance + if (actorInstanceList[i] is Retainer && playerActor.currentSpawnedRetainer == null) + { + QueuePacket(RemoveActorPacket.BuildPacket(actorInstanceList[i].actorId)); + actorInstanceList.RemoveAt(i); + } + else if (!list.Contains(actorInstanceList[i]) && !(actorInstanceList[i] is Retainer)) { QueuePacket(RemoveActorPacket.BuildPacket(actorInstanceList[i].actorId)); actorInstanceList.RemoveAt(i); } } + //Retainer Instance + if (playerActor.currentSpawnedRetainer != null && !playerActor.sentRetainerSpawn) + { + Actor actor = playerActor.currentSpawnedRetainer; + QueuePacket(actor.GetSpawnPackets(playerActor, 1)); + QueuePacket(actor.GetInitPackets()); + QueuePacket(actor.GetSetEventStatusPackets()); + actorInstanceList.Add(actor); + playerActor.sentRetainerSpawn = true; + } + //Add new actors or move for (int i = 0; i < list.Count; i++) { diff --git a/FFXIVClassic Map Server/packets/send/groups/SynchGroupWorkValuesPacket.cs b/FFXIVClassic Map Server/packets/send/groups/SynchGroupWorkValuesPacket.cs index 19104a4b..f33202ef 100644 --- a/FFXIVClassic Map Server/packets/send/groups/SynchGroupWorkValuesPacket.cs +++ b/FFXIVClassic Map Server/packets/send/groups/SynchGroupWorkValuesPacket.cs @@ -194,7 +194,7 @@ namespace FFXIVClassic_Map_Server.packets.send.groups } - public SubPacket buildPacket(uint playerActorID, uint actorID) + public SubPacket buildPacket(uint actorID) { binWriter.Seek(0x8, SeekOrigin.Begin); binWriter.Write((byte)runningByteTotal); diff --git a/FFXIVClassic World Server/DataObjects/Group/Group.cs b/FFXIVClassic World Server/DataObjects/Group/Group.cs index a60de10a..c771d1a8 100644 --- a/FFXIVClassic World Server/DataObjects/Group/Group.cs +++ b/FFXIVClassic World Server/DataObjects/Group/Group.cs @@ -12,6 +12,7 @@ namespace FFXIVClassic_World_Server.DataObjects.Group public const uint GroupInvitationRelationGroup = 50001; public const uint TradeRelationGroup = 50002; + public const uint RetainerMeetingRelationGroup = 50003; public const uint BazaarBuyItemRelationGroup = 50009; public const uint RetainerGroup = 80001; diff --git a/FFXIVClassic World Server/DataObjects/Group/RetainerMeetingRelationGroup.cs b/FFXIVClassic World Server/DataObjects/Group/RetainerMeetingRelationGroup.cs new file mode 100644 index 00000000..d54afb16 --- /dev/null +++ b/FFXIVClassic World Server/DataObjects/Group/RetainerMeetingRelationGroup.cs @@ -0,0 +1,36 @@ +using FFXIVClassic.Common; +using FFXIVClassic_World_Server.Actor.Group.Work; +using FFXIVClassic_World_Server.Packets.Send.Subpackets.Groups; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace FFXIVClassic_World_Server.DataObjects.Group +{ + class RetainerMeetingRelationGroup : Relation + { + public RetainerMeetingRelationGroup(ulong groupIndex, uint host, uint other, uint command, ulong topicGroup) + : base(groupIndex, host, other, command, topicGroup) + { + + } + + public override uint GetTypeId() + { + return Group.RetainerMeetingRelationGroup; + } + + public override void SendInitWorkValues(Session session) + { + SynchGroupWorkValuesPacket groupWork = new SynchGroupWorkValuesPacket(groupIndex); + groupWork.setTarget("/_init"); + + SubPacket test = groupWork.buildPacket(session.sessionId); + test.DebugPrintSubPacket(); + session.clientConnection.QueuePacket(test); + } + + } +} diff --git a/FFXIVClassic World Server/Database.cs b/FFXIVClassic World Server/Database.cs index 0a63ac4e..36c7df4b 100644 --- a/FFXIVClassic World Server/Database.cs +++ b/FFXIVClassic World Server/Database.cs @@ -165,7 +165,7 @@ namespace FFXIVClassic_World_Server try { conn.Open(); - MySqlCommand cmd = new MySqlCommand("SELECT id, name, classActorId, cdIDOffset, placeName, conditions, level FROM server_retainers INNER JOIN characters_retainers ON retainerId = server_retainers.id WHERE characterId = @charaId", conn); + MySqlCommand cmd = new MySqlCommand("SELECT id, name, actorClassId, cdIDOffset, placeName, conditions, level FROM server_retainers INNER JOIN characters_retainers ON retainerId = server_retainers.id WHERE characterId = @charaId", conn); cmd.Parameters.AddWithValue("@charaId", charaId); using (MySqlDataReader Reader = cmd.ExecuteReader()) { @@ -173,13 +173,13 @@ namespace FFXIVClassic_World_Server { uint id = Reader.GetUInt32("id") | 0xE0000000; string name = Reader.GetString("name"); - uint classActorId = Reader.GetUInt32("classActorId"); + uint actorClassId = Reader.GetUInt32("actorClassId"); byte cdIDOffset = Reader.GetByte("cdIDOffset"); ushort placeName = Reader.GetUInt16("placeName"); byte conditions = Reader.GetByte("conditions"); byte level = Reader.GetByte("level"); - members.Add(new RetainerGroupMember(id, name, classActorId, cdIDOffset, placeName, conditions, level)); + members.Add(new RetainerGroupMember(id, name, actorClassId, cdIDOffset, placeName, conditions, level)); } } } diff --git a/FFXIVClassic World Server/FFXIVClassic World Server.csproj b/FFXIVClassic World Server/FFXIVClassic World Server.csproj index 2bf7f335..61cbdd46 100644 --- a/FFXIVClassic World Server/FFXIVClassic World Server.csproj +++ b/FFXIVClassic World Server/FFXIVClassic World Server.csproj @@ -95,6 +95,7 @@ + @@ -190,7 +191,8 @@ - + +