/*
===========================================================================

  Copyright (c) 2010-2014 Darkstar Dev Teams

  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/

  This file is part of DarkStar-server source code.

===========================================================================
*/

#include "transport.h"

#include "entities/charentity.h"
#include "map.h"
#include "vana_time.h"
#include "zone.h"
#include "utils/zoneutils.h"

#include "packets/event.h"
#include "packets/entity_update.h"

/************************************************************************
*                                                                       *
*  �R���x�t�p�~�y�u �s�|���q�p�|���~���z �������|�{�y �~�p ���q���u�{�� �{�|�p�����p                          *
*                                                                       *
************************************************************************/

CTransportHandler* CTransportHandler::_instance = NULL;

CTransportHandler* CTransportHandler::getInstance() 
{
	if(_instance == NULL) {
		_instance = new CTransportHandler();
	}
	return _instance;
}

/************************************************************************
*                                                                       *
*  �B �{���~���������{�������u �y�~�y���y�p�|�y�x�y�����u�} �r���� �����p�~�����������~���� ���y�����u�}��               *
*                                                                       *
************************************************************************/

CTransportHandler::CTransportHandler() 
{
    InitializeTransport();
	InitializeElevators();
}

/************************************************************************
*                                                                       *
*  �I�~�y���y�p�|�y�x�p���y�� �����p�~�����������p (�{�����p�q�|�y �y ���p�}���|�u����)                        *
*                                                                       *
************************************************************************/

void CTransportHandler::InitializeTransport()
{
    DSP_DEBUG_BREAK_IF(TransportList.size() != 0);

    const int8* fmtQuery = "SELECT id, transport, door, dock_x, dock_y, dock_z, dock_rot, boundary, zone, anim_arrive, anim_depart, time_offset, time_interval, time_waiting, time_anim_arrive, time_anim_depart  FROM transport;";

	int32 ret = Sql_Query(SqlHandle, fmtQuery);

	if (ret != SQL_ERROR && Sql_NumRows(SqlHandle) != 0)
	{
		while(Sql_NextRow(SqlHandle) == SQL_SUCCESS) 
		{
            Transport_t* PTransport = new Transport_t;

            PTransport->Dock.zone = zoneutils::GetZone((Sql_GetUIntData(SqlHandle,1) >> 12) & 0x0FFF);
            PTransport->Dock.p.x  = Sql_GetFloatData(SqlHandle,3);
            PTransport->Dock.p.y  = Sql_GetFloatData(SqlHandle,4);
            PTransport->Dock.p.z  = Sql_GetFloatData(SqlHandle,5);
            PTransport->Dock.p.rotation = (uint8) Sql_GetIntData(SqlHandle,6);
            PTransport->Dock.boundary   = (uint16)Sql_GetIntData(SqlHandle,7);
            PTransport->Dock.prevzone   = (uint8) Sql_GetIntData(SqlHandle,8);

            PTransport->PDoorNPC      = zoneutils::GetEntity(Sql_GetUIntData(SqlHandle,2), TYPE_NPC);
            PTransport->PTransportNPC = zoneutils::GetEntity(Sql_GetUIntData(SqlHandle,1), TYPE_SHIP);

            PTransport->AnimationArrive = (uint8)Sql_GetIntData(SqlHandle, 9);
            PTransport->AnimationDepart = (uint8)Sql_GetIntData(SqlHandle,10);

            PTransport->TimeOffset   = (uint16)Sql_GetIntData(SqlHandle,11);
            PTransport->TimeInterval = (uint16)Sql_GetIntData(SqlHandle,12);
            PTransport->TimeWaiting  = (uint16)Sql_GetIntData(SqlHandle,13);
            PTransport->TimeAnimationArrive = (uint16)Sql_GetIntData(SqlHandle,14);
            PTransport->TimeAnimationDepart = (uint16)Sql_GetIntData(SqlHandle,15);

            if (PTransport->PDoorNPC == NULL ||
                PTransport->PTransportNPC == NULL)
            {
                ShowError("Transport <%u>: transport or door not found\n", (uint8)Sql_GetIntData(SqlHandle,0));
                delete PTransport;
                continue;
            }
            if (PTransport->TimeAnimationArrive < 10)
            {
                ShowError("Transport <%u>: time_anim_arrive must be > 10\n", (uint8)Sql_GetIntData(SqlHandle,0));
                delete PTransport;
                continue;
            }
            if (PTransport->TimeInterval < PTransport->TimeAnimationArrive + PTransport->TimeWaiting + PTransport->TimeAnimationDepart)
            {
                ShowError("Transport <%u>: time_interval must be > time_anim_arrive + time_waiting + time_anim_depart\n", (uint8)Sql_GetIntData(SqlHandle,0));
                delete PTransport;
                continue;
            }
            PTransport->PTransportNPC->name.resize(8);
            TransportList.push_back(PTransport);
        }
    }
}


/************************************************************************
*                                                                       *
*  �I�~�y���y�p�|�y�x�p���y�� �|�y�������r �y �p�r�����}�p���y���u���{�y�� �t�r�u���u�z                         *
*                                                                       *
************************************************************************/

void CTransportHandler::InitializeElevators()
{
    DSP_DEBUG_BREAK_IF(ElevatorList.size() != 0);

	const int8* fmtQuery = "SELECT id, elevator, lowerDoor, upperDoor, status, regime FROM elevators ;";

	int32 ret = Sql_Query(SqlHandle, fmtQuery);

	if( ret != SQL_ERROR && Sql_NumRows(SqlHandle) != 0)
	{
		while(Sql_NextRow(SqlHandle) == SQL_SUCCESS) 
		{
			Elevator_t elevator;

			elevator.id = (uint8)Sql_GetUIntData(SqlHandle,0);
			elevator.zone = (uint16)((Sql_GetUIntData(SqlHandle,1) >> 12) & 0x0FFF);

			elevator.Elevator  = (CNpcEntity*)zoneutils::GetEntity(Sql_GetUIntData(SqlHandle,1), TYPE_NPC);
			elevator.LowerDoor = (CNpcEntity*)zoneutils::GetEntity(Sql_GetUIntData(SqlHandle,2), TYPE_NPC);
			elevator.UpperDoor = (CNpcEntity*)zoneutils::GetEntity(Sql_GetUIntData(SqlHandle,3), TYPE_NPC);

			elevator.isMoving    = false;
			elevator.isStarted   = (Sql_GetUIntData(SqlHandle,4) != 0);
			elevator.isPermanent = (Sql_GetUIntData(SqlHandle,5) != 0);

			elevator.movetime = ((elevator.UpperDoor == NULL)||(elevator.LowerDoor == NULL) ? 0 : 3);
			elevator.interval = ((elevator.UpperDoor == NULL)||(elevator.LowerDoor == NULL)||(!elevator.isPermanent) ? 8 : 8);

			if (elevator.Elevator != NULL)
			{
				elevator.Elevator->name.resize(10);
				ElevatorList.push_back(elevator);
			}
		}
	}
}

/************************************************************************
*                                                                       *
*  �B���u �|���s�y�{�p ���u���u�t�r�y�w�u�~�y�� �����p�~�����������p                                   *
*                                                                       *
************************************************************************/

void CTransportHandler::TransportTimer() 
{
	uint32 VanaTime = CVanaTime::getInstance()->getDate();

    // �r �����������r���� �x���~�p�� �~�u���q�����t�y�}�� �~�p���y���p���� �}�p�{�������� �~�p ���|�����p�z, �u���|�y ���u�������~�p�w �r�����u�| �y�x �y�s���� �r �{�����p�q�|�u. 
    // �����y �r�����t�u �r �y�s���� ���~ �t���|�w�u�~ ���{�p�x�p�������� �~�p �����y�����p�~�y

    for(uint32 i = 0; i < TransportList.size(); ++i)
    {
        Transport_t* PTransport = TransportList.at(i);

        uint16 ShipTimerOffset = ((VanaTime - PTransport->TimeOffset) % PTransport->TimeInterval);

        // �{�����p�q�|�� �������r�|���u������ �~�p �s�����y�x���~���u
        if (ShipTimerOffset == 0)
        {
            PTransport->PTransportNPC->status = STATUS_NORMAL;
            PTransport->PTransportNPC->animation = PTransport->AnimationArrive;
            PTransport->PTransportNPC->loc = PTransport->Dock;

            WBUFL(&PTransport->PTransportNPC->name[0],4) = CVanaTime::getInstance()->getVanaTime();

            PTransport->Dock.zone->PushPacket(NULL, CHAR_INZONE, new CEntityUpdatePacket(PTransport->PTransportNPC, ENTITY_SPAWN));
        }
        // ���u�������~�p�w�y �r�y�t���� �{�����p�q�|��, �y�~�p���u �w�t�u�} ���|�u�t�������u�s�� �����y�q�����y��
        else if (PTransport->PTransportNPC->status == STATUS_NORMAL) 
        {
            // �������p �����t�����s�y�r�p���� ���p�����p�w�y�����r �{ �r�������t��
            if (ShipTimerOffset ==  PTransport->TimeAnimationArrive - 10) 
            {
                PTransport->PTransportNPC->loc.boundary = 0;
                zoneutils::GetZone(PTransport->Dock.prevzone)->TransportDepart(PTransport->PTransportNPC);
            }
            // �{�����p�q�|�� �����y���p�|�y�|, �����{�����r�p�u�} �t�r�u���y ���p�����p�w�y���p�}
            else if (ShipTimerOffset == PTransport->TimeAnimationArrive)
            {
                PTransport->PDoorNPC->animation = ANIMATION_OPEN_DOOR;
                PTransport->Dock.zone->PushPacket(PTransport->PDoorNPC, CHAR_INRANGE, new CEntityUpdatePacket(PTransport->PDoorNPC, ENTITY_UPDATE)); 
            }
            //�{�����p�q�|�� �������p�|�y�r�p�u��
            else if (ShipTimerOffset == PTransport->TimeAnimationArrive + PTransport->TimeWaiting)
            {
                PTransport->PDoorNPC->animation = ANIMATION_CLOSE_DOOR;
                PTransport->PTransportNPC->animation = PTransport->AnimationDepart;
                PTransport->PTransportNPC->loc.boundary = PTransport->Dock.boundary;

                WBUFL(&PTransport->PTransportNPC->name[0],4) = CVanaTime::getInstance()->getVanaTime();

                PTransport->Dock.zone->TransportDepart(PTransport->PTransportNPC);
                PTransport->Dock.zone->PushPacket(PTransport->PDoorNPC, CHAR_INRANGE, new CEntityUpdatePacket(PTransport->PDoorNPC, ENTITY_UPDATE)); 
                PTransport->Dock.zone->PushPacket(NULL, CHAR_INZONE, new CEntityUpdatePacket(PTransport->PTransportNPC, ENTITY_UPDATE));
            }
            //�{�����p�q�|�� �y�����u�x�p�u��
            else if (ShipTimerOffset == PTransport->TimeAnimationArrive + PTransport->TimeWaiting + PTransport->TimeAnimationDepart)
            {
                PTransport->PTransportNPC->status = STATUS_DISAPPEAR;
                PTransport->Dock.zone->PushPacket(NULL, CHAR_INZONE, new CEntityUpdatePacket(PTransport->PTransportNPC, ENTITY_DESPAWN));
            }
        }
    }

	for(uint32 i = 0; i < ElevatorList.size(); ++i) 
	{
		Elevator_t * elevator = &ElevatorList.at(i);

		if (elevator->id == 22){
			ShowDebug(CL_CYAN"[Transport] Elevator Started = %d\n" CL_RESET, elevator->isStarted);
		}

		if (elevator->isStarted)
		{
			uint16 TimerOffset = (VanaTime % elevator->interval);
			
			if (elevator->id == 22){
				ShowDebug(CL_CYAN"[Transport] Elevator Timer: Interval = %d, Movetime = %d\n" CL_RESET, elevator->interval, elevator->movetime);
			}

			if (elevator->id == ELEVATOR_PORT_BASTOK_DRWBRDG)
			{
				TimerOffset = (VanaTime % INTERVAL_PORT_BASTOK_DRWBRDG);

				if (TimerOffset == 0 || TimerOffset == 76)
				{
					CZone* PZone = zoneutils::GetZone(elevator->zone);
					EntityList_t charList = PZone->GetCharList();

					if (!charList.empty())
					{
						for (EntityList_t::const_iterator it = charList.begin() ; it != charList.end() ; ++it)
						{
							CCharEntity* PChar = (CCharEntity*)it->second;
							if ((PChar->GetXPos() > 54 && PChar->GetXPos() < 66) && (PChar->GetZPos() > -160 && PChar->GetZPos() < -80))
							{
								PChar->pushPacket(new CEventPacket(PChar, 70, 0, 0, 0, 0, 0, 0, 0, 0, 0, -1));
							}
						}
					}
				}
				else if (TimerOffset == 4 || TimerOffset == 80)
				{
					elevator->isMoving = true;
					startElevator(elevator);
				}
				else if (TimerOffset == 8 || TimerOffset == 84)
				{
					elevator->isMoving = true;
					startElevator(elevator);
				}
				else if (TimerOffset == 12 || TimerOffset == 88)
				{
					elevator->isMoving = false;
					arriveElevator(elevator);
				}
			}
			else if (elevator->id == ELEVATOR_KUFTAL_TUNNEL_DSPPRNG_RCK)
			{
				TimerOffset = (VanaTime % INTERVAL_KUFTAL_TUNNEL_DSPPRNG_RCK);

				if (TimerOffset == 60)
				{
					elevator->isMoving = true;
					startElevator(elevator);
				}
			}
			else
			{
				if (TimerOffset == 0)
				{
					elevator->isMoving = true;
					startElevator(elevator);
				}
				else if (TimerOffset == elevator->movetime)
				{
					if (elevator->isMoving)
					{
						if (!elevator->isPermanent)
						{
							elevator->isStarted = false;
						}
						elevator->isMoving = false;
						arriveElevator(elevator);
					}
				}
			}
		}
	}
}

/************************************************************************
*                                                                       *
*                                                                       *
*                                                                       *
************************************************************************/

void CTransportHandler::startElevator(int32 elevatorID)
{
    for(uint32 i = 0; i < ElevatorList.size(); ++i) 
	{		
	    Elevator_t * elevator = &ElevatorList.at(i);

		if (elevator->id == elevatorID)
		{			
			CTransportHandler::startElevator(elevator);
            return;
		}
    }
}

/************************************************************************
*                                                                       *
*                                                                       *
*                                                                       *
************************************************************************/

void CTransportHandler::startElevator(Elevator_t * elevator)
{
	if (elevator->id == 22){
		ShowDebug(CL_CYAN"[Transport] Starting Elevator, Id = %d, Animation = %d\n" CL_RESET, elevator->id, elevator->Elevator->animation);
	}

	if (!elevator->isPermanent){
		elevator->isStarted = true;
	}

	elevator->Elevator->animation ^= 1;

	if (elevator->id == 22){
		ShowDebug(CL_CYAN"[Transport] Elevator Set Animation -> %d\n" CL_RESET, elevator->Elevator->animation);
	}

	if (elevator->id == 22){
		ShowDebug(CL_CYAN"[Transport] Elevator Name -> %s\n" CL_RESET, elevator->Elevator->GetName());
	}
	elevator->Elevator->name[8] = 8;
    WBUFL(&elevator->Elevator->name[0],4) = CVanaTime::getInstance()->getVanaTime();
  
	if ((elevator->LowerDoor != NULL) && (elevator->UpperDoor != NULL)) 
	{
		if (elevator->id == 22){
			ShowDebug(CL_CYAN"[Transport] This Elevator Has Doors!\n" CL_RESET);
		}
		if (elevator->id == ELEVATOR_PORT_BASTOK_DRWBRDG)
		{
			elevator->LowerDoor->animation = ANIMATION_CLOSE_DOOR;
			zoneutils::GetZone(elevator->zone)->PushPacket(NULL,CHAR_INZONE, new CEntityUpdatePacket(elevator->LowerDoor,ENTITY_SPAWN));
			elevator->UpperDoor->animation = ANIMATION_CLOSE_DOOR;
			zoneutils::GetZone(elevator->zone)->PushPacket(NULL,CHAR_INZONE, new CEntityUpdatePacket(elevator->UpperDoor,ENTITY_SPAWN));
		}
		else
		{
			if (elevator->Elevator->animation == ANIMATION_ELEVATOR_DOWN) 
			{
				if (elevator->id == 22){
					ShowDebug(CL_CYAN"[Transport] Elevator Going Down, Closing Doors...!\n" CL_RESET);
				}
				elevator->LowerDoor->animation = ANIMATION_CLOSE_DOOR;
				zoneutils::GetZone(elevator->zone)->PushPacket(NULL,CHAR_INZONE, new CEntityUpdatePacket(elevator->LowerDoor,ENTITY_SPAWN));
				if (!elevator->isPermanent) 
				{
					if (elevator->id == 22){
						ShowDebug(CL_CYAN"[Transport] Elevator Not Permanent, Opening Doors...!\n" CL_RESET);
					}
					elevator->UpperDoor->animation = ANIMATION_OPEN_DOOR;
					zoneutils::GetZone(elevator->zone)->PushPacket(NULL,CHAR_INZONE, new CEntityUpdatePacket(elevator->UpperDoor,ENTITY_SPAWN));
				}
			}
			else
			{
				if (elevator->id == 22){
					ShowDebug(CL_CYAN"[Transport] Elevator Going Up, Closing Doors...!\n" CL_RESET);
				}
				elevator->UpperDoor->animation = ANIMATION_CLOSE_DOOR;
				zoneutils::GetZone(elevator->zone)->PushPacket(NULL,CHAR_INZONE, new CEntityUpdatePacket(elevator->UpperDoor,ENTITY_SPAWN));
				if (!elevator->isPermanent) 
				{
					if (elevator->id == 22){
						ShowDebug(CL_CYAN"[Transport] Elevator Not Permanent, Opening Doors...!\n" CL_RESET);
					}
					elevator->LowerDoor->animation = ANIMATION_OPEN_DOOR;
					zoneutils::GetZone(elevator->zone)->PushPacket(NULL,CHAR_INZONE, new CEntityUpdatePacket(elevator->LowerDoor,ENTITY_SPAWN));
				}
			}
		}
	}
	zoneutils::GetZone(elevator->zone)->PushPacket(NULL,CHAR_INZONE, new CEntityUpdatePacket(elevator->Elevator,ENTITY_SPAWN));
}

/************************************************************************
*                                                                       *
*                                                                       *
*                                                                       *
************************************************************************/

void CTransportHandler::arriveElevator(Elevator_t * elevator)
{
	if (elevator->id == 22){
		ShowDebug(CL_CYAN"[Transport] Elevator Arrival: Id = %d\n" CL_RESET, elevator->id);
	}

	if (elevator->id == ELEVATOR_DAVOI_ELVTR)
	{
		elevator->interval = elevator->interval;
	}
	if (elevator->id == ELEVATOR_PORT_BASTOK_DRWBRDG)
	{
		elevator->LowerDoor->animation = ANIMATION_OPEN_DOOR;
		zoneutils::GetZone(elevator->zone)->PushPacket(NULL,CHAR_INZONE, new CEntityUpdatePacket(elevator->LowerDoor,ENTITY_SPAWN));
		elevator->UpperDoor->animation = ANIMATION_OPEN_DOOR;
		zoneutils::GetZone(elevator->zone)->PushPacket(NULL,CHAR_INZONE, new CEntityUpdatePacket(elevator->UpperDoor,ENTITY_SPAWN));
	}
	else
	{
		if (elevator->Elevator->animation == ANIMATION_ELEVATOR_DOWN)
		{
			if (elevator->id == 22){
				ShowDebug(CL_CYAN"[Transport] Elevator Arrival: Had ANIMATION_ELEVATOR_DOWN\n" CL_RESET);
			}
			elevator->LowerDoor->animation = ANIMATION_OPEN_DOOR;
			if (elevator->id == 22){
				ShowDebug(CL_CYAN"[Transport] Elevator Arrival: Opening Lower Door, Name = %d, X = %d, Y = %d, Z = %d\n" CL_RESET, elevator->LowerDoor->GetName(), elevator->LowerDoor->GetXPos(), elevator->LowerDoor->GetYPos(), elevator->LowerDoor->GetZPos());
			}
			zoneutils::GetZone(elevator->zone)->PushPacket(NULL,CHAR_INZONE, new CEntityUpdatePacket(elevator->LowerDoor,ENTITY_SPAWN));
		}
		else
		{
			if (elevator->id == 22){
				ShowDebug(CL_CYAN"[Transport] Elevator Arrival: Had ANIMATION_ELEVATOR_UP\n" CL_RESET);
			}
			elevator->UpperDoor->animation = ANIMATION_OPEN_DOOR;
			if (elevator->id == 22){
				ShowDebug(CL_CYAN"[Transport] Elevator Arrival: Opening Upper Door, Name = %d, X = %d, Y = %d, Z = %d\n" CL_RESET, elevator->UpperDoor->GetName(), elevator->UpperDoor->GetXPos(), elevator->UpperDoor->GetYPos(), elevator->UpperDoor->GetZPos());
			}
			zoneutils::GetZone(elevator->zone)->PushPacket(NULL,CHAR_INZONE, new CEntityUpdatePacket(elevator->UpperDoor,ENTITY_SPAWN));
		}
	}
}