123 lines
5.4 KiB
Java
123 lines
5.4 KiB
Java
package com.graywolf336.jail;
|
|
|
|
import com.graywolf336.jail.beans.Jail;
|
|
import com.graywolf336.jail.beans.Prisoner;
|
|
import com.graywolf336.jail.enums.Lang;
|
|
import com.graywolf336.jail.enums.Settings;
|
|
import com.graywolf336.jail.events.PrisonerTimeChangeEvent;
|
|
import org.bukkit.entity.Player;
|
|
|
|
import javax.swing.*;
|
|
|
|
/**
|
|
* Contains all the logic for counting down the time of the prisoners time.
|
|
*
|
|
* @author graywolf336
|
|
* @version 3.0.0
|
|
* @since 2.x.x
|
|
*/
|
|
public class JailTimer {
|
|
private final JailMain pl;
|
|
private Timer timer;
|
|
private Long lastTime;
|
|
private Long afkTime = 0L;
|
|
|
|
protected JailTimer(JailMain plugin) {
|
|
this.pl = plugin;
|
|
try {
|
|
afkTime = Util.getTime(pl.getConfig().getString(Settings.MAXAFKTIME.getPath()));
|
|
} catch (Exception e) {
|
|
pl.getLogger().severe("Error while processing the max afk time: " + e.getMessage());
|
|
}
|
|
|
|
this.lastTime = System.currentTimeMillis();
|
|
if (pl.getConfig().getBoolean(Settings.USEBUKKITTIMER.getPath())) {
|
|
pl.getLogger().info("Using the Bukkit Scheduler.");
|
|
pl.getServer().getScheduler().runTaskTimerAsynchronously(pl, new TimeEvent(), 200, 200);
|
|
} else {
|
|
pl.getLogger().info("Using the Java Timer.");
|
|
timer = new Timer(10000, event -> pl.getServer().getScheduler().scheduleSyncDelayedTask(pl, new TimeEvent()));
|
|
|
|
timer.start();
|
|
}
|
|
|
|
//Save all the jail information every minute, not every 10 seconds
|
|
pl.getServer().getScheduler().runTaskTimerAsynchronously(pl, () -> {
|
|
for (Jail j : pl.getJailManager().getJails()) {
|
|
pl.getJailIO().saveJail(j);
|
|
}
|
|
}, 1200L, 1200L);
|
|
}
|
|
|
|
/**
|
|
* Returns the instance of this timer.
|
|
*
|
|
* @return the {@link Timer} instance
|
|
*/
|
|
public Timer getTimer() {
|
|
return this.timer;
|
|
}
|
|
|
|
private class TimeEvent implements Runnable {
|
|
public void run() {
|
|
long timePassed = System.currentTimeMillis() - lastTime;
|
|
lastTime = System.currentTimeMillis();
|
|
|
|
for (Jail j : pl.getJailManager().getJails()) {
|
|
for (Prisoner p : j.getAllPrisoners().values()) {
|
|
//only execute this code if the prisoner's time is more than 0 milliseconds
|
|
//and they don't have any offline pending things
|
|
if (p.getRemainingTime() > 0 && !p.isOfflinePending()) {
|
|
final Player player = pl.getServer().getPlayer(p.getUUID());
|
|
|
|
//Check if the player is offline
|
|
if (player == null) {
|
|
//if they are offline AND the config has counting down the time
|
|
//while the prisoner is offline, then let's do it
|
|
if (pl.getConfig().getBoolean(Settings.COUNTDOWNTIMEOFFLINE.getPath())) {
|
|
//Set their remaining time but if it is less than zero, set it to zero
|
|
long before = p.getRemainingTime();
|
|
long after = Math.max(0, p.getRemainingTime() - timePassed);
|
|
|
|
PrisonerTimeChangeEvent event = new PrisonerTimeChangeEvent(j, j.getCellPrisonerIsIn(p.getUUID()), p, player, before, after);
|
|
pl.getServer().getPluginManager().callEvent(event);
|
|
|
|
if (!event.isCancelled()) {
|
|
after = event.getTimeAfterChange();
|
|
p.setRemainingTime(after);
|
|
if (p.getRemainingTime() == 0) pl.getPrisonerManager().schedulePrisonerRelease(p);
|
|
}
|
|
}
|
|
} else {
|
|
if (afkTime > 0) {
|
|
p.setAFKTime(p.getAFKTime() + timePassed);
|
|
if (p.getAFKTime() > afkTime) {
|
|
p.setAFKTime(0);
|
|
//This is so we kick players on the main thread
|
|
//instead of on the async thread(s), as spigot
|
|
//has a protection against this enabled.
|
|
pl.getServer().getScheduler().scheduleSyncDelayedTask(pl, () -> player.kickPlayer(Lang.AFKKICKMESSAGE.get()));
|
|
}
|
|
}
|
|
|
|
//The prisoner isn't offline, so let's count down
|
|
//Set their remaining time but if it is less than zero, set it to zero
|
|
long before = p.getRemainingTime();
|
|
long after = Math.max(0, p.getRemainingTime() - timePassed);
|
|
|
|
PrisonerTimeChangeEvent event = new PrisonerTimeChangeEvent(j, j.getCellPrisonerIsIn(p.getUUID()), p, player, before, after);
|
|
pl.getServer().getPluginManager().callEvent(event);
|
|
|
|
if (!event.isCancelled()) {
|
|
after = event.getTimeAfterChange();
|
|
p.setRemainingTime(after);
|
|
if (p.getRemainingTime() == 0) pl.getPrisonerManager().schedulePrisonerRelease(p);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|