src/main/java/com/l2jserver/gameserver/model/entity/TvTManager.java - develop - tofu/l2interlude

src/main/java/com/l2jserver/gameserver/model/entity/TvTManager.java
221 строка7 KB
Zoey76
01 янв 2025, 07:57
01 янв 2025, 07:5716130a5
/*
 * Copyright © 2004-2025 L2J Server
 * 
 * This file is part of L2J Server.
 * 
 * L2J Server is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 * 
 * L2J Server is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
 * General Public License for more details.
 * 
 * You should have received a copy of the GNU General Public License
 * along with this program. If not, see <http://www.gnu.org/licenses/>.
 */
package com.l2jserver.gameserver.model.entity;

import static com.l2jserver.gameserver.config.Configuration.tvt;
import static java.util.concurrent.TimeUnit.MILLISECONDS;

import java.util.Calendar;
import java.util.concurrent.ScheduledFuture;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.l2jserver.gameserver.ThreadPoolManager;
import com.l2jserver.gameserver.util.Broadcast;

/**
 * TVT Manager.
 * @author HorridoJoho
 */
public class TvTManager {
	
	private static final Logger LOG = LoggerFactory.getLogger(TvTManager.class);
	
	private TvTStartTask _task;
	
	protected TvTManager() {
		if (tvt().enabled()) {
			TvTEvent.init();
			
			scheduleEventStart();
			LOG.info("Started.");
		} else {
			LOG.info("Engine is disabled.");
		}
	}
	
	public static TvTManager getInstance() {
		return SingletonHolder.INSTANCE;
	}
	
	public void scheduleEventStart() {
		try {
			Calendar currentTime = Calendar.getInstance();
			Calendar nextStartTime = null;
			for (String timeOfDay : tvt().getInterval()) {
				// Creating a Calendar object from the specified interval value
				var testStartTime = Calendar.getInstance();
				testStartTime.setLenient(true);
				String[] splitTimeOfDay = timeOfDay.split(":");
				testStartTime.set(Calendar.HOUR_OF_DAY, Integer.parseInt(splitTimeOfDay[0]));
				testStartTime.set(Calendar.MINUTE, Integer.parseInt(splitTimeOfDay[1]));
				// If the date is in the past, make it the next day (Example: Checking for "1:00", when the time is 23:57.)
				if (testStartTime.getTimeInMillis() < currentTime.getTimeInMillis()) {
					testStartTime.add(Calendar.DAY_OF_MONTH, 1);
				}
				// Check for the test date to be the minimum (smallest in the specified list)
				if ((nextStartTime == null) || (testStartTime.getTimeInMillis() < nextStartTime.getTimeInMillis())) {
					nextStartTime = testStartTime;
				}
			}
			if (nextStartTime != null) {
				_task = new TvTStartTask(nextStartTime.getTimeInMillis());
				ThreadPoolManager.getInstance().executeGeneral(_task);
			}
		} catch (Exception ex) {
			LOG.warn("There has been an error figuring out a start time. Check TvTEventInterval in config file.", ex);
		}
	}
	
	/**
	 * Method to start participation
	 */
	public void startReg() {
		if (!TvTEvent.startParticipation()) {
			Broadcast.toAllOnlinePlayers("TvT Event: Event was cancelled.");
			LOG.warn("There has been an error spawning event NPC for participation.");
			
			scheduleEventStart();
		} else {
			Broadcast.toAllOnlinePlayers("TvT Event: Registration opened for " + tvt().getParticipationTime() + " minute(s).");
			
			// schedule registration end
			_task.setStartTime(System.currentTimeMillis() + (60000L * tvt().getParticipationTime()));
			ThreadPoolManager.getInstance().executeGeneral(_task);
		}
	}
	
	/**
	 * Method to start the fight
	 */
	public void startEvent() {
		if (!TvTEvent.startFight()) {
			Broadcast.toAllOnlinePlayers("TvT Event: Event cancelled due to lack of Participation.");
			LOG.info("Lack of registration, abort event.");
			
			scheduleEventStart();
		} else {
			TvTEvent.sysMsgToAllParticipants("TvT Event: Teleporting participants to an arena in " + MILLISECONDS.toSeconds(tvt().getStartLeaveTeleportDelay()) + " second(s).");
			_task.setStartTime(System.currentTimeMillis() + (60000L * tvt().getRunningTime()));
			ThreadPoolManager.getInstance().executeGeneral(_task);
		}
	}
	
	/**
	 * Method to end the event and reward
	 */
	public void endEvent() {
		Broadcast.toAllOnlinePlayers(TvTEvent.calculateRewards());
		TvTEvent.sysMsgToAllParticipants("TvT Event: Teleporting back to the registration npc in " + MILLISECONDS.toSeconds(tvt().getStartLeaveTeleportDelay()) + " second(s).");
		TvTEvent.stopFight();
		
		scheduleEventStart();
	}
	
	public void skipDelay() {
		if (_task.nextRun.cancel(false)) {
			_task.setStartTime(System.currentTimeMillis());
			ThreadPoolManager.getInstance().executeGeneral(_task);
		}
	}
	
	/**
	 * Class for TvT cycles
	 */
	class TvTStartTask implements Runnable {
		private long _startTime;
		public ScheduledFuture<?> nextRun;
		
		public TvTStartTask(long startTime) {
			_startTime = startTime;
		}
		
		public void setStartTime(long startTime) {
			_startTime = startTime;
		}
		
		@Override
		public void run() {
			int delay = (int) Math.round((_startTime - System.currentTimeMillis()) / 1000.0);
			
			if (delay > 0) {
				announce(delay);
			}
			
			int nextMsg = 0;
			if (delay > 3600) {
				nextMsg = delay - 3600;
			} else if (delay > 1800) {
				nextMsg = delay - 1800;
			} else if (delay > 900) {
				nextMsg = delay - 900;
			} else if (delay > 600) {
				nextMsg = delay - 600;
			} else if (delay > 300) {
				nextMsg = delay - 300;
			} else if (delay > 60) {
				nextMsg = delay - 60;
			} else if (delay > 5) {
				nextMsg = delay - 5;
			} else if (delay > 0) {
				nextMsg = delay;
			} else {
				// start
				if (TvTEvent.isInactive()) {
					startReg();
				} else if (TvTEvent.isParticipating()) {
					startEvent();
				} else {
					endEvent();
				}
			}
			
			if (delay > 0) {
				nextRun = ThreadPoolManager.getInstance().scheduleGeneral(this, nextMsg * 1000);
			}
		}
		
		private void announce(long time) {
			if ((time >= 3600) && ((time % 3600) == 0)) {
				if (TvTEvent.isParticipating()) {
					Broadcast.toAllOnlinePlayers("TvT Event: " + (time / 60 / 60) + " hour(s) until registration is closed!");
				} else if (TvTEvent.isStarted()) {
					TvTEvent.sysMsgToAllParticipants("TvT Event: " + (time / 60 / 60) + " hour(s) until event is finished!");
				}
			} else if (time >= 60) {
				if (TvTEvent.isParticipating()) {
					Broadcast.toAllOnlinePlayers("TvT Event: " + (time / 60) + " minute(s) until registration is closed!");
				} else if (TvTEvent.isStarted()) {
					TvTEvent.sysMsgToAllParticipants("TvT Event: " + (time / 60) + " minute(s) until the event is finished!");
				}
			} else {
				if (TvTEvent.isParticipating()) {
					Broadcast.toAllOnlinePlayers("TvT Event: " + time + " second(s) until registration is closed!");
				} else if (TvTEvent.isStarted()) {
					TvTEvent.sysMsgToAllParticipants("TvT Event: " + time + " second(s) until the event is finished!");
				}
			}
		}
	}
	
	private static class SingletonHolder {
		protected static final TvTManager INSTANCE = new TvTManager();
	}
}