package l2f.gameserver.model.entity.olympiad;
import l2f.commons.threading.RunnableImpl;
import l2f.gameserver.Config;
import l2f.gameserver.ThreadPoolManager;
import l2f.gameserver.cache.Msg;
import l2f.gameserver.network.serverpackets.SystemMessage;
import l2f.gameserver.utils.Log;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.util.concurrent.ScheduledFuture;
public class OlympiadGameTask extends RunnableImpl
{
private static final Logger _log = LoggerFactory.getLogger (OlympiadGameTask.class);
private OlympiadGame _game;
private BattleStatus _status;
private int _count;
private long _time;
private boolean _terminated = false;
public boolean isTerminated ()
{
return _terminated;
}
public BattleStatus getStatus ()
{
return _status;
}
public int getCount ()
{
return _count;
}
public OlympiadGame getGame ()
{
return _game;
}
public long getTime ()
{
return _count;
}
public ScheduledFuture <?> shedule ()
{
return ThreadPoolManager.getInstance (). schedule (this, _time);
}
public OlympiadGameTask (OlympiadGame game, BattleStatus status, int count, long time)
{
_game = game;
_status = status;
_count = count;
_time = time;
}
@override
public void runImpl () throws Exception
{
if (_game == null || _terminated)
return;
OlympiadGameTask task = null;
int gameId = _game.getId ();
try
{
if (! Olympiad.inCompPeriod ())
return;
// Interrupt the game if one of the players is not online, and the game is not interrupted
if (! _game.checkPlayersOnline () && _status! = BattleStatus.ValidateWinner && _status! = BattleStatus.Ending)
{
Log.add ("Player is offline for game" + gameId + ", status:" + _status, "olympiad");
_game.endGame (1000, true);
return;
}
switch (_status)
{
case Begining:
{
_game.broadcastPacket (new SystemMessage (SystemMessage.YOU_WILL_ENTER_THE_OLYMPIAD_STADIUM_IN_S1_SECOND_S) .addNumber (Config.OLYMPIAD_BEGIN_TIME), true, false);
task = new OlympiadGameTask (_game, BattleStatus.Begin_Countdown, Config.OLYMPIAD_BEGIN_TIME / 2, (Config.OLYMPIAD_BEGIN_TIME / 2) * 1000);
break;
}
case Begin_Countdown:
{
_game.broadcastPacket (new SystemMessage (SystemMessage.YOU_WILL_ENTER_THE_OLYMPIAD_STADIUM_IN_S1_SECOND_S) .addNumber (_count), true, false);
if (_count == 60)
task = new OlympiadGameTask (_game, BattleStatus.Begin_Countdown, 30, 30000);
else if (_count == 30)
task = new OlympiadGameTask (_game, BattleStatus.Begin_Countdown, 15, 15000);
else if (_count == 15)
task = new OlympiadGameTask (_game, BattleStatus.Begin_Countdown, 5, 10000);
else if (_count <6 && _count> 1)
task = new OlympiadGameTask (_game, BattleStatus.Begin_Countdown, _count - 1, 1000);
else if (_count == 1)
task = new OlympiadGameTask (_game, BattleStatus.PortPlayers, 0, 1000);
break;
}
case PortPlayers:
{
_game.portPlayersToArena ();
_game.managerShout ();
task = new OlympiadGameTask (_game, BattleStatus.Started, 60, 1000);
break;
}
case Started:
{
if (_count == 60)
{
_game.setState (1);
_game.preparePlayers ();
_game.addBuffers ();
_game.restorePreparePlayers ();
}
_game.broadcastPacket (new SystemMessage (SystemMessage.THE_GAME_WILL_START_IN_S1_SECOND_S) .addNumber (_count), true, true);
_count - = 10;
if (_count> 0)
{
task = new OlympiadGameTask (_game, BattleStatus.Started, _count, 10000);
break;
}
_game.openDoors ();
task = new OlympiadGameTask (_game, BattleStatus.CountDown, 5, 5000);
break;
}
case CountDown:
{
_game.broadcastPacket (new SystemMessage (SystemMessage.THE_GAME_WILL_START_IN_S1_SECOND_S) .addNumber (_count), true, true);
_count--;
if (_count <= 0)
task = new OlympiadGameTask (_game, BattleStatus.StartComp, 36, 1000);
else
task = new OlympiadGameTask (_game, BattleStatus.CountDown, _count, 1000);
break;
}
case StartComp:
{
_game.deleteBuffers ();
if (_count == 36)
{
_game.setState (2);
_game.broadcastPacket (Msg.STARTS_THE_GAME, true, true);
_game.broadcastInfo (null, null, false);
}
// Wait 3 mins (Battle)
_count--;
if (_count == 0)
task = new OlympiadGameTask (_game, BattleStatus.ValidateWinner, 0, 10000);
else
task = new OlympiadGameTask (_game, BattleStatus.StartComp, _count, 10000);
break;
}
case ValidateWinner:
{
try
{
_game.validateWinner (_count> 0);
}
catch (RuntimeException e)
{
_log.error ("Error on Olympiad Validate Winner", e);
}
task = new OlympiadGameTask (_game, BattleStatus.Ending, 0, 20000);
break;
}
case Ending:
{
_game.collapse ();
_terminated = true;
if (Olympiad._manager! = null)
Olympiad._manager.freeOlympiadInstance (_game.getId ());
return;
}
}
if (task == null)
{
Log.add ("task == null for game" + gameId, "olympiad");
Thread.dumpStack ();
_game.endGame (1000, true);
return;
}
_game.sheduleTask (task);
}
catch (RuntimeException e)
{
_log.error ("Error on Olympiad Game Task", e);
_game.endGame (1000, true);
}
}
} [/ CODE]
[/ CODE] [/ CODE]
