1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918 |
- #include "Datenbank.h"
- #include <Zeit.h>
- #include "AccountHistorieDaten.h"
- #include "KartenLeser.h"
- // Inhalt der LSDatenbank Klasse aus Datenbank.h
- // Konstruktor
- ISDatenbank::ISDatenbank(InitDatei* zIni)
- : ReferenceCounter()
- {
- datenbank = new Datenbank(zIni->zWert("DBBenutzer")->getText(), zIni->zWert("DBPasswort")->getText(),
- zIni->zWert("DBName")->getText(), zIni->zWert("DBIP")->getText(),
- (unsigned short)TextZuInt(zIni->zWert("DBPort")->getText(), 10));
- if (!datenbank->istOk())
- {
- std::cout << "IS: Die Verbindung zur Datenbank konnte nicht hergestellt werden.\nDas Programm wird beendet.";
- exit(1);
- }
- InitializeCriticalSection(&cs);
- Text befehl = "SELECT port, admin_port FROM server WHERE id = ";
- befehl += zIni->zWert("ServerId")->getText();
- lock();
- datenbank->befehl(befehl);
- Result res = datenbank->getResult();
- unlock();
- if (res.zeilenAnzahl == 1)
- {
- zIni->addWert("ServerPort", res.values[0]);
- zIni->addWert("AdminServerPort", res.values[1]);
- }
- res.destroy();
- }
- // Destruktor
- ISDatenbank::~ISDatenbank()
- {
- datenbank->release();
- DeleteCriticalSection(&cs);
- }
- // nicht constant
- void ISDatenbank::lock()
- {
- EnterCriticalSection(&cs);
- }
- void ISDatenbank::unlock()
- {
- LeaveCriticalSection(&cs);
- }
- int ISDatenbank::istAdministrator(const char* name, const char* passwort)
- {
- Text* befehl = new Text("SELECT id FROM benutzer WHERE name = '");
- befehl->append(name);
- befehl->append("' AND passwort = md5('");
- befehl->append(passwort);
- befehl->append("')");
- lock();
- datenbank->befehl(befehl->getText());
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- int ret = 0;
- if (res.zeilenAnzahl > 0)
- ret = TextZuInt(res.values[0].getText(), 10);
- res.destroy();
- return ret;
- }
- bool ISDatenbank::adminHatRecht(int id, int recht)
- {
- Text* befehl = new Text("SELECT * FROM benutzer_rechte WHERE benutzer_id = ");
- befehl->append(id);
- befehl->append(" AND rechte_id = ");
- befehl->append(recht);
- lock();
- datenbank->befehl(befehl->getText());
- int ret = datenbank->getZeilenAnzahl();
- unlock();
- befehl->release();
- return ret != 0;
- }
- bool ISDatenbank::proveKlient(int num, int sNum)
- {
- Text* befehl = new Text("SELECT * FROM server_client WHERE server_id = ");
- befehl->append(sNum);
- befehl->append(" AND client_id = ");
- befehl->append(num);
- lock();
- datenbank->befehl(befehl->getText());
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- bool ret = 0;
- if (res.zeilenAnzahl == 1)
- ret = 1;
- res.destroy();
- return ret;
- }
- Text* ISDatenbank::getKlientKey(int cId)
- {
- lock();
- if (!datenbank->befehl(Text("SELECT schluessel FROM client WHERE id = ") += cId))
- {
- unlock();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- Text* ret = new Text(res.values[0].getText());
- res.destroy();
- return ret;
- }
- void ISDatenbank::unregisterKlient(int num, int sNum)
- {
- Text* befehl = new Text("DELETE FROM server_client WHERE client_id = ");
- befehl->append(num);
- befehl->append(" AND server_id = ");
- befehl->append(sNum);
- lock();
- datenbank->befehl(befehl->getText());
- int za = datenbank->getZeilenAnzahl();
- unlock();
- if (za == 1)
- {
- befehl->setText("UPDATE server SET tasks = tasks - 1 WHERE id = ");
- befehl->append(sNum);
- lock();
- datenbank->befehl(befehl->getText());
- unlock();
- }
- befehl->release();
- }
- bool ISDatenbank::setServerStatus(int id, int status)
- {
- Text* befehl = new Text("UPDATE server SET server_status_id = ");
- *befehl += status;
- *befehl += "WHERE id = ";
- *befehl += id;
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- bool ret = datenbank->getZeilenAnzahl() != 0;
- unlock();
- befehl->release();
- return ret;
- }
- bool ISDatenbank::setMaxClients(int id, int maxC)
- {
- Text* befehl = new Text("UPDATE server SET max_tasks = ");
- befehl->append(maxC);
- befehl->append(" WHERE id = ");
- befehl->append(id);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- bool ret = datenbank->getZeilenAnzahl() > 0;
- unlock();
- befehl->release();
- return ret;
- }
- bool ISDatenbank::serverIstNichtPausiert(int id)
- {
- Text* befehl = new Text("SELECT server_status_id FROM server WHERE id = ");
- befehl->append(id);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- bool ret = (int)res.values[0] == 3;
- res.destroy();
- return ret;
- }
- Text* ISDatenbank::getInformationsText(char* typ)
- {
- lock();
- if (!datenbank->befehl("SELECT text, typ FROM info_text ORDER BY insert_datum DESC LIMIT 1"))
- {
- unlock();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- *typ = 0;
- return 0;
- }
- *typ = (char)TextZuInt(res.values[1].getText(), 10);
- Text* ret = new Text(res.values[0].getText());
- res.destroy();
- return ret;
- }
- bool ISDatenbank::istSpielErlaubt(int spielId)
- {
- Text* befehl = new Text("SELECT erlaubt FROM spiel_art WHERE id = ");
- befehl->append(spielId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- bool ret = 0;
- if (res.zeilenAnzahl > 0 && res.values[0].istGleich("t"))
- ret = 1;
- res.destroy();
- return ret;
- }
- bool ISDatenbank::istKarteErlaubt(int karteId)
- {
- Text* befehl = new Text("SELECT erlaubt FROM karte WHERE id = ");
- befehl->append(karteId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- bool ret = 0;
- if (res.zeilenAnzahl > 0 && res.values[0].istGleich("t"))
- ret = 1;
- res.destroy();
- return ret;
- }
- Text* ISDatenbank::getAccountRufName(int accountId)
- {
- Text* befehl = new Text("SELECT ruf_name FROM account WHERE id = ");
- befehl->append(accountId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- Text* ret = new Text(res.values[0].getText());
- res.destroy();
- return ret;
- }
- int ISDatenbank::getAccountId(const char* rufName)
- {
- Text* befehl = new Text("SELECT id FROM account WHERE ruf_name = '");
- befehl->append(rufName);
- befehl->append("' LIMIT 1");
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- int ret = TextZuInt(res.values[0].getText(), 10);
- res.destroy();
- return ret;
- }
- Array< int >* ISDatenbank::getAccountSpielStatistik(int accountId, int spielId)
- {
- Text* befehl = new Text("SELECT gespielt, gewonnen, verloren, punkte, bw0, bw1, bw2, bw3, bw4, bw5 FROM spiel_statistik WHERE account_id = ");
- befehl->append(accountId);
- befehl->append(" AND spiel_art_id = ");
- befehl->append(spielId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- Array< int >* ret = new Array< int >();
- if (!res.zeilenAnzahl)
- {
- for (int i = 0; i < res.feldAnzahl; i++)
- ret->add(0);
- res.destroy();
- return ret;
- }
- for (int i = 0; i < res.feldAnzahl; i++)
- ret->add(TextZuInt(res.values[i].getText(), 10));
- res.destroy();
- return ret;
- }
- int ISDatenbank::getAccountKarteSpiele(int accountId, int karteId)
- {
- Text* befehl = new Text("SELECT count( a.id ) FROM spiel a, spiel_spieler b WHERE a.id = b.spiel_id AND b.account_id = ");
- befehl->append(accountId);
- befehl->append(" AND a.karte_id = ");
- befehl->append(karteId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- int ret = (int)res.values[0];
- res.destroy();
- return ret;
- }
- int ISDatenbank::getAccountKarteSpieleGewonnen(int accountId, int karteId)
- {
- Text* befehl = new Text("SELECT count( a.id ) FROM spiel a, spiel_spieler b WHERE a.id = b.spiel_id "
- "AND b.spiel_spieler_status_id = 2 AND b.account_id = ");
- befehl->append(accountId);
- befehl->append(" AND a.karte_id = ");
- befehl->append(karteId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- int ret = (int)res.values[0];
- res.destroy();
- return ret;
- }
- Text* ISDatenbank::getKarteName(int karteId)
- {
- Text* befehl = new Text("SELECT name FROM karte WHERE id = ");
- befehl->append(karteId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- Text* ret = new Text(res.values[0].getText());
- res.destroy();
- return ret;
- }
- Text* ISDatenbank::getSpielName(int spielId)
- {
- Text* befehl = new Text("SELECT name FROM spiel_art WHERE id = ");
- befehl->append(spielId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- Text* ret = new Text(res.values[0].getText());
- res.destroy();
- return ret;
- }
- Text* ISDatenbank::getChatroomName(int chatroomId)
- {
- Text* befehl = new Text("SELECT name FROM chatroom WHERE id = ");
- befehl->append(chatroomId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- Text* ret = new Text(res.values[0].getText());
- res.destroy();
- return ret;
- }
- int ISDatenbank::getChatroomId(const char* name)
- {
- Text* befehl = new Text("SELECT id FROM chatroom WHERE name = '");
- befehl->append(name);
- befehl->append("' LIMIT 1");
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- int ret = TextZuInt(res.values[0].getText(), 10);
- res.destroy();
- return ret;
- }
- int ISDatenbank::getSpielId(int karteId)
- {
- Text* befehl = new Text("SELECT spiel_art_id FROM karte WHERE id = ");
- befehl->append(karteId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- int ret = TextZuInt(res.values[0].getText(), 10);
- res.destroy();
- return ret;
- }
- int ISDatenbank::getSpielId(const char* name)
- {
- Text* befehl = new Text("SELECT id FROM spiel_art WHERE name = '");
- befehl->append(name);
- befehl->append("'");
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- int ret = TextZuInt(res.values[0].getText(), 10);
- res.destroy();
- return ret;
- }
- int ISDatenbank::getKarteId(const char* name)
- {
- Text* befehl = new Text("SELECT id FROM karte WHERE name = '");
- befehl->append(name);
- befehl->append("'");
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- int ret = TextZuInt(res.values[0].getText(), 10);
- res.destroy();
- return ret;
- }
- int ISDatenbank::getGruppenKarteId(int gruppeId)
- {
- Text* befehl = new Text("SELECT karte_id FROM gruppe WHERE id = ");
- befehl->append(gruppeId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- int ret = TextZuInt(res.values[0].getText(), 10);
- res.destroy();
- return ret;
- }
- int ISDatenbank::getGruppeAdminId(int gruppeId)
- {
- Text* befehl = new Text("SELECT admin_account_id FROM gruppe WHERE id = ");
- befehl->append(gruppeId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- int ret = TextZuInt(res.values[0].getText(), 10);
- res.destroy();
- return ret;
- }
- int ISDatenbank::getSpielerPunkte(int spielId, int accountId)
- {
- Text* befehl = new Text("SELECT sum( b.punkte ) FROM spiel a, spiel_spieler b, karte c WHERE a.karte_id = c.id "
- "AND a.spiel_status_id = 5 AND c.spiel_art_id = ");
- befehl->append(spielId);
- befehl->append(" AND b.spiel_id = a.id AND b.account_id = ");
- befehl->append(accountId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- int ret = TextZuInt(res.values[0].getText(), 10);
- res.destroy();
- return ret;
- }
- Array< int >* ISDatenbank::getAccountSpielArtListe(int cId)
- {
- Text* befehl = new Text("SELECT a.spiel_art_id FROM spiel_art_account a, account_client b "
- "WHERE a.account_id = b.account_id AND a.end_dat IS NULL AND b.client_id = ");
- befehl->append(cId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- Array< int >* ret = new Array< int >();
- for (int i = 0; i < res.zeilenAnzahl; i++)
- ret->add(TextZuInt(res.values[i].getText(), 10));
- res.destroy();
- return ret;
- }
- int ISDatenbank::getNeusteSpielVersion(int sId)
- {
- Text* befehl = new Text("SELECT a.version FROM datei_gruppe a, spiel_art b WHERE a.id = b.datei_gruppe_id AND b.id = ");
- befehl->append(sId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- int ret = TextZuInt(res.values[0].getText(), 10);
- res.destroy();
- return ret;
- }
- int ISDatenbank::getKupfer(int cId)
- {
- Text* befehl = new Text("SELECT a.kupfer FROM account a, account_client b WHERE a.id = b.account_id AND b.client_id = ");
- befehl->append(cId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- int ret = TextZuInt(res.values[0].getText(), 10);
- res.destroy();
- return ret;
- }
- int ISDatenbank::getDateiGruppeVonSpiel(int sId)
- {
- Text* befehl = new Text("SELECT datei_gruppe_id FROM spiel_art WHERE id = ");
- befehl->append(sId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- int ret = TextZuInt(res.values[0].getText(), 10);
- res.destroy();
- return ret;
- }
- Text* ISDatenbank::getDateiGruppePfad(int dgId)
- {
- Text* befehl = new Text("SELECT pfad FROM datei_gruppe WHERE id = ");
- befehl->append(dgId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- Text* ret = new Text(res.values[0].getText());
- res.destroy();
- return ret;
- }
- Array< int >* ISDatenbank::getAccountKarteListe(int cId, int sId)
- {
- Text* befehl = new Text("SELECT a.karte_id FROM karte_account a, account_client b, karte c "
- "WHERE c.id = a.karte_id AND a.account_id = b.account_id AND a.end_dat IS NULL AND b.client_id = ");
- befehl->append(cId);
- befehl->append(" AND c.spiel_art_id = ");
- befehl->append(sId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- Array< int >* ret = new Array< int >();
- for (int i = 0; i < res.zeilenAnzahl; i++)
- ret->add(TextZuInt(res.values[i].getText(), 10));
- res.destroy();
- return ret;
- }
- bool ISDatenbank::hatAccountKarte(int account, int karte)
- {
- Text* befehl = new Text("SELECT karte_id FROM karte_account WHERE end_dat IS NULL AND karte_id = ");
- befehl->append(karte);
- befehl->append(" AND account_id = ");
- befehl->append(account);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- bool ret = datenbank->getZeilenAnzahl() != 0;
- unlock();
- befehl->release();
- return ret;
- }
- bool ISDatenbank::hatAccountSpiel(int account, int spiel)
- {
- Text* befehl = new Text("SELECT spiel_art_id FROM spiel_art_account WHERE end_dat IS NULL AND spiel_art_id = ");
- befehl->append(spiel);
- befehl->append(" AND account_id = ");
- befehl->append(account);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- bool ret = datenbank->getZeilenAnzahl() != 0;
- unlock();
- befehl->release();
- return ret;
- }
- Array< int >* ISDatenbank::getAccountKarteGespieltListe(int accountId, int spielArt)
- {
- Text* befehl = new Text("SELECT distinct( c.id ) FROM spiel a, spiel_spieler b, karte c WHERE "
- "a.karte_id = c.id AND b.spiel_id = a.id AND b.account_id = ");
- befehl->append(accountId);
- befehl->append(" AND c.spiel_art_id = ");
- befehl->append(spielArt);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- Array< int >* ret = new Array< int >();
- for (int i = 0; i < res.zeilenAnzahl; i++)
- ret->set((int)res.values[i], i);
- res.destroy();
- return ret;
- }
- Array< int >* ISDatenbank::getAccountSpielGespieltListe(int accountId)
- {
- Text* befehl = new Text("SELECT distinct( c.spiel_art_id ) FROM spiel a, spiel_spieler b, karte c WHERE "
- "a.karte_id = c.id AND b.spiel_id = a.id AND b.account_id = ");
- befehl->append(accountId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- Array< int >* ret = new Array< int >();
- for (int i = 0; i < res.zeilenAnzahl; i++)
- ret->add((int)res.values[i]);
- res.destroy();
- return ret;
- }
- int ISDatenbank::getDateiGruppeVonPfad(const char* pfad)
- {
- Text* befehl = new Text("SELECT id FROM datei_gruppe WHERE pfad = '");
- befehl->append(pfad);
- befehl->append("'");
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- int ret = TextZuInt(res.values[0].getText(), 10);
- res.destroy();
- return ret;
- }
- int ISDatenbank::getNeusteDateiGruppe(int dg)
- {
- Text* befehl = new Text("SELECT version FROM datei_gruppe WHERE id = ");
- befehl->append(dg);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- int ret = TextZuInt(res.values[0].getText(), 10);
- res.destroy();
- return ret;
- }
- bool ISDatenbank::getGruppeSpielerAdd(int gruppeId)
- {
- Text* befehl = new Text("SELECT spiel_starten FROM gruppe WHERE id = ");
- befehl->append(gruppeId);
- lock();
- if (!datenbank->befehl(befehl->getText()))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- bool ret = res.values[0].istGleich("f");
- res.destroy();
- return ret;
- }
- Result ISDatenbank::getSpielerListe(const char* suche, int* seite, int* maxSeite, int sortStalte, bool backwords)
- {
- Text* befehl = new Text("SELECT count( a.id ) FROM account a, "
- "( SELECT a.id, max( b.datum ) "
- " FROM account a LEFT JOIN "
- " ( SELECT g.spiel_art_id, i.account_id"
- " FROM karte g, spiel h, spiel_spieler i "
- " WHERE i.spiel_id = h.id AND h.karte_id = g.id AND h.beginn_datum = "
- " ( SELECT max( x.beginn_datum ) FROM spiel x, spiel_spieler y WHERE y.spiel_id = x.id AND y.account_id = i.account_id ) ) f ON a.id = f.account_id "
- " LEFT JOIN account_online b ON b.account_id = a.id "
- " LEFT JOIN spiel_statistik e ON e.account_id = a.id "
- " LEFT JOIN spiel_art c ON c.id = f.spiel_art_id "
- " LEFT JOIN karte d ON c.id = d.spiel_art_id "
- " WHERE a.name LIKE '");
- befehl->append(suche);
- befehl->append("' AND d.spiel_art_id = c.id "
- " AND e.spiel_art_id = f.spiel_art_id "
- " GROUP BY a.id ) b "
- "WHERE a.id = b.id");
- lock();
- if (!datenbank->befehl(*befehl))
- {
- unlock();
- befehl->release();
- Result res = { 0, 0, 0, 0 };
- return res;
- }
- Result res = datenbank->getResult();
- unlock();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- befehl->release();
- Result res = { 0, 0, 0, 0 };
- return res;
- }
- int entrys = (int)res.values[0];
- res.destroy();
- *maxSeite = entrys / 21;
- if (entrys % 21)
- (*maxSeite)++;
- if (*seite > *maxSeite)
- *seite = *maxSeite;
- if (!(*seite))
- {
- befehl->release();
- Result res = { 0, 0, 0, 0 };
- return res;
- }
- befehl->setText("SELECT a.id, a.ruf_name, max( b.datum ), c.name, d.name, e.punkte "
- "FROM account a LEFT JOIN "
- "( SELECT g.spiel_art_id, i.account_id "
- " FROM karte g, spiel h, spiel_spieler i "
- " WHERE i.spiel_id = h.id AND h.karte_id = g.id AND h.beginn_datum = "
- "( SELECT max( x.beginn_datum ) FROM spiel x, spiel_spieler y WHERE y.spiel_id = x.id AND y.account_id = i.account_id ) ) f ON a.id = f.account_id "
- "LEFT JOIN account_online b ON b.account_id = a.id "
- "LEFT JOIN spiel_statistik e ON e.account_id = a.id "
- "LEFT JOIN spiel_art c ON c.id = f.spiel_art_id "
- "LEFT JOIN karte d ON c.id = d.spiel_art_id "
- "WHERE a.name LIKE '");
- befehl->append(suche);
- befehl->append("' AND ( d.spiel_art_id = c.id "
- "AND e.spiel_art_id = f.spiel_art_id ) "
- "OR d.spiel_art_id IS NULL "
- "GROUP BY a.id, a.ruf_name, c.name, d.name, e.punkte ORDER BY ");
- befehl->append(sortStalte + 2);
- if (backwords)
- befehl->append(" DESC");
- befehl->append(" OFFSET ");
- befehl->append(((*seite) - 1) * 21);
- befehl->append(" LIMIT 21");
- lock();
- if (!datenbank->befehl(*befehl))
- {
- unlock();
- befehl->release();
- Result res = { 0, 0, 0, 0 };
- return res;
- }
- res = datenbank->getResult();
- unlock();
- befehl->release();
- return res;
- }
- bool ISDatenbank::getSpielerAktivity(int accountId, RCArray< Text >* datum, Array< double >* stOnline, Array< double >* stGespielt,
- Array< int >* anzSpiele, Array< int >* anzGewonnen)
- {
- Datum* beg = getDatum();
- Datum* end = getDatum();
- beg->minusTag(29);
- end->minusTag(29);
- end->plusTag(1);
- for (int i = 0; i < 30; i++)
- { // 30 Tage Rückblick
- datum->add(beg->getDatum("d-m-y"));
- Text* b = beg->getDatum("y-m-d");
- Text* e = end->getDatum("y-m-d");
- stOnline->add(getOnlineSeconds(accountId, *b, *e) / (60.0 * 60));
- stGespielt->add(getGespieltSeconds(accountId, *b, *e) / (60.0 * 60));
- anzSpiele->add(getGespieltSpiele(accountId, *b, *e));
- anzGewonnen->add(getGewonnenSpiele(accountId, *b, *e));
- b->release();
- e->release();
- beg->plusTag(1);
- end->plusTag(1);
- }
- return 1;
- }
- int ISDatenbank::getOnlineSeconds(int accountId, const char* beg, const char* end)
- {
- int sec = 0;
- Text* befehl = new Text("SELECT date_part( 'epoch', ( SELECT sum( now() - '");
- befehl->append(beg);
- befehl->append("' ) FROM account_online WHERE datum < '");
- befehl->append(beg);
- befehl->append("' AND now() < '");
- befehl->append(end);
- befehl->append("' AND now() > '");
- befehl->append(beg);
- befehl->append("' AND end_datum IS NULL AND account_id = ");
- befehl->append(accountId);
- befehl->append(" )::INTERVAL )");
- lock();
- if (!datenbank->befehl(*befehl))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- if (res.zeilenAnzahl)
- sec += (int)res.values[0];
- res.destroy();
- befehl->setText("SELECT date_part( 'epoch', ( SELECT sum( now() - datum ) FROM account_online WHERE datum > '");
- befehl->append(beg);
- befehl->append("' AND now() < '");
- befehl->append(end);
- befehl->append("' AND end_datum IS NULL AND account_id = ");
- befehl->append(accountId);
- befehl->append(" )::INTERVAL )");
- lock();
- if (!datenbank->befehl(*befehl))
- {
- unlock();
- befehl->release();
- return 0;
- }
- res = datenbank->getResult();
- unlock();
- if (res.zeilenAnzahl)
- sec += (int)res.values[0];
- res.destroy();
- befehl->setText("SELECT date_part( 'epoch', ( SELECT sum( '");
- befehl->append(end);
- befehl->append("' - datum ) FROM account_online WHERE datum > '");
- befehl->append(beg);
- befehl->append("' AND datum < '");
- befehl->append(end);
- befehl->append("' AND now() > '");
- befehl->append(end);
- befehl->append("' AND end_datum IS NULL AND account_id = ");
- befehl->append(accountId);
- befehl->append(" )::INTERVAL )");
- lock();
- if (!datenbank->befehl(*befehl))
- {
- unlock();
- befehl->release();
- return 0;
- }
- res = datenbank->getResult();
- unlock();
- if (res.zeilenAnzahl)
- sec += (int)res.values[0];
- res.destroy();
- befehl->setText("SELECT date_part( 'epoch', ( SELECT sum( '");
- befehl->append(end);
- befehl->append("'::TIMESTAMP WITH TIME ZONE - '");
- befehl->append(beg);
- befehl->append("' ) FROM account_online WHERE datum < '");
- befehl->append(beg);
- befehl->append("' AND now() > '");
- befehl->append(end);
- befehl->append("' AND end_datum IS NULL AND account_id = ");
- befehl->append(accountId);
- befehl->append(" )::INTERVAL )");
- lock();
- if (!datenbank->befehl(*befehl))
- {
- unlock();
- befehl->release();
- return 0;
- }
- res = datenbank->getResult();
- unlock();
- if (res.zeilenAnzahl)
- sec += (int)res.values[0];
- res.destroy();
- befehl->setText("SELECT date_part( 'epoch', ( SELECT sum( end_datum - '");
- befehl->append(beg);
- befehl->append("' ) FROM account_online WHERE datum < '");
- befehl->append(beg);
- befehl->append("' AND end_datum < '");
- befehl->append(end);
- befehl->append("' AND end_datum > '");
- befehl->append(beg);
- befehl->append("' AND account_id = ");
- befehl->append(accountId);
- befehl->append(" )::INTERVAL )");
- lock();
- if (!datenbank->befehl(*befehl))
- {
- unlock();
- befehl->release();
- return 0;
- }
- res = datenbank->getResult();
- unlock();
- if (res.zeilenAnzahl)
- sec += (int)res.values[0];
- res.destroy();
- befehl->setText("SELECT date_part( 'epoch', ( SELECT sum( end_datum - datum ) FROM account_online WHERE datum > '");
- befehl->append(beg);
- befehl->append("' AND end_datum < '");
- befehl->append(end);
- befehl->append("' AND account_id = ");
- befehl->append(accountId);
- befehl->append(" )::INTERVAL )");
- lock();
- if (!datenbank->befehl(*befehl))
- {
- unlock();
- befehl->release();
- return 0;
- }
- res = datenbank->getResult();
- unlock();
- if (res.zeilenAnzahl)
- sec += (int)res.values[0];
- res.destroy();
- befehl->setText("SELECT date_part( 'epoch', ( SELECT sum( '");
- befehl->append(end);
- befehl->append("' - datum ) FROM account_online WHERE datum > '");
- befehl->append(beg);
- befehl->append("' AND datum < '");
- befehl->append(end);
- befehl->append("' AND end_datum > '");
- befehl->append(end);
- befehl->append("' AND account_id = ");
- befehl->append(accountId);
- befehl->append(" )::INTERVAL )");
- lock();
- if (!datenbank->befehl(*befehl))
- {
- unlock();
- befehl->release();
- return 0;
- }
- res = datenbank->getResult();
- unlock();
- if (res.zeilenAnzahl)
- sec += (int)res.values[0];
- res.destroy();
- befehl->setText("SELECT date_part( 'epoch', ( SELECT sum( '");
- befehl->append(end);
- befehl->append("'::TIMESTAMP WITH TIME ZONE - '");
- befehl->append(beg);
- befehl->append("' ) FROM account_online WHERE datum < '");
- befehl->append(beg);
- befehl->append("' AND end_datum > '");
- befehl->append(end);
- befehl->append("' AND account_id = ");
- befehl->append(accountId);
- befehl->append(" )::INTERVAL )");
- lock();
- if (!datenbank->befehl(*befehl))
- {
- unlock();
- befehl->release();
- return 0;
- }
- res = datenbank->getResult();
- unlock();
- if (res.zeilenAnzahl)
- sec += (int)res.values[0];
- res.destroy();
- befehl->release();
- return sec;
- }
- int ISDatenbank::getGespieltSeconds(int accountId, const char* beg, const char* end)
- {
- int sec = 0;
- Text* befehl = new Text("SELECT date_part( 'epoch', ( SELECT sum( now() - '");
- befehl->append(beg);
- befehl->append("' ) FROM spiel a, spiel_spieler b WHERE a.beginn_datum < '");
- befehl->append(beg);
- befehl->append("' AND now() < '");
- befehl->append(end);
- befehl->append("' AND now() > '");
- befehl->append(beg);
- befehl->append("' AND a.end_datum IS NULL AND a.id = b.spiel_id AND b.account_id = ");
- befehl->append(accountId);
- befehl->append(" )::INTERVAL )");
- lock();
- if (!datenbank->befehl(*befehl))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- if (res.zeilenAnzahl)
- sec += (int)res.values[0];
- res.destroy();
- befehl->setText("SELECT date_part( 'epoch', ( SELECT sum( now() - a.beginn_datum ) FROM spiel a, spiel_spieler b WHERE a.beginn_datum > '");
- befehl->append(beg);
- befehl->append("' AND now() < '");
- befehl->append(end);
- befehl->append("' AND a.end_datum IS NULL AND a.id = b.spiel_id AND b.account_id = ");
- befehl->append(accountId);
- befehl->append(" )::INTERVAL )");
- lock();
- if (!datenbank->befehl(*befehl))
- {
- unlock();
- befehl->release();
- return 0;
- }
- res = datenbank->getResult();
- unlock();
- if (res.zeilenAnzahl)
- sec += (int)res.values[0];
- res.destroy();
- befehl->setText("SELECT date_part( 'epoch', ( SELECT sum( '");
- befehl->append(end);
- befehl->append("' - a.beginn_datum ) FROM spiel a, spiel_spieler b WHERE a.beginn_datum > '");
- befehl->append(beg);
- befehl->append("' AND a.beginn_datum < '");
- befehl->append(end);
- befehl->append("' AND now() > '");
- befehl->append(end);
- befehl->append("' AND a.end_datum IS NULL AND a.id = b.spiel_id AND b.account_id = ");
- befehl->append(accountId);
- befehl->append(" )::INTERVAL )");
- lock();
- if (!datenbank->befehl(*befehl))
- {
- unlock();
- befehl->release();
- return 0;
- }
- res = datenbank->getResult();
- unlock();
- if (res.zeilenAnzahl)
- sec += (int)res.values[0];
- res.destroy();
- befehl->setText("SELECT date_part( 'epoch', ( SELECT sum( '");
- befehl->append(end);
- befehl->append("'::TIMESTAMP WITH TIME ZONE - '");
- befehl->append(beg);
- befehl->append("' ) FROM spiel a, spiel_spieler b WHERE a.beginn_datum < '");
- befehl->append(beg);
- befehl->append("' AND now() > '");
- befehl->append(end);
- befehl->append("' AND a.end_datum IS NULL AND a.id = b.spiel_id AND b.account_id = ");
- befehl->append(accountId);
- befehl->append(" )::INTERVAL )");
- lock();
- if (!datenbank->befehl(*befehl))
- {
- unlock();
- befehl->release();
- return 0;
- }
- res = datenbank->getResult();
- unlock();
- if (res.zeilenAnzahl)
- sec += (int)res.values[0];
- res.destroy();
- befehl->setText("SELECT date_part( 'epoch', ( SELECT sum( a.end_datum - '");
- befehl->append(beg);
- befehl->append("' ) FROM spiel a, spiel_spieler b WHERE a.beginn_datum < '");
- befehl->append(beg);
- befehl->append("' AND a.end_datum < '");
- befehl->append(end);
- befehl->append("' AND a.end_datum > '");
- befehl->append(beg);
- befehl->append("' AND a.id = b.spiel_id AND b.account_id = ");
- befehl->append(accountId);
- befehl->append(" )::INTERVAL )");
- lock();
- if (!datenbank->befehl(*befehl))
- {
- unlock();
- befehl->release();
- return 0;
- }
- res = datenbank->getResult();
- unlock();
- if (res.zeilenAnzahl)
- sec += (int)res.values[0];
- res.destroy();
- befehl->setText("SELECT date_part( 'epoch', ( SELECT sum( a.end_datum - a.beginn_datum ) FROM spiel a, spiel_spieler b WHERE a.beginn_datum > '");
- befehl->append(beg);
- befehl->append("' AND a.end_datum < '");
- befehl->append(end);
- befehl->append("' AND a.id = b.spiel_id AND b.account_id = ");
- befehl->append(accountId);
- befehl->append(" )::INTERVAL )");
- lock();
- if (!datenbank->befehl(*befehl))
- {
- unlock();
- befehl->release();
- return 0;
- }
- res = datenbank->getResult();
- unlock();
- if (res.zeilenAnzahl)
- sec += (int)res.values[0];
- res.destroy();
- befehl->setText("SELECT date_part( 'epoch', ( SELECT sum( '");
- befehl->append(end);
- befehl->append("' - a.beginn_datum ) FROM spiel a, spiel_spieler b WHERE a.beginn_datum > '");
- befehl->append(beg);
- befehl->append("' AND a.beginn_datum < '");
- befehl->append(end);
- befehl->append("' AND a.end_datum > '");
- befehl->append(end);
- befehl->append("' AND a.id = b.spiel_id AND account_id = ");
- befehl->append(accountId);
- befehl->append(" )::INTERVAL )");
- lock();
- if (!datenbank->befehl(*befehl))
- {
- unlock();
- befehl->release();
- return 0;
- }
- res = datenbank->getResult();
- unlock();
- if (res.zeilenAnzahl)
- sec += (int)res.values[0];
- res.destroy();
- befehl->setText("SELECT date_part( 'epoch', ( SELECT sum( '");
- befehl->append(end);
- befehl->append("'::TIMESTAMP WITH TIME ZONE - '");
- befehl->append(beg);
- befehl->append("' ) FROM spiel a, spiel_spieler b WHERE a.beginn_datum < '");
- befehl->append(beg);
- befehl->append("' AND a.end_datum > '");
- befehl->append(end);
- befehl->append("' AND a.id = b.spiel_id AND account_id = ");
- befehl->append(accountId);
- befehl->append(" )::INTERVAL )");
- lock();
- if (!datenbank->befehl(*befehl))
- {
- unlock();
- befehl->release();
- return 0;
- }
- res = datenbank->getResult();
- unlock();
- if (res.zeilenAnzahl)
- sec += (int)res.values[0];
- res.destroy();
- befehl->release();
- return sec;
- }
- int ISDatenbank::getGespieltSpiele(int accountId, const char* beg, const char* end)
- {
- int anz = 0;
- Text* befehl = new Text("SELECT count( a.id ) FROM spiel a, spiel_spieler b WHERE a.beginn_datum < '");
- befehl->append(beg);
- befehl->append("' AND a.end_datum < '");
- befehl->append(end);
- befehl->append("' AND a.end_datum > '");
- befehl->append(beg);
- befehl->append("' AND a.id = b.spiel_id AND b.account_id = ");
- befehl->append(accountId);
- lock();
- if (!datenbank->befehl(*befehl))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- if (res.zeilenAnzahl)
- anz += (int)res.values[0];
- res.destroy();
- befehl->setText("SELECT count( a.id ) FROM spiel a, spiel_spieler b WHERE a.beginn_datum > '");
- befehl->append(beg);
- befehl->append("' AND a.end_datum < '");
- befehl->append(end);
- befehl->append("' AND a.id = b.spiel_id AND b.account_id = ");
- befehl->append(accountId);
- lock();
- if (!datenbank->befehl(*befehl))
- {
- unlock();
- befehl->release();
- return 0;
- }
- res = datenbank->getResult();
- unlock();
- if (res.zeilenAnzahl)
- anz += (int)res.values[0];
- res.destroy();
- befehl->release();
- return anz;
- }
- int ISDatenbank::getGewonnenSpiele(int accountId, const char* beg, const char* end)
- {
- int anz = 0;
- Text* befehl = new Text("SELECT count( a.id ) FROM spiel a, spiel_spieler b WHERE a.beginn_datum < '");
- befehl->append(beg);
- befehl->append("' AND a.end_datum < '");
- befehl->append(end);
- befehl->append("' AND a.end_datum > '");
- befehl->append(beg);
- befehl->append("' AND a.id = b.spiel_id AND b.spiel_spieler_status_id = 2 AND b.account_id = ");
- befehl->append(accountId);
- lock();
- if (!datenbank->befehl(*befehl))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- if (res.zeilenAnzahl)
- anz += (int)res.values[0];
- res.destroy();
- befehl->setText("SELECT count( a.id ) FROM spiel a, spiel_spieler b WHERE a.beginn_datum > '");
- befehl->append(beg);
- befehl->append("' AND a.end_datum < '");
- befehl->append(end);
- befehl->append("' AND a.id = b.spiel_id AND b.spiel_spieler_status_id = 2 AND b.account_id = ");
- befehl->append(accountId);
- lock();
- if (!datenbank->befehl(*befehl))
- {
- unlock();
- befehl->release();
- return 0;
- }
- res = datenbank->getResult();
- unlock();
- if (res.zeilenAnzahl)
- anz += (int)res.values[0];
- res.destroy();
- befehl->release();
- return anz;
- }
- Result ISDatenbank::getSpielPartnerListe(int accountId)
- {
- Text* befehl = new Text("SELECT account_id_b, anzahl, karte_id FROM account_mitspieler WHERE account_id_a = ");
- befehl->append(accountId);
- lock();
- if (!datenbank->befehl(*befehl))
- {
- unlock();
- befehl->release();
- Result res = { 0, 0, 0, 0 };
- return res;
- }
- Result res = datenbank->getResult();
- unlock();
- befehl->release();
- return res;
- }
- Result ISDatenbank::getSpielStatistikListe(int accountId, int* seite, int* maxSeite, int sortStalte, bool backwords)
- {
- Text* befehl = new Text("SELECT count( spiel_art_id ) FROM spiel_statistik WHERE account_id = ");
- befehl->append(accountId);
- lock();
- if (!datenbank->befehl(*befehl))
- {
- unlock();
- befehl->release();
- Result res = { 0, 0, 0, 0 };
- return res;
- }
- Result res = datenbank->getResult();
- unlock();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- befehl->release();
- Result res = { 0, 0, 0, 0 };
- return res;
- }
- int entrys = (int)res.values[0];
- res.destroy();
- *maxSeite = entrys / 21;
- if (entrys % 21)
- (*maxSeite)++;
- if (*seite > *maxSeite)
- *seite = *maxSeite;
- if (!(*seite))
- {
- befehl->release();
- Result res = { 0, 0, 0, 0 };
- return res;
- }
- befehl->setText("SELECT a.id, a.name, b.gespielt, b.gewonnen, b.verloren, b.punkte, b.bw0, b.bw1, b.bw2, b.bw3, "
- "b.bw4, b.bw5 FROM spiel_art a, spiel_statistik b WHERE a.id = b.spiel_art_id AND b.account_id = ");
- befehl->append(accountId);
- befehl->append(" ORDER BY ");
- befehl->append(sortStalte + 2);
- if (backwords)
- befehl->append(" DESC");
- befehl->append(" OFFSET ");
- befehl->append(((*seite) - 1) * 18);
- befehl->append(" LIMIT 18");
- lock();
- if (!datenbank->befehl(*befehl))
- {
- unlock();
- befehl->release();
- Result res = { 0, 0, 0, 0 };
- return res;
- }
- res = datenbank->getResult();
- unlock();
- befehl->release();
- return res;
- }
- AHDaten* ISDatenbank::getSpielHistorie(int accountId, InformationServer* is)
- {
- Text* befehl = new Text("SELECT a.id, a.karte_id, c.name, d.name, substring( a.beginn_datum::CHARACTER VARYING FOR 16 ), "
- "b.spiel_spieler_status_id, a.spiel_status_id, count( e.spiel_id ) "
- "FROM spiel a, spiel_spieler b, spiel_art c, karte d, (SELECT spiel_id FROM spiel_spieler) e "
- "WHERE a.id = e.spiel_id AND a.karte_id = d.id AND d.spiel_art_id = c.id "
- "AND a.id = b.spiel_id AND b.account_id = ");
- *befehl += accountId;
- *befehl += " GROUP BY a.id, a.karte_id, c.name, d.name, a.beginn_datum, b.spiel_spieler_status_id, a.spiel_status_id "
- "ORDER BY beginn_datum DESC LIMIT 20";
- lock();
- if (!datenbank->befehl(*befehl))
- {
- unlock();
- befehl->release();
- return 0;
- }
- Result spielListe = datenbank->getResult();
- unlock();
- AHDaten* ret = new AHDaten();
- for (int i = 0; i < spielListe.zeilenAnzahl; i++)
- {
- SpielerTeamStruktur* sts = new SpielerTeamStruktur();
- bool stsOK = 1;
- KartenLeser* reader = new KartenLeser((int)spielListe.values[1 + i * spielListe.feldAnzahl], is);
- if (!reader->ladeSpielerTeamStruktur(sts))
- stsOK = 0;
- reader->release();
- AHSpielDaten* spiel = new AHSpielDaten();
- spiel->id = (int)spielListe.values[i * spielListe.feldAnzahl];
- spiel->karteId = (int)spielListe.values[1 + i * spielListe.feldAnzahl];
- spiel->spiel->setText(spielListe.values[2 + i * spielListe.feldAnzahl]);
- spiel->karte->setText(spielListe.values[3 + i * spielListe.feldAnzahl]);
- spiel->datum->setText(spielListe.values[4 + i * spielListe.feldAnzahl]);
- switch ((int)spielListe.values[5 + i * spielListe.feldAnzahl])
- {
- case 1:
- spiel->status->setText("Verloren");
- break;
- case 2:
- spiel->status->setText("Gewonnen");
- break;
- case 3:
- spiel->status->setText("Nicht Anwesend");
- break;
- case 4:
- spiel->status->setText("Beobachter");
- break;
- case 5:
- spiel->status->setText("Unentschieden");
- break;
- }
- switch ((int)spielListe.values[6 + i * spielListe.feldAnzahl])
- {
- case 1:
- spiel->spielStatus->setText("Beginnt");
- break;
- case 2:
- spiel->spielStatus->setText("Läuft");
- break;
- case 3:
- spiel->spielStatus->setText("Abgebrochen");
- break;
- case 4:
- spiel->spielStatus->setText("Fehlerhaft");
- break;
- case 5:
- spiel->spielStatus->setText("Beendet");
- break;
- case 6:
- spiel->spielStatus->setText("Unbewertet");
- break;
- }
- spiel->sAnzahl = (int)spielListe.values[7 + i * spielListe.feldAnzahl];
- *befehl = "SELECT substring( (end_datum - beginn_datum)::CHARACTER VARYING FOR 8) FROM spiel WHERE id = ";
- *befehl += spielListe.values[i * spielListe.feldAnzahl].getText();
- lock();
- if (datenbank->befehl(*befehl))
- {
- Result dauer = datenbank->getResult();
- unlock();
- if (dauer.zeilenAnzahl && dauer.values[0].getLength())
- spiel->dauer->setText(dauer.values[0]);
- }
- else
- unlock();
- int gewinnerTeam = -1;
- if (stsOK)
- {
- *befehl = "SELECT team_id FROM spiel_spieler WHERE spiel_spieler_status_id = 2 AND spiel_id = ";
- *befehl += spielListe.values[i * spielListe.feldAnzahl].getText();
- lock();
- if (datenbank->befehl(*befehl))
- {
- Result team = datenbank->getResult();
- unlock();
- if (team.zeilenAnzahl && team.values[0].getLength() && sts->teamName->z((int)team.values[0]))
- {
- spiel->gewinner->setText(sts->teamName->z((int)team.values[0])->getText());
- gewinnerTeam = (int)team.values[0];
- }
- }
- else
- unlock();
- }
- *befehl = "SELECT a.ruf_name, b.team_id, b.punkte, b.spiel_spieler_status_id, b.spieler_nummer FROM account a, spiel_spieler b WHERE b.account_id = a.id AND spiel_id = ";
- *befehl += spielListe.values[i * spielListe.feldAnzahl].getText();
- *befehl += " ORDER BY team_id";
- lock();
- if (datenbank->befehl(*befehl))
- {
- Result spielerListe = datenbank->getResult();
- unlock();
- for (int j = 0; j < spielerListe.zeilenAnzahl; j++)
- {
- int tAnz = spiel->teams->getEintragAnzahl();
- int index = -1;
- for (int k = 0; k < tAnz; k++)
- {
- if (spiel->teams->z(k)->id == (int)spielerListe.values[1 + j * spielerListe.feldAnzahl])
- {
- index = k;
- break;
- }
- }
- if (index < 0)
- {
- index = tAnz;
- AHSpielTeamDaten* team = new AHSpielTeamDaten();
- team->id = (int)spielerListe.values[1 + j * spielerListe.feldAnzahl];
- if (sts->teamName->z(team->id))
- team->name->setText(sts->teamName->z(team->id)->getText());
- team->sAnzahl = 0;
- if (team->id == gewinnerTeam)
- team->status->setText("Gewonnen");
- else
- team->status->setText("Verloren");
- if (sts->teamFarbe->hat(team->id))
- team->farbe = sts->teamFarbe->get(team->id);
- else
- team->farbe = 0;
- spiel->teams->add(team);
- }
- AHSpielSpielerDaten* spieler = new AHSpielSpielerDaten();
- spieler->name->setText(spielerListe.values[j * spielerListe.feldAnzahl]);
- spieler->punkte = (int)spielerListe.values[2 + j * spielerListe.feldAnzahl];
- if (sts->spielerFarbe->hat((int)spielerListe.values[4 + j * spielerListe.feldAnzahl] - 1))
- spieler->farbe = sts->spielerFarbe->get((int)spielerListe.values[4 + j * spielerListe.feldAnzahl] - 1);
- else
- spieler->farbe = 0;
- switch ((int)spielerListe.values[3 + j * spielerListe.feldAnzahl])
- {
- case 1:
- spieler->status->setText("Verloren");
- break;
- case 2:
- spieler->status->setText("Gewonnen");
- break;
- case 3:
- spieler->status->setText("Nicht Anwesend");
- break;
- case 4:
- spieler->status->setText("Beobachter");
- break;
- case 5:
- spieler->status->setText("Unentschieden");
- break;
- }
- spiel->teams->z(index)->sAnzahl++;
- spiel->teams->z(index)->spieler->add(spieler);
- }
- }
- else
- unlock();
- sts->release();
- ret->spiele->add(spiel);
- }
- return ret;
- }
- bool ISDatenbank::getHistorieServerPortIp(int clientId, int spielId, int* port, Text* ip)
- {
- lock();
- if (!datenbank->befehl(Text("SELECT a.id, a.port, a.ip FROM server a, server_historie_spiel b "
- "WHERE a.id = b.server_historie_id AND a.tasks < a.max_tasks - 1 AND "
- "a.server_status_id = 3 AND b.spiel_id = ") += spielId))
- {
- unlock();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- if (!res.zeilenAnzahl)
- {
- res.destroy();
- return 0;
- }
- int id = (int)res.values[0];
- *port = (int)res.values[1];
- *ip = res.values[2].getText();
- res.destroy();
- Text* befehl = new Text("INSERT INTO server_client( client_id, server_id ) VALUES ( ");
- befehl->append(clientId);
- befehl->append(", ");
- befehl->append(id);
- befehl->append(" )");
- bool ret = 1;
- lock();
- ret &= datenbank->befehl(Text("DELETE FROM server_client a USING server b WHERE b.server_typ_name = 'historie' AND b.id = a.server_id AND a.client_id = ") += clientId);
- ret &= datenbank->befehl(*befehl);
- unlock();
- befehl->release();
- return ret;
- }
- bool ISDatenbank::hatKlientRecht(int kId, int recht)
- {
- Text befehl = "SELECT a.* FROM account_user_rechte a, account_client b WHERE a.account_id = b.account_id AND b.client_id = ";
- befehl += kId;
- befehl += " AND a.user_rechte_id = ";
- befehl += recht;
- lock();
- datenbank->befehl(befehl);
- int num = datenbank->getZeilenAnzahl();
- unlock();
- return num == 1;
- }
- Result ISDatenbank::getKartenListe(int kId, const char* suchFilter, char sortSpalte, char sortRichtung)
- {
- Text befehl = "SELECT a.id, a.name, b.name, c.kupfer, a.verkauft, a.max_spieler FROM karte a ";
- befehl += "INNER JOIN spiel_art b ON a.spiel_art_id = b.id ";
- befehl += "LEFT JOIN karte_kauf_erlaubt c ON a.id = c.karte_id ";
- befehl += "INNER JOIN account_client d ON d.account_id = a.account_id ";
- befehl += "WHERE d.client_id = ";
- befehl += kId;
- befehl += " AND a.name LIKE'%";
- befehl += suchFilter;
- befehl += "%' ORDER BY ";
- befehl += sortSpalte + 2;
- if (sortRichtung) // absteigend
- befehl += " DESC";
- lock();
- if (!datenbank->befehl(befehl))
- {
- unlock();
- Result res = { 0, 0, 0, 0 };
- return res;
- }
- Result res = datenbank->getResult();
- unlock();
- return res;
- }
- bool ISDatenbank::getEditorServerPortIp(int clientId, int karteId, int* port, Text* ip)
- {
- Text befehl = "SELECT a.port, a.ip, a.id FROM server a, karte b, account_client c ";
- befehl += "WHERE a.id = b.server_editor_id AND b.account_id = c.account_id AND a.server_status_id = 3 AND c.client_id = ";
- befehl += clientId;
- befehl += " AND b.id = ";
- befehl += karteId;
- lock();
- if (!datenbank->befehl(befehl))
- {
- unlock();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- *port = (int)res.values[0];
- ip->setText(res.values[1]);
- int id = (int)res.values[2];
- res.destroy();
- befehl = "INSERT INTO server_client( client_id, server_id ) VALUES ( ";
- befehl += clientId;
- befehl += ", ";
- befehl += id;
- befehl += " )";
- bool ret = 1;
- lock();
- ret &= datenbank->befehl(Text("SELECT a.server_id FROM server_client a, server b WHERE a.server_id = b.id AND b.server_typ_name = 'editor' AND a.client_id = ") += clientId);
- ret &= datenbank->befehl(Text("DELETE FROM server_client a USING server b WHERE b.id = a.server_id AND b.server_typ_name = 'editor' AND a.client_id = ") += clientId);
- ret &= datenbank->befehl(befehl);
- unlock();
- return 1;
- }
- bool ISDatenbank::getKartenServerPortIp(int clientId, int karteId, int* port, Text* ip)
- {
- Text befehl = "SELECT a.port, a.ip, a.id FROM server a, karte b ";
- befehl += "WHERE a.id = b.server_karten_id AND a.server_status_id = 3 AND b.id = ";
- befehl += karteId;
- if (!karteId)
- befehl = "SELECT port, ip, id FROM server WHERE server_typ_name = 'karten' AND server_status_id = 3 LIMIT 1";
- lock();
- if (!datenbank->befehl(befehl))
- {
- unlock();
- return 0;
- }
- Result res = datenbank->getResult();
- unlock();
- if (!res.zeilenAnzahl)
- return 0;
- *port = (int)res.values[0];
- ip->setText(res.values[1]);
- int id = (int)res.values[2];
- res.destroy();
- if (clientId)
- {
- befehl = "INSERT INTO server_client( client_id, server_id ) VALUES ( ";
- befehl += clientId;
- befehl += ", ";
- befehl += id;
- befehl += " )";
- bool ret = 1;
- lock();
- ret &= datenbank->befehl(Text("SELECT a.server_id FROM server_client a, server b WHERE b.id = a.server_id AND b.server_typ_name = 'karten' AND a.client_id = ") += clientId);
- ret &= datenbank->befehl(Text("DELETE FROM server_client a USING server b WHERE b.id = a.server_id AND b.server_typ_name = 'karten' AND a.client_id = ") += clientId);
- ret &= datenbank->befehl(befehl);
- unlock();
- }
- return 1;
- }
- // constant
- Text* ISDatenbank::getLetzterFehler() const
- {
- return datenbank->getLetzterFehler();
- }
|