123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321 |
- #include "Spiel.h"
- #define TICK 0.03333333
- // Konstruktor
- Spiel::Spiel()
- {
- isRunning = 0;
- log = 0;
- spielerAnzahl = 0;
- zAccounts = 0;
- spielId = 0;
- karteId = 0;
- pause = 0;
- gameTicks = 0;
- ende = 1;
- stat = new Statistik();
- ref = 1;
- }
- // Destruktor
- Spiel::~Spiel()
- {
- stat->release();
- if( psqldb )
- psqldb->release();
- }
- // nicht constant
- void Spiel::setPSQLK( SSDatenbankV *psqldb )
- {
- if( this->psqldb )
- this->psqldb->release();
- this->psqldb = psqldb;
- stat->setPSQLDB( psqldb->getThis() );
- }
- // call 1
- void Spiel::setSpielId( int id )
- {
- spielId = id;
- stat->setSpielId( id );
- }
- // call 2
- void Spiel::setKarteId( int karteId )
- {
- this->karteId = karteId;
- stat->setKarteId( karteId );
- }
- // call 3
- void Spiel::setTempPfad( char *pfad )
- {
- mapPfad = pfad;
- mapPfad += "/";
- }
- // call 3.5
- void Spiel::setAccounts( int anzahl, Array< int > *zAccounts )
- {
- this->zAccounts = zAccounts->getThis();
- spielerAnzahl = anzahl;
- }
- // call 4
- void Spiel::setKlients( int anzahl, RCArray< SSKlientV > *zKlients )
- {
- this->zKlients = zKlients->getThis();
- }
- // call 5
- void Spiel::setSpielerNummern( int anzahl, Array< int > *spielerNummern )
- {
- MapReader *reader = new MapReader( karteId, psqldb->getThis(), mapPfad );
- reader->ladeKarte( this );
- reader->release();
- for( int i = 0; i < anzahl; i++ )
- {
- for( auto s = spieler.getIterator(); s; s++ )
- {
- if( s->getSpielerNummer() == spielerNummern->get( i ) )
- {
- s->setAccount( zAccounts->get( i ) );
- s->setKlient( new Klient( zKlients->get( i ) ) );
- break;
- }
- }
- }
- zAccounts = zAccounts->release();
- zKlients = zKlients->release();
- stat->setTeams( spielerAnzahl, &teams );
- stat->setSpieler( spielerAnzahl, &spieler );
- }
- // call 6
- void Spiel::run()
- {
- log = new Datei();
- Text *pfad = new Text( "../spiel log/" );
- pfad->append( spielId );
- pfad->append( "/verlauf.ksggl" );
- log->setDatei( pfad );
- log->remove();
- log->erstellen();
- log->open( Datei::Style::schreiben );
- time_t t;
- time( &t );
- srand( (unsigned int)t );
- log->schreibe( (char *)& spielerAnzahl, 4 );
- for( int i = 0; i < spielerAnzahl; i++ )
- {
- Spieler *tmp = spieler.z( i );
- if( tmp && tmp->zKlient() )
- {
- tmp->zKlient()->sendeInit( &spieler, -1 );
- log->schreibe( (char *)& i, 4 );
- int sNum = tmp->getSpielerNummer();
- log->schreibe( (char *)& sNum, 4 );
- tmp->zKlient()->sendeSpielerNummer( sNum, -1 );
- Text * name = psqldb->getAccountRufName( tmp->getAccountId() );
- char len = (char)( name ? name->getLength() : 0 );
- log->schreibe( &len, 1 );
- if( len )
- log->schreibe( name->getText(), len );
- if( name )
- name->release();
- }
- }
- __int64 randSeed = randG.getSeed();
- log->schreibe( (char *)& randSeed, 8 );
- Array< char > spielerStatus;
- ZeitMesser * zeit = new ZeitMesser();
- zeit->messungStart();
- isRunning = 1;
- ende = 0;
- double ausgleich = 0;
- double sZ = 0;
- gameTicks = -1;
- for( int i = 0; i < spielerAnzahl; i++ )
- {
- Spieler *tmp = spieler.z( i );
- if( tmp && tmp->zKlient() )
- tmp->zKlient()->sendeStart( gameTicks );
- }
- double rZeit = 0;
- while( !ende )
- {
- zeit->messungEnde();
- zeit->messungStart();
- double z = zeit->getSekunden();
- ausgleich += TICK - z;
- if( ausgleich > 0 )
- Sleep( (int)( ausgleich * 1000 ) );
- rZeit += z;
- while( sZ + TICK < rZeit && !ende )
- {
- c.lock();
- sZ += TICK;
- gameTicks++;
- char ch = 0;
- log->schreibe( &ch, 1 );
- tick( TICK );
- c.unlock();
- }
- }
- zeit->messungEnde();
- zeit->release();
- for( int i = 0; i < spielerAnzahl; i++ )
- {
- if( spieler.z( i ) && spieler.z( i )->zKlient() )
- {
- if( !spieler.z( i )->zTeam()->getPunkte() )
- {
- spielerStatus.set( 1, i ); // Datenbank Verloren
- spieler.z( i )->zKlient()->sendeSpielEnde( 0, 0 );
- }
- else
- {
- spielerStatus.set( 2, i ); // Datenbank Gewonnen
- spieler.z( i )->zKlient()->sendeSpielEnde( 1, 0 );
- }
- }
- if( spieler.z( i ) && ( !spieler.z( i )->zKlient() || !spieler.z( i )->zKlient()->istOnline() ) )
- spielerStatus.set( 3, i );
- }
- psqldb->setSpielStatusBeendet( spielId, 5 );
- for( int i = 0; i < spielerAnzahl; i++ )
- {
- Spieler *tmp = spieler.z( i );
- if( tmp )
- {
- psqldb->setSpielSpielerStatus( spielId, tmp->getAccountId(), tmp->getPunkte(), spielerStatus.get( i ) );
- psqldb->addSpielerStatistik( tmp->getAccountId(), spielId );
- }
- }
- log->close();
- log = log->release();
- isRunning = 0;
- }
- // call 7
- void Spiel::klientOffline( int accountId )
- {
- for( int i = 0; i < spielerAnzahl; i++ )
- {
- if( spieler.z( i )->getAccountId() == accountId )
- spieler.z( i )->zKlient()->offline();
- }
- }
- void Spiel::klientOnline( int accountId, SSKlientV *zKlient )
- {
- for( int i = 0; i < spielerAnzahl; i++ )
- {
- if( spieler.z( i )->getAccountId() == accountId )
- {
- c.lock();
- Spieler *s = spieler.z( i );
- Klient *tmp = s->zKlient();
- tmp->online( zKlient );
- tmp->sendeSpielerNummer( s->getSpielerNummer(), 0 );
- //--------------------------
- c.unlock();
- }
- }
- }
- void Spiel::nachricht( int accountId, int len, char *bytes )
- {
- }
- void Spiel::setPausiert( bool pausiert )
- {
- this->pause = pausiert;
- }
- void Spiel::tick( double zeit )
- {
- }
- void Spiel::addVariable( const char *name, Variable *var )
- {
- bool found = 0;
- for( auto v = variablen.getIterator(); v; v++ )
- {
- if( v->zName()->istGleich( name ) )
- {
- found = 1;
- break;
- }
- }
- if( !found )
- variablen.add( new VarPointer( name, var ) );
- else
- var->release();
- }
- void Spiel::setVariable( const char *name, Variable *var )
- {
- bool found = 0;
- for( auto v = variablen.getIterator(); v; v++ )
- {
- if( v->zName()->istGleich( name ) )
- {
- v->setVariable( var );
- break;
- }
- }
- if( !found )
- var->release();
- }
- void Spiel::addTeam( Team *team )
- {
- teams.add( team );
- }
- void Spiel::addSpieler( Spieler *spieler )
- {
- this->spieler.add( spieler );
- }
- Variable *Spiel::getVariable( const char *name ) const
- {
- for( auto v = variablen.getIterator(); v; v++ )
- {
- if( v->zName()->istGleich( name ) )
- return v->getVariable();
- }
- return 0;
- }
- Variable *Spiel::zVariable( const char *name ) const
- {
- for( auto v = variablen.getIterator(); v; v++ )
- {
- if( v->zName()->istGleich( name ) )
- return v->zVariable();
- }
- return 0;
- }
- bool Spiel::istPausiert() const
- {
- return pause;
- }
- // constant
- StatistikV *Spiel::getStatistik() const
- {
- return stat->getThis();
- }
- // Reference Counting
- SpielKlasse *Spiel::getThis()
- {
- ref++;
- return this;
- }
- SpielKlasse *Spiel::release()
- {
- if( !--ref )
- delete this;
- return 0;
- }
|