using Google.Protobuf; using Google.Protobuf.WellKnownTypes; using ServerCore; using ServerBase; using ServerCommon; using ServerCommon.BusinessLogDomain; using MetaAssets; namespace GameServer.PacketHandler; [PacketHandler("allgameserver", typeof(ServerMessage.Types.GS2GS_NTF_MODIFY_FLOOR_LINKED_INFOS), typeof(NtfModifyFloorLinkedInfosMQPacketHandler), typeof(RabbitMQ4Game))] internal class NtfModifyFloorLinkedInfosMQPacketHandler : PacketRecvHandler { public override async Task onProcessPacket(ISession session, IMessage recvMessage) { var result = new Result(); var err_msg = string.Empty; var server_logic = GameServerApp.getServerLogic(); ArgumentNullException.ThrowIfNull(server_logic, $"server_logic is null !!!"); var message = recvMessage as ServerMessage; ArgumentNullException.ThrowIfNull(message, $"message is null !!!"); var ntf_modify_floor_linked_infos = message.NtfModifyFloorLinkedInfos; if (ntf_modify_floor_linked_infos.ExceptServerName == server_logic.getServerName()) return result; Log.getLogger().info($"MQ - NtfModifyFloorLinkedInfos"); foreach (var modify_floor_linked_info in ntf_modify_floor_linked_infos.ModifyFloorLinkedInfos) { result = MapManager.Instance.modifyFloorLinkedInfo(modify_floor_linked_info); if (result.isFail()) { err_msg = $"Failed to modifyFloorLinkedInfo() !!! : {result.toBasicString()}"; Log.getLogger().error(err_msg); continue; } } var modify_floor_linked_infos = ntf_modify_floor_linked_infos.ModifyFloorLinkedInfos.ToList(); MapNotifyHelper.broadcast_S2C_NTF_MODIFY_FLOOR_LINKED_INFOS(modify_floor_linked_infos); return await Task.FromResult(result); } }