Evento Top Pvp

[Swarlog]

Código [Seleccionar] Expandir

/*
 * This program 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.
 * 
 * This program 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.l2jfrozen.gameserver.model.entity.event.Topvp;
import java.util.Collection;
import java.util.logging.Level;

import com.l2jfrozen.Config;
import com.l2jfrozen.gameserver.model.actor.instance.L2ItemInstance;
import com.l2jfrozen.gameserver.model.actor.instance.L2PcInstance;
import com.l2jfrozen.gameserver.model.entity.Announcements;

import java.util.Calendar;
import java.util.concurrent.ScheduledFuture;
import java.util.logging.Logger;
import com.l2jfrozen.gameserver.network.serverpackets.SystemMessage;

import com.l2jfrozen.gameserver.idfactory.IdFactory;
import com.l2jfrozen.gameserver.network.SystemMessageId;

import com.l2jfrozen.gameserver.network.serverpackets.NpcHtmlMessage;
import com.l2jfrozen.gameserver.thread.ThreadPoolManager;

import com.l2jfrozen.gameserver.model.L2World;
import com.l2jfrozen.util.CloseUtil;
import com.l2jfrozen.util.database.L2DatabaseFactory;


import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;


/**
 * @author Vampkiller
 */
public class TopPvp
{
	protected static final Logger _log = Logger.getLogger(TopPvp.class.getName());
	private static int winner_id;
	private static String winner_name;
	private static int winner_kills;
	
	/** Task for event cycles<br> */
	private TopPvpStartTask _task;
	
	/**
	 * New instance only by getInstance()<br>
	 */
	public TopPvp()
	{
		if (Config.TOP_PVP_ENABLE)
		{			
			this.scheduleEventStart();
			_log.info("TopPvpEventEngine: Started.");
		}
		else
		{
			_log.info("TopPvpEventEngine: Engine is disabled.");
		}
	}
	
	/**
	 * Initialize new/Returns the one and only instance<br><br>
	 *
	 * @return TopPvp<br>
	 */
	public static TopPvp getInstance()
	{
		return SingletonHolder._instance;
	}
	
	/**
	 * Starts TopPvpStartTask
	 */
	@SuppressWarnings("null")
	public void scheduleEventStart()
	{
		try
		{
			Calendar currentTime = Calendar.getInstance();
			Calendar nextStartTime = null;
			Calendar testStartTime = null;
			//String timeOfDay = "23:00";

				// Creating a Calendar object from the specified interval value
				testStartTime = Calendar.getInstance();
				testStartTime.setLenient(true);
				String[] splitTimeOfDay = (Config.TOP_PVP_TIME).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()+60000)
				{
					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;
				}
			System.out.printf ( "Top PvP Event: Schedule next start\n");
			_task = new TopPvpStartTask(nextStartTime.getTimeInMillis());
			ThreadPoolManager.getInstance().executeTask(_task);
		}
		catch (Exception e)
		{
			_log.warning("TopPvpEventEngine[TopPvp.scheduleEventStart()]: Error figuring out a start time. Check TopPvpEventInterval in config file.");
		}
	}
	
	
	/**
	 * Method to start the fight
	 */
	public void startReward()
	{
		Connection con = null;
		if (Config.TOP_PVP_TAKE_REWARD_FROM_PREVIOUS){
			System.out.printf ( "Top PvP Event: Delete items\n");
			try
			{
				con = L2DatabaseFactory.getInstance().getConnection();
				PreparedStatement statement = con.prepareStatement("SELECT * FROM items WHERE item_id = "+Config.TOP_PVP_REWARD_ID);
				ResultSet rset = statement.executeQuery();
				while (rset.next())
				{
					Collection<L2PcInstance> pls = L2World.getInstance().getAllPlayers();
					{
						for (L2PcInstance onlinePlayer : pls)
							if (onlinePlayer.isOnline() == 1 && onlinePlayer.getObjectId()==rset.getInt("owner_Id")){
								//onlinePlayer.getInventory().destroyItemByItemId("Consume", Config.TOP_PVP_REWARD_ID, Config.TOP_PVP_REWARD_AMOUNT, onlinePlayer, onlinePlayer);
								onlinePlayer.destroyItemByItemId("TopPvp", Config.TOP_PVP_REWARD_ID, Config.TOP_PVP_REWARD_AMOUNT, onlinePlayer, false);
								/*SystemMessage sm = new SystemMessage(SystemMessageId.S1_DISAPPEARED);
								sm.addItemName(rset.getInt("item_id"));*/
								SystemMessage sm = new SystemMessage(SystemMessageId.DISSAPEARED_ITEM);
								sm.addItemName(Config.TOP_PVP_REWARD_ID);
								sm.addNumber(Config.TOP_PVP_REWARD_AMOUNT);
								onlinePlayer.sendPacket(sm);
							}
					}
				}
				
				statement = con.prepareStatement("DELETE FROM items WHERE item_id = "+Config.TOP_PVP_REWARD_ID);
				statement.execute();
				rset.close();
				statement.close();
			}
			catch (SQLException e)
			{
				if(_log.isLoggable(Level.SEVERE))
					_log.log(Level.SEVERE, "SQL exception while Delete previous reward DailyPvp for characters", e);
			}
			finally
			{
				CloseUtil.close(con);
			}
		}	
		System.out.printf ( "Top PvP Event: Calculate winners\n");
		boolean rewarded = false;
		
		String list = "";
		con = null;
		try
		{
			con = L2DatabaseFactory.getInstance().getConnection();
			PreparedStatement statement = con.prepareStatement("SELECT * FROM characters WHERE DailyPvp>0 AND accesslevel=0 AND punish_level=0 order by DailyPvp desc, pvpkills desc limit " + Integer.toString(Config.TOP_PVP_LIST_LENGTH));
			ResultSet rset = statement.executeQuery();
			
			if (rset.next()){
				int count = 1;
				String color_text;
				winner_id = rset.getInt("obj_Id");
				winner_name = rset.getString("char_name");
				winner_kills = rset.getInt("DailyPvp");
				color_text = "<font color =\"LEVEL\">";
					
				list += "<tr><td><center>"+ color_text + count + "</font></center></td><td><center>" + color_text +winner_name +"</font></center></td><td><center>"+ color_text + winner_kills + "</font></center></td><td><center>"+ color_text + rset.getInt("pvpkills") + "</font></center></td></tr>";
				list += "<tr><td></td><td></td><td></td></tr>";
				while (rset.next())
				{	
					count++;		
					color_text = "<font color =\"FFFFFF\">";
					list += "<tr><td><center>"+ color_text + count + "</font></center></td><td><center>" + color_text +rset.getString("char_name") +"</font></center></td><td><center>"+ color_text + rset.getInt("DailyPvp") + "</font></center></td><td><center>"+ color_text + rset.getInt("pvpkills") + "</font></center></td></tr>";
				}
			}
			else 
				list = "<tr><td><center>-</center></td><td><center>-</center></td><td><center>-</center></td></tr>";
			
			rset.close();
			statement.close();
		}
		catch (SQLException e)
		{
			if(_log.isLoggable(Level.SEVERE))
				_log.log(Level.SEVERE, "SQL exception while Update DailyPvp count for characters", e);
		}
		finally
		{
			CloseUtil.close(con);
		}
		
		
		//give reward to online and inform about the results
		System.out.printf ( "Top PvP Event: Reset-inform-reward\n");
		Collection<L2PcInstance> pls = L2World.getInstance().getAllPlayers();
		{
			for (L2PcInstance onlinePlayer : pls){
				//Announcements.getInstance().announceToAll(onlinePlayer.getName());
				//if (onlinePlayer.isOnline() == 1 && onlinePlayer.getPunishLevel() == 0 && !onlinePlayer.isGM())
				if (onlinePlayer.isOnline() == 1){
					onlinePlayer.setDailyPvp(0);
					
					if(onlinePlayer.getObjectId() == winner_id ) {
						//onlinePlayer.getInventory().addItem("TopPvP Reward", Config.TOP_PVP_REWARD_ID, Config.TOP_PVP_REWARD_AMOUNT, onlinePlayer, onlinePlayer);
						onlinePlayer.addItem("TopPvP Reward",Config.TOP_PVP_REWARD_ID,Config.TOP_PVP_REWARD_AMOUNT,onlinePlayer,false);
						/*SystemMessage systemMessage2 = new SystemMessage(SystemMessageId.EARNED_ITEM);
						systemMessage2.addItemName(Config.TOP_PVP_REWARD_ID);*/
						SystemMessage systemMessage2 = new SystemMessage(SystemMessageId.EARNED_S2_S1_S);
						systemMessage2.addItemName(Config.TOP_PVP_REWARD_ID);
						systemMessage2.addNumber(Config.TOP_PVP_REWARD_AMOUNT);
						onlinePlayer.sendPacket(systemMessage2);
						rewarded = true;
					}
					NpcHtmlMessage notice = new NpcHtmlMessage(1);
					notice.setFile("data/html/TopPvp.htm");
					notice.replace("%n%", Integer.toString(Config.TOP_PVP_LIST_LENGTH));
					notice.replace("%list%", list);
					onlinePlayer.sendPacket(notice);
					}
			}
		}
		
		
		//give reward to offline 
		if (!rewarded){
			L2ItemInstance item = new L2ItemInstance(IdFactory.getInstance().getNextId(), Config.TOP_PVP_REWARD_ID);
			con = null;
			try
			{
				con = L2DatabaseFactory.getInstance().getConnection();
				PreparedStatement statement = con.prepareStatement("INSERT INTO items VALUES (?, ?, "+Config.TOP_PVP_REWARD_ID+", "+Config.TOP_PVP_REWARD_AMOUNT+", 0, 'INVENTORY', 1, 0,0,NULL, 0, 0, -1)");
				statement.setInt(1, winner_id);
				statement.setInt(2, item.getObjectId());
				statement.execute();
				statement.close();
			}
			catch (SQLException e)
			{
				if(_log.isLoggable(Level.SEVERE))
					_log.log(Level.SEVERE, "SQL exception while Insert reward DailyPvp for characters", e);
			}
			finally
			{
				CloseUtil.close(con);
			}
		}
				
		
		con = null;
		try
		{
			con = L2DatabaseFactory.getInstance().getConnection();
			PreparedStatement statement = con.prepareStatement("UPDATE characters SET DailyPvp=0");
			statement.execute();
			statement.close();
		}
		catch (SQLException e)
		{
			//if(_log.isLoggable(Level.SEVERE))
			_log.log(Level.WARNING, "SQL exception while Update DailyPvp count for characters "+ e.getMessage(), e);
		}
		finally
		{
			CloseUtil.close(con);
		}
		
	}
	
	
	public void skipDelay()
	{
		if (_task.nextRun.cancel(false))
		{
			_task.setStartTime(System.currentTimeMillis());
			ThreadPoolManager.getInstance().executeTask(_task);
		}
	}
	
	/**
	 * Class for TopPvp cycles
	 */
	class TopPvpStartTask implements Runnable
	{
		private long _startTime;
		public ScheduledFuture<?> nextRun;
		
		public TopPvpStartTask(long startTime)
		{
			_startTime = startTime;
		}
		
		public void setStartTime(long startTime)
		{
			_startTime = startTime;
		}
		
		/**
		 * @see java.lang.Runnable#run()
		 */
		@Override
		public void run()
		{
			int delay = (int) Math.round((_startTime - System.currentTimeMillis()) / 1000.0);
			
			if (delay > 0)
			{
				this.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
			{

				TopPvp.this.startReward();
				TopPvp.this.scheduleEventStart();

			}
			
			if (delay > 0)
			{
				nextRun = ThreadPoolManager.getInstance().scheduleGeneral(this, nextMsg * 1000);
			}
		}
		
		private void announce(long time)
		{
			if (time >= 3600 && time % 3600 == 0)
			{
				Announcements.getInstance().announceToAll("Top PvP Event: " + (time / 60 / 60) + " hour(s) until event is finished!");
			}
			else if (time >= 60)
			{
				Announcements.getInstance().announceToAll("Top PvP Event: " + (time / 60) + " minute(s) until the event is finished!");
			}
			else
			{
				Announcements.getInstance().announceToAll("Top PvP Event: " + time + " second(s) until the event is finished!");
			}
		}
	}
	

	private static class SingletonHolder
	{
		protected static final TopPvp _instance = new TopPvp();
	}
}