eu07/maszyna
1
0
Fork 0
mirror of https://github.com/MaSzyna-EU07/maszyna.git synced 2026-03-22 15:05:03 +01:00
Code Issues Packages Projects Releases Wiki Activity
Files
84f54db12e3c99e13ec006d266131e63599d6c62
maszyna/Event.cpp
VB 0f33b0abdb merge
2017-02-15 15:03:15 +01:00

698 lines
23 KiB
C++
Raw Blame History

/*
This Source Code Form is subject to the
terms of the Mozilla Public License, v.
2.0. If a copy of the MPL was not
distributed with this file, You can
obtain one at
http://mozilla.org/MPL/2.0/.
*/
/*
MaSzyna EU07 locomotive simulator
Copyright (C) 2001-2004 Marcin Wozniak and others
*/
#include "stdafx.h"
#include "Event.h"
#include "Globals.h"
#include "Logs.h"
#include "Usefull.h"
#include "parser.h"
#include "Timer.h"
#include "MemCell.h"
#include "Ground.h"
#include "McZapkie\mctools.h"
TEvent::TEvent( std::string const &m ) :
asNodeName( m )
{
if( false == m.empty() ) {
// utworzenie niejawnego odczytu komórki pamięci w torze
Type = tp_GetValues;
}
for( int i = 0; i < 13; ++i ) {
Params[ i ].asPointer = nullptr;
}
};
TEvent::~TEvent()
{
switch (Type)
{ // sprzątanie
case tp_Multiple:
// SafeDeleteArray(Params[9].asText); //nie usuwać - nazwa obiektu powiązanego zamieniana na
// wskaźnik
if (iFlags & conditional_memstring) // o ile jest łańcuch do porównania w memcompare
SafeDeleteArray(Params[10].asText);
break;
case tp_UpdateValues:
case tp_AddValues:
SafeDeleteArray(Params[0].asText);
if (iFlags & conditional_memstring) // o ile jest łańcuch do porównania w memcompare
SafeDeleteArray(Params[10].asText);
break;
case tp_Animation: // nic
// SafeDeleteArray(Params[9].asText); //nie usuwać - nazwa jest zamieniana na wskaźnik do
// submodelu
if (Params[0].asInt == 4) // jeśli z pliku VMD
delete[] Params[8].asPointer; // zwolnić obszar
case tp_GetValues: // nic
break;
case tp_PutValues: // params[0].astext stores the token
SafeDeleteArray( Params[ 0 ].asText );
break;
}
evJoined = NULL; // nie usuwać podczepionych tutaj
};
void TEvent::Init(){
};
void TEvent::Conditions(cParser *parser, string s)
{ // przetwarzanie warunków, wspólne dla Multiple i UpdateValues
if (s == "condition")
{ // jesli nie "endevent"
std::string token, str;
if (!asNodeName.empty())
{ // podczepienie łańcucha, jeśli nie jest pusty
// BUG: source of a memory leak -- the array never gets deleted. fix the destructor
Params[9].asText = new char[asNodeName.length() + 1]; // usuwane i zamieniane na
// wskaźnik
strcpy(Params[9].asText, asNodeName.c_str());
}
parser->getTokens();
*parser >> token;
str = token;
if (str == "trackoccupied")
iFlags |= conditional_trackoccupied;
else if (str == "trackfree")
iFlags |= conditional_trackfree;
else if (str == "propability")
{
iFlags |= conditional_propability;
parser->getTokens();
*parser >> Params[10].asdouble;
}
else if (str == "memcompare")
{
iFlags |= conditional_memcompare;
parser->getTokens(1, false); // case sensitive
*parser >> token;
str = token;
if (str != "*") //"*" - nie brac command pod uwage
{ // zapamiętanie łańcucha do porównania
Params[10].asText = new char[255];
strcpy(Params[10].asText, str.c_str());
iFlags |= conditional_memstring;
}
parser->getTokens();
*parser >> token;
str = token;
if (str != "*") //"*" - nie brac val1 pod uwage
{
Params[11].asdouble = atof(str.c_str());
iFlags |= conditional_memval1;
}
parser->getTokens();
*parser >> token;
str = token;
if (str != "*") //"*" - nie brac val2 pod uwage
{
Params[12].asdouble = atof(str.c_str());
iFlags |= conditional_memval2;
}
}
parser->getTokens();
*parser >> token;
s = token; // ewentualnie dalej losowe opóźnienie
}
if (s == "randomdelay")
{ // losowe opóźnienie
std::string token;
parser->getTokens();
*parser >> fRandomDelay; // Ra 2014-03-11
parser->getTokens();
*parser >> token; // endevent
}
};
void TEvent::Load(cParser *parser, vector3 *org)
{
int i;
int ti;
std::string token;
//string str;
char *ptr;
bEnabled = true; // zmieniane na false dla eventów używanych do skanowania sygnałów
parser->getTokens();
*parser >> token;
asName = ToLower(token); // użycie parametrów może dawać wielkie
parser->getTokens();
*parser >> token;
// str = AnsiString(token.c_str());
if (token == "exit")
Type = tp_Exit;
else if (token == "updatevalues")
Type = tp_UpdateValues;
else if (token == "getvalues")
Type = tp_GetValues;
else if (token == "putvalues")
Type = tp_PutValues;
else if (token == "disable")
Type = tp_Disable;
else if (token == "sound")
Type = tp_Sound;
else if (token == "velocity")
Type = tp_Velocity;
else if (token == "animation")
Type = tp_Animation;
else if (token == "lights")
Type = tp_Lights;
else if (token == "visible")
Type = tp_Visible; // zmiana wyświetlania obiektu
else if (token == "switch")
Type = tp_Switch;
else if (token == "dynvel")
Type = tp_DynVel;
else if (token == "trackvel")
Type = tp_TrackVel;
else if (token == "multiple")
Type = tp_Multiple;
else if (token == "addvalues")
Type = tp_AddValues;
else if (token == "copyvalues")
Type = tp_CopyValues;
else if (token == "whois")
Type = tp_WhoIs;
else if (token == "logvalues")
Type = tp_LogValues;
else if (token == "voltage")
Type = tp_Voltage; // zmiana napięcia w zasilaczu (TractionPowerSource)
else if (token == "message")
Type = tp_Message; // wyświetlenie komunikatu
else if (token == "friction")
Type = tp_Friction; // zmiana tarcia na scenerii
else
Type = tp_Unknown;
parser->getTokens();
*parser >> fDelay;
parser->getTokens();
*parser >> token;
// str = AnsiString(token.c_str());
if (token != "none")
asNodeName = token; // nazwa obiektu powiązanego
if (asName.substr(0, 5) == "none_")
Type = tp_Ignored; // Ra: takie są ignorowane
switch (Type)
{
case tp_AddValues:
iFlags = update_memadd; // dodawanko
case tp_UpdateValues:
// if (Type==tp_UpdateValues) iFlags=0; //co modyfikować
parser->getTokens(1, false); // case sensitive
*parser >> token;
// str = AnsiString(token.c_str());
Params[0].asText = new char[token.length() + 1];
strcpy(Params[0].asText, token.c_str());
if (token != "*") // czy ma zostać bez zmian?
iFlags |= update_memstring;
parser->getTokens();
*parser >> token;
// str = AnsiString(token.c_str());
if (token != "*") // czy ma zostać bez zmian?
{
Params[1].asdouble = atof(token.c_str());
iFlags |= update_memval1;
}
else
Params[1].asdouble = 0;
parser->getTokens();
*parser >> token;
// str = AnsiString(token.c_str());
if (token != "*") // czy ma zostać bez zmian?
{
Params[2].asdouble = atof(token.c_str());
iFlags |= update_memval2;
}
else
Params[2].asdouble = 0;
parser->getTokens();
*parser >> token;
Conditions(parser, token); // sprawdzanie warunków
break;
case tp_CopyValues:
Params[9].asText = NULL;
iFlags = update_memstring | update_memval1 | update_memval2; // normalanie trzy
i = 0;
parser->getTokens();
*parser >> token; // nazwa drugiej komórki (źródłowej)
while (token.compare("endevent") != 0)
{
switch (++i)
{ // znaczenie kolejnych parametrów
case 1: // nazwa drugiej komórki (źródłowej)
Params[9].asText = new char[token.length() + 1]; // usuwane i zamieniane na wskaźnik
strcpy(Params[9].asText, token.c_str());
break;
case 2: // maska wartości
iFlags = stol_def(token,
(update_memstring | update_memval1 | update_memval2));
break;
}
parser->getTokens();
*parser >> token;
}
break;
case tp_WhoIs:
iFlags = update_memstring | update_memval1 | update_memval2; // normalanie trzy
i = 0;
parser->getTokens();
*parser >> token; // nazwa drugiej komórki (źródłowej)
while (token.compare("endevent") != 0)
{
switch (++i)
{ // znaczenie kolejnych parametrów
case 1: // maska wartości
iFlags = stol_def(token,
(update_memstring | update_memval1 | update_memval2));
break;
}
parser->getTokens();
*parser >> token;
}
break;
case tp_GetValues:
case tp_LogValues:
parser->getTokens(); //"endevent"
*parser >> token;
break;
case tp_PutValues:
parser->getTokens(3);
*parser >> Params[3].asdouble >> Params[4].asdouble >> Params[5].asdouble; // położenie
// X,Y,Z
if (org)
{ // przesunięcie
// tmp->pCenter.RotateY(aRotate.y/180.0*M_PI); //Ra 2014-11: uwzględnienie rotacji
Params[3].asdouble += org->x; // współrzędne w scenerii
Params[4].asdouble += org->y;
Params[5].asdouble += org->z;
}
// Params[12].asInt=0;
parser->getTokens(1, false); // komendy 'case sensitive'
*parser >> token;
// str = AnsiString(token.c_str());
if (token.substr(0, 19) == "PassengerStopPoint:")
{
if (token.find('#') != std::string::npos)
token.erase(token.find('#')); // obcięcie unikatowości
win1250_to_ascii( token ); // get rid of non-ascii chars
bEnabled = false; // nie do kolejki (dla SetVelocity też, ale jak jest do toru
// dowiązany)
Params[6].asCommand = cm_PassengerStopPoint;
}
else if (token == "SetVelocity")
{
bEnabled = false;
Params[6].asCommand = cm_SetVelocity;
}
else if (token == "RoadVelocity")
{
bEnabled = false;
Params[6].asCommand = cm_RoadVelocity;
}
else if (token == "SectionVelocity")
{
bEnabled = false;
Params[6].asCommand = cm_SectionVelocity;
}
else if (token == "ShuntVelocity")
{
bEnabled = false;
Params[6].asCommand = cm_ShuntVelocity;
}
//else if (str == "SetProximityVelocity")
//{
// bEnabled = false;
// Params[6].asCommand = cm_SetProximityVelocity;
//}
else if (token == "OutsideStation")
{
bEnabled = false; // ma być skanowny, aby AI nie przekraczało W5
Params[6].asCommand = cm_OutsideStation;
}
else
Params[6].asCommand = cm_Unknown;
Params[0].asText = new char[token.length() + 1];
strcpy(Params[0].asText, token.c_str());
parser->getTokens();
*parser >> token;
// str = AnsiString(token.c_str());
if (token == "none")
Params[1].asdouble = 0.0;
else
try
{
Params[1].asdouble = atof(token.c_str());
}
catch (...)
{
Params[1].asdouble = 0.0;
WriteLog("Error: number expected in PutValues event, found: " + token);
}
parser->getTokens();
*parser >> token;
// str = AnsiString(token.c_str());
if (token == "none")
Params[2].asdouble = 0.0;
else
try
{
Params[2].asdouble = atof(token.c_str());
}
catch (...)
{
Params[2].asdouble = 0.0;
WriteLog("Error: number expected in PutValues event, found: " + token);
}
parser->getTokens();
*parser >> token;
break;
case tp_Lights:
i = 0;
do
{
parser->getTokens();
*parser >> token;
if (token.compare("endevent") != 0)
{
// str = AnsiString(token.c_str());
if (i < 8)
Params[i].asdouble = atof(token.c_str()); // teraz może mieć ułamek
i++;
}
} while (token.compare("endevent") != 0);
break;
case tp_Visible: // zmiana wyświetlania obiektu
parser->getTokens();
*parser >> token;
// str = AnsiString(token.c_str());
Params[0].asInt = atoi(token.c_str());
parser->getTokens();
*parser >> token;
break;
case tp_Velocity:
parser->getTokens();
*parser >> token;
// str = AnsiString(token.c_str());
Params[0].asdouble = atof(token.c_str()) * 0.28;
parser->getTokens();
*parser >> token;
break;
case tp_Sound:
// Params[0].asRealSound->Init(asNodeName.c_str(),Parser->GetNextSymbol().ToDouble(),Parser->GetNextSymbol().ToDouble(),Parser->GetNextSymbol().ToDouble(),Parser->GetNextSymbol().ToDouble());
// McZapkie-070502: dzwiek przestrzenny (ale do poprawy)
// Params[1].asdouble=Parser->GetNextSymbol().ToDouble();
// Params[2].asdouble=Parser->GetNextSymbol().ToDouble();
// Params[3].asdouble=Parser->GetNextSymbol().ToDouble(); //polozenie X,Y,Z - do poprawy!
parser->getTokens();
*parser >> Params[0].asInt; // 0: wylaczyc, 1: wlaczyc; -1: wlaczyc zapetlone
parser->getTokens();
*parser >> token;
break;
case tp_Exit:
while ((ptr = strchr(strdup(asNodeName.c_str()), '_')) != NULL)
*ptr = ' ';
parser->getTokens();
*parser >> token;
break;
case tp_Disable:
parser->getTokens();
*parser >> token;
break;
case tp_Animation:
parser->getTokens();
*parser >> token;
Params[0].asInt = 0; // na razie nieznany typ
if (token.compare("rotate") == 0)
{ // obrót względem osi
parser->getTokens();
*parser >> token;
Params[9].asText = new char[token.size() + 1]; // nazwa submodelu
std::strcpy(Params[9].asText, token.c_str());
Params[0].asInt = 1;
parser->getTokens(4);
*parser
>> Params[1].asdouble
>> Params[2].asdouble
>> Params[3].asdouble
>> Params[4].asdouble;
}
else if (token.compare("translate") == 0)
{ // przesuw o wektor
parser->getTokens();
*parser >> token;
Params[9].asText = new char[token.size() + 1]; // nazwa submodelu
std::strcpy(Params[9].asText, token.c_str());
Params[0].asInt = 2;
parser->getTokens(4);
*parser
>> Params[1].asdouble
>> Params[2].asdouble
>> Params[3].asdouble
>> Params[4].asdouble;
}
else if (token.compare("digital") == 0)
{ // licznik cyfrowy
parser->getTokens();
*parser >> token;
Params[9].asText = new char[token.size() + 1]; // nazwa submodelu
std::strcpy(Params[9].asText, token.c_str());
Params[0].asInt = 8;
parser->getTokens(4); // jaki ma być sens tych parametrów?
*parser
>> Params[1].asdouble
>> Params[2].asdouble
>> Params[3].asdouble
>> Params[4].asdouble;
}
else if (token.substr(token.length() - 4, 4) == ".vmd") // na razie tu, może będzie inaczej
{ // animacja z pliku VMD
// TFileStream *fs = new TFileStream( "models\\" + AnsiString( token.c_str() ), fmOpenRead );
{
std::ifstream file( "models\\" + token, std::ios::binary | std::ios::ate ); file.unsetf( std::ios::skipws );
auto size = file.tellg(); // ios::ate already positioned us at the end of the file
file.seekg( 0, std::ios::beg ); // rewind the caret afterwards
Params[ 7 ].asInt = size;
Params[8].asPointer = new char[size];
file.read( static_cast<char*>(Params[ 8 ].asPointer), size ); // wczytanie pliku
}
parser->getTokens();
*parser >> token;
Params[9].asText = new char[token.size() + 1]; // nazwa submodelu
std::strcpy(Params[9].asText, token.c_str());
Params[0].asInt = 4; // rodzaj animacji
parser->getTokens(4);
*parser
>> Params[1].asdouble
>> Params[2].asdouble
>> Params[3].asdouble
>> Params[4].asdouble;
}
parser->getTokens();
*parser >> token;
break;
case tp_Switch:
parser->getTokens();
*parser >> Params[0].asInt;
parser->getTokens();
*parser >> token;
// str = AnsiString(token.c_str());
if (token != "endevent")
{
Params[1].asdouble = atof(token.c_str()); // prędkość liniowa ruchu iglic
parser->getTokens();
*parser >> token;
// str = AnsiString(token.c_str());
}
else
Params[1].asdouble = -1.0; // użyć domyślnej
if (token != "endevent")
{
Params[2].asdouble =
atof(token.c_str()); // dodatkowy ruch drugiej iglicy (zamknięcie nastawnicze)
parser->getTokens();
*parser >> token;
}
else
Params[2].asdouble = -1.0; // użyć domyślnej
break;
case tp_DynVel:
parser->getTokens();
*parser >> Params[0].asdouble; // McZapkie-090302 *0.28;
parser->getTokens();
*parser >> token;
break;
case tp_TrackVel:
parser->getTokens();
*parser >> Params[0].asdouble; // McZapkie-090302 *0.28;
parser->getTokens();
*parser >> token;
break;
case tp_Multiple:
i = 0;
ti = 0; // flaga dla else
parser->getTokens();
*parser >> token;
// str = AnsiString(token.c_str());
while (token != "endevent" && token != "condition" &&
token != "randomdelay")
{
if ((token.substr(0, 5) != "none_") ? (i < 8) : false)
{ // eventy rozpoczynające się od "none_" są ignorowane
if (token != "else")
{
Params[i].asText = new char[255];
strcpy(Params[i].asText, token.c_str());
if (ti)
iFlags |= conditional_else << i; // oflagowanie dla eventów "else"
i++;
}
else
ti = !ti; // zmiana flagi dla słowa "else"
}
else if (i >= 8)
ErrorLog("Bad event: \"" + token + "\" ignored in multiple \"" + asName + "\"!");
else
WriteLog("Event \"" + token + "\" ignored in multiple \"" + asName + "\"!");
parser->getTokens();
*parser >> token;
// str = AnsiString(token.c_str());
}
Conditions(parser, token); // sprawdzanie warunków
break;
case tp_Voltage: // zmiana napięcia w zasilaczu (TractionPowerSource)
case tp_Friction: // zmiana przyczepnosci na scenerii
parser->getTokens();
*parser >> Params[0].asdouble; // Ra 2014-01-27
parser->getTokens();
*parser >> token;
break;
case tp_Message: // wyświetlenie komunikatu
do
{
parser->getTokens();
*parser >> token;
// str = AnsiString(token.c_str());
} while (token != "endevent");
break;
case tp_Ignored: // ignorowany
case tp_Unknown: // nieznany
do
{
parser->getTokens();
*parser >> token;
// str = AnsiString(token.c_str());
} while (token != "endevent");
WriteLog("Bad event: \"" + asName +
(Type == tp_Unknown ? "\" has unknown type." : "\" is ignored."));
break;
}
};
void TEvent::AddToQuery(TEvent *e)
{ // dodanie eventu do kolejki
if (evNext ? (e->fStartTime >= evNext->fStartTime) : false)
evNext->AddToQuery(e); // sortowanie wg czasu
else
{ // dodanie z przodu
e->evNext = evNext;
evNext = e;
}
}
//---------------------------------------------------------------------------
string TEvent::CommandGet()
{ // odczytanie komendy z eventu
switch (Type)
{ // to się wykonuje również składu jadącego bez obsługi
case tp_GetValues:
return string(Params[9].asMemCell->Text());
case tp_PutValues:
return string(Params[0].asText);
}
return ""; // inne eventy się nie liczą
};
TCommandType TEvent::Command()
{ // odczytanie komendy z eventu
switch (Type)
{ // to się wykonuje również dla składu jadącego bez obsługi
case tp_GetValues:
return Params[9].asMemCell->Command();
case tp_PutValues:
return Params[6].asCommand; // komenda zakodowana binarnie
}
return cm_Unknown; // inne eventy się nie liczą
};
double TEvent::ValueGet(int n)
{ // odczytanie komendy z eventu
n &= 1; // tylko 1 albo 2 jest prawidłowy
switch (Type)
{ // to się wykonuje również składu jadącego bez obsługi
case tp_GetValues:
return n ? Params[9].asMemCell->Value1() : Params[9].asMemCell->Value2();
case tp_PutValues:
return Params[2 - n].asdouble;
}
return 0.0; // inne eventy się nie liczą
};
vector3 TEvent::PositionGet()
{ // pobranie współrzędnych eventu
switch (Type)
{ //
case tp_GetValues:
return Params[9].asMemCell->Position(); // współrzędne podłączonej komórki pamięci
case tp_PutValues:
return vector3(Params[3].asdouble, Params[4].asdouble, Params[5].asdouble);
}
return vector3(0, 0, 0); // inne eventy się nie liczą
};
bool TEvent::StopCommand()
{ //
if (Type == tp_GetValues)
return Params[9].asMemCell->StopCommand(); // info o komendzie z komórki
return false;
};
void TEvent::StopCommandSent()
{
if (Type == tp_GetValues)
Params[9].asMemCell->StopCommandSent(); // komenda z komórki została wysłana
};
void TEvent::Append(TEvent *e)
{ // doczepienie kolejnych z tą samą nazwą
if (evJoined)
evJoined->Append(e); // rekurencja! - góra kilkanaście eventów będzie potrzebne
else
{
evJoined = e;
e->bEnabled = true; // ten doczepiony może być tylko kolejkowany
}
};
Reference in New Issue View Git Blame Copy Permalink