lineage2/l2j_mobius
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

PremiumManager coding style format.

Browse Source
This commit is contained in:
MobiusDevelopment
2020-07-24 04:37:50 +00:00
parent 4029f3e91f
commit 7e3ba00372
17 changed files with 289 additions and 323 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
L2J_Mobius_1.0_Ertheia/java/org/l2jmobius/gameserver/instancemanager/PremiumManager.java
View File

@@ -51,30 +51,30 @@ public class PremiumManager
class PremiumExpireTask implements Runnable class PremiumExpireTask implements Runnable
{ {
final PlayerInstance player; final PlayerInstance _player;
PremiumExpireTask(PlayerInstance player) PremiumExpireTask(PlayerInstance player)
{ {
this.player = player; _player = player;
} }
@Override @Override
public void run() public void run()
{ {
player.setPremiumStatus(false); _player.setPremiumStatus(false);
} }
} }
// Data Cache // Data Cache
private final Map<String, Long> premiumData = new ConcurrentHashMap<>(); private final Map<String, Long> _premiumData = new ConcurrentHashMap<>();
// expireTasks // expireTasks
private final Map<String, ScheduledFuture<?>> expiretasks = new ConcurrentHashMap<>(); private final Map<String, ScheduledFuture<?>> _expiretasks = new ConcurrentHashMap<>();
// Listeners // Listeners
private final ListenersContainer listenerContainer = Containers.Players(); private final ListenersContainer _listenerContainer = Containers.Players();
private final Consumer<OnPlayerLogin> playerLoginEvent = event -> private final Consumer<OnPlayerLogin> _playerLoginEvent = event ->
{ {
final PlayerInstance player = event.getPlayer(); final PlayerInstance player = event.getPlayer();
final String accountName = player.getAccountName(); final String accountName = player.getAccountName();
@@ -92,16 +92,15 @@ public class PremiumManager
} }
}; };
private final Consumer<OnPlayerLogout> playerLogoutEvent = event -> private final Consumer<OnPlayerLogout> _playerLogoutEvent = event ->
{ {
final PlayerInstance player = event.getPlayer(); stopExpireTask(event.getPlayer());
stopExpireTask(player);
}; };
protected PremiumManager() protected PremiumManager()
{ {
listenerContainer.addListener(new ConsumerEventListener(listenerContainer, EventType.ON_PLAYER_LOGIN, playerLoginEvent, this)); _listenerContainer.addListener(new ConsumerEventListener(_listenerContainer, EventType.ON_PLAYER_LOGIN, _playerLoginEvent, this));
listenerContainer.addListener(new ConsumerEventListener(listenerContainer, EventType.ON_PLAYER_LOGOUT, playerLogoutEvent, this)); _listenerContainer.addListener(new ConsumerEventListener(_listenerContainer, EventType.ON_PLAYER_LOGOUT, _playerLogoutEvent, this));
} }
/** /**
@@ -110,8 +109,7 @@ public class PremiumManager
*/ */
private void startExpireTask(PlayerInstance player, long delay) private void startExpireTask(PlayerInstance player, long delay)
{ {
final ScheduledFuture<?> task = ThreadPool.schedule(new PremiumExpireTask(player), delay); _expiretasks.put(player.getAccountName(), ThreadPool.schedule(new PremiumExpireTask(player), delay));
expiretasks.put(player.getAccountName(), task);
} }
/** /**
@@ -119,7 +117,7 @@ public class PremiumManager
*/ */
private void stopExpireTask(PlayerInstance player) private void stopExpireTask(PlayerInstance player)
{ {
ScheduledFuture<?> task = expiretasks.remove(player.getAccountName()); ScheduledFuture<?> task = _expiretasks.remove(player.getAccountName());
if (task != null) if (task != null)
{ {
task.cancel(false); task.cancel(false);
@@ -137,7 +135,7 @@ public class PremiumManager
{ {
while (rset.next()) while (rset.next())
{ {
premiumData.put(rset.getString(1), rset.getLong(2)); _premiumData.put(rset.getString(1), rset.getLong(2));
} }
} }
} }
@@ -149,7 +147,7 @@ public class PremiumManager
public long getPremiumExpiration(String accountName) public long getPremiumExpiration(String accountName)
{ {
return premiumData.getOrDefault(accountName, 0L); return _premiumData.getOrDefault(accountName, 0L);
} }
public void addPremiumTime(String accountName, int timeValue, TimeUnit timeUnit) public void addPremiumTime(String accountName, int timeValue, TimeUnit timeUnit)
@@ -174,7 +172,7 @@ public class PremiumManager
} }
// UPDATE CACHE // UPDATE CACHE
premiumData.put(accountName, newPremiumExpiration); _premiumData.put(accountName, newPremiumExpiration);
// UPDATE PlAYER PREMIUMSTATUS // UPDATE PlAYER PREMIUMSTATUS
for (PlayerInstance player : World.getInstance().getPlayers()) for (PlayerInstance player : World.getInstance().getPlayers())
@@ -208,7 +206,7 @@ public class PremiumManager
} }
// UPDATE CACHE // UPDATE CACHE
premiumData.remove(accountName); _premiumData.remove(accountName);
// UPDATE DATABASE // UPDATE DATABASE
try (Connection con = DatabaseFactory.getConnection(); try (Connection con = DatabaseFactory.getConnection();

36
L2J_Mobius_2.5_Underground/java/org/l2jmobius/gameserver/instancemanager/PremiumManager.java
View File

@@ -51,30 +51,30 @@ public class PremiumManager
class PremiumExpireTask implements Runnable class PremiumExpireTask implements Runnable
{ {
final PlayerInstance player; final PlayerInstance _player;
PremiumExpireTask(PlayerInstance player) PremiumExpireTask(PlayerInstance player)
{ {
this.player = player; _player = player;
} }
@Override @Override
public void run() public void run()
{ {
player.setPremiumStatus(false); _player.setPremiumStatus(false);
} }
} }
// Data Cache // Data Cache
private final Map<String, Long> premiumData = new ConcurrentHashMap<>(); private final Map<String, Long> _premiumData = new ConcurrentHashMap<>();
// expireTasks // expireTasks
private final Map<String, ScheduledFuture<?>> expiretasks = new ConcurrentHashMap<>(); private final Map<String, ScheduledFuture<?>> _expiretasks = new ConcurrentHashMap<>();
// Listeners // Listeners
private final ListenersContainer listenerContainer = Containers.Players(); private final ListenersContainer _listenerContainer = Containers.Players();
private final Consumer<OnPlayerLogin> playerLoginEvent = event -> private final Consumer<OnPlayerLogin> _playerLoginEvent = event ->
{ {
final PlayerInstance player = event.getPlayer(); final PlayerInstance player = event.getPlayer();
final String accountName = player.getAccountName(); final String accountName = player.getAccountName();
@@ -92,16 +92,15 @@ public class PremiumManager
} }
}; };
private final Consumer<OnPlayerLogout> playerLogoutEvent = event -> private final Consumer<OnPlayerLogout> _playerLogoutEvent = event ->
{ {
final PlayerInstance player = event.getPlayer(); stopExpireTask(event.getPlayer());
stopExpireTask(player);
}; };
protected PremiumManager() protected PremiumManager()
{ {
listenerContainer.addListener(new ConsumerEventListener(listenerContainer, EventType.ON_PLAYER_LOGIN, playerLoginEvent, this)); _listenerContainer.addListener(new ConsumerEventListener(_listenerContainer, EventType.ON_PLAYER_LOGIN, _playerLoginEvent, this));
listenerContainer.addListener(new ConsumerEventListener(listenerContainer, EventType.ON_PLAYER_LOGOUT, playerLogoutEvent, this)); _listenerContainer.addListener(new ConsumerEventListener(_listenerContainer, EventType.ON_PLAYER_LOGOUT, _playerLogoutEvent, this));
} }
/** /**
@@ -110,8 +109,7 @@ public class PremiumManager
*/ */
private void startExpireTask(PlayerInstance player, long delay) private void startExpireTask(PlayerInstance player, long delay)
{ {
final ScheduledFuture<?> task = ThreadPool.schedule(new PremiumExpireTask(player), delay); _expiretasks.put(player.getAccountName(), ThreadPool.schedule(new PremiumExpireTask(player), delay));
expiretasks.put(player.getAccountName(), task);
} }
/** /**
@@ -119,7 +117,7 @@ public class PremiumManager
*/ */
private void stopExpireTask(PlayerInstance player) private void stopExpireTask(PlayerInstance player)
{ {
ScheduledFuture<?> task = expiretasks.remove(player.getAccountName()); ScheduledFuture<?> task = _expiretasks.remove(player.getAccountName());
if (task != null) if (task != null)
{ {
task.cancel(false); task.cancel(false);
@@ -137,7 +135,7 @@ public class PremiumManager
{ {
while (rset.next()) while (rset.next())
{ {
premiumData.put(rset.getString(1), rset.getLong(2)); _premiumData.put(rset.getString(1), rset.getLong(2));
} }
} }
} }
@@ -149,7 +147,7 @@ public class PremiumManager
public long getPremiumExpiration(String accountName) public long getPremiumExpiration(String accountName)
{ {
return premiumData.getOrDefault(accountName, 0L); return _premiumData.getOrDefault(accountName, 0L);
} }
public void addPremiumTime(String accountName, int timeValue, TimeUnit timeUnit) public void addPremiumTime(String accountName, int timeValue, TimeUnit timeUnit)
@@ -174,7 +172,7 @@ public class PremiumManager
} }
// UPDATE CACHE // UPDATE CACHE
premiumData.put(accountName, newPremiumExpiration); _premiumData.put(accountName, newPremiumExpiration);
// UPDATE PlAYER PREMIUMSTATUS // UPDATE PlAYER PREMIUMSTATUS
for (PlayerInstance player : World.getInstance().getPlayers()) for (PlayerInstance player : World.getInstance().getPlayers())
@@ -208,7 +206,7 @@ public class PremiumManager
} }
// UPDATE CACHE // UPDATE CACHE
premiumData.remove(accountName); _premiumData.remove(accountName);
// UPDATE DATABASE // UPDATE DATABASE
try (Connection con = DatabaseFactory.getConnection(); try (Connection con = DatabaseFactory.getConnection();

36
L2J_Mobius_3.0_Helios/java/org/l2jmobius/gameserver/instancemanager/PremiumManager.java
View File

@@ -51,30 +51,30 @@ public class PremiumManager
class PremiumExpireTask implements Runnable class PremiumExpireTask implements Runnable
{ {
final PlayerInstance player; final PlayerInstance _player;
PremiumExpireTask(PlayerInstance player) PremiumExpireTask(PlayerInstance player)
{ {
this.player = player; _player = player;
} }
@Override @Override
public void run() public void run()
{ {
player.setPremiumStatus(false); _player.setPremiumStatus(false);
} }
} }
// Data Cache // Data Cache
private final Map<String, Long> premiumData = new ConcurrentHashMap<>(); private final Map<String, Long> _premiumData = new ConcurrentHashMap<>();
// expireTasks // expireTasks
private final Map<String, ScheduledFuture<?>> expiretasks = new ConcurrentHashMap<>(); private final Map<String, ScheduledFuture<?>> _expiretasks = new ConcurrentHashMap<>();
// Listeners // Listeners
private final ListenersContainer listenerContainer = Containers.Players(); private final ListenersContainer _listenerContainer = Containers.Players();
private final Consumer<OnPlayerLogin> playerLoginEvent = event -> private final Consumer<OnPlayerLogin> _playerLoginEvent = event ->
{ {
final PlayerInstance player = event.getPlayer(); final PlayerInstance player = event.getPlayer();
final String accountName = player.getAccountName(); final String accountName = player.getAccountName();
@@ -92,16 +92,15 @@ public class PremiumManager
} }
}; };
private final Consumer<OnPlayerLogout> playerLogoutEvent = event -> private final Consumer<OnPlayerLogout> _playerLogoutEvent = event ->
{ {
final PlayerInstance player = event.getPlayer(); stopExpireTask(event.getPlayer());
stopExpireTask(player);
}; };
protected PremiumManager() protected PremiumManager()
{ {
listenerContainer.addListener(new ConsumerEventListener(listenerContainer, EventType.ON_PLAYER_LOGIN, playerLoginEvent, this)); _listenerContainer.addListener(new ConsumerEventListener(_listenerContainer, EventType.ON_PLAYER_LOGIN, _playerLoginEvent, this));
listenerContainer.addListener(new ConsumerEventListener(listenerContainer, EventType.ON_PLAYER_LOGOUT, playerLogoutEvent, this)); _listenerContainer.addListener(new ConsumerEventListener(_listenerContainer, EventType.ON_PLAYER_LOGOUT, _playerLogoutEvent, this));
} }
/** /**
@@ -110,8 +109,7 @@ public class PremiumManager
*/ */
private void startExpireTask(PlayerInstance player, long delay) private void startExpireTask(PlayerInstance player, long delay)
{ {
final ScheduledFuture<?> task = ThreadPool.schedule(new PremiumExpireTask(player), delay); _expiretasks.put(player.getAccountName(), ThreadPool.schedule(new PremiumExpireTask(player), delay));
expiretasks.put(player.getAccountName(), task);
} }
/** /**
@@ -119,7 +117,7 @@ public class PremiumManager
*/ */
private void stopExpireTask(PlayerInstance player) private void stopExpireTask(PlayerInstance player)
{ {
ScheduledFuture<?> task = expiretasks.remove(player.getAccountName()); ScheduledFuture<?> task = _expiretasks.remove(player.getAccountName());
if (task != null) if (task != null)
{ {
task.cancel(false); task.cancel(false);
@@ -137,7 +135,7 @@ public class PremiumManager
{ {
while (rset.next()) while (rset.next())
{ {
premiumData.put(rset.getString(1), rset.getLong(2)); _premiumData.put(rset.getString(1), rset.getLong(2));
} }
} }
} }
@@ -149,7 +147,7 @@ public class PremiumManager
public long getPremiumExpiration(String accountName) public long getPremiumExpiration(String accountName)
{ {
return premiumData.getOrDefault(accountName, 0L); return _premiumData.getOrDefault(accountName, 0L);
} }
public void addPremiumTime(String accountName, int timeValue, TimeUnit timeUnit) public void addPremiumTime(String accountName, int timeValue, TimeUnit timeUnit)
@@ -174,7 +172,7 @@ public class PremiumManager
} }
// UPDATE CACHE // UPDATE CACHE
premiumData.put(accountName, newPremiumExpiration); _premiumData.put(accountName, newPremiumExpiration);
// UPDATE PlAYER PREMIUMSTATUS // UPDATE PlAYER PREMIUMSTATUS
for (PlayerInstance player : World.getInstance().getPlayers()) for (PlayerInstance player : World.getInstance().getPlayers())
@@ -208,7 +206,7 @@ public class PremiumManager
} }
// UPDATE CACHE // UPDATE CACHE
premiumData.remove(accountName); _premiumData.remove(accountName);
// UPDATE DATABASE // UPDATE DATABASE
try (Connection con = DatabaseFactory.getConnection(); try (Connection con = DatabaseFactory.getConnection();

36
L2J_Mobius_4.0_GrandCrusade/java/org/l2jmobius/gameserver/instancemanager/PremiumManager.java
View File

@@ -51,30 +51,30 @@ public class PremiumManager
class PremiumExpireTask implements Runnable class PremiumExpireTask implements Runnable
{ {
final PlayerInstance player; final PlayerInstance _player;
PremiumExpireTask(PlayerInstance player) PremiumExpireTask(PlayerInstance player)
{ {
this.player = player; _player = player;
} }
@Override @Override
public void run() public void run()
{ {
player.setPremiumStatus(false); _player.setPremiumStatus(false);
} }
} }
// Data Cache // Data Cache
private final Map<String, Long> premiumData = new ConcurrentHashMap<>(); private final Map<String, Long> _premiumData = new ConcurrentHashMap<>();
// expireTasks // expireTasks
private final Map<String, ScheduledFuture<?>> expiretasks = new ConcurrentHashMap<>(); private final Map<String, ScheduledFuture<?>> _expiretasks = new ConcurrentHashMap<>();
// Listeners // Listeners
private final ListenersContainer listenerContainer = Containers.Players(); private final ListenersContainer _listenerContainer = Containers.Players();
private final Consumer<OnPlayerLogin> playerLoginEvent = event -> private final Consumer<OnPlayerLogin> _playerLoginEvent = event ->
{ {
final PlayerInstance player = event.getPlayer(); final PlayerInstance player = event.getPlayer();
final String accountName = player.getAccountName(); final String accountName = player.getAccountName();
@@ -92,16 +92,15 @@ public class PremiumManager
} }
}; };
private final Consumer<OnPlayerLogout> playerLogoutEvent = event -> private final Consumer<OnPlayerLogout> _playerLogoutEvent = event ->
{ {
final PlayerInstance player = event.getPlayer(); stopExpireTask(event.getPlayer());
stopExpireTask(player);
}; };
protected PremiumManager() protected PremiumManager()
{ {
listenerContainer.addListener(new ConsumerEventListener(listenerContainer, EventType.ON_PLAYER_LOGIN, playerLoginEvent, this)); _listenerContainer.addListener(new ConsumerEventListener(_listenerContainer, EventType.ON_PLAYER_LOGIN, _playerLoginEvent, this));
listenerContainer.addListener(new ConsumerEventListener(listenerContainer, EventType.ON_PLAYER_LOGOUT, playerLogoutEvent, this)); _listenerContainer.addListener(new ConsumerEventListener(_listenerContainer, EventType.ON_PLAYER_LOGOUT, _playerLogoutEvent, this));
} }
/** /**
@@ -110,8 +109,7 @@ public class PremiumManager
*/ */
private void startExpireTask(PlayerInstance player, long delay) private void startExpireTask(PlayerInstance player, long delay)
{ {
final ScheduledFuture<?> task = ThreadPool.schedule(new PremiumExpireTask(player), delay); _expiretasks.put(player.getAccountName(), ThreadPool.schedule(new PremiumExpireTask(player), delay));
expiretasks.put(player.getAccountName(), task);
} }
/** /**
@@ -119,7 +117,7 @@ public class PremiumManager
*/ */
private void stopExpireTask(PlayerInstance player) private void stopExpireTask(PlayerInstance player)
{ {
ScheduledFuture<?> task = expiretasks.remove(player.getAccountName()); ScheduledFuture<?> task = _expiretasks.remove(player.getAccountName());
if (task != null) if (task != null)
{ {
task.cancel(false); task.cancel(false);
@@ -137,7 +135,7 @@ public class PremiumManager
{ {
while (rset.next()) while (rset.next())
{ {
premiumData.put(rset.getString(1), rset.getLong(2)); _premiumData.put(rset.getString(1), rset.getLong(2));
} }
} }
} }
@@ -149,7 +147,7 @@ public class PremiumManager
public long getPremiumExpiration(String accountName) public long getPremiumExpiration(String accountName)
{ {
return premiumData.getOrDefault(accountName, 0L); return _premiumData.getOrDefault(accountName, 0L);
} }
public void addPremiumTime(String accountName, int timeValue, TimeUnit timeUnit) public void addPremiumTime(String accountName, int timeValue, TimeUnit timeUnit)
@@ -174,7 +172,7 @@ public class PremiumManager
} }
// UPDATE CACHE // UPDATE CACHE
premiumData.put(accountName, newPremiumExpiration); _premiumData.put(accountName, newPremiumExpiration);
// UPDATE PlAYER PREMIUMSTATUS // UPDATE PlAYER PREMIUMSTATUS
for (PlayerInstance player : World.getInstance().getPlayers()) for (PlayerInstance player : World.getInstance().getPlayers())
@@ -208,7 +206,7 @@ public class PremiumManager
} }
// UPDATE CACHE // UPDATE CACHE
premiumData.remove(accountName); _premiumData.remove(accountName);
// UPDATE DATABASE // UPDATE DATABASE
try (Connection con = DatabaseFactory.getConnection(); try (Connection con = DatabaseFactory.getConnection();

36
L2J_Mobius_5.0_Salvation/java/org/l2jmobius/gameserver/instancemanager/PremiumManager.java
View File

@@ -51,30 +51,30 @@ public class PremiumManager
class PremiumExpireTask implements Runnable class PremiumExpireTask implements Runnable
{ {
final PlayerInstance player; final PlayerInstance _player;
PremiumExpireTask(PlayerInstance player) PremiumExpireTask(PlayerInstance player)
{ {
this.player = player; _player = player;
} }
@Override @Override
public void run() public void run()
{ {
player.setPremiumStatus(false); _player.setPremiumStatus(false);
} }
} }
// Data Cache // Data Cache
private final Map<String, Long> premiumData = new ConcurrentHashMap<>(); private final Map<String, Long> _premiumData = new ConcurrentHashMap<>();
// expireTasks // expireTasks
private final Map<String, ScheduledFuture<?>> expiretasks = new ConcurrentHashMap<>(); private final Map<String, ScheduledFuture<?>> _expiretasks = new ConcurrentHashMap<>();
// Listeners // Listeners
private final ListenersContainer listenerContainer = Containers.Players(); private final ListenersContainer _listenerContainer = Containers.Players();
private final Consumer<OnPlayerLogin> playerLoginEvent = event -> private final Consumer<OnPlayerLogin> _playerLoginEvent = event ->
{ {
final PlayerInstance player = event.getPlayer(); final PlayerInstance player = event.getPlayer();
final String accountName = player.getAccountName(); final String accountName = player.getAccountName();
@@ -92,16 +92,15 @@ public class PremiumManager
} }
}; };
private final Consumer<OnPlayerLogout> playerLogoutEvent = event -> private final Consumer<OnPlayerLogout> _playerLogoutEvent = event ->
{ {
final PlayerInstance player = event.getPlayer(); stopExpireTask(event.getPlayer());
stopExpireTask(player);
}; };
protected PremiumManager() protected PremiumManager()
{ {
listenerContainer.addListener(new ConsumerEventListener(listenerContainer, EventType.ON_PLAYER_LOGIN, playerLoginEvent, this)); _listenerContainer.addListener(new ConsumerEventListener(_listenerContainer, EventType.ON_PLAYER_LOGIN, _playerLoginEvent, this));
listenerContainer.addListener(new ConsumerEventListener(listenerContainer, EventType.ON_PLAYER_LOGOUT, playerLogoutEvent, this)); _listenerContainer.addListener(new ConsumerEventListener(_listenerContainer, EventType.ON_PLAYER_LOGOUT, _playerLogoutEvent, this));
} }
/** /**
@@ -110,8 +109,7 @@ public class PremiumManager
*/ */
private void startExpireTask(PlayerInstance player, long delay) private void startExpireTask(PlayerInstance player, long delay)
{ {
final ScheduledFuture<?> task = ThreadPool.schedule(new PremiumExpireTask(player), delay); _expiretasks.put(player.getAccountName(), ThreadPool.schedule(new PremiumExpireTask(player), delay));
expiretasks.put(player.getAccountName(), task);
} }
/** /**
@@ -119,7 +117,7 @@ public class PremiumManager
*/ */
private void stopExpireTask(PlayerInstance player) private void stopExpireTask(PlayerInstance player)
{ {
ScheduledFuture<?> task = expiretasks.remove(player.getAccountName()); ScheduledFuture<?> task = _expiretasks.remove(player.getAccountName());
if (task != null) if (task != null)
{ {
task.cancel(false); task.cancel(false);
@@ -137,7 +135,7 @@ public class PremiumManager
{ {
while (rset.next()) while (rset.next())
{ {
premiumData.put(rset.getString(1), rset.getLong(2)); _premiumData.put(rset.getString(1), rset.getLong(2));
} }
} }
} }
@@ -149,7 +147,7 @@ public class PremiumManager
public long getPremiumExpiration(String accountName) public long getPremiumExpiration(String accountName)
{ {
return premiumData.getOrDefault(accountName, 0L); return _premiumData.getOrDefault(accountName, 0L);
} }
public void addPremiumTime(String accountName, int timeValue, TimeUnit timeUnit) public void addPremiumTime(String accountName, int timeValue, TimeUnit timeUnit)
@@ -174,7 +172,7 @@ public class PremiumManager
} }
// UPDATE CACHE // UPDATE CACHE
premiumData.put(accountName, newPremiumExpiration); _premiumData.put(accountName, newPremiumExpiration);
// UPDATE PlAYER PREMIUMSTATUS // UPDATE PlAYER PREMIUMSTATUS
for (PlayerInstance player : World.getInstance().getPlayers()) for (PlayerInstance player : World.getInstance().getPlayers())
@@ -208,7 +206,7 @@ public class PremiumManager
} }
// UPDATE CACHE // UPDATE CACHE
premiumData.remove(accountName); _premiumData.remove(accountName);
// UPDATE DATABASE // UPDATE DATABASE
try (Connection con = DatabaseFactory.getConnection(); try (Connection con = DatabaseFactory.getConnection();

36
L2J_Mobius_5.5_EtinasFate/java/org/l2jmobius/gameserver/instancemanager/PremiumManager.java
View File

@@ -51,30 +51,30 @@ public class PremiumManager
class PremiumExpireTask implements Runnable class PremiumExpireTask implements Runnable
{ {
final PlayerInstance player; final PlayerInstance _player;
PremiumExpireTask(PlayerInstance player) PremiumExpireTask(PlayerInstance player)
{ {
this.player = player; _player = player;
} }
@Override @Override
public void run() public void run()
{ {
player.setPremiumStatus(false); _player.setPremiumStatus(false);
} }
} }
// Data Cache // Data Cache
private final Map<String, Long> premiumData = new ConcurrentHashMap<>(); private final Map<String, Long> _premiumData = new ConcurrentHashMap<>();
// expireTasks // expireTasks
private final Map<String, ScheduledFuture<?>> expiretasks = new ConcurrentHashMap<>(); private final Map<String, ScheduledFuture<?>> _expiretasks = new ConcurrentHashMap<>();
// Listeners // Listeners
private final ListenersContainer listenerContainer = Containers.Players(); private final ListenersContainer _listenerContainer = Containers.Players();
private final Consumer<OnPlayerLogin> playerLoginEvent = event -> private final Consumer<OnPlayerLogin> _playerLoginEvent = event ->
{ {
final PlayerInstance player = event.getPlayer(); final PlayerInstance player = event.getPlayer();
final String accountName = player.getAccountName(); final String accountName = player.getAccountName();
@@ -92,16 +92,15 @@ public class PremiumManager
} }
}; };
private final Consumer<OnPlayerLogout> playerLogoutEvent = event -> private final Consumer<OnPlayerLogout> _playerLogoutEvent = event ->
{ {
final PlayerInstance player = event.getPlayer(); stopExpireTask(event.getPlayer());
stopExpireTask(player);
}; };
protected PremiumManager() protected PremiumManager()
{ {
listenerContainer.addListener(new ConsumerEventListener(listenerContainer, EventType.ON_PLAYER_LOGIN, playerLoginEvent, this)); _listenerContainer.addListener(new ConsumerEventListener(_listenerContainer, EventType.ON_PLAYER_LOGIN, _playerLoginEvent, this));
listenerContainer.addListener(new ConsumerEventListener(listenerContainer, EventType.ON_PLAYER_LOGOUT, playerLogoutEvent, this)); _listenerContainer.addListener(new ConsumerEventListener(_listenerContainer, EventType.ON_PLAYER_LOGOUT, _playerLogoutEvent, this));
} }
/** /**
@@ -110,8 +109,7 @@ public class PremiumManager
*/ */
private void startExpireTask(PlayerInstance player, long delay) private void startExpireTask(PlayerInstance player, long delay)
{ {
final ScheduledFuture<?> task = ThreadPool.schedule(new PremiumExpireTask(player), delay); _expiretasks.put(player.getAccountName(), ThreadPool.schedule(new PremiumExpireTask(player), delay));
expiretasks.put(player.getAccountName(), task);
} }
/** /**
@@ -119,7 +117,7 @@ public class PremiumManager
*/ */
private void stopExpireTask(PlayerInstance player) private void stopExpireTask(PlayerInstance player)
{ {
ScheduledFuture<?> task = expiretasks.remove(player.getAccountName()); ScheduledFuture<?> task = _expiretasks.remove(player.getAccountName());
if (task != null) if (task != null)
{ {
task.cancel(false); task.cancel(false);
@@ -137,7 +135,7 @@ public class PremiumManager
{ {
while (rset.next()) while (rset.next())
{ {
premiumData.put(rset.getString(1), rset.getLong(2)); _premiumData.put(rset.getString(1), rset.getLong(2));
} }
} }
} }
@@ -149,7 +147,7 @@ public class PremiumManager
public long getPremiumExpiration(String accountName) public long getPremiumExpiration(String accountName)
{ {
return premiumData.getOrDefault(accountName, 0L); return _premiumData.getOrDefault(accountName, 0L);
} }
public void addPremiumTime(String accountName, int timeValue, TimeUnit timeUnit) public void addPremiumTime(String accountName, int timeValue, TimeUnit timeUnit)
@@ -174,7 +172,7 @@ public class PremiumManager
} }
// UPDATE CACHE // UPDATE CACHE
premiumData.put(accountName, newPremiumExpiration); _premiumData.put(accountName, newPremiumExpiration);
// UPDATE PlAYER PREMIUMSTATUS // UPDATE PlAYER PREMIUMSTATUS
for (PlayerInstance player : World.getInstance().getPlayers()) for (PlayerInstance player : World.getInstance().getPlayers())
@@ -208,7 +206,7 @@ public class PremiumManager
} }
// UPDATE CACHE // UPDATE CACHE
premiumData.remove(accountName); _premiumData.remove(accountName);
// UPDATE DATABASE // UPDATE DATABASE
try (Connection con = DatabaseFactory.getConnection(); try (Connection con = DatabaseFactory.getConnection();

36
L2J_Mobius_6.0_Fafurion/java/org/l2jmobius/gameserver/instancemanager/PremiumManager.java
View File

@@ -51,30 +51,30 @@ public class PremiumManager
class PremiumExpireTask implements Runnable class PremiumExpireTask implements Runnable
{ {
final PlayerInstance player; final PlayerInstance _player;
PremiumExpireTask(PlayerInstance player) PremiumExpireTask(PlayerInstance player)
{ {
this.player = player; _player = player;
} }
@Override @Override
public void run() public void run()
{ {
player.setPremiumStatus(false); _player.setPremiumStatus(false);
} }
} }
// Data Cache // Data Cache
private final Map<String, Long> premiumData = new ConcurrentHashMap<>(); private final Map<String, Long> _premiumData = new ConcurrentHashMap<>();
// expireTasks // expireTasks
private final Map<String, ScheduledFuture<?>> expiretasks = new ConcurrentHashMap<>(); private final Map<String, ScheduledFuture<?>> _expiretasks = new ConcurrentHashMap<>();
// Listeners // Listeners
private final ListenersContainer listenerContainer = Containers.Players(); private final ListenersContainer _listenerContainer = Containers.Players();
private final Consumer<OnPlayerLogin> playerLoginEvent = event -> private final Consumer<OnPlayerLogin> _playerLoginEvent = event ->
{ {
final PlayerInstance player = event.getPlayer(); final PlayerInstance player = event.getPlayer();
final String accountName = player.getAccountName(); final String accountName = player.getAccountName();
@@ -92,16 +92,15 @@ public class PremiumManager
} }
}; };
private final Consumer<OnPlayerLogout> playerLogoutEvent = event -> private final Consumer<OnPlayerLogout> _playerLogoutEvent = event ->
{ {
final PlayerInstance player = event.getPlayer(); stopExpireTask(event.getPlayer());
stopExpireTask(player);
}; };
protected PremiumManager() protected PremiumManager()
{ {
listenerContainer.addListener(new ConsumerEventListener(listenerContainer, EventType.ON_PLAYER_LOGIN, playerLoginEvent, this)); _listenerContainer.addListener(new ConsumerEventListener(_listenerContainer, EventType.ON_PLAYER_LOGIN, _playerLoginEvent, this));
listenerContainer.addListener(new ConsumerEventListener(listenerContainer, EventType.ON_PLAYER_LOGOUT, playerLogoutEvent, this)); _listenerContainer.addListener(new ConsumerEventListener(_listenerContainer, EventType.ON_PLAYER_LOGOUT, _playerLogoutEvent, this));
} }
/** /**
@@ -110,8 +109,7 @@ public class PremiumManager
*/ */
private void startExpireTask(PlayerInstance player, long delay) private void startExpireTask(PlayerInstance player, long delay)
{ {
final ScheduledFuture<?> task = ThreadPool.schedule(new PremiumExpireTask(player), delay); _expiretasks.put(player.getAccountName(), ThreadPool.schedule(new PremiumExpireTask(player), delay));
expiretasks.put(player.getAccountName(), task);
} }
/** /**
@@ -119,7 +117,7 @@ public class PremiumManager
*/ */
private void stopExpireTask(PlayerInstance player) private void stopExpireTask(PlayerInstance player)
{ {
ScheduledFuture<?> task = expiretasks.remove(player.getAccountName()); ScheduledFuture<?> task = _expiretasks.remove(player.getAccountName());
if (task != null) if (task != null)
{ {
task.cancel(false); task.cancel(false);
@@ -137,7 +135,7 @@ public class PremiumManager
{ {
while (rset.next()) while (rset.next())
{ {
premiumData.put(rset.getString(1), rset.getLong(2)); _premiumData.put(rset.getString(1), rset.getLong(2));
} }
} }
} }
@@ -149,7 +147,7 @@ public class PremiumManager
public long getPremiumExpiration(String accountName) public long getPremiumExpiration(String accountName)
{ {
return premiumData.getOrDefault(accountName, 0L); return _premiumData.getOrDefault(accountName, 0L);
} }
public void addPremiumTime(String accountName, int timeValue, TimeUnit timeUnit) public void addPremiumTime(String accountName, int timeValue, TimeUnit timeUnit)
@@ -174,7 +172,7 @@ public class PremiumManager
} }
// UPDATE CACHE // UPDATE CACHE
premiumData.put(accountName, newPremiumExpiration); _premiumData.put(accountName, newPremiumExpiration);
// UPDATE PlAYER PREMIUMSTATUS // UPDATE PlAYER PREMIUMSTATUS
for (PlayerInstance player : World.getInstance().getPlayers()) for (PlayerInstance player : World.getInstance().getPlayers())
@@ -208,7 +206,7 @@ public class PremiumManager
} }
// UPDATE CACHE // UPDATE CACHE
premiumData.remove(accountName); _premiumData.remove(accountName);
// UPDATE DATABASE // UPDATE DATABASE
try (Connection con = DatabaseFactory.getConnection(); try (Connection con = DatabaseFactory.getConnection();

36
L2J_Mobius_7.0_PreludeOfWar/java/org/l2jmobius/gameserver/instancemanager/PremiumManager.java
View File

@@ -51,30 +51,30 @@ public class PremiumManager
class PremiumExpireTask implements Runnable class PremiumExpireTask implements Runnable
{ {
final PlayerInstance player; final PlayerInstance _player;
PremiumExpireTask(PlayerInstance player) PremiumExpireTask(PlayerInstance player)
{ {
this.player = player; _player = player;
} }
@Override @Override
public void run() public void run()
{ {
player.setPremiumStatus(false); _player.setPremiumStatus(false);
} }
} }
// Data Cache // Data Cache
private final Map<String, Long> premiumData = new ConcurrentHashMap<>(); private final Map<String, Long> _premiumData = new ConcurrentHashMap<>();
// expireTasks // expireTasks
private final Map<String, ScheduledFuture<?>> expiretasks = new ConcurrentHashMap<>(); private final Map<String, ScheduledFuture<?>> _expiretasks = new ConcurrentHashMap<>();
// Listeners // Listeners
private final ListenersContainer listenerContainer = Containers.Players(); private final ListenersContainer _listenerContainer = Containers.Players();
private final Consumer<OnPlayerLogin> playerLoginEvent = event -> private final Consumer<OnPlayerLogin> _playerLoginEvent = event ->
{ {
final PlayerInstance player = event.getPlayer(); final PlayerInstance player = event.getPlayer();
final String accountName = player.getAccountName(); final String accountName = player.getAccountName();
@@ -92,16 +92,15 @@ public class PremiumManager
} }
}; };
private final Consumer<OnPlayerLogout> playerLogoutEvent = event -> private final Consumer<OnPlayerLogout> _playerLogoutEvent = event ->
{ {
final PlayerInstance player = event.getPlayer(); stopExpireTask(event.getPlayer());
stopExpireTask(player);
}; };
protected PremiumManager() protected PremiumManager()
{ {
listenerContainer.addListener(new ConsumerEventListener(listenerContainer, EventType.ON_PLAYER_LOGIN, playerLoginEvent, this)); _listenerContainer.addListener(new ConsumerEventListener(_listenerContainer, EventType.ON_PLAYER_LOGIN, _playerLoginEvent, this));
listenerContainer.addListener(new ConsumerEventListener(listenerContainer, EventType.ON_PLAYER_LOGOUT, playerLogoutEvent, this)); _listenerContainer.addListener(new ConsumerEventListener(_listenerContainer, EventType.ON_PLAYER_LOGOUT, _playerLogoutEvent, this));
} }
/** /**
@@ -110,8 +109,7 @@ public class PremiumManager
*/ */
private void startExpireTask(PlayerInstance player, long delay) private void startExpireTask(PlayerInstance player, long delay)
{ {
final ScheduledFuture<?> task = ThreadPool.schedule(new PremiumExpireTask(player), delay); _expiretasks.put(player.getAccountName(), ThreadPool.schedule(new PremiumExpireTask(player), delay));
expiretasks.put(player.getAccountName(), task);
} }
/** /**
@@ -119,7 +117,7 @@ public class PremiumManager
*/ */
private void stopExpireTask(PlayerInstance player) private void stopExpireTask(PlayerInstance player)
{ {
ScheduledFuture<?> task = expiretasks.remove(player.getAccountName()); ScheduledFuture<?> task = _expiretasks.remove(player.getAccountName());
if (task != null) if (task != null)
{ {
task.cancel(false); task.cancel(false);
@@ -137,7 +135,7 @@ public class PremiumManager
{ {
while (rset.next()) while (rset.next())
{ {
premiumData.put(rset.getString(1), rset.getLong(2)); _premiumData.put(rset.getString(1), rset.getLong(2));
} }
} }
} }
@@ -149,7 +147,7 @@ public class PremiumManager
public long getPremiumExpiration(String accountName) public long getPremiumExpiration(String accountName)
{ {
return premiumData.getOrDefault(accountName, 0L); return _premiumData.getOrDefault(accountName, 0L);
} }
public void addPremiumTime(String accountName, int timeValue, TimeUnit timeUnit) public void addPremiumTime(String accountName, int timeValue, TimeUnit timeUnit)
@@ -174,7 +172,7 @@ public class PremiumManager
} }
// UPDATE CACHE // UPDATE CACHE
premiumData.put(accountName, newPremiumExpiration); _premiumData.put(accountName, newPremiumExpiration);
// UPDATE PlAYER PREMIUMSTATUS // UPDATE PlAYER PREMIUMSTATUS
for (PlayerInstance player : World.getInstance().getPlayers()) for (PlayerInstance player : World.getInstance().getPlayers())
@@ -208,7 +206,7 @@ public class PremiumManager
} }
// UPDATE CACHE // UPDATE CACHE
premiumData.remove(accountName); _premiumData.remove(accountName);
// UPDATE DATABASE // UPDATE DATABASE
try (Connection con = DatabaseFactory.getConnection(); try (Connection con = DatabaseFactory.getConnection();

36
L2J_Mobius_CT_2.4_Epilogue/java/org/l2jmobius/gameserver/instancemanager/PremiumManager.java
View File

@@ -51,30 +51,30 @@ public class PremiumManager
class PremiumExpireTask implements Runnable class PremiumExpireTask implements Runnable
{ {
final PlayerInstance player; final PlayerInstance _player;
PremiumExpireTask(PlayerInstance player) PremiumExpireTask(PlayerInstance player)
{ {
this.player = player; _player = player;
} }
@Override @Override
public void run() public void run()
{ {
player.setPremiumStatus(false); _player.setPremiumStatus(false);
} }
} }
// Data Cache // Data Cache
private final Map<String, Long> premiumData = new ConcurrentHashMap<>(); private final Map<String, Long> _premiumData = new ConcurrentHashMap<>();
// expireTasks // expireTasks
private final Map<String, ScheduledFuture<?>> expiretasks = new ConcurrentHashMap<>(); private final Map<String, ScheduledFuture<?>> _expiretasks = new ConcurrentHashMap<>();
// Listeners // Listeners
private final ListenersContainer listenerContainer = Containers.Players(); private final ListenersContainer _listenerContainer = Containers.Players();
private final Consumer<OnPlayerLogin> playerLoginEvent = (event) -> private final Consumer<OnPlayerLogin> _playerLoginEvent = event ->
{ {
final PlayerInstance player = event.getPlayer(); final PlayerInstance player = event.getPlayer();
final String accountName = player.getAccountName(); final String accountName = player.getAccountName();
@@ -92,16 +92,15 @@ public class PremiumManager
} }
}; };
private final Consumer<OnPlayerLogout> playerLogoutEvent = (event) -> private final Consumer<OnPlayerLogout> _playerLogoutEvent = event ->
{ {
final PlayerInstance player = event.getPlayer(); stopExpireTask(event.getPlayer());
stopExpireTask(player);
}; };
protected PremiumManager() protected PremiumManager()
{ {
listenerContainer.addListener(new ConsumerEventListener(listenerContainer, EventType.ON_PLAYER_LOGIN, playerLoginEvent, this)); _listenerContainer.addListener(new ConsumerEventListener(_listenerContainer, EventType.ON_PLAYER_LOGIN, _playerLoginEvent, this));
listenerContainer.addListener(new ConsumerEventListener(listenerContainer, EventType.ON_PLAYER_LOGOUT, playerLogoutEvent, this)); _listenerContainer.addListener(new ConsumerEventListener(_listenerContainer, EventType.ON_PLAYER_LOGOUT, _playerLogoutEvent, this));
} }
/** /**
@@ -110,8 +109,7 @@ public class PremiumManager
*/ */
private void startExpireTask(PlayerInstance player, long delay) private void startExpireTask(PlayerInstance player, long delay)
{ {
final ScheduledFuture<?> task = ThreadPool.schedule(new PremiumExpireTask(player), delay); _expiretasks.put(player.getAccountName(), ThreadPool.schedule(new PremiumExpireTask(player), delay));
expiretasks.put(player.getAccountName(), task);
} }
/** /**
@@ -119,7 +117,7 @@ public class PremiumManager
*/ */
private void stopExpireTask(PlayerInstance player) private void stopExpireTask(PlayerInstance player)
{ {
ScheduledFuture<?> task = expiretasks.remove(player.getAccountName()); ScheduledFuture<?> task = _expiretasks.remove(player.getAccountName());
if (task != null) if (task != null)
{ {
task.cancel(false); task.cancel(false);
@@ -137,7 +135,7 @@ public class PremiumManager
{ {
while (rset.next()) while (rset.next())
{ {
premiumData.put(rset.getString(1), rset.getLong(2)); _premiumData.put(rset.getString(1), rset.getLong(2));
} }
} }
} }
@@ -149,7 +147,7 @@ public class PremiumManager
public long getPremiumExpiration(String accountName) public long getPremiumExpiration(String accountName)
{ {
return premiumData.getOrDefault(accountName, 0L); return _premiumData.getOrDefault(accountName, 0L);
} }
public void addPremiumTime(String accountName, int timeValue, TimeUnit timeUnit) public void addPremiumTime(String accountName, int timeValue, TimeUnit timeUnit)
@@ -174,7 +172,7 @@ public class PremiumManager
} }
// UPDATE CACHE // UPDATE CACHE
premiumData.put(accountName, newPremiumExpiration); _premiumData.put(accountName, newPremiumExpiration);
// UPDATE PlAYER PREMIUMSTATUS // UPDATE PlAYER PREMIUMSTATUS
for (PlayerInstance player : World.getInstance().getPlayers()) for (PlayerInstance player : World.getInstance().getPlayers())
@@ -208,7 +206,7 @@ public class PremiumManager
} }
// UPDATE CACHE // UPDATE CACHE
premiumData.remove(accountName); _premiumData.remove(accountName);
// UPDATE DATABASE // UPDATE DATABASE
try (Connection con = DatabaseFactory.getConnection(); try (Connection con = DatabaseFactory.getConnection();

36
L2J_Mobius_CT_2.6_HighFive/java/org/l2jmobius/gameserver/instancemanager/PremiumManager.java
View File

@@ -51,30 +51,30 @@ public class PremiumManager
class PremiumExpireTask implements Runnable class PremiumExpireTask implements Runnable
{ {
final PlayerInstance player; final PlayerInstance _player;
PremiumExpireTask(PlayerInstance player) PremiumExpireTask(PlayerInstance player)
{ {
this.player = player; _player = player;
} }
@Override @Override
public void run() public void run()
{ {
player.setPremiumStatus(false); _player.setPremiumStatus(false);
} }
} }
// Data Cache // Data Cache
private final Map<String, Long> premiumData = new ConcurrentHashMap<>(); private final Map<String, Long> _premiumData = new ConcurrentHashMap<>();
// expireTasks // expireTasks
private final Map<String, ScheduledFuture<?>> expiretasks = new ConcurrentHashMap<>(); private final Map<String, ScheduledFuture<?>> _expiretasks = new ConcurrentHashMap<>();
// Listeners // Listeners
private final ListenersContainer listenerContainer = Containers.Players(); private final ListenersContainer _listenerContainer = Containers.Players();
private final Consumer<OnPlayerLogin> playerLoginEvent = (event) -> private final Consumer<OnPlayerLogin> _playerLoginEvent = event ->
{ {
final PlayerInstance player = event.getPlayer(); final PlayerInstance player = event.getPlayer();
final String accountName = player.getAccountName(); final String accountName = player.getAccountName();
@@ -92,16 +92,15 @@ public class PremiumManager
} }
}; };
private final Consumer<OnPlayerLogout> playerLogoutEvent = (event) -> private final Consumer<OnPlayerLogout> _playerLogoutEvent = event ->
{ {
final PlayerInstance player = event.getPlayer(); stopExpireTask(event.getPlayer());
stopExpireTask(player);
}; };
protected PremiumManager() protected PremiumManager()
{ {
listenerContainer.addListener(new ConsumerEventListener(listenerContainer, EventType.ON_PLAYER_LOGIN, playerLoginEvent, this)); _listenerContainer.addListener(new ConsumerEventListener(_listenerContainer, EventType.ON_PLAYER_LOGIN, _playerLoginEvent, this));
listenerContainer.addListener(new ConsumerEventListener(listenerContainer, EventType.ON_PLAYER_LOGOUT, playerLogoutEvent, this)); _listenerContainer.addListener(new ConsumerEventListener(_listenerContainer, EventType.ON_PLAYER_LOGOUT, _playerLogoutEvent, this));
} }
/** /**
@@ -110,8 +109,7 @@ public class PremiumManager
*/ */
private void startExpireTask(PlayerInstance player, long delay) private void startExpireTask(PlayerInstance player, long delay)
{ {
final ScheduledFuture<?> task = ThreadPool.schedule(new PremiumExpireTask(player), delay); _expiretasks.put(player.getAccountName(), ThreadPool.schedule(new PremiumExpireTask(player), delay));
expiretasks.put(player.getAccountName(), task);
} }
/** /**
@@ -119,7 +117,7 @@ public class PremiumManager
*/ */
private void stopExpireTask(PlayerInstance player) private void stopExpireTask(PlayerInstance player)
{ {
ScheduledFuture<?> task = expiretasks.remove(player.getAccountName()); ScheduledFuture<?> task = _expiretasks.remove(player.getAccountName());
if (task != null) if (task != null)
{ {
task.cancel(false); task.cancel(false);
@@ -137,7 +135,7 @@ public class PremiumManager
{ {
while (rset.next()) while (rset.next())
{ {
premiumData.put(rset.getString(1), rset.getLong(2)); _premiumData.put(rset.getString(1), rset.getLong(2));
} }
} }
} }
@@ -149,7 +147,7 @@ public class PremiumManager
public long getPremiumExpiration(String accountName) public long getPremiumExpiration(String accountName)
{ {
return premiumData.getOrDefault(accountName, 0L); return _premiumData.getOrDefault(accountName, 0L);
} }
public void addPremiumTime(String accountName, int timeValue, TimeUnit timeUnit) public void addPremiumTime(String accountName, int timeValue, TimeUnit timeUnit)
@@ -174,7 +172,7 @@ public class PremiumManager
} }
// UPDATE CACHE // UPDATE CACHE
premiumData.put(accountName, newPremiumExpiration); _premiumData.put(accountName, newPremiumExpiration);
// UPDATE PlAYER PREMIUMSTATUS // UPDATE PlAYER PREMIUMSTATUS
for (PlayerInstance player : World.getInstance().getPlayers()) for (PlayerInstance player : World.getInstance().getPlayers())
@@ -208,7 +206,7 @@ public class PremiumManager
} }
// UPDATE CACHE // UPDATE CACHE
premiumData.remove(accountName); _premiumData.remove(accountName);
// UPDATE DATABASE // UPDATE DATABASE
try (Connection con = DatabaseFactory.getConnection(); try (Connection con = DatabaseFactory.getConnection();

36
L2J_Mobius_Classic_2.0_Saviors/java/org/l2jmobius/gameserver/instancemanager/PremiumManager.java
View File

@@ -51,30 +51,30 @@ public class PremiumManager
class PremiumExpireTask implements Runnable class PremiumExpireTask implements Runnable
{ {
final PlayerInstance player; final PlayerInstance _player;
PremiumExpireTask(PlayerInstance player) PremiumExpireTask(PlayerInstance player)
{ {
this.player = player; _player = player;
} }
@Override @Override
public void run() public void run()
{ {
player.setPremiumStatus(false); _player.setPremiumStatus(false);
} }
} }
// Data Cache // Data Cache
private final Map<String, Long> premiumData = new ConcurrentHashMap<>(); private final Map<String, Long> _premiumData = new ConcurrentHashMap<>();
// expireTasks // expireTasks
private final Map<String, ScheduledFuture<?>> expiretasks = new ConcurrentHashMap<>(); private final Map<String, ScheduledFuture<?>> _expiretasks = new ConcurrentHashMap<>();
// Listeners // Listeners
private final ListenersContainer listenerContainer = Containers.Players(); private final ListenersContainer _listenerContainer = Containers.Players();
private final Consumer<OnPlayerLogin> playerLoginEvent = event -> private final Consumer<OnPlayerLogin> _playerLoginEvent = event ->
{ {
final PlayerInstance player = event.getPlayer(); final PlayerInstance player = event.getPlayer();
final String accountName = player.getAccountName(); final String accountName = player.getAccountName();
@@ -92,16 +92,15 @@ public class PremiumManager
} }
}; };
private final Consumer<OnPlayerLogout> playerLogoutEvent = event -> private final Consumer<OnPlayerLogout> _playerLogoutEvent = event ->
{ {
final PlayerInstance player = event.getPlayer(); stopExpireTask(event.getPlayer());
stopExpireTask(player);
}; };
protected PremiumManager() protected PremiumManager()
{ {
listenerContainer.addListener(new ConsumerEventListener(listenerContainer, EventType.ON_PLAYER_LOGIN, playerLoginEvent, this)); _listenerContainer.addListener(new ConsumerEventListener(_listenerContainer, EventType.ON_PLAYER_LOGIN, _playerLoginEvent, this));
listenerContainer.addListener(new ConsumerEventListener(listenerContainer, EventType.ON_PLAYER_LOGOUT, playerLogoutEvent, this)); _listenerContainer.addListener(new ConsumerEventListener(_listenerContainer, EventType.ON_PLAYER_LOGOUT, _playerLogoutEvent, this));
} }
/** /**
@@ -110,8 +109,7 @@ public class PremiumManager
*/ */
private void startExpireTask(PlayerInstance player, long delay) private void startExpireTask(PlayerInstance player, long delay)
{ {
final ScheduledFuture<?> task = ThreadPool.schedule(new PremiumExpireTask(player), delay); _expiretasks.put(player.getAccountName(), ThreadPool.schedule(new PremiumExpireTask(player), delay));
expiretasks.put(player.getAccountName(), task);
} }
/** /**
@@ -119,7 +117,7 @@ public class PremiumManager
*/ */
private void stopExpireTask(PlayerInstance player) private void stopExpireTask(PlayerInstance player)
{ {
ScheduledFuture<?> task = expiretasks.remove(player.getAccountName()); ScheduledFuture<?> task = _expiretasks.remove(player.getAccountName());
if (task != null) if (task != null)
{ {
task.cancel(false); task.cancel(false);
@@ -137,7 +135,7 @@ public class PremiumManager
{ {
while (rset.next()) while (rset.next())
{ {
premiumData.put(rset.getString(1), rset.getLong(2)); _premiumData.put(rset.getString(1), rset.getLong(2));
} }
} }
} }
@@ -149,7 +147,7 @@ public class PremiumManager
public long getPremiumExpiration(String accountName) public long getPremiumExpiration(String accountName)
{ {
return premiumData.getOrDefault(accountName, 0L); return _premiumData.getOrDefault(accountName, 0L);
} }
public void addPremiumTime(String accountName, int timeValue, TimeUnit timeUnit) public void addPremiumTime(String accountName, int timeValue, TimeUnit timeUnit)
@@ -174,7 +172,7 @@ public class PremiumManager
} }
// UPDATE CACHE // UPDATE CACHE
premiumData.put(accountName, newPremiumExpiration); _premiumData.put(accountName, newPremiumExpiration);
// UPDATE PlAYER PREMIUMSTATUS // UPDATE PlAYER PREMIUMSTATUS
for (PlayerInstance player : World.getInstance().getPlayers()) for (PlayerInstance player : World.getInstance().getPlayers())
@@ -208,7 +206,7 @@ public class PremiumManager
} }
// UPDATE CACHE // UPDATE CACHE
premiumData.remove(accountName); _premiumData.remove(accountName);
// UPDATE DATABASE // UPDATE DATABASE
try (Connection con = DatabaseFactory.getConnection(); try (Connection con = DatabaseFactory.getConnection();

36
L2J_Mobius_Classic_2.1_Zaken/java/org/l2jmobius/gameserver/instancemanager/PremiumManager.java
View File

@@ -51,30 +51,30 @@ public class PremiumManager
class PremiumExpireTask implements Runnable class PremiumExpireTask implements Runnable
{ {
final PlayerInstance player; final PlayerInstance _player;
PremiumExpireTask(PlayerInstance player) PremiumExpireTask(PlayerInstance player)
{ {
this.player = player; _player = player;
} }
@Override @Override
public void run() public void run()
{ {
player.setPremiumStatus(false); _player.setPremiumStatus(false);
} }
} }
// Data Cache // Data Cache
private final Map<String, Long> premiumData = new ConcurrentHashMap<>(); private final Map<String, Long> _premiumData = new ConcurrentHashMap<>();
// expireTasks // expireTasks
private final Map<String, ScheduledFuture<?>> expiretasks = new ConcurrentHashMap<>(); private final Map<String, ScheduledFuture<?>> _expiretasks = new ConcurrentHashMap<>();
// Listeners // Listeners
private final ListenersContainer listenerContainer = Containers.Players(); private final ListenersContainer _listenerContainer = Containers.Players();
private final Consumer<OnPlayerLogin> playerLoginEvent = event -> private final Consumer<OnPlayerLogin> _playerLoginEvent = event ->
{ {
final PlayerInstance player = event.getPlayer(); final PlayerInstance player = event.getPlayer();
final String accountName = player.getAccountName(); final String accountName = player.getAccountName();
@@ -92,16 +92,15 @@ public class PremiumManager
} }
}; };
private final Consumer<OnPlayerLogout> playerLogoutEvent = event -> private final Consumer<OnPlayerLogout> _playerLogoutEvent = event ->
{ {
final PlayerInstance player = event.getPlayer(); stopExpireTask(event.getPlayer());
stopExpireTask(player);
}; };
protected PremiumManager() protected PremiumManager()
{ {
listenerContainer.addListener(new ConsumerEventListener(listenerContainer, EventType.ON_PLAYER_LOGIN, playerLoginEvent, this)); _listenerContainer.addListener(new ConsumerEventListener(_listenerContainer, EventType.ON_PLAYER_LOGIN, _playerLoginEvent, this));
listenerContainer.addListener(new ConsumerEventListener(listenerContainer, EventType.ON_PLAYER_LOGOUT, playerLogoutEvent, this)); _listenerContainer.addListener(new ConsumerEventListener(_listenerContainer, EventType.ON_PLAYER_LOGOUT, _playerLogoutEvent, this));
} }
/** /**
@@ -110,8 +109,7 @@ public class PremiumManager
*/ */
private void startExpireTask(PlayerInstance player, long delay) private void startExpireTask(PlayerInstance player, long delay)
{ {
final ScheduledFuture<?> task = ThreadPool.schedule(new PremiumExpireTask(player), delay); _expiretasks.put(player.getAccountName(), ThreadPool.schedule(new PremiumExpireTask(player), delay));
expiretasks.put(player.getAccountName(), task);
} }
/** /**
@@ -119,7 +117,7 @@ public class PremiumManager
*/ */
private void stopExpireTask(PlayerInstance player) private void stopExpireTask(PlayerInstance player)
{ {
ScheduledFuture<?> task = expiretasks.remove(player.getAccountName()); ScheduledFuture<?> task = _expiretasks.remove(player.getAccountName());
if (task != null) if (task != null)
{ {
task.cancel(false); task.cancel(false);
@@ -137,7 +135,7 @@ public class PremiumManager
{ {
while (rset.next()) while (rset.next())
{ {
premiumData.put(rset.getString(1), rset.getLong(2)); _premiumData.put(rset.getString(1), rset.getLong(2));
} }
} }
} }
@@ -149,7 +147,7 @@ public class PremiumManager
public long getPremiumExpiration(String accountName) public long getPremiumExpiration(String accountName)
{ {
return premiumData.getOrDefault(accountName, 0L); return _premiumData.getOrDefault(accountName, 0L);
} }
public void addPremiumTime(String accountName, int timeValue, TimeUnit timeUnit) public void addPremiumTime(String accountName, int timeValue, TimeUnit timeUnit)
@@ -174,7 +172,7 @@ public class PremiumManager
} }
// UPDATE CACHE // UPDATE CACHE
premiumData.put(accountName, newPremiumExpiration); _premiumData.put(accountName, newPremiumExpiration);
// UPDATE PlAYER PREMIUMSTATUS // UPDATE PlAYER PREMIUMSTATUS
for (PlayerInstance player : World.getInstance().getPlayers()) for (PlayerInstance player : World.getInstance().getPlayers())
@@ -208,7 +206,7 @@ public class PremiumManager
} }
// UPDATE CACHE // UPDATE CACHE
premiumData.remove(accountName); _premiumData.remove(accountName);
// UPDATE DATABASE // UPDATE DATABASE
try (Connection con = DatabaseFactory.getConnection(); try (Connection con = DatabaseFactory.getConnection();

36
L2J_Mobius_Classic_2.2_Antharas/java/org/l2jmobius/gameserver/instancemanager/PremiumManager.java
View File

@@ -51,30 +51,30 @@ public class PremiumManager
class PremiumExpireTask implements Runnable class PremiumExpireTask implements Runnable
{ {
final PlayerInstance player; final PlayerInstance _player;
PremiumExpireTask(PlayerInstance player) PremiumExpireTask(PlayerInstance player)
{ {
this.player = player; _player = player;
} }
@Override @Override
public void run() public void run()
{ {
player.setPremiumStatus(false); _player.setPremiumStatus(false);
} }
} }
// Data Cache // Data Cache
private final Map<String, Long> premiumData = new ConcurrentHashMap<>(); private final Map<String, Long> _premiumData = new ConcurrentHashMap<>();
// expireTasks // expireTasks
private final Map<String, ScheduledFuture<?>> expiretasks = new ConcurrentHashMap<>(); private final Map<String, ScheduledFuture<?>> _expiretasks = new ConcurrentHashMap<>();
// Listeners // Listeners
private final ListenersContainer listenerContainer = Containers.Players(); private final ListenersContainer _listenerContainer = Containers.Players();
private final Consumer<OnPlayerLogin> playerLoginEvent = event -> private final Consumer<OnPlayerLogin> _playerLoginEvent = event ->
{ {
final PlayerInstance player = event.getPlayer(); final PlayerInstance player = event.getPlayer();
final String accountName = player.getAccountName(); final String accountName = player.getAccountName();
@@ -92,16 +92,15 @@ public class PremiumManager
} }
}; };
private final Consumer<OnPlayerLogout> playerLogoutEvent = event -> private final Consumer<OnPlayerLogout> _playerLogoutEvent = event ->
{ {
final PlayerInstance player = event.getPlayer(); stopExpireTask(event.getPlayer());
stopExpireTask(player);
}; };
protected PremiumManager() protected PremiumManager()
{ {
listenerContainer.addListener(new ConsumerEventListener(listenerContainer, EventType.ON_PLAYER_LOGIN, playerLoginEvent, this)); _listenerContainer.addListener(new ConsumerEventListener(_listenerContainer, EventType.ON_PLAYER_LOGIN, _playerLoginEvent, this));
listenerContainer.addListener(new ConsumerEventListener(listenerContainer, EventType.ON_PLAYER_LOGOUT, playerLogoutEvent, this)); _listenerContainer.addListener(new ConsumerEventListener(_listenerContainer, EventType.ON_PLAYER_LOGOUT, _playerLogoutEvent, this));
} }
/** /**
@@ -110,8 +109,7 @@ public class PremiumManager
*/ */
private void startExpireTask(PlayerInstance player, long delay) private void startExpireTask(PlayerInstance player, long delay)
{ {
final ScheduledFuture<?> task = ThreadPool.schedule(new PremiumExpireTask(player), delay); _expiretasks.put(player.getAccountName(), ThreadPool.schedule(new PremiumExpireTask(player), delay));
expiretasks.put(player.getAccountName(), task);
} }
/** /**
@@ -119,7 +117,7 @@ public class PremiumManager
*/ */
private void stopExpireTask(PlayerInstance player) private void stopExpireTask(PlayerInstance player)
{ {
ScheduledFuture<?> task = expiretasks.remove(player.getAccountName()); ScheduledFuture<?> task = _expiretasks.remove(player.getAccountName());
if (task != null) if (task != null)
{ {
task.cancel(false); task.cancel(false);
@@ -137,7 +135,7 @@ public class PremiumManager
{ {
while (rset.next()) while (rset.next())
{ {
premiumData.put(rset.getString(1), rset.getLong(2)); _premiumData.put(rset.getString(1), rset.getLong(2));
} }
} }
} }
@@ -149,7 +147,7 @@ public class PremiumManager
public long getPremiumExpiration(String accountName) public long getPremiumExpiration(String accountName)
{ {
return premiumData.getOrDefault(accountName, 0L); return _premiumData.getOrDefault(accountName, 0L);
} }
public void addPremiumTime(String accountName, int timeValue, TimeUnit timeUnit) public void addPremiumTime(String accountName, int timeValue, TimeUnit timeUnit)
@@ -174,7 +172,7 @@ public class PremiumManager
} }
// UPDATE CACHE // UPDATE CACHE
premiumData.put(accountName, newPremiumExpiration); _premiumData.put(accountName, newPremiumExpiration);
// UPDATE PlAYER PREMIUMSTATUS // UPDATE PlAYER PREMIUMSTATUS
for (PlayerInstance player : World.getInstance().getPlayers()) for (PlayerInstance player : World.getInstance().getPlayers())
@@ -208,7 +206,7 @@ public class PremiumManager
} }
// UPDATE CACHE // UPDATE CACHE
premiumData.remove(accountName); _premiumData.remove(accountName);
// UPDATE DATABASE // UPDATE DATABASE
try (Connection con = DatabaseFactory.getConnection(); try (Connection con = DatabaseFactory.getConnection();

36
L2J_Mobius_Classic_2.3_SevenSigns/java/org/l2jmobius/gameserver/instancemanager/PremiumManager.java
View File

@@ -51,30 +51,30 @@ public class PremiumManager
class PremiumExpireTask implements Runnable class PremiumExpireTask implements Runnable
{ {
final PlayerInstance player; final PlayerInstance _player;
PremiumExpireTask(PlayerInstance player) PremiumExpireTask(PlayerInstance player)
{ {
this.player = player; _player = player;
} }
@Override @Override
public void run() public void run()
{ {
player.setPremiumStatus(false); _player.setPremiumStatus(false);
} }
} }
// Data Cache // Data Cache
private final Map<String, Long> premiumData = new ConcurrentHashMap<>(); private final Map<String, Long> _premiumData = new ConcurrentHashMap<>();
// expireTasks // expireTasks
private final Map<String, ScheduledFuture<?>> expiretasks = new ConcurrentHashMap<>(); private final Map<String, ScheduledFuture<?>> _expiretasks = new ConcurrentHashMap<>();
// Listeners // Listeners
private final ListenersContainer listenerContainer = Containers.Players(); private final ListenersContainer _listenerContainer = Containers.Players();
private final Consumer<OnPlayerLogin> playerLoginEvent = event -> private final Consumer<OnPlayerLogin> _playerLoginEvent = event ->
{ {
final PlayerInstance player = event.getPlayer(); final PlayerInstance player = event.getPlayer();
final String accountName = player.getAccountName(); final String accountName = player.getAccountName();
@@ -92,16 +92,15 @@ public class PremiumManager
} }
}; };
private final Consumer<OnPlayerLogout> playerLogoutEvent = event -> private final Consumer<OnPlayerLogout> _playerLogoutEvent = event ->
{ {
final PlayerInstance player = event.getPlayer(); stopExpireTask(event.getPlayer());
stopExpireTask(player);
}; };
protected PremiumManager() protected PremiumManager()
{ {
listenerContainer.addListener(new ConsumerEventListener(listenerContainer, EventType.ON_PLAYER_LOGIN, playerLoginEvent, this)); _listenerContainer.addListener(new ConsumerEventListener(_listenerContainer, EventType.ON_PLAYER_LOGIN, _playerLoginEvent, this));
listenerContainer.addListener(new ConsumerEventListener(listenerContainer, EventType.ON_PLAYER_LOGOUT, playerLogoutEvent, this)); _listenerContainer.addListener(new ConsumerEventListener(_listenerContainer, EventType.ON_PLAYER_LOGOUT, _playerLogoutEvent, this));
} }
/** /**
@@ -110,8 +109,7 @@ public class PremiumManager
*/ */
private void startExpireTask(PlayerInstance player, long delay) private void startExpireTask(PlayerInstance player, long delay)
{ {
final ScheduledFuture<?> task = ThreadPool.schedule(new PremiumExpireTask(player), delay); _expiretasks.put(player.getAccountName(), ThreadPool.schedule(new PremiumExpireTask(player), delay));
expiretasks.put(player.getAccountName(), task);
} }
/** /**
@@ -119,7 +117,7 @@ public class PremiumManager
*/ */
private void stopExpireTask(PlayerInstance player) private void stopExpireTask(PlayerInstance player)
{ {
ScheduledFuture<?> task = expiretasks.remove(player.getAccountName()); ScheduledFuture<?> task = _expiretasks.remove(player.getAccountName());
if (task != null) if (task != null)
{ {
task.cancel(false); task.cancel(false);
@@ -137,7 +135,7 @@ public class PremiumManager
{ {
while (rset.next()) while (rset.next())
{ {
premiumData.put(rset.getString(1), rset.getLong(2)); _premiumData.put(rset.getString(1), rset.getLong(2));
} }
} }
} }
@@ -149,7 +147,7 @@ public class PremiumManager
public long getPremiumExpiration(String accountName) public long getPremiumExpiration(String accountName)
{ {
return premiumData.getOrDefault(accountName, 0L); return _premiumData.getOrDefault(accountName, 0L);
} }
public void addPremiumTime(String accountName, int timeValue, TimeUnit timeUnit) public void addPremiumTime(String accountName, int timeValue, TimeUnit timeUnit)
@@ -174,7 +172,7 @@ public class PremiumManager
} }
// UPDATE CACHE // UPDATE CACHE
premiumData.put(accountName, newPremiumExpiration); _premiumData.put(accountName, newPremiumExpiration);
// UPDATE PlAYER PREMIUMSTATUS // UPDATE PlAYER PREMIUMSTATUS
for (PlayerInstance player : World.getInstance().getPlayers()) for (PlayerInstance player : World.getInstance().getPlayers())
@@ -208,7 +206,7 @@ public class PremiumManager
} }
// UPDATE CACHE // UPDATE CACHE
premiumData.remove(accountName); _premiumData.remove(accountName);
// UPDATE DATABASE // UPDATE DATABASE
try (Connection con = DatabaseFactory.getConnection(); try (Connection con = DatabaseFactory.getConnection();

36
L2J_Mobius_Classic_2.4_SecretOfEmpire/java/org/l2jmobius/gameserver/instancemanager/PremiumManager.java
View File

@@ -51,30 +51,30 @@ public class PremiumManager
class PremiumExpireTask implements Runnable class PremiumExpireTask implements Runnable
{ {
final PlayerInstance player; final PlayerInstance _player;
PremiumExpireTask(PlayerInstance player) PremiumExpireTask(PlayerInstance player)
{ {
this.player = player; _player = player;
} }
@Override @Override
public void run() public void run()
{ {
player.setPremiumStatus(false); _player.setPremiumStatus(false);
} }
} }
// Data Cache // Data Cache
private final Map<String, Long> premiumData = new ConcurrentHashMap<>(); private final Map<String, Long> _premiumData = new ConcurrentHashMap<>();
// expireTasks // expireTasks
private final Map<String, ScheduledFuture<?>> expiretasks = new ConcurrentHashMap<>(); private final Map<String, ScheduledFuture<?>> _expiretasks = new ConcurrentHashMap<>();
// Listeners // Listeners
private final ListenersContainer listenerContainer = Containers.Players(); private final ListenersContainer _listenerContainer = Containers.Players();
private final Consumer<OnPlayerLogin> playerLoginEvent = event -> private final Consumer<OnPlayerLogin> _playerLoginEvent = event ->
{ {
final PlayerInstance player = event.getPlayer(); final PlayerInstance player = event.getPlayer();
final String accountName = player.getAccountName(); final String accountName = player.getAccountName();
@@ -92,16 +92,15 @@ public class PremiumManager
} }
}; };
private final Consumer<OnPlayerLogout> playerLogoutEvent = event -> private final Consumer<OnPlayerLogout> _playerLogoutEvent = event ->
{ {
final PlayerInstance player = event.getPlayer(); stopExpireTask(event.getPlayer());
stopExpireTask(player);
}; };
protected PremiumManager() protected PremiumManager()
{ {
listenerContainer.addListener(new ConsumerEventListener(listenerContainer, EventType.ON_PLAYER_LOGIN, playerLoginEvent, this)); _listenerContainer.addListener(new ConsumerEventListener(_listenerContainer, EventType.ON_PLAYER_LOGIN, _playerLoginEvent, this));
listenerContainer.addListener(new ConsumerEventListener(listenerContainer, EventType.ON_PLAYER_LOGOUT, playerLogoutEvent, this)); _listenerContainer.addListener(new ConsumerEventListener(_listenerContainer, EventType.ON_PLAYER_LOGOUT, _playerLogoutEvent, this));
} }
/** /**
@@ -110,8 +109,7 @@ public class PremiumManager
*/ */
private void startExpireTask(PlayerInstance player, long delay) private void startExpireTask(PlayerInstance player, long delay)
{ {
final ScheduledFuture<?> task = ThreadPool.schedule(new PremiumExpireTask(player), delay); _expiretasks.put(player.getAccountName(), ThreadPool.schedule(new PremiumExpireTask(player), delay));
expiretasks.put(player.getAccountName(), task);
} }
/** /**
@@ -119,7 +117,7 @@ public class PremiumManager
*/ */
private void stopExpireTask(PlayerInstance player) private void stopExpireTask(PlayerInstance player)
{ {
ScheduledFuture<?> task = expiretasks.remove(player.getAccountName()); ScheduledFuture<?> task = _expiretasks.remove(player.getAccountName());
if (task != null) if (task != null)
{ {
task.cancel(false); task.cancel(false);
@@ -137,7 +135,7 @@ public class PremiumManager
{ {
while (rset.next()) while (rset.next())
{ {
premiumData.put(rset.getString(1), rset.getLong(2)); _premiumData.put(rset.getString(1), rset.getLong(2));
} }
} }
} }
@@ -149,7 +147,7 @@ public class PremiumManager
public long getPremiumExpiration(String accountName) public long getPremiumExpiration(String accountName)
{ {
return premiumData.getOrDefault(accountName, 0L); return _premiumData.getOrDefault(accountName, 0L);
} }
public void addPremiumTime(String accountName, int timeValue, TimeUnit timeUnit) public void addPremiumTime(String accountName, int timeValue, TimeUnit timeUnit)
@@ -174,7 +172,7 @@ public class PremiumManager
} }
// UPDATE CACHE // UPDATE CACHE
premiumData.put(accountName, newPremiumExpiration); _premiumData.put(accountName, newPremiumExpiration);
// UPDATE PlAYER PREMIUMSTATUS // UPDATE PlAYER PREMIUMSTATUS
for (PlayerInstance player : World.getInstance().getPlayers()) for (PlayerInstance player : World.getInstance().getPlayers())
@@ -208,7 +206,7 @@ public class PremiumManager
} }
// UPDATE CACHE // UPDATE CACHE
premiumData.remove(accountName); _premiumData.remove(accountName);
// UPDATE DATABASE // UPDATE DATABASE
try (Connection con = DatabaseFactory.getConnection(); try (Connection con = DatabaseFactory.getConnection();

36
L2J_Mobius_Classic_3.0_TheKamael/java/org/l2jmobius/gameserver/instancemanager/PremiumManager.java
View File

@@ -51,30 +51,30 @@ public class PremiumManager
class PremiumExpireTask implements Runnable class PremiumExpireTask implements Runnable
{ {
final PlayerInstance player; final PlayerInstance _player;
PremiumExpireTask(PlayerInstance player) PremiumExpireTask(PlayerInstance player)
{ {
this.player = player; _player = player;
} }
@Override @Override
public void run() public void run()
{ {
player.setPremiumStatus(false); _player.setPremiumStatus(false);
} }
} }
// Data Cache // Data Cache
private final Map<String, Long> premiumData = new ConcurrentHashMap<>(); private final Map<String, Long> _premiumData = new ConcurrentHashMap<>();
// expireTasks // expireTasks
private final Map<String, ScheduledFuture<?>> expiretasks = new ConcurrentHashMap<>(); private final Map<String, ScheduledFuture<?>> _expiretasks = new ConcurrentHashMap<>();
// Listeners // Listeners
private final ListenersContainer listenerContainer = Containers.Players(); private final ListenersContainer _listenerContainer = Containers.Players();
private final Consumer<OnPlayerLogin> playerLoginEvent = event -> private final Consumer<OnPlayerLogin> _playerLoginEvent = event ->
{ {
final PlayerInstance player = event.getPlayer(); final PlayerInstance player = event.getPlayer();
final String accountName = player.getAccountName(); final String accountName = player.getAccountName();
@@ -92,16 +92,15 @@ public class PremiumManager
} }
}; };
private final Consumer<OnPlayerLogout> playerLogoutEvent = event -> private final Consumer<OnPlayerLogout> _playerLogoutEvent = event ->
{ {
final PlayerInstance player = event.getPlayer(); stopExpireTask(event.getPlayer());
stopExpireTask(player);
}; };
protected PremiumManager() protected PremiumManager()
{ {
listenerContainer.addListener(new ConsumerEventListener(listenerContainer, EventType.ON_PLAYER_LOGIN, playerLoginEvent, this)); _listenerContainer.addListener(new ConsumerEventListener(_listenerContainer, EventType.ON_PLAYER_LOGIN, _playerLoginEvent, this));
listenerContainer.addListener(new ConsumerEventListener(listenerContainer, EventType.ON_PLAYER_LOGOUT, playerLogoutEvent, this)); _listenerContainer.addListener(new ConsumerEventListener(_listenerContainer, EventType.ON_PLAYER_LOGOUT, _playerLogoutEvent, this));
} }
/** /**
@@ -110,8 +109,7 @@ public class PremiumManager
*/ */
private void startExpireTask(PlayerInstance player, long delay) private void startExpireTask(PlayerInstance player, long delay)
{ {
final ScheduledFuture<?> task = ThreadPool.schedule(new PremiumExpireTask(player), delay); _expiretasks.put(player.getAccountName(), ThreadPool.schedule(new PremiumExpireTask(player), delay));
expiretasks.put(player.getAccountName(), task);
} }
/** /**
@@ -119,7 +117,7 @@ public class PremiumManager
*/ */
private void stopExpireTask(PlayerInstance player) private void stopExpireTask(PlayerInstance player)
{ {
ScheduledFuture<?> task = expiretasks.remove(player.getAccountName()); ScheduledFuture<?> task = _expiretasks.remove(player.getAccountName());
if (task != null) if (task != null)
{ {
task.cancel(false); task.cancel(false);
@@ -137,7 +135,7 @@ public class PremiumManager
{ {
while (rset.next()) while (rset.next())
{ {
premiumData.put(rset.getString(1), rset.getLong(2)); _premiumData.put(rset.getString(1), rset.getLong(2));
} }
} }
} }
@@ -149,7 +147,7 @@ public class PremiumManager
public long getPremiumExpiration(String accountName) public long getPremiumExpiration(String accountName)
{ {
return premiumData.getOrDefault(accountName, 0L); return _premiumData.getOrDefault(accountName, 0L);
} }
public void addPremiumTime(String accountName, int timeValue, TimeUnit timeUnit) public void addPremiumTime(String accountName, int timeValue, TimeUnit timeUnit)
@@ -174,7 +172,7 @@ public class PremiumManager
} }
// UPDATE CACHE // UPDATE CACHE
premiumData.put(accountName, newPremiumExpiration); _premiumData.put(accountName, newPremiumExpiration);
// UPDATE PlAYER PREMIUMSTATUS // UPDATE PlAYER PREMIUMSTATUS
for (PlayerInstance player : World.getInstance().getPlayers()) for (PlayerInstance player : World.getInstance().getPlayers())
@@ -208,7 +206,7 @@ public class PremiumManager
} }
// UPDATE CACHE // UPDATE CACHE
premiumData.remove(accountName); _premiumData.remove(accountName);
// UPDATE DATABASE // UPDATE DATABASE
try (Connection con = DatabaseFactory.getConnection(); try (Connection con = DatabaseFactory.getConnection();

36
L2J_Mobius_Classic_Interlude/java/org/l2jmobius/gameserver/instancemanager/PremiumManager.java
View File

@@ -51,30 +51,30 @@ public class PremiumManager
class PremiumExpireTask implements Runnable class PremiumExpireTask implements Runnable
{ {
final PlayerInstance player; final PlayerInstance _player;
PremiumExpireTask(PlayerInstance player) PremiumExpireTask(PlayerInstance player)
{ {
this.player = player; _player = player;
} }
@Override @Override
public void run() public void run()
{ {
player.setPremiumStatus(false); _player.setPremiumStatus(false);
} }
} }
// Data Cache // Data Cache
private final Map<String, Long> premiumData = new ConcurrentHashMap<>(); private final Map<String, Long> _premiumData = new ConcurrentHashMap<>();
// expireTasks // expireTasks
private final Map<String, ScheduledFuture<?>> expiretasks = new ConcurrentHashMap<>(); private final Map<String, ScheduledFuture<?>> _expiretasks = new ConcurrentHashMap<>();
// Listeners // Listeners
private final ListenersContainer listenerContainer = Containers.Players(); private final ListenersContainer _listenerContainer = Containers.Players();
private final Consumer<OnPlayerLogin> playerLoginEvent = event -> private final Consumer<OnPlayerLogin> _playerLoginEvent = event ->
{ {
final PlayerInstance player = event.getPlayer(); final PlayerInstance player = event.getPlayer();
final String accountName = player.getAccountName(); final String accountName = player.getAccountName();
@@ -92,16 +92,15 @@ public class PremiumManager
} }
}; };
private final Consumer<OnPlayerLogout> playerLogoutEvent = event -> private final Consumer<OnPlayerLogout> _playerLogoutEvent = event ->
{ {
final PlayerInstance player = event.getPlayer(); stopExpireTask(event.getPlayer());
stopExpireTask(player);
}; };
protected PremiumManager() protected PremiumManager()
{ {
listenerContainer.addListener(new ConsumerEventListener(listenerContainer, EventType.ON_PLAYER_LOGIN, playerLoginEvent, this)); _listenerContainer.addListener(new ConsumerEventListener(_listenerContainer, EventType.ON_PLAYER_LOGIN, _playerLoginEvent, this));
listenerContainer.addListener(new ConsumerEventListener(listenerContainer, EventType.ON_PLAYER_LOGOUT, playerLogoutEvent, this)); _listenerContainer.addListener(new ConsumerEventListener(_listenerContainer, EventType.ON_PLAYER_LOGOUT, _playerLogoutEvent, this));
} }
/** /**
@@ -110,8 +109,7 @@ public class PremiumManager
*/ */
private void startExpireTask(PlayerInstance player, long delay) private void startExpireTask(PlayerInstance player, long delay)
{ {
final ScheduledFuture<?> task = ThreadPool.schedule(new PremiumExpireTask(player), delay); _expiretasks.put(player.getAccountName(), ThreadPool.schedule(new PremiumExpireTask(player), delay));
expiretasks.put(player.getAccountName(), task);
} }
/** /**
@@ -119,7 +117,7 @@ public class PremiumManager
*/ */
private void stopExpireTask(PlayerInstance player) private void stopExpireTask(PlayerInstance player)
{ {
ScheduledFuture<?> task = expiretasks.remove(player.getAccountName()); ScheduledFuture<?> task = _expiretasks.remove(player.getAccountName());
if (task != null) if (task != null)
{ {
task.cancel(false); task.cancel(false);
@@ -137,7 +135,7 @@ public class PremiumManager
{ {
while (rset.next()) while (rset.next())
{ {
premiumData.put(rset.getString(1), rset.getLong(2)); _premiumData.put(rset.getString(1), rset.getLong(2));
} }
} }
} }
@@ -149,7 +147,7 @@ public class PremiumManager
public long getPremiumExpiration(String accountName) public long getPremiumExpiration(String accountName)
{ {
return premiumData.getOrDefault(accountName, 0L); return _premiumData.getOrDefault(accountName, 0L);
} }
public void addPremiumTime(String accountName, int timeValue, TimeUnit timeUnit) public void addPremiumTime(String accountName, int timeValue, TimeUnit timeUnit)
@@ -174,7 +172,7 @@ public class PremiumManager
} }
// UPDATE CACHE // UPDATE CACHE
premiumData.put(accountName, newPremiumExpiration); _premiumData.put(accountName, newPremiumExpiration);
// UPDATE PlAYER PREMIUMSTATUS // UPDATE PlAYER PREMIUMSTATUS
for (PlayerInstance player : World.getInstance().getPlayers()) for (PlayerInstance player : World.getInstance().getPlayers())
@@ -208,7 +206,7 @@ public class PremiumManager
} }
// UPDATE CACHE // UPDATE CACHE
premiumData.remove(accountName); _premiumData.remove(accountName);
// UPDATE DATABASE // UPDATE DATABASE
try (Connection con = DatabaseFactory.getConnection(); try (Connection con = DatabaseFactory.getConnection();